1
|
package notify
|
1
|
package notify
|
2
|
|
2
|
|
3
|
import (
|
3
|
import (
|
|
|
4
|
+ "time"
|
|
|
5
|
+
|
4
|
"github.com/linmadan/egglib-go/core/application"
|
6
|
"github.com/linmadan/egglib-go/core/application"
|
5
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/factory"
|
7
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/factory"
|
6
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/notify/command"
|
8
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/notify/command"
|
|
|
9
|
+ "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
|
7
|
)
|
10
|
)
|
8
|
|
11
|
|
9
|
// 个人信息提示
|
12
|
// 个人信息提示
|
|
@@ -28,8 +31,19 @@ func (srv *MessagePersonalService) TodayMessageSummaryEvaluationSelf(param *comm |
|
@@ -28,8 +31,19 @@ func (srv *MessagePersonalService) TodayMessageSummaryEvaluationSelf(param *comm |
28
|
defer func() {
|
31
|
defer func() {
|
29
|
_ = transactionContext.RollbackTransaction()
|
32
|
_ = transactionContext.RollbackTransaction()
|
30
|
}()
|
33
|
}()
|
31
|
- // nowTime := time.Now()
|
|
|
32
|
|
34
|
|
|
|
35
|
+ nowTime := time.Now()
|
|
|
36
|
+ evaluationRepo := factory.CreateSummaryEvaluationRepository(map[string]interface{}{
|
|
|
37
|
+ "transactionContext": transactionContext,
|
|
|
38
|
+ })
|
|
|
39
|
+ _, evaluationList, err := evaluationRepo.Find(map[string]interface{}{
|
|
|
40
|
+ "targetUserId": param.UserId,
|
|
|
41
|
+ "types": domain.EvaluationSelf,
|
|
|
42
|
+ "beginTime": nowTime,
|
|
|
43
|
+ "endTime": nowTime,
|
|
|
44
|
+ "limit": 20,
|
|
|
45
|
+ })
|
|
|
46
|
+ _ = evaluationList
|
33
|
if err := transactionContext.CommitTransaction(); err != nil {
|
47
|
if err := transactionContext.CommitTransaction(); err != nil {
|
34
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
48
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
35
|
}
|
49
|
}
|