自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhangchao
2024-11-04 59f80df1e377e8775969ca4acadfa2eadd6e37ae 
 src/main/java/com/zy/asrs/controller/AgvMobileController.java


@@ -5,13 +5,17 @@


import com.core.annotations.ManagerAuth;


import com.core.common.Cools;


import com.core.common.R;


import com.core.common.SnowflakeIdWorker;


import com.core.exception.CoolException;


import com.zy.asrs.entity.*;


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


import com.zy.asrs.service.*;


import com.zy.asrs.service.impl.OrderServiceImpl;


import com.zy.common.web.BaseController;


import io.swagger.models.auth.In;


import lombok.Synchronized;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.bind.annotation.*;


@@ -28,7 +32,7 @@


public class AgvMobileController extends BaseController  {








    private static final Logger log = LoggerFactory.getLogger(AgvMobileController.class);


    @Autowired


    private AgvMobileService agvMobileService;


    @Autowired


@@ -45,6 +49,12 @@


    private AgvWrkMastService agvWrkMastService;


    @Autowired


    private AgvWrkDetlService agvWrkDetlService;


    @Autowired


    private SnowflakeIdWorker snowflakeIdWorker;


    @Autowired


    private FlowLogService flowLogService;


    @Autowired


    private OrderServiceImpl orderService;






    /*


@@ -115,7 +125,7 @@


    }




    /*


    启动入库，组托 + 生产工作档


    启动入库，组托 + 生成工作档


    */


    @PostMapping("/start/pakin/auth")


    @Synchronized


@@ -187,7 +197,54 @@


        String matnr = params.get("matnr");


        String floor = params.get("floor");




        Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr);


        Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).ne("process_sts",1);






//        wrapper.eq("orderNo",orderNo);




        wrapper = Cools.isEmpty(threeCode) ? wrapper.isNull("three_code") : wrapper.eq("three_code",threeCode);




        if (threeCode.substring(0,2).equals(30)) {


            wrapper.isNull("specs").or().eq("specs","").eq("floor",1);


        }


        List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(wrapper);


        List<AgvLocDetl> locDetls = new ArrayList<>();


        for (AgvLocDetl agvLocDetl : agvLocDetls) {


            AgvLocMast agvLocMast = new AgvLocMast();


            if (Cools.isEmpty(floor)) {


                agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvLocDetl.getLocNo()).notLike("loc_no","F1"));


            } else {


                // 如果是加工单 只在 lev1 = 1 查库存


                if ("JG".equals(orderNo.substring(0,2))) {


                    agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("lev1",1).eq("loc_no", agvLocDetl.getLocNo()).like("loc_no",floor));


                } else {


                    agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvLocDetl.getLocNo()).like("loc_no",floor));


                }


            }




            if (Cools.isEmpty(agvLocMast)) continue;


            agvLocDetl.setLocSts(agvLocMast.getLocSts());


            agvLocDetl.setLocSts$(agvLocMast.getLocSts$());


            locDetls.add(agvLocDetl);


        }






        return R.ok(locDetls);


    }




    /*


    查询库存 入库订单与销售单号


     */


    @PostMapping("/query/locDetl/v3")


    public R queryAgvLocDetl3(@RequestBody HashMap<String,String> params){




        String orderNo = params.get("orderNo");


        String threeCode = params.get("threeCode");


        String matnr = params.get("matnr");


        String floor = params.get("floor");




        Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).ne("process_sts",1);






//        wrapper.eq("orderNo",orderNo);




@@ -204,6 +261,53 @@


                agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvLocDetl.getLocNo()).notLike("loc_no","F1"));


            } else {


                agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvLocDetl.getLocNo()).like("loc_no",floor));


            }




            if (Cools.isEmpty(agvLocMast)) continue;


            agvLocDetl.setLocSts(agvLocMast.getLocSts());


            agvLocDetl.setLocSts$(agvLocMast.getLocSts$());


            locDetls.add(agvLocDetl);


        }






        return R.ok(locDetls);


    }




    /*


    查询库存 入库订单与销售单号


     */


    @PostMapping("/query/locDetl/v2")


    public R queryAgvLocDetl2(@RequestBody HashMap<String,String> params){




        String orderNo = params.get("orderNo");


        String threeCode = params.get("threeCode");


        String matnr = params.get("matnr");


        String floor = params.get("floor");




        OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", orderNo).eq("three_code", threeCode).eq("matnr", matnr));


        Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr);






//        wrapper.eq("orderNo",orderNo);




        wrapper = Cools.isEmpty(threeCode) ? wrapper.isNull("three_code") : wrapper.eq("three_code",threeCode);




        if (threeCode.substring(0,2).equals(30)) {


            wrapper.isNull("specs").or().eq("specs","").eq("floor",1);


        }


        List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(wrapper);


        List<AgvLocDetl> locDetls = new ArrayList<>();


        for (AgvLocDetl agvLocDetl : agvLocDetls) {


            AgvLocMast agvLocMast = new AgvLocMast();


            if (Cools.isEmpty(floor)) {


                agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvLocDetl.getLocNo()).notLike("loc_no","F1"));


            } else {


                // 如果是加工单 只在 lev1 = 1 查库存


                if (orderDetl.getSource().equals(35)) {


                    agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("lev1",1).eq("loc_no", agvLocDetl.getLocNo()).like("loc_no",floor));


                } else {


                    agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvLocDetl.getLocNo()).like("loc_no",floor));


                }


            }




            if (Cools.isEmpty(agvLocMast)) continue;


@@ -277,9 +381,7 @@








        if((!Cools.eq("F",agvLocMastByContainerCode.getLocSts())


                && !Cools.eq("D",agvLocMastByContainerCode.getLocSts()))


                || (!Cools.eq("F",agvLocMastByLocNo.getLocSts())


        if((!Cools.eq("F",agvLocMastByLocNo.getLocSts())


                && !Cools.eq("D",agvLocMastByLocNo.getLocSts()))){




            return R.error("库位状态不为F或者D，无法维护");


@@ -304,6 +406,9 @@


                agvLocMastByContainerCode.setBarcode(barcode1);


                agvLocMastService.updateById(agvLocMastByContainerCode);


            }


            // 保存调整记录


            AdjDetl adjDetl = new AdjDetl();






            return R.ok("维护成功");


        }


@@ -332,7 +437,13 @@


        }




        if((listByLocNo == null && listByContainerCode == null) || listByLocNo.equals(listByContainerCode)){


            return R.ok("该库位与货架库存一致，无需维护");


            //agvLocMastByContainerCode.setBarcode(agvLocMastByLocNo.getBarcode());


            //agvLocMastService.updateById(agvLocMastByContainerCode);




            agvLocMastByLocNo.setBarcode(containerCode);


            agvLocMastService.updateById(agvLocMastByLocNo);


            //return R.ok("该库位与货架库存一致，无需维护");


            return R.ok("维护成功");


        }






@@ -418,11 +529,17 @@


        List<HashMap<String,String>> dbList = (List<HashMap<String, String>>) params.get("dbList");


        params.get("dbList");


        Object mT = params.get("moveType");


        String orderNo = params.get("orderNo").toString();


        String moveType = "";


        Integer ioType = 0;


        if (mT.equals("unAuto")) {


            moveType = "2";


            ioType = 111;


            //int count = agvWrkMastService.selectCount(new EntityWrapper<AgvWrkMast>().eq("io_type", ioType));


            //if (count>3){


            //    log.equals("111任务堵塞，稍后再试！！！当前限制数量3条，限制条件：io_type = 111");


            //    throw new CoolException("111任务堵塞，稍后再试！");


            //}


        } else {


            moveType = "1";


            ioType = 108;


@@ -440,6 +557,97 @@


            }


            AgvWrkMast wrkMast = createWrkMast(ioType, 22L, locNo, "", barcode, now, getUserId(), 30,floor);


            // 同步调拨单


            long flowId = snowflakeIdWorker.nextId();


            List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo));


            for (AgvLocDetl agvLocDetl : agvLocDetls) {


                AgvWrkDetl wrkDetl = new AgvWrkDetl();


                wrkDetl.setWrkNo(wrkMast.getWrkNo());


                wrkDetl.sync(agvLocDetl);


                wrkDetl.setSuppCode(agvLocDetl.getSuppCode());


                wrkDetl.setModel(orderNo);


                wrkDetl.setIoTime(now);


                wrkDetl.setAppeUser(getUserId());


                wrkDetl.setAppeTime(now);


                wrkDetl.setModiUser(getUserId());


                wrkDetl.setModiTime(now);


                if (!agvWrkDetlService.insert(wrkDetl)) {


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


                }


                // 更新订单


                OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no",orderNo).eq("source",33).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode()));


                // 判断订单是否超量


                if (orderDetl.getQty() >= orderDetl.getAnfme()) {


                    throw new CoolException("调拨单:" + orderNo + "的<" + agvLocDetl.getMatnr() + ">已完成调拨数量,请检查!");


                }


                //                FlowLog flowLog = new FlowLog();


//                flowLog.setFid(String.valueOf(flowId));


//                flowLog.setSpare2(wrkMast.getWrkNo().toString());


//                flowLog.setLocNo(wrkMast.getSourceLocNo());


//                flowLog.setSpare1(barcode);


//                flowLog.setOpType(5L);


//                flowLog.setOrderNo(orderDetl.getOrderNo());


//                flowLog.setThreeCode(orderDetl.getThreeCode());


//                flowLog.setMatnr(agvLocDetl.getMatnr());


//                flowLog.setMaktx(agvLocDetl.getMaktx());


//                flowLog.setOrderPrevious(orderDetl.getAnfme());


//                flowLog.setOrderCurrent(orderDetl.getAnfme());


//                flowLog.setOrderChanged(0.0);


//


//                flowLog.setQtyPrevious(orderDetl.getQty());


//                flowLog.setQtyCurrent(orderDetl.getQty() + agvLocDetl.getAnfme());


//                flowLog.setQtyChanged(agvLocDetl.getAnfme());


//


//                flowLog.setLocPrevious(agvLocDetl.getAnfme());


//                flowLog.setLocCurrent(0.0d);


//                flowLog.setLocChanged(agvLocDetl.getAnfme());


//                flowLog.setUserId(getUserId());


//                flowLog.setAppeTime(now);


//                if (!flowLogService.insert(flowLog)) {


//                    throw new CoolException("同步半成品调拨单流水记录失败");


//                }


                orderDetl.setQty(orderDetl.getQty() + agvLocDetl.getAnfme());


                if (!orderDetlService.update(orderDetl,new EntityWrapper<OrderDetl>().eq("order_no",orderNo).eq("source",33).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode()))){


                    throw new CoolException("订单号：{"+orderNo+"}更新订单明细失败！ 异常物料:"+agvLocDetl.getMatnr()+"(半成品调拨单任务)" );


                }


                // 更新订单状态


                Order order = orderService.selectByNo(orderDetl.getOrderNo());


                Long settle = order.getSettle();


                if (settle == 1L) {


                    if (!orderService.updateSettle(order.getId(),2L,getUserId())) {


                        throw new CoolException("订单号：{"+order.getOrderNo()+"}更新订单状态：1-->2 失败！(半成品调拨单任务)" );


                    }


                }


            }


            // 更新源库位


            AgvLocMast locMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", locNo));


            locMast.setLocSts("R");


            agvLocMastService.updateById(locMast);


        }


        return R.ok();


    }




    @PostMapping("/agv/v3/locMove")


    @Transactional


    @ManagerAuth(memo = "回调单任务下发")


    @Synchronized


    public R agvLocMove3(@RequestBody HashMap<String,Object> params){


        Date now = new Date();


        List<HashMap<String,String>> dbList = (List<HashMap<String, String>>) params.get("dbList");


        params.get("dbList");


        String orderNo = params.get("orderNo").toString();


        for (HashMap<String, String> map : dbList) {


            String locNo = map.get("locNo");


            String barcode = map.get("suppCode");


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


            if (!Cools.isEmpty(source_loc_no)) {


                throw new CoolException("当前库位已生成任务！");


            }


            AgvLocMast locMastS = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", locNo).eq("loc_sts","F"));


            if (Cools.isEmpty(locMastS)) {


                throw new CoolException("当前库位非在库状态！库位号="+locNo);


            }


            AgvWrkMast wrkMast = createWrkMast(114, 22L, locNo, "", barcode, now, getUserId(), 30,1);


            // 同步调拨单


            List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo));


            for (AgvLocDetl agvLocDetl : agvLocDetls) {


                AgvWrkDetl wrkDetl = new AgvWrkDetl();


@@ -455,10 +663,20 @@


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


                }


                // 更新订单


                OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", "DB" + agvLocDetl.getOrderNo()).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode()));


                // 先查询库订单明细 所属的订单




                OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no",orderNo).eq("source",17).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode()));


                orderDetl.setQty(orderDetl.getQty() + agvLocDetl.getAnfme());


                if (!orderDetlService.update(orderDetl,new EntityWrapper<OrderDetl>().eq("order_no","DB" + agvLocDetl.getOrderNo()).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode()))){


                if (!orderDetlService.update(orderDetl,new EntityWrapper<OrderDetl>().eq("order_no",orderNo).eq("source",17).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode()))){


                    throw new CoolException("修改订单明细失败，请联系管理员"+agvLocDetl.getOrderNo()+agvLocDetl.getMatnr());


                }


                // 更新订单状态


                Order order = orderService.selectByNo(orderNo);


                Long settle = order.getSettle();


                if (settle == 1L) {


                    if (!orderService.updateSettle(order.getId(),2L,getUserId())) {


                        throw new CoolException("订单号：{"+order.getOrderNo()+"}更新订单状态：1-->2 失败！(半成品调拨单任务)" );


                    }


                }


            }


            // 更新源库位


@@ -535,6 +753,16 @@


        return R.ok();


    }




    @PostMapping("/hand/control/processed")


    @Transactional


    @ManagerAuth(memo = "确认加工完成")


    @Synchronized


    public R processed(@RequestBody AgvMobileStartPakin param){


        agvMobileService.processed(param, getUserId());


        return R.ok();


    }






    public static void main(String[] args) {


        List<AgvLocDetl> agvLocDetls1 = new ArrayList<>();


        List<AgvLocDetl> agvLocDetls2 = new ArrayList<>();