UserController.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710
  1. <?php
  2. namespace App\Http\Controllers\Wap\User;
  3. use App\Libs\AliSMS;
  4. use App\Modules\Book\Services\BookConfigService;
  5. use App\Modules\Book\Services\BookUrgeUpdateService;
  6. use App\Modules\Book\Services\SignBookService;
  7. use App\Modules\Statistic\Services\AdVisitStatService;
  8. use App\Modules\Subscribe\Services\OrderService;
  9. use App\Modules\User\Services\ForceGuidePersonAccountService;
  10. use App\Modules\User\Services\ReadRecordService;
  11. use App\Modules\User\Services\UserBindPhoneService;
  12. use App\Modules\User\Services\UserWealthyOperateRecordService;
  13. use App\Modules\User\Services\WapReaderPageFissionService;
  14. use Illuminate\Http\Request;
  15. use App\Http\Controllers\Wap\BaseController;
  16. use App\Modules\Subscribe\Services\YearOrderService;
  17. use App\Modules\User\Services\UserService;
  18. use App\Modules\User\Services\UserRandSignService;
  19. use App\Modules\User\Services\UserSignService;
  20. use App\Http\Controllers\Wap\User\Transformers\SignRecordTransformer;
  21. use Log;
  22. use Redis;
  23. use Cookie;
  24. use DB;
  25. use Hashids;
  26. class UserController extends BaseController
  27. {
  28. /**
  29. * @apiDefine User 用户
  30. */
  31. /**
  32. * @apiVersion 1.0.0
  33. * @apiDescription 获取用户信息
  34. * @api {GET} userinfo 获取用户信息
  35. * @apiGroup User
  36. * @apiName index
  37. * @apiSuccess {Number} id 用户ID.
  38. * @apiSuccess {String} openid 微信openid.
  39. * @apiSuccess {String} unionid 微信unionid.
  40. * @apiSuccess {Number} distribution_channel_id 分销渠道ID.
  41. * @apiSuccess {String} province 省份.
  42. * @apiSuccess {String} city 城市.
  43. * @apiSuccess {String} country 国家.
  44. * @apiSuccess {String} headimgurl 头像地址.
  45. * @apiSuccess {Number} send_order_id 派单ID.
  46. * @apiSuccess {Number=0,1} sex 性别.
  47. * @apiSuccess {String} balance 书币余额.
  48. * @apiSuccess {Int} is_vip 是否vip
  49. * @apiSuccess {String} vip_days 364天.
  50. * @apiSuccessExample {json} Success-Response:
  51. *
  52. * {
  53. * "code": 0,
  54. * "msg": "",
  55. * "data": {
  56. * "id": 56,
  57. * "openid": "sdfs34ssdfdsf",
  58. * "unionid": "SDFSD3343S",
  59. * "distribution_channel_id": 1212,
  60. * "province": "浙江省",
  61. * "city": "杭州",
  62. * "country": "中国",
  63. * "headimgurl": "http://.."
  64. * "send_order_id": 323
  65. * "balance": 8956
  66. * "register_time": "2017-12-12 12:12:12"
  67. * }
  68. * }
  69. */
  70. public function index(){
  71. if(!$this->checkUid()){
  72. return response()->error('NOT_LOGIN');
  73. }
  74. $data = UserService::getById($this->uid);
  75. $data['bind'] = 0;
  76. $data['bind_phone'] = '';
  77. $data['is_paid'] = $this->is_paid;
  78. if($this->is_paid){
  79. $bind_info = UserBindPhoneService::bindInfo($this->uid);
  80. if($bind_info){
  81. $data['bind'] = 1;
  82. $data['bind_phone'] = $bind_info->phone;
  83. }
  84. }
  85. $data['is_vip'] = 0;
  86. $data['vip_days'] = 0;
  87. $year_record = YearOrderService::getRecord($this->uid);
  88. if($year_record){
  89. $data['is_vip'] = 1;
  90. $time = strtotime($year_record['end_time'])-time();
  91. if($time>=86400){
  92. $data['vip_days'] = floor($time/86400).'天';
  93. }elseif ($time>3600) {
  94. $data['vip_days'] = floor($time/3600).'小时';
  95. }elseif ($time>60) {
  96. $data['vip_days'] = floor($time/60).'分钟';
  97. }else{
  98. $data['vip_days'] = $time.'秒';
  99. }
  100. }
  101. $data['is_all_life'] = 0;
  102. $activity_id = env('FOREVER_ACTIVITY_ID');
  103. if($activity_id){
  104. if(OrderService::userIsParticipateActivity($this->uid,$activity_id)){
  105. $data['is_vip'] = 0 ;
  106. $data['vip_days'] = '99年';
  107. $data['is_all_life'] = 1;
  108. }
  109. }
  110. return response()->success($data);
  111. }
  112. /**
  113. * @apiVersion 1.0.0
  114. * @apiDescription 用户签到记录
  115. * @api {GET} user/sign_record 用户签到记录
  116. * @apiGroup User
  117. * @apiName signRecord
  118. * @apiSuccess {int} code 状态码
  119. * @apiSuccess {String} msg 信息
  120. * @apiSuccess {object} data 结果集
  121. * @apiSuccess {reward} data.reward 奖励金额.
  122. * @apiSuccess {sign_time} data.sign_time 签到时间.
  123. * @apiParam {page} page
  124. * @apiSuccessExample {json} Success-Response:
  125. *
  126. * {
  127. * code: 0,
  128. * msg: "",
  129. * data: {
  130. * list: [
  131. * {
  132. * reward: 50,
  133. * sign_time: "2018-03-20 13:43:11"
  134. * },
  135. * {
  136. * reward: 50,
  137. * sign_time: "2018-01-18 16:22:33"
  138. * },
  139. * ],
  140. * meta: {
  141. * total: 12,
  142. * per_page: 15,
  143. * current_page: 1,
  144. * last_page: 1,
  145. * next_page_url: "",
  146. * prev_page_url: ""
  147. * }
  148. * }
  149. * }
  150. */
  151. public function signRecord(Request $request){
  152. $sign_result = paginationTransform(new SignRecordTransformer(),UserSignService::getUserSignRecord($this->uid));
  153. $sign_status = UserSignService::isSign($this->uid);
  154. $sign_today = [];
  155. if($sign_status){
  156. $sign_today = ReadRecordService::getByField($this->uid,'sign_info');
  157. if($sign_today) $sign_today = json_decode($sign_today,1);
  158. isset($sign_today['sign_time']) && $sign_today['sign_time'] = date('Y-m-d H:i:s',$sign_today['sign_time']);
  159. isset($sign_today['sign_at']) && $sign_today['sign_time'] = $sign_today['sign_at'];
  160. isset($sign_today['price']) && $sign_today['reward'] = $sign_today['price'];
  161. }
  162. $result = [
  163. 'sign_status'=>$sign_status,
  164. 'sign_result'=>$sign_result,
  165. 'sign_today'=>$sign_today
  166. ];
  167. return response()->success($result);
  168. }
  169. public function getCoupons(Request $request){
  170. $activity_id = $request->input('activity_id');
  171. if(!DB::table('discount_coupons')->where('uid',$this->uid)->where('activity_id',$activity_id)->count()){
  172. DB::table('discount_coupons')->insert([
  173. 'uid'=>$this->uid,
  174. 'activity_id'=>$activity_id,
  175. 'created_at'=>date('Y-m-d H:i:s'),
  176. 'updated_at'=>date('Y-m-d H:i:s')
  177. ]);
  178. }
  179. return response()->success();
  180. }
  181. public function sign(Request $request){
  182. //sign_days
  183. //$day = date('Y-m-d');
  184. $sign = UserSignService::isSign($this->uid);
  185. $sign_count = ReadRecordService::getSignCount($this->uid);
  186. if($sign){
  187. //如果已经签过到
  188. if(!$sign_count){
  189. ReadRecordService::setSignCount($this->uid,1);
  190. ReadRecordService::setSignDay($this->uid);
  191. $sign_count = 1;
  192. }
  193. $fee = 30;
  194. if($sign_count>=3){
  195. $fee = 50;
  196. }
  197. $data = ['sign_days'=>$sign_count,'sign_reard'=>$fee,'status'=>1];
  198. return response()->success($data);
  199. }
  200. //还没有签到
  201. $status = UserSignService::signToday($this->uid);
  202. $sign_count = ReadRecordService::getSignCount($this->uid);
  203. $data = ['sign_days'=>$sign_count,'sign_reard'=>$status,'status'=>0];
  204. return response()->success($data);
  205. }
  206. /**
  207. * @return string
  208. */
  209. public function signi()
  210. {
  211. /*if(in_array($this->distribution_channel_id,explode(',',redisEnv('NEW_SIGN_CHANNELS','')))){
  212. $version = UserSignService::getUserSignVersion($this->uid);
  213. }else{
  214. $version = 'v1';
  215. }*/
  216. $version = UserSignService::getUserSignVersion($this->uid);
  217. if($version == 'v1'){
  218. $page = 'wap.sign';
  219. }else{
  220. $page = 'wap.signv2';
  221. }
  222. $book1= $book2 = null;
  223. if($version == 'v2' ){
  224. $sex = $this->_user_info->sex;
  225. $sex = $sex?$sex:2;
  226. $book1 = BookConfigService::getRandomOneHighQualityBook($sex);
  227. $book1->url = sprintf('/reader?bid=%s&cid=%s&source=wechatmsg&fromtype=sign_recommend',Hashids::encode($book1->bid),$book1->first_cid);
  228. $book2 = SignBookService::getRandomBook($sex);
  229. \Log::info($book2);
  230. foreach ($book2 as $item){
  231. $item->url = sprintf('/reader?bid=%s&cid=%s&source=wechatmsg&fromtype=sign_recommend',Hashids::encode($item->bid),$item->first_cid);
  232. }
  233. }
  234. $tomorrow_pool = $fee_pool = [0,30,50,120,50,50,50,150];
  235. $day = [0,'一','二','三','四','五','六','七'];
  236. list($sign,$sign_count) = ReadRecordService::getByMultiField($this->uid,'sign_day','sign_counts');
  237. if ($sign && $sign == date('Y-m-d')) {
  238. if($version == 'v1'){
  239. $fee = $sign_count>=3 ? 50:30;
  240. }else{
  241. if ($sign_count % 7 == 1 && $sign_count<=7) {
  242. $fee = 30;
  243. } elseif ($sign_count % 7 == 3) {
  244. $fee = 120;
  245. } elseif ($sign_count % 7 == 0) {
  246. $fee = 150;
  247. } else {
  248. $fee = 50;
  249. }
  250. }
  251. if($sign_count >=8){
  252. $fee_pool[1] = 50;
  253. }
  254. $tomorrow = (($sign_count+1) % 7 == 0? 7:($sign_count+1) % 7);
  255. if($sign_count+1 >=8){
  256. $tomorrow_pool[1] = 50;
  257. }
  258. //签过到了
  259. $data = ['sign_count'=>$sign_count,'fee'=>$fee,'fee_pool'=>$fee_pool,'day'=>$day,'book1'=>$book1,'book2'=>$book2,'tomorrow_fee'=>$tomorrow_pool[$tomorrow]];
  260. return view($page,$data);
  261. }
  262. $fee = UserSignService::signToday($this->uid,$version);
  263. if(!$fee){
  264. return response()->error('WAP_SYS_ERROR');
  265. }
  266. $sign_count = ReadRecordService::getSignCount($this->uid);
  267. if($sign_count >=8){
  268. $fee_pool[1] = 50;
  269. }
  270. if($sign_count+1 >=8){
  271. $tomorrow_pool[1] = 50;
  272. }
  273. $tomorrow = (($sign_count+1) % 7 == 0? 7:($sign_count+1) % 7);
  274. $data = ['sign_count'=>$sign_count,'fee'=>$fee,'fee_pool'=>$fee_pool,'day'=>$day,'book1'=>$book1,'book2'=>$book2,'tomorrow_fee'=>$tomorrow_pool[$tomorrow]];
  275. return view($page,$data);
  276. }
  277. public function signV3(){
  278. //修改签到页面,version=v2
  279. $fee_pool = [0,30,50,120,50,50,50,150];
  280. list($sign,$sign_count) = ReadRecordService::getByMultiField($this->uid,'sign_day','sign_counts');
  281. $read_record = $this->getSignPageReadRecord($all_bid);
  282. $user = $this->_user_info;
  283. $recommend_book = $this->getSignRecomandBook($user->sex,$all_bid);
  284. if ($sign && $sign == date('Y-m-d')) {
  285. if ($sign_count % 7 == 1 && $sign_count<=7) {
  286. $fee = 30;
  287. } elseif ($sign_count % 7 == 3) {
  288. $fee = 120;
  289. } elseif ($sign_count % 7 == 0) {
  290. $fee = 150;
  291. } else {
  292. $fee = 50;
  293. }
  294. if($sign_count >=8){
  295. $fee_pool[1] = 50;
  296. }
  297. $day = $sign_count%7;
  298. if($day == 0){
  299. $day = 7;
  300. }
  301. //签过到了
  302. $name = $user->nickname;
  303. $head_img = $user->head_img;
  304. $balance = $user->balance;
  305. $data = ['sign_count'=>$sign_count,'fee'=>$fee,'fee_pool'=>$fee_pool,
  306. 'day'=>$day,'is_alert'=>0,'read_record'=>$read_record,'name'=>$name,
  307. 'head_img'=>$head_img,
  308. 'balance'=>$balance,
  309. 'recommend_book'=>$recommend_book
  310. ];
  311. return view('wap.signV3',$data);
  312. }
  313. $fee = UserSignService::signToday($this->uid,'v2');
  314. if(!$fee){
  315. return response()->error('WAP_SYS_ERROR');
  316. }
  317. $sign_count++;
  318. if($sign_count >=8){
  319. $fee_pool[1] = 50;
  320. }
  321. $day = $sign_count%7;
  322. if($day == 0){
  323. $day = 7;
  324. }
  325. //签过到了
  326. $name = $user->nickname;
  327. $head_img = $user->head_img;
  328. $balance = $user->balance;
  329. $data = ['sign_count'=>$sign_count,'fee'=>$fee,'fee_pool'=>$fee_pool,
  330. 'day'=>$day,'is_alert'=>1,'read_record'=>$read_record,
  331. 'name'=>$name,
  332. 'head_img'=>$head_img,
  333. 'balance'=>$balance,
  334. 'recommend_book'=>$recommend_book
  335. ];
  336. return view('wap.signV3',$data);
  337. }
  338. private function getSignPageReadRecord(&$all_id){
  339. $res = ReadRecordService::getReadRecord($this->uid);
  340. if($res){
  341. $id_arr = [];
  342. foreach ($res as $key => $value) {
  343. if($key < 2){
  344. $id_arr[] = $value['bid'];
  345. }
  346. $all_id[] = $value['bid'];
  347. }
  348. $book = BookConfigService::getBooksByIds($id_arr);
  349. foreach ($res as $key => &$value) {
  350. $value['cover'] = '';
  351. $value['url'] = sprintf('/reader?bid=%s&cid=%s',Hashids::encode($value['bid']),$value['cid']);
  352. $value['last_chapter'] = 0;
  353. $value['update_count'] = 0;
  354. foreach ($book as $val) {
  355. if($value['bid'] == $val->bid){
  356. $value['cover'] = $val->cover;
  357. $value['last_chapter'] = $val->last_chapter;
  358. if($val->status == 0){
  359. $value['update_count'] = DB::table('book_updates')
  360. ->where('bid',$val->bid)->where('update_type','add_chapter')
  361. ->where('created_at','>=',date('Y-m-d H:i:s',$value['time']))
  362. ->count();
  363. }
  364. break;
  365. }
  366. }
  367. }
  368. }
  369. return $res;
  370. }
  371. private function getSignRecomandBook(int $sex,array $all_bid):array
  372. {
  373. if($sex == 1){
  374. $set_key = 'male_high_reco_bids';
  375. }else{
  376. $set_key = 'female_high_reco_bids';
  377. }
  378. $bids = Cookie::get('sign_recomand_bids');
  379. if(!$bids){
  380. $bid_array = Redis::Srandmember($set_key,16);
  381. //Log::info($bid_array);
  382. $time = strtotime(date('Y-m-d',time()+86400))-time();
  383. $new_bid_array = [];
  384. foreach ($bid_array as $item){
  385. if(in_array($item,$all_bid)){
  386. array_unshift($new_bid_array,$item);
  387. }else{
  388. array_push($new_bid_array,$item);
  389. }
  390. }
  391. $bids = implode(',',$new_bid_array);
  392. Cookie::queue('sign_recomand_bids',$bids,$time);
  393. }
  394. //Log::info($bids);
  395. $result = DB::select(sprintf('select book_configs.book_name,intro,bid,books.category_name,book_configs.cover,first_cid,
  396. (select GROUP_CONCAT(tags) from book_tags where bid = book_configs.bid) as tag from book_configs
  397. left join books on books.id = book_configs.bid left join book_categories on book_categories.id = books.category_id
  398. where bid in (%s) and is_on_shelf =2 ORDER by field(book_configs.bid,%s)',$bids,$bids));
  399. $data = [];
  400. foreach ($result as $item){
  401. $tag_list = [];
  402. if($item->tag){
  403. $tag_list = explode(',',$item->tag);
  404. }
  405. $data[] = [
  406. 'book_name'=>$item->book_name,
  407. 'intro'=>$item->intro,
  408. 'bid'=>$item->bid,
  409. 'category_name'=>$item->category_name,
  410. 'cover'=>$item->cover,
  411. 'tag'=>$item->tag,
  412. 'tag_list'=>$tag_list,
  413. 'url'=>sprintf('/reader?bid=%s&cid=%s&source=wechatmsg&fromtype=sign_recommend',Hashids::encode($item->bid),$item->first_cid),
  414. ];
  415. }
  416. return $data;
  417. }
  418. public function recordShare(Request $request){
  419. if(!$this->checkUid()){
  420. return response()->error('NOT_LOGIN');
  421. }
  422. $uid = $this->uid;
  423. $distribution_channel_id = $this->distribution_channel_id;
  424. $type = 'click';
  425. $bid = $request->get('bid');
  426. $cid = $request->get('cid',0);
  427. if(!$bid){
  428. return response()->error('PARAM_ERROR');
  429. }
  430. !is_numeric($bid) && $bid = Hashids::decode($bid)[0];
  431. WapReaderPageFissionService::createV2($uid,$bid,$distribution_channel_id,$type,0,$cid);
  432. $user = $this->_user_info;
  433. $data = [];
  434. if(in_array($distribution_channel_id,[2,14,211]) && $user){
  435. $data['username'] = $user->nickname;
  436. $data['head_img'] = $user->head_img;
  437. $url = 'https://'._domain().'/detail?fromtype=readershare&id='.Hashids::encode($bid).'&fromflag='.$uid;
  438. //$url = str_replace('http://', $h5_scheme . '://', url()->current() . '?' . http_build_query($params));
  439. $data['share_url'] = $url;
  440. }
  441. return response()->success($data);
  442. }
  443. /**
  444. * @apiVersion 1.0.0
  445. * @apiDescription 用户点击广告统计
  446. * @api {post} user/advisitstat 用户点击广告统计
  447. * @apiGroup User
  448. * @apiName signRecord
  449. * @apiParam {Int} bid bid
  450. * @apiParam {Int} cid cid
  451. * @apiParam {Int} type type类型(CLICK|UNLOCK)
  452. * @apiSuccess {int} code 状态码
  453. * @apiSuccess {String} msg 信息
  454. * @apiSuccess {object} data 结果集
  455. * @apiParam {page} page
  456. * @apiSuccessExample {json} Success-Response:
  457. *
  458. * {
  459. * code: 0,
  460. * msg: "",
  461. * data: {
  462. * {
  463. * reward: 50,
  464. * sign_time: "2018-03-20 13:43:11"
  465. * },
  466. * {
  467. * reward: 50,
  468. * sign_time: "2018-01-18 16:22:33"
  469. * },
  470. * }
  471. * }
  472. */
  473. public function adVisitStat(Request $request){
  474. $bid = $request->get('bid');
  475. $cid = $request->get('cid',0);
  476. $type = $request->get('type');
  477. if(!$bid || !$type){
  478. return response()->error('PARAM_ERROR');
  479. }
  480. !is_numeric($bid) && $bid = Hashids::decode($bid)[0];
  481. AdVisitStatService::create($this->uid,$bid,$cid,$type);
  482. return response()->success();
  483. }
  484. public function urgeUpdate(Request $request){
  485. $bid = $request->get('bid');
  486. if(!$bid){
  487. return response()->error('PARAM_ERROR');
  488. }
  489. $bid = Hashids::decode($bid)[0];
  490. $result = BookUrgeUpdateService::UrgeRecord($this->uid,$bid);
  491. if($result && !$result->id){
  492. BookUrgeUpdateService::UrgeUpdate($this->uid,$bid,$result->updated_at);
  493. }
  494. return response()->success();
  495. }
  496. function logout(Request $request,$channel_id,$domain)
  497. {
  498. //echo $channel_id.'----';
  499. //echo $domain;
  500. $domains = ['zhuishuyun','66kshu','iycdm','leyuee'];
  501. setcookie(env('COOKIE_AUTH_WEB_WECHAT'), '', -1);
  502. setcookie('u', '', -1);
  503. setcookie('force_show_qrcode', '', -1);
  504. setcookie('sub_random_num', '', -1);
  505. setcookie('cpc_ad_status', '', -1);
  506. //return response('logout');
  507. $param = $request->except('_url');
  508. $url_format = '%s://site%s.%s.com/logout?%s';
  509. if(in_array($domain,$domains)){
  510. $i = 0;
  511. foreach ($domains as $k=>$v){
  512. if($v == $domain){
  513. $i = $k;
  514. }
  515. }
  516. if(isset($domains[$i+1])){
  517. $link = sprintf($url_format,env('PROTOCOL'),$channel_id,$domains[$i+1],http_build_query($param)) ;
  518. return redirect()->to($link);
  519. }
  520. }
  521. return view('help.logout');
  522. }
  523. function setOrderDelCookie(Request $request){
  524. $param = $request->except('_url');
  525. $type = isset($param['type']) ?$param['type']:'set';
  526. foreach ($param as $k=>$v){
  527. if($k == 'type') continue;
  528. if($type == 'set'){
  529. Cookie::queue($k, $v, 1000, null, null, false, false);
  530. }else{
  531. setcookie($k, '', -1);
  532. }
  533. }
  534. return response('ok');
  535. }
  536. function test_add_user_login_cookie(Request $request)
  537. {
  538. $uid = $request->get('uid');
  539. \Log::info('test_add_user_login_cookie:'.$uid);
  540. Cookie::queue(env('COOKIE_AUTH_WEB_WECHAT'), $uid, env('U_COOKIE_EXPIRE'), null, null, false, false);
  541. return response('add_cookie:'.$uid);
  542. }
  543. //日常随机签到
  544. function day_rand_sign(Request $request)
  545. {
  546. $uid = $this->uid;
  547. $day = date('Y-m-d');
  548. $hasSigned = UserRandSignService::hasSigned(compact('uid','day'));
  549. $fee = 0;
  550. if(!$hasSigned)
  551. {
  552. $fee = mt_rand(5,15);
  553. UserRandSignService::sign(compact('uid','day','fee'));
  554. }
  555. return view('wap.rand_sign',compact('hasSigned','fee'));
  556. }
  557. public function sendCode(Request $request){
  558. $phone = $request->post('phone');
  559. $code = random_int(1000,9999);
  560. Redis::setex('code:'.$phone,120,$code);
  561. AliSMS::send($phone, 'paid_user_bind_phone', ['code'=>$code]);
  562. return response()->success();
  563. }
  564. public function bindPhone(Request $request){
  565. $code = $request->post('code');
  566. $phone = $request->post('phone');
  567. $from = $request->post('from');
  568. $old = Redis::get('code:'.$phone);
  569. if($old && $old == $code){
  570. Redis::del('code:'.$phone);
  571. $user_info = UserService::getById($this->uid);
  572. if(!$user_info){
  573. return response()->error();
  574. }
  575. try{
  576. $result = UserBindPhoneService::bind($this->uid,$user_info->openid,$phone,$from);
  577. if($result == 0){
  578. UserService::addBalance($this->uid,100,0,100);
  579. UserWealthyOperateRecordService::create($this->uid,100,$this->distribution_channel_id,'bind_phone');
  580. return response()->success();
  581. }
  582. if($result == -1){
  583. return response()->error('WAP_BIND_PHONE_EXIST');
  584. }
  585. if($result == -2){
  586. return response()->error('WAP_SEND_OPENID_EXIST');
  587. }
  588. }catch (\Exception $e){}
  589. }else{
  590. return response()->error('WAP_SEND_CODE_ERROR');
  591. }
  592. return response()->error();
  593. }
  594. public function bindPhoneView(Request $request){
  595. $from = 'personal';
  596. $order = '';
  597. $url = '/personal';
  598. return view('pay.order.bindPhone', compact('order', 'url','from'));
  599. }
  600. public function guidePersonalAccount(Request $request){
  601. $bid = $request->get('bid');
  602. $cid = $request->get('cid');
  603. $prev_cid = $request->get('prev_cid');
  604. $book_name = $request->get('book_name');
  605. $bid_no = Hashids::decode($bid)[0];
  606. $env_config = redisEnvMulti('FORCE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE','FORCE_GUIDE_PERSONAL_ACCOUNT_MAX_UV',
  607. 'FORCE_GUIDE_PERSONAL_ACCOUNT_ID','FORCE_GUIDE_PERSONAL_ACCOUNT_MAX_EVERY_UV');
  608. $img = empty($env_config[0])?'https://cdn-novel.iycdm.com/h5/personal_account/chenchen.jpg':$env_config[0];
  609. $max = empty($env_config[1])?100:$env_config[1];
  610. $one_loop_max = empty($env_config[3])?10:$env_config[3];
  611. $now_id = (int)$env_config[2];
  612. $uv = Redis::scard('force_guide_personal_uv');
  613. $personal_info = DB::table('personal_account_list')->where('id',$now_id)->select('count')->first();
  614. $total_max = $personal_info->count+$uv;
  615. //Log::info('$total_max is: '.);
  616. if($uv >= $one_loop_max || $total_max>=$max){
  617. if($total_max>=$max){
  618. DB::table('personal_account_list')->where('id',$now_id)->update([
  619. 'status'=>2,
  620. 'count'=>$total_max,
  621. 'updated_at'=>date('Y-m-d H:i:s')
  622. ]);
  623. }else{
  624. DB::table('personal_account_list')->where('id',$now_id)->increment('count',$uv,[
  625. 'updated_at'=>date('Y-m-d H:i:s')
  626. ]);
  627. }
  628. $account = DB::table('personal_account_list')
  629. ->where('is_enable',1)
  630. ->whereIn('status',[1,0])
  631. ->select('id','url')
  632. ->where('count','<',$max)
  633. ->where('group','FORCE')
  634. ->orderBy('count','asc')
  635. ->orderBy('id')
  636. ->first();
  637. Redis::del('force_guide_personal_uv');
  638. if($account){
  639. DB::table('personal_account_list')->where('id',$account->id)->update([
  640. 'status'=>1,
  641. 'updated_at'=>date('Y-m-d H:i:s')
  642. ]);
  643. $img = $account->url;
  644. $now_id = $account->id;
  645. Redis::Hmset('env','FORCE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE',$account->url,'FORCE_GUIDE_PERSONAL_ACCOUNT_ID',$account->id);
  646. }else{
  647. Redis::Hmset('env','FORCE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE','','FORCE_GUIDE_PERSONAL_ACCOUNT_ID','');
  648. }
  649. }
  650. Redis::sadd('force_guide_personal_uv',$this->uid);
  651. DB::table('ad_pdd')->insert([
  652. 'uid'=>$this->uid,
  653. 'img'=>'FORCE_GUIDE_PERSONAL_ACCOUNT_'.$now_id,
  654. 'date'=>date('Y-m-d'),
  655. 'created_at'=>date('Y-m-d H:i:s'),
  656. 'updated_at'=>date('Y-m-d H:i:s')
  657. ]);
  658. ForceGuidePersonAccountService::create($this->uid,$bid_no,$cid);
  659. $link['next'] = sprintf('/reader?bid=%s&cid=%s',$bid,$cid);
  660. $link['prev'] = sprintf('/reader?bid=%s&cid=%s',$bid,$prev_cid);
  661. $link['catalog'] = sprintf('/catalog?id=%s',$bid);
  662. return view('jump.forceGuidePersonalAccount',['img'=>$img,'link'=>$link,'title'=>$book_name]);
  663. }
  664. }