修改状态

Signed-off-by: zouap <zouap@pcl.ac.cn>

routers/repo/attachment.go

@@ -78,7 +78,7 @@ func UploadAttachmentUI(ctx *context.Context) {
 }
 
 func EditAttachmentUI(ctx *context.Context) {
-	
+
 	id, _ := strconv.ParseInt(ctx.Params(":id"), 10, 64)
 	ctx.Data["PageIsDataset"] = true
 	attachment, _ := models.GetAttachmentByID(id)
@@ -986,23 +986,29 @@ func HandleUnDecompressAttachment() {
 		if attach.Type == models.TypeCloudBrainOne {
 			err = worker.SendDecompressTask(contexExt.Background(), attach.UUID, attach.Name)
 			if err != nil {
-				log.Error("SendDecompressTask(%s) failed:%s", attach.UUID, err.Error())
+				log.Error("SendDecompressTask(%s)  failed:%s", attach.UUID, err.Error())
 			} else {
-				attach.DecompressState = models.DecompressStateIng
-				err = models.UpdateAttachment(attach)
-				if err != nil {
-					log.Error("UpdateAttachment state(%s) failed:%s", attach.UUID, err.Error())
-				}
+				updateAttachmentDecompressStateIng(attach)
 			}
 		} else if attach.Type == models.TypeCloudBrainTwo {
 			attachjson, _ := json.Marshal(attach)
-			labelmsg.SendDecompressAttachToLabelOBS(string(attachjson))
+			err = labelmsg.SendDecompressAttachToLabelOBS(string(attachjson))
+			if err != nil {
+				log.Error("SendDecompressTask to labelsystem (%s) failed:%s", attach.UUID, err.Error())
+			} else {
+				updateAttachmentDecompressStateIng(attach)
+			}
 		}
-
 	}
-
 	return
 }
+func updateAttachmentDecompressStateIng(attach *models.Attachment) {
+	attach.DecompressState = models.DecompressStateIng
+	err := models.UpdateAttachment(attach)
+	if err != nil {
+		log.Error("UpdateAttachment state(%s) failed:%s", attach.UUID, err.Error())
+	}
+}
 
 func QueryAllPublicDataset(ctx *context.Context) {
 	attachs, err := models.GetAllPublicAttachments()