|
@@ -7,6 +7,7 @@ import cn.hutool.core.util.IdUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
import com.github.pagehelper.PageHelper;
|
|
import com.github.pagehelper.PageHelper;
|
|
|
import com.github.pagehelper.PageInfo;
|
|
import com.github.pagehelper.PageInfo;
|
|
|
|
|
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
|
|
|
import com.ytpm.agent.enums.UserStatusEnum;
|
|
import com.ytpm.agent.enums.UserStatusEnum;
|
|
|
import com.ytpm.agent.model.YtAppUser;
|
|
import com.ytpm.agent.model.YtAppUser;
|
|
|
import com.ytpm.agent.model.YtPlatformBanned;
|
|
import com.ytpm.agent.model.YtPlatformBanned;
|
|
@@ -467,11 +468,14 @@ public class RiskServiceImpl extends ReflectUtil implements RiskService {
|
|
|
if(records.isEmpty()){
|
|
if(records.isEmpty()){
|
|
|
return Result.resultOk(RepMessage.QUERY_SUCCESS);
|
|
return Result.resultOk(RepMessage.QUERY_SUCCESS);
|
|
|
}
|
|
}
|
|
|
- //校验风控742规则
|
|
|
|
|
- RiskTemplateView ecpmLimit= configMapper.getByCode("742");
|
|
|
|
|
|
|
+ //过滤出当日的激励视频数据
|
|
|
records = records.stream().filter(s->
|
|
records = records.stream().filter(s->
|
|
|
DateUtil.isSameDay(DateUtil.parse(s.getFinishTime()), new Date())
|
|
DateUtil.isSameDay(DateUtil.parse(s.getFinishTime()), new Date())
|
|
|
|
|
+ &&
|
|
|
|
|
+ AdSourceTypeEnum.rewarded_video.getAdSourceType() == s.getAdSourceType()
|
|
|
).collect(Collectors.toList());
|
|
).collect(Collectors.toList());
|
|
|
|
|
+ //校验风控742规则
|
|
|
|
|
+ RiskTemplateView ecpmLimit= configMapper.getByCode("742");
|
|
|
checkRisk742(ecpmLimit,userId,records);
|
|
checkRisk742(ecpmLimit,userId,records);
|
|
|
//校验风控746规则
|
|
//校验风控746规则
|
|
|
checkRisk746(userId,records,userRevenue);
|
|
checkRisk746(userId,records,userRevenue);
|