package com.ard.alarm.radar.service.impl; import java.util.List; 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业务层处理 * * @author zj * @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 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 * * @param id radar主键 * @return radar */ @Override public ArdEquipRadar selectArdEquipRadarById(String id) { return ardEquipRadarMapper.selectArdEquipRadarById(id); } /** * 查询radar列表 * * @param ardEquipRadar radar * @return radar */ @Override public List selectArdEquipRadarList(ArdEquipRadar ardEquipRadar) { return ardEquipRadarMapper.selectArdEquipRadarList(ardEquipRadar); } /** * 新增radar * * @param ardEquipRadar radar * @return 结果 */ @Override public int insertArdEquipRadar(ArdEquipRadar ardEquipRadar) { return ardEquipRadarMapper.insertArdEquipRadar(ardEquipRadar); } /** * 修改radar * * @param ardEquipRadar radar * @return 结果 */ @Override public int updateArdEquipRadar(ArdEquipRadar ardEquipRadar) { return ardEquipRadarMapper.updateArdEquipRadar(ardEquipRadar); } /** * 批量删除radar * * @param ids 需要删除的radar主键 * @return 结果 */ @Override public int deleteArdEquipRadarByIds(String[] ids) { return ardEquipRadarMapper.deleteArdEquipRadarByIds(ids); } /** * 删除radar信息 * * @param id radar主键 * @return 结果 */ @Override public int deleteArdEquipRadarById(String id) { return ardEquipRadarMapper.deleteArdEquipRadarById(id); } }