using log4net;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Quartz;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.IO;
using System.Linq;
using System.Text;
using HtmlAgilityPack;
using HcUtility.Core;
using HcUtility.Comm;
using System.Data.Entity;
using System.Text.RegularExpressions;

namespace Job_JieFeng_FTP
{

    public class Job_JFFTP : IJob
    {
        private ILog log = LogManager.GetLogger(typeof(Job_JFFTP));

        private string connStr { get; set; }
        private string FTPADDRESS { get; set; }
        private string FTPPATH { get; set; }
        private string FTPUSERNAME { get; set; }
        private string FTPPWD { get; set; }
        private string carrierStr { get; set; }
        private List<CARRIER> carrierList { get; set; }
        private 运输条款表 运输条款 { get; set; }

        //错误文件记录
        //List<string> ERRORFILEList = new List<string>();
        /// <summary>
        /// 当前正在处理的xml文件在ftp端的文件名
        /// </summary>
        private string currXMLFile { get; set; }

        private string ErrorFilePackName { get { return "ERROR"; } }

        private string ErrorFileHead { get { return "ERROR_"; } }


        public void Execute(IJobExecutionContext context)
        {
            log.Debug($"Execute开始");
            
            connStr = context.JobDetail.JobDataMap.GetString("ConnectString");
            FTPADDRESS = context.JobDetail.JobDataMap.GetString("FTPADDRESS");
            FTPPATH = context.JobDetail.JobDataMap.GetString("FTPPATH");
            FTPUSERNAME = context.JobDetail.JobDataMap.GetString("FTPUSERNAME");
            FTPPWD = context.JobDetail.JobDataMap.GetString("FTPPWD");
            carrierStr = context.JobDetail.JobDataMap.GetString("CARRIER");



            //1:获得FTP的文件列表
            //var ftp = new FtpWeb("ddlucky.vicp.net:3721", "", "dsuser", "dsuser");
            var ftpmsg = "";
            var ftp = new FtpWeb(FTPADDRESS, FTPPATH, FTPUSERNAME, FTPPWD);
            try
            {
                //log.Debug($"读取任务信息完成");
                while (carrierStr.Substring(carrierStr.Length - 1, 1) == ";")
                {
                    carrierStr = carrierStr.Substring(0, carrierStr.Length - 1);
                }

                carrierList = new List<CARRIER>();
                var carrierarray = Regex.Split(carrierStr, ";;");
                foreach (string carrierstr in carrierarray)
                {
                    var temparray = Regex.Split(carrierstr, ";");
                    CARRIER carrier = new CARRIER(temparray[0], temparray[1]);
                    carrierList.Add(carrier);
                }
                //log.Debug($"船公司读取完成");
                var PaymentTermStr = context.JobDetail.JobDataMap.GetString("PaymentTerm");
                运输条款 = new 运输条款表(PaymentTermStr);


                //if (!ftp.DirectoryExist(ErrorFilePackName))
                //{
                //    log.Debug($"在FTP中建立错误文件文件夹：{ErrorFilePackName}");
                //    ftp.MakeDir(ErrorFilePackName);
                //}
                

                
                //获得FTP的文件列表
                var filearray = ftp.GetFileList("",out ftpmsg);
                log.Debug($"FTP连接:{FTPADDRESS},{FTPPATH},{FTPUSERNAME},{FTPPWD},ftpmsg={ftpmsg}");
                if (filearray == null || filearray.Count() == 0)
                {
                    log.Debug($"没有可读取的文件，进程结束");
                    moveErrorFileOut(ftp);
                    return;
                }

                log.Debug($"发现文件数：{filearray.Count()}");




                //如果文件列表没有文件 结束
                //if ( filearray.Count() == 0 ) return;
                
                

                var filepath = AppDomain.CurrentDomain.BaseDirectory + @"\XMLFILE\" + DateTime.Now.ToString("yyyy-MM-dd") + @"\";
                if (Directory.Exists(filepath) == false)
                {
                    Directory.CreateDirectory(filepath);
                    log.Debug($"服务器本地建立文件夹：{filepath}");
                }
            

                //var pkgslist = DBWork.GetPKGSList(connStr);

                //2:遍历文件列表 将文件解析成数据对象
                var clcount = 0;

                foreach (var filename in filearray) {
                    try
                    {
                        ftp = new FtpWeb(FTPADDRESS, FTPPATH, FTPUSERNAME, FTPPWD);
                        //只处理末尾是.xml的文件 不分大小写；
                        var filenamelast = filename.Substring(filename.Length - 4, 4).ToUpper();
                        if (filenamelast != ".XML")
                            continue;
                        if (filename.Contains(ErrorFileHead))
                            continue;

                        clcount++;
                        //2.1:保存数据对象 记录结果

                        if (Directory.Exists(filepath + filename) == false)
                        {
                            log.Debug($"保存文件：{filename}");
                            ftp.Download(filepath, filename);
                            currXMLFile = filename;
                        }


                        var xmlstr = ftp.getFileStr(filename);
                        //XMLParser xmlParser = new XMLParser();
                        //XMLNode xn = xmlParser.Parse(xmlstr);
                        log.Debug($"开始解析文档{clcount.ToString()}:{filename}");
                        var xmlroot = XmlReader.GetXmlDocByXmlContent(xmlstr);
                        log.Debug($"已解析至xml对象，开始整理数据");
                        var _r = 0;//影响行数

                        var msgout = "";
                        var pkgslist = DBWork.GetPKGSList(connStr);
                        var ctncodelist= DBWork.GetCtnCodeList(connStr);
                        var head = new FTP_SeaeOrderMC(xmlroot, carrierList, 运输条款, pkgslist, ctncodelist, out msgout);

                        if (msgout != "over")
                        {
                            log.Debug($"提取数据错误：{msgout}");

                            movetoerror(ftp);
                            //GC.Collect();
                        }
                        else
                        {

                            log.Debug($"解析完成，保存数据:{filename}");
                            var sqlstr = DBWork.getSaveSql(connStr, head);
                            log.Debug($"Save语句:{sqlstr}");
                            _r = DBWork.Save(connStr, head);

                            log.Debug($"保存完成");

                            ////2.2 将保存正确的文件删除。
                            if (_r > 0)
                            {
                                log.Debug($"开始删除:{filename}");
                                ftp.Delete(filename);
                                log.Debug($"结束删除");
                            }
                            if (head.BLTYPE != "Booking") {
                                var htmlFile = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "JFMailTemplate.html");
                                var content = File.ReadAllText(htmlFile);
                                content = content.Replace("$SHIPPER$", head.SHIPPER.Replace("\r\n", "<br />"));
                                content = content.Replace("$CONSIGNEE$", head.CONSIGNEE.Replace("\r\n", "<br />"));
                                content = content.Replace("$NOTIFYPARTY$", head.NOTIFYPARTY.Replace("\r\n", "<br />"));
                                content = content.Replace("$CUSTNO$", head.CUSTNO);
                                content = content.Replace("$MBLNO$", head.MBLNO);
                                content = content.Replace("$ETD$", head.ETD);
                                content = content.Replace("$SERVICE$", head.SERVICE);
                                content = content.Replace("$BLFRT$", head.BLFRT);
                                content = content.Replace("$PREPARDAT$", head.PREPARDAT);
                                content = content.Replace("$PAYABLEAT$", head.PAYABLEAT);
                                content = content.Replace("$VESSEL$", head.VESSEL);
                                content = content.Replace("$VOYNO$", head.VOYNO);
                                content = content.Replace("$PORTLOAD$", head.PORTLOAD);
                                content = content.Replace("$NOBILL$", head.NOBILL);
                                content = content.Replace("$ISSUEPLACE$", head.ISSUEPLACE);
                                content = content.Replace("$PORTDISCHARGE$", head.PORTDISCHARGE);
                                content = content.Replace("$PLACEDELIVERY$", head.PLACEDELIVERY);
                                content = content.Replace("$MARKS$", head.MARKS.Replace("\r\n", "<br />"));
                                content = content.Replace("$PKGS$", head.PKGS);
                                content = content.Replace("$KINDPKGS$", head.KINDPKGS);
                                content = content.Replace("$DESCRIPTION$", head.DESCRIPTION.Replace("\r\n", "<br />"));
                                content = content.Replace("$KGS$", head.KGS);
                                content = content.Replace("$CBM$", head.CBM);
                                content = content.Replace("$CARRIER$", head.CARRIER);
                                content = content.Replace("$CUSTATTN$", head.CUSTATTN);
                                content = content.Replace("$CUSTTEL$", head.CUSTTEL);
                                content = content.Replace("$DCLASS$", head.DCLASS);
                                content = content.Replace("$DUNNO$", head.DUNNO);
                                content = content.Replace("$SERVICECONTRACTNO$", head.SERVICECONTRACTNO);
                                content = content.Replace("$ISSUETYPE$", head.ISSUETYPE);
                                content = content.Replace("$TEMPMIN$", head.TEMPMIN);
                                content = content.Replace("$TEMPMAX$", head.TEMPMAX);
                                content = content.Replace("$REMARK$", head.REMARK.Replace("\r\n", "<br />"));

                                HtmlDocument htmlDoc = new HtmlDocument();
                                htmlDoc.LoadHtml(content);
                                var nodeTbList = htmlDoc.GetElementbyId("tbCtnDataList");
                                nodeTbList.RemoveAllChildren();
                                foreach (var itemsctn in head.CtnList) {
                                    var tr = htmlDoc.CreateElement("tr");
                                    nodeTbList.AppendChild(tr);
                                    var CNTRNO = htmlDoc.CreateElement("td");
                                    tr.AppendChild(CNTRNO);
                                    CNTRNO.SetAttributeValue("style", "padding:10px;border-left:1px solid #333;border-bottom:1px solid #333;text-align:center;font-size:14px;");
                                    CNTRNO.InnerHtml = $"{itemsctn.CNTRNO}";
                                    var SEALNO = htmlDoc.CreateElement("td");
                                    tr.AppendChild(SEALNO);
                                    SEALNO.SetAttributeValue("style", "padding:10px;border-bottom:1px solid #333;text-align:center;font-size:14px;");
                                    SEALNO.InnerHtml = $"{itemsctn.SEALNO}";
                                    var CTNALL = htmlDoc.CreateElement("td");
                                    tr.AppendChild(CTNALL);
                                    CTNALL.SetAttributeValue("style", "padding:10px;border-bottom:1px solid #333;text-align:center;font-size:14px;");
                                    CTNALL.InnerHtml = $"{itemsctn.CTNALL}";
                                    var PKGS = htmlDoc.CreateElement("td");
                                    tr.AppendChild(PKGS);
                                    PKGS.SetAttributeValue("style", "padding:10px;border-bottom:1px solid #333;text-align:center;font-size:14px;");
                                    PKGS.InnerHtml = $"{itemsctn.PKGS}{itemsctn.KINDPKGS}";
                                    var KGS = htmlDoc.CreateElement("td");
                                    tr.AppendChild(KGS);
                                    KGS.SetAttributeValue("style", "padding:10px;border-bottom:1px solid #333;text-align:center;font-size:14px;");
                                    KGS.InnerHtml = $"{itemsctn.KGS}";
                                    var CBM = htmlDoc.CreateElement("td");
                                    tr.AppendChild(CBM);
                                    CBM.SetAttributeValue("style", "padding:10px;border-bottom:1px solid #333;text-align:center;font-size:14px;");
                                    CBM.InnerHtml = $"{itemsctn.CBM}";
                                    var HSCODE = htmlDoc.CreateElement("td");
                                    tr.AppendChild(HSCODE);
                                    HSCODE.SetAttributeValue("style", "padding:10px;border-bottom:1px solid #333;text-align:center;font-size:14px;");
                                    HSCODE.InnerHtml = $"{itemsctn.HSCODE}";
                                    var GOODSNAME = htmlDoc.CreateElement("td");
                                    tr.AppendChild(GOODSNAME);
                                    GOODSNAME.SetAttributeValue("style", "padding:10px;border-bottom:1px solid #333;border-right:1px solid #333;text-align:center;font-size:14px;");
                                    GOODSNAME.InnerHtml = $"{itemsctn.GOODSNAME.Replace("\r\n", "<br />")}";

                                }
                                StringWriter writer = new StringWriter();
                                htmlDoc.Save(writer);
                                string str = writer.ToString();
                                var stmpid = DBWork.GetMailStmp(connStr);
                                var maillist = DBWork.Get任务相关人员邮箱(connStr,head);
                                DBWork.SaveMail(connStr, maillist,"辛克截单:"+head.MBLNO+" "+head.CUSTNO, str, stmpid);
                            }

                            //}
                            //GC.Collect();
                        }
                    }
                    catch (Exception ex)
                    {

                        log.Debug($"错误foreach：{ex.Message}");
                        //GC.Collect();
                        //将该文件写入error文件夹 并删除原文件
                        movetoerror(ftp);
                        //GC.Collect();
                        //log.Error(ex.StackTrace);
                    }
                }

                moveErrorFileOut(ftp);
            }
            catch (Exception ex)
            {

                log.Debug($"错误：{ex.Message}");
                //GC.Collect();
                //将该文件写入error文件夹 并删除原文件
                //movetoerror(ftp);
                //GC.Collect();
                //log.Error(ex.StackTrace);
            }

            moveErrorFileOut(ftp);
     

        }

        private void DoSendMessage(string mblno) {

        }

        private void movetoerror(FtpWeb ftp) {
            try
            {

                //ftp.MoveFile(currXMLFile, ErrorFilePackName + "/" + currXMLFile);
                //log.Debug($"文件移动：" + ErrorFilePackName + "/" + currXMLFile + " 完成");

                ftp.ReName(currXMLFile, ErrorFileHead + currXMLFile);
                log.Debug($"文件重命名：" + ErrorFileHead + currXMLFile + " 完成");
            }
            catch (Exception ex3)
            {
                log.Debug($"文件移动错误_movetoerror：" + ex3.Message);
            }
        }

        private void moveErrorFileOut(FtpWeb ftp)
        {
            log.Debug($"错误文件移动回根目录：开始");
            try
            {
                var ftpmsg = "";
                //var ftp = new FtpWeb(FTPADDRESS, FTPPATH, FTPUSERNAME, FTPPWD);
                //ftp.GotoDirectory("ERROR", false);
                //var errorfilearray = ftp.GetFileList("", out ftpmsg);
                //log.Debug($"错误文件数量:{errorfilearray.Length.ToString()}");
                //if(errorfilearray.Length>0)
                //    log.Debug($"错误文件1:{errorfilearray[0].ToString()}");
                //if (errorfilearray!=null && errorfilearray.Length>0)
                //    foreach (var errorFile in errorfilearray)
                //    {
                //        log.Debug($"错误文件{errorFile}移动：开始 ");
                //        ftp.MoveFile( errorFile,"../"+errorFile);
                //        log.Debug($"错误文件{errorFile}移动：完成");
                //    }
                //ftp = new FtpWeb(FTPADDRESS, FTPPATH, FTPUSERNAME, FTPPWD);

                //20200825 改为将ERROR五个字母放置在文件名前面 

                //var ftp = new FtpWeb(FTPADDRESS, FTPPATH, FTPUSERNAME, FTPPWD);
                var errorfilearray = ftp.GetFileList("", out ftpmsg);
                if (errorfilearray != null) {
                    foreach (var efn in errorfilearray) {
                        if(efn.Contains(ErrorFileHead))
                            ftp.ReName(efn, efn.Replace(ErrorFileHead, ""));
                    }
                }
            }
            catch (Exception ex3)
            {
                log.Debug($"文件移动错误_moveErrorFileOut：" + ex3.Message);
            }
        }
    }

}