From 715af00851145d97afa322c211dcc44f78238ef1 Mon Sep 17 00:00:00 2001
From: YYC <1833023622@qq.com>
Date: 星期三, 24 九月 2025 14:24:14 +0800
Subject: [PATCH] 61版本13,14同步

---
 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java |   56 +++++++++++++++++++++++++++++++++++---------------------
 1 files changed, 35 insertions(+), 21 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 ed9b4f6..d8a5964 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java
@@ -5,6 +5,8 @@
 import com.fzzy.api.service.ApiCommonService;
 import com.fzzy.api.service.ApiTriggerService;
 import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.utils.DateUtil;
+import com.fzzy.api.view.repository.Api1202Rep;
 import com.fzzy.api.view.repository.Api1203Rep;
 import com.fzzy.api.view.repository.ApiLogRep;
 import com.fzzy.api.view.repository.GbCheckItemRep;
@@ -14,10 +16,12 @@
 import com.fzzy.async.fzzy35.repository.Fzzy35Sync1203Rep;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang.time.DateFormatUtils;
 import org.apache.commons.lang.time.DateUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.List;
 
@@ -37,9 +41,10 @@
     private Fzzy35Sync1202Rep fzzySync1202Rep;
     @Autowired
     private Fzzy35Sync1203Rep fzzySync1203Rep;
-
     @Autowired
     private ApiTriggerService apiTriggerService;
+    @Autowired
+    private Api1202Rep api1202Rep;
     @Autowired
     private Api1203Rep api1203Rep;
     @Autowired
@@ -86,12 +91,14 @@
             String zkj;
             String zkl;
             List<Api1203> api1203List;
+            List<Api1202> api1102List;
             for (Fz35InoutRecord sysData : list) {
-                //鍒ゆ柇鍑�閲嶆槸鍚﹀ぇ浜�0锛岀瓑浜�0琛ㄧず涓嶅悎鏍硷紝涓嶈繘琛屽悓姝ヤ笂浼�
-                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
+                //鏌ヨ绮鍏ュ簱淇℃伅锛岃嫢涓虹┖鍒欎笉杩涜鍚屾涓婁紶
+                api1102List = api1202Rep.getDataByBizId(sysData.getId());
+                if(null == api1102List || api1102List.isEmpty()){
                     continue;
                 }
-                fz35CheckItems = null;
+
                 //鑾峰彇鍏ュ簱璐ㄦ淇℃伅
                 fz35CheckItems = fzzySync1203Rep.listInoutCheckItem(sysData.getCheckId(), deptId.substring(0, 4));
                 if (null == fz35CheckItems || fz35CheckItems.isEmpty()) {
@@ -99,20 +106,25 @@
                     continue;
                 }
 
-                //鑾峰彇璐т綅淇℃伅
-                api1105 = commonService.getApi1105Cache(sysData.getDepotId());
-                if (null == api1105) {
-                    continue;
-                }
-
                 apiData = new Api1203();
 
-                apiData.setRkjydh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
-
+                apiData.setRkjydh(api1102List.get(0).getRkywdh());
                 //璐т綅浠g爜
-                apiData.setHwdm(api1105.getHwdm());
-                apiData.setRkywdh(apiData.getRkjydh());
-                apiData.setQysj(sysData.getFullWeightTime());
+                apiData.setHwdm(api1102List.get(0).getHwdm());
+                apiData.setRkywdh(api1102List.get(0).getRkywdh());
+                if(null == sysData.getFullWeightTime()){
+                    sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 5));
+                }
+
+                //鍒ゆ柇涓氬姟鏃堕棿涓庡崟鎹彿鏄惁鍖归厤锛岃嫢涓嶅尮閰嶏紝鍒欐洿鏀逛笟鍔℃椂闂翠负鍗曟嵁鍙锋墍鍦ㄧ殑鏃堕棿
+                SimpleDateFormat dateFormat = new SimpleDateFormat("yyMMdd");
+                Date time = dateFormat.parse(apiData.getRkjydh().substring(2, 8));
+                int numDay = DateUtil.difDay(DateUtil.getCurZero(sysData.getRegisterTime()), DateUtil.getCurZero(time));
+                if(numDay != 0){
+                    sysData.setRegisterTime(DateUtils.addDays(sysData.getRegisterTime(), numDay));
+                }
+
+                apiData.setQysj(sysData.getRegisterTime());
                 apiData.setQyrxm(sysData.getCheckUser());
                 //鎵︽牱鏂瑰紡 2-鏅鸿兘闅忔満
                 apiData.setQyfs("2");
@@ -139,21 +151,23 @@
 
                 apiData.setJyxm(jyxm);
                 apiData.setJyz(jyz);
-                apiData.setZkj(zkj.substring(1));
-                apiData.setZkl(zkl.substring(1));
+                apiData.setZkj(StringUtils.isEmpty(zkj)?"":zkj.substring(1));
+                apiData.setZkl(StringUtils.isEmpty(zkl)?"":zkl.substring(1));
                 if("UNPASS".equals(sysData.getCheckStatus())){
                     apiData.setJyjg("0");
-                }
-                if("PASS".equals(sysData.getCheckStatus())){
+                }else {
                     apiData.setJyjg("1");
                 }
                 apiData.setJyrxm(sysData.getCheckUser());
-                apiData.setJysj(DateUtils.addMinutes(sysData.getFullWeightTime(), 5));
+                apiData.setJysj(DateUtils.addMinutes(sysData.getRegisterTime(), 90));
 
                 //绮鍝佺
-                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
+                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety().substring(0,3));
                 apiData.setLspzdm(mappingCode);
 
+                //淇濈鍛樺鏍�
+                apiData.setBgyfh(apiData.getJyjg());
+                apiData.setSpaqzbsfhg("1");
                 //绮绛夌骇
                 mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, sysData.getFoodLevel());
                 apiData.setLsdd(mappingCode);

--
Gitblit v1.9.3