HEGII.ss.mes.wcf/DK.Basics/Library/SapApi.cs

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;

using Dongke.IBOSS.PRD.Basics.Library;
using SAP.Middleware.Connector;

/// <summary>
/// SapApi
/// </summary>
public class SapApi
{
    //SAP服务器配置参数
    public static INIUtility ini = INIUtility.Instance(INIUtility.IniFile.SAP_HEGII);
    public static string appServerHost = ini.ReadIniData("SAP_RFC_INFO", "SapAppServerHost");
    public static string systemNumber = ini.ReadIniData("SAP_RFC_INFO", "SapSystemNumber");
    public static string user = ini.ReadIniData("SAP_RFC_INFO", "SapUser");
    public static string password = ini.ReadIniData("SAP_RFC_INFO", "SapPassword");
    public static string client = ini.ReadIniData("SAP_RFC_INFO", "SapClient");

    /// <summary>
    /// 读取库存单价接口（获取库存数量）
    /// </summary>
    /// <param name="WERKS">工厂代号</param>
    /// <param name="MATNR">物料编号</param>
    /// <param name="LGORT">库存地点</param>
    /// <param name="ZTYPE">消息类型: S 成功,E 错误,W 警告,I 信息,A 中断</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static DataTable ZMMFM037(string WERKS, List<string> matnrs, string LGORT, out string ZTYPE, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMMFM037");

        //输入参数
        IRfcTable imTable = rfcApi.GetTable("TAB_IN");

        foreach (string MATNR in matnrs)
        {
            imTable.Append();
            imTable.SetValue("WERKS", WERKS);
            imTable.SetValue("MATNR", MATNR);
            imTable.SetValue("LGORT", LGORT);
        }

        //调用接口
        rfcApi.Invoke(rfcDest);

        //获取输出
        ZTYPE = rfcApi.GetValue("ZTYPE").ToString();
        ZMSG = rfcApi.GetValue("ZMSG").ToString();
        IRfcTable table = rfcApi.GetTable("TAB_OUT");

        DataTable dt = GetDataTableFromRFCTable(table);

        //string[] columns = new string[] { "WERKS", "MATNR", "MEINS", "VBELN", "POSNR", "CHARG", "LGORT", "MENGE", "VERPR", "WAERS" };
        //DataTable dt = new DataTable();
        //foreach (string clmn in columns)
        //{
        //    dt.Columns.Add(clmn);
        //}
        //for (int i = 0; i < table.RowCount; i++)
        //{
        //    DataRow dr = dt.NewRow();
        //    foreach (string clmn in columns)
        //    {
        //        dr[clmn] = table.GetString(clmn);
        //    }
        //    dt.Rows.Add(dr);
        //}

        rfcDest = null;
        rfcRep = null;

        return dt;
    }

    /// <summary>
    /// 读取库存单价接口（获取库存数量）
    /// </summary>
    /// <param name="WERKS">工厂代号</param>
    /// <param name="MATNR">物料编号</param>
    /// <param name="LGORT">库存地点</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static DataTable ZMM_WMS016(string WERKS, List<string> matnrs, string LGORT, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMM_WMS016");

        //输入参数
        IRfcTable imTable = rfcApi.GetTable("IT_INPUT");
        if (matnrs != null && matnrs.Count > 0)
        {
            foreach (string MATNR in matnrs)
            {
                imTable.Append();
                imTable.SetValue("WERKS", WERKS);
                imTable.SetValue("MATNR", MATNR);
                imTable.SetValue("LGORT", LGORT);
            }
        }
        else
        {

            imTable.Append();
            imTable.SetValue("WERKS", WERKS);
            imTable.SetValue("MATNR", "");
            imTable.SetValue("LGORT", LGORT);


        }

        //调用接口
        rfcApi.Invoke(rfcDest);

        //获取输出
        ZMSG = rfcApi.GetValue("E_MSG").ToString();
        IRfcTable table = rfcApi.GetTable("IT_OUTPUT");

        DataTable dt = GetDataTableFromRFCTable(table);

        rfcDest = null;
        rfcRep = null;

        return dt;
    }

    /// <summary>
    /// 物料凭证通用接口
    /// </summary>
    /// <param name="list">数据</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static DataTable ZMMFM_MES_YCDB(List<SendSendOutGoods> list, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMMFM_MES_YCDB");

        //输入参数
        IRfcTable imTable = rfcApi.GetTable("GT_INPUT");
        if (list != null && list.Count > 0)
        {
            foreach (SendSendOutGoods ss in list)
            {
                imTable.Append();
                imTable.SetValue("WERKS", ss.WERKS);
                imTable.SetValue("MATNR", ss.MATNR);
                imTable.SetValue("LGORT", ss.LGORT);
                imTable.SetValue("MESNO", ss.MESNO);
                imTable.SetValue("MESLINENO", ss.MESLINENO);
                imTable.SetValue("ZID", ss.ZID);
                imTable.SetValue("BUDAT", ss.BUDAT);
                imTable.SetValue("BWART", ss.BWART);
                imTable.SetValue("PSMNG", ss.PSMNG);
                imTable.SetValue("MEINS", ss.MEINS);
                imTable.SetValue("MOVE_MAT", ss.MOVE_MAT);
                imTable.SetValue("MOVE_STLOC", ss.MOVE_STLOC);
                imTable.SetValue("MOVE_BATCH", ss.MOVE_BATCH);
                imTable.SetValue("CHARG", ss.CHARG);
                imTable.SetValue("CARID", ss.CARID);
            }
        }

        //调用接口
        rfcApi.Invoke(rfcDest);
        ZMSG = "";
        //获取输出
        // ZMSG = rfcApi.GetValue("E_MSG").ToString();
        IRfcTable table = rfcApi.GetTable("GT_OUTPUT");

        DataTable dt = GetDataTableFromRFCTable(table);

        rfcDest = null;
        rfcRep = null;

        return dt;
    }
    public class SendSendOutGoods
    {
        public string MESNO;
        public string MESLINENO;
        public string ZID;
        public string BUDAT;
        public string HEADER_TXT;
        public string BWART;
        public string SOBKZ;
        public string MOVE_REAS;
        public string WERKS;
        public string MATNR;
        public int PSMNG;
        public string MEINS;
        public string LGORT;
        public string CHARG;
        public string KDAUF;
        public int KDPOS;
        public string MOVE_MAT;
        public string MOVE_STLOC;
        public string MOVE_BATCH;
        public string VAL_SALES_ORD;
        public int VAL_S_ORD_ITEM;
        public string CARID;
    }
    /// <summary>
    /// 读取库存单价接口（获取库存数量）
    /// </summary>
    /// <param name="WERKS">工厂代号</param>
    /// <param name="LGORT">库存地点</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static DataTable ZMM_WMS016(string WERKS, DataTable dtInventory, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMM_WMS016");

        //输入参数
        IRfcTable imTable = rfcApi.GetTable("IT_INPUT");

        foreach (DataRow row in dtInventory.Rows)
        {
            imTable.Append();
            imTable.SetValue("WERKS", WERKS);
            imTable.SetValue("MATNR", row["IDNRK"]);
            imTable.SetValue("LGORT", row["POSITION"]);
        }

        //调用接口
        rfcApi.Invoke(rfcDest);

        //获取输出
        ZMSG = rfcApi.GetValue("E_MSG").ToString();
        IRfcTable table = rfcApi.GetTable("IT_OUTPUT");

        DataTable dt = GetDataTableFromRFCTable(table);

        rfcDest = null;
        rfcRep = null;

        return dt;
    }

    /// <summary>
    /// 查询PO的相关信息（获取订单达成数量）
    /// </summary>
    /// <param name="IN_EBELN">采购凭证号</param>
    /// <param name="ZTYPE">消息类型: S 成功,E 错误,W 警告,I 信息,A 中断</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static DataTable ZMMFM_MES_POCX(string IN_EBELN, out string ZTYPE, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMMFM_MES_POCX");

        //输入参数
        rfcApi.SetValue("IN_EKORG", 1000);
        rfcApi.SetValue("IN_EBELN", IN_EBELN);
        rfcApi.SetValue("IN_AEDAT_FROM", "20220101");
        rfcApi.SetValue("IN_AEDAT_TO", "20301231");

        //调用接口
        rfcApi.Invoke(rfcDest);

        //获取输出
        ZTYPE = rfcApi.GetValue("ZTYPE").ToString();
        ZMSG = rfcApi.GetValue("ZMSG").ToString();
        IRfcTable table = rfcApi.GetTable("GT_OUT");

        //EBELN  采购凭证编号
        //EBELP  采购凭证的项目编号
        //MENGE  采购订单数量
        //MEINS  订单计量单位
        //ZYSSL  已收/ 退数量数量
        //ZWSSL  未收/ 退数量
        //ELIKZ  交货已完成标识
        //LIFNR  供应商编码
        //EKGRP  采购组
        //MATNR  物料编码

        //string[] columns = new string[] { "EBELN", "EBELP", "MENGE", "MEINS", "ZYSSL", "ZWSSL", "ELIKZ", "LIFNR", "EKGRP", "MATNR" };
        DataTable dt = GetDataTableFromRFCTable(table);
        //foreach (string clmn in columns)
        //{
        //    dt.Columns.Add(clmn);
        //}
        //for (int i = 0; i < table.RowCount; i++)
        //{
        //    DataRow dr = dt.NewRow();
        //    foreach (string clmn in columns)
        //    {
        //        dr[clmn] = table.ro.GetString(clmn);
        //    }
        //    dt.Rows.Add(dr);
        //}

        rfcDest = null;
        rfcRep = null;

        return dt;
    }

    /// <summary>
    /// 物料主数据接口（同步最小包装数用）
    /// </summary>
    /// <param name="MBLNR">物料凭证编号</param>
    /// <param name="createTime">创建时间</param>
    /// <param name="ZTYPE">消息类型: S 成功,E 错误,W 警告,I 信息,A 中断</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static DataTable ZMMFM054(out string ZTYPE, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMMFM054");

        //输入参数
        rfcApi.SetValue("IN_ALL", 'Y');
        rfcApi.SetValue("IN_WERKS", 5020);

        //调用接口
        rfcApi.Invoke(rfcDest);

        //获取输出
        ZTYPE = rfcApi.GetValue("ZTYPE").ToString();
        ZMSG = rfcApi.GetValue("ZMSG").ToString();
        IRfcTable table = rfcApi.GetTable("OUT_TABLE");

        DataTable dt = GetDataTableFromRFCTable(table);

        rfcDest = null;
        rfcRep = null;
        return dt;
    }

    /// <summary>
    /// 东科与SAP系统之线边仓库存领用接口（库存过账）
    /// </summary>
    /// <param name="BLDAT">过帐日期</param>
    /// <param name="ZDKNO">东科单据号</param>
    /// <param name="ZTYPE">消息类型: S 成功,E 错误,W 警告,I 信息,A 中断</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static DataTable ZMMFM045(string BLDAT, string ZDKNO, DataTable dtTable, out string ZTYPE, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMMFM045");

        //BLDAT     DATS    8   0   必填 凭证日期    格式: yyyymmdd
        //BUDAT     DATS    8   0   必填 过帐日期    格式: yyyymmdd
        //WERKS     CHAR    4   0   必填 工厂  5020
        //LGORT_FM  CHAR    4   0   必填 发出库位
        //LGORT_TO  CHAR    4   0   必填 接收库位
        //MATNR     CHAR    40  0   必填 物料编号
        //BWART     CHAR    3   0   必填 移动类型(库存管理)  目前只允许填：311
        //MEINS     UNIT    3   0   必填 基本计量单位
        //MENGE     QUAN    13  3   必填 数量
        //ZDKNO     CHAR    40  0   必填 东科单据号

        //输入参数
        IRfcTable imTable = rfcApi.GetTable("IT_ITEM");

        foreach (DataRow dr in dtTable.Rows)
        {
            imTable.Append();
            imTable.SetValue("BLDAT", BLDAT);
            imTable.SetValue("BUDAT", BLDAT);
            imTable.SetValue("WERKS", "5000");
            imTable.SetValue("LGORT_FM", dr["LGORT_FM"]);
            imTable.SetValue("LGORT_TO", dr["TOLOGT"]);
            imTable.SetValue("MATNR", dr["MATNR"]);
            imTable.SetValue("CHARG", dr["CHARG"] + "");
            imTable.SetValue("BWART", "311");
            imTable.SetValue("MEINS", dr["MEINS"]);
            imTable.SetValue("MENGE", dr["MENGE"]);
            imTable.SetValue("ZDKNO", ZDKNO);
        }

        //调用接口
        rfcApi.Invoke(rfcDest);

        //获取输出
        ZTYPE = rfcApi.GetValue("ZTYPE").ToString();
        ZMSG = rfcApi.GetValue("ZMSG").ToString();
        IRfcTable table = rfcApi.GetTable("ET_RETURN");

        DataTable dt = GetDataTableFromRFCTable(table);

        //string[] columns = new string[] { "BLDAT", "WERKS", "MBLNR", "MJAHR", "MSGTY", "MSGTX" };
        //DataTable dt = new DataTable();
        //foreach (string clmn in columns)
        //{
        //    dt.Columns.Add(clmn);
        //}
        //for (int i = 0; i < table.RowCount; i++)
        //{
        //    DataRow dr = dt.NewRow();
        //    foreach (string clmn in columns)
        //    {
        //        dr[clmn] = table.GetString(clmn);
        //    }
        //    dt.Rows.Add(dr);
        //}

        rfcDest = null;
        rfcRep = null;

        return dt;
    }

    /// <summary>
    /// 冲销凭证接口（撤销过账）
    /// </summary>
    /// <param name="MBLNR">物料凭证编号</param>
    /// <param name="createTime">创建时间</param>
    /// <param name="ZTYPE">消息类型: S 成功,E 错误,W 警告,I 信息,A 中断</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static void ZMMFM038(string MBLNR, DateTime createTime, out string ZTYPE, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMMFM038");

        //输入参数
        rfcApi.SetValue("MBLNR", MBLNR);
        rfcApi.SetValue("MJAHR", createTime.ToString("yyyy"));
        rfcApi.SetValue("BUDAT", createTime.ToString("yyyyMMdd"));

        //调用接口
        rfcApi.Invoke(rfcDest);

        //获取输出
        ZTYPE = rfcApi.GetValue("ZTYPE").ToString();
        ZMSG = rfcApi.GetValue("ZMSG").ToString(); 
        rfcDest = null;
        rfcRep = null; 
    }

    /// <summary>
    /// 测试用，用于把线边仓的货，全挪走
    /// </summary>
    /// <param name="BLDAT">过帐日期</param>
    /// <param name="ZDKNO">东科单据号</param>
    /// <param name="ZTYPE">消息类型: S 成功,E 错误,W 警告,I 信息,A 中断</param>
    /// <param name="ZMSG">消息文本</param>
    /// <returns></returns>
    public static DataTable ZMMFM045_TEST(string BLDAT, string ZDKNO, DataTable dtTable, out string ZTYPE, out string ZMSG)
    {
        RfcConfigParameters rfcPara = new RfcConfigParameters();
        rfcPara.Add(RfcConfigParameters.AppServerHost, appServerHost);
        rfcPara.Add(RfcConfigParameters.SystemNumber, systemNumber);
        rfcPara.Add(RfcConfigParameters.User, user);
        rfcPara.Add(RfcConfigParameters.Password, password);
        rfcPara.Add(RfcConfigParameters.Client, client);

        rfcPara.Add(RfcConfigParameters.Name, "CON");
        rfcPara.Add(RfcConfigParameters.Language, "ZH");
        rfcPara.Add(RfcConfigParameters.PoolSize, "5");
        rfcPara.Add(RfcConfigParameters.ConnectionIdleTimeout, "60");

        RfcDestination rfcDest = RfcDestinationManager.GetDestination(rfcPara);
        RfcRepository rfcRep = rfcDest.Repository;

        //接口API
        IRfcFunction rfcApi = rfcRep.CreateFunction("ZMMFM045");

        //BLDAT     DATS    8   0   必填 凭证日期    格式: yyyymmdd
        //BUDAT     DATS    8   0   必填 过帐日期    格式: yyyymmdd
        //WERKS     CHAR    4   0   必填 工厂  5020
        //LGORT_FM  CHAR    4   0   必填 发出库位
        //LGORT_TO  CHAR    4   0   必填 接收库位
        //MATNR     CHAR    40  0   必填 物料编号
        //BWART     CHAR    3   0   必填 移动类型(库存管理)  目前只允许填：311
        //MEINS     UNIT    3   0   必填 基本计量单位
        //MENGE     QUAN    13  3   必填 数量
        //ZDKNO     CHAR    40  0   必填 东科单据号

        //输入参数
        IRfcTable imTable = rfcApi.GetTable("IT_ITEM");

        foreach (DataRow dr in dtTable.Rows)
        {
            imTable.Append();
            imTable.SetValue("BLDAT", BLDAT);
            imTable.SetValue("BUDAT", BLDAT);
            imTable.SetValue("WERKS", "5020");
            imTable.SetValue("LGORT_FM", "2205");
            imTable.SetValue("LGORT_TO", "1103");
            imTable.SetValue("MATNR", dr["MATNR"]);
            imTable.SetValue("CHARG", dr["CHARG"] + "");
            imTable.SetValue("BWART", "311");
            imTable.SetValue("MEINS", dr["MEINS"]);
            imTable.SetValue("MENGE", dr["MENGE"]);
            imTable.SetValue("ZDKNO", ZDKNO);
        }

        //调用接口
        rfcApi.Invoke(rfcDest);

        //获取输出
        ZTYPE = rfcApi.GetValue("ZTYPE").ToString();
        ZMSG = rfcApi.GetValue("ZMSG").ToString();
        IRfcTable table = rfcApi.GetTable("ET_RETURN");

        DataTable dt = GetDataTableFromRFCTable(table);

        rfcDest = null;
        rfcRep = null;

        return dt;
    }

    /// <summary>
    /// IRfcTable转DataTable
    /// </summary>
    /// <param name="myrfcTable"></param>
    /// <returns></returns>
    private static DataTable GetDataTableFromRFCTable(IRfcTable myrfcTable)
    {

        DataTable loTable = new DataTable();
        int liElement = 0;
        for (liElement = 0; liElement <= myrfcTable.ElementCount - 1; liElement++)
        {
            RfcElementMetadata metadata = myrfcTable.GetElementMetadata(liElement);
            loTable.Columns.Add(metadata.Name);
        }

        foreach (IRfcStructure Row in myrfcTable)
        {
            DataRow ldr = loTable.NewRow();
            for (liElement = 0; liElement <= myrfcTable.ElementCount - 1; liElement++)
            {
                RfcElementMetadata metadata = myrfcTable.GetElementMetadata(liElement);
                ldr[metadata.Name] = Row.GetString(metadata.Name);
            }
            loTable.Rows.Add(ldr);
        }
        return loTable;
    }
}