o mDWj@sdZddlmZddlZddlmZmZmZd;dd?ddZ d@dAddZ dBddZ dCdDdd Z dEd"d#ZdFd&d'ZdGd)d*ZdHd+d,ZdId/d0ZdJd3d4ZdKd7d8ZdGd9d:ZdS)Lz Small, dependency-free helpers shared by every analyzer. AliExpress payloads are inconsistent (strings for numbers, lists wrapped in single-key dicts, missing keys), so all extraction goes through these defensive utilities. ) annotationsN)AnyIterableOptionaldatarpathstrdefaultreturncCs:|}|dD]}t|tr||vr|S||}q|S)zRead a nested value using a dotted path, e.g. ``"a.b.c"``. Returns ``default`` when any segment is missing or not a dict. .)split isinstancedict)rrr currentkeyrt/var/www/snowflake_co_dev_github/snow_flake_back_end_deploy/mama_care_api/ali_express_ds/pms/engine/utils/helpers.pysafe_gets  rrkeys Iterable[str]cCs0|D]}t||}|ddgifvr|Sq|S)z>Return the first non-empty value among several candidate keys.N)r)rrr rvaluerrr first_presents  rrfloatcCsN|dur|St|ttfrt|Stdt|}|s|St|ddS)zJCoerce AliExpress numeric strings ('27.78', '19,00', 'USD 5.99') to float.Nz-?\d+(?:[.,]\d+)?,r )r intrresearchrgroupreplace)rr matchrrrto_float$sr"rcCstt|t|SN)rr"r)rr rrrto_int0sr$cCstt|ddS)z9Round monetary / percentage values to two decimal places.r)roundr)rrrrround24sr'Y@lowhighcCst|t||S)z$Keep a score inside its valid range.)maxmin)rr)r*rrrclamp9sr-listcCsj|durgSt|tr |St|tr2t|dkr/tt|}t|tr'|St|tr/|gS|gS|gS)zNormalize AliExpress list containers. The API often wraps lists as ``{"some_key_dto": [...]}`` or returns a single dict instead of a list. This flattens all of those to a plain list. N)r r.rlennextitervalues)rinnerrrras_list>s     r5bestworstcCs4||kr ||kr dSdS||||}t|dS)zMap ``value`` to 0-100 where ``best`` earns 100 and ``worst`` earns 0. Works in both directions (best < worst means "lower is better"). r(rr-)rr6r7ratiorrr linear_scoreTs r: full_score_atcCs|dkrdSt||dS)z8Map ``value`` to 0-100, saturating at ``full_score_at``.rrr(r8rr;rrr ratio_score_sr=cCst|tsiS|}tdD]0}d}|D]\}}|dr)t|tr)|}d}nqt|dtr8|d}d}|s=|Sq |S)aPeel AliExpress API envelopes off a payload. Real API responses arrive wrapped, e.g.:: {"aliexpress_ds_product_wholesale_get_response": {"result": {...}}} {"aliexpress_ds_freight_query_response": {"result": {...}}} This walks down through any ``*_response`` wrapper and any ``result`` container until the actual data object is reached. Payloads that are already unwrapped pass through unchanged. F _responseTresult)r rrangeitemsendswithget)rr_ descendedrrrrrunwrap_responsefs&  rGraw#tuple[Optional[int], Optional[int]]cCs|durdSt|ttfrt|}||fSddtdt|D}|s&dSt|dkr4|d|dfSt|d|dt|d|dfS)zParse AliExpress delivery time strings. Accepts values like ``"12-20"``, ``"15"``, ``"7 days"`` or integers. Returns ``(min_days, max_days)`` or ``(None, None)`` when unknown. N)NNcSsg|]}t|qSr)r).0nrrr sz'parse_delivery_days..z\d+r/r) r rrrfindallrr0r,r+)rHdaysnumbersrrrparse_delivery_dayss $rPrB%'list[tuple[Optional[float], float]]'cCsFdd|D}tdd|D}|dkrdSttdd|D|S)aWeighted average of (score, weight) pairs on a 0-100 scale. Missing metrics are passed as ``None`` scores and are *excluded*; the remaining weights are renormalized so unavailable data never drags the result toward zero. Returns 0.0 when nothing is available. cSs(g|]\}}|dur|dkr||fqS)NrrrJswrrrrLs(z$weighted_average..css|]\}}|VqdSr#r)rJrErTrrr sz#weighted_average..rrcss|] \}}||VqdSr#rrRrrrrUs)sumr-)rB available total_weightrrrweighted_averages rYanchors'list[tuple[float, float]]'cCs|sdS||ddkrt|ddSt||ddD]&\\}}\}}||krC||kr5||||nd}t||||Sqt|ddS)zLinear interpolation over (value, score) anchor points. Produces smooth, gradually increasing scores instead of hard cliffs. Anchors must be sorted by value; values outside the range clamp to the first / last anchor's score. rrr/Ng?)r-zip)rrZx1y1x2y2r9rrrpiecewise_scores"rbcCs(|dks|dkr dSt||ddS)aSquare-root saturation curve on a 0-100 scale. Rewards early progress: 10% of the saturation point already earns ~32 points instead of 10. Used for volume metrics (sales, reviews) so that moderate history is not punished as if it were zero. rrg?r(r8r<rrrsaturating_scoresrcr#)rrrrr rr r)rrrrr rr r)r)rrr rr r)r)rrr rr r)rrr r)rr()rrr)rr*rr r)rrr r.)rrr6rr7rr r)rrr;rr r)rrr r)rHrr rI)rBrQr r)rrrZr[r r)__doc__ __future__rrtypingrrrrrr"r$r'r-r5r:r=rGrPrYrbrcrrrrs$