o }si}$@sdZddlZddlmZmZddlmZddlmZddl m Z m Z m Z hdZ hdZd ed efd d Zd ed efddZd ed efddZded eeddffddZded eeddffddZded eeddffddZdS)uSync orders and products from e-računi (source of truth). Order sync strategy — two SalesOrderList calls, results merged: 1. dateFrom = 2 weeks ago → all recent orders regardless of status 2. status = Draft → older drafts that may predate the window 3. status = PartialDelivery→ older partially-delivered orders No per-order API calls are made. No writes to e-računi during sync. VAT/OIB fixes are applied when an individual order is processed (Step 1). N)datetime timedelta) Generator)eracuni) upsert_ordersupsert_productsset_order_shopify_id>BAHRMERSXK>ATCHDELIcountryreturncCs,|pd}|tvrdS|tvrdSdS)Nr rEN)stripupper _HR_COUNTRIES _DE_COUNTRIES)rcr4/var/www/warehouse.soldered.com/app/services/sync.py_order_languages rrawcCs|dp |dp d|dp|dpd|dp!|dp!d|dp,|d p,d|d p7|d p7dd }t|rB|S|d pW|dpW|dpW|dpWi}t|trpzt|}Wn tyoi}Ynwt|trt|r|dp|dpd|dp|dp|dpd|dp|dp|dpd|dpd|dp|dp|dpdd Sdddddd S)u$Extract delivery/shipping address from a raw e-računi order dict. e-računi may provide it as flat fields (deliveryStreet, …) or as a nested Address / ShippingAddress object. Returns a dict with keys: name, street, postalCode, city, country — all may be empty strings. deliveryName shipToNamerdeliveryStreet shipToStreetdeliveryPostalCodeshipToPostalCode deliveryCity shipToCitydeliveryCountry shipToCountry)namestreet postalCodecityrAddressaddressShippingAddressshippingAddressr) buyerNamer*address1r+ postal_codezipr,r countryCode country_code) getanyvalues isinstancestrjsonloads Exceptiondict)rflatnestedrrr_extract_delivery!s.  ,      rBc Csf|dp|dp|dpg}t|tr)zt|}Wn ty(g}Ynwt|}id|dd|dd|dd|dd|dd |d d |d d |d d |d d |d d|dd|dd|dd|dd|dd|dd|d||d|d|d|d|d|dt|d d d!S)"u0Map a raw e-računi order dict to our DB schema.Itemsitems orderItemsnumberdatestatusr1 buyerName1 buyerStreetbuyerPostalCode buyerCity buyerCountry buyerEMail buyerPhonebuyerTaxNumberrr)r!r*r#r+r%r,r'rdeliveryMethodmethodOfPaymenttotalAmountInDomCurrdocumentCurrencyremarks shopify_idr)rDrQrRrSrTrUrVlanguage)r7r:r;r<r=r>rBr)rrDdeliveryrrr _normalizeEsh"               rYdb_pathc csvttddd}i}d|dVz t|}|D] }|d}|r+|||<qdt|dVWntyO}z d |VWYd }~d Sd }~wwd Vz-t d }d }|D]}|d}|rr||vrr|||<|d7}q]dt|d|dVWnty}z d|VWYd }~nd }~wwt|} d| dVdd| D} t | |d| dVd S)u Generator: yields log strings while syncing orders from e-računi. Makes 3 SalesOrderList calls and merges results (deduplicated by number). )weeksz%Y-%m-%dzFetching orders since u…rFu → z recent orderszERROR (recent orders): Nu"Fetching PartialDelivery orders…PartialDeliveryrz partial-delivery orders (z new outside window)z#WARNING (partial-delivery orders): zMerging u unique orders…cSsg|]}t|qSr)rY).0orrr szsync_orders.. ✓ Saved z orders to local database) rnowrstrftime eracuni_svc get_ordersr7lenr>get_orders_by_statusr9r) rZ date_fromcombinedrecentr`numepartialaddedtotal normalizedrrr sync_ordersmsJ       rrc csVddlm}dVz|jdd}Wnty+}z d|VWYd}~dSd}~wwdt|d Vd}|D]c}t|d }|d d }|d }|dpRi} | dpYd } | dp`d } | d| } | s{|dpri} | d d pzd } |dpd}|dpd}|rt ||||| pd||dr|d7}q9d|dt|dVdS)uFetch all recent Shopify orders and write their IDs to matching local orders. Matching is done by Shopify order name (e.g. '#S1001') → e-računi number ('S1001'). Only updates rows that exist in the local DB; does not create new rows. r)shopifyu)Fetching Shopify orders (last 60 days)…<) limit_dayszERROR fetching Shopify orders: NGot z orders from Shopifyidr)r#customer first_name last_name shipping_addressfinancial_statusfulfillment_status unfulfilled)shopify_order_nameshopify_customer_nameshopify_financial_statusshopify_fulfillment_statusr^u ✓ Linked z of u) Shopify orders to local e-računi orders) app.servicesrsget_all_ordersr>rgr;r7lstriprr)rZ shopify_svcshopify_ordersrmmatchedorderrVr) er_numberryfirstlast customer_nameshippingr~rrrrsync_shopify_idssF     rc csdVzt}Wnty#}z d|VWYd}~dSd}~wwdt|dVdd|D}t||dt|dVdS) uDGenerator: yields log strings while syncing products from e-računi.u#Fetching products from e-računi…zERROR fetching products: Nrvz productsc SsLg|]"}|dr|d|d|d|d|d|ddqS) productCoder) englishName germanNamebarCodedefaultWarehouseLocation)rr)rrbarcoder)r7)r_prrrras z!sync_products..rb)re get_productsr>rgr)rZrrmproductsrrr sync_productss    r)__doc__r<rrtypingrrrreapp.dbrrrrrr;rr?rBrYrrrrrrrrs    $(- /