diff --git a/riis-system/src/main/java/com/yfd/platform/component/WebSocketServer.java b/riis-system/src/main/java/com/yfd/platform/component/WebSocketServer.java index 10dd581..240c2b9 100644 --- a/riis-system/src/main/java/com/yfd/platform/component/WebSocketServer.java +++ b/riis-system/src/main/java/com/yfd/platform/component/WebSocketServer.java @@ -25,7 +25,7 @@ public class WebSocketServer { webSocketSet.add(this);//加入set中 addOnlineCount(); log.info("有新连接加入!当前在线人数为"+getOnlineCount()); - allCurrentOnline(); +// allCurrentOnline(); } @OnClose @@ -33,7 +33,7 @@ public class WebSocketServer { webSocketSet.remove(this); subOnlineCount(); log.info("有一连接关闭!当前在线人数为" + getOnlineCount()); - allCurrentOnline(); +// allCurrentOnline(); } @OnMessage diff --git a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/controller/AlgorithmClassController.java b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/controller/AlgorithmClassController.java index ed8c8ae..01873ef 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/controller/AlgorithmClassController.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/controller/AlgorithmClassController.java @@ -43,8 +43,8 @@ public class AlgorithmClassController { @GetMapping("/getAlgorithmClassTree") @ApiOperation("获取算法分类树") - public ResponseResult getAlgorithmClassTree(String algorithmClassName) { - List treeNodes = algorithmClassService.getAlgorithmComponentTree(algorithmClassName); + public ResponseResult getAlgorithmClassTree(String stationCode,String algorithmClassName) { + List treeNodes = algorithmClassService.getAlgorithmComponentTree(stationCode,algorithmClassName); return ResponseResult.successData(treeNodes); } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/mapper/AlgorithmClassComponentMapper.java b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/mapper/AlgorithmClassComponentMapper.java index 10925f2..ced6a39 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/mapper/AlgorithmClassComponentMapper.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/mapper/AlgorithmClassComponentMapper.java @@ -16,5 +16,5 @@ import java.util.Map; */ public interface AlgorithmClassComponentMapper extends BaseMapper { - List> getAlgorithmComponentList(String algorithmClassName); + List> getAlgorithmComponentList(String stationCode,String algorithmClassName); } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/mapper/AlgorithmDeviceMapper.java b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/mapper/AlgorithmDeviceMapper.java index 6337cd5..b0a90cb 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/mapper/AlgorithmDeviceMapper.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/mapper/AlgorithmDeviceMapper.java @@ -25,4 +25,6 @@ public interface AlgorithmDeviceMapper extends BaseMapper { List> getAlgorithmDeviceParams(String algorithmId, String componentId); List> getAlgorithmDeviceType(String algorithmId, String componentId); + + String getReturnDesc(String componentId); } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/IAlgorithmClassService.java b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/IAlgorithmClassService.java index a648cc5..60a70e5 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/IAlgorithmClassService.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/IAlgorithmClassService.java @@ -51,6 +51,6 @@ public interface IAlgorithmClassService extends IService { * 参数说明 algorithmClassName * 返回值说明: java.util.List ***********************************/ - List getAlgorithmComponentTree(String algorithmClassName); + List getAlgorithmComponentTree(String stationCode,String algorithmClassName); } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/impl/AlgorithmClassServiceImpl.java b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/impl/AlgorithmClassServiceImpl.java index 69a23b7..5c4c980 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/impl/AlgorithmClassServiceImpl.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/impl/AlgorithmClassServiceImpl.java @@ -136,9 +136,9 @@ public class AlgorithmClassServiceImpl extends ServiceImpl ***********************************/ @Override - public List getAlgorithmComponentTree(String algorithmClassName) { + public List getAlgorithmComponentTree(String stationCode,String algorithmClassName) { List> dataList = - algorithmClassComponentMapper.getAlgorithmComponentList(algorithmClassName); + algorithmClassComponentMapper.getAlgorithmComponentList(stationCode,algorithmClassName); List treeNodes = this.buildSignalTree(dataList); if (treeNodes.size() <= 0) { return treeNodes; diff --git a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/impl/AlgorithmParamsServiceImpl.java b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/impl/AlgorithmParamsServiceImpl.java index fed9613..f4dd499 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/impl/AlgorithmParamsServiceImpl.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/algorithm/service/impl/AlgorithmParamsServiceImpl.java @@ -1,5 +1,6 @@ package com.yfd.platform.modules.algorithm.service.impl; +import cn.hutool.core.net.NetUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -12,10 +13,13 @@ import com.yfd.platform.modules.algorithm.mapper.AlgorithmDeviceMapper; import com.yfd.platform.modules.algorithm.mapper.AlgorithmParamsMapper; import com.yfd.platform.modules.algorithm.service.IAlgorithmParamsService; import com.yfd.platform.utils.HttpRESTfulUtils; +import com.yfd.platform.utils.StringUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; +import java.net.URI; +import java.net.URISyntaxException; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -115,6 +119,10 @@ public class AlgorithmParamsServiceImpl extends ServiceImpl> mapList = algorithmParamsMapper.getAnalyseParams(id, componentId); if (mapList.size() <= 0) { @@ -126,9 +134,10 @@ public class AlgorithmParamsServiceImpl extends ServiceImpl param = new HashMap<>(); param.put("param", senData); - JSONObject jsonObject = httpRESTfulUtils.sendHttpUrlPost("json", - algorithmClass.getServiceAddress(), "", param, null); + JSONObject jsonObject = httpRESTfulUtils.sendHttpUrlPost("json", serviceAddress, "", param, null); + String desc = algorithmDeviceMapper.getReturnDesc(componentId); jsonObject.put("mapList", mapList); + jsonObject.put("desc", desc); return jsonObject; } } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/controller/DeviceWorkDataController.java b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/controller/DeviceWorkDataController.java index 36f2ace..4a0895b 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/controller/DeviceWorkDataController.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/controller/DeviceWorkDataController.java @@ -47,6 +47,9 @@ public class DeviceWorkDataController { @ApiOperation("分页查询变电站设备运行记录") public ResponseResult getDeviceWorkDataPage(Page page, String signalId, String startDate, String endDate) { + if(StrUtil.isBlank(signalId)){ + return ResponseResult.successData(page); + } Page deviceWorkDataPage = deviceWorkDataService.getDeviceWorkDataPage(page, signalId, startDate, endDate); return ResponseResult.successData(deviceWorkDataPage); diff --git a/riis-system/src/main/java/com/yfd/platform/utils/StringUtils.java b/riis-system/src/main/java/com/yfd/platform/utils/StringUtils.java index 57e11ff..ecedea2 100644 --- a/riis-system/src/main/java/com/yfd/platform/utils/StringUtils.java +++ b/riis-system/src/main/java/com/yfd/platform/utils/StringUtils.java @@ -33,9 +33,7 @@ import org.springframework.core.io.ClassPathResource; import javax.servlet.http.HttpServletRequest; import java.io.File; import java.io.IOException; -import java.net.InetAddress; -import java.net.NetworkInterface; -import java.net.UnknownHostException; +import java.net.*; import java.util.Calendar; import java.util.Date; import java.util.Enumeration; @@ -283,6 +281,17 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils { return weekDays[w]; } + public static boolean isHttpOrHttps(String url) { + try { + URI uri = new URI(url); + String scheme = uri.getScheme(); + return "http".equalsIgnoreCase(scheme) || "https".equalsIgnoreCase(scheme); + } catch (URISyntaxException e) { + // 非法 URL 格式 + return false; + } + } + /** * 获取当前机器的IP * diff --git a/riis-system/src/main/resources/mapper/algorithm/AlgorithmClassComponentMapper.xml b/riis-system/src/main/resources/mapper/algorithm/AlgorithmClassComponentMapper.xml index 7816b01..8cf74f5 100644 --- a/riis-system/src/main/resources/mapper/algorithm/AlgorithmClassComponentMapper.xml +++ b/riis-system/src/main/resources/mapper/algorithm/AlgorithmClassComponentMapper.xml @@ -15,7 +15,7 @@ iis_algorithm_class ac INNER JOIN iis_algorithm_class_component acc ON ac.id = acc.algorithm_id WHERE - 1 =1 + acc.station_code=#{stationCode} AND ac.algorithm_class_name LIKE CONCAT('%',#{algorithmClassName},'%') diff --git a/riis-system/src/main/resources/mapper/algorithm/AlgorithmDeviceMapper.xml b/riis-system/src/main/resources/mapper/algorithm/AlgorithmDeviceMapper.xml index 1b1bda5..f0d2c6f 100644 --- a/riis-system/src/main/resources/mapper/algorithm/AlgorithmDeviceMapper.xml +++ b/riis-system/src/main/resources/mapper/algorithm/AlgorithmDeviceMapper.xml @@ -36,4 +36,13 @@ AND ad.component_id =#{componentId} +