JDF_ElectronicPublicity_admin/app/admin/controller/base/org/Org.php

<?php

namespace app\admin\controller\base\org;

/**
 * @title        : 组织
 * @desc         :
 * @Author       : Rock
 * @Date         : 2023-01-16 10:11:36
 */

use app\admin\controller\Base;
use app\common\model\base\org\Org as OrgModel;
use app\common\model\base\org\OrgType as OrgTypeModel;
use app\common\model\base\org\OrgRole as OrgRoleModel;
use app\common\model\base\user\User as UserModel;
use app\common\model\base\menu\Menu;
use app\common\model\base\menu\Menurequest;
use app\common\model\base\menu\Frontmenus;
use daorui\platform\platformAuth;
use think\facade\Db;

class Org extends Base
{
    private $orgModel = null;
    private $orgRoleModel = null;
    private $userModel = null;
    protected $noNeedLogin = [];
    protected $noNeedAuth = ['getTree'];

    public function initialize()
    {
        parent::initialize();
        $this->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]);
    }
}