// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。 // // 本项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。 // // 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动!任何基于本项目二次开发而产生的一切法律纠纷和责任,我们不承担任何责任! namespace Admin.NET.Core.Service; /// /// 系统行政区域服务 🧩 /// [ApiDescriptionSettings(Order = 310)] public class SysRegionService : IDynamicApiController, ITransient { private readonly SqlSugarRepository _sysRegionRep; //// Url地址-国家统计局行政区域2023年 //private readonly string _url = "http://www.stats.gov.cn/sj/tjbz/tjyqhdmhcxhfdm/2023/index.html"; public SysRegionService(SqlSugarRepository sysRegionRep) { _sysRegionRep = sysRegionRep; } /// /// 获取行政区域分页列表 🔖 /// /// /// [DisplayName("获取行政区域分页列表")] public async Task> Page(PageRegionInput input) { return await _sysRegionRep.AsQueryable() .WhereIF(input.Pid > 0, u => u.Pid == input.Pid || u.Id == input.Pid) .WhereIF(!string.IsNullOrWhiteSpace(input.Name), u => u.Name.Contains(input.Name)) .WhereIF(!string.IsNullOrWhiteSpace(input.Code), u => u.Code.Contains(input.Code)) .ToPagedListAsync(input.Page, input.PageSize); } /// /// 获取行政区域列表 🔖 /// /// /// [DisplayName("获取行政区域列表")] public async Task> GetList([FromQuery] RegionInput input) { return await _sysRegionRep.GetListAsync(u => u.Pid == input.Id); } /// /// 增加行政区域 🔖 /// /// /// [ApiDescriptionSettings(Name = "Add"), HttpPost] [DisplayName("增加行政区域")] public async Task AddRegion(AddRegionInput input) { input.Code = input.Code.Trim(); if (input.Code.Length != 12 && input.Code.Length != 9 && input.Code.Length != 6) throw Oops.Oh("行政区代码只能为6、9或12位"); if (input.Pid != 0) { var pRegion = await _sysRegionRep.GetFirstAsync(u => u.Id == input.Pid); pRegion ??= await _sysRegionRep.GetFirstAsync(u => u.Code == input.Pid.ToString()); if (pRegion == null) throw Oops.Oh(ErrorCodeEnum.D2000); input.Pid = pRegion.Id; } var isExist = await _sysRegionRep.IsAnyAsync(u => u.Name == input.Name && u.Code == input.Code); if (isExist) throw Oops.Oh(ErrorCodeEnum.R2002); var sysRegion = input.Adapt(); var newRegion = await _sysRegionRep.AsInsertable(sysRegion).ExecuteReturnEntityAsync(); return newRegion.Id; } /// /// 更新行政区域 🔖 /// /// /// [ApiDescriptionSettings(Name = "Update"), HttpPost] [DisplayName("更新行政区域")] public async Task UpdateRegion(UpdateRegionInput input) { input.Code = input.Code.Trim(); if (input.Code.Length != 12 && input.Code.Length != 9 && input.Code.Length != 6) throw Oops.Oh("行政区代码只能为6、9或12位"); if (input.Pid != input.Pid && input.Pid != 0) { var pRegion = await _sysRegionRep.GetFirstAsync(u => u.Id == input.Pid); pRegion ??= await _sysRegionRep.GetFirstAsync(u => u.Code == input.Pid.ToString()); if (pRegion == null) throw Oops.Oh(ErrorCodeEnum.D2000); input.Pid = pRegion.Id; var regionTreeList = await _sysRegionRep.AsQueryable().ToChildListAsync(u => u.Pid, input.Id, true); var childIdList = regionTreeList.Select(u => u.Id).ToList(); if (childIdList.Contains(input.Pid)) throw Oops.Oh("父节点不能为自己的子节点"); } if (input.Id == input.Pid) throw Oops.Oh(ErrorCodeEnum.R2001); var sysRegion = await _sysRegionRep.GetFirstAsync(u => u.Id == input.Id); var isExist = await _sysRegionRep.IsAnyAsync(u => (u.Name == input.Name && u.Code == input.Code) && u.Id != sysRegion.Id); if (isExist) throw Oops.Oh(ErrorCodeEnum.R2002); //// 父Id不能为自己的子节点 //var regionTreeList = await _sysRegionRep.AsQueryable().ToChildListAsync(u => u.Pid, input.Id, true); //var childIdList = regionTreeList.Select(u => u.Id).ToList(); //if (childIdList.Contains(input.Pid)) // throw Oops.Oh(ErrorCodeEnum.R2001); await _sysRegionRep.AsUpdateable(input.Adapt()).IgnoreColumns(true).ExecuteCommandAsync(); } /// /// 删除行政区域 🔖 /// /// /// [ApiDescriptionSettings(Name = "Delete"), HttpPost] [DisplayName("删除行政区域")] public async Task DeleteRegion(DeleteRegionInput input) { var regionTreeList = await _sysRegionRep.AsQueryable().ToChildListAsync(u => u.Pid, input.Id, true); var regionIdList = regionTreeList.Select(u => u.Id).ToList(); await _sysRegionRep.DeleteAsync(u => regionIdList.Contains(u.Id)); } /// /// 同步行政区域 🔖 /// /// [DisplayName("同步行政区域")] public async Task Sync() { await _sysRegionRep.DeleteAsync(u => u.Id > 0); //var context = BrowsingContext.New(AngleSharp.Configuration.Default.WithDefaultLoader()); //var dom = await context.OpenAsync(_url); //// 省级 //var itemList = dom.QuerySelectorAll("table.provincetable tr.provincetr td a"); //foreach (IHtmlAnchorElement item in itemList) //{ // var region = await _sysRegionRep.InsertReturnEntityAsync(new SysRegion // { // Pid = 0, // Name = item.TextContent, // Remark = item.Href, // Level = 1, // }); // // 市级 // if (string.IsNullOrEmpty(item.Href)) // continue; // var dom1 = await context.OpenAsync(item.Href); // var itemList1 = dom1.QuerySelectorAll("table.citytable tr.citytr td a"); // for (var i1 = 0; i1 < itemList1.Length; i1 += 2) // { // var item1 = (IHtmlAnchorElement)itemList1[i1 + 1]; // var region1 = await _sysRegionRep.InsertReturnEntityAsync(new SysRegion // { // Pid = region.Id, // Name = item1.TextContent, // Code = itemList1[i1].TextContent, // Remark = item1.Href, // Level = 2, // }); // // 区县级 // if (string.IsNullOrEmpty(item1.Href)) // continue; // var dom2 = await context.OpenAsync(item1.Href); // var itemList2 = dom2.QuerySelectorAll("table.countytable tr.countytr td a"); // for (var i2 = 0; i2 < itemList2.Length; i2 += 2) // { // var item2 = (IHtmlAnchorElement)itemList2[i2 + 1]; // var region2 = await _sysRegionRep.InsertReturnEntityAsync(new SysRegion // { // Pid = region1.Id, // Name = item2.TextContent, // Code = itemList2[i2].TextContent, // Remark = item2.Href, // Level = 3, // }); // // 街道级 // if (string.IsNullOrEmpty(item2.Href)) // continue; // var dom3 = await context.OpenAsync(item2.Href); // var itemList3 = dom3.QuerySelectorAll("table.towntable tr.towntr td a"); // for (var i3 = 0; i3 < itemList3.Length; i3 += 2) // { // var item3 = (IHtmlAnchorElement)itemList3[i3 + 1]; // var region3 = await _sysRegionRep.InsertReturnEntityAsync(new SysRegion // { // Pid = region2.Id, // Name = item3.TextContent, // Code = itemList3[i3].TextContent, // Remark = item3.Href, // Level = 4, // }); // // 村级 // if (string.IsNullOrEmpty(item3.Href)) // continue; // var dom4 = await context.OpenAsync(item3.Href); // var itemList4 = dom4.QuerySelectorAll("table.villagetable tr.villagetr td"); // for (var i4 = 0; i4 < itemList4.Length; i4 += 3) // { // await _sysRegionRep.InsertAsync(new SysRegion // { // Pid = region3.Id, // Name = itemList4[i4 + 2].TextContent, // Code = itemList4[i4].TextContent, // CityCode = itemList4[i4 + 1].TextContent, // Level = 5, // }); // } // } // } // } //} } }