orderDetail.js 9.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272
  1. 'use strict';
  2. const { CrudService } = require('naf-framework-mongoose-free/lib/service');
  3. const { BusinessError, ErrorCode } = require('naf-core').Error;
  4. const _ = require('lodash');
  5. const assert = require('assert');
  6. const { ObjectId } = require('mongoose').Types;
  7. const Transaction = require('mongoose-transactions');
  8. //
  9. class OrderDetailService extends CrudService {
  10. constructor(ctx) {
  11. super(ctx, 'orderdetail');
  12. this.model = this.ctx.model.Trade.OrderDetail;
  13. this.orderModel = this.ctx.model.Trade.Order;
  14. this.goodsSpecModel = this.ctx.model.Shop.GoodsSpec;
  15. this.userCouponModel = this.ctx.model.User.UserCoupon;
  16. this.goodsRateModel = this.ctx.model.Shop.GoodsRate;
  17. this.afterSaleModel = this.ctx.model.Trade.AfterSale;
  18. this.tran = new Transaction();
  19. }
  20. async searchOrderTransport({ id }) {
  21. const orderDetail = await this.model.findById(id);
  22. if (!id) throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到订单信息');
  23. const { transport = {} } = orderDetail;
  24. const { shop_transport_no: no, shop_transport_type: type } = transport;
  25. if (!no || !type) throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '缺少快递信息');
  26. const res = await this.ctx.service.util.kd100.search({ no, type });
  27. return res;
  28. }
  29. /**
  30. * 创建:用户支付完成后的订单
  31. * @param {Object} body 请求参数体
  32. * @param body.order_id 下单的id
  33. * @param {Transaction} tran 数据库事务实例
  34. */
  35. async create({ order_id }, tran) {
  36. assert(order_id, '缺少支付订单信息');
  37. const order = await this.orderModel.findById(order_id);
  38. if (!order) throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到支付订单的数据');
  39. // 返现部分
  40. const { customer, address, goods: shopGoods, no, status, buy_time, pay, total_detail: otd, inviter } = order;
  41. if (status === '0') throw new BusinessError(ErrorCode.DATA_INVALID, '订单未支付');
  42. const orderDetailData = { customer, address, order: order_id, buy_time, pay_time: _.get(pay, 'pay_time'), status, inviter };
  43. const shopMoneyDetail = this.ctx.service.util.order.shopMoneyDetail(order);
  44. // 分订单计数器
  45. let noTimes = 1;
  46. for (const s of shopGoods) {
  47. const shop = _.get(s, 'shop');
  48. const remarks = _.get(s, 'remarks');
  49. const goodsList = _.get(s, 'goods', []);
  50. const detailNo = `${no}-${noTimes}`;
  51. const total_detail = shopMoneyDetail[shop];
  52. // 优惠部分分割
  53. if (_.get(otd, 'discount_detail')) {
  54. // 如果有优惠部分,那就得找,优惠里面有没有对应的商品规格
  55. const discount_detail = this.getGoodsListDiscountDetail(goodsList, _.get(otd, 'discount_detail'));
  56. total_detail.discount_detail = discount_detail;
  57. }
  58. noTimes++;
  59. const obj = { ...orderDetailData, shop, goods: goodsList, no: detailNo, total_detail, remarks };
  60. // #region 团购
  61. const type = _.get(order, 'type');
  62. let group = _.get(order, 'group');
  63. if (type === '1') {
  64. // 说明是团购,需要找订单中有没有团的id
  65. obj.type = '1';
  66. obj.group = group;
  67. if (!group) {
  68. // 需要创建团,这是团长支付的单子,开团;然后把id回补
  69. group = await this.ctx.service.group.group.create(obj, tran);
  70. obj.group = group;
  71. tran.update('Order', order_id, { group, type: '1' });
  72. } else {
  73. // 需要参团操作,这是团员的单子,将人加入团中
  74. await this.ctx.service.group.group.join(customer, group, tran);
  75. }
  76. }
  77. // #endregion
  78. tran.insert('OrderDetail', obj);
  79. // arr.push(obj);
  80. }
  81. // await this.model.insertMany(arr);
  82. }
  83. /**
  84. * 将商品规格列表中,优惠的部分提取出来,分单用
  85. * @param {Array} goodsList 某店的商品列表
  86. * @param {Object} odd discount_detail 支付订单的优惠券设置
  87. */
  88. getGoodsListDiscountDetail(goodsList, odd) {
  89. const result = {};
  90. for (const uc_id in odd) {
  91. const detail = odd[uc_id];
  92. const obj = {};
  93. for (const g of goodsList) {
  94. const { _id } = g;
  95. const gdd = detail[_id];
  96. if (gdd) obj[_id] = gdd;
  97. }
  98. result[uc_id] = obj;
  99. }
  100. return result;
  101. }
  102. /**
  103. * 计算某店铺的金额总计
  104. * @param {Array} goodsList 商品规格列表
  105. */
  106. getTotalDetail(goodsList) {
  107. const goods_total = goodsList.reduce((p, n) => this.ctx.plus(p, this.ctx.multiply(n.sell_money, n.buy_num)), 0);
  108. const freight_total = goodsList.reduce((p, n) => this.ctx.plus(p, this.ctx.multiply(n.freight, n.buy_num)), 0);
  109. return { goods_total, freight_total };
  110. }
  111. async fetch(filter) {
  112. assert(filter);
  113. filter = await this.beforeFetch(filter);
  114. const { _id, id } = filter;
  115. if (_id || id) filter = { _id: ObjectId(_id || id) };
  116. const { populate } = this.getRefMods();
  117. let res = await this.model.findOne(filter).populate(populate).exec();
  118. res = JSON.parse(JSON.stringify(res));
  119. // 找售后和评论
  120. const afterSale = await this.afterSaleModel.find({ order_detail: res._id });
  121. const rate = await this.goodsRateModel.find({ orderDetail: res._id });
  122. const goods = _.get(res, 'goods', []);
  123. for (const g of goods) {
  124. const r = afterSale.find(f => ObjectId(_.get(f, 'goods._id')).equals(g._id));
  125. if (r) g.is_afterSale = true;
  126. else g.is_afterSale = false;
  127. const r2 = rate.find(f => ObjectId(_.get(f, 'goods._id')).equals(g._id));
  128. if (r2) g.is_rate = true;
  129. else g.is_rate = false;
  130. }
  131. res.goods = goods;
  132. return res;
  133. }
  134. async query(filter, { skip = 0, limit, sort, desc, projection } = {}) {
  135. // 处理排序
  136. if (sort && _.isString(sort)) {
  137. sort = { [sort]: desc ? -1 : 1 };
  138. } else if (sort && _.isArray(sort)) {
  139. sort = sort.map(f => ({ [f]: desc ? -1 : 1 })).reduce((p, c) => ({ ...p, ...c }), {});
  140. }
  141. let condition = _.cloneDeep(filter);
  142. condition = await this.beforeQuery(condition);
  143. condition = this.dealFilter(condition);
  144. // 过滤出ref字段
  145. const pipline = [{ $sort: { 'meta.createdAt': -1 } }];
  146. pipline.push({ $match: condition });
  147. // 整理字段
  148. // 店铺需要的字段
  149. pipline.push({ $addFields: { shop_id: { $toObjectId: '$shop' } } });
  150. pipline.push({
  151. $lookup: {
  152. from: 'shop',
  153. localField: 'shop_id',
  154. foreignField: '_id',
  155. as: 'shopInfo',
  156. },
  157. });
  158. pipline.push({ $addFields: { customer_id: { $toObjectId: '$customer' } } });
  159. pipline.push({
  160. $lookup: {
  161. from: 'user',
  162. localField: 'customer_id',
  163. foreignField: '_id',
  164. as: 'customerInfo',
  165. },
  166. });
  167. pipline.push({ $unwind: '$shopInfo' });
  168. pipline.push({ $unwind: '$customerInfo' });
  169. const lastProject = {
  170. $project: {
  171. _id: 1,
  172. type: 1,
  173. order: 1,
  174. buy_time: 1,
  175. pay_time: 1,
  176. status: 1,
  177. no: 1,
  178. group: 1,
  179. address: 1,
  180. goods: {
  181. _id: 1,
  182. sell_money: 1,
  183. freight: 1,
  184. name: 1,
  185. buy_num: 1,
  186. group_config: 1,
  187. goods: { name: 1, file: 1 },
  188. file: 1,
  189. },
  190. shop: {
  191. _id: '$shopInfo._id',
  192. name: '$shopInfo.name',
  193. },
  194. customer: {
  195. _id: '$customerInfo._id',
  196. name: '$customerInfo.name',
  197. },
  198. total_detail: 1,
  199. },
  200. };
  201. pipline.push(lastProject);
  202. const qPipline = _.cloneDeep(pipline);
  203. if (parseInt(skip) >= 0) qPipline.push({ $skip: parseInt(skip) });
  204. if (parseInt(limit)) qPipline.push({ $limit: parseInt(limit) });
  205. const rs = await this.model.aggregate(qPipline);
  206. const tPipline = _.cloneDeep(pipline);
  207. tPipline.push({ $addFields: { id: { $toString: '$_id' } } });
  208. tPipline.push({ $count: 'id' });
  209. const t = await this.model.aggregate(tPipline);
  210. const total = _.get(_.head(t), 'id');
  211. const list = [];
  212. for (const i of rs) {
  213. const { goods } = i;
  214. const obj = _.cloneDeep(i);
  215. const real_pay = this.ctx.service.util.orderDetail.computedRealPay(obj);
  216. obj.real_pay = real_pay;
  217. obj.buy_num_total = goods.reduce((p, n) => this.ctx.plus(p, n.buy_num), 0);
  218. for (const og of obj.goods) {
  219. const { file = [] } = og;
  220. const gfile = _.get(og, 'goods.file', []);
  221. const nf = [ ...file, ...gfile ];
  222. const url = _.get(_.head(nf), 'url');
  223. og.url = url;
  224. delete og.file;
  225. delete og.goods.file;
  226. }
  227. // 评价与售后
  228. const rate = await this.goodsRateModel.findOne({ orderDetail: obj._id }, { _id: 1 });
  229. obj.rate = _.get(rate, '_id');
  230. const asum = await this.afterSaleModel.count({ order_detail: obj._id });
  231. obj.is_afterSale = asum > 0;
  232. list.push(obj);
  233. }
  234. return { data: list, total };
  235. }
  236. async update(filter, update, { projection } = {}) {
  237. assert(filter);
  238. assert(update);
  239. const { _id, id } = filter;
  240. if (_id || id) filter = { _id: ObjectId(_id || id) };
  241. const entity = await this.model.findOne(filter).exec();
  242. if (!entity) throw new BusinessError(ErrorCode.DATA_NOT_EXIST);
  243. try {
  244. this.tran.update('OrderDetail', filter._id, update);
  245. if (_.get(update, 'status') === '3') {
  246. // 积分部分
  247. await this.ctx.service.user.point.addPoints(filter._id, this.tran);
  248. // 返现部分
  249. await this.ctx.service.user.cashBack.create(filter._id, this.tran);
  250. }
  251. await this.tran.run();
  252. const e = await this.model.findOne(filter, projection).exec();
  253. return e;
  254. } catch (error) {
  255. await this.tran.rollback();
  256. } finally {
  257. this.tran.clean();
  258. }
  259. }
  260. }
  261. module.exports = OrderDetailService;