diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java index db9010ea..a34a8257 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/MsgExchangeRunner.java @@ -33,20 +33,20 @@ public class MsgExchangeRunner implements Runnable{ @Override public void run() { - logger.debug("进入获取动态航班消息..."); + logger.info("进入获取动态航班消息..."); //获取上次的beginId Integer beginIdInt = (Integer)redisService.get(RedisKeyConstant.KEY_LASTBEGINID); Long beginId = beginIdInt.longValue(); - logger.debug("从上次获取的消息位置{}开始",beginId); + logger.info("从上次获取的消息位置{}开始",beginId); //获取航班动态消息 List lsCminmsgs = cminmsgService.getNewMsgsAfterId(beginId); if(null == lsCminmsgs || lsCminmsgs.size() <= 0) { - logger.debug("本周期没有获取到最新消息,直接退出本次循环"); + logger.info("本周期没有获取到最新消息,直接退出本次循环"); return; } @@ -59,6 +59,6 @@ public class MsgExchangeRunner implements Runnable{ }//end for - logger.debug("本次定时获取新消息完成..."); + logger.info("本次定时获取新消息完成..."); }//end run } diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java index b0901383..a56a2781 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java @@ -1,6 +1,5 @@ package com.gzzn.omms.msgexchangeapi.runner; -import java.util.ArrayList; import java.util.Arrays; import java.util.Date; import java.util.Optional; @@ -52,7 +51,7 @@ public class SchdWaitRunner implements Runnable { while (isRun) { tryTimes++; - logger.debug("尝试第{}次获取返回日计划消息",tryTimes); + logger.info("尝试第{}次获取返回日计划消息",tryTimes); //获取 Date waitSchdDate = (Date) redisService.get(RedisKeyConstant.KEY_WAITSCHDDATE); @@ -106,7 +105,7 @@ public class SchdWaitRunner implements Runnable { try { Thread.sleep(intervalMs); } catch (InterruptedException e) { - e.printStackTrace(); + logger.info("sleep error:{}",e.getMessage()); } } }