QappUserService.php 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158
  1. <?php
  2. namespace App\Modules\User\Services;
  3. use App\Consts\SysConsts;
  4. use App\Modules\BaseService;
  5. use App\Modules\User\Models\QappUser;
  6. use App\Modules\User\Models\User;
  7. use DB;
  8. use Exception;
  9. use Tymon\JWTAuth\Facades\JWTAuth;
  10. use Redis;
  11. /**
  12. *
  13. * @method static \App\Modules\User\Models\QappUser setGolableUserStatic(int $uid) 设置快应用用户信息(全局)
  14. * @method static void getGolableUserStatic() 获取快应用用户信息(全局)
  15. * @method static \App\Modules\User\Models\QappUser loginStatic(array $data) 快应用用户登录
  16. * @method static bool bindPhoneStatic(int $uid, string $phone) 绑定手机号
  17. */
  18. class QappUserService
  19. {
  20. use BaseService;
  21. /**
  22. * 获取快应用用户
  23. */
  24. public function login(array $data)
  25. {
  26. $device_no = $data['device_no'];
  27. $qapp_user = $this->getQAppUserByDeviceNo($device_no);
  28. if (!$qapp_user) {
  29. $qapp_user = $this->createQuickAppUser($data);
  30. }
  31. $user = $qapp_user->user;
  32. $uid = $user->id;
  33. $time = time() + SysConsts::ONE_HOUR_SECONDS * 2;
  34. $token = JWTAuth::fromUser($user);
  35. return compact('token', 'time', 'uid');
  36. }
  37. public function getGolableUser()
  38. {
  39. $qapp_user = app()->make('qapp_user');
  40. return $qapp_user;
  41. }
  42. /**
  43. * 绑定手机号
  44. */
  45. public function bindPhone(int $uid, string $phone)
  46. {
  47. $is_exists = QappUser::where('phone', $phone)->exists();
  48. if ($is_exists) {
  49. return false;
  50. } else {
  51. $qapp_user = QappUser::where('uid', $uid)->first();
  52. if ($qapp_user->phone) {
  53. return false;
  54. } else {
  55. try {
  56. DB::beginTransaction();
  57. $qapp_user->phone = $phone;
  58. $qapp_user->save();
  59. $reward = 100;
  60. User::where('id', $uid)->update(
  61. [
  62. 'balance' => DB::raw('balance+' . $reward),
  63. 'reward_balance' => DB::raw('reward_balance+' . $reward)
  64. ]
  65. );
  66. DB::commit();
  67. } catch (Exception $e) {
  68. myLog('bindPhone')->error($e->getMessage());
  69. }
  70. return true;
  71. }
  72. }
  73. }
  74. public function setGolableUser(int $uid)
  75. {
  76. $user_info = $this->getQAppUserByUid($uid);
  77. $qapp_user = app()->make('qapp_user');
  78. $qapp_user->id = $user_info->id;
  79. $qapp_user->uid = $user_info->uid;
  80. $qapp_user->device_no = $user_info->device_no;
  81. $qapp_user->device_info = $user_info->device_info;
  82. $qapp_user->phone = $user_info->phone;
  83. $qapp_user->user = $user_info->user;
  84. }
  85. /**
  86. * 根据设备号获取快应用用户信息
  87. */
  88. public function getQAppUserByDeviceNo(string $device_no)
  89. {
  90. $qapp_user = QappUser::where('device_no', $device_no)->first();
  91. if ($qapp_user) {
  92. $user = User::find($qapp_user->uid);
  93. $qapp_user->user = $user;
  94. }
  95. return $qapp_user;
  96. }
  97. /**
  98. * 根据uid获取快应用用户信息
  99. */
  100. public function getQAppUserByUid(int $uid)
  101. {
  102. $qapp_user = QappUser::where('uid', $uid)->first();
  103. if ($qapp_user) {
  104. $user = User::find($uid);
  105. $qapp_user->user = $user;
  106. $send_order_id = UserService::getUserSendOrderStatic($uid);
  107. $qapp_user->send_order_id = $send_order_id ? $send_order_id : 0;
  108. }
  109. return $qapp_user;
  110. }
  111. /**
  112. * 创建快应用用户信息
  113. */
  114. public function createQuickAppUser(array $data)
  115. {
  116. try {
  117. DB::beginTransaction();
  118. $user = $this->createUser($data);
  119. $uid = $user->id;
  120. $device_no = $data['device_no'];
  121. $data = compact('device_info');
  122. $unique_key = compact('device_no', 'uid');
  123. $qapp_user = QappUser::firstOrCreate($unique_key, $data);
  124. $qapp_user->user = $user;
  125. DB::commit();
  126. return $qapp_user;
  127. } catch (Exception $e) {
  128. myLog('create_user')->error($e->getMessage());
  129. }
  130. }
  131. /**
  132. * 创建用户
  133. */
  134. private function createUser(array $data)
  135. {
  136. $openid = $data['device_no'];
  137. $unionid = $data['device_no'];
  138. $register_ip = _getIp();
  139. $distribution_channel_id = 0;
  140. $send_order_id = $data['send_order_id'];
  141. $unique_key = compact('unionid', 'distribution_channel_id');
  142. $data = compact('openid', 'register_ip', 'send_order_id');
  143. return User::firstOrCreate($unique_key, $data);
  144. }
  145. }