C#调用SAP RFC

RFC 结构:

Name :	Z_RFC_XXXX
Import:
	WERKS	Plant	A
	STATUS	Export indicator	B
Table:	INPUT_TABLE	Input Table
	RETURN_TABLE	Export Table
INPUT_TABLE:
str1	CHAR	12
str2	CHAR	12
str3	CHAR	12
RETURN_TABLE:
X	CHAR	3	0
Y	CHAR	12	0
Z	CHAR	18	0

 

 

using SAP.Middleware.Connector;

private RfcConfigParameters _params = new RfcConfigParameters();
private RfcDestination _rfcDest;

RfcConfigParameters parms = new RfcConfigParameters();
            parms.Add(RfcConfigParameters.Name, "xxx");
            parms.Add(RfcConfigParameters.AppServerHost, "xxx");
            parms.Add(RfcConfigParameters.SystemNumber, "00");
            parms.Add(RfcConfigParameters.Client, "900");
            parms.Add(RfcConfigParameters.User, "xxx");
            parms.Add(RfcConfigParameters.Password, "xxxxx");
            parms.Add(RfcConfigParameters.Language, "EN");
            parms.Add(RfcConfigParameters.PoolSize, "5");
            parms.Add(RfcConfigParameters.MaxPoolSize, "10");
            parms.Add(RfcConfigParameters.IdleTimeout, "600");
            return parms;

_rfcDest = RfcDestinationManager.GetDestination(_params);

 1 public DataTable GetSAPData(DataTable dt)
        {
            DataTable dtSAPData = new DataTable();
            try
            {
                dtSAPData.Columns.Add("DATA1", typeof(string));
                dtSAPData.Columns.Add("DATA2", typeof(string));
                dtSAPData.Columns.Add("DATA3", typeof(string));


                string strOrder = null;

                RfcRepository   rfcRep      =   _rfcDest.Repository;
                IRfcFunction    func        =   rfcRep.CreateFunction("Z_RFC_XXXX");
                IRfcTable       tSAP    =   func.GetTable("INPUT_TABLE");

                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    str1 = dt.Rows[i][0].ToString();
                    str2 = dt.Rows[i][1].ToString();
                    str3 = dt.Rows[i][2].ToString();
                    IRfcStructure struSAP = tSAP.Metadata.LineType.CreateStructure();
                    struSAP.SetValue("str1", str1);
                    struSAP.SetValue("str2", str2);
                    struSAP.SetValue("str3", str3);
                    tSAP.Append(struSAP);
                }
                func.SetValue("INPUT_TABLE", tSAP); //table 参数
                func.SetValue("WERKS", "A");        //单个参数    
                func.SetValue("STATUS", "B");    //单个参数
                func.Invoke(_rfcDest);
                IRfcTable SAPDataTable = func.GetTable("RETURN_TABLE");

                for (int i = 0; i < SAPDataTable.RowCount; i++)
                {
                    IRfcStructure   stru    =   SAPDataTable[i];
                    DataRow         dr      =   dtSAPData.NewRow();

                    dr["DATA1"] = stru.GetValue("X").ToString();   
                    dr["DATA2"] = stru.GetValue("Y").ToString();   
                    dr["DATA3"] = stru.GetValue("Z").ToString();   

                    
                    dtSAPData.Rows.Add(dr);
                }
            }
            catch(Exception ex)
            {
                string strcatch = ex.Message;
            }
            return dtSAPData;
        }