package com.ard.alarm.tube.service;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.ard.utils.DateUtils;
|
import com.ard.utils.mqtt.MqttConsumer;
|
import com.ard.utils.tcp.NettyTcpClient;
|
import com.ard.utils.udp.NettyUdpServer;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.PostConstruct;
|
import javax.annotation.Resource;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* @Description: 管线泄漏报警服务
|
* @ClassName: TubeAlarmService
|
* @Author: 刘苏义
|
* @Date: 2023年06月06日8:56
|
* @Version: 1.0
|
**/
|
@Service
|
@Slf4j(topic = "tube")
|
public class TubeAlarmService {
|
@Resource
|
NettyUdpServer nettyUdpServer;
|
|
@Value("${spring.netty.udp.port}")
|
private Integer udpPort;
|
@Value("${spring.netty.udp.enabled}")
|
private String UdpServerEnable;
|
|
@PostConstruct
|
public void init() {
|
if (UdpServerEnable.equals("false")) {
|
return;
|
}
|
nettyUdpServer.init(udpPort);
|
log.info("UDP服务已启动");
|
}
|
|
@Async("alarm")
|
public void alarmHandler(String message) {
|
try {
|
String[] messages = message.split(",");
|
if (messages.length == 8) {
|
String start = messages[0];
|
String host = messages[1];
|
String tubeId = messages[2];
|
String alarmTime = DateUtils.convertDate(messages[3]);
|
String position = messages[4];
|
String type = messages[5];
|
String watcher = messages[6];
|
String stop = messages[7];
|
Map<String, Object> map = new HashMap<>();
|
map.put("host", host);
|
map.put("tubeId", tubeId);
|
map.put("alarmTime", alarmTime);
|
map.put("type", type);
|
map.put("alarmType", start);
|
map.put("position", position);
|
map.put("watcher", watcher);
|
log.info("开始解析" + start);
|
log.info("主机：" + host);
|
log.info("管线编号：" + tubeId);
|
log.info("报警时间：" + alarmTime);
|
log.info("报警类型：" + type);
|
log.info("位置：" + position);
|
log.info("值班人：" + watcher);
|
log.info("结束解析" + stop);
|
MqttConsumer.publish(2, false, "tube", JSON.toJSONString(map));
|
} else {
|
log.error("数据异常");
|
}
|
} catch (Exception ex) {
|
log.error("tube报警数据推送异常：" + ex.getMessage());
|
}
|
}
|
}
|
