From 0b31be01af4247244e1b6285d6c537c2894acea9 Mon Sep 17 00:00:00 2001
From: wangrong <wangrong@shsening.com>
Date: 星期二, 28 六月 2022 14:32:46 +0800
Subject: [PATCH] 添加socket.io taskshchedule等
---
src/app/modules/business/controller/admin/taskmonitor.ts | 30 +++++++++++++++++++++++++++++-
1 files changed, 29 insertions(+), 1 deletions(-)
diff --git a/src/app/modules/business/controller/admin/taskmonitor.ts b/src/app/modules/business/controller/admin/taskmonitor.ts
index 63e6f79..6f26494 100644
--- a/src/app/modules/business/controller/admin/taskmonitor.ts
+++ b/src/app/modules/business/controller/admin/taskmonitor.ts
@@ -3,6 +3,8 @@
import { Taskmonitor } from '../../entity/taskmonitor';
// import { TaskmonitorService } from '../../service/taskmonitor';
import { DataController } from '../../../base/controller/dataController';
+import { SocketHandler } from '../../../../../socket/socketHandle';
+import { RpcService } from '../../../base/service/dataapi/rpcservice';
/**
* 鐩戞祴浠诲姟
*/
@@ -10,17 +12,39 @@
@CoolController({
api: ['add', 'delete', 'update', 'list', 'page', 'info'],
entity: Taskmonitor,
+ service: RpcService,
// 聽service: TaskmonitorService,
})
export class TaskmonitorController extends DataController {
// 聽@Inject()
// 聽taskmonitorService: TaskmonitorService;
+ @Inject()
+ socketHandler: SocketHandler
+
+ @Inject()
+ rpcService: RpcService
+
+
+
+ /**
+ * 浠诲姟涓嬪彂
+ */
+ @Get('/add', { summary: '涓嬪彂浠诲姟' })
+ async add(@Query(ALL) params: any) { // 杩欎釜io瀵硅薄瀵瑰簲 SocketHandler鐨勫懡鍚嶇┖闂�
+ // this.socketHandler.connection
+ this.socketHandler.clients.get("").emit('device is offline');
+ this.rpcService.remoteCall(null,"");
+
+ }
+
/**
* 鑾峰緱鏁版嵁
*/
@Get('/getdata', { summary: '鏁版嵁鎺ュ彛' })
- async getData(@Query(ALL) params: any) {
+ async getData(@Query(ALL) params: any) { // 杩欎釜io瀵硅薄瀵瑰簲 SocketHandler鐨勫懡鍚嶇┖闂�
+ // this.socketHandler.connection
+ this.socketHandler.clients.get("").emit('device is offline');
return this.ok(await this.dataService.getData(params));
}
/**
@@ -30,4 +54,8 @@
async postData(@Query(ALL) params: any) {
return this.ok(await this.dataService.getData(params));
}
+
+
+
+
}
\ No newline at end of file
--
Gitblit v1.9.1