neiyou_user_web/app/Http/Controllers/Gateway/AbstractPayment.php

<?php

namespace App\Http\Controllers\Gateway;

use App\Components\Helpers;
use App\Http\Models\Goods;
use App\Http\Models\GoodsLabel;
use App\Http\Models\Order;
use App\Http\Models\Payment;
use App\Http\Models\ReferralLog;
use App\Http\Models\User;
use App\Http\Models\UserLabel;
use Illuminate\Http\Request;
use Log;

abstract class AbstractPayment {
	protected static $systemConfig;

	function __construct() {
		self::$systemConfig = Helpers::systemConfig();
	}

	public static function generateGuid() {
		mt_srand((double) microtime() * 10000);
		$charid = strtoupper(md5(uniqid(mt_rand() + time(), true)));
		$hyphen = chr(45);
		$uuid = chr(123).substr($charid, 0, 8).$hyphen.substr($charid, 8, 4).$hyphen.substr($charid, 12,
		                                                                                    4).$hyphen.substr($charid,
		                                                                                                      16,
		                                                                                                      4).$hyphen.substr($charid,
		                                                                                                                        20,
		                                                                                                                        12).chr(125);
		$uuid = str_replace(['}', '{', '-'], '', $uuid);
		$uuid = substr($uuid, 0, 8);

		return $uuid;
	}

	abstract public function purchase(Request $request);


	abstract public function notify(Request $request);

	abstract public function getReturnHTML(Request $request);

	abstract public function getPurchaseHTML();

	public function postPayment($data, $method) {
		// 获取需要的信息
		$payment = Payment::whereSn($data)->first();
		// 是否为余额购买套餐
		if($payment){
			Payment::whereSn($data)->update(['status' => 1]);
			$order = Order::find($payment->oid);
		}else{
			$order = Order::find($data);
		}
		$goods = Goods::find($order->goods_id);
		$user = User::find($order->user_id);

		//余额充值
		if($order->goods_id == -1){
			User::query()->whereId($order->user_id)->increment('balance', $order->amount * 100);
			// 余额变动记录日志
			Helpers::addUserBalanceLog($order->user_id, $order->oid, $order->user->balance,
			                           $order->user->balance + $order->amount, $order->amount, '用户'.$method.'充值余额');

			return 0;
		}

		// 商品为流量或者套餐
		switch($goods->type){
			case 1:
				$order->status = 2;
				$order->save();
				User::query()->whereId($order->user_id)->increment('transfer_enable', $goods->traffic * 1048576);
				Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable,
				                                 $user->transfer_enable + $goods->traffic * 1048576,
				                                 '['.$method.']加上用户购买的套餐流量');
				break;
			case 2:
				$activePlan = Order::query()
				                   ->whereUserId($user->id)
				                   ->with(['goods'])
				                   ->whereIsExpire(0)
				                   ->whereStatus(2)
				                   ->whereHas('goods', function($q) {
					                   $q->whereType(2);
				                   })
				                   ->exists();

				// 2为开始生效，3为预支付
				$order->status = $activePlan? 3 : 2;
				$order->save();

				if($activePlan){
					// 预支付订单, 刷新账号有效时间用于流量重置判断
					User::query()->whereId($order->user_id)->update([
						                                                'expire_time' => date('Y-m-d',
						                                                                      strtotime("+".$goods->days." days",
						                                                                                strtotime($user->expire_time)))
					                                                ]);
				}else{
					// 如果买的是套餐，则先将之前购买的套餐都无效化，重置用户已用、可用流量为0
					Order::query()->whereUserId($user->id)->with(['goods'])->whereHas('goods', function($q) {
						$q->where('type', '<=', 2);
					})->whereIsExpire(0)->whereStatus(2)->where('oid', '<>', $order->oid)->update([
						                                                                              'expire_at' => date('Y-m-d H:i:s'),
						                                                                              'is_expire' => 1
					                                                                              ]);

					User::query()->whereId($order->user_id)->update(['u' => 0, 'd' => 0, 'transfer_enable' => 0]);
					Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, 0,
					                                 '['.$method.']用户购买新套餐，先清空流量');

					$userTraffic = $goods->traffic * 1048576;
					// 添加账号有效期
					$expireTime = date('Y-m-d', strtotime("+".$goods->days." days"));
					//账号下一个重置时间
					$nextResetTime = date('Y-m-d', strtotime("+".$goods->period." days"));
					if($nextResetTime >= $expireTime){
						$nextResetTime = null;
					}

					// 写入用户标签
					if($goods->label){
						// 删除用户所有标签
						UserLabel::query()->whereUserId($order->user_id)->delete();

						//取出 商品默认标签  & 系统默认标签 去重
						$newUserLabels = array_values(array_unique(array_merge(GoodsLabel::query()
						                                                                 ->whereGoodsId($order->goods_id)
						                                                                 ->pluck('label_id')
						                                                                 ->toArray(),
						                                                       self::$systemConfig['initial_labels_for_user']? explode(',',
						                                                                                                               self::$systemConfig['initial_labels_for_user']) : [])));

						// 生成标签
						foreach($newUserLabels as $Label){
							$obj = new UserLabel();
							$obj->user_id = $order->user_id;
							$obj->label_id = $Label;
							$obj->save();
						}
					}

					User::query()->whereId($order->user_id)->increment('invite_num', $goods->invite_num?: 0, [
						'transfer_enable' => $userTraffic,
						'reset_time'      => $nextResetTime,
						'expire_time'     => $expireTime,
						'enable'          => 1
					]);
					Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, $userTraffic,
					                                 '['.$method.']加上用户购买的套餐流量');
				}

				// 是否返利
				if(self::$systemConfig['referral_type'] && $order->user->referral_uid){
					//获取历史返利记录
					$referral = ReferralLog::whereUserId($order->user_id)->get();
					// 无记录 / 首次返利
					if(!$referral && self::$systemConfig['is_invite_register']){
						// 邀请注册功能开启时，返还邀请者邀请名额
						User::query()->whereId($order->user->referral_uid)->increment('invite_num', 1);
					}
					//按照返利模式进行返利判断
					if(self::$systemConfig['referral_type'] == 2
					   || (self::$systemConfig['referral_type'] == 1
					       && !$referral)){
						$this->addReferralLog($order->user_id, $order->user->referral_uid, $order->oid, $order->amount,
						                      $order->amount * self::$systemConfig['referral_percent']);
					}
				}

				break;
			default:
				Log::info('【处理订单】出现错误-未知套餐类型');
		}

		return 0;
	}

	/**
	 * 添加返利日志
	 *
	 * @param  int  $userId     用户ID
	 * @param  int  $refUserId  返利用户ID
	 * @param  int  $oid        订单ID
	 * @param  int  $amount     发生金额
	 * @param  int  $refAmount  返利金额
	 *
	 * @return int
	 */
	private function addReferralLog($userId, $refUserId, $oid, $amount, $refAmount) {
		$log = new ReferralLog();
		$log->user_id = $userId;
		$log->ref_user_id = $refUserId;
		$log->order_id = $oid;
		$log->amount = $amount;
		$log->ref_amount = $refAmount;
		$log->status = 0;

		return $log->save();
	}
}