添加服务追踪

refined-manager/src/main/java/com/mortals/xhx/daemon/task/RealTimePeopleStatTaskImpl.java

@@ -25,6 +25,7 @@ import org.springframework.web.multipart.MultipartFile;
 
 import java.io.ByteArrayInputStream;
 import java.io.InputStream;
+import java.text.DateFormat;
 import java.util.Date;
 import java.util.List;
 
@@ -110,29 +111,31 @@ public class RealTimePeopleStatTaskImpl implements ITaskExcuteService {
         //下载最近一天的抓拍数据
         RealtimeDataflowQuery realtimeDataflowQuery = new RealtimeDataflowQuery();
         realtimeDataflowQuery.setDetectTimeStart(DateUtil.yesterday().toStringDefaultTimeZone());
+        realtimeDataflowQuery.setDetectTimeEnd(DateUtil.formatDateTime(new Date()));
         //realtimeDataflowQuery.setPicture("");
         List<RealtimeDataflowEntity> updateList = realtimeDataflowService.find(realtimeDataflowQuery).stream()
                 .filter(f -> ObjectUtils.isEmpty(f.getPicture()) && !ObjectUtils.isEmpty(f.getPicUri()))
                 .map(item -> {
-            ImgReq imgReq = new ImgReq();
-            imgReq.setUrl(item.getPicUri());
-            Rest<String> rest = faceService.downloadPicture(imgReq);
-            if (YesNoEnum.YES.getValue() == rest.getCode()) {
-                byte[] bytes = Base64.decode(rest.getData());
-                if (!ObjectUtils.isEmpty(bytes)) {
-                    InputStream inputStream = new ByteArrayInputStream(bytes);
-                    MultipartFile file = ServletUtils.getMultipartFile(inputStream, "snap.jpg");
-                    String filePath = uploadService.saveFileUpload(file, "file/fileupload/snap", null);
-                    item.setPicture(filePath);
-                    item.setUpdateTime(new Date());
-                    item.setUpdateUserId(1L);
-                    item.setUpdateUserName("system");
-                    return item;
-                }
-            }
-            return null;
-        }).filter(f -> f != null).collect(toList());
-        log.info("更新列表:{}",updateList.size());
+                    ImgReq imgReq = new ImgReq();
+                    imgReq.setUrl(item.getPicUri());
+                    Rest<String> rest = faceService.downloadPicture(imgReq);
+                    if (YesNoEnum.YES.getValue() == rest.getCode()) {
+                        byte[] bytes = Base64.decode(rest.getData());
+                        if (!ObjectUtils.isEmpty(bytes)) {
+                            InputStream inputStream = new ByteArrayInputStream(bytes);
+                            MultipartFile file = ServletUtils.getMultipartFile(inputStream, "snap.jpg");
+
+                            String filePath = uploadService.saveFileUpload(file, "file/fileupload/snap/" + DateUtil.today(), null);
+                            item.setPicture(filePath);
+                            item.setUpdateTime(new Date());
+                            item.setUpdateUserId(1L);
+                            item.setUpdateUserName("system");
+                            return item;
+                        }
+                    }
+                    return null;
+                }).filter(f -> f != null).collect(toList());
+        log.info("更新列表:{}", updateList.size());
         if (!ObjectUtils.isEmpty(updateList)) {
             realtimeDataflowService.update(updateList, null);
         }