调度预案配置

ljq
1 parent 27368090
Showing 4 changed files with 33 additions and 2 deletions
src/main/java/com/bsth/data/zndd/AutomaticSch.java
src/main/java/com/bsth/repository/zndd/ZnddYuAnRepository.java
src/main/java/com/bsth/service/zndd/ZnddYuAnService.java
src/main/java/com/bsth/service/zndd/impl/ZnddYuAnServiceImpl.java
@@ -2,6 +2,7 @@ package com.bsth.data.zndd;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.TypeReference;
 import com.bsth.data.BasicData;
 import com.bsth.data.adjg.domain.LargeGap;
 import com.bsth.data.directive.DayOfDirectives;
@@ -12,9 +13,11 @@ import com.bsth.data.schedule.ScheduleComparator;
 import com.bsth.data.schedule.late_adjust.LateAdjustHandle;
 import com.bsth.entity.directive.D60;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import com.bsth.entity.zndd.ZnddYuAn;
 import com.bsth.repository.StationRouteRepository;
 import com.bsth.service.directive.DirectiveService;
 import com.bsth.service.realcontrol.ScheduleRealInfoService;
+import com.bsth.service.zndd.ZnddYuAnService;
 import com.bsth.util.HttpClientUtils;
 import com.google.gson.Gson;
 import org.apache.commons.lang3.StringUtils;
@@ -22,6 +25,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -53,6 +57,8 @@ public class AutomaticSch {
     carMonitor carMonitor;
     @Autowired
     BasicData basicData;
+    @Autowired
+    ZnddYuAnService znddYuAnService;
     Queue<Map>  queue = new LinkedList<>();
@@ -442,4 +448,18 @@ public class AutomaticSch {
         long rangeLong = (((long) (new Random().nextDouble() * (max - min)))) + min;
         return rangeLong;
     }
+
+    //调度预案的配置情况
+    public String  penum(String type, String types){
+        List<ZnddYuAn> znyanList = znddYuAnService.yuanList(type,types);
+        for (ZnddYuAn zn : znyanList){
+            Map<String, Object> jsonMap = JSON.parseObject(zn.getJsonDate(), new TypeReference<HashMap<String, Object>>() {});
+
+            String typetext =  jsonMap.get("type").toString();
+            if(type.equals("pz")){
+                return typetext;
+            }
+        }
+        return null;
+    }
 }
@@ -7,9 +7,14 @@ import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
+import java.util.List;
+
 @Repository
 public interface ZnddYuAnRepository extends BaseRepository<ZnddYuAn, Integer> {
     @Modifying
     @Query(value="delete from ZnddYuAn sr where sr.type = ?1")
     void deleteType(String type);
+
+    @Query(value="select sr from ZnddYuAn sr where sr.type = ?1 and sr.types = ?2")
+    List<ZnddYuAn> yuanlist(String type,String types);
 }
 package com.bsth.service.zndd;
-import com.bsth.entity.GeoPremise;
 import com.bsth.entity.zndd.ZnddYuAn;
 import com.bsth.service.BaseService;
+import java.util.List;
 import java.util.Map;
 public interface ZnddYuAnService extends BaseService<ZnddYuAn, Integer> {
     Map<String, Object> addMap(Map<String, Object> params);
+
+
+     List<ZnddYuAn> yuanList(String type, String types);
 }
@@ -13,7 +13,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
-import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -61,4 +60,8 @@ public class ZnddYuAnServiceImpl extends BaseServiceImpl&lt;ZnddYuAn, Integer&gt; impl
         return rs;
     }
+
+    public List<ZnddYuAn> yuanList(String type,String types){
+        return znddYuAnRepository.yuanlist(type, types);
+    }
 }