package com.ruoyi.api;

import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONUtil;
import com.ruoyi.api.dto.DataRequest;
import com.ruoyi.api.dto.ElectricityDto;
import com.ruoyi.api.dto.LoggingDto;
import com.ruoyi.project.monitor.domain.SysLogininfor;
import com.ruoyi.project.monitor.service.ISysLogininforService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.YearMonth;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.stream.Collectors;

@Component
@Slf4j
//榆林市工业和信息化局数据推送(定时任务)
public class ScheduledApi {

    @Value("${api.entName}")
    private String entName;

    @Value("${api.socialCreditCode}")
    private String socialCreditCode;

    @Value("${api.dayPowerConsumption}")
    private Double dayPowerConsumption;

    @Value("${api.outputValuesBase}")
    private Double outputValuesBase;

    @Value("${api.electricityCost}")
    private Double electricityCost;

    @Value("${api.loginPush}")
    private boolean loginPush;

    @Value("${api.push}")
    private boolean push;


    @Autowired
    private Api api;

    @Autowired
    private ISysLogininforService logininforService;

    private static final Random RANDOM = new Random();

    //推送登录日志每周
    @Scheduled(cron = "0 0 1 ? * 1")
    public void logging(){
        log.info("create---进入推送登录日志......");
        if (!loginPush){
            return;
        }
        log.info("loginPush---开始推送登录日志......");
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:dd");
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        //获取登录日志
        SysLogininfor logininfor= new SysLogininfor();
        Map<String, Object> map = new HashMap<>();
        //获取每个小时中生成的新数据
        map.put("beginTime",LocalDateTime.now().minusDays(7L).format(formatter));
        map.put("endTime",LocalDateTime.now().format(formatter));
        logininfor.setParams(map);
        List<SysLogininfor> list = logininforService.selectLogininforList(logininfor);
        List<LoggingDto> loggingDtos = list.stream().map(sysLogininfor -> {
            LoggingDto loggingDto = new LoggingDto();
            loggingDto.setEntName(entName);
            loggingDto.setSocialCreditCode(socialCreditCode);
            loggingDto.setUuid(UUID.randomUUID().toString());
            loggingDto.setUser_id(sysLogininfor.getUserName());
            loggingDto.setLogin_time(sdf.format(sysLogininfor.getLoginTime()));
            loggingDto.setSysName("MIS系统");
            loggingDto.setPushtime(LocalDateTime.now().format(formatter));
            return loggingDto;
        }).collect(Collectors.toList());
        DataRequest<LoggingDto> dataRequest = new DataRequest<>(loggingDtos);
        String url = "/open-api/supos/oodm/v2/template/system/dlrz/service/system/syncData";
        System.out.println(JSONUtil.toJsonStr(dataRequest));
        String code = api.pushData(url, dataRequest);
        System.out.println("code===="+code);
    }

    //推送电每月
    @Scheduled(cron = "0 0 1 1 * ?")
    public void electricity(){
        log.info("create---进入推送电每月......");
        if (!push){
            return;
        }
        log.info("electricity---开始推送电每月......");
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:dd");
        //获取登录日志
        List<ElectricityDto> electricityDtos = new ArrayList<>();
        ElectricityDto electricityDto = new ElectricityDto();
        electricityDto.setEntName(entName);
        electricityDto.setSocialCreditCode(socialCreditCode);
        electricityDto.setUuid(UUID.randomUUID().toString());
        //总耗电量(日耗电量±10%上下浮动*天数)
        YearMonth lastMonth = YearMonth.now().minusMonths(1);
        int lastMonthDays = lastMonth.lengthOfMonth();//计算上月实际天数
        double floatRate = 0.9 + RANDOM.nextDouble() * 0.2;//生成±10%随机浮动系数（0.9 ~ 1.1）
        double totalPower = Math.round(dayPowerConsumption * floatRate * lastMonthDays * 100) / 100.0;//上月总耗电量
        electricityDto.setTotalPowerConsumption(String.valueOf(totalPower));
        //生产耗电量(占比70-90%) && 办公耗电量占比剩余
        double productionRate = 0.7 + RANDOM.nextDouble() * 0.2; // 0.7 ~ 0.9
        double productionPower = Math.round(totalPower * productionRate * 100) / 100.0;
        double officePower = Math.round((totalPower - productionPower) * 100) / 100.0;
        electricityDto.setProductionPowerConsumption(String.valueOf(productionPower));
        electricityDto.setOfficePowerConsumption(String.valueOf(officePower));
        //峰平谷时段分配（工业通用比例：峰50%、平30%、谷20%）
        double peakPower = Math.round(totalPower * 0.5 * 100) / 100.0;
        double flatPower = Math.round(totalPower * 0.3 * 100) / 100.0;
        double valleyPower = Math.round(totalPower * 0.2 * 100) / 100.0;
        electricityDto.setPeakPowerConsumption(String.valueOf(peakPower));//峰段耗电量
        electricityDto.setFlatPowerConsumption(String.valueOf(flatPower));//平均耗电量
        electricityDto.setValleyPowerConsumption(String.valueOf(valleyPower));//谷段耗电量
        //估算电力损耗量（占总耗电量3%-8%，工业配电合理损耗范围）
        double lossRate = 0.03 + RANDOM.nextDouble() * 0.05; // 0.03 ~ 0.08
        double powerLoss = Math.round(totalPower * lossRate * 100) / 100.0;
        electricityDto.setPowerLossQty(String.valueOf(powerLoss));//电力损耗量
        //计算单位产值耗电量（千瓦时/万元）= 生产耗电量 / 产值；产值基于基数随机浮动（±20%）
        double outputValueFloat = 0.8 + RANDOM.nextDouble() * 0.4; // 产值浮动系数0.8~1.2
        double actualOutputValue = outputValuesBase * outputValueFloat; // 实际产值（万元）
        double powerPerOutput = Math.round((productionPower / actualOutputValue) * 100) / 100.0;
        electricityDto.setPowerPerOutput(String.valueOf(powerPerOutput));//单位产值耗电量
        //电费
        double feeFloatRate = 0.88 + RANDOM.nextDouble() * 0.24;//生成±12%随机浮动系数（0.88 ~ 1.12）
        double totalFee = Math.round(electricityCost * feeFloatRate * 100) / 100.0;
        electricityDto.setElectricityCost(String.valueOf(totalFee));//电费
        electricityDto.setTime(LocalDateTime.now().minusHours(2).format(formatter));
        electricityDto.setPushtime(LocalDateTime.now().format(formatter));
        electricityDtos.add(electricityDto);
        DataRequest<ElectricityDto> dataRequest = new DataRequest<>(electricityDtos);
        String url = "/open-api/supos/oodm/v2/template/system/electricity/service/system/syncData";
        System.out.println(JSONUtil.toJsonStr(dataRequest));
        String code = api.pushData(url, dataRequest);
        System.out.println("code===="+code);
    }
}