ForceSubscribeService.php 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787
  1. <?php
  2. /**
  3. * Created by sublime.
  4. * User: wosinC
  5. * Date: 2017/12/2
  6. * Time: 上午11:39
  7. */
  8. namespace App\Modules\OfficialAccount\Services;
  9. use App\Modules\OfficialAccount\Models\ForceSubscribeUsers;
  10. use App\Modules\OfficialAccount\Models\TempForceSubscribeUsers;
  11. use App\Modules\OfficialAccount\Models\OfficialAccount;
  12. use App\Modules\SendOrder\Services\SendOrderService;
  13. use App\Modules\User\Services\UserService;
  14. use App\Modules\Subscribe\Services\OrderService;
  15. use App\Modules\Subscribe\Services\YearOrderService;
  16. use App\Modules\User\Models\YqMove;
  17. use App\Libs\OSS;
  18. use Redis;
  19. use App\Jobs\SendTemplate;
  20. use App\Jobs\SendStatisticsList;
  21. use GuzzleHttp\Client;
  22. class ForceSubscribeService
  23. {
  24. //-----------强关用户---------------
  25. /**
  26. * 通过appid和openid获取强关用户
  27. */
  28. static function forceSubscribeUsersByAppidAndOpenId($forceSubscribeUsersPrams)
  29. {
  30. //\Log::info('======================get_forceSubscribe_Users11111111111======================'."\n");
  31. //\Log::info($forceSubscribeUsersPrams);
  32. $officialAccount = OfficialAccount::officialAccountByAppid($forceSubscribeUsersPrams['appid']);
  33. \Log::info('======================get_forceSubscribe_Users222222222222======================'."\n");
  34. \Log::info($officialAccount);
  35. if (!empty($officialAccount)) {
  36. $distribution_channel_id = $officialAccount['distribution_channel_id'];
  37. //\Log::info('======================get_forceSubscribe_Users333333333333======================'."\n");
  38. //\Log::info(ForceSubscribeUsers::forceSubscribeUsersByOpenidAndChannelId($forceSubscribeUsersPrams['openid'],$officialAccount['distribution_channel_id']));
  39. return ForceSubscribeUsers::forceSubscribeUsersByOpenidAndChannelId($forceSubscribeUsersPrams['openid'],$officialAccount['distribution_channel_id']);
  40. }
  41. }
  42. /**
  43. * 通过distribution_channel_id和openid获取素材强关映射关系
  44. */
  45. static function getMaterialForceSubscribeMapping($distribution_channel_id,$openid)
  46. {
  47. $result = array();
  48. $result['uid'] = Redis::hget('book:linksubscribe:openid:'.$openid.':channelid:'.$distribution_channel_id,'uid');
  49. $result['time'] = Redis::hget('book:linksubscribe:openid:'.$openid.':channelid:'.$distribution_channel_id,'time');
  50. \Log::info('key:'.'book:linksubscribe:openid:'.$openid.':channelid:'.$distribution_channel_id);
  51. \Log::info('getMaterialForceSubscribeMapping:distribution_channel_id:'.$distribution_channel_id.' openid:'.$openid.' uid:'.$result['uid'].' time:'.$result['time']);
  52. return $result;
  53. }
  54. /**
  55. * 获取所有强关用户
  56. */
  57. static function forceSubscribeUsersAllOf()
  58. {
  59. return ForceSubscribeUsers::forceSubscribeUsersAllOf();
  60. }
  61. /**
  62. * 修改切换的
  63. */
  64. static function updateSubscribeUserTransfer($distribution_channel_id,$uid,$from_appid,$to_appid,$to_openid)
  65. {
  66. return ForceSubscribeUsers::updateSubscribeUserTransfer($distribution_channel_id,$uid,$from_appid,$to_appid,$to_openid);
  67. }
  68. /**
  69. * 通过uid获取强关用户
  70. */
  71. static function forceSubscribeUsersByUid($forceSubscribeUsersPrams)
  72. {
  73. return ForceSubscribeUsers::forceSubscribeUsersByUid($forceSubscribeUsersPrams['uid']);
  74. }
  75. /**
  76. * 根据distribution_channel_id获取强关用户
  77. */
  78. static function forceSubscribeUsersByChannelidAndTimeset($forceSubscribeUsersPrams)
  79. {
  80. return ForceSubscribeUsers::forceSubscribeUsersByChannelidAndTimeset($forceSubscribeUsersPrams['distribution_channel_id'],$forceSubscribeUsersPrams['timeset']);
  81. }
  82. /**
  83. * 获取关注12小时的新用户
  84. */
  85. static function forceSubscribeNewUsersByTimeset($forceSubscribeUsersPrams)
  86. {
  87. return ForceSubscribeUsers::forceSubscribeNewUsersByTimeset($forceSubscribeUsersPrams['distribution_channel_id'],$forceSubscribeUsersPrams['timeset']);
  88. }
  89. /**
  90. * 获取未付费的新关用户24-48小时
  91. */
  92. static function forceSubscribeNewUnpaidUsersByTime($forceSubscribeUsersPrams)
  93. {
  94. return ForceSubscribeUsers::forceSubscribeNewUnpaidUsersByTime($forceSubscribeUsersPrams['distribution_channel_id'],$forceSubscribeUsersPrams['start_time'],$forceSubscribeUsersPrams['end_time']);
  95. }
  96. /**
  97. * 通过uid和appid获取强关用户
  98. */
  99. static function forceSubscribeUsersByUidAndAppidAndChannelId($forceSubscribeUsersPrams)
  100. {
  101. return ForceSubscribeUsers::forceSubscribeUsersByUidAndAppidAndChannelId($forceSubscribeUsersPrams['uid'],$forceSubscribeUsersPrams['appid'],$forceSubscribeUsersPrams['distribution_channel_id']);
  102. }
  103. /**
  104. * 通过openid获取强关用户
  105. */
  106. static function forceSubscribeUsersByOpenid($forceSubscribeUsersPrams)
  107. {
  108. return ForceSubscribeUsers::forceSubscribeUsersByOpenid($forceSubscribeUsersPrams['openid']);
  109. }
  110. /**
  111. * 通过openid获取强关用户
  112. */
  113. static function forceSubscribeUsersByUidAndAppid($appid, $uid)
  114. {
  115. return ForceSubscribeUsers::forceSubscribeUsersByUidAndAppid($appid, $uid);
  116. }
  117. /**
  118. * 通过openid获取性别
  119. */
  120. static function getSexByOpenid($distribution_channel_id,$openid)
  121. {
  122. return ForceSubscribeUsers::getSexByOpenid($distribution_channel_id,$openid);
  123. }
  124. /**
  125. * 通过openid获取性别,只根据强关书的性别
  126. */
  127. static function getSimpleSexByOpenid($distribution_channel_id,$openid)
  128. {
  129. return ForceSubscribeUsers::getSimpleSexByOpenid($distribution_channel_id,$openid);
  130. }
  131. /**
  132. * 通过uid获取性别,只根据强关书的性别
  133. */
  134. static function getSimpleSexByUid($uid)
  135. {
  136. return ForceSubscribeUsers::getSimpleSexByUid($uid);
  137. }
  138. /**
  139. * 通过uid获取强关用户 包括取关用户
  140. */
  141. static function forceSubscribeUsersByUidIncludeCancel($forceSubscribeUsersPrams){
  142. return ForceSubscribeUsers::forceSubscribeUsersByUidIncludeCancel($forceSubscribeUsersPrams['uid']);
  143. }
  144. /**
  145. * 通过openid,appid,distribution_channel_id获取强关用户
  146. */
  147. static function forceSubscribeUsersByOpenidAndAppidAndChannelId($forceSubscribeUsersPrams)
  148. {
  149. return ForceSubscribeUsers::forceSubscribeUsersByOpenidAndAC($forceSubscribeUsersPrams['openid'],$forceSubscribeUsersPrams['appid'],$forceSubscribeUsersPrams['distribution_channel_id']);
  150. }
  151. /**
  152. * 增加强关用户
  153. */
  154. static function addForceSubscribeUsers($forceSubscribeUsersPrams) {
  155. try {
  156. \Log::info('~~~~~~~~~~~~~~~~~~~addForceSubscribeUsers~~~~~~~~~~~~~~~~~~~~'."\n");
  157. $officialAccount = OfficialAccount::officialAccountByAppid($forceSubscribeUsersPrams['appid']);
  158. if (!empty($officialAccount)) {
  159. # code...
  160. $forceSubscribeUsers = ForceSubscribeUsers::forceSubscribeUsersByOpenidAndAC($forceSubscribeUsersPrams['openid'],$forceSubscribeUsersPrams['appid'],$officialAccount['distribution_channel_id']);
  161. // dd($forceSubscribeUsers);
  162. if(empty($forceSubscribeUsers)) {
  163. // $data = $request->all();
  164. $bid = Redis::hget('force_subscribe_from_bid',$forceSubscribeUsersPrams['appid'].'_'.$forceSubscribeUsersPrams['uid']);
  165. if (empty($bid)) {
  166. # code...
  167. $bid = '0';
  168. }else{
  169. Redis::hdel('force_subscribe_from_bid',$forceSubscribeUsersPrams['appid'].'_'.$forceSubscribeUsersPrams['uid']);
  170. }
  171. if(isset($forceSubscribeUsersPrams['send_order_id']) && !empty($forceSubscribeUsersPrams['send_order_id'])){
  172. $sendOrderId = $forceSubscribeUsersPrams['send_order_id'];
  173. }else{
  174. $sendOrderId = Redis::hget('force_subscribe_from_send_order_id',$forceSubscribeUsersPrams['appid'].'_'.$forceSubscribeUsersPrams['uid']);
  175. if (empty($sendOrderId)) {
  176. $sendOrderId = '0';
  177. }else{
  178. Redis::hdel('force_subscribe_from_send_order_id',$forceSubscribeUsersPrams['appid'].'_'.$forceSubscribeUsersPrams['uid']);
  179. }
  180. }
  181. if($bid && $sendOrderId){
  182. $send_order_bid = Redis::hget('sendOrderIdToBid',$sendOrderId);
  183. if(!$send_order_bid){
  184. $send_order_info = SendOrderService::getById($sendOrderId);
  185. if($send_order_info){
  186. $send_order_bid = $send_order_info->book_id;
  187. Redis::hset('sendOrderIdToBid',$sendOrderId,$send_order_bid);
  188. }
  189. }
  190. if($send_order_bid && $bid == $send_order_bid){
  191. $key = 'accurateSendOrderSubscribeNum:bid:%s:send_order_id:'.$sendOrderId;
  192. Redis::sadd(sprintf($key,$bid),$forceSubscribeUsersPrams['uid']);
  193. }
  194. }
  195. $data['is_subscribed'] = 1;
  196. $data['subscribe_time'] = date("Y-m-d H:i:s");
  197. $data['last_interactive_time'] = $forceSubscribeUsersPrams['last_interactive_time'];
  198. $data['uid'] = $forceSubscribeUsersPrams['uid'];
  199. $data['appid'] = $forceSubscribeUsersPrams['appid'];
  200. $data['openid'] = $forceSubscribeUsersPrams['openid'];
  201. $data['distribution_channel_id'] = $forceSubscribeUsersPrams['distribution_channel_id'];
  202. $data['bid'] = $bid;
  203. $data['send_order_id'] = $sendOrderId;
  204. $data['official_account_id'] = isset($forceSubscribeUsersPrams['official_account_id'])?$forceSubscribeUsersPrams['official_account_id']:0;
  205. $forceSubscribeUsers = ForceSubscribeUsers::create($data);
  206. //Redis::hset('www.zhuishuyun.com'.'force_subscribe:scene:'.$forceSubscribeUsersPrams['uid'].':'.$forceSubscribeUsersPrams['appid'], 'is_subscribe', '[{is_subscribed:1},{subscribe_time:'.date("Y-m-d H:i:s").'}]');
  207. //在Redis中记录一个appid下每天的强关用户数量
  208. Redis::hincrby('day_appid_fans_nums_appid:add:'.$forceSubscribeUsersPrams['appid'],date("Y-m-d"),1);
  209. Redis::hincrby('day_appid_fans_nums_appid:add:'.$forceSubscribeUsersPrams['appid'],'total',1);
  210. // $user['openid'] = $forceSubscribeUsersPrams['openid'];
  211. // $user['unionid'] = $forceSubscribeUsersPrams['unionid'];
  212. // $user['distribution_channel_id'] = $forceSubscribeUsersPrams['distribution_channel_id'];
  213. $user['province'] = isset($forceSubscribeUsersPrams['province']) ? $forceSubscribeUsersPrams['province'] : '';
  214. $user['nickname'] = isset($forceSubscribeUsersPrams['nick_name']) ? $forceSubscribeUsersPrams['nick_name'] : '';
  215. $user['city'] = isset($forceSubscribeUsersPrams['city']) ? $forceSubscribeUsersPrams['city'] : '';
  216. $user['country'] = isset($forceSubscribeUsersPrams['country']) ? $forceSubscribeUsersPrams['country'] : '';
  217. $user['head_img'] = isset($forceSubscribeUsersPrams['headimgurl']) ? $forceSubscribeUsersPrams['headimgurl'] : '';
  218. $user['sex'] = isset($forceSubscribeUsersPrams['sex']) ? $forceSubscribeUsersPrams['sex'] : '';
  219. $user['id'] = isset($forceSubscribeUsersPrams['uid']) ? $forceSubscribeUsersPrams['uid'] : '';
  220. \Log::info('~~~~~~~~~~~~~~~~~~~addForceSubscribeUsers~~~~~~~~~~~~~~~~~~~~'."\n");
  221. \Log::info($user);
  222. UserService::updateInfo($user['id'],$user);
  223. // UserService::addUser($user);
  224. // 新关统计
  225. \Log::info('addForceSubscribeUsers_redis_new:'.$forceSubscribeUsersPrams['uid']);
  226. $sub_key = 'gzh_new_sub:'.$forceSubscribeUsersPrams['appid'].':'.date('Y-m-d');
  227. Redis::SADD($sub_key,$forceSubscribeUsersPrams['uid']);
  228. Redis::EXPIRE($sub_key,24*3600*3);
  229. return 1;
  230. } else {
  231. $forceSubscribeUsers['is_subscribed'] = 1;
  232. $forceSubscribeUsers['subscribe_time'] = date("Y-m-d H:i:s");
  233. $forceSubscribeUsers->save();
  234. //Redis::hset('www.zhuishuyun.com'.'force_subscribe:scene:'.$forceSubscribeUsersPrams['uid'].':'.$forceSubscribeUsersPrams['appid'], 'is_subscribe', '[{is_subscribed:1},{subscribe_time:'.date("Y-m-d H:i:s").'}]');
  235. Redis::hincrby('day_appid_fans_nums_appid:add:'.$forceSubscribeUsersPrams['appid'],date("Y-m-d"),1);
  236. Redis::hincrby('day_appid_fans_nums_appid:add:'.$forceSubscribeUsersPrams['appid'],'total',1);
  237. // $user['openid'] = $forceSubscribeUsersPrams['openid'];
  238. // $user['unionid'] = $forceSubscribeUsersPrams['unionid'];
  239. // $user['distribution_channel_id'] = $forceSubscribeUsersPrams['distribution_channel_id'];
  240. $user['province'] = isset($forceSubscribeUsersPrams['province']) ? $forceSubscribeUsersPrams['province'] : '';
  241. $user['nickname'] = isset($forceSubscribeUsersPrams['nick_name']) ? $forceSubscribeUsersPrams['nick_name'] : '';
  242. $user['city'] = isset($forceSubscribeUsersPrams['city']) ? $forceSubscribeUsersPrams['city'] : '';
  243. $user['country'] = isset($forceSubscribeUsersPrams['country']) ? $forceSubscribeUsersPrams['country'] : '';
  244. $user['head_img'] = isset($forceSubscribeUsersPrams['headimgurl']) ? $forceSubscribeUsersPrams['headimgurl'] : '';
  245. $user['sex'] = isset($forceSubscribeUsersPrams['sex']) ? $forceSubscribeUsersPrams['sex'] : '';
  246. $user['id'] = isset($forceSubscribeUsersPrams['uid']) ? $forceSubscribeUsersPrams['uid'] : '';
  247. \Log::info('~~~~~~~~~~~~~~~~~addForceSubscribeUsers~~~~~~~~~~~~~~~~'."\n");
  248. //\Log::info($user);
  249. UserService::updateInfo($user['id'],$user);
  250. // 老关统计
  251. \Log::info('addForceSubscribeUsers_redis_old:'.$forceSubscribeUsersPrams['uid']);
  252. $sub_key = 'gzh_old_sub:'.$forceSubscribeUsersPrams['appid'].':'.date('Y-m-d');
  253. Redis::SADD($sub_key,$forceSubscribeUsersPrams['uid']);
  254. Redis::EXPIRE($sub_key,24*3600*3);
  255. return 1;
  256. }
  257. }
  258. } catch (\Exception $e) {
  259. // \Log($e);
  260. return 0;
  261. }
  262. }
  263. /**
  264. * 更新强关用户uid
  265. */
  266. static function updateSubscribeUsersUid($forceSubscribeUsersPrams) {
  267. try {
  268. $forceSubscribeUsers = ForceSubscribeUsers::getOneForceSubscribeUsersByOpenid($forceSubscribeUsersPrams['openid']);
  269. if(empty($forceSubscribeUsers)) {
  270. return 2;
  271. } else {
  272. \Log::info('updateSubscribeUsersUid,openid'. $forceSubscribeUsersPrams['openid']. ' old_uid:'.$forceSubscribeUsers->uid.' new_uid:'.$forceSubscribeUsersPrams['uid']);
  273. $forceSubscribeUsers['uid'] = $forceSubscribeUsersPrams['uid'];
  274. $forceSubscribeUsers->save();
  275. return 1;
  276. }
  277. } catch (\Exception $e) {
  278. \Log::info($e->getMessage());
  279. return 0;
  280. }
  281. }
  282. /**
  283. * 更新强关用户最后交互时间
  284. */
  285. static function forceSubscribeUsersLastTimeUpdate($forceSubscribeUsersPrams) {
  286. try {
  287. $forceSubscribeUsers = ForceSubscribeUsers::getOneForceSubscribeUsersByOpenid($forceSubscribeUsersPrams['openid']);
  288. if(empty($forceSubscribeUsers)) {
  289. return 2;
  290. } else {
  291. $forceSubscribeUsers['last_interactive_time'] = $forceSubscribeUsersPrams['last_interactive_time'];
  292. $forceSubscribeUsers->save();
  293. return 1;
  294. }
  295. } catch (\Exception $e) {
  296. // \Log($e);
  297. return 0;
  298. }
  299. }
  300. /**
  301. * 更新强关用户最后交互时间
  302. */
  303. static function tempForceSubscribeUsersLastTimeUpdate($forceSubscribeUsersPrams) {
  304. try {
  305. $forceSubscribeUsers = ForceSubscribeUsers::forceSubscribeUsersByOpenidAndAC($forceSubscribeUsersPrams['openid'],$forceSubscribeUsersPrams['appid'],$forceSubscribeUsersPrams['distribution_channel_id']);
  306. // \Log::info('tempForceSubscribeUsersLastTimeUpdate:'.json_encode($forceSubscribeUsers));
  307. if(empty($forceSubscribeUsers)) {
  308. \Log::info('empty_origin_update_temp_force_subscribe_user:'.$forceSubscribeUsersPrams['openid']);
  309. return 2;
  310. } else {
  311. $tempForceSubscribeUsers = TempForceSubscribeUsers::forceSubscribeUsersByOpenidAndAC($forceSubscribeUsersPrams['openid'],$forceSubscribeUsersPrams['appid'],$forceSubscribeUsersPrams['distribution_channel_id']);
  312. if(!empty($tempForceSubscribeUsers)){
  313. \Log::info('exist_update_temp_force_subscribe_user:'.$forceSubscribeUsersPrams['openid']);
  314. $tempForceSubscribeUsers->last_interactive_time = $forceSubscribeUsers->last_interactive_time;
  315. $tempForceSubscribeUsers->bid = $forceSubscribeUsers->bid;
  316. $tempForceSubscribeUsers->is_subscribed = $forceSubscribeUsers->is_subscribed;
  317. $tempForceSubscribeUsers->subscribe_time = $forceSubscribeUsers->subscribe_time;
  318. $tempForceSubscribeUsers->unsubscribe_time = $forceSubscribeUsers->unsubscribe_time;
  319. $tempForceSubscribeUsers->save();
  320. } else{
  321. $tempForceSubscribeUsers = [
  322. 'uid'=>$forceSubscribeUsers->uid,
  323. 'openid'=>$forceSubscribeUsers->openid,
  324. 'appid'=>$forceSubscribeUsers->appid,
  325. 'bid'=>$forceSubscribeUsers->bid,
  326. 'is_subscribed'=>$forceSubscribeUsers->is_subscribed,
  327. 'subscribe_time'=>$forceSubscribeUsers->subscribe_time,
  328. 'unsubscribe_time'=>$forceSubscribeUsers->unsubscribe_time,
  329. 'distribution_channel_id'=>$forceSubscribeUsers->distribution_channel_id,
  330. 'last_interactive_time'=>$forceSubscribeUsersPrams['last_interactive_time'],
  331. ];
  332. \Log::info('not_exist_create_temp_force_subscribe_user:'.$forceSubscribeUsersPrams['openid']);
  333. TempForceSubscribeUsers::firstOrCreate($tempForceSubscribeUsers);
  334. }
  335. return 1;
  336. }
  337. } catch (\Exception $e) {
  338. // \Log($e);
  339. return 0;
  340. }
  341. }
  342. static function getOfficalAccountNickName($uid)
  343. {
  344. return ForceSubscribeUsers::getOfficalAccountNickName($uid);
  345. }
  346. /**
  347. * 强关用户取关
  348. */
  349. static function cancelForceSubscribeUsers($forceSubscribeUsersPrams) {
  350. try {
  351. // $forceSubscribeUsers = ForceSubscribeUsers::forceSubscribeUsersByOpenid($forceSubscribeUsersPrams['openid']);
  352. // if(empty($forceSubscribeUsers)) {
  353. // return 2;
  354. // } else {
  355. // # code...
  356. // $forceSubscribeUsers['is_subscribed'] = 0;
  357. // $forceSubscribeUsers['unsubscribe_time'] = date("Y-m-d H:i:s");
  358. // $forceSubscribeUsers->save();
  359. // Redis::hset('www.zhuishuyun.com'.'force_subscribe:scene:'.$forceSubscribeUsers['uid'].':'.$forceSubscribeUsersPrams['appid'], 'is_subscribe', '[{is_subscribed:0},{unsubscribe_time:'.date("Y-m-d H:i:s").'}]');
  360. // return 1;
  361. // }
  362. $forceSubscribeUsers = ForceSubscribeUsers::forceAllSubscribeUsersByOpenid($forceSubscribeUsersPrams['openid']);
  363. if(count($forceSubscribeUsers)>0) {
  364. for ($i=0; $i < count($forceSubscribeUsers); $i++) {
  365. # code...
  366. $cancelforceSubscribeUsers = $forceSubscribeUsers[$i];
  367. $cancelforceSubscribeUsers['is_subscribed'] = 0;
  368. $cancelforceSubscribeUsers['unsubscribe_time'] = date("Y-m-d H:i:s");
  369. $cancelforceSubscribeUsers->save();
  370. //Redis::hset('www.zhuishuyun.com'.'force_subscribe:scene:'.$cancelforceSubscribeUsers['uid'].':'.$forceSubscribeUsersPrams['appid'], 'is_subscribe', '[{is_subscribed:0},{unsubscribe_time:'.date("Y-m-d H:i:s").'}]');
  371. Redis::hincrby('day_appid_fans_nums_appid:cancel:'.$forceSubscribeUsersPrams['appid'],date("Y-m-d"),1);
  372. Redis::hincrby('day_appid_fans_nums_appid:cancel:'.$forceSubscribeUsersPrams['appid'],'total',1);
  373. $theCancelForceSubscribeUserArray = $cancelforceSubscribeUsers->toArray();
  374. $send_data=array(
  375. 'type'=>'unsubscribe_user',
  376. 'data' => $theCancelForceSubscribeUserArray
  377. );
  378. $delay = 0;
  379. $job = (new SendStatisticsList($send_data))->onConnection('rabbitmq')->delay($delay)->onQueue('send_statistics_list');
  380. dispatch($job);
  381. }
  382. return 1;
  383. } else {
  384. return 2;
  385. }
  386. } catch (\Exception $e) {
  387. // \Log($e);
  388. return 0;
  389. }
  390. }
  391. /**
  392. * 强制关注
  393. */
  394. static function subscribeForceSubscribeUsers($forceSubscribeUsersPrams) {
  395. try {
  396. // $forceSubscribeUsers = ForceSubscribeUsers::forceUnSubscribeUsersByOpenid($forceSubscribeUsersPrams['openid']);
  397. // if(empty($forceSubscribeUsers)) {
  398. // return 2;
  399. // } else {
  400. // # code...
  401. // $forceSubscribeUsers['is_subscribed'] = 1;
  402. // $forceSubscribeUsers['subscribe_time'] = date("Y-m-d H:i:s");
  403. // $forceSubscribeUsers->save();
  404. // Redis::hset('www.zhuishuyun.com'.'force_subscribe:scene:'.$forceSubscribeUsers['uid'].':'.$forceSubscribeUsersPrams['appid'], 'is_subscribe', '[{is_subscribed:1},{subscribe_time:'.date("Y-m-d H:i:s").'}]');
  405. // return 1;
  406. // }
  407. $forceSubscribeUsers = ForceSubscribeUsers::forceAllUnSubscribeUsersByOpenid($forceSubscribeUsersPrams['openid']);
  408. // \Log::info('=======================GET ALL BY OPENID==============================');
  409. // \Log::info($forceSubscribeUsers);
  410. if(count($forceSubscribeUsers)>0) {
  411. // \Log::info(count($forceSubscribeUsers));
  412. for ($i=0; $i < count($forceSubscribeUsers); $i++) {
  413. # code...
  414. // \Log::info($forceSubscribeUsers[$i]['is_subscribed']);
  415. // \Log::info($forceSubscribeUsers[$i]['subscribe_time']);
  416. $forceSubscribeUsers[$i]['is_subscribed'] = 1;
  417. $forceSubscribeUsers[$i]['subscribe_time'] = date("Y-m-d H:i:s");
  418. $forceSubscribeUsers[$i]->save();
  419. Redis::hincrby('day_appid_fans_nums_appid:add:'.$forceSubscribeUsersPrams['appid'],date("Y-m-d"),1);
  420. Redis::hincrby('day_appid_fans_nums_appid:add:'.$forceSubscribeUsersPrams['appid'],'total',1);
  421. //Redis::hset('www.zhuishuyun.com'.'force_subscribe:scene:'.$forceSubscribeUsers[$i]['uid'].':'.$forceSubscribeUsersPrams['appid'], 'is_subscribe', '[{is_subscribed:1},{subscribe_time:'.date("Y-m-d H:i:s").'}]');
  422. }
  423. return 1;
  424. } else {
  425. return 2;
  426. }
  427. } catch (\Exception $e) {
  428. // \Log($e);
  429. return 0;
  430. }
  431. }
  432. //获取推广带来的净关粉丝总数
  433. static function getFansNum($send_order_id)
  434. {
  435. return ForceSubscribeUsers::getFansNum($send_order_id);
  436. }
  437. //获取推广带来的新关粉丝总数
  438. static function getNewFansNum($send_order_id)
  439. {
  440. return ForceSubscribeUsers::getNewFansNum($send_order_id);
  441. }
  442. //根据模板消息传的各项条件检索用户
  443. static function forceUserCountByTemplatePrams($appids,$distribution_channel_id,$subscribe_time,$sex,$balance,$category_id,$order_type,$skip){
  444. $forceSubscribes = ForceSubscribeUsers::forceUserCountByTemplatePrams($appids,$distribution_channel_id,$subscribe_time,$sex,$balance,$category_id,$order_type,$skip);
  445. return $forceSubscribes;
  446. }
  447. //根据客服消息传的各项条件检索用户
  448. static function forceUserCountByCustomPrams($appids,$distribution_channel_id,$subscribe_time,$sex,$balance,$category_id,$order_type,$sign_time,$skip){
  449. $forceSubscribes = ForceSubscribeUsers::forceUserCountByCustomPrams($appids,$distribution_channel_id,$subscribe_time,$sex,$balance,$category_id,$order_type,$sign_time,$skip);
  450. return $forceSubscribes;
  451. }
  452. // 指定用户的基础信息获取
  453. static function simpleForceUserCountByPrams($uids, $param,$skip){
  454. $forceSubscribes = ForceSubscribeUsers::simpleForceUserCountByPrams($uids, $param,$skip);
  455. return $forceSubscribes;
  456. }
  457. // 根据渠道号和日期获取强关用户数量
  458. /**
  459. * startTime endTime 如果两个参数都传会查询这两个时间段内的的强关用户数量
  460. * startTime endTime 如果只传一个,则会查询当天的强关用户数量,传哪个都可以
  461. * startTime endTime 如果都不传, 则会获取该渠道下的所有强关用户数量
  462. */
  463. static function forceSubscribeUserCountByChannelIdAndDate($distribution_channel_id,$startTime,$endTime){
  464. return ForceSubscribeUsers::forceSubscribeUserCountByChannelIdAndDate($distribution_channel_id,$startTime,$endTime);
  465. }
  466. /**
  467. * 获取全服务号粉丝
  468. */
  469. static function getFullOfficialAccountUsers($appid,$next_openid){
  470. // \Log::info('getFullOfficialAccountUsers_start,appid:'.$appid.' next_openid:'.$next_openid);
  471. $result = array();
  472. try {
  473. $timestamp = time();
  474. $params = array("next_openid"=>$next_openid,'gzh_app_id'=>$appid,"timestamp"=>$timestamp);
  475. $sign = get_sign($params);
  476. $res = self::getUserClient()->request("GET","get_full_official_account_users",
  477. ['query'=>['next_openid'=>$next_openid,'gzh_app_id'=>$appid,'timestamp'=>$timestamp,'sign'=>$sign],'connect_timeout' => 10]
  478. )->getBody()->getContents();
  479. // \Log::info($res);
  480. $res = object_to_array(json_decode($res));
  481. // 组装格式,方便后面统一处理
  482. $openids= isset($res['data']['data']['openid'])?$res['data']['data']['openid']:array();
  483. $result['openids'] = array();
  484. if(!empty($openids)){
  485. foreach($openids as $key=> $openid){
  486. $result['openids'][$key]['openid'] = $openid;
  487. }
  488. }
  489. $result['next_openid'] = isset($res['data']['next_openid'])?$res['data']['next_openid']:'';
  490. $result['count'] = isset($res['data']['count'])?$res['data']['count']:0;
  491. $result['total'] = isset($res['data']['total'])?$res['data']['total']:0;
  492. //\Log::info('getFullOfficialAccountUsers_end,appid:'.$appid.' next_openid:'.$result['next_openid'].' count:'.$result['count'].' total:'.$result['total'].' num:'.count($result['openids']));
  493. } catch (\Exception $e) {
  494. \Log::info($e);
  495. }
  496. return $result;
  497. }
  498. /**
  499. * 获取单个粉丝信息
  500. */
  501. static function getUserInfo($appid,$openid){
  502. \Log::info('getUserInfo_start,appid:'.$appid.' openid:'.$openid);
  503. $result = array();
  504. try {
  505. $timestamp = time();
  506. $params = array("openid"=>$openid,'gzh_app_id'=>$appid,"timestamp"=>$timestamp);
  507. $sign = get_sign($params);
  508. $res = self::getUserClient()->request("GET","get_userinfo",
  509. ['query'=>['openid'=>$openid,'gzh_app_id'=>$appid,'timestamp'=>$timestamp,'sign'=>$sign],'connect_timeout' => 10]
  510. )->getBody()->getContents();
  511. $res = object_to_array(json_decode($res));
  512. $result['nickname'] = isset($res['data']['nickname'])?$res['data']['nickname']:0;
  513. \Log::info('getUserInfo_end,appid:'.$appid.' openid:'.$openid.' nickname:'.$result['nickname']);
  514. } catch (\Exception $e) {
  515. \Log::info('getUserInfo_ept:'.$e->getMessage());
  516. }
  517. return $result;
  518. }
  519. static function getUserInfoAll($appid,$openid){
  520. \Log::info('getUserInfo_start,appid:'.$appid.' openid:'.$openid);
  521. $result = array();
  522. try {
  523. $timestamp = time();
  524. $params = array("openid"=>$openid,'gzh_app_id'=>$appid,"timestamp"=>$timestamp);
  525. $sign = get_sign($params);
  526. $res = self::getUserClient()->request("GET","get_userinfo",
  527. ['query'=>['openid'=>$openid,'gzh_app_id'=>$appid,'timestamp'=>$timestamp,'sign'=>$sign],'connect_timeout' => 10]
  528. )->getBody()->getContents();
  529. $res = object_to_array(json_decode($res));
  530. if(isset($res['data']) && !empty($res['data'])){
  531. return $res['data'];
  532. }
  533. } catch (\Exception $e) {
  534. \Log::info('getUserInfo_ept:'.$e->getMessage());
  535. }
  536. return $result;
  537. }
  538. /**
  539. * 占位符替换
  540. * @param unknown_type $content
  541. * @param unknown_type $type
  542. * @return string
  543. */
  544. static public function change_placeholder($content,$params){
  545. \Log::info('change_placeholder_before:'.$content);
  546. $wx_name = isset($params['nickname'])?$params['nickname']:'';
  547. $content = str_replace('{wx_name}',$wx_name,$content);
  548. \Log::info('change_placeholder_end:'.$content);
  549. return $content;
  550. }
  551. static public function getUserClient(){
  552. return new Client(['base_uri' => env('MEDIA_API_BASE_URI')]);
  553. }
  554. /**
  555. * 获取派单的枪管用户
  556. * @param int $send_order_id
  557. * @param int $distribution_channel_id
  558. * @return mixed
  559. */
  560. static public function getUidByParam(int $send_order_id,int $distribution_channel_id){
  561. return ForceSubscribeUsers::where('send_order_id',$send_order_id)->where('distribution_channel_id',$distribution_channel_id)->select('uid')->limit(100)->get();
  562. }
  563. /**
  564. * 获取云栖迁移的特殊回复
  565. * @param unknown_type $distribution_channel_id
  566. * @param unknown_type $openid
  567. */
  568. static public function getYqMoveReply($distribution_channel_id,$openid){
  569. $text = '';
  570. $encode_distribution_channel_id = encodeDistributionChannelId($distribution_channel_id);
  571. // 检查是否第一次
  572. $move_user = YqMove::getUser($distribution_channel_id,$openid);
  573. // 是否订阅大于50章的用户
  574. $is_big_50_user = isset($move_user['read_count']) && $move_user['read_count'] >= 50 ? '1':'0';
  575. $yq_distribution_channel_id = isset($move_user['yq_distribution_channel_id']) && $move_user['yq_distribution_channel_id'] ? $move_user['yq_distribution_channel_id']:$distribution_channel_id;
  576. $encode_yq_distribution_channel_id = encodeDistributionChannelId($yq_distribution_channel_id);
  577. $not_recommend_old_sites = array('4042','4043','4044');
  578. \Log::info('getYqMoveReply:zsy_distribution_channel_id:'.$distribution_channel_id.' yq_distribution_channel_id:'.$yq_distribution_channel_id.' openid:'.$openid.' is_big_50_user:'.$is_big_50_user);
  579. // 已经迁移过用户的文案
  580. if(!empty($move_user)){
  581. if($is_big_50_user == '0'){
  582. $text = "<a href='".env('PROTOCOL')."://site".$encode_distribution_channel_id.".".env('CUSTOM_HOST').".com'>点击进入新站</a>\n\n";
  583. $text .= "<a href='".env('PROTOCOL')."://site".$encode_distribution_channel_id.".".env('CUSTOM_HOST').".com/recent'>点击查看最近阅读</a>";
  584. }else{
  585. if(in_array($distribution_channel_id,$not_recommend_old_sites)){
  586. \Log::info('not_recommend_old_site:'.$distribution_channel_id.' openid:'.$openid);
  587. $text = "<a href='".env('PROTOCOL')."://site".$encode_distribution_channel_id.".".env('CUSTOM_HOST').".com'>点击进入新站</a>\n\n";
  588. $text .= "<a href='".env('PROTOCOL')."://site".$encode_distribution_channel_id.".".env('CUSTOM_HOST').".com/recent'>点击查看最近阅读</a>";
  589. }else{
  590. $text = "<a href='".env('PROTOCOL')."://site".$encode_distribution_channel_id.".".env('CUSTOM_HOST').".com/recent'>追书云:点此进入新站,看海量优质小说</a>\n\n".
  591. "<a href='http://site".$encode_yq_distribution_channel_id."."."imycmh".".com/recent'>云栖:点此进入老站继续阅读 </a>\n";
  592. }
  593. }
  594. }
  595. // 第一次回复的文案
  596. else
  597. {
  598. $text = "<a href='".env('PROTOCOL')."://site".$encode_distribution_channel_id.".".env('CUSTOM_HOST').".com'>点击进入新站</a>\n\n";
  599. $text .= "<a href='".env('PROTOCOL')."://site".$encode_distribution_channel_id.".".env('CUSTOM_HOST').".com/recent'>点击查看最近阅读</a>";
  600. }
  601. return $text;
  602. }
  603. }