qj~v 0UddlmZddlZddlZddlZddlmZddlmZddl m Z m Z ddl m ZmZmZddd gd d d d dddddgddd ddddgddd dZded<dZddgZdRdZdSd ZdTd!ZdUd"ZdVdWd#ZdXd$ZdVdYd%ZdZd&Zd[d'Zd\d(Zd]d)Zd^d*Z d_d+Z!d`d,Z"dad-Z#dbd.Z$dVdcd/Z%ddd0Z&dedfd1Z'dddd2 dgd3Z(dhd4Z)dddd5did6Z*ddd7 djd8Z+d9d:d;gd<d=d>d;id>d;id?d>d;id@d?d>d;id@d>dAidBgdBdCZ,d9d:d9d:d>d;id>d;id>d;id>d;idDgdDdCd?e,d@dEdFdGgdCZ-d9d:d;gdHd=d>dAid?d>d;id@d>d;idIgdIdCZ.d9d:d9d:d>d;id>d;id>d;id>dAidJgdJdCd?d9d:d>d;id>d;id>d;idKgdKdCd@d?d9d:d>d;id>d;id>dAidLgdLdCd@d?d>d;id@dMgdMdCZ/dkdNZ0dldOZ1ddPdmdQZ2y)n) annotationsN)Any)connect)init_core_schemautc_now) configured load_secret save_secretz Groq Freezhttps://api.groq.com/openai/v1openai/gpt-oss-120b)r zopenai/gpt-oss-20bzqwen/qwen3.8-27bu6Free tier; основной провайдер ORIGUS.uДля рабочих данных используй настройки проекта Groq и проверяй выбранную политику хранения.)namebase_url default_modelmodels free_note privacy_notez Gemini Freez8https://generativelanguage.googleapis.com/v1beta/openai/zgemini-3.6-flashzgemini-3.5-flash-liteuAБесплатный tier; резервный провайдер.uFree tier может иметь отличающиеся условия использования данных; включай fallback осознанно.zOpenRouter Freezhttps://openrouter.ai/api/v1zopenrouter/freeu>Бесплатный резерв; лимиты ниже Groq.uМаршрутизация идёт к сторонним model providers; используй только если это допустимо для данных.)groqgemini openrouterzdict[str, dict[str, Any]] PROVIDERSrrrctj|xsdjj}|st d||S)Nu.Неизвестный AI-провайдер: )rgetstriplower RuntimeError)keyitems J/var/www/origus_pro_usr/data/www/origus.pro/core/connectors/ai_provider.py _providerr/sA ==#)**,224 5D KC5QRR Kctt5}|jdjDcic]}t |dt |}}dddg}t jD]\}}j|xsi} tj|jdxsd}|j||d|d|d|d|d |d t||jd xsd |jd |jd|jdxs|d|d |Scc}w#1swYxYw#t$ri}YwxYw)Nz2SELECT * FROM connectors WHERE connector_type='ai' connector_key meta_jsonz{}r r rrrrstatusnot_configured last_test_at last_errormodel) rr r rrrrrr$r&r'r(meta)rrexecutefetchallstrdictritemsrjsonloads Exceptionappendsecret_configured)conxrowsresultrcfgrowr)s rprovider_catalogr:6sl  c[[Dhj   /" #T!W ,    FOO% S HHSM R CGGK08D9D  v;:0]K(~.*3/WWX&:*:77>2.HHW%=_)=   * M;    D s."ED?E(E?EE  EEctt5}|jdj}dddstdt dS t j|dxsd}|Dcgc]}|tvs ||dk7s|}}|dtvr|dntt|d||dd S#1swYxYw#t$r t }YhwxYwcc}w) Nz+SELECT * FROM ai_settings WHERE singleton=1F)primary_providerfallback_enabledfallback_orderfallback_order_jsonz[]r<r= updated_at)r<r=r>r@) rrr*fetchoneDEFAULT_PRIMARYDEFAULT_FALLBACKr/r0r1rbool)r4r9orderr5s rrouting_settingsrFYs c KK 9 (*  .$-  jj23;t< OqI~!s;M7N2N1 OE O69:L6MQZ6Z312`o$6 78&    Os/ B5C. C<CC5B>CCc t|xsdjj}t|g}|D]I}|xsdjj}|tvs.||k7s4||vs9|j |Kt 5}|jd||rdndtj|dtf|jdddtS#1swYtSxYw)Nra INSERT INTO ai_settings(singleton,primary_provider,fallback_enabled,fallback_order_json,updated_at) VALUES(1,?,?,?,?) ON CONFLICT(singleton) DO UPDATE SET primary_provider=excluded.primary_provider, fallback_enabled=excluded.fallback_enabled, fallback_order_json=excluded.fallback_order_json, updated_at=excluded.updated_at rF ensure_ascii) rrrrrr2rr*r/dumpsrcommitrF)r<r=r>primarycleanrr4s rsave_routing_settingsrOrs  # * * , 2 2 4G g E YB    % % ' ) w3e3C LL   c  *Q$**UPU2VW^W` a c       s AC,,C>ct|xsdjj}t|}|xsdj}|s t d|xs|dj}t |||dt 5}|jdtjd|id|f|jdddd ||d S#1swYxYw) NruAPI key обязателен.r)api_keyr(z UPDATE connectors SET status='configured',last_error=NULL,meta_json=? WHERE connector_key=? r(FrIT)okproviderr() rrrrrr rr*r/rKrL)rSrQr(rr8chosenr4s rconfigure_providerrUs R &&(C#C ] ! ! #G :;;  )S) 0 0 2Fwv67 c  ZZ(e |d k(r|dk(rd} n1|dk(r d|dd} n"|dd} n|dk(rd} n|dk(rd} n |dvrd} nd} | g} |r| j d||jdr| j d|d|r| j d|t d j | d!| d"|zS)#NrWr]rr[r : z (model=)iuAPI key не принят: проверь, что ключ действующий и сохранён без лишних символов.rmodel_permission_blocked_orguМодель запрещена на уровне Groq Organization. Разреши её в Organization → Limits или выбери разрешённую модель. model_permission_blocked_projectuМодель запрещена на уровне Groq Project. Разреши её в Project → Limits или выбери разрешённую модель. GET /modelsuКлюч передан u, но доступ к API запрещён политикой/правами аккаунта или проекта. Проверь права и статус ключа.up запретил запрос. Core показывает исходный код провайдера ниже.iuРесурс или модель недоступны для этого API. Core повторно сверит список /models при следующем тесте.iugДостигнут rate limit/quota Groq. Повтори тест после сброса лимита.)iiiu\Временная серверная ошибка Groq. Повтори тест позже.u\Проверь ответ провайдера и сетевую доступность API.zHTTP r\ztype=zcode=u · z. u Провайдер: )rrerr,r2rjoin) rS operationrar(r8infor$r]remotewherehintpartss r_diagnostic_errorrts H C # D XXm $F 88F  !rD XXi ,CHF6{m2i[ )E  8E7!$$ }] 3 v $*H"HBD  D,N$NxD - '-c&k];fgD&k]#STD 3| 3x ? "mm GE  uVH%& xx uT&\N+,  uTF^$  E*r$7LVH-UU VVr c*|xsdjj}t|}t|\}} |jj }t|d|}g} t |xsg} | D]h} t| dd} | !t| tr| jd} t| xsdj} | sS| |vsX|j| j|S#t $r}t|d||d}~wwxYw#t $rg} YwxYw)zJCall the provider's OpenAI-compatible GET /models with the same saved key.rrlNdataid)rrr_clientrlistr1rtr^r`r-rr,r2) rSrr8client_pagerar.r7iterablermodel_ids r_list_available_modelsrs >r " ( ( *C C.C IFAB}}!!# D&$ 'EF $$4t,   4 6xx~Hx~2&,,. . MM( # $ M! B]C8cAB s)C%'D% D.C<<D DDczt|}t|}g}||jdg|jdxsgD]8}t|xsdj }|s#||vs(|j |:|D] }||vs|cSdj |ddxsd}t|dd|xsd d |) Nrrrz, uсписок пустr u: ни одна настроенная текстовая модель ORIGUS не найдена в GET /models. Настроено: u—u#. Доступные модели: )rsetrr,rr2rmr)rSconfigured_modelavailable_modelsr8 available candidatesrbpreviews r_select_available_modelr s H C$%IJ&(@]CGGHDUD[Y[])  R(..0 *4   i ()   ! ii("-.I2IG  v;-/8599\]d\e g r cBt|}|sy||d<t||y)Nr()r r )rSr(secrets r_persist_provider_modelrs%  "F F7O&!r cr ddlm}t |}t |}t |jdxsdj}|std|ddt |jd xs|d j}|||d  |fS#t$r}td|d}~wwxYw) Nr)OpenAIuMНе установлен пакет openai (SDK совместимых API).rQrzAPI key r u не настроен.r(rr )rQr ) openair ImportErrorrrr r,rr)rSrrar8rrQr(s rrxrx'su! (C x F  9%+ , 2 2 4G Xc&k]2IJKK fjj!9S%9 : @ @ BE '3z? ;E AA ujkqttusB B6% B11B6c 0tj|jdj}t 5}|j d|||t d|f}|jt|jcdddS#1swYyxYw)Nzutf-8z~ INSERT INTO ai_runs(purpose,provider,model,created_at,status,input_hash) VALUES(?,?,?,?,?,?) running) hashlibsha256encode hexdigestrr*rrLint lastrowid)purposerSr( input_textdigestr4curs r _run_startr5s >>*++G4 5 ? ? AF "c KK XeGIi ? A 3==! """s AB  Bct5}|jdtj|d|f|jd|f|j dddy#1swYyxYw)NzGUPDATE ai_runs SET status='ok',result_meta_json=?,error=NULL WHERE id=?FrIzGUPDATE connectors SET status='ok',last_error=NULL WHERE connector_key=?)rr*r/rKrL)run_idrSr)r4s r_run_okr@s] c ]ZZ%8@ B ]_g^ij s A A!!A*ct|dd}t5}|jd||f|jd|dd|f|jdddy#1swYyxYw)Ni z4UPDATE ai_runs SET status='error',error=? WHERE id=?zGUPDATE connectors SET status='error',last_error=? WHERE connector_key=?)r,rr*rL)rrSramsgr4s r _run_errorrHsi C$C c JCPV<X ]_bchdh_ijr^st s t)DE| FKK++,? EG GNN $V $Id+/((//9&9 M'* **r c|t|ddxs|t|dd||d}t|dd}|3dddd}|jD]\}} t||d} | | || <|S) Nr(rw)rSr( response_id fallback_used rate_limitsusage input_tokens output_tokens total_tokens) prompt_tokenscompletion_tokensr)r^r.) rYrSr(rrr)rmappingsrcdstvals r _usage_metars.7%htD1%  D (74 (E * /)  }} .GCc$'C#S  . Kr ct}|r@|jjg}|drB||dDcgc] }||vs| c}z }n&|dg}|dr||dDcgc] }||vs| c}z }g}t|D]C\}}|tvs t |st |\}} |j||dk(r|r|n| fE|s td|Scc}wcc}w)Nr=r>r<ruAI-провайдеры не настроены. В Admin → ORIGUS Core настрой Groq Free (рекомендуется) или другой провайдер.) rFrr enumeraterr3rxr2r) preferred_providermodel_overridesettingsrEr5routesirr{rs r_routesrs  H!'')//12 & ' *:!;NAq~aN NE*+, & ' *:!;NAq~aN NE F5!^# i '8'= "3<  sad~NK[\] ^  S   M#OOs CC C*C)rrr(c .t||}g}t|D]X\}\} } t|| | |} t| | ||\} } t | | | | |dkD}t | | |dt | || dcStddj!|z#t$ry}t|tr*t|jt| ddzr|}nt| d|| }t| | ||jt|Yd}~d}~wwxYw) NrT)rRr_r) ai_run_idr :POST /chat/completionsu]Все настроенные AI-провайдеры завершились ошибкой.  | )rrrrrrrr1r`rr, startswithrrtrr2rm)rrrrrr(rerrorsindexrS chosen_modelrrYrr)ra diagnostics r_executersF %e ,F F)26):%%x '(< C %h|H_U HWXh|GE!GLD F8D ))"   ( vy~zDzDEKzLL MM #|,S1D1DYxEXY_E`cfEf1g ,X6NsS_` vhz 2 MM#j/ *  s?B DA/DDc |xsdjj}t|}t|\}}g}g} t |}t |}g} ||j dg|j dxsgD]=} t| xsdj} | s#| |vs(| | vs-| j| ?| s t|||d} d} | D]9} |j|  t|| dddgd\} }t| | } | } n| | s/djd|Dxsd}t!|dd| | |k7}|r t1|| | |||||t-d}t)5}|j+dt-t3j4|d|f|j/dddd||d|d|dj7ddz|| |||t9||d S#t$r}t|}|j ddk(rf|j d d vrS|j| t|j d xsdt|j d xsdd Yd}~t|d || |d}~wwxYw#t$r}t#|t r#t|j%|ddzr|}n)t|d |t'j dxs|}t)5}|j+dt|ddt-|f|j/ddd||#1swY||xYwd}~wwxYw#1swYxYw) Nrrruseru(Ответь одним словом: OKrolerrWrir]>rjrkr[)r(r]r[rrc3BK|]}|dd|dd|dyw)r(rgr]u — r[Nr).0rs r z test_provider..s6=/DL>tI6GHsu$нет успешной моделиr ud: все совместимые модели ORIGUS запрещены настройками Groq. rr(zVUPDATE connectors SET status='error',last_error=?,last_test_at=? WHERE connector_key=?r)r(rmodel_auto_selectedrattempted_modelspermission_blocked_modelsmodels_checked_atzbUPDATE connectors SET status='ok',last_test_at=?,last_error=NULL,meta_json=? WHERE connector_key=?FrITr /z/models) rRrS provider_namer models_endpointrr(rrravailable_models_countr)rrrrxrrrr,r2rrrr1rertrmrr`rlocalsrr*rrLrr/rKrstriplen)rSrr8 _client_objrrrrrrrbrYr(candidate_response_headers model_excrodetailsrarr4 model_changedr)s r test_providerrs R &&(C#C!( K "$577"/4&'  *377?+C_cgghFWF][]_ -I)/r*002IY)3 8S!!), - #C(89I J# iI  # #I . i,4 #.XYZ-+"8 +,+ i2  5JJ588 v;- DELDMN  $)&,,ME*++++$=#I D c xYtzz$EB3G I  F z?j/005i?+++$=!$%5!6+  c i#I.88M*C/DHHV4DI5.44 )"488F#3#9r:"%dhhy&9&?R"@6 ',DYyY_hh i*  " c< (SX-@-@VsAR-SJ(-Ec&(,,W^J_JscstJ Y # KKpZ$/ #> @ JJL c!  c! "0sA"J$J)J.2B$tfNG &G+3H r )r(cj||||d}d}tdtj|dd|dt|S) N)r r descriptioncharacteristicsuВыполни только идентификацию продукции для ORIGUS. Не выноси окончательное юридическое решение о применимости технических регламентов и не назначай сертификат/декларацию. Выдели фактические признаки из введённых данных, предложи кандидатные технические регламенты для проверки rules engine и сформулируй недостающие вопросы. Не придумывай характеристики.product_identificationF)rJindentorigus_product_identity)rr_rrrr()rr/rKPRODUCT_IDENTITY_SCHEMA)r rr;r<r(r8rs ridentify_productrBsJ7Wf gG } (djje[\.]!.GOfmr r )rr,returndict[str, Any])rCzlist[dict[str, Any]])rCrD)r<r,r=rDr> list[str]rCrD)N)rSr,rQr,r( str | NonerCrD)rar1rCrD) rSr,rnr,rar1r(rFrCr)rSr,rCrE)rSr,rr,rrErCr,)rSr,r(r,rCNone)rSr,) rr,rSr,r(r,rr,rCr)rrrSr,r)rDrCrG)rrrSr,rar1rCrG)rYrrCr,)rrrCrD)rSr,r(r,rlist[dict[str, str]]rdict[str, Any] | None) rYrrSr,r(r,rrDrrDrCrD)NN)rrFrrFrCzlist[tuple[str, str]])rr,rr,rrHrrIrrFr(rFrCrD)rSr,rCrD) rr,r_r,rrFr(rFrSrFrCrD)rr,r_r,rr,rr,rrDr(rFrSrFrCrD)r0r,rr,rr,rCrD) r0r,rr,r_r,r6rr7rrCrD) r r,rr,r;r,r<rDr(rFrCrD)3 __future__rrr/retypingrcore_dbr core_schemarr secret_storerr3r r r__annotations__rBrCrr:rFrOrUrertrrrrxrrrrrrrrrrrrRULE_ITEM_SCHEMAr5r/rAr1r9rBrr rrRs;" 1RR4. NA N+%'>?Xw "2*$%U} +( $>l+ F2.5&+\&WR4$" B" $+&*2ko)-TM (M4<MDQM6^B?CRVim (,d&5=ER( 5$,uvh'H%$fX->?"F8+<=X& \  55x(&1B!' 1fX=NC   (89 7#" 5!)XY!!6(*;< &x0  C  55 &x0@Q!(+&9JN  #5"(!2F8;LW]^fVgh0,  )05"(!2VH