admin
2019-02-15 c12b6ec43f6c79426d6f2337f903d3c0a225e9a5
fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java
@@ -7,11 +7,14 @@
import java.util.List;
import java.util.Map;
import org.yeshi.utils.taobao.TbImgUtil;
import com.taobao.api.ApiException;
import com.yeshi.fanli.entity.taobao.RelateGoods;
import com.yeshi.fanli.entity.taobao.SearchFilter;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoHead;
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoProvince;
import com.yeshi.fanli.entity.taobao.TaoBaoSearchNav;
import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult;
@@ -24,7 +27,6 @@
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
import org.yeshi.utils.taobao.TbImgUtil;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
@@ -157,6 +159,7 @@
      map.put("method", "taobao.tbk.item.info.get");
      map.put("num_iids", id + "");
      String resultStr = TaoKeBaseUtil.baseRequestForThreeTimes(map, true);
      // System.out.println(resultStr);
      JSONObject data = JSONObject.fromObject(resultStr);
      // 商品下架
      if (data.optJSONObject("error_response") != null && data.optJSONObject("error_response").optInt("code") == 15
@@ -192,6 +195,7 @@
         goods.setProvcity(item.optString("provcity"));
         goods.setPictUrl(item.optString("pict_url"));
         goods.setShopTitle(item.optString("nick"));
         goods.setSellerId(item.optLong("seller_id"));
         String optString = item.optString("shop_dsr");
         if (!StringUtil.isNullOrEmpty(optString)) {
@@ -218,9 +222,38 @@
         if (item.optBoolean("free_shipment"))
            goods.setFreeShipment(1);
         if (!StringUtil.isNullOrEmpty(item.optString("material_lib_type")))
            goods.setMaterialLibType(item.optInt("material_lib_type"));
         return goods;
      }
      return null;
   }
   public String convertSpecialGoodsLink(Long auctionId, TaoKeAppInfo app) {
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.coupon.convert");
      map.put("item_id", auctionId + "");
      String resultStr = TaoKeBaseUtil.baseRequestForThreeTimes(map, app);
      return resultStr;
   }
   public static List<TaoBaoGoodsBrief> getBatchGoodsInfo(List<Long> listId)
         throws TaoKeApiException, TaobaoGoodsDownException {
      if (listId == null || listId.size() == 0) {
         throw new TaobaoGoodsDownException(1, "淘宝商品ID不能为空");
      }
      if (listId.size() > 40) {
         throw new TaobaoGoodsDownException(1, "淘宝商品ID不能超过40个");
      }
      StringBuffer ids = new StringBuffer();
      for (Long id : listId) {
         ids.append(id + ",");
      }
      return getBatchGoodsInfos(ids.substring(0, ids.length() - 1));
   }
   /**
@@ -302,6 +335,9 @@
            if (item.optBoolean("free_shipment"))
               goods.setFreeShipment(1);
            if ("1".equalsIgnoreCase(item.optString("material_lib_type")))
               ;
            goodsList.add(goods);
         }
@@ -866,10 +902,16 @@
   private static TaoBaoGoodsBrief parseWuLiaoItem(JSONObject item) {
      TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
      goods.setPictUrl(item.optString("pict_url"));
      if (!StringUtil.isNullOrEmpty(item.optString("white_image"))) {
         goods.setPictUrlWhite(item.optString("white_image"));
      }
      goods.setAuctionId(item.optLong("num_iid"));
      goods.setAuctionUrl("https:" + item.optString("url"));
      goods.setBiz30day(item.optInt("volume"));
      goods.setCouponInfo(item.optString("coupon_info"));
      if (goods.getCouponInfo() != null)
         goods.setCouponInfo(goods.getCouponInfo().replace(".00", ""));
@@ -1415,6 +1457,473 @@
      return result;
   }
   /**
    * 从淘宝链接中解析商品ID(高级接口)
    *
    * @param link
    * @return
    */
   public static String parseAuctionIdFromLink(String link) {
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.item.click.extract");
      map.put("click_url", link + "");
      JSONObject resultJSON = null;
      try {
         resultJSON = TaoKeBaseUtil.baseRequest(map, true);
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      if (resultJSON == null)
         return null;
      return null;
   }
   public static String getAccessToken(String code, String appKey, String appSecret) {
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.top.auth.token.create");
      map.put("code", code);
      TaoKeAppInfo app = new TaoKeAppInfo();
      app.setAppKey(appKey);
      app.setAppSecret(appSecret);
      try {
         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
         if (json != null)
            return json.toString();
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      return null;
   }
   /**
    * 渠道邀请码
    *
    * @param relationId
    * @return
    */
   public static String getInviteCode(Long relationId, String accessToken, String appKey, String appSecret) {
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.sc.invitecode.get");
      map.put("session", accessToken);
      map.put("code_type", "1");
      map.put("relation_app", "common");
      JSONObject resultJSON = null;
      try {
         TaoKeAppInfo app = new TaoKeAppInfo();
         app.setAppKey(appKey);
         app.setAppSecret(appSecret);
         resultJSON = TaoKeBaseUtil.baseRequest(map, app);
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      if (resultJSON == null)
         return null;
      return null;
   }
   /**
    * 获取渠道邀请码
    *
    * @param accessToken
    * @param appKey
    * @param appSecret
    * @return
    */
   public static String getRootRelationInviteCode(String accessToken, String appKey, String appSecret) {
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.sc.invitecode.get");
      map.put("session", accessToken);
      map.put("code_type", "1");
      map.put("relation_app", "common");
      JSONObject resultJSON = null;
      try {
         TaoKeAppInfo app = new TaoKeAppInfo();
         app.setAppKey(appKey);
         app.setAppSecret(appSecret);
         resultJSON = TaoKeBaseUtil.baseRequest(map, app);
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      if (resultJSON == null)
         return null;
      return null;
   }
   public static String getRootSpecialInviteCode(String accessToken, String appKey, String appSecret) {
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.sc.invitecode.get");
      map.put("session", accessToken);
      map.put("code_type", "3");
      map.put("relation_app", "common");
      JSONObject resultJSON = null;
      try {
         TaoKeAppInfo app = new TaoKeAppInfo();
         app.setAppKey(appKey);
         app.setAppSecret(appSecret);
         resultJSON = TaoKeBaseUtil.baseRequest(map, app);
         return resultJSON.optJSONObject("tbk_sc_invitecode_get_response").optJSONObject("data")
               .optString("inviter_code");
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      if (resultJSON == null)
         return null;
      return null;
   }
   public static String getRelationId(String accessToken, String appKey, String appSecret) {
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.sc.publisher.info.save");
      map.put("session", accessToken);
      map.put("inviter_code", "A2QnGL");
      map.put("info_type", "1");
      map.put("online_scene", "1");
      JSONObject resultJSON = null;
      try {
         TaoKeAppInfo app = new TaoKeAppInfo();
         app.setAppKey(appKey);
         app.setAppSecret(appSecret);
         resultJSON = TaoKeBaseUtil.baseRequest(map, app);
         return resultJSON.optJSONObject("tbk_sc_publisher_info_save_response").optJSONObject("data")
               .optString("relation_id");
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      return null;
   }
   public static String getSpecialId(String accessToken, String appKey, String appSecret) {
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.sc.publisher.info.save");
      map.put("session", accessToken);
      map.put("inviter_code", "AA5ISJ");
      map.put("info_type", "1");
      map.put("online_scene", "1");
      JSONObject resultJSON = null;
      try {
         TaoKeAppInfo app = new TaoKeAppInfo();
         app.setAppKey(appKey);
         app.setAppSecret(appSecret);
         resultJSON = TaoKeBaseUtil.baseRequest(map, app);
         return resultJSON.optJSONObject("tbk_sc_publisher_info_save_response").optJSONObject("data")
               .optString("special_id");
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      return null;
   }
   /**
    * 获取会员订单
    *
    * @param startTime-开始时间
    * @param page-页码
    * @param appKey
    * @param appSecret
    * @return
    */
   public static List<TaoBaoOrder> getTaoBaoSpecialOrder(String startTime, int page, 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");
      map.put("start_time", startTime);
      map.put("tk_status", "1");
      map.put("order_query_type", "create_time");
      map.put("order_scene", "3");
      map.put("page_no", page + "");
      map.put("page_size", 100 + "");
      TaoKeAppInfo app = new TaoKeAppInfo();
      app.setAppKey(appKey);
      app.setAppSecret(appSecret);
      try {
         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
         System.out.println(json.toString());
         return parseTaoBaoOrder(json.toString());
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      return null;
   }
   /**
    * 获取第三方会员订单
    *
    * @param startTime
    * @param page
    * @param appKey
    * @param appSecret
    * @return
    */
   public static List<TaoBaoOrder> getTaoBaoSpecialThirdOrder(String startTime, int page, 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");
      map.put("start_time", startTime);
      map.put("tk_status", "1");
      map.put("order_query_type", "create_time");
      map.put("order_scene", "3");
      map.put("page_no", page + "");
      map.put("page_size", 100 + "");
      map.put("order_count_type", "2");
      TaoKeAppInfo app = new TaoKeAppInfo();
      app.setAppKey(appKey);
      app.setAppSecret(appSecret);
      try {
         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
         System.out.println(json.toString());
         return parseTaoBaoOrder(json.toString());
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      return null;
   }
   /**
    * 获取渠道订单
    *
    * @param startTime
    * @param appKey
    * @param appSecret
    * @return
    */
   public static List<TaoBaoOrder> getTaoBaoRelationOrder(String startTime, int page, 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");
      map.put("start_time", startTime);
      map.put("span", "1200");
      map.put("tk_status", "1");
      map.put("order_query_type", "create_time");
      map.put("order_scene", "2");
      map.put("page_no", page + "");
      map.put("page_size", 100 + "");
      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;
   }
   /**
    * 第三方渠道订单
    *
    * @param startTime
    * @param page
    * @param appKey
    * @param appSecret
    * @return
    */
   public static List<TaoBaoOrder> getTaoBaoRelationThirdOrder(String startTime, int page, 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");
      map.put("start_time", startTime);
      map.put("span", "1200");
      map.put("tk_status", "1");
      map.put("order_query_type", "create_time");
      map.put("order_scene", "2");
      map.put("page_no", page + "");
      map.put("page_size", 100 + "");
      map.put("order_count_type", "2");
      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;
   }
   /**
    * 获取所有的订单(不带渠道信息与会员信息)
    *
    * @param startTime
    * @param appKey
    * @param appSecret
    * @return
    */
   public static List<TaoBaoOrder> getTaoBaoAllOrder(String startTime, 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");
      map.put("start_time", startTime);
      map.put("span", "1200");
      map.put("tk_status", "1");
      map.put("order_query_type", "create_time");
      map.put("order_scene", "1");// 所有订单
      map.put("page_no", 1 + "");
      map.put("page_size", 100 + "");
      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);
         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("alipay_total_price")))
            taoBaoOrder.setSettlement(new BigDecimal(item.optString("alipay_total_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));
         taoBaoOrder.setTkRate(new BigDecimal(item.optString("commission_rate")));
         taoBaoOrder.setTransactionPlatform(item.optString("terminal_type"));
         taoBaoOrder.setRelationId(item.optString("relation_id"));
         taoBaoOrder.setSpecialId(item.optString("special_id"));
         orderList.add(taoBaoOrder);
      }
      return orderList;
   }
   public static void specialConvertItem(Long auctionId, TaoKeAppInfo app) {
      String pid = app.getPid();
      String[] sts = pid.split("_");
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.item.convert");
      map.put("num_iids", auctionId + "");
      map.put("fields", "num_iid,click_url");
      map.put("adzone_id", sts[3]);
      map.put("platform", "2");
      try {
         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
         System.out.println(json.toString());
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
   }
   public static TaoBaoGoodsBrief specialConvertCoupon(Long auctionId, TaoKeAppInfo app) {
      String pid = app.getPid();
      String[] sts = pid.split("_");
      Map<String, String> map = new HashMap<>();
      map.put("method", "taobao.tbk.coupon.convert");
      map.put("item_id", auctionId + "");
      map.put("adzone_id", sts[3]);
      try {
         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);
         JSONObject resultJSON = json.optJSONObject("tbk_coupon_convert_response").optJSONObject("result")
               .optJSONObject("results");
         String couponLink = resultJSON.optString("coupon_click_url");
         String itemLink = resultJSON.optString("item_url");
         TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
         goods.setAuctionUrl(itemLink);
         goods.setCouponLink(couponLink);
         return goods;
      } catch (TaoKeApiException e) {
         e.printStackTrace();
      }
      return null;
   }
   // AA5ISJ
   private static TaoBaoGoodsBrief parseWuLiaoItemFromMaterialId(JSONObject item) {
      TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
      // 设置成320*320的图片尺寸