淘宝
不得不说阿里系的文档和工具确实很人性化，按照文档对接就行了。
加一点说明，现在各个平台的的开发者都需要软著才能申请，所以在店铺同主体下要有软著才行（不同主体也行，但是店铺授权给开发者比较麻烦），不用考虑软著上的系统名称，平台应该不会考虑一致性。
要读取订单信息需要满足御城河的分数要求，需要提供专业的渗透测试报告（这个要花钱认证）。读取订单后发现所有的订单都是打※的（国家对隐私比较注重，所有平台的订单收件人都是加密的），需要解密，需要购买聚石塔的服务器，淘宝的解密接口只能用聚石塔内的服务器请求。再说明一下，现在各个平台返回的收件人手机号都是虚拟号。到这订单拉取就完成了。
但是，这样读取订单是有延迟的，系统不可能太频繁的读取接口。各个平台提供了websocket的接口，平台在订单有各种变化的时候会推送消息，淘宝的消息支持http和webscoket，http就需要一个长连接，基本思路就是while循环读取。淘宝的websocket提供了很多版本的sdk，我能理解的是java和nodejs，最后选择了nodejs，但是nodejs的sdk版本有点老了，服务器安装了新版的node会报错，解决方案是：
源文件改过，具体行数不确定了
修改 tmcCodec.js

TmcCodec.prototype.writeMessage = function(message) {
    var buffer = new Buffer(256);
    buffer.writeUInt8(2,0);
    buffer.writeUInt8(message.messageType,1);
    var index = 2;
1
2
3
4
5

改为

TmcCodec.prototype.writeMessage = function(message) {
    var buffer = new Buffer.allocUnsafe(256); //改了这一行
    buffer.writeUInt8(2,0);
    buffer.writeUInt8(message.messageType,1);
    var index = 2;
1
2
3
4
5

第二个问题

if(message.content){
        for(var key in message.content){
            buffer.writeUInt16LE(Common.enum.HeaderType.Custom,index);
            var length = Buffer.byteLength(key);
            buffer.writeUInt32LE(length,index+2);
            buffer.write(key,index+6,'UTF-8');
            index = index + length + 6;
            length = Buffer.byteLength(message.content[key]);
            if(length == 0){
                buffer.writeUInt8(Common.enum.ValueFormat.Void,index);
1
2
3
4
5
6
7
8
9
10
11

改为

if(message.content){
        for(var key in message.content){
            buffer.writeUInt16LE(Common.enum.HeaderType.Custom,index);
            var length = Buffer.byteLength(key);
            buffer.writeUInt32LE(length,index+2);
            buffer.write(key,index+6,'UTF-8');
            index = index + length + 6;
            
            length = Buffer.byteLength(String(message.content[key])); //修改了这一行
            if(length == 0){
                buffer.writeUInt8(Common.enum.ValueFormat.Void,index);
1
2
3
4
5
6
7
8
9
10
11

第三个问题
sdk带的ws地址是错的，要用这个 ws://mc.api.taobao.com/

tmcClient.connect('ws://mc.api.daily.taobao.net/',
    function (message,status) {
        console.log('message',message);
    });
1
2
3
4

然后我在项目里加了个http模块，有订单变化时更新到订单系统，就能做到实时同步订单变化（实时有点夸张，有10秒左右的延迟）。

tmcClient.connect('ws://mc.api.taobao.com/',
    function (message,status) {
        console.log('message',message);
        console.log('status',status); 
        if(message.content){
            //post是用http模块写一个ajax函数
            post('/notify/tm/msg',JSON.stringify(message),(data)=>{
                console.log('callback',data)
            })
        }
        
});

ITPub博客

深度解析：淘宝电商平台对接实操方案汇总

最新文章