u(i=ddlmZddlmZmZmZmZddlmZm Z ddl Z ddl Z ddl m Z e jeZGddZy) )Session)ListOptionalDictAny)modelsschemasN)IntegrityErrorceZdZdZdefdZdejdejfdZ dejdejfdZ d ejdejfd Zd ej"dej$fd Zd ej(dej*fdZdededeej2fdZdededeej6fdZdej:dejfdZdej>de e!e"ffdZ#de e!e"fde e!e"ffdZ$d#dedede%ejfdZ&dedeejfdZ'de%ejfdZ(de%ejfdZ)de%ej$fd Z*d#dedede%ej*fd!Z+y")$ProductServicez,Service class for product-related operationsdbc||_y)N)r)selfrs I/var/www/html/hubwallet-dev/src/smart_inventory/apps/products/services.py__init__zProductService.__init__s  product_datareturnc|jjtjj tjj |j k(j }|rl|jdjD]\}}t||||jj|jj||Stjdi|j}|jj||jj|jj||S)z&Get existing product or create new oneT exclude_unset) rqueryr Productfilter product_idfirst model_dumpitemssetattrcommitrefreshadd)rrexisting_productfieldvalue db_products rget_or_create_productz$ProductService.get_or_create_products77==8?? NN % %)@)@ @ %'   , 7 7d 7 K Q Q S 8 u(%7 8 GGNN  GGOO, -# # D,*A*A*CDJ GGKK # GGNN  GGOOJ ' r location_datac|jjtjj tjj |j k(j }|rl|jdjD]\}}t||||jj|jj||Stjdi|j}|jj||jj|jj||S)z'Get existing location or create new oneTrr) rrr Locationr location_idrrr r!r"r#r$)rr*existing_locationr&r' db_locations rget_or_create_locationz%ProductService.get_or_create_location& GGMM&//:AA OO ' '=+D+D D %'   - 8 8t 8 L R R T 9 u)5%8 9 GGNN  GGOO- .$ $!//GM,D,D,FGK GGKK $ GGNN  GGOOK ( r vendor_datac|jjtjj tjj |j k(j }|rl|jdjD]\}}t||||jj|jj||Stjdi|j}|jj||jj|jj||S)z%Get existing vendor or create new oneTrr) rrr Vendorr vendor_idrrr r!r"r#r$)rr2existing_vendorr&r' db_vendors rget_or_create_vendorz#ProductService.get_or_create_vendor;s''-- 6== MM # #{'<'< < %'   + 6 6T 6 J P P R 7 u6 7 GGNN  GGOOO ," " A (>(>(@AI GGKK " GGNN  GGOOI & r category_datac|jjtjj tjj |j k(j }|rl|jdjD]\}}t||||jj|jj||Stjdi|j}|jj||jj|jj||S)z'Get existing category or create new oneTrr) rrr Categoryr category_idrrr r!r"r#r$)rr9existing_categoryr&r' db_categorys rget_or_create_categoryz%ProductService.get_or_create_categoryPr1r price_datac|jjtjj tjj |j k(j }|rl|jdjD]\}}t||||jj|jj||Stjdi|j}|jj||jj|jj||S)z,Get existing product price or create new oneTrr) rrr ProductPricerproduct_price_idrrr r!r"r#r$)rr@existing_pricer&r'db_prices rget_or_create_product_pricez*ProductService.get_or_create_product_priceesv':':;BB    0 0J4O4O O %'   * 5 5D 5 I O O Q 6 uu5 6 GGNN  GGOON +! !**EZ-B-B-DEH GGKK ! GGNN  GGOOH %Orrr5c`|jjtjj tjj |k(tjj |k(j}|sj tj||}|jj||jj|jj||S|S#t$r8|jjtjd|d|YywxYw)z1Create product-vendor mapping if it doesn't exist)rr5z'Product-Vendor mapping already exists: -N)rrr ProductVendorrrr5rr$r"r#r rollbackloggerwarning)rrr5existing_mapping db_mappings rcreate_product_vendor_mappingz,ProductService.create_product_vendor_mappingzs77==)=)=>EE  + +z 9  * *i 7  %'    #11ZS\]  J'  +!!   "   "!H TUV_U`ab A(C,,>D-,D-r-c`|jjtjj tjj |k(tjj |k(j}|sj tj||}|jj||jj|jj||S|S#t$r8|jjtjd|d|YywxYw)z3Create product-location mapping if it doesn't exist)rr-z)Product-Location mapping already exists: rHN)rrr ProductLocationrrr-rr$r"r#r rJrKrL)rrr-rMrNs rcreate_product_location_mappingz.ProductService.create_product_location_mappings77==)?)?@GG  " " - - ;  " " . .+ =  %'    #33zWbc  J'  +!!   "   "!J:,VWXcWdef rP api_productc Z d}|jr1t|jdkDr|jdj}|jrH|jrk(jA} | stBjEd|j>dt j&|j>d|j>} |j-| |j/|j|j>t jF|jH|j|j>|jJ|jL|jN|jP|jR|jT|jV } |jY| |jZr~|jZD]o} t j\| j^| j`| jb } |je| |jg|j| j^q|S#th$rN}tBjkd |jd tm||j2jod}~wwxYw) z@Process a single product from API response and store in databaseNr)r< category_name) r product_name short_name description brand_namefk_product_category_id image_patheligible_for_returndisplay_on_posdisplay_on_online_store)r- location_namez Location z, not found, creating minimal location record) rCrr-cost_price_per_unit markup_value margin_valueretail_price_excl_taxcompare_at_pricemarkup_type_namemargin_type_name)r5 vendor_name vendor_codeError processing product : )8 productImageslen imagePathfkProductCategoryId categoryNamer CategoryCreater? ProductCreate productId productName shortNamerY brandNameeligibleForReturn displayOnPOSdisplayOnOnlineStorer) locationsLocationCreate locationId locationNamer0rSpricesrrr r,rr- fkLocationIdrrKrLProductPriceCreateproductPriceIdcostPricePerUnit markupValue marginValueretailPriceExclTaxcompareAtPricemarkupTypeNamemarginTypeNamerFvendors VendorCreatevendorId vendorName vendorCoder8rO ExceptionerrorstrrJ)rrTr\r9rr(locationr*pricer.minimal_location_dataprice_data_itemvendorr2es rprocess_api_productz"ProductService.process_api_productsZ J((S1J1J-Ka-O(66q9CC ..;3K3K ' 6 6 + ? ?"-":":! ++M:#00&00(44&00'33&00'2'F'F%$/$A$A*77(3(H(H L33LAJ$$ + 5 5eH$+$:$:$,$7$7&.&;&;%M// >889N9NPXPcPcd e!!(//FE(, foo(F(M(M33u7I7II)eg&-53E3E2FFr'st070F0F(-(:(:,5e6H6H5I*J1-334IJ<<[=R=RTYTfTfg'.&@&@).)=)=#.#8#8$)$6$6,1,B,B%*%6%6%*%6%6.3.F.F).)=)=).)=)=).)=)= 'O44_E9F>"")11_F")"6"6"(//$*$5$5$*$5$5#K --k:66{7L7Lfoo^_   LL4[5J5J4K2cRSfXV W GG     sOO P*A P%%P* request_datacbd}|j|j|jd}ddd} tj|||d}|j |j }tjd|jd d |S#tjj$r=}tjd t|td t|d }~wt$r=}tjd t|tdt|d }~wwxYw)z Fetch products from external APIzLhttps://hubwalletdev-api.myteamconnector.com/api/AIIntegration/ProductSearch) companyId pageNumberpageSizez*/*zapplication/json)acceptz Content-Type<)jsonheaderstimeoutzAPI response received: successFzAPI request failed: NzJSON decode error: zInvalid JSON response: ) company_id page_number page_sizerequestspostraise_for_statusrrKinfoget exceptionsRequestExceptionrr RuntimeError ValueError)rrapi_urlpayloadrresponse api_responsers rfetch_products_from_apiz&ProductService.fetch_products_from_apis`&00&22$.. .   C}}W7GUWXH  % % '#==?L KK1,2B2B9e2T1UV W ""33 @ LL/Ax8 9!5c!fX>? ? C LL.s1vh7 8!8QAB B Cs$A"BD.-8C%% D.18D))D.rc |jdds |jdd}td||jdi}|jdg}d}g}|D].} tjdi|}|j ||d z }0dt||t||d} |rd| d<| S#t $rQ} d |jd d d t | }tj||j|Yd} ~ d} ~ wwxYw#t $rV} tjdt | |jjdt | ddd dcYd} ~ Sd} ~ wwxYw)z@Process the complete API response and store products in databaserF errorMessagezUnknown API errorzAPI returned error: datar rrrjrsunknownrkNT)r total_itemsprocessed_count error_counterrorszError processing API response: )rrrrrr) rrr APIProductrrrrKrappendrmrrJ) rr error_msgrr rr item_datarTrresults rprocess_api_responsez#ProductService.process_api_response"s+ ##Iu5(,,^=PQ  #7 {!CDD##FB/DHHWb)EOF" - -")"4"4"Ay"AK,,[9#q(O  - "5z#2"6{ F$)y!M!!-";IMM+W`DDUKOOQQrN)rd),__name__ __module__ __qualname____doc__rrr rrr rr)r{r,r0rr4r8rqr;r?rrBrFintrrIrOrRrSrrProductFetchRequestrrrrrrrrrrrrrrrr r s67'2G2GFNN*G4J4Jv*0D0D*G4J4Jv*g6P6PU[UhUh*   PXY_YmYmPn * # C T\]c]s]sTt *\w/A/A\fnn\|CG4O4OCTXY\^aYaTbC@-c3h-DcN-^MMMtFNN?SMeCeHV^^4Le4tFOO442T&--024V__ 54R3R3RfFYFYAZRrr )sqlalchemy.ormrtypingrrrrr r rloggingsqlalchemy.excr getLoggerrrKr rrrrs:",,)   8 $\R\Rr