|
|
|
|
|
using ESRI.ArcGIS.Carto;
|
|
|
|
|
|
using ESRI.ArcGIS.Geodatabase;
|
|
|
|
|
|
using KGIS.Framework.AE;
|
|
|
|
|
|
using KGIS.Framework.AE.Enum;
|
|
|
|
|
|
using KGIS.Framework.AE.GPHelper;
|
|
|
|
|
|
using KGIS.Framework.ThreadManager;
|
|
|
|
|
|
using KGIS.Framework.Utils;
|
|
|
|
|
|
using Kingo.PluginServiceInterface;
|
|
|
|
|
|
using Kingo.PluginServiceInterface.Model;
|
|
|
|
|
|
using System;
|
|
|
|
|
|
using System.Collections.Generic;
|
|
|
|
|
|
using System.IO;
|
|
|
|
|
|
using System.Linq;
|
|
|
|
|
|
using System.Runtime.InteropServices;
|
|
|
|
|
|
|
|
|
|
|
|
namespace IDGForNDBG
|
|
|
|
|
|
{
|
|
|
|
|
|
public class GDDB_IDGHelper : BaseIDG
|
|
|
|
|
|
{
|
|
|
|
|
|
public string IDataChangeName { get => "XZQ_IDGHelper"; }
|
|
|
|
|
|
private string TempGDBPath = string.Empty;
|
|
|
|
|
|
private string TempDBPath = string.Empty;
|
|
|
|
|
|
|
|
|
|
|
|
//IDGParameter IDGParm = null;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void Execute(IDGParameter pParm)
|
|
|
|
|
|
{
|
|
|
|
|
|
ThreadManager.Instance.QueueUserWorkItem(new System.Threading.WaitCallback(ExeGDDB), pParm, new System.Threading.WaitCallback(ComplateCallBack));
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
public void ComplateCallBack(object obj)
|
|
|
|
|
|
{
|
|
|
|
|
|
Console.WriteLine($"Log:耕地等别数据提取完成。耗时：{GetTime(StartTime)}");
|
|
|
|
|
|
}
|
|
|
|
|
|
DateTime StartTime = DateTime.Now;
|
|
|
|
|
|
public void ExeGDDB(object obj)
|
|
|
|
|
|
{
|
|
|
|
|
|
StartTime = DateTime.Now;
|
|
|
|
|
|
//IDGParameter Parm = obj as IDGParameter;
|
|
|
|
|
|
Kingo.ThreadManager.TaskParameter taskParm = obj as Kingo.ThreadManager.TaskParameter;
|
|
|
|
|
|
IDGParameter Parm = taskParm.Data as IDGParameter;
|
|
|
|
|
|
|
|
|
|
|
|
//IFeatureLayer GDDBGXLayer = null;
|
|
|
|
|
|
//IFeatureLayer JCGDDBLayer = JCGDDBLayer;
|
|
|
|
|
|
//IFeatureLayer NMKLayer = null;
|
|
|
|
|
|
|
|
|
|
|
|
IFeatureLayer featureLayer = null;
|
|
|
|
|
|
IFeatureCursor sourCursor = null;
|
|
|
|
|
|
IFeatureCursor gddbCursor = null;
|
|
|
|
|
|
try
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
|
|
OpenDB(Parm);
|
|
|
|
|
|
string TempDir = CreateTempDB("GDDB");
|
|
|
|
|
|
TempGDBPath = System.IO.Path.Combine(TempDir, "TempGDB.gdb");
|
|
|
|
|
|
TempDBPath = TempDir + @"\Temp" + ".sqlite";
|
|
|
|
|
|
|
|
|
|
|
|
//this.UpdateMsg("正在进行耕地等别数据提取，请稍候...");
|
|
|
|
|
|
//jcgddblayer = Parm.JC_GDDBLay as IFeatureLayer;
|
|
|
|
|
|
Console.WriteLine("Log:正在进行耕地等别数据提取，请稍候...");
|
|
|
|
|
|
if (JcGddbLayer != null)
|
|
|
|
|
|
{
|
|
|
|
|
|
//GeoprocessorHelper gpHelper = new GeoprocessorHelper();
|
|
|
|
|
|
//string gdbFolder = Directory.GetCurrentDirectory() + "\\Temp\\NMK";
|
|
|
|
|
|
//if (!System.IO.Directory.Exists(gdbFolder))
|
|
|
|
|
|
//{
|
|
|
|
|
|
// System.IO.Directory.CreateDirectory(gdbFolder);
|
|
|
|
|
|
//}
|
|
|
|
|
|
//try
|
|
|
|
|
|
//{ DelectDir(gdbFolder); }
|
|
|
|
|
|
//catch
|
|
|
|
|
|
//{ }
|
|
|
|
|
|
//string gdbFileName = Guid.NewGuid().ToString() + ".gdb";
|
|
|
|
|
|
//string path = System.IO.Path.Combine(gdbFolder, gdbFileName);
|
|
|
|
|
|
//IWorkspaceFactory pFtWsFct = new FileGDBWorkspaceFactory();
|
|
|
|
|
|
//IWorkspaceName workspaceName = pFtWsFct.Create(gdbFolder, gdbFileName, null, 0);
|
|
|
|
|
|
|
|
|
|
|
|
(GxGddbLayer.FeatureClass as ITable).DeleteSearchedRows(null);//删除耕地等别更新层所有数据
|
|
|
|
|
|
//空间联合赋值
|
|
|
|
|
|
GPParamClass gPParamClass = new GPParamClass();
|
|
|
|
|
|
IFeatureLayer TempNMKLayer = null;
|
|
|
|
|
|
if (NmTbLayer == null)
|
|
|
|
|
|
{
|
|
|
|
|
|
Console.WriteLine("Log:正在进行耕地等别数据提取_数据准备...");
|
|
|
|
|
|
gPParamClass = new GPParamClass();
|
|
|
|
|
|
gPParamClass.FirstFeatureLayer = JcTbLayer;
|
|
|
|
|
|
gPParamClass.SecondFeatureLayer = GxTbLayer;
|
|
|
|
|
|
gPParamClass.OutFeatureClassPath = Parm.PrjInfo.NMDatabase + "\\" + "DLTB_NMK";//要添加的要素类图层
|
|
|
|
|
|
gPParamClass.IsGetOutPutFeature = true;
|
|
|
|
|
|
gPParamClass.GPType = EnumGPType.Erase;
|
|
|
|
|
|
GPHelper.Instance.ExeGPForProces(gPParamClass, ref TempNMKLayer);//擦除/相减分析
|
|
|
|
|
|
}
|
|
|
|
|
|
else
|
|
|
|
|
|
TempNMKLayer = NmTbLayer;
|
|
|
|
|
|
//GPParamClass gPParamClass = new GPParamClass();
|
|
|
|
|
|
gPParamClass = new GPParamClass();
|
|
|
|
|
|
//gPParamClass.FirstFeatureLayer = NmTbLayer;
|
|
|
|
|
|
gPParamClass.FirstFeatureLayer = TempNMKLayer;
|
|
|
|
|
|
gPParamClass.SecondFeatureLayer = JcGddbLayer;
|
|
|
|
|
|
gPParamClass.OutFeatureClassPath = TempGDBPath + "\\" + "DLTB_GDDB";
|
|
|
|
|
|
gPParamClass.Match_option = "ARE_IDENTICAL_TO";
|
|
|
|
|
|
gPParamClass.IsGetOutPutFeature = true;
|
|
|
|
|
|
gPParamClass.GPType = EnumGPType.SpatialJoin;
|
|
|
|
|
|
gPParamClass.Join_type = "KEEP_ALL";
|
|
|
|
|
|
gPParamClass.JOIN_ONE_TO_ONE = true;
|
|
|
|
|
|
GPHelper.Instance.ExeGPForProces(gPParamClass, ref featureLayer);
|
|
|
|
|
|
if (featureLayer != null)
|
|
|
|
|
|
{
|
|
|
|
|
|
Console.WriteLine("Log:正在进行耕地等别数据提取_数据生成中...");
|
|
|
|
|
|
sourCursor = featureLayer.FeatureClass.Search(new QueryFilterClass() { WhereClause = " DLBM LIKE '01%'" }, true);
|
|
|
|
|
|
IFeature f = null;
|
|
|
|
|
|
gddbCursor = GxGddbLayer.FeatureClass.Insert(true);
|
|
|
|
|
|
int gddbIdx = featureLayer.FeatureClass.FindField("GDDB");
|
|
|
|
|
|
int kcmjIdx = featureLayer.FeatureClass.FindField("KCMJ");
|
|
|
|
|
|
int tbmjIdx = featureLayer.FeatureClass.FindField("TBMJ");
|
|
|
|
|
|
DateTime dateTime = DateTime.Now.Month >= 10 ? new DateTime(DateTime.Now.Year, 12, 31) : new DateTime(DateTime.Now.Year - 1, 12, 31);
|
|
|
|
|
|
while ((f = sourCursor.NextFeature()) != null)
|
|
|
|
|
|
{
|
|
|
|
|
|
IFeatureBuffer buff = GxGddbLayer.FeatureClass.CreateFeatureBuffer();
|
|
|
|
|
|
buff.Shape = f.ShapeCopy;
|
|
|
|
|
|
int sIndex = -1;
|
|
|
|
|
|
for (int i = 0; i < buff.Fields.FieldCount; i++)
|
|
|
|
|
|
{
|
|
|
|
|
|
IField field = buff.Fields.Field[i];
|
|
|
|
|
|
if (field.Name.Contains(featureLayer.FeatureClass.ShapeFieldName) || !field.Editable) continue;
|
|
|
|
|
|
sIndex = f.Fields.FindField(field.Name);
|
|
|
|
|
|
if (field.Name.ToUpper() == "GXSJ")
|
|
|
|
|
|
{
|
|
|
|
|
|
buff.Value[i] = dateTime;
|
|
|
|
|
|
}
|
|
|
|
|
|
if (sIndex == -1) continue;
|
|
|
|
|
|
else if (field.Name.ToUpper() == "KCDLMJ")
|
|
|
|
|
|
{
|
|
|
|
|
|
buff.Value[i] = f.Value[kcmjIdx];
|
|
|
|
|
|
}
|
|
|
|
|
|
else if (field.Name.ToUpper() == "TBDLMJ")
|
|
|
|
|
|
{
|
|
|
|
|
|
buff.Value[i] = f.Value[tbmjIdx];
|
|
|
|
|
|
}
|
|
|
|
|
|
else if (field.Name.ToUpper() == "LYD")
|
|
|
|
|
|
{
|
|
|
|
|
|
buff.Value[i] = f.Value[gddbIdx];
|
|
|
|
|
|
}
|
|
|
|
|
|
else
|
|
|
|
|
|
{
|
|
|
|
|
|
string value = f.Value[sIndex].ToTrim();
|
|
|
|
|
|
if (string.IsNullOrWhiteSpace(value))
|
|
|
|
|
|
buff.Value[i] = DBNull.Value;
|
|
|
|
|
|
else
|
|
|
|
|
|
buff.Value[i] = f.Value[sIndex];
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
gddbCursor.InsertFeature(buff);
|
|
|
|
|
|
if (buff != null)
|
|
|
|
|
|
Marshal.ReleaseComObject(buff);
|
|
|
|
|
|
}
|
|
|
|
|
|
gddbCursor.Flush();
|
|
|
|
|
|
}
|
|
|
|
|
|
Console.WriteLine($"Log:耕地等别数据提取完成。耗时：{GetTime(StartTime)}");
|
|
|
|
|
|
}
|
|
|
|
|
|
else
|
|
|
|
|
|
{
|
|
|
|
|
|
Console.WriteLine($"Log:耕地等别数据获取失败。");
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
catch (Exception ex)
|
|
|
|
|
|
{
|
|
|
|
|
|
LogAPI.Debug("耕地等别数据提取错误:" + ex.Message.ToString());
|
|
|
|
|
|
LogAPI.Debug(ex);
|
|
|
|
|
|
Console.WriteLine("Err:耕地等别数据提取错误:" + ex.Message.ToString());
|
|
|
|
|
|
//throw ex;
|
|
|
|
|
|
}
|
|
|
|
|
|
finally
|
|
|
|
|
|
{
|
|
|
|
|
|
if (sourCursor != null)
|
|
|
|
|
|
Marshal.ReleaseComObject(sourCursor);
|
|
|
|
|
|
if (gddbCursor != null)
|
|
|
|
|
|
Marshal.ReleaseComObject(gddbCursor);
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
public void OpenDB(IDGParameter parm)
|
|
|
|
|
|
{
|
|
|
|
|
|
try
|
|
|
|
|
|
{
|
|
|
|
|
|
LayerCfg layerInfo = null;
|
|
|
|
|
|
if (parm.PrjInfo != null && !string.IsNullOrWhiteSpace(parm.PrjInfo.TempData))
|
|
|
|
|
|
{
|
|
|
|
|
|
byte[] contentArray = Convert.FromBase64String(parm.PrjInfo.TempData);
|
|
|
|
|
|
string LayerCfg = System.Text.Encoding.Default.GetString(contentArray);
|
|
|
|
|
|
layerInfo = KGIS.Framework.Utils.SerializeAPI.DeserializeToObject<LayerCfg>(LayerCfg);
|
|
|
|
|
|
}
|
|
|
|
|
|
if (layerInfo == null)
|
|
|
|
|
|
{
|
|
|
|
|
|
throw new Exception("Err:获取图层信息失败！");
|
|
|
|
|
|
}
|
|
|
|
|
|
//FileInfo fileInfo = new FileInfo(parm.PrjInfo.BGDatabase);
|
|
|
|
|
|
string PathBgDB = parm.PrjInfo.BGDatabase;// Path.Combine(, "BGDB" + ".gdb");
|
|
|
|
|
|
string PathZLDB = parm.PrjInfo.ZLDatabase;
|
|
|
|
|
|
string PathNMDB = parm.PrjInfo.NMDatabase;// System.IO.Path.Combine(fileInfo.DirectoryName, "NMDB" + ".gdb");
|
|
|
|
|
|
BgWsAPI = new WorkspaceAPI(PathBgDB, WorkspaceTypeEnum.GDBFile);
|
|
|
|
|
|
if (BgWsAPI.CurrentWorkspace == null)
|
|
|
|
|
|
{
|
|
|
|
|
|
Console.WriteLine("打开变更数据库失败！");
|
|
|
|
|
|
return;
|
|
|
|
|
|
}
|
|
|
|
|
|
ZlWsAPI = new WorkspaceAPI(PathZLDB, WorkspaceTypeEnum.GDBFile);
|
|
|
|
|
|
if (ZlWsAPI.CurrentWorkspace == null)
|
|
|
|
|
|
{
|
|
|
|
|
|
Console.WriteLine("打开增量数据库失败！");
|
|
|
|
|
|
return;
|
|
|
|
|
|
}
|
|
|
|
|
|
NmWsAPI = new WorkspaceAPI(PathNMDB, WorkspaceTypeEnum.GDBFile);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
LayerCfg JCLayerInfo = layerInfo.Layers.FirstOrDefault(f => f.LayerName == "年初数据");
|
|
|
|
|
|
if (JCLayerInfo == null)
|
|
|
|
|
|
{
|
|
|
|
|
|
throw new Exception("Err:获取年初数据库失败！");
|
|
|
|
|
|
}
|
|
|
|
|
|
List<LayerCfg> NcList = JCLayerInfo.GetAllItem();
|
|
|
|
|
|
//if (parm.ExeDLTB)
|
|
|
|
|
|
//{
|
|
|
|
|
|
LayerCfg _JcTBLayerInfo = NcList.FirstOrDefault(f => f.LayerName == "地类图斑");
|
|
|
|
|
|
|
|
|
|
|
|
_jcTbLayer = OpenLayer(_JcTBLayerInfo);
|
|
|
|
|
|
if (_jcTbLayer == null)
|
|
|
|
|
|
{
|
|
|
|
|
|
throw new Exception("Err:获取年初地类图斑数据失败！");
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
//}
|
|
|
|
|
|
|
|
|
|
|
|
LayerCfg _JcGddbLayerInfo = NcList.FirstOrDefault(f => f.LayerName == "耕地等别");
|
|
|
|
|
|
_jcGddbLayer = OpenLayer(_JcGddbLayerInfo);
|
|
|
|
|
|
if (_JcGddbLayerInfo == null)
|
|
|
|
|
|
throw new Exception("Err:获取年初耕地等别数据失败！");
|
|
|
|
|
|
if (_nmTbLayer == null)
|
|
|
|
|
|
_nmTbLayer = OpenLayer(NmWsAPI, "DLTB_NMK");
|
|
|
|
|
|
_gxGddbLayer = OpenLayer(ZlWsAPI, "GDDBGX");
|
|
|
|
|
|
_gxTbLayer = OpenLayer(ZlWsAPI, "DLTBGX");
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
catch (Exception ex)
|
|
|
|
|
|
{
|
|
|
|
|
|
throw ex;
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
#region DelectDir
|
|
|
|
|
|
public static void DelectDir(string srcPath)
|
|
|
|
|
|
{
|
|
|
|
|
|
try
|
|
|
|
|
|
{
|
|
|
|
|
|
DirectoryInfo dir = new DirectoryInfo(srcPath);
|
|
|
|
|
|
FileSystemInfo[] fileinfo = dir.GetFileSystemInfos(); //返回目录中所有文件和子目录
|
|
|
|
|
|
foreach (FileSystemInfo i in fileinfo)
|
|
|
|
|
|
{
|
|
|
|
|
|
if (i is DirectoryInfo) //判断是否文件夹
|
|
|
|
|
|
{
|
|
|
|
|
|
DirectoryInfo subdir = new DirectoryInfo(i.FullName);
|
|
|
|
|
|
subdir.Delete(true); //删除子目录和文件
|
|
|
|
|
|
}
|
|
|
|
|
|
else
|
|
|
|
|
|
{
|
|
|
|
|
|
File.Delete(i.FullName); //删除指定文件
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
catch (Exception ex)
|
|
|
|
|
|
{
|
|
|
|
|
|
LogAPI.Debug(ex + ":删除错误不处理");
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
