Commit a62e0d1

@@ -30,6 +30,7 @@ async def query_r2(dates: list[str], user: str, keyword: str, caption: str, supe
     paths = []
     for date in sorted(dates, reverse=True):  # 日期从新到旧
         logger.debug(f"Get {qtype} from R2: {date}")
+        await modify_progress(text=caption + f"\n🔍查询时间: {date}", force_update=True, **kwargs)
         data: dict[str, list[dict]] = await get_cf_r2(prefix + date, silent=True)
         if not data:
             continue

@@ -35,6 +35,7 @@ async def query_server(dates: list[str], user: str, keyword: str, caption: str,
             payload |= {"message": keyword} if qtype == "弹幕" else {"content": keyword}
         payload["page"] = 1
         logger.debug(f"Query {qtype}: {payload}")
+        await modify_progress(text=f"\n🔍查询时间: {date}", force_update=True, **kwargs)
         resp = await hx_req(api_url, "POST", data=payload, proxy=DANMU.PROXY, check_kv={"code": 0}, silent=True)
         parsed = await parse_from_server(resp.get("data", []), user, keyword, super_chats, qtype)
         count = parsed.get("count", 0)