From 550b14e27b9bba40e80f1141d0943d1dc62acbbc Mon Sep 17 00:00:00 2001
From: 陈战涛 <chenzhantao7055@sina.com>
Date: 星期一, 22 五月 2023 15:26:55 +0800
Subject: [PATCH] 优化广东粮食购销接口
---
src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java | 34 ++++++++++++++++++++++------------
1 files changed, 22 insertions(+), 12 deletions(-)
diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java
index 2277270..43d445f 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java
@@ -1,10 +1,7 @@
package com.fzzy.async.fzzy35.impl;
import com.fzzy.api.Constant;
-import com.fzzy.api.entity.Api1105;
-import com.fzzy.api.entity.Api1203;
-import com.fzzy.api.entity.ApiLog;
-import com.fzzy.api.entity.GbCheckItem;
+import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
@@ -16,6 +13,7 @@
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1202Rep;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1203Rep;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -86,8 +84,13 @@
String jyz;
String zkj;
String zkl;
+ List<Api1203> api1203List;
for (Fz35InoutRecord sysData : list) {
-
+ //鍒ゆ柇鍑�閲嶆槸鍚﹀ぇ浜�0锛岀瓑浜�0琛ㄧず涓嶅悎鏍硷紝涓嶈繘琛屽悓姝ヤ笂浼�
+ if(sysData.getRecordWeight() == 0){
+ continue;
+ }
+ fz35CheckItems = null;
//鑾峰彇鍏ュ簱璐ㄦ淇℃伅
fz35CheckItems = fzzySync1203Rep.listInoutCheckItem(sysData.getCheckId());
if (null == fz35CheckItems || fz35CheckItems.isEmpty()) {
@@ -102,7 +105,6 @@
}
apiData = new Api1203();
- apiData.setId(sysData.getId());
apiData.setRkjydh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
@@ -127,18 +129,22 @@
}
jyxm += gbCheckList.get(0).getCode() + ",";
jyz += fz35CheckItem.getValue() + ",";
- zkj += "0,";
- zkl += "0,";
+ zkj += "0.0,";
+ zkl += "0.0,";
}
apiData.setJyxm(jyxm);
apiData.setJyz(jyz);
apiData.setZkj(zkj);
apiData.setZkl(zkl);
- apiData.setJyjg("0");
+ if("UNPASS".equals(sysData.getCheckStatus())){
+ apiData.setJyjg("0");
+ }
+ if("PASS".equals(sysData.getCheckStatus())){
+ apiData.setJyjg("1");
+ }
apiData.setJyrxm(sysData.getCheckUser());
- apiData.setJysj(sysData.getFullWeightTime());
- //apiData.setJyjg("");
+ apiData.setJysj(DateUtils.addMinutes(sysData.getFullWeightTime(), 5));
//绮鍝佺
String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
@@ -149,7 +155,6 @@
apiData.setLsdd(mappingCode);
//鎿嶄綔鏍囧織鍙婃渶鍚庢洿鏂版椂闂�
- apiData.setCzbz(Constant.CZBZ_I);
apiData.setZhgxsj(sysData.getCompleteTime());
//涓氬姟id銆佸簱鍖虹紪鐮併�佸悓姝ユ椂闂�
@@ -157,6 +162,11 @@
apiData.setKqdm(kqdm);
apiData.setSyncTime(new Date());
+ api1203List = api1203Rep.getDataById(apiData.getRkjydh());
+ if(null == api1203List || api1203List.isEmpty()){
+ apiData.setCzbz(Constant.CZBZ_I);
+ }
+
//淇濆瓨鏁版嵁
api1203Rep.save(apiData);
log.info("1203---鍚屾鏁版嵁锛歿}", apiData.toString());
--
Gitblit v1.9.3