diff --git a/app/jobs/jobs.go b/app/jobs/jobs.go index c3b373c..e286f63 100644 --- a/app/jobs/jobs.go +++ b/app/jobs/jobs.go @@ -394,12 +394,12 @@ func (l ListenSymbol) Exec(arg interface{}) error { for _, email := range emails { if slices.Contains(set, symbol.Token0Symbol+symbol.Token1Symbol) { emailhelper.SendNoticeEmail(email, chain, symbol.Token0Symbol+"/"+symbol.Token1Symbol, symbol.TargetToken) + db.Model(&models.SpiderListenSymbol{}).Where("coin = ? AND currency = ?", symbol.Token0Symbol, symbol.Token1Symbol).Delete(&models.SpiderListenSymbol{}) } else { emailhelper.SendNoticeEmail(email, chain, symbol.Token1Symbol+"/"+symbol.Token0Symbol, symbol.TargetToken) + db.Model(&models.SpiderListenSymbol{}).Where("coin = ? AND currency = ?", symbol.Token1Symbol, symbol.Token0Symbol).Delete(&models.SpiderListenSymbol{}) } } - // 清除数据 - db.Model(&models.SpiderListenSymbol{}).Where("coin = ? AND currency = ?", symbol.Token0Symbol, symbol.Token1Symbol).Delete(&models.SpiderListenSymbol{}) continue } }