fix: reload similar asin chunks after coze flush

backend-java/src/main/java/com/nanri/aiimage/modules/brand/service/BrandTaskService.java

@@ -75,6 +75,7 @@ public class BrandTaskService {
 
     private static final DateTimeFormatter DATETIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
     private static final Duration STALE_CHECK_LOCK_TTL = Duration.ofMinutes(10);
+    private static final long RESULT_SUBMIT_WAIT_MILLIS = 5 * 60 * 1000L;
     private static final String STATUS_PENDING = "pending";
     private static final String STATUS_RUNNING = "running";
     private static final String STATUS_SUCCESS = "success";
@@ -223,7 +224,7 @@ public class BrandTaskService {
         if (taskId == null || taskId <= 0) {
             throw new BusinessException("taskId invalid");
         }
-        try (TaskDistributedLockService.LockHandle ignored = acquireTaskLockOrThrow(taskId, TaskDistributedLockService.DEFAULT_WAIT_MILLIS)) {
+        try (TaskDistributedLockService.LockHandle ignored = acquireTaskLockOrThrow(taskId, RESULT_SUBMIT_WAIT_MILLIS)) {
             long startedAt = System.currentTimeMillis();
             BrandCrawlTaskEntity task = requireActiveTask(taskId);
             List<BrandSourceFileDto> sourceFiles = parseSourceFiles(task.getFilePaths());

backend-java/src/main/java/com/nanri/aiimage/modules/similarasin/service/SimilarAsinTaskService.java

@@ -1720,6 +1720,10 @@ public class SimilarAsinTaskService {
         // （Redis 锁竞争 / 异常退出），在 assemble 阶段读 chunk 之前再 flush 一次，幂等。
         try {
             flushBufferedCozeResults(task.getId());
+            chunks = taskChunkMapper.selectList(new LambdaQueryWrapper<TaskChunkEntity>()
+                    .eq(TaskChunkEntity::getTaskId, task.getId())
+                    .eq(TaskChunkEntity::getModuleType, MODULE_TYPE)
+                    .orderByAsc(TaskChunkEntity::getChunkIndex));
         } catch (Exception flushEx) {
             log.warn("[相似ASIN] 结果文件任务刷新缓冲区 Coze 结果失败 任务ID={} 文件任务ID={} 错误={}",
                     task.getId(), job.getId(), flushEx.getMessage(), flushEx);