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;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

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

/**
 * Created by Monkey D. Luffy on 2023.07.25
 * 徐工汉云..............以下.............上饶江铜.............自动补空板
 */
@Component
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.getRgvSts1()!=0  || basRgv2.getRgvSts2()!=0
                || basRgv2.getWrkNo1()!=0 || basRgv2.getWrkNo2()!=0 || basRgv2.getLoaded2()>1){
            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.getRgvSts1()!=0  || basRgv2.getRgvSts2()!=0
                || 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",101+19999L));
            if (Cools.isEmpty(wrkMastSta)){
                WrkMastSta wrkMastSta1 = new WrkMastSta(new Date(),101);
                wrkMastSta1.setType(1);
                wrkMastSta1.setWrkType(4);
                wrkMastStaService.insert(wrkMastSta1);
            }
        }
        if (basRgv1.getNowStaNo()==102){
            if (basRgv2.getNowStaNo()==116){
                rgvTwoSign.setRgvOneSign(0);
                rgvOneSignService.updateById(rgvTwoSign);
            }
        }

    }

}