先理解一下
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; } //配置结果 } }