Jؔj%UddlZddlmZddlmZddlmZddlmZej dZ iZ e e e e effed<Gdd ZdS) N)Any)ErpDatabaseClient) get_settings) LLMClientzdscons.pricing_resolver_MATERIAL_PRICE_CACHEceZdZdZ ddedzdedzfdZ dd ed ed ed edzd ede ee ff dZ dd ed ed ed edzd ede ee ff dZ de ee ffdZ dS)PricingResolverServicez Zero-Error Bidding Pricing Engine (High-Speed Cached 4-Tier Resolver) Resolves material prices with exact code, trigram similarity, and domain rules. N erp_client llm_clientct|p t|_|ptt|_dS)N)r _erp_clientrr _llm_client)selfr r s YC:\Projects\DSCons\app\modules\inventory\application\state_price_sync\pricing_resolver.py__init__zPricingResolverService.__init__s7 &<):)<)<%B<>>)B)B Vật liệurkeywordcontextmaterial_group material_codefallback_pricereturnc|d|d|pd}|tvr t|S|}|r|nd}d|vsd|vsd|vr*d|vsd|vsd|vrd nd |vrd nd } | d dddd} | t|<| Sd|vrdd dddd} | t|<| Sd|vsd|vsd|vs d|vsd|vsd|vrdd dddd} | t|<| Sd|vrdd dddd} | t|<| Sd |vrd!|vrd nd"d d#dd$d} | t|<| S |j5} | 5} |rr| d%|f| } | rEt| d&d d'd| d(d} | t|<| cd)d)d)cd)d)d)Sd)d)d)n #1swxYwYd*}| |||f| }|s+| d+|f| }d)d)d)n #1swxYwY|rK|d,}t|d&}|d,kr(||d-d.krd nd/d0d|d(d} | t|<| Sn4#t$r'}t d1|Yd)}~nd)}~wwxYw|}|d,krId2|vrd3}nBd4|vsd5|vrd6}n7d7|vrd8}n0d|vrd9}n)d|vrd:}n"d;|vsd<|vrd }nd=|vrd>}nd?|vrd@}n dA|vrdB}ndC}|d/dDd|d} | t|<| S)EzbCore high-speed synchronous resolution (0.1ms) using domain rules and PostgreSQL trigram matching.|ru bốc xếpu bốc xuốngu bốc dỡucátuđáusỏiiUuxi măngiȯihightransport_ruleFu9Cước bốc xếp / bốc dỡ định mức cơ giới)price confidencesourcerequire_review matched_nameuvận chuyểni$u.Cước vận chuyển vật tư / đất đáu đắp cátu cát đắpu san nềnu đắp nềnisand_fill_ruleu&Cát san nền (Theo thông báo giá)u cọc treigbamboo_stake_ruleu#Cọc tre (giá quy đổi 1 cọc)u cừ larsenuthuêi larsen_ruleuCừ Larsen IVzcSELECT state_unit_price_vnd, material_name FROM erp_state_published_prices WHERE material_code = %sstate_unit_price_vndexact_code_match material_nameNah SELECT material_code, material_name, state_unit_price_vnd, similarity(material_name, %s) as sim_score FROM erp_state_published_prices WHERE (material_group = %s OR material_group IS NULL OR material_group = '') ORDER BY sim_score DESC LIMIT 3 zSELECT material_code, material_name, state_unit_price_vnd, similarity(material_name, %s) as sim_score FROM erp_state_published_prices ORDER BY sim_score DESC LIMIT 3r sim_scoreg?mediumtrigram_db_searchz-SQL Trigram search error in PricingResolver: u bê tôngi`uthépu cốt thépiDHu ván khuôniIiiEuđàouxúcuđắpisubơmi uxói hút bùniLidomain_fallback) striplowerrr get_connectioncursorexecutefetchoneintfetchall Exceptionloggerdebug)rrrrrr cache_keykw_lower ctx_lowerp_valresconncurrowquery candidates top_candidatere default_prices r _resolve_corez$PricingResolverService._resolve_cores}},,..WWWW-BUSUWW - - -(3 3==??((**'.6GMMOOOB  H $ $8(C(C|W_G_G_h&&&H*<*<8@S@S)X55ee5  $*"' [ C03 !) ,J x ' '$*"' P C03 !) ,J X % %((h&&))** )) $*"' H C03 !) ,J ( " "$-"' E C03 !) ,J H $ $")"9"9t$'"' 0 C03 !) ,J8 N!0022$ 0d[[]]'c$' B*,"llnn '),S1G-H)I)I.4*<2703O0D ##C@C1)<#&#'''''''$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0'''''''''''''''( EG^#<=== \\^^ !0KK@ "%JI$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0$ 0L  *1 M*@ABB199!&(5;;'-f%"5*/(5o(FC8;))4J N N N LLLLL M M M M M M M M N' A  h&& ' H$$ (A(A % (** & 8## & 8## & H$$((:(: % X%% % 8## & !X-- % & #"'##   ,/i( so6J0I$AG% I J0 I%G) )I,G) -AI J0IJ0IAJ00 K!:KK!c:K||||||S)z'Async interface for pricing resolution.rrrrr)rF)rrrrrrs rresolve_material_pricez-PricingResolverService.resolve_material_prices4!!)') "   rc*|dpt|dkr|dnd}|dpt|dkr|dnd}|dpt|dkr|dnd}|d pt|d kr|d nd }|d pt|d kr|d nd}||||||S)z/Synchronous instant resolution wrapper (0.1ms).rrrrrrrNrrH)getlenrF)rargskwargsrrrrrs rresolve_material_price_syncz2PricingResolverService.resolve_material_price_syncs$**Y''Ms4yy1}}DGG"**Y''Ms4yy1}}DGG"$455 4yy1}}DGG.  ?33 4yy1}}DGG$  $455 4yy1}}DGG! !!)') "   r)NN)rrNr)__name__ __module__ __qualname____doc__rrrstrr4dictrrFrIrSrrr r sk04'+CC%,C$CCCC,$( qqqq q Tz q  q c3hqqqql,$(       Tz     c3h    " d38n      rr )loggingtypingrapp.core.postgres.erp_clientrapp.core.settingsr)app.modules.agents.application.llm_clientr getLoggerr7rrYrX__annotations__r rZrrrbs::::::******??????  4 5 546tCc3h/0555f f f f f f f f f f r