先理解一下
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, "");
// argsP.Add(RfcConfigParameters.SystemID, "QS7");
argsP.Add(RfcConfigParameters.User, "ATPSUSER");
argsP.Add(RfcConfigParameters.Password, "q123456");
argsP.Add(RfcConfigParameters.Client, "");
argsP.Add(RfcConfigParameters.Language, "zh");
argsP.Add(RfcConfigParameters.PoolSize, "");
argsP.Add(RfcConfigParameters.MaxPoolSize, "");
argsP.Add(RfcConfigParameters.IdleTimeout, ""); //获取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(, BAPIACHE09IMPORT);
rfc_invoke.SetValue(, BAPIACPA09IMPORT);
rfc_invoke.SetValue(, 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, "");
argsP.Add(RfcConfigParameters.MaxPoolSize, "");
argsP.Add(RfcConfigParameters.IdleTimeout, "");
//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 = ; i < itemArr.Length; i++)
{
var tmpitVal = itemArr[i].Split(new string[] { "@_@" }, StringSplitOptions.RemoveEmptyEntries);
rfc_invoke.SetValue(tmpitVal[], tmpitVal[]); //设置参数 (参数名,参数值)
} }
#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 = ; i < structFieldArr.Length; i++)
{
var tmptableVal = structFieldArr[i].Split(new string[] { "@_@" }, StringSplitOptions.None); import.SetValue(tmptableVal[], tmptableVal[]); //设置参数 (参数名,参数值)
} 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 = ; 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[].ToLower())
{
modelInstance.GetProperty(py.Name).SetValue(modelObj, tmpArr[]);
}
}
}
}
#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; } //配置结果
}
}