#

vincentlu

7 天以前 efabc6ba991acfd01d38bb0bf4e8cfd772416617

 zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/AutoRunScheduler.java

@@ -24,6 +24,8 @@
@Component
public class AutoRunScheduler {

    private static final AgvModelType DEFAULT_AGV_MODEL = AgvModelType.CTU_BOX_TRANSPORT_AGV;

    private final RedisSupport redis = RedisSupport.defaultRedisSupport;

    @Autowired
@@ -52,10 +54,13 @@
//    @Scheduled(cron = "0/1 * * * * ? ")
    private void execute() {
        if (!configService.getVal("TaskAssignMode", Boolean.class)) { return; }
        this.autoRun();
        AgvModel agvModel = agvModelService.getOne(new LambdaQueryWrapper<AgvModel>().eq(AgvModel::getType, DEFAULT_AGV_MODEL.toString()));
        if (null == agvModel) { return; }

        this.autoRun(agvModel);
    }

    private void autoRun() {
    private void autoRun(AgvModel agvModel) {
        int availableAgvCount = this.getAvailableAgvCount();
        if (0 == availableAgvCount) { return; }

@@ -64,18 +69,16 @@
        String memo = "DEMO_STA_" + String.join("-", staPreNos);

        // 入库
        this.runStaToLoc(memo);
        this.runStaToLoc(agvModel, memo);
        // 出库
        this.runLocToSta(memo);

        this.runLocToSta(agvModel, memo);
        // 移库
        this.runLocToLoc(memo);
        this.runLocToLoc(agvModel, memo);
    }

    // 入库
    private void runStaToLoc(String memo) {
        AgvModel agvModel = agvModelService.getOne(new LambdaQueryWrapper<AgvModel>().eq(AgvModel::getType, AgvModelType.CTU_BOX_TRANSPORT_AGV.toString()));
        if (null == agvModel) { return; }
    private void runStaToLoc(AgvModel agvModel, String memo) {


        // STOCK STA
        List<Sta> stockList = staService.queryAvailableOutSta(1);
@@ -131,9 +134,7 @@
    }

    // 出库
    private void runLocToSta(String memo) {
        AgvModel agvModel = agvModelService.getOne(new LambdaQueryWrapper<AgvModel>().eq(AgvModel::getType, AgvModelType.CTU_BOX_TRANSPORT_AGV.toString()));
        if (null == agvModel) { return; }
    private void runLocToSta(AgvModel agvModel, String memo) {

        // IDLE STA
        List<Sta> idleList = staService.queryAvailableInSta(1);
@@ -189,7 +190,7 @@
    }

    // 移库
    private void runLocToLoc(String staTaskMemo) {
    private void runLocToLoc(AgvModel agvModel, String staTaskMemo) {
        String memo = "DEMO_LOC";

        int availableAgvCount = this.getAvailableAgvCount();
@@ -199,9 +200,6 @@
                .in(Bus::getBusSts, BusStsType.RECEIVE.val(), BusStsType.PROGRESS.val())
                .in(Bus::getMemo, memo, staTaskMemo)
        )) { return; }

        AgvModel agvModel = agvModelService.getOne(new LambdaQueryWrapper<AgvModel>().eq(AgvModel::getType, AgvModelType.CTU_BOX_TRANSPORT_AGV.toString()));
        if (null == agvModel) { return; }

        int maxCapacity = agvModel.getBackpack();