xservice/xservice-script
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:添加现价

Browse Source
This commit is contained in:
Zhujx
2025-09-30 14:07:44 +08:00
parent b62726545e
commit 8cdfe9421d
1 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
script/src/main/java/com/xiang/xservice/stock/data/schedule/DataMsgSendJob.java
View File

@@ -49,10 +49,24 @@ public class DataMsgSendJob {
Object o = redisService.hGet(RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), stockGnshyxRecordDataDO.getStockCode()); Object o = redisService.hGet(RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), stockGnshyxRecordDataDO.getStockCode());
if (Objects.isNull(o)) { if (Objects.isNull(o)) {
if (recordDO.getXjPrice().compareTo(stockGnshyxRecordDataDO.getAttentionPrice()) > 0) { 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) { 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.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); redisService.expire("xservice-script-center", RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), 10, TimeUnit.DAYS);