业务向——基于淘宝联盟平台的CPS

发布时间:2024年01月13日

业务向——基于淘宝联盟平台的CPS

导读

上篇文章我们分享了多多进宝平台,那么这篇文章想继续带来CPS业务的分享,这次玩转的平台是淘宝联盟。在对接的过程中,也是踩了一些坑,特别是对于订单和用户绑定这一功能。在本文中,我们也继续从0到1,深入了解及实践如何玩转淘宝联盟CPS,为自己的副业拓宽一下路子。

小试牛刀

在开始之前,我们需要通过如下两个链接注册一下账号。如图1,注册完淘宝联盟后,我们可以在推广管理,找到媒体备案管理和推广位管理。媒体备案管理其实就是填报一下你的信息及计划在哪个平台推广(小程序、web等),推广位则是指淘宝客推广时用于跟踪和结算的参数依据,对于我们来说,也是绑定用户和订单的重要依据。

图1

如图2、图3所示,这里我们先新增推广位,然后选择创建好的媒体类型及填写广告位名称,即可完成。
图2

图3
完成备案并创建好推广位后,就可以点击顶部导航栏“我要推广”,去选择对应的商品、活动等,获取推广链接,进行推广了。
图4
关于淘宝联盟,下面这几个参数是最容易搞混乱的,这里想做一解释:

  • 推广位ID:即pid信息,如:mm_2039840091_2459350210_115589800408,可用于区分媒体备案内不同资源位的识别,是淘宝客推广识别、跟踪和结算的依据,也可查看对应推广位的数据。
  • 广告位ID:其中115589800408即为广告位id,通常也叫adzone id。
  • 渠道ID:其中2459350210即为渠道位id,通常也叫site id。该值就是你媒体备案的时候,创建媒体渠道后对应的ID值。注意,渠道专属推广位是有20个的个数限制。
  • 会员ID:其中2039840091即为会员id,通常也叫member id。该值就是你注册账号后对应的会员ID.
  • 关系ID:这个参数也叫**relation_id,在后边获取商品详情API传参时需要传入该参数,用于绑定用户订单。**该参数的获取来源比较繁琐,需要邀请用户绑定授权,通常我们可以上淘宝找人代刷一下。

图5
由于淘宝SDK获取流程比较繁琐,切总是莫名其妙出现一些接口缺失的问题,因为它会根据你的当前的权限,动态生成不同的SDK,而权限的获取,对于某些API又需要你的接口的请求量达到一定级别了才会开放给你,所以下面的实践案例都是采用原始的Http请求方式进行获取。

签名

  • 如下,这里先提供一个统一的签名工具类,在这之前,我们还需要引入依赖:
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.Assert;

import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;
import java.util.Map;

import static org.apache.commons.codec.Charsets.UTF_8;

/**
 * 淘宝签名工具
 */
public class SignUtil {

    private static final Logger LOGGER = LoggerFactory.getLogger(SignUtil.class);
    // 參數签名
    public static String signParams(Map<String, Object> params, String appSecret) {
        String[] keys = params.keySet().toArray(new String[0]);
        Arrays.sort(keys);
        StringBuilder query = new StringBuilder();
        query.append(appSecret);
        for (String key : keys) {
            Object value = params.get(key);
            if (value != null && StringUtils.isNotBlank(key)) {
                query.append(key).append(value);
            }
        }
        byte[] bytes = null;
        try {
            query.append(appSecret);
            bytes = MessageDigest.getInstance("md5").digest(query.toString().getBytes(UTF_8));
        } catch (NoSuchAlgorithmException e) {
            LOGGER.error("加密出错" + e);
            throw CommonExceptions.BIZ_INVALID.newWithErrMsg("加密出错" + e);
        }
        Assert.notNull(bytes, "加密后字节数组为null");
        return byte2hex(bytes);
    }


    private static String byte2hex(byte[] bytes) {
        Assert.notNull(bytes, "字节数组为null");
        StringBuilder builder = new StringBuilder();
        for (byte aByte : bytes) {
            String hex = Integer.toHexString(aByte & 0xFF);
            if (hex.length() == 1) {
                builder.append("0");
            }
            builder.append(hex.toUpperCase());
        }
        return builder.toString();
    }
}

商品活动

taobao.tbk.activity.info.get

  • 这里的relation_id就是我们上面的关系ID
  • activity_material_id为官方活动会场ID,从淘宝客后台“我要推广-活动推广”中获取。
  • method即为我们的接口能力,taobao.tbk.activity.info.get
  • **adzone_id,我们上述所的广告位ID,**mm_xxx_xxx_xxx的第三位。
 TopActivityLinkRequest request = new TopRequestVo().new TopActivityLinkRequest();
        request.setActivity_material_id(config.topActivity).setAdzone_id(userPidAdzone.getAdzoneId()).
                setRelation_id(userPidAdzone.getRelationId()).
                setMethod(TopAPIConstant.TOP_ACTIVITY_LINK).
                setTimestamp(DateTimeUtil.getCurrentDayOfString(DateTimeUtil.DATE_TIME)).
                setApp_key(config.topAppKey);
        String sign = SignUtil.signParams(BeanToMapUtil.beanToObjMap(request), config.topAppSecret);
        request.setSign(sign);
        TopActivityLinkResponse response = topActivityLinkService.request(request);

  • 关于这里的request方法:
public TopActivityLinkResponse request(TopActivityLinkRequest topActivityLinkRequest) {
        String result = null;
        try {
            String query = TopRequestUtil.buildQuery(BeanToMapUtil.beanToObjMap(topActivityLinkRequest));
            result = TopRequestUtil.handle(query, TopAPIConstant.TOP_REQUEST_URL);
            LOGGER.info("11111:"  + result);
        } catch (Exception e) {
            LOGGER.error("淘宝官方转链请求失败 : {}", JSONObject.toJSON(result), e);
            throw CommonExceptions.BIZ_INVALID.newWithErrMsg("淘宝官方转链请求失败");
        }
        LOGGER.info("淘宝官方转链原始数据 : {}", JSONObject.toJSON(result));
        JSONObject jsonObject = JSONObject.parseObject(result);

        jsonObject = jsonObject.getJSONObject("tbk_activity_info_get_response");
        if (!jsonObject.containsKey("data")) {
            return null;
        }
        return JSONObject.parseObject(JSONObject.toJSONString(jsonObject.get("data")), TopActivityLinkResponse.class);
    }

public static String buildQuery(Map<String, Object> params) throws UnsupportedEncodingException {
        if (params == null || params.isEmpty()) {
            return null;
        }

        StringBuilder query = new StringBuilder();
        Set<Map.Entry<String, Object>> entries = params.entrySet();
        boolean hasParam = false;

        for (Map.Entry<String, Object> entry : entries) {
            String name = entry.getKey();
            Object value = entry.getValue();
            // 忽略参数名或参数值为空的参数
            if (StringUtils.isNotBlank(name) && value != null) {
                if (hasParam) {
                    query.append("&");
                } else {
                    hasParam = true;
                }
                query.append(name).append("=").
                        append(URLEncoder.encode(String.valueOf(value), UTF_8.toString()));
            }
        }
        return query.toString();
    }

    public static String handle(String query, String url) {
        byte[] content = query.getBytes(UTF_8);;

        HttpURLConnection conn = null;
        try {
            URL newUrl = new URL(url);
            conn = (HttpURLConnection) newUrl.openConnection();
            conn.setRequestMethod(DEFAULT_REQUEST_METHOD);
            conn.setRequestProperty("Host", newUrl.getHost());
        } catch (IOException e) {
            throw CommonExceptions.BIZ_INVALID.newWithErrMsg("淘宝请求失败" + e);
        }
        conn.setDoInput(true);
        conn.setDoOutput(true);
        conn.setRequestProperty("Accept", "text/xml,text/javascript");
        conn.setRequestProperty("User-Agent", "top-sdk-java");
        conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=" + UTF_8);

        try (OutputStream out = conn.getOutputStream();) {
            out.write(content);
        } catch (IOException e) {
            throw CommonExceptions.BIZ_INVALID.newWithErrMsg("淘宝请求失败" + e);
        }
        conn.disconnect();

        try {
            return responseToString(conn);
        } catch (IOException e) {
            throw CommonExceptions.BIZ_INVALID.newWithErrMsg("淘宝请求失败" + e);
        }
    }

    protected static String responseToString(HttpURLConnection conn) throws IOException {
        assert conn != null;
        if (conn.getResponseCode() >= ERROR) {
            // Client Error 4xx and Server Error 5xx
            throw new IOException(conn.getResponseCode() + " " + conn.getResponseMessage());

        }
        String contentEncoding = conn.getContentEncoding();
        return "gzip".equalsIgnoreCase(contentEncoding) ?
                getStreamToString(new GZIPInputStream(conn.getInputStream()), UTF_8.toString())
                :
                getStreamToString(conn.getInputStream(), UTF_8.toString());
    }


    protected static String getStreamToString(InputStream stream, String charset) throws IOException {
        Reader reader = new InputStreamReader(stream, charset);
        StringBuilder response = new StringBuilder();
        final char[] buff = new char[1024];
        int read = 0;
        while ((read = reader.read(buff)) > 0) {
            response.append(buff, 0, read);
        }
        stream.close();
        return response.toString();
    }

订单获取及用户

tobao.ovs.tbk.order.details.batch.get
● 关于淘宝联盟的订单获取请求方式大致如上,这里不再贴代码了,注意,关于淘宝联盟订单获取一般会有权限限制,需要你访问量达到一定级别才会开放给你接口权限。所以一般我们会选取如大淘客这样的第三方平台做对接。
● 关于订单和用户绑定:通过上面的请求我们可以看到在传参时有传入关系ID和广告位ID。那么有一个绑定的思路如下:
○ 提前生成好一批关系ID,这里找淘宝帮忙代刷可以有500个。
○ 提前生成好一批PID,这个是有数量限制的,只有20个
○ 将关系ID和PID的第三段即广告位ID,进行组合即500*20
○ 当用户进入商品页时,在我们的业务方,先将某个组合锁住,如标记位1,并更新updateTime
○ 当下一个用户进来时,我们根据updateTime,选取最久未使用的组合进行标记,并更新updateTime
○ 另外,每个用户和组合的关系也会记录下来
○ 获取淘宝订单列表时,淘宝联盟也会返回我们关系ID和广告位ID,还有用户下单时间,这时我们可以根据下单时间前后5min,找到组合,从而时间订单和用户的绑定。
● 上面的思路在实践验证也是可行的,除非你是大V用户,并发量贼大,不过这种可以单独找淘宝运营申请专门的接口进行对接。其他情况,采用上面思路是可以实现绑定关系的。

文章来源:https://blog.csdn.net/legendaryhaha/article/details/135564092
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。