Method registerTask

sendat/sendat.ts:318–379

(task: SendTask)

    const taskName = `sendat_${task.task_id}`;
    // Guard: delete any zombie cron from a previous generation before re-registering
    if (cronManager.has(taskName)) {
      cronManager.del(taskName);
    }
    
    if (task.interval) {
      if (task.cron) {
        // 定时任务（每天固定时间）
        const cronExpression = `${task.second} ${task.minute} ${task.hour} * * *`;
        cronManager.set(taskName, cronExpression, async () => {
            await this.executeTask(task);
        });
      } else {
        // 间隔任务
        const intervalMs = 
          (parseInt(task.hour) * 3600 + 
           parseInt(task.minute) * 60 + 
           parseInt(task.second)) * 1000;
        
        if (intervalMs > 0) {
          // 使用cron表达式模拟间隔任务
          const seconds = parseInt(task.second);
          const minutes = parseInt(task.minute);
          const hours = parseInt(task.hour);
          
          let cronExpression = '';
          if (hours > 0) {
            cronExpression = `${seconds} ${minutes} */${hours} * * *`;
          } else if (minutes > 0) {
            cronExpression = `${seconds} */${minutes} * * * *`;
          } else {
            cronExpression = `*/${seconds} * * * * *`;
          }
          
          cronManager.set(taskName, cronExpression, async () => {
            await this.executeTask(task);
          });
        }
      }
    } else {
      // 单次任务 - 使用cron表达式指定具体时间
      const now = new Date();
      const targetTime = new Date();
      targetTime.setHours(parseInt(task.hour), parseInt(task.minute), parseInt(task.second));
      
      if (targetTime <= now) {
        targetTime.setDate(targetTime.getDate() + 1);
      }
      
      const cronExpression = `${targetTime.getSeconds()} ${targetTime.getMinutes()} ${targetTime.getHours()} ${targetTime.getDate()} ${targetTime.getMonth() + 1} *`;
      
      cronManager.set(taskName, cronExpression, async () => {
        await this.executeTask(task);
        // 单次任务执行后删除
        await this.removeTask(task.task_id);
      });
    }
  }