+api:查取数字账号;

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamRscController.java

@@ -31,6 +31,7 @@ import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.Optional;
 
 @ApiSupport(order = 10080)
 @Api(tags = "@API:RSC")
@@ -95,6 +96,20 @@ public class AdamRscController {
         return ResponseDto.success(vo.getCreateAt());
     }
 
+    @ApiOperationSupport(order = 23)
+    @ApiOperation(value = "@API:用户第三方业务账号")
+    @GetMapping("inquire/bizacc")
+    public ResponseDto<AdamUserBizAcctVo> queryBizacc(@Pattern(regexp = "\\b(NFT_ZX)\\b", message = "业务码无效")
+                                                      @RequestParam String bizCode,
+                                                      @NotBlank(message = "用户ID不能为空") @RequestParam String uid) {
+        List<AdamUserBizAcctVo> userBizAcctVoList = adamRdmService.getBizAcctVosByUid(uid);
+        if (!CollectionUtils.isEmpty(userBizAcctVoList)) {
+            Optional<AdamUserBizAcctVo> optional = userBizAcctVoList.stream().filter(r -> r.getBizCode().equals(bizCode)).findAny();
+            if (optional.isPresent()) return ResponseDto.success(optional.get());
+        }
+        return ResponseDto.success();
+    }
+
     @ApiOperationSupport(order = 30)
     @ApiOperation(value = "@API:票务下单所需信息查询", notes = "包括是否会员、收货地址及入场人信息")
     @PostMapping("inquire/of_buy_ticket")

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserBusiAcctServiceImpl.java

@@ -2,6 +2,7 @@ package com.liquidnet.service.adam.service.impl;
 
 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.CurrentUtil;
 import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
@@ -19,9 +20,11 @@ import com.liquidnet.service.base.constant.MQConst;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.env.Environment;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
+import org.springframework.util.LinkedMultiValueMap;
 
 import java.time.LocalDateTime;
 import java.util.List;
@@ -42,6 +45,8 @@ public class AdamUserBusiAcctServiceImpl implements IAdamUserBusiAcctService {
     Environment env;
 //    @Value("${liquidnet.service.galaxy.url}")// TODO: 2022/3/29 ==zhanggb
 //    private String sevGalaxyUrl;
+    @Value("${liquidnet.service.goblin.url}")
+    private String serviceGoblinUrl;
 
     @Override
     public ResponseDto<AdamUserBizAcctVo> openAccount(String uid, String bizCode, String name, String idCard, String mobile) {
@@ -66,6 +71,14 @@ public class AdamUserBusiAcctServiceImpl implements IAdamUserBusiAcctService {
                 queueUtils.sendMsgByRedis(MQConst.AdamQueue.SQL_UCENTER.getKey(),
                         SqlMapping.get("adam_user_busi_acct.add", uid, AdamEnum.BizAcct.NFT_ZX.name(), userBizAcctVo.getUuid(), null, null, 1, LocalDateTime.now())
                 );
+
+                try {
+                    LinkedMultiValueMap<String, String> paramsMap = CollectionUtil.linkedMultiValueMapStringString();
+                    paramsMap.add("userId", uid);
+                    HttpUtil.post(serviceGoblinUrl + "/goblin/rsc/nft/sync/acc", paramsMap);
+                } catch (Exception e) {
+                    log.error("Ex.开通业务账号:同步Goblin缓存异常[UID={},URL={}],ex:{}", uid, serviceGoblinUrl, e.getMessage());
+                }
             }
             return responseDto;
         }