*

L

2 天以前 9f535f9c6ff8640d0cbbc915235a59d2ee39c702

*

 src/main/java/com/zy/asrs/entity/BasRgv.java

@@ -131,6 +131,13 @@
    @ApiModelProperty(value= "是否有物 1: 有物  0: 无物  ")
    private Integer loaded2;

    /**
     * 有物无物
     */
    @ApiModelProperty(value= "有物无物")
    @TableField("now_sta_no")
    private int nowStaNo;

    public BasRgv() {}

    public BasRgv(Integer rgvNo,String inEnable,String outEnable,Integer rgvSts,Integer wrkNo1,Integer wrkNo2,Long rgvErr,String pakMk,Integer status,Long createBy,Date createTime,Long updateBy,Date updateTime,String memo,Integer loaded2) {

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

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

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.zy.asrs.entity.*;
import com.zy.asrs.service.*;
import org.springframework.beans.factory.annotation.Autowired;
@@ -7,6 +9,7 @@
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
@@ -17,14 +20,174 @@
public class WrkMastRgvTwoScheduler {
    @Autowired
    private WrkMastService wrkMastService;

    @Autowired
    private RgvOneSignService rgvOneSignService;
    @Autowired
    private WrkMastStaService wrkMastStaService;
    @Autowired
    private BasRgvService basRgvService;

    public static final List<Integer> STA_WORK_RU = new ArrayList<Integer>() {{
        add(118);add(120);add(121);add(122);add(123);add(171);
    }};

    @Scheduled(cron = "0/2 * * * * ? ")
    private void execute0(){
        RgvOneSign rgvTwoSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","rgvTwo"));
        if (Cools.isEmpty(rgvTwoSign) || rgvTwoSign.getRgvOneSign()!=0){
            return;
        }
        int selectCount345 = wrkMastService.selectCount(new EntityWrapper<WrkMast>()
                .ge("crn_no", 4)
                .ge("io_type", 100)
                .ge("wrk_sts", 11L)
                .le("wrk_sts", 14L)
                .le("sta_no", 199));
        if (selectCount345>0){
            return;
        }
        int selectCount123 = wrkMastService.selectCount(new EntityWrapper<WrkMast>()
                .ge("io_type", 100)
                .ge("wrk_sts", 11L)
                .le("wrk_sts", 14L)
                .le("sta_no", 199));
        if (selectCount123<3){
            return;
        }

        BasRgv basRgv2 = basRgvService.selectById(2);
        if (Cools.isEmpty(basRgv2) || basRgv2.getRgvSts()!=3 || basRgv2.getWrkNo1()!=0 || basRgv2.getWrkNo2()!=0){
            return;
        }
        if (Cools.isEmpty(basRgv2.getNowStaNo())){
            return;
        }
        if (basRgv2.getNowStaNo()!=116){
            WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("wrk_no",117+19999L));
            if (Cools.isEmpty(wrkMastSta)){
                WrkMastSta wrkMastSta1 = new WrkMastSta(new Date(),117);
                wrkMastSta1.setType(1);
                wrkMastSta1.setWrkType(4);
                wrkMastStaService.insert(wrkMastSta1);
            }
        }
        rgvTwoSign.setRgvOneSign(1);
        rgvOneSignService.updateById(rgvTwoSign);
    }

    @Scheduled(cron = "0/1 * * * * ? ")
    private void execute1(){
        RgvOneSign rgvTwoSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","rgvTwo"));
        if (Cools.isEmpty(rgvTwoSign) || rgvTwoSign.getRgvOneSign()!=1){
            return;
        }
        int selectCount345 = wrkMastService.selectCount(new EntityWrapper<WrkMast>()
                .ge("crn_no", 4)
                .ge("io_type", 100)
                .ge("wrk_sts", 11L)
                .le("wrk_sts", 14L)
                .le("sta_no", 199));
        if (selectCount345>0){
            rgvTwoSign.setRgvOneSign(0);
            rgvOneSignService.updateById(rgvTwoSign);
            return;
        }
        int selectCount123 = wrkMastService.selectCount(new EntityWrapper<WrkMast>()
                .ge("io_type", 100)
                .ge("wrk_sts", 11L)
                .le("wrk_sts", 14L)
                .le("sta_no", 199));
        if (selectCount123<3){
            rgvTwoSign.setRgvOneSign(0);
            rgvOneSignService.updateById(rgvTwoSign);
            return;
        }
        BasRgv basRgv2 = basRgvService.selectById(2);
        if (basRgv2==null || basRgv2.getRgvSts()!=3 || basRgv2.getWrkNo1()!=0 || basRgv2.getWrkNo2()!=0){
            rgvTwoSign.setRgvOneSign(0);
            rgvOneSignService.updateById(rgvTwoSign);
            return;
        }
        int selectCount = wrkMastStaService.selectCount(new EntityWrapper<>());
        if (selectCount>0){
            return;
        }
        if (basRgv2.getNowStaNo()!=116){
            rgvTwoSign.setRgvOneSign(0);
            rgvOneSignService.updateById(rgvTwoSign);
            return;
        }
        rgvTwoSign.setRgvOneSign(2);
        rgvOneSignService.updateById(rgvTwoSign);
    }

    @Scheduled(cron = "0/2 * * * * ? ")
    private void execute2(){
        RgvOneSign rgvTwoSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","rgvTwo"));
        if (Cools.isEmpty(rgvTwoSign) || rgvTwoSign.getRgvOneSign()!=2){
            return;
        }
        int selectCount345 = wrkMastService.selectCount(new EntityWrapper<WrkMast>()
                .ge("crn_no", 4)
                .ge("io_type", 100)
                .ge("wrk_sts", 11L)
                .le("wrk_sts", 14L)
                .le("sta_no", 199));
        if (selectCount345>0){
            rgvTwoSign.setRgvOneSign(3);
            rgvOneSignService.updateById(rgvTwoSign);
            return;
        }
        int selectCount123 = wrkMastService.selectCount(new EntityWrapper<WrkMast>()
                .ge("io_type", 100)
                .ge("wrk_sts", 11L)
                .le("wrk_sts", 14L)
                .le("sta_no", 199));
        if (selectCount123==0){
            rgvTwoSign.setRgvOneSign(3);
            rgvOneSignService.updateById(rgvTwoSign);
        }
    }

    @Scheduled(cron = "0/1 * * * * ? ")
    private void execute3(){
        RgvOneSign rgvTwoSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","rgvTwo"));
        if (Cools.isEmpty(rgvTwoSign) || rgvTwoSign.getRgvOneSign()!=3){
            return;
        }
        BasRgv basRgv1 = basRgvService.selectById(1);
        if (Cools.isEmpty(basRgv1) || basRgv1.getRgvSts()!=3 || basRgv1.getWrkNo1()!=0 || basRgv1.getWrkNo2()!=0){
            return;
        }
        if (Cools.isEmpty(basRgv1.getNowStaNo())){
            return;
        }
        BasRgv basRgv2 = basRgvService.selectById(2);
        if (Cools.isEmpty(basRgv2) || basRgv2.getRgvSts()!=3 || basRgv2.getWrkNo1()!=0 || basRgv2.getWrkNo2()!=0){
            return;
        }
        if (Cools.isEmpty(basRgv2.getNowStaNo())){
            return;
        }
        int selectCount = wrkMastStaService.selectCount(new EntityWrapper<>());
        if (selectCount>0){
            return;
        }
        if (basRgv1.getNowStaNo()!=102){
            WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("wrk_no",102+19999L));
            if (Cools.isEmpty(wrkMastSta)){
                WrkMastSta wrkMastSta1 = new WrkMastSta(new Date(),102);
                wrkMastSta1.setType(1);
                wrkMastSta1.setWrkType(4);
                wrkMastStaService.insert(wrkMastSta1);
            }
        }
        if (basRgv1.getNowStaNo()==102){
            if (basRgv2.getNowStaNo()==116){
                rgvTwoSign.setRgvOneSign(0);
                rgvOneSignService.updateById(rgvTwoSign);
            }
        }

    }


 src/main/resources/mapper/BasRgvMapper.xml

@@ -19,6 +19,7 @@
        <result column="update_time" property="updateTime" />
        <result column="memo" property="memo" />
        <result column="loaded2" property="loaded2" />
        <result column="now_sta_no" property="nowStaNo" />

    </resultMap>