接口验签

yiming
1 parent fb672d59
Showing 8 changed files with 124 additions and 21 deletions
src/main/java/com/bsth/XDApplication.java
src/main/java/com/bsth/common/SystemParamKeys.java
src/main/java/com/bsth/data/SystemParamCache.java
src/main/java/com/bsth/data/commonData/SyncData.java
src/main/java/com/bsth/data/gpsdata_v2/load/GatewayHttpLoader.java
src/main/java/com/bsth/service/impl/LsSectionRouteServiceImpl.java
src/main/java/com/bsth/util/WebserviceSign.java
src/main/resources/static/real_control_v2/css/north.css
@@ -163,7 +163,7 @@ public class XDApplication implements CommandLineRunner {
         sexec.scheduleWithFixedDelay(scheduleRefreshThread, 10, 120, TimeUnit.SECONDS);//班次更新线程
         sexec.scheduleWithFixedDelay(scheduleLateThread, 140, 20, TimeUnit.SECONDS);//检查班次误点
         sexec.scheduleWithFixedDelay(gpsDataLoader, 100, 2, TimeUnit.SECONDS);//抓取GPS数据
-        sexec.scheduleWithFixedDelay(rfidDataLoader, 5, 5, TimeUnit.SECONDS);//抓取RFID数据
+        //sexec.scheduleWithFixedDelay(rfidDataLoader, 5, 5, TimeUnit.SECONDS);//抓取RFID数据
         sexec.scheduleWithFixedDelay(fixedCheckStationCodeThread, 60, 60 * 5, TimeUnit.SECONDS);//检查班次站点编码
  
         sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线
@@ -214,7 +214,7 @@ public class XDApplication implements CommandLineRunner {
         sexec.scheduleWithFixedDelay(scheduleRefreshThread, 10, 120, TimeUnit.SECONDS);//班次更新线程
         sexec.scheduleWithFixedDelay(scheduleLateThread, 140, 20, TimeUnit.SECONDS);//检查班次误点
         sexec.scheduleWithFixedDelay(gpsDataLoader, 0, 2, TimeUnit.SECONDS);//抓取GPS数据
-        sexec.scheduleWithFixedDelay(rfidDataLoader, 5, 5, TimeUnit.SECONDS);//抓取RFID数据
+        //sexec.scheduleWithFixedDelay(rfidDataLoader, 5, 5, TimeUnit.SECONDS);//抓取RFID数据
         sexec.scheduleWithFixedDelay(fixedCheckStationCodeThread, 60, 60 * 5, TimeUnit.SECONDS);//检查班次站点编码
  
         sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线
@@ -266,7 +266,7 @@ public class XDApplication implements CommandLineRunner {
         sexec.scheduleWithFixedDelay(scheduleRefreshThread, 10, 120, TimeUnit.SECONDS);//班次更新线程
         sexec.scheduleWithFixedDelay(scheduleLateThread, 140, 20, TimeUnit.SECONDS);//检查班次误点
         sexec.scheduleWithFixedDelay(gpsDataLoader, 0, 2, TimeUnit.SECONDS);//抓取GPS数据
-        sexec.scheduleWithFixedDelay(rfidDataLoader, 5, 5, TimeUnit.SECONDS);//抓取RFID数据
+        //sexec.scheduleWithFixedDelay(rfidDataLoader, 5, 5, TimeUnit.SECONDS);//抓取RFID数据
         sexec.scheduleWithFixedDelay(fixedCheckStationCodeThread, 60, 60 * 5, TimeUnit.SECONDS);//检查班次站点编码
  
         sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线
@@ -312,7 +312,7 @@ public class XDApplication implements CommandLineRunner {
         sexec.scheduleWithFixedDelay(scheduleRefreshThread, 10, 120, TimeUnit.SECONDS);//班次更新线程
         sexec.scheduleWithFixedDelay(scheduleLateThread, 140, 20, TimeUnit.SECONDS);//检查班次误点
         sexec.scheduleWithFixedDelay(gpsDataLoader, 0, 2, TimeUnit.SECONDS);//抓取GPS数据
-        sexec.scheduleWithFixedDelay(rfidDataLoader, 5, 5, TimeUnit.SECONDS);//抓取RFID数据
+        //sexec.scheduleWithFixedDelay(rfidDataLoader, 5, 5, TimeUnit.SECONDS);//抓取RFID数据
         sexec.scheduleWithFixedDelay(fixedCheckStationCodeThread, 60, 60 * 5, TimeUnit.SECONDS);//检查班次站点编码
  
         sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线
@@ -40,4 +40,6 @@ public class SystemParamKeys {
     public static final String URL_HTTP_SSO_LOGOUT = "url.http.sso.logout";
  
     public static final String URL_HTTP_SSO_AUTH = "url.http.sso.auth";
+
+    public static final String URL_HTTP_PWD = "url.http.pwd";
 }
@@ -90,6 +90,10 @@ public class SystemParamCache implements InitializingBean {
         return systemParamService1.getValue(SystemParamKeys.URL_HTTP_SSO_AUTH);
     }
  
+    public static String getUrlHttpPwd() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_PWD);
+    }
+
     @Override
     public void afterPropertiesSet() throws Exception {
         systemParamService1 = systemParamService;
@@ -91,7 +91,8 @@ public class SyncData  extends Thread{
     @Autowired
     BasicData.BasicDataLoader basicDataLoader;
  
-    @Scheduled(cron = "0 1 * * * ?")
+    //@Scheduled(cron = "0 1 * * * ?")
+    //@Transactional()
     public void SyncData(){
         syncBusiness();
         syncCarPark();
 package com.bsth.data.gpsdata_v2.load;
  
+import cn.hutool.http.HttpUtil;
 import com.alibaba.fastjson.JSON;
 import com.bsth.data.BasicData;
 import com.bsth.data.SystemParamCache;
 import com.bsth.data.gpsdata_v2.GpsRealData;
 import com.bsth.data.gpsdata_v2.entity.GpsEntity;
 import com.bsth.data.gpsdata_v2.utils.GpsDataUtils;
+import com.bsth.util.WebserviceSign;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.http.HttpEntity;
 import org.apache.http.client.config.RequestConfig;
 import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpGet;
 import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
 import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeansException;
@@ -24,7 +28,9 @@ import org.springframework.stereotype.Component;
 import java.io.BufferedReader;
 import java.io.InputStreamReader;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
  
 /**
  * 从网关http 接口加载数据
@@ -51,22 +57,12 @@ public class GatewayHttpLoader implements ApplicationContextAware, InitializingB
             if(list.size() > 0)
                 list.clear();
  
-            response = httpClient.execute(get);
-            entity = response.getEntity();
  
-            logger.info("entity:" + entity + "get:" + get);
-            if(null == entity)
-                return list;
-
-            br = new BufferedReader(new InputStreamReader(entity.getContent()));
-
-            StringBuilder sb = new StringBuilder();
-            String str;
-            while ((str = br.readLine()) != null)
-                sb.append(str);
-
-            logger.debug("gps:" + sb.toString());
-            list = JSON.parseArray(JSON.parseObject(sb.toString()).getString("data"), GpsEntity.class);
+            url =generateEndpoint(SystemParamCache.getUrlHttpGpsReal());
+            logger.info("get:" + url);
+            String sb = HttpUtil.get(url);
+            logger.info("gps:" + sb);
+            list = JSON.parseArray(sb, GpsEntity.class);
             //过滤掉无效的点位
             list = GpsDataUtils.clearInvalid(list);
  
@@ -119,4 +115,33 @@ public class GatewayHttpLoader implements ApplicationContextAware, InitializingB
                 .setSocketTimeout(2500).build();
         get.setConfig(requestConfig);
     }
+
+    /**
+     * 生成请求接口链接
+     * @param uri
+     * @return
+     */
+    private static String generateEndpoint(String uri) {
+        StringBuilder endpoint = new StringBuilder();
+        String timestamp = String.valueOf(System.currentTimeMillis());
+        String nonce = WebserviceSign.getRandomString(5);
+        Map<String, String> map = new HashMap<String, String>(3);
+        // 时间戳
+        map.put("timestamp", timestamp);
+        // 随机字符串
+        map.put("nonce", nonce);
+        // 密码
+        map.put("password", SystemParamCache.getUrlHttpPwd());
+        String signStr = null;
+        try {
+            signStr = WebserviceSign.getSHA1(map);
+        } catch (Exception e) {
+            logger.error("生成签名异常", e);
+        }
+        endpoint.append(uri).append("?timestamp=")
+                .append(timestamp).append("&nonce=").append(nonce).append("&password=")
+                .append(SystemParamCache.getUrlHttpPwd()).append("&sign=").append(signStr);
+        System.out.println(endpoint.toString());
+        return endpoint.toString();
+    }
 }
@@ -15,6 +15,7 @@ import org.springframework.data.domain.Sort;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
  
+import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -121,6 +122,8 @@ public class LsSectionRouteServiceImpl extends BaseServiceImpl&lt;LsSectionRoute, I
 		if (!isPresent) {
 			sectionRepository.save(section);
 		}
+		sectionRoute.setCreateDate(new Date());
+		sectionRoute.setUpdateDate(new Date());
 		lsSectionRouteRepository.save(sectionRoute);
 		if (sectionRoute.getVersions().equals(version)) {
 			refreshCurrent(line.getId(), version);
+package com.bsth.util;
+
+import java.security.MessageDigest;
+import java.util.Arrays;
+import java.util.Map;
+import java.util.Random;
+
+public class WebserviceSign {
+
+	/**
+	 * 生成签名
+	 * @param map
+	 * @return
+	 * @throws Exception
+	 */
+	public static String getSHA1(Map<String, String> map) throws Exception {
+		try {
+			String[] array = new String[map.size()];
+			map.values().toArray(array);
+			StringBuffer sb = new StringBuffer();
+			// 字符串排序
+			Arrays.sort(array);
+			for (int i = 0; i < array.length; i++) {
+				sb.append(array[i]);
+			}
+			String str = sb.toString();
+			// SHA1签名生成
+			MessageDigest md = MessageDigest.getInstance("SHA-1");
+			md.update(str.getBytes());
+			byte[] digest = md.digest();
+			StringBuffer hexstr = new StringBuffer();
+			String shaHex = "";
+			for (int i = 0; i < digest.length; i++) {
+				shaHex = Integer.toHexString(digest[i] & 0xFF);
+				if (shaHex.length() < 2) {
+					hexstr.append(0);
+				}
+				hexstr.append(shaHex);
+			}
+			return hexstr.toString();
+		} catch (Exception e) {
+			throw e;
+		}
+	}
+	
+	/**
+	 * 生成随机字符串
+	 * @param length
+	 * @return
+	 */
+	public static String getRandomString(int length) { //length表示生成字符串的长度  
+	    String base = "abcdefghijklmnopqrstuvwxyz0123456789";     
+	    Random random = new Random();     
+	    StringBuffer sb = new StringBuffer();     
+	    for (int i = 0; i < length; i++) {     
+	        int number = random.nextInt(base.length());     
+	        sb.append(base.charAt(number));     
+	    }     
+	    return sb.toString();     
+	 }  
+	
+	public static void main(String[] args) {
+		// TODO Auto-generated method stub
+
+	}
+	
+
+}
@@ -6,7 +6,7 @@
 }
  
 .north.main {
-    background: linear-gradient(to right, #082F4A, #125688, #0a3f64);
+    background: linear-gradient(to right, #ececef, #ececef, #ececef);
     /*background-image: url('/assets/img/title-bg.jpg');*/
     padding-bottom: 0;
 }