Skip to content

D
data-streaming

MeterSphere / data-streaming
9 个月 前同步成功

通知 12
Star 0
Fork 0
D
data-streaming

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 c87c7b1e 编写于 作者: C CaptainB
浏览文件
操作

refactor: 实时报告计算优化

上级 73bdf6ef
隐藏空白更改
内联 并排
Showing with 11 addition and 6 deletion
src/main/java/io/metersphere/streaming/report/realtime/RequestStatisticsSummaryRealtime.java
浏览文件 @ c87c7b1e
......@@ -86,9 +86,11 @@ public class RequestStatisticsSummaryRealtime extends AbstractSummaryRealtime<Li
realtimeInfo.set(reportTimeInfo.getDuration());
reportContent.forEach(statistics -> {
statistics.setTransactions(format.format(new BigDecimal(statistics.getTransactions()).multiply(BigDecimal.valueOf(realtimeInfo.get()))));
statistics.setReceived(format.format(new BigDecimal(statistics.getReceived()).multiply(BigDecimal.valueOf(realtimeInfo.get()))));
statistics.setSent(format.format(new BigDecimal(statistics.getSent()).multiply(BigDecimal.valueOf(realtimeInfo.get()))));
if (realtimeInfo.get() > 0) {
statistics.setTransactions(format.format(new BigDecimal(statistics.getTransactions()).multiply(BigDecimal.valueOf(realtimeInfo.get()))));
statistics.setReceived(format.format(new BigDecimal(statistics.getReceived()).multiply(BigDecimal.valueOf(realtimeInfo.get()))));
statistics.setSent(format.format(new BigDecimal(statistics.getSent()).multiply(BigDecimal.valueOf(realtimeInfo.get()))));
}
});
// 保存顺序
......@@ -100,9 +102,12 @@ public class RequestStatisticsSummaryRealtime extends AbstractSummaryRealtime<Li
}
finalResult.forEach(statistics -> {
statistics.setTransactions(format.format(new BigDecimal(statistics.getTransactions()).multiply(BigDecimal.valueOf(timeInfo.get().getDuration()))));
statistics.setReceived(format.format(new BigDecimal(statistics.getReceived()).multiply(BigDecimal.valueOf(timeInfo.get().getDuration()))));
statistics.setSent(format.format(new BigDecimal(statistics.getSent()).multiply(BigDecimal.valueOf(timeInfo.get().getDuration()))));
long duration = timeInfo.get().getDuration();
if (duration > 0) {
statistics.setTransactions(format.format(new BigDecimal(statistics.getTransactions()).multiply(BigDecimal.valueOf(duration))));
statistics.setReceived(format.format(new BigDecimal(statistics.getReceived()).multiply(BigDecimal.valueOf(duration))));
statistics.setSent(format.format(new BigDecimal(statistics.getSent()).multiply(BigDecimal.valueOf(duration))));
}
});
// 第二遍以后
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或