zianxin/pj_service_cloud
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

注释默认短信

Browse Source
This commit is contained in:
zjf committed 2025-04-25 15:44:06 +08:00
1 parent 5138684ba1
commit a16ba88d4a
1 file changed
+36 -36
Download Patch File Download Diff File Expand all files Collapse all files
pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysMessageServiceImpl.java
+36 -36
View File
@@ -295,47 +295,47 @@ public class SysMessageServiceImpl extends ServiceImpl<SysMessageMapper, SysMess
public R sendSms(MessageSmsDTO messageSmsDTO) {
// 根据业务编码获取短信通道配置
List<SysSystemConfigEntity> configEntityList = sysSystemConfigMapper.selectList(Wrappers.<SysSystemConfigEntity>lambdaQuery().eq(SysSystemConfigEntity::getConfigType, SystemConfigTypeEnum.SMS.getValue()).eq(SysSystemConfigEntity::getConfigStatus, YesNoEnum.YES.getCode()).eq(SysSystemConfigEntity::getConfigKey, messageSmsDTO.getBizCode()));
if (CollUtil.isEmpty(configEntityList)) {
return R.failed("发送失败，短信通道配置不存在");
}
// List<SysSystemConfigEntity> configEntityList = sysSystemConfigMapper.selectList(Wrappers.<SysSystemConfigEntity>lambdaQuery().eq(SysSystemConfigEntity::getConfigType, SystemConfigTypeEnum.SMS.getValue()).eq(SysSystemConfigEntity::getConfigStatus, YesNoEnum.YES.getCode()).eq(SysSystemConfigEntity::getConfigKey, messageSmsDTO.getBizCode()));
// if (CollUtil.isEmpty(configEntityList)) {
// return R.failed("发送失败，短信通道配置不存在");
// }
SysSystemConfigEntity configEntity = configEntityList.get(0);
JSONObject configMap = JSONUtil.parseObj(configEntity.getConfigValue());
// SysSystemConfigEntity configEntity = configEntityList.get(0);
// JSONObject configMap = JSONUtil.parseObj(configEntity.getConfigValue());
// 组装SMS4J 的发送对象
SmsBlend smsBlend = SmsFactory.getSmsBlend(messageSmsDTO.getBizCode());
if (Objects.isNull(smsBlend)) {
Class targetClass = Arrays.stream(SUPPORT_CONFIG_CLAZZ).filter(config -> config.getSimpleName().toLowerCase().contains(configMap.getStr(MessageSmsDTO.Fields.supplier))).findFirst().orElseThrow(() -> new CheckedException("发送失败，短信通道配置不存在"));
BaseConfig baseConfig = (BaseConfig) JSONUtil.toBean(configEntity.getConfigValue(), targetClass);
// 如果渠道扩展参数不为空则增加特性化参数
if (StrUtil.isNotBlank(configMap.getStr(MessageSmsDTO.Fields.extParams))) {
JSONObject extParams = configMap.getJSONObject(MessageSmsDTO.Fields.extParams);
BeanUtil.copyProperties(extParams, baseConfig);
}
baseConfig.setConfigId(configEntity.getConfigKey());
SmsFactory.createSmsBlend(baseConfig);
smsBlend = SmsFactory.getSmsBlend(messageSmsDTO.getBizCode());
}
// SmsBlend smsBlend = SmsFactory.getSmsBlend(messageSmsDTO.getBizCode());
// if (Objects.isNull(smsBlend)) {
// Class targetClass = Arrays.stream(SUPPORT_CONFIG_CLAZZ).filter(config -> config.getSimpleName().toLowerCase().contains(configMap.getStr(MessageSmsDTO.Fields.supplier))).findFirst().orElseThrow(() -> new CheckedException("发送失败，短信通道配置不存在"));
// BaseConfig baseConfig = (BaseConfig) JSONUtil.toBean(configEntity.getConfigValue(), targetClass);
//
// // 如果渠道扩展参数不为空则增加特性化参数
// if (StrUtil.isNotBlank(configMap.getStr(MessageSmsDTO.Fields.extParams))) {
// JSONObject extParams = configMap.getJSONObject(MessageSmsDTO.Fields.extParams);
// BeanUtil.copyProperties(extParams, baseConfig);
// }
//
// baseConfig.setConfigId(configEntity.getConfigKey());
// SmsFactory.createSmsBlend(baseConfig);
// smsBlend = SmsFactory.getSmsBlend(messageSmsDTO.getBizCode());
// }
// 异步发送短信
SysLogDTO sysLog = SysLogUtils.getSysLog();
Long start = System.currentTimeMillis();
sysLog.setTenantId(TenantContextHolder.getTenantId());
for (String mobile : messageSmsDTO.getMobiles()) {
smsBlend.sendMessageAsync(mobile, configMap.getStr(MessageSmsDTO.Fields.templateId), messageSmsDTO.getParams(), smsResponse -> {
log.info("发送短信结果:{}", smsResponse);
sysLog.setTitle(String.format("发送短信 %s", mobile));
sysLog.setLogType(LogTypeEnum.NORMAL.getType());
sysLog.setServiceId(SystemConfigTypeEnum.SMS.getValue());
sysLog.setParams(JacksonSensitiveFieldUtil.writeValueAsString(smsResponse));
sysLog.setTime(System.currentTimeMillis() - start);
sysLog.setException(JacksonSensitiveFieldUtil.writeValueAsString(smsResponse));
remoteLogService.saveLog(sysLog);
});
}
// SysLogDTO sysLog = SysLogUtils.getSysLog();
// Long start = System.currentTimeMillis();
// sysLog.setTenantId(TenantContextHolder.getTenantId());
// for (String mobile : messageSmsDTO.getMobiles()) {
// smsBlend.sendMessageAsync(mobile, configMap.getStr(MessageSmsDTO.Fields.templateId), messageSmsDTO.getParams(), smsResponse -> {
// log.info("发送短信结果:{}", smsResponse);
// sysLog.setTitle(String.format("发送短信 %s", mobile));
// sysLog.setLogType(LogTypeEnum.NORMAL.getType());
// sysLog.setServiceId(SystemConfigTypeEnum.SMS.getValue());
// sysLog.setParams(JacksonSensitiveFieldUtil.writeValueAsString(smsResponse));
// sysLog.setTime(System.currentTimeMillis() - start);
// sysLog.setException(JacksonSensitiveFieldUtil.writeValueAsString(smsResponse));
// remoteLogService.saveLog(sysLog);
// });
// }
return R.ok();
}