From 424b62489ed556b599a88390d854133cd2075876 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Wed, 14 Apr 2021 11:28:14 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/common/system/controller/CommonController.java | 3 ++- src/main/java/com/xcong/excoin/quartz/job/UsdtCnyExchangePriceUpdateJob.java | 14 +++++++------- src/test/java/com/xcong/excoin/SymbolsTest.java | 10 ++++++++++ 3 files changed, 19 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/xcong/excoin/common/system/controller/CommonController.java b/src/main/java/com/xcong/excoin/common/system/controller/CommonController.java index 73ebfb2..b08d0b6 100644 --- a/src/main/java/com/xcong/excoin/common/system/controller/CommonController.java +++ b/src/main/java/com/xcong/excoin/common/system/controller/CommonController.java @@ -100,8 +100,9 @@ @PostMapping(value = "/uploadFileBase64") public Result uploadFileBase64(@RequestBody @Validated Base64UploadDto uploadDto) { String imageName = "uploadeFile/image/" + System.currentTimeMillis() + IdUtil.simpleUUID() + AppContants.UPLOAD_IMAGE_SUFFIX; - + log.info("#进入上传图片接口#"); boolean flag = OssUtils.uploadFileWithBase64(uploadDto.base64Str, imageName); + log.info("#确认出来了{}#", flag); if (flag) { String url = aliOssProperties.getBucketName() + "/" + imageName; return Result.ok(MessageSourceUtils.getString("result_success_msg"), url); diff --git a/src/main/java/com/xcong/excoin/quartz/job/UsdtCnyExchangePriceUpdateJob.java b/src/main/java/com/xcong/excoin/quartz/job/UsdtCnyExchangePriceUpdateJob.java index 96dc366..5bbbb45 100644 --- a/src/main/java/com/xcong/excoin/quartz/job/UsdtCnyExchangePriceUpdateJob.java +++ b/src/main/java/com/xcong/excoin/quartz/job/UsdtCnyExchangePriceUpdateJob.java @@ -37,7 +37,7 @@ // 模拟浏览器 String userAgent = "Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/29.0.1547.66 Safari/537.36"; try { - URL url = new URL("https://otc-api-hk.eiijo.cn/v1/data/config/purchase-price?coinId=2¤cyId=1&matchType=0"); + URL url = new URL("https://freecurrencyrates.com/api/action.php?s=fcr&iso=USD-CNH&f=USD&v=1&do=cvals&ln=zh-hans"); HttpURLConnection connection = (HttpURLConnection) url.openConnection(); connection.setRequestMethod("GET"); connection.setReadTimeout(30000); @@ -53,13 +53,13 @@ } reader.close(); result = sbf.toString(); - JSONObject jsonObject = (JSONObject) JSONObject.parse(result); - String code = jsonObject.getString("code"); - if ("200".equals(code)) { - JSONObject jsonData = (JSONObject) jsonObject.get("data"); - cnyUsdtExchangeDao.updateUsdt(BigDecimal.valueOf(jsonData.getDouble("price"))); - } +// String code = jsonObject.getString("code"); +// if ("200".equals(code)) { +// JSONObject jsonData = (JSONObject) jsonObject.get("data"); +// cnyUsdtExchangeDao.updateUsdt(BigDecimal.valueOf(jsonData.getDouble("price"))); +// } + cnyUsdtExchangeDao.updateUsdt(new BigDecimal(jsonObject.getString("CNH"))); } catch (Exception e) { e.printStackTrace(); } diff --git a/src/test/java/com/xcong/excoin/SymbolsTest.java b/src/test/java/com/xcong/excoin/SymbolsTest.java index 7cdd104..d32a23f 100644 --- a/src/test/java/com/xcong/excoin/SymbolsTest.java +++ b/src/test/java/com/xcong/excoin/SymbolsTest.java @@ -16,6 +16,7 @@ import com.xcong.excoin.modules.member.entity.MemberWalletContractEntity; import com.xcong.excoin.modules.platform.entity.PlatformTradeSettingEntity; import com.xcong.excoin.modules.symbols.service.SymbolsService; +import com.xcong.excoin.quartz.job.UsdtCnyExchangePriceUpdateJob; import com.xcong.excoin.rabbit.producer.OrderProducer; import com.xcong.excoin.utils.CacheSettingUtils; import com.xcong.excoin.utils.CalculateUtil; @@ -23,6 +24,7 @@ import com.xcong.excoin.utils.RedisUtils; import lombok.extern.slf4j.Slf4j; import org.junit.jupiter.api.Test; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import javax.annotation.Resource; @@ -139,4 +141,12 @@ log.info("-->", e); } } + + @Autowired + private UsdtCnyExchangePriceUpdateJob usdtCnyExchangePriceUpdateJob; + + @Test + public void usdtCnyTest() { + usdtCnyExchangePriceUpdateJob.updateUsdtCnyExchange(); + } } -- Gitblit v1.9.1