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

业务向——基于淘宝联盟平台的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用户，并发量贼大，不过这种可以单独找淘宝运营申请专门的接口进行对接。其他情况，采用上面思路是可以实现绑定关系的。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/315406.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

git修改历史（非最新）提交信息

git修改历史（非最新）提交信息

二、修改最近第二次或更早之前的commit信息 当前有三次提交&#xff0c;从近到远分别为1、2、3 以修改第2次提交为例&#xff08;从最新往前数&#xff09; 1、使用命令git rebase -i HEAD~2 按i进入编辑模式&#xff0c;将对应的pick改为edit&#xff0c;然后ctrlc退出。最…
阅读更多...
环形链表[简单]

环形链表[简单]

优质博文&#xff1a;IT-BLOG-CN 一、题目 给你一个链表的头节点head&#xff0c;判断链表中是否有环。 如果链表中有某个节点&#xff0c;可以通过连续跟踪next指针再次到达&#xff0c;则链表中存在环。为了表示给定链表中的环&#xff0c;评测系统内部使用整数pos来表示链…
阅读更多...
【算法与数据结构】62、LeetCode不同路径

【算法与数据结构】62、LeetCode不同路径

文章目录 一、题目二、解法2.1 动态规划解法2.2 数论解法 三、完整代码 所有的LeetCode题解索引&#xff0c;可以看这篇文章——【算法和数据结构】LeetCode题解。 一、题目 二、解法 2.1 动态规划解法 思路分析&#xff1a;机器人只能向下或者向右移动&#xff0c;那么到达&a…
阅读更多...
Komodor：Kubernetes 监控工具全面指南

Komodor：Kubernetes 监控工具全面指南

为了方便起见&#xff0c;Komodor 提供了一个简单的 Web 界面&#xff0c;以帮助您监控 Kubernetes 集群的状态。它拥有付费和免费增值计划&#xff0c;除了在出现问题时通知用户外&#xff0c;还拥有一系列方便的工具&#xff0c;用于跟踪和管理集群中部署的资源的状态。让我们…
阅读更多...
单片机I/O口驱动MOS管

单片机I/O口驱动MOS管

自记录&#xff1a; 使用单片机做一个PLC,输出可如下两种情况&#xff1a; 单片机I/O口驱动&#xff0c;为什么一般都选用三极管而不是MOS管&#xff1f; 1.单片机的IO口&#xff0c;有一定的带负载能力。但电流很小&#xff0c;驱动能力有限&#xff0c;一般在10-20mA以内。…
阅读更多...
【Java SE语法篇】6.数组

【Java SE语法篇】6.数组

&#x1f4da;博客主页&#xff1a;爱敲代码的小杨. ✨专栏&#xff1a;《Java SE语法》 ❤️感谢大家点赞&#x1f44d;&#x1f3fb;收藏⭐评论✍&#x1f3fb;&#xff0c;您的三连就是我持续更新的动力❤️ 文章目录 1.数组的基本概念1.1 为什么使用数组&#xff1f;1.…
阅读更多...
Realm Management Extension领域管理扩展之安全状态

Realm Management Extension领域管理扩展之安全状态

RME基于Arm TrustZone技术。TrustZone技术在Armv6中引入，提供以下两个安全状态： 安全状态（Secure state）非安全状态（Non-secure state）以下图表显示了在AArch64中的这两个安全状态以及通常在每个安全状态中找到的软件组件： 该架构将在安全状态运行的软件与在非安全状态运…
阅读更多...
【Linux实用篇】Linux常用命令（1）

【Linux实用篇】Linux常用命令（1）

目录 1.1 Linux命令初体验 1.1.1 常用命令演示 1.1.2 Linux命令使用技巧 1.1.3 Linux命令格式 1.2 文件目录操作命令 1.2.1 ls 1.2.2 cd 1.2.3 cat 1.2.4 more 1.2.5 tail 1.2.6 mkdir 1.2.7 rmdir 1.2.8 rm 1.1 Linux命令初体验 1.1.1 常用命令演示 在这一部分中…
阅读更多...
C#，卡特兰数（Catalan number，明安图数）的算法源代码

C#，卡特兰数（Catalan number，明安图数）的算法源代码

一、概要 卡特兰数&#xff08;英语&#xff1a;Catalan number&#xff09;&#xff0c;又称卡塔兰数、明安图数&#xff0c;是组合数学中一种常出现于各种计数问题中的数列。以比利时的数学家欧仁查理卡特兰的名字来命名。1730年左右被蒙古族数学家明安图使用于对三角函数幂…
阅读更多...
Linux 【C编程】IO进阶— 阻塞IO、非阻塞IO、 多路复用IO、 异步IO

Linux 【C编程】IO进阶— 阻塞IO、非阻塞IO、 多路复用IO、 异步IO

文章目录 1.阻塞IO与非阻塞IO1.1为什么有阻塞式&#xff1f;1.2非阻塞 2.阻塞式IO的困境3.并发IO的解决方案3.1非阻塞式IO3.2多路复用IO3.2.1什么是多路复用IO&#xff1f;3.2.1多路复用IO select原理3.2.1多路复用IO poll原理 3.3异步IO 1.阻塞IO与非阻塞IO 1.1为什么有阻塞式…
阅读更多...
国产麒麟系统开机没有网络需要点一下这个设置

国产麒麟系统开机没有网络需要点一下这个设置

问题描述&#xff1a; 一台国产电脑网线连接正常&#xff0c;打开网页后显示无法访问&#xff0c;那么是什么原因无法上网呢&#xff1f;下面就告诉你一个小方法去解决一下这个问题&#xff1b; 检查故障&#xff1a; 检测交换机、网线、水晶头全都正常&#xff0c;同房间摆放的…
阅读更多...
ZooKeeper 实战(二) 命令行操作篇

ZooKeeper 实战(二) 命令行操作篇

文章目录 ZooKeeper 实战(二) 命令行操作篇1. 服务端命令1.1. 服务启动1.2. 查看服务1.3. 重启服务1.4. 停止服务 2. 客户端命令2.1. 启动客户端2.2. 查看节点信息查看根节点详情 ls -s /添加一个watch监视器 ls -w /列举出节点的级联节点 ls -R / 2.3. 查看节点状态2.4. 创建节…
阅读更多...
Jenkins 问题

Jenkins 问题

从gitlab 仓库拉去代码到Jenkins本地报错 ERROR: Couldn’t find any revision to build. Verify the repository and branch configuration for this job. 问题原因&#xff1a; 创建条目》配置的时候&#xff0c;gitlab仓库不存在master分支 修复后&#xff1a;
阅读更多...
44-js return返回值，全局作用域，局部作用域，隐式作用域，变量的生命周期，delete释放内存

44-js return返回值，全局作用域，局部作用域，隐式作用域，变量的生命周期，delete释放内存

1.return返回值&#xff1a;函数执行后剩下结果就是返回值。 function fn(a,b,c){//return返回值return(abc);// console.log("aaa"); //return之后的值都不在执行了// alert("bbb"); //return之后的值不在执行了}console.log(fn(1,2,3)*10)…
阅读更多...
人工智能：我的学习之旅与认知探索（第1版）

人工智能：我的学习之旅与认知探索（第1版）

&#x1f31f;&#x1f30c; 欢迎来到知识与创意的殿堂 — 远见阁小民的世界&#xff01;&#x1f680; &#x1f31f;&#x1f9ed; 在这里&#xff0c;我们一起探索技术的奥秘&#xff0c;一起在知识的海洋中遨游。 &#x1f31f;&#x1f9ed; 在这里&#xff0c;每个错误都…
阅读更多...
what is BERT?

what is BERT?

BERT Introduction Paper 参考博客 9781838821593_ColorImages.pdf (packt-cdn.com) Bidirectional Encoder Representation from Transformer 来自Transformer的双向编码器表征 基于上下文&#xff08;context-based&#xff09;的嵌入模型。 那么基于上下文&#xff08;…
阅读更多...
golang学习笔记——go语言多文件项目运行的四种方式

golang学习笔记——go语言多文件项目运行的四种方式

go语言多文件运行技巧 有两个源码文件的go语言项目如何运行? go.modmain.go Trie.go 如何直接运行go run main.go会提示找不到文件。 # 在windows10下运行 $ go run main.go # command-line-arguments .\main.go:6:9: undefined: Constructor是真的找不到文件吗。其实不是。…
阅读更多...
一个成功的camera案例：ros2+gazebo+摄像头

一个成功的camera案例：ros2+gazebo+摄像头

各位看&#xff1a;随着大物体的移动&#xff0c;在涉嫌头的位置也发生了改变-----右上角那个/camera的位置也变了 右上角那个是摄像头图案&#xff0c;以下是仓库链接&#xff1a; ros-ign-gazebo-camera: https://github.com/arashsm79/ros-ign-gazebo-camera.git一个ros2摄…
阅读更多...
基于多智能体点对点转换的分布式模型预测控制

基于多智能体点对点转换的分布式模型预测控制

matlab2020正常运行 基于多智能体点对点转换的分布式模型预测控制资源-CSDN文库
阅读更多...
Zabbix“专家坐诊”第223期问答汇总

Zabbix“专家坐诊”第223期问答汇总

来源&#xff1a;乐维社区 问题一 Q&#xff1a;Zabbix 5.0安装完mysql之后怎么备份&#xff1f;忘记mysql当时创建的密码了&#xff0c;怎么样能查看设置的密码&#xff1f; A&#xff1a;mysql初始化密码在 /var/log/mysqld.log中可以看到&#xff0c;搜关键字temporary pas…
阅读更多...
最新文章

Copyright @ 2022~2023