|
|
@ -114,7 +114,7 @@ public class StationServiceImpl extends BaseServiceImpl<StationMapper, StationEn |
|
|
|
StationPushConfigVO configVO = stationPushConfigService.getOne(BeanUtil.copy(config, StationPushConfigDTO.class)); |
|
|
|
StationPushConfigVO configVO = stationPushConfigService.getOne(BeanUtil.copy(config, StationPushConfigDTO.class)); |
|
|
|
if(ObjectUtil.isNotEmpty(configVO) && configVO.getIsPush()) { |
|
|
|
if(ObjectUtil.isNotEmpty(configVO) && configVO.getIsPush()) { |
|
|
|
log.info("{}站点开始智能诊断站点推送",req.getCode()); |
|
|
|
log.info("{}站点开始智能诊断站点推送",req.getCode()); |
|
|
|
new Thread(() -> questionClient.submitStationInfo(configVO.getFdpStationType(), req.getCode(), ""), "智能诊断站点推送").start(); |
|
|
|
new Thread(() -> questionClient.submitStationInfo(configVO.getFdpStationType(), req.getCode(), "运维平台推送"), "智能诊断站点推送").start(); |
|
|
|
} |
|
|
|
} |
|
|
|
// 如果设备数据来源未选定其他 则进行站点初始化操作
|
|
|
|
// 如果设备数据来源未选定其他 则进行站点初始化操作
|
|
|
|
if (StationConstants.GATHER.equals(req.getDataOrigin()) && !StationConstants.HZ3000_OTHER.equals(req.getDataSource())) { |
|
|
|
if (StationConstants.GATHER.equals(req.getDataOrigin()) && !StationConstants.HZ3000_OTHER.equals(req.getDataSource())) { |
|
|
|