Commit 828f178d46d22d5dfcceb03e9725dcf3ff233deb
1 parent
c43abb73
update...
Showing
2 changed files
with
7 additions
and
5 deletions
src/main/java/com/bsth/redis/ScheduleRedisService.java
| @@ -228,15 +228,17 @@ public class ScheduleRedisService implements CommandLineRunner { | @@ -228,15 +228,17 @@ public class ScheduleRedisService implements CommandLineRunner { | ||
| 228 | public void run() { | 228 | public void run() { |
| 229 | try { | 229 | try { |
| 230 | DateTime dt = new DateTime(); | 230 | DateTime dt = new DateTime(); |
| 231 | - String rq = dt.toString("yyyy-MM-dd"); | ||
| 232 | - logger.info("ScheduleRefreshThread..." + rq + " -start"); | ||
| 233 | - List<ScheduleRealInfo> list = realInfoRepository.findAll(rq); | 231 | + DateTime yesterday = dt.minusDays(2); |
| 232 | + | ||
| 233 | + String rq = yesterday.toString("yyyy-MM-dd"); | ||
| 234 | + logger.info("refresh lt yesterday ..." + rq + " -start"); | ||
| 235 | + List<ScheduleRealInfo> list = realInfoRepository.findByDateLT(rq); | ||
| 234 | 236 | ||
| 235 | //计算时间戳 | 237 | //计算时间戳 |
| 236 | scheduleRedisService.calcTime(list); | 238 | scheduleRedisService.calcTime(list); |
| 237 | scheduleRedisService.wirte(list); | 239 | scheduleRedisService.wirte(list); |
| 238 | 240 | ||
| 239 | - logger.info("ScheduleRefreshThread..." + rq + " -end"); | 241 | + logger.info("refresh lt yesterday ..." + rq + " -end### size: " + list.size()); |
| 240 | } catch (Exception e) { | 242 | } catch (Exception e) { |
| 241 | logger.error("", e); | 243 | logger.error("", e); |
| 242 | } | 244 | } |
src/main/java/com/bsth/server_rs/schedule/real/ScheduleRealService.java
| @@ -94,7 +94,7 @@ public class ScheduleRealService { | @@ -94,7 +94,7 @@ public class ScheduleRealService { | ||
| 94 | @GET | 94 | @GET |
| 95 | @Path("/in_out/pz_vip/{code}") | 95 | @Path("/in_out/pz_vip/{code}") |
| 96 | public List<ScheduleInOut> findInOut_real(@PathParam("code") String code) { | 96 | public List<ScheduleInOut> findInOut_real(@PathParam("code") String code) { |
| 97 | - logger.error("in_out -" + code); | 97 | + logger.info("in_out -" + code); |
| 98 | return ScheduleInOut.getMultiInstance(schRealDataBuffer.findByParkCode(code)); | 98 | return ScheduleInOut.getMultiInstance(schRealDataBuffer.findByParkCode(code)); |
| 99 | } | 99 | } |
| 100 | 100 |