#

luxiaotao1123

2020-07-07 6aa54366fa3c46567875e7df66dab43f4b897792

 src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java

@@ -1,14 +1,8 @@
package com.zy.asrs.task.handler;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.zy.asrs.entity.LocDetl;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.WrkDetl;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.service.LocDetlService;
import com.zy.asrs.service.LocMastService;
import com.zy.asrs.service.WrkDetlService;
import com.zy.asrs.service.WrkMastService;
import com.zy.asrs.entity.*;
import com.zy.asrs.service.*;
import com.zy.asrs.task.AbstractHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -32,11 +26,13 @@
    private LocMastService locMastService;
    @Autowired
    private LocDetlService locDetlService;
    @Autowired
    private WaitPakinService waitPakinService;

    public void start() {
    public boolean start() {
        List<WrkMast> wrkMasts = wrkMastService.selectToBeCompleteData();
        if (wrkMasts.isEmpty()) {
            return;
            return true;
        }
        for (WrkMast wrkMast : wrkMasts) {
            // 4.入库完成
@@ -47,16 +43,21 @@
                doOut(wrkMast);
            }
        }
        return true;
    }

    private void doIn(WrkMast wrkMast){
        Date now = new Date();
        LocMast locMast = locMastService.selectById(wrkMast.getLocNo());
        if (null == locMast) {
            exceptionHandle(""); // todo
            return;
        }
        switch (wrkMast.getIoType()) {
            // 空板入库
            case 10:
                // 修改库位状态=D
                LocMast locMast = locMastService.selectById(wrkMast.getLocNo());
                if (null != locMast && (locMast.getLocType().equals("S") || locMast.getLocType().equals("Q"))) {
                if (locMast.getLocType().equals("S") || locMast.getLocType().equals("Q")) {
                    locMast.setLocType("D");
                    locMast.setIoTime(now);
                    locMast.setModiTime(now);
@@ -65,25 +66,24 @@
                    }
                }
                break;
            // 全板入库
            case 1:

                // 清除所属库位之前的库存明细
                List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getLocNo()));
                if (!locDetls.isEmpty()) {
                    locDetlService.delete(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getLocNo()));
                }

                // 根据工作号，查询工作明细档
                List<WrkDetl> wrkDetls = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
                if (wrkDetls.isEmpty()) {
                    exceptionHandle(""); // todo
                }

                // 遍历工作明细，更新库存明细和入库通知档
                for (WrkDetl wrkDetl : wrkDetls) {

                    LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getLocNo()).eq("matnr", wrkDetl.getMatnr()));
                    if (null != locDetl) {
                        locDetl.setAnfme(wrkDetl.getAnfme());
                        locDetl.setModiTime(now);
                        if (!locDetlService.updateById(locDetl)) {
                        boolean res = locDetlService.updateAnfme(wrkDetl.getAnfme(), wrkMast.getLocNo(), wrkDetl.getMatnr());
                        if (!res) {
                            exceptionHandle(""); // todo
                        }
                    } else {
@@ -94,47 +94,242 @@
                                null,    // 转储请求编号
                                null,    // 行项目
                                null,    // 物料标签ID
                                null,    // 物料描述
                                wrkDetl.getMaktx(),    // 物料描述
                                null,    // 工厂
                                null,    // 数量
                                null,    // 单位
                                null,    // 托盘条码
                                wrkDetl.getAnfme(),    // 数量
                                wrkDetl.getAltme(),    // 单位
                                wrkDetl.getZpallet(),    // 托盘条码
                                null,    // 用户ID
                                null,    // 备注
                                null,    // 修改人员
                                null,    // 修改时间
                                now,    // 修改时间
                                null,    // 创建者
                                null    // 添加时间
                                now    // 添加时间
                        );
                        // todo

                        if (!locDetlService.insert(locDetl)) {
                            exceptionHandle(""); // todo
                        }
                    }


                    // 更新入库通知档 status ===>> Y
                    WaitPakin setParam = new WaitPakin();
                    setParam.setStatus("Y");
                    boolean updateRes = waitPakinService.update(setParam
                            , new EntityWrapper<WaitPakin>().eq("barcode", wrkDetl.getZpallet())
                                    .eq("matnr", wrkDetl.getMatnr())
                                    .eq("anfme", wrkDetl.getAnfme()));
                    if (!updateRes) {
                        exceptionHandle(""); // todo
                    }
                }



                // 修改库位状态 S ====>> F
                if (locMast.getLocType().equals("S")) {
                    locMast.setLocType("F");
                    locMast.setBarcode(wrkMast.getBarcode());
                    locMast.setIoTime(now);
                    locMast.setModiTime(now);
                    if (!locMastService.updateById(locMast)) {
                        exceptionHandle(""); // todo
                    }
                }
                break;
            // 拣料入库
            case 53:
                // 根据工作号，查询工作明细档
                List<WrkDetl> wrkDetls53 = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
                if (wrkDetls53.isEmpty()) {
                    exceptionHandle(""); // todo
                }
                for (WrkDetl wrkDetl:wrkDetls53) {
                    // 修改库存明细数量，如果工作明细数量为0时，删除库存明细
                    LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()).eq("matnr", wrkDetl.getMatnr()));
                    if (null != locDetl) {
                        if (!locDetlService.updateAnfme(wrkDetl.getAnfme(), locMast.getLocNo(), wrkDetl.getMatnr())) {
                            exceptionHandle(""); // todo
                        }
                        // todo:luxiaotao 3)修改出库通知档 status ==> Y
                    }
                }
                // 修改库位状态 Q ====>> F
                if (locMast.getLocType().equals("Q")) {
                    locMast.setLocType("F");
                    locMast.setBarcode(wrkMast.getBarcode());
                    locMast.setIoTime(now);
                    locMast.setModiTime(now);
                    if (!locMastService.updateById(locMast)) {
                        exceptionHandle(""); // todo
                    }
                }
                break;
            // 并板入库
            case 54:
                // 根据工作号，查询工作明细档
                List<WrkDetl> wrkDetls54 = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
                if (wrkDetls54.isEmpty()) {
                    exceptionHandle(""); // todo
                }
                // 修改库存明细数量，如无库存，曾新增
                for (WrkDetl wrkDetl:wrkDetls54) {
                    LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()).eq("matnr", wrkDetl.getMatnr()));
                    if (null != locDetl) {
                        if (!locDetlService.updateAnfme(wrkDetl.getAnfme(), locMast.getLocNo(), wrkDetl.getMatnr())) {
                            exceptionHandle(""); // todo
                        }
                    } else {
                        locDetl = new LocDetl(
                                wrkMast.getLocNo(), // 库位号
                                wrkDetl.getMatnr(), // 物料号
                                null,    // 仓库号
                                null,    // 转储请求编号
                                null,    // 行项目
                                null,    // 物料标签ID
                                wrkDetl.getMaktx(),    // 物料描述
                                null,    // 工厂
                                wrkDetl.getAnfme(),    // 数量
                                wrkDetl.getAltme(),    // 单位
                                wrkDetl.getZpallet(),    // 托盘条码
                                null,    // 用户ID
                                null,    // 备注
                                null,    // 修改人员
                                now,    // 修改时间
                                null,    // 创建者
                                now    // 添加时间
                        );
                        if (!locDetlService.insert(locDetl)) {
                            exceptionHandle(""); // todo
                        }
                    }
                    // todo:luxiaotao 3)修改出库通知档 status ==> Y
                }
                // 修改库位状态 Q ====>> F
                if (locMast.getLocType().equals("Q")) {
                    locMast.setLocType("F");
                    locMast.setBarcode(wrkMast.getBarcode());
                    locMast.setIoTime(now);
                    locMast.setModiTime(now);
                    if (!locMastService.updateById(locMast)) {
                        exceptionHandle(""); // todo
                    }
                }
                break;
            // 盘点入库
            case 57:
                // 根据工作号，查询工作明细档
                List<WrkDetl> wrkDetls57 = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
                if (wrkDetls57.isEmpty()) {
                    exceptionHandle(""); // todo
                }
                // todo:luxiaotao 3)修改盘点通知档 status ==> Y
                // 修改库位状态 Q ====>> F
                if (locMast.getLocType().equals("Q")) {
                    locMast.setLocType("F");
                    locMast.setBarcode(wrkMast.getBarcode());
                    locMast.setIoTime(now);
                    locMast.setModiTime(now);
                    if (!locMastService.updateById(locMast)) {
                        exceptionHandle(""); // todo
                    }
                }
                break;
            // 库位移转
            case 11:
                // 默认目标库位是空板
                String locType = "D";
                // 库位移转判断是否为空板移转
                if (wrkMast.getEmptyMk().equals("N")) {
                    locType = "F";
                    // 转移库存明细数据: 库存号 由工作档源库位变为目标库位
                    if (!locDetlService.updateLocNo(wrkMast.getLocNo(), wrkMast.getSourceLocNo())) {
                        exceptionHandle(""); // todo
                    }
                }
                // todo:luxiaotao 3)修改盘点通知档 status ==> Y
                // 修改源库位状态 ==> O
                LocMast sourceLoc = locMastService.selectById(wrkMast.getSourceLocNo());
                if (null != sourceLoc) {
                    sourceLoc.setBarcode("");
                    sourceLoc.setLocType("O");
                    sourceLoc.setModiTime(now);
                    sourceLoc.setIoTime(now);
                    if (!locMastService.updateById(sourceLoc)) {
                        exceptionHandle(""); // todo
                    }
                }
                // 修改目标库位状态 ==> .locType
                locMast.setLocType(locType);
                locMast.setBarcode(wrkMast.getBarcode());
                locMast.setIoTime(now);
                locMast.setModiTime(now);
                if (!locMastService.updateById(locMast)) {
                    exceptionHandle(""); // todo
                }
                break;
            default:
                break;
        }
        // 修改工作主档状态
        wrkMast.setWrkSts(5L);
        wrkMast.setModiTime(now);
        if (!wrkMastService.updateById(wrkMast)) {
            exceptionHandle(""); // todo
        }
    }

    private void doOut(WrkMast wrkMast){

        Date now = new Date();
        LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo());
        if (null == locMast) {
            exceptionHandle(""); // todo
            return;
        }
        switch (wrkMast.getIoType()) {
            // 全板出库
            case 101:
                // 根据工作号，查询工作明细档
                List<WrkDetl> wrkDetls101 = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));
                if (wrkDetls101.isEmpty()) {
                    exceptionHandle(""); // todo
                }
                for (WrkDetl wrkDetl : wrkDetls101) {
                    // todo:luxiaotao 3)修改出库通知档 status ==> Y
                }
                // 删除工作档源库位的库存明细
                if (!locDetlService.delete(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getSourceLocNo()))) {
                    exceptionHandle(""); // todo
                }
                // 修改库位状态 R ===>> O
                if (locMast.getLocType().equals("R")) {
                    locMast.setLocType("O");
                    locMast.setBarcode("");
                    locMast.setModiTime(now);
                    locMast.setIoTime(now);
                    if (!locMastService.updateById(locMast)) {
                        exceptionHandle(""); // todo
                    }
                }
                break;
            // 空板出库
            case 110:
                // 修改库位状态 R ===>> O
                if (locMast.getLocType().equals("R")) {
                    locMast.setLocType("O");
                    locMast.setBarcode("");
                    locMast.setModiTime(now);
                    locMast.setIoTime(now);
                    if (!locMastService.updateById(locMast)) {
                        exceptionHandle(""); // todo
                    }
                }
                break;
            default:
                break;
        }
        // 修改工作主档状态
        wrkMast.setWrkSts(15L);
        wrkMast.setModiTime(now);
        if (!wrkMastService.updateById(wrkMast)) {
            exceptionHandle(""); // todo
        }
    }




    public static void main(String[] args) {
        for (int i = 0;i<10;i++) {