From d2743de6842f6af91408e0b4ce53ee25627d3e6e Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期二, 04 三月 2025 14:04:50 +0800 Subject: [PATCH] * --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 42 +++++++++++++++++++++++++++++++++++++----- 1 files changed, 37 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java index f6eea83..fa18b85 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -16,6 +16,7 @@ import com.zy.asrs.utils.SortTheExecutionOfTheCarUtil; import com.zy.asrs.utils.TimeCalculatorUtils; import com.zy.common.CodeRes; +import com.zy.common.service.CommonService; import com.zy.common.utils.HttpHandler; import com.zy.core.cache.MessageQueue; import com.zy.core.cache.SlaveConnection; @@ -54,6 +55,8 @@ private BasCircularShuttleService basCircularShuttleService; @Autowired private WrkMastService wrkMastService; + @Autowired + private CommonService commonService; @Value("${constant-parameters.perimeter}") private Long perimeter; @@ -65,6 +68,14 @@ private Long rgvCount; @Value("${constant-parameters.rgvDate}") private Double rgvDate; + @Value("${wms.url}") + private String wmsUrl; + @Value("${wms.reportOutPath}") + private String wmsOutPath; + @Value("${wms.reportSwitch}") + private boolean reportSwitch; + @Value("${wms.reportSwitchAuto}") + private boolean reportSwitchAuto; /* * 楠岃瘉璁稿彲璇佹槸鍚︽湁鏁� @@ -386,15 +397,36 @@ wrkMast.setAppeTime(now); try{ try{ - RgvTaskReportingParam rgvTaskReportingParam = new RgvTaskReportingParam(wrkMast); - ReturnT<String> result = new PostMesDataUtils().postMesDataWcs("", "", rgvTaskReportingParam); - if (result.getCode()==200){ + if (reportSwitch){ + RgvTaskReportingParam rgvTaskReportingParam = new RgvTaskReportingParam(wrkMast); + ReturnT<String> result = new PostMesDataUtils().postMesDataWcs(wmsUrl, wmsOutPath, rgvTaskReportingParam); + if (result.getCode()==200){ + wrkMast.setWrkSts(4L); + wrkMast.setAppeTime(now); + wrkMastService.updateById(wrkMast); + continue; + }else { + log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触"); + } + } else { + //娴嬭瘯鐢� wrkMast.setWrkSts(4L); wrkMast.setAppeTime(now); wrkMastService.updateById(wrkMast); + if (reportSwitchAuto) { + WrkMast wrkMast1 = new WrkMast(); + int workNo = commonService.getWorkNo(0); + wrkMast1.setWrkNo((long) workNo); + wrkMast1.setSourceStaNo(wrkMast.getSourceNoCs()); + wrkMast1.setStaNo(wrkMast.getStaNoCs()); + wrkMast1.setWrkSts(1L); + wrkMast1.setIoType(1); + wrkMast1.setModiTime(now); + wrkMast1.setAppeTime(now); + wrkMast1.setMemo("娴嬭瘯鏁版嵁"); + wrkMastService.insert(wrkMast1); + } continue; - }else { - log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触"); } } catch (Exception e){ log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触锛屽紓甯镐俊鎭細"+e); -- Gitblit v1.9.1