package com.lassenInterface.common.httpRpcPost;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import com.alibaba.fastjson.JSONObject;
import com.lassenInterface.constant.WorkContext;
public class HttpRpcPost {
/**
*
* lassen-post方法
* @param domain 域名
* @param url rpc接口url
* @param params 参数
* @param loginAccount 登录账号
*
*/
public static String post(String domain, String url, Map<String, String> params, String loginAccount) throws Exception {
//调绕过验证方法
CloseableHttpClient client = SSLUtils.createIgnoreVerifySSL();
//初始化response内容
String responseContent = null;
//获取Cookie
String cookie = getCookie(domain, loginAccount);
//创建HttpPost
String reqURL = domain + url;
HttpPost post = new HttpPost(reqURL);
//构建Post请求的表单参数
ArrayList<BasicNameValuePair> pairs = new ArrayList<BasicNameValuePair>();
if (params != null) {
Set<String> keys = params.keySet();
for (Iterator<String> i = keys.iterator(); i.hasNext();) {
String key = (String) i.next();
pairs.add(new BasicNameValuePair(key, params.get(key)));
}
}
//设置参数到请求对象中
post.setEntity(new UrlEncodedFormEntity(pairs, "UTF-8"));
//设置header信息,指定报文头【Accept】、【Content-Type】、【Cookie】
post.setHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8");
// post.setHeader("Content-Type", "application/json;charset=UTF-8");
post.setHeader("Content-Type", "application/x-www-form-urlencoded");
post.setHeader("Cookie", cookie);
try {
//执行请求操作，并拿到response（同步阻塞）
HttpResponse response = client.execute(post);
// 获取响应实体
HttpEntity entity = response.getEntity();
//获取Http状态码
int responseStatusCode = response.getStatusLine().getStatusCode();
//如果态码是200，表示请求成功
if (responseStatusCode == 200) {
//按指定编码转换结果实体为String类型
responseContent = EntityUtils.toString(entity,"UTF-8");
System.out.println("【Response】" + responseContent);
}
else{
System.err.println("【调用rpc失败】"+responseStatusCode);
}
//释放链接
client.close();
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
client.close();
}
return responseContent;
}
/**
*
* etna-post方法
* @param domain 域名
* @param url rpc接口url
* @param params 参数
* @param loginAccount 登录账号
*
*/
public static String etnaPost(String domain, String url, Map<String, String> params, String loginAccount) throws Exception {
CloseableHttpClient client = SSLUtils.createIgnoreVerifySSL();
String responseContent = null;
String cookie = getEtnaCookie(domain, loginAccount);
HttpPost post = new HttpPost(domain + url);
ArrayList<BasicNameValuePair> pairs = new ArrayList<BasicNameValuePair>();
if (params != null) {
Set<String> keys = params.keySet();
for (Iterator<String> i = keys.iterator(); i.hasNext();) {
String key = (String) i.next();
pairs.add(new BasicNameValuePair(key, params.get(key)));
}
}
post.setEntity(new UrlEncodedFormEntity(pairs, "UTF-8"));
post.setHeader("accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8");
post.setHeader("content-type", "application/x-www-form-urlencoded");
post.setHeader("cookie", cookie);
try {
HttpResponse response = client.execute(post);
int responseStatusCode = response.getStatusLine().getStatusCode();
if (responseStatusCode == 200) {
responseContent = EntityUtils.toString(response.getEntity());
System.out.println("【Response】" + responseContent);
}
client.close();
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
client.close();
}
return responseContent;
}
/**
*
* etna-get方法
* @param domain 域名
* @param url rpc接口url
* @param params 参数
* @param loginAccount 登录账号
*
*/
public static String etna_get(String domain, String url, String params, String loginAccount) throws Exception {
CloseableHttpClient client = SSLUtils.createIgnoreVerifySSL();
String rtnMsg = "";
try {
String cookie = getEtnaCookie(domain, loginAccount);
HttpGet httpget = new HttpGet(domain + url + "?" + params);
httpget.setHeader("cookie", cookie);
CloseableHttpResponse response = client.execute(httpget);
HttpEntity entity = response.getEntity();
if (entity != null) {
rtnMsg = EntityUtils.toString(entity);
}
response.close();
} catch (Exception e) {
rtnMsg = "ERROR";
} finally {
try {
client.close();
} catch (IOException e) {
rtnMsg = "ERROR";
}
}
System.out.println("【rtnMsg】" + rtnMsg);
return rtnMsg;
}
private static String getEtnaCookie(String domain, String loginAccount) throws Exception {
// TODO Auto-generated method stub
CloseableHttpClient client = SSLUtils.createIgnoreVerifySSL();
HttpPost loginpost = new HttpPost(domain + "/login/mock?openaccountId=" + loginAccount);
loginpost.setHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8");
HttpResponse loginResponse = client.execute(loginpost);
String cookieReturn = "";
Map<String, String> cookieMap = new HashMap<String, String>();
if (loginResponse.getStatusLine().getStatusCode() == 200) {
Header[] cookies = loginResponse.getHeaders("Set-Cookie");
if (cookies.length == 0) {
System.out.println(String.format("未获取到cookie,请检查登录账户是否正确。登录账户=【%s】", loginAccount));
}
for (Header cookie : cookies) {
String value = cookie.getValue();
if (value.startsWith("LAVATMP0=") || value.startsWith("LAVATMP1=")) {
String[] valueArr = value.split(";");
String cookieContent = valueArr[0];
String[] cookieArr = cookieContent.split("=");
cookieMap.put(cookieArr[0], cookieArr[1]);
}
}
}
Set<String> keySet = cookieMap.keySet();
for (String key : keySet) {
cookieReturn += key + "=" + cookieMap.get(key) + ";";
}
return cookieReturn;
}
private static String getCookie(String domain, String loginAccount) throws Exception {
// TODO Auto-generated method stub
CloseableHttpClient client = SSLUtils.createIgnoreVerifySSL();
HttpPost loginpost = new HttpPost(domain + "/login/mock.json?openaccountId=" + loginAccount);
loginpost.setHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8");
HttpResponse loginResponse = client.execute(loginpost);
String cookieReturn = "";
Map<String, String> cookieMap = new HashMap<String, String>();
if (loginResponse.getStatusLine().getStatusCode() == 200) {
Header[] cookies = loginResponse.getHeaders("Set-Cookie");
for (Header cookie : cookies) {
String value = cookie.getValue();
if (value.contains("LASSENLOGINUSER") || value.contains("LASSENLGAC") || value.contains("LASSENTMP0")) {
String[] valueArr = value.split(";");
String cookieContent = valueArr[0];
String[] cookieArr = cookieContent.split("=");
cookieMap.put(cookieArr[0], cookieArr[1]);
}
}
}
Set<String> keySet = cookieMap.keySet();
for (String key : keySet) {
cookieReturn += key + "=" + cookieMap.get(key) + ";";
}
return cookieReturn.substring(0, cookieReturn.length() - 1);
}
public static void main(String[] args) throws Exception {
String params = "{\"entrustOrganizationId\":\"10003\",\"entrustCourt\":\"速裁庭\",\"entrustPhase\":\"诉前\",\"caseCode\":\"（cxp）test-001\",\"causeAction\":\"民间借贷纠纷\",\"caseType\":\"laborDispute\",\"amount\":111,\"amountCurrency\":\"cny\",\"secretaryId\":\"487\",\"mediationOrganizationId\":\"10013\",\"mandator\":\"达达001\",\"mandatorContacts\":\"0571-101012020\",\"deadlineTime\":\"2018-06-03 10:00:00\",\"prosecutionDate\":\"2018-05-11 16:11:00\",\"entrustTime\":\"2018-05-11 16:11:00\",\"mediateEntityDTOList\":[{\"name\":\"达达001\",\"certifyType\":\"idCard\",\"idCard\":\"123456789\",\"mailAddress\":\"测试通讯地址\",\"mobile\":\"13290901010\",\"email\":\"13290901010@qq.com\",\"phone\":\"13690901010\",\"gender\":\"male\",\"lawOffice\":\"红心律所\",\"lawyerContacts\":\"13190901010\",\"lawyer\":\"小红\",\"contactInfo\":\"13090901010\",\"entityType\":\"normal\",\"entityRole\":\"accuser\",\"entityPosition\":1},{\"name\":\"达达002\",\"certifyType\":\"idCard\",\"idCard\":\"12345678901\",\"mailAddress\":\"测试通讯地址1\",\"mobile\":\"13280801010\",\"email\":\"13080801010@qq.com\",\"phone\":\"13380801010\",\"gender\":\"male\",\"lawOffice\":\"黑心律所\",\"lawyerContacts\":\"13180801010\",\"lawyer\":\"小黑\",\"contactInfo\":\"13080801010\",\"entityType\":\"normal\",\"entityRole\":\"accused\",\"entityPosition\":1}],\"securityFileIds\":[]}";
Map<String, String> parms = new HashMap<String, String>();
parms.put("param", params);
String etnaPost2 = etnaPost(WorkContext.ETNA_BEICU_URL, "/etnaMediator/case/insertMediateCase", parms, "13999999991");
String paramsss = "{\"securityId\":\"oWljD-e_bGBRKUFUIn-mqQ\"}";
Map parmsss = JSONObject.parseObject(paramsss, Map.class);
String etnaPost22 = etnaPost(WorkContext.ETNA_BEICU_URL, "/etnaMediator/case/queryByBaseCaseId", parmsss, "13999999991");
String paramss = "securityId=oWljD-e_bGBRKUFUIn-mqQ";
String getString = etna_get(WorkContext.ETNA_BEICU_URL, "/etnaMediator/case/queryByBaseCaseId", paramss, "13999999991");
}
}