From 6b6f0416d36ad25ed3c06e2ad773faa13613f209 Mon Sep 17 00:00:00 2001 From: liyj <1617420630@qq.com> Date: Thu, 15 Jan 2026 09:58:17 +0800 Subject: [PATCH] =?UTF-8?q?mq=E5=A4=84=E7=90=86=E5=BA=97=E9=93=BA=E4=BC=9A?= =?UTF-8?q?=E5=91=98=E5=8D=87=E7=BA=A7=E7=AD=96=E7=95=A5=EF=BC=8C=E4=BC=9A?= =?UTF-8?q?=E5=91=98=E6=96=B0=E5=A2=9E=E7=AD=96=E7=95=A5=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/admin/AccountController.java | 4 +- .../listener/DealUserInfoListener.java | 81 +------------------ .../listener/UpgradeUserLevelListener.java | 12 ++- .../service/AccountUserInfoService.java | 2 +- .../service/ShopStoreMemberLevelService.java | 8 +- .../service/ShopStoreMemberService.java | 5 +- .../impl/AccountUserBaseServiceImpl.java | 2 +- .../impl/AccountUserInfoServiceImpl.java | 29 +------ .../impl/ShopStoreMemberLevelServiceImpl.java | 76 +++++++++++++---- .../impl/ShopStoreMemberServiceImpl.java | 40 +++++---- 10 files changed, 109 insertions(+), 150 deletions(-) diff --git a/mall-account/src/main/java/com/suisung/mall/account/controller/admin/AccountController.java b/mall-account/src/main/java/com/suisung/mall/account/controller/admin/AccountController.java index fab2a862..18b3a3a9 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/controller/admin/AccountController.java +++ b/mall-account/src/main/java/com/suisung/mall/account/controller/admin/AccountController.java @@ -187,7 +187,7 @@ public class AccountController { @RequestParam(name = "user_store_total") Integer user_store_total, @RequestParam(name = "user_fans_vip_total", defaultValue = "0") Integer user_fans_vip_total, @RequestParam(name = "user_fans_team_total", defaultValue = "0") Integer user_fans_team_total) { - return CommonResult.success(accountUserInfoService.checkUpdateUserLevel(user_id, user_exp_total, user_fans_total, user_spend_total, user_store_total, user_fans_vip_total, user_fans_team_total,null,null)); + return CommonResult.success(accountUserInfoService.checkUpdateUserLevel(user_id, user_exp_total, user_fans_total, user_spend_total, user_store_total, user_fans_vip_total, user_fans_team_total)); } @RequestMapping(value = "/checkUpdateUserLevelById", method = RequestMethod.POST) @@ -196,7 +196,7 @@ public class AccountController { @RequestParam(name = "user_exp_total") BigDecimal user_exp_total, @RequestParam(name = "user_fans_total") Integer user_fans_total) { AccountUserAnalytics analytics = accountUserAnalyticsService.get(user_id); - return CommonResult.success(accountUserInfoService.checkUpdateUserLevel(user_id, user_exp_total, user_fans_total, analytics.getUser_spend(), 0, 0, 0,null,null)); + return CommonResult.success(accountUserInfoService.checkUpdateUserLevel(user_id, user_exp_total, user_fans_total, analytics.getUser_spend(), 0, 0, 0)); } @ApiOperation(value = "用户SNS信息", notes = "用户SNS信息") diff --git a/mall-account/src/main/java/com/suisung/mall/account/listener/DealUserInfoListener.java b/mall-account/src/main/java/com/suisung/mall/account/listener/DealUserInfoListener.java index 72d067af..0bb24dc5 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/listener/DealUserInfoListener.java +++ b/mall-account/src/main/java/com/suisung/mall/account/listener/DealUserInfoListener.java @@ -1,19 +1,11 @@ package com.suisung.mall.account.listener; import cn.hutool.json.JSONUtil; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.rabbitmq.client.Channel; -import com.suisung.mall.account.mapper.AccountUserBindConnectMapper; -import com.suisung.mall.account.mapper.AccountUserInfoMapper; -import com.suisung.mall.account.mapper.ShopStoreMemberLevelMapper; -import com.suisung.mall.account.mapper.ShopStoreMemberMapper; import com.suisung.mall.account.service.AccountUserInfoService; -import com.suisung.mall.common.api.BindCode; +import com.suisung.mall.account.service.ShopStoreMemberService; import com.suisung.mall.common.constant.MqConstant; -import com.suisung.mall.common.modules.account.AccountUserBindConnect; import com.suisung.mall.common.modules.account.AccountUserInfo; -import com.suisung.mall.common.modules.store.ShopStoreMember; -import com.suisung.mall.common.modules.store.ShopStoreMemberLevel; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.annotation.RabbitHandler; @@ -25,7 +17,6 @@ import org.springframework.web.context.request.ServletRequestAttributes; import java.io.IOException; import java.nio.charset.StandardCharsets; -import java.util.List; @Service @Slf4j @@ -36,16 +27,7 @@ public class DealUserInfoListener { private AccountUserInfoService accountUserInfoService; @Autowired - private AccountUserBindConnectMapper accountUserBindConnectMapper; - - @Autowired - private AccountUserInfoMapper accountUserInfoMapper; - - @Autowired - private ShopStoreMemberMapper shopStoreMemberMapper; - - @Autowired - private ShopStoreMemberLevelMapper shopStoreMemberLevelMapper; + private ShopStoreMemberService shopStoreMemberService; @RabbitHandler public void listener(byte[] data, Channel channel, Message message) throws IOException, InterruptedException { @@ -67,11 +49,7 @@ public class DealUserInfoListener { boolean flag = accountUserInfoService.saveOrUpdate(accountUserInfo); if (flag) { if(accountUserInfo.getStore_id()!=null){ - AccountUserInfo updateAccountUserInfo= accountUserInfoMapper.selectById(accountUserInfo.getUser_id()); - // AccountUserInfo updateAccountUserInfo= accountUserInfoService.get(accountUserInfo.getUser_id()); - updateAccountUserInfo.setStore_name(accountUserInfo.getStore_name()); - //shopStoreMemberService.dealStoreMember(updateAccountUserInfo); - this.dealStoreMember(updateAccountUserInfo); + shopStoreMemberService.dealStoreMember(accountUserInfo); } channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } else { @@ -86,57 +64,4 @@ public class DealUserInfoListener { } } - private void dealStoreMember(AccountUserInfo accountUserInfo){ - log.info("dealStoreMember-MQ处理店铺会员开始:accountUserInfo:{}", JSONUtil.toJsonStr(accountUserInfo)); - if(null!=accountUserInfo.getStore_id()){ - log.info("MQ处理店铺会员开始:accountUserInfo:{}", JSONUtil.toJsonStr(accountUserInfo)); - Integer store_id = accountUserInfo.getStore_id(); - Integer user_id = accountUserInfo.getUser_id(); - QueryWrapper params=new QueryWrapper<>(); - params.eq("store_id",store_id); - params.eq("user_id",user_id); - List shopStoreMembers= shopStoreMemberMapper.selectList(params); - if(shopStoreMembers.isEmpty()){ - QueryWrapper queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("bind_id", "+86"+accountUserInfo.getUser_mobile()); - queryWrapper.eq("bind_type", BindCode.MOBILE) - .eq("user_type", 0) - .eq("user_id", user_id) - .orderByAsc("bind_time"); - List accountUserBindConnectList = accountUserBindConnectMapper.selectList(queryWrapper); - if (!accountUserBindConnectList.isEmpty()){ - AccountUserBindConnect accountUserBindConnect= accountUserBindConnectList.get(0); - ShopStoreMember shopStoreMember = new ShopStoreMember(); - shopStoreMember.setStoreName(accountUserInfo.getStore_name()); - shopStoreMember.setStoreId(store_id); - shopStoreMember.setUserId(user_id); - shopStoreMember.setBind_openid(accountUserBindConnect.getBind_openid()); - shopStoreMember.setUserNickname(accountUserBindConnect.getBind_nickname()); - shopStoreMember.setUserAccount(accountUserBindConnect.getBind_id()); - shopStoreMemberMapper.insert(shopStoreMember); - ShopStoreMemberLevel shopStoreMemberLevel = getShopStoreMemberLevel(store_id, shopStoreMember); - shopStoreMemberLevel.setUserId(user_id); - shopStoreMemberLevelMapper.insert(shopStoreMemberLevel); - } - } - } - } - - /** - * 店铺会员初始化信息 - * @param storeId - * @param shopStoreMember - * @return - */ - private ShopStoreMemberLevel getShopStoreMemberLevel(Integer storeId, ShopStoreMember shopStoreMember) { - ShopStoreMemberLevel shopStoreMemberLevel=new ShopStoreMemberLevel(); - shopStoreMemberLevel.setStoreId(storeId); - shopStoreMemberLevel.setStoreMemberId(shopStoreMember.getStore_member_id()); - shopStoreMemberLevel.setUserLevelName("v1"); - shopStoreMemberLevel.setUserLevelId(1001); - shopStoreMemberLevel.setMemberLevelId(1001); - shopStoreMemberLevel.setMemberLevelName("v1"); - return shopStoreMemberLevel; - } - } diff --git a/mall-account/src/main/java/com/suisung/mall/account/listener/UpgradeUserLevelListener.java b/mall-account/src/main/java/com/suisung/mall/account/listener/UpgradeUserLevelListener.java index 77b43399..4afdd03e 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/listener/UpgradeUserLevelListener.java +++ b/mall-account/src/main/java/com/suisung/mall/account/listener/UpgradeUserLevelListener.java @@ -3,7 +3,9 @@ package com.suisung.mall.account.listener; import cn.hutool.json.JSONUtil; import com.rabbitmq.client.Channel; import com.suisung.mall.account.service.AccountUserInfoService; +import com.suisung.mall.account.service.ShopStoreMemberLevelService; import com.suisung.mall.common.constant.MqConstant; +import com.suisung.mall.common.modules.store.ShopStoreMemberLevel; import com.suisung.mall.common.pojo.to.UserLevelTO; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.core.Message; @@ -23,6 +25,9 @@ public class UpgradeUserLevelListener { @Autowired private AccountUserInfoService accountUserInfoService; + @Autowired + private ShopStoreMemberLevelService shopStoreMemberLevelService; + @RabbitHandler public void listener(byte[] data, Channel channel, Message message) throws IOException, InterruptedException { // 将byte[]转换为String，然后调用现有的处理逻辑 @@ -36,8 +41,13 @@ public class UpgradeUserLevelListener { // String messageId = message.getMessageProperties().getMessageId(); try { - boolean flag = accountUserInfoService.checkUpdateUserLevel(userLevelTO.getUser_id(), userLevelTO.getUser_exp_total(), userLevelTO.getUser_fans_total(), userLevelTO.getUser_spend_total(), 0, 0, 0,userLevelTO.getStore_id(),userLevelTO.getUser_store_spend_total()); + boolean flag = accountUserInfoService.checkUpdateUserLevel(userLevelTO.getUser_id(), userLevelTO.getUser_exp_total(), userLevelTO.getUser_fans_total(), userLevelTO.getUser_spend_total(), 0, 0, 0); if (flag) { + ShopStoreMemberLevel shopStoreMemberLevel = new ShopStoreMemberLevel(); + shopStoreMemberLevel.setUserLevelSpend(userLevelTO.getUser_store_spend_total()); + shopStoreMemberLevel.setUserId(userLevelTO.getUser_id()); + shopStoreMemberLevel.setStoreId(userLevelTO.getStore_id()); + shopStoreMemberLevelService.checkUpdateStoreUserLevel(shopStoreMemberLevel);//店铺会员升级 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } else { log.error("消息消费失败，执行upgradeUserLevel异常，当前用户编号：{}", userLevelTO.getUser_id()); diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserInfoService.java b/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserInfoService.java index 14c08df8..bc628970 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserInfoService.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserInfoService.java @@ -26,7 +26,7 @@ public interface AccountUserInfoService extends IBaseService { Map getLists(QueryWrapper queryWrapper, Integer page, Integer rows); - boolean checkUpdateUserLevel(Integer user_id, BigDecimal user_exp_total, Integer user_fans_total, BigDecimal user_spend_total, Integer user_store_total, Integer user_fans_vip_total, Integer user_fans_team_total,Integer store_id,BigDecimal user_store_spend_total); + boolean checkUpdateUserLevel(Integer user_id, BigDecimal user_exp_total, Integer user_fans_total, BigDecimal user_spend_total, Integer user_store_total, Integer user_fans_vip_total, Integer user_fans_team_total); BigDecimal getDistUserLevelConfig(String key, Integer user_id, BigDecimal defaultValue); diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/ShopStoreMemberLevelService.java b/mall-account/src/main/java/com/suisung/mall/account/service/ShopStoreMemberLevelService.java index 55943f2e..e0f54214 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/ShopStoreMemberLevelService.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/ShopStoreMemberLevelService.java @@ -1,12 +1,10 @@ package com.suisung.mall.account.service; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.baomidou.mybatisplus.extension.service.IService; import com.suisung.mall.common.modules.store.ShopStoreMemberLevel; -import java.util.List; -public interface ShopStoreMemberLevelService extends IService { +public interface ShopStoreMemberLevelService { - List findShopStoreMemberLevelList(ShopStoreMemberLevel shopStoreMemberLevel); + + void checkUpdateStoreUserLevel(ShopStoreMemberLevel shopStoreMemberLevel); } diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/ShopStoreMemberService.java b/mall-account/src/main/java/com/suisung/mall/account/service/ShopStoreMemberService.java index e9971bcb..d16ffe0c 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/ShopStoreMemberService.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/ShopStoreMemberService.java @@ -1,11 +1,10 @@ package com.suisung.mall.account.service; -import com.baomidou.mybatisplus.extension.service.IService; import com.suisung.mall.common.modules.account.AccountUserInfo; -import com.suisung.mall.common.modules.store.ShopStoreMember; -public interface ShopStoreMemberService extends IService { + +public interface ShopStoreMemberService { void dealStoreMember(AccountUserInfo accountUserInfo); } diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBaseServiceImpl.java b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBaseServiceImpl.java index bfbff4cb..8c8550ce 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBaseServiceImpl.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBaseServiceImpl.java @@ -1355,7 +1355,7 @@ public class AccountUserBaseServiceImpl extends BaseServiceImpl levelQueryWrapper = new QueryWrapper<>(); @@ -218,30 +217,6 @@ public class AccountUserInfoServiceImpl extends BaseServiceImpl shopStoreMemberLevels= shopStoreMemberLevelService.findShopStoreMemberLevelList(params); - if(shopStoreMemberLevels!=null && !shopStoreMemberLevels.isEmpty()){ - ShopStoreMemberLevel updateShopStoreMemberLevel= shopStoreMemberLevels.get(0); - BigDecimal storeSpend=NumberUtil.add(updateShopStoreMemberLevel.getUserLevelSpend(),user_store_spend_total);//店铺会员总消费 - QueryWrapper levelQueryWrapper = new QueryWrapper<>(); - levelQueryWrapper.le("user_level_spend", storeSpend) - .gt("user_level_spend", "0.00").orderByDesc("user_level_spend"); - level_row = accountBaseUserLevelService.findOne(levelQueryWrapper); - updateShopStoreMemberLevel.setUserLevelSpend(storeSpend); - if(level_row != null && CheckUtil.isNotEmpty(level_row.getUser_level_id())){ - Integer user_level_id = level_row.getUser_level_id(); - String user_level_name = level_row.getUser_level_name(); - updateShopStoreMemberLevel.setUserLevelId(user_level_id); - updateShopStoreMemberLevel.setUserLevelName(user_level_name); - } - shopStoreMemberLevelService.updateById(updateShopStoreMemberLevel); - } - } return true; } @@ -451,7 +426,7 @@ public class AccountUserInfoServiceImpl extends BaseServiceImpl */ -@Transactional @Service -public class ShopStoreMemberLevelServiceImpl extends BaseServiceImpl implements ShopStoreMemberLevelService { +@Slf4j +public class ShopStoreMemberLevelServiceImpl implements ShopStoreMemberLevelService { + @Autowired + private ShopStoreMemberLevelMapper shopStoreMemberLevelMapper; + @Autowired + private AccountBaseUserLevelMapper accountBaseUserLevelMapper; @Override - public List findShopStoreMemberLevelList(ShopStoreMemberLevel shopStoreMemberLevel) { - QueryWrapper queryWrapper = new QueryWrapper<>(); - if(shopStoreMemberLevel.getStoreId()!=null){ - queryWrapper.eq("store_id",shopStoreMemberLevel.getStoreId()); + public void checkUpdateStoreUserLevel(ShopStoreMemberLevel shopStoreMemberLevel) { + log.info("MQ店铺会员升级开始shopStoreMemberLevel:{}", shopStoreMemberLevel); + int maxAttempts = 3; // 最多尝试3次 + int currentAttempt = 0; + boolean success = false; + while (currentAttempt < maxAttempts && !success) { + success = dealStoreUserLevel(shopStoreMemberLevel); + if (!success) { + currentAttempt++; + if (currentAttempt < maxAttempts) { + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + log.error("线程被中断，重试终止", e); + Thread.currentThread().interrupt(); + break; + } + } + } } - - if(shopStoreMemberLevel.getMemberLevelId()!=null){ - queryWrapper.eq("store_member_id",shopStoreMemberLevel.getStoreMemberId()); + if (!success) { + log.error("店铺会员升级失败，已达到最大重试次数"); } + } - if(shopStoreMemberLevel.getUserId()!=null){ - queryWrapper.eq("user_id",shopStoreMemberLevel.getUserId()); + private boolean dealStoreUserLevel(ShopStoreMemberLevel shopStoreMemberLevel){ + if(shopStoreMemberLevel.getUserLevelSpend()!=null && shopStoreMemberLevel.getStoreId()!=null && shopStoreMemberLevel.getUserId()!=null){//店铺消费 + //查找会员再，更新店铺会员等级 todo + QueryWrapper params = new QueryWrapper<>(); + params.eq("user_id", shopStoreMemberLevel.getUserId()); + params.eq("store_id", shopStoreMemberLevel.getStoreId()); + List shopStoreMemberLevels= shopStoreMemberLevelMapper.selectList(params); + if(shopStoreMemberLevels!=null && !shopStoreMemberLevels.isEmpty()) { + ShopStoreMemberLevel updateShopStoreMemberLevel = shopStoreMemberLevels.get(0); + BigDecimal storeSpend = NumberUtil.add(updateShopStoreMemberLevel.getUserLevelSpend(), shopStoreMemberLevel.getUserLevelSpend());//店铺会员总消费 + QueryWrapper levelQueryWrapper = new QueryWrapper<>(); + levelQueryWrapper.le("user_level_spend", storeSpend) + .gt("user_level_spend", "0.00").orderByDesc("user_level_spend"); + AccountBaseUserLevel level_row = accountBaseUserLevelMapper.selectOne(levelQueryWrapper); + updateShopStoreMemberLevel.setUserLevelSpend(storeSpend); + if (level_row != null && CheckUtil.isNotEmpty(level_row.getUser_level_id())) { + Integer user_level_id = level_row.getUser_level_id(); + String user_level_name = level_row.getUser_level_name(); + updateShopStoreMemberLevel.setUserLevelId(user_level_id); + updateShopStoreMemberLevel.setUserLevelName(user_level_name); + } + shopStoreMemberLevelMapper.updateById(updateShopStoreMemberLevel); + }else { + return false; + } } - - return this.list(queryWrapper); + return true; } diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/impl/ShopStoreMemberServiceImpl.java b/mall-account/src/main/java/com/suisung/mall/account/service/impl/ShopStoreMemberServiceImpl.java index 166255de..209e8ade 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/impl/ShopStoreMemberServiceImpl.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/impl/ShopStoreMemberServiceImpl.java @@ -2,17 +2,16 @@ package com.suisung.mall.account.service.impl; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.suisung.mall.account.mapper.AccountUserBindConnectMapper; +import com.suisung.mall.account.mapper.AccountUserInfoMapper; +import com.suisung.mall.account.mapper.ShopStoreMemberLevelMapper; import com.suisung.mall.account.mapper.ShopStoreMemberMapper; -import com.suisung.mall.account.service.AccountUserBindConnectService; -import com.suisung.mall.account.service.ShopStoreMemberLevelService; import com.suisung.mall.account.service.ShopStoreMemberService; import com.suisung.mall.common.api.BindCode; -import com.suisung.mall.common.constant.CommonConstant; import com.suisung.mall.common.modules.account.AccountUserBindConnect; import com.suisung.mall.common.modules.account.AccountUserInfo; import com.suisung.mall.common.modules.store.ShopStoreMember; import com.suisung.mall.common.modules.store.ShopStoreMemberLevel; -import com.suisung.mall.core.web.service.impl.BaseServiceImpl; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -25,17 +24,24 @@ import java.util.List; */ @Service @Slf4j -public class ShopStoreMemberServiceImpl extends BaseServiceImpl implements ShopStoreMemberService { +public class ShopStoreMemberServiceImpl implements ShopStoreMemberService { @Autowired - private ShopStoreMemberLevelService shopStoreMemberLevelService; + private ShopStoreMemberMapper shopStoreMemberMapper; @Autowired - private AccountUserBindConnectService accountUserBindConnectService; + private AccountUserBindConnectMapper accountUserBindConnectMapper; + @Autowired + private ShopStoreMemberLevelMapper shopStoreMemberLevelMapper; + + @Autowired + private AccountUserInfoMapper accountUserInfoMapper; @Override public void dealStoreMember(AccountUserInfo accountUserInfo){ + AccountUserInfo updateAccountUserInfo= accountUserInfoMapper.selectById(accountUserInfo.getUser_id()); + log.info("dealStoreMember-MQ处理店铺会员开始:accountUserInfo:{}", JSONUtil.toJsonStr(accountUserInfo)); if(null!=accountUserInfo.getStore_id()){ log.info("MQ处理店铺会员开始:accountUserInfo:{}", JSONUtil.toJsonStr(accountUserInfo)); Integer store_id = accountUserInfo.getStore_id(); @@ -43,15 +49,15 @@ public class ShopStoreMemberServiceImpl extends BaseServiceImpl params=new QueryWrapper<>(); params.eq("store_id",store_id); params.eq("user_id",user_id); - List shopStoreMembers= this.list(params); + List shopStoreMembers= shopStoreMemberMapper.selectList(params); if(shopStoreMembers.isEmpty()){ - AccountUserBindConnect paramAccountUserBindConnect=new AccountUserBindConnect(); - paramAccountUserBindConnect.setBind_id("+86"+accountUserInfo.getUser_mobile()); - paramAccountUserBindConnect.setBind_type(BindCode.MOBILE); - paramAccountUserBindConnect.setUser_id(user_id); - paramAccountUserBindConnect.setBind_active(CommonConstant.Enable); - paramAccountUserBindConnect.setUser_type(0); - List accountUserBindConnectList = accountUserBindConnectService.getAllBindList(paramAccountUserBindConnect); + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("bind_id", "+86"+updateAccountUserInfo.getUser_mobile()); + queryWrapper.eq("bind_type", BindCode.MOBILE) + .eq("user_type", 0) + .eq("user_id", user_id) + .orderByAsc("bind_time"); + List accountUserBindConnectList = accountUserBindConnectMapper.selectList(queryWrapper); if (!accountUserBindConnectList.isEmpty()){ AccountUserBindConnect accountUserBindConnect= accountUserBindConnectList.get(0); ShopStoreMember shopStoreMember = new ShopStoreMember(); @@ -61,10 +67,10 @@ public class ShopStoreMemberServiceImpl extends BaseServiceImpl