CS_GIS/Main/GNetworkProcessTool/FormNetworkLoader.cs

//======================================================================
//
//		  成都同飞科技地下管网GIS系统
//
//        CLR 版本: 4.0.30319.42000
//        命名空间: GNetworkProcessTool
//        类    名: FormNetworkLoader
//        创 建 人: 汤云伟
//        创建时间: 2017-07-06 17:57:26
//        修 改 人: 
//        修改时间: 
//
//======================================================================

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

using ESRI.ArcGIS.Geodatabase;
using ESRI.ArcGIS.esriSystem;
using ESRI.ArcGIS.EditorExt;

using Tofly.GIS.ArcGIS.Util;
using Tofly.GIS.Carto;
using Tofly.GIS.Util;
using Tofly.GIS.SpatialAnalysis.ArcGIS;

namespace GNetworkProcessTool
{
    public partial class FormNetworkLoader : Form
    {


        #region 私有方法
        /// <summary>
        /// 通过增量网络数据加载工具进行数据入库
        /// </summary>
        private void LoadDataByGNIncrementalLoader(IWorkspace wsSDE, string userID, Dictionary<string, IFeatureClass> dicFGDBClass)
        {
            GNUtility.Initialize(wsSDE, true, userID);
            IGeometricNetwork __gnProcessing = GNUtility.GetGNetworlByName(AppConfig.GeometryNetworkName);
            //IWorkspaceName __wsName = new WorkspaceNameClass()
            //{
            //    WorkspaceFactoryProgID = "esriDataSourcesGDB.SdeWorkspaceFactory",
            //    ConnectionProperties = this._SDEWorkspace.ConnectionProperties
            //};
            //IWorkspaceName __wsName = (IWorkspaceName)(this._SDEWorkspace as IDataset).FullName;
            IGeometricNetworkName __gnName = (IGeometricNetworkName)(__gnProcessing as IDataset).FullName;
            IEnumNameEdit __enumNameEdit = new NamesEnumeratorClass();
            #region 获取导入要素类名称集合
            IFeatureClassName __flnName;
            foreach (var __kvFClassGDB in dicFGDBClass)
            {
                if ((__kvFClassGDB.Value as ITable).RowCount(null) > 0)
                {
                    __flnName = (__kvFClassGDB.Value as IDataset).FullName as IFeatureClassName;
                    __enumNameEdit.Add(__flnName as IName);
                    break;
                }
            }
            #endregion

            IGeometricNetworkIncrementalLoader __gnIncrementalLoader = new GNIncrementalLoaderClass();
            IEnumNameMapping __fcMapping = null;
            IPropertySet __unmappedFields;
            string __strSpatialRef = (dicFGDBClass.ElementAt(0).Value as IGeoDataset).SpatialReference.Name;
            string __strSpatialRef2 = (__gnProcessing as IGeoDataset).SpatialReference.Name;
            IEnumName __enumName = __enumNameEdit as IEnumName;

            __enumName.Reset();
            __gnIncrementalLoader.GenerateNameMapping(__enumName, __gnName, out __fcMapping, out __unmappedFields);
            __fcMapping.Reset();
            INameMapping __nameMapping = null;
            //while ((__nameMapping = __fcMapping.Next()) != null)
            //{
            //    __nameMapping.TargetName = string.Format("{0}.{1}", this._wsOrigine.UserID.ToUpper(), __nameMapping.TargetName);
            //}

            //string __strClass = "";
            //IFeatureClass __fclass;
            //var __enumClass = __gnProcessing.get_ClassesByType(ESRI.ArcGIS.Geodatabase.esriFeatureType.esriFTSimpleJunction);
            //while ((__fclass = __enumClass.Next()) != null)
            //{
            //    __strClass += __fclass.AliasName + " " + (__fclass as IDataset).BrowseName + ";";
            //}
            //__enumClass = __gnProcessing.get_ClassesByType(ESRI.ArcGIS.Geodatabase.esriFeatureType.esriFTSimpleEdge);
            //while ((__fclass = __enumClass.Next()) != null)
            //{
            //    __strClass += __fclass.AliasName + " " + (__fclass as IDataset).BrowseName + ";";
            //}

            string __strMappingClass = "";
            __fcMapping.Reset();
            while ((__nameMapping = __fcMapping.Next()) != null)
            {
                __strMappingClass += __nameMapping.TargetName + " " + (__nameMapping.SourceObject as IDatasetName).Name + ";";
            }
            __fcMapping.Reset();

            __gnIncrementalLoader.GetUnmappedTargetFields(__gnProcessing, __fcMapping, __unmappedFields);
            __gnIncrementalLoader.LoadNetwork(__fcMapping, __gnProcessing);
        }


        #endregion

        public FormNetworkLoader()
        {
            InitializeComponent();
        }

        private void FormNetworkLoader_Shown(object sender, EventArgs e)
        {
            #region 加载地图
            //this.lblInfo.Text = "正在加载地图数据";
            ESRI.ArcGIS.Carto.IMapDocument __mapDoc = new ESRI.ArcGIS.Carto.MapDocumentClass();
            __mapDoc.Open(string.Format(@"{0}\Default.mxd", Application.StartupPath));
            ESRI.ArcGIS.Carto.IMap __mapData = __mapDoc.Map[0];
            this.MapControl.Map = __mapData;
            this.MapControl.ActiveView.PartialRefresh(ESRI.ArcGIS.Carto.esriViewDrawPhase.esriViewGeography, null, this.MapControl.ActiveView.Extent);

            __mapDoc.Close();
            #endregion
        }

        private void btnOpenGDB_Click(object sender, EventArgs e)
        {
            FolderBrowserDialog __folderDia = new FolderBrowserDialog() { ShowNewFolderButton = false };
            if(__folderDia.ShowDialog() == DialogResult.OK)
            {
                this.txtGDBFile.Text = __folderDia.SelectedPath;
            }
            //OpenFileDialog __fileDia = new OpenFileDialog()
            //{
            //    Filter = "*.gdb|*.gdb;"
            //};
            //if (__fileDia.ShowDialog() == DialogResult.OK)
            //{
            //    this.txtGDBFile.Text = __fileDia.FileName;
            //}
        }

        private void btnImport_Click(object sender, EventArgs e)
        {
            try
            {
                IMap __cmap = new Tofly.GIS.ArcGIS.Carto.MapClass(this.MapControl.Map);      //获取数据地图
                List<IFeatureLayer> __lstGNLayer = new List<IFeatureLayer>(__cmap.GetShowFeatureLayersByMap());
                List<ESRI.ArcGIS.Carto.IFeatureLayer> __lstESRIGNLayer = __lstGNLayer.Select(layer => layer.InnerObject as ESRI.ArcGIS.Carto.IFeatureLayer).ToList();
                __lstESRIGNLayer.RemoveAll(layer => layer.FeatureClass == null || layer.FeatureClass.FeatureDataset == null);
                __lstESRIGNLayer.RemoveAll(layer => layer.FeatureClass.FeatureDataset == null || layer.FeatureClass.FeatureDataset.Name.IndexOf(AppConfig.GWDatasetName, StringComparison.OrdinalIgnoreCase) == -1);

                IWorkspace __wsFileGDB = GeoDataSourceHelper.FileGdbWorkspaceFromPath(this.txtGDBFile.Text);
                IFeatureDataset __fdsetGASDATASET_GDB = (__wsFileGDB as IFeatureWorkspace).OpenFeatureDataset("GASDATASET");
                Dictionary<string, IFeatureClass> __dicFileGDBFeatureClass = DataOperateHelper.GetFeatureClassFromDataset(__wsFileGDB as IFeatureWorkspace, __fdsetGASDATASET_GDB, new List<string>());

                IWorkspace __wsSDE = (__lstESRIGNLayer[0].FeatureClass as IDataset).Workspace;
                GeoDataSourceHelper __geoDSHelper = new GeoDataSourceHelper();
                Dictionary<string,object> __dicParameters = __geoDSHelper.GetSdeDataSourceParameters(__wsSDE);
                string __strUserID = (__dicParameters.ContainsKey("USER") ? Convert.ToString(__dicParameters["USER"]) : "");
                string __strDSetName = (string.IsNullOrEmpty(__strUserID) ? "" : __strUserID + ".") + "GASDATASET";
                IFeatureDataset __fdsetGASDATASET_SDE = (__wsSDE as IFeatureWorkspace).OpenFeatureDataset(__strDSetName);
                Dictionary<string, IFeatureClass> __dicSDEFeatureClass = DataOperateHelper.GetFeatureClassFromDataset(__wsSDE as IFeatureWorkspace, __fdsetGASDATASET_SDE, new List<string>());

                IWorkspaceEdit2 __wseSDEProcessing = __wsSDE as IWorkspaceEdit2;
                __wseSDEProcessing.StartEditing(true);
                __wseSDEProcessing.StartEditOperation();
                try
                {
                    this.LoadDataByGNIncrementalLoader(__wsSDE, __strUserID, __dicFileGDBFeatureClass);       //工具导入测试
                    __wseSDEProcessing.StopEditOperation();
                }
                catch (System.Exception ex)
                {
                    __wseSDEProcessing.AbortEditOperation();
                    throw new System.Exception("数据入库错误|" + ex.Message);
                }
            }
            catch(System.Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }


    }
}