From aa3476e8ff45d168f0bb9376ed3a114610a65f12 Mon Sep 17 00:00:00 2001 From: zhangc <zc@123> Date: 星期三, 25 十二月 2024 08:39:12 +0800 Subject: [PATCH] 添加工厂判断逻辑及优化库位查找 --- src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java | 109 +++++++++++++++++++++++++++--------------------------- 1 files changed, 55 insertions(+), 54 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java index 7b2dde8..18cb689 100644 --- a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java @@ -1,5 +1,6 @@ package com.zy.asrs.service.impl; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.mapper.Wrapper; import com.baomidou.mybatisplus.plugins.Page; @@ -58,9 +59,10 @@ log.info("agvWrkDetl: " + agvLocDetl.getBarcode()); BeanUtils.copyProperties(agvWrkDetl, agvLocDetl); agvLocDetl.setLocNo(locNo); + log.info("zc娣诲姞搴撳瓨鏃ュ織:{}", JSON.toJSON(agvLocDetl)); this.insert(agvLocDetl); // 娴佹按 -- 鏂板璁㈠崟鏄庣粏 - OrderDetl orderDetl = orderDetlService.selectItem(agvWrkDetl.getOrderNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getThreeCode()); + OrderDetl orderDetl = orderDetlService.selectItem(agvWrkDetl.getOrderNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode()); // FlowLog flowLog = new FlowLog(); // flowLog.setFid(String.valueOf(flowId)); // flowLog.setSpare2(String.valueOf(taskCode)); @@ -91,39 +93,39 @@ } - public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued, String csocode, String isoseq,String type) { + public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued, String csocode, String isoseq, String type) { //鏍规嵁鐗╂枡鍙峰拰鎵规鎵惧埌瀵瑰簲鐨勫簱瀛橈紝骞朵笖鎸夌収淇敼鏃堕棿鎺掑簭 Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).orderBy("modi_time"); if (type != null) { wrapper.notLike("loc_no", "F1"); } - wapperSetCondition(wrapper,"batch",batch); - wapperSetCondition(wrapper,"three_code",csocode); - wapperSetCondition(wrapper,"dead_time",isoseq); + wapperSetCondition(wrapper, "batch", batch); + wapperSetCondition(wrapper, "three_code", csocode); + wapperSetCondition(wrapper, "dead_time", isoseq); - if ("JG".equals(orderNo.substring(0,2))) { - wapperSetCondition(wrapper,"process_sts","1"); + if ("JG".equals(orderNo.substring(0, 2))) { + wapperSetCondition(wrapper, "process_sts", "1"); } List<AgvLocDetl> agvLocDetls = this.selectList(wrapper); - for (AgvLocDetl agvLocDetl: agvLocDetls) { + for (AgvLocDetl agvLocDetl : agvLocDetls) { //鍒ゆ柇褰撳墠搴撲綅璐х墿鏄惁F鍦ㄥ簱 AgvLocMast agvLocMast = agvLocMastService.selectById(agvLocDetl.getLocNo()); - if(!"F".equals(agvLocMast.getLocSts())){ + if (!"F".equals(agvLocMast.getLocSts())) { continue; } //濡傛灉璁㈠崟鍓╀綑鍑哄簱閲忓ぇ浜�0 - if(issued > 0) { + if (issued > 0) { //褰撳墠搴撲綅鐨勫簱瀛橀噺 double anfme = agvLocDetl.getAnfme(); //int ioType = anfme > issued ? 101 : 103; anfme = anfme > issued ? issued : anfme; //鐢ㄤ簬鏄剧ず宸ヤ綔鏄庣粏妗g殑璁㈠崟鍙� - String orderNoWrkDtel = Utils.getOrderNo(orderNo,anfme); + String orderNoWrkDtel = Utils.getOrderNo(orderNo, anfme); //鏇存柊璁㈠崟鏁伴噺 - orderNo = Utils.orderMergeUpdate(orderNo,anfme); - LocDto locDto = new LocDto(agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getMaktx(), agvLocDetl.getBatch(), orderNoWrkDtel, anfme,agvLocDetl.getProcessSts()); + orderNo = Utils.orderMergeUpdate(orderNo, anfme); + LocDto locDto = new LocDto(agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getMaktx(), agvLocDetl.getBatch(), orderNoWrkDtel, anfme, agvLocDetl.getProcessSts()); locDto.setCsocode(csocode); locDto.setIsoseq(isoseq); locDto.setContainerCode(agvLocDetl.getSuppCode()); @@ -131,7 +133,7 @@ //褰撳墠搴撲綅鎵�澶勬ゼ灞� int floor = Integer.parseInt(agvLocDetl.getLocNo().split("F")[1]); //locDto.setAgvStaNos(queryAgvStaNosByFloor(floor)); - locDto.setAgvStaNos(agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1(),floor)); + locDto.setAgvStaNos(agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1(), floor)); locDtoList.add(locDto); issued -= anfme; @@ -146,7 +148,7 @@ 鏇存柊搴撳瓨鏄庣粏 */ public void updateStock(String sourceLoc, String targetLoc) { - this.baseMapper.updateStock(sourceLoc,targetLoc); + this.baseMapper.updateStock(sourceLoc, targetLoc); } public Page<AgvLocDetl> getStockStatis(Page<AgvLocDetl> page) { @@ -162,7 +164,7 @@ @Override public AgvLocDetl selectItem(String locNo, String matnr, String batch, String csocode, String isoCode) { - return this.baseMapper.selectItemByOrderNo(locNo, matnr, batch,csocode,isoCode); + return this.baseMapper.selectItemByOrderNo(locNo, matnr, batch, csocode, isoCode); } @Override @@ -176,12 +178,12 @@ } @Override - public Double getSumAnfmeDb(String matnr, String threeCode,Integer floor) { + public Double getSumAnfmeDb(String matnr, String threeCode, Integer floor) { return this.baseMapper.selectSumAnfmeByMatnr2(matnr, threeCode, floor); } @Override - public Double getSumAnfmeback(String matnr, String threeCode,Integer floor) { + public Double getSumAnfmeback(String matnr, String threeCode, Integer floor) { return this.baseMapper.getSumAnfmeback(matnr, threeCode, floor); } @@ -192,7 +194,7 @@ return this.baseMapper.sum(); } - public List<AgvLocDetl> getStockStatisExcel(){ + public List<AgvLocDetl> getStockStatisExcel() { return this.baseMapper.getStockStatisExcel(); } @@ -201,20 +203,20 @@ return new ArrayList<AgvLocDetl>(); } EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>(); - if(Cools.isEmpty(orderNo)){ - wrapper.like("order_no",orderNo); + if (Cools.isEmpty(orderNo)) { + wrapper.like("order_no", orderNo); } - if(Cools.isEmpty(matnr)){ - wrapper.like("matnr",matnr); + if (Cools.isEmpty(matnr)) { + wrapper.like("matnr", matnr); } - if(Cools.isEmpty(maktx)){ - wrapper.like("maktx",maktx); + if (Cools.isEmpty(maktx)) { + wrapper.like("maktx", maktx); } - if(Cools.isEmpty(specs)){ - wrapper.like("specs",specs); + if (Cools.isEmpty(specs)) { + wrapper.like("specs", specs); } - if(Cools.isEmpty()){ - wrapper.like("loc_no",locNo); + if (Cools.isEmpty()) { + wrapper.like("loc_no", locNo); } return this.selectList(wrapper); } @@ -222,42 +224,42 @@ public boolean updateAnfme(Double anfme, String locNo, String matnr, String batch, String csocode, String isocode) { EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>(); wrapper.eq("loc_no", locNo); - Utils.confirmOnlyMat(wrapper,matnr,batch,csocode,isocode); + Utils.confirmOnlyMat(wrapper, matnr, batch, csocode, isocode); if (anfme <= 0) { - return this.baseMapper.deleteLocDetl(locNo,anfme,matnr,batch,csocode,isocode) > 0; + return this.baseMapper.deleteLocDetl(locNo, anfme, matnr, batch, csocode, isocode) > 0; } else { AgvLocDetl agvLocDetl = this.selectOne(wrapper); agvLocDetl.setAnfme(anfme); agvLocDetl.setModiTime(new Date()); - return this.baseMapper.updateAnfme(locNo,anfme,matnr,batch,csocode,isocode) > 0; + return this.baseMapper.updateAnfme(locNo, anfme, matnr, batch, csocode, isocode) > 0; } } public boolean updateAnfmeProcess(Double anfme, String locNo, String matnr, String batch, String csocode, String isocode, Integer process) { EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>(); wrapper.eq("loc_no", locNo); - Utils.confirmOnlyMat(wrapper,matnr,batch,csocode,isocode); + Utils.confirmOnlyMat(wrapper, matnr, batch, csocode, isocode); if (anfme <= 0) { - return this.baseMapper.deleteLocDetl(locNo,anfme,matnr,batch,csocode,isocode) > 0; + return this.baseMapper.deleteLocDetl(locNo, anfme, matnr, batch, csocode, isocode) > 0; } else { AgvLocDetl agvLocDetl = this.selectOne(wrapper); agvLocDetl.setAnfme(anfme); agvLocDetl.setModiTime(new Date()); - return this.baseMapper.updateAnfmeProcess(locNo,anfme,matnr,batch,csocode,isocode,process) > 0; + return this.baseMapper.updateAnfmeProcess(locNo, anfme, matnr, batch, csocode, isocode, process) > 0; } } - private void wapperSetCondition(Wrapper wrapper,String column, String condition){ - if(Cools.isEmpty(condition)){ - wrapper.andNew().eq(column,"").or().isNull(column); - }else { - wrapper.andNew().eq(column,condition); + private void wapperSetCondition(Wrapper wrapper, String column, String condition) { + if (Cools.isEmpty(condition)) { + wrapper.andNew().eq(column, "").or().isNull(column); + } else { + wrapper.andNew().eq(column, condition); } } - public AgvLocDetl selectByLocNo(String locNo){ - return this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no",locNo)); + public AgvLocDetl selectByLocNo(String locNo) { + return this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo)); } @Override @@ -265,7 +267,7 @@ List<AgvLocDetl> agvLocDetls = new ArrayList<>(); taskDto.getLocDtos().forEach(locDto -> { - AgvLocDetl agvLocDetl = this.selectByMatnrAndBatchAndCsocodeAndisoCode(locDto.getLocNo(),locDto.getMatnr(), locDto.getBatch(), locDto.getCsocode(), locDto.getIsoseq()); + AgvLocDetl agvLocDetl = this.selectByMatnrAndBatchAndCsocodeAndisoCode(locDto.getLocNo(), locDto.getMatnr(), locDto.getBatch(), locDto.getCsocode(), locDto.getIsoseq()); agvLocDetls.add(agvLocDetl); }); return agvLocDetls; @@ -274,16 +276,16 @@ @Override public AgvLocDetl selectByMatnrAndBatchAndCsocodeAndisoCode(String locNo, String matnr, String batch, String csocode, String isocode) { EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>(); - wrapper.eq("loc_no",locNo); - Utils.confirmOnlyMat(wrapper,matnr,batch,csocode,isocode); + wrapper.eq("loc_no", locNo); + Utils.confirmOnlyMat(wrapper, matnr, batch, csocode, isocode); return this.selectOne(wrapper); } @Override - public AgvLocDetl selectByMatnrAndBatchAndCsocodeAndisoCode2(String locNo,String orderNo, String matnr, String batch, String csocode, String isocode) { + public AgvLocDetl selectByMatnrAndBatchAndCsocodeAndisoCode2(String locNo, String orderNo, String matnr, String batch, String csocode, String isocode) { EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>(); - wrapper.eq("loc_no",locNo); - Utils.confirmOnlyMat2(wrapper,orderNo,matnr,batch,csocode,isocode); + wrapper.eq("loc_no", locNo); + Utils.confirmOnlyMat2(wrapper, orderNo, matnr, batch, csocode, isocode); return this.selectOne(wrapper); } @@ -299,7 +301,7 @@ @Override public AgvLocDetl selectLocdetl(String locNo, String matnr, String batch, String csocode, String isocode) { - return this.baseMapper.selectLocdetl(locNo,matnr,batch,csocode,isocode); + return this.baseMapper.selectLocdetl(locNo, matnr, batch, csocode, isocode); } @Override @@ -314,8 +316,7 @@ try { if (excelVersion == 2003) { book = new HSSFWorkbook(inStream); - } - else { // 褰� excel 鏄� 2007 鏃� + } else { // 褰� excel 鏄� 2007 鏃� book = new XSSFWorkbook(inStream); } } catch (Exception e) { @@ -335,10 +336,10 @@ String containerCode = dataFormatter.formatCellValue(row.getCell(1)); List<AgvLocDetl> agvLocDetls = this.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo).eq("supp_code", containerCode)); - if(Cools.isEmpty(agvLocDetls)){ + if (Cools.isEmpty(agvLocDetls)) { log.info("搴撲綅鍙凤細" + locNo + "锛岃揣鏋剁爜锛�" + containerCode + "锛屼笉瀛樺湪鏄庣粏"); } - if(agvLocDetls.size()>1){ + if (agvLocDetls.size() > 1) { log.info("搴撲綅鍙凤細" + locNo + "锛岃揣鏋剁爜锛�" + containerCode + "锛屽瓨鍦�1鏉′互涓婅褰�"); } } @@ -346,6 +347,6 @@ @Override public void updateLocNo(String locNo, String sourceLoc, AgvLocDetl agvLocDetl) { - this.baseMapper.updateLocNo(locNo,sourceLoc,agvLocDetl.getSuppCode()); + this.baseMapper.updateLocNo(locNo, sourceLoc, agvLocDetl.getSuppCode()); } } -- Gitblit v1.9.1