增加xuper用户同步接口

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/galaxy/controller/GalaxyUserController.java

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