飞滴出行网约车2022-service-map-入库第三方地图地区字典

internal-common/src/main/java/com/mashibing/internalcommon/constant/AmapConfigConstants.java

@@ -20,4 +20,10 @@ public class AmapConfigConstants {
     public static final String DISTANCE = "distance";
     public static final String DURATION = "duration";
 
+    public static final String DISTRICTS = "districts";
+    public static final String ADCODE = "adcode";
+    public static final String NAME = "name";
+    public static final String LEVEL = "level";
+    public static final String STREET = "street" ;
+
 }

internal-common/src/main/java/com/mashibing/internalcommon/constant/CommonStatusEnum.java

@@ -31,6 +31,12 @@ public enum  CommonStatusEnum {
      */
     ,PRICE_RULE_EMPTY(1300,"计价规则不存在")
 
+    /**
+     地图信息：1400-1499
+     */
+    ,MAP_DISTRICT_ERROR(1400,"请求地图错误")
+
+
     ;
 
 

service-map/src/main/java/com/mashibing/servicemap/remote/MapDicDistrictClient.java

@@ -34,7 +34,7 @@ public class MapDicDistrictClient {
         // 发起 结果拉取请求
         ResponseEntity<String> forEntity = restTemplate.getForEntity(url.toString(), String.class);
 
-        return forEntity.toString();
+        return forEntity.getBody();
     }
 
 }

service-map/src/main/java/com/mashibing/servicemap/service/DicDistrictService.java

@@ -1,8 +1,13 @@
 package com.mashibing.servicemap.service;
 
 import com.mashibing.internalcommon.constant.AmapConfigConstants;
+import com.mashibing.internalcommon.constant.CommonStatusEnum;
+import com.mashibing.internalcommon.dto.DicDistrict;
 import com.mashibing.internalcommon.dto.ResponseResult;
+import com.mashibing.servicemap.mapper.DicDistrictMapper;
 import com.mashibing.servicemap.remote.MapDicDistrictClient;
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
@@ -14,15 +19,118 @@ public class DicDistrictService {
     @Autowired
     private MapDicDistrictClient mapDicDistrictClient;
 
+    @Autowired
+    private DicDistrictMapper dicDistrictMapper;
+
     public ResponseResult initDicDistrict(String keywords){
 
         // 请求第三方接口，拉取区域编号信息
-        String dicDistrict = mapDicDistrictClient.dicDistrict(keywords);
+        String dicDistrictResultStr = mapDicDistrictClient.dicDistrict(keywords);
-        System.out.println("\n\ndicDistrict = " + dicDistrict);
+        System.out.println("dicDistrictResultStr = " + dicDistrictResultStr);
 
         // 解析 结果
+        JSONObject resultJobj = JSONObject.fromObject(dicDistrictResultStr);
+        int status = resultJobj.getInt(AmapConfigConstants.STATUS);
+        // 错误响应 返回失败
+        if(status != 1){
+            ResponseResult.fail(CommonStatusEnum.MAP_DISTRICT_ERROR.getCode(),CommonStatusEnum.MAP_DISTRICT_ERROR.getValue());
+        }
+
+        // 正确响应 则进行详细解析
+        JSONArray resultJobjArr = resultJobj.getJSONArray(AmapConfigConstants.DISTRICTS);
+
+        // 遍历 解析 所有节点信息
+        for (int i = 0; i < resultJobjArr.size(); i++) {
+
+            // 0 国家节点下的信息
+            JSONObject contryJobj = resultJobjArr.getJSONObject(i);
+
+            String contryAddresscode = contryJobj.getString(AmapConfigConstants.ADCODE) ;
+            String contryAddressName = contryJobj.getString(AmapConfigConstants.NAME) ;
+            String contryParentAddressCode = "0" ;
+            String contryLevel = contryJobj.getString(AmapConfigConstants.LEVEL) ;
+            // 持久化 国家节点信息
+            saveDicDistrictObj(contryAddresscode,contryAddressName,contryParentAddressCode,contryLevel);
+
+
+            // 解析 省
+            JSONArray provinceJobjArr = contryJobj.getJSONArray(AmapConfigConstants.DISTRICTS);
+            for (int p = 0; p < provinceJobjArr.size(); p++) {
+                JSONObject provinceJobj = provinceJobjArr.getJSONObject(p);
+
+                // 持久化  省 节点信息
+                String provinceAddresscode = provinceJobj.getString(AmapConfigConstants.ADCODE) ;
+                String provinceAddressName = provinceJobj.getString(AmapConfigConstants.NAME) ;
+                String provinceParentAddressCode = contryAddresscode;
+                String provinceLevel = provinceJobj.getString(AmapConfigConstants.LEVEL) ;
+                saveDicDistrictObj(provinceAddresscode,provinceAddressName,provinceParentAddressCode,provinceLevel);
+
+
+
+                // 解析 市
+                JSONArray cityJobjArr = provinceJobj.getJSONArray(AmapConfigConstants.DISTRICTS);
+                for (int c = 0;c< cityJobjArr.size();c++) {
+
+                    // 持久化 市 节点信息
+                    JSONObject cityJobj = cityJobjArr.getJSONObject(c);
+                    String cityAddressCode = cityJobj.getString(AmapConfigConstants.ADCODE);
+                    String cityAddressName = cityJobj.getString(AmapConfigConstants.NAME);
+                    String cityParentAddressCode = provinceAddresscode;
+                    String cityLevel = cityJobj.getString(AmapConfigConstants.LEVEL);
+                    saveDicDistrictObj(cityAddressCode, cityAddressName, cityParentAddressCode, cityLevel);
+
+
+                    // 解析 区
+                    JSONArray districtArray = cityJobj.getJSONArray(AmapConfigConstants.DISTRICTS);
+                    for (int d = 0; d < districtArray.size(); d++) {
+
+                        // 持久化 区 节点信息
+                        JSONObject districtJobj = districtArray.getJSONObject(d);
+                        String districtAddressCode = districtJobj.getString(AmapConfigConstants.ADCODE);
+                        String districtAddressName = districtJobj.getString(AmapConfigConstants.NAME);
+                        String districtLevelParentAddressCode = cityAddressCode;
+                        String districtLevelLevel = districtJobj.getString(AmapConfigConstants.LEVEL);
+                        // 暂不解析 街道
+                        if(districtLevelLevel.equals(AmapConfigConstants.STREET)){
+                            continue;
+                        }
+                        saveDicDistrictObj(districtAddressCode, districtAddressName, districtLevelParentAddressCode, districtLevelLevel);
+
+                    }
+                }
+
+            }
+
+        }
+
+
 
         return ResponseResult.success();
     }
 
+    private void saveDicDistrictObj(String addresscode,String addressName,String parentAddressCode,String levelStr){
+        DicDistrict district = new DicDistrict();
+        district.setAddressCode(addresscode);
+        district.setAddressName(addressName);
+        Integer level = generatelevel(levelStr);
+        district.setLevel(level) ;
+        district.setParentAddressCode(parentAddressCode);
+
+        dicDistrictMapper.insert(district);
+    }
+
+    private int generatelevel(String level) {
+        int levelInt = 0;
+        if (level.trim().equals("country")) {
+            levelInt = 0;
+        } else if (level.trim().equals("province")) {
+            levelInt = 1;
+        } else if (level.trim().equals("city")) {
+            levelInt = 2;
+        } else if (level.trim().equals("district")) {
+            levelInt = 3;
+        }
+        return levelInt;
+    }
+
 }