taxh5回调

app/controller/order.js

@@ -68,6 +68,10 @@ class OrderController extends Controller {
         if (orderId) {
             await service.order.update(object);
         } else {
+            if (!userId) {
+                ctx.throw(422, { message: '请输入userId' });
+                return;
+              }
             object.orderId = ctx.helper.getUuid();
             await service.order.create(object);
         }

app/controller/task.js

@@ -90,8 +90,10 @@ class TaskController extends Controller {
         const {ctx, service} = this;
         ctx.logger.info('【handleCallback】', ctx.request.body);
         const {taskId} = ctx.request.body;
+        ctx.body = {
+            code: '0',
+        };
         const result = await service.task.fetchTask({taskId});
-        ctx.success();
         let taskNote = {
             status: 'init',
             note: {message: 'init'},

app/extend/context.js

@@ -26,4 +26,19 @@ module.exports = {
     };
   },
 
+  error(err = '') {
+    this.status = 200;
+    if (err.code === 'invalid_param') {
+      this.body = { code: -1, msg: '请求参数有误' };
+      return;
+    }
+    if (!/token/.test(err.message)) {
+      if (/[a-zA-Z]+/.test(err.message)) {
+        this.body = { code: err.code || -1, msg: '系统错误, 请稍后再试' };
+        return;
+      }
+    }
+    this.body = { code: err.code || -1, msg: err.message || '' };
+  },
+
 };