Tony CHEMIT pushed to branch develop at ultreiaio / ird-observe
Commits:
-
788f7b86
by Tony Chemit at 2023-01-25T11:49:52+01:00
-
f086b9ef
by Tony Chemit at 2023-01-25T11:49:52+01:00
-
c26a5fdf
by Tony Chemit at 2023-01-25T11:49:52+01:00
4 changed files:
- core/persistence/avdth/src/main/java/fr/ird/observe/persistence/avdth/data/logbook/FloatingObjectReader.java
- core/persistence/java/src/main/java/fr/ird/observe/entities/data/ps/common/TripConsolidateEngine.java
- src/site/markdown/avdth/logbook.md
- src/site/markdown/avdth/referential.md
Changes:
| ... | ... | @@ -76,19 +76,21 @@ public class FloatingObjectReader extends DataReader<FloatingObject> { |
| 76 | 76 | .put("0", "99")
|
| 77 | 77 | .put("1", "99")
|
| 78 | 78 | .put("2", "99")
|
| 79 | - .put("3", "99")
|
|
| 80 | - .put("4", "99")
|
|
| 81 | - .put("10", "99")
|
|
| 82 | - .put("14", "99")
|
|
| 79 | + |
|
| 80 | + .put("3", "2")
|
|
| 81 | + .put("4", "2")
|
|
| 82 | + .put("5", "1")
|
|
| 83 | + .put("6", "4")
|
|
| 84 | + |
|
| 83 | 85 | .put("7", "99")
|
| 84 | 86 | .put("8", "99")
|
| 85 | 87 | .put("9", "99")
|
| 88 | + .put("10", "99")
|
|
| 86 | 89 | .put("12", "99")
|
| 87 | 90 | .put("13", "99")
|
| 91 | + .put("14", "99")
|
|
| 88 | 92 | .put("15", "99")
|
| 89 | 93 | |
| 90 | - .put("5", "1")
|
|
| 91 | - .put("6", "4")
|
|
| 92 | 94 | .put("22", "4")
|
| 93 | 95 | .put("23", "1")
|
| 94 | 96 | .put("24", "4")
|
| ... | ... | @@ -110,8 +112,16 @@ public class FloatingObjectReader extends DataReader<FloatingObject> { |
| 110 | 112 | * If for a given {@code ACTIVITE.C_OPERA}, no value is found here, this means that there is no buoy to create.
|
| 111 | 113 | */
|
| 112 | 114 | public static final Map<String, String> TRANSMITTING_BUOY_OPERATION_CODE_MAPPING = ImmutableMap.<String, String>builder()
|
| 115 | + .put("3", "1") // Visite | Visite
|
|
| 116 | + .put("4", "1") // Visite | Visite
|
|
| 113 | 117 | .put("5", "3") // Mise à l'eau | null ou 3 Mise à l'eau
|
| 114 | 118 | .put("6", "2") // Retrait | null ou 2 Récupération
|
| 119 | + .put("7", "1") // Visite | Visite
|
|
| 120 | + .put("10", "1")// Visite | Visite
|
|
| 121 | + .put("12", "1")// Visite | Visite
|
|
| 122 | + .put("13", "1")// Visite | Visite
|
|
| 123 | + .put("14", "1")// Visite | Visite
|
|
| 124 | + .put("15", "1")// Visite | Visite
|
|
| 115 | 125 | .put("23", "3") // Mise à l'eau | 3 Mise à l'eau
|
| 116 | 126 | .put("24", "2") // Retrait | 2 Récupération
|
| 117 | 127 | .put("25", "3") // Visite | 3 Mise à l'eau
|
| ... | ... | @@ -137,15 +147,15 @@ public class FloatingObjectReader extends DataReader<FloatingObject> { |
| 137 | 147 | "2",
|
| 138 | 148 | "3",
|
| 139 | 149 | "4",
|
| 150 | + "6",
|
|
| 151 | + "7",
|
|
| 152 | + "8",
|
|
| 140 | 153 | "9",
|
| 141 | 154 | "10",
|
| 142 | 155 | "12",
|
| 156 | + "13",
|
|
| 143 | 157 | "14",
|
| 144 | 158 | "15",
|
| 145 | - "7",
|
|
| 146 | - "8",
|
|
| 147 | - "13",
|
|
| 148 | - "6",
|
|
| 149 | 159 | "22",
|
| 150 | 160 | "24",
|
| 151 | 161 | "25",
|
| ... | ... | @@ -38,7 +38,6 @@ import fr.ird.observe.dto.data.ps.observation.consolidate.ActivityConsolidateRes |
| 38 | 38 | import fr.ird.observe.dto.data.ps.observation.consolidate.FloatingObjectConsolidateRequest;
|
| 39 | 39 | import fr.ird.observe.dto.referential.I18nReferentialHelper;
|
| 40 | 40 | import fr.ird.observe.dto.referential.ReferentialLocale;
|
| 41 | -import fr.ird.observe.dto.referential.ps.common.VesselActivityReference;
|
|
| 42 | 41 | import fr.ird.observe.entities.ObserveTopiaDaoSupplier;
|
| 43 | 42 | import fr.ird.observe.entities.ToolkitTopiaPersistenceContextSupport;
|
| 44 | 43 | import fr.ird.observe.entities.data.ps.localmarket.Batch;
|
| ... | ... | @@ -178,9 +177,8 @@ public class TripConsolidateEngine { |
| 178 | 177 | |
| 179 | 178 | String activityPrefix = String.format("%s - Activity [%s/%s] ", routePrefix, ++activityIndex, activityMax);
|
| 180 | 179 | |
| 181 | - boolean floatingObjectEmpty = activity.isFloatingObjectEmpty();
|
|
| 182 | - if (!VesselActivityReference.isSetOperation(activity) && floatingObjectEmpty) {
|
|
| 183 | - log.debug(String.format("%s Skip activity (No set nor dcp found): %s", activityPrefix, activity.getTopiaId()));
|
|
| 180 | + if (activity.getSetSize() == 0 && activity.isFloatingObjectEmpty()) {
|
|
| 181 | + log.debug(String.format("%s Skip activity (No set nor floating object found): %s", activityPrefix, activity.getTopiaId()));
|
|
| 184 | 182 | continue;
|
| 185 | 183 | }
|
| 186 | 184 |
| ... | ... | @@ -69,11 +69,13 @@ On effecute la somme pour toutes les activités AVDTH du jour |
| 69 | 69 | |
| 70 | 70 | * Note 4
|
| 71 | 71 | ### <a name="n_0_4"></a>
|
| 72 | -Voir mapping [REF_VESSEL_ACTIVITY_TYPE](./referential.html#REF_VESSEL_ACTIVITY_TYPE) si code 13 (dans ObServe) alors on ajoute un dcp
|
|
| 72 | +Voir mapping [REF_VESSEL_ACTIVITY_TYPE](./referential.html#REF_VESSEL_ACTIVITY_TYPE)
|
|
| 73 | 73 | |
| 74 | 74 | * Note 5
|
| 75 | 75 | ### <a name="n_0_5"></a>
|
| 76 | -Voir mapping [REF_SCHOOL_TYPE](./referential.html#REF_SCHOOL_TYPE)
|
|
| 76 | +Voir mapping [REF_SCHOOL_TYPE](./referential.html#REF_SCHOOL_TYPE).
|
|
| 77 | + |
|
| 78 | +**À noter que cette donée est renseigné uniquement si ```ACTIVITE_C_OPERA in (0, 1, 2, 14)```**
|
|
| 77 | 79 | |
| 78 | 80 | * Note 6
|
| 79 | 81 | ### <a name="n_0_6"></a>
|
| ... | ... | @@ -103,6 +105,36 @@ Donnée non persistée dans ObServe, (voir https://gitlab.com/ultreiaio/ird-obse |
| 103 | 105 | ### <a name="n_0_12"></a>
|
| 104 | 106 | Mapping sur le code.
|
| 105 | 107 | |
| 108 | +### Cas des activités de pêche à partir de ```ACTIVITE.C_OPERA```
|
|
| 109 | + |
|
| 110 | +Pour les activités de pêche, on rajoute des données sur l'activité pour décrire la calée.
|
|
| 111 | + |
|
| 112 | +| ACTIVITE.C_OPERA | SetSuccessStatus [1](#n_5_1) | ReasonForNullSet [1](#n_5_1) | SetCount | SchoolType |
|
|
| 113 | +|-----------------:|-----------------------------:|------------------------------:|:---------|:-----------|
|
|
| 114 | +| 0 | 0 | 0 | (1) | (2) |
|
|
| 115 | +| 1 | 1 | non renseigné | (1) | (2) |
|
|
| 116 | +| 2 | 2 | non renseigné | (1) | (2) |
|
|
| 117 | +| 14 (3) | 2 | non renseigné | (1) | (2) |
|
|
| 118 | + |
|
| 119 | +* Note 1
|
|
| 120 | +#### <a name="n_5_1"></a>
|
|
| 121 | + |
|
| 122 | +On utilise le code du réferentiel ObServe
|
|
| 123 | + |
|
| 124 | +* Note 2
|
|
| 125 | +#### <a name="n_5_2"></a>
|
|
| 126 | + |
|
| 127 | +* Note 3
|
|
| 128 | +#### <a name="n_5_3"></a>
|
|
| 129 | + |
|
| 130 | +* Note 4
|
|
| 131 | +#### <a name="n_5_4"></a>
|
|
| 132 | + |
|
| 133 | +0.
|
|
| 134 | +1. calculé depuis ```ACTIVITE.V_NB_OP```
|
|
| 135 | +2. calculé depuis ```ACTIVITE.C_TBANC```
|
|
| 136 | +3. dans ce cas on rajoute aussi le système observé ***110**
|
|
| 137 | + |
|
| 106 | 138 | ### Ajout d'un DCP
|
| 107 | 139 | |
| 108 | 140 | On ajoute un DCP uniquement pour une activité avec **vesselActivity.code == 13**.
|
| ... | ... | @@ -223,8 +223,8 @@ Mapping type d'activité |
| 223 | 223 | | 1 | 6 (1) |
|
| 224 | 224 | | 2 | 6 (1) |
|
| 225 | 225 | | 14 | 6 (1) (3) |
|
| 226 | -| 3 | 2 |
|
|
| 227 | -| 4 | 1 |
|
|
| 226 | +| 3 | 2 (ou 102) (4) |
|
|
| 227 | +| 4 | 1 (ou 101) (4) |
|
|
| 228 | 228 | | 5 | 13 (2) |
|
| 229 | 229 | | 6 | 13 (2) |
|
| 230 | 230 | | 22 | 13 (2) |
|
| ... | ... | @@ -251,11 +251,13 @@ Mapping type d'activité |
| 251 | 251 | | 19 | 29 |
|
| 252 | 252 | | 20 | 30 |
|
| 253 | 253 | | 35 | 31 |
|
| 254 | -| 36 | 36 |
|
|
| 254 | +| 36 | 36 (5) |
|
|
| 255 | 255 | |
| 256 | 256 | 1. **Seule une activité de code 6 permet la création de captures**.
|
| 257 | 257 | 2. **Seule une activité de code 13 permet la création de DCP**.
|
| 258 | 258 | 3. On ajoute en plus un système observé **110** et **setSuccessStatus** à **2**.
|
| 259 | +4. Si un dcp est trouvé alors on utilise un type d'activité introduit en version *9.1.0* qui permet l'ajout de dcp.
|
|
| 260 | +5. Le type d'activité a été ajouté lors de la migration de la version *9.1.0* (avant on utilisait *99*)
|
|
| 259 | 261 | |
| 260 | 262 | ### REF_SCHOOL_TYPE
|
| 261 | 263 |