瀏覽代碼

同步组件增加设备同步方法,设备新增增加自动同步功能,提供全局同步接口

chenwen 1 年之前
父節點
當前提交
1c95045fe5

+ 21 - 1
src/main/java/com/hb/proj/base/controller/DeviceController.java

@@ -28,6 +28,9 @@ public class DeviceController {
 	@Autowired
 	private DeviceService  service;
 	
+	@Autowired
+	private SynGatherComp  synComp;
+	
 	
 	/**
 	 * 加载某类设备的基本信息
@@ -92,7 +95,9 @@ public class DeviceController {
 			 return RespVOBuilder.error("该设备编码已存在,勿重复添加");
 		 }
 		 device.setModifyBy(token.getUsName());
-		 return RespVOBuilder.ok(service.add(device));
+		 String devId=service.add(device);
+		 synComp.synAllDev();
+		 return RespVOBuilder.ok(devId);
 		
 	}
 	
@@ -115,4 +120,19 @@ public class DeviceController {
 	  
 		
 	}
+	
+	/**
+	 * 同步采集程序对所有设备重加载
+	 * @return
+	 */
+	@RequestMapping("/synGather")
+	public RespVO<Object> synGather(){
+		boolean rst=synComp.synAllDev();
+		if(rst) {
+			return RespVOBuilder.ok();
+		}
+		else {
+			return RespVOBuilder.error("同步失败");
+		}
+	}
 }

+ 10 - 0
src/main/java/com/hb/proj/base/controller/SynGatherComp.java

@@ -48,4 +48,14 @@ public class SynGatherComp {
 		String rst=OkhttpUtils.post(gatherAPIUrl+"/api/synWellParams", args);
 		return rst!=null;
 	}
+	
+	/**
+	 * 重新加载全部设备
+	 * @return
+	 */
+	public boolean synAllDev() {
+		Map<String,String> args=new HashMap<>();
+		String rst=OkhttpUtils.post(gatherAPIUrl+"/api/synDevs", args);
+		return rst!=null;
+	}
 }