From 05aa35cd44519f34698a69a7151edb78e3cfae64 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期一, 26 二月 2024 09:02:10 +0800
Subject: [PATCH] 优化上海熏蒸接口批次号

---
 src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java |  168 ++++++++++++++++++++++++++++----------------------------
 1 files changed, 84 insertions(+), 84 deletions(-)

diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java b/src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java
index 17b1ef9..58206dc 100644
--- a/src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java
+++ b/src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java
@@ -63,17 +63,17 @@
     public void pushData(ApiParam param) {
         log.info("------->>>>绮簱绠$悊 鎺ュ彛妯″潡涓婃姤寮�濮�");
 
-        this.pushData1301(apiRemoteService, param);
-        this.pushData1302(apiRemoteService, param);
-        this.pushData1303(apiRemoteService, param);
-        this.pushData1304(apiRemoteService, param);
-        this.pushData1305(apiRemoteService, param);
-        this.pushData1306(apiRemoteService, param);
-        this.pushData1307(apiRemoteService, param);
-        this.pushData1308(apiRemoteService, param);
-        this.pushData1309(apiRemoteService, param);
-        this.pushData1310(apiRemoteService, param);
-        this.pushData1311(apiRemoteService, param);
+//        this.pushData1301(apiRemoteService, param);
+//        this.pushData1302(apiRemoteService, param);
+//        this.pushData1303(apiRemoteService, param);
+//        this.pushData1304(apiRemoteService, param);
+//        this.pushData1305(apiRemoteService, param);
+//        this.pushData1306(apiRemoteService, param);
+//        this.pushData1307(apiRemoteService, param);
+//        this.pushData1308(apiRemoteService, param);
+//        this.pushData1309(apiRemoteService, param);
+//        this.pushData1310(apiRemoteService, param);
+//        this.pushData1311(apiRemoteService, param);
 
         log.info("------->>>>绮簱绠$悊 鎺ュ彛妯″潡涓婃姤缁撴潫");
     }
@@ -89,12 +89,14 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌瀹夊叏绠$悊锛屼笉鎺ㄩ��-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1301);
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (Api1301 data : list) {
+
+        ResponseDto responseDto;
+        for (Api1301 data : list) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
                 if (Constant.CZBZ_I.equals(data.getCzbz())) {
 
                     data.setCzbz(Constant.CZBZ_U);
@@ -103,7 +105,6 @@
                 }
             }
         }
-
     }
 
     /**
@@ -117,12 +118,14 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌娓╂箍搴︽娴嬶紝涓嶆帹閫�-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1302);
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (Api1302 data : list) {
+
+        ResponseDto responseDto;
+        for (Api1302 data : list) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
                 if (Constant.CZBZ_I.equals(data.getCzbz())) {
 
                     data.setCzbz(Constant.CZBZ_U);
@@ -144,21 +147,21 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌瀹宠櫕妫�娴嬶紝涓嶆帹閫�-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1303);
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (Api1303 data : list) {
-                if (Constant.CZBZ_I.equals(data.getCzbz())) {
 
+        ResponseDto responseDto;
+        for (Api1303 data : list) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                     data.setCzbz(Constant.CZBZ_U);
                     //鏇存柊鐘舵��
                     api1303Rep.save(data);
                 }
             }
         }
-
     }
 
     /**
@@ -172,14 +175,15 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌姘斾綋妫�娴嬶紝涓嶆帹閫�-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1304);
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (Api1304 data : list) {
-                if (Constant.CZBZ_I.equals(data.getCzbz())) {
 
+        ResponseDto responseDto;
+        for (Api1304 data : list) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                     data.setCzbz(Constant.CZBZ_U);
                     //鏇存柊鐘舵��
                     api1304Rep.save(data);
@@ -200,21 +204,21 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌閫氶浣滀笟锛屼笉鎺ㄩ��-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1305);
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (Api1305 data : list) {
-                if (Constant.CZBZ_I.equals(data.getCzbz())) {
 
+        ResponseDto responseDto;
+        for (Api1305 data : list) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                     data.setCzbz(Constant.CZBZ_U);
                     //鏇存柊鐘舵��
                     api1305Rep.save(data);
                 }
             }
         }
-
     }
 
     /**
@@ -228,14 +232,15 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌鐔忚捀浣滀笟锛屼笉鎺ㄩ��-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1306);
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (Api1306 data : list) {
-                if (Constant.CZBZ_I.equals(data.getCzbz())) {
 
+        ResponseDto responseDto;
+        for (Api1306 data : list) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                     data.setCzbz(Constant.CZBZ_U);
                     //鏇存柊鐘舵��
                     api1306Rep.save(data);
@@ -255,14 +260,15 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌浠撳唴瑙嗛鍥惧儚锛屼笉鎺ㄩ��-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1307);
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (Api1307 data : list) {
-                if (Constant.CZBZ_I.equals(data.getCzbz())) {
 
+        ResponseDto responseDto;
+        for (Api1307 data : list) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                     data.setCzbz(Constant.CZBZ_U);
                     //鏇存柊鐘舵��
                     api1307Rep.save(data);
@@ -299,12 +305,14 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌璐ㄦ鏁版嵁锛屼笉鎺ㄩ��-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1310);
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (Api1310 data : list) {
+
+        ResponseDto responseDto;
+        for (Api1310 data : list) {
+            param.setBizId(data.getBizId());
+            responseDto = apiRemoteService.pushData(param, data);
+            if (responseDto.getSuccess() == 0) {
                 if (Constant.CZBZ_I.equals(data.getCzbz())) {
                     data.setCzbz(Constant.CZBZ_U);
                     //鏇存柊鐘舵��
@@ -325,29 +333,24 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌瑙嗛鐩戞帶锛屼笉鎺ㄩ��-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_1311);
 
         SH2023Api1311 shApi1311;
-        List<SH2023Api1311> list = new ArrayList<>();
+        ResponseDto responseDto;
         for (ApiInfoData infoData : items) {
             shApi1311 = JSONObject.parseObject(infoData.getData(), SH2023Api1311.class);
-            shApi1311.setCzbz(infoData.getCzbz());
             shApi1311.setZhgxsj(infoData.getUpdateTime());
-            list.add(shApi1311);
-        }
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (ApiInfoData data : items) {
-                if (Constant.CZBZ_I.equals(data.getCzbz())) {
 
-                    data.setCzbz(Constant.CZBZ_U);
-                    apiInfoDataRep.save(data);
+            param.setBizId(infoData.getDataId());
+            responseDto = apiRemoteService.pushData(param, shApi1311);
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(infoData.getCzbz())) {
+                    infoData.setCzbz(Constant.CZBZ_U);
+                    apiInfoDataRep.save(infoData);
                 }
             }
         }
-
     }
 
     /**
@@ -362,26 +365,23 @@
             log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌绮儏璁惧閰嶇疆锛屼笉鎺ㄩ��-----");
             return;
         }
+        param.setInteCategory(Constant.API_CATEGORY_13);
         param.setInteId(SH2023Constant.SH_2023_API_CODE_2103);
+
         SH2023Api2103 shApi2103;
-        List<SH2023Api2103> list = new ArrayList<>();
+        ResponseDto responseDto;
         for (ApiInfoData infoData : items) {
             shApi2103 = JSONObject.parseObject(infoData.getData(), SH2023Api2103.class);
             shApi2103.setZhgxsj(infoData.getUpdateTime());
-            list.add(shApi2103);
-        }
-        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
-        ResponseDto responseDto = apiRemoteService.pushData(param, list);
-        if (responseDto.getSuccess() == 0) {
-            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
-            for (ApiInfoData data : items) {
-                if (Constant.CZBZ_I.equals(data.getCzbz())) {
+            param.setBizId(infoData.getDataId());
+            responseDto = apiRemoteService.pushData(param, shApi2103);
+            if (responseDto.getSuccess() == 0) {
+                if (Constant.CZBZ_I.equals(infoData.getCzbz())) {
 
-                    data.setCzbz(Constant.CZBZ_U);
-                    apiInfoDataRep.save(data);
+                    infoData.setCzbz(Constant.CZBZ_U);
+                    apiInfoDataRep.save(infoData);
                 }
             }
         }
-
     }
 }

--
Gitblit v1.9.3