package com.zy.asrs.controller;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.common.R;
import com.zy.asrs.domain.devops.DevopsMessage;
import com.zy.asrs.domain.devops.ErrorType;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.mapper.WrkMastMapper;
import com.zy.asrs.service.WrkMastService;
import com.zy.core.CrnThread;
import com.zy.core.DevpThread;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.CrnForkPosType;
import com.zy.core.enums.CrnModeType;
import com.zy.core.enums.CrnStatusType;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.CrnSlave;
import com.zy.core.model.protocol.CrnProtocol;
import com.zy.core.model.protocol.StaProtocol;
import com.zy.core.properties.SlaveProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

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

@RestController
@RequestMapping("/devops")
public class DevopsController {

    @Autowired
    private WrkMastService wrkMastService;

    @Autowired
    private SlaveProperties slaveProperties;

    @Autowired
    private WrkMastMapper wrkMastMapper;

    @RequestMapping("/wrkMast/list")
    public R list() {
        List<DevopsMessage> devopsMessages = new ArrayList<>();
        DevopsMessage devopsMessage;
        for (CrnSlave crnSlave : slaveProperties.getCrn()) {
            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("crn_no", crnSlave.getId()).in("io_type", 101, 103, 107).orderBy("wrk_sts", false));
            WrkMast working = wrkMastMapper.selectWorking(crnSlave.getId());
            for (WrkMast wrkMast : wrkMasts) {
                devopsMessage = new DevopsMessage();
                devopsMessage.setWrkNo(wrkMast.getWrkNo());
                if (working != null) {
                    if (working.getWrkNo().equals(wrkMast.getWrkNo())) {
                        devopsMessage.setError("该工作档正在出库，请稍后");
                    } else {
                        devopsMessage.setError(working.getWrkNo() + "号工作档正在出库");
                    }
                    continue;
                }
                List<ErrorType> staError = isStaError(wrkMast);
                for (ErrorType type : staError) {
                    if (!Cools.isEmpty(devopsMessage.getError())) {
                        devopsMessage.setError(devopsMessage.getError() + ";" + type.getDesc());
                        devopsMessage.setMethod(devopsMessage.getMethod() + ";" + type.getMethod());
                    } else {
                        devopsMessage.setError(type.getDesc());
                        devopsMessage.setMethod(type.getMethod());
                    }
                }
                List<ErrorType> crnError = isCrnError(wrkMast);
                for (ErrorType type : crnError) {
                    if (!Cools.isEmpty(devopsMessage.getError())) {
                        devopsMessage.setError(devopsMessage.getError() + ";" + type.getDesc());
                        devopsMessage.setMethod(devopsMessage.getMethod() + ";" + type.getMethod());
                    } else {
                        devopsMessage.setError(type.getDesc());
                        devopsMessage
                                .setMethod(type.getMethod());
                    }
                }
                devopsMessages.add(devopsMessage);
            }
        }
        return R.ok(devopsMessages);
    }

    private List<ErrorType> isStaError(WrkMast staNo) {
        List<ErrorType> types = new ArrayList<>();
        DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
        StaProtocol staProtocol = devpThread.getStation().get(staNo);
        if (staProtocol == null) {
            types.add(ErrorType.ERROR);
            return types;
        } else {
            staProtocol = staProtocol.clone();
        }
        if (staProtocol.isAutoing()) {
            types.add(ErrorType.FEIZIDONG);
        }
        if (staProtocol.isLoading()) {
            types.add(ErrorType.YOUWU);
        }
        if (staProtocol.getWorkNo() == 0) {
            types.add(ErrorType.GONGZUOHAO);
        }
        if (staProtocol.getStaNo() == null) {
            types.add(ErrorType.STANO);
        }
        return types;
    }


    private List<ErrorType> isCrnError(WrkMast wrkMast) {
        List<ErrorType> types = new ArrayList<>();
        CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, wrkMast.getCrnNo());
        CrnProtocol crnProtocol = crnThread.getCrnProtocol();

        if (crnProtocol.getStatusType() == CrnStatusType.IDLE) {

        }
        if (crnProtocol.getTaskNo() == 0) {

        }
        if (crnProtocol.getModeType() == CrnModeType.AUTO) {

        }
        if (crnProtocol.getLoaded() == 0) {

        }
        if (crnProtocol.statusType == CrnStatusType.FETCHING) {
            types.add(ErrorType.WORKING);
        }
        if (crnProtocol.statusType == CrnStatusType.PUTTING) {
            types.add(ErrorType.WORKING);
        }
        if (crnProtocol.statusType == CrnStatusType.WAITING) {
            types.add(ErrorType.WORKING);
        }
        if (crnProtocol.forkPosType == CrnForkPosType.HOME) {
            types.add(ErrorType.HOME);
        }
        if (crnProtocol.modeType == CrnModeType.AUTO) {
            types.add(ErrorType.FEIZIDONG);
        }
//        if (crnProtocol.getTaskNo().equals(wrkMast.getWrkNo().shortValue())) {
//            types.add(ErrorType.CRNGONGZUOHAO);
//        }
        return types;
    }


}