diff --git a/插件库/Lskj.QueryEssentialInfo/DllBaseClass.cs b/插件库/Lskj.QueryEssentialInfo/DllBaseClass.cs
index f3e2945..937c444 100644
--- a/插件库/Lskj.QueryEssentialInfo/DllBaseClass.cs
+++ b/插件库/Lskj.QueryEssentialInfo/DllBaseClass.cs
@@ -46,6 +46,11 @@ namespace Lskj.QueryEssentialInfo
         /// 执行类型0：专项附加查询1：个税申报
         /// </summary>
         public string ExecMode = "0";
+        public string EmployeeTab = "";
         public DynamicQueryEssential(string[] args) : base(args)
         {
-            if (args.Length > 5 && !string.IsNullOrWhit
\ No newline at end of file
+            if (args.Length > 5 && !string.IsNullOrWhiteSpace(args[5]))
+            {
+                MainSourceSql = args[5] + "";
+            }
+            if (args.Length > 6 && !string.IsNullOrWh
\ No newline at end of file
diff --git a/插件库/Lskj.QueryEssentialInfo/FrmMain.cs b/插件库/Lskj.QueryEssentialInfo/FrmMain.cs
index 7ad40b3..6810413 100644
--- a/插件库/Lskj.QueryEssentialInfo/FrmMain.cs
+++ b/插件库/Lskj.QueryEssentialInfo/FrmMain.cs
@@ -49,7 +49,15 @@ namespace Lskj.QueryEssentialInfo
                     {
                         switch (Model.ExecMode)
                         {
+                            case "00":
+                                RYSend();
+                                Invoke(new Action(() =>
+                                {
+                                    MessageUtil.Show("报送人员完成");
+                                }));
+                                break;
                             case "0":
+                                RYJQuery();
                                 ZXFJQuery();
                                 Invoke(new Action(() =>
                                 {
@@ -57,6 +65,7 @@ namespace Lskj.QueryEssentialInfo
                                 }));
                                 break;
                             case "1":
+                                RYJQuery();
                                 GSSKQuery();
                                 Invoke(new Action(() =>
                                 {
@@ -64,6 +73,7 @@ namespace Lskj.QueryEssentialInfo
                                 }));
                                 break;
                             case "11":
+                                RYJQuery();
                                 GSSBQuery();
                                 Invoke(new Action(() =>
                                 {
@@ -71,6 +81,7 @@ namespace Lskj.QueryEssentialInfo
                                 }));
                                 break;
                             case "2":
+                                RYJQuery();
                                 YLJQuery();
                                 Invoke(new Action(() =>
                                 {
@@ -78,6 +89,7 @@ namespace Lskj.QueryEssentialInfo
                                 }));
                                 break;
                             case "3":
+                                RYJQuery();
                                 DSFXZQuery();
                                 Invoke(new Action(() =>
                                 {
@@ -103,9 +115,9 @@ namespace Lskj.QueryEssentialInfo
             }
         }
         /// <summary>
-        /// 查询专项附加
+        /// 报送人员
         /// </summary>
-        private void ZXFJQuery()
+        private void RYSend()
         {
             QueryApiUtil.Init(out string initResult, out string initMsg);
             var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
@@ -117,12 +129,17 @@ namespace Lskj.QueryEssentialInfo
                 {
                     throw new Exception($"报送失败\r\n{personMsg}");
                 }
+            }
+        }
+        /// <summary>
+        /// 报送查询
+        /// </summary>
+        private void RYJQuery()
+        {
+            var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
+            if (rowsEnumerable.Where(n => string.IsNullOrEmpty(n["p_emp_addTag"] + "") || (n["p_emp_addTag"] + "").Equals("0")).Count() > 0)
+            {
                 SetProcessMsg($"正在查询报送人员...");
-                for (int i = 0; i < 5; i++)
-                {
-                    Thread.Sleep(1000);
-                    SetProcessMsg($"正在查询报送人员...({i + 1}秒)");
-                }
                 string personQueryCode = QueryApiUtil.PersonQuery(out string personQueryResult, out string personQueryMsg);
                 if (!personQueryCode.Equals("0"))
                 {
@@ -145,7 +162,7 @@ namespace Lskj.QueryEssentialInfo
                                 DataRow selectRow = rowsEnumerable.Where(n => (n["idNumber"] + "").Equals(sfzh)).FirstOrDefault();
                                 if (selectRow != null)
                                 {
-                                    SqlHelper.ExecuteNonQuery($"update p_employeeTab set p_emp_addTag = 1 where p_emp_idcardnum = '{sfzh}'");
+                                    SqlHelper.ExecuteNonQuery($"update {Model.EmployeeTab} set p_emp_addTag = 1 where p_emp_idcardnum = '{sfzh}'");
                                 }
                             }
                             else
@@ -153,7 +170,35 @@ namespace Lskj.QueryEssentialInfo
                                 DataRow selectRow = rowsEnumerable.Where(n => (n["idNumber"] + "").Equals(sfzh)).FirstOrDefault();
                                 if (selectRow != null)
                                 {
-                                    SqlHelper.ExecuteNonQuery($"update p_employeeTab set p_emp_addTag = 2,error_msg='{bszt},{sfyzzt}' where p_emp_idcardnum = '{sfzh}'");
+                                    SqlHelper.ExecuteNonQuery($"update {Model.EmployeeTab} set p_emp_addTag = 2,error_msg='{bszt},{sfyzzt}' where p_emp_idcardnum = '{sfzh}'");
+                                }
+                            }
+                            SetProcessMsg($"已报送：{name}");
+                        }
+                    }
+                    else if (personQueryJObject["data"] is JObject listObject && listObject.ContainsKey("list") && listObject["list"] is JArray)
+                    {
+                        JArray personQueryJArray = (JArray)personQueryJObject["data"]["list"];
+                        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("验证成功"))
+                            {
+                                DataRow selectRow = rowsEnumerable.Where(n => (n["idNumber"] + "").Equals(sfzh)).FirstOrDefault();
+                                if (selectRow != null)
+                                {
+                                    SqlHelper.ExecuteNonQuery($"update {Model.EmployeeTab} set p_emp_addTag = 1 where p_emp_idcardnum = '{sfzh}'");
+                                }
+                            }
+                            else
+                            {
+                                DataRow selectRow = rowsEnumerable.Where(n => (n["idNumber"] + "").Equals(sfzh)).FirstOrDefault();
+                                if (selectRow != null)
+                                {
+                                    SqlHelper.ExecuteNonQuery($"update {Model.EmployeeTab} set p_emp_addTag = 2,error_msg='{bszt},{sfyzzt}' where p_emp_idcardnum = '{sfzh}'");
                                 }
                             }
                             SetProcessMsg($"已报送：{name}");
@@ -161,8 +206,19 @@ namespace Lskj.QueryEssentialInfo
                     }
                 }
             }
+        }
+        /// <summary>
+        /// 查询专项附加
+        /// </summary>
+        private void ZXFJQuery()
+        {
             QueryApiUtil.detailTab = BaseImpl.GetDataTableResult(Model.DetailSourceSql);
-            rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
+            var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
+            int bsFaildCount = rowsEnumerable.Where(n => !(n["p_emp_addTag"] + "").Equals("1")).Count();
+            if (bsFaildCount > 0)
+            {
+                throw new Exception($"人员未全部报送成功，请稍后再试或联系管理员");
+            }
             Invoke(new Action(() =>
             {
                 int maxCount = rowsEnumerable.Where(n => (n["p_emp_addTag"] + "").Equals("1")).Count();
@@ -457,61 +513,13 @@ namespace Lskj.QueryEssentialInfo
         /// </summary>
         private void YLJQuery()
         {
-            QueryApiUtil.Init(out string initResult, out string initMsg);
-            var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
-            if (rowsEnumerable.Where(n => string.IsNullOrEmpty(n["p_emp_addTag"] + "") || (n["p_emp_addTag"] + "").Equals("0")).Count() > 0)
-            {
-                SetProcessMsg($"正在报送人员...");
-                string personCode = QueryApiUtil.Person(out string personResult, out string personMsg);
-                if (!personCode.Equals("0"))
-                {
-                    throw new Exception($"报送失败\r\n{personMsg}");
-                }
-                SetProcessMsg($"正在查询报送人员...");
-                for (int i = 0; i < 5; i++)
-                {
-                    Thread.Sleep(1000);
-                    SetProcessMsg($"正在查询报送人员...({i + 1}秒)");
-                }
-                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("验证成功"))
-                            {
-                                DataRow selectRow = rowsEnumerable.Where(n => (n["idNumber"] + "").Equals(sfzh)).FirstOrDefault();
-                                if (selectRow != null)
-                                {
-                                    SqlHelper.ExecuteNonQuery($"update p_employeeTab set p_emp_addTag = 1 where p_emp_idcardnum = '{sfzh}'");
-                                }
-                            }
-                            else
-                            {
-                                DataRow selectRow = rowsEnumerable.Where(n => (n["idNumber"] + "").Equals(sfzh)).FirstOrDefault();
-                                if (selectRow != null)
-                                {
-                                    SqlHelper.ExecuteNonQuery($"update p_employeeTab set p_emp_addTag = 2,error_msg='{bszt},{sfyzzt}' where p_emp_idcardnum = '{sfzh}'");
-                                }
-                            }
-                            SetProcessMsg($"已报送：{name}");
-                        }
-                    }
-                }
-            }
             QueryApiUtil.detailTab = BaseImpl.GetDataTableResult(Model.DetailSourceSql);
+            var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
+            int bsFaildCount = rowsEnumerable.Where(n => !(n["p_emp_addTag"] + "").Equals("1")).Count();
+            if (bsFaildCount > 0)
+            {
+                throw new Exception($"人员未全部报送成功，请稍后再试或联系管理员");
+            }
             Invoke(new Action(() =>
             {
                 rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
@@ -601,61 +609,13 @@ namespace Lskj.QueryEssentialInfo
         /// </summary>
         private void DSFXZQuery()
         {
-            QueryApiUtil.Init(out string initResult, out string initMsg);
-            var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
-            if (rowsEnumerable.Where(n => string.IsNullOrEmpty(n["p_emp_addTag"] + "") || (n["p_emp_addTag"] + "").Equals("0")).Count() > 0)
-            {
-                SetProcessMsg($"正在报送人员...");
-                string personCode = QueryApiUtil.Person(out string personResult, out string personMsg);
-                if (!personCode.Equals("0"))
-                {
-                    throw new Exception($"报送失败\r\n{personMsg}");
-                }
-                SetProcessMsg($"正在查询报送人员...");
-                for (int i = 0; i < 5; i++)
-                {
-                    Thread.Sleep(1000);
-                    SetProcessMsg($"正在查询报送人员...({i + 1}秒)");
-                }
-                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("验证成功"))
-                            {
-                                DataRow selectRow = rowsEnumerable.Where(n => (n["idNumber"] + "").Equals(sfzh)).FirstOrDefault();
-                                if (selectRow != null)
-                                {
-                                    SqlHelper.ExecuteNonQuery($"update hr_grdkfptab set p_emp_addTag = 1 where hr_ID_Card = '{sfzh}'");
-                                }
-                            }
-                            else
-                            {
-                                DataRow selectRow = rowsEnumerable.Where(n => (n["idNumber"] + "").Equals(sfzh)).FirstOrDefault();
-                                if (selectRow != null)
-                                {
-                                    SqlHelper.ExecuteNonQuery($"update hr_grdkfptab set p_emp_addTag = 2,error_msg='{bszt},{sfyzzt}' where hr_ID_Card = '{sfzh}'");
-                                }
-                            }
-                            SetProcessMsg($"已报送：{name}");
-                        }
-                    }
-                }
-            }
             QueryApiUtil.detailTab = BaseImpl.GetDataTableResult(Model.DetailSourceSql);
+            var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
+            int bsFaildCount = rowsEnumerable.Where(n => !(n["p_emp_addTag"] + "").Equals("1")).Count();
+            if (bsFaildCount > 0)
+            {
+                throw new Exception($"人员未全部报送成功，请稍后再试或联系管理员");
+            }
             Invoke(new Action(() =>
             {
                 rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
@@ -685,6 +645,13 @@ namespace Lskj.QueryEssentialInfo
         /// </summary>
         private void GSSBQuery()
         {
+            QueryApiUtil.detailTab = BaseImpl.GetDataTableResult(Model.DetailSourceSql);
+            var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
+            int bsFaildCount = rowsEnumerable.Where(n => !(n["p_emp_addTag"] + "").Equals("1")).Count();
+            if (bsFaildCount > 0)
+            {
+                throw new Exception($"人员未全部报送成功，请稍后再试或联系管理员");
+            }
             SetProcessMsg($"正在进行个税申报...");
             string submitCode = QueryApiUtil.Submit(out string submitResult, out string submitMsg);
             if (!submitCode.Equals("0"))
@@ -727,6 +694,13 @@ namespace Lskj.QueryEssentialInfo
         /// </summary>
         private void GSSKQuery()
         {
+            QueryApiUtil.detailTab = BaseImpl.GetDataTableResult(Model.DetailSourceSql);
+            var rowsEnumerable = QueryApiUtil.detailTab.AsEnumerable();
+            int bsFaildCount = rowsEnumerable.Where(n => !(n["p_emp_addTag"] + "").Equals("1")).Count();
+            if (bsFaildCount > 0)
+            {
+                throw new Exception($"人员未全部报送成功，请稍后再试或联系管理员");
+            }
             SetProcessMsg($"正在同步收入...");
             string incomeCode = QueryApiUtil.GetIncome(out string incomeResult, out string incomeMsg);
             if (!incomeCode.Equals("0"))