From 701f0bd7adccb1c630a3745a53405fafb23b939e Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期四, 18 四月 2024 21:31:27 +0800
Subject: [PATCH] 优化调整船运出入库图片同步问题

---
 src/main/java/com/fzzy/push/impl/ComPushService13.java |  106 +++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 99 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/fzzy/push/impl/ComPushService13.java b/src/main/java/com/fzzy/push/impl/ComPushService13.java
index 8097914..b7c6702 100644
--- a/src/main/java/com/fzzy/push/impl/ComPushService13.java
+++ b/src/main/java/com/fzzy/push/impl/ComPushService13.java
@@ -23,6 +23,8 @@
 public class ComPushService13 {
 
     @Autowired
+    private Api1301Rep apiRep1301;
+    @Autowired
     private Api1302Rep apiRep1302;
     @Autowired
     private Api1303Rep apiRep1303;
@@ -30,8 +32,14 @@
     private Api1304Rep apiRep1304;
     @Autowired
     private Api1305Rep apiRep1305;
-     @Autowired
+    @Autowired
     private Api1306Rep apiRep1306;
+    @Autowired
+    private Api1307Rep apiRep1307;
+    @Autowired
+    private Api1308Rep apiRep1308;
+    @Autowired
+    private Api1309Rep apiRep1309;
     @Autowired
     private Api1310Rep apiRep1310;
 
@@ -58,6 +66,32 @@
             if (responseDto.getSuccess() == 0) {
                 if (Constant.CZBZ_I.equals(data.getCzbz())) {
                     apiRep1302.updateStatus(data.getWsdjcdh(), Constant.CZBZ_U);
+                }
+            }
+        }
+    }
+
+    public void pushData1303(ApiRemoteService apiRemoteService, ApiParam param) {
+
+        //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
+        List<Api1303> items = apiRep1303.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+        if (null == items || items.isEmpty()) {
+            log.info("-------------娌℃湁铏妫�娴嬫暟鎹〃琛ㄩ渶瑕佹帹閫�-----------");
+            return;
+        }
+
+        param.setInteCategory(Constant.API_CATEGORY_13);
+        param.setInteId(Constant.API_CODE_1302);
+
+        ResponseDto responseDto;
+
+        for (Api1303 data : items) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
+                    apiRep1303.updateStatus(data.getHcjcdh(), Constant.CZBZ_U);
                 }
             }
         }
@@ -144,27 +178,85 @@
         }
     }
 
-    public void pushData1303(ApiRemoteService apiRemoteService, ApiParam param) {
+    public void pushData1307(ApiRemoteService apiRemoteService, ApiParam param) {
 
         //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
-        List<Api1303> items = apiRep1303.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+        List<Api1307> items = apiRep1307.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
 
         if (null == items || items.isEmpty()) {
-            log.info("-------------娌℃湁铏妫�娴嬫暟鎹〃琛ㄩ渶瑕佹帹閫�-----------");
+            log.info("-------------娌℃湁浠撳唴鍥惧儚浣滀笟鏁版嵁闇�瑕佹帹閫�-----------");
             return;
         }
 
         param.setInteCategory(Constant.API_CATEGORY_13);
-        param.setInteId(Constant.API_CODE_1302);
+        param.setInteId(Constant.API_CODE_1307);
 
         ResponseDto responseDto;
 
-        for (Api1303 data : items) {
+        for (Api1307 data : items) {
             param.setBizId(data.getBizId());
             responseDto = apiRemoteService.pushData(param, data);
+
             if (responseDto.getSuccess() == 0) {
                 if (Constant.CZBZ_I.equals(data.getCzbz())) {
-                    apiRep1303.updateStatus(data.getHcjcdh(), Constant.CZBZ_U);
+                    data.setCzbz("u");
+                    apiRep1307.save(data);
+                }
+            }
+        }
+    }
+
+    public void pushData1308(ApiRemoteService apiRemoteService, ApiParam param) {
+
+        //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
+        List<Api1308> items = apiRep1308.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+        if (null == items || items.isEmpty()) {
+            log.info("-------------娌℃湁瑙嗛鐩戞帶寮傚父浜嬩欢鏁版嵁闇�瑕佹帹閫�-----------");
+            return;
+        }
+
+        param.setInteCategory(Constant.API_CATEGORY_13);
+        param.setInteId(Constant.API_CODE_1308);
+
+        ResponseDto responseDto;
+
+        for (Api1308 data : items) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
+                    data.setCzbz("u");
+                    apiRep1308.save(data);
+                }
+            }
+        }
+    }
+
+    public void pushData1309(ApiRemoteService apiRemoteService, ApiParam param) {
+
+        //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
+        List<Api1309> items = apiRep1309.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+        if (null == items || items.isEmpty()) {
+            log.info("-------------娌℃湁杩濊棰勮鏁版嵁闇�瑕佹帹閫�-----------");
+            return;
+        }
+
+        param.setInteCategory(Constant.API_CATEGORY_13);
+        param.setInteId(Constant.API_CODE_1309);
+
+        ResponseDto responseDto;
+
+        for (Api1309 data : items) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
+                    data.setCzbz("u");
+                    apiRep1309.save(data);
                 }
             }
         }

--
Gitblit v1.9.3