orgModel = new OrgModel; $this->orgRoleModel = new OrgRoleModel; $this->userModel = new UserModel; } /** * @title: 创建统一查询条件 * @desc: 描述 * @return {*} * @author: Rock * @method: POST * @Date: 2023-02-01 09:09:06 */ private function createWhere() { $where = []; $data = $this->request->param(); if (!empty($data['type'])) { $where[] = ['type', '=', $data['type']]; } if (!empty($data['status'])) { $where[] = ['status', '=', $data['status']]; } if (!empty($data['pid'])) { $where[] = ['pid', '=', $data['pid']]; } elseif (!$this->userinfo['is_developer']) { $data['pid'] = $this->userinfo['org_id']; $where[] = ['pid', '=', $data['pid']]; } else { if (empty($data['keyword'])) { $where[] = ['pid', '=', 0]; } } if (!empty($data['keyword'])) { $keyword = $data['keyword']; $where[] = ['name', 'LIKE', "%$keyword%"]; } return $where; } /** * Desc :获取组织架构 * User : zwq * Date : 2025-01-23 10:23 */ public function getOrgs() { $data = $this->request->param(); $res = (new platformAuth())->interfaceRequest('getOrg', $data); if (!$res['code']) return res(2, $res['msg'] ?? '获取失败'); $orgData = $res['data']; print_r($orgData); // 遍历数据并写入数据库 foreach ($orgData as $item) { $primaryKey = $item['org_id']; // 假设主键字段名为 id $org = OrgModel::find($primaryKey); unset($item['menu_ids']); unset($item['request_ids']); unset($item['front_ids']); if ($org) { // 如果记录已存在,更新数据 $org->save($item); } else { // 如果记录不存在,创建新记录 OrgModel::create($item); } } return res(1, "获取成功"); } /** * @title: 获取组织列表 * @desc: 描述 * @param {int} {pageNo} {0} {页码,不传或传0则不分页} * @param {int} {pageSize} {10} {每页数量} * @return {*} * @author: Rock * @method: POST * @Date: 2023-02-01 09:12:42 */ public function getList(int $pageNo = 0, int $pageSize = 10) { $where = $this->createWhere(); if ($pageNo) { $res = OrgModel::where($where)->order("sort ASC")->paginate(['page' => $pageNo, 'list_rows' => $pageSize]); $total = $res->total(); $list = $res->items(); return pageRes(1, "获取成功", $total, $list); } else { $list = OrgModel::where($where)->order("sort ASC")->select(); return res(1, "获取成功", $list); } } /** * @title: 获取组织简单信息列表 * @param {int} {pid} {非必填,默认值为0} {上级组织ID} * @param {string} {org_type_code} {非必填} {公司类型编码搜索} * @param {string} {keyword} {非必填} {字段搜索} * @return array * @Author: wangkewei * @Date: 2021/5/18 9:46 */ public function getSingleList() { $field = ['org_id', 'name']; $where = $this->createWhere(); $list = $this->orgModel->where($where)->field($field)->order('sort ASC,org_id ASC')->select(); return res(1, "获取成功", $list, $where); } /** * @title: 获取组织/企业部门树 * @desc: 描述 * @param {int} {pid} {0} {上级组织ID} * @return {*} * @author: Rock * @method: POST * @Date: 2023-02-03 10:20:19 */ public function getTree(int $pid = 0) { $field = ['org_id', 'org_name']; $where = []; $org_id = 0; if (empty($pid) && !$this->userinfo['is_developer']) { $org_id = $this->userinfo['org_id']; } if (!empty($pid)) { $parent = OrgModel::where('org_id', $pid)->find(); $where[] = ['lft', '>', $parent->lft]; $where[] = ['rgt', '<', $parent->rgt]; $result = OrgModel::where($where)->order('lft asc')->append(['hasChildren'])->select()->toArray(); $list = array2tree($result, 'pid', 'org_id', $pid); return res(1, "获取成功", $list); } elseif (!$this->userinfo['is_developer']) { $self = OrgModel::where('org_id', $org_id)->find(); $where[] = ['lft', '>=', $self->lft]; $where[] = ['rgt', '<=', $self->rgt]; $result = OrgModel::where($where)->order('lft asc')->append(['hasChildren'])->select()->toArray(); $list = array2tree($result, 'pid', 'org_id', $self->pid); return res(1, "获取成功", $list); } else { $result = OrgModel::where($where)->order('lft asc')->append(['hasChildren'])->select()->toArray(); $list = array2tree($result, 'pid', 'org_id'); return res(1, "获取成功", $list); } } /** * @title: 添加组织 * @desc: 描述 * @return {*} * @author: Rock * @method: POST * @Date: 2023-03-17 11:23:06 */ public function doAdd() { $data = $this->request->param(); $pid = $data['pid']; $parent = OrgModel::find($pid); $brother = OrgModel::order('rgt DESC')->find(); if ($parent) { OrgModel::where('lft', '>', $parent->lft)->update(['lft' => Db::raw('lft+2')]); OrgModel::where('rgt', '>', $parent->lft)->update(['rgt' => Db::raw('rgt+2')]); } if ($parent) { $data['lft'] = $parent->lft + 1; $data['rgt'] = $parent->lft + 2; $data['parent_name'] = $parent->name; } elseif ($brother) { $data['lft'] = $brother->rgt + 1; $data['rgt'] = $brother->rgt + 2; } else { $data['lft'] = 1; $data['rgt'] = 2; } $this->orgModel->replace()->save($data); // return res(1, "添加成功"); } /** * @title: 修改组织 * @desc: 描述 * @return {*} * @author: Rock * @method: POST * @Date: 2023-01-16 10:13:10 */ public function doEdit() { $data = $this->request->param(); if (!isset($data['org_id'])) { return res(2, "参数错误"); } $org_id = $data['org_id']; $pid = isset($data['pid']) ? $data['pid'] : 0; $oldInfo = OrgModel::find($org_id); $oldParent = OrgModel::find($oldInfo->pid); $parent = OrgModel::find($pid); $width = $oldInfo->rgt - $oldInfo->lft + 1; // 改变了上级组织时进行以下处理 if ($pid != $oldInfo->pid) { // 提取本节点 $nodeList = OrgModel::where('lft', '>=', $oldInfo->lft)->where('rgt', '<=', $oldInfo->rgt)->column('*', 'org_id'); $nodeList[$org_id]['name'] = $data['name'] ?? ''; $nodeList[$org_id]['short_name'] = $data['short_name'] ?? ''; $nodeList[$org_id]['parent_name'] = $parent ? $parent->name : ''; $nodeList[$org_id]['pid'] = $pid; $nodeIds = array_keys($nodeList); // 有新上级节点 if (!empty($parent)) { // 先算出节点移动的距离 $distance = $parent->rgt - $oldInfo->lft; // 修改本节点之后的节点 OrgModel::where('lft', '>', $oldInfo->rgt)->update(['lft' => Db::raw("lft - $width")]); OrgModel::where('rgt', '>', $oldInfo->rgt)->update(['rgt' => Db::raw("rgt - $width")]); // 上级节点的lft和rgt已经发生变化 $parent = OrgModel::find($pid); // 插入本节点 $reList = []; foreach ($nodeList as $node) { //向后移动 if ($distance >= 0) { $node['lft'] += $distance - $width; $node['rgt'] += $distance - $width; } // 向前移动 else { $node['lft'] += $distance; $node['rgt'] += $distance; } $reList[] = $node; } (new OrgModel)->replace()->saveAll($reList); // 插入本节点后,修改本节点之后的节点 OrgModel::where('rgt', '>', $parent->rgt)->where('lft', '>', $parent->lft)->where('org_id', 'NOT IN', $nodeIds)->update(['lft' => Db::raw("lft + $width")]); OrgModel::where('rgt', '>=', $parent->rgt)->where('org_id', 'NOT IN', $nodeIds)->update(['rgt' => Db::raw("rgt + $width")]); WLog("MoveOrg", "将" . $oldInfo->getAttr('name') . "从" . ($oldInfo->pid != 0 ? $oldInfo->getAttr('name') : "顶级组织") . "移动至" . $parent->getAttr('name') . "下"); return res(1, '操作成功', ['width' => $width, 'distance' => $distance]); } else {// 无新上级节点 // 修改本节点之后的节点 OrgModel::where('lft', '>', $oldInfo->rgt)->update(['lft' => Db::raw("lft - $width")]); OrgModel::where('rgt', '>', $oldInfo->rgt)->update(['rgt' => Db::raw("rgt - $width")]); // 插入本节点 $lastBrother = OrgModel::where('org_id', 'NOT IN', $nodeIds)->order('rgt DESC')->find(); $newLft = $lastBrother->rgt + 1; $distance = $newLft - $oldInfo->lft; $reList = []; foreach ($nodeList as $node) { $node['lft'] += $distance; $node['rgt'] += $distance; $reList[] = $node; } (new OrgModel)->replace()->saveAll($reList); WLog("MoveOrg", "将" . $oldInfo->getAttr('name') . "从" . ($oldInfo->pid != 0 ? $oldInfo->getAttr('name') : "顶级组织") . "移动至顶级组织"); return res(1, '操作成功', ['width' => $width, 'distance' => $distance]); } } else { // 修改本次修改的组织信息 $this->orgModel->replace()->save($data); // 修改相关父组织为本次修改的组织的信息 $this->orgModel->where('pid', $data['org_id'])->update(['parent_name' => $data['name']]); return res(1, "修改成功"); } } /** * @title: 删除组织 * @desc: 描述 * @param {int} {id} {} {组织ID} * @return {*} * @author: Rock * @method: POST * @Date: 2023-02-02 09:07:12 */ public function doDelete(int $id = 0) { $info = OrgModel::find($id); $width = $info['rgt'] - $info['lft'] + 1; // 删除自己 $info->name .= '(已删除)'; $info->save(); $info->delete(); // 删除下级 $where = []; $where[] = ['lft', '>', $info->lft]; $where[] = ['lft', '<', $info->rgt]; OrgModel::where($where)->update(['name' => Db::raw("CONCAT(name,'(已删除)')")]); OrgModel::destroy(function ($query) use ($where) { $query->where($where); }); // 修改其他 OrgModel::where('lft', '>', $info->rgt)->update(['lft' => Db::raw("lft - $width")]); OrgModel::where('rgt', '>', $info->rgt)->update(['rgt' => Db::raw("rgt - $width")]); return res(1, "删除成功"); } /** * @title: 改变状态 * @desc: 描述 * @param {int} $id {} {} * @return {*} * @author: wangjunchong * @method: Post * @Date: 2023-03-11 09:37:43 */ public function changeStatus(int $org_id = 0) { // 改变本组织 $info = OrgModel::find($org_id); $status = abs(5 - $info->status * 3); $info->status = $status; $info->save(); // 改变下级组织 OrgModel::where('lft', '>', $info->lft)->where('rgt', '<', $info->rgt)->update(['status' => $status]); return res(1, "操作成功"); } /** * @title: 获取组织已有的权限 * @desc: 描述 * @param {int} {org_id} {} {组织ID} * @return {*} * @author: Rock * @method: POST * @Date: 2023-02-02 17:01:50 */ public function getAuthList(int $org_id = 0) { try { $orgInfo = OrgModel::find($org_id); if ($orgInfo && $orgInfo->isEmpty()) { return error('未找到此组织'); } $menu_ids = is_string($orgInfo->menu_ids) ? explode(',', $orgInfo->menu_ids) : $orgInfo->menu_ids; $request_ids = is_string($orgInfo->request_ids) ? explode(',', $orgInfo->request_ids) : $orgInfo->request_ids; $front_ids = is_string($orgInfo->front_ids) ? explode(',', $orgInfo->front_ids) : $orgInfo->front_ids; // 此组织类型的所有菜单权限 $allMenuList = Menu::where('menu_id', 'IN', $menu_ids)->with(['menurequest'])->select()->toArray(); $menuAuthList = []; foreach ($allMenuList as $menu) { $MenuItemRequestIds = array_column($menu['menurequest'], 'menu_request_id'); $selected = array_intersect($request_ids, $MenuItemRequestIds); // 当所有请求权限都勾选了,菜单才会被选中 if (count($selected) == count($MenuItemRequestIds)) { $menuAuthList[] = $menu['menu_id']; } } $menuAuthList = !empty($menuAuthList) ? array_filter($menuAuthList) : []; $request_ids = !empty($request_ids) ? array_filter($request_ids) : []; $front_ids = !empty($front_ids) ? array_filter($front_ids) : []; $request_ids = array_map('intval', $request_ids); $front_ids = array_map('intval', $front_ids); $menuAuthList = array_map('intval', $menuAuthList); return res(1, '获取成功', ['menuAuthList' => $menuAuthList, 'requestAuthList' => $request_ids, 'frontAuthList' => $front_ids]); } catch (\Exception $e) { return res(2, '获取失败', $e->getMessage(), $e->getTrace()); } } /** * @title: 设置组织权限 * @desc: 描述 * @param {int} {org_id} {} {组织ID} * @param {array} {menuAuthList} {} {菜单权限} * @param {array} {requestAuthList} {} {请求权限} * @param {array} {frontAuthList} {} {移动端权限} * @return {*} * @author: Rock * @method: POST * @Date: 2023-02-02 17:00:27 */ public function setAuth(int $org_id = 0, array $menuAuthList = [], array $requestAuthList = [], array $frontAuthList = []) { $menuAuthList = array_unique(array_filter($menuAuthList)); $requestAuthList = array_unique(array_filter($requestAuthList)); $frontAuthList = array_unique(array_filter($frontAuthList)); try { // 事务开始 OrgModel::startTrans(); $orgInfo = OrgModel::find($org_id); $oldMenuIds = $orgInfo->menu_ids; $oldRequestIds = $orgInfo->request_ids; $oldFrontIds = $orgInfo->front_ids; $requestMenu = Menurequest::where('menu_request_id', 'IN', $requestAuthList)->column('menu_id'); $menuAuthList = array_unique(array_merge($menuAuthList, $requestMenu)); // 更新组织权限 $orgInfo->menu_ids = $menuAuthList; //菜单权限 $orgInfo->request_ids = $requestAuthList; //请求权限 $orgInfo->front_ids = $frontAuthList; //小程序权限 $orgInfo->save(); // 若有移除的权限,同时企业角色的权限 $delMenuIds = array_values(array_diff($oldMenuIds, $menuAuthList)); $delRequestIds = array_values(array_diff($oldRequestIds, $requestAuthList)); $delFrontIds = array_values(array_diff($oldFrontIds, $frontAuthList)); $WhereOr = []; // 移除菜单权限 if (!empty($delMenuIds)) { foreach ($delMenuIds as $menu_id) { $WhereOr[] = ['menu_ids', 'FIND IN SET', $menu_id]; } } // 移除请求权限 if (!empty($delRequestIds)) { foreach ($delRequestIds as $request_id) { $WhereOr[] = ['request_ids', 'FIND IN SET', $request_id]; } } // 移除手机端权限 if (!empty($delFrontIds)) { foreach ($delFrontIds as $front_id) { $WhereOr[] = ['front_ids', 'FIND IN SET', $front_id]; } } $orgSaveData = []; $orgRoleSaveData = []; if (!empty($WhereOr)) { $where = []; $where[] = ['lft', '>=', $orgInfo->lft]; $where[] = ['lft', '<=', $orgInfo->rgt]; $org_ids = OrgModel::where($where)->column('org_id'); // 下级组织列表(不包含本组织,本组织权限已再上面步骤处理过) $orgList = OrgModel::where('org_id', 'IN', array_diff($org_ids, [$org_id]))->where(function ($query) use ($WhereOr) { $query->whereOr($WhereOr); })->select()->toArray(); foreach ($orgList as $orgItem) { $orgItem['menu_ids'] = array_diff($orgItem['menu_ids'], $delMenuIds); $orgItem['request_ids'] = array_diff($orgItem['request_ids'], $delRequestIds); $orgItem['front_ids'] = array_diff($orgItem['front_ids'], $delFrontIds); $orgSaveData[] = $orgItem; } // 本组织及下级组织角色列表 $roleList = OrgRoleModel::where('org_id', 'IN', $org_ids)->where(function ($query) use ($WhereOr) { $query->whereOr($WhereOr); })->select()->toArray(); foreach ($roleList as $roleItem) { $roleItem['menu_ids'] = array_diff($roleItem['menu_ids'], $delMenuIds); $roleItem['request_ids'] = array_diff($roleItem['request_ids'], $delRequestIds); $roleItem['front_ids'] = array_diff($roleItem['front_ids'], $delFrontIds); $orgRoleSaveData[] = $roleItem; } (new OrgModel)->replace()->saveAll($orgSaveData); (new OrgRoleModel)->replace()->saveAll($orgRoleSaveData); } OrgModel::commit(); return res(1, '保存成功', $WhereOr); } catch (\Exception $e) { OrgModel::rollback(); return res(2, '保存失败', $e->getMessage(), $e->getTrace()); } } /** * @title: 获取上级组织的权限 * @desc: 描述 * @param {int} {pid} {0} {上级组织org_id} * @return {*} * @author: Rock * @method: POST * @Date: 2023-03-24 11:06:36 */ public function getParentAuth(int $pid = 0) { $parent = OrgModel::find($pid); $menuList = []; $frontList = []; if ($parent) { $menu_ids = $parent->menu_ids; $request_ids = $parent->request_ids; $front_ids = $parent->front_ids; $parentList = Menu::where('menu_id', 'IN', $menu_ids)->column('parent_path'); $parentIds = explode(',', implode(',', $parentList)); $menuList = Menu::where('menu_id', 'IN', $menu_ids)->whereOr('menu_id', 'IN', $parentIds)->with(['menurequest' => function ($query) use ($request_ids) { $query->where('menu_request_id', 'IN', $request_ids); }])->order('menu_id asc')->select()->toArray(); $menuList = array2tree($menuList, 'pid', 'menu_id'); $frontList = Frontmenus::where('menu_id', 'IN', $front_ids)->select(); } return res(1, "获取成功", ['menuList' => $menuList, 'frontList' => $frontList]); } }