From 4d44da4ecfc9538b7a9a32d1280964ac62d3b0b7 Mon Sep 17 00:00:00 2001 From: root Date: Sat, 18 Apr 2026 14:21:12 +0200 Subject: [PATCH] 18.04 --- API/__pycache__/rok.cpython-313.pyc | Bin 6330 -> 6446 bytes API/__pycache__/rokky.cpython-313.pyc | Bin 6595 -> 6718 bytes API/rok.py | 11 ++- API/rokky.py | 72 ++++++++++-------- app/__pycache__/__init__.cpython-313.pyc | Bin 433 -> 433 bytes app/__pycache__/routes.cpython-313.pyc | Bin 6866 -> 6894 bytes app/routes.py | 11 ++- models/del_s.py | 9 +++ models/orders.py | 31 ++++---- services/__pycache__/__init__.cpython-313.pyc | Bin 122 -> 122 bytes services/__pycache__/red.cpython-313.pyc | Bin 1015 -> 2299 bytes services/__pycache__/tim.cpython-313.pyc | Bin 619 -> 900 bytes services/orders_rokky.py | 58 ++++++++++++++ services/red.py | 24 +++++- services/tim.py | 24 ++++-- 15 files changed, 175 insertions(+), 65 deletions(-) create mode 100644 models/del_s.py create mode 100644 services/orders_rokky.py diff --git a/API/__pycache__/rok.cpython-313.pyc b/API/__pycache__/rok.cpython-313.pyc index 735ec71cb721d8cbc243138a7e17e24eb2bbad13..7383ace409c8fb89c69c6a21833b1ed8e2009335 100644 GIT binary patch delta 2218 zcmbVNOKcNI7@paO?X|sLJ9b_su^ok&nD9zMfKWn-Adt3!B5zl;a$C!?okt7nXlx2a zMe(5rC`c(9A#p;vrAQT(nj4iWR0@Y4+8}X=Rvapos_LyGsOSFw*v^B}OGnyo{+-7^ zkN^Arxz~SpKws5$FM*;B|2DIDLvN=|H@5w;!wj2xlzc>)VFsdv1x*7mWCj77pf6PK zYl8nUAE)=}ZLUe9{)~pMuvml}N>UP42cMQQ)Wv_45^hJGWixh#Ka)<(wZph5eB~nm zRr1tmoxl9W<>k)fPfnkC^5N8DW4b#2Owq3N&hNas^V;qwN_52+o*%h7a_#l%v6V>M ztUP7!F7t}I*tM>tJk_?4Pl%ZP1k3^KdwFv=Y(m~0VP05l1 zWKc3?Q`sfiibX7Hs$i*nv8jtYvY%=^q(p-WlJV6Y63dm=q0x4^86JvPmE;_YfW-`e zJ8sqmm7~q(ri$6}%%vi0#eexcJIexSxo2~qo-O4HtQr2wZh%Csur}=WP8BQJ5-Sv0 znQe!LtvG5D04^=u&JR>4p6bn4-u!ZE*&C}K{mVr zTeKbZ0-LE69e2KDSBiE;?DUSzdT|);z@d|6ygArIZ3Ce~>4J?L%+9h>;e5VQW_XGF zmu|XmQo4ipX+v};&uKftyU@oVz`6szpf#%ppy>p^r`db=ft5$^je^G&ae5!{6>%cA z%oo%|(4<545JFUxv>T(a)mAf}h9d}}1R->pvL%ZUDk5-h{=IiU_3*#F-TJiUHZ{{b ztk{~R@uaU$*3wOU*_Q}r@Zh4Dx}~LCuyOl_#(?EPpN%a*^w%dC;Ol2!4-n(DKNj22 z5wyIUC&9oy{GN4WGo-?rwx3`0cMbX1om*-eDf3b>o8J9luQXKWY=XcobmJ|! zgxP~8_vqPieZv;QmcDrlMPd?LAJr%6BpH$8WRj*Lrm%h>Gsam7- zVPgyJ=2>H#OYpjvUx$Vs{*`f14zSnw??%^LjnxXU%4TEeKoANE&Qb`1THYdKC6+DZ zDmjNT$0KN+ohdl9SjM3>-Z!vDKYyMTbCqIE0_+TovfwK(0v)R4SzQ4>eleKhaW%B` zZE%`q;-iPghRK7D*jS1@I5@fsejcX0WBcTXgA&?96zzR7+QYHqee$DL<9JejlvKff zbsqT|7DayY{z&-$Ck~q6ekBf?WF6oy+`*F2_OFZ}vVZ`N-35TP zRKNr3+x(}nz86z#zOEQB2|=m}p?wamuM`@6S!j?9YeL&@%bSH}5s;fasMw0BSX9VO zHC-Z4mLpxhG1EN^QiQ~4G#KhihtPb-c7q5#g7+TF6DH#zV3eb&i8k*^c#nJpC@rVM zV&9v<^q%orWRnV{baP`3Dcy>u0<*pR4&Ll{H&&mg^py%Pv00a8AO{1kFvX|%-bbv2+6SPOt7gIFAz z7ps@?IcX4o0E~L>T}%GiM!x<41}?%^egv={_`5Crbb3)aFx7znl-0h6=1v)bV?AT`3`J0ue+G-65u$l-!(JiEeY8WhL#jQvSd5bdBinb8eWW@lR zEfX*fwx))y8P*9tOmEOR{tq1&Y{L7bEI%()sLX#C@;oN)*EhkA8F;)weq3ykA1K5~ z@MST#U&ON-LxCCBk3IvqOezgEAyHz{0l^h5*gQ%G1WUA}Ucr@YY73SOlFYB`dE@Ay zEnCWv=qk3tuOza3Ofduy=Y=dkB^{y)zaw?N>C5wM)?HvR*uGn3DVSIuz}M!dPB@d^ z>{-VbPqH}{MWs4F_3m74YMLcr<*5Mq`e11^>nEIr$r_t>n8&(7QADpvfF;8JGq>;$ zx2DCO?%}2i&6iPx} zlP8dkB4ndQ3B(Q*`D|qJfUz!wxNU3-Xu(&#cjllD27*Fxo$7+GR8KOm#@H5gOYs}AE(L3Yb@9Jqt+btM=CBxH!+f7v z$odkLkIVK3b_6V1_8dZjpEL8N2#EE9ZD74_jVg1d7MyzNvcuqH!Q)+lT38}K^Iy!Z z^y-S)bcQZw#z!Uw$jwx4qDXEIj`zaiR#Bhm6L0khDDR*s_lYPEt69 z7f;;Lb4z=mnPrPtNBAjuBziv_zcBjI=6Ev@z^&{MST58?@9RARt`QOtwKw?MrU9put(8ptx0AjgtdFO(dPA1v>3z=cQ*_#zaxPphmS79Req8ubekd=@UGQ?X;9 z{TR((13<&=P50BQ{CN8OBK~T+1vUiJAAy|omFXI^*;5Q#sxQ<$7Th3+Hn;{x<15h4 z(FxPYdJ(YW*GUyz5!1==XIB4jV9RINmV@RR@Q6WFyU8`e@Z37tLL+b2rccf}yV)C{ z!*=U^0`Nejl>R_+_lS0vgx`%(@9jy}wX XY5&9Q^ECSSEH!ECqs}Z%1n2w@-K}y% diff --git a/API/__pycache__/rokky.cpython-313.pyc b/API/__pycache__/rokky.cpython-313.pyc index 1b79bee91a6aa6351ce3a05e9da05998fff86745..47039a220289755619ba452f036f9b1f79c37541 100644 GIT binary patch delta 1606 zcmZuxZ)h837{51n*CcmM(5jZxdJ6X1QyYHMzv+ zl3}dSZP4i^L%R2a;0M3>Nd!Tw;2&0meGw77GKKN_Ni2$A1goeN6rcC5S)F)r&-=X3 zzx%z<^Sk%f(CTpD*FZoK@cI1k_xaD31Aq1gVgj_ML+PfNaGpR%I*9vNx*26>x&>v| zbcF6Ev!TuA{(-rC!LSCPG(TVK*U!@L!foVtI@lbhYHPa3$IIUP+$W^P{lvAIo*OM~ z^k>!IEe;5#bc%$9V`l}ylr=dm$rxicXmTn*KW>eSeEoK7{i`+Ji~D;E^Ih6^x3r>3 z^hBg}TJvf?&95n1!?0X;CWJ{{5L6){Xkx16f6DkZX}`y{Cxp}CdPG{;uAq5R5xN*T zxaZ5mVqBObN%g7CaJ?O6$Y%|!|GZT)83EwkWui4-rE8J(#cC9{_M7&5_Dy@$e&7Dc z{xq?6#s1K~x%O&OWm2hZm`rkVr9vsAGq3f0Azv|um^WK8O(R=j4cRJKC17ICz)hx% z89Gyq7mRGRViYrGjmZeXuTt=(QBi2 z=ib|D|Hbh;ffjl#da$uA_WHTyb9Q{_cH1!hDmt|%B*==b^nNYvyd(KuK7Q%=(&Qhb zg3|YmKe=gfEZ3t)`ovp(%8?Q8${Xa2M+QC=`nPyghAyr>Athwk!L_24>VRFSu}0m< zLakhx;T(lAG#yy^L0a%Um_!u@QB?VnZECNsU3NyX`cNY2bt1u!9wy~p%$Ffdm%SaN zi@xI>+2Irp)eC1#eWq%bGue5V#CUCm_?{srp%Hc9^xTxImASnmZxiM-%xp=|o4KUu zKnLC{h@eP%9Nf%ThLT>*RxFD%FOhK00C671#Ram|$2ii~h?iuc*(7J6K{n7i5vQ3!dg;iVKH}cozteMZr8N4e*y0z~Ewzn^Z6gM#eJ6k%USAe-glH#C8UU z?xaBuwVyb!Drbv*W9<_Dc`G)Z4YeaJta>!V z-ic*#j$Mr%@4HW^Q+tVR*C{t#&#tV|Q7|047Jmk_kJKJ^K5=LwBQvb}b(d?ky6qGc z+9ybo15+veL|%;>l?L_el!wSmq|yio*H-IQ7u5Cj^=eR1xmKyWuKYc@=! z!8{N^<$2tW5EaNUT4KZ9LobVV&=UeC1c-B#$HEQU1133gfAo2w&H-?>M%;ofTSg~^ zBI()GC(d3ye*4gkw$|6d1q$CQJ!(7qp0ols{3hewzjX_7e}q922X^yI_6c6bCYw}p zwla)d^*NkIk6%Q{)hw-~irlVlX+=TY1EZvkMY#_Xr6O_O8;eiup68-&Tw9 z0|{Yi8CJ*&Tc)Lt?Z@WPtb98Z z?~F|MhYFZ3fu?W=Jpxmkfk#2&A^(LMY;lzR)U&n7L*gQlO3-GYc&y};BHx4CWNnjF zkcf({%Iic*j1d4gPX$f@ delta 20 acmdnUypfsvGcPX}0}v>$*}ai_86yBVUvO#&&~p7*#Xej{y0g_ns39#B#L0q(Kazyp^2(fM)j@%LPx z`(yd9vbwLTiol=EwclD_+*Whs=Iyz2^-2_?hENk~foiOxg6i3FHD1v`^Xy?@Ly3uEsW?iI(LBxdF5v3E?&$cM+C#l4xa z_oG z6j!#>OLn{6Gq&hp(|(T@49{IKMOW@at2=-Q-*<=IlZwx0xux@$Y8)R3PXm#UkKCI7 zIiNp|79qp_ly0Ok?M6^nt7ADfJjeY!dq0pRnbGHg`w~fvE`@b5f&Ug%L=+KYR9T-Y zqB)H?jF>^pBIekh@){|#g=l`l`$DkQZQAcHz}|peJYdGyM_N7vDXf2#eXXT^O(pbSM8w$>EkETq)U~(# zgNCI#49cPx<@k*DnY#3A0>Ug8niF>%`k#1i5nqJpR*E^%y!SI)1|&EYEsEMsg1 z;mL_Y0PQyrGU77ASBKV{h*gAlbpOh%@fgKnHj)N-Y9;;wc$-K1Y-#daE>2IaiUrwm zsNDwCxIMAlqO{d@jJ^d{#~$zjf+cnr( z;B3JO4mZ4E57w{ux;DIwv6CF8>{Wz12F@XHxhp|$i()YYA76Sp-iKauxISnM`%R1M zYViDr?517{I6tYg?4Eu%nBgIFj%{R(9Z$sq77Lxde6a-l--fscVFb>t8^rjP3*Mo* z8nxk_*1Ang{-yC|&y9|wjsr2=iF4^D$6;!Bn~jduf;cAeLLAEav=@l)$2$&s9#(b8V<3aw=Hv=4kjyEFcD00QYC z1V#UuOn*8AA)%#=0Y;vVlAM|!NJ%&|ArQ`aAd*+IFZKFQGdulsucz}9|38&yZgk@d z&!%Yazk7dS-+!$8%D=3;FW2|P^Kd?#J;63DU&5 z5FzXj*QgQZsn~3V<0g5enP9M#yp|l`eaBO=nuThuSg~M;_p#Z2k@&MV{Lzh1E^liy z59Apz+CR#7UDV(HK#fQN56=KE0`D9&_C;UGW1@_4FjF(waqSqLW;e9`{bC(=wO+Qa zO~ENXKHUCH`;z+5kJ!xjd|S8Kq%zV@2S+Ho=bJOHpa=0?qI++`Bv%I6pS~FyXA}O# z$Oun!+;+3rY}t;~Sb_u(By@Jizu)61D^RUBA;}*22hI!E<9rk*5Gq3F*peK%Tx=E{ zwE<-d3e~cW1!tPjJEFR^S`Z^}iH9%pW_Q?lpshcY2X2)%53<^K^4LT6C@?~e&x2pn z^*B#~(}**OImB7SIYgS{x;lS)!Cq>;Y(fTO=MloV26(sd8UjxU<`J(Wl86fk^Zvp;Ncp(9QuYD?YNPZJnl-xE-qUTXYYoi^bGqje0BXG&WD-sCP%{C z^Y8)&#G=B;6m}0Gjw0~A!C?+Zy=pZ}i;cPkM=+M+NGShI2eTN(bjJmaRZ)i~e!b)M ztw4XH+$uE-trdO?7QDqX-($BTNqKQwkF)!cJ8lD~e4bs4nr`7@l6@QvA938X7tST$ zm=h=A_-zZ`u9hr2DelS^rRiu-qLm70XvE99(Z~?qJ76t1YN1ds)~rGSd>A{*VuLg5 zQ5;dA(c*sa@rcJEidWP?Z*yoApBVx4*V~QyYK?DZ**Xq29>e!)ALH!0D5a0d$!&77 zLp&Yg>k#cRncgAh4mt1xIlM#0e@t| diff --git a/app/routes.py b/app/routes.py index 904bc78..a10fbcc 100644 --- a/app/routes.py +++ b/app/routes.py @@ -4,11 +4,12 @@ import os import sqlite3 import json # from services.rokky import ones -from API.rok import create_order, get_order_content +from API.rok import create_order, get_order_content, get_orders from API.TG import send_telegram from services.orders import get_sku from services.gg import get_product, create_messagea from services.send_mai import send_html_flow +# from services.orders_rokky import rok_orders import logging @@ -21,7 +22,9 @@ IMAGE_FOLDER = os.path.join(BASE_DIR, 'images') @main.route("/") def index(): - return "Hello wstkeys!!123!" + print(get_orders()) + return "Hello wstkeys! Hello1" + @main.route("/images/") def get_image(filename): @@ -98,7 +101,7 @@ def new_order(): send_telegram(order_id) logging.warn(f"newOrder: {order_id}") - get_order_content(int(order_id)) + # get_order_content(int(order_id)) send_html_flow(order_id) @@ -134,7 +137,7 @@ def sku(): def product_update(): # получаем параметры sku = request.args.get("rokky") - ggsale = request.args.get("ggsale") + ggsale = request.args.get("ggsel") if not sku or not ggsale: return jsonify({"error": "Missing parameters"}), 400 diff --git a/models/del_s.py b/models/del_s.py new file mode 100644 index 0000000..33d2419 --- /dev/null +++ b/models/del_s.py @@ -0,0 +1,9 @@ +import sqlite3 + +conn = sqlite3.connect("./files/rokky.db") +cursor = conn.cursor() + +cursor.execute("DROP TABLE IF EXISTS orders") + +conn.commit() +conn.close() \ No newline at end of file diff --git a/models/orders.py b/models/orders.py index de0e91b..774c877 100644 --- a/models/orders.py +++ b/models/orders.py @@ -4,23 +4,22 @@ conn = sqlite3.connect("./files/rokky.db") cursor = conn.cursor() cursor.execute(""" -CREATE TABLE IF NOT EXISTS products ( +CREATE TABLE IF NOT EXISTS orders ( id INTEGER PRIMARY KEY AUTOINCREMENT, - sku INTEGER UNIQUE, - product_type TEXT, - product_id INTEGER, - name TEXT, - developer TEXT, - publisher TEXT, - cover TEXT, - release_date TEXT, - genres TEXT, - price TEXT, - price_gg TEXT, - price_sales TEXT, - price_salesgg TEXT, - gg TEXT, - insale TEXT + id_i INTEGER UNIQUE, + id_d INTEGER, + name_p TEXT, + im TEXT, + email TEXT, + chat_id TEXT, + currency TEXT, + amount TEXT, + date TEXT, + sku_rokky TEXT, + price_rokky TEXT, + orders_rokky TEXT, + key TEXT, + content TEXT ) """) diff --git a/services/__pycache__/__init__.cpython-313.pyc b/services/__pycache__/__init__.cpython-313.pyc index 463a4550ce034d0c98dde3c9ac871f41424cfad4..3ecf4c00a8bb1f6c53a5e41f81d520f921e699d5 100644 GIT binary patch delta 17 Xcmb=b;{MFb%f$c$df~Sxa_0j8C)fmn delta 17 Xcmb=b;{MFb%f$c$Pk-&6$ej-WF3|yu_KAu zbz|!kN)A2bPzt&A&_gbP{u90wddp&&g{evoIpr3tOKC58v(kQ8F+G%=GN89_-n@A` z^M1egR=s30j$r(8@9lO0BlMO{yb&2Fy$w)aAPs5UIwI^DS?5X-5-IV7SJ<3i$0dOX zC6S1wD2ci@ye^euBnG;00g<>Sf*jGJAQPGdGP%WNWAE52%Gn4V*PBloyUm(jZIPzF zSGP=>3YoU+hMDE*Io+s}gO*jTHT3FUqgAW#(2<(%Z=%V)mR_?A2;%PGXq+^6s!gIB z#H*DhrJlVxlKkaw0;`+(1GXCtLJNxpNeMi1#%hw$FrY+w*k{3Jpmb-H0<$Wiex6^qi zecMjoK1weg<7JY97oN?_pJ64;%McG3Z{4ABA;$Q;40-x2)FKth+ok%NX8~6Gd<$$| zoPgDUFkhyUSE23c)984mTgZxpov{xDODtjGNrH(a6QfM9yOS{xH0B|3olL--+01zm z42sDPo@NPeckq=iPCfg^&E{7xA32#tJG1Cy3U;P&lvzH;EB}$r-yzxybU9pY;oSKd z_3nJCE+Z92D|e{A=2;+jewG897bl#%85Cd;MYSn}8sYQs-=V-;hOXK`MYJ_|ZgQJw zg_qGLm&N6Fs$V@`)^4;wgF`5rj-vO1>VIJCf3s&OJ}S?8oLu%s-ZH{oNgz=pk<4ulzdW zNNHP2|NEW?+dsW&2>8QF5urmAFDm?DJW;&JA6^tdKf5SCYZwE|5#GbeS!m4dCSS)c*vKT!5(AQTHe`TKx9wIr!T4OP|#VjSWmY2ccHL z4o@e&W<1ybHdkRIc)9#!-Pr8|F7w>e4>t^H`7!)S*fs7D1)Lde%~=pYD~|gUrQV>$ fH)z#HtAC-ZCpgNjoJ?Tu&PhV#GQBYnZlm}BTOFev delta 321 zcmew@_??~aGcPX}0}!mY-HhBYqYsh9Zt&Rv^il&Zx;Yu_1193-bm} zwt}L}SgP27yH&H-IJ4^>Wzc=BJeAq}mmU0hKTUaj`Uz_`uA_$atH9|2~7+eFm3{ T3@)EoSQu?S^RY16fh`6AX1-0s diff --git a/services/__pycache__/tim.cpython-313.pyc b/services/__pycache__/tim.cpython-313.pyc index 2e9bae5d8d1d868b9e57fa9b0078c814a7138d78..9e7ddd73d744abf02ca4ae91f2144606b2f39aa6 100644 GIT binary patch literal 900 zcmZ`%&1%~~5T2D*mh8l}p>d$;#i8_|i%owL2$X<(aH$OmwJ155)+m;0tBGYZlH2B% zp85jKJ=fmy5Pg6eQ(U$^6ig|;8TU9u7sGN7GrXTO=*`LwHiJ_p>M#q*%20nEil z8Q)7=?Q?el4mhL<4T7XBu-4R2lU_%id%Z~;1{#eFW*R1%4GS&Kqg#O4o@N^hQOYLl z_EWce(!=36^qg+r_r|9_9@vywI1W3p8=bJMLJv~-Folo0qLMO`1D$`XC0{O}P1M28 zH3;D)v;^ZnYf}|)h@-VLYS&7TiU72-DOO0;cl144zNv@QR%GxV)G_w-8=32>uDFep zxn>qrH1(=)8G2xw2h0k>*vEJ7=|YTdYs?%3;W+jqmJj_8aYu?74E%*5jtQg-XjF~( zJ%X+uRe5q{bjAvj-$}?=;$$IZ^oB3z@T+)lTD*V${5Q?dXlX)ApM%S-s~2DUv-;7b zel)AMC-wHU{_2}JeElO~^)GW*H5uGZgCccX1|KhrVBGq2`0?;NEvH ZP6+t}wK)`i!rEV`O`*1;d9o=}{{bTp!+!t( delta 359 zcmZo+f6c=8nU|M~0SKnX7pz8Vk}}*0I`|8nY@^bn1O6& zDTX4Jbe4%3a>|;Fw>XMQ^WsYqi?fqKhQI(DkiiVZpL-^rwq*)to}9-hJ@GfsSspCu)+vRIR)2xQVN_QaHw z_^kY-B9_UTOs=8)KrxUl#STECf#HsT@?`0klZ}h*)BKjF<27{j_>*NA diff --git a/services/orders_rokky.py b/services/orders_rokky.py new file mode 100644 index 0000000..ae7634b --- /dev/null +++ b/services/orders_rokky.py @@ -0,0 +1,58 @@ +import sqlite3 +from API.rok import get_order_content +import requests +# from send_mai import send_html_flow + + +conn = sqlite3.connect("./files/rokky.db") +cursor = conn.cursor() + + +def rok_orders(): + conn = sqlite3.connect("./files/rokky.db") + cursor = conn.cursor() + + cursor.execute(""" + SELECT * FROM orders + WHERE key IS NULL OR key = '' + """) + + rows = cursor.fetchall() + + for row in rows: + order_id = row[12] # ✅ id (а не 12!) + id_i = row[1] + + print(f"Обработка заказа {order_id}") + try: + # пример: + new_key = get_order_content(int(order_id)) + + cursor.execute(""" + UPDATE orders + SET key = ? + WHERE id = ? + """, (new_key, order_id)) + + url = "https://wstkeys.top/newOrder" + # url = "http://0.0.0.0:5205/newOrder" + + payload = {"orderId": int(order_id), "partnerSchemaId": 209} + + headers = { + "Content-Type": "application/json" + } + + response = requests.post(url, json=payload, headers=headers) + except Exception as a: + print(a) + + print(response.status_code) + print(response.text) + + conn.commit() + conn.close() + + + + \ No newline at end of file diff --git a/services/red.py b/services/red.py index d18f8dd..0a5ae54 100644 --- a/services/red.py +++ b/services/red.py @@ -1,12 +1,16 @@ import datetime from API.rok import download_products, download_prices from API.rokky import decrypt_and_unpack, add_product, update_prices +from services.orders_rokky import rok_orders def run_task(): + print("REDs start download_prices:!", datetime.datetime.now()) download_prices() decrypt_and_unpack("prices") + print("START update_prices") update_prices() - print("REDs download_prices:", datetime.datetime.now()) + print("END update_prices", datetime.datetime.now()) + print("REDs download_prices:!", datetime.datetime.now()) def run_task1(): @@ -14,4 +18,20 @@ def run_task1(): decrypt_and_unpack("products") add_product() print("REDs download__product:", datetime.datetime.now()) - \ No newline at end of file + +def run_task2(): + try: + print("START run_task2") + rok_orders() + print("END run_task2", datetime.datetime.now()) + except Exception as e: + print("ERROR run_task2:", e) + +def run_task3(): + try: + print("START run_task3") + update_prices() + print("END run_task3", datetime.datetime.now()) + except Exception as e: + print("ERROR run_task3:", e) + \ No newline at end of file diff --git a/services/tim.py b/services/tim.py index d767e7c..b65df49 100644 --- a/services/tim.py +++ b/services/tim.py @@ -1,14 +1,24 @@ from apscheduler.schedulers.background import BackgroundScheduler -from services.red import run_task +import datetime +import time + +from services.red import run_task, run_task1, run_task2,run_task3 def start_scheduler(): scheduler = BackgroundScheduler() - - # каждые 10 секунд - scheduler.add_job(run_task, 'interval', minutes=10) - # Раз в сутки (24 часа) - scheduler.add_job(run_task, 'interval', days=1) - scheduler.start() \ No newline at end of file + scheduler.add_job(run_task2, 'interval', minutes=1, next_run_time=datetime.datetime.now()) + scheduler.add_job(run_task, 'interval', minutes=5) + scheduler.add_job(run_task1, 'interval', days=1) + # scheduler.add_job( + # run_task3, + # 'interval', + # minutes=2, + # next_run_time=datetime.datetime.now() # 🔥 сразу запуск + # ) + + scheduler.start() + +