From 5fe703946fa7bd708e58039980a84a13cf28de59 Mon Sep 17 00:00:00 2001
From: xiaohuozi <1093565302@qq.com>
Date: Thu, 11 Jul 2024 20:43:43 +0800
Subject: [PATCH] mqtt push

---
 icons/Mqtt_A.png             | Bin 0 -> 16159 bytes
 plugins/mqttpush/__init__.py | 291 +++++++++++++++++++++++++++++++++++
 2 files changed, 291 insertions(+)
 create mode 100755 icons/Mqtt_A.png
 create mode 100755 plugins/mqttpush/__init__.py

diff --git a/icons/Mqtt_A.png b/icons/Mqtt_A.png
new file mode 100755
index 0000000000000000000000000000000000000000..ccbf11b8a0426f430d9ccf7b505ee9af247fbd9b
GIT binary patch
literal 16159
zcmdVB2Ut_>wk{e3MX7=yN(%}~6I6PSh*Slnh8k2vnuzpH1Vj{&2nYxYNbf{?2Wiqo
zI-y8O=me<=1PIBQ{Qp{OyZ*E9bN5~A>~qh_^L)wtX8YzCbCh?KkjKcgptD+Pnra{l
z3JTC4A2J#ws_Je31O(F71_=SXPJ>R|0)Z%jEea492y}}A_&whK+lM>}QUTFWQ=g$e
zMRVr#8CqHzI>w7<85tNDxzDpPU*zMtdWDyV_p*S9><s}SDdEe!Vt2%(<P~q-x^?x2
z+Fey8Em_Dd#p9b$(9+T}(lc_MJ<Fvi$SbJ$|M^4y3Sv4<5l=BeNpTr;f{B8XiGth)
z0t3%_5}@uM1OoFDlvF2AQJ+3TLkpZxaTauff|BwC73Im3R8+vx0N^-?is>ZtrJKs9
z&gng*zU;yx78IR!n)h}|Gpqi<CZG5t*WfcW=h-e?WWREiUqDbuLQ+avMpjPcj;flv
zhNhN*p^-7v#MI3CvCR`(J9`H=cMnf5Zy(=~m!Yr1UcU*CiG3dzpYS0uDLo@ID?2AQ
zFTb>`yrQzIx~8_JwXOYIM`u^};Lz~MC~9nc0*#rQUszmPURmAR-ofE__Xzt3$8=GE
zDE}nuAC&!tE+&Ak6I4``RMf|GQJnBPCY*`t<fWUZn3eUYAG(~oEEaT{<#u#hN%I+A
zas5r!N3H`j=lLYiSGJBx`-8Io8ezfz5@r7&>_6z50MSuW056Y{2?PP{nhB)8p!q*>
zEL8NpHaj2UI*O7Ok!<-SabI-1$)F$nbTMmdu|hNyE!<P^L|C4J^Ql~(b>z{lE~4;K
zsU}~HCO=>7Xsy7&64Z~&#9uDYb62r|#Ks*&1}R7~9^#saM&QkA9OFJZ7e13k24M=?
zw(Yu#5&2(N50W9`lMuAaGI*!;J{i<>mkesxBZFuWx5%Ir_OPP^E0R#X?$yX7r2^1@
z=ef&VV9fQfig>0DpIskKjC|0S)Q&VFHrJSrg6gavs(Z@O?ao$I1saq74Nr`Ntn%&8
z5$ggk6fT95jBOOyw#AoMg@51}Ba#Bv$2?wZzt2HP2HGL;RvkOV2h)oj)y$6e`X--j
zU{Z997~%N)?_s%f$+F558cE>-c{~E?;h^Ak&&o=lm@~El;tTD;y|}Iu)rpOwcJI0e
zwC(fMFLM<lXo7S4-~NR9SyV+R(B=@*&qog{`)8ba9um9ON(ft(XRnr-nU=`u^3%2E
zC$XJBX8v_DXk(BJ+A@T<%=N>ULdl>%8Jc6cxt@lu+i}WmfkIa2VfxCejJQ=r;cL;B
z(XB%<weoYJSy$ZstcaqDlq7El@ZJiXkpGvr1bs6<5UacT1w6d6pECZJS5`Pigl_(t
z$DZqQaf*F0)DcQ-mLWQ})TD=nzEI$Th_8AtXr`O;K3HxQ>UKT7n}bU9=Nh%Gu4ov{
zab0n$)NmsTjdvf3i4&4=6X;Kzd;?2{Aum6f=&7>uon+Cw^{)<2_4d?#=Er1E@c<bl
zx7mH*Wia>@|53#;_iNc#6RB@}u5#{$>I7%BCpJq>DMp428ZXFxYol$NQT*z%#M~1^
zs!ztLhH2+erHcvcX1#2Ou~qo1WyOJX%iEN@ev`|(PTvb5anDNb%NdJ)oL-9DQI}k)
zf}boNy4qtDuDfgVI%oAvao{03;Z32dYLdlgk^mnyP6m=?SD=iSGzoXk>v|Mk=94pR
zzx}kKJY}lkN+fb8e<a<0%^}I}nC6ynfzKc}vs(T)lDdq#i}ne+XZb~#_M;o~y@|eu
zqs9W6n9Rbi_l9vvipW+7tNW2r%%rhVNsWRt|K7d8rd9&UW4hqfeZyeJ+rkSjQTSnR
z^N!k_SC)^U(#E_+^<nFXUENJm#zc+K!`e1X!AmUVvXC%iYs$4De{HA5G3~>4aD6Dj
zo0M@7CG1+mZa@BsK~(fRAilT7@lM=57GL}nZ=Z}mzvi2Vr!LuJMU%ufuPlW=5zEHD
zm7Sdb#9(lgfKxhREWtFs$SoGZ)CHld-`c!EIr2un;>H)r6*G2D#MvA8KJ~AN92l%?
z;`W!1y=6NrQDN^s*OOx$LWIs#!OhT&lFKa)4$JtwVI$UlKqORC;x^4mDsrhuF1kmj
zQD2}4;(0RY-H#kH$ijdOx-GfJy7Wj%%I5+S^Cdl8nDW!HzWuKlQFfQB-()07L^B$B
zP=SBc1VGWqFc0nCT}WvsJZfz1NNHom(uRLdTeB!p?^F7E;#_S<^OV}8dy@7%)J{%a
zV0&g~8Lox);1VK(G*Y{Vovu~}PCuFjr!B*24m>~CmR2?deXa|ZO@BtCkrqUxcUL)g
zr7`E;%~-4RIX%gC^UzX9GU#;qVejDb5QiY*vQ&>6JfGC0wIkxz%8m?sGM;BvZl`nJ
zXg|X_gK_?OKtVohhEi?vFt#PT&){;nK#_JZAW^jEy%Nr|X}a0UH!JuTq&0(&oE`8R
zr~Gw8j2@SacAHOg3f+^@)FpMpRelZD+bX>`HWC!fU@y1UbF9G|vCeUyCd5g-A6Pl~
z`Bo%hO0(}eV|D-(&y8t_Ix|-tdNp)Z<L5JDgLhx|PSx)ZJ@>SYGk%{}C#EHk{`tFg
zdS@t?ir@vFsMAO`Ldfi?0lolT&B%%n&YrVmP(0Nhc#RCYp5<pLW)fpEA<H6nL#Vrz
zCuD5&{i=+7hMAG2w7Y-lDOG+IOJp0Evg#F*ej)t)5dX8AeK8#b-I6spBa(HrK|oX6
zlDqzDcC31q|6e6zjtn~4G%ub<2BBEUp#HahC!Zh7iueBtS-Cfm>SBRtn>=igZxPeA
zb`hy>F{GGt%Avw_B6)P#z2C|?N~cC9k~}KpL>-owv%=z3-TN|JaOsT!VHoLfk<M@V
zKNPw7oL9^|XV{3!3{+h<fJt%?%fU(N(o2{(51VtNRehWizJ2&{DlN12pq%;D(P{9H
zT5WlZ^D8`^V8fw!D!N)f6{$N~=AK=pCYGizpHZBiUR4*oeo3T!p!eePz?TPbCjHST
z%Bn2)DfBGNTRmu7U6}8lixiW4MdcTwKX8lN1_OWj&ceB7bLaJyRi{h{FT55Ww(P1D
zw~%n)F`D4LTQ$0E{v%nh1G}!+9-wT>z7Zy|!8CC}lEZ}u?5f<FhBuhp4{*#*xzwTQ
z5LGLa!*wNJ>FHur#R#G9t6W&<&mT3lLtPjTn8A35^+x}pd$E3<^_45`eQM_np!Wbh
zP5<g<85TtJazjUiR@PpZ`mnU9vjs12LeF3=;9BBIiK?2W(K3Ps;;X{)W0JHc>rOVN
z58}Ld^ExjV+J<j}DGAeXnrR>DlUYMH&eLkLH&ZvRH|1{NkzVC>!3Tr#A5G7j*xc`2
zb-lnHw`7z#`>TK3QO|uUr46U2`uGvFp|ooFX;ww;Tbp1bq2<<K;UzNYqPISrW_6LW
z=GT=T^KNw`oYEYT(f8nTse&f@(3yF8du)o%b}{Ofn04THNFPtM*+4$}I<GHlvh;kP
z6hVXxy7X3;RLxI%={P3b-FV*K%j|l1#Yc|eafzEeN|Dmf)k|1c%dzE)6LfcVGVA~z
zw0-?|3>KzQ1l}3Vf8>SOM}>MJJqQ(K(B(U+_-V)zjCHzhvx#E$0SN@y#!T!nEWI|q
z%I53dV$P9Q^waB2_tJK8pBkZ}aEw)3`Et{155A}G0(nCSh;P*j?BaStF7eAh+|wX$
zxXGZ;#5?^JgC#|M<Il`VrWXF0M~o`_OB1zeR>CgRwayHLJ+sZ7Yc4v^oY+W~OIKci
z*HQ`yF25{>TJRAvs}E|MQ<Vo%g6P!Oa=LG5T9CWutz^)(D+;lsuH~7&iQ2}IE`jPg
z@o+sC&tsn4iHwnmm(pYryU|Q1b{Z+L)zo?_<omFKBGY5AL}f^f;t=X+rf0ChA-r0<
zd5Ya2Pw3h5zWF;1MRhY3SkK%>n0<a>Qc6_N^{`$(l^_T~dgovVCeP>0@|H8ab5*PK
zOEZ<H5`K9oKO12jXJce11{h5GkRs0+#`@>e9QEg+KYFw8O~IEUz!>h1YGPo$u9m*5
zkS(j^lRLB7Nw&iSoiS?MQgo4Gr)8-Ouw6=QgyCjBUxqCH&W`gjH<#f{iKNtoEZ;Gt
z*mJ-tB8)%g2;WE#7ozJXgC4!G;%L6Wb_ycU<XZCsLYew~1TfSm{>{O_i|Hf25rd=b
z$e?8JCo;$^e--qh74wQ(3w}W(g8Hf$Mdv|?g@5WPi4aop!4YHKB>(|A=7-v~NZCGP
zufN2hu~j(G>s!>(Y}71O+f4l>hK`gL`e>SXdFy1QcHM*}L-S*y8Ny}<)>5cJdKhbx
z<eb-{moz-=FIl)ED?Q=#T|=(1w}%W0U=Y5RG@_}fSNJ%y{2^d_?(3<tfM%a7Qw1|9
za}_jfCbV-*@!MpVHE#Dmzk=nnCWD@UVFB0|-vshLv5X{%=jn(W$0(%?RmdyCdPNIG
znY}rm1O90_;H?GnqrW1?Nu^af9n)eJjo7&4T*I@+-8dJ00IepNx9@Tbm+pv|bUc6I
z^X2A#EK$Ash~5WpSM5-#&^_j*Ym_g?E|6X#`xTYye|wV#>(ZE$^^NVma)NS43N`7w
zq8|>2RL)?%|1qRi=-hKJ_3rOkoCSi$2EmyRLNru;XWIHsM0}XB7)(Dph@85UarA&h
z*yB1<S5#NhOc5T;(E~hDyHI}SGr;i{(W{>@3_e4}8O*4)ryB;lK?c1<+&z?>49T5%
z!PiGDhxHvXHjUN`_>LT%GpX*c@Rp=iIqdv+MH7vxP0cMVFff2UVO`FT-cd?Q&$T-!
zYOKndoSBeX&em=n=AJzai6$5w?68-W%u5WF0eT(uufpcPUU!B7g%l9L%A>6u1*b;=
zh$Zrf1H8ip=R~P!_DW2Qztzlf@4JLjVziumm2jul{3Yk>CoN60Q;c)rJ6He|-K~+@
z+Z~+zE>{>4d8DXbjm#B_%E=hRN@dUJRfJ=B#}jg@6_xi`2k7p_#|&e0BHp{l=k7;E
zCgI>L#H%$Wj2@rsELvox*5TewDnymZ5Ij;onw|e~v?-U)MUw|18<y{Kv&(G*<VtcI
zMggrYkf1Ow|E0E}(HOP;?a3?ezV03(B3J2EJ}yH-A|+D$YGGgCCNxT<-pFyGtCH)s
zB==KUENSonv0!QG-(VBqk^@uqvK3ZU(5~U~gX0ldeyCu7YiCS@yvrmjj^_-zkEEc8
zSQ)}Ln<1_iSogF&+*e#)^I*|ab>mEDny9~v(G7uo+0e;($bC)Je9?&W_EM!Hqq9m!
zmY;{=@KX`|-7|&jbIi(O?>!{5<f0fB%N=T6n^YEQsLfDYqCqa`23IE~|58Mf;LW{$
z9As#f{;@k!M@%28UUE^8Z?svJ#XtZD4uuJlzK`fcyAvwvou`-s=NnViR`8Ug4e5<0
zP=V(6aW=A4+;KSmAflSWUG&&9PDF+JVcu5~VS^9}{#NZGv9=$*h*>e+DbCSUWq}H|
z0nZQmw+8g)+>z@}>-0sx$x}w3w8CkN(ZN2L`oZfFfxMA#Te_8(2bhR&9cjdpYNc{+
zd$10y8$#br5bYaoD~)G1^Q=F5m$U3<c|Li|>vr9xXYrU`gu&%!dW2$l9781PRy=q5
z6xRZ)y3Xh|Njv{3rES`m>(<X*@HnCa{_&8Swq!M6Q%(!N-*SF|BZFAf24~H!g0_EN
z#_v8Ps^D2i2Hmu!+1w2uW7ZK#l0`I!trJ1z!;fw@89m&4%$@It*mg0kz*RP&55Y_;
zz4p0xxO_9BE^>_MTEplu2wE5csxP&t;(tAsZq~n)aarBvNVfPu@;%NkC7JGaUdF%&
zLp@b@u3JL8(FK;vW}l>Y#h%8C_v0Q;>E=R~k}?J(`v)DqYYPgCuR!Pt!IN!C3eepg
zibhjj{;SelhCud1`BVjVsfm)1uS@HAm$!`LV&~nLTwzZrhvC=44^9Zic*mH0kdu35
zY|u>o36*G;%2$uL+`y&-yYn7^Ee~ACASQnRXq-9!>T%V*8M70cv#xWsfjof^pdru^
zDrl&`&L(OX{91dMHsbDDXEo=w)V8K5Hv;Mjd(OCRATx3d&Km(Bf-gAA22TjR{~dS8
zxlHCt5$6)x`ArUj`Hsv1*kLZuRqZq%Q-9QmczBFGfWg|^Qw{Y|inDM1NX*x1C#K||
zcyI%>Y#<GeWvrHcJE^P$qbXDQ0eCep{~g(Ku{z&0uMtbC>mXuV>QJ>rGcqXpvhKkK
zcn3+dVM(wGS@it?30VZza8G_*xp&U&`_;-M4I3DOgOzuS^`|!+^Q|a5F2Ya`{!Hd)
zpeglSKM9ij-0(^E{m9YWAMP2F8@wxAl<mIIH#{>r7Oy<O3L@K`sd`81-1xFy|0*Xp
z$*gV*v+m8_i`})HOaxQ`K^l`}DdEX|NtmT$;qK=f2-4o3Zj)}7i(zXumP>DGw58gS
zOK+uIU-%R#<egu**`n-;GLHu4A*&&q(nf^8Za+@IPb{U)IF9A&5WACn#$q26!FQvT
zy*wUjExecho`FxN&2P8E+LTLpxrxpD(M-FU_@w5`YTcAG8ixoHbsBiI(XYNdsb$^V
zJomd>OFNhDBjLd`XtHCiqJ^TfUE$sxfE!QUUkQ(rm<a{H&i_iY>`J`EQS?R;T1(;z
ze0czkIcHpcxPoiAO^Y?2lwjb}9jfZb5gp~qhcN?h9UL;vls>1I;k3=@-83qjsvvdA
zl-3G)>q?*J16k8x=Ej~1o=KiGOGNw6*IyGQ-R$z|RuwwWtj*;tbrKyvXSPdB*uON7
z&<0;)wYg$)_Uml0oPpyPLSh;{TYF3|J7${T)77Cyy0pJTK!K+lOf<CwGbUfY$7I%q
zvgjF_t^ko*@ng2y<jReo?=_`TdSk>1h<V{rYzK)J-f0WCp<+QYD2;uWX2%80p%4k(
zI?flp`SHI^%#Lvk1u&>TdsAchlH@zGvCQHt^S`2=$lma!Ty5%Ef&GXo<#E3h_ez;M
zSa>0FDIC}LN=e$$G`+t<(2X{^vh?O**kRb%E>6LHr3;3bc+>o*b)^@ah#l5bb>a4g
zCK63HKi5={rpgd|{UA{g*hgM^7=As=*GB!Crh+a@J{Ol(X>>DnZvM-k>~^(o&tqbg
zOtGrZyz5$jp^;1$rVsY{_TSxH56i*Gf<qtfA&tfKH8Un6-=`<70&EgP=n@o>`(D!Q
ze809k>H2LCTQ?Ycs5d3C9y<)NxjmT<qg9(^P+`?OCB<8-N-rM=O5z%lzk5|a|JgE`
zo=BO7r+N%ceG{7HF}%IyzHi(6GbLQ0*zFxgNoaXy0><K)Y0>*=`gw<C0|#zt6G?~6
z6MYc1K4Eh8{y=x=1@75MCM$6V&+A#M3C8*XSRXTmgV|YdN0BGm#vS7;BRC~fn#H1L
zY3s6L^_P&{n+$4p-ltoI<J%!PURX2ClXuQGI-Dd7pq?+XE&m2=W)Q}ph;NwTC}4?X
zZ>aB{RfN?xpC%b(IY;t9TVk7NH~sqzs5kwAMT%n!{~n|X{>?59zrRmiN0ixmxWyeY
zKc(dS>qbnB&pS`&j<h{){5Yz2ngx})IrCZsIb8Lgp=%h<VvAfrt)2|vpnIcmm+$FC
zE|n9E_Z@#Abz`8*eZ1%H#(0?@Cr-Y|{-DH+21_zB7H2R&@jF-ZMfPUOg+OZHRbi4H
zSLF-5H$*b45>-@%Sf2X@-%#}*$Y0sEXD=FgSu^7-tRDN5vYDvHIA=L#IwjK>mJyQY
zjyYgiP7hy|e*vu~UL7HW$`!7PJbv0^eF>4eo|>q;s*Z+nIyMrN^Ej+n?mq4~<8$UK
z-eW%SV*%$KXGWEetPBp$ox9xv>GeZhlrWAh+k1y>5v0M4Gd?smWRSOi4vumM>57yg
z^gLW#j+gFMa`fpwN9tkR(ldX!V4smeD{2<;eG9n0ffuDHJX=M4<pDXsq#iIKA0WYh
z#LLM*yqxn#y!@lh|LOKkt9C%$jHzXg<A#56P_+C1lh=S@w;V}#-axSR@E`TU4PNL#
z#zY`4W(1rS>!1f<gZ`0s1|i)DMnym>#@oor<|!c4dVTJzP1yjGE?V}rINci~)U6ec
zMeSbx0GYP>5Ev9TXM*AFrJi?t^sraAe-8*S06v`%Zfm@5pFY&i1QTe1-996;ifulU
zLRBu-@62(%PHpw9df-2b0s(BI0}s<oyeyJ%ew84iy6D}`q6dp!JLPE53SH9PlKSZJ
z>6%;d9H~nNk|r5%C;MykecaH!MB(g2{QVVGy@BG!sSHy~TP621R|E6uVaQ9%ee?zL
zC*2@t3md0q-)i2B<qWjjolt@EIA-V9CV#0P5-sZNjAy$SpbQ@UWSL|gQXZ>hm7YNL
z+&8K`4x6&_|D=8n|J~|miiH8i41S#i{Y@jxt*p$~h0V8CS>{QJ$kd%)FSJ$lz{+gW
z{BdevMgE^+<#Gv*)*SB;-8yP+?UtJd&z5k#wn_9?iwgz+;L@@{el1WGupe@=ReT%@
z-ns8E;=`!Y;(Js0BO%m5w4OdMTTK7@4ft0L=M_tShaX#Xx8V#9dQ8c?rHn-P5!LZ*
z8F@|dMPC7~T%^g~@yfRSO^mjO>Ot-~{8t_UUdg}2YQ<8-C6$J6X4c$;G+%n1q@as0
z{!yPFK4kmG$jo_IK#`t>JMNV2clJ!klaY;wD+_&>1MjICayeSH+wpEaE6m85SU65l
zKK4Sw7`E>1@ocd4X%T=5&!zuRjqX6&mF<u`2fEDLhYwW{^=g_V>m8&qQm(Fkd;yc>
zVHq4QP^j}fJzM}t_WVnO;xwk3%MC4+m^Y=^`?hsued$_wP)6UEIdD)%g%{39?U`J*
zA-{lp``9*;pby7$kU?Emq;AA-+YS2RLzBbnj`;kBK4CH_l%EXJYa+&xL2J4HG%FYp
z$N<g*n-%=rZu;%|zuZf)K?nUW-OBm5#{#w+ph*I|c=@nVhdm+t_*bp>D$1`fUbtjZ
zWzA6;X$uZDPY-WjeK6IMUi;EwqL)I3IqkN~5HG6;3&n!fW+oZ5DoqB(%pApmf1mgk
zu~t>({hYx{`lT3=K{UFg4ER1k^f*xC{ErDVUr!x4OQ`}{6NU!UlR+&a8MKV$M;XlG
z8{=ijr;iVef3X;ASFV3IcbWq1kcRq4N648|MTJu{Z_T?8?`3PJsQs$ho9b1!*?cr8
z+iK+yt9t?BD%0jebcJi-CgesNCp;^98%y+ruNsw<R1G=tmY0P-3cggqbP7~psAu}@
z(NxR7;UrJ|Z@8Ah>RX_ME_G3c=94{${k2ml+Nx)Y4P=nkLKE6UnGCvR58ogFOm+U&
zhc|;90#(noiUq30I=g|FpFf(VgwiSSQ%wxxQwf&$;r;AZha^Z#CGqB#xbD{Z^h##s
zE6G5rF`uD1?x<|+5E{BIWWpaax+wgbGjrgE`@`Y0u0jj1Ld$;+nrN6#x~-ZC^R~+U
zgz@wjIb*(xUEg4V(?(qggl7xGs)2ONqQuabzsEPMtZiG9%6vPunR<D)PZR_=WA#y=
z{4KWF#&DfDKd&|vT%r2c1w{xmgvTL`T9(gJMz%|p=_k>)B+Bb<fT&M8^}@SOHm}AT
z&xNiNET8}V(d!csW-|C<GN|Adj+A$|1Pj@$odxo*5>0zVc&IPKo4mKSY8AuhdCyiy
z%G`FVQo`>@I~)jqo!RDFf#BCGUR{3wAXa0sT`yGPllFl?dW{ZGZn5aY^3bg6xXW+V
zOs8H@u4=n9-XuiZq8I(-ub4O7@vxlXv)W*q84KitBCtxAhVlEvDV<-7&E470BXF>g
z{ZZVqmTv>o&|P}LRh;^l)l^o0NKQ=rwx%D?uM@<ky@9X9GK&$^w~w!6$_9D$#(Hi-
zKA)&>4VNv>3JabwD3#H24A8v|x#&^qUHXNxzW^}xM%N%0@sbahRw|?9*Pd7{CGAAn
zEf$Qal)#O1#&$&@bD|%`PYz#u=Hy1yxDyVEJ`ye;^jFVvELk6NPD|x7<h*f^HxKQV
z&AXIz*C*bD&pXQ?&izql!0Ez;(1=MD!C4H6&3e^AxWiv~3%1%jh_ae;p;mUySklcU
zT{<{&9Q}2jr>P=panLa7;;DIeSt=;sN;kvz**q=7>D&*S;xOl2qE&>>i0ImnSl*95
zDVL|cIVwNd=2ZA9FFP(Gnc<y71#r~-%)!MX0Rsak@uwm(!%iAFD}v=az?8FF5l@4O
z+ThLOG%N7x2xlRLr0r*l0&|14fkg}*wj=hQinb)S#}M491TyFZH5qhHohaG~U#7oK
zqGBXnt^bJ7lEG!H_OF4Bvc`^O`~T&(hys-_0mcc|qj0pR${#wj$phb#fVZrLkzN2Q
zGYfQGU>v)uaTy3Lr6PuAyqP7!1Te}d#v=-#Z=-3B40?l99d!PdmpNf|npomSbN9=q
zUq8hoNs>F~y^)y;03nw>qsbtc3w-&+mo|e)X1j$ygiH%2z7<1I;(+?8)gG#dy+Bqy
z11Y88yWuU^<E7y<TVzn%P@^QgBPtdE*L<Yg_3uB8=w+N~*>Jn3cv|O7MIIpIe=;id
z4@N<LCqZ)lr>|Z|mLuNIQ|h2dw4)HPp}*4vB)mh%|0LpT5U>&|)@4PV`+a~JSIBC4
z9d{YfzEBE2pu9^41yKStX8beLVcH#8oW6R%%^C9t*L?eae+P(vV!Dqs_j};ZBWYtw
z1$Rq+rEm~Z!LKW@0g~<=A$?O};-|i`RNeD~`pRJHY0(KvN<)n?@a0NmK(W^5{kZ7X
zH#zKX<*Go|<=j8jsJCa{rmmL5_p(TLVY(9y)^oN8Mc|_qcnm6b7kQVFDB(M1h2{Y+
zv(CgpUN-U`o+`N-{d_EVXEB0*y^|VGxdUVYQzf^*i)%VdxP4u?@+KsMq0N<X$x7YZ
z94Ju2z?Dt+s6E=kA)y^~5XcZ~>zmM2u~nbyZqEd<)u#ab?RGf{z~8f$7VS2UBH!1U
z1>V(_tWoo!dP$c?ZMII;c;w!VUaacOA>4nSvE4D3gqw+IymTm<dOqSA8PrgFG(V=u
zOC3ar-lv2?`ca<j$qC|$oLusvo<P*;!PRV~O5h;fN#-Rrj5fM&{5gAjJgafBqQT3Q
zG|@<7e+2RpHdllu)M5w?E{7{nl1a!Iyj*==@xX)o#ul@;W9!iLr;CX7Sp%YuZy;q%
zK&bzgi$axnm%{p>wlJHQb<epj$$0Jr@kKvgIuUNK@4I&%#{;cPikgb{0_k;q_XM}T
z4OVN!CHJZ7#W)Vsb8MDWoX%)MRkhQCx}G)(-@scFA<BK#NQ0qrCy2&N^_=n6XD_Vh
zZ=E?v$=ND)_z=ftlh<RwcA@Tyr~h&ac$CkwD|3~uF@3y~WMsDZZMBD_RAd`Ms{IDt
zM-9sy81RM5-p_npoRj<Tougz#K%}uOUcE=rZUwf0(S60PQ^wKrAmX9dc!q^q$59q3
z1N_!|v><cZF6n)|*-JIS4B`h*psYa#jn)c|Mjq+p8_gLwb>FT<Qh5(9wV<$^S$|YJ
z+mBk0@OyYJQgyL$<Vd%W*7w2Z2FA9-@q0I66CEy2m%HflFLLRqP+BPvBJMWDwjE?-
zy`AK>>{dB#5-gqiEN<MNcT0tD<MULbUQo<%Y(L(HWD6t&_yUAOrEhDSEhS}c4mqHd
z9+5hS;mcqzGANLPDDeA4c;%-b&CN9-Qsp6gfTtxQA*ZCa;y&tpSxe@uM06bWPCkBZ
z<|2@;JUx<d6bR@j_M0zMTj<kPLsYFKm&T6d1J-M2wOtoP&@oWTE7tlQxZFCF-=@E9
z`wrs34SsY+C`Z(!YAio?J|e+7>i3oZv&RsQ#X6U?<HtS!cw!gC+F{e-<_y|Og`h7L
z(c-J6Q5aPjeWLJ&@`SKCSj()t$X4%)HTzhY5#I<xlF;tx;$fQ=VRz-j8$Ld@(2}n>
zr10-63a<=`t0{&WDX0WjglB~VT`Sg$*Vo>vlY;i(d+4SX#BbY;$sJ!lM=_p20uPjf
zvKiaA2)+<}nrEB-QXUdMN17wmHtpoT^(@j`7P%ky+}<oC*XB!|kec$@5^7w&?RwII
zn;PXIa|fvbFv|U^)@B7cPISVf?nO3!sQ?mv>;S<r)&VA)p2PzGZNiFMR}8(d%NjO1
zWBn0Zy5<dSO;*}v<Q&tKO#bc?bk!7N174lvjE4QvpdO6>l4p=S^=ZVRwzMG_h#bBH
zU;ijVGKvt!Nd@X;kgwHz#r#phsFD;se}D{{PS_XmfjHp4kU_2LMWG~S8kj1-16Dyd
z?LxhLy5qZS-kM5{oUbc97pS)=cewExG1~mY69#(rN;&+npv{kM@bQVE6)5BD>plqn
z^=?R8;Ad!RN(G;O7u7&7ZRuT(Q^s6|QOfC=ESUcMW*t%f;qeUC2(-3`f;#%p5&tzh
z;b}f#$Ee^|X{;4610X4BoaFiNKFqS!+E#L;_2nx*(KSDin1k;QB!YB#`&#;d$jn~C
zg?NAN*Nl`~yttgxvR!;e$1sfBrg(K5J2CYmO-kk7z7hX=E*iSsZku!u6OPx{Gghx)
zNiPgtLOSTgje38)rNq6N{f4Eda`jhc$^&&Cv?p?waZ%g#eFo6Va5g5X_FO{%+pP0G
zvjpN`&uo9FA%Jz(4MDkbXSdR9soh_Ac>WtvU`ID1X}ocZ)7Mpcy)bqWg!h~$eK>M_
zA?at@AeT}R;N5Z6eyXEC1#&6K&~Fqs*TWK(bbmfrd9<!6l*DG~XySBx^~P@H9VdM;
zZk>#6>^_usqA`fzl`WbuTgN*2hF`Z_7Jt3-=mvzQk4gH1{csPfUdws&vRuG-{7`t8
z4#b4*t`H^#(Ui;mFb!+)v+`3KCJZKU=0INjiQ3hB9yu3f>eAErPbDcCf3qv<yRed>
zvE`Xz7g2dr(48`SbU$q2Qy^>Dbc0<_;#I^mG5zp>p7YW%D|`Jg^UCoD?=-@Ga*~X2
zjfnx=S=o~?6;iQxyy^i{(tb#VUrtNJj@N8;x^;X-9Ga*E<Qe-*2v8{@Y0XdGV}AMS
zPC!lS%o4ZP)<=?R!S#bfz+IyvQDy#5fW*H;52>+(^a4L8xr}b49BF~mQ#)(~GLS)?
zGtx&sO{AA`&7Q@3vm3;>J8;xTGH6*7YEF1M*t9v5_N!b^)yFmx@I!yry0~A3GpgJI
zi^AX?M}0>g&P(?V_fi3H;s&4+^Zj8~Y!Sj&o(JODm^{!lf5sYsI>5o@%Z-ozr(HES
z0~k2HZvSG@v#?G1$Nm4l4)E*qAF;|6BtO#RcYVUIJS2l&A*^VLe5@Pn+z5uc&B`9#
zYP4-Rh%;bxm19#za+Xwq(+z^ms}Dl3KaIV!2erM#ze&Y7*6jS6${b}YGqcF<N^^};
z>|h09VIQ~rT2oYi$}QCT$37B{WQbJ42C9HxAjKpbWb@j^eT`T!nO-wA3aUqm#g&Qj
znCZjy$4BGpy5C*!?S8fn`;TO~*)(|{#qgdorhcc+gBnO-M#Z)Ta#c27VE!^LhCsWZ
zh=DJmSFfJ;@5yVA%(4AZn*^<Tw=!yA`BO&Y;qCQ~FPx~}iRmJ#n!+iEb4%_U)uL_{
zz9)&NPWoE4Z=Bti>R*oE*y(*^+p$NnuZ~fJQ($45W)Jhm-NY>bpx{;QQCx;bg+b6f
zTVe`bwS#@kJ<+XTv{hT=5k;}VCl}O2WAG*;aGY~<_@-8MZR%cGjO<T%*yaT=5Ok#S
zxlbiMa&W!f<LL_KkXt5$G~v5i+a<8Pt+EXO9PUm6CKD;l0!ZBnZZ?93JgT3Y{eA0Z
z_n_X$HCo1IZGXV9HNM!Ke`59Od`T2CCyqEg{KylQ?cJM@w?kMK`0UOC)g0xnz%wMD
z4$-c7O?Mh&M7ey^>bfs#*qHfD`Jp}aC5$n#-34>NDKi!Q2*?(T_W{}IKia?*<T3NN
zA?(zYM>hF4iDPhO3u%Y-#_L*qTS-7lB;GSOXUF=;G4vNK3mn8f!iYxRS`$VE(rW1>
z=BtiBQ3Hnq1W3+XhWaiwYjh4(n956ZW^5XeBrl}C=wl;Z^#v-?Fqiq1|C?0Dk2j2~
zzYb9Oi%Y*JUXM}e@!&S!DmyYpkZ?_1j$PP)ay^Q^CUA7dXbVvKr1m}F{|evcT><0Q
zg_oY;ak?+apug)&Q>bs^Tp)|Rqnx4KXtZ0-PsXVqp_(02iilxOa7*K};cNUuk{l5n
zS(B1=?;m2L$RHKe7BW}3Tj_?k8$Cnavt$?gAJj+NGee~P!Y_CcQE1tX7Q=-E;qesH
z>AIQF6h3WU<C?PCcUOwqp4{q4ucZU*1P|$UwUF7bPliMHa1P2k3WZI@4ug(KBhzW3
zZVI6<AT13nfgqaCc0U9tK84=Dd+r4Yt9^y_vA&j2hxKM(Ynb_#(9e5`6(w!R=vK%k
za#5TBt;5u8P<ea!OQY-jjPHv+K3ZEkDw_nvKGa=uaWqw-*qacZGU!~gVD*RG|4q_a
zS5rBZb`fNdQ`4~?SXRS>xTF3M`~juY7dNG1PIpT6Sjl@K(}_Sn>arRTl)<p3m`2uB
zo3{kLS@x{Np$f+ysS7vmZIM8jyuIQj%(qDQ4VH*u3l;yMQtB-v{lNp0WGnk}j;LL>
z`(UcVIY4gH>M8Q*b(@pi6MNb(gp%^M$siuaIV%NJx<CJxkbUi^B-NqNS6fxLHNP_B
zI*6wq1l;1nUc1Mc=F#85MlE3Jt_bwYBW1S##35RX{vH^^O;lJ`+y&a2=BO#Zbx1po
zGPTnyJAG1<^+JtA^jwPc@T<Hz5iK-_0N?hzs1M3j2j>VV$R~D~F5i4g<{%TS+$cu9
z>cVzA&o9{AW_;TOLE>KPsYTm&0n|NYP$}xoq<N2z3u`@%nW@EPfpyKV$Sj<bti)UH
z!EXvqRd1|2H-b=G3MeTdV@=Kv<7PsNJ;Qpc&r|G|;1`?b%}U82WC;-5D|+|(Nq=+R
zKVR5{U4t((!o*=w9J7iR{G0uMaZDC$fAL%%O|N=^j3NC2_avYW@!rjUt1?n3FWY^_
zNl<JrED_;9f%a8nlE+D1A2JBM2f>dtB`d>f$M!NxDfb*#rZ`Bq;vx7AFezAgk@qh<
zV%bV%T&8HtfeK@a_kU7Jp;&0*fQ$e(a^o&BzCPujqEA#-7>Ql+>GjQbfS~xF0R%<q
zSWqyHo*Pzo2#lmV0YDJfZW~U3=A}rZ)m04fmU8sw+SR2smi<3MF9i6FbPI>dbGv$a
zDLoo-@4^KbFX`4^h^H3NxmoSWI|j52<he^?;pd5>sI%=w<9AHamI;^CugFWIJC)iz
zS?3dbec$H`wu_Ht=otnFsN@yTpuNH%l?r#RXWyGNdAQFhk=g=b(47^2TNP}cH%RL}
zVVe0M_qCWw(gC=c#BD`SaGma<?Bo5O9JVEk-G8nWT-Ii|@HT#}j};mZ;38i@+7z}C
zf`oAt0CX#74zKu_APouQd*$#$CqO!&apA`}_k^PVpDg%8S9GF}b;U~V@4EBn{2#i*
z7NsDgpp71Pnxp)66D)NC-Y6e%x|67kOy!nRx0}~5&MY|Yht9xS8KB~ccQ=K5`H~i6
z&#&D4m}}@d^D79uDv!ql2FJ%rc&vlgJZ`%oaUM6T^-h^5<el=0HW0~b;1SgRhOgVX
z5U(vV!=;L5Hi2h!?mxsSZov|rJx<OGO9H*W9E@=TA(Vvhedi+6vSCr&(u|FVVx8Ab
z4FgD=n=akQT2G)Ob2u5Z7NDY;v_GKWg3&-xn%4481(7`TciNJEd=3@Gn|IyE8{7nu
zPL!IMdWo3`dMVbm1wsZD<T(m-M2o-fJE3_h1Nu~nKD&~bK%T9W8*e0~8=9V*ye;|G
z<SB^*&rO$Bvv?GTyBkVQB^!R($|_zHR}-L=Y(ihBvGgu5INQQ5Z_+8=7j@Q`(O4-J
zp*5<n2YoUa6J93=e@VJ1T^s8N6+Dc1WK4%>;CI7;NVXFVG5Pir0gZ7F>61S_lDTA=
zn=x2~O4NVmS~EA2yQ+Eo4*+rAA0%;jXN3(JWCb9&TfSRKyUvj_+ajiL)EIy}x$B=a
za7usmt=2_<{$;t*JhRWS2q-cTR`thJi;heaxd6=B=zOqq9DQQp^hr<>2TrjP5SD9O
zf0`yBObY2A05p_xp{EZ>O9MsF;v(WIP09`lvJS@<z~zD)JW4jyA5*WRhH9mWLD%5e
zX~+>3^t<};j_d!i<LdRt&*y5{?9#*M6gJcU=b{Z|&p+ZWGROugz{|P;Q{1%ai-_-X
zDozhsTj<(h`Ly1VGgv*hX{8UCqAcXmp~J5XW2Rv3lql}{OH?0+caBrT@NGW(<J9m{
z&TL}_8KivI>Tq{tg~T-kR^2>`PrVkwJNfNwX(Xk=>%5Cuk8T=0l*u}8KcLFm`TTYF
zMGc;_0gfp(n{2Pvv+ZpLo%Tw)CTKzkCr-K>x@k*QTI)MLd2A138^CGOB?YEZF*ChI
zy8@i{-Z8`JsW`3ESK@(cu0GQO<Zn*t7@W1-gl){toU|a+6lzxt8v`AnGs&wuUQR$W
zmuC&-Z^W$sLCmVJiSOo1W@m%mg5{<Y0Q8RqiZZBLR0=rw0C99u1imo|&Gq)X7r=3=
zbZ9>Mv7dMFdA%1ddH^|@(J4ZO{4D9cLO>>*;oOgUo6SZpqiMk7k2`y6+P>W4%$YpQ
z!6{8Sc6rc??P%3XO@x+L?l7XGT~c#$_bwuHR^v0WOdWQ=(cc~wevR1dtmzo)KMY^a
zdF?W=8kKL7r=p&(^yn)-BWc&tV0Jyu{q73NV7z2GXYVyc32wGn9LRumIk)RrAc(3o
zeMd5Z{HTrdR;rY@ev^GLwnGxY)LkVQV4go0DVqGLQy~F9O;i^=p<;6yZ~umLyI@kK
zCU82{Evze}$U{kJlRFEoaj80aaB*5UF7u5Jud~Wp0Gwta|2Posi3I+9nbDv7!1S(w
zLat0FGR^;-SEeQ5+0W(ZLa9}$a;rAPPwBk9jnPK0AHr@eq^otC#kp0+ZS}gLNzC5S
z@H8$2t`KYBX7()7g(X>Ic~>dwxb?IlyCz4~&srenqB_tz7c9@T0>$>)=j6?o|JixU
z?eTlq_7>9^w1o<_-FlL6vZ$f$xrD))yK*r~D_o5gt?-tF;ihFlM<9_jQD<lL^5K&{
z6-KkO!P=`nU$B5KZtQac1;amevH198_}@;hy-ww?07OYOSMcrg;=H#X(S$2s<k>qg
zGAg1z6)Rfd>l&iD>V*TGGxvkPySe+m>;j4cfR4@pI$90rC=$?7Tn{3|H?pjUXZY7G
zuWQutKOZjw`Ve|O58khjA{|xuYSoL>U<<Y7pZU}U3|Z+cH*He^J|5{!2H}`shJm!J
z5F888VBh2ftFWdh|58=;gl<4BS7Rdxv0_08k4`RheUz`}x!`r}kHqSK25<ikbN{Qq
ztQ${14_}+F1pcG&>i9njJmH%Vc7hW8%&NELpvgVWV1r@!mw=8{S$s$ThkW+NSo@-t
z!EviQe6RF^<wM3o#t>$saZu`cC$+L{A|g?stGJ-eiqRwa)WUbqZP<kEd=kqw7t&yq
z@{uAo(L3|DvBs2%$4L#Ons{W~kfPlWap=8e1rE$%Dvg8Rx0R<^ynQdhL?8GB7^&;K
z*Puk2F)R&V|6vq=2I?xehx||}y=T5%T=g|YGPMQOsQNWVTk6RX2BaGguWuUmIzTD<
zTJ$77bH&&RirTIFO|fz{v_U<$`krC=^aUQ<$kNekTJR^a{1!?7w{M5C;O_^f$A^P-
nMc}nfaoj-PhzDHAOrY8V1bP6X&ibu4<iGmP{{K1;OdkIq?`#$>

literal 0
HcmV?d00001

diff --git a/plugins/mqttpush/__init__.py b/plugins/mqttpush/__init__.py
new file mode 100755
index 0000000..28d1d8a
--- /dev/null
+++ b/plugins/mqttpush/__init__.py
@@ -0,0 +1,291 @@
+import json
+import paho.mqtt.client as mqtt
+
+from typing import Any, List, Dict, Tuple
+
+from app.core.event import eventmanager, Event
+from app.log import logger
+from app.plugins import _PluginBase
+from app.schemas.types import EventType, NotificationType
+
+class MqttClient:
+
+    def __init__(self, broker: str, port: int, topic: str, username: str = None, password: str = None):
+        self._broker = broker
+        self._port = port
+        self._topic = topic
+        self._username = username
+        self._password = password
+        self._client = mqtt.Client()
+        if username and password:
+            self._client.username_pw_set(username, password)
+        self._client.connect(broker, port, 60)
+
+    def send(self, message: str, qos: int = 0, retain: bool = False):
+        result = self._client.publish(self._topic, message, qos, retain)
+        return result
+
+class MqttMsg(_PluginBase):
+    # 插件名称
+    plugin_name = "MQTT 消息通知"
+    # 插件描述
+    plugin_desc = "支持使用 MQTT 发送消息通知。"
+    # 插件图标
+    plugin_icon = "Mqtt_A.png"
+    # 插件版本
+    plugin_version = "1.0"
+    # 插件作者
+    plugin_author = "lethargicScribe"
+    # 作者主页
+    author_url = "https://github.com/lethargicScribe"
+    # 插件配置项ID前缀
+    plugin_config_prefix = "mqttmsg_"
+    # 加载顺序
+    plugin_order = 27
+    # 可使用的用户级别
+    auth_level = 1
+
+    # 私有属性
+    _enabled = False
+    _broker = None
+    _port = None
+    _topic = None
+    _username = None
+    _password = None
+    _msgtypes = []
+
+    def init_plugin(self, config: dict = None):
+        if config:
+            self._enabled = config.get("enabled")
+            self._msgtypes = config.get("msgtypes") or []
+            self._broker = config.get("broker")
+            self._port = config.get("port")
+            self._topic = config.get("topic")
+            self._username = config.get("username")
+            self._password = config.get("password")
+
+    def get_state(self) -> bool:
+        return self._enabled and (True if self._broker and self._port and self._topic else False)
+
+    @staticmethod
+    def get_command() -> List[Dict[str, Any]]:
+        pass
+
+    def get_api(self) -> List[Dict[str, Any]]:
+        pass
+
+    def get_form(self) -> Tuple[List[dict], Dict[str, Any]]:
+        """
+        拼装插件配置页面，需要返回两块数据：1、页面配置；2、数据结构
+        """
+        MsgTypeOptions = []
+        for item in NotificationType:
+            MsgTypeOptions.append({
+                "title": item.value,
+                "value": item.name
+            })
+        return [
+            {
+                'component': 'VForm',
+                'content': [
+                    {
+                        'component': 'VRow',
+                        'content': [
+                            {
+                                'component': 'VCol',
+                                'props': {
+                                    'cols': 12,
+                                    'md': 6
+                                },
+                                'content': [
+                                    {
+                                        'component': 'VSwitch',
+                                        'props': {
+                                            'model': 'enabled',
+                                            'label': '启用插件',
+                                        }
+                                    }
+                                ]
+                            }
+                        ]
+                    },
+                    {
+                        'component': 'VRow',
+                        'content': [
+                            {
+                                'component': 'VCol',
+                                'props': {
+                                    'cols': 12,
+                                    'md': 6
+                                },
+                                'content': [
+                                    {
+                                        'component': 'VTextField',
+                                        'props': {
+                                            'model': 'broker',
+                                            'label': 'MQTT Broker',
+                                            'placeholder': 'broker.example.com',
+                                        }
+                                    }
+                                ]
+                            },
+                            {
+                                'component': 'VCol',
+                                'props': {
+                                    'cols': 12,
+                                    'md': 6
+                                },
+                                'content': [
+                                    {
+                                        'component': 'VTextField',
+                                        'props': {
+                                            'model': 'port',
+                                            'label': '端口',
+                                            'placeholder': '1883',
+                                        }
+                                    }
+                                ]
+                            },
+                            {
+                                'component': 'VCol',
+                                'props': {
+                                    'cols': 12,
+                                    'md': 6
+                                },
+                                'content': [
+                                    {
+                                        'component': 'VTextField',
+                                        'props': {
+                                            'model': 'topic',
+                                            'label': '主题',
+                                            'placeholder': 'example/topic',
+                                        }
+                                    }
+                                ]
+                            },
+                            {
+                                'component': 'VCol',
+                                'props': {
+                                    'cols': 12,
+                                    'md': 6
+                                },
+                                'content': [
+                                    {
+                                        'component': 'VTextField',
+                                        'props': {
+                                            'model': 'username',
+                                            'label': '用户名',
+                                            'placeholder': 'mqttuser',
+                                        }
+                                    }
+                                ]
+                            },
+                            {
+                                'component': 'VCol',
+                                'props': {
+                                    'cols': 12,
+                                    'md': 6
+                                },
+                                'content': [
+                                    {
+                                        'component': 'VTextField',
+                                        'props': {
+                                            'model': 'password',
+                                            'label': '密码',
+                                            'placeholder': 'mqttpassword',
+                                        }
+                                    }
+                                ]
+                            }
+                        ]
+                    },
+                    {
+                        'component': 'VRow',
+                        'content': [
+                            {
+                                'component': 'VCol',
+                                'props': {
+                                    'cols': 12
+                                },
+                                'content': [
+                                    {
+                                        'component': 'VSelect',
+                                        'props': {
+                                            'multiple': True,
+                                            'chips': True,
+                                            'model': 'msgtypes',
+                                            'label': '消息类型',
+                                            'items': MsgTypeOptions
+                                        }
+                                    }
+                                ]
+                            }
+                        ]
+                    },
+                ]
+            }
+        ], {
+            "enabled": False,
+            'msgtypes': [],
+            'broker': 'broker.example.com',
+            'port': 1883,
+            'topic': 'example/topic',
+            'username': '',
+            'password': '',
+        }
+
+    def get_page(self) -> List[dict]:
+        pass
+
+    @eventmanager.register(EventType.NoticeMessage)
+    def send(self, event: Event):
+        """
+        消息发送事件
+        """
+        if not self.get_state():
+            return
+
+        if not event.event_data:
+            return
+
+        msg_body = event.event_data
+        # 渠道
+        channel = msg_body.get("channel")
+        if channel:
+            return
+        # 类型
+        msg_type: NotificationType = msg_body.get("type")
+        # 标题
+        title = msg_body.get("title")
+        # 文本
+        text = msg_body.get("text")
+
+        if not title and not text:
+            logger.warn("标题和内容不能同时为空")
+            return
+
+        if (msg_type and self._msgtypes
+                and msg_type.name not in self._msgtypes):
+            logger.info(f"消息类型 {msg_type.value} 未开启消息发送")
+            return
+
+        try:
+            if not self._broker or not self._port or not self._topic:
+                return False, "参数未配置"
+            mqtt_client = MqttClient(
+                broker=self._broker,
+                port=self._port,
+                topic=self._topic,
+                username=self._username,
+                password=self._password
+            )
+            mqtt_client.send(message=text)
+
+        except Exception as msg_e:
+            logger.error(f"MQTT消息发送失败，错误信息：{str(msg_e)}")
+
+    def stop_service(self):
+        """
+        退出插件
+        """
+        pass