接口没有改https协议，故改会http请求

娄高锋
1 parent 4681a8ec
Showing 10 changed files with 223 additions and 219 deletions
src/main/java/com/bsth/realschedule/DataUpload.java
src/main/java/com/bsth/serviec_jk/JkToken.java
src/main/java/com/bsth/serviec_jk/car_start/CarStartService.java
src/main/java/com/bsth/serviec_jk/xl_basic/HttpService.java
src/main/java/com/bsth/serviec_jk/xl_basic/XlBasicService.java
src/main/java/com/bsth/utils/HttpUtils.java
src/main/java/com/bsth/utils/postUtil.java
src/main/resources/application-dev.yml
src/main/resources/application-prod.yml
src/main/resources/application.yml
@@ -45,7 +45,7 @@ public class DataUpload {
 	 * 云平台数据需求对接（建交委）
 	 * @throws Exception
 	 */
-	@Scheduled(cron = "0 00 06 * * ? ")
+	@Scheduled(cron = "0 00 06 * * ? ")  // 每天凌晨6点
 	public void realScheduleUpload() throws Exception{
 		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
 		SimpleDateFormat sdf2 = new SimpleDateFormat("yyyyMMdd");
@@ -205,7 +205,7 @@ public class DataUpload {
 				listGroup.add(newList);
 			}
-			String json= getHttpInterface("https://180.167.126.126:8992/api/getcode");
+			String json= getHttpInterface("http://180.167.126.126:8992/api/getcode");
 			Map<String, Object> map=(Map<String, Object>) JSONObject.parse(json);
 			String token = encrypt(accessToken, map.get("result").toString());
 			String deleteAll = "TRUE";
@@ -218,7 +218,7 @@ public class DataUpload {
 //				param.put("DeleteAll", deleteAll);
 //				param.put("DataList", JSON.toJSONString(list));
 				param.put("list", URLEncoder.encode(JSON.toJSONStringWithDateFormat(list, "yyyy-MM-dd HH:mm:ss"), "UTF-8"));
-				HttpUtils.request("https://180.167.126.126:8992/api/todaybuslinescheduleinfo/addEntityList",
+				HttpUtils.request("http://180.167.126.126:8992/api/todaybuslinescheduleinfo/addEntityList",
 						new BackClass(), "POST", header, param);
 				deleteAll = "FALSE";
 			}
@@ -377,7 +377,7 @@ public class DataUpload {
 				listGroup.add(newList);
 			}
-			String json= getHttpInterface("https://180.167.126.126:8992/api/getcode");
+			String json= getHttpInterface("http://180.167.126.126:8992/api/getcode");
 			Map<String, Object> map=(Map<String, Object>) JSONObject.parse(json);
 			String token = encrypt(accessToken, map.get("result").toString());
 			String deleteAll = "TRUE";
@@ -389,8 +389,8 @@ public class DataUpload {
 //				param.put("AccessToken", token);
 //				param.put("DeleteAll", deleteAll);
 //				param.put("DataList", JSON.toJSONString(list));
-//				param.put("list", URLEncoder.encode(JSON.toJSONStringWithDateFormat(list, "yyyy-MM-dd HH:mm:ss"), "UTF-8"));
-				HttpUtils.request("https://180.167.126.126:8992/api/busdispatchuncarrymileage/addEntityList",
+				param.put("list", URLEncoder.encode(JSON.toJSONStringWithDateFormat(list, "yyyy-MM-dd HH:mm:ss"), "UTF-8"));
+				HttpUtils.request("http://180.167.126.126:8992/api/busdispatchuncarrymileage/addEntityList",
 						new BackClass(), "POST", header, param);
 				deleteAll = "FALSE";
 			}
@@ -568,7 +568,7 @@ public class DataUpload {
 				listGroup.add(newList);
 			}
-			String json= getHttpInterface("https://180.167.126.126:8992/api/getcode");
+			String json= getHttpInterface("http://180.167.126.126:8992/api/getcode");
 			Map<String, Object> map=(Map<String, Object>) JSONObject.parse(json);
 			String token = encrypt(accessToken, map.get("result").toString());
 			String deleteAll = "TRUE";
@@ -580,8 +580,8 @@ public class DataUpload {
 //				param.put("AccessToken", token);
 //				param.put("DeleteAll", deleteAll);
 //				param.put("DataList", JSON.toJSONString(list));
-//				param.put("list", URLEncoder.encode(JSON.toJSONStringWithDateFormat(list, "yyyy-MM-dd HH:mm:ss"), "UTF-8"));
-				HttpUtils.request("https://180.167.126.126:8992/api/busdispatchundonemileage/addEntityList",
+				param.put("list", URLEncoder.encode(JSON.toJSONStringWithDateFormat(list, "yyyy-MM-dd HH:mm:ss"), "UTF-8"));
+				HttpUtils.request("http://180.167.126.126:8992/api/busdispatchundonemileage/addEntityList",
 						new BackClass(), "POST", header, param);
 				deleteAll = "FALSE";
 			}
@@ -15,7 +15,7 @@ public class JkToken {
     public static String jkdata() {
         try {
            String token ="abfed98867c64fde99f7f88a4532efa8";
-            String endpoint = "https://180.167.126.126:8992/api/getcode";
+            String endpoint = "http://180.167.126.126:8992/api/getcode";
             InputStream in = null;
             try {
                 HttpURLConnection con = (HttpURLConnection) new URL(endpoint).openConnection();
@@ -33,7 +33,7 @@ public class CarStartService {
     public  void  listall() throws UnsupportedEncodingException {
         log.info("调用车辆发车信息接口开始---------------");
         long startTime=System.currentTimeMillis();
-        String url="https://180.167.126.126:8992/api/todaybuslinescheduleshiftinfo/addEntityList";
+        String url="http://180.167.126.126:8992/api/todaybuslinescheduleshiftinfo/addEntityList";
         Map<String,Object> map = new HashMap<>();
         //不走缓存，暂时直连数据库
         List<Clfcxxb> list = jdbcTemplate.query("select * from  bsth_t_clfcxxb", BeanPropertyRowMapper.newInstance(Clfcxxb.class));
-package com.bsth.serviec_jk.xl_basic;
-
-import com.alibaba.fastjson.JSONObject;
-import com.bsth.utils.HttpUtils;
-import com.bsth.utils.postUtil;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.IOException;
-import java.io.UnsupportedEncodingException;
-
-
-public class HttpService {
-    private final static Logger log = LoggerFactory.getLogger(HttpUtils.class);
-    
-    public static int httpRequestResult(JSONObject json, String token, String url, int count){
-
-
-
-        String result= null;
-        try {
-            result = postUtil.send(url, json, "UTF-8", token);
-            System.out.println(result);
-        } catch (UnsupportedEncodingException e) {
-            e.printStackTrace();
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
-        log.info("返回结果------------------"+result);
-        if(result !=null){
-            if(result.indexOf("state")!=-1){
-                log.info("第"+count+"次调用插入成功！");
-                return 1;
-            }else {
-                log.info("第"+count+"次调用插入失败！");
-                return -1;
-            }
-        }
-        log.info("第"+count+"次调用插入未返回数据！");
-        return -1;
-    }
-    
-    public static int httpRequestResulty(String json, String token, String url, int count){
-        String result= null;
-        try {
-            result = postUtil.sendy(url, json, "UTF-8", token);
-            System.out.println(result);
-        } catch (UnsupportedEncodingException e) {
-            e.printStackTrace();
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
-        log.info("返回结果------------------"+result);
-        if(result !=null){
-            if(result.indexOf("state")!=-1){
-                log.info("第"+count+"次调用插入成功！");
-                return 1;
-            }else {
-                log.info("第"+count+"次调用插入失败！");
-                return -1;
-            }
-        }
-        log.info("第"+count+"次调用插入未返回数据！");
-        return -1;
-    }
-}
+package com.bsth.serviec_jk.xl_basic;
+
+import com.alibaba.fastjson.JSONObject;
+import com.bsth.utils.HttpUtils;
+import com.bsth.utils.postUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+
+
+public class HttpService {
+    private final static Logger log = LoggerFactory.getLogger(HttpUtils.class);
+    
+    public static int httpRequestResult(JSONObject json, String token, String url, int count){
+
+
+
+        String result= null;
+        try {
+            result = postUtil.send(url, json, "UTF-8", token);
+            System.out.println(result);
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        log.info("返回结果------------------"+result);
+        if(result !=null){
+            if(result.indexOf("state")!=-1){
+                log.info("第"+count+"次调用插入成功！");
+                return 1;
+            }else {
+                log.info("第"+count+"次调用插入失败！");
+                return -1;
+            }
+        }
+        log.info("第"+count+"次调用插入未返回数据！");
+        return -1;
+    }
+    
+    public static int httpRequestResulty(String json, String token, String url, int count){
+        String result= null;
+        try {
+            result = postUtil.sendy(url, json, "UTF-8", token);
+            System.out.println(result);
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        log.info("返回结果------------------"+result);
+        if(result !=null){
+            if(result.indexOf("state")!=-1){
+                log.info("第"+count+"次调用插入成功！");
+                return 1;
+            }else {
+                log.info("第"+count+"次调用插入失败！");
+                return -1;
+            }
+        }
+        log.info("第"+count+"次调用插入未返回数据！");
+        return -1;
+    }
+}
@@ -37,7 +37,7 @@ public class XlBasicService {
         log.info("调用线路基本信息接口开始---------------");
         long startTime=System.currentTimeMillis();
         Map<String,Object> xlmap = new LinkedHashMap<>();
-        String url = "https://180.167.126.126:8992/api/buslineinfo/insertlist";
+        String url = "http://180.167.126.126:8992/api/buslineinfo/insertlist";
         try{
             String password = "6DABD12209BEDAB0808CF7DC967EC2B4C6748277";
             String timestamp = String.valueOf(System.currentTimeMillis());
@@ -171,7 +171,7 @@ public class XlBasicService {
     public  void  xlparameter(){
         log.info("调用线路参数信息接口开始---------------");
         long startTime=System.currentTimeMillis();
-        String url = "https://180.167.126.126:8992/api/buslineparmterinfo/insertlist";
+        String url = "http://180.167.126.126:8992/api/buslineparmterinfo/insertlist";
         Map<String,Object> xlmap = new HashMap<>();
         try{
             String password = "6DABD12209BEDAB0808CF7DC967EC2B4C6748277";
@@ -306,7 +306,7 @@ public class XlBasicService {
         long startTime=System.currentTimeMillis();
         Map<String,Object> xlmap = new HashMap<>();
         List numlist = new ArrayList();
-        String url="https://180.167.126.126:8992/api/stationnetpoints/insertlist";
+        String url="http://180.167.126.126:8992/api/stationnetpoints/insertlist";
         try{
             String password = "6DABD12209BEDAB0808CF7DC967EC2B4C6748277";
             String timestamp = String.valueOf(System.currentTimeMillis());
@@ -420,7 +420,7 @@ public class XlBasicService {
         long startTime=System.currentTimeMillis();
         Map<String,Object> xlmap = new HashMap<>();
         List numlist = new ArrayList();
-        String url="https://180.167.126.126:8992/api/buslinenetstation/insertlist";
+        String url="http://180.167.126.126:8992/api/buslinenetstation/insertlist";
         try{
             String password = "6DABD12209BEDAB0808CF7DC967EC2B4C6748277";
             String timestamp = String.valueOf(System.currentTimeMillis());
@@ -68,8 +68,8 @@ public class HttpUtils {
 //            con.setRequestProperty("charset", "utf-8");
             con.setDoInput(true);
             con.setDoOutput(true);
-            con.setReadTimeout(20000);
-            con.setConnectTimeout(20000);
+            con.setReadTimeout(180000);
+            con.setConnectTimeout(180000);
             if (header.size() > 0) {
                 for (Map.Entry<String, String> entry : header.entrySet()) {
-package com.bsth.utils;
-
-import com.alibaba.fastjson.JSONObject;
-import net.sf.json.JSONArray;
-import org.apache.http.HttpEntity;
-import org.apache.http.ParseException;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.entity.StringEntity;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.apache.http.message.BasicHeader;
-import org.apache.http.util.EntityUtils;
-import java.io.IOException;
-
-public class postUtil {
-    
-    public static String send(String url, JSONObject jsonObject, String encoding, String token) throws ParseException, IOException {
-        String body = "";
-
-        CloseableHttpClient client = HttpClients.createDefault();
-
-        HttpPost httpPost = new HttpPost(url);
-
-        StringEntity s = new StringEntity(jsonObject.toString(), "utf-8");
-        s.setContentEncoding(new BasicHeader("Content-Type", "application/json"));
-
-        httpPost.setEntity(s);
-        System.out.println("请求地址：" + url);
-
-        httpPost.setHeader("Content-type", "application/json");
-        httpPost.setHeader("Access-Token", token);
-
-        CloseableHttpResponse response = client.execute(httpPost);
-
-        HttpEntity entity = response.getEntity();
-        if (entity != null)
-        {
-            body = EntityUtils.toString(entity, encoding);
-        }
-        EntityUtils.consume(entity);
-
-        response.close();
-        return body;
-    }
-
-    public static String sendy(String url, String object, String encoding, String token) throws ParseException, IOException {
-        String body = "";
-
-        CloseableHttpClient client = HttpClients.createDefault();
-
-        HttpPost httpPost = new HttpPost(url);
-
-        StringEntity s = new StringEntity(object, "utf-8");
-        s.setContentEncoding(new BasicHeader("Content-Type", "application/json"));
-
-        httpPost.setEntity(s);
-        System.out.println("请求地址：" + url);
-
-        httpPost.setHeader("Content-type", "application/json");
-        httpPost.setHeader("Access-Token", token);
-
-        CloseableHttpResponse response = client.execute(httpPost);
-
-        HttpEntity entity = response.getEntity();
-        if (entity != null)
-        {
-            body = EntityUtils.toString(entity, encoding);
-        }
-        EntityUtils.consume(entity);
-
-        response.close();
-        return body;
-    }
-
-}
+package com.bsth.utils;
+
+import com.alibaba.fastjson.JSONObject;
+import net.sf.json.JSONArray;
+import org.apache.http.HttpEntity;
+import org.apache.http.ParseException;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicHeader;
+import org.apache.http.util.EntityUtils;
+import java.io.IOException;
+
+public class postUtil {
+    
+    public static String send(String url, JSONObject jsonObject, String encoding, String token) throws ParseException, IOException {
+        String body = "";
+
+        CloseableHttpClient client = HttpClients.createDefault();
+
+        HttpPost httpPost = new HttpPost(url);
+
+        StringEntity s = new StringEntity(jsonObject.toString(), "utf-8");
+        s.setContentEncoding(new BasicHeader("Content-Type", "application/json"));
+
+        httpPost.setEntity(s);
+        System.out.println("请求地址：" + url);
+
+        httpPost.setHeader("Content-type", "application/json");
+        httpPost.setHeader("Access-Token", token);
+
+        CloseableHttpResponse response = client.execute(httpPost);
+
+        HttpEntity entity = response.getEntity();
+        if (entity != null)
+        {
+            body = EntityUtils.toString(entity, encoding);
+        }
+        EntityUtils.consume(entity);
+
+        response.close();
+        return body;
+    }
+
+    public static String sendy(String url, String object, String encoding, String token) throws ParseException, IOException {
+        String body = "";
+
+        CloseableHttpClient client = HttpClients.createDefault();
+
+        HttpPost httpPost = new HttpPost(url);
+
+        StringEntity s = new StringEntity(object, "utf-8");
+        s.setContentEncoding(new BasicHeader("Content-Type", "application/json"));
+
+        httpPost.setEntity(s);
+        System.out.println("请求地址：" + url);
+
+        httpPost.setHeader("Content-type", "application/json");
+        httpPost.setHeader("Access-Token", token);
+
+        CloseableHttpResponse response = client.execute(httpPost);
+
+        HttpEntity entity = response.getEntity();
+        if (entity != null)
+        {
+            body = EntityUtils.toString(entity, encoding);
+        }
+        EntityUtils.consume(entity);
+
+        response.close();
+        return body;
+    }
+
+}
-server:
-  port: 10010
-
-management:
-  port: 9001
-  address: 127.0.0.1
-  security:
-    enabled: false
-  context-path: /manage
-
-#DATASOURCE
-spring:
-  datasource:
-    driver-class-name: com.mysql.jdbc.Driver
-    url: jdbc:mysql://192.168.168.241/pd_control?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
-    username: root
-    password: root2jsp
-    max-active: 100
-    max-idle: 8
-    min-idle: 8
-    initial-size: 5
-    test-on-borrow: true
-    test-on-connect: true
-    test-on-return: true
-    test-while-idle: true
-    validation-query: select 1
-## gateway real data
-http:
-  gps:
-    real:
+server:
+  port: 10010
+
+management:
+  port: 9001
+  address: 127.0.0.1
+  security:
+    enabled: false
+  context-path: /manage
+
+#DATASOURCE
+spring:
+  datasource:
+    driver-class-name: com.mysql.jdbc.Driver
+#    url: jdbc:mysql://192.168.168.241/pd_control?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
+#    username: root
+#    password: root2jsp
+    url: jdbc:mysql://127.0.0.1/control?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
+    username: root
+    password: root
+    max-active: 100
+    max-idle: 8
+    min-idle: 8
+    initial-size: 5
+    test-on-borrow: true
+    test-on-connect: true
+    test-on-return: true
+    test-while-idle: true
+    validation-query: select 1
+## gateway real data
+http:
+  gps:
+    real:
       url: http://114.80.178.12:18080/transport_server/rtgps/
 \ No newline at end of file
-server:
-  port: 29088
-
-management:
-  port: 9001
-  address: 127.0.0.1
-  security:
-    enabled: false
-  context-path: /manage
-
-#DATASOURCE
-spring:
-  datasource:
-    driver-class-name: com.mysql.jdbc.Driver
-    url: jdbc:mysql://10.10.200.121/control?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
-    username: root
-    password: root2jsp
-    max-active: 100
-    max-idle: 8
-    min-idle: 8
-    initial-size: 5
-    test-on-borrow: true
-    test-on-connect: true
-    test-on-return: true
-    test-while-idle: true
-    validation-query: select 1
-## gateway real data
-http:
-  gps:
-    real:
+server:
+  port: 29088
+
+management:
+  port: 9001
+  address: 127.0.0.1
+  security:
+    enabled: false
+  context-path: /manage
+
+#DATASOURCE
+spring:
+  datasource:
+    driver-class-name: com.mysql.jdbc.Driver
+    url: jdbc:mysql://10.10.200.121/control?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
+    username: root
+    password: root2jsp
+    max-active: 100
+    max-idle: 8
+    min-idle: 8
+    initial-size: 5
+    test-on-borrow: true
+    test-on-connect: true
+    test-on-return: true
+    test-while-idle: true
+    validation-query: select 1
+## gateway real data
+http:
+  gps:
+    real:
       url: http://10.10.200.79:8080/transport_server/rtgps/
 \ No newline at end of file
 spring:
   profiles:
     active: prod
+    #dev,prod
   view:
     suffix: .html
 server: