backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1、店铺会员mq新增日志

Browse Source 
2、店铺会员新增查询条件
This commit is contained in:
liyj 2026-01-14 09:51:20 +08:00
parent 8761eec19e
commit d819216b4a
3 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
mall-account/src/main/java/com/suisung/mall/account/listener/DealUserInfoListener.java
View File

@ -50,7 +50,7 @@ public class DealUserInfoListener {
public void listener(String data, Channel channel, Message message) throws IOException, InterruptedException { public void listener(String data, Channel channel, Message message) throws IOException, InterruptedException {
AccountUserInfo accountUserInfo = JSONUtil.toBean(data, AccountUserInfo.class); AccountUserInfo accountUserInfo = JSONUtil.toBean(data, AccountUserInfo.class);
// String messageId = message.getMessageProperties().getMessageId(); // String messageId = message.getMessageProperties().getMessageId();
log.info("MQ处理活动开始:accountUserInfo:{}", JSONUtil.toJsonStr(accountUserInfo));
try { try {
boolean flag = accountUserInfoService.saveOrUpdate(accountUserInfo); boolean flag = accountUserInfoService.saveOrUpdate(accountUserInfo);
if (flag) { if (flag) {
@ -69,6 +69,7 @@ public class DealUserInfoListener {
} }
private void dealStoreMember(AccountUserInfo accountUserInfo){ private void dealStoreMember(AccountUserInfo accountUserInfo){
if(null!=accountUserInfo.getStore_id()){ if(null!=accountUserInfo.getStore_id()){
log.info("MQ店铺会员开始:accountUserInfo:{}", JSONUtil.toJsonStr(accountUserInfo));
Integer store_id = accountUserInfo.getStore_id(); Integer store_id = accountUserInfo.getStore_id();
Integer user_id = accountUserInfo.getUser_id(); Integer user_id = accountUserInfo.getUser_id();
ShopStoreMember params=new ShopStoreMember(); ShopStoreMember params=new ShopStoreMember();

4
mall-shop/src/main/java/com/suisung/mall/shop/store/controller/admin/ShopStoreMemberController.java
View File

@ -46,9 +46,13 @@ public class ShopStoreMemberController extends BaseControllerImpl {
@RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
ShopStoreMember shopStoreMember=new ShopStoreMember(); ShopStoreMember shopStoreMember=new ShopStoreMember();
String userId=getParameter("userId"); String userId=getParameter("userId");
String userAccount=getParameter("userAccount");
if(StringUtils.isNotEmpty(userId)){ if(StringUtils.isNotEmpty(userId)){
shopStoreMember.setUserId(Convert.toInt(userId)); shopStoreMember.setUserId(Convert.toInt(userId));
} }
if(StringUtils.isNotEmpty(userAccount)){
shopStoreMember.setUserAccount(userAccount);
}
return shopStoreMemberService.findPage(shopStoreMember,pageNum,pageSize); return shopStoreMemberService.findPage(shopStoreMember,pageNum,pageSize);
} }

4
mall-shop/src/main/java/com/suisung/mall/shop/store/service/impl/ShopStoreMemberServiceImpl.java
View File

@ -8,6 +8,7 @@ import com.suisung.mall.common.domain.UserDto;
import com.suisung.mall.common.exception.ApiException; import com.suisung.mall.common.exception.ApiException;
import com.suisung.mall.common.modules.store.*; import com.suisung.mall.common.modules.store.*;
import com.suisung.mall.common.utils.ContextUtil; import com.suisung.mall.common.utils.ContextUtil;
import com.suisung.mall.common.utils.StringUtils;
import com.suisung.mall.core.web.service.impl.BaseServiceImpl; import com.suisung.mall.core.web.service.impl.BaseServiceImpl;
import com.suisung.mall.shop.store.mapper.ShopStoreMemberMapper; import com.suisung.mall.shop.store.mapper.ShopStoreMemberMapper;
import com.suisung.mall.shop.store.service.ShopStoreMemberLevelService; import com.suisung.mall.shop.store.service.ShopStoreMemberLevelService;
@ -50,6 +51,9 @@ public class ShopStoreMemberServiceImpl extends BaseServiceImpl<ShopStoreMemberM
if(shopStoreMember.getUserId()!=null){ if(shopStoreMember.getUserId()!=null){
queryWrapper.eq("user_id", shopStoreMember.getUserId()); queryWrapper.eq("user_id", shopStoreMember.getUserId());
} }
if(StringUtils.isNotEmpty(shopStoreMember.getUserAccount())){
queryWrapper.like("user_account", shopStoreMember.getUserAccount());
}
return this.lists(queryWrapper, pageNo, pageSize); return this.lists(queryWrapper, pageNo, pageSize);
} }