diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java index 2ad7f334d..63893d97d 100644 --- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java +++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/JobServiceImpl.java @@ -151,8 +151,6 @@ public class JobServiceImpl implements JobService { % systemProperties.getBucketTotal()); job.setNextTriggerAt(calculateNextTriggerAt(jobRequestVO, DateUtils.toNowMilli())); job.setNamespaceId(UserSessionUtils.currentUserSession().getNamespaceId()); - job.setNotifyIds(JsonUtil.toJsonString(jobRequestVO.getNotifyIds())); - job.setOwnerId(jobRequestVO.getOwnerId()); job.setId(null); return 1 == jobMapper.insert(job); } @@ -166,8 +164,6 @@ public class JobServiceImpl implements JobService { // 判断常驻任务 Job updateJob = JobConverter.INSTANCE.convert(jobRequestVO); - updateJob.setNotifyIds(JsonUtil.toJsonString(jobRequestVO.getNotifyIds())); - updateJob.setOwnerId(jobRequestVO.getOwnerId()); updateJob.setResident(isResident(jobRequestVO)); updateJob.setNamespaceId(job.getNamespaceId());