using HslCommunication.Secs.Types; using Microsoft.AspNetCore.Http; using SqlSugar; using System; using System.Collections; using System.Collections.Generic; using System.Drawing.Printing; using System.Dynamic; using System.Linq; using System.Linq.Expressions; using System.Reflection; using System.Text; using System.Threading.Tasks; using WIDESEA_Common.LocationEnum; using WIDESEA_Core; using WIDESEA_Core.BaseRepository; using WIDESEA_Core.BaseServices; using WIDESEA_Core.Const; using WIDESEA_Core.DB.Models; using WIDESEA_Core.Enums; using WIDESEA_Core.Helper; using WIDESEA_Core.HostedService; using WIDESEA_Core.Utilities; using WIDESEA_DTO.Stock; using WIDESEA_IStockRepository; using WIDESEA_IStockService; using WIDESEA_Model.Models; namespace WIDESEA_StockService { public partial class StockViewService : IStockViewService { private readonly IUnitOfWorkManage _unitOfWorkManage; private readonly SqlSugarClient _dbBase; public StockViewService(IUnitOfWorkManage unitOfWorkManage) { _unitOfWorkManage = unitOfWorkManage; _dbBase = unitOfWorkManage.GetDbClient(); } public virtual PageGridData GetPageData(PageDataOptions options) { try { List stockViewDTOs = new List(); string where = string.Empty; ISugarQueryable sugarQueryable1 = _dbBase.Queryable().Includes(x => x.Details); if (!string.IsNullOrEmpty(options.Wheres)) { try { List searchParametersList = options.Wheres.DeserializeObject>(); if (searchParametersList.Count > 0) { { SearchParameters? searchParameters = searchParametersList.FirstOrDefault(x => x.Name == nameof(Dt_StockInfoDetail.MaterielCode).FirstLetterToLower()); if (searchParameters != null) { sugarQueryable1 = sugarQueryable1.Where(x => x.Details.Any(v => v.MaterielCode.Contains(searchParameters.Value))); } } { SearchParameters? searchParameters = searchParametersList.FirstOrDefault(x => x.Name == nameof(Dt_StockInfoDetail.BatchNo).FirstLetterToLower()); if (searchParameters != null) { sugarQueryable1 = sugarQueryable1.Where(x => x.Details.Any(v => v.BatchNo.Contains(searchParameters.Value))); } } } } catch { } } string whereSto = GetDataRole(typeof(Dt_StockInfo)); sugarQueryable1 = sugarQueryable1.Where(whereSto); EntityProperties.ValidatePageOptions(options, ref sugarQueryable1); string whereLo = GetDataRole(typeof(Dt_LocationInfo)); ISugarQueryable sugarQueryable = _dbBase.Queryable().Where(whereLo); EntityProperties.ValidatePageOptions(options, ref sugarQueryable); ISugarQueryable list = sugarQueryable1.InnerJoin(sugarQueryable, (b, a) => a.LocationCode == b.LocationCode).Select((b, a) => new StockViewDTO { LocationCode = b.LocationCode, Column = a.Column, WarehouseId = b.WarehouseId, CreateDate = b.CreateDate, Creater = b.Creater, Depth = a.Depth, EnalbeStatus = a.EnableStatus, Layer = a.Layer, LocationName = a.LocationName, LocationStatus = a.LocationStatus, LocationType = a.LocationType, Modifier = b.Modifier, ModifyDate = b.ModifyDate, PalletCode = b.PalletCode, StockRemark = b.Remark, RoadwayNo = a.RoadwayNo, Row = a.Row, StockId = b.Id, StockStatus = b.StockStatus, Details = b.Details, }); var pklist = sugarQueryable1.Where(b => b.LocationCode == "平库位").Select(b => new StockViewDTO { LocationCode = b.LocationCode, Column = 0, WarehouseId = b.WarehouseId, CreateDate = b.CreateDate, Creater = b.Creater, Depth = 0, EnalbeStatus = EnableStatusEnum.Normal.ObjToInt(), Layer = 0, LocationName = "平库位", LocationStatus = LocationStatusEnum.InStock.ObjToInt(), LocationType = LocationTypeEnum.Undefined.ObjToInt(), Modifier = b.Modifier, ModifyDate = b.ModifyDate, PalletCode = b.PalletCode, StockRemark = b.Remark, RoadwayNo = "平库", Row = 0, StockId = b.Id, StockStatus = b.StockStatus, Details = b.Details, }); int totalCount = 0; int pktotalCount = 0; stockViewDTOs = list.ToPageList(options.Page, options.Rows, ref totalCount); stockViewDTOs.AddRange(pklist.ToPageList(options.Page, options.Rows, ref pktotalCount)); stockViewDTOs.ForEach(x => { x.MaterielCode = string.Join(",", x.Details.Select(x => x.MaterielCode).Distinct()); x.BatchNo = string.Join(",", x.Details.Select(x => x.BatchNo).Distinct()); } ); return new PageGridData(totalCount + pktotalCount, stockViewDTOs); } catch (Exception ex) { } return new PageGridData(); } public virtual object GetDetailPage(PageDataOptions pageData) { Type t = typeof(StockViewDTO); if (pageData.Value == null) return new PageGridData(total: 0, null); string keyName = t.GetKeyName(); ////生成查询条件 //Expression> whereExpression = keyName.CreateExpression(pageData.Value, LinqExpressionType.Equal); int totalCount = 0; PropertyInfo? propertyInfo = t.GetProperties().FirstOrDefault(x => x.GetCustomAttribute() != null); if (propertyInfo != null) { Type detailType = propertyInfo.PropertyType.GetGenericArguments()[0]; Navigate? navigate = propertyInfo.GetCustomAttribute(); if (navigate != null) { List list = _dbBase.Queryable(detailType.Name, "detail").Where(navigate.GetName(), "=", pageData.Value).ToPageList(pageData.Page, pageData.Rows, ref totalCount); return new PageGridData(totalCount, list); } } return new PageGridData(total: 0, null); } private string GetDataRole(Type type) { try { UserRole? userRole = PermissionDataHostService.UserRoles.FirstOrDefault(x => x.UserId == App.User.UserId); if (userRole == null) throw new Exception($"无权限"); if (type.IsAssignableFrom(typeof(BaseWarehouseEntity)) || type.GetProperty(nameof(BaseWarehouseEntity.WarehouseId)) != null) { if (userRole.WarehouseIds.Count > 0) { return $"{nameof(BaseWarehouseEntity.WarehouseId)} in ({userRole.WarehouseIds.Serialize().Replace("[", "").Replace("]", "")})"; } else return $"1 != 1"; } else { return "1 = 1"; } //UserRole? userRole = PermissionDataHostService.UserRoles.FirstOrDefault(x => x.UserId == App.User.UserId); //if (userRole == null) // throw new Exception($"无权限"); //if (userRole.AuthorityScope == (int)AuthorityScopeEnum.CurrentRole) //{ // List userId = PermissionDataHostService.UserRoles.Where(x => x.RoleId == userRole.RoleId).Select(x => x.UserId).ToList(); // return $"creater in ({userId.Serialize()})"; //} //else if (userRole.AuthorityScope == (int)AuthorityScopeEnum.OnlySelf) //{ // return $"creater = '{userRole.UserName}'"; //} //else if (userRole.AuthorityScope == (int)AuthorityScopeEnum.None) //{ // return $"1 != 1"; //} //return ""; } catch (Exception ex) { throw new Exception($"无权限,{ex.Message}"); } } } }