From ba00ccf642bbfe980d8df9da15c2de264f88b719 Mon Sep 17 00:00:00 2001
From: quantulr <35954003+quantulr@users.noreply.github.com>
Date: Thu, 21 Mar 2024 14:18:01 +0800
Subject: [PATCH] =?UTF-8?q?AI=E4=BA=8B=E4=BB=B6=E9=87=8D=E5=A4=8D=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 hik_push/__pycache__/__init__.cpython-311.pyc | Bin 171 -> 167 bytes
 .../custom_exception.cpython-312.pyc          | Bin 359 -> 0 bytes
 hik_push/__pycache__/main.cpython-312.pyc     | Bin 1751 -> 0 bytes
 .../__pycache__/read_event.cpython-311.pyc    | Bin 4494 -> 9431 bytes
 hik_push/custom_exception.py                  |   2 -
 hik_push/push_notification.py                 | 170 ++++++++++++++++++
 hik_push/{main.py => subscribe.py}            |   2 +-
 pyproject.toml                                |   6 +-
 8 files changed, 174 insertions(+), 6 deletions(-)
 delete mode 100644 hik_push/__pycache__/custom_exception.cpython-312.pyc
 delete mode 100644 hik_push/__pycache__/main.cpython-312.pyc
 delete mode 100644 hik_push/custom_exception.py
 create mode 100644 hik_push/push_notification.py
 rename hik_push/{main.py => subscribe.py} (100%)

diff --git a/hik_push/__pycache__/__init__.cpython-311.pyc b/hik_push/__pycache__/__init__.cpython-311.pyc
index 479e17dae27b81a7b330ec7c5eeade2a0de63442..04263a70f8eec4127bdebed8b2c8b68ec536265d 100644
GIT binary patch
delta 50
zcmZ3@xSWxDIWI340}zDG{yvf0RNBhLD#j&0ximL5ucSC8pfWilu_!m7C_gJTd1AZ|
E0Cf`(lmGw#

delta 54
zcmZ3^xSElBIWI340}#Zo-#L-nRNl_nDkiizwWv78F(o%MFSEF$D6u5JD8?l}ximL5
IZ(_6$0JsMdCjbBd

diff --git a/hik_push/__pycache__/custom_exception.cpython-312.pyc b/hik_push/__pycache__/custom_exception.cpython-312.pyc
deleted file mode 100644
index cf6acf5c15f511a1abf5c4647639d8b0348e4153..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 359
zcmX@j%ge<81c&!+Of>}3k3k$5V1+V1O92_v8JHN{8B!Qp7*ZHh8CEkx<f0fWnKYS`
zVLCuGBb4)*2gsPtkjfCnn8FanRLQ8xbW7MRHM2OQ)UmWA!?hwgwV)(3KhIB-`4&ff
zd|qO1YJB`HuK4)e{FKrh5Su4HzOXbg2O_hQ;WNnKUrsJoF)sPZrManjCB-oTmB|^2
zMY#b*`B|ySKz>GMc6>o;aR!2sTv}X`pBtYFvrey|vIyjOFadIFG02-O3^!Ofia226
zen7W!!d(ba&km9VtKbB(esS19+-X<D4dj9i5(F|nFf%eTeqmx{<eZ`Tl>tbBwEzI;
CC|4T*

diff --git a/hik_push/__pycache__/main.cpython-312.pyc b/hik_push/__pycache__/main.cpython-312.pyc
deleted file mode 100644
index bf55583e27a3980a5b9c6cd5219257c9d113fbd2..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 1751
zcmah}U1%It6ux)n&d&bkPuoo!(?*+UH^0^v6QvDCt5^deL_t^z%XDUv%w}h2xpy|Q
zYYRyeZA8HcV)9T$q0mYc`l9qT&%SI;F>xwb5kc`~?Y`7JdCu%lYCychJ@?Ex_ndpq
zx!<|p#bRLsqwviw^IM6KU-73tlp0eh0kcL7V$cjp;wojREhS}Im9ZoPnVeDVKr&#f
zNtF_bn1PL&c`|4)Gc+w3$}&ra&0soSKVWY)0vojYXQ<1hVHt(p9eca#oDpp72G2&w
zRHvB{US<uuCL^*;lFep|5uH0u2oFL$&2=p$1zMnq*dOR_B0)V>6NRj9ISI*AU(tj+
zHhIo#eo@osX1J5j8gFP~PI%1FTurY9=?4-3x&*Uw56C#7P$IXXPeU>H4}%)gSMo+p
zvjoL^TPEZaX-$4tQOG5Fk*4b<f5_Beu3G<12kYG4dXdzN@n4=P0nd>=i#k^?$o@#6
zKxCMF@EXjcFhgI<Z_$J@Q4F1UW_a*v_)b`Vwi5#7VzZ8LJ(hF0Ta3+Ga|0rOVZfX>
zvu+~b1vSgzreO(BnW`?CTwct2EG?X@rx<xV2P!?|2s0sZtfr^<`vq30t84e!v(KMD
z>*#qK{E73E1$|cI_9S=GrVjsbTnhc|F}7x92Xh54tQkg1xZKoi-UhA^;bIEN@8rP(
z`Kj&j+TcfnpU>T5ciPTuN6#$0yc2Hzu<yOTRp**}z4%4(X7|=p!&~8zZ8lP3BQ@pw
z1KTWqo5jltiH$zkVIwf(yW%9cz1%T2NI#`x$JuB7z-@-<STEa*#F2l3j`g$6V*%uQ
zDbjwVyL3ng%f`TreJo+TRV*P|Ec!a}t1nM@s%;9P&6vf=t7azSbiL{DjPWJm2f?C(
zj(95&k8#IwIb08Efhkbtr+qJaVD(Zd(o<qRe+vfE%Zf^ip&|daru2EQ<w67TDHkEH
zKMY~C@B<tLrWzoCssVQp)`r`#0$|p7cqjHHBimxeQ$=3aAt?Y-5U&hR^)IXj2Yv{A
z*1%9rF62j>;`%&40=fgJe;i0PL-y!4>%7f6ucmKw-(f>L(bm=HN|DYI>#Swm(MkVR
zb?i17X5}=H|La~COW==MAEPA<?3M(ZD5}^Q@L4Y$h2D@oS<B@(_A3to0fCyIw{(YR
zJ(=gTybCpWcO0L?YI-UtQfPJzMELFrgabg9MXro5j(_~px^=_&ft~bCykIJYh)<;w
ztvrT4@WMGp#S!rw3*)KN@Stfqi(~X06ZTJr=giVwzu2BUV^#r!jSOvrmGvXQ6SA6Z
zrc(O?-3^|$9V4GHM|m%7Mihu;AZ3|SdY43gBRzLX)6b;;mq2XET9C^DnYOQ=st{Pp
zQ6ec<;*0T>N0uJ@OQQ72icF-YGIHf0>e?6ESNgW-!LlULBkSE|0?W;z`?%oNxG%pS
brt}o-XVI17_wu11S>&B_Wtp(Uer^5%)n|CP

diff --git a/hik_push/__pycache__/read_event.cpython-311.pyc b/hik_push/__pycache__/read_event.cpython-311.pyc
index 84cf380c308a522cae1e43d8fa762d1792e0840f..baac372e8b5504a46b54f9999f8833002c5b3edc 100644
GIT binary patch
literal 9431
zcmeHNYit|Yb)Mmy)KE`SB=xW!eCt8$VOfurU%Rp`Sr5w(Y1gW4g4R$nwG^ctQubOV
zy9%;xUBn3(!0EE6vt<outt3WP2^Oi)Z2~1-v<mvbj4*`;(`6u_>)8HBV{O1l|Mc7;
zMRH`*wT-mDI=no*=iGC@d+t5wp5Yzxj#jI|;QIN^|MLFEhGGASnC(lJu6+G5R6fE;
zjKuxeMCuctzy)41A%RbcUpgzBkm0E|`Gj0(Q%oq}Q|edFViPK8lYNLys7X0c4XFTH
zKq`R}UM;D5SAxc(DkPW}n<-3>ivg$p1ehOh3$Rac;NYFQ024nYyq)TYNHpTadD*BZ
zbP+z4p5T?hq;GCAtt@<~fPNF+U;nZQ!v--NrWMM-Vc1Nj9?I!8BN&GSck!JDgp^su
zne7F`#70N3P(fBJ49m3$JSi2ZOrUa7aaZ|?6eb7n)YXAS@Q`+!1KTnqg?CsHk&vpe
z<PuKRi{^snDqN&`r`2lYD0qDWGy8F7cF29OoSGM66}%D_@j@)^D`6GB5Uc2wu!>)Z
zRq`rW`PMQ}V8&XppzN~bed!tOGLB<sAl`6sys5W+6qf89GYnoeZ8u{PDe#&cUIsjo
z!^?p$%;6Ql7w7QGkUj&3&1B+{EWKMM9{HOP1y`lx*hkVol|@u)OpS$AaU$C{TO;)^
z=&24>W;L^0I;<wkvsT4n7e0HD3Nfyji)g|c(vZa<joEsnAY9OgMdj!G5h6^GrfdsY
zkxDU93H38*sm!)Sv|%muk(|37DGb$RtqB)~mEl6NDyu2ppEwql$4j#M*_yZ)SuNgW
zk)m)B(&&W_@VP6CA1MyY@*ozIH9JsB!X?nV7NL-J;lfK8MF3xyMFXxLwFcyZrcj^8
zBBdZVXSGO6I`vM3rOzLmwEA}Bi9C9?=^c8JvV54~lGny84VQ+?7GYkI(!iN~_%Cg<
z^?$+UXEAeZ2I~t+yWo2w*AK`mX{jUY9gsQ%4?6`9|1((y5@)s@y#6b(BsX3oy0A{%
z3i>}3OX8)ll+RpYop{fQ`;ZNSr6`JXY#|%6c9D%pBV^A4=hqE6vRdL8r@BIo*|z)$
zVq2-|{F-D_*2bM$g2m0RK3?98UMRK;hfEsUoyDIqZr8(#aN*r%@!V%JhQ3^mjOa!8
z{_K5aM~=oJ(_O!8#zK3xN5?P=M%72kMg6ni9bDn^zrw!%%-!h>+$AFAe_Re|AE#=U
z@yl51P6x7Ii!vzznUu(l%x5yGs5N2`*^-@$Vdsj5^JQSebF(gtB1A6n`dJrpEg|Gu
zLX>NXoLrl(lV;GwDLJ_t<}U1QA^VDU{r_iQan%0-?ier5z9rxb;hqV3m`LSe(kXZp
z<yIm$p9#5DB*~3nA-9TJh1@EVyku?_^~vPc9nwrXz@C#^^Xk5IZq17z-f@sy^J<E6
z>kh4Fa_f%v?Ciwj<;|_cPQ4f8R^tCKx5}>{_yguv`Sq!txixU~8T_8Sxw|D?F5X}0
z43a_&b!PMbOx1RsY!$C-?pXlt9E$6zo%X=GzXnpE24?XZ{W5nL#q}X)8#?XF{oYGn
z|Dw`0ITx7nO)si0`rd7xUkF}YEJ#UQS3I+R9;X)N3!$mzF6g521}5i7UtpS7Ed;%k
z+eZc$(D(QUpZ@K`Kl%3kU;JcS$}36lCEuhsxKNzioEGvL7&#Dfhpx<f7s_%KvT|O9
zOmQzze(?y~QobOiD@<ZR_bf<icIwu)PFD-OTG8{3i*v!y=|wG?XmH^|vw-jrJ-FZ%
z^B&4G8{`#&EXXT^)Z}R}k5>zVlM8+?PYBgMZ^+~G2h$BmX90Z?{N2qT-T&(!eD!zV
z`s(wa-~Z|7_dfm>uL6vL0O@^y0i6L;3J-qr%X_!~jMt=AV#G7+6^0Tj8p=EEn+pha
zl`z)OCI3V8RD+j#{C+UsH+_*;qBR~MgS_UVXMWxrIPC)r8R-dm_+mHd4S6R+0CEzR
z-XG#sXo(RZg&tL)C721$1r{oRx&Mpr-v9jO!yAA3;L}fk_nqa3OW(M6`=<{+`$13b
zL!`T?^itFu)l)kS3|w0WoYlP2KQ}#%++T3P6ZB2KB?JyH8yGoqoD%GW6-L&~fnB^z
z2p@IOGv#&r=R71Y7Z7=wFEBO7t319r%1io!y!>S9;{r85H&2;iEC@}|2WOC82sbZZ
zdeIXg{a&}QCT_v8ymZ<d;-%1o*Z6|IKrrM9Ov1>1Ul7E87`~M9&ig%+Ubk=7GwpRF
z*YhgM``&^#7z*;TdBiIr&_fW3y!!C_liqo>a1?qH#mj?!uXo;Q<W*=wZqi5b_!O^5
z?Td8q&w60&lpo!wo{AJyrI5cV^Z<${ggLq={XQ6mszo9dgq|C@fkImcRt4<^UYnX6
zI8cbLRIDL?0?QYs8j&;I!4So(A+p>)6k2>i+JXRbGWx!kwhjf1E)x#!DWBI*x{(sE
z7Pb)O4bJnpmqL#-g6R8nZJz7*y?s4r`{pJWX2Hzh+0iSL7d_PMC^a_&krq6=oitFz
zjgZe$UJsdam23VA4?(@nQYT>;VZ2^=a{2&XOISiyz{(8YpT6m*WsQuik(D(<<z7+Q
z^(%jV_4?JN{)Ae~5xVFVhNzAAFhui;mLc}72G`$CN+lY_BMiu6M3PvkylhLYNtEbs
z?26+|Nj+Oqe@(#^=wst_ff-7ID7!vPS2Qz(izQq%;o^wWq!xM!T?O(8fjmYeD@)Z1
zF+v|ZLKoCSNdq;3H7wCg6U_*yOw=hqkPah^u}gG;6-pXtH$$|rL<>!{ARyCA0##r{
z`3t93^O8Wd7-5Pl=mHy*v_&lp(aI97G|`GIvc5c!Jz4jX%Hl<S`t<3}6-NqB9GIN=
za41^N$c(JaNXv{|kv=-Z7S%2Fb0vnD8hpHTj4LjWhS_4v(m+mYsWDc~mfDvF6Q;VG
zyEv^eDV0`0ya0KOND`Ck@{^^Zq-sbaw<aZn619~xSvO6M8>YtP<BX}7HTBYEJIl4c
zgrV}rV%!pc@3#Gp>y~T9z|?oM_1%o2hc)zE>*w^<v5TzUzN}*Pt=EolrkW&nNTTh>
zAEiE`@~tvs%*2+N<5xGz+L*F7&f;8lv6k-WFz4t<Vh8j?po?gXxMytOsvOIWE8(?4
zwsZ86RAQ=tU0|w63Pgo9w0~OtqiUp6$yRmHor9p#fK(bPVueWs*6|jg#Q%sfwr*Kk
zRw`IaZ%obETJ8jH1y;_i6*9KttnGNLfa^F2YG)Z^+g7DznV>88K;gO%uld;S(b&*(
z6;rjBuG+iR-Ir#z%+{D{tJ1!#VJq8L-rK0`qAR;N`|dm8Tj7<%t8I*ZKWpE=X@7IW
z{^r`=b>K%>`$(*RE3GoPR?67>SbN{5y??{rzg|wCIK|jcv-Z=met=nVF!r8Uf2<#-
z;AnX+XvcazV;^Si!}&q=^yo>(eu}l9$_3@xdSI?+7~}4(_O8_mw!IJ73C7sMb@Z(E
zvK{@Im8grKr7K&ZY}GU@`&aj}t~co#RJhK!){d~9gX`dwcj($ZoVjzgcU{50ahx`z
zvgO#bGR``BHysBz90%z`V~hjX@uU>9wyu=3mM*$`kg*KG<j&$VczkGE##)BfCm72+
z341Ho)U{g9HbLi8Y}4s~AD;lnI&9!rhb@W8tqu1Ynzv1QYm9Y`GYxOE4R0sq(3DhR
z&D}Yj>9KLP3DPL$>=3M?_Z?>(qfZo=wUbL53L@5l!pn+=u)+{PK*LmfGZhxBv5hvi
zB_#^e5T0<f+|_cmj^!|<X6G(Q&CXrW%em{TUDi8Ox2Bfg{+qemb4fW?jUcKmH;0x@
zOjSEu)lOHnL*;3r#*xHuK+2_wD)Y@@y5ZQ`dqAKtRfBBRAT2H+gbeaDDMh`Z@+g9%
zjq;>Vg6Zw?h2?iwJJu@MH-;JA2&)^Rbt7AKw)j=Hu047zp{u+x6t7@(O{}ho)-`cf
z*PU~>&aL#&2Tn28)2#J$bcAzuMi0jt8J!JW13hQh+Scd*SKlOTbkphxQ$NVo4@L*K
z47KsYw8065bG5Gwu&(_vdCbok8);+Xma99>Y#Hj7^|ZkSg==aC;S6JRZq?L9`?m~L
zu?g1TSU$92Xr>L#oVoE%@2%by`3l9DdsuVNrg{H{dH?FAHQ<l2=3}ti(kcb3CmHiW
z)_ic&+_z!wTN_^oev~zj##Df^e33Eljj3WPn1Q9~xtI%U7Z~#ZYaYmtIkx^LV?NHB
zkLO}?4IQvLO^nVCI}~b8MrYv+)p33FgXjk^T$O#<x}vz-OjmY7;b3!>f3^?Y(LPL9
zwQx1<D+{aRpGD}JJ}6w@z`E^=;my9WjlMC?(gmS+7_WyY0veacr*3O$*FmQC5Wt?m
z-FQaC)*f1GU}}dG=4Q^(ygYSROYiMx9RvTm2M{a>z)}zUqt1EH=1g1Db&PEoWNbsM
zZ3wnUof9Aj@DY4{>R+^+qvx?yGJxB*Z1%@;s5s+?mu<I)>9#(`au|ZQu6?Bg%>wPh
z_R~!57+X6=*N)v2Vo47x!RqX^&JO!R-;XCOO}B?v9BX>oa+I+gWl=f4X&K+JjB{0H
zw7F1XwpPT{+dB&-A=bE?HtvSX(?q2OHUt3W(uA?*rk1uHS!)FXg)tswjYny50bzPu
zKyS1^4#|XD&eJDHWLU8YcC%WaCBnTw=8T_U2s=yIX~GU)ysq`5*S%8Hjpn$NDYdYr
z7MgfYVF-&blo}w>NJmp6JsFW<WflKJUjTgiJ^M>2!Nxu#L$~GN&)}QnuZmrLEz(~X
zm=JA6^dAfY-G}HGEwa8n$}c)`p#P{lW;s`h(cOn6C-%vhHzdF?`!pw=$_=IAq(!;0
zO97G%iyTRu{riCV5Bnj>*+$8iPNe%~qvo7J{$+>ZT&X-kAl*c%93%;Y6xA#6^ZT(x
zrRIE%G-1`BuaG8sWFYx%g&ZWmt&yVo{wjBcbTacBIhc>m8R*RP^<MyizX;%A44#A4
zz;E1m_L)u`+Mc~g2`Lpnoj|?NlOj?kpws~`do2{1fP#L@hPP8b!mEVi(-`Gn)V6lF
zxmx#jxmsOq9W9H68Mf8c+SS5qFTpwNg5Nvpn*?n*YAVwQFsK%04<hKG8bs?*OPv5p
zb#Ifuhf0tFvV?KUlIVF_X@<gC+gFaU)&rZ?qZ`(v98pPEH^Y{(X<*CPG}j8Fi;Sus
zwyw$$bJ0o%6t1CbwT5jN*lakl(QqQuqY?FJL_I!WRCZb@aPLz&q084WDmICnv3;Ss
z;GF$X`3MV3!g#J*z)?z40*froESD4(9tSBnAV->7M5-E4DD<N)g-+g-1;`IEr<59i
zO8T)v>R200oyXA7a2!jmP&?{^$Unh5co;}(h0exptRBoqg)>{O5zz@oRZ9znQ<ueh
zX|)~7&L)_&#sPBb9YC6dcjn4O<Pi|%{db2vqrc<78sg_)seeQ`@e!CN0_LUELO?hH
zQWL-mqYLwcI9Uj|;ZX*49_0T9?_d=W;b{2b;P*7&C2kOmteTZo)7wSp%&XjR*7gP5
zZfB7&g7D~ovO-^8IS+qi@%t_a4<)D`5K#?CE*DPYlnV*aVKfze!UChg5hOYyyWP||
z)G9Xg_p096IT9WO?WfSPp%@PS1_*rXz;O;MToPU!R<I<zawJ9?6O}EjXi0eGC|hYv
zRFaB-1h*!!9C|^n!Zk@OL&{}HAwvprd>7mzwuuUp5!V(sq$XNw;$%fjM?V~lYNF3u
NPKXFu1!xJ&`rn$saWen_

literal 4494
zcmbVPeQXoS6`%F4Ki1wPP8=t3z7rgRfh6T9A0lw%4#)xdIN%N<LR!mYH;IE|ySwY;
z2<s}+(KhW-$(6XCg=n!(6mmUurBc<VJ+->_stSqwV;8N2wNfOc9tHlWWJHmo`>Su(
z_+x#ch1;Ed^WK{`zj^cC?9A@<vNAh@>#+7mZp?wuKe3RzsAtTRp8)d#Vi8M(&}g<M
zMhTEjA=3;wN)lNeHA?9==20`$WXLjuMy=3BokycK)(n*9?5yRC3FGqhCd8p>7&Ci;
zWV;6J$2kSMMt}rQ_5vK@E&cIXA7Rz7kI<+i0dWdyYd|;~9uG#wpBd|w1?ao*JXrv4
z01+?+F%O5(be<QBdQI!jVZ{xi)B(|2Fr3Z>2N|7?BQZZEgd_;jJjg7mQ%a|1)^fvo
zjfBa;lfAZ~I3bqhB=9Xil2qbF+{D@>(=5R^iIoL=mM-;`#wmgO8qDY8{G4#2Ac*!g
z5F9Usz^s8#_EHGtYamp-48rqf7<Q~fTaZA_ncg8!qB(*<Cn5KQG52&Xc9N-dObH_F
z$u*-m39`LNra)$jWHZR+MY2V7=Q|fIZ`R3HvQ;-+#=O4^`8Y?OKp&7lq~cZ@N!Aoo
z=w0Agx6w;OKbzQ4u$(T>@sf?LDfpGD$mxq~)?&mpN^u%IqS@L43R_p;<95luA0>$I
zRK*>VgY^`(Fp@dtEFLGvOAK3YT#@lIsSNkt4JK@Z<d{YL&p~b|ps|ewK3*<S&p|F{
zn@W%?q>2)xW;}{SJ`Z8C<ZX#NC1(jji|(h#s0E*Q8#RV#R7#b`R<QRPHL0R^ITtJN
zw9=RlV;{B^`yzS^_9<6^FL07Ya@=S$#%8)Y*ZyMbB3@Oz+elyAD-5kwMz0B2BNwW}
zudhSm#@wg~c@e)Y?keubwo5Lfm-x+PQQY-?m)KS4IbECM*>%Q|ir)%-)Q_^g=ZHC!
z-3w^+O_0JZ;QKf5AU7(^|KC0@KCjFnZk7wpTf4_2;fdhnylpCYrYjl~rsf@4P50Tr
zOh_a6d2>vh=-LTgY+QIe!Un^Wnk^=9yg$eaF}zwH{^k#le(=)=fBqz=)vPQx8yx3^
z7=HEg&CisY9Yzj|e(`LSi{W*WHz?>e8+OGX<3q*~a@u)%%PTv&zXkV};2GF+G}~K4
z2ibl;G~gpOYAPa#8WoN3BH#oBVJ^b6Z_k(E849t}UHUMO@R_Swq5(cIBWM;~Cup=@
zzl}Ysg7$x1{`G?^zxwh|?|u2{?;rg3)BC@CPovm?7|`fo^fi{{IYEfwT{3I;@RPsX
zzxpH1o}K4#V20DII3$NyL38?9PUObLU?hAD;t~?^C&RQ53C~+Oo{#XmS|<Squ6uiZ
zb(%F4nViIdcAO3f!SQ{1iZtrbaQ~Y;KB@5(0iB9Oxv)m*iK2zT1m_P$0<30^^1(0!
zAQ+yAXtqEw!gFj;(9FlO)oDH&iSqRr#*FP@_ACd9<ur1V6EzZAH5<=;FUAR?fWrvE
zw8EMYA!!<Y;GJ<Uil@Qj&koHjgg7qhtJZATBR?DDHDW@uWS7vhbutr(=7QqKd^X6K
z<#F&dM)%J@9ty$;JU+8D8|2B4!^7hRqM7xy@c45^E7y5__4oym*X+TlKakCZ=E#QL
zABNcT_+Ztl^I`W-1i28aH)*uKjv#$ejo<{l1GTPkebu*b*Vu7LpfL6tI};2CVYq-8
z;m7tz#$z+!t1y;(X)xo*pkq82VEwv_-O;m}y&&>^Fbw{}6`~Nihj1^T70RJfwZE9W
z9FnO`3bje4HUV?L!gb;7kI!8=w{UQUE?b;RdX)0^)TmP4bF)h+-}{;C)|^a_DD;R*
zk7Q7p*(IMETd8zkY)%nMWxHD0zGz81+{qKNV;z(grc$ozP?+^9vtDM_r<tk@4Sn>E
zI(dvC{)0(Dm*wn;aVPs_M>`Z9#;Y(LD$^k|9T=v<(B=6sPQ=tDXJtnR6dk5hVK%7D
z2ASD_VcahWQ-heA|1qhC7l-j?YG2UU7?su4)zT1QgQv~N%$y%g)F@P)O4Z3!UAn@Z
zm{u#=77nH>Ym+pjWZ`hyS(A`dr+48{p>@U6cDZ@!)UtSMTK1e&JSSDpN!e9e76vmW
zuel@bZoBL5yyNa%s!-fJRrgN0qO>ehE3Vp$yOL~b%jL-{;Y;DA5v6&X+PqD1ZC72}
z7i}3+8x25B$te|ZY^r<9Vt?Axl0lxbw#S$x%=enwQ@v_aPr{yV+jza{!=|Nqx%W+_
z?TFfTBvGF3*qSgW&M40Iw9At`p4gk%o3Wtw&eZJHrloUgTW{hp$m_bUcYoM@vwr!z
zO8cPNKA0Ftzp^KBAi4hHP-?SM-2*1A8?H!~q@}~lCZ(lUZRt%MO!w?~X5v$-H{Yvm
zPjO5AS7+qftx(cE-@bX`Mtu2{+H***+njFbxw&n*=68GKhCV3iz5}04{JrdM-_bjL
zN9AJ^O5dc~H<>(;T7P*+-nd(7+;hLtdu8a-(9(uwcXCK++^gd9#@)u@JB`D)=9I<}
zwQ(dtuQ=Ta?q|$JCc$7fs5o0yXRGXN1tzl<!n68xJ92t5$V9sf1lDxImprO4Eh^I@
zGc9SRdhsB>?^k&)cBM$A%Bxm+WoC_{FkV<xs~H*qalHe^c={@G)&HM<0Ji#m=L;CE
zu0B3Qz~T{(!_M<pr*GeO@^6-EOgl0C+@{m*)V^KT&-V~O|IxVLJ3ye@h!|`^w+Z_o
zB5ymK1HI(!1`2C>&7k=Lk-&e^(m2>ljstN1!e;_Lpq}&tdG1fHId5O`%WC|H%Kjqy
zh+!X@J#0um7S^}XkI)kg!S4m4SwZU$M5FuxkPgEmGy>5#*YgAK+i^M-s!64q<XqwR
z<9;?j96`ab-|u5|`0SBrjlzF?D0o^wXL<ZP!?$8<vwleNUaaWD1doO>@LA*c^RHvw
zK1?vU?%7wi-7^t37UEvzv0M0qL%0GYLlOj$M&%3ookorY{Z6Ag*;u}Aa}RaM#*(q@
vAv!WBPx?#*(VRhfVnY<OIDd!q$fPGtRV=)5ejs5_tQD0EiKu$8(kJj=K#eeJ

diff --git a/hik_push/custom_exception.py b/hik_push/custom_exception.py
deleted file mode 100644
index 086a7a4..0000000
--- a/hik_push/custom_exception.py
+++ /dev/null
@@ -1,2 +0,0 @@
-class FeishuAuthException(Exception):
-    pass
diff --git a/hik_push/push_notification.py b/hik_push/push_notification.py
new file mode 100644
index 0000000..3d47c39
--- /dev/null
+++ b/hik_push/push_notification.py
@@ -0,0 +1,170 @@
+import asyncio
+import json
+import logging
+from pathlib import Path
+
+import requests
+import yaml
+from redis import asyncio as aioredis
+
+
+def read_config():
+    # 读取配置文件
+    home_dir = Path.home()
+    with open(home_dir / ".config" / "hik-push" / "config.yaml", "r", encoding="utf-8") as f:
+        config = yaml.safe_load(f)
+        if "user_ids" not in config:
+            raise Exception("请配置user_ids")
+        if "devices" not in config:
+            raise Exception("请配置devices")
+        if "event_type" not in config:
+            raise Exception("请配置event_type")
+        if "push_url" not in config:
+            raise Exception("请配置push_url")
+        if "event_level" not in config:
+            raise Exception("请配置event_level")
+
+    logging.info(config)
+    return config
+
+
+def replace_image_host(detection_data):
+    if "imageUrl" in detection_data:
+        detection_data["imageUrl"] = detection_data["imageUrl"].replace(
+            "192.168.1.250", "192.168.11.180"
+        )
+    if "visiblePicUrl" in detection_data:
+        detection_data["visiblePicUrl"] = detection_data["visiblePicUrl"].replace(
+            "192.168.1.250", "192.168.11.180"
+        )
+
+
+def push_notification(push_url: str, notify_content: dict):
+    try:
+        push_resp = requests.post(push_url, json=notify_content).content.decode(
+            "utf-8"
+        )
+        logging.info(push_resp)
+    except Exception as e:
+        logging.error(f"网络错误推送失败: {e}")
+
+
+def handle_event_detail(event_detail: dict, config: dict):
+    user_map = config["user_ids"]
+    device_map = config["devices"]
+    event_map = config["event_type"]
+    event_level = config["event_level"]
+
+    # 事件类型 id 替换为 事件名称字符串
+    event_type = event_detail["eventType"]
+    event_type_str = event_map.get(
+        event_type, "未知事件类型"
+    )
+    event_detail["eventType"] = event_type_str
+
+    # 添加设备名称
+    src_index = event_detail["srcIndex"]
+    device_name = device_map.get(src_index, "未知设备")
+    event_detail["deviceName"] = device_name
+
+    # 添加regionName
+    if "srcName" in event_detail:
+        event_detail["regionName"] = event_detail["srcName"]
+    else:
+        event_detail["regionName"] = device_name
+
+    # 设置默认的事件等级，高级-3，其他为中级-2
+    if event_type in event_level["high"]:
+        event_detail["eventLvl"] = 3
+    elif "eventLvl" not in event_detail:
+        event_detail["eventLvl"] = 2
+
+    # 根据设备名称获取 user_ids
+    # 高级事件
+    if event_detail["eventLvl"] == 3:
+        user_all = user_map.get("all", {}).get("high", [])
+        # 接受全部通知的用户
+        user_ids = user_map.get(device_name, {}).get("high", [])
+        user_ids = user_ids + user_all
+    # 除高级外均为中级
+    else:
+        user_all = user_map.get("all", {}).get("all", [])
+        # 接受全部通知的用户
+        user_ids = user_map.get(device_name, {}).get("all", [])
+        user_ids = user_ids + user_all
+    event_detail["userIds"] = user_ids
+
+    # 如果存在 data 属性
+    if "data" in event_detail:
+        # 替换分析结果字段
+        if "eventType" in event_detail["data"]:
+            # 事件的分析结果字段名称
+            detection_field_name = event_detail["data"]["eventType"]
+            logging.info(f"DFF：{detection_field_name}")
+            if detection_field_name in event_detail["data"]:
+                # 不同事件的分析结果字段名称不同，将字段名称替换为_detectionResult
+                event_detail["data"]["_detectionResult"] = (
+                    event_detail["data"].pop(detection_field_name)
+                )
+
+                # 如果_detectionResult类型为数组，则将该数组第一项赋值给_detectionResult
+                if isinstance(
+                        event_detail["data"]["_detectionResult"], list
+                ) and len(event_detail["data"]["_detectionResult"]):
+                    event_detail["data"]["_detectionResult"] = (
+                        event_detail["data"]["_detectionResult"][0]
+                    )
+
+                # 如果typeName字段不存在，则将事件类型名称赋值给typeName字段
+                if "typeName" not in event_detail["data"]["_detectionResult"]:
+                    event_detail["data"]["_detectionResult"]["typeName"] = event_type_str
+
+                # 替换图片链接url的host
+                replace_image_host(
+                    event_detail["data"]["_detectionResult"]
+                )
+    logging.info(event_detail)
+    return event_detail
+
+
+async def push_loop():
+    logging.basicConfig(level=logging.INFO)
+    config = read_config()
+    redis_client = await aioredis.Redis(
+        host="127.0.0.1", port=7019, password="SMHdFrlK"
+    )
+    push_url = config["push_url"]
+    while True:
+        try:
+            data = await redis_client.brpop("hik-sub-event")
+            sub_json = json.loads(data[1].decode("utf-8"))
+            events = sub_json["params"]["events"]
+            for event in events:
+                notify_json = None
+                # AI事件
+                if event["srcType"] == "eventRule":
+                    event_details = event["eventDetails"]
+                    if len(event_details):
+                        event_detail = event_details[0]
+                        event_detail["eventLvl"] = event["eventLvl"]
+                        event_detail["happenTime"] = event["happenTime"]
+                        notify_json = handle_event_detail(event_detail, config)
+                else:
+                    notify_json = handle_event_detail(event, config)
+                if notify_json is not None:
+                    push_notification(push_url, notify_json)
+                else:
+                    logging.error("No event detected")
+        except Exception as e:
+            logging.error("error: ", e)
+            continue
+        finally:
+            await asyncio.sleep(0.5)
+
+
+def run_app():
+    asyncio.run(push_loop())
+
+
+if __name__ == "__main__":
+    asyncio.run(push_loop())
diff --git a/hik_push/main.py b/hik_push/subscribe.py
similarity index 100%
rename from hik_push/main.py
rename to hik_push/subscribe.py
index dd826e4..91c6c3a 100644
--- a/hik_push/main.py
+++ b/hik_push/subscribe.py
@@ -1,8 +1,8 @@
 import json
 
-from redis import asyncio as aioredis
 import uvicorn
 from fastapi import FastAPI, BackgroundTasks
+from redis import asyncio as aioredis
 
 app = FastAPI()
 
diff --git a/pyproject.toml b/pyproject.toml
index dfae25d..8f64362 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "hik-push"
-version = "1.0.1"
+version = "1.0.2"
 description = ""
 authors = ["quantulr <35954003+quantulr@users.noreply.github.com>"]
 readme = "README.md"
@@ -19,5 +19,5 @@ build-backend = "poetry.core.masonry.api"
 
 
 [tool.poetry.scripts]
-hik-sub = 'hik_push.main:run_app'
-hik-push = 'hik_push.read_event:run_app'
+hik-sub = 'hik_push.subscribe:run_app'
+hik-push = 'hik_push.push_notification:run_app'