mirror of
https://gitee.com/lxwcode/weixinHttpApi.git
synced 2025-12-06 10:18:57 +08:00
645 lines
25 KiB
C#
645 lines
25 KiB
C#
using FluorineFx.Json;
|
||
using System;
|
||
using System.Collections;
|
||
using System.Collections.Generic;
|
||
using System.ComponentModel;
|
||
using System.Data;
|
||
using System.Drawing;
|
||
using System.IO;
|
||
using System.IO.Compression;
|
||
using System.Linq;
|
||
using System.Net;
|
||
using System.Net.Http;
|
||
using System.Net.Http.Headers;
|
||
using System.Security.Cryptography;
|
||
using System.Text;
|
||
using System.Text.RegularExpressions;
|
||
using System.Threading;
|
||
using System.Windows.Forms;
|
||
using System.Xml;
|
||
|
||
namespace WeiXinZhuaFaWang
|
||
{
|
||
public partial class MainForm : Form
|
||
{
|
||
|
||
public MainForm()
|
||
{
|
||
InitializeComponent();
|
||
|
||
jslogin();
|
||
|
||
qrcode();
|
||
|
||
login();
|
||
}
|
||
|
||
private void login()
|
||
{
|
||
ShowMsg("login.....");
|
||
if (__3)
|
||
{
|
||
//第三步，等待扫描
|
||
var time = new System.Windows.Forms.Timer();
|
||
time.Interval = sleeptime;
|
||
time.Stop();
|
||
|
||
int count = 0;
|
||
time.Tick += new EventHandler(delegate
|
||
{
|
||
if (count++ > login_try_times)
|
||
{
|
||
time.Stop();
|
||
throw new Exception("错误的次数超过了:" + login_try_times + "次");
|
||
}
|
||
|
||
SendHeader(httpclient, url_login[1]);
|
||
var task = httpclient.GetStringAsync(ReplaceKey(url_login[0]));
|
||
var result = task.Result;
|
||
|
||
if (result.IndexOf("window.redirect_uri=") != -1)
|
||
{
|
||
time.Stop();
|
||
redirect_uri = GetResultString(result, "\"(.*?)\"");
|
||
|
||
if (redirect_uri.IndexOf("wx2.qq.com")!=-1)
|
||
WXNUMBER = "2";
|
||
|
||
//执行第四部
|
||
doStep4();
|
||
}
|
||
});
|
||
time.Start();
|
||
}
|
||
}
|
||
|
||
private void qrcode()
|
||
{
|
||
ShowMsg("qrcode");
|
||
if (__2)
|
||
{
|
||
SendHeader(httpclient, url_qrcode[1]);
|
||
var task = httpclient.GetStreamAsync(ReplaceKey(url_qrcode[0]));
|
||
|
||
var result = task.Result;
|
||
this.pictureBox1.BackgroundImage = Image.FromStream(result);
|
||
}
|
||
}
|
||
|
||
private void jslogin()
|
||
{
|
||
ShowMsg("islogin");
|
||
if (__1)
|
||
{
|
||
SendHeader(httpclient, url_jslogin[1]);
|
||
var task = httpclient.GetStreamAsync(ReplaceKey(url_jslogin[0]));
|
||
var result = GetDeflateByStream(task.Result, "GBK");
|
||
UUID = GetCodeString(result, "200", "\"(.*?)\"");
|
||
|
||
|
||
}
|
||
}
|
||
|
||
|
||
private void doStep4()
|
||
{
|
||
this.pictureBox1.Visible = false;
|
||
this.listBox1.Visible = true;
|
||
this.lstBoxUser.Visible = true;
|
||
this.btnSend.Visible = true;
|
||
this.txtBoxMessage.Visible = true;
|
||
this.btnGetUserList.Visible = true;
|
||
|
||
redirect_uri_fun();
|
||
|
||
webwxinit_new();
|
||
|
||
webwxgetcontact();
|
||
|
||
//循环检查状态，如果得到了最新信息，然后开始执行
|
||
synccheck();
|
||
|
||
urldownload();
|
||
|
||
//开启一个timer，一直给我发送信息
|
||
var timer = new System.Timers.Timer();
|
||
timer.Interval = 1000;
|
||
timer.Elapsed += (o, e) => {
|
||
if (!bFirst)
|
||
{
|
||
timer.Interval = 10 * 60 * 1000;
|
||
bool b = false;
|
||
foreach (var s in USER_DI)
|
||
{
|
||
if (s.Value.IndexOf("都好") != -1)
|
||
{
|
||
b = true;
|
||
SendMsg(s.Key,USER_INFO, DateTime.Now.ToString(), false);
|
||
break;
|
||
}
|
||
}
|
||
|
||
if (b == false)
|
||
{
|
||
//如果走到这一步，就随机一个人发
|
||
SendMsg(USER_DI.ElementAt((new Random()).Next(USER_DI.Count())).Key, USER_INFO,DateTime.Now.ToString(), false);
|
||
}
|
||
}
|
||
};
|
||
|
||
timer.Start();
|
||
}
|
||
|
||
|
||
bool bFirst = true;
|
||
private void redirect_uri_fun()
|
||
{
|
||
ShowMsg("redirect_uri_fun");
|
||
if (__4)
|
||
{
|
||
HttpWebRequest h = (HttpWebRequest)HttpWebRequest.Create(redirect_uri);
|
||
h.AllowAutoRedirect = false;
|
||
h.CookieContainer = cookieContainer;
|
||
HttpWebResponse r = (HttpWebResponse)h.GetResponse();
|
||
|
||
COOKIES = GetAllCookiesA(cookieContainer);
|
||
|
||
using (System.IO.StreamReader read = new System.IO.StreamReader(r.GetResponseStream()))
|
||
{
|
||
string value = read.ReadToEnd();
|
||
if (value.IndexOf("pass_ticket") == -1) throw new Exception("没有得到wxsid信息");
|
||
step4xml = Xml2Json<Step4XML>(value);
|
||
}
|
||
r.Close();
|
||
}
|
||
}
|
||
|
||
private void synccheck()
|
||
{
|
||
ShowMsg("synccheck");
|
||
if (__6)
|
||
{
|
||
var urlA = "https://webpush[number].weixin.qq.com/cgi-bin/mmwebwx-bin/synccheck?r={time}&skey={SKEY}&sid={SID}&uin={UIN}&deviceid={DeviceID}&synckey={synckey}&_={time}";
|
||
|
||
bool bRun = true;
|
||
|
||
ThreadPool.QueueUserWorkItem(new WaitCallback(delegate
|
||
{
|
||
while (bRun)
|
||
{
|
||
Thread.Sleep(2000);
|
||
try
|
||
{
|
||
var url = ReplaceKey(urlA);
|
||
if (bFirst) ShowMsg("正在解析中...等待!");
|
||
JavaScriptObject obj = JavaScriptConvert.DeserializeObject(SyncKey) as JavaScriptObject;
|
||
JavaScriptArray list = obj["List"] as JavaScriptArray;
|
||
var k = "";
|
||
foreach (JavaScriptObject o in list)
|
||
k += "|" + o["Key"] + "_" + o["Val"];
|
||
|
||
url = url.Replace("{synckey}", k.Substring(1));
|
||
|
||
HttpWebRequest h = (HttpWebRequest)HttpWebRequest.Create(url);
|
||
h.AllowAutoRedirect = false;
|
||
h.CookieContainer = cookieContainer;
|
||
h.Accept = "application/javascript, */*;q=0.8";
|
||
HttpWebResponse r = (HttpWebResponse)h.GetResponse();
|
||
using (System.IO.StreamReader read = new System.IO.StreamReader(r.GetResponseStream()))
|
||
{
|
||
|
||
string value = read.ReadToEnd();
|
||
if (value.Contains("1101"))
|
||
{
|
||
bRun = false;
|
||
|
||
ShowMsg("请重新打开!" + url);
|
||
}
|
||
else
|
||
{
|
||
if (bFirst)
|
||
{
|
||
bFirst = false;
|
||
ShowMsg("正常运行!");
|
||
}
|
||
Console.WriteLine("1=>" + value);
|
||
//string ret = value;
|
||
//window.synccheck={retcode:"0",selector:"6"}
|
||
if (value.IndexOf("selector:\"0\"") == -1 && value.IndexOf("retcode:\"0\"") != -1)
|
||
doStep7();
|
||
}
|
||
|
||
}
|
||
r.Close();
|
||
}
|
||
catch
|
||
{
|
||
}
|
||
}
|
||
}));
|
||
}
|
||
}
|
||
|
||
|
||
|
||
private void webwxgetcontact()
|
||
{
|
||
ShowMsg("webwxgetcontact");
|
||
if (true)
|
||
{
|
||
var url = "https://wx[number].qq.com/cgi-bin/mmwebwx-bin/webwxgetcontact?pass_ticket={pass_ticket}&r={time}&skey={SKEY}";
|
||
|
||
HttpWebRequest h = (HttpWebRequest)HttpWebRequest.Create(ReplaceKey(url));
|
||
h.AllowAutoRedirect = false;
|
||
h.CookieContainer = cookieContainer;
|
||
h.Accept = "application/json, text/plain, */*";
|
||
HttpWebResponse r = (HttpWebResponse)h.GetResponse();
|
||
using (System.IO.StreamReader read = new System.IO.StreamReader(r.GetResponseStream()))
|
||
{
|
||
string value = read.ReadToEnd();
|
||
USER_LIST = JavaScriptConvert.DeserializeObject(value) as JavaScriptObject;
|
||
|
||
//显示到list中
|
||
var arr = USER_LIST["MemberList"] as JavaScriptArray;
|
||
lstBoxUser.Items.Clear();
|
||
|
||
foreach (JavaScriptObject o in arr)
|
||
{
|
||
USER_DI[o["UserName"] + ""] = o["NickName"] + "";
|
||
//NickName
|
||
lstBoxUser.Items.Add(o["NickName"] + ">" + o["UserName"]);
|
||
}
|
||
}
|
||
r.Close();
|
||
|
||
}
|
||
}
|
||
|
||
private void webwxinit_new()
|
||
{
|
||
ShowMsg("webwxinit_new");
|
||
if (__5)
|
||
{
|
||
SendHeader(httpclient, ReplaceHeaderKey(url_webwxinit[1]));
|
||
byte[] bs = Encoding.UTF8.GetBytes(ReplaceHeaderKey(@"{""BaseRequest"":{""Uin"":""{UIN}"",""Sid"":""{SID}"",""Skey"":""{SKEY}"",""DeviceID"":""{DeviceID}""}}"));
|
||
|
||
var task = httpclient.PostAsync(ReplaceKey(url_webwxinit[0]), new ByteArrayContent(bs));
|
||
{
|
||
string value = GetDeflateByStream(task.Result.Content.ReadAsStreamAsync().Result);
|
||
//"Ret": 1100,
|
||
if (!value.Contains("\"Ret\": 0"))
|
||
{
|
||
ShowMsg("没有返回正确的数据，webwxinit错误!");
|
||
throw new Exception("没有返回正确的数据，webwxinit错误!");
|
||
}
|
||
|
||
//USER_INFO
|
||
USER_INFO = SubString(value.Replace("\r", "").Replace("\n", ""), "\"User\": {", "NickName");
|
||
USER_INFO = SubString(USER_INFO, "\"UserName\": \"", "\",");
|
||
|
||
|
||
USER_NICKNAME = SubString(value.Replace("\r", "").Replace("\n", ""), "\"User\": {", "HeadImgUrl");
|
||
USER_NICKNAME = SubString(USER_NICKNAME, "\"NickName\": \"", "\",");
|
||
|
||
|
||
label1.Text = USER_INFO;
|
||
USER_DI.Add(USER_INFO, USER_NICKNAME);
|
||
|
||
this.Text = USER_NICKNAME+">>>转发微信机器人 V0.5 20151007 By LXW";
|
||
|
||
//SyncKey
|
||
SyncKey = SubString(value.Replace("\r", "").Replace("\n", ""), "\"SyncKey\": ", "}]}");
|
||
SyncKey += "}]}";
|
||
#if DEBUG
|
||
this.textBox1.Text = SyncKey;
|
||
#endif
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送文件
|
||
/// </summary>
|
||
private void btnSendFile_Click(object sender, EventArgs e)
|
||
{
|
||
var openFileDialog = new OpenFileDialog();
|
||
if (openFileDialog.ShowDialog() == System.Windows.Forms.DialogResult.OK)
|
||
{
|
||
sendFileMsg(openFileDialog.FileName);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送文件
|
||
/// </summary>
|
||
/// <param name="filePath"></param>
|
||
void sendFileMsg(string filePath)
|
||
{
|
||
HttpClient newClient = new HttpClient();
|
||
{
|
||
//执行第一个
|
||
SendHeader(newClient, webwxuploadmedia0[1]);
|
||
var result = newClient.PostAsync(ReplaceKey(webwxuploadmedia0[0]),new StringContent(""));
|
||
Console.WriteLine(result.Result);
|
||
}
|
||
{
|
||
FileStream fs = File.OpenRead(filePath);
|
||
|
||
var requestContent = new MultipartFormDataContent();
|
||
|
||
var txtContent = new ByteArrayContent(Encoding.UTF8.GetBytes(ReplaceHeaderKey(webwxuploadmedia1body2).Replace("[CD]", fs.Length + "")));
|
||
txtContent.Headers.ContentDisposition = new ContentDispositionHeaderValue("form-data")
|
||
{
|
||
Name = "uploadmediarequest"
|
||
};
|
||
requestContent.Add(txtContent);
|
||
Dictionary<string, string> di = new Dictionary<string, string>();
|
||
di["id"] = "WU_FILE_0";
|
||
di["name"] = "webwxgetvoice.mp3";
|
||
di["type"] = "audio/mpeg";
|
||
di["size"] = fs.Length+"";
|
||
di["mediatype"] = "doc";
|
||
di["webwx_data_ticket"] = COOKIES["webwx_data_ticket"];
|
||
di["pass_ticket"] = this.step4xml.pass_ticket;
|
||
foreach (string s in di.Keys)
|
||
{
|
||
txtContent = new ByteArrayContent(Encoding.UTF8.GetBytes(di[s]));
|
||
txtContent.Headers.ContentDisposition = new ContentDispositionHeaderValue("form-data")
|
||
{
|
||
Name = s
|
||
};
|
||
requestContent.Add(txtContent);
|
||
}
|
||
|
||
|
||
|
||
//var imageContent = new ByteArrayContent(temp);
|
||
//imageContent.Headers.ContentType =
|
||
// MediaTypeHeaderValue.Parse("audio/mpeg");
|
||
//requestContent.Add(imageContent, "filename","webwxgetvoice.mp3");
|
||
var t = new StreamContent(fs);
|
||
t.Headers.ContentType = MediaTypeHeaderValue.Parse("audio/mp3");
|
||
requestContent.Add(t, "filename", "webwxgetvoice.mp3");
|
||
|
||
SendHeader(newClient, webwxuploadmedia1[1]);
|
||
|
||
var task = newClient.PostAsync(ReplaceHeaderKey(webwxuploadmedia1[0]), requestContent);
|
||
var value = task.Result.Content.ReadAsStringAsync().Result;
|
||
Console.WriteLine(value);
|
||
|
||
//requestContent.Add(imageContent, "image", "image.jpg");
|
||
}
|
||
{
|
||
//SendHeader(httpclient, ReplaceHeaderKey(webwxuploadmedia1[1]));
|
||
|
||
//FileStream fs = File.OpenRead(filePath);
|
||
|
||
//byte[] temp = new byte[fs.Length];
|
||
//fs.Read(temp, 0, temp.Length);
|
||
|
||
//byte[] bs = Encoding.UTF8.GetBytes(ReplaceHeaderKey(webwxuploadmedia1body0).Replace("[CD]", temp.Length + "") + "\r\n\r\n");
|
||
|
||
//byte[] bsA = Encoding.UTF8.GetBytes("\r\n\r\n-----------------------------7e0d1f760df0");
|
||
//byte[] resArr = new byte[bs.Length + temp.Length + bsA.Length];
|
||
//bs.CopyTo(resArr, 0);
|
||
//temp.CopyTo(resArr, bs.Length);
|
||
//bsA.CopyTo(resArr, temp.Length + bs.Length);
|
||
|
||
|
||
//var task = httpclient.PostAsync(ReplaceKey(webwxuploadmedia1[0]), new ByteArrayContent(resArr));
|
||
//{
|
||
// var value = task.Result.Content.ReadAsStringAsync().Result;
|
||
// Console.WriteLine(value);
|
||
//}
|
||
}
|
||
}
|
||
|
||
private void webwxinit_old()
|
||
{
|
||
ShowMsg("webwxinit_old");
|
||
if (__5)
|
||
{
|
||
HttpWebRequest h = (HttpWebRequest)HttpWebRequest.Create(ReplaceKey(url_webwxinit[0]));
|
||
h.AllowAutoRedirect = false;
|
||
h.CookieContainer = cookieContainer;
|
||
h.Method = "POST";
|
||
h.Accept = "application/json, text/plain, */*";
|
||
h.ContentType = "application/json;charset=utf-8";
|
||
|
||
byte[] bs = Encoding.UTF8.GetBytes(ReplaceHeaderKey(@"{""BaseRequest"":{""Uin"":""{UIN}"",""Sid"":""{SID}"",""Skey"":""{SKEY}"",""DeviceID"":""{DeviceID}""}}"));
|
||
using (Stream reqStream = h.GetRequestStream())
|
||
{
|
||
reqStream.Write(bs, 0, bs.Length);
|
||
reqStream.Close();
|
||
}
|
||
HttpWebResponse r = (HttpWebResponse)h.GetResponse();
|
||
|
||
|
||
using (System.IO.StreamReader read = new System.IO.StreamReader(r.GetResponseStream()))
|
||
{
|
||
string value = read.ReadToEnd();
|
||
//"Ret": 1100,
|
||
if (!value.Contains("\"Ret\": 0"))
|
||
{
|
||
ShowMsg("没有返回正确的数据，webwxinit错误!");
|
||
throw new Exception("没有返回正确的数据，webwxinit错误!");
|
||
}
|
||
|
||
//USER_INFO
|
||
USER_INFO = SubString(value.Replace("\r", "").Replace("\n", ""), "\"User\": {", "NickName");
|
||
USER_INFO = SubString(USER_INFO, "\"UserName\": \"", "\",");
|
||
|
||
label1.Text = USER_INFO;
|
||
USER_DI.Add(USER_INFO, "我自己");
|
||
|
||
//SyncKey
|
||
SyncKey = SubString(value.Replace("\r", "").Replace("\n", ""), "\"SyncKey\": ", "}]}");
|
||
SyncKey += "}]}";
|
||
#if DEBUG
|
||
this.textBox1.Text = SyncKey;
|
||
#endif
|
||
}
|
||
r.Close();
|
||
|
||
|
||
}
|
||
}
|
||
|
||
|
||
//https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxgetvoice?msgid=8332473900244757099&skey=@crypt_39864b32_3b5756470b541ab03f03f519c0f1d2a9
|
||
|
||
void UploadWxImage(string MsgID, string Form, string FormName, string ad)
|
||
{
|
||
try
|
||
{
|
||
//下载图片
|
||
//https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxgetmsgimg?&MsgID=8055351800675473074&skey=%40crypt_671d6fec_1cd01b65296c06ef559ae98b0646725a&type=slave
|
||
//image/png,image/*;q=0.8,*/*;q=0.5
|
||
//&type=slave 获取缩略图的意思
|
||
Image img = DownLoadImage(MsgID);
|
||
|
||
//SendImage(Form, FormName, ad, img);
|
||
|
||
}
|
||
catch (Exception err)
|
||
{
|
||
#if DEBUG
|
||
SendMsg(Form, USER_INFO, err.Message, false);
|
||
#else
|
||
SendMsg(Form, USER_INFO, "接收图片出现错误!", false);
|
||
#endif
|
||
}
|
||
}
|
||
|
||
private Image DownLoadImage(string MsgID,string slave="&type=slave")
|
||
{
|
||
var url = "https://wx[number].qq.com/cgi-bin/mmwebwx-bin/webwxgetmsgimg?&MsgID={0}&skey={1}" + slave;
|
||
|
||
|
||
HttpWebRequest h = (HttpWebRequest)HttpWebRequest.Create(ReplaceHeaderKey(string.Format(url, MsgID, step4xml.skey)));
|
||
h.AllowAutoRedirect = false;
|
||
h.CookieContainer = cookieContainer;
|
||
h.Accept = "image/png,image/*;q=0.8,*/*;q=0.5";
|
||
HttpWebResponse r = (HttpWebResponse)h.GetResponse();
|
||
Image img = Image.FromStream(r.GetResponseStream());
|
||
r.Close();
|
||
return img;
|
||
}
|
||
|
||
//https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxgetvoice?msgid=8332473900244757099&skey=@crypt_39864b32_3b5756470b541ab03f03f519c0f1d2a9
|
||
//private Image DownLoadvoice(string MsgID)
|
||
//{
|
||
// var url = "https://wx[number].qq.com/cgi-bin/mmwebwx-bin/webwxgetvoice?&msgid={0}&skey={1}";
|
||
|
||
|
||
// HttpWebRequest h = (HttpWebRequest)HttpWebRequest.Create(ReplaceHeaderKey(string.Format(url, MsgID, step4xml.skey)));
|
||
// h.AllowAutoRedirect = false;
|
||
// h.CookieContainer = cookieContainer;
|
||
// //h.Accept = "image/png,image/*;q=0.8,*/*;q=0.5";
|
||
// HttpWebResponse r = (HttpWebResponse)h.GetResponse();
|
||
// MemoryStream ms = new MemoryStream(r.GetResponseStream());
|
||
// r.Close();
|
||
// return ms;
|
||
//}
|
||
|
||
|
||
|
||
void doStep7()
|
||
{
|
||
if (__7)
|
||
{
|
||
//https://webpush.weixin.qq.com/cgi-bin/mmwebwx-bin/synccheck?r=1444004057053&skey=%40crypt_39864b32_c5aaad7d38892d44fde5da7e97b32e69&sid=iM3uR2da1I2t0Upy&uin=840648442&deviceid=e013657496826621&synckey=1_634979925%7C2_634981902%7C3_634981851%7C11_634981845%7C201_1444003994%7C1000_1443952994&_=1444003858911
|
||
//var url = "https://webpush.weixin.qq.com/cgi-bin/mmwebwx-bin/synccheck?r={time}&skey={SKEY}&sid={SID}&uin={UIN}&deviceid={DeviceID}&synckey=1_634979925%7C2_634981902%7C3_634981851%7C11_634981845%7C201_1444003994%7C1000_1443952994&_=1444003858911
|
||
|
||
//var url = "https://wx2.qq.com/cgi-bin/mmwebwx-bin/webwxsync?sid={SID}&r={time}&skey={SKEY}";
|
||
var url = "https://wx[number].qq.com/cgi-bin/mmwebwx-bin/webwxsync?sid={SID}&skey={SKEY}&lang=zh_CN&pass_ticket={pass_ticket}";
|
||
|
||
HttpWebRequest h = (HttpWebRequest)HttpWebRequest.Create(ReplaceKey(url));
|
||
h.AllowAutoRedirect = false;
|
||
h.CookieContainer = cookieContainer;
|
||
h.Method = "POST";
|
||
h.Accept = "application/json, text/plain, */*";
|
||
h.ContentType = "application/json;charset=utf-8";
|
||
|
||
byte[] bs = Encoding.ASCII.GetBytes(ReplaceHeaderKey(@"{""BaseRequest"":{""Uin"":{UIN},""Sid"":""{SID}"",""Skey"":""{SKEY}"",""DeviceID"":""{DeviceID}""},""SyncKey"":{SyncKey},""rr"":{time}}"));
|
||
using (Stream reqStream = h.GetRequestStream())
|
||
{
|
||
reqStream.Write(bs, 0, bs.Length);
|
||
reqStream.Close();
|
||
}
|
||
|
||
HttpWebResponse r = (HttpWebResponse)h.GetResponse();
|
||
|
||
//var list = GetAllCookies(cookieContainer);
|
||
|
||
using (System.IO.StreamReader read = new System.IO.StreamReader(r.GetResponseStream()))
|
||
{
|
||
string value = read.ReadToEnd();
|
||
|
||
if (value.IndexOf("\"SyncKey\": ") == -1) throw new Exception("SyncKey 没有捕获到");
|
||
|
||
SyncKey = SubString(value.Replace("\r", "").Replace("\n", ""), "\"SyncKey\": ", "}]}");
|
||
SyncKey += "}]}";
|
||
|
||
//得到用户的消息
|
||
JavaScriptObject ret = JavaScriptConvert.DeserializeObject(value) as JavaScriptObject;
|
||
JavaScriptArray arr = ret["AddMsgList"] as JavaScriptArray;
|
||
foreach (JavaScriptObject obj in arr)
|
||
{
|
||
var content = obj["Content"].ToString().Replace(">", ">").Replace("<", "<").Replace("<br/>", "");
|
||
ShowMsg(content, obj);
|
||
|
||
//处理消息
|
||
DoMsg(content, obj, obj["MsgId"]+"");
|
||
}
|
||
}
|
||
r.Close();
|
||
}
|
||
}
|
||
|
||
void ShowMsg(string msg, JavaScriptObject obj = null)
|
||
{
|
||
DelegateFun.ExeControlFun(listBox1, new DelegateFun.delegateExeControlFun(delegate
|
||
{
|
||
//全部清除
|
||
if (listBox1.Items.Count > 3000) listBox1.Items.Clear();
|
||
|
||
Console.WriteLine("2=>" + msg);
|
||
listBox1.Items.Add(DateTime.Now + ">2=>" + msg);
|
||
if (obj != null)
|
||
{
|
||
var _FormUserName = obj["FromUserName"] + "";
|
||
var _ToUserName = obj["ToUserName"] + "";
|
||
var FormUserName = GetDIName(_FormUserName);
|
||
var ToUserName = GetDIName(_ToUserName);
|
||
|
||
listBox1.Items.Add(DateTime.Now + ">" + FormUserName + ">" + ToUserName + ":" + msg);
|
||
|
||
this.listBox1.TopIndex = this.listBox1.Items.Count - (int)(this.listBox1.Height / this.listBox1.ItemHeight);
|
||
}
|
||
|
||
//listBox1.
|
||
|
||
}));
|
||
}
|
||
|
||
/// <summary>
|
||
/// 给用户发送信息
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private void btnSend_Click(object sender, EventArgs e)
|
||
{
|
||
object user = lstBoxUser.SelectedItem;
|
||
if (user == null)
|
||
{
|
||
MessageBox.Show("请选择用户！");
|
||
return;
|
||
}
|
||
|
||
if (txtBoxMessage.Text == "")
|
||
{
|
||
MessageBox.Show("请输入信息！");
|
||
return;
|
||
}
|
||
|
||
string userid = user.ToString().Substring(user.ToString().LastIndexOf('>')+1);
|
||
|
||
SendMsg(userid, USER_INFO, txtBoxMessage.Text, false);
|
||
|
||
txtBoxMessage.Text = "";
|
||
}
|
||
|
||
public string USER_NICKNAME { get; set; }
|
||
|
||
private void btnGetUserList_Click(object sender, EventArgs e)
|
||
{
|
||
webwxgetcontact();
|
||
}
|
||
|
||
|
||
|
||
public Dictionary<string, string> COOKIES { get; set; }
|
||
}
|
||
}
|