From bd54e68039b74191eeff7fe0786528e7ed2785c1 Mon Sep 17 00:00:00 2001
From: xiang <xiang@example.com>
Date: Sat, 23 Aug 2025 14:10:45 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E5=91=A8=E5=B9=B3=E5=9D=87=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=20bug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/xiang/xservice/xb/repository/XBFundMapper.java    | 1 +
 .../com/xiang/xservice/xb/schedule/xb/FundCountJob.java   | 8 ++++++--
 .../java/com/xiang/xservice/xb/service/FundService.java   | 1 +
 .../com/xiang/xservice/xb/service/FundServiceImpl.java    | 5 +++++
 script/src/main/resources/mapper/xb/XBFundMapper.xml      | 3 +++
 5 files changed, 16 insertions(+), 2 deletions(-)

diff --git a/script/src/main/java/com/xiang/xservice/xb/repository/XBFundMapper.java b/script/src/main/java/com/xiang/xservice/xb/repository/XBFundMapper.java
index fa91778..dabc3d0 100644
--- a/script/src/main/java/com/xiang/xservice/xb/repository/XBFundMapper.java
+++ b/script/src/main/java/com/xiang/xservice/xb/repository/XBFundMapper.java
@@ -22,6 +22,7 @@ public interface XBFundMapper {
     int batchSave(List<FundInfo> list);
 
     List<XbFundList> queryFundList(@Param("type") Integer type);
+    List<XbFundList> queryAllFundList();
 
     int addCounts(List<XbFundCount> list);
 
diff --git a/script/src/main/java/com/xiang/xservice/xb/schedule/xb/FundCountJob.java b/script/src/main/java/com/xiang/xservice/xb/schedule/xb/FundCountJob.java
index 04f7b32..956f717 100644
--- a/script/src/main/java/com/xiang/xservice/xb/schedule/xb/FundCountJob.java
+++ b/script/src/main/java/com/xiang/xservice/xb/schedule/xb/FundCountJob.java
@@ -13,6 +13,8 @@ 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.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
@@ -33,6 +35,7 @@ import java.util.stream.Collectors;
 @Component
 @RequiredArgsConstructor
 @Slf4j
+@RestController
 public class FundCountJob {
 
     private final FundService fundService;
@@ -45,7 +48,7 @@ public class FundCountJob {
             return;
         }
         log.info("==========================[基金统计] 基金统计定时任务启动！==========================");
-        List<XbFundList> lists = fundService.queryFundList(null);
+        List<XbFundList> lists = fundService.queryFundList();
         if (CollectionUtils.isEmpty(lists)) {
             return;
         }
@@ -71,6 +74,7 @@ public class FundCountJob {
     }
 
     @Scheduled(cron = "0 40 14 * * ? ")
+    @PostMapping("/ddddd")
     public void countFundInWeek() throws Exception {
         log.info("==========================[基金统计] 基金本周涨跌幅消息发送定时任务启动！==========================");
         List<XbFundCount> xbFundCounts = fundService.queryFundCountInWeek();
@@ -81,7 +85,7 @@ public class FundCountJob {
         Map<String, List<XbFundCount>> map = xbFundCounts.stream().collect(Collectors.groupingBy(XbFundCount::getCode));
         map.forEach((k, v) -> {
             List<XbFundCount> fundCounts = map.get(k);
-            if (CollectionUtils.isNotEmpty(fundCounts)) {
+            if (CollectionUtils.isEmpty(fundCounts)) {
                 return;
             }
             List<BigDecimal> decimals = fundCounts.stream().map(XbFundCount::getChange).collect(Collectors.toList());
diff --git a/script/src/main/java/com/xiang/xservice/xb/service/FundService.java b/script/src/main/java/com/xiang/xservice/xb/service/FundService.java
index 277b01c..afeee54 100644
--- a/script/src/main/java/com/xiang/xservice/xb/service/FundService.java
+++ b/script/src/main/java/com/xiang/xservice/xb/service/FundService.java
@@ -31,6 +31,7 @@ public interface FundService {
      * @return
      */
     List<XbFundList> queryFundList(Integer type);
+    List<XbFundList> queryFundList();
 
     int addCounts(List<XbFundCount> list);
 
diff --git a/script/src/main/java/com/xiang/xservice/xb/service/FundServiceImpl.java b/script/src/main/java/com/xiang/xservice/xb/service/FundServiceImpl.java
index fd0fb75..2d5f1b3 100644
--- a/script/src/main/java/com/xiang/xservice/xb/service/FundServiceImpl.java
+++ b/script/src/main/java/com/xiang/xservice/xb/service/FundServiceImpl.java
@@ -99,6 +99,11 @@ public class FundServiceImpl implements FundService{
         return xbFundMapper.queryFundList(type);
     }
 
+    @Override
+    public List<XbFundList> queryFundList() {
+        return xbFundMapper.queryAllFundList();
+    }
+
     @Override
     public int addCounts(List<XbFundCount> list) {
         return xbFundMapper.addCounts(list);
diff --git a/script/src/main/resources/mapper/xb/XBFundMapper.xml b/script/src/main/resources/mapper/xb/XBFundMapper.xml
index 09effde..6102915 100644
--- a/script/src/main/resources/mapper/xb/XBFundMapper.xml
+++ b/script/src/main/resources/mapper/xb/XBFundMapper.xml
@@ -54,6 +54,9 @@
         select * from xb_fund_count
         where update_time between NOW() - INTERVAL 7 DAY and NOW()
     </select>
+    <select id="queryAllFundList" resultMap="XbFundListMap" parameterType="Integer">
+        select * from xb_fund_list where 1=1
+    </select>
 
 
 </mapper>
\ No newline at end of file