|
@@ -10,14 +10,14 @@ type LocalLifeTaskInfoDao struct{}
|
|
|
// 获取指定违约类型的本地生活子任务数量
|
|
|
func (d LocalLifeTaskInfoDao) CountByDefaultType(localId string, defaultType int64) int64 {
|
|
|
var total int64
|
|
|
- Db.Model(&entity.LocalLifeInfo{}).Where("local_id = ? AND cur_default_type = ?", localId, defaultType).Count(&total)
|
|
|
+ Db.Model(&entity.LocalLifeTaskInfo{}).Where("local_id = ? AND cur_default_type = ?", localId, defaultType).Count(&total)
|
|
|
return total
|
|
|
}
|
|
|
|
|
|
// 获取指定任务阶段的本地生活子任务数量
|
|
|
func (d LocalLifeTaskInfoDao) CountByTaskStage(localId string, taskStage int64) int64 {
|
|
|
var total int64
|
|
|
- Db.Model(&entity.LocalLifeInfo{}).Where("local_id = ? AND task_stage = ?", localId, taskStage).Count(&total)
|
|
|
+ Db.Model(&entity.LocalLifeTaskInfo{}).Where("local_id = ? AND task_stage = ?", localId, taskStage).Count(&total)
|
|
|
return total
|
|
|
}
|
|
|
|
|
@@ -58,78 +58,78 @@ func (d LocalLifeTaskInfoDao) GetListByTaskStage(localId string, bookStatus int6
|
|
|
}
|
|
|
|
|
|
// 获取未传初稿的本地生活子任务数据
|
|
|
-func (d LocalLifeTaskInfoDao) GetListBySketchDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeInfo, int64, error) {
|
|
|
- projectTaskInfos := []entity.LocalLifeInfo{}
|
|
|
+func (d LocalLifeTaskInfoDao) GetListBySketchDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeTaskInfo, int64, error) {
|
|
|
+ localTaskInfos := []entity.LocalLifeTaskInfo{}
|
|
|
var total int64
|
|
|
- query := Db.Model(&entity.LocalLifeInfo{}).Where("local_id = ? AND cur_default_type = ?", param.TaskId, 4)
|
|
|
+ query := Db.Model(&entity.LocalLifeTaskInfo{}).Where("local_id = ? AND cur_default_type = ?", param.TaskId, 4)
|
|
|
query.Count(&total)
|
|
|
query = query.Select("task_id, talent_id, settle_amount, draft_fee, sketch_missing_time")
|
|
|
offset := (param.Page - 1) * param.PageSize
|
|
|
- if err := query.Order("sketch_missing_time desc").Offset(offset).Limit(param.PageSize).Find(&projectTaskInfos).Error; err != nil {
|
|
|
+ if err := query.Order("sketch_missing_time desc").Offset(offset).Limit(param.PageSize).Find(&localTaskInfos).Error; err != nil {
|
|
|
return nil, 0, err
|
|
|
}
|
|
|
- return projectTaskInfos, total, nil
|
|
|
+ return localTaskInfos, total, nil
|
|
|
}
|
|
|
|
|
|
// 获取未发作品的本地生活子任务数据
|
|
|
-func (d LocalLifeTaskInfoDao) GetListByLinkDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeInfo, int64, error) {
|
|
|
- projectTaskInfos := []entity.LocalLifeInfo{}
|
|
|
+func (d LocalLifeTaskInfoDao) GetListByLinkDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeTaskInfo, int64, error) {
|
|
|
+ localTaskInfos := []entity.LocalLifeTaskInfo{}
|
|
|
var total int64
|
|
|
- query := Db.Model(&entity.LocalLifeInfo{}).Where("local_id = ? AND cur_default_type = ?", param.TaskId, 6)
|
|
|
+ query := Db.Model(&entity.LocalLifeTaskInfo{}).Where("local_id = ? AND cur_default_type = ?", param.TaskId, 6)
|
|
|
query.Count(&total)
|
|
|
query = query.Select("task_id, talent_id, settle_amount, draft_fee, link_missing_time")
|
|
|
offset := (param.Page - 1) * param.PageSize
|
|
|
- if err := query.Order("link_missing_time desc").Offset(offset).Limit(param.PageSize).Find(&projectTaskInfos).Error; err != nil {
|
|
|
+ if err := query.Order("link_missing_time desc").Offset(offset).Limit(param.PageSize).Find(&localTaskInfos).Error; err != nil {
|
|
|
return nil, 0, err
|
|
|
}
|
|
|
- return projectTaskInfos, total, nil
|
|
|
+ return localTaskInfos, total, nil
|
|
|
}
|
|
|
|
|
|
// 获取未传数据的本地生活子任务数据
|
|
|
-func (d LocalLifeTaskInfoDao) GetListByDataDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeInfo, int64, error) {
|
|
|
- projectTaskInfos := []entity.LocalLifeInfo{}
|
|
|
+func (d LocalLifeTaskInfoDao) GetListByDataDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeTaskInfo, int64, error) {
|
|
|
+ localTaskInfos := []entity.LocalLifeTaskInfo{}
|
|
|
var total int64
|
|
|
- query := Db.Model(&entity.LocalLifeInfo{}).Where("local_id = ? AND cur_default_type = ?", param.TaskId, 8)
|
|
|
+ query := Db.Model(&entity.LocalLifeTaskInfo{}).Where("local_id = ? AND cur_default_type = ?", param.TaskId, 8)
|
|
|
query.Count(&total)
|
|
|
query = query.Select("task_id, talent_id, settle_amount, draft_fee, data_missing_time")
|
|
|
offset := (param.Page - 1) * param.PageSize
|
|
|
- if err := query.Order("data_missing_time desc").Offset(offset).Limit(param.PageSize).Find(&projectTaskInfos).Error; err != nil {
|
|
|
+ if err := query.Order("data_missing_time desc").Offset(offset).Limit(param.PageSize).Find(&localTaskInfos).Error; err != nil {
|
|
|
return nil, 0, err
|
|
|
}
|
|
|
- return projectTaskInfos, total, nil
|
|
|
+ return localTaskInfos, total, nil
|
|
|
}
|
|
|
|
|
|
// 获取终止合作的本地生活子任务数据
|
|
|
-func (d LocalLifeTaskInfoDao) GetListByTerminateDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeInfo, int64, error) {
|
|
|
- projectTaskInfos := []entity.LocalLifeInfo{}
|
|
|
+func (d LocalLifeTaskInfoDao) GetListByTerminateDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeTaskInfo, int64, error) {
|
|
|
+ localTaskInfos := []entity.LocalLifeTaskInfo{}
|
|
|
var total int64
|
|
|
- query := Db.Debug().Model(&entity.LocalLifeInfo{}).Where("local_id = ? AND task_stage = ?", param.TaskId, 17)
|
|
|
+ query := Db.Debug().Model(&entity.LocalLifeTaskInfo{}).Where("local_id = ? AND task_stage = ?", param.TaskId, 17)
|
|
|
query.Count(&total)
|
|
|
query = query.Select("task_id, talent_id, settle_amount, draft_fee, terminate_time, terminate_reason, terminate_operator_type, terminate_operator")
|
|
|
offset := (param.Page - 1) * param.PageSize
|
|
|
- if err := query.Order("terminate_time desc").Offset(offset).Limit(param.PageSize).Find(&projectTaskInfos).Error; err != nil {
|
|
|
+ if err := query.Order("terminate_time desc").Offset(offset).Limit(param.PageSize).Find(&localTaskInfos).Error; err != nil {
|
|
|
return nil, 0, err
|
|
|
}
|
|
|
- return projectTaskInfos, total, nil
|
|
|
+ return localTaskInfos, total, nil
|
|
|
}
|
|
|
|
|
|
// 获取已解约的本地生活子任务数据
|
|
|
-func (d LocalLifeTaskInfoDao) GetListByCancelDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeInfo, int64, error) {
|
|
|
- projectTaskInfos := []entity.LocalLifeInfo{}
|
|
|
+func (d LocalLifeTaskInfoDao) GetListByCancelDefault(param *vo.DefaultSearchParam) ([]entity.LocalLifeTaskInfo, int64, error) {
|
|
|
+ localTaskInfos := []entity.LocalLifeTaskInfo{}
|
|
|
var total int64
|
|
|
- query := Db.Debug().Model(&entity.LocalLifeInfo{}).Where("local_id = ? AND task_stage = ?", param.TaskId, 16)
|
|
|
+ query := Db.Debug().Model(&entity.LocalLifeTaskInfo{}).Where("local_id = ? AND task_stage = ?", param.TaskId, 16)
|
|
|
query.Count(&total)
|
|
|
query = query.Select("task_id, talent_id, settle_amount, draft_fee, cancel_time, cancel_reason, cancel_operator_type, cancel_operator")
|
|
|
offset := (param.Page - 1) * param.PageSize
|
|
|
- if err := query.Order("cancel_time desc").Offset(offset).Limit(param.PageSize).Find(&projectTaskInfos).Error; err != nil {
|
|
|
+ if err := query.Order("cancel_time desc").Offset(offset).Limit(param.PageSize).Find(&localTaskInfos).Error; err != nil {
|
|
|
return nil, 0, err
|
|
|
}
|
|
|
- return projectTaskInfos, total, nil
|
|
|
+ return localTaskInfos, total, nil
|
|
|
}
|
|
|
|
|
|
// 更新字段
|
|
|
func (d LocalLifeTaskInfoDao) UpdateField(taskId string, updateData map[string]interface{}) error {
|
|
|
- err := Db.Model(&entity.LocalLifeInfo{}).Where("task_id = ?", taskId).Updates(updateData).Error
|
|
|
+ err := Db.Model(&entity.LocalLifeTaskInfo{}).Where("task_id = ?", taskId).Updates(updateData).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -138,7 +138,7 @@ func (d LocalLifeTaskInfoDao) UpdateField(taskId string, updateData map[string]i
|
|
|
|
|
|
// 批量更新字段
|
|
|
func (d LocalLifeTaskInfoDao) UpdateFieldBatch(taskIds []string, updateData map[string]interface{}) error {
|
|
|
- err := Db.Model(&entity.LocalLifeInfo{}).Where("task_id IN ?", taskIds).Updates(updateData).Error
|
|
|
+ err := Db.Model(&entity.LocalLifeTaskInfo{}).Where("task_id IN ?", taskIds).Updates(updateData).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|