【国家地址库】省市区三级数据生成方案

最近做了一套国家三级地址库前后端生成方案。因为是从国家民政部获取的官方数据，与网络上各种各样的地址库产品相比，自己比较满意。

给大家介绍一下思路：

1. 获取国家民政部官方数据：http://www.mca.gov.cn/article/sj/xzqh/2020/
2. 后端ETL这些数据，放入数据库中。
3. 前端按照Element UI的组件element-china-area-data引入，替换其中省市区数据源，分离一个app.js，即可使用。

结果展示：

 

具体方案如图：

[文字留底]

地址库组件
    生成
        数据库：省市区表
            1. 从国家民政部获取最新行政区划代码。
                http://www.mca.gov.cn/article/sj/xzqh/2020/
            2. 放入Excel，按照尾部00、0000拆分出省、市、区。
            3. 用kettle按照设计表的规则导入mysql，不存在的省或市表主键设置为0。
            4. 生成insert语句。
        前端element-china-area-data控件
            后端写一个小程序，依照“数据库表”和“element-china-area-data数据格式”生成前端行政区划json数据。
                https://www.npmjs.com/package/element-china-area-data
            json数据，压缩成一行，替换element-china-area-data控件数据。
                https://www.sojson.com/yasuo.html
    维护
        民政部数据更新
            大约几个月会更新一次。
        数据库省市区表最新版与上一版数据比对
            差异
                区划代码
                名称
                所属二级或一级
            影响是什么？
                新增
                    无影响
                修改
                    新旧的区划代码不一致
                删除
                    合并
                        新旧的区划代码不一致
            方案：存储时，区划代码和名称都存储，作为快照；变更仅影响新的。
                不用比对
                    element-china-area-data控件json数据与民政部数据比对？
                        不用

[后端]

相关表

CREATE TABLE `bd_province`  (
  `province_id` bigint(20) UNSIGNED NOT NULL COMMENT '表主键id 全局唯一, snowflake id',
  `adr_code` int(11) NOT NULL COMMENT '行政区划代码 administrative division 唯一依据',
  `adr_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '行政区划单位名称 有一个名称最长45位',
  `full_pinyin` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '名称全拼 需要200的长度，用于搜索',
  `short_pinyin` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '名称短拼音 有一个名称最长45位，用于搜索',
  `longitude` decimal(32, 10) NULL DEFAULT NULL COMMENT '中心点经度 从高德地图接口获取',
  `latitude` decimal(32, 10) NULL DEFAULT NULL COMMENT '中心点纬度 从高德地图接口获取',
  `creator_id` bigint(20) UNSIGNED NOT NULL DEFAULT 0 COMMENT '创建人ID 默认0',
  `create_time` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '创建时间',
  `modifier_id` bigint(20) UNSIGNED NOT NULL DEFAULT 0 COMMENT '修改人ID 默认0',
  `modify_time` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '修改时间 自动更新',
  `deleted` tinyint(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '逻辑删除标识 0是未删除，1是已删除。',
  PRIMARY KEY (`province_id`) USING BTREE,
  UNIQUE INDEX `uk_adr_code`(`adr_code`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '行政划分-省和直辖市表 ' ROW_FORMAT = Dynamic;

CREATE TABLE `bd_city`  (
  `city_id` bigint(20) UNSIGNED NOT NULL COMMENT '表主键id 全局唯一, snowflake id',
  `province_id` bigint(20) UNSIGNED NOT NULL COMMENT '所属省ID',
  `province_code` int(11) NULL DEFAULT NULL COMMENT '所属省代码 冗余',
  `adr_code` int(11) NOT NULL COMMENT '行政区划代码 administrative division 唯一依据',
  `adr_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '行政区划单位名称 有一个名称最长45位',
  `full_pinyin` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '名称全拼 需要200的长度，用于搜索',
  `short_pinyin` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '名称短拼音 有一个名称最长45位，用于搜索',
  `longitude` decimal(32, 10) NULL DEFAULT NULL COMMENT '中心点经度 从高德地图接口获取',
  `latitude` decimal(32, 10) NULL DEFAULT NULL COMMENT '中心点纬度 从高德地图接口获取',
  `creator_id` bigint(20) UNSIGNED NOT NULL DEFAULT 0 COMMENT '创建人ID 默认0',
  `create_time` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '创建时间',
  `modifier_id` bigint(20) UNSIGNED NOT NULL DEFAULT 0 COMMENT '修改人ID 默认0',
  `modify_time` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '修改时间 自动更新',
  `deleted` tinyint(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '逻辑删除标识 0是未删除，1是已删除。',
  PRIMARY KEY (`city_id`) USING BTREE,
  UNIQUE INDEX `uk_adr_code`(`adr_code`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '行政划分-城市表 ' ROW_FORMAT = Dynamic;

CREATE TABLE `bd_district`  (
  `district_id` bigint(20) UNSIGNED NOT NULL COMMENT '表主键id 全局唯一, snowflake id',
  `city_id` bigint(20) UNSIGNED NOT NULL COMMENT '所属市ID',
  `city_code` int(11) NULL DEFAULT NULL COMMENT '所属市代码 冗余',
  `adr_code` int(11) NOT NULL COMMENT '行政区划代码 唯一依据',
  `adr_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '行政区划单位名称 有一个名称最长45位',
  `full_pinyin` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '名称全拼 需要200的长度，用于搜索',
  `short_pinyin` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '名称短拼音 有一个名称最长45位，用于搜索',
  `longitude` decimal(32, 10) NULL DEFAULT NULL COMMENT '中心点经度',
  `latitude` decimal(32, 10) NULL DEFAULT NULL COMMENT '中心点纬度',
  `creator_id` bigint(20) UNSIGNED NOT NULL DEFAULT 0 COMMENT '创建人ID 默认0',
  `create_time` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '创建时间',
  `modifier_id` bigint(20) UNSIGNED NOT NULL DEFAULT 0 COMMENT '修改人ID 默认0',
  `modify_time` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '修改时间 自动更新',
  `deleted` tinyint(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '逻辑删除标识 0是未删除，1是已删除；默认0。',
  PRIMARY KEY (`district_id`) USING BTREE,
  UNIQUE INDEX `uk_adr_code`(`adr_code`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '行政划分-区县表 ' ROW_FORMAT = Dynamic;

相关代码

package cn.com.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.*;

/**
 * 区县实现类
 * 
 * @author Mike
 * 2020/9/1 15:05
 */
@Service
public class DistrictServiceImpl implements DistrictService {

    @Autowired
    private ProvinceMapper provinceMapper;

    @Autowired
    private CityMapper cityMapper;

    @Autowired
    private DistrictMapper districtMapper;

    /**
     * 生成Element UI 地址库控件数据源，用于替换为最新国家民政部发布的三级地址库信息。
     *
     * @author Mike
     * 2020/8/27 17:39
     */
    @Override
    public Result generateAdrInfo() {
        Map<String, Map> result = new HashMap();
        QueryWrapper queryWrapper = new QueryWrapper();

        //省
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        HashMap hmProvince = new HashMap();
        queryWrapper.select("adr_code", "adr_name");
        List<Province> provinceList = provinceMapper.selectList(queryWrapper);
        for (Province item : provinceList) {
            hmProvince.put(item.getAdrCode(), item.getAdrName());
        }
        result.put("86", hmProvince);
        int countProvince = hmProvince.size();

        //市
        queryWrapper.clear();
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        queryWrapper.select("province_code", "adr_code", "adr_name");
        queryWrapper.orderByAsc("province_code", "adr_code");
        List<City> cityList = cityMapper.selectList(queryWrapper);
        Integer tempProvinceCode = cityList.get(0).getProvinceCode();
        HashMap hmCity = new HashMap();
        int countCity = 0;
        for (City item : cityList) {
            if (!item.getProvinceCode().equals(tempProvinceCode)) {
                HashMap tempHashMap = (HashMap) hmCity.clone();
                result.put(tempProvinceCode.toString(), tempHashMap);
                tempProvinceCode = item.getProvinceCode();
                countCity = countCity + hmCity.size();
                hmCity = new HashMap();
            }
            hmCity.put(item.getAdrCode(), item.getAdrName());
        }
        result.put(cityList.get(cityList.size() - 1).getProvinceCode().toString(), hmCity);
        countCity = countCity + hmCity.size();

        //区
        queryWrapper.clear();
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        queryWrapper.select("city_code", "adr_code", "adr_name");
        queryWrapper.orderByAsc("city_code", "adr_code");
        List<District> districtList = districtMapper.selectList(queryWrapper);
        Integer tempCityCode = districtList.get(0).getCityCode();
        HashMap hmDistrict = new HashMap();
        int countDistrict = 0;
        for (District item : districtList) {
            if (!item.getCityCode().equals(tempCityCode)) {
                HashMap tempHashMap = (HashMap) hmDistrict.clone();
                result.put(tempCityCode.toString(), tempHashMap);
                tempCityCode = item.getCityCode();
                countDistrict = countDistrict + hmDistrict.size();
                hmDistrict = new HashMap();
            }
            hmDistrict.put(item.getAdrCode(), item.getAdrName());
        }
        result.put(districtList.get(districtList.size() - 1).getCityCode().toString(), hmDistrict);
        countDistrict = countDistrict + hmDistrict.size();

        return new Result(SUCCESS,
                String.format("%tF 最新省市区数据生成成功！其中省(直辖市)有%d个，市有%d个，区有%d个。",
                        new Date(), countProvince, countCity, countDistrict),
                result);
    }
}

后来代码增加了生成手机端 json格式的部分：

/**
     * 生成Element UI 地址库控件数据源，用于替换为最新国家民政部发布的三级地址库信息。
     *
     * @author Mike
     * 2020/8/27 17:39
     */
    @Override
    public Result generateAdrInfo(Integer mode) {
        if (mode.equals(1)) {
            return mode1();
        }
        if (mode.equals(2)) {
            return mode2();
        }
        return null;
    }

    /**
     * 模式1的json
     *
     * @author Mike
     * 2020/9/8 18:26
     */
    private Result mode1() {
        Map<String, Map> result = new HashMap();
        QueryWrapper queryWrapper = new QueryWrapper();

        //省
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        HashMap hmProvince = new HashMap();
        queryWrapper.select("adr_code", "adr_name");
        List<Province> provinceList = provinceMapper.selectList(queryWrapper);
        for (Province item : provinceList) {
            hmProvince.put(item.getAdrCode(), item.getAdrName());
        }
        result.put("86", hmProvince);
        int countProvince = hmProvince.size();

        //市
        queryWrapper.clear();
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        queryWrapper.select("province_code", "adr_code", "adr_name");
        queryWrapper.orderByAsc("province_code", "adr_code");
        List<City> cityList = cityMapper.selectList(queryWrapper);
        Integer tempProvinceCode = cityList.get(0).getProvinceCode();
        HashMap hmCity = new HashMap();
        int countCity = 0;
        for (City item : cityList) {
            if (!item.getProvinceCode().equals(tempProvinceCode)) {
                HashMap tempHashMap = (HashMap) hmCity.clone();
                result.put(tempProvinceCode.toString(), tempHashMap);
                tempProvinceCode = item.getProvinceCode();
                countCity = countCity + hmCity.size();
                hmCity = new HashMap();
            }
            hmCity.put(item.getAdrCode(), item.getAdrName());
        }
        result.put(cityList.get(cityList.size() - 1).getProvinceCode().toString(), hmCity);
        countCity = countCity + hmCity.size();

        //区
        queryWrapper.clear();
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        queryWrapper.select("city_code", "adr_code", "adr_name");
        queryWrapper.orderByAsc("city_code", "adr_code");
        List<District> districtList = districtMapper.selectList(queryWrapper);
        Integer tempCityCode = districtList.get(0).getCityCode();
        HashMap hmDistrict = new HashMap();
        int countDistrict = 0;
        for (District item : districtList) {
            if (!item.getCityCode().equals(tempCityCode)) {
                HashMap tempHashMap = (HashMap) hmDistrict.clone();
                result.put(tempCityCode.toString(), tempHashMap);
                tempCityCode = item.getCityCode();
                countDistrict = countDistrict + hmDistrict.size();
                hmDistrict = new HashMap();
            }
            hmDistrict.put(item.getAdrCode(), item.getAdrName());
        }
        result.put(districtList.get(districtList.size() - 1).getCityCode().toString(), hmDistrict);
        countDistrict = countDistrict + hmDistrict.size();

        return new Result(SUCCESS,
                String.format("%tF 最新省市区数据生成成功！其中省(直辖市)有%d个，市有%d个，区有%d个。",
                        new Date(), countProvince, countCity, countDistrict),
                result);
    }

    /**
     * 模式2的json
     *
     * @author Mike
     * 2020/9/8 18:28
     */
    private Result mode2() {
        List<Province> result = new ArrayList<>();
        QueryWrapper queryWrapper = new QueryWrapper();

        //省
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        queryWrapper.select("adr_code", "adr_name");
        result = provinceMapper.selectList(queryWrapper);
        int countProvince = result.size();

        //市
        queryWrapper.clear();
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        queryWrapper.select("province_code", "adr_code", "adr_name");
        queryWrapper.orderByAsc("province_code", "adr_code");
        List<City> dbCityList = cityMapper.selectList(queryWrapper);
        int countCity = dbCityList.size();
        for (Province p : result) {
            p.setCityList(dbCityList
                    .stream()
                    .filter(city -> city.getProvinceCode().equals(p.getAdrCode()))
                    .collect(Collectors.toList()));
        }

        //区
        queryWrapper.clear();
        queryWrapper.eq("deleted", DeletableEnum.NOT_DELETED.ordinal());
        queryWrapper.select("city_code", "adr_code", "adr_name");
        queryWrapper.orderByAsc("city_code", "adr_code");
        List<District> dbDistrictList = districtMapper.selectList(queryWrapper);
        int countDistrict = dbDistrictList.size();
        for (Province p : result) {
            for (City c : p.getCityList()) {
                c.setDistrictList(dbDistrictList
                        .stream()
                        .filter(district -> district.getCityCode().equals(c.getAdrCode()))
                        .collect(Collectors.toList()));
            }
        }

        return new Result(SUCCESS,
                String.format("%tF 手机端使用的json格式，最新省市区数据生成成功！其中省(直辖市)有%d个，市有%d个，区有%d个。",
                        new Date(), countProvince, countCity, countDistrict),
                result);
    }

以上文件在百度网盘可下载（永久有效）：

链接：https://pan.baidu.com/s/1_OIgSUULPZDcn0W8yG7Thg
提取码：x6ig