#

lsh

2024-05-31 6e05d25d44bd1fa1bab3806e5f2f33d9076664b5

#

 src/main/java/com/zy/asrs/task/AutoMoveScheduler.java

@@ -201,6 +201,7 @@
     */
    @Scheduled(cron = "0/2 * * * * ? ")
    private void autoEmptyBack4(){
//        if (determineFloorConnection(2)){
        // 查询 不为1楼的空货架
        List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(
                new EntityWrapper<AgvLocMast>()
@@ -217,6 +218,24 @@
                log.error("库位号"+agvLocMast.getLocNo()+"空板自动回库 库位-接驳点  库位-吸塑车间,处理失败：===》异常原因："+e.getMessage());
            }
        }
//        }
    }

    private boolean determineFloorConnection(Integer floor){
        try{
            List<AgvBasDevp> agvBasDevps = agvBasDevpService.selectList(new EntityWrapper<AgvBasDevp>().eq("floor", floor).like("dev_no", "DB_"));
            if (!agvBasDevps.isEmpty()){
                for (AgvBasDevp agvBasDevp:agvBasDevps){
                    if (agvBasDevp.getInEnable().equals("Y")){
                        return false;
                    }
                }
                return true;
            }
        }catch (Exception e){
            log.error("判断当前楼层接驳位是否全部关闭，异常"+e.getMessage());
        }
        return false;
    }

    /**

 src/main/java/com/zy/asrs/task/AutoMoveTwoAndThreeGoOneScheduler.java

New file
@@ -0,0 +1,18 @@
package com.zy.asrs.task;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

// 自动移库
@Slf4j
@Component
public class AutoMoveTwoAndThreeGoOneScheduler {

    /**
     * 2、3楼转移到1楼任务执行
     */
//    @Scheduled(cron = "0/2 * * * * ? ")
    private void autoMove(){

    }
}

 src/main/java/com/zy/asrs/task/AutoReplenishmentScheduler.java

@@ -37,7 +37,7 @@
    /*
    定时遍历库存，生成自动补货单据
     */
    @Scheduled(cron = "0 */1 * * * ? ")
//    @Scheduled(cron = "0 */1 * * * ? ")
    public void createOrder(){

        if(!"Y".equals(Parameter.get().getAutoReplenishment())){

 src/main/java/com/zy/asrs/task/CheckLocDetlExistScheduler.java

@@ -28,7 +28,7 @@
    private ConfigService configService;

    //每30分钟扫描一次
    @Scheduled(cron = "0 30 * * * ? ")
//    @Scheduled(cron = "0 30 * * * ? ")
    private void execute(){
        List<LocMast> locMasts = locMastService.selectLocDetlNotExist();
        if (locMasts.isEmpty()) {

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

@@ -54,6 +54,7 @@

    @Transactional
    public ReturnT<String> completedPutWayWrk(AgvWrkMast agvWrkMast) {
        try{
        int wrkNo = agvWrkMast.getWrkNo();
        String barcode = agvWrkMast.getBarcode();
        String orderNo = getOrderNoByWrkNo(wrkNo);
@@ -159,11 +160,16 @@
        }

        return SUCCESS;
        }catch (Exception e){
            log.error(""+e.getMessage());
        }
        return FAIL;
    }


    @Transactional
    public ReturnT<String> completedCarryWrk(AgvWrkMast agvWrkMast) {
        try{
        int wrkNo = agvWrkMast.getWrkNo();
        String orderNo = getOrderNoByWrkNo(wrkNo);
        //修改工作档状态为207.库存更新完成
@@ -203,10 +209,15 @@
            });
        }
        return SUCCESS;
        }catch (Exception e){
            log.error(""+e.getMessage());
        }
        return FAIL;
    }

    @Transactional
    public ReturnT<String> completedCarryWrk2(AgvWrkMast agvWrkMast) {
        try{
        int wrkNo = agvWrkMast.getWrkNo();
        String orderNo = getOrderNoByWrkNo(wrkNo);
        String agvBasDevp = "";
@@ -244,6 +255,10 @@
            });
        }
        return SUCCESS;
        }catch (Exception e){
            log.error(""+e.getMessage());
        }
        return FAIL;
    }

    @Transactional
@@ -265,7 +280,7 @@
            }
            return SUCCESS;
        }catch (Exception e){
            log.error(e.getMessage());
            log.error("修改AGV入库通知档状态入出状态为Y"+e.getMessage());
        }
        return FAIL;
    }
@@ -275,11 +290,16 @@
    public ReturnT<String> startAllcationIn(AgvWrkMast agvWrkMast) throws IOException {
        
        //下发任务
        try{
        int startWrkCode = agvWrkMastService.startAllcationIn(agvWrkMast);
        if(startWrkCode != 0){
            throw new CoolException("任务下发失败");
        }
        return SUCCESS;
        }catch (Exception e){
            log.error("任务下发失败"+e.getMessage());
        }
        return FAIL;

    }