diff --git a/app/jobs/jobs.go b/app/jobs/jobs.go index fcf1a63..59fc879 100644 --- a/app/jobs/jobs.go +++ b/app/jobs/jobs.go @@ -385,11 +385,18 @@ func (l ListenSymbol) Exec(arg interface{}) error { continue } for _, symbol := range symbols.Data.Data { - if slices.Contains(set, symbol.Token0Symbol+symbol.Token1Symbol) { + if chain == "bsc" { + fmt.Println(symbol.Token0Symbol + symbol.Token1Symbol) + } + if slices.Contains(set, symbol.Token0Symbol+symbol.Token1Symbol) || slices.Contains(set, symbol.Token1Symbol+symbol.Token0Symbol) { //发送邮箱 emails := strings.Split(configResp.ConfigValue, ",") for _, email := range emails { - emailhelper.SendNoticeEmail(email, chain, symbol.Token0Symbol+"/"+symbol.Token1Symbol, symbol.Pair) + if slices.Contains(set, symbol.Token0Symbol+symbol.Token1Symbol) { + emailhelper.SendNoticeEmail(email, chain, symbol.Token0Symbol+"/"+symbol.Token1Symbol, symbol.TargetToken) + } else { + emailhelper.SendNoticeEmail(email, chain, symbol.Token1Symbol+"/"+symbol.Token0Symbol, symbol.TargetToken) + } } // 清除数据 db.Model(&models.SpiderListenSymbol{}).Where("coin = ? AND currency = ?", symbol.Token0Symbol, symbol.Token1Symbol).Delete(&models.SpiderListenSymbol{})