package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.AlarmRuleMapper;
import com.whyc.pojo.AlarmRule;
import io.swagger.models.auth.In;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.stream.Stream;

@Service
public class AlarmRuleService {

    @Resource
    private AlarmRuleMapper mapper;

    public Response<List<AlarmRule>> getRuleByDeviceFlag(int deviceFlag) {
        QueryWrapper<AlarmRule> wrapper = Wrappers.query();
        if(deviceFlag==201){
            wrapper.in("device_flag",201,202,203,204);
        }else {
            wrapper.eq("device_flag", deviceFlag);
        }
        List<AlarmRule> alarmRules = mapper.selectList(wrapper);
        return new Response<List<AlarmRule>>().set(1,alarmRules);
    }

    /**
     * 必须考虑阈值和级别的关系
     * TODO 必须考虑阈值和级别的关系
     * @param alarmRule
     * @return
     */
    public Response add(AlarmRule alarmRule) {

        mapper.insert(alarmRule);
        return new Response().setMsg(1,"新增成功");
    }

    public Response update(AlarmRule alarmRule) {
        mapper.updateById(alarmRule);
        return new Response().setMsg(1,"更新成功");
    }

    public Response delete(int id) {
        mapper.deleteById(id);
        return new Response().set(1,"删除成功");
    }

    /**
     * 提前校验,如果库中存在 同 设备&字段&阈值标识
     * 的数据,则需要根据当前选择的级别,给出阈值
     *
     * 如果数据库中已经存在当前传入的级别,说明当前是编辑时修改阈值,故先排除当前级别的值
     * @param alarmRule
     * @return
     */
    public Response getThresholdValueByLevel(AlarmRule alarmRule) {
        List<AlarmRule> listWithSameThreshold = mapper.getListWithSameThreshold(alarmRule);
        //查询到level和thresholdValue,对比当前的level,得到允许的阈值范围
        //获取到的就近的level
        //如果thresholdFlag为1,过低,level越大,thresholdValue应该越小
        //如果thresholdFlag为2,过高,level越大,thresholdValue应该越大
        final Object[][] aboveCloserLevel = new Object[1][2];
        final Object[][] belowCloserLevel = new Object[1][2];

        LinkedList<Object> thresholdValueRange = new LinkedList<>();

        if(alarmRule.getThresholdFlag()==2) {
            listWithSameThreshold.stream().forEach(alarmRuleLevel -> {
                if(alarmRule.getLevel()==alarmRuleLevel.getLevel()){
                    //如果告警级别相等,不携带数据作参考,这里必定是编辑时的阈值范围获取
                }
                else if (alarmRule.getLevel() > alarmRuleLevel.getLevel()) {
                    if (belowCloserLevel[0][0] != null) {
                        if ((Integer) (belowCloserLevel[0][0]) < alarmRuleLevel.getLevel()) {
                            belowCloserLevel[0][0] = alarmRuleLevel.getLevel();
                            belowCloserLevel[0][1] = alarmRuleLevel.getThresholdValue();
                        }
                    } else {
                        belowCloserLevel[0][0] = alarmRuleLevel.getLevel();
                        belowCloserLevel[0][1] = alarmRuleLevel.getThresholdValue();
                    }
                } else {
                    if (aboveCloserLevel[0][0] != null) {
                        if ((Integer) (aboveCloserLevel[0][0]) > alarmRuleLevel.getLevel()) {
                            aboveCloserLevel[0][0] = alarmRuleLevel.getLevel();
                            aboveCloserLevel[0][1] = alarmRuleLevel.getThresholdValue();
                        }
                    } else {
                        aboveCloserLevel[0][0] = alarmRuleLevel.getLevel();
                        aboveCloserLevel[0][1] = alarmRuleLevel.getThresholdValue();
                    }
                }
            });
            thresholdValueRange.add(belowCloserLevel[0][1]);
            thresholdValueRange.add(aboveCloserLevel[0][1]);
        }else{
            listWithSameThreshold.stream().forEach(alarmRuleLevel -> {
                if(alarmRule.getLevel()==alarmRuleLevel.getLevel()){
                    //如果告警级别相等,不携带数据作参考,这里必定是编辑时的阈值范围获取
                }
                else if (alarmRule.getLevel() > alarmRuleLevel.getLevel()) {
                    if (belowCloserLevel[0][0] != null) {
                        if ((Integer) (belowCloserLevel[0][0]) < alarmRuleLevel.getLevel()) {
                            belowCloserLevel[0][0] = alarmRuleLevel.getLevel();
                            belowCloserLevel[0][1] = alarmRuleLevel.getThresholdValue();
                        }
                    } else {
                        belowCloserLevel[0][0] = alarmRuleLevel.getLevel();
                        belowCloserLevel[0][1] = alarmRuleLevel.getThresholdValue();
                    }
                } else {
                    if (aboveCloserLevel[0][0] != null) {
                        if ((Integer) (aboveCloserLevel[0][0]) > alarmRuleLevel.getLevel()) {
                            aboveCloserLevel[0][0] = alarmRuleLevel.getLevel();
                            aboveCloserLevel[0][1] = alarmRuleLevel.getThresholdValue();
                        }
                    } else {
                        aboveCloserLevel[0][0] = alarmRuleLevel.getLevel();
                        aboveCloserLevel[0][1] = alarmRuleLevel.getThresholdValue();
                    }
                }
            });
            thresholdValueRange.add(aboveCloserLevel[0][1]);
            thresholdValueRange.add(belowCloserLevel[0][1]);
        }



        return new Response().set(1,thresholdValueRange);
    }

    public Response getLevelListWithSameAlarm(Integer deviceFlag, String field, Integer thresholdFlag) {
        List<Integer>  levelList = mapper.getLevelListWithSameAlarm(deviceFlag,field,thresholdFlag);
        return new Response().set(1,levelList);
    }

}