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,

services/sse/sse.go

@@ -35,6 +35,8 @@ func (s *ServerSentRouter) Notify() {
 		logger.Info("params  userId:", userId)
 	}
 	if userId != "" {
+		userId = fmt.Sprintf("%s#%d", userId, time.Now().UnixMilli())
+		logger.Info("new  userId:", userId)
 		// 创建用户专属的消息通道
 		messageChan := make(chan string)
 		// 注册当前连接