1

ZY

2025-03-29 c65db22f67af8018ae7105ea00d8743e42835e13

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

@@ -1,6 +1,7 @@
package com.zy.asrs.task.handler;


import com.baomidou.mybatisplus.enums.SqlLike;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.exception.CoolException;
@@ -9,6 +10,8 @@
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.common.service.AgvCommonService;
import com.zy.system.entity.Config;
import com.zy.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -34,22 +37,25 @@
    private AgvWrkDetlService agvWrkDetlService;
    @Autowired
    AgvBasDevpService agvBasDevpService;
    @Autowired
    private ConfigService configService;

    public ReturnT<String> start(AgvLocMast agvLocMast) {
        // locType 1. 自动， 2. 手动
        if (agvLocMast.getLocType().equals("1")) {
            return doAutoMove(agvLocMast);
        } else if (agvLocMast.getLocType().equals("2")) {
            return doHandMove(agvLocMast);
        }
        return SUCCESS;
    }
//    public ReturnT<String> start(AgvLocMast agvLocMast) {
//        // locType 1. 自动， 2. 手动
//        if (agvLocMast.getLocType().equals("1")) {
//            return doAutoMove(agvLocMast);
//        } else if (agvLocMast.getLocType().equals("2")) {
//            return doHandMove(agvLocMast);
//        }
//        return SUCCESS;
//    }

    public ReturnT<String> start2(AgvWrkMast agvWrkMast) {
        // locType 1. 自动， 2. 手动
        doAutoMove2(agvWrkMast);
        return SUCCESS;
    }

    public ReturnT<String> start3(AgvWrkMast agvWrkMast) {
        // locType 1. 自动， 2. 手动
        doHandMove2(agvWrkMast);
@@ -62,73 +68,73 @@
        return SUCCESS;
    }
    //根据库位的loctype值发送任务--弃用
    private ReturnT<String> doAutoMove(AgvLocMast agvLocMast) {
        Date now = new Date();
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
        if(!Cools.isEmpty(agvWrkMast)){
            throw new CoolException("当前"+agvLocMast.getBarcode()+"货架码已在工作档中");
        }
        //检索库位，选择合适的库位
        AgvLocMast LocMast = agvCommonService.getLocNo(3,agvLocMast.getLocType3(),false,true);
        //生成工作档
        AgvWrkMast mast = new AgvWrkMast();
        //工作状态
        mast.setWrkSts(201L);
        //入出库类型
        mast.setIoType(108);
        mast.setIoTime(now);
        //优先级
        mast.setIoPri(300.0);
        //源站点
        mast.setSourceLocNo(agvLocMast.getLocNo());
        //目标站点
        mast.setLocNo(LocMast.getLocNo());
        //货架编码
        mast.setBarcode(agvLocMast.getBarcode());
        //货架类型
        mast.setWhsType(30);

        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
        mast.setModiUser(9527L);
        mast.setModiTime(now);
        mast.setLogErrMemo("doAutoMove");
        if (!agvWrkMastService.insertByIncrease(mast)) {
            throw new CoolException("保存工作档失败");
        }

        AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", LocMast.getLocNo()).eq("source_loc_no",agvLocMast.getLocNo()));
        //生成工作档明细
        List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
        agvLocDetls.forEach(agvLocDetl -> {
            AgvWrkDetl wrkDetl = new AgvWrkDetl();
            wrkDetl.setWrkNo(mast1.getWrkNo());
            wrkDetl.sync(agvLocDetl);
            wrkDetl.setSpecs("1-" + agvLocMast.getLocType3());
            wrkDetl.setSuppCode(agvLocDetl.getSuppCode());
            wrkDetl.setIoTime(now);
            wrkDetl.setAppeUser(9527L);
            wrkDetl.setAppeTime(now);
            wrkDetl.setModiUser(9527L);
            wrkDetl.setModiTime(now);
            if (!agvWrkDetlService.insert(wrkDetl)) {
                throw new CoolException("保存工作明细失败");
            }
        });
        //更新目标库位状态
        updateAgvLocMast(agvLocMast,"R");
        updateAgvLocMast(LocMast,"S");

        return SUCCESS;
    }
//    private ReturnT<String> doAutoMove(AgvLocMast agvLocMast) {
//        Date now = new Date();
//        //查询工作档
//        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
//        if(!Cools.isEmpty(agvWrkMast)){
//            throw new CoolException("当前"+agvLocMast.getBarcode()+"货架码已在工作档中");
//        }
//        //检索库位，选择合适的库位
//        AgvLocMast LocMast = agvCommonService.getLocNo(3,agvLocMast.getLocType3(),false,true);
//        //生成工作档
//        AgvWrkMast mast = new AgvWrkMast();
//        //工作状态
//        mast.setWrkSts(201L);
//        //入出库类型
//        mast.setIoType(108);
//        mast.setIoTime(now);
//        //优先级
//        mast.setIoPri(300.0);
//        //源站点
//        mast.setSourceLocNo(agvLocMast.getLocNo());
//        //目标站点
//        mast.setLocNo(LocMast.getLocNo());
//        //货架编码
//        mast.setBarcode(agvLocMast.getBarcode());
//        //货架类型
//        mast.setWhsType(30);
//
//        mast.setAppeUser(9527L);
//        mast.setAppeTime(now);
//        mast.setModiUser(9527L);
//        mast.setModiTime(now);
//        mast.setLogErrMemo("doAutoMove");
//        if (!agvWrkMastService.insertByIncrease(mast)) {
//            throw new CoolException("保存工作档失败");
//        }
//
//        AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", LocMast.getLocNo()).eq("source_loc_no",agvLocMast.getLocNo()));
//        //生成工作档明细
//        List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
//        agvLocDetls.forEach(agvLocDetl -> {
//            AgvWrkDetl wrkDetl = new AgvWrkDetl();
//            wrkDetl.setWrkNo(mast1.getWrkNo());
//            wrkDetl.sync(agvLocDetl);
//            wrkDetl.setSpecs("1-" + agvLocMast.getLocType3());
//            wrkDetl.setSuppCode(agvLocDetl.getSuppCode());
//            wrkDetl.setIoTime(now);
//            wrkDetl.setAppeUser(9527L);
//            wrkDetl.setAppeTime(now);
//            wrkDetl.setModiUser(9527L);
//            wrkDetl.setModiTime(now);
//            if (!agvWrkDetlService.insert(wrkDetl)) {
//                throw new CoolException("保存工作明细失败");
//            }
//        });
//        //更新目标库位状态
//        updateAgvLocMast(agvLocMast,"R");
//        updateAgvLocMast(LocMast,"S");
//
//        return SUCCESS;
//    }

    private ReturnT<String> doHandMove(AgvLocMast agvLocMast) {
        Date now = new Date();
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
        if(!Cools.isEmpty(agvWrkMast)){
            throw new CoolException("当前"+agvLocMast.getBarcode()+"货架码已在工作档中");
        if (!Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("当前" + agvLocMast.getBarcode() + "货架码已在工作档中");
        }
//        //检索库位，选择合适的库位
//        AgvLocMast LocMast = agvCommonService.getLocNo(3,agvLocMast.getLocType3());
@@ -150,7 +156,8 @@
        //货架编码
        mast.setBarcode(agvLocMast.getBarcode());
        //货架类型
        mast.setWhsType(30);
        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0, 2)));

        // 目标楼层
        mast.setPauseMk(agvLocMast.getLocType3().toString());

@@ -162,7 +169,7 @@
            throw new CoolException("保存工作档失败");
        }

        AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", devpNo.getDevNo()).eq("source_loc_no",agvLocMast.getLocNo()));
        AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", devpNo.getDevNo()).eq("source_loc_no", agvLocMast.getLocNo()));
        //生成工作档明细
        List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
        agvLocDetls.forEach(agvLocDetl -> {
@@ -181,30 +188,44 @@
            }
        });
        //更新目标库位状态
        updateAgvLocMast(agvLocMast,"R");
        updateAgvBasDevp(devpNo,"S",null,agvLocMast.getBarcode());
        updateAgvLocMast(agvLocMast, "R");
        updateAgvBasDevp(devpNo, "S", null, agvLocMast.getBarcode());
        return SUCCESS;
    }


    private ReturnT<String> doAutoMove2(AgvWrkMast agvWrkMast) {
        Date now = new Date();
        //检索库位，选择合适的库位
        AgvLocMast locMast = agvCommonService.getLocNo(3,agvWrkMast.getCrnNo(),false,true);
        String barcode = agvWrkMast.getBarcode();
        AgvLocMast locMast;
        if (Integer.parseInt(barcode.substring(0, 2)) == 31) {
            //检索库位，选择合适的库位
            locMast = agvCommonService.getLocByLocRule(6, 2, 1);
        } else {
            //检索库位，选择合适的库位
            locMast = agvCommonService.getLocNo(3, agvWrkMast.getCrnNo(), false, true);
        }

        if (Cools.isEmpty(locMast)) {
            throw new CoolException("暂无库位");
            log.info("暂无库位");
            return FAIL;
            //throw new CoolException("暂无库位");
        }
        AgvWrkMast workingMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", locMast.getLocNo()));
        if (!Cools.isEmpty(workingMast)) {
            throw new CoolException("当前库位正在进行入库，进行下一次轮询");
            log.info("当前库位正在进行入库，进行下一次轮询");
            return FAIL;
            //throw new CoolException("当前库位正在进行入库，进行下一次轮询");
        }
        agvWrkMast.setWrkSts(201L);
        agvWrkMast.setModiTime(new Date());
        agvWrkMast.setLocNo(locMast.getLocNo());
        agvWrkMast.setLogErrMemo("start2-doAutoMove2");
        agvWrkMastService.updateById(agvWrkMast);
        //更新目标库位状态
        updateAgvLocMast(locMast,"S");
        updateAgvLocMast(locMast, "S");
        AgvLocMast locMast1 = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", locMast.getLocNo()));
        log.info("自动调拨任务 ==> 源库位：{}，目标库位：{},库位状态{}",agvWrkMast.getSourceLocNo(),agvWrkMast.getLocNo(),locMast1.getLocSts());
        log.info("自动调拨任务 ==> 源库位：{}，目标库位：{},库位状态{}", agvWrkMast.getSourceLocNo(), agvWrkMast.getLocNo(), locMast1.getLocSts());

        return SUCCESS;
    }
@@ -212,9 +233,11 @@
    private ReturnT<String> doAutoMove3(AgvWrkMast agvWrkMast) {
        Date now = new Date();
        //检索库位，选择合适的库位
        AgvLocMast locMast = agvCommonService.getLocNo(3,agvWrkMast.getCrnNo(),false,false);
        AgvLocMast locMast = agvCommonService.getLocNo(3, agvWrkMast.getCrnNo(), false, false);
        if (Cools.isEmpty(locMast)) {
            throw new CoolException("暂无库位");
            log.info("暂无库位");
            return FAIL;
            //throw new CoolException("暂无库位");
        }
        agvWrkMast.setWrkSts(201L);
        agvWrkMast.setLocNo(locMast.getLocNo());
@@ -222,7 +245,7 @@
        agvWrkMast.setModiTime(new Date());
        agvWrkMastService.updateById(agvWrkMast);
        //更新目标库位状态
        updateAgvLocMast(locMast,"S");
        updateAgvLocMast(locMast, "S");

        return SUCCESS;
    }
@@ -238,7 +261,9 @@
        }

        if (Cools.isEmpty(devpNo)) {
            throw new CoolException("暂无空闲接驳位");
            log.info("暂无空闲接驳位");
            return FAIL;
            //throw new CoolException("暂无空闲接驳位");
        }
        agvWrkMast.setWrkSts(201L);
        agvWrkMast.setLocNo(devpNo.getDevNo());
@@ -246,27 +271,30 @@
        agvWrkMast.setLogErrMemo("start3-doHandMove2");
        agvWrkMastService.updateById(agvWrkMast);
        agvWrkMast.setModiTime(new Date());
        updateAgvBasDevp(devpNo,"S",null,agvWrkMast.getBarcode());
        updateAgvBasDevp(devpNo, "S", null, agvWrkMast.getBarcode());
        return SUCCESS;
    }

    /*
    更新目标库位信息
     */
    private void updateAgvLocMast(AgvLocMast locMast, String locSts){
    private void updateAgvLocMast(AgvLocMast locMast, String locSts) {
        locMast.setLocSts(locSts);
        agvLocMastService.updateById(locMast);
    }

    /*
    更新源站点信息
     */
    private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts){
        if(!Cools.isEmpty(agvBasDevp)){
    private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts) {
        if (!Cools.isEmpty(agvBasDevp)) {
            agvBasDevp.setLocSts(locSts);
            agvBasDevpService.updateById(agvBasDevp);
        }
    }
    private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts, Short continerType, String containerCode){
        if(!Cools.isEmpty(agvBasDevp)){

    private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts, Short continerType, String containerCode) {
        if (!Cools.isEmpty(agvBasDevp)) {
            agvBasDevp.setLocSts(locSts);
            agvBasDevp.setBarcode(containerCode);
            agvBasDevpService.updateById(agvBasDevp);
@@ -277,8 +305,8 @@
        Date now = new Date();
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
        if(!Cools.isEmpty(agvWrkMast)){
            throw new CoolException("当前"+agvLocMast.getBarcode()+"货架码已在工作档中");
        if (!Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("当前" + agvLocMast.getBarcode() + "货架码已在工作档中");
        }
        //检索空闲接驳位，选择合适的接驳位
        AgvBasDevp devpNo = agvCommonService.getDevpNo(3, agvLocMast.getFloor());
@@ -298,7 +326,8 @@
        //货架编码
        mast.setBarcode(agvLocMast.getBarcode());
        //货架类型
        mast.setWhsType(30);
        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0, 2)));


        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
@@ -310,15 +339,16 @@
        }

        //更新目标库位状态
        updateAgvLocMast(agvLocMast,"R");
        updateAgvBasDevp(devpNo,"S",agvLocMast.getLocType2(),agvLocMast.getBarcode());
        updateAgvLocMast(agvLocMast, "R");
        updateAgvBasDevp(devpNo, "S", agvLocMast.getLocType2(), agvLocMast.getBarcode());
        return SUCCESS;
    }

    public ReturnT<String> autoEmptyBack3(AgvWrkMast agvWrkMast) {
        Date now = new Date();
        AgvBasDevp agvBasDevp = agvBasDevpService.selectByDevNo(agvWrkMast.getSourceLocNo());
        //检索空闲接驳位，选择合适的接驳位
        AgvLocMast locMast = agvCommonService.getLocNo(3, 1,true,true);
        AgvLocMast locMast = agvCommonService.getLocNo(3, 1, true, true);
        if (Cools.isEmpty(locMast)) {
            throw new CoolException("1楼暂无空库位");
        }
@@ -332,58 +362,59 @@
            throw new CoolException("保存工作档失败");
        }
        //更新目标库位状态
        updateAgvLocMast(locMast,"S");
        updateAgvBasDevp(agvBasDevp,"R");
        updateAgvLocMast(locMast, "S");
        updateAgvBasDevp(agvBasDevp, "R");
        return SUCCESS;
    }
    public ReturnT<String> autoEmptyBack2(AgvLocMast agvLocMast) {
        Date now = new Date();
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
        if(!Cools.isEmpty(agvWrkMast)){
            throw new CoolException("当前"+agvLocMast.getBarcode()+"货架码已在工作档中");
        }
        //检索库位，选择合适的库位
        AgvLocMast LocMast = agvCommonService.getLocNo(3,1,true,true);
        //生成工作档
        AgvWrkMast mast = new AgvWrkMast();
        //工作状态
        mast.setWrkSts(201L);
        //入出库类型
        mast.setIoType(109);
        mast.setIoTime(now);
        //优先级
        mast.setIoPri(300.0);
        //源站点
        mast.setSourceLocNo(agvLocMast.getLocNo());
        //目标站点
        mast.setLocNo(LocMast.getLocNo());
        //货架编码
        mast.setBarcode(agvLocMast.getBarcode());
        //货架类型
        mast.setWhsType(30);

        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
        mast.setModiUser(9527L);
        mast.setModiTime(now);
        mast.setLogErrMemo("autoEmptyBack2");
        if (!agvWrkMastService.insertByIncrease(mast)) {
            throw new CoolException("保存工作档失败");
        }

        //更新目标库位状态
        updateAgvLocMast(agvLocMast,"R");
        updateAgvLocMast(LocMast,"S");
        return SUCCESS;
    }
//    public ReturnT<String> autoEmptyBack2(AgvLocMast agvLocMast) {
//        Date now = new Date();
//        //查询工作档
//        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
//        if(!Cools.isEmpty(agvWrkMast)){
//            throw new CoolException("当前"+agvLocMast.getBarcode()+"货架码已在工作档中");
//        }
//        //检索库位，选择合适的库位
//        AgvLocMast LocMast = agvCommonService.getLocNo(3,1,true,true);
//        //生成工作档
//        AgvWrkMast mast = new AgvWrkMast();
//        //工作状态
//        mast.setWrkSts(201L);
//        //入出库类型
//        mast.setIoType(109);
//        mast.setIoTime(now);
//        //优先级
//        mast.setIoPri(300.0);
//        //源站点
//        mast.setSourceLocNo(agvLocMast.getLocNo());
//        //目标站点
//        mast.setLocNo(LocMast.getLocNo());
//        //货架编码
//        mast.setBarcode(agvLocMast.getBarcode());
//        //货架类型
//        mast.setWhsType(30);
//
//        mast.setAppeUser(9527L);
//        mast.setAppeTime(now);
//        mast.setModiUser(9527L);
//        mast.setModiTime(now);
//        mast.setLogErrMemo("autoEmptyBack2");
//        if (!agvWrkMastService.insertByIncrease(mast)) {
//            throw new CoolException("保存工作档失败");
//        }
//
//        //更新目标库位状态
//        updateAgvLocMast(agvLocMast,"R");
//        updateAgvLocMast(LocMast,"S");
//        return SUCCESS;
//    }

    public ReturnT<String> autoEmptyBack4(AgvLocMast agvLocMast) {
        Date now = new Date();
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
        if(!Cools.isEmpty(agvWrkMast)){
            throw new CoolException("当前"+agvLocMast.getBarcode()+"货架码已在工作档中");
        if (!Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("当前" + agvLocMast.getBarcode() + "货架码已在工作档中");
        }
        String floor = "";
        String locNo = "";
@@ -392,22 +423,26 @@
        AgvLocMast locMast = new AgvLocMast();
        if (agvLocMast.getFloor() == 3) {
            floor = "F3";
        } else if(agvLocMast.getFloor() == 2) {
        } else if (agvLocMast.getFloor() == 2) {
            floor = "F2";
        } else if (agvLocMast.getFloor() == 1 && agvLocMast.getLev1() == 2) {
            floor = "02F1";
        }
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 109).like("source_loc_no", floor).or().eq("io_type", 113));
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 109).like("barcode", "30",SqlLike.RIGHT).like("source_loc_no", floor).or().eq("io_type", 113));
        if (agvWrkMasts.size() >= 5) {
            throw new CoolException("暂停回流");
            //log.error("暂停回流");
            return FAIL;
            //throw new CoolException("暂停回流");
        }
        //检索空闲可入接驳位 没有空闲可入接驳位 直接找库位
        AgvBasDevp devpNo = agvCommonService.getDevpNo(3, agvLocMast.getFloor(),"Y","Y");
        AgvBasDevp devpNo = agvCommonService.getDevpNo(3, agvLocMast.getFloor(), "Y", "Y");
        if (!Cools.isEmpty(devpNo)) {
            locNo = devpNo.getDevNo();
            wrkSts = 21L;
            ioType = 109;
        } else {
            //检索库位，选择合适的库位
            locMast = agvCommonService.getLocNo(3,1,true,true);
            locMast = agvCommonService.getLocNo(3, 1, true, true);
            locNo = locMast.getLocNo();
            wrkSts = 201L;
            ioType = 109;
@@ -429,7 +464,8 @@
        //货架编码
        mast.setBarcode(agvLocMast.getBarcode());
        //货架类型
        mast.setWhsType(30);
        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0, 2)));


        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
@@ -441,22 +477,108 @@
        }

        //更新目标库位状态
        updateAgvLocMast(agvLocMast,"R");
        updateAgvLocMast(agvLocMast, "R");
        if (wrkSts == 21L) {
            updateAgvBasDevp(devpNo,"S",agvLocMast.getLocType2(),agvLocMast.getBarcode());
            updateAgvBasDevp(devpNo, "S", agvLocMast.getLocType2(), agvLocMast.getBarcode());
        } else {
            updateAgvLocMast(locMast,"S");
            updateAgvLocMast(locMast, "S");
        }


        return SUCCESS;
    }


    public ReturnT<String> autoEmptyBackSiqi(AgvLocMast agvLocMast) {
        Date now = new Date();
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
        if (!Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("当前" + agvLocMast.getBarcode() + "货架码已在工作档中");
        }
        String floor = "";
        String locNo = "";
        Long wrkSts = 0L;
        Integer ioType = 0;
        AgvLocMast locMast = new AgvLocMast();
        if (agvLocMast.getFloor() == 3) {
            floor = "F3";
        } else if (agvLocMast.getFloor() == 2) {
            floor = "F2";
        }
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 109).like("barcode", "31", SqlLike.RIGHT).like("source_loc_no", floor).or().eq("io_type", 113));
        Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_6_MAX"));
        if (config != null && !Cools.isEmpty(config.getValue())) {
            if (agvWrkMasts.size() >= Integer.parseInt(config.getValue())) {
                return FAIL;
            }
        } else {
            if (agvWrkMasts.size() >= 5) {
                return FAIL;
            }
        }
        //检索空闲可入接驳位 没有空闲可入接驳位 直接找库位
        AgvBasDevp devpNo = agvCommonService.getDevpNo(6, agvLocMast.getFloor(), "Y", "Y");
        if (!Cools.isEmpty(devpNo)) {
            locNo = devpNo.getDevNo();
            wrkSts = 21L;
            ioType = 109;
        } else {
            //检索库位，选择合适的库位
            locMast = agvCommonService.getLocByFloorAndLev1(6, 1, 2);
            locNo = locMast.getLocNo();
            wrkSts = 201L;
            ioType = 109;
        }
        if (locMast == null) {
            throw new CoolException("没有可用的库位");
        }
        //生成工作档
        AgvWrkMast mast = new AgvWrkMast();
        //工作状态
        mast.setWrkSts(wrkSts);
        //入出库类型
        mast.setIoType(ioType);
        mast.setIoTime(now);
        //优先级
        mast.setIoPri(300.0);
        //源站点
        mast.setSourceLocNo(agvLocMast.getLocNo());
        //目标站点
        mast.setLocNo(locNo);
        //货架编码
        mast.setBarcode(agvLocMast.getBarcode());
        //货架类型
        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0, 2)));


        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
        mast.setModiUser(9527L);
        mast.setModiTime(now);
        mast.setLogErrMemo("autoEmptyBackSiqi");
        if (!agvWrkMastService.insertByIncrease(mast)) {
            throw new CoolException("保存工作档失败");
        }

        //更新目标库位状态
        updateAgvLocMast(agvLocMast, "R");
        if (wrkSts == 21L) {
            updateAgvBasDevp(devpNo, "S", agvLocMast.getLocType2(), agvLocMast.getBarcode());
        } else {
            updateAgvLocMast(locMast, "S");
        }


        return SUCCESS;
    }


    public ReturnT<String> autoEmptyBack5(AgvBasDevp agvBasDevp) {
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvBasDevp.getBarcode());
        if(!Cools.isEmpty(agvWrkMast)){
            throw new CoolException("当前"+agvBasDevp.getBarcode()+"货架码已在工作档中");
        if (!Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("当前" + agvBasDevp.getBarcode() + "货架码已在工作档中");
        }
        Date now = new Date();
        //生成工作档
@@ -469,7 +591,8 @@
        //货架编码
        mast.setBarcode(agvBasDevp.getBarcode());
        //货架类型
        mast.setWhsType(30);
        mast.setWhsType(Integer.parseInt(agvBasDevp.getBarcode().substring(0, 2)));

        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
        mast.setModiUser(9527L);
@@ -482,9 +605,9 @@
            //入出库类型
            mast.setIoType(109);
            //检索库位，选择合适的库位
            AgvLocMast locMast = agvCommonService.getLocNo(3,1,true,true);
            AgvLocMast locMast = agvCommonService.getLocNo(3, 1, true, true);
            mast.setLocNo(locMast.getLocNo());
            updateAgvLocMast(locMast,"S");
            updateAgvLocMast(locMast, "S");
        } else {
            //工作状态
            mast.setWrkSts(212L);
@@ -497,7 +620,7 @@
            throw new CoolException("保存工作档失败");
        }
        //更新目标库位状态
        updateAgvBasDevp(agvBasDevp,"R");
        updateAgvBasDevp(agvBasDevp, "R");


        return SUCCESS;
@@ -506,8 +629,8 @@
    public ReturnT<String> autoEmptyBack6(AgvBasDevp agvBasDevp) {
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvBasDevp.getBarcode());
        if(!Cools.isEmpty(agvWrkMast)){
            throw new CoolException("当前"+agvBasDevp.getBarcode()+"货架码已在工作档中");
        if (!Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("当前" + agvBasDevp.getBarcode() + "货架码已在工作档中");
        }
        Date now = new Date();
        //生成工作档
@@ -526,7 +649,8 @@
        //货架编码
        mast.setBarcode(agvBasDevp.getBarcode());
        //货架类型
        mast.setWhsType(30);
        mast.setWhsType(Integer.parseInt(agvBasDevp.getBarcode().substring(0, 2)));

        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
        mast.setModiUser(9527L);
@@ -536,13 +660,13 @@
            throw new CoolException("保存工作档失败");
        }
        //更新目标库位状态
        updateAgvBasDevp(agvBasDevp,"R");
        updateAgvBasDevp(agvBasDevp, "R");


        return SUCCESS;
    }

    public ReturnT<String> autoTransfers(AgvLocMast agvLocMast,Integer maxTansk) {
    public ReturnT<String> autoTransfers(AgvLocMast agvLocMast, Integer maxTansk) {
        Date now = new Date();
        List<AgvLocDetl> locDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
        locDetls.forEach(agvLocDetl -> {
@@ -552,13 +676,18 @@
        });
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
        if(!Cools.isEmpty(agvWrkMast)){
            throw new CoolException("当前"+agvLocMast.getBarcode()+"货架码已在工作档中");
        if (!Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("当前" + agvLocMast.getBarcode() + "货架码已在工作档中");
        }
        //检索库位，选择合适的库位
        AgvLocMast LocMast = agvCommonService.getLocNo(3,1,false,false);
        AgvLocMast LocMast = agvCommonService.getLocNo(3, 1, false, false);
        if (LocMast.getLev1() != 2) {
            throw new CoolException("目标楼层不是吸塑二楼");
            //throw new CoolException("目标楼层不是吸塑二楼");
            return FAIL;
        }
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().like("loc_no", "02F1").like("source_loc_no", "F1").eq("io_type", 12));
        if (agvWrkMasts.size() >= maxTansk) {
            throw new CoolException("自动移库任务已到设定最大值：" + maxTansk);
        }
        //生成工作档
        AgvWrkMast mast = new AgvWrkMast();
@@ -576,7 +705,8 @@
        //货架编码
        mast.setBarcode(agvLocMast.getBarcode());
        //货架类型
        mast.setWhsType(30);
        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0, 2)));


        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
@@ -587,7 +717,7 @@
            throw new CoolException("保存工作档失败");
        }

        AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", LocMast.getLocNo()).eq("source_loc_no",agvLocMast.getLocNo()));
        AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", LocMast.getLocNo()).eq("source_loc_no", agvLocMast.getLocNo()));
        //生成工作档明细
        List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
        agvLocDetls.forEach(agvLocDetl -> {
@@ -605,8 +735,91 @@
            }
        });
        //更新目标库位状态
        updateAgvLocMast(agvLocMast,"R");
        updateAgvLocMast(LocMast,"S");
        updateAgvLocMast(agvLocMast, "R");
        updateAgvLocMast(LocMast, "S");

        return SUCCESS;
    }

    /**
     * 四期，跨层移库，1楼到2楼，2楼到1楼
     *
     * @param agvLocMast
     * @param maxTansk
     * @return
     */
    public ReturnT<String> autoTransfersV2(AgvLocMast agvLocMast, Integer maxTansk) {
        Date now = new Date();
        List<AgvLocDetl> locDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
        locDetls.forEach(agvLocDetl -> {
            if (agvLocDetl.getProcessSts().equals(1)) {
                throw new CoolException("当前库位有库存未加工");
            }
        });
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
        if (!Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("当前" + agvLocMast.getBarcode() + "货架码已在工作档中");
        }
        AgvLocMast LocMast;
        if (agvLocMast.getLev1() == 1) {
            //检索库位，选择合适的库位
            LocMast = agvCommonService.getLocByLocRule2(3, 1, 2);
        } else {
            LocMast = agvCommonService.getLocByLocRule2(3, 1, 1);
        }
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 12));
        if (agvWrkMasts.size() >= maxTansk) {
            throw new CoolException("自动移库任务已到设定最大值：" + maxTansk);
        }
        //生成工作档
        AgvWrkMast mast = new AgvWrkMast();
        //工作状态
        mast.setWrkSts(201L);
        //入出库类型
        mast.setIoType(12);
        mast.setIoTime(now);
        //优先级
        mast.setIoPri(300.0);
        //源站点
        mast.setSourceLocNo(agvLocMast.getLocNo());
        //目标站点
        mast.setLocNo(LocMast.getLocNo());
        //货架编码
        mast.setBarcode(agvLocMast.getBarcode());
        //货架类型
        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0, 2)));


        mast.setAppeUser(9527L);
        mast.setAppeTime(now);
        mast.setModiUser(9527L);
        mast.setModiTime(now);
        mast.setLogErrMemo("doAutoMoveV4");
        if (!agvWrkMastService.insertByIncrease(mast)) {
            throw new CoolException("保存工作档失败");
        }

        AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", LocMast.getLocNo()).eq("source_loc_no", agvLocMast.getLocNo()));
        //生成工作档明细
        List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
        agvLocDetls.forEach(agvLocDetl -> {
            AgvWrkDetl wrkDetl = new AgvWrkDetl();
            wrkDetl.setWrkNo(mast1.getWrkNo());
            wrkDetl.sync(agvLocDetl);
            wrkDetl.setSuppCode(agvLocDetl.getSuppCode());
            wrkDetl.setIoTime(now);
            wrkDetl.setAppeUser(9527L);
            wrkDetl.setAppeTime(now);
            wrkDetl.setModiUser(9527L);
            wrkDetl.setModiTime(now);
            if (!agvWrkDetlService.insert(wrkDetl)) {
                throw new CoolException("保存工作明细失败");
            }
        });
        //更新目标库位状态
        updateAgvLocMast(agvLocMast, "R");
        updateAgvLocMast(LocMast, "S");

        return SUCCESS;
    }