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


@@ -6,13 +6,13 @@


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;


@@ -21,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


@@ -55,6 +57,8 @@


    private OrderService orderService;


    @Autowired


    private OrderDetlService orderDetlService;


    @Autowired


    private AdjDetlService adjDetlService;






    /*


@@ -74,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());


@@ -84,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");


@@ -114,18 +118,21 @@


            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);


            //更新源站点信息


@@ -201,9 +208,9 @@


            Date now = new Date();




            //生成工作党


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


            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);


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


            //修改库位信息


            updateAgvLocMast(agvLocMast,"P");


            //修改站点信息


@@ -231,9 +238,9 @@




        Date now = new Date();


        //生成移库工作档


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


        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);


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


        //修改目标库位状态


        updateAgvLocMast(targetLocMast,"S");


        //修改原库位状态


@@ -293,6 +300,140 @@


        });


    }




    @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("更新库位状态失败");


        }


    }




    /*


    更新目标库位信息


     */


@@ -312,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 + "商品维护失败");


@@ -324,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("保存工作明细失败");


        }


@@ -369,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);


        //入出库类型


@@ -397,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;


    }


@@ -411,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);