test

app/controller/task.js

@@ -105,6 +105,7 @@ class TaskController extends Controller {
         const {ctx, service} = this;
         const {taskId} = ctx.request.body;
         const result = await service.task.fetchTask({taskId});
+        ctx.logger.info('原始数据result:----', result, '-----------------666')
         ctx.success();
         let taskNote = {
             status: 'init',
@@ -144,7 +145,6 @@ class TaskController extends Controller {
                     note: {message: 'task success'},
                 };
                 try {
-                    // const insertData = await service.washData.wash(result);
                     const order = await service.order.getOneByTaskId(taskId);
                     if (!order) {
                         throw new Error('任务已经结束了');
@@ -152,13 +152,16 @@ class TaskController extends Controller {
                     const {orderId, appkey} = order;
                     ctx.logger.info(result.cityId)
                     const script = await service.scripts.fetchOneScripts(result.cityId);
-                    ctx.logger.info('callback-script', JSON.stringify(script))
+                    ctx.logger.info('callback-script-----------', JSON.stringify(script))
+                    result.cityId = '12';
+                    result.cityName = '北京';
+                    result.taskId = taskId;
+                    result.data = JSON.parse(result.data.data);
                     result.orderSn = orderId;
                     result.orderId = orderId;
-                    // result.cityName = script.name || 'unknown';
-                    result.taskId = taskId;
-                    // result.appKey = appkey;
+                    result.appKey = appkey;
                     delete result.code;
+                    delete result.msg;
                     await service.storage.write(result);
                     await service.partner.notice(order);
                 } catch (err) {