From 9d38f2354b3a7267a2486d937bb7d256fcb949c1 Mon Sep 17 00:00:00 2001 From: lty <876263681@qq.com> Date: 星期五, 13 六月 2025 08:15:48 +0800 Subject: [PATCH] #增加生产日期,到期日期字段,增加库存明细超期库存检索 --- src/main/java/com/zy/common/web/WcsController.java | 87 +++++++++++++++++++++++++++++++++++-------- 1 files changed, 70 insertions(+), 17 deletions(-) diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java index 2b2ab28..2b79a7f 100644 --- a/src/main/java/com/zy/common/web/WcsController.java +++ b/src/main/java/com/zy/common/web/WcsController.java @@ -9,6 +9,7 @@ import com.zy.asrs.mapper.WrkMastMapper; import com.zy.asrs.service.*; import com.zy.common.CodeRes; +import com.zy.common.model.AgvBasDevpDto; import com.zy.common.model.LocTypeDto; import com.zy.common.model.StartupDto; import com.zy.common.service.CommonService; @@ -26,6 +27,8 @@ import java.util.HashMap; import java.util.List; import java.util.stream.Collectors; + +import static jdk.nashorn.internal.runtime.regexp.joni.Config.log; /** * Created by vincent on 2020/10/30 @@ -67,6 +70,8 @@ private WrkMastLogService wrkMastLogService; @Autowired private AgvWrkDetlService agvWrkDetlService; + @Autowired + private AgvLocDetlService agvLocDetlService; // @Autowired // private ErpService erpService; @@ -275,6 +280,8 @@ WrkDetl wrkDetl = new WrkDetl(); BeanUtils.copyProperties(waitPakin, wrkDetl); wrkDetl.setZpallet(barcode); + wrkDetl.setProddate(waitPakin.getProddate()); + wrkDetl.setDeadline(waitPakin.getDeadline()); wrkDetl.setWrkNo(wrkMast.getWrkNo()); wrkDetl.setIoTime(wrkMast.getIoTime()); wrkDetl.setAppeTime(now); @@ -630,7 +637,8 @@ currentContainerMap = new HashMap<>(); } - String containerCode = param.getContainerCode(); + String containerCode = param.getContainerCode().split(";")[0]; + if(Cools.isEmpty(containerCode)){ throw new CoolException("鏂欑鐮佷负绌�"); } @@ -648,19 +656,22 @@ //鏌ヨ鏃у鍣ㄧ殑宸ヤ綔妗� AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(currentContainerCode); if(!Cools.isEmpty(agvWrkMast) && agvWrkMast.getIoType() == 101){ - //鍙戦�佸鍣ㄧ珛鍦鸿姹傦紝瀹屾垚宸ヤ綔妗� - List<AgvWrkMast> agvWrkMastList = new ArrayList<>(); - agvWrkMastList.add(agvWrkMast); - try { - int code = agvWrkMastService.containerMoveOut(agvWrkMastList); - if(code == 0){ - //灏嗗伐浣滃厷鐘舵�佹敼涓哄鍣ㄧ鍦� - agvWrkMast.setWrkSts(206L); - agvWrkMastService.updateById(agvWrkMast); - } - } catch (IOException e) { - log.error(e.getMessage()); - } + //灏嗗伐浣滃厷鐘舵�佹敼涓哄鍣ㄧ鍦� + agvWrkMast.setWrkSts(206L); + agvWrkMastService.updateById(agvWrkMast); +// //鍙戦�佸鍣ㄧ珛鍦鸿姹傦紝瀹屾垚宸ヤ綔妗� +// List<AgvWrkMast> agvWrkMastList = new ArrayList<>(); +// agvWrkMastList.add(agvWrkMast); +// try { +// int code = agvWrkMastService.containerMoveOut(agvWrkMastList); +// if(code == 0){ +// //灏嗗伐浣滃厷鐘舵�佹敼涓哄鍣ㄧ鍦� +// agvWrkMast.setWrkSts(206L); +// agvWrkMastService.updateById(agvWrkMast); +// } +// } catch (IOException e) { +// log.error(e.getMessage()); +// } } } @@ -679,18 +690,60 @@ String devNo = param.getDevNo(); String containerCode = currentContainerMap.get(devNo); + AgvBasDevpDto agvBasDevpDto = new AgvBasDevpDto(); + //鏌ユ壘璇ュ鍣ㄧ殑宸ヤ綔妗� AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(containerCode); if(!Cools.isEmpty(agvWrkMast)){ - return R.ok(agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no",agvWrkMast.getWrkNo()))); + List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", agvWrkMast.getWrkNo())); + + for (AgvWrkDetl agvWrkDetl : agvWrkDetlList){ + agvWrkDetl.setVolume(agvWrkDetl.getAnfme()); + if(agvWrkMast.getIoType() == 103){ + //瀵绘壘鏄惁鏈夌浉鍚岀墿鏂欑殑宸ヤ綔妗f槑缁嗭紝骞惰繑鍥炴暟閲忎箣鍜� + double anfme = getAllAnfmeInAgvWrkDetlList(agvWrkDetlList,agvWrkDetl); + AgvLocDetl agvLocDetl = agvLocDetlService.selectByMatnrAndBatchAndCsocodeAndisoCode(agvWrkMast.getSourceLocNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode(), agvWrkDetl.getDeadTime()); + //鐢ㄤ簬缁撲綑鏁伴噺鏄剧ず + agvWrkDetl.setVolume(agvLocDetl.getAnfme() - anfme); + } + if(agvWrkMast.getIoType() == 53){ + AgvLocDetl agvLocDetl = agvLocDetlService.selectByMatnrAndBatchAndCsocodeAndisoCode(agvWrkMast.getLocNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode(), agvWrkDetl.getDeadTime()); + if(Cools.isEmpty(agvLocDetl)){ + agvWrkDetl.setVolume(0.0); + }else { + agvWrkDetl.setVolume(agvLocDetl.getAnfme()); + } + } + }; + + agvBasDevpDto.setAgvWrkDetls(agvWrkDetlList); + agvBasDevpDto.setAgvWrkMast(agvWrkMast); } //鏌ユ壘璇ュ鍣ㄧ殑鍏ュ簱閫氱煡妗� List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>().eq("supp_code", containerCode)); if(!Cools.isEmpty(agvWaitPakinList)){ - return R.ok(agvWaitPakinList); + agvBasDevpDto.setAgvWaitPakins(agvWaitPakinList); } - return R.error("娌℃湁璇ュ鍣ㄧ殑鍑哄簱銆佹嫞鏂欍�佸叆搴撲俊鎭瓑"); + System.out.println("currentContainerMap: " + currentContainerMap); + + + System.out.println("agvBasDevpDto: " + agvBasDevpDto); + + return R.ok(agvBasDevpDto); + } + + private double getAllAnfmeInAgvWrkDetlList(List<AgvWrkDetl> agvWrkDetlList, AgvWrkDetl wd0) { + double allAnfme = 0; + for (AgvWrkDetl wd1 : agvWrkDetlList){ + if(Cools.eq(wd0.getMatnr(),wd1.getMatnr()) + && Cools.eq(wd0.getBatch(),wd1.getBatch()) + && Cools.eq(wd0.getThreeCode(),wd1.getThreeCode()) + && Cools.eq(wd0.getDeadTime(),wd1.getDeadTime())){ + allAnfme += wd1.getAnfme(); + } + } + return allAnfme; } -- Gitblit v1.9.1