...
|
...
|
@@ -861,18 +861,14 @@ func (srv TaskService) ReplyTaskStage(transactionContext application.Transaction |
|
|
}
|
|
|
|
|
|
//改为定时检查每日任务反馈,并计算反馈异常数
|
|
|
// for _, val2 := range stageList {
|
|
|
// if val2.Id != val.TaskStageCheck.Id {
|
|
|
// continue
|
|
|
// }
|
|
|
// val2.RealCompletedAt = val.TaskStageCheck.RealCompletedAt
|
|
|
// if val2.PlanCompletedAt < val2.RealCompletedAt {
|
|
|
// taskData.WarnFlag = 1
|
|
|
// } else {
|
|
|
// taskData.WarnFlag = 0
|
|
|
// }
|
|
|
// break
|
|
|
// }
|
|
|
//这边仅记录 里程碑的完成情况
|
|
|
for _, val2 := range stageList {
|
|
|
if val2.Id != val.TaskStageCheck.Id {
|
|
|
continue
|
|
|
}
|
|
|
val2.RealCompletedAt = val.TaskStageCheck.RealCompletedAt
|
|
|
break
|
|
|
}
|
|
|
err = taskStageRepo.Save(stageList)
|
|
|
if err != nil {
|
|
|
return application.ThrowError(application.INTERNAL_SERVER_ERROR, "保存任务里程碑数据"+err.Error())
|
...
|
...
|
@@ -966,9 +962,7 @@ func (srv TaskService) ListTaskRecord(param *command.ListTaskRecordCommand) (map |
|
|
//}
|
|
|
resultList = append(resultList, item)
|
|
|
}
|
|
|
//if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
//}
|
|
|
|
|
|
result := tool_funs.SimpleWrapGridMap(int64(cnt), resultList)
|
|
|
return result, nil
|
|
|
}
|
...
|
...
|
|