From 4be521d7e3135ac0a8e4a15e395f44448e23e09e Mon Sep 17 00:00:00 2001
From: YYC <1833023622@qq.com>
Date: 星期二, 22 八月 2023 18:40:30 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1202Rep.java | 2
src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1208.java | 13 +
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1109.java | 41 ++++--
src/main/java/com/fzzy/api/view/repository/Api1202Rep.java | 8 +
src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java | 20 ++
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1203.java | 43 ++-----
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java | 26 ++-
src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java | 19 ++
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1205.java | 18 ++
src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java | 30 ++--
src/main/java/com/fzzy/api/view/repository/Api1205Rep.java | 8 +
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1208.java | 18 +-
src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1109.java | 41 ++++--
src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java | 56 ++++----
14 files changed, 203 insertions(+), 140 deletions(-)
diff --git a/src/main/java/com/fzzy/api/view/repository/Api1202Rep.java b/src/main/java/com/fzzy/api/view/repository/Api1202Rep.java
index 3b31632..95879c1 100644
--- a/src/main/java/com/fzzy/api/view/repository/Api1202Rep.java
+++ b/src/main/java/com/fzzy/api/view/repository/Api1202Rep.java
@@ -33,4 +33,12 @@
@Query("from Api1202 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
List<Api1202> findPushDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);
+
+ /**
+ * 鏍规嵁bizId鏌ヨ鏁版嵁
+ * @param bizId
+ * @return
+ */
+ @Query("from Api1202 where bizId =:bizId")
+ List<Api1202> getDataByBizId(@Param("bizId") String bizId);
}
diff --git a/src/main/java/com/fzzy/api/view/repository/Api1205Rep.java b/src/main/java/com/fzzy/api/view/repository/Api1205Rep.java
index f2e1b1e..0de6e06 100644
--- a/src/main/java/com/fzzy/api/view/repository/Api1205Rep.java
+++ b/src/main/java/com/fzzy/api/view/repository/Api1205Rep.java
@@ -26,4 +26,12 @@
@Query("from Api1205 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
List<Api1205> findPushDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);
+
+ /**
+ * 鏍规嵁bizId鏌ヨ鏁版嵁
+ * @param bizId
+ * @return
+ */
+ @Query("from Api1205 where bizId =:bizId")
+ List<Api1205> getDataByBizId(@Param("bizId") String bizId);
}
diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1109.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1109.java
index 20589bd..bef4291 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1109.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1109.java
@@ -2,15 +2,17 @@
import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1109;
+import com.fzzy.api.entity.Api1202;
+import com.fzzy.api.entity.Api1205;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.FileUtil;
import com.fzzy.api.view.repository.Api1109Rep;
+import com.fzzy.api.view.repository.Api1202Rep;
+import com.fzzy.api.view.repository.Api1205Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy35.entity.Fz35FileInfo;
-import com.fzzy.async.fzzy35.entity.Fz35InoutRecord;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1109Rep;
-import com.fzzy.async.fzzy35.repository.Fzzy35Sync1202Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -47,9 +49,11 @@
@Autowired
private Fzzy35Sync1109Rep fzzySync1109Rep;
@Autowired
- private Fzzy35Sync1202Rep fzzySync1202Rep;
- @Autowired
private Api1109Rep api1109Rep;
+ @Autowired
+ private Api1202Rep api1202Rep;
+ @Autowired
+ private Api1205Rep api1205Rep;
@Autowired
private ApiLogRep apiLogRep;
@Autowired
@@ -87,24 +91,29 @@
String wjlx;
String wjmc;
List<Api1109> api1109List;
- List<Fz35InoutRecord> listInout;
+ List<Api1202> api1202List;
+ List<Api1205> api1205List;
+ String str = "";
for (Fz35FileInfo sysData : list) {
if (StringUtils.isEmpty(sysData.getBizId())) {
continue;
}
//鏍规嵁鍥剧墖id鏌ヨ瀵瑰簲鍑哄叆搴撲俊鎭�
- listInout = fzzySync1202Rep.listInoutRecordById(sysData.getBizId());
- if(null == listInout || listInout.isEmpty()){
- continue;
+ if(sysData.getBizId().startsWith(IMG_START_R)){
+ api1202List = api1202Rep.getDataByBizId(sysData.getBizId());
+ if (null == api1202List || api1202List.isEmpty()) {
+ continue;
+ }
+ str = api1202List.get(0).getRkywdh();
}
- //鑻ュ嚭鍏ュ簱淇℃伅涓哄垹闄ゆ垨鑰呴敊璇姸鎬侊紝鍒欎笉鍚屾
- if("DEL".equals(listInout.get(0).getRecordStatus()) || "ERROR".equals(listInout.get(0).getRecordStatus())){
- continue;
+ if(sysData.getBizId().startsWith(IMG_START_C)){
+ api1205List = api1205Rep.getDataByBizId(sysData.getBizId());
+ if (null == api1205List || api1205List.isEmpty()) {
+ continue;
+ }
+ str = api1205List.get(0).getCkywdh();
}
- //鑻ュ嚭鍏ュ簱淇℃伅涓叆搴撻噸閲忎负绌烘垨涓�0锛屽垯涓嶅悓姝�
- if(null == listInout.get(0).getRecordWeight() || listInout.get(0).getRecordWeight() == 0){
- continue;
- }
+
//鍙悓姝ョО閲�
if(BIZ_TAG_WEIGHT_FULL.equals(sysData.getBizTag()) || BIZ_TAG_WEIGHT_EMPTY.equals(sysData.getBizTag())){
wjlx = "";
@@ -132,7 +141,7 @@
apiData.setWjdz(fileUtil.getInoutFilePath(sysData.getCreateTime()) + sysData.getFileName());
//鏂囦欢鍚嶇О
- wjmc = getImgNameType(wjmc, sysData.getBizTag(), sysData.getBizId(), sysData.getFileName(), map);
+ wjmc = getImgNameType(wjmc, sysData.getBizTag(), str, sysData.getFileName(), map);
apiData.setWjmc(wjmc);
//鏂囦欢绫诲瀷
apiData.setWjlx(wjlx);
diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java
index 8d4540b..4fdc9f4 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java
@@ -20,9 +20,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
/**
* 绮鍏ュ簱淇℃伅
@@ -81,6 +79,9 @@
List<Fz35InoutNoticeIn> listInoutNotice;
List<Api1202> api1202List;
Calendar c = Calendar.getInstance();
+ String ywsj = "";
+ String num = "";
+ Map<String, Integer> map = new HashMap<>();
for (Fz35InoutRecord sysData : list) {
if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
sysData.setRecordWeight(sysData.getSettleWeight());
@@ -97,6 +98,16 @@
apiData = new Api1202();
apiData.setRkywdh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
+ //鍒ゆ柇涓氬姟鏃堕棿涓庡崟鎹彿鏄惁鍖归厤
+ ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
+ if(!ywsj.equals(sysData.getId().substring(4, 10))){
+ if(null == map.get(ywsj)){
+ map.put(ywsj, 10201);
+ }
+ num = String.valueOf(map.get(ywsj)).substring(1);
+ apiData.setRkywdh(Constant.INOUT_TYPE_14 + ywsj + num);
+ map.put(ywsj, map.get(ywsj) + 1);
+ }
//璐т綅浠ｇ爜
apiData.setHwdm(api1105.getHwdm());
@@ -107,7 +118,7 @@
//榛樿涓�涓殢渚垮��
apiData.setLxdh(StringUtils.isEmpty(sysData.getUserContact()) ? "13012345678" : sysData.getUserContact());
- apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId());
+ apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId().trim());
//鑾峰彇鍚堝悓鍙�
listInoutNotice = fzzy35SyncNoticeInRep.listInoutNoticeInById(sysData.getNoticeId());
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 f383d4b..2583529 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,7 @@
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
+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,6 +15,7 @@
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;
@@ -37,9 +39,10 @@
private Fzzy35Sync1202Rep fzzySync1202Rep;
@Autowired
private Fzzy35Sync1203Rep fzzySync1203Rep;
-
@Autowired
private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1202Rep api1202Rep;
@Autowired
private Api1203Rep api1203Rep;
@Autowired
@@ -86,12 +89,11 @@
String zkj;
String zkl;
List<Api1203> api1203List;
+ List<Api1202> api1102List;
for (Fz35InoutRecord sysData : list) {
- if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
- sysData.setRecordWeight(sysData.getSettleWeight());
- }
- //鍒ゆ柇鍑�閲嶆槸鍚﹀ぇ浜�0锛岀瓑浜�0琛ㄧず涓嶅悎鏍硷紝涓嶈繘琛屽悓姝ヤ笂浼�
- if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
+ //鏌ヨ绮鍏ュ簱淇℃伅锛岃嫢涓虹┖鍒欎笉杩涜鍚屾涓婁紶
+ api1102List = api1202Rep.getDataByBizId(sysData.getId());
+ if(null == api1102List || api1102List.isEmpty()){
continue;
}
@@ -102,19 +104,12 @@
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());
//璐т綅浠ｇ爜
- apiData.setHwdm(api1105.getHwdm());
- apiData.setRkywdh(apiData.getRkjydh());
+ apiData.setHwdm(api1102List.get(0).getHwdm());
+ apiData.setRkywdh(api1102List.get(0).getRkywdh());
if(null == sysData.getFullWeightTime()){
sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 5));
}
@@ -160,6 +155,9 @@
String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
apiData.setLspzdm(mappingCode);
+ //淇濈鍛樺鏍�
+ apiData.setBgyfh(apiData.getJyjg());
+
//绮绛夌骇
mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, sysData.getFoodLevel());
apiData.setLsdd(mappingCode);
diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java
index 45ac8b1..6cddd0d 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java
@@ -18,9 +18,8 @@
import org.apache.commons.lang.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.List;
+
+import java.util.*;
/**
* 绮鍑哄簱淇℃伅
@@ -78,8 +77,10 @@
Api1105 api1105;
List<Fz35InoutNoticeOut> listInoutNotice;
List<Api1205> api1205List;
- // List<GbArea> gbAreaList;
Calendar c = Calendar.getInstance();
+ String ywsj = "";
+ String num = "";
+ Map<String, Integer> map = new HashMap<>();
for (Fz35InoutRecord sysData : list) {
if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
sysData.setRecordWeight(sysData.getSettleWeight());
@@ -95,7 +96,16 @@
}
apiData = new Api1205();
apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4));
-
+ //鍒ゆ柇涓氬姟鏃堕棿涓庡崟鎹彿鏄惁鍖归厤
+ ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
+ if(!ywsj.equals(sysData.getId().substring(4, 10))){
+ if(null == map.get(ywsj)){
+ map.put(ywsj, 10201);
+ }
+ num = String.valueOf(map.get(ywsj)).substring(1);
+ apiData.setCkywdh(Constant.INOUT_TYPE_15 + ywsj + num);
+ map.put(ywsj, map.get(ywsj) + 1);
+ }
//璐т綅浠ｇ爜
apiData.setHwdm(api1105.getHwdm());
diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1208.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1208.java
index 4df4f97..bfafbc4 100644
--- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1208.java
+++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1208.java
@@ -71,6 +71,7 @@
Api1208 apiData;
Api1105 api1105;
+ List<Api1208> api1208List;
for (Fz35DepotStore fz35DepotStore : list) {
//鑾峰彇璐т綅淇℃伅
@@ -80,6 +81,7 @@
}
apiData = new Api1208();
+ apiData.setId(fz35DepotStore.getId());
apiData.setHwdm(api1105.getHwdm());
//绮鍝佺
@@ -135,7 +137,7 @@
apiData.setSjzlxg(6);
apiData.setLdtj(10000);
- apiData.setZhgxsj(new Date());
+ apiData.setZhgxsj(fz35DepotStore.getUpdateDate());
//涓氬姟id銆佸簱鍖虹紪鐮併�佸悓姝ユ椂闂�
apiData.setBizId(fz35DepotStore.getId());
@@ -143,8 +145,13 @@
apiData.setSyncTime(new Date());
//搴撳瓨姣忔鏂板
- apiData.setCzbz(Constant.CZBZ_I);
- apiData.setId(ContextUtil.getCurTimeMillis());
+ api1208List = api1208Rep.getDataById(apiData.getId());
+ if(null == api1208List || api1208List.isEmpty()){
+ apiData.setCzbz(Constant.CZBZ_I);
+ }else {
+ apiData.setCzbz(api1208List.get(0).getCzbz());
+ }
+
//淇濆瓨鏁版嵁
api1208Rep.save(apiData);
}
diff --git a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
index 1056074..94c7903 100644
--- a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
+++ b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
@@ -58,40 +58,40 @@
Date end = param.getEnd();
//瀹㈡埛鍚屾
- fzzySync1212.syncData(kqdm, deptId, start, end);
+// fzzySync1212.syncData(kqdm, deptId, start, end);
//鍚堝悓鍚屾
- fzzySync1201.syncData(kqdm, deptId, start, end);
+// fzzySync1201.syncData(kqdm, deptId, start, end);
- //绮鍏ュ簱鍚屾
+// //绮鍏ュ簱鍚屾
fzzySync1202.syncData(kqdm, deptId, start, end);
-
- //绮鍏ュ簱璐ㄦ
+//
+// //绮鍏ュ簱璐ㄦ
fzzySync1203.syncData(kqdm, deptId, start, end);
-
- //绮鍏ュ簱缁撶畻
- fzzySync1204.syncData(kqdm, deptId, start, end);
- //绮鍑哄簱鍚屾
- fzzySync1205.syncData(kqdm, deptId, start, end);
-
- //绮鍑哄簱缁撶畻
- fzzySync1206.syncData(kqdm, deptId, start, end);
- //绮鎹熺泭
- fzzySync1209.syncData(kqdm, deptId, start, end);
- //鍊掍粨淇℃伅鍚屾
- fzzySync1207.syncData(kqdm, deptId, start, end);
-
- //鍑哄叆搴撴枃浠朵俊鎭悓姝�
- fzzySync1109.syncData(kqdm, deptId, start, end);
-
- //绮搴撳瓨鍚屾
+//
+// //绮鍏ュ簱缁撶畻
+// fzzySync1204.syncData(kqdm, deptId, start, end);
+// //绮鍑哄簱鍚屾
+// fzzySync1205.syncData(kqdm, deptId, start, end);
+//
+// //绮鍑哄簱缁撶畻
+// fzzySync1206.syncData(kqdm, deptId, start, end);
+// //绮鎹熺泭
+// fzzySync1209.syncData(kqdm, deptId, start, end);
+// //鍊掍粨淇℃伅鍚屾
+// fzzySync1207.syncData(kqdm, deptId, start, end);
+//
+// //鍑哄叆搴撴枃浠朵俊鎭悓姝�
+// fzzySync1109.syncData(kqdm, deptId, start, end);
+//
+// //绮搴撳瓨鍚屾
fzzySync1208.syncData(kqdm, deptId, start, end);
-
- //绮鎬ц川杞彉淇℃伅鍚屾
- fzzySync1210.syncData(kqdm, deptId, start, end);
-
-
- //璐﹂潰搴撳瓨淇℃伅鍚屾 TODO
+//
+// //绮鎬ц川杞彉淇℃伅鍚屾
+// fzzySync1210.syncData(kqdm, deptId, start, end);
+//
+//
+// //璐﹂潰搴撳瓨淇℃伅鍚屾 TODO
}
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1109.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1109.java
index 1507f49..243c1e7 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1109.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1109.java
@@ -2,15 +2,17 @@
import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1109;
+import com.fzzy.api.entity.Api1202;
+import com.fzzy.api.entity.Api1205;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.FileUtil;
import com.fzzy.api.view.repository.Api1109Rep;
+import com.fzzy.api.view.repository.Api1202Rep;
+import com.fzzy.api.view.repository.Api1205Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40FileInfo;
-import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1109Rep;
-import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -48,9 +50,11 @@
@Autowired
private Fzzy40Sync1109Rep fzzySync1109Rep;
@Autowired
- private Fzzy40Sync1202Rep fzzySync1202Rep;
- @Autowired
private Api1109Rep api1109Rep;
+ @Autowired
+ private Api1202Rep api1202Rep;
+ @Autowired
+ private Api1205Rep api1205Rep;
@Autowired
private ApiLogRep apiLogRep;
@Autowired
@@ -88,24 +92,29 @@
String wjlx;
String wjmc;
List<Api1109> api1109List;
- List<Fz40InoutRecord> listInout;
+ List<Api1202> api1202List;
+ List<Api1205> api1205List;
+ String str = "";
for (Fz40FileInfo sysData : list) {
if (StringUtils.isEmpty(sysData.getBizId())) {
continue;
}
//鏍规嵁鍥剧墖id鏌ヨ瀵瑰簲鍑哄叆搴撲俊鎭�
- listInout = fzzySync1202Rep.listInoutRecordById(sysData.getBizId());
- if (null == listInout || listInout.isEmpty()) {
- continue;
+ if(sysData.getBizId().startsWith(IMG_START_R)){
+ api1202List = api1202Rep.getDataByBizId(sysData.getBizId());
+ if (null == api1202List || api1202List.isEmpty()) {
+ continue;
+ }
+ str = api1202List.get(0).getRkywdh();
}
- //鑻ュ嚭鍏ュ簱淇℃伅涓哄垹闄ゆ垨鑰呴敊璇姸鎬侊紝鍒欎笉鍚屾
- if ("DEL".equals(listInout.get(0).getRecordStatus()) || "ERROR".equals(listInout.get(0).getRecordStatus())) {
- continue;
+ if(sysData.getBizId().startsWith(IMG_START_C)){
+ api1205List = api1205Rep.getDataByBizId(sysData.getBizId());
+ if (null == api1205List || api1205List.isEmpty()) {
+ continue;
+ }
+ str = api1205List.get(0).getCkywdh();
}
- //鑻ュ嚭鍏ュ簱淇℃伅涓叆搴撻噸閲忎负绌烘垨涓�0锛屽垯涓嶅悓姝�
- if (null == listInout.get(0).getRecordWeight() || listInout.get(0).getRecordWeight() == 0) {
- continue;
- }
+
//鍙悓姝ョО閲�
if (BIZ_TAG_WEIGHT_FULL.equals(sysData.getBizTag()) || BIZ_TAG_WEIGHT_EMPTY.equals(sysData.getBizTag())) {
wjlx = "";
@@ -133,7 +142,7 @@
apiData.setWjdz(fileUtil.getInoutFilePath(sysData.getCreateTime()) + sysData.getFileName());
//鏂囦欢鍚嶇О
- wjmc = getImgNameType(wjmc, sysData.getBizTag(), sysData.getBizId(), sysData.getFileName(), map);
+ wjmc = getImgNameType(wjmc, sysData.getBizTag(), str, sysData.getFileName(), map);
apiData.setWjmc(wjmc);
//鏂囦欢绫诲瀷
apiData.setWjlx(wjlx);
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java
index 696ffbc..c1eed03 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1202.java
@@ -18,9 +18,8 @@
import org.apache.commons.lang.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.List;
+
+import java.util.*;
/**
* 绮鍏ュ簱淇℃伅
@@ -65,7 +64,6 @@
apiLog.setInteId(Constant.API_CODE_1202);
apiLog.setStatus(99);
apiLog.setId(ContextUtil.getUUID());
- String sfzh = "";
try {
//鑾峰彇绮鍏ュ簱璁板綍淇℃伅锛屾牴鎹祦绋嬪畬鎴愭椂闂磋幏鍙�
List<Fz40InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_IN, start, end);
@@ -80,6 +78,9 @@
List<Fz40InoutNoticeIn> listInoutNotice;
List<Api1202> api1202List;
Calendar c = Calendar.getInstance();
+ String ywsj = "";
+ String num = "";
+ Map<String, Integer> map = new HashMap<>();
for (Fz40InoutRecord sysData : list) {
if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
sysData.setRecordWeight(sysData.getSettleWeight());
@@ -95,11 +96,16 @@
}
apiData = new Api1202();
-
apiData.setRkywdh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
//鍒ゆ柇涓氬姟鏃堕棿涓庡崟鎹彿鏄惁鍖归厤
- if(!DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd").equals(sysData.getId().substring(4, 10))){
- apiData.setRkywdh(Constant.INOUT_TYPE_14 + DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd") + sysData.getId().substring(10));
+ ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
+ if(!ywsj.equals(sysData.getId().substring(4, 10))){
+ if(null == map.get(ywsj)){
+ map.put(ywsj, 10201);
+ }
+ num = String.valueOf(map.get(ywsj)).substring(1);
+ apiData.setRkywdh(Constant.INOUT_TYPE_14 + ywsj + num);
+ map.put(ywsj, map.get(ywsj) + 1);
}
//璐т綅浠ｇ爜
@@ -111,7 +117,7 @@
//榛樿涓�涓殢渚垮��
apiData.setLxdh(StringUtils.isEmpty(sysData.getUserContact()) ? "13012345678" : sysData.getUserContact());
- apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId());
+ apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId().trim());
//鑾峰彇鍚堝悓鍙�
listInoutNotice = fzzySyncNoticeInRep.listInoutNoticeInById(sysData.getNoticeId());
@@ -189,13 +195,13 @@
}else {
apiData.setCzbz(api1202List.get(0).getCzbz());
}
- sfzh = apiData.getSfzh();
+
//淇濆瓨鏁版嵁
api1202Rep.save(apiData);
log.info("1202---鍚屾鏁版嵁锛歿}", apiData.toString());
}
} catch (Exception e) {
- System.out.println(sfzh);
+
log.error("---鍚屾澶辫触----{}", e);
apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
apiLogRep.save(apiLog);
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 ded0330..ea46b9a 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1203.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1203.java
@@ -1,13 +1,10 @@
package com.fzzy.async.fzzy40.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.service.ApiCommonService;
+import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
+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;
@@ -20,9 +17,7 @@
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-
-import java.util.Date;
-import java.util.List;
+import java.util.*;
/**
* 绮鍏ュ簱妫�楠屼俊鎭�
@@ -40,15 +35,14 @@
private Fzzy40Sync1202Rep fzzySync1202Rep;
@Autowired
private Fzzy40Sync1203Rep fzzySync1203Rep;
-
@Autowired
private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1202Rep api1202Rep;
@Autowired
private Api1203Rep api1203Rep;
@Autowired
private GbCheckItemRep gbCheckItemRep;
- @Autowired
- private ApiCommonService commonService;
@Autowired
private ApiLogRep apiLogRep;
@@ -81,7 +75,6 @@
}
Api1203 apiData;
- Api1105 api1105;
List<Fz40CheckItem> fz40CheckItems;
List<GbCheckItem> gbCheckList;
String jyxm;
@@ -89,12 +82,11 @@
String zkj;
String zkl;
List<Api1203> api1203List;
+ List<Api1202> api1102List;
for (Fz40InoutRecord sysData : list) {
- if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
- sysData.setRecordWeight(sysData.getSettleWeight());
- }
- //鍒ゆ柇鍑�閲嶆槸鍚﹀ぇ浜�0锛岀瓑浜�0琛ㄧず涓嶅悎鏍硷紝涓嶈繘琛屽悓姝ヤ笂浼�
- if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
+ //鏌ヨ绮鍏ュ簱淇℃伅锛岃嫢涓虹┖鍒欎笉杩涜鍚屾涓婁紶
+ api1102List = api1202Rep.getDataByBizId(sysData.getId());
+ if(null == api1102List || api1102List.isEmpty()){
continue;
}
@@ -105,19 +97,12 @@
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());
//璐т綅浠ｇ爜
- apiData.setHwdm(api1105.getHwdm());
- apiData.setRkywdh(apiData.getRkjydh());
+ apiData.setHwdm(api1102List.get(0).getHwdm());
+ apiData.setRkywdh(api1102List.get(0).getRkywdh());
if(null == sysData.getFullWeightTime()){
sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 5));
}
@@ -163,10 +148,8 @@
String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
apiData.setLspzdm(mappingCode);
- //绮瀹氱瓑
-
//淇濈鍛樺鏍�
-
+ apiData.setBgyfh(apiData.getJyjg());
//绮绛夌骇
mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, sysData.getFoodLevel());
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1205.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1205.java
index 29cd89c..f74319e 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1205.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1205.java
@@ -19,9 +19,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
/**
* 绮鍑哄簱淇℃伅
@@ -80,6 +78,9 @@
List<Fz40InoutNoticeOut> listInoutNotice;
List<Api1205> api1205List;
Calendar c = Calendar.getInstance();
+ String ywsj = "";
+ String num = "";
+ Map<String, Integer> map = new HashMap<>();
for (Fz40InoutRecord sysData : list) {
if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
sysData.setRecordWeight(sysData.getSettleWeight());
@@ -95,7 +96,16 @@
}
apiData = new Api1205();
apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4));
-
+ //鍒ゆ柇涓氬姟鏃堕棿涓庡崟鎹彿鏄惁鍖归厤
+ ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
+ if(!ywsj.equals(sysData.getId().substring(4, 10))){
+ if(null == map.get(ywsj)){
+ map.put(ywsj, 10201);
+ }
+ num = String.valueOf(map.get(ywsj)).substring(1);
+ apiData.setCkywdh(Constant.INOUT_TYPE_15 + ywsj + num);
+ map.put(ywsj, map.get(ywsj) + 1);
+ }
//璐т綅浠ｇ爜
apiData.setHwdm(api1105.getHwdm());
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1208.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1208.java
index a8aaf00..a841582 100644
--- a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1208.java
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1208.java
@@ -1,10 +1,7 @@
package com.fzzy.async.fzzy40.impl;
import com.fzzy.api.Constant;
-import com.fzzy.api.entity.Api1102;
-import com.fzzy.api.entity.Api1105;
-import com.fzzy.api.entity.Api1208;
-import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
@@ -75,6 +72,7 @@
Api1208 apiData;
Api1105 api1105;
+ List<Api1208> api1208List;
for (Fz40DepotStore fz40DepotStore : list) {
//鑾峰彇璐т綅淇℃伅
@@ -84,6 +82,7 @@
}
apiData = new Api1208();
+ apiData.setId(fz40DepotStore.getId());
apiData.setHwdm(api1105.getHwdm());
//绮鍝佺
@@ -139,7 +138,7 @@
apiData.setSjzlxg(6);
apiData.setLdtj(10000);
- apiData.setZhgxsj(new Date());
+ apiData.setZhgxsj(fz40DepotStore.getUpdateDate());
//涓氬姟id銆佸簱鍖虹紪鐮併�佸悓姝ユ椂闂�
apiData.setBizId(fz40DepotStore.getId());
@@ -147,8 +146,13 @@
apiData.setSyncTime(new Date());
//搴撳瓨姣忔鏂板
- apiData.setCzbz(Constant.CZBZ_I);
- apiData.setId(ContextUtil.getCurTimeMillis());
+ api1208List = api1208Rep.getDataById(apiData.getId());
+ if(null == api1208List || api1208List.isEmpty()){
+ apiData.setCzbz(Constant.CZBZ_I);
+ }else {
+ apiData.setCzbz(api1208List.get(0).getCzbz());
+ }
+
//淇濆瓨鏁版嵁
api1208Rep.save(apiData);
}
diff --git a/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1202Rep.java b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1202Rep.java
index 1ab8136..f2bebaf 100644
--- a/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1202Rep.java
+++ b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1202Rep.java
@@ -23,7 +23,7 @@
* @param end
* @return
*/
- @Query("from Fz40InoutRecord where deptId=:deptId and type=:type and updateTime >=:start and updateTime <:end order by updateTime ")
+ @Query("from Fz40InoutRecord where deptId=:deptId and type=:type and updateTime >=:start and updateTime <:end order by id ")
List<Fz40InoutRecord> listInoutRecord(@Param("deptId") String deptId, @Param("type") String type, @Param("start") Date start, @Param("end") Date end);
/**
--
Gitblit v1.9.3