{

protected static $systemConfig;

function __construct()

{

self::$systemConfig = Helpers::systemConfig();

}

public function index(Request $request)

{

$user = User::query()->where('id', Auth::user()->id)->first();

$user->totalTransfer = flowAutoShow($user->transfer_enable);

$user->usedTransfer = flowAutoShow($user->u + $user->d);

$user->usedPercent = $user->transfer_enable > 0 ? round(($user->u + $user->d) / $user->transfer_enable, 2) : 1;

$user->levelName = Level::query()->where('level', $user['level'])->first()['level_name'];

$view['info'] = $user->toArray();

$view['notice'] = Article::query()->where('type', 2)->where('is_del', 0)->orderBy('id', 'desc')->first();

$view['ipa_list'] = 'itms-services://?action=download-manifest&url=' . self::$systemConfig['website_url'] . '/clients/ipa.plist';

$view['goodsList'] = Goods::query()->where('type', 3)->where('status', 1)->where('is_del', 0)->orderBy('sort', 'desc')->orderBy('price', 'asc')->limit(10)->get(); // 余额充值商品，只取10个

$view['userLoginLog'] = UserLoginLog::query()->where('user_id', Auth::user()->id)->orderBy('id', 'desc')->limit(5)->get(); // 近期登录日志

// 推广返利是否可见

if (!Session::has('referral_status')) {

Session::put('referral_status', self::$systemConfig['referral_status']);

}

// 订阅码

$subscribe = UserSubscribe::query()->where('user_id', Auth::user()->id)->first();

$view['subscribe_status'] = $subscribe->status;

$view['link'] = (self::$systemConfig['subscribe_domain'] ? self::$systemConfig['subscribe_domain'] : self::$systemConfig['website_url']) . '/s/' . $subscribe->code;

// 节点列表

$userLabelIds = UserLabel::query()->where('user_id', Auth::user()->id)->pluck('label_id');

if (empty($userLabelIds)) {

$view['nodeList'] = [];

return Response::view('user.index', $view);

}

$nodeList = DB::table('ss_node')

->selectRaw('ss_node.*')

->leftJoin('ss_node_label', 'ss_node.id', '=', 'ss_node_label.node_id')

->whereIn('ss_node_label.label_id', $userLabelIds)

->where('ss_node.status', 1)

->groupBy('ss_node.id')

->orderBy('ss_node.sort', 'desc')

->orderBy('ss_node.id', 'asc')

->get();

$allNodes = ''; // 全部节点SSR链接，用于一键复制所有节点

foreach ($nodeList as &$node) {

// 获取分组名称

$group = SsGroup::query()->where('id', $node->group_id)->first();

if ($node->type == 1) {

// 生成ssr scheme

$obfs_param = $user->obfs_param ? $user->obfs_param : $node->obfs_param;

$protocol_param = $node->single ? $user->port . ':' . $user->passwd : $user->protocol_param;

$ssr_str = ($node->server ? $node->server : $node->ip) . ':' . ($node->single ? $node->single_port : $user->port);

$ssr_str .= ':' . ($node->single ? $node->single_protocol : $user->protocol) . ':' . ($node->single ? $node->single_method : $user->method);

$ssr_str .= ':' . ($node->single ? $node->single_obfs : $user->obfs) . ':' . ($node->single ? base64url_encode($node->single_passwd) : base64url_encode($user->passwd));

$ssr_str .= '/?obfsparam=' . base64url_encode($obfs_param);

$ssr_str .= '&protoparam=' . ($node->single ? base64url_encode($user->port . ':' . $user->passwd) : base64url_encode($protocol_param));

$ssr_str .= '&remarks=' . base64url_encode($node->name);

$ssr_str .= '&group=' . base64url_encode(empty($group) ? '' : $group->name);

$ssr_str .= '&udpport=0';

$ssr_str .= '&uot=0';

$ssr_str = base64url_encode($ssr_str);

$ssr_scheme = 'ssr://' . $ssr_str;

// 生成ss scheme

$ss_str = $user->method . ':' . $user->passwd . '@';

$ss_str .= ($node->server ? $node->server : $node->ip) . ':' . $user->port;

$ss_str = base64url_encode($ss_str) . '#' . 'VPN';

$ss_scheme = 'ss://' . $ss_str;

// 生成文本配置信息

$txt = "服务器：" . ($node->server ? $node->server : $node->ip) . "\r\n";

if ($node->ipv6) {

$txt .= "IPv6：" . $node->ipv6 . "\r\n";

}

$txt .= "远程端口：" . ($node->single ? $node->single_port : $user->port) . "\r\n";

$txt .= "密码：" . ($node->single ? $node->single_passwd : $user->passwd) . "\r\n";

$txt .= "加密方法：" . ($node->single ? $node->single_method : $user->method) . "\r\n";

$txt .= "路由：绕过局域网及中国大陆地址" . "\r\n\r\n";

$txt .= "协议：" . ($node->single ? $node->single_protocol : $user->protocol) . "\r\n";

$txt .= "协议参数：" . ($node->single ? $user->port . ':' . $user->passwd : $user->protocol_param) . "\r\n";

$txt .= "混淆方式：" . ($node->single ? $node->single_obfs : $user->obfs) . "\r\n";

$txt .= "混淆参数：" . ($user->obfs_param ? $user->obfs_param : $node->obfs_param) . "\r\n";

$txt .= "本地端口：1080" . "\r\n";

$node->txt = $txt;

$node->ssr_scheme = $ssr_scheme;

$node->ss_scheme = $node->compatible ? $ss_scheme : ''; // 节点兼容原版才显示

$allNodes .= $ssr_scheme . '|';

} else {

// 生成v2ray scheme

$v2_json = [

"v" => "2",

"ps" => $node->name,

"add" => $node->server ? $node->server : $node->ip,

"port" => $node->v2_port,

"id" => $user->vmess_id,

"aid" => $node->v2_alter_id,

"net" => $node->v2_net,

"type" => $node->v2_type,

"host" => $node->v2_host,

"path" => $node->v2_path,

"tls" => $node->v2_tls == 1 ? "tls" : ""

];

$v2_scheme = 'vmess://' . base64url_encode(json_encode($v2_json));

// 生成文本配置信息

$txt = "服务器：" . ($node->server ? $node->server : $node->ip) . "\r\n";

if ($node->ipv6) {

$txt .= "IPv6：" . $node->ipv6 . "\r\n";

}

$txt .= "端口：" . $node->v2_port . "\r\n";

$txt .= "加密方式：" . $node->v2_method . "\r\n";

$txt .= "用户ID：" . $user->vmess_id . "\r\n";

$txt .= "额外ID：" . $node->v2_alter_id . "\r\n";

$txt .= "传输协议：" . $node->v2_net . "\r\n";

$txt .= "伪装类型：" . $node->v2_type . "\r\n";

$txt .= $node->v2_host ? "伪装域名：" . $node->v2_host . "\r\n" : "";

$txt .= $node->v2_path ? "路径：" . $node->v2_path . "\r\n" : "";

$txt .= $node->v2_tls ? "TLS：tls\r\n" : "";

$node->txt = $txt;

$node->v2_scheme = $v2_scheme;

}

// 节点在线状态

$nodeInfo = SsNodeInfo::query()->where('node_id', $node->id)->where('log_time', '>=', strtotime("-10 minutes"))->orderBy('id', 'desc')->first();

$node->online_status = empty($nodeInfo) || empty($nodeInfo->load) ? 0 : 1;

// 节点标签

$node->labels = SsNodeLabel::query()->with('labelInfo')->where('node_id', $node->id)->get();

}

$view['allNodes'] = rtrim($allNodes, "|");

$view['nodeList'] = $nodeList;

return Response::view('user.index', $view);

}

// 公告详情

public function article(Request $request)

{

$id = $request->get('id');

$view['info'] = Article::query()->where('is_del', 0)->where('id', $id)->first();

if (empty($view['info'])) {

return Redirect::to('/');

}

return Response::view('user.article', $view);

}

// 修改个人资料

public function profile(Request $request)

{

if ($request->method() == 'POST') {

$old_password = trim($request->get('old_password'));

$new_password = trim($request->get('new_password'));

$wechat = $request->get('wechat');

$qq = $request->get('qq');

$passwd = trim($request->get('passwd'));

// 修改密码

if ($old_password && $new_password) {

if (!Hash::check($old_password, Auth::user()->password)) {

Session::flash('errorMsg', '旧密码错误，请重新输入');

return Redirect::to('profile#tab_1');

} elseif (Hash::check($new_password, Auth::user()->password)) {

Session::flash('errorMsg', '新密码不可与旧密码一样，请重新输入');

return Redirect::to('profile#tab_1');

}

// 演示环境禁止改管理员密码

if (env('APP_DEMO') && Auth::user()->id == 1) {

Session::flash('errorMsg', '演示环境禁止修改管理员密码');

return Redirect::to('profile#tab_1');

}

$ret = User::query()->where('id', Auth::user()->id)->update(['password' => Hash::make($new_password)]);

if (!$ret) {

Session::flash('errorMsg', '修改失败');

return Redirect::to('profile#tab_1');

} else {

Session::flash('successMsg', '修改成功');

return Redirect::to('profile#tab_1');

}

}

// 修改联系方式

if ($wechat || $qq) {

if (empty(clean($wechat)) && empty(clean($qq))) {

Session::flash('errorMsg', '修改失败');

return Redirect::to('profile#tab_2');

}

$ret = User::query()->where('id', Auth::user()->id)->update(['wechat' => $wechat, 'qq' => $qq]);

if (!$ret) {

Session::flash('errorMsg', '修改失败');

return Redirect::to('profile#tab_2');

} else {

Session::flash('successMsg', '修改成功');

return Redirect::to('profile#tab_2');

}

}

// 修改代理密码

if ($passwd) {

$ret = User::query()->where('id', Auth::user()->id)->update(['passwd' => $passwd]);

if (!$ret) {

Session::flash('errorMsg', '修改失败');

return Redirect::to('profile#tab_3');

} else {

Session::flash('successMsg', '修改成功');

return Redirect::to('profile#tab_3');

}

}

Session::flash('errorMsg', '非法请求');

return Redirect::to('profile#tab_1');

} else {

$view['info'] = User::query()->where('id', Auth::user()->id)->first();

return Response::view('user.profile', $view);

}

}

// 流量日志

public function trafficLog(Request $request)

{

$dailyData = [];

$hourlyData = [];

// 节点一个月内的流量

$userTrafficDaily = UserTrafficDaily::query()->where('user_id', Auth::user()->id)->where('node_id', 0)->where('created_at', '>=', date('Y-m', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();

$dailyTotal = date('d', time()) - 1; // 今天不算，减一

$dailyCount = count($userTrafficDaily);

for ($x = 0; $x < ($dailyTotal - $dailyCount); $x++) {

$dailyData[$x] = 0;

}

for ($x = ($dailyTotal - $dailyCount); $x < $dailyTotal; $x++) {

$dailyData[$x] = round($userTrafficDaily[$x - ($dailyTotal - $dailyCount)] / (1024 * 1024 * 1024), 3);

}

// 节点一天内的流量

$userTrafficHourly = UserTrafficHourly::query()->where('user_id', Auth::user()->id)->where('node_id', 0)->where('created_at', '>=', date('Y-m-d', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();

$hourlyTotal = date('H', time());

$hourlyCount = count($userTrafficHourly);

for ($x = 0; $x < ($hourlyTotal - $hourlyCount); $x++) {

$hourlyData[$x] = 0;

}

for ($x = ($hourlyTotal - $hourlyCount); $x < $hourlyTotal; $x++) {

$hourlyData[$x] = round($userTrafficHourly[$x - ($hourlyTotal - $hourlyCount)] / (1024 * 1024 * 1024), 3);

}

// 本月天数数据

$monthDays = [];

$monthHasDays = date("t");

for ($i = 1; $i <= $monthHasDays; $i++) {

$monthDays[] = $i;

}

$view['trafficDaily'] = "'" . implode("','", $dailyData) . "'";

$view['trafficHourly'] = "'" . implode("','", $hourlyData) . "'";

$view['monthDays'] = "'" . implode("','", $monthDays) . "'";

return Response::view('user.trafficLog', $view);

}

// 商品列表

public function services(Request $request)

{

$view['goodsList'] = Goods::query()->where('status', 1)->where('is_del', 0)->where('type', '<=', '2')->orderBy('type', 'desc')->orderBy('sort', 'desc')->paginate(10)->appends($request->except('page'));

return Response::view('user.services', $view);

}

// 工单

public function ticketList(Request $request)

{

$view['ticketList'] = Ticket::query()->where('user_id', Auth::user()->id)->orderBy('id', 'desc')->paginate(10)->appends($request->except('page'));

return Response::view('user.ticketList', $view);

}

// 订单

public function invoices(Request $request)

{

$view['orderList'] = Order::query()->with(['user', 'goods', 'coupon', 'payment'])->where('user_id', Auth::user()->id)->orderBy('oid', 'desc')->paginate(10)->appends($request->except('page'));

return Response::view('user.invoices', $view);

}

// 订单明细

public function invoiceDetail(Request $request, $sn)

{

$view['order'] = Order::query()->with(['goods', 'coupon', 'payment'])->where('order_sn', $sn)->firstOrFail();

return Response::view('user.invoiceDetail', $view);

}

// 添加工单

public function addTicket(Request $request)

{

$title = $request->get('title');

$content = clean($request->get('content'));

$content = str_replace("eval", "", str_replace("atob", "", $content));

if (empty($title) || empty($content)) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '请输入标题和内容']);

}

$obj = new Ticket();

$obj->user_id = Auth::user()->id;

$obj->title = $title;

$obj->content = $content;

$obj->status = 0;

$obj->save();

if ($obj->id) {

$emailTitle = "新工单提醒";

$content = "标题：【" . $title . "】<br>内容：" . $content;

// 发邮件通知管理员

if (self::$systemConfig['crash_warning_email']) {

try {

Mail::to(self::$systemConfig['crash_warning_email'])->send(new newTicket($emailTitle, $content));

Helpers::addEmailLog(self::$systemConfig['crash_warning_email'], $emailTitle, $content);

} catch (\Exception $e) {

Helpers::addEmailLog(self::$systemConfig['crash_warning_email'], $emailTitle, $content, 0, $e->getMessage());

}

}

ServerChan::send($emailTitle, $content);

return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);

} else {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '提交失败']);

}

}

// 回复工单

public function replyTicket(Request $request)

{

$id = intval($request->get('id'));

$ticket = Ticket::query()->with('user')->where('id', $id)->first();

if (empty($ticket) || $ticket->user_id != Auth::user()->id) {

return Redirect::to('tickets');

}

if ($request->method() == 'POST') {

$content = clean($request->get('content'));

$content = str_replace("eval", "", str_replace("atob", "", $content));

$content = substr($content, 0, 300);

if (empty($content)) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '回复内容不能为空']);

}

$obj = new TicketReply();

$obj->ticket_id = $id;

$obj->user_id = Auth::user()->id;

$obj->content = $content;

$obj->save();

if ($obj->id) {

// 重新打开工单

$ticket->status = 0;

$ticket->save();

$title = "工单回复提醒";

$content = "标题：【" . $ticket->title . "】<br>用户回复：" . $content;

// 发邮件通知管理员

if (self::$systemConfig['crash_warning_email']) {

try {

Mail::to(self::$systemConfig['crash_warning_email'])->send(new replyTicket($title, $content));

Helpers::addEmailLog(self::$systemConfig['crash_warning_email'], $title, $content);

} catch (\Exception $e) {

Helpers::addEmailLog(self::$systemConfig['crash_warning_email'], $title, $content, 0, $e->getMessage());

}

}

ServerChan::send($title, $content);

return Response::json(['status' => 'success', 'data' => '', 'message' => '回复成功']);

} else {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '回复失败']);

}

} else {

$view['ticket'] = $ticket;

$view['replyList'] = TicketReply::query()->where('ticket_id', $id)->with('user')->orderBy('id', 'asc')->get();

return Response::view('user.replyTicket', $view);

}

}

// 关闭工单

public function closeTicket(Request $request)

{

$id = $request->get('id');

$ret = Ticket::query()->where('id', $id)->where('user_id', Auth::user()->id)->update(['status' => 2]);

if ($ret) {

ServerChan::send('工单关闭提醒', '工单：ID' . $id . '客户已手动关闭');

return Response::json(['status' => 'success', 'data' => '', 'message' => '关闭成功']);

} else {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '关闭失败']);

}

}

// 邀请码

public function invite(Request $request)

{

// 已生成的邀请码数量

$num = Invite::query()->where('uid', Auth::user()->id)->count();

$view['num'] = self::$systemConfig['invite_num'] - $num <= 0 ? 0 : self::$systemConfig['invite_num'] - $num; // 还可以生成的邀请码数量

$view['inviteList'] = Invite::query()->where('uid', Auth::user()->id)->with(['generator', 'user'])->paginate(10); // 邀请码列表

$view['referral_traffic'] = flowAutoShow(self::$systemConfig['referral_traffic'] * 1048576);

$view['referral_percent'] = self::$systemConfig['referral_percent'];

return Response::view('user.invite', $view);

}

// 生成邀请码

public function makeInvite(Request $request)

{

// 已生成的邀请码数量

$num = Invite::query()->where('uid', Auth::user()->id)->count();

if ($num >= self::$systemConfig['invite_num']) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '生成失败：最多只能生成' . self::$systemConfig['invite_num'] . '个邀请码']);

}

$obj = new Invite();

$obj->uid = Auth::user()->id;

$obj->fuid = 0;

$obj->code = strtoupper(mb_substr(md5(microtime() . makeRandStr()), 8, 12));

$obj->status = 0;

$obj->dateline = date('Y-m-d H:i:s', strtotime("+7 days"));

$obj->save();

return Response::json(['status' => 'success', 'data' => '', 'message' => '生成成功']);

}

// 使用优惠券

public function redeemCoupon(Request $request)

{

$coupon_sn = $request->get('coupon_sn');

if (empty($coupon_sn)) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '优惠券不能为空']);

}

$coupon = Coupon::query()->where('sn', $coupon_sn)->whereIn('type', [1, 2])->where('is_del', 0)->first();

if (!$coupon) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券不存在']);

} elseif ($coupon->status == 1) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已使用，请换一个试试']);

} elseif ($coupon->status == 2) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已失效，请换一个试试']);

} elseif ($coupon->available_end < time()) {

$coupon->status = 2;

$coupon->save();

return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已失效，请换一个试试']);

} elseif ($coupon->available_start > time()) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券尚不可用，请换一个试试']);

}

$data = [

'type' => $coupon->type,

'amount' => $coupon->amount,

'discount' => $coupon->discount

];

return Response::json(['status' => 'success', 'data' => $data, 'message' => '该优惠券有效']);

}

// 购买服务

public function buy(Request $request, $id)

{

$goods_id = intval($id);

$coupon_sn = $request->get('coupon_sn');

if ($request->method() == 'POST') {

$goods = Goods::query()->with(['label'])->where('is_del', 0)->where('status', 1)->where('id', $goods_id)->first();

if (!$goods) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败：商品或服务已下架']);

}

// 限购控制：all-所有商品限购, free-价格为0的商品限购, none-不限购（默认）

$strategy = self::$systemConfig['goods_purchase_limit_strategy'];

if ($strategy == 'all' || ($strategy == 'package' && $goods->type == 2) || ($strategy == 'free' && $goods->price == 0) || ($strategy == 'package&free' && ($goods->type == 2 || $goods->price == 0))) {

$noneExpireGoodExist = Order::query()->where('status', '>=', 0)->where('is_expire', 0)->where('user_id', Auth::user()->id)->where('goods_id', $goods_id)->exists();

if ($noneExpireGoodExist) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败：商品不可重复购买']);

}

}

// 单个商品限购

if ($goods->is_limit == 1) {

$noneExpireOrderExist = Order::query()->where('status', '>=', 0)->where('user_id', Auth::user()->id)->where('goods_id', $goods_id)->exists();

if ($noneExpireOrderExist) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '创建支付单失败：此商品每人限购1次']);

}

}

// 使用优惠券

if (!empty($coupon_sn)) {

$coupon = Coupon::query()->where('status', 0)->where('is_del', 0)->whereIn('type', [1, 2])->where('sn', $coupon_sn)->first();

if (empty($coupon)) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败：优惠券不存在']);

}

// 计算实际应支付总价

$amount = $coupon->type == 2 ? $goods->price * $coupon->discount / 10 : $goods->price - $coupon->amount;

$amount = $amount > 0 ? $amount : 0;

} else {

$amount = $goods->price;

}

// 价格异常判断

if ($amount < 0) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败：订单总价异常']);

}

// 验证账号余额是否充足

$user = User::query()->where('id', Auth::user()->id)->first();

if ($user->balance < $amount) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败：您的余额不足，请先充值']);

}

// 验证账号是否存在有效期更长的套餐

if ($goods->type == 2) {

$existOrderList = Order::query()

->with(['goods'])

->whereHas('goods', function ($q) {

$q->where('type', 2);

})

->where('user_id', Auth::user()->id)

->where('is_expire', 0)

->where('status', 2)

->get();

foreach ($existOrderList as $vo) {

if ($vo->goods->days > $goods->days) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败：您已存在有效期更长的套餐，只能购买流量包']);

}

}

}

DB::beginTransaction();

try {

// 生成订单

$order = new Order();

$order->order_sn = date('ymdHis') . mt_rand(100000, 999999);

$order->user_id = $user->id;

$order->goods_id = $goods_id;

$order->coupon_id = !empty($coupon) ? $coupon->id : 0;

$order->origin_amount = $goods->price;

$order->amount = $amount;

$order->expire_at = date("Y-m-d H:i:s", strtotime("+" . $goods->days . " days"));

$order->is_expire = 0;

$order->pay_way = 1;

$order->status = 2;

$order->save();

// 扣余额

User::query()->where('id', $user->id)->decrement('balance', $amount * 100);

// 记录余额操作日志

$this->addUserBalanceLog($user->id, $order->oid, $user->balance, $user->balance - $amount, -1 * $amount, '购买服务：' . $goods->name);

// 优惠券置为已使用

if (!empty($coupon)) {

if ($coupon->usage == 1) {

$coupon->status = 1;

$coupon->save();

}

// 写入日志

Helpers::addCouponLog($coupon->id, $goods_id, $order->oid, '余额支付订单使用');

}

// 如果买的是套餐，则先将之前购买的所有套餐置都无效，并扣掉之前所有套餐的流量，重置用户已用流量为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($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', $user->id)->first(); // 重新取出user信息

Helpers::addUserTrafficModifyLog($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', $user->id)->first(); // 重新取出user信息

Helpers::addUserTrafficModifyLog($user->id, $order->oid, $user->transfer_enable, ($user->transfer_enable + $goods->traffic * 1048576), '[余额支付]用户购买商品，加上流量');

// 把商品的流量加到账号上

User::query()->where('id', $user->id)->increment('transfer_enable', $goods->traffic * 1048576);

// 计算账号过期时间

if ($user->expire_time < date('Y-m-d', strtotime("+" . $goods->days . " days"))) {

$expireTime = date('Y-m-d', strtotime("+" . $goods->days . " days"));

} else {

$expireTime = $user->expire_time;

}

// 套餐就改流量重置日，流量包不改

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', $user->id)->pluck('label_id')->toArray();

$goodsLabels = GoodsLabel::query()->where('goods_id', $goods_id)->pluck('label_id')->toArray();

// 标签去重

$newUserLabels = array_values(array_unique(array_merge($userLabels, $goodsLabels, $defaultLabels)));

// 删除用户所有标签

UserLabel::query()->where('user_id', $user->id)->delete();

// 生成标签

foreach ($newUserLabels as $vo) {

$obj = new UserLabel();

$obj->user_id = $user->id;

$obj->label_id = $vo;

$obj->save();

}

}

// 写入返利日志

if ($user->referral_uid) {

$this->addReferralLog($user->id, $user->referral_uid, $order->oid, $amount, $amount * self::$systemConfig['referral_percent']);

}

// 取消重复返利

User::query()->where('id', $order->user_id)->update(['referral_uid' => 0]);

DB::commit();

return Response::json(['status' => 'success', 'data' => '', 'message' => '支付成功']);

} catch (\Exception $e) {

DB::rollBack();

Log::error('支付订单失败：' . $e->getMessage());

return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败：' . $e->getMessage()]);

}

} else {

$goods = Goods::query()->where('id', $goods_id)->where('is_del', 0)->where('status', 1)->first();

if (empty($goods)) {

return Redirect::to('services');

}

$view['goods'] = $goods;

$view['is_youzan'] = self::$systemConfig['is_youzan'];

$view['is_alipay'] = self::$systemConfig['is_alipay'];

return Response::view('user.buy', $view);

}

}

// 积分兑换流量

public function exchange(Request $request)

{

// 积分满100才可以兑换

if (Auth::user()->score < 100) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '兑换失败：满100才可以兑换，请继续累计吧']);

}

// 账号过期不允许兑换

if (Auth::user()->expire_time < date('Y-m-d')) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '兑换失败：账号已过期，请先购买服务吧']);

}

DB::beginTransaction();

try {

// 写入积分操作日志

$ret = $this->addUserScoreLog(Auth::user()->id, Auth::user()->score, 0, -1 * Auth::user()->score, '积分兑换流量');

// 扣积分加流量

if ($ret) {

User::query()->where('id', Auth::user()->id)->update(['score' => 0]);

User::query()->where('id', Auth::user()->id)->increment('transfer_enable', Auth::user()->score * 1048576);

}

DB::commit();

// 更新session

$user = User::query()->where('id', Auth::user()->id)->first()->toArray();

Session::remove('user');

Session::put('user', $user);

return Response::json(['status' => 'success', 'data' => '', 'message' => '兑换成功']);

} catch (\Exception $e) {

DB::rollBack();

return Response::json(['status' => 'fail', 'data' => '', 'message' => '兑换失败：' . $e->getMessage()]);

}

}

// 推广返利

public function referral(Request $request)

{

$view['referral_traffic'] = flowAutoShow(self::$systemConfig['referral_traffic'] * 1048576);

$view['referral_percent'] = self::$systemConfig['referral_percent'];

$view['referral_money'] = self::$systemConfig['referral_money'];

$view['totalAmount'] = ReferralLog::query()->where('ref_user_id', Auth::user()->id)->sum('ref_amount') / 100;

$view['canAmount'] = ReferralLog::query()->where('ref_user_id', Auth::user()->id)->where('status', 0)->sum('ref_amount') / 100;

$view['link'] = self::$systemConfig['website_url'] . '/register?aff=' . Auth::user()->id;

$view['referralLogList'] = ReferralLog::query()->where('ref_user_id', Auth::user()->id)->with('user')->orderBy('id', 'desc')->paginate(10);

$view['referralApplyList'] = ReferralApply::query()->where('user_id', Auth::user()->id)->with('user')->orderBy('id', 'desc')->paginate(10);

$view['referralUserList'] = User::query()->select(['username', 'created_at'])->where('referral_uid', Auth::user()->id)->orderBy('id', 'desc')->paginate(10);

return Response::view('user.referral', $view);

}

// 申请提现

public function extractMoney(Request $request)

{

// 判断账户是否过期

if (Auth::user()->expire_time < date('Y-m-d')) {

return Response::json(['status' => 'fail', 'data' => '', 'message' => '申请失败：账号已过期，请先购买服务吧']);