package com.yeshi.fanli.util.taobao;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import com.yeshi.fanli.dto.order.OrderQuery;
|
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
|
import com.yeshi.fanli.entity.taobao.TaoKeAppInfo;
|
import com.yeshi.fanli.exception.taobao.TaoKeApiException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.TaoBaoConstant;
|
import com.yeshi.fanli.util.TimeUtil;
|
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
|
//淘宝客API接口
|
public class TaoKeOrderApiUtil {
|
|
public static int TK_STATUS_ALL=1;
|
public static int TK_STATUS_SETTLEMENT=3;
|
public static int TK_STATUS_PAY=12;
|
public static int TK_STATUS_SUCCESS=14;
|
public static int TK_STATUS_INVALID=13;
|
|
/**
|
* 获取会员订单
|
*
|
* @param startTime-开始时间
|
* @param page-页码
|
* @param appKey
|
* @param appSecret
|
* @return
|
*/
|
private static List<TaoBaoOrder> getTaoBaoSpecialOrder(String startTime, int span, int page, String appKey,
|
String appSecret) {
|
OrderQuery orderQuery = new OrderQuery();
|
orderQuery.startTime = startTime;
|
orderQuery.tkStatus = 1;
|
orderQuery.orderScene = 3;
|
orderQuery.pageNo = page;
|
orderQuery.pageSize = 100;
|
orderQuery.span = span;
|
orderQuery.orderQueryType = "create_time";
|
return queryTaoBaoOrder(orderQuery, appKey, appSecret);
|
}
|
|
/**
|
* 获取第三方会员订单
|
*
|
* @param startTime
|
* @param page
|
* @param appKey
|
* @param appSecret
|
* @return
|
*/
|
private static List<TaoBaoOrder> getTaoBaoSpecialThirdOrder(String startTime, int span, int page, String appKey,
|
String appSecret) {
|
OrderQuery orderQuery = new OrderQuery();
|
orderQuery.startTime = startTime;
|
orderQuery.tkStatus = 1;
|
orderQuery.orderQueryType = "create_time";
|
orderQuery.orderScene = 3;
|
orderQuery.pageNo = page;
|
orderQuery.pageSize = 100;
|
orderQuery.span = span;
|
orderQuery.orderCountType = 2;
|
return queryTaoBaoOrder(orderQuery, appKey, appSecret);
|
}
|
|
/**
|
* 获取渠道订单
|
*
|
* @param startTime
|
* @param appKey
|
* @param appSecret
|
* @return
|
*/
|
private static List<TaoBaoOrder> getTaoBaoRelationOrder(String startTime, int span, int page, String appKey,
|
String appSecret) {
|
|
OrderQuery orderQuery = new OrderQuery();
|
orderQuery.startTime = startTime;
|
orderQuery.span = span;
|
orderQuery.tkStatus = 1;
|
orderQuery.orderQueryType = "create_time";
|
orderQuery.orderScene = 2;
|
orderQuery.pageNo = page;
|
orderQuery.pageSize = 100;
|
return queryTaoBaoOrder(orderQuery, appKey, appSecret);
|
}
|
|
/**
|
* 第三方渠道订单
|
*
|
* @param startTime
|
* @param page
|
* @param appKey
|
* @param appSecret
|
* @return
|
*/
|
private static List<TaoBaoOrder> getTaoBaoRelationThirdOrder(String startTime, int span, int page, String appKey,
|
String appSecret) {
|
OrderQuery orderQuery = new OrderQuery();
|
orderQuery.startTime = startTime;
|
orderQuery.span = span;
|
orderQuery.tkStatus = 1;
|
orderQuery.orderQueryType = "create_time";
|
orderQuery.orderScene = 2;
|
orderQuery.pageNo = page;
|
orderQuery.pageSize = 100;
|
orderQuery.orderCountType = 2;
|
return queryTaoBaoOrder(orderQuery, appKey, appSecret);
|
}
|
|
/**
|
* 获取所有的订单（不带渠道信息与会员信息）
|
*
|
* @param startTime
|
* @param appKey
|
* @param appSecret
|
* @return
|
*/
|
public static List<TaoBaoOrder> getTaoBaoAllOrder(String startTime, String appKey, String appSecret) {
|
|
return getTaoBaoAllOrder(startTime, 1200, 1, appKey, appSecret);
|
}
|
|
public static List<TaoBaoOrder> getTaoBaoAllOrder(String startTime, int span, int page, String appKey,
|
String appSecret) {
|
OrderQuery orderQuery = new OrderQuery();
|
orderQuery.startTime = startTime;
|
orderQuery.span = span;
|
orderQuery.tkStatus = 1;
|
orderQuery.orderQueryType = "create_time";
|
orderQuery.orderScene = 1;
|
orderQuery.pageNo = page;
|
orderQuery.pageSize = 100;
|
orderQuery.orderCountType = 1;
|
return queryTaoBaoOrder(orderQuery, appKey, appSecret);
|
}
|
|
/**
|
* 获取第三方订单
|
*
|
* @param startTime
|
* @param span
|
* @param page
|
* @param appKey
|
* @param appSecret
|
* @return
|
*/
|
public static List<TaoBaoOrder> getTaoBaoThirdAllOrder(String startTime, int span, int page, String appKey,
|
String appSecret) {
|
OrderQuery orderQuery = new OrderQuery();
|
orderQuery.startTime = startTime;
|
orderQuery.span = span;
|
orderQuery.tkStatus = 1;
|
orderQuery.orderQueryType = "create_time";
|
orderQuery.orderScene = 1;
|
orderQuery.pageNo = page;
|
orderQuery.pageSize = 100;
|
orderQuery.orderCountType = 2;
|
return queryTaoBaoOrder(orderQuery, appKey, appSecret);
|
}
|
|
public static void punish() {
|
Map<String, String> map = new HashMap<>();
|
map.put("method", "taobao.tbk.dg.punish.order.get");
|
map.put("span", "3600");
|
map.put("page_no", "1");
|
map.put("page_size", "20");
|
map.put("start_time", "2019-01-01 00:00:00");
|
// map.put("start_time", "2019-01-01 00:00:00");
|
TaoKeAppInfo app = new TaoKeAppInfo();
|
app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);
|
app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
try {
|
JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
|
} catch (TaoKeApiException e) {
|
e.printStackTrace();
|
}
|
}
|
|
public static void test(String startTime, String appKey, String appSecret) {
|
OrderQuery orderQuery = new OrderQuery();
|
orderQuery.startTime = startTime;
|
orderQuery.span = 1200;
|
orderQuery.tkStatus = 1;
|
orderQuery.orderQueryType = "create_time";
|
orderQuery.orderScene = 1;
|
orderQuery.pageNo = 1;
|
orderQuery.pageSize = 100;
|
List<TaoBaoOrder> list = queryTaoBaoOrder(orderQuery, appKey, appSecret);
|
for (TaoBaoOrder order : list)
|
System.out.println(order.getCreateTime() + "--" + order.getSettlementTime());
|
}
|
|
private static List<TaoBaoOrder> queryTaoBaoOrder(OrderQuery orderQuery, String appKey, String appSecret) {
|
|
Map<String, String> map = new HashMap<>();
|
map.put("method", "taobao.tbk.order.get");
|
map.put("fields",
|
"tb_trade_parent_id,tb_trade_id,num_iid,item_title,item_num,price,pay_price,seller_nick,seller_shop_title,commission,commission_rate,unid,create_time,earning_time,tk_status,tk3rd_pub_id,tk3rd_site_id,tk3rd_adzone_id,relation_id,tb_trade_parent_id,tb_trade_id,num_iid,item_title,item_num,price,pay_price,seller_nick,seller_shop_title,commission,commission_rate,unid,create_time,earning_time,tk3rd_pub_id,tk3rd_site_id,tk3rd_adzone_id,special_id,click_time,relation_id,special_id");
|
if (orderQuery.startTime != null)
|
map.put("start_time", orderQuery.startTime);
|
if (orderQuery.span != null)
|
map.put("span", orderQuery.span + "");
|
map.put("page_no", orderQuery.pageNo + "");
|
map.put("page_size", orderQuery.pageSize + "");
|
|
if (orderQuery.tkStatus != null)
|
map.put("tk_status", orderQuery.tkStatus + "");
|
if (orderQuery.orderQueryType != null)
|
map.put("order_query_type", orderQuery.orderQueryType);
|
if (orderQuery.orderScene != null)
|
map.put("order_scene", orderQuery.orderScene + "");
|
|
if (orderQuery.orderCountType != null)
|
map.put("order_count_type", orderQuery.orderCountType + "");
|
|
TaoKeAppInfo app = new TaoKeAppInfo();
|
app.setAppKey(appKey);
|
app.setAppSecret(appSecret);
|
try {
|
JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
|
return parseTaoBaoOrder(json.toString());
|
} catch (TaoKeApiException e) {
|
e.printStackTrace();
|
}
|
|
return null;
|
}
|
|
private static List<TaoBaoOrder> parseTaoBaoOrder(String response) {
|
|
List<TaoBaoOrder> orderList = new ArrayList<>();
|
|
JSONObject data = JSONObject.fromObject(response);
|
if (data.optJSONObject("tbk_order_get_response") == null)
|
return orderList;
|
if (data.optJSONObject("tbk_order_get_response").optJSONObject("results") == null)
|
return orderList;
|
if (data.optJSONObject("tbk_order_get_response").optJSONObject("results").optJSONArray("n_tbk_order") == null)
|
return orderList;
|
|
JSONArray array = data.optJSONObject("tbk_order_get_response").optJSONObject("results")
|
.optJSONArray("n_tbk_order");
|
for (int i = 0; i < array.size(); i++) {
|
|
JSONObject item = array.optJSONObject(i);
|
try {
|
TaoBaoOrder taoBaoOrder = new TaoBaoOrder();
|
taoBaoOrder.setAdPositionId(item.optString("adzone_id"));
|
taoBaoOrder.setAdPositionName(item.optString("adzone_name"));
|
taoBaoOrder.setAuctionId(item.optLong("num_iid"));
|
taoBaoOrder.setClassName(item.optString("auction_category"));
|
taoBaoOrder.setClickTime(item.optString("click_time"));
|
taoBaoOrder.setCount(item.optInt("item_num"));
|
taoBaoOrder.setCreateTime(item.optString("create_time"));
|
if (!StringUtil.isNullOrEmpty(item.optString("total_commission_fee")))
|
taoBaoOrder.seteIncome(new BigDecimal(item.optString("total_commission_fee")));
|
else
|
taoBaoOrder.seteIncome(new BigDecimal(0));
|
|
if (!StringUtil.isNullOrEmpty(item.optString("pub_share_pre_fee")))
|
taoBaoOrder.setEstimate(new BigDecimal(item.optString("pub_share_pre_fee")));
|
else
|
taoBaoOrder.setEstimate(new BigDecimal(0));
|
taoBaoOrder.setiRatio(new BigDecimal(item.optString("income_rate")).multiply(new BigDecimal(100)));
|
taoBaoOrder.setLatestUpdateTime(null);
|
taoBaoOrder.setManagerWangWang(null);
|
taoBaoOrder.setOrderBy(null);
|
taoBaoOrder.setOrderId(item.optString("trade_parent_id"));
|
if (item.optInt("tk_status") == 12)
|
taoBaoOrder.setOrderState("订单付款");
|
else if (item.optInt("tk_status") == 3)
|
taoBaoOrder.setOrderState("订单结算");
|
else if (item.optInt("tk_status") == 13)
|
taoBaoOrder.setOrderState("订单失效");
|
else if (item.optInt("tk_status") == 14)
|
taoBaoOrder.setOrderState("订单成功");
|
|
taoBaoOrder.setOrderType(item.optString("order_type"));
|
if (!StringUtil.isNullOrEmpty(item.optString("alipay_total_price")))
|
taoBaoOrder.setPayment(new BigDecimal(item.optString("alipay_total_price")));
|
else
|
taoBaoOrder.setPayment(new BigDecimal(0));
|
taoBaoOrder.setPrice(new BigDecimal(item.optString("price")));
|
if (!StringUtil.isNullOrEmpty(item.optString("pay_price")))
|
taoBaoOrder.setSettlement(new BigDecimal(item.optString("pay_price")));
|
else
|
taoBaoOrder.setSettlement(new BigDecimal(0));
|
taoBaoOrder.setSettlementTime(item.optString("earning_time"));
|
taoBaoOrder.setShop(item.optString("seller_shop_title"));
|
taoBaoOrder.setSourceMediaId(item.optString("site_id"));
|
taoBaoOrder.setSourceMediaName(item.optString("site_name"));
|
taoBaoOrder.setsRatio(null);
|
taoBaoOrder.setSubsidy(null);
|
if (!StringUtil.isNullOrEmpty(item.optString("subsidy_rate")))
|
taoBaoOrder.setSubsidyRatio(
|
new BigDecimal(item.optString("subsidy_rate")).multiply(new BigDecimal(100)));
|
taoBaoOrder.setSubsidyType(item.optString("subsidy_type"));
|
taoBaoOrder.setTechnologySupportPercent(null);
|
taoBaoOrder.setThirdService(null);
|
taoBaoOrder.setTitle(item.optString("item_title"));
|
if (!StringUtil.isNullOrEmpty(item.optString("total_commission_fee")))
|
taoBaoOrder.setTkMoney(new BigDecimal(item.optString("total_commission_fee")));
|
else
|
taoBaoOrder.setTkMoney(new BigDecimal(0));
|
if (!StringUtil.isNullOrEmpty(item.optString("commission_rate")))
|
taoBaoOrder
|
.setTkRate(new BigDecimal(item.optString("commission_rate")).multiply(new BigDecimal(100)));
|
else if (!StringUtil.isNullOrEmpty(item.optString("total_commission_rate")))
|
taoBaoOrder.setTkRate(
|
new BigDecimal(item.optString("total_commission_rate")).multiply(new BigDecimal(100)));
|
taoBaoOrder.setTransactionPlatform(item.optString("terminal_type"));
|
taoBaoOrder.setRelationId(item.optString("relation_id"));
|
taoBaoOrder.setSpecialId(item.optString("special_id"));
|
taoBaoOrder.setTradeId(item.optString("trade_id"));
|
orderList.add(taoBaoOrder);
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e, "订单号信息:" + item.toString(), "订单解析出错");
|
} catch (Exception e1) {
|
}
|
}
|
}
|
|
return orderList;
|
}
|
|
private static List<TaoBaoOrder> getSpecialOrder(long startTime, int span) {
|
int page = 1;
|
String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");
|
List<TaoBaoOrder> orderList = getTaoBaoSpecialOrder(startTimeStr, span, page, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
while (orderList.size() == 100 * page) {
|
page++;
|
List<TaoBaoOrder> tempOrderList = getTaoBaoSpecialOrder(startTimeStr, span, page,
|
TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
if (tempOrderList != null && tempOrderList.size() > 0)
|
orderList.addAll(tempOrderList);
|
}
|
return orderList;
|
}
|
|
/**
|
* 获取第三方普通订单
|
*
|
* @param startTime
|
* @param span
|
* @return
|
*/
|
private static List<TaoBaoOrder> getThirdTSpecialOrder(long startTime, int span) {
|
int page = 1;
|
String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");
|
List<TaoBaoOrder> orderList = getTaoBaoSpecialThirdOrder(startTimeStr, span, page, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
while (orderList.size() == 100 * page) {
|
page++;
|
List<TaoBaoOrder> tempOrderList = getTaoBaoSpecialThirdOrder(startTimeStr, span, page,
|
TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
if (tempOrderList != null && tempOrderList.size() > 0)
|
orderList.addAll(tempOrderList);
|
}
|
return orderList;
|
}
|
|
private static List<TaoBaoOrder> getRelationOrder(long startTime, int span) {
|
int page = 1;
|
String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");
|
List<TaoBaoOrder> orderList = getTaoBaoRelationOrder(startTimeStr, span, page, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
while (orderList.size() == 100 * page) {
|
page++;
|
List<TaoBaoOrder> tempOrderList = getTaoBaoRelationOrder(startTimeStr, span, page,
|
TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
if (tempOrderList != null && tempOrderList.size() > 0)
|
orderList.addAll(tempOrderList);
|
}
|
return orderList;
|
}
|
|
private static List<TaoBaoOrder> getThirdRelationOrder(long startTime, int span) {
|
int page = 1;
|
String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");
|
List<TaoBaoOrder> orderList = getTaoBaoRelationThirdOrder(startTimeStr, span, page, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
while (orderList.size() == 100 * page) {
|
page++;
|
List<TaoBaoOrder> tempOrderList = getTaoBaoRelationThirdOrder(startTimeStr, span, page,
|
TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
if (tempOrderList != null && tempOrderList.size() > 0)
|
orderList.addAll(tempOrderList);
|
}
|
return orderList;
|
}
|
|
/**
|
* 获取某个区间的会员订单
|
*
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public static List<TaoBaoOrder> getSpecialOrder(long startTime, long endTime) {
|
List<TaoBaoOrder> orderList = new ArrayList<>();
|
long span = (endTime - startTime) % 1000 == 0 ? (endTime - startTime) / 1000 : (endTime - startTime) / 1000 + 1;
|
int count = (int) (span / 1200);
|
if (span % 1200 != 0)
|
count++;
|
for (int i = 0; i < count; i++) {
|
long startT = startTime + i * 1200 * 1000L;
|
int s = 1200;
|
if (endTime < startT + 1200 * 1000L) {
|
s = (int) ((endTime - startT) / 1000) + 1;
|
if (s < 60)
|
s = 60;
|
}
|
List<TaoBaoOrder> tempOrderList = getSpecialOrder(startT, s);
|
if (tempOrderList != null && tempOrderList.size() > 0)
|
orderList.addAll(tempOrderList);
|
}
|
return orderList;
|
}
|
|
/**
|
* 获取某个区间的第三方会员订单
|
*
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public static List<TaoBaoOrder> getThirdSpecialOrder(long startTime, long endTime) {
|
List<TaoBaoOrder> orderList = new ArrayList<>();
|
long span = (endTime - startTime) % 1000 == 0 ? (endTime - startTime) / 1000 : (endTime - startTime) / 1000 + 1;
|
int count = (int) (span / 1200);
|
if (span % 1200 != 0)
|
count++;
|
for (int i = 0; i < count; i++) {
|
long startT = startTime + i * 1200 * 1000L;
|
int s = 1200;
|
if (endTime < startT + 1200 * 1000L) {
|
s = (int) ((endTime - startT) / 1000) + 1;
|
if (s < 60)
|
s = 60;
|
}
|
List<TaoBaoOrder> tempOrderList = getThirdTSpecialOrder(startT, s);
|
if (tempOrderList != null && tempOrderList.size() > 0)
|
orderList.addAll(tempOrderList);
|
}
|
return orderList;
|
}
|
|
/**
|
* 获取渠道订单
|
*
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public static List<TaoBaoOrder> getRelationOrder(long startTime, long endTime) {
|
List<TaoBaoOrder> orderList = new ArrayList<>();
|
long span = (endTime - startTime) % 1000 == 0 ? (endTime - startTime) / 1000 : (endTime - startTime) / 1000 + 1;
|
int count = (int) (span / 1200);
|
if (span % 1200 != 0)
|
count++;
|
for (int i = 0; i < count; i++) {
|
long startT = startTime + i * 1200 * 1000L;
|
int s = 1200;
|
if (endTime < startT + 1200 * 1000L) {
|
s = (int) ((endTime - startT) / 1000) + 1;
|
if (s < 60)
|
s = 60;
|
}
|
List<TaoBaoOrder> tempOrderList = getRelationOrder(startT, s);
|
if (tempOrderList != null && tempOrderList.size() > 0)
|
orderList.addAll(tempOrderList);
|
}
|
return orderList;
|
}
|
|
/**
|
* 获取某个区间的第三方渠道订单
|
*
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public static List<TaoBaoOrder> getThirdRelationOrder(long startTime, long endTime) {
|
List<TaoBaoOrder> orderList = new ArrayList<>();
|
long span = (endTime - startTime) % 1000 == 0 ? (endTime - startTime) / 1000 : (endTime - startTime) / 1000 + 1;
|
int count = (int) (span / 1200);
|
if (span % 1200 != 0)
|
count++;
|
for (int i = 0; i < count; i++) {
|
long startT = startTime + i * 1200 * 1000L;
|
int s = 1200;
|
if (endTime < startT + 1200 * 1000L) {
|
s = (int) ((endTime - startT) / 1000) + 1;
|
if (s < 60)
|
s = 60;
|
}
|
List<TaoBaoOrder> tempOrderList = getThirdRelationOrder(startT, s);
|
if (tempOrderList != null && tempOrderList.size() > 0)
|
orderList.addAll(tempOrderList);
|
}
|
return orderList;
|
}
|
}
|
