From 6f2c07bbd6f50f1f9fe29bfa6fec5a6568897432 Mon Sep 17 00:00:00 2001
From: zengh <123456>
Date: Thu, 18 Mar 2021 10:43:01 +0800
Subject: [PATCH] 警情分发逻辑修改

---
 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/alarm/controller/AlarmController.java |   34 +++++++++++++++++++++++++++++++++-
 1 files changed, 33 insertions(+), 1 deletions(-)

diff --git a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/alarm/controller/AlarmController.java b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/alarm/controller/AlarmController.java
index 82e8aec..39d3519 100644
--- a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/alarm/controller/AlarmController.java
+++ b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/alarm/controller/AlarmController.java
@@ -163,7 +163,39 @@
 		if (alarm.getAlarmTime() != null && alarm.getAlarmTime().equals("")){
 			alarm.setAlarmTime(null);
 		}
-		return R.status(alarmService.saveOrUpdate(alarm));
+		if (alarm.getCid() != null && alarm.getCid().equals("")){
+			alarm.setCid("0");
+		}
+
+
+		//警情分发测试代码
+		//查询所有在线的接警员
+		List<Map<String, Object>> policeList = alarmService.queryPolice();
+		List<Map<String, Object>> online_police = new ArrayList<>();
+		for (int i = 0; i < policeList.size(); i++) {
+			if (policeList.get(i).get("work_status").equals(0)){
+				System.out.println(policeList.get(i).get("real_name"));
+				online_police.add(policeList.get(i));
+			}
+		}
+
+		int size = 0;
+		if (online_police.size() == 0){
+			online_police = policeList;
+			size = policeList.size();
+		}else {
+			size = online_police.size();
+		}
+
+		int num=(int)(Math.random()*(size));
+		String name = (String) online_police.get(num).get("real_name");
+		String id = (String) online_police.get(num).get("id");
+
+		alarm.setAlarmPeople(name);
+		alarm.setAlarmId(name);
+
+		return null;
+		//return R.status(alarmService.saveOrUpdate(alarm));
 	}
 
 

--
Gitblit v1.9.3