feat: 添加设备拉取服务和相关配置

@@ -35,6 +35,60 @@
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+            <version>4.0.3</version>
+        </dependency>
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP-java7</artifactId>
+            <version>2.4.13</version>
+        </dependency>
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <version>42.7.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5.8</version>
+        </dependency>
+        <!--工具类-->
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.6</version>
+        </dependency>
+
+        <!--工具类-->
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-collections4</artifactId>
+            <version>4.2</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.60</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+            <version>2.0.9.RELEASE</version>
+        </dependency>
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>2.9.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.paho</groupId>
+            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
+            <version>1.2.5</version>
+        </dependency>
     </dependencies>
 
     <build>

 package com.iot.scheduler.controller;
 
+import com.iot.scheduler.service.DevicePullService;
+import jakarta.annotation.Resource;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 public class HealthController {
 
+    @Resource
+    private DevicePullService devicePullService;
+
     @GetMapping("/health")
     public String health() {
+        devicePullService.getEnergyInfo();
         return "IoT Scheduler is running...";
     }
 }

+package com.iot.scheduler.service;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.TypeReference;
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.http.Consts;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+
+@Slf4j
+@Service
+public class DevicePullService {
+
+
+    @Value("${device.token.url}")
+    private String deviceTokenUrl;
+    @Value("${device.token.userName}")
+    private String deviceUserName;
+    @Value("${device.token.password}")
+    private String devicePassword;
+    @Value("${device.info.url}")
+    private String deviceInfoUrl;
+    @Value("${device.detail.url}")
+    private String deviceDetailUrl;
+    @Value("${device.energyInfo.url}")
+    private String energyInfoUrl;
+
+    @Resource
+    private RedisTemplate<String, String> redisTemplate;
+
+    final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+    public void pullDeviceAndPushToIot() {
+        String deviceResult = getDeviceInfo();
+        Map<String, Object> deviceInfos = JSON.parseObject(deviceResult, new TypeReference<>() {
+        });
+
+        JSONArray deviceInfoList = (JSONArray) deviceInfos.get("data");
+
+    }
+
+    public String getDeviceInfoDetail(String dtuSn) {
+        String accessToken = getAccessToken();
+        Map<String, String> dtuSnOb = new HashMap<>(1);
+        dtuSnOb.put("dtuSn", dtuSn);
+        Map<String, String> headerMap = new HashMap<>(1);
+        headerMap.put("Authorization", "Bearer " + accessToken);
+        String deviceInfoDetail = sendRequestGet(deviceDetailUrl, dtuSnOb, headerMap);
+        if (StringUtils.isBlank(deviceInfoDetail)) {
+            return null;
+        }
+
+        Map<String, Object> deviceInfoDetailMap = JSON.parseObject(deviceInfoDetail,
+                new TypeReference<>() {
+                });
+        Integer deviceInfoDetailCode = (Integer) deviceInfoDetailMap.get("code");
+        if (deviceInfoDetailCode != 200) {
+            return null;
+        }
+
+        JSONArray deviceInfoDetailList = (JSONArray) deviceInfoDetailMap.get("data");
+        if (CollectionUtils.isEmpty(deviceInfoDetailList)) {
+            return null;
+        }
+
+        JSONObject deviceInfoDetailJson = (JSONObject) deviceInfoDetailList.get(0);
+        //灯详情数据
+        //灯状态(0:灭灯，1：红，2：黄，3：绿，4：蓝)
+        Integer lampState = deviceInfoDetailJson.getInteger("lampState");
+        if (lampState == null) {
+            return null;
+        }
+
+        return deviceInfoDetail;
+    }
+
+    public String getEnergyInfo() {
+        String accessToken = getAccessToken();
+        Map<String, String> headerMap = new HashMap<>(1);
+        headerMap.put("Authorization", "Bearer " + accessToken);
+
+        Map<String, String> paramsMap = new HashMap<>();
+        paramsMap.put("groupName", "一期工厂");
+
+        String energyInfoResult = sendRequestGet(energyInfoUrl, paramsMap, headerMap);
+        if (StringUtils.isBlank(energyInfoResult)) {
+            return null;
+        }
+
+        // 解析设备信息
+        Map<String, Object> energyInfos = JSON.parseObject(energyInfoResult, new TypeReference<>() {
+        });
+        Integer energyInfoCode = (Integer) energyInfos.get("code");
+
+        // 如果code不为200，可能是accessToken失效，重新获取token并重试
+        if (energyInfoCode != 200) {
+            accessToken = getAccessToken();
+            if (StringUtils.isEmpty(accessToken)) {
+                return null;
+            }
+
+            // 更新headerMap中的Authorization
+            headerMap.put("Authorization", "Bearer " + accessToken);
+
+            // 第二次请求设备信息
+            energyInfoResult = sendRequestGet(energyInfoUrl, paramsMap, headerMap);
+            if (StringUtils.isBlank(energyInfoResult)) {
+                return null;
+            }
+
+            // 重新解析设备信息
+            energyInfos = JSON.parseObject(energyInfoResult, new TypeReference<Map<String, Object>>() {
+            });
+            energyInfoCode = (Integer) energyInfos.get("code");
+
+            // 如果第二次请求仍然失败，返回错误信息
+            if (energyInfoCode != 200) {
+                return null;
+            }
+        }
+
+        // 返回成功的设备信息
+        return energyInfoResult;
+    }
+
+    public String getDeviceInfo() {
+        String accessToken = getAccessToken();
+        // 初始化headerMap并设置Authorization
+        Map<String, String> headerMap = new HashMap<>(1);
+        headerMap.put("Authorization", "Bearer " + accessToken);
+
+        Map<String, String> paramsMap = new HashMap<>();
+        paramsMap.put("groupName", "一期工厂");
+
+        // 第一次请求设备信息
+        String deviceResult = sendRequestGet(deviceInfoUrl, paramsMap, headerMap);
+
+        // 检查设备信息是否为空
+        if (StringUtils.isBlank(deviceResult)) {
+            return null;
+        }
+
+        // 解析设备信息
+        Map<String, Object> deviceInfos = JSON.parseObject(deviceResult, new TypeReference<Map<String, Object>>() {
+        });
+        Integer deviceInfoCode = (Integer) deviceInfos.get("code");
+
+        // 如果code不为200，可能是accessToken失效，重新获取token并重试
+        if (deviceInfoCode != 200) {
+            accessToken = getAccessToken();
+            if (StringUtils.isEmpty(accessToken)) {
+                return null;
+            }
+
+            // 更新headerMap中的Authorization
+            headerMap.put("Authorization", "Bearer " + accessToken);
+
+            // 第二次请求设备信息
+            deviceResult = sendRequestGet(deviceInfoUrl, paramsMap, headerMap);
+            if (StringUtils.isBlank(deviceResult)) {
+                return null;
+            }
+
+            // 重新解析设备信息
+            deviceInfos = JSON.parseObject(deviceResult, new TypeReference<Map<String, Object>>() {
+            });
+            deviceInfoCode = (Integer) deviceInfos.get("code");
+
+            // 如果第二次请求仍然失败，返回错误信息
+            if (deviceInfoCode != 200) {
+                return null;
+            }
+        }
+
+        // 返回成功的设备信息
+        return deviceResult;
+    }
+
+    private String getAccessToken() {
+        String accessToken = "";
+        String redisKey = "hnyssl_device_token";
+        if (StringUtils.isNotBlank(redisTemplate.opsForValue().get(redisKey)) && redisTemplate.getExpire(redisKey) > 0) {
+            return redisTemplate.opsForValue().get(redisKey);
+        }
+
+        Map<String, String> param = new HashMap<>(2);
+        param.put("username", deviceUserName);
+        param.put("password", devicePassword);
+        HttpPost httpPost = new HttpPost(deviceTokenUrl);
+        String result = sendPost(httpPost, JSON.toJSONString(param));
+        if (StringUtils.isBlank(result)) {
+            return accessToken;
+        }
+
+        Map<String, Object> res = JSON.parseObject(result, new TypeReference<>() {
+        });
+
+        Integer code = (Integer) res.get("code");
+        if (code == 200) {
+            JSONObject data = (JSONObject) res.get("data");
+            accessToken = (String) data.get("token");
+            redisTemplate.opsForValue().set(redisKey, accessToken, 3600, TimeUnit.SECONDS); // 一小时过期
+        }
+
+        return accessToken;
+    }
+
+    public static String sendRequestGet(String url, Map<String, String> params, Map<String, String> header) {
+        //实例化httpclient
+        CloseableHttpClient httpclient = HttpClients.createDefault();
+        url = builderUrl(url, params);
+        //请求结果
+        String content = "";
+        //实例化get方法
+        HttpGet httpget = new HttpGet(url);
+        if (!CollectionUtils.isEmpty(header)) {
+            for (Map.Entry<String, String> entry : header.entrySet()) {
+                httpget.setHeader(entry.getKey(), entry.getValue());
+            }
+        }
+
+        try (CloseableHttpResponse response = httpclient.execute(httpget)) {
+
+            //执行get方法
+            if (response.getStatusLine().getStatusCode() == 200) {
+                content = EntityUtils.toString(response.getEntity(), "UTF-8");
+            }
+        } catch (IOException e) {
+            log.error("sendRequest---GET Error!", e);
+        }
+        return content;
+    }
+
+    private static String builderUrl(String url, Map<String, String> params) {
+        UriComponentsBuilder uriBuilder = UriComponentsBuilder.fromHttpUrl(url);
+        if (!CollectionUtils.isEmpty(params)) {
+            MultiValueMap<String, String> paramsValue = new LinkedMultiValueMap<>();
+            for (Map.Entry<String, String> entry : params.entrySet()) {
+                paramsValue.add(entry.getKey(), entry.getValue());
+            }
+
+            uriBuilder = uriBuilder.queryParams(paramsValue);
+        }
+
+        return uriBuilder.toUriString();
+    }
+
+    private String sendPost(HttpPost httpPost, String jsonData) {
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        StringEntity entity = new StringEntity(jsonData, ContentType.create("application/json", Consts.UTF_8));
+        httpPost.setEntity(entity);
+        String result = null;
+        try {
+            CloseableHttpResponse execute = httpClient.execute(httpPost);
+            HttpEntity res = execute.getEntity();
+            InputStream is = res.getContent();
+            int len;
+            byte[] buf = new byte[128];
+            ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+            while ((len = is.read(buf)) != -1) {
+                byteArrayOutputStream.write(buf, 0, len);
+            }
+            result = byteArrayOutputStream.toString();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+}

@@ -3,6 +3,15 @@ spring:
     name: iot-scheduler
   main:
     banner-mode: off
+  data:
+    redis:
+      cluster:
+        nodes: # 集群节点列表
+          - 10.9.1.252:16380
+          - 10.9.1.252:16381
+          - 10.9.1.252:16382
+        max-redirects: 3  # 最大重定向次数
+      password: "Qixiao@redis20240410.com"  # 如果有密码
 
 server:
   port: 8080
@@ -24,3 +33,17 @@ scheduler:
   panji:
     pull: "0 0/5 * * * ?"
     push: "0 0/10 * * * ?"
+
+device:
+  token:
+    url: "https://iotgc.cniot.vip/auth/token"
+    userName: "guests"
+    password: "Lingzhi"
+  info:
+    url: "https://iotgc.cniot.vip/triColorLamp/userGroupDtuSns"
+  detail:
+    url: "https://iotgc.cniot.vip/triColorLamp/dtuSnState"
+  energyInfo:
+    url: "https://iotgc.cniot.vip/api/energy/userGroupDtuSns"
+  energyDetail:
+    url: "https://iotgc.cniot.vip/api/energy/dtuSnRateEnergy"