调试ws1

app/controller/index.js

@@ -69,7 +69,7 @@ class IndexController extends Controller {
         OrderNum: orderId,
         TaskId: '',
         redirectUrl: redirect,
-        appKey: appkey,
+        appkey,
         scriptId: Number(data.id),
       });
     } else {

app/router.js

@@ -10,17 +10,18 @@ module.exports = app => {
   yysRouter.get('/index', controller.index.index);// H5页面
 
   yysRouter.get('/scripts', controller.task.configs); // 获取所有脚本配置信息
-
+  yysRouter.post('/fields', controller.task.fields);// 更换运营商
   yysRouter.post('/tasks', controller.task.create); // 创建任务
   yysRouter.get('/tasks/:taskId', controller.task.show); // 获取任务状态
   yysRouter.post('/submit', controller.task.submit); // 提交任务参数
   yysRouter.post('/capture', controller.task.fetchCapture); // 获取验证码
 
   yysRouter.post('/callback', controller.task.handleCallback); // 处理回调结果，不对外
-
   yysRouter.post('/dataCallback', controller.task.dataCallback);// 数据处理完成结果，不对外
   yysRouter.post('/newdataCallback', controller.task.newdataCallback);// 运营报告处理完成结果，不对外
 
+  yysRouter.ws('/ws', controller.task.wslink);
+
   // yysRouter.get('/scripts', controller.script.fetchScripts); // 获取所有脚本信息
   // yysRouter.get('/scripts/:phone');// 手机号获取脚本信息
   // yysRouter.get('/scripts/:scriptId', controller.script.fetchOneScripts); // 获取单一脚本信息

app/service/order.js

@@ -24,6 +24,22 @@ class OrderService extends Service {
     return;
   }
 
+  async getOneByParams(where){
+    const { ctx } = this;
+    const order = await ctx.model.TaskStatus.findAll({
+      where,
+    });
+    if (order.length === 0) {
+      ctx.throw(400, { message: 'no orderId' });
+      return;
+    }
+    if (order.length > 1) {
+      ctx.throw(400, { message: 'error orderId or taskId' });
+      return;
+    }
+    return order[0];
+  }
+
   /*
     @desc 更新task
   */