package com.ruoyi.other.util;

import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.common.core.utils.SpringUtils;
import com.ruoyi.common.core.utils.StringUtils;
import com.ruoyi.other.domain.TPlatformConfig;
import com.ruoyi.other.service.TPlatformConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.LocalDate;
import java.util.*;


/**
 * 定时任务：储能放电情况 光伏发电情况
 */
@Slf4j
@Service
public class KsolarUtils {


    private static String token;

    private static String accessToken;


    private static List<String> stationIds= Arrays.asList("2025060710462417","2025060711331323","2025060715425437","2025060716010425");

    private static final String KSOLAR_URL = "http://111.230.136.62:8092";

    /**
     * 获取今日总发电量
     * @param time
     * @return
     */
    public static Double getTodayEnergy(String time) {
        try {
            HttpRequest get = HttpUtil.createGet("http://111.230.136.62:8092/station/list/earn");
            get.header("Authorization", "Bearer "+token);
            get.form("startDate", time);
            HttpResponse execute = get.execute();
            String body = execute.body();
            JSONObject jsonObject = JSONObject.parseObject(body);
            String code = jsonObject.get("code").toString();
            if(!"200".equals(code)){
                token = token();
                return getTodayEnergy(time);
            }
            Object data  = jsonObject.get("data");
            JSONObject jsonObject1 = JSONObject.parseObject(data.toString());
            Double earn = jsonObject1.getDouble("dayGeneration");
            return earn;
        } catch (Exception e) {
            e.printStackTrace();
            token = token();
            return getTodayEnergy(time);
        }
    }
    public static ArrayList<Map<String, Object>> getMonthEnergy(String time,String time1) {
        ArrayList<Map<String, Object>> list = new ArrayList<>();
        try {
            HttpRequest get = HttpUtil.createGet("http://111.230.136.62:8092/protocol/user/statistic/elec/chart");
            get.header("Authorization", "Bearer "+token);
            get.form("stime", time);
            get.form("attribId", "201");
            HttpResponse execute = get.execute();
            String body = execute.body();
            if(body.contains("code")){
                token = token();
                return getMonthEnergy(time,time1);
            }
            JSONArray jsonArray = JSONArray.parseArray(body);
            for (Object o1 : jsonArray) {
                HashMap<String, Object> stringObjectHashMap = new HashMap<>();
                JSONObject jsonObject = JSONObject.parseObject(o1.toString()) ;
                stringObjectHashMap.put("time", jsonObject.getString("saveTime"));
                stringObjectHashMap.put("value", jsonObject.getString("attribValue"));
                list.add(stringObjectHashMap);
            }
            // 相同月份
            if(!time.equals(time1)){
                list.addAll(getMonthEnergy(time1,time1));
            }

            return list;
        } catch (Exception e) {
            e.printStackTrace();
            token = token();
            return getMonthEnergy(time,time1);
        }
    }



    /**
     * 光伏累计
     * @return
     */
    public static Double getAllEnergy(String time) {
        try {
            HttpRequest get = HttpUtil.createGet("http://111.230.136.62:8092/station/list/earn");
            get.header("Authorization", "Bearer "+token);
            get.form("startDate", time);
            HttpResponse execute = get.execute();
            String body = execute.body();
            JSONObject jsonObject = JSONObject.parseObject(body);
            String code = jsonObject.get("code").toString();
            if(!"200".equals(code)){
                token = token();
                return getAllEnergy(time);
            }
            Object data  = jsonObject.get("data");
            JSONObject jsonObject1 = JSONObject.parseObject(data.toString());
            Double earn = jsonObject1.getDouble("totalGeneration");
            return earn;
        } catch (Exception e) {
            e.printStackTrace();
            token = token();
            return getAllEnergy(time);
        }
    }


    /**
     * 光伏碳减排
     * @return
     */
    public static BigDecimal getYearAllEnergy() {
        Double yearAllEnergy = getYearAllEnergy(stationIds.get(0));
        Double yearAllEnergy1 = getYearAllEnergy(stationIds.get(1));
        Double yearAllEnergy2 = getYearAllEnergy(stationIds.get(2));
        Double yearAllEnergy3 = getYearAllEnergy(stationIds.get(3));
        double v = yearAllEnergy + yearAllEnergy1 + yearAllEnergy2 + yearAllEnergy3;
        BigDecimal divide = new BigDecimal(v).multiply(new BigDecimal("0.1564")).divide(new BigDecimal("1000"), 2, RoundingMode.DOWN);
        return divide;
    }



    private static Double getYearAllEnergy(String stationId) {
        try {
            HttpRequest get = HttpUtil.createGet("http://111.230.136.62:8092/protocol/station/statistic/elec/chart");
            get.header("Authorization", "Bearer "+token);
            get.form("stationId", stationId);
            get.form("attribId", "202");
            get.form("stime",LocalDate.now().getYear()+"" );
            HttpResponse execute = get.execute();
            String body = execute.body();
            JSONArray jsonArray = JSONArray.parseArray(body);
            Object o1 = jsonArray.get(0);
            JSONObject jsonObject = JSONObject.parseObject(o1.toString());
            String code = jsonObject.get("attribValue").toString();
            Double earn = Double.valueOf(code);
            return earn;
        } catch (Exception e) {
            e.printStackTrace();
            token = token();
            return getYearAllEnergy(stationId);
        }
    }



    public static String token() {
        TPlatformConfig config = SpringUtils.getBean(TPlatformConfigService.class).getOne(Wrappers.lambdaQuery(TPlatformConfig.class).eq(TPlatformConfig::getPlatformName, "科士达"));
        if (config == null) {
            config = new TPlatformConfig();
        }
        if (StringUtils.isBlank(config.getAccount()) || StringUtils.isBlank(config.getPassword())) {
            config.setAccount("环岛光伏");
            config.setPassword("cR8GGwIXMI462A8Dfl9eXg==");
        }
        HttpRequest post = HttpUtil.createPost("http://111.230.136.62:8092/authentication/form");
        post.basicAuth("kstar","kstarSecret");
        post.form("username", config.getAccount());
        post.form("password", config.getPassword());
        HttpResponse execute = post.execute();
        String body = execute.body();
        JSONObject jsonObject = JSONObject.parseObject(body);
        String token = jsonObject.getString("token");
        JSONObject jsonObject1 = JSONObject.parseObject(token);
        String access_token = jsonObject1.getString("access_token");
        return  access_token;
    }


    public static String getAccessToken(){
        HttpRequest post = HttpRequest.post("https://www.zsdcloud.cn:8443/openApi/getAccessToken.action?accessId=87bde117-1f29-4371-8d4d-82324d17ddc3");
        HttpResponse execute = post.execute();
        String body = execute.body();
        JSONObject jsonObject = JSONObject.parseObject(body);
        return jsonObject.getString("result");
    }


    /**
     * 消纳数据
     * @return
     */
    public static String getElectricity(){
        String valueTotal = "0";
        String value = "0";
        HttpRequest post = HttpRequest.post("https://www.zsdcloud.cn:8443/openApi/equipment/select.action");
        post.form("token", accessToken);
        post.form("keyCode", "869916072417147");
        post.form("version", "V2");
        HttpResponse execute = post.execute();
        String body = execute.body();
        JSONObject jsonObject = JSONObject.parseObject(body);
        String string = jsonObject.get("statusCode").toString();
        if(!string.equals("200")){
           accessToken =  getAccessToken();
           return getElectricity();

        }
        String string1 = jsonObject.getString("result");
        JSONObject jsonObject1 = JSONObject.parseObject(string1);
        String realInfo = jsonObject1.getString("childList");
        JSONArray jsonArray = JSONArray.parseArray(realInfo);
        for (Object o : jsonArray) {
            JSONObject jsonObject2 = JSONObject.parseObject(o.toString());
            String string2 = jsonObject2.get("valueList").toString();
            JSONArray jsonArray1 = JSONArray.parseArray(string2);
            for (Object o1 : jsonArray1) {
                JSONObject jsonObject3 = JSONObject.parseObject(o1.toString());
                if(jsonObject3.get("Name").toString().equals("系统累计充电量")){
                    valueTotal=  jsonObject3.get("Value").toString();
                }
                if(jsonObject3.get("Name").toString().equals("系统累计放电量")){
                    value=  jsonObject3.get("Value").toString();
                }
            }
        }
        return valueTotal+"_"+value;
    }

    /**
     * 获取用户的发电量和收益统计
     */
    public static JSONObject getListEarn(String time, String token) {
        try {
            HttpRequest get = HttpUtil.createGet(KSOLAR_URL.concat("/station/list/earn"));
            get.header("Authorization", "Bearer "+token);
            if(StringUtils.isNotEmpty(time)) {
                get.form("startDate", time);
            }
            HttpResponse execute = get.execute();
            String body = execute.body();
            JSONObject jsonObject = JSONObject.parseObject(body);
            String code = jsonObject.get("code").toString();
            if("200".equals(code)){
                Object data  = jsonObject.get("data");
                return JSONObject.parseObject(data.toString());
            }
            return null;
        } catch (Exception e) {
            log.error("获取用户的发电量和收益统计-调用第三方接口报错：", e);
            return null;
        }
    }

    /**
     * 获取用户的电站状态统计
     */
    public static JSONObject getListStatus(String token) {
        try {
            HttpRequest get = HttpUtil.createGet(KSOLAR_URL.concat("/station/list/status"));
            get.header("Authorization", "Bearer "+token);
            HttpResponse execute = get.execute();
            String body = execute.body();
            JSONObject jsonObject = JSONObject.parseObject(body);
            String code = jsonObject.get("code").toString();
            if("200".equals(code)){
                Object data  = jsonObject.get("data");
                return JSONObject.parseObject(data.toString());
            }
           return null;
        } catch (Exception e) {
            log.error("获取用户的电站状态统计-调用第三方接口报错：", e);
            return null;
        }
    }

    /**
     * 电站列表信息
     */
    public static JSONArray getStationListInfo(Integer pageNumber, Integer pageSize, String token) {
        try {
            HttpRequest get = HttpUtil.createGet(KSOLAR_URL.concat("/station/list/info"));
            get.header("Authorization", "Bearer "+token);
            get.form("pageNumber", pageNumber);
            get.form("pageSize", pageSize);
            HttpResponse execute = get.execute();
            String body = execute.body();
            JSONObject jsonObject = JSONObject.parseObject(body);
            String code = jsonObject.get("code").toString();
            if("0".equals(code)){
                String rows = jsonObject.get("rows").toString();
                return JSONArray.parseArray(rows);
            }
            return null;
        } catch (Exception e) {
            log.error("电站列表信息-调用第三方接口报错：", e);
            return null;
        }
    }


    /**
     * 电站基本信息列表
     */
    public static JSONArray getStationListBase(Integer pageNumber, Integer pageSize, String token) {
        try {
            HttpRequest post = HttpUtil.createPost(KSOLAR_URL.concat("/station/list/base"));
            post.header("Authorization", "Bearer "+token);
            post.header("Content-Type", "application/json");
            JSONObject param = new JSONObject();
            param.put("pageNumber", pageNumber);
            param.put("pageSize", pageSize);

            HttpResponse execute = post.body(param.toJSONString()).execute();
            String body = execute.body();
            JSONObject jsonObject = JSONObject.parseObject(body);
            String code = jsonObject.get("code").toString();
            if("0".equals(code)){
                String rows = jsonObject.get("rows").toString();
                return JSONArray.parseArray(rows);
            }
            return null;
        } catch (Exception e) {
            log.error("电站列表信息-调用第三方接口报错：", e);
            return null;
        }
    }


    /**
     * 逆变器列表
     */
    public static JSONArray getCollectBaseList(Integer pageNumber, Integer pageSize, String token) {
        try {
            HttpRequest post = HttpUtil.createPost(KSOLAR_URL.concat("/collect/manager/base/list"));
            post.header("Authorization", "Bearer "+token);
            post.header("Content-Type", "application/json");
            JSONObject param = new JSONObject();
            param.put("pageNumber", pageNumber);
            param.put("pageSize", pageSize);

            HttpResponse execute = post.body(param.toJSONString()).execute();
            String body = execute.body();
            JSONObject jsonObject = JSONObject.parseObject(body);
            String code = jsonObject.get("code").toString();
            if("0".equals(code)){
                String rows = jsonObject.get("rows").toString();
                return JSONArray.parseArray(rows);
            }
            return null;
        } catch (Exception e) {
            log.error("逆变器列表-调用第三方接口报错：", e);
            return null;
        }
    }

    /**
     * 电站发电量和收益统计明细
     */
    public static JSONArray getStationElecList(String startDate, String endDate, String token) {
        try {
            HttpRequest get = HttpUtil.createGet(KSOLAR_URL.concat("/protocol/station/statistic/elec/detail"));
            get.header("Authorization", "Bearer "+token);
            if(StringUtils.isNotEmpty(startDate)) {
                get.form("startDate", startDate);
            }
            if(StringUtils.isNotEmpty(endDate)) {
                get.form("endDate", endDate);
            }
            HttpResponse execute = get.execute();
            String body = execute.body();
            return JSONArray.parseArray(body);
        } catch (Exception e) {
            log.error("电站的电量和收益统计查询-调用第三方接口报错：", e);
            return null;
        }
    }

    /**
     * 查询单个电站的发电量和收益
     */
    public static JSONObject getStationEarnDetail(String stationId, String token) {
        try {
            HttpRequest get = HttpUtil.createGet(KSOLAR_URL.concat("/station/detail/earn"));
            get.header("Authorization", "Bearer "+token);
            if(StringUtils.isNotEmpty(stationId)) {
                get.form("stationId", stationId);
            }
            HttpResponse execute = get.execute();
            String body = execute.body();
            JSONObject jsonObject = JSONObject.parseObject(body);
            Object data  = jsonObject.get("data");
            return JSONObject.parseObject(data.toString());
        } catch (Exception e) {
            log.error("电站的电量和收益统计查询-调用第三方接口报错：", e);
            return null;
        }
    }


}