package com.yeshi.fanli.util.jd;
|
|
import java.io.UnsupportedEncodingException;
|
import java.lang.reflect.Type;
|
import java.math.BigDecimal;
|
import java.net.URLEncoder;
|
import java.util.*;
|
|
import com.yeshi.fanli.dto.jd.*;
|
import com.yeshi.fanli.entity.jd.JDBackUpOrder;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.taobao.SearchFilterUtil;
|
import com.yeshi.goods.facade.utils.taobao.DaTaoKeApiUtil;
|
import org.apache.commons.httpclient.HttpClient;
|
import org.apache.commons.httpclient.methods.PostMethod;
|
|
import com.google.gson.Gson;
|
import com.google.gson.reflect.TypeToken;
|
import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
|
import com.yeshi.fanli.entity.jd.JDGoods;
|
import com.yeshi.fanli.entity.jd.JDOrder;
|
import com.yeshi.fanli.entity.jd.JDOrderItem;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.common.entity.PageEntity;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.yeshi.utils.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.StringUtil;
|
import org.yeshi.utils.TimeUtil;
|
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
|
public class JDApiUtil {
|
|
final static Logger logger = LoggerFactory.getLogger("jdApiLogger");
|
|
public static String APP_ID = "1864778416";
|
public static String APP_KEY = "388f5133d13a5ea290aa5c44f3ebcc00";
|
public static String SECRET_KEY = "270eefea04d44e33b5c21511aa857458";
|
private static String SERVER_URL = "https://router.jd.com/api";
|
|
// 订单查询类型
|
public static int ORDER_TYPE_CREATETIME = 1;// 下单时间
|
public static int ORDER_TYPE_FINISHTIME = 2;// 完成时间
|
public static int ORDER_TYPE_UPDATETIME = 3;// 更新时间
|
|
private static String post2(String url, Map<String, String> params) {
|
String baseUrl = url;
|
List<String> paramsList = new ArrayList<>();
|
if (params != null)
|
for (Iterator<String> its = params.keySet().iterator(); its.hasNext(); ) {
|
String key = its.next();
|
try {
|
paramsList.add(key + "=" + URLEncoder.encode(params.get(key), "UTF-8"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
baseUrl += "?" + StringUtil.concat(paramsList, "&");
|
HttpClient client = new HttpClient();
|
PostMethod pm = new PostMethod(baseUrl);
|
try {
|
client.executeMethod(pm);
|
String result = pm.getResponseBodyAsString();
|
return result;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
private static String getSign(Map<String, String> params) {
|
List<String> list = new ArrayList<>();
|
Iterator<String> its = params.keySet().iterator();
|
while (its.hasNext()) {
|
String key = its.next();
|
list.add(key + params.get(key));
|
}
|
String str = "";
|
Collections.sort(list);
|
for (String st : list) {
|
str += st;
|
}
|
return StringUtil.Md5(SECRET_KEY + str + SECRET_KEY).toUpperCase();
|
}
|
|
private static String baseRequest2(String method, String accessToken, JSONObject params) {
|
Map<String, String> baseMap = new HashMap<String, String>();
|
baseMap.put("param_json", params.toString());
|
baseMap.put("app_key", APP_KEY);
|
baseMap.put("method", method);
|
if (accessToken != null)
|
baseMap.put("access_token", accessToken);
|
baseMap.put("timestamp", TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss"));
|
baseMap.put("format", "json");
|
baseMap.put("v", "1.0");
|
baseMap.put("sign_method", "md5");
|
baseMap.put("sign", getSign(baseMap));
|
String result = post2(SERVER_URL, baseMap);
|
return result;
|
}
|
|
/**
|
* 转链
|
*
|
* @return
|
*/
|
public static String convertLink1(String materialId, String couponUrl, String positionId, String ext1, String giftCouponKey) {
|
JSONObject json = new JSONObject();
|
json.put("materialId", materialId);
|
json.put("siteId", APP_ID);
|
json.put("positionId", positionId);
|
|
if (!StringUtil.isNullOrEmpty(couponUrl))
|
json.put("couponUrl", couponUrl);
|
|
if (!StringUtil.isNullOrEmpty(ext1))
|
json.put("ext1", ext1);
|
if (!StringUtil.isNullOrEmpty(giftCouponKey))
|
json.put("giftCouponKey", giftCouponKey);
|
|
JSONObject root = new JSONObject();
|
root.put("promotionCodeReq", json);
|
|
String result = baseRequest2("jd.union.open.promotion.common.get", null, root);
|
|
JSONObject resultJson = JSONObject.fromObject(result);
|
result = resultJson.optJSONObject("jd_union_open_promotion_common_get_response").optString("result");
|
System.out.println(result);
|
if (result == null) {
|
return null;
|
}
|
|
resultJson = JSONObject.fromObject(result);
|
return resultJson.optJSONObject("data").optString("clickURL");
|
}
|
|
public static String convertLinkWithSubUnionId(String materialId, String couponUrl, String giftCouponKey, String positionId,
|
String subUnionId) throws Exception {
|
String log = "京东转链出错:";
|
JSONObject json = new JSONObject();
|
|
json.put("siteId", APP_ID);
|
json.put("positionId", positionId);
|
json.put("materialId", materialId);
|
|
if (!StringUtil.isNullOrEmpty(giftCouponKey)) {
|
json.put("giftCouponKey", giftCouponKey);
|
}
|
if (!StringUtil.isNullOrEmpty(couponUrl))
|
json.put("couponUrl", couponUrl);
|
|
if (!StringUtil.isNullOrEmpty(subUnionId))
|
json.put("subUnionId", subUnionId);
|
|
// 1：长链， 2 ：短链 ，3： 长链+短链
|
json.put("chainType", 3);
|
JSONObject root = new JSONObject();
|
root.put("promotionCodeReq", json);
|
|
String result = baseRequest2("jd.union.open.promotion.bysubunionid.get", null, root);
|
|
log += json.toString() + "####" + result;
|
JSONObject resultJson = JSONObject.fromObject(result);
|
result = resultJson.optJSONObject("jd_union_open_promotion_bysubunionid_get_response").optString("result");
|
System.out.println(result);
|
if (result == null) {
|
return null;
|
}
|
|
resultJson = JSONObject.fromObject(result);
|
return resultJson.optJSONObject("data").optString("shortURL");
|
}
|
|
public static JDGoods queryGoodsDetail(String itemId) {
|
List<String> itemIdList = new ArrayList<>();
|
itemIdList.add(itemId);
|
JDFilter filter = new JDFilter();
|
filter.setPageIndex(1);
|
filter.setPageSize(20);
|
filter.setListItemId(itemIdList);
|
JDSearchResult searchResult = queryByKey(filter);
|
if (searchResult != null) {
|
List<JDGoods> list = searchResult.getGoodsList();
|
if (list != null && list.size() > 0)
|
return list.get(0);
|
}
|
return null;
|
}
|
|
public static List<JDGoods> queryGoodsDetail(List<String> itemIdList) {
|
JDFilter filter = new JDFilter();
|
filter.setPageIndex(1);
|
filter.setPageSize(20);
|
filter.setListItemId(itemIdList);
|
JDSearchResult searchResult = queryByKey(filter);
|
if (searchResult != null) {
|
List<JDGoods> list = searchResult.getGoodsList();
|
if (list != null && list.size() > 0)
|
return list;
|
}
|
return null;
|
}
|
|
/**
|
* 通过商品搜索接口批量获取详情
|
*
|
* @param itemIds
|
* @return
|
*/
|
public static List<JDGoods> listGoodsDetail(List<String> itemIds) {
|
JDFilter filter = new JDFilter();
|
filter.setListItemId(itemIds);
|
JDSearchResult result = queryByKey(filter);
|
return result.getGoodsList();
|
}
|
|
/**
|
* 关键词商品查询接口【申请】
|
*
|
* @param filter
|
* @return
|
*/
|
public static JDSearchResult queryByKey(JDFilter filter) {
|
logger.info(String.format("queryByKey:%s %s", filter.getKeyword(), StringUtil.concat(filter.getListItemId(), ",")));
|
|
JDSearchResult searchResult = new JDSearchResult();
|
|
List<JDGoods> list = new ArrayList<>();
|
JSONObject json = new JSONObject();
|
json.put("pageIndex", filter.getPageIndex());
|
json.put("pageSize", filter.getPageSize());
|
// json.put("sceneId", 1);
|
|
|
if (filter.getCid1() != null)
|
json.put("cid1", filter.getCid1());
|
|
if (filter.getCid2() != null)
|
json.put("cid2", filter.getCid2());
|
|
if (filter.getCid3() != null)
|
json.put("cid3", filter.getCid3());
|
|
if (filter.getKeyword() != null)
|
json.put("keyword", filter.getKeyword());
|
|
if (filter.getPricefrom() != null)
|
json.put("pricefrom", filter.getPricefrom());
|
|
if (filter.getPriceto() != null)
|
json.put("priceto", filter.getPriceto());
|
|
if (filter.getCommissionShareStart() != null)
|
json.put("commissionShareStart", filter.getCommissionShareStart());
|
|
if (filter.getCommissionShareEnd() != null)
|
json.put("commissionShareEnd", filter.getCommissionShareEnd());
|
|
if (filter.getSortName() != null)
|
json.put("sortName", filter.getSortName());
|
|
if (filter.getSort() != null)
|
json.put("sort", filter.getSort());
|
|
if (filter.getIsCoupon() != null)
|
json.put("isCoupon", filter.getIsCoupon());
|
|
if (filter.getListItemId() != null)
|
json.put("itemIds", new Gson().toJson(filter.getListItemId()));
|
|
if (filter.getIsPG() != null)
|
json.put("isPG", filter.getIsPG());
|
|
if (filter.getPingouPriceStart() != null)
|
json.put("pingouPriceStart", filter.getPingouPriceStart());
|
|
if (filter.getPingouPriceEnd() != null)
|
json.put("pingouPriceEnd", filter.getPingouPriceEnd());
|
|
if (filter.getIsHot() != null)
|
json.put("isHot", filter.getIsHot());
|
|
if (filter.getBrandCode() != null)
|
json.put("brandCode", filter.getBrandCode());
|
|
if (filter.getShopId() != null)
|
json.put("shopId", filter.getShopId());
|
|
if (filter.getOwner() != null)
|
json.put("owner", filter.getOwner());
|
|
System.out.println(json.toString());
|
String result = "";
|
|
|
JSONObject jsonDTO = new JSONObject();
|
jsonDTO.put("goodsReqDTO", json);
|
result = baseRequest2("jd.union.open.goods.query", null, jsonDTO);
|
System.out.println(result);
|
JSONObject resultJson = JSONObject.fromObject(result);
|
resultJson = resultJson.optJSONObject("jd_union_open_goods_query_response");
|
if (resultJson != null && resultJson.optInt("code") == 0) {
|
result = resultJson.optString("result");
|
resultJson = JSONObject.fromObject(result);
|
String message = resultJson.optString("message");
|
if ("SUCCESS".equalsIgnoreCase(message)) {
|
JSONArray array = resultJson.optJSONArray("data");
|
System.out.println(array.toString());
|
if (array != null) {
|
for (int i = 0; i < array.size(); i++) {
|
JDGoods goods = parseJDGoods(array.optJSONObject(i));
|
if (goods != null)
|
list.add(goods);
|
}
|
}
|
}
|
long totalCount = resultJson.optLong("totalCount");
|
PageEntity pageEntity = new PageEntity();
|
pageEntity.setTotalCount(totalCount);
|
searchResult.setPageEntity(pageEntity);
|
} else {
|
result = DaTaoKeApiUtil.searchJDGoods(json);
|
resultJson = JSONObject.fromObject(result);
|
if (resultJson.optInt("code") == 0) {
|
JSONObject data = resultJson.optJSONObject("data");
|
JSONArray array = data.optJSONArray("list");
|
for (int i = 0; i < array.size(); i++) {
|
JSONObject item = array.optJSONObject(i);
|
JDGoods goods = parseDaTaoKeJDGoods(item);
|
if (goods != null)
|
list.add(goods);
|
}
|
|
long totalCount = data.optLong("totalNum");
|
PageEntity pageEntity = new PageEntity();
|
pageEntity.setTotalCount(totalCount);
|
searchResult.setPageEntity(pageEntity);
|
}
|
System.out.printf(result);
|
|
}
|
|
|
searchResult.setGoodsList(list);
|
return searchResult;
|
}
|
|
/**
|
* 解析京东的券信息
|
*
|
* @param json
|
* @return
|
*/
|
private static JDCouponInfo parseJDCouponInfo(JSONObject json) {
|
JDCouponInfo couponInfo = new Gson().fromJson(json.toString(), JDCouponInfo.class);
|
return couponInfo;
|
}
|
|
/**
|
* 解析京东商品信息
|
*
|
* @param json
|
* @return
|
*/
|
|
private static JDGoods parseJDGoods(JSONObject json) {
|
JDGoods goods = new JDGoods();
|
|
// 佣金信息
|
Object commission = json.get("commissionInfo");
|
JSONObject commissionJson = JSONObject.fromObject(commission);
|
BigDecimal commissionShare = new BigDecimal(commissionJson.optString("commissionShare"));
|
if (commissionShare.compareTo(new BigDecimal(0)) > 0) {
|
JDCommissionInfo commissionInfo = new JDCommissionInfo();
|
commissionInfo.setCommission(new BigDecimal(commissionJson.optString("commission")));
|
commissionInfo.setCommissionShare(commissionShare);
|
goods.setCommissionInfo(commissionInfo);
|
} else {
|
return null;
|
}
|
goods.setItemId(json.optString("itemId"));
|
goods.setComments(json.optLong("comments"));
|
goods.setBrandCode(json.optString("brandCode"));
|
goods.setBrandName(json.optString("brandName"));
|
goods.setGoodCommentsShare(new BigDecimal(json.optString("goodCommentsShare")));
|
goods.setInOrderCount30Days(json.optLong("inOrderCount30Days"));
|
goods.setOwner(json.optString("owner"));
|
goods.setMaterialUrl(json.optString("materialUrl"));
|
goods.setSkuId(json.optLong("skuId"));
|
goods.setSpuid(json.optLong("spuid"));
|
goods.setSkuName(json.optString("skuName"));
|
goods.setIsHot(json.optInt("isHot"));
|
|
// 价格信息
|
Object priceInfo = json.get("priceInfo");
|
JSONObject priceInfoJson = JSONObject.fromObject(priceInfo);
|
goods.setPrice(new BigDecimal(priceInfoJson.optString("price")));
|
|
// 店铺信息
|
Object shopInfo = json.get("shopInfo");
|
JSONObject shopInfoJson = JSONObject.fromObject(shopInfo);
|
JDShopInfo jdshopInfo = new JDShopInfo();
|
jdshopInfo.setShopId(shopInfoJson.optInt("shopId"));
|
jdshopInfo.setShopName(shopInfoJson.optString("shopName"));
|
goods.setShopInfo(jdshopInfo);
|
|
// 分类信息
|
Object category = json.get("categoryInfo");
|
JSONObject categoryJson = JSONObject.fromObject(category);
|
JDCategoryInfo categoryInfo = new JDCategoryInfo();
|
categoryInfo.setCid1(categoryJson.optLong("cid1"));
|
categoryInfo.setCid1Name(categoryJson.optString("cid1Name"));
|
categoryInfo.setCid2(categoryJson.optLong("cid2"));
|
categoryInfo.setCid2Name(categoryJson.optString("cid2Name"));
|
categoryInfo.setCid3(categoryJson.optLong("cid3"));
|
categoryInfo.setCid3Name(categoryJson.optString("cid3Name"));
|
goods.setCategoryInfo(categoryInfo);
|
|
// 图片信息
|
List<String> imageList = new ArrayList<String>();
|
Object images = json.get("imageInfo");
|
JSONObject imagesJson = JSONObject.fromObject(images);
|
JSONArray imagesArray = imagesJson.optJSONArray("imageList");
|
for (int i = 0; i < imagesArray.size(); i++) {
|
imageList.add(imagesArray.optJSONObject(i).optString("url"));
|
}
|
goods.setImageList(imageList);
|
|
if (imageList.size() > 0) {
|
goods.setPicUrl(imageList.get(0));
|
}
|
|
BigDecimal price = new BigDecimal(priceInfoJson.optString("price"));
|
// 拼购信息
|
Object pinGouInfo = json.get("pinGouInfo");
|
if (pinGouInfo != null) {
|
JSONObject pinGouInfoJson = JSONObject.fromObject(pinGouInfo);
|
if (!pinGouInfoJson.isEmpty()) {
|
JDPingouInfo jdPinGouInfo = new JDPingouInfo();
|
price = new BigDecimal(pinGouInfoJson.optString("pingouPrice"));
|
jdPinGouInfo.setPingouPrice(price);
|
jdPinGouInfo.setPingouTmCount(pinGouInfoJson.optLong("pingouTmCount"));
|
jdPinGouInfo.setPingouUrl(pinGouInfoJson.optString("pingouUrl"));
|
jdPinGouInfo.setTotalCount(pinGouInfoJson.optLong("totalCount"));
|
jdPinGouInfo.setPingouEndTime(pinGouInfoJson.optLong("pingouEndTime"));
|
jdPinGouInfo.setPingouStartTime(pinGouInfoJson.optLong("pingouStartTime"));
|
goods.setPinGouInfo(jdPinGouInfo);
|
}
|
}
|
|
// 券信息
|
Object coupon = json.get("couponInfo");
|
if (coupon != null) {
|
JSONObject couponJson = JSONObject.fromObject(coupon);
|
JSONArray couponArray = couponJson.optJSONArray("couponList");
|
if (couponArray != null) {
|
List<JDCouponInfo> couponInfoList = new ArrayList<>();
|
for (int i = 0; i < couponArray.size(); i++) {
|
JDCouponInfo couponInfo = parseJDCouponInfo(couponArray.optJSONObject(i));
|
if (couponInfo != null)
|
couponInfoList.add(couponInfo);
|
}
|
|
// 根据消费条件排序
|
Comparator<JDCouponInfo> cm = new Comparator<JDCouponInfo>() {
|
@Override
|
public int compare(JDCouponInfo o1, JDCouponInfo o2) {
|
return o1.getQuota().compareTo(o2.getQuota());
|
}
|
};
|
Collections.sort(couponInfoList, cm);
|
// if (couponInfoList.size() > 0) {
|
// // 设置券信息为最接近的一个
|
// for (int i = couponInfoList.size() - 1; i >= 0; i--) {
|
// if
|
// (couponInfoList.get(i).getQuota().compareTo(goods.getPrice())
|
// <= 0) {
|
// goods.setCouponInfo(couponInfoList.get(i));
|
// break;
|
// }
|
// }
|
// if (goods.getCouponInfo() == null)
|
// goods.setCouponInfo(couponInfoList.get(0));
|
// }
|
//
|
goods.setCouponInfoList(couponInfoList);
|
|
}
|
}
|
|
return goods;
|
}
|
|
|
private static JDGoods parseDaTaoKeJDGoods(JSONObject json) {
|
JDGoods goods = new JDGoods();
|
|
// 佣金信息
|
BigDecimal commissionShare = new BigDecimal(json.optString("commissionShare"));
|
if (commissionShare.compareTo(new BigDecimal(0)) > 0) {
|
JDCommissionInfo commissionInfo = new JDCommissionInfo();
|
commissionInfo.setCommission(new BigDecimal(json.optString("commission")));
|
commissionInfo.setCommissionShare(commissionShare);
|
goods.setCommissionInfo(commissionInfo);
|
} else {
|
return null;
|
}
|
|
goods.setComments(json.optLong("comments"));
|
goods.setBrandCode(json.optString("brandCode"));
|
goods.setBrandName(json.optString("brandName"));
|
goods.setGoodCommentsShare(new BigDecimal(json.optString("goodCommentsShare")));
|
goods.setInOrderCount30Days(json.optLong("inOrderCount30Days"));
|
goods.setOwner(json.optString("owner"));
|
goods.setMaterialUrl(json.optString("materialUrl"));
|
goods.setSkuId(json.optLong("skuId"));
|
goods.setSkuName(json.optString("skuName"));
|
goods.setIsHot(json.optInt("isHot"));
|
|
// 价格信息
|
goods.setPrice(new BigDecimal(json.optString("price")));
|
|
// 店铺信息
|
JDShopInfo jdshopInfo = new JDShopInfo();
|
jdshopInfo.setShopId(json.optInt("shopId"));
|
jdshopInfo.setShopName(json.optString("shopName"));
|
goods.setShopInfo(jdshopInfo);
|
|
// 分类信息
|
JDCategoryInfo categoryInfo = new JDCategoryInfo();
|
categoryInfo.setCid1(json.optLong("cid1"));
|
categoryInfo.setCid1Name(json.optString("cid1Name"));
|
categoryInfo.setCid2(json.optLong("cid2"));
|
categoryInfo.setCid2Name(json.optString("cid2Name"));
|
categoryInfo.setCid3(json.optLong("cid3"));
|
categoryInfo.setCid3Name(json.optString("cid3Name"));
|
goods.setCategoryInfo(categoryInfo);
|
|
// 图片信息
|
List<String> imageList = new ArrayList<>();
|
JSONArray imagesArray = json.optJSONArray("imageUrlList");
|
for (int i = 0; i < imagesArray.size(); i++) {
|
imageList.add(imagesArray.optString(i));
|
}
|
goods.setImageList(imageList);
|
|
if (imageList.size() > 0) {
|
goods.setPicUrl(imageList.get(0));
|
}
|
|
BigDecimal price = new BigDecimal(json.optString("price"));
|
// 拼购信息
|
Object pinGouInfo = json.get("pinGouInfo");
|
if (pinGouInfo != null) {
|
JSONObject pinGouInfoJson = JSONObject.fromObject(pinGouInfo);
|
if (!pinGouInfoJson.isEmpty()) {
|
JDPingouInfo jdPinGouInfo = new JDPingouInfo();
|
price = new BigDecimal(pinGouInfoJson.optString("pingouPrice"));
|
jdPinGouInfo.setPingouPrice(price);
|
jdPinGouInfo.setPingouTmCount(pinGouInfoJson.optLong("pingouTmCount"));
|
jdPinGouInfo.setPingouUrl(pinGouInfoJson.optString("pingouUrl"));
|
jdPinGouInfo.setTotalCount(pinGouInfoJson.optLong("totalCount"));
|
jdPinGouInfo.setPingouEndTime(pinGouInfoJson.optLong("pingouEndTime"));
|
jdPinGouInfo.setPingouStartTime(pinGouInfoJson.optLong("pingouStartTime"));
|
goods.setPinGouInfo(jdPinGouInfo);
|
}
|
}
|
|
// 券信息
|
Object coupon = json.get("couponInfo");
|
if (coupon != null) {
|
JSONArray couponArray = json.optJSONArray("couponList");
|
if (couponArray != null) {
|
List<JDCouponInfo> couponInfoList = new ArrayList<>();
|
for (int i = 0; i < couponArray.size(); i++) {
|
JDCouponInfo couponInfo = parseJDCouponInfo(couponArray.optJSONObject(i));
|
if (couponInfo != null)
|
couponInfoList.add(couponInfo);
|
}
|
|
// 根据消费条件排序
|
Comparator<JDCouponInfo> cm = new Comparator<JDCouponInfo>() {
|
@Override
|
public int compare(JDCouponInfo o1, JDCouponInfo o2) {
|
return o1.getQuota().compareTo(o2.getQuota());
|
}
|
};
|
Collections.sort(couponInfoList, cm);
|
// if (couponInfoList.size() > 0) {
|
// // 设置券信息为最接近的一个
|
// for (int i = couponInfoList.size() - 1; i >= 0; i--) {
|
// if
|
// (couponInfoList.get(i).getQuota().compareTo(goods.getPrice())
|
// <= 0) {
|
// goods.setCouponInfo(couponInfoList.get(i));
|
// break;
|
// }
|
// }
|
// if (goods.getCouponInfo() == null)
|
// goods.setCouponInfo(couponInfoList.get(0));
|
// }
|
//
|
goods.setCouponInfoList(couponInfoList);
|
|
}
|
}
|
|
return goods;
|
}
|
|
|
/**
|
* 获取推广商品信息接口
|
*
|
* @param itemIdList
|
* @return
|
*/
|
public static List<JDGoods> getGoodsDetail(List<String> itemIdList) {
|
List<JDGoods> list = new ArrayList<>();
|
JSONObject json = new JSONObject();
|
json.put("itemIds", StringUtil.concat(itemIdList, ","));
|
String result = baseRequest2("jd.union.open.goods.promotiongoodsinfo.query", null, json);
|
System.out.println(result);
|
JSONObject resultJson = JSONObject.fromObject(result);
|
resultJson = resultJson.optJSONObject("jd_union_open_goods_promotiongoodsinfo_query_response");
|
if (resultJson.optInt("code") == 0) {
|
result = resultJson.optString("result");
|
resultJson = JSONObject.fromObject(result);
|
JSONArray array = resultJson.optJSONArray("data");
|
if (array != null)
|
for (int i = 0; i < array.size(); i++) {
|
JDGoods goods = parseSimpleJDGoods(array.optJSONObject(i));
|
if (goods != null)
|
list.add(goods);
|
}
|
}
|
return list;
|
}
|
|
private static JDGoods parseSimpleJDGoods(JSONObject json) {
|
JDGoods goods = new JDGoods();
|
goods.setPrice(StringUtil.isNullOrEmpty(json.optString("wlUnitPrice"))
|
? new BigDecimal(json.optString("unitPrice")) : new BigDecimal(json.optString("wlUnitPrice")));
|
|
BigDecimal commisionRatioWl = new BigDecimal(json.optString("commisionRatioWl"));
|
if (commisionRatioWl.compareTo(new BigDecimal(0)) > 0) {
|
JDCommissionInfo commissionInfo = new JDCommissionInfo();
|
commissionInfo.setCommissionShare(new BigDecimal(json.optString("commisionRatioWl")));
|
commissionInfo.setCommission(MoneyBigDecimalUtil
|
.div(goods.getPrice().multiply(commissionInfo.getCommissionShare()), new BigDecimal(100)));
|
goods.setCommissionInfo(commissionInfo);
|
} else {
|
return null;
|
}
|
|
JDCategoryInfo categoryInfo = new JDCategoryInfo();
|
categoryInfo.setCid1(json.optLong("cid1"));
|
categoryInfo.setCid1Name(json.optString("cid1Name"));
|
categoryInfo.setCid2(json.optLong("cid2"));
|
categoryInfo.setCid2Name(json.optString("cid2Name"));
|
categoryInfo.setCid3(json.optLong("cid3"));
|
categoryInfo.setCid3Name(json.optString("cid3Name"));
|
|
goods.setCategoryInfo(categoryInfo);
|
goods.setComments(null);
|
|
String isFreeShipping = json.optString("isFreeShipping");
|
if (!StringUtil.isNullOrEmpty(isFreeShipping)) {
|
goods.setIsFreeShipping(Integer.parseInt(isFreeShipping));
|
}
|
String inOrderCount = json.optString("inOrderCount");
|
if (!StringUtil.isNullOrEmpty(isFreeShipping)) {
|
goods.setInOrderCount30Days(Long.parseLong(inOrderCount));
|
}
|
|
goods.setGoodCommentsShare(null);
|
List<String> imageList = new ArrayList<>();
|
imageList.add(json.optString("imgUrl"));
|
goods.setPicUrl(json.optString("imgUrl"));
|
goods.setImageList(imageList);
|
goods.setIsHot(null);
|
goods.setMaterialUrl(json.optString("materialUrl"));
|
goods.setOwner(null);
|
goods.setPinGouInfo(null);
|
|
JDShopInfo shopInfo = new JDShopInfo();
|
shopInfo.setShopId(json.optInt("shopId"));
|
shopInfo.setShopName(null);
|
goods.setShopInfo(shopInfo);
|
goods.setSkuId(json.optLong("skuId"));
|
goods.setSkuName(json.optString("goodsName"));
|
goods.setTotalCount(null);
|
|
return goods;
|
}
|
|
public static JDSearchResult getJingFenGoods(int pageIndex, int eliteId) {
|
JDSearchResult searchResult = new JDSearchResult();
|
List<JDGoods> list = new ArrayList<>();
|
JSONObject json = new JSONObject();
|
json.put("pageIndex", pageIndex);
|
json.put("pageSize", 20);
|
json.put("sortName", "inOrderCount30DaysSku");
|
json.put("sort", "desc");
|
json.put("eliteId", eliteId);
|
|
JSONObject jsonDTO = new JSONObject();
|
jsonDTO.put("goodsReq", json);
|
|
String result = baseRequest2("jd.union.open.goods.jingfen.query", null, jsonDTO);
|
LogHelper.test(result);
|
System.out.println(result);
|
JSONObject resultJson = JSONObject.fromObject(result);
|
resultJson = resultJson.optJSONObject("jd_union_open_goods_jingfen_query_response");
|
if (resultJson.optInt("code") == 0) {
|
result = resultJson.optString("result");
|
resultJson = JSONObject.fromObject(result);
|
String message = resultJson.optString("message");
|
if ("SUCCESS".equalsIgnoreCase(message)) {
|
JSONArray array = resultJson.optJSONArray("data");
|
if (array != null) {
|
for (int i = 0; i < array.size(); i++) {
|
JDGoods goods = parseJDGoods(array.optJSONObject(i));
|
if (goods != null)
|
list.add(goods);
|
}
|
}
|
}
|
|
long totalCount = resultJson.optLong("totalCount");
|
PageEntity pageEntity = new PageEntity();
|
pageEntity.setTotalCount(totalCount);
|
|
searchResult.setPageEntity(pageEntity);
|
}
|
searchResult.setGoodsList(list);
|
return searchResult;
|
}
|
|
public static List<GoodsClass> getGoodsClass(int parentId, int grade) {
|
JDSearchResult searchResult = new JDSearchResult();
|
List<GoodsClass> list = new ArrayList<>();
|
JSONObject json = new JSONObject();
|
json.put("parentId", parentId);
|
json.put("grade", grade);
|
|
JSONObject jsonDTO = new JSONObject();
|
jsonDTO.put("req", json);
|
|
String result = baseRequest2("jd.union.open.category.goods.get", null, jsonDTO);
|
System.out.println(result);
|
JSONObject resultJson = JSONObject.fromObject(result);
|
resultJson = resultJson.optJSONObject("jd_union_open_category_goods_get_response");
|
if (resultJson.optInt("code") == 0) {
|
result = resultJson.optString("result");
|
resultJson = JSONObject.fromObject(result);
|
String message = resultJson.optString("message");
|
if ("SUCCESS".equalsIgnoreCase(message)) {
|
JSONArray array = resultJson.optJSONArray("data");
|
if (array != null) {
|
for (int i = 0; i < array.size(); i++) {
|
GoodsClass gc = new GoodsClass();
|
JSONObject item = array.optJSONObject(i);
|
gc.setName(item.optString("name"));
|
gc.setId(item.optLong("id"));
|
list.add(gc);
|
}
|
}
|
}
|
|
long totalCount = resultJson.optLong("totalCount");
|
PageEntity pageEntity = new PageEntity();
|
pageEntity.setTotalCount(totalCount);
|
searchResult.setPageEntity(pageEntity);
|
}
|
return list;
|
}
|
|
public static JDGoods getGoodsDetail(String itemId) {
|
List<String> skuIdList = new ArrayList<>();
|
skuIdList.add(itemId);
|
List<JDGoods> list = getGoodsDetail(skuIdList);
|
if (list != null && list.size() > 0)
|
return list.get(0);
|
return null;
|
}
|
|
/**
|
* 获取订单列表
|
*
|
* @param page
|
* @param pageSize
|
* @param time
|
* @param type 时间类型 1-下单时间 2-完成时间 3-更新时间
|
* @return
|
*/
|
public static JDOrderResult getOrderList(int page, int pageSize, Date time, int type) {
|
JSONObject json = new JSONObject();
|
JSONObject orderReq = new JSONObject();
|
orderReq.put("pageNo", page);
|
orderReq.put("pageSize", pageSize);
|
orderReq.put("type", type);
|
orderReq.put("time", TimeUtil.getGernalTime(time.getTime(), "yyyyMMddHH"));
|
|
json.put("orderReq", orderReq);
|
String result = baseRequest2("jd.union.open.order.query", null, json);
|
System.out.println(result);
|
JSONObject root = JSONObject.fromObject(result).optJSONObject("jd_union_open_order_query_response");
|
if (root.optInt("code") == 0) {
|
boolean hasMore = root.optBoolean("hasMore");
|
root = JSONObject.fromObject(root.optString("result"));
|
if (root.optInt("code") == 200 && root.optJSONArray("data") != null) {
|
|
JSONArray data = root.optJSONArray("data");
|
Type typeToken = new TypeToken<List<JDOrder>>() {
|
}.getType();
|
List<JDOrder> orderList = new Gson().fromJson(data.toString(), typeToken);
|
if (orderList != null)
|
for (JDOrder order : orderList) {
|
Map<String, List<JDOrderItem>> map = new HashMap<>();
|
for (int i = 0; i < order.getOrderItemList().size(); i++) {
|
JDOrderItem orderItem = order.getOrderItemList().get(i);
|
String goodsId = getGoodsId(orderItem, order.getOrderItemList().size());
|
if (map.get(goodsId) == null)
|
map.put(goodsId, new ArrayList<>());
|
map.get(goodsId).add(orderItem);
|
|
order.getOrderItemList().get(i)
|
.setTradeId(order.getOrderId() + "-" + getGoodsId(order.getOrderItemList().get(i),order.getOrderItemList().size()));
|
order.getOrderItemList().get(i).setOrderId(order.getOrderId());
|
order.getOrderItemList().get(i).setOrderBy(i + 1);
|
}
|
// 查询商品ID相同的子订单
|
for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) {
|
String goodsId = its.next();
|
if (map.get(goodsId).size() > 1) {
|
int skuOrderBy = 1;
|
for (int i = 0; i < order.getOrderItemList().size(); i++) {
|
JDOrderItem orderItem = order.getOrderItemList().get(i);
|
if (getGoodsId(orderItem,order.getOrderItemList().size()).equalsIgnoreCase(goodsId)) {
|
order.getOrderItemList().get(i).setTradeId(order.getOrderId() + "-"
|
+ getGoodsId(order.getOrderItemList().get(i), order.getOrderItemList().size()) + "-" + skuOrderBy++);
|
}
|
}
|
}
|
}
|
|
}
|
return new JDOrderResult(hasMore, orderList);
|
}
|
}
|
return null;
|
}
|
|
private static String getGoodsId(JDOrderItem item, int itemCount) {
|
if (itemCount <= 1) {
|
return item.getSkuId() + "";
|
}
|
if (item.getSkuId() != null) {
|
return item.getSkuId() + "";
|
}
|
return item.getItemId().split("_")[1];
|
}
|
|
|
public static JDOrderForBackUpResult getOrderListForBackUp(int page, int pageSize, Date time, int type) {
|
JSONObject json = new JSONObject();
|
JSONObject orderReq = new JSONObject();
|
orderReq.put("pageNo", page);
|
orderReq.put("pageSize", pageSize);
|
orderReq.put("type", type);
|
orderReq.put("time", TimeUtil.getGernalTime(time.getTime(), "yyyyMMddHH"));
|
|
json.put("orderReq", orderReq);
|
String result = baseRequest2("jd.union.open.order.query", null, json);
|
System.out.println(result);
|
JSONObject root = JSONObject.fromObject(result).optJSONObject("jd_union_open_order_query_response");
|
if (root.optInt("code") == 0) {
|
boolean hasMore = root.optBoolean("hasMore");
|
root = JSONObject.fromObject(root.optString("result"));
|
if (root.optInt("code") == 200 && root.optJSONArray("data") != null) {
|
List<JDBackUpOrder> orderList = new ArrayList<>();
|
JSONArray data = root.optJSONArray("data");
|
for (int i = 0; i < data.size(); i++) {
|
JSONObject item = data.optJSONObject(i);
|
String orderId = item.optString("orderId");
|
Long orderTime = item.optLong("orderTime");
|
JDBackUpOrder order = new JDBackUpOrder();
|
order.setId(orderId);
|
order.setContent(item.toString());
|
order.setOrderTime(new Date(orderTime));
|
orderList.add(order);
|
}
|
return new JDOrderForBackUpResult(hasMore, orderList);
|
}
|
}
|
return null;
|
}
|
|
|
public static String createLiJin(String sku) {
|
JSONObject json = new JSONObject();
|
JSONObject couponReq = new JSONObject();
|
couponReq.put("skuMaterialId", sku);
|
couponReq.put("discount", 10.01);
|
couponReq.put("amount", 5);
|
couponReq.put("receiveStartTime", TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd HH"));
|
couponReq.put("receiveEndTime", TimeUtil.getGernalTime(System.currentTimeMillis() + 1000 * 60 * 2, "yyyy-MM-dd HH"));
|
couponReq.put("isSpu", 0);
|
couponReq.put("expireType", 2);
|
couponReq.put("useStartTime", TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd"));
|
couponReq.put("useEndTime", TimeUtil.getGernalTime(System.currentTimeMillis() + 1000 * 60 * 60L * 24, "yyyy-MM-dd"));
|
couponReq.put("share", 1);
|
couponReq.put("contentMatch", 0);
|
|
json.put("couponReq", couponReq);
|
String result = baseRequest2("jd.union.open.coupon.gift.get", null, json);
|
System.out.println(result);
|
JSONObject root = JSONObject.fromObject(result).optJSONObject("jd_union_open_coupon_gift_get_response");
|
if (root.optInt("code") == 0) {
|
boolean hasMore = root.optBoolean("hasMore");
|
root = JSONObject.fromObject(root.optString("result"));
|
if (root.optInt("code") == 200 && root.optJSONObject("data") != null) {
|
JSONObject data = root.optJSONObject("data");
|
String giftCouponKey = data.optString("giftCouponKey");
|
return giftCouponKey;
|
}
|
}
|
return null;
|
}
|
|
|
public static void toolConvert() {
|
JSONObject json = new JSONObject();
|
JSONObject couponReq = new JSONObject();
|
couponReq.put("materialId", "https://item.jd.com/71751967284.html");
|
couponReq.put("unionId", "2011217145");
|
// couponReq.put("pid", "2011217145_4100059717_3003005722");
|
couponReq.put("subUnionId", "123_437032");
|
couponReq.put("giftCouponKey", "123123123123");
|
json.put("promotionCodeReq", couponReq);
|
String result = baseRequest2("jd.union.open.promotion.byunionid.get", null, json);
|
System.out.println(result);
|
}
|
|
public static void toolOrder() {
|
JSONObject json = new JSONObject();
|
JSONObject couponReq = new JSONObject();
|
couponReq.put("pageIndex", 1);
|
couponReq.put("pageSize", 20);
|
couponReq.put("type", 3);
|
couponReq.put("startTime", "2020-10-31 16:00:00");
|
couponReq.put("endTime", "2020-10-31 16:55:00");
|
// couponReq.put("key", "026eea846250e0dcbcacd750faf07de0");
|
|
|
// couponReq.put("pid", "2011217145_4100059717_3003005722");
|
couponReq.put("childUnionId", "2011217145");
|
json.put("orderReq", couponReq);
|
String result = baseRequest2("jd.union.open.order.row.query", null, json);
|
System.out.println(result);
|
}
|
|
|
public static void test() {
|
JSONObject json = new JSONObject();
|
json.put("materialId", "https://item.jd.com/32376790478.html");
|
json.put("ext1", "437032");
|
JSONObject root = new JSONObject();
|
root.put("promotionCodeReq", json);
|
String result = baseRequest2("jd.union.open.promotion.bysubunionid.get", null, root);
|
System.out.println(result);
|
}
|
|
public static void main(String[] args) {
|
Date startTime = new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L);
|
// 一个小时为一个步长
|
List<JDOrder> tempOrderList = new ArrayList<>();
|
for (int i = 0; i < 24; i++) {
|
Date da = new Date(startTime.getTime() + 1000 * 60 * 60L * i);
|
if (da.getTime() >System.currentTimeMillis())
|
break;
|
|
|
int pageSize = 200;
|
int page = 1;
|
JDOrderResult result = JDApiUtil.getOrderList(page++, pageSize, da, JDApiUtil.ORDER_TYPE_UPDATETIME);
|
if (result != null) {
|
tempOrderList.addAll(result.getOrderList());
|
while (result != null && result.isHasMore()) {
|
result = JDApiUtil.getOrderList(page++, pageSize, da, JDApiUtil.ORDER_TYPE_UPDATETIME);
|
if (result != null)
|
tempOrderList.addAll(result.getOrderList());
|
}
|
}
|
}
|
System.out.println(tempOrderList.size());
|
}
|
|
}
|
