From ec60e757d358636dcac1589c44a66f3e276fe58c Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期一, 29 六月 2020 14:41:42 +0800 Subject: [PATCH] 拉新 --- fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java | 76 ++++++++++++++++++++++++++++++++++--- 1 files changed, 69 insertions(+), 7 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 22d4cbf..ab4371c 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,10 +7,12 @@ import java.util.List; import java.util.Map; +import org.yeshi.utils.JsonUtil; import org.yeshi.utils.taobao.TbImgUtil; import com.yeshi.fanli.dto.taobao.TaoBaoShopInfoDTO; import com.yeshi.fanli.dto.taobao.TaoLiJinDTO; +import com.yeshi.fanli.dto.taobao.api.TaoKeOfficialActivityConvertResultDTO; import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinReport; import com.yeshi.fanli.entity.taobao.SearchFilter; import com.yeshi.fanli.entity.taobao.SearchShopFilter; @@ -264,10 +266,10 @@ */ public static List<TaoBaoGoodsBrief> getBatchGoodsInfos(String ids) throws TaobaoGoodsDownException { List<TaoBaoGoodsBrief> goodsList = new ArrayList<>(); - Map<String, String> map = new HashMap<>(); map.put("method", "taobao.tbk.item.info.get"); map.put("num_iids", ids + ""); + String resultStr = TaoKeBaseUtil.baseRequestForThreeTimes(map, true); JSONObject data = JSONObject.fromObject(resultStr); // 鍟嗗搧涓嬫灦 @@ -279,6 +281,63 @@ if (data.optJSONObject("tbk_item_info_get_response") == null) return null; + JSONArray array = data.optJSONObject("tbk_item_info_get_response").optJSONObject("results") + .optJSONArray("n_tbk_item"); + if (array != null && array.size() > 0) { + + for (int i = 0; i < array.size(); i++) { + JSONObject item = array.optJSONObject(i); + goodsList.add(parseSimpleGoodsInfo(item)); + } + } + return goodsList; + } + + + public static List<TaoBaoGoodsBrief> getBatchGoodsInfo(List<Long> listId, String ip ) + 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), ip); + } + + /** + * 鑾峰彇鍟嗗搧璇︽儏锛岀畝鐗� + * + * @param id + * @return + */ + public static List<TaoBaoGoodsBrief> getBatchGoodsInfos(String ids, String ip) throws TaobaoGoodsDownException { + Map<String, String> map = new HashMap<>(); + map.put("method", "taobao.tbk.item.info.get"); + map.put("num_iids", ids + ""); + if (!StringUtil.isNullOrEmpty(ip)) { + map.put("ip", ip); + } + + String resultStr = TaoKeBaseUtil.baseRequestForThreeTimes(map, true); + JSONObject data = JSONObject.fromObject(resultStr); + // 鍟嗗搧涓嬫灦 + if (data.optJSONObject("error_response") != null && data.optJSONObject("error_response").optInt("code") == 15 + && data.optJSONObject("error_response").optInt("sub_code") == 50001) { + throw new TaobaoGoodsDownException(data.optJSONObject("error_response").optInt("code"), "鍟嗗搧涓嬫灦"); + } + + if (data.optJSONObject("tbk_item_info_get_response") == null) + return null; + List<TaoBaoGoodsBrief> goodsList = new ArrayList<>(); + JSONArray array = data.optJSONObject("tbk_item_info_get_response").optJSONObject("results") .optJSONArray("n_tbk_item"); if (array != null && array.size() > 0) { @@ -2076,11 +2135,12 @@ * -娓犻亾ID * @return */ - public static String officialActivityConvert(String adZoneId, String promotionSceneId, String relationId) { + public static TaoKeOfficialActivityConvertResultDTO officialActivityConvert(String adZoneId, + String promotionSceneId, String relationId) { Map<String, String> map = new HashMap<>(); - map.put("method", "taobao.tbk.activitylink.get"); + map.put("method", "taobao.tbk.activity.info.get"); map.put("adzone_id", adZoneId); - map.put("promotion_scene_id", promotionSceneId); + map.put("activity_material_id", promotionSceneId); if (relationId != null) map.put("relation_id", relationId); TaoKeAppInfo app = new TaoKeAppInfo(); @@ -2088,11 +2148,13 @@ app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET); try { String result = TaoKeBaseUtil.baseRequestForThreeTimes(map, app); + System.out.println(result); JSONObject json = JSONObject.fromObject(result); if (json != null) { - json = json.optJSONObject("tbk_activitylink_get_response"); - if (json.optInt("result_code") == 200) { - return json.optString("data"); + json = json.optJSONObject("tbk_activity_info_get_response"); + if (json.optJSONObject("data") != null) { + return JsonUtil.getSimpleGson().fromJson(json.optJSONObject("data").toString(), + TaoKeOfficialActivityConvertResultDTO.class); } } } catch (Exception e) { -- Gitblit v1.8.0