Commit 6e6664fb by Li Yongyu

update db

parent 220124a2
......@@ -17,7 +17,6 @@ import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.StringUtils;
import com.offcn.process.BasicsGM;
import com.offcn.process.XYZB;
import static io.restassured.http.ContentType.JSON;
......@@ -89,7 +88,7 @@ public class RequestDataUtils {
}
public static Response Post_NOToken1(String Parameter,String token) {
/*public static Response Post_NOToken1(String Parameter,String token) {
// 设置参数格式
// String Parameter = (String) data.get("parameter");
//
......@@ -128,8 +127,8 @@ public class RequestDataUtils {
}
return re;
}
public static Response Post_NOToken2(String Parameter,String token) {
*/
/*public static Response Post_NOToken2(String Parameter,String token) {
// 设置参数格式
// String Parameter = (String) data.get("parameter");
//
......@@ -167,7 +166,7 @@ public class RequestDataUtils {
}
}
return re;
}
}*/
//不带token的post请求
public static Response Post_Token(String token, String Parameter) {
......
......@@ -13,12 +13,10 @@ import com.offcn.interfaces.API;
*/
public class Reflect_api {
public API Reflections(HashMap<String, Object> data) {
public Class<?> ReflecClass(HashMap<String, Object> data) {
String ClassName = Reflect_api.getRefleserviceUrlxClassName(data);
API obj = null;
Class c = null;
Class<?> c = null;
int count=1;
while(true){
try {
c = Class.forName(ClassName);
......@@ -26,12 +24,8 @@ public class Reflect_api {
}catch (ClassNotFoundException e) {
String serviceUrl = data.get("serviceUrl").toString();
String CalssName_new = serviceUrl.split("/")[serviceUrl.split("/").length - 1];
String system = MapUtil.getValue("system", data);
String classRoute = ReadProperties.GetPropertyByKey(system);
// classRoute=StringUtils.getPathName(classRoute);
ClassName=classRoute+"process."+CalssName_new;
// String system = MapUtil.getValue("system", data);
// String classRoute = ReadProperties.GetPropertyByKey(system);
......@@ -42,29 +36,24 @@ public class Reflect_api {
// String classRoute1 = ReadProperties.GetPropertyByKey("gmysx");
// ClassName=ClassName.replaceAll(classRoute, classRoute1);
// }
}
if(count==3){
Log.logError("Reflect_api,ReflexClass Error,Classname=" + ClassName);
break;
}
}
return c;
}
public Object ReflecObj(Class<?> c){
Object obj = null;
try{
obj = (API) c.newInstance();
obj = c.newInstance();
}catch (InstantiationException e) {
Log.logError("Reflect_api,instantiation Error,Classname="
+ ClassName);
e.printStackTrace();
} catch (IllegalAccessException e) {
Log.logError("Reflect_api,Reflection class is not public Error,Classname="
+ ClassName);
e.printStackTrace();
}
return obj;
}
// 获得数据中serviceUrl所对应的类名
......@@ -88,9 +77,8 @@ public class Reflect_api {
// return classRoute+ classReflectName;
// }
// }
if("nwn".equals(system)){
String classReflectName = ReadProperties.GetPropertyByClassName(serviceUrl);
if("xyzb".equals(system)){
String classReflectName = ReadProperties.GetPropertyByClassName(serviceUrl,system);
if ( classReflectName!=null ) {
return classRoute+ classReflectName;
}
......
......@@ -37,7 +37,7 @@ public class XMLread {
try {
SAXReader saxReader = new SAXReader();
document = saxReader.read(new File("src/resources/system.xml")); // 读取XML文件,获得document对象
document = saxReader.read(new File("src/resources/system.xml")); // 读取XML文件,获得document对象DatabaseSql.xml
// 获取根节点
Element root = document.getRootElement();
// 获取根节点下的子节点
......@@ -61,6 +61,40 @@ public class XMLread {
}
return map;
}
public Map<String, Object> getDatabaseSql(){
Document document = null;
Object obj=null;
Method met=null;
Map<String,Object> map=new HashMap<String,Object>();
try {
SAXReader saxReader = new SAXReader();
document = saxReader.read(new File("src/resources/DatabaseSql.xml")); // 读取XML文件,获得document对象DatabaseSql.xml
// 获取根节点
Element root = document.getRootElement();
// 获取根节点下的子节点
for (Iterator i = root.elementIterator(); i.hasNext();) {
// 将每个子节点赋给el
Element el = (Element) i.next();
// 如果节点的名称为“system”,system元素属性name=参数// && systemName.equals(el.attribute("name").getValue())
if ("Database".equals(el.getName())) {// 获取节点元素的名称
Class c=Class.forName("com.offcn.system.sql");
obj=(Object) c.newInstance();
for (Iterator it = el.elementIterator(); it.hasNext();) {
Element elchild = (Element) it.next();
met=c.getDeclaredMethod(getMethodName(elchild.getName()), String.class);
met.invoke(obj, elchild.getText());
map.put(el.attribute("name").getValue(), obj);
}
}
}
} catch (Exception ex) {
ex.printStackTrace();
}
return map;
}
//获取注入得方法名
private String getMethodName(String str){
String s="set"+str.substring(0,1).toUpperCase()+str.substring(1,str.length());
......
......@@ -23,7 +23,7 @@ import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.STUDY;
import com.offcn.process.TK;
import com.offcn.system.MyRequest;
import com.offcn.TestUnti.ListUtil;
......
......@@ -23,7 +23,6 @@ import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.STUDY;
import com.offcn.process.TK;
import com.offcn.system.MyRequest;
import com.offcn.TestUnti.ListUtil;
......@@ -165,18 +164,20 @@ public class login extends STUDY implements API {
if (!isProduct) {
Token = jp.getString("data.user_info.token");
System.out.println( "Token=========" + Token);
/*template_id=jp.getString("data.id").substring(0,jp.getString("data.id").length());
System.out.println("template_id====="+ template_id );
// System.out.println("datavalue=======" + jp.getString("data.moment[0].tag_name"));
try {
String sql="SELECT deleted_at FROM `n_package` WHERE id = " + package_id;
//SELECT id FROM n_template ORDER BY id DESC LIMIT 1
stmt=StatementsMap.get("nwn"); //切库
String sql="SELECT username FROM `n_admin` WHERE id = " + 118;
ResultSet rs_bankcard = this.sqlFromDB(sql);
stmt=StatementsMap.get("zxkt"); //切回默认
rs_bankcard.last();
System.out.println("after deleted_packate ============"+ rs_bankcard.getString("deleted_at"));
if(rs_bankcard.getString("deleted_at").contains("2019") )
{
System.out.println(rs_bankcard.getString("username"));
if(rs_bankcard.getString("username").contains("马增礼"))
{
System.out.println("db select successful ");
}else {
result = result && false;
......@@ -188,7 +189,7 @@ public class login extends STUDY implements API {
result = result && false;
failReason = failReason + "cannot verify template_id info in DB;";
e.printStackTrace();
}*/
}
}
......
......@@ -23,7 +23,7 @@ import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.STUDY;
import com.offcn.process.TK;
import com.offcn.system.MyRequest;
import com.offcn.TestUnti.ListUtil;
......@@ -48,7 +48,6 @@ public class moment extends STUDY implements API {
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
......@@ -179,18 +178,16 @@ public class moment extends STUDY implements API {
//是否验证数据库
if (!isProduct) {
/*template_id=jp.getString("data.id").substring(0,jp.getString("data.id").length());
System.out.println("template_id====="+ template_id );
System.out.println("datavalue=======" + jp.getString("data.moment[0].tag_name"));
try {
String sql="SELECT deleted_at FROM `n_package` WHERE id = " + package_id;
String sql="SELECT name FROM `moment_tag` WHERE id = " + 43;
//SELECT id FROM n_template ORDER BY id DESC LIMIT 1
ResultSet rs_bankcard = this.sqlFromDB(sql);
rs_bankcard.last();
System.out.println("after deleted_packate ============"+ rs_bankcard.getString("deleted_at"));
if(rs_bankcard.getString("deleted_at").contains("2019") )
{
if(rs_bankcard.getString("name").contains("早安")||jp.getString("data.user_info.name").contains("早安") )
{
System.out.println("db select successful ");
}else {
result = result && false;
......@@ -202,7 +199,7 @@ public class moment extends STUDY implements API {
result = result && false;
failReason = failReason + "cannot verify template_id info in DB;";
e.printStackTrace();
}*/
}
}
......
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.TestUnti.VerificationMethod;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 用户绑定或修改手机号
*
* @author puhui
*
*/
public class addOrEditPhone extends TK implements API {
public String parameter;//参数集合
public String user_id;//用户id
public String phone;//手机
@Override
public void initialize(HashMap<String, Object> data) {
if (!isProduct && data.get("CleanDB").toString().contains("Y")) {
cleanUser_FromDB();//清除注册用户根据user_id
}
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
user_id = MapUtil.getParameter(parameter, "user_id").trim();
phone = MapUtil.getParameter(parameter, "phone").trim();
if ((!user_id.equals("")) && user_id.equals("code")) {
user_id=ListUtil.getListValue(user_idList,0);
parameter = parameter.replace("\"user_id\":code", "\"user_id\":\""+ user_id + "\"");
}
if ((!phone.equals("")) && phone.equals("random")) {
phone="1391"+(new Random().nextInt(9000000)+ 1000000);
parameter = parameter.replace("\"open_id\":random", "\"open_id\":\""+ phone + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_NOtokenNOcookie(data, Url);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
// System.out.println(jp.getString("message"));
// String msg=StringUtils.decodeUnicode(getMsg(re));
String msg=jp.getString("message");
String code=jp.getString("retcode");
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("接口响应成功!".equals(msg)){
phoneNeb=phone;
//是否验证数据库
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" t_user u ",
" u.user_id = '" + user_id + "' ");
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
String act_phone=rs_bankcard.getString("phone").equals("null ")?"null":rs_bankcard.getString("phone");
parameter = MapUtil.getValue("parameter", data);
phone = MapUtil.getParameter(parameter, "phone").trim();
phone = MapUtil.killQuotes(phone, "\"");
if(phone.length()<60){
if(!(phone.equals(act_phone))){
result = result && false;
failReason = failReason + "t_user info phone is not in DB;";
}
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_user info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 用户地区操作
*
* @author puhui
*
*/
public class area extends TK implements API {
public String parameter;//参数集合
public String type;//操作类型
public String user_id;//用户id
public String province_id;//省id
public String id;//t_exam_area表的主键,用于删除记录
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
user_id = MapUtil.getParameter(parameter, "user_id").trim();
type = MapUtil.getParameter(parameter, "type").trim();
id = MapUtil.getParameter(parameter, "id").trim();
if ((!user_id.equals("")) && user_id.equals("code")) {
user_id=ListUtil.getListValue(user_idList,0);
parameter = parameter.replace("\"user_id\":code", "\"user_id\":\""+ user_id + "\"");
}
if ((!id.equals("")) && id.equals("code")) {
id=ListUtil.getListValue(t_exam_area,0);
parameter = parameter.replace("\"id\":code", "\"id\":\""+ id + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_token(data, Url,tk_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("接口响应成功!".equals(msg) && type.contains("add")){
String item_id=jp.getString("data.item_id");
item_id = MapUtil.killQuotes(item_id, "\"");
String name=jp.getString("data.name");
name = MapUtil.killQuotes(name, "\"");
//是否验证数据库
if (!isProduct) {
province_id = MapUtil.getParameter(parameter, "province_id").trim();
province_id = MapUtil.killQuotes(province_id, "\"");
try {
String sql="select t.item_id , e.name , e.province_id , ea.id ,ea.user_id from"
+ " t_exam_item t, t_exam_area ea, "
+ "( select * from t_exam te where province_id='"+province_id+"' "
+ "and is_delete='0' ) e where "
+ "t.status='2' and t.exam_id=e.id and ea.user_id='"+user_id+"' "
+ "and ea.if_delete='0' and ea.province_id='"+province_id+"'";
ResultSet rs_bankcard = this.sqlFromDB(sql);
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
String act_item_id=rs_bankcard.getString("item_id").equals("null ")?"null":rs_bankcard.getString("item_id");
String act_name=rs_bankcard.getString("name").equals("null ")?"null":rs_bankcard.getString("name");
// String act_province_id=rs_bankcard.getString("province_id").equals("null ")?"null":rs_bankcard.getString("platform");
// String act_user_id=rs_bankcard.getString("user_id").equals("null ")?"null":rs_bankcard.getString("device_id");
String act_id=rs_bankcard.getString("id").equals("null ")?"null":rs_bankcard.getString("id");
t_exam_area.add(act_id);//保存地区,以后需要删除的必须参数
if(!(item_id.equals(act_item_id))){
result = result && false;
failReason = failReason + "t_exam_area info phone is not in DB;";
}
if(!(name.equals(act_name))){
result = result && false;
failReason = failReason + "t_exam_area info system is not in DB;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_exam_area info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.TestUnti.VerificationMethod;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 个人中心绑定第三方账号接口
*
* @author puhui
*
*/
public class bindThirdLoginByUserId extends TK implements API {
public String parameter;//参数集合
public String open_id;//第三方登录openId
public String nickname;//昵称
public String avatar;//第三方登录用户头像
public String union_id;//微信登录的unionId(仅在微信登录时必填)
public String login_type;//第三方登录类型(当前登录方式:phone手机登录;weibo微博登录;weixin微信登录;qq腾讯登录)
public String user_id;//用户id
@Override
public void initialize(HashMap<String, Object> data) {
if (!isProduct && data.get("CleanDB").toString().contains("Y")) {
cleanUser_FromDB();//清除注册用户根据user_id
}
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
union_id = MapUtil.getParameter(parameter, "union_id").trim();
open_id = MapUtil.getParameter(parameter, "open_id").trim();
user_id = MapUtil.getParameter(parameter, "user_id").trim();
if ((!user_id.equals("")) && user_id.equals("code")) {
user_id=ListUtil.getListValue(user_idList,0);
parameter = parameter.replace("\"user_id\":code", "\"user_id\":\""+ user_id + "\"");
}
if ((!union_id.equals("")) && union_id.equals("code")) {
union_id=union_id_str;
parameter = parameter.replace("\"union_id\":code", "\"union_id\":\""+ union_id + "\"");
}
if ((!open_id.equals("")) && open_id.equals("code")) {
open_id=open_id_str;
parameter = parameter.replace("\"open_id\":code", "\"open_id\":\""+ open_id + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_NOtokenNOcookie(data, Url);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
// System.out.println(jp.getString("message"));
// String msg=StringUtils.decodeUnicode(getMsg(re));
String msg=jp.getString("message");
String code=jp.getString("retcode");
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("注册成功".equals(msg) || "登录成功".equals(msg)){
String user_id=jp.getString("data.userinfo.user_id");
user_id = MapUtil.killQuotes(user_id, "\"");
user_idList.add(user_id);
String data_login_type=jp.getString("data.userinfo.login_type");
data_login_type = MapUtil.killQuotes(data_login_type, "\"");
data_login_type=data_login_type.equals("null ")?"null":data_login_type;
String data_nickname=jp.getString("data.userinfo."+data_login_type+"_nickname");
data_nickname = MapUtil.killQuotes(data_nickname, "\"");
data_nickname=data_nickname.equals("null ")?"null":data_nickname;
String data_avatar=jp.getString("data.userinfo.avatar");
data_avatar = MapUtil.killQuotes(data_avatar, "\"");
data_avatar=data_avatar.equals("null ")?"null":data_avatar;
//这里~!!!
//是否验证数据库
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" t_user u ",
" u.user_id = '" + user_id + "' ");
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
String act_union_id=rs_bankcard.getString("union_id").equals("null ")?"null":rs_bankcard.getString("union_id");
String act_weibo_nickname=rs_bankcard.getString("weibo_nickname").equals("null ")?"null":rs_bankcard.getString("weibo_nickname");
String act_qq_nickname=rs_bankcard.getString("qq_nickname").equals("null ")?"null":rs_bankcard.getString("qq_nickname");
String act_weixin_nickname=rs_bankcard.getString("weixin_nickname").equals("null ")?"null":rs_bankcard.getString("weixin_nickname");
String act_login_type=rs_bankcard.getString("login_type").equals("null ")?"null":rs_bankcard.getString("login_type");
String act_avatar=rs_bankcard.getString("avatar").equals("null ")?"null":rs_bankcard.getString("avatar");
String act_qq_id=rs_bankcard.getString("qq_id").equals("null ")?"null":rs_bankcard.getString("qq_id");
String act_weixin_id=rs_bankcard.getString("weixin_id").equals("null ")?"null":rs_bankcard.getString("weixin_id");
String act_weibo_id=rs_bankcard.getString("weibo_id").equals("null ")?"null":rs_bankcard.getString("weibo_id");
String act_open_id="";
String act_nickname="";
if("qq".equals(act_login_type)){
act_open_id=act_qq_id;
act_nickname=act_qq_nickname;
}else if("weibo".equals(act_login_type)){
act_open_id=act_weibo_id;
act_nickname=act_weibo_nickname;
}else if("weixin".equals(act_login_type)){
act_open_id=act_weixin_id;
act_nickname=act_weixin_nickname;
}
// System.out.println((dataPhone.equals(act_phone)));
// System.out.println((dataPhone.equals(phone)));
parameter = MapUtil.getValue("parameter", data);
union_id = MapUtil.getParameter(parameter, "union_id").trim();
union_id = MapUtil.killQuotes(union_id, "\"");
open_id = MapUtil.getParameter(parameter, "open_id").trim();
open_id = MapUtil.killQuotes(open_id, "\"");
nickname = MapUtil.getParameter(parameter, "nickname").trim();
nickname = MapUtil.killQuotes(nickname, "\"");
login_type = MapUtil.getParameter(parameter, "login_type").trim();
login_type = MapUtil.killQuotes(login_type, "\"");
avatar = MapUtil.getParameter(parameter, "avatar").trim();
avatar = MapUtil.killQuotes(avatar, "\"");
if(union_id.length()<60){
if(!(union_id.equals(act_union_id))){
result = result && false;
failReason = failReason + "t_user info union_id is not in DB;";
}
}
if(nickname.length()<60){
if(!(data_nickname.equals(act_nickname) && (data_nickname.equals(nickname)))){
result = result && false;
failReason = failReason + "t_user info nickname is not in DB;";
}
}
if(login_type.length()<60){
if(!(data_login_type.equals(act_login_type) && (data_login_type.equals(login_type)))){
result = result && false;
failReason = failReason + "t_user info login_type is not in DB;";
}
}
if(avatar.length()<60){
if(!(data_avatar.equals(act_avatar) && (data_avatar.equals(avatar)))){
result = result && false;
failReason = failReason + "t_user info avatar is not in DB;";
}
}
if(open_id.length()<60){
if(!(open_id.equals(act_open_id))){
result = result && false;
failReason = failReason + "t_user info open_id is not in DB;";
}
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_user info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MySqlUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.TestUnti.VerificationMethod;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* .第三方登录接口绑定手机号
*
* @author puhui
*
*/
public class bindUserByPhone extends TK implements API {
public String parameter;//参数集合
public String user_id;//用户id
public String phone;//用户手机号
public String code;//手机验证码
public String login_type;//第三方登录方式
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
phone = MapUtil.getParameter(parameter, "phone").trim();
code = MapUtil.getParameter(parameter, "code").trim();
user_id = MapUtil.getParameter(parameter, "user_id").trim();
if ((!user_id.equals("")) && user_id.equals("code")) {
user_id=ListUtil.getListValue(user_idList,0);
parameter = parameter.replace("\"user_id\":code", "\"user_id\":\""+ user_id + "\"");
}
if ((!phone.equals("")) && phone.equals("code")) {
phone=phoneNeb;
parameter = parameter.replace("\"phone\":code", "\"phone\":\""+ phone + "\"");
}
if ((!code.equals("")) && code.equals("code")) {
code=phone_code;
parameter = parameter.replace("\"code\":code", "\"code\":\""+ code + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_token(data, Url,tk_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("绑定成功".equals(msg)){
String dataPhone=jp.getString("data.phone");
dataPhone = MapUtil.killQuotes(dataPhone, "\"");
String datalogin_type=jp.getString("data.login_type");
datalogin_type = MapUtil.killQuotes(datalogin_type, "\"");
String token=jp.getString("data.token");
tk_token = MapUtil.killQuotes(token, "\"");//保存token
//是否验证数据库
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" t_user u ",
" u.user_id = '" + user_id + "' ");
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
phone = MapUtil.killQuotes(phone, "\"");
phoneNeb=phone;
String act_phone=rs_bankcard.getString("phone").equals("null ")?"null":rs_bankcard.getString("phone");
String act_login_type=rs_bankcard.getString("login_type").equals("null ")?"null":rs_bankcard.getString("login_type");
if(phone.length()<60){
if(!(dataPhone.equals(act_phone) && (dataPhone.equals(phone)))){
result = result && false;
failReason = failReason + "t_user info phone is not in DB;";
}
}
if(login_type.length()<60){
if(!(datalogin_type.equals(act_login_type) && (datalogin_type.equals(login_type)))){
result = result && false;
failReason = failReason + "t_user info system is not in DB;";
}
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_user info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MySqlUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 校验验证码
*
* @author puhui
*
*/
public class checkCode extends TK implements API {
public String parameter;//参数集合
public String phone;//用户id
public String code;//验证码
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
phone = MapUtil.getParameter(parameter, "phone").trim();
code = MapUtil.getParameter(parameter, "code").trim();
if ((!phone.equals("")) && phone.equals("code")) {
phone=phoneNeb;
parameter = parameter.replace("\"phone\":code", "\"phone\":\""+ phone + "\"");
}
if ((!code.equals("")) && code.equals("code")) {
code=phone_code;
parameter = parameter.replace("\"code\":code", "\"code\":\""+ code + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_token(data, Url,tk_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 检测手机号是否已经被注册
*
* @author puhui
*
*/
public class checkUserPhoneIfExist extends TK implements API {
public String parameter;//参数集合
public String phone;//手机号
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
phone = MapUtil.getParameter(parameter, "phone").trim();
if ((!phone.equals("")) && phone.equals("code")) {
parameter = parameter.replace("\"phone\":code", "\"phone\":\""+ phoneNeb + "\"");
}
phone = MapUtil.getParameter(parameter, "phone").trim();
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_NOtokenNOcookie(data, Url);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("接口响应成功".equals(msg)){
String if_exist=jp.getString("data.if_exist");
//是否验证数据库
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" t_user u ",
" u.phone = '" + phone + "' ");
rs_bankcard.last();
String act_phone=rs_bankcard.getString("phone");
if("1".equals(if_exist)){//if_exist=1时代表改手机号已存在
if (!phone.equals(act_phone)) {
result = result && false;
failReason = failReason + "t_user info is not in DB;";
}
}else{
if (phone.equals(act_phone)) {
result = result && false;
failReason = failReason + "t_user info is in DB;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_user info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.util.HashMap;
import com.offcn.TestUnti.ListUtil;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
/**
*
* @author wufeifei
* 修改用户名称
*
*/
public class editUserName extends TK implements API {
public String parameter;//参数集合
public String user_id;//用户id
public String nickname;//用户名
@Override
public void initialize(HashMap<String, Object> data) {
// TODO Auto-generated method stub
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// TODO Auto-generated method stub
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
user_id = MapUtil.getParameter(parameter, "user_id").trim();
nickname = MapUtil.getParameter(parameter, "nickname").trim();
nickname = MapUtil.killQuotes(nickname, "\"");
if ((!user_id.equals("")) && user_id.equals("code")) {
user_id = ListUtil.getListValue(user_idList,0);
parameter = parameter.replace("\"user_id\":code", "\"user_id\":\""+ user_id + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
// TODO Auto-generated method stub
Response re = RequestDataUtils.Post_token(data, Url, tk_token);
System.out.println(re.asString());
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
// TODO Auto-generated method stub
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("接口响应成功!".equals(msg)){
//是否验证数据库
if(!isProduct){
try {
String sql="SELECT nickname FROM t_user where user_id ='"+user_id+"'";
ResultSet rs_bankcard = this.sqlFromDB(sql);
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
String act_nickname=rs_bankcard.getString("nickname").equals("null ")?"null":rs_bankcard.getString("nickname");
String date_nicknameString = jp.getString("data.nickname");
if(!(date_nicknameString.equals(act_nickname) && date_nicknameString.equals(nickname))){
result = result && false;
failReason = failReason + "nickname is not in DB;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_user info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MySqlUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 获取验证码
*
* @author puhui
*
*/
public class getCode extends TK implements API {
public String parameter;//参数集合
public String phone;//用户手机号
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
phone = MapUtil.getParameter(parameter, "phone").trim();
if ((!phone.equals("")) && phone.equals("random")) {
phone="1391"+(new Random().nextInt(9000000)+ 1000000);
parameter = parameter.replace("\"phone\":random", "\"phone\":\""+ phone + "\"");
}
if ((!phone.equals("")) && phone.equals("code")) {
phone=phoneNeb;
parameter = parameter.replace("\"phone\":code", "\"phone\":\""+ phone + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_token(data, Url,tk_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("验证码发送正常请求".equals(msg)){
//是否验证数据库
if (!isProduct) {
parameter = MapUtil.getValue("parameter", data);
phone = MapUtil.getParameter(parameter, "phone").trim();
phone = MapUtil.killQuotes(phone, "\"");
phoneNeb=phone;
String data_code=jp.getString("data.code");
phone_code=data_code;
try {
ResultSet rs_bankcard = this.selectFromDB(
" t_code u ",
" u.phone = '" + phone + "'");
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
String act_phone=rs_bankcard.getString("phone").equals("null ")?"null":rs_bankcard.getString("phone");
String act_code=rs_bankcard.getString("code").equals("null ")?"null":rs_bankcard.getString("code");
if(!(act_phone.equals(phone))){
result = result && false;
failReason = failReason + "phone is not in DB;";
}
if(!(data_code.equals(act_code))){
result = result && false;
failReason = failReason + "code is not in DB;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "not find t_code in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MySqlUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 用户地区操作
*
* @author puhui
*
*/
public class getUserArea extends TK implements API {
public String parameter;//参数集合
public String user_id;//用户id
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
user_id = MapUtil.getParameter(parameter, "user_id").trim();
if ((!user_id.equals("")) && user_id.equals("code")) {
user_id=ListUtil.getListValue(user_idList,0);
parameter = parameter.replace("\"user_id\":code", "\"user_id\":\""+ user_id + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_token(data, Url,tk_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("接口响应成功!".equals(msg)){
List<Object> examList=jp.getList("data.exam");
//是否验证数据库
if (!isProduct) {
try {
String sql="select t.name as name , e.id as id, e.item_id as item_id, "
+ "e.exam_id as exam_id, e.province_id as province_id, e.if_default as if_default"
+ " from t_exam t, ( select * from t_exam_area where user_id='"+user_id+"' ) e "
+ "where e.exam_id=t.id ";
ResultSet rs_bankcard = this.sqlFromDB(sql);
List<Map<String, Object>> list=MySqlUtil.ResultSetToList(rs_bankcard);
String [] str={"id","name","item_id","exam_id","province_id","if_default"};
List<Object> ListObject= MapUtil.getStringList(list,str);
for(int i=0;i<ListObject.size();i++){
String rse=ListObject.get(i).toString();
// System.out.println(examList.toString().contains((rse.equals("false")?"0":"1")));
if(!(examList.toString().contains((rse.equals("false")?"0":"1")))){
result = result && false;
failReason = failReason + "t_exam_area info system is not in DB;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_exam_area info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* app登录
*
* @author puhui
*
*/
public class login extends TK implements API {
public String parameter;//参数集合
public String phone;//手机号
public String passwd;//密码
public String system;//手机系统信息
public String platform;//手机平台
public String version;//版本号
public String device_id;//设备号
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
phone = MapUtil.getParameter(parameter, "phone").trim();
if ((!phone.equals("")) && phone.equals("code")) {
parameter = parameter.replace("\"phone\":code", "\"phone\":\""+ phoneNeb + "\"");
}
phone = MapUtil.getParameter(parameter, "phone").trim();
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_NOtokenNOcookie(data, Url);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("接口响应成功!".equals(msg)){
String user_id=jp.getString("data.userinfo.user_id");
user_id = MapUtil.killQuotes(user_id, "\"");
String dataPhone=jp.getString("data.userinfo.phone");
dataPhone = MapUtil.killQuotes(dataPhone, "\"");
String dataSystem=jp.getString("data.userinfo.system");
dataSystem = MapUtil.killQuotes(dataSystem, "\"");
String dataPlatform=jp.getString("data.userinfo.platform");
dataPlatform = MapUtil.killQuotes(dataPlatform, "\"");
String dataVersion=jp.getString("data.userinfo.version");
dataVersion = MapUtil.killQuotes(dataVersion, "\"");
String token=jp.getString("data.token").trim();
tk_token = MapUtil.killQuotes(token, "\"");//保存token
user_idList.add(user_id);//保存user_id
//是否验证数据库
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" t_user u ",
" u.user_id = '" + user_id + "' ");
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
phone = MapUtil.killQuotes(phone, "\"");
phoneNeb=phone;
parameter = MapUtil.getValue("parameter", data);
system = MapUtil.getParameter(parameter, "system");
system = MapUtil.killQuotes(system, "\"");
platform = MapUtil.getParameter(parameter, "platform");
platform = MapUtil.killQuotes(platform, "\"");
version = MapUtil.getParameter(parameter, "version");
version = MapUtil.killQuotes(version, "\"");
device_id = MapUtil.getParameter(parameter, "device_id");
device_id = MapUtil.killQuotes(device_id, "\"");
passwd = MapUtil.getParameter(parameter, "passwd");
passwd = MapUtil.killQuotes(passwd, "\"");
String act_phone=rs_bankcard.getString("phone").equals("null ")?"null":rs_bankcard.getString("phone");
String act_system=rs_bankcard.getString("system").equals("null ")?"null":rs_bankcard.getString("system");
String act_platform=rs_bankcard.getString("platform").equals("null ")?"null":rs_bankcard.getString("platform");
String act_version=rs_bankcard.getString("version").equals("null ")?"null":rs_bankcard.getString("version");
String act_device_id=rs_bankcard.getString("device_id").equals("null ")?"null":rs_bankcard.getString("device_id");
String act_passwd=rs_bankcard.getString("passwd").equals("null ")?"null":rs_bankcard.getString("passwd");
if(!(dataPhone.equals(act_phone) || !(dataPhone.equals(phone)))){
result = result && false;
failReason = failReason + "t_user info phone is not in DB;";
}
if(!(dataSystem.equals(act_system) || !(dataSystem.equals(system)))){
result = result && false;
failReason = failReason + "t_user info system is not in DB;";
}
if(!(dataPlatform.equals(act_platform) || !(dataPlatform.equals(platform)))){
result = result && false;
failReason = failReason + "t_user info platform is not in DB;";
}
if(!(dataVersion.equals(act_version) || !(dataVersion.equals(version)))){
result = result && false;
failReason = failReason + "t_user info version is not in DB;";
}
if(!(act_device_id.equals(device_id))){
result = result && false;
failReason = failReason + "t_user info device_id is not in DB;";
}
if(!(act_passwd.equals(passwd))){
result = result && false;
failReason = failReason + "t_user info passwd is not in DB;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_user info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.TestUnti.VerificationMethod;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 注册
*
* @author puhui
*
*/
public class register extends TK implements API {
public String parameter;//参数集合
public String phone;//手机号
public String passwd;//密码
public String system;//手机系统信息
public String platform;//手机平台
public String version;//版本号
public String device_id;//设备号
@Override
public void initialize(HashMap<String, Object> data) {
if (!isProduct && data.get("CleanDB").toString().contains("Y")) {
cleanUser_FromDB();//清除注册用户根据user_id
}
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
phone = MapUtil.getParameter(parameter, "phone").trim();
if ((!phone.equals("")) && phone.equals("code")) {
parameter = parameter.replace("\"phone\":code", "\"phone\":\""+ phoneNeb + "\"");
}
phone = MapUtil.getParameter(parameter, "phone").trim();
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_NOtokenNOcookie(data, Url);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
// System.out.println(jp.getString("message"));
// String msg=StringUtils.decodeUnicode(getMsg(re));
String msg=jp.getString("message");
String code=jp.getString("retcode");
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("注册成功".equals(msg)){
String user_id=jp.getString("data.userinfo.user_id");
user_id = MapUtil.killQuotes(user_id, "\"");
user_idList.add(user_id);
String dataPhone=jp.getString("data.userinfo.phone");
dataPhone = MapUtil.killQuotes(dataPhone, "\"");
String dataSystem=jp.getString("data.userinfo.system");
dataSystem = MapUtil.killQuotes(dataSystem, "\"");
String dataPlatform=jp.getString("data.userinfo.platform");
dataPlatform = MapUtil.killQuotes(dataPlatform, "\"");
String dataVersion=jp.getString("data.userinfo.version");
dataVersion = MapUtil.killQuotes(dataVersion, "\"");
String token=jp.getString("data.token");
tk_token = MapUtil.killQuotes(token, "\"");//保存token
//是否验证数据库
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" t_user u ",
" u.user_id = '" + user_id + "' ");
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
phone = MapUtil.killQuotes(phone, "\"");
phoneNeb=phone;
parameter = MapUtil.getValue("parameter", data);
system = MapUtil.getParameter(parameter, "system");
system=VerificationMethod.VerificationField(system);
platform = MapUtil.getParameter(parameter, "platform");
platform=VerificationMethod.VerificationField(platform);
version = MapUtil.getParameter(parameter, "version");
version=VerificationMethod.VerificationField(version);
device_id = MapUtil.getParameter(parameter, "device_id");
device_id=VerificationMethod.VerificationField(device_id);
passwd = MapUtil.getParameter(parameter, "passwd");
passwd=VerificationMethod.VerificationField(passwd);
// String act_phone=rs_bankcard.getString("phone").equals("")?"null":rs_bankcard.getString("phone");
String act_phone=rs_bankcard.getString("phone");
// String act_system=rs_bankcard.getString("system").equals("")?"null":rs_bankcard.getString("system");
String act_system=rs_bankcard.getString("system");
// String act_platform=rs_bankcard.getString("platform").equals("")?"null":rs_bankcard.getString("platform");
String act_platform=rs_bankcard.getString("platform");
// String act_version=rs_bankcard.getString("version").equals("")?"null":rs_bankcard.getString("version");
String act_version=rs_bankcard.getString("version");
// String act_device_id=rs_bankcard.getString("device_id").equals("")?"null":rs_bankcard.getString("device_id");
String act_device_id=rs_bankcard.getString("device_id");
// String act_passwd=rs_bankcard.getString("passwd").equals("")?"null":rs_bankcard.getString("passwd");
String act_passwd=rs_bankcard.getString("passwd");
// System.out.println((dataPhone.equals(act_phone)));
// System.out.println((dataPhone.equals(phone)));
if(phone.length()<60){
if(!(dataPhone.equals(act_phone) && (dataPhone.equals(phone)))){
result = result && false;
failReason = failReason + "t_user info phone is not in DB;";
}
}
if(system.length()<60){
if(!(dataSystem.equals(act_system) && (dataSystem.equals(system)))){
result = result && false;
failReason = failReason + "t_user info system is not in DB;";
}
}
if(platform.length()<60){
if(!(dataPlatform.equals(act_platform) && (dataPlatform.equals(platform)))){
result = result && false;
failReason = failReason + "t_user info platform is not in DB;";
}
}
if(version.length()<60){
if(!(dataVersion.equals(act_version) && (dataVersion.equals(version)))){
result = result && false;
failReason = failReason + "t_user info version is not in DB;";
}
}
if(device_id.length()<60){
if(!(act_device_id.equals(device_id))){
result = result && false;
failReason = failReason + "t_user info device_id is not in DB;";
}
}
if(passwd.length()<60){
if(!(act_passwd.equals(passwd))){
result = result && false;
failReason = failReason + "t_user info passwd is not in DB;";
}
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify t_user info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.tk;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MySqlUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.TK;
import com.offcn.TestUnti.ListUtil;
import net.sf.json.JSONObject;
/**
* 修改默认地区
*
* @author puhui
*
*/
public class setDefaultArea extends TK implements API {
public String parameter;//参数集合
public String user_id;//用户id
public String area_id;//用户id
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
user_id = MapUtil.getParameter(parameter, "user_id").trim();
area_id = MapUtil.getParameter(parameter, "area_id").trim();
if ((!user_id.equals("")) && user_id.equals("code")) {
user_id=ListUtil.getListValue(user_idList,0);
parameter = parameter.replace("\"user_id\":code", "\"user_id\":\""+ user_id + "\"");
}
if ((!area_id.equals("")) && area_id.equals("code")) {
area_id=ListUtil.getListValue(t_exam_area,0);
parameter = parameter.replace("\"area_id\":code", "\"area_id\":\""+ area_id + "\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_token(data, Url,tk_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(getMsg(re));
String code=getCode(re);
if ((data.get("code") != null ) && (code != null) && (!code.equals(data.get("code").toString()))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null) && (msg != null) && (!msg.equals(data.get("msg").toString()))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("接口响应成功!".equals(msg)){
//是否验证数据库
if (!isProduct) {
user_id = MapUtil.killQuotes(user_id, "\"");
area_id = MapUtil.killQuotes(area_id, "\"");
try {
ResultSet rs_bankcard = this.selectFromDB(
" t_exam_area u ",
" u.if_default = '" + 1 + "'");
rs_bankcard.last();
if(rs_bankcard.getRow()>=1){
String act_user_id=rs_bankcard.getString("user_id").equals("null ")?"null":rs_bankcard.getString("user_id");
String act_id=rs_bankcard.getString("id").equals("null ")?"null":rs_bankcard.getString("id");
if(!(user_id.equals(act_user_id))){
result = result && false;
failReason = failReason + "act_user_id is not in DB;";
}
if(!(area_id.equals(act_id))){
result = result && false;
failReason = failReason + "area_id is not in DB;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "not find t_exam_area in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.BasicsGM;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 添加公告
*
* @author puhui
*
*/
public class announce extends XYZB implements API {
public String parameter;//参数集合
public String uuid;
public String nickname;
public String create_time;
public String token_room_num;
public String content;//公告内容
public String id;
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_token(data, Url,Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
//是否是线上环境
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" xyu_announcement a",
" a.uuid = '" + Current_uuid + "' ");
rs_bankcard.last();
if (rs_bankcard.getRow() < 1) {
result = result && false;
failReason = failReason + "xyu_announcement info is not in DB;";
} else {
String act_uuid = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("uuid")));
String act_nickname = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("nickname")));
String act_create_time = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("create_time")));
String act_token_room_num = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("token_room_num")));
String act_content = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("content")));
Current_announcement_id=String.
valueOf(rs_bankcard.getString(rs_bankcard.findColumn("id")));
uuid = MapUtil.killQuotes(jp.getString("data.uuid"), "\"");//去掉双引号的uuid
nickname = MapUtil.killQuotes(jp.getString("data.nickname"), "\"");//去掉双引号的uuid
create_time = MapUtil.killQuotes(jp.getString("data.create_time"), "\"");//去掉双引号的uuid
token_room_num = MapUtil.killQuotes(jp.getString("data.token_room_num"), "\"");//去掉双引号的uuid
content = MapUtil.killQuotes(jp.getString("data.content"), "\"");//去掉双引号的uuid
id = MapUtil.killQuotes(jp.getString("data.id"), "\"");//去掉双引号的uuid
if ((!act_uuid.equals(uuid))
|| (!act_nickname.equals(StringUtils.decodeUnicode(nickname)))
|| (!act_create_time.contains(create_time))
|| (!act_token_room_num.equals(token_room_num))
|| (!act_content.contains(content))){
result = result && false;
failReason = failReason + "xyu_announcement info in DB is wrong;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_announcement info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 删除公告信息
*
* @author puhui
*
*/
public class announce_del extends XYZB implements API {
public String parameter;//参数集合
public String Description;//参数集合
public String id;//文件id
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
id = MapUtil.getParameter(parameter, "id").trim();
if ((!id.equals("")) && id.equals("code")) {
parameter = Current_announcement_id;
parameter = MapUtil.killQuotes(parameter, "\"");//去掉双引号的Othercode
data.put("parameter", parameter);
return data;
}
if ((!id.equals("")) && id.equals("Othercode")) {
parameter = Integer.valueOf(Current_id)-2+"";
parameter = MapUtil.killQuotes(parameter, "\"");//去掉双引号的Othercode
data.put("parameter", parameter);
return data;
}
data.put("parameter", id);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Map<String, Object> jsonAsMap = new HashMap<>();
parameter = MapUtil.getValue("parameter", data);
Response re = RequestDataUtils.Del_Token(data,Client_token, "/api/v1/announce/"+parameter);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
//是否是线上环境
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" xyu_room_files f ",
" f.id = '" + Current_id + "' ");
rs_bankcard.last();
if (rs_bankcard.getRow()!=0){
result = result && false;
failReason = failReason + "xyu_room_files info in DB is wrong;";
} else {
Log.logInfo("xyu_room_files info in DB is correct;");
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room_files info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 获取公告列表
*
* @author puhui
*
*/
public class announce_get extends XYZB implements API {
public String parameter;//参数集合
public String Description;
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
// 获取parameter对应的内容
Description = MapUtil.getValue("Description", data);
if(Description.contains("错误token")){
Response re = RequestDataUtils.Get_Errtoken(data, "/api/v1/announce", Client_token);
return re;
}else if(Description.contains("超长token")){
Response re = RequestDataUtils.Get_Longtoken(data, "/api/v1/announce", Client_token);
return re;
}else if(Description.contains("无token")){
Response re = RequestDataUtils.Get_Notoken(data, "/api/v1/announce");
return re;
}
Response re = RequestDataUtils.Get_Noparameter(data, "/api/v1/announce",Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if((data.get("custom") != null) && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if (jp.getString("data") != null) {
parameter = MapUtil.getValue("parameter", data);
String dataarr[] =jp.getString("data.data").split("]");
System.out.println(jp.getString("data.data"));
try {
ResultSet xyu_announcement=null;
xyu_announcement = this.selectFromDB(
" xyu_announcement a ",
" a.token_room_num = '" + Current_room + "' ");
xyu_announcement.last();
// System.out.println(dataarr.length);
// System.out.println(xyu_announcement.getRow());
if (xyu_announcement.getRow()!=dataarr.length) {
result = result && false;
failReason = failReason + "xyu_announcement.getRow() is not dataarr.length;";
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_announcement info in DB;";
e.printStackTrace();
}
}
}
if (result){
return "Pass";
}else{
return "Fail:" + failReason;
}
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 提交回答
*
* @author puhui
*
*/
public class answer extends XYZB implements API {
public String parameter;//参数集合
public String id;//
public String answer;//
public String private_;//
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
id = MapUtil.getParameter(parameter, "id").trim();
answer = MapUtil.getParameter(parameter, "answer").trim();
private_ = MapUtil.getParameter(parameter, "private").trim();
if ((!id.equals("")) && id.equals("code")) {
id=Current_questions_id;
parameter = parameter.replace("\"id\":code", "\"id\":\""+ Current_questions_id + "\"");
}
if ((!answer.equals("")) && answer.equals("random")) {
answer="我也不会啊。。。";
parameter = parameter.replace("\"answer\":random", "\"answer\":\""+ answer + "\"");
}
if (!private_.equals("")) {
parameter = parameter.replace("\"private_\"", "\"private\"");
}
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_token(data, Url,Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
//是否是线上环境
if (!isProduct) {
private_ = MapUtil.killQuotes(private_, "\"");//去掉双引号的private_
answer = MapUtil.killQuotes(answer, "\"");//去掉双引号的answer
id = MapUtil.killQuotes(id, "\"");//去掉双引号的id
try {
ResultSet rs_bankcard = this.selectFromDB(
" xyu_room_answer ",
" 1 = 1");
rs_bankcard.last();
if (rs_bankcard.getRow() < 1) {
result = result && false;
failReason = failReason + "xyu_room_answer info is not in DB;";
} else {
String act_id = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("id")));
String act_answer = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("answer")));
act_answer = MapUtil.killQuotes(act_answer, "\"");
String act_question_id = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("question_id")));
String act_private = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("private")));
// System.out.println(private_);
// System.out.println(act_private);
// System.out.println(answer);
// System.out.println(StringUtils.decodeUnicode(act_answer));
// System.out.println(id);
// System.out.println(act_question_id);
// if ((!private_.equals(act_private))
if ( (!answer.equals(StringUtils.decodeUnicode(act_answer)))
|| (!id.equals(act_question_id))){
result = result && false;
failReason = failReason + "xyu_room_answer info in DB is wrong;";
}
}
} catch (Exception e) {
e.printStackTrace();
result = result && false;
failReason = failReason + "cannot verify xyu_room_answer info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 禁止提问
*
* @author puhui
*
*/
public class ask_status extends XYZB implements API {
public String parameter;//参数集合
public String Description;//参数集合
public String is_ask;//
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
is_ask = MapUtil.getParameter(parameter, "is_ask").trim();
is_ask=MapUtil.killQuotes(is_ask, "\"");
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Map<String, Object> jsonAsMap = new HashMap<>();
jsonAsMap.put("is_ask", is_ask);
// System.out.println(room_nums.get("Not_edited"));
Response re = RequestDataUtils.Put_Token(data,Client_token, Url,jsonAsMap);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
//是否是线上环境
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" xyu_room r ",
" r.room_num = '" + Current_room + "' ");
rs_bankcard.last();
String act_is_ask = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("is_ask")));
if (!is_ask.equals(act_is_ask)){
result = result && false;
failReason = failReason + "xyu_room info in DB is wrong;";
} else {
Log.logInfo("xyu_room info in DB is correct;");
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 全员禁言
*
* @author puhui
*
*/
public class banned_status extends XYZB implements API {
public String parameter;//参数集合
public String Description;//参数集合
public String is_banned;//
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
is_banned = MapUtil.getParameter(parameter, "is_banned").trim();
is_banned=MapUtil.killQuotes(is_banned, "\"");
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Map<String, Object> jsonAsMap = new HashMap<>();
jsonAsMap.put("is_banned", is_banned);
// System.out.println(room_nums.get("Not_edited"));
Response re = RequestDataUtils.Put_Token(data,Client_token, Url,jsonAsMap);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
//是否是线上环境
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" xyu_room r ",
" r.room_num = '" + Current_room + "' ");
rs_bankcard.last();
String act_is_banned = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("is_banned")));
if (!is_banned.equals(act_is_banned)){
result = result && false;
failReason = failReason + "xyu_room info in DB is wrong;";
} else {
Log.logInfo("xyu_room info in DB is correct;");
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 获取禁言状态
*
* @author puhui
*
*/
public class banned_status_get extends XYZB implements API {
public String Description;//参数集合
public int id;//房间id
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
// 获取parameter对应的内容
Description = MapUtil.getValue("Description", data);
if(Description.contains("错误token")){
Response re = RequestDataUtils.Get_Errtoken(data, "/api/v1/banned_status", Client_token);
return re;
}else if(Description.contains("超长token")){
Response re = RequestDataUtils.Get_Longtoken(data, "/api/v1/banned_status", Client_token);
return re;
}else if(Description.contains("无token")){
Response re = RequestDataUtils.Get_Notoken_NoCookie(data, "/api/v1/banned_status");
return re;
}
Response re = RequestDataUtils.Get_Noparameter(data, "/api/v1/banned_status",Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
//是否验证数据库
if (!isProduct) {
String is_banned=jp.getString("data.is_banned");
try {
ResultSet rs_bankcard = this.selectFromDB(
" xyu_room r ",
" r.room_num = '" + Current_room + "' ");
rs_bankcard.last();
// System.out.println(rs_bankcard.getString("is_banned"));
if (!is_banned.equals(rs_bankcard.getString("is_banned"))){
result = result && false;
failReason = failReason + "xyu_room info in DB is wrong;";
} else {
Log.logInfo("xyu_room info in DB is correct;");
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 获取发言间隔时间
*
* @author puhui
*
*/
public class banned_time extends XYZB implements API {
public String Description;//参数集合
public int id;//房间id
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Get_Noparameter(data, Url,Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
//是否是线上环境
if (!isProduct) {
String banned_time=jp.getString("data.banned_time");
try {
ResultSet rs_bankcard = this.selectFromDB(
" xyu_room r ",
" r.room_num = '" + Current_room + "' ");
rs_bankcard.last();
if (!banned_time.equals(rs_bankcard.getString("banned_time"))){
result = result && false;
failReason = failReason + "xyu_room info in DB is wrong;";
} else {
Log.logInfo("xyu_room info in DB is correct;");
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 更新发言间隔时间
*
* @author puhui
*
*/
public class banned_time_up extends XYZB implements API {
public String parameter;//参数集合
public String Description;//参数集合
public String banned_time;//
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
banned_time = MapUtil.getParameter(parameter, "banned_time").trim();
banned_time=MapUtil.killQuotes(banned_time, "\"");
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Map<String, Object> jsonAsMap = new HashMap<>();
jsonAsMap.put("banned_time", banned_time);
// System.out.println(room_nums.get("Not_edited"));
Response re = RequestDataUtils.Put_Token(data,Client_token, "/api/v1/banned_time",jsonAsMap);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
//是否是线上环境
if (!isProduct) {
try {
ResultSet rs_bankcard = this.selectFromDB(
" xyu_room r ",
" r.room_num = '" + Current_room + "' ");
rs_bankcard.last();
String act_banned_time = String
.valueOf(rs_bankcard.getString(rs_bankcard.findColumn("banned_time")));
if (!banned_time.equals(act_banned_time)){
result = result && false;
failReason = failReason + "xyu_room info in DB is wrong;";
} else {
Log.logInfo("xyu_room info in DB is correct;");
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room info in DB;";
e.printStackTrace();
}
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.util.HashMap;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
/**
* 用户离开房间
*
* @author puhui
*
*/
public class del extends XYZB implements API {
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Del_Token(data, Client_token, Url);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data").length()>4){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
try {
ResultSet rs_bankcard=null;
rs_bankcard = this.selectFromDB(
" xyu_room_users r ",
" r.uuid = '" + Current_uuid + "' ");
rs_bankcard.last();
// System.out.println(rs_bankcard.getRow());
if(!(rs_bankcard.getString("online").equals("0"))){
result = result && false;
failReason = failReason + "online is not find;";
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room info in DB;";
e.printStackTrace();
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 获取房间用户信息
*
* @author puhui
*
*/
public class getRooms extends XYZB implements API {
public String parameter;//参数集合
public String Description;
public String password;//姓名
public String room_num;
public String current_page;
public String first_page_url;
public String last_page;
public String last_page_url;
public String next_page_url;
public String path;
public String per_page;
public String prev_page_url;
public String to;
public String total;
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
password = MapUtil.getParameter(parameter, "password").trim();
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
// 获取parameter对应的内容
Description = MapUtil.getValue("Description", data);
if(Description.contains("错误token")){
Response re = RequestDataUtils.Get_Errtoken(data, "/api/v1/users", Client_token);
return re;
}else if(Description.contains("超长token")){
Response re = RequestDataUtils.Get_Longtoken(data, "/api/v1/users", Client_token);
return re;
}else if(Description.contains("无token")){
Response re = RequestDataUtils.Get_Notoken(data, "/api/v1/users");
return re;
}
Response re = RequestDataUtils.Get_token(data, "/api/v1/users",Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
System.out.println(json);
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if((data.get("custom") != null) && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
//如果请求地址接口是studentinfo接口5
if (jp.getString("data") != null) {
parameter = MapUtil.getValue("parameter", data);
first_page_url=jp.getString("data.first_page_url");
last_page_url=jp.getString("data.last_page_url");
next_page_url=jp.getString("data.next_page_url");
prev_page_url=jp.getString("data.prev_page_url");
total=jp.getString("data.total");
String role="";
if(parameter.contains("&")){
String arr[]=parameter.split("&");
role=arr[0].split("=")[1];
}
try {
ResultSet rs_bankcard=null;
if(!parameter.contains("role")){
rs_bankcard = this.selectFromDB(
" xyu_room_users r ",
" r.room_num = '" + Current_room + "' ");
rs_bankcard.last();
// System.out.println(rs_bankcard.getString("count(*)"));
}else{
rs_bankcard = this.selectFromDB(
" xyu_room_users r ",
" r.room_num = '" + Current_room + "' and online = '1' and role = '"+role+"'");
rs_bankcard.last();
// System.out.println(rs_bankcard.getString("count(*)"));
}
// System.out.println(rs_bankcard.getRow());
if (!(rs_bankcard.getRow()+"").equals(total)) {
result = result && false;
failReason = failReason + "total is not find;";
}
if(!first_page_url.contains(parameter.substring(1, parameter.length()-2))){
result = result && false;
failReason = failReason + "first_page_url is not find;";
}
if(!last_page_url.contains(parameter.substring(1, parameter.length()-2))){
result = result && false;
failReason = failReason + "last_page_url is not find;";
}
if(next_page_url!=null && !next_page_url.contains(parameter.substring(1, parameter.length()-2))){
result = result && false;
failReason = failReason + "next_page_url is not find;";
}
if(prev_page_url!=null && !prev_page_url.contains(parameter.substring(1, parameter.length()-2))){
result = result && false;
failReason = failReason + "prev_page_url is not find;";
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room info in DB;";
e.printStackTrace();
}
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 获取用户信息
*
* @author puhui
*
*/
public class getUser extends XYZB implements API {
public String parameter;//参数集合
public String Description;
public String uuid;
public String id;
public String room_num;
public String nickname;
public String speaking_status;
public String enabled;
public String role;
public String created_at;
public String updated_at;
public String online;
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
uuid = MapUtil.getParameter(parameter, "uuid").trim();
uuid = MapUtil.killQuotes(uuid, "\"");//去掉双引号的education
if ((!uuid.equals("")) && uuid.equals("code")) {
parameter = Current_uuid;
parameter = MapUtil.killQuotes(parameter, "\"");//去掉双引号的parameter
data.put("parameter", parameter);
return data;
}
// 替换原来的parameter
data.put("parameter", uuid);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
// 获取parameter对应的内容
Description = MapUtil.getValue("Description", data);
if(Description.contains("错误token")){
Response re = RequestDataUtils.Get_Errtoken(data, "/api/v1/users", Client_token);
return re;
}else if(Description.contains("超长token")){
Response re = RequestDataUtils.Get_Longtoken(data, "/api/v1/users", Client_token);
return re;
}else if(Description.contains("无token")){
Response re = RequestDataUtils.Get_Notoken(data, "/api/v1/users");
return re;
}
Response re = RequestDataUtils.Get_Noparameter(data, "/api/v1/users",Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if((data.get("custom") != null) && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if (jp.getString("data") != null) {
parameter = MapUtil.getValue("parameter", data);
id =jp.getString("data.id");
room_num =jp.getString("data.room_num");
nickname =jp.getString("data.nickname");
role =jp.getString("data.role");
speaking_status =jp.getString("data.speaking_status");
enabled =jp.getString("data.enabled");
online =jp.getString("data.online");
try {
ResultSet xyu_room_users=null;
if(id!=null){
xyu_room_users = this.selectFromDB(
" xyu_room_users r ",
" r.uuid = '" + parameter + "' ");
xyu_room_users.last();
String act_id = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("id")));
String act_room_num = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("room_num")));
String act_nickname = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("nickname")));
String act_role = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("role")));
String act_speaking_status = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("speaking_status")));
String act_enabled = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("enabled")));
String act_online = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("online")));
if (!act_id.equals(id)) {
result = result && false;
failReason = failReason + "id is not find;";
}
if (!act_room_num.equals(room_num)) {
result = result && false;
failReason = failReason + "re_room_num is not find;";
}
if(!act_nickname.equals(nickname)){
result = result && false;
failReason = failReason + "Current_nickname is not find;";
}
if(!act_role.contains(role)){
result = result && false;
failReason = failReason + "Current_password is not find;";
}
if(!act_speaking_status.equals(speaking_status)){
result = result && false;
failReason = failReason + "re_speaking_status is not find;";
}
if(!act_enabled.equals(enabled)){
result = result && false;
failReason = failReason + "re_enabled is not find;";
}
if(!act_online.equals(online)){
result = result && false;
failReason = failReason + "re_online is not find;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room info in DB;";
e.printStackTrace();
}
}
}
if (result){
Current_user_id=id;
return "Pass";
}else{
return "Fail:" + failReason;
}
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Random;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 获取配置信息
*
* @author puhui
*
*/
public class get_config extends XYZB implements API {
public String Description;//参数集合
public int id;//房间id
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
// 获取parameter对应的内容
Description = MapUtil.getValue("Description", data);
if(Description.contains("错误token")){
Response re = RequestDataUtils.Get_Errtoken(data, Url, Client_token);
return re;
}else if(Description.contains("超长token")){
Response re = RequestDataUtils.Get_Longtoken(data, Url, Client_token);
return re;
}else if(Description.contains("无token")){
Response re = RequestDataUtils.Get_Notoken_NoCookie(data, Url);
return re;
}
Response re = RequestDataUtils.Get_Noparameter(data, Url,Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 根据room_num获取教师相关信息
*
* @author puhui
*
*/
public class get_teacher_info extends XYZB implements API {
public String parameter;//参数集合
public String Description;
public String teacher_uuid;
public String uuid;
public String nickname;
public String desc;
public String pic;
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
teacher_uuid = MapUtil.getParameter(parameter, "teacher_uuid").trim();
teacher_uuid = MapUtil.killQuotes(teacher_uuid, "\"");//去掉双引号的education
// if ((!room_name.equals("")) && room_name.equals("code")) {
// parameter = parameter.replace("\"room_name\":code", "\"room_name\":\""+ room_names.get("Not_edited") + "\"");
// }
if ((!teacher_uuid.equals("")) && teacher_uuid.equals("code")) {
parameter = "teacher_uuid="+Current_uuid;
parameter = MapUtil.killQuotes(parameter, "\"");//去掉双引号的parameter
data.put("parameter", parameter);
return data;
}
// 替换原来的parameter
data.put("parameter", teacher_uuid);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
// 获取parameter对应的内容
Description = MapUtil.getValue("Description", data);
if(Description.contains("错误token")){
Response re = RequestDataUtils.Get_Errtoken(data, "/api/v1/users", Client_token);
return re;
}else if(Description.contains("超长token")){
Response re = RequestDataUtils.Get_Longtoken(data, "/api/v1/users", Client_token);
return re;
}else if(Description.contains("无token")){
Response re = RequestDataUtils.Get_Notoken(data, "/api/v1/users");
return re;
}
Response re = RequestDataUtils.Get_token(data, Url,Client_token);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if((data.get("custom") != null) && jp.getString("data")!=null){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if (jp.getString("data") != null) {
parameter = MapUtil.getValue("parameter", data);
/**
* public String uuid;
public String nickname;
public String desc;
public String pic;
*/
uuid =jp.getString("data.uuid");
nickname =jp.getString("data.nickname");
// desc =jp.getString("data.data.desc[0]");
// pic =jp.getString("data.data.pic[0]");
try {
ResultSet xyu_room_users=null;
if(uuid!=null){
xyu_room_users = this.selectFromDB(
" xyu_room_users r ",
" r.uuid = '" + Current_uuid + "' ");
xyu_room_users.last();
String act_nickname = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("nickname")));
String act_uuid = String.valueOf(xyu_room_users.getString(xyu_room_users.findColumn("uuid")));
if (!act_uuid.equals(uuid)) {
result = result && false;
failReason = failReason + "uuid is not find;";
}
if(!act_nickname.equals(nickname)){
result = result && false;
failReason = failReason + "nickname is not find;";
}
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room_users info in DB;";
e.printStackTrace();
}
}
}
if (result){
return "Pass";
}else{
return "Fail:" + failReason;
}
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import org.json.simple.JSONArray;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.XYZB;
import net.sf.json.JSONObject;
/**
* 业务员管理员登陆
*
* @author puhui
*
*/
public class login extends XYZB implements API {
public String parameter;//参数集合
public String Description;//用例名称
public String username;//姓名
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
parameter = MapUtil.getValue("parameter", data);
username = MapUtil.getParameter(parameter, "username").trim();
if ((!username.equals("")) && username.equals("Enterprise_users")) {
parameter = parameter.replace("\"username\":Enterprise_users", "\"username\":\""+ Enterprise_users.get("name") + "\"");
}
if ((!username.equals("")) && username.equals("Business_Administrator")) {
parameter = parameter.replace("\"username\":Business_Administrator", "\"username\":\""+ Business_Administrator.get("name") + "\"");
}
// 替换原来的parameter
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Response re = RequestDataUtils.Post_NOtokenNOcookie(data,Url );
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data")!=null && jp.getString("data").length()>4){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if (jp.getString("data") != null){
String token_data=jp.getString("data.access_token");
// String[] token_arr=token_data.split(",");
// String[] token_value=token_arr[0].split(":");
// Salesman_token=token_value[1];
Salesman_token=token_data;
}
}
if (result)
return "Pass";
else
return "Fail:" + failReason;
}
}
package com.offcn.api.xyzb;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;
import java.sql.ResultSet;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import com.offcn.TestUnti.Log;
import com.offcn.TestUnti.MapUtil;
import com.offcn.TestUnti.MyDateUtil;
import com.offcn.TestUnti.ReadProperties;
import com.offcn.TestUnti.RequestDataUtils;
import com.offcn.TestUnti.StringUtils;
import com.offcn.interfaces.API;
import com.offcn.process.BasicsGM;
import com.offcn.process.XYZB;
/**
* 修改用户昵称
*
* @author puhui
*
*/
public class modify extends XYZB implements API {
public String parameter;//参数集合
public String Description;
public String nickname;//nickname
@Override
public void initialize(HashMap<String, Object> data) {
}
@Override
public HashMap<String, Object> handleInput(HashMap<String, Object> data) {
// 获取parameter对应的内容
parameter = MapUtil.getValue("parameter", data);
nickname = MapUtil.getParameter(parameter, "nickname").trim();
if ((!nickname.equals("")) && nickname.equals("random")) {
Current_nickname="ys"+(new Random().nextInt(90000000)+ 10000000);
parameter = parameter.replace("\"nickname\":random", "\"nickname\":\""+ Current_nickname + "\"");
}
// 替换原来的parameter
data.put("parameter", parameter);
return data;
}
@Override
public Response SendRequest(HashMap<String, Object> data, String Url,
String Request) {
Map<String, Object> jsonAsMap = new HashMap<>();
parameter = MapUtil.getValue("parameter", data);
nickname = MapUtil.getParameter(parameter, "nickname").trim();
jsonAsMap.put("nickname", nickname);
// System.out.println(room_nums.get("Not_edited"));
Response re = RequestDataUtils.Put_Token(data,Client_token, Url,jsonAsMap);
return re;
}
@Override
public String handleOutput(Response re, HashMap<String, Object> data) {
JsonPath jp = re.body().jsonPath();
boolean result = true;
String failReason = "";
String json = re.asString();
if ((data.get("statusCode") != null)
&& (!data.get("statusCode").toString()
.equals(String.valueOf(re.getStatusCode())))) {
result = result && false;
failReason = failReason + "statusCode is expected "
+ data.get("statusCode").toString() + " but actually "
+ String.valueOf(re.getStatusCode()) + ". ";
}
if (json.length() != 0) {
String msg=StringUtils.decodeUnicode(jp.getString("msg"));
if ((data.get("code") != null )
&& ((jp.getString("code") == null) || (!jp.getString(
"code").equals(data.get("code").toString())))) {
result = result && false;
failReason = failReason + "code is expected "
+ data.get("code").toString() + " but actually "
+ jp.getString("code") + ".";
}
if ((data.get("msg") != null)
&& ((msg == null) || (!msg.equals(data.get("msg").toString())))) {
result = result && false;
failReason = failReason + "msg is expected "
+ data.get("msg").toString() + " but actually "
+ jp.getString("msg") + ".";
}
if(data.get("custom") != null && jp.getString("data").length()>4){
String custom=data.get("custom").toString();
String[] ArrayString=StringUtils.getArrayString(custom,",");
if(!StringUtils.VerificationString(jp.getString("data"),ArrayString)){
result = result && false;
failReason = failReason + "custom is expected "
+ data.get("custom").toString() + " but actually "
+ jp.getString("data") + ".";
}
}
if("操作成功".equals(jp.getString("msg"))){
try {
parameter = MapUtil.getValue("parameter", data);
ResultSet rs_bankcard=null;
if(!parameter.contains("role")){
rs_bankcard = this.selectFromDB(
" xyu_room_users r ",
" r.uuid = '" + Current_uuid + "' ");
rs_bankcard.last();
// System.out.println(rs_bankcard.getString("count(*)"));
}
if(!(rs_bankcard.getString("nickname").equals(nickname))){
result = result && false;
failReason = failReason + "nickname is not find;";
}
} catch (Exception e) {
result = result && false;
failReason = failReason + "cannot verify xyu_room_users info in DB;";
e.printStackTrace();
}
}
}
if (result){
return "Pass";
}else{
return "Fail:" + failReason;
}
}
}
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