| | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 从缓存获取指定类型的全量路由数据,缓存不存在时自动从数据库加载并写入缓存 |
| | | /// </summary> |
| | | /// <param name="routeType">路由类型(入口/出口)</param> |
| | | /// <returns>该类型的全部路由列表</returns> |
| | | private List<Dt_Router> GetAllRoutersFromCache(int routeType) |
| | | { |
| | | // 根据路由类型构建缓存Key,In类型对应"In",Out类型对应"Out" |
| | | string cacheKey = $"Router:AllRouters:{(routeType == RouterInOutType.In.ObjToInt() ? "In" : "Out")}"; |
| | | // 通过缓存服务获取数据,缓存未命中时调用工厂方法从数据库查询并写入缓存 |
| | | return _cacheService.GetOrAdd( |
| | | cacheKey, |
| | | _ => BaseDal.QueryData(x => x.InOutType == routeType) |
| | | ); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 根据起点/当前位置、终点获取下一个子节点。 |
| | | /// </summary> |
| | | /// <param name="startPosi">起点/当前位置。</param> |
| | |
| | | List<Dt_Router> routers = new List<Dt_Router>(); |
| | | try |
| | | { |
| | | // 一次性查询所有路由数据到内存 |
| | | List<Dt_Router> allRouters = BaseDal.QueryData(x => true); |
| | | // 从缓存加载入口类型的所有路由数据 |
| | | List<Dt_Router> allRouters = GetAllRoutersFromCache(RouterInOutType.In.ObjToInt()); |
| | | // 从缓存加载出口类型的所有路由数据 |
| | | List<Dt_Router> outRouters = GetAllRoutersFromCache(RouterInOutType.Out.ObjToInt()); |
| | | // 合并入口和出口路由数据 |
| | | allRouters.AddRange(outRouters); |
| | | |
| | | // 在内存中进行路径搜索 |
| | | routers = FindRoutesInMemory(startPosi, endPosi, allRouters, null); |
| | |
| | | List<Dt_Router> routers = new List<Dt_Router>(); |
| | | try |
| | | { |
| | | // 一次性查询指定类型的所有路由数据到内存 |
| | | List<Dt_Router> allRouters = BaseDal.QueryData(x => x.InOutType == routeType); |
| | | // 从缓存加载指定类型的所有路由数据 |
| | | List<Dt_Router> allRouters = GetAllRoutersFromCache(routeType); |
| | | |
| | | // 在内存中进行路径搜索 |
| | | routers = FindRoutesInMemory(startPosi, endPosi, allRouters, routeType); |