server/app/service/user/cashBack.js

'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 CashBackService extends CrudService {
  constructor(ctx) {
    super(ctx, 'cashback');
    this.model = this.ctx.model.User.CashBack;
    this.orderDetailModel = this.ctx.model.Trade.OrderDetail;
  }

  async computedTotal({ customer }) {
    assert(customer, '缺少用户信息');
    // status(状态) 和 source(来源) 均表示钱是入账还是出账,判断一个就行,主要还是依靠来源吧
    const res = await this.model.find({ inviter: customer }).lean();
    let total = 0;
    for (const i of res) {
      const { source, money } = i;
      const sn = parseInt(source);
      if (sn >= 0) total = this.ctx.plus(total, money);
      else total = this.ctx.minus(total, money);
    }
    return total;
  }
  /**
   * 添加检查返现
   * @param {String} orderDetail_id 订单详情id
   * @param {Transaction} tran 数据库事务
   */
  async create(orderDetail_id, tran) {
    const { populate } = this.ctx.service.trade.orderDetail.getRefMods();
    const orderDetail = await this.orderDetailModel.findById(orderDetail_id).populate(populate);
    if (!orderDetail) return;
    // 找到商品的返现类型
    let rmoney = 0;
    const { goods: goodsSpec, type } = orderDetail;
    // 根据订单类型判断应该取哪个价钱,为下面的百分比计算取值用
    let priceKey;
    if (type === '1') priceKey = 'ggrp';
    else priceKey = 'grp';
    const moneyDetail = this.ctx.service.util.orderDetail.moneyDetail(orderDetail);
    for (const gs of goodsSpec) {
      const goods = _.get(gs, 'goods');
      if (!goods) continue;
      const { is_cashBack, cb_config } = goods;
      // 0:返现(使用)
      if (is_cashBack !== '0') continue;
      const type = _.get(cb_config, 'back_type');
      if (!type) continue;
      const money = _.get(cb_config, 'money');
      if (type === 'fixed') rmoney = this.ctx.plus(rmoney, money);
      else if (type === 'percent') {
        const specId = _.get(gs, '_id');
        const realPay = _.get(moneyDetail, `${specId}.${priceKey}`);
        const grm = this.ctx.multiply(realPay, this.ctx.divide(money, 10));
        rmoney = this.ctx.plus(rmoney, grm);
      }
    }
    const { inviter, _id: order_detail } = orderDetail;
    if (!inviter) return;
    const obj = { inviter: _.get(inviter, '_id'), source_id: order_detail, source: '0', money: rmoney, time: moment().format('YYYY-MM-DD HH:mm:ss') };
    // 检查是否已经返利
    const num = await this.model.count({ inviter: _.get(inviter, '_id'), source_id: order_detail, source: '0' });
    if (num > 0) return;
    tran.insert('CashBack', obj);
  }
}

module.exports = CashBackService;