admin
2019-08-27 fe879975a3e8a0a1aa280fb839e02d159bfbcff8
fanli/src/main/java/com/yeshi/fanli/util/dataoke/DaTaoKeApiUtil.java
@@ -1,7 +1,6 @@
package com.yeshi.fanli.util.dataoke;
import java.io.IOException;
import java.lang.reflect.Type;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
@@ -21,8 +20,10 @@
import org.jsoup.select.Elements;
import org.yeshi.utils.HttpUtil;
import com.google.gson.ExclusionStrategy;
import com.google.gson.FieldAttributes;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
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;
@@ -30,9 +31,9 @@
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.log.LogHelper;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
@@ -62,7 +63,20 @@
   final static String[] APP_SECRETS = new String[] { APP_KEY_SECRET, APP_KEY_SECRET_2 };
   static Gson gson = new Gson();
   static Gson gson = null;
   static {
      gson = new GsonBuilder().setExclusionStrategies(new ExclusionStrategy() {
         @Override
         public boolean shouldSkipField(FieldAttributes f) {
            return f.getName().equals("createTime");// 忽略createTime的解析
         }
         @Override
         public boolean shouldSkipClass(Class<?> clazz) {
            return false;
         }
      }).create();
   }
   private static String get(String url) {
      HttpClient client = new HttpClient();
@@ -120,6 +134,14 @@
            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
    * 
@@ -168,10 +190,10 @@
               taoBaoShopDTO.setBrandId(item.optString("brand_id"));
               taoBaoShopDTO.setBrandDes(item.optString("brand_des"));
               taoBaoShopDTO.setUserType(0);
               // 商品信息
               taoBaoShopDTO = getDynamicShopGoods(brandId, taoBaoShopDTO);
               break;
            }
         }
@@ -204,11 +226,7 @@
      if (dataJson != null) {
         JSONArray array = dataJson.optJSONArray("list");
         if (array != null) {
            String data = array.toString();
            Type type = new TypeToken<List<DaTaoKeDetailV2>>() {
            }.getType();
            List<DaTaoKeDetailV2> list = gson.fromJson(data, type);
            List<DaTaoKeDetailV2> list = parseDaTaoKeDetailV2List(array);
            daTaoKeGoodsResult.setGoodsList(list);
         }
         daTaoKeGoodsResult.setPageId(dataJson.optString("pageId"));
@@ -248,11 +266,7 @@
      if (dataJson != null) {
         JSONArray array = dataJson.optJSONArray("list");
         if (array != null) {
            String data = array.toString();
            Type type = new TypeToken<List<DaTaoKeDetailV2>>() {
            }.getType();
            List<DaTaoKeDetailV2> list = gson.fromJson(data, type);
            List<DaTaoKeDetailV2> list = parseDaTaoKeDetailV2List(array);
            daTaoKeGoodsResult.setGoodsList(list);
         }
         daTaoKeGoodsResult.setPageId(dataJson.optString("pageId"));
@@ -285,11 +299,8 @@
      if (dataJson != null) {
         JSONArray array = dataJson.optJSONArray("list");
         if (array != null) {
            String data = array.toString();
            Type type = new TypeToken<List<DaTaoKeDetailV2>>() {
            }.getType();
            List<DaTaoKeDetailV2> list = gson.fromJson(data, type);
            List<DaTaoKeDetailV2> list = parseDaTaoKeDetailV2List(array);
            daTaoKeGoodsResult.setGoodsList(list);
         }
         daTaoKeGoodsResult.setPageId(dataJson.optString("pageId"));
@@ -321,11 +332,7 @@
      if (dataJson != null) {
         JSONArray array = dataJson.optJSONArray("list");
         if (array != null) {
            String data = array.toString();
            Type type = new TypeToken<List<DaTaoKeDetailV2>>() {
            }.getType();
            List<DaTaoKeDetailV2> list = gson.fromJson(data, type);
            List<DaTaoKeDetailV2> list = parseDaTaoKeDetailV2List(array);
            daTaoKeGoodsResult.setGoodsList(list);
         }
         daTaoKeGoodsResult.setPageId(dataJson.optString("pageId"));
@@ -336,7 +343,6 @@
   public static DaTaoKeDetailV2 getGoodsDetail(Long id) {
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("appKey", app.getAppKey());
@@ -347,7 +353,7 @@
      JSONObject json = JSONObject.fromObject(result);
      JSONObject dataJson = json.optJSONObject("data");
      if (dataJson != null) {
         return gson.fromJson(dataJson.toString(), DaTaoKeDetailV2.class);
         return parseDaTaoKeDetailV2(dataJson);
      }
      return null;
   }
@@ -388,11 +394,7 @@
      if (dataJson != null) {
         JSONArray array = dataJson.optJSONArray("list");
         if (array != null) {
            String data = array.toString();
            Type type = new TypeToken<List<DaTaoKeDetailV2>>() {
            }.getType();
            List<DaTaoKeDetailV2> list = gson.fromJson(data, type);
            List<DaTaoKeDetailV2> list = parseDaTaoKeDetailV2List(array);
            daTaoKeGoodsResult.setGoodsList(list);
         }
         daTaoKeGoodsResult.setPageId(dataJson.optString("pageId"));
@@ -418,7 +420,6 @@
      return StringUtil.Md5(signStr).toUpperCase();
   }
   /**
    * 获取店铺下前4个商品、店铺介绍
    * 
@@ -429,20 +430,20 @@
      if (brandId == null) {
         return taoBaoShopDTO;
      }
      int userType = 0;
      List<TaoBaoGoodsBrief> listGoods = new ArrayList<TaoBaoGoodsBrief>();
      String result = HttpUtil.get("http://www.dataoke.com/brandGoods?id=" + brandId +"&page=1");
      String result = HttpUtil.get("http://www.dataoke.com/brandGoods?id=" + brandId + "&page=1");
      JSONObject json = JSONObject.fromObject(result);
      JSONArray arrayGoods = json.optJSONArray("goods");
      for (int i = 0; i < arrayGoods.size(); i++) {
         if (i >= 2) {
            break;
         }
         JSONObject itemGoods = arrayGoods.optJSONObject(i);
         TaoBaoGoodsBrief taoBaoGoods = new TaoBaoGoodsBrief();
         taoBaoGoods.setAuctionId(itemGoods.optLong("goodsid"));
         taoBaoGoods.setBiz30day(itemGoods.optInt("xiaoliang"));
@@ -471,11 +472,11 @@
      taoBaoShopDTO.setListGoods(listGoods);
      return taoBaoShopDTO;
   }
   public static int RANK_TYPE_TIME = 1;// 实时
   public static int RANK_TYPE_DAY = 2;// 全天榜
   public static int RANK_TYPE_HOT = 3;// 热推榜
   public static int RANK_TYPE_REBUY = 4;// 复购榜
   /**
    * 各大榜单
@@ -483,16 +484,23 @@
    * @param type
    * @return
    */
   public static DaTaoKeGoodsResult getRankingList(int type) {
   public static DaTaoKeGoodsResult getRankingList(int type, Integer cid) {
      TaoKeAppInfo app = getRandomApp();
      DaTaoKeGoodsResult daTaoKeGoodsResult = new DaTaoKeGoodsResult();
      Map<String, String> params = new TreeMap<>();
      params.put("version", "v1.0.0");
      params.put("appKey", app.getAppKey());
      params.put("rankType", type + "");
      if (cid != null)
         params.put("cid", cid + "");
      params.put("sign", getSign(params, app.getAppSecret()));
      String result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-ranking-list", params, new HashMap<>());
      LogHelper.test("getRankingList:" + result);
      // 做2次请求
      String result = null;
      try {
         result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-ranking-list", params, new HashMap<>());
      } catch (Exception e) {
         result = HttpUtil.get("https://openapi.dataoke.com/api/goods/get-ranking-list", params, new HashMap<>());
      }
      JSONObject json = JSONObject.fromObject(result);
      if (json != null) {
         JSONArray array = json.optJSONArray("data");
@@ -500,7 +508,7 @@
         List<DaTaoKeDetailV2> list = new ArrayList<>();
         for (int i = 0; i < array.size(); i++) {
            JSONObject itemData = array.optJSONObject(i);
            DaTaoKeDetailV2 item = gson.fromJson(itemData.toString(), DaTaoKeDetailV2.class);
            DaTaoKeDetailV2 item = parseDaTaoKeDetailV2(itemData);
            item.setCouponConditions(itemData.optString("quanUsageCondition"));
            item.setShopType(itemData.optInt("istmall"));
            item.setOriginalPrice(new BigDecimal(itemData.optString("originPrice")));
@@ -513,6 +521,27 @@
   }
   private static List<DaTaoKeDetailV2> parseDaTaoKeDetailV2List(JSONArray array) {
      List<DaTaoKeDetailV2> detailList = new ArrayList<>();
      for (int i = 0; i < array.size(); i++) {
         DaTaoKeDetailV2 detail = parseDaTaoKeDetailV2(array.optJSONObject(i));
         detailList.add(detail);
      }
      return detailList;
   }
   private static DaTaoKeDetailV2 parseDaTaoKeDetailV2(JSONObject json) {
      DaTaoKeDetailV2 detail = gson.fromJson(json.toString(), DaTaoKeDetailV2.class);
      if (StringUtil.isNullOrEmpty(json.optString("createTime"))) {
         detail.setCreateTime(
               new Date(TimeUtil.convertToTimeTemp(json.optString("onSaleTime"), "yyyy-MM-dd HH:mm:ss")));
      } else {
         detail.setCreateTime(
               new Date(TimeUtil.convertToTimeTemp(json.optString("createTime"), "yyyy-MM-dd HH:mm:ss")));
      }
      return detail;
   }
   class DaTaoKeResult {
      Date updateTime;
      List<DaTaoKeDetail> dataList;