UserController.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Components\PushNotification;
  5. use App\Http\Models\Article;
  6. use App\Http\Models\Coupon;
  7. use App\Http\Models\Goods;
  8. use App\Http\Models\Invite;
  9. use App\Http\Models\Order;
  10. use App\Http\Models\SsNode;
  11. use App\Http\Models\SsNodeInfo;
  12. use App\Http\Models\SsNodeLabel;
  13. use App\Http\Models\SsNodePing;
  14. use App\Http\Models\Ticket;
  15. use App\Http\Models\TicketReply;
  16. use App\Http\Models\User;
  17. use App\Http\Models\UserLabel;
  18. use App\Http\Models\UserLoginLog;
  19. use App\Http\Models\UserSubscribe;
  20. use App\Http\Models\UserTrafficDaily;
  21. use App\Http\Models\UserTrafficHourly;
  22. use App\Mail\newTicket;
  23. use App\Mail\replyTicket;
  24. use Auth;
  25. use Cache;
  26. use DB;
  27. use Exception;
  28. use Hash;
  29. use Illuminate\Http\Request;
  30. use Illuminate\Validation\Rule;
  31. use Log;
  32. use Mail;
  33. use Redirect;
  34. use Response;
  35. use Session;
  36. use Validator;
  37. /**
  38. * 用户控制器
  39. *
  40. * Class UserController
  41. *
  42. * @package App\Http\Controllers
  43. */
  44. class UserController extends Controller {
  45. protected static $systemConfig;
  46. function __construct() {
  47. self::$systemConfig = Helpers::systemConfig();
  48. }
  49. public function index() {
  50. $totalTransfer = Auth::user()->transfer_enable;
  51. $usedTransfer = Auth::user()->u + Auth::user()->d;
  52. $unusedTransfer = $totalTransfer - $usedTransfer > 0? $totalTransfer - $usedTransfer : 0;
  53. $expireTime = Auth::user()->expire_time;
  54. $view['remainDays'] = $expireTime < date('Y-m-d')? -1 : (strtotime($expireTime) - strtotime(date('Y-m-d'))) / 86400;
  55. $view['resetDays'] = Auth::user()->reset_time? round((strtotime(Auth::user()->reset_time) - strtotime(date('Y-m-d'))) / 86400) : 0;
  56. $view['unusedTransfer'] = $unusedTransfer;
  57. $view['expireTime'] = $expireTime;
  58. $view['banedTime'] = Auth::user()->ban_time? date('Y-m-d H:i:s', Auth::user()->ban_time) : 0;
  59. $view['unusedPercent'] = $totalTransfer > 0? round($unusedTransfer / $totalTransfer, 2) : 0;
  60. $view['noticeList'] = Article::type(2)->orderBy('id', 'desc')->Paginate(1); // 公告
  61. //流量异常判断
  62. $hourlyTraffic = UserTrafficHourly::query()
  63. ->whereUserId(Auth::user()->id)
  64. ->whereNodeId(0)
  65. ->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))
  66. ->sum('total');
  67. $view['isTrafficWarning'] = $hourlyTraffic >= (self::$systemConfig['traffic_ban_value'] * 1073741824)?: 0;
  68. //付费用户判断
  69. $view['not_paying_user'] = Order::uid()
  70. ->whereStatus(2)
  71. ->whereIsExpire(0)
  72. ->where('origin_amount', '>', 0)
  73. ->doesntExist();
  74. $view['userLoginLog'] = UserLoginLog::query()
  75. ->whereUserId(Auth::user()->id)
  76. ->orderBy('id', 'desc')
  77. ->first(); // 近期登录日志
  78. $dailyData = [];
  79. $hourlyData = [];
  80. // 节点一个月内的流量
  81. // TODO:有bug
  82. $userTrafficDaily = UserTrafficDaily::query()
  83. ->whereUserId(Auth::user()->id)
  84. ->whereNodeId(0)
  85. ->where('created_at', '<=', date('Y-m-d', time()))
  86. ->orderBy('created_at', 'asc')
  87. ->pluck('total')
  88. ->toArray();
  89. $dailyTotal = date('d', time()) - 1; // 今天不算,减一
  90. $dailyCount = count($userTrafficDaily);
  91. for($x = 0; $x < $dailyTotal - $dailyCount; $x++){
  92. $dailyData[$x] = 0;
  93. }
  94. for($x = $dailyTotal - $dailyCount; $x < $dailyTotal; $x++){
  95. $dailyData[$x] = round($userTrafficDaily[$x - ($dailyTotal - $dailyCount)] / (1024 * 1024 * 1024), 3);
  96. }
  97. // 节点一天内的流量
  98. $userTrafficHourly = UserTrafficHourly::query()
  99. ->whereUserId(Auth::user()->id)
  100. ->whereNodeId(0)
  101. ->where('created_at', '>=', date('Y-m-d', time()))
  102. ->orderBy('created_at', 'asc')
  103. ->pluck('total')
  104. ->toArray();
  105. $hourlyTotal = date('H');
  106. $hourlyCount = count($userTrafficHourly);
  107. for($x = 0; $x < $hourlyTotal - $hourlyCount; $x++){
  108. $hourlyData[$x] = 0;
  109. }
  110. for($x = ($hourlyTotal - $hourlyCount); $x < $hourlyTotal; $x++){
  111. $hourlyData[$x] = round($userTrafficHourly[$x - ($hourlyTotal - $hourlyCount)] / (1024 * 1024 * 1024), 3);
  112. }
  113. // 本月天数数据
  114. $monthDays = [];
  115. for($i = 1; $i <= date("d"); $i++){
  116. $monthDays[] = $i;
  117. }
  118. // 本日小时数据
  119. $dayHours = [];
  120. for($i = 1; $i <= date("H"); $i++){
  121. $dayHours[] = $i;
  122. }
  123. $view['trafficDaily'] = "'".implode("','", $dailyData)."'";
  124. $view['trafficHourly'] = "'".implode("','", $hourlyData)."'";
  125. $view['monthDays'] = "'".implode("','", $monthDays)."'";
  126. $view['dayHours'] = "'".implode("','", $dayHours)."'";
  127. return Response::view('user.index', $view);
  128. }
  129. // 签到
  130. public function checkIn() {
  131. // 系统开启登录加积分功能才可以签到
  132. if(!self::$systemConfig['is_checkin']){
  133. return Response::json(['status' => 'fail', 'message' => '系统未开启签到功能']);
  134. }
  135. // 已签到过,验证是否有效
  136. if(Cache::has('userCheckIn_'.Auth::user()->id)){
  137. return Response::json(['status' => 'fail', 'message' => '已经签到过了,明天再来吧']);
  138. }
  139. $traffic = mt_rand((int) self::$systemConfig['min_rand_traffic'],
  140. (int) self::$systemConfig['max_rand_traffic']) * 1048576;
  141. $ret = User::uid()->increment('transfer_enable', $traffic);
  142. if(!$ret){
  143. return Response::json(['status' => 'fail', 'message' => '签到失败,系统异常']);
  144. }
  145. // 写入用户流量变动记录
  146. Helpers::addUserTrafficModifyLog(Auth::user()->id, 0, Auth::user()->transfer_enable,
  147. Auth::user()->transfer_enable + $traffic, '[签到]');
  148. // 多久后可以再签到
  149. $ttl = self::$systemConfig['traffic_limit_time']? self::$systemConfig['traffic_limit_time'] * 60 : 86400;
  150. Cache::put('userCheckIn_'.Auth::user()->id, '1', $ttl);
  151. return Response::json(['status' => 'success', 'message' => '签到成功,系统送您 '.flowAutoShow($traffic).'流量']);
  152. }
  153. // 节点列表
  154. public function nodeList(Request $request) {
  155. if($request->isMethod('POST')){
  156. $node_id = $request->input('id');
  157. $infoType = $request->input('type');
  158. $node = SsNode::query()->whereId($node_id)->first();
  159. // 生成节点信息
  160. $proxyType = $node->type == 1? ($node->compatible? 'SS' : 'SSR') : 'V2Ray';
  161. $data = $this->getNodeInfo(Auth::user()->id, $node->id, $infoType != 'text'? 0 : 1);
  162. return Response::json(['status' => 'success', 'data' => $data, 'title' => $proxyType]);
  163. }else{
  164. // 获取当前用户标签
  165. $userLabelIds = UserLabel::uid()->pluck('label_id');
  166. // 获取当前用户可用节点
  167. $nodeList = SsNode::query()
  168. ->selectRaw('ss_node.*')
  169. ->leftJoin('ss_node_label', 'ss_node.id', '=', 'ss_node_label.node_id')
  170. ->whereIn('ss_node_label.label_id', $userLabelIds)
  171. ->where('ss_node.status', 1)
  172. ->groupBy('ss_node.id')
  173. ->orderBy('ss_node.sort', 'desc')
  174. ->orderBy('ss_node.id', 'asc')
  175. ->get();
  176. foreach($nodeList as $node){
  177. $node->ct = number_format(SsNodePing::query()->whereNodeId($node->id)->where('ct', '>', '0')->avg('ct'),
  178. 1, '.', '');
  179. $node->cu = number_format(SsNodePing::query()->whereNodeId($node->id)->where('cu', '>', '0')->avg('cu'),
  180. 1, '.', '');
  181. $node->cm = number_format(SsNodePing::query()->whereNodeId($node->id)->where('cm', '>', '0')->avg('cm'),
  182. 1, '.', '');
  183. $node->hk = number_format(SsNodePing::query()->whereNodeId($node->id)->where('hk', '>', '0')->avg('hk'),
  184. 1, '.', '');
  185. // 节点在线状态
  186. $node->offline = SsNodeInfo::query()
  187. ->whereNodeId($node->id)
  188. ->where('log_time', '>=', strtotime("-10 minutes"))
  189. ->orderBy('id', 'desc')
  190. ->doesntExist();
  191. // 节点标签
  192. $node->labels = SsNodeLabel::query()->whereNodeId($node->id)->first();
  193. }
  194. $view['nodeList'] = $nodeList?: [];
  195. }
  196. return Response::view('user.nodeList', $view);
  197. }
  198. // 公告详情
  199. public function article(Request $request) {
  200. $view['info'] = Article::query()->findOrFail($request->input('id'));
  201. return Response::view('user.article', $view);
  202. }
  203. // 修改个人资料
  204. public function profile(Request $request) {
  205. if($request->isMethod('POST')){
  206. $old_password = trim($request->input('old_password'));
  207. $new_password = trim($request->input('new_password'));
  208. $username = trim($request->input('username'));
  209. $wechat = trim($request->input('wechat'));
  210. $qq = trim($request->input('qq'));
  211. $passwd = trim($request->input('passwd'));
  212. // 修改密码
  213. if($old_password && $new_password){
  214. if(!Hash::check($old_password, Auth::user()->password)){
  215. return Redirect::to('profile#tab_1')->withErrors('旧密码错误,请重新输入');
  216. }elseif(Hash::check($new_password, Auth::user()->password)){
  217. return Redirect::to('profile#tab_1')->withErrors('新密码不可与旧密码一样,请重新输入');
  218. }
  219. // 演示环境禁止改管理员密码
  220. if(env('APP_DEMO') && Auth::user()->id == 1){
  221. return Redirect::to('profile#tab_1')->withErrors('演示环境禁止修改管理员密码');
  222. }
  223. $ret = User::uid()->update(['password' => Hash::make($new_password)]);
  224. if(!$ret){
  225. return Redirect::to('profile#tab_1')->withErrors('修改失败');
  226. }else{
  227. return Redirect::to('profile#tab_1')->with('successMsg', '修改成功');
  228. }
  229. // 修改代理密码
  230. }elseif($passwd){
  231. $ret = User::uid()->update(['passwd' => $passwd]);
  232. if(!$ret){
  233. return Redirect::to('profile#tab_3')->withErrors('修改失败');
  234. }else{
  235. return Redirect::to('profile#tab_3')->with('successMsg', '修改成功');
  236. }
  237. }else{
  238. // 修改联系方式
  239. if(empty($username)){
  240. return Redirect::to('profile#tab_2')->withErrors('修改失败,昵称不能为空值');
  241. }
  242. $ret = User::uid()->update(['username' => $username, 'wechat' => $wechat, 'qq' => $qq]);
  243. if(!$ret){
  244. return Redirect::to('profile#tab_2')->withErrors('修改失败');
  245. }else{
  246. return Redirect::to('profile#tab_2')->with('successMsg', '修改成功');
  247. }
  248. }
  249. }else{
  250. return Response::view('user.profile');
  251. }
  252. }
  253. // 商品列表
  254. public function services(Request $request) {
  255. // 余额充值商品,只取10个
  256. $view['chargeGoodsList'] = Goods::type(3)
  257. ->whereStatus(1)
  258. ->orderBy('price', 'asc')
  259. ->orderBy('price', 'asc')
  260. ->limit(10)
  261. ->get();
  262. $view['goodsList'] = Goods::query()
  263. ->whereStatus(1)
  264. ->where('type', '<=', '2')
  265. ->orderBy('type', 'desc')
  266. ->orderBy('sort', 'desc')
  267. ->paginate(10)
  268. ->appends($request->except('page'));
  269. $renewOrder = Order::query()
  270. ->with(['goods'])
  271. ->whereUserId(Auth::user()->id)
  272. ->whereStatus(2)
  273. ->whereIsExpire(0)
  274. ->whereHas('goods', function($q) {
  275. $q->whereType(2);
  276. })
  277. ->first();
  278. $renewPrice = $renewOrder? Goods::query()->whereId($renewOrder->goods_id)->first() : 0;
  279. $view['renewTraffic'] = $renewPrice? $renewPrice->renew : 0;
  280. // 有重置日时按照重置日为标准,否者就以过期日为标准
  281. $dataPlusDays = Auth::user()->reset_time? Auth::user()->reset_time : Auth::user()->expire_time;
  282. $view['dataPlusDays'] = $dataPlusDays > date('Y-m-d')? round((strtotime($dataPlusDays) - strtotime(date('Y-m-d'))) / 86400) : 0;
  283. $view['purchaseHTML'] = PaymentController::purchaseHTML();
  284. return Response::view('user.services', $view);
  285. }
  286. //重置流量
  287. public function resetUserTraffic() {
  288. $temp = Order::uid()->whereStatus(2)->whereIsExpire(0)->with(['goods'])->whereHas('goods', function($q) {
  289. $q->whereType(2);
  290. })->first();
  291. $renewCost = Goods::query()->whereId($temp->goods_id)->first()->renew;
  292. if(Auth::user()->balance < $renewCost){
  293. return Response::json(['status' => 'fail', 'data' => '', 'message' => '余额不足,请充值余额']);
  294. }else{
  295. User::uid()->update(['u' => 0, 'd' => 0]);
  296. // 扣余额
  297. User::query()->whereId(Auth::user()->id)->decrement('balance', $renewCost * 100);
  298. // 记录余额操作日志
  299. Helpers::addUserBalanceLog(Auth::user()->id, '', Auth::user()->balance, Auth::user()->balance - $renewCost,
  300. -1 * $renewCost, '用户自行重置流量');
  301. return Response::json(['status' => 'success', 'data' => '', 'message' => '重置成功']);
  302. }
  303. }
  304. // 工单
  305. public function ticketList(Request $request) {
  306. $view['ticketList'] = Ticket::uid()->orderBy('id', 'desc')->paginate(10)->appends($request->except('page'));
  307. return Response::view('user.ticketList', $view);
  308. }
  309. // 订单
  310. public function invoices(Request $request) {
  311. $view['orderList'] = Order::uid()
  312. ->with(['user', 'goods', 'coupon', 'payment'])
  313. ->orderBy('oid', 'desc')
  314. ->paginate(10)
  315. ->appends($request->except('page'));
  316. return Response::view('user.invoices', $view);
  317. }
  318. public function activeOrder(Request $request) {
  319. $oid = $request->input('oid');
  320. $prepaidOrder = Order::query()->whereOid($oid)->first();
  321. if(!$prepaidOrder){
  322. return Response::json(['status' => 'fail', 'data' => '', 'message' => '查无此单!']);
  323. }elseif($prepaidOrder->status != 3){
  324. return Response::json(['status' => 'fail', 'data' => '', 'message' => '非预支付订单,无需再次启动!']);
  325. }else{
  326. (new ServiceController)->activePrepaidOrder($oid);
  327. }
  328. return Response::json(['status' => 'success', 'data' => '', 'message' => '激活成功']);
  329. }
  330. // 订单明细
  331. public function invoiceDetail($sn) {
  332. $view['order'] = Order::uid()->with(['goods', 'coupon', 'payment'])->whereOrderSn($sn)->firstOrFail();
  333. return Response::view('user.invoiceDetail', $view);
  334. }
  335. // 添加工单
  336. public function addTicket(Request $request) {
  337. $title = $request->input('title');
  338. $content = clean($request->input('content'));
  339. $content = str_replace("eval", "", str_replace("atob", "", $content));
  340. if(empty($title) || empty($content)){
  341. return Response::json(['status' => 'fail', 'data' => '', 'message' => '请输入标题和内容']);
  342. }
  343. $obj = new Ticket();
  344. $obj->user_id = Auth::user()->id;
  345. $obj->title = $title;
  346. $obj->content = $content;
  347. $obj->status = 0;
  348. $obj->save();
  349. if($obj->id){
  350. $emailTitle = "新工单提醒";
  351. $content = "标题:【".$title."】<br>用户:".Auth::user()->email."<br>内容:".$content;
  352. // 发邮件通知管理员
  353. if(self::$systemConfig['webmaster_email']){
  354. $logId = Helpers::addNotificationLog($emailTitle, $content, 1, self::$systemConfig['webmaster_email']);
  355. Mail::to(self::$systemConfig['webmaster_email'])->send(new newTicket($logId, $emailTitle, $content));
  356. }
  357. PushNotification::send($emailTitle, $content);
  358. return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
  359. }else{
  360. return Response::json(['status' => 'fail', 'data' => '', 'message' => '提交失败']);
  361. }
  362. }
  363. // 回复工单
  364. public function replyTicket(Request $request) {
  365. $id = $request->input('id');
  366. $ticket = Ticket::uid()->with('user')->whereId($id)->firstOrFail();
  367. if($request->isMethod('POST')){
  368. $content = clean($request->input('content'));
  369. $content = str_replace("eval", "", str_replace("atob", "", $content));
  370. $content = substr($content, 0, 300);
  371. if(empty($content)){
  372. return Response::json(['status' => 'fail', 'data' => '', 'message' => '回复内容不能为空']);
  373. }
  374. if($ticket->status == 2){
  375. return Response::json(['status' => 'fail', 'data' => '', 'message' => '错误:该工单已关闭']);
  376. }
  377. $obj = new TicketReply();
  378. $obj->ticket_id = $id;
  379. $obj->user_id = Auth::user()->id;
  380. $obj->content = $content;
  381. $obj->save();
  382. if($obj->id){
  383. // 重新打开工单
  384. $ticket->status = 0;
  385. $ticket->save();
  386. $title = "工单回复提醒";
  387. $content = "标题:【".$ticket->title."】<br>用户回复:".$content;
  388. // 发邮件通知管理员
  389. if(self::$systemConfig['webmaster_email']){
  390. $logId = Helpers::addNotificationLog($title, $content, 1, self::$systemConfig['webmaster_email']);
  391. Mail::to(self::$systemConfig['webmaster_email'])->send(new replyTicket($logId, $title, $content));
  392. }
  393. PushNotification::send($title, $content);
  394. return Response::json(['status' => 'success', 'data' => '', 'message' => '回复成功']);
  395. }else{
  396. return Response::json(['status' => 'fail', 'data' => '', 'message' => '回复失败']);
  397. }
  398. }else{
  399. $view['ticket'] = $ticket;
  400. $view['replyList'] = TicketReply::query()->whereTicketId($id)->with('user')->orderBy('id', 'asc')->get();
  401. return Response::view('user.replyTicket', $view);
  402. }
  403. }
  404. // 关闭工单
  405. public function closeTicket(Request $request) {
  406. $id = $request->input('id');
  407. $ret = Ticket::uid()->whereId($id)->update(['status' => 2]);
  408. if($ret){
  409. PushNotification::send('工单关闭提醒', '工单:ID'.$id.'用户已手动关闭');
  410. return Response::json(['status' => 'success', 'data' => '', 'message' => '关闭成功']);
  411. }else{
  412. return Response::json(['status' => 'fail', 'data' => '', 'message' => '关闭失败']);
  413. }
  414. }
  415. // 邀请码
  416. public function invite() {
  417. if(Order::uid()->whereStatus(2)->whereIsExpire(0)->where('origin_amount', '>', 0)->doesntExist()){
  418. return Response::view('auth.error',
  419. ['message' => '本功能对非付费用户禁用!请 <a class="btn btn-sm btn-danger" href="/">返 回</a>']);
  420. }
  421. $view['num'] = Auth::user()->invite_num; // 还可以生成的邀请码数量
  422. $view['inviteList'] = Invite::uid()->with(['generator', 'user'])->paginate(10); // 邀请码列表
  423. $view['referral_traffic'] = flowAutoShow(self::$systemConfig['referral_traffic'] * 1048576);
  424. $view['referral_percent'] = self::$systemConfig['referral_percent'];
  425. return Response::view('user.invite', $view);
  426. }
  427. // 生成邀请码
  428. public function makeInvite() {
  429. if(Auth::user()->invite_num <= 0){
  430. return Response::json(['status' => 'fail', 'data' => '', 'message' => '生成失败:已无邀请码生成名额']);
  431. }
  432. $obj = new Invite();
  433. $obj->uid = Auth::user()->id;
  434. $obj->fuid = 0;
  435. $obj->code = strtoupper(mb_substr(md5(microtime().makeRandStr()), 8, 12));
  436. $obj->status = 0;
  437. $obj->dateline = date('Y-m-d H:i:s', strtotime("+".self::$systemConfig['user_invite_days']." days"));
  438. $obj->save();
  439. User::uid()->decrement('invite_num', 1);
  440. return Response::json(['status' => 'success', 'data' => '', 'message' => '生成成功']);
  441. }
  442. // 使用优惠券
  443. public function redeemCoupon(Request $request) {
  444. $coupon_sn = $request->input('coupon_sn');
  445. $good_price = $request->input('price');
  446. if(empty($coupon_sn)){
  447. return Response::json(['status' => 'fail', 'title' => '使用失败', 'message' => '请输入您的优惠劵!']);
  448. }
  449. $coupon = Coupon::query()->whereSn($coupon_sn)->whereIn('type', [1, 2])->first();
  450. if(!$coupon){
  451. return Response::json(['status' => 'fail', 'title' => '优惠券不存在', 'message' => '请确认优惠券是否输入正确!']);
  452. }elseif($coupon->status == 1){
  453. return Response::json(['status' => 'fail', 'title' => '抱歉', 'message' => '优惠券已被使用!']);
  454. }elseif($coupon->status == 2){
  455. return Response::json(['status' => 'fail', 'title' => '抱歉', 'message' => '优惠券已失效!']);
  456. }elseif($coupon->available_end < time()){
  457. $coupon->status = 2;
  458. $coupon->save();
  459. return Response::json(['status' => 'fail', 'title' => '抱歉', 'message' => '优惠券已失效!']);
  460. }elseif($coupon->available_start > time()){
  461. return Response::json(['status' => 'fail', 'title' => '优惠券尚未生效', 'message' => '请等待活动正式开启']);
  462. }elseif($good_price < $coupon->rule){
  463. return Response::json(['status' => 'fail', 'title' => '使用条件未满足', 'message' => '请购买价格更高的套餐']);
  464. }
  465. $data = [
  466. 'name' => $coupon->name,
  467. 'type' => $coupon->type,
  468. 'amount' => $coupon->amount,
  469. 'discount' => $coupon->discount
  470. ];
  471. return Response::json(['status' => 'success', 'data' => $data, 'message' => '优惠券有效']);
  472. }
  473. // 购买服务
  474. public function buy($goods_id) {
  475. $goods = Goods::query()->whereId($goods_id)->whereStatus(1)->first();
  476. if(empty($goods)){
  477. return Redirect::to('services');
  478. }
  479. // 有重置日时按照重置日为标准,否者就以过期日为标准
  480. $dataPlusDays = Auth::user()->reset_time? Auth::user()->reset_time : Auth::user()->expire_time;
  481. $view['dataPlusDays'] = $dataPlusDays > date('Y-m-d')? round((strtotime($dataPlusDays) - strtotime(date('Y-m-d'))) / 86400) : 0;
  482. $view['activePlan'] = Order::uid()
  483. ->with(['goods'])
  484. ->whereIsExpire(0)
  485. ->whereStatus(2)
  486. ->whereHas('goods', function($q) {
  487. $q->whereType(2);
  488. })
  489. ->exists();
  490. $view['purchaseHTML'] = PaymentController::purchaseHTML();
  491. $view['goods'] = $goods;
  492. return Response::view('user.buy', $view);
  493. }
  494. // 帮助中心
  495. public function help() {
  496. $view['articleList'] = Article::type(1)->orderBy('sort', 'desc')->orderBy('id', 'desc')->limit(10)->paginate(5);
  497. //付费用户判断
  498. $view['not_paying_user'] = Order::uid()
  499. ->whereStatus(2)
  500. ->whereIsExpire(0)
  501. ->where('origin_amount', '>', 0)
  502. ->doesntExist();
  503. //客户端安装
  504. $view['Shadowrocket_install'] = 'itms-services://?action=download-manifest&url='.self::$systemConfig['website_url'].'/clients/Shadowrocket.plist';
  505. $view['Quantumult_install'] = 'itms-services://?action=download-manifest&url='.self::$systemConfig['website_url'].'/clients/Quantumult.plist';
  506. // 订阅连接
  507. $subscribe = UserSubscribe::query()->whereUserId(Auth::user()->id)->first();
  508. $view['subscribe_status'] = $subscribe->status;
  509. $subscribe_link = (self::$systemConfig['subscribe_domain']? self::$systemConfig['subscribe_domain'] : self::$systemConfig['website_url']).'/s/'.$subscribe->code;
  510. $view['link'] = $subscribe_link;
  511. $view['subscribe_link'] = 'sub://'.base64url_encode($subscribe_link);
  512. $view['Shadowrocket_link'] = 'shadowrocket://add/sub://'.base64url_encode($subscribe_link).'?remarks='.(self::$systemConfig['website_name'].'-'.self::$systemConfig['website_url']);
  513. $view['Shadowrocket_linkQrcode'] = 'sub://'.base64url_encode($subscribe_link).'#'.base64url_encode(self::$systemConfig['website_name']);
  514. $view['Quantumult_linkOut'] = 'quantumult://configuration?server='.base64url_encode($subscribe_link).'&filter='.base64url_encode('https://raw.githubusercontent.com/ZBrettonYe/VPN-Rules-Collection/master/Profiles/Quantumult/Pro.conf').'&rejection='.base64url_encode('https://raw.githubusercontent.com/ZBrettonYe/VPN-Rules-Collection/master/Profiles/Quantumult/Rejection.conf');
  515. $view['Quantumult_linkIn'] = 'quantumult://configuration?server='.base64url_encode($subscribe_link).'&filter='.base64url_encode('https://raw.githubusercontent.com/ZBrettonYe/VPN-Rules-Collection/master/Profiles/Quantumult/BacktoCN.conf').'&rejection='.base64url_encode('https://raw.githubusercontent.com/ZBrettonYe/VPN-Rules-Collection/master/Profiles/Quantumult/Rejection.conf');
  516. return Response::view('user.help', $view);
  517. }
  518. // 更换订阅地址
  519. public function exchangeSubscribe() {
  520. DB::beginTransaction();
  521. try{
  522. // 更换订阅码
  523. UserSubscribe::uid()->update(['code' => Helpers::makeSubscribeCode()]);
  524. // 更换连接密码
  525. User::uid()->update(['passwd' => makeRandStr()]);
  526. DB::commit();
  527. return Response::json(['status' => 'success', 'data' => '', 'message' => '更换成功']);
  528. }catch(Exception $e){
  529. DB::rollBack();
  530. Log::info("更换订阅地址异常:".$e->getMessage());
  531. return Response::json(['status' => 'fail', 'data' => '', 'message' => '更换失败'.$e->getMessage()]);
  532. }
  533. }
  534. // 转换成管理员的身份
  535. public function switchToAdmin() {
  536. if(!Session::has('admin')){
  537. return Response::json(['status' => 'fail', 'data' => '', 'message' => '非法请求']);
  538. }
  539. // 管理员信息重新写入user
  540. Auth::loginUsingId(Session::get('admin'));
  541. Session::forget('admin');
  542. return Response::json(['status' => 'success', 'data' => '', 'message' => "身份切换成功"]);
  543. }
  544. // 卡券余额充值
  545. public function charge(Request $request) {
  546. $validator = Validator::make($request->all(), [
  547. 'coupon_sn' => [
  548. 'required',
  549. Rule::exists('coupon', 'sn')->where(function($query) {
  550. $query->whereType(3)->whereStatus(0);
  551. }),
  552. ]
  553. ], ['coupon_sn.required' => '券码不能为空', 'coupon_sn.exists' => '该券不可用']);
  554. if($validator->fails()){
  555. return Response::json([
  556. 'status' => 'fail',
  557. 'data' => '',
  558. 'message' => $validator->getMessageBag()->first()
  559. ]);
  560. }
  561. $coupon = Coupon::query()->whereSn($request->input('coupon_sn'))->first();
  562. try{
  563. DB::beginTransaction();
  564. // 写入日志
  565. Helpers::addUserBalanceLog(Auth::user()->id, 0, Auth::user()->balance,
  566. Auth::user()->balance + $coupon->amount, $coupon->amount,
  567. '用户手动充值 - [充值券:'.$request->input('coupon_sn').']');
  568. // 余额充值
  569. User::uid()->increment('balance', $coupon->amount * 100);
  570. // 更改卡券状态
  571. $coupon->status = 1;
  572. $coupon->save();
  573. // 写入卡券日志
  574. Helpers::addCouponLog($coupon->id, 0, 0, '账户余额充值使用');
  575. DB::commit();
  576. return Response::json(['status' => 'success', 'data' => '', 'message' => '充值成功']);
  577. }catch(Exception $e){
  578. Log::error($e);
  579. DB::rollBack();
  580. return Response::json(['status' => 'fail', 'data' => '', 'message' => '充值失败']);
  581. }
  582. }
  583. }