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['activity_fee']) { $this->error = '用户余额不足,无法使用余额支付'; return false; } } // 事务处理 $this->model->transaction(function () use ($payType, $payData) { // 更新支付状态 $this->updateOrderInfo($payType, $payData); // 累积用户总消费金额 $this->user->setIncPayMoney($this->model['activity_fee']); // 记录余额支付信息 $this->updatePayInfo($payType); }); return true; } /** * 更新订单记录 */ private function updateOrderInfo($payType, $payData) { $order = [ 'pay_type' => $payType, 'pay_status' => 20, 'status' => 1, '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['activity_fee'] > 0) { // 更新用户余额 $this->user->where('user_id', '=', $this->user['user_id']) ->dec('balance', $this->model['activity_fee']) ->update(); BalanceLogModel::add(BalanceLogSceneEnum::CONSUME, [ 'user_id' => $this->user['user_id'], 'money' => -$this->model['activity_fee'], ], ['order_no' => $this->model['order_no']]); } } /** * 返回shop_supplier_id * $pay_status 兼容支付宝支付 */ public function isExistSupplier() { return 0; } }