From 95d8d3df562c8f7fca74ba994cddbbf41564488e Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期二, 08 四月 2025 20:08:15 +0800
Subject: [PATCH] 优化未完成计划列表、已完成计划列表接口
---
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu3rd/src/main/java/com/dy/rtuMw3rd/http4Xjnk/HttpRq.java | 228 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 228 insertions(+), 0 deletions(-)
diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu3rd/src/main/java/com/dy/rtuMw3rd/http4Xjnk/HttpRq.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu3rd/src/main/java/com/dy/rtuMw3rd/http4Xjnk/HttpRq.java
new file mode 100644
index 0000000..0343a3f
--- /dev/null
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu3rd/src/main/java/com/dy/rtuMw3rd/http4Xjnk/HttpRq.java
@@ -0,0 +1,228 @@
+package com.dy.rtuMw3rd.http4Xjnk;
+
+import com.dy.common.util.HttpCallback;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.*;
+import org.springframework.http.converter.StringHttpMessageConverter;
+import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.nio.charset.StandardCharsets;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2025/3/15 9:56
+ * @Description
+ */
+@Component()
+public class HttpRq {
+
+ private RestTemplate restTemplate ;
+
+ @Autowired
+ public void setRestTemplate(RestTemplate restTemplate){
+ this.restTemplate = restTemplate;
+ }
+
+ /**
+ * get璇锋眰锛岃繑鍥瀓son鍐呭
+ * 鍚屾
+ * @param httpBaseUrl
+ * @param params
+ * @param cb
+ * @throws Exception
+ */
+ public void get4JsonBySync(String httpBaseUrl, Map<String, String> params, HttpCallback cb) throws Exception {
+ String url = UriComponentsBuilder.fromUriString(httpBaseUrl)
+ .build()
+ .toUriString();
+
+ UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(url) ;
+ if(params != null && params.size() > 0){
+ Iterator<String> it = params.keySet().iterator() ;
+ String key ;
+ while (it.hasNext()){
+ key = it.next() ;
+ builder.queryParam(key, params.get(key)) ;
+ }
+ }
+ httpGetRequestSync(builder, cb);
+ }
+ /**
+ * get璇锋眰锛岃繑鍥瀓son鍐呭
+ * 寮傛
+ * @param httpBaseUrl
+ * @param params
+ * @param cb
+ * @throws Exception
+ */
+ public void get4JsonByAsync(String httpBaseUrl, Map<String, String> params, HttpCallback cb) throws Exception {
+ String url = UriComponentsBuilder.fromUriString(httpBaseUrl)
+ .build()
+ .toUriString();
+
+ UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(url) ;
+ if(params != null && params.size() > 0){
+ Iterator<String> it = params.keySet().iterator() ;
+ String key ;
+ while (it.hasNext()){
+ key = it.next() ;
+ builder.queryParam(key, params.get(key)) ;
+ }
+ }
+ httpGetRequestAsync(builder, cb);
+ }
+
+ /**
+ * get璇锋眰锛岃繑鍥瀓son鍐呭
+ * 鍚屾
+ * @param httpBaseUrl
+ * @param params
+ * @param cb
+ * @throws Exception
+ */
+ public void post4JsonBySync(String httpBaseUrl, Map<String, String> params, HttpCallback cb) throws Exception {
+ String url = UriComponentsBuilder.fromUriString(httpBaseUrl)
+ .build()
+ .toUriString();
+
+ UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(url) ;
+ httpPostRequestSync(builder, params, cb);
+ }
+ /**
+ * get璇锋眰锛岃繑鍥瀓son鍐呭
+ * 寮傛
+ * @param httpBaseUrl
+ * @param params
+ * @param cb
+ * @throws Exception
+ */
+ public void post4JsonByAsync(String httpBaseUrl, Map<String, String> params, HttpCallback cb) throws Exception {
+ String url = UriComponentsBuilder.fromUriString(httpBaseUrl)
+ .build()
+ .toUriString();
+
+ UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(url) ;
+ httpPostRequestAsync(builder, params, cb);
+ }
+
+ /**
+ * 鍙戣捣璇锋眰
+ * @param builder
+ * @param cb
+ * @return
+ */
+ private void httpGetRequestSync(UriComponentsBuilder builder, HttpCallback cb) {
+ HttpHeaders headers = new HttpHeaders() ;
+ headers.setContentType(MediaType.APPLICATION_JSON) ;
+ restTemplate.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));
+ // 閫氳繃Get鏂瑰紡璋冪敤鎺ュ彛
+ ResponseEntity<String> response = restTemplate.exchange(builder.toUriString(),
+ HttpMethod.GET,
+ new HttpEntity<>(headers),
+ String.class);
+
+ String contentType = response.getHeaders().getContentType().toString() ;
+ cb.call(response.getStatusCode().value() + "", contentType, response.getBody());
+ }
+
+
+ /**
+ * 鍙戣捣璇锋眰
+ * @param builder
+ * @param cb
+ * @return
+ */
+ private void httpGetRequestAsync(UriComponentsBuilder builder, HttpCallback cb) throws Exception {
+ HttpHeaders headers = new HttpHeaders() ;
+ headers.setContentType(MediaType.APPLICATION_JSON) ;
+ restTemplate.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));
+ // 鍙戣捣寮傛 GET 璇锋眰
+ CompletableFuture<ResponseEntity<String>> future = CompletableFuture.supplyAsync(() ->
+ // 閫氳繃Get鏂瑰紡璋冪敤鎺ュ彛
+ restTemplate.exchange(builder.toUriString(),
+ HttpMethod.GET,
+ new HttpEntity<>(headers),
+ String.class)
+ );
+ future.thenAccept(response -> {
+ String contentType = response.getHeaders().getContentType().toString() ;
+ cb.call(response.getStatusCode().value() + "", contentType, response.getBody());
+ }) ;
+ /*
+ AtomicReference<Throwable> exeEx = new AtomicReference() ;
+ future.thenAccept(response -> {
+ String contentType = response.getHeaders().getContentType().toString() ;
+ cb.call(response.getStatusCode().value() + "", contentType, response.getBody());
+ }).exceptionally(ex -> {
+ exeEx.set(ex.getCause());
+ return null;
+ });
+ */
+ }
+
+ /**
+ * 鍙戣捣璇锋眰
+ * @param builder
+ * @param body
+ * @param cb
+ * @return
+ */
+ private void httpPostRequestSync(UriComponentsBuilder builder, Map<String, String> body, HttpCallback cb) {
+ HttpHeaders headers = new HttpHeaders() ;
+ headers.setContentType(MediaType.APPLICATION_JSON) ;
+ restTemplate.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));
+ restTemplate.getMessageConverters().add(new MappingJackson2HttpMessageConverter());
+ HttpEntity<Map<String, String>> requestEntity = new HttpEntity<>(body, headers);
+ // 閫氳繃Get鏂瑰紡璋冪敤鎺ュ彛
+ ResponseEntity<String> response = restTemplate.exchange(builder.toUriString(),
+ HttpMethod.POST,
+ requestEntity,
+ String.class);
+
+ String contentType = response.getHeaders().getContentType().toString() ;
+ cb.call(response.getStatusCode().value() + "", contentType, response.getBody());
+ }
+
+ /**
+ * 鍙戣捣璇锋眰
+ * @param builder
+ * @param body
+ * @param cb
+ * @return
+ */
+ private void httpPostRequestAsync(UriComponentsBuilder builder, Map<String, String> body, HttpCallback cb) throws Exception {
+ HttpHeaders headers = new HttpHeaders() ;
+ headers.setContentType(MediaType.APPLICATION_JSON) ;
+ restTemplate.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));
+ restTemplate.getMessageConverters().add(new MappingJackson2HttpMessageConverter());
+ HttpEntity<Map<String, String>> requestEntity = new HttpEntity<>(body, headers);
+ // 鍙戣捣寮傛 GET 璇锋眰
+ CompletableFuture<ResponseEntity<String>> future = CompletableFuture.supplyAsync(() ->
+ // 閫氳繃Get鏂瑰紡璋冪敤鎺ュ彛
+ restTemplate.exchange(builder.toUriString(),
+ HttpMethod.POST,
+ requestEntity,
+ String.class)
+ );
+ future.thenAccept(response -> {
+ String contentType = response.getHeaders().getContentType().toString() ;
+ cb.call(response.getStatusCode().value() + "", contentType, response.getBody());
+ }) ;
+ /*
+ AtomicReference<Throwable> exeEx = new AtomicReference() ;
+ future.thenAccept(response -> {
+ String contentType = response.getHeaders().getContentType().toString() ;
+ cb.call(response.getStatusCode().value() + "", contentType, response.getBody());
+ }).exceptionally(ex -> {
+ exeEx.set(ex.getCause());
+ return null;
+ });
+ */
+ }
+}
--
Gitblit v1.8.0