~api:我的藏品列表:至信链上链结果查询异常处理;

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinUserDigitalArtworkServiceImpl.java

@@ -358,36 +358,40 @@ public class GoblinUserDigitalArtworkServiceImpl implements IGoblinUserDigitalAr
 
     private void updateUserDigitalArtworkByChainTrade(GoblinUserDigitalArtworkVo userDigitalArtworkVo, GoblinUserDigitalArtworkListVo listVo,
                                                       String routerType, LocalDateTime now) {
-        GalaxyNftPublishAndBuyResultQueryReqDto nftTradeQueryReqDto = GalaxyNftPublishAndBuyResultQueryReqDto.getNew();
-        nftTradeQueryReqDto.setUserId(userDigitalArtworkVo.getUid());
-        nftTradeQueryReqDto.setNftOrderPayId(userDigitalArtworkVo.getOrderId());
-        nftTradeQueryReqDto.setRouterType(routerType);
-        ResponseDto<GalaxyNftPublishAndBuyResultQueryRespDto> nftTradeQueryRespDto = galaxyTradeService.nftPublishAndBuyResultQuery(nftTradeQueryReqDto);
-        if (nftTradeQueryRespDto.isSuccess()) {
-            GalaxyNftPublishAndBuyResultQueryRespDto nftTradeQueryRespDtoData = nftTradeQueryRespDto.getData();
-            String nftId = nftTradeQueryRespDtoData.getNftId();
-
-            listVo.setState(1);
-            listVo.setEditionSn(Integer.valueOf(nftId.substring(nftId.indexOf("_") + 1)));
-
-            userDigitalArtworkVo.setEditionSn(listVo.getEditionSn());
-            userDigitalArtworkVo.setNftId(nftId);
-            userDigitalArtworkVo.setReleaseAt(nftTradeQueryRespDtoData.getNftPublishChainTimestamp());
-            userDigitalArtworkVo.setReleaseTxhash(nftTradeQueryRespDtoData.getNftPublishTradeHash());
-            userDigitalArtworkVo.setTradingAt(nftTradeQueryRespDtoData.getNftBuyChainTimestamp());
-            userDigitalArtworkVo.setTradingTxhash(nftTradeQueryRespDtoData.getNftBuyTradeHash());
-            userDigitalArtworkVo.setState(1);
-            userDigitalArtworkVo.setUpdatedAt(now);
-
-            goblinRedisUtils.setUserDigitalArtworkVo(userDigitalArtworkVo);
-            goblinMongoUtils.updateUserDigitalArtworkVoByChainTrade(userDigitalArtworkVo);
-
-            queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_ARTWORK_GEN.getKey(),
-                    SqlMapping.get("goblin_user_digital_artwork.update_for_chain",
-                            userDigitalArtworkVo.getEditionSn(), userDigitalArtworkVo.getNftId(), userDigitalArtworkVo.getReleaseTxhash(),
-                            userDigitalArtworkVo.getReleaseAt(), userDigitalArtworkVo.getTradingTxhash(), userDigitalArtworkVo.getTradingAt(),
-                            userDigitalArtworkVo.getState(), userDigitalArtworkVo.getUpdatedAt(), userDigitalArtworkVo.getArtworkId())
-            );
+        try {
+            GalaxyNftPublishAndBuyResultQueryReqDto nftTradeQueryReqDto = GalaxyNftPublishAndBuyResultQueryReqDto.getNew();
+            nftTradeQueryReqDto.setUserId(userDigitalArtworkVo.getUid());
+            nftTradeQueryReqDto.setNftOrderPayId(userDigitalArtworkVo.getOrderId());
+            nftTradeQueryReqDto.setRouterType(routerType);
+            ResponseDto<GalaxyNftPublishAndBuyResultQueryRespDto> nftTradeQueryRespDto = galaxyTradeService.nftPublishAndBuyResultQuery(nftTradeQueryReqDto);
+            if (nftTradeQueryRespDto.isSuccess()) {
+                GalaxyNftPublishAndBuyResultQueryRespDto nftTradeQueryRespDtoData = nftTradeQueryRespDto.getData();
+                String nftId = nftTradeQueryRespDtoData.getNftId();
+
+                listVo.setState(1);
+                listVo.setEditionSn(Integer.valueOf(nftId.substring(nftId.indexOf("_") + 1)));
+
+                userDigitalArtworkVo.setEditionSn(listVo.getEditionSn());
+                userDigitalArtworkVo.setNftId(nftId);
+                userDigitalArtworkVo.setReleaseAt(nftTradeQueryRespDtoData.getNftPublishChainTimestamp());
+                userDigitalArtworkVo.setReleaseTxhash(nftTradeQueryRespDtoData.getNftPublishTradeHash());
+                userDigitalArtworkVo.setTradingAt(nftTradeQueryRespDtoData.getNftBuyChainTimestamp());
+                userDigitalArtworkVo.setTradingTxhash(nftTradeQueryRespDtoData.getNftBuyTradeHash());
+                userDigitalArtworkVo.setState(1);
+                userDigitalArtworkVo.setUpdatedAt(now);
+
+                goblinRedisUtils.setUserDigitalArtworkVo(userDigitalArtworkVo);
+                goblinMongoUtils.updateUserDigitalArtworkVoByChainTrade(userDigitalArtworkVo);
+
+                queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_ARTWORK_GEN.getKey(),
+                        SqlMapping.get("goblin_user_digital_artwork.update_for_chain",
+                                userDigitalArtworkVo.getEditionSn(), userDigitalArtworkVo.getNftId(), userDigitalArtworkVo.getReleaseTxhash(),
+                                userDigitalArtworkVo.getReleaseAt(), userDigitalArtworkVo.getTradingTxhash(), userDigitalArtworkVo.getTradingAt(),
+                                userDigitalArtworkVo.getState(), userDigitalArtworkVo.getUpdatedAt(), userDigitalArtworkVo.getArtworkId())
+                );
+            }
+        } catch (NumberFormatException e) {
+            log.error("Ex.我的藏品列表:藏品上链结果查询处理失败[uid={},orderId={}]", userDigitalArtworkVo.getUid(), userDigitalArtworkVo.getOrderId(), e);
         }
     }
 }