add offline queue5

720yun_fd_base/gis_service/src/main/java/com/gis/service/WorkService.java

@@ -82,5 +82,6 @@ public interface WorkService extends IService<WorkEntity> {
     void updatePanoStatus(String id, int panoStatus);
 
     boolean updateOfflineStatus(String id, int offlineStatus);
+    boolean updateOfflineStatusAndUrl(String id, int offlineStatus,String url);
 
 }

720yun_fd_base/gis_service/src/main/java/com/gis/service/impl/WorkServiceImpl.java

@@ -2089,4 +2089,13 @@ public class WorkServiceImpl extends ServiceImpl<WorkMapper, WorkEntity> impleme
         wrapper.set(WorkEntity::getOfflineStatus, offlineStatus);
         return update(wrapper);
     }
+
+    @Override
+    public boolean updateOfflineStatusAndUrl(String id, int offlineStatus, String url) {
+        LambdaUpdateWrapper<WorkEntity> wrapper=Wrappers.lambdaUpdate();
+        wrapper.eq(WorkEntity::getId, id);
+        wrapper.set(WorkEntity::getOfflineStatus, offlineStatus);
+        wrapper.set(WorkEntity::getOfflineUrl, url);
+        return update(wrapper);
+    }
 }

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

@@ -194,9 +194,9 @@ public class WorkOfflineListener implements ChannelAwareMessageListener {
                 redisUtil.set(progressKey, 90);
                 OssShUtil.yunUpload(param.getPath() + File.separator + zipName,zipOssKey);
                 redisUtil.set(progressKey, 100);
-                workService.updateOfflineStatus(param.getWorkId(), 3);
                 String ossUrl = fileStorageTemplate.calculateUrl(zipOssKey);
                 log.info("上传OSS完成,{}", ossUrl );
+                workService.updateOfflineStatusAndUrl(param.getWorkId(), 3,ossUrl);
                 WorkOfflineDoneDTO workOfflineDoneDTO=new WorkOfflineDoneDTO();
                 workOfflineDoneDTO.setWorkId(workEntity.getId());
                 workOfflineDoneDTO.setUrl(ossUrl);