对接榆林市工业和信息化局数据推送

zss

9 小时以前 ee4ba5104799d6ef8f3050870bd5ea328de329ff

对接榆林市工业和信息化局数据推送

 pom.xml

@@ -294,6 +294,13 @@
            <artifactId>easyexcel</artifactId>

            <version>4.0.3</version>

        </dependency>

    
        <!-- Hutool æ ¸å¿ƒå·¥å…·åŒ…（包含http模块，无需单独引入http子包） -->

        <dependency>

            <groupId>cn.hutool</groupId>

            <artifactId>hutool-all</artifactId>

            <version>5.3.7</version>

        </dependency>



    </dependencies>




 src/main/java/com/ruoyi/api/Api.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,60 @@
package com.ruoyi.api;

import cn.hutool.http.Header;
import cn.hutool.http.HttpRequest;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

@Data
@Slf4j
@Component
//榆林市工业和信息化局数据推送
public class Api {

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

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

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


    //获取token
    public String getToken(){
        try {
            Map<String, Object> map = new HashMap<>();
            map.put("appid", appid);
            map.put("secret", secret);
            map.put("grantType", "client_credential");
            String result = HttpRequest.get(ip + "/oauth2/client/v1/accessToken")
                    .contentType("none")
                    .form(map).execute().body();
            JSONObject jsonObject = JSONObject.parseObject(result);
            return jsonObject.getString("accessToken");
        } catch (Exception e) {
            throw new RuntimeException("token获取异常");
        }
    }

    //推送数据
    public String pushData(String urlApi,Object data){
        String url = ip + urlApi;
        Map<String, String> heads = new HashMap<>();
        heads.put("Content-Type", "application/json;charset=UTF-8");
        heads.put("authorization", "Bearer " + getToken());
        String body = HttpRequest.post(url)
                .headerMap(heads, false)
                .body(JSONUtil.toJsonStr(data)).execute().body();
        return JSON.parseObject(body).get("code").toString();
    }
}

 src/main/java/com/ruoyi/api/ScheduledApi.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,136 @@
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;


    @Autowired
    private Api api;

    @Autowired
    private ISysLogininforService logininforService;

    private static final Random RANDOM = new Random();

    //推送登录日志每周
//    @Scheduled(cron = "0 0 1 ? * 1")
    public void logging(){
        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(){
        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);
    }
}

 src/main/java/com/ruoyi/api/dto/DataRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,22 @@
package com.ruoyi.api.dto;

import lombok.Data;
import org.apache.poi.ss.formula.functions.T;

import java.util.List;

/**
 * æŽ¥å£å…¥å‚包装类（严格匹配接口要求的外层结构）
 */
@Data
public class DataRequest<T>{
    // æŽ¥å£è¦æ±‚的核心键：data，值为日志列表
    private List<T> data;

    // ä¾¿æ·æž„造方法：直接传入列表生成包装对象，简化调用
    public DataRequest(List<T> data) {
        this.data = data;
    }


}

 src/main/java/com/ruoyi/api/dto/ElectricityDto.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,38 @@
package com.ruoyi.api.dto;

import lombok.Data;

@Data
//推送电能耗的传参
public class ElectricityDto {

    //企业名称
    private String entName;
    //统一社会信用代码
    private String socialCreditCode;
    //唯一标识
    private String uuid;
    //总耗电量（千瓦时）
    private String totalPowerConsumption;
    //生产设备耗电量（千瓦时）
    private String productionPowerConsumption;
    //办公设备耗电量（千瓦时）
    private String officePowerConsumption;
    //峰段耗电量（千瓦时）
    private String peakPowerConsumption;
    //平段耗电量（千瓦时）
    private String flatPowerConsumption;
    //谷段耗电量（千瓦时）
    private String valleyPowerConsumption;
    //电力损耗量（千瓦时）
    private String powerLossQty;
    //单位产值耗电量（千瓦时/万元）
    private String powerPerOutput;
    //电费支出（元）
    private String electricityCost;
    //数据时间
    private String time;
    //推送时间
    private String pushtime;

}

 src/main/java/com/ruoyi/api/dto/LoggingDto.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,24 @@
package com.ruoyi.api.dto;

import lombok.Data;

@Data
//推送登录日志传参
public class LoggingDto {

    //企业名称
    private String entName;
    //统一社会信用代码
    private String socialCreditCode;
    //唯一标识
    private String uuid;
    //登录人员
    private String user_id;
    //登录时间
    private String login_time;
    //系统名称
    private String sysName;
    //推送时间
    private String pushtime;

}

 src/main/resources/application-bdsm.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: é–边县博达商贸有限公司 #企业名称
  socialCreditCode: 91610824MA7037PN2R #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-bhmy.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: ç¥žæœ¨å¸‚博宏煤业有限公司 #企业名称
  socialCreditCode: 91610821MA70GY9906 #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-cjny.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: ç¥žæœ¨å¸‚创巨能源有限公司 #企业名称
  socialCreditCode: 91610821MA709HFD7X #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-cmny.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: é™•è¥¿çœåˆ›é“­èƒ½æºæœ‰é™å…¬å¸ #企业名称
  socialCreditCode: 91610824MA70BUKD5H #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-hcmy.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: ç¥žæœ¨å¸‚浩成煤业有限公司 #企业名称
  socialCreditCode: 91610821MA704UUN2D #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-hxgy.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: é™•è¥¿çœæ±‡æ˜Ÿé’™ä¸šæœ‰é™å…¬å¸ #企业名称
  socialCreditCode: 91610824MA703CW53U #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-jsyny.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: ç¥žæœ¨å¸‚锦盛源能源科技有限公司 #企业名称
  socialCreditCode: 91610821MA70H8FF2D #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-mkzs.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: ç¥žæœ¨å¸‚模凯再生物资回收有限公司 #企业名称
  socialCreditCode: 91610821MA70A2RE60 #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-tjxm.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: ç¥žæœ¨å¸‚泰江洗煤有限责任公司 #企业名称
  socialCreditCode: 916108216911367669 #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-wdsy.yml

@@ -134,15 +134,16 @@
  # redis é…ç½®
  redis:
    # åœ°å€
#    host: 127.0.0.1
    host: 172.17.0.1
    host: 127.0.0.1
#    host: 172.17.0.1
    # ç«¯å£ï¼Œé»˜è®¤ä¸º6379
    port: 6380
#    port: 6380
    port: 6379
    # æ•°æ®åº“索引
    database: 2
    # å¯†ç 
#    password: root2022!
    password:
    password: 123456

    # è¿žæŽ¥è¶…时时间
    timeout: 10s
@@ -217,3 +218,15 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: é–边县伟德实业有限公司 #企业名称
  socialCreditCode: 91610824MA703F1G4N #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）
  electricityCost: 1200 #月电费


 src/main/resources/application-xyhb.yml

@@ -217,3 +217,13 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads

#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: ç¥žæœ¨å®£å±¹çŽ¯ä¿ç§‘技有限公司 #企业名称
  socialCreditCode: 91610821MA709KB544 #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application-zqhx.yml

@@ -217,3 +217,14 @@
file:
  temp-dir: /javaWork/product-inventory-management/file/temp/uploads
  upload-dir: /javaWork/product-inventory-management/file/prod/uploads


#榆林市工业和信息化局数据推送
api:
  ip: http://111.20.184.155:8888 #推送ip地址
  appid: 48b97e28e0aad7963e96fc50b9e63908 #企业应用id
  secret: 0db7a9fa112427df622c4207b4707432 #企业应用秘钥
  entName: é–边县中强恒兴环保科技有限公司 #企业名称
  socialCreditCode: 91610824093912366E #统一社会信用代码
  dayPowerConsumption: 1200 #日均用电量
  outputValuesBase: 1200 #单位产值基数（万元）

 src/main/resources/application.yml

@@ -1,4 +1,4 @@
# Spring配置
spring:
  profiles:
    active: demo
    active: wdsy