package com.nova.sankuai.infra.utils.huawei;
|
|
import cn.hutool.core.map.MapBuilder;
|
import cn.hutool.core.map.MapUtil;
|
import cn.hutool.core.util.IdUtil;
|
import cn.hutool.crypto.digest.MD5;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.nova.sankuai.domain.api.zhongzan.ZhongZanResponse;
|
import com.nova.sankuai.domain.dto.huawei.HuaWeiDTO;
|
import com.nova.sankuai.security.HttpClientUtil;
|
import lombok.RequiredArgsConstructor;
|
import org.apache.commons.lang3.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.DigestUtils;
|
|
import java.util.Map;
|
|
/**
|
* 华为业务对接
|
*/
|
@Component
|
@RequiredArgsConstructor
|
public class HuaWeiUtil {
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
@Value("${huawei.basicUrl}")
|
private String basicUrl;
|
|
@Value("${huawei.appId}")
|
private String appId;
|
|
@Value("${huawei.deviceIdType}")
|
private String deviceIdType;
|
|
@Value("${huawei.grantType}")
|
private String grantType;
|
|
@Value("${huawei.clientId}")
|
private String clientId;
|
|
@Value("${huawei.clientSecret}")
|
private String clientSecret;
|
|
public String click(HuaWeiDTO dto) {
|
String logNumber = IdUtil.randomUUID();
|
String token = getToken();
|
if (StringUtils.isNotEmpty(token)) {
|
String result = null;
|
JSONObject jsonData = new JSONObject();
|
jsonData.put("appId", appId);
|
jsonData.put("deviceIdType", deviceIdType);
|
jsonData.put("deviceId", dto.getOaid());
|
jsonData.put("actionTime", dto.getTime());
|
jsonData.put("actionType", dto.getActionType());
|
jsonData.put("callBack", dto.getCallback());
|
try {
|
result = HttpClientUtil.getInstance().postJsonData(basicUrl + "datasource/v1/track/activate", jsonData.toJSONString(), getHeader(token, clientId));
|
log.info("日志编号：" + logNumber + " 回传用户行为数据接口成功 :{}", result);
|
} catch (Exception ex) {
|
log.error("日志编号：" + logNumber + " 回传用户行为数据接口 ，传参：token: {} ex：{}", token, jsonData , ex);
|
}
|
}
|
|
return null;
|
}
|
|
private String getToken(){
|
String logNumber = IdUtil.randomUUID();
|
JSONObject jsonData = new JSONObject();
|
jsonData.put("grant_type", grantType);
|
jsonData.put("client_id", clientId);
|
jsonData.put("client_secret", clientSecret);
|
String result = null;
|
try {
|
result = HttpClientUtil.getInstance().postJsonData(basicUrl + "oauth2/v1/token", jsonData.toJSONString());
|
} catch (Exception ex) {
|
log.error("日志编号：" + logNumber + " 获取Token, 请求参数：", jsonData, ex, "");
|
}
|
try {
|
JSONObject res = JSON.parseObject(result);
|
return res.getString("access_token");
|
} catch (Exception ex) {
|
log.error("日志编号：" + logNumber + " 获取Token，jsonData：{} ex：{}", jsonData , ex, "");
|
}
|
return null;
|
}
|
/**
|
* 交互请求头
|
* @param token token
|
* @param clientId 客⼾端id
|
* @return
|
*/
|
public static Map<String ,Object> getHeader(String token, String clientId) {
|
return new MapBuilder<String, Object>(MapUtil.newHashMap(16))
|
.put("client-id", clientId)
|
.put("Authorization", "Bearer "+ token)
|
.put("charset", "utf-8")
|
.build();
|
}
|
|
}
|
