QappUserService.php 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156
  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 = strtotime("+1 month");
  34. $token = JWTAuth::fromUser($user);
  35. if ($data['send_order_id']) {
  36. UserService::setUserSendOrderStatic($uid, $data['send_order_id']);
  37. }
  38. return compact('token', 'time', 'uid');
  39. }
  40. public function getGolableUser()
  41. {
  42. $qapp_user = app()->make('qapp_user');
  43. return $qapp_user;
  44. }
  45. /**
  46. * 绑定手机号
  47. */
  48. public function bindPhone(int $uid, string $phone)
  49. {
  50. $qapp_user = QappUser::where('uid', $uid)->first();
  51. if ($qapp_user->phone && $qapp_user->phone != $phone) {
  52. return false;
  53. } else {
  54. try {
  55. DB::beginTransaction();
  56. $qapp_user->phone = $phone;
  57. $qapp_user->save();
  58. $reward = 100;
  59. User::where('id', $uid)->update(
  60. [
  61. 'balance' => DB::raw('balance+' . $reward),
  62. 'reward_balance' => DB::raw('reward_balance+' . $reward)
  63. ]
  64. );
  65. DB::commit();
  66. } catch (Exception $e) {
  67. myLog('bindPhone')->error($e->getMessage());
  68. }
  69. return true;
  70. }
  71. }
  72. public function setGolableUser(int $uid)
  73. {
  74. $user_info = $this->getQAppUserByUid($uid);
  75. $qapp_user = app()->make('qapp_user');
  76. $qapp_user->id = $user_info->id;
  77. $qapp_user->uid = $user_info->uid;
  78. $qapp_user->send_order_id = $user_info->send_order_id;
  79. $qapp_user->device_no = $user_info->device_no;
  80. $qapp_user->device_info = $user_info->device_info;
  81. $qapp_user->phone = $user_info->phone;
  82. $qapp_user->user = $user_info->user;
  83. }
  84. /**
  85. * 根据设备号获取快应用用户信息
  86. */
  87. public function getQAppUserByDeviceNo(string $device_no)
  88. {
  89. $qapp_user = QappUser::where('device_no', $device_no)->first();
  90. if ($qapp_user) {
  91. $user = User::find($qapp_user->uid);
  92. $qapp_user->user = $user;
  93. }
  94. return $qapp_user;
  95. }
  96. /**
  97. * 根据uid获取快应用用户信息
  98. */
  99. public function getQAppUserByUid(int $uid)
  100. {
  101. $qapp_user = QappUser::where('uid', $uid)->first();
  102. if ($qapp_user) {
  103. $user = User::find($uid);
  104. $qapp_user->user = $user;
  105. $qapp_user->send_order_id = UserService::getUserSendOrderStatic($uid);
  106. }
  107. return $qapp_user;
  108. }
  109. /**
  110. * 创建快应用用户信息
  111. */
  112. public function createQuickAppUser(array $data)
  113. {
  114. try {
  115. DB::beginTransaction();
  116. $user = $this->createUser($data);
  117. $uid = $user->id;
  118. $device_no = $data['device_no'];
  119. $data = compact('device_info');
  120. $unique_key = compact('device_no', 'uid');
  121. $qapp_user = QappUser::firstOrCreate($unique_key, $data);
  122. $qapp_user->user = $user;
  123. DB::commit();
  124. return $qapp_user;
  125. } catch (Exception $e) {
  126. myLog('create_user')->error($e->getMessage());
  127. }
  128. }
  129. /**
  130. * 创建用户
  131. */
  132. private function createUser(array $data)
  133. {
  134. $openid = $data['device_no'];
  135. $unionid = $data['device_no'];
  136. $register_ip = _getIp();
  137. $distribution_channel_id = env('QUICKAPP_SITE');
  138. $send_order_id = $data['send_order_id'];
  139. $unique_key = compact('unionid', 'distribution_channel_id');
  140. $data = compact('openid', 'register_ip', 'send_order_id');
  141. return User::firstOrCreate($unique_key, $data);
  142. }
  143. }