update...

潘钊
1 parent cee12c6e
Showing 1 changed file with 27 additions and 0 deletions
src/main/java/com/bsth/server_rs/schedule/real/ScheduleRealService.java
@@ -2,12 +2,14 @@ package com.bsth.server_rs.schedule.real;
 import com.alibaba.fastjson.JSONObject;
 import com.bsth.common.BasicData;
+import com.bsth.entity.ScheduleRealInfo;
 import com.bsth.redis.ScheduleRedisService;
 import com.bsth.server_rs.base_info.line.Line;
 import com.bsth.server_rs.base_info.line.buffer.LineBufferData;
 import com.bsth.server_rs.schedule.dto.ScheduleCcInfoConfig;
 import com.bsth.server_rs.schedule.dto.ScheduleInOut;
 import com.bsth.server_rs.schedule.dto.ScheduleRealInfoDTO_JK;
+import com.google.common.base.Splitter;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -107,4 +109,29 @@ public class ScheduleRealService {
         }
         return all;
     }
+
+    /**
+     * 读取指定日期的redis 数据，计算程序调用
+     * @param rqs
+     * @return
+     */
+    @GET
+    @Path("/pz_vip/read/{rqs}")
+    public List<ScheduleRealInfo> read(@PathParam("rqs") String rqs){
+        List<ScheduleRealInfo> all = new ArrayList<>(), rs = new ArrayList<>();
+        List<Line> lines = LineBufferData.findAll();
+        List<String> rqArray = Splitter.on(",").splitToList(rqs);
+
+        for(Line line : lines){
+            for(String rq : rqArray)
+                all.addAll(redisService.read(rq, line.getLineCode()));
+        }
+
+        for(ScheduleRealInfo sch : all){
+            if(sch.getStatus() != -1 && (sch.getcTasks()==null || sch.getcTasks().size()==0))
+                continue;
+            rs.add(sch);
+        }
+        return rs;
+    }
 }