diff --git a/app/common/utils/MigrationResources.php b/app/common/utils/MigrationResources.php new file mode 100644 index 0000000..ce2f473 --- /dev/null +++ b/app/common/utils/MigrationResources.php @@ -0,0 +1,194 @@ +where($conditions); + + // 按排序字段排序 + $resources = $query->orderBy('sort')->orderBy('id')->get(); + // var_dump($resources->count()); + // 转换为数组 + $resourceList = []; + foreach ($resources as $resource) { + $resourceList[] = (array) $resource; + } + + // 构建树状结构 + return $this->buildTree($resourceList); + } + + /** + * 构建树状结构 + * + * @param array $resources 资源列表 + * @param int $parentId 父级ID + * @return array + */ + private function buildTree(array $resources, int $parentId = 0): array + { + $tree = []; + + foreach ($resources as $resource) { + if ($resource['parent_id'] == $parentId) { + // 递归获取子节点 + $children = $this->buildTree($resources, $resource['id']); + + // 如果有子节点，则添加到children字段 + if (!empty($children)) { + $resource['children'] = $children; + } + + $tree[] = $resource; + } + } + + return $tree; + } + + /** + * 使用引用方式构建树（性能优化版） + * + * @param array $conditions 筛选条件 + * @return array + */ + public function getFullResourceTreeOptimized($table = 'resources', array $conditions = []): array + { + // 查询所有资源数据 + $query = Db::table($table)->where($conditions); + + // 按排序字段排序 + $resources = $query->orderBy('sort')->orderBy('id')->get(); + + // 构建ID映射和引用关系 + $resourceMap = []; + $tree = []; + + // 初始化所有节点 + foreach ($resources as $resource) { + $resourceArray = (array) $resource; + $resourceMap[$resourceArray['id']] = $resourceArray; + } + + // 构建父子关系 + foreach ($resourceMap as $id => &$node) { + if ($node['parent_id'] == 0) { + // 根节点 + $tree[] = &$node; + } else { + // 子节点 + if (isset($resourceMap[$node['parent_id']])) { + if (!isset($resourceMap[$node['parent_id']]['children'])) { + $resourceMap[$node['parent_id']]['children'] = []; + } + $resourceMap[$node['parent_id']]['children'][] = &$node; + } else { + // 父节点不存在，作为根节点处理 + $tree[] = &$node; + } + } + } + unset($node); + + return $tree; + } + + /** + * 获取扁平化的资源列表 + * + * @param array $conditions 筛选条件 + * @return array + */ + public function getResourceList($table = 'resources', array $conditions = []): array + { + $query = Db::table($table)->where($conditions); + + // 按排序字段排序 + $resources = $query->orderBy('sort')->orderBy('id')->get(); + + // 转换为数组 + $resourceList = []; + foreach ($resources as $resource) { + $resourceList[] = (array) $resource; + } + + return $resourceList; + } + + + /** + * 递归插入资源树 + */ + private function insertResourceTree($table, $tree, $parentId, $keys = []) + { + $keys = ['system_id','name','desc','type','code','parent_id','url','icon','open_type','link', + 'is_hide','is_hide_tab','no_auth','is_home','instance','keep_alive','sort','status']; + foreach ($tree as $item) { + // 保存子节点 + $children = $item['children'] ?? []; + + // 过滤字段 + $filteredItem = []; + foreach ($item as $k => $v) { + if (in_array($k, $keys)) { + $filteredItem[$k] = $v; + } + } + + // 设置parent_id + $filteredItem['parent_id'] = $parentId; + + // 插入并获取新ID + $newId = Db::table($table)->insertGetId($filteredItem); + echo "插入节点: {$filteredItem['name']}, 新ID: $newId\n"; + + // 递归处理子节点 + if (!empty($children)) { + $this->insertResourceTree($table, $children, $newId, $keys); + } + } + } + + + public function do(string $from = 'resources_20250916_bak', string $to = 'resources_yuanshi', array $where = []) + { + try { + // 开启事务 + Db::beginTransaction(); + + // 查询迁移资源的树状结果集 + $list = $this->getFullResourceTreeOptimized($from, $where); + + // 入库字段 + $keys = ['system_id','name','desc','type','code','parent_id','url','icon','open_type','link', + 'is_hide','is_hide_tab','no_auth','is_home','instance','keep_alive','sort','status']; + + // 使用递归处理树结构 + $this->insertResourceTree($to, $list, 0, $keys); + + // 提交事务 + Db::commit(); + + echo "数据插入成功"; + + } catch (\Exception $e) { + // 回滚事务 + Db::rollBack(); + + echo "数据插入失败: " . $e->getMessage() . " 在文件 " . $e->getFile() . " 第 " . $e->getLine() . " 行"; + } + } +} \ No newline at end of file diff --git a/app/controller/IndexController.php b/app/controller/IndexController.php index b99ead4..a05463a 100644 --- a/app/controller/IndexController.php +++ b/app/controller/IndexController.php @@ -2,6 +2,7 @@ namespace app\controller; +use app\common\model\Resource; use app\common\service\SysDictService; use app\common\service\UploadService; use app\common\utils\scaffold\Generate; @@ -97,71 +98,58 @@ class IndexController } + public function test2(Request $request) + { + $where[] = ['id', '>', 141]; + $list = (new \app\common\utils\MigrationResources())->getFullResourceTreeOptimized('resources', $where); + + + $keys = ['system_id','name','desc','type','code','parent_id','url','icon','open_type','link', + 'is_hide','is_hide_tab','no_auth','is_home','instance','keep_alive','sort','status']; + foreach ($list as $key=>$item) { + + + $temp = []; + + foreach ($item as $k=>$v) { + + if (isset($item['children']) && count($item['children']) > 0) { + $temp = $item['children']; + } + + if (!in_array($k, $keys)) { + unset($item[$k]); + } + + $id = Db::table('resources')->insertGetId($item); + + if ($temp) { + foreach ($temp as $kc=>$vc) { + + foreach ($vc as $kk => $vv) { + if (!in_array($kk, $keys)) { + unset($vc[$kk]); + } + } + + $vc['parent_id'] = $id; + + Db::table('resources')->insert($vc); + } + + } + + } + } + } + + + public function test(Request $request) { + // 菜单迁移 + $where[] = ['id', '>', 141]; + $list = (new \app\common\utils\MigrationResources())->do('resources_20250916_bak', 'resources_yuanshi', $where); - - // $flowType = 'stock_orders'; - // $bizType = 'stock_orders'; - // $bizId = 32; - // $formData = []; - // $initiatorId = 74; - - // $appro = new \app\common\utils\approval\service\ApprovalFlowService(); - // // $sp = $appro->start($flowType, $bizType, $bizId, $formData, $initiatorId); - - // $sp = $appro->approve(11, 1, 'reject'); - // var_dump($sp); - - // return json([ - // 'code' => 0, - // 'msg' => 'success' - // ]); - - // $param = [ - // 'path' => public_path().'/pdf/BH20250908014.pdf', - // 'scene' => 'stock_orders', - // 'category' => 'pdf', - // 'original_name' => 'BH20250908014.pdf' - // ]; - - // $up = new UploadService(); - // $res = $up->uploadLocalFile($param); - // var_dump($res); - $param = $request->all(); - try { - // $service = new \app\crm\service\StockOrdersService(); - // $result = $service->createdPdfFile($param['id']); - // return json($result); - - // \Webman\RedisQueue\Redis::send('stock-order-pdf', ['id'=>82]); - - - // $approvalType = array_flip(\app\common\service\SysDictService::pluckKeyValueByCode('approval_type')->toArray()); - // $result = $approvalType['stock_orders']; - // var_dump($result); - - - // $list = \app\common\model\User::where('status', 1)->where('email', '!=', '')->pluck('email')->toArray(); - - // var_dump($list); - - $approvalType = array_flip(\app\common\service\SysDictService::pluckKeyValueByCode('approval_type')->toArray()); - - $title = "【审批】备货单：BH20250911001"; - $flowType = $approvalType['stock_orders']; - $content = "【审批】你有一条审批 待审批：类型 {$flowType}，业务单号 BH20250911001"; - - noticePush([ - 'title' => $title, - 'content' => $content, - 'recipient' => [1,74,78], - 'email' => 1 - ]); - } catch (\Throwable $th) { - //throw $th; - var_dump($th->getMessage().$th->getLine().$th->getFile()); - } - } } \ No newline at end of file