kuake/application/admin/controller/Users.php

<?php

namespace app\admin\controller;

use app\common\controller\Backend;
use comservice\Excel;
use datamodel\AwardRecommend;
use logicmodel\AccountLogic;
use logicmodel\award\Recommend;
use logicmodel\MemberLogic;
use logicmodel\WalletLogic;
use think\Db;

/**
 *
 *
 * @icon fa fa-users
 */
class Users extends Backend
{

    /**
     * Users模型对象
     * @var \app\admin\model\Users
     */
    protected $model = null;

    public function _initialize()
    {
        parent::_initialize();
        $this->model = new \app\admin\model\Users;
        $this->view->assign("statusList", $this->model->getStatusList());
        $this->view->assign("isDelList", $this->model->getIsDelList());
        $this->view->assign("isAuthList", $this->model->getIsAuthList());
    }

    /**
     * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
     * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
     * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
     */
    public function import()
    {
        parent::import();
    }

    /**
     * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
     * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
     * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
     */


    /**
     * 查看
     */
    public function index()
    {
        //当前是否为关联查询
        $this->relationSearch = true;
        //设置过滤方法
        $this->request->filter(['strip_tags', 'trim']);
        if ($this->request->isAjax()) {
            //如果发送的来源是Selectpage，则转发到Selectpage
            if ($this->request->request('keyField')) {
                return $this->selectpage();
            }
            list($where, $sort, $order, $offset, $limit) = $this->buildparams();

            $list = $this->model
                    ->where(['is_del'=>0])
                    ->with(['rank','role'])
                    ->where($where)
                    ->order($sort, $order)
                    ->paginate($limit);

            foreach ($list as $row) {
                $row->visible(['id','member','nick_name','head_image','phone','status','uuid','total_direct','group_person_count','achievement_money','group_achievement_money','parent_member','create_time','remittance_number','remittance_money','draw_money','draw_number','email','account','trx_address','integral','name','card','is_auth','wallet_address']);
                $row->visible(['rank']);
				$row->getRelation('rank')->visible(['name']);
				$row->visible(['role']);
				$row->getRelation('role')->visible(['name']);
            }

            $result = array("total" => $list->total(), "rows" => $list->items());

            return json($result);
        }
        return $this->view->fetch();
    }
    public function add()
{
    if(request()->isPost()){
        $data = input('post.');
        $data = $data['row'];

        $parentInfo = $this->model->where(['is_del'=>0,'phone'=>$data['parent_member']])->find();
        if(empty($parentInfo))  $this->error('推荐人手机号错误');
        $phone = $data['phone'];
        if(empty($phone))$this->error('手机号不能为空');
        $info = $this->model->where(['phone'=>$phone,'is_del'=>0])->find();
        if($info) $this->error('手机号已注册');
        //$account = (new WalletLogic())->newAccount();
        //if($account === false) $this->error('钱包地址创建失败');

        $uuid = uuid();
        $pid = $parentInfo['id'];
        $salt = rand(1111,9999);
        $password = md5(md5($data['password']).$salt);
        $userData['nick_name'] = 'KK'.rand(111111,999999);
        $userData['phone'] = $phone;
        $userData['head_image'] = defaultImage();
        $userData['salt'] = $salt;
        $userData['password'] = $password;
        $userData['uuid'] = $uuid;
        $userData['pid'] = $pid;
        $userData['upid'] = $pid;
        $userData['parent_member'] = $parentInfo['phone'];
        $userData['create_time'] = date('Y-m-d H:i:s');
        //$userData['wallet_address'] = $account['address'];
        //$userData['wallet_private_key'] = $account['private_key'];
        Db::startTrans();
        $user_id = $this->model->insertGetId($userData);
        \datamodel\Users::get($user_id)->addAddress();
        if($user_id > 0) {
            $result =  $this->updateGroup($pid);
            if(!$result){
                Db::rollback();
                $this->error('注册失败');
            }
            Db::commit();
            $this->success('注册成功');
        }
        Db::rollback();
        $this->error('注册失败');
    }
    return $this->fetch();
}
    /**
     * 更新团队信息
     * @param $pid
     * @return bool
     * @throws \think\Exception
     */
    private function updateGroup($pid)
    {

        $field = ['id', 'pid', 'upid'];
        $userData = (new MemberLogic())->listParent($pid, $field, 1, 0);
        $groupArr = array_column($userData, 'id');
        $where['id']  = ['in', $groupArr];
        $result = $this->model->where($where)->setInc('group_person_count',1); //修改团队成员
        $res = $this->model->where(['id' => $pid])->setInc('total_direct', 1);//修改直推人数
        if ($result > 0 && $res > 0) return true;
        return false;
    }

    public function del($ids = "")
    {
        $result = $this->model->where(['id'=>['in',$ids]])->update(['is_del'=>1]);
        if($result) return json(['code'=>1,'msg'=>'删除成功']);
        return json(['code'=>0,'msg'=>'删除失败']);
    }
    public function edit($ids = null)
    {
        if(request()->isPost()){
            $data = input('post.');
            $data = $data['row'];
            if(!empty($data['password'])){
                $salt = rand(1111,9999);
                $password = md5(md5($data['password']).$salt);
                $data['password'] = $password;
                $data['salt'] = $salt;
            }else{
                unset($data['password']);
            }
            if(!empty($data['pay_password'])){
                $salt = rand(1111,9999);
                $pay_password = md5(md5($data['pay_password']).$salt);
                $data['pay_password'] = $pay_password;
                $data['pay_salt'] = $salt;
            }else{
                unset($data['pay_password']);
            }
            $result = $this->model->where(['id'=>$ids])->update($data);
            if($result)  $this->success('修改成功');
            $this->success('修改失败');
        }
        $row = $this->model->find($ids)->toArray();
        $this->assign('row',$row);
        return  $this->fetch();
    }
    /**
     * 资金操作
     * @param $ids
     * @return mixed|\think\response\Json
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function funds($ids){
        if(request()->post()){
            $data = input('post.');
            if(empty($data['currency_id'])) return json(['code'=>0,'msg'=>'请选择要操作币种']);
            if(empty($data['type'])) return json(['code'=>0,'msg'=>'请选择操作类型']);
            if(empty($data['account'])) return json(['code'=>0,'msg'=>'请输入金额']);
            $account = $data['account'];
            if($account <= 0) return json(['code'=>0,'msg'=>'操作金额需大于0']);
            $type = $data['type'];
            $currency_id = $data['currency_id'];
            Db::startTrans();
            if($type == 1){
                $currency_id = $data['currency_id'];
                $bil_type = '后台充值';
                $remark = '后台充值';

                $result =  (new AccountLogic())->addAccount($ids,$currency_id,$account,$bil_type,$remark);
                if($result == false){
                    Db::rollback();
                    return json(['code'=>0,'msg'=>'充值失败']);
                }
            }elseif($type == 2){
                $bil_type = '后台扣费';
                $remark = '后台扣费';
                $result =  (new AccountLogic())->subAccount($ids,$currency_id,$account,$bil_type,$remark);
                if($result == false){
                    Db::rollback();
                    return json(['code'=>0,'msg'=>'账户余额不足']);
                }

            }else{
                return json(['code'=>0,'msg'=>'操作类型错误']);
            }
            $fundsData = ['uid'=>$ids,'currency_id'=>$currency_id,'account'=>$account,'type'=>$type,'create_time'=>date('Y-m-d H:i:s')];
            $result = Db::name('funds')->insertGetId($fundsData);
            if($result > 0) {
                Db::commit();
                return json(['code'=>1,'msg'=>'操作成功']);
            }
            return json(['code'=>0,'msg'=>'操作失败']);
        }

        $currencyData = Db::name('currency')->select();
        $userInfo = $this->model->find($ids);
        $this->assign('userInfo',$userInfo);
        $this->assign('currencyData',$currencyData);
        $this->assign('ids',$ids);
        return $this->fetch();
    }

    public function team($phone=''){
        if(request()->isAjax()){
            if(empty($phone)){
                $data = $this->model->alias('u')
                    ->join('role ro','ro.id = u.role_id')
                    ->where(['u.pid'=>0])
                    ->field(['u.*','ro.name role_name'])
                    ->select();
                return json($data);
            }
            $field = ['pu.*','ro.name role_name'];
            $data =  $this->model->alias('u')
                ->join('users pu','u.id = pu.pid')
                ->join('role ro','ro.id = u.role_id')
                ->where(['u.phone'=>$phone])
                ->field($field)
                ->select();
            return $data;
        }
        return $this->fetch();
    }
    /**
     * 搜索
     * @param string $phone
     * @return \think\response\Json
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function search($phone=''){

        if(empty($phone)){
            $where ['u.pid'] = 0;
        }else{
            $where ['u.phone'] = $phone;
            $where['u.is_del'] = 0;
        }
        $data = $this->model
            ->alias('u')
            ->join('role ro','ro.id = u.role_id')
            ->join('rank r','r.id = u.rank_id')
            ->where($where)
            ->field(['u.*','r.name rank_name','ro.name role_name'])
            ->select();
        return json($data);
    }
    public function goods($ids=''){
        if(request()->isPost()){
            $data = input('post.');
            $price = $data['price'];
            if(empty($price)){
               $price = (new \app\admin\model\Goods())->where(['id'=>$data['goods_id']])->value('price');
            }
            $time = date('Y-m-d H:i:s');
            $send['uid'] = $ids;
            $send['goods_id'] = $data['goods_id'];
            $send['price'] = $price;
            $send['create_time'] = $time;
           $result =  (new \app\admin\model\GoodsSend())->insertGetId($send);
           if(!$result) return json(['code'=>0,'msg'=>'赠送失败']);
           $goods['uid'] = $ids;
           $goods['price'] = $price;
           $goods['goods_id'] = $data['goods_id'];
           $goods['create_time'] = $time;
           $result =  (new \app\admin\model\UsersGoods())->insertGetId($goods);
            if($result) return json(['code'=>1,'msg'=>'赠送成功']);
            return json(['code'=>0,'msg'=>'赠送失败']);
        }
        $this->assign('ids',$ids);
        return $this->fetch();
    }
    public function box($ids=''){
        if(request()->isPost()){
            $data = input('post.');
            $price = $data['price'];
            if(empty($price)){
                $price = (new \app\admin\model\Box())->where(['id'=>$data['box_id']])->value('price');
            }
            $time = date('Y-m-d H:i:s');
            $send['uid'] = $ids;
            $send['box_id'] = $data['box_id'];
            $send['price'] = $price;
            $send['create_time'] = $time;
            $result =  (new \app\admin\model\BoxSend())->insertGetId($send);
            if(!$result) return json(['code'=>0,'msg'=>'赠送失败']);
            $box['uid'] = $ids;
            $box['price'] = $price;
            $box['box_id'] = $data['box_id'];
            $box['create_time'] = $time;
            $result =  (new \app\admin\model\UsersBox())->insertGetId($box);
            if($result) return json(['code'=>1,'msg'=>'赠送成功']);
            return json(['code'=>0,'msg'=>'赠送失败']);
        }
        return $this->fetch();
    }
}