lachang/app/api/service/order/PaySuccess.php

<?php
// +----------------------------------------------------------------------
// | 萤火商城系统 [ 致力于通过产品和服务，帮助商家高效化开拓市场 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2017~2021 https://www.yiovo.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed 这不是一个自由软件，不允许对程序代码以任何形式任何目的的再发行
// +----------------------------------------------------------------------
// | Author: 萤火科技 <admin@yiovo.com>
// +----------------------------------------------------------------------
declare (strict_types=1);

namespace app\api\service\order;

use app\api\model\card\UserRiceCard as UserRiceCardModel;
use app\api\model\card\UserRiceCardConsume as UserRiceCardConsumeModel;
use app\api\model\member\GoldRice as GoldRiceModel;
use app\common\enum\user\AccumulatePointsScene;
use app\common\service\BaseService;
use app\api\model\User as UserModel;
use app\api\model\Order as OrderModel;
use app\api\model\user\BalanceLog as BalanceLogModel;
use app\common\service\commission\RecordWaitCommission;
use app\common\service\goods\source\Factory as StockFactory;
use app\common\enum\OrderType as OrderTypeEnum;
use app\common\enum\order\PayType as OrderPayTypeEnum;
use app\common\enum\user\balanceLog\Scene as SceneEnum;
use app\common\enum\order\OrderSource as OrderSourceEnum;
use app\common\model\store\Setting as SettingModel;
use think\facade\Event;

/**
 * 订单支付成功服务类
 * Class PaySuccess
 * @package app\api\service\order
 */
class PaySuccess extends BaseService
{
    // 订单模型
    public $model;

    // 当前用户信息
    private $user;

    /**
     * 构造函数
     * PaySuccess constructor.
     * @param $orderNo
     */
    public function __construct($orderNo)
    {
        parent::__construct();
        // 实例化订单模型
        $this->model = OrderModel::getPayDetail($orderNo);
        // 获取用户信息
        $this->user = UserModel::detail($this->model['user_id']);
    }

    /**
     * 获取订单详情
     * @return OrderModel|null
     */
    public function getOrderInfo()
    {
        return $this->model;
    }

    /**
     * 订单支付成功业务处理
     * @param $payType
     * @param array $payData
     * @return bool
     */
    public function onPaySuccess($payType, $payData = [])
    {
        if (empty($this->model)) {
            $this->error = '未找到该订单信息';
            return false;
        }
        // 更新付款状态
        $status = $this->updatePayStatus($payType, $payData);
        // 订单支付成功事件
        if ($status == true) {
            Event::trigger('OrderPaySuccess', ['order' => $this->model, 'orderType' => OrderTypeEnum::ORDER]);
        }
        return $status;
    }

    /**
     * 更新付款状态
     * @param $payType
     * @param array $payData
     * @return bool
     */
    private function updatePayStatus($payType, $payData = [])
    {
        // 验证余额支付时用户余额是否满足
        if ($payType == OrderPayTypeEnum::BALANCE) {
            if ($this->user['balance'] < $this->model['pay_price']) {
                $this->error = '用户余额不足，无法使用余额支付';
                return false;
            }
        }

        //积分不足
        if ($payType == OrderPayTypeEnum::EXCHANGE) {
            if ($this->user['accumulate_points'] < $this->model['total_price']) {
                $this->error = '用户积分不足，无法兑换成功';
                return false;
            }
            $this->model->transaction(function () use ($payType, $payData) {
                // 更新订单状态
                $this->updateOrderInfo($payType, $payData);
                //扣除用户积分
                $rate = SettingModel::getItem('points_rate')['points_2_money'];
                $points = bcmul($this->model['total_price'],$rate,0);
                UserModel::setDecAccumulatePoints($this->user['user_id'], $points,AccumulatePointsScene::CONSUME,'兑换商品');
                // 记录订单支付信息
                $this->updatePayInfo($payType);
            });
            return true;

        }

        // 事务处理
        $this->model->transaction(function () use ($payType, $payData) {
            // 更新订单状态
            $this->updateOrderInfo($payType, $payData);
            // 累积用户总消费金额
            UserModel::setIncPayMoney($this->user['user_id'], (float)$this->model['pay_price']);
            //累积VIP用户积分
            UserModel::setIncGrowthValue($this->user,$this->model['rice_card_money']+$this->model['pay_price']);
            //累计用户积分
            UserModel::setIncAccumulatePoints($this->user['user_id'], $this->model['pay_price']);
            // 记录订单支付信息
            $this->updatePayInfo($payType);
            // 如果是普通订单，写入分销记录(积分兑换商品订单无分佣)
            if($this->model['order_source']!=OrderSourceEnum::BARGAIN || $this->model['or'] != OrderSourceEnum::EXCHANGE){
                $this->writeCommission($payType);
            }
            //写入金米粒记录
            $this->writeUserGoldRice();
            //写入米卡记录
            $this->writeUserRiceCard($payType, $payData);
        });
        return true;
    }

    /**
     * 更新订单记录
     * @param int $payType
     * @param array $payData
     * @return false|int
     * @throws \Exception
     */
    private function updateOrderInfo(int $payType, array $payData)
    {
        log_record($this->model['order_id']);
        log_record($payData);
        log_record($payType);
        // 更新商品库存、销量
        StockFactory::getFactory($this->model['order_source'])->updateStockSales($this->model);

        //秒杀订单还要处理正常订单的销量
        if($this->model['order_source']==OrderSourceEnum::MIAOSHA){
            StockFactory::getFactory(OrderSourceEnum::MASTER)->updateStockSales($this->model);
        }
        
        // 整理订单信息
        $order = [
            'pay_type' => $payType,
            'pay_status' => 20,
            'pay_time' => time(),
            'invoice_deadline' => time() + OrderModel::getInvoiceDeadline() * 60 // 申请开票截止时间：订单付款后的40天内可以申请开票
        ];
        if ($payType == OrderPayTypeEnum::WECHAT) {
            $order['transaction_id'] = $payData['transaction_id'];
        }
        // 更新订单状态
        return $this->model->save($order);
    }

    /**
     * 记录订单支付信息
     * @param int $payType
     */
    private function updatePayInfo(int $payType)
    {
        // 余额支付
        if ($payType == OrderPayTypeEnum::BALANCE) {
            // 更新用户余额
            UserModel::setDecBalance((int)$this->user['user_id'], (float)$this->model['pay_price']);
            // 新增余额变动记录
            BalanceLogModel::add(SceneEnum::CONSUME, [
                'user_id' => (int)$this->user['user_id'],
                'money' => -$this->model['pay_price'],
            ], ['order_no' => $this->model['order_no']]);
        }
        // 微信支付
        if ($payType == OrderPayTypeEnum::WECHAT) {

        }
    }
    /**
     * 写入分销记录
     * @param int $payType
     * @return false|int
     * @throws \Exception
     */
    private function writeCommission(int $payType)
    {
        // 余额支付 或 微信支付
        if ($payType == OrderPayTypeEnum::BALANCE || $payType == OrderPayTypeEnum::WECHAT) {
            //待结算佣金计算
            $RecordWaitCommission = new RecordWaitCommission;
            //分销记录放入队列
            $RecordWaitCommission->recordWaitCommission($this->model['order_id']);
        }
        // 米卡兑换
        if ($payType == OrderPayTypeEnum::MICAH_EXCHANGE) {

        }
    }

    /**
     * 写入金米粒记录
     * @param int $payType
     * @return false|int
     * @throws \Exception
     */
    private function writeUserGoldRice()
    {
        if($this->model['gold_rice_amount']>0){
            //写金米粒出账记录
            GoldRiceModel::add($this->model['user_id'],$this->model['order_no'],'下单抵扣',$this->model['gold_rice_amount'],0);
            //扣除冻结中的金米粒
            UserModel::setDecByField($this->user['user_id'],'gold_rice_frozen',(float)$this->model['gold_rice_amount']);
        }
        if($this->model['gold_rice_amount_input']>0){
            //写金米粒入账记录
            GoldRiceModel::add($this->model['user_id'],$this->model['order_no'],'会员购物返金米粒',$this->model['gold_rice_amount_input'],1);
            //用户直接添加在途金米粒
            UserModel::setIncByField($this->user['user_id'],'gold_rice_road',(float)$this->model['gold_rice_amount_input']);
        }
    }

    /**
     * 写入米卡记录
     * @param int $payType
     * @return false|int
     * @throws \Exception
     */
    private function writeUserRiceCard(int $payType,array $payData)
    {
        // 余额支付 或 微信支付
//        if ($payType == OrderPayTypeEnum::BALANCE || $payType == OrderPayTypeEnum::WECHAT) {
            //现金卡的操作
            if($this->model['rice_card_id']>0){
                //写现金卡出账记录
                $userRiceCard = UserRiceCardModel::find($this->model['rice_card_id']);
                UserRiceCardConsumeModel::add($userRiceCard,$this->model['order_no'],$this->model['pay_price'],$this->model['rice_card_money']);
                //如果可用余额为0并且冻结余额等于要抵扣的金额
                if($this->model['userRiceCard']['balance']==0 && $this->model['rice_card_money']==$this->model['userRiceCard']['frozen_amount']){
                    //现金卡直接减冻结余额,并且状态改为已失效
                    UserRiceCardModel::setIncDecByField($this->model['rice_card_id'],[],['frozen_amount'=>(float)$this->model['rice_card_money']],['effect_state'=>2]);
                }else{
                    //现金卡直接减冻结余额
                    UserRiceCardModel::setDecByField($this->model['rice_card_id'],'frozen_amount',(float)$this->model['rice_card_money']);
                }
            }
//        }
//        // 米卡兑换
//        if ($payType == OrderPayTypeEnum::MICAH_EXCHANGE) {
//
//        }
    }

}