m
This commit is contained in:
@@ -90,10 +90,13 @@ func main() {
|
||||
fund.Clear()
|
||||
|
||||
msg_ := fund.FundsMsg(user.Codes(true)...)
|
||||
if msg_ != "" {
|
||||
err = msg.Send(msg_)
|
||||
if err != nil {
|
||||
logx.Errorf("fund msg send err: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
user.ForEachUser(func(u *user.User) bool {
|
||||
if u.IsStop() {
|
||||
|
||||
@@ -78,9 +78,6 @@ func ForEachUser(f func(u *User) bool) {
|
||||
func Codes(isFund bool) []string {
|
||||
var codes = map[string]struct{}{}
|
||||
ForEachUser(func(u *User) bool {
|
||||
if u.IsStop() {
|
||||
return true
|
||||
}
|
||||
cds := u.Codes(isFund)
|
||||
for _, cd := range cds {
|
||||
if _, ok := codes[cd]; ok {
|
||||
|
||||
Reference in New Issue
Block a user