ClientApps/CN_Gather
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

处理暂降持续时间

Browse Source
This commit is contained in:
chendaofei
2025-07-14 15:39:55 +08:00
parent cb4d8d502a
commit 6e4bbfc383
3 changed files with 62 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
event_smart/src/main/java/com/njcn/gather/event/transientes/handler/SqlExecuteTimeInterceptor.java Normal file
View File

@@ -0,0 +1,57 @@
//package com.njcn.gather.event.transientes.handler;
//
//import org.apache.ibatis.executor.statement.StatementHandler;
//import org.apache.ibatis.plugin.*;
//import org.apache.ibatis.session.ResultHandler;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.stereotype.Component;
//
//import java.sql.Statement;
//import java.util.Properties;
//
///**
// * @Author: cdf
// * @CreateTime: 2025-07-14
// * @Description:
// */
//@Intercepts({
// @Signature(type = StatementHandler.class, method = "query", args = {Statement.class, ResultHandler.class}),
// @Signature(type = StatementHandler.class, method = "update", args = {Statement.class}),
// @Signature(type = StatementHandler.class, method = "batch", args = {Statement.class})
//})
//@Component
//public class SqlExecuteTimeInterceptor implements Interceptor {
// private static final Logger logger = LoggerFactory.getLogger(SqlExecuteTimeInterceptor.class);
//
// @Override
// public Object intercept(Invocation invocation) throws Throwable {
// long startTime = System.currentTimeMillis();
// try {
// return invocation.proceed();
// } finally {
// long endTime = System.currentTimeMillis();
// long executeTime = endTime - startTime;
//
// // 获取 SQL 语句
// StatementHandler statementHandler = (StatementHandler) invocation.getTarget();
// String sql = statementHandler.getBoundSql().getSql();
//
// // 打印执行时间和 SQL
// logger.info("SQL 执行时间: {}ms, SQL: {}", executeTime, sql);
// }
// }
//
// @Override
// public Object plugin(Object target) {
// if (target instanceof StatementHandler) {
// return Plugin.wrap(target, this);
// }
// return target;
// }
//
// @Override
// public void setProperties(Properties properties) {
// // 可配置参数
// }
//}

11
event_smart/src/main/java/com/njcn/gather/event/transientes/service/impl/LargeScreenCountServiceImpl.java
View File

@@ -2,10 +2,7 @@ package com.njcn.gather.event.transientes.service.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.date.LocalDateTimeUtil;
import cn.hutool.core.date.*;
import cn.hutool.core.util.IdUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -414,7 +411,7 @@ public class LargeScreenCountServiceImpl implements LargeScreenCountService {
eventDetailVO.setTimeid(temp.getTimeid());
eventDetailVO.setMs(temp.getMs());
eventDetailVO.setWavetype(temp.getWavetype().toString());
eventDetailVO.setPersisttime(temp.getPersisttime().toString());
eventDetailVO.setPersisttime(String.valueOf(temp.getPersisttime()/1000));
eventDetailVO.setEventvalue(temp.getEventvalue());
eventDetailVO.setLookFlag(temp.getLookFlag());
eventDetailVO.setNoticeFlag(temp.getNoticeFlag());
@@ -506,7 +503,7 @@ public class LargeScreenCountServiceImpl implements LargeScreenCountService {
eventDetailVO.setTimeid(it.getTimeid());
eventDetailVO.setMs(it.getMs());
eventDetailVO.setWavetype(it.getWavetype().toString());
eventDetailVO.setPersisttime(it.getPersisttime().toString());
eventDetailVO.setPersisttime(String.valueOf(it.getPersisttime()/1000));
eventDetailVO.setEventvalue(it.getEventvalue());
if (ledgerBaseInfoDTOMap.containsKey(it.getLineid())) {
LedgerBaseInfoDTO ledgerBaseInfoDTO = ledgerBaseInfoDTOMap.get(it.getLineid());
@@ -883,7 +880,7 @@ public class LargeScreenCountServiceImpl implements LargeScreenCountService {
eventDetailVO.setTimeid(temp.getTimeid());
eventDetailVO.setMs(temp.getMs());
eventDetailVO.setWavetype(temp.getWavetype().toString());
eventDetailVO.setPersisttime(temp.getPersisttime().toString());
eventDetailVO.setPersisttime(String.valueOf(temp.getPersisttime()/1000));
eventDetailVO.setEventvalue(temp.getEventvalue());
eventDetailVO.setLookFlag(temp.getLookFlag());
eventDetailVO.setNoticeFlag(temp.getNoticeFlag());

2
event_smart/src/main/java/com/njcn/gather/event/transientes/websocket/WebSocketServer.java
View File

@@ -74,7 +74,7 @@ public class WebSocketServer {
if (executor != null) {
executor.shutdownNow();
}
System.out.println("用户 " + userId + " 已断开连接，状态码: " + closeReason.getReasonPhrase());
System.out.println("用户 " + userId + " 已断开连接，状态码: " + closeReason.getCloseCode());
}
@OnError