Middleware/cn-data-platform
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

将入库改成多线程添加日志，排查耗时情况

Browse Source
This commit is contained in:
hzj
2026-06-10 09:03:00 +08:00
parent fce3f74da1
commit 5cb4ab0e8f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbPqsCommunicateImpl.java
View File

@@ -121,7 +121,7 @@ public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate {
long end1 = System.currentTimeMillis();
log.info("更新device表：" + (end1 - start) + " ms");
log.info("查询通讯表最新数据：" + (end1 - start) + " ms");
PqsCommunicate pqsCommunicate = new PqsCommunicate();
pqsCommunicate.setTime(LocalDateTime.parse(pqsCommunicateDto.getTime(), DATE_TIME_FORMATTER).atZone(ZoneId.systemDefault()).toInstant());
pqsCommunicate.setDevId(pqsCommunicateDto.getDevId());
@@ -133,7 +133,7 @@ public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate {
}
long end2 = System.currentTimeMillis();
log.info("更新device表：" + (end2 - end1) + " ms");
log.info("更新通讯表最新数据：" + (end2 - end1) + " ms");
//更新mysql数据
DevComFlagDTO devComFlagDTO = new DevComFlagDTO();