using System.IO;

using System.Data;

using System.Configuration;

using System.ServiceProcess;

using System.Data.SqlClient;

using System.Data.OleDb;

using System.Timers;

using Log4AES;

using System;

namespace DataCollection_model_HD

{

    public partial class Service1 : ServiceBase

    {

        public Service1()

        {

            InitializeComponent();

            InitTimer();

        }

        #region 各种配置的全局定义

        //定义一个dataset 用于暂时存放excel中的数据,后续要存入datatable

        DataSet ds = new DataSet();

        Timer TimModel = new Timer();

        public static string LogPath = ConfigurationManager.AppSettings["LogPath"].ToString();

        public static string WPath = ConfigurationManager.AppSettings["WorkingPath"].ToString();

        public static string APath = ConfigurationManager.AppSettings["ArchivePath"].ToString();

        //数据库登录

        //注意Integrated Security不写（false）表示必须要用pwd登录，true表示不用密码也能进入数据库

        public static string ConnStr = ConfigurationManager.AppSettings["ConnStr"].ToString();

        //用于记录log的时候，机台名字

        public static string machineName = "test";

        #endregion

        #region 定时器的初始化，及其事务

        //这个按钮用于模拟服务(定时器）启动

        public void InitTimer()

        {

            //DFL的定时器

            TimModel.Interval = 15 * 1000;

            //定时器的事务

            TimModel.Elapsed += new ElapsedEventHandler(ElapsedEventDFL);

            TimModel.Enabled = true;

            TimModel.AutoReset = true;

        }

        private void ElapsedEventDFL(object source, ElapsedEventArgs e)

        {

            if (GetFiles("test"))

            {

                //多次读取数据，存在多个文件时但其中某个文件在使用的bug

                ds.Tables.Clear();

                Log4App.WriteLine(" ---- End the collect ! ----", LogPath, machineName, System.Threading.Thread.CurrentThread.ManagedThreadId.ToString(), Log4AES.Type.Information);

            }

            else

            {

                DataToSql("test");

                BackupData("test");

                Log4App.WriteLine(" ---- End the collect ! ----", LogPath, machineName, System.Threading.Thread.CurrentThread.ManagedThreadId.ToString(), Log4AES.Type.Information);

            }

        }

        #endregion

        //log初始化设置

        Log4Application Log4App = new Log4Application();

        /*用于移动源文件到指定文件夹，也就是备份源数据文件

        copy all file in folder Working to Achieve*/

        public void BackupData(string equipName)

        {

            //需要存放（备份）的文件夹路径（Achieve）

            string ArchivePath = APath + equipName + " Equipment Temp. monitoring by third tool\\Archive";

            //读取数据源文件的文件夹路径（Working）

            string WorkingPath = WPath + equipName + " Equipment Temp. monitoring by third tool\\Working";

            //初始化system.IO的配置（路径)

            DirectoryInfo directoryInfo = new DirectoryInfo(WorkingPath);

            //用文件流来获取文件夹中所有文件，存放到

            FileInfo[] files = directoryInfo.GetFiles();

            //循环的把所有机台数据备份到Achieve文件夹

            try

            {

                foreach (FileInfo file in files) // Directory.GetFiles(srcFolder)

                {

                    //使用IO中的Moveto函数进行移动文件操作

                    file.MoveTo(Path.Combine(ArchivePath, file.Name));

                }

            }

            catch (Exception ex)

            {

            }

        }

        //判断Excel是否在被人使用

        public bool IsUsed(String fileName)

        {

            bool result = false;

            try

            {

                FileStream fs = File.OpenWrite(fileName);

                fs.Close();

            }

            catch

            {

                result = true;

            }

            return result;

        }

        //将xls文件投入datatable ， 返回一个datatable为 ds.table[0]

        public bool GetFiles(string equipName)

        {

            bool flag = false;

            //choose all sheet?  or all data in sheet?

            string strExcel = "select * from [Sheet1$]";

            //初始化system.IO的配置（路径)

            DirectoryInfo directoryInfo1 = new DirectoryInfo(WPath + equipName + " Equipment Temp. monitoring by third tool\\Working");

            //用文件流来获取文件夹中所有文件，存放到

            FileInfo[] files1 = directoryInfo1.GetFiles();

            foreach (FileInfo file in files1) // Directory.GetFiles(srcFolder)

            {

                // 连接到excel 数据源,   xlsx要用ACE

                string strConn = ("Provider=Microsoft.ACE.OLEDB.12.0;" + "Data Source= " + file.FullName + "; Extended Properties='Excel 12.0';");

                OleDbConnection OledbConn = new OleDbConnection(strConn);

                if (IsUsed(file.FullName))

                {

                    flag = IsUsed(file.FullName);

                    continue;

                }

                try

                {

                    OledbConn.Open();

                    // 存入datatable，Excel表示哪一个sheet，conn表示连接哪一个Excel文件（jet、ACE）

                    OleDbDataAdapter dAdapter = new OleDbDataAdapter(strExcel, strConn);

                    dAdapter.Fill(ds);

                    OledbConn.Dispose();

                    OledbConn.Close();

                }

                catch (Exception ex)

                {

                }

            }

            return flag;

        }

        // 将datatable中的数据存入SQL server

        public void DataToSql(string equipName)

        {

            //初始化配置 sqlserver的服务器名用户等

            SqlConnection Conn = new SqlConnection(ConnStr);

            Conn.Open();

            //配置SQLBulkCopy方法，真正用于复制数据到数据库的方法

            SqlBulkCopy bulkCopy = new SqlBulkCopy(ConnStr, SqlBulkCopyOptions.UseInternalTransaction)

            {

                DestinationTableName = "ModelTest_HD"

            };

            try

            {

                foreach (DataColumn item in ds.Tables[0].Columns)

                {

                    //只复制所选的相关列

                    bulkCopy.ColumnMappings.Add(item.ColumnName, item.ColumnName);

                }

                //开始复制到sql,每次在数据库中添加

                bulkCopy.WriteToServer(ds.Tables[0]);

                bulkCopy.Close();

                //copy完了，要清空ds的内容，不然会引起循环写入上一个内容

                ds.Tables.Clear();

            }

            catch (Exception ex)

            {

            }

            finally

            {

                //关闭数据库通道

                Conn.Close();

            }

        }

        protected override void OnStart(string[] args)

        {

            //启动服务时做的事情

        }

        protected override void OnStop()

        {

            //停止服务时做的事情

        }

    }

}