|
|
@@ -20,6 +20,7 @@ import com.yunfeiyun.agmp.iotm.web.domain.resvo.IotWarnconfigInfoResVo;
|
|
|
import com.yunfeiyun.agmp.iotm.web.domain.resvo.IotWarnconfigResVo;
|
|
|
import com.yunfeiyun.agmp.iotm.web.mapper.*;
|
|
|
import com.yunfeiyun.agmp.iotm.web.service.IIotWarnconfigService;
|
|
|
+import com.yunfeiyun.agmp.iotm.web.service.IIotWarnindicatorService;
|
|
|
import org.apache.commons.collections4.CollectionUtils;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
@@ -53,6 +54,8 @@ public class IotWarnconfigServiceImpl implements IIotWarnconfigService {
|
|
|
private RedisCacheManager redisCacheManager;
|
|
|
@Resource
|
|
|
private IotWarncountMapper iotWarncountMapper;
|
|
|
+ @Resource
|
|
|
+ private IIotWarnindicatorService iotWarnindicatorService;
|
|
|
|
|
|
/**
|
|
|
* 查询告警配置
|
|
|
@@ -250,10 +253,25 @@ public class IotWarnconfigServiceImpl implements IIotWarnconfigService {
|
|
|
IotWarnindicator iotWarnindicatorQuery = new IotWarnindicator();
|
|
|
iotWarnindicatorQuery.setWcBid(wcBid);
|
|
|
iotWarnindicatorQuery.setTid(SecurityUtils.getTid());
|
|
|
+ // 获取已经配置的设备要素
|
|
|
List<IotWarnindicator> iotWarnindicatorList = iotWarnindicatorMapper.selectIotWarnindicatorList(iotWarnindicatorQuery);
|
|
|
+ Set<String> wiCodeSet = new HashSet<>();
|
|
|
+ if(iotWarnobjectList.size() ==1){
|
|
|
+ IotDevice deviceQuery = new IotDevice();
|
|
|
+ deviceQuery.setDevBid(iotWarnobjectList.get(0).getDevBid());
|
|
|
+ deviceQuery.setDevtypeBid(iotWarnconfig.getDevtypeBid());
|
|
|
+ List<IotWarnindicator> devNowWarnIndicator = iotWarnindicatorService.warnindicatorDevQuery(deviceQuery);
|
|
|
+ wiCodeSet.addAll(devNowWarnIndicator.stream().map(IotWarnindicator::getWiCode).collect(Collectors.toList()));
|
|
|
+ }
|
|
|
+ List<IotWarnindicator> resultIotWarnIndicatorList = new ArrayList<>();
|
|
|
+ for(IotWarnindicator iotWarnindicator : iotWarnindicatorList){
|
|
|
+ if(wiCodeSet.contains(iotWarnindicator.getWiCode())){
|
|
|
+ resultIotWarnIndicatorList.add(iotWarnindicator);
|
|
|
+ }
|
|
|
+ }
|
|
|
IotWarnconfigInfoResVo iotWarnconfigInfoResVo = new IotWarnconfigInfoResVo();
|
|
|
BeanUtils.copyProperties(iotWarnconfig,iotWarnconfigInfoResVo);
|
|
|
- iotWarnconfigInfoResVo.setIotWarnindicatorList(iotWarnindicatorList);
|
|
|
+ iotWarnconfigInfoResVo.setIotWarnindicatorList(resultIotWarnIndicatorList);
|
|
|
iotWarnconfigInfoResVo.setIotWarnobjectList(iotWarnobjectList);
|
|
|
return iotWarnconfigInfoResVo;
|
|
|
}
|