From 6b797dde6b14f96ee2a9f62d78fe333925a689cc Mon Sep 17 00:00:00 2001 From: tdx Date: Sat, 11 Oct 2025 03:45:52 +0000 Subject: [PATCH] SVN r1013 SVN-Revision: r1013 --- 插件库/Lskj.QueryEssentialInfo/FrmMain.cs | 137 ++++++++++++++++++ .../Lskj.QueryEssentialInfo/QueryApiUtil.cs | 117 +++++++++++++++ 2 files changed, 254 insertions(+) diff --git a/插件库/Lskj.QueryEssentialInfo/FrmMain.cs b/插件库/Lskj.QueryEssentialInfo/FrmMain.cs index 901cc35..36ba1eb 100644 --- a/插件库/Lskj.QueryEssentialInfo/FrmMain.cs +++ b/插件库/Lskj.QueryEssentialInfo/FrmMain.cs @@ -57,6 +57,13 @@ namespace Lskj.QueryEssentialInfo MessageUtil.Show("个税申报完成"); })); break; + case "2": + YLJQuery(); + Invoke(new Action(() => + { + MessageUtil.Show("个人养老金查询完成"); + })); + break; } } catch (Exception ex) @@ -126,6 +133,22 @@ namespace Lskj.QueryEssentialInfo 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}"); } @@ -375,6 +398,120 @@ namespace Lskj.QueryEssentialInfo })); } /// + /// 养老金查询 + /// + 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 peopleName = item["peopleName"] + ""; + //string idNumber = item["idNumber"] + ""; + //sqlBuilder.AppendLine($"delete from p_gszxfjkctab where idnumber = '{idNumber}' and itemid = '{ysyf}';"); + //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(); + } + } + } + } + Invoke(new Action(() => + { + this.Close(); + })); + } + /// /// 个税申报 /// private void GSSBQuery() diff --git a/插件库/Lskj.QueryEssentialInfo/QueryApiUtil.cs b/插件库/Lskj.QueryEssentialInfo/QueryApiUtil.cs index 502a0aa..9dfa807 100644 --- a/插件库/Lskj.QueryEssentialInfo/QueryApiUtil.cs +++ b/插件库/Lskj.QueryEssentialInfo/QueryApiUtil.cs @@ -601,6 +601,123 @@ namespace Lskj.QueryEssentialInfo return code; } /// + /// 发起个人养老金查询 + /// + /// + /// + /// + public static string GetYLJFQ(out string resultRead, out string resultMsg) + { + string code = "-9999"; + resultRead = ""; + resultMsg = ""; + try + { + string url = "http://swgxs.poc.htjs.net:9019/v2/web/sbmk/personal-tax/api/v1/acquire/ylj/fqcx"; + HttpTools.setting("application/json", null, null, HttpTools.Encode.UTF8); + Dictionary headerDic = new Dictionary(); + DateTime utcNow = DateTime.UtcNow; + string date = utcNow.ToString("r", CultureInfo.InvariantCulture); + string host = "api.baiwangjs.com"; + string x_htjs_nonce = Guid.NewGuid().ToString().ToLower(); + string x_htjs_ua = "1.8.0_181 64 bit, sdk-ver=1.0.0"; + headerDic.Add("Date", DateTime.UtcNow.ToString()); + headerDic.Add("host", host); + headerDic.Add("x-htjs-nonce", x_htjs_nonce); + headerDic.Add("x-htjs-ua", x_htjs_ua); + headerDic.Add("Authorization", $"{GetAuthorization(date, host, x_htjs_nonce, x_htjs_ua)}"); + JObject pmsJObject = new JObject(); + pmsJObject.Add("busiTypeCode", mainRow["busiTypeCode"] + ""); + pmsJObject.Add("requestId", Guid.NewGuid().ToString().Replace("-", "").ToLower()); + pmsJObject.Add("accountId", "1"); + pmsJObject.Add("qysh", mainRow["qysh"] + ""); + pmsJObject.Add("operator", mainRow["operator"] + ""); + pmsJObject.Add("dknd", mainRow["dknd"] + ""); + JArray idNumberjArray = new JArray(); + foreach (DataRow detailRow in detailTab.Rows) + { + string addTag = detailRow["p_emp_addTag"] + ""; + if (!addTag.Equals("1")) + { + continue; + } + string idNumber = detailRow["idNumber"] + ""; + idNumberjArray.Add(idNumber); + } + pmsJObject.Add("idNumberList", idNumberjArray); + HttpWebResponse webResponse = HttpTools.Post(url, JsonConvert.SerializeObject(pmsJObject), null, headerDic, HttpTools.Method.POST); + resultRead = new StreamReader(webResponse.GetResponseStream(), Encoding.UTF8).ReadToEnd(); + if (webResponse != null && !string.IsNullOrEmpty(resultRead)) + { + JObject resultJObject = (JObject)JsonConvert.DeserializeObject(resultRead); + code = resultJObject["code"] + ""; + resultMsg = resultJObject["msg"] + ""; + } + } + catch (Exception) + { + throw; + } + return code; + } + /// + /// 获取个人养老金明细 + /// + public static string GetYLJMX(out string resultRead, out string resultMsg) + { + string code = "-9999"; + resultRead = ""; + resultMsg = ""; + try + { + string url = "http://swgxs.poc.htjs.net:9019/v2/web/sbmk/personal-tax/api/v1/acquire/ylj/list"; + HttpTools.setting("application/json", null, null, HttpTools.Encode.UTF8); + Dictionary headerDic = new Dictionary(); + DateTime utcNow = DateTime.UtcNow; + string date = utcNow.ToString("r", CultureInfo.InvariantCulture); + string host = "api.baiwangjs.com"; + string x_htjs_nonce = Guid.NewGuid().ToString().ToLower(); + string x_htjs_ua = "1.8.0_181 64 bit, sdk-ver=1.0.0"; + headerDic.Add("Date", DateTime.UtcNow.ToString()); + headerDic.Add("host", host); + headerDic.Add("x-htjs-nonce", x_htjs_nonce); + headerDic.Add("x-htjs-ua", x_htjs_ua); + headerDic.Add("Authorization", $"{GetAuthorization(date, host, x_htjs_nonce, x_htjs_ua)}"); + JObject pmsJObject = new JObject(); + pmsJObject.Add("busiTypeCode", mainRow["busiTypeCode"] + ""); + pmsJObject.Add("requestId", Guid.NewGuid().ToString().Replace("-", "").ToLower()); + pmsJObject.Add("accountId", "1"); + pmsJObject.Add("qysh", mainRow["qysh"] + ""); + pmsJObject.Add("operator", mainRow["operator"] + ""); + pmsJObject.Add("dknd", mainRow["dknd"] + ""); + JArray idNumberjArray = new JArray(); + foreach (DataRow detailRow in detailTab.Rows) + { + string addTag = detailRow["p_emp_addTag"] + ""; + if (!addTag.Equals("1")) + { + continue; + } + string idNumber = detailRow["idNumber"] + ""; + idNumberjArray.Add(idNumber); + } + pmsJObject.Add("idNumberList", idNumberjArray); + HttpWebResponse webResponse = HttpTools.Post(url, JsonConvert.SerializeObject(pmsJObject), null, headerDic, HttpTools.Method.POST); + resultRead = new StreamReader(webResponse.GetResponseStream(), Encoding.UTF8).ReadToEnd(); + if (webResponse != null && !string.IsNullOrEmpty(resultRead)) + { + JObject resultJObject = (JObject)JsonConvert.DeserializeObject(resultRead); + code = resultJObject["code"] + ""; + resultMsg = resultJObject["msg"] + ""; + } + } + catch (Exception) + { + throw; + } + return code; + } + /// /// 个税申报 /// ///