orderNo = $orderNo; $this->attach = $attach; // 实例化订单模型 $this->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 = []) { // 事务处理 $this->model->transaction(function () use ($payType, $payData) { // 更新订单状态 $this->updateOrderInfo($payType, $payData); // 累积用户总消费金额 $this->user->setIncPayMoney($this->model['pay_price']); // 记录订单支付信息 $this->updatePayInfo(); // 更新报名人数 $this->updateActivityTotal(); }); return true; } /** * 更新订单记录 */ private function updateOrderInfo($payType, $payData) { // 整理订单信息 $order = [ 'pay_type' => $payType, 'status' => 1 ]; if ($this->model['online_money'] == 0) { if ($this->model['balance'] > 0) { $order['pay_type'] = OrderPayTypeEnum::BALANCE; } else { $order['pay_type'] = OrderPayTypeEnum::POINTS; } } if ($this->model['total_price'] > 0) { $order['pay_status'] = 20; $order['pay_time'] = time(); } else { $order['pay_type'] = 0; } if (isset($payData['attach'])) { $attach = json_decode($payData['attach'], true); if(isset($attach['pay_source'])){ $order['pay_source'] = $attach['pay_source']; } } if ($payType == OrderPayTypeEnum::WECHAT || $payType == OrderPayTypeEnum::ALIPAY) { $order['transaction_id'] = $payData['transaction_id']; } // 如果是在活动范围内报名,直接签到 if ($this->model['in_radius'] == 1) { $order['is_verify'] = 1; $order['verify_time'] = time(); } // 更新订单状态 return $this->model->save($order); } /** * 记录订单支付信息 */ private function updatePayInfo() { // 积分抵扣 if ($this->model['points_num'] > 0) { $describe = "活动报名消费:{$this->model['order_no']}"; $this->user->setIncPoints(-$this->model['points_num'], $describe); } // 余额支付 if ($this->model['balance'] > 0) { // 更新用户余额 $this->user->where('user_id', '=', $this->user['user_id']) ->dec('balance', $this->model['balance']) ->update(); BalanceLogModel::add(BalanceLogSceneEnum::CONSUME, [ 'user_id' => $this->user['user_id'], 'money' => -$this->model['balance'], ], ['order_no' => $this->model['order_no']]); } } /** * 更新报名人数 */ private function updateActivityTotal() { ActivityModel::incTotal($this->model['activity_id']); } /** * 返回app_id,大于0则存在订单信息 * $pay_status 兼容支付宝支付 */ public function isExist($pay_status = 10) { // 订单信息 $app_id = 0; $params = ['trade_no' => $this->orderNo, 'is_delete' => 0]; if ($pay_status == 10) { $params['pay_status'] = 10; } $order = OrderModel::detail($params, []); !empty($order) && $app_id = $order['app_id']; return $app_id; } }