add-job查询指定身份证的人

black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/job/BlackUserSyncJob.java

@@ -1,13 +1,17 @@
 package cn.axzo.nanopart.server.job;
 
 import cn.axzo.nanopart.api.constant.enums.BlackModuleEnum;
+import cn.axzo.nanopart.api.constant.enums.ListTypeEnum;
 import cn.axzo.nanopart.api.constant.enums.MQEventEnum;
+import cn.axzo.nanopart.api.request.BlackListReq;
 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.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;
@@ -15,6 +19,8 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
@@ -40,7 +46,21 @@ public class BlackUserSyncJob extends BaseJobHandler{
     @Override
     @XxlJob("blackUserSyncJob")
     public ReturnT<String> execute(String param) throws Exception {
-        List<SaasBlackWhiteList> saasBlackWhiteLists = blackAndWhiteListService.listModuleBlackUser();
+        List<SaasBlackWhiteList> saasBlackWhiteLists;
+        // 身份证号不为空，多条以“,”分割
+        if(StringUtils.isNotBlank(param)){
+            List<String> idCards = Arrays.stream(param.split(",")).collect(Collectors.toList());
+            ArrayList<BlackModuleEnum> models = Lists.newArrayList(BlackModuleEnum.GXJG_BLACKUSER_WORKER, BlackModuleEnum.GXJG_BLACKUSER_TEAMLEADER, BlackModuleEnum.GXJG_BLACKUSER_EMPLOYEE);
+            BlackListReq req = new BlackListReq();
+            req.setModules(models);
+            req.setType(ListTypeEnum.BLACK_LIST);
+            HashMap<String, Object> map = Maps.newHashMap();
+            map.put("userIdCard", idCards);
+            req.setParam(map);
+            saasBlackWhiteLists = blackAndWhiteListService.listModuleBlackUser(req);
+        }else{
+            saasBlackWhiteLists = blackAndWhiteListService.listModuleBlackUser();
+        }
         Map<String, List<SaasBlackWhiteList>> modulBlackMap = saasBlackWhiteLists.stream().collect(Collectors.groupingBy(SaasBlackWhiteList::getModule));
         modulBlackMap.forEach((module, blackList) -> {
             log.info("syncRockerMQ module:{} ,blackList.size:{}" ,module, blackList.size());

black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/service/BlackAndWhiteListService.java

@@ -53,4 +53,6 @@ public interface BlackAndWhiteListService {
      * @return
      */
     List<BlackAndWhiteListResp> isInBlackListExistList(BlackListReq req);
+
+    List<SaasBlackWhiteList> listModuleBlackUser(BlackListReq req);
 }

black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/service/impl/BlackAndWhiteListServiceImpl.java

@@ -397,4 +397,10 @@ public class BlackAndWhiteListServiceImpl implements BlackAndWhiteListService {
         List<SaasBlackWhiteList> detail = blackAndWhiteListRepository.blackWhiteLists(req);
         return BeanMapper.copyList(detail, BlackAndWhiteListResp.class);
     }
+
+    @Override
+    public List<SaasBlackWhiteList> listModuleBlackUser(BlackListReq req){
+        // 同步到RockerMQ
+        return blackAndWhiteListRepository.blackWhiteLists(req);
+    }
 }