diff --git a/backend/src/main/java/com/yfd/platform/system/domain/QuartzJob.java b/backend/src/main/java/com/yfd/platform/system/domain/QuartzJob.java index d5135141..055a4d0f 100644 --- a/backend/src/main/java/com/yfd/platform/system/domain/QuartzJob.java +++ b/backend/src/main/java/com/yfd/platform/system/domain/QuartzJob.java @@ -1,6 +1,7 @@ package com.yfd.platform.system.domain; import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; @@ -115,4 +116,18 @@ public class QuartzJob implements Serializable { @Schema(description = "备用3") private String custom3; + /** + * 业务模块编码(如:PUSH-推送配置,SYNC-数据同步,REPORT-报表生成) + */ + @Schema(description = "业务模块编码") + @TableField("BIZ_MODULE") + private String bizModule; + + /** + * 关联业务表的主键ID(如 PUSH_CONFIG.ID) + */ + @Schema(description = "关联业务主键ID") + @TableField("BIZ_ID") + private String bizId; + } diff --git a/backend/src/main/java/com/yfd/platform/system/service/impl/PushConfigServiceImpl.java b/backend/src/main/java/com/yfd/platform/system/service/impl/PushConfigServiceImpl.java index 1636eb31..8ad1ff06 100644 --- a/backend/src/main/java/com/yfd/platform/system/service/impl/PushConfigServiceImpl.java +++ b/backend/src/main/java/com/yfd/platform/system/service/impl/PushConfigServiceImpl.java @@ -399,8 +399,8 @@ public class PushConfigServiceImpl extends ServiceImpl list = quartzJobService.list(new LambdaQueryWrapper() - .eq(QuartzJob::getCustom1, QUARTZ_BIZ_TYPE) - .eq(QuartzJob::getCustom2, configId)); + .eq(QuartzJob::getBizModule, QUARTZ_BIZ_TYPE) + .eq(QuartzJob::getBizId, configId)); return list.isEmpty() ? null : list.getFirst(); }