no message

skyouc

2025-07-07 2a24c69b830d9dc97a8673f5f69418e9f95f3e1b

 zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java

@@ -1,8 +1,10 @@
package com.zy.asrs.wms.asrs.manage;



import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;

import com.mysql.cj.util.StringUtils;

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

import com.zy.asrs.framework.exception.CoolException;

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

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

@@ -935,9 +937,9 @@


        /**

         * 波次合并出库

         * 1. 判断是平库还TCU库

         * 1. 判断是平库还CTU库

         * 2. 平库生成拣货单

         * 3. TCU库生成任务单

         * 3. CTU库生成任务单

         */

        outStockByArea(dto, wave);



@@ -1048,13 +1050,11 @@
        if (!flatOrders.isEmpty()) {

            //平库出库

            outStockByFlat(flatOrders, wave);

        } else if (!tucOrders.isEmpty()) {

            //CTU出库

            outStockByTUC(tucOrders, wave);

        } else {

            throw new CoolException("库存不足");

        }



        if (!tucOrders.isEmpty()) {

            //CTU出库

            outStockByCTU(tucOrders, wave);

        }

    }



    /**

@@ -1063,7 +1063,7 @@
     * @param tucOrders

     * @param wave

     */

    private void outStockByTUC(List<OrderOutMergeParam> tucOrders, Wave wave) {

    private void outStockByCTU(List<OrderOutMergeParam> tucOrders, Wave wave) {

        Map<Long, List<OrderOutMergeDto>> map = checkLoc(tucOrders, wave);



        for (Map.Entry<Long, List<OrderOutMergeDto>> entry : map.entrySet()) {

@@ -1154,7 +1154,7 @@
            }



            List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>()

                    .eq(CacheSite::getSiteStatus, CacheSiteStatusType.O.id).eq(CacheSite::getChannel,task.getTargetSite()));

                    .eq(CacheSite::getSiteStatus, CacheSiteStatusType.O.id).eq(CacheSite::getChannel, task.getTargetSite()));



            if (cacheSites.isEmpty()) {

                throw new CoolException("缓存站空间不足，请稍后再试");

@@ -1219,6 +1219,18 @@


        //根据库位ID分组

        Map<Long, List<OrderOutMergeParam>> listMap = flatOrders.stream().collect(Collectors.groupingBy(OrderOutMergeParam::getLocId));



        genPickSheet(listMap, pickSheet);

    }



    /**

     * @author Ryan

     * @date 2025/7/4

     * @description: 生面拣货明细

     * @version 1.0

     */

    @Transactional(rollbackFor = Exception.class)

    public void genPickSheet(Map<Long, List<OrderOutMergeParam>> listMap, PickSheet pickSheet) {

        //生成拣货明细

        listMap.keySet().forEach(key -> {

            Loc curLoc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getId, key));

@@ -1248,11 +1260,14 @@
                if (!locDetlService.updateById(locDetl)) {

                    throw new CoolException("库存加锁失败！！");

                }



            });



        });

            curLoc.setLocStsId(LocStsType.R.val());



            if (!locService.updateById(curLoc)) {

                throw new CoolException("库位状态修改失败！！");

            }

        });

    }



    /**

@@ -1272,24 +1287,19 @@
        if (param == null) {

            throw new CoolException("参数不能为空");

        }



        List<String> channels = param.getChannels();

        if (channels == null) {

            throw new CoolException("通道参数不能为空");

        }



        if (channels.isEmpty()) {

            throw new CoolException("通道参数不能为空");

        }



//        for (String channel : channels) {

//            long count = cacheSiteService.count(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getChannel, channel).ne(CacheSite::getSiteStatus, 0));

//            if (count > 0) {

//                throw new CoolException(channel + "通道已经分配波次");

//            }

//        }





        List<Long> orderIds = param.getOrderIds();

        if (orderIds == null) {

            throw new CoolException("订单参数不能为空");

@@ -1450,7 +1460,190 @@


            waveService.removeById(wave.getId());

        }



    }



    /**

     * @author Ryan

     * @date 2025/7/3

     * @description: 库存出库信息

     * @version 1.0

     */

    @Transactional(rollbackFor = Exception.class)

    public void outLocStock(StockOutParam param) {

        System.out.println(JSONObject.toJSONString(param));

        if (param.getOutType().equals(1)) {

            //拣货单

            outFlatStock(param);

        } else {

            //生成任务档

            generateTask(param);

        }

    }



    /**

     * @author Ryan

     * @param: []

     * @return: void

     * @date: 2025/7/4

     * @description: 手动出库生成任务

     */

    @Transactional(rollbackFor = Exception.class)

    public void generateTask(StockOutParam outParam) {

        for (LocDetl outLocDetl : outParam.getLocDetls()) {

            List<OrderOutMergeDto> orders = new ArrayList<>();

            LocDetl detl = locDetlService.getOne(new LambdaQueryWrapper<LocDetl>().eq(LocDetl::getId, outLocDetl.getId()));

            if (Objects.isNull(detl)) {

                continue;

            }

            OrderOutMergeDto outMergeParam = new OrderOutMergeDto();

            outMergeParam.setAnfme(outLocDetl.getAnfme());

            outMergeParam.setLocNo(outLocDetl.getLocNo());

            outMergeParam.setLocDetlId(detl.getId());

            outMergeParam.setLocId(detl.getLocId());

            outMergeParam.setMatnr(outLocDetl.getMatnr());

            outMergeParam.setBatch(detl.getBatch());

            orders.add(outMergeParam);



            //根据库位ID分组

            Map<Long, List<OrderOutMergeDto>> listMap = orders.stream().collect(Collectors.groupingBy(OrderOutMergeDto::getLocId));

            //生成拣货单明细

            for (Map.Entry<Long, List<OrderOutMergeDto>> entry : listMap.entrySet()) {

                Long locId = entry.getKey();

                List<OrderOutMergeDto> list = entry.getValue();

                //判断是否全仓出库

                Boolean all = outUtils.isAllForMerge(locId, list);

                OrderOutMergeDto param = list.stream().findFirst().get();



                List<CacheSite> sites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>()

                        .isNotNull(CacheSite::getOrderId));

                if (!sites.isEmpty()) {

                    Map<String, Long> longMap = sites.stream().collect(Collectors.groupingBy(CacheSite::getChannel, Collectors.counting()));

                    Map.Entry<String, Long> entry1 = longMap.entrySet().stream().min(Map.Entry.comparingByValue()).get();

                    param.setPortSite(entry1.getKey());

                } else {

                    CacheSite cacheSite = cacheSiteService.getOne(new LambdaQueryWrapper<CacheSite>().last("limit 1"));

                    param.setPortSite(cacheSite.getChannel());

                }

                Loc loc = locService.getById(locId);

                if (loc == null) {

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

                }



                if (!loc.getLocStsId().equals(LocStsType.F.val())) {

                    throw new CoolException(loc.getLocNo() + "库位状态异常");

                }



                OperationPort operationPort = operationPortService

                        .getOne(new LambdaQueryWrapper<OperationPort>()

                                .eq(OperationPort::getFlag, param.getPortSite()));

                if (Objects.isNull(operationPort)) {

                    throw new CoolException("作业口不存在");

                }

                //101 全拖出库   103 拣货出库

                long taskType = all ? 101L : 103L;



                Task task = new Task();

                task.setTaskNo(workService.generateTaskNo(taskType));

                task.setTaskSts(TaskStsType.GENERATE_OUT.id);

                task.setTaskType(taskType);

                task.setIoPri(workService.generateIoPri(taskType));

                task.setOriginLoc(loc.getLocNo());

                task.setTargetSite(operationPort.getFlag());

                task.setBarcode(loc.getBarcode());

                boolean res = taskService.save(task);

                if (!res) {

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

                }



                for (OrderOutMergeDto merge : list) {

                    LocDetl locDetl = locDetlService.getById(merge.getLocDetlId());

                    if (locDetl == null) {

                        throw new CoolException("明细不存在");

                    }



                    TaskDetl taskDetl = new TaskDetl();

                    taskDetl.sync(locDetl);

                    taskDetl.setId(null);

                    taskDetl.setTaskId(task.getId());

                    taskDetl.setTaskNo(task.getTaskNo());

                    taskDetl.setAnfme(merge.getAnfme());

                    taskDetl.setStock(locDetl.getAnfme());

                    taskDetl.setOrderId(null);

                    taskDetl.setOrderNo(null);

                    if (!taskDetlService.save(taskDetl)) {

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

                    }



                    List<LocDetlField> locDetlFields = locDetlFieldService

                            .list(new LambdaQueryWrapper<LocDetlField>()

                                    .eq(LocDetlField::getDetlId, locDetl.getId()));

                    for (LocDetlField locDetlField : locDetlFields) {

                        TaskDetlField taskDetlField = new TaskDetlField();

                        taskDetlField.sync(locDetlField);

                        taskDetlField.setId(null);

                        taskDetlField.setDetlId(taskDetl.getId());

                        boolean taskDetlFieldSave = taskDetlFieldService.save(taskDetlField);

                        if (!taskDetlFieldSave) {

                            throw new CoolException("明细扩展生成失败");

                        }

                    }

                }



                //库位F => R

                loc.setLocStsId(LocStsType.R.val());

                loc.setUpdateTime(new Date());

                boolean locUpdate = locService.updateById(loc);

                if (!locUpdate) {

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

                }

            }

        }

    }





    /**

     * @author Ryan

     * @date 2025/7/4

     * @description: 平库库存出库

     * @version 1.0

     */

    @Transactional(rollbackFor = Exception.class)

    public void outFlatStock(StockOutParam param) {

        //生成拣货单

        PickSheet pickSheet = new PickSheet();

        //波次数量汇总

        Double sum = param.getLocDetls().stream().mapToDouble(LocDetl::getAnfme).sum();

        //生成拣货单号

        String pickNo = generatePickNO();

        pickSheet.setId(null)

                .setPickNo(pickNo)

                .setMemo("库存出库")

                .setAnfme(sum)

                .setType(2);



        if (!pickSheetService.save(pickSheet)) {

            throw new CoolException("拣货单写入失败！！");

        }



        for (LocDetl locDetl : param.getLocDetls()) {

            List<OrderOutMergeParam> orders = new ArrayList<>();

            LocDetl detl = locDetlService.getOne(new LambdaQueryWrapper<LocDetl>().eq(LocDetl::getLocNo, locDetl.getLocNo()));

            if (Objects.isNull(detl)) {

                continue;

            }

            OrderOutMergeParam outMergeParam = new OrderOutMergeParam();

            outMergeParam.setAnfme(locDetl.getAnfme())

                    .setLocNo(locDetl.getLocNo())

                    .setLocId(detl.getLocId())

                    .setLocDetlId(detl.getId())

                    .setMatnr(locDetl.getMatnr())

                    .setBatch(detl.getBatch());

            orders.add(outMergeParam);



            //根据库位ID分组

            Map<Long, List<OrderOutMergeParam>> listMap = orders.stream().collect(Collectors.groupingBy(OrderOutMergeParam::getLocId));

            //生成拣货单明细

            genPickSheet(listMap, pickSheet);

        }

    }

}