Skip to content

S
study
Commit d50e9c24 by Li Yongyu
Options

update

parent db0d3708
Showing with 331 additions and 411 deletions
studycenter_Api_auto_test/src/com/offcn/TestUnti/ReadProperties.java
......@@ -139,7 +139,7 @@ public class ReadProperties {
Properties pps = new Properties();
try {
File directory = new File(".");
String sourceFile = directory.getCanonicalPath() +File.separator+"src"+File.separator+"resources"+File.separator+qudao+"reflect.properties";
String sourceFile = directory.getCanonicalPath() +File.separator+"src"+File.separator+"resources"+File.separator+"reflect.properties";
InputStream in = new BufferedInputStream (new FileInputStream(sourceFile));
pps.load(in);
String value = pps.getProperty(key);
......
studycenter_Api_auto_test/src/com/offcn/TestUnti/Reflect_api.java
......@@ -30,12 +30,7 @@ public class Reflect_api {
// String system = MapUtil.getValue("system", data);
// String classRoute = ReadProperties.GetPropertyByKey(system);
count++;
// if(!classRoute.equals("com.offcn.api.xyzb.liucheng")){
//// String serviceUrl = data.get("serviceUrl").toString();
//// ClassName = serviceUrl.split("/")[serviceUrl.split("/").length - 1];
// String classRoute1 = ReadProperties.GetPropertyByKey("gmysx");
// ClassName=ClassName.replaceAll(classRoute, classRoute1);
// }
}
if(count==3){
Log.logError("Reflect_api,ReflexClass Error，Classname=" + ClassName);
......@@ -65,24 +60,14 @@ public class Reflect_api {
String system = MapUtil.getValue("system", data);
String classRoute = ReadProperties.GetPropertyByKey(system);
// if ("/order/insert".equals(serviceUrl)) {
// if (serviceUrl.indexOf("/order/insert")!=-1) {
// return classRoute+CalssName + "_dd";
// }
//xuwen-添加对商户（sh）的支持
// if("zy".equals(system) || "sh".equals(system) || "dk".equals(system) ){
// String classReflectName = ReadProperties.GetPropertyByClassName(serviceUrl);
// if ( classReflectName!=null ) {
// return classRoute+ classReflectName;
// }
// }
if("xyzb".equals(system)){
if(system.contains("study")){
String classReflectName = ReadProperties.GetPropertyByClassName(serviceUrl,system);
if ( classReflectName!=null ) {
return classRoute+ classReflectName;
}
}
return classRoute+CalssName;
}
}
studycenter_Api_auto_test/src/com/offcn/TestUnti/RequestDataUtils.java
......@@ -2,6 +2,7 @@ package com.offcn.TestUnti;
import io.restassured.RestAssured;
import io.restassured.config.EncoderConfig;
import io.restassured.config.RedirectConfig;
import io.restassured.config.RestAssuredConfig;
import io.restassured.config.SSLConfig;
import io.restassured.http.ContentType;
......@@ -9,6 +10,7 @@ import io.restassured.http.Cookies;
import io.restassured.http.Headers;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import io.restassured.specification.RequestSpecification;
import java.io.File;
import java.util.Date;
......@@ -16,7 +18,6 @@ import java.util.HashMap;
import java.util.Map;
import com.offcn.process.BasicsGM;
import com.offcn.system.MyRequest;
import com.offcn.system.system;
......@@ -25,26 +26,29 @@ import static io.restassured.http.ContentType.JSON;
public class RequestDataUtils {
public static void main(String[] args) {
String s="/user/validator/code?phone=13910960649&sendImageCode=CJ6J";
}
//发送请求前的准备
private RestAssured getRMEnv(system tem) {
RestAssured ra = new RestAssured();
ra.config = RestAssuredConfig.newConfig().sslConfig(
SSLConfig.sslConfig().allowAllHostnames());
// System.out.println(""+tem.getRM_URI()+"");
if(tem!=null){
if(tem !=null){
ra.baseURI = tem.getRM_URI();
// System.out.println(tem.getRM_port());
if (tem.getRM_port()!=null && tem.getRM_port().length()>1){
ra.port = Integer.valueOf(tem.getRM_port());
}
// System.out.println(tem.getRM_basePath());
if (tem.getRM_basePath()!=null && tem.getRM_basePath().length()>1){
ra.basePath = tem.getRM_basePath();
}
// RestAssured.config = ra.config().connectionConfig(RestAssured.config().getConnectionConfig().closeIdleConnectionsAfterEachResponse());
}
// RestAssured.config = RestAssured.config().encoderConfig(EncoderConfig.encoderConfig().encodeContentTypeAs("x-www-form-urlencoded", ContentType.ANY).defaultContentCharset("utf-8"));
// RestAssured.config = RestAssured.config().redirect(RedirectConfig.redirectConfig().followRedirects(false));
//RestAssured.config = RestAssured.config().encoderConfig(EncoderConfig.encoderConfig().encodeContentTypeAs("x-www-form-urlencoded", ContentType.ANY).defaultContentCharset("utf-8"));
return ra;
}
......@@ -64,43 +68,61 @@ public class RequestDataUtils {
}
public static Response PostAll(HashMap<String, Object> data,MyRequest myRequest){
if(myRequest.getFile()!=null){
return Post_file(data,myRequest);
}
if(myRequest.getFormParameter()!=null){
if(myRequest.getFile()!=null){
return Post_file(data,myRequest);
}else{
return Post_form_data(data,myRequest);
}
}else if(myRequest.getParameter()!=null){
return Post_JSON(data,myRequest);
return Post_form_data(data,myRequest);
}
return null;
return Post_JSON(data,myRequest);
}
public static Response Post_file(HashMap<String, Object> data,MyRequest myRequest) {
// 设置参数格式
public static RequestSpecification jobApi(HashMap<String, Object> data,MyRequest myRequest){
String Parameter = (String) data.get("parameter");
String system = MapUtil.getValue("system", data);system = replaceString(system);
String system = MapUtil.getValue("system", data);
system = replaceString(system);
com.offcn.system.system tem = (com.offcn.system.system) (BasicsGM.map.get(system));
String path=tem.getRM_URI()+tem.getRM_port()+tem.getRM_basePath()+myRequest.getUrl();
Log.logInfo(data.get("Description").toString() + "," + data.get("TCNO").toString()+"," +path+ ",Parameter=" + Parameter);
int state = 0;
Response re = null;
RequestDataUtils rdu = new RequestDataUtils();
String path="";
if(myRequest.getUrl().startsWith("http://")){
tem=null;
}else{
path=tem.getRM_URI()+(tem.getRM_port().equals("")?"":":"+tem.getRM_port())+tem.getRM_basePath()+myRequest.getUrl();
}
@SuppressWarnings("static-access")
RequestSpecification rsf=rdu.getRMEnv(tem).given();
if(myRequest.getFormParameter()!=null){
Log.logInfo(data.get("Description").toString() + "," + data.get("TCNO").toString()+"," +path + ",FormParameter="+myRequest.getFormParameter());
}else{
Log.logInfo(data.get("Description").toString() + "," + data.get("TCNO").toString()+"," +path + ",Parameter=" + Parameter);
}
if(myRequest.getHeaders()!=null){
rsf=rsf.headers(myRequest.getHeaders());
}
if(myRequest.getCookies()!=null){
rsf=rsf.cookies(myRequest.getCookies());
}
return rsf;
}
public static Response Post_file(HashMap<String, Object> data,MyRequest myRequest) {
String Parameter = (String) data.get("parameter");
int state = 0;
Response re = null;
while (state < 5) {
try {
state++;
File filen=new File("out/"+myRequest.getFile());
re = rdu.getRMEnv(tem).given()
.headers(myRequest.getHeaders()!=null?myRequest.getHeaders():new HashMap<String, String>())
.cookies(myRequest.getCookies()!=null?myRequest.getCookies():new HashMap<String, String>())
.params(myRequest.getFormParameter()).when().multiPart("image", filen)
re = jobApi(data,myRequest)
.body("{"+Parameter+"}").when().multiPart(myRequest.getFileType(), filen)
.post(myRequest.getUrl()).thenReturn();
if (!"200".equals(re.getStatusCode()+"")) {
Log.logError("请求返回:" +re.getStatusCode()+",第"+ state + "次。");
Thread.sleep(1000);
} else {
return re;
}
......@@ -113,38 +135,23 @@ public class RequestDataUtils {
}
public static Response Post_form_data(HashMap<String, Object> data,MyRequest myRequest) {
//设置参数格式
String parameter= MapUtil.getParameter(data);
String system= MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
String path=tem.getRM_URI()+tem.getRM_port()+tem.getRM_basePath()+myRequest.getUrl();
parameter=parameter.substring(1, parameter.length()-1);
Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+","+path+",Parameter="+parameter);
// 设置参数格式
int state = 0;
Response re = null;
RequestDataUtils rdu = new RequestDataUtils();
while (state < 5) {
try {
state++;
re = rdu.getRMEnv(tem).given()
.headers(myRequest.getHeaders()!=null?myRequest.getHeaders():new HashMap<String, String>())
.cookies(myRequest.getCookies()!=null?myRequest.getCookies():new HashMap<String, String>())
re = jobApi(data,myRequest)
.params(myRequest.getFormParameter())
.when()
.post(myRequest.getUrl())
.thenReturn();
JsonPath jp = re.body().jsonPath();
if ("500".equals(jp.getString("status"))) {
Log.logError("请求返回500," + state + "次。");
Thread.sleep(1000);
} else {
return re;
if (!"200".equals(re.getStatusCode()+"")) {
Log.logError("请求返回" + re.getStatusCode() + "次。");
// } else {
}
return re;
} catch (Exception e) {
e.printStackTrace();
Log.logError("请求超时," + state + "次。");
......@@ -158,33 +165,18 @@ public class RequestDataUtils {
public static Response Post_JSON(HashMap<String, Object> data,MyRequest myRequest) {
// 设置参数格式
String Parameter = (String) data.get("parameter");
String system = MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem = (com.offcn.system.system) (BasicsGM.map.get(system));
int state = 0;
Response re = null;
RequestDataUtils rdu = new RequestDataUtils();
if(myRequest.getUrl().contains("http://")){
tem=null;
Log.logInfo(data.get("Description").toString() + "," + data.get("TCNO").toString() +","+myRequest.getUrl()+ ",Parameter=" + Parameter);
}else{
String path=tem.getRM_URI()+tem.getRM_port()+tem.getRM_basePath()+ myRequest.getUrl();
Log.logInfo(data.get("Description").toString() + "," + data.get("TCNO").toString() +","+path+ ",Parameter=" + Parameter);
}
while (state < 5) {
try {
state++;
re = rdu.getRMEnv(tem).given()
.headers(myRequest.getHeaders()!=null?myRequest.getHeaders():new HashMap<String, String>())
.cookies(myRequest.getCookies()!=null?myRequest.getCookies():new HashMap<String, String>())
re = jobApi(data,myRequest)
.contentType(JSON).body("{"+Parameter+"}").when()
.post(myRequest.getUrl()).thenReturn();
if (!"200".equals(re.getStatusCode()+"")) {
Log.logError("请求返回," + re.getStatusCode() + "次。");
Thread.sleep(1000);
} else {
return re;
}
......@@ -199,35 +191,18 @@ public class RequestDataUtils {
@SuppressWarnings("deprecation")
public static Response Put(HashMap<String, Object> data,MyRequest myRequest) {
//设置参数格式
String parameter= MapUtil.getParameter(data);
String system= MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
String path=tem.getRM_URI()+tem.getRM_port()+tem.getRM_basePath()+myRequest.getUrl();
parameter=parameter.substring(1, parameter.length()-1);
Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+","+path+",Parameter="+parameter);
// 设置参数格式
int state = 0;
Response re = null;
RequestDataUtils rdu = new RequestDataUtils();
while (state < 5) {
try {
state++;
re = rdu.getRMEnv(tem).given().config(RestAssured.config()
.encoderConfig(EncoderConfig.encoderConfig()
.encodeContentTypeAs("x-www-form-urlencoded", ContentType.ANY)
.defaultContentCharset("utf-8")))
.headers(myRequest.getHeaders()!=null?myRequest.getHeaders():new HashMap<String, String>())
.cookies(myRequest.getCookies()!=null?myRequest.getCookies():new HashMap<String, String>())
re = jobApi(data,myRequest)
.formParameters(myRequest.getFormParameter())
.when().put(myRequest.getUrl()).thenReturn();
JsonPath jp = re.body().jsonPath();
if ("500".equals(jp.getString("status"))) {
Log.logError("请求返回500," + state + "次。");
Thread.sleep(1000);
} else {
return re;
}
......@@ -240,34 +215,21 @@ public class RequestDataUtils {
}
public static Response Del(HashMap<String, Object> data,MyRequest myRequest) {
//设置参数格式
String parameter= MapUtil.getParameter(data);
String system= MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
String path=tem.getRM_URI()+tem.getRM_port()+tem.getRM_basePath()+myRequest.getUrl();
parameter=parameter.substring(1, parameter.length()-1);
Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+","+path+",Parameter="+parameter);
// 设置参数格式
Log.logInfo("serviceURL=" + myRequest.getUrl() + ",Parameter=" + myRequest.getParameter());
int state = 0;
Response re = null;
RequestDataUtils rdu = new RequestDataUtils();
while (state < 5) {
try {
state++;
re = rdu.getRMEnv(tem).given()
.headers(myRequest.getHeaders()!=null?myRequest.getHeaders():new HashMap<String, String>())
.cookies(myRequest.getCookies()!=null?myRequest.getCookies():new HashMap<String, String>())
re =jobApi(data,myRequest)
.when().delete(myRequest.getUrl()).thenReturn();
JsonPath jp = re.body().jsonPath();
if ("500".equals(jp.getString("status"))) {
Log.logError("请求返回500," + state + "次。");
Thread.sleep(1000);
} else {
return re;
}
} catch (Exception e) {
e.printStackTrace();
Log.logError("请求超时," + state + "次。");
}
}
......@@ -277,59 +239,32 @@ public class RequestDataUtils {
@SuppressWarnings("static-access")
public static Response Get(HashMap<String, Object> data,MyRequest myRequest) {
//设置参数格式
String parameter= MapUtil.getParameter(data);
String system= MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
String path=tem.getRM_URI()+tem.getRM_port()+tem.getRM_basePath()+myRequest.getUrl();
parameter=parameter.substring(1, parameter.length()-1);
Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+","+path+",Parameter="+parameter);
String parameter= (String) data.get("parameter");
int state=0;
Response re=null;
RequestDataUtils rdu=new RequestDataUtils();
while(state<3){
try {
state++;
if(parameter != null && !"".equals(parameter)) {
re = rdu.getRMEnv(tem).given()
.headers(myRequest.getHeaders()!=null?myRequest.getHeaders():new HashMap<String, String>())
.cookies(myRequest.getCookies()!=null?myRequest.getCookies():new HashMap<String, String>())
.get(myRequest.getUrl() + "?" + parameter).andReturn();
re = jobApi(data,myRequest)
.get(myRequest.getUrl() + "?" + parameter).thenReturn();
}else {
re = rdu.getRMEnv(tem).given()
.headers(myRequest.getHeaders()!=null?myRequest.getHeaders():new HashMap<String, String>())
.cookies(myRequest.getCookies()!=null?myRequest.getCookies():new HashMap<String, String>())
.get(myRequest.getUrl()).andReturn();
re = jobApi(data,myRequest)
.get(myRequest.getUrl()).thenReturn();
}
if(!"200".equals(re.statusCode()+"")){
Log.logError("请求返回"+re.statusCode()+"次。");
}else{
return re;
}
return re;
} catch (Exception e) {
e.printStackTrace();
Log.logError("请求超时,"+state+"次。");
}
}
return re;
}
//不带token的post请求
public static Response Post_headers(HashMap<String, Object> data, String serviceURL,String zgl_clienttype) {
// 设置参数格式
......@@ -368,71 +303,71 @@ public class RequestDataUtils {
return re;
}
// //不带token的post请求
// public static Response Post_NOToken(HashMap<String, Object> data, String serviceURL) {
// // 设置参数格式
// String Parameter = (String) data.get("parameter");
//
// String system = MapUtil.getValue("system", data);system = replaceString(system);
// com.offcn.system.system tem = (com.offcn.system.system) (BasicsGM.map.get(system));
//
// Log.logInfo(data.get("Description").toString() + "," + data.get("TCNO").toString() + ",Parameter=" + Parameter);
//
// int state = 0;
// Response re = null;
// RequestDataUtils rdu = new RequestDataUtils();
// while (state < 5) {
// try {
// state++;
// if("/web/member".equals(serviceURL)){
//// Cookie cookie1 = Cookie.Builder("username", "John").setComment("comment 1").build();
//// Cookie cookie2 = Cookie.Builder("token", 1234).setComment("comment 2").build();
//// Cookies cookies = new Cookies(cookie1, cookie2);
// System.out.println(XYZB.laravel_session);
// System.out.println(XYZB.XSRF_token);
// re = rdu.getRMEnv(tem).given()
//// .header("laravel_session", XYZB.laravel_session)
//// .header("XSRF-TOKEN", XYZB.XSRF_token)
// .cookie("laravel_session", XYZB.laravel_session)
// .cookie("XSRF-TOKEN", XYZB.XSRF_token)
// .contentType(JSON).body("{"+Parameter+"}").when()
// .post(serviceURL).thenReturn();
//// System.out.println(re.getStatusCode()+"............................");
//// System.out.println(re.asString());
//// Headers headers=re.getHeaders();
//// System.out.println(headers.toString());
//// System.out.println(re.getSessionId());
//
//// JsonPath jp = re.body().jsonPath();
// if (!"200".equals(re.getStatusCode()+"")) {
// Log.logError("请求返回:" +re.getStatusCode()+",第"+ state + "次。");
// Thread.sleep(1000);
// } else {
// return re;
// }
// }else{
// re = rdu.getRMEnv(tem).given()
//// .header("laravel_session", XYZB.laravel_session)
// .cookie("laravel_session", XYZB.laravel_session)
// .contentType(JSON).body("{"+Parameter+"}").when()
// .post(serviceURL).thenReturn();
//// System.out.println(re.getStatusCode()+"............................");
//// System.out.println(re.asString());
//不带token的post请求
/*public static Response Post_NOToken(HashMap<String, Object> data, String serviceURL) {
// 设置参数格式
String Parameter = (String) data.get("parameter");
String system = MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem = (com.offcn.system.system) (BasicsGM.map.get(system));
Log.logInfo(data.get("Description").toString() + "," + data.get("TCNO").toString() + ",Parameter=" + Parameter);
int state = 0;
Response re = null;
RequestDataUtils rdu = new RequestDataUtils();
while (state < 5) {
try {
state++;
if("/web/member".equals(serviceURL)){
// Cookie cookie1 = Cookie.Builder("username", "John").setComment("comment 1").build();
// Cookie cookie2 = Cookie.Builder("token", 1234).setComment("comment 2").build();
// Cookies cookies = new Cookies(cookie1, cookie2);
System.out.println(XYZB.laravel_session);
System.out.println(XYZB.XSRF_token);
re = rdu.getRMEnv(tem).given()
// .header("laravel_session", XYZB.laravel_session)
// .header("XSRF-TOKEN", XYZB.XSRF_token)
.cookie("laravel_session", XYZB.laravel_session)
.cookie("XSRF-TOKEN", XYZB.XSRF_token)
.contentType(JSON).body("{"+Parameter+"}").when()
.post(serviceURL).thenReturn();
// System.out.println(re.getStatusCode()+"............................");
// System.out.println(re.asString());
// Headers headers=re.getHeaders();
// System.out.println(headers.toString());
// System.out.println(re.getSessionId());
// JsonPath jp = re.body().jsonPath();
// if ("500".equals(jp.getString("status"))) {
// Log.logError("请求返回500," + state + "次。");
// Thread.sleep(1000);
// } else {
// return re;
// }
// }
// } catch (Exception e) {
// e.printStackTrace();
// Log.logError("请求超时," + state + "次。");
// }
// }
// return re;
// }
if (!"200".equals(re.getStatusCode()+"")) {
Log.logError("请求返回:" +re.getStatusCode()+",第"+ state + "次。");
Thread.sleep(1000);
} else {
return re;
}
}else{
re = rdu.getRMEnv(tem).given()
// .header("laravel_session", XYZB.laravel_session)
.cookie("laravel_session", XYZB.laravel_session)
.contentType(JSON).body("{"+Parameter+"}").when()
.post(serviceURL).thenReturn();
// System.out.println(re.getStatusCode()+"............................");
// System.out.println(re.asString());
JsonPath jp = re.body().jsonPath();
if ("500".equals(jp.getString("status"))) {
Log.logError("请求返回500," + state + "次。");
Thread.sleep(1000);
} else {
return re;
}
}
} catch (Exception e) {
e.printStackTrace();
Log.logError("请求超时," + state + "次。");
}
}
return re;
}*/
//不带token的post请求
@SuppressWarnings("static-access")
......@@ -578,6 +513,50 @@ public class RequestDataUtils {
//需要添加token的post，json请求
@SuppressWarnings("static-access")
public static Response Post_cooike2_form_data(HashMap<String, Object> data,
String serviceURL,Map<String, String> jsonAsMap, String cooikeName, String cooikevalue, String cooikeName2, String cooikevalue2) {
// 设置参数格式
String Parameter = (String) data.get("parameter");
String system = MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem = (com.offcn.system.system) (BasicsGM.map.get(system));
Log.logInfo(data.get("Description").toString() + "," + data.get("TCNO").toString() + ",Parameter=" + Parameter);
int state = 0;
Response re = null;
RequestDataUtils rdu = new RequestDataUtils();
while (state < 5) {
try {
state++;
System.out.println(tem.getRM_URI()+tem.getRM_port()+tem.getRM_basePath()+serviceURL);
if("".equals(cooikevalue) && "".equals(cooikevalue2)){
re = rdu.getRMEnv(tem).given()
.params(jsonAsMap)
.when()
.post(serviceURL).thenReturn();
}else{
re = rdu.getRMEnv(tem).given().cookie(cooikeName, cooikevalue).cookie(cooikeName2, cooikevalue2)
.params(jsonAsMap)
.when()
.post(serviceURL).thenReturn();
}
// System.out.println(re.asString());
if (!"200".equals(re.getStatusCode()+"")) {
Log.logError("请求返回:" +re.getStatusCode()+",第"+ state + "次。");
} else {
return re;
}
} catch (Exception e) {
Log.logError("请求超时," + state + "次。");
}
}
return re;
}
//需要添加token的post，json请求
@SuppressWarnings("static-access")
public static Response Post_file(HashMap<String, Object> data, String serviceURL,
String cooikeName, String cooikevalue,String file,String filename) {
// 设置参数格式
......@@ -841,41 +820,41 @@ public class RequestDataUtils {
return re;
}
//get无token请求
// @SuppressWarnings("static-access")
// public static Response Get_Notoken(HashMap<String, Object> data,
// String serviceURL) {
// //设置参数格式
// String parameter= MapUtil.getParameter(data);
//
// String system= MapUtil.getValue("system", data);system = replaceString(system);
// com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
//
//
// parameter=parameter.substring(1, parameter.length()-1);
// Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+",Parameter="+parameter);
//
// int state=0;
// Response re=null;
// RequestDataUtils rdu=new RequestDataUtils();
// while(state<5){
// try {
// state++;
// re = rdu.getRMEnv(tem).given().cookie("laravel_session",XYZB.laravel_session).get(serviceURL).andReturn();
//
//// System.out.println(re.asString());
// if(!"200".equals(re.statusCode()+"")){
// Log.logError("请求返回,"+re.statusCode()+"。");
// }else{
// return re;
// }
// } catch (Exception e) {
// Log.logError("请求超时,"+state+"次。");
// }
// }
// return re;
// }
/*//get无token请求
@SuppressWarnings("static-access")
public static Response Get_Notoken(HashMap<String, Object> data,
String serviceURL) {
//设置参数格式
String parameter= MapUtil.getParameter(data);
String system= MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
parameter=parameter.substring(1, parameter.length()-1);
Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+",Parameter="+parameter);
int state=0;
Response re=null;
RequestDataUtils rdu=new RequestDataUtils();
while(state<5){
try {
state++;
re = rdu.getRMEnv(tem).given().cookie("laravel_session",XYZB.laravel_session).get(serviceURL).andReturn();
// System.out.println(re.asString());
if(!"200".equals(re.statusCode()+"")){
Log.logError("请求返回,"+re.statusCode()+"。");
}else{
return re;
}
} catch (Exception e) {
Log.logError("请求超时,"+state+"次。");
}
}
return re;
}
*/
//get无token请求
@SuppressWarnings("static-access")
public static Response Get_Notoken_NoCookie(HashMap<String, Object> data,
......@@ -896,7 +875,8 @@ public class RequestDataUtils {
while(state<5){
try {
state++;
re = rdu.getRMEnv(tem).given().get(serviceURL).andReturn();
System.out.println(tem.getRM_URI()+serviceURL);
re = rdu.getRMEnv(null).given().get(tem.getRM_URI()+serviceURL).andReturn();
// System.out.println(re.asString());
if(!"200".equals(re.statusCode()+"")){
......@@ -905,46 +885,51 @@ public class RequestDataUtils {
return re;
}
} catch (Exception e) {
e.printStackTrace();
Log.logError("请求超时,"+state+"次。");
}
}
return re;
}
// @SuppressWarnings("static-access")
// public static Response Get_cookie(HashMap<String, Object> data,
// String serviceURL) {
// //设置参数格式
// String parameter= MapUtil.getParameter(data);
//
// String system= MapUtil.getValue("system", data);system = replaceString(system);
// com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
//
//
// parameter=parameter.substring(1, parameter.length()-1);
// Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+",Parameter="+parameter);
//
// int state=0;
// Response re=null;
// RequestDataUtils rdu=new RequestDataUtils();
// while(state<5){
// try {
// state++;
// re = rdu.getRMEnv(tem).given()
// .cookie("laravel_session",XYZB.laravel_session)
// .cookie("XSRF-TOKEN", XYZB.XSRF_token)
// .get(serviceURL).andReturn();
// if(!"200".equals(re.statusCode()+"")){
// Log.logError("请求返回,"+re.statusCode()+"。");
// }else{
// return re;
// }
// } catch (Exception e) {
// Log.logError("请求超时,"+state+"次。");
// }
// }
// return re;
// }
/* @SuppressWarnings("static-access")
public static Response Get_cookie(HashMap<String, Object> data,
String serviceURL) {
//设置参数格式
String parameter= MapUtil.getParameter(data);
String system= MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
parameter=parameter.substring(1, parameter.length()-1);
Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+",Parameter="+parameter);
int state=0;
Response re=null;
RequestDataUtils rdu=new RequestDataUtils();
while(state<5){
try {
state++;
re = rdu.getRMEnv(tem).given()
.cookie("laravel_session",XYZB.laravel_session)
.cookie("XSRF-TOKEN", XYZB.XSRF_token)
.get(serviceURL).andReturn();
if(!"200".equals(re.statusCode()+"")){
Log.logError("请求返回,"+re.statusCode()+"。");
}else{
return re;
}
} catch (Exception e) {
Log.logError("请求超时,"+state+"次。");
}
}
return re;
}*/
public static void main(String[] args) {
Get_two_cookie(null,"","","","","");
}
@SuppressWarnings("static-access")
public static Response Get_two_cookie(HashMap<String, Object> data,
......@@ -959,14 +944,21 @@ public class RequestDataUtils {
String system= MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
parameter=parameter.substring(1, parameter.length()-1);
parameter = parameter.substring(1, parameter.length()-1);
Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+",Parameter="+parameter);
int state=0;
Response re=null;
RequestDataUtils rdu=new RequestDataUtils();
String path="";
if(serviceURL.startsWith("http://")){
tem=null;
path=serviceURL;
}else{
path=tem.getRM_URI()+(tem.getRM_port().equals("")?"":":"+tem.getRM_port())+tem.getRM_basePath()+serviceURL;
}
Log.logInfo(path);
while(state<5){
try {
state++;
......@@ -974,6 +966,7 @@ public class RequestDataUtils {
.cookie(cookie1Name,cookie1value)
.cookie(cookie2Name, cookie2value)
.get(serviceURL).andReturn();
System.out.println(re.asString());
if(!"200".equals(re.statusCode()+"")){
Log.logError("请求返回,"+re.statusCode()+"。");
}else{
......@@ -1005,6 +998,9 @@ public class RequestDataUtils {
int state=0;
Response re=null;
RequestDataUtils rdu=new RequestDataUtils();
if(serviceURL.contains("http:")){
tem=null;
}
while(state<5){
try {
state++;
......@@ -1158,9 +1154,10 @@ public class RequestDataUtils {
//设置参数格式
String parameter= MapUtil.getParameter(data);
String system= MapUtil.getValue("system", data);
system = replaceString(system);
String system= MapUtil.getValue("system", data);system = replaceString(system);
com.offcn.system.system tem=(com.offcn.system.system)(BasicsGM.map.get(system));
parameter=parameter.substring(1, parameter.length()-1);
Log.logInfo(data.get("Description").toString()+","+data.get("TCNO").toString()+",Parameter="+parameter);
// 设置参数格式
......
studycenter_Api_auto_test/src/com/offcn/api/study/process/ticket.java
......@@ -55,11 +55,7 @@ public class ticket extends STUDY implements API {
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
/*phone = MapUtil.getParameter_get(parameter, "phone").trim();
if ((!phone.equals("")) && phone.equals("phone")) {
phone = "1331" + (new Random().nextInt(9000000) + 1000000);
parameter = parameter.replace("phone=phone", "phone="+ phone );
} */
data.put("parameter", parameter);
return data;
}
......@@ -80,7 +76,7 @@ public class ticket extends STUDY implements API {
MyRequest myRequest=new MyRequest();
myRequest.setParameter(parameter);
myRequest.setUrl("http://l.alitest.eoffcn.com/newapi/login.html");
myRequest.setUrl("http://l.t.eoffcn.com/newapi/login.html");
myRequest.setRequest(Request);
//myRequest.setCookies(cookies);
......
studycenter_Api_auto_test/src/com/offcn/api/study/studyapi/moment.java
......@@ -152,7 +152,7 @@ public class moment extends STUDY implements API {
//如果自定义结果包含多个希望结果，也就是有逗号，那么就切割，包含比较。
if(data.get("custom").toString().contains(",")){
String [] strCustomStrings=data.get("custom").toString().split(",");
System.out.println(strCustomStrings.length);
//System.out.println(strCustomStrings.length);
for(int i=0;i<strCustomStrings.length;i++){
if(!json.contains(strCustomStrings[i])){
result = result && false;
......
studycenter_Api_auto_test/src/com/offcn/process/BasicsGM.java
......@@ -12,6 +12,7 @@ import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
......@@ -43,6 +44,18 @@ public abstract class BasicsGM {
public static HashMap<String,String> DynamicParameter = new HashMap<String,String>();//动态公共参数
public static Map<String,Connection> ConnectionsMap=new HashMap<String, Connection>();
public static Map<String,Statement> StatementsMap=new HashMap<String, Statement>();
public static HashMap<Class<?>,Object> Delsql = new HashMap<Class<?>,Object>();//数据库信息源
public static Set<String> Delsqlset = new HashSet<String>();//数据库信息源
public static void setDelSystemSql(Class<?> c,Object object){
String SystemName=c.getSuperclass().getSimpleName();
int count=Delsqlset.size();
Delsqlset.add(SystemName);
if(Delsqlset.size()>count){
Delsql.put(c, object);
}
}
//
// public static boolean isProduct = false;
......@@ -177,6 +190,7 @@ public abstract class BasicsGM {
public void deleteFromDB(String tableName, String key, String value) throws Exception {
String sql = "delete from " + tableName + " where " + key + " like '" + value + "'";
Log.logInfo("sql==="+sql);
int result = stmt.executeUpdate(sql);
Log.logInfo("result==="+result);
if (result == -1) {
......
studycenter_Api_auto_test/src/com/offcn/process/STUDY.java
......@@ -135,7 +135,7 @@ public class STUDY extends BasicsGM{
public void cleann_moment_FromDB() {
try {
deleteFromDB("moment", "id", "565");
deleteFromDB("zxkt.moment", "id", "565");
} catch (Exception e) {
......@@ -148,6 +148,10 @@ public class STUDY extends BasicsGM{
public void cleanMysqlData() {
if (!isClearMysql) {
conn=ConnectionsMap.get("zxkt");//设置默认的连接对象
stmt=StatementsMap.get("zxkt");//设置默认的连接对象
this.cleann_moment_FromDB();
}
}
......
studycenter_Api_auto_test/src/com/offcn/system/MyRequest.java
......@@ -7,10 +7,11 @@ public class MyRequest {
private String Request;
private String Url;
private Map<String, String> Cookies;
private Map<String,String> headers;
private Map<String, String> Headers;
private String Parameter; //json请求方式的参数
private Map<String, String> formParameter;//form_data请求方式的参数、或file请求方式的参数
private String file;
private String fileType;
public String getRequest() {
return Request;
}
......@@ -30,10 +31,10 @@ public class MyRequest {
Cookies = cookies;
}
public Map<String, String> getHeaders() {
return headers;
return Headers;
}
public void setHeaders(Map<String, String> headers) {
this.headers = headers;
Headers = headers;
}
public String getParameter() {
return Parameter;
......@@ -53,19 +54,27 @@ public class MyRequest {
public void setFile(String file) {
this.file = file;
}
public String getFileType() {
return fileType;
}
public void setFileType(String fileType) {
this.fileType = fileType;
}
public MyRequest(String request, String url, Map<String, String> cookies,
Map<String, String> headers, String parameter,
Map<String, String> formParameter, String file) {
Map<String, String> formParameter, String file, String fileType) {
super();
Request = request;
Url = url;
Cookies = cookies;
this.headers = headers;
Headers = headers;
Parameter = parameter;
this.formParameter = formParameter;
this.file = file;
this.fileType = fileType;
}
public MyRequest() {
}
}
studycenter_Api_auto_test/src/com/offcn/test/APITest_study.java
......@@ -3,6 +3,10 @@ import io.restassured.response.Response;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import net.sf.json.JSONObject;
......@@ -23,6 +27,7 @@ import com.offcn.listener.ProcessTestng;
import com.offcn.listener.ResultTestng;
import com.offcn.process.BasicsGM;
import com.offcn.process.STUDY;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Listeners;
import org.testng.annotations.Test;
......@@ -50,10 +55,12 @@ public class APITest_study extends BasicsGM{
Log.logInfo(data.get("TCNO").toString() + " Step " + data.get("Description").toString() + " is running......");
// API obj = new Reflect_api().Reflections(data);
Reflect_api Reflect=new Reflect_api();
c=Reflect.ReflecClass(data);
object = Reflect.ReflecObj(c);
Class<?> c=Reflect.ReflecClass(data);
Object object = Reflect.ReflecObj(c);
API obj = (API)object;
setDelSystemSql(c, object);//保存曾经操作过的系统
BasicsGM.map=new XMLread().getSystem();
......@@ -143,18 +150,19 @@ public class APITest_study extends BasicsGM{
}
}
@AfterClass
public void afterClass() {
//测试结束删除测试所用的数据
Set<Map.Entry<Class<?>,Object>> set=Delsql.entrySet();
Iterator<Entry<Class<?>,Object>> it=set.iterator();
while(it.hasNext()){
Map.Entry<Class<?>,Object> me=it.next();
Class<?> c=me.getKey();
Object object=me.getValue();
this.cleanMysqlData(c,object);
this.CloseMysql();
}
this.CloseMysql();
Log.logInfo("========测试结束========");
}
}
}
studycenter_Api_auto_test/src/resources/system1.xml deleted 100644 → 0
<?xml version="1.0" encoding="UTF-8"?>
<systems>
<system name="gmysx"><!-- 更美预授信 -->
<access_token_uri>http://106.75.5.205:8082/uaa/oauth/token</access_token_uri>
<client_id>bestbuy-acceptance</client_id>
<client_secret>bestbuy-acceptance</client_secret>
<grant_type>client_credentials</grant_type>
<isProduct>N</isProduct>
<RM_URI>http://t1.zuul.pub.puhuifinance.com</RM_URI>
<RM_port>80</RM_port>
<RM_basePath>/bestbuy-pclacceptance/api</RM_basePath>
<redis_URI>10.10.229.48</redis_URI>
<redis_db_index>5</redis_db_index>
<sqlurl>jdbc:mysql://10.10.231.135:3306/huimai_safe?user=root&amp;password=OYLDASuPfbpsEQB6&amp;useUnicode=true&amp;characterEncoding=UTF8</sqlurl>
</system>
<system name="gmdd"><!-- 更美订单 -->
<access_token_uri>http://106.75.5.205:8082/uaa/oauth/token</access_token_uri>
<client_id>bestbuy-acceptance</client_id>
<client_secret>bestbuy-acceptance</client_secret>
<grant_type>client_credentials</grant_type>
<isProduct>N</isProduct>
<RM_URI>http://t1.zuul.pub.puhuifinance.com</RM_URI>
<RM_port>80</RM_port>
<RM_basePath>/bestbuy-pclacceptance/api</RM_basePath>
<redis_URI>10.10.229.48</redis_URI>
<redis_db_index>5</redis_db_index>
<sqlurl>jdbc:mysql://10.10.231.135:3306/huimai_safe?user=root&amp;password=OYLDASuPfbpsEQB6&amp;useUnicode=true&amp;characterEncoding=UTF8</sqlurl>
</system>
<system name="rgxs"><!-- 人工信审 -->
<access_token_uri>http://106.75.5.205:8082/uaa/oauth/token</access_token_uri>
<client_id>bestbuy-acceptance</client_id>
<client_secret>bestbuy-acceptance</client_secret>
<grant_type>client_credentials</grant_type>
<isProduct>N</isProduct>
<RM_URI>http://ut1.zuul.pub.puhuifinance.com</RM_URI>
<RM_port>8765</RM_port>
<RM_basePath>/bestbuy-pclacceptance/api</RM_basePath>
<redis_URI>10.10.229.48</redis_URI>
<redis_db_index>5</redis_db_index>
<sqlurl>jdbc:mysql://10.10.231.135:3306/streaming?user=root&amp;password=OYLDASuPfbpsEQB6&amp;useUnicode=true&amp;characterEncoding=UTF8</sqlurl>
</system>
<system name="bl"><!-- 保理系统 -->
<access_token_uri>http://t.uaa.pub.puhuifinance.com:8082/uaa/oauth/token</access_token_uri>
<client_id>factoring-server</client_id>
<client_secret>factoring-server</client_secret>
<grant_type>client_credentials</grant_type>
<isProduct>N</isProduct>
<RM_URI>http://10.10.121.184</RM_URI>
<RM_port>8888</RM_port>
<RM_basePath>/baoli</RM_basePath>
<redis_URI>10.10.229.48</redis_URI>
<redis_db_index>5</redis_db_index>
<sqlurl>jdbc:mysql://10.10.231.135:3306/streaming?user=root&amp;password=OYLDASuPfbpsEQB6&amp;useUnicode=true&amp;characterEncoding=UTF8</sqlurl>
</system>
<system name="zy"><!-- 自营订单 -->
<!--<access_token_uri>http://106.75.5.205:8082/uaa/oauth/token</access_token_uri>-->
<!--<client_id>bestbuy-acceptance</client_id>-->
<!--<client_secret>bestbuy-acceptance</client_secret>-->
<access_token_uri>http://106.75.5.205:8082/uaa/oauth/token</access_token_uri>
<client_id>gengmei</client_id>
<client_secret>gengmei</client_secret>
<grant_type>client_credentials</grant_type>
<isProduct>N</isProduct>
<RM_URI>http://10.10.155.181</RM_URI>
<RM_port>3000</RM_port>
<RM_basePath></RM_basePath>
<redis_URI>10.10.229.48</redis_URI>
<redis_db_index>5</redis_db_index>
<sqlurl>jdbc:mysql://10.10.231.135:3306/huimai_safe?user=root&amp;password=OYLDASuPfbpsEQB6&amp;useUnicode=true&amp;characterEncoding=UTF8</sqlurl>
</system>
<system name="sh"><!-- 商户微信 -->
<access_token_uri>http://106.75.5.205:8082/uaa/oauth/token</access_token_uri>
<client_id>gengmei</client_id>
<client_secret>gengmei</client_secret>
<grant_type>client_credentials</grant_type>
<isProduct>N</isProduct>
<RM_URI>http://t1.zuul.pub.puhuifinance.com</RM_URI>
<RM_port>80</RM_port>
<RM_basePath>/bestbuy-pclacceptance/api</RM_basePath>
<redis_URI>10.10.229.48</redis_URI>
<redis_db_index>5</redis_db_index>
<sqlurl>jdbc:mysql://10.10.231.135:3306/huimai_safe?user=root&amp;password=OYLDASuPfbpsEQB6&amp;useUnicode=true&amp;characterEncoding=UTF8</sqlurl>
</system>
</systems>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment