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]