From 7f1a84cb9c7f7e3c1d03abacd6fc65fbc76b02aa Mon Sep 17 00:00:00 2001 From: "3067418132@qq.com" Date: Fri, 10 Jul 2026 09:53:08 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E4=BF=9D=E5=88=A9=E5=B1=B1=E5=BA=84?= =?UTF-8?q?=E6=8E=A5=E5=85=A5=E7=BB=B4=E6=8E=A7=E7=BD=91=E5=85=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../device/OperationController.java | 20 +- .../src/main/resources/application-dev.yml | 8 +- mh-admin/src/main/resources/application.yml | 5 +- .../test/java/com/mh/MHApplicationTest.java | 8 + .../com/mh/common/constant/Constants.java | 1 + .../mh/quartz/task/GetWeiKongSysDataJob.java | 566 ++++++++++++++++++ .../operation/IOperationDeviceService.java | 2 + .../impl/OperationDeviceServiceImpl.java | 26 +- 8 files changed, 626 insertions(+), 10 deletions(-) create mode 100644 mh-quartz/src/main/java/com/mh/quartz/task/GetWeiKongSysDataJob.java diff --git a/mh-admin/src/main/java/com/mh/web/controller/device/OperationController.java b/mh-admin/src/main/java/com/mh/web/controller/device/OperationController.java index 7d32d8a..b03003a 100644 --- a/mh-admin/src/main/java/com/mh/web/controller/device/OperationController.java +++ b/mh-admin/src/main/java/com/mh/web/controller/device/OperationController.java @@ -12,6 +12,7 @@ import com.mh.common.core.page.TableDataInfo; import com.mh.common.enums.BusinessType; import com.mh.framework.mqtt.service.IMqttGatewayService; import com.mh.framework.netty.INettyService; +import com.mh.quartz.task.GetWeiKongSysDataJob; import com.mh.system.service.device.ICollectionParamsManageService; import com.mh.system.service.operation.IOperationDeviceService; import lombok.extern.slf4j.Slf4j; @@ -37,6 +38,9 @@ public class OperationController extends BaseController { @Value("${control.topic}") String controlTopic; + @Value(value = "${wkBaseUrl}") + private String wkBaseUrl; + @Autowired private MHConfig mhConfig; @@ -52,6 +56,9 @@ public class OperationController extends BaseController { @Autowired private INettyService nettyService; + @Autowired + private GetWeiKongSysDataJob getWeiKongSysDataJob; + /** * 获取监控列表内容数据 */ @@ -94,7 +101,7 @@ public class OperationController extends BaseController { public AjaxResult operationDevice(@RequestBody List changeValues) { try { // 增加判断是否是昆仑通态触摸屏的MQTT设备 - if (!iOperationService.isKuLunTouchScreen(changeValues)) { + if (iOperationService.isKuLunTouchScreen(changeValues)) { String sendOrder = iOperationService.operationKLTTDevice(changeValues); String name = mhConfig.getName(); // 获取mqtt操作队列(后期通过mqtt队列配置发送主题) @@ -104,7 +111,7 @@ public class OperationController extends BaseController { } else { log.warn("MQTT未启用，无法发送控制指令"); } - } else if (!iOperationService.isAdvanTech(changeValues)) { + } else if (iOperationService.isAdvanTech(changeValues)) { // 判断id是否是DTU设备类型 String sendOrder = iOperationService.operationDevice(changeValues); String name = mhConfig.getName(); @@ -115,7 +122,14 @@ public class OperationController extends BaseController { } else { log.warn("MQTT未启用，无法发送控制指令"); } - } else { + } else if (iOperationService.isWeiKong(changeValues)) { + // 直接请求维控控制接口 + if(getWeiKongSysDataJob.operationDevice(wkBaseUrl, changeValues)) { + return AjaxResult.success(); + } else { + return AjaxResult.error(); + } + }else { // 目前只有DTU设备需要发送4G指令 if (nettyService.sendOrder(changeValues)) { return AjaxResult.success(); diff --git a/mh-admin/src/main/resources/application-dev.yml b/mh-admin/src/main/resources/application-dev.yml index a93b3bc..b50d7d9 100644 --- a/mh-admin/src/main/resources/application-dev.yml +++ b/mh-admin/src/main/resources/application-dev.yml @@ -1,7 +1,7 @@ # 项目相关配置 mh: # 名称 - name: bl_dev + name: blsz_dev # 版本 version: 1.0.0 # 版权年份 @@ -63,7 +63,7 @@ spring: # 端口，默认为6379 port: 6379 # 数据库索引 - database: 3 + database: 4 # 密码 password: # 连接超时时间 @@ -98,10 +98,10 @@ spring: # 主库数据源 master: #添加allowMultiQueries=true 在批量更新时才不会出错 - url: jdbc:postgresql://192.168.1.107:5232/bl_eems + url: jdbc:postgresql://127.0.0.1:5432/eemcs_blsz # url: jdbc:postgresql://106.55.173.225:5505/eemcs username: postgres - password: mhtech@803 + password: mh@803 # 从库数据源 slave: # 从数据源开关/默认关闭 diff --git a/mh-admin/src/main/resources/application.yml b/mh-admin/src/main/resources/application.yml index c3ae7c3..25d5789 100644 --- a/mh-admin/src/main/resources/application.yml +++ b/mh-admin/src/main/resources/application.yml @@ -24,4 +24,7 @@ pagehelper: reasonable: true params: count=countSql support-methods-arguments: true - helper-dialect: postgresql \ No newline at end of file + helper-dialect: postgresql + +wkBaseUrl: http://api.v-iec.com + #维控网关第三方账号：用户名【170b9f801b0c40e1b83d63217726fa18】，密码【7a627c3ef7bf1cae22474ad516415281】 \ No newline at end of file diff --git a/mh-admin/src/test/java/com/mh/MHApplicationTest.java b/mh-admin/src/test/java/com/mh/MHApplicationTest.java index df2f1e8..92c1f24 100644 --- a/mh-admin/src/test/java/com/mh/MHApplicationTest.java +++ b/mh-admin/src/test/java/com/mh/MHApplicationTest.java @@ -73,6 +73,14 @@ public class MHApplicationTest { @Autowired private GetOtherSysDataJob getOtherSysDataJob; + @Autowired + private GetWeiKongSysDataJob getWeiKongSysDataJob; + + @Test + public void getWKData() { + getWeiKongSysDataJob.getWeiKongSysData(""); + } + @Test public void getBSDData() { // getOtherSysDataJob.getBSDData1("",""); diff --git a/mh-common/src/main/java/com/mh/common/constant/Constants.java b/mh-common/src/main/java/com/mh/common/constant/Constants.java index d0119cc..023fe36 100644 --- a/mh-common/src/main/java/com/mh/common/constant/Constants.java +++ b/mh-common/src/main/java/com/mh/common/constant/Constants.java @@ -192,6 +192,7 @@ public class Constants { public static final String OTHER_TYPE = "1"; // 其他设备 public static final String BOILER_TYPE = "12"; // 锅炉设备 public static final String ERS = "ers"; // 热回收系统 + public static final String WEI_KONG_SID = "weikong_sid"; // 维控登录凭证 public static boolean CONTROL_WEB_FLAG = false; public static boolean SEND_STATUS = false; // 指令发送状态 public static boolean FLAG = false; diff --git a/mh-quartz/src/main/java/com/mh/quartz/task/GetWeiKongSysDataJob.java b/mh-quartz/src/main/java/com/mh/quartz/task/GetWeiKongSysDataJob.java new file mode 100644 index 0000000..2ebb7f2 --- /dev/null +++ b/mh-quartz/src/main/java/com/mh/quartz/task/GetWeiKongSysDataJob.java @@ -0,0 +1,566 @@ +package com.mh.quartz.task; + +import com.alibaba.fastjson2.JSON; +import com.alibaba.fastjson2.JSONArray; +import com.alibaba.fastjson2.JSONObject; +import com.mh.common.constant.Constants; +import com.mh.common.core.domain.entity.CollectionParamsManage; +import com.mh.common.core.domain.entity.OrderEntity; +import com.mh.common.core.redis.RedisCache; +import com.mh.common.model.request.AdvantechDatas; +import com.mh.common.model.request.AdvantechReceiver; +import com.mh.common.utils.DateUtils; +import com.mh.common.utils.StringUtils; +import com.mh.common.utils.sign.Md5Utils; +import com.mh.framework.rabbitmq.producer.SendMsgByTopic; +import com.mh.system.mapper.device.GatewayManageMapper; +import com.mh.system.service.device.ICollectionParamsManageService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.io.PrintWriter; +import java.math.BigDecimal; +import java.net.HttpURLConnection; +import java.net.URL; +import java.nio.charset.StandardCharsets; +import java.util.*; +import java.util.concurrent.TimeUnit; + +/** + * @author LJF + * @version 1.0 + * @project EEMCS + * @description 获取维控网关数据定时任务 + * @date 2026-07-07 14:57:49 + */ +@Slf4j +@Component("getWeiKongSysDataJob") +public class GetWeiKongSysDataJob { + + @Autowired + private ICollectionParamsManageService collectionParamsManageService; + + @Autowired + private GatewayManageMapper gatewayManageMapper; + + @Autowired + private SendMsgByTopic sendMsgByTopic; + + @Autowired + private RedisCache redisCache; + + // ==== 维控网关账号配置（建议后续改为 @Value 从 application.yml 注入） ==== + private static final String VK_ALIAS = "170b9f801b0c40e1b83d63217726fa18"; + private static final String VK_PASSWORD_MD5 = "7a627c3ef7bf1cae22474ad516415281"; // URL中password参数（密码的MD5） + private static final String VK_CUID = "123456789"; + private static final String VK_SV = "1.0"; + private static final String VK_MT = "255"; + private static final String VK_PID = "1"; + private static final String VK_SIGN_KEY = "5cee621329f24e5cbdc43daa959ce9a1"; // sign拼接用的key + + // ==== 通用常量 ==== + private static final int PAGE_SIZE = 50; + private static final int REDIS_CACHE_SECONDS = 8 * 60 * 60; + + + // 获取维控网关数据 + public void getWeiKongSysData(String realUrl) { + log.info("开始获取维控网关数据"); + try { + if (StringUtils.isEmpty(realUrl)) { + realUrl = "http://api.v-iec.com"; + } else { + realUrl = "http://" + realUrl; + } + +// // 获取冷源所有点位（预留，后续用于 realdata 数据与点位映射） +// HashMap params = new HashMap<>(); +// params.put("systemType", "0"); +// List collectionParamsManages = collectionParamsManageService.selectListByParams(params); + + List> allAdvantechDatas = new ArrayList<>(); + String token = null; + + // 增加redis 8小时过期缓存时间 + if (redisCache.hasKey(Constants.WEI_KONG_SID)) { + token = redisCache.getCacheObject(Constants.WEI_KONG_SID); + } else { + token = loginToWeiKong(realUrl); + if (StringUtils.isBlank(token)) { + log.error("未获取到维控网关token，终止本次采集"); + return; + } + } + + // 获取到token值之后，开始获取设备列表 + String deviceListUrl = realUrl + "/m16/we-data/device/getList"; + // 其中wcommon值，会发生改变 + // 计算签名拼接发生改变：cuid=123456789&mt=255&pid=1&sid=84b46fd2565b49e9ab678b6cd211721e&sv=1.0&ts=1783409441936&key=5cee621329f24e5cbdc43daa959ce9a1 + // wcommon的值变成：{"cuid":"123456789","sv":"1.0","mt":"255","sign":"5021bd40d02659558c9c7e5056fdcf67","pid":"1","ts":1783409441936,"sid":"84b46fd2565b49e9ab678b6cd211721e"} + String deviceListWc = buildWcommonHeader(token, + "cuid", VK_CUID, "mt", VK_MT, "pid", VK_PID, "sid", token, "sv", VK_SV); + String deviceListResp = sendGetWithHeader(realUrl, deviceListUrl, deviceListWc, allAdvantechDatas); + log.info("维控网关设备列表响应: {}", deviceListResp); + + // 封装成研华网关格式并发送到消息队列 + if (!allAdvantechDatas.isEmpty()) { + AdvantechReceiver advantechReceiver = new AdvantechReceiver(); + advantechReceiver.setTs(DateUtils.dateToString(new Date(), Constants.DATE_FORMAT)); + advantechReceiver.setD(allAdvantechDatas); + + String message = JSONObject.toJSONString(advantechReceiver); + log.info("发送维控数据到消息队列，数据点数: {}", allAdvantechDatas.size()); + sendMsgByTopic.sendToDeviceMQ(message); + log.info("维控数据发送成功"); + } else { + log.warn("没有获取到任何维控数据"); + } + + } catch (Exception e) { + log.error("获取维控数据异常", e); + } + } + + /** + * 登录维控网关，获取会话 sid + * + * @param realUrl 维控网关基础地址 + * @return 会话 sid，登录失败返回 null + */ + private String loginToWeiKong(String realUrl) { + // 登录维控网关 + String loginUrl = realUrl + "/m16/we-data/sign/login"; + // 根据这个cli的请求方式生成对应的请求逻辑 + // postman request POST 'http://api.v-iec.com/m16/we-data/sign/login?alias=170b9f801b0c40e1b83d63217726fa18&password=2348648c42e6913b53bf5b0e3c366f64' \ + // --header 'Wcommon: {"cuid":"123456789","sv":"1.0","mt":"255","sign":"5fa49940234e55c13fd831ef5b5079dc","pid":"1","ts":1783407005717}' + //其中ts是当前时间戳，sign是"alias=test&cuid=123456789&mt=255&password=e10adc3949ba59abbe56e057f20f883e&pid=1&sv=1.0&ts=1756708016315&key=5cee621329f24e5cbdc43daa959ce9a1"的md5 32位小加密 + // sign 拼接串：注意 password 使用明文密码的MD5，key 放在最后 + String passwordMd5 = Md5Utils.hash(VK_PASSWORD_MD5); + String wcommonHeader = buildWcommonHeader("", + "alias", VK_ALIAS, "cuid", VK_CUID, "mt", VK_MT, + "password", passwordMd5, "pid", VK_PID, "sv", VK_SV); + + // 组装带 query 参数的完整登录URL（password 为密码MD5） + String fullLoginUrl = loginUrl + "?alias=" + VK_ALIAS + "&password=" + passwordMd5; + + // 发送带 Wcommon 头的 POST 登录请求（HttpUtils 不支持自定义header，使用 HttpURLConnection） + String loginResp = sendPostWithHeader(fullLoginUrl, wcommonHeader); + log.info("维控网关登录响应: {}", loginResp); + + String token = null; + if (StringUtils.isNotBlank(loginResp)) { + JSONObject loginJson = JSON.parseObject(loginResp); + if (loginJson.getInteger("code") == 200) { + token = loginJson.getJSONObject("result").getString("sid"); // 依据接口实际返回字段调整 + log.info("维控网关登录成功"); + } else { + log.error("维控网关登录失败: {}", loginJson.getString("msg")); + } + } + if (StringUtils.isNotBlank(token)) { + log.info("维控网关登录成功，sid: {}", token); + redisCache.setCacheObject(Constants.WEI_KONG_SID, token, REDIS_CACHE_SECONDS, TimeUnit.SECONDS); + } + return token; + } + + /** + * 构建维控网关 Wcommon 请求头 JSON（含自动签名与时间戳） + * + * @param sid 会话ID（登录时传空串） + * @param signPairs 签名参数，按 key1,val1,key2,val2... 顺序排列，ts 和 key 会自动追加 + * @return Wcommon 头的 JSON 字符串 + */ + private String buildWcommonHeader(String sid, String... signPairs) { + long ts = System.currentTimeMillis(); + // 拼接签名源串：key1=val1&key2=val2&...&ts=xxx&key=xxx + StringBuilder signSrc = new StringBuilder(); + for (int i = 0; i < signPairs.length; i += 2) { + if (i > 0) { + signSrc.append("&"); + } + signSrc.append(signPairs[i]).append("=").append(signPairs[i + 1]); + } + signSrc.append("&ts=").append(ts); + signSrc.append("&key=").append(VK_SIGN_KEY); + String sign = Md5Utils.hash(signSrc.toString()); + + JSONObject wcommon = new JSONObject(); + wcommon.put("cuid", VK_CUID); + wcommon.put("sv", VK_SV); + wcommon.put("mt", VK_MT); + wcommon.put("sign", sign); + wcommon.put("pid", VK_PID); + wcommon.put("ts", ts); + if (StringUtils.isNotBlank(sid)) { + wcommon.put("sid", sid); + } + return wcommon.toJSONString(); + } + + /** + * 发送设备列表请求，遍历设备并拉取实时数据 + * + * @return API响应原始字符串 + */ + private String sendGetWithHeader(String baseUrl, String url, String wcommonHeader, List> allAdvantechDatas) { + String deviceResp = sendPostWithHeader(url, wcommonHeader); + log.info("维控网关设备列表响应: {}", deviceResp); + // 响应值：{ + //{ + // "reqId": "1783412496265", + // "code": 200, + // "msg": "ok", + // "result": { + // "list": [ + // { + // "groupName": "默认组", + // "boxList": [ + // { + // "devType": 0, + // "baseAuth": false, + // "devModel": "V-BOX H-4G", + // "machineCode": "V12000240702037747696d4cb0f", + // "devVer": 1, + // "groupId": 10209020, + // "sort": 0, + // "templateId": 0, + // "realAuth": 3, + // "boxName": "保利", + // "state": 1, + // "map": ",", + // "boxId": 6434626 + // } + // ] + // } + // ] + // } + //} + if (StringUtils.isBlank(deviceResp)) { + log.error("维控网关设备列表响应为空"); + return Constants.SUCCESS; + } + + JSONObject deviceListJson = JSON.parseObject(deviceResp); + JSONObject resultObj = deviceListJson.getJSONObject("result"); + if (resultObj == null) { + log.error("维控网关设备列表result为空"); + return Constants.SUCCESS; + } + JSONArray list = resultObj.getJSONArray("list"); + if (list == null || list.isEmpty()) { + log.warn("维控网关设备列表为空"); + return Constants.SUCCESS; + } + + // 从登录后的 wcommon 头中提取 sid，供后续 realdata 请求使用 + JSONObject wcommonJson = JSON.parseObject(wcommonHeader); + String sid = wcommonJson.getString("sid"); + + // 遍历获取boxList组数据并进行log.info + for (int i = 0; i < list.size(); i++) { + JSONObject groupObj = list.getJSONObject(i); + log.info("设备列表分组信息: {}", groupObj.toJSONString()); + JSONArray boxList = groupObj.getJSONArray("boxList"); + if (boxList == null) { + continue; + } + for (int j = 0; j < boxList.size(); j++) { + JSONObject boxObj = boxList.getJSONObject(j); + log.info("设备详情信息: {}", boxObj.toJSONString()); + String boxId = boxObj.getString("boxId"); + String devType = boxObj.getString("devType"); + + // 根据boxId获取对应的分组列表数据 + try { + processBoxGroups(baseUrl, boxId, devType, sid, allAdvantechDatas); + } catch (Exception e) { + log.error("处理设备 [boxId={}] 分组数据异常", boxId, e); + } + } + } + return Constants.SUCCESS; + } + + /** + * 获取设备的分组列表，并拉取每个分组的实时监控点数据 + */ + private void processBoxGroups(String baseUrl, String boxId, String devType, String sid, List> allAdvantechDatas) { + // 根据boxId获取对应的分组列表数据 + // 其中签名参数：boxId=6434626&cuid=123456789&mt=255&pid=1&sid=84b46fd2565b49e9ab678b6cd211721e&sv=1.0&ts=1783414379064&key=5cee621329f24e5cbdc43daa959ce9a1 + // 请求头 wcommon = {"cuid":"123456789","sv":"1.0","mt":"255","sign":"e04d082236a317f262fb8bd1267d0966","pid":"1","ts":1783414379064,"sid":"84b46fd2565b49e9ab678b6cd211721e"} + String groupListUrl = baseUrl + "/m16/we-data/actGroup?boxId=" + boxId; + String groupWc = buildWcommonHeader(sid, + "boxId", boxId, "cuid", VK_CUID, "mt", VK_MT, + "pid", VK_PID, "sid", sid, "sv", VK_SV); + + // 开始发送请求 + String groupResp = sendPostWithHeader(groupListUrl, groupWc); + log.info("设备 [boxId={}] 实时监控点分组列表响应: {}", boxId, groupResp); + + if (StringUtils.isBlank(groupResp)) { + return; + } + JSONObject groupJson = JSON.parseObject(groupResp); + JSONObject listObj = groupJson.getJSONObject("result"); + if (listObj == null) { + return; + } + // 请求后响应：{ + // "list": + // [ + // { + // "groupName":"默认组", + // "groupId":338364 + // } + // + // ] + // + //} + JSONArray groupList = listObj.getJSONArray("list"); + if (groupList == null || groupList.isEmpty()) { + return; + } + + for (int k = 0; k < groupList.size(); k++) { + JSONObject groupItem = groupList.getJSONObject(k); + String groupId = groupItem.getString("groupId"); + if (StringUtils.isBlank(groupId)) { + continue; + } + fetchRealDataByPage(baseUrl, boxId, devType, groupId, sid, allAdvantechDatas); + } + } + + /** + * 分页拉取设备实时监控点数据 + */ + private void fetchRealDataByPage(String baseUrl, String boxId, String devType, String groupId, String sid, List> allAdvantechDatas) { + String realDataUtl = baseUrl + "/m16/we-data/realdata"; + // 其中参数是：boxId 盒子ID（不传为自定义的监控点分组） + //groupId 组别ID，必传 + //pageSize 每页数量，不传默认10条 + //pageIndex 第几页，从1开始 + //devtype 设备类型（0:box，1:hmi），必传， + + int pageIndex = 1; + int totalRecord = 0; + boolean hasMoreData = true; + + while (hasMoreData) { + // 签名字符串是：boxId=6434626&cuid=123456789&devtype=0&groupId=10209020&mt=255&pageIndex=1&pageSize=10&pid=1&sid=84b46fd2565b49e9ab678b6cd211721e&sv=1.0&ts=1783410587018&key=5cee621329f24e5cbdc43daa959ce9a1 + // wcommon值：{"cuid":"123456789","sv":"1.0","mt":"255","sign":"2f1862fd0144108914b3e0d70c79ee39","pid":"1","ts":1783410587018,"sid":"84b46fd2565b49e9ab678b6cd211721e"} + String realDataWc = buildWcommonHeader(sid, + "boxId", boxId, "cuid", VK_CUID, "devtype", devType, + "groupId", groupId, "mt", VK_MT, "pageIndex", String.valueOf(pageIndex), + "pageSize", String.valueOf(PAGE_SIZE), "pid", VK_PID, "sid", sid, "sv", VK_SV); + + // 开始发送请求 + String fullRealDataUrl = realDataUtl + "?boxId=" + boxId + + "&groupId=" + groupId + + "&devtype=" + devType + + "&pageSize=" + PAGE_SIZE + + "&pageIndex=" + pageIndex; + String realDataResp = sendPostWithHeader(fullRealDataUrl, realDataWc); + log.info("设备 [boxId={}] 实时数据第{}页响应: {}", boxId, pageIndex, realDataResp); + + // 请求后数据响应为：{ + // "code": 200, + // "msg": "ok", + // "result": { + // "list": [ + // { + // "com":1, + // "string_point":-1, + // "monitorId":1, + // "addr_stat_no":-1, + // "actAuth":3, + // "monitorName":"3v-y3", + // "groupId":1, + // "state":0, + // "float_point":1, + // "templateId":0, + // "value":"0", + // "boxId":1 + // }, + // ], + //totalRecord：500， + //currentPage：2 + // } + //} + if (StringUtils.isBlank(realDataResp)) { + log.error("设备 [boxId={}] 实时数据响应为空", boxId); + break; + } + + JSONObject realDataJson = JSON.parseObject(realDataResp); + if (realDataJson.getInteger("code") != 200) { + log.error("设备 [boxId={}] 实时数据查询失败: {}", boxId, realDataJson.getString("msg")); + break; + } + + JSONObject resultObj = realDataJson.getJSONObject("result"); + if (resultObj == null) { + log.error("设备 [boxId={}] 实时数据result为空", boxId); + break; + } + JSONArray dataList = resultObj.getJSONArray("list"); + List registers = null; + if (redisCache.hasKey("DEVICES_REGISTER")) { + registers = redisCache.getCacheList("DEVICES_REGISTER", CollectionParamsManage.class); + + } else { + registers = collectionParamsManageService.queryCollectionParamsByMtType(Constants.OTHER_TYPE); + redisCache.setCacheList("DEVICES_REGISTER", registers); + } + // 开始遍历数据 + for (int i = 0; i < dataList.size(); i++) { + AdvantechDatas advantechData = new AdvantechDatas<>(); + JSONObject dataItem = dataList.getJSONObject(i); + String tag = dataItem.getString("monitorName"); + // 根据moitorName获取对应的otherName "DEVICES_REGISTER", Constants.DEVICE + long monitorId = dataItem.getLongValue("monitorId"); + // 遍历所有数据 + for (CollectionParamsManage register : registers) { + if (register.getMtNum().equals(String.valueOf(monitorId))) { + tag = register.getOtherName(); + break; + } + } + BigDecimal value = new BigDecimal(dataItem.getString("value")); + advantechData.setValue(value); + advantechData.setTag(tag); + // 根据state状态值，1为正常，其他为异常 + if (dataItem.getIntValue("state") == 1) { + advantechData.setQuality(BigDecimal.valueOf(0)); + } else { + advantechData.setQuality(BigDecimal.valueOf(1)); + } + allAdvantechDatas.add(advantechData); + } + totalRecord = resultObj.getIntValue("totalRecord"); + int currentPage = resultObj.getIntValue("currentPage"); + + if (!dataList.isEmpty()) { + log.info("设备 [boxId={}] 第{}页获取到{}条数据, 总记录数: {}", + boxId, pageIndex, dataList.size(), totalRecord); + } + + // 根据响应查看是否是已经全部查询完毕，如果没有就继续请求，如果已经全部查询完毕则结束请求 + if (currentPage * PAGE_SIZE >= totalRecord) { + hasMoreData = false; + log.info("设备 [boxId={}] 数据已全部获取完毕, 总记录数: {}", boxId, totalRecord); + } else { + pageIndex++; + } + } + } + + /** + * 发送带自定义 Wcommon 头的 POST 请求 + */ + private String sendPostWithHeader(String url, String wcommonHeader) { + StringBuilder result = new StringBuilder(); + BufferedReader in = null; + HttpURLConnection conn = null; + try { + URL realUrl = new URL(url); + conn = (HttpURLConnection) realUrl.openConnection(); + conn.setRequestMethod("POST"); + conn.setRequestProperty("accept", "*/*"); + conn.setRequestProperty("connection", "Keep-Alive"); + conn.setRequestProperty("user-agent", "Mozilla/5.0"); + conn.setRequestProperty("Content-Type", "application/json;charset=utf-8"); + conn.setRequestProperty("Wcommon", wcommonHeader); + conn.setDoOutput(true); + conn.setDoInput(true); + try (PrintWriter out = new PrintWriter(conn.getOutputStream())) { + out.print("{}"); // 登录无 body，传空 JSON + out.flush(); + } + in = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8)); + String line; + while ((line = in.readLine()) != null) { + result.append(line); + } + } catch (Exception e) { + log.error("维控网关登录请求异常, url={}", url, e); + } finally { + if (in != null) { + try { + in.close(); + } catch (IOException ignored) { + } + } + if (conn != null) { + conn.disconnect(); + } + } + return result.toString(); + } + + public boolean operationDevice(String wkBaseUrl, List changeValues) { + // 地址：/m16/we-data/updrealdata + String url = wkBaseUrl + "/m16/we-data/updrealdata"; + String token = null; + // 参数：boxId，monitorId，value，devtype(我们是0) + for (OrderEntity order : changeValues) { + // 根据id查询对应的网关，然后查询网关地址 + CollectionParamsManage collectionParamsManage = collectionParamsManageService.selectCollectionParamsManageById(order.getId()); + if (collectionParamsManage == null) { + log.error("设备 [id={}] 未找到对应的网关信息", order.getId()); + continue; + } + String gatewayId = collectionParamsManage.getGatewayId(); + String gatewayAddr = gatewayManageMapper.selectById(gatewayId).getGwAddr(); + if (StringUtils.isBlank(gatewayAddr)) { + log.error("设备 [id={}] 对应的网关地址为空", order.getId()); + continue; + } + String monitorId = collectionParamsManage.getMtNum(); + BigDecimal value = new BigDecimal(order.getParam()); + int devType = 0; + // 增加redis 8小时过期缓存时间 + if (redisCache.hasKey(Constants.WEI_KONG_SID)) { + token = redisCache.getCacheObject(Constants.WEI_KONG_SID); + } else { + token = loginToWeiKong(wkBaseUrl); + if (StringUtils.isBlank(token)) { + log.error("未获取到维控网关token，终止本次采集"); + continue; + } + } + // boxId=6434626&cuid=123456789&devtype=0&monitorId=12085422&mt=255&pid=1&sid=ec71bf11ad0f43e8926fc1f2c2985787&sv=1.0&ts=1783475921486&value=26&key=5cee621329f24e5cbdc43daa959ce9a1 + // {"cuid":"123456789","sv":"1.0","mt":"255","sign":"56e11aadbecc2559af7c6fcafcab226e","pid":"1","ts":1783475921486,"sid":"ec71bf11ad0f43e8926fc1f2c2985787"} + // 其中wcommon值，会发生改变 + // 开始发送请求 + String fullRealDataUrl = url + "?boxId=" + gatewayAddr + + "&monitorId=" + monitorId + + "&devtype=" + devType + + "&value=" + value; + String deviceListWc = buildWcommonHeader(token, + "cuid", VK_CUID, "mt", VK_MT, "pid", VK_PID, "sid", token, "sv", VK_SV); + // 发送请求，并获取响应结果 + String result = sendPostWithHeader(fullRealDataUrl, deviceListWc); + JSONObject jsonObject = JSONObject.parseObject(result); + log.info("维控网关设备设置值操作返回: {}", result); + if (jsonObject.getInteger("code").equals(200)) { + continue; + } else { + log.error("维控网关设备设置值操作失败: {}", result); + return false; + } + } + // 重新查询实时数据 + try { + getWeiKongSysData(""); + } catch (Exception e) { + log.error("重新查询维控网关实时数据异常", e); + } + return true; + } +} diff --git a/mh-system/src/main/java/com/mh/system/service/operation/IOperationDeviceService.java b/mh-system/src/main/java/com/mh/system/service/operation/IOperationDeviceService.java index 0760c3c..c8ecc12 100644 --- a/mh-system/src/main/java/com/mh/system/service/operation/IOperationDeviceService.java +++ b/mh-system/src/main/java/com/mh/system/service/operation/IOperationDeviceService.java @@ -20,4 +20,6 @@ public interface IOperationDeviceService { boolean isKuLunTouchScreen(List changeValues); String operationKLTTDevice(List changeValues); + + boolean isWeiKong(List changeValues); } diff --git a/mh-system/src/main/java/com/mh/system/service/operation/impl/OperationDeviceServiceImpl.java b/mh-system/src/main/java/com/mh/system/service/operation/impl/OperationDeviceServiceImpl.java index 9b503af..53b702c 100644 --- a/mh-system/src/main/java/com/mh/system/service/operation/impl/OperationDeviceServiceImpl.java +++ b/mh-system/src/main/java/com/mh/system/service/operation/impl/OperationDeviceServiceImpl.java @@ -93,7 +93,7 @@ public class OperationDeviceServiceImpl implements IOperationDeviceService { GatewayManage gatewayManage = gatewayManageMapper.selectById(gatewayId); if (null != gatewayManage) { String dictLabel = sysDictDataMapper.selectDictLabel("communication_type", String.valueOf(gatewayManage.getCommunicationType())); - if (!dictLabel.equals("MQTT/KNTT")) { + if (dictLabel.equals("MQTT/KNTT")) { return true; } } @@ -111,7 +111,7 @@ public class OperationDeviceServiceImpl implements IOperationDeviceService { String cpmId = changeValue.getId(); CollectionParamsManage collectionParamsManage = collectionParamsManageMapper.selectById(cpmId); if (null != collectionParamsManage) { - if (!collectionParamsManage.getGatewayId().contains("99")) { + if (collectionParamsManage.getGatewayId().contains("99")) { return true; } } @@ -120,6 +120,28 @@ public class OperationDeviceServiceImpl implements IOperationDeviceService { return false; } + @Override + public boolean isWeiKong(List changeValues) { + // 判断是否存在非维控网关设备 + if (!changeValues.isEmpty()) { + for (OrderEntity changeValue : changeValues) { + String cpmId = changeValue.getId(); + CollectionParamsManage collectionParamsManage = collectionParamsManageMapper.selectById(cpmId); + if (null != collectionParamsManage) { + String gatewayId = collectionParamsManage.getGatewayId(); + GatewayManage gatewayManage = gatewayManageMapper.selectById(gatewayId); + if (null != gatewayManage) { + String dictLabel = sysDictDataMapper.selectDictLabel("communication_type", String.valueOf(gatewayManage.getCommunicationType())); + if (dictLabel.equals("HTTP/WEIKONG")) { + return true; + } + } + } + } + } + return false; + } + @Override public String operationDevice(List changeValues) { // 拼接发送的报文