From 1f61312e9aa4761c8723db9da4655d3f4664eeac Mon Sep 17 00:00:00 2001 From: cjy Date: Thu, 23 Oct 2025 11:05:40 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=B3=E9=97=AD=E4=BB=8E=E5=85=B6=E4=BB=96?= =?UTF-8?q?=E5=85=A5=E5=8F=A3=E5=8F=91=E5=B8=83=EF=BC=8C=E6=89=A3=E5=87=8F?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E5=8F=B0=E7=9A=84=E6=95=B0=E9=87=8F=E7=9A=84?= =?UTF-8?q?=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/service/cast/work.go | 83 ++++++++++++++++++++-------------------- 1 file changed, 42 insertions(+), 41 deletions(-) diff --git a/pkg/service/cast/work.go b/pkg/service/cast/work.go index 66c09f7..9a0b92c 100644 --- a/pkg/service/cast/work.go +++ b/pkg/service/cast/work.go @@ -10,7 +10,6 @@ import ( "fonchain-fiee/cmd/config" "fonchain-fiee/pkg/e" modelCast "fonchain-fiee/pkg/model/cast" - "fonchain-fiee/pkg/model/login" "fonchain-fiee/pkg/service" "strconv" @@ -59,26 +58,27 @@ func UpdateWorkImage(ctx *gin.Context) { return } - // EmployeeName 和 EmployeeNum 从 token 中获取 - userInfo := login.GetUserInfoFromC(ctx) - // 更新任务台的任务数量,调用员工实际任务状态更新 - if service.BundleProvider != nil { - resp1, err := service.BundleProvider.UpdateTaskProgress(context.Background(), &bundle.UpdateTaskProgressRequest{ - AssignRecordsUUID: "", - EmployeeName: userInfo.Name, - EmployeeNum: userInfo.TelNum, - TaskType: "post", - CompleteCount: 1, - }) - if err != nil { - zap.L().Error("UpdateTaskProgress failed", zap.Error(err)) - // 不直接返回错误,允许主要功能继续执行 - } else { - zap.L().Info("UpdateTaskProgress", zap.Any("resp", resp1)) - } - } else { - zap.L().Warn("BundleProvider is nil, skipping UpdateTaskProgress") - } + // 产品暂时关闭从其他入口发布,扣减任务台的数量的功能 + // // EmployeeName 和 EmployeeNum 从 token 中获取 + // userInfo := login.GetUserInfoFromC(ctx) + // // 更新任务台的任务数量,调用员工实际任务状态更新 + // if service.BundleProvider != nil { + // resp1, err := service.BundleProvider.UpdateTaskProgress(context.Background(), &bundle.UpdateTaskProgressRequest{ + // AssignRecordsUUID: "", + // EmployeeName: userInfo.Name, + // EmployeeNum: userInfo.TelNum, + // TaskType: "post", + // CompleteCount: 1, + // }) + // if err != nil { + // zap.L().Error("UpdateTaskProgress failed", zap.Error(err)) + // // 不直接返回错误,允许主要功能继续执行 + // } else { + // zap.L().Info("UpdateTaskProgress", zap.Any("resp", resp1)) + // } + // } else { + // zap.L().Warn("BundleProvider is nil, skipping UpdateTaskProgress") + // } service.Success(ctx, resp) return } @@ -124,26 +124,27 @@ func UpdateWorkVideo(ctx *gin.Context) { return } - // EmployeeName 和 EmployeeNum 从 token 中获取 - userInfo := login.GetUserInfoFromC(ctx) - // 更新任务台的任务数量,调用员工实际任务状态更新 - if service.BundleProvider != nil { - resp1, err := service.BundleProvider.UpdateTaskProgress(context.Background(), &bundle.UpdateTaskProgressRequest{ - AssignRecordsUUID: "", - EmployeeName: userInfo.Name, - EmployeeNum: userInfo.TelNum, - TaskType: "video", - CompleteCount: 1, - }) - if err != nil { - zap.L().Error("UpdateTaskProgress failed", zap.Error(err)) - // 不直接返回错误,允许主要功能继续执行 - } else { - zap.L().Info("UpdateTaskProgress", zap.Any("resp", resp1)) - } - } else { - zap.L().Warn("BundleProvider is nil, skipping UpdateTaskProgress") - } + // 产品暂时关闭从其他入口发布,扣减任务台的数量的功能 + // // EmployeeName 和 EmployeeNum 从 token 中获取 + // userInfo := login.GetUserInfoFromC(ctx) + // // 更新任务台的任务数量,调用员工实际任务状态更新 + // if service.BundleProvider != nil { + // resp1, err := service.BundleProvider.UpdateTaskProgress(context.Background(), &bundle.UpdateTaskProgressRequest{ + // AssignRecordsUUID: "", + // EmployeeName: userInfo.Name, + // EmployeeNum: userInfo.TelNum, + // TaskType: "video", + // CompleteCount: 1, + // }) + // if err != nil { + // zap.L().Error("UpdateTaskProgress failed", zap.Error(err)) + // // 不直接返回错误,允许主要功能继续执行 + // } else { + // zap.L().Info("UpdateTaskProgress", zap.Any("resp", resp1)) + // } + // } else { + // zap.L().Warn("BundleProvider is nil, skipping UpdateTaskProgress") + // } service.Success(ctx, resp) return }