o hS)@sddlZddlZddlZddlZddlmZmZmZmZddl m Z ddl m Z m Z mZmZddlmZddlZddlmZddlmZmZejejdeeZGd d d e ZGd d d e ZGd dde ZGddde Z Gddde Z!Gddde Z"Gddde Z#Gddde Z$Gddde Z%Gddde Z&edddd Z'e'j(ed!gd"d!gd!gd#e')d$d%d&Z*e'j+d'e$d(d)e!d*efd+d,Z,e'j+d-ed(d)ed*efd.d/Z-ddl.Z.e'j+d0e&d(d)e%d*efd1d2Z/d3d4Z0d5e1fd6d7Z2dS)8N)FastAPI HTTPExceptionBackgroundTasksstatus) BaseModel)DictListAnyOptional)CORSMiddleware)StreamingResponse)ManagerCareerGuidanceRequestManagerCareerGuidanceResponse)levelc@s&eZdZUeed<eed<eed<dS)Skillskill_id skill_type skill_nameN__name__ __module__ __qualname__str__annotations__rrE/var/www/eduai.edurigo.com/my_career/production/my_career_fast_api.pyrs  rc@s2eZdZUdZeeed<dZeee ed<dS) JobProfileNjob_profile_namejob_profile_skills) rrrrr rrrrrrrrrrs rc@sfeZdZUeed<eed<eed<dZeeed<gZe eed<gZ e eed<gZ e e ed<dS) UserInfo user_name managerId designationN jobProfileassignedCoursescompletedCoursesskills) rrrrrr#r rr$rr%r&rrrrrr s rc@s>eZdZUeed<eed<eed<eed<gZeeed<dS)CoursecourseIdnameshort_description descriptionr&N)rrrrrr&rrrrrrr')s r'c@sBeZdZUeed<eed<eeefed<eeee fed<dS)CareerGuidanceRequest client_id user_query user_dataclient_all_courses_dataN) rrrintrrrrrr'rrrrr,0s r,c@s6eZdZUeed<eed<eed<eed<eed<dS)RecommendedCourser( courseName matchScorereasonscenario_relevanceNrrrrrr26s  r2c@seZdZUeed<eed<eed<eed<eed<eed<eed<eed<d Zeed <eed <eed <eed <dZ e eed<dS) OnlineCourser(r3platform instructordurationr4r5scoreTisOnlineCourseurltype lastUpdatedN thumbnail) rrrrrr1floatr<boolr@r rrrrr7=s  r7c@seZdZUeed<eeed<gZeee ed<dZ ee ee fed<dZ ee ee fed<dZee ee fed<eed<dS) CareerGuidanceResponseanswerrecommended_coursesonline_course_recommendationsNskill_gap_chartjob_profile_analysiscareer_context token_count)rrrrrrr2rFr r7rGrr rHrIr1rrrrrCMs   rCc@s6eZdZUeed<eed<eeefed<eed<dS)PlatformCourseRequestr-r.r/ platform_nameN)rrrr1rrrrrrrrrKVs  rKc@seZdZUeeed<dS)PlatformCourseResponserFN)rrrrr7rrrrrrM\s rMzCareer Guidance APIzCAPI for career guidance recommendations using Ollama with Gemma 12Bz1.0.0)titler+version*T) allow_originsallow_credentials allow_methods allow_headers/cs dddS)NzAPI is runningz)Welcome to Career Guidance production API)rmessagerrrrrrootns rWz/career-guidance)response_modelrequestbackground_tasksc sz|}tjdddd}|j}t|||t| Wdn1s-wYzt j dd|gdddd}|j }td |z1|d }|d d }|d kru||kru|||} t| } d| vrtd | d<nttjddWntjy} zttjddd} ~ ww|t|| dd| dg| dg| di| di| di| dd d} | WWSt jy} z ttjd| jdd} ~ wwty} z ttjdt| dd} ~ ww)Nw+.jsonFmodesuffixdeletepython3z my_career.pyTcapture_outputtextcheckzScript output: {}rrJ$No valid JSON found in script output status_codedetailFailed to parse script outputrDrErFrGrHrI)rDrErFrGrHrIrJError executing Python script: Unexpected error: )dicttempfileNamedTemporaryFiler)jsondumpflushosfsyncfileno subprocessrunstdoutstriploggerinfofindrfindloadsrrHTTP_500_INTERNAL_SERVER_ERRORJSONDecodeErroradd_taskcleanup_temp_filegetCalledProcessErrorstderr Exceptionr) rYrZpayloadtmp_filetemp_file_pathresultoutput json_startjson_endjson_str response_dataefinal_response_datarrrget_career_guidancers~                rz/career-guidance-managerc sz|}tjdddd}|j}t|||t| Wdn1s-wYzbt j dd|gdddd d }|j }z)|d }|d d }|dkrf||krf|||} t| } nttjddWntjy} zttjddd} ~ ww|t|d| vrd| d<| WWSt jy} z ttjd| jdd} ~ wt jyttjddwty} z ttjdt| dd} ~ ww)z Advanced career guidance endpoint specifically designed for managers. Provides comprehensive team analysis, management insights, and strategic recommendations. Now includes total token count in the response. r[r\Fr]Nraz$manager_career_guidance_processor.pyTx)rcrdretimeoutrfrgrhrrirjrm total_tokensz)Error executing manager guidance script: z/Request processing timed out. Please try again.rp)rqrrrsr)rtrurvrwrxryrzr{r|r}rrrrrrrrrrrTimeoutExpiredHTTP_408_REQUEST_TIMEOUTrr) rYrZrrrrrrrrrrrrrget_manager_career_guidancesv        rz/fetch-platform-coursesc stz|}tjdddd}|j}t||Wdn1s"wYt}|dt d|IdH}|j }z)| d}| dd} |d kr\| |kr\||| } t| } ntd |d Wntjyrtd d d wd| dgi} |t|| WStjy} ztd dt| dr| jnt| d d} ~ wty} z td dt| d d} ~ ww)Nr[r\Fr]z5my_career_fetch_particular_platform_online_courses.pyrfrgrhrzNo valid JSON foundizError parsing JSON outputrjrFrorrp)rqrrrsr)rtruasyncioget_event_looprun_in_executorexecute_subprocessr|r}rrrrrrrrrzrhasattrrrr) rYrZrrrlooprrrrrrrrrrfetch_platform_coursess@       &rcCstjd||gdddd}|S)NraTrb)rzr{) script_pathrrrrrr#sr file_pathcCs8ztj|rt|WdSWdStyYdSw)N)rwpathexistsunlinkr)rrrrr,s  r)3rzrtrrrwfastapirrrrpydanticrtypingrrr r fastapi.middleware.corsr loggingfastapi.responsesr manager_career_guidance_modelsr r basicConfigINFO getLoggerrr~rrrr'r,r2r7rCrKrMappadd_middlewarerrWpostrrrrrrrrrrrs\         FC #