CoflController.php 27 KB

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