1.加入历史路单修改逻辑

王通
1 parent d45f6d0c
Showing 4 changed files with 197 additions and 48 deletions
src/main/java/com/bsth/entity/Business.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/schedule/WaybillService.java
+package com.bsth.entity;
+
+/**
+ * @author Hill
+ */
+public class Business {
+
+    private String businessCode;
+
+    private String businessName;
+
+    public String getBusinessCode() {
+        return businessCode;
+    }
+
+    public void setBusinessCode(String businessCode) {
+        this.businessCode = businessCode;
+    }
+
+    public String getBusinessName() {
+        return businessName;
+    }
+
+    public void setBusinessName(String businessName) {
+        this.businessName = businessName;
+    }
+}
@@ -4,6 +4,7 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.Set;
+import com.bsth.entity.Business;
 import org.springframework.stereotype.Component;
 import com.bsth.server_rs.gps.entity.LineInfo;
@@ -14,20 +15,27 @@ import com.bsth.server_rs.gps.entity.LineInfo;
 @Component
 public class BasicDataBuffer {
-	private static Map<Integer, LineInfo> LINEID_INFO = new HashMap<Integer, LineInfo>();
+	private static Map<Integer, LineInfo> LINEID_INFO = new HashMap<>();
+
+	private static Map<String, LineInfo> LINENAME_INFO = new HashMap<>();
-	private static Map<String, String> DEVICE_PLATE = new HashMap<String, String>();
+	private static Map<String, String> DEVICE_PLATE = new HashMap<>();
-	private static Map<String, String> DEVICE_INCODE = new HashMap<String, String>();
+	private static Map<String, String> DEVICE_INCODE = new HashMap<>();
-	private static Map<String, String> INCODE_PLATE = new HashMap<String, String>();
+	private static Map<String, String> INCODE_PLATE = new HashMap<>();
 	private static Map<String, String> INCODE_INCODE = new HashMap<>();
 	private static Map<String, String> INCODE_VIN = new HashMap<>();
+
+	private static Map<String, String> CODE_NAME = new HashMap<>();
+
+	private static Map<String, String> BCODE_BNAME = new HashMap<>();
 	public static void putLine(Integer lineId, LineInfo info) {
 		LINEID_INFO.put(lineId, info);
+		LINENAME_INFO.put(info.getLineName(), info);
 	}
 	public static void putCar(String deviceId, String plateNo, String insideCode, String vin) {
@@ -40,6 +48,14 @@ public class BasicDataBuffer {
 			INCODE_INCODE.put(insideCode.replaceAll("-", ""), insideCode);
 		}
 	}
+
+	public static void putCompany(Business business) {
+		CODE_NAME.put(business.getBusinessCode(), business.getBusinessName());
+	}
+
+	public static void putBrancheCompany(Business business) {
+		BCODE_BNAME.put(business.getBusinessCode(), business.getBusinessName());
+	}
 	public static String getPlateByDevice(String deviceId) {
 		return DEVICE_PLATE.get(deviceId);
@@ -68,4 +84,16 @@ public class BasicDataBuffer {
 	public static LineInfo getLineById(Integer lineId) {
 		return LINEID_INFO.get(lineId);
 	}
+
+	public static LineInfo getLineByName(String lineName) {
+		return LINENAME_INFO.get(lineName);
+	}
+
+	public static String getCompanyNameByCode(String code) {
+		return CODE_NAME.get(code);
+	}
+
+	public static String getBranchCompanyNameByCode(String code) {
+		return BCODE_BNAME.get(code);
+	}
 }
@@ -6,10 +6,12 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import com.bsth.entity.Business;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.core.RowMapper;
 import org.springframework.stereotype.Component;
@@ -36,13 +38,17 @@ public class BasicDataRefreshThread extends Thread implements InitializingBean {
     private void loadBasicData() {
     	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 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";
         	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, inside_code, vin from bsth_c_cars";
+        	String qcompany = "select business_code, business_name from bsth_c_business where up_code = 88";
+			String qbcompany = "select business_code, business_name from bsth_c_business where up_code = 77";
         	List<LineInfo> lines = jdbcTemplate.query(qline, new RowMapperLineInfo());
         	List<StopInfo> stops = jdbcTemplate.query(qstop, new RowMapperStopInfo());
         	List<Map<String, Object>> cars = jdbcTemplate.queryForList(qcar);
+        	List<Business> company = jdbcTemplate.query(qcompany, BeanPropertyRowMapper.newInstance(Business.class));
+        	List<Business> bcompany = jdbcTemplate.query(qbcompany, BeanPropertyRowMapper.newInstance(Business.class));
         	// 缓存线路基本信息
     		for (LineInfo line : lines) {
@@ -66,6 +72,14 @@ public class BasicDataRefreshThread extends Thread implements InitializingBean {
     		for (Map<String, Object> car : cars) {
     			BasicDataBuffer.putCar((String) car.get("device_id"), (String) car.get("plate_no"), (String) car.get("inside_code"), (String) car.get("vin"));
     		}
+
+    		for (Business business : company) {
+    			BasicDataBuffer.putCompany(business);
+			}
+
+			for (Business business : bcompany) {
+				BasicDataBuffer.putBrancheCompany(business);
+			}
     		logger.info("基础数据加载成功");
         }catch (Exception e){
 package com.bsth.server_rs.schedule;
 import com.bsth.entity.Waybill;
+import com.bsth.server_rs.gps.buffer.BasicDataBuffer;
+import com.bsth.server_rs.gps.buffer.BasicDataRefreshThread;
+import com.bsth.server_rs.gps.entity.LineInfo;
+import com.bsth.server_rs.gps.entity.StopInfo;
 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.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jdbc.core.BatchPreparedStatementSetter;
 import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
 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.io.BufferedReader;
+import java.io.FileReader;
+import java.nio.charset.StandardCharsets;
+import java.sql.Date;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 @Component
 @Path("/waybill")
 @Produces({MediaType.APPLICATION_JSON})
-public class WaybillService {
+@EnableScheduling
+public class WaybillService implements InitializingBean {
     private final static Logger log = LoggerFactory.getLogger(WaybillService.class);
@@ -32,53 +43,122 @@ public class WaybillService {
     @Autowired
     private JdbcTemplate jdbcTemplate;
+    @Autowired
+    private BasicDataRefreshThread basicDataRefreshThread;
+
+    private Set<String> adjustExps = new HashSet<>();
+
+    @Scheduled(cron = "0 0 0/2 * * *")
+    public void task() {
+        DateTime current = new DateTime();
+        for (int i = 0;i < 2;i++) {
+            current = current.minusDays(1);
+            String rq = current.toString("yyyy-MM-dd");
+            jdbcTemplate.update("delete from bsth_c_s_sp_info_real where schedule_date_str = ? and xl_name like '临港中运量%'", new Object[] { rq });
+            jdbcTemplate.update("insert into bsth_c_s_sp_info_real SELECT * FROM zyl.bsth_c_s_sp_info_real_1 where schedule_date_str = ?", new Object[] { rq });
+        }
+    }
+
     @POST
     public Map<String, Object> save(final List<Waybill> waybills) throws JsonProcessingException {
         Map<String, Object> result = new HashMap<>();
         log.error(mapper.writeValueAsString(waybills));
-        jdbcTemplate.batchUpdate("insert into zyl.bsth_c_s_sp_real_info (schedule_date_str,real_exec_date,xl_name,lp_name,cl_zbh,j_gh,j_name,s_gh,s_name," +
-                "xl_dir,qdz_name,qdz_code,zdz_name,zdz_code,fcsj,zdsj,fcno,bcs,jhlc,bcsj,bc_type,fcsj_actual,zdsj_actual,status,dfsj,gs_bm,fgs_bm,remarks) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
-            @Override
-            public void setValues(PreparedStatement ps, int i) throws SQLException {
-                Waybill sri = waybills.get(i);
-                ps.setString(1, sri.getScheduleDateStr());
-                ps.setString(2, sri.getRealExecDate());
-                ps.setString(3, sri.getXlName());
-                ps.setString(4, sri.getLpName());
-                ps.setString(5, sri.getClZbh());
-                ps.setString(6, sri.getjGh());
-                ps.setString(7, sri.getjName());
-                ps.setString(8, sri.getsGh());
-                ps.setString(9, sri.getsName());
-                ps.setString(10, sri.getXlDir());
-                ps.setString(11, sri.getQdzName());
-                ps.setString(12, sri.getQdzCode());
-                ps.setString(13, sri.getZdzName());
-                ps.setString(14, sri.getZdzCode());
-                ps.setString(15, sri.getFcsj());
-                ps.setString(16, sri.getZdsj());
-                ps.setInt(17, sri.getFcno());
-                ps.setInt(18, sri.getBcs());
-                ps.setDouble(19, sri.getJhlc());
-                ps.setInt(20, sri.getBcsj());
-                ps.setString(21, sri.getBcType());
-                ps.setString(22, sri.getFcsjActual());
-                ps.setString(23, sri.getZdsjActual());
-                ps.setInt(24, sri.getStatus());
-                ps.setString(25, sri.getDfsj());
-                ps.setString(26, sri.getGsBm());
-                ps.setString(27, sri.getFgsBm());
-                ps.setString(28, sri.getRemarks());
-            }
+        if (waybills.size() > 0) {
+            Waybill waybill = waybills.get(0);
+            String scheduleDateStr = new DateTime(Long.parseLong(waybill.getScheduleDateStr())).toString("yyyy-MM-dd");
+            jdbcTemplate.update("delete from zyl.bsth_c_s_sp_info_real_1 where schedule_date_str = ? and xl_name = ?", new Object[] { scheduleDateStr, waybill.getXlName() });
+            jdbcTemplate.batchUpdate("insert into zyl.bsth_c_s_sp_info_real_1 (schedule_date_str,real_exec_date,xl_name,lp_name,cl_zbh,j_gh,j_name,s_gh,s_name," +
+                    "xl_dir,qdz_name,qdz_code,zdz_name,zdz_code,fcsj,zdsj,fcno,bcs,jhlc,bcsj,bc_type,fcsj_actual,zdsj_actual,status,dfsj,gs_bm,fgs_bm,remarks,schedule_date,xl_bm,jhlc_orig,adjust_exps,gs_name,fgs_name) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    Waybill sri = waybills.get(i);
+                    LineInfo lineInfo = BasicDataBuffer.getLineByName(sri.getXlName());
+                    DateTime scheduleDate = new DateTime(Long.parseLong(sri.getScheduleDateStr())), realScheduleDate = new DateTime(Long.parseLong(sri.getRealExecDate()));
+                    int direction = Integer.parseInt(sri.getXlDir()) - 1;
+                    String clzbh = sri.getClZbh().replace("LG", "LG-"), remark = sri.getRemarks();
+                    String jgh = sri.getjGh() != null ? sri.getjGh().replace("05-", "") : "", sgh = sri.getsGh() != null ? sri.getsGh().replace("05-", "") : "";
+                    String adjustExp = sri.getStatus() == -1 ? getAdjustExp(remark) : null;
+                    sri.setScheduleDateStr(scheduleDate.toString("yyyy-MM-dd"));
+                    sri.setRealExecDate(realScheduleDate.toString("yyyy-MM-dd"));
+                    ps.setString(1, sri.getScheduleDateStr());
+                    ps.setString(2, sri.getRealExecDate());
+                    ps.setString(3, sri.getXlName());
+                    ps.setString(4, sri.getLpName());
+                    ps.setString(5, clzbh);
+                    ps.setString(6, jgh);
+                    ps.setString(7, sri.getjName());
+                    ps.setString(8, sgh);
+                    ps.setString(9, sri.getsName());
+                    ps.setString(10, String.valueOf(direction));
+                    ps.setString(11, sri.getQdzName());
+                    ps.setString(12, getStationCode(lineInfo, direction, sri.getQdzName()));
+                    ps.setString(13, sri.getZdzName());
+                    ps.setString(14, getStationCode(lineInfo, direction, sri.getZdzName()));
+                    ps.setString(15, sri.getFcsj());
+                    ps.setString(16, sri.getZdsj());
+                    ps.setInt(17, sri.getFcno());
+                    ps.setInt(18, i + 1);
+                    ps.setDouble(19, sri.getJhlc());
+                    ps.setInt(20, sri.getBcsj());
+                    ps.setString(21, sri.getBcType());
+                    ps.setString(22, sri.getFcsjActual());
+                    ps.setString(23, sri.getZdsjActual());
+                    ps.setInt(24, sri.getStatus());
+                    ps.setString(25, sri.getDfsj());
+                    ps.setString(26, lineInfo.getCompany());
+                    ps.setString(27, lineInfo.getBrancheCompany());
+                    ps.setString(28, sri.getRemarks());
+                    ps.setDate(29, new Date(scheduleDate.getMillis()));
+                    ps.setString(30, String.valueOf(lineInfo.getId()));
+                    ps.setDouble(31, sri.getJhlc());
+                    ps.setString(32, adjustExp);
+                    ps.setString(33, BasicDataBuffer.getCompanyNameByCode(lineInfo.getCompany()));
+                    ps.setString(34, BasicDataBuffer.getBranchCompanyNameByCode(lineInfo.getBrancheCompany()));
+                }
-            @Override
-            public int getBatchSize() {
-                return waybills.size();
-            }
-        });
+                @Override
+                public int getBatchSize() {
+                    return waybills.size();
+                }
+            });
+        }
         result.put("code", 0);
         result.put("msg", "ok");
         return result;
     }
+
+    private String getStationCode(LineInfo lineInfo, int direction, String stationName) {
+        List<StopInfo> stopInfos = direction == 0 ? lineInfo.getStopsUp() : lineInfo.getStopsDown();
+        for (StopInfo stopInfo : stopInfos) {
+            if (stationName.equals(stopInfo.getStationName().replace("(", "").replace("（", "").replace("起点站", "").replace("终点站","").replace("）","").replace(")", ""))) {
+                return stopInfo.getStationCod();
+            }
+        }
+
+        return null;
+    }
+
+    private String getAdjustExp(String remark) {
+        int idx = -1;
+        String exp = null;
+        for (String adjustExp : adjustExps) {
+            int currentIdx = remark.indexOf(adjustExp);
+            if (currentIdx > idx) {
+                idx = currentIdx;
+                exp = adjustExp;
+            }
+        }
+
+        return exp == null ? "其他" : exp;
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        adjustExps.addAll(Arrays.asList("配车", "保养", "故障", "肇事", "路阻", "纠纷", "缺人", "客稀", "缺车", "气候", "援外", "吊慢", "抽减", "路救抛锚", "其他"));
+        /*BufferedReader reader = new BufferedReader(new FileReader("E:/waybill.txt"));
+        String line = reader.readLine();
+        List<Waybill> waybills = mapper.readValue(line, mapper.getTypeFactory().constructParametricType(List.class, Waybill.class));
+        save(waybills);*/
+    }
 }