Merge remote-tracking branch 'origin/master'

admin

2019-07-30 573c491b4a1ba60e12a5678a01c1546c0077c1ee

 fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeApiUtil.java

@@ -22,6 +22,7 @@
import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult;

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

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

import com.yeshi.fanli.exception.taobao.TaoBaoAuthException;

import com.yeshi.fanli.exception.taobao.TaoKeApiException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.log.LogHelper;

@@ -1392,7 +1393,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);

@@ -1646,7 +1647,7 @@
      return null;

   }



   public static String getRelationId(String accessToken, String appKey, String appSecret) {

   public static String getRelationId(String accessToken, String appKey, String appSecret) throws TaoBaoAuthException {

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

      map.put("method", "taobao.tbk.sc.publisher.info.save");

      map.put("session", accessToken);

@@ -1662,14 +1663,22 @@
         return resultJSON.optJSONObject("tbk_sc_publisher_info_save_response").optJSONObject("data")

               .optString("relation_id");

      } catch (TaoKeApiException e) {

         e.printStackTrace();

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

         JSONObject errorJSON = JSONObject.fromObject(e.getMsg()).optJSONObject("error_response");

         if (errorJSON.optInt("code") == 15 && errorJSON.optInt("sub_code") == 1)// 未实名

         {

            throw new TaoBaoAuthException(TaoBaoAuthException.CODE_NOT_REAL_NAME, errorJSON.optString("sub_msg"));

         } else {

            e.printStackTrace();

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

            throw new TaoBaoAuthException(TaoBaoAuthException.CODE_OTHER, errorJSON.optString("sub_msg"));

         }

      } catch (Exception e) {

         LogHelper.error("渠道ID申请出错:" + (resultJSON != null ? resultJSON.toString() : "未知错误"));

      }



      return null;

   }



   public static String getSpecialId(String accessToken, String appKey, String appSecret) {

   public static String getSpecialId(String accessToken, String appKey, String appSecret) throws TaoBaoAuthException {

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

      map.put("method", "taobao.tbk.sc.publisher.info.save");

      map.put("session", accessToken);

@@ -1685,8 +1694,17 @@
         return resultJSON.optJSONObject("tbk_sc_publisher_info_save_response").optJSONObject("data")

               .optString("special_id");

      } catch (TaoKeApiException e) {

         e.printStackTrace();

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

         JSONObject errorJSON = JSONObject.fromObject(e.getMsg()).optJSONObject("error_response");

         if (errorJSON.optInt("code") == 15 && errorJSON.optInt("sub_code") == 1)// 未实名

         {

            throw new TaoBaoAuthException(TaoBaoAuthException.CODE_NOT_REAL_NAME, errorJSON.optString("sub_msg"));

         } else {

            e.printStackTrace();

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

            throw new TaoBaoAuthException(TaoBaoAuthException.CODE_OTHER, errorJSON.optString("sub_msg"));

         }

      } catch (Exception e) {

         LogHelper.error("会员运营ID申请出错:" + (resultJSON != null ? resultJSON.toString() : "未知错误"));

      }



      return null;

@@ -1946,9 +1964,38 @@


   }



   /**

    * 淘口令转商品ID

    * 
    * @param token

    * @return

    */

   public static Long tokenConvertAuctionId(String token) {

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

      map.put("method", "taobao.tbk.tpwd.convert");

      map.put("password_content", token);

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

      TaoKeAppInfo app = new TaoKeAppInfo();

      app.setAppKey(TaoBaoConstant.TAOBAO_AUTH_APPKEY);

      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);

      try {

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

         try {

            return json.optJSONObject("tbk_tpwd_convert_response").optJSONObject("data").optLong("num_iid");

         } catch (Exception e) {

            return null;

         }



      } catch (TaoKeApiException e) {

         e.printStackTrace();

      }

      return null;

   }



   // 淘礼金创建

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

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

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

@@ -1959,17 +2006,16 @@
      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)



      if (sendEndTime != null)

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

		
      if(useEndTime != null) {



      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)



      if (useStartTime != null)

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

      try {

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

@@ -1977,38 +2023,39 @@
         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 "2":

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

                 default:

                    return null;

               }

               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;

         throw e;

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }



      return null;

   }





   // 淘礼金报告

   public static UserTaoLiJinReport getTaoLiJinEffective(String rightsId) {

@@ -2019,19 +2066,18 @@
      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);

@@ -2046,7 +2092,7 @@
                  report.setWinNum(modelJson.optInt("win_num"));

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

                  return report;

               } 
               }

            }

         }

      } catch (Exception e) {

@@ -2054,6 +2100,23 @@
      }

      return null;

   }



   public static void getCouponByAuctionId(Long auctionId) {

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

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

      map.put("platform", 2 + "");

      map.put("pid", TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID);

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

      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.print(json);

      } catch (Exception e) {

         e.printStackTrace();

      }

   }

}



class QuanInfo {