Skip to content

R
refined-platform
Commit 970689b6 authored by 赵啸非's avatar 赵啸非
Browse files
Options

添加服务追踪

parent 56955640
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 3 deletions
refined-manager/src/main/java/com/mortals/xhx/daemon/task/RealTimeDownloadImgTaskImpl.java
View file @ 970689b6
...@@ -58,10 +58,10 @@ public class RealTimeDownloadImgTaskImpl implements ITaskExcuteService { ...@@ -58,10 +58,10 @@ public class RealTimeDownloadImgTaskImpl implements ITaskExcuteService {
realtimeDataflowQuery.setDetectTimeEnd(DateUtil.formatDateTime(new Date())); realtimeDataflowQuery.setDetectTimeEnd(DateUtil.formatDateTime(new Date()));
PageInfo pageInfo = new PageInfo(); PageInfo pageInfo = new PageInfo();
pageInfo.setPrePageResult(50); pageInfo.setPrePageResult(50);
//realtimeDataflowQuery.setPicture("");
List<RealtimeDataflowEntity> updateList = realtimeDataflowService.find(realtimeDataflowQuery, pageInfo, null).getList() List<RealtimeDataflowEntity> updateList = realtimeDataflowService.find(realtimeDataflowQuery, pageInfo, null).getList()
.parallelStream() .parallelStream()
.filter(f -> ObjectUtils.isEmpty(f.getPicture()) && !ObjectUtils.isEmpty(f.getPicUri())) .filter(f -> !ObjectUtils.isEmpty(f.getPicUri()))
.filter(f -> ObjectUtils.isEmpty(f.getPicture()))
.map(item -> { .map(item -> {
ImgReq imgReq = new ImgReq(); ImgReq imgReq = new ImgReq();
imgReq.setUrl(item.getPicUri()); imgReq.setUrl(item.getPicUri());
...@@ -76,12 +76,13 @@ public class RealTimeDownloadImgTaskImpl implements ITaskExcuteService { ...@@ -76,12 +76,13 @@ public class RealTimeDownloadImgTaskImpl implements ITaskExcuteService {
item.setUpdateTime(new Date()); item.setUpdateTime(new Date());
item.setUpdateUserId(1L); item.setUpdateUserId(1L);
item.setUpdateUserName("system"); item.setUpdateUserName("system");
log.info("item:{},picPath:{}",item.getId(),item.getPicture());
return item; return item;
} }
} }
return null; return null;
}).filter(f -> f != null).collect(toList()); }).filter(f -> f != null).collect(toList());
log.info("更新列表:{}", updateList.size()); log.info("更新图片列表:{}", updateList.size());
if (!ObjectUtils.isEmpty(updateList)) { if (!ObjectUtils.isEmpty(updateList)) {
realtimeDataflowService.update(updateList, null); realtimeDataflowService.update(updateList, null);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment