Browse Source

feat(dao&service): add updateTsOnly method and adjust log and logic

新增更新最新时间戳的DAO方法,在状态中断时仅更新lastTs并调整日志提示
zhczh_c
zhczyx@163.com 2 weeks ago
parent
commit
ce42e9a23e
  1. 8
      src/main/java/com/techsor/datacenter/sender/dao/BaStatusDao.java
  2. 6
      src/main/java/com/techsor/datacenter/sender/service/impl/DataProcessServiceImpl.java

8
src/main/java/com/techsor/datacenter/sender/dao/BaStatusDao.java

@ -69,6 +69,14 @@ public class BaStatusDao {
return (rows>0); return (rows>0);
} }
public Boolean updateTsOnly(BaStatusEntity entity) {
String sql= "UPDATE ba_status_statistics SET " +
"latest_ts = ?" +
"WHERE id = ?";
int rows = jdbcTemplate.update(sql,entity.getLatest_ts(),entity.getId());
return (rows>0);
}
public Boolean insertHistory(BaStatusHistoryEntity entity) { public Boolean insertHistory(BaStatusHistoryEntity entity) {
String sql = "INSERT INTO `ba_status_history` " + String sql = "INSERT INTO `ba_status_history` " +
"(`device_info_id`, `is_running`, `update_ts`) " + "(`device_info_id`, `is_running`, `update_ts`) " +

6
src/main/java/com/techsor/datacenter/sender/service/impl/DataProcessServiceImpl.java

@ -1538,7 +1538,8 @@ public class DataProcessServiceImpl implements IDataProcessService {
updateData.setAggregatedRunningTime(historyData.getAggregatedRunningTime()); updateData.setAggregatedRunningTime(historyData.getAggregatedRunningTime());
updateData.setContinuousRunningTime(0L); updateData.setContinuousRunningTime(0L);
}else if (historyData.getIsRunning()==1){ }else if (historyData.getIsRunning()==1){
log.warn("Break due to last bs_status is start, the new bs_status is:"+value); log.warn("Break due to last bs_status is start, Only update lastTs, the new bs_status is:"+value);
baStatusDao.updateTsOnly(updateData);
return; return;
// log.info("bs_status: process [start],last status [start]"); // log.info("bs_status: process [start],last status [start]");
// Long tsPeriod = (System.currentTimeMillis()-Long.parseLong(historyData.getLatest_ts())); // Long tsPeriod = (System.currentTimeMillis()-Long.parseLong(historyData.getLatest_ts()));
@ -1554,7 +1555,8 @@ public class DataProcessServiceImpl implements IDataProcessService {
updateData.setLastStopTime(System.currentTimeMillis()); updateData.setLastStopTime(System.currentTimeMillis());
//check history data's status //check history data's status
if (historyData.getIsRunning()==0){ if (historyData.getIsRunning()==0){
log.warn("Break due to last bs_status is stop, the new bs_status is:"+value); log.warn("Break due to last bs_status is stop, Only update lastTs, the new bs_status is:"+value);
baStatusDao.updateTsOnly(updateData);
return; return;
}else if (historyData.getIsRunning()==1){ }else if (historyData.getIsRunning()==1){
log.info("bs_status: process [stop],last status [start]"); log.info("bs_status: process [stop],last status [start]");

Loading…
Cancel
Save