1.

王通
1 parent 875de6d0
Showing 15 changed files with 389 additions and 255 deletions
src/main/java/com/bsth/server_rs/base_info/car/CarRestService.java
src/main/java/com/bsth/server_rs/base_info/line/LineRestService.java
src/main/java/com/bsth/server_rs/base_info/person/PersonRestService.java
src/main/java/com/bsth/server_rs/base_info/station/StationRestService.java
src/main/java/com/bsth/server_rs/base_info/station/entity/StationRotue.java
src/main/java/com/bsth/server_rs/directive/DirectiveRestService.java
src/main/java/com/bsth/server_rs/gps/GpsRestService.java
src/main/java/com/bsth/server_rs/gps/buffer/BasicDataBuffer.java
src/main/java/com/bsth/server_rs/gps/buffer/BasicDataRefreshThread.java
src/main/java/com/bsth/server_rs/gps/buffer/GpsRefreshThread.java
src/main/java/com/bsth/server_rs/schedule/SchedulePlanService.java
src/main/java/com/bsth/server_rs/schedule/ScheduleRealService.java
src/main/java/com/bsth/server_rs/schedule/ScheduleTimeService.java
src/main/resources/application-prod.properties
src/main/resources/static/index.html
@@ -11,9 +11,14 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.commons.lang3.StringEscapeUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
 import javax.ws.rs.*;
 import javax.ws.rs.core.MediaType;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -29,6 +34,9 @@ public class CarRestService {
     private ObjectMapper mapper = new ObjectMapper();
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @GET
     @Path("/all")
     public List<Car> findAll(){
@@ -57,9 +65,24 @@ public class CarRestService {
     @POST
     @Path("")
-    public Map<String, Object> save(List<Car> cars) throws JsonProcessingException {
+    public Map<String, Object> save(final List<Car> cars) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(cars));
+        log.error(mapper.writeValueAsString(cars));
+        jdbcTemplate.batchUpdate("insert into zyl.bsth_c_cars (car_plate,company_code,branche_company_code,energy_type) values(?,?,?,?)", new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                Car car = cars.get(i);
+                ps.setString(1, car.getCarPlate());
+                ps.setString(2, car.getCompanyCode());
+                ps.setString(3, car.getBrancheCompanyCode());
+                ps.setInt(4, car.getEnergyType());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return cars.size();
+            }
+        });
         return result;
     }
 package com.bsth.server_rs.base_info.line;
+import com.bsth.entity.ScheduleExec;
 import com.bsth.server_rs.base_info.line.buffer.LineBufferData;
 import com.bsth.server_rs.schedule.ScheduleRealService;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
 import javax.ws.rs.*;
 import javax.ws.rs.core.MediaType;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
 import java.util.*;
 /**
@@ -23,6 +29,9 @@ public class LineRestService {
     private ObjectMapper mapper = new ObjectMapper();
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @GET
     @Path("/all")
     public List<Line> findAll(){
@@ -58,9 +67,34 @@ public class LineRestService {
     @POST
     @Path("")
-    public Map<String, Object> save(List<Line> lines) throws JsonProcessingException {
+    public Map<String, Object> save(final List<Line> lines) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(lines));
+        log.error(mapper.writeValueAsString(lines));
+        jdbcTemplate.batchUpdate("insert into zyl.bsth_c_line (name,start_station_name,end_station_name,start_station_first_time,start_station_end_time,end_station_first_time,end_station_end_time,company,branche_company,line_play_type,up_mileage,down_mileage,up_travel_time,down_travel_time) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                Line line = lines.get(i);
+                ps.setString(1, line.getName());
+                ps.setString(2, line.getStartStationName());
+                ps.setString(3, line.getEndStationName());
+                ps.setString(4, line.getStartStationFirstTime());
+                ps.setString(5, line.getStartStationEndTime());
+                ps.setString(6, line.getEndStationFirstTime());
+                ps.setString(7, line.getEndStationEndTime());
+                ps.setString(8, line.getCompany());
+                ps.setString(9, line.getBrancheCompany());
+                ps.setInt(10, line.getLinePlayType());
+                ps.setDouble(11, line.getUpMileage());
+                ps.setDouble(12, line.getDownMileage());
+                ps.setDouble(13, line.getUpTravelTime());
+                ps.setDouble(14, line.getDownTravelTime());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return lines.size();
+            }
+        });
         return result;
     }
@@ -11,9 +11,14 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.commons.lang3.StringEscapeUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
 import javax.ws.rs.*;
 import javax.ws.rs.core.MediaType;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -29,6 +34,9 @@ public class PersonRestService {
     private ObjectMapper mapper = new ObjectMapper();
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @GET
     @Path("/all")
     public List<Personnel> findAll(){
@@ -57,9 +65,26 @@ public class PersonRestService {
     @POST
     @Path("")
-    public Map<String, Object> save(List<Personnel> personnels) throws JsonProcessingException {
+    public Map<String, Object> save(final List<Personnel> personnels) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(personnels));
+        log.error(mapper.writeValueAsString(personnels));
+        jdbcTemplate.batchUpdate("insert into zyl.bsth_c_personnel (job_code,company_code,branche_company_code,personnel_name,personnel_type,posts) values(?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                Personnel personnel = personnels.get(i);
+                ps.setString(1, personnel.getJobCode());
+                ps.setString(2, personnel.getCompanyCode());
+                ps.setString(3, personnel.getBrancheCompanyCode());
+                ps.setString(4, personnel.getPersonnelName());
+                ps.setString(5, personnel.getPersonnelType());
+                ps.setString(6, personnel.getPosts());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return personnels.size();
+            }
+        });
         return result;
     }
@@ -8,10 +8,15 @@ import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 import javax.ws.rs.*;
 import javax.ws.rs.core.MediaType;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.List;
@@ -29,6 +34,9 @@ public class StationRestService {
     private ObjectMapper mapper = new ObjectMapper();
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @GET
     @Path("/all")
     public Map<String, Collection<StationRotue>> findAll(){
@@ -49,9 +57,33 @@ public class StationRestService {
     @POST
     @Path("")
-    public Map<String, Object> save(List<StationRotue> stationRotues) throws JsonProcessingException {
+    public Map<String, Object> save(final List<StationRotue> stationRotues) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(stationRotues));
+        log.error(mapper.writeValueAsString(stationRotues));
+        jdbcTemplate.batchUpdate("insert into zyl.bsth_c_stationroute (line_code,station_name,station_route_code,station_mark,distances,to_time,first_time,end_time,directions,lon,lat) values(?,?,?,?,?,?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                StationRotue stationRotue = stationRotues.get(i);
+                ps.setString(1, stationRotue.getLineName());
+                ps.setString(2, stationRotue.getStationName());
+                ps.setInt(3, stationRotue.getStationRouteCode());
+                ps.setString(4, stationRotue.getStationMark());
+                ps.setDouble(5, stationRotue.getDistances());
+                ps.setDouble(6, stationRotue.getToTime());
+                ps.setString(7, stationRotue.getFirstTime());
+                ps.setString(8, stationRotue.getEndTime());
+                ps.setInt(9, stationRotue.getDirections());
+                ps.setFloat(10, stationRotue.getLon());
+                ps.setFloat(11, stationRotue.getLat());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return stationRotues.size();
+            }
+        });
+        result.put("code", 0);
+        result.put("msg", "ok");
         return result;
     }
@@ -5,6 +5,8 @@ package com.bsth.server_rs.base_info.station.entity;
  */
 public class StationRotue {
+    private String lineName;
+
     /** 线路编码 */
     private String lineCode;
@@ -48,6 +50,14 @@ public class StationRotue {
     private Float lat;
+    public String getLineName() {
+        return lineName;
+    }
+
+    public void setLineName(String lineName) {
+        this.lineName = lineName;
+    }
+
     public String getLineCode() {
         return lineCode;
     }
@@ -4,9 +4,11 @@ import com.alibaba.fastjson.JSON;
 import com.bsth.entity.D60;
 import com.bsth.entity.ZylInfo;
 import com.bsth.repository.DirectiveRepository;
+import com.bsth.server_rs.gps.buffer.BasicDataBuffer;
 import com.bsth.util.ConfigUtil;
 import com.bsth.util.HttpClientUtils;
 import com.bsth.Application;
+import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -18,6 +20,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import javax.ws.rs.*;
 import javax.ws.rs.core.MediaType;
 import java.io.*;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
@@ -41,7 +44,7 @@ public class DirectiveRestService implements InitializingBean {
     private ObjectMapper mapper = new ObjectMapper();
-    Logger logger = LoggerFactory.getLogger(this.getClass());
+    Logger log = LoggerFactory.getLogger(this.getClass());
     static {
         secretKey = ConfigUtil.get("http.control.secret.key");
@@ -49,20 +52,41 @@ public class DirectiveRestService implements InitializingBean {
     }
     @POST
-    @Path("/send")
-    public int send(@RequestBody Map<String, Object> map){
+    @Path("/")
+    public Map<String, Object> send(@RequestBody Map<String, Object> map){
+        try {
+            log.error(mapper.writeValueAsString(map));
+        } catch (JsonProcessingException e) {
+            e.printStackTrace();
+        }
+        Map<String, Object> result = new HashMap<>();
+        result.put("code", 0);
+        result.put("msg", "");
         try{
             String plate = String.valueOf(map.get("plate"));
             int trainNum = (int) map.get("trainNum"), lineId = (int) map.get("lineId");
+            if (plate == null || trainNum == 0 || lineId == 0) {
+                result.put("code", 500);
+                result.put("msg", "参数不完整");
+
+                return result;
+            }
+            if (plate.contains("-")) {
+                plate = BasicDataBuffer.getIncodeByIncode(plate);
+            }
+            plate = BasicDataBuffer.getPlateByIncode(plate);
+            map.put("plate", plate);
             ZylInfo zylInfo = new ZylInfo(lineId, trainNum);
             plate2zyl.put(plate, zylInfo);
             map.put("sender", "中运量接口@系统");
             StringBuilder sb = HttpClientUtils.post(url, JSON.toJSONString(map));
-            return Integer.parseInt(sb.toString());
         }catch (Exception e){
-            logger.error("", e);
-            return -500;
+            log.error("", e);
+            result.put("code", 500);
+            result.put("msg", "服务端异常");
         }
+
+        return result;
     }
     @GET
@@ -72,7 +96,7 @@ public class DirectiveRestService implements InitializingBean {
             StringBuilder sb = HttpClientUtils.get(url + "&msgIds=" + msgIds);
             return JSON.parseArray(sb.toString(), Map.class);
         }catch (Exception e){
-            logger.error("", e);
+            log.error("", e);
             return null;
         }
     }
@@ -83,7 +107,7 @@ public class DirectiveRestService implements InitializingBean {
         try{
             return directiveRepository.findByRqAndDevice(rq, device);
         }catch (Exception e){
-            logger.error("", e);
+            log.error("", e);
             return null;
         }
     }
@@ -122,7 +146,7 @@ public class DirectiveRestService implements InitializingBean {
                 try {
                     saveZylInfo(file);
                 } catch (IOException e) {
-                    logger.error("保存临时文件异常", e);
+                    log.error("保存临时文件异常", e);
                 }
             }
         }, 60, 60, TimeUnit.SECONDS);
@@ -38,6 +38,9 @@ public class GpsRestService {
 	@Value("${zyl.lines}")
 	private String zylLines;
+	@Value("${zyl.devices}")
+	private String zylDevices;
+
     @Autowired
     HistoryGpsDao historyGpsDao;
@@ -59,7 +62,7 @@ public class GpsRestService {
     	Collection<GpsEntity> result = new ArrayList<>();
 		Collection<GpsEntity> gpsEntities = GpsRealDataBuffer.all();
 		for (GpsEntity gpsEntity : gpsEntities) {
-			if (zylLines.indexOf(String.format("%s,", gpsEntity.getLineId())) > -1) {
+			if (zylLines.indexOf(String.format("%s,", gpsEntity.getLineId())) > -1 || zylDevices.indexOf(gpsEntity.getDeviceId()) > -1) {
 				result.add(gpsEntity);
 			}
 		}
-package com.bsth.server_rs.gps.buffer;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Set;
-
-import org.springframework.stereotype.Component;
-
-import com.bsth.server_rs.gps.entity.LineInfo;
-
-/**
- * Created by panzhao on 2017/3/30.
- */
-@Component
-public class BasicDataBuffer {
-
-	private static Map<Integer, LineInfo> LINEID_INFO = new HashMap<Integer, LineInfo>();
-	
-	private static Map<String, String> DEVICE_PLATE = new HashMap<String, String>();
-	
-	public static void putLine(Integer lineId, LineInfo info) {
-		LINEID_INFO.put(lineId, info);
-	}
-	
-	public static void putCar(String deviceId, String plateNo) {
-		DEVICE_PLATE.put(deviceId, plateNo);
-	}
-	
-	public static String getPlateByDevice(String deviceId) {
-		return DEVICE_PLATE.get(deviceId);
-	}
-	
-	public static Set<Integer> getAllLine() {
-		return LINEID_INFO.keySet();
-	}
-	
-	public static LineInfo getLineById(Integer lineId) {
-		return LINEID_INFO.get(lineId);
-	}
-}
+package com.bsth.server_rs.gps.buffer;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+import org.springframework.stereotype.Component;
+
+import com.bsth.server_rs.gps.entity.LineInfo;
+
+/**
+ * Created by panzhao on 2017/3/30.
+ */
+@Component
+public class BasicDataBuffer {
+
+	private static Map<Integer, LineInfo> LINEID_INFO = new HashMap<Integer, LineInfo>();
+	
+	private static Map<String, String> DEVICE_PLATE = new HashMap<String, String>();
+
+	private static Map<String, String> DEVICE_INCODE = new HashMap<String, String>();
+
+	private static Map<String, String> INCODE_PLATE = new HashMap<String, String>();
+
+	private static Map<String, String> INCODE_INCODE = new HashMap<>();
+	
+	public static void putLine(Integer lineId, LineInfo info) {
+		LINEID_INFO.put(lineId, info);
+	}
+	
+	public static void putCar(String deviceId, String plateNo, String insideCode) {
+		DEVICE_PLATE.put(deviceId, plateNo);
+		DEVICE_INCODE.put(deviceId, insideCode);
+		INCODE_PLATE.put(insideCode, plateNo);
+		if (insideCode != null) {
+			INCODE_INCODE.put(insideCode.replaceAll("-", ""), insideCode);
+		}
+	}
+	
+	public static String getPlateByDevice(String deviceId) {
+		return DEVICE_PLATE.get(deviceId);
+	}
+
+	public static String getIncodeByDevice(String deviceId) {
+		return DEVICE_INCODE.get(deviceId);
+	}
+
+	public static String getIncodeByIncode(String insideCode) {
+		return INCODE_INCODE.get(insideCode);
+	}
+
+	public static String getPlateByIncode(String insideCode) {
+		return INCODE_PLATE.get(insideCode);
+	}
+	
+	public static Set<Integer> getAllLine() {
+		return LINEID_INFO.keySet();
+	}
+	
+	public static LineInfo getLineById(Integer lineId) {
+		return LINEID_INFO.get(lineId);
+	}
+}
@@ -38,7 +38,7 @@ public class BasicDataRefreshThread extends Thread implements InitializingBean {
     	try {
         	String qline = "select a.id,in_use,line_code,name,start_station_name,start_station_first_time,start_station_end_time,end_station_name,end_station_first_time,end_station_end_time,company,branche_company,length,telephone,speed_limit,shanghai_linecode,line_play_type,up_travel_time,down_travel_time from bsth_c_line a left join bsth_c_line_information b on a.id = b.line where a.destroy = 0 and a.nature = 'hlwgj'";
         	String qstop = "select b.id,b.station_cod,b.station_name,b.road_coding,b.g_lonx,b.g_laty,b.shapes_type,b.radius,AsText(b.g_polygon_grid) as g_polygon_grid,a.line,a.line_code,a.directions,a.distances from bsth_c_stationroute a join bsth_c_station b on a.station = b.id where a.destroy = 0 order by a.line,a.directions,a.station_route_code";
-        	String qcar = "select equipment_code device_id, car_plate plate_no from bsth_c_cars";
+        	String qcar = "select equipment_code device_id, car_plate plate_no, inside_code from bsth_c_cars";
         	List<LineInfo> lines = jdbcTemplate.query(qline, new RowMapperLineInfo());
         	List<StopInfo> stops = jdbcTemplate.query(qstop, new RowMapperStopInfo());
@@ -64,10 +64,7 @@ public class BasicDataRefreshThread extends Thread implements InitializingBean {
     		}
     		for (Map<String, Object> car : cars) {
-    			String plateNo = (String)car.get("plate_no");
-    			if (plateNo != null) {
-					BasicDataBuffer.putCar((String)car.get("device_id"), plateNo.replace("沪","").replace("-", ""));
-				}
+    			BasicDataBuffer.putCar((String)car.get("device_id"), (String)car.get("plate_no"), (String)car.get("inside_code"));
     		}
     		logger.info("基础数据加载成功");
@@ -66,8 +66,12 @@ public class GpsRefreshThread extends Thread{
             if (jsonObj != null)
                 rs = JSON.parseArray(jsonObj.getString("data"), GpsEntity.class);
-            for(GpsEntity gps : rs){
-                gps.setPlate(BasicDataBuffer.getPlateByDevice(gps.getDeviceId()));
+            for (GpsEntity gps : rs) {
+                String incode = BasicDataBuffer.getIncodeByDevice(gps.getDeviceId());
+                if (incode != null) {
+                    gps.setPlate(incode);
+                    //gps.setPlate(incode.replace("-", ""));
+                }
                 if (gps.getPlate() == null) {
                     continue;
                 }
 package com.bsth.server_rs.schedule;
 import com.bsth.entity.ScheduleRealInfo;
+import com.bsth.server_rs.gps.buffer.BasicDataBuffer;
 import com.bsth.server_rs.gps.buffer.GpsRealDataBuffer;
 import com.bsth.server_rs.gps.entity.GpsEntity;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 import javax.ws.rs.*;
 import javax.ws.rs.core.MediaType;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -24,10 +31,41 @@ public class SchedulePlanService {
     private ObjectMapper mapper = new ObjectMapper();
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @POST
-    public Map<String, Object> save(List<ScheduleRealInfo> reals) throws JsonProcessingException {
+    public Map<String, Object> save(ScheduleRealInfo real) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(reals));
+        final List<ScheduleRealInfo> reals = new ArrayList<>();
+        reals.add(real);
+        log.error(mapper.writeValueAsString(reals));
+        jdbcTemplate.batchUpdate("insert into zyl.bsth_c_s_sp_real_info (schedule_date_str,xl_name,lp_name,cl_zbh,jsy,spy," +
+                "direction,qdz_name,zdz_name,fcsj,fcno,jhlc,bcsj,bc_type) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                ScheduleRealInfo sri = reals.get(i);
+                ps.setString(1, sri.getScheduleDateStr());
+                ps.setString(2, sri.getXlName());
+                ps.setString(3, sri.getLpName());
+                ps.setString(4, BasicDataBuffer.getIncodeByIncode(sri.getClZbh()));
+                ps.setString(5, sri.getJsy());
+                ps.setString(6, sri.getSpy());
+                ps.setString(7, sri.getXlDir());
+                ps.setString(8, sri.getQdzName());
+                ps.setString(9, sri.getZdzName());
+                ps.setString(10, sri.getFcsj());
+                ps.setInt(11, sri.getFcno());
+                ps.setDouble(12, sri.getJhlc());
+                ps.setInt(13, sri.getBcsj());
+                ps.setString(14, sri.getBcType());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return reals.size();
+            }
+        });
         result.put("code", 0);
         result.put("msg", "ok");
@@ -2,16 +2,24 @@ package com.bsth.server_rs.schedule;
 import com.bsth.entity.ScheduleExec;
 import com.bsth.entity.ScheduleRealInfo;
+import com.bsth.server_rs.gps.buffer.BasicDataBuffer;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import org.joda.time.DateTime;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 import javax.ws.rs.POST;
 import javax.ws.rs.Path;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -25,11 +33,32 @@ public class ScheduleRealService {
     private ObjectMapper mapper = new ObjectMapper();
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @POST
     @Path("/leave")
-    public Map<String, Object> leave(List<ScheduleExec> execs) throws JsonProcessingException {
+    public Map<String, Object> leave(ScheduleExec exec) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(execs));
+        final List<ScheduleExec> execs = new ArrayList<>();
+        execs.add(exec);
+        log.error(mapper.writeValueAsString(execs));
+        jdbcTemplate.batchUpdate("update zyl.bsth_c_s_sp_real_info set fcsj_actual = ? where xl_name = ? and cl_zbh = ? and lp_name = ? and fcsj = ?", new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                ScheduleExec scheduleExec = execs.get(i);
+                ps.setString(1, new DateTime(scheduleExec.getTime()).toString("HH:mm"));
+                ps.setString(2, scheduleExec.getLineName());
+                ps.setString(3, BasicDataBuffer.getIncodeByIncode(scheduleExec.getPlate()));
+                ps.setString(4, scheduleExec.getLpName());
+                ps.setString(5, scheduleExec.getFcsj());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return execs.size();
+            }
+        });
         result.put("code", 0);
         result.put("msg", "ok");
@@ -38,9 +67,27 @@ public class ScheduleRealService {
     @POST
     @Path("/arrival")
-    public Map<String, Object> arrival(List<ScheduleExec> execs) throws JsonProcessingException {
+    public Map<String, Object> arrival(ScheduleExec exec) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(execs));
+        final List<ScheduleExec> execs = new ArrayList<>();
+        execs.add(exec);
+        log.error(mapper.writeValueAsString(execs));
+        jdbcTemplate.batchUpdate("update zyl.bsth_c_s_sp_real_info set zdsj_actual = ? where xl_name = ? and cl_zbh = ? and lp_name = ? and fcsj = ?", new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                ScheduleExec scheduleExec = execs.get(i);
+                ps.setString(1, new DateTime(scheduleExec.getTime()).toString("HH:mm"));
+                ps.setString(2, scheduleExec.getLineName());
+                ps.setString(3, BasicDataBuffer.getIncodeByIncode(scheduleExec.getPlate()));
+                ps.setString(4, scheduleExec.getLpName());
+                ps.setString(5, scheduleExec.getFcsj());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return execs.size();
+            }
+        });
         result.put("code", 0);
         result.put("msg", "ok");
@@ -49,9 +96,26 @@ public class ScheduleRealService {
     @POST
     @Path("/destroy")
-    public Map<String, Object> destroy(List<ScheduleExec> execs) throws JsonProcessingException {
+    public Map<String, Object> destroy(ScheduleExec exec) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(execs));
+        final List<ScheduleExec> execs = new ArrayList<>();
+        execs.add(exec);
+        log.error(mapper.writeValueAsString(execs));
+        jdbcTemplate.batchUpdate("update zyl.bsth_c_s_sp_real_info set status = -1 where xl_name = ? and cl_zbh = ? and lp_name = ? and fcsj = ?", new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                ScheduleExec scheduleExec = execs.get(i);
+                ps.setString(1, scheduleExec.getLineName());
+                ps.setString(2, BasicDataBuffer.getIncodeByIncode(scheduleExec.getPlate()));
+                ps.setString(3, scheduleExec.getLpName());
+                ps.setString(4, scheduleExec.getFcsj());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return execs.size();
+            }
+        });
         result.put("code", 0);
         result.put("msg", "ok");
 package com.bsth.server_rs.schedule;
+import com.bsth.entity.ScheduleRealInfo;
 import com.bsth.entity.TimeTable;
+import com.bsth.entity.TimeTableDetail;
+import com.bsth.server_rs.gps.buffer.BasicDataBuffer;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 import javax.ws.rs.POST;
 import javax.ws.rs.Path;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -27,11 +35,38 @@ public class ScheduleTimeService {
     private ObjectMapper mapper = new ObjectMapper();
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @POST
     @Path("")
     public Map<String, Object> save(List<TimeTable> timeTables) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
-        log.info(mapper.writeValueAsString(timeTables));
+        log.error(mapper.writeValueAsString(timeTables));
+        for (TimeTable timeTable : timeTables) {
+            jdbcTemplate.update("insert into zyl.bsth_c_s_ttinfo (xl,total_mileage,service_mileage,week_days) values(?,?,?,?)", new Object[]{ timeTable.getLineCode(), timeTable.getTotalMileage(), timeTable.getServiceMileage(), timeTable.getWeekDays() });
+            final List<TimeTableDetail> timeTableDetails = timeTable.getDetails();
+            jdbcTemplate.batchUpdate("insert into zyl.bsth_c_s_ttinfo_detail (bc_type,bcs,bcsj,lp_name,direction,start_station,end_station,leave_time,arrival_time) values (?,?,?,?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    TimeTableDetail timeTableDetail = timeTableDetails.get(i);
+                    ps.setString(1, timeTableDetail.getBcType());
+                    ps.setInt(2, timeTableDetail.getBcs());
+                    ps.setInt(3, timeTableDetail.getBcsj());
+                    ps.setString(4, timeTableDetail.getLpName());
+                    ps.setInt(5, timeTableDetail.getDirection());
+                    ps.setString(6, timeTableDetail.getStartStation());
+                    ps.setString(7, timeTableDetail.getEndStation());
+                    ps.setString(8, timeTableDetail.getLeaveTime());
+                    ps.setString(9, timeTableDetail.getArrivalTime());
+                }
+
+                @Override
+                public int getBatchSize() {
+                    return timeTableDetails.size();
+                }
+            });
+        }
         result.put("code", 0);
         result.put("msg", "ok");
@@ -8,7 +8,7 @@ spring.jpa.hibernate.naming_strategy= org.hibernate.cfg.ImprovedNamingStrategy
 spring.jpa.database= MYSQL
 spring.jpa.show-sql= false
 spring.datasource.driver-class-name= com.mysql.jdbc.Driver
-spring.datasource.url= jdbc:mysql://10.10.150.103/control?useUnicode=true&characterEncoding=utf-8&useSSL=false
+spring.datasource.url= jdbc:mysql://10.10.150.103/control?rewriteBatchedStatements=true&useUnicode=true&characterEncoding=utf-8&useSSL=false
 spring.datasource.username= root
 spring.datasource.password= Aa123456
 #DATASOURCE
@@ -28,4 +28,5 @@ http.control.secret.key= dVPHJkWUt5FhMT7jrM2dLV7QvlHAmZFd42rs1P0usBx8A7HZki
 http.gps.real.url= http://10.10.150.103:8080/transport_server/rtgps/
-zyl.lines= 230329,
 \ No newline at end of file
+zyl.lines=
+zyl.devices= 77S2C001,77S2C002,77S2C003,77S2C004,77S2C005,77S2C006,77S2C007,77S2C008,77S2C009,77S2C010,77S2C011,77S2C012,77S2C013,77S2C014,77S2C015,77S2C016,77S2C017,77S2C018,77S2C019,77S2C020,
 \ No newline at end of file
-<!DOCTYPE html>
-<html>
-<head>
-<title>调度系统营运数据接口</title>
-<meta charset="utf-8">
-<meta http-equiv="Expires" content="0">
-<meta http-equiv="Pragma" content="no-cache">
-<meta http-equiv="Cache-control" content="no-cache">
-<meta http-equiv="Cache" content="no-cache">
-<link rel="stylesheet"
-	href="http://apps.bdimg.com/libs/bootstrap/3.2.0/css/bootstrap.min.css">
-<link rel="stylesheet" href="/simple_switch/simple.switch.three.css">
-<style>
-.table-wrap {
-	height: 500px;
-	overflow: auto;
-}
-
-#line2SysListTable .Switch_FlatRadius .SwitchLine:before {
-	content: "老系统";
-}
-
-#line2SysListTable .Switch_FlatRadius .SwitchLine:after {
-	content: "新系统";
-}
-
-#line2SysListTable .Switch_FlatRadius {
-	width: 118px;
-}
-
-#line2SysListTable .Switch_FlatRadius .SwitchButton {
-	width: 52px;
-}
-
-#line2SysListTable .Switch_FlatRadius .SwitchButton:before {
-	left: 18px;
-}
-
-#line2SysListTable .Switch_FlatRadius .SwitchButton:after {
-	left: 30px;
-}
-
-#line2SysListTable .Switch_FlatRadius.On .SwitchButton {
-	left: 60px;
-}
-</style>
-</head>
-
-<body>
-
-	<div class="row" style="margin: 15px;">
-		<div class="col-md-12 well">
-			<h4>
-				Available SOAP services: <a href="/webservice" target="_blank">/webservice</a>
-			</h4>
-			<h4>
-				WSDL: <a href="/webservice/CompanyService?wsdl" target="_blank">/webservice/CompanyService?wsdl</a>
-			</h4>
-		</div>
-
-		<div class="col-lg-4 col-md-6 col-sm-12">
-			<div class="bs-example"
-				data-example-id="panel-without-body-with-table">
-				<div class="panel panel-default">
-					<!-- Default panel contents -->
-					<div class="panel-heading">线路清单</div>
-					<div class="panel-body">
-						<p style="color: #ff2727;">屏蔽新老系统的底层数据差异，对外提供统一的数据输出</p>
-						<p>1、使用员工号查询数据时，系统将参考 “线路人员配置” 以确定人员所在线路。</p>
-						<p>2、使用公司编码查询数据时，系统将参考 “线路基础信息” 里的公司编码。</p>
-					</div>
-					<div class="table-wrap">
-						<table class="table" id="line2SysListTable">
-							<thead>
-								<tr>
-									<th>线路编码</th>
-									<th>线路名称</th>
-									<th>数据来源</th>
-								</tr>
-							</thead>
-							<tbody>
-							</tbody>
-						</table>
-					</div>
-				</div>
-			</div>
-		</div>
-
-		<div class="col-lg-8 col-md-6 col-sm-12">
-			<div class="bs-example">
-				<div class="panel panel-default">
-					<div class="panel-heading">接口调试工具</div>
-					<div style="padding: 15px; margin-top: 15px;">
-						<form class="form-inline">
-							<div class="form-group">
-								<label>函数</label> <select class="form-control">
-									<option value="returnCCInfo">returnCCInfo（获取出场班次信息）</option>
-									<option value="returnJCInfo">returnJCInfo（获取进场班次信息）</option>
-								</select>
-							</div>
-							&nbsp;
-							<div class="form-group">
-								<label>公司编码</label> <select class="form-control">
-									<option value="55">55（上南）</option>
-									<option value="22">22（金高）</option>
-									<option value="05">05（杨高）</option>
-									<option value="26">26（南汇）</option>
-								</select>
-							</div>
-							&nbsp;
-							<div class="form-group">
-								<label>日期</label> <input type="date" class="form-control"
-									style="width: 150px;" required>
-							</div>
-							<button type="submit" class="btn btn-primary">获取数据</button>
-
-							<textarea class="form-control" rows="25"
-								style="width: 100%; margin-top: 25px;"></textarea>
-						</form>
-
-					</div>
-				</div>
-			</div>
-		</div>
-	</div>
-
-	<script id="line2sys-table-list-temp" type="text/html">
-    {{each list as obj i}}
-    <tr data-id="{{obj.lineCode}}" data-name="{{obj.lineName}}" {{if obj.new}}class="warning" {{/if}} >
-    <td>{{obj.lineCode}}</td>
-    <td>{{obj.lineName}}</td>
-    <td>
-        <input type="checkbox" {{if obj.new}}checked{{/if}} />
-    </td>
-    </tr>
-    {{/each}}
-</script>
-
-	<script src="http://apps.bdimg.com/libs/jquery/1.8.3/jquery.min.js"></script>
-	<script
-		src="http://apps.bdimg.com/libs/bootstrap/3.2.0/js/bootstrap.min.js"></script>
-	<script src="/assets/js/template.js"></script>
-	<script src="/simple_switch/simple.switch.min.js"></script>
-
-	<script>
-
-    //线路清单
-    !function () {
-        var f = arguments.callee;
-/*        $.get('/line2System/all', function (list) {
-            list.sort(function (a, b) {
-                return b.new - a.new;
-            });
-            var htmlStr = template('line2sys-table-list-temp', {list: list});
-            $('#line2SysListTable tbody').html(htmlStr);
-
-            $('input[type=checkbox]').simpleSwitch({
-                "theme": "FlatRadius"
-            });
-
-            $('input[type=checkbox]').on('change', function () {
-                var $tr = $(this).parents('tr');
-                var data = {
-                    lineCode: $tr.data('id'),
-                    lineName: $tr.data('name'),
-                    new: this.checked
-                }
-
-                $.post('/line2System/update', data, function (rs) {
-                    var $tr = $('#line2SysListTable tr[data-id=' + rs.lineCode + ']');
-                    $tr.attr('class', rs.new ? 'warning' : '');
-                });
-            });
-        });*/
-    }();
-
-</script>
-</body>
-</html>
 \ No newline at end of file