useraccount/app/controller/UserCompanyBasic.php

<?php

namespace app\controller;

use app\BaseController;
use app\model\Account;
use app\model\AccountCompany;
use think\Exception;
use think\facade\Db;
use think\facade\Validate;

//【公司账号管理】
class UserCompanyBasic extends BaseController
{

    //列表
    public function getList()
    {
        $post = $this->request->only(['nickname' => '', 'username' => '', 'status' => '', 'page' => 1, 'size' => 10], 'post');
        $condition = [['a.is_del', '=', 0]];

        if ($post['nickname'] != '') $condition[] = ['nickname', 'like', "%{$post['nickname']}%"];
        if ($post['username'] != '') $condition[] = ['username', 'like', "%{$post['username']}%"];
        if ($post['status'] != '') $condition[] = ['a.status', '=', $post['status']];

        $count = Db::name('account')
            ->alias('a')
            ->leftJoin('user b', 'a.id=b.account_id and b.status=1')
            ->where($condition)
            ->count('a.id');

        $list = Db::name('account')
            ->alias('a')
            ->field('a.id,a.username,a.mobile,a.source,a.status,b.nickname,b.sex,b.email,a.addtime,a.updatetime')
            ->leftJoin('user b', 'a.id=b.account_id and b.status=1')
            ->where($condition)
            ->page($post['page'], $post['size'])
//            ->append(['plat', 'company_relaton'])
//            ->withAttr('plat', function ($val, $da) {
//                return Db::name('account_plat')
//                    ->alias('a')
//                    ->leftJoin('platform b', 'a.plat_code=b.plat_code and b.is_del=0 and b.status=1')
//                    ->where(['a.status' => 1, 'a.is_del' => 0, 'a.account_id' => $da['id']])
//                    ->field('a.plat_code,plat_name')
//                    ->select()
//                    ->toArray();
//            })
//            ->withAttr('company_relaton', function ($val, $da) {
//                return Db::name('account_company')
//                    ->where(['account_id' => $da['id'], 'is_del' => 0])
//                    ->field('companyCode,companyName,company_type,is_main,status')
//                    ->select()
//                    ->toArray();
//            })
            ->order('a.addtime desc')
            ->select()
            ->toArray();

        return json_show(0, '获取成功', ['list' => $list, 'count' => $count]);
    }

    //注册
    public function add()
    {
        $post = $this->request->only(['nickname' => '', 'mobile' => '', 'email' => '', 'companyArr' => []], 'post', 'trim');
        $validate = Validate::rule([
            'nickname|真实姓名' => 'require|min:2|max:200',
            'mobile|手机号' => 'require|number|length:11|mobile',
            'email|邮箱' => 'email',
            'companyArr|关联业务公司' => 'require|array|max:100',
        ]);
        if ($validate->check($post) == false) return json_show(1004, $validate->getError());
        Db::startTrans();

        try {

            $uiq = Db::table('sys_account')
                ->field('id')
                ->where(['mobile' => $post['mobile']])
                ->findOrEmpty();
            if ($uiq) throw new Exception('手机号已注册！');

            $date = date('Y-m-d H:i:s');
            $salt = makeSalt();
            $password = sha1('dingding123' . $salt);
            $data = [
                'username' => $post['mobile'],
                'password' => $password,
                'salt' => $salt,
                'mobile' => $post['mobile'],
                'source' => 'paltadd',
                'status' => 1,
                'addtime' => $date,
                'updatetime' => $date
            ];
            $reuslt = Db::table('sys_account')->insertGetId($data);
            if ($reuslt) {
                $data = [
                    'nickname' => $post['nickname'],
                    'mobile' => $post['mobile'],
                    'email' => $post['email'],
                    'portrait' => '',
                    'sex' => 1,
                    'post' => '',
                    'department' => '',
                    'account_id' => $reuslt,
                    'status' => 1,
                    'addtime' => $date,
                    'updatetime' => $date
                ];
                $user = Db::table('sys_user')->insert($data);
                if ($user != false) {
                    if (!empty($post['companyArr'])) {
                        $company_insert = [];
                        $acount = new AccountCompany();

                        foreach ($post['companyArr'] as $company) {
                            $company_insert[] = [
                                'account_id' => $reuslt,
                                'companyCode' => $company['companyCode'],
                                'companyName' => $company['companyName'],
                                'company_type' => $company['company_type'],
                                'is_main' => $company['is_main'],
                                'status' => 1,
                                'is_del' => 0,
                                'addtime' => $date,
                                'updatetime' => $date,
                            ];
                        }
                        $acount->saveAll($company_insert);
                    }
                    Db::commit();
                    return json_show(0, '账户注册成功',['uid'=>$reuslt]);
                }
            } else throw new Exception();

        } catch (Exception $e) {
            Db::rollback();
            return json_show(1002, '账户注册失败,' . $e->getMessage());
        }
    }

    //删除
    public function delete()
    {

        $param = $this->request->only(['ids'], 'post', 'trim');

        $val = Validate::rule([
            'ids' => 'require|array|max:100',
        ]);

        if (!$val->check($param)) return json_show(1004, $val->getError());

        Db::startTrans();

        try {
            Db::name('account')
                ->where(['is_del' => 0])
                ->whereIn('id', $param['ids'])
                ->update([
                    'is_del' => 1,
                    'updatetime' => date('Y-m-d H:i:s')
                ]);

            Db::name('account_company')
                ->where(['is_del' => 0])
                ->whereIn('account_id', $param['ids'])
                ->update([
                    'is_del' => 1,
                    'updatetime' => date('Y-m-d H:i:s')
                ]);

            Db::commit();
            return json_show(0, '删除成功');
        } catch (Exception $exception) {
            Db::rollback();
            return json_show(1005, '删除失败,' . $exception->getMessage());
        }

    }

    //编辑
    public function update()
    {
        $post = $this->request->only(['id', 'nickname', 'mobile', 'email' => '', 'portrait' => '', 'sex' => '',], 'post');
        $validate = Validate::rule([
            'id|主键ID' => 'require|number|gt:0',
            'nickname|名称' => 'require|max:255',
            'mobile|手机号' => 'require|number|length:11|mobile',
            'email|名称' => 'email',
            'sex|性别' => 'number|in:0,1,2',
        ]);
        if ($validate->check($post) == false) return json_show(1004, $validate->getError());
        $account = Db::name('account')
            ->field('id')
            ->where([['id', '=', $post['id']], ['is_del', '=', 0]])
            ->findOrEmpty();
        if (empty($account)) return json_show(1003, '账户不存在');

        $accountinfo = Db::name('user')
            ->field('id')
            ->where([['account_id', '=', $post['id']]])
            ->findOrEmpty();
        if (empty($accountinfo)) return json_show(1003, '账户信息不存在');

        Db::startTrans();
        try {

            Db::name('user')
                ->where($accountinfo)
                ->update([
                    'nickname' => $post['nickname'],
                    'mobile' => $post['mobile'],
                    'email' => $post['email'],
                    'portrait' => $post['portrait'],
                    'sex' => $post['sex'],
                    'updatetime' => date('Y-m-d H:i:s')
                ]);

            Db::name('account')
                ->where('id', $post['id'])
                ->update([
                    'id' => $post['id'],
                    'mobile' => $post['mobile'],
                    'username' => $post['mobile'],
                    'updatetime' => date('Y-m-d H:i:s'),
                ]);

            Db::commit();
            return json_show(0, '信息修改成功');
        } catch (Exception $exception) {
            Db::rollback();
            return json_show(1005, '信息修改失败,' . $exception->getMessage());
        }

    }

    //启禁用
    public function status()
    {
        $post = $this->request->only(['id', 'status'], 'post', 'trim');
        $validate = Validate::rule(['id|主键ID' => 'require|number|gt:0', 'status|状态' => 'require|number|in:0,1']);
        if ($validate->check($post) == false) return json_show(1004, $validate->getError());

        Db::startTrans();

        try {

            $account = Account::where(['id' => $post['id'], 'is_del' => 0])
                ->field('id,status')
                ->findOrEmpty();
            if (empty($account)) throw new Exception('账户不存在');

            if ($account['status'] == $post['status']) throw new Exception('重复操作');

            $message = $post['status'] == 1 ? '启用' : '禁用';

            Db::name('account')
                ->where('status', '<>', $post['status'])
                ->where(['id' => $post['id'], 'is_del' => 0])
                ->save(['status' => $post['status'], 'updatetime' => date('Y-m-d H:i:s')]);

            Db::name('account_company')
                ->where('status', '<>', $post['status'])
                ->where(['account_id' => $post['id'], 'is_del' => 0])
                ->save(['status' => $post['status'], 'updatetime' => date('Y-m-d H:i:s')]);

            Db::commit();
            return json_show(0, "账户{$message}成功");

        } catch (Exception $exception) {
            Db::rollback();
            return json_show(1004, '操作失败,' . $exception->getMessage());
        }
    }

    //详情
    public function info()
    {
        $id = $this->request->post('id/d', 0, 'trim');
        if ($id == 0) return json_show(1003, "参数 id 不能为空");

        $list = Db::name('account')
            ->alias('a')
            ->field('a.id,a.username,a.mobile,a.source,a.status,b.nickname,b.sex,b.email,a.addtime,a.updatetime')
            ->leftJoin('user b', 'a.id=b.account_id')
//            ->append(['plat','company_relaton'])
//            ->withAttr('plat',function($val,$da){
//                return Db::name('account_plat')
//                    ->alias('a')
//                    ->leftJoin('platform b', 'a.plat_code=b.plat_code and b.status=1')
//                    ->where(['a.status' => 1, 'a.is_del' => 0, 'a.account_id' => $da['id']])
//                    ->column('a.plat_code,plat_name');
//            })
//            ->withAttr('company_relaton',function($val,$da){
//                return Db::name('account_company')
//                    ->where(['account_id' => $da['id'], 'is_del' => 0, 'status' => 1])
//                    ->column('companyCode,companyName,company_type,is_main,status');
//            })
            ->where(['a.id' => $id, 'a.is_del' => 0])
            ->findOrEmpty();
        if (empty($list)) return json_show(1004, '未找到用户信息');

//        $list['plat'] = Db::name('account_plat')->alias('a')
//            ->leftJoin('platform b', 'a.plat_code=b.plat_code and b.status=1')
//            ->where(['a.status' => 1, 'a.is_del' => 0, 'a.account_id' => $list['id']])->column('a.plat_code,plat_name');
//        $list['company_relaton'] = Db::name('account_company')->where(['account_id' => $list['id'], 'is_del' => 0, 'status' => 1])
//            ->column('companyCode,companyName,company_type,is_main,status');
        return json_show(0, '获取成功', $list);
    }


}