yusm пре 4 недеља
родитељ
комит
e80a99af67

+ 10 - 7
fhKeeper/formulahousekeeper/management-crm/src/main/java/com/management/platform/controller/WechatCallbackController.java

@@ -20,7 +20,7 @@ import java.util.Arrays;
 import java.util.Map;
 
 @RestController
-@RequestMapping("/wechat/callback")
+@RequestMapping("/wechat")
 @Slf4j
 public class WechatCallbackController {
     private final String TOKEN = "FireRockCRM2025";
@@ -37,11 +37,12 @@ public class WechatCallbackController {
     }
 
     // 微信配置验证接口(GET请求)
-    @GetMapping
+    @GetMapping("/callback")
     public String validate(@RequestParam("signature") String signature,
                            @RequestParam("timestamp") String timestamp,
                            @RequestParam("nonce") String nonce,
                            @RequestParam("echostr") String echostr) {
+        log.info("进入了微信配置验证接口");
 
         // 1. 将Token、timestamp、nonce按字典序排序
         String[] arr = new String[]{TOKEN, timestamp, nonce};
@@ -53,14 +54,16 @@ public class WechatCallbackController {
 
         // 3. 验证签名
         if (calculatedSignature.equals(signature)) {
+            log.info("Invalid signature==>GET请求验证签名成功");
             return echostr; // 验证成功返回echostr
         }
         log.info("Invalid signature==>GET请求验证失败");
         return "Invalid signature"; // 验证失败
     }
     
-    @PostMapping(produces = "application/xml;charset=UTF-8")
-    public String handleCallback(@RequestBody String xmlData, HttpServletRequest request) {
+    @PostMapping(produces = "application/xml;charset=UTF-8",value = "/callback")
+    public String handleMessage(@RequestBody String xmlData, HttpServletRequest request) {
+        log.info("进入微信接口回调处理逻辑");
         try {
             Document document = DocumentHelper.parseText(xmlData);
             Element root = document.getRootElement();
@@ -85,12 +88,12 @@ public class WechatCallbackController {
                 handleUnsubscribe(openId);
             }
 
-            log.info("回调成功");
-            log.info("回调返回==>"+successResponse(root));
+            log.info("回调处理逻辑成功");
+            log.info("回调处理逻辑返回==>"+successResponse(root));
             return successResponse(root);
         } catch (Exception e) {
             e.printStackTrace();
-            log.info("回调失败==>"+e.getMessage());
+            log.info("回调处理逻辑失败==>"+e.getMessage());
             return "";
         }
     }