修复昨日95值没计算bug。
This commit is contained in:
+4
@@ -772,6 +772,7 @@ public class EpsInitialTrafficDataServiceImpl implements EpsInitialTrafficDataSe
|
|||||||
// 对每个businessCode计算全天的95带宽
|
// 对每个businessCode计算全天的95带宽
|
||||||
for (String businessCode : businessCodes) {
|
for (String businessCode : businessCodes) {
|
||||||
// 设置当前要统计的业务代码(需要在queryParam或calculateSegment95中支持businessCode过滤)
|
// 设置当前要统计的业务代码(需要在queryParam或calculateSegment95中支持businessCode过滤)
|
||||||
|
queryParam.setMac(null);
|
||||||
queryParam.setBusinessId(businessCode); // 假设queryParam有setBusinessCode方法
|
queryParam.setBusinessId(businessCode); // 假设queryParam有setBusinessCode方法
|
||||||
calculateSegment95(queryParam, dailyStartTime, dailyEndTime, calculationMode);
|
calculateSegment95(queryParam, dailyStartTime, dailyEndTime, calculationMode);
|
||||||
}
|
}
|
||||||
@@ -781,6 +782,7 @@ public class EpsInitialTrafficDataServiceImpl implements EpsInitialTrafficDataSe
|
|||||||
.map(EpsMethodChangeRecord::getTrafficPort)
|
.map(EpsMethodChangeRecord::getTrafficPort)
|
||||||
.filter(Objects::nonNull)
|
.filter(Objects::nonNull)
|
||||||
.collect(Collectors.toSet());
|
.collect(Collectors.toSet());
|
||||||
|
queryParam.setBusinessId(null);
|
||||||
if(names != null && !names.isEmpty()){
|
if(names != null && !names.isEmpty()){
|
||||||
// 对每个网卡计算全天的95带宽
|
// 对每个网卡计算全天的95带宽
|
||||||
for (String name : names) {
|
for (String name : names) {
|
||||||
@@ -798,11 +800,13 @@ public class EpsInitialTrafficDataServiceImpl implements EpsInitialTrafficDataSe
|
|||||||
}
|
}
|
||||||
}else{
|
}else{
|
||||||
queryParam.setBusinessId(null);
|
queryParam.setBusinessId(null);
|
||||||
|
queryParam.setMac(null);
|
||||||
calculateNormalDeviceBandwidth(queryParam, dailyStartTime, dailyEndTime, calculationMode);
|
calculateNormalDeviceBandwidth(queryParam, dailyStartTime, dailyEndTime, calculationMode);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}else{
|
}else{
|
||||||
queryParam.setBusinessId(null);
|
queryParam.setBusinessId(null);
|
||||||
|
queryParam.setMac(null);
|
||||||
calculateNormalDeviceBandwidth(queryParam, dailyStartTime, dailyEndTime, calculationMode);
|
calculateNormalDeviceBandwidth(queryParam, dailyStartTime, dailyEndTime, calculationMode);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user