wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add-修改对象类型

Browse Source
This commit is contained in:
zhangran 2024-03-30 21:05:54 +08:00
parent bca277b00d
commit 4c8d2b1034
2 changed files with 22 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -5,12 +5,16 @@ import cn.axzo.nanopart.api.constant.enums.MQEventEnum;
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.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.google.common.collect.Lists;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Objects;
@ -40,10 +44,15 @@ public class BlackUserSyncJob extends BaseJobHandler{
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());
BlackModuleEnum blackModuleEnum = BlackModuleEnum.getByValue(module);
MQEventEnum event = MQEventEnum.getByName(blackModuleEnum.name());
ArrayList<Map<String,Object>> sends = Lists.newArrayList();
blackList.forEach(item -> sends.add(item.getParam()));
String jsonStr = JSONUtil.toJsonStr(sends);
if(Objects.nonNull(blackModuleEnum) && Objects.nonNull(event)){
BlackProducer.sendBatch(event, blackList);
BlackProducer.send(event, jsonStr);
}
});
return ReturnT.SUCCESS;

12
black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/mq/producer/BlackProducer.java
View File

@ -51,6 +51,18 @@ public class BlackProducer implements InitializingBean {
baseEntities.forEach(baseEntity -> send(mqEventEnum, baseEntity, null));
}
public static void send(MQEventEnum mqEventEnum, String data) {
//生产消息
eventProducer.send(Event.builder()
.targetType(mqEventEnum.getModel())
.eventCode(mqEventEnum.getEventCode())
.eventModule(mqEventEnum.getModel())
.eventName(mqEventEnum.getTag())
.operatorId(null)
.data(data)
.build());
}
@Override
public void afterPropertiesSet() {
eventProducer = SpringUtil.getBean(EventProducer.class);