ۉj)"ddlmZddlZddlmZddlmZmZmZddl m Z m Z ddl m Z ddlmZmZmZmZddlmZdd lmZejd ZeZeZeZed ee ee gd fd2dZede ee gdfd3dZ eddee gdfd4dZ!edee gd fd5dZ"ed ee gd fd5d!Z#ed"e dee gd#fd6d'Z$dd(l%m&Z&ed)ee gdfd7d*Z'ddl(Z(dd+l%m)Z)ed,ee gdfd5d-Z*ed.ee gdfd8d1Z+dS)9) annotationsN)Any) APIRouterDepends HTTPException)get_current_user require_role)ErpDatabaseClient)AIBudgetSummaryResponseDHSMissionRequestDHSMissionResponseDHSSampleMissionItem)AgentSchedulerService)DeepSeekHarnessServicezdscons.api.knowledge_agents.dhsz"/v1/agents/harness/sample-missions)response_model) superadmindirectoradminpmqsengineer current_userdict[str, Any]returnlist[DHSSampleMissionItem]c t}d|DS#t$r}tdd||d}~wwxYw)uQLấy danh mục các kịch bản nhiệm vụ mẫu 4 Trụ cột của DSCons.c&g|]}tdi|S))r).0ss YC:\Projects\DSCons\app\modules\agents\presentation\knowledge_agent_routes\dhs_missions.py z+get_dhs_sample_missions..&s';;;a$))q));;;u+Lỗi lấy danh mục nhiệm vụ mẫu:  status_codedetailN) dhs_serviceget_sample_missions Exceptionr)rsamplesexcs r!get_dhs_sample_missionsr-st1133;;7;;;; $YRU$Y$Y    s$' A AA z/v1/agents/harness/execute)rrrrrpayloadr r cK t|j|j|j|j|jd{V}tdi|S#t$r}tdd||d}~wwxYw)u^Kích hoạt điều phối nhiệm vụ Multi-Agent tự trị bằng DeepSeek Harness (DHS). mission_titlemission_prompttarget_project_idpillardeep_reasoning_enabledNr$u0Lỗi thực thi nhiệm vụ DeepSeek Harness: r%r) r(execute_missionr1r2r3r4r5r r*r)r.rresultr,s r!execute_dhs_missionr8-s "22!/"1%7>#*#A 3        "++F+++ $^WZ$^$^    sA A A2A--A2z/v1/agents/harness/history limitintc t|}t||dS#t$r}t dd||d}~wwxYw)uQTruy xuất lịch sử các nhiệm vụ đã thực thi bởi DeepSeek Harness.)r:)totalhistoryr$u#Lỗi truy xuất lịch sử DHS: r%N)r(get_mission_historylenr*r)r:rlogsr,s r!get_dhs_mission_historyrBDs ..U.;;YY    $Q#$Q$Q    s,/ AAAz/v1/agents/schedule/dailyc t}t||dS#t$r}t dd||d}~wwxYw)uVLấy bảng phân ca làm việc so le thông minh trong ngày của 9 Nhân sự AI.) total_shiftsshiftsr$u#Lỗi lấy lịch làm việc AI: r%N)scheduler_serviceget_daily_scheduler@r*r)rscheduler,s r!get_daily_agent_schedulerIXs| $7799MM    $Q#$Q$Q    s*- AA  Az$/v1/agents/schedule/anti-spam-statusc tS#t$r}tdd||d}~wwxYw)umLấy trạng thái bộ đệm bảo vệ chống Rate Limit & Spam Detection (OpenRouter & Local failover).r$u+Lỗi kiểm tra bộ đệm chống spam: r%N)rFget_anti_spam_shield_statusr*r)rr,s r!get_anti_spam_statusrLmsa <<>>> $YRU$Y$Y    s ?:?z/v1/agents/budget-summary)rrrr accountant agent_code str | Noner ct} ||}tdi|S#t$r}t dd||d}~wwxYw)ugTruy xuất tổng hợp ngân sách tiêu thụ theo ngày, tuần, tháng, năm của nhân viên AI.)rNr$u"Lỗi truy xuất ngân sách AI: r%Nr)r get_ai_agent_budget_summaryr r*r)rNrclientdatar,s r!get_ai_agents_budget_summaryrT~s F11Z1HH&..... $P$P$P    s!2 AAAStreamingResponsez!/v1/agents/harness/execute_streamcDKfd}t|dS)ufKích hoạt điều phối nhiệm vụ Multi-Agent tự trị bằng DeepSeek Harness (DHS) qua SSE.c2K tjjjjj23d{V}d|dWV6dS#t$r;}ddl}d| dt|ddWVYd}~dSd}~wwxYw)Nr0zdata: z rERROR)typemessage) r(execute_mission_streamr1r2r3r4r5r*jsondumpsstr)eventr,r]r.s r!event_generatorz3execute_dhs_mission_stream..event_generators  T*AA%3&5")";~'.'E B   + + + + + + +e+u********    T T T KKKS4::w3s88&L&LMMSSS S S S S S S S S S S Ts"8AA A B0BBztext/event-stream) media_typerU)r.rras` r!execute_dhs_mission_streamrcsC T T T T T __..;N O O OOr#) FileResponsez/v1/agents/reportscd}tj|sdgiSg}tj|D]n}|drWtj||}tj|}|||j|j do| ddd|iS)uDDanh sách các file Báo cáo điều hành tự động đã lưu.storage/secure_vault/reportsreports.md)filename size_bytes created_atc|dS)Nrkr)xs r!z(list_executive_reports..s qr#T)keyreverse) ospathexistslistdirendswithjoinstatappendst_sizest_mtimesort)r report_dirrgrifilepathrws r!list_executive_reportsr~s0J 7>>* % %2GJz**   U # # w||J99H78$$D NN$"l"m    LL..L=== w r#z/v1/agents/reports/{filename}rir_cBtj|}||krtdd|dstddtjd}tjtj||}||stddtj|stdd t|d | S) ueTải xuống file Báo cáo điều hành (bảo mật nghiêm ngặt chống Local File Inclusion).iu?Tên file không hợp lệ (Phát hiện Directory Traversal).r%rhu/Chỉ cho phép truy xuất định dạng .md.rfu3Cố gắng truy cập ngoài thư mục cho phép.iu"Không tìm thấy file báo cáo.z text/markdown)rbri) rqrrbasenamerruabspathrv startswithrsrd)rir safe_filenamer| file_paths r!download_executive_reportrsG$$X..M  4uvvvv  ! !% ( (g4effff!?@@J Z G GHHI    + +k4ijjjj 7>>) $ $Z4XYYYY "   r#)rrrr)r.r rrrr )r:r;rrrr)rrrr)rNrOrrrr )r.r rr)rir_rr), __future__rloggingtypingrfastapirrr"app.modules.auth.presentation.authrr app.core.postgres.erp_clientr app.models.schemasr r r r6app.modules.agents.application.agent_scheduler_servicer7app.modules.agents.application.deepseek_harness_servicer getLoggerloggerrouterr(rFgetlistr-postr8rBrIrLrTfastapi.responsesrVrcrqrdr~rrr#r!rs""""""5555555555MMMMMMMM:::::: YXXXXXZZZZZZ  < = = $$&& ))++(>R9S $+7 G G G  $$" ):LMM$+7 DDDEE$$NM, ())#*7 DDDEE$$*)& '((#*7 G G G  $$)(( 233#*7 G G G  $$    43   '8OPP!#*7 LLLMM$$QP 0///// 011$+7 DDDEE$$PPPP21P. ****** !!#*7 DDDEE$$    "! 2 +,,$+7 DDDEE$$-,r#