mirror of
https://gitee.com/fit2cloud-feizhiyun/MeterSphere.git
synced 2024-12-04 13:09:28 +08:00
Merge remote-tracking branch 'origin/dev' into dev
This commit is contained in:
W23123
commit
a62eaa55e0
@ -153,6 +153,12 @@
|
||||
<version>2.9</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>com.opencsv</groupId>
|
||||
<artifactId>opencsv</artifactId>
|
||||
<version>5.1</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.httpcomponents</groupId>
|
||||
<artifactId>httpclient</artifactId>
|
||||
|
||||
@ -0,0 +1,22 @@
|
||||
package io.metersphere.commons.constants;
|
||||
|
||||
public enum JmeterReportType {
|
||||
AggregateReport,
|
||||
SynthesisReport,
|
||||
ThreadsStateOverTime,
|
||||
BytesThroughputOverTime,
|
||||
HitsPerSecond,
|
||||
LatenciesOverTime,
|
||||
PerfMon,
|
||||
DbMon,
|
||||
JMXMon,
|
||||
ResponseCodesPerSecond,
|
||||
ResponseTimesDistribution,
|
||||
ResponseTimesOverTime,
|
||||
ResponseTimesPercentiles,
|
||||
ThroughputVsThreads,
|
||||
TimesVsThreads,
|
||||
TransactionsPerSecond,
|
||||
PageDataExtractorOverTime,
|
||||
MergeResults,
|
||||
}
|
||||
@ -1,18 +0,0 @@
|
||||
package io.metersphere.config;
|
||||
|
||||
import io.metersphere.proxy.ProxyServlet;
|
||||
import org.springframework.boot.web.servlet.ServletRegistrationBean;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
@Configuration
|
||||
public class ProxyServletConfiguration {
|
||||
|
||||
@Bean
|
||||
public ServletRegistrationBean servletRegistrationBean(){
|
||||
//代理到hub节点获取录像
|
||||
ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new ProxyServlet(), "/proxy/*");
|
||||
return servletRegistrationBean;
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package io.metersphere.config;
|
||||
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
|
||||
import org.springframework.web.client.RestTemplate;
|
||||
|
||||
@Configuration
|
||||
public class RestTemplateConfig {
|
||||
|
||||
@Bean
|
||||
public RestTemplate getRestTemplate() {
|
||||
HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory();
|
||||
httpRequestFactory.setConnectionRequestTimeout(3000);
|
||||
httpRequestFactory.setConnectTimeout(3000);
|
||||
httpRequestFactory.setReadTimeout(3000);
|
||||
return new RestTemplate(httpRequestFactory);
|
||||
}
|
||||
|
||||
}
|
||||
@ -51,10 +51,4 @@ public class FunctionalReportController {
|
||||
return functionalReportService.getReportTestAndProInfo(reportId);
|
||||
}
|
||||
|
||||
@GetMapping("/test/log/{reportId}")
|
||||
public FucTestLog getTestLog(@PathVariable String reportId) {
|
||||
return functionalReportService.getTestLog(reportId);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
@ -1,25 +0,0 @@
|
||||
package io.metersphere.job;
|
||||
|
||||
import io.metersphere.commons.utils.LogUtil;
|
||||
import io.metersphere.service.ZaleniumService;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.scheduling.annotation.EnableScheduling;
|
||||
import org.springframework.scheduling.annotation.Scheduled;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
|
||||
@Configuration
|
||||
@EnableScheduling
|
||||
public class ZaleniumJob {
|
||||
|
||||
|
||||
@Resource
|
||||
ZaleniumService zaleniumService;
|
||||
|
||||
@Scheduled(cron = "0 0/1 * * * ?")
|
||||
public void syncFucTestReport(){
|
||||
LogUtil.info("============= start sync FucTestReport =============");
|
||||
zaleniumService.syncTestResult();
|
||||
LogUtil.info("============= end sync FucTestReport =============");
|
||||
}
|
||||
}
|
||||
@ -1,382 +0,0 @@
|
||||
package io.metersphere.proxy;
|
||||
|
||||
import io.metersphere.commons.utils.LogUtil;
|
||||
import org.apache.http.*;
|
||||
import org.apache.http.client.HttpClient;
|
||||
import org.apache.http.client.config.CookieSpecs;
|
||||
import org.apache.http.client.config.RequestConfig;
|
||||
import org.apache.http.client.methods.AbortableHttpRequest;
|
||||
import org.apache.http.entity.InputStreamEntity;
|
||||
import org.apache.http.impl.client.HttpClientBuilder;
|
||||
import org.apache.http.message.BasicHeader;
|
||||
import org.apache.http.message.BasicHttpEntityEnclosingRequest;
|
||||
import org.apache.http.message.BasicHttpRequest;
|
||||
import org.apache.http.message.HeaderGroup;
|
||||
import org.apache.http.util.EntityUtils;
|
||||
|
||||
import javax.servlet.ServletException;
|
||||
import javax.servlet.http.Cookie;
|
||||
import javax.servlet.http.HttpServlet;
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
import java.io.Closeable;
|
||||
import java.io.IOException;
|
||||
import java.io.OutputStream;
|
||||
import java.net.HttpCookie;
|
||||
import java.net.URI;
|
||||
import java.net.URISyntaxException;
|
||||
import java.util.Enumeration;
|
||||
|
||||
/**
|
||||
* Http代理
|
||||
* 获取 zalenium 录像等资源
|
||||
*/
|
||||
public class ProxyServlet extends HttpServlet {
|
||||
|
||||
public static final String PRESERVEHOST = "preserveHost";
|
||||
|
||||
public static final String PRESERVECOOKIES = "preserveCookies";
|
||||
|
||||
public static final String HANDLEREDIRECTS = "http.protocol.handle-redirects";
|
||||
|
||||
public static final String CONNECTTIMEOUT = "http.socket.timeout";
|
||||
|
||||
public static final String READTIMEOUT = "http.read.timeout";
|
||||
|
||||
public static final String USESYSTEMPROPERTIES = "useSystemProperties";
|
||||
|
||||
public static final String FORWARDEDFOR = "forwardip";
|
||||
|
||||
protected boolean doPreserveHost = false;
|
||||
protected boolean doForwardIP = true;
|
||||
protected boolean doPreserveCookies = false;
|
||||
protected boolean doHandleRedirects = false;
|
||||
protected boolean useSystemProperties = false;
|
||||
protected int connectTimeout = -1;
|
||||
protected int readTimeout = -1;
|
||||
|
||||
|
||||
protected String targetUri;
|
||||
protected URI targetUriObj;
|
||||
protected HttpHost targetHost;
|
||||
|
||||
private HttpClient proxyClient;
|
||||
|
||||
|
||||
protected String getConfigParam(String key) {
|
||||
return getServletConfig().getInitParameter(key);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void init() {
|
||||
|
||||
String doForwardIPString = getConfigParam(FORWARDEDFOR);
|
||||
if (doForwardIPString != null) {
|
||||
this.doForwardIP = Boolean.parseBoolean(doForwardIPString);
|
||||
}
|
||||
|
||||
String preserveHostString = getConfigParam(PRESERVEHOST);
|
||||
if (preserveHostString != null) {
|
||||
this.doPreserveHost = Boolean.parseBoolean(preserveHostString);
|
||||
}
|
||||
|
||||
String preserveCookiesString = getConfigParam(PRESERVECOOKIES);
|
||||
if (preserveCookiesString != null) {
|
||||
this.doPreserveCookies = Boolean.parseBoolean(preserveCookiesString);
|
||||
}
|
||||
|
||||
String handleRedirectsString = getConfigParam(HANDLEREDIRECTS);
|
||||
if (handleRedirectsString != null) {
|
||||
this.doHandleRedirects = Boolean.parseBoolean(handleRedirectsString);
|
||||
}
|
||||
|
||||
String connectTimeoutString = getConfigParam(CONNECTTIMEOUT);
|
||||
if (connectTimeoutString != null) {
|
||||
this.connectTimeout = Integer.parseInt(connectTimeoutString);
|
||||
}
|
||||
|
||||
String readTimeoutString = getConfigParam(READTIMEOUT);
|
||||
if (readTimeoutString != null) {
|
||||
this.readTimeout = Integer.parseInt(readTimeoutString);
|
||||
}
|
||||
|
||||
String useSystemPropertiesString = getConfigParam(USESYSTEMPROPERTIES);
|
||||
if (useSystemPropertiesString != null) {
|
||||
this.useSystemProperties = Boolean.parseBoolean(useSystemPropertiesString);
|
||||
}
|
||||
proxyClient = createHttpClient(buildRequestConfig());
|
||||
}
|
||||
|
||||
protected RequestConfig buildRequestConfig() {
|
||||
return RequestConfig.custom()
|
||||
.setRedirectsEnabled(doHandleRedirects)
|
||||
.setCookieSpec(CookieSpecs.IGNORE_COOKIES)
|
||||
.setConnectTimeout(connectTimeout)
|
||||
.setSocketTimeout(readTimeout)
|
||||
.build();
|
||||
}
|
||||
|
||||
protected HttpClient createHttpClient(final RequestConfig requestConfig) {
|
||||
HttpClientBuilder clientBuilder = HttpClientBuilder.create().setDefaultRequestConfig(requestConfig);
|
||||
if (useSystemProperties){
|
||||
clientBuilder = clientBuilder.useSystemProperties();
|
||||
}
|
||||
return clientBuilder.build();
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public void destroy() {
|
||||
if (proxyClient instanceof Closeable) {
|
||||
try {
|
||||
((Closeable) proxyClient).close();
|
||||
} catch (IOException e) {
|
||||
LogUtil.error(e.getMessage(),e);
|
||||
}
|
||||
} else {
|
||||
if (proxyClient != null){
|
||||
proxyClient.getConnectionManager().shutdown();
|
||||
}
|
||||
}
|
||||
super.destroy();
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void service(HttpServletRequest request, HttpServletResponse servletResponse)
|
||||
throws ServletException, IOException {
|
||||
|
||||
String method = request.getMethod();
|
||||
|
||||
String targetUri = getTargetUri(request);
|
||||
|
||||
HttpRequest targetRequest;
|
||||
if (request.getHeader(HttpHeaders.CONTENT_LENGTH) != null ||
|
||||
request.getHeader(HttpHeaders.TRANSFER_ENCODING) != null) {
|
||||
targetRequest = getTargetRequestWithEntity(method, targetUri, request);
|
||||
} else {
|
||||
targetRequest = new BasicHttpRequest(method, targetUri);
|
||||
}
|
||||
|
||||
copyRequestHeaders(request, targetRequest);
|
||||
|
||||
setXForwardedForHeader(request, targetRequest);
|
||||
|
||||
HttpResponse proxyResponse = null;
|
||||
try {
|
||||
proxyResponse = proxyClient.execute(targetHost, targetRequest);;
|
||||
int statusCode = proxyResponse.getStatusLine().getStatusCode();
|
||||
servletResponse.setStatus(statusCode, proxyResponse.getStatusLine().getReasonPhrase());
|
||||
copyResponseHeaders(proxyResponse, request, servletResponse);
|
||||
|
||||
if (statusCode == HttpServletResponse.SC_NOT_MODIFIED) {
|
||||
servletResponse.setIntHeader(HttpHeaders.CONTENT_LENGTH, 0);
|
||||
} else {
|
||||
copyResponseEntity(proxyResponse, servletResponse);
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
handleRequestException(targetRequest, e);
|
||||
} finally {
|
||||
if (proxyResponse != null){
|
||||
EntityUtils.consumeQuietly(proxyResponse.getEntity());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
protected void handleRequestException(HttpRequest proxyRequest, Exception e) {
|
||||
if (proxyRequest instanceof AbortableHttpRequest) {
|
||||
AbortableHttpRequest abortableHttpRequest = (AbortableHttpRequest) proxyRequest;
|
||||
abortableHttpRequest.abort();
|
||||
}
|
||||
throw new RuntimeException(e.getMessage(), e);
|
||||
}
|
||||
|
||||
protected HttpRequest getTargetRequestWithEntity(String method, String zaleniumUri,
|
||||
HttpServletRequest servletRequest) throws IOException {
|
||||
HttpEntityEnclosingRequest targetRequest = new BasicHttpEntityEnclosingRequest(method, zaleniumUri);
|
||||
targetRequest.setEntity(new InputStreamEntity(servletRequest.getInputStream(),
|
||||
getContentLength(servletRequest)));
|
||||
return targetRequest;
|
||||
}
|
||||
|
||||
private long getContentLength(HttpServletRequest request) {
|
||||
String contentLengthHeader = request.getHeader("Content-Length");
|
||||
if (contentLengthHeader != null) {
|
||||
return Long.parseLong(contentLengthHeader);
|
||||
}
|
||||
return -1L;
|
||||
}
|
||||
|
||||
|
||||
protected static final HeaderGroup hopByHopHeaders;
|
||||
static {
|
||||
hopByHopHeaders = new HeaderGroup();
|
||||
String[] headers = new String[] {
|
||||
"Connection", "Keep-Alive", "Proxy-Authenticate", "Proxy-Authorization",
|
||||
"TE", "Trailers", "Transfer-Encoding", "Upgrade" };
|
||||
for (String header : headers) {
|
||||
hopByHopHeaders.addHeader(new BasicHeader(header, null));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
protected void copyRequestHeaders(HttpServletRequest servletRequest, HttpRequest proxyRequest) {
|
||||
Enumeration<String> enumerationOfHeaderNames = servletRequest.getHeaderNames();
|
||||
while (enumerationOfHeaderNames.hasMoreElements()) {
|
||||
String headerName = enumerationOfHeaderNames.nextElement();
|
||||
copyRequestHeader(servletRequest, proxyRequest, headerName);
|
||||
}
|
||||
}
|
||||
|
||||
protected void copyRequestHeader(HttpServletRequest servletRequest, HttpRequest proxyRequest,
|
||||
String headerName) {
|
||||
if (headerName.equalsIgnoreCase(HttpHeaders.CONTENT_LENGTH)){
|
||||
return;
|
||||
}
|
||||
if (hopByHopHeaders.containsHeader(headerName)){
|
||||
return;
|
||||
}
|
||||
|
||||
Enumeration<String> headers = servletRequest.getHeaders(headerName);
|
||||
while (headers.hasMoreElements()) {
|
||||
String headerValue = headers.nextElement();
|
||||
if (!doPreserveHost && headerName.equalsIgnoreCase(HttpHeaders.HOST)) {
|
||||
HttpHost host = targetHost;
|
||||
headerValue = host.getHostName();
|
||||
if (host.getPort() != -1){
|
||||
headerValue += ":"+host.getPort();
|
||||
}
|
||||
} else if (!doPreserveCookies && headerName.equalsIgnoreCase(org.apache.http.cookie.SM.COOKIE)) {
|
||||
headerValue = getRealCookie(headerValue);
|
||||
}
|
||||
proxyRequest.addHeader(headerName, headerValue);
|
||||
}
|
||||
}
|
||||
|
||||
private void setXForwardedForHeader(HttpServletRequest servletRequest,
|
||||
HttpRequest proxyRequest) {
|
||||
if (doForwardIP) {
|
||||
String forHeaderName = "X-Forwarded-For";
|
||||
String forHeader = servletRequest.getRemoteAddr();
|
||||
String existingForHeader = servletRequest.getHeader(forHeaderName);
|
||||
if (existingForHeader != null) {
|
||||
forHeader = existingForHeader + ", " + forHeader;
|
||||
}
|
||||
proxyRequest.setHeader(forHeaderName, forHeader);
|
||||
|
||||
String protoHeaderName = "X-Forwarded-Proto";
|
||||
String protoHeader = servletRequest.getScheme();
|
||||
proxyRequest.setHeader(protoHeaderName, protoHeader);
|
||||
}
|
||||
}
|
||||
|
||||
protected void copyResponseHeaders(HttpResponse proxyResponse, HttpServletRequest servletRequest,
|
||||
HttpServletResponse servletResponse) {
|
||||
for (Header header : proxyResponse.getAllHeaders()) {
|
||||
copyResponseHeader(servletRequest, servletResponse, header);
|
||||
}
|
||||
}
|
||||
|
||||
protected void copyResponseHeader(HttpServletRequest servletRequest,
|
||||
HttpServletResponse servletResponse, Header header) {
|
||||
String headerName = header.getName();
|
||||
if (hopByHopHeaders.containsHeader(headerName)){
|
||||
return;
|
||||
}
|
||||
String headerValue = header.getValue();
|
||||
if (headerName.equalsIgnoreCase(org.apache.http.cookie.SM.SET_COOKIE) ||
|
||||
headerName.equalsIgnoreCase(org.apache.http.cookie.SM.SET_COOKIE2)) {
|
||||
copyProxyCookie(servletRequest, servletResponse, headerValue);
|
||||
} else if (headerName.equalsIgnoreCase(HttpHeaders.LOCATION)) {
|
||||
servletResponse.addHeader(headerName, rewriteUrlFromResponse(servletRequest, headerValue));
|
||||
} else {
|
||||
servletResponse.addHeader(headerName, headerValue);
|
||||
}
|
||||
}
|
||||
|
||||
protected void copyProxyCookie(HttpServletRequest servletRequest,
|
||||
HttpServletResponse servletResponse, String headerValue) {
|
||||
String path = servletRequest.getContextPath();
|
||||
path += servletRequest.getServletPath();
|
||||
if(path.isEmpty()){
|
||||
path = "/";
|
||||
}
|
||||
|
||||
for (HttpCookie cookie : HttpCookie.parse(headerValue)) {
|
||||
String proxyCookieName = doPreserveCookies ? cookie.getName() : getCookieNamePrefix(cookie.getName()) + cookie.getName();
|
||||
Cookie servletCookie = new Cookie(proxyCookieName, cookie.getValue());
|
||||
servletCookie.setComment(cookie.getComment());
|
||||
servletCookie.setMaxAge((int) cookie.getMaxAge());
|
||||
servletCookie.setPath(path);
|
||||
servletCookie.setSecure(cookie.getSecure());
|
||||
servletCookie.setVersion(cookie.getVersion());
|
||||
servletResponse.addCookie(servletCookie);
|
||||
}
|
||||
}
|
||||
|
||||
protected String getRealCookie(String cookieValue) {
|
||||
StringBuilder escapedCookie = new StringBuilder();
|
||||
String cookies[] = cookieValue.split("[;,]");
|
||||
for (String cookie : cookies) {
|
||||
String cookieSplit[] = cookie.split("=");
|
||||
if (cookieSplit.length == 2) {
|
||||
String cookieName = cookieSplit[0].trim();
|
||||
if (cookieName.startsWith(getCookieNamePrefix(cookieName))) {
|
||||
cookieName = cookieName.substring(getCookieNamePrefix(cookieName).length());
|
||||
if (escapedCookie.length() > 0) {
|
||||
escapedCookie.append("; ");
|
||||
}
|
||||
escapedCookie.append(cookieName).append("=").append(cookieSplit[1].trim());
|
||||
}
|
||||
}
|
||||
}
|
||||
return escapedCookie.toString();
|
||||
}
|
||||
|
||||
protected String getCookieNamePrefix(String name) {
|
||||
return "!Proxy!" + getServletConfig().getServletName();
|
||||
}
|
||||
|
||||
protected void copyResponseEntity(HttpResponse proxyResponse, HttpServletResponse servletResponse)
|
||||
throws IOException {
|
||||
HttpEntity entity = proxyResponse.getEntity();
|
||||
if (entity != null) {
|
||||
OutputStream servletOutputStream = servletResponse.getOutputStream();
|
||||
entity.writeTo(servletOutputStream);
|
||||
}
|
||||
}
|
||||
|
||||
protected String getTargetUri(HttpServletRequest servletRequest) {
|
||||
String pathInfo = servletRequest.getPathInfo();
|
||||
targetUri = pathInfo.split("/")[1];
|
||||
String host = targetUri.split(":")[0];
|
||||
String port = targetUri.split(":")[1];
|
||||
try {
|
||||
targetUriObj = new URI(targetUri);
|
||||
} catch (URISyntaxException e) {
|
||||
e.printStackTrace();
|
||||
throw new RuntimeException(e.getMessage(),e);
|
||||
}
|
||||
targetHost = new HttpHost(host, Integer.valueOf(port));
|
||||
return "http:/" + pathInfo;
|
||||
}
|
||||
|
||||
|
||||
protected String rewriteUrlFromResponse(HttpServletRequest servletRequest, String theUrl) {
|
||||
if (theUrl.startsWith(targetUri)) {
|
||||
StringBuffer curUrl = servletRequest.getRequestURL();
|
||||
int pos;
|
||||
if ((pos = curUrl.indexOf("://"))>=0) {
|
||||
if ((pos = curUrl.indexOf("/", pos + 3)) >=0) {
|
||||
curUrl.setLength(pos);
|
||||
}
|
||||
}
|
||||
curUrl.append(servletRequest.getContextPath());
|
||||
curUrl.append(servletRequest.getServletPath());
|
||||
curUrl.append(theUrl, targetUri.length(), theUrl.length());
|
||||
return curUrl.toString();
|
||||
}
|
||||
return theUrl;
|
||||
}
|
||||
|
||||
}
|
||||
@ -23,8 +23,6 @@ public class FunctionalReportService {
|
||||
private FucTestReportMapper fucTestReportMapper;
|
||||
@Resource
|
||||
private ExtFunctionalTestReportMapper extFunctionalTestReportMapper;
|
||||
@Resource
|
||||
private ZaleniumService zaleniumService;
|
||||
|
||||
public List<FucTestReport> getRecentReportList(ReportRequest request) {
|
||||
FucTestReportExample example = new FucTestReportExample();
|
||||
@ -44,11 +42,4 @@ public class FunctionalReportService {
|
||||
return extFunctionalTestReportMapper.getReportTestAndProInfo(reportId);
|
||||
}
|
||||
|
||||
public FucTestLog getTestLog(String reportId) {
|
||||
FucTestReport fucTestReport = fucTestReportMapper.selectByPrimaryKey(reportId);
|
||||
String content = fucTestReport.getContent();
|
||||
String endpoint = "http://localhost:4444";
|
||||
FucTestLog fucTestLogs = JSON.parseObject(content, FucTestLog.class);
|
||||
return zaleniumService.getFucTestLog(endpoint, fucTestLogs);
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,93 +0,0 @@
|
||||
package io.metersphere.service;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import io.metersphere.base.domain.*;
|
||||
import io.metersphere.base.mapper.FucTestMapper;
|
||||
import io.metersphere.base.mapper.FucTestReportMapper;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.web.client.RestTemplate;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.function.Function;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
@Service
|
||||
public class ZaleniumService {
|
||||
|
||||
@Resource
|
||||
RestTemplate restTemplate;
|
||||
|
||||
@Resource
|
||||
FucTestReportMapper fucTestReportMapper;
|
||||
|
||||
@Resource
|
||||
FucTestMapper fucTestMapper;
|
||||
|
||||
public void syncTestResult(){
|
||||
|
||||
List<ZaleniumTest> zaleniumTests = getZaleniumTest();
|
||||
|
||||
List<String> fucTestIds = zaleniumTests.stream().map(test -> test.getTestName())
|
||||
.collect(Collectors.toList());
|
||||
|
||||
FucTestExample fucTestExample = new FucTestExample();
|
||||
fucTestExample.createCriteria().andIdIn(fucTestIds);
|
||||
List<FucTest> fucTests = fucTestMapper.selectByExample(fucTestExample);
|
||||
|
||||
List<String> reportIds = fucTestReportMapper.selectByExample(new FucTestReportExample()).stream().map(report -> report.getId()).collect(Collectors.toList());
|
||||
|
||||
Map<String, FucTest> fucTestMaps = fucTests.stream()
|
||||
.collect(Collectors.toMap(FucTest::getId, Function.identity()));
|
||||
|
||||
zaleniumTests.forEach(item -> {
|
||||
if(!reportIds.contains(item.getTestName())){
|
||||
saveFucTestReport(item, fucTestMaps.get(item.getTestName()));
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
private void saveFucTestReport(ZaleniumTest item, FucTest fucTest) {
|
||||
FucTestReport fucTestReport = new FucTestReport();
|
||||
fucTestReport.setCreateTime(System.currentTimeMillis());
|
||||
fucTestReport.setUpdateTime(System.currentTimeMillis());
|
||||
fucTestReport.setTestId(item.getTestName());
|
||||
fucTestReport.setStatus("1");
|
||||
fucTestReport.setId(item.getTestName());
|
||||
JSONObject content = new JSONObject();
|
||||
content.put("videoUrl", "dashboard/" + item.getFileName());
|
||||
content.put("seleniumLog", "dashboard/logs/" + item.getTestNameNoExtension() + "/selenium-multinode-stderr.log");
|
||||
content.put("browserDriverLog", "dashboard/" + item.getBrowserDriverLogFileName());
|
||||
fucTestReport.setContent(content.toJSONString());
|
||||
if(fucTest != null){
|
||||
fucTestReport.setDescription(fucTest.getDescription());
|
||||
fucTestReport.setName(fucTest.getName());
|
||||
} else {
|
||||
fucTestReport.setDescription("ZaleniumTest");
|
||||
fucTestReport.setName(item.getTestName());
|
||||
}
|
||||
fucTestReportMapper.insert(fucTestReport);
|
||||
}
|
||||
|
||||
private List<ZaleniumTest> getZaleniumTest() {
|
||||
List<ZaleniumTest> tests = new ArrayList<>();
|
||||
String url = "http://localhost:4444/dashboard/information?lastDateAddedToDashboard=0";
|
||||
tests.addAll(Arrays.asList(restTemplate.getForObject(url, ZaleniumTest[].class)));
|
||||
return tests;
|
||||
}
|
||||
|
||||
public FucTestLog getFucTestLog(String endpoint, FucTestLog logPaths) {
|
||||
FucTestLog testLog = new FucTestLog();
|
||||
testLog.setSeleniumLog(getZaleniumTestLog(endpoint, logPaths.getSeleniumLog()));
|
||||
testLog.setBrowserDriverLog(getZaleniumTestLog(endpoint, logPaths.getBrowserDriverLog()));
|
||||
return testLog;
|
||||
}
|
||||
|
||||
private String getZaleniumTestLog(String endpoint, String logPath) {
|
||||
return restTemplate.getForObject(endpoint + "/" + logPath, String.class);
|
||||
}
|
||||
|
||||
}
|
||||
45
backend/src/test/java/io/metersphere/GenerateGraphTest.java
Normal file
45
backend/src/test/java/io/metersphere/GenerateGraphTest.java
Normal file
@ -0,0 +1,45 @@
|
||||
package io.metersphere;
|
||||
|
||||
import com.opencsv.bean.CsvToBean;
|
||||
import com.opencsv.bean.CsvToBeanBuilder;
|
||||
import com.opencsv.bean.HeaderColumnNameMappingStrategy;
|
||||
import com.opencsv.bean.MappingStrategy;
|
||||
import org.junit.Test;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.Reader;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import java.util.List;
|
||||
|
||||
public class GenerateGraphTest {
|
||||
|
||||
|
||||
@Test
|
||||
public void test1() {
|
||||
File csvFile = new File("/Users/liuruibin/Desktop/0316.jtl");
|
||||
HeaderColumnNameMappingStrategy<Metric> ms = new HeaderColumnNameMappingStrategy<>();
|
||||
ms.setType(Metric.class);
|
||||
List<Metric> metrics = beanBuilderExample(csvFile.toPath(), ms);
|
||||
metrics.forEach(c -> {
|
||||
System.out.println(c.getTimestamp());
|
||||
});
|
||||
}
|
||||
|
||||
public static List<Metric> beanBuilderExample(Path path, MappingStrategy<Metric> ms) {
|
||||
try (Reader reader = Files.newBufferedReader(path)) {
|
||||
|
||||
CsvToBean<Metric> cb = new CsvToBeanBuilder<Metric>(reader)
|
||||
.withType(Metric.class)
|
||||
.withSkipLines(0)
|
||||
.withMappingStrategy(ms)
|
||||
.withIgnoreLeadingWhiteSpace(true)
|
||||
.build();
|
||||
|
||||
return cb.parse();
|
||||
} catch (Exception ex) {
|
||||
ex.printStackTrace();
|
||||
}
|
||||
return null;
|
||||
}
|
||||
}
|
||||
180
backend/src/test/java/io/metersphere/Metric.java
Normal file
180
backend/src/test/java/io/metersphere/Metric.java
Normal file
@ -0,0 +1,180 @@
|
||||
package io.metersphere;
|
||||
|
||||
import com.opencsv.bean.CsvBindByName;
|
||||
|
||||
public class Metric {
|
||||
// timestamp,elapsed,label,responseCode,responseMessage,threadName,dataType,success,failureMessage,bytes,sentBytes,grpThreads,allThreads,URL,Latency,IdleTime,Connect
|
||||
|
||||
@CsvBindByName(column = "timestamp")
|
||||
private String timestamp;
|
||||
@CsvBindByName(column = "elapsed")
|
||||
private String elapsed;
|
||||
@CsvBindByName(column = "label")
|
||||
private String label;
|
||||
@CsvBindByName(column = "responseCode")
|
||||
private String responseCode;
|
||||
@CsvBindByName(column = "responseMessage")
|
||||
private String responseMessage;
|
||||
@CsvBindByName(column = "threadName")
|
||||
private String threadName;
|
||||
@CsvBindByName(column = "dataType")
|
||||
private String dataType;
|
||||
@CsvBindByName(column = "success")
|
||||
private String success;
|
||||
@CsvBindByName(column = "failureMessage")
|
||||
private String failureMessage;
|
||||
@CsvBindByName(column = "bytes")
|
||||
private String bytes;
|
||||
@CsvBindByName(column = "sentBytes")
|
||||
private String sentBytes;
|
||||
@CsvBindByName(column = "grpThreads")
|
||||
private String grpThreads;
|
||||
@CsvBindByName(column = "allThreads")
|
||||
private String allThreads;
|
||||
@CsvBindByName(column = "URL")
|
||||
private String url;
|
||||
@CsvBindByName(column = "Latency")
|
||||
private String latency;
|
||||
@CsvBindByName(column = "IdleTime")
|
||||
private String idleTime;
|
||||
@CsvBindByName(column = "Connect")
|
||||
private String connect;
|
||||
|
||||
|
||||
public String getTimestamp() {
|
||||
return timestamp;
|
||||
}
|
||||
|
||||
public void setTimestamp(String timestamp) {
|
||||
this.timestamp = timestamp;
|
||||
}
|
||||
|
||||
public String getElapsed() {
|
||||
return elapsed;
|
||||
}
|
||||
|
||||
public void setElapsed(String elapsed) {
|
||||
this.elapsed = elapsed;
|
||||
}
|
||||
|
||||
|
||||
public String getLabel() {
|
||||
return label;
|
||||
}
|
||||
|
||||
public void setLabel(String label) {
|
||||
this.label = label;
|
||||
}
|
||||
|
||||
public String getResponseCode() {
|
||||
return responseCode;
|
||||
}
|
||||
|
||||
public void setResponseCode(String responseCode) {
|
||||
this.responseCode = responseCode;
|
||||
}
|
||||
|
||||
public String getResponseMessage() {
|
||||
return responseMessage;
|
||||
}
|
||||
|
||||
public void setResponseMessage(String responseMessage) {
|
||||
this.responseMessage = responseMessage;
|
||||
}
|
||||
|
||||
public String getThreadName() {
|
||||
return threadName;
|
||||
}
|
||||
|
||||
public void setThreadName(String threadName) {
|
||||
this.threadName = threadName;
|
||||
}
|
||||
|
||||
public String getDataType() {
|
||||
return dataType;
|
||||
}
|
||||
|
||||
public void setDataType(String dataType) {
|
||||
this.dataType = dataType;
|
||||
}
|
||||
|
||||
public String getSuccess() {
|
||||
return success;
|
||||
}
|
||||
|
||||
public void setSuccess(String success) {
|
||||
this.success = success;
|
||||
}
|
||||
|
||||
public String getFailureMessage() {
|
||||
return failureMessage;
|
||||
}
|
||||
|
||||
public void setFailureMessage(String failureMessage) {
|
||||
this.failureMessage = failureMessage;
|
||||
}
|
||||
|
||||
public String getBytes() {
|
||||
return bytes;
|
||||
}
|
||||
|
||||
public void setBytes(String bytes) {
|
||||
this.bytes = bytes;
|
||||
}
|
||||
|
||||
public String getSentBytes() {
|
||||
return sentBytes;
|
||||
}
|
||||
|
||||
public void setSentBytes(String sentBytes) {
|
||||
this.sentBytes = sentBytes;
|
||||
}
|
||||
|
||||
public String getGrpThreads() {
|
||||
return grpThreads;
|
||||
}
|
||||
|
||||
public void setGrpThreads(String grpThreads) {
|
||||
this.grpThreads = grpThreads;
|
||||
}
|
||||
|
||||
public String getAllThreads() {
|
||||
return allThreads;
|
||||
}
|
||||
|
||||
public void setAllThreads(String allThreads) {
|
||||
this.allThreads = allThreads;
|
||||
}
|
||||
|
||||
public String getUrl() {
|
||||
return url;
|
||||
}
|
||||
|
||||
public void setUrl(String url) {
|
||||
this.url = url;
|
||||
}
|
||||
|
||||
public String getLatency() {
|
||||
return latency;
|
||||
}
|
||||
|
||||
public void setLatency(String latency) {
|
||||
this.latency = latency;
|
||||
}
|
||||
|
||||
public String getIdleTime() {
|
||||
return idleTime;
|
||||
}
|
||||
|
||||
public void setIdleTime(String idleTime) {
|
||||
this.idleTime = idleTime;
|
||||
}
|
||||
|
||||
public String getConnect() {
|
||||
return connect;
|
||||
}
|
||||
|
||||
public void setConnect(String connect) {
|
||||
this.connect = connect;
|
||||
}
|
||||
}
|
||||
@ -1,23 +0,0 @@
|
||||
package io.metersphere;
|
||||
|
||||
import io.metersphere.service.ZaleniumService;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
|
||||
public class ZaleniumTest {
|
||||
|
||||
@Resource
|
||||
ZaleniumService zaleniumService;
|
||||
|
||||
@Test
|
||||
public void sysnZaleniumTest(){
|
||||
zaleniumService.syncTestResult();
|
||||
}
|
||||
|
||||
}
|
||||
@ -35,10 +35,10 @@
|
||||
|
||||
<el-tabs v-model="active" type="border-card" :stretch="true">
|
||||
<el-tab-pane :label="$t('report.test_details')">
|
||||
<result-details v-if="isRouterAlive" :video-url="videoUrl" />
|
||||
<result-details />
|
||||
</el-tab-pane>
|
||||
<el-tab-pane :label="$t('report.test_log_details')">
|
||||
<ms-report-log-details :report-id="report.id"/>
|
||||
<ms-report-log-details />
|
||||
</el-tab-pane>
|
||||
</el-tabs>
|
||||
|
||||
@ -62,9 +62,7 @@
|
||||
result: {},
|
||||
active: '0',
|
||||
videoPath: '',
|
||||
videoUrl: null,
|
||||
report: {},
|
||||
isRouterAlive: true //控制视图是否显示的变量
|
||||
report: {}
|
||||
}
|
||||
},
|
||||
methods: {
|
||||
@ -75,17 +73,9 @@
|
||||
if(data){
|
||||
this.report = data;
|
||||
this.report.content = JSON.parse(this.report.content);
|
||||
this.videoUrl = 'proxy/localhost:4444/' + this.report.content.videoUrl;
|
||||
this.reload();//重新渲染组件
|
||||
}
|
||||
});
|
||||
}
|
||||
},
|
||||
reload () {
|
||||
this.isRouterAlive = false;//先关闭，
|
||||
this.$nextTick(function () {
|
||||
this.isRouterAlive = true;//再打开
|
||||
})
|
||||
}
|
||||
},
|
||||
mounted() {
|
||||
|
||||
@ -1,14 +1,7 @@
|
||||
<template>
|
||||
<div>
|
||||
<div>
|
||||
<el-tabs type="border-card">
|
||||
<el-tab-pane label="seleniumLog">
|
||||
<el-input v-model="seleniumLog" rows="15" type="textarea"></el-input>
|
||||
</el-tab-pane>
|
||||
<el-tab-pane label="browserDriverLog">
|
||||
<el-input v-model="browserDriverLog" rows="15" type="textarea"></el-input>
|
||||
</el-tab-pane>
|
||||
</el-tabs>
|
||||
LogDetails
|
||||
</div>
|
||||
<div>
|
||||
|
||||
@ -25,29 +18,8 @@
|
||||
browserDriverLog: ''
|
||||
}
|
||||
},
|
||||
props: {
|
||||
reportId: {
|
||||
type: String
|
||||
}
|
||||
},
|
||||
mounted() {
|
||||
this.getLogDetails(this.reportId);
|
||||
},
|
||||
watch: {
|
||||
reportId: function (newVal) {
|
||||
this.getLogDetails(newVal);
|
||||
}
|
||||
},
|
||||
methods: {
|
||||
getLogDetails(reportId) {
|
||||
if(reportId){
|
||||
let url = '/functional/report/test/log/' + reportId;
|
||||
this.$get(url, (response) => {
|
||||
this.seleniumLog = response.data.seleniumLog;
|
||||
this.browserDriverLog = response.data.browserDriverLog;
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
</script>
|
||||
|
||||
@ -1,19 +1,12 @@
|
||||
<template>
|
||||
<div>
|
||||
<video id="video" controls="" autoplay="" class="embed-responsive-item">
|
||||
<source id="video-source" :src="videoUrl" type="video/mp4">
|
||||
</video>
|
||||
ResultDetails
|
||||
</div>
|
||||
</template>
|
||||
|
||||
<script>
|
||||
export default {
|
||||
name: "ResultDetails",
|
||||
props: {
|
||||
videoUrl: {
|
||||
type: String
|
||||
}
|
||||
}
|
||||
name: "ResultDetails"
|
||||
}
|
||||
</script>
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user