消息发送动作流,增加消息类型条件

This commit is contained in:
dxfeng 2025-08-29 14:40:52 +08:00
parent ffa436259f
commit 5bed75960b
3 changed files with 5 additions and 3 deletions

View File

@ -54,11 +54,12 @@ public class SendMessageAction implements EsbServerlessRpcRemoteInterface {
String templateId = (String) params.get("templateId");
String templateVersionName = (String) params.get("templateVersionName");
String content = (String) params.get("content");
String type = (String) params.get("type");
log.error("params===" + JSON.toJSONString(params));
BaseParam baseParam = new BaseParam();
MessageSendConfig messageSendConfig = sendMessageMapper.getMessageSendConfig(baseParam, departmentId);
MessageSendConfig messageSendConfig = sendMessageMapper.getMessageSendConfig(baseParam, departmentId,type);
while (messageSendConfig == null && StringUtils.isNotBlank(departmentId)) {
String parentDepartmentId = sendMessageMapper.getParentDepartmentId(baseParam, departmentId);
@ -68,7 +69,7 @@ public class SendMessageAction implements EsbServerlessRpcRemoteInterface {
break;
}
departmentId = parentDepartmentId;
messageSendConfig = sendMessageMapper.getMessageSendConfig(baseParam, departmentId);
messageSendConfig = sendMessageMapper.getMessageSendConfig(baseParam, departmentId,type);
}
if (null == messageSendConfig) {

View File

@ -18,7 +18,7 @@ public interface SendMessageMapper {
String getParentDepartmentId(@Param("param") BaseParam param, @Param("departmentId") String departmentId);
MessageSendConfig getMessageSendConfig(@Param("param") BaseParam param, @Param("departmentId") String departmentId);
MessageSendConfig getMessageSendConfig(@Param("param") BaseParam param, @Param("departmentId") String departmentId,@Param("type") String type);
String getSuperior(@Param("param") BaseParam param, @Param("employeeId") String employeeId);

View File

@ -14,6 +14,7 @@
<select id="getMessageSendConfig" resultType="com.weaver.seconddev.entry.entity.MessageSendConfig">
select bm,ry,xxlx,ms,zjsj,jgsjzjssj,xxsj,bmfzr,tbmyg,hrbp,fgld
from ${param.eteams}.uf_xxgzb t1 where t1.tenant_key = #{param.tenantKey} and t1.delete_type = 0
and xxlx = #{type}
and FIND_IN_SET(#{departmentId}, bm) > 0
</select>