修改

console/get_convert_command.go

@@ -61,35 +61,31 @@ func getConvertDoData(ctx context.Context) int8 {
 	list, err := db.GetServerSiteMicrosDB().DocServerProject.Query().Where(
 		docserverproject.StatusEQ(1),
 	).All(ctx)
-
 	if err != nil {
 		return 0
 	}
-
 	if len(list) <= 0 {
 		return 0
 	}
 
 	for _, items := range list {
-		res := GetProjectInfo(ctx, items.ID)
-		if res > 0 {
-			_, errUpdateSt := db.GetServerSiteMicrosDB().DocServerProject.UpdateOneID(items.ID).SetStatus(2).Save(ctx)
-			if errUpdateSt != nil {
-				log.Info("修改获取的文件进度状态失败" + errUpdateSt.Error())
-				continue
-			}
+		res, msg := GetProjectInfo(ctx, items.ID)
+		logger.Info("状态: %d", res)
+		_, errUpdateSt := db.GetServerSiteMicrosDB().DocServerProject.UpdateOneID(items.ID).SetStatus(2).SetCallbackRes(msg).Save(ctx)
+		if errUpdateSt != nil {
+			log.Info("修改获取的文件进度状态失败" + errUpdateSt.Error())
+			continue
 		}
 	}
-
-	return 0
+	return int8(len(list))
 }
 
-func GetProjectInfo(c context.Context, projectId int32) int8 {
+func GetProjectInfo(c context.Context, projectId int32) (int8, string) {
 
 	defer recoverPanicGetPro()
 	projectInfo, infoErr := db.GetServerSiteMicrosDB().DocServerProject.Get(c, projectId)
 	if infoErr != nil {
-		return 0
+		return 0, infoErr.Error()
 	}
 	request := &service.GetTaskRequest{}
 	request.ProjectId = projectId
@@ -103,9 +99,9 @@ func GetProjectInfo(c context.Context, projectId int32) int8 {
 	if errs != nil || *result.StatusCode != 200 || *result.Body.Status != "Succeeded" {
 		logger.Info(result)
 		logger.Error("错误信息" + errs.Error())
-		return 0
+		return 0, errs.Error()
 	}
 	service2.CreateGetProject(c, projectId, *result.Body.Status)
 
-	return 1
+	return 1, "success"
 }