taskid

app/controller/task.js

@@ -51,7 +51,7 @@ class TaskController extends Controller {
     const taskId = await service.task.create(scriptId);
     await service.order.update({ orderId, cityId: scriptId, taskId });
     await service.cache.set({
-      key: taskId,
+      key: String(taskId),
       value: { status: 'init', note: { message: 'init' } },
     });
     ctx.success({ taskId });
@@ -62,7 +62,7 @@ class TaskController extends Controller {
     ctx.validate(this.submitRule);
     const { taskId } = ctx.params;
     await service.cache.set({
-      key: taskId,
+      key: String(taskId),
       value: { status: 'login', note: { message: 'login' } },
     });
     await service.task.submit({
@@ -90,7 +90,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);
   }
 
@@ -139,14 +139,14 @@ class TaskController extends Controller {
         note: { message: 'wash' },
       };
       try {
-        const order = await service.order.getOneByTaskId(taskId);
+        const order = await service.order.getOneByTaskId(String(taskId));
         if (!order) {
           throw new Error('任务不存在');
         }
         const { orderId, netMark } = order;
         await service.washData.wash(result, orderId, netMark);
         await service.cache.set({
-          key: taskId,
+          key: String(taskId),
           value: taskNote,
         });
         return;
@@ -163,7 +163,7 @@ class TaskController extends Controller {
       break;
     }
     await service.cache.set({
-      key: taskId,
+      key: String(taskId),
       value: taskNote,
     });
   }
@@ -174,7 +174,7 @@ class TaskController extends Controller {
       code: 200,
     };
     const { taskId, state } = ctx.request.body;
-    const order = await service.order.getOneByTaskId(taskId);
+    const order = await service.order.getOneByTaskId(String(taskId));
     if (!order) {
       throw new Error('任务不存在');
     }
@@ -190,7 +190,7 @@ class TaskController extends Controller {
     }
     await service.partner.notice(order, state);
     await service.cache.set({
-      key: taskId,
+      key: String(taskId),
       value: taskNote,
     });
   }