package com.zy.asrs.task;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.RgvOneSign;
import com.zy.asrs.entity.WrkMastSta;
import com.zy.asrs.service.BasDevpService;
import com.zy.asrs.service.RgvOneSignService;
import com.zy.asrs.service.WrkMastStaService;
import com.zy.asrs.service.impl.BasDevpServiceImpl;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.OneLouHangJiaHandler;
import com.zy.asrs.task.handler.RailwayPlatformHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * Created by Monkey D. Luffy on 2023.09.17
 * 徐工汉云..............以下.............上饶江铜.............退库拆码垛
 */
@Slf4j
@Component
public class OneLouHangJiaScheduler {

    @Autowired
    private OneLouHangJiaHandler oneLouHangJiaHandler;
    @Autowired
    private WrkMastStaService wrkMastStaService;
    @Autowired
    private BasDevpService basDevpService;
    @Autowired
    private RgvOneSignService rgvOneSignService;

    @Scheduled(cron = "0/3 * * * * ? ")
    private void execute(){//退库拆码垛
//        int[] staNos =new int[]{118,119};
        int[] staNos =new int[]{118};
        for (int staNo : staNos){
            try{
                WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("sta_end",staNo)
                        .eq("type", 2).eq("wrk_sts", 0).eq("wrk_type", 2));
                if (!Cools.isEmpty(wrkMastSta)){
                    break;
                }
                ReturnT<String> result = oneLouHangJiaHandler.start(147,staNo);
                if (result.getCode()==200){
                    break;
                }
            }catch (Exception e){
                log.error("退库拆码垛"+staNo+"站点处理失败，异常信息："+e);
            }
        }
    }

    @Scheduled(cron = "0/3 * * * * ? ")
    private void executeoTHER(){//131、135标记自动清除
//        int[] staNos =new int[]{131,135};
        int[][] staNoLists =new int[2][3];
        staNoLists[0] = new int[]{131,118,119};
        staNoLists[1] = new int[]{135,120,121};
        int i = 0;
        for (int[] staNos : staNoLists){
            if (i==0){
                RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","oneSign"));
                if (rgvOneSign.getRgvOneSign()==1){//1:退库模式
                    i++;
                    continue;
                }
            }
            boolean sign = true;
            int j =0;
            for (int staNo : staNos){
                try{
                    BasDevp basDevp = basDevpService.selectById(staNo);
                    if (!Cools.isEmpty(basDevp) && basDevp.getAutoing().equals("Y")){
                        if (
                                (j==0 && basDevp.getReportSign()==1 && basDevp.getLoading().equals("Y")&& basDevp.getLoadingSuper().equals("Y"))
                                ||
                                (j!=0 && basDevp.getReportSign()==0)
                        ){
                            j++;
                            continue;
                        }
                    }
                }catch (Exception e){
                    log.error("131、135标记自动清除"+staNo+"站点处理失败，异常信息："+e);
                }
                sign = false;
                j++;
            }
            if (sign){
                basDevpService.updateReportSignFalse(staNos[0]);
            }
            i++;
        }
    }

}