sms_summary_evaluation.go
2.2 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
package notify
import (
"time"
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/factory"
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
)
// 周期评估短信通知
// 条件:周期自评结束前4个小时,且还未完成评估填写
type notifySummaryEvaluation struct {
}
func (notices notifySummaryEvaluation) from() string {
return "SummaryEvaluation"
}
// makeNotify 生成待执行的短信通知内容
func (notices notifySummaryEvaluation) makeNotify(param *domain.SummaryEvaluation) *domain.LogSms {
newSms := domain.LogSms{
Id: 0,
Phone: param.Executor.Account,
TemplateId: 5536232,
Template: "您好,#name#,百忙之中不要忘记填写本月综合自评哦",
Value: map[string]string{
"name": param.Executor.UserName,
},
Result: "",
Status: domain.SmsWait,
From: notices.from(),
Index: param.Id,
// ExecuteAt: executeAt,
CreatedAt: time.Now(),
}
// 周期自评结束前4个小时,
// newSms.ExecuteAt = param.EndTime.Add(-4 * time.Hour)
//改为 固定在截止时间 那天的 前一天晚上10
y, m, d := param.EndTime.Local().Date()
dayTime := time.Date(y, m, d, 0, 0, 0, 0, time.Local)
newSms.ExecuteAt = dayTime.Add(-2 * time.Hour)
return &newSms
}
// ifSend 确认是否发送通知
func (notices notifySummaryEvaluation) ifSend(index int) (bool, error) {
nowDay := time.Now().Weekday()
if nowDay == time.Sunday || nowDay == time.Saturday {
//周末不发
return false, nil
}
transactionContext, err := factory.CreateTransactionContext(nil)
if err != nil {
return false, err
}
if err := transactionContext.StartTransaction(); err != nil {
return false, err
}
defer func() {
_ = transactionContext.RollbackTransaction()
}()
summaryEvaluationRepo := factory.CreateSummaryEvaluationRepository(map[string]interface{}{"transactionContext": transactionContext})
summaryEvaluationData, err := summaryEvaluationRepo.FindOne(map[string]interface{}{"id": index})
if err != nil {
return false, err
}
//还未完成评估填写,时发送短信
if summaryEvaluationData.Status == domain.EvaluationUncompleted {
return true, nil
}
if err := transactionContext.CommitTransaction(); err != nil {
return false, err
}
return false, nil
}