update

app/service/statistics/bill.js

@@ -20,10 +20,63 @@ class BillService extends CrudService {
     const { shop, start, end } = query;
     assert(start, '缺少开始时间');
     assert(end, '缺少结束时间');
+    const orderList = await this.makeBillOrderPart(query);
+    const afterSaleList = await this.makeBillAfterSalePart(query);
+    const ot = orderList.reduce((p, n) => this.ctx.plus(p, n.total), 0);
+    const oa = afterSaleList.reduce((p, n) => this.ctx.plus(p, n.money), 0);
+    const total = this.ctx.minus(ot, oa);
+    return { total, orderList, afterSaleList };
+  }
+
+  /**
+   * 对账单售后部分
+   * @param {Object} query 查询条件
+   */
+  async makeBillAfterSalePart(query) {
+    const { shop, start, end } = query;
     const pipline = [];
-    // TODO: 商店过滤
-    // 时间过滤
+    // 商店过滤&时间过滤
+    const q = { $match: { $and: [{ apply_time: { $gte: start } }, { apply_time: { $lte: end } }] } }; // 退款,退货的完成状态, status:{$in:['-1','-2']}
+    if (shop) q.$match.shop = shop;
+    pipline.push(q);
+    // 组织数据
+    // 单号,商品,规格,退款金额,退款时间
+    // 单号是要用orderDetail关联获取;商品&规格&退款时间&退款金额有;
+    pipline.push({ $addFields: { orderDetail_id: { $toObjectId: '$order_detail' } } });
+    pipline.push({
+      $lookup: {
+        from: 'orderDetail',
+        localField: 'orderDetail_id',
+        foreignField: '_id',
+        pipeline: [{ $project: { no: 1 } }],
+        as: 'orderDetailInfo',
+      },
+    });
+    // 组织数据
+    pipline.push({ $unwind: '$orderDetailInfo' });
+    pipline.push({
+      $project: {
+        no: '$ordderDetailInfo.no',
+        goods: '$goods.goods.name',
+        spec: '$goods.name',
+        end_time: 1,
+        money: { $toString: '$money' },
+      },
+    });
+    const afterSaleList = await this.afterSaleModel.aggregate(pipline);
+    return afterSaleList;
+  }
+
+  /**
+   * 对账单订单部分
+   * @param {Object} query 查询条件
+   */
+  async makeBillOrderPart(query) {
+    const { shop, start, end } = query;
+    const pipline = [];
+    // 商店过滤&时间过滤
     const q = { $match: { $and: [{ pay_time: { $gte: start } }, { pay_time: { $lte: end } }] } };
+    if (shop) q.$match.shop = shop;
     pipline.push(q);
     // #region 整理数据
     // 整理最外层的orderDetail,没用的裁掉
@@ -31,6 +84,7 @@ class BillService extends CrudService {
       type: 1,
       total_detail: 1,
       no: 1,
+      pay_time: 1,
       goods: {
         _id: 1,
         sell_money: 1,
@@ -46,8 +100,51 @@ class BillService extends CrudService {
     pipline.push({ $unwind: '$goods' });
     // #endregion
     const orderList = await this.orderDetailModel.aggregate(pipline);
-    return orderList;
+    const dictData = await this.ctx.model.Dev.DictData.find({ code: 'order_type' });
+    const list = [];
+    for (const order of orderList) {
+      const o = _.cloneDeep(order);
+      const type = dictData.find(f => f.value === o.type);
+      const moneyDetail = this.moneyDetail(order);
+      const obj = {
+        no: _.get(o, 'no'),
+        type: _.get(type, 'label'),
+        pay_time: _.get(o, 'pay_time'),
+        goods: _.get(o, 'goods.goods.name'),
+        spec: _.get(o, 'goods.name'),
+        buy_num: _.get(o, 'goods.buy_num'),
+        price: o.type === '1' ? _.get(o, 'goods.group_config.money') : _.get(o, 'goods.sell_money'),
+        discount: _.get(moneyDetail, 'dt'),
+        total: o.type === '1' ? _.get(moneyDetail, 'ggrp') : _.get(moneyDetail, 'grp'),
+      };
+      list.push(obj);
+    }
+    return list;
+  }
 
+  moneyDetail(data) {
+    const ddt = _.get(data, 'total_detail.discount_detail', {});
+    const { sell_money: sm, freight: f, buy_num: bn, group_config, _id } = data.goods;
+    const st = this.ctx.multiply(sm, bn);
+    const ft = this.ctx.multiply(f, bn);
+    const gt = this.ctx.plus(st, ft);
+    const dd = {};
+    for (const uc_id in ddt) {
+      const detail = _.get(ddt, uc_id, {});
+      const value = detail[_id];
+      if (value) dd[uc_id] = value;
+    }
+    const dt = Object.values(dd).reduce((p, n) => this.ctx.plus(p, n), 0);
+    const grp = this.ctx.minus(gt, dt);
+    let obj = { sm, f, bn, st, ft, gt, dd, dt, grp };
+    const gsm = _.get(group_config, 'money');
+    if (gsm) {
+      const gst = this.ctx.multiply(gsm, bn);
+      const ggt = this.ctx.plus(gst, ft);
+      const ggrp = this.ctx.minus(ggt, dt);
+      obj = { ...obj, gsm, gst, ggt, ggrp };
+    }
+    return obj;
   }
 }