update

app/controller/shop/config/.shopInBill.js

@@ -0,0 +1,40 @@
+module.exports = {
+  create: {
+    requestBody: ['total', 'receipts', 'shop', 'cut', 'time', 'source', 'source_id'],
+  },
+  destroy: {
+    params: ['!id'],
+    service: 'delete',
+  },
+  update: {
+    params: ['!id'],
+    requestBody: ['total', 'receipts', 'shop', 'cut', 'time', 'source', 'source_id'],
+  },
+  show: {
+    parameters: {
+      params: ['!id'],
+    },
+    service: 'fetch',
+  },
+  index: {
+    parameters: {
+      query: {
+        'time@start': 'time@start',
+        'time@end': 'time@end',
+        shop: 'shop',
+        source: 'source',
+        source_id: 'source_id',
+      },
+      // options: {
+      //   "meta.state": 0 // 默认条件
+      // },
+    },
+    service: 'query',
+    options: {
+      query: ['skip', 'limit'],
+      sort: ['meta.createdAt'],
+      desc: true,
+      count: true,
+    },
+  },
+};

app/controller/shop/shopInBill.js

@@ -0,0 +1,13 @@
+'use strict';
+const meta = require('./config/.shopInBill.js');
+const Controller = require('egg').Controller;
+const { CrudController } = require('naf-framework-mongoose-free/lib/controller');
+
+// 
+class ShopInBillController extends Controller {
+  constructor(ctx) {
+    super(ctx);
+    this.service = this.ctx.service.shop.shopInBill;
+  }
+}
+module.exports = CrudController(ShopInBillController, meta);

app/controller/util.js

@@ -14,8 +14,8 @@ class UtilController extends Controller {
     this.tradeService = this.ctx.service.util.trade;
   }
   async util() {
-    await this.ctx.service.view.order.allOrder();
-    this.ctx.ok();
+    const res = this.ctx.multiply(this.ctx.minus(1, this.ctx.divide(0, 100)), 200);
+    this.ctx.ok({ data: res });
   }
 
   async crk() {

app/model/shop/shopInBill.js

@@ -0,0 +1,30 @@
+'use strict';
+const Schema = require('mongoose').Schema;
+const metaPlugin = require('naf-framework-mongoose-free/lib/model/meta-plugin');
+
+const MoneyPlugin = require('naf-framework-mongoose-free/lib/model/type-money-plugin');
+
+// 店铺流水
+// 如果是入账,则有抽成比例,总金额.出账则不需要抽成比例和总金额
+const shopInBill = {
+  shop: { type: String, required: false, zh: '店铺', ref: 'Shop.Shop' }, //
+  cut: { type: Number, required: false, zh: '抽成比例' }, //
+  time: { type: String, required: false, zh: '流水时间' }, //
+  source: { type: String, required: false, zh: '来源' }, // 字典:cashBack_source
+  source_id: { type: String, required: false, zh: '来源id' }, //
+};
+const schema = new Schema(shopInBill, { toJSON: { getters: true, virtuals: true } });
+schema.index({ id: 1 });
+schema.index({ 'meta.createdAt': 1 });
+schema.index({ shop: 1 });
+schema.index({ source: 1 });
+schema.index({ source_id: 1 });
+
+schema.plugin(metaPlugin);
+schema.plugin(MoneyPlugin({ zh: '总金额', required: false, key: 'total' }));
+schema.plugin(MoneyPlugin({ zh: '净金额', required: false, key: 'receipts' }));
+
+module.exports = app => {
+  const { mongoose } = app;
+  return mongoose.model('ShopInBill', schema, 'shopInBill');
+};

app/service/shop/shopInBill.js

@@ -0,0 +1,50 @@
+'use strict';
+const { CrudService } = require('naf-framework-mongoose-free/lib/service');
+const { BusinessError, ErrorCode } = require('naf-core').Error;
+const _ = require('lodash');
+const assert = require('assert');
+const moment = require('moment');
+
+//
+class ShopInBillService extends CrudService {
+  constructor(ctx) {
+    super(ctx, 'shopinbill');
+    this.model = this.ctx.model.Shop.ShopInBill;
+    this.shopModel = this.ctx.model.Shop.Shop;
+    this.orderUtil = this.ctx.service.util.orderDetail;
+  }
+  /**
+   * 正常购物创建店铺流水
+   * @param {object} orderDetail 订单详情数据
+   * @param {Transaction} tran 数据库事务
+   */
+  async createByOrder(orderDetail, tran) {
+    const obj = { shop: _.get(orderDetail, 'shop') };
+    const shopData = await this.shopModel.findById(_.get(orderDetail, 'shop'), { cut: 1 });
+    if (!shopData) throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到店铺数据');
+    obj.cut = _.get(shopData, 'cut', 0);
+    const real_pay = this.orderUtil.computedRealPay(orderDetail);
+    obj.total = real_pay;
+    obj.receipts = this.ctx.multiply(this.ctx.minus(1, this.ctx.divide(obj.cut, 100)), real_pay);
+    obj.time = moment().format('YYYY-MM-DD HH:mm:ss');
+    obj.source = '3';
+    obj.source_id = _.get(orderDetail, '_id');
+    tran.insert('ShopInBill', obj);
+  }
+
+  /**
+   * 售后创建流水
+   * @param {object} afterSale 订单详情数据
+   * @param {Transaction} tran 数据库事务
+   */
+  async createByAfterSale(afterSale, tran) {
+    const obj = { shop: _.get(afterSale, '_id') };
+    obj.time = moment().format('YYYY-MM-DD HH:mm:ss');
+    obj.source = '-3';
+    obj.source_id = _.get(afterSale, '_id');
+    obj.receipts = _.get(afterSale, 'money');
+    tran.insert('ShopInBill', obj);
+  }
+}
+
+module.exports = ShopInBillService;

app/service/trade/afterSale.js

@@ -198,6 +198,9 @@ class AfterSaleService extends CrudService {
     const refundInfo = { reason: _.get(data, 'desc', '购物退款'), money: returnMoney, order_no, out_refund_no };
     // 退积分
     await this.ctx.service.user.point.refundOrderPoint(order_detail, tran);
+    // 退商铺的入账流水金额
+    const shopBill = { shop: _.get(data, 'shop'), _id: _.get(data, '_id'), money: returnMoney };
+    await this.ctx.service.shop.shopInBill.createByAfterSale(shopBill, tran);
     return refundInfo;
   }
   /**

app/service/trade/orderDetail.js

@@ -26,10 +26,10 @@ class OrderDetailService extends CrudService {
     if (goods_id) {
       // 传来指定商品,查有该商品的订单,但是如果没有,就查每一项中是否有 shop_transport_no 和 shop_transport_type
       // 如果有这俩属性,说明也有单子,也查出来
-      toSearch = transport.filter(f => _.isArray(f.goods) && f.goods.find(fg => fg.goods_id === goods_id));
+      toSearch = transport.filter((f) => _.isArray(f.goods) && f.goods.find((fg) => fg.goods_id === goods_id));
       console.log(toSearch);
       if (toSearch.length <= 0) {
-        toSearch = transport.filter(f => f.shop_transport_no && f.shop_transport_type);
+        toSearch = transport.filter((f) => f.shop_transport_no && f.shop_transport_type);
       }
     } else {
       toSearch = transport;
@@ -86,7 +86,6 @@ class OrderDetailService extends CrudService {
     // await this.model.insertMany(list);
   }
 
-
   /**
    * 将商品规格列表中,优惠的部分提取出来,分单用
    * @param {Array} goodsList 某店的商品列表
@@ -130,10 +129,10 @@ class OrderDetailService extends CrudService {
     const rate = await this.goodsRateModel.find({ orderDetail: res._id });
     const goods = _.get(res, 'goods', []);
     for (const g of goods) {
-      const r = afterSale.find(f => ObjectId(_.get(f, 'goods._id')).equals(g._id));
+      const r = afterSale.find((f) => ObjectId(_.get(f, 'goods._id')).equals(g._id));
       if (r) g.is_afterSale = true;
       else g.is_afterSale = false;
-      const r2 = rate.find(f => ObjectId(_.get(f, 'goodsSpec')).equals(g._id));
+      const r2 = rate.find((f) => ObjectId(_.get(f, 'goodsSpec')).equals(g._id));
       if (r2) {
         g.is_rate = true;
         g.rate = r2._id;
@@ -179,7 +178,7 @@ class OrderDetailService extends CrudService {
     if (sort && _.isString(sort)) {
       sort = { [sort]: desc ? -1 : 1 };
     } else if (sort && _.isArray(sort)) {
-      sort = sort.map(f => ({ [f]: desc ? -1 : 1 })).reduce((p, c) => ({ ...p, ...c }), {});
+      sort = sort.map((f) => ({ [f]: desc ? -1 : 1 })).reduce((p, c) => ({ ...p, ...c }), {});
     }
     let condition = _.cloneDeep(filter);
     condition = await this.beforeQuery(condition);
@@ -266,7 +265,7 @@ class OrderDetailService extends CrudService {
       for (const og of obj.goods) {
         const { file = [], _id: goodsSpec } = og;
         const gfile = _.get(og, 'goods.file', []);
-        const nf = [ ...file, ...gfile ];
+        const nf = [...file, ...gfile];
         const url = _.get(_.head(nf), 'url');
         og.url = url;
         delete og.file;
@@ -278,7 +277,7 @@ class OrderDetailService extends CrudService {
         obj.price = _.get(obj, 'price', obj.sell_money);
       }
       // 售后
-      const asum = await this.afterSaleModel.count({ order_detail: obj._id, status: { $nin: [ '-1', '!1', '-2', '!2', '-3', '!3', '-4', '!4', '-5', '!5' ] } });
+      const asum = await this.afterSaleModel.count({ order_detail: obj._id, status: { $nin: ['-1', '!1', '-2', '!2', '-3', '!3', '-4', '!4', '-5', '!5'] } });
       obj.is_afterSale = asum > 0;
       list.push(obj);
     }
@@ -300,6 +299,8 @@ class OrderDetailService extends CrudService {
         await this.ctx.service.user.point.addPoints(filter._id, this.tran);
         // 返现部分
         await this.ctx.service.user.cashBack.create(filter._id, this.tran);
+        // 店铺流水部分
+        await this.ctx.service.shop.shopInBill.createByOrder(entity, this.tran);
       }
 
       await this.tran.run();
@@ -307,7 +308,6 @@ class OrderDetailService extends CrudService {
       return e;
     } catch (error) {
       await this.tran.rollback();
-
     } finally {
       this.tran.clean();
     }

app/z_router/shop/index.js

@@ -8,4 +8,5 @@ module.exports = app => {
   require('./goodsSpec')(app); // 商品规格
   require('./goodsRate')(app); // 商品评价
   require('./goodsJoinAct')(app); // 平台活动商品关联
+  require('./shopInBill')(app); // 店铺流水
 };

app/z_router/shop/shopInBill.js

@@ -0,0 +1,19 @@
+'use strict';
+// 路由配置
+const path = require('path');
+const regPath = path.resolve('app', 'public', 'routerRegister');
+const routerRegister = require(regPath);
+const rkey = 'shopInBill';
+const ckey = 'shop.shopInBill';
+const keyZh = '店铺流水信息';
+const routes = [
+  { method: 'get', path: `${rkey}`, controller: `${ckey}.index`, name: `${ckey}Query`, zh: `${keyZh}列表查询` },
+  { method: 'get', path: `${rkey}/:id`, controller: `${ckey}.show`, name: `${ckey}Show`, zh: `${keyZh}查询` },
+  // { method: 'post', path: `${rkey}`, controller: `${ckey}.create`, name: `${ckey}Create`, zh: `创建${keyZh}` },
+  // { method: 'post', path: `${rkey}/:id`, controller: `${ckey}.update`, name: `${ckey}Update`, zh: `修改${keyZh}` },
+  // { method: 'delete', path: `${rkey}/:id`, controller: `${ckey}.destroy`, name: `${ckey}Delete`, zh: `删除${keyZh}` },
+];
+
+module.exports = app => {
+  routerRegister(app, routes, keyZh, rkey, ckey);
+};