领星海外仓

This commit is contained in:
18942506660
2024-11-04 16:06:32 +08:00
parent ec0be490e1
commit 94040ba63d
3 changed files with 21 additions and 1 deletions

View File

@@ -20,5 +20,10 @@ namespace WMS.Web.Core.Dto.LingXing
/// </summary> /// </summary>
[JsonProperty("length")] [JsonProperty("length")]
public int length { get; set; } = 800; public int length { get; set; } = 800;
/// <summary>
/// 海外仓
/// </summary>
[JsonProperty("type")]
public int type { get; set; } = 1;
} }
} }

View File

@@ -77,6 +77,8 @@ namespace WMS.Web.Domain.Services.Public
if (stock_list != null && stock_list.Count > 0) if (stock_list != null && stock_list.Count > 0)
return Result<List<LingXingStockResponse>>.ReSuccess(stock_list); return Result<List<LingXingStockResponse>>.ReSuccess(stock_list);
List<LingXingStockResponse> list = new List<LingXingStockResponse>();
//默认获取本地仓库 如果需要海外仓 另外需传参数type //默认获取本地仓库 如果需要海外仓 另外需传参数type
var request = new LingXingRequest(); var request = new LingXingRequest();
var resUrl = await GetStr<LingXingRequest>("/erp/sc/data/local_inventory/warehouse", request); var resUrl = await GetStr<LingXingRequest>("/erp/sc/data/local_inventory/warehouse", request);
@@ -85,7 +87,20 @@ namespace WMS.Web.Domain.Services.Public
var res = await _httpClientService.PostAsync<LingXingResponse>(resUrl.Data, JsonConvert.SerializeObject(request), null); var res = await _httpClientService.PostAsync<LingXingResponse>(resUrl.Data, JsonConvert.SerializeObject(request), null);
if (res.Code != 0) return Result<List<LingXingStockResponse>>.ReFailure(ResultCodes.LingXingDataError); if (res.Code != 0) return Result<List<LingXingStockResponse>>.ReFailure(ResultCodes.LingXingDataError);
var list = JsonConvert.DeserializeObject<List<LingXingStockResponse>>(res.Data.ToString()); list.AddRange(JsonConvert.DeserializeObject<List<LingXingStockResponse>>(res.Data.ToString()));
//海外仓
request = new LingXingRequest();
request.type = 3;
resUrl = await GetStr<LingXingRequest>("/erp/sc/data/local_inventory/warehouse", request);
if (!resUrl.IsSuccess) return Result<List<LingXingStockResponse>>.ReFailure(ResultCodes.LingXingUrlError);
res = await _httpClientService.PostAsync<LingXingResponse>(resUrl.Data, JsonConvert.SerializeObject(request), null);
if (res.Code != 0) return Result<List<LingXingStockResponse>>.ReFailure(ResultCodes.LingXingDataError);
list.AddRange(JsonConvert.DeserializeObject<List<LingXingStockResponse>>(res.Data.ToString()));
//设置缓存 //设置缓存
_memoryCache.Set("lingxing_stock", list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromMinutes(DateTimeUtil.GetTotalMinutesTimeSpan()))); _memoryCache.Set("lingxing_stock", list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromMinutes(DateTimeUtil.GetTotalMinutesTimeSpan())));