anderx пре 3 година
родитељ
комит
1059525d5c

+ 82 - 0
src/main/java/com/goafanti/common/utils/HttpUtils.java

@@ -0,0 +1,82 @@
+package com.goafanti.common.utils;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import org.apache.http.HttpResponse;
+import org.apache.http.HttpStatus;
+import org.apache.http.ParseException;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.apache.http.util.EntityUtils;
+
+import java.io.IOException;
+import java.nio.charset.Charset;
+import java.util.Map;
+
+public class HttpUtils {
+
+
+
+	 public static JSONObject httpGet(String url) {
+			JSONObject jsonResult = null;
+			try {
+			HttpClient client = HttpClientBuilder.create().build();//获取DefaultHttpClient请求
+			HttpGet request = new HttpGet(url);
+			HttpResponse response = client.execute(request);
+			if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
+			String strResult = EntityUtils.toString(response.getEntity(),"UTF-8");//此处设定编码格式
+			jsonResult = JSON.parseObject(strResult);
+			} else {
+			LoggerUtils.error(HttpUtils.class,"HttpStatus异常");
+			}
+			} catch (IOException e) {
+			e.printStackTrace();
+			}
+			return jsonResult;
+		}
+
+		 /**
+		  *
+		  * @param url 地址
+		  * @param map 参数
+		  * @return
+		  */
+		public static JSONObject httpPost(String url,Map<String, Object>map){
+			HttpClient httpClient = HttpClientBuilder.create().build();
+			HttpPost httpPost = new HttpPost(url);
+			httpPost.addHeader("Content-type", "application/json");
+			httpPost.setHeader("Accept", "application/json");
+			httpPost.setEntity(new StringEntity(JSON.toJSONString(map), Charset.forName("UTF-8")));
+			HttpResponse response = null;
+			try {
+				response = httpClient.execute(httpPost);
+			if (null == response || response.getStatusLine() == null) {
+				throw new Exception("Post Request For Url[{}] is not ok. Response is null");
+			} else if (response.getStatusLine().getStatusCode() != HttpStatus.SC_OK) {
+				throw new Exception("Post Request For Url[{}] is not ok. Response Status Code is {"+response.getStatusLine().getStatusCode()+"}");
+			}
+			} catch (ClientProtocolException e) {
+				e.printStackTrace();
+			} catch (IOException e) {
+				e.printStackTrace();
+			} catch (Exception e) {
+				e.printStackTrace();
+			}
+			String resultString=null;
+			try {
+				resultString = EntityUtils.toString(response.getEntity());
+			} catch (ParseException | IOException e) {
+				e.printStackTrace();
+			}
+			JSONObject jsonObj = JSONObject.parseObject(resultString);
+			return jsonObj;
+			}
+
+
+
+
+}

+ 13 - 2
src/main/java/com/goafanti/evaluation/controller/UserEvaluationApiController.java

@@ -12,6 +12,7 @@ import java.util.stream.Stream;
 
 import javax.validation.Valid;
 
+import com.goafanti.common.utils.HttpUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -227,7 +228,7 @@ public class UserEvaluationApiController extends BaseApiController {
 	}
 
 	/**
-	 * 
+	 *
 	 * @param id
 	 * @return
 	 */
@@ -580,7 +581,7 @@ public class UserEvaluationApiController extends BaseApiController {
 		return industryCategoryService.list(pid).stream()
 				.collect(Collectors.toMap(IndustryCategory::getId, (it) -> it));
 	}
-	
+
 	private Map<Integer, DistrictGlossory> getProvinces() {
 		return districtGlossoryService.list(0).stream().collect(Collectors.toMap(DistrictGlossory::getId, (it) -> it));
 	}
@@ -629,4 +630,14 @@ public class UserEvaluationApiController extends BaseApiController {
 		res[1] = two.longValue();
 		return res;
 	}
+
+	@RequestMapping(value = "/getLPR", method = RequestMethod.GET)
+	public Result getLPR(){
+		Result res =new Result();
+		StringBuffer str=new StringBuffer("https://www.chinamoney.com.cn/ags/ms/cm-u-bk-currency/LprChrtCSV?startDate=2022-01-01");
+		JSONObject json =HttpUtils.httpGet(str.toString());
+		System.out.println(json.toJSONString());
+		res.data(json.toJSONString());
+		return res;
+	}
 }