Ë
    3/|j'  ã                   ó–  — d Z ddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlmZmZ dZedz   ZdZdZdZej(                  j+                  d	d
«      Zej(                  j+                  dd«      ZdZddddœZdZdadZ eej<                  «      D ]k  \  ZZ e jC                  d«      r	  e"e jG                  dd«      d   «      ZŒ4e dk(  sŒ:edz    e%ej<                  «      k  sŒS	  e"ej<                  edz      «      ZŒm edk\  rendZ&d"d„Z'd„ Z(d„ Z)d„ Z*d„ Z+d„ Z,d„ Z-d„ Z.d „ Z/e0d!k(  r e/«        yy# e$$ r Y Œ¨w xY w# e$$ r Y Œ³w xY w)#u  
crawl_jiangcheng_hpgs.py - æ±ŸåŸŽåŒº-å»ºè®¾é¡¹ç›®çŽ¯å¢ƒå½±å“�è¯„ä»·ä¿¡æ�¯
https://www.jiangcheng.gov.cn/zwgk/zdlyxxgkzl/hjbhxxgk/jsxmhjyxpjxx/
åˆ—è¡¨: ul.list_transform > li > a[href=.../content/post_N.html][title=å®Œæ•´æ ‡é¢˜] > æ ‡é¢˜ + span.date
åˆ†é¡µ: index.html / index_N.html (20 é¡µ ~400 æ�¡, æ¯�é¡µ 20)
è¯¦æƒ…: /zwgk/zdlyxxgkzl/hjbhxxgk/jsxmhjyxpjxx/content/post_NNNNNN.html
  â†’ div.s_title(æ ‡é¢˜) + div.s_info(å�‘å¸ƒæ—¶é—´) + div#zoomcon.s_content(æ­£æ–‡, å�«è¡¨æ ¼)
é™„ä»¶: #zoomcon å†… a é“¾æŽ¥ (s_files/xgfj åŒº)
é    N)ÚBeautifulSoupÚCommentzhttps://www.jiangcheng.gov.cnz'/zwgk/zdlyxxgkzl/hjbhxxgk/jsxmhjyxpjxx/u   æ±ŸåŸŽåŒº-å»ºè®¾é¡¹ç›®çŽ¯è¯„u   å¹¿ä¸œzcrawl_jiangcheng_hpgs.pyÚDB_PATHz/root/search.dbÚ
JSONL_PATHÚ úutf-8zkMozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0 Safari/537.36z?text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8zzh-CN,zh;q=0.9)z
User-AgentÚAcceptzAccept-Languageg333333ó?g        é   z--pages=ú=z--pagesc                 ó’  — t        j                   «       t        z
  }|t        k  rt        j                  t        |z
  «       t        j                   «       at	        |«      D ]V  }	 t        j                  | t        |d¬«      }|j                  dk(  rd|_	        |c S 	 t        j                  d|dz  z   «       ŒX y # t        $ r Y Œ)w xY w)NF)ÚheadersÚtimeoutÚverifyéÈ   r   é   )ÚtimeÚ	_last_reqÚREQUEST_INTERVALÚsleepÚrangeÚrequestsÚgetÚHEADERSÚstatus_codeÚencodingÚ	Exception)ÚurlÚretriesr   ÚdtÚiÚrs         ú*/root/gov_crawler/crawl_jiangcheng_hpgs.pyÚhttp_getr#   :   s°   € ä	�‰‹”yÑ	 €BØ	ÔÒÜ�
‰
Ô# bÑ(Ô)Ü—	‘	“€IÜ�7‹^ò ˆð	Ü—‘˜S¬'¸7È5ÔQˆAØ�}‰} Ò#Ø$�”
Ø’ð $ô
 	�
‰
�1�q˜1‘u‘9Õðð øô ò 	Ùð	ús   Á$4B:Â:	CÃCc                 ó  — | syt        j                  | «      } | j                  dd«      j                  dd«      j                  dd«      j                  dd«      } t        j                  dd| «      } | j                  «       S )Nr   u   â€‹u   â€Œu   â€�u   ï»¿ú\s+ú )Úhtml_libÚunescapeÚreplaceÚreÚsubÚstrip)Úts    r"   Úclean_titler.   L   so   € ÙØÜ×Ñ˜!Ó€AØ	�	‰	�(˜BÓ×'Ñ'¨°"Ó5×=Ñ=¸hÈÓK×SÑSÐT\Ð^`Óa€AÜ
�‰ˆv�s˜AÓ€AØ�7‰7‹9Ðó    c                 ó¼  — | dk(  rt         }nt         d| › d�z   }t        |«      }|€g S |j                  }g }t        j                  d|t        j
                  «      D ]}  }|j                  d«      t        |j                  d«      «      |j                  d«      }}}t        j                  d|«      }	|	r|	j                  d«      nd}
|j                  |||
f«       Œ |S )	u0   æŠ“ä¸€é¡µåˆ—è¡¨, è¿”å›ž [(abs_url, title, date)]r
   Úindex_z.htmlzŒ<a href="(https://www\.jiangcheng\.gov\.cn/zwgk/zdlyxxgkzl/hjbhxxgk/jsxmhjyxpjxx/content/post_\d+\.html)"[^>]*title="([^"]*)"[^>]*>(.*?)</a>r   é   z-<span class="date">(\d{4}-\d{2}-\d{2})</span>r   )
ÚLIST_URLr#   Útextr*   ÚfinditerÚSÚgroupr.   ÚsearchÚappend)Úpager   r!   Ú	html_textÚitemsÚmÚabs_urlÚtitleÚbodyÚdmÚdates              r"   Ú
fetch_listrC   U   sã   € àˆq‚yÜ‰ä˜6 $  uÐ-Ñ-ˆÜ�‹€AØ€yØˆ	Ø—‘€IØ€EÜ�[‰[ð  ið  ktô  vx÷  vzñ  vzó  {ò -ˆØ Ÿw™w q›z¬;°q·w±w¸q³zÓ+BÀAÇGÁGÈAÃJ˜�ˆÜ�Y‰YÐGÈÓNˆÙ ˆr�x‰x˜Œ{ bˆØ�‰�g˜u dÐ+Õ,ð	-ð
 €Lr/   c                 ó\  — t        | «      }|€y|j                  }t        |d«      }d}|j                  dd¬«      }|rt	        |j                  «       «      }|s4t        j                  d|«      }|rt	        |j                  d	«      «      nd}d}t        j                  d
|«      }|r|j                  d	«      nd}|s+t        j                  d|«      }	|	r|	j                  d	«      nd}|j                  dd¬«      }
|
s||dfS |
j                  d„ ¬«      D ]  }|j                  «        Œ |||
fS )u-   è¯¦æƒ…é¡µ: è¿”å›ž (title, pubdate, zoom_soup)N)NNNzhtml.parserr   ÚdivÚs_title)Úclass_z+<meta name="ArticleTitle" content="([^"]*)"r
   u#   å�‘å¸ƒæ—¶é—´:\s*(\d{4}-\d{2}-\d{2})z1<meta name="PubDate" content="(\d{4}-\d{2}-\d{2})Úzoomcon)Úidc                 ó"   — t        | t        «      S )N)Ú
isinstancer   )Úss    r"   ú<lambda>zparse_detail.<locals>.<lambda>�   s   € ¬J°q¼'Ó,B€ r/   )Ústring)r#   r4   r   Úfindr.   Úget_textr*   r8   r7   Úfind_allÚextract)r   r!   r;   Úsoupr?   ÚstÚtmÚpubdaterA   Údm2ÚzoomÚcs               r"   Úparse_detailrZ   h   s  € ä�‹€AØ€yØØ—‘€IÜ˜ MÓ2€Dà€EØ	�‰�5 ˆÓ	+€BÙ	Ü˜BŸK™K›MÓ*ˆÙÜ�Y‰YÐEÀyÓQˆÙ,.”˜BŸH™H Q›KÔ(°Bˆà€GÜ	�‰Ð9¸9Ó	E€BÙˆb�h‰h�qŒk R€GÙÜ�i‰iÐLÈiÓXˆÙ"%�#—)‘)˜A”,¨2ˆØ�9‰9�U˜yˆ9Ó)€DÙØ�g˜tÐ#Ð#Ø�]‰]Ñ"Bˆ]ÓCò ˆØ	�	‰	�ðà�'˜4ÐÐr/   c                 óv  — | €ddg fS | j                  g d¢«      D ]  }|j                  «        Œ t        | j                  d«      «      }g }| j                  dd¬«      D ]Ô  }|d   j	                  «       }|j                  d	«      s|j                  d
«      r't        j                  j                  t        |«      |d<   |j                  «       j                  d«      s%d|j                  «       v sd|j                  «       v sŒ£t        |j                  «       «      }|sŒ¿|j                  |d   |f«       ŒÖ | j                  dd¬«      D ]_  }|d   j	                  «       }	|	j                  d	«      s|	j                  d
«      sŒ9t        j                  j                  t        |	«      |d<   Œa t        | «      }
|
||fS )Nr   F)ÚscriptÚstyleÚiframeÚobjectÚtableÚaT)Úhrefrb   ú/Úhttp)z.pdfz.docz.docxz.xlsz.xlsxz.zipz.rarz.wpsÚuploadÚattachÚimg)Úsrcrh   )rQ   Ú	decomposeÚboolrO   r,   Ú
startswithÚurllibÚparseÚurljoinÚBASE_URLÚlowerÚendswithr.   rP   r9   Ústr)Ú	zoom_soupr>   ÚtagÚ	has_tableÚattachmentsra   ÚhÚtxtrg   rL   Úcontents              r"   Úhtml_to_textrz   †   s§  € ØÐØ�5˜"ˆ}ÐØ×!Ñ!Ò"IÓJò ˆØ�‰�ðä�Y—^‘^ GÓ,Ó-€IØ€KØ×Ñ ¨$ÐÓ/ò 5ˆØˆf‰I�O‰OÓˆØ�<‰<˜Ô §¡¨VÔ 4ÜŸ™×,Ñ,¬X°qÓ9ˆAˆf‰IØ�7‰7‹9×ÑÐ`ÔaÐemÐqr×qxÑqxÓqzÑezð  Gð  KL÷  KRñ  KRó  KTò  TÜ˜aŸj™j›lÓ+ˆCÚØ×"Ñ" A f¡I¨sÐ#3Õ4ð5ð ×!Ñ! %¨TÐ!Ó2ò ;ˆØ�‰J×ÑÓˆØ�<‰<˜Ô §¡¨VÕ 4ÜŸ™×-Ñ-¬h¸Ó:ˆC�ŠJð;ô �)‹n€GØ�I˜{Ð*Ð*r/   c                 óš   — |s| S | j                  «       r| gng }|D ]  \  }}|j                  d|› d|› d�«       Œ dj                  |«      S )Nz<p><a href="z" target="_blank">z</a></p>z

)r,   r9   Újoin)ry   rv   Úpartsr>   rx   s        r"   Úappend_attachmentsr~   �   s[   € ÙØˆØ Ÿ™œˆW‰I¨b€EØ#ò N‰ˆ�Ø�‰�| G 9Ð,>¸s¸eÀ8ÐLÕMðNà�;‰;�uÓÐr/   c                 ó°   — 	 | j                  dt        f«      }|j                  «       D �ch c]  }|d   ’Œ	 c}S c c}w # t        $ r t	        «       cY S w xY w)Nz.SELECT page_url FROM gov_raw WHERE site_name=?r   )ÚexecuteÚ	SITE_NAMEÚfetchallr   Úset)ÚconnÚcurÚrows      r"   Úload_existing_urlsr‡   ¦   sN   € ðØ�l‰lÐKÌiÈ\ÓZˆØ"%§,¡,£.Ö1˜3��A“Ò1Ð1ùÒ1øÜò Ü‹uŠðús   ‚)? «:·? º? ¿AÁAc                 óž  — | j                  d|t        f«      }|j                  «       ry	 d}	 ddlm}  ||«      }| j                  d|||||t        t        t        ||f
«      }|j                  dkD  ryt        j                  dd|«      }	t        j                  |	«      }	t        j                  d	d
|	«      j                  «       d d }	| j                  d|j                  |t        |	f«       yy# t
        $ r Y Œ¼w xY w# t        j                   $ r=}
dt#        |
«      v r*t%        j&                  d«       t)        | |||||«      cY d }
~
S ‚ d }
~
ww xY w)Nz7SELECT id FROM gov_raw WHERE page_url=? AND site_name=?FÚotherr   )Úclassify_industryz¨INSERT OR IGNORE INTO gov_raw (page_url, source_url, title, content, publish_date, site_name, group_name, script_name, has_table, industry) VALUES (?,?,?,?,?,?,?,?,?,?)ú<[^>]+>r   r%   r&   r   zTINSERT OR IGNORE INTO gov_search (rowid, title, site_name, summary) VALUES (?,?,?,?)TÚlockedr2   )r€   r�   ÚfetchoneÚcrawler_librŠ   r   Ú
GROUP_NAMEÚSCRIPT_NAMEÚrowcountr*   r+   r'   r(   r,   Ú	lastrowidÚsqlite3ÚOperationalErrorrr   r   r   Ústore_record)r„   r   r?   ry   rB   ru   r…   ÚindustryrŠ   ÚsummaryÚes              r"   r•   r•   ®   sF  € Ø
�,‰,ÐPÐSVÔXaÐRbÓ
c€CØ
‡|�|„~ØðØˆð	Ý5Ù(¨Ó/ˆHð �l‰lð+ð �#�u˜g t¬Y¼
ÄKÐQZÐ\dÐeó	
ˆð �<‰<˜!ÒÜ—f‘f˜Z¨¨WÓ5ˆGÜ×'Ñ'¨Ó0ˆGÜ—f‘f˜V S¨'Ó2×8Ñ8Ó:¸4¸CÐ@ˆGØ�L‰LØfØ—‘ ¤y°'Ð:ôð Øøô# ò 	Ùð	ûô$ ×#Ñ#ò Ø”s˜1“vÑÜ�J‰J�qŒMÜ  c¨5°'¸4ÀÓKÕKØûð	úsF   «C< ®C- ¼B/C< Ã-	C9Ã6C< Ã8C9Ã9C< Ã<EÄ1EÅ EÅEÅEc                  ó˜  — d } t         sbt        j                  t        d¬«      } | j	                  d«       | j	                  d«       t        | «      }t        dt        |«      › d�d¬«       d	}d	}g }t        d
t        d
z   «      D �]�  }t        |«      }t        d|› dt        |«      › �d¬«       |st        dd¬«        �nV|D �]M  \  }}}	t         s
|v r|d
z  }Œt        |«      \  }
}}|€t        d|d d › d|› �d¬«       |d
z  }ŒE|
s|}
|s|	}t        ||«      \  }}}t        ||«      }t        t        j                  dd|«      j!                  «       «      }|dk  r"d|vr|st        d|
d d › d|› �d¬«       |d
z  }Œ¾t         rD|j#                  ||
|||t$        t&        t(        dœ«       t        d|
d d › d|› d�d¬«       |d
z  }�Œt+        | ||
|||«      }|r/|d
z  }j-                  |«       t        d|
d d › d|› d�d¬«       �ŒI|d
z  }�ŒP �Œ’ t         rmt/        t         dd¬«      5 }|D ]+  }|j1                  t3        j4                  |d¬«      d z   «       Œ- 	 d d d «       t        d!t         › dt        |«      › d"�d¬«       | � | j7                  «        | j9                  «        t        d#|› d$|› �d¬«       y # 1 sw Y   Œ`xY w)%Né<   )r   zPRAGMA busy_timeout=60000zPRAGMA journal_mode=WALu
   å·²å…¥åº“ u    æ�¡, ç”¨äºŽåˆ—è¡¨çº§é¢„æŸ¥é‡�T)Úflushr   r
   z[list] page=z items=zEmpty page, stop paginationz  skip empty: é   z | r‹   r   é
   z<img)Úpage_urlr?   ry   Úpublish_dateru   Ú	site_nameÚ
group_nameÚscript_namez
  JSONL + é(   z (ú)z  + Úwr   )r   F)Úensure_asciiú
zJSONL written: z rows)z[done] new=z skip=)r   r“   Úconnectr   r€   r‡   ÚprintÚlenr   Ú_PAGESrC   rZ   rz   r~   r*   r+   r,   r9   r�   r�   r�   r•   ÚaddÚopenÚwriteÚjsonÚdumpsÚcommitÚclose)r„   ÚexistingÚ	new_countÚ
skip_countÚ
jsonl_rowsr:   r<   r>   r?   rB   ÚdtitleÚddaterX   ry   ru   ÚattsÚ	plain_lenÚokÚfr†   s                       r"   Úmainr½   Ð   sþ  € Ø€DÝÜ�‰œw°Ô3ˆØ�‰Ð0Ô1Ø�‰Ð.Ô/Ü% dÓ+ˆÜ�
œ3˜x›=˜/Ð)GÐHÐPTÕUà€IØ€JØ€Jä�aœ !™Ó$ó * ˆÜ˜4Ó ˆÜ�˜T˜F '¬#¨e«*¨Ð6¸dÕCÙÜÐ/°tÕ<ÚØ$)ó $	 Ñ ˆG�U˜DÝ '¨XÑ"5Ø˜a‘�
ØÜ".¨wÓ"7ÑˆF�E˜4Øˆ|Ü˜ u¨S¨b z l°#°g°YÐ?ÀtÕLØ˜a‘�
ØÙØ�ÙØ�Ü'3°D¸'Ó'BÑ$ˆG�Y Ü(¨°$Ó7ˆGÜœBŸF™F :¨r°7Ó;×AÑAÓCÓDˆIØ˜2Š~ &°Ñ"7ÁÜ˜ v¨c¨r { m°3°w°iÐ@ÈÕMØ˜a‘�
ØÝØ×!Ñ!Ø '°&ÀWØ$)¸	Ü!*¼*Ü#.ñ	#ô ô ˜
 6¨#¨2 ; -¨r°%°¸Ð:À$ÕGØ˜Q‘�	ÙÜ˜d G¨V°W¸eÀYÓOˆBÙØ˜Q‘�	Ø—‘˜WÔ%Ü˜˜V C R˜[˜M¨¨E¨7°!Ð4¸D×Aà˜a‘’
òI$	 ð* õX Ü”*˜c¨GÔ4ð 	D¸Ø!ò D�Ø—‘œŸ
™
 3°UÔ;¸dÑBÕCñD÷	Dô 	�¤
˜|¨2¬c°*«oÐ->¸fÐEÈTÕRàÐØ�‰ŒØ�
‰
ŒÜ	ˆK˜	�{ &¨¨Ð
5¸TÖB÷	Dð 	Dús   È/1K Ë K	Ú__main__)r2   rœ   )1Ú__doc__ÚsysÚosr*   r   Úhtmlr'   Úurllib.parserl   r“   r¯   r   Úbs4r   r   ro   r3   r�   r�   r�   Úenvironr   r   r   ÚENCr   r   r   Ú
_MAX_PAGESÚ	enumerateÚargvr    ra   rk   ÚintÚsplitÚ
ValueErrorrª   r«   r#   r.   rC   rZ   rz   r~   r‡   r•   r½   Ú__name__© r/   r"   ú<module>rÏ      s—  ðñó Û 	Û 	Û Û Û Û Û ã ß &ð +€ØÐ?Ñ?€Ø*€	Ø€
Ø(€Ø
�*‰*�.‰.˜Ð$5Ó
6€Ø�Z‰Z�^‰^˜L¨"Ó-€
Ø€ð @ØOØ'ñ€ð Ð Ø€	à€
Ù�c—h‘hÓò 
�D€A€qØ‡|�|�JÔð	Ù˜QŸW™W S¨!›_¨QÑ/Ó0‰Jð 
ˆi‹˜A ™E¡C¨¯©£MÓ1ð	Ù˜SŸX™X a¨!¡e™_Ó-‰Jð
ð " Q’‰¨A€óò$òò& ò<+ò.òòòDBCðJ ˆzÒÙ…Fð øðK ò 	Ùð	ûð
 ò 	Ùð	ús$   Â,D5Ã(E Ä5D=Ä<D=Å EÅE