这个例子是C#服务调用RFC函数，获取物料的信息，并生成Excel文件

上接文章：C#服务

创建函数

创建结构

编写源代码

创建批处理文件

echo %~dp0
%SystemRoot%\Microsoft.NET\Framework64\v4.0.30319\installUtil.exe %~dp0WindowsService1_SAP_RFC.exe
Net Start C#ServerTest
sc config C#ServerTest=auto
pause

%SystemRoot%\Microsoft.NET\Framework64\v4.0.30319\InstallUtil.exe /u %~dp0WindowsService1_SAP_RFC.exe
pause

运行结果-成功

部署服务器

C#代码

using SAP.Middleware.Connector;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Configuration;
using System.Data;
using System.Data.OleDb;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.ServiceProcess;
using System.Text;
using System.Threading.Tasks;
using System.Timers;

namespace WindowsService1_SAP_RFC
{
    //创建人：LiuHongyu
    //创建日期：2024年12月20日
    //描述：测试C#服务的创建以及和SAP进行通讯，并生成Excel文档

    public partial class Service1 : ServiceBase
    {
        public Service1()
        {
            InitializeComponent();
        }

        //文件路径
        private string filePath = ConfigurationManager.AppSettings["FilePath"];

        //Excel文件路径
        private string excelFilePath = ConfigurationManager.AppSettings["ExcelFilePath"];

        //Excel模板文件路径
        private string excelFileTemplatePath = ConfigurationManager.AppSettings["ExcelFileTemplatePath"];

        private int n = 1;

        //计时器
        Timer timer;

        //rfc的地址
        private RfcDestination _rfcDestination;

        //每天定时器开关
        private bool dayScheduleSwitch;
        //每天定时执行的时间
        private string dayScheduleTime;
        //每月定时器开关
        private bool monthScheduleSwitch;

        //服务启动时调用
        protected override void OnStart(string[] args)
        {
            WriteLog(filePath, "启动服务------");
            InitTimer();
        }

        private void InitTimer()
        {
            try
            {
                WriteLog(filePath, "开始计数------");
                timer = new Timer(60000);//1分钟

                //时间间隔到了之后，执行的操作为Execute
                timer.Elapsed += Execute;

                //是否重复执行
                timer.AutoReset = true;  //如果不设置就是只会执行一次

                //是否执行Elapsed中的事件
                timer.Enabled = true;
            }
            catch (Exception ex)
            {
                WriteLog(filePath, "计时器错误: " + ex.Message);
                throw;
            }
        }

        //执行的操作
        private void Execute(object sender, ElapsedEventArgs e)
        {
            //注册SAP客户端
            this.RegisterDestination();

            //获取当前的每日定时开关状态
            dayScheduleSwitch = Convert.ToBoolean(ConfigurationManager.AppSettings["DayScheduleSwitch"]);
            
            //获取每日定时执行的时间
            dayScheduleTime = ConfigurationManager.AppSettings["DayScheduleTime"];

            //获取当时的每月定时开关状态
            monthScheduleSwitch = Convert.ToBoolean(ConfigurationManager.AppSettings["MonthScheduleSwitch"]);
            
            //如果每日定时开关打开，并且当时是设置的时间
            if (dayScheduleSwitch && DateTime.Now.ToString("t") == dayScheduleTime)
            {
                timer.Stop();
                //获取SAP数据
                this.InvokeRFCFunctionGetJobList();
                WriteLog(filePath, "第 " + n + " 次数据写入完毕------");
                n++;
                timer.Start();
            }
            else if (monthScheduleSwitch) //每月定时开关是打开状态
            {
                DateTime dt = DateTime.Now;
                int year = dt.Date.Year;    //获取当前的年
                int month = dt.Date.Month;  //获取当前的月
                int dayCount = DateTime.DaysInMonth(year, month); //返回这个当前年当前月的天数

                var endDayOfMonth = new DateTime(year, month, dayCount, 0, 0, 0);  //最后一天
                if (DateTime.Now.ToString("g") == endDayOfMonth.ToString("g"))//g：常规（短日期和短时间）
                {
                    timer.Stop();
                    //获取SAP数据
                    this.InvokeRFCFunctionGetJobList();
                    WriteLog(filePath, "第 " + n + " 次数据写入完毕------");
                    n++;
                    timer.Start();
                }
            }
            
            //DateTime dt = DateTime.Now;
            //int year = dt.Date.Year;    //获取当前的年
            //int month = dt.Date.Month;  //获取当前的月
            //int dayCount = DateTime.DaysInMonth(year, month); //返回这个当前年当前月的天数

            //var endDayOfMonth = new DateTime(year, month, dayCount, 0, 0, 0);  //最后一天
            if (DateTime.Now.ToString("t") == "7:00" || DateTime.Now.ToString("t") == "11:30" || DateTime.Now.ToString("t") == "18:00")
            
            if (DateTime.Now.ToString("g") == endDayOfMonth.ToString("g"))//g：常规（短日期和短时间）
            //if (DateTime.Now.ToString("t") == "16:30")
            //{
            //    timer.Stop();
            //    //获取SAP数据
            //    this.InvokeRFCFunctionGetJobList();
            //    WriteLog(filePath, "第 " + n + " 次数据写入完毕------");
            //    n++;
            //    timer.Start();
            //}
        }

        //获取函数
        private void InvokeRFCFunctionGetJobList()
        {
            //数据表
            DataTable dataTable = new DataTable();
            //根据Destination获取函数
            IRfcFunction rfcFunction = null;
            try
            {
                WriteLog(filePath, "获取数据，第 "+ n +" 次------");
                RfcRepository rfcRepository = _rfcDestination.Repository;
                rfcFunction = rfcRepository.CreateFunction("Z_TEST_CSHAP_GET_MARA");
                rfcFunction.SetValue("I_MATKL", "10010101");  //设置参数
                rfcFunction.SetParameterActive(0, false); //设置参数有效性,false无效
                rfcFunction.Invoke(_rfcDestination);     //执行函数
                IRfcTable rfcTable = rfcFunction.GetTable("OT_TABLE"); //获取返回的表
               

                //给数据表添加列结构
                for (int i = 0; i < rfcTable.ElementCount; i++)
                {
                    RfcElementMetadata rfcElementMetadata = rfcTable.GetElementMetadata(i);
                    dataTable.Columns.Add(rfcElementMetadata.Name);
                }

                //填充数据表
                DataRow drH = dataTable.NewRow();
                drH["MATNR"] = "物料编号";
                drH["MAKTX"] = "物料描述";
                drH["ERSDA"] = "创建日期";
                drH["MATKL"] = "物料组";
                drH["MEINS"] = "基本计量单位";
                drH["ZGUIG"] = "规格";
                dataTable.Rows.Add(drH);
                //填充数据
                foreach (IRfcStructure rs in rfcTable)
                {
                    DataRow dr = dataTable.NewRow();
                    //循环每一列
                    for (int i = 0; i < rfcTable.ElementCount; i++)
                    {
                        RfcElementMetadata rfcElement = rfcTable.GetElementMetadata(i);
                        dr[rfcElement.Name] = rs.GetString(rfcElement.Name);
                    }
                    dataTable.Rows.Add(dr);
                }
                dataTable.TableName = "Data";

                //复制模板Excel，覆盖原来的旧的Excel文件
                File.Copy(excelFileTemplatePath, excelFilePath, true);

                //选择解析文档格式相匹配的字符串
                string connectString = "Provider=Microsoft.ACE.OLEDB.12.0;" + "Data Source=" + excelFilePath + ";" + ";Extended Properties='Excel 12.0;HDR=YES;IMEX=0'";
                using(OleDbConnection con = new OleDbConnection(connectString))
                {
                    con.Open();
                    string insertCmd = "INSERT INTO [Sheet1$] (物料编号,物料描述,创建日期,物料组,基本计量单位,规格) VALUES (?, ?, ?, ?, ?, ?)";//拼接插入语句；
                    //创建执行命令
                    OleDbCommand command = new OleDbCommand(insertCmd, con);

                    //定义执行命令对应值的参数类型；
                    command.Parameters.Add("@物料编号", OleDbType.VarChar);
                    command.Parameters.Add("@物料描述", OleDbType.VarChar);
                    command.Parameters.Add("@创建日期", OleDbType.DBDate);
                    command.Parameters.Add("@物料组", OleDbType.VarChar);
                    command.Parameters.Add("@基本计量单位", OleDbType.VarChar);
                    command.Parameters.Add("@规格", OleDbType.VarChar);

                    //执行插入语句
                    for (int i = 1; i < dataTable.Rows.Count; i++)
                    {
                        command.Parameters["@物料编号"].Value = dataTable.Rows[i]["MATNR"].ToString();
                        command.Parameters["@物料描述"].Value = dataTable.Rows[i]["MAKTX"].ToString();
                        command.Parameters["@创建日期"].Value = dataTable.Rows[i]["ERSDA"].ToString();
                        command.Parameters["@物料组"].Value = dataTable.Rows[i]["MATKL"].ToString();
                        command.Parameters["@基本计量单位"].Value = dataTable.Rows[i]["MEINS"].ToString();
                        command.Parameters["@规格"].Value = dataTable.Rows[i]["ZGUIG"].ToString();

                        command.ExecuteNonQuery();
                    }
                    con.Close();
                }

                #region 写入txt文件,已经注释
                写入txt文件
                //string dataFilePath = "D:\\Projects\\Visual_Studio_2022\\WindowsService1_SAP_RFC\\Data.txt";
                //using (StreamWriter sw = new StreamWriter(dataFilePath,true))
                //{
                //    foreach (IRfcStructure rs in rfcTable)
                //    {
                //        sw.Write(rs.GetString(0).Trim().ToString() + " ");
                //        sw.Write(rs.GetString(1).Trim().ToString() + " ");
                //        sw.Write(rs.GetString(2).Trim().ToString() + " ");
                //        sw.Write(rs.GetString(3).Trim().ToString() + " ");
                //        sw.Write(rs.GetString(4).Trim().ToString() + " ");
                //        sw.Write(rs.GetString(5).Trim().ToString() + " ");
                //        sw.WriteLine();
                //    }
                //}
                #endregion
            }
            catch (Exception ex)
            {
                WriteLog(filePath, "发生错误: " + ex.Message);
                throw;
            }
        }

        private void RegisterDestination()
        {
            try
            {
                if (_rfcDestination == null)
                {
                    //_rfcDestination = RfcDestinationManager.GetDestination("S4P");  //正式库
                    _rfcDestination = RfcDestinationManager.GetDestination("S4D");  //测试库
                }
            }
            catch (Exception ex)
            {
                WriteLog(filePath, "SAP注册客户端失败: " + ex.Message);
            }
        }

        //写日志
        private void WriteLog(string filePath,string message)
        {
            StreamWriter sw = null;
            try
            {
                //创建一个log文件
                sw = new StreamWriter(filePath, true);
                sw.WriteLine(message + DateTime.Now.ToString());
            }
            catch(Exception ex)
            {
                sw.Write(ex.Message + DateTime.Now.ToString());
            }
            finally
            {
                if (sw != null)
                {
                    sw.Close();  //关闭流对象
                    sw.Dispose(); //释放资源
                }
            }
        }

        //服务停止时调用
        protected override void OnStop()
        {
            WriteLog(filePath, "停止服务------");
        }
    }
}

配置文件

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
	<!--关于连接SAP的配置-->
	<configSections>
		<sectionGroup name="SAP.Middleware.Connector">
			<sectionGroup name="ClientSettings">
				<section name="DestinationConfiguration" type="SAP.Middleware.Connector.RfcDestinationConfiguration,sapnco"/>
			</sectionGroup>
		</sectionGroup>
	</configSections>
	<SAP.Middleware.Connector>
		<ClientSettings>
			<DestinationConfiguration>
				<destinations>
					<!--正式系统800-->
					<!--<add NAME="S4P" USER="999999" PASSWD="Hs123456789" CLIENT="800" SYSNR="00" ASHOST="192.168.4.23" LANG="ZH" GROUP="PUBLIC" MAX_POOL_SIZE="10" IDLE_TIMEOUT="600"/>-->

					<!--测试系统310-->
					<add NAME="S4D" USER="024083" PASSWD="Hs87654321" CLIENT="310" SYSNR="00" ASHOST="192.168.4.20" LANG="ZH" GROUP="PUBLIC" MAX_POOL_SIZE="10" IDLE_TIMEOUT="600"/>
				</destinations>
			</DestinationConfiguration>
		</ClientSettings>
	</SAP.Middleware.Connector>


	<startup>
		<supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.8" />
	</startup>
	<startup useLegacyV2RuntimeActivationPolicy="true">
		<supportedRuntime version="v4.0"/>
	</startup>
	<!--配置日志的位置-->
	<appSettings>
		<!--本机测试目录-->
		<add key="FilePath" value="D:\Projects\Visual_Studio_2022\WindowsService1_SAP_RFC\log.txt" />
		<add key="ExcelFilePath" value="D:\Projects\Visual_Studio_2022\WindowsService1_SAP_RFC\SAP返回数据.xlsx"/>
		<add key="ExcelFileTemplatePath" value="D:\Projects\Visual_Studio_2022\WindowsService1_SAP_RFC\SAP返回数据模板.xlsx"/>
		
		<!--服务器测试目录-->
		<!--<add key="FilePath" value="D:\HS_C#Service_RFC_SAP_TEST\WindowsService1_SAP_RFC\log.txt" />
		<add key="ExcelFileTemplatePath" value="D:\HS_C#Service_RFC_SAP_TEST\WindowsService1_SAP_RFC\SAP返回数据模板.xlsx"/>
		<add key="ExcelFilePath" value="D:\HS_C#Service_RFC_SAP_TEST\WindowsService1_SAP_RFC\SAP返回数据.xlsx"/>-->
		
		<!--每月循环开关MonthScheduleSwitch，如果打开（设置为true）就是每月月末执行生成Excel，关闭（设置为false）就不执行-->
		<add key="MonthScheduleSwitch" value="false"/>
		<!--定时开关DayScheduleSwitch，如果打开（设置为true）就是每天定时执行生成Excel，关闭（设置为false）就不执行-->
		<add key="DayScheduleSwitch" value="true"/>
		<!--time:指定每天定时生成Excel的时间 9:00,10:00的格式-->
		<add key="DayScheduleTime" value="14:30"/>

		<add key="ClientSettingsProvider.ServiceUri" value="" />
	
	</appSettings>
</configuration>

注意！！

要先创建好Excel表，并预先准备好表头：