diff options
Diffstat (limited to 'Client/Assets/Scripts/XMainClient/XChatApolloMgr.cs')
| -rw-r--r-- | Client/Assets/Scripts/XMainClient/XChatApolloMgr.cs | 536 |
1 files changed, 536 insertions, 0 deletions
diff --git a/Client/Assets/Scripts/XMainClient/XChatApolloMgr.cs b/Client/Assets/Scripts/XMainClient/XChatApolloMgr.cs new file mode 100644 index 00000000..f1f3a3b5 --- /dev/null +++ b/Client/Assets/Scripts/XMainClient/XChatApolloMgr.cs @@ -0,0 +1,536 @@ +using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Text;
+using KKSG;
+using UnityEngine;
+using XMainClient.UI;
+using XMainClient.UI.UICommon;
+using XUpdater;
+using XUtliPoolLib;
+
+namespace XMainClient
+{
+ internal class XChatApolloMgr : XSingleton<XChatApolloMgr>
+ {
+ public bool IsRecording
+ {
+ get
+ {
+ return this._is_recording;
+ }
+ }
+
+ public bool IsInRecordingState
+ {
+ get
+ {
+ return this._is_recording || this._prepare_record_time > 0u;
+ }
+ }
+
+ private EndRecordCallBack _callback = null;
+
+ private VoiceUsage _usage = VoiceUsage.CHAT;
+
+ private bool _engine_inited = false;
+
+ private uint _prepare_record_time = 0u;
+
+ private uint _record_timer = 0u;
+
+ private uint _mic_timer = 0u;
+
+ private bool _is_recording = false;
+
+ private float _record_start = 0f;
+
+ private float _record_length = 0f;
+
+ private bool _is_uploading = false;
+
+ private float _uploading_start = 0f;
+
+ private string _record_filename = "";
+
+ private string _audio_text = "";
+
+ private uint _upload_timer = 0u;
+
+ private uint _stop_record_timer = 0u;
+
+ private int _stop_record_count = 0;
+
+ private int _upload_wait_time = 0;
+
+ private string _file_id = "";
+
+ private static readonly float MIN_RECORD_LENGTH = 0.3f;
+
+ private UpLoadAudioRes lastAudoRes;
+
+ private Dictionary<ulong, string> _local_audio = new Dictionary<ulong, string>();
+
+ public void InitApolloEngine()
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ int num = xapolloManager.InitApolloEngine(XChatDocument.m_ApolloIPtable[0], XChatDocument.m_ApolloIPtable[1], XChatDocument.m_ApolloIPtable[2], XChatDocument.m_ApolloIPtable[3], XChatDocument.m_ApolloKey, XChatDocument.m_ApolloKey.Length);
+ bool flag = num == 0;
+ if (flag)
+ {
+ this._engine_inited = true;
+ }
+ }
+
+ public void StartRecord(VoiceUsage usage = VoiceUsage.CHAT, EndRecordCallBack callback = null)
+ {
+ bool flag = !this._engine_inited;
+ if (!flag)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Start apollo record", null, null, null, null, null, XDebugColor.XDebug_None);
+ bool isBroadcast = DlgBase<BroadMiniDlg, BroadcastMiniBehaviour>.singleton.isBroadcast;
+ if (isBroadcast)
+ {
+ XSingleton<UiUtility>.singleton.ShowSystemTip(XStringDefineProxy.GetString("FM_VOICE_BROAD"), "fece00");
+ }
+ else
+ {
+ XRadioDocument specificDocument = XDocuments.GetSpecificDocument<XRadioDocument>(XRadioDocument.uuID);
+ bool flag2 = specificDocument.isHosting();
+ if (flag2)
+ {
+ XSingleton<UiUtility>.singleton.ShowSystemTip(XStringDefineProxy.GetString("FM_VOICE_RADIO"), "fece00");
+ }
+ else
+ {
+ bool is_uploading = this._is_uploading;
+ if (is_uploading)
+ {
+ bool flag3 = Time.realtimeSinceStartup - this._uploading_start <= 5f;
+ if (flag3)
+ {
+ return;
+ }
+ this._is_uploading = false;
+ }
+ XSingleton<XChatIFlyMgr>.singleton.StopAutoPlay();
+ this.SetBackMusicOn(false);
+ this.setRadioOn(false);
+ DlgBase<XChatVoiceStatusView, XChatVoiceStatusBehaviour>.singleton.SetVisible(true, true);
+ this._callback = callback;
+ this._usage = usage;
+ this._record_start = Time.realtimeSinceStartup;
+ this._prepare_record_time = XSingleton<XTimerMgr>.singleton.SetTimer(0.15f, new XTimerMgr.ElapsedEventHandler(this.DoStartRecord), null);
+ }
+ }
+ }
+ }
+
+ private void DoStartRecord(object obj)
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ int num = xapolloManager.SetApolloMode(2);
+ XSingleton<XDebug>.singleton.AddLog("Will Do start apollo record, setmode2 res: ", num.ToString(), null, null, null, null, XDebugColor.XDebug_None);
+ this._record_filename = string.Format("{0:D2}{1:D2}{2:D2}.sound", DateTime.Now.Hour, DateTime.Now.Minute, DateTime.Now.Second);
+ int num2 = xapolloManager.StartRecord(this._record_filename);
+ bool flag = num2 != 0;
+ if (flag)
+ {
+ xapolloManager.SetApolloMode(0);
+ }
+ else
+ {
+ this._is_recording = true;
+ this._prepare_record_time = 0u;
+ this._record_timer = XSingleton<XTimerMgr>.singleton.SetTimer(10.5f, new XTimerMgr.ElapsedEventHandler(this.RecordTimeOut), null);
+ this._mic_timer = XSingleton<XTimerMgr>.singleton.SetTimer(0.1f, new XTimerMgr.ElapsedEventHandler(this.RefreshMicLevel), null);
+ }
+ }
+
+ private void RefreshMicLevel(object obj)
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ int micLevel = xapolloManager.GetMicLevel();
+ DlgBase<XChatVoiceStatusView, XChatVoiceStatusBehaviour>.singleton.OnSetVolume((uint)(micLevel * 7 / 65535));
+ this._mic_timer = XSingleton<XTimerMgr>.singleton.SetTimer(0.1f, new XTimerMgr.ElapsedEventHandler(this.RefreshMicLevel), null);
+ }
+
+ private void RecordTimeOut(object obj)
+ {
+ bool flag = !this._is_recording;
+ if (!flag)
+ {
+ this.StopRecord(false);
+ bool flag2 = this._callback != null;
+ if (flag2)
+ {
+ this._callback();
+ }
+ }
+ }
+
+ public void StopRecord(bool cancel)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Will stop record", null, null, null, null, null, XDebugColor.XDebug_None);
+ DlgBase<XChatVoiceStatusView, XChatVoiceStatusBehaviour>.singleton.SetNormalHide(true);
+ DlgBase<XChatVoiceStatusView, XChatVoiceStatusBehaviour>.singleton.SetVisible(false, true);
+ XSingleton<XTimerMgr>.singleton.KillTimer(this._mic_timer);
+ this._mic_timer = 0u;
+ XSingleton<XTimerMgr>.singleton.KillTimer(this._prepare_record_time);
+ this._prepare_record_time = 0u;
+ this.SetBackMusicOn(true);
+ this.setRadioOn(true);
+ bool flag = !this._is_recording;
+ if (!flag)
+ {
+ this._is_recording = false;
+ this._record_length = Time.realtimeSinceStartup - this._record_start;
+ XSingleton<XDebug>.singleton.AddLog("Will stop record, length:", this._record_length.ToString(), null, null, null, null, XDebugColor.XDebug_None);
+ bool flag2 = this._record_length <= XChatApolloMgr.MIN_RECORD_LENGTH;
+ if (flag2)
+ {
+ XSingleton<UiUtility>.singleton.ShowSystemTip(XStringDefineProxy.GetString("CHAT_RECORD_TOO_SHORT"), "fece00");
+ this._is_uploading = true;
+ this.CancelRecord(null);
+ }
+ else
+ {
+ bool flag3 = this._record_timer > 0u;
+ if (flag3)
+ {
+ XSingleton<XTimerMgr>.singleton.KillTimer(this._record_timer);
+ this._record_timer = 0u;
+ }
+ bool flag4 = !cancel;
+ if (flag4)
+ {
+ this._stop_record_count = 0;
+ this._is_uploading = true;
+ this.StopRecordProc(null);
+ }
+ else
+ {
+ this._stop_record_count = 0;
+ this.CancelRecord(null);
+ }
+ }
+ }
+ }
+
+ private void StopRecordProc(object obj)
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ int num = xapolloManager.StopApolloRecord();
+ XSingleton<XDebug>.singleton.AddLog("Will stop record", null, null, null, null, null, XDebugColor.XDebug_None);
+ bool flag = num != 0;
+ if (flag)
+ {
+ this._stop_record_count = this._stop_record_count;
+ bool flag2 = this._stop_record_count > 10;
+ if (flag2)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Stop record failed", null, null, null, null, null, XDebugColor.XDebug_None);
+ this._is_uploading = false;
+ xapolloManager.SetApolloMode(0);
+ }
+ else
+ {
+ this._stop_record_timer = XSingleton<XTimerMgr>.singleton.SetTimer(0.1f, new XTimerMgr.ElapsedEventHandler(this.StopRecordProc), null);
+ }
+ }
+ else
+ {
+ this.UploadRecordFile(this._record_filename);
+ }
+ }
+
+ private void CancelRecord(object obj)
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ int num = xapolloManager.StopApolloRecord();
+ XSingleton<XDebug>.singleton.AddLog("Will Cancel record", null, null, null, null, null, XDebugColor.XDebug_None);
+ bool flag = num != 0;
+ if (flag)
+ {
+ this._stop_record_count = this._stop_record_count;
+ bool flag2 = this._stop_record_count > 10;
+ if (flag2)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Cancel record failed", null, null, null, null, null, XDebugColor.XDebug_None);
+ this._is_uploading = false;
+ }
+ else
+ {
+ this._stop_record_timer = XSingleton<XTimerMgr>.singleton.SetTimer(0.1f, new XTimerMgr.ElapsedEventHandler(this.CancelRecord), null);
+ }
+ }
+ else
+ {
+ this._is_uploading = false;
+ }
+ }
+
+ private int UploadRecordFile(string filename)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Will apollo upload", null, null, null, null, null, XDebugColor.XDebug_None);
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ bool flag = !File.Exists(Application.persistentDataPath + "/" + filename);
+ int result;
+ if (flag)
+ {
+ this._is_uploading = false;
+ result = -1;
+ }
+ else
+ {
+ int num = xapolloManager.UploadRecordFile(filename);
+ this._upload_wait_time = 0;
+ XSingleton<XDebug>.singleton.AddLog("UploadRecord file error: ", num.ToString(), null, null, null, null, XDebugColor.XDebug_None);
+ this.GetFileID(null);
+ result = 0;
+ }
+ return result;
+ }
+
+ private void GetFileID(object obj)
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ int apolloUploadStatus = xapolloManager.GetApolloUploadStatus();
+ bool flag = apolloUploadStatus == 0;
+ if (flag)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Upload success", null, null, null, null, null, XDebugColor.XDebug_None);
+ this._file_id = xapolloManager.GetFileID();
+ bool flag2 = !string.IsNullOrEmpty(this._file_id);
+ if (flag2)
+ {
+ this._record_length = Time.realtimeSinceStartup - this._record_start;
+ this._record_length = ((this._record_length > 10f) ? 10f : this._record_length);
+ XSingleton<XDebug>.singleton.AddLog("Record StopTime: ", Time.time.ToString(), null, null, null, null, XDebugColor.XDebug_None);
+ bool flag3 = this._record_length <= XChatApolloMgr.MIN_RECORD_LENGTH;
+ if (flag3)
+ {
+ XSingleton<UiUtility>.singleton.ShowSystemTip(XStringDefineProxy.GetString("CHAT_RECORD_TOO_SHORT"), "fece00");
+ }
+ else
+ {
+ this.GetAudioText(this._file_id);
+ }
+ }
+ else
+ {
+ XSingleton<XDebug>.singleton.AddLog("GetFileId failed", null, null, null, null, null, XDebugColor.XDebug_None);
+ xapolloManager.SetApolloMode(0);
+ }
+ }
+ else
+ {
+ bool flag4 = apolloUploadStatus == 11;
+ if (flag4)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Upload http busy", null, null, null, null, null, XDebugColor.XDebug_None);
+ this._upload_wait_time++;
+ bool flag5 = this._upload_wait_time >= 20;
+ if (flag5)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Upload http failed, times top", null, null, null, null, null, XDebugColor.XDebug_None);
+ this._is_uploading = false;
+ }
+ else
+ {
+ this._upload_timer = XSingleton<XTimerMgr>.singleton.SetTimer(0.1f, new XTimerMgr.ElapsedEventHandler(this.GetFileID), null);
+ }
+ }
+ else
+ {
+ this._is_uploading = false;
+ XSingleton<XDebug>.singleton.AddLog("GetFileId error", null, null, null, null, null, XDebugColor.XDebug_None);
+ xapolloManager.SetApolloMode(0);
+ }
+ }
+ }
+
+ public void GetAudioText(string fileid)
+ {
+ RpcC2A_AudioText rpcC2A_AudioText = new RpcC2A_AudioText();
+ rpcC2A_AudioText.oArg.file_id = fileid;
+ XSingleton<XClientNetwork>.singleton.Send(rpcC2A_AudioText);
+ }
+
+ public void OnGotAudioTextError(AudioTextRes res)
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ bool flag = xapolloManager != null;
+ if (flag)
+ {
+ xapolloManager.SetApolloMode(0);
+ }
+ }
+
+ public void OnGotAudioText(AudioTextRes res)
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ this._audio_text = res.file_text;
+ xapolloManager.SetApolloMode(0);
+ this.StartUpLoadMp3();
+ }
+
+ public void StartUpLoadMp3()
+ {
+ XSingleton<XDebug>.singleton.AddLog("Will start upload mp3, txt:", this._audio_text, null, null, null, null, XDebugColor.XDebug_None);
+ RpcC2T_UpLoadAudioToGate rpcC2T_UpLoadAudioToGate = new RpcC2T_UpLoadAudioToGate();
+ string path = Application.persistentDataPath + "/" + this._record_filename;
+ bool flag = !File.Exists(path);
+ if (flag)
+ {
+ this._is_uploading = false;
+ }
+ else
+ {
+ RuntimePlatform platform = Application.platform;
+ if ((int)platform != 8 && (int)platform != 11)
+ {
+ path = Application.persistentDataPath + "/record.sound";
+ }
+ rpcC2T_UpLoadAudioToGate.oArg.audio = File.ReadAllBytes(path);
+ rpcC2T_UpLoadAudioToGate.oArg.text = Encoding.UTF8.GetBytes(this._audio_text);
+ rpcC2T_UpLoadAudioToGate.oArg.srctype = 1u;
+ XSingleton<XDebug>.singleton.AddLog("The audio length: ", rpcC2T_UpLoadAudioToGate.oArg.audio.Length.ToString(), null, null, null, null, XDebugColor.XDebug_None);
+ XSingleton<XClientNetwork>.singleton.Send(rpcC2T_UpLoadAudioToGate);
+ }
+ }
+
+ public void UpLoadAudioRes(UpLoadAudioRes res)
+ {
+ uint num = (uint)(this._record_length * 1000f) + 1u;
+ XSingleton<XDebug>.singleton.AddLog("Will upload res mp3, usage: ", null, null, null, null, null, XDebugColor.XDebug_None);
+ this._is_uploading = false;
+ bool flag = this._usage == VoiceUsage.CHAT;
+ if (flag)
+ {
+ XSingleton<XChatIFlyMgr>.singleton.LocalAudio[res.audiodownuid] = Application.persistentDataPath + "/" + this._record_filename;
+ this.lastAudoRes = res;
+ bool flag2 = DlgBase<XChatView, XChatBehaviour>.singleton.CheckWorldSendMsg(true, null, ChatChannelType.DEFAULT);
+ if (flag2)
+ {
+ bool flag3 = num >= 9000u && this._audio_text.Length <= (int)(num / 2000u);
+ if (!flag3)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Will Do send world chat", null, null, null, null, null, XDebugColor.XDebug_None);
+ DlgBase<XChatView, XChatBehaviour>.singleton.SendVoiceChat(this._audio_text, DlgBase<XChatView, XChatBehaviour>.singleton.activeChannelType, res.audiodownuid, num * 1f);
+ }
+ }
+ }
+ else
+ {
+ bool flag4 = this._usage == VoiceUsage.ANSWER;
+ if (flag4)
+ {
+ XVoiceQADocument specificDocument = XDocuments.GetSpecificDocument<XVoiceQADocument>(XVoiceQADocument.uuID);
+ XSingleton<XDebug>.singleton.AddLog("Will Do send answer chat", null, null, null, null, null, XDebugColor.XDebug_None);
+ specificDocument.SendAnswer(this._audio_text, res.audiodownuid, num);
+ }
+ else
+ {
+ bool flag5 = this._usage == VoiceUsage.FLOWER_REPLY;
+ if (flag5)
+ {
+ XSingleton<XChatIFlyMgr>.singleton.LocalAudio[res.audiodownuid] = Application.persistentDataPath + "/" + this._record_filename;
+ this.lastAudoRes = res;
+ DlgBase<XChatView, XChatBehaviour>.singleton.SendVoiceChat(this._audio_text, ChatChannelType.Friends, res.audiodownuid, num * 1f);
+ }
+ else
+ {
+ bool flag6 = this._usage == VoiceUsage.MENTORHIP;
+ if (flag6)
+ {
+ XSingleton<XChatIFlyMgr>.singleton.LocalAudio[res.audiodownuid] = Application.persistentDataPath + "/" + this._record_filename;
+ this.lastAudoRes = res;
+ }
+ else
+ {
+ bool flag7 = this._usage == VoiceUsage.GUILDCOLLECT;
+ if (flag7)
+ {
+ XExchangeItemDocument specificDocument2 = XDocuments.GetSpecificDocument<XExchangeItemDocument>(XExchangeItemDocument.uuID);
+ XSingleton<XDebug>.singleton.AddLog("Will Do send voice chat in guild collect", null, null, null, null, null, XDebugColor.XDebug_None);
+ specificDocument2.SendChat(this._audio_text, res.audiodownuid, num);
+ }
+ }
+ }
+ }
+ }
+ }
+
+ private void DoSendVoiceMsg(string fileid)
+ {
+ uint num = (uint)(this._record_length * 1000f) + 1u;
+ XSingleton<XDebug>.singleton.AddLog("Will DoSendVoiceMsg ", null, null, null, null, null, XDebugColor.XDebug_None);
+ }
+
+ private void setRadioOn(bool on)
+ {
+ XRadioDocument specificDocument = XDocuments.GetSpecificDocument<XRadioDocument>(XRadioDocument.uuID);
+ bool flag = specificDocument != null;
+ if (flag)
+ {
+ specificDocument.MuteSounds(!on);
+ }
+ }
+
+ public void SetBackMusicOn(bool on)
+ {
+ XAudioOperationArgs @event = XEventPool<XAudioOperationArgs>.GetEvent();
+ @event.IsAudioOn = on;
+ @event.Firer = XSingleton<XGame>.singleton.Doc;
+ XSingleton<XEventMgr>.singleton.FireEvent(@event);
+ }
+
+ public void StartPlayVoice(string filepath)
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ bool flag = !File.Exists(filepath);
+ if (flag)
+ {
+ XSingleton<XDebug>.singleton.AddLog("Start Play Voice, File not exist: ", filepath, null, null, null, null, XDebugColor.XDebug_None);
+ }
+ else
+ {
+ XSingleton<XDebug>.singleton.AddLog("Will play file: ", filepath, null, null, null, null, XDebugColor.XDebug_None);
+ RuntimePlatform platform = Application.platform;
+ if ((int)platform != 8 && (int)platform != 11)
+ {
+ bool flag2 = File.Exists(filepath);
+ if (flag2)
+ {
+ xapolloManager.StartPlayVoice(filepath);
+ }
+ else
+ {
+ xapolloManager.StartPlayVoice(Application.persistentDataPath + "/record.sound");
+ }
+ }
+ else
+ {
+ xapolloManager.StartPlayVoice(filepath);
+ }
+ }
+ }
+
+ public void StopPlayVoice()
+ {
+ IApolloManager xapolloManager = XSingleton<XUpdater.XUpdater>.singleton.XApolloManager;
+ xapolloManager.StopPlayVoice();
+ }
+
+ public void ResendLastWorldChat()
+ {
+ uint num = (this._record_length >= 1f) ? ((uint)this._record_length) : 1u;
+ bool flag = this.lastAudoRes != null;
+ if (flag)
+ {
+ DlgBase<XChatView, XChatBehaviour>.singleton.SendVoiceChat(this._audio_text, DlgBase<XChatView, XChatBehaviour>.singleton.activeChannelType, this.lastAudoRes.audiodownuid, num * 1f);
+ }
+ }
+ }
+}
|