package com.yami.trading.huobi.websocket.service.huobi;
|
|
import java.util.List;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.yami.trading.huobi.websocket.client.SubUserClient;
|
import com.yami.trading.huobi.websocket.client.req.account.TransferSubuserRequest;
|
import com.yami.trading.huobi.websocket.client.req.subuser.*;
|
import com.yami.trading.huobi.websocket.constant.Options;
|
import com.yami.trading.huobi.websocket.model.account.AccountBalance;
|
import com.yami.trading.huobi.websocket.model.account.SubuserAggregateBalance;
|
import com.yami.trading.huobi.websocket.model.subuser.GetApiKeyListResult;
|
import com.yami.trading.huobi.websocket.model.subuser.GetSubUserAccountListResult;
|
import com.yami.trading.huobi.websocket.model.subuser.GetSubUserDepositResult;
|
import com.yami.trading.huobi.websocket.model.subuser.GetSubUserListResult;
|
import com.yami.trading.huobi.websocket.model.subuser.SubUserApiKeyGenerationResult;
|
import com.yami.trading.huobi.websocket.model.subuser.SubUserApiKeyModificationResult;
|
import com.yami.trading.huobi.websocket.model.subuser.SubUserCreationInfo;
|
import com.yami.trading.huobi.websocket.model.subuser.SubUserManagementResult;
|
import com.yami.trading.huobi.websocket.model.subuser.SubUserState;
|
import com.yami.trading.huobi.websocket.model.subuser.SubUserTradableMarketResult;
|
import com.yami.trading.huobi.websocket.model.subuser.SubUserTransferabilityResult;
|
import com.yami.trading.huobi.websocket.model.wallet.DeductModeResult;
|
import com.yami.trading.huobi.websocket.model.wallet.DepositAddress;
|
import com.yami.trading.huobi.websocket.service.huobi.connection.HuobiRestConnection;
|
import com.yami.trading.huobi.websocket.service.huobi.connection.HuobiRestConnection25519;
|
import com.yami.trading.huobi.websocket.service.huobi.parser.account.AccountBalanceParser;
|
import com.yami.trading.huobi.websocket.service.huobi.parser.account.SubuserAggregateBalanceParser;
|
import com.yami.trading.huobi.websocket.service.huobi.parser.subuser.*;
|
import com.yami.trading.huobi.websocket.service.huobi.parser.wallet.DepositAddressParser;
|
import com.yami.trading.huobi.websocket.service.huobi.signature.UrlParamsBuilder;
|
import com.yami.trading.huobi.websocket.utils.InputChecker;
|
|
public class HuobiSubUserService implements SubUserClient {
|
|
public static final String GET_SUBUSER_ACCOUNT_BALANCE_PATH = "/v1/account/accounts/{sub-uid}";//子用户余额
|
public static final String GET_SUBUSER_AGGREGATE_BALANCE_PATH = "/v1/subuser/aggregate-balance";//子用户余额（汇总）
|
public static final String TRANSFER_SUBUSER_PATH = "/v1/subuser/transfer";//资产划转（母子用户之间）
|
public static final String SUBUSER_CREATION_PATH = "/v2/sub-user/creation";//子用户创建
|
public static final String GET_SUBUSER_LIST_PATH = "/v2/sub-user/user-list";//获取子用户列表
|
public static final String GET_SUBUSER_STATE_PATH = "/v2/sub-user/user-state";//获取特定子用户的用户状态
|
public static final String SUBUSER_MANAGEMENT_PATH = "/v2/sub-user/management";//冻结/解冻子用户
|
public static final String GET_SUBUSER_ACCOUNT_LIST_PATH = "/v2/sub-user/account-list";//获取特定子用户的账户列表
|
public static final String SUBUSER_TRANSFERABILITY_PATH = "/v2/sub-user/transferability";//设置子用户资产转出权限
|
public static final String SUBUSER_TRADABLE_MARKET_PATH = "/v2/sub-user/tradable-market";//设置子用户交易权限
|
public static final String SUBUSER_APIKEY_GENERATION_PATH = "/v2/sub-user/api-key-generation";//子用户APIkey创建
|
public static final String SUBUSER_APIKEY_MODIFICATION_PATH = "/v2/sub-user/api-key-modification";//修改子用户APIkey
|
public static final String SUBUSER_APIKEY_DELETION_PATH = "/v2/sub-user/api-key-deletion";//删除子用户APIkey
|
public static final String GET_SUBUSER_APIKEY_PATH = "/v2/user/api-key";//母子用户APIkey信息查询
|
public static final String GET_SUBUSER_DEPOSIT_ADDRESS_PATH = "/v2/sub-user/deposit-address";//子用户充币地址查询
|
public static final String GET_SUBUSER_DEPOSIT_PATH = "/v2/sub-user/query-deposit";//子用户充币记录查询
|
public static final String GET_UID_PATH = "/v2/user/uid";//母子用户获取用户UID
|
public static final String SET_DDEDUCT_MODE_PATH = "/v2/sub-user/deduct-mode";//设置子用户手续费抵扣模式
|
public static final String SET_CREDIT_PATH = "/v1/trust/user/active/credit";//用户主动授信
|
|
|
private Options options;
|
|
private HuobiRestConnection restConnection;
|
|
public HuobiSubUserService(Options options) {
|
this.options = options;
|
if(options.getSign().equals("256")){
|
this.restConnection = new HuobiRestConnection(options);
|
}else if(options.getSign().equals("25519")){
|
this.restConnection = new HuobiRestConnection25519(options);
|
}
|
}
|
|
@Override
|
public List<SubUserCreationInfo> subuserCreation(SubUserCreationRequest request) {
|
|
InputChecker checker = InputChecker.checker().checkList(request.getUserList(), 1, 50, "userList");
|
request.getUserList().forEach(param -> {
|
checker.shouldNotNull(param.getUserName(), "userName");
|
});
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("userList", request.getUserList());
|
|
JSONObject jsonObject = restConnection.executePostWithSignature(SUBUSER_CREATION_PATH, builder);
|
JSONArray jsonArray = jsonObject.getJSONArray("data");
|
return new SubUserCreationInfoParser().parseArray(jsonArray);
|
}
|
|
@Override
|
public GetSubUserListResult getSubUserList(GetSubUserListRequest request) {
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToUrl("fromId", request.getFromId());
|
|
JSONObject jsonObject = restConnection.executeGetWithSignature(GET_SUBUSER_LIST_PATH, builder);
|
return new GetSubUserListResultParser().parse(jsonObject);
|
}
|
|
public SubUserState getSubuserState(Long subUid) {
|
|
InputChecker.checker().shouldNotNull(subUid, "subUid");
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToUrl("subUid", subUid);
|
|
JSONObject jsonObject = restConnection.executeGetWithSignature(GET_SUBUSER_STATE_PATH, builder);
|
JSONObject data = jsonObject.getJSONObject("data");
|
return new SubUserStateParser().parse(data);
|
}
|
|
public SubUserManagementResult subuserManagement(SubUserManagementRequest request) {
|
|
InputChecker.checker()
|
.shouldNotNull(request.getSubUid(), "subUid")
|
.shouldNotNull(request.getAction(), "action");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("subUid", request.getSubUid())
|
.putToPost("action", request.getAction().getAction());
|
|
JSONObject jsonObject = restConnection.executePostWithSignature(SUBUSER_MANAGEMENT_PATH, builder);
|
JSONObject data = jsonObject.getJSONObject("data");
|
return new SubUserManagementResultParser().parse(data);
|
}
|
|
public GetSubUserAccountListResult getSubuserAccountList(GetSubUserAccountListRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getSubUid(), "subUid");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToUrl("subUid", request.getSubUid());
|
|
JSONObject jsonObject = restConnection.executeGetWithSignature(GET_SUBUSER_ACCOUNT_LIST_PATH, builder);
|
JSONObject data = jsonObject.getJSONObject("data");
|
return new GetSubUserAccountListResultParser().parse(data);
|
}
|
|
public SubUserTransferabilityResult subuserTransferability(SubUserTransferabilityRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getSubUids(), "subUids")
|
.shouldNotNull(request.getTransferrable(), "transferrable");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("subUids", request.getSubUids())
|
.putToPost("accountType", request.getAccountType().getAccountType())
|
.putToPost("transferrable", request.getTransferrable());
|
|
JSONObject jsonObject = restConnection.executePostWithSignature(SUBUSER_TRANSFERABILITY_PATH, builder);
|
return new SubUserTransferabilityResultParser().parse(jsonObject);
|
}
|
|
public SubUserTradableMarketResult subuserTradableMarket(SubUserTradableMarketRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getSubUids(), "subUids")
|
.shouldNotNull(request.getAccountType(), "accountType")
|
.shouldNotNull(request.getActivation(), "activation");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("subUids", request.getSubUids())
|
.putToPost("accountType", request.getAccountType().getAccountType())
|
.putToPost("activation", request.getActivation().getActivation());
|
|
JSONObject jsonObject = restConnection.executePostWithSignature(SUBUSER_TRADABLE_MARKET_PATH, builder);
|
return new SubUserTradableMarketResultParser().parse(jsonObject);
|
}
|
|
public SubUserApiKeyGenerationResult subuserApiKeyGeneration(SubUserApiKeyGenerationRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getOtpToken(), "otpToken")
|
.shouldNotNull(request.getSubUid(), "subUid")
|
.shouldNotNull(request.getNote(), "note")
|
.shouldNotNull(request.getPermission(), "permission");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("otpToken", request.getOtpToken())
|
.putToPost("subUid", request.getSubUid())
|
.putToPost("note", request.getNote())
|
.putToPost("permission", request.getPermission())
|
.putToPost("ipAddresses", request.getIpAddresses());
|
|
JSONObject jsonObject = restConnection.executePostWithSignature(SUBUSER_APIKEY_GENERATION_PATH, builder);
|
JSONObject data = jsonObject.getJSONObject("data");
|
return new SubUserApiKeyGenerationResultParser().parse(data);
|
}
|
|
public SubUserApiKeyModificationResult subuserApiKeyModification(SubUserApiKeyModificationRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getAccessKey(), "accessKey")
|
.shouldNotNull(request.getSubUid(), "subUid");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("accessKey", request.getAccessKey())
|
.putToPost("subUid", request.getSubUid())
|
.putToPost("note", request.getNote())
|
.putToPost("permission", request.getPermission())
|
.putToPost("ipAddresses", request.getIpAddresses());
|
|
JSONObject jsonObject = restConnection.executePostWithSignature(SUBUSER_APIKEY_MODIFICATION_PATH, builder);
|
JSONObject data = jsonObject.getJSONObject("data");
|
return new SubUserApiKeyModificationResultParser().parse(data);
|
}
|
|
@Override
|
public void subuserApiKeyDeletion(SubUserApiKeyDeletionRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getAccessKey(), "accessKey")
|
.shouldNotNull(request.getSubUid(), "subUid");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("accessKey", request.getAccessKey())
|
.putToPost("subUid", request.getSubUid());
|
|
restConnection.executePostWithSignature(SUBUSER_APIKEY_DELETION_PATH, builder);
|
}
|
|
public GetApiKeyListResult getApiKeyList(GetApiKeyListRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getUid(), "uid");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToUrl("uid", request.getUid())
|
.putToUrl("accessKey", request.getAccessKey());
|
|
JSONObject jsonObject = restConnection.executeGetWithSignature(GET_SUBUSER_APIKEY_PATH, builder);
|
return new GetApiKeyListResultParser().parse(jsonObject);
|
}
|
|
@Override
|
public List<DepositAddress> getSubUserDepositAddress(Long subUid, String currency) {
|
|
InputChecker.checker()
|
.shouldNotNull(subUid, "subUid")
|
.checkCurrency(currency);
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToUrl("subUid", subUid)
|
.putToUrl("currency", currency);
|
|
JSONObject jsonObject = restConnection.executeGetWithSignature(GET_SUBUSER_DEPOSIT_ADDRESS_PATH, builder);
|
|
JSONArray array = jsonObject.getJSONArray("data");
|
return new DepositAddressParser().parseArray(array);
|
}
|
|
public GetSubUserDepositResult getSubUserDeposit(GetSubUserDepositRequest request) {
|
|
InputChecker.checker()
|
.shouldNotNull(request.getSubUid(), "subUid");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToUrl("subUid", request.getSubUid())
|
.putToUrl("currency", request.getCurrency())
|
.putToUrl("startTime", request.getStartTime())
|
.putToUrl("endTime", request.getEndTime())
|
.putToUrl("sort", request.getSort() == null ? null : request.getSort().getSort())
|
.putToUrl("limit", request.getLimit())
|
.putToUrl("fromId", request.getFromId());
|
|
JSONObject jsonObject = restConnection.executeGetWithSignature(GET_SUBUSER_DEPOSIT_PATH, builder);
|
return new GetSubUserDepositResultParser().parse(jsonObject);
|
}
|
|
@Override
|
public long transferSubuser(TransferSubuserRequest request) {
|
|
InputChecker.checker()
|
.shouldNotNull(request.getSubUid(), "sub-uid")
|
.shouldNotNull(request.getCurrency(), "currency")
|
.shouldNotNull(request.getAmount(), "amount")
|
.shouldNotNull(request.getType(), "type");
|
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("sub-uid", request.getSubUid())
|
.putToPost("currency", request.getCurrency())
|
.putToPost("amount", request.getAmount().toPlainString())
|
.putToPost("type", request.getType().getCode())
|
.putToPost("client-order-id", request.getClientOrderId());
|
|
JSONObject jsonObject = restConnection.executePostWithSignature(TRANSFER_SUBUSER_PATH, builder);
|
return jsonObject.getLong("data");
|
}
|
|
@Override
|
public List<AccountBalance> getSubuserAccountBalance(Long subuserId) {
|
|
InputChecker.checker()
|
.shouldNotNull(subuserId, "sub-uid");
|
|
String path = GET_SUBUSER_ACCOUNT_BALANCE_PATH.replace("{sub-uid}", subuserId + "");
|
JSONObject jsonObject = restConnection.executeGetWithSignature(path, UrlParamsBuilder.build());
|
JSONArray data = jsonObject.getJSONArray("data");
|
return new AccountBalanceParser().parseArray(data);
|
}
|
|
@Override
|
public List<SubuserAggregateBalance> getSubuserAggregateBalance() {
|
|
JSONObject jsonObject = restConnection.executeGetWithSignature(GET_SUBUSER_AGGREGATE_BALANCE_PATH, UrlParamsBuilder.build());
|
JSONArray data = jsonObject.getJSONArray("data");
|
return new SubuserAggregateBalanceParser().parseArray(data);
|
|
}
|
|
@Override
|
public List<DeductModeResult> setDeductMode(DeductModeRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getSubUids(), "subUids")
|
.shouldNotNull(request.getDeductMode(), "deductMode");
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("subUids", request.getSubUids())
|
.putToPost("deductMode", request.getDeductMode());
|
JSONObject jsonObject = restConnection.executePostWithSignature(SET_DDEDUCT_MODE_PATH, builder);
|
JSONArray data = jsonObject.getJSONArray("data");
|
return new DeductModeResultParser().parseArray(data);
|
}
|
|
@Override
|
public long getUid() {
|
JSONObject jsonObject = restConnection.executeGetWithSignature(GET_UID_PATH, UrlParamsBuilder.build());
|
long data = jsonObject.getLong("data");
|
return data;
|
}
|
|
@Override
|
public boolean setCredit(CreditRequest request) {
|
InputChecker.checker()
|
.shouldNotNull(request.getTransactionId(), "transactionId")
|
.shouldNotNull(request.getCurrency(), "currency")
|
.shouldNotNull(request.getAmount(), "amount")
|
.shouldNotNull(request.getAccountId(), "accountId")
|
.shouldNotNull(request.getUserId(), "userId");
|
UrlParamsBuilder builder = UrlParamsBuilder.build()
|
.putToPost("transactionId", request.getTransactionId())
|
.putToPost("currency", request.getCurrency())
|
.putToPost("amount", request.getAmount())
|
.putToPost("accountId", request.getAccountId())
|
.putToPost("userId", request.getUserId())
|
;
|
JSONObject jsonObject = restConnection.executePostWithSignature(SET_CREDIT_PATH, builder);
|
return jsonObject.getBoolean("data");
|
}
|
|
}
|
