websocket 消息发送

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

@@ -10,8 +10,10 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
 import com.miniframe.core.ExecProcessFlow;
+import com.miniframe.core.ext.UtilTools;
 import com.miniframe.generate.business.system.model.D00008BaseModel;
 import com.miniframe.template.TemplateGenerator;
+import com.miniframe.websocket.WebsocketEndPoint;
 import lombok.SneakyThrows;
 
 /**
@@ -54,6 +56,8 @@ 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);
 					System.out.println(line);
 				}
 			} catch (IOException e) {
@@ -77,6 +81,8 @@ 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);
 				System.out.println(line);
 			}
 			} catch (IOException e) {