wz1531/5.24BuYu
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

每日自动提交 2026-04-15 18:30

Browse Source
This commit is contained in:
wz1531
2026-04-15 18:30:37 +08:00
parent ee94087bc2
commit 0f4e2716d9
136 changed files with 278684 additions and 3376 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Assets/MyGame/Scripts/Net/WebSocketManager_Message.cs
+56 -1
View File
@@ -1,4 +1,5 @@
using Best.WebSockets;
using Assets.MyGame.Scripts.Net.WebResponses;
using Best.WebSockets;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
@@ -36,6 +37,9 @@ namespace Assets.MyGame.Scripts.Net
case SocketType.chess:
ChineseChess(item, v);
break;
case SocketType.customer:
CustomerMSG(item, v);
break;
default:
break;
}
@@ -197,6 +201,57 @@ namespace Assets.MyGame.Scripts.Net
break;
}
}
private static void CustomerMSG(string msg, WebSocketResponseBase<object> v)
{
switch ((MessageType)v.type)
{
case MessageType.Invocation:
switch (v.target)
{
// 发起会话回调（用户端）：服务端返回 {isOk, msg, conversation}
case "OnConversationStarted":
{
var result = JsonConvert.DeserializeObject<WebSocketResponseBase<CustomerConversationStartedResult>>(msg).arguments[0];
WebSocketReponseList.Customer_OnConversationStarted(result);
}
break;
// 消息接收回调（用户端 & 客服端）
case "OnMessageReceived":
{
var result = JsonConvert.DeserializeObject<WebSocketResponseBase<CustomerMessageReceived>>(msg).arguments[0];
WebSocketReponseList.Customer_OnMessageReceived(result);
}
break;
// 新会话通知（客服端）
case "OnNewConversation":
{
var result = JsonConvert.DeserializeObject<WebSocketResponseBase<CustomerNewConversationNotice>>(msg).arguments[0];
WebSocketReponseList.Customer_OnNewConversation(result);
}
break;
default:
break;
}
break;
case MessageType.StreamItem:
break;
case MessageType.Completion:
break;
case MessageType.StreamInvocation:
break;
case MessageType.CancelInvocation:
break;
case MessageType.Ping:
break;
case MessageType.Close:
break;
default:
break;
}
}
private static void FishMSG(string msg, WebSocketResponseBase<object> v)
{
switch ((MessageType)v.type)