|
|
|
|
@ -6,11 +6,9 @@ import com.hnac.hzims.message.fegin.IMessageClient;
|
|
|
|
|
import com.hnac.hzims.operational.alert.constants.AbnormalAlarmConstant; |
|
|
|
|
import com.hnac.hzims.operational.alert.entity.AbnormalAlarmEntity; |
|
|
|
|
import com.hnac.hzims.operational.alert.entity.HistoryAbnormalAlarmEntity; |
|
|
|
|
import com.hnac.hzims.operational.alert.entity.HistoryLevelAlarmEntity; |
|
|
|
|
import com.hnac.hzims.operational.alert.mapper.AbnormalAlarmMapper; |
|
|
|
|
import com.hnac.hzims.operational.alert.service.AbnormalAlarmService; |
|
|
|
|
import com.hnac.hzims.operational.alert.service.HistoryAbnormalAlarmService; |
|
|
|
|
import com.hnac.hzims.operational.main.constant.HomePageConstant; |
|
|
|
|
import com.hnac.hzims.operational.station.entity.StationEntity; |
|
|
|
|
import com.hnac.hzims.operational.station.service.IStationService; |
|
|
|
|
import com.hnac.hzinfo.datasearch.soe.ISoeClient; |
|
|
|
|
@ -18,7 +16,6 @@ import com.hnac.hzinfo.datasearch.soe.domian.SoeData;
|
|
|
|
|
import com.hnac.hzinfo.datasearch.soe.domian.SoeQueryConditionByStation; |
|
|
|
|
import com.hnac.hzinfo.sdk.core.response.HzPage; |
|
|
|
|
import com.hnac.hzinfo.sdk.core.response.Result; |
|
|
|
|
|
|
|
|
|
import lombok.RequiredArgsConstructor; |
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
|
import org.springblade.core.mp.base.BaseServiceImpl; |
|
|
|
|
@ -33,7 +30,6 @@ import org.springblade.system.user.feign.IUserClient;
|
|
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
|
|
import java.time.LocalDateTime; |
|
|
|
|
import java.time.format.DateTimeFormatter; |
|
|
|
|
import java.util.*; |
|
|
|
|
import java.util.concurrent.CompletableFuture; |
|
|
|
|
import java.util.function.Function; |
|
|
|
|
@ -67,7 +63,7 @@ public class AbnormalAlarmServiceImpl extends BaseServiceImpl<AbnormalAlarmMappe
|
|
|
|
|
@Override |
|
|
|
|
public void alarmDataHandle(String param) { |
|
|
|
|
// 查询代运维站点
|
|
|
|
|
List<StationEntity> stations = stationService.getStationByType(null,HomePageConstant.HYDROPOWER_SERVETYPE); |
|
|
|
|
List<StationEntity> stations = stationService.list(); |
|
|
|
|
if(CollectionUtil.isEmpty(stations)){ |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
|
