using System;
|
using System.Collections.Generic;
|
using System.ComponentModel;
|
using System.Data;
|
using System.Linq;
|
using System.Text;
|
using System.Diagnostics;
|
using System.IO;
|
using System.Net;
|
using System.Collections;
|
using System.Xml;
|
|
namespace CY_DocumentSynchroWCFService
|
{
|
public partial class ServerUpdate
|
{
|
public bool IsFirst
|
{
|
get;
|
set;
|
}
|
|
public Sys_Update m_Sys_Update
|
{
|
get;
|
set;
|
}
|
|
public ServerUpdate(Sys_Update m_Sys_Update_Parm, bool isFirst = false)
|
{
|
IsFirst = isFirst;
|
m_Sys_Update = m_Sys_Update_Parm;
|
}
|
|
private string updateUrl = string.Empty;
|
private string tempUpdatePath = string.Empty;
|
XmlFiles updaterXmlFiles = null;
|
private int availableUpdate = 0;
|
bool isRun = false;
|
string mainAppExe = "";
|
private IList<string> verList = null;
|
bool IsUpdateSql = false;
|
string strCode = string.Empty;
|
string ApplicationPath = "";
|
List<Sys_Update> m_Sys_UpdateList = new List<Sys_Update>();
|
public delegate void SetlvUpdateListItem(string[] arry);
|
|
public delegate void CloseMain();
|
|
public void FrmUpdate_Load()
|
{
|
#if DEBUG
|
ApplicationPath = System.AppDomain.CurrentDomain.BaseDirectory.Replace("\\bin\\Debug", "");
|
#else
|
ApplicationPath = System.AppDomain.CurrentDomain.BaseDirectory ;
|
#endif
|
//if (!IsCanUpdate())
|
//{
|
// return;
|
//}
|
IsCanUpdate();
|
Init();
|
System.Threading.Thread.Sleep(2000);
|
DownUpdateFile();
|
}
|
|
//初始化
|
private void Init()
|
{
|
string localXmlFile = ApplicationPath + "\\UpdateList.xml";
|
string serverXmlFile = string.Empty;
|
Sys_Update m_Sys_Update = new Sys_Update();
|
try
|
{
|
//从本地读取更新配置文件信息
|
updaterXmlFiles = new XmlFiles(localXmlFile);
|
}
|
catch
|
{
|
return;
|
}
|
if (string.IsNullOrEmpty(strCode))
|
{
|
return;
|
}
|
//获取服务器地址
|
updateUrl = updaterXmlFiles.GetNodeValue("//Url");
|
string localVersion = updaterXmlFiles.GetNodeValue("//Version");
|
verList = new List<string>();
|
try
|
{
|
bool isCanUpdate = false;
|
RegisterService.RegisterSystemClient client = new RegisterService.RegisterSystemClient("WSHttpBinding_IRegisterSystem");
|
string[] newVewArry = new string[]{
|
};
|
int isNew = 0;
|
client.GetNewVersion(out newVewArry, out isNew, strCode, localVersion);
|
if (isNew == 1)
|
{
|
if (newVewArry.Length > 0)
|
{
|
foreach (string str in newVewArry)
|
{
|
verList.Add(str);
|
}
|
}
|
if (verList.Count > 0)
|
{
|
// IDictionary<int, string[]> htUpdateFile = new Dictionary<int, string[]>();
|
Hashtable htUpdateFile = new Hashtable();
|
foreach (string ver in verList)
|
{
|
AppUpdater appUpdater = new AppUpdater();
|
appUpdater.UpdaterUrl = updateUrl + "/" + strCode + "//" + ver + "//UpdateList.xml";
|
|
//与服务器连接,下载更新配置文件
|
string tempUpdateChildPath = string.Empty;
|
try
|
{
|
tempUpdatePath = Environment.GetEnvironmentVariable("Temp") + "\\" + "_" + updaterXmlFiles.FindNode("//Application").Attributes["applicationId"].Value + "_" + "y" + "_" + "x" + "_" + "m" + "_" + "\\";
|
tempUpdateChildPath = tempUpdatePath + ver + "\\";
|
appUpdater.DownAutoUpdateFile(tempUpdateChildPath);
|
}
|
catch
|
{
|
return;
|
}
|
|
//获取更新文件列表
|
serverXmlFile = tempUpdateChildPath + "UpdateList.xml";
|
if (!File.Exists(serverXmlFile))
|
{
|
return;
|
}
|
availableUpdate = appUpdater.CheckForUpdate(serverXmlFile, localXmlFile, out htUpdateFile);
|
if (availableUpdate > 0)
|
{
|
for (int i = 0; i < htUpdateFile.Count; i++)
|
{
|
string[] fileArray = (string[])htUpdateFile[i];
|
Sys_Update m_Sys_Update_XXXX = new Sys_Update();
|
m_Sys_Update_XXXX.NowName = fileArray[0];
|
m_Sys_Update_XXXX.NowVersion = fileArray[1];
|
m_Sys_UpdateList.Add(m_Sys_Update_XXXX);
|
}
|
}
|
}
|
if (htUpdateFile.Count > 0)
|
{
|
isCanUpdate = true;
|
foreach (var item in htUpdateFile)
|
{
|
int i = 0;
|
string[] fileArray = (string[])htUpdateFile[i];
|
Sys_Update m_Sys_Update_XXXX = new Sys_Update();
|
m_Sys_Update_XXXX.NowName = fileArray[0];
|
m_Sys_Update_XXXX.NowVersion = fileArray[1];
|
m_Sys_UpdateList.Add(m_Sys_Update_XXXX);
|
}
|
}
|
else
|
{
|
isCanUpdate = false;
|
}
|
}
|
}
|
if (!isCanUpdate)
|
{
|
return;
|
}
|
}
|
catch (Exception ex)
|
{
|
return;
|
}
|
}
|
|
//根据更新时间判断是否能够更新
|
public bool IsCanUpdate()
|
{
|
string updateTime = string.Empty;
|
bool isCanUpdate = true;
|
try
|
{
|
string updateTimeXML = ApplicationPath + "\\UpdateTime.xml";
|
XmlFiles updateTimeXMLFile = new XmlFiles(updateTimeXML);
|
updateTime = updateTimeXMLFile.GetNodeValue("//LastUpdateTime");
|
strCode = updateTimeXMLFile.GetNodeValue("//SystemCode").Trim();
|
if (IsFirst)
|
{
|
if (string.IsNullOrEmpty(updateTime))
|
{
|
isCanUpdate = true;
|
}
|
else
|
{
|
DateTime nowDateTime = DateTime.Now;
|
DateTime updateDateTime = DateTime.Parse(updateTime).AddDays(30);
|
if (updateDateTime.CompareTo(nowDateTime) >= 0)
|
{
|
isCanUpdate = false;
|
}
|
else
|
{
|
isCanUpdate = true;
|
}
|
}
|
}
|
string nowDateTimeStr = DateTime.Now.ToShortDateString();
|
updateTimeXMLFile.UpdateNodeValue("//LastUpdateTime", nowDateTimeStr);
|
}
|
catch (Exception ex)
|
{
|
isCanUpdate = true;
|
}
|
return isCanUpdate;
|
}
|
|
private void DownUpdateFile()
|
{
|
//this.Cursor = Cursors.WaitCursor;
|
mainAppExe = updaterXmlFiles.GetNodeValue("//EntryPoint");
|
Process[] allProcess = Process.GetProcesses();
|
foreach (Process p in allProcess)
|
{
|
|
if (p.ProcessName.ToLower() + ".exe" == mainAppExe.ToLower())
|
{
|
for (int i = 0; i < p.Threads.Count; i++)
|
p.Threads[i].Dispose();
|
p.Kill();
|
isRun = true;
|
//break;
|
}
|
}
|
WebClient wcClient = new WebClient();
|
for (int i = 0; i < m_Sys_UpdateList.Count; i++)
|
{
|
Sys_Update item = m_Sys_UpdateList[i];
|
string UpdateFile = item.NowName;
|
string ver = item.NowVersion;
|
if (UpdateFile == "更新数据库")
|
{
|
IsUpdateSql = true;
|
continue;
|
}
|
string updateFileUrl = updateUrl + "/" + strCode + "//" + ver + "//" + UpdateFile;
|
long fileLength = 0;
|
|
WebRequest webReq = WebRequest.Create(updateFileUrl);
|
WebResponse webRes = webReq.GetResponse();
|
fileLength = webRes.ContentLength;
|
|
try
|
{
|
Stream srm = webRes.GetResponseStream();
|
StreamReader srmReader = new StreamReader(srm);
|
byte[] bufferbyte = new byte[fileLength];
|
int allByte = (int)bufferbyte.Length;
|
int startByte = 0;
|
while (fileLength > 0)
|
{
|
// Application.DoEvents();
|
int downByte = srm.Read(bufferbyte, startByte, allByte);
|
if (downByte == 0)
|
{
|
break;
|
};
|
startByte += downByte;
|
allByte -= downByte;
|
// pbDownFile.Value += downByte;
|
|
float part = (float)startByte / 1024;
|
float total = (float)bufferbyte.Length / 1024;
|
int percent = Convert.ToInt32((part / total) * 100);
|
|
// this.lvUpdateList.Items[i].SubItems[2].Text = percent.ToString() + "%";
|
|
}
|
|
string tempPath = tempUpdatePath + ver + "//" + UpdateFile;
|
CreateDirtory(tempPath);
|
FileStream fs = new FileStream(tempPath, FileMode.OpenOrCreate, FileAccess.Write);
|
fs.Write(bufferbyte, 0, bufferbyte.Length);
|
srm.Close();
|
srmReader.Close();
|
fs.Close();
|
|
}
|
catch (WebException ex)
|
{
|
return;
|
}
|
finally
|
{
|
webRes.Close();
|
}
|
}
|
//InvalidateControl();
|
//this.Cursor = Cursors.Default;
|
}
|
//创建目录
|
private void CreateDirtory(string path)
|
{
|
if (!File.Exists(path))
|
{
|
string[] dirArray = path.Split('\\');
|
string temp = string.Empty;
|
for (int i = 0; i < dirArray.Length - 1; i++)
|
{
|
temp += dirArray[i].Trim() + "\\";
|
if (!Directory.Exists(temp))
|
Directory.CreateDirectory(temp);
|
}
|
}
|
}
|
|
//复制文件;
|
public void CopyFile(string sourcePath, string objPath)
|
{
|
// char[] split = @"\".ToCharArray();
|
if (!Directory.Exists(objPath))
|
{
|
Directory.CreateDirectory(objPath);
|
}
|
string[] files = Directory.GetFiles(sourcePath);
|
for (int i = 0; i < files.Length; i++)
|
{
|
string[] childfile = files[i].Split('\\');
|
File.Copy(files[i], objPath + @"\" + childfile[childfile.Length - 1], true);
|
}
|
string[] dirs = Directory.GetDirectories(sourcePath);
|
for (int i = 0; i < dirs.Length; i++)
|
{
|
string[] childdir = dirs[i].Split('\\');
|
CopyFile(dirs[i], objPath + @"\" + childdir[childdir.Length - 1]);
|
}
|
}
|
|
//点击完成复制更新文件到应用程序目录
|
private void btnFinish_Click()
|
{
|
try
|
{
|
UpdateSql();
|
foreach (string ver in verList)
|
{
|
string tempUpdateChildPath = tempUpdatePath + ver + "\\";
|
CopyFile(tempUpdateChildPath, Directory.GetCurrentDirectory());
|
}
|
System.IO.Directory.Delete(tempUpdatePath, true);
|
}
|
catch (Exception ex)
|
{
|
return;
|
}
|
if (true == this.isRun)
|
Process.Start(mainAppExe);
|
}
|
|
/// <summary>
|
/// 更新SQL语句
|
/// </summary>
|
public void UpdateSql()
|
{
|
if (IsUpdateSql)
|
{
|
if (verList.Count > 0)
|
{
|
foreach (string ver in verList)
|
{
|
string serverXmlPath = tempUpdatePath + ver + "\\UpdateList.xml";
|
|
XmlFiles serverXmlFiles = new XmlFiles(serverXmlPath);
|
|
XmlNodeList newSqlList = serverXmlFiles.GetNodeList("AutoUpdater/SQLList");
|
if (newSqlList != null && newSqlList.Count > 0)
|
{
|
|
for (int i = 0; i < newSqlList.Count; i++)
|
{
|
string sqlStr = newSqlList.Item(i).InnerText;
|
try
|
{
|
//AccessHelper.excuteSql(sqlStr);
|
}
|
catch (Exception ex)
|
{
|
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
//判断主应用程序是否正在运行
|
private bool IsMainAppRun()
|
{
|
string mainAppExe = updaterXmlFiles.GetNodeValue("//EntryPoint");
|
bool isRun = false;
|
Process[] allProcess = Process.GetProcesses();
|
foreach (Process p in allProcess)
|
{
|
|
if (p.ProcessName.ToLower() + ".exe" == mainAppExe.ToLower())
|
{
|
isRun = true;
|
//break;
|
}
|
}
|
return isRun;
|
}
|
}
|
}
|
