package com.zy.asrs.task;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.exception.CoolException;
import com.zy.asrs.entity.BasCrnError;
import com.zy.asrs.entity.BasCrnp;
import com.zy.asrs.entity.BasErrLog;
import com.zy.asrs.entity.TaskWrk;
import com.zy.asrs.service.BasCrnErrorService;
import com.zy.asrs.service.BasCrnpService;
import com.zy.asrs.service.BasErrLogService;
import com.zy.asrs.service.TaskWrkService;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.ss.formula.functions.T;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.util.Date;
import java.util.List;

/**
 * 定时获取堆垛机报警，进行记录
 */
@Slf4j
@Component
public class BasErrLogScheduler {

    @Autowired
    private BasErrLogService basErrLogService;
    @Autowired
    private BasCrnpService basCrnpService;
    @Autowired
    private TaskWrkService taskWrkService;
    @Autowired
    private BasCrnErrorService  basCrnErrorService;




    @Scheduled(cron = "0/3 * * * * ? ")
    public void execute() throws IOException {

        //对有异常的堆垛机进行异常记录
        List<BasCrnp> basCrnps=basCrnpService.selectList(new EntityWrapper<BasCrnp>().ge("crn_err",1));
        if(!Cools.isEmpty(basCrnps)){
            for(BasCrnp basCrnp:basCrnps){
                Integer wrkNo=basCrnp.getWrkNo();
                Integer ioType = 0;
                Long wrkSts= 0L;
                String error="";

                if(Cools.isEmpty(basCrnp.getRetrieveMk())||basCrnp.getRetrieveMk().equals("N")){
                    BasCrnError basCrnError=basCrnErrorService.selectOne(new EntityWrapper<BasCrnError>().eq("error_code",Math.toIntExact(basCrnp.getCrnErr())));
                    if(!Cools.isEmpty(basCrnError)){
                        error = basCrnError.getErrName();
                    }
                    BasErrLog basErrLog=new BasErrLog();
                    if(basCrnp.getWrkNo()>0){
                        TaskWrk taskWrk=taskWrkService.selectOne(new EntityWrapper<TaskWrk>()
                                .eq("crn_no",basCrnp.getCrnNo())
                                .eq("wrk_no",basCrnp.getWrkNo()));
                        if(taskWrk!=null){
                            wrkNo=taskWrk.getWrkNo();
                            ioType=taskWrk.getIoType();
                            wrkSts=taskWrk.getWrkSts().longValue();
                        }
                    }
                    basErrLog.setWrkNo(wrkNo);
                    basErrLog.setWrkSts(wrkSts);
                    basErrLog.setIoType(ioType);
                    basErrLog.setStartTime(new Date());
                    basErrLog.setCrnNo(basCrnp.getCrnNo());
                    basErrLog.setErrCode(Math.toIntExact(basCrnp.getCrnErr()));
                    basErrLog.setError(error);
                    if(basErrLogService.insert(basErrLog)){
                        basCrnp.setRetrieveMk("Y");
                        basCrnpService.updateById(basCrnp);
                    }
                }
            }
        }

        //对没异常的堆垛机进行异常记号复位
        List<BasCrnp> basCrnps1 = basCrnpService.selectList(new EntityWrapper<BasCrnp>().eq("crn_err", 0).eq("retrieve_mk", "Y"));
        for(BasCrnp basCrnp:basCrnps1){
            basCrnp.setRetrieveMk("N");
            basCrnpService.updateById(basCrnp);
        }
    }
}