mn1_rec.py 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397
  1. '''
  2. Schéma de validation des données MN1
  3. @author: olivier.massot, 2018
  4. '''
  5. import logging
  6. from qgis.core import QgsGeometry
  7. from core.cerberus_ import is_float, is_multi_int, is_int, \
  8. is_modern_french_date
  9. from core.validation_errors import UniqueError, RelationError, \
  10. DuplicatedGeom, MissingItem, DimensionError, TechnicalValidationError
  11. from core.validator import QgsModel, BaseValidator
  12. logger = logging.getLogger("mncheck")
  13. SCHEMA_NAME = "Schéma MN v1 REC"
  14. XMIN, XMAX, YMIN, YMAX = 1341999, 1429750, 8147750, 8294000
  15. CRS = 'EPSG:3949' # Coordinate Reference System
  16. TOLERANCE = 1
  17. class Artere(QgsModel):
  18. layername = "artere_geo"
  19. geom_type = QgsModel.GEOM_LINE
  20. crs = CRS
  21. bounding_box = (XMIN,YMIN,XMAX,YMAX)
  22. schema = {'AR_ID_INSE': {'type': 'string', 'empty': False, 'regex': r'50\d{3}'},
  23. 'AR_LONG': {'empty': False, 'validator': is_float},
  24. 'AR_ETAT': {'type': 'string', 'empty': False, 'allowed': ['0', '1', '2', '3', '4']},
  25. 'AR_OCCP': {'type': 'string', 'empty': False, 'allowed': ['0', '1.1', '1.2', '2', '3', '4']},
  26. 'AR_NOEUD_A': {'type': 'string', 'empty': False, 'maxlength': 20},
  27. 'AR_NOEUD_B': {'type': 'string', 'empty': False, 'maxlength': 20},
  28. 'AR_NB_FOUR': {'empty': False, 'validator': is_multi_int},
  29. 'AR_FOU_DIS': {'empty': False, 'validator': is_int},
  30. 'AR_TYPE_FO': {'type': 'string', 'multiallowed': ['PVC', 'PEHD', 'SOUS-TUBAGE PEHD', 'SOUS-TUBAGE SOUPLE', 'FACADE', 'AERIEN', 'ENCORBELLEMENT', 'AUTRE']},
  31. 'AR_DIAM_FO': {'type': 'string', 'multiallowed': ['10', '14', '18', '25', '28', '32', '40', '45', '60', '80', '150', 'NUL']},
  32. 'AR_PRO_FOU': {'type': 'string', 'multiallowed': ['MANCHE NUMERIQUE', 'COLLECTIVITE', 'ORANGE', 'PRIVE', 'ERDF', 'AUTRE (à préciser)']},
  33. 'AR_PRO_CAB': {'type': 'string', 'empty': False, 'allowed': ['MANCHE NUMERIQUE']},
  34. 'AR_GEST_FO': {'type': 'string', 'multiallowed': ['MANCHE NUMERIQUE', 'MANCHE TELECOM', 'COLLECTIVITE', 'ORANGE', 'MANCHE FIBRE', 'PRIVE', 'ERDF', 'AUTRE (à préciser)', 'NUL']},
  35. 'AR_UTIL_FO': {'type': 'string', 'multiallowed': ['MANCHE NUMERIQUE', 'MANCHE TELECOM', 'COLLECTIVITE', 'ORANGE', 'MANCHE FIBRE', 'PRIVE', 'AUTRE (à préciser)', 'NUL']},
  36. 'AR_DATE_IN': {'empty': False, 'validator': is_modern_french_date},
  37. 'AR_DATE_RE': {'empty': False, 'validator': is_modern_french_date},
  38. 'AR_REF_PLA': {'type': 'string', 'maxlength': 100},
  39. 'AR_SRC_GEO': {'type': 'string', 'maxlength': 50},
  40. 'AR_QLT_GEO': {'type': 'string', 'empty': False, 'allowed': ['A', 'B', 'C']},
  41. 'AR_PRO_MD': {'type': 'string', 'empty': False, 'default': 'MANCHE NUMERIQUE', 'allowed': ['MANCHE NUMERIQUE']},
  42. 'AR_COMMENT': {'type': 'string', 'maxlength': 300, 'empty': True},
  43. 'AR_STATUT': {'type': 'string', 'empty': False, 'allowed': ['APS', 'APD', 'EXE', 'REC']}}
  44. def __repr__(self):
  45. return "Artere {}-{}".format(self.AR_NOEUD_A, self.AR_NOEUD_B)
  46. class Cable(QgsModel):
  47. layername = "cable_geo"
  48. geom_type = QgsModel.GEOM_LINE
  49. crs = CRS
  50. bounding_box = (XMIN,YMIN,XMAX,YMAX)
  51. schema = {'CA_NUMERO': {'type': 'string', 'maxlength': 17},
  52. 'CA_TYPE': {'type': 'string', 'maxlength': 10, 'empty': False, 'allowed': ['AERIEN', 'IMMEUBLE', 'FACADE', 'MIXTE', 'SOUTERRAIN']},
  53. 'CA_ETAT': {'type': 'string', 'maxlength': 1, 'empty': False, 'allowed': ['0', '1', '2', '3', '4']},
  54. 'CA_LONG': {'validator': is_float},
  55. 'CA_EQ_A': {'type': 'string', 'maxlength': 18},
  56. 'CA_EQ_B': {'type': 'string', 'maxlength': 18},
  57. 'CA_DIAMETR': {'empty': False, 'validator': is_float},
  58. 'CA_COULEUR': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['NOIR', 'BLEU', 'BLANC']},
  59. 'CA_TECHNOL': {'type': 'string', 'maxlength': 17, 'empty': False, 'allowed': ['G657A2_M6', 'G657A2_M12']},
  60. 'CA_NB_FO': {'validator': is_int},
  61. 'CA_NB_FO_U': {'empty': False, 'validator': is_int},
  62. 'CA_NB_FO_D': {'empty': False, 'validator': is_int},
  63. 'CA_PRO': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['MANCHE NUMERIQUE']},
  64. 'CA_GEST': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['MANCHE FIBRE']},
  65. 'CA_DATE_IN': {'empty': False, 'validator': is_modern_french_date},
  66. 'CA_COMMENT': {'type': 'string', 'maxlength': 300, 'empty': True},
  67. 'CA_STATUT': {'type': 'string', 'maxlength': 14, 'empty': False, 'allowed': ['APS', 'APD', 'EXE', 'REC']}}
  68. def __repr__(self):
  69. return "Cable {}-{}".format(self.CA_EQ_A, self.CA_EQ_B)
  70. class Equipement(QgsModel):
  71. layername = "equipement_passif"
  72. geom_type = QgsModel.GEOM_POINT
  73. crs = CRS
  74. bounding_box = (XMIN,YMIN,XMAX,YMAX)
  75. schema = {'EQ_NOM': {'type': 'string', 'maxlength': 10, 'contains_any_of': ['PBO', 'BPE', 'BAI']},
  76. 'EQ_NOM_NOE': {'type': 'string', 'maxlength': 30},
  77. 'EQ_ETAT': {'type': 'string', 'maxlength': 1, 'empty': False, 'allowed': ['0', '1', '2', '3', '4']},
  78. 'EQ_OCCP': {'type': 'string', 'maxlength': 3, 'empty': False, 'allowed': ['0', '1.1', '1.2', '2', '3', '4']},
  79. 'EQ_TYPE': {'type': 'string', 'empty': False, 'allowed': ['PBO', 'PBOE', 'BPE', 'BAI']},
  80. 'EQ_TYPE_LQ': {'type': 'string', 'maxlength': 6, 'empty': False, 'allowed': ['PBO', 'BPE JB', 'BPE JD', 'BAIDC', 'BAIOP']},
  81. 'EQ_TYPE_PH': {'type': 'string', 'maxlength': 24, 'empty': False, 'allowed': ['PBO 6', 'PBO 12', 'BPE 12EP', 'BPE 24EP', 'BPE 48EP', 'BPE 72EP', 'BPE 96EP', 'BPE 144EP', 'BPE 288EP', 'BPE 576EP', 'BPE 720EP', 'BAI']},
  82. 'EQ_PRO': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['MANCHE NUMERIQUE', 'COLLECTIVITE', 'ORANGE', 'PRIVE', 'AUTRE (à préciser)', 'NUL']},
  83. 'EQ_GEST': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['MANCHE NUMERIQUE', 'MANCHE TELECOM', 'COLLECTIVITE', 'ORANGE', 'MANCHE FIBRE', 'PRIVE', 'AUTRE (à préciser)', 'NUL']},
  84. 'EQ_HAUT': {'empty': False, 'validator': is_float},
  85. 'EQ_DATE_IN': {'empty': False, 'validator': is_modern_french_date},
  86. 'EQ_COMMENT': {'type': 'string', 'maxlength': 300, 'empty': True},
  87. 'EQ_STATUT': {'type': 'string', 'maxlength': 14, 'empty': False, 'allowed': ['APS', 'APD', 'EXE', 'REC']}}
  88. def __repr__(self):
  89. return "Equipement {}".format(self.EQ_NOM)
  90. class Noeud(QgsModel):
  91. layername = "noeud_geo"
  92. geom_type = QgsModel.GEOM_POINT
  93. crs = CRS
  94. bounding_box = (XMIN,YMIN,XMAX,YMAX)
  95. schema = {'NO_NOM': {'type': 'string', 'maxlength': 30},
  96. 'NO_ID_INSE': {'type': 'string', 'empty': False, 'regex': r'50\d{3}'},
  97. 'NO_VOIE': {'type': 'string', 'maxlength': 100},
  98. 'NO_ETAT': {'type': 'string', 'maxlength': 1, 'empty': False, 'allowed': ['0', '1', '2', '3', '4']},
  99. 'NO_OCCP': {'type': 'string', 'maxlength': 3, 'empty': False, 'allowed': ['0', '1.1', '1.2', '2', '3', '4']},
  100. 'NO_TYPE': {'type': 'string', 'maxlength': 3, 'empty': False, 'allowed': ['CHA', 'POT', 'LTE', 'SEM', 'FAC', 'OUV', 'IMM']},
  101. 'NO_TYPE_LQ': {'type': 'string', 'maxlength': 10, 'empty': False, 'allowed': ['CHTIR', 'CHRACC', 'POT', 'NRO', 'PM', 'MIMO', 'FAC', 'OUV', 'IMM']},
  102. 'NO_TYPE_PH': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['CHAMBRE', 'POTEAU', 'ARMOIRE', 'SHELTER', 'BATIMENT', 'SITE MIMO', 'FACADE', 'OUVRAGE', 'IMMEUBLE']},
  103. 'NO_CODE_PH': {'type': 'string', 'maxlength': 20},
  104. 'NO_TECH_PS': {'type': 'string', 'maxlength': 20, 'multiallowed': ['COAX', 'CUT', 'ECL', 'ELEC', 'VP', 'OPT', 'NC']},
  105. 'NO_AMO': {'type': 'string', 'maxlength': 20},
  106. 'NO_PLINOX': {'required':False, 'type': 'string', 'maxlength': 3, 'allowed': ['OUI', 'NON']},
  107. 'NO_X': {'empty': False, 'validator': is_float},
  108. 'NO_Y': {'empty': False, 'validator': is_float},
  109. 'NO_PRO': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['MANCHE NUMERIQUE', 'COLLECTIVITE', 'ORANGE', 'ERDF', 'PRIVE', 'ENEDIS', 'AUTRE (à préciser)', 'NUL']},
  110. 'NO_GEST': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['MANCHE NUMERIQUE', 'MANCHE TELECOM', 'COLLECTIVITE', 'ORANGE', 'ERDF', 'ENEDIS', 'MANCHE FIBRE', 'PRIVE', 'AUTRE (à préciser)', 'NUL']},
  111. 'NO_HAUT': {'empty': False, 'validator': is_float},
  112. 'NO_DATE_IN': {'empty': False, 'validator': is_modern_french_date},
  113. 'NO_REF_PLA': {'type': 'string', 'maxlength': 100},
  114. 'NO_SRC_GEO': {'type': 'string', 'maxlength': 50},
  115. 'NO_QLT_GEO': {'type': 'string', 'maxlength': 1, 'empty': False, 'allowed': ['A', 'B', 'C']},
  116. 'NO_PRO_MD': {'type': 'string', 'maxlength': 20, 'empty': False, 'allowed': ['MANCHE NUMERIQUE']},
  117. 'NO_COMMENT': {'type': 'string', 'maxlength': 300, 'empty': True},
  118. 'NO_STATUT': {'type': 'string', 'maxlength': 14, 'empty': False, 'allowed': ['APS', 'APD', 'EXE', 'REC']}}
  119. def __repr__(self):
  120. return "Noeud {}".format(self.NO_NOM)
  121. class Tranchee(QgsModel):
  122. layername = "tranchee_geo"
  123. geom_type = QgsModel.GEOM_LINE
  124. crs = CRS
  125. bounding_box = (XMIN,YMIN,XMAX,YMAX)
  126. schema = {'TR_ID_INSE': {'type': 'string', 'empty': False, 'regex': r'50\d{3}'},
  127. 'TR_VOIE': {'type': 'string', 'maxlength': 200},
  128. 'TR_TYP_IMP': {'type': 'string', 'empty': False, 'allowed': ['ACCOTEMENT STABILISE', 'ACCOTEMENT NON STABILISE', 'CHAUSSEE LOURDE', 'CHAUSSEE LEGERE', 'FOSSE', 'TROTTOIR', 'ESPACE VERT', 'ENCORBELLEMENT']},
  129. 'TR_MOD_POS': {'type': 'string', 'empty': False, 'allowed': ['TRADITIONNEL', 'MICRO TRANCHEE', 'FONCAGE 60', 'FONCAGE 90', 'FONCAGE 120', 'TRANCHEUSE', 'FORAGE URBAIN', 'FORAGE RURAL', 'ENCORBELLEMENT']},
  130. 'TR_LONG': {'empty': False, 'validator': is_float},
  131. 'TR_LARG': {'empty': False, 'validator': is_float},
  132. 'TR_REVET': {'empty':True, 'type': 'string', 'allowed': ['SABLE', 'BICOUCHE', 'ENROBE', 'BETON', 'PAVE', 'TERRAIN NATUREL']},
  133. 'TR_CHARGE': {'empty': False, 'validator': is_float},
  134. 'TR_GRILLAG': {'empty':True, 'validator': is_float},
  135. 'TR_REMBLAI': {'type': 'string'},
  136. 'TR_PLYNOX': {'type': 'string', 'empty': False, 'allowed': ['OUI', 'NON']},
  137. 'TR_PRO_VOI': {'type': 'string', 'empty': False, 'allowed': ['COMMUNE', 'COMMUNAUTE DE COMMUNES', 'DEPARTEMENT', 'ETAT', 'PRIVE']},
  138. 'TR_GEST_VO': {'type': 'string', 'empty': False, 'allowed': ['COMMUNE', 'COMMUNAUTE DE COMMUNES', 'DEPARTEMENT', 'ETAT', 'PRIVE']},
  139. 'TR_SCHEMA': {'maxlength': 100, 'type': 'string'},
  140. 'TR_DATE_IN': {'empty': False, 'validator': is_modern_french_date},
  141. 'TR_SRC_GEO': {'type': 'string', 'maxlength': 50},
  142. 'TR_QLT_GEO': {'type': 'string', 'empty': False, 'allowed': ['A', 'B', 'C']},
  143. 'TR_PRO_MD': {'type': 'string', 'maxlength': 20},
  144. 'TR_COMMENT': {'type': 'string', 'maxlength': 300, 'empty': True},
  145. 'TR_STATUT': {'type': 'string', 'empty': False, 'allowed': ['APS', 'APD', 'EXE', 'REC']}}
  146. def __repr__(self):
  147. return "Tranchee {}".format(self.TR_VOIE)
  148. class Zapbo(QgsModel):
  149. layername = "zapbo_geo"
  150. geom_type = QgsModel.GEOM_POLYGON
  151. crs = CRS
  152. bounding_box = (XMIN,YMIN,XMAX,YMAX)
  153. schema = {'ID_ZAPBO': {'type': 'string', 'maxlength': 30, 'contains_any_of': ['PBO', 'BPE']},
  154. 'COMMENTAIR': {'type': 'string', 'maxlength': 254, 'empty': True},
  155. 'STATUT': {'type': 'string', 'empty': False, 'allowed': ['APS', 'APD', 'EXE', 'REC']}}
  156. def __repr__(self):
  157. return "Zapbo {}".format(self.ID_ZAPBO)
  158. ####### Validateur
  159. class Validator(BaseValidator):
  160. schema_name = "Mn1 REC"
  161. models = [Artere, Cable, Equipement, Noeud, Tranchee, Zapbo]
  162. def _technical_validation(self):
  163. # construction des index
  164. arteres = self.dataset[Artere]
  165. cables = self.dataset[Cable]
  166. tranchees = self.dataset[Tranchee]
  167. noeuds = {}
  168. for noeud in self.dataset[Noeud]:
  169. if not noeud.NO_NOM in noeuds:
  170. noeuds[noeud.NO_NOM] = noeud
  171. else:
  172. self.log_error(UniqueError("Doublons dans le champs: {}".format(noeud), layername=Noeud.layername, field="NO_NOM"))
  173. equipements = {}
  174. for equipement in self.dataset[Equipement]:
  175. if not equipement.EQ_NOM in equipements:
  176. equipements[equipement.EQ_NOM] = equipement
  177. else:
  178. self.log_error(UniqueError("Doublons dans le champs: {}".format(equipement), layername=Equipement.layername, field="EQ_NOM"))
  179. zapbos = {}
  180. for zapbo in self.dataset[Zapbo]:
  181. if not zapbo.ID_ZAPBO in zapbos:
  182. zapbos[zapbo.ID_ZAPBO] = zapbo
  183. else:
  184. self.log_error(UniqueError("Doublons dans le champs: {}".format(zapbo), layername=Zapbo.layername, field="ID_ZAPBO"))
  185. # rattachement les noeuds aux artères
  186. for artere in arteres:
  187. try:
  188. artere.noeud_a = noeuds[artere.AR_NOEUD_A]
  189. except KeyError:
  190. artere.noeud_a = None
  191. self.log_error(RelationError("Le noeud '{}' n'existe pas".format(artere.AR_NOEUD_A), layername=Artere.layername, field="AR_NOEUD_A"))
  192. try:
  193. artere.noeud_b = noeuds[artere.AR_NOEUD_B]
  194. except KeyError:
  195. artere.noeud_b = None
  196. self.log_error(RelationError("Le noeud '{}' n'existe pas".format(artere.AR_NOEUD_B), layername=Artere.layername, field="AR_NOEUD_A"))
  197. # rattachement des equipements aux cables
  198. for cable in cables:
  199. try:
  200. cable.equipement_a = equipements[cable.CA_EQ_A]
  201. except KeyError:
  202. cable.equipement_a = None
  203. self.log_error(RelationError("L'équipement '{}' n'existe pas".format(cable.CA_EQ_A), layername=Cable.layername, field="CA_EQ_A"))
  204. try:
  205. cable.equipement_b = equipements[cable.CA_EQ_B]
  206. except KeyError:
  207. cable.equipement_b = None
  208. self.log_error(RelationError("L'équipement '{}' n'existe pas".format(cable.CA_EQ_B), layername=Cable.layername, field="CA_EQ_B"))
  209. # rattachement des equipements aux noeuds
  210. for equipement in equipements.values():
  211. try:
  212. equipement.noeud = noeuds[equipement.EQ_NOM_NOE]
  213. except KeyError:
  214. equipement.noeud = None
  215. self.log_error(RelationError("Le noeud '{}' n'existe pas".format(equipement.EQ_NOM_NOE, equipement.EQ_NOM), layername=Equipement.layername, field="EQ_NOM_NOE"))
  216. # verifie que tous les equipements sont l'equipement B d'au moins un cable
  217. equipements_b = [cable.CA_EQ_B for cable in cables]
  218. for eq_id in equipements:
  219. if equipements[eq_id].EQ_TYPE == "BAI":
  220. continue
  221. if not eq_id in equipements_b:
  222. self.log_error(RelationError("L'equipement '{}' n'est l'équipement B d'aucun cable".format(eq_id), layername=Equipement.layername, field="EQ_NOM"))
  223. # controle des doublons graphiques
  224. for i, tranchee in enumerate(tranchees):
  225. for other in tranchees[i+1:]:
  226. if tranchee.geom == other.geom:
  227. self.log_error(DuplicatedGeom("Une entité graphique est dupliquée".format(tranchee), layername=Tranchee.layername, field="geom"))
  228. for i, artere in enumerate(arteres):
  229. for other in arteres[i+1:]:
  230. if artere.geom == other.geom:
  231. self.log_error(DuplicatedGeom("Une entité graphique est dupliquée ('{}')".format(artere), layername=Artere.layername, field="geom"))
  232. for i, cable in enumerate(cables):
  233. for other in cables[i+1:]:
  234. if cable.geom == other.geom and cable.CA_EQ_A == other.CA_EQ_A and cable.CA_EQ_B == other.CA_EQ_B:
  235. self.log_error(DuplicatedGeom("Une entité graphique est dupliquée ('{}')".format(cable), layername=Cable.layername, field="geom"))
  236. ls_noeuds = list(noeuds.values())
  237. for i, noeud in enumerate(ls_noeuds):
  238. for other in ls_noeuds[i+1:]:
  239. if noeud.geom == other.geom:
  240. self.log_error(DuplicatedGeom("Une entité graphique est dupliquée ('{}')".format(noeud), layername=Noeud.layername, field="geom"))
  241. del ls_noeuds
  242. ls_zapbos = list(zapbos.values())
  243. for i, zapbo in enumerate(ls_zapbos):
  244. for other in ls_zapbos[i+1:]:
  245. if zapbo.geom == other.geom:
  246. self.log_error(DuplicatedGeom("Une entité graphique est dupliquée ('{}')".format(zapbo), layername=Zapbo.layername, field="geom"))
  247. del ls_zapbos
  248. # Arteres: comparer la géométrie à celle des noeuds
  249. for artere in arteres:
  250. if not artere.noeud_a or not artere.noeud_b:
  251. continue
  252. if not any(((artere.points[0].distanceSquared(artere.noeud_a.points[0]) <= TOLERANCE and \
  253. artere.points[-1].distanceSquared(artere.noeud_b.points[0]) <= TOLERANCE),
  254. (artere.points[0].distanceSquared(artere.noeud_b.points[0]) <= TOLERANCE and \
  255. artere.points[-1].distanceSquared(artere.noeud_a.points[0]) <= TOLERANCE))):
  256. self.log_error(MissingItem("Pas de noeud aux coordonnées attendues ('{}')".format(artere), layername=Artere.layername, field="geom"))
  257. # Cables: comparer la géométrie à celle des equipements (on utilise en fait la geom du noeud correspondant à l'équipement)
  258. for cable in cables:
  259. if not cable.equipement_a or not cable.equipement_b or not cable.is_geometry_valid() or not cable.equipement_a.noeud or not cable.equipement_b.noeud:
  260. continue
  261. if not any(((cable.points[0].distanceSquared(cable.equipement_a.noeud.points[0]) <= TOLERANCE and \
  262. cable.points[-1].distanceSquared(cable.equipement_b.noeud.points[0]) <= TOLERANCE),
  263. (cable.points[0].distanceSquared(cable.equipement_b.noeud.points[0]) <= TOLERANCE and \
  264. cable.points[-1].distanceSquared(cable.equipement_a.noeud.points[0]) <= TOLERANCE))):
  265. self.log_error(MissingItem("Pas d'equipement aux coordonnées attendues ('{}')".format(cable), layername=Cable.layername, field="geom"))
  266. # Verifie que chaque tranchée a au moins une artère
  267. arteres_full_buffer = QgsGeometry().unaryUnion([a.geom for a in arteres]).buffer(TOLERANCE, 100)
  268. for tranchee in tranchees:
  269. if not arteres_full_buffer.contains(tranchee.geom):
  270. self.log_error(MissingItem("Tranchée ou portion de tranchée sans artère ('{}')".format(tranchee), layername=Tranchee.layername, field="*"))
  271. # Verifie que chaque cable a au moins une artère (sauf si commentaire contient 'baguette')
  272. for cable in cables:
  273. if "baguette" in cable.CA_COMMENT.lower() or not cable.is_geometry_valid():
  274. continue
  275. if not arteres_full_buffer.contains(cable.geom):
  276. self.log_error(MissingItem("Cable ou portion de cable sans artère ('{}')".format(cable), layername=Cable.layername, field="*"))
  277. del arteres_full_buffer
  278. # Verifie que chaque artère a au moins un cable (sauf si commentaire contient un de ces mots 'racco client adductio attente bus 'sans cable'')
  279. cables_full_buffer = QgsGeometry().unaryUnion([c.geom for c in cables]).buffer(TOLERANCE, 100)
  280. for artere in arteres:
  281. if any(x in artere.AR_COMMENT.lower() for x in ['racco','client','adductio','attente','bus','sans cable']):
  282. continue
  283. if not cables_full_buffer.contains(artere.geom):
  284. self.log_error(MissingItem("Artère sans cable ('{}')".format(artere), layername=Artere.layername, field="*"))
  285. # Contrôle des dimensions logiques
  286. for artere in arteres:
  287. try:
  288. if not int(artere.AR_FOU_DIS) <= int(artere.AR_NB_FOUR):
  289. self.log_error(DimensionError("Le nombre de fourreaux disponibles doit être inférieur au nombre total ('{}')".format(artere), layername=Artere.layername, field="AR_FOU_DIS"))
  290. except (TypeError, ValueError):
  291. pass
  292. for cable in cables:
  293. try:
  294. if not int(cable.CA_NB_FO_U) <= int(cable.CA_NB_FO):
  295. self.log_error(DimensionError("Le nombre de fourreaux utilisés doit être inférieur au nombre total ('{}')".format(cable), layername=Cable.layername, field="CA_NB_FO_U"))
  296. if not int(cable.CA_NB_FO_D) <= int(cable.CA_NB_FO):
  297. self.log_error(DimensionError("Le nombre de fourreaux disponibles doit être inférieur au nombre total ('{}')".format(cable), layername=Cable.layername, field="CA_NB_FO_D"))
  298. except (TypeError, ValueError):
  299. pass
  300. # Verifier que chaque equipement de type PBO est contenu dans une zapbo, et que le nom de la zapbo contient le nom de l'equipement
  301. for equipement in equipements.values():
  302. if not equipement.EQ_TYPE == "PBO":
  303. continue
  304. #zapbos englobant l'equipement
  305. candidates = []
  306. for zapbo in zapbos.values():
  307. if zapbo.geom.contains(equipement.geom):
  308. candidates.append(zapbo)
  309. # le pbo doit être contenu dans une zapbo
  310. if not candidates:
  311. self.log_error(MissingItem("Le PBO n'est contenu dans aucune ZAPBO: {}".format(equipement), layername=Equipement.layername, field="geom"))
  312. continue
  313. # On se base sur le nom pour trouver la zapbo correspondante
  314. try:
  315. equipement.zapbo = next((z for z in candidates if equipement.EQ_NOM in z.ID_ZAPBO))
  316. except StopIteration:
  317. self.log_error(MissingItem("Le nom du PBO ne coincide avec le nom d'aucune des ZAPBO qui le contient: {}".format(equipement), layername=Equipement.layername, field="EQ_NOM"))
  318. break
  319. if not hasattr(equipement.zapbo, "nb_prises") or equipement.zapbo.nb_prises is None:
  320. equipement.zapbo.nb_prises = 0
  321. # Controle du dimensionnement des PBO
  322. if equipement.EQ_TYPE_PH == 'PBO 6' and not equipement.zapbo.nb_prises < 6:
  323. self.log_error(DimensionError("Le PBO 6 contient plus de 5 prises: {}".format(equipement), layername=Equipement.layername, field="*"))
  324. if equipement.EQ_TYPE_PH == 'PBO 12' and not equipement.zapbo.nb_prises >= 6 and equipement.zapbo.nb_prises <= 8:
  325. self.log_error(DimensionError("Le PBO 12 contient mois de 6 prises ou plus de 8 prises: {}".format(equipement), layername=Equipement.layername, field="*"))
  326. if equipement.zapbo.STATUT == "REC" and not equipement.EQ_STATUT == "REC":
  327. self.log_error(TechnicalValidationError("Le statut du PBO n'est pas cohérent avec le statut de sa ZAPBO: {}".format(equipement), layername=Equipement.layername, field="*"))
  328. if equipement.EQ_STATUT == "REC" and not equipement.zapbo.STATUT == "REC" and not equipement.zapbo.ID_ZAPBO[:4].lower() == "att_":
  329. self.log_error(TechnicalValidationError("Le statut du PBO n'est pas cohérent avec le statut de sa ZAPBO: {}".format(equipement), layername=Equipement.layername, field="*"))