From 7494eb35eb0e6a3f33dff907133e59f677800003 Mon Sep 17 00:00:00 2001 From: 陈战涛 <chenzhantao7055@sina.com> Date: 星期四, 25 五月 2023 11:29:27 +0800 Subject: [PATCH] 优化3.5版本同步时,操作标志的状态 --- src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java | 11 +++++++---- 1 files changed, 7 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java index c4bf0c7..2103ef8 100644 --- a/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java +++ b/src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1302.java @@ -16,7 +16,6 @@ import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; - import java.util.Date; import java.util.List; @@ -71,7 +70,7 @@ Date syncTime = new Date(); Api1302 api1302; Api1105 api1105; - //int index = 10001; + List<Api1302> api1302List; for (Fz35Grain fz35Grain : list) { //鑾峰彇璐т綅淇℃伅 api1105 = commonService.getApi1105Cache(fz35Grain.getDepotId()); @@ -113,15 +112,19 @@ api1302.setLssdzjh(getHumPointList2(fz35Grain.getPoints(), fz35Grain.getCable(), fz35Grain.getCableCir())); } - api1302.setCzbz(Constant.CZBZ_I); api1302.setZhgxsj(syncTime); api1302.setBizId(fz35Grain.getBatchId()); api1302.setKqdm(api1105.getKqdm()); api1302.setSyncTime(syncTime); + api1302List = api1302Rep.getDataByWsdjcdh(api1302.getWsdjcdh()); + if(null == api1302List || api1302List.isEmpty()){ + api1302.setCzbz(Constant.CZBZ_I); + }else { + api1302.setCzbz(api1302List.get(0).getCzbz()); + } log.info("1302---鍚屾鏁版嵁锛�" + api1302.toString()); api1302Rep.save(api1302); - // index++; } } catch (Exception e) { -- Gitblit v1.9.3