j ddlmZddlmZddlmZdZdedefdZdeed e d e deefd Z d e deefd Z dS))datetime) query_all) TimelineEventc|dSt|dr|St|} tj|ddS#t $r|cYSwxYw)N isoformat)hasattrrstrr fromisoformat ValueError)valuetexts K/home/longshao/multi-rider-rag/modules/profile/services/timeline_service.py_to_isors }tuk""!   u::D%d3B3i00::<<<  s-A'' A65A6rowreturnci}|D].\}}|dvr t|drt|n|||</|S)N>timetitler)itemsr r)rdetailkeyr s r _clean_detailrs\ FiikkOO U # # # (/{(C(CNgennns Mrows event_type default_titlec g}|D]}t|d}|s'|dp|}t|||t|}|||S)Nrr)rtyperr)rgetrrappendto_dict)rrreventsr event_timerevents r _build_eventsr&s F ' 'SWWV__--     1M %%      emmoo&&&& Mrzjhmc d}d}d}d}g}|tt|d|idd|tt|d|idd |tt|d|id d |tt|d|id d t|ddS)Na SELECT a."ajxx_fasj" AS time, COALESCE(a."ajxx_ay", a."ajxx_ajmc", a."ajxx_ajbh") AS title, a."ajxx_ajbh" AS ajbh, a."ajxx_ajmc" AS ajmc, a."ajxx_ay" AS ay, a."ajxx_cbdw_mc" AS cbdw FROM "ywdata"."zq_zfba_ajxx" a JOIN "ywdata"."zq_zfba_xyrxx" x ON x."ajxx_join_ajxx_ajbh" = a."ajxx_ajbh" WHERE x."xyrxx_sfzh" = %(zjhm)s z SELECT wf_sj AS time, wfxw_cn AS title, wfxw_cn, blxwlx_cn, fsdd, cphm FROM "ywdata"."t_wcnrxwjl_xx" WHERE sfzhm = %(zjhm)s a4 SELECT shot_time AS time, device_name AS title, device_name, jd, wd, ssfj, sspcs FROM "jcgkzx_monitor"."wcnr_ryrl_gj" WHERE zjhm = %(zjhm)s ORDER BY shot_time DESC LIMIT 50 z SELECT rzsj AS time, lgmc AS title, lgmc, lgdz, lksj, tfrxm, tfrzjhm FROM "jcgkzx_monitor"."wcnr_ly_checkin" WHERE zjhm = %(zjhm)s r'caseu案件behavioru行为 trajectoryu轨迹hotelu入住c|dS)Nr)items rz build_timeline..bs 4<rT)rreverse)extendr&rsorted)r'case_sql behavior_sqltrajectory_sql hotel_sqlr#s rbuild_timeliner8-s H L N IF MM- (VTN C CVXVVWWW MM- , G GU]^^___ MM- .64. I Ir=s((((((000000   tT CDQUJ"5G5Gd5G5G5G5G5G5Gr