update Transactional control

Author: YukiRinLL

.idea/workspace.xml

@@ -14,7 +14,7 @@ public class SchedulingConfig {
     @Bean
     public ThreadPoolTaskScheduler taskScheduler() {
         ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
-        scheduler.setPoolSize(5); // 核心线程数5，避免单线程阻塞
+        scheduler.setPoolSize(10); // 核心线程数10，避免单线程阻塞
         scheduler.setThreadNamePrefix("FF14-Scheduler-");
         scheduler.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
         scheduler.setWaitForTasksToCompleteOnShutdown(true);

src/main/java/com/phantoms/phantomsbackend/common/config/SchedulingConfig.java

@@ -13,6 +13,7 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StopWatch;
 
 import java.time.LocalDateTime;
@@ -99,6 +100,7 @@ public class DataSyncScheduler {
     private com.phantoms.phantomsbackend.repository.secondary.SecondaryExpeditionaryTeamRepository secondaryExpeditionaryTeamRepository;
 
     @Scheduled(fixedRate = 600000) // 每10分钟执行一次
+    @Transactional(timeout = 300)
     public void syncData() {
         StopWatch totalStopWatch = new StopWatch("TotalSync");
         totalStopWatch.start("total-sync");
@@ -252,41 +254,29 @@ private List<com.phantoms.phantomsbackend.pojo.entity.secondary.onebot.ChatRecor
     }
 
     /**
-     * 优化后的批量插入方法
+     * 优化后的批量插入方法 - 使用 Spring 事务管理
      */
+    @Transactional(timeout = 120) // 2分钟超时
     private void batchInsertOptimized(List<com.phantoms.phantomsbackend.pojo.entity.secondary.onebot.ChatRecord> records) {
         if (records.isEmpty()) {
             return;
         }
 
-        EntityManager entityManager = entityManagerFactory.createEntityManager();
-        EntityTransaction transaction = entityManager.getTransaction();
-
         try {
-            transaction.begin();
-
+            // 使用 Spring Data JPA 的批量保存
             for (int i = 0; i < records.size(); i++) {
-                entityManager.persist(records.get(i));
+                secondaryChatRecordRepository.save(records.get(i));
 
                 // 分批刷新，避免内存溢出
                 if ((i + 1) % INSERT_BATCH_SIZE == 0) {
-                    entityManager.flush();
-                    entityManager.clear();
+                    secondaryChatRecordRepository.flush();
                 }
             }
-
-            entityManager.flush();
-            entityManager.clear();
-            transaction.commit();
+            secondaryChatRecordRepository.flush();
 
         } catch (Exception e) {
-            if (transaction.isActive()) {
-                transaction.rollback();
-            }
             logger.error("Batch insert failed for {} records", records.size(), e);
             throw e;
-        } finally {
-            entityManager.close();
         }
     }
 

src/main/java/com/phantoms/phantomsbackend/service/scheduler/DataSyncScheduler.java

@@ -46,7 +46,7 @@ public class RecruitmentScheduler {
     private RedisUtil redisUtil;
 
     @Scheduled(fixedRate = 300000) // 每300秒执行一次
-    @Transactional
+    @Transactional(timeout = 60, readOnly = false)
     public void fetchAndFilterRecruitments() {
         try {
             List<RecruitmentResponse> allResponses = LittlenightmareClient.fetchAllRecruitmentListings(