import hashlib
from common.loguru_conf import Logger

logger = Logger().logger


def getMd5(value, long=True, lower=True):
    """
    md5 加密
    :param value: 待加密的值
    :param long: 32 位或 16 位,默认为 32 位
    :param lower: 大写或小写,默认为小写
    :return: 加密后的值
    """
    try:
        md5 = hashlib.md5()
        md5.update(value.encode('utf-8'))
        if long:
            if lower:
                return (md5.hexdigest()).lower()
            else:
                return (md5.hexdigest()).upper()
        else:
            if lower:
                return (md5.hexdigest())[8:-8].lower()
            else:
                return (md5.hexdigest())[8:-8].upper()
    except Exception as e:
        logger.error(f'md5 加密程序错误:{e}')
        return None


if __name__ == '__main__':
    print(getMd5("000000"))
    print(getMd5('{"packageName": "com.eccalc.ichat", "userName": "chat2uapp@outlook.com"}'))

import time
from functools import wraps
from pathlib import Path
from tools.get_root_path import get_root_path
import loguru

logger = None


# 单例类的装饰器
def singleton_class_decorator(cls):
    """装饰器，单例类的装饰器"""
    _instance = None

    @wraps(cls)
    def wrapper_class(*args, **kwargs):
        nonlocal _instance
        if _instance is None:
            _instance = cls(*args, **kwargs)
        return _instance

    return wrapper_class


@singleton_class_decorator
class Logger:
    def __init__(self):
        self.__logger_add()  # 调用此方法以初始化日志器

    @staticmethod
    def __get_log_path():
        """获取日志文件路径"""
        project_path = get_root_path()  # 项目根目录
        creat_time = time.strftime("%Y-%m-%d", time.localtime())
        logs_file_path = Path(project_path).joinpath("logs", creat_time)
        logs_file_path.mkdir(
            parents=True, exist_ok=True
        )  # 使用exist_ok=True来避免目录已存在的错误
        project_log_filename = (
            f'{time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}.log'
        )
        project_log_path = logs_file_path.joinpath(project_log_filename)
        return project_log_path.as_posix()

    def __logger_add(self):
        loguru.logger.add(
            sink=self.__get_log_path(),  # 水槽，分流器，可以用来输入路径
            rotation="00:00",  # 日志创建周期
            retention="1 day",  # 保存
            compression="zip",  # 文件的压缩格式
            encoding="utf-8",  # 编码格式
            enqueue=True,  # 具有使日志记录调用非阻塞的优点
        )

    @property
    def logger(self):
        global logger
        if logger is None:
            loguru.logger.debug(f"logger 初始化")
            logger = loguru.logger
            return logger
        return logger

import configparser
from common.loguru_conf import Logger
from tools.get_root_path import get_root_path

logger = Logger().logger
config = None
config_ini = "/configs/config.ini"


def read_ini():
    """
    读取 config.ini 配置信息
    :return: dict
    """
    global config
    try:
        if config is None:
            config = configparser.ConfigParser()
            config_path = get_root_path() + config_ini
            config.read(config_path, encoding="utf-8")
            logger.debug(f"读取配置成功: {config}")
            return config
        return config
    except Exception as e:
        logger.error(f"读取配置文件报错: {e}")


def get_config(section: str):
    return read_ini()[section]

import json

import requests

from common.loguru_conf import Logger

logger = Logger().logger


def send_weixin(text: str):
    url = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=d4a2932b-511d-4ace-8810-c259adda7bdf"  # 这里就是群机器人的Webhook地址
    headers = {"Content-Type": "application/json"}  # http数据头，类型为json
    data = {
        "msgtype": "text",
        "text": {
            "content": text,  # 让群机器人发送的消息内容。
            "mentioned_list": [],
        },
    }
    res = requests.post(url, headers=headers, json=data)  # 利用requests库发送post请求
    if res.status_code == 200:
        logger.debug(f"微信预警发送成功: {text}")
        return
    logger.debug(f"微信预警发送失败: {text}")


if __name__ == "__main__":
    t = str(
        {
            "app_name": "通友",
            "pkg_name": "com.eccalc.ichat",
            "update_time": "2024年03月04日 17:24:35",
            "version_name": "4.2.11",
            "audit_status_name": "审核不通过",
            "audit_status": "444",
            "refuse_reason": "测试机型：OPPO Find X5； Android版本：13； 软件版本：PFFM10_11_C.36；,直播、社交、音视频类应用内需添加“青少年模式/未成年模式”功能。您的应用属性涉及相关，还请添加青少年模式/未成年模式功能，且需在进入应用后以弹窗的形式主动提醒用户，请您完善。详情可查看未成年人网络保护条例第四十三条（https://www.gov.cn/zhengce/content/202310/content_6911288.htm）",
        }
    )
    send_weixin(t)