model = OrderModel::getPayDetail($orderNo); // 获取用户信息 $this->user = UserModel::detail($this->model['user_id']); } /** * 订单支付成功业务处理 */ public function onPaySuccess($payType, $payData = []) { if (empty($this->model)) { $this->error = '未找到该订单信息'; return false; } // 更新付款状态 return $this->updatePayStatus($payType, $payData); } /** * 更新付款状态 */ private function updatePayStatus($payType, $payData = []) { // 验证余额支付时用户余额是否满足 if ($payType == OrderPayTypeEnum::BALANCE) { if ($this->user['balance'] < $this->model['money']) { $this->error = '用户余额不足,无法使用余额支付'; return false; } } // 事务处理 $this->model->transaction(function () use ($payType, $payData) { // 更新订单状态 $this->updateOrderInfo($payType, $payData); // 累积用户总消费金额 $this->user->setIncPayMoney($this->model['money']); // 记录订单支付信息 $this->updatePayInfo($payType); //更新会员卡数据 $this->updateCard(); }); return true; } /** * 更新会员卡数据 */ private function updateCard() { CardModel::where('card_id', '=', $this->model['card_id'])->inc('receive_num', 1)->update(); //赠送积分 if ($this->model['open_points'] && $this->model['open_points_num']) { $this->user->setIncPoints($this->model['open_points_num'], '发会员卡获取积分'); } //赠送优惠券 if ($this->model['open_coupon'] && $this->model['open_coupons']) { (new UserCouponModel)->addUserCardCoupon($this->model['open_coupons'], $this->user,$this->model['order_id']); } //赠送余额 if ($this->model['open_money'] && $this->model['open_money_num']) { (new UserModel)->where('user_id', '=', $this->user['user_id']) ->inc('balance', $this->model['open_money_num']) ->update(); BalanceLogModel::add(BalanceLogSceneEnum::RECHARGE, [ 'user_id' => $this->user['user_id'], 'money' => $this->model['open_money_num'], ], ['order_no' => '后台发放会员卡赠送']); } //赠送券商品 if ($this->model['open_product'] && $this->model['open_products']) { (new CardModel)->createOrder($this->model['open_products'], $this->user); } } /** * 更新订单记录 */ private function updateOrderInfo($payType, $payData) { $order = [ 'pay_type' => $payType, 'pay_status' => 20, 'pay_time' => time(), ]; if ($payType == OrderPayTypeEnum::WECHAT) { $order['transaction_id'] = $payData['transaction_id']; } // 更新订单状态 return $this->model->save($order); } /** * 记录订单支付信息 */ private function updatePayInfo($payType) { // 余额支付 if ($payType == OrderPayTypeEnum::BALANCE && $this->model['money'] > 0) { // 更新用户余额 $this->user->where('user_id', '=', $this->user['user_id']) ->dec('balance', $this->model['money']) ->update(); BalanceLogModel::add(BalanceLogSceneEnum::CONSUME, [ 'user_id' => $this->user['user_id'], 'money' => -$this->model['money'], ], ['order_no' => $this->model['order_no']]); } } /** * 返回shop_supplier_id * $pay_status 兼容支付宝支付 */ public function isExistSupplier() { return 0; } }