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

Skip to content

L
liquidnet-bus-v1
Commit 1d62a79e authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

暂时提交代码

parent 267f1ac4
Hide whitespace changes
Inline Side-by-side
Showing with 38 additions and 245 deletions
liquidnet-bus-api/liquidnet-service-goblin-api/src/main/java/com/liquidnet/service/goblin/dto/vo/AdamUserBizAcctVo.java deleted 100644 → 0
View file @ 267f1ac4
package com.liquidnet.service.goblin.dto.vo;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.liquidnet.service.goblin.entity.AdamUserBusiAcct;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
@ApiModel(value = "AdamUserBizAcctVo", description = "用户业务账号信息")
@JsonIgnoreProperties(ignoreUnknown = true)
@Data
public class AdamUserBizAcctVo implements Serializable, Cloneable {
private static final long serialVersionUID = 7428532456309328881L;
@ApiModelProperty(position = 11, value = "业务码[NFT_ZX-至信数字藏品账号]")
private String bizCode;
@ApiModelProperty(position = 12, value = "业务账号状态[1-已开通]")
private Integer state;
@ApiModelProperty(position = 13, value = "业务账号ID")
private String uuid;
private static final AdamUserBizAcctVo obj = new AdamUserBizAcctVo();
public static AdamUserBizAcctVo getNew() {
try {
return (AdamUserBizAcctVo) obj.clone();
} catch (CloneNotSupportedException e) {
return new AdamUserBizAcctVo();
}
}
public AdamUserBizAcctVo copy(AdamUserBusiAcct source) {
if (null == source) return this;
this.setBizCode(source.getBusi());
this.setUuid(source.getUuid());
this.setState(source.getState());
return this;
}
}
liquidnet-bus-api/liquidnet-service-goblin-api/src/main/java/com/liquidnet/service/goblin/service/IGoblinNftUserService.java deleted 100644 → 0
View file @ 267f1ac4
package com.liquidnet.service.goblin.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.goblin.dto.vo.AdamUserBizAcctVo;
public interface IGoblinNftUserService {
ResponseDto<AdamUserBizAcctVo> openNftAccount(String uid, String bizCode, String name, String idCard, String mobile);
}
liquidnet-bus-do/liquidnet-service-goblin-do/src/main/java/com/liquidnet/service/goblin/entity/AdamUserBusiAcct.java deleted 100644 → 0
View file @ 267f1ac4
package com.liquidnet.service.goblin.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDateTime;
import java.io.Serializable;
import lombok.Data;
import lombok.EqualsAndHashCode;
/**
* <p>
* 用户业务服务账号表
* </p>
*
* @author liquidnet
* @since 2021-09-17
*/
@Data
@EqualsAndHashCode(callSuper = false)
public class AdamUserBusiAcct implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(value = "mid", type = IdType.AUTO)
private Long mid;
private String uid;
/**
* 业务服务平台
*/
private String busi;
/**
* 业务服务ID
*/
private String uuid;
/**
* 业务服务模块
*/
private String work;
/**
* 业务服务密码
*/
private String ppwd;
/**
* 1-NORMAL,2-INVALID
*/
private Integer state;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private String comment;
}
liquidnet-bus-do/liquidnet-service-goblin-do/src/main/java/com/liquidnet/service/goblin/mapper/AdamUserBusiAcctMapper.java deleted 100644 → 0
View file @ 267f1ac4
package com.liquidnet.service.goblin.mapper;
import com.liquidnet.service.goblin.entity.AdamUserBusiAcct;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* <p>
* 用户业务服务账号表 Mapper 接口
* </p>
*
* @author liquidnet
* @since 2021-09-17
*/
public interface AdamUserBusiAcctMapper extends BaseMapper<AdamUserBusiAcct> {
}
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/controller/GoblinNFTUserController.java
View file @ 1d62a79e
package com.liquidnet.service.goblin.controller; package com.liquidnet.service.goblin.controller;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import com.liquidnet.common.exception.LiquidnetServiceException;
import com.liquidnet.commons.lang.constant.LnsRegex;
import com.liquidnet.commons.lang.util.CurrentUtil; 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.base.ResponseDto;
import com.liquidnet.service.goblin.dto.vo.AdamUserBizAcctVo;
import com.liquidnet.service.goblin.service.IGoblinNftUserService;
import com.liquidnet.service.goblin.util.GoblinRedisUtils; import com.liquidnet.service.goblin.util.GoblinRedisUtils;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -26,47 +18,47 @@ import javax.validation.constraints.Pattern; ...@@ -26,47 +18,47 @@ import javax.validation.constraints.Pattern;
@RequestMapping("user") @RequestMapping("user")
public class GoblinNFTUserController { public class GoblinNFTUserController {
@Autowired // @Autowired
IGoblinNftUserService goblinNftUserService; // IGoblinNftUserService goblinNftUserService;
@Autowired @Autowired
GoblinRedisUtils goblinRedisUtils; GoblinRedisUtils goblinRedisUtils;
@ApiOperationSupport(order = 11) // @ApiOperationSupport(order = 11)
@ApiOperation(value = "业务账号开通") // @ApiOperation(value = "业务账号开通")
@ApiImplicitParams({ // @ApiImplicitParams({
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "bizCode", value = "业务码[NFT_ZX]", allowableValues = "NFT_ZX"), // @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "bizCode", value = "业务码[NFT_ZX]", allowableValues = "NFT_ZX"),
@ApiImplicitParam(type = "form", required = false, dataType = "String", name = "name", value = "姓名"), // @ApiImplicitParam(type = "form", required = false, dataType = "String", name = "name", value = "姓名"),
@ApiImplicitParam(type = "form", required = false, dataType = "String", name = "idCard", value = "身份证号"), // @ApiImplicitParam(type = "form", required = false, dataType = "String", name = "idCard", value = "身份证号"),
}) // })
@PostMapping(value = "open/account") // @PostMapping(value = "open/account")
public ResponseDto<AdamUserBizAcctVo> openAccount(@Pattern(regexp = "\\b(NFT_ZX)\\b", message = "业务码无效") // public ResponseDto<AdamUserBizAcctVo> openAccount(@Pattern(regexp = "\\b(NFT_ZX)\\b", message = "业务码无效")
@RequestParam String bizCode, // @RequestParam String bizCode,
@RequestParam(required = false) String name, // @RequestParam(required = false) String name,
@RequestParam(required = false) String idCard) { // @RequestParam(required = false) String idCard) {
if (!java.util.regex.Pattern.matches(LnsRegex.Valid.CN_HANZI, name)) { // if (!java.util.regex.Pattern.matches(LnsRegex.Valid.CN_HANZI, name)) {
return ResponseDto.failure(ErrorMapping.get("10103")); // return ResponseDto.failure(ErrorMapping.get("10103"));
} // }
if (!java.util.regex.Pattern.matches(LnsRegex.Valid.CN_ID_CARD_REF, idCard)) { // if (!java.util.regex.Pattern.matches(LnsRegex.Valid.CN_ID_CARD_REF, idCard)) {
return ResponseDto.failure(ErrorMapping.get("10104")); // return ResponseDto.failure(ErrorMapping.get("10104"));
} // }
if (IDCardUtil.getAge(idCard) < 18) { // if (IDCardUtil.getAge(idCard) < 18) {
return ResponseDto.failure(ErrorMapping.get("10100")); // return ResponseDto.failure(ErrorMapping.get("10100"));
} // }
//
String currentUid = CurrentUtil.getCurrentUid(); // String currentUid = CurrentUtil.getCurrentUid();
String mobile = (String) CurrentUtil.getTokenClaims().get(CurrentUtil.TOKEN_MOBILE); // String mobile = (String) CurrentUtil.getTokenClaims().get(CurrentUtil.TOKEN_MOBILE);
try { // try {
ResponseDto<AdamUserBizAcctVo> vo = goblinNftUserService.openNftAccount(currentUid, bizCode, name, idCard, mobile); // ResponseDto<AdamUserBizAcctVo> vo = goblinNftUserService.openNftAccount(currentUid, bizCode, name, idCard, mobile);
goblinRedisUtils.setNftNumAccount(currentUid); // goblinRedisUtils.setNftNumAccount(currentUid);
return vo; // return vo;
} catch (Exception e) { // } catch (Exception e) {
if (e instanceof LiquidnetServiceException) { // if (e instanceof LiquidnetServiceException) {
LiquidnetServiceException lsEx = (LiquidnetServiceException) e; // LiquidnetServiceException lsEx = (LiquidnetServiceException) e;
return ResponseDto.failure(lsEx.getCode(), lsEx.getMessage()); // return ResponseDto.failure(lsEx.getCode(), lsEx.getMessage());
} // }
return ResponseDto.failure(ErrorMapping.get("10113")); // return ResponseDto.failure(ErrorMapping.get("10113"));
} // }
} // }
@ApiOperationSupport(order = 11) @ApiOperationSupport(order = 11)
@ApiOperation(value = "业务账号是否开通") @ApiOperation(value = "业务账号是否开通")
......
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinNftUserServiceImpl.java deleted 100644 → 0
View file @ 267f1ac4
package com.liquidnet.service.goblin.service.impl;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.goblin.dto.vo.AdamUserBizAcctVo;
import com.liquidnet.service.goblin.service.IGoblinNftUserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
@Slf4j
@Service
public class GoblinNftUserServiceImpl implements IGoblinNftUserService {
@Override
public ResponseDto<AdamUserBizAcctVo> openNftAccount(String uid, String bizCode, String name, String idCard, String mobile) {
// 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());
// }
//
// if (AdamEnum.BizAcct.NFT_ZX.name().equals(bizCode)) {
// boolean inputNameIdCardInvalidFlg = StringUtils.isBlank(name) || name.contains("*") || StringUtils.isBlank(idCard) || idCard.contains("*");
// AdamRealInfoVo realInfoVo = adamRdmService.getRealInfoVoByUidPlain(uid);
// if (null != realInfoVo) {// 账号已实名
// if (realInfoVo.getNode() == 2) {// 二要素认证的
// if (inputNameIdCardInvalidFlg) {
// name = realInfoVo.getName();
// idCard = realInfoVo.getIdCard();
//
// if (IDCardUtil.getAge(idCard) < 18) {
// return ResponseDto.failure(ErrorMapping.get("10100"));
// }
// }
// adamUserService.identityForUpsert(uid, name, idCard, mobile, true);
// } else {// 三要素认证的
// name = realInfoVo.getName();
// idCard = realInfoVo.getIdCard();
// }
// } else {// 账号未实名
// if (inputNameIdCardInvalidFlg) {
// return ResponseDto.failure(ErrorMapping.get("10101"));
// }
// adamUserService.identityForUpsert(uid, name, idCard, mobile, false);
// }
//
// ResponseDto<AdamUserBizAcctVo> responseDto = this.openAccountForNftZXin(uid, name, idCard, mobile);
// if (responseDto.isSuccess()) {
// 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())
// );
//
// 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;
// }
// log.warn("#开通业务账号:无效的业务码[UID={},bizCode={}]", bizCode, uid);
return ResponseDto.failure();
}
}
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