using JamaaTech.Smpp.Net.Client;
using JamaaTech.Smpp.Net.Lib;
using NLog;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace XXX_Common
{
    public class SMPPHelper
    {
        //DOC:  https://github.com/AdhamAwadhi/JamaaSMPP/wiki
        public SmppClient Client = new SmppClient();
        public string TextSMSDelivered = string.Empty;
 
        private static readonly Logger m_logger = LogManager.GetCurrentClassLogger();
 
        /// <summary>
        /// Instaura una connessione al server SMSC (Short Message Service Centre)
        /// </summary>
        /// <param name="systemID"></param>
        /// <param name="password"></param>
        /// <param name="port"></param>
        /// <param name="host"></param>
        /// <param name="systemType"></param>
        /// <param name="defaultServiceType"></param>
        public SMPPHelper(string systemID, string password, int port
                        , string host, string systemType, string defaultServiceType)
        {
            SmppConnectionProperties properties = Client.Properties;
            properties.SystemID = systemID; // "mysystemid";
            properties.Password = password; // "mypassword";
            properties.Port = port; // 2034; //IP port to use
            properties.Host = host; // "196.23.3.12"; //SMSC host name or IP Address
            properties.SystemType = systemType; // "mysystemtype";
            properties.DefaultServiceType = defaultServiceType; // "mydefaultservicetype";
 
            //Handle the SmppClient.ConnectionStateChanged event to receive notifications 
            //when connection status changes
            Client.ConnectionStateChanged += Client_ConnectionStateChanged;
 
            //Resume a lost connection after 30 seconds
            Client.AutoReconnectDelay = 3000;
 
            //Send Enquire Link PDU every 15 seconds
            Client.KeepAliveInterval = 15000;
 
            //Start smpp client
            Client.Start();
        }
 
        private void Client_ConnectionStateChanged(object sender, ConnectionStateChangedEventArgs e)
        {
            m_logger.Debug("SMPP connection status changes to '{0}'.", e.CurrentState);
            switch (e.CurrentState)
            {
                case SmppConnectionState.Closed:
                    //Connection to the remote server is lost
                    //Do something here
 
                    e.ReconnectInteval = 60000; //Try to reconnect after 1 min
                    break;
                case SmppConnectionState.Connected:
                    //A successful connection has been established
                    break;
                case SmppConnectionState.Connecting:
                    //A connection attemp is still on progress
                    break;
            }
        }
 
        public string SendSMS_Synchro(string destinationNr, string sourceAddress, string smsText)
        {
            string strErrorMsg = string.Empty;
            TextMessage msg = new TextMessage();
            int timeOut = 0; //?????????????
 
            try
            {
                m_logger.Debug("Sending SMS to {0}, sourceAddress='{1}'", destinationNr, sourceAddress);
 
                msg.DestinationAddress = destinationNr;     // "255455388333"; //Receipient number
                msg.SourceAddress = sourceAddress;          // "255344338333"; //Originating number
                msg.Text = smsText;
                msg.RegisterDeliveryNotification = true;    //I want delivery notification for this message
 
                Client.MessageDelivered += Client_MessageDelivered; //Per Notifica e verifica del messaggio inviato
 
                //Default encdoing:      System.Text.Encoding.BigEndianUnicode
                //But if you like UTF8:
                //Client.SmppEncodingService = new SmppEncodingService(System.Text.Encoding.UTF8);
 
                //Client.SendMessage(msg, timeOut);
                Client.SendMessage(msg);
            }
            catch (Exception ex)
            {
                m_logger.Error(ex);
                strErrorMsg = string.Format("Error sending to '{0}':\r\n{1}", destinationNr, ex.Message);
            }
            return strErrorMsg;
        }
 
 
        public string SendSMS_Asynchro(string destinationNr, string sourceAddress, string smsText)
        {
            string strErrorMsg = string.Empty;
            TextMessage msg = new TextMessage();
 
            try
            {
                msg.DestinationAddress = destinationNr; // "255455388333"; //Receipient number
                msg.SourceAddress = sourceAddress; // "255344338333"; //Originating number
                msg.Text = smsText; // "Hello, this is my test message!";
                msg.RegisterDeliveryNotification = true; //I want delivery notification for this message
 
                // ??? SmppClient client = GetSmppClient();
                Client.BeginSendMessage(msg, SendMessageCompleteCallback, Client);
            }
            catch (Exception ex)
            {
                m_logger.Error(ex);
                strErrorMsg = string.Format("Error sending to '{0}':\r\n{1}", destinationNr, ex.Message);
            }
            return strErrorMsg;
        }
 
        #region Private methods
        private void Client_MessageDelivered(object sender, MessageEventArgs e)
        {
            try
            {
                TextMessage msg = e.ShortMessage as TextMessage;
 
                //parse msg.Text for more details
                m_logger.Debug(msg.Text);
 
                TextSMSDelivered = msg.Text;
            }
            catch (Exception ex)
            {
                m_logger.Error(ex);
            }
        }
 
        private void SendMessageCompleteCallback(IAsyncResult result)
        {
            try
            {
                SmppClient client = (SmppClient)result.AsyncState;
                client.EndSendMessage(result);
            }
            catch (Exception ex)
            {
                m_logger.Error(ex);
            }
        }
        #endregion
    }
}