package com.iailab.module.data.http.collector;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.iailab.module.data.common.utils.HttpsRequest;
import com.iailab.api.IFeignModelApi;
import com.iailab.module.data.http.entity.HttpApiEntity;
import com.iailab.module.data.http.service.HttpTokenService;
import com.iailab.module.data.http.service.HttpApiService;
import com.iailab.module.data.http.service.HttpTagService;
import com.iailab.module.data.influxdb.service.InfluxDBService;
import lombok.extern.slf4j.Slf4j;
import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 山大设备数据采集
 *
 * @author lirm
 * @Description
 * @createTime 2024年05月21日
 */
@Slf4j
@Component
public class HttpCollectorForSD {

    @Resource
    private HttpApiService httpApiService;

    @Resource
    private HttpTagService httpTagService;

    @Resource
    HttpTokenService httpTokenService;
    @Resource
    HttpsRequest httpsRequest;

    @Resource
    private IFeignModelApi feignModelApi;

    @Resource
    private InfluxDBService influxDBService;

    public void getRunStateValue(Map<String, String> tMap) {
        Map<String, Integer> monitorCountMap = new HashMap<>();
        HttpApiEntity httpApi = httpApiService.getByCode(tMap.get("code"));
        String token = httpTokenService.queryToken(tMap.get("client_id"));
        Map<String, String> queryParams = new HashMap<>();
        queryParams.put("cu_ids", tMap.get("cu_ids"));
        queryParams.put("t", tMap.get("t"));
        String responseStr = httpsRequest.doGetSDData(httpApi.getUrl(), queryParams, "utf-8", token, tMap);
        JSONObject responseObj = JSON.parseObject(responseStr);
        if ("0".equals(responseObj.get("code").toString())) {
            JSONObject dataObject = (JSONObject) responseObj.get("data");

            JSONArray hasSensorArray = dataObject.getJSONArray("has_sensor");
            if (!CollectionUtils.isEmpty(hasSensorArray)) {
                for (int i = 0; i < hasSensorArray.size(); i++) {
                    JSONObject item = hasSensorArray.getJSONObject(i);
                    String value = item.get("de_has_sensor").toString();
                    if ("yes".equals(value)) {
                        monitorCountMap.put("total_count", Integer.parseInt(item.get("count").toString()));//在线监控设备数量
                    }
                }
            }
            JSONArray stateArray = dataObject.getJSONArray("state");
            if (!CollectionUtils.isEmpty(stateArray)) {
                monitorCountMap.put("offline_count", 0);
                monitorCountMap.put("halt_count", 0);
                monitorCountMap.put("run_count", 0);
                for (int i = 0; i < stateArray.size(); i++) {
                    JSONObject item = stateArray.getJSONObject(i);
                    String value = item.get("device_state").toString();
                    if ("0".equals(value)) {
                        monitorCountMap.put("offline_count", Integer.parseInt(item.get("count").toString()));//离线设备数量
                    } else if ("1".equals(value)) {
                        monitorCountMap.put("halt_count", Integer.parseInt(item.get("count").toString()));//停机设备数量
                    } else if ("2".equals(value)) {
                        monitorCountMap.put("run_count", Integer.parseInt(item.get("count").toString()));//运行设备数量
                    }
                }
            }
            if (!monitorCountMap.isEmpty()) {
                feignModelApi.insertRunState(monitorCountMap);
            }
        }
    }

    public void getHealthStateValue(Map<String, String> tMap) {
        Map<String, Object> monitorCountMap = new HashMap<>();
        HttpApiEntity httpApi = httpApiService.getByCode(tMap.get("code"));
        String token = httpTokenService.queryToken(tMap.get("client_id"));
        Map<String, String> queryParams = new HashMap<>();
        queryParams.put("cu_ids", tMap.get("cu_ids"));
        queryParams.put("t", tMap.get("t"));
        String responseStr = httpsRequest.doGetSDData(httpApi.getUrl(), queryParams, "utf-8", token, tMap);
        JSONObject responseObj = JSON.parseObject(responseStr);
        if ("0".equals(responseObj.get("code").toString())) {
            JSONArray hasSensorArray = responseObj.getJSONArray("data");
            if (!CollectionUtils.isEmpty(hasSensorArray)) {
                for (int i = 0; i < hasSensorArray.size(); i++) {
                    JSONObject item = hasSensorArray.getJSONObject(i);
                    String value = item.get("fault_level").toString();
                    if ("0".equals(value)) {
                        monitorCountMap.put("normal", item.get("count"));//正常
                    } else if ("1".equals(value)) {
                        monitorCountMap.put("common", item.get("count"));//一般
                    } else if ("2".equals(value)) {
                        monitorCountMap.put("heavy", item.get("count"));//较重
                    } else if ("3".equals(value)) {
                        monitorCountMap.put("serious", item.get("count"));//严重
                    } else if ("4".equals(value)) {
                        monitorCountMap.put("espSerious", item.get("count"));//特别严重
                    }
                }
            }
            if (!monitorCountMap.isEmpty()) {
                feignModelApi.insertHealthState(monitorCountMap);
            }
        }
    }

    public void getDeviceList(Map<String, String> tMap) {
        HttpApiEntity httpApi = httpApiService.getByCode(tMap.get("code"));
        tMap.put("url", httpApi.getUrl());

        feignModelApi.insertDeviceList(tMap);
    }

    public void getTemperatureValue(Map<String, String> tMap, Date date) {
        Map<String, Object> monitorCountMap = new HashMap<>();
        HttpApiEntity httpApi = httpApiService.getByCode(tMap.get("code"));
        String token = httpTokenService.queryToken(tMap.get("client_id"));
        List<String> deviceIdList = feignModelApi.getDeviceIdList();
        if (!CollectionUtils.isEmpty(deviceIdList)) {
            for (String deviceId : deviceIdList) {
                List<String> tagNoList = httpTagService.getByTagType(deviceId);
                if (CollectionUtils.isEmpty(tagNoList)) {
                    continue;
                }
                StringBuffer sb = new StringBuffer();
                sb.append(httpApi.getUrl());
                sb.append("/");
                sb.append(deviceId);
                Map<String, String> queryParams = new HashMap<>();
                String responseStr = httpsRequest.doGetSDData(sb.toString(), queryParams, "utf-8", token, tMap);
                JSONObject responseObj = JSON.parseObject(responseStr);
                if ("200".equals(responseObj.get("status").toString())) {
                    JSONObject dataObject = (JSONObject) responseObj.get("data");
                    JSONArray jsonArray = dataObject.getJSONArray("realtime-params");
                    if (!CollectionUtils.isEmpty(jsonArray)) {
                        for (int i = 0; i < jsonArray.size(); i++) {
                            JSONObject item = jsonArray.getJSONObject(i);
                            String order = item.get("cp_order").toString();
                            String name = item.get("param_name").toString();
                            if ("1".equals(order) && "温度".equals(name)) {
                                for (String tagCode : tagNoList) {
                                    String value = item.get("last_value").toString();
                                    // Date date = DateUtils.parse(item.get("last_time").toString(),"yyyy-MM-dd HH:mm:ss");
                                    if (tagCode.contains("Temperature")) {
                                        influxDBService.syncWriteFloatValue(tagCode, value, date.getTime());
                                    }
                                }
                            }
                            if ("1".equals(order) && "1倍频振幅".equals(name)) {
                                for (String tagCode : tagNoList) {
                                    String value = item.get("last_value").toString();
                                    // Date date = DateUtils.parse(item.get("last_time").toString(),"yyyy-MM-dd HH:mm:ss");
                                    if (tagCode.contains("Flutter")) {
                                        influxDBService.syncWriteFloatValue(tagCode, value, date.getTime());
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
    }
}