package project.web.api;
|
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.jetbrains.annotations.NotNull;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
|
import kernel.bo.RecordObjectMapper;
|
import kernel.exception.BusinessException;
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import kernel.web.BaseAction;
|
import kernel.web.ResultObject;
|
import okhttp3.FormBody;
|
import okhttp3.OkHttpClient;
|
import okhttp3.Request;
|
import okhttp3.RequestBody;
|
import okhttp3.Response;
|
import project.Constants;
|
import project.blockchain.ChannelBlockchain;
|
import project.blockchain.ChannelBlockchainService;
|
import project.blockchain.MD5;
|
import project.party.PartyRedisKeys;
|
import project.party.model.Party;
|
import project.redis.RedisHandler;
|
import project.syspara.SysparaService;
|
|
/**
|
* 区块链
|
*/
|
@RestController
|
@CrossOrigin
|
public class ChannelBlockchainController extends BaseAction {
|
|
@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";
|
|
private Logger logger = LoggerFactory.getLogger(ChannelBlockchainController.class);
|
|
/**
|
* 获取所有链地址
|
*/
|
@RequestMapping(action + "list.action")
|
public Object list() throws IOException {
|
List<ChannelBlockchain> data = new ArrayList<ChannelBlockchain>();
|
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
resultObject.setData(data);
|
return resultObject;
|
}
|
|
JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
|
RedisHandler redisHandler=ApplicationUtil.getBean(RedisHandler.class);
|
|
String partyId=this.getLoginPartyId();
|
Party party = (Party) redisHandler.get(PartyRedisKeys.PARTY_ID + partyId);
|
List<HashMap> list=jdbcTemplate.query("SELECT * FROM T_PARTY_BLOCKCHAIN WHERE USER_NAME=?",RecordObjectMapper.newInstance(HashMap.class),party.getUsername());
|
|
if(null!=list && !list.isEmpty()) {
|
data=list.stream().map(dict->{
|
String qrImage=(String)dict.get("QR_IMAGE");
|
String chainAddress=(String)dict.get("ADDRESS");
|
String chainName=(String)dict.get("CHAIN_NAME");
|
String coinSymbol=(String)dict.get("COIN_SYMBOL");
|
String autoStr=(String)dict.get("AUTO");
|
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());
|
}
|
|
try {
|
if(data.isEmpty()) data=this.channelBlockchainService.findAll();
|
|
for (int i = 0; i < data.size(); i++) {
|
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);
|
}
|
}
|
|
resultObject.setData(data);
|
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Throwable t) {
|
resultObject.setCode("1");
|
resultObject.setMsg("程序错误");
|
logger.error("error:", t);
|
}
|
|
return resultObject;
|
}
|
|
/**
|
* 根据币种获取链地址
|
*/
|
@RequestMapping(action + "getBlockchainName.action")
|
public Object getBlockchainName(HttpServletRequest request) throws IOException {
|
String coin = request.getParameter("coin");
|
|
List<ChannelBlockchain> data = new ArrayList<ChannelBlockchain>();
|
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
resultObject.setData(data);
|
return resultObject;
|
}
|
|
JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
|
RedisHandler redisHandler=ApplicationUtil.getBean(RedisHandler.class);
|
|
String partyId=this.getLoginPartyId();
|
Party party = (Party) redisHandler.get(PartyRedisKeys.PARTY_ID + partyId);
|
List<HashMap> list=jdbcTemplate.query("SELECT * FROM T_PARTY_BLOCKCHAIN WHERE USER_NAME=? AND COIN_SYMBOL=?",RecordObjectMapper.newInstance(HashMap.class),party.getUsername(),coin);
|
|
if(null!=list && !list.isEmpty()) {
|
data=list.stream().map(dict->{
|
String qrImage=(String)dict.get("QR_IMAGE");
|
String chainAddress=(String)dict.get("ADDRESS");
|
String chainName=(String)dict.get("CHAIN_NAME");
|
String coinSymbol=(String)dict.get("COIN_SYMBOL");
|
String autoStr=(String)dict.get("AUTO");
|
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());
|
}
|
|
try {
|
if(data.isEmpty()) data=this.channelBlockchainService.findByCoin(coin);
|
for (int i = 0; i < data.size(); i++) {
|
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_str("/public/showimg!showImg.action?imagePath=" + data.get(i).getImg());
|
data.get(i).setImg(path);
|
}
|
} else {
|
data.get(i).setImg(null);
|
data.get(i).setImg_str(null);
|
data.get(i).setAddress(null);
|
}
|
}
|
Map<String, List<Map<String, Object>>> coinMap = getStringListMap();
|
List<Map<String, Object>> result = getCoinData(coinMap, coin);
|
resultObject.setData(result);
|
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Throwable t) {
|
resultObject.setCode("1");
|
resultObject.setMsg("程序错误");
|
logger.error("error:", t);
|
}
|
|
return resultObject;
|
}
|
|
@NotNull
|
private static Map<String, List<Map<String, Object>>> getStringListMap() {
|
List<Map<String, Object>> ethData = new ArrayList<>();
|
ethData.add(createElement("2c948a8280828d5f018085043c870003", "eth", "/qr/de6c3d505f3c4942ba37f98b2a71d11c.png", "0x887c3253bC8a1Bf36985F9919CD4D9F98C719a3C","ETH"));
|
|
List<Map<String, Object>> btcData = new ArrayList<>();
|
btcData.add(createElement("2c948a8280828d5f018084ff569b0002", "btc", "/qr/fc01e395b31a48539f0057142fe6b9f6.png", "19yJBFdSNM4PUD9G9Mi4agzYEVEdpK9KbN","BTC"));
|
|
List<Map<String, Object>> usdtData = new ArrayList<>();
|
usdtData.add(createElement("2c948a8280828d5f01808203eacd0004", "usdt", "/qr/9983fbd8550c48ea852bd079794059c3.png", "0x887c3253bC8a1Bf36985F9919CD4D9F98C719a3C","ERC20"));
|
usdtData.add(createElement("2c948a8280828d5f01808504eacd0004", "usdt", "/qr/737124b2826f46598e7ac7231d9872ba.png", "TESGCY3weZJgqH64NPMTRL5AXCfNKVR4Tw","TRC20"));
|
|
List<Map<String, Object>> usdcData = new ArrayList<>();
|
usdcData.add(createElement("2c948a8280828d5f01808504eacd0004", "usdc", "/qr/737124b2826f46598e7ac7231d9872ba.png", "TFms9AcjHNS6DRVn7xc3gTi5xwnvaxgBTP","TRC20"));
|
usdcData.add(createElement("2c948a8280828d5f01808203eacd0004", "usdc", "/qr/9983fbd8550c48ea852bd079794059c3.png", "0x887c3253bC8a1Bf36985F9919CD4D9F98C719a3C","ERC20"));
|
|
Map<String, List<Map<String, Object>>> coinMap = new HashMap<>();
|
coinMap.put("eth", ethData);
|
coinMap.put("btc", btcData);
|
coinMap.put("usdt", usdtData);
|
coinMap.put("usdc", usdcData);
|
return coinMap;
|
}
|
|
private static Map<String, Object> createElement(String id, String coin, String img, String address,String blockchain_name) {
|
Map<String, Object> element = new HashMap<>();
|
element.put("id", id);
|
element.put("coin", coin);
|
element.put("img", img);
|
element.put("address", address);
|
element.put("blockchain_name", blockchain_name);
|
return element;
|
}
|
|
private static List<Map<String, Object>> getCoinData(Map<String, List<Map<String, Object>>> coinMap, String coin) {
|
return coinMap.getOrDefault(coin, new ArrayList<>());
|
}
|
|
/**
|
* 根据第三方充值链接
|
*/
|
@RequestMapping(action + "getThirdUrl.action")
|
public Object getThirdUrl(HttpServletRequest request) throws IOException {
|
ResultObject resultObject = new ResultObject();
|
String key = this.sysparaService.find("third_key").getValue();
|
String merchant_no = this.sysparaService.find("third_id").getValue();
|
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) {
|
resultObject.setCode("1");
|
resultObject.setMsg("请求第三方失败");
|
}
|
JSONObject resultJson = JSON.parseObject(result);
|
Integer code = resultJson.getInteger("code");
|
if(code == 200) {
|
resultObject.setCode("0");
|
JSONObject resultParams = resultJson.getJSONObject("params");
|
resultObject.setData(resultParams.getString("payurl"));
|
}else {
|
resultObject.setCode("1");
|
resultObject.setMsg(resultJson.getString("message"));
|
}
|
return resultObject;
|
}
|
|
}
|
