using CommonLang;
using CommonLang.Concurrent;
using CommonLang.IO;
using CommonLang.Property;
using CommonNetwork.Http;
using pomelo.chat;
using SimpleJson;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
namespace XmdsBattleClientBot.Bot
{
partial class BotClient
{
public ChatManager CurrentChatManager { get; private set; }
public GetChatServerIdResponse LastGetChatServerIdResponse { get; private set; }
/// <summary>
/// 0综合，1世界，2区域，3交易，4公会，5队伍，6系统，7喇叭，8私聊
/// </summary>
public enum ChatChannel
{
[Desc("世界")]
WORLD = 1, // 世界
[Desc("公会")]
SOCIETY = 2, // 公会
[Desc("队伍")]
GROUPS = 3, // 队伍
[Desc("私聊")]
PRIVATE = 4, // 私聊
[Desc("连服")]
ZONE = 5, // 连服(跨服)
[Desc("附近")]
NEARBY = 6, // 附近
[Desc("喇叭")]
HORM = 8 // 喇叭
}
public enum ChatAt
{
Normal = 0,
All = 1,
Single = 2,
}
public enum ChatFunType
{
NA = 0,
Roll = 1,
}
public void chat_SendChat(Action<Exception, JsonObject> callback,
string content,
string titleMsg = "",
ChatChannel ch = ChatChannel.WORLD,
string acceptRoleId = "",
ChatAt at = ChatAt.Normal,
ChatFunType funtype = ChatFunType.NA)
{
dynamic input = new
{
s2c_name = this.PlayerData.name,//DataMgr.Instance.UserData.Name
s2c_level = this.PlayerData.level, // DataMgr.Instance.UserData:TryToGetIntAttribute(UserData.NotiFyStatus.LEVEL, 0);
s2c_pro = this.PlayerData.pro,// DataMgr.Instance.UserData.Pro;
s2c_zoneId = this.PlayerData.zoneId,//DataMgr.Instance.UserData:GetAttribute(UserData.NotiFyStatus.ZONEID);
s2c_vip = this.PlayerData.vip,// DataMgr.Instance.UserData:GetAttribute(UserData.NotiFyStatus.VIP);
s2c_isAtAll = (int)at,
s2c_titleMsg = titleMsg,
s2c_funtype = (int)funtype,
s2c_color = (uint)0xFFFFFFFF,
acceptRoleId = acceptRoleId,
};
string msg = SimpleJson.SimpleJson.SerializeObject(input);
new ChatManager.ChatRequest(this)
{
channel = ch,
chatContent = content,
acceptRoleId = acceptRoleId,
serverData = msg,
}.Send(callback);
}
public virtual string FormatChat(OnChatPush push)
{
StringBuilder sb = new StringBuilder();
var ch = (BotClient.ChatChannel)push.s2c_scope;
var desc = PropertyUtil.GetEnumAttribute<DescAttribute>(ch);
dynamic input = SimpleJson.SimpleJson.DeserializeObject(push.s2c_serverData);
sb.Append(push.s2c_time);
sb.Append(" ");
sb.Append(string.Format("[{0}]", desc.Desc));
try
{
sb.Append(string.Format("{0}(Lv{1})", input["s2c_name"], input["s2c_level"]));
string s2c_titleMsg = input["s2c_titleMsg"];
if (!string.IsNullOrEmpty(s2c_titleMsg))
{
sb.Append(string.Format(":\"{0}\"", s2c_titleMsg));
}
}
catch (Exception err)
{
sb.Append(err.Message);
}
sb.Append(": " + push.s2c_content);
return sb.ToString();
}
public class ChatManager
{
public ChatManager(BotClient bot)
{
bot.client.GameSocket.chatHandler.getChatServerIdRequest((err, rsp) =>
{
bot.LastGetChatServerIdResponse = rsp;
});
}
public class ChatRequest
{
private readonly BotClient bot;
public static string BOUNDARY = "---------------------------123821742118716"; //boundary就是request头和上传文件内容的分隔符
public ChatChannel channel = ChatChannel.WORLD;
public string chatContent = "0";
public string acceptRoleId = "1";
public string serverData = "0";
public string chatType = "1";//0 is sound
public bool Result { get; private set; }
public ChatRequest(BotClient bot)
{
this.bot = bot;
}
public void Send(Action<Exception, JsonObject> callback)
{
if (bot.LastGetChatServerIdResponse == null)
{
callback(new Exception("No Server ID"), null);
return;
}
try
{
#if OLD_CHAT
HttpWebRequest webRequest = System.Net.WebRequest.Create(bot.LastGetChatServerIdResponse.s2c_clientHttp) as HttpWebRequest;
webRequest.Method = "POST";
webRequest.BeginGetRequestStream(new System.AsyncCallback((System.IAsyncResult asynchronousResult) =>
{
try
{
HttpWebRequest request = (HttpWebRequest)asynchronousResult.AsyncState;
request.Timeout = 1000 * 300;
request.ContentType = "multipart/form-data; boundary=" + BOUNDARY;
request.KeepAlive = true;
request.UserAgent = "Mozilla/5.0 (Windows; U; Windows NT 6.1; zh-CN; rv:1.9.2.6)";
Stream stream = request.EndGetRequestStream(asynchronousResult);
StreamWriter postStream = new StreamWriter(stream);
Dictionary<string, string> textMap = new Dictionary<string, string>();
{
textMap.Add("account", bot.Account);
textMap.Add("appid", bot.config.Appid.ToString());
///************************/
//textMap.Add("serverId", DataMgr.Instance.AccountData.CurSrvInfo.ServerId.ToString());
textMap.Add("serverId", bot.LastGetChatServerIdResponse.s2c_serverId);
string zoneid = bot.PlayerData.zoneId;//(string)DataMgr.Instance.UserData.GetAttribute(UserData.NotiFyStatus.ZONEID);
string[] array = zoneid.Split('-');
int zoneidnum = int.Parse(array[0]) * 1000000 + int.Parse(array[1]);
textMap.Add("realServerId", zoneidnum + "");
textMap.Add("myRoleId", bot.PlayerData.id/*DataMgr.Instance.UserData.RoleID.ToString()*/);
textMap.Add("acceptRoleId", acceptRoleId);
textMap.Add("channel", ((int)channel).ToString());
textMap.Add("chatContent", chatContent);
textMap.Add("chatType", chatType);
textMap.Add("serverData", serverData);
}
{
var strBuf = new StringBuilder();
foreach (string key in textMap.Keys)
{
string inputName = key;
string inputValue = "";
if (textMap[key] == null)
{
continue;
}
inputValue = (string)textMap[key];
strBuf.Append("\r\n" + "--" + BOUNDARY + "\r\n");
strBuf.Append("Content-Disposition: form-data; name=\"" + inputName + "\"\r\n\r\n");
strBuf.Append(inputValue);
}
postStream.Write(strBuf);
}
postStream.Write("\r\n--" + BOUNDARY + "--\r\n");
postStream.Flush();
postStream.Close();
postStream = null;
WebResponse wrp = request.GetResponse();
StreamReader respRs = new StreamReader(wrp.GetResponseStream());
string responseData = "";
string readCallBackFileResponse = "";
while ((responseData = respRs.ReadLine()) != null)
{
readCallBackFileResponse += responseData + "\n";
}
JsonObject obj = (JsonObject)SimpleJson.SimpleJson.DeserializeObject(readCallBackFileResponse);
object status;
if (obj.TryGetValue("status", out status) && (status as string) == "1")
{
Result = (true);
}
else
{
Result = (false);
}
bot.QueueTask(() =>
{
callback(null, obj);
});
}
catch (Exception err)
{
bot.log.Error(err.Message, err);
bot.QueueTask(() =>
{
callback(err, null);
});
}
}), webRequest);
#else
var url = new Uri(bot.LastGetChatServerIdResponse.s2c_clientHttp);
using (WebClient client = new WebClient(url))
{
client.Request.Method = HttpRequest.METHOD_POST;
client.Request.Referer = url.AbsoluteUri;
{
StringBuilder postStream = new StringBuilder();
Dictionary<string, string> textMap = new Dictionary<string, string>();
{
textMap.Add("account", bot.Account);
textMap.Add("appid", bot.config.Appid.ToString());
///************************/
//textMap.Add("serverId", DataMgr.Instance.AccountData.CurSrvInfo.ServerId.ToString());
textMap.Add("serverId", bot.LastGetChatServerIdResponse.s2c_serverId);
string zoneid = bot.PlayerData.zoneId;//(string)DataMgr.Instance.UserData.GetAttribute(UserData.NotiFyStatus.ZONEID);
string[] array = zoneid.Split('-');
int zoneidnum = int.Parse(array[0]) * 1000000 + int.Parse(array[1]);
textMap.Add("realServerId", zoneidnum + "");
textMap.Add("myRoleId", bot.PlayerData.id/*DataMgr.Instance.UserData.RoleID.ToString()*/);
textMap.Add("acceptRoleId", acceptRoleId);
textMap.Add("channel", ((int)channel).ToString());
textMap.Add("chatContent", chatContent);
textMap.Add("chatType", chatType);
textMap.Add("serverData", serverData);
}
{
foreach (string key in textMap.Keys)
{
string inputName = key;
string inputValue = "";
if (textMap[key] == null)
{
continue;
}
inputValue = (string)textMap[key];
postStream.Append("\r\n" + "--" + BOUNDARY + "\r\n");
postStream.Append("Content-Disposition: form-data; name=\"" + inputName + "\"\r\n\r\n");
postStream.Append(inputValue);
}
}
postStream.Append("\r\n--" + BOUNDARY + "--\r\n");
var content = postStream.ToString();
client.Request.Content = CUtils.UTF8.GetBytes(content);
client.Request.ContentType = "multipart/form-data; boundary=" + BOUNDARY;
}
client.ConnectAsync((www)=>
{
try
{
byte[] data = client.Response.ReadContentToEnd();
string ret = CUtils.UTF8.GetString(data);
JsonObject obj = (JsonObject)SimpleJson.SimpleJson.DeserializeObject(ret);
object status;
if (obj.TryGetValue("status", out status) && (status as string) == "1")
{
Result = (true);
}
else
{
Result = (false);
}
bot.QueueTask(() =>
{
callback(null, obj);
});
}
catch (Exception err)
{
bot.log.Error(err.Message, err);
bot.QueueTask(() =>
{
callback(err, null);
});
}
});
}
#endif
}
catch (Exception err)
{
bot.log.Error(err.Message, err);
callback(err, null);
}
}
}
}
}
}