1

ljq
1 parent 03e6def0
Showing 1 changed file with 27 additions and 0 deletions
src/main/java/com/bsth/controller/realcontrol/ServiceDataInterface.java
@@ -13,9 +13,12 @@ import com.bsth.data.gpsdata_v2.GpsRealData;
 import com.bsth.data.gpsdata_v2.entity.GpsEntity;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.data.schedule.external.TccExternalService;
+import com.bsth.entity.Line;
 import com.bsth.entity.directive.D60;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import com.bsth.repository.LineRepository;
 import com.bsth.repository.directive.D60Repository;
+import com.bsth.service.LineService;
 import com.bsth.websocket.handler.SendUtils;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.base.Splitter;
@@ -59,6 +62,13 @@ public class ServiceDataInterface {
     @Autowired
     private SendUtils sendUtils;
+
+    @Autowired
+    LineRepository lineRepository;
+    
+    @Autowired
+    private LineService service;
+    
     /**
      * 获取车辆 和 当前执行班次对照信息
      *
@@ -324,9 +334,26 @@ public class ServiceDataInterface {
         ObjectMapper mapper = new ObjectMapper();
         try {
+            List<Map<String,String>> emergencyList = new ArrayList();
+            List<Map<String,String>> emergencyListAll = new ArrayList();
             List<Map> maps = mapper.readValue(jsonStr,mapper.getTypeFactory().constructParametricType(List.class, Map.class));
             for (Map map : maps) {
                 sendUtils.sendContingencyPlan(map);
+                emergencyList.add((Map<String, String>) map.get("emergencyLine"));
+            }
+      
+            for (Map.Entry<String, String> m : BasicData.lineCode2NameMap.entrySet()){
+                for (Map<String,String> emer : emergencyList){
+                    for (Map.Entry<String,String> t : emer.entrySet()){
+                        if(m.getKey().equals(t.getKey())){
+                            emergencyListAll.add(emer); //
+                            Line line = lineRepository.findById(Integer.parseInt(t.getKey())).get();
+                            line.setName(t.getValue());
+                            Map<String, Object> status = service.update(line);
+                            logger.info("应急接口修改线路名称-----------------------"+status.get("status"));
+                        }
+                    }
+                }
             }
         } catch (IOException e) {
             result.put("errCode", 502);