QappUserService.php 9.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255
  1. <?php
  2. namespace App\Modules\User\Services;
  3. use App\Cache\Lock\LockCache;
  4. use App\Consts\ErrorConst;
  5. use App\Consts\QuickConst;
  6. use App\Jobs\Push\NewUserPushMsgDelay;
  7. use App\Jobs\QappTikTok\QappTikTokUserRequest;
  8. use App\Jobs\QappTikTok\QappTikTokUser;
  9. use App\Libs\Utils;
  10. use App\Modules\User\Models\QappPackage;
  11. use App\Modules\User\Models\QappUser;
  12. use App\Modules\User\Models\User;
  13. use App\Modules\UserTask\Services\BaseTask;
  14. use App\Modules\UserTask\Services\UserTaskService;
  15. use Exception;
  16. use Illuminate\Support\Facades\DB;
  17. use Tymon\JWTAuth\Facades\JWTAuth;
  18. /**
  19. *
  20. */
  21. class QappUserService
  22. {
  23. /**
  24. * 登录
  25. */
  26. public function login(array $data)
  27. {
  28. $codeVersion = getProp($data, 'codeVersion');
  29. $lockToken = '';
  30. $isNewRegister = false;
  31. $device_no = $data['device_no'];
  32. $channel_id = $this->findChannelId($data['package']);
  33. $qapp_user = $this->getQAppUserByDeviceNo($device_no, $channel_id);
  34. if (!$qapp_user) {
  35. // 判断版本号,大于等于1.0.0才做处理
  36. if (version_compare($codeVersion, '1.0.0', '>=')) {
  37. // 加锁3秒,否则报错
  38. $lockToken = md5($device_no . ':' . $channel_id);
  39. $lock = LockCache::getLock($lockToken, 3);
  40. if (!$lock) {
  41. Utils::throwError(ErrorConst::QAPP_LOGIN_FREQUENTLY);
  42. }
  43. }
  44. myLog('login')->info('register', compact('codeVersion', 'device_no', 'channel_id', 'lockToken'));
  45. // 初始化新用户
  46. $isNewRegister = true;
  47. $qapp_user = $this->createQuickAppUser($data);
  48. }
  49. $user = $qapp_user->user;
  50. $uid = $user->id;
  51. $time = strtotime("+1 month");
  52. $token = JWTAuth::fromUser($user);
  53. if ($data['send_order_id']) {
  54. UserService::setUserSendOrder((int)$uid, (int)$data['send_order_id']);
  55. }
  56. // 新注册统计
  57. if ($isNewRegister && $qapp_user) {
  58. // 注册统计
  59. QappAddDeskTopService::incrAddDeskTop($uid, QuickConst::FIELD_REGISTER);
  60. // 释放锁
  61. // if ($lockToken) {
  62. // LockCache::releaseLock($lockToken);
  63. // }
  64. }
  65. return compact('token', 'time', 'uid');
  66. }
  67. public function getGolableUser()
  68. {
  69. $qapp_user = app()->make('qapp_user');
  70. return $qapp_user;
  71. }
  72. /**
  73. * 绑定手机号
  74. * 多个账号可以绑定一个手机号
  75. */
  76. public function bindPhone(int $uid, string $phone, string $version = "1.0")
  77. {
  78. $qapp_user = QappUser::where('uid', $uid)->first();
  79. if ($qapp_user->phone && $qapp_user->phone != $phone) {
  80. return false;
  81. } else {
  82. try {
  83. DB::beginTransaction();
  84. if (!$qapp_user->phone) {
  85. $reward = 100;
  86. if ($version == "1.0") {
  87. User::where('id', $uid)->update(
  88. [
  89. 'balance' => DB::raw('balance+' . $reward),
  90. 'reward_balance' => DB::raw('reward_balance+' . $reward)
  91. ]
  92. );
  93. } else {
  94. UserTaskService::addUserTaskQueue($uid, BaseTask::bind_phone, UserTaskService::add_trigger);
  95. }
  96. }
  97. $qapp_user->phone = $phone;
  98. $qapp_user->save();
  99. DB::commit();
  100. } catch (Exception $e) {
  101. myLog('bindPhone')->error($e->getMessage());
  102. }
  103. return true;
  104. }
  105. }
  106. public function setGolableUser(int $uid, string $package)
  107. {
  108. $user_info = $this->getQAppUserByUid($uid, $package);
  109. $qapp_user = app()->make('qapp_user');
  110. $qapp_user->id = $user_info->id;
  111. $qapp_user->uid = $user_info->uid;
  112. $qapp_user->send_order_id = $user_info->send_order_id;
  113. $qapp_user->device_no = $user_info->device_no;
  114. $qapp_user->device_info = $user_info->device_info;
  115. $qapp_user->phone = $user_info->phone;
  116. $qapp_user->user = $user_info->user;
  117. $qapp_user->app_pay_merchat_id = $user_info->app_pay_merchat_id;
  118. $qapp_user->h5_pay_merchat_id = $user_info->h5_pay_merchat_id;
  119. $qapp_user->ali_pay_merchat_id = $user_info->ali_pay_merchat_id;
  120. }
  121. /**
  122. * 根据设备号获取快应用用户信息
  123. */
  124. public function getQAppUserByDeviceNo(string $device_no, int $channel_id)
  125. {
  126. $qapp_user = QappUser::where('device_no', $device_no)->where('channel_id', $channel_id)->first();
  127. if ($qapp_user) {
  128. $user = User::find($qapp_user->uid);
  129. $qapp_user->user = $user;
  130. }
  131. return $qapp_user;
  132. }
  133. /**
  134. * 根据uid获取快应用用户信息
  135. * @param int $uid
  136. * @param string $package
  137. * @return mixed
  138. */
  139. public function getQAppUserByUid(int $uid, string $package = '')
  140. {
  141. $qapp_user = QappUser::where('uid', $uid)->first();
  142. if ($qapp_user) {
  143. $user = User::find($uid);
  144. $qapp_user->user = $user;
  145. $qapp_user->send_order_id = UserService::getUserSendOrder($uid);
  146. // 针对聚裕的包无法支付的问题(注册时传入了仙女阅读的包名,导致支付时取的支付信息不一致)
  147. if ($package && $package === 'com.juyu.kuaiying.rmyq') {
  148. $package_info = QappPackage::where('package', $package)->first();
  149. } else {
  150. $package_info = QappPackage::where('channel_id', $user->distribution_channel_id)->first();
  151. }
  152. // 支付id
  153. $qapp_user->app_pay_merchat_id = $package_info->app_pay_merchat_id;
  154. $qapp_user->h5_pay_merchat_id = $package_info->h5_pay_merchat_id;
  155. $qapp_user->ali_pay_merchat_id = $package_info->ali_pay_merchat_id;
  156. }
  157. return $qapp_user;
  158. }
  159. /**
  160. * 创建快应用用户信息
  161. */
  162. public function createQuickAppUser(array $data)
  163. {
  164. try {
  165. DB::beginTransaction();
  166. $user = $this->createUser($data);
  167. $channel_id = $user->distribution_channel_id;
  168. $qapp_user = QappUser::firstOrCreate([
  169. 'device_no' => $data['device_no'],
  170. 'channel_id' => $channel_id,
  171. ], [
  172. 'imei' => $data['imei'],
  173. 'androidid' => $data['androidid'],
  174. 'mac' => $data['mac'],
  175. 'uid' => $user->id,
  176. 'device_info' => $data['device_info'],
  177. ]);
  178. $qapp_user->user = $user;
  179. DB::commit();
  180. $this->syncHandle($user, $data);
  181. return $qapp_user;
  182. } catch (Exception $e) {
  183. myLog('create_user')->error($e->getMessage());
  184. }
  185. }
  186. /**
  187. * 新用户异步处理数据
  188. */
  189. private function syncHandle(User $user, array $data)
  190. {
  191. // 队列处理回传业务
  192. $tikTokRegisterRequest = new QappTikTokUserRequest();
  193. $tikTokRegisterRequest->ip = $user->register_ip;
  194. $tikTokRegisterRequest->device_no = $data['device_no'];
  195. $tikTokRegisterRequest->mac = $data['mac'];
  196. $tikTokRegisterRequest->channel_id = $user->distribution_channel_id;
  197. $tikTokRegisterRequest->uid = $user->id;
  198. $tikTokRegisterRequest->register_time = $user->created_at->format('Y-m-d H:i:s');
  199. $tikTokRegisterRequest->send_order_id = $data['send_order_id'];
  200. myLog('qapp_register')->info('', compact('tikTokRegisterRequest'));
  201. // 回传业务
  202. $job = new QappTikTokUser($tikTokRegisterRequest);
  203. dispatch($job->onConnection('rabbitmq')->onQueue('qapp_tiktok_user_register_queue'));
  204. UserTaskService::addUserTaskQueue($user->id, BaseTask::register, UserTaskService::add_trigger);
  205. new NewUserPushMsgDelay($user->id);
  206. dispatch($job->onConnection('rabbitmq')->onQueue('new_user_push_msg'));
  207. }
  208. private function findChannelId(string $package)
  209. {
  210. $channel_id = env('QUICKAPP_SITE');
  211. if ($package) {
  212. $package_info = QappPackage::where('package', $package)->first();
  213. $channel_id = $package_info ? $package_info->channel_id : $channel_id;
  214. }
  215. return $channel_id;
  216. }
  217. /**
  218. * 创建用户
  219. */
  220. private function createUser(array $data): User
  221. {
  222. $openid = $data['device_no'];
  223. $unionid = $data['device_no'];
  224. $register_ip = _getIp();
  225. $distribution_channel_id = $this->findChannelId($data['package']);
  226. $send_order_id = $data['send_order_id'];
  227. $unique_key = compact('unionid', 'distribution_channel_id');
  228. $data = compact('openid', 'register_ip', 'send_order_id');
  229. return User::firstOrCreate($unique_key, $data);
  230. }
  231. }