From cb77d4de4602586a140a0872705da2dac315f929 Mon Sep 17 00:00:00 2001
From: WX <wx036@qq.com>
Date: 星期六, 10 六月 2023 23:36:49 +0800
Subject: [PATCH] 9个天眼查接口 11-2=9
---
RiskControl.NewService/Service/TianYanChaService.cs | 453 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 453 insertions(+), 0 deletions(-)
diff --git a/RiskControl.NewService/Service/TianYanChaService.cs b/RiskControl.NewService/Service/TianYanChaService.cs
index e1f9ac6..7fd51a8 100644
--- a/RiskControl.NewService/Service/TianYanChaService.cs
+++ b/RiskControl.NewService/Service/TianYanChaService.cs
@@ -1,6 +1,7 @@
锘縰sing System;
using System.Collections.Generic;
using System.Configuration;
+using System.Diagnostics;
using System.Linq;
using System.Threading.Tasks;
using CommonHelper;
@@ -2831,5 +2832,457 @@
}
}
+ public async Task<QccMsgData> GetInverst(string name, int pageIndex = 1, int pageSize = 10)
+ {
+ var result = new QccMsgData();
+ var resultPage = new Page<TycInverstReturnItem>();
+ if (_expiredDays > 0)
+ {
+ // 1.鏁版嵁搴撴槸瀛樺湪
+ var createTime = await RiskControlRRDb.Queryable<TycInverstReturnItem>().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<TycInverstReturnItem>().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<TycInverstReturnItem>().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<TycInverstReturnItem>().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<TycInverstReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
+ }
+ var qccResult = _api.GetInverst(new TycInverstQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
+ if (qccResult.Error_code == "0")
+ {
+ var addList = new List<TycInverstReturnItem>();
+ 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> GetBranch(string name, int pageIndex = 1, int pageSize = 10)
+ {
+ var result = new QccMsgData();
+ var resultPage = new Page<TycBranchReturnItem>();
+ if (_expiredDays > 0)
+ {
+ // 1.鏁版嵁搴撴槸瀛樺湪
+ var createTime = await RiskControlRRDb.Queryable<TycBranchReturnItem>().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<TycBranchReturnItem>().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<TycBranchReturnItem>().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<TycBranchReturnItem>().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<TycBranchReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
+ }
+ var qccResult = _api.GetBranch(new TycBranchQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
+ if (qccResult.Error_code == "0")
+ {
+ var addList = new List<TycBranchReturnItem>();
+ 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> GetHumanCompanyholding(string name, int pageIndex = 1, int pageSize = 10)
+ {
+ var result = new QccMsgData();
+ var resultPage = new Page<TycHumanCompanyholdingReturnItem>();
+ if (_expiredDays > 0)
+ {
+ // 1.鏁版嵁搴撴槸瀛樺湪
+ var createTime = await RiskControlRRDb.Queryable<TycHumanCompanyholdingReturnItem>().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<TycHumanCompanyholdingReturnItem>().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<TycHumanCompanyholdingReturnItem>().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<TycHumanCompanyholdingReturnItem>().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<TycHumanCompanyholdingReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
+ }
+ var qccResult = _api.GetHumanCompanyholding(new TycHumanCompanyholdingQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
+ if (qccResult.Error_code == "0")
+ {
+ var addList = new List<TycHumanCompanyholdingReturnItem>();
+ 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> GetParentCompany(string name)
+ {
+ var result = new QccMsgData();
+ if (_expiredDays > 0)
+ {
+ // 1.鏁版嵁搴撴槸瀛樺湪
+ var createTime = await RiskControlRRDb.Queryable<TycParentCompanyReturn>().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<TycParentCompanyReturn>().Where(a => a.CompanyName == name).ToListAsync();
+ result.Data = dbmodel;
+ return result;
+ }
+ // 2.涓嶅瓨鍦ㄦ垨杩囨湡
+ await RiskControlRRDb.Deleteable<TycParentCompanyReturn>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
+ }
+ var qccResult = _api.GetParentCompany(new TycParentCompanyQuery() { 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;
+ }
+ }
+ public async Task<QccMsgData> GetActualControl(string name)
+ {
+ var result = new QccMsgData();
+ if (_expiredDays > 0)
+ {
+ // 1.鏁版嵁搴撴槸瀛樺湪
+ var createTime = await RiskControlRRDb.Queryable<TycActualControlReturn>().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<TycActualControlReturn>().Where(a => a.CompanyName == name).ToListAsync();
+ result.Data = dbmodel;
+ return result;
+ }
+ // 2.涓嶅瓨鍦ㄦ垨杩囨湡
+ await RiskControlRRDb.Deleteable<TycActualControlReturn>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
+ }
+ var qccResult = _api.GetActualControl(new TycActualControlQuery() { keyword = name });
+ if (qccResult.Error_code == "0")
+ {
+ var r = qccResult;
+ r.CreateTime = DateTime.Now;
+ r.CompanyName = name;
+ if (_expiredDays > 0) await RiskControlRRDb.Insertable((TycActualControlReturn)r).ExecuteCommandAsync();
+ result.Data = r;
+ return result;
+ }
+ else
+ {
+ result.Message = qccResult.Reason;
+ return result;
+ }
+ }
+ public async Task<QccMsgData> GetBids(string name, int pageIndex = 1, int pageSize = 10)
+ {
+ var result = new QccMsgData();
+ var resultPage = new Page<TycBidsReturnItem>();
+ if (_expiredDays > 0)
+ {
+ // 1.鏁版嵁搴撴槸瀛樺湪
+ var createTime = await RiskControlRRDb.Queryable<TycBidsReturnItem>().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<TycBidsReturnItem>().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<TycBidsReturnItem>().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<TycBidsReturnItem>().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<TycBidsReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
+ }
+ var qccResult = _api.GetBids(new TycBidsQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
+ if (qccResult.Error_code == "0")
+ {
+ var addList = new List<TycBidsReturnItem>();
+ 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> GetPsNews(string name, int pageIndex = 1, int pageSize = 10)
+ {
+ var result = new QccMsgData();
+ var resultPage = new Page<TycPsNewsReturnItem>();
+ if (_expiredDays > 0)
+ {
+ // 1.鏁版嵁搴撴槸瀛樺湪
+ var createTime = await RiskControlRRDb.Queryable<TycPsNewsReturnItem>().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<TycPsNewsReturnItem>().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<TycPsNewsReturnItem>().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<TycPsNewsReturnItem>().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<TycPsNewsReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
+ }
+ var qccResult = _api.GetPsNews(new TycPsNewsQuery() { name = name, pageNum = pageIndex, pageSize = pageSize });
+ if (qccResult.Error_code == "0")
+ {
+ var addList = new List<TycPsNewsReturnItem>();
+ 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> GetStockList(string name, int pageIndex = 1, int pageSize = 10)
+ {
+ var result = new QccMsgData();
+ var resultPage = new Page<TycStockListReturnItem>();
+ if (_expiredDays > 0)
+ {
+ // 1.鏁版嵁搴撴槸瀛樺湪
+ var createTime = await RiskControlRRDb.Queryable<TycStockListReturnItem>().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<TycStockListReturnItem>().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<TycStockListReturnItem>().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<TycStockListReturnItem>().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<TycStockListReturnItem>().Where(a => a.CompanyName == name).ExecuteCommandAsync();
+ }
+ var qccResult = _api.GetStockList(new TycStockListQuery() { keyword = name, pageNum = pageIndex, pageSize = pageSize });
+ if (qccResult.Error_code == "0")
+ {
+ var addList = new List<TycStockListReturnItem>();
+ 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;
+ }
+ }
+
}
}
\ No newline at end of file
--
Gitblit v1.8.0