huahuibao/biz/admin/classes/AdminClass.php

<?php

namespace biz\admin\classes;

use biz\user\classes\UserClass;
use common\components\util;
use common\services\ImageService;
use Yii;
use biz\base\classes\BaseClass;

class AdminClass extends BaseClass
{

    public static $baseFile = '\biz\admin\models\Admin';

    //收益通知人
    public static $noticeAdmin = [
        //国兰
        'wx193341a4a80f6ea3' => ['o4c8Vs54PQh32nkgG8R3m4VuGTvw', 'o4c8VszacQJyrzu651CAu0sCsfPc'],
        //花美灵
        'wx84d95afcb7b594eb' => ['oTFbYvsjwgVwXggwtlM2ESAKwuN8', 'oTFbYvqP6qwdCCkdFB9GYnlzDIUg'],
    ];

    //组合员工基本信息 shish 2019.12.9
    public static function groupAdminBaseInfo($list, $sensitive = true)
    {
        //$roleIdList = array_column($list, 'roleId');
        //$roleInfo = AdminRoleClass::getByIds($roleIdList, null, 'id');
        $prefix = Yii::$app->params['imgHost'];
        foreach ($list as $key => $val) {
            //$roleId = $val['roleId'];
            $roleId = 0;
            //$list[$key]['roleName'] = isset($roleInfo[$roleId]['roleName']) ? $roleInfo[$roleId]['roleName'] : '';
            $list[$key]['roleName'] = '';
            $list[$key]['avatarUrl'] = Yii::$app->params['imgHost'] . '/retail/default-avatar.png';
            $list[$key]['addDate'] = date("Y-m-d H:i", $val['addTime']);
            $list[$key]['lastLoginTime'] = date("Y-m-d H:i", $val['loginTime']);
            //敏感信息
            if ($sensitive) {
                //这里需要输出值secret，否则修改密码那边会有问题
                $list[$key]['openId'] = isset($val['openId']) && !empty($val['openId']) ? 'secret' : '';
                $list[$key]['password'] = isset($val['password']) && !empty($val['password']) ? 'secret' : '';
                $list[$key]['confirmPassword'] = isset($val['confirmPassword']) && !empty($val['confirmPassword']) ? 'secret' : '';
            }
        }
        return $list;
    }

    //获取员工详情 shish 2019.12.9
    public static function getDetail($id)
    {
        $detail = self::getById($id);
        if (empty($detail)) {
            util::fail('没有找到员工信息' . $id . '|');
        }
        $list = self::groupAdminBaseInfo([$detail]);
        return current($list);
    }

    //获取员工详情 shish 2019.12.9
    public static function getAdminById($id)
    {
        $detail = AdminClass::getById($id);
        if (empty($detail)) {
            util::fail('没有找到员工信息');
        }
        $list = self::groupAdminBaseInfo([$detail]);
        return current($list);
    }

    //添加员工 shish 2019.12.9
    public static function addAdmin($data)
    {
        $merchantId = $data['merchantId'];

        //验证角色
        $roleId = $data['roleId'];
        $role = AdminRoleClass::getById($roleId);
        AdminRoleClass::valid($role, $merchantId);

        //验证关联的微信
        $userId = $data['userId'];
        $user = UserClass::getById($userId);
        UserClass::valid($user, $merchantId);

        $relateUserIdList = self::getAdminShopUserId($merchantId);
        if (in_array($userId, $relateUserIdList)) {
            util::fail('您选择的微信已经绑定别的帐号');
        }

        $adminName = $data['adminName'];
        $adminNameList = self::getAdminNameList($merchantId);
        if (in_array($adminName, $adminNameList)) {
            util::fail('名字已被使用');
        }

        $data['password'] = password_hash($data['password'], PASSWORD_BCRYPT);

        $respond = self::add($data);
        return $respond;
    }

    //获取商家的所有员工 shish 2019.12.9
    public static function getAdminList($merchantId)
    {
        return self::getAllByCondition(['merchantId' => $merchantId, 'delStatus' => 0, 'status' => 1], null, '*');
    }

    //获取商家所有员工的名字 shish 2019.12.9
    public static function getAdminNameList($merchantId)
    {
        $list = self::getAdminList($merchantId);
        return !empty($list) ? array_column($list, 'adminName') : [];
    }

    //获取商家所有员工已经关联微信的userId
    public static function getAdminShopUserId($merchantId)
    {
        $list = self::getAdminList($merchantId);
        return !empty($list) ? array_column($list, 'userId') : [];
    }

    //验证权限
    public static function valid($admin, $merchantId)
    {
        if (empty($admin)) {
            util::fail('员工无效');
        }
        if ($admin['merchantId'] != $merchantId) {
            util::fail('您没有权限操作此员工');
        }
    }

    //删除员工，需要考虑权限 shish 2019.12.9
    public static function deleteAdmin($admin, $adminId)
    {
        $id = $admin['id'];
        if ($admin['super'] == 1) {
            util::fail('超级管理员不能删除');
        }
        if ($id == $adminId) {
            util::fail('不能删除自己');
        }
        self::updateById($id, ['delStatus' => 1]);
    }

    //更新员工 shish 2019.12
    public static function updateAdmin($admin, $data)
    {
        $id = $admin['id'];
        //验证角色
        $roleId = $data['roleId'];
        $merchantId = $data['merchantId'];
        if ($roleId != $admin['roleId']) {
            $role = AdminRoleClass::getById($roleId);
            AdminRoleClass::valid($role, $merchantId);
        }

        //验证关联的微信
        $userId = $data['userId'];
        if ($userId != $admin['userId']) {
            $user = UserClass::getById($userId);
            UserClass::valid($user, $merchantId);

            $relateUserIdList = self::getAdminShopUserId($merchantId);
            if (in_array($userId, $relateUserIdList)) {
                util::fail('您选择的微信已经绑定别的帐号');
            }
        }

        //密码留空不修改密码
        if (isset($data['password']) && empty($data['password'])) {
            unset($data['password']);
        } else {
            $data['password'] = password_hash($data['password'], PASSWORD_BCRYPT);
        }

        $adminName = $data['adminName'];
        if ($adminName != $admin['adminName']) {
            $adminNameList = self::getAdminNameList($merchantId);
            if (in_array($adminName, $adminNameList)) {
                util::fail('名字已被使用');
            }
        }
        self::updateById($id, $data);
    }

    //取商家需要收款通知的全部员工 shish 2019.12.24
    public static function getAllNoticeAdmin($merchantId)
    {
        $list = self::getAllByCondition(['merchantId' => $merchantId, 'delStatus' => 0, 'status' => 1, 'remind' => 1], null, '*');
        if (empty($list)) {
            return [];
        }
        //需要收款通知的需要拿到是否关注公众号
        $list = self::groupAdminBaseInfo($list);
        return $list;
    }

    //取商家的全部员工 shish 2019.12.24
    public static function getAllAdmin($merchantId, $notice)
    {
        $list = self::getAllByCondition(['merchantId' => $merchantId, 'delStatus' => 0, 'status' => 1]);
        return $list;
    }

    public static function getByMiniOpenId($miniOpenId)
    {
        return self::getByCondition(['miniOpenId' => $miniOpenId]);
    }

    //创建以及更新用户 shish 2020.2.7
    public static function replaceAdmin($adminInfo, $source)
    {
        $adminInfo = self::switchAdminInfo($adminInfo, $source);
        $userSource = UserClass::$userSourceId;

        switch ($source) {
            case $userSource['mini']['name']:
                $sourceId = $userSource['mini']['id'];
                $miniOpenId = $adminInfo['miniOpenId'];
                $user = self::getByMiniOpenId($miniOpenId);
                break;
            case $userSource['official']['name']:
                $sourceId = $userSource['official']['id'];
                $openId = isset($adminInfo['openId']) ? $adminInfo['openId'] : '';
                $user = [];
                if (!empty($openId)) {
                    $user = self::getByOpenId($openId);
                }
                break;
            default:
                throw new \Exception('未知来源的用户');
        }
        if (empty($user)) {
            $adminInfo['source'] = $sourceId;
            $user = self::generateAdmin($adminInfo);
        } else {
            $user = self::updateAdminInfo($user, $userInfo);
        }
        //存在相同unionid则进行合并
        $unionId = isset($adminInfo['unionId']) ? $adminInfo['unionId'] : '';
        if (!empty($unionId)) {
            $same = self::getSameUnionId($unionId);
            if (count($same) == 2) {
                $delUser = $same[0];
                $retainUser = $same[1];
                $user = self::mergeAdmin($delUser, $retainUser);
            }
        }
        return $user;
    }

    public static function updateAdminInfo($originalUser, $getUserInfo)
    {
        $data = [];
        $adminId = $originalUser['id'];
        //替换掉微信不支持的图片
        $userName = isset($getUserInfo['userName']) ? preg_replace('/[\x{10000}-\x{10FFFF}]/u', '', $getUserInfo['userName']) : '';
        if (!empty($userName)) {
            $data['userName'] = $userName;
        }
        if (isset($getUserInfo['openId']) && !empty($getUserInfo['openId'])) {
            $openId = $getUserInfo['openId'];
            $data['openId'] = $openId;
        }
        if (isset($getUserInfo['miniOpenId']) && !empty($getUserInfo['miniOpenId'])) {
            $data['miniOpenId'] = $getUserInfo['miniOpenId'];
        }
        if (isset($getUserInfo['unionId']) && !empty($getUserInfo['unionId'])) {
            $data['unionId'] = $getUserInfo['unionId'];
        }
        if (isset($getUserInfo['sex'])) {
            $data['sex'] = $getUserInfo['sex'];
        }
        if (isset($getUserInfo['subscribe'])) {
            $data['subscribe'] = $getUserInfo['subscribe'];
        }
        if (isset($getUserInfo['subscribeTime'])) {
            $data['subscribeTime'] = $getUserInfo['subscribeTime'];
        }
        if (isset($getUserInfo['isFull'])) {
            $data['isFull'] = $getUserInfo['isFull'];
        }
        if (isset($getUserInfo['headImgUrl']) && !empty($getUserInfo['headImgUrl'])) {
            $data['isFull'] = 1;
        }
        //更新头像
        $merchantId = 0;
        if (isset($originalUser['avatar']) == false || empty($originalUser['avatar'])) {
            if (isset($getUserInfo['headImgUrl']) && !empty($getUserInfo['headImgUrl'])) {
                $imgUrl = $getUserInfo['headImgUrl'];
                $name = ImageService::generateAvatar($merchantId, $imgUrl);
                if (!empty($name)) {
                    $data['avatar'] = $name;
                }
            }
        }
        self::updateById($adminId, $data);
        $admin = self::getById($adminId);
        return $admin;
    }

    public static function generateAdmin($getAdminInfo)
    {
        $date = date("Y-m-d H:i:s");
        $time = time();
        //替换掉微信名称不支持的图片
        $getAdminInfo['adminName'] = isset($getAdminInfo['userName']) ? preg_replace('/[\x{10000}-\x{10FFFF}]/u', '', $getAdminInfo['userName']) : '';
        $subscribe = isset($getAdminInfo['subscribe']) ? $getAdminInfo['subscribe'] : 0;
        $getAdminInfo['subscribe'] = $subscribe;
        $getAdminInfo['avatar'] = '';
        $getAdminInfo['password'] = '';
        $getAdminInfo['payPassword'] = '';
        $getAdminInfo['mobile'] = isset($getAdminInfo['mobile']) ? $getAdminInfo['mobile'] : '';
        $getAdminInfo['addTime'] = $time;
        $getAdminInfo['source'] = isset($getAdminInfo['source']) ? $getAdminInfo['source'] : 0;
        $getAdminInfo['hasSubscribe'] = 0;
        //生成用户基础信息
        $admin = self::add($getAdminInfo);
        $adminId = $admin['id'];
        if (empty($admin['adminName'])) {
            self::updateById($adminId, ['adminName' => $adminId]);
        }
        return $admin;
    }

    //合并管理员
    public static function mergeAdmin($delAdmin, $retainAdmin)
    {
        $connection = Yii::$app->db;//事务处理
        $transaction = $connection->beginTransaction();
        try {
            $transaction->commit();
        } catch (Exception $e) {
            $transaction->rollBack();
            return [];
        }
    }

    //找出相同unionId的用户
    public static function getSameUnionId($unionId)
    {
        return self::getAllByCondition(['unionId' => $unionId], 'addTime desc', '*');
    }

    public static function getByOpenId($openId)
    {
        return self::getByCondition(['openId' => $openId]);
    }

    //将微信和小程序获取的用户信息转成可以保存的用户信息
    public static function switchAdminInfo($info, $source)
    {
        $openId = '';
        if (isset($info['openid']) && !empty($info['openid'])) {
            $openId = $info['openid'];
            unset($info['openId']);
        }
        if (isset($info['openId']) && !empty($info['openId'])) {
            $openId = $info['openId'];
            unset($info['openId']);
        }
        if (!empty($openId)) {
            $userSource = self::$userSourceId;
            switch ($source) {
                case $userSource['mini']['name']:
                    $info['miniOpenId'] = $openId;
                    break;
                case $userSource['official']['name']:
                    $info['openId'] = $openId;
                    break;
                default:

            }
        }
        if (isset($info['nickname'])) {
            $info['userName'] = $info['nickname'];
        }
        if (isset($info['nickName'])) {
            $info['userName'] = $info['nickName'];
        }
        if (isset($info['unionid'])) {
            $info['unionId'] = $info['unionid'];
        }
        if (isset($info['unionId'])) {
            $info['unionId'] = $info['unionId'];
        }
        if (isset($info['headimgurl'])) {
            $info['headImgUrl'] = $info['headimgurl'];
        }
        if (isset($info['avatarUrl'])) {
            $info['headImgUrl'] = $info['avatarUrl'];
        }
        if (isset($info['subscribe_time'])) {
            $info['subscribeTime'] = $info['subscribe_time'];
        }
        if (isset($info['subscribe'])) {
            $info['subscribe'] = $info['subscribe'];
        }
        return $info;
    }

}