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

Commit 0a5de099 authored by jiangxiulong's avatar jiangxiulong

获取nft数字账户开通信息

parent fbd1d81e
......@@ -132,6 +132,7 @@ public class GoblinRedisConst {
public static final String REDIS_GOBLIN_NFT_ORDER_EX_LOCK = PREFIX.concat("nft:order:exLock:");// nft兑换码锁 code
public static final String REDIS_GOBLIN_NFT_GOODS_LIST = PREFIX.concat("nft:goodsList");// nft商品列表
public static final String REDIS_GOBLIN_NFT_NUM_ACCOUNT = PREFIX.concat("nft:account:");// nft用户数字账户是否开通 userId
public static final String REDIS_GOBLIN_NFT_NUM_ACCOUNT_INFO = PREFIX.concat("nft:account:info:");// nft用户数字账户开通信息 userId
......
package com.liquidnet.service.goblin.constant;
public class NftAccStatusEnum {
/**
* 数字账户开通状态
*/
public enum StatusAcc {
ING("1000", "开通中"),
SUCCESS("2000", "开通成功"),
FAILURE1("3000", "实名失败"),
FAILURE2("3001", "开通失败 重试"),
FAILURE3("3002", "该身份证已开通数字账号 不可重复操作"),
;
private final String code;
private final String msg;
StatusAcc(String code, String msg) {
this.code = code;
this.msg = msg;
}
public String getCode() {
return code;
}
public String getMsg() {
return msg;
}
}
}
package com.liquidnet.service.goblin.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.liquidnet.commons.lang.util.DateUtil;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
@ApiModel(value = "GoblinUserNftAccInfoVo", description = "数字账户开通信息")
@Data
public class GoblinUserNftAccInfoVo implements Serializable, Cloneable {
private static final long serialVersionUID = 9036417838200526658L;
@ApiModelProperty(position = 11, value = "状态码")
private String code;
@ApiModelProperty(position = 12, value = "提示信息")
private String msg;
@ApiModelProperty(position = 13, value = "最后操作的时间")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR)
private LocalDateTime time;
private static final GoblinUserNftAccInfoVo obj = new GoblinUserNftAccInfoVo();
public static GoblinUserNftAccInfoVo getNew() {
try {
return (GoblinUserNftAccInfoVo) obj.clone();
} catch (CloneNotSupportedException e) {
return new GoblinUserNftAccInfoVo();
}
}
}
......@@ -7,6 +7,7 @@ import com.liquidnet.commons.lang.util.CurrentUtil;
import com.liquidnet.commons.lang.util.IDCardUtil;
import com.liquidnet.service.base.ErrorMapping;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.goblin.dto.GoblinUserNftAccInfoVo;
import com.liquidnet.service.goblin.service.IGoblinNftUserService;
import com.liquidnet.service.goblin.util.GoblinRedisUtils;
import io.swagger.annotations.Api;
......@@ -71,4 +72,12 @@ public class GoblinNFTUserController {
public ResponseDto<Boolean> openAccount() {
return ResponseDto.success(goblinRedisUtils.getNftNumAccount(CurrentUtil.getCurrentUid()));
}
@ApiOperationSupport(order = 11)
@ApiOperation(value = "业务账号开通信息")
@GetMapping(value = "open/account/info")
public ResponseDto<GoblinUserNftAccInfoVo> openAccountInfo() {
goblinRedisUtils.setOpenAccountInfo(CurrentUtil.getCurrentUid());
return ResponseDto.success(goblinRedisUtils.openAccountInfo(CurrentUtil.getCurrentUid()));
}
}
package com.liquidnet.service.goblin.util;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import com.liquidnet.common.cache.redis.util.RedisUtil;
import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.commons.lang.util.RandomUtil;
import com.liquidnet.commons.lang.util.StringUtil;
import com.liquidnet.service.goblin.constant.GoblinRedisConst;
import com.liquidnet.service.goblin.constant.GoblinStatusConst;
import com.liquidnet.service.goblin.constant.NftAccStatusEnum;
import com.liquidnet.service.goblin.dto.GoblinStoreMarketDto;
import com.liquidnet.service.goblin.dto.GoblinUserNftAccInfoVo;
import com.liquidnet.service.goblin.dto.manage.vo.GoblinGoodsAnticipateValueVo;
import com.liquidnet.service.goblin.dto.manage.vo.GoblinMgtCategorySpecVo;
import com.liquidnet.service.goblin.dto.vo.*;
......@@ -1756,6 +1756,24 @@ public class GoblinRedisUtils {
}
}
public GoblinUserNftAccInfoVo openAccountInfo(String userId) {
String redisKey = GoblinRedisConst.REDIS_GOBLIN_NFT_NUM_ACCOUNT_INFO.concat(userId);
Object obj = redisUtil.get(redisKey);
if (obj == null) {
return null;
} else {
return (GoblinUserNftAccInfoVo) obj;
}
}
public void setOpenAccountInfo(String userId) {
String redisKey = GoblinRedisConst.REDIS_GOBLIN_NFT_NUM_ACCOUNT_INFO.concat(userId);
GoblinUserNftAccInfoVo nftAccInfoVo = GoblinUserNftAccInfoVo.getNew();
nftAccInfoVo.setCode(NftAccStatusEnum.StatusAcc.ING.getCode());
nftAccInfoVo.setMsg(NftAccStatusEnum.StatusAcc.ING.getMsg());
nftAccInfoVo.setTime(LocalDateTime.now());
Object obj = redisUtil.set(redisKey, nftAccInfoVo);
}
public int getIsExchange(String skuId) {
String redisKey = GoblinRedisConst.ACTIVITY_SKU_TIME.concat(skuId);
Object obj = redisUtil.get(redisKey);
......
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