From 8cdfe9421d7af2e52fa4f12e6e151870f522f9d5 Mon Sep 17 00:00:00 2001 From: Zhujx Date: Tue, 30 Sep 2025 14:07:44 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E6=B7=BB=E5=8A=A0=E7=8E=B0=E4=BB=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../stock/data/schedule/DataMsgSendJob.java | 18 ++++++++++++++++-- 1 file changed, 16 insertions(+), 2 deletions(-) diff --git a/script/src/main/java/com/xiang/xservice/stock/data/schedule/DataMsgSendJob.java b/script/src/main/java/com/xiang/xservice/stock/data/schedule/DataMsgSendJob.java index 8811fa6..e185fc2 100644 --- a/script/src/main/java/com/xiang/xservice/stock/data/schedule/DataMsgSendJob.java +++ b/script/src/main/java/com/xiang/xservice/stock/data/schedule/DataMsgSendJob.java @@ -49,10 +49,24 @@ public class DataMsgSendJob { Object o = redisService.hGet(RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), stockGnshyxRecordDataDO.getStockCode()); if (Objects.isNull(o)) { if (recordDO.getXjPrice().compareTo(stockGnshyxRecordDataDO.getAttentionPrice()) > 0) { - msg.append("股票代码:").append(stockGnshyxRecordDataDO.getStockCode()).append("，名称:").append(stockGnshyxRecordDataDO.getStockName()).append("达到预期的价格：").append(stockGnshyxRecordDataDO.getAttentionPrice()).append("\n"); + msg.append("股票代码:") + .append(stockGnshyxRecordDataDO.getStockCode()) + .append("，名称:") + .append(stockGnshyxRecordDataDO.getStockName()) + .append(",达到预期的价格：") + .append(stockGnshyxRecordDataDO.getAttentionPrice()) + .append(",现在价格:").append(recordDO.getXjPrice()) + .append("\n"); } if (recordDO.getXjPrice().compareTo(stockGnshyxRecordDataDO.getStopPrice()) < 0) { - msg.append("股票代码:").append(stockGnshyxRecordDataDO.getStockCode()).append("，名称:").append(stockGnshyxRecordDataDO.getStockName()).append("达到止损的价格：").append(stockGnshyxRecordDataDO.getStopPrice()).append("\n"); + msg.append("股票代码:") + .append(stockGnshyxRecordDataDO.getStockCode()) + .append("，名称:") + .append(stockGnshyxRecordDataDO.getStockName()) + .append("达到止损的价格：") + .append(stockGnshyxRecordDataDO.getStopPrice()) + .append(",现在价格:").append(recordDO.getXjPrice()) + .append("\n"); } redisService.hSet(RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), stockGnshyxRecordDataDO.getStockCode(), "true"); redisService.expire("xservice-script-center", RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), 10, TimeUnit.DAYS);