first init.

wangzhibo

2026-07-16 bac4362a0b7726d38a23d38f0d7913f2c2bab262

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
import { App, Inject } from '@midwayjs/core';
import { BaseCoolQueue, CoolQueue } from '@cool-midway/task';
import { TaskBullService } from '../service/bull';
import { IMidwayApplication } from '@midwayjs/core';
 
/**
 * 任务
 */
@CoolQueue()
export abstract class TaskInfoQueue extends BaseCoolQueue {
  @App()
  app: IMidwayApplication;
 
  @Inject()
  taskBullService: TaskBullService;
 
  async data(job, done: any): Promise<void> {
    try {
      const result = await this.taskBullService.invokeService(job.data.service);
      this.taskBullService.record(job.data, 1, JSON.stringify(result));
    } catch (error) {
      this.taskBullService.record(job.data, 0, error.message);
    }
    if (!job.data.isOnce) {
      this.taskBullService.updateNextRunTime(job.data.jobId);
      this.taskBullService.updateStatus(job.data.id);
    }
    done();
  }
}