工事管理システム製品化対応

using System;

using System.Collections;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Diagnostics;

using System.Drawing;

using System.IO;

using System.Linq;

using System.Security.Cryptography;

using System.Text;

using System.Threading.Tasks;

using System.Windows.Forms;

using System.IO.Compression;

namespace UpDateCopy

{

    public partial class FrmCopy : Form

    {

        #region 定数

        /// <summary>

        /// コピー元パス

        /// </summary>

        private static string s_SrcPath = string.Format(@"{0}{1}", Path.GetTempPath(), ClsCommon.s_HONTAI_MODULE);

        /// <summary>

        /// コピー元パス

        /// </summary>

        private static string s_DestPath = System.Environment.CurrentDirectory;

        #endregion

        #region 変数

        /// <summary>

        /// クリエイトフォルダ一覧リスト

        /// </summary>

        private List<string> m_CreateFolderList = new List<string>();

        /// <summary>

        /// コピーファイル一覧リスト

        /// </summary>

        private List<string> m_CopyFileList = new List<string>();

        #endregion

        #region スレッド使用定義

        /// <summary>

        /// コントロールの値を変更するためのデリゲート

        /// </summary>

        /// <param name="num"></param>

        private delegate void SetProgressValueDelegate(int num);

        private delegate void SetProgressMaxDelegate();

        /// <summary>

        /// バックグラウンド処理が終わった時にコントロールの値を変更するためのデリゲート

        /// </summary>

        private delegate void ThreadCompletedDelegate();

        /// <summary>

        /// 別処理をするためのスレッド

        /// </summary>

        private System.Threading.Thread workerThread;

        /// <summary>

        /// デリゲートの作成

        /// </summary>

        SetProgressValueDelegate m_progressDlg = null;

        SetProgressMaxDelegate m_progressEnd = null;

        ThreadCompletedDelegate m_completeDlg = null;

        /// <summary>

        /// プログレスバー使用カウント

        /// </summary>

        private int m_ProgressCount = 0;

        #endregion

        #region コンストラクタ

        public FrmCopy()

        {

            InitializeComponent();

        }

        #endregion

        #region 画面ロード

        /// <summary>

        /// 画面ロード

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void FrmCopy_Load(object sender, EventArgs e)

        {

            try

            {

                // バージョン情報を取得する

                lblVersion.Text = string.Format("Version.{0}", ClsCommon.ProductVersionInfo.ProductVersion);

                if (File.Exists(ClsCommon.s_DefinitionFileName))

                {

                    // 定義ファイル読込

                    ClsCommon.DefinitionFileInit();

                    // FTP接続情報作成

                    ClsCommon.m_FTP_USER_NAME = ClsCommon.m_DFRModel.FTPConnect.FTPUser;

                    ClsCommon.m_FTP_PASSWORD = ClsCommon.m_DFRModel.FTPConnect.FTPPassword;

                    ClsCommon.m_FTP_SERVER_PATH = ClsCommon.m_DFRModel.FTPConnect.FTPServer;

                }

                else

                {

                    // FTP接続情報作成

                    ClsCommon.m_FTP_USER_NAME = ClsCommon.s_FTP_USER_NAME;

                    ClsCommon.m_FTP_PASSWORD = ClsCommon.s_FTP_PASSWORD;

                    ClsCommon.m_FTP_SERVER_PATH = ClsCommon.s_FTP_SERVER_PATH;

                }

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

            }

        }

        #endregion

        #region フォームクローズ処理

        /// <summary>

        /// フォームクローズ処理

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void FrmCopy_FormClosing(object sender, FormClosingEventArgs e)

        {

            // 終了処理

            TermProcess();

        }

        #endregion

        #region 終了処理

        /// <summary>

        /// 終了処理

        /// </summary>

        private void TermProcess()

        {

            try

            {

                // ターゲットを起動する

                string ExecProc = System.Environment.CurrentDirectory + "\\" + ClsCommon.s_TargetProcess + ".exe";

                //logger.ErrorFormat("{0}：起動プログラム：{1}", this.Name, ExecProc);

                // ▼自動更新VPS対応▼ 

                // 起動パラメータつきで起動する

                Process exec = Process.Start(ExecProc, ClsCommon.s_KIDOU_PARAM);

                //            Process exec = Process.Start(ExecProc);

                // ▲自動更新VPS対応▲

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

            }

        }

        #endregion

        #region 工程管理の終了を待ってコピーする

        /// <summary>

        /// 工程管理の終了を待ってコピーする

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void FrmCopy_Shown(object sender, EventArgs e)

        {

            try

            {

                // コマンドライン引数を取る

                string[] cmds = Environment.GetCommandLineArgs();

                lblMessage.Text = ClsCommon.s_TargetProcess + "を更新しています。\nそのまましばらくお待ちください。";

                lblMessage.Refresh();

                // ▼自動更新VPS対応▼ 

                System.Threading.Thread.Sleep(1000);

                string tempPath = Path.GetTempPath();

                // アップデートファイルパス

                string updateFilePath = string.Format("{0}{1}", tempPath, ClsCommon.s_HONTAI_MODULE);

                // サーバ更新モジュールzipファイル（ダウンロード後）

                string updateModuleZip = string.Format("{0}.zip", updateFilePath);

                // 「現場監督秘書（本体）zipの展開フォルダが存在するかチェック

                if (System.IO.Directory.Exists(updateFilePath))

                {

                    // zip削除

                    System.IO.File.Delete(updateModuleZip);

                    // ダウンロードファイル削除

                    System.IO.Directory.Delete(updateFilePath, true);

                }

                // 「現場監督秘書（本体）zipダウンロード

                string strServerPath = string.Format("{0}{1}.zip", ClsCommon.m_FTP_SERVER_PATH, ClsCommon.s_HONTAI_MODULE);

                Download(strServerPath, updateModuleZip);

                // ダウンロードした「現場監督秘書（本体）zip解凍

                ZipFile.ExtractToDirectory(updateModuleZip, tempPath);

                // ▲自動更新VPS対応▲

                // プログレスバー初期設定

                string[] files = Directory.GetFiles(s_SrcPath);

                progressBar.Visible = true;

                progressBar.Minimum = 0;

                progressBar.Maximum = Directory.GetFiles(s_SrcPath, "*", SearchOption.AllDirectories).Length;

                progressBar.Value = 0;

                // メインプログラムの終了を待つ

                while (true)

                {

                    bool Aliveflg = false;

                    int cnt = 0;

                    Process[] processList = Process.GetProcesses();

                    foreach (Process p in processList)

                    {

                        Aliveflg = false;

                        if (p.ProcessName == ClsCommon.s_TargetProcess)

                        {

                            if (p.Responding)

                            {

                                Aliveflg = true;

                                Console.WriteLine("OK");

                                break;

                            }

                        }

                        Debug.WriteLine(++cnt + ":" + p.ProcessName);

                    }

                    if (!Aliveflg) break;

                    System.Threading.Thread.Sleep(1000);

                }

                System.Threading.Thread.Sleep(1000);

                // ファイルコピー

                CopyFileProcess();

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

                this.Close();

            }

        }

        #endregion

        #region ファイルコピーメイン

        /// <summary>

        /// ファイルコピーメイン

        /// </summary>

        /// <param name="dir"></param>

        private void CopyFileProcess()

        {

            try

            {

                lblMessage.Text = ClsCommon.s_TargetProcess + "を更新しています。\nそのまましばらくお待ちください。";

                lblMessage.Refresh();

                //印刷を別スレッドで実行する

                m_ProgressCount = 0;

                workerThread = new System.Threading.Thread(new System.Threading.ThreadStart(DoWork));

                workerThread.IsBackground = true;

                workerThread.Start();

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

            }

        }

        #endregion

        #region サーバからファイルダウンロード

        // ▼自動更新VPS対応▼ 

        /// <summary>

        /// サーバからファイルダウンロード

        /// </summary>

        /// <param name="serverPath"></param>

        /// <param name="downloadSakiPath"></param>

        private static void Download(String serverPath, String downloadSakiPath)

        {

            //WebClientオブジェクトを作成

            System.Net.WebClient wc = new System.Net.WebClient();

            try

            {

                //ログインユーザー名とパスワードを指定

                wc.Credentials =

                    new System.Net.NetworkCredential(ClsCommon.m_FTP_USER_NAME, ClsCommon.m_FTP_PASSWORD);

                //FTPサーバーからダウンロードする

                wc.DownloadFile(serverPath, downloadSakiPath);

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

            }

            finally

            {

                //解放する

                wc.Dispose();

            }

        }

        // ▲自動更新VPS対応t▲

        #endregion

        #region スレッドメインプロセス

        /// <summary>

        /// スレッドメインプロセス

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        public void DoWork()

        {

            // ----- ここで時間のかかる処理を行う

            try

            {

                //デリゲートの作成

                m_progressDlg = new SetProgressValueDelegate(SetProgressValue);

                m_progressEnd = new SetProgressMaxDelegate(SetProgressMax);

                m_completeDlg = new ThreadCompletedDelegate(ThreadCompleted);

                // ファイルコピー

                CopyDirectory(s_SrcPath, s_DestPath);

                // 完了したときにコントロールの値を変更する

                this.Invoke(m_progressEnd);

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

            }

            finally

            {

                // 終了処理

                this.Invoke(m_completeDlg);

                //デリゲートの廃棄

                m_progressDlg = null;

                m_progressEnd = null;

                m_completeDlg = null;

                // ガーベージコレクト

                GC.Collect();

            }

        }

        #endregion

        #region ファイルをディレクトリごとコピーする

        /// <summary>

        /// ファイルをディレクトリごとコピーする

        /// </summary>

        /// <param name="srcDirName">コピーするディレクトリ</param>

        /// <param name="destDirName">コピー先のディレクトリ</param>

        private void CopyDirectory(string srcDirName, string destDirName)

        {

            try

            {

                // コピー先のディレクトリがないときは作る

                if (!Directory.Exists(destDirName))

                {

                    Directory.CreateDirectory(destDirName);

                    // 属性もコピー

                    File.SetAttributes(destDirName, File.GetAttributes(srcDirName));

                }

                // コピー先のディレクトリ名の末尾に"\"をつける

                if (destDirName[destDirName.Length - 1] != Path.DirectorySeparatorChar)

                {

                    destDirName = destDirName + Path.DirectorySeparatorChar;

                }

                string strMyProcess = string.Format("{0}.exe", Process.GetCurrentProcess().ProcessName);

                // コピー元のディレクトリにあるファイルをコピー

                string[] files = Directory.GetFiles(srcDirName);

                foreach (string f in files)

                {

                    // プログレスバー加算

                    this.Invoke(m_progressDlg, new object[] { ++m_ProgressCount });

                    // 自分は処理しない

                    if (Path.GetFileName(f).IndexOf(strMyProcess) > -1) continue;

                    string destFileName = string.Format(@"{0}\{1}", destDirName, Path.GetFileName(f));

                    // コピー先にファイルが存在する、またはコピー先のファイルが新しい場合はコピーしない

                    if (File.Exists(destFileName) && CompareFileDifference(f, destFileName)) continue;

                    File.Copy(f, destFileName, true);

                }

                // コピー先にあってコピー元にないファイルを削除

                //DeleteNotExistFiles(srcDirName, destDirName);

                // コピー元のディレクトリにあるディレクトリについて、再帰的に呼び出す

                string[] dirs = Directory.GetDirectories(srcDirName);

                foreach (string dir in dirs)

                {

                    CopyDirectory(dir, destDirName + Path.GetFileName(dir));

                }

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

            }

        }

        #endregion

        #region ファイルのタイムスタンプを比較する

        /// <summary>

        /// ファイルのタイムスタンプを比較する

        /// </summary>

        /// <param name="srcHash">コピー元ファイル</param>

        /// <param name="destHash">コピー先ファイル</param>

        /// <returns></returns>

        private bool CompareFileDifference(string SrcFile, string DestFile)

        {

            try

            {

                // ハッシュ値を取得する

                // ----- コピー元ファイル

                string srcHash = ClsCommon.GetFileHashData(@SrcFile);

                // ----- コピー先ファイル

                string destHash = ClsCommon.GetFileHashData(@DestFile);

                // ファイルが同じ

                if (srcHash == destHash) return true;

                // 更新時間を確認する

                // ----- コピー元ファイル

                DateTime srcTimeStamp = ClsCommon.GetFileTimeStamp(SrcFile, 'U');

                // ----- コピー先ファイル

                DateTime destTimeStamp = ClsCommon.GetFileTimeStamp(DestFile, 'U');

                // コピー元ファイルが新しくない

                if (srcTimeStamp <= destTimeStamp) return true;

                return false;

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

                return true;

            }

        }

        #endregion

        #region コピー先にありコピー元にないファイルを削除する

        /// <summary>

        /// コピー先にありコピー元にないファイルを削除する

        /// </summary>

        /// <param name="srcDirName">比較先のフォルダ</param>

        /// <param name="destDirName">比較もとのフォルダ</param>

        private void DeleteNotExistFiles(string srcDirName, string destDirName)

        {

            try

            {

                // sourceDirNameの末尾に"\"をつける

                if (srcDirName[srcDirName.Length - 1] != Path.DirectorySeparatorChar)

                {

                    srcDirName = srcDirName + Path.DirectorySeparatorChar;

                }

                string strMyProcess = Process.GetCurrentProcess().ProcessName;

                // destDirNameにありsourceDirNameにないファイルを削除する

                string[] files = Directory.GetFiles(destDirName);

                foreach (string f in files)

                {

                    string strFileName = Path.GetFileName(f);

                    // 自プロセス関連ファイルを削除しない

                    if (strFileName.IndexOf(strMyProcess) > -1) continue;

                    string strSrcPath = string.Format("{0}{1}", srcDirName, strFileName);

                    // ファイル存在確認

                    if (File.Exists(strSrcPath)) continue;

                    // ファイル削除

                    File.Delete(f);

                }

                // destDirNameにありsourceDirNameにないフォルダを削除する

                string[] folders = Directory.GetDirectories(destDirName);

                foreach (string folder in folders)

                {

                    // フォルダ存在確認

                    if (Directory.Exists(srcDirName + Path.GetFileName(folder))) continue;

                    // フォルダ削除

                    Directory.Delete(folder, true);

                }

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

            }

        }

        #endregion

        #region プロセス終了時ハンドラ

        /// <summary>

        /// プロセス終了時ハンドラ

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void ThreadCompleted()

        {

            // ----- 処理が終わったときに呼び出される

            try

            {

                string tempPath = Path.GetTempPath();

                // zip削除

                string strZipFile = tempPath + ClsCommon.s_HONTAI_MODULE + ".zip";

                if (File.Exists(strZipFile)) System.IO.File.Delete(strZipFile);

                // ダウンロードファイル削除

                string strDownLoad = tempPath + ClsCommon.s_HONTAI_MODULE;

                if (Directory.Exists(strDownLoad)) System.IO.Directory.Delete(strDownLoad, true);

            }

            catch (Exception ex)

            {

                ClsCommon.ErrorLogWrite(string.Format("システムエラー:{0}：{1}", ClsCommon.GetMethodName(), ex.Message.ToString()));

            }

            finally

            {

                this.Close();

                Application.Exit();

            }

        }

        #endregion

        #region プログレスバーの値を変更する

        /// <summary>

        /// プログレスバーの値を変更する

        /// </summary>

        /// <param name="num"></param>

        private void SetProgressValue(int num)

        {

            // ProgressBarの値を変更する

            progressBar.Value = num;

            progressBar.Update();

            if ((num % 2) == 0)

                System.Threading.Thread.Sleep(10);

        }

        #endregion

        #region プログレスバーの最終値に変更する

        /// <summary>

        /// プログレスバーの最終値に変更する

        /// </summary>

        /// <param name="num"></param>

        private void SetProgressMax()

        {

            // ProgressBarの値を変更する

            progressBar.Value = progressBar.Maximum;

            progressBar.Update();

            System.Threading.Thread.Sleep(500);

        }

        #endregion

    }

}