<dependency>
    <groupId>com.googlecode.libphonenumber</groupId>
    <artifactId>libphonenumber</artifactId>
    <version>8.13.26</version>
</dependency>
<dependency>
    <groupId>com.googlecode.libphonenumber</groupId>
    <artifactId>carrier</artifactId>
    <version>1.210</version>
</dependency>
<dependency>
    <groupId>com.googlecode.libphonenumber</groupId>
    <artifactId>geocoder</artifactId>
    <version>2.220</version>
</dependency>

/**
 * @author: jiangjs
 * @description: 基于google的libphonenumber將手機(jī)號(hào)轉(zhuǎn)成地區(qū)及供應(yīng)商信息
 * @date: 2023/11/30 14:33
 **/
public class PhoneToRegionUtil {

    /**
     * 手機(jī)號(hào)基本工具類(lèi)
     */
    private final static PhoneNumberUtil PHONE_NUMBER_UTIL = PhoneNumberUtil.getInstance();

    /**
     * 運(yùn)營(yíng)商
     */
    private final static PhoneNumberToCarrierMapper CARRIER_MAPPER = PhoneNumberToCarrierMapper.getInstance();

    /**
     *
     */
    private final static PhoneNumberOfflineGeocoder GEO_CODER = PhoneNumberOfflineGeocoder.getInstance();

    /**
     * 驗(yàn)證當(dāng)前手機(jī)號(hào)是否有效
     * @param phone 手機(jī)號(hào)
     * @return 校驗(yàn)結(jié)果
     */
    public static boolean isValidNumber(String phone){
        return PHONE_NUMBER_UTIL.isValidNumber(getPhoneNumber(phone));
    }

    /**
     * 獲取手機(jī)號(hào)運(yùn)營(yíng)商
     * @param phone 手機(jī)號(hào)
     * @return 運(yùn)營(yíng)商
     */
    public static String getPhoneCarrier(String phone){
        return isValidNumber(phone) ?  CARRIER_MAPPER.getNameForNumber(getPhoneNumber(phone), Locale.CHINA) : "";
    }

    /**
     * 獲取手機(jī)號(hào)歸屬地
     * @param phone 手機(jī)號(hào)
     * @return 歸屬地
     */
    public static String getRegionInfoByPhone(String phone){
        return isValidNumber(phone) ? GEO_CODER.getDescriptionForNumber(getPhoneNumber(phone),Locale.CHINESE) : "";
    }

    /**
     * 生成PhoneNumber
     * @param phone 手機(jī)號(hào)
     * @return PhoneNumber
     */
    private static Phonenumber.PhoneNumber getPhoneNumber(String phone){
        Phonenumber.PhoneNumber phoneNumber = new Phonenumber.PhoneNumber();
        phoneNumber.setCountryCode(86);
        phoneNumber.setNationalNumber(Long.parseLong(phone));
        return phoneNumber;
    }

     /**
     * 獲取手機(jī)號(hào)的歸屬信息：運(yùn)營(yíng)商，歸屬地
     * @param phone 手機(jī)號(hào)
     * @return 歸屬信息
     */
    public static JSONObject getPhoneAffiliationInfo(String phone){
        JSONObject affiliation = new JSONObject();
        affiliation.put("phone",phone);
        affiliation.put("carrier",getPhoneCarrier(phone));
        affiliation.put("region",getRegionInfoByPhone(phone));
        return affiliation;
    }
}

@GetMapping("/getPhoneAffiliationInfo.do/{phone}")
public JsonResult<?> getPhoneAffiliationInfo(@PathVariable("phone") String phone){
    return JsonResult.success(PhoneToRegionUtil.getPhoneAffiliationInfo(phone));
}

/**
 * @author: jiangjs
 * @description: 服務(wù)啟動(dòng)后，加載數(shù)據(jù)到緩存
 * @date: 2023/12/9 15:32
 **/
@ConditionalOnProperty(havingValue = "true",value = "phoneToRegion.enabled")
@Component
public class ReadRegionToRedisStart implements CommandLineRunner {
    private final static String REGION_CSV_PATH = "classpath:/static/region/phonetmp.csv";

    private final static String PHONE_REGION_KEY = "country_phone_region_info";

    @Resource
    private ResourceLoader resourceLoader;
    @Resource
    private RedisTemplate<String,Object> redisTemplate;


    @Override
    public void run(String... args) {
        long size = redisTemplate.opsForHash().size(PHONE_REGION_KEY);
        if (size <= 0){
            try (InputStream ism = resourceLoader.getResource(REGION_CSV_PATH).getInputStream()){
                Assert.notNull(ism,"讀取手機(jī)號(hào)信息文件為空");
                BufferedReader reader = new BufferedReader(new InputStreamReader(ism));
                String line = reader.readLine();
                while (StringUtils.isNoneBlank(line)){
                    String[] lineVal = line.split(",");
                    RegionVo regionVo = new RegionVo();
                    regionVo.setPhonePrefix(lineVal[0]).setProvince(lineVal[1]).setCity(lineVal[2]).setCarrier(lineVal[3]);
                    redisTemplate.opsForHash().put(PHONE_REGION_KEY,lineVal[0],regionVo);
                    line = reader.readLine();
                }
            }catch (Exception e){
                e.printStackTrace();
                throw new RuntimeException("獲取手機(jī)號(hào)信息報(bào)錯(cuò)");
            }
        }

    }
}

/**
 * @author: jiangjs
 * @description: 讀取CSV文件，根據(jù)手機(jī)號(hào)前7位進(jìn)行匹配
 * @date: 2023/11/30 14:54
 **/
@Component
public class PhoneToRegionCsvUtil {

    private final static String PHONE_REGION_KEY = "country_phone_region_info";

    @Resource
    private RedisTemplate<String,Object> redisTemplate;

    /**
     * 根據(jù)手機(jī)號(hào)獲取手機(jī)歸屬地
     * @param phone 手機(jī)號(hào)
     * @return 歸屬地信息
     */
    public RegionVo getPhoneToRegion(String phone){
        String prefix = StringUtils.substring(phone, 0, 7);
        Object region = redisTemplate.opsForHash().get(PHONE_REGION_KEY, prefix);
        return Objects.isNull(region) ? new RegionVo() : (RegionVo) region;
    }
}

@Resource
private PhoneToRegionCsvUtil phoneToRegionCsvUtil;

@GetMapping("/getPhoneGeoInfoByCsv.do/{phone}")
public JsonResult<?> getPhoneGeoInfoByCsv(@PathVariable("phone") String phone){
    return JsonResult.success(phoneToRegionCsvUtil.getPhoneToRegion(phone));
}