自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
#
野心家
2023-10-10 ba4e5ac7bd44e0d24f480b44a94cfe8d256a86e9 
 src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java


@@ -5,12 +5,14 @@


import com.core.common.Cools;


import com.core.exception.CoolException;


import com.zy.asrs.entity.*;


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


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


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


import com.zy.asrs.service.*;


import com.zy.common.model.LocDto;


import com.zy.common.model.OrderDto;


import com.zy.common.model.StartupDto;


import com.zy.common.model.TaskDto;


import com.zy.common.model.enums.WorkNoType;


import com.zy.common.service.AgvCommonService;


import com.zy.common.web.BaseController;


import lombok.extern.slf4j.Slf4j;


@@ -19,7 +21,9 @@


import org.springframework.transaction.annotation.Transactional;




import java.util.Date;


import java.util.Iterator;


import java.util.List;


import java.util.UUID;




/**


 * Created by vincent on 2020/6/11


@@ -38,7 +42,7 @@


    @Autowired


    private AgvBasDevpService agvBasDevpService;


    @Autowired


    private AgvLocMastService agvLockMastService;


    private AgvLocMastService agvLocMastService;


    @Autowired


    private AgvLocDetlService agvLocDetlService;


    @Autowired


@@ -53,6 +57,8 @@


    private OrderService orderService;


    @Autowired


    private OrderDetlService orderDetlService;


    @Autowired


    private AdjDetlService adjDetlService;






    /*


@@ -72,7 +78,7 @@


                throw new CoolException("选中的站点中含有货位状态不为F.在库的站点，请重新选择");


            }




            List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>().eq("zpallet", agvBasDevp.getBarcode()));


            List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>().eq("supp_code", agvBasDevp.getBarcode()));




            //检索库位，选择合适的库位


            AgvLocMast agvLocMast = agvCommonService.getLocNo(agvWaitPakinList, agvBasDevp.getFloor());


@@ -82,7 +88,7 @@


            //生成工作档明细


            //createWrkDetlReWrite(agvWaitPakinList,wrkMast,userId);


            agvWaitPakinList.forEach(wp -> {


                createWrkDetlReWrite(wp.getMatnr(),wrkMast.getWrkNo(),wp.getOrderNo(),wp.getBatch(),wp.getAnfme(),wp.getZpallet(),now,userId);


                createWrkDetlReWrite(wp.getMatnr(),wrkMast.getWrkNo(),wp.getOrderNo(),wp.getBatch(),wp.getAnfme(),wp.getSuppCode(),now,userId,wp.getThreeCode(),wp.getDeadTime());


            });


            //更新源站点信息


            updateAgvBasDevp(agvBasDevp,"R");


@@ -104,7 +110,7 @@




        agvTaskDtos.forEach(taskDto -> {




            AgvLocMast agvLocMast = agvLockMastService.selectById(taskDto.getLocNo());


            AgvLocMast agvLocMast = agvLocMastService.selectById(taskDto.getLocNo());


            AgvLocDetl agvLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", taskDto.getLocNo()));




            //工作档所需参数


@@ -112,23 +118,26 @@


            long wrkSts = 21L;


            String sourceLocNo = taskDto.getLocNo();


            String targetLocNo = taskDto.getAgvStaNo();


            String barcode = agvLocDetl.getZpallet();


            String barcode = agvLocDetl.getSuppCode();


            //明细档所需参数


            String mantr = taskDto.getLocDtos().get(0).getMatnr();


            String orderNo = taskDto.getLocDtos().get(0).getOrderNo();


            String batch = taskDto.getLocDtos().get(0).getBatch();




            String csocode = agvLocDetl.getThreeCode();


            String isoseq = agvLocDetl.getDeadTime();




            //判断是否全板出库


            int ioType = isPakOut(sourceLocNo,anfme) ?  101 : 103;


            //生成工作档


            AgvWrkMast wrkMast = createWrkMast(ioType,wrkSts,sourceLocNo,targetLocNo,barcode,now,userId);


            //生成工作档明细


            createWrkDetlReWrite(mantr,wrkMast.getWrkNo(),orderNo,batch,anfme,barcode,now,userId);


            createWrkDetlReWrite(mantr,wrkMast.getWrkNo(),orderNo,batch,anfme,barcode,now,userId,csocode,isoseq);


            //修改订单信息


            modifyOrderDetl(taskDto.getLocDtos().get(0), userId);


            //更新源站点信息


            String locSts = ioType == 101 ? "R" : "P";


            updateAgvLocMast(agvLockMastService.selectById(sourceLocNo),locSts);


            updateAgvLocMast(agvLocMastService.selectById(sourceLocNo),locSts);


            //更新目标站点状态


            //locSts = ioType == 101 ? "S" : "Q";


            updateAgvBasDevp(agvBasDevpService.selectById(targetLocNo),"S");


@@ -143,7 +152,11 @@


        agvWrkMastList.forEach(agvWrkMast -> {


            //修改工作党


            agvWrkMast.setWrkSts(201L);


            agvWrkMast.setIoType(53);




            //根据出库类型 设置入库类型 53拣料入库 57盘点入库


            int ioType = agvWrkMast.getIoType() == 103 ? 53 : 57;




            agvWrkMast.setIoType(ioType);


            String locNo = agvWrkMast.getLocNo();


            agvWrkMast.setLocNo(agvWrkMast.getSourceLocNo());


            agvWrkMast.setSourceLocNo(locNo);


@@ -151,23 +164,274 @@


            agvWrkMastService.updateById(agvWrkMast);




            AgvWrkDetl agvWrkDetl = agvWrkDetlService.selectOne(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", agvWrkMast.getWrkNo()));


            AgvLocMast agvLocMast = agvLockMastService.selectById(agvWrkMast.getLocNo());


            AgvLocMast agvLocMast = agvLocMastService.selectById(agvWrkMast.getLocNo());


            AgvLocDetl agvLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no",agvLocMast.getLocNo()));


            AgvBasDevp agvBasDevp = agvBasDevpService.selectById(agvWrkMast.getSourceLocNo());


            //修改工作党明细


            agvWrkDetl.setAnfme(agvLocDetl.getAnfme() - agvWrkDetl.getAnfme());


            agvWrkDetlService.update(agvWrkDetl,new EntityWrapper<AgvWrkDetl>().eq("wrk_no",agvWrkDetl.getWrkNo()));


            //修改库存信息


            agvLocDetl.setAnfme(agvWrkDetl.getAnfme());


            agvLocDetlService.update(agvLocDetl,new EntityWrapper<AgvLocDetl>().eq("loc_no",agvLocDetl.getLocNo()));




            //拣料入库


            if(ioType == 53){


                //修改工作党明细


                agvWrkDetl.setAnfme(agvLocDetl.getAnfme() - agvWrkDetl.getAnfme());


                agvWrkDetlService.update(agvWrkDetl,new EntityWrapper<AgvWrkDetl>().eq("wrk_no",agvWrkDetl.getWrkNo()));


                //修改库存信息


                agvLocDetl.setAnfme(agvWrkDetl.getAnfme());


                agvLocDetlService.update(agvLocDetl,new EntityWrapper<AgvLocDetl>().eq("loc_no",agvLocDetl.getLocNo()));


            }


            //修改库位信息


            agvLocMast.setLocSts("Q");


            agvLockMastService.selectById(agvLocMast);


            updateAgvLocMast(agvLocMast,"Q");


            //修改站点信息


            agvBasDevp.setLocSts("R");


            agvBasDevpService.updateById(agvBasDevp);


            updateAgvBasDevp(agvBasDevp,"R");




        });


    }




    /*


    盘点出库


     */


    @Transactional


    public void locCheckOut(StockOutParam param, Long userId) {


        String station = param.getStation();


        List<AgvBasDevp> agvBasDevpList = agvBasDevpService.selectList(new EntityWrapper<AgvBasDevp>()


                .eq("station_code", station)


                .eq("loc_sts","O"));




        if(param.getLocDetls().size() > agvBasDevpList.size()){


            throw new CoolException("当前站点可用缓存货架数量为" + agvBasDevpList.size() + ",少于需要盘点出库库位数量，请重新选择盘点库位");


        }




        param.getLocDetls().forEach(locDetl -> {


            AgvLocMast agvLocMast = agvLocMastService.selectById(locDetl.getLocNo());


            AgvLocDetl agvLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locDetl.getLocNo()));


            AgvBasDevp agvBasDevp = agvBasDevpService.selectOne(new EntityWrapper<AgvBasDevp>()


                    .eq("station_code", station)


                    .eq("loc_sts","O"));


            Date now = new Date();




            //生成工作党


            AgvWrkMast wrkMast = createWrkMast(107, 21L, locDetl.getLocNo(), agvBasDevp.getDevNo(), agvLocDetl.getSuppCode(), now, userId);


            //生成工作明细档


            createWrkDetlReWrite(locDetl.getMatnr(),wrkMast.getWrkNo(),null,locDetl.getBatch(),locDetl.getCount(),wrkMast.getBarcode(),now,userId,agvLocDetl.getThreeCode(),agvLocDetl.getDeadTime());


            //修改库位信息


            updateAgvLocMast(agvLocMast,"P");


            //修改站点信息


            updateAgvBasDevp(agvBasDevp,"S");




        });




    }




    /*


    库位移转


     */


    @Transactional


    public void locMove(String sourceLocNo, String targetLocNo, Long userId) {


        AgvLocMast sourceLocMast = agvLocMastService.selectById(sourceLocNo);


        AgvLocMast targetLocMast = agvLocMastService.selectById(targetLocNo);


        AgvLocDetl sourceLocDetl = agvLocDetlService.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", sourceLocMast.getLocNo()));




        if(!sourceLocMast.getLocSts().equals("F")){


            throw new CoolException(sourceLocMast.getLocNo() + "源库位出库失败，状态："+sourceLocMast.getLocSts$());


        }


        if(!targetLocMast.getLocSts().equals("O")){


            throw new CoolException("移转失败，目标库位状态："+targetLocMast.getLocSts$());


        }




        Date now = new Date();


        //生成移库工作档


        AgvWrkMast wrkMast = createWrkMast(11, 21L, sourceLocNo, targetLocNo, sourceLocDetl.getSuppCode(), now, userId);


        //生成工作党明细


        createWrkDetlReWrite(sourceLocDetl.getMatnr(),wrkMast.getWrkNo(),null,sourceLocDetl.getBatch(),sourceLocDetl.getAnfme(),sourceLocDetl.getZpallet(),now,userId,sourceLocDetl.getThreeCode(),sourceLocDetl.getDeadTime());


        //修改目标库位状态


        updateAgvLocMast(targetLocMast,"S");


        //修改原库位状态


        updateAgvLocMast(sourceLocMast,"R");


    }




    /*


    空板入库


     */


    @Transactional


    public String emptyPlateIn(String sourceStaion, Long userId) {


        Date now = new Date();


        // 源站点状态检测


        AgvBasDevp agvBasDevp = agvBasDevpService.selectById(sourceStaion);


        if(!agvBasDevp.getLocSts().equals("O")){


            throw new CoolException("当前工作位状态为" + agvBasDevp.getLocSts()+",无法进行空板入库");


        }


        // 检索库位


        AgvLocMast locMast = agvCommonService.getLocNo(null, agvBasDevp.getFloor());


        // 生成工作档 10.空板入库


        createWrkMast(10,201L,agvBasDevp.getDevNo(),locMast.getLocNo(),null,now,userId);


        //更新源站点状态


        updateAgvBasDevp(agvBasDevp,"R");


        //更新目标库位状态


        updateAgvLocMast(locMast,"S");


        return locMast.getLocNo();


    }




    /*


    空板出库


     */


    @Transactional


    public void emptyPlateOut(EmptyPlateOutParam param, Long userId) {


        Date now = new Date();


        //判断所选工作站空余工作位数量是否满足出库数量


        List<AgvBasDevp> agvBasDevpList = agvBasDevpService.selectList(new EntityWrapper<AgvBasDevp>()


                .eq("station_code", param.getStationCode())


                .eq("loc_sts","O"));


        if(agvBasDevpList.size() < param.getLocNos().size()){


            throw new CoolException("当前工作站可出库工作位数量为"+ agvBasDevpList.size() + "，小于要出库的库位数量，请重新选择出库库位");


        }


        param.getLocNos().forEach(locNo -> {


            AgvLocMast agvLocMast = agvLocMastService.selectById(locNo);


            if(!agvLocMast.getLocSts().equals("D")){


                throw new CoolException(agvLocMast.getLocNo() + "库位状态已经不为D.空桶/空栈板，请重新选择库位进行空板出库");


            }


            //检索工作位


            AgvBasDevp agvBasDevp = agvBasDevpService.selectOne(new EntityWrapper<AgvBasDevp>()


                    .eq("station_code", param.getStationCode())


                    .eq("loc_sts", "O"));


            //生成工作档


            createWrkMast(110,21L,locNo,agvBasDevp.getDevNo(),null,now,userId);


            //修改源库位状态


            updateAgvLocMast(agvLocMast,"R");


            //修改目标工作位状态


            updateAgvBasDevp(agvBasDevp,"S");


        });


    }




    @Transactional


    public void adjustLocDetl(LocDetlAdjustParam param, Long userId) {


        param.integrate();


        AgvLocMast locMast = agvLocMastService.selectById(param.getLocNo());


        if (Cools.isEmpty(locMast)) {


            throw new CoolException("库位不存在");


        }


        if (!(locMast.getLocSts().equals("F") || locMast.getLocSts().equals("D") || locMast.getLocSts().equals("O"))) {


            throw new CoolException("当前库位不可调整！库位状态：" + locMast.getLocSts$());


        }




        Date now = new Date();


        List<AgvLocDetl> locDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", param.getLocNo()));




        List<LocDetlAdjustParam.LocDetlAdjust> list = param.getList();




        // 修改数量


        Iterator<AgvLocDetl> iterator = locDetls.iterator();


        while (iterator.hasNext()) {


            AgvLocDetl locDetl = iterator.next();




            Iterator<LocDetlAdjustParam.LocDetlAdjust> iterator1 = list.iterator();


            while (iterator1.hasNext()) {


                LocDetlAdjustParam.LocDetlAdjust adjust = iterator1.next();


                if (adjust.getCount() == 0) { continue; }


                if (locDetl.getMatnr().equals(adjust.getMatnr()) && Cools.eq(locDetl.getBatch(), adjust.getBatch())) {


                    if (!locDetl.getAnfme().equals(adjust.getCount())) {


                        // todo 盘点记录


                        // 修改库存


                        if (!agvLocDetlService.updateAnfme(adjust.getCount(), locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getBatch())) {


                            throw new CoolException(locDetl.getLocNo() + "库位，" + locDetl.getMatnr() + "商品，" + locDetl.getBatch() + "序列码修改数量失败");


                        }


                        // 保存调整记录


                        AdjDetl adjDetl = new AdjDetl();


                        adjDetl.setLocNo(locDetl.getLocNo());


                        adjDetl.setMatnr(locDetl.getMatnr());


                        adjDetl.setBatch(locDetl.getBatch());


                        adjDetl.setOriQty(locDetl.getAnfme());


                        adjDetl.setAdjQty(adjust.getCount());


                        adjDetl.setModiTime(now);


                        adjDetl.setModiUser(userId);


                        adjDetl.setAppeTime(now);


                        adjDetl.setAppeUser(userId);




                        UUID uuid = UUID.randomUUID();


                        adjDetl.setOrderNo(uuid.toString());


                        adjDetl.setCsocode(locDetl.getThreeCode());


                        adjDetl.setIsoseq(locDetl.getDeadTime());




                        adjDetlService.save(adjDetl, userId);


                    }


                    iterator.remove();


                    iterator1.remove();


                }


            }


        }




        // 删除库存


        for (AgvLocDetl locDetl : locDetls) {


            // todo 盘点记录


            if (!agvLocDetlService.updateAnfme(-1.0D, locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getBatch())) {


                throw new CoolException("删除" + locDetl.getLocNo() + "库位，" + locDetl.getMatnr() + "商品，" + locDetl.getBatch() + "序列码库存明细失败");


            }


            // 保存调整记录


            AdjDetl adjDetl = new AdjDetl();


            adjDetl.setLocNo(locDetl.getLocNo());


            adjDetl.setMatnr(locDetl.getMatnr());


            adjDetl.setBatch(locDetl.getBatch());


            adjDetl.setOriQty(locDetl.getAnfme());


            adjDetl.setAdjQty(0.0D);


            adjDetl.setModiTime(now);


            adjDetl.setModiUser(userId);


            adjDetl.setAppeTime(now);


            adjDetl.setAppeUser(userId);




            adjDetlService.save(adjDetl, userId);


        }




        // 添加库存


        for (LocDetlAdjustParam.LocDetlAdjust adjust : list) {


            if (adjust.getCount() == 0.0D) { continue; }


            Mat mat = matService.selectByMatnr(adjust.getMatnr());


            AgvLocDetl locDetl = new AgvLocDetl();


            locDetl.sync(mat);


            locDetl.setBatch(adjust.getBatch());


            locDetl.setLocNo(locMast.getLocNo());


            locDetl.setAnfme(adjust.getCount()); // 数量


            locDetl.setModiUser(userId); // 操作人员信息


            locDetl.setModiTime(now);


            locDetl.setAppeUser(userId);


            locDetl.setAppeTime(now);


            locDetl.setThreeCode(adjust.getThreeCode());


            locDetl.setDeadTime(adjust.getDeadTime());


            if (!agvLocDetlService.insert(locDetl)) {


                throw new CoolException("添加" + locDetl.getLocNo() + "库位，" + locDetl.getMatnr() + "商品，" + locDetl.getBatch() + "序列码库存明细失败");


            }


            // 保存调整记录


            AdjDetl adjDetl = new AdjDetl();


            adjDetl.setLocNo(locMast.getLocNo());


            adjDetl.setMatnr(adjust.getMatnr());


            adjDetl.setBatch(adjust.getBatch());


            adjDetl.setOriQty(0.0D);


            adjDetl.setAdjQty(adjust.getCount());


            adjDetl.setModiTime(now);


            adjDetl.setModiUser(userId);


            adjDetl.setAppeTime(now);


            adjDetl.setAppeUser(userId);




            UUID uuid = UUID.randomUUID();


            adjDetl.setOrderNo(uuid.toString());


            adjDetl.setCsocode(locDetl.getThreeCode());


            adjDetl.setIsoseq(locDetl.getDeadTime());




            adjDetlService.save(adjDetl, userId);


        }


        // 修改库位状态


        int count = agvLocDetlService.selectCount(new EntityWrapper<AgvLocDetl>().eq("loc_no", locMast.getLocNo()));


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


            if (count == 0) {


                locMast.setLocSts("D");


            }


        }


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


            if (count > 0) {


                locMast.setLocSts("F");


            }


        }


        locMast.setModiUser(userId);


        locMast.setModiTime(new Date());


        if (!agvLocMastService.updateById(locMast)) {


            throw new CoolException("更新库位状态失败");


        }


    }




    /*


@@ -175,7 +439,7 @@


     */


    private void updateAgvLocMast(AgvLocMast locMast, String locSts){


        locMast.setLocSts(locSts);


        agvLockMastService.updateById(locMast);


        agvLocMastService.updateById(locMast);


    }




    /*


@@ -189,7 +453,7 @@


    /*


    生成工作档明细


     */


    private void createWrkDetlReWrite(String matnr, int wrkNo, String orderNo,String batch, double anfme, String zpallet, Date now, Long userId){


    private void createWrkDetlReWrite(String matnr, int wrkNo, String orderNo,String batch, double anfme, String zpallet, Date now, Long userId, String csocode, String isoseq){


        Mat mat = matService.selectByMatnr(matnr);


        if (Cools.isEmpty(mat)) {


            throw new CoolException(matnr + "商品维护失败");


@@ -201,11 +465,14 @@


        wrkDetl.setIoTime(now);


        wrkDetl.setBatch(batch);


        wrkDetl.setAnfme(anfme); // 数量


        wrkDetl.setZpallet(zpallet); // 托盘条码


        wrkDetl.setSuppCode(zpallet); // 托盘条码


        wrkDetl.setAppeUser(userId);


        wrkDetl.setAppeTime(now);


        wrkDetl.setModiUser(userId);


        wrkDetl.setModiTime(now);




        wrkDetl.setThreeCode(csocode);


        wrkDetl.setDeadTime(isoseq);


        if (!agvWrkDetlService.insert(wrkDetl)) {


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


        }


@@ -246,8 +513,8 @@


    private AgvWrkMast createWrkMast(int ioType, long wrkSts, String sourceLocNo, String locNo, String barcode,  Date now, Long userId){


        AgvWrkMast wrkMast = new AgvWrkMast();


        //生成工作号


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


        wrkMast.setWrkNo(workNo);


//        int workNo = agvCommonService.getWorkNo(WorkNoType.getWorkNoType(ioType));


//        wrkMast.setWrkNo();


        //工作状态


        wrkMast.setWrkSts(wrkSts);


        //入出库类型


@@ -274,9 +541,16 @@


        wrkMast.setAppeTime(now);


        wrkMast.setModiUser(userId);


        wrkMast.setModiTime(now);


        if (!agvWrkMastService.insert(wrkMast)) {




        if (!agvWrkMastService.insertByIncrease(wrkMast)) {


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


        }




        int i = agvWrkMastService.selectCount(new EntityWrapper<AgvWrkMast>());


        log.info(i + "");






        wrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", locNo).eq("source_loc_no",sourceLocNo));




        return wrkMast;


    }


@@ -288,8 +562,8 @@


    private AgvWrkMast createWrkMast(AgvBasDevp agvBasDevp,AgvLocMast agvLocMast, Date now, Long userId){


        AgvWrkMast wrkMast = new AgvWrkMast();


        //生成工作号


        int workNo = agvCommonService.getWorkNo(0);


        wrkMast.setWrkNo(workNo);


        //int workNo = agvCommonService.getWorkNo(0);


        //wrkMast.setWrkNo(workNo);


        wrkMast.setIoTime(new Date());


        // 工作状态：201.生成入库任务ID


        wrkMast.setWrkSts(201L);