Browse Source

add offline queue5

xiewj 2 tháng trước cách đây
mục cha
commit
de719d6c34

+ 7 - 1
720yun_fd_consumer/src/main/java/com/gis/listener/container/WorkOfflineListener.java

@@ -153,11 +153,17 @@ public class WorkOfflineListener implements ChannelAwareMessageListener {
                 workHotsFodderEntityList.forEach(workHotsFodderEntity -> {
                     FodderEntity fodderEntity = fodderService.getById(workHotsFodderEntity.getFodderId());
                     if (ObjUtil.isNotEmpty(fodderEntity)&&StrUtil.isNotEmpty(fodderEntity.getOssPath())&&!fodderEntity.getType().equalsIgnoreCase("pano")){
-                        log.info("下载热点资源:{}", fodderEntity.getOssPath());
+                        log.info("下载热点资源ossPath:{}", fodderEntity.getOssPath());
                         String ossKeyHot = fodderEntity.getOssPath().replaceAll(fileStorageTemplate.calculateUrl(""), "");
                         String defaultDataPath =basePath+File.separator+ossKeyHot;
                         fileStorageTemplate.ossDownloadFileToLocal(ossKeyHot, defaultDataPath);
                     }
+                    if (ObjUtil.isNotEmpty(fodderEntity)&&StrUtil.isNotEmpty(fodderEntity.getIcon())&&!fodderEntity.getType().equalsIgnoreCase("pano")){
+                        log.info("下载热点资源Icon:{}", fodderEntity.getIcon());
+                        String ossKeyHot = fodderEntity.getIcon().replaceAll(fileStorageTemplate.calculateUrl(""), "");
+                        String defaultDataPath =basePath+File.separator+ossKeyHot;
+                        fileStorageTemplate.ossDownloadFileToLocal(ossKeyHot, defaultDataPath);
+                    }
                 });
 
                 // 处理关联的作品和场景