選択できるのは25トピックまでです。 トピックは、先頭が英数字で、英数字とダッシュ('-')を使用した35文字以内のものにしてください。
 
 
 
 

673 行
20 KiB

  1. import asyncio
  2. import json
  3. from urllib.parse import urlencode
  4. from fastapi import APIRouter, Depends, HTTPException, Query, Request
  5. import httpx
  6. import config_env
  7. from typing import List, Optional
  8. from schemas.reslevis import (
  9. BuildingItem,
  10. FloorItem,
  11. ZoneItem,
  12. ZoneAreaDefinitionItem,
  13. GatewayItem,
  14. TrackerItem,
  15. OperatorItem,
  16. SubjectItem,
  17. AlarmItem,
  18. AlarmCoreItem,
  19. AlarmStatusUpdateItem,
  20. TrackItem,
  21. TrackHistoryItem,
  22. TrackerZoneItem,
  23. SettingItem,
  24. GuiConfigItem,
  25. CoreSettingsItem,
  26. CoreSettingsUpdateItem,
  27. )
  28. from logica_reslevis.gateway import GatewayJsonRepository
  29. from logica_reslevis.building import BuildingJsonRepository
  30. from logica_reslevis.floor import FloorJsonRepository
  31. from logica_reslevis.zone import ZoneJsonRepository
  32. from logica_reslevis.zone_area_definition import ZoneAreaDefinitionJsonRepository
  33. from logica_reslevis.tracker import TrackerJsonRepository
  34. from logica_reslevis.operator import OperatorJsonRepository
  35. from logica_reslevis.setting import SettingJsonRepository
  36. from logica_reslevis.gui_config import GuiConfigJsonRepository
  37. from logica_reslevis.subject import SubjectJsonRepository
  38. from logica_reslevis.alarm import AlarmJsonRepository
  39. from logica_reslevis.track import TrackJsonRepository
  40. from logica_reslevis.tracker_zone import TrackerZoneJsonRepository
  41. from logica_reslevis.tracker_mode import get_mode_aware_trackers
  42. from security import get_current_user
  43. #CORE SYNC
  44. CORE_BASE_URL = config_env.CORE_API_URL.rstrip("/")
  45. ALERTS_CORE_BASE_URL = "http://localhost:1902"
  46. TRACKS_CORE_BASE_URL = "http://localhost:1902"
  47. SETTINGS_CORE_BASE_URL = "http://127.0.0.1:1902"
  48. CORE_TIMEOUT = 2.0 # secondi
  49. async def sync_core_get(request: Request) -> None:
  50. if request.method != "GET":
  51. return
  52. sync = CORE_GET_SYNC.get(request.url.path)
  53. if sync is None:
  54. return
  55. repo, normalizer = sync
  56. try:
  57. async with httpx.AsyncClient(timeout=CORE_TIMEOUT) as client:
  58. resp = await client.get(
  59. f"{CORE_BASE_URL}{request.url.path}",
  60. params=request.query_params,
  61. )
  62. if 200 <= resp.status_code < 300:
  63. data = resp.json()
  64. if isinstance(data, list):
  65. if normalizer:
  66. data = [normalizer(r) for r in data if isinstance(r, dict)]
  67. repo._write_all(data) # aggiorna i file locali
  68. except (httpx.RequestError, ValueError):
  69. # CORE giù o risposta non valida -> uso il file locale
  70. pass
  71. router = APIRouter(dependencies=[Depends(sync_core_get)])
  72. gateway_repo = GatewayJsonRepository()
  73. building_repo = BuildingJsonRepository()
  74. floor_repo = FloorJsonRepository()
  75. zone_repo = ZoneJsonRepository()
  76. zone_area_definition_repo = ZoneAreaDefinitionJsonRepository()
  77. tracker_repo = TrackerJsonRepository()
  78. operator_repo = OperatorJsonRepository()
  79. subject_repo = SubjectJsonRepository()
  80. alarm_repo = AlarmJsonRepository()
  81. track_repo = TrackJsonRepository()
  82. tracker_zone_repo = TrackerZoneJsonRepository()
  83. setting_repo = SettingJsonRepository()
  84. gui_config_repo = GuiConfigJsonRepository()
  85. def _none_if_empty(v):
  86. return None if v in ("", None, 0, "0") else v
  87. def _str_or_none(v):
  88. if v in ("", None):
  89. return None
  90. if isinstance(v, (int, float, bool)):
  91. return str(v)
  92. return v
  93. def _uuid_list(values):
  94. if values in ("", None):
  95. return []
  96. if isinstance(values, str):
  97. values = [v for v in values.split(",") if v]
  98. if isinstance(values, (list, tuple, set)):
  99. cleaned = []
  100. for v in values:
  101. if isinstance(v, dict):
  102. v = v.get("id") or v.get("uuid")
  103. if v in ("", None, 0, "0"):
  104. continue
  105. cleaned.append(v)
  106. return cleaned
  107. return [values] if values not in ("", None, 0, "0") else []
  108. def _normalize_gateway(row: dict) -> dict:
  109. row = dict(row)
  110. row["floor"] = _none_if_empty(row.get("floor"))
  111. row["building"] = _none_if_empty(row.get("building"))
  112. return row
  113. def _normalize_track(row: dict) -> dict:
  114. row = dict(row)
  115. row["ID"] = row.get("ID")
  116. row["gateway"] = _none_if_empty(row.get("gateway"))
  117. row["tracker"] = _none_if_empty(row.get("tracker"))
  118. row["subject"] = _none_if_empty(row.get("subject"))
  119. row["floor"] = _none_if_empty(row.get("floor"))
  120. row["building"] = _none_if_empty(row.get("building"))
  121. row["timestamp"] = _str_or_none(row.get("timestamp"))
  122. row["type"] = _str_or_none(row.get("type"))
  123. row["status"] = _str_or_none(row.get("status"))
  124. row["gatewayMac"] = _str_or_none(row.get("gatewayMac"))
  125. row["trackerMac"] = _str_or_none(row.get("trackerMac"))
  126. row["subjectName"] = _str_or_none(row.get("subjectName"))
  127. row["x"] = None if row.get("x") in ("", None) else row.get("x")
  128. row["y"] = None if row.get("y") in ("", None) else row.get("y")
  129. row["z"] = None if row.get("z") in ("", None) else row.get("z")
  130. # signal resta float o None
  131. row["signal"] = None if row.get("signal") in ("", None) else row.get("signal")
  132. return row
  133. def _normalize_zone(row: dict) -> dict:
  134. row = dict(row)
  135. row["floor"] = _none_if_empty(row.get("floor"))
  136. row["building"] = _none_if_empty(row.get("building"))
  137. row["groups"] = _uuid_list(row.get("groups"))
  138. return row
  139. CORE_GET_SYNC = {
  140. "/reslevis/getGateways": (gateway_repo, _normalize_gateway),
  141. "/reslevis/getZones": (zone_repo, _normalize_zone),
  142. }
  143. async def _fetch_tracks_for_tracker(
  144. tracker_id: str,
  145. params: Optional[dict] = None,
  146. ) -> List[dict]:
  147. query_string = urlencode(params or {})
  148. url = f"{TRACKS_CORE_BASE_URL}/reslevis/getTracks/{tracker_id}"
  149. if query_string:
  150. url = f"{url}?{query_string}"
  151. process = await asyncio.create_subprocess_exec(
  152. "curl",
  153. "-sS",
  154. "-X",
  155. "GET",
  156. url,
  157. stdout=asyncio.subprocess.PIPE,
  158. stderr=asyncio.subprocess.PIPE,
  159. )
  160. stdout, stderr = await process.communicate()
  161. if process.returncode != 0:
  162. detail = (stderr or stdout).decode("utf-8", errors="replace").strip() or "CORE curl request failed"
  163. raise HTTPException(status_code=502, detail=detail)
  164. try:
  165. payload = json.loads(stdout.decode("utf-8"))
  166. except ValueError as exc:
  167. raise HTTPException(status_code=502, detail="Invalid CORE response") from exc
  168. if not isinstance(payload, list):
  169. raise HTTPException(status_code=502, detail="Unexpected CORE response type")
  170. return [_normalize_track(row) for row in payload if isinstance(row, dict)]
  171. @router.get(
  172. "/getGateways",
  173. response_model=List[GatewayItem],
  174. tags=["Reslevis"],
  175. dependencies=[Depends(get_current_user)],
  176. )
  177. def getGateways():
  178. return gateway_repo.list()
  179. @router.post("/postGateway", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  180. def postGateway(item: GatewayItem):
  181. gateway_repo.add(item)
  182. return {"message": "OK"}
  183. @router.put("/updateGateway", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  184. def updateGateway(item: GatewayItem):
  185. gateway_repo.update(item)
  186. return {"message": "OK"}
  187. @router.delete("/removeGateway/{gateway_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  188. def removeGateway(gateway_id: str):
  189. gateway_repo.remove(gateway_id)
  190. return {"message": "OK"}
  191. @router.get(
  192. "/getBuildings",
  193. response_model=List[BuildingItem],
  194. tags=["Reslevis"],
  195. dependencies=[Depends(get_current_user)],
  196. )
  197. def getBuildings():
  198. return building_repo.list()
  199. @router.post("/postBuilding", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  200. def postBuilding(item: BuildingItem):
  201. building_repo.add(item)
  202. return {"message": "OK"}
  203. @router.put("/updateBuilding", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  204. def updateBuilding(item: BuildingItem):
  205. building_repo.update(item)
  206. return {"message": "OK"}
  207. @router.delete("/removeBuilding/{building_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  208. def removeBuilding(building_id: str):
  209. building_repo.remove(building_id)
  210. return {"message": "OK"}
  211. @router.get(
  212. "/getFloors",
  213. response_model=List[FloorItem],
  214. tags=["Reslevis"],
  215. dependencies=[Depends(get_current_user)],
  216. )
  217. def getFloors():
  218. return floor_repo.list()
  219. @router.post("/postFloor", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  220. def postFloor(item: FloorItem):
  221. floor_repo.add(item)
  222. return {"message": "OK"}
  223. @router.put("/updateFloor", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  224. def updateFloor(item: FloorItem):
  225. floor_repo.update(item)
  226. return {"message": "OK"}
  227. @router.delete("/removeFloor/{floor_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  228. def removeFloor(floor_id: str):
  229. floor_repo.remove(floor_id)
  230. return {"message": "OK"}
  231. @router.get(
  232. "/getZones",
  233. response_model=List[ZoneItem],
  234. tags=["Reslevis"],
  235. dependencies=[Depends(get_current_user)],
  236. )
  237. def getZones():
  238. return zone_repo.list()
  239. @router.post("/postZone", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  240. def postZone(item: ZoneItem):
  241. zone_repo.add(item)
  242. return {"message": "OK"}
  243. @router.put("/updateZone", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  244. def updateZone(item: ZoneItem):
  245. zone_repo.update(item)
  246. return {"message": "OK"}
  247. @router.delete("/removeZone/{zone_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  248. def removeZone(zone_id: str):
  249. zone_repo.remove(zone_id)
  250. return {"message": "OK"}
  251. @router.get(
  252. "/getZoneAreaDefinitions",
  253. response_model=List[ZoneAreaDefinitionItem],
  254. tags=["Reslevis"],
  255. dependencies=[Depends(get_current_user)],
  256. )
  257. def getZoneAreaDefinitions(UUID: str | None = None):
  258. return zone_area_definition_repo.list(UUID)
  259. @router.post("/postZoneAreaDefinition", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  260. def postZoneAreaDefinition(item: ZoneAreaDefinitionItem):
  261. zone_area_definition_repo.add(item)
  262. return {"message": "OK"}
  263. @router.put("/updateZoneAreaDefinition", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  264. def updateZoneAreaDefinition(item: ZoneAreaDefinitionItem):
  265. zone_area_definition_repo.update(item)
  266. return {"message": "OK"}
  267. @router.delete("/removeZoneAreaDefinition/{zone_area_definition_uuid}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  268. def removeZoneAreaDefinition(zone_area_definition_uuid: str):
  269. zone_area_definition_repo.remove(zone_area_definition_uuid)
  270. return {"message": "OK"}
  271. @router.get(
  272. "/getTrackers",
  273. response_model=List[TrackerItem],
  274. tags=["Reslevis"],
  275. dependencies=[Depends(get_current_user)],
  276. )
  277. async def getTrackers():
  278. return await get_mode_aware_trackers(
  279. tracker_repo,
  280. SETTINGS_CORE_BASE_URL,
  281. config_env.BLE_AI_INFER_CSV,
  282. CORE_TIMEOUT,
  283. )
  284. @router.post("/postTracker", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  285. def postTracker(item: TrackerItem):
  286. tracker_repo.add(item)
  287. return {"message": "OK"}
  288. @router.put("/updateTracker", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  289. def updateTracker(item: TrackerItem):
  290. tracker_repo.update(item)
  291. return {"message": "OK"}
  292. @router.delete("/removeTracker/{tracker_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  293. def removeTracker(tracker_id: str):
  294. tracker_repo.remove(tracker_id)
  295. return {"message": "OK"}
  296. @router.get(
  297. "/getTrackerZones",
  298. response_model=List[TrackerZoneItem],
  299. tags=["Reslevis"],
  300. dependencies=[Depends(get_current_user)],
  301. )
  302. def getTrackerZones():
  303. return tracker_zone_repo.list()
  304. @router.post("/postTrackerZone", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  305. def postTrackerZone(item: TrackerZoneItem):
  306. tracker_zone_repo.add(item)
  307. return {"message": "OK"}
  308. @router.put("/updateTrackerZone", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  309. def updateTrackerZone(item: TrackerZoneItem):
  310. tracker_zone_repo.update(item)
  311. return {"message": "OK"}
  312. @router.delete("/removeTrackerZone/{tracker_zone_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  313. def removeTrackerZone(tracker_zone_id: str):
  314. tracker_zone_repo.remove(tracker_zone_id)
  315. return {"message": "OK"}
  316. @router.get(
  317. "/getTracks",
  318. response_model=List[TrackHistoryItem],
  319. tags=["Reslevis"],
  320. dependencies=[Depends(get_current_user)],
  321. )
  322. async def getTracks(
  323. tracker_id: str = Query(..., alias="id"),
  324. limit: Optional[int] = Query(None, ge=1),
  325. from_: Optional[str] = Query(None, alias="from"),
  326. to: Optional[str] = Query(None),
  327. ):
  328. params = {}
  329. if limit is not None:
  330. params["limit"] = limit
  331. if from_:
  332. params["from"] = from_
  333. if to:
  334. params["to"] = to
  335. return await _fetch_tracks_for_tracker(tracker_id, params)
  336. @router.get(
  337. "/getTracks/{tracker_id}",
  338. response_model=List[TrackHistoryItem],
  339. tags=["Reslevis"],
  340. dependencies=[Depends(get_current_user)],
  341. )
  342. async def getTrack(
  343. tracker_id: str,
  344. limit: Optional[int] = Query(None, ge=1),
  345. from_: Optional[str] = Query(None, alias="from"),
  346. to: Optional[str] = Query(None),
  347. ):
  348. params = {}
  349. if limit is not None:
  350. params["limit"] = limit
  351. if from_:
  352. params["from"] = from_
  353. if to:
  354. params["to"] = to
  355. return await _fetch_tracks_for_tracker(tracker_id, params)
  356. @router.post("/postTrack", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  357. def postTrack(item: TrackItem):
  358. track_repo.add(item)
  359. return {"message": "OK"}
  360. @router.put("/updateTrack", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  361. def updateTrack(item: TrackItem):
  362. track_repo.update(item)
  363. return {"message": "OK"}
  364. @router.delete("/removeTrack/{track_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  365. def removeTrack(track_id: str):
  366. track_repo.remove(track_id)
  367. return {"message": "OK"}
  368. @router.get(
  369. "/getAlarms",
  370. response_model=List[AlarmCoreItem],
  371. tags=["Reslevis"],
  372. dependencies=[Depends(get_current_user)],
  373. )
  374. async def getAlarms():
  375. async with httpx.AsyncClient(timeout=CORE_TIMEOUT) as client:
  376. resp = await client.get(f"{ALERTS_CORE_BASE_URL}/reslevis/alerts")
  377. if resp.status_code >= 400:
  378. detail = resp.text.strip() or "CORE alerts request failed"
  379. raise HTTPException(status_code=resp.status_code, detail=detail)
  380. try:
  381. payload = resp.json()
  382. except ValueError as exc:
  383. raise HTTPException(status_code=502, detail="Invalid CORE response") from exc
  384. if not isinstance(payload, list):
  385. raise HTTPException(status_code=502, detail="Unexpected CORE response type")
  386. return payload
  387. @router.put(
  388. "/updateAlarm",
  389. tags=["Reslevis"],
  390. dependencies=[Depends(get_current_user)],
  391. )
  392. async def updateAlarm(item: AlarmStatusUpdateItem):
  393. async with httpx.AsyncClient(timeout=CORE_TIMEOUT) as client:
  394. resp = await client.patch(
  395. f"{ALERTS_CORE_BASE_URL}/reslevis/alerts/{item.id}",
  396. json={"status": item.status},
  397. )
  398. if resp.status_code >= 400:
  399. detail = resp.text.strip() or "CORE alert update failed"
  400. raise HTTPException(status_code=resp.status_code, detail=detail)
  401. if not resp.content:
  402. return {"message": "OK"}
  403. try:
  404. return resp.json()
  405. except ValueError:
  406. return {"message": "OK"}
  407. @router.get(
  408. "/getOperators",
  409. response_model=List[OperatorItem],
  410. tags=["Reslevis"],
  411. dependencies=[Depends(get_current_user)],
  412. )
  413. def getOperators():
  414. return operator_repo.list()
  415. @router.post("/postOperator", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  416. def postOperator(item: OperatorItem):
  417. operator_repo.add(item)
  418. return {"message": "OK"}
  419. @router.put("/updateOperator", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  420. def updateOperator(item: OperatorItem):
  421. operator_repo.update(item)
  422. return {"message": "OK"}
  423. @router.delete("/removeOperator/{operator_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  424. def removeOperator(operator_id: str):
  425. operator_repo.remove(operator_id)
  426. return {"message": "OK"}
  427. @router.get(
  428. "/getSubjects",
  429. response_model=List[SubjectItem],
  430. tags=["Reslevis"],
  431. dependencies=[Depends(get_current_user)],
  432. )
  433. def getSubjects():
  434. return subject_repo.list()
  435. @router.post("/postSubject", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  436. def postSubject(item: SubjectItem):
  437. subject_repo.add(item)
  438. return {"message": "OK"}
  439. @router.put("/updateSubject", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  440. def updateSubject(item: SubjectItem):
  441. subject_repo.update(item)
  442. return {"message": "OK"}
  443. @router.delete("/removeSubject/{subject_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  444. def removeSubject(subject_id: str):
  445. subject_repo.remove(subject_id)
  446. return {"message": "OK"}
  447. @router.get(
  448. "/getSettings",
  449. response_model=List[SettingItem],
  450. tags=["Reslevis"],
  451. dependencies=[Depends(get_current_user)],
  452. )
  453. def getSettings():
  454. return setting_repo.list()
  455. @router.post("/postSetting", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  456. def postSetting(item: SettingItem):
  457. setting_repo.add(item)
  458. return {"message": "OK"}
  459. @router.put("/updateSetting", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  460. def updateSetting(item: SettingItem):
  461. setting_repo.update(item)
  462. return {"message": "OK"}
  463. @router.delete("/removeSetting/{setting_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  464. def removeSetting(setting_id: str):
  465. setting_repo.remove(setting_id)
  466. return {"message": "OK"}
  467. @router.get(
  468. "/getGuiConfigs",
  469. response_model=List[GuiConfigItem],
  470. tags=["Reslevis"],
  471. dependencies=[Depends(get_current_user)],
  472. )
  473. def getGuiConfigs():
  474. return gui_config_repo.list()
  475. @router.post("/postGuiConfig", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  476. def postGuiConfig(item: GuiConfigItem):
  477. gui_config_repo.add(item)
  478. return {"message": "OK"}
  479. @router.put("/updateGuiConfig", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  480. def updateGuiConfig(item: GuiConfigItem):
  481. gui_config_repo.update(item)
  482. return {"message": "OK"}
  483. @router.delete("/removeGuiConfig/{gui_config_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  484. def removeGuiConfig(gui_config_id: str):
  485. gui_config_repo.remove(gui_config_id)
  486. return {"message": "OK"}
  487. @router.get(
  488. "/getCoreSettings",
  489. response_model=List[CoreSettingsItem],
  490. tags=["Reslevis"],
  491. dependencies=[Depends(get_current_user)],
  492. )
  493. async def getCoreSettings():
  494. async with httpx.AsyncClient(timeout=CORE_TIMEOUT) as client:
  495. resp = await client.get(f"{SETTINGS_CORE_BASE_URL}/reslevis/settings")
  496. if resp.status_code >= 400:
  497. detail = resp.text.strip() or "CORE settings request failed"
  498. raise HTTPException(status_code=resp.status_code, detail=detail)
  499. try:
  500. payload = resp.json()
  501. except ValueError as exc:
  502. raise HTTPException(status_code=502, detail="Invalid CORE response") from exc
  503. if not isinstance(payload, list):
  504. raise HTTPException(status_code=502, detail="Unexpected CORE response type")
  505. return payload
  506. @router.put(
  507. "/updateCoreSettings",
  508. tags=["Reslevis"],
  509. dependencies=[Depends(get_current_user)],
  510. )
  511. async def updateCoreSettings(item: CoreSettingsUpdateItem):
  512. async with httpx.AsyncClient(timeout=CORE_TIMEOUT) as client:
  513. resp = await client.patch(
  514. f"{SETTINGS_CORE_BASE_URL}/reslevis/settings",
  515. json=item.model_dump(exclude_none=True),
  516. )
  517. if resp.status_code >= 400:
  518. detail = resp.text.strip() or "CORE settings update failed"
  519. raise HTTPException(status_code=resp.status_code, detail=detail)
  520. if not resp.content:
  521. return {"message": "OK"}
  522. try:
  523. return resp.json()
  524. except ValueError:
  525. return {"message": "OK"}