基于Spring Boot、SpringSecurity、MyBatis、Jwt、Vue的自动化测试平台支持UI自动化接口自动化

package com.rabbit.service.Impl; import com.jayway.jsonpath.JsonPath; import com.rabbit.model.TApiResult; import com.rabbit.model.TApi; import com.rabbit.model.po.*; import com.rabbit.service.RequestExecutorServer; import com.rabbit.service.TApiService; import com.rabbit.service.TFileInfoService; import com.rabbit.utils.BeanUtils; import com.rabbit.utils.MyStringUtils; import com.rabbit.utils.StringUtilHelper; import com.rabbit.utils.apitest.ApiUtil; import io.restassured.RestAssured; import io.restassured.config.EncoderConfig; import io.restassured.config.HttpClientConfig; import io.restassured.http.Header; import io.restassured.path.xml.XmlPath; import io.restassured.response.Response; import io.restassured.specification.RequestSpecification; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.io.File; import java.net.ConnectException; import java.net.URLDecoder; import java.net.UnknownHostException; import java.util.*; import static io.restassured.config.JsonConfig.jsonConfig; import static io.restassured.config.SSLConfig.sslConfig; import static io.restassured.path.json.config.JsonPathConfig.NumberReturnType.BIG_DECIMAL; @Slf4j @Service public class RequestExecutorImpl implements RequestExecutorServer { @Resource private TFileInfoService fileInfoService; @Resource private TApiService apiService; @Override public TApiResult executeHttpRequest(TApi tApi, Map<String, Object> gVars, Map<String, Object> caseVars, List<ApiParam> params) { TApiResult tApiResult = new TApiResult(); if (params != null) { for (ApiParam apiParam : params) { apiParam.setValue(MyStringUtils.replaceKeyFromMap(apiParam.getValue(), gVars, caseVars)); } } beforeHandle(tApi, gVars, caseVars); tApiResult.setCreateTime(new Date()); RequestSpecification requestSpecification = RestAssured.given(); trustAllHosts(requestSpecification); applyHeaders(requestSpecification, tApi, gVars, caseVars, tApiResult, params); applyQueryParameters(requestSpecification, tApi, gVars, caseVars, tApiResult, params); log.info("开始请求执行接口"); tApi.setDomain(MyStringUtils.replaceKeyFromMap(tApi.getDomain(), gVars, caseVars)); tApiResult.setReqMethod(tApi.getMethod()); if (!tApi.getMethod().equalsIgnoreCase("get")) { tApiResult.setReqBodyType(tApi.getReqBodyType()); if (tApi.getReqBodyType() == null) { } else if (tApi.getReqBodyType().equals("form")) { applyFormParam(requestSpecification, tApi, gVars, caseVars, tApiResult, params); } else if (tApi.getReqBodyType().equals("raw")) { applyRawParam(requestSpecification, tApi, gVars, caseVars, tApiResult, params); } } Response response = null; if (!tApi.getPath().startsWith("/")) { tApi.setPath("/" + tApi.getPath()); } String url = tApi.getDomain() + tApi.getPath(); if (url.indexOf("?") != -1) { url = url.substring(0, url.indexOf("?")); } url = MyStringUtils.replaceKeyFromMap(url, gVars, caseVars); tApiResult.setReqUrl(url); try { switch (tApi.getMethod().toUpperCase()) { case "GET": response = requestSpecification.when().get(url); break; case "POST": response = requestSpecification.when().post(url); break; case "PATCH": response = requestSpecification.when().patch(url); break; case "DELETE": response = requestSpecification.when().delete(url); break; case "PUT": response = requestSpecification.when().put(url); break; case "OPTIONS": response = requestSpecification.when().options(url); break; case "HEAD": response = requestSpecification.when().head(url); break; default: tApiResult.setException(String.format("不支持这个请求 %s.", url)); } } catch (Exception e) { tApiResult.setResultType(-1); if (e instanceof UnknownHostException) { tApiResult.setException("请求异常,URL[" + e.getMessage() + "]无法连接"); } else if (e instanceof ConnectException) { tApiResult.setException("请求异常,URL[" + tApi.getDomain() + "]无法连接"); } else { tApiResult.setException("请求异常：" + e.getMessage()); e.printStackTrace(); } log.info("请求异常:{}", e.getMessage()); long time = new Date().getTime() - tApiResult.getCreateTime().getTime(); tApiResult.setRspTime(time); return tApiResult; } tApiResult.setRspStatusCode(response.getStatusCode()); tApiResult.setRspTime(response.getTime()); tApiResult.setRspBodySize(response.getBody().asByteArray().length); List<com.rabbit.model.po.Header> listHeader = new ArrayList<>(); response.getHeaders().asList().forEach(x -> { com.rabbit.model.po.Header header = new com.rabbit.model.po.Header(); header.setKey(x.getName()); header.setValue(x.getValue()); listHeader.add(header); }); tApiResult.setRspHeaders(listHeader); tApiResult.setRspBody(response.getBody().prettyPrint()); tApiResult.setRspBodyType(StringUtilHelper.checkStringFormat(tApiResult.getRspBody())); Boolean handResult = handleAssert(tApi, caseVars, tApiResult); //断言 handleExtract(tApi, caseVars, tApiResult); //提取参数 if (handResult) { //响应断言成功 tApiResult.setResultType(1); } else { //断言失败 tApiResult.setResultType(0); } return tApiResult; } private void beforeHandle(TApi tApi, Map<String, Object> gVars, Map<String, Object> caseVars) { //前置处理器 List<Action> beforeExcs = tApi.getBeforeExcs(); if (beforeExcs != null) { for (Action action : beforeExcs) { apiService.runAction(action, gVars, caseVars); } } } //trust all hosts regardless if the SSL certificate is invalid private void trustAllHosts(RequestSpecification requestSpecification) { RestAssured.config = RestAssured.config().sslConfig(sslConfig().relaxedHTTPSValidation()); RestAssured.config = RestAssured.config().jsonConfig(jsonConfig().numberReturnType(BIG_DECIMAL)); Map<String, Object> httpClientParams = new HashMap<String, Object>(); httpClientParams.put("http.connection.timeout", 60000); httpClientParams.put("http.socket.timeout", 60000); httpClientParams.put("http.connection.manager.timeout", 60000); RestAssured.config = RestAssured.config().httpClient(HttpClientConfig.httpClientConfig().addParams(httpClientParams)); // RestAssured.config = RestAssured.config().encoderConfig(EncoderConfig.encoderConfig().defaultContentCharset("UTF-8")); RestAssured.config = RestAssured.config().encoderConfig(EncoderConfig.encoderConfig().appendDefaultContentCharsetToContentTypeIfUndefined(false)); requestSpecification.config(RestAssured.config); } private void applyHeaders(RequestSpecification requestSpecification, TApi tApi, Map<String, Object> gVars, Map<String, Object> caseVars, TApiResult TApiResult, List<ApiParam> params) { List<com.rabbit.model.po.Header> headers = tApi.getReqHeader(); for (com.r