XzyWeChatThread.cs 85 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224
  1. using Newtonsoft.Json;
  2. using SuperSocket.ClientEngine;
  3. using SuperSocket.ProtoBase;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Drawing;
  7. using System.Drawing.Imaging;
  8. using System.IO;
  9. using System.Net;
  10. using System.Net.Sockets;
  11. using System.Runtime.InteropServices;
  12. using System.Text;
  13. using System.Threading;
  14. using System.Threading.Tasks;
  15. using IPADDemo;
  16. using IPADDemo.Model;
  17. using IPADDemo.Util;
  18. using System.Configuration;
  19. using System.Text.RegularExpressions;
  20. using IPADDemo.AppData;
  21. namespace IPADDemo.WeChat
  22. {
  23. public class XzyWeChatThread
  24. {
  25. #region 全局变量
  26. public int pointerWxUser;
  27. public int pushStr;
  28. public int result;
  29. public int msgPtr;
  30. public int callBackMsg;
  31. public int redPack;
  32. public int readMember;
  33. public string bankerWxid = "";
  34. public string cheshouWxid = "";
  35. public string groupId = "";
  36. public object objGroup = new object();
  37. private WxUser wxUser = new WxUser();
  38. private List<WxGroup> wxGroup { get; set; }
  39. public Dictionary<string, string> dicRedPack { get; set; }
  40. public Dictionary<string, string> dicReadContent { get; set; }
  41. private EasyClient<StringPackageInfo> socketClient = null;
  42. private int mHeartBeatInterval = 1000 * 10;
  43. private int mReConnectionInterval = 1000 * 10;
  44. Random R = new Random();
  45. string RandomStr(int n)
  46. {
  47. List<int> ilist = new List<int>();
  48. for (int i = 0; i < n; i++)
  49. {
  50. ilist.Add(R.Next(0, 9));
  51. }
  52. return string.Join("", ilist);
  53. }
  54. Int64 RandomL(int n)
  55. {
  56. List<int> ilist = new List<int>();
  57. for (int i = 0; i < n; i++)
  58. {
  59. ilist.Add(R.Next(0, 9));
  60. }
  61. return Convert.ToInt64(string.Join("", ilist));
  62. }
  63. string Mac
  64. {
  65. get
  66. {
  67. //return "0016D3B5C493";
  68. int min = 0;
  69. int max = 16;
  70. Random ro = new Random();
  71. var sn = string.Format("{0}{1}{2}{3}{4}{5}{6}{7}{8}{9}{10}{11}",
  72. ro.Next(min, max).ToString("x"),//0
  73. ro.Next(min, max).ToString("x"),//
  74. ro.Next(min, max).ToString("x"),
  75. ro.Next(min, max).ToString("x"),
  76. ro.Next(min, max).ToString("x"),
  77. ro.Next(min, max).ToString("x"),//5
  78. ro.Next(min, max).ToString("x"),
  79. ro.Next(min, max).ToString("x"),
  80. ro.Next(min, max).ToString("x"),
  81. ro.Next(min, max).ToString("x"),
  82. ro.Next(min, max).ToString("x"),//10
  83. ro.Next(min, max).ToString("x")
  84. ).ToUpper();
  85. return sn;
  86. }
  87. }
  88. string UUID
  89. {
  90. get
  91. {
  92. return RandomStr(8) + "-" + RandomStr(4) + "-" + RandomL(4).ToString("X") + "-" + RandomL(4).ToString("X") + "-" + RandomL(12).ToString("X");
  93. }
  94. }
  95. #endregion
  96. #region 微信委托
  97. public XzyWxApis.DllcallBack msgCallBack { get; set; }
  98. #endregion
  99. #region 定时器
  100. /// <summary>
  101. /// 心跳检查定时器
  102. /// </summary>
  103. private System.Threading.Timer tmrHeartBeat = null;
  104. /// <summary>
  105. /// 断线重连定时器
  106. /// </summary>
  107. private System.Threading.Timer tmrReConnection = null;
  108. #endregion
  109. #region 构造函数
  110. /// <summary>
  111. /// 初始化,并且使用二维码登录。并且初始化一些计时器,但实际上这些计时器没有什么用。这些计时器,应该是为了实现类似signalr的功能
  112. /// </summary>
  113. public XzyWeChatThread()
  114. {
  115. dicRedPack = new Dictionary<string, string>();
  116. dicReadContent = new Dictionary<string, string>();
  117. Task.Factory.StartNew(() =>
  118. {
  119. this.Init();
  120. });
  121. msgCallBack += new XzyWxApis.DllcallBack(Wx_MsgCallBack);
  122. tmrHeartBeat = new System.Threading.Timer(HeartBeatCallBack, null, mHeartBeatInterval, mHeartBeatInterval);
  123. tmrReConnection = new System.Threading.Timer(ReConnectionCallBack, null, mReConnectionInterval, mReConnectionInterval);
  124. SocketStart(null);
  125. }
  126. /// <summary>
  127. /// 62数据登陆,并且初始化一些计时器,但实际上这些计时器没有什么用。这些计时器,应该是为了实现类似signalr的功能
  128. /// </summary>
  129. /// <param name="str16"></param>
  130. /// <param name="WxUsername"></param>
  131. /// <param name="wxpassword"></param>
  132. public XzyWeChatThread(string str16, string WxUsername, string wxpassword)
  133. {
  134. dicRedPack = new Dictionary<string, string>();
  135. dicReadContent = new Dictionary<string, string>();
  136. Task.Factory.StartNew(() =>
  137. {
  138. this.Init62(str16, WxUsername, wxpassword);
  139. });
  140. msgCallBack += new XzyWxApis.DllcallBack(Wx_MsgCallBack);
  141. tmrHeartBeat = new System.Threading.Timer(HeartBeatCallBack, null, mHeartBeatInterval, mHeartBeatInterval);
  142. tmrReConnection = new System.Threading.Timer(ReConnectionCallBack, null, mReConnectionInterval, mReConnectionInterval);
  143. SocketStart(null);
  144. }
  145. #endregion
  146. #region 全局方法
  147. #region socket
  148. /// <summary>
  149. /// socket启动
  150. /// </summary>
  151. /// <param name="a"></param>
  152. private async void SocketStart(object a)
  153. {
  154. try
  155. {
  156. //初始化并启动客户端引擎(TCP、文本协议)
  157. socketClient = new EasyClient<StringPackageInfo>()
  158. {
  159. ReceiveBufferSize = 65535
  160. };
  161. socketClient.Initialize(new MyTerminatorReceiveFilter());
  162. socketClient.Connected += client_Connected;
  163. socketClient.NewPackageReceived += client_NewPackageReceived;
  164. socketClient.Closed += client_Closed;
  165. socketClient.Error += client_Error;//192.168.0.102
  166. var connected = await socketClient.ConnectAsync(new System.Net.DnsEndPoint(CS.IP, 9000));
  167. if (connected && socketClient.IsConnected)
  168. {
  169. ShowMessage("连接成功!");
  170. if (this.wxUser.wxid != "")
  171. {
  172. TcpSendMsg(TcpMsg.OL, wxUser);
  173. if (wxGroup != null)
  174. {
  175. this.Wx_GetContacts();
  176. }
  177. }
  178. }
  179. else
  180. {
  181. ShowMessage("连接失败!");
  182. }
  183. }
  184. catch (Exception ex)
  185. {
  186. ShowMessage(string.Format("连接服务器失败:{0}", ex.Message));
  187. }
  188. }
  189. /// <summary>
  190. /// 接收消息
  191. /// </summary>
  192. /// <param name="sender"></param>
  193. /// <param name="e"></param>
  194. void client_NewPackageReceived(object sender, PackageEventArgs<StringPackageInfo> e)
  195. {
  196. var body = e.Package.Body;
  197. MsgContent json = null;
  198. switch (e.Package.Key)
  199. {
  200. case TcpMsg.content:
  201. json = Newtonsoft.Json.JsonConvert.DeserializeObject<MsgContent>(body);
  202. this.Wx_SendMsg(json.towxid, json.content);
  203. break;
  204. case TcpMsg.img:
  205. json = Newtonsoft.Json.JsonConvert.DeserializeObject<MsgContent>(body);
  206. this.Wx_SendImg(json.towxid, json.ImgPath);
  207. break;
  208. case TcpMsg.redpack:
  209. //json = Newtonsoft.Json.JsonConvert.DeserializeObject<MsgContent>(body);
  210. //var key = json.content;
  211. //await Task.Factory.StartNew(() =>
  212. //{
  213. // this.RedpackOK2(key);
  214. //});
  215. //this.RedpackOK2(key, 0);
  216. break;
  217. case TcpMsg.BankerConfig:
  218. var BankerConfig = Newtonsoft.Json.JsonConvert.DeserializeObject<BankerConfig>(body);
  219. switch (BankerConfig.code)
  220. {
  221. case 1: groupId = BankerConfig.wxid; break;
  222. case 2: bankerWxid = BankerConfig.wxid; break;
  223. case 3: cheshouWxid = BankerConfig.wxid; break;
  224. }
  225. break;
  226. }
  227. ShowMessage(e.Package.Body);
  228. }
  229. /// <summary>
  230. /// socket 异常回调
  231. /// </summary>
  232. /// <param name="sender"></param>
  233. /// <param name="e"></param>
  234. void client_Error(object sender, global::SuperSocket.ClientEngine.ErrorEventArgs e)
  235. {
  236. if (e.Exception.GetType() == typeof(System.Net.Sockets.SocketException))
  237. {
  238. var socketExceptin = e.Exception as System.Net.Sockets.SocketException;
  239. if (socketExceptin.SocketErrorCode == SocketError.ConnectionRefused)
  240. {
  241. ShowMessage("错误:请先启动AppServer 服务端!");
  242. }
  243. else
  244. ShowMessage("错误:" + e.Exception.Message);
  245. }
  246. else
  247. ShowMessage("错误:" + e.Exception.Message);
  248. }
  249. /// <summary>
  250. /// socket断开回调
  251. /// </summary>
  252. /// <param name="sender"></param>
  253. /// <param name="e"></param>
  254. void client_Closed(object sender, EventArgs e)
  255. {
  256. ShowMessage("您已经掉线!");
  257. SocketStart(null);
  258. }
  259. /// <summary>
  260. /// socket连接成功回调
  261. /// </summary>
  262. /// <param name="sender"></param>
  263. /// <param name="e"></param>
  264. void client_Connected(object sender, EventArgs e)
  265. {
  266. ShowMessage("连接成功!");
  267. }
  268. /// <summary>
  269. /// socket发送消息
  270. /// </summary>
  271. /// <param name="TcpMsg"></param>
  272. /// <param name="content"></param>
  273. void TcpSendMsg(string TcpMsg, object content)
  274. {
  275. if (socketClient != null && socketClient.IsConnected)
  276. {
  277. var json = TcpMsg + " " + Newtonsoft.Json.JsonConvert.SerializeObject(content) + Environment.NewLine;
  278. var data = Encoding.UTF8.GetBytes(json);
  279. socketClient.Send(new ArraySegment<byte>(data, 0, data.Length));
  280. }
  281. }
  282. /// <summary>
  283. /// 心跳包
  284. /// </summary>
  285. /// <param name="state"></param>
  286. private void HeartBeatCallBack(object state)
  287. {
  288. try
  289. {
  290. tmrHeartBeat.Change(Timeout.Infinite, Timeout.Infinite);
  291. if (socketClient != null && socketClient.IsConnected)
  292. {
  293. var sbMessage = new StringBuilder();
  294. sbMessage.AppendFormat(string.Format("heartbeat #{0}#\r\n", "心跳数据包:ok"));
  295. var data = Encoding.UTF8.GetBytes(sbMessage.ToString());
  296. socketClient.Send(new ArraySegment<byte>(data, 0, data.Length));
  297. }
  298. }
  299. finally
  300. {
  301. tmrHeartBeat.Change(mHeartBeatInterval, mHeartBeatInterval);
  302. }
  303. }
  304. /// <summary>
  305. /// 掉线重连
  306. /// </summary>
  307. /// <param name="state"></param>
  308. private void ReConnectionCallBack(object state)
  309. {
  310. try
  311. {
  312. tmrReConnection.Change(Timeout.Infinite, Timeout.Infinite);
  313. if (socketClient != null &&
  314. socketClient.IsConnected == false)
  315. {
  316. SocketStart(null);
  317. //btnOpen_Click(null, null);
  318. }
  319. }
  320. finally
  321. {
  322. tmrReConnection.Change(mHeartBeatInterval, mHeartBeatInterval);
  323. }
  324. }
  325. #endregion
  326. /// <summary>
  327. /// 登录
  328. /// </summary>
  329. public unsafe void Init()
  330. {
  331. fixed (int* WxUser1 = &pointerWxUser, pushStr1 = &pushStr)
  332. {
  333. //string version = System.Reflection.Assembly.LoadFrom("wxipadapi.dll").GetName().Version.ToString();
  334. //WxDelegate.show("版本信息:" + version);
  335. string uid = UUID;
  336. var mac = Mac;
  337. //var ret = XzyAuth.Init();
  338. //if (ret == 1)
  339. //{
  340. var ret = XzyAuth.Init(ConfigurationSettings.AppSettings["AuthKey"].ToString());
  341. //}
  342. WxDelegate.show("授权结果:" + ret);
  343. var key = string.Format(@"<softtype><k3>11.0.1</k3><k9>iPad</k9><k10>2</k10><k19>58BF17B5-2D8E-4BFB-A97E-38F1226F13F8</k19><k20>{0}</k20><k21>neihe_5GHz</k21><k22>(null)</k22><k24>{1}</k24><k33>\345\276\256\344\277\241</k33><k47>1</k47><k50>1</k50><k51>com.tencent.xin</k51><k54>iPad4,4</k54></softtype>", UUID, Mac);
  344. XzyWxApis.WXInitialize((int)WxUser1, "张三的IPAD", key, UUID);
  345. XzyWxApis.WXSetRecvMsgCallBack(pointerWxUser, msgCallBack);
  346. XzyWxApis.WXGetQRCode(pointerWxUser, (int)pushStr1);
  347. var msg = Marshal.PtrToStringAnsi(new IntPtr(Convert.ToInt32(pushStr)));
  348. WxQrCode qr_code = JsonConvert.DeserializeObject<WxQrCode>(msg);//反序列化
  349. //var img = MyUtils.Base64StringToImage(qr_code.QrCodeStr);
  350. WxDelegate.qrCode(qr_code.QrCodeStr);
  351. Wx_ReleaseEX(ref pushStr);
  352. QrCodeJson QRCodejson = null;
  353. while (true)
  354. {
  355. Thread.Sleep(500);
  356. XzyWxApis.WXCheckQRCode(pointerWxUser, (int)pushStr1);
  357. var datas = MarshalNativeToManaged((IntPtr)pushStr);
  358. if (datas == null)
  359. {
  360. continue;
  361. }
  362. string sstr = datas.ToString();
  363. QRCodejson = Newtonsoft.Json.JsonConvert.DeserializeObject<QrCodeJson>(sstr);//反序列化
  364. Wx_ReleaseEX(ref pushStr);
  365. bool breakok = false;
  366. switch (QRCodejson.Status)
  367. {
  368. case 0: WxDelegate.show("请扫描二维码"); break;
  369. case 1: WxDelegate.show("请点在手机上点确认"); break;
  370. case 2: WxDelegate.show("正在登录中.."); breakok = true; break;
  371. case 3: WxDelegate.show("已过期"); break;
  372. case 4: WxDelegate.show("取消操作了"); breakok = true; break;
  373. }
  374. if (breakok) { break; }
  375. }
  376. if (QRCodejson.Status == 2)
  377. {
  378. var username = QRCodejson.UserName;
  379. this.wxUser.wxid = QRCodejson.UserName;
  380. this.wxUser.name = QRCodejson.NickName;
  381. var pass = QRCodejson.Password;
  382. XzyWxApis.WXQRCodeLogin(pointerWxUser, username, pass, (int)pushStr1);
  383. var datas = MarshalNativeToManaged((IntPtr)pushStr);
  384. string sstr = datas.ToString();
  385. Wx_ReleaseEX(ref pushStr);
  386. UserData userdata = Newtonsoft.Json.JsonConvert.DeserializeObject<UserData>(sstr);//反序列化
  387. if (userdata.Status == -301)
  388. {
  389. XzyWxApis.WXQRCodeLogin(pointerWxUser, username, pass, (int)pushStr1);
  390. datas = MarshalNativeToManaged((IntPtr)pushStr);
  391. sstr = datas.ToString();
  392. Wx_ReleaseEX(ref pushStr);
  393. WxDelegate.show("微信重定向");
  394. userdata = Newtonsoft.Json.JsonConvert.DeserializeObject<UserData>(sstr);//反序列化
  395. if (userdata.Status == 0)
  396. {
  397. WxDelegate.show("登录成功");
  398. XzyWxApis.WXHeartBeat(pointerWxUser, (int)pushStr1);
  399. datas = MarshalNativeToManaged((IntPtr)pushStr);
  400. sstr = datas.ToString();
  401. Wx_ReleaseEX(ref pushStr);
  402. this.TcpSendMsg(TcpMsg.OL, this.wxUser);
  403. Task.Factory.StartNew(delegate { this.Wx_GetContacts(); });
  404. return;
  405. }
  406. else
  407. {
  408. WxDelegate.show("登录失败");
  409. }
  410. }
  411. if (userdata.Status == 0)
  412. {
  413. WxDelegate.show("登录成功");
  414. XzyWxApis.WXHeartBeat(pointerWxUser, (int)pushStr1);
  415. datas = MarshalNativeToManaged((IntPtr)pushStr);
  416. sstr = datas.ToString();
  417. Wx_ReleaseEX(ref pushStr);
  418. this.TcpSendMsg(TcpMsg.OL, this.wxUser);
  419. Task.Factory.StartNew(delegate { this.Wx_GetContacts(); });
  420. return;
  421. }
  422. else
  423. {
  424. WxDelegate.show("登录失败");
  425. }
  426. }
  427. }
  428. }
  429. /// <summary>
  430. /// 初始化62数据
  431. /// </summary>
  432. /// <param name="str16"></param>
  433. /// <param name="WxUsername"></param>
  434. /// <param name="wxpassword"></param>
  435. public unsafe void Init62(string str16, string WxUsername, string wxpassword)
  436. {
  437. fixed (int* WxUser1 = &pointerWxUser, pushStr1 = &pushStr)
  438. {
  439. //var ret = XzyAuth.Init();
  440. //if (ret == 1)
  441. //{
  442. var ret = XzyAuth.Init(ConfigurationSettings.AppSettings["AuthKey"].ToString());
  443. //}
  444. string uid = UUID;
  445. var mac = Mac;
  446. var key = string.Format($@"<softtype><k3>11.0.1</k3><k9>iPad</k9><k10>2</k10><k19>{Guid.NewGuid()}</k19><k20>{0}</k20><k21>neihe_5GHz</k21><k22>(null)</k22><k24>{1}</k24><k33>\345\276\256\344\277\241</k33><k47>1</k47><k50>1</k50><k51>com.tencent.xin</k51><k54>iPad5,5</k54></softtype>", UUID, Mac);
  447. XzyWxApis.WXInitialize((int)WxUser1, "xzyIPAD", key, UUID);
  448. XzyWxApis.WXSetRecvMsgCallBack(pointerWxUser, msgCallBack);
  449. //62数据是扫码登录成功后,再获取,并保存下来,而不是其它方式登录后再保存。并且还要使用方法WXGetLoginToken保存下token
  450. #region 使用62数据自动登录,在扫码登录后,会得到62数据及token,传入到这里即可实现自动登录
  451. //加载62数据
  452. byte[] data62Bytes = Convert.FromBase64String(str16);
  453. XzyWxApis.WXLoadWxDat(pointerWxUser, data62Bytes, data62Bytes.Length, (int)pushStr1);
  454. var datas1 = MarshalNativeToManaged((IntPtr)pushStr);
  455. var sstr1 = datas1.ToString();
  456. if (string.IsNullOrEmpty(sstr1))
  457. {
  458. WxDelegate.show("登陆失败,重新登录");
  459. }
  460. Wx_ReleaseEX(ref pushStr);
  461. #endregion
  462. //以下是使用账号密码登录,已经测试成功。账号:13127873237,密码:Taobao123
  463. XzyWxApis.WXUserLogin(pointerWxUser, WxUsername, wxpassword, (int)pushStr1);
  464. var datas = MarshalNativeToManaged((IntPtr)pushStr);
  465. var sstr = datas.ToString();
  466. Wx_ReleaseEX(ref pushStr);
  467. UserData userdata = Newtonsoft.Json.JsonConvert.DeserializeObject<UserData>(sstr);//反序列化
  468. if (userdata.Status == -301)
  469. {
  470. XzyWxApis.WXUserLogin(pointerWxUser, WxUsername, wxpassword, (int)pushStr1);
  471. datas = MarshalNativeToManaged((IntPtr)pushStr);
  472. sstr = datas.ToString();
  473. Wx_ReleaseEX(ref pushStr);
  474. WxDelegate.show("微信重定向");
  475. userdata = Newtonsoft.Json.JsonConvert.DeserializeObject<UserData>(sstr);//反序列化
  476. this.wxUser.wxid = userdata.UserName;
  477. this.wxUser.name = userdata.NickName;
  478. if (userdata.Status == 0)
  479. {
  480. WxDelegate.show("登录成功");
  481. XzyWxApis.WXHeartBeat(pointerWxUser, (int)pushStr1);
  482. datas = MarshalNativeToManaged((IntPtr)pushStr);
  483. sstr = datas.ToString();
  484. Wx_ReleaseEX(ref pushStr);
  485. this.TcpSendMsg(TcpMsg.OL, this.wxUser);
  486. Task.Factory.StartNew(delegate { this.Wx_GetContacts(); });
  487. //:登录成功后,取出token备用
  488. XzyWxApis.WXGetLoginToken(pointerWxUser, (int)pushStr1);
  489. var datas3 = MarshalNativeToManaged((IntPtr)pushStr);
  490. var sstr3 = datas3.ToString();
  491. var tokenData = Newtonsoft.Json.JsonConvert.DeserializeAnonymousType(sstr3, new { Token = "" });
  492. Wx_ReleaseEX(ref pushStr);
  493. return;
  494. }
  495. else
  496. {
  497. WxDelegate.show("登录失败");
  498. }
  499. }
  500. if (userdata.Status == 0)
  501. {
  502. WxDelegate.show("登录成功");
  503. XzyWxApis.WXHeartBeat(pointerWxUser, (int)pushStr1);
  504. datas = MarshalNativeToManaged((IntPtr)pushStr);
  505. sstr = datas.ToString();
  506. Wx_ReleaseEX(ref pushStr);
  507. this.wxUser.wxid = userdata.UserName;
  508. this.wxUser.name = userdata.NickName;
  509. this.TcpSendMsg(TcpMsg.OL, this.wxUser);
  510. Task.Factory.StartNew(delegate { this.Wx_GetContacts(); });
  511. //:登录成功后,取出token备用
  512. XzyWxApis.WXGetLoginToken(pointerWxUser, (int)pushStr1);
  513. var datas3 = MarshalNativeToManaged((IntPtr)pushStr);
  514. var sstr3 = datas3.ToString();
  515. var tokenData = Newtonsoft.Json.JsonConvert.DeserializeAnonymousType(sstr3, new { Token = "" });
  516. Wx_ReleaseEX(ref pushStr);
  517. return;
  518. }
  519. else
  520. {
  521. WxDelegate.show("登录失败");
  522. }
  523. }
  524. }
  525. public object MarshalNativeToManaged(IntPtr pNativeData)
  526. {
  527. try
  528. {
  529. if (pNativeData == IntPtr.Zero)
  530. {
  531. return null;
  532. }
  533. List<byte> list = new List<byte>();
  534. int num = 0;
  535. for (; ; )
  536. {
  537. byte b = Marshal.ReadByte(pNativeData, num);
  538. if (b == 0)
  539. {
  540. break;
  541. }
  542. list.Add(b);
  543. num++;
  544. }
  545. return Encoding.UTF8.GetString(list.ToArray(), 0, list.Count);
  546. }
  547. catch
  548. {
  549. return null;
  550. }
  551. }
  552. /// <summary>
  553. /// 图片转byte
  554. /// </summary>
  555. /// <param name="image"></param>
  556. /// <returns></returns>
  557. public byte[] ImageToBytes(Image image)
  558. {
  559. ImageFormat format = image.RawFormat;
  560. using (MemoryStream ms = new MemoryStream())
  561. {
  562. if (format.Equals(ImageFormat.Jpeg))
  563. {
  564. image.Save(ms, ImageFormat.Jpeg);
  565. }
  566. else if (format.Equals(ImageFormat.Png))
  567. {
  568. image.Save(ms, ImageFormat.Png);
  569. }
  570. else if (format.Equals(ImageFormat.Bmp))
  571. {
  572. image.Save(ms, ImageFormat.Bmp);
  573. }
  574. else if (format.Equals(ImageFormat.Gif))
  575. {
  576. image.Save(ms, ImageFormat.Gif);
  577. }
  578. else if (format.Equals(ImageFormat.Icon))
  579. {
  580. image.Save(ms, ImageFormat.Icon);
  581. }
  582. byte[] buffer = new byte[ms.Length];
  583. //Image.Save()会改变MemoryStream的Position,需要重新Seek到Begin
  584. ms.Seek(0, SeekOrigin.Begin);
  585. ms.Read(buffer, 0, buffer.Length);
  586. return buffer;
  587. }
  588. }
  589. /// <summary>
  590. /// 打印消息
  591. /// </summary>
  592. /// <param name="msg"></param>
  593. private void ShowMessage(string msg)
  594. {
  595. Console.WriteLine(msg);
  596. }
  597. public static int TimeStamp
  598. {
  599. get
  600. {
  601. TimeSpan ts = DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0);
  602. return Convert.ToInt32(ts.TotalSeconds - 180);
  603. }
  604. }
  605. #endregion
  606. #region 微信方法
  607. #region 微信消息
  608. /// <summary>
  609. /// 发消息 -文字
  610. /// </summary>
  611. /// <param name="wxid"></param>
  612. /// <param name="content"></param>
  613. public unsafe void Wx_SendMsg(string wxid, string content)
  614. {
  615. WxDelegate.show(string.Format("发送文字: {0}", content));
  616. content = content.Replace(" ", "\r\n");
  617. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  618. {
  619. XzyWxApis.WXSendMsg(pointerWxUser, wxid, content, null, (int)msgptr1);
  620. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  621. var str = datas.ToString();
  622. Wx_ReleaseEX(ref msgPtr);
  623. }
  624. }
  625. private int wx_imptr;
  626. /// <summary>
  627. /// 发消息 - 图片
  628. /// </summary>
  629. /// <param name="wxid"></param>
  630. /// <param name="imgpath"></param>
  631. public unsafe void Wx_SendImg(string wxid, string imgpath)
  632. {
  633. WxDelegate.show(string.Format("发送图片 :{0}", imgpath));
  634. fixed (int* WxUser1 = &pointerWxUser, imptr1 = &wx_imptr)
  635. {
  636. try
  637. {
  638. Image _image = Image.FromStream(WebRequest.Create(imgpath).GetResponse().GetResponseStream());
  639. //把文件读取到字节数组
  640. byte[] data = this.ImageToBytes(_image);
  641. if (data.Length > 0)
  642. {
  643. XzyWxApis.WXSendImage(pointerWxUser, wxid, data, data.Length, (int)imptr1);
  644. var datas = MarshalNativeToManaged((IntPtr)wx_imptr);
  645. var str = datas.ToString();
  646. Wx_ReleaseEX(ref wx_imptr);
  647. }
  648. _image = null;
  649. }
  650. catch { }
  651. }
  652. }
  653. /// <summary>
  654. /// 发语音 - silk
  655. /// </summary>
  656. /// <param name="wxid"></param>
  657. /// <param name="imgpath"></param>
  658. public unsafe string Wx_SendVoice(string wxid, string silkpath, int time)
  659. {
  660. var result = "";
  661. fixed (int* WxUser1 = &pointerWxUser, imptr1 = &wx_imptr)
  662. {
  663. try
  664. {
  665. FileStream fs = new FileStream(silkpath, FileMode.Open, FileAccess.Read);
  666. //获取文件大小
  667. long size = fs.Length;
  668. byte[] data = new byte[size];
  669. //将文件读到byte数组中
  670. fs.Read(data, 0, data.Length);
  671. fs.Close();
  672. if (data.Length > 0)
  673. {
  674. XzyWxApis.WXSendVoice(pointerWxUser, wxid, data, data.Length, time * 1000, (int)imptr1);
  675. var datas = MarshalNativeToManaged((IntPtr)wx_imptr);
  676. result = datas.ToString();
  677. Wx_ReleaseEX(ref wx_imptr);
  678. }
  679. }
  680. catch { }
  681. }
  682. return result;
  683. }
  684. /// <summary>
  685. /// 分享名片
  686. /// </summary>
  687. /// <param name="user"></param>
  688. /// <param name="wxid"></param>
  689. /// <param name="title"></param>
  690. /// <returns></returns>
  691. public unsafe string Wx_ShareCard(string user, string wxid, string title)
  692. {
  693. var result = "";
  694. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  695. {
  696. msgPtr = EShareCarde(pointerWxUser, user, wxid, title);
  697. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  698. result = datas.ToString();
  699. Wx_ReleaseEX(ref wx_imptr);
  700. }
  701. return result;
  702. }
  703. /// <summary>
  704. /// 微信消息 - 回调
  705. /// </summary>
  706. /// <param name="a"></param>
  707. /// <param name="b"></param>
  708. public unsafe void Wx_MsgCallBack(int a, int b)
  709. {
  710. if (b == -1)
  711. {
  712. TcpSendMsg(TcpMsg.Out, wxUser);
  713. return;
  714. }
  715. fixed (int* wxUser1 = &pointerWxUser, callBackMsg1 = &callBackMsg)
  716. {
  717. try
  718. {
  719. XzyWxApis.WXSyncMessage(pointerWxUser, (int)callBackMsg1);
  720. if (callBackMsg == 0)
  721. {
  722. return;
  723. }
  724. var str = MarshalNativeToManaged((IntPtr)callBackMsg).ToString();
  725. List<BackWxMsg> BackWxMsg = new List<BackWxMsg>();
  726. Wx_ReleaseEX(ref callBackMsg);
  727. List<WxTtsMsg> WXttsmsg = Newtonsoft.Json.JsonConvert.DeserializeObject<List<WxTtsMsg>>(str);
  728. foreach (var msg in WXttsmsg)
  729. {
  730. var msgtype = msg.MsgType;
  731. var content = msg.Content;
  732. var sub_type = msg.SubType;
  733. var MsgId = msg.MsgId;
  734. if (msg.Timestamp < TimeStamp)
  735. {
  736. continue;
  737. }
  738. //32768 主动删除好友
  739. //5 浏览通知。比如手机上打开群时,会得到5的通知
  740. //2048 估计是二维码登录成功的通知
  741. //Timestamp = 1520153620
  742. //<msg><appmsg appid="" sdkver=""><title><![CDATA[邀请你加入群聊]]></title><des><![CDATA["红毛哥哥,(招财进宝)"邀请你加入群聊🌸 招财进宝🌸 三点比!!,进入可查看详情。]]></des><action>view</action><type>5</type><showtype>0</showtype><content></content><url><![CDATA[http://support.weixin.qq.com/cgi-bin/mmsupport-bin/addchatroombyinvite?ticket=AxmPr0y71kZ0GHNfgHzvMA%3D%3D]]></url><thumburl><![CDATA[http://weixin.qq.com/cgi-bin/getheadimg?username=c718f942d57830318779f76095c014e2f561b16364ef1eef132a316aa94fcc5a]]></thumburl><lowurl></lowurl><appattach><totallen>0</totallen><attachid></attachid><fileext></fileext></appattach><extinfo></extinfo></appmsg><appinfo><version></version><appname></appname></appinfo></msg>
  743. if (sub_type == 42)
  744. {
  745. var username = Utilities.GetMidStr(msg.Content, "username=\"", "\" nickname=").Trim();
  746. if (username.Length > 20)
  747. {
  748. //v1
  749. }
  750. }
  751. //判断此消息是否已经处理过。若未处理,才会进入里面处理
  752. if (Wx_SetMsgKey(MsgId))
  753. {
  754. WxDelegate.msgCallBack(msg);
  755. if (sub_type == 49)
  756. {
  757. if (content.IndexOf("加入群聊") != -1)
  758. {
  759. var url = Utilities.GetMidStr(content, "<url><![CDATA[", "]]>");
  760. Task.Factory.StartNew(delegate { Wx_IntoGroup(url); });
  761. }
  762. else if (content.IndexOf("微信转账") != -1)//当sub_type=49,并且content内容包含“微信转账”时,表示这是一笔微信转账通知
  763. {
  764. Task.Factory.StartNew(delegate
  765. {
  766. fixed (int* WxUser1 = &pointerWxUser, pushStr1 = &pushStr)
  767. {
  768. XzyWxApis.WXTransferOperation(pointerWxUser, Newtonsoft.Json.JsonConvert.SerializeObject(msg), (int)pushStr1);
  769. var datas23 = MarshalNativeToManaged((IntPtr)pushStr);
  770. var str23 = datas23.ToString();
  771. WxDelegate.show(str23);
  772. Wx_ReleaseEX(ref pushStr);
  773. }
  774. });
  775. }
  776. }
  777. if (sub_type == 10000)
  778. {
  779. if (msg.Content.IndexOf("邀请") != -1)
  780. {
  781. //更新群成员
  782. if (wxGroup != null)
  783. {
  784. Task.Factory.StartNew(delegate { Wx_SetGroup(msg.FromUser); });
  785. }
  786. }
  787. }
  788. if (sub_type == 10002)
  789. {
  790. if (msg.Content.IndexOf("撤回") != -1)
  791. {
  792. //<newmsgid>7189063840892613759</newmsgid>
  793. //撤回消息
  794. var chid = Utilities.GetMidStr(msg.Content, "<newmsgid>", "</newmsgid>");
  795. if (chid != "")
  796. {
  797. BackWxMsg chmsg = new BackWxMsg();
  798. chmsg.wxid = this.wxUser.wxid;
  799. chmsg.groupid = msg.FromUser;
  800. chmsg.msgid = MsgId;
  801. chmsg.chmsgid = chid;
  802. BackWxMsg.Add(chmsg);
  803. }
  804. }
  805. }
  806. if (sub_type == 1) //文字消息
  807. {
  808. if (content != null)
  809. {
  810. var des = content.Trim();
  811. if (des != "")
  812. {
  813. Console.WriteLine(des + "--" + sub_type.ToString());
  814. //来源
  815. var from_user = msg.FromUser;
  816. var arr = msg.Content.Trim().Split(new string[] { ":\n" }, StringSplitOptions.None);
  817. if (arr.Length >= 2)
  818. {
  819. BackWxMsg BackWxMsgs = new BackWxMsg();
  820. BackWxMsgs.wxid = arr[0];
  821. arr[0] = "";
  822. BackWxMsgs.content = string.Join("", arr);
  823. BackWxMsgs.groupid = from_user;
  824. BackWxMsgs.inputtime = msg.Timestamp;
  825. BackWxMsgs.msgid = MsgId;
  826. BackWxMsgs.chmsgid = null;
  827. BackWxMsg.Add(BackWxMsgs);
  828. }
  829. }
  830. }
  831. }
  832. else if (sub_type == 49 && content.IndexOf("CDATA[1002]") != -1) //红包
  833. {
  834. var redpackjson = Newtonsoft.Json.JsonConvert.SerializeObject(msg);
  835. var packtouser = msg.ToUser;//发包人
  836. var packforuser = msg.FromUser;//qun
  837. Dictionary<string, packitme> data = null;
  838. Task.Factory.StartNew(delegate { data = RedpackOK(redpackjson, msg.Timestamp); });
  839. }
  840. else if (sub_type == 3 || sub_type == 47) //图片
  841. {
  842. Task.Factory.StartNew(delegate
  843. {
  844. fixed (int* WxUser1 = &pointerWxUser, pushStr1 = &pushStr)
  845. {
  846. XzyWxApis.WXGetMsgImage(pointerWxUser, Newtonsoft.Json.JsonConvert.SerializeObject(msg), (int)pushStr1);
  847. var datas23 = MarshalNativeToManaged((IntPtr)pushStr);
  848. var str23 = datas23.ToString();
  849. //取base64转码图片
  850. WxDelegate.show(str23);
  851. Wx_ReleaseEX(ref pushStr);
  852. }
  853. });
  854. }
  855. else if (sub_type == 34)//34指语音消息,
  856. {
  857. Task.Factory.StartNew(delegate
  858. {
  859. fixed (int* WxUser1 = &pointerWxUser, pushStr1 = &pushStr)
  860. {
  861. XzyWxApis.WXGetMsgVoice(pointerWxUser, Newtonsoft.Json.JsonConvert.SerializeObject(msg), (int)pushStr1);
  862. var datas23 = MarshalNativeToManaged((IntPtr)pushStr);
  863. var str23 = datas23.ToString();
  864. //取base64转码语音
  865. WxDelegate.show(str23);
  866. Wx_ReleaseEX(ref pushStr);
  867. }
  868. });
  869. }
  870. else if (sub_type == 43)//视频
  871. {
  872. Task.Factory.StartNew(delegate
  873. {
  874. fixed (int* WxUser1 = &pointerWxUser, pushStr1 = &pushStr)
  875. {
  876. XzyWxApis.WXGetMsgVideo(pointerWxUser, Newtonsoft.Json.JsonConvert.SerializeObject(msg), (int)pushStr1);
  877. var datas23 = MarshalNativeToManaged((IntPtr)pushStr);
  878. var str23 = datas23.ToString();
  879. //取base64转码视频
  880. WxDelegate.show(str23);
  881. Wx_ReleaseEX(ref pushStr);
  882. }
  883. });
  884. }
  885. else if (sub_type == 37)
  886. {
  887. //37代表:对方主动加我们好友时,微信发过一个回调消息,消息类型是37。
  888. //通过这个变量: var content = msg.Content;
  889. //可以得到stranger的v1参数和v2参数
  890. //然后调用此接口:public static extern void WXAcceptUser(int objects, string stranger, string ticket, int result);
  891. //就会自动同意此好友请求。其中该接口的参数stranger就是v1,ticket就是v2参数
  892. }
  893. else if (sub_type == 51)
  894. {
  895. //51 自己主动查看群信息
  896. }
  897. }
  898. }
  899. this.TcpSendMsg(TcpMsg.content, BackWxMsg);
  900. }
  901. catch
  902. {
  903. Console.WriteLine("异常事件");
  904. }
  905. }
  906. }
  907. public object wx_objMsg = new object();
  908. /// <summary>
  909. /// 设置消息。用于判断消息是否被处理过。若未处理过,则返回true,已经处理过的,返回false。
  910. /// </summary>
  911. /// <param name="msgid"></param>
  912. /// <returns></returns>
  913. public bool Wx_SetMsgKey(string msgid)
  914. {
  915. lock (wx_objMsg)
  916. {
  917. try
  918. {
  919. if (dicReadContent.Count > 5000)
  920. {
  921. dicReadContent = new Dictionary<string, string>();
  922. }
  923. if (!dicReadContent.ContainsKey(msgid))
  924. {
  925. dicRedPack.Add(msgid, msgid);
  926. return true;
  927. }
  928. }
  929. catch
  930. {
  931. return false;
  932. }
  933. }
  934. return false;
  935. }
  936. #endregion 微信消息
  937. #region 微信群
  938. /// <summary>
  939. /// 取群成员
  940. /// </summary>
  941. /// <param name="groupId"></param>
  942. /// <returns></returns>
  943. public unsafe List<WxMember> Wx_GetGroupMember(string groupId)
  944. {
  945. fixed (int* WxUser1 = &pointerWxUser, readmember1 = &readMember)
  946. {
  947. XzyWxApis.WXGetChatRoomMember(pointerWxUser, groupId, (int)readmember1);
  948. var datas = MarshalNativeToManaged((IntPtr)readMember);
  949. var str = datas.ToString();
  950. Wx_ReleaseEX(ref readMember);
  951. GroupMember groupmember = null;
  952. groupmember = Newtonsoft.Json.JsonConvert.DeserializeObject<GroupMember>(str);
  953. List<Member> member = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Member>>(groupmember.Member);
  954. List<WxMember> WxMember = new List<WxMember>();
  955. if (member != null && member.Count > 0)
  956. {
  957. foreach (var m in member)
  958. {
  959. WxMember w = new WxMember();
  960. w.userid = this.wxUser.wxid;
  961. w.groupid = groupId;
  962. w.nickname = m.NickName;
  963. w.wxid = m.UserName;
  964. WxMember.Add(w);
  965. }
  966. return WxMember;
  967. }
  968. return null;
  969. }
  970. }
  971. int wx_intoGroup = 0;
  972. /// <summary>
  973. /// 进群
  974. /// </summary>
  975. /// <param name="url"></param>
  976. public unsafe void Wx_IntoGroup(string url)
  977. {
  978. if (url != "")
  979. {
  980. fixed (int* WxUser1 = &pointerWxUser, jinqun1 = &wx_intoGroup)
  981. {
  982. XzyWxApis.WXGetRequestToken(pointerWxUser, "", url, (int)jinqun1);
  983. if ((int)jinqun1 == 0) { return; }
  984. var json = MarshalNativeToManaged((IntPtr)wx_intoGroup).ToString();
  985. Wx_ReleaseEX(ref wx_intoGroup);
  986. if (json == "") { return; }
  987. EnterGroupJson jinqunjson = Newtonsoft.Json.JsonConvert.DeserializeObject<EnterGroupJson>(json);
  988. var FullUrl = jinqunjson.FullUrl;
  989. var tk = Utilities.GetMidStr(jinqunjson.FullUrl + "||||", "ticket=", "||||");
  990. Http_Helper Http_Helper = new Http_Helper();
  991. var res = "";
  992. var status = Http_Helper.GetResponse_WX(ref res, FullUrl, "POST", "", FullUrl, 30000, "UTF-8", true);
  993. WxDelegate.show("被邀请进入群,开始读通讯录!");
  994. this.Wx_GetContacts();
  995. }
  996. }
  997. }
  998. public object wx_groupObj = new object();
  999. /// <summary>
  1000. /// 更新群成员
  1001. /// </summary>
  1002. /// <param name="groupId"></param>
  1003. /// <returns></returns>
  1004. public bool Wx_SetGroup(string groupId)
  1005. {
  1006. lock (wx_groupObj)
  1007. {
  1008. try
  1009. {
  1010. List<WxGroup> nWxGroup = new List<WxGroup>();
  1011. for (int i = 0; i < wxGroup.Count; i++)
  1012. {
  1013. WxGroup n = wxGroup[i];
  1014. if (groupId == n.groupid)
  1015. {
  1016. n.member = this.Wx_GetGroupMember(wxGroup[i].groupid);
  1017. }
  1018. if (n.member != null)
  1019. {
  1020. nWxGroup.Add(n);
  1021. }
  1022. }
  1023. wxGroup = nWxGroup;
  1024. TcpSendMsg(TcpMsg.Group, wxGroup);
  1025. }
  1026. catch
  1027. {
  1028. return false;
  1029. }
  1030. }
  1031. return false;
  1032. }
  1033. /// <summary>
  1034. /// 创建群
  1035. /// </summary>
  1036. /// <param name="user"></param>
  1037. /// <returns></returns>
  1038. public unsafe string Wx_CreateChatRoom(string users)
  1039. {
  1040. var result = "";
  1041. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1042. {
  1043. XzyWxApis.WXCreateChatRoom(pointerWxUser, users, (int)msgptr1);
  1044. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1045. result = datas.ToString();
  1046. Wx_ReleaseEX(ref msgPtr);
  1047. var tokenData = Newtonsoft.Json.JsonConvert.DeserializeAnonymousType(result, new { user_name = "" });
  1048. if (!String.IsNullOrEmpty(tokenData.user_name))
  1049. {
  1050. result = tokenData.user_name.Replace(" ", @"\n\u").Substring(4);
  1051. }
  1052. if (result.Contains("@chatroom"))
  1053. {
  1054. }
  1055. }
  1056. return result;
  1057. }
  1058. /// <summary>
  1059. /// 退群
  1060. /// </summary>
  1061. /// <param name="groupid"></param>
  1062. /// <returns></returns>
  1063. public unsafe string Wx_QuitChatRoom(string groupid)
  1064. {
  1065. var result = "";
  1066. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1067. {
  1068. XzyWxApis.WXQuitChatRoom(pointerWxUser, groupid, (int)msgptr1);
  1069. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1070. result = datas.ToString();
  1071. Wx_ReleaseEX(ref msgPtr);
  1072. }
  1073. return result;
  1074. }
  1075. /// <summary>
  1076. /// 修改群名称
  1077. /// </summary>
  1078. /// <param name="groupid"></param>
  1079. /// <param name="content"></param>
  1080. /// <returns></returns>
  1081. public unsafe string Wx_SetChatroomName(string groupid, string content)
  1082. {
  1083. var result = "";
  1084. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1085. {
  1086. try
  1087. {
  1088. msgPtr = ESetChatroomName(pointerWxUser, groupid, content);
  1089. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1090. result = datas.ToString();
  1091. Wx_ReleaseEX(ref msgPtr);
  1092. }
  1093. catch (Exception ex){
  1094. }
  1095. }
  1096. return result;
  1097. }
  1098. /// <summary>
  1099. /// 修改群公告
  1100. /// </summary>
  1101. /// <param name="groupid"></param>
  1102. /// <param name="content"></param>
  1103. /// <returns></returns>
  1104. public unsafe string Wx_SetChatroomAnnouncement(string groupid, string content)
  1105. {
  1106. var result = "";
  1107. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1108. {
  1109. try
  1110. {
  1111. //方案一
  1112. //XzyWxApis.WXSetChatroomAnnouncement(pointerWxUser, groupid, Encoding.Default.GetString( Encoding.UTF8.GetBytes( content)), (int)msgptr1);
  1113. //var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1114. //result = datas.ToString();
  1115. //Wx_ReleaseEX(ref msgPtr);
  1116. //方案二
  1117. msgPtr = ESetChatroomAnnouncement(pointerWxUser, groupid, content);
  1118. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1119. result = datas.ToString();
  1120. Wx_ReleaseEX(ref msgPtr);
  1121. }
  1122. catch (Exception ex) {
  1123. }
  1124. }
  1125. return result;
  1126. }
  1127. /// <summary>
  1128. /// 获取群成员资料
  1129. /// </summary>
  1130. /// <param name="groupid"></param>
  1131. /// <returns></returns>
  1132. public unsafe string Wx_GetChatRoomMember(string groupid)
  1133. {
  1134. var result = "";
  1135. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1136. {
  1137. XzyWxApis.WXGetChatRoomMember(pointerWxUser, groupid,(int)msgptr1);
  1138. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1139. result = datas.ToString();
  1140. Wx_ReleaseEX(ref msgPtr);
  1141. }
  1142. return result;
  1143. }
  1144. /// <summary>
  1145. /// 添加群成员
  1146. /// </summary>
  1147. /// <param name="groupid"></param>
  1148. /// <param name="user"></param>
  1149. /// <returns></returns>
  1150. public unsafe string Wx_AddChatRoomMember(string groupid, string user)
  1151. {
  1152. var result = "";
  1153. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1154. {
  1155. XzyWxApis.WXAddChatRoomMember(pointerWxUser, groupid, user, (int)msgptr1);
  1156. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1157. result = datas.ToString();
  1158. Wx_ReleaseEX(ref msgPtr);
  1159. }
  1160. return result;
  1161. }
  1162. public unsafe string Wx_InviteChatRoomMember(string groupid, string user)
  1163. {
  1164. var result = "";
  1165. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1166. {
  1167. XzyWxApis.WXInviteChatRoomMember(pointerWxUser, groupid, user, (int)msgptr1);
  1168. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1169. result = datas.ToString();
  1170. Wx_ReleaseEX(ref msgPtr);
  1171. }
  1172. return result;
  1173. }
  1174. /// <summary>
  1175. /// 删除群成员
  1176. /// </summary>
  1177. /// <param name="groupid"></param>
  1178. /// <param name="user"></param>
  1179. /// <returns></returns>
  1180. public unsafe string Wx_DeleteChatRoomMember(string groupid, string user)
  1181. {
  1182. var result = "";
  1183. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1184. {
  1185. XzyWxApis.WXDeleteChatRoomMember(pointerWxUser, groupid, user, (int)msgptr1);
  1186. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1187. result = datas.ToString();
  1188. Wx_ReleaseEX(ref msgPtr);
  1189. }
  1190. return result;
  1191. }
  1192. #endregion 微信群
  1193. #region 朋友圈
  1194. /// <summary>
  1195. /// 朋友圈评论
  1196. /// </summary>
  1197. /// <param name="snsid"></param>
  1198. /// <param name="content"></param>
  1199. /// <returns></returns>
  1200. public unsafe string Wx_SnsComment(string snsid, string content, int replyid)
  1201. {
  1202. var result = "";
  1203. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1204. {
  1205. XzyWxApis.WXSnsComment(pointerWxUser, this.wxUser.wxid, snsid, content, replyid, (int)msgptr1);
  1206. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1207. result = datas.ToString();
  1208. Wx_ReleaseEX(ref msgPtr);
  1209. }
  1210. return result;
  1211. }
  1212. /// <summary>
  1213. /// 删除评论、点赞
  1214. /// </summary>
  1215. /// <param name="snsid"></param>
  1216. /// <param name="cid"></param>
  1217. /// <returns></returns>
  1218. public unsafe string Wx_SnsObjectOpDeleteComment(string snsid, int cid)
  1219. {
  1220. var result = "";
  1221. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1222. {
  1223. XzyWxApis.WXSnsObjectOp(pointerWxUser, snsid, 4, cid, 3, (int)msgptr1);
  1224. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1225. result = datas.ToString();
  1226. Wx_ReleaseEX(ref msgPtr);
  1227. }
  1228. return result;
  1229. }
  1230. /// <summary>
  1231. /// 获取朋友圈消息详情
  1232. /// </summary>
  1233. /// <param name="snsid"></param>
  1234. /// <returns></returns>
  1235. public unsafe string Wx_SnsObjectDetail(string snsid)
  1236. {
  1237. var result = "";
  1238. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1239. {
  1240. XzyWxApis.WXSnsObjectDetail(pointerWxUser, snsid, (int)msgptr1);
  1241. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1242. if (datas != null)
  1243. {
  1244. result = datas.ToString();
  1245. Wx_ReleaseEX(ref msgPtr);
  1246. }
  1247. }
  1248. return result;
  1249. }
  1250. /// <summary>
  1251. /// 查看指定用户朋友圈
  1252. /// </summary>
  1253. /// <param name="wxid"></param>
  1254. /// <param name="snsid">获取到的最后一次的id,第一次调用设置为空</param>
  1255. /// <returns></returns>
  1256. public unsafe string Wx_SnsUserPage(string wxid,string snsid)
  1257. {
  1258. var result = "";
  1259. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1260. {
  1261. XzyWxApis.WXSnsUserPage(pointerWxUser, wxid, snsid,(int)msgptr1);
  1262. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1263. if (datas != null)
  1264. {
  1265. result = datas.ToString();
  1266. Wx_ReleaseEX(ref msgPtr);
  1267. }
  1268. }
  1269. return result;
  1270. }
  1271. /// <summary>
  1272. /// 发朋友圈
  1273. /// </summary>
  1274. /// <param name="wxid"></param>
  1275. /// <param name="content"></param>
  1276. public unsafe void Wx_SendMoment(string content, List<string> imagelist)
  1277. {
  1278. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1279. {
  1280. if (!imagelist.IsNull())
  1281. {
  1282. string imagestr = "";
  1283. foreach (string strImage in imagelist)
  1284. {
  1285. var reg = new Regex("data:image/(.*);base64,");
  1286. string fileBase64 = reg.Replace(strImage, "");
  1287. var reg2 = new Regex("data:video/(.*);base64,");
  1288. fileBase64 = reg2.Replace(fileBase64, "");
  1289. string strUploadResult = Wx_SnsUpload(fileBase64);
  1290. SnsUpload upload = JsonConvert.DeserializeObject<SnsUpload>(strUploadResult);
  1291. imagestr += String.Format(App.PYQContentImage, upload.big_url, upload.small_url, upload.size, 100, 100);
  1292. }
  1293. var result = String.Format(App.PYQContent, wxUser.wxid, imagestr);
  1294. msgPtr = ESendSNSImage(pointerWxUser, result, content);
  1295. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1296. result = datas.ToString();
  1297. Wx_ReleaseEX(ref msgPtr);
  1298. }
  1299. }
  1300. }
  1301. public unsafe void Wx_SendMoment(string content)
  1302. {
  1303. var result = "";
  1304. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1305. {
  1306. msgPtr = ESendSNS(pointerWxUser, content);
  1307. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1308. result = datas.ToString();
  1309. Wx_ReleaseEX(ref msgPtr);
  1310. }
  1311. }
  1312. /// <summary>
  1313. /// 朋友圈图片上传
  1314. /// </summary>
  1315. /// <param name="base64"></param>
  1316. /// <returns></returns>
  1317. public unsafe string Wx_SnsUpload(string base64)
  1318. {
  1319. var result = "";
  1320. fixed (int* WxUser1 = &pointerWxUser, imptr1 = &wx_imptr)
  1321. {
  1322. try
  1323. {
  1324. byte[] data = Convert.FromBase64String(base64);
  1325. if (data.Length > 0)
  1326. {
  1327. XzyWxApis.WXSnsUpload(pointerWxUser, data, data.Length, (int)imptr1);
  1328. var datas = MarshalNativeToManaged((IntPtr)wx_imptr);
  1329. result = datas.ToString();
  1330. Wx_ReleaseEX(ref wx_imptr);
  1331. }
  1332. }
  1333. catch { }
  1334. }
  1335. return result;
  1336. }
  1337. #endregion 朋友圈
  1338. private int wx_resultContacts;
  1339. /// <summary>
  1340. /// 获取通讯录
  1341. /// </summary>
  1342. public unsafe void Wx_GetContacts()
  1343. {
  1344. if (wxGroup != null && wxGroup.Count > 0)
  1345. {
  1346. TcpSendMsg(TcpMsg.Group, wxGroup);
  1347. return;
  1348. }
  1349. wxGroup = new List<WxGroup>();
  1350. Dictionary<string, string> dicg = new Dictionary<string, string>();
  1351. fixed (int* WxUser1 = &pointerWxUser, resulttxl1 = &wx_resultContacts)
  1352. {
  1353. while (true)
  1354. {
  1355. Thread.Sleep(200);
  1356. XzyWxApis.WXSyncContact(pointerWxUser, (int)(resulttxl1));
  1357. if (wx_resultContacts == 0)
  1358. {
  1359. continue;
  1360. }
  1361. var datas = MarshalNativeToManaged((IntPtr)wx_resultContacts);
  1362. Wx_ReleaseEX(ref wx_resultContacts);
  1363. if (datas == null) { continue; }
  1364. var str = datas.ToString();
  1365. List<Contact> Contact = null;
  1366. Contact = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Contact>>(str);
  1367. result = 0;
  1368. var con = 0;
  1369. //循环所有通讯录对象,此通讯录包括好友、群、公众号等
  1370. foreach (var c in Contact)
  1371. {
  1372. con = c.Continue;
  1373. if (con == 0) { break; }
  1374. if (c.UserName.IsNull()) {
  1375. continue;
  1376. }
  1377. if (c.UserName.IndexOf("@chatroom") == -1 && c.UserName.IndexOf("gh_") == -1)
  1378. {
  1379. WxDelegate.getContact(c);
  1380. }
  1381. else if (c.UserName.IndexOf("@chatroom") != -1)
  1382. {
  1383. WxDelegate.getGroup(c);
  1384. }
  1385. else if (c.UserName.IndexOf("gh_") != -1) {
  1386. WxDelegate.getGZH(c);
  1387. }
  1388. }
  1389. if (con == 0) { break; }
  1390. }
  1391. XzyWxApis.WXSyncReset(pointerWxUser);
  1392. }
  1393. }
  1394. /// <summary>
  1395. /// 接受好友请求
  1396. /// </summary>
  1397. /// <param name="stranger"></param>
  1398. /// <param name="ticket"></param>
  1399. /// <returns></returns>
  1400. public unsafe string Wx_AcceptUser(string stranger, string ticket)
  1401. {
  1402. var result = "";
  1403. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1404. {
  1405. XzyWxApis.WXAcceptUser(pointerWxUser, stranger, ticket, (int)msgptr1);
  1406. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1407. result = datas.ToString();
  1408. Wx_ReleaseEX(ref msgPtr);
  1409. }
  1410. return result;
  1411. }
  1412. /// <summary>
  1413. /// 获取好友详情
  1414. /// </summary>
  1415. /// <param name="wxid"></param>
  1416. /// <returns></returns>
  1417. public unsafe string Wx_GetContact(string wxid)
  1418. {
  1419. var result = "";
  1420. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1421. {
  1422. XzyWxApis.WXGetContact(pointerWxUser, wxid, (int)msgptr1);
  1423. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1424. result = datas.ToString();
  1425. Wx_ReleaseEX(ref msgPtr);
  1426. }
  1427. return result;
  1428. }
  1429. /// <summary>
  1430. /// 设置用户备注
  1431. /// </summary>
  1432. /// <param name="wxid"></param>
  1433. /// <param name="context"></param>
  1434. /// <returns></returns>
  1435. public unsafe string Wx_SetUserRemark(string wxid,string context)
  1436. {
  1437. var result = "";
  1438. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1439. {
  1440. msgPtr = ESetUserRemark(pointerWxUser, wxid, context);
  1441. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1442. result = datas.ToString();
  1443. Wx_ReleaseEX(ref msgPtr);
  1444. }
  1445. return result;
  1446. }
  1447. /// <summary>
  1448. /// 删除好友
  1449. /// </summary>
  1450. /// <param name="wxid"></param>
  1451. /// <returns></returns>
  1452. public unsafe string Wx_DeleteUser(string wxid)
  1453. {
  1454. var result = "";
  1455. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1456. {
  1457. msgPtr = EDeleteUser(pointerWxUser, wxid);
  1458. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1459. result = datas.ToString();
  1460. Wx_ReleaseEX(ref msgPtr);
  1461. }
  1462. return result;
  1463. }
  1464. /// <summary>
  1465. /// 获取登录token
  1466. /// </summary>
  1467. /// <returns></returns>
  1468. public unsafe string Wx_GetLoginToken()
  1469. {
  1470. var result = "";
  1471. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1472. {
  1473. XzyWxApis.WXGetLoginToken(pointerWxUser, (int)msgptr1);
  1474. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1475. result = datas.ToString();
  1476. Wx_ReleaseEX(ref msgPtr);
  1477. }
  1478. return result;
  1479. }
  1480. /// <summary>
  1481. /// 设置微信id
  1482. /// </summary>
  1483. /// <param name="wxid"></param>
  1484. /// <returns></returns>
  1485. public unsafe string Wx_SetWeChatID(string wxid)
  1486. {
  1487. var result = "";
  1488. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1489. {
  1490. XzyWxApis.WXSetWeChatID(pointerWxUser, wxid,(int)msgptr1);
  1491. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1492. result = datas.ToString();
  1493. Wx_ReleaseEX(ref msgPtr);
  1494. }
  1495. return result;
  1496. }
  1497. /// <summary>
  1498. /// 获取本地二维码信息
  1499. /// </summary>
  1500. /// <param name="path"></param>
  1501. /// <returns></returns>
  1502. public unsafe string Wx_QRCodeDecode(string path)
  1503. {
  1504. var result = "";
  1505. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1506. {
  1507. XzyWxApis.WXQRCodeDecode(pointerWxUser, path, (int)msgptr1);
  1508. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1509. result = datas.ToString();
  1510. Wx_ReleaseEX(ref msgPtr);
  1511. }
  1512. return result;
  1513. }
  1514. /// <summary>
  1515. /// 获取其他设备登陆请求
  1516. /// </summary>
  1517. /// <param name="url"></param>
  1518. /// <returns></returns>
  1519. public unsafe string Wx_ExtDeviceLoginGet(string url)
  1520. {
  1521. var result = "";
  1522. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1523. {
  1524. XzyWxApis.WXExtDeviceLoginGet(pointerWxUser, url, (int)msgptr1);
  1525. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1526. result = datas.ToString();
  1527. Wx_ReleaseEX(ref msgPtr);
  1528. }
  1529. return result;
  1530. }
  1531. /// <summary>
  1532. /// 确认其他设备登陆请求
  1533. /// </summary>
  1534. /// <param name="url"></param>
  1535. /// <returns></returns>
  1536. public unsafe string Wx_ExtDeviceLoginOK(string url)
  1537. {
  1538. var result = "";
  1539. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1540. {
  1541. XzyWxApis.WXExtDeviceLoginOK(pointerWxUser, url, (int)msgptr1);
  1542. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1543. result = datas.ToString();
  1544. Wx_ReleaseEX(ref msgPtr);
  1545. }
  1546. return result;
  1547. }
  1548. /// <summary>
  1549. /// 获取62数据
  1550. /// </summary>
  1551. /// <returns></returns>
  1552. public unsafe string Wx_GenerateWxDat()
  1553. {
  1554. var result = "";
  1555. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1556. {
  1557. XzyWxApis.WXGenerateWxDat(pointerWxUser, (int)msgptr1);
  1558. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1559. result = datas.ToString();
  1560. Wx_ReleaseEX(ref msgPtr);
  1561. }
  1562. return result;
  1563. }
  1564. /// <summary>
  1565. /// 断线重连
  1566. /// </summary>
  1567. /// <returns></returns>
  1568. public unsafe string Wx_AutoLogin(string token)
  1569. {
  1570. var result = "";
  1571. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1572. {
  1573. XzyWxApis.WXAutoLogin(pointerWxUser, token,(int)msgptr1);
  1574. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1575. result = datas.ToString();
  1576. Wx_ReleaseEX(ref msgPtr);
  1577. }
  1578. return result;
  1579. }
  1580. public unsafe string Wx_GetPeopleNearby(float lat,float lng)
  1581. {
  1582. var result = "";
  1583. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1584. {
  1585. XzyWxApis.WXGetPeopleNearby(pointerWxUser, lat,lng,(int)msgptr1);
  1586. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1587. result = datas.ToString();
  1588. Wx_ReleaseEX(ref msgPtr);
  1589. }
  1590. return result;
  1591. }
  1592. public unsafe string Wx_AddUser(string v1, string v2,int type,string context)
  1593. {
  1594. var result = "";
  1595. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1596. {
  1597. XzyWxApis.WXAddUser(pointerWxUser, v1, v2, type,context, (int)msgptr1);
  1598. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1599. result = datas.ToString();
  1600. Wx_ReleaseEX(ref msgPtr);
  1601. }
  1602. return result;
  1603. }
  1604. /// <summary>
  1605. /// 获取公众号菜单
  1606. /// </summary>
  1607. /// <param name="gzhid"></param>
  1608. /// <returns></returns>
  1609. public unsafe string GetSubscriptionInfo(string gzhid)
  1610. {
  1611. var result = "";
  1612. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1613. {
  1614. XzyWxApis.WXGetSubscriptionInfo(pointerWxUser, gzhid, (int)msgptr1);
  1615. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1616. result = datas.ToString();
  1617. Wx_ReleaseEX(ref msgPtr);
  1618. }
  1619. return result;
  1620. }
  1621. /// <summary>
  1622. /// 执行公众号菜单
  1623. /// </summary>
  1624. /// <param name="wxid">公众号用户名gh* 开头的</param>
  1625. /// <param name="uin">通过WXGetSubscriptionInfo获取</param>
  1626. /// <param name="key">通过WXGetSubscriptionInfo获取</param>
  1627. /// <returns></returns>
  1628. public unsafe string Wx_SubscriptionCommand(string wxid,uint uin,string key)
  1629. {
  1630. var result = "";
  1631. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1632. {
  1633. XzyWxApis.WXSubscriptionCommand(pointerWxUser, wxid,uin,key ,(int)msgptr1);
  1634. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1635. result = datas.ToString();
  1636. Wx_ReleaseEX(ref msgPtr);
  1637. }
  1638. return result;
  1639. }
  1640. /// <summary>
  1641. /// 后期所有标签
  1642. /// </summary>
  1643. /// <returns></returns>
  1644. public unsafe string Wx_GetContactLabelList()
  1645. {
  1646. var result = "";
  1647. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1648. {
  1649. XzyWxApis.WXGetContactLabelList(pointerWxUser, (int)msgptr1);
  1650. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1651. result = datas.ToString();
  1652. Wx_ReleaseEX(ref msgPtr);
  1653. }
  1654. return result;
  1655. }
  1656. /// <summary>
  1657. /// 设置用户标签
  1658. /// </summary>
  1659. /// <param name="wxid"></param>
  1660. /// <param name="labelid"></param>
  1661. /// <returns></returns>
  1662. public unsafe string Wx_SetContactLabel(string wxid,string labelid)
  1663. {
  1664. var result = "";
  1665. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1666. {
  1667. XzyWxApis.WXSetContactLabel(pointerWxUser, wxid,labelid,(int)msgptr1);
  1668. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1669. result = datas.ToString();
  1670. Wx_ReleaseEX(ref msgPtr);
  1671. }
  1672. return result;
  1673. }
  1674. /// <summary>
  1675. /// 创建标签
  1676. /// </summary>
  1677. /// <param name="context"></param>
  1678. /// <returns></returns>
  1679. public unsafe string Wx_AddContactLabel(string context)
  1680. {
  1681. var result = "";
  1682. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1683. {
  1684. msgPtr = EAddContactLabel(pointerWxUser, context);
  1685. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1686. result = datas.ToString();
  1687. Wx_ReleaseEX(ref msgPtr);
  1688. }
  1689. return result;
  1690. }
  1691. /// <summary>
  1692. /// 创建标签
  1693. /// </summary>
  1694. /// <param name="context"></param>
  1695. /// <returns></returns>
  1696. public unsafe string Wx_DeleteContactLabel(string labelid)
  1697. {
  1698. var result = "";
  1699. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1700. {
  1701. XzyWxApis.WXDeleteContactLabel(pointerWxUser, labelid, (int)msgptr1);
  1702. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1703. result = datas.ToString();
  1704. Wx_ReleaseEX(ref msgPtr);
  1705. }
  1706. return result;
  1707. }
  1708. /// <summary>
  1709. /// 同步收藏
  1710. /// </summary>
  1711. /// <param name="key"></param>
  1712. /// <returns></returns>
  1713. public unsafe string Wx_FavSync(string key)
  1714. {
  1715. var result = "";
  1716. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1717. {
  1718. XzyWxApis.WXFavSync(pointerWxUser, key, (int)msgptr1);
  1719. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1720. result = datas.ToString();
  1721. Wx_ReleaseEX(ref msgPtr);
  1722. }
  1723. return result;
  1724. }
  1725. /// <summary>
  1726. /// 添加收藏
  1727. /// </summary>
  1728. /// <param name="fav_object"></param>
  1729. /// <returns></returns>
  1730. public unsafe string Wx_FavAddItem(string fav_object)
  1731. {
  1732. var result = "";
  1733. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1734. {
  1735. XzyWxApis.WXFavAddItem(pointerWxUser, fav_object, (int)msgptr1);
  1736. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1737. result = datas.ToString();
  1738. Wx_ReleaseEX(ref msgPtr);
  1739. }
  1740. return result;
  1741. }
  1742. /// <summary>
  1743. /// 查看收藏
  1744. /// </summary>
  1745. /// <param name="favid"></param>
  1746. /// <returns></returns>
  1747. public unsafe string Wx_FavGetItem(string favid)
  1748. {
  1749. var result = "";
  1750. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1751. {
  1752. XzyWxApis.WXFavGetItem(pointerWxUser, favid.ConvertToInt32(), (int)msgptr1);
  1753. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1754. result = datas.ToString();
  1755. Wx_ReleaseEX(ref msgPtr);
  1756. }
  1757. return result;
  1758. }
  1759. /// <summary>
  1760. /// 发送链接消息
  1761. /// </summary>
  1762. /// <param name="wxid"></param>
  1763. /// <param name="context"></param>
  1764. /// <returns></returns>
  1765. public unsafe string Wx_SendAppMsg(string wxid,string context)
  1766. {
  1767. var result = "";
  1768. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1769. {
  1770. XzyWxApis.WXSendAppMsg(pointerWxUser, wxid,Encoding.Default.GetString( Encoding.UTF8.GetBytes(context)),(int)msgptr1);
  1771. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1772. result = datas.ToString();
  1773. Wx_ReleaseEX(ref msgPtr);
  1774. }
  1775. return result;
  1776. }
  1777. /// <summary>
  1778. /// token登录
  1779. /// </summary>
  1780. /// <param name="token"></param>
  1781. /// <returns></returns>
  1782. public unsafe string Wx_LoginRequest(string token, string str62)
  1783. {
  1784. var result = "";
  1785. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1786. {
  1787. byte[] data62Bytes = Convert.FromBase64String(str62);
  1788. XzyWxApis.WXLoadWxDat(pointerWxUser, data62Bytes, data62Bytes.Length, (int)msgptr1);
  1789. var data1 = MarshalNativeToManaged((IntPtr)msgPtr);
  1790. result = data1.ToString();
  1791. Wx_ReleaseEX(ref msgPtr);
  1792. }
  1793. fixed (int* WxUser1 = &pointerWxUser, msgptr1 = &msgPtr)
  1794. {
  1795. XzyWxApis.WXLoginRequest(pointerWxUser, token, (int)msgptr1);
  1796. var datas = MarshalNativeToManaged((IntPtr)msgPtr);
  1797. result = datas.ToString();
  1798. Wx_ReleaseEX(ref msgPtr);
  1799. }
  1800. return result;
  1801. }
  1802. //读红包key
  1803. public unsafe Dictionary<string, packitme> RedpackOK(string json, int Timestamp)
  1804. {
  1805. fixed (int* WxUser1 = &pointerWxUser, redpack1 = &redPack)
  1806. {
  1807. XzyWxApis.WXReceiveRedPacket(pointerWxUser, json, (int)redpack1);
  1808. if ((int)redpack1 == 0) { return null; }
  1809. var fromwxid = "";
  1810. var key = MarshalNativeToManaged((IntPtr)redPack).ToString();
  1811. if (key == null)
  1812. {
  1813. return null;
  1814. }
  1815. Wx_ReleaseEX(ref redPack);
  1816. WXReceiveRedPacketJson wxReceiveRedPacketjson = Newtonsoft.Json.JsonConvert.DeserializeObject<WXReceiveRedPacketJson>(key);
  1817. key = wxReceiveRedPacketjson.Key;
  1818. RedPacketJson redPacketjson = Newtonsoft.Json.JsonConvert.DeserializeObject<RedPacketJson>(wxReceiveRedPacketjson.External);
  1819. fromwxid = redPacketjson.SendUserName;
  1820. WxDelegate.show(key);
  1821. if (!this.SET_redpack_Key(key, json))
  1822. {
  1823. return null;
  1824. }
  1825. else
  1826. {
  1827. /*接收到新红包*/
  1828. this.CallBackRedPack(false, -2, "收到新红包", key, fromwxid, Timestamp);
  1829. //将收到新红包的时间等日志信息,记录到数据库中。
  1830. //db.apck_insert(new redpack() { inputtime = DateTime.Now, pack_key = key, pack_json = json, groupid = fromwxid });
  1831. WxDelegate.show("收到新红包");
  1832. }
  1833. #region 领取红包
  1834. XzyWxApis.WXOpenRedPacket(pointerWxUser, json, key, (int)redpack1);
  1835. if ((int)redpack1 == 0) { return null; }
  1836. var datas22 = MarshalNativeToManaged((IntPtr)redPack);
  1837. var str22 = datas22.ToString();
  1838. WxDelegate.show(str22);
  1839. Wx_ReleaseEX(ref redPack);
  1840. #endregion
  1841. #region 循环接收红包事件,先隐藏掉
  1842. double time = Utilities.GetTimestamp;
  1843. //while (true)
  1844. //{
  1845. // Thread.Sleep(500);
  1846. //读取红包,要在领了红包后再调用此方法查看
  1847. XzyWxApis.WXQueryRedPacket(pointerWxUser, json, 0, (int)redpack1);
  1848. if ((int)redpack1 == 0) { return null; }
  1849. var datas = MarshalNativeToManaged((IntPtr)redPack);
  1850. var str = datas.ToString();
  1851. Wx_ReleaseEX(ref redPack);
  1852. ReadPackJson redpackjson = Newtonsoft.Json.JsonConvert.DeserializeObject<ReadPackJson>(str);
  1853. Dictionary<string, packitme> ipackitme = new Dictionary<string, packitme>();
  1854. if (redpackjson.External != "")
  1855. {
  1856. ReadPackItem redpackitem = Newtonsoft.Json.JsonConvert.DeserializeObject<ReadPackItem>(redpackjson.External);
  1857. if (redpackitem.HeadTitle != null)
  1858. {
  1859. var nowcount = redpackitem.RecNum;
  1860. var count = redpackitem.TotalNum;
  1861. WxDelegate.show(string.Format("当前{0}-{1}", nowcount, count));
  1862. if (nowcount == count || redpackitem.HeadTitle.IndexOf("被抢光") != -1)
  1863. {
  1864. this.CallBackRedPack(false, -1, "红包被抢光,读包中", key, fromwxid, Timestamp);
  1865. WxDelegate.show("红包被抢光,读包中");
  1866. #region 抢光之后开始翻页
  1867. Bk2:;
  1868. var countpage = Convert.ToInt32(Convert.ToDouble(count) / 11.00);
  1869. if (count % 11 > 0)
  1870. {
  1871. countpage = countpage + 1;
  1872. }
  1873. ipackitme = new Dictionary<string, packitme>();
  1874. var index = 0;
  1875. List<packitme> ilist = new List<packitme>();
  1876. for (int i = 0; i < countpage + countpage; i++)
  1877. {
  1878. XzyWxApis.WXQueryRedPacket(pointerWxUser, json, i, (int)redpack1);
  1879. if ((int)redpack1 == 0) { return null; }
  1880. var datas1 = MarshalNativeToManaged((IntPtr)redPack);
  1881. var str1 = datas1.ToString();
  1882. Wx_ReleaseEX(ref redPack);
  1883. var redpackjson1 = Newtonsoft.Json.JsonConvert.DeserializeObject<ReadPackJson>(str1);
  1884. var redpackitem1 = Newtonsoft.Json.JsonConvert.DeserializeObject<ReadPackItem>(redpackjson1.External);
  1885. this.CallBackRedPack(false, i + 1, string.Format("读红包第{0}页", i + 1), key, fromwxid, Timestamp);
  1886. foreach (var rec in redpackitem1.Record)
  1887. {
  1888. packitme packitme = Newtonsoft.Json.JsonConvert.DeserializeObject<packitme>(rec.ToString());
  1889. if (!ipackitme.ContainsKey(packitme.UserName))
  1890. {
  1891. packitme.xh = index;
  1892. ipackitme.Add(packitme.UserName, packitme);
  1893. index++;
  1894. ilist.Add(packitme);
  1895. }
  1896. }
  1897. }
  1898. if (index == count)
  1899. {
  1900. this.CallBackRedPack(false, 0, "读包完毕", key, fromwxid, Timestamp, ipackitme);
  1901. return ipackitme;
  1902. }
  1903. else
  1904. {
  1905. goto Bk2;
  1906. }
  1907. #endregion
  1908. }
  1909. else
  1910. {
  1911. if (Utilities.GetTimestamp - time > 60 * 1000)
  1912. {
  1913. this.CallBackRedPack(false, -3, "红包超时", key, fromwxid, Timestamp, ipackitme);
  1914. return null;
  1915. }
  1916. }
  1917. }
  1918. }
  1919. //}
  1920. #endregion
  1921. return null;
  1922. }
  1923. }
  1924. public Dictionary<string, string> dic_redpack { get; set; }
  1925. public object obj = new object();
  1926. public bool SET_redpack_Key(string key, string json)
  1927. {
  1928. lock (obj)
  1929. {
  1930. try
  1931. {
  1932. if (dic_redpack == null)
  1933. {
  1934. dic_redpack = new Dictionary<string, string>();
  1935. }
  1936. if (!dic_redpack.ContainsKey(key))
  1937. {
  1938. dic_redpack.Add(key, json);
  1939. return true;
  1940. }
  1941. }
  1942. catch
  1943. {
  1944. return false;
  1945. }
  1946. }
  1947. return false;
  1948. }
  1949. /// <summary>
  1950. /// 收到新红包时的回调处理
  1951. /// </summary>
  1952. /// <param name="ok"></param>
  1953. /// <param name="page"></param>
  1954. /// <param name="msg"></param>
  1955. /// <param name="key"></param>
  1956. /// <param name="fromuser"></param>
  1957. /// <param name="Timestamp"></param>
  1958. /// <param name="dic"></param>
  1959. public void CallBackRedPack(bool ok, int page, string msg, string key, string fromuser, int Timestamp, Dictionary<string, packitme> dic = null)
  1960. {
  1961. PackMsg packmsg = new PackMsg();
  1962. packmsg.msg = msg;
  1963. packmsg.key = key;
  1964. packmsg.fromuser = fromuser;
  1965. packmsg.Timestamp = Timestamp;
  1966. if (ok)
  1967. {
  1968. packmsg.ok = true;
  1969. packmsg.packitme = dic;
  1970. }
  1971. else
  1972. {
  1973. packmsg.ok = false;
  1974. packmsg.page = page;
  1975. }
  1976. this.TcpSendMsg(TcpMsg.redpack, packmsg);
  1977. }
  1978. /// <summary>
  1979. /// 释放内存
  1980. /// </summary>
  1981. /// <param name="hande"></param>
  1982. public void Wx_ReleaseEX(ref int hande)
  1983. {
  1984. XzyWxApis.WXRelease(hande);
  1985. hande = 0;
  1986. }
  1987. #endregion
  1988. #region 易语言 Utils 处理中文乱码
  1989. [DllImport("EUtils.dll")]
  1990. public static extern int ESendSNS(int wxuser, string str);
  1991. [DllImport("EUtils.dll")]
  1992. public static extern int ESendSNSImage(int wxuser, string xml, string context);
  1993. [DllImport("EUtils.dll")]
  1994. public static extern int ESetChatroomAnnouncement(int wxuser, string wxid, string context);
  1995. [DllImport("EUtils.dll")]
  1996. public static extern int ESetChatroomName(int wxuser, string wxid, string name);
  1997. [DllImport("EUtils.dll")]
  1998. public static extern int EShareCarde(int wxuser, string wxid, string fromwxid, string caption);
  1999. [DllImport("EUtils.dll")]
  2000. public static extern int ESnsComment(int wxuser, string wxid, string snsid, string context);
  2001. [DllImport("EUtils.dll")]
  2002. public static extern int EAddUser(int wxuser, string v1, string v2, int type,string context);
  2003. [DllImport("EUtils.dll")]
  2004. public static extern int ESetUserRemark(int wxuser, string wxid, string context);
  2005. [DllImport("EUtils.dll")]
  2006. public static extern int ESayHello(int wxuser, string v1, string context);
  2007. [DllImport("EUtils.dll")]
  2008. public static extern int EAddContactLabel(int wxuser, string context);
  2009. [DllImport("EUtils.dll")]
  2010. public static extern int EDeleteUser(int wxuser, string wxid);
  2011. #endregion
  2012. }
  2013. }