add offline queue5

720yun_fd_base/gis_domain/src/main/java/com/gis/domain/dto/WorkOfflineDoneDTO.java

@@ -1,5 +1,6 @@
 package com.gis.domain.dto;
 
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 /**
@@ -13,4 +14,6 @@ public class WorkOfflineDoneDTO {
 
     private String url; //http下载路径
 
+    @ApiModelProperty(value = "离线包 状态：-1失败 0未生成 1排队中 2生成中 3生成成功", name = "offlineStatus")
+    private Integer offlineStatus;
 }

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

@@ -209,14 +209,19 @@ public class WorkOfflineListener implements ChannelAwareMessageListener {
                 WorkOfflineDoneDTO workOfflineDoneDTO=new WorkOfflineDoneDTO();
                 workOfflineDoneDTO.setWorkId(workEntity.getId());
                 workOfflineDoneDTO.setUrl(ossUrl);
+                workOfflineDoneDTO.setOfflineStatus(3);
                 rabbitMqProducerUtil.sendByWorkQueue(workOfflineDoneQueue,workOfflineDoneDTO);
 
             }
 
 
         } catch (Exception e) {
-            log.error("场景WorkOffline报错{}", e.getMessage());
+            log.error("场景WorkOffline报错{}", e);
             workService.updateOfflineStatus(param.getWorkId(), -1);
+            WorkOfflineDoneDTO workOfflineDoneDTO=new WorkOfflineDoneDTO();
+            workOfflineDoneDTO.setWorkId(param.getWorkId());
+            workOfflineDoneDTO.setOfflineStatus(-1);
+            rabbitMqProducerUtil.sendByWorkQueue(workOfflineDoneQueue,workOfflineDoneDTO);
             e.printStackTrace();
         } finally {
             redisUtil.delete(key);