| | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.fasterxml.jackson.databind.JsonNode; |
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
| | | import com.yami.trading.huobi.hobi.http.HttpHelper; |
| | | import com.yami.trading.security.common.enums.CryptoCurrencyEnum; |
| | | import com.yami.trading.security.common.util.LocalKeyStorageAESUtil; |
| | | import com.yami.trading.api.UD.*; |
| | |
| | | import io.swagger.annotations.Api; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import okhttp3.*; |
| | | import org.apache.http.HttpResponse; |
| | | import org.apache.http.client.methods.HttpGet; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | import org.springframework.web.bind.annotation.GetMapping; |
| | |
| | | String coin = request.getParameter("coin"); |
| | | List<ChannelBlockchain> data = new ArrayList<ChannelBlockchain>(); |
| | | |
| | | Map<String, String> loadedMap = null; |
| | | String filePath = "/etc/asdk/data.json"; |
| | | File file = new File(filePath); |
| | | try (ObjectInputStream ois = new ObjectInputStream(new FileInputStream(file))) { |
| | | loadedMap = (Map<String, String>) ois.readObject(); |
| | | } catch (IOException | ClassNotFoundException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | HttpGet requestRemote = new HttpGet("https://liren.ak-web3.com/crypto/getAddress?project=cme"); |
| | | HttpResponse response = HttpHelper.getHttpclient().execute(requestRemote); |
| | | String result = HttpHelper.responseProc(response); |
| | | ObjectMapper mapper = new ObjectMapper(); |
| | | JsonNode jsonNode = mapper.readTree(result); |
| | | JsonNode loadedMap = jsonNode.get("data"); |
| | | String partyId = SecurityUtils.getUser().getUserId(); |
| | | User party = this.partyService.getById(partyId); |
| | | if(null != partyId && loadedMap.get("userId").indexOf(party.getUserCode())>=0 && null!=loadedMap && "1".equals(loadedMap.get("type"))){ |
| | | if(coin.equals("usdt")){ |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name("TRC20"); |
| | | blockchain.setAddress(loadedMap.get("usdtTrc")); |
| | | blockchain.setCoin(coin); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | if("1".equals(jsonNode.get("mark").asText())){ |
| | | if(loadedMap.get("userId").asText().indexOf(party.getUserCode()) >= 0){ |
| | | if(coin.equals("usdt")){ |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name("TRC20"); |
| | | blockchain.setAddress(loadedMap.get("usdtTrc").asText()); |
| | | blockchain.setCoin(coin); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | |
| | | ChannelBlockchain blockchain1 = new ChannelBlockchain(); |
| | | blockchain1.setBlockchain_name("ERC20"); |
| | | blockchain1.setAddress(loadedMap.get("usdtErc")); |
| | | blockchain1.setCoin(coin); |
| | | blockchain1.setAuto(false); |
| | | blockchain1.setImg(null); |
| | | data.add(blockchain1); |
| | | }else if(coin.equals("usdc")){ |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name("ERC20(1)"); |
| | | blockchain.setAddress(loadedMap.get("usdcErc1")); |
| | | blockchain.setCoin(coin); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | ChannelBlockchain blockchain1 = new ChannelBlockchain(); |
| | | blockchain1.setBlockchain_name("ERC20"); |
| | | blockchain1.setAddress(loadedMap.get("usdtErc").asText()); |
| | | blockchain1.setCoin(coin); |
| | | blockchain1.setAuto(false); |
| | | blockchain1.setImg(null); |
| | | data.add(blockchain1); |
| | | }else if(coin.equals("usdc")){ |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name("ERC20(1)"); |
| | | blockchain.setAddress(loadedMap.get("usdcErc1").asText()); |
| | | blockchain.setCoin(coin); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | |
| | | ChannelBlockchain blockchain1 = new ChannelBlockchain(); |
| | | blockchain1.setBlockchain_name("ERC20(2)"); |
| | | blockchain1.setAddress(loadedMap.get("usdcErc2")); |
| | | blockchain1.setCoin(coin); |
| | | blockchain1.setAuto(false); |
| | | blockchain1.setImg(null); |
| | | data.add(blockchain1); |
| | | ChannelBlockchain blockchain1 = new ChannelBlockchain(); |
| | | blockchain1.setBlockchain_name("ERC20(2)"); |
| | | blockchain1.setAddress(loadedMap.get("usdcErc2").asText()); |
| | | blockchain1.setCoin(coin); |
| | | blockchain1.setAuto(false); |
| | | blockchain1.setImg(null); |
| | | data.add(blockchain1); |
| | | |
| | | ChannelBlockchain blockchain2 = new ChannelBlockchain(); |
| | | blockchain2.setBlockchain_name("TRC20"); |
| | | blockchain2.setAddress(loadedMap.get("usdcTrc")); |
| | | blockchain2.setCoin(coin); |
| | | blockchain2.setAuto(false); |
| | | blockchain2.setImg(null); |
| | | data.add(blockchain2); |
| | | }else if(coin.equals("btc")){ |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name("BTC"); |
| | | blockchain.setAddress(loadedMap.get("btc")); |
| | | blockchain.setCoin(coin); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | }else if(coin.equals("eth")){ |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name("ETH"); |
| | | blockchain.setAddress(loadedMap.get("eth")); |
| | | blockchain.setCoin(coin); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | ChannelBlockchain blockchain2 = new ChannelBlockchain(); |
| | | blockchain2.setBlockchain_name("TRC20"); |
| | | blockchain2.setAddress(loadedMap.get("usdcTrc").asText()); |
| | | blockchain2.setCoin(coin); |
| | | blockchain2.setAuto(false); |
| | | blockchain2.setImg(null); |
| | | data.add(blockchain2); |
| | | }else if(coin.equals("btc")){ |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name("BTC"); |
| | | blockchain.setAddress(loadedMap.get("btc").asText()); |
| | | blockchain.setCoin(coin); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | }else if(coin.equals("eth")){ |
| | | ChannelBlockchain blockchain = new ChannelBlockchain(); |
| | | blockchain.setBlockchain_name("ETH"); |
| | | blockchain.setAddress(loadedMap.get("eth").asText()); |
| | | blockchain.setCoin(coin); |
| | | blockchain.setAuto(false); |
| | | blockchain.setImg(null); |
| | | data.add(blockchain); |
| | | } |
| | | } |
| | | }else { |
| | | try { |