|
@@ -47,7 +47,7 @@ public class ContentPlatformDemandVideoJob {
|
|
|
// 调用接口获取需求匹配结果
|
|
// 调用接口获取需求匹配结果
|
|
|
JSONObject requestParam = new JSONObject();
|
|
JSONObject requestParam = new JSONObject();
|
|
|
requestParam.put("dt", dt);
|
|
requestParam.put("dt", dt);
|
|
|
- requestParam.put("channelName", "微信视频号");
|
|
|
|
|
|
|
+ requestParam.put("channelName", "群/企微合作-稳定");
|
|
|
|
|
|
|
|
String response = httpPoolClient.post(DEMAND_MATCH_API_URL, requestParam.toJSONString());
|
|
String response = httpPoolClient.post(DEMAND_MATCH_API_URL, requestParam.toJSONString());
|
|
|
if (!StringUtils.hasText(response)) {
|
|
if (!StringUtils.hasText(response)) {
|
|
@@ -138,6 +138,11 @@ public class ContentPlatformDemandVideoJob {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ // 过滤未获取到视频详情的记录
|
|
|
|
|
+ saveList = saveList.stream()
|
|
|
|
|
+ .filter(v -> StringUtils.hasText(v.getTitle()))
|
|
|
|
|
+ .collect(Collectors.toList());
|
|
|
|
|
+
|
|
|
// 先删除当天数据,再批量插入
|
|
// 先删除当天数据,再批量插入
|
|
|
demandVideoMapperExt.deleteByDt(dt);
|
|
demandVideoMapperExt.deleteByDt(dt);
|
|
|
for (List<ContentPlatformDemandVideo> partition : Lists.partition(saveList, 500)) {
|
|
for (List<ContentPlatformDemandVideo> partition : Lists.partition(saveList, 500)) {
|