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

Commit 00474748 authored by anjiabin's avatar anjiabin

增加xuper用户同步接口

parent af43c227
...@@ -77,12 +77,12 @@ public class GalaxyUserController { ...@@ -77,12 +77,12 @@ public class GalaxyUserController {
@ApiOperationSupport(order = 2) @ApiOperationSupport(order = 2)
@ApiOperation(value = "NFT百度用户同步") @ApiOperation(value = "NFT百度用户同步")
@PostMapping(value = {"xuperUserSync"}) @PostMapping(value = {"xuperUserSync"})
public ResponseDto<Boolean> xuperUserSync(@Valid @RequestBody GalaxyUserRegisterReqDto reqDto) { public ResponseDto<String> xuperUserSync(@Valid @RequestBody GalaxyUserRegisterReqDto reqDto) {
//判断百度链用户是否已经存在 //判断百度链用户是否已经存在
GalaxyUserInfoBo xuperUserInfoBo = dataUtils.getGalaxyUserInfo(GalaxyEnum.RouterTypeEnum.XUPER.getCode(), reqDto.getUserId()); GalaxyUserInfoBo xuperUserInfoBo = dataUtils.getGalaxyUserInfo(GalaxyEnum.RouterTypeEnum.XUPER.getCode(), reqDto.getUserId());
if(StringUtil.isNotNull(xuperUserInfoBo)&&StringUtil.isNotEmpty(xuperUserInfoBo.getBlockChainAddress())){ if(StringUtil.isNotNull(xuperUserInfoBo)&&StringUtil.isNotEmpty(xuperUserInfoBo.getBlockChainAddress())){
log.error("NFT百度用户同步 error 该用户百度链用户已经开通成功无需再次开通 reqParam:{}", JsonUtils.toJson(reqDto)); log.error("NFT百度用户同步 error 该用户百度链用户已经开通成功无需再次开通 reqParam:{}", JsonUtils.toJson(reqDto));
return ResponseDto.success(true); return ResponseDto.success("已开通成功");
} }
//获取至信链用户开通信息 //获取至信链用户开通信息
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode(), reqDto.getUserId()); GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode(), reqDto.getUserId());
...@@ -98,7 +98,7 @@ public class GalaxyUserController { ...@@ -98,7 +98,7 @@ public class GalaxyUserController {
dataUtils.getQueueUtil().sendMsgByRedis(MQConst.GoblinQueue.SQL_STORE.getKey(), dataUtils.getQueueUtil().sendMsgByRedis(MQConst.GoblinQueue.SQL_STORE.getKey(),
SqlMapping.get("adam_user_busi_acct.add",sqlsDataA) SqlMapping.get("adam_user_busi_acct.add",sqlsDataA)
); );
return ResponseDto.failure("开通失败"); return ResponseDto.success("开通成功");
}; };
} }
log.error("NFT百度用户同步 error 该用户至信链数字账户未开通 reqParam:{}", JsonUtils.toJson(reqDto)); log.error("NFT百度用户同步 error 该用户至信链数字账户未开通 reqParam:{}", JsonUtils.toJson(reqDto));
......
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