1

zhang

2025-08-06 aa221b6b6c3939130c78e4219207d14ce877ff30

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

@@ -50,18 +50,21 @@
//        return SUCCESS;
//    }

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

    @Transactional
    public ReturnT<String> start3(AgvWrkMast agvWrkMast) {
        // locType 1. 自动， 2. 手动
        doHandMove2(agvWrkMast);
        return SUCCESS;
    }

    @Transactional
    public ReturnT<String> start4(AgvWrkMast agvWrkMast) {
        // locType 1. 自动， 2. 手动
        doAutoMove3(agvWrkMast);
@@ -193,8 +196,8 @@
        return SUCCESS;
    }


    private ReturnT<String> doAutoMove2(AgvWrkMast agvWrkMast) {
    @Transactional
    public ReturnT<String> doAutoMove2(AgvWrkMast agvWrkMast) {
        Date now = new Date();
        String barcode = agvWrkMast.getBarcode();
        AgvLocMast locMast;
@@ -230,7 +233,8 @@
        return SUCCESS;
    }

    private ReturnT<String> doAutoMove3(AgvWrkMast agvWrkMast) {
    @Transactional
    public ReturnT<String> doAutoMove3(AgvWrkMast agvWrkMast) {
        Date now = new Date();
        //检索库位，选择合适的库位
        AgvLocMast locMast = agvCommonService.getLocNo(3, agvWrkMast.getCrnNo(), false, false);
@@ -250,7 +254,8 @@
        return SUCCESS;
    }

    private ReturnT<String> doHandMove2(AgvWrkMast agvWrkMast) {
    @Transactional
    public ReturnT<String> doHandMove2(AgvWrkMast agvWrkMast) {
        Date now = new Date();
        String lev1 = agvWrkMast.getSourceLocNo().substring(agvWrkMast.getSourceLocNo().length() - 4).substring(0, 2);
        AgvBasDevp devpNo = new AgvBasDevp();
@@ -261,7 +266,7 @@
        }

        if (Cools.isEmpty(devpNo)) {
            log.info("暂无空闲接驳位");
            //log.info("暂无空闲接驳位");
            return FAIL;
            //throw new CoolException("暂无空闲接驳位");
        }
@@ -278,7 +283,7 @@
    /*
    更新目标库位信息
     */
    private void updateAgvLocMast(AgvLocMast locMast, String locSts) {
    public void updateAgvLocMast(AgvLocMast locMast, String locSts) {
        locMast.setLocSts(locSts);
        agvLocMastService.updateById(locMast);
    }
@@ -286,14 +291,14 @@
    /*
    更新源站点信息
     */
    private void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts) {
    public 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) {
    public void updateAgvBasDevp(AgvBasDevp agvBasDevp, String locSts, Short continerType, String containerCode) {
        if (!Cools.isEmpty(agvBasDevp)) {
            agvBasDevp.setLocSts(locSts);
            agvBasDevp.setBarcode(containerCode);
@@ -344,6 +349,7 @@
        return SUCCESS;
    }

    @Transactional
    public ReturnT<String> autoEmptyBack3(AgvWrkMast agvWrkMast) {
        Date now = new Date();
        AgvBasDevp agvBasDevp = agvBasDevpService.selectByDevNo(agvWrkMast.getSourceLocNo());
@@ -409,6 +415,8 @@
//        return SUCCESS;
//    }


    @Transactional
    public ReturnT<String> autoEmptyBack4(AgvLocMast agvLocMast) {
        Date now = new Date();
        //查询工作档
@@ -428,7 +436,7 @@
        } else if (agvLocMast.getFloor() == 1 && agvLocMast.getLev1() == 2) {
            floor = "02F1";
        }
        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));
        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) {
            //log.error("暂停回流");
            return FAIL;
@@ -441,6 +449,20 @@
            wrkSts = 21L;
            ioType = 109;
        } else {
            try {
                List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>().eq("loc_sts", "O").eq("loc_type1", 3).eq("lev1", 1).eq("floor", 1));
                int num = 20;
                Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "LOC_3_NUM_RETURN"));
                if (config != null && !Cools.isEmpty(config.getValue())) {
                    num = Integer.parseInt(config.getValue());
                }
                if (agvLocMasts == null || agvLocMasts.size() < num) {
                    log.error("<库位不足>" + num + "<库位不足>");
                    return FAIL;
                }
            } catch (Exception e) {

            }
            //检索库位，选择合适的库位
            locMast = agvCommonService.getLocNo(3, 1, true, true);
            locNo = locMast.getLocNo();
@@ -488,7 +510,7 @@
        return SUCCESS;
    }


    @Transactional
    public ReturnT<String> autoEmptyBackSiqi(AgvLocMast agvLocMast) {
        Date now = new Date();
        //查询工作档
@@ -574,6 +596,7 @@
    }


    @Transactional
    public ReturnT<String> autoEmptyBack5(AgvBasDevp agvBasDevp) {
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvBasDevp.getBarcode());
@@ -626,6 +649,8 @@
        return SUCCESS;
    }


    @Transactional
    public ReturnT<String> autoEmptyBack6(AgvBasDevp agvBasDevp) {
        //查询工作档
        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvBasDevp.getBarcode());
@@ -666,6 +691,7 @@
        return SUCCESS;
    }

    @Transactional
    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()));
@@ -748,6 +774,7 @@
     * @param maxTansk
     * @return
     */
    @Transactional
    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()));
@@ -764,9 +791,9 @@
        AgvLocMast LocMast;
        if (agvLocMast.getLev1() == 1) {
            //检索库位，选择合适的库位
            LocMast = agvCommonService.getLocByLocRule(3, 1, 2);
            LocMast = agvCommonService.getLocByLocRule2(3, 1, 2);
        } else {
            LocMast = agvCommonService.getLocByLocRule(3, 1, 1);
            LocMast = agvCommonService.getLocByLocRule2(3, 1, 1);
        }
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 12));
        if (agvWrkMasts.size() >= maxTansk) {