李晓鹤 / iot-scheduler · Commits

Commit 994f0d24a7e3f3c4141976951eed5310eb417e6d

Authored by 杨鸣坤
1 parent bf446453

怀宁非奖补企业同步

Inline Side-by-side
Showing 4 changed files with 835 additions and 0 deletions
  1 +package com.iot.scheduler.service;
  2 +
  3 +import com.alibaba.fastjson.JSON;
  4 +import com.alibaba.fastjson.JSONArray;
  5 +import com.alibaba.fastjson.JSONObject;
  6 +import com.alibaba.fastjson.TypeReference;
  7 +import com.iot.scheduler.model.DeviceToken;
  8 +import com.iot.scheduler.model.QxDeviceInfo;
  9 +import com.iot.scheduler.model.QxDeviceInfoDetail;
  10 +import jakarta.annotation.Resource;
  11 +import lombok.extern.slf4j.Slf4j;
  12 +import org.apache.commons.lang3.StringUtils;
  13 +import org.apache.http.Consts;
  14 +import org.apache.http.HttpEntity;
  15 +import org.apache.http.client.methods.CloseableHttpResponse;
  16 +import org.apache.http.client.methods.HttpGet;
  17 +import org.apache.http.client.methods.HttpPost;
  18 +import org.apache.http.entity.ContentType;
  19 +import org.apache.http.entity.StringEntity;
  20 +import org.apache.http.impl.client.CloseableHttpClient;
  21 +import org.apache.http.impl.client.HttpClients;
  22 +import org.apache.http.message.BasicHeader;
  23 +import org.apache.http.util.EntityUtils;
  24 +import org.springframework.beans.factory.annotation.Value;
  25 +import org.springframework.data.redis.core.RedisTemplate;
  26 +import org.springframework.stereotype.Service;
  27 +import org.springframework.util.CollectionUtils;
  28 +import org.springframework.util.LinkedMultiValueMap;
  29 +import org.springframework.util.MultiValueMap;
  30 +import org.springframework.web.util.UriComponentsBuilder;
  31 +
  32 +import java.io.ByteArrayOutputStream;
  33 +import java.io.IOException;
  34 +import java.io.InputStream;
  35 +import java.text.SimpleDateFormat;
  36 +import java.util.*;
  37 +import java.util.concurrent.TimeUnit;
  38 +
  39 +/**
  40 + * 康健纸塑科技应用数据同步
  41 + */
  42 +@Slf4j
  43 +@Service
  44 +public class KjzsDevicePullService {
  45 +
  46 + @Value("${kjzs.iot.organizeId:}")
  47 + private String iotOrganizeId;
  48 + @Value("${kjzs.iot.profileId}")
  49 + private String iotProfileId;
  50 + @Value("${kjzs.iot.deviceProfileId}")
  51 + private String iotDeviceProfileId;
  52 + @Value("${kjzs.iot.userName:}")
  53 + private String iotUserName;
  54 + @Value("${kjzs.iot.password:}")
  55 + private String iotPassword;
  56 + @Value("${kjzs.iot.tokenUrl}")
  57 + private String iotTokenUrl;
  58 + @Value("${kjzs.iot.infoUrl}")
  59 + private String iotDeviceInfoUrl;
  60 + @Value("${kjzs.iot.detailUrl}")
  61 + private String iotDeviceDetailUrl;
  62 +
  63 + @Value("${device.token.url}")
  64 + private String deviceTokenUrl;
  65 + @Value("${device.token.userName}")
  66 + private String deviceUserName;
  67 + @Value("${device.token.password}")
  68 + private String devicePassword;
  69 + @Value("${device.info.url}")
  70 + private String deviceInfoUrl;
  71 + @Value("${device.detail.url}")
  72 + private String deviceDetailUrl;
  73 +
  74 + @Resource
  75 + private RedisTemplate<String, String> redisTemplate;
  76 +
  77 + final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  78 +
  79 + public void pullDeviceAndPushToIot() {
  80 + String deviceResult = getDeviceInfo();
  81 + Map<String, Object> deviceInfos = JSON.parseObject(deviceResult, new TypeReference<>() {
  82 + });
  83 +
  84 + JSONArray deviceInfoList = (JSONArray) deviceInfos.get("data");
  85 + List<QxDeviceInfo> qxDeviceInfos = new ArrayList<>();
  86 + List<QxDeviceInfoDetail> qxAddDeviceInfoDetails = new ArrayList<>();
  87 + Map<String, QxDeviceInfoDetail> qxDeviceInfoDetailMap = new HashMap<>();
  88 + for (Object o : deviceInfoList) {
  89 + JSONObject deviceInfoJson = (JSONObject) o;
  90 + QxDeviceInfo qxDeviceInfo = new QxDeviceInfo();
  91 + qxDeviceInfo.setDeviceType("DIRECT_CONNECTION");
  92 + qxDeviceInfo.setTransportType("DEFAULT");
  93 + qxDeviceInfo.setOrganizationId(iotOrganizeId);
  94 + qxDeviceInfo.setDeviceProfileId(iotDeviceProfileId);
  95 + qxDeviceInfo.setProfileId(iotProfileId);
  96 +// //项目状态（1：在线，2：离线，3：报警）
  97 +// Integer projectState = deviceInfoJson.getInteger("projectState");
  98 +// if (projectState != null) {
  99 +// qxDeviceInfo.setDescription(String.valueOf(projectState));
  100 +// }
  101 +
  102 + //项目类型
  103 + qxDeviceInfo.setLabel("生产设备");
  104 + //设备名称
  105 + String deviceName = deviceInfoJson.getString("deviceName");
  106 +
  107 + qxDeviceInfo.setName(deviceName);
  108 + qxDeviceInfo.setBrand(deviceName);
  109 + //序列号
  110 + String dtuSn = deviceInfoJson.getString("dtuSn");
  111 + qxDeviceInfo.setSn(dtuSn);
  112 + //高速/中速
  113 + boolean highSpeed = deviceName.contains("高速");
  114 + if (highSpeed) {
  115 + qxDeviceInfo.setDescription("高速机");
  116 + } else {
  117 + qxDeviceInfo.setDescription("中速机");
  118 + }
  119 +
  120 + DeviceToken deviceToken = new DeviceToken();
  121 + deviceToken.setCredentialsType("ACCESS_TOKEN");
  122 + deviceToken.setCredentialsId(dtuSn);
  123 + deviceToken.setCredentialsValue(dtuSn);
  124 + qxDeviceInfo.setDeviceToken(deviceToken);
  125 + qxDeviceInfos.add(qxDeviceInfo);
  126 + //有序列号直接获取灯信息
  127 + if (StringUtils.isNotBlank(dtuSn)) {
  128 + String deviceInfoDetails = getDeviceInfoDetail(dtuSn);
  129 + if (StringUtils.isBlank(deviceInfoDetails)) {
  130 + continue;
  131 + }
  132 +
  133 + Map<String, Object> deviceInfoDetailMap = JSON.parseObject(deviceInfoDetails, new TypeReference<>() {
  134 + });
  135 +
  136 + JSONArray deviceInfoDetailList = (JSONArray) deviceInfoDetailMap.get("data");
  137 + if (CollectionUtils.isEmpty(deviceInfoDetailList)) {
  138 + continue;
  139 + }
  140 +
  141 + JSONObject deviceInfoDetailJson = (JSONObject) deviceInfoDetailList.get(0);
  142 + //灯详情数据
  143 + //序列号
  144 + String dtuSnDetail = deviceInfoDetailJson.getString("dtuSn");
  145 + //开始时间
  146 + String startTime = deviceInfoDetailJson.getString("startTime");
  147 + QxDeviceInfoDetail qxDeviceInfoDetail = new QxDeviceInfoDetail();
  148 + qxDeviceInfoDetail.setAlarm(false);
  149 + //灯状态(0:灭灯，1：红，2：黄，3：绿，4：蓝)
  150 + Integer lampState = deviceInfoDetailJson.getInteger("lampState");
  151 + switch (lampState) {
  152 + case 0:
  153 + qxDeviceInfoDetail.setStatus("OFF");
  154 + break;
  155 + case 1:
  156 + qxDeviceInfoDetail.setStatus("ERROR");
  157 + qxDeviceInfoDetail.setAlarm(true);
  158 + break;
  159 + case 2:
  160 + qxDeviceInfoDetail.setStatus("STAND");
  161 + break;
  162 + case 3:
  163 + qxDeviceInfoDetail.setStatus("RUN");
  164 + //先从缓存里面拿token信息
  165 + break;
  166 + default:
  167 + continue;
  168 + }
  169 +
  170 + if (StringUtils.isNotBlank(startTime)) {
  171 + try {
  172 + qxDeviceInfoDetail.setStartTime(dateFormat.parse(startTime));
  173 + } catch (Exception e) {
  174 + log.error("时间格式出错");
  175 + qxDeviceInfoDetail.setStartTime(new Date());
  176 + }
  177 + } else {
  178 + qxDeviceInfoDetail.setStartTime(new Date());
  179 + }
  180 +
  181 + qxDeviceInfoDetail.setDtuSn(dtuSn);
  182 + qxDeviceInfoDetailMap.put(dtuSn, qxDeviceInfoDetail);
  183 + qxAddDeviceInfoDetails.add(qxDeviceInfoDetail);
  184 + }
  185 + }
  186 +
  187 + //将数据同步到IOT平台
  188 + Map<String, String> qxParam = new HashMap<>(2);
  189 + qxParam.put("username", iotUserName);
  190 + qxParam.put("password", iotPassword);
  191 +
  192 + HttpPost qxHttpPost = new HttpPost(iotTokenUrl);
  193 + String qxResult = sendPost(qxHttpPost, JSON.toJSONString(qxParam));
  194 + if (StringUtils.isBlank(qxResult)) {
  195 + return;
  196 + }
  197 + Map<String, Object> qxRes = JSON.parseObject(qxResult, new TypeReference<Map<String, Object>>() {
  198 + });
  199 +
  200 + String qxAccessToken = (String) qxRes.get("token");
  201 + if (StringUtils.isBlank(qxAccessToken)) {
  202 + return;
  203 + }
  204 +
  205 + BasicHeader qxAuthorization = new BasicHeader("X-Authorization", "Bearer " + qxAccessToken);
  206 + if (!CollectionUtils.isEmpty(qxDeviceInfos)) {
  207 + HttpPost qxDeviceInfoPost = new HttpPost(iotDeviceInfoUrl);
  208 + qxDeviceInfoPost.addHeader(qxAuthorization);
  209 + for (QxDeviceInfo qxDeviceInfo : qxDeviceInfos) {
  210 + // todo
  211 + String syncDeviceInfo = sendPost(qxDeviceInfoPost, JSON.toJSONString(qxDeviceInfo));
  212 + //log.info("同步设备信息 syncDeviceInfo:{}", syncDeviceInfo);
  213 + }
  214 + }
  215 +
  216 + if (!CollectionUtils.isEmpty(qxAddDeviceInfoDetails)) {
  217 + for (QxDeviceInfoDetail qxDeviceInfoDetail : qxAddDeviceInfoDetails) {
  218 + String qxDeviceInfoDetailUrlStr = iotDeviceDetailUrl + qxDeviceInfoDetail.getDtuSn() + "/telemetry";
  219 + HttpPost qxDeviceInfoDetailPost = new HttpPost(qxDeviceInfoDetailUrlStr);
  220 + qxDeviceInfoDetailPost.addHeader(qxAuthorization);
  221 + String syncDeviceInfoDetail = sendPost(qxDeviceInfoDetailPost, JSON.toJSONString(qxDeviceInfoDetail));
  222 + }
  223 + }
  224 + }
  225 +
  226 + public String getDeviceInfoDetail(String dtuSn) {
  227 + String accessToken = getAccessToken();
  228 + Map<String, String> dtuSnOb = new HashMap<>(1);
  229 + dtuSnOb.put("dtuSn", dtuSn);
  230 + Map<String, String> headerMap = new HashMap<>(1);
  231 + headerMap.put("Authorization", "Bearer " + accessToken);
  232 + String deviceInfoDetail = sendRequestGet(deviceDetailUrl, dtuSnOb, headerMap);
  233 + if (StringUtils.isBlank(deviceInfoDetail)) {
  234 + return null;
  235 + }
  236 +
  237 + Map<String, Object> deviceInfoDetailMap = JSON.parseObject(deviceInfoDetail,
  238 + new TypeReference<>() {
  239 + });
  240 + Integer deviceInfoDetailCode = (Integer) deviceInfoDetailMap.get("code");
  241 + if (deviceInfoDetailCode != 200) {
  242 + return null;
  243 + }
  244 +
  245 + JSONArray deviceInfoDetailList = (JSONArray) deviceInfoDetailMap.get("data");
  246 + if (CollectionUtils.isEmpty(deviceInfoDetailList)) {
  247 + return null;
  248 + }
  249 +
  250 + JSONObject deviceInfoDetailJson = (JSONObject) deviceInfoDetailList.get(0);
  251 + //灯详情数据
  252 + //灯状态(0:灭灯，1：红，2：黄，3：绿，4：蓝)
  253 + Integer lampState = deviceInfoDetailJson.getInteger("lampState");
  254 + if (lampState == null) {
  255 + return null;
  256 + }
  257 +
  258 + return deviceInfoDetail;
  259 + }
  260 +
  261 + public String getDeviceInfo() {
  262 + String accessToken = getAccessToken();
  263 + // 初始化headerMap并设置Authorization
  264 + Map<String, String> headerMap = new HashMap<>(1);
  265 + headerMap.put("Authorization", "Bearer " + accessToken);
  266 +
  267 + Map<String, String> paramsMap = new HashMap<>();
  268 + paramsMap.put("groupName", "康健纸塑科技");
  269 +
  270 + // 第一次请求设备信息
  271 + String deviceResult = sendRequestGet(deviceInfoUrl, paramsMap, headerMap);
  272 +
  273 + // 检查设备信息是否为空
  274 + if (StringUtils.isBlank(deviceResult)) {
  275 + return null;
  276 + }
  277 +
  278 + // 解析设备信息
  279 + Map<String, Object> deviceInfos = JSON.parseObject(deviceResult, new TypeReference<>() {
  280 + });
  281 + Integer deviceInfoCode = (Integer) deviceInfos.get("code");
  282 +
  283 + // 如果code不为200，可能是accessToken失效，重新获取token并重试
  284 + if (deviceInfoCode != 200) {
  285 + accessToken = getAccessToken();
  286 + if (StringUtils.isEmpty(accessToken)) {
  287 + return null;
  288 + }
  289 +
  290 + // 更新headerMap中的Authorization
  291 + headerMap.put("Authorization", "Bearer " + accessToken);
  292 +
  293 + // 第二次请求设备信息
  294 + deviceResult = sendRequestGet(deviceInfoUrl, paramsMap, headerMap);
  295 + if (StringUtils.isBlank(deviceResult)) {
  296 + return null;
  297 + }
  298 +
  299 + // 重新解析设备信息
  300 + deviceInfos = JSON.parseObject(deviceResult, new TypeReference<>() {
  301 + });
  302 + deviceInfoCode = (Integer) deviceInfos.get("code");
  303 +
  304 + // 如果第二次请求仍然失败，返回错误信息
  305 + if (deviceInfoCode != 200) {
  306 + return null;
  307 + }
  308 + }
  309 +
  310 + // 返回成功的设备信息
  311 + return deviceResult;
  312 + }
  313 +
  314 + private String getAccessToken() {
  315 + String accessToken = "";
  316 + String redisKey = "device_token";
  317 + if (StringUtils.isNotBlank(redisTemplate.opsForValue().get(redisKey)) && redisTemplate.getExpire(redisKey) > 0) {
  318 + return redisTemplate.opsForValue().get(redisKey);
  319 + }
  320 +
  321 + Map<String, String> param = new HashMap<>(2);
  322 + param.put("username", deviceUserName);
  323 + param.put("password", devicePassword);
  324 + HttpPost httpPost = new HttpPost(deviceTokenUrl);
  325 + String result = sendPost(httpPost, JSON.toJSONString(param));
  326 + if (StringUtils.isBlank(result)) {
  327 + return accessToken;
  328 + }
  329 +
  330 + Map<String, Object> res = JSON.parseObject(result, new TypeReference<>() {
  331 + });
  332 +
  333 + Integer code = (Integer) res.get("code");
  334 + if (code == 200) {
  335 + JSONObject data = (JSONObject) res.get("data");
  336 + accessToken = (String) data.get("token");
  337 + redisTemplate.opsForValue().set(redisKey, accessToken, 3600, TimeUnit.SECONDS); // 一小时过期
  338 + }
  339 +
  340 + return accessToken;
  341 + }
  342 +
  343 + public static String sendRequestGet(String url, Map<String, String> params, Map<String, String> header) {
  344 + //实例化httpclient
  345 + CloseableHttpClient httpclient = HttpClients.createDefault();
  346 + url = builderUrl(url, params);
  347 + //请求结果
  348 + String content = "";
  349 + //实例化get方法
  350 + HttpGet httpget = new HttpGet(url);
  351 + if (!CollectionUtils.isEmpty(header)) {
  352 + for (Map.Entry<String, String> entry : header.entrySet()) {
  353 + httpget.setHeader(entry.getKey(), entry.getValue());
  354 + }
  355 + }
  356 +
  357 + try (CloseableHttpResponse response = httpclient.execute(httpget)) {
  358 +
  359 + //执行get方法
  360 + if (response.getStatusLine().getStatusCode() == 200) {
  361 + content = EntityUtils.toString(response.getEntity(), "UTF-8");
  362 + }
  363 + } catch (IOException e) {
  364 + log.error("sendRequest---GET Error!", e);
  365 + }
  366 + return content;
  367 + }
  368 +
  369 + private static String builderUrl(String url, Map<String, String> params) {
  370 + UriComponentsBuilder uriBuilder = UriComponentsBuilder.fromHttpUrl(url);
  371 + if (!CollectionUtils.isEmpty(params)) {
  372 + MultiValueMap<String, String> paramsValue = new LinkedMultiValueMap<>();
  373 + for (Map.Entry<String, String> entry : params.entrySet()) {
  374 + paramsValue.add(entry.getKey(), entry.getValue());
  375 + }
  376 +
  377 + uriBuilder = uriBuilder.queryParams(paramsValue);
  378 + }
  379 +
  380 + return uriBuilder.toUriString();
  381 + }
  382 +
  383 + private String sendPost(HttpPost httpPost, String jsonData) {
  384 + CloseableHttpClient httpClient = HttpClients.createDefault();
  385 + StringEntity entity = new StringEntity(jsonData, ContentType.create("application/json", Consts.UTF_8));
  386 + httpPost.setEntity(entity);
  387 + String result = null;
  388 + try {
  389 + CloseableHttpResponse execute = httpClient.execute(httpPost);
  390 + HttpEntity res = execute.getEntity();
  391 + InputStream is = res.getContent();
  392 + int len;
  393 + byte[] buf = new byte[128];
  394 + ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
  395 + while ((len = is.read(buf)) != -1) {
  396 + byteArrayOutputStream.write(buf, 0, len);
  397 + }
  398 + result = byteArrayOutputStream.toString();
  399 + } catch (IOException e) {
  400 + e.printStackTrace();
  401 + }
  402 + return result;
  403 + }
  404 +}
  1 +package com.iot.scheduler.service;
  2 +
  3 +import com.alibaba.fastjson.JSON;
  4 +import com.alibaba.fastjson.JSONArray;
  5 +import com.alibaba.fastjson.JSONObject;
  6 +import com.alibaba.fastjson.TypeReference;
  7 +import com.iot.scheduler.model.DeviceToken;
  8 +import com.iot.scheduler.model.QxDeviceInfo;
  9 +import com.iot.scheduler.model.QxDeviceInfoDetail;
  10 +import jakarta.annotation.Resource;
  11 +import lombok.extern.slf4j.Slf4j;
  12 +import org.apache.commons.lang3.StringUtils;
  13 +import org.apache.http.Consts;
  14 +import org.apache.http.HttpEntity;
  15 +import org.apache.http.client.methods.CloseableHttpResponse;
  16 +import org.apache.http.client.methods.HttpGet;
  17 +import org.apache.http.client.methods.HttpPost;
  18 +import org.apache.http.entity.ContentType;
  19 +import org.apache.http.entity.StringEntity;
  20 +import org.apache.http.impl.client.CloseableHttpClient;
  21 +import org.apache.http.impl.client.HttpClients;
  22 +import org.apache.http.message.BasicHeader;
  23 +import org.apache.http.util.EntityUtils;
  24 +import org.springframework.beans.factory.annotation.Value;
  25 +import org.springframework.data.redis.core.RedisTemplate;
  26 +import org.springframework.stereotype.Service;
  27 +import org.springframework.util.CollectionUtils;
  28 +import org.springframework.util.LinkedMultiValueMap;
  29 +import org.springframework.util.MultiValueMap;
  30 +import org.springframework.web.util.UriComponentsBuilder;
  31 +
  32 +import java.io.ByteArrayOutputStream;
  33 +import java.io.IOException;
  34 +import java.io.InputStream;
  35 +import java.text.SimpleDateFormat;
  36 +import java.util.*;
  37 +import java.util.concurrent.TimeUnit;
  38 +
  39 +/**
  40 + * 亿佳环保科技应用数据同步
  41 + */
  42 +@Slf4j
  43 +@Service
  44 +public class YjhbDevicePullService {
  45 +
  46 + @Value("${yjhb.iot.organizeId:}")
  47 + private String iotOrganizeId;
  48 + @Value("${yjhb.iot.profileId}")
  49 + private String iotProfileId;
  50 + @Value("${yjhb.iot.deviceProfileId}")
  51 + private String iotDeviceProfileId;
  52 + @Value("${yjhb.iot.userName:}")
  53 + private String iotUserName;
  54 + @Value("${yjhb.iot.password:}")
  55 + private String iotPassword;
  56 + @Value("${yjhb.iot.tokenUrl}")
  57 + private String iotTokenUrl;
  58 + @Value("${yjhb.iot.infoUrl}")
  59 + private String iotDeviceInfoUrl;
  60 + @Value("${yjhb.iot.detailUrl}")
  61 + private String iotDeviceDetailUrl;
  62 +
  63 + @Value("${device.token.url}")
  64 + private String deviceTokenUrl;
  65 + @Value("${device.token.userName}")
  66 + private String deviceUserName;
  67 + @Value("${device.token.password}")
  68 + private String devicePassword;
  69 + @Value("${device.info.url}")
  70 + private String deviceInfoUrl;
  71 + @Value("${device.detail.url}")
  72 + private String deviceDetailUrl;
  73 +
  74 + @Resource
  75 + private RedisTemplate<String, String> redisTemplate;
  76 +
  77 + final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  78 +
  79 + public void pullDeviceAndPushToIot() {
  80 + String deviceResult = getDeviceInfo();
  81 + Map<String, Object> deviceInfos = JSON.parseObject(deviceResult, new TypeReference<>() {
  82 + });
  83 +
  84 + JSONArray deviceInfoList = (JSONArray) deviceInfos.get("data");
  85 + List<QxDeviceInfo> qxDeviceInfos = new ArrayList<>();
  86 + List<QxDeviceInfoDetail> qxAddDeviceInfoDetails = new ArrayList<>();
  87 + Map<String, QxDeviceInfoDetail> qxDeviceInfoDetailMap = new HashMap<>();
  88 + for (Object o : deviceInfoList) {
  89 + JSONObject deviceInfoJson = (JSONObject) o;
  90 + QxDeviceInfo qxDeviceInfo = new QxDeviceInfo();
  91 + qxDeviceInfo.setDeviceType("DIRECT_CONNECTION");
  92 + qxDeviceInfo.setTransportType("DEFAULT");
  93 + qxDeviceInfo.setOrganizationId(iotOrganizeId);
  94 + qxDeviceInfo.setDeviceProfileId(iotDeviceProfileId);
  95 + qxDeviceInfo.setProfileId(iotProfileId);
  96 +// //项目状态（1：在线，2：离线，3：报警）
  97 +// Integer projectState = deviceInfoJson.getInteger("projectState");
  98 +// if (projectState != null) {
  99 +// qxDeviceInfo.setDescription(String.valueOf(projectState));
  100 +// }
  101 +
  102 + //项目类型
  103 + qxDeviceInfo.setLabel("生产设备");
  104 + //设备名称
  105 + String deviceName = deviceInfoJson.getString("deviceName");
  106 +
  107 + qxDeviceInfo.setName(deviceName);
  108 + qxDeviceInfo.setBrand(deviceName);
  109 + //序列号
  110 + String dtuSn = deviceInfoJson.getString("dtuSn");
  111 + qxDeviceInfo.setSn(dtuSn);
  112 + //高速/中速
  113 + boolean highSpeed = deviceName.contains("高速");
  114 + if (highSpeed) {
  115 + qxDeviceInfo.setDescription("高速机");
  116 + } else {
  117 + qxDeviceInfo.setDescription("中速机");
  118 + }
  119 +
  120 + DeviceToken deviceToken = new DeviceToken();
  121 + deviceToken.setCredentialsType("ACCESS_TOKEN");
  122 + deviceToken.setCredentialsId(dtuSn);
  123 + deviceToken.setCredentialsValue(dtuSn);
  124 + qxDeviceInfo.setDeviceToken(deviceToken);
  125 + qxDeviceInfos.add(qxDeviceInfo);
  126 + //有序列号直接获取灯信息
  127 + if (StringUtils.isNotBlank(dtuSn)) {
  128 + String deviceInfoDetails = getDeviceInfoDetail(dtuSn);
  129 + if (StringUtils.isBlank(deviceInfoDetails)) {
  130 + continue;
  131 + }
  132 +
  133 + Map<String, Object> deviceInfoDetailMap = JSON.parseObject(deviceInfoDetails, new TypeReference<>() {
  134 + });
  135 +
  136 + JSONArray deviceInfoDetailList = (JSONArray) deviceInfoDetailMap.get("data");
  137 + if (CollectionUtils.isEmpty(deviceInfoDetailList)) {
  138 + continue;
  139 + }
  140 +
  141 + JSONObject deviceInfoDetailJson = (JSONObject) deviceInfoDetailList.get(0);
  142 + //灯详情数据
  143 + //序列号
  144 + String dtuSnDetail = deviceInfoDetailJson.getString("dtuSn");
  145 + //开始时间
  146 + String startTime = deviceInfoDetailJson.getString("startTime");
  147 + QxDeviceInfoDetail qxDeviceInfoDetail = new QxDeviceInfoDetail();
  148 + qxDeviceInfoDetail.setAlarm(false);
  149 + //灯状态(0:灭灯，1：红，2：黄，3：绿，4：蓝)
  150 + Integer lampState = deviceInfoDetailJson.getInteger("lampState");
  151 + switch (lampState) {
  152 + case 0:
  153 + qxDeviceInfoDetail.setStatus("OFF");
  154 + break;
  155 + case 1:
  156 + qxDeviceInfoDetail.setStatus("ERROR");
  157 + qxDeviceInfoDetail.setAlarm(true);
  158 + break;
  159 + case 2:
  160 + qxDeviceInfoDetail.setStatus("STAND");
  161 + break;
  162 + case 3:
  163 + qxDeviceInfoDetail.setStatus("RUN");
  164 + break;
  165 + default:
  166 + continue;
  167 + }
  168 +
  169 + if (StringUtils.isNotBlank(startTime)) {
  170 + try {
  171 + qxDeviceInfoDetail.setStartTime(dateFormat.parse(startTime));
  172 + } catch (Exception e) {
  173 + log.error("时间格式出错");
  174 + qxDeviceInfoDetail.setStartTime(new Date());
  175 + }
  176 + } else {
  177 + qxDeviceInfoDetail.setStartTime(new Date());
  178 + }
  179 +
  180 + qxDeviceInfoDetail.setDtuSn(dtuSn);
  181 + qxDeviceInfoDetailMap.put(dtuSn, qxDeviceInfoDetail);
  182 + qxAddDeviceInfoDetails.add(qxDeviceInfoDetail);
  183 + }
  184 + }
  185 +
  186 + //将数据同步到IOT平台
  187 + Map<String, String> qxParam = new HashMap<>(2);
  188 + qxParam.put("username", iotUserName);
  189 + qxParam.put("password", iotPassword);
  190 +
  191 + HttpPost qxHttpPost = new HttpPost(iotTokenUrl);
  192 + String qxResult = sendPost(qxHttpPost, JSON.toJSONString(qxParam));
  193 + if (StringUtils.isBlank(qxResult)) {
  194 + return;
  195 + }
  196 + Map<String, Object> qxRes = JSON.parseObject(qxResult, new TypeReference<Map<String, Object>>() {
  197 + });
  198 +
  199 + String qxAccessToken = (String) qxRes.get("token");
  200 + if (StringUtils.isBlank(qxAccessToken)) {
  201 + return;
  202 + }
  203 +
  204 + BasicHeader qxAuthorization = new BasicHeader("X-Authorization", "Bearer " + qxAccessToken);
  205 + if (!CollectionUtils.isEmpty(qxDeviceInfos)) {
  206 + HttpPost qxDeviceInfoPost = new HttpPost(iotDeviceInfoUrl);
  207 + qxDeviceInfoPost.addHeader(qxAuthorization);
  208 + for (QxDeviceInfo qxDeviceInfo : qxDeviceInfos) {
  209 + // todo
  210 + String syncDeviceInfo = sendPost(qxDeviceInfoPost, JSON.toJSONString(qxDeviceInfo));
  211 + //log.info("同步设备信息 syncDeviceInfo:{}", syncDeviceInfo);
  212 + }
  213 + }
  214 +
  215 + if (!CollectionUtils.isEmpty(qxAddDeviceInfoDetails)) {
  216 + for (QxDeviceInfoDetail qxDeviceInfoDetail : qxAddDeviceInfoDetails) {
  217 + String qxDeviceInfoDetailUrlStr = iotDeviceDetailUrl + qxDeviceInfoDetail.getDtuSn() + "/telemetry";
  218 + HttpPost qxDeviceInfoDetailPost = new HttpPost(qxDeviceInfoDetailUrlStr);
  219 + qxDeviceInfoDetailPost.addHeader(qxAuthorization);
  220 + String syncDeviceInfoDetail = sendPost(qxDeviceInfoDetailPost, JSON.toJSONString(qxDeviceInfoDetail));
  221 + }
  222 + }
  223 + }
  224 +
  225 + public String getDeviceInfoDetail(String dtuSn) {
  226 + String accessToken = getAccessToken();
  227 + Map<String, String> dtuSnOb = new HashMap<>(1);
  228 + dtuSnOb.put("dtuSn", dtuSn);
  229 + Map<String, String> headerMap = new HashMap<>(1);
  230 + headerMap.put("Authorization", "Bearer " + accessToken);
  231 + String deviceInfoDetail = sendRequestGet(deviceDetailUrl, dtuSnOb, headerMap);
  232 + if (StringUtils.isBlank(deviceInfoDetail)) {
  233 + return null;
  234 + }
  235 +
  236 + Map<String, Object> deviceInfoDetailMap = JSON.parseObject(deviceInfoDetail,
  237 + new TypeReference<>() {
  238 + });
  239 + Integer deviceInfoDetailCode = (Integer) deviceInfoDetailMap.get("code");
  240 + if (deviceInfoDetailCode != 200) {
  241 + return null;
  242 + }
  243 +
  244 + JSONArray deviceInfoDetailList = (JSONArray) deviceInfoDetailMap.get("data");
  245 + if (CollectionUtils.isEmpty(deviceInfoDetailList)) {
  246 + return null;
  247 + }
  248 +
  249 + JSONObject deviceInfoDetailJson = (JSONObject) deviceInfoDetailList.get(0);
  250 + //灯详情数据
  251 + //灯状态(0:灭灯，1：红，2：黄，3：绿，4：蓝)
  252 + Integer lampState = deviceInfoDetailJson.getInteger("lampState");
  253 + if (lampState == null) {
  254 + return null;
  255 + }
  256 +
  257 + return deviceInfoDetail;
  258 + }
  259 +
  260 + public String getDeviceInfo() {
  261 + String accessToken = getAccessToken();
  262 + // 初始化headerMap并设置Authorization
  263 + Map<String, String> headerMap = new HashMap<>(1);
  264 + headerMap.put("Authorization", "Bearer " + accessToken);
  265 +
  266 + Map<String, String> paramsMap = new HashMap<>();
  267 + paramsMap.put("groupName", "亿佳环保科技");
  268 +
  269 + // 第一次请求设备信息
  270 + String deviceResult = sendRequestGet(deviceInfoUrl, paramsMap, headerMap);
  271 +
  272 + // 检查设备信息是否为空
  273 + if (StringUtils.isBlank(deviceResult)) {
  274 + return null;
  275 + }
  276 +
  277 + // 解析设备信息
  278 + Map<String, Object> deviceInfos = JSON.parseObject(deviceResult, new TypeReference<>() {
  279 + });
  280 + Integer deviceInfoCode = (Integer) deviceInfos.get("code");
  281 +
  282 + // 如果code不为200，可能是accessToken失效，重新获取token并重试
  283 + if (deviceInfoCode != 200) {
  284 + accessToken = getAccessToken();
  285 + if (StringUtils.isEmpty(accessToken)) {
  286 + return null;
  287 + }
  288 +
  289 + // 更新headerMap中的Authorization
  290 + headerMap.put("Authorization", "Bearer " + accessToken);
  291 +
  292 + // 第二次请求设备信息
  293 + deviceResult = sendRequestGet(deviceInfoUrl, paramsMap, headerMap);
  294 + if (StringUtils.isBlank(deviceResult)) {
  295 + return null;
  296 + }
  297 +
  298 + // 重新解析设备信息
  299 + deviceInfos = JSON.parseObject(deviceResult, new TypeReference<>() {
  300 + });
  301 + deviceInfoCode = (Integer) deviceInfos.get("code");
  302 +
  303 + // 如果第二次请求仍然失败，返回错误信息
  304 + if (deviceInfoCode != 200) {
  305 + return null;
  306 + }
  307 + }
  308 +
  309 + // 返回成功的设备信息
  310 + return deviceResult;
  311 + }
  312 +
  313 + private String getAccessToken() {
  314 + String accessToken = "";
  315 + String redisKey = "device_token";
  316 + if (StringUtils.isNotBlank(redisTemplate.opsForValue().get(redisKey)) && redisTemplate.getExpire(redisKey) > 0) {
  317 + return redisTemplate.opsForValue().get(redisKey);
  318 + }
  319 +
  320 + Map<String, String> param = new HashMap<>(2);
  321 + param.put("username", deviceUserName);
  322 + param.put("password", devicePassword);
  323 + HttpPost httpPost = new HttpPost(deviceTokenUrl);
  324 + String result = sendPost(httpPost, JSON.toJSONString(param));
  325 + if (StringUtils.isBlank(result)) {
  326 + return accessToken;
  327 + }
  328 +
  329 + Map<String, Object> res = JSON.parseObject(result, new TypeReference<>() {
  330 + });
  331 +
  332 + Integer code = (Integer) res.get("code");
  333 + if (code == 200) {
  334 + JSONObject data = (JSONObject) res.get("data");
  335 + accessToken = (String) data.get("token");
  336 + redisTemplate.opsForValue().set(redisKey, accessToken, 3600, TimeUnit.SECONDS); // 一小时过期
  337 + }
  338 +
  339 + return accessToken;
  340 + }
  341 +
  342 + public static String sendRequestGet(String url, Map<String, String> params, Map<String, String> header) {
  343 + //实例化httpclient
  344 + CloseableHttpClient httpclient = HttpClients.createDefault();
  345 + url = builderUrl(url, params);
  346 + //请求结果
  347 + String content = "";
  348 + //实例化get方法
  349 + HttpGet httpget = new HttpGet(url);
  350 + if (!CollectionUtils.isEmpty(header)) {
  351 + for (Map.Entry<String, String> entry : header.entrySet()) {
  352 + httpget.setHeader(entry.getKey(), entry.getValue());
  353 + }
  354 + }
  355 +
  356 + try (CloseableHttpResponse response = httpclient.execute(httpget)) {
  357 +
  358 + //执行get方法
  359 + if (response.getStatusLine().getStatusCode() == 200) {
  360 + content = EntityUtils.toString(response.getEntity(), "UTF-8");
  361 + }
  362 + } catch (IOException e) {
  363 + log.error("sendRequest---GET Error!", e);
  364 + }
  365 + return content;
  366 + }
  367 +
  368 + private static String builderUrl(String url, Map<String, String> params) {
  369 + UriComponentsBuilder uriBuilder = UriComponentsBuilder.fromHttpUrl(url);
  370 + if (!CollectionUtils.isEmpty(params)) {
  371 + MultiValueMap<String, String> paramsValue = new LinkedMultiValueMap<>();
  372 + for (Map.Entry<String, String> entry : params.entrySet()) {
  373 + paramsValue.add(entry.getKey(), entry.getValue());
  374 + }
  375 +
  376 + uriBuilder = uriBuilder.queryParams(paramsValue);
  377 + }
  378 +
  379 + return uriBuilder.toUriString();
  380 + }
  381 +
  382 + private String sendPost(HttpPost httpPost, String jsonData) {
  383 + CloseableHttpClient httpClient = HttpClients.createDefault();
  384 + StringEntity entity = new StringEntity(jsonData, ContentType.create("application/json", Consts.UTF_8));
  385 + httpPost.setEntity(entity);
  386 + String result = null;
  387 + try {
  388 + CloseableHttpResponse execute = httpClient.execute(httpPost);
  389 + HttpEntity res = execute.getEntity();
  390 + InputStream is = res.getContent();
  391 + int len;
  392 + byte[] buf = new byte[128];
  393 + ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
  394 + while ((len = is.read(buf)) != -1) {
  395 + byteArrayOutputStream.write(buf, 0, len);
  396 + }
  397 + result = byteArrayOutputStream.toString();
  398 + } catch (IOException e) {
  399 + e.printStackTrace();
  400 + }
  401 + return result;
  402 + }
  403 +}
@@ -21,6 +21,10 @@ public class ChizhouZoneScheduler extends AbstractZoneScheduler { @@ -21,6 +21,10 @@ public class ChizhouZoneScheduler extends AbstractZoneScheduler {
21 private GhDevicePullService ghDevicePullService; 21 private GhDevicePullService ghDevicePullService;
22 @Resource 22 @Resource
23 private ShzzDevicePullService shzzDevicePullService; 23 private ShzzDevicePullService shzzDevicePullService;
  24 + @Resource
  25 + private KjzsDevicePullService kjzsDevicePullService;
  26 + @Resource
  27 + private YjhbDevicePullService yjhbDevicePullService;
24 28
25 @Override 29 @Override
26 protected String getZoneName() { 30 protected String getZoneName() {
@@ -38,6 +42,8 @@ public class ChizhouZoneScheduler extends AbstractZoneScheduler { @@ -38,6 +42,8 @@ public class ChizhouZoneScheduler extends AbstractZoneScheduler {
38 slDevicePullService.pullDeviceAndPushToIot(); 42 slDevicePullService.pullDeviceAndPushToIot();
39 ghDevicePullService.pullDeviceAndPushToIot(); 43 ghDevicePullService.pullDeviceAndPushToIot();
40 shzzDevicePullService.pullDeviceAndPushToIot(); 44 shzzDevicePullService.pullDeviceAndPushToIot();
  45 + yjhbDevicePullService.pullDeviceAndPushToIot();
  46 + kjzsDevicePullService.pullDeviceAndPushToIot();
41 Thread.sleep(1000); 47 Thread.sleep(1000);
42 } catch (Exception e) { 48 } catch (Exception e) {
43 logError(taskName, e); 49 logError(taskName, e);
@@ -260,6 +260,28 @@ sy: @@ -260,6 +260,28 @@ sy:
260 infoUrl: "https://iot.hzzlyun.com/api/yt/device" 260 infoUrl: "https://iot.hzzlyun.com/api/yt/device"
261 detailUrl: "https://iot.hzzlyun.com/api/v1/" 261 detailUrl: "https://iot.hzzlyun.com/api/v1/"
262 262
  263 +yjhb:
  264 + iot:
  265 + organizeId: "00690478-b836-4986-88fd-1dd8cb87ed1d"
  266 + profileId: "f2292f60-f738-11f0-9cb8-e3376d1e7978"
  267 + deviceProfileId: "f2292f60-f738-11f0-9cb8-e3376d1e7978"
  268 + userName: "yjhb"
  269 + password: "Yjhb@123.com"
  270 + tokenUrl: "https://iot.hzzlyun.com/api/auth/login"
  271 + infoUrl: "https://iot.hzzlyun.com/api/yt/device"
  272 + detailUrl: "https://iot.hzzlyun.com/api/v1/"
  273 +
  274 +kjzs:
  275 + iot:
  276 + organizeId: "7985002f-53c5-41bf-98d6-58ef422dadfd"
  277 + profileId: "f2292f60-f738-11f0-9cb8-e3376d1e7978"
  278 + deviceProfileId: "f2292f60-f738-11f0-9cb8-e3376d1e7978"
  279 + userName: "kjzs"
  280 + password: "Kjzs@123.com"
  281 + tokenUrl: "https://iot.hzzlyun.com/api/auth/login"
  282 + infoUrl: "https://iot.hzzlyun.com/api/yt/device"
  283 + detailUrl: "https://iot.hzzlyun.com/api/v1/"
  284 +
263 device: 285 device:
264 token: 286 token:
265 url: "https://iotgc.cniot.vip/auth/token" 287 url: "https://iotgc.cniot.vip/auth/token"