UserController.php 55 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Components\ServerChan;
  5. use App\Http\Models\Article;
  6. use App\Http\Models\Coupon;
  7. use App\Http\Models\Goods;
  8. use App\Http\Models\GoodsLabel;
  9. use App\Http\Models\Invite;
  10. use App\Http\Models\Level;
  11. use App\Http\Models\Order;
  12. use App\Http\Models\ReferralApply;
  13. use App\Http\Models\ReferralLog;
  14. use App\Http\Models\SsConfig;
  15. use App\Http\Models\SsGroup;
  16. use App\Http\Models\SsNodeInfo;
  17. use App\Http\Models\SsNodeLabel;
  18. use App\Http\Models\Ticket;
  19. use App\Http\Models\TicketReply;
  20. use App\Http\Models\User;
  21. use App\Http\Models\UserLabel;
  22. use App\Http\Models\UserLoginLog;
  23. use App\Http\Models\UserSubscribe;
  24. use App\Http\Models\UserTrafficDaily;
  25. use App\Http\Models\UserTrafficHourly;
  26. use App\Http\Models\Verify;
  27. use App\Mail\activeUser;
  28. use App\Mail\newTicket;
  29. use App\Mail\replyTicket;
  30. use App\Mail\resetPassword;
  31. use Illuminate\Http\Request;
  32. use Redirect;
  33. use Response;
  34. use Session;
  35. use Cache;
  36. use Mail;
  37. use Log;
  38. use DB;
  39. class UserController extends Controller
  40. {
  41. protected static $systemConfig;
  42. function __construct()
  43. {
  44. self::$systemConfig = Helpers::systemConfig();
  45. }
  46. public function index(Request $request)
  47. {
  48. $user = Session::get('user');
  49. $user = User::query()->where('id', $user['id'])->first();
  50. $user->totalTransfer = flowAutoShow($user->transfer_enable);
  51. $user->usedTransfer = flowAutoShow($user->u + $user->d);
  52. $user->usedPercent = $user->transfer_enable > 0 ? round(($user->u + $user->d) / $user->transfer_enable, 2) : 1;
  53. $user->levelName = Level::query()->where('level', $user['level'])->first()['level_name'];
  54. $view['info'] = $user->toArray();
  55. $view['notice'] = Article::query()->where('type', 2)->where('is_del', 0)->orderBy('id', 'desc')->first();
  56. $view['wechat_qrcode'] = self::$systemConfig['wechat_qrcode'];
  57. $view['alipay_qrcode'] = self::$systemConfig['alipay_qrcode'];
  58. $view['login_add_score'] = self::$systemConfig['login_add_score'];
  59. $view['website_logo'] = self::$systemConfig['website_logo'];
  60. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  61. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  62. $view['is_push_bear'] = self::$systemConfig['is_push_bear'];
  63. $view['push_bear_qrcode'] = self::$systemConfig['push_bear_qrcode'];
  64. $view['goodsList'] = Goods::query()->where('type', 3)->where('status', 1)->where('is_del', 0)->orderBy('sort', 'desc')->orderBy('price', 'asc')->limit(10)->get(); // 余额充值商品,只取10个
  65. // 推广返利是否可见
  66. if (!Session::has('referral_status')) {
  67. Session::put('referral_status', self::$systemConfig['referral_status']);
  68. }
  69. // 如果没有唯一码则生成一个
  70. $subscribe = UserSubscribe::query()->where('user_id', $user['id'])->first();
  71. if (!$subscribe) {
  72. $code = $this->makeSubscribeCode();
  73. $obj = new UserSubscribe();
  74. $obj->user_id = $user['id'];
  75. $obj->code = $code;
  76. $obj->times = 0;
  77. $obj->save();
  78. } else {
  79. $code = $subscribe->code;
  80. }
  81. $view['subscribe_status'] = !$subscribe ? 1 : $subscribe->status;
  82. $view['link'] = self::$systemConfig['subscribe_domain'] ? self::$systemConfig['subscribe_domain'] . '/s/' . $code : self::$systemConfig['website_url'] . '/s/' . $code;
  83. // 近期登录日志
  84. $view['userLoginLog'] = UserLoginLog::query()->where('user_id', $user['id'])->orderBy('id', 'desc')->limit(10)->get();
  85. // 节点列表
  86. $userLabelIds = UserLabel::query()->where('user_id', $user['id'])->pluck('label_id');
  87. if (empty($userLabelIds)) {
  88. $view['nodeList'] = [];
  89. return Response::view('user.index', $view);
  90. }
  91. $nodeList = DB::table('ss_node')
  92. ->leftJoin('ss_node_label', 'ss_node.id', '=', 'ss_node_label.node_id')
  93. ->whereIn('ss_node_label.label_id', $userLabelIds)
  94. ->where('ss_node.status', 1)
  95. ->groupBy('ss_node.id')
  96. ->orderBy('sort', 'desc')
  97. ->get();
  98. foreach ($nodeList as &$node) {
  99. // 获取分组名称
  100. $group = SsGroup::query()->where('id', $node->group_id)->first();
  101. // 生成ssr scheme
  102. $obfs_param = $user->obfs_param ? $user->obfs_param : $node->obfs_param;
  103. $protocol_param = $node->single ? $user->port . ':' . $user->passwd : $user->protocol_param;
  104. $ssr_str = ($node->server ? $node->server : $node->ip) . ':' . ($node->single ? $node->single_port : $user->port);
  105. $ssr_str .= ':' . ($node->single ? $node->single_protocol : $user->protocol) . ':' . ($node->single ? $node->single_method : $user->method);
  106. $ssr_str .= ':' . ($node->single ? $node->single_obfs : $user->obfs) . ':' . ($node->single ? base64url_encode($node->single_passwd) : base64url_encode($user->passwd));
  107. $ssr_str .= '/?obfsparam=' . base64url_encode($obfs_param);
  108. $ssr_str .= '&protoparam=' . ($node->single ? base64url_encode($user->port . ':' . $user->passwd) : base64url_encode($protocol_param));
  109. $ssr_str .= '&remarks=' . base64url_encode($node->name . "|" . $node->traffic_rate . "倍流量消耗");
  110. $ssr_str .= '&group=' . base64url_encode(empty($group) ? '' : $group->name);
  111. $ssr_str .= '&udpport=0';
  112. $ssr_str .= '&uot=0';
  113. $ssr_str = base64url_encode($ssr_str);
  114. $ssr_scheme = 'ssr://' . $ssr_str;
  115. // 生成ss scheme
  116. $ss_str = $user->method . ':' . $user->passwd . '@';
  117. $ss_str .= ($node->server ? $node->server : $node->ip) . ':' . $user->port;
  118. $ss_str = base64url_encode($ss_str) . '#' . 'VPN';
  119. $ss_scheme = 'ss://' . $ss_str;
  120. // 生成文本配置信息
  121. $txt = "服务器:" . ($node->server ? $node->server : $node->ip) . "\r\n";
  122. if ($node->ipv6) {
  123. $txt .= "IPv6:" . $node->ipv6 . "\r\n";
  124. }
  125. $txt .= "远程端口:" . ($node->single ? $node->single_port : $user->port) . "\r\n";
  126. $txt .= "密码:" . ($node->single ? $node->single_passwd : $user->passwd) . "\r\n";
  127. $txt .= "加密方法:" . ($node->single ? $node->single_method : $user->method) . "\r\n";
  128. $txt .= "路由:绕过局域网及中国大陆地址" . "\r\n\r\n";
  129. $txt .= "协议:" . ($node->single ? $node->single_protocol : $user->protocol) . "\r\n";
  130. $txt .= "协议参数:" . ($node->single ? $user->port . ':' . $user->passwd : $user->protocol_param) . "\r\n";
  131. $txt .= "混淆方式:" . ($node->single ? $node->single_obfs : $user->obfs) . "\r\n";
  132. $txt .= "混淆参数:" . ($user->obfs_param ? $user->obfs_param : $node->obfs_param) . "\r\n";
  133. $txt .= "本地端口:1080" . "\r\n";
  134. $node->txt = $txt;
  135. $node->ssr_scheme = $ssr_scheme;
  136. $node->ss_scheme = $node->compatible ? $ss_scheme : ''; // 节点兼容原版才显示
  137. // 节点在线状态
  138. $nodeInfo = SsNodeInfo::query()->where('node_id', $node->node_id)->where('log_time', '>=', strtotime("-10 minutes"))->orderBy('id', 'desc')->first();
  139. $node->online_status = empty($nodeInfo) || empty($nodeInfo->load) ? 0 : 1;
  140. // 节点标签
  141. $node->labels = SsNodeLabel::query()->with('labelInfo')->where('node_id', $node->id)->get();
  142. }
  143. $view['nodeList'] = $nodeList;
  144. return Response::view('user.index', $view);
  145. }
  146. // 公告详情
  147. public function article(Request $request)
  148. {
  149. $id = $request->get('id');
  150. $view['info'] = Article::query()->where('is_del', 0)->where('id', $id)->first();
  151. if (empty($view['info'])) {
  152. return Redirect::to('/');
  153. }
  154. $view['website_logo'] = self::$systemConfig['website_logo'];
  155. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  156. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  157. return Response::view('user.article', $view);
  158. }
  159. // 修改个人资料
  160. public function profile(Request $request)
  161. {
  162. $user = Session::get('user');
  163. if ($request->method() == 'POST') {
  164. $old_password = $request->get('old_password');
  165. $new_password = $request->get('new_password');
  166. $wechat = $request->get('wechat');
  167. $qq = $request->get('qq');
  168. $passwd = trim($request->get('passwd'));
  169. $method = $request->get('method');
  170. $protocol = $request->get('protocol');
  171. $obfs = $request->get('obfs');
  172. // 修改密码
  173. if ($old_password && $new_password) {
  174. $old_password = md5(trim($old_password));
  175. $new_password = md5(trim($new_password));
  176. $user = User::query()->where('id', $user['id'])->first();
  177. if ($user->password != $old_password) {
  178. Session::flash('errorMsg', '旧密码错误,请重新输入');
  179. return Redirect::to('profile#tab_1');
  180. } elseif ($user->password == $new_password) {
  181. Session::flash('errorMsg', '新密码不可与旧密码一样,请重新输入');
  182. return Redirect::to('profile#tab_1');
  183. }
  184. // 演示环境禁止改管理员密码
  185. if (env('APP_DEMO') && $user['id'] == 1) {
  186. Session::flash('errorMsg', '演示环境禁止修改管理员密码');
  187. return Redirect::to('profile#tab_1');
  188. }
  189. $ret = User::query()->where('id', $user['id'])->update(['password' => $new_password]);
  190. if (!$ret) {
  191. Session::flash('errorMsg', '修改失败');
  192. return Redirect::to('profile#tab_1');
  193. } else {
  194. Session::flash('successMsg', '修改成功');
  195. return Redirect::to('profile#tab_1');
  196. }
  197. }
  198. // 修改联系方式
  199. if ($wechat || $qq) {
  200. if (empty(clean($wechat)) && empty(clean($qq))) {
  201. Session::flash('errorMsg', '修改失败');
  202. return Redirect::to('profile#tab_2');
  203. }
  204. $ret = User::query()->where('id', $user['id'])->update(['wechat' => $wechat, 'qq' => $qq]);
  205. if (!$ret) {
  206. Session::flash('errorMsg', '修改失败');
  207. return Redirect::to('profile#tab_2');
  208. } else {
  209. Session::flash('successMsg', '修改成功');
  210. return Redirect::to('profile#tab_2');
  211. }
  212. }
  213. // 修改SSR(R)设置
  214. if ($method || $protocol || $obfs) {
  215. if (empty($passwd)) {
  216. Session::flash('errorMsg', '密码不能为空');
  217. return Redirect::to('profile#tab_3');
  218. }
  219. // 加密方式、协议、混淆必须存在
  220. $existMethod = SsConfig::query()->where('type', 1)->where('name', $method)->first();
  221. $existProtocol = SsConfig::query()->where('type', 2)->where('name', $protocol)->first();
  222. $existObfs = SsConfig::query()->where('type', 3)->where('name', $obfs)->first();
  223. if (!$existMethod || !$existProtocol || !$existObfs) {
  224. Session::flash('errorMsg', '非法请求');
  225. return Redirect::to('profile#tab_3');
  226. }
  227. $data = [
  228. 'passwd' => $passwd,
  229. 'method' => $method,
  230. 'protocol' => $protocol,
  231. 'obfs' => $obfs
  232. ];
  233. $ret = User::query()->where('id', $user['id'])->update($data);
  234. if (!$ret) {
  235. Session::flash('errorMsg', '修改失败');
  236. return Redirect::to('profile#tab_3');
  237. } else {
  238. // 更新session
  239. $user = User::query()->where('id', $user['id'])->first()->toArray();
  240. Session::remove('user');
  241. Session::put('user', $user);
  242. Session::flash('successMsg', '修改成功');
  243. return Redirect::to('profile#tab_3');
  244. }
  245. }
  246. } else {
  247. // 加密方式、协议、混淆
  248. $view['method_list'] = Helpers::methodList();
  249. $view['protocol_list'] = Helpers::protocolList();
  250. $view['obfs_list'] = Helpers::obfsList();
  251. $view['info'] = User::query()->where('id', $user['id'])->first();
  252. $view['website_logo'] = self::$systemConfig['website_logo'];
  253. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  254. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  255. return Response::view('user.profile', $view);
  256. }
  257. }
  258. // 流量日志
  259. public function trafficLog(Request $request)
  260. {
  261. $user = Session::get('user');
  262. $dailyData = [];
  263. $hourlyData = [];
  264. // 节点一个月内的流量
  265. $userTrafficDaily = UserTrafficDaily::query()->where('user_id', $user['id'])->where('node_id', 0)->where('created_at', '>=', date('Y-m', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();
  266. $dailyTotal = date('d', time()) - 1; // 今天不算,减一
  267. $dailyCount = count($userTrafficDaily);
  268. for ($x = 0; $x < ($dailyTotal - $dailyCount); $x++) {
  269. $dailyData[$x] = 0;
  270. }
  271. for ($x = ($dailyTotal - $dailyCount); $x < $dailyTotal; $x++) {
  272. $dailyData[$x] = round($userTrafficDaily[$x - ($dailyTotal - $dailyCount)] / (1024 * 1024 * 1024), 3);
  273. }
  274. // 节点一天内的流量
  275. $userTrafficHourly = UserTrafficHourly::query()->where('user_id', $user['id'])->where('node_id', 0)->where('created_at', '>=', date('Y-m-d', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();
  276. $hourlyTotal = date('H', time());
  277. $hourlyCount = count($userTrafficHourly);
  278. for ($x = 0; $x < ($hourlyTotal - $hourlyCount); $x++) {
  279. $hourlyData[$x] = 0;
  280. }
  281. for ($x = ($hourlyTotal - $hourlyCount); $x < $hourlyTotal; $x++) {
  282. $hourlyData[$x] = round($userTrafficHourly[$x - ($hourlyTotal - $hourlyCount)] / (1024 * 1024 * 1024), 3);
  283. }
  284. // 本月天数数据
  285. $monthDays = [];
  286. $monthHasDays = date("t");
  287. for ($i = 1; $i <= $monthHasDays; $i++) {
  288. $monthDays[] = $i;
  289. }
  290. $view['trafficDaily'] = "'" . implode("','", $dailyData) . "'";
  291. $view['trafficHourly'] = "'" . implode("','", $hourlyData) . "'";
  292. $view['monthDays'] = "'" . implode("','", $monthDays) . "'";
  293. $view['website_logo'] = self::$systemConfig['website_logo'];
  294. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  295. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  296. return Response::view('user.trafficLog', $view);
  297. }
  298. // 商品列表
  299. public function goodsList(Request $request)
  300. {
  301. $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'));
  302. $view['website_logo'] = self::$systemConfig['website_logo'];
  303. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  304. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  305. return Response::view('user.goodsList', $view);
  306. }
  307. // 工单
  308. public function ticketList(Request $request)
  309. {
  310. $user = Session::get('user');
  311. $view['website_logo'] = self::$systemConfig['website_logo'];
  312. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  313. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  314. $view['ticketList'] = Ticket::query()->where('user_id', $user['id'])->orderBy('id', 'desc')->paginate(10)->appends($request->except('page'));
  315. return Response::view('user.ticketList', $view);
  316. }
  317. // 订单
  318. public function orderList(Request $request)
  319. {
  320. $user = Session::get('user');
  321. $view['orderList'] = Order::query()->with(['user', 'goods', 'coupon', 'payment'])->where('user_id', $user['id'])->orderBy('oid', 'desc')->paginate(10)->appends($request->except('page'));
  322. $view['website_logo'] = self::$systemConfig['website_logo'];
  323. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  324. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  325. return Response::view('user.orderList', $view);
  326. }
  327. // 订单明细
  328. public function orderDetail(Request $request, $sn)
  329. {
  330. $view['website_logo'] = self::$systemConfig['website_logo'];
  331. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  332. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  333. $view['order'] = Order::query()->with(['goods', 'coupon', 'payment'])->where('order_sn', $sn)->firstOrFail();
  334. return Response::view('user.orderDetail', $view);
  335. }
  336. // 添加工单
  337. public function addTicket(Request $request)
  338. {
  339. $title = $request->get('title');
  340. $content = clean($request->get('content'));
  341. $content = str_replace("eval", "", str_replace("atob", "", $content));
  342. $user = Session::get('user');
  343. if (empty($title) || empty($content)) {
  344. return Response::json(['status' => 'fail', 'data' => '', 'message' => '请输入标题和内容']);
  345. }
  346. $obj = new Ticket();
  347. $obj->user_id = $user['id'];
  348. $obj->title = $title;
  349. $obj->content = $content;
  350. $obj->status = 0;
  351. $obj->created_at = date('Y-m-d H:i:s');
  352. $obj->save();
  353. if ($obj->id) {
  354. $emailTitle = "新工单提醒";
  355. $content = "标题:【" . $title . "】<br>内容:" . $content;
  356. // 发邮件通知管理员
  357. if (self::$systemConfig['crash_warning_email']) {
  358. try {
  359. Mail::to(self::$systemConfig['crash_warning_email'])->send(new newTicket(self::$systemConfig['website_name'], $emailTitle, $content));
  360. Helpers::addEmailLog(1, $emailTitle, $content);
  361. } catch (\Exception $e) {
  362. Helpers::addEmailLog(1, $emailTitle, $content, 0, $e->getMessage());
  363. }
  364. }
  365. // 通过ServerChan发微信消息提醒管理员
  366. if (self::$systemConfig['is_server_chan'] && self::$systemConfig['server_chan_key']) {
  367. $serverChan = new ServerChan();
  368. $serverChan->send($emailTitle, $content);
  369. }
  370. return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
  371. } else {
  372. return Response::json(['status' => 'fail', 'data' => '', 'message' => '提交失败']);
  373. }
  374. }
  375. // 回复工单
  376. public function replyTicket(Request $request)
  377. {
  378. $id = intval($request->get('id'));
  379. $user = Session::get('user');
  380. if ($request->method() == 'POST') {
  381. $content = clean($request->get('content'));
  382. $content = str_replace("eval", "", str_replace("atob", "", $content));
  383. $content = substr($content, 0, 300);
  384. if (empty($content)) {
  385. return Response::json(['status' => 'fail', 'data' => '', 'message' => '回复内容不能为空']);
  386. }
  387. $obj = new TicketReply();
  388. $obj->ticket_id = $id;
  389. $obj->user_id = $user['id'];
  390. $obj->content = $content;
  391. $obj->created_at = date('Y-m-d H:i:s');
  392. $obj->save();
  393. if ($obj->id) {
  394. $ticket = Ticket::query()->where('id', $id)->first();
  395. $title = "工单回复提醒";
  396. $content = "标题:【" . $ticket->title . "】<br>用户回复:" . $content;
  397. // 发邮件通知管理员
  398. if (self::$systemConfig['crash_warning_email']) {
  399. try {
  400. Mail::to(self::$systemConfig['crash_warning_email'])->send(new replyTicket(self::$systemConfig['website_name'], $title, $content));
  401. Helpers::addEmailLog(1, $title, $content);
  402. } catch (\Exception $e) {
  403. Helpers::addEmailLog(1, $title, $content, 0, $e->getMessage());
  404. }
  405. }
  406. // 通过ServerChan发微信消息提醒管理员
  407. if (self::$systemConfig['is_server_chan'] && self::$systemConfig['server_chan_key']) {
  408. $serverChan = new ServerChan();
  409. $serverChan->send($title, $content);
  410. }
  411. return Response::json(['status' => 'success', 'data' => '', 'message' => '回复成功']);
  412. } else {
  413. return Response::json(['status' => 'fail', 'data' => '', 'message' => '回复失败']);
  414. }
  415. } else {
  416. $ticket = Ticket::query()->where('id', $id)->with('user')->first();
  417. if (empty($ticket) || $ticket->user_id != $user['id']) {
  418. return Redirect::to('tickets');
  419. }
  420. $view['ticket'] = $ticket;
  421. $view['replyList'] = TicketReply::query()->where('ticket_id', $id)->with('user')->orderBy('id', 'asc')->get();
  422. $view['website_logo'] = self::$systemConfig['website_logo'];
  423. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  424. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  425. return Response::view('user.replyTicket', $view);
  426. }
  427. }
  428. // 关闭工单
  429. public function closeTicket(Request $request)
  430. {
  431. $id = $request->get('id');
  432. $user = Session::get('user');
  433. $ret = Ticket::query()->where('id', $id)->where('user_id', $user['id'])->update(['status' => 2]);
  434. if ($ret) {
  435. return Response::json(['status' => 'success', 'data' => '', 'message' => '关闭成功']);
  436. } else {
  437. return Response::json(['status' => 'fail', 'data' => '', 'message' => '关闭失败']);
  438. }
  439. }
  440. // 邀请码
  441. public function invite(Request $request)
  442. {
  443. $user = Session::get('user');
  444. // 已生成的邀请码数量
  445. $num = Invite::query()->where('uid', $user['id'])->count();
  446. $view['website_logo'] = self::$systemConfig['website_logo'];
  447. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  448. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  449. $view['num'] = self::$systemConfig['invite_num'] - $num <= 0 ? 0 : self::$systemConfig['invite_num'] - $num; // 还可以生成的邀请码数量
  450. $view['inviteList'] = Invite::query()->where('uid', $user['id'])->with(['generator', 'user'])->paginate(10); // 邀请码列表
  451. $view['referral_traffic'] = flowAutoShow(self::$systemConfig['referral_traffic'] * 1048576);
  452. $view['referral_percent'] = self::$systemConfig['referral_percent'];
  453. return Response::view('user.invite', $view);
  454. }
  455. // 公开的邀请码列表
  456. public function free(Request $request)
  457. {
  458. $view['website_logo'] = self::$systemConfig['website_logo'];
  459. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  460. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  461. $view['is_invite_register'] = self::$systemConfig['is_invite_register'];
  462. $view['is_free_code'] = self::$systemConfig['is_free_code'];
  463. $view['inviteList'] = Invite::query()->where('uid', 0)->where('status', 0)->paginate();
  464. return Response::view('user.free', $view);
  465. }
  466. // 生成邀请码
  467. public function makeInvite(Request $request)
  468. {
  469. $user = Session::get('user');
  470. // 已生成的邀请码数量
  471. $num = Invite::query()->where('uid', $user['id'])->count();
  472. if ($num >= self::$systemConfig['invite_num']) {
  473. return Response::json(['status' => 'fail', 'data' => '', 'message' => '生成失败:最多只能生成' . self::$systemConfig['invite_num'] . '个邀请码']);
  474. }
  475. $obj = new Invite();
  476. $obj->uid = $user['id'];
  477. $obj->fuid = 0;
  478. $obj->code = strtoupper(mb_substr(md5(microtime() . makeRandStr()), 8, 12));
  479. $obj->status = 0;
  480. $obj->dateline = date('Y-m-d H:i:s', strtotime("+7 days"));
  481. $obj->save();
  482. return Response::json(['status' => 'success', 'data' => '', 'message' => '生成成功']);
  483. }
  484. // 激活账号页
  485. public function activeUser(Request $request)
  486. {
  487. if ($request->method() == 'POST') {
  488. $username = trim($request->get('username'));
  489. // 是否开启账号激活
  490. if (!self::$systemConfig['is_active_register']) {
  491. Session::flash('errorMsg', '系统未开启账号激活功能,请联系管理员');
  492. return Redirect::back()->withInput();
  493. }
  494. // 查找账号
  495. $user = User::query()->where('username', $username)->first();
  496. if (!$user) {
  497. Session::flash('errorMsg', '账号不存在,请重试');
  498. return Redirect::back();
  499. } elseif ($user->status < 0) {
  500. Session::flash('errorMsg', '账号已禁止登陆,无需激活');
  501. return Redirect::back();
  502. } elseif ($user->status > 0) {
  503. Session::flash('errorMsg', '账号无需激活');
  504. return Redirect::back();
  505. }
  506. // 24小时内激活次数限制
  507. $activeTimes = 0;
  508. if (Cache::has('activeUser_' . md5($username))) {
  509. $activeTimes = Cache::get('activeUser_' . md5($username));
  510. if ($activeTimes >= self::$systemConfig['active_times']) {
  511. Session::flash('errorMsg', '同一个账号24小时内只能请求激活' . self::$systemConfig['active_times'] . '次,请勿频繁操作');
  512. return Redirect::back();
  513. }
  514. }
  515. // 生成激活账号的地址
  516. $token = md5(self::$systemConfig['website_name'] . $username . microtime());
  517. $verify = new Verify();
  518. $verify->user_id = $user->id;
  519. $verify->username = $username;
  520. $verify->token = $token;
  521. $verify->status = 0;
  522. $verify->save();
  523. // 发送邮件
  524. $activeUserUrl = self::$systemConfig['website_url'] . '/active/' . $token;
  525. $title = '重新激活账号';
  526. $content = '请求地址:' . $activeUserUrl;
  527. try {
  528. Mail::to($user->username)->send(new activeUser(self::$systemConfig['website_name'], $activeUserUrl));
  529. Helpers::addEmailLog($user->id, $title, $content);
  530. } catch (\Exception $e) {
  531. Helpers::addEmailLog($user->id, $title, $content, 0, $e->getMessage());
  532. }
  533. Cache::put('activeUser_' . md5($username), $activeTimes + 1, 1440);
  534. Session::flash('successMsg', '激活邮件已发送,如未收到,请查看垃圾邮箱');
  535. return Redirect::back();
  536. } else {
  537. $view['is_active_register'] = self::$systemConfig['is_active_register'];
  538. return Response::view('user.activeUser', $view);
  539. }
  540. }
  541. // 激活账号
  542. public function active(Request $request, $token)
  543. {
  544. if (empty($token)) {
  545. return Redirect::to('login');
  546. }
  547. $verify = Verify::query()->where('token', $token)->with('user')->first();
  548. if (empty($verify)) {
  549. return Redirect::to('login');
  550. } elseif (empty($verify->user)) {
  551. Session::flash('errorMsg', '该链接已失效');
  552. return Response::view('user.active');
  553. } elseif ($verify->status == 1) {
  554. Session::flash('errorMsg', '该链接已失效');
  555. return Response::view('user.active');
  556. } elseif ($verify->user->status != 0) {
  557. Session::flash('errorMsg', '该账号无需激活.');
  558. return Response::view('user.active');
  559. } elseif (time() - strtotime($verify->created_at) >= 1800) {
  560. Session::flash('errorMsg', '该链接已过期');
  561. // 置为已失效
  562. $verify->status = 2;
  563. $verify->save();
  564. return Response::view('user.active');
  565. }
  566. // 更新账号状态
  567. $ret = User::query()->where('id', $verify->user_id)->update(['status' => 1]);
  568. if (!$ret) {
  569. Session::flash('errorMsg', '账号激活失败');
  570. return Redirect::back();
  571. }
  572. // 置为已使用
  573. $verify->status = 1;
  574. $verify->save();
  575. // 账号激活后给邀请人送流量
  576. if ($verify->user->referral_uid) {
  577. $transfer_enable = self::$systemConfig['referral_traffic'] * 1048576;
  578. User::query()->where('id', $verify->user->referral_uid)->increment('transfer_enable', $transfer_enable);
  579. User::query()->where('id', $verify->user->referral_uid)->update(['enable' => 1]);
  580. }
  581. Session::flash('successMsg', '账号激活成功');
  582. return Response::view('user.active');
  583. }
  584. // 重设密码页
  585. public function resetPassword(Request $request)
  586. {
  587. if ($request->method() == 'POST') {
  588. $username = trim($request->get('username'));
  589. // 是否开启重设密码
  590. if (!self::$systemConfig['is_reset_password']) {
  591. Session::flash('errorMsg', '系统未开启重置密码功能,请联系管理员');
  592. return Redirect::back()->withInput();
  593. }
  594. // 查找账号
  595. $user = User::query()->where('username', $username)->first();
  596. if (!$user) {
  597. Session::flash('errorMsg', '账号不存在,请重试');
  598. return Redirect::back();
  599. }
  600. // 24小时内重设密码次数限制
  601. $resetTimes = 0;
  602. if (Cache::has('resetPassword_' . md5($username))) {
  603. $resetTimes = Cache::get('resetPassword_' . md5($username));
  604. if ($resetTimes >= self::$systemConfig['reset_password_times']) {
  605. Session::flash('errorMsg', '同一个账号24小时内只能重设密码' . self::$systemConfig['reset_password_times'] . '次,请勿频繁操作');
  606. return Redirect::back();
  607. }
  608. }
  609. // 生成取回密码的地址
  610. $token = md5(self::$systemConfig['website_name'] . $username . microtime());
  611. $verify = new Verify();
  612. $verify->user_id = $user->id;
  613. $verify->username = $username;
  614. $verify->token = $token;
  615. $verify->status = 0;
  616. $verify->save();
  617. // 发送邮件
  618. $resetPasswordUrl = self::$systemConfig['website_url'] . '/reset/' . $token;
  619. $title = '重置密码';
  620. $content = '请求地址:' . $resetPasswordUrl;
  621. try {
  622. Mail::to($user->username)->send(new resetPassword(self::$systemConfig['website_name'], $resetPasswordUrl));
  623. Helpers::addEmailLog($user->id, $title, $content);
  624. } catch (\Exception $e) {
  625. Helpers::addEmailLog($user->id, $title, $content, 0, $e->getMessage());
  626. }
  627. Cache::put('resetPassword_' . md5($username), $resetTimes + 1, 1440);
  628. Session::flash('successMsg', '重置成功,请查看邮箱');
  629. return Redirect::back();
  630. } else {
  631. $view['website_home_logo'] = self::$systemConfig['website_home_logo'];
  632. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  633. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  634. $view['is_reset_password'] = self::$systemConfig['is_reset_password'];
  635. return Response::view('user.resetPassword', $view);
  636. }
  637. }
  638. // 重设密码
  639. public function reset(Request $request, $token)
  640. {
  641. if ($request->method() == 'POST') {
  642. $password = trim($request->get('password'));
  643. $repassword = trim($request->get('repassword'));
  644. if (empty($token)) {
  645. return Redirect::to('login');
  646. } elseif (empty($password) || empty($repassword)) {
  647. Session::flash('errorMsg', '密码不能为空');
  648. return Redirect::back();
  649. } elseif (md5($password) != md5($repassword)) {
  650. Session::flash('errorMsg', '两次输入密码不一致,请重新输入');
  651. return Redirect::back();
  652. }
  653. // 校验账号
  654. $verify = Verify::query()->where('token', $token)->with('User')->first();
  655. if (empty($verify)) {
  656. return Redirect::to('login');
  657. } elseif ($verify->status == 1) {
  658. Session::flash('errorMsg', '该链接已失效');
  659. return Redirect::back();
  660. } elseif ($verify->user->status < 0) {
  661. Session::flash('errorMsg', '账号已被禁用');
  662. return Redirect::back();
  663. } elseif (md5($password) == $verify->user->password) {
  664. Session::flash('errorMsg', '新旧密码一样,请重新输入');
  665. return Redirect::back();
  666. }
  667. // 更新密码
  668. $ret = User::query()->where('id', $verify->user_id)->update(['password' => md5($password)]);
  669. if (!$ret) {
  670. Session::flash('errorMsg', '重设密码失败');
  671. return Redirect::back();
  672. }
  673. // 置为已使用
  674. $verify->status = 1;
  675. $verify->save();
  676. Session::flash('successMsg', '新密码设置成功,请自行登录');
  677. return Redirect::back();
  678. } else {
  679. if (empty($token)) {
  680. return Redirect::to('login');
  681. }
  682. $verify = Verify::query()->where('token', $token)->with('user')->first();
  683. if (empty($verify)) {
  684. return Redirect::to('login');
  685. } elseif (time() - strtotime($verify->created_at) >= 1800) {
  686. Session::flash('errorMsg', '该链接已过期');
  687. // 置为已失效
  688. $verify->status = 2;
  689. $verify->save();
  690. // 重新获取一遍verify
  691. $view['verify'] = Verify::query()->where('token', $token)->with('user')->first();
  692. return Response::view('user.reset', $view);
  693. }
  694. $view['website_home_logo'] = self::$systemConfig['website_home_logo'];
  695. $view['verify'] = $verify;
  696. return Response::view('user.reset', $view);
  697. }
  698. }
  699. // 使用优惠券
  700. public function redeemCoupon(Request $request)
  701. {
  702. $coupon_sn = $request->get('coupon_sn');
  703. if (empty($coupon_sn)) {
  704. return Response::json(['status' => 'fail', 'data' => '', 'message' => '优惠券不能为空']);
  705. }
  706. $coupon = Coupon::query()->where('sn', $coupon_sn)->whereIn('type', [1, 2])->where('is_del', 0)->first();
  707. if (!$coupon) {
  708. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券不存在']);
  709. } elseif ($coupon->status == 1) {
  710. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已使用,请换一个试试']);
  711. } elseif ($coupon->status == 2) {
  712. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已失效,请换一个试试']);
  713. } elseif ($coupon->available_start > time() || $coupon->available_end < time()) {
  714. $coupon->status = 2;
  715. $coupon->save();
  716. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已失效,请换一个试试']);
  717. }
  718. $data = [
  719. 'type' => $coupon->type,
  720. 'amount' => $coupon->amount,
  721. 'discount' => $coupon->discount
  722. ];
  723. return Response::json(['status' => 'success', 'data' => $data, 'message' => '该优惠券有效']);
  724. }
  725. // 购买服务
  726. public function buy(Request $request, $id)
  727. {
  728. $goods_id = intval($id);
  729. $coupon_sn = $request->get('coupon_sn');
  730. $user = Session::get('user');
  731. if ($request->method() == 'POST') {
  732. $goods = Goods::query()->with(['label'])->where('is_del', 0)->where('status', 1)->where('id', $goods_id)->first();
  733. if (!$goods) {
  734. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:商品或服务已下架']);
  735. }
  736. // 限购控制:all-所有商品限购, free-价格为0的商品限购, none-不限购(默认)
  737. $strategy = self::$systemConfig['goods_purchase_limit_strategy'];
  738. if ($strategy == 'all' || ($strategy == 'package' && $goods->type == 2) || ($strategy == 'free' && $goods->price == 0) || ($strategy == 'package&free' && ($goods->type == 2 || $goods->price == 0))) {
  739. $noneExpireGoodExist = Order::query()->where('status', '>=', 0)->where('is_expire', 0)->where('user_id', $user['id'])->where('goods_id', $goods_id)->exists();
  740. if ($noneExpireGoodExist) {
  741. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:商品不可重复购买']);
  742. }
  743. }
  744. // 使用优惠券
  745. if (!empty($coupon_sn)) {
  746. $coupon = Coupon::query()->where('status', 0)->where('is_del', 0)->whereIn('type', [1, 2])->where('sn', $coupon_sn)->first();
  747. if (empty($coupon)) {
  748. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:优惠券不存在']);
  749. }
  750. // 计算实际应支付总价
  751. $amount = $coupon->type == 2 ? $goods->price * $coupon->discount / 10 : $goods->price - $coupon->amount;
  752. $amount = $amount > 0 ? $amount : 0;
  753. } else {
  754. $amount = $goods->price;
  755. }
  756. // 价格异常判断
  757. if ($amount < 0) {
  758. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:订单总价异常']);
  759. }
  760. // 验证账号余额是否充足
  761. $user = User::query()->where('id', $user['id'])->first();
  762. if ($user->balance < $amount) {
  763. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:您的余额不足,请先充值']);
  764. }
  765. // 验证账号是否存在有效期更长的套餐
  766. if ($goods->type == 2) {
  767. $existOrderList = Order::query()
  768. ->with(['goods'])
  769. ->whereHas('goods', function ($q) {
  770. $q->where('type', 2);
  771. })
  772. ->where('user_id', $user['id'])
  773. ->where('is_expire', 0)
  774. ->where('status', 2)
  775. ->get();
  776. foreach ($existOrderList as $vo) {
  777. if ($vo->goods->days > $goods->days) {
  778. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:您已存在有效期更长的套餐,只能购买流量包']);
  779. }
  780. }
  781. }
  782. DB::beginTransaction();
  783. try {
  784. // 生成订单
  785. $order = new Order();
  786. $order->order_sn = date('ymdHis') . mt_rand(100000, 999999);
  787. $order->user_id = $user->id;
  788. $order->goods_id = $goods_id;
  789. $order->coupon_id = !empty($coupon) ? $coupon->id : 0;
  790. $order->origin_amount = $goods->price;
  791. $order->amount = $amount;
  792. $order->expire_at = date("Y-m-d H:i:s", strtotime("+" . $goods->days . " days"));
  793. $order->is_expire = 0;
  794. $order->pay_way = 1;
  795. $order->status = 2;
  796. $order->save();
  797. // 扣余额
  798. User::query()->where('id', $user->id)->decrement('balance', $amount * 100);
  799. // 记录余额操作日志
  800. $this->addUserBalanceLog($user->id, $order->oid, $user->balance, $user->balance - $amount, -1 * $amount, '购买服务:' . $goods->name);
  801. // 优惠券置为已使用
  802. if (!empty($coupon)) {
  803. if ($coupon->usage == 1) {
  804. $coupon->status = 1;
  805. $coupon->save();
  806. }
  807. // 写入日志
  808. Helpers::addCouponLog($coupon->id, $goods_id, $order->oid, '余额支付订单使用');
  809. }
  810. // 如果买的是套餐,则先将之前购买的所有套餐置都无效,并扣掉之前所有套餐的流量,重置用户已用流量为0
  811. if ($goods->type == 2) {
  812. $existOrderList = Order::query()
  813. ->with(['goods'])
  814. ->whereHas('goods', function ($q) {
  815. $q->where('type', 2);
  816. })
  817. ->where('user_id', $order->user_id)
  818. ->where('oid', '<>', $order->oid)
  819. ->where('is_expire', 0)
  820. ->where('status', 2)
  821. ->get();
  822. foreach ($existOrderList as $vo) {
  823. Order::query()->where('oid', $vo->oid)->update(['is_expire' => 1]);
  824. // 先判断,防止手动扣减过流量的用户流量被扣成负数
  825. if ($order->user->transfer_enable - $vo->goods->traffic * 1048576 <= 0) {
  826. User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0, 'transfer_enable' => 0]);
  827. } else {
  828. User::query()->where('id', $order->user_id)->update(['u' => 0, 'd' => 0]);
  829. User::query()->where('id', $order->user_id)->decrement('transfer_enable', $vo->goods->traffic * 1048576);
  830. }
  831. }
  832. }
  833. // 把商品的流量加到账号上
  834. User::query()->where('id', $user->id)->increment('transfer_enable', $goods->traffic * 1048576);
  835. // 计算账号过期时间
  836. if ($user->expire_time < date('Y-m-d', strtotime("+" . $goods->days . " days"))) {
  837. $expireTime = date('Y-m-d', strtotime("+" . $goods->days . " days"));
  838. } else {
  839. $expireTime = $user->expire_time;
  840. }
  841. // 套餐就改流量重置日,流量包不改
  842. if ($goods->type == 2) {
  843. if (date('m') == 2 && date('d') == 29) {
  844. $traffic_reset_day = 28;
  845. } else {
  846. $traffic_reset_day = date('d') == 31 ? 30 : abs(date('d'));
  847. }
  848. User::query()->where('id', $order->user_id)->update(['traffic_reset_day' => $traffic_reset_day, 'expire_time' => $expireTime, 'enable' => 1]);
  849. } else {
  850. User::query()->where('id', $order->user_id)->update(['expire_time' => $expireTime, 'enable' => 1]);
  851. }
  852. // 写入用户标签
  853. if ($goods->label) {
  854. // 用户默认标签
  855. $defaultLabels = [];
  856. if (self::$systemConfig['initial_labels_for_user']) {
  857. $defaultLabels = explode(',', self::$systemConfig['initial_labels_for_user']);
  858. }
  859. // 取出现有的标签
  860. $userLabels = UserLabel::query()->where('user_id', $user->id)->pluck('label_id')->toArray();
  861. $goodsLabels = GoodsLabel::query()->where('goods_id', $goods_id)->pluck('label_id')->toArray();
  862. // 标签去重
  863. $newUserLabels = array_values(array_unique(array_merge($userLabels, $goodsLabels, $defaultLabels)));
  864. // 删除用户所有标签
  865. UserLabel::query()->where('user_id', $user->id)->delete();
  866. // 生成标签
  867. foreach ($newUserLabels as $vo) {
  868. $obj = new UserLabel();
  869. $obj->user_id = $user->id;
  870. $obj->label_id = $vo;
  871. $obj->save();
  872. }
  873. }
  874. // 写入返利日志
  875. if ($user->referral_uid) {
  876. $this->addReferralLog($user->id, $user->referral_uid, $order->oid, $amount, $amount * self::$systemConfig['referral_percent']);
  877. }
  878. // 取消重复返利
  879. User::query()->where('id', $order->user_id)->update(['referral_uid' => 0]);
  880. DB::commit();
  881. return Response::json(['status' => 'success', 'data' => '', 'message' => '支付成功']);
  882. } catch (\Exception $e) {
  883. DB::rollBack();
  884. Log::error('支付订单失败:' . $e->getMessage());
  885. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:' . $e->getMessage()]);
  886. }
  887. } else {
  888. $goods = Goods::query()->where('id', $goods_id)->where('is_del', 0)->where('status', 1)->first();
  889. if (empty($goods)) {
  890. return Redirect::to('services');
  891. }
  892. $view['goods'] = $goods;
  893. $view['is_youzan'] = self::$systemConfig['is_youzan'];
  894. $view['website_logo'] = self::$systemConfig['website_logo'];
  895. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  896. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  897. return Response::view('user.buy', $view);
  898. }
  899. }
  900. // 积分兑换流量
  901. public function exchange(Request $request)
  902. {
  903. $user = Session::get('user');
  904. // 积分满100才可以兑换
  905. if ($user['score'] < 100) {
  906. return Response::json(['status' => 'fail', 'data' => '', 'message' => '兑换失败:满100才可以兑换,请继续累计吧']);
  907. }
  908. // 账号过期不允许兑换
  909. if ($user['expire_time'] < date('Y-m-d')) {
  910. return Response::json(['status' => 'fail', 'data' => '', 'message' => '兑换失败:账号已过期,请先购买服务吧']);
  911. }
  912. DB::beginTransaction();
  913. try {
  914. // 写入积分操作日志
  915. $ret = $this->addUserScoreLog($user['id'], $user['score'], 0, -1 * $user['score'], '积分兑换流量');
  916. // 扣积分加流量
  917. if ($ret) {
  918. User::query()->where('id', $user['id'])->update(['score' => 0]);
  919. User::query()->where('id', $user['id'])->increment('transfer_enable', $user['score'] * 1048576);
  920. }
  921. DB::commit();
  922. // 更新session
  923. $user = User::query()->where('id', $user['id'])->first()->toArray();
  924. Session::remove('user');
  925. Session::put('user', $user);
  926. return Response::json(['status' => 'success', 'data' => '', 'message' => '兑换成功']);
  927. } catch (\Exception $e) {
  928. DB::rollBack();
  929. return Response::json(['status' => 'fail', 'data' => '', 'message' => '兑换失败:' . $e->getMessage()]);
  930. }
  931. }
  932. // 推广返利
  933. public function referral(Request $request)
  934. {
  935. // 生成个人推广链接
  936. $user = Session::get('user');
  937. $view['website_logo'] = self::$systemConfig['website_logo'];
  938. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  939. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  940. $view['referral_traffic'] = flowAutoShow(self::$systemConfig['referral_traffic'] * 1048576);
  941. $view['referral_percent'] = self::$systemConfig['referral_percent'];
  942. $view['referral_money'] = self::$systemConfig['referral_money'];
  943. $view['totalAmount'] = ReferralLog::query()->where('ref_user_id', $user['id'])->sum('ref_amount') / 100;
  944. $view['canAmount'] = ReferralLog::query()->where('ref_user_id', $user['id'])->where('status', 0)->sum('ref_amount') / 100;
  945. $view['link'] = self::$systemConfig['website_url'] . '/register?aff=' . $user['id'];
  946. $view['referralLogList'] = ReferralLog::query()->where('ref_user_id', $user['id'])->with('user')->orderBy('id', 'desc')->paginate(10);
  947. $view['referralApplyList'] = ReferralApply::query()->where('user_id', $user['id'])->with('user')->orderBy('id', 'desc')->paginate(10);
  948. $view['referralUserList'] = User::query()->select(['username', 'created_at'])->where('referral_uid', $user['id'])->orderBy('id', 'desc')->paginate(10);
  949. return Response::view('user.referral', $view);
  950. }
  951. // 申请提现
  952. public function extractMoney(Request $request)
  953. {
  954. $user = Session::get('user');
  955. // 判断账户是否过期
  956. if ($user['expire_time'] < date('Y-m-d')) {
  957. return Response::json(['status' => 'fail', 'data' => '', 'message' => '申请失败:账号已过期,请先购买服务吧']);
  958. }
  959. // 判断是否已存在申请
  960. $referralApply = ReferralApply::query()->where('user_id', $user['id'])->whereIn('status', [0, 1])->first();
  961. if ($referralApply) {
  962. return Response::json(['status' => 'fail', 'data' => '', 'message' => '申请失败:已存在申请,请等待之前的申请处理完']);
  963. }
  964. // 校验可以提现金额是否超过系统设置的阀值
  965. $ref_amount = ReferralLog::query()->where('ref_user_id', $user['id'])->where('status', 0)->sum('ref_amount');
  966. $ref_amount = $ref_amount / 100;
  967. if ($ref_amount < self::$systemConfig['referral_money']) {
  968. return Response::json(['status' => 'fail', 'data' => '', 'message' => '申请失败:满' . self::$systemConfig['referral_money'] . '元才可以提现,继续努力吧']);
  969. }
  970. // 取出本次申请关联返利日志ID
  971. $link_logs = '';
  972. $referralLog = ReferralLog::query()->where('ref_user_id', $user['id'])->where('status', 0)->get();
  973. foreach ($referralLog as $log) {
  974. $link_logs .= $log->id . ',';
  975. }
  976. $link_logs = rtrim($link_logs, ',');
  977. $obj = new ReferralApply();
  978. $obj->user_id = $user['id'];
  979. $obj->before = $ref_amount;
  980. $obj->after = 0;
  981. $obj->amount = $ref_amount;
  982. $obj->link_logs = $link_logs;
  983. $obj->status = 0;
  984. $obj->save();
  985. return Response::json(['status' => 'success', 'data' => '', 'message' => '申请成功,请等待管理员审核']);
  986. }
  987. // 帮助中心
  988. public function help(Request $request)
  989. {
  990. $view['website_logo'] = self::$systemConfig['website_logo'];
  991. $view['website_analytics'] = self::$systemConfig['website_analytics'];
  992. $view['website_customer_service'] = self::$systemConfig['website_customer_service'];
  993. $view['articleList'] = Article::query()->where('type', 1)->where('is_del', 0)->orderBy('sort', 'desc')->orderBy('id', 'desc')->limit(10)->paginate(15);
  994. return Response::view('user.help', $view);
  995. }
  996. // 更换订阅地址
  997. public function exchangeSubscribe(Request $request)
  998. {
  999. $user = Session::get('user');
  1000. DB::beginTransaction();
  1001. try {
  1002. // 更换订阅地址
  1003. $code = $this->makeSubscribeCode();
  1004. UserSubscribe::query()->where('user_id', $user['id'])->update(['code' => $code]);
  1005. // 更换连接密码
  1006. User::query()->where('id', $user['id'])->update(['passwd' => makeRandStr()]);
  1007. DB::commit();
  1008. return Response::json(['status' => 'success', 'data' => '', 'message' => '更换成功']);
  1009. } catch (\Exception $e) {
  1010. DB::rollBack();
  1011. Log::info("更换订阅地址异常:" . $e->getMessage());
  1012. return Response::json(['status' => 'fail', 'data' => '', 'message' => '更换失败' . $e->getMessage()]);
  1013. }
  1014. }
  1015. // 转换成管理员的身份
  1016. public function switchToAdmin(Request $request)
  1017. {
  1018. if (!Session::has('admin') || !Session::has('user')) {
  1019. return Response::json(['status' => 'fail', 'data' => '', 'message' => '非法请求']);
  1020. }
  1021. $admin = Session::get('admin');
  1022. $user = User::query()->where('id', $admin['id'])->first();
  1023. if (!$user) {
  1024. return Response::json(['status' => 'fail', 'data' => '', 'message' => "非法请求"]);
  1025. }
  1026. // 管理员信息重新写入user
  1027. Session::put('user', Session::get('admin'));
  1028. Session::forget('admin');
  1029. return Response::json(['status' => 'success', 'data' => '', 'message' => "身份切换成功"]);
  1030. }
  1031. // 卡券余额充值
  1032. public function charge(Request $request)
  1033. {
  1034. $user = Session::get('user');
  1035. $coupon_sn = trim($request->get('coupon_sn'));
  1036. if (empty($coupon_sn)) {
  1037. return Response::json(['status' => 'fail', 'data' => '', 'message' => '券码不能为空']);
  1038. }
  1039. $coupon = Coupon::query()->where('sn', $coupon_sn)->where('type', 3)->where('is_del', 0)->where('status', 0)->first();
  1040. if (!$coupon) {
  1041. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该券不可用']);
  1042. }
  1043. DB::beginTransaction();
  1044. try {
  1045. $user = User::query()->where('id', $user['id'])->first();
  1046. // 写入日志
  1047. $this->addUserBalanceLog($user->id, 0, $user->balance, $user->balance + $coupon->amount, $coupon->amount, '用户手动充值 - [充值券:' . $coupon_sn . ']');
  1048. // 余额充值
  1049. $user->balance = $user->balance + $coupon->amount;
  1050. $user->save();
  1051. // 更改卡券状态
  1052. $coupon->status = 1;
  1053. $coupon->save();
  1054. // 写入卡券日志
  1055. Helpers::addCouponLog($coupon->id, 0, 0, '账户余额充值使用');
  1056. DB::commit();
  1057. return Response::json(['status' => 'success', 'data' => '', 'message' => '充值成功']);
  1058. } catch (\Exception $e) {
  1059. Log::error($e->getMessage());
  1060. DB::rollBack();
  1061. return Response::json(['status' => 'fail', 'data' => '', 'message' => '充值失败']);
  1062. }
  1063. }
  1064. // 切换语言
  1065. public function switchLang(Request $request, $locale)
  1066. {
  1067. Session::put("locale", $locale);
  1068. return Redirect::back();
  1069. }
  1070. }