736 lines
28 KiB
C#
736 lines
28 KiB
C#
// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
|
||
//
|
||
// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
|
||
//
|
||
// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
|
||
|
||
using Furion.Shapeless;
|
||
|
||
namespace Admin.NET.Core.Service;
|
||
|
||
/// <summary>
|
||
/// 系统行政区划服务 🧩
|
||
/// </summary>
|
||
[ApiDescriptionSettings(Order = 310, Description = "行政区划")]
|
||
public class SysRegionService : IDynamicApiController, ITransient
|
||
{
|
||
private readonly SqlSugarRepository<SysRegion> _sysRegionRep;
|
||
private readonly IHttpRemoteService _httpRemoteService;
|
||
|
||
public SysRegionService(SqlSugarRepository<SysRegion> sysRegionRep, IHttpRemoteService httpRemoteService)
|
||
{
|
||
_sysRegionRep = sysRegionRep;
|
||
_httpRemoteService = httpRemoteService;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取行政区划分页列表 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[DisplayName("获取行政区划分页列表")]
|
||
public async Task<SqlSugarPagedList<SysRegion>> 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))
|
||
.OrderBy(u => new { u.Code })
|
||
.ToPagedListAsync(input.Page, input.PageSize);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取行政区划列表 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[DisplayName("获取行政区划列表")]
|
||
public async Task<List<SysRegion>> GetList([FromQuery] RegionInput input)
|
||
{
|
||
return await _sysRegionRep.GetListAsync(u => u.Pid == input.Id);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取指定层级行政区划子树 🔖
|
||
/// </summary>
|
||
/// <param name="pid"></param>
|
||
/// <param name="level"></param>
|
||
/// <returns></returns>
|
||
[DisplayName("获取指定层级行政区划子树")]
|
||
public async Task<List<SysRegion>> GetChildTree(long pid, int level)
|
||
{
|
||
var iSugarQueryable = _sysRegionRep.AsQueryable().OrderBy(u => new { u.Code });
|
||
return await iSugarQueryable.Where(u => u.Level < level).ToTreeAsync(u => u.Children, u => u.Pid, pid);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取指定层级行政区划子列表 🔖
|
||
/// </summary>
|
||
/// <param name="pid"></param>
|
||
/// <returns></returns>
|
||
[DisplayName("获取指定层级行政区划子列表")]
|
||
public async Task<List<SysRegion>> GetChildList(long pid)
|
||
{
|
||
return await _sysRegionRep.AsQueryable().Where(u => u.Pid == pid).OrderBy(u => new { u.Code }).ToListAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询行政区划列表 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[ApiDescriptionSettings(Name = "Query"), HttpPost]
|
||
[DisplayName("查询行政区划列表")]
|
||
public async Task<List<SysRegion>> QueryList(QueryRegionInput input)
|
||
{
|
||
return await _sysRegionRep.AsQueryable()
|
||
.WhereIF(input.Pid.HasValue, u => u.Pid == input.Pid)
|
||
.WhereIF(!string.IsNullOrWhiteSpace(input.Type), u => u.Type == input.Type)
|
||
.WhereIF(!string.IsNullOrWhiteSpace(input.Name), u => u.Name.Contains(input.Name))
|
||
.WhereIF(!string.IsNullOrWhiteSpace(input.Code), u => u.Code.Contains(input.Code))
|
||
.OrderBy(u => new { u.Code })
|
||
.ToListAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 增加行政区划 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[ApiDescriptionSettings(Name = "Add"), HttpPost]
|
||
[DisplayName("增加行政区划")]
|
||
public async Task<long> AddRegion(AddRegionInput input)
|
||
{
|
||
input.Code = input.Code?.Trim() ?? "";
|
||
if (input.Code.Length != 12 && input.Code.Length != 9 && input.Code.Length != 6) throw Oops.Oh(ErrorCodeEnum.R2003);
|
||
|
||
if (input.Pid != 0)
|
||
{
|
||
var pRegion = await _sysRegionRep.GetByIdAsync(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<SysRegion>();
|
||
var newRegion = await _sysRegionRep.AsInsertable(sysRegion).ExecuteReturnEntityAsync();
|
||
return newRegion.Id;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更新行政区划 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[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(ErrorCodeEnum.R2003);
|
||
|
||
var sysRegion = await _sysRegionRep.GetByIdAsync(input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
||
|
||
if (sysRegion.Pid != input.Pid && input.Pid != 0)
|
||
{
|
||
var pRegion = await _sysRegionRep.GetByIdAsync(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(ErrorCodeEnum.R2004);
|
||
}
|
||
|
||
if (input.Id == input.Pid) throw Oops.Oh(ErrorCodeEnum.R2001);
|
||
|
||
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<SysRegion>()).IgnoreColumns(true).ExecuteCommandAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 删除行政区划 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[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));
|
||
}
|
||
|
||
/// <summary>
|
||
/// 同步行政区划（民政部） 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[DisplayName("同步行政区划（民政部）")]
|
||
public async Task SyncRegionMzb(MzbInput input)
|
||
{
|
||
try
|
||
{
|
||
var html = await _httpRemoteService.GetAsStringAsync("http://xzqh.mca.gov.cn/map");
|
||
var municipalityList = new List<string> { "北京", "天津", "上海", "重庆" };
|
||
|
||
var proJson = Regex.Match(html, @"(?<=var json = )(\[\{.*?\}\])(?=;)").Value;
|
||
dynamic provList = Clay.Parse(proJson);
|
||
|
||
var list = new List<SysRegion>();
|
||
foreach (var proItem in provList)
|
||
{
|
||
var provName = proItem.shengji;
|
||
var province = new SysRegion
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
Name = Regex.Replace(provName, "[(（].*?[）)]", ""),
|
||
Code = proItem.quHuaDaiMa,
|
||
CityCode = proItem.quhao,
|
||
Level = 1,
|
||
Pid = 0,
|
||
};
|
||
//if (municipalityList.Any(u => province.Name.StartsWith(u))) province.Name += "(省)";
|
||
list.Add(province);
|
||
|
||
if (input.Level <= 1) continue;
|
||
|
||
var cityList = await GetSelectList(provName);
|
||
foreach (var cityItem in cityList)
|
||
{
|
||
var cityName = cityItem.diji;
|
||
var city = new SysRegion
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
Code = cityItem.quHuaDaiMa,
|
||
CityCode = cityItem.quhao,
|
||
Pid = province.Id,
|
||
Name = cityName,
|
||
Level = 2
|
||
};
|
||
if (municipalityList.Any(u => city.Name.StartsWith(u)))
|
||
{
|
||
city.Name = "市辖区";
|
||
if (province.Code == city.Code) city.Code = province.Code.Substring(0, 2) + "0100";
|
||
}
|
||
list.Add(city);
|
||
|
||
if (input.Level <= 2) continue;
|
||
|
||
var countyList = await GetSelectList(provName, cityName);
|
||
foreach (var countyItem in countyList)
|
||
{
|
||
var countyName = countyItem.xianji;
|
||
var county = new SysRegion
|
||
{
|
||
Id = YitIdHelper.NextId(),
|
||
Code = countyItem.quHuaDaiMa,
|
||
CityCode = countyItem.quhao,
|
||
Name = countyName,
|
||
Pid = city.Id,
|
||
Level = 3
|
||
};
|
||
if (city.Code.IsNullOrEmpty())
|
||
{
|
||
// 省直辖县级行政单位 节点无Code编码处理
|
||
city.Code = county.Code.Substring(0, 3).PadRight(6, '0');
|
||
}
|
||
list.Add(county);
|
||
}
|
||
}
|
||
}
|
||
|
||
if (list.Count > 0)
|
||
{
|
||
await _sysRegionRep.AsDeleteable().ExecuteCommandAsync();
|
||
await _sysRegionRep.Context.Fastest<SysRegion>().BulkCopyAsync(list);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
throw Oops.Oh(ex);
|
||
}
|
||
|
||
// 获取选择数据
|
||
async Task<Clay> GetSelectList(string prov, string prefecture = null)
|
||
{
|
||
var json = await _httpRemoteService.PostAsStringAsync("http://xzqh.mca.gov.cn/selectJson", builder => builder.SetJsonContent(new
|
||
{
|
||
shengji = prov,
|
||
diji = prefecture,
|
||
}));
|
||
return Clay.Parse(json);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 同步行政区划（高德） 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[DisplayName("同步行政区划（高德）")]
|
||
public async Task SyncRegionGD(GDInput input)
|
||
{
|
||
if (string.IsNullOrWhiteSpace(input.Key) || input.Key.Length < 30)
|
||
throw Oops.Oh("请正确输入高德地图开发者 Key 值");
|
||
|
||
var res = await _httpRemoteService.GetAsync($"https://restapi.amap.com/v3/config/district?keywords={input.Keywords}&subdistrict={input.Level}&key={input.Key}");
|
||
if (!res.IsSuccessStatusCode) return;
|
||
|
||
var gdResponse = JSON.Deserialize<GDResponse<List<GDRegionResponse>>>(res.Content.ReadAsStringAsync().Result);
|
||
if (gdResponse.info != "OK" || gdResponse.districts == null || gdResponse.districts.Count < 1) return;
|
||
|
||
var regionList = new List<SysRegion>();
|
||
foreach (var item in gdResponse.districts)
|
||
{
|
||
GetChildren(regionList, item.districts, 1, 0); // 排除一级目录（国家）
|
||
}
|
||
|
||
await _sysRegionRep.AsDeleteable().ExecuteCommandAsync();
|
||
await _sysRegionRep.Context.Fastest<SysRegion>().BulkCopyAsync(regionList);
|
||
}
|
||
|
||
private static void GetChildren(List<SysRegion> regionList, List<GDRegionResponse> responses, int level, long pid)
|
||
{
|
||
foreach (var region in responses)
|
||
{
|
||
var sysRegion = new SysRegion { Id = YitIdHelper.NextId(), Pid = pid, Name = region.name, Code = region.adcode, CityCode = region.adcode, Level = level };
|
||
regionList.Add(sysRegion);
|
||
|
||
if (region.districts.Count > 0)
|
||
GetChildren(regionList, region.districts, level++, sysRegion.Id);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 同步行政区划数据（国家地名信息库，最多支持2级深度） 🔖
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[DisplayName("同步行政区划数据（国家地名信息库）")]
|
||
public async Task<int> SyncRegionMca(McaInput input)
|
||
{
|
||
var url = $"https://dmfw.mca.gov.cn/9095/xzqh/getList?code={input.Code}&maxLevel={input.Level}";
|
||
|
||
var res = await _httpRemoteService.GetAsStreamAsync(url);
|
||
SysRegion regionLevel0 = ((dynamic)Clay.Parse(res)).data;
|
||
if (regionLevel0 == null) return 0;
|
||
|
||
var areaList = new List<SysRegion>();
|
||
if (regionLevel0.Code != "00" && regionLevel0.Level > 0 && !string.IsNullOrEmpty(regionLevel0.Name))
|
||
{
|
||
areaList.Add(new SysRegion
|
||
{
|
||
Id = Convert.ToInt64(regionLevel0.Code),
|
||
Pid = 0,
|
||
Code = regionLevel0.Code,
|
||
Name = regionLevel0.Name,
|
||
Type = regionLevel0.Type,
|
||
Level = regionLevel0.Level,
|
||
});
|
||
}
|
||
if (regionLevel0.Children != null)
|
||
{
|
||
foreach (var regionLevel1 in regionLevel0.Children)
|
||
{
|
||
var region1 = new SysRegion
|
||
{
|
||
Id = Convert.ToInt64(regionLevel1.Code),
|
||
Pid = Convert.ToInt64(regionLevel0.Code),
|
||
Code = regionLevel1.Code,
|
||
Name = regionLevel1.Name,
|
||
Type = regionLevel1.Type,
|
||
Level = regionLevel1.Level,
|
||
};
|
||
if (areaList.Any(u => u.Id == region1.Id))
|
||
Console.WriteLine($"1 级：{region1.Id} - {region1.Name} 已存在");
|
||
else
|
||
areaList.Add(region1);
|
||
if (regionLevel1.Children == null) continue;
|
||
foreach (var regionLevel2 in regionLevel1.Children)
|
||
{
|
||
var region2 = new SysRegion
|
||
{
|
||
Id = Convert.ToInt64(regionLevel2.Code),
|
||
Pid = Convert.ToInt64(regionLevel1.Code),
|
||
Code = regionLevel2.Code,
|
||
Name = regionLevel2.Name,
|
||
Type = regionLevel2.Type,
|
||
Level = regionLevel2.Level,
|
||
};
|
||
if (areaList.Any(u => u.Id == region2.Id))
|
||
Console.WriteLine($"2 级：{region2.Id} - {region2.Name} 已存在");
|
||
else
|
||
areaList.Add(region2);
|
||
if (regionLevel2.Children == null) continue;
|
||
foreach (var regionLevel3 in regionLevel2.Children)
|
||
{
|
||
var region3 = new SysRegion
|
||
{
|
||
Id = Convert.ToInt64(regionLevel3.Code),
|
||
Pid = Convert.ToInt64(regionLevel2.Code),
|
||
Code = regionLevel3.Code,
|
||
Name = regionLevel3.Name,
|
||
Type = regionLevel3.Type,
|
||
Level = regionLevel3.Level,
|
||
};
|
||
if (areaList.Any(u => u.Id == region3.Id))
|
||
Console.WriteLine($"3 级：{region3.Id} - {region3.Name}");
|
||
else
|
||
areaList.Add(region3);
|
||
if (regionLevel3.Children == null) continue;
|
||
foreach (var regionLevel4 in regionLevel3.Children)
|
||
{
|
||
var region4 = new SysRegion
|
||
{
|
||
Id = Convert.ToInt64(regionLevel4.Code),
|
||
Pid = Convert.ToInt64(regionLevel3.Code),
|
||
Code = regionLevel4.Code,
|
||
Name = regionLevel4.Name,
|
||
Type = regionLevel4.Type,
|
||
Level = regionLevel4.Level,
|
||
};
|
||
areaList.Add(region4);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
if (input.Code == 0)
|
||
await _sysRegionRep.AsDeleteable().ExecuteCommandAsync();
|
||
else if (await _sysRegionRep.IsAnyAsync(u => u.Id == input.Code)) // 如果存在指定行政区划则删除
|
||
await DeleteRegion(new DeleteRegionInput { Id = input.Code });
|
||
return await _sysRegionRep.AsInsertable(areaList).ExecuteCommandAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 同步行政区划数据（天地图行政区划） 🔖
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[DisplayName("同步行政区划数据（天地图行政区划）")]
|
||
public async Task<int> SyncRegionTianditu(TiandituInput input)
|
||
{
|
||
// 接口说明及地址：http://lbs.tianditu.gov.cn/server/administrative2.html
|
||
var url = $"http://api.tianditu.gov.cn/v2/administrative?keyword={input.Keyword}&childLevel={input.ChildLevel}&extensions={input.Extensions}&tk={input.Tk}";
|
||
|
||
var res = await _httpRemoteService.GetAsAsync<TiandituDto>(url);
|
||
if (res == null || res.District == null) return 0;
|
||
|
||
var parent = res.District[0];
|
||
var areaList = new List<SysRegion>()
|
||
{
|
||
new()
|
||
{
|
||
Id = Convert.ToInt64(parent.Gb),
|
||
Pid = 0,
|
||
Code = parent.Gb,
|
||
Name = parent.Name,
|
||
Level = parent.Level,
|
||
Longitude = parent.Center.Lng,
|
||
Latitude = parent.Center.Lat
|
||
}
|
||
};
|
||
|
||
foreach (var item in parent.Children)
|
||
{
|
||
var region = new SysRegion
|
||
{
|
||
Id = Convert.ToInt64(item.Gb),
|
||
Pid = Convert.ToInt64(parent.Gb),
|
||
Code = item.Gb,
|
||
Name = item.Name,
|
||
Level = item.Level,
|
||
Longitude = item.Center.Lng,
|
||
Latitude = item.Center.Lat
|
||
};
|
||
areaList.Add(region);
|
||
|
||
foreach (var child in item.Children)
|
||
{
|
||
areaList.Add(new SysRegion
|
||
{
|
||
Id = Convert.ToInt64(child.Gb),
|
||
Pid = region.Id,
|
||
Code = child.Gb,
|
||
Name = child.Name,
|
||
Level = child.Level,
|
||
Longitude = child.Center.Lng,
|
||
Latitude = child.Center.Lat
|
||
});
|
||
}
|
||
}
|
||
|
||
// 若存在指定行政区划则删除
|
||
if (await _sysRegionRep.IsAnyAsync(u => u.Name.Contains(input.Keyword) || u.Id.ToString() == input.Keyword))
|
||
{
|
||
var region = await _sysRegionRep.GetFirstAsync(u => u.Name.Contains(input.Keyword) || u.Id.ToString() == input.Keyword);
|
||
await DeleteRegion(new DeleteRegionInput { Id = region.Id });
|
||
}
|
||
|
||
return await _sysRegionRep.AsInsertable(areaList).ExecuteCommandAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 生成组织架构 🔖
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[DisplayName("生成组织架构")]
|
||
public async Task GenOrg(GenOrgInput input)
|
||
{
|
||
var region = await _sysRegionRep.GetByIdAsync(input.Id);
|
||
var orgRep = _sysRegionRep.ChangeRepository<SqlSugarRepository<SysOrg>>();
|
||
if (!await orgRep.IsAnyAsync(u => u.Id == region.Pid))
|
||
region.Pid = 0;
|
||
|
||
var regionList = await GetRegionListByLevel(region, input.Level);
|
||
var orgList = regionList.Adapt<List<SysOrg>>();
|
||
await orgRep.InsertOrUpdateAsync(orgList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据层级获取行政区划数据
|
||
/// </summary>
|
||
/// <param name="region"></param>
|
||
/// <param name="level"></param>
|
||
/// <returns></returns>
|
||
private async Task<List<SysRegion>> GetRegionListByLevel(SysRegion region, int level)
|
||
{
|
||
var regionList = new List<SysRegion>();
|
||
if (level > 5) level = 5;
|
||
regionList.Add(region);
|
||
|
||
if (level == 1) return regionList;
|
||
var regionList2 = await GetList(new RegionInput { Id = region.Id });
|
||
regionList.AddRange(regionList2);
|
||
|
||
if (level == 2) return regionList;
|
||
foreach (var item in regionList2)
|
||
{
|
||
var regionList3 = await GetList(new RegionInput { Id = item.Id });
|
||
if (regionList3 == null) continue;
|
||
regionList.AddRange(regionList3);
|
||
|
||
if (level == 3) continue;
|
||
foreach (var item3 in regionList3)
|
||
{
|
||
var regionList4 = await GetList(new RegionInput { Id = item3.Id });
|
||
if (regionList4 == null) continue;
|
||
regionList.AddRange(regionList4);
|
||
|
||
if (level == 4) continue;
|
||
foreach (var item4 in regionList4)
|
||
{
|
||
var regionList5 = await GetList(new RegionInput { Id = item4.Id });
|
||
if (regionList5 == null) continue;
|
||
regionList.AddRange(regionList5);
|
||
}
|
||
}
|
||
}
|
||
return regionList;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 从 china.sqlite 中获取区划数据
|
||
/// </summary>
|
||
/// <param name="code">区划编码</param>
|
||
/// <param name="level">级数（从当前code所在级别往下级数）</param>
|
||
/// <returns></returns>
|
||
[DisplayName("从 china.sqlite 中获取区划数据")]
|
||
public async Task GetRegionTree(string code, int level)
|
||
{
|
||
level = level > 5 ? 5 : level;
|
||
|
||
var sqlitePath = "C:\\china.sqlite";
|
||
var db = new SqlSugarScope(new ConnectionConfig()
|
||
{
|
||
ConnectionString = $"Data Source={sqlitePath};Cache=Shared",
|
||
DbType = SqlSugar.DbType.Sqlite,
|
||
IsAutoCloseConnection = true,
|
||
InitKeyType = InitKeyType.Attribute
|
||
});
|
||
|
||
var regionList = new List<SysRegion>();
|
||
|
||
// 判断编码所属层级
|
||
int startLevel = 1; // 省
|
||
switch (code.Length)
|
||
{
|
||
case 4:
|
||
startLevel = 2; // 市
|
||
break;
|
||
|
||
case 6:
|
||
startLevel = 3; // 区县
|
||
break;
|
||
|
||
case 9:
|
||
startLevel = 4; // 街道
|
||
break;
|
||
|
||
case 12:
|
||
startLevel = 5; // 社区/村
|
||
break;
|
||
|
||
default:
|
||
break;
|
||
}
|
||
var region1List = GetRegionList(code, startLevel, db);
|
||
if (region1List.Count == 0)
|
||
return;
|
||
region1List.ForEach(u => u.Pid = 0);
|
||
regionList.AddRange(region1List);
|
||
|
||
if (level == 1 || startLevel == 5)
|
||
goto result;
|
||
startLevel++;
|
||
|
||
var region2List = new List<SysRegion>();
|
||
foreach (var item in region1List)
|
||
{
|
||
region2List.AddRange(GetRegionList(item.Code, startLevel, db));
|
||
}
|
||
regionList.AddRange(region2List);
|
||
|
||
if (level == 2 || startLevel == 5 || region2List.Count == 0)
|
||
goto result;
|
||
startLevel++;
|
||
|
||
var region3List = new List<SysRegion>();
|
||
foreach (var item in region2List)
|
||
{
|
||
region3List.AddRange(GetRegionList(item.Code, startLevel, db));
|
||
}
|
||
regionList.AddRange(region3List);
|
||
|
||
if (level == 3 || startLevel == 5 || region3List.Count == 0)
|
||
goto result;
|
||
startLevel++;
|
||
|
||
var region4List = new List<SysRegion>();
|
||
foreach (var item in region3List)
|
||
{
|
||
region4List.AddRange(GetRegionList(item.Code, startLevel, db));
|
||
}
|
||
regionList.AddRange(region4List);
|
||
|
||
if (level == 4 || startLevel == 5 || region4List.Count == 0)
|
||
goto result;
|
||
startLevel++;
|
||
|
||
var region5List = new List<SysRegion>();
|
||
region5List.AddRange(GetVillageList(region4List.Select(u => u.Code).ToList(), db));
|
||
regionList.AddRange(region5List);
|
||
|
||
result:
|
||
|
||
// 保存行政区划树
|
||
var defaultDbConfig = App.GetOptions<DbConnectionOptions>().ConnectionConfigs[0];
|
||
db = new SqlSugarScope(new ConnectionConfig()
|
||
{
|
||
ConnectionString = defaultDbConfig.ConnectionString,
|
||
DbType = defaultDbConfig.DbType,
|
||
IsAutoCloseConnection = true,
|
||
InitKeyType = InitKeyType.Attribute
|
||
});
|
||
await db.Deleteable<SysRegion>().ExecuteCommandAsync();
|
||
await db.Insertable(regionList).ExecuteCommandAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据层级及父级编码获取区域集合
|
||
/// </summary>
|
||
/// <param name="pCode"></param>
|
||
/// <param name="level"></param>
|
||
/// <param name="db"></param>
|
||
/// <returns></returns>
|
||
private static List<SysRegion> GetRegionList(string pCode, int level, SqlSugarScope db)
|
||
{
|
||
string table = "";
|
||
switch (level)
|
||
{
|
||
case 1:
|
||
table = "province";
|
||
break;
|
||
|
||
case 2:
|
||
table = "city";
|
||
break;
|
||
|
||
case 3:
|
||
table = "area";
|
||
break;
|
||
|
||
case 4:
|
||
table = "street";
|
||
break;
|
||
|
||
case 5:
|
||
table = "village";
|
||
break;
|
||
|
||
default:
|
||
break;
|
||
}
|
||
if (string.IsNullOrWhiteSpace(table))
|
||
return [];
|
||
|
||
var condition = string.IsNullOrWhiteSpace(pCode) || pCode == "0" ? "" : $" and code like '{pCode}%'";
|
||
var sql = $"select * from {table} where 1=1 {condition}";
|
||
var regions = db.Ado.SqlQuery<SysRegion>(sql);
|
||
if (regions.Count == 0)
|
||
return [];
|
||
|
||
foreach (var item in regions)
|
||
{
|
||
item.Pid = string.IsNullOrWhiteSpace(pCode) || item.Code == pCode || level == 1 ? 0 : Convert.ToInt64(pCode);
|
||
item.Level = level;
|
||
item.Id = Convert.ToInt64(item.Code);
|
||
}
|
||
|
||
return regions;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取社区/村集合
|
||
/// </summary>
|
||
/// <param name="pCodes"></param>
|
||
/// <param name="db"></param>
|
||
/// <returns></returns>
|
||
private static List<SysRegion> GetVillageList(List<string> pCodes, SqlSugarScope db)
|
||
{
|
||
var condition = pCodes == null || pCodes.Count == 0 ? "" : $" and streetCode in ('{pCodes.Join("','")}')";
|
||
var sql = $"select * from village where 1=1 {condition}";
|
||
var regions = db.Ado.SqlQuery<dynamic>(sql);
|
||
if (regions.Count == 0)
|
||
return [];
|
||
|
||
var regionList = new List<SysRegion>();
|
||
foreach (var item in regions)
|
||
{
|
||
var region = new SysRegion
|
||
{
|
||
Name = item.name,
|
||
Code = item.code,
|
||
Pid = Convert.ToInt64(item.streetCode),
|
||
Level = 5,
|
||
Id = Convert.ToInt64(item.code)
|
||
};
|
||
regionList.Add(region);
|
||
}
|
||
return regionList;
|
||
}
|
||
} |