From 2ecbe3179bd2b1a7967dc53f56653be8943b5fa0 Mon Sep 17 00:00:00 2001 From: xiang Date: Sat, 20 Sep 2025 00:49:02 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E8=82=A1=E7=A5=A8=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=8B=89=E5=8F=96=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/xiang/ServiceScriptApplication.java | 1 + .../data/common/constants/RedisConstants.java | 15 +++ .../data/common/constants/UrlConstants.java | 9 ++ .../data/entity/StockSinaDataRecordDO.java | 63 +++++++++ .../mapper/StockSinaDataRecordPullMapper.java | 15 +++ .../stock/data/schedule/DataMsgSendJob.java | 84 ++++++++++++ .../stock/data/schedule/StockDataPullJob.java | 55 ++++++++ .../service/DingTalkScriptStockService.java | 32 +++++ .../stock/data/service/IStockDataService.java | 14 ++ .../data/service/StockDataServiceImpl.java | 98 ++++++++++++++ .../mapper/StockGnshyxRecordDataMapper.java | 9 ++ .../gnshyx/schedule/CloudRecordDataJob.java | 55 +++++--- .../service/CloudRecordDataServiceImpl.java | 21 +++ .../service/ICloudRecordDataService.java | 8 ++ .../stock/StockGnshyxRecordDataMapper.xml | 8 ++ .../stock/StockSinaDataRecordPullMapper.xml | 126 ++++++++++++++++++ 16 files changed, 592 insertions(+), 21 deletions(-) create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/common/constants/RedisConstants.java create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/common/constants/UrlConstants.java create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/entity/StockSinaDataRecordDO.java create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/mapper/StockSinaDataRecordPullMapper.java create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/schedule/DataMsgSendJob.java create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/schedule/StockDataPullJob.java create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/service/DingTalkScriptStockService.java create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/service/IStockDataService.java create mode 100644 script/src/main/java/com/xiang/xservice/stock/data/service/StockDataServiceImpl.java create mode 100644 script/src/main/resources/mapper/stock/StockSinaDataRecordPullMapper.xml diff --git a/script/src/main/java/com/xiang/ServiceScriptApplication.java b/script/src/main/java/com/xiang/ServiceScriptApplication.java index 4516fe2..fcdeb45 100644 --- a/script/src/main/java/com/xiang/ServiceScriptApplication.java +++ b/script/src/main/java/com/xiang/ServiceScriptApplication.java @@ -17,6 +17,7 @@ import org.springframework.scheduling.annotation.EnableScheduling; "com.xiang.xservice.glados.repository", "com.xiang.xservice.xb.repository", "com.xiang.xservice.stock.gnshyx.mapper", + "com.xiang.xservice.stock.data.mapper", }) @ConfigurationPropertiesScan(basePackages = { "com.xiang.xservice.config" diff --git a/script/src/main/java/com/xiang/xservice/stock/data/common/constants/RedisConstants.java b/script/src/main/java/com/xiang/xservice/stock/data/common/constants/RedisConstants.java new file mode 100644 index 0000000..7582d65 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/common/constants/RedisConstants.java @@ -0,0 +1,15 @@ +package com.xiang.xservice.stock.data.common.constants; + +import com.xiang.xservice.basic.utils.DateUtils; + +import java.time.LocalDate; + +public class RedisConstants { + + public static final String MSG_SEND_REDIS_KEY = "stock:msg:send:"; + + + public static String getDate4Key() { + return DateUtils.getDateFromDate(LocalDate.now(), "yyyyMMdd"); + } +} diff --git a/script/src/main/java/com/xiang/xservice/stock/data/common/constants/UrlConstants.java b/script/src/main/java/com/xiang/xservice/stock/data/common/constants/UrlConstants.java new file mode 100644 index 0000000..a495181 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/common/constants/UrlConstants.java @@ -0,0 +1,9 @@ +package com.xiang.xservice.stock.data.common.constants; + +public class UrlConstants { + + /** + * 新浪财经 股票数据拉取 + */ + public static final String SINA_STOCK_DATA_PULL_URL = "https://hq.sinajs.cn/list="; +} diff --git a/script/src/main/java/com/xiang/xservice/stock/data/entity/StockSinaDataRecordDO.java b/script/src/main/java/com/xiang/xservice/stock/data/entity/StockSinaDataRecordDO.java new file mode 100644 index 0000000..55aa6e2 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/entity/StockSinaDataRecordDO.java @@ -0,0 +1,63 @@ +package com.xiang.xservice.stock.data.entity; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.math.BigDecimal; +import java.time.LocalDateTime; + +@Data +@AllArgsConstructor +@NoArgsConstructor +public class StockSinaDataRecordDO { + /** + * 主键id + */ + private Long id; + + /** + * 股票名称 + */ + private String name; + + /** + * 今开价格 + */ + private BigDecimal jkPrice; + + /** + * 昨收价格 + */ + private BigDecimal zsPrice; + + /** + * 现在价格 + */ + private BigDecimal xjPrice; + + /** + * 最高价格 + */ + private BigDecimal zgPrice; + + /** + * 最低价格 + */ + private BigDecimal zdPrice; + + /** + * 总手数量 + */ + private String zsNum; + + /** + * 总交易金额 + */ + private BigDecimal price; + + /** + * 时间 + */ + private LocalDateTime updateTime; +} diff --git a/script/src/main/java/com/xiang/xservice/stock/data/mapper/StockSinaDataRecordPullMapper.java b/script/src/main/java/com/xiang/xservice/stock/data/mapper/StockSinaDataRecordPullMapper.java new file mode 100644 index 0000000..5b17000 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/mapper/StockSinaDataRecordPullMapper.java @@ -0,0 +1,15 @@ +package com.xiang.xservice.stock.data.mapper; + +import com.xiang.xservice.stock.data.entity.StockSinaDataRecordDO; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; +import org.springframework.stereotype.Repository; + +import java.util.List; + +@Repository +@Mapper +public interface StockSinaDataRecordPullMapper { + + int batchInsert(@Param("list") List list); +} 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 new file mode 100644 index 0000000..d394df0 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/schedule/DataMsgSendJob.java @@ -0,0 +1,84 @@ +package com.xiang.xservice.stock.data.schedule; + +import com.xiang.xservice.basic.utils.DateUtils; +import com.xiang.xservice.cache.service.IRedisService; +import com.xiang.xservice.stock.data.common.constants.RedisConstants; +import com.xiang.xservice.stock.data.entity.StockSinaDataRecordDO; +import com.xiang.xservice.stock.data.service.DingTalkScriptStockService; +import com.xiang.xservice.stock.data.service.IStockDataService; +import com.xiang.xservice.stock.gnshyx.entity.StockGnshyxRecordDataDO; +import com.xiang.xservice.stock.gnshyx.service.ICloudRecordDataService; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.time.DayOfWeek; +import java.time.LocalDateTime; +import java.time.LocalTime; +import java.util.List; +import java.util.Objects; +import java.util.concurrent.TimeUnit; + +@Component +@Slf4j +@RequiredArgsConstructor +public class DataMsgSendJob { + + private final ICloudRecordDataService cloudRecordDataService; + private final IStockDataService stockDataService; + private final DingTalkScriptStockService dingTalkScriptStockService; + private final IRedisService redisService; + + @Scheduled(cron = "0/10 * * * * ?") + public void stockGetTargetMsgSend() { + if (DateUtils.validWeekTime()) return; + + StringBuilder msg = new StringBuilder("0000"); + List list = cloudRecordDataService.getList(); + for (StockGnshyxRecordDataDO stockGnshyxRecordDataDO : list) { + String stockCode = stockGnshyxRecordDataDO.getStockCode(); + String[] values = stockCode.split("\\."); + String c1 = values[1].toLowerCase(); + String c2 = values[0]; + String code = c1 + c2; + String resp = stockDataService.getStockDataFromHttp(code); + StockSinaDataRecordDO recordDO = stockDataService.buildRecordDO(resp); + if (Objects.nonNull(recordDO)) { + 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"); + } + if (recordDO.getXjPrice().compareTo(stockGnshyxRecordDataDO.getStopPrice()) < 0) { + msg.append("股票代码:").append(stockGnshyxRecordDataDO.getStockCode()).append("，名称:").append(stockGnshyxRecordDataDO.getStockName()).append("达到止损的价格：").append(stockGnshyxRecordDataDO.getStopPrice()).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); + } + } + } + + if (StringUtils.isNotBlank(msg)) { + log.info("发送钉钉消息:{}", msg); + dingTalkScriptStockService.sendScriptMsg(msg.toString()); + } + } + + private static boolean validTime() { + if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || + Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { + log.info("当前时间为：{}", LocalDateTime.now()); + return false; + } + LocalTime now = LocalTime.now(); + + boolean inMorning = now.isAfter(LocalTime.of(9, 29)) && now.isBefore(LocalTime.of(11, 31)); + boolean inAfternoon = now.isAfter(LocalTime.of(12, 59)) && now.isBefore(LocalTime.of(15, 1)); + if (!inAfternoon && !inMorning) { + return false; + } + return true; + } +} diff --git a/script/src/main/java/com/xiang/xservice/stock/data/schedule/StockDataPullJob.java b/script/src/main/java/com/xiang/xservice/stock/data/schedule/StockDataPullJob.java new file mode 100644 index 0000000..b0b5528 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/schedule/StockDataPullJob.java @@ -0,0 +1,55 @@ +package com.xiang.xservice.stock.data.schedule; + +import com.google.common.collect.Lists; +import com.xiang.xservice.basic.utils.DateUtils; +import com.xiang.xservice.stock.data.entity.StockSinaDataRecordDO; +import com.xiang.xservice.stock.data.service.IStockDataService; +import com.xiang.xservice.stock.gnshyx.entity.StockGnshyxRecordDataDO; +import com.xiang.xservice.stock.gnshyx.service.ICloudRecordDataService; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.util.List; +import java.util.Objects; + +@Component +@Slf4j +@RequiredArgsConstructor +public class StockDataPullJob { + + private final ICloudRecordDataService cloudRecordDataService; + private final IStockDataService stockDataService; + private static final Integer BATCH_SIZE = 500; + + @Scheduled(cron = "*/1 * * * * ?") + public void sinaDataPullJob() { + if (DateUtils.validWeekTime()) return; + log.info(">>>>>>>>>>>>>>>>>新浪财经数据拉取开始>>>>>>>>>>>>>>>>>"); + List dataList = cloudRecordDataService.getList(); + List result = Lists.newArrayList(); + for (StockGnshyxRecordDataDO stockGnshyxRecordDataDO : dataList) { + String stockCode = stockGnshyxRecordDataDO.getStockCode(); + String[] values = stockCode.split("\\."); + String c1 = values[1].toLowerCase(); + String c2 = values[0]; + String code = c1 + c2; + String resp = stockDataService.getStockDataFromHttp(code); + StockSinaDataRecordDO stockSinaDataRecordDO = stockDataService.buildRecordDO(resp); + if (Objects.nonNull(stockSinaDataRecordDO)) { + result.add(stockSinaDataRecordDO); + } + } + + if (CollectionUtils.isNotEmpty(result)) { + if (BATCH_SIZE > result.size()) { + Lists.partition(result, BATCH_SIZE).forEach(stockDataService::insertData2DB); + } else { + stockDataService.insertData2DB(result); + } + } + log.info(">>>>>>>>>>>>>>>>>新浪财经数据拉取结束>>>>>>>>>>>>>>>>>"); + } +} diff --git a/script/src/main/java/com/xiang/xservice/stock/data/service/DingTalkScriptStockService.java b/script/src/main/java/com/xiang/xservice/stock/data/service/DingTalkScriptStockService.java new file mode 100644 index 0000000..d054579 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/service/DingTalkScriptStockService.java @@ -0,0 +1,32 @@ +package com.xiang.xservice.stock.data.service; + +import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService; +import com.xiang.xservice.config.DingTalkRobotXbConfig; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +/** + * @Author: xiang + * @Date: 2025-08-07 10:30 + */ +@Slf4j +@Service +@RequiredArgsConstructor +public class DingTalkScriptStockService { + + private final DingTalkService dingTalkService; + private final DingTalkRobotXbConfig dingTalkRobotXbConfig; + + /** + * 发送脚本消息 + * @param msg 消息 + */ + public void sendScriptMsg(String msg) { + try { + dingTalkService.sendRobotMessage(dingTalkRobotXbConfig.getSecret(), dingTalkRobotXbConfig.getToken(), dingTalkRobotXbConfig.getUsers(), msg); + } catch (Exception e) { + log.error("信息发送异常, 信息：{}", msg, e); + } + } +} diff --git a/script/src/main/java/com/xiang/xservice/stock/data/service/IStockDataService.java b/script/src/main/java/com/xiang/xservice/stock/data/service/IStockDataService.java new file mode 100644 index 0000000..8bcf5d6 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/service/IStockDataService.java @@ -0,0 +1,14 @@ +package com.xiang.xservice.stock.data.service; + +import com.xiang.xservice.stock.data.entity.StockSinaDataRecordDO; + +import java.util.List; + +public interface IStockDataService { + + String getStockDataFromHttp(String stockCode); + + boolean insertData2DB(List stockSinaDataRecordDOs); + + StockSinaDataRecordDO buildRecordDO(String resp); +} diff --git a/script/src/main/java/com/xiang/xservice/stock/data/service/StockDataServiceImpl.java b/script/src/main/java/com/xiang/xservice/stock/data/service/StockDataServiceImpl.java new file mode 100644 index 0000000..f3cda9f --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/stock/data/service/StockDataServiceImpl.java @@ -0,0 +1,98 @@ +package com.xiang.xservice.stock.data.service; + +import com.google.common.collect.Maps; +import com.xiang.xservice.basic.exception.BusinessException; +import com.xiang.xservice.basic.utils.HttpUtils; +import com.xiang.xservice.stock.data.common.constants.UrlConstants; +import com.xiang.xservice.stock.data.entity.StockSinaDataRecordDO; +import com.xiang.xservice.stock.data.mapper.StockSinaDataRecordPullMapper; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Service; + +import java.math.BigDecimal; +import java.math.RoundingMode; +import java.time.LocalDateTime; +import java.util.List; +import java.util.Map; + +@Slf4j +@Service +@RequiredArgsConstructor +public class StockDataServiceImpl implements IStockDataService{ + + private final StockSinaDataRecordPullMapper stockSinaDataRecordPullMapper; + + //文灿股份,22.210,22.240,22.070,22.310,21.960,22.070,22.080,5173623, 114323642.000, 2900, 22.070,7600, 22.060,4600, 22.050,2700, 22.040,4700, 22.030,600, 22.080,29800,22.090,3800, 22.100,3000, 22.120,800, 22.130,2025-09-19,15:00:02,00 + //浦发银行,12.690,12.750,12.810,12.900,12.560,12.800,12.810,79638295,1015780801.000,78500, 12.800,88400, 12.790,151900,12.780,42900,12.770,71700,12.760,841170, 12.810,1100, 12.830,48100,12.860,128600,12.870,116600,12.880,2025-09-19,15:00:03,00, + //平安银行,11.410,11.410,11.450,11.510,11.370,11.450,11.460,83465123,955004096.910, 103813,11.450,321000,11.440,198700,11.430,216100,11.420,553000,11.410,15300,11.460,27500,11.470,28400,11.480,175335,11.490,893111,11.500,2025-09-19,15:00:00,00 + + @Override + public String getStockDataFromHttp(String stockCode) { + String url = UrlConstants.SINA_STOCK_DATA_PULL_URL + stockCode; + + Map headers = Maps.newHashMap(); + headers.put("Referer", "https://finance.sina.com.cn"); + headers.put("User-Agent", "Mozilla/5.0"); + String resp = HttpUtils.doGet(url, headers, null); + if (StringUtils.isBlank(resp)) { + log.error("http请求拉取新浪财经股票数据失败, 股票代码:{}, 响应结果:{}", stockCode, resp); + throw new BusinessException("拉取数据失败"); + } + return resp; + } + + @Override + public boolean insertData2DB(List stockSinaDataRecordDOs) { + return stockSinaDataRecordPullMapper.batchInsert(stockSinaDataRecordDOs) > 0; + } + + @Override + public StockSinaDataRecordDO buildRecordDO(String resp) { + if (resp.contains("=")) { + resp = resp.split("=")[1].replace("\"", "").replace(";", ""); + if (StringUtils.equals(resp, "FAILED")) { + return null; + } + String[] values = resp.split(","); + + // 股票名称 + String mc = values[0]; + // 今开价格 + String jk = values[1]; + // 昨收价格 + String zs = values[2]; + // 现在价格 + String xj = values[3]; + // 最高价格 + String zg = values[4]; + // 最低价格 + String zd = values[5]; + // 总手 + String zongshou = values[8]; + // 金额 + String je = values[9]; + // 时间 + String sj = values[values.length - 3]; + // 日期 + String rq = values[values.length - 4]; + + BigDecimal change = (new BigDecimal(xj).subtract(new BigDecimal(zs))).divide(new BigDecimal(zs), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); + log.info("股票名称:{}, 当前价格:{}, 昨收价格:{}， 涨跌幅:{}%", mc, xj, zs, change); + + StockSinaDataRecordDO stockSinaDataRecordDO = new StockSinaDataRecordDO(); + stockSinaDataRecordDO.setName(mc); + stockSinaDataRecordDO.setJkPrice(new BigDecimal(jk)); + stockSinaDataRecordDO.setZsPrice(new BigDecimal(zs)); + stockSinaDataRecordDO.setXjPrice(new BigDecimal(xj)); + stockSinaDataRecordDO.setZgPrice(new BigDecimal(zg)); + stockSinaDataRecordDO.setZdPrice(new BigDecimal(zd)); + stockSinaDataRecordDO.setZsNum(zs); + stockSinaDataRecordDO.setPrice(new BigDecimal(je)); + stockSinaDataRecordDO.setUpdateTime(LocalDateTime.now()); + return stockSinaDataRecordDO; + } + return null; + } +} diff --git a/script/src/main/java/com/xiang/xservice/stock/gnshyx/mapper/StockGnshyxRecordDataMapper.java b/script/src/main/java/com/xiang/xservice/stock/gnshyx/mapper/StockGnshyxRecordDataMapper.java index 2844c16..b294fa8 100644 --- a/script/src/main/java/com/xiang/xservice/stock/gnshyx/mapper/StockGnshyxRecordDataMapper.java +++ b/script/src/main/java/com/xiang/xservice/stock/gnshyx/mapper/StockGnshyxRecordDataMapper.java @@ -17,4 +17,13 @@ public interface StockGnshyxRecordDataMapper { * @return */ int batchInsertRecord(@Param("list") List entities); + + List getList(); + + + int insert(StockGnshyxRecordDataDO entity); + + StockGnshyxRecordDataDO getByStockCode(@Param("stockCode") String stockCode); + + int update(StockGnshyxRecordDataDO entity); } diff --git a/script/src/main/java/com/xiang/xservice/stock/gnshyx/schedule/CloudRecordDataJob.java b/script/src/main/java/com/xiang/xservice/stock/gnshyx/schedule/CloudRecordDataJob.java index 861ebf8..ee9b909 100644 --- a/script/src/main/java/com/xiang/xservice/stock/gnshyx/schedule/CloudRecordDataJob.java +++ b/script/src/main/java/com/xiang/xservice/stock/gnshyx/schedule/CloudRecordDataJob.java @@ -2,7 +2,6 @@ package com.xiang.xservice.stock.gnshyx.schedule; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; -import com.google.common.collect.Lists; import com.xiang.xservice.basic.utils.DateUtils; import com.xiang.xservice.basic.utils.HttpUtils; import com.xiang.xservice.stock.gnshyx.common.constants.UrlConstant; @@ -18,6 +17,7 @@ import org.springframework.stereotype.Component; import java.time.LocalDateTime; import java.util.List; +import java.util.Objects; @Slf4j @RequiredArgsConstructor @@ -26,7 +26,7 @@ public class CloudRecordDataJob { private final ICloudRecordDataService cloudRecordDataService; - @Scheduled(cron = "0 0/1 * * * ? ") + @Scheduled(cron = "0 30 9,14 * * ?") public void gnshyxRecordDataPullJob() { log.info("<<<<>>>>， 时间戳:{}", System.currentTimeMillis()); @@ -42,28 +42,41 @@ public class CloudRecordDataJob { log.info("查询到的数据结果:{}", data); List dataRespList = JSON.parseArray(data, ListLastDataResp.class); if (CollectionUtils.isNotEmpty(dataRespList)) { - List results = Lists.newArrayList(); for (ListLastDataResp listLastDataResp : dataRespList) { - StockGnshyxRecordDataDO stockGnshyxRecordDataDO = new StockGnshyxRecordDataDO(); - stockGnshyxRecordDataDO.setSymbolName(listLastDataResp.getSymbolName()); - stockGnshyxRecordDataDO.setStockName(listLastDataResp.getStockName()); - stockGnshyxRecordDataDO.setAttentionPrice(listLastDataResp.getAttentionPrice()); - stockGnshyxRecordDataDO.setTargetPriceLow(listLastDataResp.getTargetPriceLow()); - stockGnshyxRecordDataDO.setTargetPriceHigh(listLastDataResp.getTargetPriceHigh()); - stockGnshyxRecordDataDO.setStopPrice(listLastDataResp.getStopPrice()); - stockGnshyxRecordDataDO.setStockDailySelectionId(listLastDataResp.getStockDailySelectionId()); - stockGnshyxRecordDataDO.setStockCode(listLastDataResp.getStockCode()); - stockGnshyxRecordDataDO.setSelectionTime(DateUtils.getDateTimeFromStr(listLastDataResp.getSelectionTime())); - stockGnshyxRecordDataDO.setMaximumIncrease(listLastDataResp.getMaximumIncrease()); - stockGnshyxRecordDataDO.setMaximumIncreaseSeven(listLastDataResp.getMaximumIncreaseSeven()); - stockGnshyxRecordDataDO.setCreateTime(LocalDateTime.now()); - results.add(stockGnshyxRecordDataDO); - } - if (CollectionUtils.isNotEmpty(results)) { - cloudRecordDataService.batchInsertRecord(results); + StockGnshyxRecordDataDO stock = cloudRecordDataService.getByStockCode(listLastDataResp.getStockCode()); + if (Objects.nonNull(stock)) { + stock.setSymbolName(listLastDataResp.getSymbolName()); + stock.setStockName(listLastDataResp.getStockName()); + stock.setAttentionPrice(listLastDataResp.getAttentionPrice()); + stock.setTargetPriceLow(listLastDataResp.getTargetPriceLow()); + stock.setTargetPriceHigh(listLastDataResp.getTargetPriceHigh()); + stock.setStopPrice(listLastDataResp.getStopPrice()); + stock.setStockDailySelectionId(listLastDataResp.getStockDailySelectionId()); + stock.setStockCode(listLastDataResp.getStockCode()); + stock.setSelectionTime(DateUtils.getDateTimeFromStr(listLastDataResp.getSelectionTime())); + stock.setMaximumIncrease(listLastDataResp.getMaximumIncrease()); + stock.setMaximumIncreaseSeven(listLastDataResp.getMaximumIncreaseSeven()); + stock.setCreateTime(LocalDateTime.now()); + cloudRecordDataService.updateRecord(stock); + } else { + StockGnshyxRecordDataDO stockGnshyxRecordDataDO = new StockGnshyxRecordDataDO(); + stockGnshyxRecordDataDO.setSymbolName(listLastDataResp.getSymbolName()); + stockGnshyxRecordDataDO.setStockName(listLastDataResp.getStockName()); + stockGnshyxRecordDataDO.setAttentionPrice(listLastDataResp.getAttentionPrice()); + stockGnshyxRecordDataDO.setTargetPriceLow(listLastDataResp.getTargetPriceLow()); + stockGnshyxRecordDataDO.setTargetPriceHigh(listLastDataResp.getTargetPriceHigh()); + stockGnshyxRecordDataDO.setStopPrice(listLastDataResp.getStopPrice()); + stockGnshyxRecordDataDO.setStockDailySelectionId(listLastDataResp.getStockDailySelectionId()); + stockGnshyxRecordDataDO.setStockCode(listLastDataResp.getStockCode()); + stockGnshyxRecordDataDO.setSelectionTime(DateUtils.getDateTimeFromStr(listLastDataResp.getSelectionTime())); + stockGnshyxRecordDataDO.setMaximumIncrease(listLastDataResp.getMaximumIncrease()); + stockGnshyxRecordDataDO.setMaximumIncreaseSeven(listLastDataResp.getMaximumIncreaseSeven()); + stockGnshyxRecordDataDO.setCreateTime(LocalDateTime.now()); + cloudRecordDataService.insertRecord(stockGnshyxRecordDataDO); + } + } } - } } } diff --git a/script/src/main/java/com/xiang/xservice/stock/gnshyx/service/CloudRecordDataServiceImpl.java b/script/src/main/java/com/xiang/xservice/stock/gnshyx/service/CloudRecordDataServiceImpl.java index 1943794..8c41f28 100644 --- a/script/src/main/java/com/xiang/xservice/stock/gnshyx/service/CloudRecordDataServiceImpl.java +++ b/script/src/main/java/com/xiang/xservice/stock/gnshyx/service/CloudRecordDataServiceImpl.java @@ -11,8 +11,29 @@ import java.util.List; @RequiredArgsConstructor public class CloudRecordDataServiceImpl implements ICloudRecordDataService { private final StockGnshyxRecordDataMapper stockGnshyxRecordDataMapper; + + @Override + public Boolean insertRecord(StockGnshyxRecordDataDO entity) { + return stockGnshyxRecordDataMapper.insert(entity) > 0; + } + @Override public Boolean batchInsertRecord(List list) { return stockGnshyxRecordDataMapper.batchInsertRecord(list) > 0; } + + @Override + public List getList() { + return stockGnshyxRecordDataMapper.getList(); + } + + @Override + public Boolean updateRecord(StockGnshyxRecordDataDO entity) { + return stockGnshyxRecordDataMapper.update(entity) > 0; + } + + @Override + public StockGnshyxRecordDataDO getByStockCode(String stockCode) { + return stockGnshyxRecordDataMapper.getByStockCode(stockCode); + } } diff --git a/script/src/main/java/com/xiang/xservice/stock/gnshyx/service/ICloudRecordDataService.java b/script/src/main/java/com/xiang/xservice/stock/gnshyx/service/ICloudRecordDataService.java index 22e2d6c..a4f0159 100644 --- a/script/src/main/java/com/xiang/xservice/stock/gnshyx/service/ICloudRecordDataService.java +++ b/script/src/main/java/com/xiang/xservice/stock/gnshyx/service/ICloudRecordDataService.java @@ -6,5 +6,13 @@ import java.util.List; public interface ICloudRecordDataService { + Boolean insertRecord(StockGnshyxRecordDataDO entity); + Boolean batchInsertRecord(List list); + + List getList(); + + Boolean updateRecord(StockGnshyxRecordDataDO entity); + + StockGnshyxRecordDataDO getByStockCode(String stockCode); } diff --git a/script/src/main/resources/mapper/stock/StockGnshyxRecordDataMapper.xml b/script/src/main/resources/mapper/stock/StockGnshyxRecordDataMapper.xml index 8e8a70d..f1d63b8 100644 --- a/script/src/main/resources/mapper/stock/StockGnshyxRecordDataMapper.xml +++ b/script/src/main/resources/mapper/stock/StockGnshyxRecordDataMapper.xml @@ -151,6 +151,14 @@ DELETE FROM stock_gnshyx_record_data WHERE id = #{id} + + UPDATE stock_gnshyx_record_data diff --git a/script/src/main/resources/mapper/stock/StockSinaDataRecordPullMapper.xml b/script/src/main/resources/mapper/stock/StockSinaDataRecordPullMapper.xml new file mode 100644 index 0000000..11d8c71 --- /dev/null +++ b/script/src/main/resources/mapper/stock/StockSinaDataRecordPullMapper.xml @@ -0,0 +1,126 @@ + + + + + + + + + + + + + + + + + + + id, + name, + jk_price, + zs_price, + xj_price, + zg_price, + zd_price, + zs_num, + price, + update_time + + + + INSERT INTO stock_sina_record_data + + + name, + + + jk_price, + + + zs_price, + + + xj_price, + + + zg_price, + + + zd_price, + + + zs_num, + + + price, + + + update_time + + + + + #{name}, + + + #{jkPrice}, + + + #{zsPrice}, + + + #{xjPrice}, + + + #{zgPrice}, + + + #{zdPrice}, + + + #{zsNum}, + + + #{price}, + + + #{updateTime} + + + + + INSERT INTO stock_sina_record_data + (name, jk_price, zs_price, xj_price, zg_price, zd_price, zs_num, price, update_time) + VALUES + + (#{item.name}, #{item.jkPrice}, #{item.zsPrice}, #{item.xjPrice}, + #{item.zgPrice}, #{item.zdPrice}, #{item.zsNum}, #{item.price}, #{item.updateTime}) + + + + + DELETE FROM stock_sina_record_data + WHERE id = #{id} + + + + UPDATE stock_sina_record_data + + name = #{name}, + jk_price = #{jkPrice}, + zs_price = #{zsPrice}, + xj_price = #{xjPrice}, + zg_price = #{zgPrice}, + zd_price = #{zdPrice}, + zs_num = #{zsNum}, + price = #{price}, + update_time = #{updateTime} + + WHERE id = #{id} + + + + + \ No newline at end of file