wip:个人

handler/activity/lotteryDrawTask.go

@@ -205,8 +205,8 @@ func LotteryDrawTask(msg *model.Message) {
 				userName = string(phone[0:3]) + "****" + string(phone[(len(phone)-4):])
 			}
 		}
-		//util.SendNotification(msgBody.UserId, model.SseMessage{
-		util.SendNotificationToAll(model.SseMessage{
+		util.SendNotification(msgBody.UserId, model.SseMessage{
+			//util.SendNotificationToAll(model.SseMessage{
 			Name:     taskInfo.Name,
 			User:     encrypt.SE.EncodeString(msgBody.UserId),
 			State:    model.TaskTarget,

util/sse.go

@@ -4,7 +4,6 @@ import (
 	"app.yhyue.com/moapp/jybase/go-logger/logger"
 	"app.yhyue.com/moapp/message/model"
 	"encoding/json"
-	"log"
 	"sync"
 )
 
@@ -58,7 +57,7 @@ func SendNotificationToAll(msg model.SseMessage) {
 	defer SseClientsMu.Unlock()
 	msgData, _ := json.Marshal(msg)
 	for userId, ch := range SseClients {
-		log.Println("userId:", userId)
+		logger.Info("to all ; userId:", userId)
 		ch <- string(msgData)
 	}
 }