yunjing_master/app/user/controller/AdminIndexController.php

<?php
// +----------------------------------------------------------------------
// | ThinkCMF [ WE CAN DO IT MORE SIMPLE ]
// +----------------------------------------------------------------------
// | Copyright (c) 2013-2019 http://www.thinkcmf.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: Powerless < wzxaini9@gmail.com>
// +----------------------------------------------------------------------

namespace app\user\controller;

use cmf\controller\AdminBaseController;
use think\facade\Db;
use think\db\Query;

/**
 * Class AdminIndexController
 * @package app\user\controller
 *
 * @adminMenuRoot(
 *     'name'   =>'用户管理',
 *     'action' =>'default',
 *     'parent' =>'',
 *     'display'=> true,
 *     'order'  => 10,
 *     'icon'   =>'group',
 *     'remark' =>'用户管理'
 * )
 *
 * @adminMenuRoot(
 *     'name'   =>'用户组',
 *     'action' =>'default1',
 *     'parent' =>'user/AdminIndex/default',
 *     'display'=> true,
 *     'order'  => 10000,
 *     'icon'   =>'',
 *     'remark' =>'用户组'
 * )
 */
class AdminIndexController extends AdminBaseController{

    /**
     * 后台本站用户列表
     * @adminMenu(
     *     'name'   => '本站用户',
     *     'parent' => 'default1',
     *     'display'=> true,
     *     'hasView'=> true,
     *     'order'  => 10000,
     *     'icon'   => '',
     *     'remark' => '本站用户',
     *     'param'  => ''
     * )
     */
    
    public function index(){

        $content = hook_one('user_admin_index_view');

        if (!empty($content)) {
            return $content;
        }
		
		$data = $this->request->param();
		
		$map=[];
        $map[]=['user_type','=',2];
		
		$user_status=isset($data['user_status']) ? $data['user_status']: '';
        if($user_status!=''){
            $map[]=['user_status','=',$user_status];
        }
		
		$isrecommend=isset($data['isrecommend']) ? $data['isrecommend']: '';
        if($isrecommend!=''){
            $map[]=['isrecommend','=',$isrecommend];
        }
		
		$issuper=isset($data['issuper']) ? $data['issuper']: '';
        if($issuper!=''){
            $map[]=['issuper','=',$issuper];
        }
		
		$uid=isset($data['uid']) ? $data['uid']: '';
        if($uid!=''){
            $map[]=['id','=',$uid];
        }

		
		$start_time=isset($data['start_time']) ? $data['start_time']: '';
        $end_time=isset($data['end_time']) ? $data['end_time']: '';
        
        if($start_time!=""){
           $map[]=['create_time','>=',strtotime($start_time)];
        }

        if($end_time!=""){
           $map[]=['create_time','<=',strtotime($end_time) + 60*60*24];
        }
		
		$keyword=isset($data['keyword']) ? $data['keyword']: '';
        if($keyword!=''){
            $map[]=['user_login|user_nickname|user_email|mobile','like','%'.$keyword.'%'];
        }

	

        $list = Db::name('user')
            ->where($map)
            ->order("create_time DESC")
            ->paginate(20);
		
		//人数
		$nums = Db::name('user')
            ->where($map)
            ->count();

        $list->each(function($v,$k){
            $v['user_login']=m_s($v['user_login']);
            $v['mobile']=m_s($v['mobile']);
            $v['user_email']=m_s($v['user_email']);

            if($v['vip_endtime']>time()){
                $v['vip_endtime_format']=date("Y-m-d",$v['vip_endtime']);
                $v['isvip']=1;
            }else{
                $v['vip_endtime_format']='--';
                $v['isvip']=0;
            }

            $country_list=$this->getCountrys();

            foreach ($country_list as $k1 => $v1) {
                if($v['country_code']==$v1['tel']){
                    $v['country_name']=$v1['name'];
                    break; 
                }
            }

            return $v;
        }); 
			
		
		//分页-->筛选条件参数
		$data = $this->request->param();
		$list->appends($data);
		
		$configpub=getConfigPub();
        // 获取分页显示
        $page = $list->render();
        $this->assign('list', $list);
        $this->assign('page', $page);
        $this->assign('nums', $nums);
        $this->assign('name_coin', $configpub['name_coin']);
        $this->assign('name_votes', $configpub['name_votes']);
        // 渲染模板输出
        return $this->fetch();
    }
	
	
	/*本站用户添加*/
	public function add(){
		$this->assign('country_list', $this->getCountrys());
		// 渲染模板输出
        return $this->fetch();	
		
	}
	
	
	public function add_post(){
		 if ($this->request->isPost()) {
            
            $data = $this->request->param();
			$user= Db::name('user');
			$country_code=$data['country_code'];
			$user_login=$data['user_login'];

            if(!$country_code){
                $this->error(lang("请选择国家/地区"));
            }

            if($user_login == ''){
                $this->error('请输入手机号');
            }else{
                
                if($country_code==86){
                    if(!checkMobile($user_login)){
                        $this->error('请输入正确手机号');
                    }
                }
                
                $check = Db::name('user')
					->where(['user_login'=>$user_login,'country_code'=>$country_code])
					->find();
                if($check){
                    $this->error('该账号已存在');
                }
            }
			
			$user_nickname=$data['user_nickname'];
            if($user_nickname == ''){
                $this->error('请输入昵称');
            }else{
                $check = Db::name('user')
					->where("user_nickname='{$user_nickname}'")
					->find();
                if($check){
                    $this->error('昵称已存在');
                }
            }

			$data['user_type']=2;
			$data['user_pass']=cmf_password($data['user_pass']);
			$data['code']=createCode();
			$avatar=$data['avatar'];
			
			if($avatar==''){
				$data['avatar']= '/default.png'; 
				$data['avatar_thumb']= '/default_thumb.png';
                if($data['bg_img']==''){
                    $data['bg_img']= '/default.png'; 
                }
                
			}else if(strpos($avatar,'http')===0){
				/* 绝对路径 */
				$data['avatar']=  $avatar; 
				$data['avatar_thumb']=  $avatar;
                if($data['bg_img']==''){
                    $data['bg_img']= $avatar; 
                }
			}else if(strpos($avatar,'/')===0){
				/* 本地图片 */
				$data['avatar']=  $avatar;
				$data['avatar_thumb']=  $avatar; 
                if($data['bg_img']==''){
                    $data['bg_img']= $avatar; 
                }
			}

			$data['create_time']=time();

			$data['birthday']='2000-01-01';
			
			if(trim($data['signature'])==""){
				$data['signature']='这家伙很懒，什么都没留下';
			}
			
			$result=$user->insert($data);
			if($result!==false){
				$this->success('添加成功');
			}else{
				$this->error('添加失败');
			}					 


		}			
	}
	
	//编辑
	public function edit(){

        $id   = $this->request->param('id', 0, 'intval');
        
        $data=Db::name('user')
            ->where("id={$id}")
            ->find();

        if(!$data){
            $this->error("信息错误");
        }

        $data['user_login_s']=m_s($data['user_login']);
        
        $this->assign('data', $data);
        $this->assign('country_list', $this->getCountrys());
        return $this->fetch();
    }

    public function editPost()
    {
        if ($this->request->isPost()) {
            $data = $this->request->param();

            $id=$data['id'];

            //获取用户的状态
            $user_status=Db::name("user")->where("id={$data['id']}")->value("user_status");
            $login_type=Db::name("user")->where("id={$data['id']}")->value("login_type");

            if($login_type=='phone'){

                $country_code=$data['country_code'];
                if(!$country_code){
                    $this->error(lang("请选择国家/地区"));
                }

                if($country_code=='86'){
                    if(!checkMobile($data['user_login'])){
                        $this->error("中国大陆手机号应为11位");
                    }
                }   
            }

            /*$user_login=$data['user_login'];
            if($user_login == ''){
                $this->error('请输入手机号');
            }else{
                
                if(!checkMobile($user_login)){
                    $this->error('请输入正确手机号');
                }
                
                $check = Db::name('user')->where("user_login='{$user_login}' and id!={$id}")->find();
                if($check){
                    $this->error('该账号已存在');
                }
            }*/
            unset($data['user_login']);
            
            $user_nickname=$data['user_nickname'];
            if($user_nickname == ''){
                $this->error('请输入昵称');
            }else if($user_status!=3 && strstr($user_nickname, '已注销')!==false){
                $this->error('非注销用户昵称不能包含已注销');
            }
           

            if($data['avatar']==''){
                $this->error('请上传头像/封面');
            }

            if($data['avatar_thumb']==''){
                $this->error('请上传头像缩略图');
            }

            if($data['bg_img']==''){
                $data['bg_img']=$data['avatar'];
            }
            
            $rs = DB::name('user')->update($data);

            if($rs === false){
                $this->error("保存失败！");
            }

            // $key='userinfo_'.$id;
            // delcache($key);
            $this->success("保存成功！");
        }
    }
	
	
	//删除用户
	public function del(){
        
        $id = $this->request->param('id', 0, 'intval');
        
        $rs = DB::name('user')->where("id={$id}")->delete();
        if(!$rs){
            $this->error("删除失败！");
        }
        
        //删除关注列表
        Db::name("user_attention")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除关注消息
        Db::name("user_attention_messages")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除用户认证信息
        Db::name("user_auth")->where("uid='{$id}'")->delete();
        //删除用户拉黑
        Db::name("user_black")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除用户提现账号
        Db::name("user_cash_account")->where("uid='{$id}'")->delete();
        //删除管理员充值用户记录
        Db::name("user_charge_admin")->where("touid='{$id}'")->delete();
        //删除用户直播记录
        Db::name("user_live")->where("uid='{$id}'")->delete();
        //删除用户禁播记录
        Db::name("user_live_ban")->where("uid='{$id}' or superid='{$id}'")->delete();
        //删除直播间踢人列表
        Db::name("user_live_kick")->where("uid='{$id}' or liveuid='{$id}'")->delete();
        //删除直播间举报
        Db::name("user_live_report")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除直播间禁言
        Db::name("user_live_shut")->where("uid='{$id}' or liveuid='{$id}'")->delete();
        //删除直播间管理员
        Db::name("user_livemanager")->where("uid='{$id}' or liveuid='{$id}'")->delete();
        //删除直播记录
        Db::name("user_liverecord")->where("uid='{$id}'")->delete();
        //删除音乐收藏
        Db::name("user_music_collection")->where("uid='{$id}'")->delete();

        //删除用户举报
        Db::name("user_report")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除超管
        Db::name("user_super")->where("uid='{$id}'")->delete();
        //删除用户token
        Db::name("user_token")->where("user_id='{$id}'")->delete();

        $list=Db::name("user_video")->field("id")->where("uid='{$id}'")->select()->toArray();

        foreach ($list as $k => $v) {
            //删除视频喜欢
            Db::name("user_video_like")->where("videoid='{$v['id']}'")->delete();

        }

        //删除用户视频
        Db::name("user_video")->where("uid='{$id}'")->delete();
        //删除视频评论
        Db::name("user_video_comments")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除视频评论@信息
        Db::name("user_video_comments_at_messages")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除视频评论点赞
        Db::name("user_video_comments_like")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除视频评论信息
        Db::name("user_video_comments_messages")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除视频喜欢
        Db::name("user_video_like")->where("uid='{$id}'")->delete();
        //删除视频付费列表
        Db::name("user_video_paylists")->where("uid='{$id}'")->delete();
        //删除视频举报
        Db::name("user_video_report")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除视频观看记录
        Db::name("user_video_view")->where("uid='{$id}'")->delete();
        //删除用户视频观看记录
        Db::name("user_video_watchlists")->where("uid='{$id}'")->delete();
        //删除用户视频观看时间记录
        Db::name("user_video_watchtime")->where("uid='{$id}'")->delete();
        //删除视频观看时长记录
        Db::name("view_reward")->where("uid='{$id}'")->delete();
        //删除邀请记录
        Db::name("agent")->where("uid='{$id}' or one='{$id}'")->delete();
        //删除邀请分成
        Db::name("agent_profit")->where("uid='{$id}' or one='{$id}'")->delete();
        //删除反馈
        Db::name("feedback")->where("uid='{$id}'")->delete();
        //删除点赞信息表
        Db::name("praise_messages")->where("uid='{$id}' or touid='{$id}'")->delete();
        //删除店铺申请
        Db::name("shop_apply")->where("uid='{$id}'")->delete();
        //删除店铺礼物
        Db::name("shop_goods")->where("uid='{$id}'")->delete();
        //删除系统消息
        Db::name("system_push")->where("uid='{$id}'")->delete();
        //删除上热门记录
        Db::name("popular_orders")->where("uid='{$id}' or touid='{$id}'")->delete();

        //删除经营类目
        Db::name("seller_goods_class")->where("uid={$id}")->delete();
        //删除店铺评分
        Db::name("shop_points")->where("shop_uid={$id}")->delete();
        //删除收货地址
        Db::name("shop_address")->where("uid={$id}")->delete();
        //删除商品访问记录
        Db::name("user_goods_visit")->where("uid={$id}")->delete();
        //删除代售商品记录
        Db::name("seller_platform_goods")->where("uid={$id}")->delete();

        //删除用户的redis
        delcache("token_".$id);

        //删除极光IM账号
        //delIMUser($id);

        $this->success("删除成功！",url("user/adminIndex/index"));
    }

    /**
     * 本站用户禁用
     * @adminMenu(
     *     'name'   => '本站用户禁用',
     *     'parent' => 'index',
     *     'display'=> false,
     *     'hasView'=> false,
     *     'order'  => 10000,
     *     'icon'   => '',
     *     'remark' => '本站用户禁用',
     *     'param'  => ''
     * )
     */
    public function ban(){

        $id = input('param.id', 0, 'intval');
        if ($id) {
            $result = Db::name("user")->where(["id" => $id, "user_type" => 2])->update(['user_status'=> 0]);
            if ($result) {
                $this->success("会员禁用成功！");
            } else {
                $this->error('会员禁用失败,会员不存在,或者是管理员！');
            }
        } else {
            $this->error('数据传入失败！');
        }
    }

    /**
     * 本站用户启用
     * @adminMenu(
     *     'name'   => '本站用户启用',
     *     'parent' => 'index',
     *     'display'=> false,
     *     'hasView'=> false,
     *     'order'  => 10000,
     *     'icon'   => '',
     *     'remark' => '本站用户启用',
     *     'param'  => ''
     * )
     */
    public function cancelBan(){

        $id = input('param.id', 0, 'intval');
        if ($id) {
            Db::name("user")->where(["id" => $id, "user_type" => 2])->update(['user_status'=>1]);
            $this->success("会员启用成功！", '');
        } else {
            $this->error('数据传入失败！');
        }
    }


    //设置超管
    public function super(){
       $id = input('param.id', 0, 'intval');
        if ($id) {
            Db::name("user")->where(["id" => $id, "user_type" => 2])->update(['issuper'=>1]);

            $isexist=DB::name("user_super")->where("uid={$id}")->find();
            if(!$isexist){
                DB::name("user_super")->insert(array("uid"=>$id,'addtime'=>time()));    
            }


            $this->success("会员设置超管成功！", '');
        } else {
            $this->error('数据传入失败！');
        }
    }

    //取消超管
    public function cancelsuper(){
        $id = input('param.id', 0, 'intval');
        if ($id) {
            Db::name("user")->where(["id" => $id, "user_type" => 2])->update(['issuper'=>0]);

            DB::name("user_super")->where("uid='{$id}'")->delete();

            $this->success("会员取消超管成功！", '');
        } else {
            $this->error('数据传入失败！');
        }
    }

    //设置vip
    public function setvip(){

        $id   = $this->request->param('id', 0, 'intval');
        
        $data=Db::name('user')
            ->field("id,vip_endtime,user_nickname")
            ->where("id={$id}")
            ->find();
        if(!$data){
            $this->error("信息错误");
        }
        
        $this->assign('data', $data);
        return $this->fetch();
    }

    //vip到期时间保存
    public function setvip_post(){
        $data = $this->request->param();
        $vip_endtime=$data['vip_endtime'];
        if(!$vip_endtime){
            $this->error('请选择vip到期时间');
        }

        $vip_endtime=$vip_endtime." 23:59:59";

        $now=time();
        $vip_endtime_format=strtotime($vip_endtime);
        if($vip_endtime_format<=$now){
            $this->error('vip到期时间不能低于当前时间');
        }

        $id=$data['id'];
        $result=Db::name('user')
            ->where("id={$id}")
            ->update(array("vip_endtime"=>$vip_endtime_format));

        if($result!==false){
            $this->success('vip到期时间设置成功');
        }else{
            $this->error('vip到期时间设置失败');
        }
    }

    public function setrecommend(){
        $data = $this->request->param();
        $id=$data['id'];
        $status=$data['status'];
        if(!$id){
            $this->error('请确定用户');
        }
        $now=time();
        if($status==1){
            $res=Db::name("user")->where("id={$id}")->update(array('isrecommend'=>1,'recommend_time'=>$now));
            if($res){
                Db::name("user_live")->where("uid={$id}")->update(array('isrecommend'=>1,'recommend_time'=>$now));
                $this->success("设置主播推荐成功");
            }else{
                $this->error("设置主播推荐失败");
            }
            
        }else{
            $res=Db::name("user")->where("id={$id}")->update(array('isrecommend'=>0,'recommend_time'=>0));
            if($res){
                $live_info=Db::name("user_live")->where("uid={$id}")->find();
                if($live_info){
                    Db::name("user_live")->where("uid={$id}")->update(array('isrecommend'=>0,'recommend_time'=>$live_info['starttime']));   
                }
                
                $this->success("取消主播推荐成功");
            }else{
                $this->error("取消主播推荐失败");
            }

        }
    }

    public function getCountrys(){
        //读取国家代号
        $key='getCountrys';
        $info=getcaches($key);
        //$info=false;
        if(!$info){

            $country=CMF_ROOT.'data/config/country.json';
            // 从文件中读取数据到PHP变量 
            $json_string = file_get_contents($country); 
             // 用参数true把JSON字符串强制转成PHP数组 
            $data = json_decode($json_string, true);

            $info=$data['country']; //国家
            
            setcaches($key,$info);
        }

        $country_list=[];
        foreach ($info as $k => $v) {
            $arr=$v['lists'];
            foreach ($arr as $k1 => $v1) {
               $country_list[]=$v1;
            }
        }
        
        return $country_list;
    }

}