bodyshop-uploader/BodyshopUploader/Utils/QuickBooksInterop.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Xml;
using System.Xml.Linq;
using Interop.QBFC13;
using Interop.QBXMLRP2;

namespace BodyshopPartner.Utils
{
    public static class QuickBooksInterop
    {
        private static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
        private static string ticket;
        private static RequestProcessor2 rp;
        private static string maxVersion;
        private static string companyFile = "";
        private static QBFileMode mode = QBFileMode.qbFileOpenDoNotCare;
        private static string appID = "ImEXBSP";
        private static string appName = "BodyshopPartner";

        public static void ConnectToQuickBooks()
        {
            try
            {
                rp = new RequestProcessor2Class();
                rp.OpenConnection(appID, appName);
                ticket = rp.BeginSession(companyFile, mode);
                string[] versions = rp.get_QBXMLVersionsForSession(ticket);
                maxVersion = versions[versions.Length - 1];
            }
            catch (Exception ex)
            {
                logger.Error(ex);
            }

        }

        public static void DisconnectFromQuickBooks()
        {
            if (ticket != null)
            {
                try
                {
                    rp.EndSession(ticket);
                    ticket = null;
                    rp.CloseConnection();
                }
                catch (Exception ex)
                {
                    logger.Error(ex);
                }
            }
        }
        public static string ProcessQBXmlRequest(string request)
        {
            try
            {
                ConnectToQuickBooks();
                var ret = rp.ProcessRequest(ticket, request);
                DisconnectFromQuickBooks();
                return ret;
            }
            catch (Exception e)
            {
                logger.Error(e.Message);
                DisconnectFromQuickBooks();
                return null;
            }
        }

        public static string[] parseInvoiceAddRs(string xml)
        {
            string[] retVal = new string[3];
            try
            {
                XmlNodeList RsNodeList = null;
                XmlDocument Doc = new XmlDocument();
                Doc.LoadXml(xml);
                RsNodeList = Doc.GetElementsByTagName("InvoiceAddRs");
                XmlAttributeCollection rsAttributes = RsNodeList.Item(0).Attributes;
                XmlNode statusCode = rsAttributes.GetNamedItem("statusCode");
                retVal[0] = Convert.ToString(statusCode.Value);
                XmlNode statusSeverity = rsAttributes.GetNamedItem("statusSeverity");
                retVal[1] = Convert.ToString(statusSeverity.Value);
                XmlNode statusMessage = rsAttributes.GetNamedItem("statusMessage");
                retVal[2] = Convert.ToString(statusMessage.Value);
            }
            catch (Exception e)
            {
                logger.Error("Error encountered when parsing Invoice info returned from QuickBooks: " + e.Message);
                retVal = null;
            }
            return retVal;
        }

        public static string CreateCustomerIfNotExist(XDocument requestXML)
        {
            string ListID = ParseCustomerId(requestXML);
            if (string.IsNullOrEmpty(ListID))
            //Could be null or exist, we need to check. 
            {
                QBSessionManager sessionManager = new QBSessionManager();
                IMsgSetRequest requestMsgSet = sessionManager.CreateMsgSetRequest("CA", 13, 0);
                requestMsgSet.Attributes.OnError = ENRqOnError.roeContinue;

                ICustomerAdd CustomerAddRq = requestMsgSet.AppendCustomerAddRq();
                //Get the address & Other information from the request XML DOC. 
                CustomerAddRq.Name.SetValue(requestXML.Descendants("CustomerRef").First()?.Element("FullName")?.Value);

                // ICustomerQuery CustomerQueryRq = requestMsgSet.AppendCustomerQueryRq();
                //CustomerQueryRq.ORCustomerListQuery.ListIDList.Add(ListID);

                string ret = ProcessQBXmlRequest(requestMsgSet.ToXMLString());
                return ret;
            }
            else
            {
                return ListID;
            }

        }
        public static string[] parseCustomerQueryRs(string xml)
        {
            string[] retVal;
            try
            {
                XDocument responseXml = XDocument.Parse(xml);
                XElement CustomerQueryRs = responseXml.Descendants("CustomerQueryRs").First();
                XAttribute statusCode = CustomerQueryRs.Attribute(XName.Get("statusCode"));

                if (statusCode.Value?.ToString() == "0")
                {
                    //All good, return the ID.
                }
                else
                {
                    //Need to create a new customer and return that ID.
                }

                //XmlNodeList RsNodeList = null;
                //XmlDocument Doc = new XmlDocument();
                //Doc.LoadXml(xml);
                //RsNodeList = Doc.GetElementsByTagName("CustomerQueryRs");
                //XmlAttributeCollection rsAttributes = RsNodeList.Item(0).Attributes;
                //XmlNode statusCode = rsAttributes.GetNamedItem("statusCode");
                //if (Convert.ToString(statusCode.Value) == "0")
                //{
                //    //Found an ID for this person. Looks all good.
                //    retVal = new string[1];
                //   //xml.Desce
                //}
                //else
                //{
                //    retVal = new string[3];
                //    retVal[0] = Convert.ToString(statusCode.Value);
                //    XmlNode statusSeverity = rsAttributes.GetNamedItem("statusSeverity");
                //    retVal[1] = Convert.ToString(statusSeverity.Value);
                //    XmlNode statusMessage = rsAttributes.GetNamedItem("statusMessage");
                //    retVal[2] = Convert.ToString(statusMessage.Value);
                //}
                //;

            }
            catch (Exception e)
            {
                logger.Error("Error encountered when parsing Invoice info returned from QuickBooks: " + e.Message);
                retVal = null;
            }
            return retVal;
        }

        private static string ParseCustomerId(XDocument xml)
        {
            XElement CustomerRef = xml.Descendants("CustomerRef").First();
            string ListId = CustomerRef.Element("ListID")?.Value;
            return ListId;
        }

    }
}