From 86db604887a24284512abe813ba9e235b3e0ec71 Mon Sep 17 00:00:00 2001
From: YYC <1833023622@qq.com>
Date: 星期三, 09 八月 2023 16:49:52 +0800
Subject: [PATCH] 武汉军粮省平台-推送粮食购销信息
---
src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java | 142 +++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 136 insertions(+), 6 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..89813d9 100644
--- a/src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java
+++ b/src/main/java/com/fzzy/push/whhpjl/WhjlPushService12.java
@@ -1,11 +1,25 @@
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.dto.ResponseDto;
+import com.fzzy.api.entity.ApiInfoData;
+import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
+import com.fzzy.api.view.repository.ApiInfoDataRep;
+import com.fzzy.whjl.WhjlConstant;
+import com.fzzy.whjl.dto.WhjlApi1101;
+import com.fzzy.whjl.dto.WhjlApi1204;
+import com.fzzy.whjl.dto.WhjlApi1207;
+import com.fzzy.whjl.dto.WhjlApi1214;
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;
/**
* 姝︽眽鍐涚伯鐪佸钩鍙�-绮璐攢鏁版嵁鎺ㄩ��
@@ -19,6 +33,8 @@
@Autowired
private WhjlApiRemoteService apiRemoteService;
+ @Autowired
+ private ApiInfoDataRep apiInfoDataRep;
@Override
public String getProtocol() {
@@ -29,21 +45,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<WhjlApi1207> list = new ArrayList<>();
+ WhjlApi1207 whjlApi1207;
+ for (ApiInfoData infoData : items) {
+ whjlApi1207 = JSONObject.parseObject(infoData.getData(), WhjlApi1207.class);
+ whjlApi1207.setKqdm(infoData.getKqdm());
+ whjlApi1207.setCzbz(infoData.getCzbz());
+ whjlApi1207.setUpdateTime(infoData.getUpdateTime());
+ whjlApi1207.setBizId(infoData.getDataId());
+ list.add(whjlApi1207);
+ }
+
+ //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
+ 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<WhjlApi1214> list = new ArrayList<>();
+ WhjlApi1214 whjlApi1214;
+ for (ApiInfoData infoData : items) {
+ whjlApi1214 = JSONObject.parseObject(infoData.getData(), WhjlApi1214.class);
+ whjlApi1214.setKqdm(infoData.getKqdm());
+ whjlApi1214.setCzbz(infoData.getCzbz());
+ whjlApi1214.setUpdateTime(infoData.getUpdateTime());
+ whjlApi1214.setBizId(infoData.getDataId());
+ list.add(whjlApi1214);
+ }
+
+ //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
+ 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