admin
2020-05-20 98b1a0affd69bbe63223c21fdd2c404e8bedfccb
fanli/src/main/java/com/yeshi/fanli/util/dataoke/DaTaoKeApiUtil.java
@@ -1,7 +1,9 @@
package com.yeshi.fanli.util.dataoke;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
@@ -24,12 +26,10 @@
import com.google.gson.FieldAttributes;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.dto.dataoke.DaTaoKeApiResult;
import com.yeshi.fanli.dto.dataoke.DaTaoKeGoodsResult;
import com.yeshi.fanli.dto.taobao.TaoBaoShopDTO;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoKeAppInfo;
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetail;
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.StringUtil;
@@ -113,35 +113,6 @@
      return result;
   }
   public static DaTaoKeApiResult goodsList(int page) {
      List<DaTaoKeDetail> list = new ArrayList<>();
      String url = String.format("http://api.dataoke.com/index.php?r=Port/index&type=total&appkey=%s&v=2&page=%s",
            Math.random() > 0.5 ? API_KEY : API_KEY_2, page + "");
      String result = request(url);
      JSONObject resultJson = JSONObject.fromObject(result);
      System.out.println(resultJson);
      JSONArray array = resultJson.optJSONArray("result");
      for (int i = 0; i < array.size(); i++) {
         list.add(gson.fromJson(array.optJSONObject(i).toString(), DaTaoKeDetail.class));
      }
      for (DaTaoKeDetail dt : list)
         if (!dt.getPic().startsWith("http"))
            dt.setPic("https:" + dt.getPic());
      return new DaTaoKeApiResult(resultJson.optJSONObject("data").optInt("total_num"),
            resultJson.optJSONObject("data").optString("update_time"), list);
   }
   public static DaTaoKeDetail getGoodsDetailV1(Long id) {
      String url = String.format("http://api.dataoke.com/index.php?r=Port/index&type=total&appkey=%s&v=2&id=%s",
            Math.random() > 0.5 ? API_KEY : API_KEY_2, id + "");
      String result = request(url);
      JSONObject resultJson = JSONObject.fromObject(result);
      return gson.fromJson(resultJson.optJSONArray("result").optJSONObject(0).toString(), DaTaoKeDetail.class);
   }
   /**
    * 获取大淘客品牌优选 品牌id
    * 
@@ -189,6 +160,7 @@
               taoBaoShopDTO.setSellerId(item.optLong("seller_id"));
               taoBaoShopDTO.setBrandId(item.optString("brand_id"));
               taoBaoShopDTO.setBrandDes(item.optString("brand_des"));
               taoBaoShopDTO.setShopIcon(item.optString("brand_logo"));
               taoBaoShopDTO.setUserType(0);
               // 商品信息
@@ -212,7 +184,7 @@
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("version", "v1.1.0");
      params.put("appKey", app.getAppKey());
      params.put("pageSize", 200 + "");
      // params.put("sort", "1");
@@ -245,7 +217,7 @@
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("version", "v1.0.1");
      params.put("appKey", app.getAppKey());
      params.put("pageSize", 200 + "");
      if (!StringUtil.isNullOrEmpty(startTime))
@@ -279,7 +251,7 @@
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("version", "v1.1.0");
      params.put("appKey", app.getAppKey());
      params.put("pageSize", 200 + "");
      if (!StringUtil.isNullOrEmpty(startTime))
@@ -313,7 +285,7 @@
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("version", "v1.1.0");
      params.put("appKey", app.getAppKey());
      params.put("pageSize", 200 + "");
      if (!StringUtil.isNullOrEmpty(startTime))
@@ -344,7 +316,7 @@
   public static DaTaoKeDetailV2 getGoodsDetail(Long id) {
      TaoKeAppInfo app = getRandomApp();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("version", "v1.1.0");
      params.put("appKey", app.getAppKey());
      params.put("id", id + "");
      params.put("sign", getSign(params, app.getAppSecret()));
@@ -358,13 +330,45 @@
      return null;
   }
   public static DaTaoKeDetailV2 getGoodsDetailByGoodsId(Long goodsId) {
      TaoKeAppInfo app = getRandomApp();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.1.1");
      params.put("appKey", app.getAppKey());
      params.put("goodsId", goodsId + "");
      params.put("sign", getSign(params, app.getAppSecret()));
      String result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-goods-details", params,
            new HashMap<>());
      System.out.println(result);
      JSONObject json = JSONObject.fromObject(result);
      JSONObject dataJson = json.optJSONObject("data");
      if (dataJson != null) {
         return parseDaTaoKeDetailV2(dataJson);
      }
      return null;
   }
   private static String requestGet(String url, Map<String, String> params) {
      Iterator<String> keys = params.keySet().iterator();
      url += "?";
      while (keys.hasNext()) {
         String key = keys.next();
         try {
            url += String.format("%s=%s&", key, URLEncoder.encode(params.get(key), "UTF-8"));
         } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
         }
      }
      return HttpUtil.get(url, 10000);
   }
   public static DaTaoKeGoodsResult search(String key, List<Integer> cidList, BigDecimal priceLowerLimit,
         BigDecimal priceUpperLimit, int page, int pageSize, int sort) {
         BigDecimal priceUpperLimit, int page, int pageSize, Integer sort) {
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("version", "v2.1.0");
      params.put("appKey", app.getAppKey());
      params.put("pageSize", pageSize + "");
      params.put("pageId", page + "");
@@ -383,12 +387,126 @@
      if (!StringUtil.isNullOrEmpty(cids))
         params.put("cids", cids);
      if (StringUtil.isNullOrEmpty(key))
         key = "";
      params.put("keyWords", key);
      params.put("sort", sort + "");
      params.put("sign", getSign(params, app.getAppSecret()));
      String result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-dtk-search-goods", params,
            new HashMap<>());
      if (sort != null)
         params.put("sort", sort + "");
      params.put("sign", getSign(params, app.getAppSecret()));
      String result = requestGet("https://openapi.dataoke.com/api/goods/get-dtk-search-goods", params);
      JSONObject json = JSONObject.fromObject(result);
      JSONObject dataJson = json.optJSONObject("data");
      if (dataJson != null) {
         JSONArray array = dataJson.optJSONArray("list");
         if (array != null) {
            List<DaTaoKeDetailV2> list = parseDaTaoKeDetailV2List(array);
            daTaoKeGoodsResult.setGoodsList(list);
         }
         daTaoKeGoodsResult.setPageId(dataJson.optString("pageId"));
         daTaoKeGoodsResult.setTotalCount(dataJson.optLong("totalNum"));
      }
      return daTaoKeGoodsResult;
   }
   public static DaTaoKeGoodsResult search(String key, List<Integer> cidList, BigDecimal priceLowerLimit,
         BigDecimal priceUpperLimit, Integer couponPriceLowerLimit, int page, int pageSize, Integer sort) {
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v2.1.0");
      params.put("appKey", app.getAppKey());
      params.put("pageSize", pageSize + "");
      params.put("pageId", page + "");
      if (priceLowerLimit != null)
         params.put("priceLowerLimit", priceLowerLimit + "");
      if (priceUpperLimit != null)
         params.put("priceUpperLimit", priceUpperLimit + "");
      if (couponPriceLowerLimit != null)
         params.put("couponPriceLowerLimit", couponPriceLowerLimit + "");
      String cids = "";
      if (cidList != null && cidList.size() > 0)
         for (Integer cid : cidList) {
            cids += cid + ",";
         }
      if (cids.endsWith(","))
         cids = cids.substring(0, cids.length() - 1);
      if (!StringUtil.isNullOrEmpty(cids))
         params.put("cids", cids);
      if (StringUtil.isNullOrEmpty(key))
         key = "%";
      params.put("keyWords", key);
      if (sort != null)
         params.put("sort", sort + "");
      params.put("sign", getSign(params, app.getAppSecret()));
      String result = requestGet("https://openapi.dataoke.com/api/goods/get-dtk-search-goods", params);
      JSONObject json = JSONObject.fromObject(result);
      JSONObject dataJson = json.optJSONObject("data");
      if (dataJson != null) {
         JSONArray array = dataJson.optJSONArray("list");
         if (array != null) {
            List<DaTaoKeDetailV2> list = parseDaTaoKeDetailV2List(array);
            daTaoKeGoodsResult.setGoodsList(list);
         }
         daTaoKeGoodsResult.setPageId(dataJson.optString("pageId"));
         daTaoKeGoodsResult.setTotalCount(dataJson.optLong("totalNum"));
      }
      return daTaoKeGoodsResult;
   }
   /**
    * 商品列表
    *
    * @param key
    * @param cidList
    * @param priceLowerLimit
    * @param priceUpperLimit
    * @param couponPriceLowerLimit
    * @param pageId
    * @param pageSize
    * @param sort
    * @return
    */
   public static DaTaoKeGoodsResult getGoodsList(String key, List<Integer> cidList, BigDecimal priceLowerLimit,
         BigDecimal priceUpperLimit, Integer couponPriceLowerLimit, int pageId, int pageSize, Integer sort) {
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.1.0");
      params.put("appKey", app.getAppKey());
      params.put("pageSize", pageSize + "");
      params.put("pageId", pageId + "");
      if (priceLowerLimit != null)
         params.put("priceLowerLimit", priceLowerLimit + "");
      if (priceUpperLimit != null)
         params.put("priceUpperLimit", priceUpperLimit + "");
      if (couponPriceLowerLimit != null)
         params.put("couponPriceLowerLimit", couponPriceLowerLimit + "");
      if (sort != null)
         params.put("sort", sort + "");
      if (cidList != null && cidList.size() > 0) {
         String cids = "";
         for (int cid : cidList)
            cids += cid + ",";
         cids = cids.endsWith(",") ? cids.substring(0, cids.length() - 1) : cids;
         params.put("cids", cids + "");
      }
      params.put("sign", getSign(params, app.getAppSecret()));
      String result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-goods-list", params, new HashMap<>());
      JSONObject json = JSONObject.fromObject(result);
      JSONObject dataJson = json.optJSONObject("data");
      if (dataJson != null) {
@@ -488,7 +606,7 @@
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("version", "v1.1.0");
      params.put("appKey", app.getAppKey());
      params.put("rankType", type + "");
      if (cid != null)
@@ -509,16 +627,15 @@
         for (int i = 0; i < array.size(); i++) {
            JSONObject itemData = array.optJSONObject(i);
            DaTaoKeDetailV2 item = parseDaTaoKeDetailV2(itemData);
            item.setCouponConditions(itemData.optString("quanUsageCondition"));
            item.setShopType(itemData.optInt("istmall"));
            item.setOriginalPrice(new BigDecimal(itemData.optString("originPrice")));
            item.setMainPic(itemData.optString("pic"));
            item.setCouponConditions(itemData.optString("couponConditions"));
            item.setShopType(itemData.optInt("shopType"));
            item.setOriginalPrice(new BigDecimal(itemData.optString("originalPrice")));
            item.setMainPic(itemData.optString("mainPic"));
            list.add(item);
         }
         daTaoKeGoodsResult.setGoodsList(list);
      }
      return daTaoKeGoodsResult;
   }
   private static List<DaTaoKeDetailV2> parseDaTaoKeDetailV2List(JSONArray array) {
@@ -542,18 +659,73 @@
      return detail;
   }
   class DaTaoKeResult {
      Date updateTime;
      List<DaTaoKeDetail> dataList;
   /**
    * 各大榜单
    *
    * @param type
    * @return
    */
   public static String getHotWords() {
      TaoKeAppInfo app = getRandomApp();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.1");
      params.put("appKey", app.getAppKey());
      params.put("sign", getSign(params, app.getAppSecret()));
      public DaTaoKeResult(Date updateTime, List<DaTaoKeDetail> dataList) {
         this.updateTime = updateTime;
         this.dataList = dataList;
      String result = null;
      try {
         result = HttpUtil.get("https://openapi.dataoke.com/api/category/get-top100", params, new HashMap<>());
      } catch (Exception e) {
         result = HttpUtil.get("https://openapi.dataoke.com/api/category/get-top100", params, new HashMap<>());
      }
      public DaTaoKeResult() {
      String hotWords = null;
      JSONObject json = JSONObject.fromObject(result);
      if (json != null) {
         json = json.getJSONObject("data");
         if (json != null) {
            hotWords = json.optString("hotWords");
         }
      }
      return hotWords;
   }
   /**
    * 高效转链
    * @Title: convertLink
    * @Description:
    * @param auctionId
    * @param pid
    * void 返回类型
    * @throws
    */
   public static String convertLink(Long auctionId, String pid) {
      TaoKeAppInfo app = APP_KEYS[1];
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.1.1");
      params.put("goodsId", auctionId + "");
      params.put("pid", pid);
      params.put("appKey", app.getAppKey());
      params.put("sign", getSign(params, app.getAppSecret()));
      String result = null;
      try {
         result = HttpUtil.get("https://openapi.dataoke.com/api/tb-service/get-privilege-link", params,
               new HashMap<>());
      } catch (Exception e) {
         result = HttpUtil.get("https://openapi.dataoke.com/api/tb-service/get-privilege-link", params,
               new HashMap<>());
      }
      System.out.println(result);
      JSONObject json = JSONObject.fromObject(result);
      if (json != null) {
         json = json.getJSONObject("data");
         if (json != null) {
            return json.optString("couponClickUrl");
         }
      }
      return null;
   }
}