using System;
|
using System.Collections.Generic;
|
using System.Configuration;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using CommonHelper;
|
using RiskControl.NewService.Entity.TycDbEntity;
|
using RiskControl.NewService.Extension;
|
using RiskControl.NewService.QiChaCha;
|
using RiskControl.NewService.QiChaCha.TycEntity;
|
using SqlSugar;
|
|
namespace RiskControl.NewService.Service
|
{
|
/// <summary>
|
/// 天眼查
|
/// </summary>
|
public class TianYanChaService : DbContext
|
{
|
private TianYanChaApi _api = new TianYanChaApi();
|
private int _expiredDays;
|
private int _expiredDaysSeniorExecutive = 30;//天眼查获取董监高默认30天
|
private int _expiredDaysSlow = 180;//天眼查获取其他信息180天
|
|
public TianYanChaService()
|
{
|
//if (!int.TryParse(ConfigurationManager.AppSettings["TianyanchaExpiredDays"], out _expiredDays))
|
// _expiredDays = 10;
|
int.TryParse(ConfigurationManager.AppSettings["TianyanchaExpiredDays"], out _expiredDays);
|
}
|
|
/// <summary>
|
/// 质押明细列表
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetStockPledgeList(string name, int pageIndex, int pageSize)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycStockPledgeList>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycStockPledgeList>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycStockPledgeList>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycStockPledgeList>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycStockPledgeList>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycStockPledgeList>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetStockPledgeList(new StockPledgeListQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycStockPledgeList>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
var dbmodel = item.MapTo<TycStockPledgeList>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
dbmodel.TotalItems = qccResult.Result.total;
|
|
addList.Add(dbmodel);
|
}
|
// 如果使用缓存，则插入数据库
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 质押明细（配合GetStockPledgeList）
|
/// </summary>
|
/// <param name="businessId">内部id（businessId）</param>
|
/// <param name="companyId">公司id</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetStockPledgeDetail(string businessId, string companyId)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycStockPledgeDetail>().Where(a => a.BusinessId == businessId).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycStockPledgeDetail>().Where(a => a.BusinessId == businessId).FirstAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycStockPledgeDetail>().Where(a => a.BusinessId == businessId).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetStockPledgeDetail(new StockPledgeDetailQuery() { businessId = businessId, id = companyId });
|
if (qccResult.Error_code == "0")
|
{
|
var dbmodel = qccResult.Result.MapTo<TycStockPledgeDetail>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = dbmodel.PledgeIns;
|
//dbmodel.BusinessId = id;
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dbmodel).ExecuteCommandAsync();
|
|
result.Data = dbmodel;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
|
/// <summary>
|
/// 知识产权出质
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetPledgeReg(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycPledgeReg>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycPledgeReg>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycPledgeReg>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycPledgeReg>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycPledgeReg>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycPledgeReg>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetPledgeReg(new PledgeRegQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycPledgeReg>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
var dbmodel = item.MapTo<TycPledgeReg>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
dbmodel.TotalItems = qccResult.Result.total;
|
|
addList.Add(dbmodel);
|
}
|
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 限制消费令
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetConsumptionRestriction(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycConsumptionRestriction>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycConsumptionRestriction>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycConsumptionRestriction>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycConsumptionRestriction>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycConsumptionRestriction>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycConsumptionRestriction>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetConsumptionRestriction(new ConsumptionRestrictionQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycConsumptionRestriction>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
var dbmodel = item.MapTo<TycConsumptionRestriction>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
dbmodel.TotalItems = qccResult.Result.total;
|
|
addList.Add(dbmodel);
|
}
|
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 知识产权出质
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetEndCase(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycEndCase>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycEndCase>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycEndCase>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycEndCase>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycEndCase>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycEndCase>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetEndCase(new EndCaseQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycEndCase>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
var dbmodel = item.MapTo<TycEndCase>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
dbmodel.TotalItems = qccResult.Result.total;
|
|
addList.Add(dbmodel);
|
}
|
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 微信公众号
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetPublicWeChat(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycPublicWeChat>();
|
if (_expiredDaysSlow > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycPublicWeChat>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDaysSlow) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycPublicWeChat>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycPublicWeChat>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycPublicWeChat>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycPublicWeChat>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetPublicWeChat(new PublicWeChatQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycPublicWeChat>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
var dbmodel = item.MapTo<TycPublicWeChat>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
dbmodel.TotalItems = qccResult.Result.total;
|
|
addList.Add(dbmodel);
|
}
|
|
if (_expiredDaysSlow > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 股本结构
|
/// </summary>
|
/// <param name="name">公司</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetShareStructure(string name)
|
{
|
var result = new QccMsgData();
|
if (_expiredDaysSlow > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycShareStructure>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDaysSlow) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycShareStructure>().Where(a => a.CompanyName == name).OrderBy(a=>a.PubDate).ToListAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycShareStructure>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetShareStructure(new ShareStructureQuery() { name = name});
|
if (qccResult.Error_code == "0")
|
{
|
// 2.1 当前返回结果的股本信息
|
var addList = new List<TycShareStructure>();
|
for (var i = 0; i < qccResult.Result.dataList.Count; i++)
|
{
|
var item = qccResult.Result.dataList[i];
|
var dbmodel = item.MapTo<TycShareStructure>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
addList.Add(dbmodel);
|
}
|
// 2.2 查询其他时间节点的股本信息,第一条就是2.1查询所得
|
for (var tIndex = 1; tIndex < qccResult.Result.timeList.Count; tIndex++)
|
{
|
var time = qccResult.Result.timeList[tIndex];
|
var qccResult2 = _api.GetShareStructure(new ShareStructureQuery() {name = name,time = time});
|
for (var i = 0; i < qccResult2.Result.dataList.Count; i++)
|
{
|
var item = qccResult2.Result.dataList[i];
|
var dbmodel = item.MapTo<TycShareStructure>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
addList.Add(dbmodel);
|
}
|
}
|
|
if (_expiredDaysSlow > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
result.Data = addList;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 司法协助
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetJudicialList(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycJudicialList>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJudicialList>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycJudicialList>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycJudicialList>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycJudicialList>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJudicialList>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJudicialList(new JudicialListQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycJudicialList>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
var dbmodel = item.MapTo<TycJudicialList>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
dbmodel.TotalItems = qccResult.Result.total;
|
|
addList.Add(dbmodel);
|
}
|
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 司法协助详情
|
/// </summary>
|
/// <param name="assistanceId">司法协助id（assistanceId）</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetJudicialDetail(string assistanceId)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJudicialDetail>().Where(a => a.AssistanceId == assistanceId).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycJudicialDetail>().Where(a => a.AssistanceId == assistanceId).FirstAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJudicialDetail>().Where(a => a.AssistanceId == assistanceId).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJudicialDetail(new JudicialDetailQuery() { assistanceId = assistanceId });
|
if (qccResult.Error_code == "0")
|
{
|
var dbmodel = new TycJudicialDetail();
|
dbmodel.CreateTime = DateTime.Now;
|
//dbmodel.CompanyName = dbmodel.PledgeIns;
|
dbmodel.AssistanceId = assistanceId;
|
dbmodel.ResultData = qccResult.Result.ToJson();
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dbmodel).ExecuteCommandAsync();
|
|
result.Data = dbmodel;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 股东信息
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetHolderList(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycHolder>();
|
if (_expiredDaysSlow > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycHolder>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDaysSlow) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycHolder>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycHolder>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycHolder>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycHolder>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetHolderList(new HolderQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycHolder>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
var dbmodel = item.MapTo<TycHolder>();
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
dbmodel.TotalItems = qccResult.Result.total;
|
|
addList.Add(dbmodel);
|
}
|
|
if (_expiredDaysSlow > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 企业年报
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetTycAnnualreportList(string name, int pageIndex = 1, int pageSize = 100)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycAnnualreport>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycAnnualreport>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycAnnualreport>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycAnnualreport>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycAnnualreport>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycAnnualreport>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetAnnualreport(new TycAnnualreportQuery() { keyword = name});
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycAnnualreport>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
var dbmodel = item.MapTo<TycAnnualreport>();
|
dbmodel.ReportYear = item.BaseInfo.ReportYear;
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
dbmodel.TotalItems = qccResult.Result.total;
|
|
addList.Add(dbmodel);
|
}
|
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 高管信息
|
/// </summary>
|
/// <param name="name">公司名称</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetSeniorExecutive(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycSeniorExecutive>();
|
if (_expiredDaysSlow > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycSeniorExecutive>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDaysSlow) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycSeniorExecutive>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycSeniorExecutive>().Where(a => a.CompanyName == name)
|
.OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycSeniorExecutive>().Where(a => a.CompanyName == name).Where(a =>
|
a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize)
|
.OrderBy(a => a.ItemIndex).ToListAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycSeniorExecutive>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetSeniorExecutive(new TycSeniorExecutiveQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycSeniorExecutive>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
|
addList.Add(item);
|
}
|
|
if (_expiredDaysSlow > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 资产负债表
|
/// </summary>
|
/// <param name="name">公司</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetBalanceSheet(string name,string year)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0 && year!=null)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycBalanceSheet>().Where(a => a.CompanyName == name&&a.year==year).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycBalanceSheet>().Where(a => a.CompanyName == name && a.year == year).ToListAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycBalanceSheet>().Where(a => a.CompanyName == name && a.year == year).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetBalanceSheet(new TycBalanceSheetQuery() { keyword = name,year = year});
|
if (qccResult.Error_code == "0")
|
{
|
var dblist = qccResult.Result.corpBalanceSheet;
|
dblist.ForEach(dbmodel=>
|
{
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.year = year;
|
dbmodel.corpFinancialYears = qccResult.Result.corpFinancialYears;
|
});
|
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dblist).ExecuteCommandAsync();
|
|
result.Data = dblist;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 现金流量表
|
/// </summary>
|
/// <param name="name">公司</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetCashFlow(string name, string year)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycCashFlow>().Where(a => a.CompanyName == name && a.year == year).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycCashFlow>().Where(a => a.CompanyName == name && a.year == year).ToListAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycCashFlow>().Where(a => a.CompanyName == name && a.year == year).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetCashFlow(new TycCashFlowQuery() { keyword = name, year = year });
|
if (qccResult.Error_code == "0")
|
{
|
var dblist = qccResult.Result.corpCashFlow;
|
dblist.ForEach(dbmodel =>
|
{
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.year = year;
|
dbmodel.corpFinancialYears = qccResult.Result.corpFinancialYears;
|
});
|
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dblist).ExecuteCommandAsync();
|
|
result.Data = dblist;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 利润表
|
/// </summary>
|
/// <param name="name">公司</param>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetProfit(string name, string year)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycProfit>().Where(a => a.CompanyName == name && a.year == year).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycProfit>().Where(a => a.CompanyName == name && a.year == year).ToListAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycProfit>().Where(a => a.CompanyName == name && a.year == year).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetProfit(new TycProfitQuery() { keyword = name, year = year });
|
if (qccResult.Error_code == "0")
|
{
|
var dblist = qccResult.Result.corpProfit;
|
dblist.ForEach(dbmodel =>
|
{
|
dbmodel.CreateTime = DateTime.Now;
|
dbmodel.CompanyName = name;
|
dbmodel.year = year;
|
dbmodel.corpFinancialYears = qccResult.Result.corpFinancialYears;
|
});
|
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dblist).ExecuteCommandAsync();
|
|
result.Data = dblist;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 历史主要人员
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetMembers(string name)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycMembersReturn>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycMembersReturn>().Where(a => a.CompanyName == name).ToListAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycMembersReturn>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetMembers(new TycMembersQuery() { keyword = name });
|
if (qccResult.Error_code == "0")
|
{
|
var r = qccResult.Result;
|
r.CreateTime = DateTime.Now;
|
r.CompanyName = name;
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(r).ExecuteCommandAsync();
|
result.Data = r;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 历史经营异常
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetAbnormal(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycAbnormalReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycAbnormalReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.DBCreateTime, OrderByType.Desc).Select(a => a.DBCreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycAbnormalReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycAbnormalReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.DBCreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycAbnormalReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycAbnormalReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetAbnormal(new TycAbnormalQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycAbnormalReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.DBCreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 历史网站备案
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetIcp(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycIcpReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycIcpReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycIcpReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycIcpReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycIcpReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycIcpReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetIcp(new TycIcpQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycIcpReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 历史司法协助
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetLsJudicial(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycLsJudicialReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycLsJudicialReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycLsJudicialReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycLsJudicialReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycLsJudicialReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycLsJudicialReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetLsJudicial(new TycLsJudicialQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycLsJudicialReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 历史司法协助详情
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetLsJudicialDetail(string id)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycLsJudicialDetailReturn>().Where(a => a.Id == id).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycLsJudicialDetailReturn>().Where(a => a.Id == id).FirstAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycLsJudicialDetailReturn>().Where(a => a.Id == id).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetLsJudicialDetail(new TycLsJudicialDetailQuery() {businessId = id});
|
if (qccResult.Error_code == "0")
|
{
|
var dblist = qccResult.Result;
|
dblist.CreateTime = DateTime.Now;
|
dblist.Id = id;
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dblist).ExecuteCommandAsync();
|
result.Data = dblist;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 税务评级
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetTaxCredit(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycTaxCreditReturnItem>();
|
if (_expiredDaysSlow > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycTaxCreditReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDaysSlow) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycTaxCreditReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycTaxCreditReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycTaxCreditReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycTaxCreditReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetTaxCredit(new TycTaxCreditQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycTaxCreditReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDaysSlow > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 双随机抽查
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetDoubleRandomCheck(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycDoubleRandomCheckReturnItem>();
|
if (_expiredDaysSlow > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycDoubleRandomCheckReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDaysSlow) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycDoubleRandomCheckReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycDoubleRandomCheckReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycDoubleRandomCheckReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycDoubleRandomCheckReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetDoubleRandomCheck(new TycDoubleRandomCheckQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycDoubleRandomCheckReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDaysSlow > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 一般纳税人
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetTaxpayer(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycTaxpayerReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycTaxpayerReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycTaxpayerReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycTaxpayerReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycTaxpayerReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycTaxpayerReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetTaxpayer(new TycTaxpayerQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycTaxpayerReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 双随机抽查详情
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetDoubleRandomCheckDetail(string id, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycDoubleRandomCheckDetailReturnItem>();
|
if (_expiredDaysSlow > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycDoubleRandomCheckDetailReturnItem>().Where(a => a.businessId == id).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDaysSlow) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycDoubleRandomCheckDetailReturnItem>().Where(a => a.businessId == id).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycDoubleRandomCheckDetailReturnItem>().Where(a => a.businessId == id).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycDoubleRandomCheckDetailReturnItem>().Where(a => a.businessId == id).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycDoubleRandomCheckDetailReturnItem>().Where(a => a.businessId == id).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetDoubleRandomCheckDetail(new TycDoubleRandomCheckDetailQuery() { businessId = id, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycDoubleRandomCheckDetailReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.businessId = id;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDaysSlow > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
|
/// <summary>
|
/// 历史主要人员
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetBaseinfoV3(string name)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycBaseinfoV3>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycBaseinfoV3>().Where(a => a.CompanyName == name).FirstAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycBaseinfoV3>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetBaseinfoV3(new TycMembersQuery() { keyword = name });
|
if (qccResult.Error_code == "0")
|
{
|
var r = qccResult.Result;
|
r.CreateTime = DateTime.Now;
|
r.CompanyName = name;
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(r).ExecuteCommandAsync();
|
result.Data = r;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 搜索
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetSearch2(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycSearch2>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycSearch2>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycSearch2>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycSearch2>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycSearch2>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycSearch2>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetSearch2(new TycSearch2Query() { word = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycSearch2>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 送达公告
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetSendAnnouncement(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycSendAnnouncementReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycSendAnnouncementReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycSendAnnouncementReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycSendAnnouncementReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycSendAnnouncementReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycSendAnnouncementReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetSendAnnouncement(new TycSendAnnouncementQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycSendAnnouncementReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 立案信息
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetCourtRegister(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycCourtRegisterReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycCourtRegisterReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycCourtRegisterReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycCourtRegisterReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycCourtRegisterReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycCourtRegisterReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetCourtRegister(new TycCourtRegisterQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycCourtRegisterReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 开庭公告
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetKtannouncement(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycKtannouncementReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycKtannouncementReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycKtannouncementReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycKtannouncementReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycKtannouncementReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycKtannouncementReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetKtannouncement(new TycKtannouncementQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycKtannouncementReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 历史开庭公告
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetAnnouncement(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycAnnouncementReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycAnnouncementReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycAnnouncementReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycAnnouncementReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycAnnouncementReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycAnnouncementReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetAnnouncement(new TycAnnouncementQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycAnnouncementReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 法院公告
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetCourtAnnouncement(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycCourtAnnouncementReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycCourtAnnouncementReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycCourtAnnouncementReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycCourtAnnouncementReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycCourtAnnouncementReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycCourtAnnouncementReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetCourtAnnouncement(new TycCourtAnnouncementQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycCourtAnnouncementReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 历史法院公告
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetHiCourt(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycHiCourtReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycHiCourtReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycHiCourtReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycHiCourtReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycHiCourtReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycHiCourtReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetHiCourt(new TycHiCourtQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycHiCourtReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 法律诉讼
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetJrLawSuit(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycJrLawSuitReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJrLawSuitReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycJrLawSuitReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycJrLawSuitReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycJrLawSuitReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJrLawSuitReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJrLawSuit(new TycJrLawSuitQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycJrLawSuitReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetJrLawSuitDetail(string uuid)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJrLawSuitDetailReturn>().Where(a => a.uuid == uuid).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycJrLawSuitDetailReturn>().Where(a => a.uuid == uuid).FirstAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJrLawSuitDetailReturn>().Where(a => a.uuid == uuid).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJrLawSuitDetail(new TycJrLawSuitDetailQuery() { uuid = uuid });
|
if (qccResult.Error_code == "0")
|
{
|
var dblist = qccResult.Result;
|
dblist.CreateTime = DateTime.Now;
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dblist).ExecuteCommandAsync();
|
result.Data = dblist;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetHiJudicialDetail(string businessId)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycHiJudicialDetailReturn>().Where(a => a.businessId == businessId).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycHiJudicialDetailReturn>().Where(a => a.businessId == businessId).FirstAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycHiJudicialDetailReturn>().Where(a => a.businessId == businessId).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetHiJudicialDetail(new TycHiJudicialDetailQuery() { businessId = businessId });
|
if (qccResult.Error_code == "0")
|
{
|
var dblist = qccResult.Result;
|
dblist.CreateTime = DateTime.Now;
|
dblist.businessId = businessId;
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dblist).ExecuteCommandAsync();
|
result.Data = dblist;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
/// <summary>
|
/// 历史法律诉讼
|
/// </summary>
|
/// <returns></returns>
|
public async Task<QccMsgData> GetHiLawSuit(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycHiLawSuitReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycHiLawSuitReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycHiLawSuitReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycHiLawSuitReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycHiLawSuitReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycHiLawSuitReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetHiLawSuit(new TycHiLawSuitQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycHiLawSuitReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetJudicial(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycJudicialReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJudicialReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycJudicialReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycJudicialReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycJudicialReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJudicialReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJudicial(new TycJudicialQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycJudicialReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetHiJudicial(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycHiJudicialReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycHiJudicialReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycHiJudicialReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycHiJudicialReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycHiJudicialReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycHiJudicialReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetHiJudicial(new TycHiJudicialQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycHiJudicialReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetJrBankruptcy(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycJrBankruptcyReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJrBankruptcyReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycJrBankruptcyReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycJrBankruptcyReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycJrBankruptcyReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJrBankruptcyReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJrBankruptcy(new TycJrBankruptcyQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycJrBankruptcyReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
item.gid = qccResult.Result.gid;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetJrBankruptcyDetail(string gid,string uuid)
|
{
|
var result = new QccMsgData();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJrBankruptcyDetailReturn>().Where(a => a.gid == gid && a.uuid == uuid).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime)
|
.FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var dbmodel = await RiskControlRRDb.Queryable<TycJrBankruptcyDetailReturn>().Where(a => a.gid == gid && a.uuid == uuid).FirstAsync();
|
result.Data = dbmodel;
|
return result;
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJrBankruptcyDetailReturn>().Where(a => a.gid == gid && a.uuid == uuid).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJrBankruptcyDetail(new TycJrBankruptcyDetailQuery() { gid = gid,uuid = uuid});
|
if (qccResult.Error_code == "0")
|
{
|
var dblist = qccResult.Result;
|
dblist.CreateTime = DateTime.Now;
|
dblist.gid = gid;
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(dblist).ExecuteCommandAsync();
|
result.Data = dblist;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetTycJrZhixinginfo(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycJrZhixinginfoReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJrZhixinginfoReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycJrZhixinginfoReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycJrZhixinginfoReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycJrZhixinginfoReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJrZhixinginfoReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJrZhixinginfo(new TycJrZhixinginfoQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycJrZhixinginfoReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetJrDishonest(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycJrDishonestReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJrDishonestReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycJrDishonestReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycJrDishonestReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycJrDishonestReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJrDishonestReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJrDishonest(new TycJrDishonestQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycJrDishonestReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetJrJudicialCase(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycJrJudicialCaseReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycJrJudicialCaseReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycJrJudicialCaseReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycJrJudicialCaseReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycJrJudicialCaseReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycJrJudicialCaseReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetJrJudicialCase(new TycJrJudicialCaseQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycJrJudicialCaseReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
public async Task<QccMsgData> GetIcChangeinfo(string name, int pageIndex = 1, int pageSize = 10)
|
{
|
var result = new QccMsgData();
|
var resultPage = new Page<TycIcChangeinfoReturnItem>();
|
if (_expiredDays > 0)
|
{
|
// 1.数据库是存在
|
var createTime = await RiskControlRRDb.Queryable<TycIcChangeinfoReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.CreateTime).FirstAsync();
|
if (createTime.AddDays(_expiredDays) >= DateTime.Now)
|
{
|
var query = RiskControlRRDb.Queryable<TycIcChangeinfoReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize);
|
var dbcount = await query.CountAsync();
|
var totalcount = await RiskControlRRDb.Queryable<TycIcChangeinfoReturnItem>().Where(a => a.CompanyName == name).OrderBy(a => a.CreateTime, OrderByType.Desc).Select(a => a.TotalItems).FirstAsync();
|
// 如果条数相同，则取数据库的。如果条数不同，则重新请求
|
if (dbcount == pageSize || dbcount == totalcount || dbcount == totalcount - pageSize * (pageIndex - 1))
|
{
|
var dbList = await RiskControlRRDb.Queryable<TycIcChangeinfoReturnItem>().Where(a => a.CompanyName == name).Where(a => a.ItemIndex > (pageIndex - 1) * pageSize && a.ItemIndex <= pageIndex * pageSize).OrderBy(a => a.ItemIndex).ToListAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = totalcount;
|
resultPage.Items = dbList;
|
result.Data = resultPage;
|
return result;
|
}
|
// 如果请求页 > 总条数,说明没有数据了
|
var dbTotalPages = totalcount != 0
|
? (totalcount % pageSize) == 0 ? (totalcount / pageSize) : (totalcount / pageSize) + 1
|
: 0;
|
if (dbTotalPages < pageIndex)
|
{
|
result.Message = "查询无结果";
|
return result;
|
}
|
}
|
// 2.不存在或过期
|
await RiskControlRRDb.Deleteable<TycIcChangeinfoReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
|
}
|
var qccResult = _api.GetIcChangeinfo(new TycIcChangeinfoQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
|
if (qccResult.Error_code == "0")
|
{
|
var addList = new List<TycIcChangeinfoReturnItem>();
|
for (var i = 0; i < qccResult.Result.items.Count; i++)
|
{
|
var item = qccResult.Result.items[i];
|
item.CreateTime = DateTime.Now;
|
item.CompanyName = name;
|
item.ItemIndex = (pageIndex - 1) * pageSize + i + 1;
|
item.TotalItems = qccResult.Result.total;
|
addList.Add(item);
|
}
|
if (_expiredDays > 0) await RiskControlRRDb.Insertable(addList).ExecuteCommandAsync();
|
resultPage.CurrentPage = pageIndex;
|
resultPage.PageSize = pageSize;
|
resultPage.TotalItems = qccResult.Result.total;
|
resultPage.Items = addList;
|
result.Data = resultPage;
|
return result;
|
}
|
else
|
{
|
result.Message = qccResult.Reason;
|
return result;
|
}
|
}
|
|
}
|
}
|
