From fafc8d352aa1a4f943dd9e79d14e8e93ee12ce1f Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期三, 11 十月 2023 08:42:11 +0800
Subject: [PATCH] 优化数据同步时品种转换

---
 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1203.java |   18 +++++++++++++++---
 1 files changed, 15 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1203.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1203.java
index ea46b9a..eb161ac 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1203.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1203.java
@@ -4,6 +4,7 @@
 import com.fzzy.api.entity.*;
 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;
@@ -17,6 +18,8 @@
 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.*;
 
 /**
@@ -106,7 +109,16 @@
                 if(null == sysData.getFullWeightTime()){
                     sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 5));
                 }
-                apiData.setQysj(sysData.getFullWeightTime());
+
+                //鍒ゆ柇涓氬姟鏃堕棿涓庡崟鎹彿鏄惁鍖归厤锛岃嫢涓嶅尮閰嶏紝鍒欐洿鏀逛笟鍔℃椂闂翠负鍗曟嵁鍙锋墍鍦ㄧ殑鏃堕棿
+                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");
@@ -142,10 +154,10 @@
                     apiData.setJyjg("1");
                 }
                 apiData.setJyrxm(sysData.getCheckUser());
-                apiData.setJysj(DateUtils.addMinutes(sysData.getFullWeightTime(), 5));
+                apiData.setJysj(DateUtils.addMinutes(sysData.getRegisterTime(), 30));
 
                 //绮鍝佺
-                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);
 
                 //淇濈鍛樺鏍�

--
Gitblit v1.9.3