|
@@ -138,14 +138,15 @@ func SendEmailFileToExpert() (err error) {
|
|
}
|
|
}
|
|
}()
|
|
}()
|
|
fmt.Println("发送附件")
|
|
fmt.Println("发送附件")
|
|
- endDate := time.Now().Add(-time.Minute * 6000000).Format("2006-01-02 15:04:05")
|
|
|
|
|
|
+ endDate := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05")
|
|
total, err := models.GetCountActivityIdToSendFile(endDate)
|
|
total, err := models.GetCountActivityIdToSendFile(endDate)
|
|
- if err != nil {
|
|
|
|
- msg = "发送附件模版消息失败 Err:" + err.Error()
|
|
|
|
- return
|
|
|
|
- }
|
|
|
|
|
|
+
|
|
if total == 0 {
|
|
if total == 0 {
|
|
fmt.Println("发送附件完成0")
|
|
fmt.Println("发送附件完成0")
|
|
|
|
+ return nil
|
|
|
|
+ }
|
|
|
|
+ if err != nil {
|
|
|
|
+ msg = "发送附件模版消息失败 Err:" + err.Error()
|
|
return
|
|
return
|
|
}
|
|
}
|
|
listActivity, err := models.GetActivityIdToSendFile(endDate)
|
|
listActivity, err := models.GetActivityIdToSendFile(endDate)
|
|
@@ -228,7 +229,7 @@ func SendEmailFileToExpert() (err error) {
|
|
defer func() {
|
|
defer func() {
|
|
os.Remove(downLoadnFilePath)
|
|
os.Remove(downLoadnFilePath)
|
|
}()
|
|
}()
|
|
- time.Sleep(time.Duration(2) * time.Second)
|
|
|
|
|
|
+ time.Sleep(time.Duration(2) * time.Second) //延迟两秒,避免过多活动的时候邮件发送没有内容
|
|
errFile = models.UPdateActivityIdToSendFile(v.ActivityId)
|
|
errFile = models.UPdateActivityIdToSendFile(v.ActivityId)
|
|
if errFile != nil {
|
|
if errFile != nil {
|
|
msg = "获取失败,Err:" + errFile.Error()
|
|
msg = "获取失败,Err:" + errFile.Error()
|