pkg/service/asChat/robot/ruler_replyWhenUserJoinSession.go

@@ -2,13 +2,13 @@ package robot
 
 import (
 	"context"
+	"fmt"
 	"fonchain-fiee/api/accountFiee"
 	"fonchain-fiee/pkg/common/ws"
 	"fonchain-fiee/pkg/service"
 	"fonchain-fiee/pkg/service/asChat/chatCache"
 	"fonchain-fiee/pkg/service/asChat/dto"
 	"fonchain-fiee/pkg/service/asChat/logic"
-	"strconv"
 	"time"
 )
 
@@ -17,12 +17,11 @@ func NewReplyWhenUserJoinSession() IRobotTask {
 }
 
 type ReplyWhenUserJoinSession struct {
-	Response  string
-	Sender    *accountFiee.ChatUserData
-	Msg       string
-	Resp      string
-	sessionId string
-	atUserId  int
+	Response string
+	Receiver *accountFiee.ChatUserData
+	Sender   *accountFiee.ChatUserData
+	Msg      string
+	Resp     string
 }
 
 func (r ReplyWhenUserJoinSession) Hit(event ws.ListenEventData, sender *accountFiee.ChatUserData) (hit bool) {
@@ -56,17 +55,17 @@ func (r ReplyWhenUserJoinSession) Hit(event ws.ListenEventData, sender *accountF
 	}
 	hit = true
 	r.Sender = sender
-	r.sessionId = event.Client.SessionId
-	r.atUserId, _ = strconv.Atoi(event.Client.SessionId)
+	r.Receiver = event.ChatUser
 	return
 }
 
 func (r ReplyWhenUserJoinSession) Run(cache *chatCache.ChatCache) (err error) {
+	clientSessionId := fmt.Sprintf("%d", r.Receiver.ID)
 	err = logic.NewMessage(context.Background(), cache, r.Sender, dto.NewMessageRequest{
 		Waiter:    true,
 		Robot:     true,
-		AtUserId:  int64(r.atUserId),
-		SessionId: r.sessionId,
+		AtUserId:  r.Receiver.ID,
+		SessionId: clientSessionId,
 		Message: dto.Message{
 			MsgType:    1,
 			Text:       r.Resp,