自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
skyouc
1 天以前 3aed7236f2db67dd90115a39bc8f1465e4cc8b73 
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java


@@ -8,10 +8,7 @@


import com.core.exception.CoolException;


import com.zy.asrs.entity.*;


import com.zy.asrs.entity.param.*;


import com.zy.asrs.entity.result.FindLocNoAttributeVo;


import com.zy.asrs.entity.result.ForwardAGVTaskDTO;


import com.zy.asrs.entity.result.HIKApiDTO;


import com.zy.asrs.entity.result.HIKResultDTO;


import com.zy.asrs.entity.result.*;


import com.zy.asrs.enums.*;


import com.zy.asrs.enums.LocAreaType;


import com.zy.asrs.enums.LocStsType;


@@ -601,6 +598,12 @@




        if (Objects.isNull(param.getBarcode())) {


            throw new CoolException("托盘码不能为空！！");


        }




        BasContainer container = basContainerService


                .selectOne(new EntityWrapper<BasContainer>().eq("barcode", param.getBarcode()));


        if (Objects.isNull(container)) {


            throw new CoolException("数据错误：容器码不存在！！");


        }


        // if (param.getBarcode().length() != 8) {


        // throw new CoolException("条码长度不是8位===>>" + param.getBarcode());


@@ -1607,6 +1610,7 @@


        if (Objects.isNull(param.getBarcode())) {


            throw new CoolException("托盘码不能为空！！");


        }




        if (Objects.isNull(param.getCombMats()) || param.getCombMats().isEmpty()) {


            throw new CoolException("组托明细不能为空！！");


        }


@@ -1618,8 +1622,14 @@




        int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet", param.getBarcode()));


        int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet", param.getBarcode()));


        if (countWrk > 0 || countLoc > 0) {


            WrkMast wrkDetl = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("barcode", param.getBarcode()));


            if (!wrkDetl.getIoType().equals(TaskIOType.MERGE_OUT.type)) {


                throw new CoolException("组托档/工作档/库存条码数据已存在===>>" + param.getBarcode());


            }


        }


        int countwait = waitPakinService.selectCount(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode()));


        if (countLoc > 0 || countWrk > 0 || countwait > 0) {


        if (countwait > 0) {


            throw new CoolException("组托档/工作档/库存条码数据已存在===>>" + param.getBarcode());


        }




@@ -1934,40 +1944,94 @@


        }




        BasDevp sourceStaNo = basDevpService.checkSiteStatus(Integer.parseInt(rela.getCrnSta()), true);




        sourceStaNo.setLocType1(locType);


        LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);


        WaitPakin pakin = waitPakins.stream().findFirst().get();


        FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo(pakin);


        StartupDto dto = commonService.getLocNo(1, sourceStaNo.getDevNo(), findLocNoAttributeVo, locTypeDto);


        int workNo = dto.getWorkNo();


        // 生成工作档




        WrkMast mast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("barcode", pakin.getZpallet()));


        WrkMast wrkMast = new WrkMast();


        wrkMast.setWrkNo(workNo);


        wrkMast.setIoTime(new Date());


        wrkMast.setWrkSts(2L); // 工作状态：生成入库ID


        wrkMast.setIoType(1); // 入出库状态：1.入库


        wrkMast.setIoPri(13D); // 优先级


        wrkMast.setCrnNo(dto.getCrnNo());


        wrkMast.setSourceStaNo(dto.getSourceStaNo() + "");


        wrkMast.setStaNo(dto.getStaNo() + "");


        wrkMast.setLocNo(dto.getLocNo());


        wrkMast.setBarcode(pakin.getZpallet()); // 托盘码


        wrkMast.setFullPlt("Y"); // 满板：Y


        wrkMast.setPicking("N"); // 拣料


        wrkMast.setExitMk("N"); // 退出


        wrkMast.setEmptyMk("N"); // 空板


        wrkMast.setLinkMis("Y");


        wrkMast.setModiUser(userId);


        wrkMast.setAppeUser(userId);


        wrkMast.setCtnType(sourceStaNo.getCtnType()); // 容器类型


        // 操作人员数据


        wrkMast.setAppeTime(now);


        wrkMast.setModiTime(now);


        boolean res = wrkMastService.insert(wrkMast);


        if (!res) {


            throw new CoolException("保存工作档失败");


        if (!Objects.isNull(mast)) {


            if (mast.getIoType().equals(TaskIOType.MERGE_OUT.type) || mast.getIoType().equals(TaskIOType.PICK_OUT.type) || mast.getIoType().equals(TaskIOType.CHECK_OUT.type)) {


                int ioType = mast.getIoType() - 50;


                mast.setIoType(ioType);


                mast.setWrkSts(2L);


                mast.setSourceStaNo(mast.getSourceStaNo());


                mast.setStaNo(mast.getSourceStaNo());


                mast.setLocNo(mast.getSourceLocNo());


                boolean res = wrkMastService.updateById(mast);


                BeanUtils.copyProperties(mast, wrkMast);


                if (!res) {


                    throw new CoolException("保存工作档失败");


                }


                // 更新源站点信息


                sourceStaNo.setWrkNo(mast.getWrkNo());


                sourceStaNo.setModiTime(now);


                if (!basDevpService.updateById(sourceStaNo)) {


                    throw new CoolException("更新源站失败");


                }


                // 更新目标库位状态


                LocMast locMast = locMastService.selectById(mast.getLocNo());


                if (locMast.getLocSts().equals("O")) {


                    locMast.setLocSts("S"); // S.入库预约


                    locMast.setModiTime(now);


                    if (!locMastService.updateById(locMast)) {


                        throw new CoolException("改变库位状态失败");


                    }


                } else {


                    throw new CoolException(mast.getLocNo() + "目标库位已被占用");


                }


            } else {


                throw new CoolException("托盘已存在任务档！！");


            }


        } else {


            StartupDto dto = commonService.getLocNo(1, sourceStaNo.getDevNo(), findLocNoAttributeVo, locTypeDto);


            int workNo = dto.getWorkNo();


            // 生成工作档


            wrkMast.setWrkNo(workNo);


            wrkMast.setIoTime(new Date());


            wrkMast.setWrkSts(2L); // 工作状态：生成入库ID


            wrkMast.setIoType(1); // 入出库状态：1.入库


            wrkMast.setCrnNo(dto.getCrnNo());


            wrkMast.setSourceStaNo(dto.getSourceStaNo() + "");


            wrkMast.setStaNo(dto.getStaNo() + "");


            wrkMast.setLocNo(dto.getLocNo());


            wrkMast.setIoPri(13D); // 优先级


            wrkMast.setBarcode(pakin.getZpallet()); // 托盘码


            wrkMast.setFullPlt("Y"); // 满板：Y


            wrkMast.setPicking("N"); // 拣料


            wrkMast.setExitMk("N"); // 退出


            wrkMast.setEmptyMk("N"); // 空板


            wrkMast.setLinkMis("Y");


            wrkMast.setModiUser(userId);


            wrkMast.setAppeUser(userId);


            wrkMast.setCtnType(sourceStaNo.getCtnType()); // 容器类型


            // 操作人员数据


            wrkMast.setAppeTime(now);


            wrkMast.setModiTime(now);


            boolean res = wrkMastService.insert(wrkMast);


            if (!res) {


                throw new CoolException("保存工作档失败");


            }


            // 更新源站点信息


            sourceStaNo.setWrkNo(workNo);


            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() + "目标库位已被占用");


            }


        }




        // 生成工作档明细


        waitPakins.forEach(waitPakin -> {


            WrkDetl wrkDetl = new WrkDetl();


@@ -1980,6 +2044,9 @@


                throw new CoolException("保存工作明细失败");


            }


        });








//        // 更新入库通知档 ioStatus ===>> Y


//        Wrapper<WaitPakin> wrapper = new EntityWrapper<WaitPakin>()


//                .eq("zpallet", pakin.getZpallet());


@@ -1990,24 +2057,6 @@


//        if (!waitPakinService.update(setParam, wrapper)) {


//            throw new CoolException("更新通知档失败");


//        }


        // 更新源站点信息


        sourceStaNo.setWrkNo(workNo);


        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() + "目标库位已被占用");


        }




    }




    /**


@@ -2073,7 +2122,7 @@


        }


        Collections.shuffle(devps);


        BasDevp basDevp = devps.stream().findFirst().get();


        List<LocMast> locMasts = new ArrayList<>();


        List<CrnTaskDetlDTO> locMasts = new ArrayList<>();


        Map<String, List<LocDetl>> listMap = locDetls.stream().collect(Collectors.groupingBy(LocDetl::getMatnr));


        //获取查库存总数量


        AtomicReference<Double> totalOut = new AtomicReference<>(0.0);


@@ -2113,11 +2162,12 @@


                            }


                            //余下最大可放数量


                            Double v = Math.round((mats.getUpQty() * suplus) * 10000) / 10000.0;


                            // 入库数量小于零且入库数量减去已出数量大于零（）


                            // 入库数量小于零且入库数量减去已计划出数量大于零（）


                            if (sum.compareTo(v) <= 0 && sum.compareTo(itemed.get()) > 0) {


                                itemed.set(Math.round((itemed.get() + v) * 10000) / 10000.0);


                                // 可放下


                                locMasts.add(locMast);


                                CrnTaskDetlDTO crnTaskDetlDTO = new CrnTaskDetlDTO().setLocNo(locMast.getLocNo()).setLocDetlList(adetls);


                                locMasts.add(crnTaskDetlDTO);


                                totalOut.set(Math.round((totalOut.get() + itemed.get()) * 10000) / 10000.0);


                            }


                        }


@@ -2136,9 +2186,10 @@


                    .eq("loc_sts", LocStsType.LOC_STS_TYPE_D.type)


                    .orderAsc(Arrays.asList("row1", "bay1", "lev1"))


                    .last("OFFSET 0 ROWS FETCH NEXT 1 ROWS ONLY"));


            locMasts.add(locMast);


            CrnTaskDetlDTO crnTaskDetlDTO = new CrnTaskDetlDTO().setLocNo(locMast.getLocNo()).setLocDetlList(locDetls);


            locMasts.add(crnTaskDetlDTO);


            // 空板出库


            generateTask(locMasts, TaskIOType.EMPTY_OUT.type, basDevp, userId);


            generateTask(locMasts, TaskIOType.MERGE_OUT.type, basDevp, userId);


        }


    }




@@ -2150,47 +2201,51 @@


     * @date 2025/12/6 14:44


     */


    @Transactional(rollbackFor = Exception.class)


    public void generateTask(List<LocMast> locMasts, Integer ioType, BasDevp devp, Long userId) {


    public void generateTask(List<CrnTaskDetlDTO> locMasts, Integer ioType, BasDevp devp, Long userId) {


        Date now = new Date();


        for (LocMast locMast : locMasts) {




        for (CrnTaskDetlDTO crnTaskDetlDTO : locMasts) {


            LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", crnTaskDetlDTO.getLocNo()));


            if (Objects.isNull(ioType)) {


                continue;


            }


            Integer outSta = devp.getDevNo();


            // 获取路径


            StaDesc staDesc = staDescService.queryCrnStn(ioType, locMast.getCrnNo(), outSta);


            WrkMast wrkMast1 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("source_loc_no", locMast.getLocNo()));


            // 生成工作号


            int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(ioType));


            // 生成工作档


            WrkMast wrkMast = new WrkMast();


            wrkMast.setWrkNo(workNo);


            wrkMast.setIoTime(now);


            wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID


            wrkMast.setIoType(ioType); // 入出库类型


            wrkMast.setIoPri(13D); // 优先级：13


            wrkMast.setCrnNo(locMast.getCrnNo());


            wrkMast.setSourceStaNo(staDesc.getCrnStn() + ""); // 源站


            wrkMast.setStaNo(staDesc.getStnNo() + ""); // 目标站


            wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位


            wrkMast.setFullPlt("Y"); // 满板：Y


            wrkMast.setPicking("N"); // 拣料


            wrkMast.setExitMk("N"); // 退出


            wrkMast.setEmptyMk("N"); // 空板


            wrkMast.setLinkMis("N");


            wrkMast.setBarcode(locMast.getBarcode());


            wrkMast.setAppeUser(userId); // 操作人员数据


            wrkMast.setAppeTime(now);


            wrkMast.setModiUser(userId);


            wrkMast.setModiTime(now);


            if (!wrkMastService.insert(wrkMast)) {


                throw new CoolException("保存工作档失败，出库库位号：" + locMast.getLocNo());


            if (Cools.isEmpty(wrkMast1)){


                Integer outSta = devp.getDevNo();


                // 获取路径


                StaDesc staDesc = staDescService.queryCrnStn(ioType, locMast.getCrnNo(), outSta);




                // 生成工作档


                WrkMast wrkMast = new WrkMast();


                wrkMast.setWrkNo(workNo);


                wrkMast.setIoTime(now);


                wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID


                wrkMast.setIoType(ioType); // 入出库类型


                wrkMast.setIoPri(13D); // 优先级：13


                wrkMast.setCrnNo(locMast.getCrnNo());


                wrkMast.setSourceStaNo(staDesc.getCrnStn() + ""); // 源站


                wrkMast.setStaNo(staDesc.getStnNo() + ""); // 目标站


                wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位


                wrkMast.setFullPlt("Y"); // 满板：Y


                wrkMast.setPicking("N"); // 拣料


                wrkMast.setExitMk("N"); // 退出


                wrkMast.setEmptyMk("N"); // 空板


                wrkMast.setLinkMis("N");


                wrkMast.setBarcode(locMast.getBarcode());


                wrkMast.setAppeUser(userId); // 操作人员数据


                wrkMast.setAppeTime(now);


                wrkMast.setModiUser(userId);


                wrkMast.setModiTime(now);


                if (!wrkMastService.insert(wrkMast)) {


                    throw new CoolException("保存工作档失败，出库库位号：" + locMast.getLocNo());


                }


            }else {


                workNo = wrkMast1.getWrkNo();


            }




            List<LocDetl> locDetls = locDetlService


                    .selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));




            // 生成工作档明细


            for (LocDetl detlDto : locDetls) {


            for (LocDetl detlDto : crnTaskDetlDTO.getLocDetlList()) {


                WrkDetl wrkDetl = new WrkDetl();


                BeanUtils.copyProperties(detlDto, wrkDetl);


                wrkDetl.setOrderNo(""); // 手动出库不需要带出库存中的单据编号