task_check_db.py

# -*- coding: utf-8 -*-
from toolkits.DButils import MyPymysqlPool
from toolkits.dateTools import DateConvert as dc
from toolkits.fileTools import GetFileInfo as gf


if __name__ == '__main__':
    db = MyPymysqlPool('db_168')
    check_sql = f"select id,filePath,copyPeriod,remarks from dbBack_info where isEnabled = 1"
    task_list = db.get_all(sql=check_sql)
    now_time = dc.get_now()
    for task in task_list:
        get_last_info = f"select checkDatetime,folderSize,fileNumber from dbBack_history where taskId = {task['id']} and isNormal = 1 order by id desc"
        # 获取上次文件备份的信息
        last_info = db.get_one(sql=get_last_info)
        folderSize = gf.get_dir_size(task['filePath'])
        fileInfo = gf.get_dir_file_number(task['filePath'])
        isNormal = 1
        errorReason = ''
        # 如果有上次记录，则进行对比。没有则直接记录
        if last_info:
            if gf.check_path_exist(task['filePath']):
                if abs(float(folderSize) - float(last_info['folderSize'])) / float(last_info['folderSize']) > 0.05:
                    errorReason += '备份文件目录大小异常'
                if fileInfo['file_num'] != last_info['fileNumber']:
                    errorReason += '备份文件目录数量异常'
                mtime_check = []
                for fileName in fileInfo['file_list']:
                    fileMtime = gf.get_file_mtime(task['filePath'], fileName)
                    if dc.date_calc(fileMtime, last_info['checkDatetime'], task['copyPeriod']):
                        mtime_check.append(1)
                if not mtime_check:
                    errorReason += '没有生成任何备份文件'
            else:
                errorReason = '文件夹不存在'
            if errorReason:
                isNormal = 0
        ins_check_ret_sql = f"insert into dbBack_history(taskId, checkDatetime, folderSize, fileNumber, isNormal, errorReason) value (%s,%s,%s,%s,%s,%s)"
        data = [task['id'], now_time, folderSize, fileInfo['file_num'], isNormal, errorReason]
        print(data)
        db.insert(ins_check_ret_sql, data)
        db.end()