From 69bee82b81626b82b7f39f0e459e4f56b1699b51 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 13 三月 2019 12:02:16 +0800 Subject: [PATCH] 正式数据库修改 --- fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java | 308 +++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 296 insertions(+), 12 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java b/fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java index 7faf1ba..7833b6a 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java @@ -7,6 +7,8 @@ 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; @@ -19,12 +21,12 @@ import com.yeshi.fanli.entity.taobao.TaoKeAppInfo; import com.yeshi.fanli.exception.taobao.TaoKeApiException; import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; +import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.log.TaoKeLogHelper; import com.yeshi.fanli.tag.PageEntity; 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); } @@ -627,6 +663,12 @@ if (filter.getEndTkRate() > 0) map.put("end_tk_rate", filter.getEndTkRate() + ""); + if (filter.getStartKaTkRate() > 0) + map.put("start_ka_tk_rate", filter.getStartKaTkRate() + ""); + + if (filter.getEndKaTkRate() > 0) + map.put("end_ka_tk_rate", filter.getEndKaTkRate() + ""); + if (filter.isTmall()) map.put("is_tmall", filter.isTmall() + ""); @@ -729,7 +771,7 @@ // 璁剧疆鍙戣揣鍦板潃 TaoBaoSearchNav nav = new TaoBaoSearchNav(); - nav.setName("鍙戣揣鍦�"); + nav.setName("鍙戣揣鍦伴�夋嫨"); nav.setFlag("address"); nav.setId(11110); nav.setType("fahuodi"); @@ -860,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", "")); @@ -953,6 +1001,11 @@ * @return */ public static String getTKToken(String logo, String text, String url) { + if (text == null) + return null; + if (text.length() < 5) + text = "濂借揣锛�" + text; + Map<String, String> map = new HashMap<>(); map.put("method", "taobao.tbk.tpwd.create"); map.put("url", url); @@ -1033,16 +1086,17 @@ return list; JSONArray array = data.optJSONObject("tbk_item_recommend_get_response").optJSONObject("results") .optJSONArray("n_tbk_item"); - for (int i = 0; i < array.size(); i++) { - JSONObject item = array.optJSONObject(i); - TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief(); - goods.setAuctionId(item.optLong("num_iid")); - goods.setTitle(item.optString("title")); - goods.setZkPrice(new BigDecimal(item.optString("zk_final_price"))); - goods.setAuctionUrl(item.optString("item_url")); - goods.setPictUrl(item.optString("pict_url")); - list.add(goods); - } + if (array != null) + for (int i = 0; i < array.size(); i++) { + JSONObject item = array.optJSONObject(i); + TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief(); + goods.setAuctionId(item.optLong("num_iid")); + goods.setTitle(item.optString("title")); + goods.setZkPrice(new BigDecimal(item.optString("zk_final_price"))); + goods.setAuctionUrl(item.optString("item_url")); + goods.setPictUrl(item.optString("pict_url")); + list.add(goods); + } } return list; } @@ -1403,6 +1457,236 @@ return result; } + /** + * 浠庢窐瀹濋摼鎺ヤ腑瑙f瀽鍟嗗搧ID锛堥珮绾ф帴鍙o級 + * + * @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(); + LogHelper.error("娓犻亾ID鐢宠鍑洪敊:" + resultJSON); + } + + 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(); + LogHelper.error("浼氬憳杩愯惀ID鐢宠鍑洪敊:" + resultJSON); + } + + return null; + } + + 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); + if (!StringUtil.isNullOrEmpty(resultJSON.optString("coupon_info"))) + goods.setCouponLink(couponLink); + return goods; + } catch (TaoKeApiException e) { + e.printStackTrace(); + } + + return null; + } + + public static void juHuaSuan() { + Map<String, String> map = new HashMap<>(); + map.put("method", "taobao.ju.items.search"); + map.put("current_page", 1 + ""); + map.put("page_size", 100+""); + map.put("pid", "mm_124933865_43788020_381938426"); + + TaoKeAppInfo app = new TaoKeAppInfo(); + app.setAppKey("24838852"); + app.setAppSecret("bc8265e2bf8d8115329d652f9d3d4cd8"); + + try { + JSONObject json = TaoKeBaseUtil.baseRequest(map, app); + System.out.println(json); + } catch (TaoKeApiException e) { + e.printStackTrace(); + } + + } + + // AA5ISJ + private static TaoBaoGoodsBrief parseWuLiaoItemFromMaterialId(JSONObject item) { TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief(); // 璁剧疆鎴�320*320鐨勫浘鐗囧昂瀵� -- Gitblit v1.8.0