wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-2481: 删除无用代码

Browse Source
This commit is contained in:
yanglin 2024-05-31 17:22:11 +08:00
parent 8407f37363
commit 5f5bd8b019
2 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/event/TodoPushSender.java
View File

@ -1,14 +1,19 @@
package cn.axzo.msg.center.message.service.todo.manage.event;
import cn.axzo.msg.center.dal.TodoBusinessDao;
import cn.axzo.msg.center.dal.TodoBusinesses;
import cn.axzo.msg.center.domain.entity.Todo;
import cn.axzo.msg.center.domain.entity.TodoBusiness;
import cn.axzo.msg.center.message.domain.dto.MessageTemplateDTO;
import cn.axzo.msg.center.message.domain.dto.MessageTemplateRouterDTO;
import cn.axzo.msg.center.message.domain.dto.MessageTemplateRouterDTO.MessageRouteDetailDTO;
import cn.axzo.msg.center.message.domain.dto.MessageTemplateRouterDTO.MessageRouterConfigDTO;
import cn.axzo.msg.center.message.service.todo.manage.TodoExt;
import cn.axzo.msg.center.message.service.youmeng.YoumengPush;
import cn.axzo.msg.center.message.service.youmeng.YoumengPush.PushNavigation;
import cn.axzo.msg.center.message.service.youmeng.YoumengTemplateClient;
import cn.axzo.msg.center.utils.MessageRouterUtil;
import com.alibaba.fastjson.JSONObject;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
@ -18,7 +23,9 @@ import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @author yanglin
@ -30,6 +37,7 @@ class TodoPushSender implements ApplicationListener<NewTodoEvent> {
private final YoumengTemplateClient youmengTemplateClient;
private final MessageRouterUtil messageRouterUtil;
private final TodoBusinessDao todoBusinessDao;
@Override
public void onApplicationEvent(@NotNull NewTodoEvent event) {
@ -56,8 +64,18 @@ class TodoPushSender implements ApplicationListener<NewTodoEvent> {
List<MessageRouterConfigDTO> routerConfigs = detail.getRouterConfigs();
if (CollectionUtils.isEmpty(routerConfigs))
return Collections.emptyList();
JSONObject routerParam = todo.getRouterParams();
if (routerParam == null) {
routerParam = new JSONObject();
}
TodoBusinesses businesses = todoBusinessDao.getBusinesses(todo);
TodoBusiness business = businesses.findBusiness(todo).orElse(null);
Map<String, Object> ctx = new HashMap<>();
ctx.put("business", business);
ctx.put("todo", todo);
routerParam.put(TodoExt.CTX, ctx);
MessageTemplateRouterDTO router = messageRouterUtil.parseAndConcatRouteUrl(
template, template.getMsgTemplateRouter(), todo.getRouterParams());
template, template.getMsgTemplateRouter(), routerParam);
if (router == null)
return Collections.emptyList();
ArrayList<PushNavigation> navigations = new ArrayList<>();

4
msg-center-dal/src/main/java/cn/axzo/msg/center/dal/TodoBusinessDao.java
View File

@ -41,6 +41,10 @@ public class TodoBusinessDao extends ServiceImpl<TodoBusinessMapper, TodoBusines
.update();
}
public TodoBusinesses getBusinesses(Todo todo) {
return getBusinesses(Collections.singletonList(todo));
}
public TodoBusinesses getBusinesses(List<Todo> todos) {
// 获取对应的待办业务
Set<Long> businessIds = todos.stream()