自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
#
luxiaotao1123
2021-01-12 4b0fec6fd68a7f6ac0f5b226cf11b3e71cbe68e1 
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java


@@ -4,6 +4,7 @@


import com.baomidou.mybatisplus.mapper.Wrapper;


import com.core.common.BaseRes;


import com.core.common.Cools;


import com.core.common.DateUtils;


import com.core.exception.CoolException;


import com.zy.asrs.entity.*;


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


@@ -13,14 +14,18 @@


import com.zy.asrs.service.*;


import com.zy.asrs.utils.VersionUtils;


import com.zy.common.model.LocDetlDto;


import com.zy.common.model.LocTypeDto;


import com.zy.common.model.OutLocDto;


import com.zy.common.model.StartupDto;


import com.zy.common.model.enums.WorkNoType;


import com.zy.common.service.CommonService;


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


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.util.*;


import java.util.concurrent.TimeUnit;


import java.util.stream.Collectors;




/**


 * Created by vincent on 2020/6/11


@@ -53,6 +58,8 @@


    private AdjDetlService adjDetlService;


    @Autowired


    private WrkMastLogService wrkMastLogService;


    @Autowired


    private WrkDetlLogService wrkDetlLogService;




    @Override


    @Transactional


@@ -62,11 +69,13 @@


            throw new CoolException(BaseRes.PARAM);


        }


        // 源站点状态检测


        BasDevp sourceStaNo = basDevpService.checkSiteStatus(param.getDevpNo());


        // 生成工作号


        int workNo = commonService.getWorkNo(DEFAULT_WORK_NO_TYPE);


        BasDevp sourceStaNo = basDevpService.checkSiteStatus(param.getDevpNo(), true);


        // 检索库位


        StartupDto dto = commonService.getLocNo(DEFAULT_ROW_NO_TYPE, 1, param.getDevpNo());


        LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);


        List<String> matNos = param.getList().stream().map(FullStoreParam.MatCodeStore::getMatNo).distinct().collect(Collectors.toList());


        StartupDto dto = commonService.getLocNo(DEFAULT_ROW_NO_TYPE, 1, param.getDevpNo(), matNos, locTypeDto, 0);


        // 生成工作号


        int workNo = dto.getWorkNo();


        // 生成工作档


        WrkMast wrkMast = new WrkMast();


        wrkMast.setWrkNo(workNo);


@@ -109,8 +118,8 @@


        }


        // 更新目标库位状态


        LocMast locMast = locMastService.selectById(dto.getLocNo());


        if (locMast.getLocType().equals("O")){


            locMast.setLocType("S"); // S.入库预约


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


            locMast.setLocSts("S"); // S.入库预约


            locMast.setModiUser(userId);


            locMast.setModiTime(new Date());


            if (!locMastService.updateById(locMast)){


@@ -183,7 +192,7 @@


                throw new CoolException("出库路径不存在");


            }


            // 生成工作号


            int workNo = commonService.getWorkNo(DEFAULT_WORK_NO_TYPE);


            int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(ioType));


            // 生成工作档


            WrkMast wrkMast = new WrkMast();


            wrkMast.setWrkNo(workNo);


@@ -227,8 +236,8 @@


            }


            // 修改库位状态:   F.在库 ====>>> R.出库预约/P.拣料/盘点/并板出库中


            locMast = locMastService.selectById(dto.getLocNo());


            if (locMast.getLocType().equals("F")) {


                locMast.setLocType(ioType==101?"R":"P");


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


                locMast.setLocSts(ioType==101?"R":"P");


                locMast.setModiUser(userId);


                locMast.setModiTime(new Date());


                if (!locMastService.updateById(locMast)) {


@@ -244,23 +253,23 @@


    @Transactional


    public String emptyPlateIn(Integer devpNo, Long userId) {


        // 源站点状态检测


        BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo);


        // 生成工作号


        int workNo = commonService.getWorkNo(DEFAULT_WORK_NO_TYPE);


        BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true);


        // 检索库位


        StartupDto dto = commonService.getLocNo(DEFAULT_ROW_NO_TYPE, 10, devpNo);


        LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);


        StartupDto dto = commonService.getLocNo(DEFAULT_ROW_NO_TYPE, 10, devpNo, null, locTypeDto, 0);


        int workNo = dto.getWorkNo();


        // 生成工作档


        WrkMast wrkMast = new WrkMast();


        wrkMast.setWrkNo(workNo);


        wrkMast.setIoTime(new Date());


        wrkMast.setWrkSts(1L); // 工作状态：生成入库ID


        wrkMast.setIoType(10); // 入出库状态：10.空板入库


        wrkMast.setIoPri(13D); // 优先级：10


        wrkMast.setIoPri(10D); // 优先级：10


        wrkMast.setCrnNo(dto.getCrnNo());


        wrkMast.setSourceStaNo(dto.getSourceStaNo());


        wrkMast.setStaNo(dto.getStaNo());


        wrkMast.setLocNo(dto.getLocNo());


        wrkMast.setFullPlt("N"); // 满板：Y


        wrkMast.setFullPlt("N"); // 满板


        wrkMast.setPicking("N"); // 拣料


        wrkMast.setExitMk("N"); // 退出


        wrkMast.setEmptyMk("Y"); // 空板


@@ -284,8 +293,8 @@


        }


        // 更新目标库位状态


        LocMast locMast = locMastService.selectById(dto.getLocNo());


        if (locMast.getLocType().equals("O")){


            locMast.setLocType("S"); // S.入库预约


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


            locMast.setLocSts("S"); // S.入库预约


            locMast.setModiUser(userId);


            locMast.setModiTime(new Date());


            if (!locMastService.updateById(locMast)){


@@ -305,7 +314,7 @@


        }


        for (String locNo : param.getLocNos()) {


            // 获取工作号


            int workNo = commonService.getWorkNo(DEFAULT_WORK_NO_TYPE);


            int workNo = commonService.getWorkNo(WorkNoType.PAKOUT.type);


            // 获取库位


            LocMast locMast = locMastService.selectById(locNo);


            if (Cools.isEmpty(locMast)) {


@@ -346,8 +355,8 @@


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


            }


            // 更新库位状态 D.空板 -> R.出库预约


            if (locMast.getLocType().equals("D")){


                locMast.setLocType("R");


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


                locMast.setLocSts("R");


                locMast.setModiUser(userId);


                locMast.setModiTime(new Date());


                if (!locMastService.updateById(locMast)) {


@@ -397,7 +406,7 @@


            throw new CoolException("移转库位属于不同堆垛机");


        }


        // 获取工作号


        int workNo = commonService.getWorkNo(DEFAULT_WORK_NO_TYPE);


        int workNo = commonService.getWorkNo(WorkNoType.PICK.type);


        // 保存工作档


        WrkMast wrkMast = new WrkMast();


        wrkMast.setWrkNo(workNo);


@@ -411,7 +420,7 @@


        wrkMast.setFullPlt("N"); // 满板：Y


        wrkMast.setPicking("N"); // 拣料


        wrkMast.setExitMk("N"); // 退出


        wrkMast.setEmptyMk(sourceLoc.getLocType().equals("D")?"Y":"N"); // 空板


        wrkMast.setEmptyMk(sourceLoc.getLocSts().equals("D")?"Y":"N"); // 空板


        wrkMast.setBarcode(sourceLoc.getBarcode()); // 托盘码


        wrkMast.setLinkMis("N");


        wrkMast.setAppeUser(userId);


@@ -439,26 +448,26 @@


            }


        }


        // 修改源库位状态


        if (sourceLoc.getLocType().equals("D") || sourceLoc.getLocType().equals("F")) {


            sourceLoc.setLocType("R"); // R.出库预约


        if (sourceLoc.getLocSts().equals("D") || sourceLoc.getLocSts().equals("F")) {


            sourceLoc.setLocSts("R"); // R.出库预约


            sourceLoc.setModiUser(userId);


            sourceLoc.setModiTime(new Date());


            if (!locMastService.updateById(sourceLoc)){


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


            }


        } else {


            throw new CoolException("源库位出库失败，状态："+sourceLoc.getLocType$());


            throw new CoolException("源库位出库失败，状态："+sourceLoc.getLocSts$());


        }


        // 修改目标库位状态


        if (loc.getLocType().equals("O")) {


            loc.setLocType("S"); // S.入库预约


        if (loc.getLocSts().equals("O")) {


            loc.setLocSts("S"); // S.入库预约


            loc.setModiTime(new Date());


            loc.setModiUser(userId);


            if (!locMastService.updateById(loc)) {


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


            }


        } else {


            throw new CoolException("移转失败，目标库位状态："+loc.getLocType$());


            throw new CoolException("移转失败，目标库位状态："+loc.getLocSts$());


        }


    }




@@ -479,8 +488,13 @@


        } else if (wrkMast.getWrkSts() > 10) {


            wrkMast.setWrkSts(14L);


        }


        wrkMast.setModiTime(new Date());


        Date now = new Date();


        wrkMast.setCrnStrTime(DateUtils.calculate(now, 1L, TimeUnit.SECONDS, true));


        wrkMast.setCrnEndTime(now);


        wrkMast.setModiTime(now);


        wrkMast.setModiUser(userId);


        // 完成操作人员记录


        wrkMast.setManuType("手动完成");


        if (!wrkMastService.updateById(wrkMast)) {


            throw new CoolException("修改工作档失败");


        }


@@ -555,6 +569,15 @@


                }


            }


        }


        List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", param.getLocNo()));


        if (locDetls.isEmpty()) {


            locMast.setLocSts("D");


            locMast.setModiUser(userId);


            locMast.setModiTime(new Date());


            if (!locMastService.updateById(locMast)) {


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


            }


        }


    }




    @Override


@@ -565,11 +588,11 @@


            throw new CoolException(workNo+"工作档不存在");


        }


        String locNo = ""; // 待修改目标库位


        String locType = ""; // 待修改目标库位状态


        String locSts = ""; // 待修改目标库位状态


        // 入库取消（修改目标库位）


        if (wrkMast.getWrkSts() < 4) {


            locNo = wrkMast.getLocNo();


            locType = "O";


            locSts = "O";


            /**


             * 库位转移


             * 取消后 源库位 ==>> F.在库


@@ -581,7 +604,7 @@


                if (Cools.isEmpty(locMast)) {


                    throw new CoolException("取消库位转移失败，源库位不存在:"+ wrkMast.getSourceLocNo());


                }


                locMast.setLocType("F");


                locMast.setLocSts("F");


                locMast.setModiTime(new Date());


                locMast.setModiUser(userId);


                locMastService.updateById(locMast);


@@ -591,19 +614,19 @@


            locNo = wrkMast.getSourceLocNo();


            // 出库 ===>> F.在库


            if (wrkMast.getIoType() > 100 && wrkMast.getIoType() != 110) {


                locType = "F";


                locSts = "F";


            // 空板出库 ===>> D.空桶/空栈板


            } else if (wrkMast.getIoType() == 110) {


                locType = "D";


                locSts = "D";


            // 库位转移 ===>> D.空桶/空栈板


            } else if (wrkMast.getIoType() == 11) {


                locType = "F";


                locSts = "F";


                // 库位转移：目标库位


                LocMast locMast = locMastService.selectById(wrkMast.getLocNo());


                if (Cools.isEmpty(locMast)) {


                    throw new CoolException("取消库位转移失败，目标库位不存在:"+ wrkMast.getSourceLocNo());


                }


                locMast.setLocType("O");


                locMast.setLocSts("O");


                locMast.setModiTime(new Date());


                locMast.setModiUser(userId);


                locMastService.updateById(locMast);


@@ -611,8 +634,23 @@


        } else {


            throw new CoolException("当前工作状态无法取消");


        }


        // 删除工作档


        // 取消操作人员记录


        wrkMast.setManuType("手动取消");


        wrkMast.setModiUser(userId);


        wrkMast.setModiTime(new Date());


        if (!wrkMastService.updateById(wrkMast)) {


            throw new CoolException("取消工作档失败");


        }


        // 保存工作主档历史档


        if (!wrkMastLogService.save(wrkMast.getWrkNo())) {


            throw new CoolException("保存工作历史档失败, workNo = " + wrkMast.getWrkNo());


        }


        // 删除工作主档


        boolean wrkMastRes = wrkMastService.deleteById(wrkMast);


        // 保存工作明细档历史档


        if (!wrkDetlLogService.save(wrkMast.getWrkNo())) {


            throw new CoolException("保存工作明细历史档失败, workNo = " + wrkMast.getWrkNo());


        }


        // 删除工作档明细


        boolean wrkDetlRes = wrkDetlService.delete(new EntityWrapper<WrkDetl>().eq("wrk_no", workNo));


        // 修改库位状态


@@ -620,7 +658,7 @@


        if (Cools.isEmpty(locMast)) {


            throw new CoolException("取消工作档失败，库位不存在:"+ locNo);


        }


        locMast.setLocType(locType);


        locMast.setLocSts(locSts);


        locMast.setModiTime(new Date());


        locMast.setModiUser(userId);


        boolean locMastRes = locMastService.updateById(locMast);


@@ -645,9 +683,9 @@


            throw new CoolException("当前工作状态无法进行操作");


        }


        // 保存工作明细档历史档


//        if (!wrkDetlLogService.save(wrkMast.getWrkNo())) {


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


//        }


        if (!wrkDetlLogService.save(wrkMast.getWrkNo())) {


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


        }


        // 保存工作主档历史档


        if (!wrkMastLogService.save(wrkMast.getWrkNo())) {


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


@@ -677,7 +715,7 @@


        }


        // 修改库位状态 Q.拣料/盘点/并板再入库


        LocMast locMast = locMastService.selectById(wrkMast.getLocNo());


        locMast.setLocType("Q");


        locMast.setLocSts("Q");


        locMast.setModiTime(new Date());


        locMast.setModiUser(userId);


        if (!locMastService.updateById(locMast)) {