update...

潘钊
1 parent bd859681
Showing 1 changed file with 11 additions and 1 deletions
src/main/java/com/bsth/server_rs/base_info/line/buffer/LineRefreshThread.java
@@ -8,7 +8,10 @@ import org.springframework.jdbc.core.BeanPropertyRowMapper;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
+import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 /**
  * Created by panzhao on 2017/3/27.
@@ -27,8 +30,15 @@ public class LineRefreshThread extends Thread{
         try {
             List<Line> list = jdbcTemplate.query("SELECT t1. NAME,t1.line_code,t1.start_station_name,t1.end_station_name,t1.start_station_first_time,t1.start_station_end_time,t1.end_station_first_time,t1.end_station_end_time,t1.company,t1.branche_company,t1.nature,t1.`level`,t1.destroy,t1.supper_line,t1.eq_linecode,t1.create_date,t2.total_mileage,t2.early_interval_lg,t2.late_interval_lg,t2.interval_lg,t2.speed_limit,t2.lag_station,t2.skip,t2.speeding,t2.crossed_line,t2.overflights FROM bsth_c_line t1 LEFT JOIN bsth_c_line_information t2 ON t1.id = t2.line where t1.destroy=0",
                     BeanPropertyRowMapper.newInstance(Line.class));
+
+            Map<String, Line> map = new HashMap<>();
+            //过滤数据，多条线路配人的保留一条
+            for(Line line : list){
+                map.put(line.getLineCode(), line);
+            }
+
             if(list != null && list.size() > 0)
-                LineBufferData.replaceAll(list);
+                LineBufferData.replaceAll(new ArrayList(map.values()));
         }catch (Exception e){
             logger.error("", e);
         }