平库组库功能优化

skyouc

2025-07-18 a15ad9309f383153d4f5a95a044fb19e882fff55

 zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/WaitPakinServiceImpl.java

@@ -4,6 +4,7 @@
import com.zy.asrs.framework.exception.CoolException;

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

import com.zy.asrs.wms.asrs.entity.enums.OrderSettleType;

import com.zy.asrs.wms.asrs.entity.enums.OrderType;

import com.zy.asrs.wms.asrs.mapper.WaitPakinMapper;

import com.zy.asrs.wms.asrs.service.*;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

@@ -35,7 +36,7 @@


    @Override

    @Transactional(rollbackFor = Exception.class)

    public boolean comb(WaitPakin waitPakin) {

    public boolean comb(WaitPakin waitPakin, Long inType) {

        //组托规则校验

        waitPakinRuleService.rule(waitPakin);



@@ -58,14 +59,23 @@
            throw new CoolException("订单明细不存在");

        }



        //可用数量

        Double count = orderDetl.getAnfme() - orderDetl.getQty() - orderDetl.getWorkQty() - orderDetl.getWaitQty();

        if (waitPakin.getAnfme() > count) {

            throw new CoolException("组托数量超过剩余可用数量");

        if (inType.equals(OrderType.PK_IN_ORDER.id)) {

            Double sCount = Math.round((orderDetl.getAnfme() - orderDetl.getWaitQty()) * 1000) / 1000.0;

            if (waitPakin.getAnfme().compareTo(sCount) > 0) {

                throw new CoolException("组托数量超过剩余可用数量");

            }

        } else {

//        Double count = orderDetl.getAnfme() - orderDetl.getQty() - orderDetl.getWorkQty() - orderDetl.getWaitQty();

            Double count = Math.round((orderDetl.getAnfme() - orderDetl.getWorkQty() - orderDetl.getQty()) * 1000) / 1000.0;

            if (waitPakin.getAnfme().compareTo(count) > 0) {

                throw new CoolException("组托数量超过剩余可用数量");

            }

        }



        //查询是否存在相同明细和托盘码的组托通知档

        WaitPakin waitPakin1 = this.getOne(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, waitPakin.getBarcode()).eq(WaitPakin::getDetlId, waitPakin.getDetlId()));

        WaitPakin waitPakin1 = this.getOne(new LambdaQueryWrapper<WaitPakin>()

                .eq(WaitPakin::getBarcode, waitPakin.getBarcode())

                .eq(WaitPakin::getDetlId, waitPakin.getDetlId()));

        if (waitPakin1 == null) {

            //不存在组托通知档，创建

            waitPakin.setMatnr(orderDetl.getMat$().getMatnr());

@@ -74,8 +84,9 @@
                throw new CoolException("添加失败");

            }

        }else {

            Double total = waitPakin1.getAnfme() + waitPakin.getAnfme();

            //存在组托通知档，更新

            waitPakin1.setAnfme(waitPakin1.getAnfme() + waitPakin.getAnfme());

            waitPakin1.setAnfme(total);

            waitPakin1.setUpdateTime(new Date());

            if (!this.updateById(waitPakin1)) {

                throw new CoolException("添加失败");

@@ -88,6 +99,12 @@
            throw new CoolException("订单不存在");

        }



        //如果是平库入库单，修改订单明细执行数量

        if (inType.equals(OrderType.PK_IN_ORDER.id)) {

            orderDetl.setWorkQty(waitPakin.getAnfme());

            orderDetlService.updateById(orderDetl);

        }



        //更新订单状态

        if (order.getOrderSettle().equals(OrderSettleType.INIT.val())) {

            order.setOrderSettle(OrderSettleType.WAIT.val());