using ExportMap.cs;
|
using ExportMap.Models;
|
using Npgsql;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.Common;
|
using System.Linq;
|
using System.Reflection;
|
using System.Web;
|
|
namespace ExportMap.db
|
{
|
public class PubDBHelper
|
{
|
private static List<string> lasList = new List<string>() { "cpt", "las", "laz" };
|
|
private static List<string> imgList = new List<string>() { "jpg", "png", "img", "tif", "tiff" };
|
|
private static string insertPublishSql = "insert into lf.sys_publish(name, url, path, type, status, dirid, depid, min, max, json, create_user, geom, bak) values (@name, @url, @path, @type, @status, @dirid, @depid, @min, @max, @json, @create_user, {0}, @bak) returning id";
|
|
private static string insertMetaPubSql = "insert into lf.sys_meta_pub (metaid, pubid, create_user) select {0}, {1}, {2} from (select 1) temp where not exists (select 1 from lf.sys_meta_pub where metaid = {0} and pubid = {1})";
|
|
// 模型-@cnName，model-@enName，自动发布模型-@name，http:// - @url，Tileset-@serve，1-@user，7-@pubid
|
private static string insertLayerSql = "insert into lf.sys_layer (pid, cn_name, en_name, url, type, level, order_num, is_show, create_user, data_type, serve_type, pubid, elev) values (@pid, @cnName, @enName, @url, 2, (select coalesce(level, 0) + 1 from lf.sys_layer where id = @pid), (select coalesce(max(order_num), 0) + 1 from lf.sys_layer where pid = @pid), 0, @user, @data, @serve, @pubid, @elev)";
|
|
private static string insertParentLayer = "insert into lf.sys_layer (pid, cn_name, en_name, type, level, order_num, is_show, create_user, data_type, is_project) values (@pid, (select name from lf.sys_dir where code = @code), @en_name, 1, (select coalesce(level, 0) + 1 from lf.sys_layer where id = @pid), (select coalesce(max(order_num), 0) + 1 from lf.sys_layer where pid = @pid), 0, @create_user, (select data_type from lf.sys_layer where id = @pid), 1) returning id";
|
|
private static string updateMetaSql = "update lf.sys_meta set path = @path where id = @id";
|
|
private static string selectLayerSql = "select id from lf.sys_layer where pid = @pid and en_name = @en_name";
|
|
/// <summary>
|
/// 是/否发布过 *
|
/// </summary>
|
public static bool IsPublish(int metaid)
|
{
|
string sql = "select count(*) from lf.sys_meta_pub a inner join lf.sys_publish b on a.pubid = b.id where a.metaid = " + metaid;
|
|
object obj = Tools.DBHelper.GetScalar(sql);
|
int count = obj == null ? 0 : Convert.ToInt32(obj);
|
|
return count > 0;
|
}
|
|
/// <summary>
|
/// 是/否发布过 *
|
/// </summary>
|
public static bool IsPublish(string dirid, string type = "DOM")
|
{
|
string sql = string.Format("select count(*) from lf.sys_meta_pub a inner join lf.sys_publish b on a.pubid = b.id where b.type = '{0}' and b.dirid = @dirid", type);
|
DbParameter dp = new NpgsqlParameter("@dirid", dirid);
|
|
object obj = Tools.DBHelper.GetScalar(sql, dp);
|
int count = obj == null ? 0 : Convert.ToInt32(obj);
|
|
return count > 0;
|
}
|
|
/// <summary>
|
/// 获取发布ID
|
/// </summary>
|
public static int GetPushlishId(int metaid)
|
{
|
string sql = string.Format("select pubid from lf.sys_meta_pub where metaid={0} order by id desc limit 1", metaid);
|
object obj = Tools.DBHelper.GetScalar(sql);
|
|
return null == obj ? 0 : Convert.ToInt32(obj);
|
}
|
|
/// <summary>
|
/// 获取发布ID
|
/// </summary>
|
public static int GetPushlishId(string dirid, string type = "DOM")
|
{
|
string sql = string.Format("select b.id from lf.sys_publish b where b.type = '{0}' and b.dirid = '{1}' limit 1", type, dirid);
|
object obj = Tools.DBHelper.GetScalar(sql);
|
|
return null == obj ? 0 : Convert.ToInt32(obj);
|
}
|
|
/// <summary>
|
/// 获取已经发布的元数据ID
|
/// </summary>
|
public static List<int> GetPublishMetaId(int pubid)
|
{
|
string sql = string.Format("select metaid from lf.sys_meta_pub where pubid = {0}", pubid);
|
DataTable dt = Tools.DBHelper.GetDataTable(sql);
|
|
List<int> list = new List<int>();
|
if (null == dt || 0 == dt.Rows.Count) return list;
|
|
for (int i = 0, c = dt.Rows.Count; i < c; i++)
|
{
|
object obj = dt.Rows[i][0];
|
if (null != obj)
|
{
|
int id = 0;
|
if (int.TryParse(obj.ToString(), out id))
|
{
|
list.Add(id);
|
}
|
}
|
}
|
|
return list;
|
}
|
|
/// <summary>
|
/// 更新发布数据
|
/// </summary>
|
public static int UpdatePublish(int pubid, string name, int userId, string geom, string url = null)
|
{
|
string str = null == geom ? "" : string.Format(", geom={0}", geom);
|
str += null == url ? "" : string.Format(", url='{0}'", url);
|
string sql = string.Format("update lf.sys_publish set name=@name, update_user=@userId, update_time=now(){0} where id=@id;update lf.sys_layer set cn_name=@name where pubid=@id;", str);
|
|
DbParameter dp1 = new NpgsqlParameter("@name", name);
|
DbParameter dp2 = new NpgsqlParameter("@userId", userId);
|
DbParameter dp3 = new NpgsqlParameter("@id", pubid);
|
|
return Tools.DBHelper.ExecuteNonQuery(sql, dp1, dp2, dp3);
|
}
|
|
/// <summary>
|
/// 插入元数据-数据发布表记录
|
/// </summary>
|
public static int InsertMetaPub(int metaid, int pubid, int userId)
|
{
|
string sql = string.Format(insertMetaPubSql, metaid, pubid, userId);
|
|
return Tools.DBHelper.ExecuteNonQuery(sql);
|
}
|
|
/// <summary>
|
/// 插入数据发布表记录
|
/// </summary>
|
public static int InsertPublish(SysPublish sys)
|
{
|
List<DbParameter> list = Tools.GetParams<SysPublish>(insertPublishSql, sys);
|
string sql = string.Format(insertPublishSql, string.IsNullOrEmpty(sys.geom) ? "null" : sys.geom);
|
|
object obj = Tools.DBHelper.GetScalar(sql, list.ToArray());
|
|
return obj == null ? 0 : Convert.ToInt32(obj);
|
}
|
|
/// <summary>
|
/// 插入图层表记录
|
/// </summary>
|
public static int InsertLayer(SysPublish sys, SysMeta meta, double elev = 0)
|
{
|
int pid = SelectLayerPid(sys, meta);
|
//string cnName = meta.name.Split(new char[] { '.' })[0];
|
int idx = meta.name.LastIndexOf(".");
|
string cnName = idx == -1 ? meta.name : meta.name.Substring(0, meta.name.LastIndexOf("."));
|
string data = getData(meta);
|
string serve = getServe(meta);
|
|
// @pid, @cnName, @enName, @url, @user, @data, @serve, @pubid, @elev
|
List<DbParameter> list = new List<DbParameter>();
|
list.Add(new NpgsqlParameter("@pid", pid));
|
list.Add(new NpgsqlParameter("@cnName", cnName));
|
list.Add(new NpgsqlParameter("@enName", sys.dirid));
|
list.Add(new NpgsqlParameter("@url", sys.url));
|
list.Add(new NpgsqlParameter("@user", sys.create_user));
|
list.Add(new NpgsqlParameter("@data", data));
|
list.Add(new NpgsqlParameter("@serve", serve));
|
list.Add(new NpgsqlParameter("@pubid", sys.id));
|
list.Add(new NpgsqlParameter("@elev", elev));
|
|
int rows = Tools.DBHelper.ExecuteNonQuery(insertLayerSql, list.ToArray());
|
|
return rows;
|
}
|
|
/// <summary>
|
/// 获取图层数据
|
/// </summary>
|
private static string getData(SysMeta meta)
|
{
|
// "mpt".Equals(meta.type) ? "自动发布地形场景" : (imgList.Contains(meta.type) ? "自动发布影像" : "自动发布模型");
|
|
if ("mpt".Equals(meta.type)) return "自动发布地形场景";
|
|
if ("DEM".Equals(meta.type)) return "自动发布地形";
|
|
if ("DOM".Equals(meta.type)) return "自动发布影像";
|
|
return "自动发布模型";
|
}
|
|
/// <summary>
|
/// 获取图层服务
|
/// </summary>
|
private static string getServe(SysMeta meta)
|
{
|
// "mpt".Equals(meta.type) ? "Mpt" : (imgList.Contains(meta.type) ? "TMS" : "Tileset");
|
|
if ("mpt".Equals(meta.type)) return "Mpt";
|
|
if ("DEM".Equals(meta.type)) return "DEM";
|
|
if ("DOM".Equals(meta.type)) return "TMS";
|
|
if ("3dml".Equals(meta.type) || "cpt".Equals(meta.type)) return "3DML";
|
|
return "Tileset";
|
}
|
|
/// <summary>
|
/// 更新元数据文件路径
|
/// </summary>
|
public static int UpdateMetaPath(SysMeta meta)
|
{
|
List<DbParameter> list = new List<DbParameter>();
|
list.Add(new NpgsqlParameter("@id", meta.id));
|
list.Add(new NpgsqlParameter("@path", meta.path));
|
|
int rows = Tools.DBHelper.ExecuteNonQuery(updateMetaSql, list.ToArray());
|
|
return rows;
|
}
|
|
/// <summary>
|
/// 查询图层父节点ID
|
/// </summary>
|
public static int SelectLayerPid(SysPublish sys, SysMeta meta)
|
{
|
string sql = GetSelectLayerPidSql(meta, meta.ismeta);
|
int pid = Tools.DBHelper.GetIntScalar(sql);
|
string dirid = sys.dirid.Substring(0, 2);
|
|
List<DbParameter> list = new List<DbParameter>();
|
list.Add(new NpgsqlParameter("@pid", pid));
|
list.Add(new NpgsqlParameter("@en_name", dirid));
|
|
int layerId = Tools.DBHelper.GetIntScalar(selectLayerSql, list.ToArray());
|
if (0 == layerId)
|
{
|
List<DbParameter> args = new List<DbParameter>();
|
args.Add(new NpgsqlParameter("@pid", pid));
|
args.Add(new NpgsqlParameter("@code", dirid));
|
args.Add(new NpgsqlParameter("@en_name", dirid));
|
args.Add(new NpgsqlParameter("@create_user", sys.create_user));
|
|
layerId = Tools.DBHelper.GetIntScalar(insertParentLayer, args.ToArray());
|
}
|
|
return layerId;
|
}
|
|
/// <summary>
|
/// 获取查询图层父节点ID的SQL
|
/// </summary>
|
public static string GetSelectLayerPidSql(SysMeta meta, int isModel)
|
{
|
string noneSql = "select id from lf.sys_layer where cn_name = '其他' and pid = (select id from lf.sys_layer where cn_name = '工程数据' order by pid limit 1)";
|
|
if (string.IsNullOrWhiteSpace(meta.dirname)) return noneSql;
|
|
if (meta.dirname.IndexOf("\\勘察") > -1)
|
return "select id from lf.sys_layer where cn_name = '三维地质模型' and pid = (select id from lf.sys_layer where cn_name = '勘察' order by pid limit 1)";
|
|
if (meta.dirname.IndexOf("\\测绘") > -1)
|
{
|
if (lasList.Contains(meta.type))
|
return "select id from lf.sys_layer where cn_name = '点云数据' and pid = (select id from lf.sys_layer where cn_name = '测绘' order by pid limit 1)";
|
if ("osgb".Equals(meta.type))
|
return "select id from lf.sys_layer where cn_name = '倾斜摄影数据' and pid = (select id from lf.sys_layer where cn_name = '测绘' order by pid limit 1)";
|
if ("mpt".Equals(meta.type))
|
return "select id from lf.sys_layer where cn_name = '三维地形模型' and pid = (select id from lf.sys_layer where cn_name = '测绘' order by pid limit 1)";
|
if ("DEM".Equals(meta.type))
|
return "select id from lf.sys_layer where cn_name = '数字高程模型' and pid = (select id from lf.sys_layer where cn_name = '测绘' order by pid limit 1)";
|
if ("DOM".Equals(meta.type))
|
return "select id from lf.sys_layer where cn_name = '数字正射影像图' and pid = (select id from lf.sys_layer where cn_name = '测绘' order by pid limit 1)";
|
else
|
{
|
//return "select id from lf.sys_layer where cn_name = '单体模型' and pid = (select id from lf.sys_layer where cn_name = '测绘' order by pid limit 1)";
|
return string.Format("select id from lf.sys_layer where cn_name = '{0}' and pid = (select id from lf.sys_layer where cn_name = '测绘' order by pid limit 1)", isModel > 0 ? "单体模型" : "倾斜摄影数据");
|
}
|
}
|
|
if (meta.dirname.IndexOf("\\地灾") > -1)
|
return "select id from lf.sys_layer where cn_name = '三维地质模型' and pid = (select id from lf.sys_layer where cn_name = '地灾' order by pid limit 1)";
|
|
if (meta.dirname.IndexOf("\\洞库") > -1)
|
return "select id from lf.sys_layer where cn_name = '洞库模型' and pid = (select id from lf.sys_layer where cn_name = '洞库' order by pid limit 1)";
|
|
return noneSql;
|
}
|
|
/// <summary>
|
/// 查询发布数据
|
/// </summary>
|
public static List<SysPublish> SelectPublishs(List<int> ids)
|
{
|
string sql = string.Format("select id, name, url, path, type, status, dirid, depid, min, max, json, create_user, create_time, update_user, update_time, st_astext(geom) geom, bak from lf.sys_publish where id in ({0}) order by id desc", string.Join(",", ids));
|
DataTable dt = Tools.DBHelper.GetDataTable(sql);
|
List<SysPublish> list = ModelHandler.FillModel<SysPublish>(dt);
|
|
return list;
|
}
|
|
/// <summary>
|
/// 获取参数列表
|
/// </summary>
|
public static List<DbParameter> GetParams<T>(string sql, T t)
|
{
|
List<DbParameter> list = new List<DbParameter>();
|
Type tType = typeof(T);
|
BindingFlags flags = BindingFlags.Public | BindingFlags.IgnoreCase | BindingFlags.Instance;
|
|
int start = sql.IndexOf("@");
|
while (start != -1)
|
{
|
int end = sql.IndexOf(",", start);
|
if (end == -1) end = sql.IndexOf(")", start);
|
if (end == -1) end = sql.IndexOf(" ", start);
|
if (end == -1) end = sql.Length;
|
|
string name = sql.Substring(start + 1, end - start - 1);
|
PropertyInfo pi = tType.GetProperty(name, flags);
|
if (pi != null)
|
{
|
object value = pi.GetValue(t, null);
|
DbParameter dp = new NpgsqlParameter("@" + name, value);
|
list.Add(dp);
|
}
|
|
start = sql.IndexOf("@", end);
|
}
|
|
return list;
|
}
|
}
|
}
|
