驾驶员匹配修改

ljq
1 parent be45452c
Showing 3 changed files with 39 additions and 61 deletions
src/main/java/com/bsth/data/zndd/ZnddThread.java
src/main/java/com/bsth/data/zndd/ZnddTwoThread.java
src/main/java/com/bsth/data/zndd/outer_car/OrderListThread.java
@@ -12,9 +12,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import java.text.SimpleDateFormat;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 /**
  * 调度预案 发车间隔、误点、大间隔、满载、大客流
@@ -23,8 +21,6 @@ import java.util.Map;
 public class ZnddThread extends Thread{
     Logger logger = LoggerFactory.getLogger(this.getClass());
-    /*@Autowired
-    StationPeopleLoggerRepository stationPeopleLoggerRepository;*/
     @Autowired
     DayOfSchedule dayOfSchedule;
     @Autowired
@@ -35,28 +31,15 @@ public class ZnddThread extends Thread{
     StationRouteRepository stationRouteRepository;
     @Autowired
     AutomaticSch automaticSch;
-
     @Autowired
     ZnddStatusRepository znddStatusRepository;
-    static Map<String,List> ZNDDTYPEMAP = new HashMap<>(); //已经推送过的检测
-
-
-
-
     private static SimpleDateFormat sdfHHmm = new SimpleDateFormat("HH:mm");
     private static SimpleDateFormat sdfMonth = new SimpleDateFormat("yyyy-MM-dd");
     private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
     @Override
     public void run() {
-        try {
-            List<znddStatus> znddStatusList = (List<znddStatus>) znddStatusRepository.findAll();
-
-            //GPSDJG();//大间隔
-            // MZ(); //满载
-            //DKL(); //大客流 以接口方式
-            //automaticSch.mz();
-            //automaticSch.dfTz();//大间隔
+        try {List<znddStatus> znddStatusList = (List<znddStatus>) znddStatusRepository.findAll();
             for (znddStatus zs : znddStatusList) {
                  if (zs.getOpenStatus() != null && zs.getOpenStatus().equals("0")) {
                     if (zs.getType().equals("sftz")) {
@@ -76,13 +59,6 @@ public class ZnddThread extends Thread{
         }catch (Throwable e){
             logger.info("智能调度线程——————",e);
         }
-
-
-
     }
-
-
-
-
 }
@@ -12,9 +12,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import java.text.SimpleDateFormat;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 /**
  * 调度预案 发车间隔、误点、大间隔、满载、大客流
@@ -23,8 +21,6 @@ import java.util.Map;
 public class ZnddTwoThread extends Thread{
     Logger logger = LoggerFactory.getLogger(this.getClass());
-    /*@Autowired
-    StationPeopleLoggerRepository stationPeopleLoggerRepository;*/
     @Autowired
     DayOfSchedule dayOfSchedule;
     @Autowired
@@ -39,11 +35,6 @@ public class ZnddTwoThread extends Thread{
     @Autowired
     ZnddStatusRepository znddStatusRepository;
-    static Map<String,List> ZNDDTYPEMAP = new HashMap<>(); //已经推送过的检测
-
-
-
-
     private static SimpleDateFormat sdfHHmm = new SimpleDateFormat("HH:mm");
     private static SimpleDateFormat sdfMonth = new SimpleDateFormat("yyyy-MM-dd");
     private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
@@ -81,7 +72,6 @@ public class ZnddTwoThread extends Thread{
                                 logger.info("行车大间隔执行完毕");
                             }
                         }.start();//启动线程
-
                     }
                     if (zs.getType().equals("mz")) {
                         new Thread() {
@@ -113,8 +103,6 @@ public class ZnddTwoThread extends Thread{
                     }
                 }
             }
-
-
         } catch (Exception e) {
             logger.info("智能调度线程——————", e);
         }
@@ -153,20 +153,21 @@ public class OrderListThread extends Thread{
                             //如果有套跑 分割班次作用
                             if (!clsc.getXlBm().equals(m.get("lineCode").toString())){
                                 Long FcsjT = clsc.getFcsjT();
-                                //判断 在上一班次结束和下一个班次开始时的空档期是否有别线路
+                                //判断 在上一订单结束和下一个订单开始时的空档期是否有别线路
                                 //11:00   13:00    12> 11 ** 12 < 13
                                 if (FcsjT > coleTime &&  FcsjT < dospathTime){
                                     lsmap.put("startDate",sdf.parse(orXlList.get(is).get("DispatchTime").toString()).getTime()); //派单时间
                                     lsmap.put("endDate", sdf.parse(m.get("CloseTime").toString()).getTime()); //行程结束时间
                                     lsmap.put("CheckTime", sdf.parse(m.get("CheckTime").toString()).getTime()); //核销时间
                                     lsmap.put("car_plate", clzbh); //车牌号
-                                    lsmap.put("jName", m.get("DriverName")); //驾驶员
+                                    lsmap.put("jName", m.get("DriverNumber")); //驾驶员
                                     lsmap.put("xl", m.get("AreaName"));//区域名称
                                     lsmap.put("remark", "公交随心订闲时响应班次（"+(i + 1 -is)+"个）");//区域名称
                                     lsmap.put("num", (i + 1 -is));//区域名称
                                     SchMap.add(lsmap);
                                     is = i + 1;
                                     lsmap = new HashMap();
+                                    break;
                                 }
                             }
                         }
@@ -175,7 +176,7 @@ public class OrderListThread extends Thread{
                         lsmap.put("endDate",sdf.parse(m.get("CloseTime").toString()).getTime()); //行程结束时间
                         lsmap.put("CheckTime", sdf.parse(m.get("CheckTime").toString()).getTime()); //核销时间
                         lsmap.put("car_plate", clzbh); //车牌号
-                        lsmap.put("jName", m.get("DriverName")); //驾驶员
+                        lsmap.put("jName", m.get("DriverNumber")); //驾驶员
                         lsmap.put("xl", m.get("AreaName"));//区域名称
                         lsmap.put("remark", "公交随心订闲时响应班次（"+(i + 1 -is)+"个）");//区域名称
                         lsmap.put("num", (i + 1 -is));//区域名称
@@ -184,7 +185,7 @@ public class OrderListThread extends Thread{
                 }
                 //根据业务部提出新需求单独加一个方法，保证因各种因素导致的行程都能算上
-                //1.起点站终点站和上下班次对应
+                //1.起点站终点站和上下班次对应 --对应不上 起点站到起点站
                 //2.订单-班次数量  同一起终点 派单时间3分钟以内合并成一个订单。
                 //3.实到时间改成下一班次的发车时间前10分钟。
                 //4.实发时间改成上一个班次发车后10分
@@ -224,13 +225,7 @@ public class OrderListThread extends Thread{
                             lmp.put("endDate",sc2.getFcsjT() - (10* 60 *1000));
                             break;
                         }
-                        //有可能没有直接添加
-                        if (sc1.getZdsjT() > CheckTime && sc2.getFcsjT() < endDate){
-                            lmp.put("startDate",sc1.getZdsjT() + (10* 60 *1000));
-                            lmp.put("endDate",sc2.getFcsjT() - (10* 60 *1000));
-                            break;
-                        }
-
+                        //有可能没有直接添加 直接使用默认的
                     }
                 }
@@ -247,7 +242,7 @@ public class OrderListThread extends Thread{
                     String LpName = null;
                     for (ScheduleRealInfo sr : schList) {
                         //范围内有已添加班次 -- 合并
-                        //同一车辆，备注里响应式公交班次数相同 发车时间在这个班次的前后五分钟
+                        //同一车辆，备注里响应式公交班次数相同 发车时间在这个班次的前后10分钟
                         if (cl.equals(sr.getClZbh()) && startTime <= sr.getFcsjT() && startTime1 >= sr.getFcsjT() && sr.getStatus() != -1
                                 && sr.getRemarks() !=null && sr.getRemarks().contains("随心订")){
                             //不管有没有相同的班次数 重新计算一下里程
@@ -276,7 +271,7 @@ public class OrderListThread extends Thread{
                     List<TrackPoint> points = getTrackPoints(device, sc.getFcsjActualTime(), sc.getZdsjActualTime());
                     // 计算总里程
                     double totalMileage = Double.valueOf(String.format("%.1f", calculateTotalMileage(points)));
-                    if (totalMileage != 0)
+                    if (totalMileage != 0  && !sc.getRemarks().contains("调整"))
                         sc.setJhlc(totalMileage);
                     //里程没问题添加班次
                     if (sc.getId() == null) {
@@ -314,24 +309,24 @@ public class OrderListThread extends Thread{
             Line line = lineService.findByLineCode(lineCode);
             Long dispatchTime = Long.valueOf(map.get("startDate").toString());
             Long closeTime = Long.valueOf(map.get("endDate").toString());
+            int direction = 1;
+            //单独设置响应式公交103 105的班次
+            if (line.getName().contains("103区域")){
+                direction = 0;
+            }
-            List<StationRoute> list = GeoCacheData.getStationRoute(lineCode, 0);
+
+            List<StationRoute> list = GeoCacheData.getStationRoute(lineCode, direction);
             String clzbh = map.get("car_plate").toString();
-            String jName = map.get("jName").toString();
-            String jGh = null;
-            Map<String, String> allpersion = BasicData.allPerson; //所有人员
-            for (String key : allpersion.keySet()) {
-                if (jName.equals(allpersion.get(key))) {
-                    //加上判断临港公交  避免另外公司重名
-                    jGh = key.split("-")[1];
-                }
-            }
+            String jName = map.get("jName").toString(); //05 -000000
+            String jGh = "77"+"-"+jName.split("-")[1];
+            jName = BasicData.allPerson.get("77"+"-"+jName.split("-")[1]);
             //公司 和 分公司名称
             sch.setGsBm(line.getCompany());
             sch.setFgsBm(line.getBrancheCompany());
-            sch.setBcType("normal");
+            sch.setBcType("region");
             sch.setXlBm(lineCode);
             sch.setXlName(line.getName());
             sch.setLpName(LpName !=null ? LpName : "临1");//临加路牌
@@ -360,6 +355,10 @@ public class OrderListThread extends Thread{
     public ScheduleRealInfo SetSch (Map map,ScheduleRealInfo sch) {
         try {
+            //人工在备注中输入调整二字后不再调整这个班次
+            if (sch.getRemarks() != null && sch.getRemarks().contains("调整")){
+                return sch;
+            }
             //初始到站时间直接到下一班次10分钟之前了 不用在修改班次了
             /*Long closeTime = Long.parseLong(map.get("endDate").toString());
             sch.setZdsj(hhmm.print(closeTime));
@@ -396,6 +395,8 @@ public class OrderListThread extends Thread{
             rs = ps.executeQuery();
             //GPS84坐标
             while (rs.next()) {
+                if (getService(rs.getLong("SERVICE_STATE")) == 0)
+                    continue;
                 double lat = rs.getDouble("LAT");
                 double lon = rs.getDouble("LON");
                 Long timestamp = rs.getLong("TS");
@@ -410,6 +411,19 @@ public class OrderListThread extends Thread{
     }
+
+    /**
+     * 获取GPS信号状态
+     *
+     * @return 0有效 1无效
+     */
+    public static byte getService(long serviceState) {
+        /*if ((serviceState & 0x00020000) == 0x00020000 || (serviceState & 0x80000000) == 0x80000000)
+            return -1;*/
+        return (byte) (((serviceState & 0x00100000) == 0x00100000) ? 0 : 1);
+    }
+
+
     public static class Orderfcsj implements Comparator<Map> {
         @Override
         public int compare(Map o1, Map o2) {