using Newtonsoft.Json;
|
using Rhea.Common;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using Tiger.IBusiness;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using Tiger.Model;
|
|
namespace Tiger.Business.WMS
|
{
|
public partial class BS : IBS
|
{
|
/// <summary>
|
/// 获取所有仓库机构列表
|
/// </summary>
|
/// <param name="name"></param>
|
/// <param name="status"></param>
|
/// <returns></returns>
|
public async Task<string> GetHouseModel(string name, string status)
|
{
|
var data = new List<OrgItemH>();
|
V_WH_TREE func = null;
|
if (!string.IsNullOrEmpty(name))
|
{
|
func = Biz.Db.Queryable<V_WH_TREE>().Where(x => x.NAME == name).First();
|
}
|
var items = await Biz.Db.Queryable<V_WH_TREE>()
|
.Where(q => q.TYPE != "Location")
|
.OrderBy(x => x.CODE)
|
.Distinct().ToListAsync();
|
//没有查询的时候
|
if (func == null)
|
{
|
List<V_WH_TREE> entities = items.OrderBy(x => x.CODE).ToList().FindAll(t => t.PARENT_ID.IsNullOrEmpty());
|
foreach (var item in entities)
|
{
|
OrgItemH houseItem = new();
|
houseItem.id = item.TYPE.ToString().FirstOrDefault() + item.ID;
|
houseItem.houseCode = item.CODE;
|
houseItem.houseName = item.AUTH_ORG + ":" + item.CODE + "(" + item.NAME + ")";
|
houseItem.PARENT_HOUSE = item.PARENT_ID;
|
houseItem.createTime = DateTime.Now.ToString("yyyy-MM-dd mm:dd:ss");
|
houseItem.houseType = item.TYPE;
|
//hosueItem.remark = item.REMARK;
|
//hosueItem.orderNo = item.SEQ_NO;
|
houseItem.children = new();
|
if (item.TYPE != "Shelf") GetOrgItem(items, item.ID, ref houseItem);
|
data.Add(houseItem);
|
}
|
}
|
//有查询条件的时候
|
else
|
{
|
|
}
|
|
//转换Json时，去除值为null的属性
|
var jsonSetting = new JsonSerializerSettings { NullValueHandling = NullValueHandling.Ignore };
|
var json = JsonConvert.SerializeObject(data, Formatting.Indented, jsonSetting);
|
return json;
|
}
|
|
/// <summary>
|
/// 递归返回组织机构
|
/// </summary>
|
/// <param name="data"></param>
|
/// <param name="parent"></param>
|
/// <param name="pOrgItem"></param>
|
private static void GetOrgItem(List<V_WH_TREE> data, string parent, ref OrgItemH pOrgItem)
|
{
|
List<V_WH_TREE> entities = data.OrderBy(x => x.CODE).ToList().FindAll(t => t.PARENT_ID == parent).Distinct().ToList();
|
if (entities.Count > 0)
|
{
|
foreach (var item in entities)
|
{
|
OrgItemH houseItem = new();
|
houseItem.id = item.TYPE.ToString().FirstOrDefault() + item.ID;
|
houseItem.houseCode = item.CODE;
|
houseItem.houseName = item.AUTH_ORG + ":" + item.CODE + "(" + item.NAME + ")";
|
houseItem.PARENT_HOUSE = item.PARENT_ID;
|
houseItem.createTime = DateTime.Now.ToString("yyyy-MM-dd mm:dd:ss");
|
houseItem.houseType = item.TYPE;
|
//houseItem.remark = item.REMARK;
|
//houseItem.orderNo = item.SEQ_NO;
|
houseItem.children = new();
|
if (item.TYPE != "Shelf") GetOrgItem(data, item.ID, ref houseItem);
|
pOrgItem.children.Add(houseItem);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 获取所有仓库机构列表
|
/// </summary>
|
/// <param name="listItem"></param>
|
/// <returns></returns>
|
public async Task<string> GetHouseModelOrg(HouseListItem listItem)
|
{
|
var data = new List<OrgItemH>();
|
V_WH_TREE func = null;
|
var items = await Biz.Db.Queryable<V_WH_TREE>()
|
.Where(q => q.TYPE != "Location" && q.AUTH_ORG == listItem.AUTH_ORG)
|
.OrderBy(x => x.CODE)
|
.Distinct().ToListAsync();
|
//没有查询的时候
|
if (func == null)
|
{
|
List<V_WH_TREE> entities = items.OrderBy(x => x.CODE).ToList().FindAll(t => t.PARENT_ID.IsNullOrEmpty());
|
foreach (var item in entities)
|
{
|
OrgItemH houseItem = new();
|
houseItem.id = item.ID;
|
houseItem.houseCode = item.CODE;
|
houseItem.houseName = item.AUTH_ORG + ":" + item.CODE + "(" + item.NAME + ")";
|
houseItem.PARENT_HOUSE = item.PARENT_ID;
|
houseItem.createTime = DateTime.Now.ToString("yyyy-MM-dd mm:dd:ss");
|
houseItem.houseType = item.TYPE;
|
//hosueItem.remark = item.REMARK;
|
//hosueItem.orderNo = item.SEQ_NO;
|
houseItem.children = new();
|
if (item.TYPE != "Shelf") GetOrgItemOrg(items, item.ID, ref houseItem);
|
data.Add(houseItem);
|
}
|
}
|
//有查询条件的时候
|
else
|
{
|
|
}
|
|
//转换Json时，去除值为null的属性
|
var jsonSetting = new JsonSerializerSettings { NullValueHandling = NullValueHandling.Ignore };
|
var json = JsonConvert.SerializeObject(data, Formatting.Indented, jsonSetting);
|
return json;
|
}
|
|
/// <summary>
|
/// 递归返回组织机构
|
/// </summary>
|
/// <param name="data"></param>
|
/// <param name="parent"></param>
|
/// <param name="pOrgItem"></param>
|
private static void GetOrgItemOrg(List<V_WH_TREE> data, string parent, ref OrgItemH pOrgItem)
|
{
|
List<V_WH_TREE> entities = data.OrderBy(x => x.CODE).ToList().FindAll(t => t.PARENT_ID == parent).Distinct().ToList();
|
if (entities.Count > 0)
|
{
|
foreach (var item in entities)
|
{
|
OrgItemH houseItem = new();
|
houseItem.id = item.ID;
|
houseItem.houseCode = item.CODE;
|
houseItem.houseName = item.AUTH_ORG + ":" + item.CODE + "(" + item.NAME + ")";
|
houseItem.PARENT_HOUSE = item.PARENT_ID;
|
houseItem.createTime = DateTime.Now.ToString("yyyy-MM-dd mm:dd:ss");
|
houseItem.houseType = item.TYPE;
|
//houseItem.remark = item.REMARK;
|
//houseItem.orderNo = item.SEQ_NO;
|
houseItem.children = new();
|
if (item.TYPE != "Shelf") GetOrgItemOrg(data, item.ID, ref houseItem);
|
pOrgItem.children.Add(houseItem);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 根据仓库代码和类型删除仓库机构列表
|
/// </summary>
|
/// <param name="wareHouse"></param>
|
/// <returns></returns>
|
public ApiAction DelWareHouseModel(DelWareHouseModelEntity wareHouse)
|
{
|
var action = new ApiAction();
|
List<string> locaIds = new();
|
List<string> shelfIds = new();
|
List<string> regIds = new();
|
List<string> wareIds = new();
|
var db = Biz.Db;
|
List<V_WH_UNIT> uNITs = new List<V_WH_UNIT>();
|
if (wareHouse.Type == "Warehouse")
|
{
|
var res = db.Queryable<WMS_ITEM>().Where(q => q.STATUS > 2 && q.WH_ID == wareHouse.ID).ToList();
|
if (res.IsNullOrEmpty())
|
{
|
var unit = db.Queryable<V_WH_UNIT>().Where(q => q.WH_ID == wareHouse.ID).ToList();
|
locaIds.AddRange(unit.Where(q => !q.LOCATION_ID.IsNullOrEmpty()).Select(s => s.LOCATION_ID).Distinct());
|
shelfIds.AddRange(unit.Where(q => !q.SHELF_ID.IsNullOrEmpty()).Select(s => s.SHELF_ID).Distinct());
|
regIds.AddRange(unit.Where(q => !q.REGION_ID.IsNullOrEmpty()).Select(s => s.REGION_ID).Distinct());
|
wareIds.AddRange(unit.Where(q => !q.WH_ID.IsNullOrEmpty()).Select(s => s.WH_ID).Distinct());
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.Message = "仓库里面有东西，不能删除！";
|
}
|
}
|
else if (wareHouse.Type == "Region")
|
{
|
var res = db.Queryable<WMS_ITEM>().Where(q => q.STATUS > 2 && q.REGION_ID == wareHouse.ID).ToList();
|
if (res.IsNullOrEmpty())
|
{
|
var unit = db.Queryable<V_WH_UNIT>().Where(q => q.REGION_ID == wareHouse.ID).ToList();
|
locaIds.AddRange(unit.Where(q => !q.LOCATION_ID.IsNullOrEmpty()).Select(s => s.LOCATION_ID).Distinct());
|
shelfIds.AddRange(unit.Where(q => !q.SHELF_ID.IsNullOrEmpty()).Select(s => s.SHELF_ID).Distinct());
|
regIds.AddRange(unit.Where(q => !q.REGION_ID.IsNullOrEmpty()).Select(s => s.REGION_ID).Distinct());
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.Message = "储区里面有东西，不能删除！";
|
}
|
}
|
else if (wareHouse.Type == "Shelf")
|
{
|
var res = db.Queryable<WMS_ITEM>().Where(q => q.STATUS > 2 && q.SHELF_ID == wareHouse.ID).ToList();
|
if (res.IsNullOrEmpty())
|
{
|
var unit = db.Queryable<V_WH_UNIT>().Where(q => q.SHELF_ID == wareHouse.ID).ToList();
|
locaIds.AddRange(unit.Where(q => !q.LOCATION_ID.IsNullOrEmpty()).Select(s => s.LOCATION_ID).Distinct());
|
shelfIds.AddRange(unit.Where(q => !q.SHELF_ID.IsNullOrEmpty()).Select(s => s.SHELF_ID).Distinct());
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.Message = "货架里面有东西，不能删除！";
|
}
|
}
|
else
|
{
|
|
}
|
//删储位
|
if (locaIds.Any())
|
{
|
db.Deleteable<Model.WMS_LOCATION>().Where(it => locaIds.Contains(it.ID)).ExecuteCommand();
|
}
|
//删货架
|
if (shelfIds.Any())
|
{
|
db.Deleteable<Model.WMS_SHELF>().Where(it => shelfIds.Contains(it.ID)).ExecuteCommand();
|
}
|
//删储区
|
if (regIds.Any())
|
{
|
db.Deleteable<Model.WMS_REGION>().Where(it => regIds.Contains(it.ID)).ExecuteCommand();
|
}
|
//删仓库
|
if (wareIds.Any())
|
{
|
db.Deleteable<Model.WMS_WAREHOUSE>().Where(it => wareIds.Contains(it.ID)).ExecuteCommand();
|
}
|
return action;
|
}
|
/// <summary>
|
/// 生成储位列表
|
/// </summary>
|
/// <param name="locations"></param>
|
/// <returns></returns>
|
public ApiAction AddLocationModel(List<AddLocationModelEntity> locations)
|
{
|
var action = new ApiAction();
|
List<WMS_LOCATION> Locations = new List<WMS_LOCATION>();
|
foreach (var item in locations)
|
{
|
WMS_LOCATION location = new WMS_LOCATION()
|
{
|
LOCATION_CODE = item.LOCATION_CODE,
|
LOCATION_NAME = item.LOCATION_CODE,
|
IS_ACTIVE = "Y",
|
AUTH_ORG = item.AUTH_ORG,
|
ORG_CODE = item.ORG_CODE,
|
SHELF_ID = item.SHELF_ID,
|
IS_MIX = item.ISMIX,
|
IS_SINGLE = item.ISMIX == "N" ? "Y" : "N",
|
FLOOR_NO = item.FLOOR_NO,
|
SEQ_NO = item.SEQ_NO,
|
LEDID = item.LEDID
|
};
|
Locations.Add(location);
|
}
|
var db = Biz.Db;
|
var dbTran = db.UseTran(() =>
|
{
|
db.Deleteable<WMS_LOCATION>().Where(q => q.SHELF_ID == locations[0].SHELF_ID).ExecuteCommand();
|
db.Insertable<WMS_LOCATION>(Locations).ExecuteCommand();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
action.GetResponse().CatchExceptionWithLog(dbTran.ErrorException, $"新增储位异常");
|
}
|
|
action.LocaleMsg = Biz.L("WMS.WareHouse.VerifyException", Locations[0].ORG_CODE);
|
return action;
|
}
|
/// <summary>
|
/// 查询货架是否有东西
|
/// </summary>
|
/// <param name="shelf"></param>
|
/// <returns></returns>
|
public ApiAction CheckLocation(DelWareHouseModelEntity shelf)
|
{
|
var action = new ApiAction();
|
var db = Biz.Db;
|
if (shelf.Type == "shelf")
|
{
|
var res = db.Queryable<WMS_ITEM>().Where(q => q.STATUS > 2 && q.SHELF_ID == shelf.ID).ToList();
|
if (res.IsNullOrEmpty())
|
{
|
action.IsSuccessed = true;
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("WMS.WareHouse.检查储位初始化", shelf.ID);
|
}
|
}
|
return action;
|
}
|
/// <summary>
|
/// 修改仓库据点，同下级全部修改
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
public async Task<string> GetUpdateOrg(string id)
|
{
|
var db = Biz.Db;
|
List<WMS_SHELF> shelfs = new();
|
List<WMS_LOCATION> locations = new();
|
var warehouse = db.Queryable<WMS_WAREHOUSE>().Where(q => q.ID == id).First();
|
if (warehouse != null)
|
{
|
var unit = db.Queryable<V_WH_UNIT>().Where(q => q.WH_ID == id).ToList();
|
var regionids = unit.Select(q => q.REGION_ID).Distinct().ToList();
|
var shelfids = unit.Select(q => q.SHELF_ID).Distinct().ToList();
|
//var locationids=unit.Select(q=>q.LOCATION_ID).Distinct().ToList();
|
var dbTran = db.UseTran(() =>
|
{
|
db.Updateable<WMS_REGION>().SetColumns(q => q.AUTH_ORG == warehouse.AUTH_ORG).Where(q => q.WH_ID == warehouse.ID).ExecuteCommand();
|
|
db.Updateable<WMS_SHELF>().SetColumns(q => q.AUTH_ORG == warehouse.AUTH_ORG)
|
.Where(q => regionids.Any(o => o == q.REGION_ID)).ExecuteCommand();
|
db.Updateable<WMS_LOCATION>().SetColumns(q => q.AUTH_ORG == warehouse.AUTH_ORG)
|
.Where(q => SqlFunc.Subqueryable<WMS_SHELF>().Where(s => regionids.Any(o => o == s.REGION_ID) && q.SHELF_ID == s.ID).Any()).ExecuteCommand();
|
});
|
}
|
return "";
|
}
|
|
/// <summary>
|
/// 根据id获取Code
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
public async Task<string> GetWmsCode(string id)
|
{
|
var db = Biz.Db;
|
var ID = "";
|
var warehouse = db.Queryable<WMS_WAREHOUSE>().Where(q => q.WH_CODE == id).First();
|
if (warehouse != null)
|
{
|
ID = warehouse.ID;
|
}
|
return ID;
|
}
|
|
}
|
}
|
