Nelze vybrat více než 25 témat Téma musí začínat písmenem nebo číslem, může obsahovat pomlčky („-“) a může být dlouhé až 35 znaků.
 
 
 
 

543 řádky
16 KiB

  1. import asyncio
  2. from fastapi import APIRouter, Depends, HTTPException, Query, Request
  3. import httpx
  4. import config_env
  5. from typing import List, Optional
  6. from schemas.reslevis import (
  7. BuildingItem,
  8. FloorItem,
  9. ZoneItem,
  10. GatewayItem,
  11. TrackerItem,
  12. OperatorItem,
  13. SubjectItem,
  14. AlarmItem,
  15. TrackItem,
  16. TrackHistoryItem,
  17. TrackerZoneItem,
  18. SettingItem,
  19. )
  20. from logica_reslevis.gateway import GatewayJsonRepository
  21. from logica_reslevis.building import BuildingJsonRepository
  22. from logica_reslevis.floor import FloorJsonRepository
  23. from logica_reslevis.zone import ZoneJsonRepository
  24. from logica_reslevis.tracker import TrackerJsonRepository
  25. from logica_reslevis.operator import OperatorJsonRepository
  26. from logica_reslevis.setting import SettingJsonRepository
  27. from logica_reslevis.subject import SubjectJsonRepository
  28. from logica_reslevis.alarm import AlarmJsonRepository
  29. from logica_reslevis.track import TrackJsonRepository
  30. from logica_reslevis.tracker_zone import TrackerZoneJsonRepository
  31. from security import get_current_user
  32. #CORE SYNC
  33. CORE_BASE_URL = config_env.CORE_API_URL.rstrip("/")
  34. CORE_TIMEOUT = 2.0 # secondi
  35. async def sync_core_get(request: Request) -> None:
  36. if request.method != "GET":
  37. return
  38. sync = CORE_GET_SYNC.get(request.url.path)
  39. if sync is None:
  40. return
  41. repo, normalizer = sync
  42. try:
  43. async with httpx.AsyncClient(timeout=CORE_TIMEOUT) as client:
  44. resp = await client.get(
  45. f"{CORE_BASE_URL}{request.url.path}",
  46. params=request.query_params,
  47. )
  48. if 200 <= resp.status_code < 300:
  49. data = resp.json()
  50. if isinstance(data, list):
  51. if normalizer:
  52. data = [normalizer(r) for r in data if isinstance(r, dict)]
  53. repo._write_all(data) # aggiorna i file locali
  54. except (httpx.RequestError, ValueError):
  55. # CORE giù o risposta non valida -> uso il file locale
  56. pass
  57. router = APIRouter(dependencies=[Depends(sync_core_get)])
  58. gateway_repo = GatewayJsonRepository()
  59. building_repo = BuildingJsonRepository()
  60. floor_repo = FloorJsonRepository()
  61. zone_repo = ZoneJsonRepository()
  62. tracker_repo = TrackerJsonRepository()
  63. operator_repo = OperatorJsonRepository()
  64. subject_repo = SubjectJsonRepository()
  65. alarm_repo = AlarmJsonRepository()
  66. track_repo = TrackJsonRepository()
  67. tracker_zone_repo = TrackerZoneJsonRepository()
  68. setting_repo = SettingJsonRepository()
  69. def _none_if_empty(v):
  70. return None if v in ("", None, 0, "0") else v
  71. def _str_or_none(v):
  72. if v in ("", None):
  73. return None
  74. if isinstance(v, (int, float, bool)):
  75. return str(v)
  76. return v
  77. def _uuid_list(values):
  78. if values in ("", None):
  79. return []
  80. if isinstance(values, str):
  81. values = [v for v in values.split(",") if v]
  82. if isinstance(values, (list, tuple, set)):
  83. cleaned = []
  84. for v in values:
  85. if isinstance(v, dict):
  86. v = v.get("id") or v.get("uuid")
  87. if v in ("", None, 0, "0"):
  88. continue
  89. cleaned.append(v)
  90. return cleaned
  91. return [values] if values not in ("", None, 0, "0") else []
  92. def _normalize_gateway(row: dict) -> dict:
  93. row = dict(row)
  94. row["floor"] = _none_if_empty(row.get("floor"))
  95. row["building"] = _none_if_empty(row.get("building"))
  96. return row
  97. def _normalize_tracker(row: dict) -> dict:
  98. row = dict(row)
  99. row["floor"] = _none_if_empty(row.get("floor"))
  100. row["building"] = _none_if_empty(row.get("building"))
  101. row["battery"] = _str_or_none(row.get("battery"))
  102. row["temperature"] = _str_or_none(row.get("temperature"))
  103. row["acceleration"] = _str_or_none(row.get("acceleration"))
  104. row["heartRate"] = _str_or_none(row.get("heartRate"))
  105. return row
  106. def _normalize_track(row: dict) -> dict:
  107. row = dict(row)
  108. row["ID"] = row.get("ID")
  109. row["gateway"] = _none_if_empty(row.get("gateway"))
  110. row["tracker"] = _none_if_empty(row.get("tracker"))
  111. row["subject"] = _none_if_empty(row.get("subject"))
  112. row["floor"] = _none_if_empty(row.get("floor"))
  113. row["building"] = _none_if_empty(row.get("building"))
  114. row["timestamp"] = _str_or_none(row.get("timestamp"))
  115. row["type"] = _str_or_none(row.get("type"))
  116. row["status"] = _str_or_none(row.get("status"))
  117. row["gatewayMac"] = _str_or_none(row.get("gatewayMac"))
  118. row["trackerMac"] = _str_or_none(row.get("trackerMac"))
  119. row["subjectName"] = _str_or_none(row.get("subjectName"))
  120. row["x"] = None if row.get("x") in ("", None) else row.get("x")
  121. row["y"] = None if row.get("y") in ("", None) else row.get("y")
  122. row["z"] = None if row.get("z") in ("", None) else row.get("z")
  123. # signal resta float o None
  124. row["signal"] = None if row.get("signal") in ("", None) else row.get("signal")
  125. return row
  126. def _normalize_zone(row: dict) -> dict:
  127. row = dict(row)
  128. row["floor"] = _none_if_empty(row.get("floor"))
  129. row["building"] = _none_if_empty(row.get("building"))
  130. row["groups"] = _uuid_list(row.get("groups"))
  131. return row
  132. CORE_GET_SYNC = {
  133. "/reslevis/getGateways": (gateway_repo, _normalize_gateway),
  134. "/reslevis/getZones": (zone_repo, _normalize_zone),
  135. "/reslevis/getTrackers": (tracker_repo, _normalize_tracker),
  136. }
  137. async def _core_get_json(
  138. client: httpx.AsyncClient,
  139. path: str,
  140. params: Optional[dict] = None,
  141. ):
  142. resp = await client.get(f"{CORE_BASE_URL}{path}", params=params)
  143. if resp.status_code >= 400:
  144. detail = resp.text.strip() or "CORE request failed"
  145. raise HTTPException(status_code=resp.status_code, detail=detail)
  146. try:
  147. return resp.json()
  148. except ValueError as exc:
  149. raise HTTPException(status_code=502, detail="Invalid CORE response") from exc
  150. async def _fetch_tracks_for_tracker(
  151. client: httpx.AsyncClient,
  152. tracker_id: str,
  153. params: Optional[dict] = None,
  154. ) -> List[dict]:
  155. payload = await _core_get_json(client, f"/reslevis/getTracks/{tracker_id}", params=params)
  156. if not isinstance(payload, list):
  157. raise HTTPException(status_code=502, detail="Unexpected CORE response type")
  158. return [_normalize_track(row) for row in payload if isinstance(row, dict)]
  159. def _sort_tracks_desc(rows: List[dict]) -> List[dict]:
  160. return sorted(rows, key=lambda row: row.get("timestamp") or "", reverse=True)
  161. async def _fetch_all_tracks(params: dict) -> List[dict]:
  162. async with httpx.AsyncClient(timeout=30.0, verify=False) as client:
  163. try:
  164. payload = await _core_get_json(client, "/reslevis/getTracks", params=params)
  165. if not isinstance(payload, list):
  166. raise HTTPException(status_code=502, detail="Unexpected CORE response type")
  167. return [_normalize_track(row) for row in payload if isinstance(row, dict)]
  168. except HTTPException as exc:
  169. if exc.status_code != 404:
  170. raise
  171. trackers_payload = await _core_get_json(client, "/reslevis/getTrackers")
  172. if not isinstance(trackers_payload, list):
  173. raise HTTPException(status_code=502, detail="Unexpected CORE tracker response type")
  174. tracker_ids = []
  175. for item in trackers_payload:
  176. if not isinstance(item, dict):
  177. continue
  178. tracker_id = item.get("id")
  179. if tracker_id:
  180. tracker_ids.append(str(tracker_id))
  181. batches = await asyncio.gather(
  182. *[_fetch_tracks_for_tracker(client, tracker_id, params) for tracker_id in tracker_ids]
  183. )
  184. merged = [row for batch in batches for row in batch]
  185. merged = _sort_tracks_desc(merged)
  186. limit = params.get("limit")
  187. if isinstance(limit, int):
  188. return merged[:limit]
  189. return merged
  190. @router.get(
  191. "/getGateways",
  192. response_model=List[GatewayItem],
  193. tags=["Reslevis"],
  194. dependencies=[Depends(get_current_user)],
  195. )
  196. def getGateways():
  197. return gateway_repo.list()
  198. @router.post("/postGateway", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  199. def postGateway(item: GatewayItem):
  200. gateway_repo.add(item)
  201. return {"message": "OK"}
  202. @router.put("/updateGateway", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  203. def updateGateway(item: GatewayItem):
  204. gateway_repo.update(item)
  205. return {"message": "OK"}
  206. @router.delete("/removeGateway/{gateway_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  207. def removeGateway(gateway_id: str):
  208. gateway_repo.remove(gateway_id)
  209. return {"message": "OK"}
  210. @router.get(
  211. "/getBuildings",
  212. response_model=List[BuildingItem],
  213. tags=["Reslevis"],
  214. dependencies=[Depends(get_current_user)],
  215. )
  216. def getBuildings():
  217. return building_repo.list()
  218. @router.post("/postBuilding", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  219. def postBuilding(item: BuildingItem):
  220. building_repo.add(item)
  221. return {"message": "OK"}
  222. @router.put("/updateBuilding", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  223. def updateBuilding(item: BuildingItem):
  224. building_repo.update(item)
  225. return {"message": "OK"}
  226. @router.delete("/removeBuilding/{building_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  227. def removeBuilding(building_id: str):
  228. building_repo.remove(building_id)
  229. return {"message": "OK"}
  230. @router.get(
  231. "/getFloors",
  232. response_model=List[FloorItem],
  233. tags=["Reslevis"],
  234. dependencies=[Depends(get_current_user)],
  235. )
  236. def getFloors():
  237. return floor_repo.list()
  238. @router.post("/postFloor", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  239. def postFloor(item: FloorItem):
  240. floor_repo.add(item)
  241. return {"message": "OK"}
  242. @router.put("/updateFloor", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  243. def updateFloor(item: FloorItem):
  244. floor_repo.update(item)
  245. return {"message": "OK"}
  246. @router.delete("/removeFloor/{floor_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  247. def removeFloor(floor_id: str):
  248. floor_repo.remove(floor_id)
  249. return {"message": "OK"}
  250. @router.get(
  251. "/getZones",
  252. response_model=List[ZoneItem],
  253. tags=["Reslevis"],
  254. dependencies=[Depends(get_current_user)],
  255. )
  256. def getZones():
  257. return zone_repo.list()
  258. @router.post("/postZone", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  259. def postZone(item: ZoneItem):
  260. zone_repo.add(item)
  261. return {"message": "OK"}
  262. @router.put("/updateZone", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  263. def updateZone(item: ZoneItem):
  264. zone_repo.update(item)
  265. return {"message": "OK"}
  266. @router.delete("/removeZone/{zone_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  267. def removeZone(zone_id: str):
  268. zone_repo.remove(zone_id)
  269. return {"message": "OK"}
  270. @router.get(
  271. "/getTrackers",
  272. response_model=List[TrackerItem],
  273. tags=["Reslevis"],
  274. dependencies=[Depends(get_current_user)],
  275. )
  276. def getTrackers():
  277. return tracker_repo.list()
  278. @router.post("/postTracker", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  279. def postTracker(item: TrackerItem):
  280. tracker_repo.add(item)
  281. return {"message": "OK"}
  282. @router.put("/updateTracker", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  283. def updateTracker(item: TrackerItem):
  284. tracker_repo.update(item)
  285. return {"message": "OK"}
  286. @router.delete("/removeTracker/{tracker_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  287. def removeTracker(tracker_id: str):
  288. tracker_repo.remove(tracker_id)
  289. return {"message": "OK"}
  290. @router.get(
  291. "/getTrackerZones",
  292. response_model=List[TrackerZoneItem],
  293. tags=["Reslevis"],
  294. dependencies=[Depends(get_current_user)],
  295. )
  296. def getTrackerZones():
  297. return tracker_zone_repo.list()
  298. @router.post("/postTrackerZone", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  299. def postTrackerZone(item: TrackerZoneItem):
  300. tracker_zone_repo.add(item)
  301. return {"message": "OK"}
  302. @router.put("/updateTrackerZone", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  303. def updateTrackerZone(item: TrackerZoneItem):
  304. tracker_zone_repo.update(item)
  305. return {"message": "OK"}
  306. @router.delete("/removeTrackerZone/{tracker_zone_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  307. def removeTrackerZone(tracker_zone_id: str):
  308. tracker_zone_repo.remove(tracker_zone_id)
  309. return {"message": "OK"}
  310. @router.get(
  311. "/getTracks",
  312. response_model=List[TrackHistoryItem],
  313. tags=["Reslevis"],
  314. dependencies=[Depends(get_current_user)],
  315. )
  316. async def getTracks(
  317. limit: Optional[int] = Query(None, ge=1),
  318. from_: Optional[str] = Query(None, alias="from"),
  319. to: Optional[str] = Query(None),
  320. ):
  321. params = {}
  322. if limit is not None:
  323. params["limit"] = limit
  324. if from_:
  325. params["from"] = from_
  326. if to:
  327. params["to"] = to
  328. try:
  329. return await _fetch_all_tracks(params)
  330. except httpx.RequestError as exc:
  331. raise HTTPException(status_code=502, detail=f"CORE request failed: {exc}") from exc
  332. @router.get(
  333. "/getTracks/{tracker_id}",
  334. response_model=List[TrackHistoryItem],
  335. tags=["Reslevis"],
  336. dependencies=[Depends(get_current_user)],
  337. )
  338. async def getTrack(
  339. tracker_id: str,
  340. limit: Optional[int] = Query(None, ge=1),
  341. from_: Optional[str] = Query(None, alias="from"),
  342. to: Optional[str] = Query(None),
  343. ):
  344. params = {}
  345. if limit is not None:
  346. params["limit"] = limit
  347. if from_:
  348. params["from"] = from_
  349. if to:
  350. params["to"] = to
  351. try:
  352. async with httpx.AsyncClient(timeout=30.0, verify=False) as client:
  353. return await _fetch_tracks_for_tracker(client, tracker_id, params)
  354. except httpx.RequestError as exc:
  355. raise HTTPException(status_code=502, detail=f"CORE request failed: {exc}") from exc
  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. "/getOperators",
  370. response_model=List[OperatorItem],
  371. tags=["Reslevis"],
  372. dependencies=[Depends(get_current_user)],
  373. )
  374. def getOperators():
  375. return operator_repo.list()
  376. @router.post("/postOperator", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  377. def postOperator(item: OperatorItem):
  378. operator_repo.add(item)
  379. return {"message": "OK"}
  380. @router.put("/updateOperator", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  381. def updateOperator(item: OperatorItem):
  382. operator_repo.update(item)
  383. return {"message": "OK"}
  384. @router.delete("/removeOperator/{operator_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  385. def removeOperator(operator_id: str):
  386. operator_repo.remove(operator_id)
  387. return {"message": "OK"}
  388. @router.get(
  389. "/getSubjects",
  390. response_model=List[SubjectItem],
  391. tags=["Reslevis"],
  392. dependencies=[Depends(get_current_user)],
  393. )
  394. def getSubjects():
  395. return subject_repo.list()
  396. @router.post("/postSubject", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  397. def postSubject(item: SubjectItem):
  398. subject_repo.add(item)
  399. return {"message": "OK"}
  400. @router.put("/updateSubject", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  401. def updateSubject(item: SubjectItem):
  402. subject_repo.update(item)
  403. return {"message": "OK"}
  404. @router.delete("/removeSubject/{subject_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  405. def removeSubject(subject_id: str):
  406. subject_repo.remove(subject_id)
  407. return {"message": "OK"}
  408. @router.get(
  409. "/getSettings",
  410. response_model=List[SettingItem],
  411. tags=["Reslevis"],
  412. dependencies=[Depends(get_current_user)],
  413. )
  414. def getSettings():
  415. return setting_repo.list()
  416. @router.post("/postSetting", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  417. def postSetting(item: SettingItem):
  418. setting_repo.add(item)
  419. return {"message": "OK"}
  420. @router.put("/updateSetting", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  421. def updateSetting(item: SettingItem):
  422. setting_repo.update(item)
  423. return {"message": "OK"}
  424. @router.delete("/removeSetting/{setting_id}", tags=["Reslevis"], dependencies=[Depends(get_current_user)])
  425. def removeSetting(setting_id: str):
  426. setting_repo.remove(setting_id)
  427. return {"message": "OK"}