From 21c6ca001628bf76fa0d400ab1b56f6c777e765d Mon Sep 17 00:00:00 2001 From: "zhczyx@163.com" Date: Wed, 11 Feb 2026 11:56:41 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=8A=B6=E6=80=81=E8=AE=BE?= =?UTF-8?q?=E5=A4=87=E9=80=BB=E8=BE=91=EF=BC=8C=E5=A6=82=E6=9E=9C=E5=BD=93?= =?UTF-8?q?=E6=AC=A1=E5=80=BC=E4=B8=8E=E4=B8=8A=E6=AC=A1=E5=80=BC=E7=9B=B8?= =?UTF-8?q?=E5=90=8C=EF=BC=8C=E4=B8=8D=E6=9B=B4=E6=96=B0=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E8=AE=BE=E5=A4=87=E8=AE=B0=E5=BD=95=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sender/service/impl/DataProcessServiceImpl.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/techsor/datacenter/sender/service/impl/DataProcessServiceImpl.java b/src/main/java/com/techsor/datacenter/sender/service/impl/DataProcessServiceImpl.java index deea88d..9bd7fe6 100644 --- a/src/main/java/com/techsor/datacenter/sender/service/impl/DataProcessServiceImpl.java +++ b/src/main/java/com/techsor/datacenter/sender/service/impl/DataProcessServiceImpl.java @@ -1521,11 +1521,13 @@ public class DataProcessServiceImpl implements IDataProcessService { updateData.setAggregatedRunningTime(historyData.getAggregatedRunningTime()); updateData.setContinuousRunningTime(0L); }else if (historyData.getIsRunning()==1){ - log.info("bs_status: process [start],last status [start]"); - Long tsPeriod = (System.currentTimeMillis()-Long.parseLong(historyData.getLatest_ts())); - log.info("tsPeriod: "+tsPeriod); - updateData.setAggregatedRunningTime(historyData.getAggregatedRunningTime()+tsPeriod); - updateData.setContinuousRunningTime(0L); + log.warn("Break due to last bs_status is start, the new bs_status is:"+value); + return; +// log.info("bs_status: process [start],last status [start]"); +// Long tsPeriod = (System.currentTimeMillis()-Long.parseLong(historyData.getLatest_ts())); +// log.info("tsPeriod: "+tsPeriod); +// updateData.setAggregatedRunningTime(historyData.getAggregatedRunningTime()+tsPeriod); +// updateData.setContinuousRunningTime(0L); } }else if (value==0){ //Process [stop]