CRON作业在预定时间执行两次(NestJS)

Question

我想在我的NestJs项目中执行这个cron函数:

@Cron('59 23 * * *')
async CashPendingCRON(){
    let stores = await this.storeRepository.find();
    for (let store of stores){
        await this.connection
        .createQueryBuilder()
        .insert()
        .into(CashPending)
        .values([
        { cashPending: store.cashPending, store: store }
        ])
        .execute()
 }

正如你所看到的，玉米作业应该在每天晚上11:59执行。但是它被执行了两次，条目在DB中被记录了两次。当我使用像10秒这样的间隔(*/10 * * * * *)时，它只被调用一次。

请让我知道是否有一个修复或如果我做错了什么。

下面是我在app.module.ts 中添加ScheduleModule的方法

@Module({
  imports: [
    ScheduleModule.forRoot(),
    ConfigModule.forRoot({
      load: [appConfig, devConfig, stagConfig],
      ignoreEnvFile: true,
      isGlobal: true,
    }),
    TypeOrmModule.forRoot(
      configService.getTypeOrmConfig(),
    ),
    TypeOrmModule.forFeature([
      User,
      Vendor,
      Store,
      Product,
      Category,
      Brand,
      AppVersion
    ]),
    JwtModule.registerAsync({
      imports: [ConfigModule],
      useFactory: async () => ({
        secret: process.env.TOKEN_KEY,
      }),
      inject: [ConfigService],
    }),
    UserModule,
    UserClusterModule,
    StoreModule,
    OperationManagerModule,
    UserBrandModule,
    UserCatalogueModule,
    UserPropertyModule,
    FileModule,
    BrandModule,
    CategoryModule,
    ProductsModule,
    WarehouseModule,
    SubCategoryModule,
    StoreStocksModule,
    WarehouseStockModule,
    RtvStocksModule,
    VendorModule,
    CustomerModule,
    W2sModule,
    S2sModule,
    W2wModule,
    BillerModule,
    WarehouseManagerModule,
    AuthModule,
    OrderModule,
    GRNModule,
    SKUTimelinesModule,
    BannerModule,
    OrderReturnModule,
    UtilModule,
    POModule,
    AppVersion,
    S2wModule,
    CashOutModule
  ],
  controllers: [AppController],
  providers: [AppService],
})
export class AppModule {}

请帮助。谢谢你。

Answer 1

我遇到了这个问题，通知name属性为我解决了这个问题:

@Cron(CronExpression.EVERY_10_SECONDS, { name: 'nameOfJob'})

Answer 2

我正在经历同样的问题，问题是我在一个被导入两次的模块中使用imports: [ScheduleModule.forRoot()](由其他两个模块)。我通过创建一个不被任何其他模块导入的新模块解决了这个问题并加入ScheduleModule.forRoot()

scheduler.module.ts

@Module({
  providers: [SchedulerService],
  imports: [ScheduleModule.forRoot()],
})
export class SchedulerModule {}

scheduler.service.ts

import { Injectable } from '@nestjs/common';
import { Cron, CronExpression } from '@nestjs/schedule';
@Injectable()
export class SchedulerService {
  @Cron(CronExpression.EVERY_10_SECONDS)
  handleExpiration() {
    console.log(new Date());
  }
}

控制台输出:

2022-12-21T14:04:00.005Z
2022-12-21T14:04:10.004Z
2022-12-21T14:04:20.009Z
2022-12-21T14:04:30.004Z
2022-12-21T14:04:40.011Z
...