['o4c8Vs54PQh32nkgG8R3m4VuGTvw', 'o4c8VszacQJyrzu651CAu0sCsfPc'], //花美灵 'wx84d95afcb7b594eb' => ['oTFbYvsjwgVwXggwtlM2ESAKwuN8', 'oTFbYvqP6qwdCCkdFB9GYnlzDIUg'], ]; //组合员工基本信息 shish 2019.12.9 public static function groupAdminBaseInfo($list, $sensitive = true) { $roleIdList = array_column($list, 'roleId'); $userIdList = array_column($list, 'userId'); $adminInfo = UserClass::getByIds($userIdList, null, 'id'); $roleInfo = AdminRoleClass::getByIds($roleIdList, null, 'id'); $prefix = Yii::$app->params['imgHost']; foreach ($list as $key => $val) { $roleId = $val['roleId']; $userId = $val['userId']; $list[$key]['roleName'] = isset($roleInfo[$roleId]['roleName']) ? $roleInfo[$roleId]['roleName'] : ''; $list[$key]['nickName'] = isset($adminInfo[$userId]['userName']) ? $adminInfo[$userId]['userName'] : ''; $list[$key]['avatarUrl'] = isset($adminInfo[$userId]['avatar']) ? $prefix . $adminInfo[$userId]['avatar'] : $prefix . '/none.jpg'; $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']); $list[$key]['openId'] = isset($adminInfo[$userId]['openId']) ? $adminInfo[$userId]['openId'] : ''; $list[$key]['subscribe'] = isset($adminInfo[$userId]['subscribe']) ? $adminInfo[$userId]['subscribe'] : 0; //敏感信息 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::getAdminRelateUserId($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 getAdminRelateUserId($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::getAdminRelateUserId($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); } //存在相同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 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; } }