From 53e34904b01fa05da96045303029cf99c54936d7 Mon Sep 17 00:00:00 2001 From: poiuty Date: Sun, 7 Aug 2022 14:26:31 +0300 Subject: [PATCH] update --- app/worker.go | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/app/worker.go b/app/worker.go index e577063..e2f8a93 100644 --- a/app/worker.go +++ b/app/worker.go @@ -188,11 +188,11 @@ func xWorker(workerData Info, u url.URL) { slog <- saveLog{workerData.Rid, time.Now().Unix(), string(message)} - quit := make(chan bool) + quit := make(chan struct{}) pid := 3 defer func() { - quit <- true + close(quit) }() go func() { @@ -214,6 +214,8 @@ func xWorker(workerData Info, u url.URL) { } }() + dons := make(map[string]struct{}) + for { select { case <-workerData.ch: @@ -258,6 +260,12 @@ func xWorker(workerData Info, u url.URL) { if err = json.Unmarshal(m.Body, d); err == nil { //fmt.Println(d.F.Username, "send", d.A, "tokens") + workerData.Tips++ + if _, ok := dons[d.F.Username]; !ok { + dons[d.F.Username] = struct{}{} + workerData.Dons++ + } + save <- saveData{workerData.room, d.F.Username, workerData.Rid, d.A, now} workerData.Income += d.A