From 89cb4ea9adbf4578cceb379b58f36d0ac2d05095 Mon Sep 17 00:00:00 2001
From: ws <ws@123.com>
Date: 星期一, 25 九月 2023 20:25:06 +0800
Subject: [PATCH] 优化上海数据上报
---
src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java | 47 ++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 46 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java b/src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java
index 52f9f89..3dc498b 100644
--- a/src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java
+++ b/src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java
@@ -10,6 +10,7 @@
import com.fzzy.api.service.PushService11;
import com.fzzy.api.view.repository.*;
import com.fzzy.push.sh2023.dto.SH2023Api2101;
+import com.fzzy.push.sh2023.dto.SH2023Api2104;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -377,6 +378,27 @@
*/
public void pushData1211(ApiRemoteService apiRemoteService, ApiParam param) {
//TODO
+ //绮鎬ц川杞彉鍗�
+ List<Api1211> list = api1211Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌绮搴撳瓨淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteId(SH2023Constant.SH_2023_API_CODE_1210);
+ //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
+ ResponseDto responseDto = apiRemoteService.pushData(param, list);
+ if (responseDto.getSuccess() == 0) {
+ //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
+ for (Api1211 data : list) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1211Rep.save(data);
+ }
+ }
+ }
}
@@ -450,7 +472,30 @@
* 2104 甯傚偍椹宠繍鍗�
*/
public void pushData2104(ApiRemoteService apiRemoteService, ApiParam param) {
- //TODO
+ //鑾峰彇 妫�鏂ゅ崟淇℃伅
+ List<ApiInfoData> items = apiInfoDataRep.getDataByInteId(SH2023Constant.SH_2023_API_CODE_2104);
+
+ SH2023Api2104 shApi2104;
+ List<SH2023Api2104> list = new ArrayList<>();
+
+ param.setInteId(SH2023Constant.SH_2023_API_CODE_2104);
+ for (ApiInfoData infoData : items) {
+ shApi2104 = JSONObject.parseObject(infoData.getData(), SH2023Api2104.class);
+ shApi2104.setCzbz(infoData.getCzbz());
+ shApi2104.setZhgxsj(infoData.getUpdateTime());
+ list.add(shApi2104);
+ }
+ 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);
+ }
+ }
+ }
}
}
--
Gitblit v1.9.3