From 9f6dacf7b39e5aeba37d8faf575c9e56d8cbe51a Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期六, 11 十月 2025 13:35:42 +0800
Subject: [PATCH] 武汉黄陂军粮-质检报告共享接口同步及推送
---
src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java | 144 +++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 136 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java b/src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java
index cf32958..ed05d2d 100644
--- a/src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java
+++ b/src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java
@@ -1,11 +1,23 @@
package com.fzzy.push.whhpjl;
+import com.alibaba.fastjson.JSONObject;
+import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
-import com.fzzy.api.service.PushService11;
+import com.fzzy.api.dto.ResponseDto;
+import com.fzzy.api.entity.ApiInfoData;
+import com.fzzy.api.service.ApiRemoteService;
+import com.fzzy.api.service.PushService12;
+import com.fzzy.api.view.repository.ApiInfoDataRep;
+import com.fzzy.otherview.whhpjl.WhjlConstant;
+import com.fzzy.otherview.whhpjl.dto.WhjlApi1204;
+import com.fzzy.otherview.whhpjl.dto.WhjlApi1206;
+import com.fzzy.otherview.whhpjl.dto.WhjlApi1212;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+import java.util.ArrayList;
+import java.util.List;
/**
* 姝︽眽鍐涚伯鐪佸钩鍙�-绮璐攢鏁版嵁鎺ㄩ��
@@ -15,10 +27,12 @@
*/
@Slf4j
@Component
-public class WhjlPushService12 implements PushService11 {
+public class WhjlPushService12 implements PushService12 {
@Autowired
private WhjlApiRemoteService apiRemoteService;
+ @Autowired
+ private ApiInfoDataRep apiInfoDataRep;
@Override
public String getProtocol() {
@@ -29,21 +43,135 @@
public void pushData(ApiParam param) {
log.info("姝︽眽鍐涚伯鐪佸钩鍙�--->>>绮璐攢 涓婃姤寮�濮�");
- //TODO 鎺ㄩ�佸鎴蜂俊鎭�
-
- //TODO 鎺ㄩ�佸悎鍚屼俊鎭�
-
+ // 鎺ㄩ�佸鎴蜂俊鎭�
+ this.pushData1204(apiRemoteService, param);
+ // 鎺ㄩ�佸悎鍚屼俊鎭�
+ this.pushData1207(apiRemoteService, param);
//TODO 鎺ㄩ�佸簱瀛樺彴璐︿俊鎭�
//TODO 鎺ㄩ�佸簱瀛樺彴璐︿骇鍝佹壒娆′俊鎭�
//TODO 鎺ㄩ�佸簱瀛樺彴璐﹀嚭鍏ヤ俊鎭�
- //TODO 鎺ㄩ�佸嚭鍏ュ簱璁板綍
-
+ // 鎺ㄩ�佸嚭鍏ュ簱璁板綍
+ this.pushData1214(apiRemoteService, param);
log.info("姝︽眽鍐涚伯鐪佸钩鍙�--->>>绮璐攢 涓婃姤缁撴潫");
}
+ /**
+ * 1204 瀹㈡埛淇℃伅
+ */
+ private void pushData1204(ApiRemoteService apiRemoteService, ApiParam param) {
+
+ //鑾峰彇鍐涘伐浼佷笟淇℃伅
+ List<ApiInfoData> items = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_1204);
+
+ if (null == items || items.isEmpty()) {
+ return;
+ }
+ param.setInteCategory(WhjlConstant.API_CATEGORY_12);
+ param.setInteId(WhjlConstant.API_CODE_1204);
+ List<WhjlApi1204> list = new ArrayList<>();
+ WhjlApi1204 whjlApi1204;
+ for (ApiInfoData infoData : items) {
+ whjlApi1204 = JSONObject.parseObject(infoData.getData(), WhjlApi1204.class);
+ whjlApi1204.setKqdm(infoData.getKqdm());
+ whjlApi1204.setCzbz(infoData.getCzbz());
+ whjlApi1204.setUpdateTime(infoData.getUpdateTime());
+ whjlApi1204.setBizId(infoData.getDataId());
+ list.add(whjlApi1204);
+ }
+
+ //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
+ 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);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1207 鍚堝悓淇℃伅
+ */
+ private void pushData1207(ApiRemoteService apiRemoteService, ApiParam param) {
+
+ //鑾峰彇鍐涘伐浼佷笟淇℃伅
+ List<ApiInfoData> items = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_1207);
+
+ if (null == items || items.isEmpty()) {
+ return;
+ }
+ param.setInteCategory(WhjlConstant.API_CATEGORY_12);
+ param.setInteId(WhjlConstant.API_CODE_1207);
+ List<WhjlApi1206> list = new ArrayList<>();
+ WhjlApi1206 whjlApi1206;
+ for (ApiInfoData infoData : items) {
+ whjlApi1206 = JSONObject.parseObject(infoData.getData(), WhjlApi1206.class);
+ whjlApi1206.setKqdm(infoData.getKqdm());
+ whjlApi1206.setCzbz(infoData.getCzbz());
+ whjlApi1206.setUpdateTime(infoData.getUpdateTime());
+ whjlApi1206.setBizId(infoData.getDataId());
+ list.add(whjlApi1206);
+ }
+
+ //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
+ 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);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1214 鍚堝悓淇℃伅
+ */
+ private void pushData1214(ApiRemoteService apiRemoteService, ApiParam param) {
+
+ //鑾峰彇鍐涘伐浼佷笟淇℃伅
+ List<ApiInfoData> items = apiInfoDataRep.getDataByInteId(WhjlConstant.API_CODE_1214);
+
+ if (null == items || items.isEmpty()) {
+ return;
+ }
+ param.setInteCategory(WhjlConstant.API_CATEGORY_12);
+ param.setInteId(WhjlConstant.API_CODE_1214);
+ List<WhjlApi1212> list = new ArrayList<>();
+ WhjlApi1212 whjlApi1212;
+ for (ApiInfoData infoData : items) {
+ whjlApi1212 = JSONObject.parseObject(infoData.getData(), WhjlApi1212.class);
+ whjlApi1212.setKqdm(infoData.getKqdm());
+ whjlApi1212.setCzbz(infoData.getCzbz());
+ whjlApi1212.setUpdateTime(infoData.getUpdateTime());
+ whjlApi1212.setBizId(infoData.getDataId());
+ list.add(whjlApi1212);
+ }
+
+ //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
+ 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