自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Junjie
2025-09-04 193c3204f7f998df4d603df202dbea88a3074585 
 src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java


@@ -1,7 +1,6 @@


package com.zy.nc.task.handler;




import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.core.common.Cools;


import com.core.exception.CoolException;


import com.zy.asrs.entity.InventoryCheckOrder;


@@ -9,10 +8,7 @@


import com.zy.asrs.entity.Mat;


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


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


import com.zy.asrs.service.InventoryCheckOrderDetlService;


import com.zy.asrs.service.InventoryCheckOrderService;


import com.zy.asrs.service.MatService;


import com.zy.asrs.service.OpenService;


import com.zy.asrs.service.*;


import com.zy.asrs.task.AbstractHandler;


import com.zy.asrs.task.core.ReturnT;


import com.zy.common.model.DetlDto;


@@ -21,10 +17,12 @@


import lombok.extern.slf4j.Slf4j;


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


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.transaction.interceptor.TransactionAspectSupport;




import java.util.ArrayList;


import java.util.Date;


import java.util.HashMap;


import java.util.List;




@Service


@@ -57,23 +55,91 @@




    @Autowired


    private OpenService openService;


    @Autowired


    private StoreTypeService storeTypeService;




    /**


     * 发货


     *


     * @return


     */


    @Transactional


    public ReturnT<String> start1(List<NccSaleXsfhmxWms> wmsFlag) {


        try {


            OpenOrderPakoutParam param = new OpenOrderPakoutParam();


            param.setOrderType("销售发货");


            List<String> ids = storeTypeService.listOwn();


            HashMap<String, List<NccSaleXsfhmxWms>> map = new HashMap<>();


            List<NccSaleXsfhmxWms> fenzu;


            for (NccSaleXsfhmxWms wms : wmsFlag) {


                if(!ids.contains(wms.getFhckbm())){


                    continue;


                }




                if (map.get(wms.getFhckbm()) == null) {


                    fenzu = new ArrayList<>();


                    fenzu.add(wms);


                    map.put(wms.getFhckbm(), fenzu);


                } else {


                    fenzu = map.get(wms.getFhckbm());


                    fenzu.add(wms);


                    map.put(wms.getFhckbm(), fenzu);


                }


            }


            int size = 1;


            for (String key : map.keySet()) {


                OpenOrderPakoutParam param = new OpenOrderPakoutParam();


                DetlDto detlDto;


                List<DetlDto> orderDetails = new ArrayList<>();


                long i = 1;


                for (NccSaleXsfhmxWms nccSaleXsfhmxWms : map.get(key)) {


                    param.setOrderType("销售发货");


                    detlDto = new DetlDto();


                    detlDto.setMatnr(nccSaleXsfhmxWms.getWlbm());


                    detlDto.setAnfme(nccSaleXsfhmxWms.getNnum().doubleValue());


                    detlDto.setBatch(nccSaleXsfhmxWms.getVbatchcode());


                    detlDto.setWeight(nccSaleXsfhmxWms.getNastnum().doubleValue());


                    detlDto.setStandby1(nccSaleXsfhmxWms.getFhckbm());


                    detlDto.setLineNumber(i);


                    detlDto.setRemark(JSONObject.toJSONString(nccSaleXsfhmxWms));


                    orderDetails.add(detlDto);


                    log.info("NccSaleXsfhmxWms数据:{}", JSONObject.toJSON(nccSaleXsfhmxWms));


                    i++;


                    nccSaleXsfhmxWms.setWmsFlag(1);


                    param.setOrderNo(nccSaleXsfhmxWms.getVbillcode() + "-" + size);


                    param.setCstmrName(nccSaleXsfhmxWms.getKhmc());


                    param.setKpCstmrName(nccSaleXsfhmxWms.getKpkhmc());


                }


                param.setOrderDetails(orderDetails);


                openService.pakoutOrderCreate(param);


                nccSaleXsfhmxWmsService.updateBatchById(map.get(key));


                size++;


            }


        } catch (Exception e) {


            e.printStackTrace();


            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


            return FAIL.setMsg(e.getMessage());


        }


        return SUCCESS;


    }




    /**


     * 发货


     *


     * @return


     */


    @Transactional


    public ReturnT<String> start1In(List<NccSaleXsfhmxWms> wmsFlag) {


        try {


            OpenOrderPakinParam param = new OpenOrderPakinParam();


            DetlDto detlDto;


            List<DetlDto> orderDetails = new ArrayList<>();


            long i = 1;


            for (NccSaleXsfhmxWms nccSaleXsfhmxWms : wmsFlag) {


                param.setOrderType("销售退货");


                detlDto = new DetlDto();


                detlDto.setMatnr(nccSaleXsfhmxWms.getWlbm());


                detlDto.setAnfme(nccSaleXsfhmxWms.getNastnum().doubleValue());


                detlDto.setAnfme(nccSaleXsfhmxWms.getNnum().doubleValue());


                detlDto.setWeight(nccSaleXsfhmxWms.getNastnum().doubleValue());


                detlDto.setStandby1(nccSaleXsfhmxWms.getFhckbm());


                detlDto.setLineNumber(i);


                detlDto.setRemark(JSONObject.toJSONString(nccSaleXsfhmxWms));


                orderDetails.add(detlDto);


@@ -83,11 +149,11 @@


                param.setOrderNo(nccSaleXsfhmxWms.getVbillcode());


            }


            param.setOrderDetails(orderDetails);


            openService.pakoutOrderCreate(param);


            openService.pakinOrderCreate(param);


            nccSaleXsfhmxWmsService.updateBatchById(wmsFlag);


        } catch (Exception e) {


            e.printStackTrace();


            TransactionAspectSupport. currentTransactionStatus().setRollbackOnly();


            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


            return FAIL.setMsg(e.getMessage());


        }


        return SUCCESS;


@@ -98,6 +164,7 @@


     *


     * @return


     */


    @Transactional


    public ReturnT<String> start2In(List<NccScZkmxbWms> wmsFlag) {


        try {


            OpenOrderPakinParam param = new OpenOrderPakinParam();


@@ -110,6 +177,7 @@


                detlDto = new DetlDto();


                detlDto.setMatnr(nccScZkmxbWms.getWlbm());


                detlDto.setAnfme(nccScZkmxbWms.getYingzzsl().doubleValue());


                detlDto.setWeight(nccScZkmxbWms.getYingzsl().doubleValue());


                detlDto.setBatch(nccScZkmxbWms.getVbatchcode());


                detlDto.setLineNumber(i);


                detlDto.setRemark(JSONObject.toJSONString(nccScZkmxbWms));


@@ -135,6 +203,7 @@


     *


     * @return


     */


    @Transactional


    public ReturnT<String> start2Out(List<NccScZkmxbWms> wmsFlag) {


        try {


            OpenOrderPakoutParam param = new OpenOrderPakoutParam();


@@ -147,6 +216,7 @@


                detlDto = new DetlDto();


                detlDto.setMatnr(nccScZkmxbWms.getWlbm());


                detlDto.setAnfme(nccScZkmxbWms.getYingzzsl().doubleValue());


                detlDto.setWeight(nccScZkmxbWms.getYingzsl().doubleValue());


                detlDto.setBatch(nccScZkmxbWms.getVbatchcode());


                detlDto.setLineNumber(i);


                detlDto.setRemark(JSONObject.toJSONString(nccScZkmxbWms));


@@ -171,6 +241,7 @@


     *


     * @return


     */


    @Transactional


    public ReturnT<String> start3(List<NccCgCgdhdWms> wmsFlag) {


        try {


            OpenOrderPakinParam param = new OpenOrderPakinParam();


@@ -183,6 +254,7 @@


                detlDto = new DetlDto();


                detlDto.setMatnr(nccCgCgdhdWms.getWlbm());


                detlDto.setAnfme(nccCgCgdhdWms.getYdzsl().doubleValue());


                detlDto.setAnfme(nccCgCgdhdWms.getYdsl().doubleValue());


                detlDto.setBatch(nccCgCgdhdWms.getVbatchcode());


                detlDto.setLineNumber(i);


                detlDto.setRemark(JSONObject.toJSONString(nccCgCgdhdWms));


@@ -209,39 +281,40 @@


     *


     * @return


     */


    public ReturnT<String> start4(List<NccCkPddWms> wmsFlag) {


        try {


            InventoryCheckOrder param = new InventoryCheckOrder();


            InventoryCheckOrderDetl checkOrderDetl = null;


            for (NccCkPddWms nccScZkmxbWms : wmsFlag) {


                log.info("NccCkPddWms数据:{}", JSONObject.toJSON(nccScZkmxbWms));


                Mat mat = matService.selectByMatnr(nccScZkmxbWms.getWlbm());


                if (Cools.isEmpty(mat)) {


                    throw new CoolException(nccScZkmxbWms.getWlbm() + "编号商品检索失败，请先添加商品");


                }


                checkOrderDetl = new InventoryCheckOrderDetl();


                checkOrderDetl.setMatnr(nccScZkmxbWms.getWlbm());


                checkOrderDetl.setMaktx(mat.getMaktx());


                checkOrderDetl.setOrderNo(nccScZkmxbWms.getVbillcode());


                checkOrderDetl.setAnfme(nccScZkmxbWms.getZmzsl().doubleValue());


                checkOrderDetl.setBatch(nccScZkmxbWms.getVbatchcode());


                inventoryCheckOrderDetlService.insert(checkOrderDetl);


                nccScZkmxbWms.setWmsFlag(1);


                param.setOrderNo(nccScZkmxbWms.getVbillcode());


                param.setCreateBy(nccScZkmxbWms.getPdrmc());




            }


            param.setCreateTime(new Date());


            param.setStatus("1");


            inventoryCheckOrderService.insert(param);


            nccCkPddWmsService.updateBatchById(wmsFlag);


        } catch (Exception e) {


            e.printStackTrace();


            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


            return FAIL.setMsg(e.getMessage());


        }


        return SUCCESS;


    }


//    @Transactional


//    public ReturnT<String> start4(List<NccCkPddWms> wmsFlag) {


//        try {


//            InventoryCheckOrder param = new InventoryCheckOrder();


//            InventoryCheckOrderDetl checkOrderDetl = null;


//            for (NccCkPddWms nccScZkmxbWms : wmsFlag) {


//                log.info("NccCkPddWms数据:{}", JSONObject.toJSON(nccScZkmxbWms));


//                Mat mat = matService.selectByMatnr(nccScZkmxbWms.getWlbm());


//                if (Cools.isEmpty(mat)) {


//                    throw new CoolException(nccScZkmxbWms.getWlbm() + "编号商品检索失败，请先添加商品");


//                }


//                checkOrderDetl = new InventoryCheckOrderDetl();


//                checkOrderDetl.setMatnr(nccScZkmxbWms.getWlbm());


//                checkOrderDetl.setMaktx(mat.getMaktx());


//                checkOrderDetl.setOrderNo(nccScZkmxbWms.getVbillcode());


//                checkOrderDetl.setAnfme(nccScZkmxbWms.getZmzsl().doubleValue());


//                checkOrderDetl.setBatch(nccScZkmxbWms.getVbatchcode());


//                inventoryCheckOrderDetlService.insert(checkOrderDetl);


//                nccScZkmxbWms.setWmsFlag(1);


//                param.setOrderNo(nccScZkmxbWms.getVbillcode());


//                param.setCreateBy(nccScZkmxbWms.getPdrmc());


//


//            }


//            param.setCreateTime(new Date());


//            param.setStatus("1");


//            inventoryCheckOrderService.insert(param);


//            nccCkPddWmsService.updateBatchById(wmsFlag);


//        } catch (Exception e) {


//            e.printStackTrace();


//            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


//            return FAIL.setMsg(e.getMessage());


//        }


//        return SUCCESS;


//    }






    /**


@@ -249,29 +322,55 @@


     *


     * @return


     */


    @Transactional


    public ReturnT<String> start5(List<NccSaleDbddWms> wmsFlag) {


        try {


            OpenOrderPakoutParam param = new OpenOrderPakoutParam();


            param.setOrderType("集团内部调拨");


            DetlDto detlDto;


            List<DetlDto> orderDetails = new ArrayList<>();


            long i = 1;


            for (NccSaleDbddWms nccCgCgdhdWms : wmsFlag) {


                log.info("nccCgCgdhdWms数据:{}", JSONObject.toJSON(nccCgCgdhdWms));


                detlDto = new DetlDto();


                detlDto.setMatnr(nccCgCgdhdWms.getWlbm());


                detlDto.setAnfme(nccCgCgdhdWms.getZsl().doubleValue());


                detlDto.setBatch(nccCgCgdhdWms.getVbatchcode());


                detlDto.setLineNumber(i);


                detlDto.setRemark(JSONObject.toJSONString(nccCgCgdhdWms));


                orderDetails.add(detlDto);


                i++;


                nccCgCgdhdWms.setWmsFlag(1);


                param.setOrderNo(nccCgCgdhdWms.getVbillcode());


            List<String> ids = storeTypeService.listOwn();


            HashMap<String, List<NccSaleDbddWms>> map = new HashMap<>();


            List<NccSaleDbddWms> fenzu;


            for (NccSaleDbddWms wms : wmsFlag) {


                if(!ids.contains(wms.getDcckbm())){


                    continue;


                }




                if (map.get(wms.getDcckbm()) == null) {


                    fenzu = new ArrayList<>();


                    fenzu.add(wms);


                    map.put(wms.getDcckbm(), fenzu);


                } else {


                    fenzu = map.get(wms.getDcckbm());


                    fenzu.add(wms);


                    map.put(wms.getDcckbm(), fenzu);


                }


            }


            param.setOrderDetails(orderDetails);


            openService.pakoutOrderCreate(param);


            nccSaleDbddWmsService.updateBatchById(wmsFlag);


            int size = 1;


            for (String key : map.keySet()) {


                OpenOrderPakoutParam param = new OpenOrderPakoutParam();


                param.setOrderType("集团内部调拨");


                DetlDto detlDto;


                List<DetlDto> orderDetails = new ArrayList<>();


                long i = 1;


                for (NccSaleDbddWms nccSaleDbddWms : map.get(key)) {


                    log.info("nccSaleDbddWms数据:{}", JSONObject.toJSON(nccSaleDbddWms));


                    detlDto = new DetlDto();


                    detlDto.setMatnr(nccSaleDbddWms.getWlbm());


                    detlDto.setAnfme(nccSaleDbddWms.getZsl().doubleValue());


                    detlDto.setWeight(nccSaleDbddWms.getFsl().doubleValue());


                    detlDto.setBatch(nccSaleDbddWms.getVbatchcode());


                    detlDto.setLineNumber(i);


                    detlDto.setRemark(JSONObject.toJSONString(nccSaleDbddWms));


                    detlDto.setStandby1(nccSaleDbddWms.getDcckbm());


                    orderDetails.add(detlDto);


                    i++;


                    param.setOrderNo(nccSaleDbddWms.getVbillcode() + "-" + size);


                    param.setCstmrName(nccSaleDbddWms.getDrkczzmc());


                    nccSaleDbddWms.setWmsFlag(1);


                }


                param.setOrderDetails(orderDetails);


                openService.pakoutOrderCreate(param);


                nccSaleDbddWmsService.updateBatchById(map.get(key));


                size++;


            }


        } catch (Exception e) {


            e.printStackTrace();


            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();