停车场信息 First Commit

chenboxin
1 parent 54300941
Showing 5 changed files with 196 additions and 0 deletions
src/main/java/com/bsth/CXFConfig.java
src/main/java/com/bsth/server_rs/base_info/carpark/CarPark.java
src/main/java/com/bsth/server_rs/base_info/carpark/CarParkRestService.java
src/main/java/com/bsth/server_rs/base_info/carpark/buffer/CarParkBufferData.java
src/main/java/com/bsth/server_rs/base_info/carpark/buffer/CarparkRefreshThread.java
@@ -2,6 +2,7 @@ package com.bsth;
  
 import com.bsth.server_rs.AuthorizeInterceptor_IN;
 import com.bsth.server_rs.base_info.car.CarRestService;
+import com.bsth.server_rs.base_info.carpark.CarParkRestService;
 import com.bsth.server_rs.base_info.line.LineRestService;
 import com.bsth.server_rs.base_info.person.PersonRestService;
 import com.bsth.server_rs.base_info.section.LD_RoadSpeedRestService;
@@ -117,6 +118,7 @@ public class CXFConfig {
                 new LineRestService(),
                 new CarRestService(),
                 new PersonRestService(),
+                new CarParkRestService(),
                 gpsRestService,
                 scheduleRealService,
                 stationRestService,
+package com.bsth.server_rs.base_info.carpark;
+
+/**
+ * 停车场信息
+ * Created by panzhao on 2017/8/31.
+ */
+public class CarPark {
+	/**
+	 * 公司代码
+	 */
+	private String company;
+
+	/**
+	 * 停车场名称
+	 */
+	private String parkName;
+	
+	/**
+	 * GPS空间坐标点
+	 */			   
+	private String gparkVector;
+	
+	/**
+	 * 停车场地址
+	 */
+	private String parkAddress;
+
+	
+	public String getCompany() {
+		return company;
+	}
+
+	public void setCompany(String company) {
+		this.company = company;
+	}
+
+	public String getParkName() {
+		return parkName;
+	}
+
+	public void setParkName(String parkName) {
+		this.parkName = parkName;
+	}
+
+	public String getGparkVector() {
+		return gparkVector;
+	}
+
+	public void setGparkVector(String gparkVector) {
+		this.gparkVector = gparkVector;
+	}
+
+	public String getParkAddress() {
+		return parkAddress;
+	}
+
+	public void setParkAddress(String parkAddress) {
+		this.parkAddress = parkAddress;
+	}
+
+	
+	public CarPark() {
+		super();
+	}
+
+	public CarPark(String company, String parkName, String gparkVector, String parkAddress) {
+		super();
+		this.company = company;
+		this.parkName = parkName;
+		this.gparkVector = gparkVector;
+		this.parkAddress = parkAddress;
+	}
+}
+package com.bsth.server_rs.base_info.carpark;
+
+import com.bsth.server_rs.base_info.carpark.buffer.CarParkBufferData;
+import org.springframework.stereotype.Component;
+
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import java.util.List;
+
+@Component
+@Path("/carpark")
+@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
+public class CarParkRestService {
+	@GET
+	@Path("/all")
+	public List<CarPark> findAll() {
+		return CarParkBufferData.findAll();
+	}
+
+	@GET
+	@Path("/{company}")
+	public List<CarPark> findByCompany(@PathParam("company") String company) {
+		List<CarPark> list = CarParkBufferData.findByCompany(company);
+			System.out.println(list.get(0).getCompany());
+			System.out.println(list.get(0).getParkName());
+		return CarParkBufferData.findByCompany(company);
+	}
+}
+package com.bsth.server_rs.base_info.carpark.buffer;
+
+import com.bsth.Application;
+import com.bsth.server_rs.base_info.carpark.CarPark;
+import com.google.common.collect.ArrayListMultimap;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 停车场数据缓存（自更新）
+ * Created by panzhao on 2017/3/27.
+ */
+@Component
+@Order(6)
+public class CarParkBufferData implements CommandLineRunner {
+
+    @Autowired
+    CarparkRefreshThread carparkRefreshThread;
+
+    private static List<CarPark> data;
+ 
+    private static ArrayListMultimap<String, CarPark> companyListMap;
+    
+
+    public static List<CarPark> findAll(){
+        return data;
+    }
+    
+    public static List<CarPark> findByCompany(String company){
+        return companyListMap.get(company);
+    }
+    
+    public static void replaceAll(List<CarPark> newData){
+        data = newData;
+      ArrayListMultimap<String, CarPark> listMap = ArrayListMultimap.create();
+
+      for(CarPark carpark : data){
+          listMap.put(carpark.getCompany(), carpark);
+      }
+      companyListMap = listMap;
+  }
+
+    @Override
+    public void run(String... strings) throws Exception {
+        Application.mainServices.scheduleWithFixedDelay(carparkRefreshThread, 10, 60 * 60, TimeUnit.SECONDS);
+    }
+      
+}
+package com.bsth.server_rs.base_info.carpark.buffer;
+
+import com.bsth.server_rs.base_info.carpark.CarPark;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * Created by panzhao on 2017/3/27.
+ */
+@Component
+public class CarparkRefreshThread extends Thread{
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Override
+    public void run() {
+        try {
+            //停车场信息
+            List<CarPark> carParkList = jdbcTemplate.query("select company,park_name AS parkName,ST_AsText(g_park_point) AS gparkVector,park_point from bsth_c_car_park where destroy=0",
+                    BeanPropertyRowMapper.newInstance(CarPark.class));
+
+            if(carParkList == null || carParkList.size() == 0)
+                return;
+            CarParkBufferData.replaceAll(carParkList);
+        }catch (Exception e){
+            logger.error("", e);
+        }
+    }
+}