diff --git a/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundCountJob.java b/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundCountJob.java index f72220b..baaa917 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundCountJob.java +++ b/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundCountJob.java @@ -1,105 +1,105 @@ -package com.xiang.xservice.application.script.xb.schedule.xb; - -import com.alibaba.fastjson2.JSONObject; -import com.google.common.collect.Lists; -import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundCount; -import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundList; -import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundList; -import com.xiang.xservice.application.script.xb.service.FundService; -import com.xiang.xservice.basic.utils.DateUtils; -import com.xiang.xservice.common.service.dingTalk.StockDingTalkFactory; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.apache.commons.collections4.CollectionUtils; -import org.apache.commons.lang3.StringUtils; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Component; -import org.springframework.web.bind.annotation.RestController; - -import java.math.BigDecimal; -import java.math.RoundingMode; -import java.time.DayOfWeek; -import java.time.LocalDate; -import java.time.LocalDateTime; -import java.time.format.DateTimeFormatter; -import java.util.Collections; -import java.util.List; -import java.util.Map; -import java.util.Objects; -import java.util.stream.Collectors; - -/** - * @Author: xiang - * @Date: 2025-05-21 13:59 - */ -@Component -@RequiredArgsConstructor -@Slf4j -@RestController -public class FundCountJob { - - private final FundService fundService; - private final StockDingTalkFactory dingTalkService; - @Scheduled(cron = "0 0 22 * * ?") - public void countFundJob() { - // 周六周日过滤 - if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || - Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { - return; - } - log.info("==========================[基金统计] 基金统计定时任务启动！=========================="); - List lists = fundService.queryFundList(); - if (CollectionUtils.isEmpty(lists)) { - return; - } - List counts = Lists.newCopyOnWriteArrayList(); - String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); - lists.parallelStream().forEach(xbFundList -> { - List fund = fundService.queryTodayList(date, "2", Boolean.TRUE, Collections.singletonList(xbFundList.getCode())); - if (CollectionUtils.isNotEmpty(fund)) { - XbFundCount xbFundCount = new XbFundCount(); - xbFundCount.setLId(xbFundList.getId()); - xbFundCount.setCode(xbFundList.getCode()); - xbFundCount.setName(xbFundList.getName()); - xbFundCount.setChange(fund.get(0).getChange().multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP)); - xbFundCount.setUpdateTime(LocalDateTime.now()); - counts.add(xbFundCount); - } - }); - if (CollectionUtils.isNotEmpty(counts)) { - log.info("[基金统计] 基金统计记录，需要插入的数据:{}", JSONObject.toJSONString(counts)); - fundService.addCounts(counts); - } - log.info("==========================[基金统计] 基金统计定时任务结束！=========================="); - } - - @Scheduled(cron = "0 40 14 * * ? ") - public void countFundInWeek() throws Exception { - if (DateUtils.validWeekTime()) return; - log.info("==========================[基金统计] 基金本周涨跌幅消息发送定时任务启动！=========================="); - List xbFundCounts = fundService.queryFundCountInWeek(); - if (CollectionUtils.isEmpty(xbFundCounts)) { - return; - } - StringBuilder sb = new StringBuilder(); - Map> map = xbFundCounts.stream().collect(Collectors.groupingBy(XbFundCount::getCode)); - map.forEach((k, v) -> { - List fundCounts = map.get(k); - if (CollectionUtils.isEmpty(fundCounts)) { - return; - } - List decimals = fundCounts.stream().map(XbFundCount::getChange).collect(Collectors.toList()); - BigDecimal sum = BigDecimal.ZERO; - for (BigDecimal decimal : decimals) { - sum = sum.add(decimal); - } - BigDecimal avg = sum.divide(BigDecimal.valueOf(decimals.size()), 2, RoundingMode.HALF_UP); - sb.append("【").append(fundCounts.get(0).getName()).append("】本周平均涨跌幅为：").append(avg).append("\n"); - }); - if (StringUtils.isNotBlank(sb)) { - dingTalkService.sendMsg(sb.toString()); - } - log.info("==========================[基金统计] 基金本周涨跌幅消息发送定时任务结束！=========================="); - } - -} +//package com.xiang.xservice.application.script.xb.schedule.xb; +// +//import com.alibaba.fastjson2.JSONObject; +//import com.google.common.collect.Lists; +//import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundCount; +//import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundList; +//import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundList; +//import com.xiang.xservice.application.script.xb.service.FundService; +//import com.xiang.xservice.basic.utils.DateUtils; +//import com.xiang.xservice.common.service.dingTalk.StockDingTalkFactory; +//import lombok.RequiredArgsConstructor; +//import lombok.extern.slf4j.Slf4j; +//import org.apache.commons.collections4.CollectionUtils; +//import org.apache.commons.lang3.StringUtils; +//import org.springframework.scheduling.annotation.Scheduled; +//import org.springframework.stereotype.Component; +//import org.springframework.web.bind.annotation.RestController; +// +//import java.math.BigDecimal; +//import java.math.RoundingMode; +//import java.time.DayOfWeek; +//import java.time.LocalDate; +//import java.time.LocalDateTime; +//import java.time.format.DateTimeFormatter; +//import java.util.Collections; +//import java.util.List; +//import java.util.Map; +//import java.util.Objects; +//import java.util.stream.Collectors; +// +///** +// * @Author: xiang +// * @Date: 2025-05-21 13:59 +// */ +//@Component +//@RequiredArgsConstructor +//@Slf4j +//@RestController +//public class FundCountJob { +// +// private final FundService fundService; +// private final StockDingTalkFactory dingTalkService; +// @Scheduled(cron = "0 0 22 * * ?") +// public void countFundJob() { +// // 周六周日过滤 +// if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || +// Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { +// return; +// } +// log.info("==========================[基金统计] 基金统计定时任务启动！=========================="); +// List lists = fundService.queryFundList(); +// if (CollectionUtils.isEmpty(lists)) { +// return; +// } +// List counts = Lists.newCopyOnWriteArrayList(); +// String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); +// lists.parallelStream().forEach(xbFundList -> { +// List fund = fundService.queryTodayList(date, "2", Boolean.TRUE, Collections.singletonList(xbFundList.getCode())); +// if (CollectionUtils.isNotEmpty(fund)) { +// XbFundCount xbFundCount = new XbFundCount(); +// xbFundCount.setLId(xbFundList.getId()); +// xbFundCount.setCode(xbFundList.getCode()); +// xbFundCount.setName(xbFundList.getName()); +// xbFundCount.setChange(fund.get(0).getChange().multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP)); +// xbFundCount.setUpdateTime(LocalDateTime.now()); +// counts.add(xbFundCount); +// } +// }); +// if (CollectionUtils.isNotEmpty(counts)) { +// log.info("[基金统计] 基金统计记录，需要插入的数据:{}", JSONObject.toJSONString(counts)); +// fundService.addCounts(counts); +// } +// log.info("==========================[基金统计] 基金统计定时任务结束！=========================="); +// } +// +// @Scheduled(cron = "0 40 14 * * ? ") +// public void countFundInWeek() throws Exception { +// if (DateUtils.validWeekTime()) return; +// log.info("==========================[基金统计] 基金本周涨跌幅消息发送定时任务启动！=========================="); +// List xbFundCounts = fundService.queryFundCountInWeek(); +// if (CollectionUtils.isEmpty(xbFundCounts)) { +// return; +// } +// StringBuilder sb = new StringBuilder(); +// Map> map = xbFundCounts.stream().collect(Collectors.groupingBy(XbFundCount::getCode)); +// map.forEach((k, v) -> { +// List fundCounts = map.get(k); +// if (CollectionUtils.isEmpty(fundCounts)) { +// return; +// } +// List decimals = fundCounts.stream().map(XbFundCount::getChange).collect(Collectors.toList()); +// BigDecimal sum = BigDecimal.ZERO; +// for (BigDecimal decimal : decimals) { +// sum = sum.add(decimal); +// } +// BigDecimal avg = sum.divide(BigDecimal.valueOf(decimals.size()), 2, RoundingMode.HALF_UP); +// sb.append("【").append(fundCounts.get(0).getName()).append("】本周平均涨跌幅为：").append(avg).append("\n"); +// }); +// if (StringUtils.isNotBlank(sb)) { +// dingTalkService.sendMsg(sb.toString()); +// } +// log.info("==========================[基金统计] 基金本周涨跌幅消息发送定时任务结束！=========================="); +// } +// +//} diff --git a/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundInfoQueryJob.java b/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundInfoQueryJob.java index 8f6fa89..bf033a1 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundInfoQueryJob.java +++ b/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundInfoQueryJob.java @@ -1,134 +1,134 @@ -package com.xiang.xservice.application.script.xb.schedule.xb; - -import com.alibaba.fastjson2.JSONObject; -import com.google.common.collect.Lists; -import com.xiang.xservice.application.script.xb.entity.pojo.xb.FundMessage; -import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundList; -import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundInfo; -import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundList; -import com.xiang.xservice.application.script.xb.repository.XBFundMapper; -import com.xiang.xservice.application.script.xb.service.FundService; -import com.xiang.xservice.basic.config.MyThreadFactory; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.apache.commons.collections4.CollectionUtils; -import org.springframework.beans.factory.annotation.Value; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Component; - -import java.math.BigDecimal; -import java.math.RoundingMode; -import java.time.DayOfWeek; -import java.time.LocalDate; -import java.time.LocalDateTime; -import java.time.format.DateTimeFormatter; -import java.util.Arrays; -import java.util.List; -import java.util.Objects; -import java.util.concurrent.CompletableFuture; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.LinkedBlockingQueue; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; -import java.util.stream.Collectors; - -/** - * @Author: xiang - * @Date: 2025-05-14 17:15 - */ -@Component -@RequiredArgsConstructor -@Slf4j -public class FundInfoQueryJob { - - private final FundService fundService; - private final XBFundMapper xbFundMapper; - private final ExecutorService es = - new ThreadPoolExecutor( - 10, - 20, - 1000, - TimeUnit.MILLISECONDS, - new LinkedBlockingQueue<>(), - new MyThreadFactory("xb-query-thread", Boolean.TRUE), - new ThreadPoolExecutor.AbortPolicy()); - @Value("${xiaobei.codeArr}") - private String codeArr; - - - /** - * 基金每分钟涨幅记录 - */ - @Scheduled(cron = "0 0/1 9,10,11,13,14 * * ?") - public void queryFundInfoInMinJob() { - // 周六周日过滤 - if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || - Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { - return; - } - List fundMessageList = queryFund(null); - if (CollectionUtils.isEmpty(fundMessageList)) { - return; - } - List futures = Lists.newArrayList(); - List fundInfoList = Lists.newCopyOnWriteArrayList(); - fundMessageList.parallelStream().forEach(fundMessage -> { - CompletableFuture future = CompletableFuture.runAsync(() -> { - FundInfo fundInfo = fundService.queryFundInfo(fundMessage.getCode()); - - com.xiang.xservice.application.script.xb.entity.pojo.xb.FundInfo info = com.xiang.xservice.application.script.xb.entity.pojo.xb.FundInfo.builder() - .code(fundMessage.getCode()) - .name(fundInfo.getName()) - .change(fundMessage.getChange().multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toString()) - .updateTime(getTimeFromStr(fundMessage.getDate(), fundMessage.getUpdate())) - .build(); - fundInfoList.add(info); - }, es); - futures.add(future); - }); - - CompletableFuture[] futureArr = futures - .toArray(futures.toArray(new CompletableFuture[0])); - CompletableFuture.allOf(futureArr).join(); - - if (CollectionUtils.isNotEmpty(fundInfoList)) { - log.info("[基金查询] 每分钟基金涨跌幅查询记录，需要插入的数据:{}", JSONObject.toJSONString(fundInfoList)); - xbFundMapper.batchSave(fundInfoList); - } - } - - private List queryFund(Integer type) { - String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); - List code = Lists.newArrayList(); - List lists = xbFundMapper.queryFundList(type); - if (CollectionUtils.isEmpty(lists)) { - if (Objects.equals(type, 1)) { - code = Arrays.stream(codeArr.split(", ")).collect(Collectors.toList()); - } - return Lists.newArrayList(); - } else { - code = lists.stream().map(XbFundList::getCode).collect(Collectors.toList()); - } - List fundLists = fundService.queryTodayList(date, "2", Boolean.TRUE, code); - if (CollectionUtils.isEmpty(fundLists)) { - return Lists.newArrayList(); - } - List result = Lists.newCopyOnWriteArrayList(); - fundLists.parallelStream().forEach(fundList -> { - FundInfo fundInfo = fundService.queryFundInfo(fundList.getCode()); - if (Objects.nonNull(fundInfo)) { - FundMessage fund = FundMessage.builder().name(fundInfo.getName()).date(fundList.getDate()) - .code(fundList.getCode()).change(fundList.getChange()).update(fundList.getUpdate()).build(); - result.add(fund); - } - }); - return result; - } - - private LocalDateTime getTimeFromStr(String date, String time) { - String dateTimeStr = date + " " + time; - DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); - return LocalDateTime.parse(dateTimeStr, formatter); - } - -} +//package com.xiang.xservice.application.script.xb.schedule.xb; +// +//import com.alibaba.fastjson2.JSONObject; +//import com.google.common.collect.Lists; +//import com.xiang.xservice.application.script.xb.entity.pojo.xb.FundMessage; +//import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundList; +//import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundInfo; +//import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundList; +//import com.xiang.xservice.application.script.xb.repository.XBFundMapper; +//import com.xiang.xservice.application.script.xb.service.FundService; +//import com.xiang.xservice.basic.config.MyThreadFactory; +//import lombok.RequiredArgsConstructor; +//import lombok.extern.slf4j.Slf4j; +//import org.apache.commons.collections4.CollectionUtils; +//import org.springframework.beans.factory.annotation.Value; +//import org.springframework.scheduling.annotation.Scheduled; +//import org.springframework.stereotype.Component; +// +//import java.math.BigDecimal; +//import java.math.RoundingMode; +//import java.time.DayOfWeek; +//import java.time.LocalDate; +//import java.time.LocalDateTime; +//import java.time.format.DateTimeFormatter; +//import java.util.Arrays; +//import java.util.List; +//import java.util.Objects; +//import java.util.concurrent.CompletableFuture; +//import java.util.concurrent.ExecutorService; +//import java.util.concurrent.LinkedBlockingQueue; +//import java.util.concurrent.ThreadPoolExecutor; +//import java.util.concurrent.TimeUnit; +//import java.util.stream.Collectors; +// +///** +// * @Author: xiang +// * @Date: 2025-05-14 17:15 +// */ +//@Component +//@RequiredArgsConstructor +//@Slf4j +//public class FundInfoQueryJob { +// +// private final FundService fundService; +// private final XBFundMapper xbFundMapper; +// private final ExecutorService es = +// new ThreadPoolExecutor( +// 10, +// 20, +// 1000, +// TimeUnit.MILLISECONDS, +// new LinkedBlockingQueue<>(), +// new MyThreadFactory("xb-query-thread", Boolean.TRUE), +// new ThreadPoolExecutor.AbortPolicy()); +// @Value("${xiaobei.codeArr}") +// private String codeArr; +// +// +// /** +// * 基金每分钟涨幅记录 +// */ +// @Scheduled(cron = "0 0/1 9,10,11,13,14 * * ?") +// public void queryFundInfoInMinJob() { +// // 周六周日过滤 +// if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || +// Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { +// return; +// } +// List fundMessageList = queryFund(null); +// if (CollectionUtils.isEmpty(fundMessageList)) { +// return; +// } +// List futures = Lists.newArrayList(); +// List fundInfoList = Lists.newCopyOnWriteArrayList(); +// fundMessageList.parallelStream().forEach(fundMessage -> { +// CompletableFuture future = CompletableFuture.runAsync(() -> { +// FundInfo fundInfo = fundService.queryFundInfo(fundMessage.getCode()); +// +// com.xiang.xservice.application.script.xb.entity.pojo.xb.FundInfo info = com.xiang.xservice.application.script.xb.entity.pojo.xb.FundInfo.builder() +// .code(fundMessage.getCode()) +// .name(fundInfo.getName()) +// .change(fundMessage.getChange().multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toString()) +// .updateTime(getTimeFromStr(fundMessage.getDate(), fundMessage.getUpdate())) +// .build(); +// fundInfoList.add(info); +// }, es); +// futures.add(future); +// }); +// +// CompletableFuture[] futureArr = futures +// .toArray(futures.toArray(new CompletableFuture[0])); +// CompletableFuture.allOf(futureArr).join(); +// +// if (CollectionUtils.isNotEmpty(fundInfoList)) { +// log.info("[基金查询] 每分钟基金涨跌幅查询记录，需要插入的数据:{}", JSONObject.toJSONString(fundInfoList)); +// xbFundMapper.batchSave(fundInfoList); +// } +// } +// +// private List queryFund(Integer type) { +// String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); +// List code = Lists.newArrayList(); +// List lists = xbFundMapper.queryFundList(type); +// if (CollectionUtils.isEmpty(lists)) { +// if (Objects.equals(type, 1)) { +// code = Arrays.stream(codeArr.split(", ")).collect(Collectors.toList()); +// } +// return Lists.newArrayList(); +// } else { +// code = lists.stream().map(XbFundList::getCode).collect(Collectors.toList()); +// } +// List fundLists = fundService.queryTodayList(date, "2", Boolean.TRUE, code); +// if (CollectionUtils.isEmpty(fundLists)) { +// return Lists.newArrayList(); +// } +// List result = Lists.newCopyOnWriteArrayList(); +// fundLists.parallelStream().forEach(fundList -> { +// FundInfo fundInfo = fundService.queryFundInfo(fundList.getCode()); +// if (Objects.nonNull(fundInfo)) { +// FundMessage fund = FundMessage.builder().name(fundInfo.getName()).date(fundList.getDate()) +// .code(fundList.getCode()).change(fundList.getChange()).update(fundList.getUpdate()).build(); +// result.add(fund); +// } +// }); +// return result; +// } +// +// private LocalDateTime getTimeFromStr(String date, String time) { +// String dateTimeStr = date + " " + time; +// DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); +// return LocalDateTime.parse(dateTimeStr, formatter); +// } +// +//} diff --git a/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundMsgReportJob.java b/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundMsgReportJob.java index 65139cd..456c104 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundMsgReportJob.java +++ b/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundMsgReportJob.java @@ -1,144 +1,144 @@ -package com.xiang.xservice.application.script.xb.schedule.xb; - -import com.alibaba.fastjson.JSON; -import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundList; -import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundList; -import com.xiang.xservice.application.script.xb.service.FundService; -import com.xiang.xservice.common.service.dingTalk.StockDingTalkFactory; -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 org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RestController; - -import java.math.BigDecimal; -import java.math.RoundingMode; -import java.time.DayOfWeek; -import java.time.LocalDate; -import java.time.LocalDateTime; -import java.time.format.DateTimeFormatter; -import java.util.ArrayList; -import java.util.Comparator; -import java.util.List; -import java.util.Map; -import java.util.Objects; -import java.util.function.Function; -import java.util.stream.Collectors; - -/** - * @Author: xiang - * @Date: 2025-07-31 18:10 - */ -@Component -@Slf4j -@RestController -@RequiredArgsConstructor -public class FundMsgReportJob { - - private final FundService fundService; - private final StockDingTalkFactory dingTalkService; - private static final Integer TYPE_A = 1; - private static final Integer TYPE_M = 3; - private static final Integer TYPE_G = 2; - - @Scheduled(cron = "0 1,31 9,10,11,13,14 * * ?") - @PostMapping("/asdasda") - public void fundReport4A() { - log.info("===========A股基金变化通知！==========="); - // 周六周日过滤 - if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || - Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { - log.info("当前时间为：{}", LocalDateTime.now()); - return; - } - List fundLists = fundService.queryFundList(TYPE_A); - if (CollectionUtils.isEmpty(fundLists)) { - log.info("查询配置的A股信息为空"); - return; - } - Map fundMap = fundLists.stream().collect(Collectors.toMap(XbFundList::getCode, Function.identity(), (a, b) -> a)); - String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); - List funds = fundService.queryTodayList(date, "2", Boolean.TRUE, new ArrayList<>(fundMap.keySet())); - if (CollectionUtils.isEmpty(funds)) { - log.info("http请求查询基金信息为空"); - return; - } - log.info("http查询基金信息:{}", JSON.toJSONString(funds)); - StringBuilder msg = new StringBuilder(date).append("===》A股基金变化通知:\n"); - buildMsg(funds, fundMap, msg); - dingTalkService.sendMsg(msg.toString()); - } - - @Scheduled(cron = "0 1,31 9,10,11,13,14,15 * * ?") - public void fundReport4G() { - log.info("===========港股基金变化通知！==========="); - // 周六周日过滤 - if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || - Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { - log.info("当前时间为：{}", LocalDateTime.now()); - return; - } - List fundLists = fundService.queryFundList(TYPE_G); - if (CollectionUtils.isEmpty(fundLists)) { - log.info("查询配置的港股信息为空"); - return; - } - Map fundMap = fundLists.stream().collect(Collectors.toMap(XbFundList::getCode, Function.identity(), (a, b) -> a)); - String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); - List funds = fundService.queryTodayList(date, "2", Boolean.TRUE, new ArrayList<>(fundMap.keySet())); - if (CollectionUtils.isEmpty(funds)) { - log.info("http请求查询基金信息为空"); - return; - } - log.info("http查询港股基金信息:{}", JSON.toJSONString(funds)); - StringBuilder msg = new StringBuilder(date).append("===》港股基金变化通知:\n"); - buildMsg(funds, fundMap, msg); - dingTalkService.sendMsg(msg.toString()); - } - - @Scheduled(cron = "0 0 9 * * ?") - public void fundReport4M() { - log.info("===========美股基金变化通知！==========="); - // 周六周日过滤 - if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || - Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { - log.info("当前时间为：{}", LocalDateTime.now()); - return; - } - List fundLists = fundService.queryFundList(TYPE_M); - if (CollectionUtils.isEmpty(fundLists)) { - log.info("查询配置的美股信息为空"); - return; - } - Map fundMap = fundLists.stream().collect(Collectors.toMap(XbFundList::getCode, Function.identity(), (a, b) -> a)); - String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); - List funds = fundService.queryTodayList(date, "2", Boolean.TRUE, new ArrayList<>(fundMap.keySet())); - if (CollectionUtils.isEmpty(funds)) { - log.info("http请求查询基金信息为空"); - return; - } - log.info("http查询美股基金信息:{}", JSON.toJSONString(funds)); - StringBuilder msg = new StringBuilder(date).append("===》美股基金变化通知:\n"); - buildMsg(funds, fundMap, msg); - dingTalkService.sendMsg(msg.toString()); - } - - private static void buildMsg(List funds, Map fundMap, StringBuilder msg) { - funds = funds.stream().sorted(Comparator.comparing(FundList::getChange).reversed()) - .collect(Collectors.toList()); - for (FundList fund : funds) { - if (fundMap.containsKey(fund.getCode())) { - XbFundList fundList = fundMap.get(fund.getCode()); - msg.append("基金名称:") - .append(fundList.getName()) - .append("涨跌幅:") - .append(fund.getChange() - .multiply(new BigDecimal("100")) - .setScale(2, RoundingMode.HALF_UP)) - .append("\n"); - } - } - } -} +//package com.xiang.xservice.application.script.xb.schedule.xb; +// +//import com.alibaba.fastjson.JSON; +//import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundList; +//import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundList; +//import com.xiang.xservice.application.script.xb.service.FundService; +//import com.xiang.xservice.common.service.dingTalk.StockDingTalkFactory; +//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 org.springframework.web.bind.annotation.PostMapping; +//import org.springframework.web.bind.annotation.RestController; +// +//import java.math.BigDecimal; +//import java.math.RoundingMode; +//import java.time.DayOfWeek; +//import java.time.LocalDate; +//import java.time.LocalDateTime; +//import java.time.format.DateTimeFormatter; +//import java.util.ArrayList; +//import java.util.Comparator; +//import java.util.List; +//import java.util.Map; +//import java.util.Objects; +//import java.util.function.Function; +//import java.util.stream.Collectors; +// +///** +// * @Author: xiang +// * @Date: 2025-07-31 18:10 +// */ +//@Component +//@Slf4j +//@RestController +//@RequiredArgsConstructor +//public class FundMsgReportJob { +// +// private final FundService fundService; +// private final StockDingTalkFactory dingTalkService; +// private static final Integer TYPE_A = 1; +// private static final Integer TYPE_M = 3; +// private static final Integer TYPE_G = 2; +// +// @Scheduled(cron = "0 1,31 9,10,11,13,14 * * ?") +// @PostMapping("/asdasda") +// public void fundReport4A() { +// log.info("===========A股基金变化通知！==========="); +// // 周六周日过滤 +// if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || +// Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { +// log.info("当前时间为：{}", LocalDateTime.now()); +// return; +// } +// List fundLists = fundService.queryFundList(TYPE_A); +// if (CollectionUtils.isEmpty(fundLists)) { +// log.info("查询配置的A股信息为空"); +// return; +// } +// Map fundMap = fundLists.stream().collect(Collectors.toMap(XbFundList::getCode, Function.identity(), (a, b) -> a)); +// String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); +// List funds = fundService.queryTodayList(date, "2", Boolean.TRUE, new ArrayList<>(fundMap.keySet())); +// if (CollectionUtils.isEmpty(funds)) { +// log.info("http请求查询基金信息为空"); +// return; +// } +// log.info("http查询基金信息:{}", JSON.toJSONString(funds)); +// StringBuilder msg = new StringBuilder(date).append("===》A股基金变化通知:\n"); +// buildMsg(funds, fundMap, msg); +// dingTalkService.sendMsg(msg.toString()); +// } +// +// @Scheduled(cron = "0 1,31 9,10,11,13,14,15 * * ?") +// public void fundReport4G() { +// log.info("===========港股基金变化通知！==========="); +// // 周六周日过滤 +// if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || +// Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { +// log.info("当前时间为：{}", LocalDateTime.now()); +// return; +// } +// List fundLists = fundService.queryFundList(TYPE_G); +// if (CollectionUtils.isEmpty(fundLists)) { +// log.info("查询配置的港股信息为空"); +// return; +// } +// Map fundMap = fundLists.stream().collect(Collectors.toMap(XbFundList::getCode, Function.identity(), (a, b) -> a)); +// String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); +// List funds = fundService.queryTodayList(date, "2", Boolean.TRUE, new ArrayList<>(fundMap.keySet())); +// if (CollectionUtils.isEmpty(funds)) { +// log.info("http请求查询基金信息为空"); +// return; +// } +// log.info("http查询港股基金信息:{}", JSON.toJSONString(funds)); +// StringBuilder msg = new StringBuilder(date).append("===》港股基金变化通知:\n"); +// buildMsg(funds, fundMap, msg); +// dingTalkService.sendMsg(msg.toString()); +// } +// +// @Scheduled(cron = "0 0 9 * * ?") +// public void fundReport4M() { +// log.info("===========美股基金变化通知！==========="); +// // 周六周日过滤 +// if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) || +// Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) { +// log.info("当前时间为：{}", LocalDateTime.now()); +// return; +// } +// List fundLists = fundService.queryFundList(TYPE_M); +// if (CollectionUtils.isEmpty(fundLists)) { +// log.info("查询配置的美股信息为空"); +// return; +// } +// Map fundMap = fundLists.stream().collect(Collectors.toMap(XbFundList::getCode, Function.identity(), (a, b) -> a)); +// String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); +// List funds = fundService.queryTodayList(date, "2", Boolean.TRUE, new ArrayList<>(fundMap.keySet())); +// if (CollectionUtils.isEmpty(funds)) { +// log.info("http请求查询基金信息为空"); +// return; +// } +// log.info("http查询美股基金信息:{}", JSON.toJSONString(funds)); +// StringBuilder msg = new StringBuilder(date).append("===》美股基金变化通知:\n"); +// buildMsg(funds, fundMap, msg); +// dingTalkService.sendMsg(msg.toString()); +// } +// +// private static void buildMsg(List funds, Map fundMap, StringBuilder msg) { +// funds = funds.stream().sorted(Comparator.comparing(FundList::getChange).reversed()) +// .collect(Collectors.toList()); +// for (FundList fund : funds) { +// if (fundMap.containsKey(fund.getCode())) { +// XbFundList fundList = fundMap.get(fund.getCode()); +// msg.append("基金名称:") +// .append(fundList.getName()) +// .append("涨跌幅:") +// .append(fund.getChange() +// .multiply(new BigDecimal("100")) +// .setScale(2, RoundingMode.HALF_UP)) +// .append("\n"); +// } +// } +// } +//}