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

fix-移除部分未使用的方法

Browse Source
This commit is contained in:
zhangran 2024-04-17 14:33:04 +08:00
parent 18ecc95e39
commit c012ba95ce
3 changed files with 0 additions and 63 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/dao/mapper/BlackAndWhiteListMapper.java
View File

@ -17,15 +17,4 @@ import java.util.List;
@Mapper
public interface BlackAndWhiteListMapper extends BaseMapper<SaasBlackWhiteList> {
/**
* 获取getField中字段的值
*
* @param type
* @param getField 获取json中指定字段
* @param modules
* @return
*/
List<String> getParamValue(@Param("type") Integer type,
@Param("getField") String getField,
@Param("modules") List<String> modules);
}

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

@ -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<? extends BaseEntity<?>> baseEntities){
baseEntities.forEach(baseEntity -> send(mqEventEnum, baseEntity, null));
}
public static void send(MQEventEnum mqEventEnum, String data) {
if(mqEventEnum == null){
throw new ServiceException("无法正确发送mq: mqEventEnum不能为空");

18
nanopart-server/src/main/resources/mapper/BlackAndWhiteListMapper.xml
View File

@ -1,18 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.axzo.nanopart.server.dao.mapper.BlackAndWhiteListMapper">
<select id="getParamValue" resultType="java.lang.String">
SELECT `param` - > '$.#{getField}'
FROM `saas_black_white_list`
WHERE type = #{type}
<if test="modules !=null and modules.size > 0">
AND `module` in
<foreach collection="modules" open="(" close=")" separator="," item="module">
#{module}
</foreach>
</if>
and `is_delete` = 0;
</select>
</mapper>