From bb553634dfca6d5df3311f89c69eacced5e01e74 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期四, 14 十二月 2023 19:33:31 +0800
Subject: [PATCH] 更新上海粮情数据封装接口

---
 src/main/java/com/fzzy/push/impl/ComPushService13.java |   81 ++++++++++++++++++++++++++++++++++------
 1 files changed, 68 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/fzzy/push/impl/ComPushService13.java b/src/main/java/com/fzzy/push/impl/ComPushService13.java
index 5bc5692..8097914 100644
--- a/src/main/java/com/fzzy/push/impl/ComPushService13.java
+++ b/src/main/java/com/fzzy/push/impl/ComPushService13.java
@@ -3,15 +3,10 @@
 import com.fzzy.api.Constant;
 import com.fzzy.api.data.ApiParam;
 import com.fzzy.api.dto.ResponseDto;
-import com.fzzy.api.entity.Api1302;
-import com.fzzy.api.entity.Api1303;
-import com.fzzy.api.entity.Api1304;
-import com.fzzy.api.entity.Api1310;
+import com.fzzy.api.entity.*;
 import com.fzzy.api.service.ApiRemoteService;
-import com.fzzy.api.view.repository.Api1302Rep;
-import com.fzzy.api.view.repository.Api1303Rep;
-import com.fzzy.api.view.repository.Api1304Rep;
-import com.fzzy.api.view.repository.Api1310Rep;
+import com.fzzy.api.view.repository.*;
+import com.fzzy.push.shjdjw2023.ShjdjwApiRemoteService2023;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -34,13 +29,17 @@
     @Autowired
     private Api1304Rep apiRep1304;
     @Autowired
+    private Api1305Rep apiRep1305;
+     @Autowired
+    private Api1306Rep apiRep1306;
+    @Autowired
     private Api1310Rep apiRep1310;
 
 
     public void pushData1302(ApiRemoteService apiRemoteService, ApiParam param) {
 
         //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
-        List<Api1302> items = apiRep1302.findPushData(param.getKqdm());
+        List<Api1302> items = apiRep1302.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
 
         if (null == items || items.isEmpty()) {
             log.info("-------------娌℃湁绮儏鏁版嵁闇�瑕佹帹閫�-----------");
@@ -67,7 +66,7 @@
     public void pushData1304(ApiRemoteService apiRemoteService, ApiParam param) {
 
         //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
-        List<Api1304> items = apiRep1304.findPushData(param.getKqdm());
+        List<Api1304> items = apiRep1304.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
 
         if (null == items || items.isEmpty()) {
             log.info("-------------娌℃湁姘斾綋妫�娴嬫暟鎹〃闇�瑕佹帹閫�-----------");
@@ -91,10 +90,64 @@
         }
     }
 
+    public void pushData1305(ApiRemoteService apiRemoteService, ApiParam param) {
+
+        //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
+        List<Api1305> items = apiRep1305.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_1305);
+
+        ResponseDto responseDto;
+
+        for (Api1305 data : items) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
+                    apiRep1305.updateStatus(data.getTfzydh(), Constant.CZBZ_U);
+                }
+            }
+        }
+    }
+
+    public void pushData1306(ApiRemoteService apiRemoteService, ApiParam param) {
+
+        //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
+        List<Api1306> items = apiRep1306.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_1306);
+
+        ResponseDto responseDto;
+
+        for (Api1306 data : items) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
+                    apiRep1306.updateStatus(data.getXzzydh(), Constant.CZBZ_U);
+                }
+            }
+        }
+    }
+
     public void pushData1303(ApiRemoteService apiRemoteService, ApiParam param) {
 
         //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
-        List<Api1303> items = apiRep1303.findPushData(param.getKqdm());
+        List<Api1303> items = apiRep1303.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
 
         if (null == items || items.isEmpty()) {
             log.info("-------------娌℃湁铏妫�娴嬫暟鎹〃琛ㄩ渶瑕佹帹閫�-----------");
@@ -120,7 +173,7 @@
     public void pushData1310(ApiRemoteService apiRemoteService, ApiParam param) {
 
         //鑾峰彇闇�瑕佹帹閫佺殑鏁版嵁
-        List<Api1310> items = apiRep1310.findPushData(param.getKqdm());
+        List<Api1310> items = apiRep1310.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
 
         if (null == items || items.isEmpty()) {
             log.info("-------------娌℃湁璐ㄦ鏁版嵁闇�瑕佹帹閫�-----------");
@@ -128,7 +181,7 @@
         }
 
         param.setInteCategory(Constant.API_CATEGORY_13);
-        param.setInteId(Constant.API_CODE_1302);
+        param.setInteId(Constant.API_CODE_1310);
 
         ResponseDto responseDto;
 
@@ -142,4 +195,6 @@
             }
         }
     }
+
+
 }

--
Gitblit v1.9.3