Prechádzať zdrojové kódy

增加滚动报警接口

chenwen 1 rok pred
rodič
commit
28f4dca616

+ 20 - 0
src/main/java/com/hb/proj/balarm/controller/AlarmLogController.java

@@ -1,8 +1,11 @@
 package com.hb.proj.balarm.controller;
 
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
+import java.util.Set;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.HashOperations;
@@ -77,5 +80,22 @@ public class AlarmLogController {
 		return RespVOBuilder.ok(rtnMap);
 	}
 	
+	/**
+	 * 加载所有实时报警记录
+	 * @return
+	 */
+	@RequestMapping("/loadAllRtAlarms")
+	public RespVO<Object>  loadAllRtAlarms(){
+		Set<Object> wells=redisTemplate.opsForSet().members("alarm_well_set");
+		if(wells==null||wells.size()==0) {
+			return RespVOBuilder.ok();
+		}
+		HashOperations<String, String, Object>  ops=redisTemplate.opsForHash();
+		List<Map<String,Object>> alarms=new ArrayList<>(wells.size());
+		for(Object wid : wells) {
+			alarms.add(ops.entries("alarm_"+wid));
+		}
+		return RespVOBuilder.ok(alarms);
+	}
 	
 }