using System.IO;
using System.Data;
using System.Configuration;
using System.ServiceProcess;
using System.Data.SqlClient;
using System.Data.OleDb;
using System.Timers;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()
        {
            //停止服务时做的事情

        }
    }
}