package com.yeshi.fanli.util.vipshop;
|
|
import java.io.IOException;
|
import java.io.UnsupportedEncodingException;
|
import java.lang.reflect.Type;
|
import java.net.URLEncoder;
|
import java.util.*;
|
|
import com.yeshi.fanli.util.Constant;
|
import org.apache.commons.httpclient.HttpClient;
|
import org.apache.commons.httpclient.HttpException;
|
import org.apache.commons.httpclient.methods.PostMethod;
|
import org.yeshi.utils.StringUtil;
|
|
import com.google.gson.Gson;
|
import com.google.gson.reflect.TypeToken;
|
import com.yeshi.fanli.dto.vip.VIPConvertResultDTO;
|
import com.yeshi.fanli.dto.vip.VIPSearchFilter;
|
import com.yeshi.fanli.dto.vip.VIPSearchResult;
|
import com.yeshi.fanli.dto.vip.goods.VIPGoodsInfo;
|
import com.yeshi.fanli.dto.vipshop.VipShopOrderQueryModel;
|
import com.yeshi.fanli.dto.vipshop.VipShopQueryOrderResultDTO;
|
import com.yeshi.fanli.entity.vipshop.VipShopOrder;
|
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
|
/**
|
* TODO 未完成 唯品会接口
|
* 商品接口链接：https://vop.vip.com/home#/api/method/detail/com.vip.adp.api.open.service.UnionGoodsService-1.3.0/getByGoodsIds
|
* @author Administrator
|
*/
|
public class VipShopApiUtil {
|
|
private final static String appKey = "f9e7f22f";
|
private final static String appSecret = "9B2291352497FAF42B2DF44BFCF62316";
|
|
//是否采用订单侠转链
|
private final static boolean CONVERT_DINGDANXIA = true;
|
|
/**
|
* 获取签名
|
*
|
* @param systemParams
|
* @param taskParams
|
* @return
|
*/
|
private static String getSign(Map<String, String> systemParams, JSONObject taskParams) {
|
List<String> list = new ArrayList<>();
|
for (Iterator<String> its = systemParams.keySet().iterator(); its.hasNext(); ) {
|
String key = its.next();
|
String value = systemParams.get(key);
|
list.add(key + value);
|
}
|
Collections.sort(list);
|
String source = "";
|
for (String st : list)
|
source += st;
|
source += taskParams.toString();
|
return StringUtil.MD5Hmac(source, appSecret);
|
}
|
|
private static Map<String, String> getSystemParams(String service, String method) {
|
Map<String, String> params = new HashMap<String, String>();
|
params.put("service", service);
|
params.put("method", method);
|
params.put("version", "1.0");
|
params.put("timestamp", System.currentTimeMillis() / 1000 + "");
|
params.put("format", "json");
|
params.put("appKey", appKey);
|
return params;
|
}
|
|
/**
|
* 基础请求
|
*
|
* @param service
|
* @param method
|
* @param taskParams
|
* @return
|
*/
|
private static String baseRequest(String service, String method, JSONObject taskParams) {
|
Map<String, String> systemParams = getSystemParams(service, method);
|
String sign = getSign(systemParams, taskParams);
|
systemParams.put("sign", sign);
|
String baseUrl = "https://gw.vipapis.com";
|
baseUrl += "?";
|
for (Iterator<String> its = systemParams.keySet().iterator(); its.hasNext(); ) {
|
String key = its.next();
|
String value = "";
|
try {
|
value = URLEncoder.encode(systemParams.get(key), "UTF-8");
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
baseUrl += key + "=" + value + "&";
|
}
|
baseUrl = baseUrl.endsWith("&") ? baseUrl.substring(0, baseUrl.length() - 1) : baseUrl;
|
String result = post(baseUrl, taskParams.toString());
|
return result;
|
}
|
|
@SuppressWarnings("deprecation")
|
private static String post(String url, String body) {
|
HttpClient client = new HttpClient();
|
PostMethod method = new PostMethod(url);
|
method.addRequestHeader("Content-Type", "application/json;charset=UTF-8");
|
method.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
|
method.setRequestBody(body);
|
try {
|
client.executeMethod(method);
|
return method.getResponseBodyAsString();
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
/**
|
* 搜索
|
*
|
* @param searchFilter
|
* @return VIPSearchResult 返回类型
|
* @throws
|
* @Title: search
|
* @Description:
|
*/
|
public static VIPSearchResult search(VIPSearchFilter searchFilter) {
|
Map<String, String> taskParams = new HashMap<>();
|
taskParams.put("keyword", searchFilter.getKeyword());
|
taskParams.put("page", searchFilter.getPage() + "");
|
taskParams.put("pageSize", searchFilter.getPageSize() + "");
|
taskParams.put("requestId", System.currentTimeMillis() + "_" + UUID.randomUUID());
|
if (searchFilter.getPriceStart() != null)
|
taskParams.put("priceStart", searchFilter.getPriceStart());
|
|
if (searchFilter.getPriceEnd() != null)
|
taskParams.put("priceEnd", searchFilter.getPriceEnd());
|
if (searchFilter.getOrder() != null)
|
taskParams.put("order", searchFilter.getOrder() + "");
|
if (searchFilter.getFieldName() != null)
|
taskParams.put("fieldName", searchFilter.getFieldName() + "");
|
|
//新增参数
|
taskParams.put("chanTag", "default_pid");
|
taskParams.put("openId", "default_open_id");
|
taskParams.put("realCall", "true");
|
|
|
|
|
JSONObject root = new JSONObject();
|
root.put("request", JSONObject.fromObject(taskParams));
|
String result = baseRequest("com.vip.adp.api.open.service.UnionGoodsService", "query", root);
|
System.out.println(result);
|
List<VIPGoodsInfo> goodsList = new ArrayList<>();
|
JSONObject resultJson = JSONObject.fromObject(result);
|
Gson gson = new Gson();
|
if (resultJson.optInt("returnCode") == 0) {
|
resultJson = resultJson.optJSONObject("result");
|
int count = resultJson.optInt("total");
|
|
JSONArray array = resultJson.optJSONArray("goodsInfoList");
|
if (array != null && array.size() > 0) {
|
for (int i = 0; i < array.size(); i++) {
|
JSONObject optJSONObject = array.optJSONObject(i);
|
if (optJSONObject == null) {
|
continue;
|
}
|
VIPGoodsInfo info = gson.fromJson(array.optJSONObject(i).toString(), VIPGoodsInfo.class);
|
if (info != null)
|
goodsList.add(info);
|
}
|
}
|
|
return new VIPSearchResult(goodsList, count);
|
}
|
return null;
|
}
|
|
|
public static VIPSearchResult getGoodsList(int channelType, int page) {
|
Map<String, String> taskParams = new HashMap<>();
|
taskParams.put("channelType", channelType + "");
|
taskParams.put("page", page + "");
|
taskParams.put("pageSize", 20 + "");
|
taskParams.put("requestId", System.currentTimeMillis() + "_" + UUID.randomUUID());
|
|
//新增参数
|
taskParams.put("chanTag", "default_pid");
|
taskParams.put("openId", "default_open_id");
|
taskParams.put("realCall", "true");
|
|
|
JSONObject root = new JSONObject();
|
root.put("request", JSONObject.fromObject(taskParams));
|
String result = baseRequest("com.vip.adp.api.open.service.UnionGoodsService", "goodsList", root);
|
System.out.println(result);
|
List<VIPGoodsInfo> goodsList = new ArrayList<>();
|
JSONObject resultJson = JSONObject.fromObject(result);
|
Gson gson = new Gson();
|
if (resultJson.optInt("returnCode") == 0) {
|
resultJson = resultJson.optJSONObject("result");
|
int count = resultJson.optInt("total");
|
JSONArray array = resultJson.optJSONArray("goodsInfoList");
|
for (int i = 0; i < array.size(); i++) {
|
VIPGoodsInfo info = gson.fromJson(array.optJSONObject(i).toString(), VIPGoodsInfo.class);
|
if (info != null)
|
goodsList.add(info);
|
}
|
return new VIPSearchResult(goodsList, count);
|
}
|
return null;
|
}
|
|
/**
|
* 商品ID转链
|
*
|
* @param goodsId
|
*/
|
public static VIPConvertResultDTO convertLink(String goodsId, String tag) {
|
|
if (CONVERT_DINGDANXIA) {
|
return DingDanXiaApiUtil.convertLink(goodsId, tag);
|
}
|
|
JSONObject taskParams = new JSONObject();
|
JSONArray goodsIdArray = new JSONArray();
|
goodsIdArray.add(goodsId);
|
taskParams.put("goodsIdList", goodsIdArray);
|
taskParams.put("chanTag", tag);
|
taskParams.put("requestId", System.currentTimeMillis() + "_" + UUID.randomUUID());
|
String result = baseRequest("com.vip.adp.api.open.service.UnionUrlService", "genByGoodsId",
|
JSONObject.fromObject(taskParams));
|
System.out.println(result);
|
JSONObject resultJSON = JSONObject.fromObject(result);
|
if (resultJSON.optInt("returnCode") == 0) {
|
String re = resultJSON.optJSONObject("result").optJSONArray("urlInfoList").optJSONObject(0).toString();
|
return new Gson().fromJson(re, VIPConvertResultDTO.class);
|
}
|
return null;
|
}
|
|
|
public static VIPConvertResultDTO convertLinkByUrl(String url, String tag) {
|
|
if (CONVERT_DINGDANXIA) {
|
return DingDanXiaApiUtil.convertLinkByUrl(url, tag);
|
}
|
JSONObject taskParams = new JSONObject();
|
JSONArray urlArray = new JSONArray();
|
urlArray.add(url);
|
taskParams.put("urlList", urlArray);
|
if (tag != null) {
|
taskParams.put("chanTag", tag);
|
}
|
taskParams.put("requestId", System.currentTimeMillis() + "_" + UUID.randomUUID());
|
String result = baseRequest("com.vip.adp.api.open.service.UnionUrlService", "genByVIPUrl",
|
JSONObject.fromObject(taskParams));
|
System.out.println(result);
|
JSONObject resultJSON = JSONObject.fromObject(result);
|
if (resultJSON.optInt("returnCode") == 0) {
|
String re = resultJSON.optJSONObject("result").optJSONArray("urlInfoList").optJSONObject(0).toString();
|
return new Gson().fromJson(re, VIPConvertResultDTO.class);
|
}
|
return null;
|
}
|
|
/**
|
* 根据商品ID获取商品详情
|
*
|
* @param goodsIdList
|
* @return
|
*/
|
public static List<VIPGoodsInfo> getGoodsDetail(List<String> goodsIdList) {
|
JSONObject params = new JSONObject();
|
params.put("goodsIdList", goodsIdList);
|
params.put("requestId", UUID.randomUUID());
|
//新增参数
|
params.put("chanTag", "default_pid");
|
JSONObject request = new JSONObject();
|
request.put("openId", "default_open_id");
|
request.put("realCall", "true");
|
params.put("request", request);
|
|
String result = baseRequest("com.vip.adp.api.open.service.UnionGoodsService", "getByGoodsIds",
|
JSONObject.fromObject(params));
|
System.out.println(result);
|
JSONObject resultJson = JSONObject.fromObject(result);
|
Gson gson = new Gson();
|
List<VIPGoodsInfo> goodsList = new ArrayList<>();
|
if (resultJson.optInt("returnCode") == 0) {
|
JSONArray array = resultJson.optJSONArray("result");
|
for (int i = 0; i < array.size(); i++) {
|
VIPGoodsInfo info = gson.fromJson(array.optJSONObject(i).toString(), VIPGoodsInfo.class);
|
if (info != null)
|
goodsList.add(info);
|
}
|
return goodsList;
|
}
|
return null;
|
}
|
|
/**
|
* 获取商品详情
|
*
|
* @param goodsId
|
* @return
|
*/
|
public static VIPGoodsInfo getGoodsDetail(String goodsId) {
|
List<String> goodsIdList = new ArrayList<>();
|
goodsIdList.add(goodsId);
|
List<VIPGoodsInfo> goodsList = getGoodsDetail(goodsIdList);
|
if (goodsList == null || goodsList.size() == 0)
|
return null;
|
return goodsList.get(0);
|
}
|
|
public static VipShopQueryOrderResultDTO getOrderList(VipShopOrderQueryModel query) {
|
JSONObject params = JSONObject.fromObject(new Gson().toJson(query));
|
params.put("requestId", UUID.randomUUID());
|
JSONObject root = new JSONObject();
|
root.put("queryModel", params);
|
String result = baseRequest("com.vip.adp.api.open.service.UnionOrderService", "orderList", root);
|
System.out.println(result);
|
JSONObject json = JSONObject.fromObject(result);
|
if (json.optInt("returnCode") == 0) {
|
JSONObject resultJson = json.optJSONObject("result");
|
int total = resultJson.optInt("total");
|
JSONArray array = JSONArray.fromObject(resultJson.optJSONArray("orderInfoList"));
|
if (array != null) {
|
Type type = new TypeToken<ArrayList<VipShopOrder>>() {
|
}.getType();
|
List<VipShopOrder> orderList = new Gson().fromJson(array.toString(), type);
|
return new VipShopQueryOrderResultDTO(orderList, total);
|
}
|
}
|
return null;
|
}
|
|
public static void main(String[] args) {
|
// VIPSearchFilter sf=new VIPSearchFilter();
|
// sf.setKeyword("花卉");
|
// sf.setPage(1);
|
// sf.setPageSize(Constant.PAGE_SIZE);
|
// search(sf);
|
|
getGoodsDetail("6920553939593155215");
|
|
// convertLinkByUrl("https://t.vip.com/T7RyKKCJLj9", "437032");
|
// convertLink("560392904","437032");
|
// getOrderList(VipShopOrderQueryModel.createOrderSn(Arrays.asList(new String[]{"23090254293903"}),1));
|
}
|
|
}
|
