自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
pang.jiabao
2024-12-24 8aee12d370ef3237b612bc191fad1d13c2abe25d 
 src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java


@@ -2,7 +2,9 @@




import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.core.common.Cools;


import com.core.common.SpringUtils;


import com.zy.asrs.entity.*;


import com.zy.asrs.mapper.BasDevpMapper;


import com.zy.asrs.service.*;


import com.zy.asrs.task.AbstractHandler;


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


@@ -68,6 +70,7 @@


                        locMast.setLocSts("D");


                        locMast.setIoTime(now);


                        locMast.setModiTime(now);


                        locMast.setFullPlt(wrkMast.getFullPlt());


                        if (!locMastService.updateById(locMast)) {


//                            exceptionHandle("空板入库 ===>> 修改库位状态失败;[workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());


                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


@@ -94,7 +97,8 @@




                        LocDetl locDetl = locDetlService.selectItem(locMast.getLocNo(), wrkDetl.getMatnr(), wrkDetl.getBatch());


                        if (null != locDetl) {


                            if (!locDetlService.updateAnfme(wrkDetl.getAnfme(), wrkMast.getLocNo(), wrkDetl.getMatnr(), wrkDetl.getBatch())) {


                            Double anfme = locDetl.getAnfme()+wrkDetl.getAnfme();


                            if (!locDetlService.updateAnfme(anfme, wrkMast.getLocNo(), wrkDetl.getMatnr(), wrkDetl.getBatch())) {


//                                exceptionHandle("全板入库 ===>> 更新库存明细失败；[workNo={0}],[locNo={1}]", wrkMast.getWrkNo(), wrkMast.getLocNo());


                                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


                                return FAIL.setMsg("全板入库 ===>> 更新库存明细失败; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");


@@ -116,10 +120,13 @@




                        // 更新订单完成数量


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


                        if (orderDetl==null){


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


                        }


                        try {


                            if(!Cools.isEmpty(orderDetl)){


                                if(!orderDetlService.increaseQtyByOrderNo(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),


                                        wrkDetl.getBatch(),wrkDetl.getAnfme())){


                                        orderDetl.getBatch(),wrkDetl.getAnfme())){


//                                    exceptionHandle("全板入库 ===>> 更新订单完成数量失败；[workNo={0}],[locNo={1}]",


//                                            wrkMast.getWrkNo(), wrkMast.getLocNo());


                                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


@@ -140,6 +147,8 @@


                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


                            return FAIL.setMsg("全板入库 ===>> 修改库位状态失败; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");


                        }


                    }else {


                        exceptionHandle("库位状态不为入库预约状态;[workNo={0}]", wrkMast.getWrkNo());


                    }


                    break;


                // 拣料入库


@@ -164,10 +173,13 @@




                        // 更新订单完成数量


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


                        if (orderDetl==null){


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


                        }


                        try {


                            if(!Cools.isEmpty(orderDetl)){


                                if(!orderDetlService.increaseQtyByOrderNo(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),


                                        wrkDetl.getBatch(),wrkDetl.getAnfme())){


                                        orderDetl.getBatch(),wrkDetl.getAnfme())){


//                                    exceptionHandle("拣料入库 ===>> 更新订单完成数量失败；[workNo={0}],[locNo={1}]",


//                                            wrkMast.getWrkNo(), wrkMast.getLocNo());


                                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


@@ -204,7 +216,8 @@




                        LocDetl locDetl = locDetlService.selectItem(locMast.getLocNo(), wrkDetl.getMatnr(), wrkDetl.getBatch());


                        if (null != locDetl) {


                            if (!locDetlService.updateAnfme(wrkDetl.getAnfme(), locMast.getLocNo(), wrkDetl.getMatnr(), wrkDetl.getBatch())) {


                            Double anfme = locDetl.getAnfme()+wrkDetl.getAnfme();


                            if (!locDetlService.updateAnfme(anfme, locMast.getLocNo(), wrkDetl.getMatnr(), wrkDetl.getBatch())) {


//                                exceptionHandle("并板入库 ===>> 修改库存明细数量失败；[workNo={0}],[matnr={1}]", wrkMast.getWrkNo(), wrkDetl.getMatnr());


                                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


                                return FAIL.setMsg("并板入库 ===>> 修改库存明细数量失败; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");


@@ -223,6 +236,25 @@


                                return FAIL.setMsg("并板入库 ===>> 新增库存明细失败; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");


                            }


                        }


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


                            // 更新订单完成数量


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


                            if (orderDetl==null){


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


                            }


                            try {


                                if(!Cools.isEmpty(orderDetl)){


                                    if(!orderDetlService.increaseQtyByOrderNo(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),


                                            orderDetl.getBatch(),wrkDetl.getAnfme())){


//                                    exceptionHandle("全板入库 ===>> 更新订单完成数量失败；[workNo={0}],[locNo={1}]",


//                                            wrkMast.getWrkNo(), wrkMast.getLocNo());


                                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


                                        return FAIL.setMsg("并板入库 ===>> 更新订单完成数量失败; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");


                                    }


                                }


                            } catch (Exception ignore){}


                        }




                    }


                    // 修改库位状态 Q ====>> F


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


@@ -235,6 +267,8 @@


                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


                            return FAIL.setMsg("并板入库 ===>> 修改库位状态失败; [workNo=" + wrkMast.getWrkNo() + "],[locNo=" + wrkMast.getLocNo() + "]");


                        }


                    }else {


                        exceptionHandle("库位状态不为入库预约状态;[workNo={0}]", wrkMast.getWrkNo());


                    }


                    break;


                // 盘点入库


@@ -300,6 +334,16 @@


                default:


                    break;


            }




            // 更新入库站点的入库暂存数


            int sourceStaNo = wrkMast.getSourceStaNo() == null ? 0 : wrkMast.getSourceStaNo();


            if (sourceStaNo == 1041 || sourceStaNo == 2011 || sourceStaNo == 2001 || sourceStaNo == 3011 ) {


                BasDevpMapper basDevpMapper = SpringUtils.getBean(BasDevpMapper.class);


                BasDevp basDevp = basDevpMapper.selectById(sourceStaNo - 1);


                basDevp.setInQty(basDevp.getInQty() -1);


                basDevpMapper.updateById(basDevp);


            }




            // 修改工作主档状态


            wrkMast.setWrkSts(5L);


            wrkMast.setModiTime(now);


@@ -344,10 +388,13 @@


                    for (WrkDetl wrkDetl : wrkDetls101) {


                        // 更新订单完成数量


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


                        if (orderDetl==null){


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


                        }


                        try {


                            if(!Cools.isEmpty(orderDetl)){


                                if(!orderDetlService.increaseQtyByOrderNo(wrkDetl.getOrderNo(), wrkDetl.getMatnr(),


                                        wrkDetl.getBatch(),wrkDetl.getAnfme())){


                                        orderDetl.getBatch(),wrkDetl.getAnfme())){


//                                    exceptionHandle("全板出库 ===>> 更新订单完成数量失败；[workNo={0}],[locNo={1}]",


//                                            wrkMast.getWrkNo(), wrkMast.getLocNo());


                                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();