taobao_java

Title

Title

Code
// testTOP.cpp : 定义控制台应用程序的入口点。
//
#include <string>
#include <map>
#include <memory>
#include <afxinet.h>
#include <atlutil.h>
#include <atlcrypt.h>

using namespace std;

const string topServerUrl = "http://gw.sandbox.taobao.com/router/rest";
const string appKey = "test";
const string secretCode = "test";

/**
*md5加密
**/
string md5String(string const& s)
{
    CCryptProv cp;
    cp.Initialize();

    CCryptMD5Hash md5;
    md5.Initialize(cp);
    md5.AddData(reinterpret_cast<unsigned char const*>(s.data()), static_cast<unsigned long>(s.length()));
    unsigned long size = 16;
    unsigned char buffer[16];
    md5.GetValue(buffer, &size);

    int length = size * 2 + 1;
    string result(length - 1, 0);
    AtlHexEncode(buffer, size, const_cast<char*>(result.data()), &length);
    return result;
}

class TopController
{
public:

    typedef map<string, string> ParamMap;

    TopController(string const& serverUrl, string const& appKey, string const& secretCode)
        : m_appKey(appKey)
        , m_secretCode(secretCode)
    {
        m_serverUrl.CrackUrl(CA2T(serverUrl.c_str()));//CA2T--确保进行类型转换的时候不溢出
    }
    
    string request(ParamMap& parameters) const
    {
        parameters["app_key"] = m_appKey;

        parameters["sign"] = calcSign(parameters);
        
        string paramString = makeParamString(parameters);

        return postToServer(paramString);
    }

private:

    string makeParamString(const ParamMap& parameters) const
    {
        string result;
        for(ParamMap::const_iterator it = parameters.begin(); it != parameters.end(); ++it)
            result += it->first + "=" + it->second + "&";
        result.erase(result.length() - 1);
        return result;
    }

    string calcSign(const ParamMap& parameters) const
    {
        string all = m_secretCode;
        for(ParamMap::const_iterator it = parameters.begin(); it != parameters.end(); ++it)
        {
            if (it->first != "sign")
                all += it->first + it->second;
        }
        return md5String(all);
    }

    string postToServer(string const& content) const
    {
        CInternetSession internetSession(_T("TopClient"));
        auto_ptr<CHttpConnection> connection(internetSession.GetHttpConnection(m_serverUrl.GetHostName()));
        auto_ptr<CHttpFile> httpFile(connection->OpenRequest(_T("POST"), m_serverUrl.GetUrlPath()));

        httpFile->AddRequestHeaders(_T("Content-Type: application/x-www-form-urlencoded\r\n"));
        httpFile->SendRequestEx(static_cast<int>(content.length()));
        httpFile->Write(content.c_str(), static_cast<int>(content.length()));
        httpFile->EndRequest();

        string result;
        char buffer[1024];
        while(int count = httpFile->Read(buffer, 1024))
            result.append(buffer, count);
        return result;
    }

    CUrl m_serverUrl;
    string m_appKey;
    string m_secretCode;
};

int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])
{
    printf("当前测试返回查询物流公司信息,返回为JSON格式:\n");

    TopController topController(topServerUrl, appKey, secretCode);

    TopController::ParamMap parameters;

    // 系统参数
    parameters["format"]    = "json";                                        // 返回格式    
    parameters["method"]    = "taobao.logisticcompanies.get";            // 查询物流公司信息接口
    parameters["v"]            = "1.0";
    parameters["timestamp"]    = "2009-06-28 20:16:12";
    // parameters["session"] = "用户session";                            // 公开API无需session    

    // 用户参数
    parameters["fields"]    = "company_id,company_code,company_name";    // 需要返回的字段

    string result = topController.request(parameters);

    printf("%s\n", CT2A(CA2T(result.c_str(), CP_UTF8)));

    return system("pause");
}

package InterfaceMain;

//package org.openapi.taobao;

import java.security.MessageDigest;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.HashMap;

import java.util.Iterator;

import java.util.Map;

import java.util.Set;

import java.util.TreeSet;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.methods.PostMethod;
public class taoBaoMain {

    /**
     * 
     * 调用淘宝的taobao.trade.get demo，
     * 
     * 运行该示例时，你需要将appId,appSecret,tid
     * 
     * 这三个参数替换为你自己的，就可以运行该demo
     * 
     * 
     * 
     * 在第一次运行时 会提醒你登录淘宝进行授权，
     * 
     * 授权成功后 再次运行该demo就可以获取指定交易的信息 呵呵
     * 
     * 
     * 
     * 这只是一个简单的demo，只是为初学者提供方便
     * 
     * 有了这个原型 大家就可以各显自己的神通了
     */

    public static void main(String[] args) {

        // 淘宝Open API平台即SIP平台的入口

        //String sipRequestUrl = "http://sip.alisoft.com/sip/rest";
        String sipRequestUrl = "http://gw.api.taobao.com/router/rest";

        String appId = "12011726"; // 在阿里软件平台注册的应用ID,请使用你自己的应用ID

        String appSecret = "0c42e9dd6080350503aa8b000434083c"; // 注册的应用的密钥，请使用你自己应用的密钥

        String taobaoApiName = "taobao.trade.get"; // 交易类api

        String sessionId = "2345678";// sessionId是isv应用自己生成的字符串

        // 确保每个使用该应用的用户各自的sessionId各不相同

        SimpleDateFormat formater = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        Map<String, String> params = new HashMap<String, String>();

        params.put("sip_appkey", appId);

        params.put("sip_apiname", taobaoApiName);

        params.put("sip_timestamp", formater.format(new Date()));

        params.put("sip_sessionid", sessionId);

        params.put("fields", "seller_nick,buyer_nick,title,type,created,sid");

        params.put("tid", "2009080484216722"); // 请设置你要查询的交易号

        params.put("format", "xml");

        params.put("v", "1.0");

        params.put("sip_sign", getSign(appSecret, params));

        String result = requestOpenApi(sipRequestUrl, params);

        if (result != null && result.startsWith("sip_isp_loginurl:")) {

            result = result.replaceAll("&amp;", "&");

            System.out.println("打开浏览器，访问下面的URL进行用户授权，授权成功后" +

            "，再次运行该类就可以调用api获取交易信息");

            System.out.println(result.substring("sip_isp_loginurl:".length()));

        } else if (result != null)

            System.out.println(result);

    }

    /**
     * 
     * 请求淘宝Open API服务
     * 
     * @param url
     *            服务集群平台入口
     * 
     * @param params
     *            请求参数
     * 
     * @return 请求结果
     */

    public static String requestOpenApi(String url, Map<String, String> params) {

        HttpClient client = new HttpClient();
        HttpClient c=new HttpClient();
        PostMethod postMethod = new PostMethod(url);
        try {

            NameValuePair[] postData = new NameValuePair[params.size()];

            Iterator<String> iters = params.keySet().iterator();

            int i = 0;

            while (iters.hasNext()) {

                String key = (String) iters.next();

                postData[i] = new NameValuePair(key, params.get(key).toString());

                i++;

            }

            postMethod.setRequestBody(postData);

            client.executeMethod(postMethod);

            String resultCode = postMethod.getResponseHeader("sip_status")

            .getValue();

            if (resultCode == null || ("".equals(resultCode)))

                return null;

            else if ("1004".equals(resultCode))

                return "sip_isp_loginurl:"+ postMethod.getResponseHeader("sip_isp_loginurl").getValue();

            else if (!"9999".equals(resultCode))

                return resultCode+ ":"+ postMethod.getResponseHeader("sip_errormessage").getValue();

            return postMethod.getResponseBodyAsString();

        } catch (Exception ex) {

            ex.printStackTrace();

        } finally {

            if (postMethod != null)

                postMethod.releaseConnection();

        }

        return null;

    }

    /**
     * 
     * 对所有参数进行签名
     * 
     * @param secret
     *            APP ID对应的密钥
     * 
     * @param params
     *            请求中所有的参数
     * 
     * @return 签名
     */

    public static String getSign(String secret, Map<String, String> params) {

        if (secret == null || "".equals(secret) || params == null)

            throw new RuntimeException(

            "secret or params is null or blank, please check");

        StringBuilder sb = new StringBuilder().append(secret);

        String result = null;

        try {

            Set<String> sortedKeys = new TreeSet<String>();

            sortedKeys.addAll(params.keySet());

            for (String key : sortedKeys)

                sb.append(key).append(params.get(key));

            MessageDigest md = MessageDigest.getInstance("MD5");

            result = byteTohex(md.digest(sb.toString().getBytes("utf-8")));

        } catch (Exception e) {

            throw new RuntimeException(e);

        }

        return result;

    }

    public static String byteTohex(byte[] b) {

        StringBuffer sb = new StringBuffer();

        String stmp = "";

        for (int n = 0; n < b.length; n++) {

            stmp = (java.lang.Integer.toHexString(b[n] & 0XFF));

            if (stmp.length() == 1)

                sb.append("0").append(stmp);

            else

                sb.append(stmp);

        }

        return sb.toString().toUpperCase();

    }

}