cangjin/application/Admin/controller/Account.php

<?php
/**
 * 用户账户管理
 */

namespace app\Admin\controller;
use think\Db;

class Account extends Base
{

    public function __construct()
    {
        parent::__construct();
    }

    /**
    * @param status
    * @param username
    * @param mobile
    * @param nickname
    * @param page
    * @param size
     */
    public function List(){
        $page = isset($this->post['page'])&&$this->post['page']!="" ? intval($this->post['page']) : 1;
        $size = isset($this->post['size'])&&$this->post['size']!="" ? intval($this->post['size']) :10;
        $status = isset($this->post['status'])&&$this->post['status']!=="" ? intval($this->post['status']) :"";
        $where=[];
        if($status!==""){
            $where['status'] = $status;
        }
        $username =  isset($this->post['username'])&&$this->post['username']!=="" ? trim($this->post['username']) :"";
        if($username!=""){
            $where['username'] = ["like","%{$username}%"];
        }
        $nickname =  isset($this->post['nickname'])&&$this->post['nickname']!=="" ? trim($this->post['nickname']) :"";
        if($nickname!=""){
            $where['nickname'] = ["like"=>"%{$nickname}%"];
        }
        $mobile =  isset($this->post['mobile'])&&$this->post['mobile']!=="" ? trim($this->post['mobile']) :"";
        if($mobile!=""){
            $where['mobile'] = ["like"=>"%{$mobile}%"];
        }

        $count= Db::name("account_list")->where($where)->count();
        $total = ceil($count/$size);
        $page = $page>=$total? $total:$page;

        $list = Db::name("account_list")->where($where)->page($page,$size)->order("addtime desc")->select();
        $i=[];
        foreach ($list as $vus ){
            $vi = Db::name('rela_video')->join('fc_video a','a.id=rela_video.video_id','left')->field('a.video_sn,a.video_name,a.video_url,a.video_img')->where(['accountid'=>$vus['id'],'is_del'=>0,])->select();
            if(empty($vi)){
                $vi=[];
            }
            $vus['info']=$vi;
            $i[]=$vus;
        }
        return app_show(0,"获取成功",["list"=>$i,"count"=>$count]);
    }

    /**
     * @param username
     * @param password
     * @param starttime
     * @param expiretime
     * @param nickname
     * @param remark
     * @param video
     */
    public function  Create(){
        $username =  isset($this->post['username'])&&$this->post['username']!=="" ? trim($this->post['username']) :"";
        if($username==""){
           return error_show(1004,"参数username 不能为空");
        }
        if(!checkAccount($username)){
            return error_show(1004,"账户格式不正确");
        }
        $isT= Db::name("account")->where(["is_del"=>0,"username"=>$username])->find();
        if($isT){
            return error_show(1004,"账户名已存在");
        }
        $pasword =  isset($this->post['password'])&&$this->post['password']!=="" ? trim($this->post['password']) :"";
        if($pasword==""){
            return error_show(1004,"参数password 不能为空");
        }
        if(!checkPasswd($pasword)){
            return error_show(1004,"密码格式不正确");
        }
        $starttime = isset($this->post['starttime'])&&$this->post['starttime']!=="" ? $this->post['starttime'] :"";
        if($starttime==""){
            return error_show(1004,"参数starttime 不能为空");
        }
        $expiretime = isset($this->post['expiretime'])&&$this->post['expiretime']!=="" ? $this->post['expiretime'] :"";
        if($expiretime==""){
            return error_show(1004,"参数expiretime 不能为空");
        }
        $nickname =  isset($this->post['nickname'])&&$this->post['nickname']!=="" ? trim($this->post['nickname']) :"";
//        if($nickname==""){
//            return error_show(1004,"参数nickname 不能为空");
//        }
        $mobile =  isset($this->post['mobile'])&&$this->post['mobile']!=="" ? trim($this->post['mobile']) :"";
//        if($mobile==""){
//            return error_show(1004,"参数mobile 不能为空");
//        }
        $remark = isset($this->post['remark'])&&$this->post['remark']!=="" ? trim($this->post['remark']) :"";
        $video =  isset($this->post['video'])&&$this->post['video']!=="" ? trim($this->post['video']) :"";

        Db::startTrans();
        try {
            $salt = makeSalt();
            $pas = sha1($pasword.$salt);
            $data=[
                "username"=>$username,
                "password"=>$pas,
                "pwd"=>$pasword,
                "salt"=>$salt,
                "status"=>0,
                "is_del"=>0,
                "starttime"=>$starttime,
                "expiretime"=>$expiretime,
                "addtime"=>date("Y-m-d H:i:s"),
                "updatetime"=>date("Y-m-d H:i:s")
            ];
            $acccount = Db::name("account")->insert($data,false,true);
            if($acccount>0){
                $user=[
                    "nickname"=>$nickname,
                    "mobile"=>$mobile,
                    "avatar"=>"",
                    "remark"=>$remark,
                    "sex"=>"",
                    "addtime"=>date("Y-m-d H:i:s"),
                    "updatetime"=>date("Y-m-d H:i:s")
                ];
                $info = Db::name("account_info")->insert($user,false,true);
                if($info>0){
                    $rela=["accountid"=>$acccount,"account_info"=>$info];
                    $rela_acc=Db::name("rela_account")->insert($rela);

                   // $rele = [["video_id"=>$video,"accountid"=>$video,"addtime"=>$video]];
                   $l=[];
                    foreach ($video as $value){

                      $temp=["video_id"=>$value,"accountid"=>$acccount,"addtime"=>date("Y-m-d H:i:s")];
                        $l[]=$temp;
                    }

                    $rele_a= Db::name("rela_video")->insertAll($l);
                    if($rele_a==false){
                        Db::rollback();
                        return error_show(1002,"绑定失败");
                    }else{
                        write_log("视频绑定成功",$this->userinfo,"account","add");
                    }
                    if($rela_acc){
                        write_log("账户{$username}新建成功",$this->userinfo,"account","add");
                        Db::commit();
                        return app_show(0,"账户新建成功");
                    }

                }
            }
            Db::rollback();
            return error_show(1005,"账户新建失败");
        }catch (\Exception $e){
            Db::rollback();
            return error_show(1003,$e->getMessage());
        }
    }

    /**@param id 账户id
     * @return \think\response\Json|void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function Read(){
        $id=isset($this->post['id'])&&$this->post["id"]!="" ? intval($this->post['id']):"";
        if($id==""){
            return error_show(1004,"参数id 不能为空");
        }
        $info = Db::name("account_list")->where(["id"=>$id])->find();
        if(empty($info)){
            return error_show(1005,"未找到数据");
        }
        if($info["is_del"]==1){
            return error_show(1005,"账户已被删除");
        }
        $info['status_n'] = $info['status']==0 ? "未激活": $info['status']==1? "已激活":"已失效";
        return app_show(0,"获取成功",$info);
    }

    /**
     * @param id
     * @param username
     * @param password
     * @param starttime
     * @param expiretime
     * @param nickname
     * @param remark
     * @param video
     */
    public function Save(){
        $id=isset($this->post['id'])&&$this->post['id']!=""? intval($this->post['id']) :"";
        if($id==""){
            return error_show(1004,"参数id 不能为空");
        }
        $info= Db::name("account")->where(["is_del"=>0,"id"=>$id])->find();
        if(empty($info)){
            return error_show(1004,"未找到数据");
        }
        $username =  isset($this->post['username'])&&$this->post['username']!=="" ? trim($this->post['username']) :"";
        if($username!=""){
            $isT= Db::name("account")->where(["is_del"=>0,"username"=>$username,"id"=>["<>",$id]])->find();
            if($isT){
                return error_show(1004,"账户名已存在");
            }
            $info['username'] = $username;
        }

        $pasword =  isset($this->post['password'])&&$this->post['password']!=="" ? trim($this->post['password']) :"";
        if($pasword!=""){
           $salt=makeSalt();
           $info['password']=sha1($pasword.$salt);
           $info['pwd']=$pasword;

        }
        $starttime = isset($this->post['starttime'])&&$this->post['starttime']!=="" ? $this->post['starttime'] :"";
        if($starttime!=""){
           $info['starttime'] = $starttime;
        }
        $expiretime = isset($this->post['expiretime'])&&$this->post['expiretime']!=="" ? $this->post['expiretime'] :"";
        if($expiretime!=""){
            $expire = strtotime($expiretime);
            if($expire>time()){
                $info['status'] = $info['activetime']==""? 0:1;
            }else{
                $info['status'] =2;
            }
            $info['expiretime'] = $expiretime;
        }
        $info['updatetime'] = date("Y-m-d H:i:s");
        $rela = Db::name("account_info")->alias("a")->Join("fc_rela_account b","b.account_info=a.id","left")->where(["b.accountid"=>$id])->field("a.*")->find();
        $nickname =  isset($this->post['nickname'])&&$this->post['nickname']!=="" ? trim($this->post['nickname']) :"";
        if($nickname!=""){
            $rela['nickname']=$nickname;
        }
        $mobile =  isset($this->post['mobile'])&&$this->post['mobile']!=="" ? trim($this->post['mobile']) :"";
        if($mobile!=""){
            $rela['mobile']=$mobile;
        }

        $rela['remark'] = isset($this->post['remark'])&&$this->post['remark']!=="" ? trim($this->post['remark']) :"";
        $video =  isset($this->post['video'])&&$this->post['video']!=="" ? $this->post['video'] :"";
        $rela['updatetime'] = date("Y-m-d H:i:s");

        Db::startTrans();
        try {
            $acccount = Db::name("account")->update($info);
            if($acccount){
                $infoacc = Db::name("account_info")->update($rela);
                $del = Db::name('rela_video')->where(["is_del"=>0,"accountid"=>$id])->select();
                    if($del==true){
                        $dl = Db::name('rela_video')->where(["is_del"=>0,"accountid"=>$id])->update(["updatetime"=>date("Y-m-d H:i:s"),"is_del"=>1]);
                    }
              //$relo=["video_id"=>$video,"accountid"=>$video,"addtime"=>date("Y-m-d H:i:s")];
                $k=[];
                foreach ($video as $valu){
                    $temp=["video_id"=>$valu,"accountid"=>$id,"addtime"=>date("Y-m-d H:i:s")];
                    $k[]=$temp;
                }
                $rele_a= Db::name("rela_video")->insertAll($k);
                if($rele_a==false){
                    Db::rollback();
                    return error_show(1002,"绑定失败");
                }else{
                    write_log("视频绑定成功",$this->userinfo,"account","edit");
                }
                if($infoacc){
                        write_log("账户{$username}新建成功",$this->userinfo,"account","edit");
                        Db::commit();
                        return app_show(0,"账户编辑成功");
                }else{
                    Db::rollback();
                    return error_show(1005,"账户编辑失败");
                }
            }
            Db::rollback();
            return error_show(1005,"账户编辑失败");
        }catch (\Exception $e){
            Db::rollback();
            return error_show(1003,$e->getMessage());
        }
    }
}