|
|
@@ -0,0 +1,494 @@
|
|
|
+<?php
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | likeshop100%开源免费商用商城系统
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
|
|
|
+// | 开源版本可自由商用，可去除界面版权logo
|
|
|
+// | 商业版本务必购买商业授权，以免引起法律纠纷
|
|
|
+// | 禁止对系统程序代码以任何目的，任何形式的再发布
|
|
|
+// | gitee下载：https://gitee.com/likeshop_gitee
|
|
|
+// | github下载：https://github.com/likeshop-github
|
|
|
+// | 访问官网：https://www.likeshop.cn
|
|
|
+// | 访问社区：https://home.likeshop.cn
|
|
|
+// | 访问手册：http://doc.likeshop.cn
|
|
|
+// | 微信公众号：likeshop技术社区
|
|
|
+// | likeshop团队 版权所有 拥有最终解释权
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+// | author: likeshopTeam
|
|
|
+// +----------------------------------------------------------------------
|
|
|
+namespace app\openapi\logic\user;
|
|
|
+use app\adminapi\logic\distribution\DistributionLogic;
|
|
|
+use app\common\{logic\BaseLogic,
|
|
|
+ model\User,
|
|
|
+ model\Order,
|
|
|
+ enum\PayEnum,
|
|
|
+ model\UserLevel,
|
|
|
+ model\UserLabel,
|
|
|
+ enum\CouponEnum,
|
|
|
+ model\CouponList,
|
|
|
+ enum\AccountLogEnum,
|
|
|
+ model\UserLabelIndex,
|
|
|
+ logic\AccountLogLogic,
|
|
|
+ enum\UserTerminalEnum};
|
|
|
+use think\facade\Db;
|
|
|
+use think\Model;
|
|
|
+
|
|
|
+
|
|
|
+/**
|
|
|
+ * 用户逻辑层
|
|
|
+ * Class UserLogic
|
|
|
+ * @package app\adminapi\logic\user
|
|
|
+ */
|
|
|
+class UserLogic extends BaseLogic
|
|
|
+{
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 用户概况页面
|
|
|
+ * @return array
|
|
|
+ * @author cjhao
|
|
|
+ * @date 2021/8/17 14:58
|
|
|
+ */
|
|
|
+ public function index():array
|
|
|
+ {
|
|
|
+ $today = strtotime(date('Y-m-d'));
|
|
|
+ //用户数
|
|
|
+ $userCount = User::count();
|
|
|
+ //今日新增用户数
|
|
|
+ $userNewCount = User::where('create_time','>=',$today)->count();
|
|
|
+ //成交用户数
|
|
|
+ $repetitionCount = Order::where(['pay_status'=>PayEnum::ISPAID])->count();
|
|
|
+ //复购用户数
|
|
|
+ $purchaseCount = Order::where(['pay_status'=>PayEnum::ISPAID])
|
|
|
+ ->group('user_id')
|
|
|
+ ->having('count(user_id) >= 2')
|
|
|
+ ->count();
|
|
|
+
|
|
|
+ $dayList = day_time(14,true);
|
|
|
+ $dayList = array_reverse($dayList);
|
|
|
+ $echarts_data = [];
|
|
|
+ //图表数据
|
|
|
+ foreach ($dayList as $dayKey => $dayVal){
|
|
|
+ $newUserCount = User::whereTime('create_time','between',[$dayVal,$dayVal+86399])->count();
|
|
|
+ $echarts_data[] = [
|
|
|
+ 'day' => date('m-d',$dayVal),
|
|
|
+ 'user_new_count' => $newUserCount,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ $data = [
|
|
|
+ 'user_count' => $userCount,
|
|
|
+ 'user_new_count' => $userNewCount,
|
|
|
+ 'repetition_count' => $repetitionCount,
|
|
|
+ 'purchase_count' => $purchaseCount,
|
|
|
+ 'echarts_data' => $echarts_data,
|
|
|
+ ];
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 用户搜索条件列表
|
|
|
+ * @return array
|
|
|
+ * @throws \think\db\exception\DataNotFoundException
|
|
|
+ * @throws \think\db\exception\DbException
|
|
|
+ * @throws \think\db\exception\ModelNotFoundException
|
|
|
+ * @author cjhao
|
|
|
+ * @date 2021/8/10 16:58
|
|
|
+ */
|
|
|
+ public function otherLists(): array
|
|
|
+ {
|
|
|
+
|
|
|
+ $userLevel = UserLevel::order('rank', 'asc')->field('id,name')->select();
|
|
|
+ $userLabel = UserLabel::field('id,name')->select();
|
|
|
+ $sourceList = UserTerminalEnum::getTermInalDesc();
|
|
|
+ return [
|
|
|
+ 'user_level_list' => $userLevel,
|
|
|
+ 'user_label_list' => $userLabel,
|
|
|
+ 'source_list' => $sourceList,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 设置用户标签
|
|
|
+ * @param array $param
|
|
|
+ * @return bool
|
|
|
+ * @throws \Exception
|
|
|
+ * @author cjhao
|
|
|
+ * @date 2021/8/17 11:43
|
|
|
+ */
|
|
|
+ public function setLabel(array $param): bool
|
|
|
+ {
|
|
|
+ $userIds = $param['user_ids'] ?? [];
|
|
|
+ $labelIds = $param['label_ids'] ?? [];
|
|
|
+ $labelIds = UserLabel::where(['id' => $labelIds])->column('id');
|
|
|
+ //当前用户已绑定的标签
|
|
|
+ $userLabelIndexList = UserLabelIndex::where(['user_id' => $userIds])
|
|
|
+ ->group('user_id')
|
|
|
+ ->column('group_concat(label_id Separator \',\') as user_label_id', 'user_id');
|
|
|
+
|
|
|
+ $addData = [];
|
|
|
+ foreach ($userIds as $userId) {
|
|
|
+ $userLabelIndex = $userLabelIndexList[$userId]['user_label_id'] ?? '';
|
|
|
+ $userLabelIds = explode(',', $userLabelIndex);
|
|
|
+
|
|
|
+ foreach ($labelIds as $labelId) {
|
|
|
+ //该用户已有该标签，跳过
|
|
|
+ if (in_array($labelId, $userLabelIds)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ $addData[] = [
|
|
|
+ 'user_id' => $userId,
|
|
|
+ 'label_id' => $labelId,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //写入数据
|
|
|
+ if ($addData) {
|
|
|
+
|
|
|
+ (new UserLabelIndex)->saveAll($addData);
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 用户详情
|
|
|
+ * @param int $userId
|
|
|
+ * @return mixed
|
|
|
+ * @throws \think\db\exception\DataNotFoundException
|
|
|
+ * @throws \think\db\exception\DbException
|
|
|
+ * @throws \think\db\exception\ModelNotFoundException
|
|
|
+ * @author cjhao
|
|
|
+ * @date 2021/8/18 15:52
|
|
|
+ */
|
|
|
+ public function detail($mobile)
|
|
|
+ {
|
|
|
+ $user = User::field('id,nickname,avatar,sex,mobile,birthday,level,create_time,user_money,user_earnings,user_money+user_earnings as total_user_money,user_integral,disable,user_delete')
|
|
|
+ ->with('user_level')
|
|
|
+ ->where(['mobile'=>$mobile])->find()->toArray();
|
|
|
+ if($user){
|
|
|
+ $user['user_level_name'] = $user['name'];
|
|
|
+ unset($user['name']);
|
|
|
+ unset($user['rank']);
|
|
|
+ unset($user['discount']);
|
|
|
+ }
|
|
|
+ return $user;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 更新用户信息
|
|
|
+ * @param array $params
|
|
|
+ * @return bool
|
|
|
+ * @author cjhao
|
|
|
+ * @date 2021/8/18 17:21
|
|
|
+ */
|
|
|
+ public function setUserInfo(array $params):bool
|
|
|
+ {
|
|
|
+ User::where(['id'=>$params['user_id']])->update([$params['field']=>$params['value']]);
|
|
|
+ return true;
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 设置用户标签
|
|
|
+ * @param array $params
|
|
|
+ * @return bool
|
|
|
+ * @throws \Exception
|
|
|
+ * @author cjhao
|
|
|
+ * @date 2021/8/19 11:31
|
|
|
+ */
|
|
|
+ public function setUserLabel(array $params):bool {
|
|
|
+ //先删除用户标签，在重新设置用户标签
|
|
|
+ UserLabelIndex::where(['user_id'=>$params['user_id']])->delete();
|
|
|
+ $addData = [];
|
|
|
+ foreach ($params['label_ids'] as $labelId){
|
|
|
+ $addData[] = [
|
|
|
+ 'user_id' => $params['user_id'],
|
|
|
+ 'label_id' => $labelId,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ if($addData){
|
|
|
+ (new UserLabelIndex)->saveAll($addData);
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 调整用户余额
|
|
|
+ * @param array $params
|
|
|
+ * @return string
|
|
|
+ * @author cjhao
|
|
|
+ * @date 2021/9/10 18:15
|
|
|
+ */
|
|
|
+ public function adjustUserWallet(array $params)
|
|
|
+ {
|
|
|
+ Db::startTrans();
|
|
|
+ try {
|
|
|
+ $user = User::find($params['user_id']);
|
|
|
+ switch ($params['type']){
|
|
|
+ case 1:
|
|
|
+ //增加
|
|
|
+ if(1 == $params['action']){
|
|
|
+ //调整可用余额
|
|
|
+ $user->user_money = $user->user_money + $params['num'];
|
|
|
+ $user->save();
|
|
|
+ //记录日志
|
|
|
+ AccountLogLogic::add($user->id, AccountLogEnum::BNW_INC_ADMIN, AccountLogEnum::INC, $params['num'], '', $params['remark'] ?? '');
|
|
|
+
|
|
|
+
|
|
|
+ }else{
|
|
|
+
|
|
|
+ $user->user_money = $user->user_money - $params['num'];
|
|
|
+ $user->save();
|
|
|
+ //记录日志
|
|
|
+ AccountLogLogic::add($user->id, AccountLogEnum::BNW_DEC_ADMIN,AccountLogEnum::DEC, $params['num'], '', $params['remark'] ?? '');
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ case 2:
|
|
|
+ //增加
|
|
|
+ if(1 == $params['action']){
|
|
|
+ //调整可用余额
|
|
|
+ $user->user_earnings = $user->user_earnings + $params['num'];
|
|
|
+ $user->save();
|
|
|
+ //记录日志
|
|
|
+ AccountLogLogic::add($user->id, AccountLogEnum::BW_INC_ADMIN, AccountLogEnum::INC, $params['num'], '', $params['remark'] ?? '');
|
|
|
+
|
|
|
+
|
|
|
+ }else{
|
|
|
+
|
|
|
+ $user->user_earnings = $user->user_earnings - $params['num'];
|
|
|
+ $user->save();
|
|
|
+ //记录日志
|
|
|
+ AccountLogLogic::add($user->id, AccountLogEnum::BW_DEC_ADMIN,AccountLogEnum::DEC, $params['num'], '', $params['remark'] ?? '');
|
|
|
+ }
|
|
|
+
|
|
|
+ break;
|
|
|
+ case 3:
|
|
|
+ //增加
|
|
|
+ if(1 == $params['action']){
|
|
|
+ //调整可用余额
|
|
|
+ $user->user_integral = $user->user_integral + $params['num'];
|
|
|
+ $user->save();
|
|
|
+ //记录日志
|
|
|
+ AccountLogLogic::add($user->id, AccountLogEnum::INTEGRAL_INC_ADMIN, AccountLogEnum::INC, $params['num'], '', $params['remark'] ?? '');
|
|
|
+
|
|
|
+
|
|
|
+ }else{
|
|
|
+
|
|
|
+ $user->user_integral = $user->user_integral - $params['num'];
|
|
|
+ $user->save();
|
|
|
+ //记录日志
|
|
|
+ AccountLogLogic::add($user->id, AccountLogEnum::INTEGRAL_DEC_ADMIN,AccountLogEnum::DEC, $params['num'], '', $params['remark'] ?? '');
|
|
|
+ }
|
|
|
+
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ Db::commit();
|
|
|
+ return true;
|
|
|
+
|
|
|
+ } catch (\Exception $e) {
|
|
|
+ Db::rollback();
|
|
|
+ return $e->getMessage();
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 用户信息
|
|
|
+ * @author Tab
|
|
|
+ * @date 2021/9/13 19:33
|
|
|
+ */
|
|
|
+ public static function info($params)
|
|
|
+ {
|
|
|
+ $info = User::findOrEmpty($params['user_id'])->toArray();
|
|
|
+ if (empty($info)) {
|
|
|
+ $info = '';
|
|
|
+ } else {
|
|
|
+ $info = $info['sn'] . '(' . $info['nickname'] . ')';
|
|
|
+ }
|
|
|
+ $count = User::where('inviter_id', $params['user_id'])->count();
|
|
|
+ return [
|
|
|
+ 'name' => $info,
|
|
|
+ 'count' => $count
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 上级分销商调整信息
|
|
|
+ * @param $params
|
|
|
+ * @return array
|
|
|
+ * @author Tab
|
|
|
+ * @date 2021/9/14 10:50
|
|
|
+ */
|
|
|
+ public static function adjustFirstLeaderInfo($params)
|
|
|
+ {
|
|
|
+ $userField = [
|
|
|
+ 'id',
|
|
|
+ 'sn',
|
|
|
+ 'nickname',
|
|
|
+ 'first_leader'
|
|
|
+ ];
|
|
|
+ $user = User::field($userField)->findOrEmpty($params['user_id'])->toArray();
|
|
|
+ if(empty($user['first_leader'])) {
|
|
|
+ $firstLeader = '系统';
|
|
|
+ } else {
|
|
|
+ $firstLeaderField = [
|
|
|
+ 'id',
|
|
|
+ 'sn',
|
|
|
+ 'nickname',
|
|
|
+ ];
|
|
|
+ $firstLeader = User::field($firstLeaderField)->findOrEmpty($user['first_leader'])->toArray();
|
|
|
+ }
|
|
|
+ return [
|
|
|
+ 'user' => $user,
|
|
|
+ 'first_leader' => $firstLeader
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes
|
|
|
+ * @param $params
|
|
|
+ * @return bool
|
|
|
+ * @author Tab
|
|
|
+ * @date 2021/9/14 11:42
|
|
|
+ */
|
|
|
+ public static function adjustFirstLeader($params)
|
|
|
+ {
|
|
|
+ Db::startTrans();
|
|
|
+ try {
|
|
|
+ switch($params['type']) {
|
|
|
+ // 指定推荐人
|
|
|
+ case 'assign':
|
|
|
+ $formatData = self::assignFirstLeader($params);
|
|
|
+ break;
|
|
|
+ // 设置推荐人为系统,即清空上级
|
|
|
+ case 'system':
|
|
|
+ $formatData = self::clearFirstLeader($params);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ $user = User::findOrEmpty($params['user_id']);
|
|
|
+ // 旧关系链
|
|
|
+ if (!empty($user->ancestor_relation)) {
|
|
|
+ $old_ancestor_relation = $user->id . ',' .$user->ancestor_relation;
|
|
|
+ } else {
|
|
|
+ $old_ancestor_relation = $user->id;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 更新当前用户的分销关系
|
|
|
+ User::where(['id' => $params['user_id']])->update($formatData);
|
|
|
+
|
|
|
+ //更新当前用户下级的分销关系
|
|
|
+ $data = [
|
|
|
+ 'second_leader' => $formatData['first_leader'],
|
|
|
+ 'third_leader' => $formatData['second_leader'],
|
|
|
+ 'update_time' => time(),
|
|
|
+ ];
|
|
|
+ User::where(['first_leader' => $params['user_id']])->update($data);
|
|
|
+
|
|
|
+ //更新当前用户下下级的分销关系
|
|
|
+ $data = [
|
|
|
+ 'third_leader' => $formatData['first_leader'],
|
|
|
+ 'update_time' => time()
|
|
|
+ ];
|
|
|
+ User::where(['second_leader' => $params['user_id']])->update($data);
|
|
|
+
|
|
|
+ //更新当前用户所有后代的关系链
|
|
|
+ $posterityArr = User::field('id,ancestor_relation')
|
|
|
+ ->whereFindInSet('ancestor_relation', $params['user_id'])
|
|
|
+ ->select()
|
|
|
+ ->toArray();
|
|
|
+ $updateData = [];
|
|
|
+ $replace_ancestor_relation = $params['user_id'] . ','. $formatData['ancestor_relation'];
|
|
|
+ foreach($posterityArr as $item) {
|
|
|
+ $replace = substr($item['ancestor_relation'], strpos($item['ancestor_relation'], $params['user_id']));
|
|
|
+ $updateData[] = [
|
|
|
+ 'id' => $item['id'],
|
|
|
+ 'ancestor_relation' => trim(str_replace($old_ancestor_relation, $replace_ancestor_relation, $item['ancestor_relation']), ',')
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ // 批量更新
|
|
|
+ (new User())->saveAll($updateData);
|
|
|
+
|
|
|
+ Db::commit();
|
|
|
+ return true;
|
|
|
+ } catch(\Exception $e) {
|
|
|
+ Db::rollback();
|
|
|
+ self::setError($e->getMessage());
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 指定上级分销商
|
|
|
+ * @param $params
|
|
|
+ * @return array
|
|
|
+ * @throws \think\Exception
|
|
|
+ * @author Tab
|
|
|
+ * @date 2021/9/14 11:44
|
|
|
+ */
|
|
|
+ public static function assignFirstLeader($params)
|
|
|
+ {
|
|
|
+ if (empty($params['first_id'])) {
|
|
|
+ throw new \think\Exception('请选择上级分销商');
|
|
|
+ }
|
|
|
+ if ($params['first_id'] == $params['user_id']) {
|
|
|
+ throw new \think\Exception('上级分销商不可以选择自己');
|
|
|
+ }
|
|
|
+ $firstLeader = User::field(['id', 'first_leader', 'second_leader', 'third_leader', 'ancestor_relation'])
|
|
|
+ ->where('id', $params['first_id'])
|
|
|
+ ->findOrEmpty()
|
|
|
+ ->toArray();
|
|
|
+ if(empty($firstLeader)) {
|
|
|
+ throw new \think\Exception('分销商不存在');
|
|
|
+ }
|
|
|
+ $ancestorRelation =explode(',', $firstLeader['ancestor_relation']);
|
|
|
+ if(!empty($ancestorRelation) && in_array($params['user_id'], $ancestorRelation)) {
|
|
|
+ throw new \think\Exception('不允许填写自己任一下级的邀请码');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 上级
|
|
|
+ $first_leader_id = $firstLeader['id'];
|
|
|
+ // 上上级
|
|
|
+ $second_leader_id = $firstLeader['first_leader'];
|
|
|
+ // 上上上级
|
|
|
+ $third_leader_id = $firstLeader['second_leader'];
|
|
|
+ // 拼接关系链
|
|
|
+ $firstLeader['ancestor_relation'] = $firstLeader['ancestor_relation'] ?: ''; // 清空null值及0
|
|
|
+ $my_ancestor_relation = $first_leader_id. ',' . $firstLeader['ancestor_relation'];
|
|
|
+ // 去除两端逗号
|
|
|
+ $my_ancestor_relation = trim($my_ancestor_relation, ',');
|
|
|
+ $data = [
|
|
|
+ 'first_leader' => $first_leader_id,
|
|
|
+ 'second_leader' => $second_leader_id,
|
|
|
+ 'third_leader' => $third_leader_id,
|
|
|
+ 'ancestor_relation' => $my_ancestor_relation,
|
|
|
+ 'admin_update_leader' => 1,
|
|
|
+ ];
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @notes 清空上级
|
|
|
+ * @param $params
|
|
|
+ * @return array
|
|
|
+ * @author Tab
|
|
|
+ * @date 2021/9/14 11:46
|
|
|
+ */
|
|
|
+ public static function clearFirstLeader($params)
|
|
|
+ {
|
|
|
+ $data = [
|
|
|
+ 'first_leader' => 0,
|
|
|
+ 'second_leader' => 0,
|
|
|
+ 'third_leader' => 0,
|
|
|
+ 'ancestor_relation' => '',
|
|
|
+ 'admin_update_leader' => 1,
|
|
|
+ ];
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+}
|
