CoflController.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725
  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->getUsersV2($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. $params['crm'] = $crm;
  222. $link = $link.'?'.http_build_query($params);
  223. $this->stats('index',$crm);
  224. $this->statsDetail($uid,'index',0);
  225. return redirect()->to($link);
  226. }
  227. public function recent(Request $request){
  228. $openid = $request->get('openid');
  229. //授权
  230. $params = $request->except('_url');
  231. if(empty($openid)){
  232. $url = url()->current() . '?' . http_build_query($params);
  233. $params['redirect_url'] = urlencode($url);
  234. $app = new Application($this->auth($params));
  235. return $app->oauth->redirect();
  236. }
  237. $user = $this->getUsersV2($openid);
  238. if(!$user[0]){
  239. $distribution_channel_id = 123;
  240. }else{
  241. $distribution_channel_id = $user[1];
  242. }
  243. $crm = $request->get('crm');
  244. $this->stats('recent',$crm);
  245. $this->statsDetail($user[0],'recent',0);
  246. $link = $this->getLink($distribution_channel_id).'recent?'.http_build_query($params);
  247. return redirect()->to($link);
  248. }
  249. public function person(Request $request){
  250. $openid = $request->get('openid');
  251. //授权
  252. $params = $request->except('_url');
  253. if(empty($openid)){
  254. $url = url()->current() . '?' . http_build_query($params);
  255. $params['redirect_url'] = urlencode($url);
  256. $app = new Application($this->auth($params));
  257. return $app->oauth->redirect();
  258. }
  259. $user = $this->getUsersV2($openid);
  260. if(!$user[0]){
  261. $distribution_channel_id = 123;
  262. }else{
  263. $distribution_channel_id = $user[1];
  264. }
  265. $crm = $request->get('crm');
  266. $this->stats('person',$crm);
  267. $this->statsDetail($user[0],'person',0);
  268. $link = $this->getLink($distribution_channel_id).'person?'.http_build_query($params);
  269. return redirect()->to($link);
  270. }
  271. public function sign(Request $request){
  272. $openid = $request->get('openid');
  273. //授权
  274. $params = $request->except('_url');
  275. if(empty($openid)){
  276. $url = url()->current() . '?' . http_build_query($params);
  277. $params['redirect_url'] = urlencode($url);
  278. $app = new Application($this->auth($params));
  279. return $app->oauth->redirect();
  280. }
  281. $user = $this->getUsersV2($openid);
  282. if(!$user[0]){
  283. $distribution_channel_id = 123;
  284. }else{
  285. $distribution_channel_id = $user[1];
  286. }
  287. $crm = $request->get('crm');
  288. $uri = $request->path();
  289. if($uri == 'sign'){
  290. $this->stats('sign',$crm);
  291. $this->statsDetail($user[0],'sign',0);
  292. }elseif($uri == 'wsign'){
  293. $this->stats('wsign',$crm);
  294. $this->statsDetail($user[0],'wsign',0);
  295. }
  296. $link = $this->getLink($distribution_channel_id).'sign?'.http_build_query($params);
  297. return redirect()->to($link);
  298. }
  299. private function getUsers($openid){
  300. $users = User::where('openid',$openid)->select('id','distribution_channel_id')->get();
  301. if($users->isEmpty()) return [0,0,0,0];
  302. $temp = null;
  303. $distribution_channel_id = 0;
  304. $uid = 0;
  305. $bid = 0;
  306. $cid = 0;
  307. foreach ($users as $user){
  308. $last_read = ReadRecordService::getByField($user->id,'last_read');
  309. if(!$last_read) continue;
  310. if(!$temp ){
  311. $distribution_channel_id = $user->distribution_channel_id;
  312. $uid = $user->id;
  313. $temp = $last_read;
  314. }else{
  315. $temp_last_read_info = explode('_',$temp);
  316. $last_read_info = explode('_',$last_read);
  317. if($last_read_info[2] > $temp_last_read_info[2]){
  318. $uid = $user->id;
  319. $distribution_channel_id = $user->distribution_channel_id;
  320. $temp = $last_read;
  321. $bid = $last_read_info[0];
  322. $cid = $last_read_info[1];
  323. }
  324. }
  325. }
  326. return [$uid,$distribution_channel_id,$bid,$cid];
  327. }
  328. /**
  329. * @param $openid
  330. * @return array
  331. */
  332. private function getUsersV2($openid){
  333. $friend_link_uid_bind = DB::table('friend_link_uid_bind')->where('openid',$openid)->first();
  334. if($friend_link_uid_bind) {
  335. $user = User::where('id',$friend_link_uid_bind->uid)->select('id','distribution_channel_id')->first();
  336. if($user) {
  337. \Log::info('user;'.json_encode($user));
  338. return [$user->id,$user->distribution_channel_id];
  339. }
  340. }
  341. $inner_channels = Channel::join('channel_users','channel_users.id','=','distribution_channels.channel_user_id')
  342. ->select('distribution_channels.id')
  343. ->whereIn('channel_users.id',explode(',',redisEnv('PROMOTION_GROUP_CHANNEL_USER_ID')))
  344. ->get()
  345. ->pluck('id')
  346. ->toArray();
  347. //\Log::info($inner_channels);
  348. $users = User::where('openid',$openid)->select('id','distribution_channel_id')->get();
  349. \Log::info('users:openid:'.$openid);
  350. if($users->isEmpty()) return [0,0];
  351. $temp = null;
  352. $distribution_channel_id = 0;
  353. $uid = 0;
  354. $inner_channel_uid_list = [];
  355. //先筛网站运营部UID
  356. foreach ($users as $user){
  357. if(in_array($user->distribution_channel_id,$inner_channels)) {
  358. $inner_channel_uid_list[] = $user;
  359. }
  360. }
  361. if(count($inner_channel_uid_list) == 1) {
  362. $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')];
  363. \Log::info('anchor:count $inner_channel_uid_list =1');
  364. DB::table('friend_link_uid_bind')->insert($insert_data);
  365. return [$inner_channel_uid_list[0]->id,$inner_channel_uid_list[0]->distribution_channel_id];
  366. }
  367. if(count($inner_channel_uid_list)>1) {
  368. //有多个网站运营部UID,针对网站运营部UID进入到下一步筛选
  369. $users = $inner_channel_uid_list;
  370. }
  371. //筛选包年UID
  372. $uid_list = [];
  373. foreach ($users as $item) {
  374. $uid_list[] =$item->id;
  375. }
  376. $year_order = YearOrder::whereIn('uid',$uid_list)->orderBy('end_time','desc')->first();
  377. if($year_order) {
  378. foreach ($users as $item) {
  379. if($item->id == $year_order->uid) {
  380. //筛选包年结束时间最后的UID
  381. $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')];
  382. \Log::info('anchor:year_order');
  383. DB::table('friend_link_uid_bind')->insert($insert_data);
  384. return [$item->id,$item->distribution_channel_id];
  385. }
  386. }
  387. }
  388. //按订阅章节数最多的筛选
  389. $users_select = ['id'=>0,'count'=>0,'user'=>null,'create_time'=>0];
  390. foreach ($users as $each){
  391. $table_prefix = ($each->id)%512;
  392. $chapter_count = DB::connection('chapter_order_mysql')
  393. ->table('chapter_orders'.$table_prefix)
  394. ->where('created_at','>=',date('Y-m-d H:i:s',strtotime('-3 day')))
  395. ->where('uid',$each->id)
  396. //->where('bid',$bid)
  397. ->count('id');
  398. $book_order = BookOrder::where('uid',$each->id)
  399. //->where('bid',$bid)
  400. ->where('created_at','>=',date('Y-m-d H:i:s',strtotime('-3 day')))
  401. ->first();
  402. if($book_order) {
  403. $chapter_count += 30;
  404. }
  405. //$each->chapter_count = $chapter_count;
  406. if($chapter_count>$users_select['count']) {
  407. $users_select['id'] = $each->id;
  408. $users_select['count'] = $chapter_count;
  409. $users_select['user'] = $each;
  410. }
  411. }
  412. if($users_select['id'] >0) {
  413. $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')];
  414. \Log::info('anchor:subs_chapter');
  415. DB::table('friend_link_uid_bind')->insert($insert_data);
  416. return [$users_select['user']->id,$users_select['user']->distribution_channel_id];
  417. }
  418. //有订阅记录的
  419. foreach ($users as $value) {
  420. $table_prefix = ($value->id)%512;
  421. $chapter_order = DB::connection('chapter_order_mysql')
  422. ->table('chapter_orders'.$table_prefix)
  423. ->where('uid',$value->id)
  424. //->where('bid',$bid)
  425. ->orderBy('created_at','desc')
  426. ->first();
  427. $book_order = BookOrder::where('uid',$value->id)
  428. //->where('bid',$bid)
  429. ->first();
  430. if($chapter_order ){
  431. if(strtotime($chapter_order->created_at) > $users_select['create_time']) {
  432. $users_select['id'] = $value->id;
  433. $users_select['create_time'] = strtotime($chapter_order->created_at);
  434. $users_select['user'] = $value;
  435. }
  436. }
  437. if($book_order){
  438. if(strtotime($book_order->created_at) > $users_select['create_time']){
  439. $users_select['id']=$value->id;
  440. $users_select['create_time']= strtotime($book_order->created_at);
  441. $users_select['user']= $value;
  442. }
  443. }
  444. }
  445. if($users_select['id'] >0) {
  446. $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')];
  447. \Log::info('anchor:subs_');
  448. DB::table('friend_link_uid_bind')->insert($insert_data);
  449. return [$users_select['user']->id,$users_select['user']->distribution_channel_id];
  450. }
  451. if(count($inner_channel_uid_list)>1) {
  452. //有多个网站运营部UID,针对网站运营部UID进入到下一步筛选
  453. $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')];
  454. \Log::info('anchor:count $inner_channel_uid_list >1');
  455. DB::table('friend_link_uid_bind')->insert($insert_data);
  456. return [$inner_channel_uid_list[0]['id'],$inner_channel_uid_list[0]['distribution_channel_id']];
  457. }
  458. \Log::info('anchor:over');
  459. return [0,0];
  460. }
  461. private function getLink($distribution_channel_id=123){
  462. $url_format = '%s://site%s.%s.com/';
  463. return sprintf(
  464. $url_format,
  465. env('PROTOCOL'),
  466. encodeDistributionChannelId($distribution_channel_id),
  467. env('CUSTOM_HOST')
  468. );
  469. }
  470. private function auth($param){
  471. $param['appid'] = 'wx9d389a73b88bbeae';
  472. $options = [
  473. 'app_id' => 'wx9d389a73b88bbeae',
  474. 'secret' => '2f6594bb595dfa256b5512e43a32a3d3',
  475. 'oauth' => [
  476. 'scopes' => ['snsapi_base'],
  477. 'callback' => env('AUTH_CALLBACK_URL') . '?' . http_build_query($param),
  478. ],
  479. ];
  480. return $options;
  481. }
  482. private function stats($page,$flag){
  483. if(!$page || !$flag) return ;
  484. $flag = trim($flag);
  485. //pv
  486. $day = date('Y-m-d');
  487. $pv_key = sprintf('crm:pv:%s',$flag);
  488. Redis::hincrby($pv_key, $day, 1);
  489. //Redis::hincrby($pv_key, 'total', 1);
  490. Redis::sadd('crm_'.$day,$flag);
  491. //uv
  492. $cookie_flag = Cookie::get('crm_flag');
  493. if(!$cookie_flag || $cookie_flag != $flag){
  494. $uv_key = sprintf('crm:uv:%s',$flag);
  495. Redis::hincrby($uv_key, $day, 1);
  496. //Redis::hincrby($uv_key, 'total', 1);
  497. }
  498. Cookie::queue('crm_flag', $flag, env('U_COOKIE_EXPIRE'), null, null, false, false);
  499. }
  500. private function statsDetail($uid,$page,$bid=0)
  501. {
  502. try{
  503. DB::table('crm_visit_detail')->insert([
  504. 'uid'=>$uid,'page'=>$page,
  505. 'bid'=>$bid,'day'=>date('Y-m-d'),
  506. 'created_at'=>date('Y-m-d H:i:s'),
  507. 'updated_at'=>date('Y-m-d H:i:s')
  508. ]);
  509. }catch (\Exception $e){}
  510. }
  511. public function longActivity(Request $request)
  512. {
  513. $openid = $request->get('openid');
  514. //授权
  515. $params = $request->except('_url');
  516. if(empty($openid)){
  517. $url = url()->current() . '?' . http_build_query($params);
  518. $params['redirect_url'] = urlencode($url);
  519. $app = new Application($this->auth($params));
  520. return $app->oauth->redirect();
  521. }
  522. $user = $this->getUsersV2($openid);
  523. if(!$user[0]){
  524. $distribution_channel_id = 123;
  525. }else{
  526. $distribution_channel_id = $user[1];
  527. }
  528. $crm = $request->get('crm');
  529. $this->stats('activity',$crm);
  530. $baselink = $this->getLink($distribution_channel_id).'activity/crm?'.http_build_query($params);
  531. if(isset($params['token']) && !empty($params['token'])){
  532. return redirect()->to($baselink.'activity/crm?'.http_build_query($params));
  533. }
  534. return redirect()->to($baselink);
  535. }
  536. public function yearActivity(Request $request)
  537. {
  538. $openid = $request->get('openid');
  539. //授权
  540. $params = $request->except('_url');
  541. if(empty($openid)){
  542. $url = url()->current() . '?' . http_build_query($params);
  543. $params['redirect_url'] = urlencode($url);
  544. $app = new Application($this->auth($params));
  545. return $app->oauth->redirect();
  546. }
  547. $user = $this->getUsersV2($openid);
  548. if(!$user[0]){
  549. $distribution_channel_id = 123;
  550. }else{
  551. $distribution_channel_id = $user[1];
  552. }
  553. $crm = $request->get('crm','crm_year_activity');
  554. $params['crm'] = $crm;
  555. $this->stats('activity',$crm);
  556. $this->statsDetail($user[0],'year_activity',0);
  557. $baselink = $this->getLink($distribution_channel_id).'activity/crmy?'.http_build_query($params);
  558. return redirect()->to($baselink);
  559. }
  560. public function guidePersonal(Request $request){
  561. $openid = $request->get('openid');
  562. //授权
  563. $params = $request->except('_url');
  564. if(empty($openid)){
  565. $url = url()->current() . '?' . http_build_query($params);
  566. $params['redirect_url'] = urlencode($url);
  567. $app = new Application($this->auth($params));
  568. return $app->oauth->redirect();
  569. }
  570. list($uid,$distribution_channel_id) = $this->getUsersV2($openid);
  571. $link = $this->getLink($distribution_channel_id);
  572. $crm = $request->get('crm','guide_personal');
  573. $params['crm'] = $crm;
  574. $params['uid'] = $uid;
  575. $link = $link.'guidestrem?'.http_build_query($params);
  576. $this->stats('index',$crm);
  577. $this->statsDetail($uid,'guidePersonal',0);
  578. return redirect()->to($link);
  579. }
  580. public function guidePersonalAccount(Request $request,$channel_id){
  581. $uid = $request->get('uid',0);
  582. //$user_cookie = Cookie::get(env('COOKIE_AUTH_WEB_WECHAT'));
  583. //$uid = $user_cookie ? decrypt($user_cookie) : null;
  584. $cookie_crm_img = Cookie::get('crm_person_img');
  585. $cookie_crm_name = Cookie::get('crm_person_name','');
  586. if($cookie_crm_img){
  587. return view('jump.guidePersonalAccountOurs',['img'=>$cookie_crm_img,'name'=>$cookie_crm_name]);
  588. }
  589. $env_config = redisEnvMulti('ACTIVE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE',
  590. 'ACTIVE_GUIDE_PERSONAL_ACCOUNT_MAX_UV','ACTIVE_GUIDE_PERSONAL_ACCOUNT_ID',
  591. 'ACTIVE_GUIDE_PERSONAL_ACCOUNT_MAX_EVERY_UV');
  592. $img = empty($env_config[0])?'https://cdn-novel.iycdm.com/h5/personal_account/chenchen.jpg':$env_config[0];
  593. $max = empty($env_config[1])?100:$env_config[1];
  594. $max = (int)$max;
  595. $one_loop_max = empty($env_config[3])?10:$env_config[3];
  596. $now_id = (int)$env_config[2];
  597. $uv = Redis::scard('active_guide_personal_uv');
  598. $personal_info = DB::table('personal_account_list')->where('id',$now_id)->select('count')->first();
  599. $total_max = (int)($personal_info->count+$uv);
  600. //Log::info('$total_max is: '.);
  601. if($uv >= $one_loop_max || $total_max>=$max){
  602. if($total_max>=$max){
  603. DB::table('personal_account_list')->where('id',$now_id)->update([
  604. 'status'=>2,
  605. 'count'=>$total_max,
  606. 'updated_at'=>date('Y-m-d H:i:s')
  607. ]);
  608. }else{
  609. DB::table('personal_account_list')->where('id',$now_id)->increment('count',$uv,[
  610. 'updated_at'=>date('Y-m-d H:i:s')
  611. ]);
  612. }
  613. $account = DB::table('personal_account_list')
  614. ->where('is_enable',1)
  615. ->whereIn('status',[1,0])
  616. ->select('id','url')
  617. ->where('group','ACTIVE')
  618. ->where('count','<',$max)
  619. ->orderBy('count','asc')
  620. ->orderBy('id')
  621. ->first();
  622. Redis::del('active_guide_personal_uv');
  623. if($account){
  624. DB::table('personal_account_list')->where('id',$account->id)->update([
  625. 'status'=>1,
  626. 'updated_at'=>date('Y-m-d H:i:s')
  627. ]);
  628. $img = $account->url;
  629. $now_id = $account->id;
  630. Redis::Hmset('env','ACTIVE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE',$account->url,'ACTIVE_GUIDE_PERSONAL_ACCOUNT_ID',$account->id);
  631. }else{
  632. Redis::Hmset('env','ACTIVE_GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE','','ACTIVE_GUIDE_PERSONAL_ACCOUNT_ID','');
  633. return back();
  634. }
  635. }
  636. Redis::sadd('active_guide_personal_uv',$uid);
  637. if($uid){
  638. DB::table('ad_pdd')->insert([
  639. 'uid'=>$uid,
  640. 'img'=>'GUIDE_PERSONAL_ACCOUNT_'.$now_id,
  641. 'date'=>date('Y-m-d'),
  642. 'created_at'=>date('Y-m-d H:i:s'),
  643. 'updated_at'=>date('Y-m-d H:i:s')
  644. ]);
  645. }
  646. $name = '';
  647. $name_info = DB::table('personal_account_list')->where('id',$now_id)->select('name')->first();
  648. if($name_info){
  649. $name = $name_info->name;
  650. }
  651. /*if(in_array($channel_id,explode(',',redisEnv('GUIDE_PERSONAL_ACCOUNT_WEID_SITES')))){
  652. $imgs = redisEnv('GUIDE_PERSONAL_ACCOUNT_WEID_QRCODE',[]);
  653. if($imgs) $imgs = json_decode($imgs,1);
  654. $page = 'jump.guidePersonalAccount';
  655. }else{
  656. $imgs = redisEnv('GUIDE_PERSONAL_ACCOUNT_OURS_QRCODE',[]);
  657. if($imgs) $imgs = json_decode($imgs,1);
  658. $page = 'jump.guidePersonalAccountOurs';
  659. }*/
  660. $page = 'jump.guidePersonalAccountOurs';
  661. $time = strtotime(date('Y-m-d',time()+86400))-time();
  662. Cookie::queue('crm_person_img', $img,$time);
  663. Cookie::queue('crm_person_name', $name,$time);
  664. //$page = 'jump.guidePersonalAccount';
  665. //$img = collect($imgs)->random();
  666. return view($page,['img'=>$img,'name'=>$name]);
  667. }
  668. public function r(Request $request,$number){
  669. switch ($number){
  670. case 1:
  671. //首页
  672. break;
  673. case 2:
  674. //阅读器
  675. break;
  676. case 3:
  677. //阅读器
  678. break;
  679. case 4:
  680. //个人中心
  681. break;
  682. case 5:
  683. //最近阅读
  684. break;
  685. case 6:
  686. }
  687. }
  688. }