git_bsmd/nsw/Source/bsmd.ExcelReadService/ExcelReadService.cs

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.IO;
using System.ServiceProcess;
using System.Text;
using System.Threading.Tasks;
using System.Timers;

using log4net;

using bsmd.database;
using bsmd.email;


namespace bsmd.ExcelReadService
{    
    public partial class ExcelReadService : ServiceBase
    {
        private Timer _timer;
        private object _timerlock = new object();
        private bool processRunning = false;
        private ILog _log = LogManager.GetLogger(typeof(ExcelReadService));

        public ExcelReadService()
        {
            Directory.SetCurrentDirectory(AppDomain.CurrentDomain.BaseDirectory);
            InitializeComponent();
        }

        protected override void OnStart(string[] args)
        {
            this.EventLog.Source = this.ServiceName;
            this.EventLog.Log = "Application";
            this.Init(args);
            this.EventLog.WriteEntry("NSW Excel Read Service started.", EventLogEntryType.Information);
            System.Reflection.Assembly assembly = System.Reflection.Assembly.GetExecutingAssembly();
            FileVersionInfo fvi = FileVersionInfo.GetVersionInfo(assembly.Location);
            string version = fvi.FileVersion;
            this._log.InfoFormat("Starting NSW Excel Read Service. v.{0}", version);
            this.DoOnce();
        }

        private void Init(string[] args)
        {
            this._timer = new Timer();
            this._timer.Interval = Properties.Settings.Default.SleepSeconds * 1000;
            this._timer.Elapsed += _timer_Elapsed;
            this._timer.Enabled = true;
        }

        private void _timer_Elapsed(object sender, ElapsedEventArgs e)
        {
            lock (this._timerlock)
            {
                if (this.processRunning) return;
                else this.processRunning = true;
            }

            if (DBManager.Instance.Connect(Properties.Settings.Default.ConnectionString))
            {

                try
                {
                    string messageId = "";
                    string attachmentLocalPath = null;
                    string mailSender = "";

                    using (BSMDPopClient bsmdPopClient = new BSMDPopClient())
                    {
                        if (!bsmdPopClient.IsConnected)
                        {
                            _log.Error("cannot connect to pop3 server!");
                        }
                        else
                        {


                            // --- BEGIN ------------ TEST 

                            /*
                            ExcelReader er = new ExcelReader(@"E:\work\bsmd\nsw\Source\bsmd.ExcelReadService\2016_01_08_BMSD - EUNoAD Tool Rev 3.0_mit Testdaten.xls");
                            string amsg;
                            MessageCore aCore;
                            bool aReadResult = Util.ProcessSheet(er, out amsg, out aCore);
                            er.Dispose();
                            */

                            // --- END --------------- TEST

                            // check and download next e-Mail, saving attachment
                            while (bsmdPopClient.ReceiveSingleMail(out attachmentLocalPath, out messageId, out mailSender))
                            {

                                bool readResult;
                                string readMessage = "";
                                MessageCore messageCore = null;

                                if (attachmentLocalPath == null)
                                {
                                    _log.WarnFormat("incoming E-Mail did not contain an Excel attachment!");
                                }
                                else
                                {

                                    // try to read/import attachment
                                    using (ExcelReader reader = new ExcelReader(attachmentLocalPath))
                                    {
                                        readResult = Util.ProcessSheet(reader, out readMessage, out messageCore);
                                        if (!readResult)
                                            _log.Error("Excel sheet could not be interpreted");
                                    }

                                    // TODO: Quittung / set messagecore to createreport and let reportGenerator create a reply?

                                    // create a reply sheet (template + scanned highlighted content for verification

                                    string confirmationExcelFilePath = Util.CreateConfirmationSheet(messageCore);
                                    List<string> sendItems = new List<string>();
                                    sendItems.Add(confirmationExcelFilePath);
                                    // send reply sheet back to sender
                                    BSMDMail.SendNSWReportWithAttachments(Properties.Settings.Default.SendEMailSubject, sendItems);

                                    // remove e-Mail
                                    _log.InfoFormat("deleting mail with messageId {0}", messageId);
                                    _log.InfoFormat("mail delete {0}", bsmdPopClient.DeleteMessageByMessageId(messageId) ? "successful" : "failed");

                                    // remove attachment
                                    _log.InfoFormat("removing local file {0}", attachmentLocalPath);

                                    if(!Properties.Settings.Default.TestMode)
                                        File.Delete(attachmentLocalPath);
                                }

                                attachmentLocalPath = null;
                            }
                        }
                    }

                    DBManager.Instance.Disconnect();
                }
                catch (Exception ex)
                {
                    _log.ErrorFormat("Exception occurred: {0}", ex.ToString());
                }
            }
            else
            {                
                _log.Error("DB Connection failure");
            }

            lock (this._timerlock)
            {
                this.processRunning = false;
            }

        }

        protected override void OnStop()
        {
            this._log.Info("Stopping NSW Excel Read Service.");
        }

        internal void DoOnce()
        {
            this._timer_Elapsed(null, null);
        }

    }
}