Screen.razor.cs 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256
  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. await searchSitesAsync();
  75. model = new ScrrenDialogModel();
  76. model.Type = type;
  77. model.Sites = Sites;
  78. if(type == 2 || type == 3)
  79. {
  80. model.sn = snInfo?.sn?? "";
  81. model.SiteId = snInfo?.SiteId ?? -1;
  82. model.siteName = snInfo?.siteName ?? "";
  83. model.Id = snInfo?.Id;
  84. model.Remark = snInfo?.Remark ?? "";
  85. }
  86. isOpen = true;
  87. }
  88. /// <summary>
  89. /// 编辑弹窗信息回调
  90. /// </summary>
  91. /// <param name="model"></param>
  92. private async Task OnDialogCallback(ScrrenDialogModel model)
  93. {
  94. switch (model.Type)
  95. {
  96. case 1:
  97. await _Repository.InsertAsync(model.ToCompany());
  98. break;
  99. case 2:
  100. ScreentEntity siteEntity = model.ToCompany();
  101. await _Repository.Context.Updateable(siteEntity).
  102. UpdateColumns(it => new { it.sn,it.SiteId, it.Remark})
  103. .ExecuteCommandAsync();
  104. break;
  105. case 3:
  106. await _Repository.DeleteByIdAsync(model.Id);
  107. break;
  108. }
  109. await Query();
  110. }
  111. /// <summary>
  112. /// 编辑弹窗是否显示回调
  113. /// </summary>
  114. /// <param name="isOpen"></param>
  115. private void OnDialogVisibleCallback(bool isOpen)
  116. {
  117. this.isOpen = isOpen;
  118. }
  119. /// <summary>
  120. /// 表格查询
  121. /// </summary>
  122. /// <param name="query"></param>
  123. /// <returns></returns>
  124. private async Task OnChange(QueryModel<SnInfo> query)
  125. => await Query();
  126. /// <summary>
  127. /// 查
  128. /// </summary>
  129. /// <returns></returns>
  130. private async Task Query()
  131. {
  132. Loading = true;
  133. var query = _Repository.AsQueryable()
  134. .LeftJoin<SiteEntity>((screen, site) => screen.SiteId == site.Id);
  135. query = query
  136. .WhereIF(filterData.siteName.IsNotNullOrEmpty(),(screen, site) => site.Name.Contains(filterData.siteName))
  137. .WhereIF(filterData.sn.IsNotNullOrEmpty(), (screen, site) => screen.sn.Contains(filterData.sn));
  138. Total = await query.CountAsync();
  139. _DataSource = await query
  140. .Select((screen,site) => new SnInfo()
  141. {
  142. Id = screen.Id,
  143. sn = screen.sn,
  144. SiteId = screen.SiteId,
  145. siteName = site.Name,
  146. CreateTime = screen.CreateTime,
  147. EditTime = screen.EditTime,
  148. Remark = screen.Remark,
  149. })
  150. .Skip((filterData.currentPage - 1) * filterData.pageSize)
  151. .Take(filterData.pageSize)
  152. .ToListAsync();
  153. await searchSitesAsync();
  154. Loading = false;
  155. }
  156. Func<PaginationTotalContext, string> showTotal = ctx => $"总数 {ctx.Total} ";
  157. private async Task OnPageChange(PaginationEventArgs args)
  158. {
  159. filterData.pageSize = args.PageSize;
  160. filterData.currentPage = args.Page;
  161. await Query();
  162. }
  163. /// <summary>
  164. /// 清空查询条件
  165. /// </summary>
  166. private void HandleReset()
  167. {
  168. filterData = new();
  169. }
  170. private async Task searchSitesAsync()
  171. {
  172. if (Global.CurrentUser.Account == "admin")
  173. {
  174. Sites = await _SiteRepository.AsQueryable()
  175. .Select<SiteInfo>()
  176. .ToListAsync();
  177. }
  178. else
  179. {
  180. Sites = await _SiteRepository.AsQueryable()
  181. .Where(it => it.Id == Global.CurrentUser.SiteId || it.ParentId == Global.CurrentUser.SiteId)
  182. .Select<SiteInfo>()
  183. .ToListAsync();
  184. }
  185. }
  186. protected override async void OnInitialized()
  187. {
  188. }
  189. protected override async Task OnAfterRenderAsync(bool firstRender)
  190. {
  191. if (firstRender)
  192. {
  193. await NavigationManager.RedirectLogin(IJSRuntime);
  194. await Query();
  195. }
  196. }
  197. private async Task OnChange(QueryModel<SystemMenu> query)
  198. => await Query();
  199. /// <summary>
  200. /// 查找条件
  201. /// </summary>
  202. public class FilterData
  203. {
  204. /// <summary>
  205. /// 页码
  206. /// </summary>
  207. public int currentPage { set; get; } = 1;
  208. /// <summary>
  209. /// 页数
  210. /// </summary>
  211. public int pageSize { set; get; } = 10;
  212. /// <summary>
  213. /// 要查找的站名
  214. /// </summary>
  215. public string? siteName { set; get; }
  216. /// <summary>
  217. /// 要查找的SN
  218. /// </summary>
  219. public string? sn{ set; get; }
  220. }
  221. }