o ;w5h'@sddlZddlZddlZddlZddlZddlZddlmZmZm Z m Z ddl m Z m Z ddlZddlmZeZededdZeeddZedd Zedd Zedd Zd Zd ZeZejedgddgdgde ddZddZde fddZ!ddZ"ddZ#e$defde fddZ%e&deefde fd d!Z'e&d"eefd#ede fd$d%Z(e)d&krej*ed'd(d)dSdS)*N)FastAPIDepends HTTPExceptionstatus)OAuth2PasswordBearerOAuth2PasswordRequestForm)CORSMiddlewarez config.iniDATABASE MYSQL_HOST MYSQL_PORT MYSQL_USERMYSQL_PASSWORDMYSQL_DB@ef7bd031dc150392a94e4aae97ee3e25cafa7ae0b6080964a91bba445d3bd8acHS256*T) allow_originsallow_credentials allow_methods allow_headerslogin)tokenUrlcCstjttttttjjdS)N)hostportuserpassworddatabase cursorclass) pymysqlconnectDB_HOSTDB_PORTDB_USER DB_PASSWORDDB_NAMEcursors DictCursorr'r'6/var/www/html/socialpigeon-dashboard/dashboard-main.pyget_db sr)tokencCsTz tj|ttgd}|WStjyttjddtjy)ttjddw)N) algorithmsz Token expired status_codedetailz Invalid token) jwtdecode SECRET_KEY ALGORITHMExpiredSignatureErrorrrHTTP_401_UNAUTHORIZEDInvalidTokenError)r*payloadr'r'r( verify_token+sr7cCs&t|tr |dd}tt|dS)N,) isinstancestrreplaceintfloatvaluer'r'r(clean_and_format4s  rAcCst|ttfr |Sz9t|}|dr"t|dddWS|dr2t|dddWS|dddr@t|WSWd SYd S) Nkimi@B.r9r) r:r=r>r;lowerstripendswithr<isdigitr?r'r'r( parse_number9s   rKz/login form_datacCst}|}|d|jf|}|r"t|j|ds)t t j dd|d|df|}|s?t t j dd|dt j t jd d d }tj|ttd }d d|ddd|ddd}|S)Nz&SELECT * FROM users WHERE UserEmail=%sUserPasszInvalid credentialsr,z$SELECT * FROM brands WHERE UserId=%sUserIdzBrand not foundBrandIdrF)hours)brand_idexp) algorithmSuccessbeareri super_admin BrandName) access_token token_type expire_in user_type brand_namecoderdata)r)cursorexecuteusernamefetchonebcryptcheckpwrencoderrr4HTTP_404_NOT_FOUNDdatetimeutcnow timedeltar/r1r2)rLdbrarbrand token_payloadr* response_datar'r'r(rHs" z/brand/campaignsc Cst|}|d}t}|}|d|f|}|d|dd|dd|ddd}|d |f|}||D]}t|d trQt |d |d <|d d|d <q@d d ||d d} | S)NrQa SELECT COUNT(DISTINCT ci.CampaignInfoId) AS total_campaigns, IFNULL(SUM(ci.Budget), 0) AS total_budget, IFNULL(SUM(cfb.DepositAmount), 0) AS total_paid, (IFNULL(SUM(ci.Budget), 0) - IFNULL(SUM(cfb.DepositAmount), 0)) AS pending_amount FROM campaigninfo ci INNER JOIN cashflowbrand cfb ON ci.CampaignInfoId = cfb.CampaignInfoId WHERE ci.BrandId = %s total_campaigns total_budget,.0f total_paidpending_amount)rprqrsrtz SELECT CampaignInfoId as CamapignId, CampaignName, Budget, StartDate, EndDate,InfluencerCategory,CampaignType, Audience,SocialMediaPlatforms FROM campaigninfo WHERE BrandId=%s BudgetrTrU)kpis campaignsr^) r7r)rarbrdfetchallcloser:r;r=) r*rmrQrlraresultformatted_resultrwcampaignror'r'r(list_campaignsgs6      r}z/brand/campaigns/{campaign_id} campaign_idc Cst|}|d}t}|}|d||f|}|s$ttjddt|dt r3t |d|d<|dd|d<|d|f| }|D]&}dD]!} t|| t r_||  d d || <t || } t | d || <qLqH|d ||f|} t| d | d <t| d | d <t| d| d<g} |D]}|d} |d|| f|}|r!|dr!|d}|dr|dd ng}|d|f| }g}t|D]E\}}||t|kr||dnd|t|kr||dnd|t|kr||dnd|t|kr||dndd}||q||d<||d<q|d|d|d| d | d|d}dd |d!}||S)"NrQzASELECT * FROM campaigninfo WHERE CampaignInfoId=%s AND BrandId=%sz"Campaign not found or unauthorizedr,rurra SELECT inf.InfluencerID, CONCAT(inf.FirstName, ' ', inf.LastName) AS 'Name', inf.Category,inf.Profilepic, IFNULL(NULLIF(infs.YouTubeFollowers, ''), 0) AS YouTubeFollowers, IFNULL(NULLIF(infs.FacebookFollowers, ''), 0) AS FacebookFollowers, IFNULL(NULLIF(infs.InstagramFollowers, ''), 0) AS InstagramFollowers, IFNULL(NULLIF(infs.TiktokFollowers, ''), 0) AS TiktokFollowers, IFNULL(NULLIF(infs.LinkedInFollowers, ''), 0) AS LinkedInFollowers, IFNULL(NULLIF(infs.TwitterFollowers, ''), 0) AS TwitterFollowers FROM campiagnexecution ce INNER JOIN influencers inf ON inf.InfluencerID = ce.InfluencerID INNER JOIN influencersocialmedia infs ON infs.InfluencerID = inf.InfluencerID WHERE ce.CampaignInfoId = %s )YouTubeFollowersFacebookFollowersInstagramFollowersTiktokFollowersLinkedInFollowersTwitterFollowersr8r9a SELECT IFNULL(SUM(ci.Budget), 0) AS total_budget, IFNULL(SUM(cfb.DepositAmount), 0) AS total_paid, (IFNULL(SUM(ci.Budget), 0) - IFNULL(SUM(cfb.DepositAmount), 0)) AS pending_amount FROM campaigninfo ci INNER JOIN cashflowbrand cfb ON ci.CampaignInfoId = cfb.CampaignInfoId WHERE ci.BrandId = %s AND ci.CampaignInfoId = %s rqrsrt InfluencerIDz SELECT CampaignDetailId, InstagramUrl FROM campaigndetail cd WHERE CampaignInfoId = %s AND InfluencerID = %s InstagramUrlCampaignDetailIdz SELECT ins.Reactions, ins.Comments, ins.Shares, ins.Views FROM insights ins WHERE ins.CampaignDetailId = %s ReactionsrCommentsSharesViews)link reactionscommentssharesviewscampaign_detail_idposts CampaignName CampaignType) campaign_name campaign_typerq amount_paidamount_pending influencersrTrUr^)r7r)rarbrdrrrhr:r;r=rxr<rKrAsplit enumeraterHlenappendry)r~r*rmrQrlrar|r influencerkeyr@ financialsinfluencer_posts influencer_idcampaign_detailrinstagram_urlsinsights posts_dataiurl post_datar`ror'r'r(get_campaign_detailss      r__main__z 127.0.0.1i@)rr)+ configparserrpymysql.cursorsrer/rifastapirrrrfastapi.securityrruvicornfastapi.middleware.corsr ConfigParserconfigreadr r=r!r"r#r$r1r2appadd_middleware oauth2_schemer)r;r7rArKpostrgetr}r__name__runr'r'r'r(sF         1|