From 92fc9b9c7e6fc3bf2b5982ccbd981ca3444b5e69 Mon Sep 17 00:00:00 2001 From: zhangran Date: Mon, 1 Apr 2024 16:52:48 +0800 Subject: [PATCH] =?UTF-8?q?add-job=E6=9F=A5=E8=AF=A2=E6=8C=87=E5=AE=9A?= =?UTF-8?q?=E8=BA=AB=E4=BB=BD=E8=AF=81=E7=9A=84=E4=BA=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/axzo/nanopart/server/job/BlackUserSyncJob.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/job/BlackUserSyncJob.java b/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/job/BlackUserSyncJob.java index 2f4b4086..be248b4d 100644 --- a/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/job/BlackUserSyncJob.java +++ b/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/job/BlackUserSyncJob.java @@ -8,6 +8,7 @@ import cn.axzo.nanopart.server.dao.entity.SaasBlackWhiteList; import cn.axzo.nanopart.server.mq.producer.BlackProducer; import cn.axzo.nanopart.server.service.BlackAndWhiteListService; import cn.azxo.framework.common.utils.StringUtils; +import cn.hutool.core.collection.CollectionUtil; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.google.common.collect.Lists; @@ -20,6 +21,7 @@ import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.util.ArrayList; import java.util.Arrays; +import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -60,6 +62,10 @@ public class BlackUserSyncJob extends BaseJobHandler{ saasBlackWhiteLists = blackAndWhiteListService.listModuleBlackUser(req); }else{ saasBlackWhiteLists = blackAndWhiteListService.listModuleBlackUser(); + if(CollectionUtil.isEmpty(saasBlackWhiteLists)){ + log.info("没有查到指定的黑名单人员数据"); + return ReturnT.SUCCESS; + } } Map> modulBlackMap = saasBlackWhiteLists.stream().collect(Collectors.groupingBy(SaasBlackWhiteList::getModule)); modulBlackMap.forEach((module, blackList) -> {