class Downloader():
    def __init__(self, download_dir, time_out=60, poll_frequency=0.5, 
                 exist_del=True, ignore_suffix_list=None):
        # 下載目錄
        self.download_dir = download_dir
        self.time_out = time_out  # 超時(shí)時(shí)間（秒）
        self.poll_frequency = poll_frequency  # 輪詢(xún)間隔（秒）
        self.exist_del = exist_del  # 目標(biāo)文件存在時(shí)是否刪除
        # 忽略的臨時(shí)文件后綴
        self.ignore_suffix_list = ignore_suffix_list or [".crdownload", ".tmp"]

    def watch_start(self):
        """記錄下載前的文件狀態(tài)"""
        path = Path(self.download_dir)
        files = set(path.glob("*"))
        self.path = path
        self.origin_files = files

    def get_download_file(self):
        """檢測(cè)新下載的文件"""
        start_time = perf_counter()
        while (perf_counter() - start_time <= self.time_out):
            now_files = set(self.path.glob("*"))
            # 計(jì)算新增文件
            diff_list = list(now_files.difference(self.origin_files))
            if not diff_list:
                sleep(self.poll_frequency)
                continue
            
            # 過(guò)濾臨時(shí)文件
            final_diff_list = []
            for item in diff_list:
                if Path(item).suffix not in self.ignore_suffix_list:
                    final_diff_list.append(item)
            
            # 處理有效文件
            if final_diff_list:
                if len(final_diff_list) > 1:
                    raise Exception("暫不支持監(jiān)控多個(gè)文件下載")
                return str(Path(final_diff_list[0]).resolve())
        
        return None

    def download_file(self, file_path):
        """移動(dòng)下載的文件到指定位置"""
        download_file = self.get_download_file()
        if download_file is None:
            raise Exception("下載超時(shí)，未獲取到文件")
        
        log.info(f"找到文件 {download_file}, 開(kāi)始移動(dòng)")
        target = Path(file_path)
        
        # 處理目標(biāo)文件已存在的情況
        if target.exists():
            if self.exist_del:
                target.unlink()  # 刪除現(xiàn)有文件
            else:
                # 創(chuàng)建帶時(shí)間戳的備份文件
                suffix = target.suffix
                timestamp = datetime.now().strftime("%Y%m%d%H%M%S")
                backup_path = target.with_name(
                    f"{target.stem}_{timestamp}_bak{suffix}"
                )
                shutil.move(file_path, backup_path)
        
        # 移動(dòng)文件到目標(biāo)位置
        shutil.move(download_file, file_path)

if __name__ == "__main__":
    log.basicConfig(level=log.INFO)
    
    # 初始化下載監(jiān)控器
    downloader = Downloader(
        download_dir=r"C:\Users\user\Downloads",  # 監(jiān)控的下載目錄
        time_out=120,           # 超時(shí)時(shí)間2分鐘
        poll_frequency=0.2,     # 每0.2秒檢查一次
        exist_del=False         # 目標(biāo)文件存在時(shí)創(chuàng)建備份
    )
    
    # 開(kāi)始監(jiān)控
    downloader.watch_start()
    
    # 這里應(yīng)該觸發(fā)下載操作（例如：點(diǎn)擊下載鏈接）
    # 示例：使用Selenium下載文件
    # driver.find_element(By.ID, "downloadButton").click()
    
    try:
        # 獲取并移動(dòng)下載的文件
        downloader.download_file(r"D:\project\data\report.xlsx")
        log.info("文件下載并移動(dòng)成功！")
    except Exception as e:
        log.error(f"下載失敗: {str(e)}")