diff --git a/internal/dao/taskDao.go b/internal/dao/taskDao.go index 69e2a2a..34c6bfe 100644 --- a/internal/dao/taskDao.go +++ b/internal/dao/taskDao.go @@ -1666,47 +1666,6 @@ func UpdateTaskProgress(req *dto.CompleteTaskRequest) error { return nil } -// GetTaskManagementBySubNum 根据艺人编号查询任务管理记录 -func GetTaskManagementBySubNum(subNum string) (*model.TaskManagement, error) { - var task model.TaskManagement - err := app.ModuleClients.TaskBenchDB.Where("sub_num = ?", subNum).First(&task).Error - if err != nil { - if err == gorm.ErrRecordNotFound { - return nil, nil // 记录不存在 - } - return nil, commonErr.ReturnError(err, "查询任务管理记录失败", "查询任务管理记录失败: ") - } - return &task, nil -} - -// GetTaskBalanceBySubNum 根据艺人编号查询任务余额记录 -func GetTaskBalanceBySubNum(subNum string) (*model.TaskBalance, error) { - var taskBalance model.TaskBalance - now := time.Now() - - // 优先查询当前有效期内的记录 - err := app.ModuleClients.TaskBenchDB.Where("sub_num = ? AND start_at <= ? AND expired_at >= ?", - subNum, now, now).Order("start_at DESC").First(&taskBalance).Error - - if err != nil { - if err == gorm.ErrRecordNotFound { - // 如果没有当前有效的记录,查询最新的记录 - err = app.ModuleClients.TaskBenchDB.Where("sub_num = ?", subNum). - Order("start_at DESC").First(&taskBalance).Error - if err != nil { - if err == gorm.ErrRecordNotFound { - return nil, nil // 记录不存在 - } - return nil, commonErr.ReturnError(err, "查询任务余额记录失败", "查询任务余额记录失败: ") - } - } else { - return nil, commonErr.ReturnError(err, "查询任务余额记录失败", "查询任务余额记录失败: ") - } - } - - return &taskBalance, nil -} - // GetAssignRecordByUUID 根据UUID查询指派记录 func GetAssignRecordByUUID(uuid string) (*model.TaskAssignRecords, error) { var record model.TaskAssignRecords @@ -1923,7 +1882,7 @@ func GetValidArtistList() ([]dto.ValidArtistInfo, error) { return data, nil } -// 新增:根据艺人手机号统计进行中的与已完成任务数量 +// 根据艺人编号统计进行中的与已完成任务数量 func GetArtistTaskStatsBySubNum(SubNum string) (int, int, error) { if SubNum == "" { return 0, 0, nil @@ -1945,18 +1904,6 @@ func GetArtistTaskStatsBySubNum(SubNum string) (int, int, error) { return res.ProgressTaskCount, res.CompleteTaskCount, nil } -// 更新被指派员工为 taskAssigneeNum 的记录中的ProgressCount + 1 和CompleteCount - 1 -func UpdateTaskRecordsByAssigneeNum(taskAssigneeNum string) error { - err := app.ModuleClients.TaskBenchDB.Table("task_management"). - Where("task_assignee_num = ?", taskAssigneeNum). - Update("progress_count", gorm.Expr("progress_count + ?", 1)). - Update("complete_count", gorm.Expr("complete_count - ?", 1)).Error - if err != nil { - return commonErr.ReturnError(err, "更新员工任务进度失败", "更新员工任务进度失败: ") - } - return nil -} - // CreateTaskWorkLog 创建任务日志记录 func CreateTaskWorkLog(req *dto.CreateTaskWorkLogRequest) error { // 参数校验