好单库转链支持

admin

2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c

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

@@ -10,11 +10,13 @@
import com.yeshi.fanli.dto.taobao.TaoBaoOrderResultDTO;

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

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

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

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

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

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

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

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TaoBaoConstant;

import com.yeshi.fanli.util.TimeUtil;

@@ -98,105 +100,6 @@
         }

      }

      return resultList;

   }



   private static List<TaoBaoOrder> parseTaoBaoOrder(String response) {



      List<TaoBaoOrder> orderList = new ArrayList<>();



      JSONObject data = JSONObject.fromObject(response);

      if (data.optJSONObject("tbk_order_get_response") == null)

         return orderList;

      if (data.optJSONObject("tbk_order_get_response").optJSONObject("results") == null)

         return orderList;

      if (data.optJSONObject("tbk_order_get_response").optJSONObject("results").optJSONArray("n_tbk_order") == null)

         return orderList;



      JSONArray array = data.optJSONObject("tbk_order_get_response").optJSONObject("results")

            .optJSONArray("n_tbk_order");

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



         JSONObject item = array.optJSONObject(i);

         try {

            TaoBaoOrder taoBaoOrder = new TaoBaoOrder();

            taoBaoOrder.setAdPositionId(item.optString("adzone_id"));

            taoBaoOrder.setAdPositionName(item.optString("adzone_name"));

            taoBaoOrder.setAuctionId(item.optLong("num_iid"));

            taoBaoOrder.setClassName(item.optString("auction_category"));

            taoBaoOrder.setClickTime(item.optString("click_time"));

            taoBaoOrder.setCount(item.optInt("item_num"));

            taoBaoOrder.setCreateTime(item.optString("create_time"));

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

               taoBaoOrder.seteIncome(new BigDecimal(item.optString("total_commission_fee")));

            else

               taoBaoOrder.seteIncome(new BigDecimal(0));



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

               taoBaoOrder.setEstimate(new BigDecimal(item.optString("pub_share_pre_fee")));

            else

               taoBaoOrder.setEstimate(new BigDecimal(0));

            taoBaoOrder.setiRatio(new BigDecimal(item.optString("income_rate")).multiply(new BigDecimal(100)));

            taoBaoOrder.setLatestUpdateTime(null);

            taoBaoOrder.setManagerWangWang(null);

            taoBaoOrder.setOrderBy(null);

            taoBaoOrder.setOrderId(item.optString("trade_parent_id"));

            if (item.optInt("tk_status") == 12)

               taoBaoOrder.setOrderState("订单付款");

            else if (item.optInt("tk_status") == 3)

               taoBaoOrder.setOrderState("订单结算");

            else if (item.optInt("tk_status") == 13)

               taoBaoOrder.setOrderState("订单失效");

            else if (item.optInt("tk_status") == 14)

               taoBaoOrder.setOrderState("订单成功");



            taoBaoOrder.setOrderType(item.optString("order_type"));

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

               taoBaoOrder.setPayment(new BigDecimal(item.optString("alipay_total_price")));

            else

               taoBaoOrder.setPayment(new BigDecimal(0));

            taoBaoOrder.setPrice(new BigDecimal(item.optString("price")));

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

               taoBaoOrder.setSettlement(new BigDecimal(item.optString("pay_price")));

            else

               taoBaoOrder.setSettlement(new BigDecimal(0));

            taoBaoOrder.setSettlementTime(item.optString("earning_time"));

            taoBaoOrder.setShop(item.optString("seller_shop_title"));

            taoBaoOrder.setSourceMediaId(item.optString("site_id"));

            taoBaoOrder.setSourceMediaName(item.optString("site_name"));

            taoBaoOrder.setsRatio(null);

            if (!StringUtil.isNullOrEmpty(item.optString("subsidy_fee")))// 补贴金额

               taoBaoOrder.setSubsidy(new BigDecimal(item.optString("subsidy_fee")));

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

               taoBaoOrder.setSubsidyRatio(

                     new BigDecimal(item.optString("subsidy_rate")).multiply(new BigDecimal(100)));

            taoBaoOrder.setSubsidyType(item.optString("subsidy_type"));

            taoBaoOrder.setTechnologySupportPercent(null);

            taoBaoOrder.setThirdService(null);

            taoBaoOrder.setTitle(item.optString("item_title"));

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

               taoBaoOrder.setTkMoney(new BigDecimal(item.optString("total_commission_fee")));

            else

               taoBaoOrder.setTkMoney(new BigDecimal(0));

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

               taoBaoOrder

                     .setTkRate(new BigDecimal(item.optString("commission_rate")).multiply(new BigDecimal(100)));

            else if (!StringUtil.isNullOrEmpty(item.optString("total_commission_rate")))

               taoBaoOrder.setTkRate(

                     new BigDecimal(item.optString("total_commission_rate")).multiply(new BigDecimal(100)));

            taoBaoOrder.setTransactionPlatform(item.optString("terminal_type"));

            taoBaoOrder.setRelationId(item.optString("relation_id"));

            taoBaoOrder.setSpecialId(item.optString("special_id"));

            taoBaoOrder.setTradeId(item.optString("trade_id"));

            orderList.add(taoBaoOrder);

         } catch (Exception e) {

            try {

               LogHelper.errorDetailInfo(e, "订单号信息:" + item.toString(), "订单解析出错");

            } catch (Exception e1) {

            }

         }

      }



      return orderList;

   }



   private static TaoBaoOrderResultDTO parseTaoBaoOrderNew(String response) {

@@ -291,6 +194,21 @@
               taoBaoOrder.setRelationId(item.optString("relation_id"));

               taoBaoOrder.setSpecialId(item.optString("special_id"));

               taoBaoOrder.setTradeId(item.optString("trade_id"));

               // 解析商品信息

               TaoBaoOrderGoods goods = new TaoBaoOrderGoods();

               goods.setCategoryName(item.optString("item_category_name"));

               goods.setCreateTime(new Date());

               goods.setGoodsId(item.optLong("item_id"));

               goods.setImg(item.optString("item_img"));

               goods.setLink(item.optString("item_link"));

               goods.setPrice(item.optString("item_price"));

               goods.setTitle(item.optString("item_title"));

               goods.setTradeId(item.optString("trade_id"));

               if (goods.getImg() != null && !goods.getImg().startsWith("http")) {

                  goods.setImg("http:" + goods.getImg());

               }



               taoBaoOrder.setGoods(goods);

               orderList.add(taoBaoOrder);

            } catch (Exception e) {

               try {

@@ -446,7 +364,7 @@
               TimeUtil.getGernalTime(end, "yyyy-MM-dd HH:mm:ss"), null, queryType, orderScene);

         if (dto != null)

            orderList.addAll(dto.getOrderList());

         while (dto.isHasNext()) {

         while (dto!=null&&dto.isHasNext()) {

            dto = queryNewOrder(TimeUtil.getGernalTime(start, "yyyy-MM-dd HH:mm:ss"),

                  TimeUtil.getGernalTime(end, "yyyy-MM-dd HH:mm:ss"), dto.getPositionIndex(), queryType,

                  orderScene);

@@ -485,6 +403,8 @@
      app.setAppSecret(TaoBaoConstant.TAOBAO_AUTH_APPSECRET);

      try {

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

         if (Constant.IS_TEST)

            System.out.println(json);

         return parseTaoBaoOrderNew(json.toString());

      } catch (Exception e) {

         e.printStackTrace();