anpeng/apzl_leasing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

二手车车型收集修正

Browse Source
This commit is contained in:
张磊 2018-06-11 18:37:05 +08:00
parent 3fc124afcb
commit ea0f5b92ec
1 changed files with 58 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
src_tenwa/com/tenwa/lease/app/quartzmession/QueryVehicleModeListAction.java
View File

@ -31,8 +31,8 @@ public class QueryVehicleModeListAction implements Job{
/*String url = "http://api.che300.com/service/getCarModelList?token=8192047c7ab1a654eda8fbce470062f0&seriesId=";
String responseResult = VehicleAppraisementUtil.getResponseResult(url);*/
String filePath = "D://che300yasuo.txt";
String readFile = ReadJSON.ReadFile(filePath);
JSONObject object = JSONObject.parseObject(readFile);
//String readFile = ReadJSON.ReadFile(filePath);
JSONObject object = JSONObject.parseObject("此处待接口通了之后再导入接口返回的JSON字符串");
JSONObject dataObject = (JSONObject) object.get("data");
@SuppressWarnings("rawtypes")
List<HashMap> brandList = JSON.parseArray(JSON.toJSONString(dataObject.get("brand")), HashMap.class);
@ -62,15 +62,20 @@ public class QueryVehicleModeListAction implements Job{
bm1.saveObject(brandObject);
}else if("更新".equals(brandList.get(i).get("oper_type"))){
//更新的操作
bm1.createQuery("update O set brandname="+brandList.get(i).get("brand_name")
+",brandinitial="+brandList.get(i).get("brand_initial")
+",opertype="+brandList.get(i).get("oper_type")
+",modeltimestamp="+brandList.get(i).get("ModelTimestamp")
+",seriestimestamp="+brandList.get(i).get("SeriesTimestamp")
+",brandtimestamp="+brandList.get(i).get("BrandTimestamp")
+",currentversion="+brandList.get(i).get("CurrentVersion")
+",initialversion="+brandList.get(i).get("InitialVersion")
+"where brandid="+brandList.get(i).get("brand_id")).executeUpdate();
bm1.createQuery("update O set brandname=:BRANDNAME,brandinitial=:BRANDINITIAL"
+",opertype=:OPERTYPE,modeltimestamp=:MODELTIMESTAMP"
+",seriestimestamp=:SERIESTIMESTAMP,brandtimestamp=:BRANDTIMESTAMP"
+",currentversion=:CURRENTVERSION,initialversion=:INITIALVERSION"
+"where brandid=:BRANDID")
.setParameter("BRANDNAME", brandList.get(i).get("brand_name").toString())
.setParameter("BRANDINITIAL", brandList.get(i).get("brand_initial").toString())
.setParameter("OPERTYPE", brandList.get(i).get("oper_type").toString())
.setParameter("MODELTIMESTAMP", brandList.get(i).get("ModelTimestamp").toString())
.setParameter("SERIESTIMESTAMP", brandList.get(i).get("SeriesTimestamp").toString())
.setParameter("BRANDTIMESTAMP",brandList.get(i).get("BrandTimestamp").toString())
.setParameter("CURRENTVERSION", brandList.get(i).get("CurrentVersion").toString())
.setParameter("INITIALVERSION",brandList.get(i).get("InitialVersion").toString())
.setParameter("BRANDID", brandList.get(i).get("brand_id").toString()).executeUpdate();
}else{
continue;
}
@ -94,19 +99,26 @@ public class QueryVehicleModeListAction implements Job{
bm2.saveObject(seriesObject);
}else if("更新".equals(seriesList.get(i).get("oper_type"))){
//更新的操作
bm2.createQuery("update O set brandname="+seriesList.get(i).get("brand_name")
+",brandid="+seriesList.get(i).get("brand_id")
+",seriesname="+seriesList.get(i).get("series_name")
+",seriesgroupname="+seriesList.get(i).get("series_group_name")
+",levelname="+seriesList.get(i).get("level_name")
+",makertype="+seriesList.get(i).get("maker_type")
+",opertype="+seriesList.get(i).get("oper_type")
+",modeltimestamp="+seriesList.get(i).get("ModelTimestamp")
+",seriestimestamp="+seriesList.get(i).get("SeriesTimestamp")
+",brandtimestamp="+seriesList.get(i).get("BrandTimestamp")
+",currentversion="+seriesList.get(i).get("CurrentVersion")
+",initialversion="+seriesList.get(i).get("InitialVersion")
+"where seriesid="+seriesList.get(i).get("series_id")).executeUpdate();
bm2.createQuery("update O set brandname=:BRANDNAME"
+",brandid=:BRANDID,seriesname=:SERIESNAME,seriesgroupname=:SERIESGROUPNAME"
+",levelname=:LEVELNAME,makertype=:MAKERTYPE"
+",opertype=:OPERTYPE,modeltimestamp=:MODELTIMESTAMP"
+",seriestimestamp=:SERIESTIMESTAMP,brandtimestamp=:BRANDTIMESTAMP"
+",currentversion=:CURRENTVERSION,initialversion=:INITIALVERSION"
+"where seriesid=:SERIESID")
.setParameter("BRANDNAME", seriesList.get(i).get("brand_name").toString())
.setParameter("BRANDID", seriesList.get(i).get("brand_id").toString())
.setParameter("SERIESNAME", seriesList.get(i).get("series_name").toString())
.setParameter("SERIESGROUPNAME", seriesList.get(i).get("series_group_name").toString())
.setParameter("LEVELNAME", seriesList.get(i).get("level_name").toString())
.setParameter("MAKERTYPE", seriesList.get(i).get("maker_type").toString())
.setParameter("OPERTYPE", seriesList.get(i).get("oper_type").toString())
.setParameter("MODELTIMESTAMP", seriesList.get(i).get("ModelTimestamp").toString())
.setParameter("SERIESTIMESTAMP", seriesList.get(i).get("SeriesTimestamp").toString())
.setParameter("BRANDTIMESTAMP",seriesList.get(i).get("BrandTimestamp").toString())
.setParameter("CURRENTVERSION", seriesList.get(i).get("CurrentVersion").toString())
.setParameter("INITIALVERSION",seriesList.get(i).get("InitialVersion").toString())
.setParameter("SERIESID", seriesList.get(i).get("series_id").toString()).executeUpdate();
}else{
continue;
}
@ -138,28 +150,28 @@ public class QueryVehicleModeListAction implements Job{
modelObject.setAttributeValue("initialversion", map.get("InitialVersion"));
bm3.saveObject(modelObject);
}else if("更新".equals(modelList.get(i).get("oper_type"))){
bm3.createQuery("update O set brandname="+modelList.get(i).get("brand_name")
+",brandid="+modelList.get(i).get("brand_id")
+",seriesid="+modelList.get(i).get("series_id")
+",seriesname="+modelList.get(i).get("series_name")
+",seriesgroupname="+modelList.get(i).get("series_group_name")
+",modelname="+modelList.get(i).get("model_name")
+",price="+modelList.get(i).get("price")
+",liter="+modelList.get(i).get("liter")
+",geartype="+modelList.get(i).get("gear_type")
+",modelyear="+modelList.get(i).get("model_year")
+",makertype="+modelList.get(i).get("maker_type")
+",dischargestandard="+modelList.get(i).get("discharge_standard")
+",seatnumber="+modelList.get(i).get("seat_number")
+",minregyear="+modelList.get(i).get("min_reg_year")
+",maxregyear="+modelList.get(i).get("max_reg_year")
+",opertype="+modelList.get(i).get("oper_type")
+",modeltimestamp="+modelList.get(i).get("ModelTimestamp")
+",seriestimestamp="+modelList.get(i).get("SeriesTimestamp")
+",brandtimestamp="+modelList.get(i).get("BrandTimestamp")
+",currentversion="+modelList.get(i).get("CurrentVersion")
+",initialversion="+modelList.get(i).get("InitialVersion")
+"where modelid="+modelList.get(i).get("model_id")).executeUpdate();
bm3.createQuery("update O set brandname="+modelList.get(i).get("brand_name")
+",brandid="+modelList.get(i).get("brand_id")
+",seriesid="+modelList.get(i).get("series_id")
+",seriesname="+modelList.get(i).get("series_name")
+",seriesgroupname="+modelList.get(i).get("series_group_name")
+",modelname="+modelList.get(i).get("model_name")
+",price="+modelList.get(i).get("price")
+",liter="+modelList.get(i).get("liter")
+",geartype="+modelList.get(i).get("gear_type")
+",modelyear="+modelList.get(i).get("model_year")
+",makertype="+modelList.get(i).get("maker_type")
+",dischargestandard="+modelList.get(i).get("discharge_standard")
+",seatnumber="+modelList.get(i).get("seat_number")
+",minregyear="+modelList.get(i).get("min_reg_year")
+",maxregyear="+modelList.get(i).get("max_reg_year")
+",opertype="+modelList.get(i).get("oper_type")
+",modeltimestamp="+modelList.get(i).get("ModelTimestamp")
+",seriestimestamp="+modelList.get(i).get("SeriesTimestamp")
+",brandtimestamp="+modelList.get(i).get("BrandTimestamp")
+",currentversion="+modelList.get(i).get("CurrentVersion")
+",initialversion="+modelList.get(i).get("InitialVersion")
+"where modelid="+modelList.get(i).get("model_id")).executeUpdate();
}else{
continue;
}