zhengsl/WholeProcessPlatform
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: 优化推送消息逻辑

Browse Source
This commit is contained in:
tangwei 2026-07-09 11:37:37 +08:00
parent 9bf01de0bb
commit 4f44e7ae26
2 changed files with 19 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
backend/src/main/java/com/yfd/platform/system/domain/QuartzJob.java
View File

@ -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;
}

8
backend/src/main/java/com/yfd/platform/system/service/impl/PushConfigServiceImpl.java
View File

@ -399,8 +399,8 @@ public class PushConfigServiceImpl extends ServiceImpl<PushConfigMapper, PushCon
Date now = new Date();
if (quartzJob == null) {
quartzJob = new QuartzJob();
quartzJob.setCustom1(QUARTZ_BIZ_TYPE);
quartzJob.setCustom2(config.getId());
quartzJob.setBizModule(QUARTZ_BIZ_TYPE);
quartzJob.setBizId(config.getId());
}
quartzJob.setJobName("推送配置-" + config.getCategoryName());
quartzJob.setJobClass("pushConfigQuartzExecutor");
@ -457,8 +457,8 @@ public class PushConfigServiceImpl extends ServiceImpl<PushConfigMapper, PushCon
private QuartzJob getPushQuartzJob(String configId) {
List<QuartzJob> list = quartzJobService.list(new LambdaQueryWrapper<QuartzJob>()
.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();
}