DemoChain

消息通知服务 · coinex-msg

职责与定位

提供推送、接收信息、群消息和通知模板等服务。

属性 内容
源码目录 coinex-msg
分类 通知、协议与支撑服务
工程角色 业务或支撑服务工程
构建入口 coinex-msg/pom.xml

已核对的源码入口

类或接口 源码路径
PushMsgService coinex-msg/msg-api/src/main/java/com/exch/msg/api/push/service/PushMsgService.java
PushKeyService coinex-msg/msg-api/src/main/java/com/exch/msg/api/pushkey/service/PushKeyService.java
ReceiveInfoService coinex-msg/msg-api/src/main/java/com/exch/msg/api/reveiveinfo/service/ReceiveInfoService.java
GroupMsgService coinex-msg/msg-api/src/main/java/com/exch/msg/api/sms/service/GroupMsgService.java
SmsTemplateService coinex-msg/msg-api/src/main/java/com/exch/msg/api/sms/service/SmsTemplateService.java
SmsTemplateTypeService coinex-msg/msg-api/src/main/java/com/exch/msg/api/sms/service/SmsTemplateTypeService.java

接口摘录

以下签名来自接口声明，用于定位能力；接口声明不等于实现和线上调用已验证。

PushMsgService

Long addOnePush(PushMsg pushMsg) throws PushMsgException;
PageResult<PushTemplate> findPushTemplte(Integer pageNumber, Integer pageSize, Long partnerId) throws PushMsgException;
int saveOnePushTemplate(PushMsg pushMsg);
int cancelPushMsg(Long pushMsgId);

PushKeyService

PageResult<PushKey> findPage(Integer pageNum, Integer pageSize, Long partnerId, String platform) throws PushKeyException;
int savePushKey(PushKey pushKey, String name);
int deleteOnePushKeyById(Long id);
void updatePushKeyStatus(Long partnerId, String platform, String isDev);

ReceiveInfoService

void updateReceiveInfoStateByIds(List<Long> ids);
void updateReceiveInfoStateByUser(Long userId);
Boolean selectHasUnreadMsgOrNot(Long id);
int selectHasUnreadCount(Long id);

启动入口线索

  • coinex-msg/msg-provider/src/main/java/com/exch/msg/provider/MsgServerApplication.java

仅列出已发现的 main 入口，部署数量与启用参数需对照目标环境确认。

核心流程核对

区分站内消息、设备推送及其他通知通道，核对受众、模板和回执。

边界与验证

本页核对了工程结构、所列文件与部分公开接口；未验证完整调用链、生产启用状态或运行结果。

选择一条实际业务请求，记录入口、下游调用、数据变化和错误结果；覆盖无权限、重复请求、下游超时及重启恢复。涉及金额时额外核对精度、冻结、流水和幂等。

返回通知、协议与支撑服务或全部工程与服务。