actionHandleMethod) {
- }
-
-
- /**
- * action 提交流程业务处理方法
- * 具体业务逻辑实现
- * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
- *
- *
- * @param requestId 流程请求ID
- * @param billTable 流程对应主表名称
- * @param workflowId 流程对应流程ID
- * @param user 当前节点操作者用户
- * @param requestInfo 请求管理对象
- */
-
- public abstract void doSubmit(String requestId, String billTable, int workflowId,
- User user, RequestInfo requestInfo);
-
-
- /**
- * action 退回流程业务处理方法
- * 具体业务逻辑实现
- * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
- *
- *
- * @param requestId 流程请求ID
- * @param billTable 流程对应主表名称
- * @param workflowId 流程对应流程ID
- * @param user 当前节点操作者用户
- * @param requestInfo 请求管理对象
- */
- public void doReject(String requestId, String billTable, int workflowId,
- User user, RequestInfo requestInfo) {
- }
-
- /**
- * action 撤回、撤回流程流程业务处理方法
- * 具体业务逻辑实现
- * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
- *
- *
- * @param requestId 流程请求ID
- * @param billTable 流程对应主表名称
- * @param workflowId 流程对应流程ID
- * @param user 当前节点操作者用户
- * @param requestInfo 请求管理对象
- */
- public void doWithdraw(String requestId, String billTable, int workflowId,
- User user, RequestInfo requestInfo) {
- }
-
-
- /**
- * action 强制收回流程业务处理方法
- * 具体业务逻辑实现
- * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
- *
- *
- * @param requestId 流程请求ID
- * @param billTable 流程对应主表名称
- * @param workflowId 流程对应流程ID
- * @param user 当前节点操作者用户
- * @param requestInfo 请求管理对象
- */
- public void doDrawBack(String requestId, String billTable, int workflowId,
- User user, RequestInfo requestInfo) {
- }
-
- /**
- * 获取流程主表数据
- *
- * @return 流程主表数据
- */
- protected Map getMainTableValue(RequestInfo requestInfo) {
- // 获取主表数据
- Property[] propertyArr = requestInfo.getMainTableInfo().getProperty();
- return getStringMap(propertyArr);
- }
-
- @NotNull
- private Map getStringMap(Property[] propertyArr) {
- if (null == propertyArr) {
- return Collections.emptyMap();
- }
- Map mainTable = new HashMap<>((int) Math.ceil(propertyArr.length * 1.4));
- for (Property property : propertyArr) {
- String fieldName = property.getName();
- String value = property.getValue();
- mainTable.put(fieldName, value);
- }
- return mainTable;
- }
-
-
- /**
- * 获取所有明细数据
- *
- * @return 以明细表需要为键，以明细表数据为值的键值对明细数据信息
- */
- protected Map>> getDetailTableValue(RequestInfo requestInfo) {
- DetailTable[] detailTableArr = requestInfo.getDetailTableInfo().getDetailTable();
- return getListMap(detailTableArr);
- }
-
-
- @NotNull
- private Map>> getListMap(DetailTable[] detailTableArr) {
- Map>> detailDataList = new HashMap<>((int) Math.ceil(detailTableArr.length * 1.4));
- for (DetailTable detailTable : detailTableArr) {
- List> detailData = getDetailValue(detailTable);
- detailDataList.put(detailTable.getId(), detailData);
- }
- return detailDataList;
- }
-
-
- /**
- * 获取指定明细表的表数据
- *
- * @param detailNo 明细表编号
- * @return 明细数据
- */
- protected List> getDetailTableValueByDetailNo(int detailNo, RequestInfo requestInfo) {
- DetailTable detailTable = requestInfo.getDetailTableInfo().getDetailTable(detailNo);
- return getDetailValue(detailTable);
- }
-
- /**
- * 根据明细表信息获取明细表数据
- *
- * @param detailTable 明细表对象
- * @return 明细表数据
- */
- @NotNull
- private List> getDetailValue(DetailTable detailTable) {
- Row[] rowArr = detailTable.getRow();
- List> detailData = new ArrayList<>(rowArr.length);
- for (Row row : rowArr) {
- Cell[] cellArr = row.getCell();
- Map rowData = new HashMap<>((int) Math.ceil(cellArr.length * (1 + 0.4)));
- rowData.put("id", row.getId());
- for (Cell cell : cellArr) {
- String fieldName = cell.getName();
- String value = cell.getValue();
- rowData.put(fieldName, value);
- }
- detailData.add(rowData);
- }
- return detailData;
- }
-
-
- public static final class ActionRunType {
- /**
- * 退回
- */
- public static final String REJECT = "reject";
- /**
- * 撤回
- */
- public static final String WITHDRAW = "withdraw";
- /**
- * 强制收回
- */
- public static final String DRAW_BACK = "drawBack";
- /**
- * 提交
- */
- public static final String SUBMIT = "submit";
- }
-
+
+
+ /**
+ * 全局日志对象
+ */
+ protected final Logger log = Util.getLogger();
+ private final Map actionHandleMethod = new HashMap<>();
+
+ /**
+ * 初始化流程默认的处理方法
+ */
+ private void initHandleMethod() {
+ // 提交
+ actionHandleMethod.put(ActionRunType.SUBMIT, this::doSubmit);
+ // 退回
+ actionHandleMethod.put(ActionRunType.REJECT, this::doReject);
+ // 撤回
+ actionHandleMethod.put(ActionRunType.WITHDRAW, this::doWithdraw);
+ // 强制收回
+ actionHandleMethod.put(ActionRunType.DRAW_BACK, this::doDrawBack);
+ }
+
+
+ @Override
+ public final String execute(RequestInfo requestInfo) {
+ RequestManager requestManager = requestInfo.getRequestManager();
+ String billTable = requestManager.getBillTableName();
+ String requestId = requestInfo.getRequestid();
+ User user = requestInfo.getRequestManager().getUser();
+ int workflowId = requestManager.getWorkflowid();
+ // 操作类型 submit - 提交 reject - 退回 等
+ String src = requestManager.getSrc();
+ if ("".equals(billTable)) {
+ WorkflowComInfo workflowComInfo = new WorkflowComInfo();
+ String formId = workflowComInfo.getFormId(String.valueOf(workflowId));
+ WorkflowBillComInfo workflowBillComInfo = new WorkflowBillComInfo();
+ billTable = workflowBillComInfo.getTablename(formId);
+ }
+ try {
+ Util.verifyRequiredField(this);
+ if (!Strings.isNullOrEmpty(src)) {
+ src = "submit";
+ }
+ // 初始化默认的流程处理方法
+ initHandleMethod();
+ // 提供自定义注册处理方法
+ registerHandler(actionHandleMethod);
+ // 获取流程对应的处理方法
+ SafeCusBaseActionHandleFunction cusBaseActionHandleFunction = actionHandleMethod.get(src);
+ // 默认没有直接成功不做拦截
+ if (null == cusBaseActionHandleFunction) {
+ return Action.SUCCESS;
+ }
+ cusBaseActionHandleFunction.handle(requestId, billTable, workflowId, user, requestInfo);
+ } catch (CustomerException e) {
+ if (e.getCode() != null && e.getCode() == 500) {
+ Util.actionFail(requestManager, e.getMessage());
+ return Action.FAILURE_AND_CONTINUE;
+ }
+ if (this.exceptionCallback(e, requestManager)) {
+ return Action.FAILURE_AND_CONTINUE;
+ }
+ } catch (Exception e) {
+ if (this.exceptionCallback(e, requestManager)) {
+ return Action.FAILURE_AND_CONTINUE;
+ }
+ }
+ return Action.SUCCESS;
+ }
+
+
+ /**
+ * 程序执行异常回调
+ *
+ * @param e 异常信息
+ * @param requestManager requestManager对象
+ * @return 是否阻止action往下提交，true- 阻止， false-放行
+ */
+ public boolean exceptionCallback(Exception e, RequestManager requestManager) {
+ e.printStackTrace();
+ log.error(Util.logStr("execute action fail, exception message is [{}], error stack trace msg is: \n{}",
+ e.getMessage(), Util.getErrString(e)));
+ Util.actionFail(requestManager, e.getMessage());
+ return true;
+ }
+
+
+ /**
+ * 流程其他流转类型处理方法注册
+ *
+ * @param actionHandleMethod 处理方法对应map
+ */
+ public void registerHandler(Map actionHandleMethod) {
+ }
+
+
+ /**
+ * action 提交流程业务处理方法
+ * 具体业务逻辑实现
+ * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
+ *
+ *
+ * @param requestId 流程请求ID
+ * @param billTable 流程对应主表名称
+ * @param workflowId 流程对应流程ID
+ * @param user 当前节点操作者用户
+ * @param requestInfo 请求管理对象
+ */
+
+ public abstract void doSubmit(String requestId, String billTable, int workflowId,
+ User user, RequestInfo requestInfo);
+
+
+ /**
+ * action 退回流程业务处理方法
+ * 具体业务逻辑实现
+ * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
+ *
+ *
+ * @param requestId 流程请求ID
+ * @param billTable 流程对应主表名称
+ * @param workflowId 流程对应流程ID
+ * @param user 当前节点操作者用户
+ * @param requestInfo 请求管理对象
+ */
+ public void doReject(String requestId, String billTable, int workflowId,
+ User user, RequestInfo requestInfo) {
+ }
+
+ /**
+ * action 撤回、撤回流程流程业务处理方法
+ * 具体业务逻辑实现
+ * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
+ *
+ *
+ * @param requestId 流程请求ID
+ * @param billTable 流程对应主表名称
+ * @param workflowId 流程对应流程ID
+ * @param user 当前节点操作者用户
+ * @param requestInfo 请求管理对象
+ */
+ public void doWithdraw(String requestId, String billTable, int workflowId,
+ User user, RequestInfo requestInfo) {
+ }
+
+
+ /**
+ * action 强制收回流程业务处理方法
+ * 具体业务逻辑实现
+ * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
+ *
+ *
+ * @param requestId 流程请求ID
+ * @param billTable 流程对应主表名称
+ * @param workflowId 流程对应流程ID
+ * @param user 当前节点操作者用户
+ * @param requestInfo 请求管理对象
+ */
+ public void doDrawBack(String requestId, String billTable, int workflowId,
+ User user, RequestInfo requestInfo) {
+ }
+
+ /**
+ * 获取流程主表数据
+ *
+ * @return 流程主表数据
+ */
+ protected Map getMainTableValue(RequestInfo requestInfo) {
+ // 获取主表数据
+ Property[] propertyArr = requestInfo.getMainTableInfo().getProperty();
+ return getStringMap(propertyArr);
+ }
+
+ @NotNull
+ private Map getStringMap(Property[] propertyArr) {
+ if (null == propertyArr) {
+ return Collections.emptyMap();
+ }
+ Map mainTable = new HashMap<>((int) Math.ceil(propertyArr.length * 1.4));
+ for (Property property : propertyArr) {
+ String fieldName = property.getName();
+ String value = property.getValue();
+ mainTable.put(fieldName, value);
+ }
+ return mainTable;
+ }
+
+ /**
+ * 获取流程主表数据
+ *
+ * @return 流程主表数据
+ */
+ protected Map getObjMainTableValue(RequestInfo requestInfo) {
+ Map mainTableValue = getMainTableValue(requestInfo);
+ return new HashMap<>(mainTableValue);
+ }
+
+
+ /**
+ * 获取所有明细数据
+ *
+ * @return 以明细表需要为键，以明细表数据为值的键值对明细数据信息
+ */
+ protected Map>> getDetailTableValue(RequestInfo requestInfo) {
+ DetailTable[] detailTableArr = requestInfo.getDetailTableInfo().getDetailTable();
+ return getListMap(detailTableArr);
+ }
+
+
+ @NotNull
+ private Map>> getListMap(DetailTable[] detailTableArr) {
+ Map>> detailDataList = new HashMap<>((int) Math.ceil(detailTableArr.length * 1.4));
+ for (DetailTable detailTable : detailTableArr) {
+ List> detailData = getDetailValue(detailTable);
+ detailDataList.put(detailTable.getId(), detailData);
+ }
+ return detailDataList;
+ }
+
+
+ /**
+ * 获取指定明细表的表数据
+ *
+ * @param detailNo 明细表编号
+ * @return 明细数据
+ */
+ protected List> getDetailTableValueByDetailNo(int detailNo, RequestInfo requestInfo) {
+ DetailTable detailTable = requestInfo.getDetailTableInfo().getDetailTable(detailNo);
+ return getDetailValue(detailTable);
+ }
+
+ /**
+ * 根据明细表信息获取明细表数据
+ *
+ * @param detailTable 明细表对象
+ * @return 明细表数据
+ */
+ @NotNull
+ private List> getDetailValue(DetailTable detailTable) {
+ Row[] rowArr = detailTable.getRow();
+ List> detailData = new ArrayList<>(rowArr.length);
+ for (Row row : rowArr) {
+ Cell[] cellArr = row.getCell();
+ Map rowData = new HashMap<>((int) Math.ceil(cellArr.length * (1 + 0.4)));
+ rowData.put("id", row.getId());
+ for (Cell cell : cellArr) {
+ String fieldName = cell.getName();
+ String value = cell.getValue();
+ rowData.put(fieldName, value);
+ }
+ detailData.add(rowData);
+ }
+ return detailData;
+ }
+
+
+ public static final class ActionRunType {
+ /**
+ * 退回
+ */
+ public static final String REJECT = "reject";
+ /**
+ * 撤回
+ */
+ public static final String WITHDRAW = "withdraw";
+ /**
+ * 强制收回
+ */
+ public static final String DRAW_BACK = "drawBack";
+ /**
+ * 提交
+ */
+ public static final String SUBMIT = "submit";
+ }
+
}
diff --git a/src/main/java/aiyh/utils/excention/CustomerException.java b/src/main/java/aiyh/utils/excention/CustomerException.java
index 1984afa..e2292c9 100644
--- a/src/main/java/aiyh/utils/excention/CustomerException.java
+++ b/src/main/java/aiyh/utils/excention/CustomerException.java
@@ -10,47 +10,49 @@ import org.apache.log4j.Logger;
* @author ayh
*/
-public class CustomerException extends RuntimeException{
- private Logger logger = Util.getLogger();
- private String msg;
- private Throwable throwable;
- private Integer code;
-
- public CustomerException(String msg){
- super(msg);
- this.msg = msg;
- }
-
- public CustomerException(String msg,Integer code){
- super(msg);
- this.code = code;
- this.msg = msg;
- }
- public CustomerException(String msg, Integer code, Throwable throwable){
- super(msg);
- this.code= code;
- this.msg = msg;
- }
- public CustomerException(String msg, Throwable throwable){
- super(msg,throwable);
- this.msg = msg;
- this.throwable = throwable;
- }
-
- @Override
- public void printStackTrace() {
- logger.error("二开自定义异常：" + this.msg);
- if(this.throwable != null){
- logger.error("异常信息： " + Util.getErrString(this.throwable));
- }
- }
-
- public Integer getCode (){
- return this.code;
- }
-
- @Override
- public String getMessage() {
- return this.msg;
- }
+public class CustomerException extends RuntimeException {
+ private final Logger logger = Util.getLogger();
+ private final String msg;
+ private Throwable throwable;
+ private Integer code = -1;
+
+ public CustomerException(String msg) {
+ super(msg);
+ this.msg = msg;
+ }
+
+ public CustomerException(String msg, Integer code) {
+ super(msg);
+ this.code = code;
+ this.msg = msg;
+ }
+
+ public CustomerException(String msg, Integer code, Throwable throwable) {
+ super(msg);
+ this.code = code;
+ this.msg = msg;
+ }
+
+ public CustomerException(String msg, Throwable throwable) {
+ super(msg, throwable);
+ this.msg = msg;
+ this.throwable = throwable;
+ }
+
+ @Override
+ public void printStackTrace() {
+ logger.error("二开自定义异常：" + this.msg);
+ if (this.throwable != null) {
+ logger.error("异常信息： " + Util.getErrString(this.throwable));
+ }
+ }
+
+ public Integer getCode() {
+ return this.code;
+ }
+
+ @Override
+ public String getMessage() {
+ return this.msg;
+ }
}
diff --git a/src/main/java/aiyh/utils/httpUtil/HttpManager.java b/src/main/java/aiyh/utils/httpUtil/HttpManager.java
index bf3c81c..d01fffc 100644
--- a/src/main/java/aiyh/utils/httpUtil/HttpManager.java
+++ b/src/main/java/aiyh/utils/httpUtil/HttpManager.java
@@ -4,17 +4,22 @@ import org.apache.http.client.CredentialsProvider;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.ssl.SSLContextBuilder;
+import org.apache.http.ssl.SSLContexts;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLContext;
+import java.io.File;
+import java.io.IOException;
import java.security.KeyManagementException;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
+import java.security.cert.CertificateException;
/**
@@ -22,76 +27,122 @@ import java.security.NoSuchAlgorithmException;
* @since 2021/08/30 17:56
**/
public class HttpManager {
-
- /**
- * 创建连接池管理对象
- */
-
-
- private static final int CONNECT_TIMEOUT = 1000 * 60 * 3;
- private static final int CONNECTION_REQUEST_TIMEOUT = 1000 * 60 * 3;
- private static final int SOCKET_TIMEOUT = 10000 * 60 * 3;
- private static final int MAX_TOTAL = 500;
- private static final int MAX_PRE_ROUTE = 500;
-
- /**
- * 设置请求配置
- */
- static RequestConfig requestConfig = RequestConfig.custom()
- //网络请求的超时时间
- .setConnectTimeout(CONNECT_TIMEOUT)
- //连接池去获取连接的超时时间
- .setConnectionRequestTimeout(CONNECTION_REQUEST_TIMEOUT)
- //设置socket超时时间
- .setSocketTimeout(SOCKET_TIMEOUT)
- .build();
- static PoolingHttpClientConnectionManager manager = new PoolingHttpClientConnectionManager();
- static {
- // 配置最大的连接数
- manager.setMaxTotal(MAX_TOTAL);
- // 每个路由最大连接数（路由是根据host来管理的，大小不好控制）
- manager.setDefaultMaxPerRoute(MAX_PRE_ROUTE);
- }
-
- /**
- * 获取连接对象 从连接池里面去获取，根据url创建对应的对象，http / https
- * @param url 请求地址
- * @return 连接对象
- */
- public static CloseableHttpClient getHttpConnection(String url, CredentialsProvider credentialsProvider){
- if(url.trim().toUpperCase().startsWith(HttpArgsType.HTTP_HTTPS.toUpperCase())){
- SSLContext sslContext;
- SSLConnectionSocketFactory sslsf = null;
- try {
- sslContext = new SSLContextBuilder().loadTrustMaterial(null, (x509Certificates, s) -> {
+
+ /**
+ * 创建连接池管理对象
+ */
+
+
+ private static final int CONNECT_TIMEOUT = 1000 * 60 * 3;
+ private static final int CONNECTION_REQUEST_TIMEOUT = 1000 * 60 * 3;
+ private static final int SOCKET_TIMEOUT = 10000 * 60 * 3;
+ private static final int MAX_TOTAL = 500;
+ private static final int MAX_PRE_ROUTE = 500;
+
+ /**
+ * 设置请求配置
+ */
+ static RequestConfig requestConfig = RequestConfig.custom()
+ // 网络请求的超时时间
+ .setConnectTimeout(CONNECT_TIMEOUT)
+ // 连接池去获取连接的超时时间
+ .setConnectionRequestTimeout(CONNECTION_REQUEST_TIMEOUT)
+ // 设置socket超时时间
+ .setSocketTimeout(SOCKET_TIMEOUT)
+ .build();
+ static PoolingHttpClientConnectionManager manager = new PoolingHttpClientConnectionManager();
+
+ static {
+ // 配置最大的连接数
+ manager.setMaxTotal(MAX_TOTAL);
+ // 每个路由最大连接数（路由是根据host来管理的，大小不好控制）
+ manager.setDefaultMaxPerRoute(MAX_PRE_ROUTE);
+ }
+
+ /**
+ * 获取连接对象 从连接池里面去获取，根据url创建对应的对象，http / https
+ *
+ * @param url 请求地址
+ * @return 连接对象
+ */
+ public static CloseableHttpClient getHttpConnection(String url, CredentialsProvider credentialsProvider) {
+ if (url.trim().toUpperCase().startsWith(HttpArgsType.HTTP_HTTPS.toUpperCase())) {
+ SSLContext sslContext;
+ SSLConnectionSocketFactory sslsf = null;
+ try {
+ sslContext = new SSLContextBuilder().loadTrustMaterial(null, (x509Certificates, s) -> {
// 绕过所有验证
- return true;
- }).build();
- HostnameVerifier hostnameVerifier = NoopHostnameVerifier.INSTANCE;
- sslsf = new SSLConnectionSocketFactory(sslContext,hostnameVerifier);
- } catch (NoSuchAlgorithmException | KeyStoreException | KeyManagementException e) {
- e.printStackTrace();
- }
- HttpClientBuilder httpClientBuilder = HttpClients.custom()
- .setSSLSocketFactory(sslsf)
- .setConnectionManager(manager)
- .setConnectionManagerShared(true)
- .setDefaultRequestConfig(requestConfig);
- if(credentialsProvider != null){
- httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
- }
- return httpClientBuilder
- .build();
- }else{
- HttpClientBuilder httpClientBuilder = HttpClients.custom()
- .setConnectionManager(manager)
- .setDefaultRequestConfig(requestConfig)
- .setConnectionManagerShared(true);
- if(credentialsProvider != null){
- httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
- }
- return httpClientBuilder
- .build();
- }
- }
+ return true;
+ }).build();
+ HostnameVerifier hostnameVerifier = NoopHostnameVerifier.INSTANCE;
+ sslsf = new SSLConnectionSocketFactory(sslContext,
+ new String[]{"TLSv1"},
+ null,
+ hostnameVerifier);
+ } catch (NoSuchAlgorithmException | KeyStoreException | KeyManagementException e) {
+ throw new RuntimeException(e);
+ }
+ HttpClientBuilder httpClientBuilder = HttpClients.custom()
+ .setSSLSocketFactory(sslsf)
+ .setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE)
+ .setConnectionManager(manager)
+ .setConnectionManagerShared(true)
+ .setDefaultRequestConfig(requestConfig);
+ if (credentialsProvider != null) {
+ httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
+ }
+ return httpClientBuilder
+ .build();
+ } else {
+ HttpClientBuilder httpClientBuilder = HttpClients.custom()
+ .setConnectionManager(manager)
+ .setDefaultRequestConfig(requestConfig)
+ .setConnectionManagerShared(true);
+ if (credentialsProvider != null) {
+ httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
+ }
+ return httpClientBuilder
+ .build();
+ }
+ }
+
+ public static CloseableHttpClient getHttpConnection(String url, CredentialsProvider credentialsProvider, String sslPath, String password) {
+ if (url.trim().toUpperCase().startsWith(HttpArgsType.HTTP_HTTPS.toUpperCase())) {
+ SSLContext sslContext;
+ SSLConnectionSocketFactory sslsf = null;
+ try {
+ sslContext = SSLContexts.custom()
+ .loadTrustMaterial(new File(sslPath), password.toCharArray(),
+ new TrustSelfSignedStrategy())
+ .build();
+ sslsf = new SSLConnectionSocketFactory(sslContext,
+ new String[]{"TLSv1"},
+ null,
+ SSLConnectionSocketFactory.getDefaultHostnameVerifier());
+ } catch (NoSuchAlgorithmException | KeyStoreException | KeyManagementException | CertificateException |
+ IOException e) {
+ throw new RuntimeException(e);
+ }
+ HttpClientBuilder httpClientBuilder = HttpClients.custom()
+ .setSSLSocketFactory(sslsf)
+ .setConnectionManager(manager)
+ .setConnectionManagerShared(true)
+ .setDefaultRequestConfig(requestConfig);
+ if (credentialsProvider != null) {
+ httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
+ }
+ return httpClientBuilder
+ .build();
+ } else {
+ HttpClientBuilder httpClientBuilder = HttpClients.custom()
+ .setConnectionManager(manager)
+ .setDefaultRequestConfig(requestConfig)
+ .setConnectionManagerShared(true);
+ if (credentialsProvider != null) {
+ httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
+ }
+ return httpClientBuilder
+ .build();
+ }
+ }
}
diff --git a/src/main/java/aiyh/utils/httpUtil/ResponeVo.java b/src/main/java/aiyh/utils/httpUtil/ResponeVo.java
index dcc34b3..3029b96 100644
--- a/src/main/java/aiyh/utils/httpUtil/ResponeVo.java
+++ b/src/main/java/aiyh/utils/httpUtil/ResponeVo.java
@@ -1,7 +1,9 @@
package aiyh.utils.httpUtil;
+import aiyh.utils.Util;
import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
@@ -19,284 +21,293 @@ import java.util.Map;
*/
public class ResponeVo implements HttpResponse {
- /**
- * 相应状态码
- */
- private int code;
- /**
- * 相应内容
- */
- private String entityString;
-
- private Map entityMap;
- /**
- * 相应头信息
- */
-
- private Locale locale;
-
- private InputStream content;
-
- private byte[] contentByteArr;
-
- private Map requestData;
-
- private HttpResponse response;
-
- public int getCode() {
- return code;
- }
-
- public void setCode(int code) {
- this.code = code;
- }
-
- public void setResponse(HttpResponse response) {
- this.response = response;
- }
-
- public Map getRequestData() {
- return requestData;
- }
-
- public void setRequestData(Map requestData) {
- this.requestData = requestData;
- }
-
- /**
- * 根据相应结果转化为map集合
- *
- * @return 资源皇后的map集合
- * @throws JsonProcessingException JSON转换异常
- */
- @Deprecated
- public Map getEntityMap() throws JsonProcessingException {
- ObjectMapper mapper = new ObjectMapper();
- return mapper.readValue(this.getEntityString(), Map.class);
- }
-
- public Map getResponseMap(){
- return this.entityMap;
- }
- /**
- * 根据相应结果，转化为实体类
- *
- * @param clazz 需要映射的实体类
- * @param 需要转换实体类的泛型
- * @return 转换后的实体类
- * @throws JsonProcessingException JSON转换异常
- */
- @Deprecated
- public T getEntity(Class clazz) throws JsonProcessingException {
- ObjectMapper mapper = new ObjectMapper();
- return mapper.readValue(this.getEntityString(), clazz);
- }
-
- public T getResponseEntity(Class clazz) {
- ObjectMapper mapper = new ObjectMapper();
- try {
- return mapper.readValue(this.getEntityString(), clazz);
- } catch (JsonProcessingException e) {
- return null;
- }
- }
-
- /**
- * 根据相应结果，转化为实体类
- *
- * @param 需要转换实体类的泛型处理器
- * @return 转换后的实体类
- * @throws JsonProcessingException JSON转换异常
- */
- public T getEntity(TypeReference typeReference) throws JsonProcessingException {
- ObjectMapper mapper = new ObjectMapper();
- return mapper.readValue(this.getEntityString(), typeReference);
- }
-
- public String getEntityString() {
- return entityString;
- }
-
- public void setEntityString(String entityString) {
- this.entityString = entityString;
- try{
- ObjectMapper mapper = new ObjectMapper();
- this.entityMap = mapper.readValue(this.getEntityString(), Map.class);
- }catch (Exception ignore){
-
- }
- }
-
- public InputStream getContent() {
- return content;
- }
-
- public void setContent(InputStream content) {
- this.content = content;
- }
-
- public byte[] getContentByteArr() {
- return contentByteArr;
- }
-
- public void setContentByteArr(byte[] contentByteArr) {
- this.contentByteArr = contentByteArr;
- }
-
- @Override
- public String toString() {
- return "ResponeVo{" +
- "code=" + code +
- ", entityString='" + entityString + '\'' +
- ", otherParam=" + requestData +
- '}';
- }
-
- /**
- * 根据相应结果转化为实体集合
- *
- * @param clazz 需要映射的实体类
- * @param 需要转换的实体类的泛型
- * @return 转换后的实体类的集合
- */
- public List getEntityArray(Class clazz) {
- return JSON.parseArray(this.getEntityString(), clazz);
- }
-
- @Override
- public StatusLine getStatusLine() {
- return this.response.getStatusLine();
- }
-
- @Override
- public void setStatusLine(StatusLine statusLine) {
-
- }
-
- @Override
- public void setStatusLine(ProtocolVersion protocolVersion, int i) {
-
- }
-
- @Override
- public void setStatusLine(ProtocolVersion protocolVersion, int i, String s) {
-
- }
-
- @Override
- public void setStatusCode(int i) throws IllegalStateException {
-
- }
-
- @Override
- public void setReasonPhrase(String s) throws IllegalStateException {
-
- }
-
- @Override
- public HttpEntity getEntity() {
- return null;
- }
-
- @Override
- public void setEntity(HttpEntity httpEntity) {
-
- }
-
- public Locale getLocale() {
- return locale;
- }
-
- public void setLocale(Locale locale) {
- this.locale = locale;
- }
-
- @Override
- public ProtocolVersion getProtocolVersion() {
- return this.response.getProtocolVersion();
- }
-
- @Override
- public boolean containsHeader(String s) {
- return response.containsHeader(s);
- }
-
- @Override
- public Header[] getHeaders(String s) {
- return response.getHeaders(s);
- }
-
- @Override
- public Header getFirstHeader(String s) {
- return response.getFirstHeader(s);
- }
-
- @Override
- public Header getLastHeader(String s) {
- return response.getLastHeader(s);
- }
-
- public Header[] getAllHeaders() {
- return response.getAllHeaders();
- }
-
- @Override
- public void addHeader(Header header) {
-
- }
-
- @Override
- public void addHeader(String s, String s1) {
-
- }
-
- @Override
- public void setHeader(Header header) {
-
- }
-
- @Override
- public void setHeader(String s, String s1) {
-
- }
-
- @Override
- public void setHeaders(Header[] headers) {
-
- }
-
- @Override
- public void removeHeader(Header header) {
-
- }
-
- @Override
- public void removeHeaders(String s) {
-
- }
-
- @Override
- public HeaderIterator headerIterator() {
- return response.headerIterator();
- }
-
- @Override
- public HeaderIterator headerIterator(String s) {
- return response.headerIterator(s);
- }
-
- @Override
- @Deprecated
- public HttpParams getParams() {
- return response.getParams();
- }
-
- @Override
- public void setParams(HttpParams httpParams) {
-
- }
-
-
-
+ /**
+ * 相应状态码
+ */
+ private int code;
+ /**
+ * 相应内容
+ */
+ private String entityString;
+
+ private Map entityMap;
+
+ private List