|
@@ -131,7 +131,9 @@ func (l *CronTask) analyze() {
|
|
|
predicates = append(predicates, usagedetail.AppIn(1, 3, 4, 5))
|
|
|
//yesterdayStart := time.Now().AddDate(0, 0, -1).Truncate(24 * time.Hour)
|
|
|
//yesterdayEnd := yesterdayStart.Add(24 * time.Hour)
|
|
|
- yesterdayEnd := time.Now().Truncate(24 * time.Hour)
|
|
|
+ loc, _ := time.LoadLocation("Asia/Shanghai")
|
|
|
+ now := time.Now().In(loc)
|
|
|
+ yesterdayEnd := now.Truncate(24 * time.Hour)
|
|
|
yesterdayStart := yesterdayEnd.AddDate(0, 0, -1)
|
|
|
predicates = append(predicates, usagedetail.CreatedAtGTE(yesterdayStart))
|
|
|
predicates = append(predicates, usagedetail.CreatedAtLT(yesterdayEnd))
|
|
@@ -390,13 +392,12 @@ func (l *CronTask) UpdateContactFields(botID string, receiverID string, fields [
|
|
|
} else {
|
|
|
if field.Value != nil {
|
|
|
if len(field.Value) == 0 || field.Value[0] == "" {
|
|
|
- continue
|
|
|
- }
|
|
|
- _, err := l.svcCtx.DB.ContactField.UpdateOneID(f.ID).
|
|
|
- SetValue(field.Value).
|
|
|
- Save(l.ctx)
|
|
|
- if err != nil {
|
|
|
- continue
|
|
|
+ _, err := l.svcCtx.DB.ContactField.UpdateOneID(f.ID).
|
|
|
+ SetValue(field.Value).
|
|
|
+ Save(l.ctx)
|
|
|
+ if err != nil {
|
|
|
+ continue
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|