mirror of
https://github.com/ProxyPanel/ProxyPanel.git
synced 2026-04-12 23:48:53 +00:00
394 lines
16 KiB
PHP
394 lines
16 KiB
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\PaymentCallback;
|
||
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 Hash;
|
||
use Illuminate\Http\Request;
|
||
use Log;
|
||
use Mail;
|
||
|
||
/**
|
||
* 有赞云支付消息推送接收
|
||
*
|
||
* Class YzyController
|
||
*
|
||
* @package App\Http\Controllers
|
||
*/
|
||
class YzyController 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));
|
||
|
||
$json = file_get_contents('php://input');
|
||
$data = json_decode($json, true);
|
||
if (!$data) {
|
||
Log::info('YZY-POST:回调数据无法解析，可能是非法请求[' . getClientIp() . ']');
|
||
exit();
|
||
}
|
||
|
||
// 判断消息是否合法
|
||
$msg = $data['msg'];
|
||
$sign_string = self::$systemConfig['youzan_client_id'] . "" . $msg . "" . self::$systemConfig['youzan_client_secret'];
|
||
$sign = md5($sign_string);
|
||
if ($sign != $data['sign']) {
|
||
Log::info('本地签名：' . $sign_string . ' | 远程签名：' . $data['sign']);
|
||
Log::info('YZY-POST:回调数据签名错误，可能是非法请求[' . getClientIp() . ']');
|
||
exit();
|
||
} else {
|
||
// 返回请求成功标识给有赞
|
||
var_dump(["code" => 0, "msg" => "success"]);
|
||
}
|
||
|
||
// 容错
|
||
if (!isset($data['kdt_name'])) {
|
||
Log::info("【有赞云】回调数据解析错误，请检查有赞支付设置是否与有赞控制台中的信息保持一致。如果还出现此提示，请执行一遍php artisan cache:clear命令");
|
||
exit();
|
||
}
|
||
|
||
// 先写入回调日志
|
||
$this->callbackLog($data['client_id'], $data['id'], $data['kdt_id'], $data['kdt_name'], $data['mode'], $data['msg'], $data['sendCount'], $data['sign'], $data['status'], $data['test'], $data['type'], $data['version']);
|
||
|
||
// msg内容经过 urlencode 编码，进行解码
|
||
$msg = json_decode(urldecode($msg), true);
|
||
|
||
switch ($data['type']) {
|
||
case 'trade_TradePaid':
|
||
$this->tradePaid($msg);
|
||
break;
|
||
case 'trade_TradeCreate':
|
||
$this->tradeCreate($msg);
|
||
break;
|
||
case 'trade_TradeClose':
|
||
$this->tradeClose($msg);
|
||
break;
|
||
case 'trade_TradeSuccess':
|
||
$this->tradeSuccess($msg);
|
||
break;
|
||
case 'trade_TradePartlySellerShip':
|
||
$this->tradePartlySellerShip($msg);
|
||
break;
|
||
case 'trade_TradeSellerShip':
|
||
$this->tradeSellerShip($msg);
|
||
break;
|
||
case 'trade_TradeBuyerPay':
|
||
$this->tradeBuyerPay($msg);
|
||
break;
|
||
case 'trade_TradeMemoModified':
|
||
$this->tradeMemoModified($msg);
|
||
break;
|
||
default:
|
||
Log::info('【有赞云】回调无法识别，可能是没有启用[交易消息V3]接口，请到有赞云控制台启用消息推送服务');
|
||
exit();
|
||
}
|
||
|
||
exit();
|
||
}
|
||
|
||
// 交易支付
|
||
private function tradePaid($msg)
|
||
{
|
||
Log::info('【有赞云】回调交易支付');
|
||
|
||
$payment = Payment::query()->with(['order', 'order.goods'])->where('qr_id', $msg['qr_info']['qr_id'])->first();
|
||
if (!$payment) {
|
||
Log::info('【有赞云】回调订单不存在');
|
||
exit();
|
||
}
|
||
|
||
if ($payment->status != '0') {
|
||
Log::info('【有赞云】回调订单状态不正确');
|
||
exit();
|
||
}
|
||
|
||
// 处理订单
|
||
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 = $msg['full_order_info']['order_info']['pay_type_str'] == 'WEIXIN_DAIXIAO' ? 1 : 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), '[在线支付]用户购买商品，加上流量');
|
||
|
||
// 计算账号过期时间
|
||
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;
|
||
}
|
||
|
||
// 把商品的流量加到账号上
|
||
User::query()->where('id', $order->user_id)->increment('transfer_enable', $goods->traffic * 1048576);
|
||
|
||
// 套餐就改流量重置日，流量包不改
|
||
if ($goods->type == 2) {
|
||
if (date('m') == 2 && date('d') == 29) {
|
||
$traffic_reset_day = 28;
|
||
} else {
|
||
$traffic_reset_day = date('d') == 31 ? 30 : abs(date('d'));
|
||
}
|
||
User::query()->where('id', $order->user_id)->update(['traffic_reset_day' => $traffic_reset_day, '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());
|
||
}
|
||
|
||
exit();
|
||
}
|
||
|
||
// 创建交易
|
||
private function tradeCreate($msg)
|
||
{
|
||
Log::info('【有赞云】回调创建交易');
|
||
exit();
|
||
}
|
||
|
||
// 关闭交易（无视，系统自带15分钟自动关闭未支付订单的定时任务）
|
||
private function tradeClose($msg)
|
||
{
|
||
Log::info('【有赞云】回调关闭交易');
|
||
|
||
exit();
|
||
}
|
||
|
||
// 交易成功
|
||
private function tradeSuccess($msg)
|
||
{
|
||
Log::info('【有赞云】回调交易成功');
|
||
|
||
exit();
|
||
}
|
||
|
||
// 卖家部分发货
|
||
private function tradePartlySellerShip($msg)
|
||
{
|
||
Log::info('【有赞云】回调卖家部分发货');
|
||
exit();
|
||
}
|
||
|
||
// 卖家发货
|
||
private function tradeSellerShip($msg)
|
||
{
|
||
Log::info('【有赞云】回调卖家发货');
|
||
exit();
|
||
}
|
||
|
||
// 买家付款
|
||
private function tradeBuyerPay($msg)
|
||
{
|
||
Log::info('【有赞云】回调买家付款');
|
||
exit();
|
||
}
|
||
|
||
// 卖家修改交易备注
|
||
private function tradeMemoModified($msg)
|
||
{
|
||
Log::info('【有赞云】回调卖家修改交易备注');
|
||
exit();
|
||
}
|
||
|
||
public function show(Request $request)
|
||
{
|
||
exit('show');
|
||
}
|
||
|
||
// 写入回调请求日志
|
||
private function callbackLog($client_id, $yz_id, $kdt_id, $kdt_name, $mode, $msg, $sendCount, $sign, $status, $test, $type, $version)
|
||
{
|
||
$obj = new PaymentCallback();
|
||
$obj->client_id = $client_id;
|
||
$obj->yz_id = $yz_id;
|
||
$obj->kdt_id = $kdt_id;
|
||
$obj->kdt_name = $kdt_name;
|
||
$obj->mode = $mode;
|
||
$obj->msg = urldecode($msg);
|
||
$obj->sendCount = $sendCount;
|
||
$obj->sign = $sign;
|
||
$obj->status = $status;
|
||
$obj->test = $test;
|
||
$obj->type = $type;
|
||
$obj->version = $version;
|
||
$obj->save();
|
||
|
||
return $obj->id;
|
||
}
|
||
}
|