Screen.razor.cs 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254
  1. using AI.Platform.Core;
  2. using AI.Platform.Core.Entity.Device;
  3. using AI.Platform.Core.Entity.Site;
  4. using AI.Platform.Page.Pages.Site.Model;
  5. using AntDesign;
  6. using AntDesign.TableModels;
  7. using Dm.util;
  8. using Microsoft.AspNetCore.Components;
  9. using Microsoft.JSInterop;
  10. using SqlSugar;
  11. using System.Data.Common;
  12. using System.Text.Json;
  13. using System.Threading.Tasks;
  14. namespace AI.Platform.Page.Pages.Site;
  15. public partial class Screen
  16. {
  17. /// <summary>
  18. ///
  19. /// </summary>
  20. [Inject] NavigationManager NavigationManager { get; set; }
  21. /// <summary>
  22. /// 数据库仓储
  23. /// </summary>
  24. [Inject] SqlSugarRepository<ScreentEntity> _Repository { get; set; }
  25. /// <summary>
  26. /// 站点
  27. /// </summary>
  28. [Inject] SqlSugarRepository<SiteEntity> _SiteRepository { get; set; }
  29. /// <summary>
  30. ///
  31. /// </summary>
  32. [Inject] IJSRuntime IJSRuntime { get; set; }
  33. /// <summary>
  34. ///
  35. /// </summary>
  36. private ITable _Table;
  37. /// <summary>
  38. /// 站点列表信息
  39. /// </summary>
  40. private List<SnInfo> _DataSource;
  41. /// <summary>
  42. /// 总条数
  43. /// </summary>
  44. private int Total = 0;
  45. /// <summary>
  46. /// 加载
  47. /// </summary>
  48. private bool Loading = false;
  49. /// <summary>
  50. /// 查询过滤条件
  51. /// </summary>
  52. private FilterData filterData { set; get; } = new();
  53. /// <summary>
  54. /// 编辑弹窗
  55. /// </summary>
  56. private UpdateScreenDialog updateMediaDialog { set; get; } = new();
  57. /// <summary>
  58. /// 标识弹窗是否显示
  59. /// </summary>
  60. private bool isOpen { set; get; } = false;
  61. private ScrrenDialogModel model = new ScrrenDialogModel();
  62. // <summary>
  63. /// 站点
  64. /// </summary>
  65. private List<SiteInfo> Sites;
  66. /// <summary>
  67. /// 打开编辑弹窗
  68. /// </summary>
  69. /// <param name="type">类型:1:新增;2:编辑;3:删除</param>
  70. /// <param name="snInfo">大屏信息</param>
  71. /// <returns></returns>
  72. private async Task ShowDialog(int type, SnInfo? snInfo)
  73. {
  74. model = new ScrrenDialogModel();
  75. model.Type = type;
  76. model.Sites = Sites;
  77. if(type == 2 || type == 3)
  78. {
  79. model.sn = snInfo?.sn?? "";
  80. model.SiteId = snInfo?.SiteId ?? -1;
  81. model.siteName = snInfo?.siteName ?? "";
  82. model.Id = snInfo?.Id;
  83. model.Remark = snInfo?.Remark ?? "";
  84. }
  85. isOpen = true;
  86. }
  87. /// <summary>
  88. /// 编辑弹窗信息回调
  89. /// </summary>
  90. /// <param name="model"></param>
  91. private async Task OnDialogCallback(ScrrenDialogModel model)
  92. {
  93. switch (model.Type)
  94. {
  95. case 1:
  96. await _Repository.InsertAsync(model.ToCompany());
  97. break;
  98. case 2:
  99. ScreentEntity siteEntity = model.ToCompany();
  100. await _Repository.Context.Updateable(siteEntity).
  101. UpdateColumns(it => new { it.sn,it.SiteId, it.Remark})
  102. .ExecuteCommandAsync();
  103. break;
  104. case 3:
  105. await _Repository.DeleteByIdAsync(model.Id);
  106. break;
  107. }
  108. await Query();
  109. }
  110. /// <summary>
  111. /// 编辑弹窗是否显示回调
  112. /// </summary>
  113. /// <param name="isOpen"></param>
  114. private void OnDialogVisibleCallback(bool isOpen)
  115. {
  116. this.isOpen = isOpen;
  117. }
  118. /// <summary>
  119. /// 表格查询
  120. /// </summary>
  121. /// <param name="query"></param>
  122. /// <returns></returns>
  123. private async Task OnChange(QueryModel<SnInfo> query)
  124. => await Query();
  125. /// <summary>
  126. /// 查
  127. /// </summary>
  128. /// <returns></returns>
  129. private async Task Query()
  130. {
  131. Loading = true;
  132. var query = _Repository.AsQueryable()
  133. .LeftJoin<SiteEntity>((screen, site) => screen.SiteId == site.Id);
  134. query = query
  135. .WhereIF(filterData.siteName.IsNotNullOrEmpty(),(screen, site) => site.Name.Contains(filterData.siteName))
  136. .WhereIF(filterData.sn.IsNotNullOrEmpty(), (screen, site) => screen.sn.Contains(filterData.sn));
  137. Total = await query.CountAsync();
  138. _DataSource = await query
  139. .Select((screen,site) => new SnInfo()
  140. {
  141. Id = screen.Id,
  142. sn = screen.sn,
  143. SiteId = screen.SiteId,
  144. siteName = site.Name,
  145. CreateTime = screen.CreateTime,
  146. EditTime = screen.EditTime,
  147. Remark = screen.Remark,
  148. })
  149. .Skip((filterData.currentPage - 1) * filterData.pageSize)
  150. .Take(filterData.pageSize)
  151. .ToListAsync();
  152. Loading = false;
  153. }
  154. Func<PaginationTotalContext, string> showTotal = ctx => $"总数 {ctx.Total} ";
  155. private async Task OnPageChange(PaginationEventArgs args)
  156. {
  157. filterData.pageSize = args.PageSize;
  158. filterData.currentPage = args.Page;
  159. await Query();
  160. }
  161. /// <summary>
  162. /// 清空查询条件
  163. /// </summary>
  164. private void HandleReset()
  165. {
  166. filterData = new();
  167. }
  168. private async Task searchSitesAsync()
  169. {
  170. if (Global.CurrentUser.Account == "admin")
  171. {
  172. Sites = await _SiteRepository.AsQueryable()
  173. .Select<SiteInfo>()
  174. .ToListAsync();
  175. }
  176. else
  177. {
  178. Sites = await _SiteRepository.AsQueryable()
  179. .Where(it => it.Id == Global.CurrentUser.SiteId || it.ParentId == Global.CurrentUser.SiteId)
  180. .Select<SiteInfo>()
  181. .ToListAsync();
  182. }
  183. }
  184. protected override async void OnInitialized()
  185. {
  186. }
  187. protected override async Task OnAfterRenderAsync(bool firstRender)
  188. {
  189. if (firstRender)
  190. {
  191. await NavigationManager.RedirectLogin(IJSRuntime);
  192. await Query();
  193. await searchSitesAsync();
  194. }
  195. }
  196. private async Task OnChange(QueryModel<SystemMenu> query)
  197. => await Query();
  198. /// <summary>
  199. /// 查找条件
  200. /// </summary>
  201. public class FilterData
  202. {
  203. /// <summary>
  204. /// 页码
  205. /// </summary>
  206. public int currentPage { set; get; } = 1;
  207. /// <summary>
  208. /// 页数
  209. /// </summary>
  210. public int pageSize { set; get; } = 10;
  211. /// <summary>
  212. /// 要查找的站名
  213. /// </summary>
  214. public string? siteName { set; get; }
  215. /// <summary>
  216. /// 要查找的SN
  217. /// </summary>
  218. public string? sn{ set; get; }
  219. }
  220. }