taskid

app/controller/task.js

@@ -69,7 +69,7 @@ class TaskController extends Controller {
       callbackUrl: config.callbackUrl,
     });
     await service.cache.set({
-      key: taskId,
+      key: String(taskId),
       value: { status: 'init', note: { message: 'init' } },
     });
     ctx.success(taskId);
@@ -91,7 +91,7 @@ class TaskController extends Controller {
     const { ctx, service } = this;
     ctx.validate(this.taskIdRule, ctx.params);
     const { taskId } = ctx.params;
-    const data = await service.cache.get({ key: taskId });
+    const data = await service.cache.get({ key: String(taskId) });
     ctx.success(data);
   }
 
@@ -99,7 +99,7 @@ class TaskController extends Controller {
   async handleCallback() {
     const { ctx, service } = this;
     const { taskId } = ctx.request.body;
-    const result = await service.task.fetchTask({ taskId });
+    const result = await service.task.fetchTask({ taskId: String(taskId) });
     // ctx.success();
     // ctx.status = 200;
     ctx.body = 'ok';
@@ -136,7 +136,7 @@ class TaskController extends Controller {
       };
       try {
         const insertData = await service.washData.wash(result);
-        const order = await service.order.getOneByTaskId(taskId);
+        const order = await service.order.getOneByTaskId(String(taskId));
         if (!order) {
           throw new Error(`【taskId】:${taskId} 任务已经结束.`);
         }
@@ -165,7 +165,7 @@ class TaskController extends Controller {
       break;
     }
     await service.cache.set({
-      key: taskId,
+      key: String(taskId),
       value: taskNote,
     });
   }