Tony CHEMIT pushed to branch develop at ultreiaio / ird-observe
Commits:
-
a8d68cf8
by Tony Chemit at 2023-03-30T17:01:00+02:00
-
b1cbde55
by Tony Chemit at 2023-03-30T17:40:44+02:00
6 changed files:
- core/persistence/java/src/main/java/fr/ird/observe/entities/data/ll/logbook/LogbookReplicateRequestCallback.java
- core/persistence/java/src/main/java/fr/ird/observe/entities/data/ll/observation/ObservationReplicateRequestCallback.java
- core/persistence/java/src/main/java/fr/ird/observe/entities/data/ps/observation/ObservationReplicateRequestCallback.java
- core/persistence/migration/src/main/java/fr/ird/observe/spi/migration/v9/DataSourceMigrationForVersion_9_1.java
- + core/persistence/migration/src/main/resources/db/migration/v9/9.1/12_fix_ps_localmarket_packaging-common.sql
- toolkit/api-datasource/src/main/java/fr/ird/observe/datasource/request/ReplicateRequest.java
Changes:
| ... | ... | @@ -48,7 +48,7 @@ public class LogbookReplicateRequestCallback implements ReplicateRequestCallback |
| 48 | 48 | public boolean accept(ReplicateRequest request) {
|
| 49 | 49 | return request.getOldParentId().contains(".Trip#")
|
| 50 | 50 | && request.getNewParentId().contains(".Trip#")
|
| 51 | - && request.getDataType().startsWith(fr.ird.observe.spi.module.ll.logbook.BusinessDataPackage.get().getPackageName());
|
|
| 51 | + && request.isDataTypeInDtoPackage(fr.ird.observe.spi.module.ll.logbook.BusinessDataPackage.get());
|
|
| 52 | 52 | }
|
| 53 | 53 | |
| 54 | 54 | @Override
|
| ... | ... | @@ -48,7 +48,7 @@ public class ObservationReplicateRequestCallback implements ReplicateRequestCall |
| 48 | 48 | public boolean accept(ReplicateRequest request) {
|
| 49 | 49 | return request.getOldParentId().contains(".Trip#")
|
| 50 | 50 | && request.getNewParentId().contains(".Trip#")
|
| 51 | - && request.getDataType().startsWith(fr.ird.observe.spi.module.ll.observation.BusinessDataPackage.get().getPackageName());
|
|
| 51 | + && request.isDataTypeInDtoPackage(fr.ird.observe.spi.module.ll.observation.BusinessDataPackage.get());
|
|
| 52 | 52 | }
|
| 53 | 53 | |
| 54 | 54 | @Override
|
| ... | ... | @@ -52,7 +52,7 @@ public class ObservationReplicateRequestCallback implements ReplicateRequestCall |
| 52 | 52 | public boolean accept(ReplicateRequest request) {
|
| 53 | 53 | return request.getOldParentId().contains(".Trip#")
|
| 54 | 54 | && request.getNewParentId().contains(".Trip#")
|
| 55 | - && request.getDataType().startsWith(fr.ird.observe.spi.module.ll.observation.BusinessDataPackage.get().getPackageName());
|
|
| 55 | + && request.isDataTypeInDtoPackage(fr.ird.observe.spi.module.ps.observation.BusinessDataPackage.get());
|
|
| 56 | 56 | }
|
| 57 | 57 | |
| 58 | 58 | @Override
|
| ... | ... | @@ -302,6 +302,8 @@ public class DataSourceMigrationForVersion_9_1 extends ByMajorMigrationVersionRe |
| 302 | 302 | executor.addScript("10", "adapt_table-common_vessel-rename-field");
|
| 303 | 303 | // See https://gitlab.com/ultreiaio/ird-observe/-/issues/2659
|
| 304 | 304 | executor.addScript("11", "adapt_table-common_fpazone-add-fields");
|
| 305 | + // See https://gitlab.com/ultreiaio/ird-observe/-/issues/2661
|
|
| 306 | + executor.addScript("12", "fix_ps_localmarket_packaging");
|
|
| 305 | 307 | |
| 306 | 308 | }
|
| 307 | 309 |
| 1 | +---
|
|
| 2 | +-- #%L
|
|
| 3 | +-- ObServe Core :: Persistence :: Migration
|
|
| 4 | +-- %%
|
|
| 5 | +-- Copyright (C) 2008 - 2023 IRD, Ultreia.io
|
|
| 6 | +-- %%
|
|
| 7 | +-- This program is free software: you can redistribute it and/or modify
|
|
| 8 | +-- it under the terms of the GNU General Public License as
|
|
| 9 | +-- published by the Free Software Foundation, either version 3 of the
|
|
| 10 | +-- License, or (at your option) any later version.
|
|
| 11 | +--
|
|
| 12 | +-- This program is distributed in the hope that it will be useful,
|
|
| 13 | +-- but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
| 14 | +-- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
| 15 | +-- GNU General Public License for more details.
|
|
| 16 | +--
|
|
| 17 | +-- You should have received a copy of the GNU General Public
|
|
| 18 | +-- License along with this program. If not, see
|
|
| 19 | +-- <http://www.gnu.org/licenses/gpl-3.0.html>.
|
|
| 20 | +-- #L%
|
|
| 21 | +---
|
|
| 22 | +UPDATE ps_localmarket.Packaging SET lastUpdateDate = ${CURRENT_TIMESTAMP}, topiaVersion = topiaVersion + 1, batchWeightType = 'fr.ird.referential.ps.localmarket.BatchWeightType#1464000000000#03' WHERE batchWeightType='fr.ird.referential.ps.localmarket.BatchWeightType#1464000000000#01' AND meanWeight IS NULL;
|
|
| 23 | +UPDATE common.LastUpdateDate SET lastUpdateDate = ${CURRENT_TIMESTAMP} WHERE type ='fr.ird.observe.entities.referential.common.ps.localmarket.Packaging'; |
| ... | ... | @@ -22,6 +22,8 @@ package fr.ird.observe.datasource.request; |
| 22 | 22 | * #L%
|
| 23 | 23 | */
|
| 24 | 24 | |
| 25 | +import fr.ird.observe.spi.module.BusinessDataPackage;
|
|
| 26 | + |
|
| 25 | 27 | import java.util.Set;
|
| 26 | 28 | import java.util.StringJoiner;
|
| 27 | 29 | |
| ... | ... | @@ -79,6 +81,10 @@ public class ReplicateRequest extends SqlServiceRequest { |
| 79 | 81 | return new DeleteRequest(isPostgres(), getDataType(), dataIds.toArray(new String[0]));
|
| 80 | 82 | }
|
| 81 | 83 | |
| 84 | + public boolean isDataTypeInDtoPackage(BusinessDataPackage dataPackage) {
|
|
| 85 | + return getDataType().replace("entities.", "dto.").startsWith(dataPackage.getPackageName());
|
|
| 86 | + }
|
|
| 87 | + |
|
| 82 | 88 | @Override
|
| 83 | 89 | public String toString() {
|
| 84 | 90 | return new StringJoiner(", ", ReplicateRequest.class.getSimpleName() + "[", "]")
|