using Lskj.Business.Impl;
using Lskj.Control;
using Lskj.Core;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace Lskj.QueryEssentialInfo
{
    public partial class FrmMain : BaseForm
    {
        public DynamicQueryEssential Model;
        public FrmMain()
        {
            InitializeComponent();
            this.Load += OnFrmMainLoad;
        }
        /// <summary>
        /// 初始化时
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnFrmMainLoad(object sender, EventArgs e)
        {
            try
            {
                progressBarCurrent.Maximum = 100;
                progressBarCurrent.Value = 0;
                QueryApiUtil.mainRow = BaseImpl.GetDataRowResult(Model.MainSourceSql);
                QueryApiUtil.detailTab = BaseImpl.GetDataTableResult(Model.DetailSourceSql);
                Task.Factory.StartNew(() =>
                {
                    try
                    {
                        switch (Model.ExecMode)
                        {
                            case "0":
                                ZXFJQuery();
                                Invoke(new Action(() =>
                                {
                                    MessageUtil.Show("专项附加查询完成");
                                }));
                                break;
                            case "1":
                                GSSBQuery();
                                Invoke(new Action(() =>
                                {
                                    MessageUtil.Show("个税申报完成");
                                }));
                                break;
                            case "2":
                                YLJQuery();
                                Invoke(new Action(() =>
                                {
                                    MessageUtil.Show("个人养老金查询完成");
                                }));
                                break;
                        }
                    }
                    catch (Exception ex)
                    {
                        Invoke(new Action(() =>
                        {
                            MessageUtil.Show(ex.Message);
                            this.Close();
                        }));
                    }
                });
            }
            catch (Exception ex)
            {
                MessageUtil.Show(ex.Message);
                this.Close();
            }
        }
        /// <summary>
        /// 查询专项附加
        /// </summary>
        private void ZXFJQuery()
        {
            QueryApiUtil.Init(out string initResult, out string initMsg);
            if (QueryApiUtil.detailTab.AsEnumerable().Where(n => !(n["p_emp_addTag"] + "").Equals("1")).Count() > 0)
            {
                SetProcessMsg($"正在报送人员...");
                string personCode = QueryApiUtil.Person(out string personResult, out string personMsg);
                if (!personCode.Equals("0"))
                {
                    throw new Exception($"报送失败\r\n{personMsg}");
                }
                SetProcessMsg($"正在查询报送人员...");
                string personQueryCode = QueryApiUtil.PersonQuery(out string personQueryResult, out string personQueryMsg);
                if (!personQueryCode.Equals("0"))
                {
                    throw new Exception($"报送查询失败\r\n{personQueryMsg}");
                }
                else
                {
                    JObject personQueryJObject = (JObject)JsonConvert.DeserializeObject(personQueryResult);
                    if (personQueryJObject["data"] is JArray)
                    {
                        JArray personQueryJArray = (JArray)personQueryJObject["data"];
                        foreach (JObject personJObject in personQueryJArray)
                        {
                            string name = personJObject["name"] + "";
                            string sfzh = personJObject["sfzh"] + "";
                            string bszt = personJObject["bszt"] + "";
                            string sfyzzt = personJObject["sfyzzt"] + "";
                            if (bszt.Equals("报送成功") && sfyzzt.Equals("验证成功"))
                            {
                                SqlHelper.ExecuteNonQuery($"update p_employeeTab set p_emp_addTag = 1 where p_emp_idcardnum = '{sfzh}'");
                            }
                            SetProcessMsg($"已报送：{name}");
                        }
                    }
                }
            }
            QueryApiUtil.detailTab = BaseImpl.GetDataTableResult(Model.DetailSourceSql);
            Invoke(new Action(() =>
            {
                progressBarCurrent.Maximum = QueryApiUtil.detailTab.AsEnumerable().Where(n => (n["p_emp_addTag"] + "").Equals("1")).Count();
            }));
            SetProcessMsg($"正在同步专项附加数据...");
            string postAdditionCode = QueryApiUtil.PostAddition(out string postAdditionResult, out string postAdditionMsg);
            SetProcessMsg($"正在查询专项附加数据...");
            string getAdditionCode = QueryApiUtil.GetAddition(out string getAdditionResult, out string getAdditionMsg);
            if (!getAdditionCode.Equals("0"))
            {
                if (getAdditionMsg.Equals("还未通过税务共享平台获取专项附加或员工还未上报专项附加"))
                {
                    for (int i = 0; i < 5; i++)
                    {
                        getAdditionResult = "";
                        getAdditionMsg = "";
                        getAdditionCode = QueryApiUtil.GetAddition(out getAdditionResult, out getAdditionMsg);
                        if (getAdditionCode.Equals("0"))
                        {
                            break;
                        }
                    }
                }
            }
            if (!getAdditionCode.Equals("0"))
            {
                throw new Exception($"查询数据失败\r\n{getAdditionMsg}");
            }
            else
            {
                JObject additionJObject = (JObject)JsonConvert.DeserializeObject(getAdditionResult);
                if (additionJObject["data"] is JObject)
                {
                    JObject additionDataJObject = (JObject)additionJObject["data"];
                    if (additionDataJObject.ContainsKey("list") && additionDataJObject["list"] is JArray)
                    {
                        string ysyf = QueryApiUtil.mainRow["ysyf"] + "";
                        JArray additionListJArray = (JArray)additionDataJObject["list"];
                        foreach (JObject item in additionListJArray)
                        {
                            StringBuilder sqlBuilder = new StringBuilder();
                            string peopleName = item["peopleName"] + "";
                            string idNumber = item["idNumber"] + "";
                            sqlBuilder.AppendLine($"delete from p_gszxfjkctab where idnumber = '{idNumber}' and itemid = '{ysyf}' and type <> '个人养老金';");
                            string sylrAccumulate = item["sylrAccumulate"] + "";
                            sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{peopleName}','赡养老人','{sylrAccumulate}','','{idNumber}','{ysyf}');");
                            string znjyAccumulate = item["znjyAccumulate"] + "";
                            sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{peopleName}','子女教育','{znjyAccumulate}','','{idNumber}','{ysyf}');");
                            string xljxjyAccumulate = item["xljxjyAccumulate"] + "";
                            sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{peopleName}','学历继续教育','{xljxjyAccumulate}','','{idNumber}','{ysyf}');");
                            string zyzgjxjyAccumulate = item["zyzgjxjyAccumulate"] + "";
                            sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{peopleName}','专业资格继续教育','{zyzgjxjyAccumulate}','','{idNumber}','{ysyf}');");
                            string zfdklxAccumulate = item["zfdklxAccumulate"] + "";
                            sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{peopleName}','住房贷款利息','{zfdklxAccumulate}','','{idNumber}','{ysyf}');");
                            string zfzjAccumulate = item["zfzjAccumulate"] + "";
                            sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{peopleName}','租房租金','{zfzjAccumulate}','','{idNumber}','{ysyf}');");
                            string yyezhfAccumulate = item["yyezhfAccumulate"] + "";
                            sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{peopleName}','婴幼儿照护','{yyezhfAccumulate}','','{idNumber}','{ysyf}');");
                            if (!string.IsNullOrEmpty(sqlBuilder.ToString()))
                            {
                                BaseImpl.ExecSqlValue(sqlBuilder.ToString());
                            }
                            SetProcessMsg($"已查询：{peopleName}");
                            SetProcessBar();
                        }
                    }
                }
            }
            #region 已弃用
            //string token = "";
            //string aggOrgId = "";
            //string accountId = "";
            //if ((string.IsNullOrEmpty(token) || string.IsNullOrEmpty(aggOrgId)) && QueryApiUtil.AlterTable("p_systemtab", "queryEssentialToken", "varchar(1000)") && QueryApiUtil.AlterTable("p_systemtab", "queryEssentialAggOrgId", "varchar(200)"))
            //{
            //    DataRow tokenRow = BaseImpl.GetDataRowResult("select queryEssentialToken,queryEssentialAggOrgId from p_systemtab");
            //    token = tokenRow["queryEssentialToken"] + "";
            //    aggOrgId = tokenRow["queryEssentialAggOrgId"] + "";
            //    if (string.IsNullOrEmpty(token))
            //    {
            //        QueryApiUtil.GetToken(ref token, ref aggOrgId);
            //    }
            //}
            //string checkPasswordMsg = "";
            //string checkPasswordCode = QueryApiUtil.CheckPassword(ref token, ref aggOrgId, ref accountId, ref checkPasswordMsg);
            //if (!checkPasswordCode.Equals("2000"))
            //{
            //    QueryApiUtil.GetToken(ref token, ref aggOrgId);
            //    checkPasswordMsg = "";
            //    checkPasswordCode = QueryApiUtil.CheckPassword(ref token, ref aggOrgId, ref accountId, ref checkPasswordMsg);
            //}
            //if (!checkPasswordCode.Equals("2000"))
            //{
            //    throw new Exception($"验证失败\r\n{checkPasswordMsg}");
            //}
            //string employeeInfoCode = QueryApiUtil.QueryEssentialEmployeeInfo(ref token, ref aggOrgId, ref accountId, out string employeeInfoResult);
            //if (employeeInfoCode.Equals("2000") || employeeInfoCode.Equals("-9998"))
            //{
            //    if (employeeInfoCode.Equals("2000"))
            //    {
            //        JObject employeeInfoJObject = (JObject)JsonConvert.DeserializeObject(employeeInfoResult);
            //        string success = employeeInfoJObject.ContainsKey("success") ? employeeInfoJObject["success"] + "" : "";
            //        string message = employeeInfoJObject.ContainsKey("message") ? employeeInfoJObject["message"] + "" : "";
            //        if (success.Equals("true", StringComparison.OrdinalIgnoreCase))
            //        {
            //            string taskId = employeeInfoJObject["data"]["taskId"] + "";
            //            string backStates = "0";
            //            string backSuccess = "";
            //            string backMessage = "";
            //            int waitCount = 1;
            //            while (backStates.Equals("0") || backStates.Equals("1"))
            //            {
            //                SetProcessMsg($"等待报送数据返回({waitCount})...");
            //                string employeeInfoBackCode = QueryApiUtil.QueryEssentialEmployeeInfoFeedback(taskId, ref token, ref aggOrgId, ref accountId, out string employeeInfoBackResult);
            //                if (employeeInfoBackCode.Equals("2000"))
            //                {
            //                    JObject employeeInfoBackJObject = (JObject)JsonConvert.DeserializeObject(employeeInfoBackResult);
            //                    backSuccess = employeeInfoBackJObject.ContainsKey("success") ? employeeInfoBackJObject["success"] + "" : "";
            //                    if (backSuccess.Equals("true", StringComparison.OrdinalIgnoreCase))
            //                    {
            //                        backMessage = employeeInfoBackJObject["data"]["taskStatusName"] + "";
            //                        backStates = employeeInfoBackJObject["data"]["taskStatus"] + "";
            //                        if (backStates.Equals("3"))//已完成
            //                        {
            //                            JArray resultArray = (JArray)employeeInfoBackJObject["data"]["result"];
            //                            foreach (JObject result in resultArray)
            //                            {
            //                                string xm = result["xm"] + "";
            //                                string zjhm = result["zzhm"] + "";
            //                                SqlHelper.ExecuteNonQuery($"update p_employeeTab set p_emp_addTag = 1 where p_emp_idcardnum = '{zjhm}'");
            //                                SetProcessMsg($"已报送：{xm}");
            //                                SetProcessBar();
            //                            }
            //                        }
            //                        if (backStates.Equals("2"))
            //                        {
            //                            string errorMessage = employeeInfoBackJObject["data"]["message"] + "";
            //                            throw new Exception($"报送反馈请求失败\r\n{errorMessage}");
            //                        }
            //                    }
            //                }
            //                else
            //                {
            //                    throw new Exception($"报送反馈请求失败\r\n{employeeInfoBackResult}");
            //                }
            //            }
            //        }
            //    }
            //}
            //else
            //{
            //    throw new Exception($"报送失败\r\n{employeeInfoResult}");
            //}
            //string queryInfoCode = QueryApiUtil.QueryEssentialInfo(ref token, ref aggOrgId, ref accountId, out string queryInfoResult);
            //if (queryInfoCode.Equals("2000") || queryInfoCode.Equals("-9998"))
            //{
            //    if (queryInfoCode.Equals("2000"))
            //    {
            //        JObject queryInfoJObject = (JObject)JsonConvert.DeserializeObject(queryInfoResult);
            //        string success = queryInfoJObject.ContainsKey("success") ? queryInfoJObject["success"] + "" : "";
            //        string message = queryInfoJObject.ContainsKey("message") ? queryInfoJObject["message"] + "" : "";
            //        if (success.Equals("true", StringComparison.OrdinalIgnoreCase))
            //        {
            //            string taskId = queryInfoJObject["data"]["taskId"] + "";
            //            string backStates = "0";
            //            string backSuccess = "";
            //            string backMessage = "";
            //            int waitCount = 1;
            //            while (backStates.Equals("0") || backStates.Equals("1"))
            //            {
            //                SetProcessMsg($"等待查询数据返回({waitCount})...");
            //                string queryInfoBackCode = QueryApiUtil.QueryEssentialInfoFeedback(taskId, ref token, ref aggOrgId, ref accountId, out string queryInfoBackResult);
            //                if (queryInfoBackCode.Equals("2000"))
            //                {
            //                    JObject queryInfoBackJObject = (JObject)JsonConvert.DeserializeObject(queryInfoBackResult);
            //                    backSuccess = queryInfoBackJObject.ContainsKey("success") ? queryInfoBackJObject["success"] + "" : "";
            //                    if (backSuccess.Equals("true", StringComparison.OrdinalIgnoreCase))
            //                    {
            //                        backMessage = queryInfoBackJObject["data"]["taskStatusName"] + "";
            //                        backStates = queryInfoBackJObject["data"]["taskStatus"] + "";
            //                        if (backStates.Equals("3"))
            //                        {
            //                            string itemId = QueryApiUtil.mainRow["skssq"] + "";
            //                            JArray resultArray = (JArray)queryInfoBackJObject["data"]["result"];
            //                            foreach (JObject result in resultArray)
            //                            {
            //                                StringBuilder sqlBuilder = new StringBuilder();
            //                                string xm = result["xm"] + "";
            //                                string zzlx = result["zzlx"] + "";
            //                                string zzhm = result["zzhm"] + "";
            //                                sqlBuilder.AppendLine($"delete from p_gszxfjkctab where idnumber = '{zzhm}' and itemid = '{itemId}';");
            //                                #region 子女教育
            //                                JArray znjys = (JArray)result["znjys"];
            //                                foreach (JObject znjy in znjys)
            //                                {
            //                                    string znjyxm = znjy["xm"] + "";
            //                                    sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{xm}','子女教育','2000','{znjyxm}','{zzhm}','{itemId}');");
            //                                }
            //                                #endregion
            //                                #region 赡养老人
            //                                if (result["sylrs"] is JObject)
            //                                {
            //                                    JObject sylrs = (JObject)result["sylrs"];
            //                                    string ftje = sylrs["ftje"] + "";
            //                                    sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{xm}','赡养老人','{ftje}','','{zzhm}','{itemId}');");
            //                                }
            //                                #endregion
            //                                #region 住房租金
            //                                JArray fwzls = (JArray)result["fwzls"];
            //                                foreach (JObject fwzl in fwzls)
            //                                {
            //                                    string zfzlhtbh = fwzl["zfzlhtbh"] + "";
            //                                    sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{xm}','住房租金','1500','{zfzlhtbh}','{zzhm}','{itemId}');");
            //                                }
            //                                #endregion
            //                                #region 住房贷款
            //                                JArray fwdks = (JArray)result["fwdks"];
            //                                foreach (JObject fwdk in fwdks)
            //                                {
            //                                    string zsh = fwdk["zsh"] + "";
            //                                    sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{xm}','住房贷款','1000','{zsh}','{zzhm}','{itemId}');");
            //                                }
            //                                #endregion
            //                                #region 继续教育
            //                                JArray jxjys = (JArray)result["jxjys"];
            //                                foreach (JObject jxjy in jxjys)
            //                                {
            //                                    string zsmc = jxjy["zsmc"] + "";
            //                                    sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{xm}','继续教育','400','{zsmc}','{zzhm}','{itemId}');");
            //                                }
            //                                #endregion
            //                                #region 婴幼儿照护
            //                                JArray yyezhls = (JArray)result["yyezhls"];
            //                                foreach (JObject yyezhl in yyezhls)
            //                                {
            //                                    string yyexm = yyezhl["xm"] + "";
            //                                    sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{xm}','婴幼儿照护','2000','{yyexm}','{zzhm}','{itemId}');");
            //                                }
            //                                #endregion
            //                                SqlHelper.ExecuteNonQuery(sqlBuilder.ToString());
            //                                SetProcessMsg($"已查询：{xm}");
            //                                SetProcessBar();
            //                            }
            //                        }
            //                        if (backStates.Equals("2"))
            //                        {
            //                            string errorMessage = queryInfoBackJObject["data"]["message"] + "";
            //                            throw new Exception($"报送反馈请求失败\r\n{errorMessage}");
            //                        }
            //                    }
            //                }
            //                else
            //                {
            //                    throw new Exception($"数据请求反馈失败\r\n{queryInfoBackResult}");
            //                }
            //                Thread.Sleep(1000);
            //            }
            //            Invoke(new Action(() =>
            //            {
            //                MessageUtil.Show(backMessage);
            //            }));
            //        }
            //    }
            //}
            //else
            //{
            //    throw new Exception($"数据请求失败\r\n{queryInfoResult}");
            //}
            #endregion
            Invoke(new Action(() =>
            {
                this.Close();
            }));
        }
        /// <summary>
        /// 养老金查询
        /// </summary>
        private void YLJQuery()
        {
            QueryApiUtil.Init(out string initResult, out string initMsg);
            if (QueryApiUtil.detailTab.AsEnumerable().Where(n => !(n["p_emp_addTag"] + "").Equals("1")).Count() > 0)
            {
                SetProcessMsg($"正在报送人员...");
                string personCode = QueryApiUtil.Person(out string personResult, out string personMsg);
                if (!personCode.Equals("0"))
                {
                    throw new Exception($"报送失败\r\n{personMsg}");
                }
                SetProcessMsg($"正在查询报送人员...");
                string personQueryCode = QueryApiUtil.PersonQuery(out string personQueryResult, out string personQueryMsg);
                if (!personQueryCode.Equals("0"))
                {
                    throw new Exception($"报送查询失败\r\n{personQueryMsg}");
                }
                else
                {
                    JObject personQueryJObject = (JObject)JsonConvert.DeserializeObject(personQueryResult);
                    if (personQueryJObject["data"] is JArray)
                    {
                        JArray personQueryJArray = (JArray)personQueryJObject["data"];
                        foreach (JObject personJObject in personQueryJArray)
                        {
                            string name = personJObject["name"] + "";
                            string sfzh = personJObject["sfzh"] + "";
                            string bszt = personJObject["bszt"] + "";
                            string sfyzzt = personJObject["sfyzzt"] + "";
                            if (bszt.Equals("报送成功") && sfyzzt.Equals("验证成功"))
                            {
                                SqlHelper.ExecuteNonQuery($"update p_employeeTab set p_emp_addTag = 1 where p_emp_idcardnum = '{sfzh}'");
                            }
                            SetProcessMsg($"已报送：{name}");
                        }
                    }
                }
            }
            QueryApiUtil.detailTab = BaseImpl.GetDataTableResult(Model.DetailSourceSql);
            Invoke(new Action(() =>
            {
                progressBarCurrent.Maximum = QueryApiUtil.detailTab.AsEnumerable().Where(n => (n["p_emp_addTag"] + "").Equals("1")).Count();
            }));
            SetProcessMsg($"正在查询个人养老金数据...");
            string yljfqCode = QueryApiUtil.GetYLJFQ(out string yljfqResult, out string yljfqMsg);
            if (!yljfqCode.Equals("0"))
            {
                for (int i = 0; i < 5; i++)
                {
                    yljfqResult = "";
                    yljfqMsg = "";
                    yljfqCode = QueryApiUtil.GetYLJFQ(out yljfqResult, out yljfqMsg);
                    if (yljfqCode.Equals("0"))
                    {
                        break;
                    }
                }
            }
            if (!yljfqCode.Equals("0"))
            {
                throw new Exception($"发起查询失败\r\n{yljfqMsg}");
            }
            else
            {
                string yljmxCode = QueryApiUtil.GetYLJMX(out string yljmxResult, out string yljmxMsg);
                if (!yljmxCode.Equals("0"))
                {
                    throw new Exception($"查询数据失败\r\n{yljmxMsg}");
                }
                else
                {
                    JObject yljJObject = (JObject)JsonConvert.DeserializeObject(yljmxResult);
                    if (yljJObject.ContainsKey("data") && yljJObject["data"] is JArray)
                    {
                        JArray yljDataJArray = (JArray)yljJObject["data"];

                        foreach (JObject item in yljDataJArray)
                        {
                            StringBuilder sqlBuilder = new StringBuilder();
                            string ysyf = QueryApiUtil.mainRow["ysyf"] + "";
                            string name = item["name"] + "";
                            string zjhm = item["zjhm"] + "";
                            string sypzbh = item["sypzbh"] + "";
                            string pzlbDm = item["pzlbDm"] + "";
                            string jcje = item["jcje"] + "";
                            string jcsj = item["jcsj"] + "";
                            string xgrq = item["xgrq"] + "";
                            sqlBuilder.AppendLine($"delete from p_gszxfjkctab where idnumber = '{zjhm}' and itemid = '{ysyf}' and type = '个人养老金';");
                            sqlBuilder.AppendLine($"insert into p_gszxfjkctab (employeename,type,money,bak,idnumber,itemid) values ('{name}','个人养老金','{jcje}','','{zjhm}','{ysyf}');");
                            if (!string.IsNullOrEmpty(sqlBuilder.ToString()))
                            {
                                BaseImpl.ExecSqlValue(sqlBuilder.ToString());
                            }
                            //SetProcessMsg($"已查询：{peopleName}");
                            SetProcessBar();
                        }
                    }
                }
            }
            Invoke(new Action(() =>
            {
                this.Close();
            }));
        }
        /// <summary>
        /// 个税申报
        /// </summary>
        private void GSSBQuery()
        {
            SetProcessMsg($"正在进行个税申报...");
            string submitCode = QueryApiUtil.Submit(out string submitResult, out string submitMsg);
            if (!submitCode.Equals("0"))
            {
                throw new Exception($"个税申报失败\r\n{submitMsg}");
            }
            SetProcessMsg($"正在查询个税申报结果...");
            string submitQueryCode = "-99";
            while (!submitQueryCode.Equals("0"))
            {
                submitQueryCode = QueryApiUtil.SubmitQuery(out string submitQueryResult, out string submitQueryMsg);
                if (!submitQueryCode.Equals("0"))
                {