ڵ1i/ddlZddlZddlZddlmZmZmZmZddlm Z ddl m Z ddl m Z ddl mZddlmZdd lmZe ej&ej( ej*eZGd d Zy) N)ListTupleDictAny) load_dotenv)datetime)CVStorageService)ResumeParserService)JobMatchingService) JobAPIService)levelceZdZdZdZdedeeeffdZde dededefdZ d e e e efdeeeffd Z d e e e efdedeeeffd Zd e e e efdefd Zy )ResumeUploadServicez?Service for handling resume uploads with background AI analysisc^t|_t|_t |_yN)r resume_parserr job_matching_servicer job_api_service)selfs B/var/www/html/drjob-dev/drjob-ai/services/resume_upload_service.py__init__zResumeUploadService.__init__s"02$6$8!, job_emp_idreturnc" |jj|}|jdsdd|d|jdddS|jdi}t|tr dd|d dSt|t rbd |vr|d }|jd d xs:|jd d xs&|jdd xs|jdd }|s dd|ddSddiS#t $r}ddt|dcYd}~Sd}~wwxYw)z Validate job_emp_id by checking if job exists using JobAPIService Args: job_emp_id: The employer job ID to validate Returns: Dict with validation result successFzInvalid job_emp_id: z - errorz Job not foundvalidrdataz% - Job ID not found or does not existjob job_titletitleposition job_positionz# - Job data incomplete or corruptedr TzError validating job_emp_id: N)rget_employer_jobget isinstancelistdict Exceptionstr)rrresultjob_datar#es rvalidate_job_emp_idz'ResumeUploadService.validate_job_emp_idsL* )):::FF::i("3J.doc.pdf.docxc3\K|]#}jj|%ywr)lowerendswith).0extr4s r z:ResumeUploadService.validate_file_types..s#T#x~~'005Ts),FzFile z; is not supported. Only PDF and Word documents are allowed.rr T)any)rrSallowed_extensionsr3r4s @rvalidate_file_typesz'ResumeUploadService.validate_file_typesxsT7&0  "L(TASTT"$XJ.ij rc tj|j||fd}|jdd|t |ddS#t $r9}t jdt|dt|dcYd }~Sd }~wwxYw) a Start background processing for resume uploads Args: files_data: List of (file_content, filename) tuples job_emp_id: The employer job ID Returns: Dict with processing start confirmation T)targetargsdaemonz&Resume processing started for job ID: processing_started)rmessage total_filesstatusz"Error starting resume processing: F)rrN) threadingThread_background_resume_processingstartlenr-rIrr.)rrSrthreadr1s rprocess_resume_uploads_asyncz0ResumeUploadService.process_resume_uploads_asyncs %%99 *-F LLN CJ<P":.    LL=c!fXF G Q  sAA B .BB B c  tjd|dt|t}d}|D]\}} tjd||j |||}|stj d|Ntjd| |j j||}tjd|d|r t|nd|r|jd k(rtj d |dtjd| |j j|} tjd|| rntjd| |j||| ||} tjd|d | jd| jdr| d}tjd|tjd| |jj||| d}tjd|d |jdjdrtjd||dz }notj d |d |jd!nDtj d"|d | jd!ntj d#|d$tjd&|d'|d(t|d)y #t$r/} tj d |d t| Yd } ~ d } ~ wwxYw#t$r/} tj d|d t| Yd } ~ Jd } ~ wwxYw#t$r/} tj d|d t| Yd } ~ d } ~ wwxYw#t$r/}tj d|d t|Yd }~d }~wwxYw#t$r/}tj d%|d t|Yd }~d }~wwxYw#t$r.}tj d*|d t|Yd }~y d }~wwxYw)+a` Background function to: 1. Parse and store resume files 2. Generate AI analysis (strengths, weaknesses, matching_percentage) 3. Store results in screenings collection with type=3 Args: files_data: List of (file_content, filename) tuples job_emp_id: The employer job ID z2Starting background resume processing for job ID: z , files: rzProcessing file: zFailed to save file: r<zText extraction successful for z , length: zText extraction failed for r=Nr$z"Could not extract text from file: z - empty contentzStarting resume parsing for zResume parsing successful for zResume parsing failed for zStarting database storage for )r4raw_text parsed_datarrOzDatabase storage completed for rzDatabase storage failed for jobseeker_idz2Successfully stored resume data for jobseeker ID: z'Starting AI analysis for jobseeker ID: )rrsrr analysis_typez(AI analysis completed for jobseeker ID: z'AI analysis exception for jobseeker ID z5Successfully completed AI analysis for jobseeker ID: r z%AI analysis failed for jobseeker ID: rzStorage failed for file zParsing failed for file z: No data returnedzError processing file z(Resume processing completed for job ID: z. Successfully processed /z files.z1Error in background resume processing for job ID )rIrJrmr rRrrextract_text_from_filer-r.strip parse_resumestore_complete_cv_datar)r#analyze_single_candidate_for_upload)rrSr cv_storageprocessed_countr3r4saved_file_pathextracted_text extract_errorrr parse_errorstorage_result storage_errorrsai_analysis_resultai_errorr1s rrkz1ResumeUploadService._background_resume_processings] e KKLZLXabefpbqars t)+JO*4R & hQKK"3H: >?'+&=&=lHV`&aO* 'xj IJ!&*&8&8&E&En&U  &DXJ$OP # &DXJ$OP %-7-N-N)1)7,7+5*9 .O.N#KK*I(SUVdVhVhirVsUt(uv *--i8+9.+IL"KK*\]i\j(kl#KK*QR^Q_(`a x595N5N5r5r/91=0;23 6s6" 2 !' .VWcVddfgyg}g}HhIgJ-K!L 255i@ & .cdpcq,r s /1 4 & /TUaTbbdewe{e{}DfEeF.G!H"LL+CH:RP^PbPbcjPkOl)mn '?zI[%\]]R h KKB:,Nghwgxxyz}I{JzKKRS TI%! 'B8*BsS`OaNb%cd !%! 'A(2cR]N^M_%`a !" )%"LL+GzQSTWXeTfSg)hi$%&$-x & /VWcVddfgjksgtfu-v w wx!LL#9(2c!fX!NO  e LLLZLXZ[^_`[aZbc d d es9P7AO<P7O<AL.O< P7O<'3M O<6AN6AO<=A OBO<$+P7 M$M=O<P7MO< N$M>8O<<P7>NO< N>$N93O<7P79N>>O< O9 $O4.O<4O99O<< P4$P/)P7/P44P77 Q.$Q))Q.N)__name__ __module__ __qualname____doc__rr.rrr2bytesrRrrr`rorkrrrrsI/ 4c4d38n4l$u$$QT$Y\$Ld53D.E$sTWx.* tE%*riloggingtypingrrrrdotenvrrr|r rr rr rr basicConfigINFO getLoggerrrIrrrrrsc ))(.4* ',,'   8 $CeCer