update

app/controller/order/order.js

@@ -38,6 +38,14 @@ class OrderController extends Controller {
     await this.bill_service.outBill(this.ctx.request.body);
     this.ctx.ok();
   }
+
+  /**
+   * 修改订单负责人
+   */
+  async principalChange() {
+    await this.service.principalChange(this.ctx.request.body);
+    this.ctx.ok();
+  }
 }
 
 module.exports = CrudController(OrderController, meta);

app/router/order.js

@@ -6,6 +6,8 @@ module.exports = app => {
   const prefix = '/api/servicezhwl';
   const index = 'order';
   const { router, controller } = app;
+  // 订单负责人 principalChange
+  router.post('order', `${prefix}/order/principal`, controller[index].order.principalChange);
   // 收入
   router.post('order', `${prefix}/order/inBill`, controller[index].order.inBill);
   // 拆分货物

app/service/order/order.js

@@ -244,6 +244,19 @@ class OrderService extends CrudService {
     return '状态错误';
   }
 
+  async principalChange(data) {
+    const { principal, _id } = data;
+    const res = await this.model.update({ _id: ObjectId(_id) }, { principal });
+    try {
+      // TODO 跨库查询该用户姓名
+      const message = '变更订单负责人';
+      this.record(_id, { method: 'principal', message });
+    } catch (error) {
+      this.logger.error(`订单id:${res.id}记录创建失败:${error.toString()}`);
+    }
+    return res;
+  }
+
 
   /**
    * 订单操作记录
@@ -265,7 +278,7 @@ class OrderService extends CrudService {
     else if (method === 'in') record.message = `${username}修改收入`;
     else if (method === 'out') record.message = `${username}修改支出`;
     else if (method === 'split') record.message = `${username}拆分货物`;
-    else if (method === 'send' || method === 'arrive') record.message = `${message}`;
+    else if (method === 'send' || method === 'arrive' || method === 'principal') record.message = `${message}`;
     order.record.push(record);
     await order.save();
   }