From 51471bec619d614a12bd2b2a367d9fb7c0e8a62b Mon Sep 17 00:00:00 2001
From: yang_shj <1069818635@QQ.com>
Date: Fri, 8 Sep 2023 11:54:32 +0800
Subject: [PATCH] =?UTF-8?q?#=E5=91=8A=E8=AD=A6=E3=80=81=E7=8F=AD=E7=BB=84?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AEbug=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../operation/business/impl/DutyServiceImpl.java   | 14 ++++++
 .../operation/home/impl/ShowServiceImpl.java       |  4 +-
 .../service/operation/monitor/MonitorService.java  |  4 --
 .../operation/monitor/impl/MonitorServiceImpl.java | 27 ++++++++++-
 .../main/resources/mapper/operation/DutyMapper.xml |  2 +-
 .../impl/HistoryAbnormalAlarmServiceImpl.java      | 54 +++++++++++++---------
 6 files changed, 76 insertions(+), 29 deletions(-)

diff --git a/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/business/impl/DutyServiceImpl.java b/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/business/impl/DutyServiceImpl.java
index 7fe1682..0a2983c 100644
--- a/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/business/impl/DutyServiceImpl.java
+++ b/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/business/impl/DutyServiceImpl.java
@@ -171,6 +171,20 @@ public class DutyServiceImpl extends BaseServiceImpl<DutyMapper, ImsDutyMainEnti
             dutyMainInfoVo.setDutyGroupId(imsDutyGroupEntity.getId());
             dutyMainInfoVo.setManagerId(imsDutyGroupEntity.getManagerId().toString());
         }
+        if (ObjectUtil.isEmpty(dutyMainInfoVo)) {
+            return null;
+        }
+        // 赋值
+        dutyMainInfoVo.setClassName(dutyMainInfoVo.getClassName());
+        dutyMainInfoVo.setDateTime(dutyMainInfoVo.getDateTime());
+        dutyMainInfoVo.setStartTime(dutyMainInfoVo.getStartTime());
+        dutyMainInfoVo.setEndTime(dutyMainInfoVo.getEndTime());
+        // 负责人
+        User user = UserCache.getUser(Long.valueOf(dutyMainInfoVo.getManagerId()));
+        if (ObjectUtil.isNotEmpty(user)) {
+            dutyMainInfoVo.setManagerName(user.getName());
+            dutyMainInfoVo.setManagerPhone(user.getPhone());
+        }
         return dutyMainInfoVo;
     }
 }
\ No newline at end of file
diff --git a/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/home/impl/ShowServiceImpl.java b/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/home/impl/ShowServiceImpl.java
index 28429fb..6bbffe2 100644
--- a/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/home/impl/ShowServiceImpl.java
+++ b/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/home/impl/ShowServiceImpl.java
@@ -1265,7 +1265,7 @@ public class ShowServiceImpl implements ShowService {
             if(CollectionUtil.isEmpty(points)){
                 return "0";
             }
-            String realId = points.get(HomePageConstant.JOINT_RELAY);
+            String realId = points.get(HomePageConstant.ACTIVE_POWER);
             if(StringUtil.isEmpty(realId)){
                 return "0";
             }
@@ -1276,7 +1276,7 @@ public class ShowServiceImpl implements ShowService {
             if(StringUtil.isEmpty(value)){
                 return  "0";
             }
-            if (value.contains("1") || "1.0".equals(value)) {
+            if (Math.abs(Double.parseDouble(value)) > 0) {
                 return o.getEmCode();
             }
             return "0";
diff --git a/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/monitor/MonitorService.java b/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/monitor/MonitorService.java
index f99ee9e..dcfaae7 100644
--- a/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/monitor/MonitorService.java
+++ b/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/monitor/MonitorService.java
@@ -1,9 +1,5 @@
 package com.hnac.hzims.scheduled.service.operation.monitor;
 
-import org.springblade.core.tool.api.R;
-
-import java.util.Map;
-
 /**
  * WEB水电站首页接口
  * @author ysj
diff --git a/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/monitor/impl/MonitorServiceImpl.java b/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/monitor/impl/MonitorServiceImpl.java
index f50b250..bef56af 100644
--- a/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/monitor/impl/MonitorServiceImpl.java
+++ b/hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/monitor/impl/MonitorServiceImpl.java
@@ -149,7 +149,7 @@ public class MonitorServiceImpl implements MonitorService {
     @Override
     public void loadRealData(String param) {
         // 获取设备
-        List<EminfoAndEmParamVo> devices = JSONObject.parseObject(redisTemplate.opsForValue().get(device_cache_final).toString(),new TypeReference<List<EminfoAndEmParamVo>>() {});;
+        List<EminfoAndEmParamVo> devices = JSONObject.parseObject(redisTemplate.opsForValue().get(device_cache_final).toString(),new TypeReference<List<EminfoAndEmParamVo>>() {});
         // 设备开关机集合监测点
         List<String> switchOnOff = devices.stream().map(o->{
             Map<String,String> points = o.getPoint();
@@ -328,6 +328,8 @@ public class MonitorServiceImpl implements MonitorService {
                     });
                     // 设备状态
                     this.getDeviceParam(devices, deviceClassifyMap, deviceList);
+                    // 运行设备状态设置
+                    this.deviceState(deviceList);
                     station.setDeviceList(deviceList.stream().sorted(Comparator.comparing((RealDeviceVo::getDeviceName))).collect(Collectors.toList()));
                     stationList.add(station);
                 });
@@ -384,6 +386,29 @@ public class MonitorServiceImpl implements MonitorService {
     }
 
     /**
+     * 设备状态
+     * @param deviceList
+     */
+    private void deviceState(List<RealDeviceVo> deviceList) {
+        deviceList.forEach(device->{
+            // 设备属性列表
+            List<RealAttributeVo> attbts = device.getAttbtList();
+            if(CollectionUtil.isEmpty(attbts)){
+                return;
+            }
+            // 功率属性记录
+            List<RealAttributeVo> powers = attbts.stream().filter(att-> HomePageConstant.powerList.contains(att.getName())).collect(Collectors.toList());
+            if(CollectionUtil.isEmpty(powers)){
+                return;
+            }
+            if("0.000000".equals(powers.get(0).getValue()) || "-".equals(powers.get(0).getValue()) || HomePageConstant.ON.equals(powers.get(0).getValue())){
+                return;
+            }
+            device.setState(1);
+        });
+    }
+
+    /**
      * 获取站点属性
      * @param stationEntityList
      * @param item
diff --git a/hzims-service/hzims-scheduled/src/main/resources/mapper/operation/DutyMapper.xml b/hzims-service/hzims-scheduled/src/main/resources/mapper/operation/DutyMapper.xml
index 6efe983..e93f2cc 100644
--- a/hzims-service/hzims-scheduled/src/main/resources/mapper/operation/DutyMapper.xml
+++ b/hzims-service/hzims-scheduled/src/main/resources/mapper/operation/DutyMapper.xml
@@ -23,7 +23,7 @@
         limit 1;
     </select>
     <select id="selectDuty" resultType="com.hnac.hzims.operational.duty.vo.DutyMainInfoVo">
-        SELECT DM.*, DC.`CLASS_NAME` as managerId, DC.`START_TIME`, DC.`END_TIME`
+        SELECT DM.*, DC.`CLASS_NAME`, DC.`START_TIME`, DC.`END_TIME`
         FROM hz_ims_duty_main DM
         JOIN hz_ims_duty_class DC
          ON DM.`CLASS_ID` = DC.`ID`
diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/impl/HistoryAbnormalAlarmServiceImpl.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/impl/HistoryAbnormalAlarmServiceImpl.java
index 151beb8..e02cfe7 100644
--- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/impl/HistoryAbnormalAlarmServiceImpl.java
+++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/impl/HistoryAbnormalAlarmServiceImpl.java
@@ -30,10 +30,13 @@ import net.logstash.logback.encoder.org.apache.commons.lang3.StringUtils;
 import org.springblade.core.mp.base.BaseServiceImpl;
 import org.springblade.core.mp.support.Condition;
 import org.springblade.core.mp.support.Query;
+import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.BeanUtil;
 import org.springblade.core.tool.utils.CollectionUtil;
 import org.springblade.core.tool.utils.DateUtil;
 import org.springblade.core.tool.utils.ObjectUtil;
+import org.springblade.system.entity.Dept;
+import org.springblade.system.feign.ISysClient;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
@@ -59,9 +62,9 @@ public class HistoryAbnormalAlarmServiceImpl extends BaseServiceImpl<HistoryAbno
 
 	private final AlarmHandleService handleService;
 
-	private final ISoeClient alarmClient;
+	private final ISysClient sysClient;
 
-	private final RedisTemplate redisTemplate;
+	private final ISoeClient alarmClient;
 
 	@Value("${hzims.operation.alarm.types}")
 	private String types;
@@ -213,16 +216,16 @@ public class HistoryAbnormalAlarmServiceImpl extends BaseServiceImpl<HistoryAbno
 	 */
 	@Override
 	public AlarmReustVo alarms(AlarmParamVo param) {
-		AlarmReustVo alarmReustVo = (AlarmReustVo) redisTemplate.opsForValue().get(param.getType() + param.getSize() + param.getCurrent());
-		if(ObjectUtil.isNotEmpty(alarmReustVo)){
-			return alarmReustVo;
+		// 查询用户权限机构
+		R<List<Dept>> result = sysClient.getDeptByCurrentUser();
+		if(!result.isSuccess() || CollectionUtil.isEmpty(result.getData())){
+			return new AlarmReustVo();
 		}
 		// 查询站点
 		LambdaQueryWrapper<StationEntity> wrapper = Wrappers.lambdaQuery();
 		wrapper.eq(StationEntity::getServeType,HomePageConstant.HYDROPOWER_SERVETYPE);
-		if(StringUtils.isNotEmpty(param.getCode())){
-			wrapper.eq(StationEntity::getCode,param.getCode());
-		}
+		wrapper.in(StationEntity::getRefDept,result.getData().stream().map(Dept::getId).collect(Collectors.toList()));
+
 		List<StationEntity> stations = stationService.list(wrapper);
 		if(CollectionUtil.isEmpty(stations)){
 			return new AlarmReustVo();
@@ -237,8 +240,8 @@ public class HistoryAbnormalAlarmServiceImpl extends BaseServiceImpl<HistoryAbno
 		condition.setStationIds(stations.stream().map(StationEntity::getCode).collect(Collectors.toList()));
 		List<String> types = Arrays.asList(param.getType().split(","));
 		condition.setTypes(types);
-		Result<HzPage<SoeData>>  result = alarmClient.getByStationsAndTime(condition);
-		if(!result.isSuccess() || ObjectUtil.isEmpty(result.getData()) || CollectionUtil.isEmpty(result.getData().getRecords())){
+		Result<HzPage<SoeData>>  soe = alarmClient.getByStationsAndTime(condition);
+		if(!soe.isSuccess() || ObjectUtil.isEmpty(soe.getData()) || CollectionUtil.isEmpty(soe.getData().getRecords())){
 			return new AlarmReustVo();
 		}
 
@@ -247,7 +250,7 @@ public class HistoryAbnormalAlarmServiceImpl extends BaseServiceImpl<HistoryAbno
 
 		// 返回数据
 		AlarmReustVo response = new AlarmReustVo();
-		List<AlarmDataVo> datas = result.getData().getRecords().stream().map(alarm -> {
+		List<AlarmDataVo> datas = soe.getData().getRecords().stream().map(alarm -> {
 			AlarmDataVo record = new AlarmDataVo();
 			// 继承类属性拷贝
 			BeanUtil.copyProperties(alarm, record);
@@ -271,10 +274,9 @@ public class HistoryAbnormalAlarmServiceImpl extends BaseServiceImpl<HistoryAbno
 		}).sorted(Comparator.comparing(AlarmDataVo::getIsHandle)
 				.thenComparing(AlarmDataVo::getTs, Comparator.reverseOrder())).collect(Collectors.toList());
 
-		response.setCount((int) (result.getData().getTotal() - handles.size()));
+		response.setCount((int) (soe.getData().getTotal() - handles.size()));
 		response.setSoeList(datas);
-		response.setTotal(result.getData().getTotal());
-		redisTemplate.opsForValue().set(param.getType() + param.getSize() + param.getCurrent(),response,1, TimeUnit.MINUTES);
+		response.setTotal(soe.getData().getTotal());
 		return response;
 	}
 
@@ -298,20 +300,30 @@ public class HistoryAbnormalAlarmServiceImpl extends BaseServiceImpl<HistoryAbno
 	 */
 	@Override
 	public List<IntelligentAlarmCountVo> alarmCount() {
+		// 查询用户权限机构
+		R<List<Dept>> result = sysClient.getDeptByCurrentUser();
+		if(!result.isSuccess() || CollectionUtil.isEmpty(result.getData())){
+			return new ArrayList<>();
+		}
 		// 步骤1.查询用户权限站点
-		List<StationEntity> stations = stationService.list();
+		LambdaQueryWrapper<StationEntity> wrapper = Wrappers.lambdaQuery();
+		wrapper.eq(StationEntity::getServeType,HomePageConstant.HYDROPOWER_SERVETYPE);
+		wrapper.in(StationEntity::getRefDept,result.getData().stream().map(Dept::getId).collect(Collectors.toList()));
 
+		List<StationEntity> stations = stationService.list(wrapper);
+		if(CollectionUtil.isEmpty(stations)){
+			return new ArrayList<>();
+		}
 		// 步骤2.查询告警数据
 		SoeQueryConditionByStation condition = new SoeQueryConditionByStation();
-		DateTimeFormatter format = DateTimeFormatter.ofPattern(DateUtil.PATTERN_DATETIME);
-		condition.setBeginTime(LocalDateTime.parse(/*DateUtil.format(new Date(), DateUtil.PATTERN_DATE) +*/ "2022-12-01 00:00:00", format));
-		condition.setEndTime(LocalDateTime.parse(/*DateUtil.format(new Date(), DateUtil.PATTERN_DATE) +*/ "2022-12-28 00:00:00", format));
+		condition.setBeginTime(LocalDateTime.parse(DateUtil.format(new Date(),DateUtil.PATTERN_DATE) + " 00:00:00", DateUtil.DATETIME_FORMATTER));
+		condition.setEndTime(LocalDateTime.now());
 		condition.setNeedPage(false);
 		condition.setStationIds(stations.stream().map(StationEntity::getCode).filter(StringUtils::isNotEmpty).collect(Collectors.toList()));
 		// nacos中配置告警类型："0-默认", "1-系统", "2-告警", "3-故障", "4-用户操作", "5-遥测越限", "6-遥信变位", "7-注册信息",
 		// "8-信息提示", "9-设备巡检", "10-遥控操作", "11-遥测越限恢复","12-未定义","13-通讯中断","14-数据异常"
 		condition.setTypes(Arrays.asList(types.split(",")));
-		Result<HzPage<SoeData>> result = alarmClient.getByStationsAndTime(condition);
+		Result<HzPage<SoeData>> soe = alarmClient.getByStationsAndTime(condition);
 
 		// 步骤3. TODO 过滤已处理告警
 
@@ -320,8 +332,8 @@ public class HistoryAbnormalAlarmServiceImpl extends BaseServiceImpl<HistoryAbno
 			IntelligentAlarmCountVo count = new IntelligentAlarmCountVo();
 			count.setType(type);
 			count.setName(AbnormalAlarmConstant.TYPE_NAMES[Integer.parseInt(type)]);
-			if(result.isSuccess() && !ObjectUtil.isEmpty(result.getData())){
-				count.setCount(result.getData().getRecords().stream().filter(record->type.equals(record.getSoeType())).count());
+			if(soe.isSuccess() && !ObjectUtil.isEmpty(soe.getData())){
+				count.setCount(soe.getData().getRecords().stream().filter(record->type.equals(record.getSoeType())).count());
 			}else {
 				count.setCount(0L);
 			}