1004 lines
37 KiB
C#
1004 lines
37 KiB
C#
|
using System.Data;
|
|||
|
|
using System.IO.Compression;
|
|||
|
|
using System.Text;
|
|||
|
|
using Infrastructure;
|
|||
|
|
using Infrastructure.Extensions;
|
|||
|
|
using Microsoft.Extensions.Options;
|
|||
|
|
using NetTopologySuite;
|
|||
|
|
using NetTopologySuite.Geometries;
|
|||
|
|
using NetTopologySuite.IO;
|
|||
|
|
using NetTopologySuite.IO.Esri;
|
|||
|
|
using NPOI.HSSF.UserModel;
|
|||
|
|
using NPOI.SS.UserModel;
|
|||
|
|
using NPOI.XSSF.UserModel;
|
|||
|
|
using OpenAuth.App.BaseApp.Base;
|
|||
|
|
using OpenAuth.App.BasicQueryService;
|
|||
|
|
using OpenAuth.App.FormScheme;
|
|||
|
|
using OpenAuth.App.FormScheme.FormHelpers;
|
|||
|
|
using OpenAuth.App.Interface;
|
|||
|
|
using OpenAuth.App.Request;
|
|||
|
|
using OpenAuth.App.Response;
|
|||
|
|
using OpenAuth.App.ServiceApp.ShpGeo.Request;
|
|||
|
|
using OpenAuth.App.ServiceApp.ShpGeo.Utils;
|
|||
|
|
using OpenAuth.Repository;
|
|||
|
|
using OpenAuth.Repository.Domain;
|
|||
|
|
using SqlSugar;
|
|||
|
|
using Shapefile = NetTopologySuite.IO.Esri.Shapefile;
|
|||
|
|
|
|||
|
|
namespace OpenAuth.App.ServiceApp.ShpGeo;
|
|||
|
|
|
|||
|
|
public class ShpGeoLayerApp : SqlSugarBaseApp<ShpGeoLayer, SugarDbContext>
|
|||
|
|
{
|
|||
|
|
private readonly string _filePath;
|
|||
|
|
private readonly ISqlSugarClient _client;
|
|||
|
|
CommonDataManager _commonDataManager;
|
|||
|
|
public ShpGeoLayerApp(ISugarUnitOfWork<SugarDbContext> unitWork,
|
|||
|
|
ISimpleClient<ShpGeoLayer> repository, IAuth auth, FormSchemeApp formSchemeApp,
|
|||
|
|
IOptions<AppSetting> setOptions, ISqlSugarClient client, CommonDataManager commonDataManager) : base(unitWork, repository, auth)
|
|||
|
|
{
|
|||
|
|
_client = client;
|
|||
|
|
_filePath = setOptions.Value.UploadPath;
|
|||
|
|
if (string.IsNullOrEmpty(_filePath))
|
|||
|
|
{
|
|||
|
|
_filePath = AppContext.BaseDirectory;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
_commonDataManager = commonDataManager;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 添加geo图层
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="obj"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
/// <exception cref="Exception"></exception>
|
|||
|
|
public async Task<Response<bool>> Add(ShpGeoLayerShpReq obj)
|
|||
|
|
{
|
|||
|
|
var record = obj.MapTo<ShpGeoLayer>();
|
|||
|
|
record.CreateTime = DateTime.Now;
|
|||
|
|
record.UpdateTime = DateTime.Now;
|
|||
|
|
record.Id = Guid.NewGuid().ToString();
|
|||
|
|
using var db = Repository.AsSugarClient();
|
|||
|
|
if (db.DbMaintenance.IsAnyTable(obj.DataTable, false))
|
|||
|
|
{
|
|||
|
|
throw new Exception(obj.DataTable + "数据表已存在");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var layer = await Repository.AsQueryable().Where(a => a.DataTable.Equals(obj.DataTable)).FirstAsync();
|
|||
|
|
if (layer != null)
|
|||
|
|
{
|
|||
|
|
throw new Exception($"图层记录数据表名{obj.DataTable}已存在");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 发布图层
|
|||
|
|
if (record.DataSourceType.Equals("shp"))
|
|||
|
|
{
|
|||
|
|
/*
|
|||
|
|
// 相对路径
|
|||
|
|
var sldFile = record.AppendPath;
|
|||
|
|
// 取得全路径
|
|||
|
|
var sldPath = Path.Combine(_filePath, sldFile);
|
|||
|
|
// 处理SLD
|
|||
|
|
var isSuccess = await GeoUtil.PublishSldStyle(sldPath, obj.DataTable);
|
|||
|
|
if (!isSuccess)
|
|||
|
|
{
|
|||
|
|
throw new Exception("SLD样式发布失败");
|
|||
|
|
}*/
|
|||
|
|
|
|||
|
|
var response = await CreateDataTable(obj);
|
|||
|
|
if (!response.Result)
|
|||
|
|
{
|
|||
|
|
throw new Exception("创建shp数据表失败");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 配置存储仓库及发布图层
|
|||
|
|
//var sldName = Path.GetFileName(sldFile);
|
|||
|
|
//var sldName = Path.GetFileNameWithoutExtension(sldFile);
|
|||
|
|
var result =
|
|||
|
|
await GeoUtil.CreateStoreAndLayer("", obj.SpatialRef, obj.DataTable, obj.StyleName);
|
|||
|
|
if (!result)
|
|||
|
|
{
|
|||
|
|
db.DbMaintenance.DropTable(obj.DataTable);
|
|||
|
|
throw new Exception("发布图层失败");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else // excel
|
|||
|
|
{
|
|||
|
|
var excelPath = Path.Combine(_filePath, obj.ShpPath);
|
|||
|
|
var excelFileName = Path.GetFileNameWithoutExtension(excelPath);
|
|||
|
|
// xls xlsx
|
|||
|
|
// 使用NPOI读取Excel文件
|
|||
|
|
using (var fileStream = new FileStream(excelPath, FileMode.Open, FileAccess.Read))
|
|||
|
|
{
|
|||
|
|
IWorkbook workbook;
|
|||
|
|
if (Path.GetExtension(excelPath).Equals(".xls"))
|
|||
|
|
{
|
|||
|
|
workbook = new HSSFWorkbook(fileStream);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
workbook = new XSSFWorkbook(fileStream);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var sheet = workbook.GetSheetAt(0);
|
|||
|
|
// 获取总行数
|
|||
|
|
var rowCount = sheet.LastRowNum;
|
|||
|
|
if (rowCount < 3)
|
|||
|
|
{
|
|||
|
|
throw new Exception("只有两行表头");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 获取总列数
|
|||
|
|
var columnCount = sheet.GetRow(0).LastCellNum;
|
|||
|
|
var headers = new List<DataTableAttr>();
|
|||
|
|
// 遍历表头
|
|||
|
|
var chineseRow = sheet.GetRow(0);
|
|||
|
|
var englishRow = sheet.GetRow(1);
|
|||
|
|
|
|||
|
|
for (var j = 0; j < columnCount; j++)
|
|||
|
|
{
|
|||
|
|
var header = new DataTableAttr
|
|||
|
|
{
|
|||
|
|
InitName = chineseRow.GetCell(j).ToString(),
|
|||
|
|
RefName = englishRow.GetCell(j).ToString()?.ToLower(),
|
|||
|
|
// 字段类型
|
|||
|
|
Type = "string",
|
|||
|
|
// 原始字段名称
|
|||
|
|
Name = englishRow.GetCell(j).ToString(),
|
|||
|
|
// 字段长度
|
|||
|
|
Length = 64
|
|||
|
|
};
|
|||
|
|
headers.Add(header);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var keys = headers.Select(a => a.RefName).ToList();
|
|||
|
|
if (!keys.Contains("lng") || !keys.Contains("lat"))
|
|||
|
|
{
|
|||
|
|
throw new Exception("缺少经纬度字段");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
var typeBuilder = db.DynamicBuilder().CreateClass(obj.DataTable,
|
|||
|
|
new SugarTable() { TableName = obj.DataTable, TableDescription = obj.ServerName + "图斑" });
|
|||
|
|
//添加主键
|
|||
|
|
typeBuilder.CreateProperty("id", typeof(string), new SugarColumn()
|
|||
|
|
{
|
|||
|
|
IsPrimaryKey = true,
|
|||
|
|
IsIdentity = false,
|
|||
|
|
ColumnDataType = "varchar",
|
|||
|
|
Length = 36,
|
|||
|
|
ColumnDescription = "主键",
|
|||
|
|
});
|
|||
|
|
//添加主键
|
|||
|
|
typeBuilder.CreateProperty("geometry", typeof(string), new SugarColumn()
|
|||
|
|
{
|
|||
|
|
IsPrimaryKey = false,
|
|||
|
|
IsIdentity = false,
|
|||
|
|
// ColumnDataType = "geometry(GEOMETRY)",
|
|||
|
|
ColumnDataType = string.Concat("geometry(GEOMETRY,",
|
|||
|
|
obj.SpatialRef.AsSpan(obj.SpatialRef.LastIndexOf(":", StringComparison.Ordinal) + 1),
|
|||
|
|
")"),
|
|||
|
|
ColumnDescription = "图斑",
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
headers.ForEach(u =>
|
|||
|
|
{
|
|||
|
|
if (!u.RefName.Equals("lng") && !u.RefName.Equals("lat"))
|
|||
|
|
{
|
|||
|
|
typeBuilder.CreateProperty(u.RefName, typeof(string), new SugarColumn()
|
|||
|
|
{
|
|||
|
|
IsPrimaryKey = false,
|
|||
|
|
IsIdentity = false,
|
|||
|
|
IsNullable = true,
|
|||
|
|
Length = u.Length,
|
|||
|
|
ColumnDescription = u.InitName,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
// 开启事务
|
|||
|
|
await db.Ado.BeginTranAsync(IsolationLevel.ReadCommitted);
|
|||
|
|
// 创建表
|
|||
|
|
db.CodeFirst.InitTables(typeBuilder.BuilderType());
|
|||
|
|
|
|||
|
|
var cols = new string[headers.Count];
|
|||
|
|
for (var i = 0; i < headers.Count; i++)
|
|||
|
|
{
|
|||
|
|
if (headers[i].RefName.Equals("lng"))
|
|||
|
|
{
|
|||
|
|
cols[i] = "geometry";
|
|||
|
|
}
|
|||
|
|
else if (headers[i].RefName.Equals("lat"))
|
|||
|
|
{
|
|||
|
|
cols[i] = "id";
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
cols[i] = headers[i].RefName;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 遍历数据行
|
|||
|
|
for (var i = 2; i < rowCount; i++)
|
|||
|
|
{
|
|||
|
|
var row = sheet.GetRow(i);
|
|||
|
|
if (row == null)
|
|||
|
|
{
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var data = new Dictionary<string, object>();
|
|||
|
|
// 遍历列
|
|||
|
|
string lat = null, lng = null;
|
|||
|
|
for (var j = 0; j < columnCount; j++)
|
|||
|
|
{
|
|||
|
|
var cell = row.GetCell(j);
|
|||
|
|
if (cell == null)
|
|||
|
|
{
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var cellValue = cell.ToString();
|
|||
|
|
switch (headers[j].RefName)
|
|||
|
|
{
|
|||
|
|
case "lat":
|
|||
|
|
lat = cellValue;
|
|||
|
|
continue;
|
|||
|
|
case "lng":
|
|||
|
|
lng = cellValue;
|
|||
|
|
continue;
|
|||
|
|
default:
|
|||
|
|
data[headers[j].RefName] = cellValue;
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (lat != null && lng != null)
|
|||
|
|
{
|
|||
|
|
var geography =
|
|||
|
|
NtsGeometryServices.Instance.CreateGeometryFactory(
|
|||
|
|
int.Parse(obj.SpatialRef.Substring(
|
|||
|
|
obj.SpatialRef.IndexOf(":", StringComparison.Ordinal) + 1)));
|
|||
|
|
var point = geography.CreatePoint(new Coordinate(double.Parse(lng), double.Parse(lat)));
|
|||
|
|
data["geometry"] = point.AsText();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
data["id"] = Guid.NewGuid().ToString();
|
|||
|
|
await db.Insertable(data)
|
|||
|
|
.AS(obj.DataTable) // 指定目标表名
|
|||
|
|
.InsertColumns(cols) // 指定要插入的列
|
|||
|
|
.ExecuteCommandAsync();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
await db.Ado.CommitTranAsync();
|
|||
|
|
// 关于图层发布失败后，如何处理？
|
|||
|
|
// excel 矢量点发布图层
|
|||
|
|
var response = await GeoUtil.CreateStoreAndLayer("", obj.SpatialRef, obj.DataTable, "");
|
|||
|
|
if (!response)
|
|||
|
|
{
|
|||
|
|
// 如果图层发布失败 删除数据表
|
|||
|
|
db.DbMaintenance.DropTable(obj.DataTable);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
workbook.Close();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var geoserver = GeoUtil.GeoserverUrl;
|
|||
|
|
var workspace = GeoUtil.Workspace;
|
|||
|
|
var storeName = GeoUtil.DbStoreName;
|
|||
|
|
var getBboxResponse = await GeoUtil.GetDBLayerBBox(workspace, storeName, obj.DataTable);
|
|||
|
|
if (getBboxResponse.Code == 200)
|
|||
|
|
{
|
|||
|
|
var bbox = getBboxResponse.Result;
|
|||
|
|
var serverUrl = $"{geoserver}/{workspace}/wms" +
|
|||
|
|
$"?service=WMS" +
|
|||
|
|
$"&version=1.1.0" +
|
|||
|
|
$"&request=GetMap" +
|
|||
|
|
$"&layers={workspace}:{obj.DataTable}" +
|
|||
|
|
$"&bbox=" + bbox +
|
|||
|
|
$"&width=768&height=619" +
|
|||
|
|
$"&srs=" + obj.SpatialRef +
|
|||
|
|
"&styles=" +
|
|||
|
|
/*$"&styles=" + (obj.DataSourceType.Equals("shp")
|
|||
|
|
? Path.GetFileName(obj.AppendPath)?.Replace(".sld", "")
|
|||
|
|
: "") +*/
|
|||
|
|
$"&format=application/openlayers";
|
|||
|
|
record.ServerUrl = serverUrl;
|
|||
|
|
var pbfUrl = $"{geoserver}/gwc/service/tms/1.0.0/{workspace}:{obj.DataTable}@{obj.SpatialRef}@pbf";
|
|||
|
|
record.PbfUrl = pbfUrl;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var settingResponse = await GeoUtil.SettingLayerReturnFormat("", obj.DataTable);
|
|||
|
|
if (!settingResponse.Result)
|
|||
|
|
{
|
|||
|
|
// 设置返回格式失败
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var flag = await Repository.InsertAsync(record);
|
|||
|
|
return new Response<bool>
|
|||
|
|
{
|
|||
|
|
Result = flag,
|
|||
|
|
Message = flag && getBboxResponse.Code == 200 ? "success" : flag ? "成功但获取serverurl失败" : "error"
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task<Response<PageInfo<List<ShpGeoLayer>>>> LoadPage(ShpGeoLayerReq req)
|
|||
|
|
{
|
|||
|
|
RefAsync<int> totalCount = 0;
|
|||
|
|
var sources = await base.Repository.AsQueryable()
|
|||
|
|
.WhereIF(!string.IsNullOrEmpty(req.SererName), a => a.ServerName.Contains(req.SererName))
|
|||
|
|
.WhereIF(!string.IsNullOrEmpty(req.startTime) && !string.IsNullOrEmpty(req.endTime), a =>
|
|||
|
|
SqlFunc.Between(a.CreateTime, Convert.ToDateTime(req.startTime),
|
|||
|
|
Convert.ToDateTime(req.endTime))) // 时间段查询
|
|||
|
|
.ToPageListAsync(req.page, req.limit, totalCount);
|
|||
|
|
|
|||
|
|
return new Response<PageInfo<List<ShpGeoLayer>>>
|
|||
|
|
{
|
|||
|
|
Result = new PageInfo<List<ShpGeoLayer>>
|
|||
|
|
{
|
|||
|
|
Items = sources,
|
|||
|
|
Total = totalCount
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public ShpGeoLayer Get(string id)
|
|||
|
|
{
|
|||
|
|
return Repository.GetById(id);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private static async Task UnZip(string zipFilePath, string extractPath)
|
|||
|
|
{
|
|||
|
|
await Task.Run(() =>
|
|||
|
|
{
|
|||
|
|
Directory.CreateDirectory(extractPath);
|
|||
|
|
// 设置字符编码
|
|||
|
|
Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);
|
|||
|
|
var gbk = Encoding.GetEncoding("utf-8");
|
|||
|
|
using (var archive = ZipFile.OpenRead(zipFilePath))
|
|||
|
|
{
|
|||
|
|
// 列举ZIP文件中的条目
|
|||
|
|
foreach (var entry in archive.Entries)
|
|||
|
|
{
|
|||
|
|
var xxx = gbk.GetString(Encoding.Default.GetBytes(entry.FullName));
|
|||
|
|
Console.WriteLine(xxx);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 提取ZIP文件中的所有文件到指定目录
|
|||
|
|
|
|||
|
|
foreach (var entry in archive.Entries)
|
|||
|
|
{
|
|||
|
|
if (entry.Name != string.Empty)
|
|||
|
|
{
|
|||
|
|
// 确保完整路径存在 entry.FullName 是否可以编码
|
|||
|
|
var fixedEntryName = entry.FullName.Replace("/", "");
|
|||
|
|
var destinationPath = Path.GetFullPath(Path.Combine(extractPath, fixedEntryName));
|
|||
|
|
Console.WriteLine("解压文件路径：" + destinationPath);
|
|||
|
|
if (!destinationPath.StartsWith(Path.GetFullPath(extractPath) + Path.DirectorySeparatorChar))
|
|||
|
|
{
|
|||
|
|
throw new UnauthorizedAccessException("试图提取的文件超出了目标文件夹的路径边界。");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 提取条目到目标路径
|
|||
|
|
entry.ExtractToFile(destinationPath, overwrite: true);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 遍历解压目录，是否有shp后缀的文件
|
|||
|
|
if (!Directory.Exists(extractPath))
|
|||
|
|
{
|
|||
|
|
throw new Exception("文件解压失败");
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private static void DeleteFile(string extractPath)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
// 递归删除目录和其内容
|
|||
|
|
Directory.Delete(extractPath, true);
|
|||
|
|
Console.WriteLine("解压目录删除成功");
|
|||
|
|
}
|
|||
|
|
catch (IOException ex)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("解压目录不能删除: " + ex.Message);
|
|||
|
|
}
|
|||
|
|
catch (UnauthorizedAccessException ex)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("没有权限删除解压目录: " + ex.Message);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
private static string MapDbaseTypeToPostgresString(char dbaseType)
|
|||
|
|
{
|
|||
|
|
return dbaseType switch
|
|||
|
|
{
|
|||
|
|
'C' => "varchar",
|
|||
|
|
'N' => "numeric",
|
|||
|
|
'L' => "boolean",
|
|||
|
|
'D' => "date",
|
|||
|
|
'M' => "text",
|
|||
|
|
_ => "varchar"
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
public async Task<Response<bool>> Test(string tableName, string serverName, string srid, string shpPath)
|
|||
|
|
{
|
|||
|
|
using var db = Repository.AsSugarClient();
|
|||
|
|
|
|||
|
|
// 校验 表是否存在
|
|||
|
|
var isExists = db.DbMaintenance.IsAnyTable(tableName, false);
|
|||
|
|
if (isExists)
|
|||
|
|
{
|
|||
|
|
//throw new Exception(tableName + "该数据库表已存在");
|
|||
|
|
db.DbMaintenance.DropTable(tableName);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var shpGeoLayer = await db.Queryable<ShpGeoLayer>()
|
|||
|
|
.Where(c => c.ServerName.Equals(serverName))
|
|||
|
|
.FirstAsync();
|
|||
|
|
if (!shpGeoLayer.IsNullOrEmpty())
|
|||
|
|
{
|
|||
|
|
throw new Exception("服务名已存在");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 插入图斑数据
|
|||
|
|
shpPath = Path.Combine(_filePath, shpPath);
|
|||
|
|
var extractPath = shpPath.Substring(0, shpPath.LastIndexOf(".", StringComparison.Ordinal)) + "extract";
|
|||
|
|
await UnZip(shpPath, extractPath);
|
|||
|
|
var searchPattern = "*.shp"; // 设置你想要遍历的文件后缀名
|
|||
|
|
var fileName = Directory.GetFiles(extractPath, searchPattern, SearchOption.AllDirectories);
|
|||
|
|
if (fileName.IsEmpty())
|
|||
|
|
{
|
|||
|
|
throw new Exception("未找到shp文件");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
string shpFileName = fileName[0];
|
|||
|
|
// shpFile 文件路径
|
|||
|
|
string shpFile = Path.Combine(extractPath, shpFileName);
|
|||
|
|
var rows = new List<Dictionary<string, object>>();
|
|||
|
|
|
|||
|
|
using (var dataReader = new ShapefileDataReader(shpFile, GeometryFactory.Default))
|
|||
|
|
{
|
|||
|
|
var headers = new List<DataTableAttr>();
|
|||
|
|
|
|||
|
|
for (var i = 0; i < dataReader.DbaseHeader.NumFields; i++)
|
|||
|
|
{
|
|||
|
|
var colAttr = new DataTableAttr();
|
|||
|
|
//colAttr.DataType = dataReader.DbaseHeader.Fields[i].Type;
|
|||
|
|
colAttr.RefName = dataReader.DbaseHeader.Fields[i].Name;
|
|||
|
|
colAttr.InitName = dataReader.DbaseHeader.Fields[i].Name;
|
|||
|
|
colAttr.Length = dataReader.DbaseHeader.Fields[i].Length;
|
|||
|
|
headers.Add(colAttr);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 创建数据表
|
|||
|
|
var typeBuilder = db.DynamicBuilder().CreateClass(tableName,
|
|||
|
|
new SugarTable() { TableName = tableName, TableDescription = serverName + "图斑" });
|
|||
|
|
//添加主键
|
|||
|
|
typeBuilder.CreateProperty("id", typeof(string), new SugarColumn()
|
|||
|
|
{
|
|||
|
|
IsPrimaryKey = true,
|
|||
|
|
IsIdentity = false,
|
|||
|
|
ColumnDataType = "varchar",
|
|||
|
|
Length = 36,
|
|||
|
|
ColumnDescription = "主键",
|
|||
|
|
});
|
|||
|
|
typeBuilder.CreateProperty("Geometry", typeof(string), new SugarColumn()
|
|||
|
|
{
|
|||
|
|
IsPrimaryKey = false,
|
|||
|
|
IsIdentity = false,
|
|||
|
|
ColumnDataType = string.Concat("geometry(GEOMETRY, ",
|
|||
|
|
srid.AsSpan(srid.LastIndexOf(":", StringComparison.Ordinal) + 1), ")"),
|
|||
|
|
ColumnDescription = "图斑",
|
|||
|
|
});
|
|||
|
|
headers.ForEach(u =>
|
|||
|
|
{
|
|||
|
|
typeBuilder.CreateProperty(u.RefName, typeof(string), new SugarColumn()
|
|||
|
|
{
|
|||
|
|
IsPrimaryKey = false,
|
|||
|
|
IsIdentity = false,
|
|||
|
|
//ColumnDataType = u.Type,
|
|||
|
|
IsNullable = true,
|
|||
|
|
Length = u.Length,
|
|||
|
|
ColumnDescription = u.InitName,
|
|||
|
|
});
|
|||
|
|
});
|
|||
|
|
// 开启事务
|
|||
|
|
await db.Ado.BeginTranAsync(IsolationLevel.ReadCommitted);
|
|||
|
|
// 创建表
|
|||
|
|
db.CodeFirst.InitTables(typeBuilder.BuilderType());
|
|||
|
|
var x = 0;
|
|||
|
|
List<string> cols = new List<string>();
|
|||
|
|
// 读取一下行数据
|
|||
|
|
while (dataReader.Read() && x++ < 20)
|
|||
|
|
{
|
|||
|
|
// 增加 id 及
|
|||
|
|
// var cols = new string[dataReader.DbaseHeader.NumFields + 2];
|
|||
|
|
var insertObj = new Dictionary<string, object>
|
|||
|
|
{
|
|||
|
|
{ "id", Guid.NewGuid().ToString() }
|
|||
|
|
};
|
|||
|
|
Console.Write("类型： " + dataReader.Geometry.GeometryType);
|
|||
|
|
// 读取一行数据
|
|||
|
|
for (int i = 0, j = 0; i < dataReader.FieldCount; i++)
|
|||
|
|
{
|
|||
|
|
cols.Add(dataReader.GetName(i));
|
|||
|
|
if (dataReader.GetName(i).ToLower().Equals("geometry"))
|
|||
|
|
{
|
|||
|
|
var geom = dataReader.GetValue(i) as Geometry;
|
|||
|
|
//var srid = geom.SRID;
|
|||
|
|
insertObj.Add(dataReader.GetName(i), geom.AsText());
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
insertObj.Add(dataReader.GetName(i), dataReader.GetValue(i));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
rows.Add(insertObj);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/*await db.Insertable(rows)
|
|||
|
|
.AS(tableName) // 指定目标表名
|
|||
|
|
//.InsertColumns(cols) // 指定要插入的列
|
|||
|
|
.ExecuteCommandAsync();*/
|
|||
|
|
var sql = "INSERT INTO \"public\".\"" + tableName + "\" (";
|
|||
|
|
// to do
|
|||
|
|
var colsStr = "";
|
|||
|
|
foreach (var key in rows.First().Keys)
|
|||
|
|
{
|
|||
|
|
colsStr += "\"" + key + "\",";
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
colsStr = colsStr.Substring(0, colsStr.Length - 1);
|
|||
|
|
sql += colsStr + ") VALUES (";
|
|||
|
|
var values = "";
|
|||
|
|
foreach (var dictionary in rows)
|
|||
|
|
{
|
|||
|
|
// todo 如何处理 geometry 类型
|
|||
|
|
foreach (var value in dictionary.Values)
|
|||
|
|
{
|
|||
|
|
values += "'" + value + "',";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
await db.Ado.ExecuteCommandAsync(sql);
|
|||
|
|
await db.Ado.CommitTranAsync();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
return new Response<bool>()
|
|||
|
|
{
|
|||
|
|
Result = true,
|
|||
|
|
Message = "ok"
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 图层更新
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="updateLayerReq"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<Response<bool>> UpdateLayer(UpdateGeoLayerShpReq updateLayerReq)
|
|||
|
|
{
|
|||
|
|
var db = Repository.AsSugarClient();
|
|||
|
|
await db.Ado.BeginTranAsync();
|
|||
|
|
var layer = await Repository.GetByIdAsync(updateLayerReq.Id);
|
|||
|
|
//var styleName = layer.StyleName; // 前面使用表名作为样式名称
|
|||
|
|
var newStyleName = updateLayerReq.StyleName;
|
|||
|
|
var result = await GeoUtil.UpdateStyle(GeoContext.Instance.Workspace, layer.DataTable, newStyleName);
|
|||
|
|
/* if (!string.IsNullOrEmpty(updateLayerReq.sldPath))
|
|||
|
|
{
|
|||
|
|
// 更新样式
|
|||
|
|
// 取得全路径
|
|||
|
|
// var sldPath = Path.Combine(_filePath, updateLayerReq.sldPath);
|
|||
|
|
var response = await GeoUtil.UpdateSldStyle(sldPath, styleName);
|
|||
|
|
if (!response)
|
|||
|
|
{
|
|||
|
|
throw new Exception("样式更新失败");
|
|||
|
|
}
|
|||
|
|
}*/
|
|||
|
|
if (!result.Result)
|
|||
|
|
{
|
|||
|
|
throw new Exception("更换样式失败");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var record = updateLayerReq.MapTo<ShpGeoLayer>();
|
|||
|
|
await db.Updateable(record).IgnoreNullColumns().ExecuteCommandAsync();
|
|||
|
|
await db.Ado.CommitTranAsync();
|
|||
|
|
return new Response<bool>()
|
|||
|
|
{
|
|||
|
|
Result = true,
|
|||
|
|
Message = "更新成功"
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 删除图层
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<Response<bool>> Delete(string id)
|
|||
|
|
{
|
|||
|
|
var db = Repository.AsSugarClient();
|
|||
|
|
await db.Ado.BeginTranAsync();
|
|||
|
|
|
|||
|
|
var shp = await Repository.GetByIdAsync(id);
|
|||
|
|
var dataTable = shp.DataTable;
|
|||
|
|
db.DbMaintenance.DropTable(dataTable);
|
|||
|
|
// todo 删除对应图层
|
|||
|
|
await db.Deleteable<ShpGeoLayer>().Where(c => c.Id.Equals(id)).ExecuteCommandAsync();
|
|||
|
|
await db.Ado.CommitTranAsync();
|
|||
|
|
return new Response<bool>()
|
|||
|
|
{
|
|||
|
|
Result = true,
|
|||
|
|
Message = "删除成功"
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task<Response<ShpInfo>> ParseShpInfo(string zipFilePath, string tableName,
|
|||
|
|
string srid)
|
|||
|
|
{
|
|||
|
|
using var db = Repository.AsSugarClient();
|
|||
|
|
// 开启事务
|
|||
|
|
|
|||
|
|
if (db.DbMaintenance.IsAnyTable(tableName))
|
|||
|
|
{
|
|||
|
|
throw new Exception("表名已存在");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 取得文件完全路径
|
|||
|
|
zipFilePath = Path.Combine(_filePath, zipFilePath);
|
|||
|
|
// 确保ZIP文件存在
|
|||
|
|
if (!File.Exists(zipFilePath))
|
|||
|
|
{
|
|||
|
|
throw new FileNotFoundException("ZIP文件未找到。");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var exist = await db.Queryable<ShpGeoLayer>()
|
|||
|
|
.Where(c => c.DataType.Equals(tableName))
|
|||
|
|
.CountAsync();
|
|||
|
|
if (exist > 0)
|
|||
|
|
{
|
|||
|
|
throw new Exception(tableName + "表名已存在");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 打开ZIP存档 取除后缀之前的字符串
|
|||
|
|
var extractPath = zipFilePath.Substring(0, zipFilePath.LastIndexOf(".", StringComparison.Ordinal)) +
|
|||
|
|
"extract";
|
|||
|
|
// 解压文件
|
|||
|
|
await UnZip(zipFilePath, extractPath);
|
|||
|
|
var searchPattern = "*.shp"; // 设置你想要遍历的文件后缀名
|
|||
|
|
var fileName = Directory.GetFiles(extractPath, searchPattern, SearchOption.AllDirectories);
|
|||
|
|
if (fileName.IsEmpty())
|
|||
|
|
{
|
|||
|
|
throw new Exception("压缩文件中无shp文件");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var shpFileName = fileName[0];
|
|||
|
|
var shpFile = Path.Combine(extractPath, shpFileName);
|
|||
|
|
var shapeType = Shapefile.GetShapeType(shpFile);
|
|||
|
|
var shpInfo = new ShpInfo();
|
|||
|
|
switch (shapeType)
|
|||
|
|
{
|
|||
|
|
case ShapeType.Point:
|
|||
|
|
shpInfo.DataType = "点";
|
|||
|
|
break;
|
|||
|
|
case ShapeType.Polygon:
|
|||
|
|
shpInfo.DataType = "面";
|
|||
|
|
break;
|
|||
|
|
case ShapeType.PolyLine:
|
|||
|
|
shpInfo.DataType = "线";
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
throw new Exception("不支持的shp类型: " + shapeType);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var attrs = new List<DataTableAttr>();
|
|||
|
|
// 添加自定义字段
|
|||
|
|
var geom = new DataTableAttr
|
|||
|
|
{
|
|||
|
|
Name = "Geometry",
|
|||
|
|
Type = string.Concat("geometry(GEOMETRY,",
|
|||
|
|
srid.AsSpan(srid.LastIndexOf(":", StringComparison.Ordinal) + 1),
|
|||
|
|
")")
|
|||
|
|
};
|
|||
|
|
attrs.Add(geom);
|
|||
|
|
using (var reader = new ShapefileDataReader(shpFile, GeometryFactory.Default))
|
|||
|
|
{
|
|||
|
|
// 获取DbfDataReader，用于读取属性信息
|
|||
|
|
var dbfReader = reader.DbaseHeader;
|
|||
|
|
foreach (var dbaseFieldDescriptor in dbfReader.Fields)
|
|||
|
|
{
|
|||
|
|
DataTableAttr attr = new DataTableAttr();
|
|||
|
|
attr.Name = dbaseFieldDescriptor.Name;
|
|||
|
|
attr.Length = dbaseFieldDescriptor.Length;
|
|||
|
|
attr.Type = MapDbaseTypeToPostgresString(dbaseFieldDescriptor.DbaseType);
|
|||
|
|
attrs.Add(attr);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
shpInfo.Headers = attrs;
|
|||
|
|
shpInfo.TableName = tableName;
|
|||
|
|
return new Response<ShpInfo>()
|
|||
|
|
{
|
|||
|
|
Result = shpInfo,
|
|||
|
|
Message = "ok"
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// todo 拆分，主方法中完成数据库操作，
|
|||
|
|
public async Task<Response<bool>> CreateDataTable(ShpGeoLayerShpReq shpInfo)
|
|||
|
|
{
|
|||
|
|
using var db = Repository.AsSugarClient();
|
|||
|
|
|
|||
|
|
var tableName = shpInfo.DataTable;
|
|||
|
|
// 校验 表是否存在
|
|||
|
|
var exist = await db.Queryable<ShpGeoLayer>()
|
|||
|
|
.Where(c => c.DataTable.Equals(tableName))
|
|||
|
|
.CountAsync();
|
|||
|
|
if (exist > 0)
|
|||
|
|
{
|
|||
|
|
throw new Exception(tableName + "库表名称已存在");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var shpGeoLayer = await db.Queryable<ShpGeoLayer>()
|
|||
|
|
.Where(c => c.ServerName.Equals(shpInfo.ServerName))
|
|||
|
|
.FirstAsync();
|
|||
|
|
if (!shpGeoLayer.IsNullOrEmpty())
|
|||
|
|
{
|
|||
|
|
throw new Exception("未执行shp解析");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 创建数据表
|
|||
|
|
var typeBuilder = db.DynamicBuilder().CreateClass(tableName,
|
|||
|
|
new SugarTable() { TableName = tableName, TableDescription = shpInfo.ServerName + "图斑" });
|
|||
|
|
//添加主键
|
|||
|
|
typeBuilder.CreateProperty("id", typeof(string), new SugarColumn()
|
|||
|
|
{
|
|||
|
|
IsPrimaryKey = true,
|
|||
|
|
IsIdentity = false,
|
|||
|
|
ColumnDataType = "varchar",
|
|||
|
|
Length = 36,
|
|||
|
|
ColumnDescription = "主键",
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
shpInfo.Headers.ForEach(u =>
|
|||
|
|
{
|
|||
|
|
typeBuilder.CreateProperty(u.RefName, typeof(string), new SugarColumn()
|
|||
|
|
{
|
|||
|
|
IsPrimaryKey = false,
|
|||
|
|
IsIdentity = false,
|
|||
|
|
ColumnDataType = u.Type,
|
|||
|
|
IsNullable = true,
|
|||
|
|
Length = u.Length,
|
|||
|
|
ColumnDescription = u.InitName,
|
|||
|
|
});
|
|||
|
|
});
|
|||
|
|
// 开启事务
|
|||
|
|
await db.Ado.BeginTranAsync(IsolationLevel.ReadCommitted);
|
|||
|
|
// 创建表
|
|||
|
|
db.CodeFirst.InitTables(typeBuilder.BuilderType());
|
|||
|
|
|
|||
|
|
// 插入图斑数据
|
|||
|
|
var shpPath = Path.Combine(_filePath, shpInfo.ShpPath);
|
|||
|
|
var extractPath = shpPath.Substring(0, shpPath.LastIndexOf(".", StringComparison.Ordinal)) + "extract";
|
|||
|
|
var searchPattern = "*.shp"; // 设置你想要遍历的文件后缀名
|
|||
|
|
var fileName = Directory.GetFiles(extractPath, searchPattern, SearchOption.AllDirectories);
|
|||
|
|
if (fileName.IsEmpty())
|
|||
|
|
{
|
|||
|
|
throw new Exception("未找到shp文件");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var shpFileName = fileName[0];
|
|||
|
|
// shpFile 文件路径
|
|||
|
|
var shpFile = Path.Combine(extractPath, shpFileName);
|
|||
|
|
shpInfo.Headers.Add(new DataTableAttr
|
|||
|
|
{
|
|||
|
|
RefName = "",
|
|||
|
|
InitName = "",
|
|||
|
|
Name = ""
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
// 批量插入
|
|||
|
|
var cols = new string[shpInfo.Headers.Count];
|
|||
|
|
for (var i = 0; i < shpInfo.Headers.Count - 1; i++)
|
|||
|
|
{
|
|||
|
|
cols[i] = shpInfo.Headers[i].RefName;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
cols[^1] = "id";
|
|||
|
|
using (var dataReader = new ShapefileDataReader(shpFile, GeometryFactory.Default))
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("记录数" + dataReader.RecordCount);
|
|||
|
|
//throw new Exception("失败");
|
|||
|
|
var objs = new List<Dictionary<string, object>>(1001);
|
|||
|
|
var num = 0;
|
|||
|
|
int count = 0;
|
|||
|
|
while (dataReader.Read())
|
|||
|
|
{
|
|||
|
|
count++;
|
|||
|
|
Console.WriteLine("记录行：" + count);
|
|||
|
|
var insertObj = new Dictionary<string, object>
|
|||
|
|
{
|
|||
|
|
{ "id", Guid.NewGuid().ToString() }
|
|||
|
|
};
|
|||
|
|
// 读取列
|
|||
|
|
for (int i = 0, j = 0; i < dataReader.FieldCount; i++)
|
|||
|
|
{
|
|||
|
|
var colName = dataReader.GetName(i);
|
|||
|
|
var header = shpInfo.Headers[j];
|
|||
|
|
if (header.Name.Equals(colName))
|
|||
|
|
{
|
|||
|
|
if (colName.ToLower().Equals("geometry"))
|
|||
|
|
{
|
|||
|
|
var geometry = (Geometry)dataReader.GetValue(i);
|
|||
|
|
var srid = shpInfo.SpatialRef.Substring(
|
|||
|
|
shpInfo.SpatialRef.IndexOf(":", StringComparison.Ordinal) + 1);
|
|||
|
|
var geometryForWgs84 = GeometryFactory.Default.WithSRID(int.Parse(srid))
|
|||
|
|
.CreateGeometry(geometry);
|
|||
|
|
insertObj.Add(shpInfo.Headers[j++].RefName, geometryForWgs84.AsText());
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
insertObj.Add(shpInfo.Headers[j++].RefName, dataReader.GetValue(i));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
objs.Add(insertObj);
|
|||
|
|
if (num++ == 999)
|
|||
|
|
{
|
|||
|
|
await db.Insertable(objs)
|
|||
|
|
.AS(tableName) // 指定目标表名
|
|||
|
|
.InsertColumns(cols) // 指定要插入的列
|
|||
|
|
.ExecuteCommandAsync();
|
|||
|
|
num = 0;
|
|||
|
|
objs.Clear();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 读取末尾
|
|||
|
|
await db.Insertable(objs)
|
|||
|
|
.AS(tableName) // 指定目标表名
|
|||
|
|
.InsertColumns(cols) // 指定要插入的列
|
|||
|
|
.ExecuteCommandAsync();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
await db.Ado.CommitTranAsync();
|
|||
|
|
// 删文件
|
|||
|
|
//DeleteFile(extractPath);
|
|||
|
|
return new Response<bool>()
|
|||
|
|
{
|
|||
|
|
Result = true,
|
|||
|
|
Message = "ok"
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task<Response<bool>> Test1(string tableName, string serverName, string srid, string shpPath)
|
|||
|
|
{
|
|||
|
|
var db = Repository.AsSugarClient();
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 输出目
|
|||
|
|
/*var db = Repository.AsSugarClient();
|
|||
|
|
shpPath = Path.Combine(_filePath, shpPath);
|
|||
|
|
var extractPath = shpPath.Substring(0, shpPath.LastIndexOf(".", StringComparison.Ordinal)) + "extract";
|
|||
|
|
var searchPattern = "*.shp"; // 设置你想要遍历的文件后缀名
|
|||
|
|
var fileName = Directory.GetFiles(extractPath, searchPattern, SearchOption.AllDirectories);
|
|||
|
|
if (fileName.IsEmpty())
|
|||
|
|
{
|
|||
|
|
throw new Exception("未找到shp文件");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var shpFileName = fileName[0];
|
|||
|
|
// shpFile 文件路径
|
|||
|
|
var shpFile = Path.Combine(extractPath, shpFileName);
|
|||
|
|
await db.Ado.BeginTranAsync();
|
|||
|
|
var rows = new List<Dictionary<string, object>>();
|
|||
|
|
using (var dataReader = new ShapefileDataReader(shpFile, GeometryFactory.Default))
|
|||
|
|
{
|
|||
|
|
while (dataReader.Read())
|
|||
|
|
{
|
|||
|
|
var insertObj = new Dictionary<string, object>
|
|||
|
|
{
|
|||
|
|
{ "id", Guid.NewGuid().ToString() },
|
|||
|
|
{ "geometry", dataReader.Geometry.AsBinary() },
|
|||
|
|
};
|
|||
|
|
rows.Add(insertObj);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
int insertCount = await db.Insertable(rows)
|
|||
|
|
.AS(tableName) // 指定目标表名
|
|||
|
|
.InsertColumns("id", "geometry") // 指定要插入的列
|
|||
|
|
.ExecuteCommandAsync();
|
|||
|
|
/*
|
|||
|
|
foreach (var geometry in Shapefile.ReadAllGeometries(shpFile))
|
|||
|
|
{
|
|||
|
|
var insertObj = new Dictionary<string, object>
|
|||
|
|
{
|
|||
|
|
{ "id", Guid.NewGuid().ToString() },
|
|||
|
|
{ "geometry", geometry.AsBinary() },
|
|||
|
|
};
|
|||
|
|
int insertCount = await db.Insertable(insertObj)
|
|||
|
|
.AS(tableName) // 指定目标表名
|
|||
|
|
.InsertColumns("id", "geometry") // 指定要插入的列
|
|||
|
|
.ExecuteCommandAsync();
|
|||
|
|
}
|
|||
|
|
#1#
|
|||
|
|
|
|||
|
|
await db.Ado.CommitTranAsync();*/
|
|||
|
|
return new Response<bool>
|
|||
|
|
{
|
|||
|
|
Result = true
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取图层中心点
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="tableName"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<Response<string>> GetGeomData(string tableName)
|
|||
|
|
{
|
|||
|
|
var sql = "select ST_AsText(ST_Centroid(ST_Extent(geometry))) from \"public\".\"" + tableName + "\"";
|
|||
|
|
var db = Repository.AsSugarClient();
|
|||
|
|
var result = await db.Ado.SqlQuerySingleAsync<string>(sql);
|
|||
|
|
return new Response<string>
|
|||
|
|
{
|
|||
|
|
Result = result,
|
|||
|
|
Message = "ok"
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public byte[] QueryVectorTileByTable(QueryVectorTileByTableReq req)
|
|||
|
|
{
|
|||
|
|
VectorTileSearchModel searchModel = new VectorTileSearchModel
|
|||
|
|
{
|
|||
|
|
x = req.x,
|
|||
|
|
y = req.y,
|
|||
|
|
z = req.z,
|
|||
|
|
//field = req.field,
|
|||
|
|
table = req.table,
|
|||
|
|
filter = req.filter,
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
var fieldArray = req.field.TrimEnd(',').Split(",");
|
|||
|
|
//req fields
|
|||
|
|
var fields = "";
|
|||
|
|
var cols = _client.DbMaintenance.GetColumnInfosByTableName(req.table);
|
|||
|
|
foreach (var dbColumnInfo in cols)
|
|||
|
|
{
|
|||
|
|
if (dbColumnInfo.DbColumnName.Equals("geometry"))
|
|||
|
|
{
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
fields += dbColumnInfo.DbColumnName + ",";
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
fields = fields.TrimEnd(',');
|
|||
|
|
var fieldArrayTemp = fields.Split(",");
|
|||
|
|
// 取两个数组的交集
|
|||
|
|
fields = string.Join(",", fieldArrayTemp.Intersect(fieldArray)) + ",";
|
|||
|
|
searchModel.field = fields;
|
|||
|
|
var result = _commonDataManager.VectorTile1(searchModel);
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public dynamic GetDataTableRecord(string dataTable, string id)
|
|||
|
|
{
|
|||
|
|
using var db = Repository.AsSugarClient();
|
|||
|
|
var list = db.DbMaintenance.GetColumnInfosByTableName(dataTable);
|
|||
|
|
var fields = string.Join(",", list.Where(x => x.DbColumnName != "geometry").Select(x => x.DbColumnName));
|
|||
|
|
return db.Ado.SqlQuery<dynamic>("select " + fields + " from " + dataTable + " where id='" + id + "'").First();
|
|||
|
|
}
|
|||
|
|
}
|