Browse Source

add offline queue5

xiewj 3 months ago
parent
commit
0c5f312be6

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

@@ -149,7 +149,7 @@ public class WorkOfflineListener implements ChannelAwareMessageListener {
                 List<WorkHotsFodderEntity> workHotsFodderEntityList = workHotsFodderService.findAllByWorkId(param.getWorkId());
                 workHotsFodderEntityList.forEach(workHotsFodderEntity -> {
                     FodderEntity fodderEntity = fodderService.getById(workHotsFodderEntity.getFodderId());
-                    if (ObjUtil.isNotEmpty(fodderEntity)&&fodderEntity.getStatus()==3){
+                    if (ObjUtil.isNotEmpty(fodderEntity)&&StrUtil.isNotEmpty(fodderEntity.getOssPath())){
                         log.info("下载热点资源:{}", fodderEntity.getOssPath());
                         String ossKeyHot = fodderEntity.getOssPath().replaceAll(fileStorageTemplate.calculateUrl(""), "");
                         String defaultDataPath =basePath+File.separator+ossKeyHot;