~api:开通数字账号补充持久化Mysql逻辑;

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

@@ -11,8 +11,11 @@ import com.liquidnet.service.adam.dto.vo.AdamUserBizAcctVo;
 import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamUserBusiAcctService;
 import com.liquidnet.service.adam.service.IAdamUserService;
+import com.liquidnet.service.adam.util.QueueUtils;
 import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.base.SqlMapping;
+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;
@@ -22,6 +25,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.LinkedMultiValueMap;
 
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Optional;
 
@@ -29,9 +33,11 @@ import java.util.Optional;
 @Service
 public class AdamUserBusiAcctServiceImpl implements IAdamUserBusiAcctService {
     @Autowired
-    AdamRdmService adamRdmService;
+    private QueueUtils queueUtils;
     @Autowired
-    IAdamUserService adamUserService;
+    private AdamRdmService adamRdmService;
+    @Autowired
+    private IAdamUserService adamUserService;
 
 
     @Autowired
@@ -50,7 +56,18 @@ public class AdamUserBusiAcctServiceImpl implements IAdamUserBusiAcctService {
         if (AdamEnum.BizAcct.NFT_ZX.name().equals(bizCode)) {
             ResponseDto<AdamUserBizAcctVo> responseDto = this.openAccountForNftZXin(uid, name, idCard, mobile);
             if (responseDto.isSuccess()) {
-                adamRdmService.addBizAcctVoByUid(uid, userBizAcctVoList, responseDto.getData());
+                AdamUserBizAcctVo userBizAcctVo = responseDto.getData();
+                adamRdmService.addBizAcctVoByUid(uid, userBizAcctVoList, userBizAcctVo);
+
+//                LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
+//                toMqSqls.add(SqlMapping.get("adam_user_busi_acct.add"));
+//                LinkedList<Object[]> initUserBusiAcctObjs = CollectionUtil.linkedListObjectArr();
+//                initUserBusiAcctObjs.add(new Object[]{
+//                        uid, AdamEnum.BizAcct.NFT_ZX.name(), userBizAcctVo.getUuid(), null, null, 1, LocalDateTime.now()
+//                });
+                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())
+                );
             }
             return responseDto;
         }
@@ -98,8 +115,8 @@ public class AdamUserBusiAcctServiceImpl implements IAdamUserBusiAcctService {
             LinkedMultiValueMap<String, String> headerMap = CollectionUtil.linkedMultiValueMapStringString();
             headerMap.add("Accept", MediaType.APPLICATION_JSON_VALUE);
             String postRespStr = HttpUtil.post(postUrl, paramsMap, headerMap);
-            JsonNode postRespJNode = JsonUtils.fromJson(postRespStr, JsonNode.class);
-            if (null == postRespJNode || !postRespJNode.get("code").asText().equals("0")) {
+            JsonNode postRespJNode = JsonUtils.fromJson(postRespStr, JsonNode.class), postRespCode;
+            if (null == postRespJNode || null == (postRespCode = postRespJNode.get("code")) || !postRespCode.asText().equals("0")) {
                 log.warn("#开通业务账号:至信数字藏品账号开通失败[paramsMap={},postRespStr={}]", paramsMap, postRespStr);
                 return ResponseDto.failure(ErrorMapping.get("10113"));
             }