Sfoglia il codice sorgente

修复自然资源主键重复

mycopy123@163.com 1 anno fa
parent
commit
8ac917e0a2

+ 1 - 1
src/main/java/com/trs/ggzyexchange/schedul/ZrzyCkqBidwinnoticeSchedul.java

@@ -162,7 +162,7 @@ public class ZrzyCkqBidwinnoticeSchedul implements Job {
             }
             String sourceDataKey = record.getSourceDataKey();
             if(!ObjectUtils.isEmpty(sourceDataKey)){
-                tenderDetailsVo.setSourceDataKey(sourceDataKey);
+                tenderDetailsVo.setSourceDataKey(sourceDataKey+tenderDetailsVo.getNoticeSendTime());
             }
             String dataSourceCode = record.getDataSourceCode();
             if(!ObjectUtils.isEmpty(dataSourceCode)){

+ 4 - 3
src/main/java/com/trs/ggzyexchange/schedul/ZrzyTdBidwinnoticeSchedul.java

@@ -129,9 +129,7 @@ public class ZrzyTdBidwinnoticeSchedul   implements Job {
         for (ZrzyTdBidwinnotice record : records) {
             TenderDetailsVo tenderDetailsVo = new TenderDetailsVo();
             String sourceDataKey = record.getSourceDataKey();
-            if(!ObjectUtils.isEmpty(sourceDataKey)){
-                tenderDetailsVo.setSourceDataKey(sourceDataKey);
-            }
+
             String dealLandCode = record.getDealLandCode();
             if(!ObjectUtils.isEmpty(dealLandCode)){
                 tenderDetailsVo.setProjectCode(dealLandCode);
@@ -164,6 +162,9 @@ public class ZrzyTdBidwinnoticeSchedul   implements Job {
                 }
             }
 
+            if(!ObjectUtils.isEmpty(sourceDataKey)){
+                tenderDetailsVo.setSourceDataKey(sourceDataKey+tenderDetailsVo.getNoticeSendTime());
+            }
 
             String regionCode = record.getRegionCode();
             if(!ObjectUtils.isEmpty(regionCode)){

+ 5 - 3
src/main/java/com/trs/ggzyexchange/schedul/ZrzyTdCedeNoticeSchedul.java

@@ -125,9 +125,7 @@ public class ZrzyTdCedeNoticeSchedul    implements Job {
         List<TenderDetailsVo> tenderDetailsVoList = new ArrayList<TenderDetailsVo>();
         for (ZrzyTdCedeNotice record : pageList.getRecords()) {
             TenderDetailsVo tenderDetailsVo = new TenderDetailsVo();
-            if(!ObjectUtils.isEmpty(record.getSourceDataKey())){
-                tenderDetailsVo.setSourceDataKey(record.getSourceDataKey());
-            }
+
             if(!ObjectUtils.isEmpty(record.getSourceDataCode())){
                 tenderDetailsVo.setDataSourceCode(record.getSourceDataCode());
             }
@@ -157,6 +155,10 @@ public class ZrzyTdCedeNoticeSchedul    implements Job {
                 }
             }
 
+            if(!ObjectUtils.isEmpty(record.getSourceDataKey())){
+                tenderDetailsVo.setSourceDataKey(record.getSourceDataKey()+tenderDetailsVo.getNoticeSendTime());
+            }
+
             if(!ObjectUtils.isEmpty(record.getLandDistrict())){
                 tenderDetailsVo.setRegionCode(record.getLandDistrict());
             }