ManagementOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/controller/general/TWithdrawalController.java
@@ -1,11 +1,16 @@ package com.stylefeng.guns.modular.system.controller.general; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.plugins.Page; import com.stylefeng.guns.core.base.controller.BaseController; import com.stylefeng.guns.core.common.constant.factory.PageFactory; import com.stylefeng.guns.core.log.LogObjectHolder; import com.stylefeng.guns.core.util.SinataUtil; import com.stylefeng.guns.modular.system.controller.util.ExcelUtil; import com.stylefeng.guns.modular.system.controller.util.HttpUtils; import com.stylefeng.guns.modular.system.model.TDriver; import com.stylefeng.guns.modular.system.model.TWithdrawal; import com.stylefeng.guns.modular.system.service.ITDriverService; import com.stylefeng.guns.modular.system.service.ITWithdrawalService; @@ -131,6 +136,12 @@ if(withdrawal.getStatus() == 3){ withdrawal.setRemark(withdrawal.getRemark()); TWithdrawal tWithdrawal = withdrawalService.selectById(withdrawal.getId()); TDriver driver = driverService.selectById(tWithdrawal.getDriverId()); BigDecimal balance = driver.getBalance(); BigDecimal withdrawalMoney = tWithdrawal.getWithdrawalMoney(); driver.setBalance(balance.add(withdrawalMoney)); driverService.updateById(driver); } withdrawalService.updateById(withdrawal); ManagementOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/controller/util/HttpUtils.java
New file @@ -0,0 +1,363 @@ package com.stylefeng.guns.modular.system.controller.util; import com.aliyun.oss.ServiceException; import org.apache.http.Consts; import org.apache.http.HttpResponse; import org.apache.http.HttpStatus; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.entity.UrlEncodedFormEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.methods.HttpUriRequest; import org.apache.http.client.protocol.HttpClientContext; import org.apache.http.client.utils.URIBuilder; import org.apache.http.entity.StringEntity; 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.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; import org.apache.http.util.TextUtils; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URI; import java.net.URISyntaxException; import java.net.URL; import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.stream.Collectors; public class HttpUtils { //请求超时时间 private final static Integer TIME_OUT = 8 * 1000; //http连接池 private static volatile PoolingHttpClientConnectionManager poolingHttpClientConnectionManager; //请求配置 private static RequestConfig requestConfig; public static PoolingHttpClientConnectionManager getPoolingHttpClientConnectionManager() { if (poolingHttpClientConnectionManager == null) { synchronized (HttpUtils.class) { if (poolingHttpClientConnectionManager == null) { poolingHttpClientConnectionManager = new PoolingHttpClientConnectionManager(); //连接池最大连接数 poolingHttpClientConnectionManager.setMaxTotal(1024); //每个路由最大连接数 poolingHttpClientConnectionManager.setDefaultMaxPerRoute(32); //配置请求的超时设置 requestConfig = RequestConfig.custom().setConnectionRequestTimeout(TIME_OUT).setConnectTimeout(TIME_OUT).setSocketTimeout(TIME_OUT).build(); } } } return poolingHttpClientConnectionManager; } public static CloseableHttpClient getHttpClient() { return HttpClients.custom().setConnectionManager(getPoolingHttpClientConnectionManager()).setDefaultRequestConfig(requestConfig).build(); } /** * 请求发送执行 * * @param httpMethd * @return */ public static String registRequest(HttpUriRequest httpMethd) { CloseableHttpClient httpClient = getHttpClient(); try (CloseableHttpResponse httpResponse = httpClient.execute(httpMethd, HttpClientContext.create())) { int statusCode = httpResponse.getStatusLine().getStatusCode(); if (httpResponse.getStatusLine().getStatusCode() != HttpStatus.SC_OK) { httpMethd.abort(); } String response = EntityUtils.toString(httpResponse.getEntity(), Consts.UTF_8); return response; } catch (Exception e) { throw new RuntimeException("请求失败", e); } } public static List<BasicNameValuePair> toPairs(Map<String, Object> params) { List<BasicNameValuePair> pairs = new ArrayList<>(params.size()); if (params != null && !params.isEmpty()) { pairs = params.entrySet().stream().map(entry -> new BasicNameValuePair(entry.getKey(), entry.getValue().toString())).collect(Collectors.toList()); } return pairs; } /** * get url请求 * * @param url * @return */ public static String get(String url) { HttpGet request = new HttpGet(); try { request.setURI(new URI(url)); return registRequest(request); } catch (Exception e) { e.printStackTrace(); } return null; } /*** * get请求(带参数) * @param url * @return String */ public static String getReq(String url, Map<String, String> params) { String result = null; try { URIBuilder uriBuilder = new URIBuilder(url); Iterator maplist = params.entrySet().iterator(); while (maplist.hasNext()) { Map.Entry<String, String> map = (Map.Entry<String, String>) maplist.next(); uriBuilder.addParameter(map.getKey(), map.getValue()); } CloseableHttpClient client = HttpClientBuilder.create().build(); HttpGet get = new HttpGet(uriBuilder.build()); get.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.81 Safari/537.36"); HttpResponse response = client.execute(get); result = EntityUtils.toString(response.getEntity(), "UTF-8"); } catch (URISyntaxException e) { e.printStackTrace(); } catch (ClientProtocolException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return result; } /*** * get请求(带参数) * @param url * @return String */ public static String postReq(String url, Map<String, Object> params,String token) { String result = null; try { URIBuilder uriBuilder = new URIBuilder(url); Iterator maplist = params.entrySet().iterator(); while (maplist.hasNext()) { Map.Entry<String, Object> map = (Map.Entry<String, Object>) maplist.next(); uriBuilder.addParameter(map.getKey(), String.valueOf(map.getValue())); } CloseableHttpClient client = HttpClientBuilder.create().build(); HttpPost post = new HttpPost(uriBuilder.build()); post.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.81 Safari/537.36"); post.addHeader("Content-type", "application/json"); post.addHeader("Accept", "application/json"); post.addHeader("Authorization", token); HttpResponse response = client.execute(post); result = EntityUtils.toString(response.getEntity(), "UTF-8"); } catch (URISyntaxException e) { e.printStackTrace(); } catch (ClientProtocolException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return result; } /** * PSOT URL方式提交 * * @param url 请求url * @param params 请求参数 * @return */ public static String postFromUrl(String url, Map<String, Object> params) { HttpPost request = new HttpPost(url); request.setEntity(new UrlEncodedFormEntity(toPairs(params), Consts.UTF_8)); try { return registRequest(request); } catch (Exception e) { e.printStackTrace(); } return null; } /** * PSOT JSON方式提交 * * @param url 请求url * @param params json串 * @return */ public static String postFromJson(String url, String params,String token) { HttpPost request = new HttpPost(url); request.setHeader("Content-type", "application/json"); request.setHeader("Accept", "application/json"); request.setHeader("Authorization", token); RequestConfig requestConfig = RequestConfig.custom() .setSocketTimeout(8000) .setConnectTimeout(6000) .build(); request.setConfig(requestConfig); StringEntity entity = new StringEntity(params, StandardCharsets.UTF_8); entity.setContentType("application/json"); request.setEntity(entity); try { return registRequest(request); } catch (Exception e) { e.printStackTrace(); } return null; } /** * PSOT JSON方式提交 * * @param url 请求url * @param params json串 * @return */ public static String postFromJson(String url, String params) { HttpPost request = new HttpPost(url); request.setHeader("Content-type", "application/json"); request.setHeader("Accept", "application/json"); RequestConfig requestConfig = RequestConfig.custom() .setSocketTimeout(8000) .setConnectTimeout(6000) .build(); request.setConfig(requestConfig); StringEntity entity = new StringEntity(params, StandardCharsets.UTF_8); entity.setContentType("application/json"); request.setEntity(entity); try { return registRequest(request); } catch (Exception e) { e.printStackTrace(); } return null; } /** * post请求带token * @param strURL * @param params * @param token * @return */ public static String post(String strURL, String params, String token) { String result = ""; BufferedReader reader = null; try { System.out.println(strURL); System.out.println(params); URL url = new URL(strURL);// 创建连接 HttpURLConnection connection = (HttpURLConnection) url .openConnection(); connection.setDoOutput(true); connection.setDoInput(true); connection.setUseCaches(false); connection.setInstanceFollowRedirects(true); connection.setRequestMethod("POST"); // 设置请求方式 connection.setRequestProperty("Accept", "application/json;charset=utf-8"); // 设置接收数据的格式 connection.setRequestProperty("Content-Type", "application/json;charset=utf-8"); // 设置发送数据的格式 connection.setRequestProperty("Authorization", token); // 设置token connection.connect(); if (params != null && !TextUtils.isEmpty(params)) { byte[] writebytes = params.getBytes(); // 设置文件长度 // connection.setRequestProperty("Content-Length", String.valueOf(writebytes.length)); OutputStream outwritestream = connection.getOutputStream(); outwritestream.write(params.getBytes()); outwritestream.flush(); outwritestream.close(); // Log.d("hlhupload", "doJsonPost: conn"+connection.getResponseCode()); } if (connection.getResponseCode() == 200) { reader = new BufferedReader( new InputStreamReader(connection.getInputStream())); result = reader.readLine(); } else { throw new ServiceException(connection.getResponseMessage()); } } catch (Exception e) { throw new ServiceException("http的post请求异常!" + e.getMessage()); } finally { if (reader != null) { try { reader.close(); } catch (IOException e) { e.printStackTrace(); } } } return result; } /** * post请求 * @param strURL * @param params * @return */ public static String post(String strURL, String params) { String result = ""; BufferedReader reader = null; try { URL url = new URL(strURL);// 创建连接 HttpURLConnection connection = (HttpURLConnection) url .openConnection(); connection.setDoOutput(true); connection.setDoInput(true); connection.setUseCaches(false); connection.setInstanceFollowRedirects(true); connection.setRequestMethod("POST"); // 设置请求方式 connection.setRequestProperty("Accept", "application/json;charset=utf-8"); // 设置接收数据的格式 connection.setRequestProperty("Content-Type", "application/json;charset=utf-8"); // 设置发送数据的格式 connection.connect(); if (params != null && !TextUtils.isEmpty(params)) { byte[] writebytes = params.getBytes(); // 设置文件长度 // connection.setRequestProperty("Content-Length", String.valueOf(writebytes.length)); OutputStream outwritestream = connection.getOutputStream(); outwritestream.write(params.getBytes()); outwritestream.flush(); outwritestream.close(); // Log.d("hlhupload", "doJsonPost: conn"+connection.getResponseCode()); } if (connection.getResponseCode() == 200) { reader = new BufferedReader( new InputStreamReader(connection.getInputStream())); result = reader.readLine(); } else { throw new ServiceException(connection.getResponseMessage()); } } catch (Exception e) { throw new ServiceException("http的post请求异常!" + e.getMessage()); } finally { if (reader != null) { try { reader.close(); } catch (IOException e) { e.printStackTrace(); } } } return result; } }
@@ -1,7 +1,8 @@ package com.stylefeng.guns.modular.system.util; public class PushURL { public static String zull_user_url = "https://xn95128.cn"; // public static String zull_user_url = "https://xn95128.cn"; public static String zull_user_url = "http://221.182.45.100:7777"; public static String order_push_url = zull_user_url + "/driver/base/order/pushOrderState"; public static String driver_auth_url = zull_user_url + "/driver/base/driver/sendsms"; public static String withdraw_auth_url = zull_user_url + "/driver/base/withdrawal/withdrawalAudit"; UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/core/util/HttpUtil.java
New file @@ -0,0 +1,363 @@ package com.stylefeng.guns.core.util; import com.aliyun.oss.ServiceException; import org.apache.http.Consts; import org.apache.http.HttpResponse; import org.apache.http.HttpStatus; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.entity.UrlEncodedFormEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.methods.HttpUriRequest; import org.apache.http.client.protocol.HttpClientContext; import org.apache.http.client.utils.URIBuilder; import org.apache.http.entity.StringEntity; 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.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; import org.apache.http.util.TextUtils; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URI; import java.net.URISyntaxException; import java.net.URL; import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.stream.Collectors; public class HttpUtil { //请求超时时间 private final static Integer TIME_OUT = 8 * 1000; //http连接池 private static volatile PoolingHttpClientConnectionManager poolingHttpClientConnectionManager; //请求配置 private static RequestConfig requestConfig; public static PoolingHttpClientConnectionManager getPoolingHttpClientConnectionManager() { if (poolingHttpClientConnectionManager == null) { synchronized (HttpUtils.class) { if (poolingHttpClientConnectionManager == null) { poolingHttpClientConnectionManager = new PoolingHttpClientConnectionManager(); //连接池最大连接数 poolingHttpClientConnectionManager.setMaxTotal(1024); //每个路由最大连接数 poolingHttpClientConnectionManager.setDefaultMaxPerRoute(32); //配置请求的超时设置 requestConfig = RequestConfig.custom().setConnectionRequestTimeout(TIME_OUT).setConnectTimeout(TIME_OUT).setSocketTimeout(TIME_OUT).build(); } } } return poolingHttpClientConnectionManager; } public static CloseableHttpClient getHttpClient() { return HttpClients.custom().setConnectionManager(getPoolingHttpClientConnectionManager()).setDefaultRequestConfig(requestConfig).build(); } /** * 请求发送执行 * * @param httpMethd * @return */ public static String registRequest(HttpUriRequest httpMethd) { CloseableHttpClient httpClient = getHttpClient(); try (CloseableHttpResponse httpResponse = httpClient.execute(httpMethd, HttpClientContext.create())) { int statusCode = httpResponse.getStatusLine().getStatusCode(); if (httpResponse.getStatusLine().getStatusCode() != HttpStatus.SC_OK) { httpMethd.abort(); } String response = EntityUtils.toString(httpResponse.getEntity(), Consts.UTF_8); return response; } catch (Exception e) { throw new RuntimeException("请求失败", e); } } public static List<BasicNameValuePair> toPairs(Map<String, Object> params) { List<BasicNameValuePair> pairs = new ArrayList<>(params.size()); if (params != null && !params.isEmpty()) { pairs = params.entrySet().stream().map(entry -> new BasicNameValuePair(entry.getKey(), entry.getValue().toString())).collect(Collectors.toList()); } return pairs; } /** * get url请求 * * @param url * @return */ public static String get(String url) { HttpGet request = new HttpGet(); try { request.setURI(new URI(url)); return registRequest(request); } catch (Exception e) { e.printStackTrace(); } return null; } /*** * get请求(带参数) * @param url * @return String */ public static String getReq(String url, Map<String, String> params) { String result = null; try { URIBuilder uriBuilder = new URIBuilder(url); Iterator maplist = params.entrySet().iterator(); while (maplist.hasNext()) { Map.Entry<String, String> map = (Map.Entry<String, String>) maplist.next(); uriBuilder.addParameter(map.getKey(), map.getValue()); } CloseableHttpClient client = HttpClientBuilder.create().build(); HttpGet get = new HttpGet(uriBuilder.build()); get.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.81 Safari/537.36"); HttpResponse response = client.execute(get); result = EntityUtils.toString(response.getEntity(), "UTF-8"); } catch (URISyntaxException e) { e.printStackTrace(); } catch (ClientProtocolException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return result; } /*** * get请求(带参数) * @param url * @return String */ public static String postReq(String url, Map<String, Object> params,String token) { String result = null; try { URIBuilder uriBuilder = new URIBuilder(url); Iterator maplist = params.entrySet().iterator(); while (maplist.hasNext()) { Map.Entry<String, Object> map = (Map.Entry<String, Object>) maplist.next(); uriBuilder.addParameter(map.getKey(), String.valueOf(map.getValue())); } CloseableHttpClient client = HttpClientBuilder.create().build(); HttpPost post = new HttpPost(uriBuilder.build()); post.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.81 Safari/537.36"); post.addHeader("Content-type", "application/json"); post.addHeader("Accept", "application/json"); post.addHeader("Authorization", token); HttpResponse response = client.execute(post); result = EntityUtils.toString(response.getEntity(), "UTF-8"); } catch (URISyntaxException e) { e.printStackTrace(); } catch (ClientProtocolException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return result; } /** * PSOT URL方式提交 * * @param url 请求url * @param params 请求参数 * @return */ public static String postFromUrl(String url, Map<String, Object> params) { HttpPost request = new HttpPost(url); request.setEntity(new UrlEncodedFormEntity(toPairs(params), Consts.UTF_8)); try { return registRequest(request); } catch (Exception e) { e.printStackTrace(); } return null; } /** * PSOT JSON方式提交 * * @param url 请求url * @param params json串 * @return */ public static String postFromJson(String url, String params,String token) { HttpPost request = new HttpPost(url); request.setHeader("Content-type", "application/json"); request.setHeader("Accept", "application/json"); request.setHeader("Authorization", token); RequestConfig requestConfig = RequestConfig.custom() .setSocketTimeout(8000) .setConnectTimeout(6000) .build(); request.setConfig(requestConfig); StringEntity entity = new StringEntity(params, StandardCharsets.UTF_8); entity.setContentType("application/json"); request.setEntity(entity); try { return registRequest(request); } catch (Exception e) { e.printStackTrace(); } return null; } /** * PSOT JSON方式提交 * * @param url 请求url * @param params json串 * @return */ public static String postFromJson(String url, String params) { HttpPost request = new HttpPost(url); request.setHeader("Content-type", "application/json"); request.setHeader("Accept", "application/json"); RequestConfig requestConfig = RequestConfig.custom() .setSocketTimeout(8000) .setConnectTimeout(6000) .build(); request.setConfig(requestConfig); StringEntity entity = new StringEntity(params, StandardCharsets.UTF_8); entity.setContentType("application/json"); request.setEntity(entity); try { return registRequest(request); } catch (Exception e) { e.printStackTrace(); } return null; } /** * post请求带token * @param strURL * @param params * @param token * @return */ public static String post(String strURL, String params, String token) { String result = ""; BufferedReader reader = null; try { System.out.println(strURL); System.out.println(params); URL url = new URL(strURL);// 创建连接 HttpURLConnection connection = (HttpURLConnection) url .openConnection(); connection.setDoOutput(true); connection.setDoInput(true); connection.setUseCaches(false); connection.setInstanceFollowRedirects(true); connection.setRequestMethod("POST"); // 设置请求方式 connection.setRequestProperty("Accept", "application/json;charset=utf-8"); // 设置接收数据的格式 connection.setRequestProperty("Content-Type", "application/json;charset=utf-8"); // 设置发送数据的格式 connection.setRequestProperty("Authorization", token); // 设置token connection.connect(); if (params != null && !TextUtils.isEmpty(params)) { byte[] writebytes = params.getBytes(); // 设置文件长度 // connection.setRequestProperty("Content-Length", String.valueOf(writebytes.length)); OutputStream outwritestream = connection.getOutputStream(); outwritestream.write(params.getBytes()); outwritestream.flush(); outwritestream.close(); // Log.d("hlhupload", "doJsonPost: conn"+connection.getResponseCode()); } if (connection.getResponseCode() == 200) { reader = new BufferedReader( new InputStreamReader(connection.getInputStream())); result = reader.readLine(); } else { throw new ServiceException(connection.getResponseMessage()); } } catch (Exception e) { throw new ServiceException("http的post请求异常!" + e.getMessage()); } finally { if (reader != null) { try { reader.close(); } catch (IOException e) { e.printStackTrace(); } } } return result; } /** * post请求 * @param strURL * @param params * @return */ public static String post(String strURL, String params) { String result = ""; BufferedReader reader = null; try { URL url = new URL(strURL);// 创建连接 HttpURLConnection connection = (HttpURLConnection) url .openConnection(); connection.setDoOutput(true); connection.setDoInput(true); connection.setUseCaches(false); connection.setInstanceFollowRedirects(true); connection.setRequestMethod("POST"); // 设置请求方式 connection.setRequestProperty("Accept", "application/json;charset=utf-8"); // 设置接收数据的格式 connection.setRequestProperty("Content-Type", "application/json;charset=utf-8"); // 设置发送数据的格式 connection.connect(); if (params != null && !TextUtils.isEmpty(params)) { byte[] writebytes = params.getBytes(); // 设置文件长度 // connection.setRequestProperty("Content-Length", String.valueOf(writebytes.length)); OutputStream outwritestream = connection.getOutputStream(); outwritestream.write(params.getBytes()); outwritestream.flush(); outwritestream.close(); // Log.d("hlhupload", "doJsonPost: conn"+connection.getResponseCode()); } if (connection.getResponseCode() == 200) { reader = new BufferedReader( new InputStreamReader(connection.getInputStream())); result = reader.readLine(); } else { throw new ServiceException(connection.getResponseMessage()); } } catch (Exception e) { throw new ServiceException("http的post请求异常!" + e.getMessage()); } finally { if (reader != null) { try { reader.close(); } catch (IOException e) { e.printStackTrace(); } } } return result; } }
@@ -1,6 +1,11 @@ package com.stylefeng.guns.modular.api; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.stylefeng.guns.core.util.HttpUtil; import com.stylefeng.guns.core.util.HttpUtils; import com.stylefeng.guns.core.util.ToolUtil; import com.stylefeng.guns.modular.CharteredCar.server.IOrderCharteredCarService; import com.stylefeng.guns.modular.crossCity.model.OrderCrossCity; @@ -22,6 +27,7 @@ import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.apache.http.HttpResponse; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.*; @@ -1396,6 +1402,27 @@ e.printStackTrace(); } } /** * 路线规划 * @param request */ @ResponseBody @PostMapping("/base/loadLine") public ResultUtil aliPayOrderLogisticsSpread(String startLat, String startLon, String nextLatitude, String nextLongitude, HttpServletRequest request, HttpServletResponse response){ try { String url = "https://api.map.baidu.com/directionlite/v1/driving?origin="+startLat+","+startLon+"&destination="+nextLatitude+","+nextLongitude+"&ak=WQhfsluNzEeUHUxoH4jc4JiCQOXw4Mnx"; String get = HttpUtil.get(url); JSONObject jsonObject = JSON.parseObject(get); JSONArray jsonArray = jsonObject.getJSONObject("result").getJSONArray("routes").getJSONObject(0).getJSONArray("steps"); System.out.println(jsonArray); return ResultUtil.success(jsonArray); }catch (Exception e){ e.printStackTrace(); return ResultUtil.runErr(); } }
