package com.example.getweather.service;

import cn.hutool.db.Db;
import cn.hutool.db.Entity;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.example.getweather.entity.DistrictCodeDO;
import com.example.getweather.entity.HeFengDay;
import com.example.getweather.util.WeixinPush;
import com.taosdata.jdbc.TSDBDriver;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.sql.Timestamp;
import java.time.Instant;
import java.time.ZonedDateTime;
import java.util.*;
import java.util.stream.Collectors;

@Service
@Validated
@Slf4j
public class GetWeather {
    @Resource
    private WeixinPush weixinPush;
    /*public void download() {

        List<String> areaCodes = new ArrayList<>();
        List<DistrictCodeDO> districtCodeDOList = new ArrayList<>();

        try {
            List<Entity> dictList = Db.use().findAll("system_dict_data");
            for (Entity entity : dictList) {
                String name = entity.getStr("label");
                if (name.contains("area_code")) {
                    String code = entity.getStr("value");
                    String[] s = code.split(",");
                    areaCodes = Arrays.asList(s);
                }
            }
            List<Entity> districtCodes = Db.use().findAll("jy_district_code");
            for (Entity e : districtCodes) {
                DistrictCodeDO districtCodeDO = new DistrictCodeDO();
                districtCodeDO.setCode(Integer.parseInt(e.getStr("code")));
                districtCodeDO.setName(e.getStr("name"));
                districtCodeDO.setLevel(Integer.parseInt(e.getStr("level")));
                districtCodeDO.setType(Integer.parseInt(e.getStr("type")));
                districtCodeDO.setAbname(e.getStr("abname"));
                districtCodeDO.setPid(Integer.parseInt(e.getStr("pid")));
                districtCodeDO.setLat(!Objects.equals(e.getStr("lat"), "") && e.getStr("lat") != null ? new BigDecimal(e.getStr("lat")).setScale(6, RoundingMode.HALF_UP).doubleValue() : 0d);
                districtCodeDO.setLng(!Objects.equals(e.getStr("lng"), "") && e.getStr("lng") != null ? new BigDecimal(e.getStr("lng")).setScale(6, RoundingMode.HALF_UP).doubleValue() : 0d);
                districtCodeDOList.add(districtCodeDO);
            }
            String jdbcUrl = "jdbc:TAOS://192.168.12.241:29500/etadm_local?user=root&password=taosdata";
            Properties connProps = new Properties();
            connProps.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8");
            connProps.setProperty(TSDBDriver.PROPERTY_KEY_LOCALE, "en_US.UTF-8");
            connProps.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8");
            Connection conn = DriverManager.getConnection(jdbcUrl, connProps);
            //省份
            for (String code : areaCodes) {
                List<DistrictCodeDO> shiList = districtCodeDOList.stream().filter(item -> item.getPid().toString().equals(code)).collect(Collectors.toList());
                //市
                for (DistrictCodeDO d : shiList) {
                    List<DistrictCodeDO> quList = districtCodeDOList.stream().filter(item -> item.getPid().toString().equals(d.getCode().toString())).collect(Collectors.toList());
                    log.info("开始下载地区:{} 的天气数据", d.getName());
                    String hefeng24;
                    String caiyun24;
                    String hefengDay;
                    String caiyunDay;
                    //!!!!!!!!!!拼的彩云的辐照度!!!!!!!!!!!!!
                    //和风逐小时数据
                    hefeng24 = "https://devapi.qweather.com/v7/grid-weather/24h?location=" + d.getLng() + "," + d.getLat() + "&key=54d9633382814e148836ce6be2d003fb";
                    //彩云逐小时数据
                    caiyun24 = "https://api.caiyunapp.com/v2.6/SRQIFijX5MGtdmhe/" + d.getLng() + "," + d.getLat() + "/hourly?hourlysteps=24";
                    //和风逐日数据
                    hefengDay = "https://devapi.qweather.com/v7/grid-weather/7d?location=" + d.getLng() + "," + d.getLat() + "&key=54d9633382814e148836ce6be2d003fb";
                    //彩云逐日数据
                    caiyunDay = "https://api.caiyunapp.com/v2.6/SRQIFijX5MGtdmhe/" + d.getLng() + "," + d.getLat() + "/daily?dailysteps=7";
                    analysis24(hefeng24, caiyun24, d.getCode(), d.getName(), conn);
                    analysisDay(hefengDay, caiyunDay, d.getCode(), d.getName(), conn);
                    //区
                    for (DistrictCodeDO q : quList) {
                        log.info("开始下载地区:{} 的天气数据", q.getName());
                        //和风逐小时数据
                        hefeng24 = "https://devapi.qweather.com/v7/grid-weather/24h?location=" + q.getLng() + "," + q.getLat() + "&key=54d9633382814e148836ce6be2d003fb";
                        //彩云逐小时数据
                        caiyun24 = "https://api.caiyunapp.com/v2.6/SRQIFijX5MGtdmhe/" + q.getLng() + "," + q.getLat() + "/hourly?hourlysteps=24";
                        //和风逐日数据
                        hefengDay = "https://devapi.qweather.com/v7/grid-weather/7d?location=" + q.getLng() + "," + q.getLat() + "&key=54d9633382814e148836ce6be2d003fb";
                        //彩云逐日数据
                        caiyunDay = "https://api.caiyunapp.com/v2.6/SRQIFijX5MGtdmhe/" + q.getLng() + "," + q.getLat() + "/daily?dailysteps=7";
                        analysis24(hefeng24, caiyun24, q.getCode(), q.getName(), conn);
                        analysisDay(hefengDay, caiyunDay, q.getCode(), q.getName(), conn);
                    }
                }
            }
            conn.close();
            log.info("天气数据全部下载完毕");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }*/


    /**
     * 根据风速获取对应风力等级
     * 2025-01-09 改为km/h单位
     *
     * @param speed 风速，单位为 km/h
     * @return 风力等级
     */
    public static int speedLevel(String speed) {
        BigDecimal val = new BigDecimal(speed);
        //<0.3	无风 0级
        if (val.compareTo(new BigDecimal("1")) < 0) {
            return 0;
        } else if (val.compareTo(new BigDecimal("6")) < 0) {
            //0.3-1.6	微风徐徐 1级
            return 1;
        } else if (val.compareTo(new BigDecimal("12")) < 0) {
            //1.6-3.4	清风 2级
            return 2;
        } else if (val.compareTo(new BigDecimal("20")) < 0) {
            //3.4-5.5	树叶摇摆 3级
            return 3;
        } else if (val.compareTo(new BigDecimal("29")) < 0) {
            //5.5-8.0	树枝摇动 4级
            return 4;
        } else if (val.compareTo(new BigDecimal("39")) < 0) {
            //8.0-10.8	风吹折小树 5级
            return 5;
        } else if (val.compareTo(new BigDecimal("50")) < 0) {
            //10.8-13.9	树枝折断 6级
            return 6;
        } else if (val.compareTo(new BigDecimal("62")) < 0) {
            //13.9-17.2	风吹倒树木 7级
            return 7;
        } else if (val.compareTo(new BigDecimal("75")) < 0) {
            //17.2-20.8	风吹断大树 8级
            return 8;
        } else if (val.compareTo(new BigDecimal("89")) < 0) {
            //20.8-24.5	强风 9级
            return 9;
        } else if (val.compareTo(new BigDecimal("103")) < 0) {
            //24.5-28.5	狂风 10级
            return 10;
        } else if (val.compareTo(new BigDecimal("117")) < 0) {
            //28.5-32.7	暴风 11级
            return 11;
        } else if (val.compareTo(new BigDecimal("134")) < 0) {
            //32.7-37.0	大暴风 12级
            return 12;
        } else if (val.compareTo(new BigDecimal("150")) < 0) {
            //37.0-41.5	飓风 13级
            return 13;
        } else if (val.compareTo(new BigDecimal("167")) < 0) {
            //41.5-46.2	强飓风 14级
            return 14;
        } else if (val.compareTo(new BigDecimal("184")) < 0) {
            //46.2-50.9	猛烈飓风 15级
            return 15;
        } else if (val.compareTo(new BigDecimal("202")) < 0) {
            //50.9-56.1	毁灭性飓风 16级
            return 16;
        } else {
            //56.1-61.3	超级飓风 17级
            return 17;
        }
    }


    public void download() {
        List<String> areaCodes = new ArrayList<>();
        List<DistrictCodeDO> districtCodeDOList = new ArrayList<>();
        boolean isApiQuotaExhausted = false; // 引入标志变量

        try {
            List<Entity> dictList = Db.use().findAll("system_dict_data");
            for (Entity entity : dictList) {
                String name = entity.getStr("label");
                if (name.contains("area_code")) {
                    String code = entity.getStr("value");
                    String[] s = code.split(",");
                    areaCodes = Arrays.asList(s);
                }
            }
            List<Entity> districtCodes = Db.use().findAll("jy_district_code");
            for (Entity e : districtCodes) {
                DistrictCodeDO districtCodeDO = new DistrictCodeDO();
                districtCodeDO.setCode(Integer.parseInt(e.getStr("code")));
                districtCodeDO.setName(e.getStr("name"));
                districtCodeDO.setLevel(Integer.parseInt(e.getStr("level")));
                districtCodeDO.setType(Integer.parseInt(e.getStr("type")));
                districtCodeDO.setAbname(e.getStr("abname"));
                districtCodeDO.setPid(Integer.parseInt(e.getStr("pid")));
                districtCodeDO.setLat(!Objects.equals(e.getStr("lat"), "") && e.getStr("lat") != null ? new BigDecimal(e.getStr("lat")).setScale(6, RoundingMode.HALF_UP).doubleValue() : 0d);
                districtCodeDO.setLng(!Objects.equals(e.getStr("lng"), "") && e.getStr("lng") != null ? new BigDecimal(e.getStr("lng")).setScale(6, RoundingMode.HALF_UP).doubleValue() : 0d);
                districtCodeDOList.add(districtCodeDO);
            }
            String jdbcUrl = "jdbc:TAOS://192.168.12.241:29500/etadm_local?user=root&password=taosdata";
            Properties connProps = new Properties();
            connProps.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8");
            connProps.setProperty(TSDBDriver.PROPERTY_KEY_LOCALE, "en_US.UTF-8");
            connProps.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8");
            Connection conn = DriverManager.getConnection(jdbcUrl, connProps);
            //省份
            for (String code : areaCodes) {
                if (isApiQuotaExhausted) break; // 检查标志变量
                List<DistrictCodeDO> shiList = districtCodeDOList.stream().filter(item -> item.getPid().toString().equals(code)).collect(Collectors.toList());
                //市
                for (DistrictCodeDO d : shiList) {
                    if (isApiQuotaExhausted) break; // 检查标志变量
                    List<DistrictCodeDO> quList = districtCodeDOList.stream().filter(item -> item.getPid().toString().equals(d.getCode().toString())).collect(Collectors.toList());
                    String caiyun;
                    //彩云综合数据查询
                    caiyun = "https://api.caiyunapp.com/v2.6/SRQIFijX5MGtdmhe/" + d.getLng() + "," + d.getLat() + "/weather?alert=true&dailysteps=7&hourlysteps=72";
                    isApiQuotaExhausted = analysis(caiyun, d.getCode(), d.getName(), conn); // 传递标志变量
                    if (isApiQuotaExhausted) break; // 检查标志变量
                    //区
                    for (DistrictCodeDO q : quList) {
                        if (isApiQuotaExhausted) break; // 检查标志变量
                        caiyun = "https://api.caiyunapp.com/v2.6/SRQIFijX5MGtdmhe/" + q.getLng() + "," + q.getLat() + "/weather?alert=true&dailysteps=7&hourlysteps=72";
                        isApiQuotaExhausted = analysis(caiyun, q.getCode(), q.getName(), conn); // 传递标志变量
                        if (isApiQuotaExhausted) break; // 检查标志变量
                        //线程睡5秒 防止请求过快
                        //花钱了 硬气 不管他
                        //Thread.sleep(5000);
                    }
                }
            }
            conn.close();
            String alarm = "电力交易系统在获取日级天气数据时报错, 彩云天气API 额度已用尽";
            String description = "接口调用异常";
            if (isApiQuotaExhausted) {
                //给企业微信发送消息
             /*   WeixinPush weixinPush = new WeixinPush();
                WeixinMessage weixinMessage = new WeixinMessage();
                weixinMessage.setToUser("WangHongChen|XiuWei|DouZhi");
                //获取今天的ymd
                String ymd = DateUtil.format(DateUtil.date(), "yyyy-MM-dd");
                weixinMessage.setContent(ymd + "日 电力交易系统在获取天气数据时报错, 彩云天气API 额度已用尽");
                weixinMessage.setMsgType("text");
                weixinMessage.setAgentid(1000009); // 确保 agentid 正确
                 weixinPush.sendMessage(weixinMessage);
                */
                weixinPush.sendMessageBot(alarm, description);
            } else {
                alarm = "电力交易系统彩云天气数据全部下载完毕";
                description = "接口调用成功";
                weixinPush.sendMessageBot(alarm, description);
                log.info("彩云天气数据全部下载完毕");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /*public void analysis24(String hefeng24url, String caiyun24url, int areaCode, String name, Connection conn) {
        try {
            Statement ps = conn.createStatement();
            String caiyunBody = HttpUtil.createGet(caiyun24url).execute().charset("utf-8").body();
            JSONObject caiyunjsonObject = JSONUtil.parseObj(caiyunBody);
            JSONObject caiyunResult = JSONUtil.parseObj(caiyunjsonObject.get("result"));
            JSONObject hourly = JSONUtil.parseObj(caiyunResult.get("hourly"));
            JSONArray dswrf = JSONUtil.parseArray(hourly.get("dswrf"));

            String hefengBody = HttpUtil.createGet(hefeng24url).execute().charset("utf-8").body();
            JSONObject jsonObject = JSONUtil.parseObj(hefengBody);
            JSONArray hefengList = JSONUtil.parseArray(jsonObject.get("hourly"));
            List<HeFengHour> list = new ArrayList<>();
            hefengList.forEach(item -> {
                JSONObject jsonObject1 = JSONUtil.parseObj(item);
                try {
                    HeFengHour weather = new HeFengHour();
                    String s = jsonObject1.getStr("fxTime");
                    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mmXXX");
                    ZonedDateTime zonedDateTime = ZonedDateTime.parse(s, formatter);
                    Instant instant = zonedDateTime.toInstant();
                    Timestamp timestamp = Timestamp.from(instant);
                    weather.setTs(timestamp);
                    weather.setTemp(new BigDecimal(jsonObject1.getStr("temp")).floatValue());
                    weather.setAreaCode(String.valueOf(areaCode));
                    weather.setText(jsonObject1.getStr("text"));
                    weather.setWindDir(jsonObject1.getStr("windDir"));
                    weather.setWind360(new BigDecimal(jsonObject1.getStr("wind360")).floatValue());
                    weather.setWindSpeed(new BigDecimal(jsonObject1.getStr("windSpeed")).divide(new BigDecimal("3.6"), 2, RoundingMode.HALF_UP).floatValue());
                    weather.setWindScale(new BigDecimal(jsonObject1.getStr("windScale")).floatValue());
                    weather.setHumidity(new BigDecimal(jsonObject1.getStr("humidity")).floatValue());
                    weather.setCloud(new BigDecimal(jsonObject1.getStr("cloud")).floatValue());
                    weather.setPrecip(new BigDecimal(jsonObject1.getStr("precip")).floatValue());
                    weather.setDew(new BigDecimal(jsonObject1.getStr("dew")).floatValue());
                    weather.setPressure(new BigDecimal(jsonObject1.getStr("pressure")).floatValue());
                    list.add(weather);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });
            if (!dswrf.isEmpty()) {
                if (list.size() != 24) {
                    log.error("地区:{} 24小时天气数据下载失败,和风天气数据不全", name);
                } else {
                    if (dswrf.size() != 24) {
                        log.error("地区:{} 24小时天气数据下载失败,心知天气数据不全", name);
                    } else {
                        for (int i = 0; i < 24; i++) {
                            Map ds = (Map) dswrf.get(i);
                            list.get(i).setDswrf(new BigDecimal(ds.get("value").toString()).floatValue());
                        }
                    }

                }
            }
            for (HeFengHour item : list) {
                String insertSql = " INSERT INTO hefeng_hour_unit_" + areaCode + " USING hefeng_hour_unit TAGS('" + areaCode + "') values('" + item.getTs() + "', " + item.getTemp() + ", '" + item.getText() + "', '" + item.getWindDir() + "', " + item.getWind360() + ", " + item.getWindSpeed() + ", " + item.getWindScale() + ", " + item.getHumidity() + ", " + item.getCloud() + ", " + item.getPrecip() + ", " + item.getDew() + ", " + item.getPressure() + ", " + item.getDswrf() + ")";
                int affectedRows = ps.executeUpdate(insertSql);
            }
            if (ps != null)
                ps.close();
        } catch (Exception e) {
            log.error("地区:{} 24小时天气数据下载失败JSON格式化错误", name);
        }
        log.info("地区:{} 24小时天气数据下载完成", name);
    }

    public void analysisDay(String hefeng24url, String caiyun24url, int areaCode, String name, Connection conn) {
        try {
            Statement ps = conn.createStatement();
            String caiyunBody = HttpUtil.createGet(caiyun24url).execute().charset("utf-8").body();
            JSONObject caiyunjsonObject = JSONUtil.parseObj(caiyunBody);
            JSONObject caiyunResult = JSONUtil.parseObj(caiyunjsonObject.get("result"));
            JSONObject daily = JSONUtil.parseObj(caiyunResult.get("daily"));
            JSONArray dswrf = JSONUtil.parseArray(daily.get("dswrf"));

            String hefengBody = HttpUtil.createGet(hefeng24url).execute().charset("utf-8").body();
            JSONObject jsonObject = JSONUtil.parseObj(hefengBody);
            JSONArray hefengList = JSONUtil.parseArray(jsonObject.get("daily"));
            List<HeFengDay> list = new ArrayList<>();
            hefengList.forEach(item -> {
                JSONObject jsonObject1 = JSONUtil.parseObj(item);
                try {
                    HeFengDay weather = new HeFengDay();
                    String s = jsonObject1.getStr("fxDate");
                    LocalDate localDate = LocalDate.parse(s);
                    // 将 LocalDate 转换为 Instant，然后再转换为 Timestamp
                    Timestamp timestamp = Timestamp.valueOf(localDate.atStartOfDay(ZoneOffset.UTC).toLocalDateTime());
                    weather.setTs(timestamp);
                    weather.setAreaCode(String.valueOf(areaCode));
                    weather.setTempMax(new BigDecimal(jsonObject1.getStr("tempMax")).floatValue());
                    weather.setTempMin(new BigDecimal(jsonObject1.getStr("tempMin")).floatValue());
                    weather.setTextDay(jsonObject1.getStr("textDay"));
                    weather.setTextNight(jsonObject1.getStr("textNight"));
                    weather.setWind360Day(new BigDecimal(jsonObject1.getStr("wind360Day")).floatValue());
                    weather.setWind360Night(new BigDecimal(jsonObject1.getStr("wind360Night")).floatValue());
                    weather.setWindDirDay(jsonObject1.getStr("windDirDay"));
                    weather.setWindDirNight(jsonObject1.getStr("windDirNight"));
                    weather.setWindScaleDay(new BigDecimal(jsonObject1.getStr("windScaleDay")).floatValue());
                    weather.setWindScaleNight(new BigDecimal(jsonObject1.getStr("windScaleNight")).floatValue());
                    weather.setWindSpeedDay(new BigDecimal(jsonObject1.getStr("windSpeedDay")).divide(new BigDecimal("3.6"), 2, RoundingMode.HALF_UP).floatValue());
                    weather.setWindSpeedNight(new BigDecimal(jsonObject1.getStr("windSpeedNight")).divide(new BigDecimal("3.6"), 2, RoundingMode.HALF_UP).floatValue());
                    weather.setHumidity(new BigDecimal(jsonObject1.getStr("humidity")).floatValue());
                    weather.setPrecip(new BigDecimal(jsonObject1.getStr("precip")).floatValue());
                    weather.setPressure(new BigDecimal(jsonObject1.getStr("pressure")).floatValue());
                    list.add(weather);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });
            if (!dswrf.isEmpty()) {
                if (list.size() != 7) {
                    log.error("地区:{} 日天气数据下载失败,和风天气数据不全", name);
                } else {
                    for (HeFengDay heFengDay : list) {
                        Map ds = (Map) dswrf.get(0);
                        heFengDay.setDswrf(new BigDecimal(ds.get("max").toString()).floatValue());
                    }
                }
            }
            for (HeFengDay item : list) {
                String insertSQL = "INSERT INTO hefeng_day_unit_" + item.getAreaCode() + " USING hefeng_day_unit TAGS('" + item.getAreaCode() + "')  values('" + item.getTs() + "', " + item.getTempMax() + ", " + item.getTempMin() + ", '" + item.getTextDay() + "', '" + item.getTextNight() + "', " + item.getWind360Day() + ", '" + item.getWindDirDay() + "', " + item.getWindScaleDay() + ", " + item.getWindSpeedDay() + ", " + item.getWind360Night() + ", '" + item.getWindDirNight() + "', " + item.getWindScaleNight() + ", " + item.getWindSpeedNight() + ", " + item.getHumidity() + ", " + item.getPrecip() + ", " + item.getPressure() + ", " + item.getDswrf() + ")";
                int affectedRows = ps.executeUpdate(insertSQL);
            }
            if (ps != null)
                ps.close();
        } catch (Exception e) {
            log.error("地区:{} 日天气数据下载失败JSON格式化错误", name);
        }
        log.info("地区:{} 日天气数据下载完成", name);
    }*/

    public boolean analysis(String caiyun, int areaCode, String name, Connection conn) {
        log.info("开始下载地区:{} 的天气数据", name);
        try {
            Statement ps = conn.createStatement();
            String caiyunBody = HttpUtil.createGet(caiyun).execute().charset("utf-8").body();
            JSONObject caiyunjsonObject = JSONUtil.parseObj(caiyunBody);
            if (caiyunjsonObject.toString().contains("API quota is exhausted")) {
                return true;
            }
            JSONObject caiyunResult = JSONUtil.parseObj(caiyunjsonObject.get("result"));
            //小时数据 72小时
            /*JSONObject hourly = JSONUtil.parseObj(caiyunResult.get("hourly"));
            //小时->温度
            JSONArray temperature = JSONUtil.parseArray(hourly.get("temperature"));
            //小时->辐照度
            JSONArray dswrf = JSONUtil.parseArray(hourly.get("dswrf"));
            //小时->风速
            JSONArray windSpeed = JSONUtil.parseArray(hourly.get("wind"));
            //小时->天气标识
            JSONArray skyconHour = JSONUtil.parseArray(hourly.get("skycon"));
            //小时->湿度
            JSONArray humidityHour = JSONUtil.parseArray(hourly.get("humidity"));
            //小时->压强
            JSONArray pressureHour = JSONUtil.parseArray(hourly.get("pressure"));*/
            //日数据 7d
            JSONObject daily = JSONUtil.parseObj(caiyunResult.get("daily"));
            //日->辐照度
            JSONArray dswrfDay = JSONUtil.parseArray(daily.get("dswrf"));
            //日->温度
            JSONArray temperatureDay = JSONUtil.parseArray(daily.get("temperature"));
            //日->风速 8点到20点
            JSONArray windSpeed8Day = JSONUtil.parseArray(daily.get("wind_08h_20h"));
            //日->风速 20点到32点
            JSONArray windSpeed20Day = JSONUtil.parseArray(daily.get("wind_20h_32h"));
            //日->天气描述 8点到20点
            JSONArray skycon8 = JSONUtil.parseArray(daily.get("skycon_08h_20h"));
            //日->天气描述 20点到32点
            JSONArray skycon20 = JSONUtil.parseArray(daily.get("skycon_20h_32h"));
            //小时数据写入。  时间 风速 辐照度
            /*List<HeFengHour> heFengHourList = new ArrayList<>();
            if (windSpeed.size() == 72 && dswrf.size() == 72 && temperature.size() == 72) {
                for (int i = 0; i < windSpeed.size(); i++) {
                    String time = ((JSONObject) windSpeed.get(i)).get("datetime").toString();
                    HeFengHour heFengHour = new HeFengHour();
                    heFengHour.setTs(getTimestamp(time));
                    heFengHour.setWindSpeed(new BigDecimal(((JSONObject) windSpeed.get(i)).get("speed").toString()).floatValue());
                    heFengHour.setWindSpeedM(new BigDecimal(((JSONObject) windSpeed.get(i)).get("speed").toString()).floatValue() * 1000 / 3600);
                    heFengHour.setWindScale(speedLevel(((JSONObject) windSpeed.get(i)).get("speed").toString()));
                    heFengHour.setWind360(new BigDecimal(((JSONObject) windSpeed.get(i)).get("direction").toString()).floatValue());
                    heFengHour.setHumidity(new BigDecimal(((JSONObject) humidityHour.get(i)).get("value").toString()).floatValue());
                    heFengHour.setPressure(new BigDecimal(((JSONObject) pressureHour.get(i)).get("value").toString()).floatValue());
                    heFengHour.setText(skycon(((JSONObject) skyconHour.get(i)).get("value").toString()));
                    heFengHour.setDswrf(new BigDecimal(((JSONObject) dswrf.get(i)).get("value").toString()).floatValue());
                    heFengHour.setTemp(new BigDecimal(((JSONObject) temperature.get(i)).get("value").toString()).floatValue());
                    heFengHourList.add(heFengHour);
                }
            } else {
                log.info("{} 的彩云小时数据不足72小时,不入库!", name);
            }*/
            //日数据写入
            List<HeFengDay> heFengDayList = new ArrayList<>();
            if (windSpeed8Day.size() == 7 && windSpeed20Day.size() == 7 && skycon8.size() == 7 && skycon20.size() == 7 && dswrfDay.size() == 7 & temperatureDay.size() == 7) {
                for (int i = 0; i < windSpeed8Day.size(); i++) {
                    String time = ((JSONObject) windSpeed8Day.get(i)).get("date").toString();
                    //白天风速
                    Map windspeedDay = (Map) ((JSONObject) windSpeed8Day.get(i)).get("avg");
                    String windspeedDay1 = windspeedDay.get("speed").toString();
                    //白天风向
                    String wind360Day1 = windspeedDay.get("direction").toString();
                    //夜间风速
                    Map windspeedNight = (Map) ((JSONObject) windSpeed20Day.get(i)).get("avg");
                    String windspeedNight1 = windspeedNight.get("speed").toString();
                    String wind360Night1 = windspeedNight.get("direction").toString();
                    //辐照度
                    String dswrf1 = ((JSONObject) dswrfDay.get(i)).get("avg").toString();
                    //白天天气
                    String skycon = ((JSONObject) skycon8.get(i)).get("value").toString();
                    //夜间天气
                    String skyconN = ((JSONObject) skycon20.get(i)).get("value").toString();
                    //最高温度
                    String temperatureMax = ((JSONObject) temperatureDay.get(i)).get("max").toString();
                    //最低温度
                    String temperatureMin = ((JSONObject) temperatureDay.get(i)).get("min").toString();
                    HeFengDay heFengDay = new HeFengDay();
                    heFengDay.setTs(getTimestamp(time));
                    heFengDay.setWindSpeedDay(new BigDecimal(windspeedDay1).floatValue());
                    heFengDay.setWindSpeedMDay(new BigDecimal(windspeedDay1).floatValue() * 1000 / 3600);
                    heFengDay.setWind360Day(new BigDecimal(wind360Day1).floatValue());
                    heFengDay.setWindScaleDay(speedLevel(windspeedDay1));
                    heFengDay.setWindSpeedNight(new BigDecimal(windspeedNight1).floatValue());
                    heFengDay.setWindSpeedMNight(new BigDecimal(windspeedNight1).floatValue() * 1000 / 3600);
                    heFengDay.setWind360Night(new BigDecimal(wind360Night1).floatValue());
                    heFengDay.setWindScaleNight(speedLevel(windspeedNight1));
                    heFengDay.setDswrf(new BigDecimal(dswrf1).floatValue());
                    heFengDay.setTextDay(skycon(skycon));
                    heFengDay.setTextNight(skycon(skyconN));
                    heFengDay.setTempMax(new BigDecimal(temperatureMax).floatValue());
                    heFengDay.setTempMin(new BigDecimal(temperatureMin).floatValue());
                    heFengDayList.add(heFengDay);
                }
            } else {
                log.info("{} 的彩云日数据不足7天,不入库!", name);
            }
            /*for (HeFengHour item : heFengHourList) {
                String insertSql = " INSERT INTO hefeng_hour_unit_" + areaCode + " USING hefeng_hour_unit TAGS('" + areaCode + "') values('" + item.getTs() + "', " + item.getTemp() + ", '" + item.getText() + "', '" + item.getWindDir() + "', " + item.getWind360() + ", " + item.getWindSpeed()  + ", " + item.getWindScale() + ", " + item.getHumidity() + ", " + item.getCloud() + ", " + item.getPrecip() + ", " + item.getDew() + ", " + item.getPressure() + ", " + item.getDswrf() +", " + item.getWindSpeedM()+ ")";
                int affectedRows = ps.executeUpdate(insertSql);
            }*/
            for (HeFengDay item : heFengDayList) {
                String insertSQL = "INSERT INTO hefeng_day_unit_" + areaCode + " USING hefeng_day_unit TAGS('" + areaCode + "')  values('" + item.getTs() + "', " + item.getTempMax() + ", " + item.getTempMin() + ", '" + item.getTextDay() + "', '" + item.getTextNight() + "', " + item.getWind360Day() + ", '" + item.getWindDirDay() + "', " + item.getWindScaleDay() + ", " + item.getWindSpeedDay() + ", " + item.getWind360Night() + ", '" + item.getWindDirNight() + "', " + item.getWindScaleNight() + ", " + item.getWindSpeedNight() + ", " + item.getHumidity() + ", " + item.getPrecip() + ", " + item.getPressure() + ", " + item.getDswrf() + ", " + item.getWindSpeedMDay() + ", " + item.getWindSpeedMNight() + ")";
                int affectedRows = ps.executeUpdate(insertSQL);
            }
            if (ps != null)
                ps.close();
        } catch (Exception e) {
            log.error("彩云天气,地区:{} 日天气数据下载失败JSON格式化错误", name);
            return true;
        }
        log.info("彩云天气,地区:{} 日天气数据下载完成", name);
        return false;
    }

    private Timestamp getTimestamp(String time) {
        // 解析字符串为 ZonedDateTime
        ZonedDateTime zonedDateTime = ZonedDateTime.parse(time);
        // 将 ZonedDateTime 转换为 Instant
        Instant instant = zonedDateTime.toInstant();
        // 将 Instant 转换为 Timestamp
        return Timestamp.from(instant);
    }

    /**
     * 根据代码获取对应天气描述
     *
     * @param skycon
     * @return
     */
    private String skycon(String skycon) {
        switch (skycon) {
            case "CLEAR_DAY":
            case "CLEAR_NIGHT":
                return "晴";
            case "PARTLY_CLOUDY_DAY":
            case "PARTLY_CLOUDY_NIGHT":
                return "多云";
            case "CLOUDY":
                return "阴";
            case "LIGHT_HAZE":
                return "轻度雾霾";
            case "MODERATE_HAZE":
                return "中度雾霾";
            case "HEAVY_HAZE":
                return "重度雾霾";
            case "LIGHT_RAIN":
                return "小雨";
            case "MODERATE_RAIN":
                return "中雨";
            case "HEAVY_RAIN":
                return "大雨";
            case "STORM_RAIN":
                return "暴雨";
            case "FOG":
                return "雾";
            case "LIGHT_SNOW":
                return "小雪";
            case "MODERATE_SNOW":
                return "中雪";
            case "HEAVY_SNOW":
                return "大雪";
            case "STORM_SNOW":
                return "暴雪";
            case "DUST":
                return "浮尘";
            case "SAND":
                return "沙尘";
            case "WIND":
                return "大风";
        }
        return "晴";
    }


}