Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
kt-keystone
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
Matrix
kt-keystone
Commits
d5b40a4e
提交
d5b40a4e
authored
3月 17, 2022
作者:
Matrix
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
feat(日志): 修正了日志的时间输出格式
上级
b1c96b9c
隐藏空白字符变更
内嵌
并排
正在显示
4 个修改的文件
包含
14 行增加
和
4 行删除
+14
-4
Actuator.java
kt-base/src/main/java/org/matrix/actuators/Actuator.java
+2
-1
MoveActuator.java
...src/main/java/org/matrix/actuators/move/MoveActuator.java
+1
-1
SqlExpActuator.java
...rc/main/java/org/matrix/actuators/sql/SqlExpActuator.java
+4
-2
LogMessage.java
...ase/src/main/java/org/matrix/socket/queue/LogMessage.java
+7
-0
没有找到文件。
kt-base/src/main/java/org/matrix/actuators/Actuator.java
浏览文件 @
d5b40a4e
...
@@ -9,4 +9,4 @@ package org.matrix.actuators;
...
@@ -9,4 +9,4 @@ package org.matrix.actuators;
*/
*/
public
interface
Actuator
{
public
interface
Actuator
{
}
}
\ No newline at end of file
kt-base/src/main/java/org/matrix/actuators/move/MoveActuator.java
浏览文件 @
d5b40a4e
...
@@ -177,7 +177,7 @@ public class MoveActuator implements Actuator {
...
@@ -177,7 +177,7 @@ public class MoveActuator implements Actuator {
Map
<
String
,
List
<
Map
<
String
,
Object
>>>
res
=
resSet
.
get
();
Map
<
String
,
List
<
Map
<
String
,
Object
>>>
res
=
resSet
.
get
();
// 分类处理 + 结果集处理(如果不存在则put数据,如果存在则替换数据)
// 分类处理 + 结果集处理(如果不存在则put数据,如果存在则替换数据)
LogQueueRuntime
.
addNewLog
(
this
.
getClass
(),
MOVE_ACTUATOR
,
String
.
format
(
"正在执行动作 actionId = %d,动作类型 = %s
Ω
,动作策略 = %s,动作参数 = %s"
,
action
.
getId
(),
action
,
strategy
,
runtimeDetail
));
LogQueueRuntime
.
addNewLog
(
this
.
getClass
(),
MOVE_ACTUATOR
,
String
.
format
(
"正在执行动作 actionId = %d,动作类型 = %s,动作策略 = %s,动作参数 = %s"
,
action
.
getId
(),
action
,
strategy
,
runtimeDetail
));
if
(
actionType
==
SQL_ACTION
)
{
if
(
actionType
==
SQL_ACTION
)
{
List
<
Map
<
String
,
Object
>>
resultMap
=
sqlActionHandler
(
envId
,
projectId
,
runtimeDetail
);
List
<
Map
<
String
,
Object
>>
resultMap
=
sqlActionHandler
(
envId
,
projectId
,
runtimeDetail
);
res
.
put
(
key
,
resultMap
);
res
.
put
(
key
,
resultMap
);
...
...
kt-base/src/main/java/org/matrix/actuators/sql/SqlExpActuator.java
浏览文件 @
d5b40a4e
...
@@ -154,7 +154,9 @@ public class SqlExpActuator implements Actuator {
...
@@ -154,7 +154,9 @@ public class SqlExpActuator implements Actuator {
*/
*/
private
String
parseVar
(
Long
envId
,
Integer
takenIndex
,
Long
projectId
,
DynamicVariable
dynamicVar
)
{
private
String
parseVar
(
Long
envId
,
Integer
takenIndex
,
Long
projectId
,
DynamicVariable
dynamicVar
)
{
DynamicVarType
varType
=
dynamicVar
.
getType
();
DynamicVarType
varType
=
dynamicVar
.
getType
();
LogQueueRuntime
.
addNewLog
(
this
.
getClass
(),
SQL_ACTUATOR
,
"当前解析的动态变量是: "
+
JSON
.
toJSONString
(
dynamicVar
));
LogQueueRuntime
.
addNewLog
(
this
.
getClass
(),
SQL_ACTUATOR
,
String
.
format
(
"当前解析的动态变量名 = %s , 变量详情 = %s , 变量类型 = %s , takenField = %s , 备注 = %s"
,
dynamicVar
.
getName
(),
dynamicVar
.
getDetail
(),
dynamicVar
.
getType
().
getDes
(),
dynamicVar
.
getTakenField
(),
dynamicVar
.
getRemark
()));
// 依据变量类型的不同调用不同的Handler
// 依据变量类型的不同调用不同的Handler
if
(
varType
==
CONSTANT_VARIABLE
)
{
if
(
varType
==
CONSTANT_VARIABLE
)
{
return
dynamicVar
.
getDetail
();
return
dynamicVar
.
getDetail
();
...
@@ -271,7 +273,7 @@ public class SqlExpActuator implements Actuator {
...
@@ -271,7 +273,7 @@ public class SqlExpActuator implements Actuator {
// 校验dynamicVar里的detail是否是可以直接执行的SQL
// 校验dynamicVar里的detail是否是可以直接执行的SQL
if
(
dynamicVar
.
getType
()
==
SQL_VARIABLE
&&
findDynamicVarList
(
sqlExp
).
size
()
==
0
)
{
if
(
dynamicVar
.
getType
()
==
SQL_VARIABLE
&&
findDynamicVarList
(
sqlExp
).
size
()
==
0
)
{
// 切换数据源,执行SQL,获取数值
// 切换数据源,执行SQL,获取数值
LogQueueRuntime
.
addNewLog
(
this
.
getClass
(),
SQL_ACTUATOR
,
String
.
format
(
"当前执行的SQL语句: %s, 使用的数据源: %s"
,
sqlExp
,
dataSourceDTO
));
LogQueueRuntime
.
addNewLog
(
this
.
getClass
(),
SQL_ACTUATOR
,
String
.
format
(
"当前执行的SQL语句: %s, 使用的数据源: %s"
,
sqlExp
,
dataSourceDTO
));
Set
<
String
>
dataSources
=
dataSourceService
.
switchDataSource
(
dataSourceDTO
);
Set
<
String
>
dataSources
=
dataSourceService
.
switchDataSource
(
dataSourceDTO
);
log
.
info
(
"当前存在的数据源 {}"
,
dataSources
);
log
.
info
(
"当前存在的数据源 {}"
,
dataSources
);
List
<
Map
<
String
,
Object
>>
resultMap
=
jdbcTemplate
.
queryForList
(
sqlExp
);
List
<
Map
<
String
,
Object
>>
resultMap
=
jdbcTemplate
.
queryForList
(
sqlExp
);
...
...
kt-base/src/main/java/org/matrix/socket/queue/LogMessage.java
浏览文件 @
d5b40a4e
...
@@ -7,6 +7,7 @@ import lombok.NoArgsConstructor;
...
@@ -7,6 +7,7 @@ import lombok.NoArgsConstructor;
import
org.matrix.enums.ModuleType
;
import
org.matrix.enums.ModuleType
;
import
java.time.LocalDateTime
;
import
java.time.LocalDateTime
;
import
java.time.format.DateTimeFormatter
;
/**
/**
* LogMessage. 日志的消息对象 封装了一些通用属性和消息
* LogMessage. 日志的消息对象 封装了一些通用属性和消息
...
@@ -20,6 +21,7 @@ import java.time.LocalDateTime;
...
@@ -20,6 +21,7 @@ import java.time.LocalDateTime;
@NoArgsConstructor
@NoArgsConstructor
public
class
LogMessage
{
public
class
LogMessage
{
@JSONField
(
serialize
=
false
)
private
LocalDateTime
logTime
;
private
LocalDateTime
logTime
;
@JSONField
(
serialize
=
false
)
@JSONField
(
serialize
=
false
)
...
@@ -36,4 +38,9 @@ public class LogMessage {
...
@@ -36,4 +38,9 @@ public class LogMessage {
public
String
getModuleType
()
{
public
String
getModuleType
()
{
return
moduleType
.
getName
();
return
moduleType
.
getName
();
}
}
@JSONField
(
name
=
"logTime"
)
public
String
getFormatTime
(){
return
logTime
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
));
}
}
}
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论