新版调度器 创建任务增加入参

app/controller/task.js

@@ -50,7 +50,7 @@ class TaskController extends Controller {
     ctx.validate(this.createRule);
     const { scriptId, orderId } = ctx.request.body;
     await service.task.iplimit();
-    const taskId = await service.task.create(scriptId);
+    const taskId = await service.task.create({cityId: scriptId, orderId});
     await service.order.update({ orderId, cityId: scriptId, taskId: String(taskId) });
     await service.cache.set({
       key: String(taskId),

app/service/task.js

@@ -49,7 +49,11 @@ class TaskService extends Service {
     const { createTaskUrl } = taskAPI;
     const result = await this._request(createTaskUrl, {
       method: 'post',
-      data: { cityId: data },
+      data: {
+        cityId: data.cityId,
+        orderId: data.orderId || '',
+        source: 'gjjH5new'
+      },
       contentType: 'json',
     });
     ctx.logger.info(`【Task】create ${createTaskUrl} cityId: ${data} result:`, JSON.stringify(result.data));