c-zhouhf1/zhgh_zjvtit
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

整改短信是否开启

Browse Source 
整改更新人员问题
This commit is contained in:
c-zhouhf1
2026-08-29 10:32:27 +08:00
parent b4e585beb5
commit a753610930
2 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/budwk/app/base/sms/impl/SmsServiceImpl.java
+1 -1
View File
@@ -65,7 +65,7 @@ public class SmsServiceImpl implements SmsService {
List<NutMap> resultReceivers = buildAndValidateReceivers(sendType, loginNameList, receivers, title, content); List<NutMap> resultReceivers = buildAndValidateReceivers(sendType, loginNameList, receivers, title, content);
List<NutMap> batchResults = new ArrayList<>(); List<NutMap> batchResults = new ArrayList<>();
if (!Globals.MyConfig.getBoolean("SendMsg", false)) { if (!Globals.MyConfig.getBoolean("AppSms", false)) {
String message = "消息发送配置未开启，已跳过实际发送"; String message = "消息发送配置未开启，已跳过实际发送";
log.warn(message); log.warn(message);
saveSendRecord(sendType, title, content, pcUrl, mobileUrl, resultReceivers.size(), false, saveSendRecord(sendType, title, content, pcUrl, mobileUrl, resultReceivers.size(), false,
src/main/java/com/budwk/app/sys/services/impl/SysDataUserAllUpdateServiceImpl.java
+8 -2
View File
@@ -53,9 +53,13 @@ import java.util.stream.Collectors;
@IocBean @IocBean
public class SysDataUserAllUpdateServiceImpl implements SysDataUserUpdateService { public class SysDataUserAllUpdateServiceImpl implements SysDataUserUpdateService {
private static final int BATCH_SIZE = 500; private static final int BATCH_SIZE = 500;
/** 不需要人工确认。 */ /**
* 不需要人工确认。
*/
private static final int PENDING_CONFIRM_STATUS_NONE = 0; private static final int PENDING_CONFIRM_STATUS_NONE = 0;
/** 数据源缺失，等待人工确认。 */ /**
* 数据源缺失，等待人工确认。
*/
private static final int PENDING_CONFIRM_STATUS_PENDING = 1; private static final int PENDING_CONFIRM_STATUS_PENDING = 1;
@Inject @Inject
@@ -353,9 +357,11 @@ public class SysDataUserAllUpdateServiceImpl implements SysDataUserUpdateService
// 6. 处理其他任务 // 6. 处理其他任务
// 6.1 更新提案的校领导角色，发送订阅 // 6.1 更新提案的校领导角色，发送订阅
ProposalConfig config = dao.fetch(ProposalConfig.class, Cnd.where("delFlag", "=", false).desc("updatedAt")); ProposalConfig config = dao.fetch(ProposalConfig.class, Cnd.where("delFlag", "=", false).desc("updatedAt"));
if (config != null) {
for (String unitId : config.getSchoolLeaderUnitIds()) { for (String unitId : config.getSchoolLeaderUnitIds()) {
RoleEventPublisher.broadcast(new RoleEventMsg(unitId, RoleConstant.PROPOSAL_BRANCH_SCHOOL_LEADER.name(), RoleEventMsg.RENEW_ROLE)); RoleEventPublisher.broadcast(new RoleEventMsg(unitId, RoleConstant.PROPOSAL_BRANCH_SCHOOL_LEADER.name(), RoleEventMsg.RENEW_ROLE));
} }
}
/* /*
* 所有异步用户更新完成后再校正待确认状态，避免主事务提前锁定 sys_user， * 所有异步用户更新完成后再校正待确认状态，避免主事务提前锁定 sys_user，