MemberService.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
  4. // +----------------------------------------------------------------------
  5. // | 版权所有 2017~2021 LARAVEL研发中心
  6. // +----------------------------------------------------------------------
  7. // | 官方网站: http://www.laravel.cn
  8. // +----------------------------------------------------------------------
  9. // | Author: laravel开发员 <laravel.qq.com>
  10. // +----------------------------------------------------------------------
  11. namespace App\Services\Api;
  12. use App\Models\ActionLogModel;
  13. use App\Models\MemberBankModel;
  14. use App\Models\MemberModel;
  15. use App\Services\BaseService;
  16. use App\Services\ConfigService;
  17. use App\Services\JwtService;
  18. use App\Services\MpService;
  19. use App\Services\RedisService;
  20. use Illuminate\Support\Facades\DB;
  21. use phpQrcode\QRcode;
  22. /**
  23. * 会员管理-服务类
  24. * @author laravel开发员
  25. * @since 2020/11/11
  26. * Class MemberService
  27. * @package App\Services\Api
  28. */
  29. class MemberService extends BaseService
  30. {
  31. // 静态对象
  32. protected static $instance = null;
  33. /**
  34. * 构造函数
  35. * @author laravel开发员
  36. * @since 2020/11/11
  37. * MemberService constructor.
  38. */
  39. public function __construct()
  40. {
  41. $this->model = new MemberModel();
  42. }
  43. /**
  44. * 静态入口
  45. * @return MemberService|static|null
  46. */
  47. public static function make()
  48. {
  49. if (!self::$instance) {
  50. self::$instance = new static();
  51. }
  52. return self::$instance;
  53. }
  54. /**
  55. * 验证账号
  56. * @param $code
  57. * @param array $params
  58. * @return array|false
  59. */
  60. public function login($code, $params = [])
  61. {
  62. // 账号登录
  63. if (empty($code)) {
  64. $this->error = 1041;
  65. return false;
  66. }
  67. // 获取用户信息
  68. $result = MpService::make()->getUserInfo($code);
  69. $openid = isset($result['openid']) ? $result['openid'] : '';
  70. if (empty($openid)) {
  71. $this->error = 1042;
  72. return false;
  73. }
  74. // 验证是否注册,没有则注册
  75. $where = ['openid' => $openid,'mark'=>1];
  76. $data = $this->model->where($where)
  77. ->select(['id', 'openid', 'mobile', 'user_type', 'nickname', 'avatar', 'code', 'status', 'mark'])
  78. ->first();
  79. $data = $data ? $data->toArray() : [];
  80. $userId = isset($data['id']) ? $data['id'] : 0;
  81. $status = isset($data['status']) ? $data['status'] : 0;
  82. $mobile = isset($data['mobile']) ? $data['mobile'] : '';
  83. $nickname = isset($data['nickname']) ? $data['nickname'] : '';
  84. $avatar = isset($data['nickname']) ? $data['avatar'] : '';
  85. if($data && $status!= 1){
  86. $this->error = '账号已被冻结,请联系客服~';
  87. return false;
  88. }
  89. // 未注册或未完善资料
  90. if(empty($data) || empty($nickname) || empty($mobile)){
  91. return [
  92. 'access_token'=>'',
  93. 'info'=>['uid'=>$userId, 'openid'=>$openid,'mobile'=>$mobile]
  94. ];
  95. }
  96. // 已注册
  97. $system = isset($params['system']) ? $params['system'] : [];
  98. $system = $system && !is_array($system) ? json_decode($system, true) : $system;
  99. $appSources = isset($system['app_sources']) && $system['app_sources'] ? $system['app_sources'] : 'ios';
  100. $uuid = isset($system['uuid']) ? $system['uuid'] : '';
  101. $version = isset($system['app_version']) ? $system['app_version'] : '';
  102. if (!RedisService::get("caches:members:login_{$userId}")) {
  103. $updateData = [
  104. 'login_ip' => get_client_ip(),
  105. 'login_time' => time(),
  106. 'app_uuid' => $uuid,
  107. 'login_count' => DB::raw("login_count+1"),
  108. 'app_version' => $version,
  109. 'device' => $appSources == 'ios' ? 1 : 2,
  110. 'mark' => 1,
  111. ];
  112. $this->model->where(['id' => $userId])->update($updateData);
  113. RedisService::set("caches:members:login_{$userId}", $updateData, rand(30, 60));
  114. }
  115. // 获取登录授权token
  116. $token = JwtService::make()->encode($userId);
  117. // 结果返回
  118. $result = [
  119. 'access_token' => $token,
  120. 'info' => ['uid' => $userId, 'openid' => $openid,'nickname'=>$nickname, 'mobile' => $mobile],
  121. ];
  122. // 用户缓存信息
  123. $this->error = 2019;
  124. $data['token'] = $token;
  125. unset($data['mobile']);
  126. RedisService::keyDel("caches:members:teamList*");
  127. RedisService::set("auths:info:{$userId}", $data, 24 * 3600);
  128. return $result;
  129. }
  130. /**
  131. * 授权注册
  132. * @param $code
  133. * @param array $params
  134. * @return array|false
  135. */
  136. public function register($params = [])
  137. {
  138. $openid = isset($params['openid'])? $params['openid'] : '';
  139. $phone = isset($params['mobile'])? $params['mobile'] : '';
  140. $avatar = isset($params['avatar'])? $params['avatar'] : '';
  141. $nickname = isset($params['nickname'])? $params['nickname'] : '';
  142. if(empty($openid)){
  143. $this->error = '请先获取授权';
  144. return false;
  145. }
  146. // 手机号
  147. if (empty($phone)) {
  148. $this->error = '请先授权获取手机号';
  149. return false;
  150. }
  151. if(empty($avatar) || empty($nickname)){
  152. $this->error = '请先授权设置用户信息';
  153. return false;
  154. }
  155. $avatar = save_base64_image($avatar, 'avatar');
  156. // 验证是否注册,没有则注册
  157. $where = ['openid' => $openid,'mark'=>1];
  158. $data = $this->model->where($where)
  159. ->select(['id', 'openid', 'mobile', 'user_type', 'nickname', 'avatar', 'code', 'status', 'mark'])
  160. ->first();
  161. $data = $data ? $data->toArray() : [];
  162. $userId = isset($data['id']) ? $data['id'] : 0;
  163. $status = isset($data['status']) ? $data['status'] : 0;
  164. if ($data && $userId && $status != 1) {
  165. $this->error = '账号已被冻结,请来奶昔客服~';
  166. return false;
  167. }
  168. $system = isset($params['system']) ? $params['system'] : [];
  169. $system = $system && !is_array($system) ? json_decode($system, true) : $system;
  170. $appSources = isset($system['app_sources']) && $system['app_sources'] ? $system['app_sources'] : 'ios';
  171. $uuid = isset($system['uuid']) ? $system['uuid'] : '';
  172. $version = isset($system['app_version']) ? $system['app_version'] : '';
  173. if (empty($data)) {
  174. // 清理无效注册数据
  175. $this->model->where(['openid'=>$openid,'mark'=>0])->delete();
  176. // 用户ID
  177. $userId = $this->model->max('id') + 1;
  178. // 推荐人
  179. $rid = isset($params['rid']) ? intval($params['rid']) : 0;
  180. $parents = '';
  181. if ($rid) {
  182. $inviteInfo = $this->model->where(['id' => $rid, 'mark' => 1])
  183. ->select(['id', 'parent_id', 'parents', 'status'])
  184. ->first();
  185. $rid = isset($inviteInfo['id']) ? $inviteInfo['id'] : 0;
  186. $parents = isset($inviteInfo['parents']) ? $inviteInfo['parents'] : '';
  187. if ($inviteInfo) {
  188. $parents = $parents ? $parents . $rid . ',' : ",{$rid},";
  189. }else{
  190. $rid = 1;
  191. $parents = ',1,';
  192. }
  193. }else{
  194. $rid = 1;
  195. $parents = ',1,';
  196. }
  197. // 滑落节点
  198. $pointId = 0;
  199. $points = '';
  200. if($rid>0){
  201. $pointId = $this->getPointParentId($rid);
  202. if($pointId){
  203. $pointParent = $this->model->where(['id'=> $pointId,'mark'=>1])->select(['id','points'])->first();
  204. $points = isset($pointParent['points']) ? $pointId.','.$pointParent['points'] : ($pointId ? $pointId . ',' : '');
  205. }
  206. }
  207. DB::beginTransaction();
  208. $data = [
  209. 'nickname' => $nickname,
  210. 'openid' => $openid,
  211. 'mobile' => $phone,
  212. 'avatar' => $avatar,
  213. 'parent_id' => $rid,
  214. 'parents' => $parents,
  215. 'point_id' => $pointId,
  216. 'points' => $points,
  217. 'code' => get_random_code(9, 'Q', $userId),
  218. 'password' => get_password('a123456'),
  219. 'login_ip' => get_client_ip(),
  220. 'create_time' => time(),
  221. 'login_time' => time(),
  222. 'login_count' => DB::raw("login_count+1"),
  223. 'app_version' => $version,
  224. 'app_uuid' => $uuid,
  225. 'device' => $appSources == 'ios' ? 1 : 2,
  226. ];
  227. if (!$userId = $this->model->insertGetId($data)) {
  228. DB::rollBack();
  229. $this->error = 2018;
  230. return false;
  231. }
  232. DB::commit();
  233. } // 更新登录信息
  234. else if (!RedisService::get("caches:members:login_{$userId}")) {
  235. $updateData = [
  236. 'login_ip' => get_client_ip(),
  237. 'login_time' => time(),
  238. 'app_uuid' => $uuid,
  239. 'login_count' => DB::raw("login_count+1"),
  240. 'app_version' => $version,
  241. 'device' => $appSources == 'ios' ? 1 : 2,
  242. 'mark' => 1,
  243. ];
  244. $this->model->where(['id' => $userId])->update($updateData);
  245. RedisService::set("caches:members:login_{$userId}", $updateData, rand(30, 60));
  246. }
  247. // 获取登录授权token
  248. $token = JwtService::make()->encode($userId);
  249. // 结果返回
  250. $result = [
  251. 'access_token' => $token,
  252. 'info' => ['uid' => $userId, 'openid' => $openid, 'mobile' => $data['mobile']],
  253. ];
  254. // 用户缓存信息
  255. $this->error = 2019;
  256. $data['token'] = $token;
  257. unset($data['mobile']);
  258. RedisService::keyDel("caches:members:teamList*");
  259. RedisService::set("auths:info:{$userId}", $data, 24 * 3600);
  260. return $result;
  261. }
  262. /**
  263. * 获取点对点上级节点
  264. * @param $userId 推荐人ID
  265. * @return int|mixed
  266. */
  267. public function getPointParentId($userId)
  268. {
  269. if($userId<=0){
  270. return 0;
  271. }
  272. $userList = $this->model->where(['mark'=> 1])->whereRaw('FIND_IN_SET(?,points)', $userId)->select(['id','point_id','points'])->orderBy('create_time','asc')->get();
  273. $userList = $userList? $userList->toArray() : [];
  274. if(count($userList) < 3){
  275. return $userId;
  276. }
  277. $users = [];
  278. foreach($userList as $item){
  279. $points = isset($item['points']) && $item['points']? explode(',', $item['points']) : [];
  280. $points = array_filter($points);
  281. $users[$item['id']]['pointLen'] = count($points);
  282. $users[$item['id']]['children'] = isset($users[$item['id']]['children'])? $users[$item['id']]['children'] : 0;
  283. $users[$item['point_id']]['children'] = isset($users[$item['point_id']]['children'])? $users[$item['point_id']]['children'] + 1 : 1;
  284. }
  285. //var_dump($users);
  286. $pointId = 0;
  287. $tempPointLen = 0;
  288. $tempChildren = 0;
  289. foreach ($userList as $item) {
  290. $id = isset($item['id'])? $item['id'] : 0;
  291. $children = isset($users[$id]['children'])? $users[$id]['children'] : 0;
  292. $pointLen = isset($users[$id]['pointLen'])? $users[$id]['pointLen'] : 0;
  293. if($pointLen<=$tempPointLen || $pointId == 0){
  294. if($children <$tempChildren || $pointId == 0){
  295. $pointId = $id;
  296. $tempPointLen = $pointLen;
  297. $tempChildren = $children;
  298. }
  299. }
  300. }
  301. return $pointId;
  302. }
  303. /**
  304. * 重置密码
  305. * @param $params
  306. * @return array|false
  307. */
  308. public function forget($params)
  309. {
  310. // 账号登录
  311. $mobile = isset($params['mobile']) ? trim($params['mobile']) : '';
  312. $password = isset($params['password']) ? trim($params['password']) : '';
  313. if (empty($params) || empty($mobile) || empty($password)) {
  314. $this->error = 1041;
  315. return false;
  316. }
  317. // 验证是否注册
  318. if (!$userId = $this->model->where(['mobile' => $mobile, 'mark' => 1])->value('id')) {
  319. $this->error = 1038;
  320. return false;
  321. }
  322. if (!$this->model->where(['id' => $userId])->update(['password' => get_password($password), 'update_time' => time()])) {
  323. $this->error = 2030;
  324. return false;
  325. }
  326. // 操作日志
  327. ActionLogModel::setRecord($userId, ['type' => 2, 'title' => '重置密码', 'content' => '重置登录密码', 'module' => 'member']);
  328. ActionLogModel::record();
  329. $this->error = 2031;
  330. return true;
  331. }
  332. /**
  333. * 获取资料详情
  334. * @param $where
  335. * @param array $field
  336. */
  337. public function getInfo($where, array $field = [], $refresh = true)
  338. {
  339. if (empty($where)) {
  340. return false;
  341. }
  342. $fieldKey = $field ? '_' . md5(json_encode($field)) : '';
  343. $cacheKey = "caches:members:info_" . (!is_array($where) ? $where . $fieldKey : md5(json_encode($where) . $fieldKey));
  344. $info = RedisService::get($cacheKey);
  345. if ($info && !$refresh) {
  346. return $info;
  347. }
  348. $defaultField = ['id', 'user_type', 'realname', 'mobile','is_auth','member_level','vip_growth','vip_expired','idcard', 'nickname','parent_id', 'balance','bonus_total','withdraw_total', 'code', 'openid','create_time', 'status', 'avatar'];
  349. $field = $field ? $field : $defaultField;
  350. if (is_array($where)) {
  351. $info = $this->model->with(['parent'])->where(['mark' => 1])->where($where)->select($field)->first();
  352. } else {
  353. $info = $this->model->with(['parent'])->where(['mark' => 1])->where(['id' => (int)$where])->select($field)->first();
  354. }
  355. $info = $info ? $info->toArray() : [];
  356. if ($info) {
  357. $info['create_time'] = $info['create_time']?datetime(strtotime($info['create_time']),'Y-m-d H:i') : '';
  358. if (isset($info['mobile'])) {
  359. $info['mobile_text'] = $info['mobile'] ? format_mobile($info['mobile']) : '';
  360. }
  361. $params = request()->all();
  362. $type = isset($params['type'])?$params['type']:'';
  363. if($type == 'qrcode'){
  364. $info['qrcode'] = MpService::make()->getMiniQrcode('pages/index/index',"{$info['id']}");
  365. $info['qrcode'] = $info['qrcode']? get_image_url($info['qrcode']):'';
  366. }
  367. if($type == 'center'){
  368. $info['uppers'] = $info['parent']?[$info['parent']]:[];
  369. $info['upper_count'] = $info['parent']?1: 0;
  370. $query = $this->model->where(['parent_id'=>$info['id'],'mark'=>1])->select(['id','avatar','nickname','status']);
  371. $query1 = clone $query;
  372. $info['user_count'] = $query1->count('id');
  373. $info['users'] = $query->limit(3)->get();
  374. // 成长值
  375. $levelGrowth = ConfigService::make()->getConfigByCode('vip_growth_'.$info['member_level']+1);
  376. $info['vip_growth_diff'] = $levelGrowth>0?ceil(max(0,$levelGrowth-$info['vip_growth'])) : 0;
  377. $info['vip_growth_1'] = ConfigService::make()->getConfigByCode('vip_growth_1');
  378. $info['vip_growth_2'] = ConfigService::make()->getConfigByCode('vip_growth_2');
  379. }
  380. RedisService::set($cacheKey, $info, rand(10, 20));
  381. }
  382. return $info;
  383. }
  384. /**
  385. * 认证资料
  386. * @param $userId
  387. * @return array|mixed
  388. */
  389. public function authInfo($userId)
  390. {
  391. $cacheKey = "caches:members:authInfo:{$userId}";
  392. $info = RedisService::get($cacheKey);
  393. if ($info) {
  394. return $info;
  395. }
  396. $info = $this->model->where(['id' => $userId, 'mark' => 1])
  397. ->select(['id', 'realname','idcard','bank_name','bank_card','bank_branch','is_auth', 'status'])
  398. ->first();
  399. $info = $info?$info->toArray() : [];
  400. if($info){
  401. RedisService::set($cacheKey, $info, rand(300,600));
  402. }
  403. return $info;
  404. }
  405. /**
  406. * 绑定收款账户
  407. * @param $userId
  408. * @return array|mixed
  409. */
  410. public function bindAccount($userId, $params)
  411. {
  412. if($params['type']==1){
  413. $alipay = MemberBankModel::where(['type'=>1,'user_id'=>$userId,'mark'=>1])
  414. ->select(['id','user_id','type','realname','account','account_remark','status'])
  415. ->first();
  416. $alipayId = isset($alipay['id'])?$alipay['id'] : 0;
  417. $data = [
  418. 'type'=> 1,
  419. 'user_id'=> $userId,
  420. 'realname'=>$params['realname'],
  421. 'account'=>$params['account'],
  422. 'account_remark'=>isset($params['account_remark']) && $params['account_remark']?$params['account_remark']:'支付宝',
  423. 'status'=>1
  424. ];
  425. if($alipayId){
  426. $data['update_time']=time();
  427. MemberBankModel::where(['id'=>$alipayId])->update($data);
  428. }else {
  429. $data['create_time']=time();
  430. MemberBankModel::insertGetId($data);
  431. }
  432. } else if($params['type']==2){
  433. $banks = MemberBankModel::where(['type'=>2,'user_id'=>$userId,'mark'=>1])
  434. ->select(['id','user_id','type','realname','account','account_remark','status'])
  435. ->first();
  436. $bankId = isset($banks['id'])?$banks['id'] : 0;
  437. $data = [
  438. 'type'=>2,
  439. 'user_id'=> $userId,
  440. 'realname'=>$params['realname'],
  441. 'account'=>$params['account'],
  442. 'account_remark'=>$params['account_remark'],
  443. 'status'=>1
  444. ];
  445. if($bankId){
  446. $data['update_time']=time();
  447. MemberBankModel::where(['id'=>$bankId])->update($data);
  448. }else {
  449. $data['create_time']=time();
  450. MemberBankModel::insertGetId($data);
  451. }
  452. }else{
  453. $this->error = '账号类型错误';
  454. return false;
  455. }
  456. RedisService::keyDel("caches:members:account:{$userId}*");
  457. $this->error = '绑定收款账号成功';
  458. return true;
  459. }
  460. /**
  461. * 团队人数
  462. * @param $uid
  463. * @return array|int|mixed
  464. */
  465. public function getTeamCount($uid)
  466. {
  467. $cacheKey = "caches:members:teamCount:{$uid}";
  468. $data = RedisService::get($cacheKey);
  469. if ($data) {
  470. return $data;
  471. }
  472. $data = $this->model->from('member as a')
  473. ->where('a.parents', 'like', "%,{$uid},%")
  474. ->where(['a.status' => 1, 'a.mark' => 1])
  475. ->count('id');
  476. if($data){
  477. RedisService::set($cacheKey, $data, rand(5,10));
  478. }
  479. return $data;
  480. }
  481. /**
  482. * 生成普通参数二维码
  483. * @param $str 参数
  484. * @param bool $refresh 是否重新生成
  485. * @return bool
  486. */
  487. public function makeQrcode($str, $refresh = false, $size = 4, $margin = 2, $level = 2)
  488. {
  489. $basePath = base_path() . '/public';
  490. $qrFile = '/images/qrcode/';
  491. if (!is_dir($basePath . '/uploads' . $qrFile)) {
  492. @mkdir($basePath . '/uploads' . $qrFile, 0755, true);
  493. }
  494. $key = date('Ymd') . strtoupper(md5($str . '_' . $size . $margin . $level));
  495. $qrFile = $qrFile . "C_{$key}.png";
  496. $cacheKey = "caches:qrcodes:member_" . $key;
  497. if (RedisService::get($cacheKey) && is_file($basePath . '/uploads' . $qrFile) && !$refresh) {
  498. return $qrFile;
  499. }
  500. QRcode::png($str, $basePath . '/uploads' . $qrFile, $level, $size, $margin);
  501. if (!file_exists($basePath . '/uploads' . $qrFile)) {
  502. return false;
  503. }
  504. RedisService::set($cacheKey, ['str' => $str, 'qrcode' => $qrFile, 'date' => date('Y-m-d H:i:s')], 7 * 24 * 3600);
  505. return $qrFile;
  506. }
  507. /**
  508. * 修改信息
  509. * @param $userId
  510. * @param $params
  511. * @return bool
  512. */
  513. public function modify($userId, $params)
  514. {
  515. $cacheLockKey = "caches:members:modify_{$userId}";
  516. if (RedisService::get($cacheLockKey)) {
  517. $this->error = 1034;
  518. return false;
  519. }
  520. // 用户验证
  521. RedisService::set($cacheLockKey, ['user_id' => $userId, 'params' => $params], rand(2, 3));
  522. $info = $this->model->where(['id' => $userId, 'mark' => 1])
  523. ->select(['id', 'nickname','avatar','company','position','department', 'status'])
  524. ->first();
  525. if (!$info || $info['status'] != 1) {
  526. $this->error = 2016;
  527. RedisService::clear($cacheLockKey);
  528. return false;
  529. }
  530. // 修改数据
  531. $data = ['update_time' => time()];
  532. $nickname = isset($params['nickname']) ? $params['nickname'] : '';
  533. if (isset($params['nickname']) && $nickname) {
  534. $data['nickname'] = $nickname;
  535. }
  536. $mobile = isset($params['mobile']) ? $params['mobile'] : '';
  537. if (isset($params['mobile']) && $mobile) {
  538. $data['mobile'] = $mobile;
  539. }
  540. $company = isset($params['company']) ? $params['company'] : '';
  541. if (isset($params['company']) && $company) {
  542. $data['company'] = $company;
  543. }
  544. $department = isset($params['department']) ? $params['department'] : '';
  545. if (isset($params['department']) && $department) {
  546. $data['department'] = $department;
  547. }
  548. $position = isset($params['position']) ? $params['position'] : '';
  549. if (isset($params['position']) && $position) {
  550. $data['position'] = $position;
  551. }
  552. // 头像
  553. $avatar = isset($params['avatar']) ? $params['avatar'] : '';
  554. if (isset($params['avatar']) && $avatar) {
  555. $data['avatar'] = save_base64_image($avatar, 'avatar');
  556. }
  557. if (!$this->model->where(['id' => $userId])->update($data)) {
  558. $this->error = 1014;
  559. RedisService::clear($cacheLockKey);
  560. return false;
  561. }
  562. $oldAvatar = isset($info['avatar']) ? $info['avatar'] : '';
  563. if ($avatar && $oldAvatar && ($avatar != $oldAvatar) && file_exists(ATTACHMENT_PATH . $oldAvatar)) {
  564. @unlink(ATTACHMENT_PATH . $oldAvatar);
  565. }
  566. $this->error = 1013;
  567. RedisService::clear($cacheLockKey);
  568. RedisService::clear("caches:members:authInfo:{$userId}");
  569. RedisService::clear("caches:members:info_{$userId}");
  570. return true;
  571. }
  572. /**
  573. * 认证
  574. * @param $userId
  575. * @param $params
  576. * @return bool
  577. */
  578. public function auth($userId, $params)
  579. {
  580. $cacheLockKey = "caches:members:auth_{$userId}";
  581. if (RedisService::get($cacheLockKey)) {
  582. $this->error = 1034;
  583. return false;
  584. }
  585. // 用户验证
  586. RedisService::set($cacheLockKey, ['user_id' => $userId, 'params' => $params], rand(2, 3));
  587. $info = $this->model->where(['id' => $userId, 'mark' => 1])
  588. ->select(['id', 'realname','idcard','is_auth', 'status'])
  589. ->first();
  590. if (!$info || $info['status'] != 1) {
  591. $this->error = '账号或已被冻结,请联系客服';
  592. RedisService::clear($cacheLockKey);
  593. return false;
  594. }
  595. if($info['is_auth'] == 1 && $info['idcard'] && $info['realname']){
  596. $this->error = '抱歉,您已完成认证';
  597. RedisService::clear($cacheLockKey);
  598. return false;
  599. }
  600. // 认证数据
  601. $data = [
  602. 'realname'=> isset($params['realname'])?$params['realname'] : '',
  603. 'company'=> isset($params['company'])?$params['company'] : '',
  604. 'idcard'=> isset($params['idcard'])?$params['idcard'] : '',
  605. 'is_auth'=> 1,
  606. 'update_time' => time()
  607. ];
  608. if (!$this->model->where(['id' => $userId])->update($data)) {
  609. $this->error = '认证提交失败';
  610. RedisService::clear($cacheLockKey);
  611. return false;
  612. }
  613. $this->error = '恭喜您,已完成认证';
  614. RedisService::clear($cacheLockKey);
  615. RedisService::clear("caches:members:authInfo:{$userId}");
  616. RedisService::keyDel("caches:members:teamList*");
  617. return true;
  618. }
  619. /**
  620. * 获取团队列表
  621. * @param $userId
  622. * @param $params
  623. * @return array
  624. */
  625. public function getTeamList($userId,$params)
  626. {
  627. $page = isset($params['page'])?$params['page']: 1;
  628. $pageSize = isset($params['pageSize'])?$params['pageSize']: 12;
  629. $cacheKey = "caches:members:teamList_{$userId}:{$page}_".md5(json_encode($params));
  630. $list = RedisService::get($cacheKey);
  631. if ($list) {
  632. return [
  633. 'cache'=>true,
  634. 'pageSize'=> $pageSize,
  635. 'total'=>isset($list['total'])? $list['total'] : 0,
  636. 'list'=> isset($list['data'])? $list['data'] : []
  637. ];
  638. }
  639. $list = $this->model->with(['account'])->from('member as a')
  640. ->leftJoin('account_statistics as b','b.user_id','=','a.id')
  641. ->where(['a.parent_id'=>$userId,'b.state'=>1,'a.mark'=>1])
  642. ->where(function($query) use($params){
  643. $keyword = isset($params['keyword'])? $params['keyword'] : '';
  644. if($keyword){
  645. $query->where(function($query) use($keyword){
  646. $query->where('a.realname','like',"%{$keyword}%")
  647. ->orWhere('a.nickname','like',"%{$keyword}%")
  648. ->orWhere('a.mobile','like',"%{$keyword}%");
  649. });
  650. }
  651. })
  652. ->select(['a.id','a.realname','a.mobile','a.nickname','a.parent_id','a.avatar','a.is_auth','a.create_time','a.status'])
  653. ->groupBy('a.id')
  654. ->orderBy('a.create_time','desc')
  655. ->orderBy('a.id','desc')
  656. ->paginate($pageSize > 0 ? $pageSize : 9999999);
  657. $list = $list? $list->toArray() :[];
  658. $total = isset($list['total'])? $list['total'] : 0;
  659. if($total){
  660. RedisService::set($cacheKey, $list, rand(5,10));
  661. }
  662. return [
  663. 'pageSize'=> $pageSize,
  664. 'total'=>$total,
  665. 'list'=> isset($list['data'])? $list['data'] : []
  666. ];
  667. }
  668. /**
  669. * 设置账户参数
  670. * @param $userId
  671. * @param $params
  672. * @return array|false|mixed|string
  673. */
  674. public function setting($userId, $params)
  675. {
  676. $apiUrl = ConfigService::make()->getConfigByCode('bonus_settle_url','');
  677. if(empty($apiUrl)){
  678. $this->error = '设置失败,参数错误';
  679. return false;
  680. }
  681. $token = request()->headers->get('Authorization');
  682. $token = str_replace("Bearer ", null, $token);
  683. $header = [
  684. 'authorization: '.$token
  685. ];
  686. $position = isset($params['position'])?trim($params['position']): '';
  687. $point = isset($params['commission_point'])?floatval($params['commission_point']): 0;
  688. $result = httpRequest($apiUrl.'/team/setting',['id'=>$userId,'position'=>$position,'point'=>$point],'post','',5,$header);
  689. $err = isset($result['err']) && $result['err']?$result['err'] : -1;
  690. $msg = isset($result['msg']) && $result['msg']?$result['msg'] : '1003';
  691. $data = isset($result['data']) && $result['data']?$result['data'] : [];
  692. if($err==0){
  693. $this->error = '操作成功';
  694. return $data;
  695. }else{
  696. $this->error = $msg;
  697. return false;
  698. }
  699. }
  700. /**
  701. * 验证操作用户权限
  702. * @param $userId
  703. * @param $actId
  704. * @return bool
  705. */
  706. public function checkTeamPermission($userId, $actId)
  707. {
  708. $parents = $this->model->where(['id'=>$actId])->value('parents');
  709. $parents = $parents? explode(',',$parents) : [];
  710. if(!in_array($userId,$parents) && $actId != $userId){
  711. $this->error = '信息错误,权限不足';
  712. return false;
  713. }
  714. $this->error = '验证成功';
  715. return true;
  716. }
  717. /**
  718. * 账号注销
  719. * @param $userId
  720. * @return bool
  721. */
  722. public function logOff($userId)
  723. {
  724. $info = $this->model->where(['id' => $userId, 'mark' => 1])
  725. ->select(['id', 'password', 'status'])
  726. ->first();
  727. $status = isset($info['status']) ? $info['status'] : 0;
  728. if (empty($info)) {
  729. $this->error = 2044;
  730. return false;
  731. }
  732. if ($status != 1) {
  733. $this->error = 2044;
  734. return false;
  735. }
  736. if (!$this->model->where(['id' => $userId])->update(['status' => 3, 'update_time' => time()])) {
  737. $this->error = 2049;
  738. return false;
  739. }
  740. $this->error = 2048;
  741. RedisService::clear("auths:info:" . $userId);
  742. return true;
  743. }
  744. }