MARKUS

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.IO;

using System.Net;

using System.Xml;

using System.Xml.Linq;

using System.Net.Mail;

using System.Data.SqlClient;

using log4net;

using Markus.EntityModel;

namespace UploadFinal

{

    public class UploadFinal

    {

        public static ILog Logger = null;

        private static string CIConnectionString;

        private static string MarkusConnectionString;

        public static KeyValuePair<bool, string> UploadFinalPDF(string PdfFilePath, string OriginFileName, FINAL_PDF FinalPDF, string UploadServiceUrl)

        {

            Logger = LogManager.GetLogger(typeof(UploadFinal));

            string _vendorItemId = null;

            string _objid = null;

            string _SharepointItemID = null;

            string _slipNO = null;

            bool _ResultFlag = false;

            string _ResultMsg = "";

            try

            {

                string docurl = string.Empty;

                //XML escape & 치환

                OriginFileName = OriginFileName.Replace("&","&");

                using (Markus.EntityModel.MarkusModel _entity = new Markus.EntityModel.MarkusModel(CIConnectionString))

                {

                    var _docInfoList = _entity.DOCINFO.Where(doc => doc.ID == FinalPDF.DOCINFO_ID);

                    if (_docInfoList.Count() > 0)

                        _SharepointItemID = _docInfoList.First().DOCUMENT_ID;

                    var _vendoritems = _entity.DOCUMENT_ITEM.Where(item => item.DOCUMENT_ID == _SharepointItemID && item.PROJECT_NO == FinalPDF.PROJECT_NO);

                    if (_vendoritems.Count() > 0)

                    {

                        _objid = _vendoritems.First().ID;

                        _slipNO = _vendoritems.First().GROUP_NO;

                        docurl = _vendoritems.First().ORIGINAL_FILE;

                    }

                }

                //EnsemblePlusWebService.DLMWebServiceClient client = new EnsemblePlusWebService.DLMWebServiceClient();

                //var result = client.fnFinalPDFCheckInService(FinalPDF.PROJECT_NO, _objid, _slipNO, PdfFilePath);

                WebClient webClient = new WebClient();

                string data = string.Empty;

                Logger.Info($"doc Uri :{docurl}");

                if (docurl.ToUpper().Contains("VPCS_DOCLIB"))

                {

                    string connectionString = "data source=ESB-DB;Initial Catalog=markus;uid=ProjectPortalDBConn;password=ProjectPortalDBConn";

                    SqlConnection sqlConn = new SqlConnection(connectionString);

                    SqlCommand sqlComm = new SqlCommand();

                    sqlComm.Connection = sqlConn;

                    sqlComm.CommandText = string.Format("SELECT [DBConnectString]  FROM [PortalEV].[dbo].[Setting]  where [ProjectNumber] = '{0}'", FinalPDF.PROJECT_NO);

                    string ciconnectionStr = string.Empty;

                    sqlConn.Open();

                    using (SqlDataReader SqlRs = sqlComm.ExecuteReader())

                    {

                        while (SqlRs.Read())

                        {

                            ciconnectionStr = SqlRs[0].ToString();

                        }

                    }

                    sqlConn.Close();

                    sqlConn = new SqlConnection(ciconnectionStr);

                    sqlComm.Connection = sqlConn;

                    sqlComm.CommandText = string.Format("SELECT [vendor_item_id]  FROM [vendor_item]  where [sharepoint_itemid] = '{0}'", _objid);

                    sqlConn.Open();

                    using (SqlDataReader SqlRs = sqlComm.ExecuteReader())

                    {

                        while (SqlRs.Read())

                        {

                            _objid = SqlRs[0].ToString();

                        }

                    }

                    sqlConn.Close();

                    UploadServiceUrl = "http://esb-vpcs-new.daelimplant.com/ProjectPortal/UserControls/DaelimCI2/FinalPDFUpload/UploadVpcsFile.asmx";

                    string finalpdfroot = CommonLib.Common.GetConfigString("FinalPDFRootUrl", "URL", "");

                    if (!string.IsNullOrEmpty(finalpdfroot))

                    {

                        string filename = Path.GetFileName(PdfFilePath);

                        PdfFilePath = !string.IsNullOrEmpty(finalpdfroot) ? finalpdfroot + filename : filename;

                    }

                    Logger.Info($"UploadServiceUrl :{UploadServiceUrl}");

                    data = "<soap12:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap12=\"http://www.w3.org/2003/05/soap-envelope\" ><soap12:Body><UploadFinalPDF xmlns=\"http://FinalPDFUpload\">"

                                     + "<ProjectNo>" + FinalPDF.PROJECT_NO + "</ProjectNo>"

                                     + "<VendorItemID>" + _objid + "</VendorItemID>"

                                     + "<SlipNumber>" + _slipNO + "</SlipNumber>"

                                     + "<filePath>" + PdfFilePath + "</filePath>"

                                     + "<OriginFileName>" + OriginFileName + "</OriginFileName></UploadFinalPDF></soap12:Body></soap12:Envelope>";

                    Logger.Info($"PROJECT_NO  :{FinalPDF.PROJECT_NO}");

                    Logger.Info($"FinalPDF.  :{_objid}");

                    Logger.Info($"SlipNumber  :{_slipNO}");

                    Logger.Info($"filePath  :{PdfFilePath}");

                    Logger.Info($"OriginFileName  :{OriginFileName}");

                    //WriteLog(data);

                    webClient.Headers.Add(HttpRequestHeader.ContentType, "application/soap+xml; charset=utf-8");

                    webClient.Headers.Add("SOAPAction", "http://FinalPDFUpload/UploadFinalPDF");

                    webClient.Encoding = System.Text.Encoding.UTF8;

                    string _result = webClient.UploadString(new Uri(UploadServiceUrl), data);

                    XmlTextReader reader = new XmlTextReader(new System.IO.StringReader(_result));

                    while (reader.Read())

                    {

                        switch (reader.NodeType)

                        {

                            case XmlNodeType.Element:

                                if (reader.Name == "Seccess")

                                {

                                    reader.Read();

                                    if (!string.IsNullOrWhiteSpace(reader.Value))

                                        _ResultFlag = Convert.ToBoolean(reader.Value);

                                }

                                if (reader.Name == "Message")

                                {

                                    reader.Read();

                                    if (!string.IsNullOrWhiteSpace(reader.Value))

                                        _ResultMsg = reader.Value;

                                }

                                if (reader.Name == "FinalPDFUrl")

                                {

                                    reader.Read();

                                    if (!string.IsNullOrWhiteSpace(reader.Value))

                                        _ResultMsg = reader.Value;

                                }

                                break;                                

                        }

                    }

                    return new KeyValuePair<bool, string>(_ResultFlag, _ResultMsg);

                }

                else

                {

                    Logger.Info($"UploadServiceUrl :{UploadServiceUrl}");

                    // 앙상블+는 파일명만 전달함

                    string finalpdfroot = CommonLib.Common.GetConfigString("FinalPDFRootUrl", "URL", "");

                    PdfFilePath = PdfFilePath.Split('/').Last();

                    if (PdfFilePath.StartsWith(finalpdfroot))

                    {

                        PdfFilePath = PdfFilePath.Split('\\').Last();

                    }

                    data = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:ens=\"http://EnsemblePlus.Webservice\"> <soapenv:Header/> <soapenv:Body> <ens:fnFinalPDFCheckInService>"

                    + "<ens:ProjectNo>" + FinalPDF.PROJECT_NO + "</ens:ProjectNo>"

                    + "<ens:ObjectId>" + _objid + "</ens:ObjectId>"

                    + "<ens:SlipNumber>" + _slipNO + "</ens:SlipNumber>"

                    + "<ens:filePath>" + PdfFilePath + "</ens:filePath>"

                    + "<ens:OriginalFileName>" + OriginFileName + "</ens:OriginalFileName>"

                    + "</ens:fnFinalPDFCheckInService> </soapenv:Body></soapenv:Envelope>";

                    Logger.Info($"PROJECT_NO  :{FinalPDF.PROJECT_NO}");

                    Logger.Info($"FinalPDF.  :{_objid}");

                    Logger.Info($"SlipNumber  :{_slipNO}");

                    Logger.Info($"filePath  :{PdfFilePath}");

                    Logger.Info($"OriginFileName  :{OriginFileName}");

                    webClient.Headers.Add(HttpRequestHeader.ContentType, "text/xml");

                    webClient.Headers.Add("SOAPAction", "http://EnsemblePlus.Webservice");

                    webClient.Encoding = System.Text.Encoding.UTF8;

                    var result = webClient.UploadString(new Uri(UploadServiceUrl), data);

                    XmlDocument xmlDoc = new XmlDocument();

                    xmlDoc.LoadXml(result);

                    XmlNodeList list = xmlDoc.GetElementsByTagName("fnFinalPDFCheckInServiceReturn");

                    if (list.Count > 0)

                    {

                        if (list[0].InnerText == "Success")

                        {

                            return new KeyValuePair<bool, string>(true, "Success");

                        }

                        else

                        {

                            return new KeyValuePair<bool, string>(false, "Fail - " + data);

                        }

                    }

                    else

                    {

                        return new KeyValuePair<bool, string>(false, "Not Completed");

                    }

                }

            }

            catch (Exception ex)

            {

                return new KeyValuePair<bool, string>(false, ex.Message);

            }

            //return new KeyValuePair<bool, string>(_ResultFlag,_ResultMsg);

        }

        static void webClient_UploadStringCompleted(object sender, UploadStringCompletedEventArgs e)

        {

            Console.WriteLine("UploadStringCompleted: {0}", e.Result);

        }

        public static void SendOnMessage(string subject, string content)

        {

            //MailMessage mail = new MailMessage();

            //mail.From = new MailAddress("h2011357@daelim.co.kr", "시스템관리자", System.Text.Encoding.UTF8);

            //mail.To.Add("h2011357@daelim.co.kr");

            //mail.Subject = subject;

            //mail.Body = content;

            //mail.BodyEncoding = System.Text.Encoding.UTF8;//한글이 안깨지기 위해서 사용

            //mail.SubjectEncoding = System.Text.Encoding.UTF8;//한글이 안깨지기 위해서 사용

            //SmtpClient SmtpServer = new SmtpClient("any.daelim.co.kr");

            //SmtpServer.Send(mail); // 메일 발송

            //mail.Dispose();

        }

        public static void WriteLog(string strLog)

        {

            StreamWriter log;

            FileStream fileStream = null;

            DirectoryInfo logDirInfo = null;

            FileInfo logFileInfo;

            string logFilePath = "C:\\Logs\\";

            logFilePath = logFilePath + "Log-" + System.DateTime.Today.ToString("MM-dd-yyyy") + "." + "txt";

            logFileInfo = new FileInfo(logFilePath);

            logDirInfo = new DirectoryInfo(logFileInfo.DirectoryName);

            if (!logDirInfo.Exists) logDirInfo.Create();

            if (!logFileInfo.Exists)

            {

                fileStream = logFileInfo.Create();

            }

            else

            {

                fileStream = new FileStream(logFilePath, FileMode.Append);

            }

            log = new StreamWriter(fileStream);

            log.WriteLine(strLog);

            log.Close();

        }

    }

}