From bff310a02690b02af26f54769ae94a82647670bc Mon Sep 17 00:00:00 2001 From: wxd <123@qq.com> Date: Mon, 20 Apr 2026 09:32:41 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E6=8A=A5=E5=91=8Asql?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../WebAppoints/WebAppointWebPeisPlugIns.cs | 5 +++++ .../TransToWebPeiss/SyncPatientRegisterReportInputDto.cs | 5 +++++ .../Schedulers/SyncPatientRegisterReportInterfaceWorker.cs | 4 ++++ 3 files changed, 14 insertions(+) diff --git a/src/Shentun.ColumnReferencePlugIns/WebAppoints/WebAppointWebPeisPlugIns.cs b/src/Shentun.ColumnReferencePlugIns/WebAppoints/WebAppointWebPeisPlugIns.cs index 370c1827..655c8b1c 100644 --- a/src/Shentun.ColumnReferencePlugIns/WebAppoints/WebAppointWebPeisPlugIns.cs +++ b/src/Shentun.ColumnReferencePlugIns/WebAppoints/WebAppointWebPeisPlugIns.cs @@ -153,6 +153,11 @@ namespace Shentun.Peis.PlugIns.WebAppoints sql += " and is_upload='N' "; } + if (!string.IsNullOrWhiteSpace(input.SqlString)) + { + //不要重复上传,筛选是否上传状态 + sql += $" {input.SqlString} "; + } var parameters = new DynamicParameters(); parameters.Add("HandDate", DateTime.Now.Date.AddDays(-input.QueryDays)); diff --git a/src/Shentun.Peis.Application.Contracts/TransToWebPeiss/SyncPatientRegisterReportInputDto.cs b/src/Shentun.Peis.Application.Contracts/TransToWebPeiss/SyncPatientRegisterReportInputDto.cs index d0ae0eb4..a5e4f9b6 100644 --- a/src/Shentun.Peis.Application.Contracts/TransToWebPeiss/SyncPatientRegisterReportInputDto.cs +++ b/src/Shentun.Peis.Application.Contracts/TransToWebPeiss/SyncPatientRegisterReportInputDto.cs @@ -27,5 +27,10 @@ namespace Shentun.Peis.TransToWebPeiss public int UploadCountLimit { get; set; } = 100; public List ExcludeMedicalTypeIds { get; set; } = new List(); + + /// + /// sql条件 + /// + public string SqlString { get; set; } } } diff --git a/src/Shentun.Peis.HttpApi.Host/Schedulers/SyncPatientRegisterReportInterfaceWorker.cs b/src/Shentun.Peis.HttpApi.Host/Schedulers/SyncPatientRegisterReportInterfaceWorker.cs index b0fcccca..28add538 100644 --- a/src/Shentun.Peis.HttpApi.Host/Schedulers/SyncPatientRegisterReportInterfaceWorker.cs +++ b/src/Shentun.Peis.HttpApi.Host/Schedulers/SyncPatientRegisterReportInterfaceWorker.cs @@ -147,6 +147,9 @@ namespace Shentun.Peis.Schedulers //单次最大的上传数量 var uploadCountLimit = Convert.ToInt32(interfaceConfig.GetValue("Interface:Scheduler:UploadCountLimit", "100")); + //sql条件 + var sqlString = interfaceConfig.GetValue("Interface:Scheduler:SqlString", ""); + @@ -157,6 +160,7 @@ namespace Shentun.Peis.Schedulers IsRepeatUpload = Convert.ToChar(isRepeatUpload), UploadDateType = Convert.ToChar(uploadDateType), UploadCountLimit = uploadCountLimit, + SqlString = sqlString };