From 328e4b676ecc9c8499c8b1d39984cebae2b007f8 Mon Sep 17 00:00:00 2001
From: liyj <1617420630@qq.com>
Date: Tue, 23 Sep 2025 18:14:10 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E8=AE=A2=E9=98=85=E6=A8=A1?=
 =?UTF-8?q?=E6=9D=BF=E7=BB=91=E5=AE=9A=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/AccountUserBindConnectServiceImpl.java     | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

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 f361ba67..0c34f53b 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
@@ -5,8 +5,8 @@ import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONArray;
 import cn.hutool.json.JSONObject;
-import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.suisung.mall.account.mapper.AccountUserBindConnectMapper;
 import com.suisung.mall.account.service.AccountUserBaseService;
 import com.suisung.mall.account.service.AccountUserBindConnectService;
@@ -538,9 +538,9 @@ public class AccountUserBindConnectServiceImpl extends BaseServiceImpl<AccountUs
         log.info("jsonObject:{}", jsonObject);
         String openId=jsonObject.getStr("FromUserName");//用户openid
         QueryWrapper<AccountUserBindConnect> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq("bind_id",openId)
+        queryWrapper.eq("bind_openid",openId)
                 .eq("user_type", CommonConstant.USER_TYPE_NORMAL)
-                .eq("bind_type",15)
+                .in("bind_type",Arrays.asList(1,15))
                 .eq("bind_active", CommonConstant.Enable);
         AccountUserBindConnect accountUserBindConnect= findOne(queryWrapper);
         if (accountUserBindConnect != null) {
@@ -551,7 +551,12 @@ public class AccountUserBindConnectServiceImpl extends BaseServiceImpl<AccountUs
                 String SubscribeStatusString= object.getStr("SubscribeStatusString");//订阅结果（accept接收；reject拒收）参考地址https://developers.weixin.qq.com/miniprogram/dev/framework/open-ability/subscribe-message.html#%E8%AE%A2%E9%98%85%E6%B6%88%E6%81%AF%E8%AF%AD%E9%9F%B3%E6%8F%90%E9%86%92
                 if(SubscribeStatusString.equals("accept")){
                     accountUserBindConnect.setBind_tmpl(templateId);
-                    updateById(accountUserBindConnect);
+                    UpdateWrapper<AccountUserBindConnect> updateWrapper = new UpdateWrapper<>(accountUserBindConnect);
+                    updateWrapper.set("bind_id",accountUserBindConnect.getBind_id());
+                    updateWrapper.set("bind_type",accountUserBindConnect.getBind_type());
+                    updateWrapper.set("user_id",accountUserBindConnect.getUser_id());
+                    updateWrapper.set("user_type",accountUserBindConnect.getUser_type());
+                    update(updateWrapper);
                 }
             }
         }