cyf
536 lines
30 KiB
C#
536 lines
30 KiB
C#
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;
|
|
}
|
|
else
|
|
{
|
|
Thread.Sleep(1000);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
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);
|
|
JObject yljfqJObject = JsonConvert.DeserializeObject(yljfqResult) as JObject;
|
|
string partRespCode = yljfqJObject.ContainsKey("partRespCode") ? yljfqJObject["partRespCode"] + "" : "0";
|
|
if (!yljfqCode.Equals("0") || !partRespCode.Equals("0"))
|
|
{
|
|
for (int i = 0; i < 5; i++)
|
|
{
|
|
yljfqResult = "";
|
|
yljfqMsg = "";
|
|
yljfqCode = QueryApiUtil.GetYLJFQ(out yljfqResult, out yljfqMsg);
|
|
partRespCode = yljfqJObject.ContainsKey("partRespCode") ? yljfqJObject["partRespCode"] + "" : "0";
|
|
if (yljfqCode.Equals("0") || partRespCode.Equals("0"))
|
|
{
|
|
break;
|
|
}
|
|
else
|
|
{
|
|
Thread.Sleep(1000);
|
|
}
|
|
}
|
|
}
|
|
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"))
|
|
{
|
|
|