🐞 fix: 修复部分bug

apis/Corn/StartAutoLepao.js

@@ -46,7 +46,7 @@ class StartAutoLepao extends API {
 
                 try {
                     const channel = await mq.getChannel('lepao_corn')
-                    await channel.assertQueue('task_queue', { durable: true })
+                    await channel.assertQueue('runforge_task_queue', { durable: true })
 
                     const taskId = `lepao:auto:${Date.now()}:${student_num}`
                     const payload = {
@@ -60,7 +60,7 @@ class StartAutoLepao extends API {
                     }
 
                     channel.sendToQueue(
-                        'task_queue',
+                        'runforge_task_queue',
                         Buffer.from(JSON.stringify(payload)),
                         { persistent: true, contentType: 'application/json' }
                     )

apis/Corn/StartLepao.js

@@ -53,7 +53,7 @@ class StartLepao extends API {
 
                 try {
                     const channel = await mq.getChannel('lepao_corn')
-                    await channel.assertQueue('task_queue', { durable: true })
+                    await channel.assertQueue('runforge_task_queue', { durable: true })
 
                     const taskId = `lepao:repair:${Date.now()}:${student_num}`
                     const payload = {
@@ -67,7 +67,7 @@ class StartLepao extends API {
                     }
 
                     channel.sendToQueue(
-                        'task_queue',
+                        'runforge_task_queue',
                         Buffer.from(JSON.stringify(payload)),
                         { persistent: true, contentType: 'application/json' }
                     )

apis/Lepao/SingleRun.js

@@ -10,8 +10,6 @@ class SingleRun extends API {
     constructor() {
         super()
 
-        
-
         this.setPath('/Lepao/SingleRun')
         this.setMethod('GET')
     }
@@ -89,7 +87,7 @@ class SingleRun extends API {
 
             try {
                 const channel = await mq.getChannel('lepao_api')
-                await channel.assertQueue('task_queue', { durable: true })
+                await channel.assertQueue('runforge_task_queue', { durable: true })
 
                 const taskId = `lepao:${Date.now()}:${student_num}`
                 const payload = {
@@ -103,7 +101,7 @@ class SingleRun extends API {
                 }
 
                 channel.sendToQueue(
-                    'task_queue',
+                    'runforge_task_queue',
                     Buffer.from(JSON.stringify(payload)),
                     { persistent: true, contentType: 'application/json' }
                 )

lib/Lepao/Worker.js

@@ -322,7 +322,7 @@ class Worker {
         /* ---------------- 开始乐跑 ---------------- */
         this.register('lepao.startRun', async (req, ctx) => {
             const traceId = ctx.traceId
-            const maxPathRetry = 999  // 自动获取路径失败最大重试次数
+            const maxPathRetry = 20  // 自动获取路径失败最大重试次数
             let pathRetry = 0
             let pointData = null
             let ossPath = null