颐和api

Sys_Module_InfoRepository.cs 1.8KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. using ConfigurationApi.IRepositories;
  2. using MadRunFabric.Model;
  3. using MadRunFabric.Common;
  4. using MadRunFabric.Common.Options;
  5. using Microsoft.Extensions.Logging;
  6. using Microsoft.Extensions.Options;
  7. using MongoDB.Driver;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.Text;
  11. using System.Threading.Tasks;
  12. namespace ConfigurationApi.Repositories
  13. {
  14. public class Sys_Module_InfoRepository : BaseRepository<Sys_Module_Info, string>, ISys_Module_InfoRepository
  15. {
  16. protected readonly IMongoCollection<Sys_Module_Info> m_collection;
  17. protected readonly ILogger<BaseRepository<Sys_Module_Info, string>> _logger;
  18. public Sys_Module_InfoRepository(IOptions<MongodbOptions> settings, ILogger<BaseRepository<Sys_Module_Info, string>> logger) : base(settings, logger)
  19. {
  20. m_collection = _collection;
  21. _logger = logger;
  22. }
  23. /// <summary>
  24. /// 根据菜单di删除对应的数据(本质是更新,保证数据被更改可排查)
  25. /// </summary>
  26. /// <returns></returns>
  27. public async Task<bool> DelModule(string[] ids)
  28. {
  29. try
  30. {
  31. var imodel = new Sys_Module_Info();
  32. Dictionary<string, string> dic = new Dictionary<string, string>();
  33. dic.Add("state_flag", "2");
  34. var list = new List<FilterDefinition<Sys_Module_Info>>();
  35. var filterBuilder = Builders<Sys_Module_Info>.Filter;
  36. list.Add(filterBuilder.In("id", ids));
  37. var filter = Builders<Sys_Module_Info>.Filter.And(list);
  38. return await UpdateManay(imodel, dic, filter);
  39. }
  40. catch (Exception ex)
  41. {
  42. _logger.LogError(ex.ToString());
  43. return false;
  44. }
  45. }
  46. }
  47. }