微信公众号服务器配置

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/controller/WxController.java

@@ -2,6 +2,7 @@ package com.mmc.iuav.user.controller;
 
 import com.mmc.iuav.response.ResultBody;
 import com.mmc.iuav.user.service.WxService;
+import com.mmc.iuav.user.util.WxApiUtil;
 import io.swagger.annotations.*;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -48,6 +49,21 @@ public class WxController extends BaseController {
         return ResultBody.success(wxService.createUrlLink(path, query));
     }
 
+    @ApiOperation(value = "验证服务器URL是否有效")
+    @ApiResponses({@ApiResponse(code = 200, message = "OK", response = String.class)})
+    @GetMapping("wxSendMessage")
+    public void checkService(@RequestParam String signature, @RequestParam String timestamp, @RequestParam String nonce,
+                             @RequestParam String echostr, HttpServletRequest req, HttpServletResponse resp) throws IOException {
+        req.setCharacterEncoding("UTF-8");
+        resp.setCharacterEncoding("UTF-8");
+        PrintWriter out = resp.getWriter();
+        System.out.println("#############验证服务器URL是否有效-START--################");
+        boolean bs = WxApiUtil.checkSignature(signature, timestamp, nonce);
+        System.out.println("输出：" + bs + "---" + echostr);
+        System.out.println("#############验证服务器URL是否有效-END--################");
+        out.println(bs ? echostr : null);
+    }
+
     @ApiOperation(value = "监控微信公众号的事件变化通知", hidden = true)
     @ApiResponses({@ApiResponse(code = 200, message = "OK", response = String.class)})
     @PostMapping("wxSendMessage")

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/impl/WxServiceImpl.java

@@ -136,7 +136,9 @@ public class WxServiceImpl implements WxService {
     @Override
     public String receiveSubAccountEvents(HttpServletRequest request) {
         try {
+            log.info("Received wx events(before convert)：", JSONObject.toJSONString(request.getInputStream()));
             Map<String, String> map = this.convertRequestToMap(request);
+            log.info("Received wx events(after convert)：", JSONObject.toJSONString(map));
             String event = map.get("Event");
             if (WxConstant.subscribe.equals(event)) {
                 // 关注事件

csm-service/cms-service-user/src/main/resources/application-local.yml

@@ -18,7 +18,7 @@ spring:
     port: 5672
     username: MjphbXFwLWNuLXp2cDJvemhuajAwMTpMVEFJNEZ6Q3B5ckEzM1BlZ254V1M2WFY=
     password: RTg3OUMxQzk4NzU0NDQ4RkQ1RDg4MkEzQjY4M0M3MkQxOTM2QkEyNDoxNjUyNDA4NDk0NDg4
-    virtual-host: /
+    virtual-host: dev
 
 wx:
   sub: