.NET通過RFC讀取SAP數據

　　本篇文章中我主要講的是.NET如何通過RFC從SAP中讀取數據。為了功能的可復用性，我將調用RFC的代碼從業務層中分離出來單獨建立在一個namespace中。

　　當然除了需要我們自己編寫代碼以外，還需要引用SAP提供的程序集文件（sapnco.dll、sapnco_utils.dll），在代碼文件需要引用相應的命名空間（using SAP.Middleware.Connector;）。

　　我在這個namespace中建立了三個類來實現這個功能，一個配置類（RfcDestinationConfig）、一個參數類（RfcParam）、一個主體功能類（RfcManager）。

• RfcDestinationConfig

　　我們需要一個類來實現SAP的連接配置工作，就如同為數據連接層建立一個數據庫配置類一樣重要。

public class RfcDestinationConfig : IDestinationConfiguration
    {
        #region 事件
        /// <summary>
        /// 配置變更事件
        /// </summary>
        public event RfcDestinationManager.ConfigurationChangeHandler ConfigurationChanged;
        /// <summary>
        /// 默認接收器名稱
        /// </summary>
        public static readonly string DefaultDesName = "destination";
        #endregion

        #region 方法
        /// <summary>
        /// 配置變更事件觸發時，暫時無用
        /// </summary>
        /// <param name="destinationName"></param>
        /// <param name="args"></param>
        public void OnConfigurationChanged(string destinationName, RfcConfigurationEventArgs args)
        {
            if (ConfigurationChanged != null)
            {
                ConfigurationChanged(destinationName, args);
            }
        }

        /// <summary>
        /// 獲取SAP配置參數
        /// </summary>
        /// <param name="destinationName"></param>
        /// <returns></returns>
        public RfcConfigParameters GetParameters(string destinationName)
        {
            if (destinationName == DefaultDesName)
            {
                RfcConfigParameters parms = new RfcConfigParameters();
                parms.Add(RfcConfigParameters.AppServerHost,ConfigManager.GetAppSettings("SAPApplicationServer").Trim());   //SAP主機IP
                parms.Add(RfcConfigParameters.SystemNumber, ConfigManager.GetAppSettings("SAPSystemNumber").Trim());  //SAP實例
                parms.Add(RfcConfigParameters.User, ConfigManager.GetAppSettings("SAPUser").Trim());  //用戶名
                parms.Add(RfcConfigParameters.Password,ConfigManager.GetAppSettings("SAPPwd").Trim());  //密碼
                parms.Add(RfcConfigParameters.Client, ConfigManager.GetAppSettings("SAPClient").Trim());  // Client
                parms.Add(RfcConfigParameters.Language,ConfigManager.GetAppSettings("SAPLanguage").Trim());  //登陸語言
                return parms;
            }
            else
            {
                return null;
            }
        }

        /// <summary>
        /// 變更事件方法，暫時無用
        /// </summary>
        /// <returns>true</returns>
        public bool ChangeEventsSupported()
        {
            return true;
        }
        #endregion
    }

• RfcParam

　　想要從SAP中讀取數據，就必須將查詢條件作為參數傳遞給RFC。另外為了返回的結果具有通用性，我使用DataTable作為返回結果的類型，然后考慮到不同條件下列是不同的，我又將列也參數化，最終我將輸入參數和輸出參數都封裝在一個參數類之中。

public class RfcParam
    {
        /// <summary>
        /// 初始化
        /// </summary>
        public RfcParam()
        {
            CoulmnNames = new List<string>();
            Param = new Dictionary<string, object>();
        }
        /// <summary>
        /// RFC方法名稱
        /// </summary>
        public string RfcName { get; set; }
        /// <summary>
        /// RFC表名
        /// </summary>
        public string TableName { get; set; }
        /// <summary>
        /// 數據表各列的列名
        /// </summary>
        public List<string> CoulmnNames { get; set; }
        /// <summary>
        /// RFC執行參數
        /// </summary>
        public Dictionary<string, object> Param { get; set; }
    }

• RfcManager

　　該主角登場了，讀取數據的功能正是業務層真正想要的東西。

　　方法ExecRfc首先將輸出參數轉換成一個真正可用的新的DataTable，然后將輸入參數傳遞給SAP執行相關的RFC功能並返回IRfcTable（SAP定義的一種接口），最后再將IRfcTable轉換成我們自定義的DataTable。

public class RfcManager
    {
        #region 屬性字段
        /// <summary>
        /// 接收器
        /// </summary>
        public RfcDestination Prd { get; set; }
        /// <summary>
        /// 數據倉庫
        /// </summary>
        public RfcRepository Repo { get; set; }
        #endregion

        #region 構造函數
        /// <summary>
        /// 初始化
        /// </summary>
        public RfcManager()
        {
            //初始化RFC接收器
            //配置接收器
            IDestinationConfiguration IDC = new RfcDestinationConfig();
            //注冊
            RfcDestinationManager.RegisterDestinationConfiguration(IDC);
            //獲取RFC接收器
            this.Prd = RfcDestinationManager.GetDestination(RfcDestinationConfig.DefaultDesName);
            this.Repo = this.Prd.Repository;
            //注銷
            RfcDestinationManager.UnregisterDestinationConfiguration(IDC);            
        }
        #endregion

        #region 方法
        /// <summary>
        /// 執行RFC獲取數據表
        /// </summary>
        /// <param name="rfcname">rfc方法名稱</param>
        /// <param name="tablename">rfc表名</param>
        /// <param name="columnnames">數據表列名列表</param>
        /// <param name="param">rfc執行參數</param>
        /// <returns>數據表</returns>
        public DataTable ExecRfc(string rfcname, string tablename, List<string> columnnames, Dictionary<string, object> param)
        {
            DataTable dt = new DataTable();

            if (columnnames != null && columnnames.Count > 0)
            {
                //配置datatable
                dt.Columns.Clear();
                foreach (string cname in columnnames)
                {
                    dt.Columns.Add(cname, typeof(string));
                }
                dt.AcceptChanges();

                //從SAP那獲取數據表
                if (!string.IsNullOrEmpty(rfcname) && param != null && param.Count > 0)
                {
                    IRfcFunction rfc = this.Repo.CreateFunction(rfcname);
                    foreach (KeyValuePair<string, object> kv in param)
                    {
                        rfc.SetValue(kv.Key, kv.Value);
                    }
                    rfc.Invoke(this.Prd);
                    IRfcTable iTable = rfc.GetTable(tablename);
                    if (iTable.Count > 0)
                    {
                        for (int i = 0; i < iTable.RowCount; i++)
                        {
                            iTable.CurrentIndex = i;
                            DataRow oNewRow = dt.NewRow();
                            foreach (string cname in columnnames)
                            {
                                oNewRow[cname] = iTable.GetString(cname).ToString();
                            }
                            dt.Rows.Add(oNewRow);
                        }
                    }
                }
            }

            return dt;
        }
        #endregion
    }