|
|
@@ -80,8 +80,15 @@ public class ContentPlatformDemandVideoJob {
|
|
|
/**
|
|
|
* 写入三条默认记录:仅含匹配实验id及三个匹配相关字段,其它字段为空。
|
|
|
* 用 channel_name=DEFAULT_RECORD_CHANNEL 与正常渠道数据隔离,先按 (dt, channel_name) 删除后批量插入,保证幂等。
|
|
|
+ * 仅当该 dt 已存在数据时才执行,避免在无任何渠道数据的日期下凭空插入默认记录。
|
|
|
*/
|
|
|
private void insertDefaultRecords(String dt) {
|
|
|
+ int existCount = demandVideoMapperExt.countByCondition(dt, null, null, null, null);
|
|
|
+ if (existCount <= 0) {
|
|
|
+ log.info("insertDefaultRecords skip, dt={} has no data", dt);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
Long now = System.currentTimeMillis();
|
|
|
List<ContentPlatformDemandVideo> defaults = new ArrayList<>();
|
|
|
defaults.add(buildDefaultRecord(dt, now,
|