|
@@ -247,7 +247,7 @@ func GetSignInOfflineTask(projectForm int32) error {
|
|
db1.Model(gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND logistics_status = ?", projectInfo.ProjectID, 2).Find(&taskInfos)
|
|
db1.Model(gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND logistics_status = ?", projectInfo.ProjectID, 2).Find(&taskInfos)
|
|
//fmt.Println("taskInfos", taskInfos)
|
|
//fmt.Println("taskInfos", taskInfos)
|
|
for _, taskInfo := range taskInfos {
|
|
for _, taskInfo := range taskInfos {
|
|
- fmt.Println("TaskId", taskInfo.TaskId)
|
|
|
|
|
|
+ //fmt.Println("TaskId", taskInfo.TaskId)
|
|
if _, ok1 := taskIDs[taskInfo.TaskId]; !ok1 {
|
|
if _, ok1 := taskIDs[taskInfo.TaskId]; !ok1 {
|
|
taskIds = append(taskIds, taskInfo.TaskId)
|
|
taskIds = append(taskIds, taskInfo.TaskId)
|
|
taskIDs[taskInfo.TaskId] = taskInfo.ProjectId
|
|
taskIDs[taskInfo.TaskId] = taskInfo.ProjectId
|
|
@@ -267,7 +267,7 @@ func GetSignInOfflineTask(projectForm int32) error {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
//fmt.Println("projectIdMap", projectIdMap)
|
|
//fmt.Println("projectIdMap", projectIdMap)
|
|
- fmt.Println("taskIds", taskIds)
|
|
|
|
|
|
+ //fmt.Println("taskIds", taskIds)
|
|
var logisticInfos []gorm_model.YoungeeTaskLogistics
|
|
var logisticInfos []gorm_model.YoungeeTaskLogistics
|
|
db3 := GetReadDB(context.Background())
|
|
db3 := GetReadDB(context.Background())
|
|
err = db3.Model(gorm_model.YoungeeTaskLogistics{}).Where("auto_sign_at <= ? AND task_id IN ?", time.Now(), taskIds).Find(&logisticInfos).Error
|
|
err = db3.Model(gorm_model.YoungeeTaskLogistics{}).Where("auto_sign_at <= ? AND task_id IN ?", time.Now(), taskIds).Find(&logisticInfos).Error
|
|
@@ -275,7 +275,7 @@ func GetSignInOfflineTask(projectForm int32) error {
|
|
log.Println("DB AutoGetSignInOfflineTask error :", err)
|
|
log.Println("DB AutoGetSignInOfflineTask error :", err)
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
- var signedTaskId []int
|
|
|
|
|
|
+ var signedTaskId []int64
|
|
for _, logisticInfo := range logisticInfos {
|
|
for _, logisticInfo := range logisticInfos {
|
|
signedTaskId = append(signedTaskId, logisticInfo.TaskID)
|
|
signedTaskId = append(signedTaskId, logisticInfo.TaskID)
|
|
if logisticInfo.SignedTime.IsZero() {
|
|
if logisticInfo.SignedTime.IsZero() {
|
|
@@ -284,19 +284,19 @@ func GetSignInOfflineTask(projectForm int32) error {
|
|
fmt.Println("已更新签收时间")
|
|
fmt.Println("已更新签收时间")
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- util.RemoveIntRepByMap(signedTaskId)
|
|
|
|
|
|
+ util.RemoveRepByMap(signedTaskId)
|
|
//fmt.Println("signedTaskId", signedTaskId)
|
|
//fmt.Println("signedTaskId", signedTaskId)
|
|
for _, taskID := range signedTaskId {
|
|
for _, taskID := range signedTaskId {
|
|
//fmt.Println("taskID", taskID)
|
|
//fmt.Println("taskID", taskID)
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
taskNeedMod := gorm_model.YoungeeTaskInfo{}
|
|
taskNeedMod := gorm_model.YoungeeTaskInfo{}
|
|
db4.Model(gorm_model.YoungeeTaskInfo{}).Where("task_id = ?", taskID).Find(&taskNeedMod)
|
|
db4.Model(gorm_model.YoungeeTaskInfo{}).Where("task_id = ?", taskID).Find(&taskNeedMod)
|
|
- if projectIdMap[int64(taskIDs[taskID])] == 1 {
|
|
|
|
|
|
+ if projectIdMap[int64(taskIDs[int(taskID)])] == 1 {
|
|
if taskNeedMod.LogisticsStatus == 2 && taskNeedMod.TaskStage == 5 {
|
|
if taskNeedMod.LogisticsStatus == 2 && taskNeedMod.TaskStage == 5 {
|
|
db4.Model(gorm_model.YoungeeTaskInfo{}).Where("task_id = ?", taskID).Updates(&gorm_model.YoungeeTaskInfo{LogisticsStatus: 3, TaskStage: 9})
|
|
db4.Model(gorm_model.YoungeeTaskInfo{}).Where("task_id = ?", taskID).Updates(&gorm_model.YoungeeTaskInfo{LogisticsStatus: 3, TaskStage: 9})
|
|
fmt.Println("内容形式为图片的项目 已修改任务状态为待传初稿 及物流状态为已签收")
|
|
fmt.Println("内容形式为图片的项目 已修改任务状态为待传初稿 及物流状态为已签收")
|
|
}
|
|
}
|
|
- } else if projectIdMap[int64(taskIDs[taskID])] == 2 {
|
|
|
|
|
|
+ } else if projectIdMap[int64(taskIDs[int(taskID)])] == 2 {
|
|
if taskNeedMod.LogisticsStatus == 2 && taskNeedMod.TaskStage == 5 {
|
|
if taskNeedMod.LogisticsStatus == 2 && taskNeedMod.TaskStage == 5 {
|
|
db4.Model(gorm_model.YoungeeTaskInfo{}).Where("task_id = ?", taskID).Updates(&gorm_model.YoungeeTaskInfo{LogisticsStatus: 3, TaskStage: 7})
|
|
db4.Model(gorm_model.YoungeeTaskInfo{}).Where("task_id = ?", taskID).Updates(&gorm_model.YoungeeTaskInfo{LogisticsStatus: 3, TaskStage: 7})
|
|
fmt.Println("内容形式为视频的项目 已修改任务状态为待传脚本 及物流状态为已签收")
|
|
fmt.Println("内容形式为视频的项目 已修改任务状态为待传脚本 及物流状态为已签收")
|
|
@@ -318,7 +318,7 @@ func GetAutoReviewTask(contentType int32) error {
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
for _, projectInfo := range projectInfos {
|
|
for _, projectInfo := range projectInfos {
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
- projectIdToAutoTaskIdMap[projectInfo.ProjectID] = projectInfo.AutoTaskID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[projectInfo.ProjectID] = int(projectInfo.AutoTaskID)
|
|
}
|
|
}
|
|
//fmt.Println("projectIds:", projectIds)
|
|
//fmt.Println("projectIds:", projectIds)
|
|
TaskIdToProjectId := make(map[int]int)
|
|
TaskIdToProjectId := make(map[int]int)
|
|
@@ -374,7 +374,7 @@ func GetAutoReviewTask(contentType int32) error {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- fmt.Println("scriptTaskIds:", scriptTaskIds)
|
|
|
|
|
|
+ //fmt.Println("scriptTaskIds:", scriptTaskIds)
|
|
for _, scriptTaskId := range scriptTaskIds {
|
|
for _, scriptTaskId := range scriptTaskIds {
|
|
//fmt.Println("scriptTaskId", scriptTaskId)
|
|
//fmt.Println("scriptTaskId", scriptTaskId)
|
|
taskStatusNeedMod := gorm_model.YoungeeTaskInfo{}
|
|
taskStatusNeedMod := gorm_model.YoungeeTaskInfo{}
|
|
@@ -396,7 +396,7 @@ func GetAutoReviewTask(contentType int32) error {
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
for _, projectInfo := range projectInfos {
|
|
for _, projectInfo := range projectInfos {
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
- projectIdToAutoTaskIdMap[projectInfo.ProjectID] = projectInfo.AutoTaskID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[projectInfo.ProjectID] = int(projectInfo.AutoTaskID)
|
|
}
|
|
}
|
|
//fmt.Println("projectIds:", projectIds)
|
|
//fmt.Println("projectIds:", projectIds)
|
|
TaskIdToProjectId := make(map[int]int)
|
|
TaskIdToProjectId := make(map[int]int)
|
|
@@ -476,7 +476,7 @@ func GetAutoPostReviewTask() error {
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
for _, projectInfo := range projectInfos {
|
|
for _, projectInfo := range projectInfos {
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
- projectIdToAutoTaskIdMap[projectInfo.ProjectID] = projectInfo.AutoTaskID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[projectInfo.ProjectID] = int(projectInfo.AutoTaskID)
|
|
}
|
|
}
|
|
//fmt.Println("projectIds:", projectIds)
|
|
//fmt.Println("projectIds:", projectIds)
|
|
TaskIdToProjectId := make(map[int]int)
|
|
TaskIdToProjectId := make(map[int]int)
|
|
@@ -551,7 +551,7 @@ func GetAutoCaseCloseTask() error {
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
for _, projectInfo := range projectInfos {
|
|
for _, projectInfo := range projectInfos {
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
- projectIdToAutoTaskIdMap[projectInfo.ProjectID] = projectInfo.AutoTaskID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[projectInfo.ProjectID] = int(projectInfo.AutoTaskID)
|
|
}
|
|
}
|
|
//fmt.Println("projectIds:", projectIds)
|
|
//fmt.Println("projectIds:", projectIds)
|
|
TaskIdToProjectId := make(map[int]int)
|
|
TaskIdToProjectId := make(map[int]int)
|
|
@@ -625,7 +625,7 @@ func GetAutoInvalidTask() error {
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
projectIdToAutoTaskIdMap := map[int64]int{}
|
|
for _, projectInfo := range projectInfos {
|
|
for _, projectInfo := range projectInfos {
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
- projectIdToAutoTaskIdMap[projectInfo.ProjectID] = projectInfo.AutoTaskID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[projectInfo.ProjectID] = int(projectInfo.AutoTaskID)
|
|
}
|
|
}
|
|
for _, projectId := range projectIds {
|
|
for _, projectId := range projectIds {
|
|
// 获取 autoTaskId 及其对应的限制时间、
|
|
// 获取 autoTaskId 及其对应的限制时间、
|
|
@@ -639,8 +639,9 @@ func GetAutoInvalidTask() error {
|
|
db1.Model(gorm_model.ProjectInfo{}).Where("project_id = ?", projectId).First(&project)
|
|
db1.Model(gorm_model.ProjectInfo{}).Where("project_id = ?", projectId).First(&project)
|
|
if project.AutoFailAt.IsZero() {
|
|
if project.AutoFailAt.IsZero() {
|
|
dd, _ := time.ParseDuration(conv.MustString(Invalid, "") + "h")
|
|
dd, _ := time.ParseDuration(conv.MustString(Invalid, "") + "h")
|
|
|
|
+ t := project.RecruitDdl.Add(dd)
|
|
db2 := GetReadDB(context.Background())
|
|
db2 := GetReadDB(context.Background())
|
|
- db2.Model(gorm_model.ProjectInfo{}).Where("project_id = ?", projectId).Updates(&gorm_model.ProjectInfo{AutoFailAt: project.RecruitDdl.Add(dd)})
|
|
|
|
|
|
+ db2.Model(gorm_model.ProjectInfo{}).Where("project_id = ?", projectId).Updates(&gorm_model.ProjectInfo{AutoFailAt: &t})
|
|
fmt.Println("已添加失效自动处理时间")
|
|
fmt.Println("已添加失效自动处理时间")
|
|
}
|
|
}
|
|
projectNeedMod := gorm_model.ProjectInfo{}
|
|
projectNeedMod := gorm_model.ProjectInfo{}
|
|
@@ -691,15 +692,16 @@ func GetAutoDraftDefaultInPicTask() error {
|
|
var DraftDefaultInPic int32
|
|
var DraftDefaultInPic int32
|
|
dbStart.Model(gorm_model.InfoAutoTask{}).Select("draft_default_in_pic").Where("auto_task_id = ?", specialProjectInfo.AutoTaskID).First(&DraftDefaultInPic)
|
|
dbStart.Model(gorm_model.InfoAutoTask{}).Select("draft_default_in_pic").Where("auto_task_id = ?", specialProjectInfo.AutoTaskID).First(&DraftDefaultInPic)
|
|
dd, _ := time.ParseDuration(conv.MustString(DraftDefaultInPic, "") + "h")
|
|
dd, _ := time.ParseDuration(conv.MustString(DraftDefaultInPic, "") + "h")
|
|
|
|
+ t1 := projectInfo.PayAt.Add(dd)
|
|
if !projectInfo.PayAt.IsZero() && projectInfo.AutoSketchBreakAt.IsZero() {
|
|
if !projectInfo.PayAt.IsZero() && projectInfo.AutoSketchBreakAt.IsZero() {
|
|
- db1.Model(gorm_model.ProjectInfo{}).Where("project_id = ?", projectInfo.ProjectID).Updates(&gorm_model.ProjectInfo{AutoSketchBreakAt: projectInfo.PayAt.Add(dd)})
|
|
|
|
|
|
+ db1.Model(gorm_model.ProjectInfo{}).Where("project_id = ?", projectInfo.ProjectID).Updates(&gorm_model.ProjectInfo{AutoSketchBreakAt: &t1})
|
|
fmt.Println("已添加素材微原创的初稿违约自动处理时间")
|
|
fmt.Println("已添加素材微原创的初稿违约自动处理时间")
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
projectIds = append(projectIds, projectInfo.ProjectID)
|
|
}
|
|
}
|
|
- projectIdToAutoTaskIdMap[projectInfo.ProjectID] = projectInfo.AutoTaskID
|
|
|
|
- projectIdToAutoDefaultIdMap[projectInfo.ProjectID] = projectInfo.AutoDefaultID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[projectInfo.ProjectID] = int(projectInfo.AutoTaskID)
|
|
|
|
+ projectIdToAutoDefaultIdMap[projectInfo.ProjectID] = int(projectInfo.AutoDefaultID)
|
|
}
|
|
}
|
|
//fmt.Println("projectIds:", projectIds)
|
|
//fmt.Println("projectIds:", projectIds)
|
|
//fmt.Println("specialProjectIds:", specialProjectIds)
|
|
//fmt.Println("specialProjectIds:", specialProjectIds)
|
|
@@ -738,7 +740,7 @@ func GetAutoDraftDefaultInPicTask() error {
|
|
if projectNeedMod.AutoSketchBreakAt.Sub(time.Now()) <= 0 && !projectNeedMod.AutoSketchBreakAt.IsZero() {
|
|
if projectNeedMod.AutoSketchBreakAt.Sub(time.Now()) <= 0 && !projectNeedMod.AutoSketchBreakAt.IsZero() {
|
|
db2 := GetReadDB(context.Background())
|
|
db2 := GetReadDB(context.Background())
|
|
err1 := db2.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db2.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: specialTaskNeedModId, BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: specialTaskNeedModId, ProjectID: TaskIdToProjectId[specialTaskNeedModId], BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -811,7 +813,7 @@ func GetAutoDraftDefaultInPicTask() error {
|
|
if !taskLogisticNeedMod2.AutoSketchBreakAt.IsZero() && taskLogisticNeedMod2.AutoSketchBreakAt.Sub(time.Now()) <= 0 {
|
|
if !taskLogisticNeedMod2.AutoSketchBreakAt.IsZero() && taskLogisticNeedMod2.AutoSketchBreakAt.Sub(time.Now()) <= 0 {
|
|
db5 := GetReadDB(context.Background())
|
|
db5 := GetReadDB(context.Background())
|
|
err1 := db5.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db5.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: taskNeedModId, BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: taskNeedModId, ProjectID: TaskIdToProjectId[taskNeedModId], BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -845,7 +847,7 @@ func GetAutoDraftDefaultInPicTask() error {
|
|
if taskSketchInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskSketchInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitTaskNeedModId, BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitTaskNeedModId, ProjectID: TaskIdToProjectId[submitTaskNeedModId], BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -860,7 +862,7 @@ func GetAutoDraftDefaultInPicTask() error {
|
|
if taskSketchInfo.AutoSketchBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskSketchInfo.AutoSketchBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitTaskNeedModId, BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitTaskNeedModId, ProjectID: TaskIdToProjectId[submitTaskNeedModId], BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -897,8 +899,8 @@ func GetAutoDraftDefaultInMvTask() error {
|
|
db2 := GetReadDB(context.Background())
|
|
db2 := GetReadDB(context.Background())
|
|
autoIds := gorm_model.ProjectInfo{}
|
|
autoIds := gorm_model.ProjectInfo{}
|
|
db2.Select([]string{"auto_task_id", "auto_default_id"}).Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", VideoProjectId).First(&autoIds)
|
|
db2.Select([]string{"auto_task_id", "auto_default_id"}).Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", VideoProjectId).First(&autoIds)
|
|
- projectIdToAutoTaskIdMap[VideoProjectId] = autoIds.AutoTaskID
|
|
|
|
- projectIdToAutoDefaultIdMap[VideoProjectId] = autoIds.AutoDefaultID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[VideoProjectId] = int(autoIds.AutoTaskID)
|
|
|
|
+ projectIdToAutoDefaultIdMap[VideoProjectId] = int(autoIds.AutoDefaultID)
|
|
|
|
|
|
var videoTaskInfos []*gorm_model.YoungeeTaskInfo
|
|
var videoTaskInfos []*gorm_model.YoungeeTaskInfo
|
|
db1 := GetReadDB(context.Background())
|
|
db1 := GetReadDB(context.Background())
|
|
@@ -953,7 +955,7 @@ func GetAutoDraftDefaultInMvTask() error {
|
|
if taskScriptInfo.AutoAgreeAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskScriptInfo.AutoAgreeAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: videoTaskNeedModId, BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: videoTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[videoTaskNeedModId]), BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -968,7 +970,7 @@ func GetAutoDraftDefaultInMvTask() error {
|
|
if taskScriptInfo.AutoSketchBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskScriptInfo.AutoSketchBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: videoTaskNeedModId, BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: videoTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[videoTaskNeedModId]), BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1006,7 +1008,7 @@ func GetAutoDraftDefaultInMvTask() error {
|
|
if taskSketchInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskSketchInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitVideoTaskNeedModId, BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitVideoTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[submitVideoTaskNeedModId]), BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1021,7 +1023,7 @@ func GetAutoDraftDefaultInMvTask() error {
|
|
if taskSketchInfo.AutoSketchBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskSketchInfo.AutoSketchBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitVideoTaskNeedModId, BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitVideoTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[submitVideoTaskNeedModId]), BreakType: 2, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1069,15 +1071,16 @@ func GetAutoScriptDefaultTask() error {
|
|
db2 := GetReadDB(context.Background())
|
|
db2 := GetReadDB(context.Background())
|
|
var projectInfo gorm_model.ProjectInfo
|
|
var projectInfo gorm_model.ProjectInfo
|
|
db2.Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", specialProjectId).First(&projectInfo)
|
|
db2.Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", specialProjectId).First(&projectInfo)
|
|
- projectIdToAutoTaskIdMap[int64(specialProjectId)] = projectInfo.AutoTaskID
|
|
|
|
- projectIdToAutoDefaultIdMap[int64(specialProjectId)] = projectInfo.AutoDefaultID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[int64(specialProjectId)] = int(projectInfo.AutoTaskID)
|
|
|
|
+ projectIdToAutoDefaultIdMap[int64(specialProjectId)] = int(projectInfo.AutoDefaultID)
|
|
var ScriptDefault int32
|
|
var ScriptDefault int32
|
|
dbStart := GetReadDB(context.Background())
|
|
dbStart := GetReadDB(context.Background())
|
|
dbStart.Model(gorm_model.InfoAutoTask{}).Select("script_default").Where("auto_task_id = ?", projectInfo.AutoTaskID).First(&ScriptDefault)
|
|
dbStart.Model(gorm_model.InfoAutoTask{}).Select("script_default").Where("auto_task_id = ?", projectInfo.AutoTaskID).First(&ScriptDefault)
|
|
dd, _ := time.ParseDuration(conv.MustString(ScriptDefault, "") + "h")
|
|
dd, _ := time.ParseDuration(conv.MustString(ScriptDefault, "") + "h")
|
|
|
|
+ t3 := projectInfo.PayAt.Add(dd)
|
|
if !projectInfo.PayAt.IsZero() && projectInfo.AutoScriptBreakAt.IsZero() {
|
|
if !projectInfo.PayAt.IsZero() && projectInfo.AutoScriptBreakAt.IsZero() {
|
|
db1 := GetReadDB(context.Background())
|
|
db1 := GetReadDB(context.Background())
|
|
- db1.Model(gorm_model.ProjectInfo{}).Where("project_id = ?", projectInfo.ProjectID).Updates(&gorm_model.ProjectInfo{AutoScriptBreakAt: projectInfo.PayAt.Add(dd)})
|
|
|
|
|
|
+ db1.Model(gorm_model.ProjectInfo{}).Where("project_id = ?", projectInfo.ProjectID).Updates(&gorm_model.ProjectInfo{AutoScriptBreakAt: &t3})
|
|
fmt.Println("已添加素材微原创的脚本违约自动处理时间")
|
|
fmt.Println("已添加素材微原创的脚本违约自动处理时间")
|
|
}
|
|
}
|
|
var videoTaskInfos []*gorm_model.YoungeeTaskInfo
|
|
var videoTaskInfos []*gorm_model.YoungeeTaskInfo
|
|
@@ -1117,7 +1120,7 @@ func GetAutoScriptDefaultTask() error {
|
|
}
|
|
}
|
|
db2 := GetReadDB(context.Background())
|
|
db2 := GetReadDB(context.Background())
|
|
err1 := db2.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db2.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: specialTaskNeedModId, BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: specialTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[specialTaskNeedModId]), BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1180,7 +1183,7 @@ func GetAutoScriptDefaultTask() error {
|
|
if taskLogisticInfo.AutoSignAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskLogisticInfo.AutoSignAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: videoTaskNeedModId, BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: videoTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[videoTaskNeedModId]), BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1195,7 +1198,7 @@ func GetAutoScriptDefaultTask() error {
|
|
if taskLogisticInfo.AutoScriptBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskLogisticInfo.AutoScriptBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: videoTaskNeedModId, BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: videoTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[videoTaskNeedModId]), BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1234,7 +1237,7 @@ func GetAutoScriptDefaultTask() error {
|
|
if taskScriptInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskScriptInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitVideoTaskNeedModId, BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitVideoTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[submitVideoTaskNeedModId]), BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1250,7 +1253,7 @@ func GetAutoScriptDefaultTask() error {
|
|
if taskScriptInfo.AutoScriptBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskScriptInfo.AutoScriptBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitVideoTaskNeedModId, BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitVideoTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[submitVideoTaskNeedModId]), BreakType: 1, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1288,8 +1291,8 @@ func GetAutoLinkBreachTask() error {
|
|
db2 := GetReadDB(context.Background())
|
|
db2 := GetReadDB(context.Background())
|
|
autoIds := gorm_model.ProjectInfo{}
|
|
autoIds := gorm_model.ProjectInfo{}
|
|
db2.Select([]string{"auto_task_id", "auto_default_id"}).Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", projectId).First(&autoIds)
|
|
db2.Select([]string{"auto_task_id", "auto_default_id"}).Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", projectId).First(&autoIds)
|
|
- projectIdToAutoTaskIdMap[projectId] = autoIds.AutoTaskID
|
|
|
|
- projectIdToAutoDefaultIdMap[projectId] = autoIds.AutoDefaultID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[projectId] = int(autoIds.AutoTaskID)
|
|
|
|
+ projectIdToAutoDefaultIdMap[projectId] = int(autoIds.AutoDefaultID)
|
|
var taskInfos []*gorm_model.YoungeeTaskInfo
|
|
var taskInfos []*gorm_model.YoungeeTaskInfo
|
|
db1 := GetReadDB(context.Background())
|
|
db1 := GetReadDB(context.Background())
|
|
db1.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND cur_default_type = ? ", projectId, 0).Find(&taskInfos)
|
|
db1.Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND cur_default_type = ? ", projectId, 0).Find(&taskInfos)
|
|
@@ -1342,7 +1345,7 @@ func GetAutoLinkBreachTask() error {
|
|
if taskSketchInfo.AutoAgreeAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskSketchInfo.AutoAgreeAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: taskNeedModId, BreakType: 3, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: taskNeedModId, ProjectID: int(taskIdToProjectIdMap[taskNeedModId]), BreakType: 3, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1357,7 +1360,7 @@ func GetAutoLinkBreachTask() error {
|
|
if taskSketchInfo.AutoLinkBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskSketchInfo.AutoLinkBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: taskNeedModId, BreakType: 3, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: taskNeedModId, ProjectID: int(taskIdToProjectIdMap[taskNeedModId]), BreakType: 3, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1396,7 +1399,7 @@ func GetAutoLinkBreachTask() error {
|
|
if taskLinkInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskLinkInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitTaskNeedModId, BreakType: 3, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[submitTaskNeedModId]), BreakType: 3, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1411,7 +1414,7 @@ func GetAutoLinkBreachTask() error {
|
|
if taskLinkInfo.AutoLinkBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskLinkInfo.AutoLinkBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitTaskNeedModId, BreakType: 3, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[submitTaskNeedModId]), BreakType: 3, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1446,8 +1449,8 @@ func GetAutoCaseCloseDefaultTask() error {
|
|
db2 := GetReadDB(context.Background())
|
|
db2 := GetReadDB(context.Background())
|
|
autoIds := gorm_model.ProjectInfo{}
|
|
autoIds := gorm_model.ProjectInfo{}
|
|
db2.Select([]string{"auto_task_id", "auto_default_id"}).Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", projectId).First(&autoIds)
|
|
db2.Select([]string{"auto_task_id", "auto_default_id"}).Model(&gorm_model.ProjectInfo{}).Where("project_id = ?", projectId).First(&autoIds)
|
|
- projectIdToAutoTaskIdMap[projectId] = autoIds.AutoTaskID
|
|
|
|
- projectIdToAutoDefaultIdMap[projectId] = autoIds.AutoDefaultID
|
|
|
|
|
|
+ projectIdToAutoTaskIdMap[projectId] = int(autoIds.AutoTaskID)
|
|
|
|
+ projectIdToAutoDefaultIdMap[projectId] = int(autoIds.AutoDefaultID)
|
|
var taskInfos []int32
|
|
var taskInfos []int32
|
|
db1 := GetReadDB(context.Background())
|
|
db1 := GetReadDB(context.Background())
|
|
db1.Select("task_id").Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND cur_default_type = ? ", projectId, 0).Find(&taskInfos)
|
|
db1.Select("task_id").Model(&gorm_model.YoungeeTaskInfo{}).Where("project_id = ? AND cur_default_type = ? ", projectId, 0).Find(&taskInfos)
|
|
@@ -1506,7 +1509,7 @@ func GetAutoCaseCloseDefaultTask() error {
|
|
if taskLinkInfo.AutoAgreeAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskLinkInfo.AutoAgreeAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: taskNeedModId, BreakType: 4, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: taskNeedModId, ProjectID: int(taskIdToProjectIdMap[taskNeedModId]), BreakType: 4, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1521,7 +1524,7 @@ func GetAutoCaseCloseDefaultTask() error {
|
|
if taskLinkInfo.AutoDataBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskLinkInfo.AutoDataBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: taskNeedModId, BreakType: 4, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: taskNeedModId, ProjectID: int(taskIdToProjectIdMap[taskNeedModId]), BreakType: 4, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1560,7 +1563,7 @@ func GetAutoCaseCloseDefaultTask() error {
|
|
if taskDataInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
if taskDataInfo.RejectAt.Add(dd).Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitTaskNeedModId, BreakType: 4, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[submitTaskNeedModId]), BreakType: 4, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|
|
@@ -1575,7 +1578,7 @@ func GetAutoCaseCloseDefaultTask() error {
|
|
if taskDataInfo.AutoDataBreakAt.Sub(time.Now()) <= 0 {
|
|
if taskDataInfo.AutoDataBreakAt.Sub(time.Now()) <= 0 {
|
|
db4 := GetReadDB(context.Background())
|
|
db4 := GetReadDB(context.Background())
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
err1 := db4.Model(gorm_model.YoungeeContractInfo{}).Create(&gorm_model.YoungeeContractInfo{
|
|
- TaskID: submitTaskNeedModId, BreakType: 4, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
|
|
|
|
+ TaskID: submitTaskNeedModId, ProjectID: int(taskIdToProjectIdMap[submitTaskNeedModId]), BreakType: 4, BreakAt: time.Now(), DefaultStatus: 1}).Error
|
|
if err1 != nil {
|
|
if err1 != nil {
|
|
return err1
|
|
return err1
|
|
}
|
|
}
|