blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2019-07-11 3824cbcaec6e6c67418d5280a53e9c2fedeef6f9 
 fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java


@@ -10,6 +10,9 @@


import org.yeshi.utils.taobao.TbImgUtil;







import com.taobao.api.ApiException;



import com.yeshi.fanli.dto.taobao.TaoBaoShopInfoDTO;



import com.yeshi.fanli.dto.taobao.TaoLiJinDTO;



import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinReport;



import com.yeshi.fanli.entity.taobao.RelateGoods;



import com.yeshi.fanli.entity.taobao.SearchFilter;



import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;



@@ -21,10 +24,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.TaoBaoConstant;



import com.yeshi.fanli.util.TimeUtil;







import net.sf.json.JSONArray;



@@ -223,6 +228,8 @@






         if (!StringUtil.isNullOrEmpty(item.optString("material_lib_type")))



            goods.setMaterialLibType(item.optInt("material_lib_type"));



         else



            goods.setMaterialLibType(0);







         return goods;



      }



@@ -336,7 +343,9 @@


               goods.setFreeShipment(1);







            if ("1".equalsIgnoreCase(item.optString("material_lib_type")))



               ;



               goods.setMaterialLibType(1);



            else



               goods.setMaterialLibType(0);







            goodsList.add(goods);



         }



@@ -364,6 +373,7 @@


            goods.getUserType());



      if (result != null && result.getTaoBaoGoodsBriefs() != null)



         for (TaoBaoGoodsBrief g : result.getTaoBaoGoodsBriefs()) {



            System.out.println(goods.getAuctionId() + ":" + g.getAuctionId());



            if (goods.getAuctionId().longValue() == g.getAuctionId()) {



               g.setId(goods.getAuctionId());



               // 判断是否有优惠券



@@ -383,6 +393,7 @@


                  g.setCouponStartFee(new BigDecimal(0));



               }



               g.setCreatetime(new Date());



               g.setMaterialLibType(goods.getMaterialLibType());



               return g;



            }



         }



@@ -450,6 +461,7 @@


                  g.setCouponStartFee(new BigDecimal(0));



               }



               g.setCreatetime(new Date());



               g.setMaterialLibType(goods.getMaterialLibType());



               return g;



            }



         }



@@ -1094,6 +1106,8 @@


               goods.setZkPrice(new BigDecimal(item.optString("zk_final_price")));



               goods.setAuctionUrl(item.optString("item_url"));



               goods.setPictUrl(item.optString("pict_url"));



               goods.setSalesCount(item.optString("volume"));



               goods.setUserType(item.optInt("user_type"));



               list.add(goods);



            }



      }



@@ -1227,6 +1241,62 @@


   }







   /**



    * 店铺搜索



    * 


    * @param key



    *            -店铺名称



    * @param page



    *            -页码



    * @return



    */



   public static TaoBaoShopInfoDTO searchShop(String key, int page, int pageSize) {



      TaoBaoShopInfoDTO dto = new TaoBaoShopInfoDTO();



      if (StringUtil.isNullOrEmpty(key))



         return dto;







      PageEntity pageEntity = new PageEntity();



      List<TaoBaoShopInfo> list = new ArrayList<>();



      Map<String, String> map = new HashMap<>();



      map.put("method", "taobao.tbk.shop.get");



      map.put("fields", "user_id,shop_title,shop_type,seller_nick,pict_url,shop_url");



      map.put("q", key);



      map.put("page_size", pageSize + "");



      map.put("page_no", page + "");



      String resultStr = TaoKeBaseUtil.baseRequestForThreeTimes(map, true);



      JSONObject resultDate = JSONObject.fromObject(resultStr);



      if (resultDate.optJSONObject("tbk_shop_get_response") != null



            && resultDate.optJSONObject("tbk_shop_get_response").optJSONObject("results") != null) {



         JSONArray array = resultDate.optJSONObject("tbk_shop_get_response").optJSONObject("results")



               .optJSONArray("n_tbk_shop");



         if (array != null) {



            for (int i = 0; i < array.size(); i++) {



               JSONObject item = array.optJSONObject(i);



               TaoBaoShopInfo info = new TaoBaoShopInfo();



               info.setPictureUrl(item.optString("pict_url"));



               info.setSellerNick(item.optString("seller_nick"));



               info.setShopTitle(item.optString("shop_title"));



               info.setShopType(item.optString("shop_type"));



               info.setShopUrl(item.optString("shop_url"));



               info.setUserId(item.optLong("user_id"));



               list.add(info);



            }



         }







         JSONObject optJSONObject = resultDate.optJSONObject("tbk_shop_get_response");



         int totalResults = optJSONObject.getInt("total_results");



         int totalPage = totalResults % pageSize == 0 ? totalResults / pageSize : totalResults / pageSize + 1;



         pageEntity.setTotalCount(totalResults);



         pageEntity.setTotalPage(totalPage);



      }



      pageEntity.setPageIndex(page);



      pageEntity.setPageSize(pageSize);







      dto.setListInfo(list);



      dto.setPage(pageEntity);



      return dto;



   }







   /**



    * TODO 按设备猜你喜欢



    * 



    * @param userNickName



@@ -1322,7 +1392,7 @@


      map.put("page_no", page + "");



      map.put("page_size", pageSize + "");



      map.put("material_id", materialId + "");



      map.put("content_id", "561388751621");



//      map.put("content_id", "561388751621");







      String resultStr = TaoKeBaseUtil.baseRequestForThreeTimes(map, true);



      System.out.println(resultStr);



@@ -1593,6 +1663,7 @@


               .optString("relation_id");



      } catch (TaoKeApiException e) {



         e.printStackTrace();



         LogHelper.error("渠道ID申请出错:" + e.getMsg());



      }







      return null;



@@ -1615,37 +1686,117 @@


               .optString("special_id");



      } catch (TaoKeApiException e) {



         e.printStackTrace();



         LogHelper.error("会员运营ID申请出错:" + resultJSON);



      }







      return null;



   }







   public static void getTaoBaoOrder(String appKey, String appSecret) {



   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.order.get");



      map.put("fields",



            "tb_trade_parent_id,tb_trade_id,num_iid,item_title,item_num,price,pay_price,seller_nick,seller_shop_title,commission,commission_rate,unid,create_time,earning_time,tk_status,tk3rd_pub_id,tk3rd_site_id,tk3rd_adzone_id,relation_id,tb_trade_parent_id,tb_trade_id,num_iid,item_title,item_num,price,pay_price,seller_nick,seller_shop_title,commission,commission_rate,unid,create_time,earning_time,tk3rd_pub_id,tk3rd_site_id,tk3rd_adzone_id,special_id,click_time,relation_id,special_id");



      map.put("start_time", "2019-01-27 21:23:00");



      map.put("span", "1200");



      map.put("tk_status", "1");



      map.put("order_query_type","create_time");



      map.put("page_no", 1+"");



      map.put("page_size", 100+"");



		


		


		


		






      TaoKeAppInfo app = new TaoKeAppInfo();



      app.setAppKey(appKey);



      app.setAppSecret(appSecret);



      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);



            goods.setCouponInfo(resultJSON.optString("coupon_info"));



         }



         String tkRate = resultJSON.optString("max_commission_rate");



         if (!StringUtil.isNullOrEmpty(tkRate)) {



            goods.setTkRate(new BigDecimal(tkRate));



         }



         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();



      }







   }







   public static void taoKeContent() {



      Map<String, String> map = new HashMap<>();



      map.put("method", "taobao.tbk.content.get");



      map.put("adzone_id", TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT.split("_")[3]);



      map.put("type", "1");



      map.put("count", "100");







      TaoKeAppInfo app = new TaoKeAppInfo();



      app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);



      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);



      try {



         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);



         System.out.println(json);



      } catch (TaoKeApiException e) {



         e.printStackTrace();



      }



   }







   public static void taoKeContentSource(String contentId, String source) {



      Map<String, String> map = new HashMap<>();



      map.put("method", "taobao.tbk.dg.optimus.material");



      map.put("adzone_id", TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT.split("_")[3]);



      map.put("page_size", "10");



      map.put("page_no", "1");



      map.put("content_id", contentId);



      map.put("content_source", source);



      map.put("material_id", "1");







      TaoKeAppInfo app = new TaoKeAppInfo();



      app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);



      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);



      try {



         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);



         System.out.println(json);



      } catch (TaoKeApiException e) {



         e.printStackTrace();



      }



   }







   // AA5ISJ



@@ -1738,9 +1889,173 @@


      }



      goods.setReservePrice(new BigDecimal(0));



      goods.setTotalFee(new BigDecimal("0"));



      goods.setPictUrlWhite(item.optString("white_image"));



      return goods;



   }







   public static void getShopGoodsList(Long shopId) {



      Map<String, String> map = new HashMap<>();



      map.put("method", "tmall.omni.pc.iteminfo.getbyshopid");



      map.put("shop_id", shopId + "");



      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();



      }



   }







   public static void getTaoKeContentEffective() {



      Map<String, String> map = new HashMap<>();



      map.put("method", "taobao.tbk.dg.optimus.material");



      map.put("adzone_id", TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID.split("_")[3]);



      map.put("page_no", "1");



      map.put("page_size", "20");



      map.put("content_id", "8872035");







      TaoKeAppInfo app = new TaoKeAppInfo();



      app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);



      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);



      try {



         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);



         System.out.println(json);



      } catch (TaoKeApiException e) {



         e.printStackTrace();



      }







   }







   public static void getTaoKeContent() {



      Map<String, String> map = new HashMap<>();



      map.put("method", "taobao.tbk.content.get");



      map.put("adzone_id", TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID.split("_")[3]);



      map.put("type", "1");







      TaoKeAppInfo app = new TaoKeAppInfo();



      app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);



      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);



      try {



         JSONObject json = TaoKeBaseUtil.baseRequest(map, app);



         System.out.println(json);



      } catch (TaoKeApiException e) {



         e.printStackTrace();



      }







   }







   // 淘礼金创建



   public static TaoLiJinDTO createTaoLiJin(Long auctionId, String name, BigDecimal perface, int totalNum,



         Date sendStartTime, Date sendEndTime, Date useStartTime, Date useEndTime,TaoKeAppInfo app) throws TaoKeApiException{



      Map<String, String> map = new HashMap<>();



      map.put("method", "taobao.tbk.dg.vegas.tlj.create");



      map.put("adzone_id", app.getPid().split("_")[3]);



      map.put("item_id", auctionId + "");



      map.put("total_num", totalNum + "");



      map.put("name", name);



      map.put("user_total_win_num_limit", "1");



      map.put("security_switch", "false");



      map.put("per_face", perface.toString());



      map.put("send_start_time", TimeUtil.getGernalTime(sendStartTime.getTime(), "yyyy-MM-dd HH:mm:ss"));



		


		


      if(sendEndTime != null)



         map.put("send_end_time", TimeUtil.getGernalTime(sendEndTime.getTime(), "yyyy-MM-dd HH:mm:ss"));



		


      if(useEndTime != null) {



         map.put("use_end_time", TimeUtil.getGernalTime(useEndTime.getTime(), "yyyy-MM-dd"));



         map.put("use_end_time_mode", "2");



      }



		


      if(useStartTime != null)



         map.put("use_start_time", TimeUtil.getGernalTime(useStartTime.getTime(), "yyyy-MM-dd"));



      try {



         String result = TaoKeBaseUtil.baseRequestForThreeTimes(map, app);



         JSONObject json = JSONObject.fromObject(result);



         System.out.println(json);



         JSONObject root = json.optJSONObject("tbk_dg_vegas_tlj_create_response");



         if (root != null && root.optJSONObject("result") != null) {



				


            if (root.optJSONObject("result").optBoolean("success")) {



               JSONObject modelJson = root.optJSONObject("result").optJSONObject("model");



               TaoLiJinDTO dto = new TaoLiJinDTO();



               dto.setRightsId(modelJson.optString("rights_id"));



               dto.setSendUrl(modelJson.optString("send_url"));



               return dto;



            }else{



               LogHelper.error(json);



            }



				


            // 接口返回异常



            String msgCode = root.optJSONObject("result").optString("msg_code");



            if (!StringUtil.isNullOrEmpty(msgCode)) {



                switch(msgCode){



                 case "FAIL_BIZ_ITEM_FORBIDDEN":



                    throw new TaoKeApiException(TaoKeApiException.CODE_TLJ_FORBIDDEN, "该商品不支持创建淘礼金红包");



                 case "FAIL_BIZ_ACCOUNT_UN_PAID":



                 case "PRE_FREEZE_ASSET_ACCOUNT_ERROR":



                    throw new TaoKeApiException(TaoKeApiException.CODE_TLJ_NO_MONEY, "官方玩法钱包余额不足");



                 default:



                    return null;



               }



            }



         }



      } catch (TaoKeApiException e) {



          throw e;



      } catch (Exception e) {



         LogHelper.errorDetailInfo(e);



      }







      return null;



   }











   // 淘礼金报告



   public static UserTaoLiJinReport getTaoLiJinEffective(String rightsId) {



      Map<String, String> map = new HashMap<>();



      map.put("method", "taobao.tbk.dg.vegas.tlj.instance.report");



      map.put("rights_id", rightsId);







      TaoKeAppInfo app = new TaoKeAppInfo();



      app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);



      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);



		


      try {



         String result = TaoKeBaseUtil.baseRequestForThreeTimes(map, app);



         JSONObject json = JSONObject.fromObject(result);



         System.out.println(json);



			


         JSONObject root = json.optJSONObject("tbk_dg_vegas_tlj_instance_report_response");



			


			


         if (root != null && root.optJSONObject("result") != null) {



            if (root.optJSONObject("result").optBoolean("success")) {



               JSONObject modelJson = root.optJSONObject("result").optJSONObject("model");



					


               if (modelJson != null && modelJson.size() > 0) {



                  UserTaoLiJinReport report = new UserTaoLiJinReport();



                  report.setId(rightsId);



                  report.setUnfreezeAmount(new BigDecimal(modelJson.optString("unfreeze_amount")));



                  report.setUnfreezeNum(modelJson.optInt("unfreeze_num"));



                  report.setRefundAmount(new BigDecimal(modelJson.optString("refund_amount")));



                  report.setRefundNum(modelJson.optInt("refund_num"));



                  report.setAlipayAmount(new BigDecimal(modelJson.optString("alipay_amount")));



                  report.setUseAmount(new BigDecimal(modelJson.optString("use_amount")));



                  report.setUseNum(modelJson.optInt("use_num"));



                  report.setWinAmount(new BigDecimal(modelJson.optString("win_amount")));



                  report.setWinNum(modelJson.optInt("win_num"));



                  report.setPreCommissionAmount(new BigDecimal(modelJson.optString("pre_commission_amount")));



                  return report;



               } 


            }



         }



      } catch (Exception e) {



         LogHelper.errorDetailInfo(e);



      }



      return null;



   }



}







class QuanInfo {