自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
13
zhang
8 天以前 ab41622d30946f83b34e5a5d881741237628f6f1 
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java


@@ -69,9 +69,13 @@


    @Autowired


    private SnowflakeIdWorker snowflakeIdWorker;


    @Autowired


    private OrderService orderService;


    private OrderPakoutService orderPakoutService;


    @Autowired


    private OrderDetlService orderDetlService;


    private OrderPakinService orderPakinService;


    @Autowired


    private OrderDetlPakoutService orderDetlPakoutService;


    @Autowired


    private OrderDetlPakinService orderDetlPakinService;


    @Autowired


    private WcsController wcsController;


    @Autowired


@@ -80,8 +84,6 @@


    private SlaveProperties slaveProperties;


    @Autowired


    private WaitPakinService waitPakinService;


    @Autowired


    private InventoryCheckOrderDetlService inventoryCheckOrderDetlService;




    @Override


    @Transactional


@@ -174,7 +176,7 @@


        List<LocDetlDto> locDetlDtos = new ArrayList<>();


        for (StockOutParam.LocDetl paramLocDetl : param.getLocDetls()) {


            if (!Cools.isEmpty(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getCount())) {


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getBatch());


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getSku());


                if (null != one) locDetlDtos.add(new LocDetlDto(one, paramLocDetl.getCount()));


            }


        }


@@ -184,10 +186,10 @@


                if (staNo.getDevNo() == 1135 && locMast.getLocType1() == 2) {


                    throw new CoolException("所选库位不是低库位无法调拨，库位号：{}" + locMast.getLocNo());


                }


                if(staNo.getDevNo()>=1100){


                if (staNo.getDevNo() >= 1100) {


                    // 启动出库开始 101.出库


                    stockOut(staNo, locDetlDtos, null, userId);


                }else {


                } else {


                    stockOutSXK(staNo, locDetlDtos, null, userId);


                }


            } else {


@@ -386,19 +388,6 @@


            // 生成工作档明细


            for (LocDetlDto detlDto : dto.getLocDetlDtos()) {




                InventoryCheckOrderDetl inventoryCheckOrderDetl = new InventoryCheckOrderDetl();


                inventoryCheckOrderDetl.setOrderNo(param.getOrderNo());


                inventoryCheckOrderDetl.setMatnr(detlDto.getLocDetl().getMatnr());


                inventoryCheckOrderDetl.setMaktx(detlDto.getLocDetl().getMaktx());


                inventoryCheckOrderDetl.setBatch(detlDto.getLocDetl().getBatch());


                inventoryCheckOrderDetl.setLocNo(detlDto.getLocDetl().getLocNo());


                inventoryCheckOrderDetl.setArea(detlDto.getLocDetl().getOrigin());


                inventoryCheckOrderDetl.setAnfme(detlDto.getLocDetl().getAnfme());


                inventoryCheckOrderDetl.setIoTime(now);


                inventoryCheckOrderDetl.setStatus("1");


                if (!inventoryCheckOrderDetlService.insert(inventoryCheckOrderDetl)) {


                    throw new CoolException("保存盘点明细失败");


                }




                if (detlDto.getCount() == null || detlDto.getCount() <= 0.0D) {


                    continue;


@@ -485,12 +474,12 @@


            if (locDto.getAnfme() == null || locDto.getAnfme() <= 0.0D) {


                continue;


            }


            OrderDetl orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());


            if (orderDetl == null) {


                orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), null);


            OrderDetlPakout orderDetlPakout = orderDetlPakoutService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());


            if (orderDetlPakout == null) {


                orderDetlPakout = orderDetlPakoutService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), null);


            }


            WrkDetl wrkDetl = new WrkDetl();


            wrkDetl.sync(orderDetl);


            wrkDetl.sync(orderDetlPakout);


            wrkDetl.setZpallet(wrkMast.getBarcode());


            wrkDetl.setIoTime(now);


            wrkDetl.setWrkNo(workNo);


@@ -505,10 +494,10 @@


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


            }


            // 修改订单明细


            if (!orderDetlService.increaseWorkQty(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), locDto.getAnfme())) {


            if (!orderDetlPakoutService.increaseWorkQtyById(orderDetlPakout.getId(), locDto.getAnfme())) {


                throw new CoolException("修改订单明细数量失败");


            }


            orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);


            orderPakoutService.updateSettle(orderDetlPakout.getOrderId(), 2L, userId);


        }


        // 修改库位状态:   F.在库 ====>>> R.出库预约/P.拣料/盘点/并板出库中


        locMast = locMastService.selectById(taskDto.getLocNo());


@@ -538,10 +527,10 @@


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




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


        if ((locMast.getBay1() >= 3 && locMast.getBay1() <= 6) ) {


        if ((locMast.getBay1() >= 3 && locMast.getBay1() <= 6)) {


            locMasts = locMastService.selectList(new EntityWrapper<LocMast>()


                    .eq("row1", locMast.getBay1())


                    .in("bay1", 3,4,5,6)


                    .in("bay1", 3, 4, 5, 6)


                    .eq("crn_no", 7)


                    .eq("loc_type1", locMast.getLocType1())


                    .orderBy("bay1", true));


@@ -593,12 +582,12 @@


            if (locDto.getAnfme() == null || locDto.getAnfme() <= 0.0D) {


                continue;


            }


            OrderDetl orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());


            if (orderDetl == null) {


                orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), null);


            OrderDetlPakout orderDetlPakout = orderDetlPakoutService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());


            if (orderDetlPakout == null) {


                orderDetlPakout = orderDetlPakoutService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), null);


            }


            WrkDetl wrkDetl = new WrkDetl();


            wrkDetl.sync(orderDetl);


            wrkDetl.sync(orderDetlPakout);


            wrkDetl.setZpallet(wrkMast.getBarcode());


            wrkDetl.setIoTime(now);


            wrkDetl.setWrkNo(workNo);


@@ -613,10 +602,10 @@


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


            }


            // 修改订单明细


            if (!orderDetlService.increaseWorkQty(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), locDto.getAnfme())) {


            if (!orderDetlPakoutService.increaseWorkQty(orderDetlPakout.getOrderId(), orderDetlPakout.getMatnr(), orderDetlPakout.getBatch(), locDto.getAnfme())) {


                throw new CoolException("修改订单明细数量失败");


            }


            orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);


            orderPakoutService.updateSettle(orderDetlPakout.getOrderId(), 2L, userId);


        }


        // 修改库位状态:   F.在库 ====>>> R.出库预约/P.拣料/盘点/并板出库中


        locMast = locMastService.selectById(taskDto.getLocNo());


@@ -912,7 +901,7 @@


        List<LocDetlDto> locDetlDtos = new ArrayList<>();


        for (StockOutParam.LocDetl paramLocDetl : param.getLocDetls()) {


            if (!Cools.isEmpty(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getCount())) {


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getBatch());


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getSku());


                if (null != one) locDetlDtos.add(new LocDetlDto(one, paramLocDetl.getCount()));


            }


        }


@@ -940,7 +929,7 @@


        List<LocDetlDto> locDetlDtos = new ArrayList<>();


        for (StockOutParam.LocDetl paramLocDetl : param.getLocDetls()) {


            if (!Cools.isEmpty(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getCount())) {


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getBatch());


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getSku());


                if (null != one) locDetlDtos.add(new LocDetlDto(one, paramLocDetl.getCount()));


            }


        }


@@ -1058,19 +1047,6 @@


            // 生成工作档明细


            for (LocDetlDto detlDto : dto.getLocDetlDtos()) {




                InventoryCheckOrderDetl inventoryCheckOrderDetl = new InventoryCheckOrderDetl();


                inventoryCheckOrderDetl.setOrderNo(param.getOrderNo());


                inventoryCheckOrderDetl.setMatnr(detlDto.getLocDetl().getMatnr());


                inventoryCheckOrderDetl.setMaktx(detlDto.getLocDetl().getMaktx());


                inventoryCheckOrderDetl.setBatch(detlDto.getLocDetl().getBatch());


                inventoryCheckOrderDetl.setLocNo(detlDto.getLocDetl().getLocNo());


                inventoryCheckOrderDetl.setArea(detlDto.getLocDetl().getOrigin());


                inventoryCheckOrderDetl.setAnfme(detlDto.getLocDetl().getAnfme());


                inventoryCheckOrderDetl.setIoTime(now);


                inventoryCheckOrderDetl.setStatus("1");


                if (!inventoryCheckOrderDetlService.insert(inventoryCheckOrderDetl)) {


                    throw new CoolException("保存盘点明细失败");


                }




                if (detlDto.getCount() == null || detlDto.getCount() <= 0.0D) {


                    continue;


@@ -1196,7 +1172,7 @@


        if (Cools.isEmpty(wrkMast)) {


            throw new CoolException(workNo + "工作档不存在");


        }


        if (wrkMast.getWrkSts() == 4 || wrkMast.getWrkSts() == 14) {


        if (wrkMast.getWrkSts() == 4 || wrkMast.getWrkSts() == 5 || wrkMast.getWrkSts() == 14 || wrkMast.getWrkSts() == 15) {


            throw new CoolException("当前工作档已完成");


        }


        // 入库 + 库位转移


@@ -1226,7 +1202,7 @@


        if (Cools.isEmpty(locMast)) {


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


        }


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


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


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


        }




@@ -1250,7 +1226,7 @@


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


                        // todo 盘点记录


                        // 修改库存


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


                        if (!locDetlService.updateAnfme(adjust.getCount(), locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getSku())) {


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


                        }


                        // 保存调整记录


@@ -1300,7 +1276,8 @@


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


            LocDetl locDetl = new LocDetl();


            locDetl.sync(mat);


            locDetl.setBatch(adjust.getBatch());


            locDetl.setDanger(adjust.getDanger());


            locDetl.setSku(adjust.getBatch());


            locDetl.setLocNo(locMast.getLocNo());


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


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


@@ -1337,7 +1314,7 @@


        }


        locMast.setModiUser(userId);


        locMast.setModiTime(now);


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


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


            locMast.setBarcode("");


        }


        if (!locMastService.updateById(locMast)) {


@@ -1422,26 +1399,26 @@


            List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo());


            for (WrkDetl wrkDetl : wrkDetls) {


                if (!Cools.isEmpty(wrkDetl.getOrderNo())) {


                    if (!orderDetlService.decrease(wrkDetl.getOrderNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getAnfme())) {


                    if (!orderDetlPakoutService.decrease(wrkDetl.getOrderNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getAnfme())) {


                        throw new CoolException("订单数据回滚失败");


                    }




                    //修改订单主表状态,没有作业数量时才可以修改


                    boolean flag = true;


                    List<OrderDetl> orderDetls = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_no", wrkDetl.getOrderNo()));


                    for (OrderDetl orderDetl : orderDetls) {


                        if (orderDetl.getWorkQty() > 0) {


                    List<OrderDetlPakout> orderDetlPakouts = orderDetlPakoutService.selectList(new EntityWrapper<OrderDetlPakout>().eq("order_no", wrkDetl.getOrderNo()));


                    for (OrderDetlPakout orderDetlPakout : orderDetlPakouts) {


                        if (orderDetlPakout.getWorkQty() > 0) {


                            flag = false;


                        }


                    }


                    if (flag) {


                        Order order = orderService.selectOne(new EntityWrapper<Order>().eq("order_no", wrkDetl.getOrderNo()));


                        OrderPakout order = orderPakoutService.selectOne(new EntityWrapper<OrderPakout>().eq("order_no", wrkDetl.getOrderNo()));


                        if (!Cools.isEmpty(order) && order.getSettle() == 2) {


                            order.setSettle(1L);


                            order.setUpdateBy(userId);


                            order.setUpdateTime(now);


                        }


                        if (!orderService.update(order, new EntityWrapper<Order>().eq("order_no", wrkDetl.getOrderNo()))) {


                        if (!orderPakoutService.update(order, new EntityWrapper<OrderPakout>().eq("order_no", wrkDetl.getOrderNo()))) {


                            throw new CoolException("修改订单状态失败");


                        }


                    }


@@ -1704,7 +1681,7 @@


        List<LocDetlDto> locDetlDtos = new ArrayList<>();


        for (StockOutParam.LocDetl paramLocDetl : param.getLocDetls()) {


            if (!Cools.isEmpty(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getCount())) {


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getBatch());


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getSku());


                if (null != one) locDetlDtos.add(new LocDetlDto(one, paramLocDetl.getCount()));


            }


        }


@@ -1725,7 +1702,7 @@


        List<LocDetlDto> locDetlDtos = new ArrayList<>();


        for (StockOutParam.LocDetl paramLocDetl : param.getLocDetls()) {


            if (!Cools.isEmpty(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getCount())) {


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getBatch());


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getSku());


                if (null != one) locDetlDtos.add(new LocDetlDto(one, paramLocDetl.getCount()));


            }


        }


@@ -1798,10 +1775,10 @@


//                    moveLocForDeepLoc(locMast1);


//                }


//            }


            if ((locMast.getBay1() >= 3 && locMast.getBay1() <= 6) ) {


            if ((locMast.getBay1() >= 3 && locMast.getBay1() <= 6)) {


                locMasts = locMastService.selectList(new EntityWrapper<LocMast>()


                        .eq("row1", locMast.getBay1())


                        .in("bay1", 3,4,5,6)


                        .in("bay1", 3, 4, 5, 6)


                        .eq("crn_no", 7)


                        .eq("loc_type1", locMast.getLocType1())


                        .orderBy("bay1", true));