fiee/fonchain-fiee
10
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

关闭从其他入口发布，扣减任务台的数量的功能

Browse Source
This commit is contained in:
cjy 2025-10-23 11:05:40 +08:00
parent 5ee928c5cf
commit 1f61312e9a
1 changed files with 42 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
pkg/service/cast/work.go
View File

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