// +---------------------------------------------------------------------- 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) { $rate = SettingModel::getItem('points_rate')['points_2_money']; $points = bcmul($this->model['total_price'],$rate,0); if ($this->user['accumulate_points'] < $points) { $this->error = '用户积分不足,无法兑换成功'; return false; } $this->model->transaction(function () use ($payType, $payData, $points) { // 更新订单状态 $this->updateOrderInfo($payType, $payData); //扣除用户积分 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) { // // } } }