using log4net;
using Newtonsoft.Json;
using Quartz;
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Text;

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

        public void Execute(IJobExecutionContext context)
        {
            try
            {
                string connStr = context.JobDetail.JobDataMap.GetString("ConnectString");
                string reqUrl = context.JobDetail.JobDataMap.GetString("ReqUrl");
                string customer = context.JobDetail.JobDataMap.GetString("Customer");
                string password = context.JobDetail.JobDataMap.GetString("Password");
                int reqTimeout = Convert.ToInt32(context.JobDetail.JobDataMap.GetString("RequestTimeout"));

                log.Debug($"连接字符串：{connStr}");
                log.Debug($"请求URL：{reqUrl}");
                log.Debug($"用户：{customer}");
                log.Debug($"密码：{password}");
                log.Debug($"请求超时：{reqTimeout}");

                //访问url获取爬取的数据
                Dictionary<string, string> dic = new Dictionary<string, string>();
                dic.Add("custname", customer);
                dic.Add("psw", password);

                log.Debug($"准备请求数据：{dic.Count}");

                string rtn = WebRequestHelper.DoPost(reqUrl, dic, reqTimeout*1000);

                log.Debug($"数据返回：{rtn}");

                //测试
                //string rtn = File.ReadAllText(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "response.json"));

                #region 模板
                //var jsonTemplate = new
                //{
                //    TD = new dynamic[]
                //    {
                //        new
                //        {
                //            GID = "",
                //            CZNAME = "",
                //            YARDNAME = "",
                //            ChuanMing_En = "",
                //            ChuanMing_Cn = "",
                //            HangCi = "",
                //            HaiGuanHangCi = "",
                //            HangXian = "",
                //            MBLNO = "",
                //            XiangXing = "",
                //            XiangLiang = "",
                //            MuDiGang = "",
                //            ZhongZhuanGang = "",
                //            JiGangKaiShiShiJian = "",
                //            JiGangJieShuShiJian = "",
                //            ChuanGongSi = "",
                //            TongGuanFangShi = "",
                //            CreateTime = DateTime.Now,
                //            XieHuoGang = "",
                //            KaoGangMaTou = "",
                //            ZhuangChuanMaTou = "",
                //            SongHuoDiZhi = "",
                //            LiHuoSongHuoChangQu = "",
                //            JieGangShiJian = ""
                //        }
                //    },
                //    XD = new dynamic[]
                //    {
                //        new
                //        {
                //            GID = "",
                //            MBLNO = "",
                //            YARDNAME = "",
                //            XiangHao = "",
                //            XiangXing = "",
                //            FengHao = "",
                //            NeiDianWaiDian = "",
                //            XiangPiZhong = "",
                //            HuoZhong = "",
                //            ZongZhong = "",
                //            VGM = "",
                //            CheHao = "",
                //            TiXiangShiJian = "",
                //            FanChangShiJian = "",
                //            JiGangShiJian = "",
                //            HuaBo = "",
                //            ZhiDingXiangHaoTiXiangChangQu = "",
                //            ShangJianXiangHao = "",
                //            CreateTime = DateTime.Now
                //        }
                //    },
                //    FD = new dynamic[]
                //    {
                //        new
                //        {
                //            GID = "",
                //            MBLNO = "",
                //            YARDNAME = "",
                //            FDH = "",
                //            XiangHao = "",
                //            XiangXing = "",
                //            QianFeng = "",
                //            JianShu = "",
                //            BaoZhuang = "",
                //            ZhongLiang = "",
                //            ChiMa = "",
                //            CreateTime = DateTime.Now
                //        }
                //    },
                //    WL = new dynamic[]
                //    {
                //        new
                //        {
                //            GID = "",
                //            MBLNO = "",
                //            CZNAME = "",
                //            HuoWuZhuangTai = "",
                //            ShenBaoXiangShu = "",
                //            JianShu = "",
                //            ZhongLiang = "",
                //            YuPeiShiJian = "",
                //            YuPeiJieGuo = "",
                //            YunDiShiJian = "",
                //            YunDiJieGuo = "",
                //            FangXingShiJian = "",
                //            FangXingZhuangTai = "",
                //            ZhuangZaiShiJian = "",
                //            ZhuangZaiJieGuo = "",
                //            CreateTime = DateTime.Now
                //        }
                //    }
                //};
                #endregion

                var parseJsonObj = JsonConvert.DeserializeObject<JsonResponse>(rtn);


                //入库
                using (SqlConnection dbcon = new SqlConnection(connStr))
                {
                    dbcon.Open();
                    using (SqlTransaction trans = dbcon.BeginTransaction())
                    {
                        #region 提单
                        //foreach (var item in parseJsonObj.TD)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.MBLNO);

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}
                        #endregion

                        #region 箱号
                        foreach (var item in parseJsonObj.XD)
                        {
                            string sql = ExecuteCommand(item.GetType(), item, item.XiangHao,"XiangHao");

                            SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                            cmd.ExecuteNonQuery();
                        }
                        #endregion

                        #region 分单
                        //foreach (var item in parseJsonObj.FD)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.FDH, "FDH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}
                        #endregion

                        #region 物流
                        foreach (var item in parseJsonObj.WL)
                        {
                            string sql = ExecuteCommand(item.GetType(), item, item.MBLNO);

                            SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                            cmd.ExecuteNonQuery();
                        }
                        #endregion

                        #region 云港通

                        foreach (var item in parseJsonObj.YGT.QdPortChuanBoJiHua)
                        {
                            string sql = ExecuteCommand(item.GetType(), item, item.TDH, "TDH");

                            SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                            cmd.ExecuteNonQuery();
                        }

                        //foreach (var item in parseJsonObj.YGT.QdPortDanChuanChuKouKLBJH)
                        //{   
                        //    string sql = ExecuteCommand(item.GetType(), item, item.ZTDH, "ZTDH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}

                        //foreach (var item in parseJsonObj.YGT.QdPortDanChuanChuKouMTCQ)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.ZTDH, "ZTDH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}

                        //foreach (var item in parseJsonObj.YGT.QdPortDanChuanChuKouZYJH)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.ZTDH, "ZTDH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}

                        //foreach (var item in parseJsonObj.YGT.QdPortDanChuanChuKouZYQK)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.ZTDH, "ZTDH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}

                        foreach (var item in parseJsonObj.YGT.QdPortDanPiaoChuKouBGDFX)
                        {
                            string sql = ExecuteCommand(item.GetType(), item, item.TDH, "TDH");

                            SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                            cmd.ExecuteNonQuery();
                        }

                        foreach (var item in parseJsonObj.YGT.QdPortDanPiaoChuKouMTXX)
                        {
                            string sql = ExecuteCommand(item.GetType(), item, item.XH, "XH");

                            SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                            cmd.ExecuteNonQuery();
                        }

                        //foreach (var item in parseJsonObj.YGT.QdPortDanPiaoChuKouWLLH)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.TDH, "TDH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}

                        //foreach (var item in parseJsonObj.YGT.QdPortDanPiaoChuKouWLSH)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.XH, "XH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}

                        foreach (var item in parseJsonObj.YGT.QdPortDanPiaoChuKouYDBG)
                        {
                            string sql = ExecuteCommand(item.GetType(), item, item.XH, "XH");

                            SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                            cmd.ExecuteNonQuery();
                        }
                        //foreach (var item in parseJsonObj.YGT.QdPortDanPiaoJinKouHGBGDFX)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.XH, "XH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}

                        //foreach (var item in parseJsonObj.YGT.QdPortDanPiaoChuKouZXD)
                        //{
                        //    string sql = ExecuteCommand(item.GetType(), item, item.TDH, "TDH");

                        //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                        //    cmd.ExecuteNonQuery();
                        //}

                        foreach (var item in parseJsonObj.YGT.QdPortDanPiaoChuKouZZFX)
                        {
                            string sql = ExecuteCommand(item.GetType(), item, item.XH, "XH");

                            SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                            cmd.ExecuteNonQuery();
                        }
                        #endregion

                        #region 单一窗口
                        foreach (var item in parseJsonObj.SDITDS)
                        {
                            string sql = ExecuteCommand(item.GetType(), item, item.MBLNO);

                            SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                            cmd.ExecuteNonQuery();
                        }
                        #endregion

                        trans.Commit();
                    }
                    dbcon.Close();
                }
            }
            catch (Exception ex)
            {
                log.Error(ex.Message);
                log.Error(ex.StackTrace);
            }
        }

        private string ExecuteCommand(Type itemType, object item, string mblno, string mblnoColName = "MBLNO")
        {
            string sqlDel = $"delete {itemType.Name} where {mblnoColName}='{mblno}';";

            string colStr = string.Empty;
            string valStr = string.Empty;
            PropertyInfo[] propertys = itemType.GetProperties();
            foreach (var prop in propertys)
            {
                if (colStr.Length > 0)
                {
                    colStr += ",";
                    valStr += ",";
                }
                colStr += prop.Name;
                valStr += $"'{prop.GetValue(item, null)}'";
            }

            string sqlIns = $"insert into {item.GetType().Name}({colStr}) values({valStr});";

            return sqlDel + sqlIns;
        }
    }
}