pkg/service/cast/work.go

@@ -11,6 +11,7 @@ import (
 	"fonchain-fiee/pkg/e"
 	logicCast "fonchain-fiee/pkg/logic/cast"
 	modelCast "fonchain-fiee/pkg/model/cast"
+	"fonchain-fiee/pkg/model/login"
 	"fonchain-fiee/pkg/service"
 	"fonchain-fiee/pkg/utils/stime"
 	"strconv"
@@ -63,27 +64,26 @@ func UpdateWorkImage(ctx *gin.Context) {
 		return
 	}
 
-	// 产品暂时关闭从其他入口发布，扣减任务台的数量的功能
+	// EmployeeName 和 EmployeeNum 从 token 中获取
-	// // EmployeeName 和 EmployeeNum 从 token 中获取
+	userInfo := login.GetUserInfoFromC(ctx)
-	// userInfo := login.GetUserInfoFromC(ctx)
+	// 更新任务台的任务数量，调用员工实际任务状态更新
-	// // 更新任务台的任务数量，调用员工实际任务状态更新
+	if service.BundleProvider != nil {
-	// if service.BundleProvider != nil {
+		resp1, err := service.BundleProvider.UpdateTaskProgress(context.Background(), &bundle.UpdateTaskProgressRequest{
-	// 	resp1, err := service.BundleProvider.UpdateTaskProgress(context.Background(), &bundle.UpdateTaskProgressRequest{
+			AssignRecordsUUID: "",
-	// 		AssignRecordsUUID: "",
+			EmployeeName:      userInfo.Name,
-	// 		EmployeeName:      userInfo.Name,
+			EmployeeNum:       userInfo.TelNum,
-	// 		EmployeeNum:       userInfo.TelNum,
+			TaskType:          "post",
-	// 		TaskType:          "post",
+			CompleteCount:     1,
-	// 		CompleteCount:     1,
+		})
-	// 	})
+		if err != nil {
-	// 	if err != nil {
+			zap.L().Error("UpdateTaskProgress failed", zap.Error(err))
-	// 		zap.L().Error("UpdateTaskProgress failed", zap.Error(err))
+			// 不直接返回错误，允许主要功能继续执行
-	// 		// 不直接返回错误，允许主要功能继续执行
+		} else {
-	// 	} else {
+			zap.L().Info("UpdateTaskProgress", zap.Any("resp", resp1))
-	// 		zap.L().Info("UpdateTaskProgress", zap.Any("resp", resp1))
+		}
-	// 	}
+	} else {
-	// } else {
+		zap.L().Warn("BundleProvider is nil, skipping UpdateTaskProgress")
-	// 	zap.L().Warn("BundleProvider is nil, skipping UpdateTaskProgress")
+	}
-	// }
 	service.Success(ctx, resp)
 	return
 }
@@ -131,27 +131,26 @@ func UpdateWorkVideo(ctx *gin.Context) {
 		return
 	}
 
-	// 产品暂时关闭从其他入口发布，扣减任务台的数量的功能
+	// EmployeeName 和 EmployeeNum 从 token 中获取
-	// // EmployeeName 和 EmployeeNum 从 token 中获取
+	userInfo := login.GetUserInfoFromC(ctx)
-	// userInfo := login.GetUserInfoFromC(ctx)
+	// 更新任务台的任务数量，调用员工实际任务状态更新
-	// // 更新任务台的任务数量，调用员工实际任务状态更新
+	if service.BundleProvider != nil {
-	// if service.BundleProvider != nil {
+		resp1, err := service.BundleProvider.UpdateTaskProgress(context.Background(), &bundle.UpdateTaskProgressRequest{
-	// 	resp1, err := service.BundleProvider.UpdateTaskProgress(context.Background(), &bundle.UpdateTaskProgressRequest{
+			AssignRecordsUUID: "",
-	// 		AssignRecordsUUID: "",
+			EmployeeName:      userInfo.Name,
-	// 		EmployeeName:      userInfo.Name,
+			EmployeeNum:       userInfo.TelNum,
-	// 		EmployeeNum:       userInfo.TelNum,
+			TaskType:          "video",
-	// 		TaskType:          "video",
+			CompleteCount:     1,
-	// 		CompleteCount:     1,
+		})
-	// 	})
+		if err != nil {
-	// 	if err != nil {
+			zap.L().Error("UpdateTaskProgress failed", zap.Error(err))
-	// 		zap.L().Error("UpdateTaskProgress failed", zap.Error(err))
+			// 不直接返回错误，允许主要功能继续执行
-	// 		// 不直接返回错误，允许主要功能继续执行
+		} else {
-	// 	} else {
+			zap.L().Info("UpdateTaskProgress", zap.Any("resp", resp1))
-	// 		zap.L().Info("UpdateTaskProgress", zap.Any("resp", resp1))
+		}
-	// 	}
+	} else {
-	// } else {
+		zap.L().Warn("BundleProvider is nil, skipping UpdateTaskProgress")
-	// 	zap.L().Warn("BundleProvider is nil, skipping UpdateTaskProgress")
+	}
-	// }
 	service.Success(ctx, resp)
 	return
 }