using AutoMapper; using SqlSugar; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WIDESEA_Core; using WIDESEA_Core.BaseRepository; using WIDESEA_Core.BaseServices; using WIDESEA_Core.Enums; using WIDESEA_Core.Helper; using WIDESEA_Core.Utilities; using WIDESEA_DTO.Basic; using WIDESEA_IBasicRepository; using WIDESEA_IRecordService; using WIDESEA_IBasicService; using WIDESEA_Model.Models; using WIDESEA_Common.CommonEnum; using WIDESEA_Common.LocationEnum; namespace WIDESEA_BasicService { public partial class LocationInfoService { public Dt_LocationInfo? AssignLocation(string roadwayNo, PalletTypeEnum palletType, int warehouseId) { Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseId == warehouseId); if (warehouse == null) { throw new Exception($"未找到仓库信息"); } return warehouse.WarehouseName switch { "板材仓" => AssignLocation_BC(roadwayNo, palletType), "PP仓" => AssignLocation_PP(roadwayNo, palletType), "干膜仓" => AssignLocation_GM(roadwayNo, palletType), "测试架仓" => AssignLocation_CSJ(roadwayNo, palletType), "阻焊仓" => AssignLocation_ZH(roadwayNo, palletType), "油墨仓" => AssignLocation(roadwayNo), "成品仓" => AssignLocation(roadwayNo), "辅料仓" => AssignLocation(roadwayNo), _ => throw new Exception($"未找到仓库货位分配方法") }; } private readonly static object _locker = new object(); private static List locationCaches = new List(); /// /// /// /// /// public Dt_LocationInfo? AssignLocation(string roadwayNo) { lock (_locker) { List removeItems = locationCaches.Where(x => (DateTime.Now - x.DateTime).TotalMinutes > 5).ToList();//查询添加静态变量超过5分钟的货位 int count = removeItems.Count; for (int i = 0; i < count; i++) { locationCaches.Remove(removeItems[i]);//移除查询添加静态变量超过5分钟的货位 } List lockLocations = locationCaches.Select(x => x.LocationCode).ToList(); List locationInfos = BaseDal.QueryData(x => x.RoadwayNo == roadwayNo);//查询巷道所有货位信息 Dictionary orderBy = new Dictionary() { { nameof(Dt_LocationInfo.Layer),OrderByType.Asc }, { nameof(Dt_LocationInfo.Column),OrderByType.Asc }, { nameof(Dt_LocationInfo.Depth),OrderByType.Desc }, { nameof(Dt_LocationInfo.Row),OrderByType.Asc } }; return BaseDal.QueryFirst(x => x.RoadwayNo == roadwayNo && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && !lockLocations.Contains(x.LocationCode), orderBy);//查询空货位信息并排除5分钟内分配的货位,根据层、列、深度、行排序 } } /// /// 修改货位状态及类型 /// /// 货位编号 /// 托盘类型 /// 货位状态 public void UpdateLocationStatus(string locationCode, PalletTypeEnum palletType, LocationStatusEnum locationStatus, int warehousId) { Dt_LocationInfo location = Repository.QueryFirst(x => x.LocationCode == locationCode); if (location == null) { throw new Exception($"未找到货位信息,{locationCode}"); } UpdateLocationStatus(location, palletType, locationStatus, warehousId); } /// /// 修改货位状态及类型 /// /// 货位对象 /// 托盘类型 /// 货位状态 public void UpdateLocationStatus(Dt_LocationInfo location, PalletTypeEnum palletType, LocationStatusEnum locationStatus, int warehousId) { List locationInfos = Repository.QueryData(x => x.RoadwayNo == location.RoadwayNo); List locations = GetGroupLocations(locationInfos, location); if (locationInfos.Max(x => x.Depth) < 3) { for (int i = 0; i < locations.Count; i++) { locations[i].LocationStatus = locationStatus.ObjToInt(); locations[i].LocationType = palletType.ObjToInt(); } Dt_LocationInfo? nearLocation = locationInfos.FirstOrDefault(x => x.Row == location.Row && x.Layer == location.Layer && x.Depth == location.Depth && x.Column == location.Column + 1); if (nearLocation != null) { List nearLocations = GetGroupLocations(locationInfos, nearLocation); for (int i = 0; i < nearLocations.Count; i++) { nearLocations[i].LocationType = palletType.ObjToInt(); if (palletType == PalletTypeEnum.LargePallet) { nearLocations[i].LocationStatus = locationStatus.ObjToInt(); } } locations.AddRange(nearLocations); } } else { for (int i = 0; i < locations.Count; i++) { locations[i].LocationStatus = locationStatus.ObjToInt(); locations[i].LocationType = palletType.ObjToInt(); } } Repository.UpdateData(locations); } /// /// 获取不同深度的同组货位信息 /// /// /// /// private List GetGroupLocations(List locationInfos, Dt_LocationInfo location) { List groupLocations = new List() { location }; int maxDepth = locationInfos.Max(x => x.Depth); for (int j = location.Depth + 1; j <= maxDepth; j++) { Dt_LocationInfo? locationInfo = locationInfos.FirstOrDefault(x => x.Depth == j && x.Column == location.Column && x.Layer == location.Layer); if (locationInfo != null) { groupLocations.Add(locationInfo); } } for (int j = location.Depth - 1; j >= 1; j--) { Dt_LocationInfo? locationInfo = locationInfos.FirstOrDefault(x => x.Depth == j && x.Column == location.Column && x.Layer == location.Layer); if (locationInfo != null) { groupLocations.Add(locationInfo); } } return groupLocations; } } }