From ee47b5036387f221579a894348669fd93ae6844b Mon Sep 17 00:00:00 2001 From: Developer01 Date: Tue, 7 Jul 2026 17:09:02 +0200 Subject: [PATCH] =?UTF-8?q?Push=20mit=20letzen=20=C3=84nderungen=20von=20M?= =?UTF-8?q?S=20an=20Jobrunner?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Service.JobRunner/JobRunner.vb | 1 + Service.JobRunner/JobRunner.vbproj | 1 + Service.JobRunner/Jobs/APISQLJob.vb | 23 +++++++++++++++++++++++ 3 files changed, 25 insertions(+) create mode 100644 Service.JobRunner/Jobs/APISQLJob.vb diff --git a/Service.JobRunner/JobRunner.vb b/Service.JobRunner/JobRunner.vb index e7c29921..86b07f36 100644 --- a/Service.JobRunner/JobRunner.vb +++ b/Service.JobRunner/JobRunner.vb @@ -44,6 +44,7 @@ Public Class JobRunner Await ScheduleJob(Of ADJob)("ADSync", GetJobConfig(JobConfig.JobType.ADSync)) Await ScheduleJob(Of TestJob)("TestJob", GetJobConfig(JobConfig.JobType.Test)) Await ScheduleJob(Of GraphQLJob)("GraphQLJob", GetJobConfig(JobConfig.JobType.GraphQL)) + Await ScheduleJob(Of TestJob)("API_SQL", GetJobConfig(JobConfig.JobType.API_SQL)) ' [END] Job Scheduling Catch ex As Exception diff --git a/Service.JobRunner/JobRunner.vbproj b/Service.JobRunner/JobRunner.vbproj index faa52385..2eafeea6 100644 --- a/Service.JobRunner/JobRunner.vbproj +++ b/Service.JobRunner/JobRunner.vbproj @@ -108,6 +108,7 @@ + diff --git a/Service.JobRunner/Jobs/APISQLJob.vb b/Service.JobRunner/Jobs/APISQLJob.vb new file mode 100644 index 00000000..be0edfa6 --- /dev/null +++ b/Service.JobRunner/Jobs/APISQLJob.vb @@ -0,0 +1,23 @@ +Imports DigitalData.Modules.Database +Imports DigitalData.Modules.Jobs +Imports DigitalData.Modules.Logging +Imports Quartz + +Public Class APISQLJob + Implements Quartz.IJob + + Public Function Execute(context As IJobExecutionContext) As Task Implements Quartz.IJob.Execute + Dim oJobData = context.MergedJobDataMap + Dim oLogConfig As LogConfig = oJobData.Item("LogConfig") + Dim oMSSQL As MSSQLServer = oJobData.Item("MSSQL") + Dim oArgs As Dictionary(Of String, String) = oJobData.Item("Args") + Dim oJobArgs = New APISQLArgs With { + .ProfileID = oArgs.Item("ProfileID") + } + + Dim oGraphQLJob As New Modules.Jobs.API_DEXSQLJob(oLogConfig, oMSSQL) + oGraphQLJob.StartDexAPISQL(oJobArgs) + + Return Task.FromResult(True) + End Function +End Class