From 0819312988ae6e041360fd354ef57a73633b7354 Mon Sep 17 00:00:00 2001
From: zhangnaisong <2434969829@qq.com>
Date: 星期六, 07 九月 2024 16:16:12 +0800
Subject: [PATCH] 二厂数字化工况预警与停机报警提交
---
src/main/java/com/ard/utils/netty/tcp/NettyInit.java | 49 +++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 49 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/ard/utils/netty/tcp/NettyInit.java b/src/main/java/com/ard/utils/netty/tcp/NettyInit.java
new file mode 100644
index 0000000..4fde840
--- /dev/null
+++ b/src/main/java/com/ard/utils/netty/tcp/NettyInit.java
@@ -0,0 +1,49 @@
+package com.ard.utils.netty.tcp;
+
+import com.ard.alarm.radar.domain.ArdEquipRadar;
+import com.ard.alarm.radar.service.IArdEquipRadarService;
+import com.ard.utils.netty.config.NettyTcpConfiguration;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import static com.ard.utils.netty.tcp.RadarNettyTcpClient.RADAR_MAP;
+
+@Component
+@Slf4j(topic = "netty")
+public class NettyInit {
+ @Resource
+ NettyTcpConfiguration nettyTcpConfig;
+ @Resource
+ private RadarNettyTcpClient radarNettyTcpClient;
+ @Resource
+ IArdEquipRadarService ardEquipRadarService;
+ @PostConstruct
+ public void createRadarConnect() {
+ try {
+ if (!nettyTcpConfig.getEnabled()) {
+ return;
+ }
+ List<Map<String, Object>> list = new ArrayList<>();
+ List<ArdEquipRadar> ardEquipRadars = ardEquipRadarService.selectArdEquipRadarList(new ArdEquipRadar());
+ for (ArdEquipRadar ardEquipRadar : ardEquipRadars) {
+ String host = ardEquipRadar.getIp();
+ Integer port = Integer.valueOf(ardEquipRadar.getPort());
+ Map<String,Object> mapParam =new HashMap<String, Object>();
+ mapParam.put("IP",host);
+ mapParam.put("PORT",port);
+ list.add(mapParam);
+ RADAR_MAP.put(host+":"+port,ardEquipRadar);
+ }
+ radarNettyTcpClient.initAllChannel(list);
+ }catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+}
--
Gitblit v1.9.3