Global.asax.cs 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851
  1. using LYFZ.WXLibrary;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Linq;
  6. using System.Web;
  7. using System.Web.Security;
  8. using System.Web.SessionState;
  9. namespace LYFZ.WeixinServers
  10. {
  11. public class Global : System.Web.HttpApplication
  12. {
  13. public static LYFZ.WeixinServiceDate.DAL.DAL_CustomerInterfaces CusDal = new WeixinServiceDate.DAL.DAL_CustomerInterfaces();
  14. LYFZ.WeixinServiceDate.DAL.DAL_SystemConfigure scDal = new WeixinServiceDate.DAL.DAL_SystemConfigure();
  15. public static LYFZ.WeixinServiceDate.DAL.DAL_Authorization_info Authorization_infoDal = new WeixinServiceDate.DAL.DAL_Authorization_info();
  16. private static int pageSize = 100;
  17. /// <summary>
  18. /// 每页记录条数
  19. /// </summary>
  20. public static int PageSize
  21. {
  22. get { return Global.pageSize; }
  23. set { Global.pageSize = value; }
  24. }
  25. static DataTable authorizationInfoDaTable = new DataTable();
  26. /// <summary>
  27. /// 公众号授权信息列表
  28. /// </summary>
  29. public static DataTable AuthorizationInfoDaTable
  30. {
  31. get { return Global.authorizationInfoDaTable; }
  32. set { Global.authorizationInfoDaTable = value; }
  33. }
  34. /// <summary>
  35. /// 刷新加载公众号授权信息列表
  36. /// </summary>
  37. public static void RefreshLoadAuthorizationInfoDaTable()
  38. {
  39. DataSet ds = Authorization_infoDal.GetAllList();
  40. lock (Global.authorizationInfoDaTable)
  41. {
  42. try
  43. {
  44. Global.authorizationInfoDaTable.Rows.Clear();
  45. Global.authorizationInfoDaTable.Dispose();
  46. Global.authorizationInfoDaTable = null;
  47. }
  48. catch
  49. {
  50. }
  51. Global.authorizationInfoDaTable = ds.Tables[0];
  52. Global.authorizationInfoDaTable.PrimaryKey = new DataColumn[] { Global.authorizationInfoDaTable.Columns["authorizer_appid"] };
  53. Global.RefreshAuthorizedAPPIDHandleList(Global.authorizationInfoDaTable);
  54. }
  55. }
  56. /// <summary>
  57. /// 刷新已授权公众号的授权信息处理集合
  58. /// </summary>
  59. /// <param name="_AuthorizationInfoDaTable"></param>
  60. public static void RefreshAuthorizedAPPIDHandleList(DataTable _AuthorizationInfoDaTable)
  61. {
  62. foreach (DataRow row in _AuthorizationInfoDaTable.Rows)
  63. {
  64. LYFZ.WeixinServiceDate.Model.Model_Authorization_info Authorization_infoModel = Authorization_infoDal.DataRowToModel(row);
  65. AddAuthorizedAPPIDHand(Authorization_infoModel);
  66. }
  67. }
  68. /// <summary>
  69. /// 更新
  70. /// </summary>
  71. /// <param name="Authorization_infoModel"></param>
  72. public static void UpdateAuthorizedAPPIDHand(LYFZ.WeixinServiceDate.Model.Model_Authorization_info Authorization_infoModel)
  73. {
  74. LYFZ.WXLibrary.AuthorizedAPPIDHandle authAPPIDHandle = null;
  75. if (OpenPlatformConfig.AuthorizedAPPIDHandleList.ContainsKey(Authorization_infoModel.Authorizer_appid))
  76. {
  77. authAPPIDHandle = OpenPlatformConfig.AuthorizedAPPIDHandleList[Authorization_infoModel.Authorizer_appid];
  78. authAPPIDHandle.Authorizer_access_token = Authorization_infoModel.Authorizer_access_token;
  79. authAPPIDHandle.Expires_in = Authorization_infoModel.Expires_in;
  80. authAPPIDHandle.Authorizer_refresh_token = Authorization_infoModel.Authorizer_refresh_token;
  81. authAPPIDHandle.RefreshTokenTime = Authorization_infoModel.RefreshTokenTime;
  82. authAPPIDHandle.AuthorizeStatus = Authorization_infoModel.AuthorizeStatus;
  83. }
  84. else {
  85. AddAuthorizedAPPIDHand(Authorization_infoModel);
  86. }
  87. }
  88. /// <summary>
  89. /// 移除
  90. /// </summary>
  91. /// <param name="Authorization_infoModel"></param>
  92. public static void RemoveAuthorizedAPPIDHand(LYFZ.WeixinServiceDate.Model.Model_Authorization_info Authorization_infoModel)
  93. {
  94. LYFZ.WXLibrary.AuthorizedAPPIDHandle authAPPIDHandle = null;
  95. lock (OpenPlatformConfig.AuthorizedAPPIDHandleList)
  96. {
  97. if (OpenPlatformConfig.AuthorizedAPPIDHandleList.ContainsKey(Authorization_infoModel.Authorizer_appid))
  98. {
  99. authAPPIDHandle = OpenPlatformConfig.AuthorizedAPPIDHandleList[Authorization_infoModel.Authorizer_appid];
  100. authAPPIDHandle.EventEvent_AuthorizerRefreshToken -= authAPPIDHandle_EventEvent_AuthorizerRefreshToken;
  101. OpenPlatformConfig.AuthorizedAPPIDHandleList.Remove(Authorization_infoModel.Authorizer_appid);
  102. }
  103. }
  104. }
  105. /// <summary>
  106. /// 添加授权公众号处理对象到集合中(OpenPlatformConfig.AuthorizedAPPIDHandleList)
  107. /// </summary>
  108. /// <param name="Authorization_infoModel"></param>
  109. public static void AddAuthorizedAPPIDHand(LYFZ.WeixinServiceDate.Model.Model_Authorization_info Authorization_infoModel)
  110. {
  111. lock (OpenPlatformConfig.AuthorizedAPPIDHandleList)
  112. {
  113. if (!OpenPlatformConfig.AuthorizedAPPIDHandleList.ContainsKey(Authorization_infoModel.Authorizer_appid) && Authorization_infoModel.AuthorizeStatus == 1 && Authorization_infoModel.JMGDomainName.Trim().Length > 0)
  114. {
  115. LYFZ.WXLibrary.AuthorizedAPPIDHandle authAPPIDHandle = new AuthorizedAPPIDHandle(Authorization_infoModel.Authorization_info, Authorization_infoModel.JMGDomainName, Authorization_infoModel.CompanyName, Authorization_infoModel.AuthorizeStatus, Authorization_infoModel.RefreshTokenTime);
  116. authAPPIDHandle.EventEvent_AuthorizerRefreshToken += authAPPIDHandle_EventEvent_AuthorizerRefreshToken;
  117. OpenPlatformConfig.AuthorizedAPPIDHandleList.Add(Authorization_infoModel.Authorizer_appid, authAPPIDHandle);
  118. }
  119. }
  120. }
  121. static void authAPPIDHandle_EventEvent_AuthorizerRefreshToken(EventAuthorizerRefreshToken e)
  122. {
  123. LYFZ.WeixinServiceDate.Model.Model_Authorization_info Authorization_infoModel =
  124. (LYFZ.WeixinServiceDate.Model.Model_Authorization_info)Authorization_infoDal.GetModelObject("authorizer_appid", e.Appid);
  125. if (Authorization_infoModel != null && Authorization_infoModel.ID > 0)
  126. {
  127. var authorizationObj = LYFZ.Weixin.SDK.BasicAPI.JsonToDynamic(Authorization_infoModel.Authorization_info);
  128. authorizationObj.authorization_info.authorizer_access_token = e.Authorizer_access_token;
  129. authorizationObj.authorization_info.expires_in = e.Expires_in;
  130. authorizationObj.authorization_info.authorizer_refresh_token = e.Authorizer_refresh_token;
  131. Authorization_infoModel.RefreshTokenTime = e.RefreshTokenTime;
  132. Authorization_infoModel.Authorizer_access_token = e.Authorizer_access_token;
  133. Authorization_infoModel.Expires_in = e.Expires_in;
  134. Authorization_infoModel.Authorizer_refresh_token = e.Authorizer_refresh_token;
  135. Authorization_infoModel.Authorization_info = authorizationObj.ToString();
  136. Authorization_infoDal.Update(Authorization_infoModel);
  137. }
  138. }
  139. /// <summary>
  140. /// 更新授权处理对象中的加密锁域名
  141. /// </summary>
  142. /// <param name="authorizer_Appid"></param>
  143. /// <param name="JMGDomainName"></param>
  144. /// <param name="CompanyName"></param>
  145. public static void UpdateAuthorizedAPPIDHandleJMGDomainName(string authorizer_Appid, string JMGDomainName, string CompanyName)
  146. {
  147. LYFZ.WXLibrary.AuthorizedAPPIDHandle authAPPIDHandle = null;
  148. if (OpenPlatformConfig.AuthorizedAPPIDHandleList.ContainsKey(authorizer_Appid))
  149. {
  150. authAPPIDHandle = OpenPlatformConfig.AuthorizedAPPIDHandleList[authorizer_Appid];
  151. authAPPIDHandle.JMGDomainName = JMGDomainName;
  152. authAPPIDHandle.CompanyName = CompanyName;
  153. LYFZ.WeixinServiceDate.Model.Model_Authorization_info Authorization_infoModel =
  154. (LYFZ.WeixinServiceDate.Model.Model_Authorization_info)Authorization_infoDal.GetModelObject("authorizer_appid", authorizer_Appid);
  155. if (Authorization_infoModel != null && Authorization_infoModel.ID > 0)
  156. {
  157. Authorization_infoModel.JMGDomainName = authAPPIDHandle.JMGDomainName;
  158. Authorization_infoModel.CompanyName = authAPPIDHandle.CompanyName;
  159. LYFZ.WXLibrary.CommonHandleClass.WriteLog("更新授权处理对象中的加密锁域名:authorizer_Appid=" + authorizer_Appid + " & JMGDomainName=" + Authorization_infoModel.JMGDomainName, "-2", Global.LogsDongleDomainList);
  160. Authorization_infoDal.Update(Authorization_infoModel);
  161. UpdateAuthorizationInfoDaTable(authorizer_Appid, Authorization_infoModel);
  162. }
  163. }
  164. }
  165. /// <summary>
  166. /// 更新缓存中的授权信息
  167. /// </summary>
  168. /// <param name="authorizer_Appid"></param>
  169. /// <param name="cusModel"></param>
  170. public static void UpdateAuthorizationInfoDaTable(string authorizer_Appid, LYFZ.WeixinServiceDate.Model.Model_Authorization_info Authorization_infoModel)
  171. {
  172. try
  173. {
  174. //主键检索查询
  175. DataRow dr = Global.AuthorizationInfoDaTable.Rows.Find(authorizer_Appid);
  176. lock (Global.AuthorizationInfoDaTable)
  177. {
  178. if (dr != null)
  179. {
  180. dr["JMGDomainName"] = Authorization_infoModel.JMGDomainName;
  181. dr["CompanyName"] = Authorization_infoModel.CompanyName;
  182. dr["authorizer_appid"] = Authorization_infoModel.Authorizer_appid;
  183. dr["authorization_info"] = Authorization_infoModel.Authorization_info;
  184. dr["AuthorizeStatus"] = Authorization_infoModel.AuthorizeStatus;
  185. dr["authorizer_access_token"] = Authorization_infoModel.Authorizer_access_token;
  186. dr["expires_in"] = Authorization_infoModel.Expires_in;
  187. dr["authorizer_refresh_token"] = Authorization_infoModel.Authorizer_refresh_token;
  188. dr["AccountBasicInfo"] = Authorization_infoModel.AccountBasicInfo;
  189. dr["CreateTime"] = Authorization_infoModel.CreateTime;
  190. dr["UpdateTime"] = Authorization_infoModel.UpdateTime;
  191. dr["RefreshTokenTime"] = Authorization_infoModel.RefreshTokenTime;
  192. }
  193. else
  194. {
  195. dr = Global.AuthorizationInfoDaTable.NewRow();
  196. dr["ID"] = Authorization_infoModel.ID;
  197. dr["JMGDomainName"] = Authorization_infoModel.JMGDomainName;
  198. dr["CompanyName"] = Authorization_infoModel.CompanyName;
  199. dr["authorizer_appid"] = Authorization_infoModel.Authorizer_appid;
  200. dr["authorization_info"] = Authorization_infoModel.Authorization_info;
  201. dr["AuthorizeStatus"] = Authorization_infoModel.AuthorizeStatus;
  202. dr["authorizer_access_token"] = Authorization_infoModel.Authorizer_access_token;
  203. dr["expires_in"] = Authorization_infoModel.Expires_in;
  204. dr["authorizer_refresh_token"] = Authorization_infoModel.Authorizer_refresh_token;
  205. dr["AccountBasicInfo"] = Authorization_infoModel.AccountBasicInfo;
  206. dr["CreateTime"] = Authorization_infoModel.CreateTime;
  207. dr["UpdateTime"] = Authorization_infoModel.UpdateTime;
  208. dr["RefreshTokenTime"] = Authorization_infoModel.RefreshTokenTime;
  209. Global.AuthorizationInfoDaTable.Rows.Add(dr);
  210. }
  211. }
  212. }
  213. catch
  214. {
  215. RefreshLoadAuthorizationInfoDaTable();
  216. }
  217. }
  218. /// <summary>
  219. /// 删除缓存中的指定的授权公众号信息
  220. /// </summary>
  221. /// <param name="authorizer_Appid"></param>
  222. public static void DeleteAuthorizationInfoDaTable(string authorizer_Appid)
  223. {
  224. try
  225. {
  226. //主键检索查询
  227. DataRow dr = Global.AuthorizationInfoDaTable.Rows.Find(authorizer_Appid);
  228. lock (Global.AuthorizationInfoDaTable)
  229. {
  230. if (dr != null)
  231. {
  232. Global.AuthorizationInfoDaTable.Rows.Remove(dr);
  233. }
  234. }
  235. }
  236. catch { }
  237. }
  238. static DataTable custDaTable = new DataTable();
  239. /// <summary>
  240. /// 利亚方舟中转服务器的Token
  241. /// </summary>
  242. public const string lyfzToken = "lyfz.net";
  243. public static string NetIPUrl = "http://1111.ip138.com/ic.asp";
  244. public static string CloudSelectionUrl = "121.42.170.207";
  245. /// <summary>
  246. /// 客户列表
  247. /// </summary>
  248. public static DataTable CustDaTable
  249. {
  250. get { return Global.custDaTable; }
  251. set { Global.custDaTable = value; }
  252. }
  253. /// <summary>
  254. /// 刷新加载客户信息
  255. /// </summary>
  256. public static void RefreshLoadCustDaTable()
  257. {
  258. try
  259. {
  260. RefreshLoadKeywordDaTable();
  261. }
  262. catch { }
  263. Global.InitializationMicroLetterEventList();
  264. DataSet ds = CusDal.GetAllList();
  265. lock (Global.custDaTable)
  266. {
  267. try
  268. {
  269. Global.custDaTable.Rows.Clear();
  270. Global.custDaTable.Dispose();
  271. }
  272. catch
  273. {
  274. }
  275. Global.custDaTable = ds.Tables[0];
  276. Global.custDaTable.PrimaryKey = new DataColumn[] { Global.custDaTable.Columns["JMGDomainName"] };
  277. }
  278. }
  279. /// <summary>
  280. /// 更新缓存中的客户CallFrequency
  281. /// </summary>
  282. /// <param name="JMGDomainName"></param>
  283. public static void UpdateCustCallFrequency(string JMGDomainName)
  284. {
  285. try
  286. {
  287. lock (Global.custDaTable)
  288. {
  289. //主键检索查询
  290. DataRow dr = Global.custDaTable.Rows.Find(JMGDomainName);
  291. if (dr != null)
  292. {
  293. long newCallFrequency = Convert.ToInt64(dr["CallFrequency"].ToString()) + 1;
  294. dr["CallFrequency"] = newCallFrequency;
  295. if (newCallFrequency % 30 == 0 || newCallFrequency <= 20)
  296. {
  297. CusDal.UpdateCustCallFrequency(JMGDomainName, newCallFrequency);
  298. }
  299. }
  300. }
  301. }
  302. catch { RefreshLoadCustDaTable(); }
  303. }
  304. /// <summary>
  305. /// 更新缓存中的客户信息
  306. /// </summary>
  307. /// <param name="JMGDomainName"></param>
  308. /// <param name="cusModel"></param>
  309. public static void UpdateCustInfo(string JMGDomainName, LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces cusModel)
  310. {
  311. try
  312. {
  313. //主键检索查询
  314. DataRow dr = Global.custDaTable.Rows.Find(JMGDomainName);
  315. lock (Global.custDaTable)
  316. {
  317. if (dr != null)
  318. {
  319. dr["ShellDomainName"] = cusModel.ShellDomainName;
  320. dr["IPAddress"] = cusModel.IPAddress;
  321. dr["PortNumber"] = cusModel.PortNumber;
  322. dr["UseType"] = cusModel.UseType;
  323. dr["RefreshTime"] = cusModel.RefreshTime;
  324. dr["ISEnabled"] = cusModel.ISEnabled;
  325. dr["CompanyName"] = cusModel.CompanyName;
  326. dr["ThirdPartyPlatformURL"] = cusModel.ThirdPartyPlatformURL;
  327. dr["Token"] = cusModel.Token;
  328. dr["AppID"] = cusModel.AppID;
  329. dr["AppSecret"] = cusModel.AppSecret;
  330. dr["AppSecret"] = cusModel.AppSecret;
  331. dr["EncodingAESKey"] = cusModel.EncodingAESKey;
  332. }
  333. else
  334. {
  335. dr = Global.custDaTable.NewRow();
  336. dr["ID"] = cusModel.ID;
  337. dr["JMGDomainName"] = cusModel.JMGDomainName;
  338. dr["ShellDomainName"] = cusModel.ShellDomainName;
  339. dr["IPAddress"] = cusModel.IPAddress;
  340. dr["PortNumber"] = cusModel.PortNumber;
  341. dr["UseType"] = cusModel.UseType;
  342. dr["RefreshTime"] = cusModel.RefreshTime;
  343. dr["CreateTime"] = cusModel.CreateTime;
  344. dr["ISEnabled"] = cusModel.ISEnabled;
  345. dr["CompanyName"] = cusModel.CompanyName;
  346. dr["CallFrequency"] = cusModel.CallFrequency;
  347. dr["ThirdPartyPlatformURL"] = cusModel.ThirdPartyPlatformURL;
  348. dr["Token"] = cusModel.Token;
  349. dr["AppID"] = cusModel.AppID;
  350. dr["AppSecret"] = cusModel.AppSecret;
  351. dr["AppSecret"] = cusModel.AppSecret;
  352. dr["EncodingAESKey"] = cusModel.EncodingAESKey;
  353. Global.custDaTable.Rows.Add(dr);
  354. }
  355. }
  356. }
  357. catch {
  358. RefreshLoadCustDaTable();
  359. }
  360. }
  361. /// <summary>
  362. /// 删除缓存中的指定的客户信息
  363. /// </summary>
  364. /// <param name="JMGDomainName"></param>
  365. public static void DeleteCustInfo(string JMGDomainName)
  366. {
  367. try
  368. {
  369. //主键检索查询
  370. DataRow dr = Global.custDaTable.Rows.Find(JMGDomainName);
  371. lock (Global.custDaTable)
  372. {
  373. if (dr != null)
  374. {
  375. Global.custDaTable.Rows.Remove(dr);
  376. }
  377. }
  378. }
  379. catch { }
  380. }
  381. /// <summary>
  382. /// 获取客户信息
  383. /// </summary>
  384. /// <param name="JMGDomainName"></param>
  385. /// <returns></returns>
  386. public static DataRow GetCustomerDataRow(string JMGDomainName)
  387. {
  388. //主键检索查询
  389. DataRow row = null;
  390. try
  391. {
  392. lock (Global.custDaTable)
  393. {
  394. row = Global.custDaTable.Rows.Find(JMGDomainName);
  395. }
  396. }
  397. catch { RefreshLoadCustDaTable(); }
  398. return row;
  399. }
  400. /// <summary>
  401. /// 获取客户信息
  402. /// </summary>
  403. /// <param name="JMGDomainName"></param>
  404. /// <returns></returns>
  405. public static LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces GetCustomerModel(string JMGDomainName)
  406. {
  407. LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces custModel = new LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces();
  408. DataRow row = Global.GetCustomerDataRow(JMGDomainName);
  409. if (row != null)
  410. {
  411. custModel = CusDal.DataRowToModel(row);
  412. }
  413. return custModel;
  414. }
  415. /// <summary>
  416. /// 获取客户信息
  417. /// </summary>
  418. /// <param name="JMGDomainName"></param>
  419. /// <returns></returns>
  420. public static LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces GetCustomerModelByWxAppId(string wxAppid)
  421. {
  422. LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces custModel = new LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces();
  423. DataRow row = Global.GetCustomerDataRowByWxAppId(wxAppid);
  424. if (row != null)
  425. {
  426. custModel = CusDal.DataRowToModel(row);
  427. }
  428. return custModel;
  429. }
  430. private static DataRow GetCustomerDataRowByWxAppId(string wxAppid)
  431. {
  432. DataRow row = null;
  433. lock (Global.custDaTable)
  434. {
  435. DataRow[] rows = Global.custDaTable.Select(" AppID = '" + wxAppid + "' ");
  436. if (rows.Length > 0)
  437. {
  438. row = rows[0];
  439. }
  440. }
  441. if (row == null)
  442. {
  443. RefreshLoadCustDaTable();
  444. }
  445. return row;
  446. }
  447. /// <summary>
  448. /// 获取客户信息
  449. /// </summary>
  450. /// <param name="JMGDomainName"></param>
  451. /// <returns></returns>
  452. public static LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces GetCustomerModelById(string id)
  453. {
  454. LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces custModel = new LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces();
  455. DataRow row = Global.GetCustomerDataRowById(id);
  456. if (row != null)
  457. {
  458. custModel = CusDal.DataRowToModel(row);
  459. }
  460. return custModel;
  461. }
  462. private static DataRow GetCustomerDataRowById(string id)
  463. {
  464. DataRow row = null;
  465. lock (Global.custDaTable)
  466. {
  467. DataRow[] rows = Global.custDaTable.Select(" ID = '" + id + "' ");
  468. if (rows.Length > 0)
  469. {
  470. row = rows[0];
  471. }
  472. }
  473. if (row == null)
  474. {
  475. RefreshLoadCustDaTable();
  476. }
  477. return row;
  478. }
  479. static DataTable _FunctionListDaTable = new DataTable();
  480. /// <summary>
  481. /// 功能模块列表
  482. /// </summary>
  483. public static DataTable FunctionListDaTable
  484. {
  485. get { return Global._FunctionListDaTable; }
  486. set { Global._FunctionListDaTable = value; }
  487. }
  488. /// <summary>
  489. /// 更新缓存中的功能模块列表
  490. /// </summary>
  491. /// <param name="FunctionCode"></param>
  492. /// <param name="fModel"></param>
  493. public static void UpdateFunctionList(string FunctionCode, LYFZ.WeixinServiceDate.Model.Model_FunctionList fModel)
  494. {
  495. try
  496. {
  497. lock (Global._FunctionListDaTable)
  498. {
  499. //主键检索查询
  500. DataRow dr = Global._FunctionListDaTable.Rows.Find(FunctionCode);
  501. if (dr != null)
  502. {
  503. dr["FunctionName"] = fModel.FunctionName;
  504. dr["FunctionCode"] = fModel.FunctionCode;
  505. }
  506. else
  507. {
  508. dr = Global._FunctionListDaTable.NewRow();
  509. dr["ID"] = fModel.ID;
  510. dr["FunctionName"] = fModel.FunctionName;
  511. dr["FunctionCode"] = fModel.FunctionCode;
  512. dr["CreateTime"] = fModel.CreateTime;
  513. Global._FunctionListDaTable.Rows.Add(dr);
  514. }
  515. }
  516. }
  517. catch { }
  518. }
  519. public static void delFunctionList(string FunctionCode)
  520. {
  521. lock (Global._FunctionListDaTable)
  522. {
  523. DataRow dr = Global._FunctionListDaTable.Rows.Find(FunctionCode);
  524. if (dr != null)
  525. {
  526. Global._FunctionListDaTable.Rows.Remove(dr);
  527. }
  528. }
  529. }
  530. static DataTable _KeywordDaTable = new DataTable();
  531. /// <summary>
  532. /// 关键字集合
  533. /// </summary>
  534. public static DataTable KeywordDaTable
  535. {
  536. get { return Global._KeywordDaTable; }
  537. set { Global._KeywordDaTable = value; }
  538. }
  539. /// <summary>
  540. /// 更新缓存中的关键字
  541. /// </summary>
  542. /// <param name="Keyword"></param>
  543. /// <param name="kModel"></param>
  544. public static void UpdateKeyword(string Keyword, LYFZ.WeixinServiceDate.Model.Model_KeywordManagement kModel, string modatype="")
  545. {
  546. try
  547. {
  548. lock (Global._KeywordDaTable)
  549. {
  550. //主键检索查询
  551. DataRow dr = Global._KeywordDaTable.Rows.Find(Keyword);
  552. if (dr != null || modatype == "edit")
  553. {
  554. if (dr == null)
  555. {
  556. foreach (DataRow row in Global._KeywordDaTable.Rows)
  557. {
  558. if (row["id"].ToString() == kModel.ID.ToString())
  559. {
  560. dr = row;
  561. break;
  562. }
  563. }
  564. }
  565. if (dr != null)
  566. {
  567. dr["Keyword"] = kModel.Keyword;
  568. dr["FunctionCode"] = kModel.FunctionCode;
  569. dr["IsEnabled"] = kModel.IsEnabled;
  570. dr["CreateTime"] = kModel.CreateTime;
  571. }
  572. }
  573. else
  574. {
  575. dr = Global._KeywordDaTable.NewRow();
  576. dr["ID"] = kModel.ID;
  577. dr["Keyword"] = kModel.Keyword;
  578. dr["FunctionCode"] = kModel.FunctionCode;
  579. dr["IsEnabled"] = kModel.IsEnabled;
  580. dr["CreateTime"] = kModel.CreateTime;
  581. Global._KeywordDaTable.Rows.Add(dr);
  582. }
  583. Global.InitializationMicroLetterEventList();
  584. }
  585. }
  586. catch { }
  587. }
  588. public static void delKeyword(string Keyword)
  589. {
  590. lock (Global._KeywordDaTable)
  591. {
  592. DataRow dr = Global._KeywordDaTable.Rows.Find(Keyword);
  593. if (dr != null)
  594. {
  595. Global._KeywordDaTable.Rows.Remove(dr);
  596. }
  597. }
  598. }
  599. static LYFZ.WeixinServiceDate.DAL.DAL_FunctionList funDal = new WeixinServiceDate.DAL.DAL_FunctionList();
  600. static LYFZ.WeixinServiceDate.DAL.DAL_KeywordManagement keyDal = new WeixinServiceDate.DAL.DAL_KeywordManagement();
  601. /// <summary>
  602. /// 刷新加载关键字
  603. /// </summary>
  604. public static void RefreshLoadKeywordDaTable()
  605. {
  606. lock (Global._FunctionListDaTable)
  607. {
  608. DataSet fds = funDal.GetAllList();
  609. Global._FunctionListDaTable.Rows.Clear();
  610. Global._FunctionListDaTable.Dispose();
  611. Global._FunctionListDaTable = fds.Tables[0];
  612. Global._FunctionListDaTable.PrimaryKey = new DataColumn[] { Global._FunctionListDaTable.Columns["FunctionCode"] };
  613. DataSet kds = keyDal.GetAllList(" FunctionCode,id");
  614. Global._KeywordDaTable.Rows.Clear();
  615. Global._KeywordDaTable.Dispose();
  616. Global._KeywordDaTable = null;
  617. Global._KeywordDaTable = kds.Tables[0];
  618. Global._KeywordDaTable.PrimaryKey = new DataColumn[] { Global._KeywordDaTable.Columns["Keyword"] };
  619. }
  620. }
  621. private static List<string> _LogsDongleDomainList = new List<string>();
  622. /// <summary>
  623. /// 调试日志加密锁域名列表
  624. /// </summary>
  625. public static List<string> LogsDongleDomainList
  626. {
  627. get { return Global._LogsDongleDomainList; }
  628. set { Global._LogsDongleDomainList = value; }
  629. }
  630. LYFZ.WeixinServiceDate.DAL.DAL_FunctionList functionDAL = new WeixinServiceDate.DAL.DAL_FunctionList();
  631. LYFZ.WeixinServiceDate.DAL.DAL_KeywordManagement keywordDAL = new WeixinServiceDate.DAL.DAL_KeywordManagement();
  632. /// <summary>
  633. /// 初始化微信事件列表
  634. /// </summary>
  635. public static void InitializationMicroLetterEventList()
  636. {
  637. lock (LYFZ.WXLibrary.CommonHandleClass.MicroLetterEventList)
  638. {
  639. LYFZ.WXLibrary.CommonHandleClass.MicroLetterEventList.Clear();
  640. LYFZ.WXLibrary.CommonHandleClass.KeywordObjectsList.Clear();
  641. foreach (DataRow row in Global._KeywordDaTable.Rows)
  642. {
  643. LYFZ.WXLibrary.CommonHandleClass.MicroLetterEventList.Add(row["Keyword"].ToString().ToLower());
  644. LYFZ.WXLibrary.CommonHandleClass.KeywordObjectsList.Add(new KeywordObjects(row));
  645. }
  646. }
  647. }
  648. static LYFZ.WeixinServiceDate.DAL.DAL_DZKJ_CustomerAccount DZKJ_Dal = new WeixinServiceDate.DAL.DAL_DZKJ_CustomerAccount();
  649. static DataTable _DZKJ_CustomerAccountDataTable = new DataTable();
  650. public static DataTable DZKJ_CustomerAccountDataTable
  651. {
  652. get { return Global._DZKJ_CustomerAccountDataTable; }
  653. set { Global._DZKJ_CustomerAccountDataTable = value; }
  654. }
  655. public static void RefreshDZKJ_CustomerAccountDataTable()
  656. {
  657. DataSet ds = DZKJ_Dal.GetAllList();
  658. lock (DZKJ_CustomerAccountDataTable)
  659. {
  660. try
  661. {
  662. Global._DZKJ_CustomerAccountDataTable.Rows.Clear();
  663. Global._DZKJ_CustomerAccountDataTable.Dispose();
  664. }
  665. catch
  666. {
  667. }
  668. Global._DZKJ_CustomerAccountDataTable = ds.Tables[0];
  669. Global._DZKJ_CustomerAccountDataTable.PrimaryKey = new DataColumn[] { Global._DZKJ_CustomerAccountDataTable.Columns["Account"] };
  670. }
  671. }
  672. public static void UpdateCustomerAccountDataTableLatestLoginTime(string account,string ip, DateTime t,string v)
  673. {
  674. lock (Global._DZKJ_CustomerAccountDataTable)
  675. {
  676. DataRow row = Global._DZKJ_CustomerAccountDataTable.Rows.Find(account);
  677. if (row != null)
  678. {
  679. row["ip"] = ip;
  680. row["LatestLoginTime"] = t;
  681. row["ManagerProgramVersion"] = v;
  682. }
  683. DZKJ_Dal.UpdateLatestLoginTime(account, ip, t.ToString("yyyy-MM-dd HH:mm:ss"), v);
  684. }
  685. }
  686. public static void UpdateCustomerAccountDataTableSmallEifVersion(string account, string v)
  687. {
  688. lock (Global._DZKJ_CustomerAccountDataTable)
  689. {
  690. DataRow row = Global._DZKJ_CustomerAccountDataTable.Rows.Find(account);
  691. if (row != null)
  692. {
  693. row["SmallEifVersion"] = v;
  694. }
  695. DZKJ_Dal.UpdateSmallEifVersion(account, v);
  696. }
  697. }
  698. #region 系统函数
  699. protected void Application_Start(object sender, EventArgs e)
  700. {
  701. #if !IGNORE
  702. Global.RefreshLoadCustDaTable();
  703. try
  704. {
  705. RefreshLoadKeywordDaTable();
  706. }
  707. catch { }
  708. try
  709. {
  710. RefreshLoadAuthorizationInfoDaTable();
  711. }
  712. catch { }
  713. try
  714. {
  715. Global.InitializationMicroLetterEventList();
  716. LYFZ.WeixinServiceDate.Model.Model_SystemConfigure scModel = scDal.GetModel("NetIPUrl");
  717. if (scModel != null)
  718. {
  719. NetIPUrl = scModel.Sconfig_Value;
  720. }
  721. LYFZ.WeixinServiceDate.Model.Model_SystemConfigure CloudSelectionUrlModel = scDal.GetModel("CloudSelectionUrl");
  722. if (CloudSelectionUrlModel != null)
  723. {
  724. CloudSelectionUrl = CloudSelectionUrlModel.Sconfig_Value;
  725. }
  726. }
  727. catch { }
  728. #endif
  729. // 加载全局性的变量;
  730. }
  731. protected void Session_Start(object sender, EventArgs e)
  732. {
  733. }
  734. protected void Application_BeginRequest(object sender, EventArgs e)
  735. {
  736. }
  737. protected void Application_AuthenticateRequest(object sender, EventArgs e)
  738. {
  739. }
  740. protected void Application_Error(object sender, EventArgs e)
  741. {
  742. }
  743. protected void Session_End(object sender, EventArgs e)
  744. {
  745. }
  746. protected void Application_End(object sender, EventArgs e)
  747. {
  748. }
  749. #endregion
  750. internal static WeixinServiceDate.Model.Model_CustomerInterfaces GetCustomerModelByWxNumber(string myUserName)
  751. {
  752. LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces custModel = new LYFZ.WeixinServiceDate.Model.Model_CustomerInterfaces();
  753. DataRow row = Global.GetCustomerDataRowByWxNumber(myUserName);
  754. if (row != null)
  755. {
  756. custModel = CusDal.DataRowToModel(row);
  757. }
  758. return custModel;
  759. }
  760. private static DataRow GetCustomerDataRowByWxNumber(string myUserName)
  761. {
  762. DataRow row = null;
  763. lock (Global.custDaTable)
  764. {
  765. DataRow[] rows = Global.custDaTable.Select(" AppSecret = '" + myUserName + "' ");
  766. if (rows.Length > 0)
  767. {
  768. row = rows[0];
  769. }
  770. }
  771. if (row == null)
  772. {
  773. RefreshLoadCustDaTable();
  774. }
  775. return row;
  776. }
  777. }
  778. }