C#与SAP进行数据交互

xiahe999

　　最近项目中需要与SAP进行数据对接，特此记录。
　　首先在项目中引用sapnco.dll和sapnco_utils.dll，然后在web.config配置文件中添加SAP一些主要配置信息，为获取SAP配置信息专门写了一个Common类，如下：


　　


1     public abstract class Common
2     {
3         /// <summary>
4         /// 获取SAP配置信息
5         /// </summary>
6         public static SAPServerInfoModel GetSapServerInfo()
7         {
8             SAPServerInfoModel sapInfo = new SAPServerInfoModel
9             {
10                 NAME = ConfigurationManager.AppSettings["NAME"],
11                 ASHOST = ConfigurationManager.AppSettings["ASHOST"],
12                 CLIENT = ConfigurationManager.AppSettings["CLIENT"],
13                 USER = ConfigurationManager.AppSettings["USER"],
14                 PASSWD = ConfigurationManager.AppSettings["PASSWD"],
15                 SYSNR = ConfigurationManager.AppSettings["SYSNR"],
16                 LANG = ConfigurationManager.AppSettings["LANG"]
17             };
18             return sapInfo;
19         }
20     }
View Code　　为初始化SAP配置信息添加了个SAPConfiguration类，如下：


　　


    public class SAPConfiguration : IDestinationConfiguration
{
public bool ChangeEventsSupported()
{
return false;
}
public event RfcDestinationManager.ConfigurationChangeHandler ConfigurationChanged;
private SAPServerInfoModel info;
public SAPConfiguration(SAPServerInfoModel info)
{
this.info = info;
}
public RfcConfigParameters GetParameters(string destinationName)
{
try
{
if (destinationName.Equals("PRD"))
{
RfcConfigParameters parms = new RfcConfigParameters();
parms.Add(RfcConfigParameters.Name, info.NAME);
parms.Add(RfcConfigParameters.AppServerHost, info.ASHOST);
parms.Add(RfcConfigParameters.Client, info.CLIENT);
parms.Add(RfcConfigParameters.User, info.USER);
parms.Add(RfcConfigParameters.Password, info.PASSWD);
parms.Add(RfcConfigParameters.Language, info.LANG);
parms.Add(RfcConfigParameters.SystemNumber, info.SYSNR);
return parms;
}
else
{
return null;
}
}
catch (Exception ex)
{
return null;
}
}
}
View Code　　最后写了一个SAP帮助类，如下:


　　


    public class SAPServerHelper : IDisposable
{
private RfcDestination prd;//SAP Rfc定义声明对象
private SAPConfiguration sapConfig;//SAP配置对象
#region 创建SAP连接对象
/// <summary>
/// 创建SAP连接对象
/// </summary>
public SAPServerHelper()
{
SAPServerInfoModel sapInfo = Common.GetSapServerInfo();
sapConfig = new SAPConfiguration(sapInfo);
prd = RfcDestinationManager.GetDestination(sapConfig.GetParameters("PRD"));
}
#endregion
#region 与SAP进行数据交互（MES->SAP && SAP->MES）
/// <summary>
/// 与SAP进行数据交互（MES->SAP && SAP->MES）
/// </summary>
/// <param name="funName">SAP接口名</param>
/// <param name="lstParameters">SAP传入参数列表</param>
/// <param name="TableName">SAP表名</param>
/// <param name="rtbInputList">SAP传入参数Table列表</param>
/// <param name="outParameters">返回值列表</param>
/// <param name="outList">返回参数列表</param>
/// <returns></returns>
public DataTable getSapFunctionToTable(string funName, Dictionary<string, string> lstParameters, string TableName,
Dictionary<IRfcTable, string> rtbInputList, out Dictionary<string, string> outParameters, List<string> outList)
{
Dictionary<string, string> outDataList = new Dictionary<string, string>();
DataTable dt = new DataTable();
RfcRepository repo = prd.Repository;
//输入
IRfcFunction function = repo.CreateFunction(funName);
foreach (var item in lstParameters)
{
function.SetValue(item.Key, item.Value);
}
foreach (var item in rtbInputList)
{
function.SetValue(item.Value, item.Key);
}
function.Invoke(prd);
//输出
IRfcTable rtb = function.GetTable(TableName);
foreach (var item in outList)
{
outDataList[item] = function.GetString(item);
}
outParameters = outDataList;
dt = CreateTable(rtb, TableName);
return dt;
}
#endregion
#region 与SAP进行数据交互（MES->SAP）返回Table
/// <summary>
///
/// </summary>
/// <param name="funName">RFC名称</param>
/// <param name="lstParameters">参数列表</param>
/// <param name="TableName">返回值Table结构名称</param>
/// <returns></returns>
public DataTable getSapFunctionToTable(string funName, Dictionary<string, string> lstParameters,
string TableName)
{
DataTable dt = new DataTable();
RfcRepository repo = prd.Repository;
IRfcFunction function = repo.CreateFunction(funName);
foreach (var item in lstParameters)
{
function.SetValue(item.Key, item.Value);
}
function.SetParameterActive(0, true);
function.Invoke(prd);
IRfcTable rtb = function.GetTable(TableName);
dt = CreateTable(rtb, TableName);
return dt;
}
#endregion
#region 与SAP进行数据交互（MES->SAP）返回多个字符串+Table
/// <summary>
///
/// </summary>
/// <param name="funName">RFC名称</param>
/// <param name="lstParameters">参数列表</param>
/// <param name="TableName">返回值Table结构名称</param>
/// <param name="outParameters">接收返回字符串List</param>
/// <param name="outList">返回参数列表</param>
/// <returns></returns>
public DataTable getSapFunctionToTable(string funName, Dictionary<string, string> lstParameters,
string TableName, out Dictionary<string, string> outParameters, List<string> outList)
{
Dictionary<string, string> outDataList = new Dictionary<string, string>();
DataTable dt = new DataTable();
RfcRepository repo = prd.Repository;
IRfcFunction function = repo.CreateFunction(funName);
foreach (var item in lstParameters)
{
function.SetValue(item.Key, item.Value);
}
function.SetParameterActive(0, true);
function.Invoke(prd);
IRfcTable rtb = function.GetTable(TableName);
foreach (var item in outList)
{
outDataList[item] = function.GetString(item);
}
outParameters = outDataList;
dt = CreateTable(rtb, TableName);
return dt;
}
#endregion
#region 根据返回的数据,生成DataTable
/// <summary>
/// 根据返回的数据,生成DataTable
/// </summary>
/// <param name="rtb"></param>
/// <param name="TableName"></param>
/// <returns></returns>
private DataTable CreateTable(IRfcTable rtb, string TableName)
{
DataTable dt = new DataTable(TableName);
//建立表结构，设定表头
for (int i = 0; i <= rtb.ElementCount - 1; i++)
{
DataColumn col = new DataColumn(rtb.GetElementMetadata(i).Name);
dt.Columns.Add(col);
}
//填充表数据  
for (int k = 0; k <= rtb.RowCount - 1; k++)
{
DataRow dr = dt.NewRow();
for (int i = 0; i <= rtb.ElementCount - 1; i++)
{
dr = rtb[k].GetValue();
}
dt.Rows.Add(dr);
}
return dt;
}
#endregion
#region 定义要给SAP传送的数据列表(把实际的Table数据转换成SAP可识别的Table数据)
/// <summary>
/// 定义要给SAP传送的数据列表(把实际的Table数据转换成SAP可识别的Table数据)
/// </summary>
/// <param name="dt"></param>
/// <param name="funName"></param>
/// <param name="TableName"></param>
/// <returns></returns>
public IRfcTable CreateRfcTable(DataTable dt, string funName, string TableName)
{
RfcRepository repo = prd.Repository;
IRfcFunction Z_RFC_ZCOX = repo.CreateFunction(funName);
IRfcTable rtb = Z_RFC_ZCOX.GetTable(TableName, true);
for (int i = 0; i < dt.Rows.Count; i++)
{
rtb.Append();
foreach (DataColumn col in dt.Columns)
{
rtb.SetValue(rtb[col.ColumnName].Metadata.Name, dt.Rows[col.ColumnName].ToString());
}
}
return rtb;
}
#endregion
#region 释放资源
/// <summary>
/// 释放资源
/// </summary>
public void Dispose()
{
RfcDestinationManager.UnregisterDestinationConfiguration(sapConfig);
}
#endregion
}
View Code　　该帮助类基本可以实现所有与SAP通过RFC接口进行数据交互，后续根据项目需要继续完善。