定期自动备份又拍云存储

name: Sync Images from UpYun to GitHub

on:
  schedule:
    - cron: '0 0 * * 3'  # 每周三凌晨 0 点运行
  workflow_dispatch:  # 允许手动触发

jobs:
  sync-images:
    runs-on: ubuntu-latest

    steps:
    - name: Checkout repository
      uses: actions/checkout@v2

    - name: Set up Python
      uses: actions/setup-python@v2
      with:
        python-version: '3.x'

    - name: Install dependencies
      run: |
        pip install gitpython

    - name: Run sync script
      env:
        UPYUN_FTP_HOST: $
        UPYUN_FTP_USER: $
        UPYUN_FTP_PASSWORD: $
        UPYUN_FTP_PATH: $
        LOCAL_DOWNLOAD_PATH: ./tmp
        REPO_PATH: ./repo
        GH_TOKEN: $
        REPO_OWNER: $
        REPO_NAME: $
        BRANCH_NAME: $
      run: |
        python3 sync_images.py

#!/usr/bin/env python3
# -*- coding: UTF-8 -*-

import os
from ftplib import FTP
import git
import shutil

class MyFTP:
    def __init__(self, host, port=21):
        self.host = host
        self.port = port
        self.ftp = FTP()
        self.ftp.encoding = 'utf8'
        self.file_list = []

    def login(self, username, password):
        try:
            self.ftp.connect(self.host, self.port)
            self.ftp.login(username, password)
            print(f"成功登录到 {self.host}")
            print(f"当前工作目录: {self.ftp.pwd()}")
        except Exception as err:
            print(f"FTP 连接或登录失败，错误描述为：{err}")
            sys.exit(1)

    def download_file(self, local_file, remote_file):
        if os.path.exists(local_file):
            print(f"{local_file} 已存在，跳过下载")
            return
        try:
            print(f"下载文件 {remote_file} 到 {local_file}")
            buf_size = 1024
            with open(local_file, 'wb') as file_handler:
                self.ftp.retrbinary(f'RETR {remote_file}', file_handler.write, buf_size)
        except Exception as err:
            print(f"下载文件出错，出现异常：{err}")

    def download_file_tree(self, local_path, remote_path):
        try:
            print(f"尝试切换到远程目录: {remote_path}")
            self.ftp.cwd(remote_path)
            print(f"成功切换到远程目录: {remote_path}")
        except Exception as err:
            print(f"远程目录 {remote_path} 不存在，继续... 具体错误描述为：{err}")
            return

        if not os.path.isdir(local_path):
            os.makedirs(local_path)
            print(f"创建本地目录 {local_path}")

        print(f"当前工作目录: {self.ftp.pwd()}")

        # 列出目录内容
        remote_files = self.ftp.nlst()
        print(f"远程目录内容: {remote_files}")

        for remote_file in remote_files:
            local = os.path.join(local_path, remote_file)
            if remote_file in ['.', '..']:
                continue
            try:
                self.ftp.cwd(remote_file)
                print(f"下载目录：{remote_file}")
                self.download_file_tree(local, os.path.join(remote_path, remote_file))
                self.ftp.cwd("..")
            except Exception:
                print(f"下载文件：{remote_file}")
                self.download_file(local, os.path.join(remote_path, remote_file))

    def close(self):
        print("FTP退出")
        self.ftp.quit()

def sync_to_github(repo_path, branch_name):
    if os.path.exists(repo_path):
        shutil.rmtree(repo_path)
    os.makedirs(repo_path)

    repo_url = f"https://{GH_TOKEN}@github.com/{REPO_OWNER}/{REPO_NAME}.git"
    print(f"克隆仓库: {repo_url}")
    try:
        repo = git.Repo.clone_from(repo_url, repo_path, branch=branch_name)
        print(f"克隆仓库到 {repo_path}")
    except git.exc.GitCommandError as e:
        print(f"克隆仓库失败: {e}")
        return

    images_dir = os.path.join(repo_path, 'images')
    if not os.path.exists(images_dir):
        os.makedirs(images_dir)

    shutil.copytree(LOCAL_DOWNLOAD_PATH, images_dir, dirs_exist_ok=True)
    print(f"复制文件到 {images_dir}")

    repo.git.add(all=True)
    if repo.is_dirty():
        repo.index.commit("Sync images from UpYun")
        origin = repo.remote(name='origin')
        origin.push()
        print("推送更改到 GitHub 仓库")
    else:
        print("没有更改需要提交")

if __name__ == "__main__":
    # 从环境变量中读取配置
    UPYUN_FTP_HOST = os.getenv('UPYUN_FTP_HOST')
    UPYUN_FTP_USER = os.getenv('UPYUN_FTP_USER')
    UPYUN_FTP_PASSWORD = os.getenv('UPYUN_FTP_PASSWORD')
    UPYUN_FTP_PATH = os.getenv('UPYUN_FTP_PATH', '/')
    LOCAL_DOWNLOAD_PATH = os.getenv('LOCAL_DOWNLOAD_PATH', './tmp')
    REPO_PATH = os.getenv('REPO_PATH', './repo')
    GH_TOKEN = os.getenv('GH_TOKEN')
    REPO_OWNER = os.getenv('REPO_OWNER')
    REPO_NAME = os.getenv('REPO_NAME')
    BRANCH_NAME = os.getenv('BRANCH_NAME', 'master')

    # 创建 FTP 对象
    my_ftp = MyFTP(UPYUN_FTP_HOST)
    # 登录 FTP 服务器
    my_ftp.login(UPYUN_FTP_USER, UPYUN_FTP_PASSWORD)
    
    # 下载目录
    my_ftp.download_file_tree(LOCAL_DOWNLOAD_PATH, UPYUN_FTP_PATH)
    
    # 关闭 FTP 连接
    my_ftp.close()

    # 同步到 GitHub
    sync_to_github(REPO_PATH, BRANCH_NAME)