diff --git a/ICSSoft.FromERP/SK/YERP_003.cs b/ICSSoft.FromERP/SK/YERP_003.cs index 2f69ca5..963a1f5 100644 --- a/ICSSoft.FromERP/SK/YERP_003.cs +++ b/ICSSoft.FromERP/SK/YERP_003.cs @@ -79,7 +79,7 @@ namespace ICSSoft.FromERP 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 +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 diff --git a/ICSSoft.FromERP/SK/YERP_006_gz.cs b/ICSSoft.FromERP/SK/YERP_006_gz.cs new file mode 100644 index 0000000..3f7b61b --- /dev/null +++ b/ICSSoft.FromERP/SK/YERP_006_gz.cs @@ -0,0 +1,357 @@ +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 +{ + /// + /// 管理费用明细账 + /// + public class YERP_006_gz : 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.GetConfigString("SysConnectionString_gz"); + if (string.IsNullOrEmpty(conStr)) + { + log.Info("YERP_006 conStr未找到。"); + return; + } + // + // + // + // + // + // + // ? + // ? + //
?
+ // ? + // ? + // ? + // ? + // ? + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + // + // ? + //
+ //
+ //
+ //
+ // 202404 + // 过滤时间为上个月 + string Date = Dates.ToString("yyyy"); + string beginMuoth = Dates.AddMonths(-1).ToString("MM"); + string endMuoth = Dates.ToString("MM"); + var beginPeriod = "200001";//Date + beginMuoth + var endPeriod = "206001";//Date + endMuoth + string sqls = @"begin transaction + +exec GL_Ledger @tblname=N'glfymxz',@KmCode=N'5602',@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..glfymxz a + +select 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,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..glfymxz 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'6602%' or ccode_name like N'6602%' or ccode_engl like N'6602%' or chelp like N'6602%' )) and ccode <>'6602' and len(ccode)=6 +and b.SPTDOC is null + set @i=@i +1 +end + + + set @k=@k +1 +end + + +SELECT + SPTDOC,imonth,iday, +SUM(CASE WHEN SBJ_CD = '660201' THEN DBTO_AMT ELSE 0 END) OFC_OPRT_CST, +SUM(CASE WHEN SBJ_CD = '660202' THEN DBTO_AMT ELSE 0 END) BZTRP_CST, +SUM(CASE WHEN SBJ_CD = '660203' THEN DBTO_AMT ELSE 0 END) TRSF_CST, +SUM(CASE WHEN SBJ_CD = '660204' THEN DBTO_AMT ELSE 0 END) BNFT_CST, +SUM(CASE WHEN SBJ_CD = '660205' THEN DBTO_AMT ELSE 0 END) NTTN_CST, +SUM(CASE WHEN SBJ_CD = '660206' THEN DBTO_AMT ELSE 0 END) SCLISRC, +SUM(CASE WHEN SBJ_CD = '660207' THEN DBTO_AMT ELSE 0 END) DDTN, +SUM(CASE WHEN SBJ_CD = '660208' THEN DBTO_AMT ELSE 0 END) NTRR_CST, +SUM(CASE WHEN SBJ_CD = '660209' THEN DBTO_AMT ELSE 0 END) VEHS_OPRT_CST, +SUM(CASE WHEN SBJ_CD = '660210' THEN DBTO_AMT ELSE 0 END) SVC_CST, +SUM(CASE WHEN SBJ_CD = '660211' THEN DBTO_AMT ELSE 0 END) VEHS_RNTL_CST, +SUM(CASE WHEN SBJ_CD = '660212' THEN DBTO_AMT ELSE 0 END) OFC_RNTL_CST, +SUM(CASE WHEN SBJ_CD = '660213' THEN DBTO_AMT ELSE 0 END) PRPT_MGMT_CST, +SUM(CASE WHEN SBJ_CD = '660214' THEN DBTO_AMT ELSE 0 END) WTNELCT_CST, +SUM(CASE WHEN SBJ_CD = '660215' THEN DBTO_AMT ELSE 0 END) NWK_CST, +SUM(CASE WHEN SBJ_CD = '660216' THEN DBTO_AMT ELSE 0 END) TELE_CST, +SUM(CASE WHEN SBJ_CD = '660217' THEN DBTO_AMT ELSE 0 END) MEET_CST, +SUM(CASE WHEN SBJ_CD = '660218' THEN DBTO_AMT ELSE 0 END) PCL_CST, +SUM(CASE WHEN SBJ_CD = '660219' THEN DBTO_AMT ELSE 0 END) PNCST, +SUM(CASE WHEN SBJ_CD = '660220' THEN DBTO_AMT ELSE 0 END) CUN_CST, +SUM(CASE WHEN SBJ_CD = '660221' THEN DBTO_AMT ELSE 0 END) DPRCT_CST, +SUM(CASE WHEN SBJ_CD = '660222' THEN DBTO_AMT ELSE 0 END) EDU_CST, +SUM(CASE WHEN SBJ_CD = '660223' THEN DBTO_AMT ELSE 0 END) RPR_CST, +SUM(CASE WHEN SBJ_CD = '660224' THEN DBTO_AMT ELSE 0 END) LBPRTT_CST, +SUM(CASE WHEN SBJ_CD = '660225' THEN DBTO_AMT ELSE 0 END) BZ_PRMT_CST, +SUM(CASE WHEN SBJ_CD = '660226' THEN DBTO_AMT ELSE 0 END) TEST_CST, +SUM(CASE WHEN SBJ_CD = '660227' THEN DBTO_AMT ELSE 0 END) BK_CST, +SUM(CASE WHEN SBJ_CD = '660228' THEN DBTO_AMT ELSE 0 END) RCRT_CST, +SUM(CASE WHEN SBJ_CD = '660229' THEN DBTO_AMT ELSE 0 END) XBT_CST, +SUM(CASE WHEN SBJ_CD = '660230' THEN DBTO_AMT ELSE 0 END) RSNB_LOS + + into #test9 +FROM + #test6 +GROUP BY + SPTDOC,imonth,iday + + + select YYYY,MM,DD,A.SPTDOC as SPTDOC_NO,SMR,DBTO_AMT DBTO,CRDTO_AMT CRDTO,INVT as DBTO_CRDTO_DVSN,BLNC,OFC_OPRT_CST,BZTRP_CST,TRSF_CST,BNFT_CST,NTTN_CST,SCLISRC,DDTN,NTRR_CST,VEHS_OPRT_CST,SVC_CST,VEHS_RNTL_CST, +OFC_RNTL_CST,PRPT_MGMT_CST,WTNELCT_CST,NWK_CST,TELE_CST,MEET_CST,PCL_CST,PNCST,CUN_CST,DPRCT_CST,EDU_CST,RPR_CST,LBPRTT_CST,BZ_PRMT_CST,TEST_CST,BK_CST,RCRT_CST,XBT_CST,RSNB_LOS + + 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 + +rollback transaction +"; + sqls = string.Format(sqls, beginPeriod, endPeriod); + log.Info("YERP_006 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(""); + soapRequestData.Append(""); + soapRequestData.Append(""); + soapRequestData.Append(""); + //循环数据 + foreach (DataRow itemRow in vbsdt.Rows) + { + //原循环部分 begin + soapRequestData.Append(""); + soapRequestData.Append(itemRow["YYYY"] != null ? "" + itemRow["YYYY"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["MM"] != null ? "" + itemRow["MM"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DD"] != null ? "
" + itemRow["DD"].ToString() + "
" : "
" + "
"); + soapRequestData.Append(itemRow["SPTDOC_NO"] != null ? "" + itemRow["SPTDOC_NO"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["SMR"] != null ? "" + itemRow["SMR"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DBTO"] != null ? "" + itemRow["DBTO"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["CRDTO"] != null ? "" + itemRow["CRDTO"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DBTO_CRDTO_DVSN"] != null ? "" + itemRow["DBTO_CRDTO_DVSN"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["BLNC"] != null ? "" + itemRow["BLNC"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["OFC_OPRT_CST"] != null ? "" + itemRow["OFC_OPRT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["BZTRP_CST"] != null ? "" + itemRow["BZTRP_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["TRSF_CST"] != null ? "" + itemRow["TRSF_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["BNFT_CST"] != null ? "" + itemRow["BNFT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["NTTN_CST"] != null ? "" + itemRow["NTTN_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["SCLISRC"] != null ? "" + itemRow["SCLISRC"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DDTN"] != null ? "" + itemRow["DDTN"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["NTRR_CST"] != null ? "" + itemRow["NTRR_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["VEHS_OPRT_CST"] != null ? "" + itemRow["VEHS_OPRT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["SVC_CST"] != null ? "" + itemRow["SVC_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["VEHS_RNTL_CST"] != null ? "" + itemRow["VEHS_RNTL_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["OFC_RNTL_CST"] != null ? "" + itemRow["OFC_RNTL_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["PRPT_MGMT_CST"] != null ? "" + itemRow["PRPT_MGMT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["WTNELCT_CST"] != null ? "" + itemRow["WTNELCT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["NWK_CST"] != null ? "" + itemRow["NWK_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["TELE_CST"] != null ? "" + itemRow["TELE_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["MEET_CST"] != null ? "" + itemRow["MEET_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["PCL_CST"] != null ? "" + itemRow["PCL_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["PNCST"] != null ? "" + itemRow["PNCST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["CUN_CST"] != null ? "" + itemRow["CUN_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DPRCT_CST"] != null ? "" + itemRow["DPRCT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["EDU_CST"] != null ? "" + itemRow["EDU_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["RPR_CST"] != null ? "" + itemRow["RPR_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["LBPRTT_CST"] != null ? "" + itemRow["LBPRTT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["BZ_PRMT_CST"] != null ? "" + itemRow["BZ_PRMT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["TEST_CST"] != null ? "" + itemRow["TEST_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["BK_CST"] != null ? "" + itemRow["BK_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["RCRT_CST"] != null ? "" + itemRow["RCRT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["XBT_CST"] != null ? "" + itemRow["XBT_CST"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["RSNB_LOS"] != null ? "" + itemRow["RSNB_LOS"].ToString() + "" : "" + ""); + soapRequestData.Append("
"); + //原循环部分 end + } + soapRequestData.Append("
"); + soapRequestData.Append("
"); + soapRequestData.Append("
"); + string postData = soapRequestData.ToString(); + log.Info("YERP_006 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_006_OA1_SI&interfaceNamespace=http://skch.com/YERP_006_MATN_COST"; + rop.RequestSAP(rop.Url, 10000, postData, "IF_YERP", "Xtxc355860", out statusCode, out resultContent); + + log.Info("YERP_006 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; + } + } + } +} diff --git a/ICSSoft.FromERP/SK/YERP_007_gz.cs b/ICSSoft.FromERP/SK/YERP_007_gz.cs new file mode 100644 index 0000000..34f66f0 --- /dev/null +++ b/ICSSoft.FromERP/SK/YERP_007_gz.cs @@ -0,0 +1,252 @@ +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 +{ + /// + /// 财务费用 明细账 + /// + public class YERP_007_gz : 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.GetConfigString("SysConnectionString_gz"); + if (string.IsNullOrEmpty(conStr)) + { + log.Info("YERP_006 conStr未找到。"); + return; + } + // + // + // + // + // + // + // ? + // 1 + //
?
+ // ? + // ? + // ? + // ? + // ? + // ? + // + // ? + // + // ? + // + // ? + //
+ //
+ //
+ //
+ + // 过滤时间为上个月 + string Date = Dates.ToString("yyyy"); + string beginMuoth = Dates.AddMonths(-1).ToString("MM"); + string endMuoth = Dates.ToString("MM"); + var beginPeriod = "200001";//Date + beginMuoth + var endPeriod = "206001";//Date + endMuoth + string sqls = @" + begin transaction + + exec GL_Ledger @tblname=N'cwfymxz',@KmCode=N'5603',@beginPeriod='{0}',@endPeriod='{1}',@bVouch=0,@bequal=1,@sum=0,@bMJ=1,@swhere=N'',@sAuth=N'',@ReportID=N'GL13',@ReportType=0,@iUnite=0 + + --select * from tempdb..cwfymxz + + select autoid,a.iyear YYYY,imonth MM,iday DD,csign_no SPTDOC,cDigest SMR,cDCode ODR_ACC,a.md DBTO_AMT,a.mc CRDTO_AMT,tmpme tmpme,b.cbegind_c + into #test + from tempdb..cwfymxz a + join GL_accsum b on a.cCode = b.ccode and a.iyear = b.iyear and b.iperiod=1 + + select SPTDOC,YYYY,MM,DD,sum(DBTO_AMT) DBTO_AMT,sum(CRDTO_AMT) CRDTO_AMT,sum(isnull(tmpme,0)) tmpme,cbegind_c + into #test2 + from #test a + where SPTDOC is not null and DD IS NOT NULL + group by SPTDOC,YYYY,MM,DD,cbegind_c + 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..cwfymxz 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'6603%' or ccode_name like N'6603%' or ccode_engl like N'6603%' or chelp like N'6603%' )) and ccode <>'6603' and len(ccode)=6 + and b.SPTDOC is null + set @i=@i +1 + end + + + set @k=@k +1 + end + + + SELECT + SPTDOC,imonth,iday, + SUM(CASE WHEN SBJ_CD = '660301' THEN DBTO_AMT ELSE 0 END) DBTO_CMSN, + SUM(CASE WHEN SBJ_CD = '660302' THEN DBTO_AMT ELSE 0 END) DBTO_IENS, + SUM(CASE WHEN SBJ_CD = '660303' THEN DBTO_AMT ELSE 0 END) DBTO_XCH_PC + + into #test9 + FROM + #test6 + GROUP BY + 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,'' DBTO_CRDTO_DVSN,cbegind_c + + 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 + + rollback transaction";//and dInvCreateDatetime > '{0}' and dInvCreateDatetime < '{1}' + + sqls = string.Format(sqls, beginPeriod, endPeriod); + log.Info("YERP_007 sql:" + sqls); + DataTable vbsdt = ICSHelper.ExecuteTable(conStr, sqls); + log.Info("YERP_007 sql结果数量" + vbsdt.Rows.Count); + if (vbsdt.Rows.Count > 0) + { + StringBuilder soapRequestData = new StringBuilder(); + soapRequestData.Append(""); + soapRequestData.Append(""); + soapRequestData.Append(""); + soapRequestData.Append(""); + //循环数据 DBTO_CRDTO_DVSN + foreach (DataRow itemRow in vbsdt.Rows) + { + soapRequestData.Append(""); + soapRequestData.Append(""); + soapRequestData.Append(itemRow["YYYY"] != null ? "" + itemRow["YYYY"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["MM"] != null ? "" + itemRow["MM"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DD"] != null ? "
" + itemRow["DD"].ToString() + "
" : "
" + "
"); + soapRequestData.Append(itemRow["SPTDOC"] != null ? "" + itemRow["SPTDOC"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["SMR"] != null ? "" + itemRow["SMR"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DBTO"] != null ? "" + itemRow["DBTO"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["CRDTO"] != null ? "" + itemRow["CRDTO"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DBTO_CRDTO_DVSN"] != null ? "" + itemRow["DBTO_CRDTO_DVSN"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["BLNC"] != null ? "" + itemRow["BLNC"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DBTO_CMSN"] != null ? "" + itemRow["DBTO_CMSN"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DBTO_IENS"] != null ? "" + itemRow["DBTO_IENS"].ToString() + "" : "" + ""); + soapRequestData.Append(itemRow["DBTO_XCH_PC"] != null ? "" + itemRow["DBTO_XCH_PC"].ToString() + "" : "" + ""); + soapRequestData.Append("
"); + } + + soapRequestData.Append("
"); + soapRequestData.Append("
"); + soapRequestData.Append("
"); + string postData = soapRequestData.ToString(); + log.Info("YERP_007 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_007_OA1_SI&interfaceNamespace=http://skch.com/YERP_007_TAX_FOR_FIN_EXPENSE"; + rop.RequestSAP(rop.Url, 10000, postData, "IF_YERP", "Xtxc355860", out statusCode, out resultContent); + + log.Info("YERP_007 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; + } + } + } +}