From 11b5c70012b274a79740e05221c4cef0ca31d40d Mon Sep 17 00:00:00 2001 From: tdx Date: Sat, 9 May 2026 08:20:32 +0000 Subject: [PATCH] SVN r1164 SVN-Revision: r1164 --- .../Lskj.QueryEssentialInfo/DllBaseClass.cs | 7 +- 插件库/Lskj.QueryEssentialInfo/FrmMain.cs | 210 ++++++++---------- 2 files changed, 98 insertions(+), 119 deletions(-) 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：个税申报 /// 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 } } /// - /// 查询专项附加 + /// 报送人员 /// - 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}"); } + } + } + /// + /// 报送查询 + /// + 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 } } } + } + /// + /// 查询专项附加 + /// + 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 /// 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 /// 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 /// 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 /// 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"))