| | |
| | | import com.core.common.R; |
| | | import com.core.exception.CoolException; |
| | | import com.zy.asrs.entity.*; |
| | | import com.zy.asrs.entity.result.FindLocNoAttributeVo; |
| | | import com.zy.asrs.entity.result.StorageResult; |
| | | import com.zy.asrs.service.*; |
| | | import com.zy.common.CodeRes; |
| | |
| | | import com.zy.common.web.param.SearchLocParam; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import javax.servlet.http.HttpServletRequest; |
| | | import java.util.Date; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | |
| | | private LocDetlService locDetlService; |
| | | @Autowired |
| | | private BasCrnpService basCrnpService; |
| | | @PostMapping("/pakin/loc/returnWarehouse") |
| | | @ResponseBody |
| | | public synchronized StorageResult returnWarehouse(@RequestBody(required = false) SearchLocParam param) { |
| | | StorageResult storageResult=new StorageResult(); |
| | | if (Cools.isEmpty(param.getTaskNo())) { |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage("传入工作号为空"); |
| | | return storageResult; |
| | | } |
| | | WrkMast wrkMast =wrkMastService.selectOne(new EntityWrapper<WrkMast>() |
| | | .eq("wrk_no",param.getTaskNo()) |
| | | .in("io_type",103,107)); |
| | | WrkMast wrkMast537 =wrkMastService.selectOne(new EntityWrapper<WrkMast>() |
| | | .eq("wrk_no",param.getTaskNo()) |
| | | .in("io_type",53,57)); |
| | | if (Cools.isEmpty(wrkMast)&&Cools.isEmpty(wrkMast537)){ |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage("没有找到盘点拣料任务---------"+param.getTaskNo()); |
| | | return storageResult; |
| | | } |
| | | |
| | | SearchLocParam searchLocParam = new SearchLocParam(); |
| | | searchLocParam.setBoxNo(Cools.isEmpty(wrkMast)?wrkMast537.getBarcode() : wrkMast.getBarcode()); |
| | | searchLocParam.setWcsIoType(1);//满板 |
| | | searchLocParam.setWcsSourceStaNo(Cools.isEmpty(wrkMast)?wrkMast537.getSourceStaNo() : wrkMast.getStaNo()); |
| | | searchLocParam.setWcsStatus(0); |
| | | return getLocNo(searchLocParam); |
| | | @Value("${led.ip}") |
| | | private String ledIp; |
| | | @Value("${led.port}") |
| | | private String ledPort; |
| | | @Value("${led.url}") |
| | | private String ledUrl; |
| | | @Value("${led.id}") |
| | | private String ledId; |
| | | |
| | | |
| | | @GetMapping("/getLedInfos") |
| | | public R getLedInfos(HttpServletRequest request) { |
| | | // String remoteAddr = request.getRemoteAddr(); |
| | | HashMap<String, String> map = new HashMap<>(); |
| | | map.put("ledIp",ledIp); |
| | | map.put("ledPort",ledPort); |
| | | map.put("ledUrl",ledUrl); |
| | | map.put("ledId",ledId); |
| | | return R.ok(map); |
| | | } |
| | | |
| | | |
| | | @PostMapping("/pakin/loc/v1") |
| | | @ResponseBody |
| | | public synchronized StorageResult getLocNo(@RequestBody(required = false) SearchLocParam param) { |
| | | StorageResult storageResult=new StorageResult(); |
| | | public synchronized R getLocNo(@RequestBody(required = false) SearchLocParam param) { |
| | | log.info("收到WCS入库接口请求====>>入参:{}", param); |
| | | if (Cools.isEmpty(param.getWcsIoType())) { |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage("入出库类型不能为空"); |
| | | return storageResult; |
| | | if (Cools.isEmpty(param.getIoType())) { |
| | | return R.error("入出库类型不能为空"); |
| | | } |
| | | if (Cools.isEmpty(param.getWcsSourceStaNo())) { |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage("源站编号不能为空"); |
| | | return storageResult; |
| | | if (Cools.isEmpty(param.getSourceStaNo())) { |
| | | return R.error("源站编号不能为空"); |
| | | } |
| | | BasDevp basDevp=basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no",param.getWcsSourceStaNo())); |
| | | // |
| | | List<WrkMast> wrkMasts=wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("sta_no",param.getWcsSourceStaNo()).in("wrk_sts",11,12,13)); |
| | | if(!Cools.isEmpty(wrkMasts)){ |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage("有出库任务禁止入库"); |
| | | basDevp.setArea("有出库任务禁止入库"); |
| | | basDevpService.updateById(basDevp); |
| | | return storageResult; |
| | | } |
| | | int ioType = 0; |
| | | List<WaitPakin> waitPakins = null; |
| | | if (param.getWcsIoType() == 1) { |
| | | //拣料和盘点入库 |
| | | WrkMast wrkMast1037 =wrkMastService.selectOne(new EntityWrapper<WrkMast>() |
| | | .eq("barcode", param.getBoxNo()) |
| | | .in("io_type",103,107)); |
| | | WrkMast wrkMast537 =wrkMastService.selectOne(new EntityWrapper<WrkMast>() |
| | | .eq("barcode", param.getBoxNo()) |
| | | .in("io_type",53,57)); |
| | | if (wrkMast537 != null) { |
| | | StorageResult.Results results=new StorageResult.Results(); |
| | | results.setTaskNo(wrkMast537.getWrkNo()); |
| | | results.setShelfUnitId(wrkMast537.getLocNo()+""); |
| | | storageResult.setResults(results); |
| | | return storageResult; |
| | | if (param.getIoType() == 1) { |
| | | if (Cools.isEmpty(param.getBarcode())) { |
| | | return R.error("条码不能为空"); |
| | | } |
| | | if(Cools.isEmpty(wrkMast1037)) { |
| | | if (Cools.isEmpty(param.getBoxNo())) { |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage("条码不能为空"); |
| | | basDevp.setArea("条码不能为空"); |
| | | basDevpService.updateById(basDevp); |
| | | return storageResult; |
| | | waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode())); |
| | | if (Cools.isEmpty(waitPakins)) { |
| | | WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBarcode()); |
| | | if (wrkMast != null && wrkMast.getIoType() == 103) { |
| | | return R.parse(CodeRes.PICK_600); |
| | | } |
| | | waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBoxNo())); |
| | | if (Cools.isEmpty(waitPakins)) { |
| | | WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBoxNo()); |
| | | if (wrkMast != null && wrkMast.getIoType() == 103) { |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage(CodeRes.PICK_600); |
| | | basDevp.setArea(CodeRes.PICK_600); |
| | | basDevpService.updateById(basDevp); |
| | | return storageResult; |
| | | } |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage(CodeRes.NO_COMB_700); |
| | | basDevp.setArea(CodeRes.NO_COMB_700); |
| | | basDevpService.updateById(basDevp); |
| | | return storageResult; |
| | | } |
| | | int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet", param.getBoxNo())); |
| | | int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet", param.getBoxNo())); |
| | | if (countLoc > 0 || countWrk > 0) { |
| | | storageResult.setReturnStatus(1); |
| | | storageResult.setErrorMessage(CodeRes.EXIST_500); |
| | | basDevp.setArea(CodeRes.NO_COMB_700); |
| | | basDevpService.updateById(basDevp); |
| | | return storageResult; |
| | | } |
| | | }else { |
| | | ioType = wrkMast1037.getIoType(); |
| | | return R.parse(CodeRes.NO_COMB_700); |
| | | } |
| | | |
| | | int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet", param.getBarcode())); |
| | | int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet", param.getBarcode())); |
| | | if (countLoc > 0 || countWrk > 0) { |
| | | return R.error(CodeRes.EXIST_500); |
| | | } |
| | | } |
| | | if (Cools.isEmpty(param.getLocType1())) { |
| | | return R.error("高低检测信号不能为空"); |
| | | } |
| | | |
| | | LocTypeDto locTypeDto = new LocTypeDto(); |
| | | locTypeDto.setLocType1(param.getLocType1()); |
| | | |
| | | switch (param.getWcsIoType()) { |
| | | StartupDto dto = null; |
| | | switch (param.getIoType()) { |
| | | case 1://满托盘入库 |
| | | assert waitPakins != null; |
| | | storageResult = startupFullPutStore(param.getWcsSourceStaNo(), param.getBoxNo(), waitPakins,ioType); |
| | | dto = startupFullPutStore(param.getSourceStaNo(), param.getBarcode(), locTypeDto, waitPakins); |
| | | break; |
| | | case 2://空托盘入库 |
| | | storageResult = emptyPlateIn(param.getWcsSourceStaNo(), param.getBoxNo()); |
| | | case 10://空托盘入库 |
| | | dto = emptyPlateIn(param.getSourceStaNo(), param.getBarcode()); |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | log.info("WCS入库接口返参:{},托盘码:{}", storageResult, param.getBoxNo()); |
| | | return storageResult; |
| | | log.info("WCS入库接口返参:{},托盘码:{}", dto, param.getBarcode()); |
| | | return R.ok().add(dto); |
| | | } |
| | | |
| | | @PostMapping("/pakin/loc/returnWarehouse") |
| | | @ResponseBody |
| | | public synchronized R returnWarehouse(@RequestBody(required = false) SearchLocParam param) { |
| | | log.info("收到WCS拣选盘点入库接口请求====>>入参:{}", param); |
| | | if (Cools.isEmpty(param.getSourceStaNo())) { |
| | | return R.error("源站编号不能为空"); |
| | | } |
| | | LocTypeDto locTypeDto = new LocTypeDto(); |
| | | locTypeDto.setLocType1(param.getLocType1()); |
| | | |
| | | StartupDto dto = startupPickIn(param.getSourceStaNo(), param.getBarcode(), locTypeDto);; |
| | | log.info("WCS拣选盘点入库接口返参:{},托盘码:{}", dto, param.getBarcode()); |
| | | return R.ok().add(dto); |
| | | } |
| | | |
| | | /** |
| | | * 全板入库 |
| | | */ |
| | | @Transactional |
| | | public StorageResult startupFullPutStore(Integer devpNo, String barcode, List<WaitPakin> waitPakins,Integer ioType) { |
| | | BasDevp basDevp=basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no",devpNo)); |
| | | public StartupDto startupFullPutStore(Integer devpNo, String barcode, LocTypeDto locTypeDto, List<WaitPakin> waitPakins) { |
| | | // 源站点状态检测 |
| | | BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true); |
| | | // 检索库位 |
| | | // List<String> matnrs = waitPakins.stream().map(WaitPakin::getMatnr).distinct().collect(Collectors.toList()); |
| | | // List<String> batchs = waitPakins.stream().map(WaitPakin::getBatch).distinct().collect(Collectors.toList()); |
| | | WaitPakin waitPakin1 = waitPakins.get(0); |
| | | FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo(); |
| | | findLocNoAttributeVo.setMatnr(waitPakin1.getMatnr()); |
| | | |
| | | StorageResult storageResult=new StorageResult(); |
| | | Integer[] arr=arr(); |
| | | LocMast locMast1=new LocMast(); |
| | | Integer workNo = 0; |
| | | //判断是否是拣料或者是盘点 |
| | | if(ioType==103||ioType==107) { |
| | | WrkDetl wrkDetl=wrkDetlService.selectOne(new EntityWrapper<WrkDetl>().eq("zpallet", barcode)); |
| | | |
| | | int type=Cools.isEmpty(wrkDetl.getBeBatch())?1:wrkDetl.getBeBatch(); |
| | | // 检索库位 |
| | | WaitPakin waitPakin1=new WaitPakin(); |
| | | waitPakin1.sync(wrkDetl); |
| | | locMast1 =commonService.getLocNo2(waitPakin1,arr,0,type,1); |
| | | if (locMast1 == null) { |
| | | basDevp.setArea("未找到空库位"); |
| | | basDevpService.updateById(basDevp); |
| | | throw new CoolException("未找到空库位"); |
| | | StartupDto dto = commonService.getLocNo(1, devpNo, findLocNoAttributeVo, locTypeDto, barcode); |
| | | if (dto == null) { |
| | | throw new CoolException("找不到空库位"); |
| | | } |
| | | int workNo = dto.getWorkNo(); |
| | | Date now = new Date(); |
| | | // 生成工作档 |
| | | WrkMast wrkMast = new WrkMast(); |
| | | wrkMast.setWrkNo(workNo); |
| | | wrkMast.setIoTime(new Date()); |
| | | wrkMast.setWrkSts(2L); // 工作状态:生成入库ID |
| | | wrkMast.setIoType(1); // 入出库状态:1.入库 |
| | | wrkMast.setIoPri(30D); // 优先级 |
| | | wrkMast.setCrnNo(dto.getCrnNo()); |
| | | wrkMast.setSourceStaNo(dto.getSourceStaNo()); |
| | | wrkMast.setStaNo(dto.getStaNo()); |
| | | wrkMast.setLocNo(dto.getLocNo()); |
| | | wrkMast.setBarcode(barcode); // 托盘码 |
| | | wrkMast.setFullPlt("Y"); // 满板:Y |
| | | wrkMast.setPicking("N"); // 拣料 |
| | | wrkMast.setExitMk("N"); // 退出 |
| | | wrkMast.setEmptyMk("N"); // 空板 |
| | | wrkMast.setLinkMis("Y"); |
| | | wrkMast.setCtnType(sourceStaNo.getCtnType()); // 容器类型 |
| | | // 操作人员数据 |
| | | wrkMast.setAppeTime(now); |
| | | wrkMast.setModiTime(now); |
| | | wrkMast.setModiUser(waitPakin1.getModiUser()); |
| | | wrkMast.setAppeUser(waitPakin1.getAppeUser()); |
| | | boolean res = wrkMastService.insert(wrkMast); |
| | | if (!res) { |
| | | throw new CoolException("保存工作档失败"); |
| | | } |
| | | // 生成工作档明细 |
| | | waitPakins.forEach(waitPakin -> { |
| | | WrkDetl wrkDetl = new WrkDetl(); |
| | | wrkDetl.sync(waitPakin); |
| | | wrkDetl.setWrkNo(wrkMast.getWrkNo()); |
| | | wrkDetl.setIoTime(wrkMast.getIoTime()); |
| | | wrkDetl.setAppeTime(now); |
| | | wrkDetl.setModiTime(now); |
| | | if (!wrkDetlService.insert(wrkDetl)) { |
| | | throw new CoolException("保存工作明细失败"); |
| | | } |
| | | |
| | | //更新货物所在库位的深浅号 |
| | | wrkDetl.setSource(locMast1.getLocAttribute()); |
| | | wrkDetlService.update(wrkDetl,new EntityWrapper<WrkDetl>().eq("wrk_no", wrkDetl.getWrkNo())); |
| | | WrkMast wrkMast=wrkMastService.selectByBarcode(barcode); |
| | | workNo = wrkMast.getWrkNo(); |
| | | int mbz=basDevp.getDevNo()*10+Integer.valueOf(wrkMast.getSourceLocNo().substring(6)); |
| | | String ykw=wrkMast.getLocNo(); |
| | | wrkMast.setIoType(ioType-50); |
| | | wrkMast.setWrkSts(1L);//入库 |
| | | wrkMast.setModiTime(new Date()); |
| | | wrkMast.setSourceStaNo(basDevp.getDevNo()); // 源站 |
| | | wrkMast.setStaNo(mbz); // 目标站 |
| | | wrkMast.setLocNo(locMast1.getLocNo()); // 目标库位 = 出库时的源库位 |
| | | wrkMast.setSourceLocNo(ykw); // 源库位 |
| | | |
| | | wrkMastService.updateById(wrkMast); |
| | | }else{ |
| | | int type=Cools.isEmpty(waitPakins.get(0).getBeBatch())?1:waitPakins.get(0).getBeBatch(); |
| | | // 检索库位 |
| | | locMast1 =commonService.getLocNo2(waitPakins.get(0),arr,0,type,1); |
| | | if (locMast1 == null) { |
| | | basDevp.setArea("未找到空库位"); |
| | | basDevpService.updateById(basDevp); |
| | | throw new CoolException("未找到空库位"); |
| | | } |
| | | |
| | | int mbz=devpNo*10+Integer.valueOf(locMast1.getLocNo().substring(6)); |
| | | //正常入库 |
| | | workNo = commonService.getWorkNo(0); |
| | | Date now = new Date(); |
| | | // 生成工作档 |
| | | WrkMast wrkMast = new WrkMast(); |
| | | wrkMast.setWrkNo(workNo); |
| | | wrkMast.setIoTime(new Date()); |
| | | wrkMast.setWrkSts(2L); // 工作状态:生成入库ID |
| | | wrkMast.setIoType(1); // 入出库状态:1.入库 |
| | | wrkMast.setIoPri(13D); // 优先级 |
| | | wrkMast.setSourceStaNo(devpNo); |
| | | wrkMast.setStaNo(mbz); |
| | | wrkMast.setLocNo(locMast1.getLocNo()); |
| | | wrkMast.setBarcode(barcode); // 托盘码 |
| | | wrkMast.setFullPlt("Y"); // 满板:Y |
| | | wrkMast.setPicking("N"); // 拣料 |
| | | wrkMast.setExitMk("N"); // 退出 |
| | | wrkMast.setEmptyMk("N"); // 空板 |
| | | wrkMast.setLinkMis("Y"); |
| | | wrkMast.setCtnType(1); // 容器类型 |
| | | // 操作人员数据 |
| | | wrkMast.setAppeTime(now); |
| | | wrkMast.setModiTime(now); |
| | | boolean res = wrkMastService.insert(wrkMast); |
| | | if (!res) { |
| | | basDevp.setArea("保存工作档失败"); |
| | | basDevpService.updateById(basDevp); |
| | | throw new CoolException("保存工作档失败"); |
| | | } |
| | | // 生成工作档明细 |
| | | int source = locMast1.getLocAttribute(); |
| | | waitPakins.forEach(waitPakin -> { |
| | | WrkDetl wrkDetl = new WrkDetl(); |
| | | wrkDetl.sync(waitPakin); |
| | | wrkDetl.setWrkNo(wrkMast.getWrkNo()); |
| | | wrkDetl.setIoTime(wrkMast.getIoTime()); |
| | | wrkDetl.setAppeTime(now); |
| | | wrkDetl.setModiTime(now); |
| | | wrkDetl.setSource(source); |
| | | if (!wrkDetlService.insert(wrkDetl)) { |
| | | basDevp.setArea("保存工作明细失败"); |
| | | basDevpService.updateById(basDevp); |
| | | throw new CoolException("保存工作明细失败"); |
| | | } |
| | | }); |
| | | // 更新入库通知档 ioStatus ===>> Y |
| | | Wrapper<WaitPakin> wrapper = new EntityWrapper<WaitPakin>() |
| | | .eq("zpallet", barcode); |
| | | WaitPakin setParam = new WaitPakin(); |
| | | setParam.setLocNo(locMast1.getLocNo()); |
| | | setParam.setIoStatus("Y"); |
| | | setParam.setModiTime(now); |
| | | if (!waitPakinService.update(setParam, wrapper)) { |
| | | basDevp.setArea("更新通知档失败"); |
| | | basDevpService.updateById(basDevp); |
| | | throw new CoolException("更新通知档失败"); |
| | | } |
| | | }); |
| | | // 更新入库通知档 ioStatus ===>> Y |
| | | if (!waitPakinService.updateIoStatus("Y", dto.getLocNo(), barcode)) { |
| | | throw new CoolException("更新通知档失败"); |
| | | } |
| | | // 更新源站点信息 |
| | | sourceStaNo.setWrkNo(workNo); |
| | | sourceStaNo.setModiTime(now); |
| | | if (!basDevpService.updateById(sourceStaNo)) { |
| | | throw new CoolException("更新源站失败"); |
| | | } |
| | | // 更新目标库位状态 |
| | | LocMast locMast = locMastService.selectById(locMast1.getLocNo()); |
| | | if (locMast.getLocSts().equals("O")){ |
| | | LocMast locMast = locMastService.selectById(dto.getLocNo()); |
| | | if (locMast.getLocSts().equals("O")) { |
| | | locMast.setLocSts("S"); // S.入库预约 |
| | | locMast.setModiTime(new Date()); |
| | | if (!locMastService.updateById(locMast)){ |
| | | basDevp.setArea("改变库位状态失败"); |
| | | basDevpService.updateById(basDevp); |
| | | locMast.setModiTime(now); |
| | | if (!locMastService.updateById(locMast)) { |
| | | throw new CoolException("改变库位状态失败"); |
| | | } |
| | | } else { |
| | | basDevp.setArea(locMast1.getLocNo()+"目标库位已被占用"); |
| | | basDevpService.updateById(basDevp); |
| | | throw new CoolException(locMast1.getLocNo()+"目标库位已被占用"); |
| | | throw new CoolException(dto.getLocNo() + "目标库位已被占用"); |
| | | } |
| | | return dto; |
| | | } |
| | | |
| | | /** |
| | | * 拣选入库 |
| | | */ |
| | | @Transactional |
| | | public StartupDto startupPickIn(Integer devpNo, String barcode, LocTypeDto locTypeDto) { |
| | | // 源站点状态检测 |
| | | BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true); |
| | | |
| | | WrkMast wrkMastOut = wrkMastService.selectByBarcode(barcode); |
| | | if (wrkMastOut == null) { |
| | | throw new CoolException("拣选盘点任务不存在"); |
| | | } |
| | | |
| | | StorageResult.Results results=new StorageResult.Results(); |
| | | results.setTaskNo(workNo); |
| | | results.setShelfUnitId(locMast1.getLocNo()); |
| | | results.setBarcode(barcode); |
| | | storageResult.setResults(results); |
| | | return storageResult; |
| | | if (wrkMastOut.getIoType() != 103 || wrkMastOut.getIoType() != 107) { |
| | | throw new CoolException("任务类型不属于拣选、盘点"); |
| | | } |
| | | |
| | | List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMastOut.getWrkNo()); |
| | | if (wrkDetls.isEmpty()) { |
| | | throw new CoolException("拣选盘点任务数据不存在"); |
| | | } |
| | | |
| | | FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo(); |
| | | findLocNoAttributeVo.setMatnr(wrkDetls.get(0).getMatnr()); |
| | | |
| | | StartupDto dto = commonService.getLocNo(1, devpNo, findLocNoAttributeVo, locTypeDto, barcode); |
| | | if (dto == null) { |
| | | throw new CoolException("找不到空库位"); |
| | | } |
| | | |
| | | Date now = new Date(); |
| | | |
| | | // 生成工作档 |
| | | WrkMast wrkMast = new WrkMast(); |
| | | int workNo = dto.getWorkNo(); |
| | | wrkMast.setWrkNo(workNo); |
| | | wrkMast.setWrkSts(2L); // 工作状态:生成入库ID |
| | | wrkMast.setIoType(wrkMastOut.getIoType() - 50); // 入出库状态:53.拣料再入库 |
| | | wrkMast.setIoPri(30D); // 优先级 |
| | | wrkMast.setCrnNo(dto.getCrnNo()); |
| | | wrkMast.setSourceStaNo(dto.getSourceStaNo()); |
| | | wrkMast.setStaNo(dto.getStaNo()); |
| | | wrkMast.setLocNo(dto.getLocNo()); |
| | | wrkMast.setBarcode(barcode); // 托盘码 |
| | | wrkMast.setFullPlt("Y"); // 满板:Y |
| | | wrkMast.setPicking("N"); // 拣料 |
| | | wrkMast.setExitMk("N"); // 退出 |
| | | wrkMast.setEmptyMk("N"); // 空板 |
| | | wrkMast.setLinkMis("Y"); |
| | | wrkMast.setCtnType(sourceStaNo.getCtnType()); // 容器类型 |
| | | // 操作人员数据 |
| | | wrkMast.setAppeTime(now); |
| | | wrkMast.setModiTime(now); |
| | | boolean res = wrkMastService.insert(wrkMast); |
| | | if (!res) { |
| | | throw new CoolException("保存工作档失败"); |
| | | } |
| | | |
| | | wrkDetlService.updateWorkNo(wrkMastOut.getWrkNo(), workNo); |
| | | |
| | | // 删除工作主档 |
| | | if (!wrkMastService.deleteById(wrkMastOut)) { |
| | | throw new CoolException("删除工作主档失败,workNo=" + wrkMastOut.getWrkNo()); |
| | | } |
| | | |
| | | // 更新源站点信息 |
| | | sourceStaNo.setWrkNo(wrkMast.getWrkNo()); |
| | | sourceStaNo.setModiTime(now); |
| | | if (!basDevpService.updateById(sourceStaNo)) { |
| | | throw new CoolException("更新源站失败"); |
| | | } |
| | | // 更新目标库位状态 |
| | | LocMast locMast = locMastService.selectById(dto.getLocNo()); |
| | | if (locMast.getLocSts().equals("O")) { |
| | | locMast.setLocSts("S"); // S.入库预约 |
| | | locMast.setModiTime(now); |
| | | if (!locMastService.updateById(locMast)) { |
| | | throw new CoolException("改变库位状态失败"); |
| | | } |
| | | } else { |
| | | throw new CoolException(dto.getLocNo() + "目标库位已被占用"); |
| | | } |
| | | return dto; |
| | | } |
| | | |
| | | @Transactional |
| | | public StorageResult emptyPlateIn(Integer devpNo, String barcode) { |
| | | StorageResult storageResult=new StorageResult(); |
| | | public StartupDto emptyPlateIn(Integer devpNo, String barcode) { |
| | | // 检索库位 |
| | | Integer[] arr=arr(); |
| | | |
| | | FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo(); |
| | | LocTypeDto locTypeDto = new LocTypeDto(); |
| | | |
| | | // 检索库位 |
| | | LocMast locMast1 =commonService.getLocNo2(null,arr,0,1,2); |
| | | StartupDto dto = commonService.getLocNo(1, devpNo, findLocNoAttributeVo, locTypeDto, barcode); |
| | | |
| | | String locNo = dto.getLocNo(); |
| | | |
| | | int workNo = commonService.getWorkNo(0); |
| | | // 生成工作档 |
| | | WrkMast wrkMast = new WrkMast(); |
| | |
| | | wrkMast.setIoType(10); // 入出库状态:10.空板入库 |
| | | wrkMast.setIoPri(13D); // 优先级 |
| | | wrkMast.setSourceStaNo(devpNo); |
| | | wrkMast.setLocNo(locMast1.getLocNo()); |
| | | wrkMast.setLocNo(locNo); |
| | | wrkMast.setFullPlt("N"); // 满板 |
| | | wrkMast.setPicking("N"); // 拣料 |
| | | wrkMast.setExitMk("N"); // 退出 |
| | |
| | | throw new CoolException("保存工作档失败"); |
| | | } |
| | | // 更新目标库位状态 |
| | | LocMast locMast = locMastService.selectById(locMast1.getLocNo()); |
| | | LocMast locMast = locMastService.selectById(locNo); |
| | | if (locMast.getLocSts().equals("O")){ |
| | | locMast.setLocSts("S"); // S.入库预约 |
| | | locMast.setModiTime(new Date()); |
| | |
| | | throw new CoolException("改变库位状态失败"); |
| | | } |
| | | } else { |
| | | throw new CoolException(locMast1.getLocNo()+"目标库位已被占用"); |
| | | throw new CoolException(locNo + "目标库位已被占用"); |
| | | } |
| | | StorageResult.Results results=new StorageResult.Results(); |
| | | results.setTaskNo(workNo); |
| | | results.setShelfUnitId(locMast1.getLocNo()); |
| | | storageResult.setResults(results); |
| | | return storageResult; |
| | | return dto; |
| | | } |
| | | |
| | | @Transactional |