This commit is contained in:
tongfei
2023-11-25 14:29:47 +08:00

View File

@@ -1012,31 +1012,42 @@ namespace WMS.Web.Domain.Services.Public
param.Limit = 10000; param.Limit = 10000;
//查询条件:备注其中的条件值以金蝶的值为准!!! //查询条件:备注其中的条件值以金蝶的值为准!!!
param.FilterString = ""; param.FilterString = "";
var list = new List<ErpCustomerDto>();
//备注因为供应商数据不是很多就不能和获取物料一样循环获取组织这里就获取10000条数据就行了 //备注因为供应商数据不是很多就不能和获取物料一样循环获取组织这里就获取10000条数据就行了
var beginTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"); var beginTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
_logger.LogInformation($"供应商拉取-开始时间:{beginTime}"); _logger.LogInformation($"供应商拉取-开始时间:{beginTime}");
int skip = 0;
//4.参数json化 //4.参数json化
query.Data = JsonConvert.SerializeObject(param); while (true)
var json = JsonConvert.SerializeObject(query); {
//4.1.页码页码按照金蝶的要求从0开始
param.StartRow = (Convert.ToInt32(skip) * param.Limit);
//5.请求查询接口并返回数据 query.Data = JsonConvert.SerializeObject(param);
var result_json = await _client.ExecuteBillQueryAsync(json); var json = JsonConvert.SerializeObject(query);
var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);
//5.请求查询接口并返回数据
var result_json = await _client.ExecuteBillQueryAsync(json);
var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);
if (result == null || result.Count == 0)
break;
//6.拼装
foreach (var item in result)
{
var lis = new ErpCustomerDto();
lis.Id = int.Parse(item[0]);
lis.Number = item[1];
lis.Name = item[2];
list.Add(lis);
}
//4.6页面的叠加
skip++;
}
var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"); var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
_logger.LogInformation($"供应商拉取-结束时间:{endTime}"); _logger.LogInformation($"供应商拉取-结束时间:{endTime}");
//6.拼装
var list = new List<ErpCustomerDto>();
foreach (var item in result)
{
var lis = new ErpCustomerDto();
lis.Id = int.Parse(item[0]);
lis.Number = item[1];
lis.Name = item[2];
list.Add(lis);
}
//5.供应商集合进行缓存 //5.供应商集合进行缓存
_memoryCache.Set(cache_key, list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromHours(12))); _memoryCache.Set(cache_key, list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromHours(12)));
_logger.LogInformation($"供应商拉取-总条数:{list.Count}"); _logger.LogInformation($"供应商拉取-总条数:{list.Count}");