UserController.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Http\Models\Article;
  4. use App\Http\Models\Coupon;
  5. use App\Http\Models\CouponLog;
  6. use App\Http\Models\Goods;
  7. use App\Http\Models\Invite;
  8. use App\Http\Models\Order;
  9. use App\Http\Models\OrderGoods;
  10. use App\Http\Models\SsNode;
  11. use App\Http\Models\SsNodeInfo;
  12. use App\Http\Models\SsNodeOnlineLog;
  13. use App\Http\Models\Ticket;
  14. use App\Http\Models\TicketReply;
  15. use App\Http\Models\User;
  16. use App\Http\Models\UserScoreLog;
  17. use App\Http\Models\UserTrafficLog;
  18. use App\Http\Models\Verify;
  19. use App\Mail\activeUser;
  20. use App\Mail\resetPassword;
  21. use Illuminate\Http\Request;
  22. use Redirect;
  23. use Response;
  24. use Cache;
  25. use Mail;
  26. use DB;
  27. use Log;
  28. class UserController extends BaseController
  29. {
  30. protected static $config;
  31. function __construct()
  32. {
  33. self::$config = $this->systemConfig();
  34. }
  35. public function index(Request $request)
  36. {
  37. if (!$request->session()->has('user')) {
  38. return Redirect::to('login');
  39. }
  40. $view['articleList'] = Article::where('is_del', 0)->orderBy('sort', 'desc')->orderBy('id', 'desc')->paginate(5);
  41. $user = $request->session()->get('user');
  42. $user['totalTransfer'] = $this->flowAutoShow($user['transfer_enable'] - $user['u'] - $user['d']);
  43. $user['usedTransfer'] = $this->flowAutoShow($user['u'] - $user['d']);
  44. $view['info'] = $user;
  45. $view['wechat_qrcode'] = static::$config['wechat_qrcode'];
  46. $view['alipay_qrcode'] = static::$config['alipay_qrcode'];
  47. return Response::view('user/index', $view);
  48. }
  49. // 公告详情
  50. public function article(Request $request)
  51. {
  52. $id = $request->get('id');
  53. $view['info'] = Article::where('is_del', 0)->where('id', $id)->first();
  54. if (empty($view['info'])) {
  55. return Redirect::to('user');
  56. }
  57. return Response::view('user/article', $view);
  58. }
  59. // 修改个人资料
  60. public function profile(Request $request)
  61. {
  62. if (!$request->session()->has('user')) {
  63. return Redirect::to('login');
  64. }
  65. $user = $request->session()->get('user');
  66. if ($request->method() == 'POST') {
  67. $old_password = $request->get('old_password');
  68. $new_password = $request->get('new_password');
  69. $port = trim($request->get('port'));
  70. $passwd = trim($request->get('passwd'));
  71. $method = $request->get('method');
  72. $protocol = $request->get('protocol');
  73. $obfs = $request->get('obfs');
  74. // 修改密码
  75. if (!empty($old_password) && !empty($new_password)) {
  76. $old_password = md5(trim($old_password));
  77. $new_password = md5(trim($new_password));
  78. $user = User::where('id', $user['id'])->first();
  79. if ($user->password != $old_password) {
  80. $request->session()->flash('errorMsg', '旧密码错误,请重新输入');
  81. return Redirect::to('user/profile#tab_1');
  82. } else if ($user->password == $new_password) {
  83. $request->session()->flash('errorMsg', '新密码不可与旧密码一样,请重新输入');
  84. return Redirect::to('user/profile#tab_1');
  85. }
  86. $ret = User::where('id', $user['id'])->update(['password' => $new_password]);
  87. if (!$ret) {
  88. $request->session()->flash('errorMsg', '修改失败');
  89. return Redirect::to('user/profile#tab_1');
  90. } else {
  91. $request->session()->flash('successMsg', '修改成功');
  92. return Redirect::to('user/profile#tab_1');
  93. }
  94. }
  95. // 修改SS信息
  96. if (empty($port)) {
  97. $request->session()->flash('errorMsg', '端口不能为空');
  98. return Redirect::to('user/profile#tab_2');
  99. }
  100. if (empty($passwd)) {
  101. $request->session()->flash('errorMsg', '密码不能为空');
  102. return Redirect::to('user/profile#tab_2');
  103. }
  104. $data = [
  105. //'port' => $port,
  106. 'passwd' => $passwd,
  107. 'method' => $method,
  108. 'protocol' => $protocol,
  109. 'obfs' => $obfs
  110. ];
  111. $ret = User::where('id', $user['id'])->update($data);
  112. if (!$ret) {
  113. $request->session()->flash('errorMsg', '修改失败');
  114. return Redirect::to('user/profile#tab_2');
  115. } else {
  116. // 更新session
  117. $user = User::where('id', $user['id'])->first()->toArray();
  118. $request->session()->remove('user');
  119. $request->session()->put('user', $user);
  120. $request->session()->flash('successMsg', '修改成功');
  121. return Redirect::to('user/profile#tab_2');
  122. }
  123. } else {
  124. // 加密方式、协议、混淆
  125. $view['method_list'] = $this->methodList();
  126. $view['protocol_list'] = $this->protocolList();
  127. $view['obfs_list'] = $this->obfsList();
  128. $view['info'] = User::where('id', $user['id'])->first();
  129. return Response::view('user/profile', $view);
  130. }
  131. }
  132. // 节点列表
  133. public function nodeList(Request $request)
  134. {
  135. if (!$request->session()->has('user')) {
  136. return Redirect::to('login');
  137. }
  138. $user = $request->session()->get('user');
  139. $nodeList = SsNode::paginate(10);
  140. foreach ($nodeList as &$node) {
  141. // 在线人数
  142. $online_log = SsNodeOnlineLog::where('node_id', $node->id)->orderBy('id', 'desc')->first();
  143. $node->online_users = empty($online_log) ? 0 : $online_log->online_user;
  144. // 已产生流量
  145. $u = UserTrafficLog::where('node_id', $node->id)->sum('u');
  146. $d = UserTrafficLog::where('node_id', $node->id)->sum('d');
  147. $node->transfer = $this->flowAutoShow($u + $d);
  148. // 负载
  149. $node_info = SsNodeInfo::where('node_id', $node->id)->orderBy('id', 'desc')->first();
  150. $node->load = empty($node_info->load) ? 0 : $node_info->load;
  151. // 生成ssr scheme
  152. $ssr_str = '';
  153. $ssr_str .= $node->server . ':' . $user['port'];
  154. $ssr_str .= ':' . $user['protocol'] . ':' . $user['method'];
  155. $ssr_str .= ':' . $user['obfs'] . ':' . base64_encode($user['passwd']);
  156. $ssr_str .= '/?obfsparam=' . $user['obfs_param'];
  157. $ssr_str .= '&=protoparam' . $user['protocol_param'];
  158. $ssr_str .= '&remarks=' . base64_encode($node->name);
  159. $ssr_str = $this->base64url_encode($ssr_str);
  160. $ssr_scheme = 'ssr://' . $ssr_str;
  161. // 生成ss scheme
  162. $ss_str = '';
  163. $ss_str .= $user['method'] . ':' . $user['passwd'] . '@';
  164. $ss_str .= $node->server . ':' . $user['port'];
  165. $ss_str = $this->base64url_encode($ss_str) . '#' . 'VPN';
  166. $ss_scheme = 'ss://' . $ss_str;
  167. // 生成文本配置信息
  168. $txt = <<<TXT
  169. 服务器:{$node->server}
  170. 远程端口:{$user['port']}
  171. 本地端口:1080
  172. 密码:{$user['passwd']}
  173. 加密方法:{$user['method']}
  174. 协议:{$user['protocol']}
  175. 协议参数:{$user['protocol_param']}
  176. 混淆方式:{$user['obfs']}
  177. 混淆参数:{$user['obfs_param']}
  178. 路由:绕过局域网及中国大陆地址
  179. TXT;
  180. $node->txt = $txt;
  181. $node->ssr_scheme = $ssr_scheme;
  182. $node->ss_scheme = $ss_scheme;
  183. }
  184. $view['nodeList'] = $nodeList;
  185. return Response::view('user/nodeList', $view);
  186. }
  187. // 流量日志
  188. public function trafficLog(Request $request)
  189. {
  190. if (!$request->session()->has('user')) {
  191. return Redirect::to('login');
  192. }
  193. $user = $request->session()->get('user');
  194. // 30天内的流量
  195. $trafficList = \DB::select("SELECT date(from_unixtime(log_time)) AS dd, SUM(u) AS u, SUM(d) AS d FROM `user_traffic_log` WHERE `user_id` = {$user['id']} GROUP BY `dd`");
  196. foreach ($trafficList as $key => &$val) {
  197. $val->total = ($val->u + $val->d) / (1024 * 1024); // 以M为单位
  198. }
  199. $view['trafficList'] = $trafficList;
  200. return Response::view('user/trafficLog', $view);
  201. }
  202. // 商品列表
  203. public function goodsList(Request $request)
  204. {
  205. $view['goodsList'] = Goods::where('is_del', 0)->paginate(10);
  206. return Response::view('user/goodsList', $view);
  207. }
  208. // 工单
  209. public function ticketList(Request $request)
  210. {
  211. $user = $request->session()->get('user');
  212. $view['ticketList'] = Ticket::where('user_id', $user['id'])->paginate(10);
  213. return Response::view('user/ticketList', $view);
  214. }
  215. // 订单
  216. public function orderList(Request $request)
  217. {
  218. $user = $request->session()->get('user');
  219. $orderList = Order::where('user_id', $user['id'])->orderBy('oid', 'desc')->with('goodsList')->paginate(10);
  220. foreach ($orderList as &$order) {
  221. foreach ($order->goodsList as &$goods) {
  222. $g = Goods::where('id', $goods->goods_id)->first();
  223. $goods->goods_name = $g->name;
  224. }
  225. }
  226. $view['orderList'] = $orderList;
  227. return Response::view('user/orderList', $view);
  228. }
  229. // 添加工单
  230. public function addTicket(Request $request)
  231. {
  232. $title = $request->get('title');
  233. $content = $request->get('content');
  234. $user = $request->session()->get('user');
  235. $obj = new Ticket();
  236. $obj->user_id = $user['id'];
  237. $obj->title = $title;
  238. $obj->content = $content;
  239. $obj->status = 0;
  240. $obj->created_at = date('Y-m-d H:i:s');
  241. $obj->save();
  242. if ($obj->id) {
  243. return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
  244. } else {
  245. return Response::json(['status' => 'fail', 'data' => '', 'message' => '提交失败']);
  246. }
  247. }
  248. // 回复工单
  249. public function replyTicket(Request $request)
  250. {
  251. $id = $request->get('id');
  252. $user = $request->session()->get('user');
  253. if ($request->method() == 'POST') {
  254. $content = $request->get('content');
  255. $obj = new TicketReply();
  256. $obj->ticket_id = $id;
  257. $obj->user_id = $user['id'];
  258. $obj->content = $content;
  259. $obj->created_at = date('Y-m-d H:i:s');
  260. $obj->save();
  261. if ($obj->id) {
  262. return Response::json(['status' => 'success', 'data' => '', 'message' => '回复成功']);
  263. } else {
  264. return Response::json(['status' => 'fail', 'data' => '', 'message' => '回复失败']);
  265. }
  266. } else {
  267. $ticket = Ticket::where('id', $id)->with('user')->first();
  268. if (empty($ticket) || $ticket->user_id != $user['id']) {
  269. return Redirect::to('user/ticketList');
  270. }
  271. $view['ticket'] = $ticket;
  272. $view['replyList'] = TicketReply::where('ticket_id', $id)->with('user')->orderBy('id', 'asc')->get();
  273. return Response::view('user/replyTicket', $view);
  274. }
  275. }
  276. // 关闭工单
  277. public function closeTicket(Request $request)
  278. {
  279. $id = $request->get('id');
  280. $user = $request->session()->get('user');
  281. $ret = Ticket::where('id', $id)->where('user_id', $user['id'])->update(['status' => 2]);
  282. if ($ret) {
  283. return Response::json(['status' => 'success', 'data' => '', 'message' => '关闭成功']);
  284. } else {
  285. return Response::json(['status' => 'fail', 'data' => '', 'message' => '关闭失败']);
  286. }
  287. }
  288. // 邀请码
  289. public function invite(Request $request)
  290. {
  291. if (!$request->session()->has('user')) {
  292. return Redirect::to('login');
  293. }
  294. $user = $request->session()->get('user');
  295. // 已生成的邀请码数量
  296. $num = Invite::where('uid', $user['id'])->count();
  297. $view['num'] = self::$config['invite_num'] - $num <= 0 ? 0 : self::$config['invite_num'] - $num; // 还可以生成的邀请码数量
  298. $view['inviteList'] = Invite::where('uid', $user['id'])->with(['generator', 'user'])->paginate(10); // 邀请码列表
  299. return Response::view('user/invite', $view);
  300. }
  301. // 生成邀请码
  302. public function makeInvite(Request $request)
  303. {
  304. if (!$request->session()->has('user')) {
  305. return Redirect::to('login');
  306. }
  307. $user = $request->session()->get('user');
  308. // 已生成的邀请码数量
  309. $num = Invite::where('uid', $user['id'])->count();
  310. if ($num >= self::$config['invite_num']) {
  311. return Response::json(['status' => 'fail', 'data' => '', 'message' => '生成失败:最多只能生成' . self::$config['invite_num'] . '个邀请码']);
  312. }
  313. $obj = new Invite();
  314. $obj->uid = $user['id'];
  315. $obj->fuid = 0;
  316. $obj->code = strtoupper(mb_substr(md5(microtime() . $this->makeRandStr(6)), 8, 16));
  317. $obj->status = 0;
  318. $obj->dateline = date('Y-m-d H:i:s', strtotime("+7 days"));
  319. $obj->save();
  320. return Response::json(['status' => 'success', 'data' => '', 'message' => '生成成功']);
  321. }
  322. // 激活账号页
  323. public function activeUser(Request $request)
  324. {
  325. if ($request->method() == 'POST') {
  326. $username = trim($request->get('username'));
  327. // 是否开启账号激活
  328. if (!self::$config['is_active_register']) {
  329. $request->session()->flash('errorMsg', '系统未开启账号激活功能,请联系管理员');
  330. return Redirect::back()->withInput();
  331. }
  332. // 查找账号
  333. $user = User::where('username', $username)->first();
  334. if (!$user) {
  335. $request->session()->flash('errorMsg', '账号不存在,请重试');
  336. return Redirect::back();
  337. } else if ($user->status < 0) {
  338. $request->session()->flash('errorMsg', '账号已禁止登陆,无需激活');
  339. return Redirect::back();
  340. } else if ($user->status > 0) {
  341. $request->session()->flash('errorMsg', '账号无需激活');
  342. return Redirect::back();
  343. }
  344. // 24小时内激活次数限制
  345. $activeTimes = 0;
  346. if (Cache::has('activeUser_' . md5($username))) {
  347. $activeTimes = Cache::get('activeUser_' . md5($username));
  348. if ($activeTimes >= self::$config['active_times']) {
  349. $request->session()->flash('errorMsg', '同一个账号24小时内只能请求激活' . self::$config['active_times'] . '次,请勿频繁操作');
  350. return Redirect::back();
  351. }
  352. }
  353. // 生成激活账号的地址
  354. $token = md5(self::$config['website_name'] . $username . microtime());
  355. $verify = new Verify();
  356. $verify->user_id = $user->id;
  357. $verify->username = $username;
  358. $verify->token = $token;
  359. $verify->status = 0;
  360. $verify->save();
  361. // 发送邮件
  362. $activeUserUrl = self::$config['website_url'] . '/active/' . $token;
  363. Mail::to($user->username)->send(new activeUser(self::$config['website_name'], $activeUserUrl));
  364. Cache::put('activeUser_' . md5($username), $activeTimes + 1, 1440);
  365. $request->session()->flash('successMsg', '邮件已发送,请查看邮箱');
  366. return Redirect::back();
  367. } else {
  368. $view['is_active_register'] = self::$config['is_active_register'];
  369. return Response::view('user/activeUser', $view);
  370. }
  371. }
  372. // 激活账号
  373. public function active(Request $request, $token)
  374. {
  375. if (empty($token)) {
  376. return Redirect::to('login');
  377. }
  378. $verify = Verify::where('token', $token)->with('user')->first();
  379. if (empty($verify)) {
  380. return Redirect::to('login');
  381. } else if ($verify->status == 1) {
  382. $request->session()->flash('errorMsg', '该链接已失效');
  383. return Response::view('user/active');
  384. } else if ($verify->user->status != 0) {
  385. $request->session()->flash('errorMsg', '该账号无需激活.');
  386. return Response::view('user/active');
  387. } else if (time() - strtotime($verify->created_at) >= 1800) {
  388. $request->session()->flash('errorMsg', '该链接已过期');
  389. // 置为已失效
  390. $verify->status = 2;
  391. $verify->save();
  392. return Response::view('user/active');
  393. }
  394. // 更新账号状态
  395. $ret = User::where('id', $verify->user_id)->update(['status' => 1]);
  396. if (!$ret) {
  397. $request->session()->flash('errorMsg', '账号激活失败');
  398. return Redirect::back();
  399. }
  400. // 置为已使用
  401. $verify->status = 1;
  402. $verify->save();
  403. $request->session()->flash('successMsg', '账号激活成功');
  404. return Response::view('user/active');
  405. }
  406. // 重设密码页
  407. public function resetPassword(Request $request)
  408. {
  409. if ($request->method() == 'POST') {
  410. $username = trim($request->get('username'));
  411. // 是否开启重设密码
  412. if (!self::$config['is_reset_password']) {
  413. $request->session()->flash('errorMsg', '系统未开启重置密码功能,请联系管理员');
  414. return Redirect::back()->withInput();
  415. }
  416. // 查找账号
  417. $user = User::where('username', $username)->first();
  418. if (!$user) {
  419. $request->session()->flash('errorMsg', '账号不存在,请重试');
  420. return Redirect::back();
  421. }
  422. // 24小时内重设密码次数限制
  423. $resetTimes = 0;
  424. if (Cache::has('resetPassword_' . md5($username))) {
  425. $resetTimes = Cache::get('resetPassword_' . md5($username));
  426. if ($resetTimes >= self::$config['reset_password_times']) {
  427. $request->session()->flash('errorMsg', '同一个账号24小时内只能重设密码' . self::$config['reset_password_times'] . '次,请勿频繁操作');
  428. return Redirect::back();
  429. }
  430. }
  431. // 生成取回密码的地址
  432. $token = md5(self::$config['website_name'] . $username . microtime());
  433. $verify = new Verify();
  434. $verify->user_id = $user->id;
  435. $verify->username = $username;
  436. $verify->token = $token;
  437. $verify->status = 0;
  438. $verify->save();
  439. // 发送邮件
  440. $resetPasswordUrl = self::$config['website_url'] . '/reset/' . $token;
  441. Mail::to($user->username)->send(new resetPassword(self::$config['website_name'], $resetPasswordUrl));
  442. Cache::put('resetPassword_' . md5($username), $resetTimes + 1, 1440);
  443. $request->session()->flash('successMsg', '重置成功,请查看邮箱');
  444. return Redirect::back();
  445. } else {
  446. $view['is_reset_password'] = self::$config['is_reset_password'];
  447. return Response::view('user/resetPassword', $view);
  448. }
  449. }
  450. // 重设密码
  451. public function reset(Request $request, $token)
  452. {
  453. if ($request->method() == 'POST') {
  454. $password = trim($request->get('password'));
  455. $repassword = trim($request->get('repassword'));
  456. if (empty($token)) {
  457. return Redirect::to('login');
  458. } else if (empty($password) || empty($repassword)) {
  459. $request->session()->flash('errorMsg', '密码不能为空');
  460. return Redirect::back();
  461. } else if (md5($password) != md5($repassword)) {
  462. $request->session()->flash('errorMsg', '两次输入密码不一致,请重新输入');
  463. return Redirect::back();
  464. }
  465. // 校验账号
  466. $verify = Verify::where('token', $token)->with('User')->first();
  467. if (empty($verify)) {
  468. return Redirect::to('login');
  469. } else if ($verify->status == 1) {
  470. $request->session()->flash('errorMsg', '该链接已失效');
  471. return Redirect::back();
  472. } else if ($verify->user->status < 0) {
  473. $request->session()->flash('errorMsg', '账号已被禁用');
  474. return Redirect::back();
  475. } else if (md5($password) == $verify->user->password) {
  476. $request->session()->flash('errorMsg', '新旧密码一样,请重新输入');
  477. return Redirect::back();
  478. }
  479. // 更新密码
  480. $ret = User::where('id', $verify->user_id)->update(['password' => md5($password)]);
  481. if (!$ret) {
  482. $request->session()->flash('errorMsg', '重设密码失败');
  483. return Redirect::back();
  484. }
  485. // 置为已使用
  486. $verify->status = 1;
  487. $verify->save();
  488. $request->session()->flash('successMsg', '新密码设置成功,请自行登录');
  489. return Redirect::back();
  490. } else {
  491. if (empty($token)) {
  492. return Redirect::to('login');
  493. }
  494. $verify = Verify::where('token', $token)->with('user')->first();
  495. if (empty($verify)) {
  496. return Redirect::to('login');
  497. } else if (time() - strtotime($verify->created_at) >= 1800) {
  498. $request->session()->flash('errorMsg', '该链接已过期');
  499. // 置为已失效
  500. $verify->status = 2;
  501. $verify->save();
  502. return Response::view('user/reset');
  503. }
  504. $view['verify'] = $verify;
  505. return Response::view('user/reset', $view);
  506. }
  507. }
  508. // 使用优惠券
  509. public function redeemCoupon(Request $request)
  510. {
  511. $coupon_sn = $request->get('coupon_sn');
  512. if (empty($coupon_sn)) {
  513. return Response::json(['status' => 'fail', 'data' => '', 'message' => '优惠券不能为空']);
  514. }
  515. $coupon = Coupon::where('sn', $coupon_sn)->where('is_del', 0)->first();
  516. if (empty($coupon)) {
  517. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券不存在']);
  518. } else if ($coupon->status == 1) {
  519. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已使用,请换一个试试']);
  520. } else if ($coupon->status == 2) {
  521. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已失效,请换一个试试']);
  522. } else if ($coupon->available_start > time() || $coupon->available_end < time()) {
  523. $coupon->status = 2;
  524. $coupon->save();
  525. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该优惠券已失效,请换一个试试']);
  526. }
  527. $data = [
  528. 'type' => $coupon->type,
  529. 'amount' => $coupon->amount,
  530. 'discount' => $coupon->discount
  531. ];
  532. return Response::json(['status' => 'success', 'data' => $data, 'message' => '该优惠券有效']);
  533. }
  534. // 添加订单
  535. public function addOrder(Request $request)
  536. {
  537. $goods_id = intval($request->get('goods_id'));
  538. $coupon_sn = $request->get('coupon_sn');
  539. $user = $request->session()->get('user');
  540. if ($request->method() == 'POST') {
  541. $goods = Goods::where('id', $goods_id)->first();
  542. if (empty($goods)) {
  543. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:商品不存在']);
  544. }
  545. // 使用优惠券
  546. if (!empty($coupon_sn)) {
  547. $coupon = Coupon::where('sn', $coupon_sn)->where('is_del', 0)->where('status', 0)->first();
  548. if (empty($coupon)) {
  549. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:优惠券不存在']);
  550. }
  551. // 计算实际应支付总价
  552. $totalPrice = $coupon->type == 2 ? $goods->price * $coupon->discount : $goods->price - $coupon->amount;
  553. $totalPrice = $totalPrice > 0 ? $totalPrice : 0;
  554. } else {
  555. $totalPrice = $goods->price;
  556. }
  557. // 扣减账号余额
  558. $user = User::where('id', $user['id'])->first();
  559. if ($user->balance < $totalPrice) {
  560. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败:您的余额不足,请先充值']);
  561. } else {
  562. User::where('id', $user['id'])->decrement('balance', $totalPrice);
  563. // TODO:记录日志
  564. }
  565. // 订单长ID
  566. $orderId = date('YmdHis') . mt_rand(100000, 999999);
  567. DB::beginTransaction();
  568. try {
  569. $order = new Order();
  570. $order->orderId = $orderId;
  571. $order->user_id = $user['id'];
  572. $order->coupon_id = !empty($coupon) ? $coupon->id : 0;
  573. $order->totalOriginalPrice = $goods->price;
  574. $order->totalPrice = $totalPrice;
  575. $order->status = 2;
  576. $order->save();
  577. if ($order->oid) {
  578. $orderGoods = new OrderGoods();
  579. $orderGoods->oid = $order->oid;
  580. $orderGoods->orderId = $orderId;
  581. $orderGoods->user_id = $user['id'];
  582. $orderGoods->goods_id = $goods_id;
  583. $orderGoods->num = 1;
  584. $orderGoods->original_price = $goods->price;
  585. $orderGoods->price = $totalPrice;
  586. $orderGoods->save();
  587. }
  588. // 优惠券置为已使用
  589. if (!empty($coupon)) {
  590. if ($coupon->usage == 1) {
  591. $coupon->status = 1;
  592. $coupon->save();
  593. }
  594. // 写入日志
  595. $couponLogObj = new CouponLog();
  596. $couponLogObj->coupon_id = $coupon->id;
  597. $couponLogObj->order_id = $order->id;
  598. $couponLogObj->save();
  599. }
  600. DB::commit();
  601. return Response::json(['status' => 'success', 'data' => '', 'message' => '支付成功']);
  602. } catch (\Exception $e) {
  603. DB::rollBack();
  604. Log::error('支付订单失败:' . $e);
  605. return Response::json(['status' => 'fail', 'data' => '', 'message' => '支付失败']);
  606. }
  607. } else {
  608. $view['goods'] = Goods::where('id', $goods_id)->first();
  609. return Response::view('user/addOrder', $view);
  610. }
  611. }
  612. // 积分兑换流量
  613. public function exchange(Request $request)
  614. {
  615. if (!$request->session()->has('user')) {
  616. return Redirect::to('login');
  617. }
  618. $user = $request->session()->get('user');
  619. // 积分满100才可以兑换
  620. if ($user['score'] < 100) {
  621. return Response::json(['status' => 'fail', 'data' => '', 'message' => '兑换失败:满100才可以兑换,请继续累计吧']);
  622. }
  623. DB::beginTransaction();
  624. try {
  625. // 写入积分操作日志
  626. $userScoreLog = new UserScoreLog();
  627. $userScoreLog->user_id = $user['id'];
  628. $userScoreLog->before = $user['score'];
  629. $userScoreLog->after = 0;
  630. $userScoreLog->score = -1 * $user['score'];
  631. $userScoreLog->desc = '积分兑换流量';
  632. $userScoreLog->created_at = date('Y-m-d H:i:s');
  633. $userScoreLog->save();
  634. // 扣积分加流量
  635. if ($userScoreLog->id) {
  636. User::where('id', $user['id'])->update(['score' => 0]);
  637. User::where('id', $user['id'])->increment('transfer_enable', $user['score'] * 1048576);
  638. }
  639. DB::commit();
  640. // 更新session
  641. $user = User::where('id', $user['id'])->first()->toArray();
  642. $request->session()->remove('user');
  643. $request->session()->put('user', $user);
  644. return Response::json(['status' => 'success', 'data' => '', 'message' => '兑换成功']);
  645. } catch (\Exception $e) {
  646. DB::rollBack();
  647. return Response::json(['status' => 'fail', 'data' => '', 'message' => '兑换失败:' . $e->getMessage()]);
  648. }
  649. }
  650. }