Дерево импорта / экспорта Entity Framework Core сущностей с похожими внешними ключами

Предположим, у вас есть список импортируемых Category, вы можете сначала получить список идентификаторов этих категорий, а затем запросить базу данных, чтобы убедиться, что они уже сохранены в базе данных. А те, которые уже есть, просто пропустите (или обновите по своему усмотрению).

Поскольку у нас есть несколько типов сущностей (категории, продукты, счета и потенциальные BillProducts), вместо того, чтобы писать новый импортер для каждого TEntity, я предпочитаю писать общий метод Importer для работы с любым списком типов сущностей с Generic и Reflection:

public async Task ImportBatch<TEntity,TKey>(IList<TEntity> entites)
    where TEntity : class 
    where TKey: IEquatable<TKey>
{
    var ids = entites.Select( e=> GetId<TEntity,TKey>(e));
    var existingsInDatabase=this._context.Set<TEntity>()
        .Where(e=> ids.Any(i => i.Equals(GetId<TEntity,TKey>(e)) ))
        .ToList();

    using (var transaction = this._context.Database.BeginTransaction())
    {
        try{
            this._context.Database.ExecuteSqlCommand("SET IDENTITY_INSERT " + typeof(TEntity).Name + " ON;");
            this._context.SaveChanges();

            foreach (var entity in entites)
            {
                var e= existingsInDatabase.Find(existing => {
                    var k1 =GetId<TEntity,TKey>(existing); 
                    var k2=GetId<TEntity,TKey>(entity);
                    return k1.Equals(k2);  
                });
                // if not yet exists
                if (e == null){
                    this._context.Add(entity);
                }else{
                    // if you would like to update the old one when there're some differences
                    //    uncomment the following line :
                    // this._context.Entry(e).CurrentValues.SetValues(entity);
                }
            }
            await this._context.SaveChangesAsync();
            transaction.Commit();
        }
        catch{
            transaction.Rollback();
        }
        finally{
            this._context.Database.ExecuteSqlCommand($"SET IDENTITY_INSERT " + typeof(TEntity).Name + " OFF;");
            await this._context.SaveChangesAsync();
        }
    }
    return;
}

Здесь GetId<TEntity,TKey>(TEntity e) - это простой вспомогательный метод, который используется для получения файла key от e:

    // use reflection to get the Id of any TEntity type
    private static TKey GetId<TEntity,TKey>(TEntity e)
        where TEntity : class
        where TKey : IEquatable<TKey>
    {
        PropertyInfo pi=typeof(TEntity).GetProperty("Id");
        if (pi == null) { throw new Exception($"the type {typeof(TEntity)} must has a property of `Id`"); }
        TKey k = (TKey) pi.GetValue(e);
        return k ;
    }

Чтобы сделать код более пригодным для повторного использования, мы можем создать сервис EntityImporter, содержащий описанный выше метод:

public class EntityImporter{
    private DbContext _context;

    public EntityImporter(DbContext dbContext){
        this._context = dbContext;
    }

    public async Task ImportBatch<TEntity,TKey>(IList<TEntity> entites)
        where TEntity : class 
        where TKey: IEquatable<TKey>
    {
        // ...
    }

    public static TKey GetId<TEntity,TKey>(TEntity e)
        where TEntity : class
        where TKey : IEquatable<TKey>
    {
        // ... 
    }
}

а затем зарегистрируйте службы во время запуска:

services.AddScoped<DbContext, AppDbContext>();
services.AddScoped<EntityImporter>();

Прецедент :

Во-первых, я возьму для примера несколько категорий:

var categories = new ProductCategory[]{
    new ProductCategory{
        Id = 1,
        Name = "Category #1"
    },
    new ProductCategory{
        Id = 2,
        Name = "Category #2"
    },
    new ProductCategory{
        Id = 3,
        Name = "Category #3"
    },
    new ProductCategory{
        Id = 2,
        Name = "Category #2"
    },
    new ProductCategory{
        Id = 1,
        Name = "Category #1"
    },
};

await this._importer.ImportBatch<ProductCategory,int>(categories);

Ожидаемые результаты должны быть импортированы только 3 строками:

1 category #1
2 category #2 
3 category #3

А вот на скриншоте все работает:

Наконец, для ваших счетов json вы можете сделать, как показано ниже, чтобы импортировать элементы:

var categories = bill.Products.Select(p=>p.ProductCategory).ToList();
var products = bill.Products.ToList();
// other List<TEntity>...

// import the categories firstly , since they might be referenced by other entity
await this._importer.ImportBatch<ProductCategory,int>(categories);
// import the product secondly , since they might be referenced by BillProduct table
await this._import.ImportBatch<Product,int>(products);
// ... import others