From c3bc743f718721d012a6cd33862bf5e9207925a8 Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Thu, 16 Oct 2025 09:17:00 +0800
Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E8=90=A5=E9=94=80=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81=E4=BB=BB=E5=8A=A1=E7=94=A8=E6=88=B7=E5=88=97=E8=A1=A8?=
 =?UTF-8?q?=E5=A4=B1=E8=B4=A5=20=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/AShopUserServiceImpl.java    | 24 ++++++++++++-------
 1 file changed, 16 insertions(+), 8 deletions(-)

diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/AShopUserServiceImpl.java b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/AShopUserServiceImpl.java
index 148340351..efe6a9e3c 100644
--- a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/AShopUserServiceImpl.java
+++ b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/AShopUserServiceImpl.java
@@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.RandomUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.hutool.log.Log;
 import com.czg.account.dto.shopuser.*;
 import com.czg.account.entity.ShopUser;
 import com.czg.account.entity.UserInfo;
@@ -29,6 +30,7 @@ import com.github.pagehelper.PageInfo;
 import com.mybatisflex.core.paginate.Page;
 import com.mybatisflex.core.query.QueryWrapper;
 import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.apache.dubbo.config.annotation.DubboService;
 import org.springframework.stereotype.Service;
@@ -46,6 +48,7 @@ import java.util.stream.Collectors;
  * @author Administrator
  * @since 2025-02-08
  */
+@Slf4j
 @DubboService
 public class AShopUserServiceImpl implements AShopUserService {
     @Resource
@@ -95,14 +98,19 @@ public class AShopUserServiceImpl implements AShopUserService {
 
     @Override
     public Page<ShopUser> getPushEventUser(SmsPushEventUser smsPushEventUser) {
-        PageHelper.startPage(new Page<>(smsPushEventUser.getPage(), smsPushEventUser.getSize()));
-        Long mainShopId = shopInfoService.getMainIdByShopId(smsPushEventUser.getShopId());
-        // 调用Mapper层查询
-        return shopUserMapper.selectPushEventUser(
-                mainShopId,
-                smsPushEventUser.getShopId(),
-                smsPushEventUser
-        );
+        try {
+            PageHelper.startPage(smsPushEventUser.getPage(), smsPushEventUser.getSize());
+            Long mainShopId = shopInfoService.getMainIdByShopId(smsPushEventUser.getShopId());
+            // 调用Mapper层查询
+            return shopUserMapper.selectPushEventUser(
+                    mainShopId,
+                    smsPushEventUser.getShopId(),
+                    smsPushEventUser
+            );
+        }catch (Exception e){
+            log.info("获取营销推送任务用户列表失败{},{}", smsPushEventUser, e.getMessage());
+            return new Page<>();
+        }
     }
 
     @Override