| | |
| | | switch (meta.type) |
| | | { |
| | | case "mpt": |
| | | return "http://{host}/SG/Imagery;" + sgsID + ".mpt"; // Elevation |
| | | return "{host}/SG/Imagery;" + sgsID + ".mpt"; // Elevation |
| | | case "3dml": |
| | | return "http://{host}/SG/b3dm/" + sgsID + "/tileset.json"; |
| | | return "{host}/SG/b3dm/" + sgsID + "/tileset.json"; |
| | | case "cpt": |
| | | return "{host}/SG/pnts/" + sgsID + "/tileset.json"; |
| | | default: |
| | | return string.Empty; |
| | | } |
| | |
| | | /// </summary> |
| | | /// <param name="args">XYZ参数</param> |
| | | /// <returns>行数</returns> |
| | | public int Release(XYZArgs args, ref string err) |
| | | public List<int> Release(XYZArgs args, ref string err) |
| | | { |
| | | List<SysMeta> list = XYZUtils.SelectMetas(args.ids, "and type in ('mpt', '3dml')"); |
| | | if (null == list || list.Count == 0) return 0; |
| | | List<SysMeta> list = XYZUtils.SelectMetas(args.ids, "and type in ('mpt', '3dml', 'cpt')"); |
| | | if (null == list || list.Count == 0) return null; |
| | | |
| | | int maxId = GetMaxId(); // maxId = 411576; |
| | | //int maxId = GetMaxId(); // maxId = 411576; |
| | | RomoveNoneFiles(list); |
| | | if (list.Count == 0) return 0; |
| | | if (list.Count == 0) return null; |
| | | |
| | | //err = LinkFiles(list); |
| | | //if (!string.IsNullOrEmpty(err)) return 0; |
| | | Tools.SetIsModel(args, list); |
| | | MoveFiles(list); |
| | | |
| | | int count = 0; |
| | | string names = GetNames(list); |
| | | for (int i = 0; i < 25; i++) |
| | | SysTask task = CreateTask(args, list); |
| | | task.pid = 0; |
| | | task.id = TaskDBHelper.Insert(task); |
| | | |
| | | //string names = GetNames(list); |
| | | string sql = getSql(list); |
| | | for (int i = 0; i < 61; i++) |
| | | { |
| | | Thread.Sleep(3000); |
| | | |
| | | List<SpatialItem> items = SelectItems(names); |
| | | //List<SpatialItem> items = SelectItems(names); |
| | | List<SpatialItem> items = SelectItemsBySql(sql); |
| | | if (null == items || items.Count == 0) continue; |
| | | |
| | | InsertInto(list, items, args); |
| | | count = items.Count; |
| | | break; |
| | | task = TaskDBHelper.SelectById(task.id); |
| | | if (null != task && task.status < 2) |
| | | { |
| | | task.status = 2; |
| | | TaskDBHelper.Update(task); |
| | | } |
| | | |
| | | return InsertInto(list, items, args); |
| | | } |
| | | |
| | | return count; |
| | | task = TaskDBHelper.SelectById(task.id); |
| | | if (null != task && task.status < 2) |
| | | { |
| | | task.status = 4; |
| | | task.err = "没有数据要发布"; |
| | | TaskDBHelper.Update(task); |
| | | } |
| | | |
| | | return null; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 创建任务 |
| | | /// </summary> |
| | | private SysTask CreateTask(XYZArgs args, List<SysMeta> list) |
| | | { |
| | | args.name = list[0].name; |
| | | for (int i = 1; i < list.Count; i++) |
| | | { |
| | | string name =args.name+ "," + list[i].name; |
| | | if (name.Length > 150) break; |
| | | |
| | | args.name = name; |
| | | } |
| | | |
| | | switch (list[0].type) |
| | | { |
| | | case "3dml": |
| | | return TaskDBHelper.CreateTask(args, "3DML", "三维模型(3DML)"); |
| | | case "cpt": |
| | | return TaskDBHelper.CreateTask(args, "CPT", "点云数据(CPT)"); |
| | | default: |
| | | return TaskDBHelper.CreateTask(args, "MPT", "场景数据(MPT)"); |
| | | } |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取查询SQL |
| | | /// </summary> |
| | | private string getSql(List<SysMeta> metas) |
| | | { |
| | | List<string> list = new List<string>(); |
| | | foreach (SysMeta meta in metas) |
| | | { |
| | | list.Add("Name like '%_" + meta.name + "'"); |
| | | } |
| | | |
| | | string filters = string.Join(" or ", list); |
| | | |
| | | |
| | | return string.Format("select id, Name, RelativePath, LayerName, DataSourceId, Description from SpatialItems where {0} order by id desc", filters); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 查询SG数据项 |
| | | /// </summary> |
| | | public List<SpatialItem> SelectItems(string names) |
| | | private List<SpatialItem> SelectItemsBySql(string sql) |
| | | { |
| | | string sql = string.Format("select id, Name, RelativePath, LayerName, DataSourceId, Description from SpatialItems where Name in ({0}) order by id desc", names); |
| | | |
| | | DataTable dt = SQLiteHelper.GetDataTable(sql); |
| | | List<SpatialItem> list = ModelHandler.FillModel<SpatialItem>(dt); |
| | | |
| | | return list; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取名称字符串 |
| | | /// </summary> |
| | | private string GetNames(List<SysMeta> metas) |
| | | { |
| | | List<string> list = new List<string>(); |
| | | foreach (SysMeta meta in metas) |
| | | { |
| | | list.Add("'" + meta.id + "_" + meta.name + "'"); |
| | | } |
| | | |
| | | return string.Join(",", list); |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | /// <summary> |
| | | /// 插入数据发布表 |
| | | /// </summary> |
| | | private void InsertInto(List<SysMeta> list, List<SpatialItem> items, XYZArgs args) |
| | | private List<int> InsertInto(List<SysMeta> list, List<SpatialItem> items, XYZArgs args) |
| | | { |
| | | List<int> ids = new List<int>(); |
| | | foreach (SysMeta meta in list) |
| | | { |
| | | IEnumerable<SpatialItem> iterator = from item in items where item.Name.Equals(meta.id + "_" + meta.name) select item; |
| | | if (null == iterator) return; |
| | | //IEnumerable<SpatialItem> iterator = from item in items where item.Name.Equals(meta.id + "_" + meta.name) select item; |
| | | IEnumerable<SpatialItem> iterator = from item in items where item.Name.Contains("_" + meta.name) select item; |
| | | if (null == iterator || 0 == iterator.Count()) return ids; |
| | | |
| | | meta.verid = iterator.First().id; |
| | | InsertToDB(meta, args); |
| | | int pubid = InsertToDB(meta, args); |
| | | |
| | | if (pubid > 0) ids.Add(pubid); |
| | | } |
| | | |
| | | return ids; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 插入数据库 |
| | | /// </summary> |
| | | private static void InsertToDB(SysMeta meta, XYZArgs args) |
| | | private static int InsertToDB(SysMeta meta, XYZArgs args) |
| | | { |
| | | if (PubDBHelper.IsPublish(meta.id)) return; |
| | | //if (PubDBHelper.IsPublish(meta.id)) return 1; |
| | | int pubid = PubDBHelper.GetPushlishId(meta.id); |
| | | if (pubid > 0) |
| | | { |
| | | PubDBHelper.UpdatePublish(pubid, meta.name, args.userId, null, GetReleaseUrl(meta, meta.verid)); |
| | | return pubid; |
| | | } |
| | | |
| | | SysPublish sys = NewPublish(meta, args); |
| | | sys.path = meta.id + "\\" + meta.name; |
| | | SysPublish sys = Tools.NewPublish(meta, args, GetReleaseUrl(meta, meta.verid), meta.id + "\\" + meta.name); |
| | | |
| | | int pubid = PubDBHelper.InsertPublish(sys); |
| | | pubid = PubDBHelper.InsertPublish(sys); |
| | | if (pubid > 0) |
| | | { |
| | | sys.id = pubid; |
| | | PubDBHelper.InsertLayer(sys, meta, sys.type == "3dml" ? 100 : 0); |
| | | PubDBHelper.InsertLayer(sys, meta); |
| | | PubDBHelper.InsertMetaPub(meta.id, pubid, args.userId); |
| | | } |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 创建数据发布类 |
| | | /// </summary> |
| | | private static SysPublish NewPublish(SysMeta meta, XYZArgs args) |
| | | { |
| | | SysPublish sp = new SysPublish(); |
| | | sp.name = meta.name; |
| | | sp.url = GetReleaseUrl(meta, meta.verid); |
| | | sp.type = meta.type; |
| | | sp.status = 3; |
| | | sp.dirid = meta.dircode; |
| | | sp.depid = args.depcode; |
| | | sp.min = 0; |
| | | sp.max = 0; |
| | | sp.json = null; |
| | | sp.create_user = args.userId; |
| | | sp.geom = null; |
| | | sp.bak = null; |
| | | |
| | | return sp; |
| | | return pubid; |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | } |
| | | } |
| | | |
| | | #region 废弃 * |
| | | /// <summary> |
| | | /// 查询SG数据项 |
| | | /// </summary> |
| | | public List<SpatialItem> SelectItems(string names) |
| | | { |
| | | string sql = string.Format("select id, Name, RelativePath, LayerName, DataSourceId, Description from SpatialItems where Name in ({0}) order by id desc", names); |
| | | |
| | | DataTable dt = SQLiteHelper.GetDataTable(sql); |
| | | List<SpatialItem> list = ModelHandler.FillModel<SpatialItem>(dt); |
| | | |
| | | return list; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取名称字符串 |
| | | /// </summary> |
| | | private string GetNames(List<SysMeta> metas) |
| | | { |
| | | List<string> list = new List<string>(); |
| | | foreach (SysMeta meta in metas) |
| | | { |
| | | list.Add("'" + meta.id + "_" + meta.name + "'"); |
| | | } |
| | | |
| | | return string.Join(",", list); |
| | | } |
| | | #endregion |
| | | |
| | | #region * 废弃 * |
| | | /// <summary> |
| | | /// 获取最大ID值 |