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/colletmeta.ts | 27 ++++++++++++++++++++++++++-
1 files changed, 26 insertions(+), 1 deletions(-)
diff --git a/src/app/modules/business/controller/admin/colletmeta.ts b/src/app/modules/business/controller/admin/colletmeta.ts
index a10b38c..813eb83 100644
--- a/src/app/modules/business/controller/admin/colletmeta.ts
+++ b/src/app/modules/business/controller/admin/colletmeta.ts
@@ -1,8 +1,10 @@
import { ALL, Body, Get, Inject, Post, Provide, Query } from '@midwayjs/decorator';
import { CoolController, BaseController } from '@cool-midway/core';
import { Colletmeta } from '../../entity/colletmeta';
-// import { ColletmetaService } from '../../service/colletmeta';
+// import { ColletmetaService } from '../../service/';
import { DataController } from '../../../base/controller/dataController';
+import { SocketHandler } from '../../../../../socket/socketHandle';
+import { RpcService } from '../../../base/service/dataapi/rpcservice';
/**
* 鐩戞祴鍏冩暟鎹�
*/
@@ -15,6 +17,22 @@
export class ColletmetaController extends DataController {
// 聽@Inject()
// 聽colletmetaService: ColletmetaService;
+
+
+ @Inject()
+ socketHandler: SocketHandler
+
+ @Inject()
+ rpcService: RpcService
+
+ /**
+ * 鎺ユ敹璁惧鐩戞帶娑堟伅
+ */
+ @Post('/getDeviceMsg', { summary: '鎺ユ敹璁惧娑堟伅' })
+ async getDeviceMsg(@Query(ALL) params: any) {
+ this.dealMessage(params)
+ return this.ok();
+ }
/**
* 鑾峰緱鏁版嵁
@@ -30,4 +48,11 @@
async postData(@Query(ALL) params: any) {
return this.ok(await this.dataService.getData(params));
}
+
+
+ async dealMessage(params: any) {
+ // this.socketHandler.connection
+ console.log(params);
+ }
+
}
\ No newline at end of file
--
Gitblit v1.9.1