@@ -45,7 +45,7 @@
record_id, user_id, nick_name, placement_id, ad_source_id, revenue, network_form_id, network_name, network_placement_id, finish_time, begin_time,result_json,ad_source_type,ad_source_index,ecpm
from yt_dyz_ad_record
where user_id = #{userId}
- order by finish_time
+ order by finish_time desc
</select>
<select id="getByUserIds" resultType="com.ytpm.app.model.YtDyzAdRecord">
select
@@ -468,12 +468,12 @@ public class RiskServiceImpl extends ReflectUtil implements RiskService {
if(records.isEmpty()){
return Result.resultOk(RepMessage.QUERY_SUCCESS);
}
- //过滤出当日的激励视频数据
+ //过滤出当日的激励视频数据 按照时间正序排以便筛选每日前几条激励视频
records = records.stream().filter(s->
DateUtil.isSameDay(DateUtil.parse(s.getFinishTime()), new Date())
&&
AdSourceTypeEnum.rewarded_video.getAdSourceType() == s.getAdSourceType()
- ).collect(Collectors.toList());
+ ).sorted(Comparator.comparing(YtDyzAdRecord::getFinishTime)).collect(Collectors.toList());
//校验风控742规则
RiskTemplateView ecpmLimit= configMapper.getByCode("742");
checkRisk742(ecpmLimit,userId,records);