a $iA@sddlZddlZddlZddlZddlZddlZddlmZddlmZmZddl m Z ddl m Z ddl mZddlmZddlmZGd d d eZdS) N)Thread)datetime timedelta) Interpreter) TaskQueue)logger)config)SQLitecseZdZeddfdd ZddZeeddd Zdeee d d d Z ee dd dZ eedddZ eedddZdeddddZddddZZS) RulesHandlerN)queuereturncs`tjddt|_||_g|_t|_t |jj d<t |jj d<t |jj d<t |jj d<dS)NT)daemonroundintabsmath)super__init__ threadingEvent stop_eventr rulesrastval_interpreterrZsymtablerrr)selfr  __class__-/var/aqua_controller/workers/rules_handler.pyrs    zRulesHandler.__init__cCs|jdSN)rset)rrrrstop(szRulesHandler.stop)exprr cCs d}ddtj||tjdDS)Nz\{([TS]):(.*?)\}cSs.i|]&}|d|d|ddqS)rtypevalue)grouplower).0matchrrr 1sz7RulesHandler.__extract_placeholders..)flags)refinditer IGNORECASE)rr!patternrrrZ__extract_placeholders/sz#RulesHandler.__extract_placeholders)r! type_filterr csDdusdvrgS||}fdd|D}t|SdS)N)tscs$h|]}|dkr|dqSr$)r()r)infor1rr Asz4RulesHandler.__get_values_by_type..)r(#_RulesHandler__extract_placeholdersvalueslist)rr!r1Z placeholdersZ unique_valuesrr5rZ__get_values_by_type<s  z!RulesHandler.__get_values_by_typecCs|dkr.t}|jd|jd|jSttt| d}t |dkrf|\}}|d|dSt |dkr|\}}}|d|d|St d|dS)NZ current_timei<:r#uFуказан неверный формат времени (HH:MM:SS): ) r(rnowhourminutesecondr9maprsplitlen ValueError)rr!r=partshmr3rrrZ__time_to_secondsLs    zRulesHandler.__time_to_secondsc Cszd|vr||ni}||}|D]\}}|ddkrV||d}nN|ddkrt||d}|durtd|dntd|d| |t|}q.|WSt y}zt d |WYd}~n d}~00dS) Nz{s:r%r2r&r3u/Отсутствует значение для u в БДu2Неизвестный тип параметра: udНе удалось осуществить замену параметров на значения: ) r(_RulesHandler__load_to_sqliter7items_RulesHandler__time_to_secondsstrgetKeyErrorrDreplace Exception RuntimeError)rr!Zcondition_type_s_dictZ placeholderZ structureZ replace_valueerrrZ__replace_placeholders_s z#RulesHandler.__replace_placeholders) conditionr c Csi}||d}|s|Stjdddd}|dur8tdz|ddd|D}d |d }|}t|<}|||} | D]} | d || d <qx|WdWS1s0YWn2ty} ztd | WYd} ~ n d} ~ 00dS)Nr3 controllerZsqlite_databasessectionkeydefaultu1Не указан путь к хранилищу.z, css|] }dVqdS)?Nr)r)_rrr z0RulesHandler.__load_to_sqlite..z SELECT t.r_id, t.r_code, t.r_create_datetime, t.r_value FROM t_result t JOIN ( SELECT r_code, MAX(r_create_datetime) AS max_datetime FROM t_result WHERE r_code IN (zk) GROUP BY r_code ) m ON t.r_code = m.r_code AND t.r_create_datetime = m.max_datetime; Zr_valueZr_codeuKНе удалось получить записи из хранилища: ) !_RulesHandler__get_values_by_typer get_valuerDjoinr Z query_allrOrP) rrRresultZcondition_values_by_typeZ"config_controller_sqlite_databasesmaskqueryZparamZdbZrowsrowrQrrrZ__load_to_sqlitevs(    (zRulesHandler.__load_to_sqlite)rr c s~|sdStjdddd}|D]Z}i}zd|vr@td|n |d|d<d|vr`|d|d<d|vrt|d|d<d |vr|d |d <n||d <d |vrtd |dd d }g|d <|d D]2tfdddDr|d qd}qq|std |dd|j|WnNtyl}z4td|t dt j ddWYd}~n d}~00t dqdS)NrSZ cron_defaultz * * * * *rTnameuПравило не будет обработано. Отсутствует наименование 'name' для правила: coderRcronactionsПравило 'u`' не будет обработано. Отсутствует список задач 'actions'Tc3s|]}|vVqdSrr)r)rVZitem_rules_actionsrrrZr[z,RulesHandler.__load_rules..ZdevicemethodFu' не будет обработано. Не все задачи из списка 'actions', содержат обязательные параметры ['device', 'method']u.Ошибка загрузки правила: %Трассировка ошибки: r"limitg?)rr]rMallappendrrOrerrordebug traceback format_exctimesleep)rrZconfig_controller_cron_default item_rulesZtmp_item_rulesZis_valid_actionsrQrrhrZ __load_ruless@     .zRulesHandler.__load_rules)r c CstdzАzptd}|dur.||t|jdkrDtd|j s~t }|jD]}zt |d|}| t }Wnbty}zJtd|dd|td tjd d WYd}~q^WYd}~n d}~00||td d krq^d |vrt|d trz4d|d vr4||d }n|d }||}Wnhty}zNd}td|dd|td tjd d WYd}~q^WYd}~n d}~00nd}nd}|r^g} zZ|dD]J} i} | D]$\} } | dvr| | | <qt| trd| vr$|| n| }|}|drnt|t|}|d||d d}|| | <n|dr|d d}z$||}|dur|n|| | <WnDty}z*td|d||| | <WYd}~n d}~00n|| | <n| | | <q| r| | qWndty}zJtd|dd|td tjd d WYd}~q^WYd}~n d}~00zi}t| dkr| |d<d|vr|d|d<|rtd|dd|dd|d|j|t j!j"st#d|Wq^tyn}zJtd|dd|td tjd d WYd}~q^WYd}~q^d}~00q^t$%d qDWnNty}z4td |td tjd d WYd}~n d}~00Wtd!n td!0dS)"NuПоток запущен.rruCписок правил пуст. Вероятно правила не были приняты в обработку, ввиду наличия ошибок конфигурации.rergrcuk' не будет обработано. Ошибка формирования расписания 'cron': rkr"rl)secondsrR{Fub' не будет обработано. Ошибка проверки условия 'condition': Trfriz'==u;Не удалось вычислить выражение 'z': uu' не будет обработано. Ошибка формирования списка заданий 'actions': rduПравило: 'u' => Расписание: 'u' => Задача: ''uIНе удалось поставить в очередь задание: uj' не будет обработано. Ошибка постановки задачи в очередь: u<Ошибка функциональности потока: u Поток остановлен.)&rr4r get_section_RulesHandler__load_rulesrCrrDris_setrr=croniterZget_prevrOrprqrrrsr isinstancerK#_RulesHandler__replace_placeholdersrrIlstrip startswithstripwarningror set_taskrPriorityLOWrPrtru)rZ config_rulesZ this_timervZcitZ prev_timerQZitem_rules_conditionZis_item_rules_conditionZ new_actionsZ item_actionsZ new_parametrskvZ_vZ _v_strippedZ_len_non_spaceZ_v_newZ _expressionZ_v_evalZnew_taskrrrruns     " $          "  &$0zRulesHandler.run)N)N)__name__ __module__ __qualname__rrr rKdictr7r9r\rrJrrHr|r __classcell__rrrrr s (@r )rrrtr~r-rrrrrZastevalrcore.task_queuer core.loggerrcore.сonfig_handlerrZ core.sqliter r rrrrs