nhanvubk/ger-market-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

判断是否新增

Browse Source
This commit is contained in:
Achilles
2024-04-28 15:59:52 +08:00
parent 3fb3e9918f
commit b5c0e7947e
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/cn/stock/market/web/MessageRetifiveController.java
View File

@@ -3,17 +3,20 @@ package cn.stock.market.web;
import cn.stock.market.domain.basic.entity.RetifiveStock; import cn.stock.market.domain.basic.entity.RetifiveStock;
import cn.stock.market.domain.basic.service.RetifiveStockService; import cn.stock.market.domain.basic.service.RetifiveStockService;
import cn.stock.market.dto.RetifiveStockInfo; import cn.stock.market.dto.RetifiveStockInfo;
import cn.stock.market.infrastructure.db.po.QRetifiveStockPO;
import cn.stock.market.listener.AppClient; import cn.stock.market.listener.AppClient;
import cn.stock.market.listener.ConcurrentAppClient; import cn.stock.market.listener.ConcurrentAppClient;
import cn.stock.market.listener.StockInfoRefinitiv; import cn.stock.market.listener.StockInfoRefinitiv;
import cn.stock.market.listener.SymbolRefinitiv; import cn.stock.market.listener.SymbolRefinitiv;
import cn.stock.market.utils.ServerResponse; import cn.stock.market.utils.ServerResponse;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.querydsl.core.types.Predicate;
import com.thomsonreuters.ema.access.DataType; import com.thomsonreuters.ema.access.DataType;
import com.thomsonreuters.ema.access.FieldEntry; import com.thomsonreuters.ema.access.FieldEntry;
import com.thomsonreuters.ema.access.FieldList; import com.thomsonreuters.ema.access.FieldList;
import com.thomsonreuters.ema.access.RefreshMsg; import com.thomsonreuters.ema.access.RefreshMsg;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.MongoTemplate;
@@ -540,7 +543,10 @@ public class MessageRetifiveController {
RetifiveStock retifiveStock = RetifiveStock.builder().stockType(stockType).saveTime(new Date()).isLock(0).isShow(0) RetifiveStock retifiveStock = RetifiveStock.builder().stockType(stockType).saveTime(new Date()).isLock(0).isShow(0)
.stockCode(stockCode).symbol(name).stockName(stockName).build(); .stockCode(stockCode).symbol(name).stockName(stockName).build();
retifiveStockService.repository().save(retifiveStock); List<RetifiveStock> all = retifiveStockService.repository().findAll(QRetifiveStockPO.retifiveStockPO.symbol.eq(name));
if(CollectionUtils.isEmpty(all)){
retifiveStockService.repository().save(retifiveStock);
}
} }