neiyou_user_web/app/Services/OrderService.php

<?php

namespace App\Services;

use App\Components\Helpers;
use App\Models\Order;
use App\Models\ReferralLog;
use App\Models\User;
use Log;

class OrderService {
	public static $order;
	public static $user;
	public static $goods;
	public static $payment;

	public function __construct(Order $order) {
		// 获取需要的信息
		self::$order = $order;
		self::$user = $order->user;
		self::$goods = $order->goods;
		self::$payment = $order->payment;
	}

	// 支付成功后处理
	public function receivedPayment(): bool {
		if(self::$payment){// 是否为余额购买套餐
			if(self::$payment->status === 1){// 已处理
				return true;
			}
			self::$payment->update(['status' => 1]);

			// 余额充值
			if(self::$order->goods_id === 0 || self::$order->goods_id === null){
				return $this->chargeCredit();
			}
		}

		$goods = self::$order->goods;
		switch($goods->type){// 商品为流量或者套餐
			case 1:// 流量包
				$this->activatePackage();
				break;
			case 2:// 套餐
				if(Order::userActivePlan(self::$user->id)->where('id', '<>', self::$order->id)->exists()){// 判断套餐是否直接激活
					$this->setPrepaidPlan();
				}else{
					$this->activatePlan();
				}
				$this->setCommissionExpense(self::$user);// 返利
				break;
			default:
				Log::error('【处理订单】出现错误-未知套餐类型');
		}

		return true;
	}

	// 余额充值
	private function chargeCredit(): bool {
		$credit = self::$user->credit;
		$ret = (new UserService(self::$user))->updateCredit(self::$order->origin_amount);
		// 余额变动记录日志
		if($ret){
			Helpers::addUserCreditLog(self::$order->user_id, self::$order->id, $credit, self::$user->credit,
				self::$order->amount, '用户通过'.self::$order->pay_way.'充值余额');
		}

		return $ret;
	}

	// 激活流量包
	private function activatePackage(): bool {
		$ret = (new UserService(self::$user))->incrementData(self::$goods->traffic * MB);
		if($ret){
			return Helpers::addUserTrafficModifyLog(self::$order->user_id, self::$order->id,
				self::$user->transfer_enable - self::$goods->traffic * MB, self::$user->transfer_enable,
				'['.self::$order->pay_way.']加上用户购买的套餐流量');
		}

		return false;
	}

	// 设置预支付套餐
	private function setPrepaidPlan(): bool {
		self::$order->status = 3;// 3为预支付
		// 预支付订单, 刷新账号有效时间用于流量重置判断
		return self::$order->save()
		       && self::$user->update([
				'expired_at' => date('Y-m-d', strtotime(self::$user->expired_at." +".self::$goods->days." days"))
			]);
	}

	// 激活套餐
	private function activatePlan(): bool {
		Order::whereId(self::$order->id)->update([
			'expired_at' => date('Y-m-d H:i:s', strtotime("+".self::$goods->days." days"))
		]);
		$oldData = self::$user->transfer_enable;
		$ret = self::$user->update(array_merge($this->resetTimeAndData(), [
			'invite_num' => self::$user->invite_num + (self::$goods->invite_num?: 0),
			'level'      => self::$goods->level,
			'enable'     => 1
		]));
		if($ret){
			return Helpers::addUserTrafficModifyLog(self::$order->user_id, self::$order->id, $oldData,
				self::$user->transfer_enable, '【'.self::$order->pay_way.'】加上用户购买的套餐流量');
		}

		return false;
	}

	// 计算下次重置与账号过期时间
	public function resetTimeAndData($expired_at = null): array {
		$data = ['u' => 0, 'd' => 0];
		// 账号有效期
		if(!$expired_at){
			$expired_at = date('Y-m-d', strtotime("+".self::$goods->days." days"));
			foreach(Order::userPrepay(self::$order->user_id)->get() as $paidOrder){//拿出可能存在的其余套餐, 推算最新的到期时间
				//取出对应套餐信息
				$expired_at = date('Y-m-d', strtotime("$expired_at +".$paidOrder->goods->days." days"));
			}
			$data['expired_at'] = $expired_at;
		}

		//账号流量重置日期
		$nextResetTime = date('Y-m-d', strtotime("+".self::$goods->period." days"));
		if($nextResetTime >= $expired_at){
			$nextResetTime = null;
		}

		return array_merge($data, [
			'transfer_enable' => self::$goods->traffic * MB,
			'reset_time'      => $nextResetTime
		]);
	}

	// 佣金计算
	private function setCommissionExpense(User $user): bool {
		$referralType = sysConfig('referral_type');

		if($referralType && $user->inviter_id){// 是否需要支付佣金
			$inviter = $user->inviter;
			// 获取历史返利记录
			$referral = ReferralLog::whereInviteeId(self::$order->user_id)->doesntExist();
			// 无记录 / 首次返利
			if($referral && sysConfig('is_invite_register')){
				// 邀请注册功能开启时，返还邀请者邀请名额
				$inviter->update(['invite_num' => $inviter->invite_num + 1]);
			}
			// 按照返利模式进行返利判断
			if($referralType == 2 || $referral){
				return $this->addReferralLog($user->id, $inviter->id, self::$order->id, self::$order->amount,
					self::$order->amount * sysConfig('referral_percent'));
			}
		}
		return true;
	}

	/**
	 * 添加返利日志
	 *
	 * @param  int  $inviteeId   用户ID
	 * @param  int  $inviterId   返利对象ID
	 * @param  int  $oid         订单ID
	 * @param  int  $amount      发生金额
	 * @param  int  $commission  返利金额
	 *
	 * @return bool
	 */
	private function addReferralLog($inviteeId, $inviterId, $oid, $amount, $commission): bool {
		$log = new ReferralLog();
		$log->invitee_id = $inviteeId;
		$log->inviter_id = $inviterId;
		$log->order_id = $oid;
		$log->amount = $amount;
		$log->commission = $commission;
		$log->status = 0;

		return $log->save();
	}

	// 激活预支付套餐
	public function activatePrepaidPlan(): bool {
		self::$order->update([
			'expired_at' => date("Y-m-d H:i:s", strtotime("+".self::$goods->days." days")),
			'status'     => 2
		]);

		return $this->activatePlan();
	}
}