优化行为分析信息报警

‘liusuyi’

2023-08-10 ad89fdba09b8f0596ed41c5b31de6f34fe1ce620

 src/main/java/com/ard/alarm/radar/service/impl/ArdEquipRadarServiceImpl.java

@@ -4,13 +4,8 @@
import com.ard.alarm.radar.domain.ArdEquipRadar;
import com.ard.alarm.radar.mapper.ArdEquipRadarMapper;
import com.ard.alarm.radar.service.IArdEquipRadarService;
import com.ard.utils.tcp.NettyTcpClient;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;

/**
 * radarService业务层处理
@@ -19,32 +14,10 @@
 * @date 2023-03-11
 */
@Service
@Slf4j(topic = "radar")
public class ArdEquipRadarServiceImpl implements IArdEquipRadarService
{
    @Autowired
    private ArdEquipRadarMapper ardEquipRadarMapper;


    @Resource
    NettyTcpClient nettyTcpClient;
    @Value("${spring.netty.tcp.enabled}")
    private Boolean tcpClientEnable;
    @PostConstruct
    public void init() {
        if(!tcpClientEnable)
        {
            return;
        }
        List<ArdEquipRadar> ardEquipRadars = selectArdEquipRadarList(new ArdEquipRadar());
        for (ArdEquipRadar ardEquipRadar:ardEquipRadars)
        {
            String host = ardEquipRadar.getIp();
            Integer port = Integer.valueOf(ardEquipRadar.getPort());
            log.info("TCP客户端尝试连接："+host+":"+port);
            nettyTcpClient.init(ardEquipRadar);
        }
    }

    /**
     * 查询radar