diff --git a/photo_mask_error_check.py b/photo_mask_error_check.py index 8b25e4d..fc96069 100644 --- a/photo_mask_error_check.py +++ b/photo_mask_error_check.py @@ -1,12 +1,11 @@ import cv2 from sqlalchemy import update -import util.util from db import MysqlSession from db.mysql import ZxIeOcrerror from photo_mask.photo_mask import mask_photo from ucloud import ufile -from util import image_util +from util import image_util, util def check_error(error_ocr): @@ -51,7 +50,7 @@ if __name__ == '__main__': remarks = input("备注:") session = MysqlSession() update_flag = (update(ZxIeOcrerror).where(ZxIeOcrerror.pk_phrec == ocr_error.pk_phrec).values( - checktime=util.util.get_default_datetime(), cfjaddress2=remarks)) + checktime=util.get_default_datetime(), cfjaddress2=remarks)) session.execute(update_flag) session.commit() session.close() diff --git a/photo_mask_error_report.py b/photo_mask_error_report.py new file mode 100644 index 0000000..26b5476 --- /dev/null +++ b/photo_mask_error_report.py @@ -0,0 +1,57 @@ +from collections import defaultdict +from datetime import date + +from sqlalchemy import update, exists, select + +from db import MysqlSession +from db.mysql import ZxIeOcrerror, ZxPhrec +from util import util + +if __name__ == '__main__': + today = date.today() + session = MysqlSession() + ocr_errors = (session.query(ZxIeOcrerror.pk_phrec, ZxIeOcrerror.cXm, ZxIeOcrerror.cSfzh, ZxIeOcrerror.cfjaddress, + ZxIeOcrerror.pk_phhd, ZxIeOcrerror.cfjaddress2) + .filter(ZxIeOcrerror.paint_date >= today) + .order_by(ZxIeOcrerror.pk_phrec.desc()).all()) + session.close() + + result = defaultdict(int) + result[f"{today}涂抹错误图片总数"] = len(ocr_errors) + for ocr_error in ocr_errors: + if ocr_error.cfjaddress2: + result[ocr_error.cfjaddress2] += 1 + continue + + if ocr_error.cfjaddress[17] == '1': + session = MysqlSession() + update_flag = (update(ZxIeOcrerror).where(ZxIeOcrerror.pk_phrec == ocr_error.pk_phrec).values( + checktime=util.get_default_datetime(), cfjaddress2="图片类型错误")) + session.execute(update_flag) + session.commit() + session.close() + result["图片类型错误"] += 1 + continue + + session = MysqlSession() + query = select(exists().where(ZxPhrec.cfjaddress == ocr_error.cfjaddress)) + record_exists = session.execute(query).scalar() + session.close() + if not record_exists: + session = MysqlSession() + update_flag = (update(ZxIeOcrerror).where(ZxIeOcrerror.pk_phrec == ocr_error.pk_phrec).values( + checktime=util.get_default_datetime(), cfjaddress2="未同步")) + session.execute(update_flag) + session.commit() + session.close() + result["未同步"] += 1 + continue + + session = MysqlSession() + update_flag = (update(ZxIeOcrerror).where(ZxIeOcrerror.pk_phrec == ocr_error.pk_phrec).values( + cfjaddress2="未知错误")) + session.execute(update_flag) + session.commit() + session.close() + result["未知错误"] += 1 + print(result)