提交 获取是否开通数字账号

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/goblin/utils/GoblinRedisUtils.java

 package com.liquidnet.client.admin.zhengzai.goblin.utils;
 
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
+import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.goblin.constant.GoblinRedisConst;
+import com.liquidnet.service.goblin.constant.NftAccStatusEnum;
+import com.liquidnet.service.goblin.dto.GoblinUserNftAccInfoVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinMarketingZhengzaiRelationVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinSelfMarketingVo;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -131,4 +134,21 @@ public class GoblinRedisUtils {
         redisDataSourceUtil.getRedisGoblinUtil().set(redisKey, list);
     }
 
+    //是否开通数字账号
+    public Boolean getIsOpenAccount(String userId) {
+        String redisKey = GoblinRedisConst.REDIS_GOBLIN_NFT_NUM_ACCOUNT_INFO.concat(userId);
+        Object obj = redisDataSourceUtil.getRedisGoblinUtil().get(redisKey);
+        GoblinUserNftAccInfoVo openAccountInfo;
+        if (obj == null) {
+            openAccountInfo = null;
+        } else {
+            openAccountInfo = (GoblinUserNftAccInfoVo) obj;
+        }
+        // 认证验证
+        if (null == openAccountInfo || !NftAccStatusEnum.StatusAcc.SUCCESS.getCode().equals(openAccountInfo.getCode())) {
+            return false;
+        } else {
+            return true;
+        }
+    }
 }