记得上下班打卡 | git大法好,push需谨慎

Commit 9131e43f authored by 张国柄's avatar 张国柄

~NFT交易查询接口;

parent f516c849
package com.liquidnet.service.goblin.service.impl.inner; package com.liquidnet.service.goblin.service.impl.inner;
import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.node.ObjectNode;
import com.liquidnet.commons.lang.util.CollectionUtil; import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.commons.lang.util.CurrentUtil; import com.liquidnet.commons.lang.util.CurrentUtil;
import com.liquidnet.commons.lang.util.HttpUtil; import com.liquidnet.commons.lang.util.HttpUtil;
...@@ -89,20 +90,18 @@ public class GoblinGalaxyService { ...@@ -89,20 +90,18 @@ public class GoblinGalaxyService {
* @return * @return
*/ */
public List<String> checkNftTradeResult(String uid, String orderId, String routerType) { public List<String> checkNftTradeResult(String uid, String orderId, String routerType) {
LinkedMultiValueMap<String, String> paramsMap = CollectionUtil.linkedMultiValueMapStringString(); ObjectNode postBodyNode = JsonUtils.OM().createObjectNode();
paramsMap.add("userId", uid); postBodyNode.put("userId", uid);
paramsMap.add("nftOrderPayId", orderId);// TODO: 2022/3/31 ==zhanggb postBodyNode.put("nftOrderPayId", orderId);
paramsMap.add("routerType", routerType); postBodyNode.put("routerType", routerType);
// String postUrl = sevGalaxyUrl + "/user/register", blockChainAddress;// TODO: 2022/3/31 ==zhanggb // String postUrl = sevGalaxyUrl + "/user/register", blockChainAddress;// TODO: 2022/3/31 ==zhanggb
String postUrl = "https://ENVgalaxy.zhengzai.tv/galaxy/nftTrade/nftPublishAndBuyResultQuery".replace("ENV", env.getProperty(CurrentUtil.CK_ENV_ACTIVE)), blockChainAddress; String postUrl = "https://ENVgalaxy.zhengzai.tv/galaxy/nftTrade/nftPublishAndBuyResultQuery".replace("ENV", env.getProperty(CurrentUtil.CK_ENV_ACTIVE)), blockChainAddress;
try { try {
LinkedMultiValueMap<String, String> headerMap = CollectionUtil.linkedMultiValueMapStringString(); String postRespStr = HttpUtil.postRaw(postUrl, postBodyNode.toString(), null);
headerMap.add("Accept", MediaType.APPLICATION_JSON_VALUE);
String postRespStr = HttpUtil.post(postUrl, paramsMap, headerMap);
JsonNode postRespJNode = JsonUtils.fromJson(postRespStr, JsonNode.class), postRespCode; JsonNode postRespJNode = JsonUtils.fromJson(postRespStr, JsonNode.class), postRespCode;
if (null == postRespJNode || null == (postRespCode = postRespJNode.get("code")) || !postRespCode.asText().equals("0")) { if (null == postRespJNode || null == (postRespCode = postRespJNode.get("code")) || !postRespCode.asText().equals("0")) {
log.warn("#NFT发行购买结果查询:查询失败[paramsMap={},postRespStr={}]", paramsMap, postRespStr); log.warn("#NFT发行购买结果查询:查询失败[postBody={},postRespStr={}]", postBodyNode, postRespStr);
return null; return null;
} }
JsonNode postRespDataJNode = postRespJNode.get("data"); JsonNode postRespDataJNode = postRespJNode.get("data");
...@@ -115,7 +114,7 @@ public class GoblinGalaxyService { ...@@ -115,7 +114,7 @@ public class GoblinGalaxyService {
respDataList.add(postRespDataJNode.get("nftBuyTxHash").asText()); respDataList.add(postRespDataJNode.get("nftBuyTxHash").asText());
return respDataList; return respDataList;
} catch (Exception e) { } catch (Exception e) {
log.error("Ex.NFT发行购买结果查询:请求异常[UID={},url={},paramsMap={}],ex:{}", uid, postUrl, paramsMap, e.getMessage()); log.error("Ex.NFT发行购买结果查询:请求异常[url={},postBody={}],ex:{}", postUrl, postBodyNode, e.getMessage());
return null; return null;
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment