I'jy7\ UddlmZddlmZmZmZmZmZddlmZddlm Z ddl m Z m Z m Z ddl mZddlmZddlmZdd lmZdd lmZmZdd lmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)dd l*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3ddl4m5Z5m6Z6m7Z7m8Z8eddgZ9iZ:e;ee&ffe?d<dldZ@dedeAdeAdeBefdZCe9jde&de9jde&deeeeedded d!d"#edd$%ed&dd'#fded(edeAdeAd)edzd*eAf d+ZEe9jd,eBe'd-eeeeedded d!d"#ed.dd'#fded(edeAdeAd*eAf d/ZFe9jd0e'd1e9jd2e'd3e9jd4e'd5ed6d!d78eeeefd9eAded(efd:ZGe9jd;e'ej<eeeefd=e$ded(efd>ZJe9jd?e'@eeeefd=e#ded(efdAZKe9jdBe'dCeeeefd=eded(efdDZLe9jdEe'dFeeeefd=eded(efdGZMe9jdHedIeeeeedded d!d"#eddJ%edKdL%fded(edeAdeAdMeall)r<r=r>s r: _fetch_usersrG<sN  $//&&($'',,. 9  u  r9z /list-userszList users (paginated))response_modelsummaryz/get-all-usersz-Get all users (paginated, same as list-users))ge2i)rJlez+Filter by role (e.g. user for members only)) description i,_role cache_secondsc\|xsdd|d|}|dkDr+tj|}|r|\}} t|kr| S|jt} |"| j tj |k(} | j} | jttjjtjjtjjtj ttj"j%tj&j)tj*j)j-|j/|j1} ddlm} | Dcgc]}|j*}}t7||}| |}t9| | Dcgc]*}t;||||j|j*,c}} |dkDrt|z| ft|<| Scc}wcc}w)NrF:r)_load_programme_levels_ordered)r<programme_levelspoints)totalusers)r3getrr@rfilterrQcountoptionsr programme_sessionr weekr moduler levelprogramme_assessmentrArBrCrDrEr>rFapp.services.user_track_servicerUrr!r()r<rPr=r>rQrR cache_keycached expires_atpayload base_queryrXrYrUuidspoints_by_userrVs r: list_usersrlFs$=5/4&%1Iq"&&y1 "( Jv "$J &&tyyD'89    E  // 0 \*// 0 \-.. / \/// 0 22 3   $//&&($'',,. 9  u  O A144C 1"c:N5b9$    )b+;NDVDVWXW[W[D\   Gq(,(>'H)$ N  s H$/H) z/get-all-users-lightz3Get users (very fast: no programme/progress/points)cd|d|}|dkDr+tj|}|r|\}}t|kr|S|jtj tj jtjjj|j|j} | D cgc] } t| }} |dkDrt|z|ft|<|Scc} w)Nzlight:rTr) r3rZrr@rrArBrCrDrEr>rFr)) r<rPr=r>rRrdrerfrgrYris r:list_users_lightrosaw'Iq"&&y1 "( Jv "  $//&&($'',,. 9  u   ;@@%Q-a0%G@q(,(>'H)$ NAsC7z /get-userz#Get one user by id (query: user_id)z/get-user-dataz*Get one user by id (query: user_id, alias)z/member-personal-infoz@Get member personal info including phone_number (query: user_id).zUser primary key)rJrNuser_idc|jt|}|sttjdt ||S)NUser not found status_codedetail)rZrrrHTTP_404_NOT_FOUNDr')rpr<rPris r:get_userrws8( tWA (A(AJZ[[ !!R ((r9z /create-user)rHrtbodycP|jtjtj|jk(j rt t jdtt|j|jt|j|jjdk(rtjntj |j"}|j%||j'|j)|t+||S)NzEmail already registeredrsadmin)email full_namehashed_passwordrQ is_active)r@rr[r{firstrrHTTP_409_CONFLICTstrr|r#passwordrQvaluerrzuserr~addcommitrefreshr'rxr<rPris r: create_userrs xx~TZZ4::56<<>(@(@Icdd $**o..%dmm4#yy'9X^^x}}..  AFF1IIIKJJqM !!R ((r9z /update-user)rHcx|jt|j}|sttj d|j |j |j k7r|jtjtj |j k(jrttjdt|j |_|j|j|_ |j|j|_ |jrt|j|_|j">|j"j$dk(rt&j(nt&j*|_|j-|j/|t1||S)Nrrrs Email in userz)rZrrprrrvr{r@r[rrrr|r~rr#r}rQrrrzrrrr'rs r: update_userrs# tT\\"A (A(AJZ[[ zz$**"7 88D> tzz!9 : @ @ BF,D,D^\ \djj/ ~~!nn  ~~!nn  }})$--8 yy#'99??g#=8==IIKJJqM !!R ((r9z/update-member-accountz/Admin update member email and/or reset passwordc^|j'|jttjd|j t |j}|sttjd|jtjk7rttjd|jt|j}||jk7r|jt jt j|k(t j|jk7j!}|rttj"d||_|jt%|j|_|j)|j+|t-||S)Nz Send email or password to updaterszMember not foundzTarget account is not a memberr)r{rrrHTTP_400_BAD_REQUESTrZrrprvrQrrrr@r[rDrrr#r}rrr')rxr<rPmember new_emailexistings r:update_member_accountrs; zzdmm3335  VVD$,, 'F (A(AJ\]] {{hmm#(C(CLlmm zz O  $xx~,,TZZ9-DdggQWQZQZFZ[aacH#0H0HQ_``$FL }} !.t}}!=IIKJJv !&" --r9z/update-member-personal-infozXUpdate member personal info (name, phone_number, level, module, week, Google Drive link)c2t||}t||Sr6)r,r'rxr<rPrs r:!update_member_personal_info_routers 'r4 0D !$ ++r9z/list-member-google-drive-linkszMList members with Google Drive links for WhatsApp video submission managementzFilter by member name or emailrFzall | with_link | without_linksearch link_statusc t|||||\}}|Dcgc]!}tjt||#} }t || Scc}w)N)r=r>rr)rXmembers)r&rmodel_validater*r) r<rPr=r>rrrrXm serializeds r:$list_member_google_drive_links_routersl 5  NGUA "001TUVXZ1[\ )uj II s&A z/member-google-drive-linkz=Get one member's Google Drive link and programme week contextcXt||}tjt||Sr6)r$rrr*)rpr<rPrs r:"get_member_google_drive_link_router=s+ R )D $ 3 34WX\^`4a bbr9z /update-member-google-drive-linkz:Attach or update a member's personalized Google Drive linkct||j|j}tjt ||Sr6)r+rpgoogle_drive_linkrrr*rs r:%update_member_google_drive_link_routerKs7 +2t||T=S=S TD $ 3 34WX\^`4a bbr9z/update-user-programmez>Assign programme level, module, week, and session for a memberc2t||}t||Sr6)r%r'rs r:update_user_programme_routerYs !T *D !$ ++r9z/list-member-inactive-followupszPList members inactive for N days (Need Follow-Up tab). Syncs table on each call.imzDays without activity)rJrMrNTz/Rebuild inactive follow-up table before listing inactive_dayssyncc t|||||\}}}t|||D cgc]} tj| c} Scc} w)N)rr=r>r)rXrr)r.rrr) r<rPrr=r>rrrXdaysrs r:$list_member_inactive_followups_routergsY: -d%dGUD .FMNg*99!|j|jk(rttjd|j t |j}|sttjd|j||jtdS)NzCannot delete yourselfrsrrz User deletedr) rprDrrrrZrrvdeleterr)rxr<rzris r: delete_userrsp ||uxx(C(CLdee tT\\"A (A(AJZ[[IIaLIIK > **r9)r4N)Wrfastapirrrrrsqlalchemy.ormr r app.programme.models_programmer r r rapp.services.admin_servicer app.databaserapp.dependenciesr app.modelsrr app.schemasrrrrrrrrrrrrr r!r" app.securityr#!app.services.admin_member_servicer$r%r&r'r(r)r*r+r,-app.services.member_inactive_followup_servicer-r.r/r0routerr3dictrtuplefloat__annotations__r;intlistrGrZrlrorwpostHTTP_201_CREATEDrrrrrrrrboolrrrrr8r9r:rsuDD"'[[9C0%"'    (- 9EG4U5*@#@AABGWCT ) $  ) ;  &/)*aAraC(!$4abraC0 22 2 2  2 T/ 2  2  2j # A  &/)*aAraC(raC0         8 1   8   N  0BC&/)*) )) )   )^JFD[D[\077SfKg )j )g )D )] ) ^J7&/)*) )) )8)2 = &/)*. ).. .  .B" f &/)*, .,, ,  ,%0 [  &/)*aAraC(t1QR 4 JJ J J  J $J J  J  J2, K  #&/)*c cc c  c&, H &/)*c -cc c  c L &/)*, $,, ,  ,%5 ^  &/)*4sPghaAraC(t)Z[          $% K  &/)*4sCii ii  i* B &/)*7 -77 7  7^G43:6?RYZmRn+m++4+5+r9