wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-2135: rename elements to precise names

Browse Source
This commit is contained in:
yanglin 2024-04-03 09:05:20 +08:00
parent 89c0f282df
commit 5dbc08a3c4
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/TodoRangeQueryService.java
View File

@ -14,8 +14,8 @@ import cn.axzo.msg.center.message.domain.param.MessageGroupNodeStatisticParam;
import cn.axzo.msg.center.message.service.group.GroupTemplateService;
import cn.axzo.msg.center.message.service.group.NodeWrapper;
import cn.axzo.msg.center.message.service.impl.PendingMessageNewServiceImpl;
import cn.axzo.msg.center.message.service.todo.mybatis.CollectSQLInterceptor;
import cn.axzo.msg.center.message.service.todo.pagequery.PageQuerySort;
import cn.axzo.msg.center.message.service.todo.mybatis.SQLCollectInterceptor;
import cn.axzo.msg.center.message.service.todo.queryanalyze.SimpleAnalyzer;
import cn.axzo.msg.center.service.enums.PendingMessageRoleCategoryEnum;
import cn.axzo.msg.center.service.enums.PendingMessageStateEnum;
@ -163,11 +163,11 @@ public class TodoRangeQueryService {
private AnalysisPage<PendingRecordAdapter> queryAndAnalysis(
Object analyzeItem, Supplier<AnalysisPage<PendingRecordAdapter>> pageQuery) {
if (analyzeItem != null)
SQLCollectInterceptor.enableCollectSQL();
CollectSQLInterceptor.enableCollectSQL();
try {
Ref<String> execSQL = Ref.create();
AnalysisPage<PendingRecordAdapter> result = pageQuery.get();
execSQL.set(SQLCollectInterceptor.getSQL().orElse(null));
execSQL.set(CollectSQLInterceptor.getSQL().orElse(null));
// !! analysis
result.addAnalysis("analyzeItem", analyzeItem);
result.addAnalysis("query", execSQL::get);
@ -178,7 +178,7 @@ public class TodoRangeQueryService {
});
return result;
} finally {
SQLCollectInterceptor.disableCollectSQL();
CollectSQLInterceptor.disableCollectSQL();
}
}

2
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/mybatis/SQLCollectInterceptor.java → inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/mybatis/CollectSQLInterceptor.java
View File

@ -19,7 +19,7 @@ import java.util.Optional;
@Intercepts(value = {
@Signature(type = StatementHandler.class, method = "parameterize", args = {Statement.class})
})
public class SQLCollectInterceptor implements Interceptor {
public class CollectSQLInterceptor implements Interceptor {
private static final ThreadLocal<SQLInfo> LOCAL = new ThreadLocal<>();

4
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/mybatis/SqlInterceptorConfig.java
View File

@ -12,8 +12,8 @@ import org.springframework.context.annotation.Configuration;
public class SqlInterceptorConfig {
@Bean
SQLCollectInterceptor sqlCollectInterceptor() {
return new SQLCollectInterceptor();
CollectSQLInterceptor sqlCollectInterceptor() {
return new CollectSQLInterceptor();
}
@Bean