123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202 |
- 'use strict';
- const BaseService = require('./base.js');
- class DiningCoinService extends BaseService {
-
- async addDiningCoinChangeLog(params = {}, transaction = null) {
- const that = this;
- let action_user = '';
-
-
- switch (params.type) {
- case -1:
- case 0:
- case 2:
- action_user = '店铺提现';
- break;
- case 1:
- action_user = '购买餐币';
- break;
- case 3:
- action_user = '餐饮消费';
- break;
- case 4:
- action_user = '核销餐币';
- break;
- }
- const createBean = await that.app.comoBean.instance({
- user_id: params.user_id,
- order_id: params.order_id,
- type: params.type,
- account: params.account,
- out_batch_no: params.out_batch_no,
- out_detail_no: params.out_detail_no,
- partner_id: params.partner_id,
- action_user,
- log_desc: params.log_desc,
- create_time: that.app.szjcomo.date('Y-m-d H:i:s'),
- ori_partner: params.ori_partner,
- customer_id: params.customer_id,
- customer_name: params.customer_name,
- customer_img: params.customer_img,
- }, { transaction });
- const result = await that.create(createBean, that.app.model.DinnerCoinLogs, '记录用户餐饮币变动失败');
- return result;
- }
-
- async dispatchDiningCoin(orderInfo = null) {
- const that = this;
- const transaction = await that.app.model.transaction();
- try {
- if (orderInfo && !orderInfo.dining_coin_send) {
-
- let ori_partner_id = -1;
- const inviterInfo = await that.app.model.Users.findOne({
- where: { user_id: orderInfo.inviter_id },
- attributes: [ 'partner_id' ],
- });
- if (inviterInfo) {
- ori_partner_id = inviterInfo.partner_id;
- }
-
- let dining_coin_send = false;
-
- if (orderInfo.orders_products.length > 0) {
- for (const ordersProduct of orderInfo.orders_products) {
- if (ordersProduct.dining_partner_id > 0 && ordersProduct.dinning_coin_amount > 0) {
-
- await that.addDiningCoinChangeLog({
- user_id: orderInfo.user_id,
- order_id: orderInfo.order_id,
- partner_id: ordersProduct.dining_partner_id,
- type: 1,
- account: ordersProduct.dinning_coin_amount * ordersProduct.product_count,
- log_desc: '购酒获得餐饮币',
- }, transaction);
-
- const info = await that.app.model.DinnerCoins.findOne({
- where: {
- user_id: orderInfo.user_id,
- ori_partner: ori_partner_id === ordersProduct.dining_partner_id,
- partner_id: ordersProduct.dining_partner_id,
- expired: false,
- },
- transaction,
- raw: true,
- });
- if (!info) {
-
- const data = {
- user_id: orderInfo.user_id,
- account: ordersProduct.dinning_coin_amount * ordersProduct.product_count,
- ori_partner: ori_partner_id === ordersProduct.dining_partner_id,
- partner_id: ordersProduct.dining_partner_id,
- create_time: that.app.szjcomo.date('Y-m-d H:i:s'),
- expired: false,
- expired_time: that.app.szjcomo.date('Y-m-d H:i:s', parseInt(+new Date() + '') / 1000 + 90 * 24 * 60 * 60),
- };
- const res = await that.app.model.PartnerInfo.findOne({
- where: { id: ordersProduct.dining_partner_id },
- transaction,
- raw: true,
- });
- data.partner_name = res.name;
- data.partner_address = res.address;
- data.partner_tel = res.tel_num;
- data.partner_opening_time = res.opening_time;
- const createBean = await that.app.comoBean.instance(data, { transaction });
- await that.service.base.create(createBean, that.app.model.DinnerCoins, '餐饮币发放失败,请重试');
- } else {
- const updateBean = await that.app.comoBean.instance({
- account: info.account + ordersProduct.dinning_coin_amount * ordersProduct.product_count,
- update_time: that.app.szjcomo.date('Y-m-d H:i:s'),
- expired: false,
- expired_time: that.app.szjcomo.date('Y-m-d H:i:s', parseInt(+new Date() + '') / 1000 + 90 * 24 * 60 * 60),
- }, {
- where: {
- user_id: orderInfo.user_id,
- ori_partner: ori_partner_id === ordersProduct.dining_partner_id,
- partner_id: ordersProduct.dining_partner_id,
- }, transaction,
- });
- await that.service.base.update(updateBean, that.app.model.DinnerCoins, '餐饮币余额更新失败,请重试');
- }
- dining_coin_send = true;
-
- const updatePartnerBean = await that.app.comoBean.instance({
- order_amount: that.app.Sequelize.literal('order_amount + ' + 1),
- update_time: that.app.szjcomo.date('Y-m-d H:i:s'),
- }, { where: { id: ordersProduct.dining_partner_id }, transaction });
- await that.update(updatePartnerBean, that.app.model.PartnerInfo, '合作餐店订单量更新失败,请稍候重试');
- }
- }
-
- if (dining_coin_send) {
- const updateBean = that.app.comoBean.instance({ dining_coin_send }, {
- where: { order_id: orderInfo.order_id }, transaction,
- });
- await that.service.base.update(updateBean, that.app.model.Orders, '更新订单餐饮币发放状态失败,请稍候重试');
- }
- await transaction.commit();
- }
- }
- } catch (e) {
- if (transaction) await transaction.rollback();
- throw new Error(e.toString());
- }
- }
-
- async orderDiningCoinDispatchAfterPay(order_id = -1) {
- const that = this;
-
- const order = await that.selectOrderInfo(order_id);
- if (!order) throw new Error('订单不存在');
- await that.dispatchDiningCoin(order);
- }
-
- async selectOrderInfo(order_id) {
- const that = this;
- const options = {
- where: { order_id }, include: [
- {
- model: that.app.model.OrdersProducts, as: 'orders_products', attributes: {
- exclude: [ 'product_id', 'create_time', 'order_id', 'activity_name', 'activity_id', 'activity_desc' ],
- },
- },
- ], attributes: {
- exclude: [ 'seller_remarks', 'province_id', 'city_id', 'county_id', 'shipping_id', 'shipping_fee', 'activity_id', 'activity_name', 'activity_desc' ],
- },
- };
- const selectBean = await that.app.comoBean.instance({}, options);
- try {
- return await that.service.base.select(selectBean, that.app.model.Orders, '查询订单详情失败,请稍候重试', false, false);
- } catch (e) {
- that.logger.error('订单id:%s ;分佣查询订单详情失败', order_id);
- return null;
- }
- }
- }
- module.exports = DiningCoinService;
|