From 0cf037e6f2c251305c3258518c0d75e60afcd512 Mon Sep 17 00:00:00 2001 From: liyj <1617420630@qq.com> Date: Tue, 13 Jan 2026 18:34:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BA=97=E9=93=BA=E4=BC=9A=E5=91=98mq=E6=96=B0?= =?UTF-8?q?=E5=A2=9E--=E8=B4=AD=E4=B9=B0=E6=97=B6=E6=96=B0=E5=A2=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/DealUserInfoListener.java | 69 +++++++++++++++++++ .../impl/AccountUserInfoServiceImpl.java | 4 +- .../modules/account/AccountUserInfo.java | 8 ++- 3 files changed, 78 insertions(+), 3 deletions(-) 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 29da5a00..ef0d5768 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,10 +1,20 @@ package com.suisung.mall.account.listener; +import cn.hutool.core.convert.Convert; import cn.hutool.json.JSONUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.rabbitmq.client.Channel; +import com.suisung.mall.account.service.AccountUserBindConnectService; import com.suisung.mall.account.service.AccountUserInfoService; +import com.suisung.mall.common.api.BindCode; +import com.suisung.mall.common.constant.CommonConstant; import com.suisung.mall.common.constant.MqConstant; +import com.suisung.mall.common.feignService.ShopService; +import com.suisung.mall.common.modules.account.AccountUserBindConnect; import com.suisung.mall.common.modules.account.AccountUserInfo; +import com.suisung.mall.common.modules.store.ShopStoreBase; +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; @@ -14,6 +24,7 @@ import org.springframework.stereotype.Service; import java.io.IOException; import java.nio.charset.StandardCharsets; +import java.util.List; @Service @Slf4j @@ -22,6 +33,11 @@ public class DealUserInfoListener { @Autowired private AccountUserInfoService accountUserInfoService; + @Autowired + private ShopService shopService; + + @Autowired + private AccountUserBindConnectService accountUserBindConnectService; @RabbitHandler public void listener(byte[] data, Channel channel, Message message) throws IOException, InterruptedException { @@ -39,6 +55,7 @@ public class DealUserInfoListener { boolean flag = accountUserInfoService.saveOrUpdate(accountUserInfo); if (flag) { channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); + dealStoreMember(accountUserInfo); } else { log.error("消息消费失败，执行dealUserInfo异常，当前用户编号：{}", accountUserInfo.getUser_id()); channel.basicReject(message.getMessageProperties().getDeliveryTag(), true); @@ -50,4 +67,56 @@ public class DealUserInfoListener { Thread.sleep(1000); } } + private void dealStoreMember(AccountUserInfo accountUserInfo){ + if(null!=accountUserInfo.getStore_id()){ + Integer store_id = accountUserInfo.getStore_id(); + Integer user_id = accountUserInfo.getUser_id(); + ShopStoreMember params=new ShopStoreMember(); + params.setUserId(user_id); + params.setStoreId(store_id); + List shopStoreMembers= shopService.findShopStoreMemberList(params); + ShopStoreBase shopStoreBase= shopService.getShopStoreBase(store_id); + if(shopStoreMembers.isEmpty()&&shopStoreBase!=null){ + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("bind_id", "+86"+accountUserInfo.getUser_mobile())//+86的 + .eq("bind_type", BindCode.MOBILE) + .eq("user_type", 0) + .eq("user_id", user_id) + .eq("bind_active", CommonConstant.Enable) + .orderByAsc("bind_time"); + List accountUserBindConnectList = accountUserBindConnectService.list(queryWrapper); + if (!accountUserBindConnectList.isEmpty()){ + AccountUserBindConnect accountUserBindConnect= accountUserBindConnectList.get(0); + ShopStoreMember shopStoreMember = new ShopStoreMember(); + shopStoreMember.setStoreName(shopStoreBase.getStore_name()); + shopStoreMember.setStoreId(shopStoreBase.getStore_id()); + shopStoreMember.setUserId(user_id); + shopStoreMember.setBind_openid(accountUserBindConnect.getBind_openid()); + shopStoreMember.setUserNickname(accountUserBindConnect.getBind_nickname()); + shopStoreMember.setUserAccount(accountUserBindConnect.getBind_id()); + ShopStoreMember saveShopStoreMember= shopService.saveShopStoreMember(shopStoreMember); + ShopStoreMemberLevel shopStoreMemberLevel = getShopStoreMemberLevel(shopStoreBase, saveShopStoreMember); + shopStoreMemberLevel.setUserId(user_id); + shopService.saveShopStoreMemberLevel(shopStoreMemberLevel); + } + } + } + } + + /** + * 店铺会员初始化信息 + * @param shopStoreBase + * @param shopStoreMember + * @return + */ + private ShopStoreMemberLevel getShopStoreMemberLevel(ShopStoreBase shopStoreBase, ShopStoreMember shopStoreMember) { + ShopStoreMemberLevel shopStoreMemberLevel=new ShopStoreMemberLevel(); + shopStoreMemberLevel.setStoreId(shopStoreBase.getStore_id()); + 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/service/impl/AccountUserInfoServiceImpl.java b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserInfoServiceImpl.java index e8e1caaf..5b6d715b 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserInfoServiceImpl.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserInfoServiceImpl.java @@ -179,7 +179,7 @@ public class AccountUserInfoServiceImpl extends BaseServiceImpl levelQueryWrapper = new QueryWrapper<>(); levelQueryWrapper.le("user_level_spend", user_spend_total) - .gt("user_level_spend", 0).orderByDesc("user_level_spend"); + .gt("user_level_spend", BigDecimal.ZERO).orderByDesc("user_level_spend"); level_row = accountBaseUserLevelService.findOne(levelQueryWrapper); } @@ -225,7 +225,7 @@ public class AccountUserInfoServiceImpl extends BaseServiceImpl levelQueryWrapper = new QueryWrapper<>(); levelQueryWrapper.le("user_level_spend", storeSpend) - .gt("user_level_spend", 0).orderByDesc("user_level_spend"); + .gt("user_level_spend", BigDecimal.ZERO).orderByDesc("user_level_spend"); level_row = accountBaseUserLevelService.findOne(levelQueryWrapper); updateShopStoreMemberLevel.setUserLevelSpend(storeSpend); if(level_row != null && CheckUtil.isNotEmpty(level_row.getUser_level_id())){ diff --git a/mall-common/src/main/java/com/suisung/mall/common/modules/account/AccountUserInfo.java b/mall-common/src/main/java/com/suisung/mall/common/modules/account/AccountUserInfo.java index 987d30c6..7d8df49e 100644 --- a/mall-common/src/main/java/com/suisung/mall/common/modules/account/AccountUserInfo.java +++ b/mall-common/src/main/java/com/suisung/mall/common/modules/account/AccountUserInfo.java @@ -1,6 +1,7 @@ package com.suisung.mall.common.modules.account; import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import com.suisung.mall.common.annotation.OssMedia; @@ -119,5 +120,10 @@ public class AccountUserInfo implements Serializable { @ApiModelProperty(value = "渠道编码") private Integer ucc_id; - + /** + * 同步会员到店铺会员，与消息队列UserLevelTO关联 + */ + @ApiModelProperty(value = "店铺id") + @TableField(exist = false) + private Integer store_id; }