model_init.py 7.37 KB
Newer Older
1
import torch
2
3
from loguru import logger

4
from magic_pdf.config.constants import MODEL_NAME
5
from magic_pdf.model.model_list import AtomicModel
6
from magic_pdf.model.sub_modules.language_detection.yolov11.YOLOv11 import YOLOv11LangDetModel
7
8
from magic_pdf.model.sub_modules.layout.doclayout_yolo.DocLayoutYOLO import DocLayoutYOLOModel
from magic_pdf.model.sub_modules.layout.layoutlmv3.model_init import Layoutlmv3_Predictor
9
10
from magic_pdf.model.sub_modules.mfd.yolov8.YOLOv8 import YOLOv8MFDModel
from magic_pdf.model.sub_modules.mfr.unimernet.Unimernet import UnimernetModel
11
12

try:
13
    from magic_pdf_ascend_plugin.libs.license_verifier import load_license, LicenseFormatError, LicenseSignatureError, LicenseExpiredError
14
15
    from magic_pdf_ascend_plugin.model_plugin.ocr.paddleocr.ppocr_273_npu import ModifiedPaddleOCR
    from magic_pdf_ascend_plugin.model_plugin.table.rapidtable.rapid_table_npu import RapidTableModel
16
17
18
19
20
21
22
23
24
25
26
27
28
    license_key = load_license()
    logger.info(f'Using Ascend Plugin Success, License expired at {license_key["payload"]["date"]["end_date"]}')
except Exception as e:
    if isinstance(e, LicenseFormatError):
        logger.error("Ascend Plugin: Invalid license format. Please check the license file.")
    elif isinstance(e, LicenseSignatureError):
        logger.error("Ascend Plugin: Invalid signature. The license may be tampered with.")
    elif isinstance(e, LicenseExpiredError):
        logger.error("Ascend Plugin: License has expired. Please renew your license.")
    elif isinstance(e, FileNotFoundError):
        logger.error("Ascend Plugin: Not found License file.")
    else:
        pass
29
30
31
    from magic_pdf.model.sub_modules.ocr.paddleocr.ppocr_273_mod import ModifiedPaddleOCR
    # from magic_pdf.model.sub_modules.ocr.paddleocr.ppocr_291_mod import ModifiedPaddleOCR
    from magic_pdf.model.sub_modules.table.rapidtable.rapid_table import RapidTableModel
32

33
34
from magic_pdf.model.sub_modules.table.structeqtable.struct_eqtable import StructTableModel
from magic_pdf.model.sub_modules.table.tablemaster.tablemaster_paddle import TableMasterPaddleModel
35

36
def table_model_init(table_model_type, model_path, max_time, _device_='cpu', ocr_engine=None, table_sub_model_name=None):
37
38
39
40
    if table_model_type == MODEL_NAME.STRUCT_EQTABLE:
        table_model = StructTableModel(model_path, max_new_tokens=2048, max_time=max_time)
    elif table_model_type == MODEL_NAME.TABLE_MASTER:
        config = {
41
42
            'model_dir': model_path,
            'device': _device_
43
44
45
        }
        table_model = TableMasterPaddleModel(config)
    elif table_model_type == MODEL_NAME.RAPID_TABLE:
46
        table_model = RapidTableModel(ocr_engine, table_sub_model_name)
47
    else:
48
        logger.error('table model type not allow')
49
50
51
52
53
54
        exit(1)

    return table_model


def mfd_model_init(weight, device='cpu'):
55
56
    if str(device).startswith("npu"):
        device = torch.device(device)
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
    mfd_model = YOLOv8MFDModel(weight, device)
    return mfd_model


def mfr_model_init(weight_dir, cfg_path, device='cpu'):
    mfr_model = UnimernetModel(weight_dir, cfg_path, device)
    return mfr_model


def layout_model_init(weight, config_file, device):
    model = Layoutlmv3_Predictor(weight, config_file, device)
    return model


def doclayout_yolo_model_init(weight, device='cpu'):
72
73
    if str(device).startswith("npu"):
        device = torch.device(device)
74
75
76
77
    model = DocLayoutYOLOModel(weight, device)
    return model


78
def langdetect_model_init(langdetect_model_weight, device='cpu'):
79
80
    if str(device).startswith("npu"):
        device = torch.device(device)
81
    model = YOLOv11LangDetModel(langdetect_model_weight, device)
82
83
84
    return model


85
86
87
88
89
90
def ocr_model_init(show_log: bool = False,
                   det_db_box_thresh=0.3,
                   lang=None,
                   use_dilation=True,
                   det_db_unclip_ratio=1.8,
                   ):
91
    if lang is not None and lang != '':
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
        model = ModifiedPaddleOCR(
            show_log=show_log,
            det_db_box_thresh=det_db_box_thresh,
            lang=lang,
            use_dilation=use_dilation,
            det_db_unclip_ratio=det_db_unclip_ratio,
        )
    else:
        model = ModifiedPaddleOCR(
            show_log=show_log,
            det_db_box_thresh=det_db_box_thresh,
            use_dilation=use_dilation,
            det_db_unclip_ratio=det_db_unclip_ratio,
        )
    return model


class AtomModelSingleton:
    _instance = None
    _models = {}

    def __new__(cls, *args, **kwargs):
        if cls._instance is None:
            cls._instance = super().__new__(cls)
        return cls._instance

    def get_atom_model(self, atom_model_name: str, **kwargs):
119

120
121
        lang = kwargs.get('lang', None)
        layout_model_name = kwargs.get('layout_model_name', None)
122
123
124
        table_model_name = kwargs.get('table_model_name', None)

        if atom_model_name in [AtomicModel.OCR]:
125
            key = (atom_model_name, lang)
126
127
128
129
130
131
132
        elif atom_model_name in [AtomicModel.Layout]:
            key = (atom_model_name, layout_model_name)
        elif atom_model_name in [AtomicModel.Table]:
            key = (atom_model_name, table_model_name)
        else:
            key = atom_model_name

133
134
        if key not in self._models:
            self._models[key] = atom_model_init(model_name=atom_model_name, **kwargs)
135
        return self._models[key]
136
137
138
139

def atom_model_init(model_name: str, **kwargs):
    atom_model = None
    if model_name == AtomicModel.Layout:
140
        if kwargs.get('layout_model_name') == MODEL_NAME.LAYOUTLMv3:
141
            atom_model = layout_model_init(
142
143
144
                kwargs.get('layout_weights'),
                kwargs.get('layout_config_file'),
                kwargs.get('device')
145
            )
146
        elif kwargs.get('layout_model_name') == MODEL_NAME.DocLayout_YOLO:
147
            atom_model = doclayout_yolo_model_init(
148
149
                kwargs.get('doclayout_yolo_weights'),
                kwargs.get('device')
150
            )
151
152
153
        else:
            logger.error('layout model name not allow')
            exit(1)
154
155
    elif model_name == AtomicModel.MFD:
        atom_model = mfd_model_init(
156
157
            kwargs.get('mfd_weights'),
            kwargs.get('device')
158
159
160
        )
    elif model_name == AtomicModel.MFR:
        atom_model = mfr_model_init(
161
162
163
            kwargs.get('mfr_weight_dir'),
            kwargs.get('mfr_cfg_path'),
            kwargs.get('device')
164
165
166
        )
    elif model_name == AtomicModel.OCR:
        atom_model = ocr_model_init(
167
168
            kwargs.get('ocr_show_log'),
            kwargs.get('det_db_box_thresh'),
169
            kwargs.get('lang'),
170
171
172
        )
    elif model_name == AtomicModel.Table:
        atom_model = table_model_init(
173
174
175
            kwargs.get('table_model_name'),
            kwargs.get('table_model_path'),
            kwargs.get('table_max_time'),
176
            kwargs.get('device'),
177
178
            kwargs.get('ocr_engine'),
            kwargs.get('table_sub_model_name')
179
        )
180
181
182
    elif model_name == AtomicModel.LangDetect:
        if kwargs.get('langdetect_model_name') == MODEL_NAME.YOLO_V11_LangDetect:
            atom_model = langdetect_model_init(
183
                kwargs.get('langdetect_model_weight'),
184
185
186
187
188
                kwargs.get('device')
            )
        else:
            logger.error('langdetect model name not allow')
            exit(1)
189
    else:
190
        logger.error('model name not allow')
191
192
193
        exit(1)

    if atom_model is None:
194
        logger.error('model init failed')
195
196
197
        exit(1)
    else:
        return atom_model