Merge pull request #367 from Divineifed1/main

scheduled jobs implementation

Author: yusuftomilola

backend/src/app.module.ts

@@ -34,6 +34,8 @@ import { DepartmentsModule } from './departments/departments.module';
 import { AssetTransfersModule } from './asset-transfers/asset-transfers.module';
 import { SearchModule } from './search/search.module';
 import { ApiKeyModule } from './api-key/api-key.module';
+import { NestModule } from './scheduled-jobs/nest/nest.module';
+import { ScheduledJobsModule } from './scheduled-jobs/scheduled-jobs.module';
 
 @Module({
   imports: [
@@ -84,6 +86,8 @@ import { ApiKeyModule } from './api-key/api-key.module';
     WebhooksModule,
     AuditLogsModule,
     ApiKeyModule,
+    NestModule,
+    ScheduledJobsModule,
   ],
   controllers: [AppController],
   providers: [

backend/src/scheduled-jobs/dto/create-scheduled-job.dto.ts

@@ -0,0 +1 @@
+export class CreateScheduledJobDto {}

backend/src/scheduled-jobs/dto/update-scheduled-settings.dto.ts

@@ -0,0 +1,8 @@
+/* eslint-disable prettier/prettier */
+import { IsOptional, IsString } from 'class-validator';
+
+export class UpdateScheduleSettingsDto {
+  @IsOptional() @IsString() licenseCheckCron?: string;
+  @IsOptional() @IsString() insuranceReminderCron?: string;
+  @IsOptional() @IsString() maintenanceCheckCron?: string;
+}

backend/src/scheduled-jobs/entities/scheduled-settings.entity.ts

@@ -0,0 +1,20 @@
+/* eslint-disable prettier/prettier */
+import { Entity, PrimaryGeneratedColumn, Column, UpdateDateColumn } from 'typeorm';
+
+@Entity('schedule_settings')
+export class ScheduleSettings {
+  @PrimaryGeneratedColumn('uuid')
+  id: string;
+
+  @Column({ default: '0 0 * * *' }) // every day at midnight
+  licenseCheckCron: string;
+
+  @Column({ default: '0 8 * * *' }) // every day at 8am
+  insuranceReminderCron: string;
+
+  @Column({ default: '0 9 * * MON' }) // every Monday at 9am
+  maintenanceCheckCron: string;
+
+  @UpdateDateColumn()
+  updatedAt: Date;
+}

backend/src/scheduled-jobs/scheduled-jobs.controller.ts

@@ -0,0 +1,19 @@
+/* eslint-disable prettier/prettier */
+import { Controller, Get, Patch, Body } from '@nestjs/common';
+import { ScheduledJobsService } from './scheduled-jobs.service';
+import { UpdateScheduleSettingsDto } from './dto/update-scheduled-settings.dto';
+
+@Controller('scheduled-jobs')
+export class ScheduledJobsController {
+  constructor(private readonly scheduledJobsService: ScheduledJobsService) {}
+
+  @Get('settings')
+  getSettings() {
+    return this.scheduledJobsService.getSettings();
+  }
+
+  @Patch('settings')
+  updateSettings(@Body() dto: UpdateScheduleSettingsDto) {
+    return this.scheduledJobsService.updateSettings(dto);
+  }
+}

backend/src/scheduled-jobs/scheduled-jobs.module.ts

@@ -0,0 +1,17 @@
+/* eslint-disable prettier/prettier */
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { ScheduleModule } from '@nestjs/schedule';
+import { ScheduledJobsController } from './scheduled-jobs.controller';
+import { ScheduledJobsService } from './scheduled-jobs.service';
+import { ScheduleSettings } from './entities/scheduled-settings.entity';
+
+@Module({
+  imports: [
+    TypeOrmModule.forFeature([ScheduleSettings]),
+    ScheduleModule.forRoot(), // enables cron support
+  ],
+  controllers: [ScheduledJobsController],
+  providers: [ScheduledJobsService],
+})
+export class ScheduledJobsModule {}

backend/src/scheduled-jobs/scheduled-jobs.service.ts

@@ -0,0 +1,49 @@
+/* eslint-disable prettier/prettier */
+import { Injectable, Logger } from '@nestjs/common';
+import { Cron, CronExpression } from '@nestjs/schedule';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+import { ScheduleSettings } from './entities/scheduled-settings.entity';
+
+@Injectable()
+export class ScheduledJobsService {
+  private readonly logger = new Logger(ScheduledJobsService.name);
+
+  constructor(
+    @InjectRepository(ScheduleSettings)
+    private readonly settingsRepo: Repository<ScheduleSettings>,
+  ) {}
+
+  // 🕒 Daily check for license expiry
+  @Cron(CronExpression.EVERY_DAY_AT_MIDNIGHT)
+  async checkLicenseExpiry() {
+    this.logger.log('Running daily license expiry check...');
+    // TODO: Query licenses expiring soon, send reminders
+  }
+
+  // 🕗 Daily insurance reminder
+  @Cron(CronExpression.EVERY_DAY_AT_8AM)
+  async sendInsuranceReminders() {
+    this.logger.log('Running insurance reminder task...');
+    // TODO: Notify companies with upcoming insurance expiry
+  }
+
+  // 🧰 Weekly maintenance scheduling
+  @Cron(CronExpression.EVERY_DAY_AT_9AM)
+  async scheduleMaintenanceTasks() {
+    this.logger.log('Running weekly maintenance scheduler...');
+    // TODO: Identify assets due for maintenance and alert teams
+  }
+
+  // ⚙️ Update job intervals dynamically
+  async updateSettings(newSettings: Partial<ScheduleSettings>) {
+    const settings = await this.settingsRepo.findOne({});
+    if (!settings) return this.settingsRepo.save(newSettings);
+    Object.assign(settings, newSettings);
+    return this.settingsRepo.save(settings);
+  }
+
+  async getSettings() {
+    return this.settingsRepo.findOne({});
+  }
+}