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 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