|
@@ -6,6 +6,8 @@ import com.kmall.common.constant.HaiKongMemberSystemUrlEnum;
|
|
import okhttp3.MediaType;
|
|
import okhttp3.MediaType;
|
|
import okhttp3.Request;
|
|
import okhttp3.Request;
|
|
import okhttp3.RequestBody;
|
|
import okhttp3.RequestBody;
|
|
|
|
+import org.slf4j.Logger;
|
|
|
|
+import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
@@ -18,6 +20,8 @@ import org.springframework.stereotype.Component;
|
|
@Component
|
|
@Component
|
|
public class HaiKongMemberTemplate {
|
|
public class HaiKongMemberTemplate {
|
|
|
|
|
|
|
|
+ private static final Logger log = LoggerFactory.getLogger(HaiKongMemberTemplate.class);
|
|
|
|
+
|
|
@Autowired
|
|
@Autowired
|
|
private HaiKongProperties haiKongProperties;
|
|
private HaiKongProperties haiKongProperties;
|
|
|
|
|
|
@@ -35,7 +39,7 @@ public class HaiKongMemberTemplate {
|
|
private String appendQueryParam(String url, String accessToken, String sign) {
|
|
private String appendQueryParam(String url, String accessToken, String sign) {
|
|
return url + "?" + "access_token=" + accessToken +
|
|
return url + "?" + "access_token=" + accessToken +
|
|
"&" + "sign=" + sign +
|
|
"&" + "sign=" + sign +
|
|
- "&" + "timestamp=" + String.valueOf(System.currentTimeMillis());
|
|
|
|
|
|
+ "&" + "timestamp=" + System.currentTimeMillis();
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -43,11 +47,15 @@ public class HaiKongMemberTemplate {
|
|
* @return accessToken
|
|
* @return accessToken
|
|
*/
|
|
*/
|
|
public String getAccessToken() {
|
|
public String getAccessToken() {
|
|
|
|
+ log.info("请求获取accessToken......");
|
|
String url = HaiKongMemberSystemUrlEnum.QUERY_ACCESS_TOKEN.getUrl();
|
|
String url = HaiKongMemberSystemUrlEnum.QUERY_ACCESS_TOKEN.getUrl();
|
|
Request request = new Request.Builder()
|
|
Request request = new Request.Builder()
|
|
.url(haiKongProperties.getMemberUrl() + url)
|
|
.url(haiKongProperties.getMemberUrl() + url)
|
|
.build();
|
|
.build();
|
|
- return OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
|
|
+
|
|
|
|
+ String response = OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
+ log.info("请求获取accessToken成功......");
|
|
|
|
+ return response;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -55,11 +63,14 @@ public class HaiKongMemberTemplate {
|
|
* @return accessToken
|
|
* @return accessToken
|
|
*/
|
|
*/
|
|
public String refreshAccessToken() {
|
|
public String refreshAccessToken() {
|
|
|
|
+ log.info("请求刷新accessToken......");
|
|
String url = HaiKongMemberSystemUrlEnum.REFRESH_ACCESS_TOKEN.getUrl();
|
|
String url = HaiKongMemberSystemUrlEnum.REFRESH_ACCESS_TOKEN.getUrl();
|
|
Request request = new Request.Builder()
|
|
Request request = new Request.Builder()
|
|
.url(haiKongProperties.getMemberUrl() + url)
|
|
.url(haiKongProperties.getMemberUrl() + url)
|
|
.build();
|
|
.build();
|
|
- return OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
|
|
+ String response = OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
+ log.info("请求刷新accessToken成功......");
|
|
|
|
+ return response;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -69,39 +80,48 @@ public class HaiKongMemberTemplate {
|
|
* @return 会员信息
|
|
* @return 会员信息
|
|
*/
|
|
*/
|
|
public String getMemberInfoByPhone(String body) {
|
|
public String getMemberInfoByPhone(String body) {
|
|
|
|
+ log.info("请求根据手机号获取会员信息......");
|
|
Request request = new Request.Builder()
|
|
Request request = new Request.Builder()
|
|
.post(requestBody(body))
|
|
.post(requestBody(body))
|
|
.url(haiKongProperties.getMemberUrl() + appendQueryParam(HaiKongMemberSystemUrlEnum.QUERY_MEMBER_INFO_BY_PHONE.getUrl(), "", ""))
|
|
.url(haiKongProperties.getMemberUrl() + appendQueryParam(HaiKongMemberSystemUrlEnum.QUERY_MEMBER_INFO_BY_PHONE.getUrl(), "", ""))
|
|
.build();
|
|
.build();
|
|
- return OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
|
|
+ String response = OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
+ log.info("请求根据手机号获取会员信息成功......");
|
|
|
|
+ return response;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 根据手机号获取会员信息
|
|
|
|
|
|
+ * 根据会员码获取会员信息
|
|
* 可根据会员码或手机号或会员的open_id来获取会员信息
|
|
* 可根据会员码或手机号或会员的open_id来获取会员信息
|
|
* @param body 请求体
|
|
* @param body 请求体
|
|
* @return 会员信息
|
|
* @return 会员信息
|
|
*/
|
|
*/
|
|
public String getMemberInfoByCode(String body) {
|
|
public String getMemberInfoByCode(String body) {
|
|
|
|
+ log.info("请求根据会员码获取会员信息......");
|
|
Request request = new Request.Builder()
|
|
Request request = new Request.Builder()
|
|
.post(requestBody(body))
|
|
.post(requestBody(body))
|
|
.url(haiKongProperties.getMemberUrl() + appendQueryParam(HaiKongMemberSystemUrlEnum.QUERY_MEMBER_INFO_BY_CODE.getUrl(), "", ""))
|
|
.url(haiKongProperties.getMemberUrl() + appendQueryParam(HaiKongMemberSystemUrlEnum.QUERY_MEMBER_INFO_BY_CODE.getUrl(), "", ""))
|
|
.build();
|
|
.build();
|
|
- return OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
|
|
+ String response = OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
+ log.info("请求根据会员码获取会员信息成功......");
|
|
|
|
+ return response;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
* 获取会员优惠券详细信息
|
|
* 获取会员优惠券详细信息
|
|
- * 待定
|
|
|
|
|
|
+ * TODO 待定
|
|
* @param body 请求体
|
|
* @param body 请求体
|
|
* @return 优惠券信息
|
|
* @return 优惠券信息
|
|
*/
|
|
*/
|
|
public String getMemberCouponInfo(String body) {
|
|
public String getMemberCouponInfo(String body) {
|
|
|
|
+ log.info("请求获取会员优惠券详细信息......");
|
|
Request request = new Request.Builder()
|
|
Request request = new Request.Builder()
|
|
.get()
|
|
.get()
|
|
.url(haiKongProperties.getMemberUrl() + appendQueryParam(HaiKongMemberSystemUrlEnum.QUERY_MEMBER_COUPON.getUrl(), "", ""))
|
|
.url(haiKongProperties.getMemberUrl() + appendQueryParam(HaiKongMemberSystemUrlEnum.QUERY_MEMBER_COUPON.getUrl(), "", ""))
|
|
.build();
|
|
.build();
|
|
- return OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
|
|
+ String response = OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
+ log.info("请求获取会员优惠券详细信息成功......");
|
|
|
|
+ return response;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -110,11 +130,14 @@ public class HaiKongMemberTemplate {
|
|
* @return 响应数据
|
|
* @return 响应数据
|
|
*/
|
|
*/
|
|
public String changeMemberScore(String body) {
|
|
public String changeMemberScore(String body) {
|
|
|
|
+ log.info("请求会员积分变动接口......");
|
|
Request request = new Request.Builder()
|
|
Request request = new Request.Builder()
|
|
.post(requestBody(body))
|
|
.post(requestBody(body))
|
|
.url(haiKongProperties.getMemberUrl() + appendQueryParam(HaiKongMemberSystemUrlEnum.CHANGE_MEMBER_SCORE.getUrl(), "", ""))
|
|
.url(haiKongProperties.getMemberUrl() + appendQueryParam(HaiKongMemberSystemUrlEnum.CHANGE_MEMBER_SCORE.getUrl(), "", ""))
|
|
.build();
|
|
.build();
|
|
- return OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
|
|
+ String response = OkHttpUtils.retry(request, haiKongProperties.getRetry());
|
|
|
|
+ log.info("请求会员积分变动接口成功......");
|
|
|
|
+ return response;
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|