CShR.ddlmZddlmZmZddlmZmZmZm Z ddl m Z ddl m Z ddl mZmZddlmZmZddlmZdd lmZdd lmZdd lmZdd l m Z mZ ddedede ede ede ede ede efdZ ddedede ede ede ede ede efdZ ddedede ede ede ede ede efdZ ddedede ede ede ede ede efdZ! ddedede ede ede ede ede efdZ"y ))Session) HTTPExceptionDepends)ListDictAnyOptional)datetime)func)FeedbackTask) TaskResponseSentimentCountResponse) Datasource)Branch)get_db)get_current_user)r timedeltaN branch_iddbsource start_dateend_date min_rating max_ratingc |jtjtj|k(tj|jk(j }|st ddddgd|r|sStjjd}tjtdz jd}|jtjjd tjjtj d k(jd tjjtj d k(jd tjjtj d k(jd tjjtj d k(jd jtj|k(} |r"| jtj"|k(} tj$|d}tj$|d}| jtjj'||} |"| jtj*|k\} |"| jtj*|k} | j-tjj/tjj1} | sdddgdS| D cgc][} | j2jd| j4xsd| j6xsd| j8xsd| j:xsdd]} } ddd| dS#t($rt dddddwxYwcc} w)z Fetch sentiment counts grouped by feedback_posting_date for a given branch. Ensures the branch belongs to the logged-in user. Allows filtering by source, date range, and rating range. F"Unauthorized access to this branchstatuscodemessagedata status_codedetail%Y-%m-%ddaysnamepositivenegativemixedneutral#Invalid date format. Use YYYY-MM-DDr r!r"T'No sentiment data found for this branchr)dater,r-r.r/z.Sentiment analysis data retrieved successfully)queryrfilterruser_idfirstrr todaystrftimerr feedback_posting_datelabelr count sentimentfeedback_sourcestrptimebetween ValueErrorfeedback_ratinggroup_byorder_byallr+r,r-r.r/) rruserrrrrrbranchr6resultsrowsentiment_lists ;/var/www/html/hubwallet-dev/src/apps/feedback/controller.pyfetch_sentiment_countsrNs(XXf  $ $V%5%5%BFNNVZVbVbDb c i i kF #S=akmn  X>>#,,Z8nn&);;EEjQ  HH&&,,V4 H..*<=CCJO H..*<=CCJO H..'9:@@I H..);<BB9M    fX  9 ,-   X55?@ &&z:> $$Xz: X;;CCJPXYZ X55CD X55CDnnX;;<EEhFdFdeiikG @      HH%%j1 ) )YY^!{{'a   N C  G  #S=bc   0 sAN)A O)Oc |jtjtj|k(tj|jk(j }|st ddddgd|r|sStjjd}tjtdz jd}|jtjtj|k(} |r"| jtj|k(} tj|d}tj|d}| jtjj||} |"| jtj"|k\} |"| jtj"|k} | j%t'j(tj*j-} | d k(rd ddgdS| j%t'j(jtj.dk(j1dt'j(jtj.dk(j1dt'j(jtj.dk(j1dt'j(jtj.dk(j1dj } t3| j4xsd | z dzdt3| j6xsd | z dzdt3| j8xsd | z dzdt3| j:xsd | z dzdd} | j=D cgc] \} }| |d }} }d dd|dS#t $rt d dd d d wxYwcc}} w)z Fetch sentiment breakdown percentages for a given branch. Ensures the branch belongs to the logged-in user. Allows filtering by source, date range, and rating range. rFrrr$r'r(r)r0r1r2rTr3r4r,r-r.r/d)r,r-r.r/)r? percentagez*Sentiment breakdown retrieved successfully)r6rr7rr8r9rr r:r;rr r@rAr<rBrCrD with_entitiesr r> feedback_idscalarr?r=roundr,r-r.r/items)rrrHrrrrrrIr6 total_countsentiment_countssentiment_datakeyvalue response_datas rMfetch_sentiment_breakdownr^gsXXf  $ $V%5%5%BFNNVZVbVbDb c i i kF #S=akmn  X>>#,,Z8nn&);;EEjQ  HHX  % %h&8&8I&E FE X55?@ &&z:> $$Xz: X;;CCJPXYZ X55CD X55CD%%djj1E1E&FGNNPKa@     JJL   2 2j @ A G G S JJL   2 2j @ A G G S JJL   2 2g = > D DW M JJL   2 2i ? @ F Fy Q  +449[H3NPQR+449[H3NPQR(..3!{BSH!L*227a;FLaP NCQBVBVBX4>Cc/M ?  _  #S=bc   Vs%AO% P%Pcn|jtjtj|k(tj|jk(j }|st ddddgd|r|s$tj} | tdz } n- tj|d} tj|d} | | z j} |jtjtj|k(} |r"| jtj|k(} | jtjj!| | } |Q|O|d ks |d kDs||kDrt d dd dd | jtj"j!||} | j%t'j(tj*j-} | dk(r dddddgddS| dkr| j%tjj/dt'j(tj*j/dj1tjj3tjj5}n| j%t'j6dtjj/dt'j(tj*j/dj1t'j6dtjj3t'j6dtjj5}t9|}|dkDrt;| |z dnd}|Dcgc]J}| dkr|j<j?dn|j<j?d|j@dL}}ddd| ||ddS#t$rt d dd d d wxYwcc}w)z Fetch review count by feedback_posting_date, average reviews per day, and total reviews. Ensures the branch belongs to the logged-in user. Allows filtering by source, date range, and feedback rating (stars). rFrrr$r(r)r'r0r1r20Invalid rating range. Use values between 1 and 5rTr3z No reviews found for this branch) total_reviewsavg_reviews_per_dayreviews_by_dater5 review_countmonthrQ%B %Y)r5rfz,Review count analysis retrieved successfully)!r6rr7rr8r9rr r:rrArCr*r r@r<rBrDrSr r>rTrUr=rErFrG date_trunclenrVr5r;rf)rrrHrrrrrrI end_date_dt start_date_dt date_diffr6rcre total_daysrdrK review_lists rMfetch_review_countrps"XXf  $ $I%$,,& eg #S=akmn  Xnn& #iR&88  $--j*EM"++HjAK},22I HHX  % %h&8&8I&E FE X55?@ LL77?? {[ \E*"8 >Z!^zJ/F"'Ast  X55==j*UV'' 83G3G(HIPPRM9!"'(#%  B   ..44V< 8//066~F Xh44 5 Xh44 5 SU    )G)GHNNvV 8//066~F Xdoogx/M/MN O Xdoogx/M/MN O SU _%JBLq.% :A>VW#  6?"_CHH%%j1#((J[J[\cJd,, KA*#6*  W "'Afg  Fs,P8AP2P/cn|jtjtj|k(tj|jk(j }|st ddddgd|r|s$tj} | tdz } n- tj|d} tj|d} | | z j} |jtjtj|k(tjd k7} |r"| jtj|k(} | jtj j#| | } |Q|O|d ks |dkDs||kDrt d dd dd | jtjj#||} | j%t'j(tjj+} | s ddddgddS| dkr| j%tj j-dt'j(tjj-dj/tj j1tj j3}n| j%t'j4dtj j-dt'j(tjj-dj/t'j4dtj j1t'j4dtj j3}|Dcgc]T}| dkr|j6j9dn|j6j9dt;|j<ddV}}dddt;| d|ddS#t$rt d dd d d wxYwcc}w)z Fetch average feedback rating by feedback_posting_date and overall average rating. Ensures the branch belongs to the logged-in user. Allows filtering by source, date range, and feedback rating (stars). rFrrr$r(r)r'r0r1r2Nr`rarbTr3z)No feedback ratings found for this branchr)overall_avg_ratingfeedback_ratings_by_dater5 avg_ratingrgrhrQ)r5rtz7Average feedback rating analysis retrieved successfully)r6rr7rr8r9rr r:rrArCr*r rDr@r<rBrSr avgrUr=rErFrGrir5r;rVrt)rrrHrrrrrrIrkrlrmr6rrrsrK feedback_lists rMfetch_feedback_ratingrw@s"XXf  $ $I%$,,& eg #S=akmn  Xnn& #iR&88  $--j*EM"++HjAK},22I HHX  % %i'  D( E  X55?@ LL77?? {[ \E*"8 >Z!^zJ/F"'Ast  X55==j*UV,,TXXh6N6N-OPWWY B&',.   B   ..44V<11288F Xh44 5 Xh44 5 SU !   )G)GHNNvV11288F Xdoogx/M/MN O Xdoogx/M/MN O SU ! ,  6?"_CHH%%j1#((J[J[\cJd2 ML"'(:A">(5  Q "'Afg  @s,P%AP2P/cH|jtjtj|k(tj|jk(j }|st ddddd|r|sStjjd}tjtdz jd}|jtjjtjd k(jd tjjtjd k(jd tjjtjd k(jd tjtj jd jtj|k(} |r"| jtj"|k(} |r^|r\ tj$|d}tj$|d}| jtj&j)||} |Q|O|dks |dkDs||kDrt d dd dd| jtj,j)||} | j } | r| j.dk(r dddddidS| j0xsd| j.z } | j2xsd| j.z } | j4xsd| j.z } | | z d| zzdzdz }t7dt9|ddz}ddddt;|didS#t*$rt d dd ddwxYw)z Calculate the overall sentiment score for a given branch. Ensures the branch belongs to the logged-in user. Allows filtering by source, date range, and feedback rating (stars). rFrr2r$r'r(r)r,r-r.totalr0r1r`rarbrTr3r4sentiment_scorerg?rQrPz'Sentiment score calculated successfully)r6rr7rr8r9rr r:r;rr r>r r?r=rTr@rAr<rBrCrDryr,r-r.maxminrV)rrrHrrrrrrIr6rZ positive_frac negative_frac mixed_fracrzs rMfetch_sentiment_scorersM"XXf  $ $V%5%5%BFNNVZVbVbDb c i i kF #S=ab  X>>#,,Z8nn&);;EEjQ  HH H..*<=CCJO H..*<=CCJO H..'9:@@I 8''(..w7    fX  9 ,-   X55?@h !**:zBJ((:>HLL!?!?!G!G T\!]^E*"8 >Z!^zJ/F"'Ast  X55==j*UV[[]N ^11Q6@&*   $,,1^5I5IIM#,,1^5I5IIM &&+!~/C/CCJ& 5# :JKaOSTTOAs?A67  M "'Afg  s ANN!)NNNNN)#sqlalchemy.ormrfastapirrtypingrrrr r sqlalchemyr src.apps.feedback.modelsr r src.apps.feedback.schemasrrsrc.apps.datasource.modelsrsrc.apps.stores.modelsr src.utils.dbrsrc.apps.auth.controllerrrintstrrNr^rprwrrMrsf"*,,3J1)5( @D@DBFSSS/7}S S08 S S3;3-Sp@D@DBFYYY/7}Y Y08 Y Y3;3-YB! $" $ $xxx SM x  x sm x x x@! $" $ $ttt SM t  t sm t t tx! $" $ $[[[ SM [  [ sm [ [ [|9r