|
@@ -110,11 +110,12 @@ func (notices *notifySms) checkSendSms() error { |
|
@@ -110,11 +110,12 @@ func (notices *notifySms) checkSendSms() error { |
110
|
}()
|
110
|
}()
|
111
|
logSmsRepo := factory.CreateLogSmsRepository(map[string]interface{}{"transactionContext": transactionContext})
|
111
|
logSmsRepo := factory.CreateLogSmsRepository(map[string]interface{}{"transactionContext": transactionContext})
|
112
|
nowTime := time.Now()
|
112
|
nowTime := time.Now()
|
113
|
- // nowDay := dayZeroTime(nowTime)
|
113
|
+ nowDay := dayZeroTime(nowTime)
|
114
|
_, logSmsList, err := logSmsRepo.Find(map[string]interface{}{
|
114
|
_, logSmsList, err := logSmsRepo.Find(map[string]interface{}{
|
115
|
- "status": string(domain.SmsWait),
|
|
|
116
|
- "executeAtEnd": nowTime,
|
|
|
117
|
- "limit": 1000,
|
115
|
+ "status": string(domain.SmsWait),
|
|
|
116
|
+ "executeAtEnd": nowTime,
|
|
|
117
|
+ "executeAtBegin": nowDay,
|
|
|
118
|
+ "limit": 1000,
|
118
|
})
|
119
|
})
|
119
|
if err != nil {
|
120
|
if err != nil {
|
120
|
return err
|
121
|
return err
|