package com.yami.trading.api.controller.exchange;
|
|
import cn.hutool.core.lang.Console;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.http.HttpStatus;
|
import cn.hutool.json.JSONUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.yami.trading.api.UD.*;
|
import com.yami.trading.api.UD.Address;
|
import com.yami.trading.bean.exchange.PartyBlockchain;
|
import com.yami.trading.bean.model.ChannelBlockchain;
|
import com.yami.trading.bean.model.RechargeBlockchainOrder;
|
import com.yami.trading.bean.model.User;
|
import com.yami.trading.bean.vo.RechargeAddressVo;
|
import com.yami.trading.common.constants.Constants;
|
import com.yami.trading.common.domain.Result;
|
import com.yami.trading.common.exception.YamiShopBindException;
|
import com.yami.trading.common.util.MD5;
|
import com.yami.trading.common.util.StringUtils;
|
import com.yami.trading.security.common.util.SecurityUtils;
|
import com.yami.trading.service.ChannelBlockchainService;
|
import com.yami.trading.service.RechargeBlockchainOrderService;
|
import com.yami.trading.service.exchange.PartyBlockchainService;
|
import com.yami.trading.service.syspara.SysparaService;
|
import com.yami.trading.service.user.UserService;
|
import com.yami.trading.sys.model.SysUser;
|
import com.yami.trading.sys.service.SysUserService;
|
import io.swagger.annotations.Api;
|
import lombok.extern.slf4j.Slf4j;
|
import okhttp3.*;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@RestController
|
@Slf4j
|
@Api(tags = "区块链 -api")
|
public class ApiChannelBlockchainController {
|
@Autowired
|
private SysparaService sysparaService;
|
private final String action = "/api/channelBlockchain!";
|
@Autowired
|
private ChannelBlockchainService channelBlockchainService;
|
private OkHttpClient okHttpClient = new OkHttpClient();
|
private final String threedUrl = "https://api.star-pay.vip/api/gateway/pay";
|
@Autowired
|
UserService userService;
|
@Autowired
|
PartyBlockchainService partyBlockchainService;
|
@Autowired
|
RedisTemplate redisTemplate;
|
@Autowired
|
private SysUserService sysUserService;
|
@Autowired
|
RechargeBlockchainOrderService rechargeBlockchainOrderService;
|
|
private final String gateway = "https://sig11.udun.io";
|
private final String merchantKey = "7fd79e4ed59e7c31e1fa2e13d64f7e6c";
|
private final String merchantId = "319563";
|
private final String defaultCallBackUrl = "https://openapi.yanshiz.com/api/channelBlockchain!rechargeCallback.action";
|
|
|
|
/**
|
* 获取所有链地址
|
*/
|
@RequestMapping(action + "list.action")
|
public Object list() throws IOException {
|
List<ChannelBlockchain> data = new ArrayList<ChannelBlockchain>();
|
ChannelBlockchain trc20 = new ChannelBlockchain();
|
trc20.setAddress("TLfgznQtWzZXFvodpuM3HFCzzDvxw5Rkub");
|
trc20.setBlockchainName("trc20");
|
trc20.setBlockchain_name("trc20");
|
trc20.setCoin("usdt");
|
data.add(trc20);
|
// String partyId = SecurityUtils.getUser().getUserId();
|
// User party = userService.getById(partyId);
|
// List<PartyBlockchain> list = partyBlockchainService.findByUserName(party.getUserName());
|
// if (null != list && !list.isEmpty()) {
|
// data = list.stream().map(dict -> {
|
// String qrImage = dict.getQrImage();
|
// String chainAddress = dict.getAddress();
|
// String chainName = dict.getChainName();
|
// String coinSymbol = dict.getCoinSymbol();
|
// String autoStr = dict.getAuto();
|
// boolean auto = autoStr.equals("Y") ? true : false;
|
// ChannelBlockchain cbc = new ChannelBlockchain();
|
// cbc.setBlockchainName(chainName);
|
// cbc.setBlockchain_name(chainName);
|
// cbc.setAddress(chainAddress);
|
// cbc.setCoin(coinSymbol);
|
// cbc.setAuto(auto);
|
// cbc.setImg(qrImage);
|
// return cbc;
|
// }).collect(Collectors.toList());
|
// }
|
// if (data.isEmpty()) data = channelBlockchainService.list();
|
// for (int i = 0; i < data.size(); i++) {
|
// data.get(i).setBlockchain_name(data.get(i).getBlockchainName());
|
// if (1 == this.sysparaService.find("can_recharge").getInteger()) {
|
// // 允许在线充值，展示二维码
|
// if (!StringUtils.isNullOrEmpty(data.get(i).getImg())) {
|
// String path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + data.get(i).getImg();
|
// data.get(i).setImg(path);
|
// }
|
// } else {
|
// data.get(i).setImg(null);
|
// data.get(i).setAddress(null);
|
// }
|
// }
|
return Result.succeed(data);
|
}
|
|
/**
|
* 根据币种获取链地址
|
*/
|
@GetMapping(action + "getBlockchainName.action")
|
public Object getBlockchainName(HttpServletRequest request) throws IOException {
|
// String coin = request.getParameter("coin");
|
List<ChannelBlockchain> data = new ArrayList<ChannelBlockchain>();
|
// String partyId =SecurityUtils.getUser().getUserId();
|
// User party = userService.getById(partyId);
|
// if (0 == this.sysparaService.find("can_recharge").getInteger()) {
|
// return Result.failed("请联系客服充值");
|
// }
|
|
// List<PartyBlockchain> list = partyBlockchainService.findByUserNameAndCoinSymbol(party.getUserName(), coin);
|
// if (null != list && !list.isEmpty()) {
|
// data = list.stream().map(dict -> {
|
// String qrImage = dict.getQrImage();
|
// String chainAddress = dict.getAddress();
|
// String chainName = dict.getChainName();
|
// String coinSymbol = dict.getCoinSymbol();
|
// String autoStr = dict.getAuto();
|
// boolean auto = autoStr.equals("Y") ? true : false;
|
// ChannelBlockchain cbc = new ChannelBlockchain();
|
// cbc.setBlockchain_name(chainName);
|
// cbc.setAddress(chainAddress);
|
// cbc.setCoin(coinSymbol);
|
// cbc.setAuto(auto);
|
// cbc.setImg(qrImage);
|
// return cbc;
|
// }).collect(Collectors.toList());
|
// }
|
//
|
// //后台设置地址
|
// if (data.isEmpty()) data = this.channelBlockchainService.findByCoin(coin.toLowerCase());
|
// for (int i = 0; i < data.size(); i++) {
|
// data.get(i).setBlockchain_name(data.get(i).getBlockchainName());
|
// if (1 == this.sysparaService.find("can_recharge").getInteger()) {
|
// if (!StringUtils.isNullOrEmpty(data.get(i).getImg())) {
|
// String path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + data.get(i).getImg();
|
// data.get(i).setImgStr("/public/showimg!showImg.action?imagePath=" + data.get(i).getImg());
|
// data.get(i).setImg(path);
|
// }
|
// } else {
|
// data.get(i).setImg(null);
|
// data.get(i).setImgStr(null);
|
// data.get(i).setAddress(null);
|
// }
|
// }
|
|
// String partyId =SecurityUtils.getUser().getUserId();
|
// if(!StringUtils.isNotEmpty(partyId)){
|
// throw new YamiShopBindException("请登录！");
|
// }
|
// if (0 == this.sysparaService.find("can_recharge").getInteger()) {
|
// return Result.failed("请联系客服充值");
|
// }
|
// RechargeAddressVo rechargeAddressVo = new RechargeAddressVo();
|
//
|
// //获取u盾地址
|
// //获取商户支持币种
|
// List<Coin> coinList = listSupportCoin(merchantId,false);
|
// //创建地址
|
// coinList.forEach(f->{
|
// Address address = new Address();
|
// if(f.getName().equals("BTC")){
|
// String ress = (String)redisTemplate.opsForValue().get(partyId + "BTC");
|
// if(StringUtils.isNotEmpty(ress)){
|
// rechargeAddressVo.setAddress(ress);
|
// rechargeAddressVo.setCoin(coin);
|
// rechargeAddressVo.setBlockchainName(coin);
|
// }else{
|
// address = createAddress(f.getMainCoinType(),null,null,null);
|
// rechargeAddressVo.setAddress(address.getAddress());
|
// rechargeAddressVo.setCoin(coin);
|
// rechargeAddressVo.setBlockchainName(coin);
|
// redisTemplate.opsForValue().set(partyId + "BTC",address.getAddress());
|
// }
|
// }else if(f.getName().equals("ETH")){
|
// String ress = (String)redisTemplate.opsForValue().get(partyId + "ETH");
|
// if(StringUtils.isNotEmpty(ress)){
|
// rechargeAddressVo.setAddress(ress);
|
// rechargeAddressVo.setCoin(coin);
|
// rechargeAddressVo.setBlockchainName(coin);
|
// }else{
|
// address = createAddress(f.getMainCoinType(),null,null,null);
|
// rechargeAddressVo.setAddress(address.getAddress());
|
// rechargeAddressVo.setCoin(coin);
|
// rechargeAddressVo.setBlockchainName(coin);
|
// redisTemplate.opsForValue().set(partyId + "ETH",address.getAddress());
|
// }
|
// }else if(f.getName().equals("USDT")){
|
// String ress = (String)redisTemplate.opsForValue().get(partyId + "USDT");
|
// if(StringUtils.isNotEmpty(ress)){
|
// rechargeAddressVo.setAddress(ress);
|
// rechargeAddressVo.setCoin(coin);
|
// rechargeAddressVo.setBlockchainName(coin);
|
// }else{
|
// address = createAddress(f.getMainCoinType(),null,null,null);
|
// rechargeAddressVo.setAddress(address.getAddress());
|
// rechargeAddressVo.setCoin(coin);
|
// rechargeAddressVo.setBlockchainName(coin);
|
// redisTemplate.opsForValue().set(partyId + "USDT",address.getAddress());
|
// }
|
// }
|
// });
|
// return Result.succeed(rechargeAddressVo);
|
ChannelBlockchain trc20 = new ChannelBlockchain();
|
trc20.setAddress("TLfgznQtWzZXFvodpuM3HFCzzDvxw5Rkub");
|
trc20.setBlockchainName("trc20");
|
trc20.setBlockchain_name("trc20");
|
trc20.setCoin("usdt");
|
data.add(trc20);
|
return Result.succeed(data);
|
}
|
|
public List<Coin> listSupportCoin(String merchantId , boolean showBalance) {
|
Map<String, Object> params = new HashMap<>();
|
params.put("merchantId", merchantId);
|
params.put("showBalance", showBalance);
|
ResultMsg result = JSONUtil.toBean(UdunUtils.post(gateway, merchantKey, ApiPath.SUPPORT_COIN, JSONUtil.toJsonStr(params)), ResultMsg.class);
|
if (result.getCode() != HttpStatus.HTTP_OK) {
|
Console.error(JSONUtil.toJsonStr(result));
|
return null;
|
}
|
return JSONUtil.toList(JSONUtil.parseArray(result.getData()), Coin.class);
|
}
|
|
public Address createAddress(String mainCoinType, String alias, String walletId, String callUrl) throws UdunException {
|
Map<String, String> params = new HashMap<>();
|
params.put("merchantId", merchantId);
|
params.put("coinType", mainCoinType);
|
params.put("callUrl", defaultCallBackUrl);
|
params.put("walletId", walletId);
|
params.put("alias", alias);
|
|
ResultMsg result = JSONUtil.toBean(UdunUtils.post(gateway, merchantKey, ApiPath.CREATE_ADDRESS, StrUtil.format("[{}]", JSONUtil.toJsonStr(params))), ResultMsg.class);
|
if (result.getCode() != HttpStatus.HTTP_OK) {
|
throw new UdunException(result.getCode(), result.getMessage());
|
}
|
return JSONUtil.toBean(result.getData(), Address.class);
|
}
|
|
@RequestMapping(action +"rechargeCallback.action")
|
public ResultMsg rechargeCallback(HttpServletRequest request){
|
String timestamp = request.getParameter("timestamp");
|
String nonce = request.getParameter("nonce");
|
String sign = request.getParameter("sign");
|
String body = request.getParameter("body");
|
try{
|
ObjectMapper objectMapper = new ObjectMapper();
|
Map<String, Object> map = objectMapper.readValue(body, HashMap.class);
|
double amounts = Double.parseDouble(map.get("amount").toString()); // 假设 amount 的值为 1000
|
double decimals = Double.parseDouble(map.get("decimals").toString());
|
double success_amount = amounts / Math.pow(10, decimals);
|
String address = map.get("address").toString();
|
|
|
RechargeBlockchainOrder blockchainOrder = rechargeBlockchainOrderService.getOne(new LambdaQueryWrapper<>(RechargeBlockchainOrder.class)
|
.eq(RechargeBlockchainOrder::getSucceeded, 0)
|
.eq(RechargeBlockchainOrder::getChannelAddress, address).last(" limit 1 "));
|
if(ObjectUtil.isEmpty(blockchainOrder)){
|
ResultMsg resultMsg = new ResultMsg();
|
resultMsg.setCode(200);
|
return resultMsg;
|
}
|
SysUser user = sysUserService.getSysUserById( Long.getLong(blockchainOrder.getPartyId()));
|
rechargeBlockchainOrderService.manualReceipt(1,blockchainOrder.getPartyId(), BigDecimal.valueOf(success_amount),user.getUsername());
|
ResultMsg resultMsg = new ResultMsg();
|
resultMsg.setCode(200);
|
return resultMsg;
|
}catch (Exception e){
|
ResultMsg resultMsg = new ResultMsg();
|
resultMsg.setCode(500);
|
resultMsg.setMessage("回调处理失败");
|
return resultMsg;
|
}
|
}
|
|
/**
|
* 根据第三方充值链接
|
*/
|
@RequestMapping(action + "getThirdUrl.action")
|
public Result getThirdUrl(HttpServletRequest request) throws IOException {
|
|
String key = this.sysparaService.find("third_key").getSvalue();
|
String merchant_no = this.sysparaService.find("third_id").getSvalue();
|
int i = (int) (Math.random() * 900) + 100;
|
//商户号
|
//10位时间戳
|
String timestamp = "" + System.currentTimeMillis() / 1000;
|
String amount = request.getParameter("amount");
|
//法币名称
|
String fiat_currency = request.getParameter("fiat_currency");
|
//订单号
|
String merchant_ref = System.currentTimeMillis() + "" + i;
|
//产品名称
|
String product = "ERC20Buy";
|
String sign_type = "MD5";
|
Map<String, String> requestparam = new HashMap<>();
|
JSONObject params = new JSONObject(new LinkedHashMap<>());
|
JSONObject extra = new JSONObject(new LinkedHashMap<>());
|
extra.put("fiat_currency", fiat_currency);
|
params.put("merchant_ref", merchant_ref);
|
params.put("product", product);
|
params.put("amount", amount);
|
params.put("extra", extra);
|
String waitsign = merchant_no + params + sign_type + timestamp + key;
|
String sign = MD5.sign(waitsign);
|
requestparam.put("merchant_no", merchant_no);
|
requestparam.put("params", params.toJSONString());
|
requestparam.put("sign", sign);
|
requestparam.put("sign_type", sign_type);
|
requestparam.put("timestamp", params.toJSONString());
|
String result = "";
|
RequestBody body = new FormBody.Builder()
|
.add("merchant_no", merchant_no)
|
.add("timestamp", timestamp)
|
.add("sign_type", sign_type)
|
.add("params", params.toString())
|
.add("sign", sign)
|
.build();
|
Request requestParm = new Request.Builder()
|
.url(threedUrl)
|
.method("POST", body)
|
.addHeader("Content-Type", "application/x-www-form-urlencoded")
|
.build();
|
try {
|
Response response = okHttpClient.newCall(requestParm).execute();
|
result = response.body().string();
|
} catch (Exception e) {
|
throw new YamiShopBindException("请求第三方失败");
|
}
|
JSONObject resultJson = JSON.parseObject(result);
|
Integer code = resultJson.getInteger("code");
|
if (code == 200) {
|
JSONObject resultParams = resultJson.getJSONObject("params");
|
return Result.succeed(resultParams.getString("payurl"));
|
} else {
|
return Result.failed(resultJson.getString("message"));
|
|
}
|
}
|
}
|
