yujian
2020-05-09 7e7db2fa55a9a3af46d4fd8ede0dee147f101d64
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;
@@ -111,35 +111,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);
   }
   /**
@@ -359,6 +330,38 @@
      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, Integer sort) {
@@ -384,13 +387,126 @@
      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 = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-dtk-search-goods", params,
            new HashMap<>());
      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) {
@@ -511,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) {
@@ -575,17 +690,42 @@
      return hotWords;
   }
   class DaTaoKeResult {
      Date updateTime;
      List<DaTaoKeDetail> dataList;
   /**
    * 高效转链
    * @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()));
      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/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);
      public DaTaoKeResult() {
      JSONObject json = JSONObject.fromObject(result);
      if (json != null) {
         json = json.getJSONObject("data");
         if (json != null) {
            return json.optString("couponClickUrl");
         }
      }
      return null;
   }
}