test-version22
/
MeterSphere
mirror of https://gitee.com/fit2cloud-feizhiyun/MeterSphere.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor(性能测试): socket中报告状态判断

This commit is contained in:
Captain.B 2021-05-25 15:29:22 +08:00 committed by 刘瑞斌
parent 17e5e37b5c
commit 9e3effefb3
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/main/java/io/metersphere/websocket/ReportWebSocket.java
View File

@ -3,8 +3,8 @@ package io.metersphere.websocket;
import io.metersphere.base.domain.LoadTestReportWithBLOBs; import io.metersphere.base.domain.LoadTestReportWithBLOBs;
import io.metersphere.commons.constants.PerformanceTestStatus; import io.metersphere.commons.constants.PerformanceTestStatus;
import io.metersphere.commons.utils.LogUtil; import io.metersphere.commons.utils.LogUtil;
import io.metersphere.performance.service.PerformanceTestService;
import io.metersphere.performance.service.PerformanceReportService; import io.metersphere.performance.service.PerformanceReportService;
import io.metersphere.performance.service.PerformanceTestService;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -112,7 +112,11 @@ public class ReportWebSocket {
if (!session.isOpen()) { if (!session.isOpen()) {
return; return;
} }
if (StringUtils.equalsAny(report.getStatus(), PerformanceTestStatus.Running.name(), PerformanceTestStatus.Reporting.name())) { if (StringUtils.equalsAny(report.getStatus(),
PerformanceTestStatus.Starting.name(),
PerformanceTestStatus.Running.name(),
PerformanceTestStatus.Reporting.name())
) {
session.getBasicRemote().sendText("refresh-" + Math.random()); session.getBasicRemote().sendText("refresh-" + Math.random());
} }
} catch (Exception e) { } catch (Exception e) {