From 8ef1760b9d6ee94fe0df3b2ea5084da8af1094b8 Mon Sep 17 00:00:00 2001
From: liyj <1617420630@qq.com>
Date: Sat, 20 Sep 2025 10:15:36 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E5=BE=AE=E4=BF=A1=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81=E6=9C=8D=E5=8A=A1=E5=99=A8=E9=85=8D=E7=BD=AE=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/mobile/WeiXinController.java        | 14 ++++----------
 .../service/AccountUserBindConnectService.java     |  2 +-
 .../impl/AccountUserBindConnectServiceImpl.java    |  7 ++++---
 3 files changed, 9 insertions(+), 14 deletions(-)

diff --git a/mall-account/src/main/java/com/suisung/mall/account/controller/mobile/WeiXinController.java b/mall-account/src/main/java/com/suisung/mall/account/controller/mobile/WeiXinController.java
index d239faa8..7f20f3c4 100644
--- a/mall-account/src/main/java/com/suisung/mall/account/controller/mobile/WeiXinController.java
+++ b/mall-account/src/main/java/com/suisung/mall/account/controller/mobile/WeiXinController.java
@@ -145,22 +145,16 @@ public class WeiXinController extends BaseControllerImpl {
 
     @ApiOperation(value = "小程序回调", notes = "小程序回调")
     @RequestMapping(value = "/xcxCallBack", method = RequestMethod.GET)
-    public CommonResult xcxCallBack(@RequestParam(value = "signature",required = false) String signature,
+    public String xcxCallBack(@RequestParam(value = "signature",required = false) String signature,
                                     @RequestParam(value = "timestamp",required = false) String timestamp,
                                     @RequestParam(value = "nonce",required = false) String nonce,
                                     @RequestParam(value = "echostr",required = false) String echostr) {
-        if(StringUtils.isEmpty(signature) || StringUtils.isEmpty(timestamp)  || StringUtils.isEmpty(nonce)  || StringUtils.isEmpty(echostr) ) {
-            return CommonResult.success("校验成功");//todo 配置好消息链接改回来，腾讯服务器测试提交没有发送参数，导致报错
-        }
         boolean checked=weiXinService.checkSignature(timestamp, nonce, signature);
         if(checked){
-            return CommonResult.success("校验成功");
+            accountUserBindConnectService.bindTmplId(echostr);
+            return echostr;
         }
-        if(!checked){
-            return CommonResult.failed("校验失败");
-        }
-        accountUserBindConnectService.bindTmplId(echostr);
-        return CommonResult.success("小程序订阅消息模板绑定成功");
+        return  "fail";
     }
 
 }
diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBindConnectService.java b/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBindConnectService.java
index 2ff35f8c..b1df5ad4 100644
--- a/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBindConnectService.java
+++ b/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBindConnectService.java
@@ -93,5 +93,5 @@ public interface AccountUserBindConnectService extends IBaseService<AccountUserB
 
     long getAllBindCount(Integer bind_type,String bindTmpl);
 
-    boolean bindTmplId(String jsonObjectStr);
+    void bindTmplId(String jsonObjectStr);
 }
diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java
index ab2ef9b4..97dce695 100644
--- a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java
+++ b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java
@@ -25,6 +25,7 @@ import com.suisung.mall.core.web.service.impl.BaseServiceImpl;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.DuplicateKeyException;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -526,12 +527,13 @@ public class AccountUserBindConnectServiceImpl extends BaseServiceImpl<AccountUs
     }
 
     @Override
-    public boolean bindTmplId(String jsonObjectStr) {
+    @Async
+    public void bindTmplId(String jsonObjectStr) {
         JSONObject jsonObject= null;
         try {
             jsonObject= JSONUtil.parseObj(jsonObjectStr);
         }catch (RuntimeException e) {
-            throw new ApiException("非json数据");
+            log.info("错误信息--{}",e.getMessage());
         }
         String openId=jsonObject.getStr("FromUserName");//用户openid
         QueryWrapper<AccountUserBindConnect> queryWrapper = new QueryWrapper<>();
@@ -552,7 +554,6 @@ public class AccountUserBindConnectServiceImpl extends BaseServiceImpl<AccountUs
                 }
             }
         }
-        return true;
     }