From 0f3c5510248031f83d37613b06440faec1e58296 Mon Sep 17 00:00:00 2001 From: zyx <zyx123456> Date: 星期一, 13 十一月 2023 14:39:33 +0800 Subject: [PATCH] bug修复 --- src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java | 85 ++++++++++++++++++++++++++++++++++++++---- 1 files changed, 76 insertions(+), 9 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 597f97d..971d784 100644 --- a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java @@ -13,7 +13,10 @@ 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.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -23,6 +26,7 @@ import java.util.stream.Collectors; @Service +@Slf4j public class AgvLocDetlServiceImpl extends ServiceImpl<AgvLocDetlMapper, AgvLocDetl> implements AgvLocDetlService { @Autowired @@ -34,8 +38,9 @@ public void addLocDetlInfo(String locNo, int taskCode) { List<AgvWrkDetl> agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", taskCode)); - List<AgvLocDetl> agvLocDetlList = agvWrkDetls.stream().map(agvWrkDetl -> { + agvWrkDetls.stream().map(agvWrkDetl -> { AgvLocDetl agvLocDetl = new AgvLocDetl(); + log.info("agvWrkDetl: " + agvLocDetl.getBarcode()); BeanUtils.copyProperties(agvWrkDetl, agvLocDetl); agvLocDetl.setLocNo(locNo); this.insert(agvLocDetl); @@ -44,14 +49,14 @@ } - public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued) { + public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued, String csocode, String isoseq) { //鏍规嵁鐗╂枡鍙峰拰鎵规鎵惧埌瀵瑰簲鐨勫簱瀛橈紝骞朵笖鎸夌収淇敼鏃堕棿鎺掑簭 Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).orderBy("modi_time"); - if(Cools.isEmpty(batch)){ - wrapper.isNull("batch"); - }else { - wrapper.eq("batch",batch); - } + + wapperSetCondition(wrapper,"batch",batch); + wapperSetCondition(wrapper,"three_code",csocode); + wapperSetCondition(wrapper,"dead_time",isoseq); + List<AgvLocDetl> agvLocDetls = this.selectList(wrapper); for (AgvLocDetl agvLocDetl: agvLocDetls) { @@ -67,7 +72,9 @@ //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); - + locDto.setCsocode(csocode); + locDto.setIsoseq(isoseq); + locDto.setContainerCode(agvLocDetl.getSuppCode()); //褰撳墠搴撲綅鎵�澶勬ゼ灞� int floor = Integer.parseInt(agvLocDetl.getLocNo().split("@")[1]); locDto.setAgvStaNos(queryAgvStaNosByFloor(floor)); @@ -89,7 +96,7 @@ } public Page<AgvLocDetl> getStockStatis(Page<AgvLocDetl> page) { - page.setRecords(baseMapper.getStockStatis(page.getCondition())); + page.setRecords(baseMapper.getStockStatis1(page.getCondition())); page.setTotal(baseMapper.getStockStatisCount(page.getCondition())); return page; } @@ -128,6 +135,21 @@ return this.selectList(wrapper); } + public boolean updateAnfme(Double anfme, String locNo, String matnr, String batch, String csocode, String isocode) { + EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>(); + Utils.confirmOnlyMat(wrapper,matnr,batch,csocode,isocode); + wrapper.eq("loc_no", locNo); + if (anfme <= 0) { + return this.baseMapper.deleteLocDetl(locNo,anfme,matnr,batch,csocode,isocode) > 0; + } else { + AgvLocDetl agvLocDetl = this.selectOne(wrapper); + agvLocDetl.setAnfme(anfme); + //return this.update(agvLocDetl,wrapper); + //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){ @@ -141,4 +163,49 @@ 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); + } + } + + 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()); + //AgvLocDetl agvLocDetl = this.selectLocdetl(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 AgvLocDetl selectLocdetl(String locNo, String matnr, String batch, String csocode, String isocode) { + return this.baseMapper.selectLocdetl(locNo,matnr,batch,csocode,isocode); + } + + } -- Gitblit v1.9.1