User.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696
  1. <?php
  2. namespace app\models\user;
  3. use app\models\store\StoreOrder;
  4. use app\models\store\StoreProduct;
  5. use app\models\system\SystemStoreMember;
  6. use crmeb\services\SystemConfigService;
  7. use think\facade\Db;
  8. use think\facade\Log;
  9. use think\facade\Session;
  10. use crmeb\traits\ModelTrait;
  11. use crmeb\basic\BaseModel;
  12. use crmeb\traits\JwtAuthModelTrait;
  13. /**
  14. * TODO 用户Model
  15. * Class User
  16. * @package app\models\user
  17. */
  18. class User extends BaseModel
  19. {
  20. use JwtAuthModelTrait;
  21. use ModelTrait;
  22. protected $pk = 'uid';
  23. protected $name = 'user';
  24. protected $insert = ['add_ip', 'last_time', 'last_ip'];
  25. protected $hidden = [
  26. 'add_ip', 'add_time', 'account', 'clean_time', 'last_ip', 'last_time', 'pwd', 'status', 'mark', 'pwd'
  27. ];
  28. protected function setAddIpAttr($value)
  29. {
  30. return app('request')->ip();
  31. }
  32. protected function setLastTimeAttr($value)
  33. {
  34. return time();
  35. }
  36. protected function setLastIpAttr($value)
  37. {
  38. return app('request')->ip();
  39. }
  40. public static function setWechatUser($wechatUser, $spread_uid = 0)
  41. {
  42. $res1 = true;
  43. if ($spread_uid) $res1 = self::where('uid', $spread_uid)->inc('spread_count', 1)->update();
  44. $res2 = self::create([
  45. 'account' => 'wx' . $wechatUser['uid'] . time(),
  46. 'pwd' => md5(123456),
  47. 'nickname' => $wechatUser['nickname'] ?: '',
  48. 'avatar' => $wechatUser['headimgurl'] ?: '',
  49. 'spread_uid' => $spread_uid,
  50. 'add_time' => date("Y-m-d H:i:s"),
  51. 'add_ip' => app('request')->ip(),
  52. 'last_time' => time(),
  53. 'last_ip' => app('request')->ip(),
  54. 'uid' => $wechatUser['uid'],
  55. 'user_type' => 'wechat'
  56. ]);
  57. $res = $res1 && $res2;
  58. self::checkTrans($res);
  59. return $res2;
  60. }
  61. /**
  62. * TODO 获取会员是否被清除过的时间
  63. * @param $uid
  64. * @return int|mixed
  65. * @throws \think\db\exception\DataNotFoundException
  66. * @throws \think\db\exception\ModelNotFoundException
  67. * @throws \think\exception\DbException
  68. */
  69. public static function getCleanTime($uid)
  70. {
  71. $user = self::where('uid', $uid)->field(['add_time', 'clean_time'])->find();
  72. if (!$user) return 0;
  73. return $user['clean_time'] ? $user['clean_time'] : $user['add_time'];
  74. }
  75. /**
  76. * 更新用户信息
  77. * @param $wechatUser 用户信息
  78. * @param $uid 用户uid
  79. * @return bool|void
  80. * @throws \think\db\exception\DataNotFoundException
  81. * @throws \think\db\exception\ModelNotFoundException
  82. * @throws \think\exception\DbException
  83. */
  84. public static function updateWechatUser($wechatUser, $uid)
  85. {
  86. $userInfo = self::where('uid', $uid)->find();
  87. if (!$userInfo) return;
  88. //增加成为分销权限
  89. if (!$userInfo->is_promoter) {
  90. $price = StoreOrder::where(['paid' => 1, 'refund_status' => 0, 'uid' => $uid])->sum('pay_price');
  91. $status = is_brokerage_statu($price);
  92. } else {
  93. $status = false;
  94. }
  95. if ($userInfo->spread_uid) {
  96. return self::edit([
  97. 'nickname' => $wechatUser['nickname'] ?: '',
  98. 'avatar' => $wechatUser['headimgurl'] ?: '',
  99. 'is_promoter' => $status ? 1 : $userInfo->is_promoter,
  100. 'login_type' => isset($wechatUser['login_type']) ? $wechatUser['login_type'] : $userInfo->login_type,
  101. ], $uid, 'uid');
  102. } else {
  103. $data = [
  104. 'nickname' => $wechatUser['nickname'] ?: '',
  105. 'avatar' => $wechatUser['headimgurl'] ?: '',
  106. 'is_promoter' => $status ? 1 : $userInfo->is_promoter,
  107. 'login_type' => isset($wechatUser['login_type']) ? $wechatUser['login_type'] : $userInfo->login_type,
  108. 'spread_uid' => 0,
  109. 'spread_time' => 0,
  110. 'last_time' => time(),
  111. 'last_ip' => request()->ip(),
  112. ];
  113. //TODO 获取后台分销类型
  114. $storeBrokerageStatus = sys_config('store_brokerage_statu');
  115. $storeBrokerageStatus = $storeBrokerageStatus ? $storeBrokerageStatus : 1;
  116. if (isset($wechatUser['code']) && $wechatUser['code'] && $wechatUser['code'] != $uid && $uid != self::where('uid', $wechatUser['code'])->value('spread_uid')) {
  117. if ($storeBrokerageStatus == 1) {
  118. $spreadCount = self::where('uid', $wechatUser['code'])->count();
  119. if ($spreadCount) {
  120. $spreadInfo = self::where('uid', $wechatUser['code'])->find();
  121. if ($spreadInfo->is_promoter) {
  122. //TODO 只有扫码才可以获得推广权限
  123. // if(isset($wechatUser['isPromoter'])) $data['is_promoter'] = $wechatUser['isPromoter'] ? 1 : 0;
  124. }
  125. }
  126. }
  127. $data['spread_uid'] = $wechatUser['code'];
  128. $data['spread_time'] = time();
  129. }
  130. return self::edit($data, $uid, 'uid');
  131. }
  132. }
  133. /**
  134. * 设置推广关系
  135. * @param $spread
  136. * @param $uid
  137. * @return bool
  138. * @throws \think\db\exception\DataNotFoundException
  139. * @throws \think\db\exception\ModelNotFoundException
  140. * @throws \think\exception\DbException
  141. */
  142. public static function setSpread($spread, $uid)
  143. {
  144. //当前用户信息
  145. $userInfo = self::where('uid', $uid)->find();
  146. if (!$userInfo) return true;
  147. //当前用户有上级直接返回
  148. if ($userInfo->spread_uid && $userInfo->lock_spread) return true;
  149. $sp = $spread;
  150. $userlist = User::column('uid,spread_uid', 'uid');
  151. while ($sp) {
  152. if ($sp == $uid) {
  153. $spread = 0;
  154. break;
  155. }
  156. $sp = $userlist[$sp]['spread_uid'];
  157. }
  158. //没有推广编号直接返回
  159. if (!$spread) return true;
  160. if ($spread == $uid) return true;
  161. if ($uid == self::where('uid', $spread)->value('spread_uid')) return true;
  162. //TODO 获取后台分销类型
  163. $storeBrokerageStatus = sys_config('store_brokerage_statu');
  164. $storeBrokerageStatus = $storeBrokerageStatus ? $storeBrokerageStatus : 1;
  165. if ($storeBrokerageStatus == 1) {
  166. $spreadCount = self::where('uid', $spread)->count();
  167. if ($spreadCount) {
  168. $spreadInfo = self::where('uid', $spread)->find();
  169. if ($spreadInfo->is_promoter) {
  170. //TODO 只有扫码才可以获得推广权限
  171. // if(isset($wechatUser['isPromoter'])) $data['is_promoter'] = $wechatUser['isPromoter'] ? 1 : 0;
  172. }
  173. }
  174. }
  175. $data['spread_uid'] = $spread;
  176. $data['spread_time'] = time();
  177. return self::edit($data, $uid, 'uid');
  178. }
  179. /**
  180. * 小程序用户添加
  181. * @param $routineUser
  182. * @param int $spread_uid
  183. * @return object
  184. */
  185. public static function setRoutineUser($routineUser, $spread_uid = 0)
  186. {
  187. self::beginTrans();
  188. $res1 = true;
  189. if ($spread_uid) $res1 = self::where('uid', $spread_uid)->inc('spread_count', 1)->update();
  190. // $storeBrokerageStatu = sys_config('store_brokerage_statu') ? : 1;//获取后台分销类型
  191. $res2 = self::create([
  192. 'account' => 'rt' . $routineUser['uid'] . time(),
  193. 'pwd' => md5(123456),
  194. 'nickname' => $routineUser['nickname'] ?: '',
  195. 'avatar' => $routineUser['headimgurl'] ?: '',
  196. 'spread_uid' => $spread_uid,
  197. // 'is_promoter'=>$spread_uid || $storeBrokerageStatu != 1 ? 1: 0,
  198. 'spread_time' => $spread_uid ? time() : 0,
  199. 'uid' => $routineUser['uid'],
  200. 'add_time' => $routineUser['add_time'],
  201. 'add_ip' => request()->ip(),
  202. 'last_time' => time(),
  203. 'last_ip' => request()->ip(),
  204. 'user_type' => $routineUser['user_type'],
  205. 'code' => $routineUser['top_code'],
  206. ]);
  207. $res = $res1 && $res2;
  208. self::checkTrans($res);
  209. return $res2;
  210. }
  211. /**
  212. * 获得当前登陆用户UID
  213. * @return int $uid
  214. */
  215. public static function getActiveUid()
  216. {
  217. $uid = null;
  218. $uid = Session::get('LoginUid');
  219. if ($uid) return $uid;
  220. else return 0;
  221. }
  222. /**
  223. * TODO 查询当前用户信息
  224. * @param $uid $uid 用户编号
  225. * @param string $field $field 查询的字段
  226. * @return array
  227. * @throws \think\Exception
  228. * @throws \think\db\exception\DataNotFoundException
  229. * @throws \think\db\exception\ModelNotFoundException
  230. * @throws \think\exception\DbException
  231. */
  232. public static function getUserInfo($uid, $field = '')
  233. {
  234. if (strlen(trim($field))) $userInfo = self::where('uid', $uid)->field($field)->find();
  235. else $userInfo = self::where('uid', $uid)->find();
  236. if (!$userInfo) return [];
  237. return $userInfo->toArray();
  238. }
  239. /**
  240. * 判断当前用户是否推广员
  241. * @param int $uid
  242. * @return bool
  243. */
  244. public static function isUserSpread($uid = 0)
  245. {
  246. if (!$uid) return false;
  247. $status = (int)sys_config('store_brokerage_statu');
  248. $isPromoter = true;
  249. if ($status == 1) $isPromoter = self::where('uid', $uid)->value('is_promoter');
  250. if ($isPromoter) return true;
  251. else return false;
  252. }
  253. /**
  254. * TODO 一级返佣
  255. * @param $orderInfo
  256. * @return bool
  257. * @throws \think\Exception
  258. * @throws \think\db\exception\DataNotFoundException
  259. * @throws \think\db\exception\ModelNotFoundException
  260. * @throws \think\exception\DbException
  261. */
  262. public static function backOrderBrokerage($orderInfo, bool $open = true)
  263. {
  264. //TODO 营销产品不返佣金
  265. if (isset($orderInfo['combination_id']) && $orderInfo['combination_id']) return true;
  266. if (isset($orderInfo['seckill_id']) && $orderInfo['seckill_id']) return true;
  267. if (isset($orderInfo['bargain_id']) && $orderInfo['bargain_id']) return true;
  268. $userInfo = User::getUserInfo($orderInfo['uid']);
  269. //TODO 当前用户不存在 没有上级 或者 当用用户上级时自己 直接返回
  270. if (!$userInfo || !$userInfo['spread_uid'] || $userInfo['spread_uid'] == $orderInfo['uid']) return true;
  271. if (!User::be(['uid' => $userInfo['spread_uid'], 'is_promoter' => 1])) return self::backOrderBrokerageTwo($orderInfo, $open);
  272. $cartId = is_string($orderInfo['cart_id']) ? json_decode($orderInfo['cart_id'], true) : $orderInfo['cart_id'];
  273. $brokeragePrice = StoreProduct::getProductBrokerage($cartId);
  274. //TODO 返佣金额小于等于0 直接返回不返佣金
  275. if ($brokeragePrice <= 0) return true;
  276. //TODO 获取上级推广员信息
  277. $spreadUserInfo = User::getUserInfo($userInfo['spread_uid']);
  278. //TODO 上级推广员返佣之后的金额
  279. $balance = bcadd($spreadUserInfo['brokerage_price'], $brokeragePrice, 2);
  280. $mark = $userInfo['nickname'] . '成功消费' . floatval($orderInfo['pay_price']) . '元,奖励推广佣金' . floatval($brokeragePrice);
  281. $open && self::beginTrans();
  282. //TODO 添加推广记录
  283. $res1 = UserBill::income('获得推广佣金', $userInfo['spread_uid'], 'now_money', 'brokerage', $brokeragePrice, $orderInfo['id'], $balance, $mark);
  284. //TODO 添加用户余额
  285. $res2 = self::bcInc($userInfo['spread_uid'], 'brokerage_price', $brokeragePrice, 'uid');
  286. //TODO 一级返佣成功 跳转二级返佣
  287. $res = $res1 && $res2 && self::backOrderBrokerageTwo($orderInfo, $open);
  288. $open && self::checkTrans($res);
  289. // if($res) return self::backOrderBrokerageTwo($orderInfo);
  290. return $res;
  291. }
  292. /**
  293. * TODO 二级推广
  294. * @param $orderInfo
  295. * @return bool
  296. * @throws \think\Exception
  297. * @throws \think\db\exception\DataNotFoundException
  298. * @throws \think\db\exception\ModelNotFoundException
  299. * @throws \think\exception\DbException
  300. */
  301. public static function backOrderBrokerageTwo($orderInfo, bool $open = true)
  302. {
  303. //TODO 获取购买商品的用户
  304. $userInfo = User::getUserInfo($orderInfo['uid']);
  305. //TODO 获取上推广人
  306. $userInfoTwo = User::getUserInfo($userInfo['spread_uid']);
  307. //TODO 上推广人不存在 或者 上推广人没有上级 或者 当用用户上上级时自己 直接返回
  308. if (!$userInfoTwo || !$userInfoTwo['spread_uid'] || $userInfoTwo['spread_uid'] == $orderInfo['uid']) return true;
  309. //TODO 获取后台分销类型 1 指定分销 2 人人分销
  310. if (!User::be(['uid' => $userInfoTwo['spread_uid'], 'is_promoter' => 1])) return true;
  311. $cartId = is_string($orderInfo['cart_id']) ? json_decode($orderInfo['cart_id'], true) : $orderInfo['cart_id'];
  312. $brokeragePrice = StoreProduct::getProductBrokerage($cartId, false);
  313. //TODO 返佣金额小于等于0 直接返回不返佣金
  314. if ($brokeragePrice <= 0) return true;
  315. //TODO 获取上上级推广员信息
  316. $spreadUserInfoTwo = User::getUserInfo($userInfoTwo['spread_uid']);
  317. //TODO 获取上上级推广员返佣之后余额
  318. $balance = bcadd($spreadUserInfoTwo['brokerage_price'], $brokeragePrice, 2);
  319. $mark = '二级推广人' . $userInfo['nickname'] . '成功消费' . floatval($orderInfo['pay_price']) . '元,奖励推广佣金' . floatval($brokeragePrice);
  320. $open && self::beginTrans();
  321. //TODO 添加返佣记录
  322. $res1 = UserBill::income('获得推广佣金', $userInfoTwo['spread_uid'], 'now_money', 'brokerage', $brokeragePrice, $orderInfo['id'], $balance, $mark);
  323. //TODO 添加用户余额
  324. $res2 = self::bcInc($userInfoTwo['spread_uid'], 'brokerage_price', $brokeragePrice, 'uid');
  325. $res = $res1 && $res2;
  326. $open && self::checkTrans($res);
  327. return $res;
  328. }
  329. /**
  330. * 获取推荐人 暂无使用
  331. * @param $uid
  332. * @param $page
  333. * @param $limit
  334. * @return mixed
  335. */
  336. public static function getSpreadList($uid, $page, $limit)
  337. {
  338. $list = self::where('spread_uid', $uid)->field('uid,nickname,avatar,add_time')->page($page, $limit)->order('add_time DESC')->select();
  339. foreach ($list as $k => $user) {
  340. $list[$k]['add_time'] = date('Y/m/d', $user['add_time']);
  341. $list[$k]['price'] = StoreOrder::getUserPrice($user['uid']);
  342. }
  343. $count = self::where('spread_uid', $uid)->field('uid,nickname,avatar,add_time')->count();
  344. $data['count'] = $count;
  345. $data['list'] = $list;
  346. return $data;
  347. }
  348. /**
  349. * 获取某个用户的下级uid
  350. * @param $uid
  351. * @return array
  352. */
  353. public static function getOneSpreadUid($uid)
  354. {
  355. return self::where('spread_uid', $uid)->column('uid');
  356. }
  357. /**
  358. * 修改个人信息
  359. * @param $avatar 头像
  360. * @param $nickname 昵称
  361. * @param $uid 用户uid
  362. * @return bool
  363. */
  364. public static function editUser($avatar, $nickname, $uid)
  365. {
  366. return self::edit(['avatar' => $avatar, 'nickname' => $nickname], $uid, 'uid');
  367. }
  368. /**
  369. * TODO 获取推广人数 一级
  370. * @param int $uid
  371. * @return bool|int|string
  372. */
  373. public static function getSpreadCount($uid = 0)
  374. {
  375. if (!$uid) return false;
  376. return self::where('spread_uid', $uid)->count('uid');
  377. }
  378. /**
  379. * 修改当前用户的推广人数
  380. * @param $uid
  381. */
  382. public static function setUserSpreadCount($uid)
  383. {
  384. self::where('uid', $uid)->update(['spread_count' => self::getSpreadCount($uid)]);
  385. }
  386. /**
  387. * TODO 获取推广人数 二级
  388. * @param int $uid
  389. * @return bool|int|string
  390. */
  391. public static function getSpreadLevelCount($uid = 0)
  392. {
  393. if (!$uid) return false;
  394. $uidSubordinate = self::where('spread_uid', $uid)->column('uid');
  395. if (!count($uidSubordinate)) return 0;
  396. return self::where('spread_uid', 'IN', implode(',', $uidSubordinate))->count('uid');
  397. }
  398. /**
  399. * 获取用户下级推广人
  400. * @param int $uid 当前用户
  401. * @param int $grade 等级 0 一级 1 二级
  402. * @param string $orderBy 排序
  403. * @param string $keyword
  404. * @param int $page
  405. * @param int $limit
  406. * @return array|bool
  407. */
  408. public static function getUserSpreadGrade($uid = 0, $grade = 0, $orderBy = '', $keyword = '', $page = 0, $limit = 20)
  409. {
  410. if (!$uid) return [];
  411. $gradeGroup = [0, 1];
  412. if (!in_array($grade, $gradeGroup)) return self::setErrorInfo('等级错误');
  413. $userStair = self::where('spread_uid', $uid)->column('uid');
  414. if (!count($userStair)) return [];
  415. if ($grade == 0) return self::getUserSpreadCountList(implode(',', $userStair), $orderBy, $keyword, $page, $limit);
  416. $userSecondary = self::where('spread_uid', 'in', implode(',', $userStair))->column('uid');
  417. return self::getUserSpreadCountList(implode(',', $userSecondary), $orderBy, $keyword, $page, $limit);
  418. }
  419. /**
  420. * 获取团队信息
  421. * @param $uid
  422. * @param string $orderBy
  423. * @param string $keyword
  424. * @param int $page
  425. * @param int $limit
  426. * @return array
  427. */
  428. public static function getUserSpreadCountList($uid, $orderBy = '', $keyword = '', $page = 0, $limit = 20)
  429. {
  430. $model = new self;
  431. $orderBy = 'u.uid asc';
  432. $model = $model->alias(' u');
  433. $sql = StoreOrder::where('o.paid', 1)->group('o.uid')->field(['SUM(o.pay_price) as numberCount', 'o.uid', 'o.order_id'])
  434. ->where('o.is_del', 0)->where('o.refund_status', 'in', [0, 1])->where('o.is_system_del', 0)->alias('o')->fetchSql(true)->select();
  435. $model = $model->join("(" . $sql . ") p", 'u.uid = p.uid', 'LEFT');
  436. $model = $model->where('u.uid', 'IN', $uid);
  437. $model = $model->field("u.uid,u.real_name as nickname,u.avatar,u.add_time as time,u.spread_count as childCount,u.pay_count as orderCount,p.numberCount");
  438. if (strlen(trim($keyword))) $model = $model->where('u.nickname|u.phone', 'like', "%$keyword%");
  439. $model = $model->group('u.uid');
  440. $model = $model->order($orderBy);
  441. $model = $model->page($page, $limit);
  442. $list = $model->select();
  443. if ($list) return $list->toArray();
  444. else return [];
  445. }
  446. /**
  447. * 设置用户的上级关系
  448. * @param $uid 用户uid
  449. * @param $spreadUid 上级用户uid
  450. * @return User|bool
  451. * @throws \think\db\exception\DataNotFoundException
  452. * @throws \think\db\exception\ModelNotFoundException
  453. * @throws \think\exception\DbException
  454. */
  455. public static function setSpreadUid($uid, $spreadUid)
  456. {
  457. // 自己不能绑定自己为上级
  458. if ($uid == $spreadUid) return false;
  459. $sp = $spreadUid;
  460. $userlist = User::column('uid,spread_uid', 'uid');
  461. while ($sp) {
  462. if ($sp == $uid) {
  463. $spreadUid = 0;
  464. break;
  465. }
  466. $sp = $userlist[$sp]['spread_uid'];
  467. }
  468. //TODO 获取后台分销类型
  469. // $storeBrokerageStatus = sys_config('store_brokerage_statu');
  470. // $storeBrokerageStatus = $storeBrokerageStatus ? $storeBrokerageStatus : 1;
  471. // if ($storeBrokerageStatus == 1) {
  472. // $spreadCount = self::where('uid', $spreadUid)->count();
  473. // if ($spreadCount) {
  474. // $spreadInfo = self::where('uid', $spreadUid)->find();
  475. // if ($spreadInfo->is_promoter) {
  476. // //TODO 只有扫码才可以获得推广权限
  477. // if (isset($wechatUser['isPromoter'])) $data['is_promoter'] = 1;
  478. // }
  479. // }
  480. // }
  481. if (!$spreadUid) return false;
  482. if (self::where('lock_spread', 1)->where('uid', $uid)->find()) return false;
  483. return self::where('uid', $uid)->update(['spread_uid' => $spreadUid, 'spread_time' => time()]);
  484. }
  485. /**
  486. * 判断上下级关系是否存在
  487. * @param $uid
  488. * @param $spreadUid
  489. * @return bool|int
  490. */
  491. public static function validSpread($uid, $spreadUid)
  492. {
  493. if (!$uid || !$spreadUid) return false;
  494. return self::where('uid', $uid)->where('spread_uid', $spreadUid)->count();
  495. }
  496. /**
  497. * H5用户注册
  498. * @param $account
  499. * @param $password
  500. * @param $spread
  501. * @return User|\think\Model
  502. */
  503. public static function register($account, $password, $spread, $real_name = '', $addres = '')
  504. {
  505. if (self::be(['account' => $account])) return self::setErrorInfo('用户已存在');
  506. $phone = $account;
  507. $data['account'] = $account;
  508. $data['pwd'] = md5($password);
  509. $data['phone'] = $phone;
  510. if ($spread) {
  511. $data['spread_uid'] = $spread;
  512. $data['spread_time'] = time();
  513. }
  514. $data['real_name'] = $real_name;
  515. $data['birthday'] = 0;
  516. $data['card_id'] = '';
  517. $data['mark'] = '';
  518. $data['addres'] = '';
  519. $data['user_type'] = 'h5';
  520. $data['add_time'] = date("Y-m-d H:i:s");
  521. $data['add_ip'] = app('request')->ip();
  522. $data['last_time'] = time();
  523. $data['last_ip'] = app('request')->ip();
  524. $data['nickname'] = substr(md5($account . time()), 0, 12);
  525. $data['avatar'] = $data['headimgurl'] = sys_config('h5_avatar');
  526. $data['city'] = '';
  527. $data['language'] = '';
  528. $data['province'] = '';
  529. $data['country'] = '';
  530. $data['addres'] = $addres;
  531. $data['uid'] = self::getkeytoid('uid');
  532. self::beginTrans();
  533. $res2 = WechatUser::create($data);
  534. $data['uid'] = $res2->uid;
  535. $res1 = self::create($data);
  536. $res = $res1 && $res2;
  537. self::checkTrans($res);
  538. return $res;
  539. }
  540. /**
  541. * 密码修改
  542. * @param $account
  543. * @param $password
  544. * @return User|bool
  545. */
  546. public static function reset($account, $password)
  547. {
  548. if (!self::be(['account' => $account])) return self::setErrorInfo('用户不存在');
  549. $count = self::where('account', $account)->where('pwd', md5($password))->count();
  550. if ($count) return true;
  551. return self::where('account', $account)->update(['pwd' => md5($password)]);
  552. }
  553. /**
  554. * 获取手机号是否注册
  555. * @param $phone
  556. * @return bool
  557. */
  558. public static function checkPhone($phone)
  559. {
  560. return self::be(['account' => $phone]);
  561. }
  562. /**
  563. * 获取推广人
  564. * @param $data 查询条件
  565. * @return array
  566. * @throws \think\db\exception\DataNotFoundException
  567. * @throws \think\db\exception\ModelNotFoundException
  568. * @throws \think\exception\DbException
  569. */
  570. public static function getRankList($data)
  571. {
  572. switch ($data['type']) {
  573. case 'week':
  574. $startTime = strtotime('this week');
  575. $endTime = time();
  576. break;
  577. case 'month':
  578. $startTime = strtotime('last month');
  579. $endTime = time();
  580. break;
  581. }
  582. $list = self::alias('t0')
  583. ->field('t0.uid,t0.spread_uid,count(t1.spread_uid) AS count,t0.add_time,t0.nickname,t0.avatar')
  584. ->join('user t1', 't0.uid = t1.spread_uid', 'LEFT')
  585. ->where('t1.spread_uid', '<>', 0)
  586. ->order('count desc')
  587. ->order('t0.uid desc')
  588. ->where('t1.add_time', 'BETWEEN', [date("Y-m-d H:i:s", $startTime), date("Y-m-d H:i:s", $endTime)])
  589. ->page($data['page'], $data['limit'])
  590. ->group('t0.uid')
  591. ->select();
  592. return count($list) ? $list->toArray() : [];
  593. }
  594. /**
  595. * 获取佣金排行
  596. * @param $data
  597. * @return array
  598. */
  599. public static function brokerageRank($data)
  600. {
  601. $model = UserBill::alias('b')->join('user u', 'b.uid = u.uid');
  602. $model = $model->where('b.category', 'now_money')->where('b.type', 'brokerage');
  603. switch ($data['type']) {
  604. case 'week':
  605. $model = $model->whereWeek('b.add_time');
  606. break;
  607. case 'month':
  608. $model = $model->whereMonth('b.add_time');
  609. break;
  610. }
  611. $users = $model->group('b.uid')
  612. ->field('b.uid,u.nickname,u.avatar,SUM(IF(pm=1,`number`,-`number`)) as brokerage_price')
  613. ->order('brokerage_price desc')
  614. ->page((int)$data['page'], (int)$data['limit'])
  615. ->select();
  616. return count($users) ? $users->toArray() : [];
  617. }
  618. /**
  619. * 获取当前用户的佣金排行位置
  620. * @param $uid
  621. * @return int
  622. */
  623. public static function currentUserRank($type, $brokerage_price)
  624. {
  625. $model = self::where('status', 1);
  626. switch ($type) {
  627. case 'week':
  628. $model = $model->whereIn('uid', function ($query) {
  629. $query->name('user_bill')->where('category', 'now_money')->where('type', 'brokerage')
  630. ->whereWeek('add_time')->field('uid');
  631. });
  632. break;
  633. case 'month':
  634. $model = $model->whereIn('uid', function ($query) {
  635. $query->name('user_bill')->where('category', 'now_money')->where('type', 'brokerage')
  636. ->whereMonth('add_time')->field('uid');
  637. });
  638. break;
  639. }
  640. return $model->where('brokerage_price', '>', $brokerage_price)->count('uid');
  641. }
  642. /**
  643. * 获取门店会员信息
  644. * @return \think\model\relation\HasOne
  645. */
  646. public function storeMember()
  647. {
  648. return $this->hasOne(SystemStoreMember::class, "uid", "uid");
  649. }
  650. }