添加socket.io taskshchedule等

wangrong

2022-06-28 0b31be01af4247244e1b6285d6c537c2894acea9

 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));
  }




}