Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
DiDi
kafka-manager
提交
999a2bd9
K
kafka-manager
项目概览
DiDi
/
kafka-manager
10 个月 前同步成功
通知
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 搜索 >>
提交
999a2bd9
编写于
3月 22, 2021
作者:
Z
zengqiao
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix monitor enable time illegal bug
上级
f6712c24
变更
1
显示空白变更内容
内联
并排
Showing
1 changed file
with
25 addition
and
3 deletion
+25
-3
kafka-manager-extends/kafka-manager-monitor/src/main/java/com/xiaojukeji/kafka/manager/monitor/component/n9e/N9eConverter.java
...eji/kafka/manager/monitor/component/n9e/N9eConverter.java
+25
-3
未找到文件。
kafka-manager-extends/kafka-manager-monitor/src/main/java/com/xiaojukeji/kafka/manager/monitor/component/n9e/N9eConverter.java
浏览文件 @
999a2bd9
...
...
@@ -5,6 +5,8 @@ import com.xiaojukeji.kafka.manager.common.utils.ValidateUtils;
import
com.xiaojukeji.kafka.manager.monitor.common.entry.*
;
import
com.xiaojukeji.kafka.manager.monitor.component.n9e.entry.*
;
import
com.xiaojukeji.kafka.manager.monitor.component.n9e.entry.bizenum.CategoryEnum
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
java.util.*
;
...
...
@@ -13,6 +15,8 @@ import java.util.*;
* @date 20/8/26
*/
public
class
N9eConverter
{
private
static
final
Logger
LOGGER
=
LoggerFactory
.
getLogger
(
N9eConverter
.
class
);
public
static
List
<
N9eMetricSinkPoint
>
convert2N9eMetricSinkPointList
(
String
nid
,
List
<
MetricSinkPoint
>
pointList
)
{
if
(
pointList
==
null
||
pointList
.
isEmpty
())
{
return
new
ArrayList
<>();
...
...
@@ -98,8 +102,8 @@ public class N9eConverter {
n9eStrategy
.
setNotify_user
(
new
ArrayList
<>());
n9eStrategy
.
setCallback
(
strategyAction
.
getCallback
());
n9eStrategy
.
setEnable_stime
(
"00:00"
);
n9eStrategy
.
setEnable_etime
(
"23:59"
);
n9eStrategy
.
setEnable_stime
(
String
.
format
(
"%02d:00"
,
ListUtils
.
string2IntList
(
strategy
.
getPeriodHoursOfDay
()).
stream
().
distinct
().
min
((
e1
,
e2
)
->
e1
.
compareTo
(
e2
)).
get
())
);
n9eStrategy
.
setEnable_etime
(
String
.
format
(
"%02d:59"
,
ListUtils
.
string2IntList
(
strategy
.
getPeriodHoursOfDay
()).
stream
().
distinct
().
max
((
e1
,
e2
)
->
e1
.
compareTo
(
e2
)).
get
())
);
n9eStrategy
.
setEnable_days_of_week
(
ListUtils
.
string2IntList
(
strategy
.
getPeriodDaysOfWeek
()));
n9eStrategy
.
setNeed_upgrade
(
0
);
...
...
@@ -120,6 +124,15 @@ public class N9eConverter {
return
strategyList
;
}
private
static
Integer
getEnableHour
(
String
enableTime
)
{
try
{
return
Integer
.
valueOf
(
enableTime
.
split
(
":"
)[
0
]);
}
catch
(
Exception
e
)
{
LOGGER
.
warn
(
"class=N9eConverter||method=getEnableHour||enableTime={}||errMsg={}"
,
enableTime
,
e
.
getMessage
());
}
return
null
;
}
public
static
Strategy
convert2Strategy
(
N9eStrategy
n9eStrategy
,
Map
<
String
,
NotifyGroup
>
notifyGroupMap
)
{
if
(
n9eStrategy
==
null
)
{
return
null
;
...
...
@@ -137,7 +150,16 @@ public class N9eConverter {
strategy
.
setId
(
n9eStrategy
.
getId
().
longValue
());
strategy
.
setName
(
n9eStrategy
.
getName
());
strategy
.
setPriority
(
n9eStrategy
.
getPriority
());
strategy
.
setPeriodHoursOfDay
(
"0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23"
);
List
<
Integer
>
hourList
=
new
ArrayList
<>();
Integer
startHour
=
N9eConverter
.
getEnableHour
(
n9eStrategy
.
getEnable_stime
());
Integer
endHour
=
N9eConverter
.
getEnableHour
(
n9eStrategy
.
getEnable_etime
());
if
(!(
ValidateUtils
.
isNullOrLessThanZero
(
startHour
)
||
ValidateUtils
.
isNullOrLessThanZero
(
endHour
)
||
endHour
<
startHour
))
{
for
(
Integer
hour
=
startHour
;
hour
<=
endHour
;
++
hour
)
{
hourList
.
add
(
hour
);
}
}
strategy
.
setPeriodHoursOfDay
(
ListUtils
.
intList2String
(
hourList
));
strategy
.
setPeriodDaysOfWeek
(
ListUtils
.
intList2String
(
n9eStrategy
.
getEnable_days_of_week
()));
List
<
StrategyExpression
>
strategyExpressionList
=
new
ArrayList
<>();
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录