package com.ruoyi.quartz.task;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ruoyi.fuzhou.domain.*;
import com.ruoyi.fuzhou.enums.DataTypeEnum;
import com.ruoyi.fuzhou.service.*;
import com.ruoyi.fuzhou.utils.electricitymodbus.HexStringToInt;
import com.ruoyi.fuzhou.utils.hj1239.FileReadUtils;
import com.ruoyi.fuzhou.utils.hj1239.StringToHexUtil;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Component;
import com.ruoyi.common.utils.StringUtils;

import java.io.File;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 定时任务调度测试
 *
 * @author ruoyi
 */
@Component("ryTask")
public class RyTask {
    @Resource
    private EquipmentService equipmentService;

    @Resource
    private ReceiveElectricityInfoService receiveElectricityInfoService;

    @Resource
    private ReceiveOilInfoService receiveOilInfoService;

    @Resource
    private ReceiveWaterInfoService receiveWaterInfoService;

    @Resource
    private ReceiveCarRuleService receiveCarRuleService;

    @Resource
    private ReceiveCarValueService receiveCarValueService;

    @Resource
    private ReceiveWeatherInfoService receiveWeatherInfoService;

    @Resource
    private ReceiveSlmInfoService receiveSlmInfoService;

    @Resource
    private ReceiveWeatherValueService receiveWeatherValueService;

    @Resource
    private HikService hikService;

    @Resource
    private ReceiveElectricityValueService receiveElectricityValueService;

    /**
     * 电数据接入
     */
    public void ryMultipleParams(String name) {
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).eq(DpEquipment::getEquipmentTypeId, DataTypeEnum.ELECTRICITY.getCode());
        }});
        for (DpEquipment info : equipments) {
            List<ReceiveElectricityInfo> list = receiveElectricityInfoService.list(new LambdaQueryWrapper<ReceiveElectricityInfo>() {{
                or().eq(ReceiveElectricityInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveElectricityInfo::getParamCode, "createTime");
            }});
            if (list != null && list.size() > 0) {
                receiveElectricityInfoService.saveElectricity(list, info);
            }
        }
    }

    /**
     * 油数据接入
     *
     * @param name
     */
    public void ryParams(String name) {
        System.out.println("执行有参方法：" + name);
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).in(DpEquipment::getEquipmentTypeId, DataTypeEnum.OIL.getCode());
        }});
        for (DpEquipment info : equipments) {
            List<ReceiveOilInfo> list = receiveOilInfoService.list(new LambdaQueryWrapper<ReceiveOilInfo>() {{
                or().eq(ReceiveOilInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveOilInfo::getParamCode, "createTime");
            }});
            if (list != null && list.size() > 0) {
                receiveOilInfoService.saveOil(list, info);
            }
        }
    }


    /**
     * 气象数据数据接入
     *
     * @param name
     */
    public void wsParams(String name) {
        System.out.println("执行有参方法：" + name);
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).in(DpEquipment::getEquipmentTypeId, DataTypeEnum.WEATHER.getCode());
        }});
        for (DpEquipment info : equipments) {
            List<ReceiveWeatherInfo> list = receiveWeatherInfoService.list(new LambdaQueryWrapper<ReceiveWeatherInfo>() {{
                or().eq(ReceiveWeatherInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveWeatherInfo::getParamCode, "createTime");
            }});
            if (list != null && list.size() > 0) {
                receiveWeatherInfoService.saveData(list, info);
            }
        }
    }

    /**
     * 气象数据告警
     *
     * @param windSpeedValue  风速阈值
     * @param windSpeedTime   风速检测时间
     * @param tempSpeedValue  温度阈值
     * @param tempSpeedTime   温度检测时间
     */
    public void wsGaoJingParams(Integer windSpeedValue,Integer windSpeedTime,Integer tempSpeedValue,Integer tempSpeedTime,Integer interval) {
        System.out.println("执行气象数据--告警有参方法：" + windSpeedValue+";"+ windSpeedTime+";"+ tempSpeedValue+";"+ tempSpeedTime+";");

        if(interval==null){
            interval=10;
        }
        LocalDateTime now=LocalDateTime.now();
        Date nowDate=new Date();

        LocalDateTime agoSpeedTime=now.minusMinutes(windSpeedTime);
        LocalDateTime agoWenduSpeedTime=now.minusMinutes(tempSpeedTime);


        List<ReceiveWeatherValue> list = receiveWeatherValueService.list(new LambdaQueryWrapper<ReceiveWeatherValue>() {{
             ge(ReceiveWeatherValue::getCreateTime,agoSpeedTime).le(ReceiveWeatherValue::getCreateTime,now);
        }});

        Boolean hasfengsubaojing=fengsubaojingpanduan(list,windSpeedValue,nowDate,interval);

        if(hasfengsubaojing){
            HikEvent hikEvent=new HikEvent();
            hikEvent.setHappenTime(list.get(0).getCreateTime());
            hikEvent.setSendTime(nowDate);
            hikEvent.setEventType(101);//风速101 温度102
            hikEvent.setSrcName("风速告警");
            hikEvent.setSrcType("气象设备");
            hikService.saveInsert(hikEvent);
        }
        List<ReceiveWeatherValue> listTemp = receiveWeatherValueService.list(new LambdaQueryWrapper<ReceiveWeatherValue>() {{
            ge(ReceiveWeatherValue::getCreateTime,agoWenduSpeedTime).le(ReceiveWeatherValue::getCreateTime,now);
        }});

        Boolean haswendubaojing=wendubaojingpanduan(listTemp,tempSpeedValue,nowDate,interval);

        if(haswendubaojing){
            HikEvent hikEvent=new HikEvent();
            hikEvent.setHappenTime(list.get(0).getCreateTime());
            hikEvent.setSendTime(nowDate);
            hikEvent.setEventType(102);//风速101 温度102
            hikEvent.setSrcName("温度告警");
            hikEvent.setSrcType("气象设备");
            hikService.saveInsert(hikEvent);
        }
    }

    /**
     * 智能电表报警
     * @param lXian 线电压-低
     * @param hXian 线电压-高
     * @param lXiang 相电压-低
     * @param hXiang 相电压-高
     */
    public void dbGaoJing(Integer lXian, Integer hXian, Integer lXiang, Integer hXiang) {
        List<DpEquipment> list = equipmentService.getListByType(3);
        if (null == list || list.isEmpty()) return;

        for (DpEquipment dp : list) {
            QueryWrapper<ReceiveElectricityValue> wrapper = new QueryWrapper<>();
            //wrapper.eq(ReceiveElectricityValue::getDeviceName, String.valueOf(dp.getId()));
            wrapper.eq("DEVICE_NAME", String.valueOf(dp.getId()));
            //wrapper.orderByDesc(ReceiveElectricityValue::getCreateTime);
            wrapper.orderByDesc("CREATE_TIME");
            wrapper.last("limit 1");

            ReceiveElectricityValue rs = receiveElectricityValueService.getOne(wrapper);
            if (null == rs) continue;
            double voltageA = Double.parseDouble(rs.getVoltageA());
            double voltageB = Double.parseDouble(rs.getVoltageB());
            double voltageC = Double.parseDouble(rs.getVoltageC());
            double voltageCa = Double.parseDouble(rs.getVoltageCa());
            double voltageAb = Double.parseDouble(rs.getVoltageAb());
            double voltageBc = Double.parseDouble(rs.getVoltageBc());

            HikEvent hikEvent = new HikEvent();
            hikEvent.setHappenTime(rs.getCreateTime());
            hikEvent.setSendTime(new Date());
            hikEvent.setSrcName(dp.getEquName());
            hikEvent.setSrcIndex(String.valueOf(dp.getId()));

            // voltageA-A相电压, B相电压-voltageB, C相电压-voltageC
            List<String> ycList = new ArrayList<>();
            if (voltageA < 1) ycList.add("A");
            if (voltageB < 1) ycList.add("B");
            if (voltageC < 1) ycList.add("C");
            if (!ycList.isEmpty()) {
                hikEvent.setEventType(103); // 103-电压异常, 104-过欠压
                hikEvent.setSrcType(StringUtils.join(ycList, " | "));
                hikService.saveInsert(hikEvent);
                continue;
            }

            List<String> qyList = new ArrayList<>();
            // voltageCa-CA线电压, AB线电压-voltageAb, BC线电压-voltageBc
            if (voltageCa < lXian || voltageCa > hXian) qyList.add("CA");
            if (voltageAb < lXian || voltageAb > hXian) qyList.add("AB");
            if (voltageBc < lXian || voltageBc > hXian) qyList.add("BC");

            // voltageA-A相电压, B相电压-voltageB, C相电压-voltageC
            if (voltageA < lXiang || voltageA > hXiang) qyList.add("A");
            if (voltageB < lXiang || voltageB > hXiang) qyList.add("B");
            if (voltageC < lXiang || voltageC > hXiang) qyList.add("C");
            if (!qyList.isEmpty()) {
                hikEvent.setEventType(104); // 103-电压异常, 104-过欠压
                hikEvent.setSrcType(StringUtils.join(qyList, " | "));
                hikService.saveInsert(hikEvent);
            }
        }
    }

    public Boolean fengsubaojingpanduan(List<ReceiveWeatherValue> list,int value,Date now,Integer interval){
        if(list.size()>=5){
            for (int i = 0; i < list.size(); i++) {
                if(list.get(i).getWindSpeed()!=null&&Double.parseDouble(list.get(i).getWindSpeed())<value){
                    return false;
                }
            }
            //最后一次报警时间   getSendTime 插入时间  happenTime 数据时间
            List<HikEvent> hList=hikService.list(new LambdaQueryWrapper<HikEvent>() {{
                eq(HikEvent::getEventType,101).orderByDesc(HikEvent::getSendTime).last("LIMIT 1");
            }});
            if(hList.size()>0){
                HikEvent hData=hList.get(0);

                if(now.getTime()-hData.getSendTime().getTime()>=1000*60*interval){
                    return true;
                }


            }
            return false;
        }else {
            return false;
        }

    }

    public Boolean wendubaojingpanduan(List<ReceiveWeatherValue> list,int value,Date now,Integer interval){
        if(list.size()>=5){
            for (int i = 0; i < list.size(); i++) {
                if(list.get(i).getTemp()!=null&&Double.parseDouble(list.get(i).getTemp())<value){
                    return false;
                }
            }
            //最后一次报警时间   getSendTime 插入时间  happenTime 数据时间
            List<HikEvent> hList=hikService.list(new LambdaQueryWrapper<HikEvent>() {{
                eq(HikEvent::getEventType,102).orderByDesc(HikEvent::getSendTime).last("LIMIT 1");
            }});
            if(hList.size()>0){
                HikEvent hData=hList.get(0);

                if(now.getTime()-hData.getSendTime().getTime()>=1000*60*interval){
                    return true;
                }


            }
            return false;
        }else {
            return false;
        }

    }

    /**
     * 激光雷达数据数据接入
     *
     * @param name
     */
    public void slmParams(String name) {
        System.out.println("执行有参方法：" + name);
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).in(DpEquipment::getEquipmentTypeId, DataTypeEnum.SLM.getCode());
        }});
        for (DpEquipment info : equipments) {
            List<ReceiveSlmInfo> list = receiveSlmInfoService.list(new LambdaQueryWrapper<ReceiveSlmInfo>() {{
                or().eq(ReceiveSlmInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveSlmInfo::getParamCode, "createTime");
            }});
            if (list != null && list.size() > 0) {
                receiveSlmInfoService.saveData(list, info);
            }
        }
    }

    /**
     * 利旧油数据接入
     *
     * @param name
     */
    public void ryLijiuParams(String name) {
        System.out.println("执行有参方法：" + name);
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).in(DpEquipment::getEquipmentTypeId, DataTypeEnum.LIJIUOIL.getCode());
        }});
        for (DpEquipment info : equipments) {
            List<ReceiveOilInfo> list = receiveOilInfoService.list(new LambdaQueryWrapper<ReceiveOilInfo>() {{
                or().eq(ReceiveOilInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveOilInfo::getParamCode, "createTime");
            }});
            if (list != null && list.size() > 0) {
                receiveOilInfoService.saveLijiuOil(list, info);
            }
        }
    }

    /**
     * 宁德退油数据接入
     *
     * @param name
     */
    public synchronized void ningdeLijiuParams(String name) {
        System.out.println("执行有参方法：" + name);
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).in(DpEquipment::getEquipmentTypeId, DataTypeEnum.LIJIUJUN.getCode());
        }});
        for (DpEquipment info : equipments) {
            try {
                List<ReceiveOilInfo> list = receiveOilInfoService.list(new LambdaQueryWrapper<ReceiveOilInfo>() {{
                    or().eq(ReceiveOilInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveOilInfo::getParamCode, "createTime");
                }});
                Thread.sleep(1000);
                if (list != null && list.size() > 0) {
                    receiveOilInfoService.saveOilLijiuNingde(list, info);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }

        }
    }

    /**
     * 水数据接入
     */
    public void ryNoParams(String name) {
        System.out.println("执行无参方法");
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).in(DpEquipment::getEquipmentTypeId, DataTypeEnum.WATER_FLOW.getCode());
        }});
        for (DpEquipment info : equipments
        ) {
            List<ReceiveWaterInfo> list = receiveWaterInfoService.list(new LambdaQueryWrapper<ReceiveWaterInfo>() {{
                or().eq(ReceiveWaterInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveWaterInfo::getParamCode, "createTime");
            }});
            if (list != null && list.size() > 0) {
                receiveWaterInfoService.saveWater(list, info);
            }
        }
    }

    /**
     * 水数据接入
     */
    public void saveWaterYa(String name) {
        System.out.println("执行无参方法");
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).in(DpEquipment::getEquipmentTypeId, DataTypeEnum.WATER_YA.getCode());
        }});
        for (DpEquipment info : equipments
        ) {
            List<ReceiveWaterInfo> list = receiveWaterInfoService.list(new LambdaQueryWrapper<ReceiveWaterInfo>() {{
                or().eq(ReceiveWaterInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveWaterInfo::getParamCode, "createTime");
            }});
            if (list != null && list.size() > 0) {
                receiveWaterInfoService.saveWaterYa(list, info);
            }
        }
    }

    /**
     * 水数据接入
     */
    public void saveWaterDept(String name) {
        System.out.println("执行无参方法");
        List<DpEquipment> equipments = equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().like(StringUtils.isNotEmpty(name), DpEquipment::getEquName, name).in(DpEquipment::getEquipmentTypeId, DataTypeEnum.WATER_DEPT.getCode());
        }});
        for (DpEquipment info : equipments
        ) {
            List<ReceiveWaterInfo> list = receiveWaterInfoService.list(new LambdaQueryWrapper<ReceiveWaterInfo>() {{
                or().eq(ReceiveWaterInfo::getDeviceName, String.valueOf(info.getId())).notIn(ReceiveWaterInfo::getParamCode, "createTime");
            }});
            if (list != null && list.size() > 0) {
                receiveWaterInfoService.saveWaterDept(list, info);
            }
        }
    }

    public void carHj1239Task(String ftpFilePath, String tmpPath) {
        File file = new File(ftpFilePath);
        File[] fs = file.listFiles();
        List<String> filePath = new ArrayList<>();
        for (File f : fs) {
            if (!f.isDirectory()) {
                filePath.add(f.getAbsolutePath());
            }
        }
        List<ReceiveCarRule> receiveCarRules = receiveCarRuleService.list(new LambdaQueryWrapper<ReceiveCarRule>() {{
            orderByAsc(ReceiveCarRule::getId);
        }});
        for (String path : filePath
        ) {
            try {
                byte[] bytes = FileReadUtils.readFromByteFile(path);
                String content = FileReadUtils.bytesToHex(bytes);
                content = content.replace("aaaabbbbccccaaaa", "aaaabbbb,ccccaaaa");
                String[] src = content.split(",");
                List<ReceiveCarValue> receiveCarValues = new ArrayList<>();
                for (int i = 0; i < src.length; i++) {
                    String item = src[i];
                    JSONObject jsonObject = getvalue(receiveCarRules, item);
                    ReceiveCarValue receiveCarValue = JSON.parseObject(jsonObject.toJSONString(), ReceiveCarValue.class);
                    receiveCarValue.setCreateTime(new Date());
                    receiveCarValues.add(receiveCarValue);
                    System.out.println(jsonObject);
                }
                receiveCarValueService.saveOrUpdateBatch(receiveCarValues);
                //源文件
                File a = new File(path);
                //目标目录
                File b = new File(tmpPath);
                if (!b.exists()) {
                    b.mkdirs();
                }
                File bFile = new File(b + a.getName());
                //调用File类的核心方法renameTo
                a.renameTo(bFile);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    private static JSONObject getvalue(List<ReceiveCarRule> rule, String content) {
        JSONObject jsonObject = new JSONObject();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        for (ReceiveCarRule r : rule
        ) {

            if (!"createTime".equals(r.getCarCode())) {
                String xx = content.substring(r.getStart() * 2, r.getStart() * 2 + r.getDataLength() * 2);
                if ("VARCHAR".equals(r.getDataType()) && "NONE".equals(r.getRule())) {
                    jsonObject.put(r.getCarCode(), StringToHexUtil.convertHexToString(xx));
                } else if ("WORD".equals(r.getDataType()) && "NONE".equals(r.getRule())) {
                    jsonObject.put(r.getCarCode(), String.valueOf(HexStringToInt.hexStringToInt2(xx)));
                } else if ("BYTE[6]".equals(r.getDataType()) && "NONE".equals(r.getRule())) {
                    String dateTime = "20";
                    dateTime = dateTime + HexStringToInt.hexStringToString(xx.substring(0, 2)) + "-";
                    dateTime = dateTime + HexStringToInt.hexStringToString(xx.substring(2, 4)) + "-";
                    dateTime = dateTime + HexStringToInt.hexStringToString(xx.substring(4, 6)) + " ";
                    dateTime = dateTime + HexStringToInt.hexStringToString(xx.substring(6, 8)) + ":";
                    dateTime = dateTime + HexStringToInt.hexStringToString(xx.substring(8, 10)) + ":";
                    dateTime = dateTime + HexStringToInt.hexStringToString(xx.substring(10, 12));
                    jsonObject.put(r.getCarCode(), dateTime);
                } else if ("WORD".equals(r.getDataType()) && "COMPUTE".equals(r.getRule())) {
                    if ("ffff".equals(xx)) {
                        jsonObject.put(r.getCarCode(), "");
                    } else {
                        jsonObject.put(r.getCarCode(), String.valueOf(new BigDecimal(HexStringToInt.hexStringToInt2(xx) * Double.valueOf(r.getRuleValue()) + Double.valueOf(r.getOffset())).setScale(3, RoundingMode.UP).doubleValue()));
                    }
                } else if ("BYTE".equals(r.getDataType()) && "COMPUTE".equals(r.getRule())) {
                    if ("ff".equals(xx)) {
                        jsonObject.put(r.getCarCode(), "");
                    } else {
                        jsonObject.put(r.getCarCode(), String.valueOf(HexStringToInt.hexStringToInt2(xx) * Double.valueOf(r.getRuleValue()) + Double.valueOf(r.getOffset())));
                    }
                } else if ("DWORD".equals(r.getDataType()) && "COMPUTE".equals(r.getRule())) {
                    if ("ffffffff".equals(xx)) {
                        jsonObject.put(r.getCarCode(), "");
                    } else {
                        jsonObject.put(r.getCarCode(), String.valueOf(Long.parseLong(xx, 16) * Double.valueOf(r.getRuleValue()) + Double.valueOf(r.getOffset())));
                    }

                }
            }
        }
        try {
            jsonObject.put("id", sdf.parse(jsonObject.getString("dataTime")).getTime() + jsonObject.getString("vin"));
        } catch (Exception e) {
            e.printStackTrace();
        }
        return jsonObject;
    }
}