mireya.2526
/
ProyectoIntermodular
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Product deleted

This commit is contained in:
Mireya Serrano 2026-05-26 16:16:17 +02:00
parent e32e84ac4a
commit f57eb9e924
1 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
sync-service/src/main/java/com/teterialosjuanjos/tfg/sync_service/sync/ProductSyncService.java
View File

@ -19,6 +19,8 @@ import java.time.Instant;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
/** /**
* Pushes Dolibarr products to PrestaShop, creating or updating by SKU. * Pushes Dolibarr products to PrestaShop, creating or updating by SKU.
@ -57,6 +59,11 @@ public class ProductSyncService {
List<DolibarrProductDto> products = dolibarrClient.getProducts(); List<DolibarrProductDto> products = dolibarrClient.getProducts();
log.info("ProductSync: {} products to process", products.size()); log.info("ProductSync: {} products to process", products.size());
Set<String> dolibarrSkus = products.stream()
.map(DolibarrProductDto::ref)
.filter(ref -> ref != null && !ref.isBlank())
.collect(Collectors.toSet());
for (DolibarrProductDto product : products) { for (DolibarrProductDto product : products) {
if (product.ref() == null || product.ref().isBlank()) { if (product.ref() == null || product.ref().isBlank()) {
log.warn("Skipping Dolibarr product id={} with no ref", product.id()); log.warn("Skipping Dolibarr product id={} with no ref", product.id());
@ -74,6 +81,23 @@ public class ProductSyncService {
markError(product.ref(), e.getMessage()); markError(product.ref(), e.getMessage());
} }
} }
for (ProductMapping mapping : productMappingRepository.findAll()) {
if (!dolibarrSkus.contains(mapping.getSku()) && mapping.getPrestashopId() != null) {
try {
prestashopClient.deleteProduct(mapping.getPrestashopId());
productMappingRepository.delete(mapping);
processed++;
log.info("ProductSync: deleted PS product SKU={} psId={} (no longer in Dolibarr)",
mapping.getSku(), mapping.getPrestashopId());
} catch (PrestashopApiException | RestClientException | HttpMessageConversionException e) {
failed++;
String msg = "Delete SKU %s: %s".formatted(mapping.getSku(), e.getMessage());
errors.add(msg);
log.warn("ProductSync delete failed: {}", msg);
}
}
}
} catch (RuntimeException e) { } catch (RuntimeException e) {
failed++; failed++;
String msg = "Failed to fetch products from Dolibarr: " + e.getMessage(); String msg = "Failed to fetch products from Dolibarr: " + e.getMessage();