Browse Source

排除logbuffer空数据

zhczh_c
zhczyx@163.com 1 month ago
parent
commit
84fcf45ebd
  1. 6
      src/main/java/com/techsor/datacenter/sender/service/TrendLogService.java

6
src/main/java/com/techsor/datacenter/sender/service/TrendLogService.java

@ -12,6 +12,7 @@ import com.techsor.datacenter.sender.entitiy.kingio.*;
import com.techsor.datacenter.sender.utils.TimeUtils; import com.techsor.datacenter.sender.utils.TimeUtils;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -83,6 +84,11 @@ public class TrendLogService {
log.info("TrendLog DataSize to process:{}",data.getLog_buffer().size()); log.info("TrendLog DataSize to process:{}",data.getLog_buffer().size());
List<KingIODbmEntity> dbmValues = new ArrayList<>(); List<KingIODbmEntity> dbmValues = new ArrayList<>();
for(TrendLog1RawEntity.LogBuffer dataItem : data.getLog_buffer()){ for(TrendLog1RawEntity.LogBuffer dataItem : data.getLog_buffer()){
if(StringUtils.isBlank(dataItem.getLogData())){
log.warn("TrendLog Data is Blank,skip");
log.warn(dataItem.toString());
continue;
}
String topCompanyId= commonOpt.getTopCompanyId(data.getDeviceId()); String topCompanyId= commonOpt.getTopCompanyId(data.getDeviceId());
if (topCompanyId==null || topCompanyId.equals("0")){ if (topCompanyId==null || topCompanyId.equals("0")){
continue; continue;

Loading…
Cancel
Save