.

.env

@@ -28,8 +28,8 @@ THROTTLE_LIMIT=20
 TYPEORM_CONNECTION="mysql"
 TYPEORM_HOST="rm-bp1cj5j76a6hp1zm5yo.rwlb.rds.aliyuncs.com"
 TYPEORM_PORT=3306
-TYPEORM_USERNAME=zouma
-TYPEORM_PASSWORD="wj4EPy2%yuq6uyo*o$*4"
+TYPEORM_USERNAME=rcs_test
+TYPEORM_PASSWORD="kuU8Te%4AXeBv*cHU@wf"
 TYPEORM_DATABASE=rcs_test
 TYPEORM_AUTO_SCHEMA_SYNC=true
 TYPEORM_ENTITIES="dist/**/*.entity.js"

.env.production

@@ -26,10 +26,10 @@ THROTTLE_TTL=60
 THROTTLE_LIMIT=20
 
 TYPEORM_CONNECTION="mysql"
-TYPEORM_HOST="rdsave1o67m1ido6gwp6145.mysql.rds.aliyuncs.com"
+TYPEORM_HOST="rm-bp1cj5j76a6hp1zm5yo.rwlb.rds.aliyuncs.com"
 TYPEORM_PORT=3306
-TYPEORM_USERNAME=zouma
-TYPEORM_PASSWORD="2wsx@WSX#EDC"
+TYPEORM_USERNAME=rcs
+TYPEORM_PASSWORD="hsDL6W@5a%F@wNA@8AP&"
 TYPEORM_DATABASE=rcs
 TYPEORM_AUTO_SCHEMA_SYNC=true
 TYPEORM_ENTITIES="dist/**/*.entity.js"

src/task/task.service.ts

@@ -66,14 +66,15 @@ export class TaskService implements OnModuleInit {
 
     onModuleInit() {
         this.lock.acquire('dispatchTask', async () => {
-            await this.taskItemRepository.update(
-                {
-                    status: TaskItemStatus.PENDING
-                },
-                {
-                    status: TaskItemStatus.IDLE
-                }
-            )
+            const tasks = await this.taskRepository.findBy({
+                status: TaskStatus.PENDING
+            })
+            for (let task of tasks) {
+                await this.taskItemRepository.update(
+                    { taskId: task.id, status: TaskItemStatus.PENDING },
+                    { status: TaskStatus.IDLE }
+                )
+            }
             await setTimeout(10000)
         })
     }