From 45d602719964509214d06ec5173f23e5307d5dfe Mon Sep 17 00:00:00 2001 From: zyx <zyx123456> Date: 星期二, 16 四月 2024 12:24:10 +0800 Subject: [PATCH] 无空库位时,不做空板入库操作 --- src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java | 133 ++++++++++++++++++++++++++++++++++++------- 1 files changed, 110 insertions(+), 23 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 7e212d6..175d9e0 100644 --- a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java @@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.plugins.Page; import com.baomidou.mybatisplus.service.impl.ServiceImpl; import com.core.common.Cools; +import com.core.exception.CoolException; import com.zy.asrs.entity.AgvLocDetl; import com.zy.asrs.entity.AgvLocMast; import com.zy.asrs.entity.AgvWrkDetl; @@ -13,13 +14,25 @@ import com.zy.asrs.service.AgvLocDetlService; import com.zy.asrs.service.AgvLocMastService; import com.zy.asrs.service.AgvWrkDetlService; +import com.zy.asrs.utils.Utils; import com.zy.common.model.LocDto; +import com.zy.common.model.TaskDto; import lombok.extern.slf4j.Slf4j; +import org.apache.poi.hssf.usermodel.HSSFWorkbook; +import org.apache.poi.ss.usermodel.DataFormatter; +import org.apache.poi.ss.usermodel.Row; +import org.apache.poi.ss.usermodel.Sheet; +import org.apache.poi.ss.usermodel.Workbook; +import org.apache.poi.xssf.usermodel.XSSFWorkbook; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.web.multipart.MultipartFile; +import java.io.IOException; +import java.io.InputStream; import java.util.ArrayList; +import java.util.Date; import java.util.List; import java.util.stream.Collectors; @@ -69,13 +82,18 @@ double anfme = agvLocDetl.getAnfme(); //int ioType = anfme > issued ? 101 : 103; anfme = anfme > issued ? issued : anfme; - LocDto locDto = new LocDto(agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getMaktx(), agvLocDetl.getBatch(), orderNo, anfme); + //鐢ㄤ簬鏄剧ず宸ヤ綔鏄庣粏妗g殑璁㈠崟鍙� + 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); locDto.setCsocode(csocode); locDto.setIsoseq(isoseq); locDto.setContainerCode(agvLocDetl.getSuppCode()); //褰撳墠搴撲綅鎵�澶勬ゼ灞� - int floor = Integer.parseInt(agvLocDetl.getLocNo().split("@")[1]); - locDto.setAgvStaNos(queryAgvStaNosByFloor(floor)); + int floor = Integer.parseInt(agvLocDetl.getLocNo().split("F")[1]); + //locDto.setAgvStaNos(queryAgvStaNosByFloor(floor)); + locDto.setAgvStaNos(agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1())); locDtoList.add(locDto); issued -= anfme; @@ -133,41 +151,110 @@ return this.selectList(wrapper); } - public boolean updateAnfme(Double anfme, String locNo, String matnr, String batch) { + 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); if (anfme <= 0) { - return this.delete(new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).eq("loc_no", locNo)); + return this.baseMapper.deleteLocDetl(locNo,anfme,matnr,batch,csocode,isocode) > 0; } else { - AgvLocDetl agvLocDetl = this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo).eq("matnr", matnr)); + AgvLocDetl agvLocDetl = this.selectOne(wrapper); agvLocDetl.setAnfme(anfme); - return this.update(agvLocDetl,new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo).eq("matnr", matnr)); - //return baseMapper.updateAnfme(anfme, locNo, matnr, batch) > 0; + return this.baseMapper.updateAnfme(locNo,anfme,matnr,batch,csocode,isocode) > 0; } } - private List<String> queryAgvStaNosByFloor(int floor){ - List<String> agvStaNos = new ArrayList<>(); - if(floor == 1){ - agvStaNos.add("CS-101"); - agvStaNos.add("CS-102"); - }else if(floor ==3){ - agvStaNos.add("CS-305"); - agvStaNos.add("CS-306"); - agvStaNos.add("CS-307"); - } - - return agvStaNos; - } private void wapperSetCondition(Wrapper wrapper,String column, String condition){ if(Cools.isEmpty(condition)){ wrapper.andNew().eq(column,"").or().isNull(column); - //wrapper.isNull(column); }else { - wrapper.eq(column,condition); + wrapper.andNew().eq(column,condition); } } public AgvLocDetl selectByLocNo(String locNo){ return this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no",locNo)); } + + @Override + public List<AgvLocDetl> selectByTaskDto(TaskDto taskDto) { + List<AgvLocDetl> agvLocDetls = new ArrayList<>(); + + taskDto.getLocDtos().forEach(locDto -> { + AgvLocDetl agvLocDetl = this.selectByMatnrAndBatchAndCsocodeAndisoCode(locDto.getLocNo(),locDto.getMatnr(), locDto.getBatch(), locDto.getCsocode(), locDto.getIsoseq()); + agvLocDetls.add(agvLocDetl); + }); + return agvLocDetls; + } + + @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); + return this.selectOne(wrapper); + } + + @Override + public Double selectSumAnfmeByLocNo(String locNo) { + return this.baseMapper.sumByLocNo(locNo); + } + + @Override + public Double selectSumAnfmeByMatnr(String matnr) { + return this.baseMapper.sumByMatnr(matnr); + } + + @Override + public AgvLocDetl selectLocdetl(String locNo, String matnr, String batch, String csocode, String isocode) { + return this.baseMapper.selectLocdetl(locNo,matnr,batch,csocode,isocode); + } + + @Override + public void compareToEss(MultipartFile file) throws IOException { + InputStream inStream = file.getInputStream(); + String fileMime = file.getContentType(); + int excelVersion = 2007; + if ("application/vnd.ms-excel".equals(fileMime)) { + excelVersion = 2003; + } + Workbook book = null; + try { + if (excelVersion == 2003) { + book = new HSSFWorkbook(inStream); + } + else { // 褰� excel 鏄� 2007 鏃� + book = new XSSFWorkbook(inStream); + } + } catch (Exception e) { + log.error("fail", e); + throw new CoolException("瀵煎叆鏂囦欢鏍煎紡閿欒锛岃浣跨敤xls鍚庣紑鐨勬枃浠讹紒"); + } + + Sheet sheet = book.getSheetAt(0); + int totalRows = sheet.getLastRowNum() + 1; // 鎬� + Date now = new Date(); + DataFormatter dataFormatter = new DataFormatter(); + for (int i = 0; i < totalRows; i++) { + Row row = sheet.getRow(i); + // 搴撲綅鍙� + String locNo = dataFormatter.formatCellValue(row.getCell(0)); + // 瀹瑰櫒鐮� + 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)){ + log.info("搴撲綅鍙凤細" + locNo + "锛屽鍣ㄧ爜锛�" + containerCode + "锛屼笉瀛樺湪鏄庣粏"); + } + if(agvLocDetls.size()>1){ + log.info("搴撲綅鍙凤細" + locNo + "锛屽鍣ㄧ爜锛�" + containerCode + "锛屽瓨鍦�1鏉′互涓婅褰�"); + } + } + } + + @Override + public void updateLocNo(String locNo, AgvLocDetl agvLocDetl) { + this.baseMapper.updateLocNo(locNo,agvLocDetl.getLocNo(),agvLocDetl.getSuppCode()); + } } -- Gitblit v1.9.1