src/CorporateTrainingBundle/Biz/Org/Service/Impl/OrgServiceImpl.php line 16

Open in your IDE?
  1. <?php
  3. namespace CorporateTrainingBundle\Biz\Org\Service\Impl;
  5. use AppBundle\Common\ArrayToolkit;
  6. use AppBundle\Common\Exception\AccessDeniedException;
  7. use Biz\Org\Service\Impl\OrgServiceImpl as BaseOrgServiceImpl;
  8. use Biz\System\Service\CacheService;
  9. use Biz\System\Service\LogService;
  10. use Codeages\Biz\Framework\Service\Exception\NotFoundException;
  11. use CorporateTrainingBundle\Biz\ManagePermission\Service\ManagePermissionOrgService;
  12. use CorporateTrainingBundle\Biz\Org\Service\OrgService;
  13. use CorporateTrainingBundle\Common\Constant\CTConst;
  14. use CorporateTrainingBundle\Common\OrgTreeToolkit;
  16. class OrgServiceImpl extends BaseOrgServiceImpl implements OrgService
  17. {
  18.     protected $visibleOrgTreeDataLocalCacheArray = [];
  20.     public function createAiCoachOrg(array $fields)
  21.     {
  22.         $parent = $this->getOrgDao()->get($fields['parentId']);
  23.         if (empty($parent)) {
  24.             throw $this->createNotFoundException('AI Coach parent org not found');
  25.         }
  26.         if ($this->getOrgDao()->getByCode($fields['code'])) {
  27.             throw $this->createInvalidArgumentException('AI Coach org code already exists');
  28.         }
  29.         $org = $this->getOrgDao()->create([
  30.             'name' => $fields['name'],
  31.             'code' => strtoupper($fields['code']),
  32.             'parentId' => $parent['id'],
  33.             'description' => $fields['description'] ?? '',
  34.             'syncId' => (string) $fields['syncId'],
  35.             'createdUserId' => 0,
  36.         ]);
  37.         $this->getOrgDao()->wave([$parent['id']], ['childrenNum' => 1]);
  39.         return $this->getOrgDao()->update($org['id'], [
  40.             'orgCode' => $parent['orgCode'].$org['id'].'.',
  41.             'depth' => $parent['depth'] + 1,
  42.         ]);
  43.     }
  45.     public function updateAiCoachOrg($id, array $fields)
  46.     {
  47.         $org = $this->getOrgDao()->get($id);
  48.         $parent = $this->getOrgDao()->get($fields['parentId']);
  49.         if (empty($org) || empty($parent)) {
  50.             throw $this->createNotFoundException('AI Coach org not found');
  51.         }
  52.         if (in_array($org['id'], array_filter(explode('.', $parent['orgCode'])))) {
  53.             throw $this->createInvalidArgumentException('AI Coach org cannot move below itself');
  54.         }
  56.         $oldPrefix = $org['orgCode'];
  57.         $newPrefix = $parent['orgCode'].$org['id'].'.';
  58.         $depthDelta = $parent['depth'] + 1 - $org['depth'];
  59.         $parentChanged = (int) $org['parentId'] !== (int) $parent['id'];
  61.         $this->beginTransaction();
  62.         try {
  63.             if ($parentChanged) {
  64.                 $this->getOrgDao()->wave([$org['parentId']], ['childrenNum' => -1]);
  65.                 $this->getOrgDao()->wave([$parent['id']], ['childrenNum' => 1]);
  66.             }
  67.             $updated = $this->getOrgDao()->update($id, [
  68.                 'name' => $fields['name'],
  69.                 'code' => strtoupper($fields['code']),
  70.                 'parentId' => $parent['id'],
  71.                 'description' => $fields['description'] ?? '',
  72.                 'syncId' => (string) $fields['syncId'],
  73.                 'orgCode' => $newPrefix,
  74.                 'depth' => $parent['depth'] + 1,
  75.             ]);
  76.             if ($oldPrefix !== $newPrefix) {
  77.                 foreach ($this->getOrgDao()->findByPrefixOrgCode($oldPrefix) as $descendant) {
  78.                     if ((int) $descendant['id'] === (int) $id) {
  79.                         continue;
  80.                     }
  81.                     $this->getOrgDao()->update($descendant['id'], [
  82.                         'orgCode' => $newPrefix.substr($descendant['orgCode'], strlen($oldPrefix)),
  83.                         'depth' => $descendant['depth'] + $depthDelta,
  84.                     ]);
  85.                 }
  86.             }
  87.             $this->commit();
  89.             return $updated;
  90.         } catch (\Exception $e) {
  91.             $this->rollback();
  92.             throw $e;
  93.         }
  94.     }
  96.     public function updateAiCoachRootOrg($id, array $fields)
  97.     {
  98.         $org = $this->getOrgDao()->get($id);
  99.         $root = $this->getOrgByOrgCode(CTConst::ROOT_ORG_CODE);
  100.         if (empty($org) || empty($root) || (int) $org['id'] !== (int) $root['id']) {
  101.             throw $this->createInvalidArgumentException('AI Coach org is not the root org');
  102.         }
  104.         $code = strtoupper($fields['code']);
  105.         $sameCodeOrg = $this->getOrgDao()->getByCode($code);
  106.         if (!empty($sameCodeOrg) && (int) $sameCodeOrg['id'] !== (int) $root['id']) {
  107.             throw $this->createInvalidArgumentException('AI Coach org code already exists');
  108.         }
  110.         return $this->getOrgDao()->update($root['id'], [
  111.             'name' => $fields['name'],
  112.             'code' => $code,
  113.             'description' => $fields['description'] ?? '',
  114.             'syncId' => (string) $fields['syncId'],
  115.         ]);
  116.     }
  118.     public function deleteAiCoachOrg($id)
  119.     {
  120.         $org = $this->getOrgDao()->get($id);
  121.         if (empty($org)) {
  122.             return;
  123.         }
  124.         $this->beginTransaction();
  125.         try {
  126.             $this->getOrgDao()->deleteByPrefixOrgCode($org['orgCode']);
  127.             $this->getOrgDao()->wave([$org['parentId']], ['childrenNum' => -1]);
  128.             $this->commit();
  129.         } catch (\Exception $e) {
  130.             $this->rollback();
  131.             throw $e;
  132.         }
  133.     }
  135.     /**
  136.      * @param $id
  137.      * @param $num //正数或负数
  138.      *
  139.      * @return array
  140.      *
  141.      * @throws NotFoundException
  142.      */
  143.     public function waveOrgChildrenNum($id, $num)
  144.     {
  145.         $org = $this->checkBeforeProccess($id);
  147.         $childrenNum = ($org['childrenNum'] + $num) < 1 ? 0 : $org['childrenNum'] + $num;
  149.         return $this->getOrgDao()->update($id, ['childrenNum' => $childrenNum]);
  150.     }
  152.     public function countOrgs(array $conditions)
  153.     {
  154.         return $this->getOrgDao()->count($conditions);
  155.     }
  157.     public function getOrgBySyncId($syncId)
  158.     {
  159.         return $this->getOrgDao()->getOrgBySyncId($syncId);
  160.     }
  162.     public function findOrgsBySyncIds($syncIds)
  163.     {
  164.         return $this->getOrgDao()->findOrgsBySyncIds($syncIds);
  165.     }
  167.     public function findOrgsByOrgCodes(array $orgCodes)
  168.     {
  169.         return $this->getOrgDao()->findByOrgCodes($orgCodes);
  170.     }
  172.     public function findOrgsByCodes(array $codes)
  173.     {
  174.         return $this->getOrgDao()->findByCodes($codes);
  175.     }
  177.     public function findSelfAndParentOrgsByOrgCode($orgCode)
  178.     {
  179.         $preOrgIdArray = explode('.', $orgCode);
  181.         return $this->findOrgsByIds($preOrgIdArray);
  182.     }
  184.     public function findOrgsByPrefixOrgCodes(array $orgCodes = ['1.'], $columns = [])
  185.     {
  186.         $cacheName = md5(json_encode($orgCodes).'|'.json_encode($columns));
  187.         $cacheOrgs = $this->getCacheService()->get($cacheName);
  189.         if (!empty($cacheOrgs)) {
  190.             return $cacheOrgs;
  191.         }
  192.         $result = $this->getOrgDao()->findByPrefixOrgCodes($orgCodes, $columns);
  194.         $this->getCacheService()->clear($cacheName);
  195.         $this->getCacheService()->set($cacheName, $result, time() + 60 * 3);
  197.         return $result;
  198.     }
  200.     public function getOrgMaxDepth($conditions)
  201.     {
  202.         return $this->getOrgDao()->getMaxDepth($conditions);
  203.     }
  205.     public function resetOrg()
  206.     {
  207.         $currentUser = $this->getCurrentUser();
  209.         if ($currentUser->isSuperAdmin() || $currentUser->hasPermission('admin_org_sync_department')) {
  210.             $org = $this->getOrg(CTConst::ROOT_ORG_CODE);
  211.             $this->getOrgDao()->wave([$org['id']], ['childrenNum' => -$org['childrenNum']]);
  212.             $this->getOrgDao()->update($org['id'], ['syncId' => 0]);
  214.             return $this->getOrgDao()->deleteOrgsWithoutOrgCode(CTConst::ROOT_ORG_CODE);
  215.         }
  217.         return false;
  218.     }
  220.     public function resetOrgSyncId()
  221.     {
  222.         $this->getOrgDao()->resetOrgSyncId();
  223.     }
  225.     public function buildOrgTreeByCode($orgCode)
  226.     {
  227.         if (empty($orgCode)) {
  228.             return [];
  229.         }
  231.         $orgInfo = $this->getOrgByOrgCode($orgCode);
  233.         $orgs = $this->findOrgsByPrefixOrgCode($orgCode);
  235.         $orgs = ArrayToolkit::index($orgs, 'id');
  237.         for ($i = CTConst::ORG_MAX_DEPTH; $i >= ($orgInfo['depth'] + 1); --$i) {
  238.             foreach ($orgs as $key => $org) {
  239.                 if (!empty($org['depth']) && $org['depth'] == $i && $org['depth'] > 1) {
  240.                     $orgs[$org['parentId']]['nodes'][] = $org;
  241.                     unset($orgs[$key]);
  242.                 }
  243.             }
  244.         }
  246.         return array_values($orgs);
  247.     }
  249.     public function buildVisibleOrgTreeByOrgCodes(array $orgCodes)
  250.     {
  251.         return array_values(OrgTreeToolkit::makeTree($this->getVisibleOrgTreeDataByOrgCodes($orgCodes, true)));
  252.     }
  254.     /**
  255.      * @param $settingOrgIds
  256.      * 被设置的用户或资源的部门orgIds
  257.      * @param bool $filter
  258.      *
  259.      * @return array|mixed
  260.      *
  261.      * 部门设置特定树结构(展示管理员的管理范围及被操作用户的超出管理员权限部分的部门,部门树中超出我管理范围的部分只展示顶级)
  262.      */
  263.     public function getPermissionOrgTreeData($settingOrgIds, $filter = false)
  264.     {
  265.         $orgCodes = $this->getCurrentUser()->getManageOrgCodes();
  266.         if (empty($orgCodes)) {
  267.             return [];
  268.         }
  269.         $cacheKey = $this->getPermissionOrgTreeDataLocalCacheKey($orgCodes, $settingOrgIds, $filter);
  271.         if (isset($this->visibleOrgTreeDataLocalCacheArray[$cacheKey])) {
  272.             return $this->visibleOrgTreeDataLocalCacheArray[$cacheKey];
  273.         }
  275.         $orgs = $this->findOrgsByPrefixOrgCodes($orgCodes);
  276.         $orgCodes = ArrayToolkit::column($orgs, 'orgCode');
  277.         $settingOrgs = $this->findOrgsByIds($settingOrgIds);
  278.         $settingOrgCodes = ArrayToolkit::column($settingOrgs, 'orgCode');
  280.         $diffOrgCodes = array_diff($settingOrgCodes, $orgCodes);
  282.         if (in_array('1.', $diffOrgCodes, true)) {
  283.             $parentOrg = $this->getOrgByOrgCode('1.');
  284.             $allOrgs = $this->findOrgsByParentId($parentOrg['id']);
  285.             $allOrgs = array_merge($allOrgs, [$parentOrg], $orgs);
  286.             if ($filter) {
  287.                 $allOrgs = $this->filterOrgs($allOrgs);
  288.             }
  289.             foreach ($allOrgs as &$org) {
  290.                 $org['disableCheckbox'] = true;
  291.                 $org['selectable'] = false;
  292.             }
  293.         } else {
  294.             $diffOrgs = $this->findOrgsByOrgCodes(array_values($diffOrgCodes));
  295.             $orgCodeIds = $this->exploreOrgCodes($orgCodes);
  296.             $parentOrgIds = array_diff($orgCodeIds, ArrayToolkit::column($orgs, 'id'));
  297.             $parentOrgs = $this->findOrgsByIds(array_values($parentOrgIds));
  299.             $allOrgs = array_merge($orgs, $parentOrgs, $diffOrgs);
  300.             if ($filter) {
  301.                 $allOrgs = $this->filterOrgs($allOrgs);
  302.             }
  303.             $diffOrgTreeOrgCodes = [];
  304.             if (!empty($diffOrgCodes)) {
  305.                 $diffOrgTree = $this->findOrgsByPrefixOrgCodes($diffOrgCodes, ['orgCode']);
  306.                 $diffOrgTreeOrgCodes = ArrayToolkit::column($diffOrgTree, 'orgCode');
  307.             }
  308.             foreach ($allOrgs as &$org) {
  309.                 if (in_array($org['id'], $parentOrgIds) || in_array($org['orgCode'], $diffOrgTreeOrgCodes)) {
  310.                     $org['selectable'] = false;
  311.                     $org['disableCheckbox'] = true;
  312.                 } else {
  313.                     $org['selectable'] = true;
  314.                     $org['disableCheckbox'] = false;
  315.                 }
  316.             }
  317.         }
  319.         $indexedAllOrgs = ArrayToolkit::index($allOrgs, 'orgCode');
  320.         ksort($indexedAllOrgs);
  322.         $treeData = array_values($indexedAllOrgs);
  324.         $this->visibleOrgTreeDataLocalCacheArray[$cacheKey] = $treeData;
  326.         return $treeData;
  327.     }
  329.     /*
  330.      * 获取可见的部门树组件数据，直线上级及所有下级
  331.      */
  332.     public function getVisibleOrgTreeDataByOrgCodes(array $orgCodes, $filter = false)
  333.     {
  334.         $cacheKey = $this->getVisibleOrgTreeDataLocalCacheKey($orgCodes, $filter);
  336.         if (isset($this->visibleOrgTreeDataLocalCacheArray[$cacheKey])) {
  337.             return $this->visibleOrgTreeDataLocalCacheArray[$cacheKey];
  338.         }
  340.         $orgs = $this->findOrgsByPrefixOrgCodes($orgCodes);
  341.         $orgCodes = ArrayToolkit::column($orgs, 'orgCode');
  342.         $orgCodeIds = $this->exploreOrgCodes($orgCodes);
  344.         $parentOrgIds = array_diff($orgCodeIds, ArrayToolkit::column($orgs, 'id'));
  345.         $parentOrgs = $this->findOrgsByIds(array_values($parentOrgIds));
  347.         $allOrgs = array_merge($orgs, $parentOrgs);
  349.         if ($filter) {
  350.             $allOrgs = $this->filterOrgs($allOrgs);
  351.         }
  353.         foreach ($allOrgs as &$org) {
  354.             if (in_array($org['id'], $parentOrgIds)) {
  355.                 $org['selectable'] = false;
  356.                 $org['disableCheckbox'] = true;
  357.             } else {
  358.                 $org['selectable'] = true;
  359.                 $org['disableCheckbox'] = false;
  360.             }
  361.         }
  363.         $indexedAllOrgs = ArrayToolkit::index($allOrgs, 'orgCode');
  364.         ksort($indexedAllOrgs);
  366.         $treeData = array_values($indexedAllOrgs);
  368.         $this->visibleOrgTreeDataLocalCacheArray[$cacheKey] = $treeData;
  370.         return $treeData;
  371.     }
  373.     public function buildOrgTreeByParentId($parentId, $offset, $limit, $filter = false)
  374.     {
  375.         $orgs = $this->findOrgsDataByParentId($parentId, $offset, $limit, $filter);
  376.         if (empty($orgs)) {
  377.             return [];
  378.         }
  380.         $orgTree = array_values(OrgTreeToolkit::makeTree($orgs));
  381.         $childrenCounts = $this->childrenCountsByOrgIds(ArrayToolkit::column($orgs, 'id'));
  382.         $childrenCounts = ArrayToolkit::index($childrenCounts, 'parentId');
  383.         $orgTree = $this->findChildrenTree($orgTree[0], $parentId, $childrenCounts);
  385.         return $orgTree;
  386.     }
  388.     public function findOrgsDataByParentId($parentId, $offset, $limit, $filter = false)
  389.     {
  390.         $orgs = $this->searchOrgs(['parentId' => $parentId], ['orgCode' => 'ASC'], $offset, $limit);
  391.         if (empty($orgs)) {
  392.             return [];
  393.         }
  395.         $parentOrg = $this->getOrg($parentId);
  396.         $parentIds = $this->parentOrgIdsByOrgCodes([$parentOrg['orgCode']]);
  397.         $orgs = array_merge($orgs, $this->findOrgsByIds(array_merge($parentIds, [$parentId])));
  398.         if ($filter) {
  399.             $orgs = $this->filterOrgs($orgs);
  400.         }
  402.         foreach ($orgs as &$org) {
  403.             if (in_array($org['id'], $parentIds, true)) {
  404.                 $org['selectable'] = false;
  405.                 $org['disableCheckbox'] = true;
  406.             } else {
  407.                 $org['selectable'] = true;
  408.                 $org['disableCheckbox'] = false;
  409.             }
  410.         }
  412.         return $orgs;
  413.     }
  415.     public function buildCanManageOrgTreeByParentId($parentId, $settingOrgIds, $offset, $limit, $filter = false)
  416.     {
  417.         $orgs = $this->findCanManageOrgsDataByParentId($parentId, $settingOrgIds, $offset, $limit, $filter);
  418.         if (empty($orgs)) {
  419.             return [];
  420.         }
  422.         $orgTree = array_values(OrgTreeToolkit::makeTree($orgs));
  423.         $childrenCounts = $this->childrenCountsByOrgIds(ArrayToolkit::column($orgs, 'id'));
  424.         $childrenCounts = ArrayToolkit::index($childrenCounts, 'parentId');
  425.         $orgTree = $this->findChildrenTree($orgTree[0], $parentId, $childrenCounts);
  427.         return $orgTree;
  428.     }
  430.     public function findCanManageOrgsDataByParentId($parentId, $settingOrgIds, $offset, $limit, $filter = false)
  431.     {
  432.         $manageOrgCodes = $this->getCurrentUser()->getManageOrgCodes();
  433.         if (empty($manageOrgCodes)) {
  434.             return [];
  435.         }
  437.         list($manageOrgIds, $lastOrgIds) = $this->exploreOrgCodesAndLastOrgIds($manageOrgCodes);
  438.         $noPermissionOrgIds = array_values(array_filter($this->parentOrgIdsByOrgCodes($manageOrgCodes)));
  439.         $noPermissionSettingOrgIds = array_intersect($noPermissionOrgIds, $settingOrgIds);
  440.         $parentOrg = $this->getOrg($parentId);
  441.         $parentOrgIds = $this->parentOrgIdsByOrgCodes([$parentOrg['orgCode']]);
  443.         $conditions = ['parentId' => $parentId];
  444.         if (!in_array('1', $lastOrgIds, true)) {
  445.             if (empty(array_intersect($manageOrgIds, $parentOrgIds)) || (in_array(
  446.                 $parentId,
  447.                 $manageOrgIds,
  448.                 true
  449.             ) && !in_array($parentId, $lastOrgIds, true))) {
  450.                 $conditions['orgIds'] = $manageOrgIds;
  451.             }
  452.         }
  454.         $allOrgs = $this->searchOrgs(
  455.             $conditions,
  456.             ['orgCode' => 'ASC'],
  457.             $offset,
  458.             $limit
  459.         );
  461.         if (empty($allOrgs)) {
  462.             return [];
  463.         }
  465.         $parentOrgs = $this->findOrgsByIds($parentOrgIds);
  466.         $allOrgs = array_merge($allOrgs, $parentOrgs, [$parentOrg]);
  467.         if ($filter) {
  468.             $allOrgs = $this->filterOrgs($allOrgs);
  469.         }
  471.         foreach ($allOrgs as &$org) {
  472.             $exploreOrgIds = $this->exploreOrgCodes([$org['orgCode']]);
  473.             $exploreOrgIds = array_diff($exploreOrgIds, $noPermissionOrgIds);
  475.             if ((!empty($noPermissionSettingOrgIds) && !empty(
  476.                     array_intersect(
  477.                         $exploreOrgIds,
  478.                         $noPermissionSettingOrgIds
  479.                     )
  480.                     )) || in_array($org['id'], $noPermissionOrgIds, true)) {
  481.                 $org['selectable'] = false;
  482.                 $org['disableCheckbox'] = true;
  483.             } else {
  484.                 $org['selectable'] = true;
  485.                 $org['disableCheckbox'] = false;
  486.             }
  487.         }
  489.         return $allOrgs;
  490.     }
  492.     public function findOrgsByParentId($orgId)
  493.     {
  494.         return $this->getOrgDao()->findByParentOrgId($orgId);
  495.     }
  497.     public function findOrgsByParentIds($orgIds)
  498.     {
  499.         return $this->getOrgDao()->findByParentOrgIds($orgIds);
  500.     }
  502.     public function findParentOrgIdsByOrgId($orgId)
  503.     {
  504.         $parentOrgIds = [];
  505.         $parentOrgIds = $this->findParentOrgIdByIdAndCategories($orgId, $parentOrgIds);
  507.         return array_merge($parentOrgIds, [$orgId]);
  508.     }
  510.     protected function findParentOrgIdByIdAndCategories($orgId, &$parentOrgIds)
  511.     {
  512.         $org = $this->getOrg($orgId);
  514.         if (0 != $org['parentId']) {
  515.             $parentOrg = $this->getOrg($org['parentId']);
  516.             $parentOrgIds = array_merge($parentOrgIds, [$parentOrg['id']]);
  517.             $this->findParentOrgIdByIdAndCategories($parentOrg['id'], $parentOrgIds);
  518.         }
  520.         return $parentOrgIds;
  521.     }
  523.     /**
  524.      * @param $orgIds
  525.      *
  526.      * @return array 过滤子部门获取顶层部门
  527.      */
  528.     public function wipeOffChildrenOrgIds($orgIds)
  529.     {
  530.         $orgs = $this->findOrgsByIds($orgIds);
  531.         $orgs = ArrayToolkit::index($orgs, 'id');
  532.         $orgIds = [];
  533.         foreach ($orgs as $org) {
  534.             if (empty($orgs[$org['parentId']])) {
  535.                 $orgIds[] = $org['id'];
  536.             }
  537.         }
  539.         return $orgIds;
  540.     }
  542.     public function wipeOffChildrenCode($codes)
  543.     {
  544.         if (empty($codes)) {
  545.             return [];
  546.         }
  547.         $orgs = $this->findOrgsByCodes($codes);
  548.         $orgs = ArrayToolkit::index($orgs, 'id');
  549.         $orgCodes = [];
  550.         foreach ($orgs as $org) {
  551.             if (empty($orgs[$org['parentId']])) {
  552.                 $orgCodes[] = $org['code'];
  553.             }
  554.         }
  556.         return $orgCodes;
  557.     }
  559.     public function childrenCountsByOrgIds($orgIds)
  560.     {
  561.         return $this->getOrgDao()->childrenCountsByOrgIds($orgIds);
  562.     }
  564.     public function deleteOrgWithoutDeleteChildren($id)
  565.     {
  566.         $org = $this->getOrg($id);
  567.         if (empty($org)) {
  568.             return;
  569.         }
  570.         if ('1.' == $org['orgCode']) {
  571.             throw new AccessDeniedException('顶级部门不可删除！');
  572.         }
  573.         try {
  574.             $this->beginTransaction();
  576.             $this->getOrgDao()->delete($id);
  577.             $parentOrg = $this->getOrg($org['parentId']);
  578.             $groupChildOrgs = ArrayToolkit::group($this->findOrgsByPrefixOrgCode($org['orgCode']), 'parentId');
  579.             $updateFields = [];
  580.             $orgQueue = [$org];
  581.             while ($orgQueue) {
  582.                 $currentOrg = array_shift($orgQueue);
  583.                 if ($currentOrg['id'] != $org['id']) {
  584.                     $updateFields[$currentOrg['id']] = [
  585.                         'parentId' => $currentOrg['parentId'] == $org['id'] ? $org['parentId'] : $currentOrg['parentId'],
  586.                         'orgCode' => $currentOrg['parentId'] == $org['id'] ? $parentOrg['orgCode'].$currentOrg['id'].'.' : $updateFields[$currentOrg['parentId']]['orgCode'].$currentOrg['id'],
  587.                         'depth' => $currentOrg['depth'] - 1,
  588.                     ];
  589.                 }
  590.                 if (isset($groupChildOrgs[$currentOrg['id']])) {
  591.                     $orgQueue = array_merge($orgQueue, $groupChildOrgs[$currentOrg['id']]);
  592.                 }
  593.             }
  594.             $this->getOrgDao()->wave([$org['parentId']], ['childrenNum' => $org['childrenNum'] - 1]);
  595.             if ($updateFields) {
  596.                 $this->getOrgDao()->batchUpdate(array_keys($updateFields), $updateFields, 'id');
  597.             }
  598.             $this->getLogService()->info('org', 'delete_org', "删除部门{$org['name']}", ['org' => $org]);
  599.             $this->commit();
  600.         } catch (\Exception $e) {
  601.             $this->rollback();
  602.             throw $e;
  603.         }
  604.     }
  606.     protected function findChildrenTree($tree, $parentId, $childrenCounts)
  607.     {
  608.         if (empty($tree['nodes'])) {
  609.             return $tree;
  610.         }
  611.         $nodes = $tree['nodes'];
  612.         foreach ($nodes as &$org) {
  613.             if ($org['id'] == $parentId || 1 == count($org['nodes'])) {
  614.                 return $this->findChildrenTree($org, $parentId, $childrenCounts);
  615.             }
  617.             if ($org['parentId'] == $parentId && !empty($childrenCounts[$org['id']])) {
  618.                 $org['nodes'] = [['name' => '加载中···', 'isExist' => $childrenCounts[$org['id']]['count'] > 0]];
  619.             }
  620.         }
  621.         $tree['nodes'] = $nodes;
  623.         return $tree;
  624.     }
  626.     protected function getVisibleOrgTreeDataLocalCacheKey($orgCodes, $filter)
  627.     {
  628.         return md5(json_encode($orgCodes).'|'.($filter ? '1' : '0'));
  629.     }
  631.     protected function getPermissionOrgTreeDataLocalCacheKey($orgCodes, $settingOrgIds, $filter)
  632.     {
  633.         return md5(json_encode($settingOrgIds).'|'.json_encode($orgCodes).'|'.($filter ? '1' : '0'));
  634.     }
  636.     protected function filterOrgs($orgs)
  637.     {
  638.         foreach ($orgs as $key => $org) {
  639.             $orgs[$key] = ArrayToolkit::parts(
  640.                 $org,
  641.                 [
  642.                     'id',
  643.                     'name',
  644.                     'parentId',
  645.                     'seq',
  646.                     'orgCode',
  647.                     'code',
  648.                     'depth',
  649.                 ]
  650.             );
  651.         }
  653.         return $orgs;
  654.     }
  656.     protected function exploreOrgCodes(array $orgCodes)
  657.     {
  658.         $orgIds = [];
  659.         foreach ($orgCodes as $orgCode) {
  660.             $orgIds[] = array_filter(explode('.', $orgCode));
  661.         }
  662.         if (!empty($orgIds)) {
  663.             $orgIds = array_merge(...$orgIds);
  664.         }
  666.         return array_unique($orgIds);
  667.     }
  669.     protected function exploreOrgCodesAndLastOrgIds(array $orgCodes)
  670.     {
  671.         $orgGroup = [];
  672.         $lastIds = [];
  673.         foreach ($orgCodes as $orgCode) {
  674.             $orgIds = array_filter(explode('.', $orgCode));
  675.             $orgGroup[] = $orgIds;
  676.             $lastIds[] = end($orgIds);
  677.         }
  679.         $orgAllIds = !empty($orgGroup) ? array_merge(...$orgGroup) : [];
  681.         return [array_unique($orgAllIds), $lastIds];
  682.     }
  684.     protected function parentOrgIdsByOrgCodes($orgCodes)
  685.     {
  686.         $orgIds = [];
  687.         foreach ($orgCodes as $orgCode) {
  688.             $orgArr = array_filter(explode('.', $orgCode));
  689.             array_pop($orgArr);
  690.             $orgIds[] = $orgArr;
  691.         }
  692.         $orgIds = array_merge(...$orgIds);
  694.         return array_unique($orgIds);
  695.     }
  697.     public function filterCurrentUserManageOrgsByOrgs(array $orgs)
  698.     {
  699.         $orgIds = $this->getCurrentUser()->getManageOrgIds();
  700.         if (empty($orgIds) || empty($orgs)) {
  701.             return [];
  702.         }
  703.         $manageOrgs = [];
  704.         foreach ($orgs as $org) {
  705.             $orgCodeExplode = explode('.', $org['orgCode'] ?? '');
  706.             $intersectIds = array_intersect($orgCodeExplode, $orgIds);
  707.             if (empty($intersectIds)) {
  708.                 continue;
  709.             }
  710.             $manageOrgs[] = $org;
  711.         }
  713.         return $manageOrgs;
  714.     }
  716.     /**
  717.      * @return array
  718.      */
  719.     public function findCurrentUserManageOrgIds()
  720.     {
  721.         $manageOrgIds = $this->getCurrentUser()->getManageOrgIds();
  722.         if (empty($manageOrgIds)) {
  723.             return [];
  724.         }
  725.         $orgs = $this->findOrgsByIds($manageOrgIds, ['orgCode']);
  726.         if (empty($orgs)) {
  727.             return [];
  728.         }
  729.         $orgCodes = ArrayToolkit::column($orgs, 'orgCode');
  730.         $manageOrgs = $this->findOrgsByPrefixOrgCodes($orgCodes, ['id']);
  731.         if (empty($manageOrgs)) {
  732.             return [];
  733.         }
  735.         return ArrayToolkit::column($manageOrgs, 'id');
  736.     }
  738.     public function findFullPathOrgsByOrgCodesColumn($list)
  739.     {
  740.         if (empty($list)) {
  741.             return [];
  742.         }
  743.         $orgCodes = ArrayToolkit::flatten(ArrayToolkit::column($list, 'orgCodes'));
  744.         $orgIds = ArrayToolkit::flatten(array_map(function ($orgCode) {
  745.             return array_filter(explode('.', $orgCode));
  746.         }, $orgCodes));
  747.         $orgs = $this->getOrgDao()->findByIds($orgIds);
  749.         return ArrayToolkit::index($orgs, 'id');
  750.     }
  752.     public function findFullPathOrgsByOrgCodeColumn($list)
  753.     {
  754.         if (empty($list)) {
  755.             return [];
  756.         }
  757.         $orgCodes = ArrayToolkit::column($list, 'orgCode');
  758.         $orgIds = ArrayToolkit::flatten(array_map(function ($orgCode) {
  759.             return array_filter(explode('.', $orgCode));
  760.         }, $orgCodes));
  761.         $orgs = $this->getOrgDao()->findByIds($orgIds);
  763.         return ArrayToolkit::index($orgs, 'id');
  764.     }
  766.     /**
  767.      * @return ManagePermissionOrgService
  768.      */
  769.     protected function getManagePermissionService()
  770.     {
  771.         return $this->createService('CorporateTrainingBundle:ManagePermission:ManagePermissionOrgService');
  772.     }
  774.     /**
  775.      * @return LogService
  776.      */
  777.     protected function getLogService()
  778.     {
  779.         return $this->createService('System:LogService');
  780.     }
  782.     /**
  783.      * @return CacheService
  784.      */
  785.     protected function getCacheService()
  786.     {
  787.         return $this->createService('System:CacheService');
  788.     }
  789. }