From fa9ffa9012d7b1df7692bb99e71be6592f48cd4b Mon Sep 17 00:00:00 2001
From: zengh <123456>
Date: Wed, 10 Mar 2021 14:00:19 +0800
Subject: [PATCH] 修改报警器端口

---
 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/controller/EquipmentController.java |  103 ++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 84 insertions(+), 19 deletions(-)

diff --git a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/controller/EquipmentController.java b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/controller/EquipmentController.java
index 4d428c8..839243f 100644
--- a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/controller/EquipmentController.java
+++ b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/controller/EquipmentController.java
@@ -88,6 +88,37 @@
 	}
 
 	/**
+	 * 查询所有
+	 */
+	@GetMapping("/listAll")
+	@ApiOperationSupport(order = 2)
+	@ApiOperation(value = "分页", notes = "传入equipment")
+	public R<List<EquipmentVO>> listAll(Equipment equipment, Query query) throws ParseException {
+		List<EquipmentVO> pages = equipmentService.listAll();
+
+		for (int j = 0; j < pages.size(); j++) {
+			String expireTime = pages.get(j).getExpireTime();
+			//1.获取当前时间
+			Date dd = new Date();
+			SimpleDateFormat sim = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			String end = sim.format(dd);
+			//把string类型转换为long类型的
+			long st = sim.parse(expireTime).getTime();
+			long en = sim.parse(end).getTime();
+			//计算天数
+			int day = (int) ((st - en) / 86400000);
+			if (day <= 30) {
+				pages.get(j).setType(1);
+			} else {
+				pages.get(j).setType(0);
+			}
+		}
+
+
+		return R.data(pages);
+	}
+
+	/**
 	 * 自定义分页
 	 */
 	@GetMapping("/pages")
@@ -98,17 +129,50 @@
 		response.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE");
 		response.setHeader("Access-Control-Allow-Credentials", "true");
 
-		List<Map<String, Object>> treedatas = catalogService.selectCatalogEqNUmber(pid);
-		//根据传入的id递归出该节点下所有的设备
-		List<Map<String, Object>> childList = treeIdList(treedatas, pid);
+		IPage<EquipmentVO> page = null;
+		//清空全局参数
+		childMenu = new ArrayList();
 
+		if (pid == null || pid.equals("")) {
+			//根据查询条件得到所有设备
+			page = equipmentService.selectEquipmentPage(Condition.getPage(query), equipment, null);
+		} else {
+			List<Map<String, Object>> treedatas = catalogService.selectCatalogEqNUmber();
+			//根据传入的id递归出该节点下所有的设备
+			List<Map<String, Object>> childList = treeIdList(treedatas, pid);
 
-		System.out.println(childList);
+			if (childList.size() > 0) {
+				//根据查询条件得到所有设备
+				page = equipmentService.selectEquipmentPage(Condition.getPage(query), equipment, childList);
+			} else {
+				page = null;
+			}
+		}
 
+		if (page != null){
+			for (int j = 0; j < page.getRecords().size(); j++) {
+				String expireTime = page.getRecords().get(j).getExpireTime();
+				//1.获取当前时间
+				Date dd = new Date();
+				SimpleDateFormat sim = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+				String end = sim.format(dd);
+				//把string类型转换为long类型的
 
+				if (expireTime != null){
+					long st = sim.parse(expireTime).getTime();
+					long en = sim.parse(end).getTime();
+					//计算天数
+					int day = (int) ((st - en) / 86400000);
+					if (day <= 30) {
+						page.getRecords().get(j).setType(1);
+					} else {
+						page.getRecords().get(j).setType(0);
+					}
+				}
+			}
+		}
 
-
-		return R.data(null);
+		return R.data(page);
 	}
 
 	/**
@@ -126,11 +190,10 @@
 		childMenu = new ArrayList();
 
 		//根据查询条件得到所有设备
-		IPage<EquipmentVO> pageData = equipmentService.selectEquipmentPage(Condition.getPage(query), equipment);
+		IPage<EquipmentVO> pageData = equipmentService.selectEquipmentPage(Condition.getPage(query), equipment, null);
 
 		List<EquipmentVO> pages = pageData.getRecords();
 		List<EquipmentVO> datas = new ArrayList();
-
 
 
 		if (pid == null || pid.equals("")) {
@@ -153,7 +216,7 @@
 			}
 			datas = pages;
 		} else {
-			List<Map<String, Object>> treedatas = catalogService.selectCatalogEqNUmber(pid);
+			List<Map<String, Object>> treedatas = catalogService.selectCatalogEqNUmber();
 			//根据传入的id递归出该节点下所有的设备
 			List<Map<String, Object>> childList = treeMenuList(treedatas, pid);
 			//将得到的设备与查询所得设备进行匹配
@@ -175,7 +238,7 @@
 						pages.get(j).setType(0);
 					}
 
-					if (childList.get(i).get("eqid") != null) {
+					if (childList.get(i).get("eqid") != null && !childList.get(i).get("eqid").equals("")) {
 						if (childList.get(i).get("eqid").equals(pages.get(j).getDeviceNumber())) {
 							datas.add(pages.get(j));
 						}
@@ -197,9 +260,9 @@
 			//遍历出父id等于参数的id,add进子节点集合
 
 			if (!pid.equals(0)) {
-				if (menuList.get(i).get("pId").toString().equals(pid) ) {
+				if (menuList.get(i).get("pId").toString().equals(pid)) {
 					//递归遍历下一级
-					treeMenuList(menuList,  menuList.get(i).get("id").toString());
+					treeMenuList(menuList, menuList.get(i).get("id").toString());
 					childMenu.add(menuList.get(i));
 				}
 			}
@@ -213,10 +276,10 @@
 			//遍历出父id等于参数的id,add进子节点集合
 
 			if (!pid.equals(0)) {
-				if (menuList.get(i).get("pId").toString().equals(pid) ) {
+				if (menuList.get(i).get("pId").toString().equals(pid)) {
 					//递归遍历下一级
-					treeIdList(menuList,  menuList.get(i).get("id").toString());
-					if (menuList.get(i).get("eqid") != null || menuList.get(i).get("eqid") != "") {
+					treeIdList(menuList, menuList.get(i).get("id").toString());
+					if (menuList.get(i).get("eqid") != null && !menuList.get(i).get("eqid").equals("")) {
 						childMenu.add(menuList.get(i).get("eqid"));
 					}
 				}
@@ -269,18 +332,20 @@
 	@ApiOperationSupport(order = 6)
 	@ApiOperation(value = "新增或修改", notes = "传入equipment")
 	public R submit(@Valid @RequestBody Equipment equipment) {
-		if (equipment.getStime() != null && equipment.getStime().equals("")){
+		if (equipment.getStime() != null && equipment.getStime().equals("")) {
 			equipment.setStime(null);
 		}
 
-		if (equipment.getExpireTime() != null && equipment.getExpireTime().equals("")){
+		if (equipment.getExpireTime() != null && equipment.getExpireTime().equals("")) {
 			equipment.setExpireTime(null);
 		}
 
-		if (equipment.getHeartbeat() != null && equipment.getHeartbeat().equals("")){
+		if (equipment.getHeartbeat() != null && equipment.getHeartbeat().equals("")) {
 			equipment.setHeartbeat(null);
 		}
-
+		String deviceName = equipment.getDeviceName();
+		String deviceNumber = equipment.getDeviceNumber();
+		catalogService.updateCatalog(deviceName,deviceNumber);
 		return R.status(equipmentService.saveOrUpdate(equipment));
 	}
 

--
Gitblit v1.9.3