convert_pdf.py 63 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492
  1. import copy
  2. import io
  3. import os
  4. import re
  5. import sys
  6. from bs4 import BeautifulSoup
  7. sys.path.append(os.path.dirname(__file__) + "/../")
  8. from pdfplumber import PDF
  9. from pdfplumber.table import TableFinder
  10. from pdfplumber.page import Page as pdfPage
  11. from format_convert.convert_tree import _Document, _Page, _Image, _Sentence, _Table, TextBox
  12. import time
  13. from PIL import Image
  14. import traceback
  15. import cv2
  16. import PyPDF2
  17. from PyPDF2 import PdfFileReader, PdfFileWriter
  18. from pdfminer.pdfparser import PDFParser
  19. from pdfminer.pdfdocument import PDFDocument
  20. from pdfminer.pdfpage import PDFPage
  21. from pdfminer.pdfinterp import PDFResourceManager, PDFPageInterpreter
  22. from pdfminer.converter import PDFPageAggregator
  23. from pdfminer.layout import LTTextBoxHorizontal, LAParams, LTFigure, LTImage, LTCurve, LTText, LTChar, LTRect, \
  24. LTTextBoxVertical, LTLine, LTTextContainer, LTTextLine
  25. from format_convert.utils import judge_error_code, get_platform, LineTable, log, \
  26. memory_decorator, get_garble_code, get_md5_from_bytes, bytes2np, bbox_iou, get_garble_code2, get_traditional_chinese
  27. import fitz
  28. from format_convert.wrapt_timeout_decorator import timeout
  29. from otr.table_line_pdf import table_line_pdf
  30. # import jieba
  31. @memory_decorator
  32. def pdf2text(path, unique_type_dir):
  33. return
  34. @timeout(10, timeout_exception=TimeoutError)
  35. def pdf_analyze(interpreter, page, device, page_no):
  36. pdf_time = time.time()
  37. interpreter.process_page(page)
  38. layout = device.get_result()
  39. log("page_no: " + str(page_no) + " pdf_analyze cost: " + str(time.time() - pdf_time))
  40. return layout
  41. @timeout(25, timeout_exception=TimeoutError)
  42. def read_pdfminer(path, laparams):
  43. fp = open(path, 'rb')
  44. parser = PDFParser(fp)
  45. doc_pdfminer = PDFDocument(parser)
  46. rsrcmgr = PDFResourceManager()
  47. device = PDFPageAggregator(rsrcmgr, laparams=laparams)
  48. interpreter = PDFPageInterpreter(rsrcmgr, device)
  49. return doc_pdfminer, device, interpreter
  50. @timeout(15, timeout_exception=TimeoutError)
  51. def read_pymupdf(path):
  52. return fitz.open(path)
  53. @timeout(15, timeout_exception=TimeoutError)
  54. def read_pypdf2(path):
  55. doc_pypdf2 = PdfFileReader(path, strict=False)
  56. doc_pypdf2_new = PdfFileWriter()
  57. return doc_pypdf2, doc_pypdf2_new
  58. @timeout(25, timeout_exception=TimeoutError, use_signals=False)
  59. def read_pdfplumber(path, laparams):
  60. fp = open(path, 'rb')
  61. lt = LineTable()
  62. doc_top = 0
  63. doc_pdfplumber = PDF(fp, laparams=laparams.__dict__)
  64. return lt, doc_top, doc_pdfplumber
  65. class PDFConvert:
  66. def __init__(self, path, unique_type_dir, need_page_no):
  67. self._doc = _Document(path)
  68. self.path = path
  69. self.unique_type_dir = unique_type_dir
  70. if not os.path.exists(self.unique_type_dir):
  71. os.mkdir(self.unique_type_dir)
  72. # 指定提取的页码范围
  73. self.need_page_no = need_page_no
  74. self.start_page_no = None
  75. self.end_page_no = None
  76. # 默认使用limit_page_cnt控制,前10页后10页
  77. if self.need_page_no is None:
  78. self.limit_page_cnt = 20
  79. else:
  80. # 使用start_page_no,end_page_no范围控制,例如2,5
  81. ss = self.need_page_no.split(',')
  82. if len(ss) != 2:
  83. self._doc.error_code = [-14]
  84. else:
  85. self.start_page_no = int(ss[0])
  86. self.end_page_no = int(ss[-1])
  87. if self.end_page_no == -1:
  88. self.end_page_no = 1000000
  89. self.start_page_no -= 1
  90. self.end_page_no -= 1
  91. if self.end_page_no <= self.start_page_no or self.start_page_no < 0 or self.end_page_no < -1:
  92. self._doc.error_code = [-14]
  93. self.packages = ["pdfminer", "PyMuPDF", "PyPDF2", "pdfplumber"]
  94. self.has_init_pdf = [0] * len(self.packages)
  95. # 记录图片对象的md5,用于去除大量重复图片
  96. self.md5_image_obj_list = []
  97. # 记录该页是不是纯文本
  98. self.only_text_list = []
  99. # 是否提取特殊页
  100. self.convert_specific_page = 1
  101. @memory_decorator
  102. def init_package(self, package_name):
  103. # 各个包初始化
  104. try:
  105. laparams = LAParams(line_overlap=0.01,
  106. char_margin=0.3,
  107. line_margin=0.01,
  108. word_margin=0.01,
  109. boxes_flow=0.1, )
  110. if package_name == self.packages[0]:
  111. self.doc_pdfminer, self.device, self.interpreter = read_pdfminer(self.path, laparams)
  112. self.has_init_pdf[0] = 1
  113. elif package_name == self.packages[1]:
  114. self.doc_pymupdf = read_pymupdf(self.path)
  115. self.has_init_pdf[1] = 1
  116. elif package_name == self.packages[2]:
  117. self.doc_pypdf2, self.doc_pypdf2_new = read_pypdf2(self.path)
  118. self.has_init_pdf[2] = 1
  119. elif package_name == self.packages[3]:
  120. self.lt, self.doc_top, self.doc_pdfplumber = read_pdfplumber(self.path, laparams)
  121. self.has_init_pdf[3] = 1
  122. else:
  123. log("Only Support Packages " + str(self.packages))
  124. raise Exception
  125. except Exception as e:
  126. log(package_name + " cannot open pdf!")
  127. traceback.print_exc()
  128. self._doc.error_code = [-3]
  129. def convert(self, limit_page_cnt=20):
  130. if self.has_init_pdf[0] == 0:
  131. self.init_package("pdfminer")
  132. if self._doc.error_code is not None:
  133. self._doc.error_code = None
  134. # pdfminer读不了直接转成图片识别
  135. self.get_all_page_image()
  136. return
  137. # 判断是否能读pdf
  138. try:
  139. pages = PDFPage.create_pages(self.doc_pdfminer)
  140. for page in pages:
  141. break
  142. pages = list(pages)
  143. # except pdfminer.psparser.PSEOF as e:
  144. except:
  145. # pdfminer 读不了空白页的对象,直接使用pymupdf转换出的图片进行ocr识别
  146. log("pdfminer read failed! read by pymupdf!")
  147. traceback.print_exc()
  148. try:
  149. self.get_all_page_image()
  150. return
  151. except:
  152. traceback.print_exc()
  153. log("use pymupdf read failed!")
  154. self._doc.error_code = [-3]
  155. return
  156. # 每一页进行处理
  157. pages = PDFPage.create_pages(self.doc_pdfminer)
  158. pages = list(pages)
  159. page_count = len(pages)
  160. self.only_text_list = [-1] * len(pages)
  161. page_no = 0
  162. for page in pages:
  163. # 指定pdf页码
  164. if self.start_page_no is not None and self.end_page_no is not None:
  165. if page_count < self.end_page_no:
  166. self.end_page_no = page_count
  167. if page_no < self.start_page_no or page_no >= self.end_page_no:
  168. page_no += 1
  169. continue
  170. # 限制pdf页数,只取前后各10页
  171. else:
  172. if page_count > limit_page_cnt and int(limit_page_cnt/2) <= page_no < page_count - int(limit_page_cnt/2):
  173. page_no += 1
  174. continue
  175. # 解析单页
  176. start_time = time.time()
  177. self._page = _Page(page, page_no)
  178. self.convert_page(page, page_no)
  179. log('convert_page page_no: ' + str(page_no) + ' cost: ' + str(time.time()-start_time))
  180. if self._doc.error_code is None and self._page.error_code is not None:
  181. if self._page.error_code[0] in [-4, -3, 0]:
  182. page_no += 1
  183. continue
  184. else:
  185. self._doc.error_code = self._page.error_code
  186. break
  187. self._doc.add_child(self._page)
  188. page_no += 1
  189. self._doc.children, detete_header_footer_list = self.delete_header_footer(self._doc.children)
  190. if self.convert_specific_page and self.need_page_no is None:
  191. # 补充提取特定页
  192. # print('self.only_text_list', self.only_text_list)
  193. if self.only_text_list.count(0) == 0:
  194. ratio = 0
  195. else:
  196. ratio = self.only_text_list.count(0) / (page_count-self.only_text_list.count(-1))
  197. # print('ratio', ratio)
  198. if page_count > limit_page_cnt and ratio <= 0.2:
  199. page_no = 0
  200. find_flag = 0
  201. add_page_list = []
  202. for page in pages:
  203. if not int(limit_page_cnt/2) <= page_no < page_count - int(limit_page_cnt/2):
  204. page_no += 1
  205. continue
  206. # 解析单页
  207. start_time = time.time()
  208. self._page = _Page(page, page_no)
  209. self.convert_page(page, page_no, skip_image=1)
  210. log('convert_page add page_no: ' + str(page_no) + ' cost: ' + str(time.time()-start_time))
  211. # 删除页眉页脚
  212. pages, _ = self.delete_header_footer([self._page], detete_header_footer_list)
  213. self._page = pages[0]
  214. # 提取特殊部分
  215. re_str = '采购清单'
  216. # 坐标都是上下颠倒的,回正
  217. self._page.children.sort(key=lambda x: x.y, reverse=True)
  218. # print('find_flag', find_flag, type(self._page.children[-1]))
  219. if find_flag and type(self._page.children[0]) == _Table:
  220. add_page_list.append(self._page)
  221. if len(self._page.children) - 1 > 3:
  222. find_flag = 0
  223. for index in range(len(self._page.children)):
  224. obj = self._page.children[index]
  225. next_obj = None
  226. if index+1 < len(self._page.children):
  227. next_obj = self._page.children[index+1]
  228. # print('采购清单', type(obj) == _Sentence, re.search(re_str, str(obj.content)), str(obj.content)[:20])
  229. if type(obj) == _Sentence and re.search(re_str, obj.content) \
  230. and next_obj and type(next_obj) == _Table:
  231. add_page_list.append(self._page)
  232. # print('add_page_list', page_no)
  233. if len(self._page.children) - index - 1 > 3:
  234. find_flag = 0
  235. else:
  236. find_flag = 1
  237. page_no += 1
  238. # print('add_page_list', add_page_list)
  239. if add_page_list:
  240. self._doc.children = self._doc.children[:int(limit_page_cnt/2)] + add_page_list + self._doc.children[int(limit_page_cnt/2):]
  241. self.delete_same_image()
  242. # self.delete_bold_text_duplicate()
  243. def delete_same_image(self, show=0):
  244. # 剔除大量重复图片
  245. md5_dict = {}
  246. for _md5, image_obj in self.md5_image_obj_list:
  247. if _md5 in md5_dict.keys():
  248. md5_dict[_md5] += [image_obj]
  249. else:
  250. md5_dict[_md5] = [image_obj]
  251. cnt_threshold = 10
  252. delete_obj_list = []
  253. for _md5 in md5_dict.keys():
  254. img_list = md5_dict.get(_md5)
  255. # print('len(md5_dict.get(_md5))', _md5, len(img_list))
  256. if len(img_list) >= cnt_threshold:
  257. if show:
  258. img_np = bytes2np(img_list[0].content)
  259. cv2.namedWindow('delete same img_np', cv2.WINDOW_NORMAL)
  260. cv2.imshow('delete same img_np', img_np)
  261. cv2.waitKey(0)
  262. delete_obj_list += img_list
  263. for page in self._doc.children:
  264. for obj in delete_obj_list:
  265. if obj in page.children:
  266. page.children.remove(obj)
  267. if show:
  268. for page in self._doc.children:
  269. for obj in page.children:
  270. if isinstance(obj, _Image):
  271. img_np = bytes2np(obj.content)
  272. cv2.imshow('page img_np', img_np)
  273. cv2.waitKey(0)
  274. def delete_header_footer(self, pages, delete_list=[]):
  275. sen_dict = {}
  276. for page in pages:
  277. for obj in page.children:
  278. if isinstance(obj, _Sentence):
  279. key = str(obj.content) + ' ' + str(int(obj.y))
  280. # print('key', key)
  281. if key in sen_dict.keys():
  282. sen_dict[key] += [obj]
  283. else:
  284. sen_dict[key] = [obj]
  285. # 把需删除的加上
  286. # print('delete_list', delete_list)
  287. for key in delete_list:
  288. if key in sen_dict:
  289. sen_dict[key] = sen_dict.get(key) * 10
  290. # print('sen_dict', sen_dict)
  291. delete_footer_header_list = []
  292. for key in sen_dict.keys():
  293. l = sen_dict.get(key)
  294. if len(l) >= 1/3 * max(10, len(pages)):
  295. delete_footer_header_list.append(key)
  296. for page in pages:
  297. new_children = []
  298. for obj in page.children:
  299. if isinstance(obj, _Sentence):
  300. if obj not in l:
  301. new_children.append(obj)
  302. else:
  303. new_children.append(obj)
  304. page.children = new_children
  305. # print('len(l)', len(l), len(pages))
  306. # print('delete_header_footer l[0]', l[0].content, l[0].y)
  307. return pages, delete_footer_header_list
  308. def delete_bold_text_duplicate(self, lt_text_box_list):
  309. # 拿出所有LTChar
  310. lt_char_list = []
  311. for lt_text_box in lt_text_box_list:
  312. for lt_text_line in lt_text_box:
  313. for lt_char in lt_text_line:
  314. if isinstance(lt_char, LTChar):
  315. lt_char_list.append(lt_char)
  316. # 找出需剔除的
  317. lt_char_list.sort(key=lambda x: (int(x.bbox[1]), x.bbox[0]))
  318. delete_list = []
  319. for i in range(len(lt_char_list)):
  320. lt_char1 = lt_char_list[i]
  321. bbox1 = lt_char1.bbox
  322. # lt_char2 = lt_char_list[i+1]
  323. # bbox2 = lt_char2.bbox
  324. if lt_char1 in delete_list:
  325. continue
  326. # if lt_char2 in delete_list:
  327. # continue
  328. # if lt_char1.get_text() == lt_char2.get_text() and bbox1[0] <= bbox2[0] <= bbox1[2] <= bbox2[2] \
  329. # and int(bbox1[1]) == int(bbox2[1]) and int(bbox1[3]) == int(bbox2[3]) \
  330. # and re.search('[\u4e00-\u9fff():、,。]', lt_char1.get_text()):
  331. for j in range(i+1, len(lt_char_list)):
  332. lt_char2 = lt_char_list[j]
  333. bbox2 = lt_char2.bbox
  334. if lt_char2 in delete_list:
  335. continue
  336. if lt_char1.get_text() == lt_char2.get_text() and bbox_iou(bbox1, bbox2) >= 0.3 \
  337. and re.search('[\u4e00-\u9fff():、,。]', lt_char1.get_text()):
  338. # continue
  339. delete_list.append(lt_char2)
  340. # 重新组装
  341. new_lt_text_box_list = []
  342. for lt_text_box in lt_text_box_list:
  343. new_lt_text_box = LTTextBoxHorizontal()
  344. for lt_text_line in lt_text_box:
  345. new_lt_text_line = LTTextLine(0.01)
  346. for lt_char in lt_text_line:
  347. if lt_char in delete_list:
  348. continue
  349. if isinstance(lt_char, LTChar):
  350. new_lt_text_line.add(lt_char)
  351. new_lt_text_box.add(new_lt_text_line)
  352. new_lt_text_box_list.append(new_lt_text_box)
  353. return new_lt_text_box_list
  354. def clean_text(self, _text):
  355. return re.sub("\s", "", _text)
  356. def get_text_lines(self, page, page_no):
  357. lt_line_list = []
  358. page_plumber = pdfPage(self.doc_pdfplumber, page, page_number=page_no, initial_doctop=self.doc_top)
  359. self.doc_top += page_plumber.height
  360. table_finder = TableFinder(page_plumber)
  361. all_width_zero = True
  362. for _edge in table_finder.get_edges():
  363. if _edge.get('linewidth') and _edge.get('linewidth') > 0:
  364. all_width_zero = False
  365. break
  366. for _edge in table_finder.get_edges():
  367. # print(_edge)
  368. if _edge.get('linewidth', 0.1) > 0 or all_width_zero:
  369. lt_line_list.append(LTLine(1, (float(_edge["x0"]), float(_edge["y0"])),
  370. (float(_edge["x1"]), float(_edge["y1"]))))
  371. log("pdf page_no %s has %s lines" % (str(page_no), str(len(lt_line_list))))
  372. return lt_line_list
  373. def get_page_lines(self, layout, page_no, show=0):
  374. lt_line_list = table_line_pdf(layout, page_no, show)
  375. return lt_line_list
  376. def recognize_text(self, layout, page_no, lt_text_list, lt_line_list):
  377. list_tables, filter_objs, _, connect_textbox_list = self.lt.recognize_table(lt_text_list, lt_line_list,
  378. from_pdf=True, is_reverse=True)
  379. self._page.in_table_objs = filter_objs
  380. # print("=======text_len:%d:filter_len:%d"%(len(lt_text_list),len(filter_objs)))
  381. for table in list_tables:
  382. _table = _Table(table["table"], table["bbox"])
  383. # self._page.children.append(_table)
  384. self._page.add_child(_table)
  385. list_sentences = ParseUtils.recognize_sentences(lt_text_list, filter_objs,
  386. layout.bbox, page_no)
  387. for sentence in list_sentences:
  388. # print('sentence.text', sentence.text)
  389. _sen = _Sentence(sentence.text, sentence.bbox)
  390. self._page.add_child(_sen)
  391. # pdf对象需反向排序
  392. self._page.is_reverse = True
  393. return list_tables
  394. def is_text_legal(self, lt_text_list, page_no):
  395. # 无法识别pdf字符编码,整页用ocr
  396. text_temp = ""
  397. for _t in lt_text_list:
  398. text_temp += _t.get_text()
  399. if re.search('[(]cid:[0-9]+[)]', text_temp):
  400. log("page_no: " + str(page_no) + " text has cid! try pymupdf...")
  401. page_image = self.get_page_image(page_no)
  402. if judge_error_code(page_image):
  403. self._page.error_code = page_image
  404. else:
  405. _image = _Image(page_image[1], page_image[0])
  406. self._page.add_child(_image)
  407. return False
  408. match1 = re.findall(get_garble_code(), text_temp)
  409. # match2 = re.search('[\u4e00-\u9fa5]', text_temp)
  410. if len(match1) > 8 and len(text_temp) > 10:
  411. log("page_no: " + str(page_no) + " garbled code! try pymupdf... " + text_temp[:20])
  412. page_image = self.get_page_image(page_no)
  413. if judge_error_code(page_image):
  414. self._page.error_code = page_image
  415. else:
  416. _image = _Image(page_image[1], page_image[0])
  417. self._page.add_child(_image)
  418. return False
  419. return True
  420. def judge_b_table(self, lt_text_list, table_list, page_no):
  421. table_h_list = []
  422. for table in table_list:
  423. table_h_list.append([table.get('bbox')[1], table.get('bbox')[3]])
  424. # 先分行
  425. lt_text_list.sort(key=lambda x: (x.bbox[1], x.bbox[0]))
  426. lt_text_row_list = []
  427. current_h = lt_text_list[0].bbox[1]
  428. row = []
  429. threshold = 2
  430. for lt_text in lt_text_list:
  431. bbox = lt_text.bbox
  432. if current_h - threshold <= bbox[1] <= current_h + threshold:
  433. row.append(lt_text)
  434. else:
  435. if row:
  436. lt_text_row_list.append(row)
  437. row = [lt_text]
  438. current_h = lt_text.bbox[1]
  439. if row:
  440. lt_text_row_list.append(row)
  441. # 判断文本中间是否是空格,或一行文本中间有多个
  442. is_b_table_cnt = 3
  443. tolerate_cnt = 2
  444. t_cnt = 0
  445. row_cnt = 0
  446. b_table_row_list = []
  447. all_b_table = []
  448. for row in lt_text_row_list:
  449. # 水印行跳过
  450. if len(row) == 1 and len(row[0].get_text()[:-1]) == 1:
  451. continue
  452. # 目录行跳过
  453. continue_flag = False
  454. for r in row:
  455. if re.search('[.·]{7,}', r.get_text()):
  456. continue_flag = True
  457. break
  458. if continue_flag:
  459. continue
  460. if len(row) == 1:
  461. text = row[0].get_text()
  462. bbox = row[0].bbox
  463. match = re.search('[ ]{3,}', text)
  464. if match and re.search('[\u4e00-\u9fff]{2,}', text[:match.span()[0]]) \
  465. and re.search('[\u4e00-\u9fff]{2,}', text[match.span()[1]:]):
  466. row_cnt += 1
  467. t_cnt = 0
  468. b_table_row_list += row
  469. else:
  470. # 容忍
  471. if t_cnt < tolerate_cnt:
  472. t_cnt += 1
  473. continue
  474. if b_table_row_list and row_cnt >= is_b_table_cnt:
  475. all_b_table.append(b_table_row_list)
  476. row_cnt = 0
  477. b_table_row_list = []
  478. else:
  479. row_cnt += 1
  480. t_cnt = 0
  481. b_table_row_list += row
  482. if b_table_row_list and row_cnt >= is_b_table_cnt:
  483. all_b_table.append(b_table_row_list)
  484. # 对每个可能的b_table判断是否与table相交
  485. is_b_table_flag = False
  486. for b_table in all_b_table:
  487. # 判断在不在有边框表格的范围
  488. in_flag = False
  489. for table_h in table_h_list:
  490. for b in b_table:
  491. if min(table_h) <= b.bbox[1] <= max(table_h) or min(table_h) <= b.bbox[3] <= max(table_h):
  492. in_flag = True
  493. break
  494. if in_flag:
  495. break
  496. if in_flag:
  497. is_b_table_flag = False
  498. else:
  499. is_b_table_flag = True
  500. # print('is_b_table_flag True ', [[x.get_text(), x.bbox] for x in b_table])
  501. # print('table_h_list', table_h_list)
  502. break
  503. log("page_no: " + str(page_no) + ' is_b_table_flag ' + str(is_b_table_flag))
  504. return is_b_table_flag
  505. def convert_page(self, page, page_no, skip_image=0):
  506. layout = self.get_layout(page, page_no)
  507. if self._doc.error_code is not None:
  508. return
  509. if judge_error_code(layout):
  510. self._page.error_code = layout
  511. return
  512. # 判断该页的对象类型,并存储
  513. lt_text_list = []
  514. lt_image_list = []
  515. for x in layout:
  516. if isinstance(x, (LTTextBoxHorizontal, LTTextBoxVertical)):
  517. lt_text_list.append(x)
  518. if isinstance(x, LTFigure):
  519. for y in x:
  520. if isinstance(y, LTImage):
  521. # 小的图忽略
  522. if y.width <= 300 and y.height <= 300:
  523. continue
  524. # 图的width超过layout width,很大可能是水印
  525. if y.width > layout.width + 20:
  526. continue
  527. lt_image_list.append(y)
  528. # 判断纯文本
  529. if len(lt_image_list) == 0 and len(lt_text_list) == 0:
  530. self.only_text_list[page_no] = 0
  531. elif len(lt_image_list) == 0:
  532. self.only_text_list[page_no] = 1
  533. else:
  534. self.only_text_list[page_no] = 0
  535. # 跳过图片
  536. if skip_image:
  537. lt_image_list = []
  538. # 判断读出来的是乱码,但有图片直接识别
  539. all_text = ''.join([x.get_text() for x in lt_text_list])
  540. all_text = re.sub('[\s\d]', '', all_text)
  541. if len(re.findall(get_garble_code2(), all_text)) >= 3 and len(lt_image_list) >= 1:
  542. log('嵌入的文字是乱码1: ' + str(all_text[:10]))
  543. lt_text_list = []
  544. # print('11111', re.findall(get_traditional_chinese(), all_text))
  545. if 3 <= len(re.findall(get_traditional_chinese(), all_text)) <= len(all_text) / 2 and len(lt_image_list) >= 1:
  546. log('嵌入的文字是乱码2: ' + str(all_text[:10]))
  547. lt_text_list = []
  548. # 解决重复粗体字问题
  549. lt_text_list = self.delete_bold_text_duplicate(lt_text_list)
  550. # 删除水印字
  551. lt_text_list = self.delete_water_mark(lt_text_list, layout.bbox, 15)
  552. log("page_no: " + str(page_no) + " len(lt_image_list), len(lt_text_list) " + str(len(lt_image_list)) + " " + str(len(lt_text_list)))
  553. # 若该页图片数量过多,或无文本,则直接ocr整页识别
  554. if len(lt_image_list) > 4 or len(lt_text_list) == 0:
  555. page_image = self.get_page_image(page_no)
  556. if judge_error_code(page_image):
  557. self._page.error_code = page_image
  558. else:
  559. _image = _Image(page_image[1], page_image[0])
  560. _image.is_from_pdf = True
  561. _image.is_reverse = False
  562. self._page.add_child(_image)
  563. # 正常读取该页对象
  564. else:
  565. # 图表对象
  566. for image in lt_image_list:
  567. try:
  568. # print("pdf2text LTImage size", page_no, image.width, image.height)
  569. image_stream = image.stream.get_data()
  570. # 小的图忽略
  571. if image.width <= 300 and image.height <= 300:
  572. continue
  573. # 查看提取的图片高宽,太大则用pdf输出图进行ocr识别
  574. img_test = Image.open(io.BytesIO(image_stream))
  575. if image.height >= 1000 and image.width >= 1000:
  576. page_image = self.get_page_image(page_no)
  577. if judge_error_code(page_image):
  578. self._page.error_code = page_image
  579. else:
  580. _image = _Image(page_image[1], page_image[0])
  581. _image.is_from_pdf = True
  582. _image.is_reverse = False
  583. self._page.add_child(_image)
  584. image_md5 = get_md5_from_bytes(page_image[1])
  585. self.md5_image_obj_list.append([image_md5, _image])
  586. return
  587. # 比较小的图则直接保存用ocr识别
  588. else:
  589. temp_path = self.unique_type_dir + 'page' + str(page_no) \
  590. + '_lt' + str(lt_image_list.index(image)) + '.jpg'
  591. img_test.save(temp_path)
  592. with open(temp_path, "rb") as ff:
  593. image_stream = ff.read()
  594. _image = _Image(image_stream, temp_path, image.bbox)
  595. self._page.add_child(_image)
  596. image_md5 = get_md5_from_bytes(image_stream)
  597. self.md5_image_obj_list.append([image_md5, _image])
  598. except Exception:
  599. log("page_no: " + str(page_no) + " pdfminer read image fail! use pymupdf read image...")
  600. traceback.print_exc()
  601. # pdf对象需反向排序
  602. self._page.is_reverse = True
  603. if self.has_init_pdf[3] == 0:
  604. self.init_package("pdfplumber")
  605. if not self.is_text_legal(lt_text_list, page_no):
  606. return
  607. try:
  608. lt_line_list = self.get_page_lines(layout, page_no)
  609. except:
  610. traceback.print_exc()
  611. lt_line_list = []
  612. self._page.error_code = [-13]
  613. table_list = self.recognize_text(layout, page_no, lt_text_list, lt_line_list)
  614. # 根据text规律,判断该页是否可能有无边框表格
  615. if self.judge_b_table(lt_text_list, table_list, page_no):
  616. page_image = self.get_page_image(page_no)
  617. if judge_error_code(page_image):
  618. self._page.error_code = page_image
  619. else:
  620. _image = _Image(page_image[1], page_image[0])
  621. _image.is_from_pdf = True
  622. _image.is_reverse = True
  623. _image.b_table_from_text = True
  624. _image.b_table_text_obj_list = lt_text_list
  625. _image.b_table_layout_size = (layout.width, layout.height)
  626. self._page.add_child(_image)
  627. def get_layout(self, page, page_no):
  628. if self.has_init_pdf[0] == 0:
  629. self.init_package("pdfminer")
  630. if self._doc.error_code is not None:
  631. return
  632. # 获取该页layout
  633. start_time = time.time()
  634. try:
  635. if get_platform() == "Windows":
  636. layout = pdf_analyze(self.interpreter, page, self.device, page_no)
  637. else:
  638. layout = pdf_analyze(self.interpreter, page, self.device, page_no)
  639. except TimeoutError as e:
  640. log("page_no: " + str(page_no) + " pdfminer read page time out! " + str(time.time() - start_time))
  641. layout = [-4]
  642. except Exception:
  643. traceback.print_exc()
  644. log("page_no: " + str(page_no) + " pdfminer read page error! continue...")
  645. layout = [-3]
  646. log("page_no: " + str(page_no) + " get_layout cost: " + str(time.time()-start_time))
  647. return layout
  648. def get_page_image(self, page_no):
  649. start_time = time.time()
  650. try:
  651. if self.has_init_pdf[1] == 0:
  652. self.init_package("PyMuPDF")
  653. if self._doc.error_code is not None:
  654. return
  655. # save_dir = self.path.split(".")[-2] + "_" + self.path.split(".")[-1]
  656. output = self.unique_type_dir + "page" + str(page_no) + ".png"
  657. page = self.doc_pymupdf.loadPage(page_no)
  658. rotate = int(0)
  659. zoom_x = 2.
  660. zoom_y = 2.
  661. mat = fitz.Matrix(zoom_x, zoom_y).preRotate(rotate)
  662. pix = page.getPixmap(matrix=mat, alpha=False)
  663. pix.writePNG(output)
  664. # 输出图片resize
  665. self.resize_image(output)
  666. with open(output, "rb") as f:
  667. pdf_image = f.read()
  668. log("page_no: " + str(page_no) + ' get_page_image cost: ' + str(time.time()-start_time))
  669. return [output, pdf_image]
  670. except ValueError as e:
  671. traceback.print_exc()
  672. if str(e) == "page not in document":
  673. log("page_no: " + str(page_no) + " page not in document! continue...")
  674. return [0]
  675. elif "encrypted" in str(e):
  676. log("page_no: " + str(page_no) + " document need password")
  677. return [-7]
  678. except RuntimeError as e:
  679. if "cannot find page" in str(e):
  680. log("page_no: " + str(page_no) + " page cannot find in document! continue...")
  681. return [0]
  682. else:
  683. traceback.print_exc()
  684. return [-3]
  685. def get_all_page_image(self):
  686. start_time = time.time()
  687. if self.has_init_pdf[1] == 0:
  688. self.init_package("PyMuPDF")
  689. if self._doc.error_code is not None:
  690. return
  691. page_count = self.doc_pymupdf.page_count
  692. for page_no in range(page_count):
  693. # 限制pdf页数,只取前10页后10页
  694. if page_count > 20:
  695. if 10 <= page_no < page_count - 10:
  696. continue
  697. self._page = _Page(None, page_no)
  698. page_image = self.get_page_image(page_no)
  699. if judge_error_code(page_image):
  700. self._page.error_code = page_image
  701. else:
  702. _image = _Image(page_image[1], page_image[0])
  703. self._page.add_child(_image)
  704. # 报错继续读后面页面
  705. if self._doc.error_code is None and self._page.error_code is not None:
  706. continue
  707. self._doc.add_child(self._page)
  708. log('get_all_page_image cost: ' + str(time.time()-start_time))
  709. def connect_table(self, html_list):
  710. if not html_list:
  711. return html_list
  712. # 判断初始条件1
  713. # 0: 前一页最后一个表格为A,后一页第一个表格为B
  714. # 1.1: A后无文本(除了页码),且B前无文本(除了页码)
  715. # 1.2: B前有文字(可能是页眉,小于60字),且B的第一行前几个单元格为空,且第一行不为空的单元格有文字较多的格子
  716. # 1.3: B前有文字(可能是页眉,小于60字),且B的第一行第一个单元格为空,且有文字的格子数量占所有格子的一半
  717. # 1.4: B前有文字(可能是页眉,小于60字),且B的第一行第一个单元格为纯数字序号
  718. # 1.5: A后有文字(除了页码还有页眉),且A的后面只有一行且中文不超过15个字
  719. connect_flag_list = []
  720. soup_list = []
  721. for i, h in enumerate(html_list):
  722. soup = BeautifulSoup(h, 'lxml')
  723. soup_list.append(soup)
  724. # 找最后一个表格
  725. last_table_start, last_table_end = None, None
  726. match = re.finditer('<table', h)
  727. for m in match:
  728. last_table_start = m.span()[0]
  729. if last_table_start is not None:
  730. match = re.finditer('</table>', h[last_table_start:])
  731. for m in match:
  732. last_table_end = m.span()[1] + last_table_start
  733. # 最后一个表格后有无除了页码外的内容
  734. connect_flag1 = False
  735. if last_table_end is not None:
  736. match = re.findall('[^-/第页0-9,,]', re.sub('<div>|</div>', '', h[last_table_end:]))
  737. # print('match', match.group())
  738. # if not match or match.group() == '':
  739. if len(match) == 0:
  740. connect_flag1 = True
  741. # 有页脚
  742. if not connect_flag1:
  743. if len(re.findall('<div>', h[last_table_end:])) <= 1 \
  744. and len(re.findall('[\u4e00-\u9fff]', h[last_table_end:])) <= 60:
  745. connect_flag1 = True
  746. # 找第一个表格
  747. first_table_start, first_table_end = None, None
  748. match = re.finditer('<table', h)
  749. for m in match:
  750. first_table_start = m.span()[0]
  751. break
  752. # 第一个表格前有无内容
  753. connect_flag2 = False
  754. if first_table_start is not None and first_table_start == 0:
  755. connect_flag2 = True
  756. # 有内容但是是页眉
  757. if not connect_flag2:
  758. tables = soup.findAll('table')
  759. if tables:
  760. first_table = tables[0]
  761. rows = first_table.findAll('tr')
  762. if rows:
  763. first_row = rows[0]
  764. col_text_len_list = [len(x.text) for x in first_row]
  765. col_text_list = [x.text for x in first_row]
  766. # 文字大于60且第一个为空
  767. if not connect_flag2 and len(h[:first_table_start]) <= 60 and col_text_len_list[0] == 0 and max(col_text_len_list) >= 30:
  768. connect_flag2 = True
  769. # 有文字格子数占一半一下且第一个格子为空
  770. if not connect_flag2 and col_text_len_list.count(0) >= len(col_text_len_list) / 2 and col_text_len_list[0] == 0:
  771. connect_flag2 = True
  772. # 表格前最多只有一行且第一个格子为纯数字
  773. if not connect_flag2 and len(col_text_list) > 0 and \
  774. len(re.findall('<div>', h[:first_table_start])) <= 0 and \
  775. len(re.findall('\d', col_text_list[0])) == len(col_text_list[0]):
  776. connect_flag2 = True
  777. # if not connect_flag2 and len(re.findall('<div>', h[:first_table_start])) <= 0 and len(re.findall('[\u4e00-\u9fff]', h[:first_table_start])) <= 25:
  778. # connect_flag2 = True
  779. connect_flag_list.append([i, connect_flag2, connect_flag1])
  780. print('connect_flag_list', connect_flag_list)
  781. # 根据条件1合并需连接页码,形成组
  782. connect_pages_list = []
  783. if connect_flag_list:
  784. temp_list = [connect_flag_list[0]]
  785. for i in range(1, len(connect_flag_list)):
  786. c = connect_flag_list[i]
  787. if c[1] and temp_list[-1][2]:
  788. temp_list.append(c)
  789. else:
  790. if temp_list:
  791. connect_pages_list.append(temp_list)
  792. temp_list = [c]
  793. # connect_pages_list.append([c])
  794. if temp_list:
  795. connect_pages_list.append(temp_list)
  796. print('connect_pages_list', connect_pages_list)
  797. # 判断后续条件:判断组内列数是否相同
  798. connect_pages_list2 = []
  799. for c_list in connect_pages_list:
  800. if len(c_list) == 1:
  801. connect_pages_list2.append(c_list)
  802. else:
  803. col_cnt_list = []
  804. # 单元格可能被复制了,相同的合并当做一列
  805. merge_col_cnt_list = []
  806. for c in c_list:
  807. soup = soup_list[c[0]]
  808. table1 = soup.findAll('table')[-1]
  809. table2 = soup.findAll('table')[0]
  810. tr1 = table1.findAll('tr')
  811. tr2 = table2.findAll('tr')
  812. td1 = tr1[-1].findAll('td')
  813. td2 = tr2[0].findAll('td')
  814. col_cnt_list.append([len(td2), len(td1)])
  815. # # 计算合并重复文本格子后的列数
  816. # last_text = td1[0].text
  817. # merge_td1 = [last_text]
  818. # for td in td1:
  819. # if td.text == last_text:
  820. # continue
  821. # else:
  822. # merge_td1.append(td.text)
  823. # last_text = td.text
  824. # last_text = td2[0].text
  825. # merge_td2 = [last_text]
  826. # for td in td2:
  827. # if td.text == last_text:
  828. # continue
  829. # else:
  830. # merge_td2.append(td.text)
  831. # last_text = td.text
  832. # merge_col_cnt_list.append([len(merge_td2), len(merge_td1)])
  833. # 判断
  834. new_c_list = [c_list[0]]
  835. # print('col_cnt_list', col_cnt_list)
  836. for i in range(len(col_cnt_list) - 1):
  837. if col_cnt_list[i][1] != col_cnt_list[i + 1][0]:
  838. # and merge_col_cnt_list[i][1] != merge_col_cnt_list[i + 1][0]:
  839. connect_pages_list2.append(new_c_list)
  840. new_c_list = [c_list[i + 1]]
  841. else:
  842. new_c_list.append(c_list[i + 1])
  843. if new_c_list:
  844. connect_pages_list2.append(new_c_list)
  845. print('connect_pages_list2', connect_pages_list2)
  846. # 符合连接条件的拼接表格
  847. new_html_list = []
  848. for c_list in connect_pages_list2:
  849. if len(c_list) == 1:
  850. new_html_list.append(html_list[c_list[0][0]])
  851. continue
  852. new_html = ''
  853. for c in c_list:
  854. match = re.finditer('</table>', new_html)
  855. last_table_index = None
  856. for m in match:
  857. last_table_index = m.span()[0]
  858. new_html += html_list[c[0]]
  859. # print('html_list[c[0]]', html_list[c[0]])
  860. if last_table_index is None:
  861. continue
  862. match = re.finditer('<table border="1">', new_html[last_table_index:])
  863. first_table_index = None
  864. for m in match:
  865. first_table_index = last_table_index + m.span()[1]
  866. break
  867. if first_table_index is None:
  868. continue
  869. # print('re', re.findall('</table>.*?<table border="1">', new_html[last_table_index:first_table_index]))
  870. # 非贪婪匹配
  871. new_html_sub = re.sub('</table>.*?<table border="1">',
  872. '<tr><td>#@#@#</td></tr>',
  873. new_html[last_table_index:first_table_index])
  874. new_html = new_html[:last_table_index] + new_html_sub + new_html[first_table_index:]
  875. # print('new_html', new_html)
  876. # new_html = new_html[:-5]
  877. # ([-/第页0-9]|<div>|</div>)*
  878. # 非贪婪匹配
  879. # match = re.finditer('</table>.*?<table border="1">', new_html)
  880. # for m in match:
  881. # if '#@#@#' in m.group():
  882. #
  883. # new_html = re.sub('</table>.*#@#@#.*?<table border="1">',
  884. # '<tr><td>#@#@#</td></tr>',
  885. # new_html)
  886. # print('new_html', new_html)
  887. soup = BeautifulSoup(new_html, 'lxml')
  888. trs = soup.findAll('tr')
  889. decompose_trs = []
  890. for i in range(len(trs)):
  891. if trs[i].get_text() == '#@#@#':
  892. td1 = trs[i - 1].findAll('td')
  893. td2 = trs[i + 1].findAll('td')
  894. if td2[0].get_text() == '':
  895. # 解决连续多页是一行表格,该行会被去掉问题
  896. find_father = False
  897. for father, son in decompose_trs:
  898. # print('son', son)
  899. # print('td1', trs[i - 1])
  900. if father != '' and son == trs[i - 1]:
  901. td_father = father.findAll('td')
  902. for j in range(len(td_father)):
  903. # print('td_father[j].string3', td_father[j].string)
  904. td_father[j].string = td_father[j].get_text() + td2[j].get_text()
  905. # print('td_father[j].string4', td_father[j].string)
  906. find_father = True
  907. decompose_trs.append([father, trs[i + 1]])
  908. break
  909. if not find_father:
  910. for j in range(len(td1)):
  911. # print('td1[j].string1', td1[j].string)
  912. td1[j].string = td1[j].get_text() + td2[j].get_text()
  913. # print('td1[j].string2', td1[j].string)
  914. decompose_trs.append([trs[i - 1], trs[i + 1]])
  915. # print('trs[i + 1]', trs[i + 1])
  916. # trs[i + 1].decompose()
  917. # print('trs[i-1]', trs[i-1])
  918. # trs[i].decompose()
  919. decompose_trs.append(['', trs[i]])
  920. # print('decompose_trs', decompose_trs)
  921. # for father, son in decompose_trs:
  922. # print('father', father)
  923. # print('son', son)
  924. # print('len(decompose_trs)', len(decompose_trs))
  925. for father, son in decompose_trs:
  926. for tr in trs:
  927. if tr == son:
  928. tr.decompose()
  929. break
  930. new_html = str(soup)
  931. new_html_list.append(new_html)
  932. html_str = ''
  933. for h in new_html_list:
  934. html_str += h
  935. return [html_str]
  936. def get_html(self):
  937. if self._doc.error_code is not None:
  938. return self._doc.error_code
  939. self.convert()
  940. if self._doc.error_code is not None:
  941. return self._doc.error_code
  942. html = self._doc.get_html(return_list=True)
  943. # 表格连接
  944. try:
  945. html = self.connect_table(html)
  946. except:
  947. traceback.print_exc()
  948. return [-12]
  949. return html
  950. def delete_water_mark(self, lt_text_list, page_bbox, times=5):
  951. # 删除过多重复字句,为水印
  952. duplicate_dict = {}
  953. for _obj in lt_text_list:
  954. t = _obj.get_text()
  955. if t in duplicate_dict.keys():
  956. duplicate_dict[t][0] += 1
  957. duplicate_dict[t][1].append(_obj)
  958. else:
  959. duplicate_dict[t] = [1, [_obj]]
  960. delete_text = []
  961. for t in duplicate_dict.keys():
  962. if duplicate_dict[t][0] >= times:
  963. obj_list = duplicate_dict[t][1]
  964. obj_list.sort(key=lambda x: x.bbox[3])
  965. obj_distance_h = abs(obj_list[-1].bbox[3] - obj_list[0].bbox[1])
  966. obj_list.sort(key=lambda x: x.bbox[2])
  967. obj_distance_w = abs(obj_list[-1].bbox[2] - obj_list[0].bbox[0])
  968. if obj_distance_h >= abs(page_bbox[1] - page_bbox[3]) * 0.7 \
  969. and obj_distance_w >= abs(page_bbox[0] - page_bbox[2]) * 0.7:
  970. delete_text.append(t)
  971. temp_text_list = []
  972. for _obj in lt_text_list:
  973. t = _obj.get_text()
  974. if t not in delete_text:
  975. temp_text_list.append(_obj)
  976. return temp_text_list
  977. def resize_image(self, img_path, max_size=2000):
  978. _img = cv2.imread(img_path)
  979. if _img.shape[0] <= max_size or _img.shape[1] <= max_size:
  980. return
  981. else:
  982. resize_axis = 0 if _img.shape[0] >= _img.shape[1] else 1
  983. ratio = max_size / _img.shape[resize_axis]
  984. new_shape = [0, 0]
  985. new_shape[resize_axis] = max_size
  986. new_shape[1 - resize_axis] = int(_img.shape[1 - resize_axis] * ratio)
  987. _img = cv2.resize(_img, (new_shape[1], new_shape[0]))
  988. cv2.imwrite(img_path, _img)
  989. def get_single_pdf(self, path, page_no):
  990. start_time = time.time()
  991. try:
  992. pdf_origin = copy.deepcopy(self.doc_pypdf2)
  993. pdf_new = copy.deepcopy(self.doc_pypdf2_new)
  994. pdf_new.addPage(pdf_origin.getPage(page_no))
  995. path_new = path.split(".")[0] + "_split.pdf"
  996. with open(path_new, "wb") as ff:
  997. pdf_new.write(ff)
  998. log("page_no: " + str(page_no) + " get_single_pdf cost: " + str(time.time()-start_time))
  999. return path_new
  1000. except PyPDF2.utils.PdfReadError as e:
  1001. return [-3]
  1002. except Exception as e:
  1003. log("page_no: " + str(page_no) + " get_single_pdf error!")
  1004. return [-3]
  1005. def get_text_font():
  1006. def flags_decomposer(flags):
  1007. """Make font flags human readable."""
  1008. l = []
  1009. if flags & 2 ** 0:
  1010. l.append("superscript")
  1011. if flags & 2 ** 1:
  1012. l.append("italic")
  1013. if flags & 2 ** 2:
  1014. l.append("serifed")
  1015. else:
  1016. l.append("sans")
  1017. if flags & 2 ** 3:
  1018. l.append("monospaced")
  1019. else:
  1020. l.append("proportional")
  1021. if flags & 2 ** 4:
  1022. l.append("bold")
  1023. return ", ".join(l)
  1024. def get_underlined_textLines(page):
  1025. """
  1026. 获取某页pdf上的所有下划线文本信息
  1027. :param page: fitz中的一页
  1028. :return: list of tuples,每个tuple都是一个完整的下划线覆盖的整体:[(下划线句, 所在blk_no, 所在line_no), ...]
  1029. """
  1030. paths = page.get_drawings() # get drawings on the current page
  1031. # 获取该页内所有的height很小的bbox。因为下划线其实大多是这种矩形
  1032. # subselect things we may regard as lines
  1033. lines = []
  1034. for p in paths:
  1035. for item in p["items"]:
  1036. if item[0] == "l": # an actual line
  1037. p1, p2 = item[1:]
  1038. if p1.y == p2.y:
  1039. lines.append((p1, p2))
  1040. elif item[0] == "re": # a rectangle: check if height is small
  1041. r = item[1]
  1042. if r.width > r.height and r.height <= 2:
  1043. lines.append((r.tl, r.tr)) # take top left / right points
  1044. # 获取该页的`max_lineheight`,用于下面比较距离使用
  1045. blocks = page.get_text("dict", flags=11)["blocks"]
  1046. max_lineheight = 0
  1047. for b in blocks:
  1048. for l in b["lines"]:
  1049. bbox = fitz.Rect(l["bbox"])
  1050. if bbox.height > max_lineheight:
  1051. max_lineheight = bbox.height
  1052. underlined_res = []
  1053. # 开始对下划线内容进行查询
  1054. # make a list of words
  1055. words = page.get_text("words")
  1056. # if underlined, the bottom left / right of a word
  1057. # should not be too far away from left / right end of some line:
  1058. for wdx, w in enumerate(words): # w[4] is the actual word string
  1059. r = fitz.Rect(w[:4]) # first 4 items are the word bbox
  1060. for p1, p2 in lines: # check distances for start / end points
  1061. if abs(r.bl - p1) <= max_lineheight: # 当前word的左下满足下划线左下
  1062. if abs(r.br - p2) <= max_lineheight: # 当前word的右下满足下划线右下(单个词,无空格)
  1063. print(f"Word '{w[4]}' is underlined! Its block-line number is {w[-3], w[-2]}")
  1064. underlined_res.append((w[4], w[-3], w[-2])) # 分别是(下划线词,所在blk_no,所在line_no)
  1065. break # don't check more lines
  1066. else: # 继续寻找同line右侧的有缘人,因为有些下划线覆盖的词包含多个词,多个词之间有空格
  1067. curr_line_num = w[-2] # line nunmber
  1068. for right_wdx in range(wdx + 1, len(words), 1):
  1069. _next_w = words[right_wdx]
  1070. if _next_w[-2] != curr_line_num: # 当前遍历到的右侧word已经不是当前行的了(跨行是不行的)
  1071. break
  1072. _r_right = fitz.Rect(_next_w[:4]) # 获取当前同行右侧某word的方框4点
  1073. if abs(_r_right.br - p2) <= max_lineheight: # 用此word右下点和p2(目标下划线右上点)算距离,距离要小于max_lineheight
  1074. print(
  1075. f"Word '{' '.join([_one_word[4] for _one_word in words[wdx:right_wdx + 1]])}' is underlined! " +
  1076. f"Its block-line number is {w[-3], w[-2]}")
  1077. underlined_res.append(
  1078. (' '.join([_one_word[4] for _one_word in words[wdx:right_wdx + 1]]),
  1079. w[-3], w[-2])
  1080. ) # 分别是(下划线词,所在blk_no,所在line_no)
  1081. break # don't check more lines
  1082. return underlined_res
  1083. _p = r'C:\Users\Administrator\Desktop\test_pdf\error2-2.pdf'
  1084. doc_pymupdf = read_pymupdf(_p)
  1085. page = doc_pymupdf[0]
  1086. blocks = page.get_text("dict", flags=11)["blocks"]
  1087. for b in blocks: # iterate through the text blocks
  1088. for l in b["lines"]: # iterate through the text lines
  1089. for s in l["spans"]: # iterate through the text spans
  1090. print("")
  1091. font_properties = "Font: '%s' (%s), size %g, color #%06x" % (
  1092. s["font"], # font name
  1093. flags_decomposer(s["flags"]), # readable font flags
  1094. s["size"], # font size
  1095. s["color"], # font color
  1096. )
  1097. print(s)
  1098. print("Text: '%s'" % s["text"]) # simple print of text
  1099. print(font_properties)
  1100. get_underlined_textLines(page)
  1101. # 以下为现成pdf单页解析接口
  1102. class ParseSentence:
  1103. def __init__(self, bbox, fontname, fontsize, _text, _title, title_text, _pattern, title_degree, is_outline,
  1104. outline_location, page_no):
  1105. (x0, y0, x1, y1) = bbox
  1106. self.x0 = x0
  1107. self.y0 = y0
  1108. self.x1 = x1
  1109. self.y1 = y1
  1110. self.bbox = bbox
  1111. self.fontname = fontname
  1112. self.fontsize = fontsize
  1113. self.text = _text
  1114. self.title = _title
  1115. self.title_text = title_text
  1116. self.groups = _pattern
  1117. self.title_degree = title_degree
  1118. self.is_outline = is_outline
  1119. self.outline_location = outline_location
  1120. self.page_no = page_no
  1121. def __repr__(self):
  1122. return "%s,%s,%s,%d,%s" % (self.text, self.title, self.is_outline, self.outline_location, str(self.bbox))
  1123. class ParseUtils:
  1124. @staticmethod
  1125. def getFontinfo(_page):
  1126. for _obj in _page._objs:
  1127. if isinstance(_obj, (LTTextBoxHorizontal, LTTextBoxVertical)):
  1128. for textline in _obj._objs:
  1129. done = False
  1130. for lchar in textline._objs:
  1131. if isinstance(lchar, (LTChar)):
  1132. _obj.fontname = lchar.fontname
  1133. _obj.fontsize = lchar.size
  1134. done = True
  1135. break
  1136. if done:
  1137. break
  1138. @staticmethod
  1139. def recognize_sentences(list_textbox, filter_objs, page_bbox, page_no,
  1140. remove_space=True, sourceP_LB=True):
  1141. list_textbox.sort(key=lambda x: x.bbox[0])
  1142. list_textbox.sort(key=lambda x: x.bbox[3], reverse=sourceP_LB)
  1143. cluster_textbox = []
  1144. for _textbox in list_textbox:
  1145. if _textbox in filter_objs:
  1146. continue
  1147. _find = False
  1148. for _ct in cluster_textbox:
  1149. if abs(_ct["y"] - _textbox.bbox[1]) < 5:
  1150. _find = True
  1151. _ct["textbox"].append(_textbox)
  1152. if not _find:
  1153. cluster_textbox.append({"y": _textbox.bbox[1], "textbox": [_textbox]})
  1154. cluster_textbox.sort(key=lambda x: x["y"], reverse=sourceP_LB)
  1155. list_sentences = []
  1156. for _line in cluster_textbox:
  1157. _textboxs = _line["textbox"]
  1158. _textboxs.sort(key=lambda x: x.bbox[0])
  1159. _linetext = _textboxs[0].get_text()
  1160. for _i in range(1, len(_textboxs)):
  1161. if abs(_textboxs[_i].bbox[0] - _textboxs[_i - 1].bbox[2]) > 60:
  1162. if _linetext and _linetext[-1] not in (",", ",", "。", ".", "、", ";"):
  1163. _linetext += "=,="
  1164. _linetext += _textboxs[_i].get_text()
  1165. _linetext = re.sub("[\s\r\n]", "", _linetext)
  1166. _bbox = (_textboxs[0].bbox[0], _textboxs[0].bbox[1],
  1167. _textboxs[-1].bbox[2], _textboxs[-1].bbox[3])
  1168. _title = None
  1169. _pattern_groups = None
  1170. title_text = ""
  1171. if not _title:
  1172. _groups = ParseUtils.find_title_by_pattern(_textboxs[0].get_text())
  1173. if _groups:
  1174. _title = _groups[0][0]
  1175. title_text = _groups[0][1]
  1176. _pattern_groups = _groups
  1177. if not _title:
  1178. _groups = ParseUtils.find_title_by_pattern(_linetext)
  1179. if _groups:
  1180. _title = _groups[0][0]
  1181. title_text = _groups[0][1]
  1182. _pattern_groups = _groups
  1183. if not _title:
  1184. _title = ParseUtils.rec_incenter(_bbox, page_bbox)
  1185. title_degree = 2
  1186. if not _title:
  1187. _linetext = _linetext.replace("=,=", ",")
  1188. else:
  1189. _linetext = _linetext.replace("=,=", "")
  1190. title_degree = int(_title.split("_")[1])
  1191. # 页码
  1192. if ParseUtils.rec_incenter(_bbox, page_bbox) and re.search("^\d+$", _linetext) is not None:
  1193. continue
  1194. if _linetext == "" or re.search("^,+$", _linetext) is not None:
  1195. continue
  1196. is_outline = False
  1197. outline_location = -1
  1198. _search = re.search("(?P<text>.+?)\.{5,}(?P<nums>\d+)$", _linetext)
  1199. if _search is not None:
  1200. is_outline = True
  1201. _linetext = _search.group("text")
  1202. outline_location = int(_search.group("nums"))
  1203. list_sentences.append(
  1204. ParseSentence(_bbox, _textboxs[-1].__dict__.get("fontname"), _textboxs[-1].__dict__.get("fontsize"),
  1205. _linetext, _title, title_text, _pattern_groups, title_degree, is_outline,
  1206. outline_location, page_no))
  1207. # for _sen in list_sentences:
  1208. # print(_sen.__dict__)
  1209. return list_sentences
  1210. @staticmethod
  1211. def find_title_by_pattern(_text,
  1212. _pattern="(?P<title_1>(?P<title_1_index_0_0>^第?)(?P<title_1_index_1_1>[一二三四五六七八九十ⅠⅡⅢⅣⅤⅥⅦⅧⅨⅩⅪⅫ]+)(?P<title_1_index_2_0>[、章]))|" \
  1213. "(?P<title_3>^(?P<title_3_index_0_1>[ⅠⅡⅢⅣⅤⅥⅦⅧⅨⅩⅪⅫ]+))|" \
  1214. "(?P<title_4>^(?P<title_4_index_0_0>第?)(?P<title_4_index_1_1>[一二三四五六七八九十]+)(?P<title_4_index_2_0>[节]))|" \
  1215. "(?P<title_11>^(?P<title_11_index_0_0>\d{1,2}[\..、\s\-]\d{1,2}[\..、\s\-]\d{1,2}[\..、\s\-])(?P<title_11_index_1_1>\d{1,2})(?P<title_11_index_2_0>[\..、\s\-]))|" \
  1216. "(?P<title_10>^(?P<title_10_index_0_0>\d{1,2}[\..、\s\-]\d{1,2}[\..、\s\-])(?P<title_10_index_1_1>\d{1,2})(?P<title_10_index_2_0>[\..、\s\-]))|" \
  1217. "(?P<title_7>^(?P<title_7_index_0_0>\d{1,2}[\..、\s\-])(?P<title_7_index_1_1>\d{1,2})(?P<title_7_index_2_0>[\..、\s\-]))|" \
  1218. "(?P<title_6>^(?P<title_6_index_0_1>\d{1,2})(?P<title_6_index_1_0>[\..、\s\-]))|" \
  1219. "(?P<title_15>^(?P<title_15_index_0_0>(?)(?P<title_15_index_1_1>\d{1,2})(?P<title_15_index_2_0>)))|" \
  1220. "(?P<title_17>^(?P<title_17_index_0_0>(?)(?P<title_17_index_1_1>[a-zA-Z]+)(?P<title_17_index_2_0>)))|"
  1221. "(?P<title_19>^(?P<title_19_index_0_0>(?)(?P<title_19_index_1_1>[一二三四五六七八九十ⅠⅡⅢⅣⅤⅥⅦⅧⅨⅩⅪⅫ]+)(?P<title_19_index_2_0>)))|" \
  1222. ):
  1223. _se = re.search(_pattern, _text)
  1224. groups = []
  1225. if _se is not None:
  1226. _gd = _se.groupdict()
  1227. for k, v in _gd.items():
  1228. if v is not None:
  1229. groups.append((k, v))
  1230. if len(groups):
  1231. groups.sort(key=lambda x: x[0])
  1232. return groups
  1233. return None
  1234. @staticmethod
  1235. def rec_incenter(o_bbox, p_bbox):
  1236. p_width = p_bbox[2] - p_bbox[0]
  1237. l_space = (o_bbox[0] - p_bbox[0]) / p_width
  1238. r_space = (p_bbox[2] - o_bbox[2]) / p_width
  1239. if abs((l_space - r_space)) < 0.1 and l_space > 0.2:
  1240. return "title_2"
  1241. @staticmethod
  1242. def is_first_title(_title):
  1243. if _title is None:
  1244. return False
  1245. if re.search("^\d+$", _title) is not None:
  1246. if int(_title) == 1:
  1247. return True
  1248. return False
  1249. if re.search("^[一二三四五六七八九十百]+$", _title) is not None:
  1250. if _title == "一":
  1251. return True
  1252. return False
  1253. if re.search("^[a-z]+$", _title) is not None:
  1254. if _title == "a":
  1255. return True
  1256. return False
  1257. if re.search("^[A-Z]+$", _title) is not None:
  1258. if _title == "A":
  1259. return True
  1260. return False
  1261. if re.search("^[ⅠⅡⅢⅣⅤⅥⅦⅧⅨⅩⅪⅫ]$", _title) is not None:
  1262. if _title == "Ⅰ":
  1263. return True
  1264. return False
  1265. return False
  1266. @staticmethod
  1267. def get_next_title(_title):
  1268. if re.search("^\d+$", _title) is not None:
  1269. return str(int(_title) + 1)
  1270. if re.search("^[一二三四五六七八九十百]+$", _title) is not None:
  1271. _next_title = ParseUtils.make_increase(['一', '二', '三', '四', '五', '六', '七', '八', '九', '十'],
  1272. re.sub("[十百]", '', _title))
  1273. _next_title = list(_next_title)
  1274. _next_title.reverse()
  1275. if _next_title[-1] != "十":
  1276. if len(_next_title) >= 2:
  1277. _next_title.insert(-1, '十')
  1278. if len(_next_title) >= 4:
  1279. _next_title.insert(-3, '百')
  1280. if _title[0] == "十":
  1281. if _next_title == "十":
  1282. _next_title = ["二", "十"]
  1283. _next_title.insert(0, "十")
  1284. _next_title = "".join(_next_title)
  1285. return _next_title
  1286. if re.search("^[a-z]+$", _title) is not None:
  1287. _next_title = ParseUtils.make_increase([chr(i + ord('a')) for i in range(26)], _title)
  1288. _next_title = list(_next_title)
  1289. _next_title.reverse()
  1290. return "".join(_next_title)
  1291. if re.search("^[A-Z]+$", _title) is not None:
  1292. _next_title = ParseUtils.make_increase([chr(i + ord('A')) for i in range(26)], _title)
  1293. _next_title = list(_next_title)
  1294. _next_title.reverse()
  1295. return "".join(_next_title)
  1296. if re.search("^[ⅠⅡⅢⅣⅤⅥⅦⅧⅨⅩⅪⅫ]$", _title) is not None:
  1297. _sort = ["Ⅰ", "Ⅱ", "Ⅲ", "Ⅳ", "Ⅴ", "Ⅵ", "Ⅶ", "Ⅷ", "Ⅸ", "Ⅹ", "Ⅺ", "Ⅻ"]
  1298. _index = _sort.index(_title)
  1299. if _index < len(_sort) - 1:
  1300. return _sort[_index + 1]
  1301. return None
  1302. @staticmethod
  1303. def make_increase(_sort, _title, _add=1):
  1304. if len(_title) == 0 and _add == 0:
  1305. return ""
  1306. if len(_title) == 0 and _add == 1:
  1307. return _sort[0]
  1308. _index = _sort.index(_title[-1])
  1309. next_index = (_index + _add) % len(_sort)
  1310. next_chr = _sort[next_index]
  1311. if _index == len(_sort) - 1:
  1312. _add = 1
  1313. else:
  1314. _add = 0
  1315. return next_chr + ParseUtils.make_increase(_sort, _title[:-1], _add)
  1316. @staticmethod
  1317. def rec_serial(_text, o_bbox, p_bbox, fontname, _pattern="(?P<title_1>^[一二三四五六七八九十]+[、])|" \
  1318. "(?P<title_2>^\d+[\.、\s])|" \
  1319. "(?P<title_3>^\d+\.\d+[\.、\s])|" \
  1320. "(?P<title_4>^\d+\.\d+\.\d+[\.、\s])|" \
  1321. "(?P<title_5>^\d+\.\d+\.\d+\.\d+[\.、\s])"):
  1322. # todo :recog the serial of the sentence
  1323. _se = re.search(_pattern, _text)
  1324. if _se is not None:
  1325. _gd = _se.groupdict()
  1326. for k, v in _gd.items():
  1327. if v is not None:
  1328. return k
  1329. return None
  1330. if __name__ == '__main__':
  1331. PDFConvert(r"C:/Users/Administrator/Downloads/1651896704621.pdf", "C:/Users/Administrator/Downloads/1").get_html()