C#通過RFC連接sap系統

先理解一下

RFC(Romote Function Call)遠程函數調用

調用前提：

1.要想通過C# 通過RFC調用SAP端，SAP端要存在RFC遠程調用的函數才行（例如SAP端通過SE37創建），要不然是無法調用的。

2.C#調用RFC要有NCO DLL支持（我們使用NCO3.0，VS2013，framework2.0才行否則會報錯)

注：好多人64位系統，開發的時候報錯，到處找支持64位的NCO3.0，這里可以說一下，是木有的，報錯是困為Framework的原因。NCO3.0只支持2.0，在開發環境中改一下就好。

 

開發背景：

因為要做SAP外圍系統IPM接口測試，這個是個異步接口

調用接口之后，返回結果要通過另外一支接口去獲得，由於某些原因不好實現，所以采取別一種方法。

直接通過RFC在sap端查接口調用日志表ZIMPSTXS00330（手工查詢方法，sap端 se11事務，輸入表名，找到MESSAGE字段S代表接口成功，E代碼失敗）

——————下面直接上代碼，其實這個不難——————

引用NCO3.0后

 

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
//using System.Linq;
using System.Text;
using System.Windows.Forms;
using SAP.Middleware.Connector;

namespace WindowsFormsApplication7
{
    public partial class Form2 : Form
    {
        public Form2()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            //rfc配置
            RfcConfigParameters argsP = new RfcConfigParameters();
            argsP.Add(RfcConfigParameters.Name, "QS7");
            argsP.Add(RfcConfigParameters.AppServerHost, "10.5.91.131");
            argsP.Add(RfcConfigParameters.SystemNumber, "00");
            // argsP.Add(RfcConfigParameters.SystemID, "QS7");
            argsP.Add(RfcConfigParameters.User, "ATPSUSER");
            argsP.Add(RfcConfigParameters.Password, "q123456");
            argsP.Add(RfcConfigParameters.Client, "800");
            argsP.Add(RfcConfigParameters.Language, "zh");
            argsP.Add(RfcConfigParameters.PoolSize, "5");
            argsP.Add(RfcConfigParameters.MaxPoolSize, "10");
            argsP.Add(RfcConfigParameters.IdleTimeout, "60");

            //獲取rfc配置
            RfcDestination sapConfig = RfcDestinationManager.GetDestination(argsP); //NCO3.0如果framework不是2.0此處會報錯，跟系統64還32無關
            RfcRepository rfcRepository = sapConfig.Repository;
           
            //調用
            IRfcFunction invoke = rfcRepository.CreateFunction("SE11_FUNC"); //調用函數名 ZRFC_MARA_INFO

            invoke.SetValue("PSPID", ""); //設置參數 項目編號

            invoke.Invoke(sapConfig); //執行函數


            IRfcTable rfcTable = invoke.GetTable("ZIMPSTXS00330"); //獲取內表
            string message = rfcTable.GetValue("MESSAGE").ToString();
            MessageBox.Show(message);
        }
    }
}

 

一些傳的參數，是結構，就不能用setValue來傳參了，要先給結構值

SetStructValue是我封裝好的，給結構值的方法，參數結果名字，結構傳真字符串，model

fc_invoke.SetValue(0, BAPIACHE09IMPORT) 把結構賦值給，函數對象，索引根據，參數位置決定。

                    IRfcFunction rfc_invoke = configModel.rfcRepository.CreateFunction(configModel.IFUNC);

                    var BAPIACHE09IMPORT = SetStructValue("BAPIACHE09", BAPIACHE09Arr, configModel);
                    var BAPIACPA09IMPORT = SetStructValue("BAPIACPA09", BAPIACPA09Arr, configModel);
                    var BAPIACCAHDIMPORT = SetStructValue("BAPIACCAHD", BAPIACCAHDArr, configModel);

                    rfc_invoke.SetValue(0, BAPIACHE09IMPORT);
                    rfc_invoke.SetValue(1, BAPIACPA09IMPORT);
                    rfc_invoke.SetValue(1, BAPIACCAHDIMPORT);


                    IRfcTable rfcTable = rfc_invoke.GetTable("RETURN"); //獲取內表

                    string message = rfcTable.GetValue("MESSAGE").ToString();
                    return message;

 

封裝好的baseClass.cs

using System;
using System.Collections.Generic;
//using System.Linq;
using System.Text;
using System.Reflection;
//using System.Threading.Tasks;
///**************************************************************///
using SAP.Middleware.Connector;
///引用合名空間SAP.Middleware.Connector需要引用sapnco3.0 dll
///sapnco.dll
///sapnco_utils
///**************************************************************///


namespace RC_RFC_LIB
{
    /// <summary>
    /// RFC接口調用
    /// </summary>
    public  class BaseClass
    {
        

        /// <summary>
        /// 登錄配置
        /// </summary>
        /// <returns>bool</returns>
        public bool rfc_config(Model.baseConfigModel configModel)
        {
            try
            {
                //rfc配置
                RfcConfigParameters argsP = new RfcConfigParameters();
                argsP.Add(RfcConfigParameters.Name, configModel.Name);
                argsP.Add(RfcConfigParameters.AppServerHost, configModel.AppServerHost);
                argsP.Add(RfcConfigParameters.SystemNumber, configModel.SystemNumber);
                argsP.Add(RfcConfigParameters.SystemID, configModel.SystemID);
                argsP.Add(RfcConfigParameters.User, configModel.User);
                argsP.Add(RfcConfigParameters.Password, configModel.Password);
                argsP.Add(RfcConfigParameters.Client, configModel.Client);
                argsP.Add(RfcConfigParameters.Language, configModel.Language);
                argsP.Add(RfcConfigParameters.PoolSize, "5");
                argsP.Add(RfcConfigParameters.MaxPoolSize, "10");
                argsP.Add(RfcConfigParameters.IdleTimeout, "60");
                //argsP.Add(RfcConfigParameters.AbapDebug, "DEBUG");
                
                //獲取rfc配置
                configModel.sapConfig = RfcDestinationManager.GetDestination(argsP);
                configModel.rfcRepository = configModel.sapConfig.Repository;
                
            }
            catch (RfcBaseException ex)
            {
                configModel.resultConfig = ex.Message;
                return false;
            }
            return true;
        }



        #region //item傳參
        /// <summary>
        /// 循環設置函數參數，不包含結構
        /// </summary>
        /// <param name="rfc_invoke">函數對象</param>
        /// <param name="itemArr">參數數組“name@_@value”</param>
        public void SetItemParaValue(IRfcFunction rfc_invoke ,string[] itemArr)
        {
            for (var i = 0; i < itemArr.Length; i++)
            {
                var tmpitVal = itemArr[i].Split(new string[] { "@_@" }, StringSplitOptions.RemoveEmptyEntries);
                rfc_invoke.SetValue(tmpitVal[0], tmpitVal[1]); //設置參數 (參數名，參數值)
            }

        }
        #endregion

        #region Struct類型 字段賦值
        /// <summary>
        /// Struct類型 字段賦值
        /// </summary>
        /// <param name="structName">ZAPWZ035 結構字段名</param>
        /// <param name="structFieldArr">結構內字段</param>
        /// <param name="configModel">配置model</param>
        /// <returns>import結構，需要當參數用</returns>
        public IRfcStructure SetStructValue(string structName, string[] structFieldArr,Model.baseConfigModel configModel)
        {
            try
            {
                IRfcStructure import = null;
                //IRfcTable table = rfc_invoke.GetTable("IS_ZAPWZ035");
                //ZAPWZ035
                //rfc_invoke.SetValue(0,import);
                import = configModel.rfcRepository.GetStructureMetadata(structName.Trim().ToUpper()).CreateStructure();

                for (var i = 0; i < structFieldArr.Length; i++)
                {
                    var tmptableVal = structFieldArr[i].Split(new string[] { "@_@" }, StringSplitOptions.None);

                    import.SetValue(tmptableVal[0], tmptableVal[1]); //設置參數 (參數名，參數值)
                }

                return import;
            }
            catch (Exception ex)
            {
                return null;
            }


        }
        #endregion

        #region property賦值

        /// <summary>
        /// property賦值
        /// </summary>
        /// <param name="arrObj">array object</param>
        /// <param name="modelObj">model object instance</param>
        public void SetPropertyValue(string[] arrObj, object modelObj)
        {

            var modelInstance = modelObj.GetType();
            for (var i = 0; i < arrObj.Length; i++)
            {
                var tmpArr = arrObj[i].Split(new string[] { "@_@" }, StringSplitOptions.None);
                foreach (System.Reflection.PropertyInfo py in modelInstance.GetProperties())
                {
                    if (py.Name.ToLower() == tmpArr[0].ToLower())
                    {
                        modelInstance.GetProperty(py.Name).SetValue(modelObj, tmpArr[1]);
                    }
                }
            }
        }
        #endregion


    }
}

baseConfigmodel.cs

using System;
using System.Collections.Generic;
//using System.Linq;
using System.Text;
//using System.Threading.Tasks;
using SAP.Middleware.Connector;


namespace RC_RFC_LIB.Model
{
    public class baseConfigModel
    {


        public string Name { get; set; } //系統名字QH5
        public string AppServerHost { get; set; }//系統ip地址
        public string SystemNumber { get; set; } //系統實例
        public string SystemID { get; set; }//系統id
        public string User { get; set; }//用戶ATPSUSER
        public string Password { get; set; }//密碼
        public string Client { get; set; }//客戶端號800
        public string Language { get; set; } //語言zh en
        public string IFUNC { get; set; } //接口函數名
        public RfcDestination sapConfig { get; set; } //sap登錄配置
        public RfcRepository rfcRepository { get; set; } //Repository對象
        public string resultConfig { get; set; } //配置結果
    }
}