feat: optimize task scheduling frequency and request control

- adjust the status check task interval from 15 seconds to 20 seconds
- add early return for file scanning tasks when no changes are detected
- add a 100ms delay to embedding processing and status check services to control request frequency

Author: WayneWang00

cmd/main.go

@@ -169,7 +169,7 @@ func main() {
 	// Initialize job layer
 	fileScanJob := job.NewFileScanJob(fileScanService, storageManager, syncRepo, appLogger, 5*time.Minute)
 	eventProcessorJob := job.NewEventProcessorJob(appLogger, syncRepo, embeddingProcessService, codegraphProcessor, 30*time.Second, storageManager)
-	statusCheckerJob := job.NewStatusCheckerJob(embeddingStatusService, storageManager, syncRepo, appLogger, 15*time.Second)
+	statusCheckerJob := job.NewStatusCheckerJob(embeddingStatusService, storageManager, syncRepo, appLogger, 20*time.Second)
 	eventCleanerJob := job.NewEventCleanerJob(eventRepo, appLogger)
 	indexCleanJob := job.NewIndexCleanJob(appLogger, indexer, workspaceRepo, storageManager, codebaseEmbeddingRepo, syncRepo, eventRepo)
 	// Initialize handler layer

internal/job/file_scanner_job.go

@@ -158,6 +158,10 @@ func (j *FileScanJob) scanWorkspace(workspace *model.Workspace) error {
 	if err != nil {
 		return fmt.Errorf("failed to detect file changes: %w", err)
 	}
+	if len(events) == 0 {
+		j.logger.Debug("no file changes detected in workspace: %s", workspace.WorkspacePath)
+		return nil
+	}
 
 	j.logger.Info("detected %d file changes in workspace: %s", len(events), workspace.WorkspacePath)
 

internal/service/embedding_processor.go

@@ -324,6 +324,9 @@ func (ep *embeddingProcessService) processBatchAddModifyEvents(ctx context.Conte
 			// 继续处理下一批，不因单批失败而中断整个处理
 			continue
 		}
+
+		// 添加延迟控制请求频率
+		time.Sleep(100 * time.Millisecond)
 	}
 
 	return nil

internal/service/embedding_status.go

@@ -219,6 +219,9 @@ func (sc *embeddingStatusService) checkWorkspaceBuildingStates(workspacePath str
 		if err := sc.processEventsWithFileStatus(workspacePath, syncIdEvents, fileStatusResp); err != nil {
 			sc.logger.Error("failed to process events with file status for syncId %s: %v", syncId, err)
 		}
+
+		// 添加延迟控制请求频率
+		time.Sleep(100 * time.Millisecond)
 	}
 
 	return nil