From e4b75d402e8cb84a70e2f84f4e19f566ffd38d85 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期三, 14 六月 2023 10:50:07 +0800
Subject: [PATCH] 优化
---
ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/GlobalAlarmServiceImpl.java | 86 +++++++++++++++++++++++++++++++++++++-----
1 files changed, 75 insertions(+), 11 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/GlobalAlarmServiceImpl.java b/ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/GlobalAlarmServiceImpl.java
index 55ace11..8fafe2e 100644
--- a/ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/GlobalAlarmServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/GlobalAlarmServiceImpl.java
@@ -13,6 +13,8 @@
import com.ruoyi.alarmpoints.tube.domain.ArdTubesDetails;
import com.ruoyi.alarmpoints.tube.mapper.ArdTubesDetailsMapper;
import com.ruoyi.alarmpoints.tube.mapper.ArdTubesMapper;
+import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;
+import com.ruoyi.alarmpoints.well.mapper.ArdAlarmpointsWellMapper;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.uuid.UUID;
@@ -26,9 +28,7 @@
import javax.annotation.Resource;
import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
import java.util.stream.Collectors;
import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;
@@ -46,9 +46,11 @@
@Resource
ArdAlarmStealelecMapper ardAlarmStealelecMapper;
@Resource
- IArdAlarmTubeService ardAlarmTubeService;
+ ArdAlarmTubeMapper ardAlarmTubeMapper;
@Resource
ArdTubesMapper ardTubesMapper;
+ @Resource
+ ArdAlarmpointsWellMapper ardAlarmpointsWellMapper;
@Resource
ArdTubesDetailsMapper ardTubesDetailsMapper;
@Resource
@@ -59,7 +61,7 @@
String refreshTime = configService.selectConfigByKey("refreshTime");
switch (condition.getCommand()) {
case 1001:
- List<ArdAlarmStealelec> ardAlarmStealelecs = ardAlarmStealelecMapper.selectAllByCommandArdAlarmStealelecList(refreshTime);
+ List<ArdAlarmStealelec> ardAlarmStealelecs = ardAlarmStealelecMapper.selectListAllByCommand(refreshTime);
return ardAlarmStealelecs.stream()
.map(ardAlarmStealelec -> {
GlobalAlarmData globalAlarmData = new GlobalAlarmData()
@@ -74,6 +76,22 @@
return globalAlarmData;
})
.collect(Collectors.toList());
+ case 1014:
+ List<ArdAlarmTube> ardAlarmTubes = ardAlarmTubeMapper.selectListAllByCommand(refreshTime);
+ return ardAlarmTubes.stream()
+ .map(ardAlarmTube -> {
+ GlobalAlarmData globalAlarmData = new GlobalAlarmData()
+ .setId(ardAlarmTube.getId())
+ .setName(ardAlarmTube.getTubeName())
+ .setAlarmTime(ardAlarmTube.getAlarmTime())
+ .setLongitude(ardAlarmTube.getLongitude())
+ .setLatitude(ardAlarmTube.getLatitude())
+ .setAltitude(ardAlarmTube.getAltitude())
+ .setCount(ardAlarmTube.getCount())
+ .setTotal(ardAlarmTube.getTotal());
+ return globalAlarmData;
+ })
+ .collect(Collectors.toList());
default:
return null;
}
@@ -84,13 +102,20 @@
SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
switch (condition.getCommand()) {
case 1001:
- String id = condition.getId();
- ArdAlarmStealelec ardAlarmStealelec = ardAlarmStealelecMapper.selectByPrimaryKey(id);
+ ArdAlarmStealelec ardAlarmStealelec = ardAlarmStealelecMapper.selectByPrimaryKey(condition.getId());
if(StringUtils.isNotNull(ardAlarmStealelec)) {
String describe = ardAlarmStealelec.getDescribe();
String startTime = fmt.format(ardAlarmStealelec.getStartTime());
int i = ardAlarmStealelecMapper.updateViewTimeByDescribe(describe, startTime, DateUtils.getTime());
return ardAlarmStealelec;
+ }
+ case 1014:
+ ArdAlarmTube ardAlarmTube = ardAlarmTubeMapper.selectArdAlarmTubeById(condition.getId());
+ if(StringUtils.isNotNull(ardAlarmTube)) {
+ String tubeId = ardAlarmTube.getTubeId();
+ String alarmTime = fmt.format(ardAlarmTube.getAlarmTime());
+ int i = ardAlarmTubeMapper.updateViewTimeByTubeId(tubeId, alarmTime, DateUtils.getTime());
+ return ardAlarmTube;
}
default: return null;
}
@@ -99,10 +124,31 @@
@Override
@Async("alarmExecutor")
public void receiveAlarm(String topic, String message) {
+ String uuid = UUID.randomUUID().toString().replace("-", "");
switch (topic) {
+ case "stealelec":
+ ArdAlarmStealelec ardAlarmStealelec = JSONObject.parseObject(message, ArdAlarmStealelec.class);
+ ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(ardAlarmStealelec.getDescribe());
+ if(well!=null)
+ {
+ ardAlarmStealelec.setLongitude(well.getLongitude());
+ ardAlarmStealelec.setLatitude(well.getLatitude());
+ ardAlarmStealelec.setDeptId(well.getDeptId());
+ }
+ ArdAlarmStealelec existe = ardAlarmStealelecMapper.selectByPrimaryKey(ardAlarmStealelec.getId());
+ if(StringUtils.isNotNull(existe))
+ {
+ return;
+ }
+ int aas = ardAlarmStealelecMapper.insert(ardAlarmStealelec);
+ if(aas>0)
+ {
+ log.info("stealelec鍏ュ簱鎴愬姛锛�" +ardAlarmStealelec);
+ }
+ break;
case "tube":
ArdAlarmTube ardAlarmTube = JSONObject.parseObject(message, ArdAlarmTube.class);
- ardAlarmTube.setId(UUID.randomUUID().toString().replace("-", ""));
+ ardAlarmTube.setId(uuid);
ArdTubesDetails atd = new ArdTubesDetails();
atd.setReelNumber(ardAlarmTube.getTubeId());
List<ArdTubesDetails> ardTubesDetails = ardTubesDetailsMapper.selectArdTubesDetailsList(atd);
@@ -120,11 +166,29 @@
ardAlarmTube.setAltitude(geoPoint.getAltitude());
}
}
- int i = ardAlarmTubeService.insertArdAlarmTube(ardAlarmTube);
- if (i > 0) {
- log.info("鍏ュ簱鎴愬姛锛�" + ardAlarmTube.toString());
+ int aat = ardAlarmTubeMapper.insertArdAlarmTube(ardAlarmTube);
+ if (aat > 0) {
+ log.info("tube鍏ュ簱鎴愬姛锛�" + ardAlarmTube);
}
break;
}
}
+ /**
+ * @鎻忚堪 鏌ヨ鎵�鏈夋姤璀︾殑褰撳墠鏁伴噺
+ * @鍙傛暟 []
+ * @杩斿洖鍊� java.util.Map<java.lang.String,java.lang.Integer>
+ * @鍒涘缓浜� 鍒樿嫃涔�
+ * @鍒涘缓鏃堕棿 2023/6/13 16:30
+ * @淇敼浜哄拰鍏跺畠淇℃伅
+ */
+ @Override
+ public Map<String, Integer> selectAlarmLogsCount() {
+ Map<String, Integer> countMap=new HashMap<>();
+ String refreshTime = configService.selectConfigByKey("refreshTime");
+ int count1001 = ardAlarmStealelecMapper.selectCountByStartTime(refreshTime);
+ countMap.put("1001",count1001);
+ int count1014 = ardAlarmTubeMapper.selectCountByStartTime(refreshTime);
+ countMap.put("1014 ",count1014);
+ return countMap;
+ }
}
--
Gitblit v1.9.3