package com.nova.sankuai.domain.api.aliyunIP;
|
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.nova.sankuai.domain.entity.City;
|
import com.nova.sankuai.infra.mapper.CityMapper;
|
import com.nova.sankuai.infra.utils.HttpUtils;
|
import com.nova.sankuai.infra.utils.IpUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.util.EntityUtils;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Slf4j
|
@Component
|
public class AliyunUtil {
|
|
//阿里云appkey，获取ip地理信息
|
// private static final String appKey = "204061314";
|
// private static final String appKey = "204574003";
|
|
//阿里云appSecrets，获取ip地理信息
|
// private static final String appSecrets = "JVkQzP2zyCBvU0frWtCG9NM8w3FbkoLm";
|
// private static final String appSecrets = "CBvIivU5E7AnfF1YYOjGnsle3267BkuP";
|
|
private static final String appcode = "40575e08cd5c424fb1939000f262d25f";
|
|
private static final String host = "https://zjip.market.alicloudapi.com";
|
|
private static final String path = "/lifeservice/QueryIpAddr/query";
|
private static final String method = "GET";
|
|
// AppKey：204574003 AppSecret：CBvIivU5E7AnfF1YYOjGnsle3267BkuP
|
//AppCode：40575e08cd5c424fb1939000f262d25f
|
|
// private static final String US_CODE = "US";
|
|
// private static final Logger logger = LoggerFactory.getLogger("loginLogger");
|
|
@Resource
|
private CityMapper cityMapper;
|
|
|
// static {
|
// //初始化appKey和appSecrets
|
// HttpClientBuilderParams httpParam = new HttpClientBuilderParams();
|
// httpParam.setAppKey(appKey);
|
// httpParam.setAppSecret(appSecrets);
|
// httpParam.setConnectionTimeout(Constants.TIME_OUT);
|
// HttpApiClientIP.getInstance().init();
|
// }
|
|
|
/**
|
* 调用阿里云的查询ip地理信息
|
*
|
* @param request
|
* @param phone
|
* @return
|
*/
|
public static ResponseInfo IPLocaltionHttpSyncTest(HttpServletRequest request, String phone) {
|
String ipAddr = IpUtil.getIpAddr(request);
|
/*ApiResponse response = HttpsApiClientIP.getInstance().IPLocaltionSyncMode(ipAddr);
|
if (response == null){
|
log.error(phone + "阿里云IP地址获取：获取失败：{}");
|
return null;
|
}
|
AliyunResponse aliyunResponse = null;
|
String result = null;
|
try {
|
result = new String(response.getBody(), SdkConstant.CLOUDAPI_ENCODING);
|
aliyunResponse = JSON.parseObject(result, AliyunResponse.class);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
log.error(phone + "阿里云IP地址获取：ip地址为" + ipAddr + "阿里云原始返回response：" + response + "，原始返回body转换字符串：" + result + "，转换ip地址信息失败：{}", ex);
|
return null;
|
}
|
if (100 != aliyunResponse.getCode()) {
|
log.error(phone + "阿里云IP地址获取：获取失败：{}", aliyunResponse.toString());
|
return null;
|
} else {
|
return aliyunResponse.getResult();
|
}*/
|
|
// String host = "https://zjip.market.alicloudapi.com";
|
// String path = "/lifeservice/QueryIpAddr/query";
|
// String method = "GET";
|
// String appcode = appCode;
|
Map<String, String> headers = new HashMap<String, String>();
|
//最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
|
headers.put("Authorization", "APPCODE " + appcode);
|
Map<String, String> querys = new HashMap<>();
|
querys.put("ip", ipAddr);
|
AliyunResponse aliyunResponse = null;
|
try {
|
HttpResponse response = HttpUtils.doGet(host, path, method, headers, querys);
|
//获取response的body
|
if (response == null){
|
log.error(phone + "阿里云IP地址获取：获取失败，ip地址为:{}", ipAddr);
|
return null;
|
}
|
|
String result = EntityUtils.toString(response.getEntity());
|
|
aliyunResponse = JSON.parseObject(result, AliyunResponse.class);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
log.error(phone + "阿里云IP地址获取：ip地址为" + ipAddr + "转换ip地址信息失败：{}", ex);
|
return null;
|
}
|
|
if (aliyunResponse == null || 0 != aliyunResponse.getError_code()) {
|
log.error(phone + "阿里云IP地址获取：获取失败：{}", aliyunResponse);
|
return null;
|
} else {
|
return aliyunResponse.getResult();
|
}
|
}
|
|
/**
|
* 调用阿里云的查询ip地理信息
|
*
|
* @param request
|
* @return
|
*/
|
public static void test(HttpServletRequest request) {
|
String ipAddr = IpUtil.getIpAddr(request);
|
|
ipAddr = "111.29.72.92";
|
|
// ApiResponse response = HttpsApiClientIP.getInstance().IPLocaltionSyncMode(ipAddr);
|
// if (response == null){
|
// log.error("阿里云IP地址获取：获取失败：{}");
|
// return;
|
// }
|
// String result = new String(response.getBody(), SdkConstant.CLOUDAPI_ENCODING);
|
// log.info("response:{}", result);
|
|
// String host = "https://zjip.market.alicloudapi.com";
|
// String path = "/lifeservice/QueryIpAddr/query";
|
// String method = "GET";
|
// String appcode = appCode;
|
Map<String, String> headers = new HashMap<String, String>();
|
//最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
|
headers.put("Authorization", "APPCODE " + appcode);
|
Map<String, String> querys = new HashMap<>();
|
querys.put("ip", ipAddr);
|
AliyunResponse aliyunResponse = null;
|
try {
|
HttpResponse response = HttpUtils.doGet(host, path, method, headers, querys);
|
//获取response的body
|
if (response == null){
|
log.error("阿里云IP地址获取：获取失败：{}");
|
}
|
|
String result = EntityUtils.toString(response.getEntity());
|
|
aliyunResponse = JSON.parseObject(result, AliyunResponse.class);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
log.error("阿里云IP地址获取：ip地址为" + ipAddr + "转换ip地址信息失败：{}", ex);
|
}
|
|
if (aliyunResponse == null || 0 != aliyunResponse.getError_code()) {
|
log.error("阿里云IP地址获取：获取失败：{}", aliyunResponse);
|
} else {
|
System.out.println("阿里云IP地址获取：获得城市信息为：" + aliyunResponse.getResult());
|
}
|
}
|
|
|
/**
|
* 通过阿里云的ip地理信息，获取城市信息
|
*
|
* @param request
|
* @param phone
|
* @return
|
*/
|
public City getCityInfo(HttpServletRequest request, String phone) {
|
ResponseInfo responseInfo = AliyunUtil.IPLocaltionHttpSyncTest(request, phone);
|
if (responseInfo == null) {
|
log.info(phone + " 阿里云IP地址获取：获得城市信息失败");
|
return null;
|
} else {
|
log.info(phone + " 阿里云IP地址获取：获得城市信息为：{}", responseInfo);
|
City cityInfo = cityMapper.selectOne(new LambdaQueryWrapper<City>().
|
likeRight(City::getName, responseInfo.getCity()).last(" limit 1 "));
|
if (cityInfo != null) {
|
log.info(phone + " 阿里云IP地址获取：获得城市信息为：{}", cityInfo);
|
return cityInfo;
|
}
|
log.info(phone + " 阿里云IP地址获取：未获取到城市信息为：{}", cityInfo);
|
return null;
|
}
|
}
|
|
/**
|
* 获取用户的ip及地理信息
|
*
|
* @param request
|
* @param phone
|
* @return
|
*/
|
public CustomerIpInfo getCustomerIpInfo(HttpServletRequest request, String phone) {
|
String ipAddr = IpUtil.getIpAddr(request);
|
ResponseInfo responseInfo = AliyunUtil.IPLocaltionHttpSyncTest(request, phone);
|
CustomerIpInfo customerIpInfo = new CustomerIpInfo();
|
if (ipAddr != null) {
|
customerIpInfo.setIp(ipAddr);
|
}
|
if (responseInfo != null) {
|
// customerIpInfo.setCityName(responseInfo.getCity());
|
City cityInfo = cityMapper.selectOne(new LambdaQueryWrapper<City>().
|
likeRight(City::getName, responseInfo.getCity()).last(" limit 1 "));
|
if (cityInfo != null) {
|
log.info(phone + "阿里云IP地址获取：获得城市信息为：{}", cityInfo);
|
customerIpInfo.setSysCityId(cityInfo.getCityId());
|
customerIpInfo.setCityName(cityInfo.getName());
|
} else {
|
customerIpInfo.setCityName(responseInfo.getCity());
|
}
|
} else {
|
log.error(phone + "阿里云IP地址获取：未获得城市信息");
|
}
|
return customerIpInfo;
|
}
|
|
/**
|
* 判断ip所属地是否未US
|
*/
|
public boolean checkCounty(String ip) {
|
Map<String, String> headers = new HashMap<String, String>();
|
//最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
|
headers.put("Authorization", "APPCODE " + appcode);
|
Map<String, String> querys = new HashMap<>();
|
querys.put("ip", ip);
|
AliyunResponse aliyunResponse = null;
|
try {
|
HttpResponse response = HttpUtils.doGet(host, path, method, headers, querys);
|
//获取response的body
|
if (response == null){
|
log.error("阿里云IP地址获取：转换ip地址信息失败");
|
return false;
|
}
|
|
String result = EntityUtils.toString(response.getEntity());
|
|
aliyunResponse = JSON.parseObject(result, AliyunResponse.class);
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
log.error("阿里云IP地址获取：转换ip地址信息失败：{}", ex);
|
return false;
|
}
|
|
if (0 != aliyunResponse.getError_code()) {
|
log.error("阿里云IP地址获取：获取失败：{}", aliyunResponse.toString());
|
return false;
|
} else {
|
ResponseInfo responseInfo = aliyunResponse.getResult();
|
if (responseInfo == null) {
|
log.error("阿里云IP地址获取：获取地理信息失败：{}", aliyunResponse);
|
return false;
|
} else {
|
log.info("阿里云IP地址获取：获得信息为：{}", responseInfo);
|
return true;
|
}
|
}
|
|
|
}
|
|
|
}
|
