Bplus/ApiWeb/ApiProcessToken/Controllers/webservice.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Http;

using System.Xml;
using System.Data;
using ResfullApi.Models;
using System.Configuration;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using System.Xml.Linq;
using ApiProcess.Process;

namespace ApiProcess.Controllers
{
   
   
   
    [Route("api/[controller]/[action]/data")]
    [ApiController]
   

    public class webservice : ControllerBase
    {
        /*
            http://10.226.40.11:8383/api/webservice/subRequest/data
         * Nhan cac dang ky va huy qua SMS
         * 
         * 
         * */

        static readonly log4net.ILog logger = log4net.LogManager.GetLogger(typeof(webservice));




        
        [HttpPost]

        //public string subRequest(HttpRequestMessage request)
        // public HttpResponseMessage subRequest(HttpRequestMessage request)
        //[Produces("text/xml")]
        public IActionResult subRequest([FromBody] XElement xml1)
        {
            

            string request = xml1.ToString();
            logger.Info("Request subRequest from MPS:" + request);
            string result = "";
            //string username1 = xml1.GetElementsByTagName("username")[0].InnerText;
            string ketqua = "0|success";
            ////log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
            ////log4net.Config.XmlConfigurator.Configure();

            try
            {

                //string ten = xml1.Element("username").Value;

                //string prefix = ConfigurationSettings.AppSettings["PREFIX"];
                string prefix = Common.GetValuesAppSetting("webConfig", "PREFIX");
                XmlDocument xml = new XmlDocument();
              
                
                //logger.Debug(request.Content.ReadAsStreamAsync().Result);
                //xml.Load(request);
                xml.LoadXml(request);
                

                string username = xml.GetElementsByTagName("username")[0].InnerText;
                string password = xml.GetElementsByTagName("password")[0].InnerText;
                string serviceid = xml.GetElementsByTagName("serviceid")[0].InnerText;
                string msisdn = xml.GetElementsByTagName("msisdn")[0].InnerText;
                string chargetime = xml.GetElementsByTagName("chargetime")[0].InnerText;
                string paramss = xml.GetElementsByTagName("params")[0].InnerText;
                string mode = xml.GetElementsByTagName("mode")[0].InnerText;
                string amount = xml.GetElementsByTagName("amount")[0].InnerText;
                string command = xml.GetElementsByTagName("command")[0].InnerText;
                string transaction = xml.GetElementsByTagName("transaction")[0].InnerText;
                
                DataSet ds = webserviceDataAccess.ProcessSub(username,
                                                    password,
                                                    serviceid,
                                                    msisdn,
                                                    chargetime,
                                                    paramss,
                                                    mode,
                                                    amount,
                                                    command, prefix, transaction);


                if (ds != null & ds.Tables[0].Rows.Count > 0)
                {
                    ketqua = ds.Tables[0].Rows[0][0].ToString();

                }
                logger.Debug("Process Request from MPS suceess");
               
            }
            catch (Exception ex)
            {
                logger.Debug("Process sub err: " + ex.ToString());
            }





            result = result + @"<?xml version=""1.0""?> <S:Envelope xmlns:S=""http://schemas.xmlsoap.org/soap/envelope/"" >";
            result = result + @"<S:Body>";
            result = result + @"<subRequestResponse xmlns=""http://contentws/xsd"">";
            result = result + @"<return>";
            result = result + ketqua;
            result = result + @"</return>";
            result = result + @"</subRequestResponse>";
            result = result + @"</S:Body>";
            result = result + @"</S:Envelope>";
            logger.Debug(result);
            //return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent(result, System.Text.Encoding.UTF8, "text/xml") }; ;
            Response.Headers.Add("Content-Type", "text/xml");
            //return Ok(result);
            return Content(result);

        }



        [HttpPost]

        //public string subRequest(HttpRequestMessage request)
        // public HttpResponseMessage subRequest(HttpRequestMessage request)
        //[Produces("text/xml")]
        public IActionResult subCheckBuy1Time([FromBody] XElement xml1)
        {


            string request = xml1.ToString();
            logger.Info("Request subCheckBuy1Time to MPS:" + request);
            string result = "";
            //string username1 = xml1.GetElementsByTagName("username")[0].InnerText;
            string ketqua = "0|success";
            ////log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
            ////log4net.Config.XmlConfigurator.Configure();

            try
            {

                //string ten = xml1.Element("username").Value;

                //string prefix = ConfigurationSettings.AppSettings["PREFIX"];
                string prefix = Common.GetValuesAppSetting("webConfig", "PREFIX");
                XmlDocument xml = new XmlDocument();


                //logger.Debug(request.Content.ReadAsStreamAsync().Result);
                //xml.Load(request);
                xml.LoadXml(request);


                string username = xml.GetElementsByTagName("username")[0].InnerText;
                string password = xml.GetElementsByTagName("password")[0].InnerText;
                string serviceid = xml.GetElementsByTagName("serviceid")[0].InnerText;
                string msisdn = xml.GetElementsByTagName("msisdn")[0].InnerText;
                string chargetime = xml.GetElementsByTagName("chargetime")[0].InnerText;
                string paramss = xml.GetElementsByTagName("params")[0].InnerText;
                string mode = xml.GetElementsByTagName("mode")[0].InnerText;
                string amount = xml.GetElementsByTagName("amount")[0].InnerText;
                string command = xml.GetElementsByTagName("command")[0].InnerText;
                string transaction = xml.GetElementsByTagName("transaction")[0].InnerText;

                DataSet ds = webserviceDataAccess.ProcessCheckBuy1Time(username,
                                                    password,
                                                    serviceid,
                                                    msisdn,
                                                    chargetime,
                                                    paramss,
                                                    mode,
                                                    amount,
                                                    command, prefix, transaction);


                if (ds != null & ds.Tables[0].Rows.Count > 0)
                {
                    ketqua = ds.Tables[0].Rows[0][0].ToString();

                }
                logger.Debug("Process Request from MPS suceess");

            }
            catch (Exception ex)
            {
                logger.Debug("Process sub err: " + ex.ToString());
            }





            result = result + @"<?xml version=""1.0""?> <S:Envelope xmlns:S=""http://schemas.xmlsoap.org/soap/envelope/"" >";
            result = result + @"<S:Body>";
            result = result + @"<subRequestResponse xmlns=""http://contentws/xsd"">";
            result = result + @"<return>";
            result = result + ketqua;
            result = result + @"</return>";
            result = result + @"</subRequestResponse>";
            result = result + @"</S:Body>";
            result = result + @"</S:Envelope>";
            logger.Debug(result);
            //return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent(result, System.Text.Encoding.UTF8, "text/xml") }; ;
            Response.Headers.Add("Content-Type", "text/xml");
            //return Ok(result);
            return Content(result);

        }







        /*
            http://10.226.40.11:8383/api/webservice/subUssdRequest/data
         * Nhan cac dang ky va huy qua USSD
         * 
         * 
         * */
        [HttpPost]
        //public string subRequest(HttpRequestMessage request)
        //public HttpResponseMessage subUssdRequest(HttpRequestMessage request)
        public IActionResult subUssdRequest([FromBody] XElement xml1)
        {
            string request = xml1.ToString();
            logger.Info("Request subUssdRequest from MPS:" + request);
            string result = "";
            string ketqua = "0";
            //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
            //log4net.Config.XmlConfigurator.Configure();

            try
            {
                //string prefix = ConfigurationSettings.AppSettings["PREFIX"];
                string prefix = Common.GetValuesAppSetting("webConfig", "PREFIX");
                XmlDocument xml = new XmlDocument();
                
                xml.LoadXml(request);


                string username = xml.GetElementsByTagName("username")[0].InnerText;
                string password = xml.GetElementsByTagName("password")[0].InnerText;
                string servicename = xml.GetElementsByTagName("servicename")[0].InnerText;
                string msisdn = xml.GetElementsByTagName("msisdn")[0].InnerText;
                string chargetime = xml.GetElementsByTagName("chargetime")[0].InnerText;
                string paramss = xml.GetElementsByTagName("params")[0].InnerText;
                string mode = xml.GetElementsByTagName("mode")[0].InnerText;
                string amount = xml.GetElementsByTagName("amount")[0].InnerText;
                string transactionId = xml.GetElementsByTagName("transactionId")[0].InnerText;
                string other_and_more = xml.GetElementsByTagName("other_and_more")[0].InnerText;
                DataSet ds = webserviceDataAccess.ProcessSubUssd(username,
                                                    password,
                                                    servicename,
                                                    msisdn,
                                                    chargetime,
                                                    paramss,
                                                    mode,
                                                    amount,
                                                    transactionId,
                                                    other_and_more,
                                                    prefix);
                if (ds != null & ds.Tables[0].Rows.Count > 0)
                {
                    ketqua = "0";

                }
                logger.Debug("Process Request from MPS suceess");

            }
            catch (Exception ex)
            {
                logger.Debug("Process sub err: " + ex.ToString());
            }





            result = result + @"<?xml version=""1.0""?> <S:Envelope xmlns:S=""http://schemas.xmlsoap.org/soap/envelope/"" >";
            result = result + @"<S:Body>";
            result = result + @"<subRequestResponse xmlns=""http://contentws/xsd"">";
            result = result + @"<return>";
            result = result + ketqua;
            result = result + @"</return>";
            result = result + @"</subRequestResponse>";
            result = result + @"</S:Body>";
            result = result + @"</S:Envelope>";
            logger.Debug(result);
            //return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent(result, System.Text.Encoding.UTF8, "text/xml") }; ;
            //return result;
            Response.Headers.Add("Content-Type", "text/xml");
            //return Ok(result);
            return Content(result);

        }











        /*
            http://10.226.40.11:8383/api/webservice/resultRequest/data
         * Nhan cac ket qua charge tu MPS
         * 
         * 
         * */

        [HttpPost]
        //public string resultRequest(HttpRequestMessage request)
        //public HttpResponseMessage resultRequest(HttpRequestMessage request)
        public IActionResult resultRequest([FromBody] XElement xml1)
        {
            string request = xml1.ToString();
            logger.Info("Request resultRequest from MPS:" + request);
            string result = "";
            string ketqua = "0|success";
            //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
            //log4net.Config.XmlConfigurator.Configure();

            try
            {


                //string prefix = ConfigurationSettings.AppSettings["PREFIX"];
                string prefix = Common.GetValuesAppSetting("webConfig", "PREFIX");
                if (request == null)  logger.Debug("Request charge from MPS is null");

             
                XmlDocument xml = new XmlDocument();
                xml.LoadXml(request);


                string username = xml.GetElementsByTagName("username")[0].InnerText;
                string password = xml.GetElementsByTagName("password")[0].InnerText;
                string serviceid = xml.GetElementsByTagName("serviceid")[0].InnerText;
                string msisdn = xml.GetElementsByTagName("msisdn")[0].InnerText;
                string chargetime = xml.GetElementsByTagName("chargetime")[0].InnerText;
                string paramss = xml.GetElementsByTagName("params")[0].InnerText;
                string mode = xml.GetElementsByTagName("mode")[0].InnerText;
                string amount = xml.GetElementsByTagName("amount")[0].InnerText;
                string cmd = xml.GetElementsByTagName("command")[0].InnerText;
                string transaction = xml.GetElementsByTagName("transaction")[0].InnerText;


                chargeObj _obj=new chargeObj();
                _obj.username = username;
                _obj.password = password;
                _obj.serviceid = serviceid;
                _obj.msisdn = msisdn;
                _obj.chargetime = chargetime;
                _obj.paramss = paramss;
                _obj.mode = mode;
                _obj.amount = amount;
                _obj.cmd = cmd;
                _obj.transaction = transaction;
                _obj.prefix = prefix;

                Variable.chargerObj.Enqueue(_obj);


                /*
                DataSet ds = webserviceDataAccess.ProcessCharge(username,
                                                    password,
                                                    serviceid,
                                                    msisdn,
                                                    chargetime,
                                                    paramss,
                                                    mode,
                                                    amount,
                                                    prefix,cmd,transaction);

                */
                //if (ds != null & ds.Tables[0].Rows.Count > 0)
                //{
                //    ketqua = ds.Tables[0].Rows[0][0].ToString();

                //}
                logger.Debug("Input queu success");



            }
            catch (Exception ex)
            {
                logger.Debug("Process charge err: " + ex.ToString());
            }


            ketqua = "0";


            result = result + @"<?xml version=""1.0""?> <S:Envelope xmlns:S=""http://schemas.xmlsoap.org/soap/envelope/"" >";
            result = result + @"<S:Body>";
            result = result + @"<subRequestResponse xmlns=""http://contentws/xsd"">";
            result = result + @"<return>";
            result = result + ketqua;
            result = result + @"</return>";
            result = result + @"</subRequestResponse>";
            result = result + @"</S:Body>";
            result = result + @"</S:Envelope>";
            //return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent(result, System.Text.Encoding.UTF8, "text/xml") }; ;
            logger.Debug(result);
            Response.Headers.Add("Content-Type", "text/xml");
            //return Ok(result);
            return Content(result);

        }



        /*
            http://10.226.40.11:8383/api/webservice/proKeyWord/data
         * Xu ly cu phap tu MPS
         * 
         * 
         * */

        [HttpPost]
        //public string resultRequest(HttpRequestMessage request)
        //public HttpResponseMessage proKeyWord(HttpRequestMessage request)
        public IActionResult proKeyWord([FromBody] XElement xml1)
        {
            string request = xml1.ToString();
            logger.Info("Request proKeyWord from MPS:" + request);
            string result = "";
            string ketqua = "0|success";
            //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
            //log4net.Config.XmlConfigurator.Configure();

            try
            {


                //string prefix = ConfigurationSettings.AppSettings["PREFIX"];
                string prefix = Common.GetValuesAppSetting("webConfig", "PREFIX");
                if (request == null) logger.Debug("Request proKeyWord from MPS is null");


                XmlDocument xml = new XmlDocument();
                xml.LoadXml(request);


                string username = xml.GetElementsByTagName("username")[0].InnerText;
                string password = xml.GetElementsByTagName("password")[0].InnerText;
                string serviceid = xml.GetElementsByTagName("serviceid")[0].InnerText;
                string msisdn = xml.GetElementsByTagName("msisdn")[0].InnerText;
                string chargetime = xml.GetElementsByTagName("chargetime")[0].InnerText;
                string paramss = xml.GetElementsByTagName("params")[0].InnerText;
                string mode = xml.GetElementsByTagName("mode")[0].InnerText;
                string amount = xml.GetElementsByTagName("amount")[0].InnerText;
                string cmd = xml.GetElementsByTagName("command")[0].InnerText;
                string transaction = xml.GetElementsByTagName("transaction")[0].InnerText;


                DataSet ds = webserviceDataAccess.ProcessKeyWord(username,
                                                    password,
                                                    serviceid,
                                                    msisdn,
                                                    chargetime,
                                                    paramss,
                                                    mode,
                                                    amount,
                                                    prefix, cmd, transaction);
                if (ds != null & ds.Tables[0].Rows.Count > 0)
                {
                    ketqua = ds.Tables[0].Rows[0][0].ToString();

                }
                logger.Debug("Process Charge from MPS suceess");

            }
            catch (Exception ex)
            {
                logger.Debug("Process charge err: " + ex.ToString());
            }





            result = result + @"<?xml version=""1.0""?> <S:Envelope xmlns:S=""http://schemas.xmlsoap.org/soap/envelope/"" >";
            result = result + @"<S:Body>";
            result = result + @"<subRequestResponse xmlns=""http://contentws/xsd"">";
            result = result + @"<return>";
            result = result + ketqua;
            result = result + @"</return>";
            result = result + @"</subRequestResponse>";
            result = result + @"</S:Body>";
            result = result + @"</S:Envelope>";
            //return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent(result, System.Text.Encoding.UTF8, "text/xml") }; ;
            logger.Debug(result);
            //return result;
            Response.Headers.Add("Content-Type", "text/xml");
            //return Ok(result);
            return Content(result);

        }




        [HttpPost]
        //public string resultRequest(HttpRequestMessage request)
        //public HttpResponseMessage contentRequest(HttpRequestMessage request)
        public IActionResult contentRequest([FromBody] XElement xml1)
        {
            string request = xml1.ToString();
            logger.Info("Request contentRequest from MPS:" + request);

            string result = "";
            string ketqua = "";
            //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
            //log4net.Config.XmlConfigurator.Configure();

            try
            {
                //string prefix = ConfigurationSettings.AppSettings["PREFIX"];
                string prefix = Common.GetValuesAppSetting("webConfig", "PREFIX");
                XmlDocument xml = new XmlDocument();
                xml.LoadXml(request);


                string username = xml.GetElementsByTagName("username")[0].InnerText;
                string password = xml.GetElementsByTagName("password")[0].InnerText;
                string serviceid = xml.GetElementsByTagName("serviceid")[0].InnerText;
                string msisdn = xml.GetElementsByTagName("msisdn")[0].InnerText;
                
                string paramss = xml.GetElementsByTagName("params")[0].InnerText;
                string mode = xml.GetElementsByTagName("mode")[0].InnerText;
                string amount = xml.GetElementsByTagName("amount")[0].InnerText;
                string transid = xml.GetElementsByTagName("transid")[0].InnerText;


                DataSet ds = webserviceDataAccess.ProcessGetContent(username,
                                                    password,
                                                    serviceid,
                                                    msisdn,
                                                    transid,
                                                    paramss,
                                                    mode,
                                                    amount,
                                                    prefix);
                if (ds != null & ds.Tables[0].Rows.Count > 0)
                {
                    string status = ds.Tables[0].Rows[0]["status"].ToString();
                    string msg = ds.Tables[0].Rows[0]["msg"].ToString();
                    if (string.IsNullOrEmpty(msg))
                        ketqua = "0";
                    else
                        ketqua = "0|" + msg;

                }
                logger.Debug("Process Charge from MPS suceess");

            }
            catch (Exception ex)
            {
                logger.Debug("Process charge err: " + ex.ToString());
            }





            result = result + @"<?xml version=""1.0""?> <S:Envelope xmlns:S=""http://schemas.xmlsoap.org/soap/envelope/"" >";
            result = result + @"<S:Body>";
            result = result + @"<contentRequestResponse  xmlns=""http://contentws/xsd"">";
            result = result + @"<return>";
            result = result + ketqua;
            result = result + @"</return>";
            result = result + @"</contentRequestResponse>";
            result = result + @"</S:Body>";
            result = result + @"</S:Envelope>";
            logger.Debug(result);
            //return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent(result, System.Text.Encoding.UTF8, "text/xml") }; ;
            Response.Headers.Add("Content-Type", "text/xml");
            //return Ok(result);
            return Content(result);

        }








        [HttpPost]
        //public HttpResponseMessage changeZodiacNew(HttpRequestMessage request)
        public IActionResult changeZodiacNew([FromBody] XElement xml1)
        {
            string request = xml1.ToString();
            logger.Info("Request changeZodiacNew from MPS:" + request);


            string result = "";
            string ketqua = "0|success";
            //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
            //log4net.Config.XmlConfigurator.Configure();

            try
            {
                //string prefix = ConfigurationSettings.AppSettings["PREFIX"];
                string prefix = Common.GetValuesAppSetting("webConfig", "PREFIX");
                XmlDocument xml = new XmlDocument();
                xml.LoadXml(request);


                string username = xml.GetElementsByTagName("username")[0].InnerText;
                string password = xml.GetElementsByTagName("password")[0].InnerText;
                string serviceid = xml.GetElementsByTagName("subServiceId")[0].InnerText;
                string msisdn = xml.GetElementsByTagName("msisdn")[0].InnerText;
                string paramss = xml.GetElementsByTagName("params")[0].InnerText;


                DataSet ds = webserviceDataAccess.changeZodiacNew(username,
                                                    password,
                                                    serviceid,
                                                    msisdn,
                                                    paramss
                                                   );
                if (ds != null & ds.Tables[0].Rows.Count > 0)
                {
                    ketqua = ds.Tables[0].Rows[0][0].ToString();

                }
                logger.Debug("Process Request change changeZodiacNew suceess");

            }
            catch (Exception ex)
            {
                logger.Debug("Process change Zodiac err: " + ex.ToString());
            }





            result = result + @"<?xml version=""1.0""?> <S:Envelope xmlns:S=""http://schemas.xmlsoap.org/soap/envelope/"" >";
            result = result + @"<S:Body>";
            result = result + @"<subRequestResponse xmlns=""http://contentws/xsd"">";
            result = result + @"<return>";
            result = result + ketqua;
            result = result + @"</return>";
            result = result + @"</subRequestResponse>";
            result = result + @"</S:Body>";
            result = result + @"</S:Envelope>";
            logger.Debug(result);
            //return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent(result, System.Text.Encoding.UTF8, "text/xml") }; ;
            //return result;
            Response.Headers.Add("Content-Type", "text/xml");
            //return Ok(result);
            return Content(result);

        }





        [HttpPost]
        //public HttpResponseMessage changeZodiac(HttpRequestMessage request)
        public IActionResult changeZodiac([FromBody] XElement xml1)
        {
            string request = xml1.ToString();
            logger.Info("Request changeZodiac from MPS:" + request);

            string result = "";
            string ketqua = "0|success";
            //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
            //log4net.Config.XmlConfigurator.Configure();

            try
            {
                //string prefix = ConfigurationSettings.AppSettings["PREFIX"];
                string prefix = Common.GetValuesAppSetting("webConfig", "PREFIX");
                XmlDocument xml = new XmlDocument();
                xml.LoadXml(request);


                string username = xml.GetElementsByTagName("username")[0].InnerText;
                string password = xml.GetElementsByTagName("password")[0].InnerText;
                string serviceid = xml.GetElementsByTagName("subServiceId")[0].InnerText;
                string msisdn = xml.GetElementsByTagName("msisdn")[0].InnerText;
                string paramss = xml.GetElementsByTagName("params")[0].InnerText;


                DataSet ds = webserviceDataAccess.changeZodiac(username,
                                                    password,
                                                    serviceid,
                                                    msisdn,
                                                    paramss
                                                   );
                if (ds != null & ds.Tables[0].Rows.Count > 0)
                {
                    ketqua = ds.Tables[0].Rows[0][0].ToString();

                }
                logger.Debug("Process Request change Zodiac suceess");

            }
            catch (Exception ex)
            {
                logger.Debug("Process change Zodiac err: " + ex.ToString());
            }





            result = result + @"<?xml version=""1.0""?> <S:Envelope xmlns:S=""http://schemas.xmlsoap.org/soap/envelope/"" >";
            result = result + @"<S:Body>";
            result = result + @"<subRequestResponse xmlns=""http://contentws/xsd"">";
            result = result + @"<return>";
            result = result + ketqua;
            result = result + @"</return>";
            result = result + @"</subRequestResponse>";
            result = result + @"</S:Body>";
            result = result + @"</S:Envelope>";
            logger.Debug(result);
            //return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent(result, System.Text.Encoding.UTF8, "text/xml") }; ;
            //return result;
            Response.Headers.Add("Content-Type", "text/xml");
            //return Ok(result);
            return Content(result);
        }



    }
}