Add article generation and pricelist categories

internal/services/sync/service.go

@@ -388,6 +388,9 @@ func (s *Service) SyncPricelists() (int, error) {
 		slog.Info("deleted stale local pricelists", "deleted", removed)
 	}
 
+	// Backfill lot_category for used pricelists (older local caches may miss the column values).
+	s.backfillUsedPricelistItemCategories(pricelistRepo, serverPricelistIDs)
+
 	// Update last sync time
 	s.localDB.SetLastSyncTime(time.Now())
 	s.RecordSyncHeartbeat()
@@ -396,6 +399,83 @@ func (s *Service) SyncPricelists() (int, error) {
 	return synced, nil
 }
 
+func (s *Service) backfillUsedPricelistItemCategories(pricelistRepo *repository.PricelistRepository, activeServerPricelistIDs []uint) {
+	if s.localDB == nil || pricelistRepo == nil {
+		return
+	}
+
+	activeSet := make(map[uint]struct{}, len(activeServerPricelistIDs))
+	for _, id := range activeServerPricelistIDs {
+		activeSet[id] = struct{}{}
+	}
+
+	type row struct {
+		ID uint `gorm:"column:id"`
+	}
+	var usedRows []row
+	if err := s.localDB.DB().Raw(`
+		SELECT DISTINCT pricelist_id AS id
+		FROM local_configurations
+		WHERE is_active = 1 AND pricelist_id IS NOT NULL
+		UNION
+		SELECT DISTINCT warehouse_pricelist_id AS id
+		FROM local_configurations
+		WHERE is_active = 1 AND warehouse_pricelist_id IS NOT NULL
+		UNION
+		SELECT DISTINCT competitor_pricelist_id AS id
+		FROM local_configurations
+		WHERE is_active = 1 AND competitor_pricelist_id IS NOT NULL
+	`).Scan(&usedRows).Error; err != nil {
+		slog.Warn("pricelist category backfill: failed to list used pricelists", "error", err)
+		return
+	}
+
+	for _, r := range usedRows {
+		serverID := r.ID
+		if serverID == 0 {
+			continue
+		}
+		if _, ok := activeSet[serverID]; !ok {
+			// Not present on server (or not active) - cannot backfill from remote.
+			continue
+		}
+
+		localPL, err := s.localDB.GetLocalPricelistByServerID(serverID)
+		if err != nil || localPL == nil {
+			continue
+		}
+
+		if s.localDB.CountLocalPricelistItems(localPL.ID) == 0 {
+			continue
+		}
+
+		missing, err := s.localDB.CountLocalPricelistItemsWithEmptyCategory(localPL.ID)
+		if err != nil {
+			slog.Warn("pricelist category backfill: failed to check local items", "server_id", serverID, "error", err)
+			continue
+		}
+		if missing == 0 {
+			continue
+		}
+
+		serverItems, _, err := pricelistRepo.GetItems(serverID, 0, 10000, "")
+		if err != nil {
+			slog.Warn("pricelist category backfill: failed to load server items", "server_id", serverID, "error", err)
+			continue
+		}
+		localItems := make([]localdb.LocalPricelistItem, len(serverItems))
+		for i := range serverItems {
+			localItems[i] = *localdb.PricelistItemToLocal(&serverItems[i], localPL.ID)
+		}
+
+		if err := s.localDB.ReplaceLocalPricelistItems(localPL.ID, localItems); err != nil {
+			slog.Warn("pricelist category backfill: failed to replace local items", "server_id", serverID, "error", err)
+			continue
+		}
+		slog.Info("pricelist category backfill: refreshed local items", "server_id", serverID, "items", len(localItems))
+	}
+}
+
 // RecordSyncHeartbeat updates shared sync heartbeat for current DB user.
 // Only users with write rights are expected to be able to update this table.
 func (s *Service) RecordSyncHeartbeat() {
@@ -595,15 +675,7 @@ func (s *Service) SyncPricelistItems(localPricelistID uint) (int, error) {
 	// Convert and save locally
 	localItems := make([]localdb.LocalPricelistItem, len(serverItems))
 	for i, item := range serverItems {
-		partnumbers := make(localdb.LocalStringList, 0, len(item.Partnumbers))
-		partnumbers = append(partnumbers, item.Partnumbers...)
-		localItems[i] = localdb.LocalPricelistItem{
-			PricelistID:  localPricelistID,
-			LotName:      item.LotName,
-			Price:        item.Price,
-			AvailableQty: item.AvailableQty,
-			Partnumbers:  partnumbers,
-		}
+		localItems[i] = *localdb.PricelistItemToLocal(&item, localPricelistID)
 	}
 
 	if err := s.localDB.SaveLocalPricelistItems(localItems); err != nil {