$1idZddlmZmZmZmZmZddlmZm Z m Z m Z m Z m Z mZddlmZddlZddlmZddlmZddlmZmZdd lmZmZmZmZmZmZdd l m!Z!m"Z"dd l#m$Z$m%Z%m&Z&dd l'm(Z(dd l)m*Z+m,Z-m.Z/m0Z1m2Z3m4Z5m6Z7m8Z9m:Z:m;Z;mZ?m@ZAddlBmCZCmDZDmEZEmFZFmGZGddlHmIZImJZJmKZKmLZLmMZMddlNmOZPmQZRmSZTmUZVmWZXddlYmZZZm[Z[ddl\m]Z]m^Z^ddl_m`Z`eZaejecZdeajdeefefe je eddededefdZ,eajdeefefe eddededefdZ@eajdeefefe e e efded ededefd!Z.eajd"eefefe efdedefd#Zieajd$eefefe ee d%d&d%'e dd(d)'e dd*d+'e d,d-d.d/d,0fded1ejd2eefd3eefd4ekdef d5Zleajd6eefefe ee dd7d8'fd9efded:eefdefd;Z*eajd6eefefe efd9efdZ4eajd?eefefe je efd9efd@e"dedeefeffdAZoeajd?eefefe ee d-d-dBd-Ce d,d-dDdEd,0e ddFdGgdHIe ddJdK'e ddLdK'e ddMdN'fd9efdedOekdPekdQeefdReejdSeejdTeefdeefeffdUZpeajdVeefefe efd9efdWekdedeefeffdXZqeajdVeefefe efd9efdWekd@erdedeefeff dYZseajdVeefefe efd9efdWekdedeefeffdZZteajd[eefefe je efd9efd\e%dedeefeffd]Zueajd[eefefe ee d-d-dBd-Ce d,d-dDdEd,0e ddJdK'e dd^d_'e dd`da'e ddbdc'fd9efdedOekdPekdReejdTeefddeefdeeefdeefeffdfZveajdgeefefe efd9efdhefdedeefeffdiZweajdgeefefe efd9efdhefd\e&dedeefeff djZxeajdgeefefe efd9efdhefdedeefeffdkZyeajdleefefe edded9efdefdmZ Customer router for handling customer-related API endpoints. )ListOptionalDictUnionAny) APIRouterDepends HTTPExceptionstatusQueryPathBody)SessionN) get_session) APIException)CustomerSchemaCustomerListSchema)CustomerCreateRequestSchemaCustomerUpdateRequestSchemaCustomerActionRequestSchemaCustomerBulkActionRequestSchemaCustomerFilterSchemaCustomerPaginationSchema) AddressSchemaAddressCreateRequestSchema)CustomerContactSchema"CustomerContactCreateRequestSchema"CustomerContactUpdateRequestSchema)User) get_customercreate_customerget_customers_listget_customer_by_emailupdate_customerdelete_customeractivate_customerdeactivate_customercheck_customer_id_existscheck_account_literal_existsget_customer_activitiesget_customer_summarybulk_customer_actions)create_customer_addressget_customer_addressesget_customer_addressupdate_customer_addressdelete_customer_address)create_customer_contactget_customer_contactsget_customer_contactupdate_customer_contactdelete_customer_contact)get_customer_notescreate_customer_noteupdate_customer_notedelete_customer_noteget_customer_note)NoteResponseSchemaNoteListResponseSchema)NoteCreateRequestSchemaNoteUpdateRequestSchema) generate_id)response_model status_code)dbrD customer_inreturncKt||d{\}}|ttj|d|t |dr|j dS|dS7Hw)ac Create new customer. The system supports two ways to handle account literals: 1. User-provided: Include 'account_literal' field (15 characters) - system will validate uniqueness 2. Auto-generated: Leave 'account_literal' empty - system will generate a unique account literal Use /customers/account-suggestions to get suggested account literals before creation. Note: All validation (email uniqueness, account literal format, etc.) is handled by Pydantic validators. Note: customer_id is for internal use only, account_literal is the public-facing account number. ) customer_dataNrCdetailT model_dumpsuccessmessagedata)create_customer_servicer r HTTP_400_BAD_REQUESThasattrrK)rDrEcustomerrNs W/var/www/html/hwPaymentPortal-be-dev/hw-payment-portal-api/src/apps/customers/router.pyr!r!^sy&6b TTHg33  )0<)H##% OW UsAAA Az/actions)rBaction_requestcK t||j|jd{}|ddk(}|rd|dd|jd}nd |dd |dd }|||d S7:#t$r&}t |j |j d}~wt$r8}tjd|t tjd d}~wwxYww)a Perform bulk actions on multiple customers. Limit- Maximum 10 customers per request for performance optimization. Available actions: - activate: Enable customers and restore soft-deleted ones - deactivate: Disable active customers - delete: Soft delete customers For single customers, pass one ID in the ids array. Returns detailed success/failure results for each customer. )rDaction customer_idsN failed_countrzAll success_countz customers were successfully dzBulk action completed: z succeeded, z failedrLrIz+Unexpected error in bulk customer actions: z:An unexpected error occurred while processing bulk actions) bulk_customer_actions_servicerWidsrr rCrN Exceptionloggingerrorr HTTP_500_INTERNAL_SERVER_ERROR)rDrUresultsoverall_successrNes rTr,r,s&  5!(('++  ".1Q6 W_566STbTiTiSjjklG/0H/IV]^lVmUnnuvG'   (   99     CA3GH==O   sDC%A&A$9A&#C$A&& C/!B C3CCC paginationfiltersc K|jdz |jz}|jdk7r |jnd|_|jdk7r |jnd|_t |||j|dd{}d|d|d|d|d |d|d zdz |d z|d du|d dud |d |d |d |dddS7Kw)z_ Retrieve customers with filtering and pagination using schema-based query parameters. rNT)rDrflimitoffsetpaginaterOtotalpageper_pagenextprevious)rlrmrn total_pageshas_next has_previousfirstlast)rorprtru)rMrOmetalinks)rmrn is_active is_vendorget_customers_list_service)rerfrDrjpagination_results rTr"r"s#oo!Z%8%8 8F.5->->!-C))G-4->->!-C))G9 !! !&)&w/%f-)*5-g69J:9VVYZZ_pq{_||)&1=-j9E  &f-)*5&w/%f-   sA>CC A Cz/account-suggestionscK g}d}d}t|dkrR||krMtd}t||d{s||vr|j||dz }t|dkr||krMt|dkr%tj dt|d|dd d t|d |d d ddddS7#t $r8}tjd|ttjdd}~wwxYww)a0 Generate four unique 15-character account literal suggestions. Returns four automatically generated account literals that are: - Exactly 15 characters long - Follow a consistent pattern - Validated against database for uniqueness - Used as public-facing account numbers rrhrSNzCould only generate z unique suggestions after z attemptsTz Generated z account literal suggestionsz9ACC + 3-char identifier + 6-digit timestamp + 3-char UUIDACCM7X123456ABC)lengthformatexample) suggestions pattern_inforLz&Error generating account suggestions: z&Failed to generate account suggestionsrI) lenr@r)appendloggerwarningr^r`r r ra)rDr max_attemptsattemptsaccount_literalrds rTget_account_suggestionsrs0'   +"x,'>)*5O6b/JJJ"+5&&7 MH+"x,'> { a  NN1#k2B1CC]^j]kktu v#C $4#55QR* Y0!  K.   =aSAB==;   s?C=3B9B71B9*A B96C=7B99 C:3C55C::C=z/summaryFzFInclude vendor statistics: true=vendor summary, false=customer summary) descriptionrz5Start date for summary statistics (YYYY-MM-DD format)z 2024-01-01z3End date for summary statistics (YYYY-MM-DD format)z 2024-12-31 rh2z(Number of top/lowest customers to return)gelerrry date_fromdate_toric6K t||d{}|S7#t$r&}t|j|jd}~wt $rD}t jd|ttjdt|d}~wwxYww)z Get customer summary statistics. Returns summary data including top customers, lowest customers, and most frequent customers. Currently returns static data for demonstration purposes. NrIz!Error fetching customer summary: Internal server error: ) get_customer_summary_servicerr rCrNr^rr`r rastr)rDryrrri summary_datards rTget_customer_summary_endpointrs  9"iHH I   99     8<===,SVH5   s<BB B!A B?BBBz/{customer_id}z]Comma-separated list of related fields to include: addresses, contacts, merchant, attachmentszaddresses,contacts customer_idfieldscK t|||d{}ddt|dr|jdS|dS7(#t$r&}t |j |j d}~wwxYww)z Get customer by ID with optional related fields. By default, no related fields are loaded for better performance. Use the 'fields' parameter to specify which relationships to include. rrNTzCustomer foundrKrLrI)get_customer_servicerRrKrr rCrN)rrDrrSapi_excs rTr r 7s  -bkRXYY'-4X|-LH'')  S[  Z  ++??   ?A2A>#AA2AA2A A/ !A**A//A2customer_updatecK t|||d{}ddt|dr|jdS|dS7(#t$r&}t |j |j d}~wwxYww)z Update customer by ID. )rrHNTzCustomer updated successfullyrKrLrI)update_customer_servicerRrKrr rCrN)rrrDupdated_customerrs rTr$r$Ss  !8ds!tt65<=M|5\$//1  cs  u  ++??   rcfK t||dd{}t||d{}|sttjddd d S7;#t$rP}|jdk(rttj dt|j|j d}~wwxYw7w) z. Delete (soft delete) customer by ID. NrCustomer not foundrI)rzFailed to delete customerTzCustomer deleted successfullyrMrN) rrrCr r HTTP_404_NOT_FOUNDrNdelete_customer_servicerQ)rrDexisting_customerrdrMs rTr%r%js  "6r{[_"``,BKHHG 33.  2 +a   ==C "55+  99   IsBB1AAAB1B/&B1A B,A B''B,,B1z/{customer_id}/addresses address_datacK t|||d{}ddt|dr|jdS|dS7(#t$r&}t |j |j d}~wt$rG}tjd|d|t tjd t|d}~wwxYww) z>Create a new address for a customer with use_as_default=False.NTzAddress created successfullyrKrLrIz$Error creating address for customer : r) r-rRrKrr rCrNr^rr`r rar)rrrDaddressrds rT create_customer_address_endpointr /KNN5,3G\,JG&&(  QX  O   99     ;K=1#NO==,SVH5   GB??=#?B??B?? B<!A)) B<5AB77B<<B?zPage number for pagination)rrrdz"Number of items per page (max 100)zFilter by address typebilling)rshippinglegalmailing)rrenumz>Filter by active status: true=active only, false=inactive onlyTz Filter by default address statusz0Search in address lines, city, state, or countryzNew Yorkrmrn address_typerxuse_as_defaultsearchc K |}|dz |z} t|||| ||||d{} dd| dd| d| d| d | d | d | d | d | dddS72#t$r&} t| j| jd} ~ wt $rG} t jd|d| ttjdt| d} ~ wwxYww)zAGet paginated list of customer addresses with optional filtering.rh)rDrrirjrrxrrNTFound rlz addressesrOrmrnrorprtrurlrmrnrorprtrurMrNrOrvrIz%Error listing addresses for customer rr) r.rr rCrNr^rr`r rar) rrDrmrnrrxrrrirjresultrds rTlist_customer_addressesrs' (h&-#%)   w0 ;6Nv":.v":.v    0   99     <[MA3OP==,SVH5   EC AA1ACA C"!B CACCCz%/{customer_id}/addresses/{address_id} address_idc K t|||d{}ddt|dr|jdS|dS7(#t$r&}t |j |j d}~wt$rJ}tjd|d|d |t tjd t|d}~wwxYww) z,Get a specific address by ID for a customer.NTz Address foundrKrLrIzError getting address  for customer rr) r/rRrKrr rCrNr^rr`r rar)rrrDrrds rTget_customer_address_endpointr ,RjII&,3G\,JG&&(  QX  J   99     -j\ }TVWXVYZ[==,SVH5   GC?=#?C?C? B?!A)) B?5AB::B??Cc K t||||d{}ddt|dr|jdS|dS7(#t$r&}t |j |j d}~wt$rJ}tjd|d|d |t tjd t|d}~wwxYww) z4Update a customer address with partial or full data.NTzAddress updated successfullyrKrLrIzError updating address rrr) r0rRrKrr rCrNr^rr`r rar)rrrrDrrds rT update_customer_address_endpointr /K\ZZ5,3G\,JG&&(  QX  [   99     .zl. UWXYWZ[\==,SVH5   LCA>#ACACA C !A** C6AB;;CCc JK t|||d{dddS7 #t$r&}t|j|jd}~wt $rJ}t jd|d|d|ttjd t|d}~wwxYww) z/Soft delete a customer address with validation.NTzAddress deleted successfullyrrIzError deleting address rrr) r1rr rCrNr^rr`r rar)rrrDrds rT delete_customer_address_endpointr %b+zBBB5   C   99     .zl. UWXYWZ[\==,SVH5   =B#  B# B !A  B ABB  B#z/{customer_id}/contacts contact_datacK t|||d{}ddt|dr|jdS|dS7(#t$r&}t |j |j d}~wt$rG}tjd|d|t tjd t|d}~wwxYww) z$Create a new contact for a customer.NTzContact created successfullyrKrLrIz$Error creating contact for customer rr) r2rRrKrr rCrNr^rr`r rar)rrrDcontactrds rT create_customer_contact_endpointr3rrz9Search across contact name, email, title, or phone numberjohnz+Filter by contact job title (partial match)ManagerzFilter by contact relation typeprimarytitlerelationc K |}|dz |z} t|||| ||||d{} dd| dd| d| d| d | d | d | d | d | dddS72#t$r&} t| j| jd} ~ wt $rG} t jd|d| ttjdt| d} ~ wwxYww)z@Get paginated list of customer contacts with optional filtering.rh)rDrrirjrxrrrNTrrlz contactsrOrmrnrorprtrurrrIz$Error listing contacts for customer rr) r3rr rCrNr^rr`r rar) rrDrmrnrxrrrrirjrrds rTlist_customer_contactsrNs' (h&,#   w0 :6Nv":.v":.v    0   99     ;K=1#NO==,SVH5   rz$/{customer_id}/contacts/{contact_id} contact_idc K t|||d{}ddt|dr|jdS|dS7(#t$r&}t |j |j d}~wt$rJ}tjd|d|d |t tjd t|d}~wwxYww) z4Get a specific contact by contact_id for a customer.NTz Contact foundrKrLrIzError getting contact rrr) r4rRrKrr rCrNr^rr`r rar)rrrDrrds rTget_customer_contact_endpointrrrc K t||||d{}ddt|dr|jdS|dS7(#t$r&}t |j |j d}~wt$rJ}tjd|d|d |t tjd t|d}~wwxYww) z4Update a customer contact with partial or full data.NTzContact updated successfullyrKrLrIzError updating contact rrr) r5rRrKrr rCrNr^rr`r rar)rrrrDrrds rT update_customer_contact_endpointrrrc JK t|||d{dddS7 #t$r&}t|j|jd}~wt $rJ}t jd|d|d|ttjd t|d}~wwxYww) z/Soft delete a customer contact with validation.NTzContact deleted successfullyrrIzError deleting contact rrr) r6rr rCrNr^rr`r rar)rrrDrds rT delete_customer_contact_endpointrrrz/{customer_id}/activitiesc<K t||d{}|S7#t$r&}t|j|jd}~wt $rG}t jd|d|ttjdt|d}~wwxYww)z Get customer activities. Returns a list of activities for the specified customer. Currently returns static data for demonstration purposes. NrIz'Error fetching activities for customer rr) get_customer_activities_servicerr rCrNr^rr`r rar)rDractivities_datards rTr*r*s  ?K PPQ   99     >{m2aSQR==,SVH5   s=BB B!A BABBBz/{customer_id}/noteszGet Customer Notesz8Retrieve paginated list of notes for a specific customerz2Paginated list of customer notes with user detailsNotes retrieved successfullyzapplication/jsonrz)Customer called regarding payment inquiryz2025-12-02T15:30:00.000ZAdminrzadmin@example.com)id first_name last_nameemail)rr created_at updated_at deleted_at created_by_id created_by)rlrmrnrorp)rMrNrOre)rcontentrrInternal server error)r)rBsummaryrresponse_description responses.zCustomer ID (customer_id field)ACCKDU1537895E7z&Number of items to skip for paginationz2Search term to filter notes by description contentpaymentrjc rK t|||||d{}dd|d|d|d|d|d |d |d |d d ddS7,#t$r&}t|j|jd}~wt $r8}t jd|ttjdd}~wwxYww)a Get paginated list of notes for a specific customer. Returns paginated notes associated with the customer, ordered by creation date (most recent first). Each note includes full details of the user who created it. **Features:** - Pagination support with configurable page size - Search functionality in note descriptions - Full user details for note creators - Ordered by creation date (newest first) **Parameters:** - **customer_id**: The customer's unique identifier - **limit**: Number of notes per page (1-100, default: 10) - **offset**: Number of notes to skip (default: 0) - **search**: Optional search term to filter notes )rirjrNTrrOrlrmrnrorprtrurr)rMrNrOrerCrIz(Unexpected error in get_customer_notes: r) get_customer_notes_servicerr rCrNr^rr`r ra)rrirjrrDrrrds rTr7r7sL 1  5  56Nv":.v":.v   $  ++??     ?sCD==*   sDB7AA+AB7A B4!A00 B4<3B//B44B7zCreate Customer Notez)Create a new note for a specific customerz+Note created successfully with full detailsNote created successfullyrLz&Invalid input data or validation error)rr)rBrCrrrrz7Note creation data with description (1-2000 characters))r note_datachK tddddd}t||||d{}dd |jd d S7#t$r&}t |j |j d}~wt$r8}tjd |t tjd d}~wwxYww)a Create a new note for a customer. Creates a new note associated with the specified customer. The note will be attributed to the currently authenticated user. **Features:** - Automatic user attribution to authenticated user - Description validation (1-2000 characters) - Customer existence validation - Returns full note details with user information **Request Body Example:** ```json { "description": "Customer called regarding payment inquiry and requested status update" } ``` **Authorization Required:** Valid JWT token (currently uses placeholder user ID) rhtemp@example.com temp_userTemprrrusernamerrNTrrrMrNrOrCrIz*Unexpected error in create_customer_note: r) rcreate_customer_note_servicerKrr rCrNr^rr`r ra)rrrDcreated_by_usernoterrds rTr8r8XsD $   2  Y  2OO%      ++??     A!EF==*   sAB2!A?AB2A B/ !A++ B/73B**B//B2z/{customer_id}/notes/{note_id}zGet Customer Notez(Get a specific note by ID for a customerz"Note details with user informationzNote found successfully Note foundzCustomer or note not foundzNote ID to retrievenote_idcFK t|||d{}dd|jddS7#t$r&}t|j|j d}~wt $r8}tjd|ttjdd}~wwxYww) a Get a specific note by ID for a customer. Returns full details of the specified note, including the user who created it. **Features:** - Full note details with user information - Customer and note existence validation - Soft-delete awareness (won't return deleted notes) **Parameters:** - **customer_id**: The customer's unique identifier - **note_id**: The note's unique ID to retrieve NTr rrrIz'Unexpected error in get_customer_note: r) get_customer_note_servicerKrr rCrNr^rr`r ra)rr rDr rrds rTr;r;sn .r;HH#OO%   I  ++??     >qcBC==*   s<B!0.0B!0 B!A B&3BBB!zUpdate Customer Notez&Update an existing note for a customerz+Note updated successfully with full detailsNote updated successfullyzWUpdated note: Customer called regarding payment inquiry and provided additional detailsz2025-12-02T16:15:00.000Z)rrrrzNote ID to updatez5Note update data with description (1-2000 characters)cjK tddddd}t|||||d{}dd |jd d S7#t$r&}t |j |j d}~wt$r8}tjd |t tjd d}~wwxYww)a Update an existing note for a customer. Updates the specified note with new data. Only the user who created the note or admin users should be able to update it. **Features:** - Description validation (1-2000 characters) - Customer and note existence validation - Automatic timestamp update - Full note details in response **Request Body Example:** ```json { "description": "Updated note: Customer called regarding payment inquiry and provided additional details" } ``` **Authorization Required:** Valid JWT token (currently uses placeholder user ID) **Permissions:** Note creator or admin users rhrrrrrNTrrrrIz*Unexpected error in update_customer_note: r) rupdate_customer_note_servicerKrr rCrNr^rr`r ra)rr rrDupdated_by_userr rrds rTr9r9sF $   2  Wi  2OO%      ++??     A!EF==*   sCB3"AAAB3A B0 !A,, B083B++B00B3zDelete Customer Notez!Soft delete a note for a customerzNote deleted successfullyzNote ID to deletecBK tddddd}t||||d{}|S7#t$r&}t|j|j d}~wt $r8}tjd |ttjd d}~wwxYww) a Delete a note for a customer. Soft deletes the specified note (sets deleted_at timestamp). Only the user who created the note or admin users should be able to delete it. **Features:** - Soft delete (preserves data with deleted_at timestamp) - Customer and note existence validation - Returns success confirmation **Parameters:** - **customer_id**: The customer's unique identifier - **note_id**: The note's unique ID to delete **Authorization Required:** Valid JWT token (currently uses placeholder user ID) **Permissions:** Note creator or admin users **Note:** This is a soft delete operation - the note will be marked as deleted but data is preserved in the database. rhrrrrrNrIz*Unexpected error in delete_customer_note: r) rdelete_customer_note_servicerr rCrNr^rr`r ra)rr rDdeleted_by_userrrrds rTr:r:msd $   4  Wo      ++??     A!EF==*   s<B!.,.B. B!A B$3BBB)z__doc__typingrrrrrfastapirr r r r r rsqlalchemy.ormrr_src.core.databasersrc.core.exceptionsr*src.apps.customers.schemas.customer_commonrr,src.apps.customers.schemas.customer_requestsrrrrrrsrc.apps.base.schemas.commonrr+src.apps.customers.schemas.customer_contactrrrsrc.apps.users.models.userrsrc.apps.customers.servicesr rr!rPr"rzr#get_customer_by_email_servicer$rr%rr&activate_customer_servicer'deactivate_customer_servicer(r)r*rr+rr,r\#src.apps.customers.address_servicesr-r.r/r0r1#src.apps.customers.contact_servicesr2r3r4r5r6src.apps.notes.servicesr7rr8rr9rr:rr;r "src.apps.notes.schemas.note_commonr<r=$src.apps.notes.schemas.note_requestsr>r?src.core.functionsr@router getLogger__name__rpostrHTTP_201_CREATEDgetrboolintrputdeleterrrdictrrrrrrrrTr7s43PPP"),S ," +    8 $RS#XFB+&3 3 3 C3 lJtCH~6+&E/wBGH$T7nyE F"45juABraB4^hjk    } c]      7 : T#s(^<+&!$5T^rs    SM   = 6 T#s(^<+&  0     = ,S#X?+&!!! !@!J 'S#XTZTkTkl+&  ,    #s(^  m 4 &tCH~F+&aA+GQRS"s8\fhi"':R\emX#Y %d8xCG!H%*4=_im%n!$4fpz{2 2 2  2  2 3- 2 ~ 2 TN2  SM2  #s(^2 G2 j 3DcNS+&      #s(^  T 4 3DcNS +&         #s(^  T 66tCQTH~V+&      #s(^  W 4 &tCH~SYSjSjk+&  4    #s(^  l 4 %d38nE+&aA+GQRS"s8\fhi %d8xCG!H!$4oyA 3`jst#D6Wajk2 2 2  2  2 ~ 2 SM 2  C=2 sm2  #s(^2 F2 j 24S>R+&      #s(^  S 4 24S>R +&    5     #s(^  S 65d3PS8nU+&      #s(^  V 2 'S#XG+&     H 8S> JM:"#'#A'(/Z.H.H.212*+2917-@ /" !"&'$%(*$((, '' %! D1 24 5I%  ,\C-NXijraC5Ycefa-U_`a!$4hr{|+& 6 6 6  6  SM 6  6  #s(^ 6 [,Z6 rS>'' ";F7"#'#>"#+V*D*D*.-.&'.5-3)< + ! % 2E F1 24 59 %NC-NXij)-c?x)y+&; ; &;  ;  #s(^ ; M%L; |$S> :=5"#'#/"#+V*D*D*.-.&'.5-3)< + ! % 29 :4 57  #JC-NXij)>J+&% % %  %  #s(^ % I#H% P$S> "8F7"#'#>"#,E*D*D*.-.&'.5-3)< + ! % 2E F9 :4 59  $LC-NXij) "347"#'#> $ %  9 :4 5 0C-NXij)