C#通过com端口获取sap数据(sharepoint)

超酷小

　　1.导入Interop.SAPFunctionsOCX.dll      Interop.SAPlogonCtrl.dll      Interop.SAPTableFactoryCtrl
　　2.
　　com端口,缺点：占用线程，单线程
        private void getCurrentStock(object obj)
        {
            SPItemEventProperties Pro = (SPItemEventProperties)obj;
            SPListItem item = Pro.ListItem;
            SAPFunctionsOCX.SAPFunctionsClass func = VStoSAP.getSAPFunctionsClass("", "");
            if (func != null)
            {
                string MaterialNo = getSPFieldTextValue(item["Material"]);
                string Plant = getSPFieldTextValue(item["Plant"]);
　　SAPFunctionsOCX.IFunction ifunc = (SAPFunctionsOCX.IFunction)func.Add("ZRFC_MM_MASTER_MRB");
　　SAPFunctionsOCX.IParameter IV_MATNR = (SAPFunctionsOCX.IParameter)ifunc.get_Exports("IV_MATNR"); //Material No.
                SAPFunctionsOCX.IParameter IV_WERKS = (SAPFunctionsOCX.IParameter)ifunc.get_Exports("IV_WERKS"); //Plant
　　IV_MATNR.Value = MaterialNo;
                IV_WERKS.Value = Plant;
　　ifunc.Call();
　　SAPFunctionsOCX.IParameter EV_MAKTX = (SAPFunctionsOCX.IParameter)ifunc.get_Imports("EV_MAKTX");
                SAPFunctionsOCX.IParameter EV_PRICE = (SAPFunctionsOCX.IParameter)ifunc.get_Imports("EV_PRICE");
                SAPFunctionsOCX.IParameter EV_MEINS = (SAPFunctionsOCX.IParameter)ifunc.get_Imports("EV_MEINS");
                SAPFunctionsOCX.IParameter EV_DSNAM = (SAPFunctionsOCX.IParameter)ifunc.get_Imports("EV_DSNAM");
　　if (EV_MAKTX != null && EV_MAKTX.Value != null)
                {
                    item["Description"] = EV_MAKTX.Value.ToString();
                }
                if (EV_PRICE != null && EV_PRICE.Value != null)
                {
                    item["Unit Price"] = Convert.ToInt32(EV_PRICE.Value);
                }
                if (EV_MEINS != null && EV_MEINS.Value != null)
                {
                    item["Unit"] = EV_MEINS.Value.ToString();
                }
                if (EV_DSNAM != null && EV_DSNAM.Value != null)
                {
                    item["Project"] = EV_DSNAM.Value.ToString();
                }
　　DisableEventFiring();
                item.SystemUpdate();
                EnableEventFiring();
            }
　　
　　}
　　
　　3.Added的事件中处理：
　　#region 方法三：com端口,缺点：占用线程，单线程
            SPItemEventProperties Pro = properties;
            //Thread mrbThread = new Thread(new ThreadStart(getCurrentStock));
           Thread mrbThread = new Thread(getCurrentStock);
            mrbThread.SetApartmentState(ApartmentState.STA);
            //mrbThread.Start();
            mrbThread.Start(properties);
            mrbThread.Join();
　　#endregion
　　
　　4.VStoSAP类
　　using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Data;
using System.Net;
using System.Configuration;
　　namespace EventHandler1888
{
    public class VStoSAP
    {
        private static string getDefaultServerName()
        {
            string hostName = Dns.GetHostName();
            if (hostName.ToUpper() == "正式服务器名字")
            {
                return "PRD";
            }
            else
            {
                return "QAS";
            }
        }
　　static string FindConfigStringValue(string strSrc, string strFind)
        {
            string ss = strSrc.ToUpper();
            strFind = strFind.ToUpper();
            int nStart = ss.IndexOf(strFind, 0);
            if (nStart < 0)
                return null;
            if (nStart > 0 && ss[nStart - 1] != ';')//关键字之前必须有分号或是开始位置
                return null;
　　
            nStart = ss.IndexOf(&quot;=&quot;, nStart);
　　if (nStart < 0)
                return null;
　　nStart&#43;&#43;;
            int nEnd = ss.IndexOf(&quot;;&quot;, nStart);
            if (nEnd < 0)
            {
                return strSrc.Substring(nStart, strSrc.Length - nStart);
            }
            else
            {
                return strSrc.Substring(nStart, nEnd - nStart);
            }
　　}
　　internal static SAPFunctionsOCX.SAPFunctionsClass getSAPFunctionsClass(string Server, string Debug)
        {
            string connStr = &quot;&quot;;
            GetClient(ref Server, Debug, ref connStr);
　　SAPLogonCtrl.SAPLogonControlClass login = new SAPLogonCtrl.SAPLogonControlClass();
            login.ApplicationServer = FindConfigStringValue(connStr, &quot;Server&quot;);
            login.Client = FindConfigStringValue(connStr, &quot;Client&quot;);
            login.Language = FindConfigStringValue(connStr, &quot;Language&quot;);
            login.User = FindConfigStringValue(connStr, &quot;User&quot;);
            login.Password = FindConfigStringValue(connStr, &quot;Psw&quot;);
            login.SystemNumber = Convert.ToInt16(FindConfigStringValue(connStr, &quot;SysNo&quot;));
            try
            {
                SAPLogonCtrl.Connection conn = (SAPLogonCtrl.Connection)login.NewConnection();
                //conn.Language = &quot;ZH&quot;;
                //conn.CodePage = &quot;8400&quot;;
                if (conn.Logon(0, true))
                {
                    SAPFunctionsOCX.SAPFunctionsClass func = new SAPFunctionsOCX.SAPFunctionsClass();
　　func.Connection = conn;
                    return func;
                }
                else
                {
                    return null;
                }
            }
            catch (Exception)
            {
                return null;
            }
　　}
　　private static void GetClient(ref string Server, string Debug, ref string connStr)
        {
            if (string.IsNullOrEmpty(Server))
            {
                Server = getDefaultServerName();
            }
            if (Server.ToUpper() == &quot;PRD&quot;)
            {
                if (Debug == &quot;1&quot;)
                {
                    connStr = ConfigurationManager.AppSettings[&quot;SAPPRDDebug&quot;];
                }
                else
                {
                    connStr = ConfigurationManager.AppSettings[&quot;SAPPRD&quot;];
                }
　　}
            if (Server.ToUpper() == &quot;QAS&quot;)
            {
                if (Debug == &quot;1&quot;)
                {
                    connStr = ConfigurationManager.AppSettings[&quot;SAPQASDebug&quot;];
                }
                else
                {
                    connStr = ConfigurationManager.AppSettings[&quot;SAPQAS&quot;];
                }
            }
        }
　　/// <summary>
        /// &#26684;式化SAPTable为DT
        /// </summary>
        /// <param name=&quot;SAPTable&quot;>SAP Table</param>
        /// <returns></returns>
        internal static DataTable convetTable(SAPTableFactoryCtrl.Table SAPTable)
        {
            try
            {
                int count = SAPTable.ColumnCount;
                DataTable dt = new DataTable();
                dt.Columns.Add(&quot;Index&quot;, typeof(int));
                for (int i = 1; i <= count; i&#43;&#43;)
                {
                    string columnName = SAPTable.get_ColumnName(i);
                    dt.Columns.Add(columnName, typeof(string));
                }
                int countRows = SAPTable.RowCount;
                for (int i = 1; i <= countRows; i&#43;&#43;)
                {
                    DataRow dr = dt.NewRow();
                    for (int j = 1; j < dt.Columns.Count; j&#43;&#43;)
                    {
                        dr[j] = SAPTable.get_Cell(i, SAPTable.get_ColumnName(i)).ToString();
                    }
                    dt.Rows.Add(dr);
                }
                return dt;
            }
            catch (Exception)
            {
                return null;
            }
　　
        }
    }
}