“lyd”
1 month ago
6 changed files with 481 additions and 98 deletions
@ -0,0 +1,21 @@ |
|||
package com.kms.yxgh.df.dto; |
|||
|
|||
import com.alibaba.fastjson.annotation.JSONField; |
|||
import io.swagger.annotations.ApiModel; |
|||
import io.swagger.annotations.ApiModelProperty; |
|||
import lombok.Data; |
|||
|
|||
import java.util.Collections; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
|
|||
@ApiModel("视频播放") |
|||
@Data |
|||
public class ReservoirListDto { |
|||
@ApiModelProperty(value = "视频ids") |
|||
private List<String> cameraIds; |
|||
|
|||
@JSONField(name = "RES_CODE") |
|||
@ApiModelProperty(value = "水库编码") |
|||
private String resCode; |
|||
} |
|||
@ -0,0 +1,28 @@ |
|||
package com.kms.yxgh.df.dto; |
|||
import com.alibaba.fastjson.annotation.JSONField; |
|||
import io.swagger.annotations.ApiModel; |
|||
import io.swagger.annotations.ApiModelProperty; |
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* @ClassName: ReservoirListQueDto |
|||
* @Description: TODO |
|||
* @Date: 2024/3/5 上午10:18 |
|||
* * |
|||
* @author: hxh |
|||
* @version: 1.0 |
|||
*/ |
|||
|
|||
@Data |
|||
@ApiModel("水库视频列表") |
|||
public class ReservoirListQueDto { |
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
@ApiModelProperty(value = "页码") |
|||
private Integer pageSize = 10; |
|||
|
|||
@ApiModelProperty(value = "每页条数") |
|||
private Integer pageNum = 1; |
|||
|
|||
|
|||
} |
|||
@ -0,0 +1,333 @@ |
|||
//
|
|||
// Source code recreated from a .class file by IntelliJ IDEA
|
|||
// (powered by FernFlower decompiler)
|
|||
//
|
|||
|
|||
package com.kms.yxgh.util; |
|||
|
|||
import com.alibaba.fastjson.JSONObject; |
|||
import java.util.HashMap; |
|||
import java.util.Map; |
|||
import java.util.stream.Collectors; |
|||
import org.slf4j.Logger; |
|||
import org.slf4j.LoggerFactory; |
|||
import org.springframework.http.HttpEntity; |
|||
import org.springframework.http.HttpHeaders; |
|||
import org.springframework.http.HttpMethod; |
|||
import org.springframework.http.MediaType; |
|||
import org.springframework.http.ResponseEntity; |
|||
import org.springframework.lang.Nullable; |
|||
import org.springframework.util.LinkedMultiValueMap; |
|||
import org.springframework.util.MultiValueMap; |
|||
import org.springframework.web.client.RestTemplate; |
|||
|
|||
public class RestTemplateUtil { |
|||
private static final Logger log = LoggerFactory.getLogger(RestTemplateUtil.class); |
|||
private static final RestTemplate restTemplate = new RestTemplate(); |
|||
private static final String QUESTION_MARK = "?"; |
|||
private static final String AFTER_BRACE = "{"; |
|||
private static final String BEFORE_BRACE = "}"; |
|||
private static final String EQUALS_SIGN = "="; |
|||
private static final String AND = "&"; |
|||
|
|||
public RestTemplateUtil() { |
|||
} |
|||
|
|||
private static String getParams(Map<String, String> params) { |
|||
return (String)params.keySet().stream().map((key) -> { |
|||
return key + "=" + "{" + key + "}"; |
|||
}).collect(Collectors.joining("&")); |
|||
} |
|||
|
|||
public static String getUrl(String url, Map<String, String> params) { |
|||
String param = getParams(params); |
|||
if (url.indexOf("?") > 0) { |
|||
url = url + "&" + param; |
|||
} else { |
|||
url = url + "?" + param; |
|||
} |
|||
|
|||
return url; |
|||
} |
|||
|
|||
public static RestTemplate getRestTemplate() { |
|||
return restTemplate; |
|||
} |
|||
|
|||
public static <T> T getForObject(String url, Class<T> responseType) { |
|||
return restTemplate.getForObject(url, responseType, new Object[0]); |
|||
} |
|||
|
|||
public static <T> T getForObject(String url, Class<T> responseType, Object... uriVariables) { |
|||
return restTemplate.getForObject(url, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> T getForObject(String url, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return restTemplate.getForObject(url, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> getForObjectWithHead(MultiValueMap<String, String> headValues, String url, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpHeaders headers = new HttpHeaders(); |
|||
headers.addAll(headValues); |
|||
HttpEntity<?> requestEntity = new HttpEntity(headers); |
|||
return restTemplate.exchange(url, HttpMethod.GET, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> T postForObjectWithHead(Object body, MultiValueMap<String, String> headValues, String url, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpHeaders headers = new HttpHeaders(); |
|||
headers.addAll(headValues); |
|||
HttpEntity<?> requestEntity = new HttpEntity(body, headers); |
|||
return restTemplate.postForObject(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static String postForFormUrlencoded(String body, String url, Map<String, ?> uriVariables) { |
|||
HttpHeaders headers = new HttpHeaders(); |
|||
headers.add("Content-Type", "application/x-www-form-urlencoded"); |
|||
HttpEntity<String> requestEntity = new HttpEntity(body, headers); |
|||
log.info(url); |
|||
log.info(requestEntity.toString()); |
|||
log.info(JSONObject.toJSONString(uriVariables)); |
|||
String s = (String)restTemplate.postForObject(url, requestEntity, String.class, uriVariables); |
|||
log.info(s); |
|||
return s; |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> getForObjectWithHead(MultiValueMap<String, String> values, String url, Class<T> responseType, Object... uriVariables) { |
|||
HttpHeaders headers = new HttpHeaders(); |
|||
headers.addAll(values); |
|||
HttpEntity<?> requestEntity = new HttpEntity(headers); |
|||
return restTemplate.exchange(url, HttpMethod.GET, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> T postForObject(String url, @Nullable Object request, Class<T> responseType) { |
|||
return restTemplate.postForObject(url, request, responseType, new Object[0]); |
|||
} |
|||
|
|||
public static <T> T postForObject(String url, @Nullable Object request, Class<T> responseType, Object... uriVariables) { |
|||
return restTemplate.postForObject(url, request, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> T postForObject(String url, @Nullable Object request, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return restTemplate.postForObject(url, request, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> T postFormDataForObject(String url, MultiValueMap<String, String> map, Class<T> responseType) { |
|||
HttpHeaders headers = new HttpHeaders(); |
|||
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED); |
|||
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity(map, headers); |
|||
return restTemplate.postForObject(url, request, responseType, new Object[0]); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> get(String url, Class<T> responseType) { |
|||
return restTemplate.getForEntity(url, responseType, new Object[0]); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> get(String url, Class<T> responseType, Object... uriVariables) { |
|||
return restTemplate.getForEntity(url, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> get(String url, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return restTemplate.getForEntity(url, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> get(String url, Map<String, String> headers, Class<T> responseType, Object... uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return get(url, httpHeaders, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> get(String url, HttpHeaders headers, Class<T> responseType, Object... uriVariables) { |
|||
HttpEntity<?> requestEntity = new HttpEntity(headers); |
|||
return exchange(url, HttpMethod.GET, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> get(String url, Map<String, String> headers, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return get(url, httpHeaders, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> get(String url, HttpHeaders headers, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpEntity<?> requestEntity = new HttpEntity(headers); |
|||
return exchange(url, HttpMethod.GET, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, Class<T> responseType) { |
|||
return restTemplate.postForEntity(url, HttpEntity.EMPTY, responseType, new Object[0]); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, Object requestBody, Class<T> responseType) { |
|||
return restTemplate.postForEntity(url, requestBody, responseType, new Object[0]); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
return restTemplate.postForEntity(url, requestBody, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return restTemplate.postForEntity(url, requestBody, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, Map<String, String> headers, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return post(url, httpHeaders, requestBody, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, HttpHeaders headers, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody, headers); |
|||
return post(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, Map<String, String> headers, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return post(url, httpHeaders, requestBody, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, HttpHeaders headers, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody, headers); |
|||
return post(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables) { |
|||
return restTemplate.exchange(url, HttpMethod.POST, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> post(String url, HttpEntity<?> requestEntity, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return restTemplate.exchange(url, HttpMethod.POST, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, Class<T> responseType, Object... uriVariables) { |
|||
return put(url, HttpEntity.EMPTY, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody); |
|||
return put(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody); |
|||
return put(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, Map<String, String> headers, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return put(url, httpHeaders, requestBody, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, HttpHeaders headers, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody, headers); |
|||
return put(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, Map<String, String> headers, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return put(url, httpHeaders, requestBody, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, HttpHeaders headers, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody, headers); |
|||
return put(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables) { |
|||
return restTemplate.exchange(url, HttpMethod.PUT, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> put(String url, HttpEntity<?> requestEntity, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return restTemplate.exchange(url, HttpMethod.PUT, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, Class<T> responseType, Object... uriVariables) { |
|||
return delete(url, HttpEntity.EMPTY, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return delete(url, HttpEntity.EMPTY, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody); |
|||
return delete(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody); |
|||
return delete(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, Map<String, String> headers, Class<T> responseType, Object... uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return delete(url, httpHeaders, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, HttpHeaders headers, Class<T> responseType, Object... uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(headers); |
|||
return delete(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, Map<String, String> headers, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return delete(url, httpHeaders, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, HttpHeaders headers, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(headers); |
|||
return delete(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, Map<String, String> headers, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return delete(url, httpHeaders, requestBody, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, HttpHeaders headers, Object requestBody, Class<T> responseType, Object... uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody, headers); |
|||
return delete(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, Map<String, String> headers, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpHeaders httpHeaders = new HttpHeaders(); |
|||
httpHeaders.setAll(headers); |
|||
return delete(url, httpHeaders, requestBody, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, HttpHeaders headers, Object requestBody, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
HttpEntity<Object> requestEntity = new HttpEntity(requestBody, headers); |
|||
return delete(url, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables) { |
|||
return restTemplate.exchange(url, HttpMethod.DELETE, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> delete(String url, HttpEntity<?> requestEntity, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return restTemplate.exchange(url, HttpMethod.DELETE, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables) { |
|||
return restTemplate.exchange(url, method, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static <T> ResponseEntity<T> exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType, Map<String, ?> uriVariables) { |
|||
return restTemplate.exchange(url, method, requestEntity, responseType, uriVariables); |
|||
} |
|||
|
|||
public static void main(String[] args) { |
|||
Map<String, String> body = new HashMap(); |
|||
Map<String, String> uriVariables = new HashMap(); |
|||
uriVariables.put("name", "ddd"); |
|||
body.put("shopname", "测试商店"); |
|||
MultiValueMap<String, String> headValues = new LinkedMultiValueMap(); |
|||
headValues.add("name2", "ssss"); |
|||
String response = (String)postForObjectWithHead(body, headValues, "http://127.0.0.1:9095/test/query?name={name}", String.class, uriVariables); |
|||
System.out.println(response); |
|||
} |
|||
} |
|||
Loading…
Reference in new issue