xusc
/
IcsFromERPJob
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

SK项目

Branch_PaiNaWeiSJob
shiqian.wang 4 weeks ago
parent
5e39af8463
commit
1608fb374e
5 changed files with 659 additions and 1 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 3
      ICSSoft.FromERP/ICSSoft.FromERP.csproj
  2. 228
      ICSSoft.FromERP/SK/YERP_002.cs
  3. 166
      ICSSoft.FromERP/SK/YERP_003.cs
  4. 261
      ICSSoft.FromERP/SK/YERP_004.cs
  5. 2
      ICSSoft.FromERP/SK/YERP_007.cs

3
ICSSoft.FromERP/ICSSoft.FromERP.csproj
View File

@ -154,6 +154,9 @@
<Compile Include="ICSSO.cs" />
<Compile Include="RestOpHelper.cs" />
<Compile Include="SK\YERP_001.cs" />
<Compile Include="SK\YERP_002.cs" />
<Compile Include="SK\YERP_003.cs" />
<Compile Include="SK\YERP_004.cs" />
<Compile Include="SK\YERP_005.cs" />
<Compile Include="SK\YERP_007.cs" />
<Compile Include="SK\YERP_008.cs" />

228
ICSSoft.FromERP/SK/YERP_002.cs
View File

@ -0,0 +1,228 @@
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.Text.RegularExpressions;
using System.Threading.Tasks;
namespace ICSSoft.FromERP
{
/// <summary>
/// 销售发票列表
/// </summary>
public class YERP_002 : 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();
//string url = config.ConnectionStrings.ConnectionStrings["APIAddStdWorkHour"].ConnectionString.ToString();
var Dates = DateTime.Now;
string conStr = ICSHelper.GetConnectString();
// 202404
// 过滤时间为上个月
string Date = Dates.ToString("yyyy");
string Muoth = Dates.AddMonths(-1).ToString("MM");
string Day = Dates.ToString("dd");
//<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:yerp="http://skch.com/YERP_002_SALES_INVOICE">
// <soapenv:Header/>
// <soapenv:Body>
// <yerp:YERP_002_OA1_MT>
// <!--1 or more repetitions:-->
// <SLS_INVC>
// <!--Optional:-->
// <P_ORDER_NUM>?</P_ORDER_NUM>
// <BIZ_TYP>?</BIZ_TYP>
// <SL_TYP>?</SL_TYP>
// <INVC_NO>?</INVC_NO>
// <INVC_DE>?</INVC_DE>
// <DO_NO>?</DO_NO>
// <CUST_CD>?</CUST_CD>
// <CUST_NM>?</CUST_NM>
// <CUR>?</CUR>
// <ER>?</ER>
// <!--Optional:-->
// <SL_TEAM>?</SL_TEAM>
// <!--Optional:-->
// <SL_PIC>?</SL_PIC>
// <WH>?</WH>
// <INVT_CD>?</INVT_CD>
// <INVT_NM>?</INVT_NM>
// <!--Optional:-->
// <STDD_MDL>?</STDD_MDL>
// <QTY>?</QTY>
// <!--Optional:-->
// <STMT>?</STMT>
// <PRTX_UPRC>?</PRTX_UPRC>
// <FRTX_UPRC>?</FRTX_UPRC>
// <FRTX_AMT>?</FRTX_AMT>
// <TXRTO>?</TXRTO>
// <TX_AMT>?</TX_AMT>
// <PRTX_AMT>?</PRTX_AMT>
// <!--Optional:-->
// <DISRTO1>?</DISRTO1>
// <!--Optional:-->
// <DISRTO2>?</DISRTO2>
// <!--Optional:-->
// <DIS_AMT>?</DIS_AMT>
// <CRTR>?</CRTR>
// <REVR>?</REVR>
// <!--Optional:-->
// <STTL_TYP_CD>?</STTL_TYP_CD>
// <!--Optional:-->
// <DLVR_TYP_CD>?</DLVR_TYP_CD>
// <!--Optional:-->
// <DLVR_TYP>?</DLVR_TYP>
// <!--Optional:-->
// <STTL_TYP>?</STTL_TYP>
// <OUTST_AMT>?</OUTST_AMT>
// <OUTST_LCUR>?</OUTST_LCUR>
// </SLS_INVC>
// </yerp:YERP_002_OA1_MT>
// </soapenv:Body>
//</soapenv:Envelope>
var beginPeriod = "2023-07-01";// Dates.AddMonths(-1).AddDays(-Dates.Day + 1).ToString("yyyy-MM-dd");//"2023-06-01";
var endPeriod = "2023-08-01";// Dates.AddDays(-Dates.Day + 1).ToString("yyyy-MM-dd");//"2023-07-01";
string sqls = @"
select b.cSOCode P_ORDER_NUM,cBusType BIZ_TYP,cSTName SL_TYP,cSBVCode INVC_NO,dDate INVC_DE,cDLCode DO_NO,cCusCode CUST_CD,cCusName CUST_NM,cexch_name CUR,iExchRate ER,
cDepName SL_TEAM, cPsn_Name SL_PIC,cWhCode WH, b.cInvCode INVT_CD, c.cInvAddCode INVT_ACD, c.cInvName INVT_NM, c.cInvStd STDD_MDL, b.iQuantity QTY, b.iQuotedPrice STMT, iTaxUnitPrice PRTX_UPRC,
iUnitPrice FRTX_UPRC, iMoney FRTX_AMT,b.iTaxRate TXRTO, iTax TX_AMT,iSum PRTX_AMT, KL DISRTO1,KL2 DISRTO2, iDisCount DIS_AMT,cMaker CRTR, cChecker REVR,a.csscode STTL_TYP_CD, a.cSCCode DLVR_TYP_CD,
d.cSCName DLVR_TYP, cSSName STTL_TYP,
iSum - iExchSum OUTST_AMT, --原币价税合计 - 累计原币收款金额
iNatSum - iMoneySum OUTST_LCUR, --本币价税合计-累计本币收款金额
0 Printnum,a.dDate
from dbo.SaleBillVouch a left join dbo.SaleBillVouchs b on A.SBVID = B.SBVID
left join dbo.Inventory c on b.cInvCode = c.cInvCode
left join dbo.ShippingChoice d on a.cSCCode = d.cSCCode
left join dbo.SettleStyle e on a.csscode = e.cSSCode
left join dbo.SaleType f on a.cSTCode = f.cSTCode
left join dbo.hr_hi_person h on a.cPersonCode = h.cPsn_Num
left join dbo.Department j on j.cDepCode = a.cDepCode WHERE 1 = 1 and a.dDate >= '{0}' and a.dDate <= '{1}'";
sqls = string.Format(sqls, beginPeriod, endPeriod);
log.Info("YERP_002 sql:" + sqls);
DataTable vbsdt = ICSHelper.ExecuteTable(conStr, sqls);
log.Info("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_002_SALES_INVOICE\">");
soapRequestData.Append("<soapenv:Header/>");
soapRequestData.Append("<soapenv:Body>");
soapRequestData.Append("<yerp:YERP_002_OA1_MT>");
//循环数据
foreach (DataRow itemRow in vbsdt.Rows)
{
//原循环部分 begin
soapRequestData.Append("<SLS_INVC>");
soapRequestData.Append(itemRow["P_ORDER_NUM"] != null ? "<P_ORDER_NUM>" + itemRow["P_ORDER_NUM"].ToString() + "</P_ORDER_NUM>" : "<P_ORDER_NUM>" + "</P_ORDER_NUM>");
soapRequestData.Append(itemRow["BIZ_TYP"] != null ? "<BIZ_TYP>" + itemRow["BIZ_TYP"].ToString() + "</BIZ_TYP>" : "<BIZ_TYP>" + "</BIZ_TYP>");
soapRequestData.Append(itemRow["SL_TYP"] != null ? "<SL_TYP>" + itemRow["SL_TYP"].ToString() + "</SL_TYP>" : "<SL_TYP>" + "</SL_TYP>");
soapRequestData.Append(itemRow["INVC_NO"] != null ? "<INVC_NO>" + itemRow["INVC_NO"].ToString() + "</INVC_NO>" : "<INVC_NO>" + "</INVC_NO>");
soapRequestData.Append(itemRow["INVC_DE"] != null ? "<INVC_DE>" + itemRow["INVC_DE"].ToString() + "</INVC_DE>" : "<INVC_DE>" + "</INVC_DE>");
soapRequestData.Append(itemRow["DO_NO"] != null ? "<DO_NO>" + itemRow["DO_NO"].ToString() + "</DO_NO>" : "<DO_NO>" + "</DO_NO>");
soapRequestData.Append(itemRow["CUST_CD"] != null ? "<CUST_CD>" + itemRow["CUST_CD"].ToString() + "</CUST_CD>" : "<CUST_CD>" + "</CUST_CD>");
soapRequestData.Append(itemRow["CUST_NM"] != null ? "<CUST_NM>" + itemRow["CUST_NM"].ToString() + "</CUST_NM>" : "<CUST_NM>" + "</CUST_NM>");
soapRequestData.Append(itemRow["CUR"] != null ? "<CUR>" + itemRow["CUR"].ToString() + "</CUR>" : "<CUR>" + "</CUR>");
soapRequestData.Append(itemRow["ER"] != null ? "<ER>" + itemRow["ER"].ToString() + "</ER>" : "<ER>" + "</ER>");
soapRequestData.Append(itemRow["SL_TEAM"] != null ? "<SL_TEAM>" + itemRow["SL_TEAM"].ToString() + "</SL_TEAM>" : "<SL_TEAM>" + "</SL_TEAM>");
soapRequestData.Append(itemRow["SL_PIC"] != null ? "<SL_PIC>" + itemRow["SL_PIC"].ToString() + "</SL_PIC>" : "<SL_PIC>" + "</SL_PIC>");
soapRequestData.Append(itemRow["WH"] != null ? "<WH>" + itemRow["WH"].ToString() + "</WH>" : "<WH>" + "</WH>");
soapRequestData.Append(itemRow["INVT_CD"] != null ? "<INVT_CD>" + itemRow["INVT_CD"].ToString() + "</INVT_CD>" : "<INVT_CD>" + "</INVT_CD>");
soapRequestData.Append(itemRow["INVT_NM"] != null ? "<INVT_NM>" + itemRow["INVT_NM"].ToString() + "</INVT_NM>" : "<INVT_NM>" + "</INVT_NM>");
soapRequestData.Append(itemRow["STDD_MDL"] != null ? "<STDD_MDL>" + Regex.Replace(itemRow["STDD_MDL"].ToString(), @"[^0-9]+", "") + "</STDD_MDL>" : "<STDD_MDL>" + "</STDD_MDL>");
soapRequestData.Append(itemRow["QTY"] != null ? "<QTY>" + itemRow["QTY"].ToString() + "</QTY>" : "<QTY>" + "</QTY>");
soapRequestData.Append(itemRow["STMT"] != null ? "<STMT>" + itemRow["STMT"].ToString() + "</STMT>" : "<STMT>" + "</STMT>");
soapRequestData.Append(itemRow["PRTX_UPRC"] != null ? "<PRTX_UPRC>" + itemRow["PRTX_UPRC"].ToString() + "</PRTX_UPRC>" : "<PRTX_UPRC>" + "</PRTX_UPRC>");
soapRequestData.Append(itemRow["FRTX_UPRC"] != null ? "<FRTX_UPRC>" + itemRow["FRTX_UPRC"].ToString() + "</FRTX_UPRC>" : "<FRTX_UPRC>" + "</FRTX_UPRC>");
soapRequestData.Append(itemRow["FRTX_AMT"] != null ? "<FRTX_AMT>" + itemRow["FRTX_AMT"].ToString() + "</FRTX_AMT>" : "<FRTX_AMT>" + "</FRTX_AMT>");
soapRequestData.Append(itemRow["TXRTO"] != null ? "<TXRTO>" + itemRow["TXRTO"].ToString() + "</TXRTO>" : "<TXRTO>" + "</TXRTO>");
soapRequestData.Append(itemRow["TX_AMT"] != null ? "<TX_AMT>" + itemRow["TX_AMT"].ToString() + "</TX_AMT>" : "<TX_AMT>" + "</TX_AMT>");
soapRequestData.Append(itemRow["PRTX_AMT"] != null ? "<PRTX_AMT>" + itemRow["PRTX_AMT"].ToString() + "</PRTX_AMT>" : "<PRTX_AMT>" + "</PRTX_AMT>");
soapRequestData.Append(itemRow["DISRTO1"] != null ? "<DISRTO1>" + itemRow["DISRTO1"].ToString() + "</DISRTO1>" : "<DISRTO1>" + "</DISRTO1>");
soapRequestData.Append(itemRow["DISRTO2"] != null ? "<DISRTO2>" + itemRow["DISRTO2"].ToString() + "</DISRTO2>" : "<DISRTO2>" + "</DISRTO2>");
soapRequestData.Append(itemRow["DIS_AMT"] != null ? "<DIS_AMT>" + itemRow["DIS_AMT"].ToString() + "</DIS_AMT>" : "<DIS_AMT>" + "</DIS_AMT>");
soapRequestData.Append(itemRow["CRTR"] != null ? "<CRTR>" + itemRow["CRTR"].ToString() + "</CRTR>" : "<CRTR>" + "</CRTR>");
soapRequestData.Append(itemRow["REVR"] != null ? "<REVR>" + itemRow["REVR"].ToString() + "</REVR>" : "<REVR>" + "</REVR>");
soapRequestData.Append(itemRow["STTL_TYP_CD"] != null ? "<STTL_TYP_CD>" + itemRow["STTL_TYP_CD"].ToString() + "</STTL_TYP_CD>" : "<STTL_TYP_CD>" + "</STTL_TYP_CD>");
soapRequestData.Append(itemRow["DLVR_TYP_CD"] != null ? "<DLVR_TYP_CD>" + itemRow["DLVR_TYP_CD"].ToString() + "</DLVR_TYP_CD>" : "<DLVR_TYP_CD>" + "</DLVR_TYP_CD>");
soapRequestData.Append(itemRow["DLVR_TYP"] != null ? "<DLVR_TYP>" + itemRow["DLVR_TYP"].ToString() + "</DLVR_TYP>" : "<DLVR_TYP>" + "</DLVR_TYP>");
soapRequestData.Append(itemRow["STTL_TYP"] != null ? "<STTL_TYP>" + itemRow["STTL_TYP"].ToString() + "</STTL_TYP>" : "<STTL_TYP>" + "</STTL_TYP>");
soapRequestData.Append(itemRow["OUTST_AMT"] != null ? "<OUTST_AMT>" + itemRow["OUTST_AMT"].ToString() + "</OUTST_AMT>" : "<OUTST_AMT>" + "</OUTST_AMT>");
soapRequestData.Append(itemRow["OUTST_LCUR"] != null ? "<OUTST_LCUR>" + itemRow["OUTST_LCUR"].ToString() + "</OUTST_LCUR>" : "<OUTST_LCUR>" + "</OUTST_LCUR>");
soapRequestData.Append("</SLS_INVC>");
//原循环部分 end
}
soapRequestData.Append("</yerp:YERP_002_OA1_MT>");
soapRequestData.Append("</soapenv:Body>");
soapRequestData.Append("</soapenv:Envelope>");
string postData = soapRequestData.ToString();
log.Info("YERP_002 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_002_OA1_SI&interfaceNamespace=http://skch.com/YERP_002_SALES_INVOICE";
rop.RequestSAP(rop.Url, 10000, postData, "IF_YERP", "Xtxc355860", out statusCode, out resultContent);
log.Info("YERP_002 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;
}
}
}
}

166
ICSSoft.FromERP/SK/YERP_003.cs
View File

@ -0,0 +1,166 @@
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.Text.RegularExpressions;
using System.Threading.Tasks;
namespace ICSSoft.FromERP
{
/// <summary>
/// 主营业务收入明细账
/// </summary>
public class YERP_003 : 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();
//string url = config.ConnectionStrings.ConnectionStrings["APIAddStdWorkHour"].ConnectionString.ToString();
var Dates = DateTime.Now;
string conStr = ICSHelper.GetConnectString();
// 202404
// 过滤时间为上个月
string Date = Dates.ToString("yyyy");
string Muoth = Dates.AddMonths(-1).ToString("MM");
string Day = Dates.ToString("dd");
//<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:yerp="http://skch.com/YERP_003_CORP_COMMISSION">
// <soapenv:Header/>
// <soapenv:Body>
// <yerp:YERP_003_OA1_MT>
// <!--1 or more repetitions:-->
// <CORP_CMISN>
// <SBJ_CD>?</SBJ_CD>
// <SBJ_NM>?</SBJ_NM>
// <YYYY>?</YYYY>
// <MM>?</MM>
// <DD>?</DD>
// <SPTDOC>?</SPTDOC>
// <SMR>?</SMR>
// <ODR_ACC>?</ODR_ACC>
// <!--Optional:-->
// <DBTO_AMT>?</DBTO_AMT>
// <!--Optional:-->
// <CRDTO_AMT>?</CRDTO_AMT>
// <DBTO_CRDTO_DVSN>?</DBTO_CRDTO_DVSN>
// <BLNC>?</BLNC>
// </CORP_CMISN>
// </yerp:YERP_003_OA1_MT>
// </soapenv:Body>
//</soapenv:Envelope>
var beginPeriod = "202301";//Date + Muoth;
var endPeriod = "202302";//Date + Muoth;
string sqls = @"
begin transaction
exec GL_Ledger @tblname=N'zyywsrmxz',@KmCode=N'6001',@beginPeriod={0},@endPeriod={1},@bVouch=0,@bequal=1,@sum=0,@bMJ=1,@swhere=N'',@sAuth=N'',@ReportID=N'GL13',@ReportType=0,@iUnite=0
select autoid,cCode SBJ_CD,ccode_name SBJ_NM,iyear YYYY,imonth MM,iday DD,csign_no SPTDOC,cDigest SMR,cDCode ODR_ACC,md DBTO_AMT,mc CRDTO_AMT,(case when ibook is null then '平' else (case when ibook ='1' then '贷' else '借' end) end) DBTO_CRDTO_DVSN,tmpme,
(Select Sum(-tmpme) from tempdb..zyywsrmxz where autoid<=a.autoid) BLNC from tempdb..zyywsrmxz a
rollback transaction";
sqls = string.Format(sqls, beginPeriod, endPeriod);
log.Info("YERP_003 sql:" + sqls);
DataTable vbsdt = ICSHelper.ExecuteTable(conStr, sqls);
log.Info("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_003_CORP_COMMISSION\">");
soapRequestData.Append("<soapenv:Header/>");
soapRequestData.Append("<soapenv:Body>");
soapRequestData.Append("<yerp:YERP_003_OA1_MT>");
//循环数据
foreach (DataRow itemRow in vbsdt.Rows)
{
//原循环部分 begin
soapRequestData.Append("<CORP_CMISN>");
soapRequestData.Append(itemRow["SBJ_CD"] != null ? "<SBJ_CD>" + itemRow["SBJ_CD"].ToString() + "</SBJ_CD>" : "<SBJ_CD>" + "</SBJ_CD>");
soapRequestData.Append(itemRow["SBJ_NM"] != null ? "<SBJ_NM>" + itemRow["SBJ_NM"].ToString() + "</SBJ_NM>" : "<SBJ_NM>" + "</SBJ_NM>");
soapRequestData.Append(itemRow["YYYY"] != null ? "<YYYY>" + itemRow["YYYY"].ToString() + "</YYYY>" : "<YYYY>" + "</YYYY>");
soapRequestData.Append(itemRow["MM"] != null ? "<MM>" + itemRow["MM"].ToString() + "</MM>" : "<MM>" + "</MM>");
soapRequestData.Append(itemRow["DD"] != null ? "<DD>" + itemRow["DD"].ToString() + "</DD>" : "<DD>" + "</DD>");
soapRequestData.Append(itemRow["SPTDOC"] != null ? "<SPTDOC>" + itemRow["SPTDOC"].ToString() + "</SPTDOC>" : "<SPTDOC>" + "</SPTDOC>");
soapRequestData.Append(itemRow["SMR"] != null ? "<SMR>" + itemRow["SMR"].ToString() + "</SMR>" : "<SMR>" + "</SMR>");
soapRequestData.Append(itemRow["ODR_ACC"] != null ? "<ODR_ACC>" + itemRow["ODR_ACC"].ToString() + "</ODR_ACC>" : "<ODR_ACC>" + "</ODR_ACC>");
soapRequestData.Append(itemRow["DBTO_AMT"] != null ? "<DBTO_AMT>" + itemRow["DBTO_AMT"].ToString() + "</DBTO_AMT>" : "<DBTO_AMT>" + "</DBTO_AMT>");
soapRequestData.Append(itemRow["CRDTO_AMT"] != null ? "<CRDTO_AMT>" + itemRow["CRDTO_AMT"].ToString() + "</CRDTO_AMT>" : "<CRDTO_AMT>" + "</CRDTO_AMT>");
soapRequestData.Append(itemRow["DBTO_CRDTO_DVSN"] != null ? "<DBTO_CRDTO_DVSN>" + itemRow["DBTO_CRDTO_DVSN"].ToString() + "</DBTO_CRDTO_DVSN>" : "<DBTO_CRDTO_DVSN>" + "</DBTO_CRDTO_DVSN>");
soapRequestData.Append(itemRow["BLNC"] != null ? "<BLNC>" + itemRow["BLNC"].ToString() + "</BLNC>" : "<BLNC>" + "</BLNC>");
soapRequestData.Append("</CORP_CMISN>");
//原循环部分 end
}
soapRequestData.Append("</yerp:YERP_003_OA1_MT>");
soapRequestData.Append("</soapenv:Body>");
soapRequestData.Append("</soapenv:Envelope>");
string postData = soapRequestData.ToString();
log.Info("YERP_003 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_003_OA1_SI&interfaceNamespace=http://skch.com/YERP_003_CORP_COMMISSION";
rop.RequestSAP(rop.Url, 10000, postData, "IF_YERP", "Xtxc355860", out statusCode, out resultContent);
log.Info("YERP_003 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;
}
}
}
}

261
ICSSoft.FromERP/SK/YERP_004.cs
View File

@ -0,0 +1,261 @@
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>
/// 销售费用明细账
/// </summary>
public class YERP_004 : 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();
//string url = config.ConnectionStrings.ConnectionStrings["APIAddStdWorkHour"].ConnectionString.ToString();
var Dates = DateTime.Now;
string conStr = ICSHelper.GetConnectString();
// 202404
// 过滤时间为上个月
string Date = Dates.ToString("yyyy");
string Muoth = Dates.AddMonths(-1).ToString("MM");
string Day = Dates.ToString("dd");
//<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:yerp="http://skch.com/YERP_004_SALES_COST_STMT">
// <soapenv:Header/>
// <soapenv:Body>
// <yerp:YERP_004_OA1_MT>
// <!--1 or more repetitions:-->
// <SL_CST_SPTDOC>
// <YYYY>?</YYYY>
// <MM>?</MM>
// <DD>?</DD>
// <SPTDOC>?</SPTDOC>
// <SMR>?</SMR>
// <!--Optional:-->
// <DBTO>?</DBTO>
// <!--Optional:-->
// <CRDTO>?</CRDTO>
// <INVT>?</INVT>
// <BLNC>?</BLNC>
// <!--Optional:-->
// <WH_CST>?</WH_CST>
// <!--Optional:-->
// <TRNSF_CST>?</TRNSF_CST>
// <!--Optional:-->
// <XBT_CST>?</XBT_CST>
// <!--Optional:-->
// <NLD_CST>?</NLD_CST>
// <!--Optional:-->
// <SMPL_CST>?</SMPL_CST>
// <!--Optional:-->
// <TRNSF_AGNC_CST>?</TRNSF_AGNC_CST>
// <!--Optional:-->
// <ADTV>?</ADTV>
// <!--Optional:-->
// <NCLSN_CST>?</NCLSN_CST>
// <!--Optional:-->
// <SVC_CST>?</SVC_CST>
// </SL_CST_SPTDOC>
// </yerp:YERP_004_OA1_MT>
// </soapenv:Body>
// </soapenv:Envelope>
var beginPeriod = "202301";//Date + Muoth;
var endPeriod = "202303";//Date + Muoth;
string sqls = @"
begin transaction
exec GL_Ledger @tblname=N'zyywsrmxz',@KmCode=N'6601',@beginPeriod='{0}',@endPeriod='{1}',@bVouch=0,@bequal=1,@sum=0,@bMJ=1,@swhere=N'',@sAuth=N'',@ReportID=N'GL13',@ReportType=0,@iUnite=0
select autoid,iyear YYYY,imonth MM,iday DD,csign_no SPTDOC,cDigest SMR,cDCode ODR_ACC,md DBTO_AMT,mc CRDTO_AMT,tmpme tmpme
into #test from tempdb..zyywsrmxz a
select YYYY,SPTDOC,MM,DD,sum(DBTO_AMT) DBTO_AMT,sum(CRDTO_AMT) CRDTO_AMT,sum(isnull(tmpme,0)) tmpme
into #test2
from #test a
where SPTDOC is not null and DD IS NOT NULL
group by SPTDOC,YYYY,MM,DD
order by SPTDOC
update a set DBTO_AMT=b.DBTO_AMT,a.CRDTO_AMT=b.CRDTO_AMT,a.tmpme=b.tmpme from #test a
left join #test2 b on a.SPTDOC=b.SPTDOC and a.MM=b.MM and a.DD=b.DD
where a.sptdoc is not null
select autoid,sptdoc,YYYY,MM,DD into #test3 from #test where sptdoc is not null
select s.* into #test4 from (select *,ROW_NUMBER() over (partition by sptdoc+CAST(MM AS VARCHAR(255))+CAST(DD AS VARCHAR(255)) order by autoid) as group_idx from #test3)s where s.group_idx>1
delete a from #test a
left join #test4 b on a.autoid=b.autoid
where b.autoid is not null
select *,(case when (Select Sum(-tmpme) from #test where autoid<=a.autoid) =0 then '平' else (case when (Select Sum(-tmpme) from #test where autoid<=a.autoid) >0 then '贷' else '借' end) end) INVT,
(case when (Select Sum(-tmpme) from #test where autoid<=a.autoid)<0 then -(Select Sum(-tmpme) from #test where autoid<=a.autoid) else (Select Sum(-tmpme) from #test where autoid<=a.autoid) end) BLNC into #test5 from #test a
select cCode SBJ_CD,ccode_name SBJ_NM,imonth,iday,csign_no SPTDOC,sum(md) DBTO_AMT
into #test6
from tempdb..zyywsrmxz a
where csign_no is not null
group by ccode_name,csign_no,cCode,imonth,iday
order by csign_no,imonth,iday
select DISTINCT sptdoc,imonth,iday into #test7 from #test6
select *,ROW_NUMBER() over (order by sptdoc,imonth,iday) rownumber into #test8 from #test7
declare @k int
set @k=1
while @k<=(select COUNT(*) from #test7)
begin
declare @i int
set @i=0
while @i<1
begin
insert into #test6 (SBJ_CD,SBJ_NM,imonth,iday,SPTDOC,DBTO_AMT)
select a.ccode,a.ccode_name,(select imonth from #test8 where rownumber=@k),(select iday from #test8 where rownumber=@k),(select SPTDOC from #test8 where rownumber=@k),0
from code a left join #test6 b on b.SPTDOC=(select SPTDOC from #test8 where rownumber=@k) and imonth=(select imonth from #test8 where rownumber=@k) and iday=(select iday from #test8 where rownumber=@k) and SBJ_NM=ccode_name
where a.iYear=2024 and ( bclose=0 and ( ccode like N'6601%' or ccode_name like N'6601%' or ccode_engl like N'6601%' or chelp like N'6601%' )) and ccode <>'6601' and b.SPTDOC is null
set @i=@i +1
end
set @k=@k +1
end
SELECT
SPTDOC,imonth,iday,
SUM(CASE WHEN SBJ_CD = '660101' THEN DBTO_AMT ELSE 0 END) WH_CST,
SUM(CASE WHEN SBJ_CD = '660102' THEN DBTO_AMT ELSE 0 END) TRNSF_CST,
SUM(CASE WHEN SBJ_CD = '660103' THEN DBTO_AMT ELSE 0 END) XBT_CST,
SUM(CASE WHEN SBJ_CD = '660104' THEN DBTO_AMT ELSE 0 END) NLD_CST,
SUM(CASE WHEN SBJ_CD = '660105' THEN DBTO_AMT ELSE 0 END) SMPL_CST,
SUM(CASE WHEN SBJ_CD = '660106' THEN DBTO_AMT ELSE 0 END) TRNSF_AGNC_CST,
SUM(CASE WHEN SBJ_CD = '660107' THEN DBTO_AMT ELSE 0 END) ADTV,
SUM(CASE WHEN SBJ_CD = '660108' THEN DBTO_AMT ELSE 0 END) NCLSN_CST,
SUM(CASE WHEN SBJ_CD = '660109' THEN DBTO_AMT ELSE 0 END) SVC_CST
into #test9
FROM
#test6
GROUP BY
SPTDOC,imonth,iday
select YYYY,MM,DD,A.SPTDOC,SMR,DBTO_AMT DBTO,CRDTO_AMT CRDTO,INVT,BLNC,WH_CST,TRNSF_CST,XBT_CST,NLD_CST,SMPL_CST,TRNSF_AGNC_CST,ADTV,NCLSN_CST,SVC_CST from #test5 a left join #test9 b on a.SPTDOC=b.SPTDOC and a.MM=b.imonth and a.DD=b.iday
rollback transaction
";
sqls = string.Format(sqls, beginPeriod, endPeriod);
log.Info("YERP_004 sql:" + sqls);
DataTable vbsdt = ICSHelper.ExecuteTable(conStr, sqls);
log.Info("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_004_SALES_COST_STMT\">");
soapRequestData.Append("<soapenv:Header/>");
soapRequestData.Append("<soapenv:Body>");
soapRequestData.Append("<yerp:YERP_004_OA1_MT>");
//循环数据
foreach (DataRow itemRow in vbsdt.Rows)
{
//原循环部分 begin
soapRequestData.Append("<SL_CST_SPTDOC>");
soapRequestData.Append(itemRow["YYYY"] != null ? "<YYYY>" + itemRow["YYYY"].ToString() + "</YYYY>" : "<YYYY>" + "</YYYY>");
soapRequestData.Append(itemRow["MM"] != null ? "<MM>" + itemRow["MM"].ToString() + "</MM>" : "<MM>" + "</MM>");
soapRequestData.Append(itemRow["DD"] != null ? "<DD>" + itemRow["DD"].ToString() + "</DD>" : "<DD>" + "</DD>");
soapRequestData.Append(itemRow["SPTDOC"] != null ? "<SPTDOC>" + itemRow["SPTDOC"].ToString() + "</SPTDOC>" : "<SPTDOC>" + "</SPTDOC>");
soapRequestData.Append(itemRow["SMR"] != null ? "<SMR>" + itemRow["SMR"].ToString() + "</SMR>" : "<SMR>" + "</SMR>");
soapRequestData.Append(itemRow["DBTO"] != null ? "<DBTO>" + itemRow["DBTO"].ToString() + "</DBTO>" : "<DBTO>" + "</DBTO>");
soapRequestData.Append(itemRow["CRDTO"] != null ? "<CRDTO>" + itemRow["CRDTO"].ToString() + "</CRDTO>" : "<CRDTO>" + "</CRDTO>");
soapRequestData.Append(itemRow["INVT"] != null ? "<INVT>" + itemRow["INVT"].ToString() + "</INVT>" : "<INVT>" + "</INVT>");
soapRequestData.Append(itemRow["BLNC"] != null ? "<BLNC>" + itemRow["BLNC"].ToString() + "</BLNC>" : "<BLNC>" + "</BLNC>");
soapRequestData.Append(itemRow["WH_CST"] != null ? "<WH_CST>" + itemRow["WH_CST"].ToString() + "</WH_CST>" : "<WH_CST>" + "</WH_CST>");
soapRequestData.Append(itemRow["TRNSF_CST"] != null ? "<TRNSF_CST>" + itemRow["TRNSF_CST"].ToString() + "</TRNSF_CST>" : "<TRNSF_CST>" + "</TRNSF_CST>");
soapRequestData.Append(itemRow["XBT_CST"] != null ? "<XBT_CST>" + itemRow["XBT_CST"].ToString() + "</XBT_CST>" : "<XBT_CST>" + "</XBT_CST>");
soapRequestData.Append(itemRow["NLD_CST"] != null ? "<NLD_CST>" + itemRow["NLD_CST"].ToString() + "</NLD_CST>" : "<NLD_CST>" + "</NLD_CST>");
soapRequestData.Append(itemRow["SMPL_CST"] != null ? "<SMPL_CST>" + itemRow["SMPL_CST"].ToString() + "</SMPL_CST>" : "<SMPL_CST>" + "</SMPL_CST>");
soapRequestData.Append(itemRow["TRNSF_AGNC_CST"] != null ? "<TRNSF_AGNC_CST>" + itemRow["TRNSF_AGNC_CST"].ToString() + "</TRNSF_AGNC_CST>" : "<TRNSF_AGNC_CST>" + "</TRNSF_AGNC_CST>");
soapRequestData.Append(itemRow["ADTV"] != null ? "<ADTV>" + itemRow["ADTV"].ToString() + "</ADTV>" : "<ADTV>" + "</ADTV>");
soapRequestData.Append(itemRow["NCLSN_CST"] != null ? "<NCLSN_CST>" + itemRow["NCLSN_CST"].ToString() + "</NCLSN_CST>" : "<NCLSN_CST>" + "</NCLSN_CST>");
soapRequestData.Append(itemRow["SVC_CST"] != null ? "<SVC_CST>" + itemRow["SVC_CST"].ToString() + "</SVC_CST>" : "<SVC_CST>" + "</SVC_CST>");
soapRequestData.Append("</SL_CST_SPTDOC>");
//原循环部分 end
}
soapRequestData.Append("</yerp:YERP_004_OA1_MT>");
soapRequestData.Append("</soapenv:Body>");
soapRequestData.Append("</soapenv:Envelope>");
string postData = soapRequestData.ToString();
log.Info("YERP_004 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_004_OA1_SI&interfaceNamespace=http://skch.com/YERP_004_SALES_COST_STMT";
rop.RequestSAP(rop.Url, 10000, postData, "IF_YERP", "Xtxc355860", out statusCode, out resultContent);
log.Info("YERP_004 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;
}
}
}
}

2
ICSSoft.FromERP/SK/YERP_007.cs
View File

@ -158,7 +158,7 @@ namespace ICSSoft.FromERP
SPTDOC,imonth,iday
select YYYY,MM,DD,A.SPTDOC,SMR,DBTO_AMT DBTO,CRDTO_AMT CRDTO,INVT,BLNC,DBTO_CMSN,DBTO_IENS,DBTO_XCH_PC
select YYYY,MM,DD,A.SPTDOC,SMR,DBTO_AMT DBTO,CRDTO_AMT CRDTO,INVT,BLNC,DBTO_CMSN,DBTO_IENS,DBTO_XCH_PC,'' DBTO_CRDTO_DVSN
from #test5 a left join #test9 b on a.SPTDOC=b.SPTDOC and a.MM=b.imonth and a.DD=b.iday order by MM

Write Preview
Loading…
Cancel
Save