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

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;
  16. class UserServiceImpl extends BaseServiceImpl implements UserService
  17. {
  18.     public function applyAiCoachProjection($id, array $roles, array $orgs, $postId, $enabled, $syncOrgs = true)
  19.     {
  20.         $user = $this->getUser($id);
  21.         if (empty($user)) {
  22.             throw $this->createNotFoundException('User', $id, '用户不存在');
  23.         }
  25.         $fields = [
  26.             'roles' => array_values(array_unique($roles)),
  27.             'postId' => (int) $postId,
  28.             'locked' => $enabled ? 0 : 1,
  29.             'updatedTime' => time(),
  30.         ];
  31.         if ($syncOrgs) {
  32.             $fields['orgIds'] = ArrayToolkit::column($orgs, 'id');
  33.             $fields['orgCodes'] = ArrayToolkit::column($orgs, 'orgCode');
  34.         }
  35.         $updatedUser = $this->getUserDao()->update($id, $fields);
  36.         if ($syncOrgs) {
  37.             $this->getUserOrgService()->setUserOrgs($id, $orgs);
  38.         }
  39.         $this->getPostMemberService()->deletePostMembersByUserId($id);
  40.         if ($postId > 0) {
  41.             $this->getPostMemberService()->becomePostMember($id, $postId);
  42.         }
  43.         $this->dispatchEvent('user.role.change', new Event($updatedUser, ['oldRoles' => $user['roles']]));
  44.         $this->dispatchEvent('user.change_post', new Event($updatedUser, [
  45.             'oldUser' => $user,
  46.             'source' => 'ai_coach_projection',
  47.         ]));
  49.         return $updatedUser;
  50.     }
  52.     public function getUserWithOrgScopes($id)
  53.     {
  54.         $user = $this->getUserDao()->get($id);
  55.         if (!($user)) {
  56.             return null;
  57.         }
  59.         $user = UserSerialize::unserialize($user);
  60.         $user['lineOrgIds'] = $this->getUserlineOrgIds($user);
  61.         $user['manageOrgIds'] = $this->getUserManageOrgIds($user);
  62.         $user['manageOrgCodes'] = $this->getUserManageOrgCodes($user);
  64.         return $user;
  65.     }
  67.     public function searchUsers(array $conditions, array $orderBy, $start, $limit, $columns = [])
  68.     {
  69.         if (isset($conditions['nickname'])) {
  70.             $conditions['nickname'] = strtoupper($conditions['nickname']);
  71.         }
  72.         if (empty($conditions['locked']) && empty($conditions['noNeedLocked'])) {
  73.             $conditions['locked'] = 0;
  74.         }
  75.         if (empty($conditions['type'])) {
  76.             $conditions['excludeTypes'] = ['deleted', 'system'];
  77.         }
  78.         if (isset($conditions['type']) && 'all' === $conditions['type']) {
  79.             unset($conditions['type']);
  80.         }
  81.         unset($conditions['noNeedLocked']);
  82.         $users = $this->getUserDao()->searchUsers($conditions, $orderBy, $start, $limit, $columns);
  84.         return UserSerialize::unserializes($users);
  85.     }
  87.     public function searchUsersByIds(array $userIds, array $orderBy, $start, $limit, array $columns = [])
  88.     {
  89.         if (empty($userIds)) {
  90.             return [];
  91.         }
  92.         $users = $this->getUserDao()->searchUsers(['userIds' => $userIds], $orderBy, $start, $limit, $columns);
  94.         return UserSerialize::unserializes($users);
  95.     }
  97.     public function findUserIdsByPermission($permission, array $conditions)
  98.     {
  99.         $roleCodes = $this->findRoleCodesWithPermission($permission);
  100.         if (empty($roleCodes)) {
  101.             return [];
  102.         }
  103.         $userIds = [];
  104.         foreach ($roleCodes as $roleCode) {
  105.             $roleConditions = array_merge($conditions, ['roles' => $roleCode]);
  106.             $list = $this->searchUsers($roleConditions, [], 0, PHP_INT_MAX, ['id']);
  107.             $userIds = array_merge($userIds, ArrayToolkit::column($list, 'id'));
  108.         }
  110.         return ArrayToolkit::uniqueValue($userIds);
  111.     }
  113.     private function findRoleCodesWithPermission($permissionCode)
  114.     {
  115.         $roles = $this->getRoleService()->searchRoles([], 'created', 0, PHP_INT_MAX);
  116.         $roleCodes = [];
  117.         foreach ($roles as $role) {
  118.             if (!empty($role['data']) && in_array($permissionCode, $role['data'], true)) {
  119.                 $roleCodes[] = $role['code'];
  120.             }
  121.         }
  123.         return $roleCodes;
  124.     }
  126.     public function findDeletedUsers()
  127.     {
  128.         return $this->getUserDao()->findDeleteUsers();
  129.     }
  131.     public function findDeletedAndLockedUsers()
  132.     {
  133.         return $this->getUserDao()->findDeletedAndLockedUsers();
  134.     }
  136.     public function findDeletedAndLockedUsersByIds($userIds)
  137.     {
  138.         return $this->getUserDao()->findDeletedAndLockedUsersByIds($userIds);
  139.     }
  141.     public function findUsersByNicknames($nicknames)
  142.     {
  143.         return $this->getUserDao()->findByNicknames($nicknames);
  144.     }
  146.     public function findByVerifiedMobiles(array $verifiedMobiles)
  147.     {
  148.         return $this->getUserDao()->findByVerifiedMobiles($verifiedMobiles);
  149.     }
  151.     public function findByEmails(array $emails)
  152.     {
  153.         return $this->getUserDao()->findByEmails($emails);
  154.     }
  156.     public function findByIds(array $ids)
  157.     {
  158.         return $this->getUserDao()->findByIds($ids);
  159.     }
  161.     public function findUserIdsByConditions($conditions)
  162.     {
  163.         // 如果设置了 noNeedLocked，则不强制设置 locked，允许查询全部用户
  164.         if (!isset($conditions['noNeedLocked']) && empty($conditions['locked'])) {
  165.             $conditions['locked'] = 0;
  166.         }
  167.         if (empty($conditions['type'])) {
  168.             $conditions['noType'] = 'deleted';
  169.         }
  171.         if (isset($conditions['userIds']) && count($conditions['userIds']) > 15000) {
  172.             $existIds = $conditions['userIds'];
  173.             unset($conditions['userIds']);
  174.             $userIds = $this->getUserDao()->search($conditions, [], 0, PHP_INT_MAX, ['id']);
  175.             $userIds = array_intersect($existIds, array_column($userIds, 'id'));
  177.             return empty($userIds) ? [-1] : $userIds;
  178.         }
  180.         $userIds = $this->getUserDao()->search($conditions, [], 0, PHP_INT_MAX, ['id']);
  182.         return empty($userIds) ? [-1] : array_column($userIds, 'id');
  183.     }
  185.     public function initPassword($id, $newPassword)
  186.     {
  187.         $connection = $this->getKernel()->getConnection();
  188.         $connection->beginTransaction();
  189.         $user = $this->getUserDao()->get($id);
  190.         try {
  191.             $init = [
  192.                 'pwdInit' => '1',
  193.                 'type' => 'init' == $user['type'] ? 'default' : $user['type'],
  194.             ];
  196.             $this->getAuthService()->changePassword($id, null, $newPassword);
  197.             $this->getUserDao()->update($id, $init);
  198.             $this->changePasswordUpgraded($id);
  200.             $connection->commit();
  201.         } catch (\Exception $e) {
  202.             $connection->rollback();
  203.             throw $e;
  204.         }
  206.         return $this->getUserDao()->update($id, $init);
  207.     }
  209.     public function changePwdInit($id)
  210.     {
  211.         $init = [
  212.             'pwdInit' => '1',
  213.         ];
  215.         return $this->getUserDao()->update($id, $init);
  216.     }
  218.     public function changePasswordUpgraded($id)
  219.     {
  220.         $fields = [
  221.             'passwordUpgraded' => 1,
  222.         ];
  224.         return $this->getUserDao()->update($id, $fields);
  225.     }
  227.     public function readGuide($id)
  228.     {
  229.         $user = $this->getUser($id);
  231.         if (empty($user)) {
  232.             throw $this->createNotFoundException('User', $id, '用户不存在');
  233.         }
  235.         return $this->getUserDao()->update($id, ['readGuide' => 1]);
  236.     }
  238.     public function changeUserPost($id, $postId)
  239.     {
  240.         $user = $this->getUser($id);
  242.         if (empty($user)) {
  243.             throw $this->createNotFoundException('User', $id, '用户不存在');
  244.         }
  246.         $post = $this->getPostService()->getPost($postId);
  248.         if (empty($post)) {
  249.             throw $this->createNotFoundException('Post', $id, '岗位不存在');
  250.         }
  252.         $updatedUser = $this->getUserDao()->update($id, ['postId' => $postId]);
  253.         $this->getPostMemberService()->becomePostMember($user['id'], $post['id']);
  254.         $this->dispatchEvent('user.change_post', new Event($updatedUser, ['oldUser' => $user]));
  255.         $this->getLogService()->info('user', 'post_change', "修改用户{$user['nickname']}岗位为{$post['name']}成功");
  257.         return $updatedUser;
  258.     }
  260.     public function findUserProfilesByTrueName($truename)
  261.     {
  262.         if (empty($truename)) {
  263.             return null;
  264.         }
  266.         return $this->getProfileDao()->findByTrueName($truename);
  267.     }
  269.     public function statisticsOrgUserNumGroupByOrgId()
  270.     {
  271.         return $this->getUserDao()->statisticsOrgUserNumGroupByOrgId();
  272.     }
  274.     public function statisticsPostUserNumGroupByPostId()
  275.     {
  276.         return $this->getUserDao()->statisticsPostUserNumGroupByPostId();
  277.     }
  279.     public function batchUpdatePost($ids, $postId)
  280.     {
  281.         $ids = explode(',', $ids);
  282.         $connection = $this->getKernel()->getConnection();
  283.         $connection->beginTransaction();
  285.         try {
  286.             foreach ($ids as $id) {
  287.                 $this->changeUserPost($id, $postId);
  288.             }
  289.             $connection->commit();
  290.         } catch (\Exception $e) {
  291.             $connection->rollback();
  292.             throw $e;
  293.         }
  294.     }
  296.     public function countUsersByLockedStatus()
  297.     {
  298.         return [
  299.             'enable' => $this->countUsers(['locked' => 0, 'noType' => 'system']),
  300.             'disable' => $this->countUsers(['locked' => 1]),
  301.         ];
  302.     }
  304.     public function isOverMaxUsersNumber()
  305.     {
  306.         return true;
  307.     }
  309.     public function changeUserOrgs($userId, $orgCodes)
  310.     {
  311.         $user = $this->getUser($userId);
  312.         if (empty($user) || ($user['orgCodes'] == $orgCodes)) {
  313.             return [];
  314.         }
  316.         $orgCodes = $this->filterOrgCodes($orgCodes);
  317.         $orgs = $this->getOrgService()->findOrgsByOrgCodes($orgCodes);
  318.         $existOrgCodes = ArrayToolkit::column($orgs, 'orgCode');
  320.         if (array_diff($orgCodes, $existOrgCodes)) {
  321.             throw $this->createNotFoundException('Org Not Found');
  322.         }
  323.         $this->getKernel()->getConnection()->beginTransaction();
  324.         try {
  325.             $fields = [
  326.                 'orgCodes' => empty($orgCodes) ? [1.] : ArrayToolkit::column($orgs, 'orgCode'),
  327.                 'orgIds' => empty($orgCodes) ? [1] : ArrayToolkit::column($orgs, 'id'),
  328.             ];
  330.             $this->getUserDao()->update($userId, $fields);
  331.             $this->getUserOrgService()->setUserOrgs($userId, $orgs);
  332.             $this->getKernel()->getConnection()->commit();
  333.         } catch (\Exception $e) {
  334.             $this->getKernel()->getConnection()->rollBack();
  335.             throw $e;
  336.         }
  338.         return $user;
  339.     }
  341.     public function getUserBindByTypeAndFromId($type, $fromId)
  342.     {
  343.         return $this->getUserBindDao()->getByTypeAndFromId($this->getUserBindType($type), $fromId);
  344.     }
  346.     public function getUserBindByTypeAndUserId($type, $toId)
  347.     {
  348.         $user = $this->getUserDao()->get($toId);
  350.         if (empty($user)) {
  351.             throw $this->createNotFoundException("User#{$toId} Not Found");
  352.         }
  354.         if (!$this->typeInOAuthClient($type)) {
  355.             throw $this->createInvalidArgumentException('Invalid Type');
  356.         }
  358.         return $this->getUserBindDao()->getByToIdAndType($this->getUserBindType($type), $toId);
  359.     }
  361.     public function bindUser($type, $fromId, $toId, $token)
  362.     {
  363.         $user = $this->getUserDao()->get($toId);
  365.         if (empty($user)) {
  366.             throw $this->createNotFoundException("User#{$toId} Not Found");
  367.         }
  369.         if (!$this->typeInOAuthClient($type)) {
  370.             throw $this->createInvalidArgumentException('Invalid Type');
  371.         }
  373.         if ('weixinweb' == $type || 'weixinmob' == $type) {
  374.             $type = 'weixin';
  375.         }
  377.         if ('dingtalkweb' == $type || 'dingtalkmob' == $type) {
  378.             $type = 'dingtalk';
  379.         }
  380.         if ('feishuweb' == $type || 'feishumob' == $type) {
  381.             $type = 'feishu';
  382.         }
  383.         if ($this->isUserBound($toId, $type)) {
  384.             throw $this->createAccessDeniedException('account already bound');
  385.         }
  387.         $bind = $this->getUserBindDao()->create([
  388.             'type' => $type,
  389.             'fromId' => $fromId,
  390.             'toId' => $toId,
  391.             'token' => empty($token['token']) ? '' : $token['token'],
  392.             'createdTime' => time(),
  393.             'expiredTime' => empty($token['expiredTime']) ? 0 : $token['expiredTime'],
  394.         ]);
  396.         $this->dispatchEvent('user.bind', new Event($bind));
  397.     }
  399.     public function isUserBound($userId, $type)
  400.     {
  401.         $bind = $this->getUserBindDao()->getByToIdAndType($this->getUserBindType($type), $userId);
  403.         return !empty($bind) ? true : false;
  404.     }
  406.     public function batchUpdateOrgs($userIds, $orgCodes)
  407.     {
  408.         $currentUser = $this->getCurrentUser();
  409.         $userIds = $this->filterUserIds($userIds);
  410.         foreach ($userIds as $userId) {
  411.             if ($currentUser['id'] == $userId) {
  412.                 continue;
  413.             }
  415.             $this->changeUserOrgs($userId, $orgCodes);
  416.         }
  417.     }
  419.     public function batchLockUser(array $userIds)
  420.     {
  421.         if (!$this->getCurrentUser()->hasPermission('admin_user_lock')) {
  422.             throw $this->createAccessDeniedException($this->trans('admin.role.no_permission'));
  423.         }
  424.         $currentUser = $this->getCurrentUser();
  425.         $userIds = array_diff($userIds, [$currentUser['id']]);
  426.         if (empty($userIds)) {
  427.             return;
  428.         }
  429.         $users = $this->searchUsers(
  430.             ['userIds' => $userIds, 'locked' => 0],
  431.             [],
  432.             0,
  433.             count($userIds),
  434.             ['id']
  435.         );
  436.         foreach ($users as $user) {
  437.             $this->lockUser($user['id']);
  438.             $this->kickUserLogout($user['id']);
  439.         }
  440.     }
  442.     public function batchDeleteUser($userIds)
  443.     {
  444.         $currentUser = $this->getCurrentUser();
  446.         foreach ($userIds as $userId) {
  447.             if ($currentUser['id'] == $userId) {
  448.                 continue;
  449.             }
  450.             $this->deleteUser($userId);
  451.         }
  452.     }
  454.     public function batchWaveUserNotificationNum(array $userIds)
  455.     {
  456.         if (empty($userIds)) {
  457.             return;
  458.         }
  459.         $this->getUserDao()->wave($userIds, ['newNotificationNum' => 1]);
  460.     }
  462.     public function findUserIdsByNickNameOrTrueName($name)
  463.     {
  464.         $userIdsByNickname = $this->getUserDao()->findUserIds(['nickname' => $name]);
  465.         $userIdsByNickname = ArrayToolkit::column($userIdsByNickname, 'id');
  466.         $userIdsByTruename = $this->getProfileDao()->findUserIds(['truename' => $name]);
  467.         $userIdsByTruename = ArrayToolkit::column($userIdsByTruename, 'id');
  469.         return array_merge($userIdsByNickname, $userIdsByTruename);
  470.     }
  472.     /**
  473.      * 批量设置讲师
  474.      *
  475.      * @param $userIds
  476.      */
  477.     public function batchSetTeachers($userIds)
  478.     {
  479.         if (empty($userIds)) {
  480.             return;
  481.         }
  482.         $users = $this->searchUsers(['userIds' => $userIds], [], 0, count($userIds), ['id', 'roles']);
  483.         $updateUsers = [];
  484.         foreach ($users as $user) {
  485.             if (in_array('ROLE_TEACHER', $user['roles'])) {
  486.                 continue;
  487.             }
  488.             $updateUsers[$user['id']] = ['roles' => array_merge($user['roles'], ['ROLE_TEACHER'])];
  489.         }
  491.         if (empty($updateUsers)) {
  492.             return;
  493.         }
  495.         $this->getUserDao()->batchUpdate(array_keys($updateUsers), $updateUsers, 'id');
  496.         $this->getLogService()->info('user', 'user_batch_set_teacher', '批量设置讲师'.json_encode($userIds));
  497.     }
  499.     public function setTeacher($userId)
  500.     {
  501.         $user = $this->getUser($userId);
  502.         if (empty($user)) {
  503.             return false;
  504.         }
  505.         if (!in_array('ROLE_TEACHER', $user['roles'])) {
  506.             $this->changeUserRoles($userId, array_merge($user['roles'], ['ROLE_TEACHER']));
  507.         }
  509.         return true;
  510.     }
  512.     /**
  513.      * 设置导师.
  514.      */
  515.     public function setMentor($userId)
  516.     {
  517.         $user = $this->getUser($userId);
  518.         if (empty($user)) {
  519.             return false;
  520.         }
  521.         if (!in_array('ROLE_MENTOR', $user['roles'])) {
  522.             $this->changeUserRoles($userId, array_merge($user['roles'], ['ROLE_MENTOR']));
  523.         }
  525.         return true;
  526.     }
  528.     /**
  529.      * 批量设置管理范围
  530.      *
  531.      * @param $userIds
  532.      * @param $orgIds
  533.      */
  534.     public function batchSetUserManagePermissions($userIds, $orgIds)
  535.     {
  536.         if (empty($userIds)) {
  537.             return;
  538.         }
  539.         foreach ($userIds as $userId) {
  540.             $manageOrgIds = $this->getManagePermissionService()->findUserManageOrgIdsByUserId($userId);
  541.             if (!$this->getManagePermissionService()->checkOrgManagePermission($orgIds, $manageOrgIds)) {
  542.                 continue;
  543.             }
  544.             $this->getManagePermissionOrgService()->setUserManagePermissionOrgs($userId, $orgIds);
  545.         }
  546.         $this->getLogService()->info('user', 'user_batch_set_permissions', '批量设置管理范围'.json_encode($userIds));
  547.     }
  549.     public function getTotalUserCount(array $conditions)
  550.     {
  551.         $conditions['locked'] = 0;
  552.         $conditions['noType'] = 'system';
  554.         $userCount = $this->countUsers(ArrayToolkit::parts($conditions, ['locked', 'noType']));
  555.         $userIncreaseCount = $this->countUsers(ArrayToolkit::parts($conditions, ['startTime', 'noType']));
  556.         $conditions['locked'] = 1;
  557.         $userIncreaseLockedCount = $this->countUsers(ArrayToolkit::parts($conditions, ['locked', 'updatedTime_GE', 'noType']));
  559.         return $userCount - $userIncreaseCount + $userIncreaseLockedCount;
  560.     }
  562.     protected function kickUserLogout($userId)
  563.     {
  564.         $this->getSessionService()->clearByUserId($userId);
  565.         $tokens = $this->getTokenService()->findTokensByUserIdAndType($userId, 'mobile_login');
  566.         if (!empty($tokens)) {
  567.             foreach ($tokens as $token) {
  568.                 $this->getTokenService()->destoryToken($token['token']);
  569.             }
  570.         }
  571.     }
  573.     protected function filterOrgCodes($orgCodes)
  574.     {
  575.         if (is_array($orgCodes)) {
  576.             return $orgCodes;
  577.         } else {
  578.             return explode('|', $orgCodes);
  579.         }
  580.     }
  582.     protected function filterUserIds($userIds)
  583.     {
  584.         if (is_array($userIds)) {
  585.             return $userIds;
  586.         } else {
  587.             return explode(',', $userIds);
  588.         }
  589.     }
  591.     public function initOrgsRelation()
  592.     {
  593.         $org = $this->getOrgService()->getOrgByOrgCode(CTConst::ROOT_ORG_CODE);
  594.         $users = $this->searchUsers([], [], 0, PHP_INT_MAX);
  595.         if (!empty($users)) {
  596.             foreach ($users as $user) {
  597.                 $this->getUserOrgService()->setUserOrgs($user['id'], [$org]);
  598.             }
  599.         }
  601.         return $this->getUserDao()->initOrgsRelation();
  602.     }
  604.     public function initSystemUsers()
  605.     {
  606.         $users = [
  607.             [
  608.                 'type' => 'system',
  609.                 'roles' => ['ROLE_USER', 'ROLE_SUPER_ADMIN'],
  610.             ],
  611.         ];
  612.         $headquarterOrg = $this->getOrgService()->getHeadquarterOrg();
  613.         foreach ($users as $user) {
  614.             $existsUser = $this->getUserDao()->getUserByType($user['type']);
  616.             if (!empty($existsUser)) {
  617.                 continue;
  618.             }
  620.             $user['nickname'] = $this->generateNickname($user).'(系统用户)';
  621.             $user['emailVerified'] = 1;
  622.             $user['password'] = $this->getRandomChar();
  623.             $user['email'] = $this->generateEmail($user);
  624.             $user['salt'] = base_convert(sha1(uniqid(mt_rand(), true)), 16, 36);
  625.             $user['password'] = $this->getPasswordEncoder()->encodePassword($user['password'], $user['salt']);
  626.             $user = UserSerialize::unserialize(
  627.                 $this->getUserDao()->create(UserSerialize::serialize($user))
  628.             );
  630.             $profile = [];
  631.             $profile['id'] = $user['id'];
  632.             $this->getProfileDao()->create($profile);
  633.             $this->getManagePermissionOrgService()->setUserManagePermissionOrgs($user['id'], [$headquarterOrg['id'] ?? 1]);
  634.         }
  635.     }
  637.     public function updateUserHireDate($userId, $hireDate)
  638.     {
  639.         return $this->getUserDao()->update($userId, ['hireDate' => $hireDate]);
  640.     }
  642.     public function findFollowersByFromId($fromId)
  643.     {
  644.         return $this->getFriendDao()->findFollowingsByFromId($fromId);
  645.     }
  647.     public function sortPromoteUser($ids)
  648.     {
  649.         if (!empty($ids)) {
  650.             foreach ($ids as $index => $id) {
  651.                 $this->promoteUser($id, $index + 1);
  652.             }
  653.         }
  654.     }
  656.     public function getUserCustomColumns($id)
  657.     {
  658.         $profile = $this->getUserProfile($id);
  659.         $customColumns = $profile['custom_column'];
  660.         $defaultColumns = [
  661.             'onlineCourse',
  662.             'offlineCourse',
  663.             'classroom',
  664.             'postCourse',
  665.             'projectPlan',
  666.             'offlineActivity',
  667.         ];
  669.         return !empty($customColumns) ? $customColumns : $defaultColumns;
  670.     }
  672.     public function updateUserCustomColumns($id, $columns)
  673.     {
  674.         $this->updateUserProfile($id, ['custom_column' => $columns]);
  676.         return $this->getUserCustomColumns($id);
  677.     }
  679.     public function updateUserBind($id, $fields)
  680.     {
  681.         return $this->getUserBindDao()->update($id, $fields);
  682.     }
  684.     public function getDingTalkUsers($userIds)
  685.     {
  686.         return $this->getUserBindDao()->search(['type' => 'dingtalk', 'toIds' => $userIds], [], 0, PHP_INT_MAX);
  687.     }
  689.     public function searchUserBinds($conditions, $orderBys, $start, $limit, $columns = [])
  690.     {
  691.         return $this->getUserBindDao()->search($conditions, $orderBys, $start, $limit, $columns);
  692.     }
  694.     public function countUserBinds($conditions)
  695.     {
  696.         return $this->getUserBindDao()->count($conditions);
  697.     }
  699.     public function batchDeleteUserBinds($conditions)
  700.     {
  701.         try {
  702.             $this->beginTransaction();
  703.             $this->getUserBindDao()->batchDelete($conditions);
  704.             $this->commit();
  705.         } catch (\Exception $e) {
  706.             $this->rollback();
  707.             throw $e;
  708.         }
  710.         return true;
  711.     }
  713.     public function batchSetPostAndManagePermissionsAndRolesAndOrgCodes($userIds, $fields)
  714.     {
  715.         if (empty($userIds)) {
  716.             return;
  717.         }
  718.         $currentUser = $this->getCurrentUser();
  720.         try {
  721.             $this->beginTransaction();
  723.             foreach ($userIds as $userId) {
  724.                 if (in_array('post', $fields['types'], true) && !empty($fields['postId'])) {
  725.                     $this->changeUserPost($userId, $fields['postId']);
  726.                 }
  728.                 if (in_array('roles', $fields['types'], true) && !empty($fields['roles']) && $userId != $currentUser->getId()) {
  729.                     $this->changeUserRolesBatchDedicated($userId, $fields['roles']);
  730.                 }
  732.                 if (in_array('org', $fields['types'], true) && $userId != $currentUser->getId()) {
  733.                     $this->changeUserOrgBatchDedicated($userId, $fields['orgIds']);
  734.                 }
  736.                 if (in_array('orgCode', $fields['types'], true) && $userId != $currentUser->getId()) {
  737.                     $this->changeUserOrgCodeBatchDedicated($userId, $fields['orgCodes']);
  738.                 }
  739.             }
  741.             $this->commit();
  742.         } catch (\Exception $e) {
  743.             $this->rollback();
  744.             throw $e;
  745.         }
  746.     }
  748.     public function findUserFromIdsByType($type, $userIds)
  749.     {
  750.         if (empty($userIds) || $userIds === [-1]) {
  751.             return [];
  752.         }
  754.         $users = $this->getUserBindDao()->search(['type' => $type, 'toIds' => $userIds], [], 0, count($userIds), ['fromId']);
  756.         return ArrayToolkit::column($users, 'fromId');
  757.     }
  759.     public function statisticsDistinctOrgUserNumGroupByOrgId()
  760.     {
  761.         return $this->getUserDao()->statisticsDistinctOrgUserNumGroupByOrgId();
  762.     }
  764.     public function findUserIdsByManageOrgIds($orgIds)
  765.     {
  766.         return $this->getUserOrgService()->findUserIdsByOrgIds($orgIds);
  767.     }
  769.     public function pickIdsByTruenameOrNicknameOrMobile($keyword)
  770.     {
  771.         return ArrayToolkit::uniqueValue(array_merge(
  772.             $this->getUserDao()->pickIdsByLikeNickname($keyword),
  773.             $this->getProfileDao()->pickIdsByLikeTruename($keyword),
  774.             $this->getUserDao()->pickIdsByLikeVerifiedMobile($keyword)
  775.         ));
  776.     }
  778.     public function pickIdsByPostId($postId)
  779.     {
  780.         return $this->getUserDao()->pickIdsByPostId($postId);
  781.     }
  783.     private function changeUserOrgCodeBatchDedicated($userId, $orgCodes)
  784.     {
  785.         if ($this->getCurrentUser()->getId() == $userId) {
  786.             return;
  787.         }
  788.         $orgCodes = explode(',', $orgCodes);
  790.         $this->changeUserOrgs($userId, $orgCodes);
  791.     }
  793.     private function changeUserOrgBatchDedicated($userId, $orgIds)
  794.     {
  795.         $orgIds = explode(',', $orgIds);
  796.         $user = $this->getUser($userId);
  797.         $user['manageOrgIds'] = $this->getManagePermissionService()->findUserManageOrgIdsByUserId($userId);
  799.         if (!$this->getManagePermissionService()->checkOrgManagePermission($orgIds, $user['manageOrgIds'])) {
  800.             throw $this->createAccessDeniedException($this->trans('admin.manage.org_permission_beyond_error'));
  801.         }
  802.         $this->getManagePermissionOrgService()->setUserManagePermissionOrgs($userId, $orgIds);
  803.     }
  805.     private function changeUserRolesBatchDedicated($userId, $roles)
  806.     {
  807.         $currentUser = $this->getCurrentUser();
  808.         $currentUserProfile = $this->getUserProfile($currentUser['id']);
  810.         if (in_array('ROLE_TRAINING_ADMIN', $roles) && !in_array('ROLE_TEACHER', $roles)) {
  811.             $roles[] = 'ROLE_TEACHER';
  812.         }
  814.         $this->changeUserRoles($userId, $roles);
  816.         if (!empty($roles)) {
  817.             $roleSet = $this->getRoleService()->searchRoles([], 'created', 0, 9999);
  818.             $rolesByIndexCode = \AppBundle\Common\ArrayToolkit::index($roleSet, 'code');
  819.             $roleNames = $this->getRoleNames($roles, $rolesByIndexCode);
  821.             $message = [
  822.                 'userId' => $currentUser['id'],
  823.                 'userName' => !empty($currentUserProfile['truename']) ? $currentUserProfile['truename'] : $currentUser['nickname'],
  824.                 'role' => implode(',', $roleNames),
  825.             ];
  827.             $this->getNotifiactionService()->notify($userId, 'role', $message);
  828.         }
  829.     }
  831.     protected function getRoleNames($roles, $roleSet)
  832.     {
  833.         $roleNames = [];
  834.         $roles = array_unique($roles);
  836.         global $kernel;
  838.         $userRoleDict = $kernel->getContainer()->get('codeages_plugin.dict_twig_extension')->getDict('userRole');
  840.         $roleDictCodes = array_keys($userRoleDict);
  842.         foreach ($roles as $role) {
  843.             if (in_array($role, $roleDictCodes)) {
  844.                 $roleNames[] = $userRoleDict[$role];
  845.             } elseif ('ROLE_BACKEND' === $role) {
  846.                 continue;
  847.             } else {
  848.                 $role = $roleSet[$role];
  849.                 $roleNames[] = $role['name'];
  850.             }
  851.         }
  853.         return $roleNames;
  854.     }
  856.     private function getUserBindType($type)
  857.     {
  858.         if ('workwechatweb' == $type || 'workwechatmob' == $type || 'work_wechat' == $type) {
  859.             $type = 'work_wechat';
  860.         }
  862.         if ('weixinweb' == $type || 'weixinmob' == $type || 'weixin' == $type) {
  863.             $type = 'weixin';
  864.         }
  866.         if ('dingtalkweb' == $type || 'dingtalkmob' == $type || 'dingtalk' == $type) {
  867.             $type = 'dingtalk';
  868.         }
  870.         if ('feishuweb' == $type || 'feishumob' == $type || 'feishu' == $type) {
  871.             $type = 'feishu';
  872.         }
  874.         return $type;
  875.     }
  877.     protected function convertOAuthType($type)
  878.     {
  879.         if ('weixinweb' == $type || 'weixinmob' == $type) {
  880.             $type = 'weixin';
  881.         }
  883.         if ('dingtalkweb' == $type || 'dingtalkmob' == $type) {
  884.             $type = 'dingtalk';
  885.         }
  887.         return $type;
  888.     }
  890.     /*
  891.      * 返回用户直属部门及直线向上所有父级部门id
  892.      */
  893.     protected function getUserLineOrgIds($user)
  894.     {
  895.         $orgIds = [];
  896.         foreach ($user['orgCodes'] as $orgCode) {
  897.             $orgIds = array_merge($orgIds, explode('.', substr($orgCode, 0, -1)));
  898.         }
  900.         return array_unique($orgIds);
  901.     }
  903.     /*
  904.      * 返回用户管理范围部门id
  905.      */
  906.     protected function getUserManageOrgIds($user)
  907.     {
  908.         return $this->getManagePermissionService()->findUserManageOrgIdsByUserId($user['id']);
  909.     }
  911.     /*
  912.      * 返回用户管理范围部门code
  913.      */
  914.     protected function getUserManageOrgCodes($user)
  915.     {
  916.         return $this->getManagePermissionService()->findUserManageOrgCodesByUserId($user['id']);
  917.     }
  919.     protected function getManagePermissionService()
  920.     {
  921.         return $this->createService('ManagePermission:ManagePermissionOrgService');
  922.     }
  924.     protected function getAuthService()
  925.     {
  926.         return $this->createService('User:AuthService');
  927.     }
  929.     /**
  930.      * @return PostService
  931.      */
  932.     protected function getPostService()
  933.     {
  934.         return $this->createService('CorporateTrainingBundle:Post:PostService');
  935.     }
  937.     /**
  938.      * @return RankService
  939.      */
  940.     protected function getRankService()
  941.     {
  942.         return $this->createService('PostMapPlugin:Rank:RankService');
  943.     }
  945.     /**
  946.      * @return \CorporateTrainingBundle\Biz\User\Service\UserOrgService
  947.      */
  948.     protected function getUserOrgService()
  949.     {
  950.         return $this->createService('User:UserOrgService');
  951.     }
  953.     protected function getPostMemberService()
  954.     {
  955.         return $this->createService('CorporateTrainingBundle:Post:PostMemberService');
  956.     }
  958.     /**
  959.      * @return SessionService
  960.      */
  961.     protected function getSessionService()
  962.     {
  963.         return $this->createService('System:SessionService');
  964.     }
  966.     /**
  967.      * @return TokenService
  968.      */
  969.     protected function getTokenService()
  970.     {
  971.         return $this->createService('User:TokenService');
  972.     }
  974.     /**
  975.      * @return NotificationService
  976.      */
  977.     protected function getNotifiactionService()
  978.     {
  979.         return $this->createService('User:NotificationService');
  980.     }
  981. }
  983. class UserSerialize
  984. {
  985.     public static function serialize(array $user)
  986.     {
  987.         return $user;
  988.     }
  990.     public static function unserialize(array $user = null)
  991.     {
  992.         if (empty($user)) {
  993.             return;
  994.         }
  996.         $user = self::_userRolesSort($user);
  998.         return $user;
  999.     }
  1001.     public static function unserializes(array $users)
  1002.     {
  1003.         return array_map(
  1004.             function ($user) {
  1005.                 return UserSerialize::unserialize($user);
  1006.             },
  1007.             $users
  1008.         );
  1009.     }
  1011.     private static function _userRolesSort($user)
  1012.     {
  1013.         if (!empty($user['roles'][1]) && 'ROLE_USER' == $user['roles'][1]) {
  1014.             $temp = $user['roles'][1];
  1015.             $user['roles'][1] = $user['roles'][0];
  1016.             $user['roles'][0] = $temp;
  1017.         }
  1019.         //交换学员角色跟roles数组第0个的位置;
  1021.         return $user;
  1022.     }
  1023. }