From cc21125cd0f8ef3ac88e56187a8fa627d811ac7b Mon Sep 17 00:00:00 2001 From: lzy Date: Tue, 30 Nov 2021 17:31:47 +0800 Subject: [PATCH] =?UTF-8?q?=E6=97=A5=E5=BF=97=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/docus/webservice/config/MyScheduling.java | 10 +++++----- .../docus/webservice/service/PcmachineServiceImpl.java | 3 ++- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/docus-webservice/src/main/java/com/docus/webservice/config/MyScheduling.java b/docus-webservice/src/main/java/com/docus/webservice/config/MyScheduling.java index 81dd844..67ab25c 100644 --- a/docus-webservice/src/main/java/com/docus/webservice/config/MyScheduling.java +++ b/docus-webservice/src/main/java/com/docus/webservice/config/MyScheduling.java @@ -14,16 +14,16 @@ public class MyScheduling { @Autowired IPcmachineService pcmachineService; - private Logger logger= LogManager.getLogger(MyScheduling.class); + private Logger logger = LogManager.getLogger(MyScheduling.class); //10分钟执行一次 - @Scheduled(fixedRate = 1000*60*10) - public void beat(){ + @Scheduled(fixedRate = 1000 * 60 * 10) + public void beat() { Integer count = pcmachineService.count(); - logger.info("----心跳执行开始,当前在线采集器数:"+count+"----"); + logger.info("----心跳执行开始,当前在线采集器数:" + count + "----"); pcmachineService.isBeat(); Integer count2 = pcmachineService.count(); - logger.info("----心跳执行结束,此次心跳下线采集数:"+(count-count2)+"----"); + logger.info("----心跳执行结束,此次心跳下线采集数:" + (count - count2) + "----"); } diff --git a/docus-webservice/src/main/java/com/docus/webservice/service/PcmachineServiceImpl.java b/docus-webservice/src/main/java/com/docus/webservice/service/PcmachineServiceImpl.java index 5a6d15d..258e2d9 100644 --- a/docus-webservice/src/main/java/com/docus/webservice/service/PcmachineServiceImpl.java +++ b/docus-webservice/src/main/java/com/docus/webservice/service/PcmachineServiceImpl.java @@ -38,6 +38,7 @@ public class PcmachineServiceImpl implements IPcmachineService { @Override public void beat(String code, String ip) { + log.info("采集器:"+code+" 上线"); String name=pcmachineMapper.getNameByCode(code); String id= pcmachineMapper.getIdByName(name); Pcmachine pcmachine=new Pcmachine(); @@ -125,7 +126,7 @@ public class PcmachineServiceImpl implements IPcmachineService { } } - log.info("----------异步结束---------------"); + log.info("------------异步结束---------------"); } private String sendHttp(CollectList collectList, String jzh) throws URISyntaxException {