magic_model.py 30 KB
Newer Older
icecraft's avatar
icecraft committed
1
import enum
kernel.h@qq.com's avatar
kernel.h@qq.com committed
2

3
4
from magic_pdf.config.model_block_type import ModelBlockTypeEnum
from magic_pdf.config.ocr_content_type import CategoryId, ContentType
5
from magic_pdf.data.dataset import Dataset
6
7
from magic_pdf.libs.boxbase import (_is_in, bbox_distance, bbox_relative_pos,
                                    calculate_iou)
liukaiwen's avatar
liukaiwen committed
8
from magic_pdf.libs.coordinate_transform import get_scale_ratio
9
from magic_pdf.pre_proc.remove_bbox_overlap import _remove_overlap_between_bbox
liukaiwen's avatar
liukaiwen committed
10

11
CAPATION_OVERLAP_AREA_RATIO = 0.6
12
MERGE_BOX_OVERLAP_AREA_RATIO = 1.1
liukaiwen's avatar
liukaiwen committed
13

许瑞's avatar
许瑞 committed
14

icecraft's avatar
icecraft committed
15
16
17
18
19
20
21
22
class PosRelationEnum(enum.Enum):
    LEFT = 'left'
    RIGHT = 'right'
    UP = 'up'
    BOTTOM = 'bottom'
    ALL = 'all'


liukaiwen's avatar
liukaiwen committed
23
class MagicModel:
24
    """每个函数没有得到元素的时候返回空list."""
liukaiwen's avatar
liukaiwen committed
25
26
27

    def __fix_axis(self):
        for model_page_info in self.__model_list:
28
            need_remove_list = []
29
            page_no = model_page_info['page_info']['page_no']
liukaiwen's avatar
liukaiwen committed
30
            horizontal_scale_ratio, vertical_scale_ratio = get_scale_ratio(
31
                model_page_info, self.__docs.get_page(page_no)
liukaiwen's avatar
liukaiwen committed
32
            )
33
            layout_dets = model_page_info['layout_dets']
liukaiwen's avatar
liukaiwen committed
34
            for layout_det in layout_dets:
35

36
                if layout_det.get('bbox') is not None:
37
                    # 兼容直接输出bbox的模型数据,如paddle
38
                    x0, y0, x1, y1 = layout_det['bbox']
39
40
                else:
                    # 兼容直接输出poly的模型数据,如xxx
41
                    x0, y0, _, _, x1, y1, _, _ = layout_det['poly']
42

liukaiwen's avatar
liukaiwen committed
43
44
45
46
47
48
                bbox = [
                    int(x0 / horizontal_scale_ratio),
                    int(y0 / vertical_scale_ratio),
                    int(x1 / horizontal_scale_ratio),
                    int(y1 / vertical_scale_ratio),
                ]
49
                layout_det['bbox'] = bbox
50
51
                # 删除高度或者宽度小于等于0的spans
                if bbox[2] - bbox[0] <= 0 or bbox[3] - bbox[1] <= 0:
liukaiwen's avatar
liukaiwen committed
52
53
54
55
                    need_remove_list.append(layout_det)
            for need_remove in need_remove_list:
                layout_dets.remove(need_remove)

56
    def __fix_by_remove_low_confidence(self):
57
58
        for model_page_info in self.__model_list:
            need_remove_list = []
59
            layout_dets = model_page_info['layout_dets']
60
            for layout_det in layout_dets:
61
                if layout_det['score'] <= 0.05:
62
63
64
65
66
                    need_remove_list.append(layout_det)
                else:
                    continue
            for need_remove in need_remove_list:
                layout_dets.remove(need_remove)
liukaiwen's avatar
liukaiwen committed
67

68
69
70
    def __fix_by_remove_high_iou_and_low_confidence(self):
        for model_page_info in self.__model_list:
            need_remove_list = []
71
            layout_dets = model_page_info['layout_dets']
72
73
74
75
            for layout_det1 in layout_dets:
                for layout_det2 in layout_dets:
                    if layout_det1 == layout_det2:
                        continue
76
                    if layout_det1['category_id'] in [
blue's avatar
blue committed
77
78
79
80
81
82
83
84
85
86
                        0,
                        1,
                        2,
                        3,
                        4,
                        5,
                        6,
                        7,
                        8,
                        9,
87
                    ] and layout_det2['category_id'] in [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]:
blue's avatar
blue committed
88
                        if (
89
                            calculate_iou(layout_det1['bbox'], layout_det2['bbox'])
blue's avatar
blue committed
90
91
                            > 0.9
                        ):
92
                            if layout_det1['score'] < layout_det2['score']:
93
94
95
96
97
98
99
100
101
102
103
104
105
                                layout_det_need_remove = layout_det1
                            else:
                                layout_det_need_remove = layout_det2

                            if layout_det_need_remove not in need_remove_list:
                                need_remove_list.append(layout_det_need_remove)
                        else:
                            continue
                    else:
                        continue
            for need_remove in need_remove_list:
                layout_dets.remove(need_remove)

106
    def __init__(self, model_list: list, docs: Dataset):
kernel.h@qq.com's avatar
kernel.h@qq.com committed
107
        self.__model_list = model_list
liukaiwen's avatar
liukaiwen committed
108
        self.__docs = docs
blue's avatar
blue committed
109
        """为所有模型数据添加bbox信息(缩放,poly->bbox)"""
kernel.h@qq.com's avatar
kernel.h@qq.com committed
110
        self.__fix_axis()
blue's avatar
blue committed
111
        """删除置信度特别低的模型数据(<0.05),提高质量"""
112
        self.__fix_by_remove_low_confidence()
blue's avatar
blue committed
113
        """删除高iou(>0.9)数据中置信度较低的那个"""
114
        self.__fix_by_remove_high_iou_and_low_confidence()
115
116
        self.__fix_footnote()

117
118
119
120
121
122
123
124
125
    def _bbox_distance(self, bbox1, bbox2):
        left, right, bottom, top = bbox_relative_pos(bbox1, bbox2)
        flags = [left, right, bottom, top]
        count = sum([1 if v else 0 for v in flags])
        if count > 1:
            return float('inf')
        if left or right:
            l1 = bbox1[3] - bbox1[1]
            l2 = bbox2[3] - bbox2[1]
126
        else:
127
128
            l1 = bbox1[2] - bbox1[0]
            l2 = bbox2[2] - bbox2[0]
129

130
        if l2 > l1 and (l2 - l1) / l1 > 0.3:
131
132
            return float('inf')

133
134
        return bbox_distance(bbox1, bbox2)

135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
    def __fix_footnote(self):
        # 3: figure, 5: table, 7: footnote
        for model_page_info in self.__model_list:
            footnotes = []
            figures = []
            tables = []

            for obj in model_page_info['layout_dets']:
                if obj['category_id'] == 7:
                    footnotes.append(obj)
                elif obj['category_id'] == 3:
                    figures.append(obj)
                elif obj['category_id'] == 5:
                    tables.append(obj)
                if len(footnotes) * len(figures) == 0:
                    continue
151
152
153
154
155
156
157
158
159
160
161
162
            dis_figure_footnote = {}
            dis_table_footnote = {}

            for i in range(len(footnotes)):
                for j in range(len(figures)):
                    pos_flag_count = sum(
                        list(
                            map(
                                lambda x: 1 if x else 0,
                                bbox_relative_pos(
                                    footnotes[i]['bbox'], figures[j]['bbox']
                                ),
163
164
                            )
                        )
165
166
167
168
                    )
                    if pos_flag_count > 1:
                        continue
                    dis_figure_footnote[i] = min(
169
                        self._bbox_distance(figures[j]['bbox'], footnotes[i]['bbox']),
170
171
172
173
174
175
176
177
178
179
180
                        dis_figure_footnote.get(i, float('inf')),
                    )
            for i in range(len(footnotes)):
                for j in range(len(tables)):
                    pos_flag_count = sum(
                        list(
                            map(
                                lambda x: 1 if x else 0,
                                bbox_relative_pos(
                                    footnotes[i]['bbox'], tables[j]['bbox']
                                ),
181
182
                            )
                        )
183
184
185
                    )
                    if pos_flag_count > 1:
                        continue
186

187
                    dis_table_footnote[i] = min(
188
                        self._bbox_distance(tables[j]['bbox'], footnotes[i]['bbox']),
189
190
191
192
193
194
195
                        dis_table_footnote.get(i, float('inf')),
                    )
            for i in range(len(footnotes)):
                if i not in dis_figure_footnote:
                    continue
                if dis_table_footnote.get(i, float('inf')) > dis_figure_footnote[i]:
                    footnotes[i]['category_id'] = CategoryId.ImageFootnote
liukaiwen's avatar
liukaiwen committed
196
197
198
199
200
201
202
203

    def __reduct_overlap(self, bboxes):
        N = len(bboxes)
        keep = [True] * N
        for i in range(N):
            for j in range(N):
                if i == j:
                    continue
204
                if _is_in(bboxes[i]['bbox'], bboxes[j]['bbox']):
liukaiwen's avatar
liukaiwen committed
205
206
207
                    keep[i] = False
        return [bboxes[i] for i in range(N) if keep[i]]

208
    def __tie_up_category_by_distance_v2(
icecraft's avatar
icecraft committed
209
210
211
212
213
        self,
        page_no: int,
        subject_category_id: int,
        object_category_id: int,
        priority_pos: PosRelationEnum,
214
    ):
icecraft's avatar
icecraft committed
215
        """_summary_
216

icecraft's avatar
icecraft committed
217
218
219
220
221
222
223
224
225
        Args:
            page_no (int): _description_
            subject_category_id (int): _description_
            object_category_id (int): _description_
            priority_pos (PosRelationEnum): _description_

        Returns:
            _type_: _description_
        """
icecraft's avatar
icecraft committed
226
        AXIS_MULPLICITY = 0.5
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
        subjects = self.__reduct_overlap(
            list(
                map(
                    lambda x: {'bbox': x['bbox'], 'score': x['score']},
                    filter(
                        lambda x: x['category_id'] == subject_category_id,
                        self.__model_list[page_no]['layout_dets'],
                    ),
                )
            )
        )

        objects = self.__reduct_overlap(
            list(
                map(
                    lambda x: {'bbox': x['bbox'], 'score': x['score']},
                    filter(
                        lambda x: x['category_id'] == object_category_id,
                        self.__model_list[page_no]['layout_dets'],
                    ),
                )
            )
        )
250
        M = len(objects)
251
252
253

        subjects.sort(key=lambda x: x['bbox'][0] ** 2 + x['bbox'][1] ** 2)
        objects.sort(key=lambda x: x['bbox'][0] ** 2 + x['bbox'][1] ** 2)
254
255
256
257
258
259
260
261
262
263

        sub_obj_map_h = {i: [] for i in range(len(subjects))}

        dis_by_directions = {
            'top': [[-1, float('inf')]] * M,
            'bottom': [[-1, float('inf')]] * M,
            'left': [[-1, float('inf')]] * M,
            'right': [[-1, float('inf')]] * M,
        }

264
        for i, obj in enumerate(objects):
265
266
267
268
269
            l_x_axis, l_y_axis = (
                obj['bbox'][2] - obj['bbox'][0],
                obj['bbox'][3] - obj['bbox'][1],
            )
            axis_unit = min(l_x_axis, l_y_axis)
270
271
            for j, sub in enumerate(subjects):

icecraft's avatar
icecraft committed
272
273
                bbox1, bbox2, _ = _remove_overlap_between_bbox(
                    objects[i]['bbox'], subjects[j]['bbox']
274
                )
icecraft's avatar
icecraft committed
275
                left, right, bottom, top = bbox_relative_pos(bbox1, bbox2)
276
277
                flags = [left, right, bottom, top]
                if sum([1 if v else 0 for v in flags]) > 1:
278
279
                    continue

280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
                if left:
                    if dis_by_directions['left'][i][1] > bbox_distance(
                        obj['bbox'], sub['bbox']
                    ):
                        dis_by_directions['left'][i] = [
                            j,
                            bbox_distance(obj['bbox'], sub['bbox']),
                        ]
                if right:
                    if dis_by_directions['right'][i][1] > bbox_distance(
                        obj['bbox'], sub['bbox']
                    ):
                        dis_by_directions['right'][i] = [
                            j,
                            bbox_distance(obj['bbox'], sub['bbox']),
                        ]
                if bottom:
                    if dis_by_directions['bottom'][i][1] > bbox_distance(
                        obj['bbox'], sub['bbox']
                    ):
                        dis_by_directions['bottom'][i] = [
                            j,
                            bbox_distance(obj['bbox'], sub['bbox']),
                        ]
                if top:
                    if dis_by_directions['top'][i][1] > bbox_distance(
                        obj['bbox'], sub['bbox']
                    ):
                        dis_by_directions['top'][i] = [
                            j,
                            bbox_distance(obj['bbox'], sub['bbox']),
                        ]
icecraft's avatar
icecraft committed
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332

            if (
                dis_by_directions['top'][i][1] != float('inf')
                and dis_by_directions['bottom'][i][1] != float('inf')
                and priority_pos in (PosRelationEnum.BOTTOM, PosRelationEnum.UP)
            ):
                RATIO = 3
                if (
                    abs(
                        dis_by_directions['top'][i][1]
                        - dis_by_directions['bottom'][i][1]
                    )
                    < RATIO * axis_unit
                ):

                    if priority_pos == PosRelationEnum.BOTTOM:
                        sub_obj_map_h[dis_by_directions['bottom'][i][0]].append(i)
                    else:
                        sub_obj_map_h[dis_by_directions['top'][i][0]].append(i)
                    continue

333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
            if dis_by_directions['left'][i][1] != float('inf') or dis_by_directions[
                'right'
            ][i][1] != float('inf'):
                if dis_by_directions['left'][i][1] != float(
                    'inf'
                ) and dis_by_directions['right'][i][1] != float('inf'):
                    if AXIS_MULPLICITY * axis_unit >= abs(
                        dis_by_directions['left'][i][1]
                        - dis_by_directions['right'][i][1]
                    ):
                        left_sub_bbox = subjects[dis_by_directions['left'][i][0]][
                            'bbox'
                        ]
                        right_sub_bbox = subjects[dis_by_directions['right'][i][0]][
                            'bbox'
                        ]

                        left_sub_bbox_y_axis = left_sub_bbox[3] - left_sub_bbox[1]
                        right_sub_bbox_y_axis = right_sub_bbox[3] - right_sub_bbox[1]

icecraft's avatar
icecraft committed
353
354
355
356
357
                        if (
                            abs(left_sub_bbox_y_axis - l_y_axis)
                            + dis_by_directions['left'][i][0]
                            > abs(right_sub_bbox_y_axis - l_y_axis)
                            + dis_by_directions['right'][i][0]
358
359
360
361
362
363
                        ):
                            left_or_right = dis_by_directions['right'][i]
                        else:
                            left_or_right = dis_by_directions['left'][i]
                    else:
                        left_or_right = dis_by_directions['left'][i]
icecraft's avatar
icecraft committed
364
                        if left_or_right[1] > dis_by_directions['right'][i][1]:
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
                            left_or_right = dis_by_directions['right'][i]
                else:
                    left_or_right = dis_by_directions['left'][i]
                    if left_or_right[1] == float('inf'):
                        left_or_right = dis_by_directions['right'][i]
            else:
                left_or_right = [-1, float('inf')]

            if dis_by_directions['top'][i][1] != float('inf') or dis_by_directions[
                'bottom'
            ][i][1] != float('inf'):
                if dis_by_directions['top'][i][1] != float('inf') and dis_by_directions[
                    'bottom'
                ][i][1] != float('inf'):
                    if AXIS_MULPLICITY * axis_unit >= abs(
                        dis_by_directions['top'][i][1]
                        - dis_by_directions['bottom'][i][1]
                    ):
                        top_bottom = subjects[dis_by_directions['bottom'][i][0]]['bbox']
                        bottom_top = subjects[dis_by_directions['top'][i][0]]['bbox']

                        top_bottom_x_axis = top_bottom[2] - top_bottom[0]
                        bottom_top_x_axis = bottom_top[2] - bottom_top[0]
icecraft's avatar
icecraft committed
388
389
390
391
392
393
                        if (
                            abs(top_bottom_x_axis - l_x_axis)
                            + dis_by_directions['bottom'][i][1]
                            > abs(bottom_top_x_axis - l_x_axis)
                            + dis_by_directions['top'][i][1]
                        ):
394
                            top_or_bottom = dis_by_directions['top'][i]
icecraft's avatar
icecraft committed
395
396
                        else:
                            top_or_bottom = dis_by_directions['bottom'][i]
397
398
                    else:
                        top_or_bottom = dis_by_directions['top'][i]
icecraft's avatar
icecraft committed
399
                        if top_or_bottom[1] > dis_by_directions['bottom'][i][1]:
400
401
402
403
404
                            top_or_bottom = dis_by_directions['bottom'][i]
                else:
                    top_or_bottom = dis_by_directions['top'][i]
                    if top_or_bottom[1] == float('inf'):
                        top_or_bottom = dis_by_directions['bottom'][i]
405
            else:
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
                top_or_bottom = [-1, float('inf')]

            if left_or_right[1] != float('inf') or top_or_bottom[1] != float('inf'):
                if left_or_right[1] != float('inf') and top_or_bottom[1] != float(
                    'inf'
                ):
                    if AXIS_MULPLICITY * axis_unit >= abs(
                        left_or_right[1] - top_or_bottom[1]
                    ):
                        y_axis_bbox = subjects[left_or_right[0]]['bbox']
                        x_axis_bbox = subjects[top_or_bottom[0]]['bbox']

                        if (
                            abs((x_axis_bbox[2] - x_axis_bbox[0]) - l_x_axis) / l_x_axis
                            > abs((y_axis_bbox[3] - y_axis_bbox[1]) - l_y_axis)
                            / l_y_axis
                        ):
                            sub_obj_map_h[left_or_right[0]].append(i)
                        else:
                            sub_obj_map_h[top_or_bottom[0]].append(i)
                    else:
                        if left_or_right[1] > top_or_bottom[1]:
                            sub_obj_map_h[top_or_bottom[0]].append(i)
                        else:
                            sub_obj_map_h[left_or_right[0]].append(i)
                else:
                    if left_or_right[1] != float('inf'):
                        sub_obj_map_h[left_or_right[0]].append(i)
                    else:
                        sub_obj_map_h[top_or_bottom[0]].append(i)
436
437
438
439
        ret = []
        for i in sub_obj_map_h.keys():
            ret.append(
                {
icecraft's avatar
icecraft committed
440
441
442
443
                    'sub_bbox': {
                        'bbox': subjects[i]['bbox'],
                        'score': subjects[i]['score'],
                    },
444
445
446
447
                    'obj_bboxes': [
                        {'score': objects[j]['score'], 'bbox': objects[j]['bbox']}
                        for j in sub_obj_map_h[i]
                    ],
448
449
450
451
452
                    'sub_idx': i,
                }
            )
        return ret

icecraft's avatar
icecraft committed
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490

    def __tie_up_category_by_distance_v3(
        self,
        page_no: int,
        subject_category_id: int,
        object_category_id: int,
        priority_pos: PosRelationEnum,
    ):
        subjects = self.__reduct_overlap(
            list(
                map(
                    lambda x: {'bbox': x['bbox'], 'score': x['score']},
                    filter(
                        lambda x: x['category_id'] == subject_category_id,
                        self.__model_list[page_no]['layout_dets'],
                    ),
                )
            )
        )
        objects = self.__reduct_overlap(
            list(
                map(
                    lambda x: {'bbox': x['bbox'], 'score': x['score']},
                    filter(
                        lambda x: x['category_id'] == object_category_id,
                        self.__model_list[page_no]['layout_dets'],
                    ),
                )
            )
        )

        ret = []
        N, M = len(subjects), len(objects)
        subjects.sort(key=lambda x: x['bbox'][0] ** 2 + x['bbox'][1] ** 2)
        objects.sort(key=lambda x: x['bbox'][0] ** 2 + x['bbox'][1] ** 2)

        OBJ_IDX_OFFSET = 10000
        SUB_BIT_KIND, OBJ_BIT_KIND = 0, 1
491

icecraft's avatar
icecraft committed
492
493
494
        all_boxes_with_idx = [(i, SUB_BIT_KIND, sub['bbox'][0], sub['bbox'][1]) for i, sub in enumerate(subjects)] + [(i + OBJ_IDX_OFFSET , OBJ_BIT_KIND, obj['bbox'][0], obj['bbox'][1]) for i, obj in enumerate(objects)]
        seen_idx = set()
        seen_sub_idx = set()
495

icecraft's avatar
icecraft committed
496
        while N > len(seen_sub_idx):
497
            candidates = []
icecraft's avatar
icecraft committed
498
499
            for idx, kind, x0, y0 in all_boxes_with_idx:
                if idx in seen_idx:
500
                    continue
icecraft's avatar
icecraft committed
501
                candidates.append((idx, kind, x0, y0))
502

icecraft's avatar
icecraft committed
503
504
505
506
            if len(candidates) == 0:
                break
            left_x = min([v[2] for v in candidates])
            top_y =  min([v[3] for v in candidates])
507

icecraft's avatar
icecraft committed
508
509
            candidates.sort(key=lambda x: (x[2]-left_x) ** 2 + (x[3] - top_y) ** 2)

510

icecraft's avatar
icecraft committed
511
512
513
            fst_idx, fst_kind, left_x, top_y = candidates[0]
            candidates.sort(key=lambda x: (x[2] - left_x) ** 2 + (x[3] - top_y)**2)
            nxt = None
514

icecraft's avatar
icecraft committed
515
516
517
            for i in range(1, len(candidates)):
                if candidates[i][1] ^ fst_kind == 1:
                    nxt = candidates[i]
518
                    break
icecraft's avatar
icecraft committed
519
520
            if nxt is None:
                break
521

icecraft's avatar
icecraft committed
522
523
            if fst_kind == SUB_BIT_KIND:
                sub_idx, obj_idx = fst_idx, nxt[0] - OBJ_IDX_OFFSET
524

icecraft's avatar
icecraft committed
525
526
            else:
                sub_idx, obj_idx = nxt[0], fst_idx - OBJ_IDX_OFFSET
527

528
529
530
            pair_dis = bbox_distance(subjects[sub_idx]['bbox'], objects[obj_idx]['bbox'])
            nearest_dis = float('inf')
            for i in range(N):
icecraft's avatar
icecraft committed
531
                if i in seen_idx or i == sub_idx:continue
532
533
534
535
                nearest_dis = min(nearest_dis, bbox_distance(subjects[i]['bbox'], objects[obj_idx]['bbox']))

            if pair_dis >= 3*nearest_dis:
                seen_idx.add(sub_idx)
536
537
                continue

538
539
540
            seen_idx.add(sub_idx)
            seen_idx.add(obj_idx + OBJ_IDX_OFFSET)
            seen_sub_idx.add(sub_idx)
541

icecraft's avatar
icecraft committed
542
543
544
545
546
547
548
549
550
551
552
553
554
            ret.append(
                {
                    'sub_bbox': {
                        'bbox': subjects[sub_idx]['bbox'],
                        'score': subjects[sub_idx]['score'],
                    },
                    'obj_bboxes': [
                        {'score': objects[obj_idx]['score'], 'bbox': objects[obj_idx]['bbox']}
                    ],
                    'sub_idx': sub_idx,
                }
            )

icecraft's avatar
icecraft committed
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
        for i in range(len(objects)):
            j = i + OBJ_IDX_OFFSET
            if j in seen_idx:
                continue
            seen_idx.add(j)
            nearest_dis, nearest_sub_idx = float('inf'), -1
            for k in range(len(subjects)):
                dis = bbox_distance(objects[i]['bbox'], subjects[k]['bbox'])
                if dis < nearest_dis:
                    nearest_dis = dis
                    nearest_sub_idx = k

            for k in range(len(subjects)):
                if k != nearest_sub_idx: continue
                if k in seen_sub_idx:
                    for kk in range(len(ret)):
                        if ret[kk]['sub_idx'] == k:
                            ret[kk]['obj_bboxes'].append({'score': objects[i]['score'], 'bbox': objects[i]['bbox']})
                            break
                else:
                    ret.append(
                        {
                            'sub_bbox': {
                                'bbox': subjects[k]['bbox'],
                                'score': subjects[k]['score'],
                            },
                            'obj_bboxes': [
                                {'score': objects[i]['score'], 'bbox': objects[i]['bbox']}
                            ],
                            'sub_idx': k,
                        }
                    )
                seen_sub_idx.add(k)
                seen_idx.add(k)


icecraft's avatar
icecraft committed
591
592
        for i in range(len(subjects)):
            if i in seen_sub_idx:
593
                continue
icecraft's avatar
icecraft committed
594
595
596
597
598
599
600
601
602
603
            ret.append(
                {
                    'sub_bbox': {
                        'bbox': subjects[i]['bbox'],
                        'score': subjects[i]['score'],
                    },
                    'obj_bboxes': [],
                    'sub_idx': i,
                }
            )
604
605


icecraft's avatar
icecraft committed
606
607
608
        return ret


609
    def get_imgs_v2(self, page_no: int):
icecraft's avatar
icecraft committed
610
        with_captions = self.__tie_up_category_by_distance_v3(
icecraft's avatar
icecraft committed
611
612
            page_no, 3, 4, PosRelationEnum.BOTTOM
        )
icecraft's avatar
icecraft committed
613
        with_footnotes = self.__tie_up_category_by_distance_v3(
icecraft's avatar
icecraft committed
614
            page_no, 3, CategoryId.ImageFootnote, PosRelationEnum.ALL
615
616
617
618
        )
        ret = []
        for v in with_captions:
            record = {
619
620
                'image_body': v['sub_bbox'],
                'image_caption_list': v['obj_bboxes'],
621
622
623
            }
            filter_idx = v['sub_idx']
            d = next(filter(lambda x: x['sub_idx'] == filter_idx, with_footnotes))
624
            record['image_footnote_list'] = d['obj_bboxes']
625
626
627
628
            ret.append(record)
        return ret

    def get_tables_v2(self, page_no: int) -> list:
icecraft's avatar
icecraft committed
629
        with_captions = self.__tie_up_category_by_distance_v3(
icecraft's avatar
icecraft committed
630
631
            page_no, 5, 6, PosRelationEnum.UP
        )
icecraft's avatar
icecraft committed
632
        with_footnotes = self.__tie_up_category_by_distance_v3(
icecraft's avatar
icecraft committed
633
634
            page_no, 5, 7, PosRelationEnum.ALL
        )
635
636
637
        ret = []
        for v in with_captions:
            record = {
638
639
                'table_body': v['sub_bbox'],
                'table_caption_list': v['obj_bboxes'],
640
641
642
            }
            filter_idx = v['sub_idx']
            d = next(filter(lambda x: x['sub_idx'] == filter_idx, with_footnotes))
643
            record['table_footnote_list'] = d['obj_bboxes']
644
645
646
            ret.append(record)
        return ret

blue's avatar
blue committed
647
    def get_imgs(self, page_no: int):
648
        return self.get_imgs_v2(page_no)
liukaiwen's avatar
liukaiwen committed
649
650

    def get_tables(
651
        self, page_no: int
liukaiwen's avatar
liukaiwen committed
652
    ) -> list:  # 3个坐标, caption, table主体,table-note
653
        return self.get_tables_v2(page_no)
liukaiwen's avatar
liukaiwen committed
654
655

    def get_equations(self, page_no: int) -> list:  # 有坐标,也有字
656
        inline_equations = self.__get_blocks_by_type(
657
            ModelBlockTypeEnum.EMBEDDING.value, page_no, ['latex']
658
659
        )
        interline_equations = self.__get_blocks_by_type(
660
            ModelBlockTypeEnum.ISOLATED.value, page_no, ['latex']
661
662
663
664
        )
        interline_equations_blocks = self.__get_blocks_by_type(
            ModelBlockTypeEnum.ISOLATE_FORMULA.value, page_no
        )
liukaiwen's avatar
liukaiwen committed
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
        return inline_equations, interline_equations, interline_equations_blocks

    def get_discarded(self, page_no: int) -> list:  # 自研模型,只有坐标
        blocks = self.__get_blocks_by_type(ModelBlockTypeEnum.ABANDON.value, page_no)
        return blocks

    def get_text_blocks(self, page_no: int) -> list:  # 自研模型搞的,只有坐标,没有字
        blocks = self.__get_blocks_by_type(ModelBlockTypeEnum.PLAIN_TEXT.value, page_no)
        return blocks

    def get_title_blocks(self, page_no: int) -> list:  # 自研模型,只有坐标,没字
        blocks = self.__get_blocks_by_type(ModelBlockTypeEnum.TITLE.value, page_no)
        return blocks

    def get_ocr_text(self, page_no: int) -> list:  # paddle 搞的,有字也有坐标
        text_spans = []
        model_page_info = self.__model_list[page_no]
682
        layout_dets = model_page_info['layout_dets']
liukaiwen's avatar
liukaiwen committed
683
        for layout_det in layout_dets:
684
            if layout_det['category_id'] == '15':
liukaiwen's avatar
liukaiwen committed
685
                span = {
686
687
                    'bbox': layout_det['bbox'],
                    'content': layout_det['text'],
liukaiwen's avatar
liukaiwen committed
688
689
690
691
692
                }
                text_spans.append(span)
        return text_spans

    def get_all_spans(self, page_no: int) -> list:
693

694
695
696
697
698
699
        def remove_duplicate_spans(spans):
            new_spans = []
            for span in spans:
                if not any(span == existing_span for existing_span in new_spans):
                    new_spans.append(span)
            return new_spans
blue's avatar
blue committed
700

liukaiwen's avatar
liukaiwen committed
701
702
        all_spans = []
        model_page_info = self.__model_list[page_no]
703
        layout_dets = model_page_info['layout_dets']
liukaiwen's avatar
liukaiwen committed
704
705
706
        allow_category_id_list = [3, 5, 13, 14, 15]
        """当成span拼接的"""
        #  3: 'image', # 图片
707
        #  5: 'table',       # 表格
liukaiwen's avatar
liukaiwen committed
708
709
710
711
        #  13: 'inline_equation',     # 行内公式
        #  14: 'interline_equation',      # 行间公式
        #  15: 'text',      # ocr识别文本
        for layout_det in layout_dets:
712
            category_id = layout_det['category_id']
liukaiwen's avatar
liukaiwen committed
713
            if category_id in allow_category_id_list:
714
                span = {'bbox': layout_det['bbox'], 'score': layout_det['score']}
liukaiwen's avatar
liukaiwen committed
715
                if category_id == 3:
716
                    span['type'] = ContentType.Image
liukaiwen's avatar
liukaiwen committed
717
                elif category_id == 5:
718
                    # 获取table模型结果
719
720
                    latex = layout_det.get('latex', None)
                    html = layout_det.get('html', None)
721
                    if latex:
722
                        span['latex'] = latex
723
                    elif html:
724
725
                        span['html'] = html
                    span['type'] = ContentType.Table
liukaiwen's avatar
liukaiwen committed
726
                elif category_id == 13:
727
728
                    span['content'] = layout_det['latex']
                    span['type'] = ContentType.InlineEquation
liukaiwen's avatar
liukaiwen committed
729
                elif category_id == 14:
730
731
                    span['content'] = layout_det['latex']
                    span['type'] = ContentType.InterlineEquation
liukaiwen's avatar
liukaiwen committed
732
                elif category_id == 15:
733
734
                    span['content'] = layout_det['text']
                    span['type'] = ContentType.Text
liukaiwen's avatar
liukaiwen committed
735
                all_spans.append(span)
736
        return remove_duplicate_spans(all_spans)
liukaiwen's avatar
liukaiwen committed
737
738
739

    def get_page_size(self, page_no: int):  # 获取页面宽高
        # 获取当前页的page对象
740
        page = self.__docs.get_page(page_no).get_page_info()
liukaiwen's avatar
liukaiwen committed
741
        # 获取当前页的宽高
742
743
        page_w = page.w
        page_h = page.h
liukaiwen's avatar
liukaiwen committed
744
745
        return page_w, page_h

746
747
748
    def __get_blocks_by_type(
        self, type: int, page_no: int, extra_col: list[str] = []
    ) -> list:
liukaiwen's avatar
liukaiwen committed
749
750
        blocks = []
        for page_dict in self.__model_list:
751
752
753
            layout_dets = page_dict.get('layout_dets', [])
            page_info = page_dict.get('page_info', {})
            page_number = page_info.get('page_no', -1)
liukaiwen's avatar
liukaiwen committed
754
755
756
            if page_no != page_number:
                continue
            for item in layout_dets:
757
758
                category_id = item.get('category_id', -1)
                bbox = item.get('bbox', None)
liukaiwen's avatar
liukaiwen committed
759

liukaiwen's avatar
liukaiwen committed
760
                if category_id == type:
761
                    block = {
762
763
                        'bbox': bbox,
                        'score': item.get('score'),
764
                    }
liukaiwen's avatar
liukaiwen committed
765
766
767
768
769
                    for col in extra_col:
                        block[col] = item.get(col, None)
                    blocks.append(block)
        return blocks

许瑞's avatar
许瑞 committed
770
771
    def get_model_list(self, page_no):
        return self.__model_list[page_no]