KhIdZddlZddlZddlZddlZddlmZmZmZm Z m Z ddl m Z ddl mZddlZddlZddlZddlZddlmZddlmZddlZej.ej0ej2eZeeZd ej:d <d ej:d <eej<d d d d e_e eGddZeZ ejCddgdZ"ejCddZ#ejCddZ$ejCddZ%ejCddZ&ejCddgdZ'ejCd dgd!Z(ejCd"dgd#Z)ejCd$dgd%Z*ejCd&dgd'Z+ejCd(dgd)Z,ejCd*dgd+Z-d,Z.ejCd-dgd.Z/ejCd-dgd/Z0ejCd0dgd1Z1ejCd0dgd2Z2ejCd3dgd4Z3ejCd5dgd6Z4ejCd7dgd8Z5ejCd9dgd:Z6ejCd;dgd<Z7ejCd=dgd>Z8ejCd?dgd@Z9ejCdAdgdBZ:ejCdCdgdDZ;edEk(rrejxe.dFGZ=e=j}e?dHe?dIe?dJe?dKe?dLe?dMe?dNejdOdPd dFQyy)RuB Asset Management Server 자산관리 서버 - RESTful API 기반 N)Flaskrequestjsonifyrender_template_stringsend_from_directory)CORS)ProxyFix)RLock)Queue)levelF JSON_AS_ASCIIiMAX_CONTENT_LENGTH)x_forx_protox_hostx_prefixceZdZddZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZddZddZdZy) AssetDatabasecddl}ddl}|jj|jj t }|jj |||_td|jt|_ td|_ d|_ td|_d|_d|_|j#|j%|j'y)NrzDatabase path: )maxsizeFiz5C:\Users\Administrator\Desktop\item\instance\icons.db)ostempfilepathdirnameabspath__file__joindb_pathprintr _lockr _connection_pool_pool_initialized update_queuebatch_processor_running icon_db_path init_database_init_connection_pool_start_batch_processor)selfr rr current_dirs 2/mnt/c/Users/Administrator/Desktop/help_/server.py__init__zAssetDatabase.__init__#sggoobggooh&?@ ww||K9   ~./W %c 2!&"$/',$U  ""$ ##%cN tjd|tjd|jtjj |js#tj d|jytjdtj|j}|j}|jd|j}tjd| |jd|j}tjd | |jd |j}tjd |tjd|d|jd|f|j}tjd||j|r tjd|d|dStj d|dy#t$r#}tjd |Yd}~d}~wwxYw#t$r"}tjd |Yd}~d}~wwxYw#t$r%}tjd|d|Yd}~yd}~wwxYw)u0icons.db에서 hostname으로 RUST 정보 조회u+🔍 RUST 정보 조회 시작 - hostname: u📁 icons.db 경로: u❌ Icon database not found: Nu$✅ icons.db 파일 존재 확인됨z2SELECT name FROM sqlite_master WHERE type='table';u!📋 사용 가능한 테이블: zPRAGMA table_info(icon);u🏷️ icon 테이블 컬럼: u)❌ icon 테이블 정보 조회 실패: z1SELECT comp_no, remote_address FROM icon LIMIT 5;u&📊 icon 테이블 샘플 데이터: u$❌ 샘플 데이터 조회 실패: u-🔎 검색 쿼리 실행 - WHERE comp_no = ''zq SELECT remote_address FROM icon WHERE comp_no = ? u🎯 쿼리 결과: u✅ RUST 정보 찾음: ru❌ hostname 'u'에 대한 RUST 정보 없음u)❌ Error querying icons.db for hostname : )loggerinfor'rrexistswarningsqlite3connectcursorexecutefetchall Exceptionerrorfetchoneclose) r+hostnameconnr9tablescolumnse sample_dataresults r- get_rust_infozAssetDatabase.get_rust_info>sJ8  KKEhZP Q KK01B1B0CD E77>>$"3"34!>t?P?P>QRS KK> @??4#4#45D[[]F NNO P__&F KK;F8D E N9: //+ =gYGH  IRS$oo/  D[MRS KKGzQRS T NN   __&F KK.vh7 8 JJL 6vaykBCay z9WXY; N HLMM N I CA3GHH I.  LLDXJbQRPST U stBI6A=I69H9I9BI6?I6 I"I:I6II6 I3I.)I6.I33I66 J$?JJ$ctj|j}|j}|j d|j d|j d|j d|j d|j d|j d|j |j tjd|j|jy ) u데이터베이스 초기화aw CREATE TABLE IF NOT EXISTS assets ( id INTEGER PRIMARY KEY AUTOINCREMENT, hostname TEXT UNIQUE NOT NULL, ip_address TEXT, mac_address TEXT, last_seen TIMESTAMP DEFAULT CURRENT_TIMESTAMP, status TEXT DEFAULT 'active', created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) a CREATE TABLE IF NOT EXISTS hardware_info ( id INTEGER PRIMARY KEY AUTOINCREMENT, asset_id INTEGER, cpu_info TEXT, ram_total INTEGER, ram_used INTEGER, ram_percent REAL, disk_total INTEGER, disk_used INTEGER, disk_percent REAL, gpu_info TEXT, motherboard TEXT, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (asset_id) REFERENCES assets (id) ) a CREATE TABLE IF NOT EXISTS network_info ( id INTEGER PRIMARY KEY AUTOINCREMENT, asset_id INTEGER, interface_name TEXT, ip_address TEXT, mac_address TEXT, subnet_mask TEXT, gateway TEXT, dns_servers TEXT, network_speed TEXT, is_connected BOOLEAN, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (asset_id) REFERENCES assets (id) ) uj CREATE TABLE IF NOT EXISTS software_info ( id INTEGER PRIMARY KEY AUTOINCREMENT, asset_id INTEGER, software_list TEXT, -- JSON 형태로 저장 software_count INTEGER, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (asset_id) REFERENCES assets (id) ) ax CREATE TABLE IF NOT EXISTS com_ports ( id INTEGER PRIMARY KEY AUTOINCREMENT, asset_id INTEGER, port_name TEXT, description TEXT, hwid TEXT, is_active BOOLEAN, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (asset_id) REFERENCES assets (id) ) a  CREATE TABLE IF NOT EXISTS admin_settings ( id INTEGER PRIMARY KEY AUTOINCREMENT, setting_key TEXT UNIQUE NOT NULL, setting_value TEXT NOT NULL, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) a CREATE TABLE IF NOT EXISTS software_management_requests ( id INTEGER PRIMARY KEY AUTOINCREMENT, hostname TEXT NOT NULL, software_name TEXT NOT NULL, action_type TEXT NOT NULL, requested_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, status TEXT DEFAULT 'pending', completed_at TIMESTAMP, FOREIGN KEY (hostname) REFERENCES assets (hostname) ) z!Database initialized successfullyN) r7r8r r9r:commitr?r3r4_create_indexes_create_agent_logs_tabler+rAr9s r-r(zAssetDatabase.init_databasezst||,      &   $               78  %%'r/cLtj|j}|j}gd}|D]} |j ||j|jy#tj $r"}t jd|Yd}~hd}~wwxYw)u+성능 최적화를 위한 인덱스 생성)zBCREATE INDEX IF NOT EXISTS idx_assets_hostname ON assets(hostname)zDCREATE INDEX IF NOT EXISTS idx_assets_last_seen ON assets(last_seen)z>CREATE INDEX IF NOT EXISTS idx_assets_status ON assets(status)zPCREATE INDEX IF NOT EXISTS idx_software_info_asset_id ON software_info(asset_id)zPCREATE INDEX IF NOT EXISTS idx_hardware_info_asset_id ON hardware_info(asset_id)zIndex creation failed: N) r7r8r r9r:Errorr3r6rIr?)r+rAr9indexes index_sqlrDs r-rJzAssetDatabase._create_indexesst||, ! >I >y) >  == >!8<== >sA..B#BB#c*tj|j}|j}|j d|j d|j d|j d|j |j y)u9에이전트 로그 테이블 생성 (PC당 50개 제한)a CREATE TABLE IF NOT EXISTS agent_logs ( id INTEGER PRIMARY KEY AUTOINCREMENT, hostname TEXT NOT NULL, log_level TEXT NOT NULL, log_type TEXT NOT NULL, message TEXT NOT NULL, details TEXT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (hostname) REFERENCES assets (hostname) ) zJCREATE INDEX IF NOT EXISTS idx_agent_logs_hostname ON agent_logs(hostname)zNCREATE INDEX IF NOT EXISTS idx_agent_logs_created_at ON agent_logs(created_at)zHCREATE INDEX IF NOT EXISTS idx_agent_logs_level ON agent_logs(log_level)N)r7r8r r9r:rIr?rLs r-rKz&AssetDatabase._create_agent_logs_tablesmt||,    cdghab  r/cx|jry|j5|jr dddytdD]} tj|j d}|j d|j d|j d|j d|j d |jj|d |_tjd dddy#tj$r"}tjd |Yd}~d}~wwxYw#1swYyxYw) u연결 풀 초기화NFcheck_same_threadPRAGMA journal_mode=WALPRAGMA synchronous=NORMALPRAGMA cache_size=20000PRAGMA temp_store=MEMORYPRAGMA mmap_size=268435456zFailed to create connection: TzConnection pool initialized) r$r"ranger7r8r r:r#putrNr3r=r4)r+_rArDs r-r)z#AssetDatabase._init_connection_pool s  ! !  ZZ 7%% 7 7 2Y F F"??4<<5QDLL!:;LL!<=LL!:;LL!;<LL!=>))--d3 F&*D " KK5 6% 7 7}}FLL#@!DEEF 7 7s;D0D0BC8D08D- D(#D0(D--D00D9c |jjd}|S# tj|jd}|j d|j d|j d|j d|j d |cYS#tj $r}tjd |d }~wwxYwxYw) u$연결 풀에서 연결 가져오기rtimeoutFrTrVrWrXrYrZz!Failed to create new connection: N) r#getr7r8r r:rNr3r=)r+rArDs r-get_connectionzAssetDatabase.get_connection9s ((,,Q,7DK  t||uM 67 89 67 78 9: ==  @DE s- CA7BCC0C  CCc |jjdkr|jj|y|jy# |jYy#YYyxYwxYw)u연결을 풀에 다시 반환rN)r#qsizer\r?)r+rAs r-return_connectionzAssetDatabase.return_connectionMsY $$**,s2%%))$/     s(8A A A)A!!A&#A)&A)c|jryd|_tj|jd}|j t j dy)u배치 처리 스레드 시작NTtargetdaemonzBatch processor started)r& threadingThread_batch_processorstartr3r4)r+ batch_threads r-r*z$AssetDatabase._start_batch_processorZsG  ' ' '+$ ''t/D/DTR  -.r/cg}tj}|jr |jjd}|j |tj}t |dk\s |r||z dk\r|r|j |g}|}|jryy#YVxYw#t$r$}tjd|g}Yd}~>d}~wwxYw)u배치 처리 워커皙?r_2g@zBatch processor error: N) timer&r%raappendlen_process_batchr<r3r=)r+batchlast_process_time update_data current_timerDs r-rlzAssetDatabase._batch_processords IIK** "&"3"3"7"7"7"DKLL- $yy{ J"$|.??3F++E2 ",8)%**   6qc:; s*-B$AB+$B(&B++ C4CCc |j} |j}g}g}|D]b}|ddk(r|j|d|d|df)|ddk(s2|j|d|d|d |d |d |d |d |dfd|r|jd||r1|D],}|d}|j d|f|j d|.|j t jdt|d|j|y#t$r2} t jd| |jYd} ~ Hd} ~ wwxYw#|j|wxYw)u배치 데이터 처리type asset_status ip_address mac_addressr@ hardware_infoasset_idcpu_info ram_totalram_used ram_percent disk_total disk_used disk_percentz UPDATE assets SET ip_address = ?, mac_address = ?, last_seen = CURRENT_TIMESTAMP, status = 'active' WHERE hostname = ? r,DELETE FROM hardware_info WHERE asset_id = ?a INSERT INTO hardware_info (asset_id, cpu_info, ram_total, ram_used, ram_percent, disk_total, disk_used, disk_percent, updated_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP) zProcessed batch of z itemszBatch processing error: N) rbr9rs executemanyr:rIr3r4rtr<r=rollbackre) r+rvrAr9 asset_updateshardware_updatesitemhw_datarrDs r-ruzAssetDatabase._process_batchs""$6 )[[]FM!  <>1!((\*]+Z(* &\_4$++Z(Z([)Z(]+\*[)^, -  (""$# $ / "G&qzHNN#QT\S^_NN$! " " KKM KK-c%j\@ A  " "4 (   LL3A37 8 MMOO   " "4 (s1ADB,D E!(E EEEE)c|j} |j}|jd|f|j}|r+|d}|jd|||f|j n1|jd|||f|j }|j |j ||S#|j |wxYw)u8자산 등록 또는 업데이트 (배치 처리 적용)(SELECT id FROM assets WHERE hostname = ?rz UPDATE assets SET ip_address = ?, mac_address = ?, last_seen = CURRENT_TIMESTAMP, status = 'active' WHERE id = ? z INSERT INTO assets (hostname, ip_address, mac_address) VALUES (?, ?, ?) )rbr9r:r>rI lastrowidre)r+r@r}r~rAr9rFrs r-register_assetzAssetDatabase.register_assets""$ )[[]F NNE{ S__&F!!9 !+x8 :    K8:"++   " "4 (  " "4 (s BB66C c |jjd||jdd|jdd|jdd|jdd|jd d|jd d|jd d|jd d|jd dd dy#t$r4}tj d||j ||Yd}~yd}~wwxYw)u7하드웨어 정보 업데이트 (배치 처리 사용)rrrrrrrrrgpu_info motherboard) r{rrrrrrrrrrrr_z!Queue full, processing directly: N)r%r\rar<r3r6_update_hardware_info_direct)r+r hardware_datarDs r-update_hardware_infoz"AssetDatabase.update_hardware_infos G    ! !'$)--j"=*..{A>)--j!<,00D+// a@*..{A> - 1 1.# F)--j"=,00C # "  G NN>qcB C  - -h F F GsB9B<< C9*C44C9c2|j} |j}|jd|f|jd||jdd|jdd|jdd|jdd |jd d|jd d|jd d |jd d|jddf |j |j |y#|j |wxYw)u?하드웨어 정보 직접 업데이트 (큐 실패 시 백업)ra" INSERT INTO hardware_info (asset_id, cpu_info, ram_total, ram_used, ram_percent, disk_total, disk_used, disk_percent, gpu_info, motherboard, updated_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP) rrrrrrrrrrrrN)rbr9r:rarIre)r+rrrAr9s r-rz*AssetDatabase._update_hardware_info_directs""$ )[[]F NNIH; W NN !!*b1!!+q1!!*a0!!-5!!,2!!+q1!!.#6!!*b1!!-4   $ KKM  " "4 (D " "4 (s CDDc4|j}|j}|jd|f|jdgD]}|jd||jdd|jdd|jdd|jdd|jd dt j |jd g|jd d|jd d f |j |jy)u 네트워크 정보 업데이트z+DELETE FROM network_info WHERE asset_id = ? interfacesa INSERT INTO network_info (asset_id, interface_name, ip_address, mac_address, subnet_mask, gateway, dns_servers, network_speed, is_connected) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?) nameripmacsubnetgatewaydnsspeed connectedFN)rbr9r:rajsondumpsrIr?)r+r network_datarAr9 interfaces r-update_network_infoz!AssetDatabase.update_network_infos""$ DxkR&)),; I NN  fb) dB' eR( h+ i, 9==34 gr* k51    $  r/c4|j}|j}|jd|f|jdg}|jd|t j |dt |f|j|jy)u#소프트웨어 정보 업데이트z,DELETE FROM software_info WHERE asset_id = ? software_listzv INSERT INTO software_info (asset_id, software_list, software_count) VALUES (?, ?, ?) F ensure_asciiN) rbr9r:rarrrtrIr?)r+r software_datarAr9rs r-update_software_infoz"AssetDatabase.update_software_info3s""$ E{S%))/2>   =uEs=GY Z \  r/c |j}|j}|jd|f|jdgD]Y}|jd||jdd|jdd|jdd|jdd f[|j |j y ) uCOM 포트 정보 업데이트z(DELETE FROM com_ports WHERE asset_id = ?portsz INSERT INTO com_ports (asset_id, port_name, description, hwid, is_active) VALUES (?, ?, ?, ?, ?) portr descriptionhwidactiveTN)rbr9r:rarIr?)r+rcom_datarAr9rs r-update_com_portszAssetDatabase.update_com_portsDs""$ AH;OLL"- D NN$+$4(     r/ct|j} |j}|jd|j}g}|D]E}|d}|jd|f|j}d}d} |r|D]} | dr| dnd} | j } d| vs d| vsd| vsd | vrAd }d | vr7d | vr3| j d } | j d }| |kr | | d z|} nd} nd} nNd| vsd| vs d| vs d| vsd| vsd}n5n3|d}|r,|dk7r'|dk7r"|d rt fddDrd }d} nd}|d r|jnd}|j|d|dxsd|d|d|d|d|d || |xsdd! H||j|S#|j|wxYw)"u8자산 요약 정보 반환 (네트워크 정보 포함)a SELECT a.id, a.hostname, a.ip_address, a.mac_address, a.last_seen, a.status, h.ram_total, h.disk_total, s.software_count FROM assets a LEFT JOIN ( SELECT asset_id, ram_total, disk_total FROM hardware_info h1 WHERE h1.updated_at = ( SELECT MAX(updated_at) FROM hardware_info h2 WHERE h2.asset_id = h1.asset_id ) ) h ON a.id = h.asset_id LEFT JOIN ( SELECT asset_id, software_count FROM software_info s1 WHERE s1.updated_at = ( SELECT MAX(updated_at) FROM software_info s2 WHERE s2.asset_id = s1.asset_id ) ) s ON a.id = s.asset_id ORDER BY a.last_seen DESC rz SELECT interface_name, ip_address, is_connected FROM network_info WHERE asset_id = ? AND is_connected = 1 ORDER BY interface_name u 미연결rzwi-fiwirelesswlanwifiu무선()rz(Wi-Fi)ethernetethz local areau유선u 유선 연결z 127.0.0.1-c3BK|]}|jvywN)upper).0keywordr@s r- z3AssetDatabase.get_assets_summary..s+{GGx~~7G,G+{s)LAPLAPTOPNBNOTEBOOKu(추정)N) r@r}r~ last_seenstatusrrsoftware_countconnection_typessid rust_address) rbr9r:r;lowerfindanyrGrsre)r+rAr9resultsassetsrowr network_inforrnetinterface_nameinterface_lower ssid_startssid_endr}rr@s @r-get_assets_summaryz AssetDatabase.get_assets_summary\sV""$m )[[]F NN 6oo'GFH q6  [ " &0 "- +"36q6Qr*8*>*>*@$6*:W[aet[t"o5.6O #n49N-;-@-@-E +9+>+>s+C#-#8+9*Q,x+PD+4D'0!(O;u?W[gkz[z&/9_P_=_.6O!/"4"%QJ!jK&?JRUDU#&q6$+{Wz+{({.6O#-D/7Oq6?Gt11(;T  ("%a&#&q6=S!$Q!!f!$Q"%a&&)!f'6 $0$7C  yH T  " "4 (D " "4 (sC-F$BF$$F7Nc |j} |j}|jd|||||f|jd||f|j|j |y#|j |wxYw)u)에이전트 로그 추가 (50개 제한)z INSERT INTO agent_logs (hostname, log_level, log_type, message, details) VALUES (?, ?, ?, ?, ?) a DELETE FROM agent_logs WHERE hostname = ? AND id NOT IN ( SELECT id FROM agent_logs WHERE hostname = ? ORDER BY created_at DESC LIMIT 50 ) N)rbr9r:rIre)r+r@ log_levellog_typemessagedetailsrAr9s r- add_agent_logzAssetDatabase.add_agent_logs""$ )[[]F NNIx'B D NNH% ' KKM  " "4 (D " "4 (s A A//Bc 8|j} |j}|jd||fg}|jD](}|j |d|d|d|d|dd*||j |S#|j |wxYw)$특정 에이전트의 로그 조회z SELECT log_level, log_type, message, details, created_at FROM agent_logs WHERE hostname = ? ORDER BY created_at DESC LIMIT ? rrrrr)r r{rr timestamprbr9r:r;rsre)r+r@limitrAr9logsrs r-get_agent_logszAssetDatabase.get_agent_logss""$ )[[]F NN E"  $D(   VF"1v"1v!$Q    " "4 (D " "4 (s A"BBc"|j} |j}|jdg}|jD] }|j |d|d|dd"||j |S#|j |wxYw)u8로그가 있는 모든 에이전트 호스트명 조회z SELECT DISTINCT hostname, COUNT(*) as log_count, MAX(created_at) as last_log_time FROM agent_logs GROUP BY hostname ORDER BY last_log_time DESC rrr)r@ log_count last_log_timer)r+rAr9agentsrs r-!get_all_agent_hostnames_with_logsz/AssetDatabase.get_all_agent_hostnames_with_logss""$ )[[]F NN F(  #A!$Q%(V   " "4 (D " "4 (s AA;;B)zasset_management.dbr)rq)__name__ __module__ __qualname__r.rGr(rJrKr)rbrer*rlrurrrrrrrrrrr/r-rr"ss&6:xr(h.672( /:9)v"HG,)><"0p)d)8):)r/r/GET)methodscvtdddtjjjdS)u서버 상태 확인runningzAsset Management Server1.0.0)rserviceversionr)rdatetimenow isoformatrr/r-indexr%s: ,&&**,668  r/z /dashboardc tjjtjjt}tjj |dd}t d|t dtjj|tjj|rFt|dd5}|j}t dt||d d d ifcd d d Std d|idfS#1swYy xYw#t$r<}t dt|td dt|idfcYd }~Sd }~wwxYw)u 메인 대시보드 웹페이지staticzdashboard.htmlzLooking for dashboard at: z File exists: rutf-8encodingzDashboard content length: Content-Typetext/html; charset=utf-8Nr=zDashboard not found at zDashboard error: )rrrrrrr!r5openreadrtrr<strr,dashboard_pathfcontentrDs r- dashboardr/sAEggoobggooh&?@ k8=MN *>*:;< bggnn^<=>? 77>>. )ncG< R&&(23w<.ABn6P%QQ R R G'>~>N%OPQSVV V  R R E !#a&*+#4SVH!=>?DDEsBCD .D7 DDDDD E$(1EE$E$z/software-dashboardc tjjtjjt}tjj |dd}tjj |r/t|dd5}|j}|dddifcd d d Std d |id fS#1swYy xYw#t$r%}td d t|idfcYd }~Sd }~wwxYw)u0소프트웨어 관리 대시보드 웹페이지r zsoftware_dashboard.htmlr r r rrrNr=z Software dashboard not found at rzSoftware dashboard error: r rrrrrrr5rrrr<rrs r-software_dashboardrFs Nggoobggooh&?@ k8=VW 77>>. )ncG< R&&(n6P%QQ R RG'GGW%XYZ\__ _  R R N#=c!fX!FGH#MMNBBCC' C1CC C C C=C82C=8C=z/logs-dashboardc tjjtjjt}tjj |dd}tjj |r/t|dd5}|j}|dddifcd d d Std d |id fS#1swYy xYw#t$r%}td d t|idfcYd }~Sd }~wwxYw)u 로깅 대시보드 웹페이지r zlogs_dashboard.htmlr r r rrrNr=zLogs dashboard not found at rzLogs dashboard error: rrrs r-logs_dashboardr Ws Jggoobggooh&?@ k8=RS 77>>. )ncG< R&&(n6P%QQ R RG'CNCS%TUVX[[ [  R R J#9#a&!BCDcIIJrz/static/ctjjtjjtd}t ||S)u정적 파일 서빙r )rrrrrr)filename static_dirs r- static_filesr$hs2bggooh7BJ z8 44r/z/api/asset/registerPOSTc tj}gd}|D]}||vstdd|idfcStj |d|d|d}t j d|dd |d td |d d S#t$r:}t jd|tdt|idfcYd}~Sd}~wwxYw)u 자산 등록)r@r}r~r=Missing required field: r@r}r~zAsset registered:  (ID: rTzAsset registered successfullysuccessrrzAsset registration error: rN) rget_jsonrdbrr3r4r<r=r)datarequired_fieldsfieldrrDs r-rrns/!D$ SED +CE7)KLMsRR S $$         (j)9(:& !LM 6   / 1!56Q()3../s(!BBAB C /C?C C z/api/asset/updatec tj}d|vrtddidfStj |d|j dd|j dd}d|vrtj ||dd |vrtj||d d |vrtj||d d |vrtj||d tjd |dd |dtd|ddS#t$r:}tjd|tdt|idfcYd}~Sd}~wwxYw)u자산 정보 업데이트r@r=Missing hostnamer(r}rr~rr software_info com_portszAsset updated: r)rTzAsset updated successfullyr*zAsset update error: rN)rr,rr-rrarrrrr3r4r<r=r)r.rrDs r- update_assetr5s\%/! T !G%7893> >$$   HH\2 & HH]B '  d "  # #Hd?.C D T !  " "8T.-A B d "  # #Hd?.C D $    ${*; < od:&6%7vhZqIJ 3   / +A3/0Q()3../s#&DCD E/E=EEz/api/asset/batch-updatec > tj}|jdg}|stddidfSt |dkDrtddidfSd}g}|D]} |jd}|s|j d d d ,t j||jd d |jdd }d|vrt j||d|dz }tjd|dt |dtd|t ||d|ddS#t$r'}|j t|d Yd}~d}~wwxYw#t$r:}tjd|tdt|idfcYd}~Sd}~wwxYw)u4다중 자산 배치 업데이트 (성능 최적화)rr=zNo assets data providedr(rqzBatch size too large (max 50)rr@unknownr2)r@r=r}rr~rrNzBatch update completed: rz assetsTz assets processed)r+ processedtotalerrorsrzBatch update error: r)rr,rarrtrsr-rrr<rr3r4r=)r. assets_dataprocessed_countr: asset_datar@rrDs r-batch_update_assetsr>s1/!hhx, G%>?@#E E { b G%DEFK K% GJ G%>>*5MMyCU"VW,,NN<4NN="5#j0++Hj6QR1$% G.  ..?q[AQ@RRYZ[(%1/1BBST     G 8c!fEFF G / +A3/0Q()3../s`6EE E 'D&EAD&!AE& E/E EEE F"/FFFz/api/asset/heartbeatc` tj}|jd}|stddidfSt j dd}t j|tj||jdd|jd d}t jd d }td ||tjjjd S#t$r:}tj!d|tdt#|idfcYd}~Sd}~wwxYw)u6경량 하트비트 (최소한의 상태 업데이트)r@r=r2r(rpg?r}rr~i,ihT)r+rnext_heartbeat server_timezHeartbeat error: rN)rr,rarrandomuniformrrsleepr-rrandintrrrr<r3r=r)r.r@delayrr@rDs r-asset_heartbeatrGs/!88J'G%7893> >sC( 5$$  HH\2 & HH]B '  S1 ,#,,002<<>     / (,-Q()3../s#5C*B1C** D-3/D("D-(D-z /api/assetsc tj}tdt||dS#t$r:}t j d|tdt|idfcYd}~Sd}~wwxYw)u자산 목록 조회T)r+countrzGet assets error: r=rN)r-rrrtr<r3r=r)rrDs r- get_assetsrJss /&&([   / )!-.Q()3../+. A1/A,&A1,A1z/api/asset/c  tj}|j}|jd|f|j }|st ddidfS|d}|jd|f|j }|jd|f|j }|jd|f|j }|jd |f|j }|jt d |d |d |d |d|dd|||r|d rtj|d ng|ddS#t$r:} tjd| t dt| idfcYd} ~ Sd} ~ wwxYw)u"특정 자산 상세 정보 조회z'SELECT * FROM assets WHERE hostname = ?r=zAsset not foundrrzOSELECT * FROM hardware_info WHERE asset_id = ? ORDER BY updated_at DESC LIMIT 1z-SELECT * FROM network_info WHERE asset_id = ?zOSELECT * FROM software_info WHERE asset_id = ? ORDER BY updated_at DESC LIMIT 1z*SELECT * FROM com_ports WHERE asset_id = ?Trrrrr)r@r}r~rr) basic_infohardwarenetworksoftwarer4)r+assetzGet asset detail error: rN)r-rbr9r:r>rr;r?rloadsr<r3r=r) r@rAr9rQrrNrOrPr4rDs r-get_asset_detailrSs3/  " @8+N!G%678#= =8 hksjuv??$ F T//# hksjuv??$ Ch[QOO%  !&a"'(#(8!&q#Ah %"7?HQKDJJx{3UW&    " / /s34Q()3../s%AEC(E F /F;FFz /api/statsc & tj}|j}|jd|j d}|jd|j d}||z }|jd|j d}|j t d||||tjddS#t$r:}tjd|t d t|id fcYd }~Sd }~wwxYw) u서버 통계 정보zSELECT COUNT(*) FROM assetsrzu SELECT COUNT(*) FROM assets WHERE datetime(last_seen) > datetime('now', '-1 hour') zu SELECT COUNT(*) FROM assets WHERE datetime(created_at) > datetime('now', '-1 day') T) total_assets active_assetsinactive_assetsrecent_registrations server_uptime)r+statszGet stats error: r=rN) r-rbr9r:r>r?rrrr<r3r=r)rAr9rUrVrW recent_assetsrDs r- get_statsr\Ws(/  " 45(+    )!, '6   )!,   ,!.#2(5!%     / (,-Q()3../sC C D/D D Dc tjd tj} |j }|j d|j d|j }|j d|j }|j dtjjjd}tjd|d|d ||j d |j}d j|Dcgc] \}}|d |c}}}|rtjd |tj| ddl} | j!j#j$dz dz } | dkDrtj'd| ddt)j*dcc}}w#t$r!} j d| #Y| xYwd} ~ wwxYw#tj|wxYw#t$r"} tjd| Yd} ~ d} ~ wwxYw#YxYw)u3개선된 데이터 정리 (백그라운드 작업)u🧹 Cleanup thread startedzBEGIN IMMEDIATEz UPDATE assets SET status = 'inactive' WHERE (julianday('now') - julianday(last_seen)) * 24 * 60 > 10 AND status = 'active' z UPDATE assets SET status = 'active' WHERE (julianday('now') - julianday(last_seen)) * 24 * 60 <= 5 AND status = 'inactive' COMMITz%H:%M:%Su🧹 [z] Cleanup: deactivated=z , activated=z3SELECT status, COUNT(*) FROM assets GROUP BY statusz, r2u📊 Asset status: ROLLBACKNu❌ Cleanup error: riu⚠️ High memory usage: z.1fMB<)r3r4r-rbr9r:rowcountrrstrftimer;rr<rer=psutilProcess memory_inforssr6rrrD) rAr9 deactivated activatedrystatus_summaryrrI status_strrDrd memory_mbs r-cleanup_old_datarms KK-. 4 4$$&D/ +01  %oo   #OO x( (00446?? K  f\N2I+VbclbmnoTU!'!2!YYR`'a6("UG(<'ab KK"5j\ BC$$T*  (446::TADHI4!;Ic?"MN 2E L(b NN:.  $$T* 4 LL.qc2 3 3 4  sxHC(G G &"G HAIG G7G*(G2*G/,G22G77G::HH H?H::H?Iz/api/admin/keywordsc tj}|j}|jd|jd|j }|rt j |d}n gdgdgdd}|jtd|d S#t$r:}tjd |td t|id fcYd }~Sd }~wwxYw)u!관리자 키워드 설정 조회# CREATE TABLE IF NOT EXISTS admin_settings ( id INTEGER PRIMARY KEY AUTOINCREMENT, setting_key TEXT UNIQUE NOT NULL, setting_value TEXT NOT NULL, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) zOSELECT setting_value FROM admin_settings WHERE setting_key = 'license_keywords'r) microsoftofficeadobeautocadwindows)chromefirefoxvlcz7-zipz notepad++)pythonnodegitvscodezvisual studio code) commercialfree opensourceT)r+keywordszGet admin keywords error: r=rN r-rbr9r:r>rrRr?rr<r3r=r)rAr9rFrrDs r-get_admin_keywordsrs%/  "    hi" zz&),HUJWH     / 1!56Q()3../sBB C &/CC C c6 tj}|jdi}tj }|j }|j d|j dtj|df|j|jtjdt|dtdd d S#t$r:}tj!d |td t#|id fcYd}~Sd}~wwxYw)u!관리자 키워드 설정 저장rroz INSERT OR REPLACE INTO admin_settings (setting_key, setting_value, updated_at) VALUES ('license_keywords', ?, CURRENT_TIMESTAMP) FrzAdmin keywords updated: z categoriesTzKeywords saved successfullyr+rzSave admin keywords error: r=rNrr,rar-rbr9r:rrrIr?r3r4rtrr<r=r)r.rrAr9rDs r-save_admin_keywordsrs#/!88J+  "     jj6 8 :   .s8}o[IJ4   / 21#67Q()3../CC D/D DDz!/api/admin/manual-classificationsc tj}|j}|jd|jd|j }|rt j |d}ni}|jtd|dS#t$r:}tjd|tdt|idfcYd }~Sd }~wwxYw) u수동 분류 설정 조회rozUSELECT setting_value FROM admin_settings WHERE setting_key = 'manual_classifications'rT)r+classificationsz"Get manual classifications error: r=rNr)rAr9rFrrDs r-get_manual_classificationsrs/  "    no" "jj3O O .   / 9!=>Q()3../sBB C/C CCc6 tj}|jdi}tj }|j }|j d|j dtj|df|j|jtjdt|dtdd d S#t$r:}tj!d |td t#|id fcYd}~Sd}~wwxYw)u수동 분류 설정 저장rroz INSERT OR REPLACE INTO admin_settings (setting_key, setting_value, updated_at) VALUES ('manual_classifications', ?, CURRENT_TIMESTAMP) Frz Manual classifications updated: z softwareTz)Manual classifications saved successfullyrz#Save manual classifications error: r=rNr)r.rrAr9rDs r-save_manual_classificationsrCs#/!((#4b9  "     jju= ? A   6s?7K6LIVWB   / :1#>?Q()3../rz/api/admin/settings-backupc  tj}|j}|jd|j }i}|D] }t j |d||d<"tjjj|d<d|d<|jtd|dS#t$r:}tjd |td t|id fcYd }~Sd }~wwxYw) u관리자 설정 백업z5SELECT setting_key, setting_value FROM admin_settingsrr backup_daterrT)r+backupzBackup admin settings error: r=rN)r-rbr9r:r;rrRrrrr?rr<r3r=r)rAr9r backup_datarrDs r-backup_admin_settingsrks/  "NO//#  5C"&**SV"4KA  5&.%6%6%:%:%<%F%F%H M"!( I !   / 4QC89Q()3../sB=C D /C>8D>Dz/api/admin/settings-restorec X tj}|jdi}tj }|j }|j d|jD]3\}}|dvs |j d|tj|df5|j|jtjdtdd d S#t$r:}tj!d |td t#|id fcYd}~Sd}~wwxYw)u관리자 설정 복원rro)rrz INSERT OR REPLACE INTO admin_settings (setting_key, setting_value, updated_at) VALUES (?, ?, CURRENT_TIMESTAMP) Frz#Admin settings restored from backupTzSettings restored successfullyrzRestore admin settings error: r=rN)rr,rar-rbr9r:itemsrrrIr?r3r4rr<r=r)r.rrAr9keyvaluerDs r-restore_admin_settingsrs%/!(B'  "   !,,. CJC44 4::e%@AC C   9;7   / 5aS9:Q()3../s%A5C&8A-C&& D)//D$D)$D)z/api/software/deletion-requestc tj}|jd}|jd}|r|stddidfStj }|j }|jd|f|j}|j|stddidfStj }|j }|jd ||f|j|jtjd |d |td |d |ddS#t$r:}tjd|tdt|idfcYd}~Sd}~wwxYw)u소프트웨어 삭제 요청r@ software_namer=,hostname과 software_name이 필요합니다r(r(해당 자산을 찾을 수 없습니다rz INSERT OR REPLACE INTO software_management_requests ( hostname, software_name, action_type, requested_at, status ) VALUES (?, ?, 'deletion_request', CURRENT_TIMESTAMP, 'pending') zSoftware deletion request:  on Tu에 u' 삭제 요청이 전송되었습니다rz!Software deletion request error: rNrr,rarr-rbr9r:r>r?rIr3r4r<r=rr.r@rrAr9rQrDs r-request_software_deletionrsq&/!88J'1 }G%STUWZZ Z  "AH;O! G%OPQSVV V  "  &  (   1-XJOP"4 6]^   / 8<=Q()3../,AD: A'D:3BD:: E=/E82E=8E=z/api/software/force-removalc tj}|jd}|jd}|r|stddidfStj }|j }|jd|f|j}|j|stddidfStj }|j }|jd ||f|j|jtjd |d |td |d |ddS#t$r:}tjd|tdt|idfcYd}~Sd}~wwxYw)u소프트웨어 강제 제거r@rr=rr(rrrz INSERT OR REPLACE INTO software_management_requests ( hostname, software_name, action_type, requested_at, status ) VALUES (?, ?, 'force_removal', CURRENT_TIMESTAMP, 'pending') zSoftware force removal: rTu에서 u' 강제 제거가 요청되었습니다rzSoftware force removal error: rNrrs r-force_software_removalrsq&/!88J'1 }G%STUWZZ Z  "AH;O! G%OPQSVV V  "  &  (   .}oT(LM"7=/9`a   / 5aS9:Q()3../rz,/api/software/management-requests/c tj}|j}|jd|f|j }|j g}|D]$}|j |d|d|d|dd&td|dS#t$r:}tjd |td t|id fcYd }~Sd }~wwxYw) u:특정 호스트의 관리 요청 조회 (에이전트용)z SELECT id, software_name, action_type, requested_at FROM software_management_requests WHERE hostname = ? AND status = 'pending' ORDER BY requested_at ASC rrrr)idr action_type requested_atT)r+requestszGet management requests error: r=rN) r-rbr9r:r;r?rsrr<r3r=r)r@rAr9rrFreqrDs r-get_management_requestsrs/  " [  ??$  C MM!f!$Q"1v #A      / 6qc:;Q()3../sBB C/C CCz;/api/software/management-requests//completec tj}|jdd}tj }|j }|j d||f|j|jtjd|d|tdddS#t$r:}tjd |td t|id fcYd }~Sd }~wwxYw) u-관리 요청 완료 처리 (에이전트용)rF completedz UPDATE software_management_requests SET status = ?, completed_at = CURRENT_TIMESTAMP WHERE id = ? zManagement request z completed with result: Tu&요청이 완료 처리되었습니다rz#Complete management request error: r=rN)rr,rar-rbr9r:rIr?r3r4rr<r=r) request_idr.rFrAr9rDs r-complete_management_requestr+s/!(K0  " j !  #   )*5MfXVW?   / :1#>?Q()3../sB&B)) C,2/C'!C,'C,z/api/agent/logc  tj}gd}|D]}||vstdd|idfcStj |d|d|d|d|j d  td d d S#t $r:}tjd|tdt|idfcYd}~Sd}~wwxYw)u에이전트 로그 제출)r@r r{rr=r'r(r@r r{rr)r@rrrrTzLog submitted successfullyrzAgent log submission error: rN) rr,rr-rrar<r3r=r)r.r/r0rDs r-submit_agent_logrHs/!C$ SED +CE7)KLMsRR S *%7m&\OHHY'  3   / 3A378Q()3../s(!A<A<AA<< B?/B:4B?:B?z/api/agent/logs/c tj|}td||t|dS#t$r:}t j d|tdt|idfcYd}~Sd}~wwxYw)rT)r+r@rrIzGet agent logs error: r=rN)r-rrrtr<r3r=r)r@rrDs r-get_agent_logs_apirfsx /  * Y     / -aS12Q()3../s-0 A3/A.(A3.A3z/api/agent/logsc tj}td|t|dS#t$r:}t j d|tdt|idfcYd}~Sd}~wwxYw)u2로그가 있는 모든 에이전트 목록 조회T)r+rrIzGet all agent logs error: r=rN)r-rrrtr<r3r=r)rrDs r-get_all_agent_logsrwss /557[   / 1!56Q()3../rK__main__Trgu(🚀 Asset Management Server Starting...u3🌐 Web Dashboard: http://localhost:5000/dashboarduA📦 Software Dashboard: http://localhost:5000/software-dashboardu9📋 Logs Dashboard: http://localhost:5000/logs-dashboardu1📊 Assets API: http://localhost:5000/api/assetsu/📈 Stats API: http://localhost:5000/api/statsu#🔧 Ready to receive asset data...z0.0.0.0i)hostrdebugthreaded)A__doc__rr7rhashlibflaskrrrrr flask_corsrwerkzeug.middleware.proxy_fixr rjrrloggingrr queuer rB basicConfigINFO getLoggerrr3appconfigwsgi_apprr-routerrrr r$rr5r>rGrJrSr\rmrrrrrrrrrrrrrrkcleanup_threadrmr!runrr/r-rs  VV2   ',,'   8 $ Ho# ?#3   AqQO S ~ )~ )B_3 !<EE, !N"N  JJ  $%5&5  6(3/4/< 1'/2'/R $vh73/83/j !F84 /5 /D=5'* /+ / "UG45/55/n<%)*/**/XFR 5'2'/3'/R 6(3%/4%/N .@!/A!/F .A%/B%/N '%9/:/6 (6(;'/<'/T +fX>(/?(/T (6(;(/<(/T 9E7K /L /D HSYRZ[/\/8 fX.///: '%9/:/  ug. // / z%Y%%-=dKN 45 ?@ MN EF => ;< /0GGUTGBr/