admin/exchange_go
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

code

Browse Source
This commit is contained in:
daichao
2025-02-19 11:52:13 +08:00
parent 8cf2a64bc0
commit d793ec59b4
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
app/jobs/jobs.go
View File

@ -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.TargetToken)
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{})