1

13693261870

2024-09-04 dbed0354a00fde9db87862b9f03db0fbf0d3aabc

 ExportMap/db/PubDBHelper.cs

@@ -3,6 +3,7 @@
using Npgsql;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Linq;
using System.Reflection;
@@ -12,6 +13,8 @@
{
    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";
@@ -28,7 +31,7 @@
        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)
        {
@@ -41,7 +44,7 @@
        }

        /// <summary>
        /// 是/否发布过
        /// 是/否发布过 *
        /// </summary>
        public static bool IsPublish(string dirid, string type = "DOM")
        {
@@ -52,6 +55,71 @@
            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>
@@ -70,7 +138,7 @@
        public static int InsertPublish(SysPublish sys)
        {
            List<DbParameter> list = Tools.GetParams<SysPublish>(insertPublishSql, sys);
            string sql = string.Format(insertPublishSql, sys.geom == null ? "null" : sys.geom);
            string sql = string.Format(insertPublishSql, string.IsNullOrEmpty(sys.geom) ? "null" : sys.geom);

            object obj = Tools.DBHelper.GetScalar(sql, list.ToArray());

@@ -83,15 +151,17 @@
        public static int InsertLayer(SysPublish sys, SysMeta meta, double elev = 0)
        {
            int pid = SelectLayerPid(sys, meta);
            string cnName = meta.name.Split(new char[] { '.' })[0];
            string data = "mpt".Equals(meta.type) ? "自动发布地形场景" : (imgList.Contains(meta.type) ? "自动发布影像" : "自动发布模型");
            string serve = "mpt".Equals(meta.type) ? "Mpt" : (imgList.Contains(meta.type) ? "TMS" : "Tileset");
            //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", meta.name));
            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));
@@ -102,6 +172,40 @@
            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>
@@ -123,10 +227,10 @@
        /// </summary>
        public static int SelectLayerPid(SysPublish sys, SysMeta meta)
        {
            string sql = GetSelectLayerPidSql(meta);
            string sql = GetSelectLayerPidSql(meta, meta.ismeta);
            int pid = Tools.DBHelper.GetIntScalar(sql);
            string dirid = sys.dirid.Substring(0, 2);

            string dirid = string.IsNullOrWhiteSpace(sys.dirid) || sys.dirid.Length < 2 ? "00" : sys.dirid.Substring(0, 2);
            List<DbParameter> list = new List<DbParameter>();
            list.Add(new NpgsqlParameter("@pid", pid));
            list.Add(new NpgsqlParameter("@en_name", dirid));
@@ -149,7 +253,7 @@
        /// <summary>
        /// 获取查询图层父节点ID的SQL
        /// </summary>
        public static string GetSelectLayerPidSql(SysMeta meta)
        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)";

@@ -160,12 +264,21 @@

            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 (imgList.Contains(meta.type))
                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 "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)
@@ -178,6 +291,18 @@
        }

        /// <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)