websocket 消息发送

src/main/java/com/miniframe/bisiness/system/D00008Service.java

@@ -46,6 +46,7 @@ public class D00008Service extends D00008BaseModel implements ExecProcessFlow {
 	//异步执行
 	@SneakyThrows
 	public void exeWater(Integer aid) throws Exception{
+		WebsocketEndPoint webs= UtilTools.getBean(WebsocketEndPoint.class);
 		CompletableFuture<Void> cf = CompletableFuture.supplyAsync(()->{
 			try {
 				Runtime runtime = Runtime.getRuntime();
@@ -56,8 +57,7 @@ public class D00008Service extends D00008BaseModel implements ExecProcessFlow {
 				BufferedReader br = new BufferedReader(isr);
 				String line = null;
 				while ((line = br.readLine()) != null) {
-//					WebsocketEndPoint webs= UtilTools.getBean(WebsocketEndPoint.class);
-//					webs.sendMessageToUser(String.valueOf(aid),line);
+					webs.sendMessageToUser(String.valueOf(aid),line);
 					System.out.println(line);
 				}
 			} catch (IOException e) {
@@ -71,6 +71,7 @@ public class D00008Service extends D00008BaseModel implements ExecProcessFlow {
 	//异步执行
 	@SneakyThrows
 	public void exeFire(Integer aid) throws Exception{
+		WebsocketEndPoint webs= UtilTools.getBean(WebsocketEndPoint.class);
 		CompletableFuture<Void> cf = CompletableFuture.supplyAsync(()->{
 			try {
 			Runtime runtime = Runtime.getRuntime();
@@ -81,8 +82,7 @@ public class D00008Service extends D00008BaseModel implements ExecProcessFlow {
 			BufferedReader br = new BufferedReader(isr);
 			String line = null;
 			while ((line = br.readLine()) != null) {
-//				WebsocketEndPoint webs= UtilTools.getBean(WebsocketEndPoint.class);
-//				webs.sendMessageToUser(String.valueOf(aid),line);
+				webs.sendMessageToUser(String.valueOf(aid),line);
 				System.out.println(line);
 			}
 			} catch (IOException e) {