From 42133da8985c02520b4884488a738665c9a3f31d Mon Sep 17 00:00:00 2001
From: wangsiyuan <2392948297@qq.com>
Date: Tue, 12 Dec 2023 18:28:20 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=9B=E5=BB=BA=20WeChatMsgForwarderControll?=
 =?UTF-8?q?er.java?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../WeChatMsgForwarderController.java         | 39 +++++++++++++++++++
 1 file changed, 39 insertions(+)
 create mode 100644 src/main/java/com/kimgo/wepush/controller/WeChatMsgForwarderController.java

diff --git a/src/main/java/com/kimgo/wepush/controller/WeChatMsgForwarderController.java b/src/main/java/com/kimgo/wepush/controller/WeChatMsgForwarderController.java
new file mode 100644
index 0000000..b16544c
--- /dev/null
+++ b/src/main/java/com/kimgo/wepush/controller/WeChatMsgForwarderController.java
@@ -0,0 +1,39 @@
+package com.kimgo.wepush.controller;
+
+import com.kimgo.wepush.model.WeChatMsg;
+import com.kimgo.wepush.response.ServerResponseEntity;
+import com.kimgo.wepush.service.HandleWeChatMsgService;
+import jakarta.validation.Valid;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@Validated
+@RequestMapping(value = "/api",method = RequestMethod.POST)
+public class WeChatMsgForwarderController {
+
+    private final Logger logger = LoggerFactory.getLogger(WeChatMsgForwarderController.class);
+
+    private final HandleWeChatMsgService handleWeChatMsgService;
+
+    public WeChatMsgForwarderController(HandleWeChatMsgService handleWeChatMsgService) {
+        this.handleWeChatMsgService = handleWeChatMsgService;
+    }
+
+    @PostMapping("/wechat")
+    public ServerResponseEntity receiveMsg(@RequestHeader("accessToken") String accessToken,
+                                             @RequestBody @Valid WeChatMsg weChatMsg){
+        logger.info("CallInfoO: {}",weChatMsg.toString());
+        if(accessToken == null){
+            logger.warn("Access token is missing or empty");
+            return ServerResponseEntity.fail("accessToken cannot be empty.");
+        }
+        if (weChatMsg.isInvalid()) {
+            logger.debug("CallInfo has invalid fields.");
+            return ServerResponseEntity.fail("json body value error.");
+        }
+        return handleWeChatMsgService.handleMsg(accessToken,weChatMsg);
+    }
+}