Commit ac7a95ce by guanzhenshan

增加获取库龄接口

parent f472f299
using System;
using System.Collections.Generic;
using System.Text;
namespace Bailun.DC.Models.Api
{
/// <summary>
/// 请求获取sku+仓库的库龄数据
/// </summary>
public class requestSkuAges
{
public List<string> skus { get; set; }
public string warehouse_code { get; set; }
}
}
...@@ -1239,6 +1239,31 @@ namespace Bailun.DC.Services ...@@ -1239,6 +1239,31 @@ namespace Bailun.DC.Services
} }
} }
/// <summary>
/// 根据sku+仓库获取库龄信息
/// </summary>
/// <param name="skus">sku集合</param>
/// <param name="warehousecode">仓库编码</param>
/// <returns></returns>
public List<dc_mid_stock_age> GetSkuStockAge(List<string> skus, string warehousecode)
{
var sql = $"select * from dc_mid_stock_age where warehouse_code='{warehousecode}' and bailun_sku in ('{string.Join("','",skus)}')";
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString_read))
{
if(cn.State== ConnectionState.Closed)
{
cn.Open();
}
var list = cn.Query<dc_mid_stock_age>(sql).AsList();
return list;
}
}
#endregion #endregion
#region 进销存 #region 进销存
......
...@@ -2,6 +2,7 @@ ...@@ -2,6 +2,7 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Bailun.DC.Models.Api;
using Bailun.DC.Models.Orders; using Bailun.DC.Models.Orders;
using Microsoft.AspNetCore.Hosting; using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Http;
...@@ -1073,6 +1074,61 @@ namespace Bailun.DC.Web.Controllers ...@@ -1073,6 +1074,61 @@ namespace Bailun.DC.Web.Controllers
} }
/// <summary>
/// 获取同仓库的sku库龄数据
/// </summary>
/// <param name="sku"></param>
/// <param name="warehouse"></param>
/// <returns></returns>
[HttpPost]
public JsonResult SkuAges([FromBody]requestSkuAges m)
{
if(m.skus.Count==0)
{
return Json(new {
success = false,
msg = "sku不能为空"
});
}
if (string.IsNullOrEmpty(m.warehouse_code))
{
return Json(new
{
success = false,
msg = "仓库编码不能为空"
});
}
try
{
var obj = new Services.InventoryServices().GetSkuStockAge(m.skus, m.warehouse_code);
return Json(new
{
success = true,
msg = "",
data = obj.GroupBy(a=>a.bailun_sku).Select(b=>new {
bailun_sku= b.Key,
list = b.Select(o=>new {
o.bailun_sku,
o.warehouse_code,
o.stock,
o.createtime,
o.basisdata_json
})
})
});
}
catch (Exception ex)
{
return Json(new {
success = false,
msg = ex.Message
});
}
}
//public JsonResult TestInsertBuyer() //public JsonResult TestInsertBuyer()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment