statbate/special-pancake
1
0
Fork 0
mirror of https://github.com/statbate/special-pancake.git synced 2026-08-11 03:12:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update worker.go

Browse source
This commit is contained in:
poiuty 2023-05-24 01:05:53 +03:00
parent f8a794b9e1
commit 733ef7c8b8
1 changed files with 4 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

10
app/worker.go
View file

@ -195,7 +195,7 @@ func xWorker(workerData Info, u url.URL) {
_, message, err := c.ReadMessage() _, message, err := c.ReadMessage()
if err != nil { if err != nil {
fmt.Println(err.Error(), workerData.room) fmt.Println(err.Error(), workerData.room)
if income > 1 && websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) { if income > 1 && !isLeave && websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) {
go reconnectRoom(workerData) go reconnectRoom(workerData)
} }
return return
@ -208,8 +208,8 @@ func xWorker(workerData Info, u url.URL) {
//fmt.Println(m) //fmt.Println(m)
if now > workerData.Last+60*20 { if now > workerData.Last+60*60 {
fmt.Println("no_mes exit:", workerData.room) fmt.Println("no_tips exit:", workerData.room)
return return
} }
@ -220,9 +220,6 @@ func xWorker(workerData Info, u url.URL) {
if input.Action == 15 { if input.Action == 15 {
workerData.Last = now
rooms.Add <- workerData
if input.Channel == "room:enter_leave:"+workerData.Id { if input.Channel == "room:enter_leave:"+workerData.Id {
type Message struct { type Message struct {
Data string `json:"data"` Data string `json:"data"`
@ -310,6 +307,7 @@ func xWorker(workerData Info, u url.URL) {
} }
save <- saveData{Room: workerData.room, From: donate.From, Rid: workerData.Rid, Amount: donate.Amount, Now: now} save <- saveData{Room: workerData.room, From: donate.From, Rid: workerData.Rid, Amount: donate.Amount, Now: now}
workerData.Last = now
workerData.Income += donate.Amount workerData.Income += donate.Amount
rooms.Add <- workerData rooms.Add <- workerData