using Oracle.DataAccess.Client;
using System.Data;
using System;
using System.Windows.Forms;
using System.Runtime.InteropServices;

namespace armds
{
     public partial class Notification_class
    {
        //Библиотеки для посылки сообщений системе
        [DllImport("user32.dll", SetLastError = true)]
        static extern IntPtr FindWindow(string lpClassName, string lpWindowName);
        [DllImport("user32.dll")]
        public static extern int SendMessage(IntPtr hWnd, int Msg, int wParam, int lParam);
        [DllImport("User32.dll")]
        extern static int PostMessage(IntPtr hWnd, UInt32 msg, Int32 wParam, Int32 lParam);

        OracleConnection con;
        OracleCommand cmd;
        OracleDependency dep = null;
        string[] dsName = { "L2.HEAT_STEPS", "L2.HEATS", "L2.CHEM_ANL", "L2.MNLZ_HEAT", "L2.MNLZ_BL", "L2.VKM_HEAT", "ADM.CREW_TMP" };
        
         public Notification_class()
         {
             con = new OracleConnection("DATA SOURCE=CIS;PASSWORD=user;PERSIST SECURITY INFO=True;USER ID=user");
             con.Open();
             cmd = con.CreateCommand();
             dep = new OracleDependency(cmd);
             cmd.Notification.IsNotifiedOnce = false;
             cmd.AddRowid = true;
             

         }
         public bool IsNotifEnabled
         {
             get { return dep.IsEnabled; }
         }
         public void run()
         {
             InitRegistrNotif(OraNotification);
         }
         private void InitRegistrNotif(OnChangeEventHandler value)
        {
                //if (dep.RegisteredResources.Count > 0) return;
                try
                {
                    cmd.CommandType = CommandType.Text;

                    if (con.State != ConnectionState.Open)
                        con.Open();
                    dep.OnChange += value;
                    dep.QueryBasedNotification = true;
                    foreach(string s in dsName)
                    {
                        cmd.CommandText = String.Format("SELECT * FROM {0} WHERE ROWNUM < 1",s);
                        cmd.ExecuteNonQuery();
                    }
                    if(con.State == ConnectionState.Open)
                        con.Close();
                  
                }
                catch ( Exception e )
                {
                    MessageBox.Show( e.Message );
                }
        }
        // ~Notification_class()
        //{
        //    try
        //    {
        //        if (con.State == ConnectionState.Open)
        //        {
        //            //if (dep.IsEnabled)
        //            //    dep.RemoveRegistration(con);
        //            con.Close();
        //        }
        //        con.Dispose();

        //    }
        //    catch ( Exception e )
        //    {
        //          MessageBox.Show(String.Format("~Notification_class(): {0}", e.Message) );
        //    }
        //}
         public void OraNotification(Object src, Oracle.DataAccess.Client.OracleNotificationEventArgs arg)
         {
             if (arg.Source == Oracle.DataAccess.Client.OracleNotificationSource.Data)
             {
                 if (arg.Type == Oracle.DataAccess.Client.OracleNotificationType.Change)
                 {
                     try
                     {
                         foreach (String s in arg.ResourceNames)
                         {
                             switch (s)
                             {
                                 case "L2.HEAT_STEPS":
                                     {
                                         PostMessage(FindWindow(null, "Notification"), 5670, 1, 0);
                                         //Change_DSP = true;
                                     }
                                     break;
                                 case "L2.MNLZ_HEAT":
                                     {
                                         PostMessage(FindWindow(null, "Notification"), 5670, 2, 0);
                                         //Change_UNRS = true;
                                     }
                                     break;
                                 case "L2.CHEM_ANL":
                                     {
                                         PostMessage(FindWindow(null, "Notification"), 5670, 3, 0);
                                         //Change_ANL = true;
                                     }
                                     break;
                                 case "L2.MNLZ_BL":
                                     {
                                         PostMessage(FindWindow(null, "Notification"), 5670, 4, 0);
                                         //Change_BL = true;
                                     }
                                     break;
                                 case "L2.VKM_HEAT":
                                     {
                                         PostMessage(FindWindow(null, "Notification"), 5670, 5, 0);
                                         //Change_UVS = true;
                                     }
                                     break;
                             }
                         }
                     }
                     catch (Exception e)
                     {
                         MessageBox.Show("Ошибка " + e);
                     }
                 }

             }
         }
    }
}