|
|
@@ -174,6 +174,13 @@ public class SampleXxlJob {
|
|
|
@Autowired
|
|
|
private GcReconsiderService gcReconsiderService;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private ZrzySuppleService zrzySuppleService;
|
|
|
+ @Autowired
|
|
|
+ private AllianceCityWebsiteService allianceCityWebsiteService;
|
|
|
+ @Autowired
|
|
|
+ private MarginReturnCeService marginReturnCeService;
|
|
|
+
|
|
|
|
|
|
/**
|
|
|
* 1、工程-招标公告与资格预审公告【GC_NOTICEANDFILE】
|
|
|
@@ -620,6 +627,40 @@ public class SampleXxlJob {
|
|
|
}
|
|
|
|
|
|
|
|
|
+ @XxlJob("task_zrzy_td_supple")
|
|
|
+ public void zrzyTdSupple() throws Exception {
|
|
|
+ detailMethod(1);//1:post 0:get
|
|
|
+ }
|
|
|
+ @XxlJob("task_zrzy_kyq_supplenotice")
|
|
|
+ public void zrzyKyqSupplenotice() throws Exception {
|
|
|
+ detailMethod(1);//1:post 0:get
|
|
|
+ }
|
|
|
+ @XxlJob("task_zrzy_dk_supplenotice")
|
|
|
+ public void zrzyDkSupplenotice() throws Exception {
|
|
|
+ detailMethod(1);//1:post 0:get
|
|
|
+ }
|
|
|
+ @XxlJob("task_zrzy_bg_supplenotice")
|
|
|
+ public void zrzyBgSupplenotice() throws Exception {
|
|
|
+ detailMethod(1);//1:post 0:get
|
|
|
+ }
|
|
|
+ @XxlJob("task_zrzy_jyzb_supplenotice")
|
|
|
+ public void zrzyJyzbSupplenotice() throws Exception {
|
|
|
+ detailMethod(1);//1:post 0:get
|
|
|
+ }
|
|
|
+
|
|
|
+ @XxlJob("task_alliance_city_website")
|
|
|
+ public void task_alliance_city_website() throws Exception {
|
|
|
+ detailMethod(1);//1:post 0:get
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 工程建设保证金退还【MARGIN_RETURN_CE】
|
|
|
+ */
|
|
|
+ @XxlJob("task_MARGIN_RETURN_CE")
|
|
|
+ public void MARGIN_RETURN_CE() throws Exception {
|
|
|
+ detailMethod(1);//1:post 0:get
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
private void detailMethod(Integer type){
|
|
|
System.out.println("进来了==================");
|
|
|
@@ -885,6 +926,12 @@ public class SampleXxlJob {
|
|
|
XxlJobHelper.log(param+":数据入库="+gcReconsiderList.size());
|
|
|
gcReconsiderService.saveOrUpdateBatch(gcReconsiderList);
|
|
|
break;
|
|
|
+ case "MARGIN_RETURN_CE"://工程建设7.6.2保证金退还数据集【MARGIN_RETURN_CE】
|
|
|
+ List<MarginReturnCe> marginReturnCeList = JSONObject.parseArray(jsonArray.toJSONString(), MarginReturnCe.class);
|
|
|
+ logger.info(param+":数据入库="+marginReturnCeList.size());
|
|
|
+ XxlJobHelper.log(param+":数据入库="+marginReturnCeList.size());
|
|
|
+ marginReturnCeService.saveOrUpdateBatch(marginReturnCeList);
|
|
|
+ break;
|
|
|
case "ZRZY_TD_CEDE_NOTICE"://20、自然资源-土地出让公告信息【ZRZY_TD_CEDE_NOTICE】
|
|
|
List<ZrzyTdCedeNotice> listZrzyTdCedeNotice = JSONObject.parseArray(jsonArray.toJSONString(), ZrzyTdCedeNotice.class);
|
|
|
// for (ZrzyTdCedeNotice zrzyTdCedeNotice : listZrzyTdCedeNotice) {
|
|
|
@@ -1245,8 +1292,127 @@ public class SampleXxlJob {
|
|
|
XxlJobHelper.log(param+":数据入库="+gongaoDbList.size());
|
|
|
zfcgGongaoService.saveOrUpdateBatch(gongaoDbList);
|
|
|
break;
|
|
|
+ case "ALLIANCE_CITY_WEBSITE"://
|
|
|
+ List<AllianceCityWebsite> allianceCityWebsiteList = JSONObject.parseArray(jsonArray.toJSONString(), AllianceCityWebsite.class);
|
|
|
+ logger.info(param+":数据入库="+allianceCityWebsiteList.size());
|
|
|
+ XxlJobHelper.log(param+":数据入库="+allianceCityWebsiteList.size());
|
|
|
+ allianceCityWebsiteService.saveOrUpdateBatch(allianceCityWebsiteList);
|
|
|
+ break;
|
|
|
+ case "ZRZY_TD_SUPPLE"://
|
|
|
+ for (int j = 0; j < jsonArray.size(); j++) {
|
|
|
+ String sourceDataKey = jsonArray.getJSONObject(j).getString("SOURCE_DATA_KEY");
|
|
|
+ String sourceDataCode = jsonArray.getJSONObject(j).getString("SOURCE_DATA_CODE");
|
|
|
+ String announcementGuid = jsonArray.getJSONObject(j).getString("ANNOUNCEMENT_GUID");//项目编号
|
|
|
+ String announcementName = jsonArray.getJSONObject(j).getString("LAND_PROJECT_NAME");//项目名称
|
|
|
+ String announcementCode = jsonArray.getJSONObject(j).getString("ANNOUNCEMENT_CODE");//公告编号
|
|
|
+ String announcementTitle = jsonArray.getJSONObject(j).getString("ANNOUNCEMENT_TITLE");//公告标题
|
|
|
+ String announcementContent = jsonArray.getJSONObject(j).getString("ANNOUNCEMENT_CONNECT");//公告内容
|
|
|
+ String regionCode = jsonArray.getJSONObject(j).getString("LAND_DISTRICT");//地区代码
|
|
|
+ Long issueTime = jsonArray.getJSONObject(j).getLong("DATA_TIMESTAMP");//发布时间
|
|
|
+ String unifiedDealCode = jsonArray.getJSONObject(j).getString("UNIFIED_DEAL_CODE");//统一交易编码
|
|
|
+ String platformCode = jsonArray.getJSONObject(j).getString("PLATFORM_CODE");//平台编码
|
|
|
+ String pubServicePlatCode = jsonArray.getJSONObject(j).getString("PUB_SERVICE_PLAT_CODE");//平台编码
|
|
|
+ Long dataTimestamp = jsonArray.getJSONObject(j).getLong("DATA_TIMESTAMP");//数据时间
|
|
|
+ String typeName = "TD";//类型名称
|
|
|
+ updateDatas(sourceDataKey, sourceDataCode, announcementGuid, announcementName, announcementCode, announcementTitle, announcementContent, regionCode, issueTime, unifiedDealCode, platformCode, pubServicePlatCode, dataTimestamp, typeName);
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ case "ZRZY_KYQ_SUPPLENOTICE"://
|
|
|
+ for (int j = 0; j < jsonArray.size(); j++) {
|
|
|
+ String sourceDataKey = jsonArray.getJSONObject(j).getString("SOURCE_DATA_KEY");
|
|
|
+ String sourceDataCode = jsonArray.getJSONObject(j).getString("SOURCE_DATA_CODE");
|
|
|
+ String announcementGuid = jsonArray.getJSONObject(j).getString("NA_APP_CODE");//项目编号
|
|
|
+ String announcementName = jsonArray.getJSONObject(j).getString("NA_APP_NAME");//项目名称
|
|
|
+ String announcementCode = jsonArray.getJSONObject(j).getString("NOTICE_CODE");//公告编号
|
|
|
+ String announcementTitle = jsonArray.getJSONObject(j).getString("NOTICE_NAME");//公告标题
|
|
|
+ String announcementContent = jsonArray.getJSONObject(j).getString("ANNOUNCEMENT_CONNECT");//公告内容
|
|
|
+ String regionCode = "";//地区代码
|
|
|
+ Long issueTime = jsonArray.getJSONObject(j).getLong("NOTICE_SEND_TIME");//发布时间
|
|
|
+ String unifiedDealCode = jsonArray.getJSONObject(j).getString("UNIFIED_DEAL_CODE");//统一交易编码
|
|
|
+ String platformCode = jsonArray.getJSONObject(j).getString("PLATFORM_CODE");//平台编码
|
|
|
+ String pubServicePlatCode = jsonArray.getJSONObject(j).getString("PUB_SERVICE_PLAT_CODE");//平台编码
|
|
|
+ Long dataTimestamp = jsonArray.getJSONObject(j).getLong("DATA_TIMESTAMP");//数据时间
|
|
|
+ String typeName = "KYQ";//类型名称
|
|
|
+ updateDatas(sourceDataKey, sourceDataCode, announcementGuid, announcementName, announcementCode, announcementTitle, announcementContent, regionCode, issueTime, unifiedDealCode, platformCode, pubServicePlatCode, dataTimestamp, typeName);
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ case "ZRZY_DK_SUPPLENOTICE"://
|
|
|
+ for (int j = 0; j < jsonArray.size(); j++) {
|
|
|
+ String sourceDataKey = jsonArray.getJSONObject(j).getString("SOURCE_DATA_KEY");
|
|
|
+ String sourceDataCode = jsonArray.getJSONObject(j).getString("SOURCE_DATA_CODE");
|
|
|
+ String announcementGuid = jsonArray.getJSONObject(j).getString("PROJECT_CODE");//项目编号
|
|
|
+ String announcementName = jsonArray.getJSONObject(j).getString("PROJECT_NAME");//项目名称
|
|
|
+ String announcementCode = jsonArray.getJSONObject(j).getString("NOTICE_CODE");//公告编号
|
|
|
+ String announcementTitle = jsonArray.getJSONObject(j).getString("NOTICE_NAME");//公告标题
|
|
|
+ String announcementContent = jsonArray.getJSONObject(j).getString("ANNOUNCEMENT_CONNECT");//公告内容
|
|
|
+ String regionCode = "";//地区代码
|
|
|
+ Long issueTime = jsonArray.getJSONObject(j).getLong("NOTICE_SEND_TIME");//发布时间
|
|
|
+ String unifiedDealCode = jsonArray.getJSONObject(j).getString("UNIFIED_DEAL_CODE");//统一交易编码
|
|
|
+ String platformCode = jsonArray.getJSONObject(j).getString("PLATFORM_CODE");//平台编码
|
|
|
+ String pubServicePlatCode = jsonArray.getJSONObject(j).getString("PUB_SERVICE_PLAT_CODE");//平台编码
|
|
|
+ Long dataTimestamp = jsonArray.getJSONObject(j).getLong("DATA_TIMESTAMP");//数据时间
|
|
|
+ String typeName = "DK";//类型名称
|
|
|
+ updateDatas(sourceDataKey, sourceDataCode, announcementGuid, announcementName, announcementCode, announcementTitle, announcementContent, regionCode, issueTime, unifiedDealCode, platformCode, pubServicePlatCode, dataTimestamp, typeName);
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ case "ZRZY_BG_SUPPLENOTICE"://
|
|
|
+ for (int j = 0; j < jsonArray.size(); j++) {
|
|
|
+ String sourceDataKey = jsonArray.getJSONObject(j).getString("SOURCE_DATA_KEY");
|
|
|
+ String sourceDataCode = jsonArray.getJSONObject(j).getString("SOURCE_DATA_CODE");
|
|
|
+ String announcementGuid = jsonArray.getJSONObject(j).getString("PROJECT_CODE");//项目编号
|
|
|
+ String announcementName = jsonArray.getJSONObject(j).getString("PROJECT_NAME");//项目名称
|
|
|
+ String announcementCode = jsonArray.getJSONObject(j).getString("NOTICE_NO");//公告编号
|
|
|
+ String announcementTitle = jsonArray.getJSONObject(j).getString("NOTICE_NAME");//公告标题
|
|
|
+ String announcementContent = jsonArray.getJSONObject(j).getString("NOTICE_CONTENT");//公告内容
|
|
|
+ String regionCode = "ZONE";//地区代码
|
|
|
+ Long issueTime = jsonArray.getJSONObject(j).getLong("ISSUE_TIME");//发布时间
|
|
|
+ String unifiedDealCode = jsonArray.getJSONObject(j).getString("UNIFIED_DEAL_CODE");//统一交易编码
|
|
|
+ String platformCode = jsonArray.getJSONObject(j).getString("PLATFORM_CODE");//平台编码
|
|
|
+ String pubServicePlatCode = jsonArray.getJSONObject(j).getString("PUB_SERVICE_PLAT_CODE");//平台编码
|
|
|
+ Long dataTimestamp = jsonArray.getJSONObject(j).getLong("DATA_TIMESTAMP");//数据时间
|
|
|
+ String typeName = "BG";//类型名称
|
|
|
+ updateDatas(sourceDataKey, sourceDataCode, announcementGuid, announcementName, announcementCode, announcementTitle, announcementContent, regionCode, issueTime, unifiedDealCode, platformCode, pubServicePlatCode, dataTimestamp, typeName);
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ case "ZRZY_JYZB_SUPPLENOTICE"://
|
|
|
+ for (int j = 0; j < jsonArray.size(); j++) {
|
|
|
+ String sourceDataKey = jsonArray.getJSONObject(j).getString("SOURCE_DATA_KEY");
|
|
|
+ String sourceDataCode = jsonArray.getJSONObject(j).getString("SOURCE_DATA_CODE");
|
|
|
+ String announcementGuid = jsonArray.getJSONObject(j).getString("PROJECT_CODE");//项目编号
|
|
|
+ String announcementName = jsonArray.getJSONObject(j).getString("PROJECT_NAME");//项目名称
|
|
|
+ String announcementCode = jsonArray.getJSONObject(j).getString("NOTICE_NO");//公告编号
|
|
|
+ String announcementTitle = jsonArray.getJSONObject(j).getString("NOTICE_NAME");//公告标题
|
|
|
+ String announcementContent = jsonArray.getJSONObject(j).getString("NOTICE_CONTENT");//公告内容
|
|
|
+ String regionCode = "ZONE";//地区代码
|
|
|
+ Long issueTime = jsonArray.getJSONObject(j).getLong("ISSUE_TIME");//发布时间
|
|
|
+ String unifiedDealCode = jsonArray.getJSONObject(j).getString("UNIFIED_DEAL_CODE");//统一交易编码
|
|
|
+ String platformCode = jsonArray.getJSONObject(j).getString("PLATFORM_CODE");//平台编码
|
|
|
+ String pubServicePlatCode = jsonArray.getJSONObject(j).getString("PUB_SERVICE_PLAT_CODE");//平台编码
|
|
|
+ Long dataTimestamp = jsonArray.getJSONObject(j).getLong("DATA_TIMESTAMP");//数据时间
|
|
|
+ String typeName = "JY";//类型名称
|
|
|
+ updateDatas(sourceDataKey, sourceDataCode, announcementGuid, announcementName, announcementCode, announcementTitle, announcementContent, regionCode, issueTime, unifiedDealCode, platformCode, pubServicePlatCode, dataTimestamp, typeName);
|
|
|
+ }
|
|
|
+ break;
|
|
|
default:
|
|
|
}
|
|
|
}
|
|
|
+ private void updateDatas(String sourceDataKey, String sourceDataCode, String announcementGuid, String announcementName, String announcementCode, String announcementTitle, String announcementContent, String regionCode, Long issueTime, String unifiedDealCode, String platformCode, String pubServicePlatCode, Long dataTimestamp, String typeName){
|
|
|
+ ZrzySupple zrzySupple = new ZrzySupple();
|
|
|
+ zrzySupple.setSourceDataKey(sourceDataKey);
|
|
|
+ zrzySupple.setSourceDataCode(sourceDataCode);
|
|
|
+ zrzySupple.setAnnouncementGuid(announcementGuid);
|
|
|
+ zrzySupple.setLandProjectName(announcementName);
|
|
|
+ zrzySupple.setAnnouncementCode(announcementCode);
|
|
|
+ zrzySupple.setAnnouncementTitle(announcementTitle);
|
|
|
+ zrzySupple.setAnnouncementContent(announcementContent);
|
|
|
+ zrzySupple.setRegionCode(regionCode);
|
|
|
+ zrzySupple.setIssueTime(issueTime);
|
|
|
+ zrzySupple.setUnifiedDealCode(unifiedDealCode);
|
|
|
+ zrzySupple.setPlatformCode(platformCode);
|
|
|
+ zrzySupple.setPubServicePlatCode(pubServicePlatCode);
|
|
|
+ zrzySupple.setDataTimestamp(dataTimestamp);
|
|
|
+ zrzySupple.setTypeName(typeName);
|
|
|
+ zrzySuppleService.saveOrUpdate(zrzySupple);
|
|
|
+ }
|
|
|
|
|
|
}
|