添加投注记录

src/main/java/com/tem/bocai/schedules/BetSchedule.java

@@ -1,6 +1,8 @@
 package com.tem.bocai.schedules;
 
 import com.tem.bocai.service.LoginService;
+import com.tem.bocai.util.TokenCacheService;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -27,18 +29,19 @@ import com.tem.bocai.repository.CompletedTodayRepository;
 import com.tem.bocai.repository.LoginInfoRepository;
 import com.tem.bocai.repository.BetRecordRepository;
 
+@Slf4j
 @Component
 public class BetSchedule {
 
     @Autowired
-    private LoginService loginService;
+    private TokenCacheService tokenCacheService;
 
     @Autowired
     private LoginInfoRepository loginInfoRepository;
 
     @Autowired
     private CompletedTodayRepository completedTodayRepository;
-    
+
     @Autowired
     private BetRecordRepository betRecordRepository;
 
@@ -131,11 +134,11 @@ public class BetSchedule {
             // 1. 获取当前时间，格式化为与betTime相同的格式（假设betTime格式为yyyy-MM-dd HH:mm:ss）
             LocalDateTime now = LocalDateTime.now();
             String currentTime = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
-            
+
             // 2. 从BetRecord中获取最新的一条记录（根据betTime排序，且betTime大于等于当前时间）
             System.out.println("  - 从BetRecord中获取最新的一条记录...");
             Optional<BetRecord> optionalBetRecord = betRecordRepository.findFirstByBetTimeGreaterThanEqualOrderByBetTimeDesc(currentTime);
-            
+
             if (optionalBetRecord.isPresent()) {
                 BetRecord betRecord = optionalBetRecord.get();
                 String betData = betRecord.getBetData();
@@ -174,7 +177,7 @@ public class BetSchedule {
         HttpRequest.Builder requestBuilder = HttpRequest.newBuilder()
                 .uri(URI.create(apiUrl))
                 .header("Content-Type", "application/json")
-                .header("cookie", "token=" + loginService.completedToday());
+                .header("cookie", "token=" + tokenCacheService.getToken());
 
         HttpRequest request = requestBuilder
                 .POST(HttpRequest.BodyPublishers.ofString(betData))
@@ -185,8 +188,9 @@ public class BetSchedule {
 
         // 解析响应
         if (response.statusCode() == 200) {
-            JSONObject responseBody = new JSONObject(response.body());
-            return responseBody.getString("result");
+
+            log.info("投注成功");
+            return null;
         } else {
             return "error: " + response.statusCode();
         }

src/main/java/com/tem/bocai/schedules/GenBetRecordSchedule.java

@@ -34,7 +34,7 @@ public class GenBetRecordSchedule {
     }
 
     // 每天6:30执行
-    @Scheduled(cron = "0 30 6 * * ?")
+//    @Scheduled(cron = "0 30 6 * * ?")
     public void processBetPredictions() {
         LocalDateTime now = LocalDateTime.now();
         String currentTime = now.format(