magic_model.py 29.9 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
531
532
533
534
535
            pair_dis = bbox_distance(subjects[sub_idx]['bbox'], objects[obj_idx]['bbox'])
            nearest_dis = float('inf')
            for i in range(N):
                if i in seen_idx:continue
                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
541

            seen_idx.add(sub_idx)
            seen_idx.add(obj_idx + OBJ_IDX_OFFSET)
            seen_sub_idx.add(sub_idx)
542

icecraft's avatar
icecraft committed
543
544
545
546
547
548
549
550
551
552
553
554
555
            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
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
591
        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
592
593
        for i in range(len(subjects)):
            if i in seen_sub_idx:
594
                continue
icecraft's avatar
icecraft committed
595
596
597
598
599
600
601
602
603
604
            ret.append(
                {
                    'sub_bbox': {
                        'bbox': subjects[i]['bbox'],
                        'score': subjects[i]['score'],
                    },
                    'obj_bboxes': [],
                    'sub_idx': i,
                }
            )
605
606


icecraft's avatar
icecraft committed
607
608
609
        return ret


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

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

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

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

    def get_equations(self, page_no: int) -> list:  # 有坐标,也有字
657
        inline_equations = self.__get_blocks_by_type(
658
            ModelBlockTypeEnum.EMBEDDING.value, page_no, ['latex']
659
660
        )
        interline_equations = self.__get_blocks_by_type(
661
            ModelBlockTypeEnum.ISOLATED.value, page_no, ['latex']
662
663
664
665
        )
        interline_equations_blocks = self.__get_blocks_by_type(
            ModelBlockTypeEnum.ISOLATE_FORMULA.value, page_no
        )
liukaiwen's avatar
liukaiwen committed
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
        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]
683
        layout_dets = model_page_info['layout_dets']
liukaiwen's avatar
liukaiwen committed
684
        for layout_det in layout_dets:
685
            if layout_det['category_id'] == '15':
liukaiwen's avatar
liukaiwen committed
686
                span = {
687
688
                    'bbox': layout_det['bbox'],
                    'content': layout_det['text'],
liukaiwen's avatar
liukaiwen committed
689
690
691
692
693
                }
                text_spans.append(span)
        return text_spans

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

695
696
697
698
699
700
        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
701

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

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

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

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

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