From 2bfe7c48dce30da4935837bda8907450a354e09b Mon Sep 17 00:00:00 2001 From: liyj <1617420630@qq.com> Date: Wed, 14 Jan 2026 16:35:07 +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?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/DealUserInfoListener.java | 77 ++----------------- 1 file changed, 8 insertions(+), 69 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 f401b5b1..669946f5 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,20 +1,11 @@ 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.account.service.ShopStoreMemberService; 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; @@ -24,7 +15,6 @@ import org.springframework.stereotype.Service; import java.io.IOException; import java.nio.charset.StandardCharsets; -import java.util.List; @Service @Slf4j @@ -34,10 +24,7 @@ public class DealUserInfoListener { @Autowired private AccountUserInfoService accountUserInfoService; @Autowired - private ShopService shopService; - - @Autowired - private AccountUserBindConnectService accountUserBindConnectService; + private ShopStoreMemberService shopStoreMemberService; @RabbitHandler public void listener(byte[] data, Channel channel, Message message) throws IOException, InterruptedException { @@ -55,7 +42,12 @@ public class DealUserInfoListener { boolean flag = accountUserInfoService.saveOrUpdate(accountUserInfo); if (flag) { channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); - dealStoreMember(accountUserInfo); + log.info("MQ处理活动开始:accountUserInfo:{}", JSONUtil.toJsonStr(accountUserInfo)); + if(accountUserInfo.getStore_id()!=null){ + AccountUserInfo updateAccountUserInfo= accountUserInfoService.get(accountUserInfo.getStore_id()); + updateAccountUserInfo.setStore_name(accountUserInfo.getStore_name()); + shopStoreMemberService.dealStoreMember(updateAccountUserInfo); + } } else { log.error("消息消费失败，执行dealUserInfo异常，当前用户编号：{}", accountUserInfo.getUser_id()); channel.basicReject(message.getMessageProperties().getDeliveryTag(), true); @@ -67,57 +59,4 @@ public class DealUserInfoListener { Thread.sleep(1000); } } - private void dealStoreMember(AccountUserInfo 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(); - 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; - } }