|
@@ -568,9 +568,9 @@ public class RiskServiceImpl extends ReflectUtil implements RiskService {
|
|
|
int firstAdCount = Integer.parseInt(limitMap.get("firstAdCount"));
|
|
int firstAdCount = Integer.parseInt(limitMap.get("firstAdCount"));
|
|
|
if(adCount>=firstAdCount){
|
|
if(adCount>=firstAdCount){
|
|
|
//过滤出ecpm值小于预设值的视频数
|
|
//过滤出ecpm值小于预设值的视频数
|
|
|
- int ecpm = Integer.parseInt(limitMap.get("ecpm"));
|
|
|
|
|
|
|
+ BigDecimal ecpm = new BigDecimal(limitMap.get("ecpm"));
|
|
|
long count = records.stream().filter(
|
|
long count = records.stream().filter(
|
|
|
- s -> Objects.nonNull(s.getEcpm())&&(s.getEcpm().compareTo(BigDecimal.valueOf(ecpm))) < 0).count();
|
|
|
|
|
|
|
+ s -> Objects.nonNull(s.getEcpm())&&(s.getEcpm().compareTo(ecpm)) < 0).count();
|
|
|
int exact = Math.toIntExact(count);
|
|
int exact = Math.toIntExact(count);
|
|
|
//判断小于预设值的视频数超出预设次数
|
|
//判断小于预设值的视频数超出预设次数
|
|
|
int haveCount = Integer.parseInt(limitMap.get("haveCount"));
|
|
int haveCount = Integer.parseInt(limitMap.get("haveCount"));
|