fiee/micro-bundle
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

移除dao层没用代码

Browse Source
This commit is contained in:
cjy 2026-01-21 10:32:38 +08:00
parent e1702d7b46
commit c87f1defa9
1 changed files with 1 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
internal/dao/taskDao.go
View File

@ -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 {
// 参数校验