作者 tangxvhui

暂存

... ... @@ -36,14 +36,6 @@ func (srv StaffAssessServeice) SearchAssessTaskMeV2(param *query.SearchAssessMeQ
limit = param.PageSize
}
offset = (param.PageNumber - 1) * param.PageSize
// assessCycleList, err := staffAssessTaskRepo.SearchAssessCycleMe(param.UserId, param.CompanyId, limit, offset)
// if err != nil {
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "查询评估周期"+err.Error())
// }
// cnt, err := staffAssessTaskRepo.CountAssessTaskMe(param.UserId, param.CompanyId)
// if err != nil {
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "查询评估周期"+err.Error())
// }
assessCycleList, cnt, err := staffAssessDao.SearchExecutorAssessBeforeNow(param.UserId, param.CompanyId, limit, offset)
if err != nil {
... ...
... ... @@ -20,7 +20,7 @@ func TaskSendSummaryEvaluationV2() error {
}()
var newPublisher summaryEvaluationPublisher
for {
projectList, err := sendSummaryEvaluationV2()
projectList, err := getPrepareSummaryEvaluation()
if err != nil {
return err
}
... ... @@ -36,7 +36,7 @@ func TaskSendSummaryEvaluationV2() error {
return nil
}
func sendSummaryEvaluationV2() ([]*domain.EvaluationProject, error) {
func getPrepareSummaryEvaluation() ([]*domain.EvaluationProject, error) {
transactionContext, err := factory.CreateTransactionContext(nil)
if err != nil {
return nil, err
... ... @@ -55,7 +55,7 @@ func sendSummaryEvaluationV2() ([]*domain.EvaluationProject, error) {
"endTime": time.Now(),
"summaryState": domain.ProjectSummaryStateNo,
"state": domain.ProjectStateEnable,
"limit": 500,
"limit": 200,
}, "template")
if err != nil {
return nil, fmt.Errorf("获取可用的项目数据,%s", err)
... ...