CoflController.php 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616
  1. <?php
  2. namespace App\Http\Controllers\Wap\User;
  3. use App\Modules\Activity\Services\ActivityService;
  4. use App\Modules\Book\Services\BookConfigService;
  5. use App\Modules\Channel\Models\Channel;
  6. use App\Modules\Subscribe\Models\BookOrder;
  7. use App\Modules\Subscribe\Models\YearOrder;
  8. use App\Modules\Subscribe\Services\YearOrderService;
  9. use App\Modules\User\Models\User;
  10. use App\Modules\User\Services\ReadRecordService;
  11. use App\Modules\User\Services\UserBindHkWelfareService;
  12. use App\Modules\User\Services\UserService;
  13. use Illuminate\Http\Request;
  14. use App\Http\Controllers\Controller;
  15. use Hashids;
  16. use EasyWeChat\Foundation\Application;
  17. use Log;
  18. use Exception;
  19. use Redis;
  20. use Cookie;
  21. use DB;
  22. /**
  23. * 朋友圈链接
  24. * Class CoflController
  25. * @package App\Http\Controllers\Wap\User
  26. */
  27. class CoflController extends Controller
  28. {
  29. public function index(Request $request){
  30. $bid = $request->get('bid');
  31. if(empty($bid)){
  32. $default_ink = $this->getLink();
  33. return redirect()->to($default_ink);
  34. }
  35. $openid = $request->get('openid');
  36. //授权
  37. $params = $request->except('_url');
  38. if(empty($openid)){
  39. //$url = str_replace('http://', env('PROTOCOL') . '://', url()->current() . '?' . http_build_query($params));
  40. $url = url()->current() . '?' . http_build_query($params);
  41. $params['redirect_url'] = urlencode($url);
  42. $app = new Application($this->auth($params));
  43. return $app->oauth->redirect();
  44. }
  45. try{
  46. $bid = Hashids::decode($bid)[0];
  47. }catch (Exception $e){
  48. return redirect()->to($this->getLink());
  49. }
  50. $crm = $request->get('crm');
  51. //获取用户
  52. //$user = $this->getUsers($openid);
  53. $test_param = $request->input('test',0);
  54. //if($test_param ==1 || $test_param =='1' ) {
  55. $user = $this->getUsersV2($openid);
  56. //}
  57. if(!$user[0]){
  58. $user[1] = 123;
  59. }
  60. //有阅读纪录的跳转
  61. $read_record = ReadRecordService::getByField($user[0],$bid);
  62. if($read_record){
  63. $cid = explode('_',$read_record)[0];
  64. }else{
  65. //没有阅读记录的跳转
  66. $book_info = BookConfigService::getBookById($bid);
  67. $cid = $book_info->first_cid;
  68. }
  69. $params['cid'] = $cid;
  70. $params['crm'] ='book_'.$bid;
  71. if(isset($params['openid'])) unset($params['openid']);
  72. if(isset($params['unionid'])) unset($params['unionid']);
  73. $url = $this->getLink($user[1]).'reader?'.http_build_query($params);
  74. $this->stats('book',$crm);
  75. $this->statsDetail($user[0],'book',$bid);
  76. return redirect()->to($url);
  77. }
  78. public function freeCurrencyView(Request $request){
  79. $openid = $request->get('openid');
  80. //授权
  81. $params = $request->except('_url');
  82. if(empty($openid)){
  83. //$url = str_replace('http://', env('PROTOCOL') . '://', url()->current() . '?' . http_build_query($params));
  84. $url = url()->current() . '?' . http_build_query($params);
  85. $params['redirect_url'] = urlencode($url);
  86. $app = new Application($this->auth($params));
  87. return $app->oauth->redirect();
  88. }
  89. $uri = $request->path();
  90. $token = $request->get('token');
  91. $rfee = $request->get('amount');
  92. $crm = $request->get('crm','reward');
  93. $source = $request->get('wx','none');
  94. $type = 'CRM';
  95. if($uri == 'freethrhcurrency'){
  96. $fee = 300;
  97. $this->stats('reward_300',$crm);
  98. }elseif($uri == 'wfreecurrency'){
  99. $fee = 200;
  100. $type = 'WCRM';
  101. }elseif ($uri == 'frocefreethrhcurrency'){
  102. $fee = 200;
  103. $type = 'CRM_FORCE';
  104. }
  105. else{
  106. $this->stats('reward_200',$crm);
  107. $fee = $this->freeCurrencyFee($token,$rfee);
  108. }
  109. //$user = $this->getUsers($openid);
  110. $user = $this->getUsersV2($openid);
  111. if(!$user || !$user[0] || !$user[1]) return redirect()->to($this->getLink().'?'.http_build_query($params));
  112. if($type == 'CRM'){
  113. $this->statsDetail($user[0],'reward',0);
  114. }elseif ($type == 'CRM_FORCE'){
  115. $this->statsDetail($user[0],'forcereward',0);
  116. } else{
  117. $this->statsDetail($user[0],'wreward',0);
  118. }
  119. $get_free_currency = UserBindHkWelfareService::isHasGet($user[0]);
  120. if($get_free_currency){
  121. //已经领过
  122. if(isset($user[2]) && !empty($user[2]) && isset($user[3]) && !empty($user[3])){
  123. $bid = Hashids::encode($user[2]);
  124. $cid = $user[3];
  125. $params['bid'] = $bid;
  126. $params['cid'] = $cid;
  127. $link = $this->getLink($get_free_currency->distribution_channel_id).'reader?'.http_build_query($params);
  128. }else{
  129. $link = $this->getLink($get_free_currency->distribution_channel_id).'recent?'.http_build_query($params);
  130. }
  131. return view('jump.bindHkFreeCurrency',['fee'=>$fee,'url'=>$link,'is_get'=>1,'uid'=>$get_free_currency->uid,'source'=>$source]);
  132. }else{
  133. if(isset($user[2]) && !empty($user[2]) && isset($user[3]) && !empty($user[3])){
  134. $bid = Hashids::encode($user[2]);
  135. $cid = $user[3];
  136. $params['bid'] = $bid;
  137. $params['cid'] = $cid;
  138. $link = $this->getLink($user[1]).'reader?'.http_build_query($params);
  139. }else{
  140. $link = $this->getLink($user[1]).'recent?'.http_build_query($params);
  141. }
  142. $this->getReward($user[0],$fee,$source,$type);
  143. return view('jump.bindHkFreeCurrency',['fee'=>$fee,'url'=>$link,'is_get'=>0,'uid'=>$user[0],'source'=>$source]);
  144. }
  145. }
  146. private function freeCurrencyFee($token,$fee){
  147. if(!$token || !$fee) return 200;
  148. $param['fee'] = $fee;
  149. if( _sign($param,env('SECRET_KEY')) == $token) return $fee;
  150. return 200;
  151. }
  152. public function freeCurrencyPost(Request $request){
  153. $uid = $request->post('uid');
  154. $fee = $request->post('fee',200);
  155. $source = $request->post('source','');
  156. $result = UserBindHkWelfareService::getfreeCurrency($uid,$fee,'CRM',$source);
  157. if($result){
  158. UserService::addBalance($uid,$fee,0,$fee);
  159. }
  160. return response()->success(['uid'=>$uid,'result'=>$result]);
  161. }
  162. private function getReward($uid,$fee,$source,$crm='CRM'){
  163. $result = UserBindHkWelfareService::getfreeCurrency($uid,$fee,$crm,$source);
  164. if($result){
  165. UserService::addBalance($uid,$fee,0,$fee);
  166. }
  167. }
  168. public function activity(Request $request){
  169. $token = $request->get('token');
  170. if(empty($token)){
  171. $default_ink = $this->getLink();
  172. return redirect()->to($default_ink);
  173. }
  174. $openid = $request->get('openid');
  175. //授权
  176. $params = $request->except('_url');
  177. if(empty($openid)){
  178. $url = url()->current() . '?' . http_build_query($params);
  179. $params['redirect_url'] = urlencode($url);
  180. $app = new Application($this->auth($params));
  181. return $app->oauth->redirect();
  182. }
  183. $crm = $request->get('crm');
  184. $this->stats('activity',$crm);
  185. $activity = ActivityService::getByToken($token);
  186. if($activity){
  187. $user = $this->getUsers($openid);
  188. $distribution_channel_id = (isset($user[1]) && !empty($user[1]))?$user[1]:123;
  189. $url_format = '%s://site%s.%s.com%s';
  190. $activity_page = $activity->activity_page ;
  191. if($activity->id == 6000){
  192. $activity_page = '/activity/common?token=LNyAqbFMgvkmvnHP8PXV3DYPIIhQm3oe';
  193. }
  194. $url = sprintf($url_format, env('PROTOCOL'), encodeDistributionChannelId($distribution_channel_id),
  195. env('CUSTOM_HOST'),
  196. $activity_page
  197. );
  198. return redirect()->to($url);
  199. }
  200. $default_ink = $this->getLink();
  201. return redirect()->to($default_ink);
  202. }
  203. public function recent(Request $request){
  204. $openid = $request->get('openid');
  205. //授权
  206. $params = $request->except('_url');
  207. if(empty($openid)){
  208. $url = url()->current() . '?' . http_build_query($params);
  209. $params['redirect_url'] = urlencode($url);
  210. $app = new Application($this->auth($params));
  211. return $app->oauth->redirect();
  212. }
  213. $user = $this->getUsers($openid);
  214. if(!$user[0]){
  215. $distribution_channel_id = 123;
  216. }else{
  217. $distribution_channel_id = $user[1];
  218. }
  219. $crm = $request->get('crm');
  220. $this->stats('recent',$crm);
  221. $this->statsDetail($user[0],'recent',0);
  222. $link = $this->getLink($distribution_channel_id).'recent?'.http_build_query($params);
  223. return redirect()->to($link);
  224. }
  225. public function person(Request $request){
  226. $openid = $request->get('openid');
  227. //授权
  228. $params = $request->except('_url');
  229. if(empty($openid)){
  230. $url = url()->current() . '?' . http_build_query($params);
  231. $params['redirect_url'] = urlencode($url);
  232. $app = new Application($this->auth($params));
  233. return $app->oauth->redirect();
  234. }
  235. $user = $this->getUsers($openid);
  236. if(!$user[0]){
  237. $distribution_channel_id = 123;
  238. }else{
  239. $distribution_channel_id = $user[1];
  240. }
  241. $crm = $request->get('crm');
  242. $this->stats('person',$crm);
  243. $this->statsDetail($user[0],'person',0);
  244. $link = $this->getLink($distribution_channel_id).'person?'.http_build_query($params);
  245. return redirect()->to($link);
  246. }
  247. public function sign(Request $request){
  248. $openid = $request->get('openid');
  249. //授权
  250. $params = $request->except('_url');
  251. if(empty($openid)){
  252. $url = url()->current() . '?' . http_build_query($params);
  253. $params['redirect_url'] = urlencode($url);
  254. $app = new Application($this->auth($params));
  255. return $app->oauth->redirect();
  256. }
  257. $user = $this->getUsers($openid);
  258. if(!$user[0]){
  259. $distribution_channel_id = 123;
  260. }else{
  261. $distribution_channel_id = $user[1];
  262. }
  263. $crm = $request->get('crm');
  264. $uri = $request->path();
  265. if($uri == 'sign'){
  266. $this->stats('sign',$crm);
  267. $this->statsDetail($user[0],'sign',0);
  268. }elseif($uri == 'wsign'){
  269. $this->stats('wsign',$crm);
  270. $this->statsDetail($user[0],'wsign',0);
  271. }
  272. $link = $this->getLink($distribution_channel_id).'sign?'.http_build_query($params);
  273. return redirect()->to($link);
  274. }
  275. private function getUsers($openid){
  276. $users = User::where('openid',$openid)->select('id','distribution_channel_id')->get();
  277. if($users->isEmpty()) return [0,0,0,0];
  278. $temp = null;
  279. $distribution_channel_id = 0;
  280. $uid = 0;
  281. $bid = 0;
  282. $cid = 0;
  283. foreach ($users as $user){
  284. $last_read = ReadRecordService::getByField($user->id,'last_read');
  285. if(!$last_read) continue;
  286. if(!$temp ){
  287. $distribution_channel_id = $user->distribution_channel_id;
  288. $uid = $user->id;
  289. $temp = $last_read;
  290. }else{
  291. $temp_last_read_info = explode('_',$temp);
  292. $last_read_info = explode('_',$last_read);
  293. if($last_read_info[2] > $temp_last_read_info[2]){
  294. $uid = $user->id;
  295. $distribution_channel_id = $user->distribution_channel_id;
  296. $temp = $last_read;
  297. $bid = $last_read_info[0];
  298. $cid = $last_read_info[1];
  299. }
  300. }
  301. }
  302. return [$uid,$distribution_channel_id,$bid,$cid];
  303. }
  304. /**
  305. * @param $openid
  306. * @return array
  307. */
  308. private function getUsersV2($openid){
  309. $friend_link_uid_bind = DB::table('friend_link_uid_bind')->where('openid',$openid)->first();
  310. if($friend_link_uid_bind) {
  311. $user = User::where('id',$friend_link_uid_bind->uid)->select('id','distribution_channel_id')->first();
  312. if($user) {
  313. \Log::info('user;'.json_encode($user));
  314. return [$user->id,$user->distribution_channel_id];
  315. }
  316. }
  317. $inner_channels = Channel::join('channel_users','channel_users.id','=','distribution_channels.channel_user_id')
  318. ->select('distribution_channels.id')
  319. ->whereIn('channel_users.id',explode(',',redisEnv('PROMOTION_GROUP_CHANNEL_USER_ID')))
  320. ->get()
  321. ->pluck('id')
  322. ->toArray();
  323. //\Log::info($inner_channels);
  324. $users = User::where('openid',$openid)->select('id','distribution_channel_id')->get();
  325. \Log::info('users:openid:'.$openid);
  326. if($users->isEmpty()) return [0,0];
  327. $temp = null;
  328. $distribution_channel_id = 0;
  329. $uid = 0;
  330. $inner_channel_uid_list = [];
  331. //先筛网站运营部UID
  332. foreach ($users as $user){
  333. if(in_array($user->distribution_channel_id,$inner_channels)) {
  334. $inner_channel_uid_list[] = $user;
  335. }
  336. }
  337. if(count($inner_channel_uid_list) == 1) {
  338. $insert_data = ['uid'=>$inner_channel_uid_list[0]->id,'openid'=>$openid ,'created_at'=>date('Y-m-d H:i:s'),'updated_at'=>date('Y-m-d H:i:s')];
  339. \Log::info('anchor:count $inner_channel_uid_list =1');
  340. DB::table('friend_link_uid_bind')->insert($insert_data);
  341. return [$inner_channel_uid_list[0]->id,$inner_channel_uid_list[0]->distribution_channel_id];
  342. }
  343. if(count($inner_channel_uid_list)>1) {
  344. //有多个网站运营部UID,针对网站运营部UID进入到下一步筛选
  345. $users = $inner_channel_uid_list;
  346. }
  347. //筛选包年UID
  348. $uid_list = [];
  349. foreach ($users as $item) {
  350. $uid_list[] =$item->id;
  351. }
  352. $year_order = YearOrder::whereIn('uid',$uid_list)->orderBy('end_time','desc')->first();
  353. if($year_order) {
  354. foreach ($users as $item) {
  355. if($item->id == $year_order->uid) {
  356. //筛选包年结束时间最后的UID
  357. $insert_data = ['uid'=>$item->id,'openid'=>$openid ,'created_at'=>date('Y-m-d H:i:s'),'updated_at'=>date('Y-m-d H:i:s')];
  358. \Log::info('anchor:year_order');
  359. DB::table('friend_link_uid_bind')->insert($insert_data);
  360. return [$item->id,$item->distribution_channel_id];
  361. }
  362. }
  363. }
  364. //按订阅章节数最多的筛选
  365. $users_select = ['id'=>0,'count'=>0,'user'=>null,'create_time'=>0];
  366. foreach ($users as $each){
  367. $table_prefix = ($each->id)%512;
  368. $chapter_count = DB::connection('chapter_order_mysql')
  369. ->table('chapter_orders'.$table_prefix)
  370. ->where('created_at','>=',date('Y-m-d H:i:s',strtotime('-3 day')))
  371. ->where('uid',$each->id)
  372. //->where('bid',$bid)
  373. ->count('id');
  374. $book_order = BookOrder::where('uid',$each->id)
  375. //->where('bid',$bid)
  376. ->where('created_at','>=',date('Y-m-d H:i:s',strtotime('-3 day')))
  377. ->first();
  378. if($book_order) {
  379. $chapter_count += 30;
  380. }
  381. //$each->chapter_count = $chapter_count;
  382. if($chapter_count>$users_select['count']) {
  383. $users_select['id'] = $each->id;
  384. $users_select['count'] = $chapter_count;
  385. $users_select['user'] = $each;
  386. }
  387. }
  388. if($users_select['id'] >0) {
  389. $insert_data = ['uid'=>$users_select['user']->id,'openid'=>$openid ,'created_at'=>date('Y-m-d H:i:s'),'updated_at'=>date('Y-m-d H:i:s')];
  390. \Log::info('anchor:subs_chapter');
  391. DB::table('friend_link_uid_bind')->insert($insert_data);
  392. return [$users_select['user']->id,$users_select['user']->distribution_channel_id];
  393. }
  394. //有订阅记录的
  395. foreach ($users as $value) {
  396. $table_prefix = ($value->id)%512;
  397. $chapter_order = DB::connection('chapter_order_mysql')
  398. ->table('chapter_orders'.$table_prefix)
  399. ->where('uid',$value->id)
  400. //->where('bid',$bid)
  401. ->orderBy('created_at','desc')
  402. ->first();
  403. $book_order = BookOrder::where('uid',$value->id)
  404. //->where('bid',$bid)
  405. ->first();
  406. if($chapter_order ){
  407. if(strtotime($chapter_order->created_at) > $users_select['create_time']) {
  408. $users_select['id'] = $value->id;
  409. $users_select['create_time'] = strtotime($chapter_order->created_at);
  410. $users_select['user'] = $value;
  411. }
  412. }
  413. if($book_order){
  414. if(strtotime($book_order->created_at) > $users_select['create_time']){
  415. $users_select['id']=$value->id;
  416. $users_select['create_time']= strtotime($book_order->created_at);
  417. $users_select['user']= $value;
  418. }
  419. }
  420. }
  421. if($users_select['id'] >0) {
  422. $insert_data = ['uid'=>$users_select['user']->id,'openid'=>$openid ,'created_at'=>date('Y-m-d H:i:s'),'updated_at'=>date('Y-m-d H:i:s')];
  423. \Log::info('anchor:subs_');
  424. DB::table('friend_link_uid_bind')->insert($insert_data);
  425. return [$users_select['user']->id,$users_select['user']->distribution_channel_id];
  426. }
  427. if(count($inner_channel_uid_list)>1) {
  428. //有多个网站运营部UID,针对网站运营部UID进入到下一步筛选
  429. $insert_data = ['uid'=>$inner_channel_uid_list[0]->id,'openid'=>$openid ,'created_at'=>date('Y-m-d H:i:s'),'updated_at'=>date('Y-m-d H:i:s')];
  430. \Log::info('anchor:count $inner_channel_uid_list >1');
  431. DB::table('friend_link_uid_bind')->insert($insert_data);
  432. return [$inner_channel_uid_list[0]['id'],$inner_channel_uid_list[0]['distribution_channel_id']];
  433. }
  434. \Log::info('anchor:over');
  435. return [0,0];
  436. }
  437. private function getLink($distribution_channel_id=123){
  438. $url_format = '%s://site%s.%s.com/';
  439. return sprintf(
  440. $url_format,
  441. env('PROTOCOL'),
  442. encodeDistributionChannelId($distribution_channel_id),
  443. env('CUSTOM_HOST')
  444. );
  445. }
  446. private function auth($param){
  447. $param['appid'] = 'wx9d389a73b88bbeae';
  448. $options = [
  449. 'app_id' => 'wx9d389a73b88bbeae',
  450. 'secret' => '2f6594bb595dfa256b5512e43a32a3d3',
  451. 'oauth' => [
  452. 'scopes' => ['snsapi_base'],
  453. 'callback' => env('AUTH_CALLBACK_URL') . '?' . http_build_query($param),
  454. ],
  455. ];
  456. return $options;
  457. }
  458. private function stats($page,$flag){
  459. if(!$page || !$flag) return ;
  460. //pv
  461. $day = date('Y-m-d');
  462. $pv_key = sprintf('crm:pv:%s',$flag);
  463. Redis::hincrby($pv_key, $day, 1);
  464. //Redis::hincrby($pv_key, 'total', 1);
  465. Redis::sadd('crm_'.$day,$flag);
  466. //uv
  467. $cookie_flag = Cookie::get('crm_flag');
  468. if(!$cookie_flag || $cookie_flag != $flag){
  469. $uv_key = sprintf('crm:uv:%s',$flag);
  470. Redis::hincrby($uv_key, $day, 1);
  471. //Redis::hincrby($uv_key, 'total', 1);
  472. }
  473. Cookie::queue('crm_flag', $flag, env('U_COOKIE_EXPIRE'), null, null, false, false);
  474. }
  475. private function statsDetail($uid,$page,$bid=0)
  476. {
  477. try{
  478. DB::table('crm_visit_detail')->insert([
  479. 'uid'=>$uid,'page'=>$page,
  480. 'bid'=>$bid,'day'=>date('Y-m-d'),
  481. 'created_at'=>date('Y-m-d H:i:s'),
  482. 'updated_at'=>date('Y-m-d H:i:s')
  483. ]);
  484. }catch (\Exception $e){}
  485. }
  486. public function longActivity(Request $request)
  487. {
  488. $openid = $request->get('openid');
  489. //授权
  490. $params = $request->except('_url');
  491. if(empty($openid)){
  492. $url = url()->current() . '?' . http_build_query($params);
  493. $params['redirect_url'] = urlencode($url);
  494. $app = new Application($this->auth($params));
  495. return $app->oauth->redirect();
  496. }
  497. $user = $this->getUsers($openid);
  498. if(!$user[0]){
  499. $distribution_channel_id = 123;
  500. }else{
  501. $distribution_channel_id = $user[1];
  502. }
  503. $crm = $request->get('crm');
  504. $this->stats('activity',$crm);
  505. $baselink = $this->getLink($distribution_channel_id).'activity/crm?'.http_build_query($params);
  506. if(isset($params['token']) && !empty($params['token'])){
  507. return redirect()->to($baselink.'activity/crm?'.http_build_query($params));
  508. }
  509. return redirect()->to($baselink);
  510. }
  511. public function guidePersonalAccount(Request $request,$channel_id){
  512. $uid = $request->get('uid',0);
  513. $env_config = redisEnvMulti('ACTIVE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE',
  514. 'ACTIVE_GUIDE_PERSONAL_ACCOUNT_MAX_UV','ACTIVE_GUIDE_PERSONAL_ACCOUNT_ID',
  515. 'ACTIVE_GUIDE_PERSONAL_ACCOUNT_MAX_EVERY_UV');
  516. $img = empty($env_config[0])?'https://cdn-novel.iycdm.com/h5/personal_account/chenchen.jpg':$env_config[0];
  517. $max = empty($env_config[1])?100:$env_config[1];
  518. $one_loop_max = empty($env_config[3])?10:$env_config[3];
  519. $now_id = (int)$env_config[2];
  520. $uv = Redis::scard('active_guide_personal_uv');
  521. $personal_info = DB::table('personal_account_list')->where('id',$now_id)->select('count')->first();
  522. $total_max = $personal_info->count+$uv;
  523. //Log::info('$total_max is: '.);
  524. if($uv >= $one_loop_max || $total_max>=$max){
  525. if($total_max>=$max){
  526. DB::table('personal_account_list')->where('id',$now_id)->update([
  527. 'status'=>2,
  528. 'count'=>$total_max,
  529. 'updated_at'=>date('Y-m-d H:i:s')
  530. ]);
  531. }else{
  532. DB::table('personal_account_list')->where('id',$now_id)->increment('count',$uv,[
  533. 'updated_at'=>date('Y-m-d H:i:s')
  534. ]);
  535. }
  536. $account = DB::table('personal_account_list')
  537. ->where('is_enable',1)
  538. ->whereIn('status',[1,0])
  539. ->select('id','url')
  540. ->where('group','ACTIVE')
  541. ->where('count','<',$max)
  542. ->orderBy('count','asc')
  543. ->orderBy('id')
  544. ->first();
  545. Redis::del('active_guide_personal_uv');
  546. if($account){
  547. DB::table('personal_account_list')->where('id',$account->id)->update([
  548. 'status'=>1,
  549. 'updated_at'=>date('Y-m-d H:i:s')
  550. ]);
  551. $img = $account->url;
  552. $now_id = $account->id;
  553. Redis::Hmset('env','ACTIVE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE',$account->url,'ACTIVE_GUIDE_PERSONAL_ACCOUNT_ID',$account->id);
  554. }else{
  555. Redis::Hmset('env','ACTIVE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE','','ACTIVE_GUIDE_PERSONAL_ACCOUNT_ID','');
  556. return back();
  557. }
  558. }
  559. Redis::sadd('active_guide_personal_uv',$uid);
  560. if($uid){
  561. DB::table('ad_pdd')->insert([
  562. 'uid'=>$uid,
  563. 'img'=>'GUIDE_PERSONAL_ACCOUNT_'.$now_id,
  564. 'date'=>date('Y-m-d'),
  565. 'created_at'=>date('Y-m-d H:i:s'),
  566. 'updated_at'=>date('Y-m-d H:i:s')
  567. ]);
  568. }
  569. /*if(in_array($channel_id,explode(',',redisEnv('GUIDE_PERSONAL_ACCOUNT_WEID_SITES')))){
  570. $imgs = redisEnv('GUIDE_PERSONAL_ACCOUNT_WEID_QRCODE',[]);
  571. if($imgs) $imgs = json_decode($imgs,1);
  572. $page = 'jump.guidePersonalAccount';
  573. }else{
  574. $imgs = redisEnv('GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE',[]);
  575. if($imgs) $imgs = json_decode($imgs,1);
  576. $page = 'jump.guidePersonalAccountOurs';
  577. }*/
  578. $page = 'jump.guidePersonalAccountOurs';
  579. //$page = 'jump.guidePersonalAccount';
  580. //$img = collect($imgs)->random();
  581. return view($page,['img'=>$img]);
  582. }
  583. }