|
@@ -3,6 +3,7 @@ package com.gyee.wisdom.alarm.sharding.service;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
|
+import com.gyee.wisdom.alarm.sharding.cache.DataDictionaryCache;
|
|
import com.gyee.wisdom.alarm.sharding.cache.WindturbineCache;
|
|
import com.gyee.wisdom.alarm.sharding.cache.WindturbineCache;
|
|
import com.gyee.wisdom.alarm.sharding.entity.*;
|
|
import com.gyee.wisdom.alarm.sharding.entity.*;
|
|
import com.gyee.wisdom.alarm.sharding.mapper.AlarmCountMapper;
|
|
import com.gyee.wisdom.alarm.sharding.mapper.AlarmCountMapper;
|
|
@@ -10,6 +11,7 @@ import com.gyee.wisdom.alarm.sharding.mapper.AlarmHisotryMapper;
|
|
import com.gyee.wisdom.alarm.sharding.model.AlarmCountStat;
|
|
import com.gyee.wisdom.alarm.sharding.model.AlarmCountStat;
|
|
import com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo;
|
|
import com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo;
|
|
import com.gyee.wisdom.alarm.sharding.model.CodeValue;
|
|
import com.gyee.wisdom.alarm.sharding.model.CodeValue;
|
|
|
|
+import com.gyee.wisdom.alarm.sharding.model.HiddeDanger;
|
|
import com.gyee.wisdom.alarm.sharding.util.ResponseWrapper;
|
|
import com.gyee.wisdom.alarm.sharding.util.ResponseWrapper;
|
|
import com.gyee.wisdom.alarm.sharding.util.SnowflakeGenerator;
|
|
import com.gyee.wisdom.alarm.sharding.util.SnowflakeGenerator;
|
|
import com.gyee.wisdom.common.utils.DateUtil;
|
|
import com.gyee.wisdom.common.utils.DateUtil;
|
|
@@ -79,10 +81,10 @@ public class AlarmCountService extends ServiceImpl<AlarmCountMapper, AlarmCount>
|
|
return list;
|
|
return list;
|
|
}
|
|
}
|
|
|
|
|
|
- public Map<String,Double> hiddeDanger(){
|
|
|
|
|
|
+ public List<HiddeDanger> hiddeDanger(){
|
|
try {
|
|
try {
|
|
List<Integer> list = getEdnValue();
|
|
List<Integer> list = getEdnValue();
|
|
- Map<String,Double> doubleMap =new HashMap<>();
|
|
|
|
|
|
+ List<HiddeDanger> hiddeDangerList =new ArrayList<>();
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
|
String strDate = sdf.format(DateUtil.addDays(new Date(),-1));
|
|
String strDate = sdf.format(DateUtil.addDays(new Date(),-1));
|
|
Date dtStart = sdf.parse(strDate);
|
|
Date dtStart = sdf.parse(strDate);
|
|
@@ -100,14 +102,21 @@ public class AlarmCountService extends ServiceImpl<AlarmCountMapper, AlarmCount>
|
|
Map<String,List<AlarmStat>> map = alarmStatList.stream().collect(Collectors.groupingBy(AlarmStat::getParts));
|
|
Map<String,List<AlarmStat>> map = alarmStatList.stream().collect(Collectors.groupingBy(AlarmStat::getParts));
|
|
for (Map.Entry<String,List<AlarmStat>> stringListMap : map.entrySet()){
|
|
for (Map.Entry<String,List<AlarmStat>> stringListMap : map.entrySet()){
|
|
double time = 0;
|
|
double time = 0;
|
|
|
|
+ int count = 0;
|
|
for (AlarmStat alarmStat : stringListMap.getValue()){
|
|
for (AlarmStat alarmStat : stringListMap.getValue()){
|
|
if (alarmStat != null){
|
|
if (alarmStat != null){
|
|
time = time + alarmStat.getTimes();
|
|
time = time + alarmStat.getTimes();
|
|
|
|
+ count = count + alarmStat.getSum();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- doubleMap.put(stringListMap.getKey(),time);
|
|
|
|
|
|
+ HiddeDanger hiddeDanger = new HiddeDanger();
|
|
|
|
+ hiddeDanger.setCode(stringListMap.getKey());
|
|
|
|
+ hiddeDanger.setCodeName(DataDictionaryCache.getPartName(stringListMap.getKey()));
|
|
|
|
+ hiddeDanger.setCount(count);
|
|
|
|
+ hiddeDanger.setTime(time);
|
|
|
|
+ hiddeDangerList.add(hiddeDanger);
|
|
}
|
|
}
|
|
- return doubleMap;
|
|
|
|
|
|
+ return hiddeDangerList;
|
|
}catch (Exception ex) {
|
|
}catch (Exception ex) {
|
|
log.error(ex.getMessage());
|
|
log.error(ex.getMessage());
|
|
log.error(ex.getStackTrace().toString());
|
|
log.error(ex.getStackTrace().toString());
|