diff --git a/src/main/java/com/wecom/robot/controller/WecomCallbackController.java b/src/main/java/com/wecom/robot/controller/WecomCallbackController.java index 5d18473..5bb3132 100644 --- a/src/main/java/com/wecom/robot/controller/WecomCallbackController.java +++ b/src/main/java/com/wecom/robot/controller/WecomCallbackController.java @@ -1,8 +1,11 @@ package com.wecom.robot.controller; +import com.wecom.robot.adapter.ChannelAdapter; +import com.wecom.robot.adapter.MessageSyncCapable; import com.wecom.robot.config.WecomConfig; -import com.wecom.robot.dto.WxCallbackMessage; +import com.wecom.robot.dto.*; import com.wecom.robot.service.MessageProcessService; +import com.wecom.robot.service.MessageRouterService; import com.wecom.robot.util.WXBizMsgCrypt; import com.wecom.robot.util.XmlUtil; import lombok.RequiredArgsConstructor; @@ -11,14 +14,24 @@ import org.springframework.web.bind.annotation.*; import java.util.Map; +/** + * 企业微信回调控制器 + *
+ * 负责验签/解密/解析,构建 InboundMessage 传递给 MessageRouterService。
+ * [AC-MCA-08] 入口层控制器
+ */
@Slf4j
@RestController
@RequestMapping("/wecom")
@RequiredArgsConstructor
public class WecomCallbackController {
+ private static final String CHANNEL_TYPE = "wechat";
+
private final WecomConfig wecomConfig;
private final MessageProcessService messageProcessService;
+ private final MessageRouterService messageRouterService;
+ private final Map 职责:
- * 关联 AC: [AC-MCA-08] 统一消息路由
- *
- * @see MessageRouterService
- * @see InboundMessage
+ * 消息处理服务
+ *
+ * 负责从微信拉取消息并转换为 InboundMessage 传递给 MessageRouterService。
+ * [AC-MCA-08] 消息处理服务
*/
@Slf4j
@Service
@RequiredArgsConstructor
public class MessageProcessService {
+ private static final String CHANNEL_TYPE = "wechat";
+
private final SessionManagerService sessionManagerService;
+ private final AiService aiService;
+ private final TransferService transferService;
private final WecomApiService wecomApiService;
+ private final WebSocketService webSocketService;
private final MessageRouterService messageRouterService;
+ private final Map
- *
- *
- *