update...

潘钊
1 parent df403c1b
Showing 6 changed files with 189 additions and 1 deletions
src/main/java/com/bsth/Application.java
src/main/java/com/bsth/StartCommand.java
src/main/java/com/bsth/server_rs/schedule/real/SchRealInfoBuffer.java
src/main/java/com/bsth/server_rs/schedule/real/ScheduleRealService.java
src/main/java/com/bsth/server_rs/schedule/real/thread/SchInOutDataRefreshThread.java
src/main/java/com/bsth/util/HttpClientUtils.java
@@ -11,7 +11,7 @@ import java.util.concurrent.ScheduledExecutorService;
 @SpringBootApplication
 public class Application extends SpringBootServletInitializer {
  
-	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(8);
+	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(9);
  
 	@Override
 	protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
 package com.bsth;
  
  
+import com.bsth.server_rs.schedule.real.thread.SchInOutDataRefreshThread;
 import com.bsth.server_rs.thread.RfidCardInfoPersistenceThread;
 import com.bsth.service.Line2SystemService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -25,6 +26,9 @@ public class StartCommand implements CommandLineRunner{
 	@Autowired
 	RfidCardInfoPersistenceThread rfidCardInfoPersistenceThread;
  
+	@Autowired
+	SchInOutDataRefreshThread schInOutDataRefreshThread;
+
 	@Override
 	public void run(String... arg0){
  
@@ -37,6 +41,9 @@ public class StartCommand implements CommandLineRunner{
 			sexec.scheduleWithFixedDelay(rfidCardInfoPersistenceThread, 120, 60 * 10, TimeUnit.SECONDS);
 			//OldWSClient.returnCCInfo();
 			//OldWSClient.getCurrentDayPlan();
+
+			//定时从调度系统刷新进出场数据
+			sexec.scheduleWithFixedDelay(schInOutDataRefreshThread, 40, 20, TimeUnit.SECONDS);
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
+package com.bsth.server_rs.schedule.real;
+
+import com.bsth.entity.ScheduleRealInfo;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 实际排班缓存
+ * Created by panzhao on 2017/9/27.
+ */
+@Component
+public class SchRealInfoBuffer  {
+
+    /**
+     * 进出场班次数据，定时从调度系统获取。 对各场站输出
+     */
+    public static List<ScheduleRealInfo> inOutList;
+
+}
@@ -46,6 +46,23 @@ public class ScheduleRealService {
         return all;
     }
  
+    /**
+     * 获取当天指定停车场的进出场排班数据（潘钊场站VIP特供版 -高实时）
+     *
+     * @return
+     */
+    @GET
+    @Path("/in_out/{code}")
+    public List<ScheduleInOut> findInOut_real(@PathParam("code") String code) {
+        Set<String> lineArray = BasicData.lineDateMap.keySet();
+
+        List<ScheduleInOut> all = new ArrayList<>();
+        for (String lineCode : lineArray) {
+            all.addAll(ScheduleInOut.getMultiInstance(redisService.read(BasicData.lineDateMap.get(lineCode), lineCode), code));
+        }
+        return all;
+    }
+
     @GET
     @Path("/sch_jk/{company}/{rq}")
     public List<ScheduleRealInfoDTO_JK> find_JK(@PathParam("company") String company, @PathParam("rq") String rq) {
+package com.bsth.server_rs.schedule.real.thread;
+
+import com.alibaba.fastjson.JSON;
+import com.bsth.entity.ScheduleRealInfo;
+import com.bsth.server_rs.schedule.real.SchRealInfoBuffer;
+import com.bsth.util.ConfigUtil;
+import com.bsth.util.HttpClientUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 从调度系统获取进出场数据线程
+ * Created by panzhao on 2017/9/27.
+ */
+@Component
+public class SchInOutDataRefreshThread extends Thread {
+
+    static String url;
+    static String secretKey;
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    static {
+        secretKey = ConfigUtil.get("http.control.secret.key");
+        url = ConfigUtil.get("http.control.service_data_url") + "/findCurrInAndOut?secretKey=" + secretKey;
+    }
+
+    @Override
+    public void run() {
+        try {
+            StringBuilder sb = HttpClientUtils.get(url);
+            List<ScheduleRealInfo> list = JSON.parseArray(sb.toString(), ScheduleRealInfo.class);
+
+            if(null != list && list.size() > 0){
+                SchRealInfoBuffer.inOutList = list;
+                logger.info("从调度系统刷新进出场班次： " + list.size());
+            }
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+    }
+}
+package com.bsth.util;
+
+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.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.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+
+/**
+ * Created by panzhao on 2017/8/2.
+ */
+public class HttpClientUtils {
+
+    static Logger logger = LoggerFactory.getLogger(HttpClientUtils.class);
+
+    public static StringBuilder get(String url) throws Exception {
+        CloseableHttpClient httpClient = null;
+        CloseableHttpResponse response = null;
+        StringBuilder stringBuffer = null;
+        try {
+            httpClient = HttpClients.createDefault();
+            HttpGet get = new HttpGet(url);
+            //超时时间
+            RequestConfig requestConfig = RequestConfig.custom()
+                    .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
+                    .setSocketTimeout(2500).build();
+            get.setConfig(requestConfig);
+            get.addHeader("Content-Encoding", "gzip");
+
+            response = httpClient.execute(get);
+            stringBuffer = getResult(response.getEntity());
+        } catch (Exception e) {
+            logger.error("", e);
+        } finally {
+            if (null != httpClient)
+                httpClient.close();
+            if (null != response)
+                response.close();
+        }
+        return stringBuffer;
+    }
+
+    /**
+     * raw post data
+     * @param url
+     * @param data
+     * @return
+     */
+    public static StringBuilder post(String url, String data) throws Exception {
+        CloseableHttpClient httpClient = null;
+        CloseableHttpResponse response = null;
+        StringBuilder stringBuffer = null;
+        try {
+            httpClient = HttpClients.createDefault();
+            HttpPost post = new HttpPost(url);
+
+            post.setHeader("Accept", "application/json");
+            post.setHeader("Content-Type", "application/json");
+            //超时时间
+            RequestConfig requestConfig = RequestConfig.custom()
+                    .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
+                    .setSocketTimeout(2500).build();
+            post.setConfig(requestConfig);
+            post.setEntity((new StringEntity(data, "UTF-8")));
+
+            response = httpClient.execute(post);
+            stringBuffer = getResult(response.getEntity());
+        } catch (Exception e) {
+            logger.error("", e);
+        } finally {
+            if (null != httpClient)
+                httpClient.close();
+            if (null != response)
+                response.close();
+        }
+        return stringBuffer;
+    }
+
+    private static StringBuilder getResult(HttpEntity entity) throws IOException {
+        StringBuilder stringBuffer = null;
+        if (null != entity) {
+            BufferedReader br = new BufferedReader(new InputStreamReader(entity.getContent()));
+            stringBuffer = new StringBuilder();
+            String str = "";
+            while ((str = br.readLine()) != null)
+                stringBuffer.append(str);
+        }
+        return stringBuffer;
+    }
+}