1

src/main/java/com/fdkankan/fusion/mq/consumer/OsgbToB3dmConsumer.java

@@ -41,7 +41,7 @@ public class OsgbToB3dmConsumer {
     @Autowired
     LocalToOssUtil localToOssUtil;
 
-    //@Async
+    @Async
     public void consumerQueue(Integer uploadId)  {
         String sourcePath = null;
         String localPath = null;

src/main/java/com/fdkankan/fusion/service/impl/CommonUploadServiceImpl.java

@@ -154,7 +154,7 @@ public class CommonUploadServiceImpl extends ServiceImpl<ICommonUploadMapper, Co
         CommonUpload commonUpload = commonUploadService.add(oldName,url, String.valueOf(getDirectorySize(unZipFile)),
                 null, fileTypeEnum, modelFileFormat,resultFormat,status,unZipFile.getPath(),dictId);
         if("osgb".equals(modelFileFormat)){
-            //commonUploadService.updateStatus(commonUpload.getId(),0);
+            commonUploadService.updateStatus(commonUpload.getId(),0);
             uploadOsgb(commonUpload.getId()) ;
         }
         return ResultData.ok(commonUpload);