-6i&U`dZddlZddlmZmZmZmZmZddlm Z ddl m Z m Z m Z mZddlmZddlmZddlZddlmZmZdd lmZdd lmZdd lmZdd lmZmZdd lm Z ddlm!Z!m"Z"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-m.Z.ddl/m0Z0ddlm1Z1ddl2m3Z3ddl4m5Z5ddlm6Z6m7Z7ddl8m9Z:ddl;mZ>m?Z?m@Z@ddlAmBZCddlDmEZEejeGZH d>de de#d eeId!eeId"eId#eeId$eJd%eJd&eKd'eeIeffd(ZLde d)e!d'e fd*ZMde d+eId'ee fd,ZNde d+eId)e"d'ee fd-ZOde d+eId'eKfd.ZPde d/eeId'eJfd0ZQde d1eed2eId3e5d4e3d+eId'ee0fd5ZRde d+eId4e3d3e5d6eJd'ef d7ZSde d4e3d)e>d+eId8e5d'e@f d9ZTde d:eJd)e?d+eId'e@f d;ZUde d4e3d+eId'ee@fd<ZVde d4e3d+eId'eeefd=ZWy)?z1 Product services for business logic operations. N)OptionalListTupleAnyDict)Session)selectupdatedeletefunc)IntegrityError)datetime)status UploadFile) APIException)FilterOperators) API_PREFIXES)Productproduct_attachments_map)ProductResponseSchema)ProductCreateSchemaProductUpdateSchemaProductListFilterSchema)QueryPaginator)generate_unique_slug)settings)File)remove_file_singleupload_file_multiple)FileResponseSchema)product_notes_map)MerchantSchema) UserSchema)ALLOWED_FILE_CONTENT_TYPESMAX_UPLOAD_LIMIT)requests)Note)NoteCreateRequestSchemaNoteUpdateRequestSchema NoteSchema)services)upload_multiple_filesdbfilters_from_tosort_byfieldsskiplimitpaginatereturnc T K tjtjj} t t } tt dr.| jt jjd} |r8tj|d} | jt j| k\} |rMtj|d} | jdddd} | jt j| k} |jr~d|jd} | jt j j#| t j$j#| zt j&j#| z} |j r<| jt j j#d|j d} |j&r<| jt j&j#d|j&d} |j(r<| jt j(j#d|j(d} |j*,| jt j*|j*k(} |j,:| jt j,|j,j/k(} |j0,| jt j0|j0k(} |j2d k7r1|j2d k(}| jt j2|k(} |j4d k7r1|j4d k(}| jt j4|k(} |j6d k7r1|j6d k(}| jt j6|k(} |j8d k7r1|j8d k(}| jt j8|k(} |j:rt=j>|j:}|d t@jBk(r%| jt jD|d k(} |d t@jFk(r5| jt jDjI|d |d } |d t@jJk(r%| jt jD|d kD} |d t@jLk(r%| jt jD|d k} |jOdrC|d d}tt |r]| jQtSt |jU} n/tt |r| jQtSt |} |r+tW| tX| |t ||d}|j[S|j]| j_|ja|jcje}|Dcgc]}tYjf|c}Scc}w#th$r/}tjjmd|dto|icYd}~Sd}~wwxYww)zD Get products list with filtering, sorting, and pagination. deleted_atNz%Y-%m-%d;i?B)hourminutesecond microsecond%roperatorstartend-T)queryschemaurlr-modeloffsetr4use_ormzError getting products list: error)8r api_base_urlrPRODUCTSvaluer rhasattrwherer8is_rstrptime created_atreplacesearchnameilike descriptionskucode merchant_id item_typelower category_id is_activeis_new is_purchaseis_sellcost_price_rangejsonloadsrEQUAL_TO unit_price IN_BETWEENbetweenIS_GREATER_THAN IS_LESS_THAN startswithorder_bygetattrdescrrto_dictexecuterIr4scalarsallmodel_validate ExceptionloggerrKstr)r-r.r/r0r1r2r3r4r5pagination_urlstmt from_dateto_date search_termis_active_bool is_new_boolis_purchase_bool is_sell_boolcost_price_range_json field_name paginatorresultsproductes X/var/www/html/hwPaymentPortal-be-dev/hw-payment-portal-api/src/apps/products/services.pyget_products_listr+s_q!!)!6!6!8 9,:O:O:U:U9VWg 7L )::g0044T:;D  ))%D ''Z8Goo2bQWoXG::g00G;>gnn-Q/K::##K0$$**;79"";/1D <<::gll001W\\N!1DEFD ;;::gkk//!GKK=0BCDD <<::gll001W\\N!1DEFD    *::g11W5H5HHID    (::g//73D3D3J3J3LLMD    *::g11W5H5HHID    !$..!3N::g//>ABD >>Q !..A-K::gnn ;D  # #$(JJw/G/G$H !$Z0O4L4LLzz&&*?*HH%Z0O4N4NNzz&&..-g68Me8T %Z0O4S4SSzz&&)>w)GG%Z0O4P4PPzz&&)>w)GG   c " Jw +}}WWj%A%F%F%HIw(}}WWg%>? &," I$$& &jjT!2!8!8!?@HHJNNPGQXYg)88AY YY ! 4QC89Q  !sTZ(W5Y-9Z(:AY- Y(%Y-'Z((Y-- Z%6$Z Z%Z( Z%%Z(payloadcK|j}|jdd}|jdd}|jdst|t|j |d<t d i|}|j ||j|j||rh|ft|dkDrX |D]B}tjj|j|}|j|D|j|rS|Q tjj|j|}|j||jt)j*|S#t$r"t!t"it$j&d wxYw#t$r"t!t"it$j&d wxYww) z Create a new product. attachmentsN thumbnailslug)r-instance slug_labelr) product_idfile_idzAttachment already existsmodulerK status_codemessagezThumbnail already exists) model_dumppopgetrrrVaddcommitrefreshlenrinsertvaluesidrqr r__name__rHTTP_400_BAD_REQUESTrrt)r-r product_dictrr new_product attachment_idattachemnts_map_querys rcreate_productrs%%'L""=$7K  d3I   F #3|| V)L)KFF;IIKJJ{ /c+6F6J !, 2 (?(F(F(H(O(O&>>=)P)% 01  2 IIKy, $;$B$B$D$K$K&>>9%L% ! JJ, - IIK ! / / <<+ "773    "772   s8B4G7AE8GAF&#G8+F##G&+GGrctK ttjtj|k(tjj d}|j |}|j}|rtj|Sy#t$r"}tjd|Yd}~yd}~wwxYww)z Get a product by ID. NzError getting product by ID: ) r rrPrr8rQrqscalar_one_or_nonerrtrurvrK)r-rryresultrrs r get_productrsg$$ LLD    " "4 (  D!++- (77@ @  4QC89s/B8BB B8 B5B0+B80B55B8c>K ttjtj|k(tjj d}|j |}|j}|sy|jd}|rtj|d<ttjtj|jk(tjj djd i|}|j ||j|j|t!j"|S#t$$r}t&j)d|dt+|j,j/vr t1ddt+|j,j/vr t1d t1d d}~wt2$r4}t&j)d |t1d t+|d}~wwxYww)z! Update a product by ID. NT) exclude_unset updated_atz!IntegrityError updating product: rYz$Product with this SKU already existsrz%Product with this slug already existsz*Product update failed due to data conflictzError updating product: zProduct update failed: r)r rrPrr8rQrqrrrutcnowr rrrrrrtr rvrKrworigr] ValueErrorru) r-rrryrr update_data update_stmtrs rupdate_productrs-=g$$ LLD    " "4 (  D!++-((t(< (0(9K %wJJ'**,&&**40  ' & '  JJ{ # IIK JJw $33G<< K 8<= CK%%' 'CD D s166{((* *DE EIJ J = /s3423q6(;<<=sCHA0E4H5CE H HBG H&/HHHcK ttjtj|k(tjj d}|j |}|j}|syttjtj|k(tjj djtj}|j ||jy#t$r4}tjd|t!dt#|d}~wwxYww)z/ Delete a product by ID (soft delete). NFr8TzError deleting product: zProduct deletion failed: )r rrPrr8rQrqrr rrrrrurvrKrrw)r-rryrrrrs rdelete_productrNs?g$$ LLD    " "4 (  D!++- 7O U $""&&t, Vx0V 1  ;  ? /s344SVH=>>?s6EA0D4E5BDE E/D>>EEslugscK ttjtjj |tj j djtj}|j|}|j|jS#t$r4}tjd|t!dt#|d}~wwxYww)z8 Delete multiple products by IDs (soft delete). NrzError bulk deleting products: zBulk deletion failed: )r rrPrin_r8rQrrrrqrrowcountrurvrKrrw)r-rrrrs rbulk_delete_productsrws< 7O U   '""&&t, Vx0V 1 K(  < 5aS9:1#a&:;;H9H;AHHrc Kt||d{}|jttj tj |k(j }|!ttitjd tjj tjj|k(tjj|j k(}|j||j!ttj tj |k(}|j|j } | ft#| j$ttj tj |k(} |j| |j!t(j5d dd|j,|j6|j.d  ddiS7#t&$rm} t(j+ddd|j,||j.t1| d  ttitj2d t1| zd} ~ wwxYww)zI Delete a product's attachment file by product slug and file id. rNz"The requested file was not found, r)pathz#Could not delete product attachmentcustomerr)rrr[rrrKrzCould not delete attachment, zproduct attachment file deletedrdeletedT)rrqr rrPrrrrrHTTP_404_NOT_FOUNDrr crrrr upload_pathrurvrKr[rrwrrr) r-rrrrrrdryrdel_stmtrs rdelete_attachments_filesrs%66L 6$<--dgg.@ABUUWI118   %  $ * * , 2 2'))11W<'))44 G  1  d|!!$''W"45D!446   F$6$6 7d|))$''W*<=H JJx IIK( KK) "#//(--)11    t {7@   1$&'33 $!-!5!5Q   333c!f<    s7I>HA3I>D;HAI> I;A(I66I;;I>rcKt||d{}|s!ttitjdt j |||jd{}tjj|j|j}|j||j|S77bw)zCreate Product NoterNProduct not foundr)r-rr)note_idr) rrrrHTTP_412_PRECONDITION_FAILED note_services create_noterr!rrrqr)r-rrrrrnoters rrr3s 2D11G ;;'   ** wjmm D&,,.55GJJ6MJJ}IIK K)2 s#CCA C C!A!CCrcKt||d{}|s!ttitjdt j |||d{}|S7I7w)zEdit Customer NoterNrr)r- object_idr)rrrrrrupdate_note_by_id)r-rrrrupdateds r update_noterSsi 2D11G ;;'   "33 'G N2s"A!AAA!AA!A!cKt||d{}|s!ttitjdt t jtt jtjjk(jtjj|jk(jt jj!}|j#|j%j'}|Dcgc]}t)j*|c}S7#cc}ww)z Get Note listrNrr)rrrrrr r'rr!rrrrPrrmrSrorqrrrsr*rt)r-rrrrynotesns r list_noterks 2D11G ;;'    t ,=,?,?,G,G!G H  ""--; < $//&&( )  JJt  $ $ & * * ,E27 8QJ % %a ( 88!2 9s"D>D6DD>D93D>9D>cKt||d{}|s!ttitjdgS7)w)zGet activities listrNrr)rrrrr)r-rrrs r activitiesrsE 2D11G ;;'    I2s ?=*?)NNz -created_atNrT)X__doc__rdtypingrrrrrsqlalchemy.ormr sqlalchemyr r r r sqlalchemy.excr rloggingfastapirrsrc.core.exceptionsrsrc.core.utils.enumsrsrc.core.utils.constantsr src.apps.products.models.productrr src.apps.products.schemas.commonrrrrsrc.helpers.paginationrsrc.apps.base.utils.functionsrsrc.core.configrsrc.apps.files.models.filersrc.apps.files.helper.iorr"src.apps.files.schemas.file_commonr r!*src.apps.merchants.schemas.merchant_commonr""src.apps.users.schemas.user_commonr#r$r%src.apps.products.schemasr&product_note_requestssrc.apps.notes.models.noter'src.apps.notes.schemas.commonr(r)r*src.apps.notesr+rsrc.apps.files.file_servicesr, getLoggerrrvrwintboolrrrrrrrrrrrrrrrsN 33"33)&,01MBmm1>$+MA>E9QG+ 5>   8 $    !! $! C=! # !  ! SM ! ! !! #s(^!D====!== ==Z #$ 66=6= 6=! 6= #$ 6=r&?&? &? &?R<< 9< <