Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
DiDi
kafka-manager
提交
3e154429
K
kafka-manager
项目概览
DiDi
/
kafka-manager
9 个月 前同步成功
通知
58
Star
6372
Fork
1229
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
K
kafka-manager
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
3e154429
编写于
4月 20, 2021
作者:
Z
zengqiao
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
删除无效代码
上级
a12c3988
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
9 addition
and
53 deletion
+9
-53
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/AuthorityServiceImpl.java
...er/service/service/gateway/impl/AuthorityServiceImpl.java
+8
-10
kafka-manager-extends/kafka-manager-notify/src/main/java/com/xiaojukeji/kafka/manager/notify/OrderApplyNotifyService.java
...ojukeji/kafka/manager/notify/OrderApplyNotifyService.java
+1
-25
kafka-manager-extends/kafka-manager-notify/src/main/java/com/xiaojukeji/kafka/manager/notify/common/NotifyConstant.java
...iaojukeji/kafka/manager/notify/common/NotifyConstant.java
+0
-18
未找到文件。
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/AuthorityServiceImpl.java
浏览文件 @
3e154429
package
com.xiaojukeji.kafka.manager.service.service.gateway.impl
;
package
com.xiaojukeji.kafka.manager.service.service.gateway.impl
;
import
com.alibaba.fastjson.JSONObject
;
import
com.xiaojukeji.kafka.manager.common.bizenum.ModuleEnum
;
import
com.xiaojukeji.kafka.manager.common.bizenum.ModuleEnum
;
import
com.xiaojukeji.kafka.manager.common.bizenum.OperateEnum
;
import
com.xiaojukeji.kafka.manager.common.bizenum.OperateEnum
;
import
com.xiaojukeji.kafka.manager.common.bizenum.OperationStatusEnum
;
import
com.xiaojukeji.kafka.manager.common.bizenum.OperationStatusEnum
;
...
@@ -10,6 +9,7 @@ import com.xiaojukeji.kafka.manager.common.entity.ao.gateway.TopicQuota;
...
@@ -10,6 +9,7 @@ import com.xiaojukeji.kafka.manager.common.entity.ao.gateway.TopicQuota;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.OperateRecordDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.OperateRecordDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.gateway.AuthorityDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.gateway.AuthorityDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.gateway.KafkaAclDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.gateway.KafkaAclDO
;
import
com.xiaojukeji.kafka.manager.common.utils.JsonUtils
;
import
com.xiaojukeji.kafka.manager.common.utils.ValidateUtils
;
import
com.xiaojukeji.kafka.manager.common.utils.ValidateUtils
;
import
com.xiaojukeji.kafka.manager.dao.gateway.AuthorityDao
;
import
com.xiaojukeji.kafka.manager.dao.gateway.AuthorityDao
;
import
com.xiaojukeji.kafka.manager.dao.gateway.KafkaAclDao
;
import
com.xiaojukeji.kafka.manager.dao.gateway.KafkaAclDao
;
...
@@ -119,7 +119,7 @@ public class AuthorityServiceImpl implements AuthorityService {
...
@@ -119,7 +119,7 @@ public class AuthorityServiceImpl implements AuthorityService {
operateRecordDO
.
setModuleId
(
ModuleEnum
.
AUTHORITY
.
getCode
());
operateRecordDO
.
setModuleId
(
ModuleEnum
.
AUTHORITY
.
getCode
());
operateRecordDO
.
setOperateId
(
OperateEnum
.
DELETE
.
getCode
());
operateRecordDO
.
setOperateId
(
OperateEnum
.
DELETE
.
getCode
());
operateRecordDO
.
setResource
(
topicName
);
operateRecordDO
.
setResource
(
topicName
);
operateRecordDO
.
setContent
(
J
SONObject
.
toJSONString
(
content
));
operateRecordDO
.
setContent
(
J
sonUtils
.
toJSONString
(
content
));
operateRecordDO
.
setOperator
(
operator
);
operateRecordDO
.
setOperator
(
operator
);
operateRecordService
.
insert
(
operateRecordDO
);
operateRecordService
.
insert
(
operateRecordDO
);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
...
@@ -149,7 +149,7 @@ public class AuthorityServiceImpl implements AuthorityService {
...
@@ -149,7 +149,7 @@ public class AuthorityServiceImpl implements AuthorityService {
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
LOGGER
.
error
(
"get authority failed, clusterId:{} topicName:{}."
,
clusterId
,
topicName
,
e
);
LOGGER
.
error
(
"get authority failed, clusterId:{} topicName:{}."
,
clusterId
,
topicName
,
e
);
}
}
return
null
;
return
Collections
.
emptyList
()
;
}
}
@Override
@Override
...
@@ -162,14 +162,12 @@ public class AuthorityServiceImpl implements AuthorityService {
...
@@ -162,14 +162,12 @@ public class AuthorityServiceImpl implements AuthorityService {
}
}
if
(
ValidateUtils
.
isEmptyList
(
doList
))
{
if
(
ValidateUtils
.
isEmptyList
(
doList
))
{
return
new
ArrayList
<>();
return
new
ArrayList
<>();
}
else
{
assert
doList
!=
null
;
// 过滤权限列表中access=0的
List
<
AuthorityDO
>
newList
=
doList
.
stream
()
.
filter
(
authorityDO
->
!
TopicAuthorityEnum
.
DENY
.
getCode
().
equals
(
authorityDO
.
getAccess
()))
.
collect
(
Collectors
.
toList
());
return
newList
;
}
}
// 去除掉权限列表中无权限的数据
return
doList
.
stream
()
.
filter
(
authorityDO
->
!
TopicAuthorityEnum
.
DENY
.
getCode
().
equals
(
authorityDO
.
getAccess
()))
.
collect
(
Collectors
.
toList
());
}
}
@Override
@Override
...
...
kafka-manager-extends/kafka-manager-notify/src/main/java/com/xiaojukeji/kafka/manager/notify/OrderApplyNotifyService.java
浏览文件 @
3e154429
package
com.xiaojukeji.kafka.manager.notify
;
package
com.xiaojukeji.kafka.manager.notify
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.account.Account
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.OrderDO
;
import
com.xiaojukeji.kafka.manager.common.events.OrderApplyEvent
;
import
com.xiaojukeji.kafka.manager.common.events.OrderApplyEvent
;
import
com.xiaojukeji.kafka.manager.notify.common.NotifyConstant
;
import
com.xiaojukeji.kafka.manager.notify.notifyer.AbstractNotifyService
;
import
com.xiaojukeji.kafka.manager.notify.common.OrderNotifyTemplate
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.context.ApplicationListener
;
import
org.springframework.context.ApplicationListener
;
import
org.springframework.scheduling.annotation.Async
;
import
org.springframework.scheduling.annotation.Async
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
...
@@ -19,27 +12,10 @@ import org.springframework.stereotype.Service;
...
@@ -19,27 +12,10 @@ import org.springframework.stereotype.Service;
*/
*/
@Service
(
"orderApplyNotifyService"
)
@Service
(
"orderApplyNotifyService"
)
public
class
OrderApplyNotifyService
implements
ApplicationListener
<
OrderApplyEvent
>
{
public
class
OrderApplyNotifyService
implements
ApplicationListener
<
OrderApplyEvent
>
{
@Autowired
private
AbstractNotifyService
notifyService
;
@Value
(
"${notify.order.detail-url}"
)
private
String
orderDetailUrl
;
@Async
@Async
@Override
@Override
public
void
onApplicationEvent
(
OrderApplyEvent
orderApplyEvent
)
{
public
void
onApplicationEvent
(
OrderApplyEvent
orderApplyEvent
)
{
OrderDO
orderDO
=
orderApplyEvent
.
getOrderDO
();
// todo 工单通知
String
detailUrl
=
String
.
format
(
orderDetailUrl
,
orderDO
.
getId
(),
orderApplyEvent
.
getIdc
());
for
(
Account
account
:
NotifyConstant
.
accountList
)
{
notifyService
.
sendMsg
(
account
.
getUsername
(),
OrderNotifyTemplate
.
getNotify2OrderHandlerMessage
(
account
.
getChineseName
(),
orderDO
.
getApplicant
(),
orderDO
.
getTitle
(),
detailUrl
)
);
}
}
}
}
}
\ No newline at end of file
kafka-manager-extends/kafka-manager-notify/src/main/java/com/xiaojukeji/kafka/manager/notify/common/NotifyConstant.java
已删除
100644 → 0
浏览文件 @
a12c3988
package
com.xiaojukeji.kafka.manager.notify.common
;
import
com.xiaojukeji.kafka.manager.common.bizenum.AccountRoleEnum
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.account.Account
;
import
java.util.Arrays
;
import
java.util.List
;
/**
* @author zengqiao
* @date 20/8/27
*/
public
class
NotifyConstant
{
public
static
final
List
<
Account
>
accountList
=
Arrays
.
asList
(
new
Account
(
"xuzhengxi"
,
"徐正熙"
,
""
,
AccountRoleEnum
.
OP
)
);
}
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录