|
|
@@ -24,7 +24,7 @@ public class DbJobPersistence : IJobPersistence
|
|
|
|
|
|
// 获取内存的作业
|
|
|
IEnumerable<SchedulerBuilder> memoryJobs = App.EffectiveTypes.ScanToBuilders();
|
|
|
-
|
|
|
+
|
|
|
// 若数据库不存在任何作业,则返回内存作业
|
|
|
if (!jobDetailRep.IsAny(u => true)) return memoryJobs;
|
|
|
|
|
|
@@ -85,7 +85,7 @@ public class DbJobPersistence : IJobPersistence
|
|
|
{
|
|
|
using var serviceScope = _serviceProvider.CreateScope();
|
|
|
var db = serviceScope.ServiceProvider.GetService<ISqlSugarClient>();
|
|
|
-
|
|
|
+
|
|
|
var jobDetail = context.JobDetail.Adapt<SysJobDetail>();
|
|
|
if (context.Behavior == PersistenceBehavior.Appended)
|
|
|
{
|
|
|
@@ -93,7 +93,7 @@ public class DbJobPersistence : IJobPersistence
|
|
|
}
|
|
|
else if (context.Behavior == PersistenceBehavior.Updated)
|
|
|
{
|
|
|
- db.Updateable(jobDetail).WhereColumns(u => new { u.JobId }).ExecuteCommand();
|
|
|
+ db.Updateable(jobDetail).IgnoreColumns(it => new { it.Id }).WhereColumns(u => new { u.JobId }).ExecuteCommand();
|
|
|
}
|
|
|
else if (context.Behavior == PersistenceBehavior.Removed)
|
|
|
{
|
|
|
@@ -117,7 +117,7 @@ public class DbJobPersistence : IJobPersistence
|
|
|
}
|
|
|
else if (context.Behavior == PersistenceBehavior.Updated)
|
|
|
{
|
|
|
- db.Updateable(jobTrigger).WhereColumns(u => new { u.TriggerId, u.JobId }).ExecuteCommand();
|
|
|
+ db.Updateable(jobTrigger).IgnoreColumns(it => new { it.Id }).WhereColumns(u => new { u.TriggerId, u.JobId }).ExecuteCommand();
|
|
|
}
|
|
|
else if (context.Behavior == PersistenceBehavior.Removed)
|
|
|
{
|