Class Group

mod/project/java/groupMod.py:19–711

class Group:
    GROUP_DATA_DIR = "/www/server/panel/data/java_group"
    GROUP_TMP_DIR = "/var/tmp/springboot/group"

    def __init__(self, group_id: Optional[str] = None, group_data: Optional[dict] = None):
        self.group_id = group_id
        if isinstance(group_data, dict):
            self.config: Optional[Dict[str, Union[str, List]]] = group_data
        else:
            self.config = self.load_group_data_by_id()

        if not os.path.exists(self.GROUP_DATA_DIR):
            os.makedirs(self.GROUP_DATA_DIR, 0o600)

        if not os.path.exists(self.GROUP_TMP_DIR):
            os.makedirs(self.GROUP_TMP_DIR)

        self.running_data = {
            "length": 0,  # 已完成的数量
            "remaining": 0,  # 未完成的数量
            "executing": 0,  # 正在执行的数量
            "projects": [],  # 项目操作详情
            "msg": "",  # 信息
            "status": True,
        }

    # 如果有配置文件，则表示可以执行
    def can_running(self) -> bool:
        return isinstance(self.config, dict)

    @staticmethod
    def new_group_id() -> str:
        from uuid import uuid4
        return uuid4().hex[::2]

    # 从配置文件中加载数据
    def load_group_data_by_id(self) -> Optional[dict]:
        config_file = "{}/{}.json".format(self.GROUP_DATA_DIR, self.group_id)
        try:
            data = json.loads(public.readFile(config_file))
        except:
            return None
        if isinstance(data, dict):
            return data
        else:
            return None

    def save_group_data(self):
        if self.config:
            config_file = "{}/{}.json".format(self.GROUP_DATA_DIR, self.group_id)
            public.writeFile(config_file, json.dumps(self.config))

    # 更新旧版数据
    @classmethod
    def update_group_data(cls) -> None:
        json_file = "/www/server/panel/class/projectModel/java_project_groups.json"
        if not os.path.isfile(json_file):
            return