NN2020042801/app/admin/controller/MessageController.php-3.18bei

<?php
namespace  app\admin\controller;
use cmf\controller\AdminBaseController;
use think\Db;
use think\Session;

class MessageController extends AdminBaseController{
    public function index(){
        //分类信息
        $param = $this->request->param();
        //分类信息
        $cate_tree=$this->getAccessTreeData();
        $this->assign('cate_tree',json_encode($cate_tree));
        isset($param['cate_id']) or $param['cate_id']=0;
        
        $this->assign('cate_id',$param['cate_id']);
        $username = $_SESSION['think']['name'];
        $userinfo = Db::name('user')->where('user_login',$username)->find();
        $catid = isset($param['catid'])?$param['catid']:0;
        $this->assign("catid",$catid);
        if($userinfo['user_type']== 1){
            $map  = array();
            $query = array();
            if($catid){
            	$query['catid'] = $catid;
            	//如果是一级分类则查找所有的子分类
            	$cateinfo = Db::name('category')->where('id',$catid)->find();
            	if($cateinfo['parent_id']==0){
            		$sonarr = Db::name('category')->where('parent_id',$catid)->select()->toArray();
            		$cate_arr = array();
            		foreach ($sonarr as $kk=>$vv){
            			$cate_arr[] = $vv['id'];
            		}
            		$map[] = ['catid','in',$cate_arr];
            		
            	}else{
            		$map['catid'] = $catid;	
            	}
                
            }
            
            
            $this->assign('qx',1);
            $users = Db::name('user')->where('id','gt',1)->select();
            $this->assign('users',$users);
            //超级管理员
            $lists = Db::name('message')->where($map)->order('id desc')->paginate(20,false,['query'=>$query]);
            $this->assign('lists',$lists);
            
        }else{
            $map  = array();
            if($catid){
                $map['catid'] = $catid;
            }
            //普通用户
            $this->assign('qx',0);
            $userinfo = Db::name('user')->where('user_login',$username)->find();
            $userid = $userinfo['id'];
            //分配的信息id
            $fenpei  = Db::name('user_fp')->where('userid',$userid)->find();
        	// print_r($fenpei);exit;
            if(empty($fenpei)){
                $lists = array();
            }else{
                // $cates = explode(',',$fenpei['cates']);
                $cates = $fenpei['cates'];
                $from = $fenpei['tiaoshu'];
                $map[] = ['create_time','>',$fenpei['from_time']];
                $lists = Db::name('message')->where('catid','in',$cates)->where($map)->order('id desc')->limit(0,$from)->select();
            	// if($from<20){
            	// 	$lists = Db::name('message')->where('catid','in',$cates)->where($map)->order('id desc')->limit(0,$from)->select();
            		
            	// }else{
            	// 	$curinfo = Db::name('message')->where('catid','in',$cates)->where($map)->order('id desc')->limit($from,1)->find();
                
	            //     $curid = $curinfo['id'];
	            //     $lists = Db::name('message')->where('catid','in',$cates)->where($map)->where('id','>',$curid)->order('id desc')->select;	
            	// }
                
            }
            $this->assign('lists',$lists);
        }
        return $this->fetch();
    }
	
	public function add(){
		return $this->fetch();
	}
	
	public function addPost(){
		$param = $this->request->param();
		if($param['jm_id']){
			$info = Db::name('jiameng')->field('title')->where('id',$param['jm_id'])->find();
			if(empty($info)){
				$this->error('品牌id无效');
			}else{
				$param['jm_title'] = $info['title'];
			}
		}
		$param['create_time'] = time();
		$res = Db::name('message')->insert($param);
		if($res){
			$this->success('添加成功');
		}else{
			$this->error('添加失败');
		}
		
	}
	
	
    /**
     * 信息分配给用户
     */
    public function fenpei(){
        $param = $this->request->param();
        if(count($param['msg'])<1){
            $this->error('请选择信息');
        }
        if(count($param['members'])<1){
            $this->error('请选择用户');
        }
        foreach($param['msg'] as $k=>$v){
            foreach($param['members'] as $kk=>$vv){
                $data = array(
                    'msg_id' => $v,
                    'user_id'=> $vv
                );
                
                $yicha = Db::name('message_fp')->where($data)->count();
                if($yicha){

                }else{
                    $data['create_time'] = time();
                    
                    Db::name('message_fp')->insert($data);
                }
                
            }
            
        }
        $this->success('分配成功');
    }

    public function edit(){
        $param = $this->request->param();
        isset($param['id']) or $this->error('需要id');
        $users = Db::name('user')->where('id','gt',1)->select();
        $this->assign('users',$users);
        //已分配的
        $yifen = Db::name('Message_fp')->where('msg_id',$param['id'])->select();
        $yifenarr = array();
        foreach($yifen as $k=>$v){
            $yifenarr[] = $v['user_id'];
        }
        $this->assign('yifenarr',$yifenarr);
        
        $info = Db::name('Message')->where('id',$param['id'])->find();
        $this->assign('info',$info);
        return $this->fetch();
    }

    public function editPost(){
        $param = $this->request->param();
        isset($param['id']) or $this->error('需要id');
        //先删掉
        Db::name('Message_fp')->where('msg_id',$param['id'])->delete();
        foreach($param['members'] as $kk=>$vv){
            $data = array(
                'msg_id' => $param['id'],
                'user_id'=> $vv,
                'create_time' => time()
            );
                
            Db::name('message_fp')->insert($data);
        
            
        }
        $this->success('调整成功');
    }
	public function edit1(){
        $param = $this->request->param();
        isset($param['id']) or $this->error('需要id');
        
        $info = Db::name('Message')->where('id',$param['id'])->find();
        $this->assign('info',$info);
        return $this->fetch();
    }

    public function editCatePost(){
        $param = $this->request->param();
        isset($param['id']) or $this->error('需要id');
        //先删掉
  
        $res = Db::name('message')->update($param);
        $this->success('修改成功');
    }
    public function delete(){
        $param = $this->request->param();
        isset($param['id']) or $this->error('需要id');
        $res = Db::name('Message')->where('id',$param['id'])->delete();
        if($res){
            $this->success('删除成功');
        }else{
            $this->error('删除失败');
        }
    }

     /**
     * 获取树的信息
     */
    public function getAccessTreeData(){
        
        $rs_array=[];

        $list=Db::name('category')->order(["list_order" => "ASC"])->select()->toArray();
        if(!empty($list)){
            foreach($list as $k=>$v){
                $rs_array[$v['id']]=$v;
                $parents=$this->getDeepParent($v);
                foreach($parents as $pv){
                    $rs_array[$pv['id']]=$pv;
                }
            }
        }else{
            $rs_array=$list;
        }
        if(!empty($rs_array)){
            foreach($rs_array as $k=>$v){
                $rs_array[$k]['name']=$v['catname'];
                $rs_array[$k]['iconSkin']='dept';
            }

        }
        return array_values($rs_array);
    }
    /**
     * 父节点数据
     */
    public function getDeepParent($data){
        $temp_array=[];
        $parent_data_info=Db::name('category')->where('id',$data['parent_id'])->find();

        if(empty($parent_data_info)){
            return $temp_array;
        }
        if(!empty($parent_data_info)){
            $temp_array[$parent_data_info['id']]=$parent_data_info;
            $rs_array=$this->getDeepParent($parent_data_info);
        }
        return array_merge($temp_array,$rs_array);
    }


    public function shanghu(){
        $param = $this->request->param();
        $shname = isset($param['shname'])?trim($param['shname']):'';
        $map = array();
        if($shname){
            $map['a.user_login'] = $shname;
        }
        $shanghu_list = Db::name('user')->alias('a')->field('a.user_login,a.id as shid,b.*')->leftJoin('jm_user_fp b','a.id=b.userid')->where('a.user_type',3)->where($map)->paginate(20);
        $this->assign('lists',$shanghu_list);
        //分类信息
        $cates = Db::name('category')->select();
        $cate_arr = array();
        foreach($cates as $k=>$v){
            $cate_arr[$v['id']] = $v['catname'];
        }
        $this->assign('shname',$shname);
        $this->assign('cate_arr',$cate_arr);
        return $this->fetch();
    }
    /**
     * 编辑商户
     */
    public function shanghuEdit(){
        $param = $this->request->param();
        isset($param['userid']) or $this->error('需要id');
        $info = array();
        $info = Db::name('user_fp')->where('userid',$param['userid'])->find();
        $userinfo = Db::name('user')->where('id',$param['userid'])->find();
        if(empty($info)){
            $ypz = 0;
        }else{
            $ypz = 1;
        }
        //分类信息
        $cates = Db::name('category')->where('parent_id','gt',0)->select();
        $this->assign('cates',$cates);
        $this->assign('userinfo',$userinfo);
        $this->assign('ypz',$ypz);
        $this->assign('info',$info);
        return $this->fetch();
    }

    public function shanghuPost(){
        $param = $this->request->param();
        
        isset($param['from_time'])&&$param['from_time']!='' or $this->error('需要开始时间');
        // isset($param['end_time'])&&$param['end_time']!='' or $this->error('需要开始时间');
        isset($param['cates'])&&count($param['cates'])>0 or $this->error('请选择至少一个分类');
        $param['cates'] = implode(",",$param['cates']);
        $param['from_time'] = strtotime($param['from_time']);
        $param['end_time'] = strtotime($param['end_time']);
        if($param['ypz']==1){
            //更新
            unset($param['ypz']);
            $param['update_time'] = time();
            $res = Db::name('user_fp')->where('userid',$param['userid'])->update($param);
        }else{
            //添加
            unset($param['ypz']);
            $param['create_time'] = time();
            $res = Db::name('user_fp')->insert($param);
        }
        if($res){
            $this->success('调整成功');
        }else{
            $this->error('调整失败');
        }
    }
}