DKIBOSSPRDLogic.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586
  1. /*******************************************************************************
  2. * Copyright(c) 2014 DongkeSoft All rights reserved. / Confidential
  3. * 类的信息:
  4. * 1.程序名称:DKIBOSSPRDLogic.cs
  5. * 2.功能描述:系统登录相关处理。
  6. * 编辑履历:
  7. * 作者 日期 版本 修改内容
  8. * 张国印 2014/09/16 1.00 新建
  9. *******************************************************************************/
  10. using System;
  11. using System.Data;
  12. using System.IO;
  13. using Dongke.IBOSS.PRD.Basics.BaseResources;
  14. using Dongke.IBOSS.PRD.Basics.DataAccess;
  15. using Dongke.IBOSS.PRD.Basics.Library;
  16. using Dongke.IBOSS.PRD.Service.DataModels;
  17. using Dongke.IBOSS.PRD.WCF.DataModels;
  18. using Oracle.ManagedDataAccess.Client;
  19. namespace Dongke.IBOSS.PRD.Service.DKIBOSSPRDLogic
  20. {
  21. /// <summary>
  22. /// 系统登录相关处理
  23. /// </summary>
  24. public static class DKIBOSSPRDLogic
  25. {
  26. /// <summary>
  27. /// 升级文件读取时,用的统一锁。
  28. /// </summary>
  29. private static object _downloadUpgradeFile = new object();
  30. #region 用户登录相关
  31. /// <summary>
  32. /// 用户登录-刷新菜单
  33. /// </summary>
  34. /// <param name="requestEntity"></param>
  35. /// <param name="actionType">0:PC端;2:移动端</param>
  36. /// <returns>LoginResultEntity对象</returns>
  37. public static LoginResultEntity DoLoginRefresh(LoginRequestEntity requestEntity, string actionType)
  38. {
  39. LoginResultEntity resultEntity = new LoginResultEntity();
  40. IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
  41. try
  42. {
  43. // 读取License文件数据
  44. if (DataManager.LicDataSet != null)
  45. {
  46. resultEntity.LicenseInfo = new DataSet("LIC");
  47. resultEntity.LicenseInfo.Merge(DataManager.LicDataSet.Tables["Info"]);
  48. }
  49. #region 形成需要执行的SQL语句
  50. string strSql = "PRO_SYS_DoLogin";
  51. OracleParameter[] paras = new OracleParameter[]
  52. {
  53. new OracleParameter("in_AccountCode",requestEntity.AccountCode),
  54. new OracleParameter("in_UserCode",requestEntity.UserCode),
  55. new OracleParameter("in_UserPassword",requestEntity.Password),
  56. new OracleParameter("in_MAC",requestEntity.MACAddress),
  57. new OracleParameter("in_SessionKey",requestEntity.SessionKey),
  58. new OracleParameter("in_ComputerName",requestEntity.ComputerName),
  59. new OracleParameter("in_IP",requestEntity.IPAddress),
  60. new OracleParameter("in_LoginType",actionType),
  61. new OracleParameter("out_LoginStatus",OracleDbType.Int16, ParameterDirection.Output),
  62. new OracleParameter("out_UserOrganization",OracleDbType.RefCursor, ParameterDirection.Output),
  63. new OracleParameter("out_Navigation",OracleDbType.RefCursor, ParameterDirection.Output), //用户导航菜单
  64. new OracleParameter("out_UserRightData",OracleDbType.RefCursor, ParameterDirection.Output), //用户功能权限
  65. new OracleParameter("out_UserRangeRightData",OracleDbType.RefCursor, ParameterDirection.Output), //用户范围权限
  66. new OracleParameter("out_Function",OracleDbType.RefCursor, ParameterDirection.Output) //系统功能菜单
  67. };
  68. #endregion
  69. oracleConn.Open();
  70. int loginStatus = 0;
  71. DataSet returnDataSet = oracleConn.ExecStoredProcedure(strSql, paras);
  72. foreach (Constant.SysCacheTable itemEnum in Enum.GetValues(typeof(Constant.SysCacheTable)))
  73. {
  74. string strSysConfig = "Select * From " + itemEnum.ToString();
  75. DataTable dtTemp = oracleConn.GetSqlResultToDt(strSysConfig);
  76. dtTemp.TableName = itemEnum.ToString();
  77. if (resultEntity.SysParameter == null)
  78. resultEntity.SysParameter = new DataSet();
  79. resultEntity.SysParameter.Tables.Add(dtTemp);
  80. }
  81. oracleConn.Close();
  82. if (returnDataSet != null && 5 <= returnDataSet.Tables.Count)
  83. {
  84. DataRow dataRow = returnDataSet.Tables[0].Rows[0];
  85. #region 给用户实体赋值
  86. resultEntity.CurrentUserEntity.UserID = Convert.ToInt16(dataRow["UserID"].ToString().Trim());
  87. resultEntity.CurrentUserEntity.UserCode = dataRow["UserCode"].ToString().Trim();
  88. resultEntity.CurrentUserEntity.UserName = dataRow["UserName"].ToString().Trim();
  89. resultEntity.CurrentUserEntity.AccountID = Convert.ToInt16(dataRow["AccountID"].ToString().Trim());
  90. resultEntity.CurrentUserEntity.AccountCode = dataRow["AccountCode"].ToString().Trim();
  91. resultEntity.CurrentUserEntity.AccountName = dataRow["AccountName"].ToString().Trim();
  92. resultEntity.CurrentUserEntity.Password = dataRow["Password"].ToString().Trim();
  93. resultEntity.CurrentUserEntity.OrganizationID = Convert.ToInt16(dataRow["OrganizationID"].ToString().Trim());
  94. resultEntity.CurrentUserEntity.OrganizationCode = dataRow["OrganizationCode"].ToString().Trim();
  95. resultEntity.CurrentUserEntity.SessionKey = dataRow["SessionKey"].ToString().Trim();
  96. resultEntity.CurrentUserEntity.ValueFlag = Convert.ToInt16(dataRow["ValueFlag"].ToString().Trim());
  97. resultEntity.CurrentUserEntity.LimitMAC = dataRow["LimitMAC"].ToString().Trim();
  98. resultEntity.CurrentUserEntity.CanSmartLogin = Convert.ToInt16(dataRow["CanSmartLogin"].ToString().Trim());
  99. resultEntity.CurrentUserEntity.Remarks = dataRow["Remarks"].ToString().Trim();
  100. resultEntity.CurrentUserEntity.UserNavigationData = returnDataSet.Tables[1]; // 用户的主导航菜单数据
  101. resultEntity.CurrentUserEntity.UserRightData = returnDataSet.Tables[2];// 用户的功能权限限制数据
  102. resultEntity.CurrentUserEntity.UserRangeRightData = returnDataSet.Tables[3]; // 用户的范围权限限制数据
  103. resultEntity.CurrentUserEntity.FunctionData = returnDataSet.Tables[4]; //系统功能菜单
  104. #endregion
  105. }
  106. else if (paras[8] != null)
  107. {
  108. loginStatus = Convert.ToInt32(paras[8].Value.ToString());
  109. }
  110. else
  111. {
  112. loginStatus = -1;
  113. }
  114. resultEntity.LoginStatus = loginStatus;
  115. return resultEntity;
  116. }
  117. finally
  118. {
  119. if (oracleConn.ConnState == ConnectionState.Open)
  120. {
  121. oracleConn.Close();
  122. }
  123. }
  124. }
  125. /// <summary>
  126. /// 用户登录
  127. /// </summary>
  128. /// <param name="requestEntity">请求用户实例</param>
  129. /// <param name="actionType">0:PC端;2:移动端</param>
  130. /// <returns>LoginResultEntity对象</returns>
  131. public static LoginResultEntity DoLogin(LoginRequestEntity requestEntity, string actionType)
  132. {
  133. LoginResultEntity resultEntity = new LoginResultEntity();
  134. IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
  135. try
  136. {
  137. #region 对License文件结果处理 返回异常信息
  138. bool checkLic = false;
  139. if (checkLic)
  140. {
  141. lock (DataManager.LicLock)
  142. {
  143. string sql = "select a.ListCode from tp_mst_account a order by a.accountid";
  144. string listCode = oracleConn.GetSqlResultToStr(sql);
  145. // 读取License文件数据
  146. DataSet customer = null;
  147. string licString = null;
  148. int readLock = LockLicenseHandle.ReadLisenceFile(listCode, ref customer, out licString);
  149. if (readLock == -1)
  150. {
  151. resultEntity.LoginStatus = Constant.LOGIN_NOT_LICENSE;
  152. return resultEntity;
  153. }
  154. else if (readLock == -2)
  155. {
  156. resultEntity.LoginStatus = Constant.LOGIN_LICENSE_CONTENT_ERROR;
  157. return resultEntity;
  158. }
  159. else if (readLock == -3)
  160. {
  161. resultEntity.LoginStatus = Constant.LOGIN_LICENSE_BE_OVERDUE;
  162. return resultEntity;
  163. }
  164. // license文件数据不正确
  165. if (customer == null || customer.Tables[0].Rows.Count < 1)
  166. {
  167. resultEntity.LoginStatus = Constant.LOGIN_LICENSE_CONTENT_ERROR;
  168. return resultEntity;
  169. }
  170. if (DataManager.LicString == null || DataManager.LicString != licString)
  171. {
  172. DataManager.LicString = licString;
  173. DataManager.LicDataSet = customer;
  174. }
  175. resultEntity.LicenseInfo = new DataSet("LIC");
  176. resultEntity.LicenseInfo.Merge(DataManager.LicDataSet.Tables["Info"]);
  177. }
  178. }
  179. #endregion
  180. #region 形成需要执行的SQL语句
  181. requestEntity.SessionKey = Guid.NewGuid().ToString().ToUpper();
  182. string strSql = "PRO_SYS_DoLogin";
  183. OracleParameter[] paras = new OracleParameter[]
  184. {
  185. new OracleParameter("in_AccountCode",requestEntity.AccountCode),
  186. new OracleParameter("in_UserCode",requestEntity.UserCode),
  187. new OracleParameter("in_UserPassword",requestEntity.Password),
  188. new OracleParameter("in_MAC",requestEntity.MACAddress==null ? " ":requestEntity.MACAddress),//wangx 2015/08/11 pda出现问题所修改
  189. new OracleParameter("in_SessionKey",requestEntity.SessionKey),
  190. new OracleParameter("in_ComputerName",requestEntity.ComputerName),
  191. new OracleParameter("in_IP",requestEntity.IPAddress),
  192. new OracleParameter("in_LoginType",actionType),
  193. new OracleParameter("out_LoginStatus",OracleDbType.Int16, ParameterDirection.Output),
  194. new OracleParameter("out_UserOrganization",OracleDbType.RefCursor, ParameterDirection.Output),
  195. new OracleParameter("out_Navigation",OracleDbType.RefCursor, ParameterDirection.Output), //用户导航菜单
  196. new OracleParameter("out_UserRightData",OracleDbType.RefCursor, ParameterDirection.Output), //用户功能权限
  197. new OracleParameter("out_UserRangeRightData",OracleDbType.RefCursor, ParameterDirection.Output), //用户范围权限
  198. new OracleParameter("out_Function",OracleDbType.RefCursor, ParameterDirection.Output) //系统功能菜单
  199. };
  200. #endregion
  201. oracleConn.Open();
  202. int loginStatus = 0;
  203. DataSet returnDataSet = oracleConn.ExecStoredProcedure(strSql, paras);
  204. foreach (Constant.SysCacheTable itemEnum in Enum.GetValues(typeof(Constant.SysCacheTable)))
  205. {
  206. string strSysConfig = "Select * From " + itemEnum.ToString();
  207. DataTable dtTemp = oracleConn.GetSqlResultToDt(strSysConfig);
  208. dtTemp.TableName = itemEnum.ToString();
  209. if (resultEntity.SysParameter == null)
  210. resultEntity.SysParameter = new DataSet();
  211. resultEntity.SysParameter.Tables.Add(dtTemp);
  212. }
  213. oracleConn.Close();
  214. if (returnDataSet != null && 5 <= returnDataSet.Tables.Count)
  215. {
  216. DataRow dataRow = returnDataSet.Tables[0].Rows[0];
  217. #region 给用户实体赋值
  218. resultEntity.CurrentUserEntity.UserID = Convert.ToInt16(dataRow["UserID"].ToString().Trim());
  219. resultEntity.CurrentUserEntity.UserCode = dataRow["UserCode"].ToString().Trim();
  220. resultEntity.CurrentUserEntity.UserName = dataRow["UserName"].ToString().Trim();
  221. resultEntity.CurrentUserEntity.AccountID = Convert.ToInt16(dataRow["AccountID"].ToString().Trim());
  222. resultEntity.CurrentUserEntity.AccountCode = dataRow["AccountCode"].ToString().Trim();
  223. resultEntity.CurrentUserEntity.AccountName = dataRow["AccountName"].ToString().Trim();
  224. resultEntity.CurrentUserEntity.Password = dataRow["Password"].ToString().Trim();
  225. resultEntity.CurrentUserEntity.OrganizationID = Convert.ToInt16(dataRow["OrganizationID"].ToString().Trim());
  226. resultEntity.CurrentUserEntity.OrganizationCode = dataRow["OrganizationCode"].ToString().Trim();
  227. resultEntity.CurrentUserEntity.SessionKey = dataRow["SessionKey"].ToString().Trim();
  228. resultEntity.CurrentUserEntity.ValueFlag = Convert.ToInt16(dataRow["ValueFlag"].ToString().Trim());
  229. resultEntity.CurrentUserEntity.LimitMAC = dataRow["LimitMAC"].ToString().Trim();
  230. resultEntity.CurrentUserEntity.CanSmartLogin = Convert.ToInt16(dataRow["CanSmartLogin"].ToString().Trim());
  231. resultEntity.CurrentUserEntity.Remarks = dataRow["Remarks"].ToString().Trim();
  232. resultEntity.CurrentUserEntity.IsGroutingWorker = Convert.ToInt16(dataRow["IsGroutingWorker"].ToString());
  233. resultEntity.CurrentUserEntity.UserNavigationData = returnDataSet.Tables[1]; // 用户的主导航菜单数据
  234. resultEntity.CurrentUserEntity.UserRightData = returnDataSet.Tables[2];// 用户的功能权限限制数据
  235. resultEntity.CurrentUserEntity.UserRangeRightData = returnDataSet.Tables[3]; // 用户的范围权限限制数据
  236. resultEntity.CurrentUserEntity.FunctionData = returnDataSet.Tables[4]; //系统功能菜单
  237. #endregion
  238. DataTable atable = oracleConn.GetSqlResultToDt("select * from tp_mst_account t where t.accountid=:accountid",
  239. new OracleParameter[] { new OracleParameter(":accountid", resultEntity.CurrentUserEntity.AccountID) });
  240. if (atable != null && atable.Rows.Count > 0)
  241. {
  242. resultEntity.CurrentUserEntity.TAG_CODE = atable.Rows[0]["tagcode"] + "";
  243. resultEntity.CurrentUserEntity.WORK_CODE = atable.Rows[0]["workcode"] + "";
  244. }
  245. }
  246. else if (paras[8] != null)
  247. {
  248. loginStatus = Convert.ToInt32(paras[8].Value.ToString());
  249. }
  250. else
  251. {
  252. loginStatus = -1;
  253. }
  254. resultEntity.LoginStatus = loginStatus;
  255. return resultEntity;
  256. }
  257. catch (Exception ex)
  258. {
  259. throw ex;
  260. }
  261. finally
  262. {
  263. if (oracleConn.ConnState == ConnectionState.Open)
  264. {
  265. oracleConn.Close();
  266. }
  267. }
  268. }
  269. /// <summary>
  270. /// 退出登录
  271. /// </summary>
  272. /// <param name="userID">用户ID</param>
  273. /// <param name="actionType">1:PC端;3:移动端</param>
  274. /// <param name="userInfo">用户基本信息</param>
  275. /// <returns>bool</returns>
  276. public static bool Logout(int userID, string actionType, SUserInfo userInfo)
  277. {
  278. IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
  279. try
  280. {
  281. oracleTrConn.Connect();
  282. #region SQL语句形成
  283. string sqlString1 = "UPDATE TP_MST_UserLogin SET "
  284. + " IsLogin = '0',"
  285. + " SessionKey = NULL,"
  286. + " LastLogoutTime = sysdate"
  287. + " WHERE IsLogin = '1'"
  288. + " AND SessionKey = :SessionKey"
  289. + " AND UserID = :userID";
  290. OracleParameter[] parmeters1 = new OracleParameter[]
  291. {
  292. new OracleParameter(":SessionKey",userInfo.SessionKey),
  293. new OracleParameter(":userID",userID),
  294. };
  295. #endregion
  296. int i = oracleTrConn.ExecuteNonQuery(sqlString1, parmeters1);
  297. #region SQL语句形成
  298. string sqlString2 = "INSERT INTO TP_MST_UserLoginLog "
  299. + " (UserID"
  300. + " ,ActionTime"
  301. + " ,ActionType"
  302. + " ,MAC"
  303. + " ,ComputerName"
  304. + " ,IP) "
  305. + " VALUES "
  306. + " (:userID "
  307. + " ,systimestamp "
  308. + " ,:in_actionType"
  309. + " ,:in_MAC "
  310. + " ,:in_ComputerName "
  311. + " ,:in_IP) ";
  312. OracleParameter[] parmeters2 = new OracleParameter[]
  313. {
  314. new OracleParameter(":userID",userID)
  315. ,new OracleParameter(":in_actionType",actionType)
  316. ,new OracleParameter(":in_MAC",userInfo.MACAddress)
  317. ,new OracleParameter(":in_ComputerName",userInfo.ComputerName)
  318. ,new OracleParameter(":in_IP",userInfo.IPAddress)
  319. };
  320. #endregion
  321. oracleTrConn.ExecuteNonQuery(sqlString2, parmeters2);
  322. oracleTrConn.Commit();
  323. oracleTrConn.Disconnect();
  324. return true;
  325. }
  326. catch (Exception ex)
  327. {
  328. if (oracleTrConn.ConnState == ConnectionState.Open)
  329. {
  330. oracleTrConn.Rollback();
  331. }
  332. throw ex;
  333. }
  334. finally
  335. {
  336. if (oracleTrConn.ConnState == ConnectionState.Open)
  337. {
  338. oracleTrConn.Disconnect();
  339. }
  340. }
  341. }
  342. /// <summary>
  343. /// 服务访问验证
  344. /// </summary>
  345. /// <param name="requestEntity">验证实体</param>
  346. /// <param name="userInfo">用户基本信息</param>
  347. /// <returns>string</returns>
  348. public static string AuthenticateRepeatLogin(LoginRequestEntity requestEntity, out SUserInfo userInfo)
  349. {
  350. userInfo = null;
  351. if (DataManager.LicDataSet != null)
  352. {
  353. DateTime vBegin = Convert.ToDateTime(DataManager.LicDataSet.Tables["Info"].Rows[0]["ValidityBegin"]);
  354. DateTime vEnd = Convert.ToDateTime(DataManager.LicDataSet.Tables["Info"].Rows[0]["ValidityEnd"]);
  355. DateTime n = DateTime.Now.Date;
  356. if (n < vBegin || n > vEnd)
  357. {
  358. return "3";
  359. }
  360. }
  361. IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
  362. try
  363. {
  364. oracleConn.Open();
  365. int loginStatus = 0;
  366. OracleParameter[] paras = new OracleParameter[]{
  367. new OracleParameter("in_accountCode", OracleDbType.Varchar2, requestEntity.AccountCode,ParameterDirection.Input),
  368. new OracleParameter("in_userCode", OracleDbType.Varchar2, requestEntity.UserCode,ParameterDirection.Input),
  369. new OracleParameter("in_userPassword", OracleDbType.Varchar2, requestEntity.Password,ParameterDirection.Input),
  370. new OracleParameter("in_sessionKey", OracleDbType.Varchar2, requestEntity.SessionKey,ParameterDirection.Input),
  371. new OracleParameter("out_loginStatus", OracleDbType.Int32, ParameterDirection.Output),
  372. new OracleParameter("out_userInfo", OracleDbType.RefCursor, ParameterDirection.Output)
  373. };
  374. DataSet dsUserInfo = oracleConn.ExecStoredProcedure("PRO_SYS_Authentication", paras);
  375. loginStatus = Convert.ToInt32(paras[4].Value.ToString());
  376. if (loginStatus == 0)
  377. {
  378. if (dsUserInfo != null && dsUserInfo.Tables[0].Rows.Count > 0)
  379. {
  380. userInfo = new SUserInfo();
  381. userInfo.UserID = System.Convert.ToInt32(dsUserInfo.Tables[0].Rows[0]["UserID"]);
  382. userInfo.UserCode = System.Convert.ToString(dsUserInfo.Tables[0].Rows[0]["UserCode"]);
  383. userInfo.UserName = System.Convert.ToString(dsUserInfo.Tables[0].Rows[0]["UserName"]);
  384. userInfo.OrganizationID = System.Convert.ToInt32(dsUserInfo.Tables[0].Rows[0]["OrganizationID"]);
  385. userInfo.OrganizationCode = System.Convert.ToString(dsUserInfo.Tables[0].Rows[0]["OrganizationCode"]);
  386. userInfo.AccountID = System.Convert.ToInt32(dsUserInfo.Tables[0].Rows[0]["AccountID"]);
  387. userInfo.AccountCode = System.Convert.ToString(dsUserInfo.Tables[0].Rows[0]["AccountCode"]);
  388. userInfo.MACAddress = System.Convert.ToString(dsUserInfo.Tables[0].Rows[0]["MAC"]);
  389. userInfo.ComputerName = System.Convert.ToString(dsUserInfo.Tables[0].Rows[0]["Computername"]);
  390. userInfo.IPAddress = System.Convert.ToString(dsUserInfo.Tables[0].Rows[0]["IP"]);
  391. userInfo.SessionKey = requestEntity.SessionKey;
  392. DataTable atable = oracleConn.GetSqlResultToDt("select * from tp_mst_account t where t.accountid=:accountid",
  393. new OracleParameter[] { new OracleParameter(":accountid", userInfo.AccountID) });
  394. if (atable != null && atable.Rows.Count > 0)
  395. {
  396. userInfo.TAG_CODE = atable.Rows[0]["tagcode"] + "";
  397. userInfo.WORK_CODE = atable.Rows[0]["workcode"] + "";
  398. }
  399. }
  400. else
  401. {
  402. return "1"; // wangxin 20150416 else后添加的
  403. }
  404. }
  405. return loginStatus.ToString();
  406. }
  407. finally
  408. {
  409. if (oracleConn.ConnState == ConnectionState.Open)
  410. {
  411. oracleConn.Close();
  412. }
  413. }
  414. }
  415. #endregion
  416. #region 客户端升级
  417. /// <summary>
  418. /// 客户端升级判断
  419. /// </summary>
  420. /// <param name="version">客户端版本号</param>
  421. /// <returns>NeedUpgradeResultEntity客户端是否需要更新信息</returns>
  422. public static NeedUpgradeResultEntity IsNeedUpgrade(string version, string dllVersion)
  423. {
  424. string serverVersion = INIUtility.Instance(INIUtility.IniFile.Config).ReadIniData("VersionSetting", "ClientVersion");//ConfigurationManager.AppSettings["ServerVersion"];
  425. NeedUpgradeResultEntity result = new NeedUpgradeResultEntity();
  426. result.ServerVersion = serverVersion;
  427. result.UpgradeState = false;
  428. result.GradeInfo = "";
  429. string[] versions = version.Split('.');
  430. string[] serverVersions = serverVersion.Split('.');
  431. if (versions == null || serverVersions == null || versions.Length != 4 || serverVersions.Length != 4)
  432. {
  433. result.UpgradeState = false;
  434. result.GradeInfo = "服务端版本信息获取异常,请联系系统管理员。";
  435. return result;
  436. }
  437. //string dbVersion = null;
  438. //try
  439. //{
  440. // IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
  441. // oracleConn.Open();
  442. // dbVersion = oracleConn.GetSqlResultToStr("select Version from T_SYS_UpgradeRecord where releaseid=0");
  443. //}
  444. //catch
  445. //{
  446. // result.UpgradeState = false;
  447. // result.GradeInfo = "数据库版本信息获取异常,请联系系统管理员。";
  448. // return result;
  449. //}
  450. //if (dbVersion == null)
  451. //{
  452. // result.UpgradeState = false;
  453. // result.GradeInfo = "数据库版本信息获取异常,请联系系统管理员。";
  454. // return result;
  455. //}
  456. //if (dbVersion != serverVersion || dbVersion != dllVersion)
  457. //{
  458. // result.UpgradeState = false;
  459. // result.GradeInfo = string.Format("服务端版本信息不一致,请联系系统管理员。{3}服务INI版本【{0}】{3}服务DLL版本【{1}】{3}数据DBR版本【{2}】",
  460. // serverVersion, dllVersion, dbVersion, System.Environment.NewLine);
  461. // return result;
  462. //}
  463. if (versions[1] != "0" && versions[1] != serverVersions[1])
  464. {
  465. result.UpgradeState = false;
  466. result.GradeInfo = string.Format("客户端[{0}]与服务端[{1}]的客户号(版本号第二位)不一致,此客户端不能连接服务器。", version, serverVersion);
  467. }
  468. for (int j = 0; j < versions.Length; j++)
  469. {
  470. int sv = Convert.ToInt32(serverVersions[j]);
  471. int cv = Convert.ToInt32(versions[j]);
  472. if (sv > cv)
  473. {
  474. result.UpgradeState = true;
  475. result.GradeInfo = LoadUpgradeInfo(version, serverVersion);
  476. break;
  477. }
  478. else if (sv < cv)
  479. {
  480. result.UpgradeState = false;
  481. result.GradeInfo = string.Format("客户端版本[{0}]比服务器版本[{1}]高,此客户端不能连接服务器。", version, serverVersion);
  482. }
  483. }
  484. return result;
  485. }
  486. /// <summary>
  487. /// 获取更新履历信息
  488. /// </summary>
  489. /// <param name="version">客户端版本号</param>
  490. /// <param name="serverVersion">最新版本号</param>
  491. /// <returns>string升级信息</returns>
  492. private static string LoadUpgradeInfo(string version, string serverVersion)
  493. {
  494. #region 查询字符串
  495. //string sqlString = "SELECT UpgradeInfoID"
  496. // + ",VersionNo"
  497. // + ",UpgradeType"
  498. // + ",Content"
  499. // + ",CreateTime"
  500. // + " FROM T_SYS_UpgradeInfo"
  501. // + " WHERE UpgradeType = 0";
  502. //if (!string.IsNullOrEmpty(serverVersion) && !string.IsNullOrEmpty(version))
  503. //{
  504. // sqlString = string.Format("{0} AND VersionNo > '{1}' AND VersionNo <= '{2}'", sqlString, version, serverVersion);
  505. // DataSet returnData = DataManager.ExecuteDataset(sqlString);
  506. //}
  507. #endregion
  508. return null;
  509. }
  510. /// <summary>
  511. /// 下载更新程序
  512. /// </summary>
  513. /// <returns>byte[]更新程序</returns>
  514. public static byte[] DownloadUpgradeFile(string flag = null)
  515. {
  516. string filePath = null;
  517. string fup = null;
  518. if (flag == "Public")
  519. {
  520. filePath = "UpgradePublicDownLoadPath";
  521. fup = @"-UpgradePublic.up";
  522. }
  523. else
  524. {
  525. filePath = "UpgradeDownLoadPath";
  526. fup = @"-Upgrade.up";
  527. }
  528. filePath = INIUtility.Instance(INIUtility.IniFile.Config).ReadIniData("PathSetting", filePath);
  529. //ConfigurationManager.AppSettings["UpgradeDownLoadPath"];
  530. // 取得WEB服务器上的文件全路径
  531. string fileFullPath = System.AppDomain.CurrentDomain.BaseDirectory + filePath;
  532. lock (_downloadUpgradeFile)
  533. {
  534. if (!Directory.Exists(fileFullPath))
  535. {
  536. Directory.CreateDirectory(fileFullPath);
  537. }
  538. // zip 压缩
  539. string zipPath = fileFullPath + fup;
  540. if (!File.Exists(zipPath))
  541. {
  542. ZipFileClass.DirectoryToZip(fileFullPath, zipPath);
  543. }
  544. // 文件存在,则将文件读入文件流中返回
  545. if (File.Exists(zipPath))
  546. {
  547. using (FileStream fileStream = new FileStream(zipPath, FileMode.Open, FileAccess.Read))
  548. {
  549. BinaryReader binaryReader = new BinaryReader(fileStream);
  550. return binaryReader.ReadBytes((int)fileStream.Length);
  551. }
  552. }
  553. }
  554. return null;
  555. }
  556. #endregion
  557. }
  558. }