neiyou_user_web/app/Http/Controllers/Api/F2fpayController.php

<?php

namespace App\Http\Controllers\Api;

use App\Components\Helpers;
use App\Http\Controllers\Controller;
use App\Http\Models\Goods;
use App\Http\Models\GoodsLabel;
use App\Http\Models\Order;
use App\Http\Models\Payment;
use App\Http\Models\SsNode;
use App\Http\Models\SsNodeLabel;
use App\Http\Models\User;
use App\Http\Models\UserLabel;
use App\Mail\sendUserInfo;
use DB;
use Exception;
use Hash;
use Illuminate\Http\Request;
use Log;
use Mail;
use Payment\Client\Query;
use Payment\Common\PayException;

/**
 * Class F2fpayController
 *
 * @author  heron
 *
 * @package App\Http\Controllers\Api
 */
class F2fpayController extends Controller
{
	protected static $systemConfig;

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

	// 接收GET请求
	public function index(Request $request)
	{
		Log::info("【支付宝当面付】回调接口[GET]：".var_export($request->all(), TRUE).'['.getClientIp().']');
		exit("【支付宝当面付】接口正常");
	}

	// 接收POST请求
	public function store(Request $request)
	{
		Log::info("【支付宝当面付】回调接口[POST]：".var_export($request->all(), TRUE));

		$result = "fail";

		try{
			$verify_result = Query::run('ali_charge', [
				'use_sandbox'     => FALSE,
				"partner"         => self::$systemConfig['f2fpay_app_id'],
				'app_id'          => self::$systemConfig['f2fpay_app_id'],
				'sign_type'       => 'RSA2',
				'ali_public_key'  => self::$systemConfig['f2fpay_public_key'],
				'rsa_private_key' => self::$systemConfig['f2fpay_private_key'],
				'notify_url'      => self::$systemConfig['website_url']."/api/f2fpay", // 异步回调接口
				'return_url'      => self::$systemConfig['website_url'],
				'return_raw'      => FALSE
			], [
				'out_trade_no' => $request->input('out_trade_no'),
				'trade_no'     => $request->input('trade_no'),
			]);

			Log::info("【支付宝当面付】回调验证查询：".var_export($verify_result, TRUE));
		} catch(PayException $e){
			Log::info("【支付宝当面付】回调验证查询出错：".var_export($e->errorMessage(), TRUE));
			exit($result);
		}

		if($verify_result['is_success'] == 'T'){ // 验证成功
			$result = "success";
			if($_POST['trade_status'] == 'TRADE_FINISHED' || $_POST['trade_status'] == 'TRADE_SUCCESS'){
				// 商户订单号
				$data = [];
				$data['out_trade_no'] = $request->input('out_trade_no');
				// 支付宝交易号
				$data['trade_no'] = $request->input('trade_no');
				// 交易状态
				$data['trade_status'] = $request->input('trade_status');
				// 交易金额(这里是按照结算货币汇率的金额，和rmb_fee不相等)
				$data['total_amount'] = $request->input('total_amount');

				$this->tradePaid($data);
			}else{
				Log::info('支付宝当面付-POST:交易失败['.getClientIp().']');
			}
		}else{
			Log::info('支付宝当面付-POST:验证失败['.getClientIp().']');
		}

		// 返回验证结果
		exit($result);
	}

	// 交易支付
	private function tradePaid($msg)
	{
		Log::info('【支付宝当面付】回调交易支付');

		// 获取未完成状态的订单防止重复增加时间
		$payment = Payment::query()->with(['order', 'order.goods'])->where('status', 0)->where('order_sn', $msg['out_trade_no'])->first();
		if(!$payment){
			Log::info('【支付宝当面付】回调订单不存在');

			return;
		}

		// 处理订单
		DB::beginTransaction();
		try{
			// 如果支付单中没有用户信息则创建一个用户
			if(!$payment->user_id){
				// 生成一个可用端口
				$port = self::$systemConfig['is_rand_port']? Helpers::getRandPort() : Helpers::getOnlyPort();

				$user = new User();
				$user->username = '自动生成-'.$payment->order->email;
				$user->password = Hash::make(makeRandStr());
				$user->port = $port;
				$user->passwd = makeRandStr();
				$user->vmess_id = createGuid();
				$user->enable = 1;
				$user->method = Helpers::getDefaultMethod();
				$user->protocol = Helpers::getDefaultProtocol();
				$user->obfs = Helpers::getDefaultObfs();
				$user->usage = 1;
				$user->transfer_enable = 1; // 新创建的账号给1，防止定时任务执行时发现u + d >= transfer_enable被判为流量超限而封禁
				$user->enable_time = date('Y-m-d');
				$user->expire_time = date('Y-m-d', strtotime("+".$payment->order->goods->days." days"));
				$user->reg_ip = getClientIp();
				$user->referral_uid = 0;
				$user->traffic_reset_day = 0;
				$user->status = 1;
				$user->save();

				if($user->id){
					Order::query()->where('oid', $payment->oid)->update(['user_id' => $user->id]);
				}
			}

			// 更新支付单
			$payment->pay_way = 2; // 1-微信、2-支付宝
			$payment->status = 1;
			$payment->save();

			// 更新订单
			$order = Order::query()->with(['user'])->where('oid', $payment->oid)->first();
			$order->status = 2;
			$order->save();

			$goods = Goods::query()->where('id', $order->goods_id)->first();

			// 商品为流量或者套餐
			if($goods->type <= 2){
				// 如果买的是套餐，则先将之前购买的所有套餐置都无效，并扣掉之前所有套餐的流量，重置用户已用流量为0
				if($goods->type == 2){
					$existOrderList = Order::query()
						->with(['goods'])
						->whereHas('goods', function($q){
							$q->where('type', 2);
						})
						->where('user_id', $order->user_id)
						->where('oid', '<>', $order->oid)
						->where('is_expire', 0)
						->where('status', 2)
						->get();

					foreach($existOrderList as $vo){
						Order::query()->where('oid', $vo->oid)->update(['is_expire' => 1]);

						// 先判断，防止手动扣减过流量的用户流量被扣成负数
						if($order->user->transfer_enable-$vo->goods->traffic*1048576 <= 0){
							// 写入用户流量变动记录
							Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, 0, 0, '[在线支付]用户购买套餐，先扣减之前套餐的流量(扣完)');

							User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0, 'transfer_enable' => 0]);
						}else{
							// 写入用户流量变动记录
							$user = User::query()->where('id', $order->user_id)->first(); // 重新取出user信息
							Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, ($user->transfer_enable-$vo->goods->traffic*1048576), '[在线支付]用户购买套餐，先扣减之前套餐的流量(未扣完)');

							User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0]);
							User::query()->where('id', $order->user_id)->decrement('transfer_enable', $vo->goods->traffic*1048576);
						}
					}
				}

				// 写入用户流量变动记录
				$user = User::query()->where('id', $order->user_id)->first(); // 重新取出user信息
				Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $user->transfer_enable, ($user->transfer_enable+$goods->traffic*1048576), '[在线支付]用户购买商品，加上流量');

				// 把商品的流量加到账号上
				User::query()->where('id', $order->user_id)->increment('transfer_enable', $goods->traffic*1048576);

				// 计算账号过期时间
				if($order->user->expire_time < date('Y-m-d', strtotime("+".$goods->days." days"))){
					$expireTime = date('Y-m-d', strtotime("+".$goods->days." days"));
				}else{
					$expireTime = $order->user->expire_time;
				}

				// 套餐就改流量重置日，流量包不改
				if($goods->type == 2){
					User::query()->where('id', $order->user_id)->update(['traffic_reset_day' =>  date('d'), 'expire_time' => $expireTime, 'enable' => 1]);
				}else{
					User::query()->where('id', $order->user_id)->update(['expire_time' => $expireTime, 'enable' => 1]);
				}

				// 写入用户标签
				if($goods->label){
					// 用户默认标签
					$defaultLabels = [];
					if(self::$systemConfig['initial_labels_for_user']){
						$defaultLabels = explode(',', self::$systemConfig['initial_labels_for_user']);
					}

					// 取出现有的标签
					$userLabels = UserLabel::query()->where('user_id', $order->user_id)->pluck('label_id')->toArray();
					$goodsLabels = GoodsLabel::query()->where('goods_id', $order->goods_id)->pluck('label_id')->toArray();

					// 标签去重
					$newUserLabels = array_values(array_unique(array_merge($userLabels, $goodsLabels, $defaultLabels)));

					// 删除用户所有标签
					UserLabel::query()->where('user_id', $order->user_id)->delete();

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

				// 写入返利日志
				if($order->user->referral_uid){
					$this->addReferralLog($order->user_id, $order->user->referral_uid, $order->oid, $order->amount, $order->amount*self::$systemConfig['referral_percent']);
				}

				// 取消重复返利
				User::query()->where('id', $order->user_id)->update(['referral_uid' => 0]);
			}elseif($goods->type == 3){ // 商品为在线充值
				User::query()->where('id', $order->user_id)->increment('balance', $goods->price*100);

				// 余额变动记录日志
				$this->addUserBalanceLog($order->user_id, $order->oid, $order->user->balance, $order->user->balance+$goods->price, $goods->price, '用户在线充值');
			}

			// 自动提号机：如果order的email值不为空
			if($order->email){
				$title = '自动发送账号信息';
				$content = [
					'order_sn'      => $order->order_sn,
					'goods_name'    => $order->goods->name,
					'goods_traffic' => flowAutoShow($order->goods->traffic*1048576),
					'port'          => $order->user->port,
					'passwd'        => $order->user->passwd,
					'method'        => $order->user->method,
					//'protocol'       => $order->user->protocol,
					//'protocol_param' => $order->user->protocol_param,
					//'obfs'           => $order->user->obfs,
					//'obfs_param'     => $order->user->obfs_param,
					'created_at'    => $order->created_at->toDateTimeString(),
					'expire_at'     => $order->expire_at
				];

				// 获取可用节点列表
				$labels = UserLabel::query()->where('user_id', $order->user_id)->get()->pluck('label_id');
				$nodeIds = SsNodeLabel::query()->whereIn('label_id', $labels)->get()->pluck('node_id');
				$nodeList = SsNode::query()->whereIn('id', $nodeIds)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get()->toArray();
				$content['serverList'] = $nodeList;

				$logId = Helpers::addEmailLog($order->email, $title, json_encode($content));
				Mail::to($order->email)->send(new sendUserInfo($logId, $content));
			}

			DB::commit();
		} catch(Exception $e){
			DB::rollBack();
			Log::info('【支付宝当面付】回调更新支付单和订单异常：'.$e->getMessage());
		}
	}

	public function show(Request $request)
	{
		exit('show');
	}
}