src/CorporateTrainingBundle/Biz/User/Service/Impl/UserServiceImpl.php line 28

Open in your IDE?
  1. <?php
  3. namespace CorporateTrainingBundle\Biz\User\Service\Impl;
  5. use AppBundle\Common\ArrayToolkit;
  6. use Biz\System\Service\SessionService;
  7. use Biz\User\Service\Impl\UserServiceImpl as BaseServiceImpl;
  8. use Biz\User\Service\NotificationService;
  9. use Biz\User\Service\TokenService;
  10. use Codeages\Biz\Framework\Event\Event;
  11. use CorporateTrainingBundle\Biz\Post\Service\PostService;
  12. use CorporateTrainingBundle\Biz\User\Service\UserService;
  13. use CorporateTrainingBundle\Common\Constant\CTConst;
  14. use PostMapPlugin\Biz\Rank\Service\RankService;
  15. use Topxia\Service\Common\ServiceKernel;
  17. class UserServiceImpl extends BaseServiceImpl implements UserService
  18. {
  19.     public function getUserWithOrgScopes($id)
  20.     {
  21.         $user = $this->getUserDao()->get($id);
  22.         if (!($user)) {
  23.             return null;
  24.         }
  26.         $user = UserSerialize::unserialize($user);
  27.         $user['lineOrgIds'] = $this->getUserlineOrgIds($user);
  28.         $user['manageOrgIds'] = $this->getUserManageOrgIds($user);
  29.         $user['manageOrgCodes'] = $this->getUserManageOrgCodes($user);
  31.         return $user;
  32.     }
  34.     public function searchUsers(array $conditions, array $orderBy, $start, $limit, $columns = [])
  35.     {
  36.         if (isset($conditions['nickname'])) {
  37.             $conditions['nickname'] = strtoupper($conditions['nickname']);
  38.         }
  39.         if (empty($conditions['locked']) && empty($conditions['noNeedLocked'])) {
  40.             $conditions['locked'] = 0;
  41.         }
  42.         if (empty($conditions['type'])) {
  43.             $conditions['excludeTypes'] = ['deleted', 'system'];
  44.         }
  45.         if (isset($conditions['type']) && $conditions['type'] === 'all') {
  46.             unset($conditions['type']);
  47.         }
  48.         unset($conditions['noNeedLocked']);
  49.         $users = $this->getUserDao()->searchUsers($conditions, $orderBy, $start, $limit, $columns);
  51.         return UserSerialize::unserializes($users);
  52.     }
  54.     public function findDeletedUsers()
  55.     {
  56.         return $this->getUserDao()->findDeleteUsers();
  57.     }
  59.     public function findDeletedAndLockedUsers()
  60.     {
  61.         return $this->getUserDao()->findDeletedAndLockedUsers();
  62.     }
  64.     public function findDeletedAndLockedUsersByIds($userIds)
  65.     {
  66.         return $this->getUserDao()->findDeletedAndLockedUsersByIds($userIds);
  67.     }
  69.     public function findUsersByNicknames($nicknames)
  70.     {
  71.         return $this->getUserDao()->findByNicknames($nicknames);
  72.     }
  74.     public function findByVerifiedMobiles(array $verifiedMobiles)
  75.     {
  76.         return $this->getUserDao()->findByVerifiedMobiles($verifiedMobiles);
  77.     }
  79.     public function findByEmails(array $emails)
  80.     {
  81.         return $this->getUserDao()->findByEmails($emails);
  82.     }
  84.     public function findByIds(array $ids)
  85.     {
  86.         return $this->getUserDao()->findByIds($ids);
  87.     }
  89.     public function findUserIdsByConditions($conditions)
  90.     {
  91.         if (empty($conditions['locked'])) {
  92.             $conditions['locked'] = 0;
  93.         }
  94.         if (empty($conditions['type'])) {
  95.             $conditions['noType'] = 'deleted';
  96.         }
  98.         if (isset($conditions['userIds']) && count($conditions['userIds']) > 15000) {
  99.             $existIds = $conditions['userIds'];
  100.             unset($conditions['userIds']);
  101.             $userIds = $this->getUserDao()->search($conditions, [], 0, PHP_INT_MAX, ['id']);
  102.             $userIds = array_intersect($existIds, array_column($userIds, 'id'));
  104.             return empty($userIds) ? [-1] : $userIds;
  105.         }
  107.         $userIds = $this->getUserDao()->search($conditions, [], 0, PHP_INT_MAX, ['id']);
  109.         return empty($userIds) ? [-1] : array_column($userIds, 'id');
  110.     }
  112.     public function initPassword($id, $newPassword)
  113.     {
  114.         $connection = $this->getKernel()->getConnection();
  115.         $connection->beginTransaction();
  116.         $user = $this->getUserDao()->get($id);
  117.         try {
  118.             $init = [
  119.                 'pwdInit' => '1',
  120.                 'type' => 'init' == $user['type'] ? 'default' : $user['type'],
  121.             ];
  123.             $this->getAuthService()->changePassword($id, null, $newPassword);
  124.             $this->getUserDao()->update($id, $init);
  126.             $connection->commit();
  127.         } catch (\Exception $e) {
  128.             $connection->rollback();
  129.             throw $e;
  130.         }
  132.         return $this->getUserDao()->update($id, $init);
  133.     }
  135.     public function changePwdInit($id)
  136.     {
  137.         $init = [
  138.             'pwdInit' => '1',
  139.         ];
  141.         return $this->getUserDao()->update($id, $init);
  142.     }
  144.     public function readGuide($id)
  145.     {
  146.         $user = $this->getUser($id);
  148.         if (empty($user)) {
  149.             throw $this->createNotFoundException('User', $id, '用户不存在');
  150.         }
  152.         return $this->getUserDao()->update($id, ['readGuide' => 1]);
  153.     }
  155.     public function changeUserPost($id, $postId)
  156.     {
  157.         $user = $this->getUser($id);
  159.         if (empty($user)) {
  160.             throw $this->createNotFoundException('User', $id, '用户不存在');
  161.         }
  163.         $post = $this->getPostService()->getPost($postId);
  165.         if (empty($post)) {
  166.             throw $this->createNotFoundException('Post', $id, '岗位不存在');
  167.         }
  169.         $updatedUser = $this->getUserDao()->update($id, ['postId' => $postId]);
  170.         $this->getPostMemberService()->becomePostMember($user['id'], $post['id']);
  171.         $this->dispatchEvent('user.change_post', new Event($updatedUser, ['oldUser' => $user]));
  172.         $this->getLogService()->info('user', 'post_change', "修改用户{$user['nickname']}岗位为{$post['name']}成功");
  174.         return $updatedUser;
  175.     }
  177.     public function findUserProfilesByTrueName($truename)
  178.     {
  179.         if (empty($truename)) {
  180.             return null;
  181.         }
  183.         return $this->getProfileDao()->findByTrueName($truename);
  184.     }
  186.     public function statisticsOrgUserNumGroupByOrgId()
  187.     {
  188.         return $this->getUserDao()->statisticsOrgUserNumGroupByOrgId();
  189.     }
  191.     public function statisticsPostUserNumGroupByPostId()
  192.     {
  193.         return $this->getUserDao()->statisticsPostUserNumGroupByPostId();
  194.     }
  196.     public function batchUpdatePost($ids, $postId)
  197.     {
  198.         $ids = explode(',', $ids);
  199.         $connection = $this->getKernel()->getConnection();
  200.         $connection->beginTransaction();
  202.         try {
  203.             foreach ($ids as $id) {
  204.                 $this->changeUserPost($id, $postId);
  205.             }
  206.             $connection->commit();
  207.         } catch (\Exception $e) {
  208.             $connection->rollback();
  209.             throw $e;
  210.         }
  211.     }
  213.     public function countUsersByLockedStatus()
  214.     {
  215.         return [
  216.             'enable' => $this->countUsers(['locked' => 0, 'noType' => 'system']),
  217.             'disable' => $this->countUsers(['locked' => 1]),
  218.         ];
  219.     }
  221.     public function isOverMaxUsersNumber()
  222.     {
  223.         return true;
  224.     }
  226.     public function getMaxUsersNumber()
  227.     {
  228.         return $this->getSettingService()->get('max_users_number', 0);
  229.     }
  231.     public function changeUserOrgs($userId, $orgCodes)
  232.     {
  233.         $user = $this->getUser($userId);
  234.         if (empty($user) || ($user['orgCodes'] == $orgCodes)) {
  235.             return [];
  236.         }
  238.         $orgCodes = $this->filterOrgCodes($orgCodes);
  239.         $orgs = $this->getOrgService()->findOrgsByOrgCodes($orgCodes);
  240.         $existOrgCodes = ArrayToolkit::column($orgs, 'orgCode');
  242.         if (array_diff($orgCodes, $existOrgCodes)) {
  243.             throw $this->createNotFoundException('Org Not Found');
  244.         }
  245.         $this->getKernel()->getConnection()->beginTransaction();
  246.         try {
  247.             $fields = [
  248.                 'orgCodes' => empty($orgCodes) ? [1.] : ArrayToolkit::column($orgs, 'orgCode'),
  249.                 'orgIds' => empty($orgCodes) ? [1] : ArrayToolkit::column($orgs, 'id'),
  250.             ];
  252.             $this->getUserDao()->update($userId, $fields);
  253.             $this->getUserOrgService()->setUserOrgs($userId, $orgs);
  254.             $this->getKernel()->getConnection()->commit();
  255.         } catch (\Exception $e) {
  256.             $this->getKernel()->getConnection()->rollBack();
  257.             throw $e;
  258.         }
  260.         return $user;
  261.     }
  263.     public function getUserBindByTypeAndFromId($type, $fromId)
  264.     {
  265.         return $this->getUserBindDao()->getByTypeAndFromId($this->getUserBindType($type), $fromId);
  266.     }
  268.     public function getUserBindByTypeAndUserId($type, $toId)
  269.     {
  270.         $user = $this->getUserDao()->get($toId);
  272.         if (empty($user)) {
  273.             throw $this->createNotFoundException("User#{$toId} Not Found");
  274.         }
  276.         if (!$this->typeInOAuthClient($type)) {
  277.             throw $this->createInvalidArgumentException('Invalid Type');
  278.         }
  280.         return $this->getUserBindDao()->getByToIdAndType($this->getUserBindType($type), $toId);
  281.     }
  283.     public function bindUser($type, $fromId, $toId, $token)
  284.     {
  285.         $user = $this->getUserDao()->get($toId);
  287.         if (empty($user)) {
  288.             throw $this->createNotFoundException("User#{$toId} Not Found");
  289.         }
  291.         if (!$this->typeInOAuthClient($type)) {
  292.             throw $this->createInvalidArgumentException('Invalid Type');
  293.         }
  295.         if ('weixinweb' == $type || 'weixinmob' == $type) {
  296.             $type = 'weixin';
  297.         }
  299.         if ('dingtalkweb' == $type || 'dingtalkmob' == $type) {
  300.             $type = 'dingtalk';
  301.         }
  302.         if ('feishuweb' == $type || 'feishumob' == $type) {
  303.             $type = 'feishu';
  304.         }
  305.         if ($this->isUserBound($toId, $type)) {
  306.             throw $this->createAccessDeniedException('account already bound');
  307.         }
  309.         $bind = $this->getUserBindDao()->create([
  310.             'type' => $type,
  311.             'fromId' => $fromId,
  312.             'toId' => $toId,
  313.             'token' => empty($token['token']) ? '' : $token['token'],
  314.             'createdTime' => time(),
  315.             'expiredTime' => empty($token['expiredTime']) ? 0 : $token['expiredTime'],
  316.         ]);
  318.         $this->dispatchEvent('user.bind', new Event($bind));
  319.     }
  321.     public function isUserBound($userId, $type)
  322.     {
  323.         $bind = $this->getUserBindDao()->getByToIdAndType($this->getUserBindType($type), $userId);
  325.         return !empty($bind) ? true : false;
  326.     }
  328.     public function batchUpdateOrgs($userIds, $orgCodes)
  329.     {
  330.         $currentUser = $this->getCurrentUser();
  331.         $userIds = $this->filterUserIds($userIds);
  332.         foreach ($userIds as $userId) {
  333.             if ($currentUser['id'] == $userId) {
  334.                 continue;
  335.             }
  337.             $this->changeUserOrgs($userId, $orgCodes);
  338.         }
  339.     }
  341.     public function batchLockUser(array $userIds)
  342.     {
  343.         if (!$this->getCurrentUser()->hasPermission('admin_user_lock')) {
  344.             throw $this->createAccessDeniedException($this->trans('admin.role.no_permission'));
  345.         }
  346.         $currentUser = $this->getCurrentUser();
  347.         $userIds = array_diff($userIds, [$currentUser['id']]);
  348.         if (empty($userIds)) {
  349.             return;
  350.         }
  351.         $users = $this->searchUsers(
  352.             ['userIds' => $userIds, 'locked' => 0],
  353.             [],
  354.             0,
  355.             count($userIds),
  356.             ['id']
  357.         );
  358.         foreach ($users as $user) {
  359.             $this->lockUser($user['id']);
  360.             $this->kickUserLogout($user['id']);
  361.         }
  362.     }
  364.     public function batchDeleteUser($userIds)
  365.     {
  366.         $currentUser = $this->getCurrentUser();
  368.         foreach ($userIds as $userId) {
  369.             if ($currentUser['id'] == $userId) {
  370.                 continue;
  371.             }
  372.             $this->deleteUser($userId);
  373.         }
  374.     }
  376.     public function batchWaveUserNotificationNum(array $userIds)
  377.     {
  378.         if (empty($userIds)) {
  379.             return;
  380.         }
  381.         $this->getUserDao()->wave($userIds, ['newNotificationNum' => 1]);
  382.     }
  384.     public function findUserIdsByNickNameOrTrueName($name)
  385.     {
  386.         $userIdsByNickname = $this->getUserDao()->findUserIds(['nickname' => $name]);
  387.         $userIdsByNickname = ArrayToolkit::column($userIdsByNickname, 'id');
  388.         $userIdsByTruename = $this->getProfileDao()->findUserIds(['truename' => $name]);
  389.         $userIdsByTruename = ArrayToolkit::column($userIdsByTruename, 'id');
  391.         return array_merge($userIdsByNickname, $userIdsByTruename);
  392.     }
  394.     /**
  395.      * 批量设置讲师
  396.      *
  397.      * @param $userIds
  398.      */
  399.     public function batchSetTeachers($userIds)
  400.     {
  401.         if (empty($userIds)) {
  402.             return;
  403.         }
  404.         $users = $this->searchUsers(['userIds' => $userIds], [], 0, count($userIds), ['id', 'roles']);
  405.         $updateUsers = [];
  406.         foreach ($users as $user) {
  407.             if (in_array('ROLE_TEACHER', $user['roles'])) {
  408.                 continue;
  409.             }
  410.             $updateUsers[$user['id']] = ['roles' => array_merge($user['roles'], ['ROLE_TEACHER'])];
  411.         }
  413.         if (empty($updateUsers)) {
  414.             return;
  415.         }
  417.         $this->getUserDao()->batchUpdate(array_keys($updateUsers), $updateUsers, 'id');
  418.         $this->getLogService()->info('user', 'user_batch_set_teacher', '批量设置讲师'.json_encode($userIds));
  419.     }
  421.     /**
  422.      * 批量设置管理范围
  423.      *
  424.      * @param $userIds
  425.      * @param $orgIds
  426.      */
  427.     public function batchSetUserManagePermissions($userIds, $orgIds)
  428.     {
  429.         if (empty($userIds)) {
  430.             return;
  431.         }
  432.         foreach ($userIds as $userId) {
  433.             $manageOrgIds = $this->getManagePermissionService()->findUserManageOrgIdsByUserId($userId);
  434.             if (!$this->getManagePermissionService()->checkOrgManagePermission($orgIds, $manageOrgIds)) {
  435.                 continue;
  436.             }
  437.             $this->getManagePermissionOrgService()->setUserManagePermissionOrgs($userId, $orgIds);
  438.         }
  439.         $this->getLogService()->info('user', 'user_batch_set_permissions', '批量设置管理范围'.json_encode($userIds));
  440.     }
  442.     public function getTotalUserCount(array $conditions)
  443.     {
  444.         $conditions['locked'] = 0;
  445.         $conditions['noType'] = 'system';
  447.         $userCount = $this->countUsers(ArrayToolkit::parts($conditions, ['locked', 'noType']));
  448.         $userIncreaseCount = $this->countUsers(ArrayToolkit::parts($conditions, ['startTime', 'noType']));
  449.         $conditions['locked'] = 1;
  450.         $userIncreaseLockedCount = $this->countUsers(ArrayToolkit::parts($conditions, ['locked', 'updatedTime_GE', 'noType']));
  452.         return $userCount - $userIncreaseCount + $userIncreaseLockedCount;
  453.     }
  455.     protected function kickUserLogout($userId)
  456.     {
  457.         $this->getSessionService()->clearByUserId($userId);
  458.         $tokens = $this->getTokenService()->findTokensByUserIdAndType($userId, 'mobile_login');
  459.         if (!empty($tokens)) {
  460.             foreach ($tokens as $token) {
  461.                 $this->getTokenService()->destoryToken($token['token']);
  462.             }
  463.         }
  464.     }
  466.     protected function filterOrgCodes($orgCodes)
  467.     {
  468.         if (is_array($orgCodes)) {
  469.             return $orgCodes;
  470.         } else {
  471.             return explode('|', $orgCodes);
  472.         }
  473.     }
  475.     protected function filterUserIds($userIds)
  476.     {
  477.         if (is_array($userIds)) {
  478.             return $userIds;
  479.         } else {
  480.             return explode(',', $userIds);
  481.         }
  482.     }
  484.     public function initOrgsRelation()
  485.     {
  486.         $org = $this->getOrgService()->getOrgByOrgCode(CTConst::ROOT_ORG_CODE);
  487.         $users = $this->searchUsers([], [], 0, PHP_INT_MAX);
  488.         if (!empty($users)) {
  489.             foreach ($users as $user) {
  490.                 $this->getUserOrgService()->setUserOrgs($user['id'], [$org]);
  491.             }
  492.         }
  494.         return $this->getUserDao()->initOrgsRelation();
  495.     }
  497.     public function initSystemUsers()
  498.     {
  499.         $users = [
  500.             [
  501.                 'type' => 'system',
  502.                 'roles' => ['ROLE_USER', 'ROLE_SUPER_ADMIN'],
  503.             ],
  504.         ];
  505.         foreach ($users as $user) {
  506.             $existsUser = $this->getUserDao()->getUserByType($user['type']);
  508.             if (!empty($existsUser)) {
  509.                 continue;
  510.             }
  512.             $user['nickname'] = $this->generateNickname($user).'(系统用户)';
  513.             $user['emailVerified'] = 1;
  514.             $user['password'] = $this->getRandomChar();
  515.             $user['email'] = $this->generateEmail($user);
  516.             $user['salt'] = base_convert(sha1(uniqid(mt_rand(), true)), 16, 36);
  517.             $user['password'] = $this->getPasswordEncoder()->encodePassword($user['password'], $user['salt']);
  518.             $user = UserSerialize::unserialize(
  519.                 $this->getUserDao()->create(UserSerialize::serialize($user))
  520.             );
  522.             $profile = [];
  523.             $profile['id'] = $user['id'];
  524.             $this->getProfileDao()->create($profile);
  525.         }
  526.     }
  528.     public function updateUserHireDate($userId, $hireDate)
  529.     {
  530.         return $this->getUserDao()->update($userId, ['hireDate' => $hireDate]);
  531.     }
  533.     public function findFollowersByFromId($fromId)
  534.     {
  535.         return $this->getFriendDao()->findFollowingsByFromId($fromId);
  536.     }
  538.     public function sortPromoteUser($ids)
  539.     {
  540.         if (!empty($ids)) {
  541.             foreach ($ids as $index => $id) {
  542.                 $this->promoteUser($id, $index + 1);
  543.             }
  544.         }
  545.     }
  547.     public function getUserCustomColumns($id)
  548.     {
  549.         $profile = $this->getUserProfile($id);
  550.         $customColumns = $profile['custom_column'];
  551.         $defaultColumns = [
  552.             'onlineCourse',
  553.             'offlineCourse',
  554.             'classroom',
  555.             'postCourse',
  556.             'projectPlan',
  557.             'offlineActivity',
  558.         ];
  560.         return !empty($customColumns) ? $customColumns : $defaultColumns;
  561.     }
  563.     public function updateUserCustomColumns($id, $columns)
  564.     {
  565.         $this->updateUserProfile($id, ['custom_column' => $columns]);
  567.         return $this->getUserCustomColumns($id);
  568.     }
  570.     public function updateUserBind($id, $fields)
  571.     {
  572.         return $this->getUserBindDao()->update($id, $fields);
  573.     }
  575.     public function getDingTalkUsers($userIds)
  576.     {
  577.         return $this->getUserBindDao()->search(['type' => 'dingtalk', 'toIds' => $userIds], [], 0, PHP_INT_MAX);
  578.     }
  580.     public function searchUserBinds($conditions, $orderBys, $start, $limit, $columns = [])
  581.     {
  582.         return $this->getUserBindDao()->search($conditions, $orderBys, $start, $limit, $columns);
  583.     }
  585.     public function countUserBinds($conditions)
  586.     {
  587.         return $this->getUserBindDao()->count($conditions);
  588.     }
  590.     public function batchDeleteUserBinds($conditions)
  591.     {
  592.         try {
  593.             $this->beginTransaction();
  594.             $this->getUserBindDao()->batchDelete($conditions);
  595.             $this->commit();
  596.         } catch (\Exception $e) {
  597.             $this->rollback();
  598.             throw $e;
  599.         }
  601.         return true;
  602.     }
  604.     public function batchSetPostAndManagePermissionsAndRolesAndOrgCodes($userIds, $fields)
  605.     {
  606.         if (empty($userIds)) {
  607.             return;
  608.         }
  609.         $currentUser = $this->getCurrentUser();
  611.         try {
  612.             $this->beginTransaction();
  614.             foreach ($userIds as $userId) {
  615.                 if (in_array('post', $fields['types'], true) && !empty($fields['postId'])) {
  616.                     $this->changeUserPost($userId, $fields['postId']);
  617.                 }
  619.                 if (in_array('roles', $fields['types'], true) && !empty($fields['roles']) && $userId != $currentUser->getId()) {
  620.                     $this->changeUserRolesBatchDedicated($userId, $fields['roles']);
  621.                 }
  623.                 if (in_array('org', $fields['types'], true) && $userId != $currentUser->getId()) {
  624.                     $this->changeUserOrgBatchDedicated($userId, $fields['orgIds']);
  625.                 }
  627.                 if (in_array('orgCode', $fields['types'], true) && $userId != $currentUser->getId()) {
  628.                     $this->changeUserOrgCodeBatchDedicated($userId, $fields['orgCodes']);
  629.                 }
  630.             }
  632.             $this->commit();
  633.         } catch (\Exception $e) {
  634.             $this->rollback();
  635.             throw $e;
  636.         }
  637.     }
  639.     public function findUserFromIdsByType($type, $userIds)
  640.     {
  641.         if (empty($userIds) || $userIds === [-1]) {
  642.             return [];
  643.         }
  645.         $users = $this->getUserBindDao()->search(['type' => $type, 'toIds' => $userIds], [], 0, count($userIds), ['fromId']);
  647.         return ArrayToolkit::column($users, 'fromId');
  648.     }
  650.     public function statisticsDistinctOrgUserNumGroupByOrgId()
  651.     {
  652.         return $this->getUserDao()->statisticsDistinctOrgUserNumGroupByOrgId();
  653.     }
  655.     public function findUserIdsByManageOrgIds($orgIds)
  656.     {
  657.         return $this->getUserOrgService()->findUserIdsByOrgIds($orgIds);
  658.     }
  660.     public function pickIdsByTruenameOrNicknameOrMobile($keyword)
  661.     {
  662.         return ArrayToolkit::uniqueValue(array_merge(
  663.             $this->getUserDao()->pickIdsByLikeNickname($keyword),
  664.             $this->getProfileDao()->pickIdsByLikeTruename($keyword),
  665.             $this->getUserDao()->pickIdsByLikeVerifiedMobile($keyword)
  666.         ));
  667.     }
  669.     public function pickIdsByPostId($postId)
  670.     {
  671.         return $this->getUserDao()->pickIdsByPostId($postId);
  672.     }
  674.     private function changeUserOrgCodeBatchDedicated($userId, $orgCodes)
  675.     {
  676.         if ($this->getCurrentUser()->getId() == $userId) {
  677.             return;
  678.         }
  679.         $orgCodes = explode(',', $orgCodes);
  681.         $this->changeUserOrgs($userId, $orgCodes);
  682.     }
  684.     private function changeUserOrgBatchDedicated($userId, $orgIds)
  685.     {
  686.         $orgIds = explode(',', $orgIds);
  687.         $user = $this->getUser($userId);
  688.         $user['manageOrgIds'] = $this->getManagePermissionService()->findUserManageOrgIdsByUserId($userId);
  690.         if (!$this->getManagePermissionService()->checkOrgManagePermission($orgIds, $user['manageOrgIds'])) {
  691.             throw $this->createAccessDeniedException($this->trans('admin.manage.org_permission_beyond_error'));
  692.         }
  693.         $this->getManagePermissionOrgService()->setUserManagePermissionOrgs($userId, $orgIds);
  694.     }
  696.     private function changeUserRolesBatchDedicated($userId, $roles)
  697.     {
  698.         $currentUser = $this->getCurrentUser();
  699.         $currentUserProfile = $this->getUserProfile($currentUser['id']);
  701.         if (in_array('ROLE_TRAINING_ADMIN', $roles) && !in_array('ROLE_TEACHER', $roles)) {
  702.             $roles[] = 'ROLE_TEACHER';
  703.         }
  705.         $this->changeUserRoles($userId, $roles);
  707.         if (!empty($roles)) {
  708.             $roleSet = $this->getRoleService()->searchRoles([], 'created', 0, 9999);
  709.             $rolesByIndexCode = \AppBundle\Common\ArrayToolkit::index($roleSet, 'code');
  710.             $roleNames = $this->getRoleNames($roles, $rolesByIndexCode);
  712.             $message = [
  713.                 'userId' => $currentUser['id'],
  714.                 'userName' => !empty($currentUserProfile['truename']) ? $currentUserProfile['truename'] : $currentUser['nickname'],
  715.                 'role' => implode(',', $roleNames),
  716.             ];
  718.             $this->getNotifiactionService()->notify($userId, 'role', $message);
  719.         }
  720.     }
  722.     protected function getRoleNames($roles, $roleSet)
  723.     {
  724.         $roleNames = [];
  725.         $roles = array_unique($roles);
  727.         global $kernel;
  729.         $userRoleDict = $kernel->getContainer()->get('codeages_plugin.dict_twig_extension')->getDict('userRole');
  731.         $roleDictCodes = array_keys($userRoleDict);
  733.         foreach ($roles as $role) {
  734.             if (in_array($role, $roleDictCodes)) {
  735.                 $roleNames[] = $userRoleDict[$role];
  736.             } elseif ('ROLE_BACKEND' === $role) {
  737.                 continue;
  738.             } else {
  739.                 $role = $roleSet[$role];
  740.                 $roleNames[] = $role['name'];
  741.             }
  742.         }
  744.         return $roleNames;
  745.     }
  747.     private function getUserBindType($type)
  748.     {
  749.         if ('workwechatweb' == $type || 'workwechatmob' == $type || 'work_wechat' == $type) {
  750.             $type = 'work_wechat';
  751.         }
  753.         if ('weixinweb' == $type || 'weixinmob' == $type || 'weixin' == $type) {
  754.             $type = 'weixin';
  755.         }
  757.         if ('dingtalkweb' == $type || 'dingtalkmob' == $type || 'dingtalk' == $type) {
  758.             $type = 'dingtalk';
  759.         }
  761.         if ('feishuweb' == $type || 'feishumob' == $type || 'feishu' == $type) {
  762.             $type = 'feishu';
  763.         }
  765.         return $type;
  766.     }
  768.     protected function convertOAuthType($type)
  769.     {
  770.         if ('weixinweb' == $type || 'weixinmob' == $type) {
  771.             $type = 'weixin';
  772.         }
  774.         if ('dingtalkweb' == $type || 'dingtalkmob' == $type) {
  775.             $type = 'dingtalk';
  776.         }
  778.         return $type;
  779.     }
  781.     /*
  782.      * 返回用户直属部门及直线向上所有父级部门id
  783.      */
  784.     protected function getUserLineOrgIds($user)
  785.     {
  786.         $orgIds = [];
  787.         foreach ($user['orgCodes'] as $orgCode) {
  788.             $orgIds = array_merge($orgIds, explode('.', substr($orgCode, 0, -1)));
  789.         }
  791.         return array_unique($orgIds);
  792.     }
  794.     /*
  795.      * 返回用户管理范围部门id
  796.      */
  797.     protected function getUserManageOrgIds($user)
  798.     {
  799.         return $this->getManagePermissionService()->findUserManageOrgIdsByUserId($user['id']);
  800.     }
  802.     /*
  803.      * 返回用户管理范围部门code
  804.      */
  805.     protected function getUserManageOrgCodes($user)
  806.     {
  807.         return $this->getManagePermissionService()->findUserManageOrgCodesByUserId($user['id']);
  808.     }
  810.     protected function getManagePermissionService()
  811.     {
  812.         return $this->createService('ManagePermission:ManagePermissionOrgService');
  813.     }
  815.     protected function getAuthService()
  816.     {
  817.         return $this->createService('User:AuthService');
  818.     }
  820.     /**
  821.      * @return PostService
  822.      */
  823.     protected function getPostService()
  824.     {
  825.         return $this->createService('CorporateTrainingBundle:Post:PostService');
  826.     }
  828.     /**
  829.      * @return RankService
  830.      */
  831.     protected function getRankService()
  832.     {
  833.         return $this->createService('PostMapPlugin:Rank:RankService');
  834.     }
  836.     /**
  837.      * @return \CorporateTrainingBundle\Biz\User\Service\UserOrgService
  838.      */
  839.     protected function getUserOrgService()
  840.     {
  841.         return $this->createService('User:UserOrgService');
  842.     }
  844.     protected function getPostMemberService()
  845.     {
  846.         return $this->createService('CorporateTrainingBundle:Post:PostMemberService');
  847.     }
  849.     /**
  850.      * @return SessionService
  851.      */
  852.     protected function getSessionService()
  853.     {
  854.         return $this->createService('System:SessionService');
  855.     }
  857.     /**
  858.      * @return TokenService
  859.      */
  860.     protected function getTokenService()
  861.     {
  862.         return $this->createService('User:TokenService');
  863.     }
  865.     /**
  866.      * @return NotificationService
  867.      */
  868.     protected function getNotifiactionService()
  869.     {
  870.         return $this->createService('User:NotificationService');
  871.     }
  872. }
  874. class UserSerialize
  875. {
  876.     public static function serialize(array $user)
  877.     {
  878.         return $user;
  879.     }
  881.     public static function unserialize(array $user = null)
  882.     {
  883.         if (empty($user)) {
  884.             return;
  885.         }
  887.         $user = self::_userRolesSort($user);
  889.         return $user;
  890.     }
  892.     public static function unserializes(array $users)
  893.     {
  894.         return array_map(
  895.             function ($user) {
  896.                 return UserSerialize::unserialize($user);
  897.             },
  898.             $users
  899.         );
  900.     }
  902.     private static function _userRolesSort($user)
  903.     {
  904.         if (!empty($user['roles'][1]) && 'ROLE_USER' == $user['roles'][1]) {
  905.             $temp = $user['roles'][1];
  906.             $user['roles'][1] = $user['roles'][0];
  907.             $user['roles'][0] = $temp;
  908.         }
  910.         //交换学员角色跟roles数组第0个的位置;
  912.         return $user;
  913.     }
  914. }