import { BaseCoolQueue, CoolQueue } from '@cool-midway/task';
import { Inject } from '@midwayjs/core';
import { OrderInfoService } from '../service/info';

// 行为
export enum Action {
  // 超时未支付
  TIMEOUT = 0,
  // 自动确认收货
  CONFIRM = 1,
}

/**
 * 队列
 */
@CoolQueue()
export abstract class OrderQueue extends BaseCoolQueue {
  @Inject()
  orderInfoService: OrderInfoService;

  async data(job: any, done: any) {
    const action = job.data.action;
    if (action == Action.TIMEOUT) {
      // 关闭订单
      await this.orderInfoService.close(job.data.orderId, '超时未支付');
    }
    if (action == Action.CONFIRM) {
      // 自动确认收货
      await this.orderInfoService.autoConfirm(job.data.orderId);
    }
    done();
  }
}