IcsFromERPJob/ICSSoft.FromERP/SK/YERP_011.cs

using Quartz;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.IO;
using System.Linq;
using System.Net;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;

namespace ICSSoft.FromERP
{
    /// <summary>
    /// Account master(交易商主数据)
    /// </summary>
    public class YERP_011 : IJob
    {
        private static object key = new object();
        private static log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
        public void Execute(IJobExecutionContext context)
        {
            try
            {
                lock (key)
                {
                    log.Info("开始……………………………………………………………………");
                    Execute();
                    log.Info("结束……………………………………………………………………");
                }
            }
            catch (Exception ex)
            {
                log.Error(ex.ToString());
            }
        }
        public async void Execute()
        {
            try
            {
                Configuration config = GetConfig();

                var Dates = DateTime.Now;
                string conStr = ICSHelper.GetConnectString();
                //<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:yerp="http://skch.com/YERP_011_IF_ACNT_INFO">
                //   <soapenv:Header/>
                //   <soapenv:Body>
                //      <yerp:YERP_011_OA1_MT>
                //         <!--Zero or more repetitions:-->
                //         <IF_ACNT_MST>
                //            <IF_STD_DATE>2</IF_STD_DATE>
                //            <ACNT_CD>2</ACNT_CD>
                //            <ACNT_NM>2</ACNT_NM>
                //            <!--Optional:-->
                //            <MODIFY_DTTM>2</MODIFY_DTTM>
                //            <GEN_ROW_CNT>2</GEN_ROW_CNT>
                //         </IF_ACNT_MST>
                //      </yerp:YERP_011_OA1_MT>
                //   </soapenv:Body>
                //</soapenv:Envelope>
                // 过滤时间为上个月
                var beginPeriod = "2000-06-01";// Dates.AddMonths(-1).AddDays(-Dates.Day + 1).ToString("yyyy-MM-dd");//"2023-06-01";
                var endPeriod = "2090-06-01";// Dates.AddDays(-Dates.Day + 1).ToString("yyyy-MM-dd");//"2023-07-01";
                string sqls = @"select convert(nvarchar(10),getdate(),112) IF_STD_DATE,
					cCusCode ACNT_CD,
					cCusName ACNT_NM,
					(case when dEndDate is null then '否' else '是' end) DEL_YN,
					dCusCreateDatetime CREATE_DTTM,
					cCreatePerson CREATE_BY,
					dModifyDate MODIFY_DTTM,
					cModifyPerson MODIFY_BY,
					COUNT(*) OVER (PARTITION BY getdate()) GEN_ROW_CNT
					from  dbo.Customer a  WHERE 1 = 1 and dCusCreateDatetime >= '{0}' and dCusCreateDatetime < '{1}'";
                sqls = string.Format(sqls, beginPeriod, endPeriod);
                log.Info("YERP_011 sql:"+sqls);
                DataTable vbsdt = ICSHelper.ExecuteTable(conStr, sqls);
                log.Info("YERP_011 sql结果数量" + vbsdt.Rows.Count);
                if (vbsdt.Rows.Count > 0)
                {
                    StringBuilder soapRequestData = new StringBuilder();
                    soapRequestData.Append("<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:yerp=\"http://skch.com/YERP_011_IF_ACNT_INFO\">");
                    soapRequestData.Append("<soapenv:Header/>");
                    soapRequestData.Append("<soapenv:Body>");
                    soapRequestData.Append("<yerp:YERP_011_OA1_MT>");
                    //循环数据
                    foreach (DataRow itemRow in vbsdt.Rows)
                    {
                        soapRequestData.Append("<!--Zero or more repetitions: -->");
                        soapRequestData.Append("<IF_ACNT_MST>");
                        soapRequestData.Append(itemRow["IF_STD_DATE"] != null ? "<IF_STD_DATE>" + itemRow["IF_STD_DATE"].ToString() + "</IF_STD_DATE>" : "<IF_STD_DATE>" + "</IF_STD_DATE>");
                        soapRequestData.Append(itemRow["ACNT_CD"] != null ? "<ACNT_CD>" + itemRow["ACNT_CD"].ToString() + "</ACNT_CD>" : "<ACNT_CD>" + "</ACNT_CD>");
                        soapRequestData.Append(itemRow["ACNT_NM"] != null ? "<ACNT_NM>" + itemRow["ACNT_NM"].ToString() + "</ACNT_NM>" : "<ACNT_NM>" + "</ACNT_NM>");
                        soapRequestData.Append("<!--Optional:-->");
                        soapRequestData.Append(itemRow["MODIFY_DTTM"] != null ? "<MODIFY_DTTM>" + itemRow["MODIFY_DTTM"].ToString() + "</MODIFY_DTTM>" : "<MODIFY_DTTM>" + "</MODIFY_DTTM>");
                        soapRequestData.Append("<!--Optional:-->");
                        soapRequestData.Append(itemRow["GEN_ROW_CNT"] != null ? "<GEN_ROW_CNT>" + itemRow["GEN_ROW_CNT"].ToString() + "</GEN_ROW_CNT>" : "<GEN_ROW_CNT>" + "</GEN_ROW_CNT>");
                        soapRequestData.Append("</IF_ACNT_MST>");
                    }

                    soapRequestData.Append("</yerp:YERP_011_OA1_MT>");
                    soapRequestData.Append("</soapenv:Body>");
                    soapRequestData.Append("</soapenv:Envelope>");
                    string postData = soapRequestData.ToString();
                    log.Info("YERP_011 xmlRequest:" + postData);

                    string statusCode;
                    string resultContent;
                    ServicePointManager.SecurityProtocol = (SecurityProtocolType)192 | (SecurityProtocolType)768 | (SecurityProtocolType)3072;
                    RestOpHelper rop = new RestOpHelper();
                    rop.Clientp12path = @"C:\Users\Administrator\Desktop\yonyou-cert\wildcard.pfx";
                    rop.Clientp12PassWord = "Yonyou2024!";
                    rop.Url = @"https://yerp-proxy-sap-dev.skchemicals.com/XISOAPAdapter/MessageServlet?senderParty=&senderService=YERP_D&receiverParty=&receiverService=&interface=YERP_011_OA1_SI&interfaceNamespace=http://skch.com/YERP_011_IF_ACNT_INFO";
                    rop.RequestSAP(rop.Url, 10000, postData, "IF_YERP", "Xtxc355860", out statusCode, out resultContent);

                    log.Info("YERP_011 statusCode:" + statusCode + "\r\n" + "resultContent:" + resultContent);

                }
            }
            catch (Exception ex)
            {
                log.Error(ex.ToString());
            }
        }
        public static Configuration GetConfig()
        {
            Assembly assembly = Assembly.GetCallingAssembly();
            string path = string.Format("{0}.config", assembly.Location);
            if (!File.Exists(path))
            {
                throw new FileNotFoundException(path + "路径下的文件未找到！");
            }
            try
            {
                ExeConfigurationFileMap configFile = new ExeConfigurationFileMap();
                configFile.ExeConfigFilename = path;
                Configuration config = ConfigurationManager.OpenMappedExeConfiguration(configFile, ConfigurationUserLevel.None);
                return config;
            }
            catch (Exception)
            {
                throw;
            }
        }
    }
}