|
@@ -8,6 +8,7 @@ import (
|
|
|
"app.yhyue.com/moapp/message/model"
|
|
"app.yhyue.com/moapp/message/model"
|
|
|
"app.yhyue.com/moapp/message/util"
|
|
"app.yhyue.com/moapp/message/util"
|
|
|
"fmt"
|
|
"fmt"
|
|
|
|
|
+ "log"
|
|
|
"net/http"
|
|
"net/http"
|
|
|
"strings"
|
|
"strings"
|
|
|
"time"
|
|
"time"
|
|
@@ -29,6 +30,7 @@ func (s *ServerSentRouter) Notify() {
|
|
|
|
|
|
|
|
sessVal := s.Session().GetMultiple()
|
|
sessVal := s.Session().GetMultiple()
|
|
|
userId := common.ObjToString(sessVal["userId"])
|
|
userId := common.ObjToString(sessVal["userId"])
|
|
|
|
|
+ log.Println("message userId:", userId)
|
|
|
//userId = s.GetString("userId")
|
|
//userId = s.GetString("userId")
|
|
|
if userId != "" {
|
|
if userId != "" {
|
|
|
// 创建用户专属的消息通道
|
|
// 创建用户专属的消息通道
|
