package org.example.ssmico.demos.web.service.impl;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.google.gson.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.example.ssmico.demos.web.dto.ResultDataListDto;
|
import org.example.ssmico.demos.web.dto.ResultListDto;
|
import org.example.ssmico.demos.web.util.RsaSigner;
|
import org.example.ssmico.demos.web.util.GoogleTranslateUtil;
|
import org.example.ssmico.demos.web.vo.WithdrawDepositVo;
|
import org.example.ssmico.demos.web.dto.AddressListDto;
|
import org.example.ssmico.demos.web.dto.ResultDto;
|
import org.example.ssmico.demos.web.service.UserPayService;
|
import org.example.ssmico.demos.web.util.ResultObject;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import java.security.InvalidKeyException;
|
import java.security.NoSuchAlgorithmException;
|
import java.security.SignatureException;
|
import java.security.spec.InvalidKeySpecException;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
import java.util.stream.Stream;
|
|
@Slf4j
|
@Service
|
public class UserPayServiceImpl implements UserPayService {
|
|
@Value("${HB_PRIKEY}")
|
private String priKey;
|
|
@Value("${HB_PUBKEY}")
|
private String pubKey;
|
|
@Value("${HB_BASEURL}")
|
private String baseUrl;
|
|
@Value("${HB_APP_ID}")
|
private String appId;
|
|
/**
|
* 获取地址
|
* @return
|
* @throws NoSuchAlgorithmException
|
* @throws InvalidKeySpecException
|
* @throws SignatureException
|
* @throws InvalidKeyException
|
*/
|
@Override
|
public ResultDto getAddressList(String coin) throws NoSuchAlgorithmException, InvalidKeySpecException, SignatureException, InvalidKeyException {
|
|
RsaSigner signer = new RsaSigner();
|
ResultDto resultDto = new ResultDto();
|
Map<String, Object> params = new HashMap<>();
|
params.put("app_id", appId);
|
params.put("version", "1.0");
|
params.put("key_version", "admin");
|
params.put("time", Long.toString(System.currentTimeMillis() / 1000));
|
params.put("coin", coin);
|
|
|
|
try {
|
String sign = signer.genSign(params, priKey);
|
params.put("sign", sign);
|
System.out.println("prikey="+priKey);
|
Gson gson = new GsonBuilder().create();
|
System.out.println("params = " + gson.toJson(params));
|
String url = baseUrl + "/address/getBatch";
|
System.out.println("请求地址:"+url);
|
String res = signer.doPost(url, gson.toJson(params));
|
log.info("---获取地址结果--->"+res);
|
if (StringUtils.isBlank(res)) {
|
log.error("获取火币地址错误，结果集为空");
|
}else{
|
resultDto = JSONUtil.toBean(res, ResultDto.class);
|
}
|
log.info("获取火币地址返回结果:{}", resultDto);
|
} catch (Exception e) {
|
log.error("获取火币地址错误: {}", e.getMessage());
|
throw e;
|
}
|
return resultDto;
|
}
|
|
/**
|
* 地址状态同步
|
* @param userId
|
* @param address
|
* @return
|
*/
|
public ResultDto syncStatus(String coin,String userId,String address){
|
ResultDto resultDto = new ResultDto();
|
RsaSigner signer = new RsaSigner();
|
Map<String, Object> params = new HashMap<>();
|
params.put("app_id", appId);
|
params.put("version", "1.0");
|
params.put("key_version", "admin");
|
params.put("time", Long.toString(System.currentTimeMillis() / 1000));
|
params.put("coin", coin);
|
params.put("address", address);
|
params.put("user_id", userId);
|
|
try {
|
|
params.put("sign", signer.genSign(params, priKey));
|
|
Gson gson = new GsonBuilder().create();
|
System.out.println("params = " + gson.toJson(params));
|
|
String res = signer.doPost( baseUrl + "/address/syncStatus", gson.toJson(params));
|
if (null == res) {
|
throw new RuntimeException("支付地址绑定失败");
|
}
|
List<String> list = new ArrayList<>();
|
list.add(address);
|
resultDto = JSONUtil.toBean(res, ResultDto.class);
|
resultDto.setData(list);
|
log.info("用户匹配地址返回结果:{}", resultDto.toString());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return resultDto;
|
}
|
//
|
// public static void main(String[] args) {
|
// String priKey="MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQDNZrCLnuGZTJ++4eyc4tEGrub6GjVj3w5Hg3n8ROdeJAj1SJmuPwZl3egonJPp9kh80MJL5dshuN7lMTti1CuLb8Qt7MW8aqORYqBytx2tMr9JZwA1bh3ZQ5IPszKPw/Vt5OO5+3iWy9VhqrzrXXHuoX1eB4X2z3KmtIBQB7Mz+8DCGDOv5KqY2kuqU8qXdTDOUWZwUeevU2bHh5UtIeUztlVZhH4o3DJUC1+CTz9uSiQ73YEa97vn+Mafz/rpNG7uCzLf5kKro0RfFyuiVPcwULo3TuWVeEGj3V9H4PDmI/oOa7B6BQpKkIb7u/9BBMRJQcz9gLt+PWF4zAddDOwJAgMBAAECggEAWg/s2UuRH+a5JLlrRl8tyABoxsE3J9NmL3U2x6ZuzJiAVQzAVebMp13lrej58lxK7G+cwirHKsIk+dnccDkX3svi+UAYc8VOczELqUEhgg/+T/EZ5lOiQuGd6cRpJyCFPOpf7+yTs4ssxOZYb9tJWZj1n4Us+Et9uhrrKCw4J1IyaHwyMOYh2w57vkeaa8ktLQSjPLeXgTL9kJXN9l7yJsl4dCnWFsOcH48+qtplzT5/JlB6R9vgvZDiR9Xi6ld1ImZfLYvq4AqWVU4p7JOL2b/Z7hNAuRCt/8he6KfJ94UemjHct8yL27xeFK6UXQfPqKAX6nqf+KncX5hiHlalAQKBgQD1H3j5UAs/HVdSwq4OL72hzCwKp5sXMs/23LM1elh7Cya7v7L4bPYkxaLF0BNB4IgmBT4KsBjhXRxguoZExG+PX/6ATSWZXO2rePRQti1ueoZETDihfqiRqNYO/SfKlxLTDHP4CWTV5Xt5fRz9Xxei7CJ0x3+4PEVjzrUFN4XOJwKBgQDWg/0Q6+QV8tBPdHIzrhlnL1CLqkHAlhOyl/wDOYN+ogsLpzJbiX74t6TEgrAnZGIYrsldHSHFOFD/DCDZfcNz2aKibnLnEBYKE2xpgiDCdmY5EphqLgha4XUUjxUQXS++Y+NGm5cMsfrhcNMYldg040D6nHeDFfqnfJPbdWoCTwKBgQDtjIqYUlIT4EN4GOLFLM8BtfQYf0V1vfB8tHWYJfEJjU0ENksjJbWE/WM5gOSouwg2kG4HvZDfFnUh6KGmkxfqQoVJoXoGnmBWBOoALgzpPCRSm+tl1nFWd+C6teuSEcZUcYURo0jtYW+/1Nf7U+R8J4tc0NmdmgtFJlWXsK8jkQKBgQDTmIwWleh9Me8CgOVpTtEl9AjqSz3ifubdIofmkmO/lI16qCjHHCBPq63uXM7vfFg66qYbn/HAvSU//zGj9ybFbqa6vGHAxCBJPhGRHVe9GdcJcus+yTtakcvQRLbNVm4SyirUagMb9a93krfXJ2+F86gTzCUi+5osfXjHX9D6hwKBgFvl9pDYX8pDeXGIvpcN7f9lzk0aWQJiAm0rVgfsvn+3ovXD2L0kGkiJNqubGfkcM++aLIZZ6mYZs4Xv1VHiLO8pnbUYTNsuRYiuJzanrZpmnYajBx8CdyRFl5Y4fLsgO8b0GWMJEuTKaf54NtdiEmdLEnK5CmJlXQBx04YL+W4O";
|
// String HB_PUBKEY="MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4N5eqJktuOjTweTlllS3b8h5v2usp4hIevyoVpZCKFF4yqN+1MPRnjLS6Du+rhnjiv382MxnrebaZasNkeNo1X2+QfScyLu+994v8GzdQ7u5n8FVJoZkQR9lvC+a9DuJ61KCuY08vQdCuaMh0FeCxyF5Rk3yvx6H6K9zGJGXMbo2cJUofqktcHVoova009lzYJHLh2Pwk0o2hgp/9Nir6ZkXjYxw1upqKJA8lsgIFDvsefXWo7D50mzm/3BvVfus0d2fu+scS7CmeRgSuMxpfhmhlLGJ5GtAnsJ/3amMcp/X8tcRCLmRzGx758Hsb+2/zEKbjR7a6EVNdct8u5ELnwIDAQAB";
|
// String baseUrl="https://apitest.hyperbc.pro/shopapi";
|
// String appId="skktesi4demjjm6m";
|
// String coin = "trx";
|
// String address = "TNJd5mA41rrJn2gGELpQtVLRFjnTdjcFNh";
|
// ResultObject resultObject = new ResultObject();
|
// RsaSigner signer = new RsaSigner();
|
// Map<String, Object> params = new HashMap<>();
|
// params.put("app_id", appId);
|
// params.put("version", "1.0");
|
// params.put("key_version", "admin");
|
// params.put("time", Long.toString(System.currentTimeMillis() / 1000));
|
// params.put("coin", coin);
|
// if(!StringUtils.isBlank(address)){
|
// params.put("address", address);
|
// }
|
// params.put("page", "1");
|
// params.put("is_used", "1");
|
//
|
// try {
|
//
|
// params.put("sign", signer.genSign(params, priKey));
|
//
|
// Gson gson = new GsonBuilder().create();
|
// System.out.println("params = " + gson.toJson(params));
|
// ObjectMapper objectMapper = new ObjectMapper();
|
// String res = signer.doPost(baseUrl + "/address/list", gson.toJson(params));
|
// if (null == res) {
|
// throw new RuntimeException("http error");
|
// }
|
// AddressListDto addressListDto = objectMapper.readValue(res, AddressListDto.class);
|
// if(addressListDto.getStatus() != 200){
|
// resultObject.setCode("1");
|
// resultObject.setMsg(addressListDto.getMsg());
|
// }
|
// if(null != addressListDto.getData() && addressListDto.getData().getCount() > 0 && null != addressListDto.getData().getList()){
|
// if(null != addressListDto.getData().getList().get(0)){
|
// resultObject.setData(addressListDto.getData().getList().get(0));
|
// }
|
// }
|
// log.info("查询地址绑定状态返回结果:{}", addressListDto.toString());
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// }
|
|
/**
|
* 查询地址绑定状态
|
* @param userId
|
* @param address
|
* @return
|
*/
|
public ResultObject getBindingState(String coin,String address) {
|
ResultObject resultObject = new ResultObject();
|
RsaSigner signer = new RsaSigner();
|
Map<String, Object> params = new HashMap<>();
|
params.put("app_id", appId);
|
params.put("version", "1.0");
|
params.put("key_version", "admin");
|
params.put("time", Long.toString(System.currentTimeMillis() / 1000));
|
params.put("coin", coin);
|
if(!StringUtils.isBlank(address)){
|
params.put("address", address);
|
}
|
params.put("page", "1");
|
params.put("is_used", "1");
|
|
try {
|
|
params.put("sign", signer.genSign(params, priKey));
|
|
Gson gson = new GsonBuilder().create();
|
System.out.println("params = " + gson.toJson(params));
|
ObjectMapper objectMapper = new ObjectMapper();
|
String res = signer.doPost(baseUrl + "/address/list", gson.toJson(params));
|
System.out.println("-----获取地址返回参数："+res.toString());
|
if (null == res) {
|
throw new RuntimeException("http error");
|
}
|
AddressListDto addressListDto = objectMapper.readValue(res, AddressListDto.class);
|
if(addressListDto.getStatus() != 200){
|
resultObject.setCode("1");
|
resultObject.setMsg(addressListDto.getMsg());
|
}
|
if(null != addressListDto.getData() && addressListDto.getData().getCount() > 0 && null != addressListDto.getData().getList()){
|
if(null != addressListDto.getData().getList().get(0)){
|
resultObject.setData(addressListDto.getData().getList().get(0));
|
}
|
}
|
log.info("查询地址绑定状态返回结果:{}", addressListDto.toString());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return resultObject;
|
}
|
|
public List getBindingState(String coin) {
|
ResultObject resultObject = new ResultObject();
|
RsaSigner signer = new RsaSigner();
|
Map<String, Object> params = new HashMap<>();
|
params.put("app_id", appId);
|
params.put("version", "1.0");
|
params.put("key_version", "admin");
|
params.put("time", Long.toString(System.currentTimeMillis() / 1000));
|
params.put("coin", coin);
|
params.put("page", "1");
|
params.put("is_used", "2");
|
|
try {
|
|
params.put("sign", signer.genSign(params, priKey));
|
|
Gson gson = new GsonBuilder().create();
|
System.out.println("params = " + gson.toJson(params));
|
ObjectMapper objectMapper = new ObjectMapper();
|
String res = signer.doPost(baseUrl + "/address/list", gson.toJson(params));
|
log.info("查询未使用地址结果:{}", res.toString());
|
if (null == res) {
|
return new ArrayList<String>();
|
}
|
ResultListDto resultDto = JSONUtil.toBean(res, ResultListDto.class);
|
if (null == resultDto) {
|
return new ArrayList<String>();
|
}
|
if(CollectionUtils.isEmpty(resultDto.getData().getList())){
|
return new ArrayList<String>();
|
}
|
List<String> list = resultDto.getData().getList()
|
.stream().filter(f -> StringUtils.isBlank(f.getUser_id())).map(ResultDataListDto::getAddress).collect(Collectors.toList());
|
System.out.println("response = " + list);
|
log.info("查询未使用地址:{}", list.toString());
|
return list;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return new ArrayList<String>();
|
}
|
|
@Override
|
public ResultObject withdrawDeposit(WithdrawDepositVo vo) {
|
ResultObject resultObject = new ResultObject();
|
RsaSigner signer = new RsaSigner();
|
|
Map<String, Object> params = new HashMap<>();
|
params.put("app_id", appId);
|
params.put("version", "1.0");
|
params.put("key_version", "admin");
|
params.put("time", Long.toString(System.currentTimeMillis() / 1000));
|
params.put("user_id", vo.getUserId());
|
params.put("coin", "eth");
|
params.put("address", vo.getAddress());
|
params.put("amount", vo.getAmount());
|
params.put("trade_id", vo.getTradeId());
|
|
try {
|
|
params.put("sign", signer.genSign(params, priKey));
|
|
Gson gson = new GsonBuilder().create();
|
System.out.println("params = " + gson.toJson(params));
|
|
String res = signer.doPost(baseUrl + "/transfer", gson.toJson(params));
|
if (null == res) {
|
throw new RuntimeException("http error");
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return resultObject;
|
}
|
|
@Override
|
public ResultObject getUserRechargeAddress(String s,String userId,String lang) throws Exception {
|
ResultObject resultObject = new ResultObject();
|
GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();
|
String address = "";
|
try {
|
//查询地址
|
ResultDto resultDto = getAddressList(s);
|
System.out.println("获取地址-->"+resultDto.toString());
|
if(resultDto.getStatus() == 200 && null != resultDto.getData() && !resultDto.getData().isEmpty()){
|
address = resultDto.getData().get(0);
|
}
|
if(resultDto.getStatus() == 500){
|
resultObject.setCode("1");
|
resultObject.setMsg("地址不足");
|
return resultObject;
|
}
|
if(resultDto.getStatus() == 551){//已分配未使用
|
List<String> list = getAddressUnusedList(s);
|
if(CollectionUtils.isEmpty(list)){
|
resultObject.setCode("1");
|
resultObject.setMsg("没有可用地址");
|
return resultObject;
|
}
|
address = list.get(0);
|
}
|
//地址状态同步
|
ResultDto result = syncStatus(s,userId,address);
|
if(result.getStatus() == 525){
|
//查询用户有没有分配地址
|
ResultObject bindingState = getBindingState(s,null);
|
if(!bindingState.getCode().equals("0")){
|
return bindingState;
|
}
|
Map<String, Object> map = BeanUtil.beanToMap(bindingState.getData(), new HashMap<>(), false, true);
|
resultObject.setData(map.get("address"));
|
return resultObject;
|
}
|
resultObject.setData(result.getData().get(0));
|
} catch (Exception e) {
|
e.printStackTrace();
|
resultObject.setCode("1");
|
resultObject.setMsg(googleTranslateUtil.translate("获取火币地址出错", lang));
|
}
|
return resultObject;
|
}
|
|
@Override
|
public List<String> getAddressUnusedList(String coin) {
|
return getBindingState(coin);
|
}
|
}
|
