package com.ld.igds.n2.service;

import com.ld.igds.constant.Constant;
import com.ld.igds.constant.DeviceStatus;
import com.ld.igds.constant.DeviceType;
import com.ld.igds.io.request.ExeDevice;
import com.ld.igds.models.DicTrigger;
import com.ld.igds.models.N2IntelTask;
import com.ld.igds.n2.N2ModelTag;
import com.ld.igds.n2.N2Util;
import com.ld.igds.n2.dto.N2AutoData;
import com.ld.igds.n2.dto.N2MacData;
import com.ld.igds.n2.dto.N2Param;
import com.ld.igds.n2.mapper.N2ServiceMapper;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.util.RedisUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.*;

@Slf4j
@Component
public class CoreN2ServiceImpl implements CoreN2Service {


    @Autowired
    private N2ServiceMapper n2ServiceMapper;
    @Autowired
    private RedisUtil redisUtil;
    @Resource
    private HMacConfService hMacConfService;

    @Override
    public void updateN2MacBySerId(N2MacData data) {
        hMacConfService.updateMac(data);
    }

    @Override
    public List<N2AutoData> listAutoData(N2Param param) {
        return n2ServiceMapper.listAutoData(param);
    }

    @Override
    public List<ExeDevice> listAutoConfData(N2Param param) {
        if (null == param.getAutoId()) {
            log.error("没有获取到模式的信息，查询失败");
            return null;
        }

        List<ExeDevice> list = n2ServiceMapper.listAutoDataConf(param);
        if (null == list || list.isEmpty())
            return null;

        // 调整数据，只获取气调相关设备
        List<ExeDevice> result = new ArrayList<>();
        for (ExeDevice device : list) {

            if (DeviceType.TYPE_04.getCode().equals(device.getType())) {
                result.add(device);
            }
            if (DeviceType.TYPE_07.getCode().equals(device.getType())) {
                result.add(device);
            }
            if (DeviceType.TYPE_09.getCode().equals(device.getType())) {
                result.add(device);
            }
            if (DeviceType.TYPE_0D.getCode().equals(device.getType())) {
                result.add(device);
            }

        }
        return result;
    }

    @Override
    public N2AutoData queryAutoDataById(N2Param param) {
        if (StringUtils.isEmpty(param.getAutoId())) {
            return null;
        }
        N2AutoData result = n2ServiceMapper.queryAutoDataById(param);
        if (null == result) {
            return null;
        }
        result.setListConf(this.listAutoConfData(param));
        return result;
    }

    @Override
    public N2AutoData queryAutoDataByModeTag(N2Param param) {
        if (StringUtils.isEmpty(param.getModeTag())) {
            return null;
        }

        List<N2AutoData> list = n2ServiceMapper.queryAutoDataByModeTag(param);

        if (null == list || list.isEmpty()) return null;

        N2AutoData result = list.get(0);
        param.setAutoId(result.getId());
        result.setListConf(this.listAutoConfData(param));
        return result;
    }

    @Override
    public Map<String, List<ExeDevice>> getExeDeviceByAutoConf(
            List<ExeDevice> listConf, String closeTag) {
        if (null == listConf || listConf.isEmpty())
            return null;

        Map<String, List<ExeDevice>> result = new HashMap<>();
        for (ExeDevice device : listConf) {

            // 屏蔽需要操作的设备信息
            if (null == device.getTargetStatus()) {
                continue;
            }

            if (DeviceStatus.CLOSE.getCode().equals(device.getTargetStatus())) {
                continue;
            }
            if (DeviceStatus.F_CLOSE.getCode().equals(device.getTargetStatus())) {
                continue;
            }
            if (DeviceStatus.W_CLOSE.getCode().equals(device.getTargetStatus())) {
                continue;
            }

            // 需要操作的设备，在执行关闭时候执行反向动作
            if (Constant.YN_Y.equals(closeTag)) {
                if (DeviceStatus.OPEN.getCode()
                        .equals(device.getTargetStatus())) {
                    device.setTargetStatus(DeviceStatus.CLOSE.getCode());
                }
                if (DeviceStatus.W_OPEN.getCode().equals(
                        device.getTargetStatus())) {
                    device.setTargetStatus(DeviceStatus.W_CLOSE.getCode());
                }
                if (DeviceStatus.F_OPEN.getCode().equals(
                        device.getTargetStatus())) {
                    device.setTargetStatus(DeviceStatus.F_CLOSE.getCode());
                    if (DeviceType.TYPE_0C.getCode().equals(device.getType())
                            || DeviceType.TYPE_02.getCode().equals(
                            device.getType())) {
                        device.setTargetStatus(DeviceStatus.W_CLOSE.getCode());
                    }
                }
                if (DeviceStatus.F_OPEN_F.getCode().equals(
                        device.getTargetStatus())) {
                    device.setTargetStatus(DeviceStatus.F_CLOSE.getCode());
                    if (DeviceType.TYPE_0C.getCode().equals(device.getType())
                            || DeviceType.TYPE_02.getCode().equals(
                            device.getType())) {
                        device.setTargetStatus(DeviceStatus.W_CLOSE.getCode());
                    }
                }
            }

            // 执行分组
            if (null == result.get(device.getSerId())) {
                result.put(device.getSerId(), new ArrayList<>());
            }
            result.get(device.getSerId()).add(device);
        }
        return result;
    }

    @Override
    public String updateAuto(N2AutoData data) {

        if (null == data.getDelTag()) data.setDelTag(Constant.YN_N);

        if (Constant.YN_Y.equals(data.getDelTag())) {
            n2ServiceMapper.delAuto(data.getId());
            return "数据删除完成！";
        }

        data.setUpdateTime(new Date());
        data.setUpdateUser(ContextUtil.getLoginUserCName());

        if (StringUtils.isEmpty(data.getExeMode())) {
            data.setExeMode(N2Util.EXE_MODE_01);
        }

        if (StringUtils.isEmpty(data.getId())) {
            data.setId(ContextUtil.getUUID());
            n2ServiceMapper.addAuto(data);

            return "数据新增成功！";
        }

        n2ServiceMapper.updateAuto(data);
        return "数据更新完成！";
    }

    @Override
    public String updateAutoConf(String autoId, List<ExeDevice> deviceList) {
        // 根据模式ID删除原有的配置信息
        n2ServiceMapper.delAutoConfByAutoId(autoId);

        // 遍历设备信息，将目标状态= NONE的设备踢出
        for (ExeDevice device : deviceList) {
            if (StringUtils.isEmpty(device.getTargetStatus())
                    || DeviceStatus.ZERO.getCode().equals(
                    device.getTargetStatus())) {
                // do nothing
            } else {
                device.setAutoId(autoId);
                n2ServiceMapper.addAutoConf(device);
            }
        }
        return "配置更新成功！";
    }

    @Override
    public List<DicTrigger> listN2ModelTag(String allTag) {
        List<DicTrigger> list = new ArrayList<>();

        list.add(new DicTrigger(N2ModelTag.MODEL_01.getCode(), N2ModelTag.MODEL_01.getMsg()));
        list.add(new DicTrigger(N2ModelTag.MODEL_02.getCode(), N2ModelTag.MODEL_02.getMsg()));
        list.add(new DicTrigger(N2ModelTag.MODEL_03.getCode(), N2ModelTag.MODEL_03.getMsg()));
        list.add(new DicTrigger(N2ModelTag.MODEL_04.getCode(), N2ModelTag.MODEL_04.getMsg()));

        list.add(new DicTrigger(N2ModelTag.MODEL_30.getCode(), N2ModelTag.MODEL_30.getMsg()));
        list.add(new DicTrigger(N2ModelTag.MODEL_31.getCode(), N2ModelTag.MODEL_31.getMsg()));

        list.add(new DicTrigger(N2ModelTag.MODEL_99.getCode(), N2ModelTag.MODEL_99.getMsg()));
        return list;
    }

    @Override
    public void addIntelTaskCache(N2IntelTask task) {
        String key = N2Util.createIntelTaskKey(task);
        long time = N2Util.getIntelTaskTime(task);

        redisUtil.set(key, task, time);
    }

    @Override
    public List<N2IntelTask> listIntelTaskByCache(N2Param param) {
        if (null == param) param = new N2Param();
        String patten = N2Util.createIntelTaskKeyPatten();

        Set<String> keys = redisUtil.keys(patten);

        if (null == keys || keys.isEmpty()) return null;

        List<N2IntelTask> result = new ArrayList<>();
        N2IntelTask task;
        for (String key : keys) {
            task = (N2IntelTask) redisUtil.get(key);
            if (null == task) continue;

            if (null == param.getDepotId()) {
                result.add(task);
                continue;
            }

            //如果有仓库信息，只返回当前仓库相关的任务
            if (task.getDepotId().equals(param.getDepotId())) {
                result.add(task);
                continue;
            }
        }
        return result;
    }


}