diff --git a/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/dao/mapper/BlackAndWhiteListMapper.java b/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/dao/mapper/BlackAndWhiteListMapper.java index 73a06d46..fca0da3c 100644 --- a/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/dao/mapper/BlackAndWhiteListMapper.java +++ b/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/dao/mapper/BlackAndWhiteListMapper.java @@ -17,15 +17,4 @@ import java.util.List; @Mapper public interface BlackAndWhiteListMapper extends BaseMapper { - /** - * 获取getField中字段的值 - * - * @param type - * @param getField 获取json中指定字段 - * @param modules - * @return - */ - List getParamValue(@Param("type") Integer type, - @Param("getField") String getField, - @Param("modules") List modules); } diff --git a/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/mq/producer/BlackProducer.java b/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/mq/producer/BlackProducer.java index 122351b3..3a439d73 100644 --- a/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/mq/producer/BlackProducer.java +++ b/black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/mq/producer/BlackProducer.java @@ -17,40 +17,6 @@ import java.util.List; @Service public class BlackProducer implements InitializingBean { private static EventProducer eventProducer; - - public static void send(MQEventEnum mqEventEnum, BaseEntity baseEntity, String operatorId){ - log.info(JSON.toJSONString(baseEntity)); - if(mqEventEnum == null){ - throw new ServiceException("无法正确发送mq: mqEventEnum不能为空"); - } - if(baseEntity == null){ - log.error("消息实体为空不能发送mq mqEventEnum {}", mqEventEnum); - return; - } - if(baseEntity.getId() == null){ - throw new ServiceException("无法正确发送mq: 主健id不能为空"); - } - //生产消息 - eventProducer.send(Event.builder() - .shardingKey(String.valueOf(baseEntity.getId())) - .targetId(String.valueOf(baseEntity.getId())) - .targetType(mqEventEnum.getModel()) - .eventCode(mqEventEnum.getEventCode()) - .eventModule(mqEventEnum.getModel()) - .eventName(mqEventEnum.getTag()) - .operatorId(operatorId) - .data(baseEntity) - .build()); - } - - public static void send(MQEventEnum mqEventEnum, BaseEntity baseEntity){ - send(mqEventEnum, baseEntity, null); - } - - public static void sendBatch(MQEventEnum mqEventEnum, List> baseEntities){ - baseEntities.forEach(baseEntity -> send(mqEventEnum, baseEntity, null)); - } - public static void send(MQEventEnum mqEventEnum, String data) { if(mqEventEnum == null){ throw new ServiceException("无法正确发送mq: mqEventEnum不能为空"); diff --git a/nanopart-server/src/main/resources/mapper/BlackAndWhiteListMapper.xml b/nanopart-server/src/main/resources/mapper/BlackAndWhiteListMapper.xml deleted file mode 100644 index 52a4415a..00000000 --- a/nanopart-server/src/main/resources/mapper/BlackAndWhiteListMapper.xml +++ /dev/null @@ -1,18 +0,0 @@ - - - - - - - \ No newline at end of file