添加socket.io taskshchedule等

wangrong

2022-06-28 0b31be01af4247244e1b6285d6c537c2894acea9

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
import { ALL, Body, Get, Inject, Post, Provide, Query } from '@midwayjs/decorator';
import { CoolController, BaseController } from '@cool-midway/core';
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';
/**
        * 监测任务
        */
@Provide()
@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) {  // 这个io对象对应 SocketHandler的命名空间
    // this.socketHandler.connection
    this.socketHandler.clients.get("").emit('device is offline');
    return this.ok(await this.dataService.getData(params));
  }
  /**
  * 获得数据
  */
  @Get('/postdata', { summary: '数据接口' })
  async postData(@Query(ALL) params: any) {
    return this.ok(await this.dataService.getData(params));
  }
 
 
 
 
}