Global.asax.cs 35 KB

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