From 8853292babb2ad94de4a3207966f1e83b767cd2d Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Sun, 17 Sep 2023 16:38:34 +0800
Subject: [PATCH] 新增流程节点进程查询接口
---
src/main/java/org/springblade/common/utils/arg.java | 97 +++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 94 insertions(+), 3 deletions(-)
diff --git a/src/main/java/org/springblade/common/utils/arg.java b/src/main/java/org/springblade/common/utils/arg.java
index a5383b5..5953560 100644
--- a/src/main/java/org/springblade/common/utils/arg.java
+++ b/src/main/java/org/springblade/common/utils/arg.java
@@ -9,10 +9,19 @@
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
+import org.springblade.core.http.util.HttpUtil;
+
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
public class arg {
- public static String url="http://192.168.0.109:80";
- public static String test01(String path,Object obj) throws Exception{
+ public static String url = "http://localhost:81";
+
+ public static String test01(String path, Object obj) throws Exception {
CloseableHttpClient httpClient = HttpClients.createDefault();
HttpPost httpPost = new HttpPost(path);
httpPost.setEntity(new StringEntity(JSON.toJSONString(obj),
@@ -22,7 +31,89 @@
String str = EntityUtils.toString(entity);
httpPost.clone();
httpClient.close();
- System.out.println(str);
return str;
}
+
+ /**
+ * 发送POST请求,删除
+ *
+ * @param url 目的地址
+ * @param ids
+ * @return 远程响应结果
+ */
+ public static String sendPostRemoveByIds(String url, String ids) {
+ HashMap<String, String> parameters = new HashMap<>(1);
+ parameters.put("ids",ids);
+ // 返回的结果
+ String result = "";
+ // 读取响应输入流
+ BufferedReader in = null;
+ PrintWriter out = null;
+ // 处理请求参数
+ StringBuffer sb = new StringBuffer();
+ // 编码之后的参数
+ String params = "";
+ try {
+ // 编码请求参数
+ if (parameters.size() == 1) {
+ for (String name : parameters.keySet()) {
+ sb.append(name).append("=").append(
+ java.net.URLEncoder.encode(parameters.get(name),
+ "UTF-8"));
+ }
+ params = sb.toString();
+ } else {
+ for (String name : parameters.keySet()) {
+ sb.append(name).append("=").append(
+ java.net.URLEncoder.encode(parameters.get(name),
+ "UTF-8")).append("&");
+ }
+ String temp_params = sb.toString();
+ params = temp_params.substring(0, temp_params.length() - 1);
+ }
+ // 创建URL对象
+ java.net.URL connURL = new java.net.URL(url);
+ // 打开URL连接
+ java.net.HttpURLConnection httpConn = (java.net.HttpURLConnection) connURL
+ .openConnection();
+ // 设置通用属性
+ httpConn.setRequestProperty("Accept", "*/*");
+ httpConn.setRequestProperty("Connection", "Keep-Alive");
+ httpConn.setRequestProperty("User-Agent",
+ "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.1)");
+ // 设置POST方式
+ httpConn.setDoInput(true);
+ httpConn.setDoOutput(true);
+ // 获取HttpURLConnection对象对应的输出流
+ out = new PrintWriter(httpConn.getOutputStream());
+ // 发送请求参数
+ out.write(params);
+ // flush输出流的缓冲
+ out.flush();
+ // 定义BufferedReader输入流来读取URL的响应，设置编码方式
+ in = new BufferedReader(new InputStreamReader(httpConn
+ .getInputStream(), "UTF-8"));
+ String line;
+ // 读取返回的内容
+ while ((line = in.readLine()) != null) {
+ result += line;
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ try {
+ if (out != null) {
+ out.close();
+ }
+ if (in != null) {
+ in.close();
+ }
+ } catch (IOException ex) {
+ ex.printStackTrace();
+ }
+ }
+ return result;
+ }
+
+
}
--
Gitblit v1.9.3