import { Body, Get, Inject, Post, Provide, Query } from '@midwayjs/core';
|
import { CoolController, BaseController } from '@cool-midway/core';
|
import { TaskInfoEntity } from '../../entity/info';
|
import { TaskInfoService } from '../../service/info';
|
|
/**
|
* 任务
|
*/
|
@Provide()
|
@CoolController({
|
api: ['add', 'delete', 'update', 'info', 'page'],
|
entity: TaskInfoEntity,
|
service: TaskInfoService,
|
before: ctx => {
|
ctx.request.body.limit = ctx.request.body.repeatCount;
|
},
|
pageQueryOp: {
|
fieldEq: ['status', 'type'],
|
},
|
})
|
export class TaskInfoController extends BaseController {
|
@Inject()
|
taskInfoService: TaskInfoService;
|
|
/**
|
* 手动执行一次
|
*/
|
@Post('/once', { summary: '执行一次' })
|
async once(@Body('id') id: number) {
|
await this.taskInfoService.once(id);
|
this.ok();
|
}
|
|
/**
|
* 暂停任务
|
*/
|
@Post('/stop', { summary: '停止' })
|
async stop(@Body('id') id: number) {
|
await this.taskInfoService.stop(id);
|
this.ok();
|
}
|
|
/**
|
* 开始任务
|
*/
|
@Post('/start', { summary: '开始' })
|
async start(@Body('id') id: number, @Body('type') type: number) {
|
await this.taskInfoService.start(id, type);
|
this.ok();
|
}
|
|
/**
|
* 日志
|
*/
|
@Get('/log', { summary: '日志' })
|
async log(@Query() params: any) {
|
return this.ok(await this.taskInfoService.log(params));
|
}
|
}
|
