From b47f8a03db79bb1f6356479cd8a5cf190d7d9694 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 23 六月 2021 11:10:36 +0800 Subject: [PATCH] 礼金功能完善 --- facade-lijin/src/main/java/com/ks/lijin/utils/taobao/TaoKeApiUtil.java | 68 ++++++++++++++++++++++++++++++++- 1 files changed, 65 insertions(+), 3 deletions(-) diff --git a/facade-lijin/src/main/java/com/ks/lijin/utils/taobao/TaoKeApiUtil.java b/facade-lijin/src/main/java/com/ks/lijin/utils/taobao/TaoKeApiUtil.java index 65e2bbb..a04cdf0 100644 --- a/facade-lijin/src/main/java/com/ks/lijin/utils/taobao/TaoKeApiUtil.java +++ b/facade-lijin/src/main/java/com/ks/lijin/utils/taobao/TaoKeApiUtil.java @@ -1,6 +1,7 @@ package com.ks.lijin.utils.taobao; +import com.google.gson.Gson; import com.ks.lijin.exception.*; import com.ks.lijin.pojo.DTO.taobao.*; import com.ks.lijin.pojo.PageEntity; @@ -27,7 +28,7 @@ // 娣樼ぜ閲戝垱寤� public static TaoLiJinDTO createTaoLiJin(Long auctionId, String name, BigDecimal perface, int totalNum, Date sendStartTime, Date sendEndTime, Date useStartTime, Date useEndTime, TaoKeAppInfo app) - throws LiJinAccountException, LiJinException, LiJinGoodsException { + throws LiJinAccountException, LiJinAmountException, LiJinException, LiJinGoodsException { Map<String, String> map = new HashMap<>(); map.put("method", "taobao.tbk.dg.vegas.tlj.create"); map.put("adzone_id", app.getPid().split("_")[3]); @@ -68,6 +69,7 @@ // 鎺ュ彛杩斿洖寮傚父 String msgCode = root.optJSONObject("result").optString("msg_code"); + String msgInfo = root.optJSONObject("result").optString("msg_info"); if (!StringUtil.isNullOrEmpty(msgCode)) { // TLJLogHelper.info(auctionId, root.toString());// 娣樼ぜ閲戝紓甯镐俊鎭褰� TODO switch (msgCode) { @@ -80,7 +82,9 @@ case "ASSET_ACCOUNT_BALANCE_NOT_ENOUGH": throw new LiJinAccountException(LiJinAccountException.CODE_TLJ_NO_MONEY, "璐︽埛棰勭畻涓嶈冻"); case "FAIL_CHECK_ITEM_DAILY_SEND_NUM_CHECK_ERROR": - throw new LiJinGoodsException(LiJinGoodsException.CODE_GOODS_CREATED_NUM_FULL, "浠婃棩璇ュ晢鍝佹窐绀奸噾鍒涘缓鏁板凡瓒呬笂闄愶紝璇锋偍鏄庢棩鍐嶈瘯"); + throw new LiJinGoodsException(LiJinGoodsException.CODE_GOODS_CREATED_FULL, "浠婃棩璇ュ晢鍝佹窐绀奸噾鍒涘缓鏁板凡瓒呬笂闄愶紝璇锋偍鏄庢棩鍐嶈瘯"); + case "FAIL_CHECK_TLJ_MIN_FACE_ERROR": + throw new LiJinAmountException(LiJinAmountException.CODE_LIJIN_AMOUNT_OUTOFRANGE, msgInfo); default: throw new LiJinException(Integer.parseInt(msgCode), root.toString()); } @@ -89,6 +93,41 @@ } catch (LiJinException e) { throw e; } + + return null; + } + + + /** + * 娣樼ぜ閲戞姤鍛� + * + * @param rightsId + * @param app + * @return + * @throws LiJinAccountException + * @throws LiJinAmountException + * @throws LiJinException + * @throws LiJinGoodsException + */ + public static TaoLiJinReportDTO taolijinReport(String rightsId, TaoKeAppInfo app) { + Map<String, String> map = new HashMap<>(); + map.put("method", "taobao.tbk.dg.vegas.tlj.instance.report"); + map.put("rights_id", rightsId); + + String result = 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"); + TaoLiJinReportDTO dto = new Gson().fromJson(modelJson.toString(), TaoLiJinReportDTO.class); + return dto; + } else { + // 鏃ュ織璁板綍 TODO + } + } + return null; } @@ -134,8 +173,9 @@ params.put("v", "2.0"); params.put("timestamp", TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss")); params.put("format", "json"); - if (!StringUtil.isNullOrEmpty(app.getAdzoneId())) + if (!StringUtil.isNullOrEmpty(app.getAdzoneId())) { params.put("adzone_id", app.getAdzoneId()); + } params.put("sign", getSign(params, "md5", app).toUpperCase()); String result = taoKeGet(params); JSONObject data = JSONObject.fromObject(result); @@ -234,11 +274,15 @@ String key = keys.next(); url += String.format("%s=%s&", key, URLEncoder.encode(params.get(key), "UTF-8")); } + System.out.println("娣樺璇锋眰杩炴帴锛�" + url); GetMethod method = new GetMethod(url); // 3S鐨勫搷搴旇秴鏃� HttpConnectionManagerParams hparams = new HttpConnectionManagerParams(); hparams.setConnectionTimeout(3000); client.getHttpConnectionManager().setParams(hparams); + client.executeMethod(method); + String result = method.getResponseBodyAsString(); + System.out.println(result); return method.getResponseBodyAsString(); } catch (Exception e) { e.printStackTrace(); @@ -573,6 +617,24 @@ return goods; } + public static Date getTaoBaoSystemTime() { + Map<String, String> map = new HashMap<>(); + map.put("method", "taobao.time.get"); + try { + JSONObject json = TaoKeBaseUtil.baseRequest(map, false); + String time = json.optJSONObject("time_get_response").optString("time"); + return new Date(TimeUtil.convertToTimeTemp(time, "yyyy-MM-dd HH:mm:ss")); + } catch (Exception e) { + e.printStackTrace(); + } + return null; + } + + + public static void main(String[] args) { + taolijinReport("eC2%2FoV8gigdzVO5CvuRDjDVC0SEP1L7d",new TaoKeAppInfo("27743325","527a23554f71557d7b786bc479fcd5fe")); + } + } -- Gitblit v1.8.0