x1ongzhu 1 year ago
parent
commit
b3d774e7b2
3 changed files with 21 additions and 0 deletions
  1. 8 0
      src/sys-config/sys-config.service.ts
  2. 3 0
      src/task/entities/task.entity.ts
  3. 10 0
      src/task/task.service.ts

+ 8 - 0
src/sys-config/sys-config.service.ts

@@ -38,6 +38,14 @@ export class SysConfigService implements OnModuleInit {
                 remark: '清理数量'
             })
         }
+        if (!(await this.sysConfigRepository.findOneBy({ name: 'request_number_interval' }))) {
+            await this.sysConfigRepository.save({
+                name: 'request_number_interval',
+                value: '100',
+                type: SysConfigType.Number,
+                remark: '请求新号码间隔'
+            })
+        }
     }
 
     async findAll(req: PageRequest<SysConfig>) {

+ 3 - 0
src/task/entities/task.entity.ts

@@ -45,4 +45,7 @@ export class Task {
 
     @Column()
     successRate: string
+
+    @Column({ default: 0 })
+    requestNumberInterval
 }

+ 10 - 0
src/task/task.service.ts

@@ -146,6 +146,7 @@ export class TaskService implements OnModuleInit {
                 let rcsWait = 2000
                 let rcsInterval = 3000
                 let cleanCount = 20
+                let requestNumberInterval = 100
                 if (task.rcsWait > 0) {
                     rcsWait = task.rcsWait
                 } else {
@@ -173,6 +174,15 @@ export class TaskService implements OnModuleInit {
                         Logger.error('Error getting clean count', error, 'RcsService')
                     }
                 }
+                if (task.requestNumberInterval > 0) {
+                    requestNumberInterval = task.requestNumberInterval
+                } else {
+                    try {
+                        requestNumberInterval = await this.sysConfigService.getNumber('request_number_interval', 100)
+                    } catch (error) {
+                        Logger.error('Error getting request number interval', error, 'RcsService')
+                    }
+                }
 
                 let taskItems = await this.taskItemRepository.find({
                     where: { taskId: task.id, status: TaskItemStatus.IDLE },