EnvironResourceApplicationService.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Threading.Tasks;
  5. using System.Web.Mvc;
  6. using Abp.Application.Services.Dto;
  7. using Abp.Auditing;
  8. using Abp.Authorization;
  9. using Abp.Configuration;
  10. using Abp.Domain.Repositories;
  11. using Abp.Runtime.Caching;
  12. using IwbZero.AppServiceBase;
  13. using IwbZero.Auditing;
  14. using IwbZero.ToolCommon.StringModel;
  15. using WePlatform.Authorization;
  16. using WePlatform.Configuration;
  17. using WePlatform.WeLib.EnvironResource.Dto;
  18. namespace WePlatform.WeLib.EnvironResource
  19. {
  20. [AbpAuthorize, AuditLog("环境资源")]
  21. public class EnvironResourceAppService : IwbAsyncCrudAppService<EnvironResourceInfo, EnvironResourceDto, string, IwbPagedRequestDto, EnvironResourceCreateDto, EnvironResourceUpdateDto >, IEnvironResourceAppService
  22. {
  23. public EnvironResourceAppService(
  24. ICacheManager cacheManager,
  25. IRepository<EnvironResourceInfo, string> repository) : base(repository, "Id")
  26. {
  27. CacheManager = cacheManager;
  28. }
  29. protected override bool KeyIsAuto { get; set; } = false;
  30. #region GetSelect
  31. [DisableAuditing]
  32. public override async Task<List<SelectListItem>> GetSelectList()
  33. {
  34. var list = await Repository.GetAllListAsync();
  35. var sList = new List<SelectListItem> {new SelectListItem {Text = @"请选择...", Value = "", Selected = true}};
  36. foreach (var l in list)
  37. {
  38. sList.Add(new SelectListItem { Value = l.Id, Text = l.ResourceName });
  39. }
  40. return sList;
  41. }
  42. [DisableAuditing]
  43. public override async Task<string> GetSelectStr()
  44. {
  45. var list = await Repository.GetAllListAsync();
  46. string str = "<option value=\"\" selected>请选择...</option>";
  47. foreach (var l in list)
  48. {
  49. str += $"<option value=\"{l.Id}\">{l.ResourceName}</option>";
  50. }
  51. return str;
  52. }
  53. #endregion
  54. #region CURD
  55. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgCreate)]
  56. public override async Task Create(EnvironResourceCreateDto input)
  57. {
  58. var entity = await Repository.FirstOrDefaultAsync(a => a.MessageCode == input.MessageCode);
  59. if (entity != null)
  60. {
  61. CheckErrors($"消息编码【{input.MessageCode}】已存在,请检查后再试!");
  62. }
  63. if (input.FileInfo.IsNotEmpty()&& input.FileExt.IsNotEmpty())
  64. {
  65. var path = $"{SettingManager.GetSettingValue(IwbSettingNames.DownloadPath)}/EnvironResource/";
  66. var name = $"{input.FileName}-{DateTime.Now:yyMMddHHmmss}";
  67. await AttachFileManager.FileUpload(input.FileInfo, path, name, input.FileExt, "png,jpg,jpeg,mp4,wmv,avi,mov,mp3");
  68. input.ResourcePath = $"\\{path}{name}.{input.FileExt}";
  69. }
  70. input.Id = await AppGuidManager.GetNextRecordIdAsync(DataLibType.EnvironResourceInfo);
  71. await CreateEntity(input);
  72. }
  73. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgUpdate)]
  74. public override async Task Update(EnvironResourceUpdateDto input)
  75. {
  76. var entity =
  77. await Repository.FirstOrDefaultAsync(a => a.MessageCode == input.MessageCode && a.Id != input.Id);
  78. if (entity != null)
  79. {
  80. CheckErrors($"消息编码【{input.MessageCode}】已存在,请检查后再试!");
  81. }
  82. entity = await Repository.FirstOrDefaultAsync(a => a.Id == input.Id);
  83. if (input.FileInfo.IsNotEmpty() && input.FileExt.IsNotEmpty())
  84. {
  85. var path = $"{SettingManager.GetSettingValue(IwbSettingNames.DownloadPath)}/EnvironResource/";
  86. var name = $"{input.FileName}-{DateTime.Now:yyMMddHHmmss}";
  87. await AttachFileManager.FileUpload(input.FileInfo, path, name, input.FileExt, "png,jpg,jpeg,mp4,wmv,avi,mov,mp3");
  88. input.ResourcePath = $"\\{path}{name}.{input.FileExt}";
  89. }
  90. else
  91. {
  92. input.ResourcePath = entity.ResourcePath;
  93. }
  94. await UpdateEntity(input, entity);
  95. }
  96. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgDelete)]
  97. public override Task Delete(EntityDto<string> input)
  98. {
  99. return base.Delete(input);
  100. }
  101. [DisableAuditing]
  102. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgQuery)]
  103. public override async Task<PagedResultDto<EnvironResourceDto>> GetAll(IwbPagedRequestDto input)
  104. {
  105. var query = CreateFilteredQuery(input);
  106. query = ApplyFilter(query, input);
  107. var totalCount = await AsyncQueryableExecuter.CountAsync(query);
  108. query = ApplySorting(query, input);
  109. query = ApplyPaging(query, input);
  110. var entities = await AsyncQueryableExecuter.ToListAsync(query);
  111. var dtoList = new PagedResultDto<EnvironResourceDto>(totalCount, entities.Select(MapToEntityDto).ToList());
  112. return dtoList;
  113. }
  114. #region GetEntity/Dto
  115. /// <summary>
  116. /// 查询实体Dto
  117. /// </summary>
  118. /// <param name="input"></param>
  119. /// <returns></returns>
  120. [DisableAuditing]
  121. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgQuery)]
  122. public override async Task<EnvironResourceDto> GetDto(EntityDto<string> input)
  123. {
  124. var entity = await GetEntity(input);
  125. return MapToEntityDto(entity);
  126. }
  127. /// <summary>
  128. /// 查询实体Dto
  129. /// </summary>
  130. /// <param name="id"></param>
  131. /// <returns></returns>
  132. [DisableAuditing]
  133. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgQuery)]
  134. public override async Task<EnvironResourceDto> GetDtoById(string id)
  135. {
  136. var entity = await GetEntityById(id);
  137. return MapToEntityDto(entity);
  138. }
  139. /// <summary>
  140. /// 查询实体Dto(需指明自定义字段)
  141. /// </summary>
  142. /// <param name="no"></param>
  143. /// <returns></returns>
  144. [DisableAuditing]
  145. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgQuery)]
  146. public override async Task<EnvironResourceDto> GetDtoByNo(string no)
  147. {
  148. var entity = await GetEntityByNo(no);
  149. return MapToEntityDto(entity);
  150. }
  151. /// <summary>
  152. /// 查询实体
  153. /// </summary>
  154. /// <param name="input"></param>
  155. /// <returns></returns>
  156. [DisableAuditing]
  157. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgQuery)]
  158. public override async Task<EnvironResourceInfo> GetEntity(EntityDto<string> input)
  159. {
  160. var entity = await GetEntityById(input.Id);
  161. return entity;
  162. }
  163. /// <summary>
  164. /// 查询实体
  165. /// </summary>
  166. /// <param name="id"></param>
  167. /// <returns></returns>
  168. [DisableAuditing]
  169. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgQuery)]
  170. public override async Task<EnvironResourceInfo> GetEntityById(string id)
  171. {
  172. return await Repository.FirstOrDefaultAsync(a=>a.Id==id);
  173. }
  174. /// <summary>
  175. /// 查询实体(需指明自定义字段)
  176. /// </summary>
  177. /// <param name="no"></param>
  178. /// <returns></returns>
  179. [DisableAuditing]
  180. [AbpAuthorize(PermissionNames.PagesResourceMgEnvironReMgQuery)]
  181. public override async Task<EnvironResourceInfo> GetEntityByNo(string no)
  182. {
  183. //CheckGetPermission();
  184. if (string.IsNullOrEmpty(KeyFiledName))
  185. {
  186. ThrowError("NoKeyFieldName");
  187. }
  188. return await base.GetEntityByNo(no);
  189. }
  190. #endregion
  191. #region Hide
  192. ///// <summary>
  193. ///// 根据给定的<see cref="IwbPagedRequestDto"/>创建 <see cref="IQueryable{EnvironResourceInfo}"/>过滤查询.
  194. ///// </summary>
  195. ///// <param name="input">The input.</param>
  196. //protected override IQueryable<EnvironResourceInfo> CreateFilteredQuery(IwbPagedRequestDto input)
  197. //{
  198. // var query = Repository.GetAll();
  199. // var pagedInput = input as IIwbPagedRequest;
  200. // if (pagedInput == null)
  201. // {
  202. // return query;
  203. // }
  204. // if (!string.IsNullOrEmpty(pagedInput.KeyWords))
  205. // {
  206. // object keyWords = pagedInput.KeyWords;
  207. // LambdaObject obj = new LambdaObject()
  208. // {
  209. // FieldType = (LambdaFieldType)pagedInput.FieldType,
  210. // FieldName = pagedInput.KeyField,
  211. // FieldValue = keyWords,
  212. // ExpType = (LambdaExpType)pagedInput.ExpType
  213. // };
  214. // var exp = obj.GetExp<EnvironResourceInfo>();
  215. // query = exp != null ? query.Where(exp) : query;
  216. // }
  217. // if (pagedInput.SearchList != null && pagedInput.SearchList.Count > 0)
  218. // {
  219. // List<LambdaObject> objList = new List<LambdaObject>();
  220. // foreach (var o in pagedInput.SearchList)
  221. // {
  222. // if (string.IsNullOrEmpty(o.KeyWords))
  223. // continue;
  224. // object keyWords = o.KeyWords;
  225. // objList.Add(new LambdaObject
  226. // {
  227. // FieldType = (LambdaFieldType)o.FieldType,
  228. // FieldName = o.KeyField,
  229. // FieldValue = keyWords,
  230. // ExpType = (LambdaExpType)o.ExpType
  231. // });
  232. // }
  233. // var exp = objList.GetExp<EnvironResourceInfo>();
  234. // query = exp != null ? query.Where(exp) : query;
  235. // }
  236. // return query;
  237. //}
  238. //protected override IQueryable<EnvironResourceInfo> ApplySorting(IQueryable<EnvironResourceInfo> query, IwbPagedRequestDto input)
  239. //{
  240. // return query.OrderBy(a => a.No);
  241. //}
  242. //protected override IQueryable<EnvironResourceInfo> ApplyPaging(IQueryable<EnvironResourceInfo> query, IwbPagedRequestDto input)
  243. //{
  244. // if (input is IPagedResultRequest pagedInput)
  245. // {
  246. // return query.Skip(pagedInput.SkipCount).Take(pagedInput.MaxResultCount);
  247. // }
  248. // return query;
  249. //}
  250. #endregion
  251. #endregion
  252. }
  253. }