using System.Collections.Generic; using System.Data.Entity; using System.Linq; using System.Threading.Tasks; using System.Web.Mvc; using System.Web.WebPages; using Abp.Application.Services.Dto; using Abp.Auditing; using Abp.Authorization; using Abp.Domain.Repositories; using Abp.Domain.Uow; using Abp.Runtime.Caching; using IwbZero.Auditing; using IwbZero.AppServiceBase; using IwbZero.ToolCommon.StringModel; using WeApp.Authorization; using WeApp.Configuration; using WeApp.TrainingCamp; using WeApp.TrainingCampGroup.Dto; namespace WeApp.TrainingCampGroup { [AbpAuthorize, AuditLog("培训营分组维护")] public class CampGroupAppService : IwbAsyncCrudAppService, ICampGroupAppService { public CampGroupAppService( ICacheManager cacheManager, IRepository repository, IRepository campRepository) : base(repository, "Id") { CampRepository = campRepository; CacheManager = cacheManager; } protected IRepository CampRepository { get; } protected override bool KeyIsAuto { get; set; } = false; #region GetSelect [DisableAuditing] public override async Task> GetSelectList() { var list = await Repository.GetAllListAsync(); var sList = new List {new SelectListItem {Text = @"请选择...", Value = "", Selected = true}}; foreach (var l in list) { //sList.Add(new SelectListItem { Value = l.Id, Text = l. }); } return sList; } [DisableAuditing] public override async Task GetSelectStr() { var list = await Repository.GetAllListAsync(); string str = ""; foreach (var l in list) { //str += $""; } return str; } #endregion #region CURD [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgCreate)] public override async Task Create(CampGroupCreateDto input) { var camp = await CampRepository.FirstOrDefaultAsync(a => a.Id == input.CampNo); if(camp.CampState!=CampStateDefinition.New&& camp.CampState != CampStateDefinition.Audit) { CheckErrors("培训营已运行(或结束),不能再操作!"); } input.Id = await GetGroupNo(input.CampNo); input.CampGroupState = CampGroupStateDefinition.New; await CreateEntity(input); } [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgUpdate)] public override async Task Update(CampGroupUpdateDto input) { var camp = await CampRepository.FirstOrDefaultAsync(a => a.Id == input.CampNo); if (camp.CampState != CampStateDefinition.New && camp.CampState != CampStateDefinition.Audit) { CheckErrors("培训营已运行(或结束),不能再操作!"); } var entity = await Repository.FirstOrDefaultAsync(a => a.Id == input.Id); if (entity == null) { CheckErrors($"未查询编号为【{input.Id}】到分组!"); return; } if (entity.CampGroupState != CampGroupStateDefinition.New) { CheckErrors($"新建状态的培训营才能修改!"); } await UpdateEntity(input); } [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgDelete)] public override async Task Delete(EntityDto input) { var entity = await Repository.FirstOrDefaultAsync(a => a.Id == input.Id); if (entity == null) { CheckErrors($"未查询编号为【{input.Id}】到分组!"); return; } if (entity.CampGroupState != CampGroupStateDefinition.New) { CheckErrors($"新建状态的培训营才能删除!"); } await base.Delete(input); } [DisableAuditing] [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgQuery)] public override async Task> GetAll(IwbPagedRequestDto input) { var query = Repository.GetAllIncluding(a => a.CampInfo); query = ApplyFilter(query, input); var totalCount = await AsyncQueryableExecuter.CountAsync(query); query = ApplySorting(query, input); query = ApplyPaging(query, input); var entities = await AsyncQueryableExecuter.ToListAsync(query); var dtoList = new PagedResultDto(totalCount, entities.Select(MapToEntityDto).ToList()); return dtoList; } #region GetEntity/Dto /// /// 查询实体Dto /// /// /// [DisableAuditing] [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgQuery)] public override async Task GetDto(EntityDto input) { var entity = await GetEntity(input); return MapToEntityDto(entity); } /// /// 查询实体Dto /// /// /// [DisableAuditing] [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgQuery)] public override async Task GetDtoById(string id) { var entity = await GetEntityById(id); return MapToEntityDto(entity); } /// /// 查询实体Dto(需指明自定义字段) /// /// /// [DisableAuditing] [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgQuery)] public override async Task GetDtoByNo(string no) { var entity = await GetEntityByNo(no); return MapToEntityDto(entity); } /// /// 查询实体 /// /// /// [DisableAuditing] [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgQuery)] public override async Task GetEntity(EntityDto input) { var entity = await GetEntityById(input.Id); return entity; } /// /// 查询实体 /// /// /// [DisableAuditing] [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgQuery)] public override async Task GetEntityById(string id) { return await Repository.FirstOrDefaultAsync(a=>a.Id==id); } /// /// 查询实体(需指明自定义字段) /// /// /// [DisableAuditing] [AbpAuthorize(PermissionNames.PagesTrainMgGroupMgQuery)] public override async Task GetEntityByNo(string no) { //CheckGetPermission(); if (string.IsNullOrEmpty(KeyFiledName)) { ThrowError("NoKeyFieldName"); } return await base.GetEntityByNo(no); } #endregion #region Hide ///// ///// 根据给定的创建 过滤查询. ///// ///// The input. //protected override IQueryable CreateFilteredQuery(IwbPagedRequestDto input) //{ // var query = Repository.GetAll(); // var pagedInput = input as IIwbPagedRequest; // if (pagedInput == null) // { // return query; // } // if (!string.IsNullOrEmpty(pagedInput.KeyWords)) // { // object keyWords = pagedInput.KeyWords; // LambdaObject obj = new LambdaObject() // { // FieldType = (LambdaFieldType)pagedInput.FieldType, // FieldName = pagedInput.KeyField, // FieldValue = keyWords, // ExpType = (LambdaExpType)pagedInput.ExpType // }; // var exp = obj.GetExp(); // query = exp != null ? query.Where(exp) : query; // } // if (pagedInput.SearchList != null && pagedInput.SearchList.Count > 0) // { // List objList = new List(); // foreach (var o in pagedInput.SearchList) // { // if (string.IsNullOrEmpty(o.KeyWords)) // continue; // object keyWords = o.KeyWords; // objList.Add(new LambdaObject // { // FieldType = (LambdaFieldType)o.FieldType, // FieldName = o.KeyField, // FieldValue = keyWords, // ExpType = (LambdaExpType)o.ExpType // }); // } // var exp = objList.GetExp(); // query = exp != null ? query.Where(exp) : query; // } // return query; //} //protected override IQueryable ApplySorting(IQueryable query, IwbPagedRequestDto input) //{ // return query.OrderBy(a => a.No); //} //protected override IQueryable ApplyPaging(IQueryable query, IwbPagedRequestDto input) //{ // if (input is IPagedResultRequest pagedInput) // { // return query.Skip(pagedInput.SkipCount).Take(pagedInput.MaxResultCount); // } // return query; //} #endregion #endregion private async Task GetGroupNo(string campNo) { if (StringExtensions.IsEmpty(campNo)) { CheckErrors("培训营编号不能为空!"); } var no = $"{campNo}_"; int index = 0; using (CurrentUnitOfWork.DisableFilter(AbpDataFilters.SoftDelete)) { var lastEntity = await Repository.GetAll().Where(a => a.CampNo == campNo).OrderByDescending(a => a.Id) .FirstOrDefaultAsync(); if (lastEntity != null) { index = lastEntity.Id.Substring(no.Length).ValI(); } } index++; return $"{no}{index.LeftPad(3)}"; } } }