its not there anymore (commented out)
with that: " public async Task<MeetingDto> UpdateAsync(Guid meetingId, Guid userId, MeetingDto input, UserModeDto userMode) { #region Allgemein: Validierung // Lade das Meeting mit zugehörigen Details (Participants) aus dem Repository var queryableMeeting = await _meetingRepository.WithDetailsAsync(m => m.Participants); var meetingQuery = queryableMeeting.Where(x => x.Id == meetingId); var meeting = await AsyncExecuter.FirstOrDefaultAsync(meetingQuery);
// Überprüfe, ob das Meeting existiert
if (meeting == null)
{
throw new BusinessException($"Meeting mit Id {meetingId} nicht gefunden.");
}
// Prüfe, ob der anfragende Benutzer Teilnehmer des Meetings ist
var participant = meeting.Participants.FirstOrDefault(p => p.UserId == userId);
if (participant == null)
{
throw new BusinessException("Sie haben keinen Zugriff auf dieses Meeting.");
}
#endregion
// Optimistic Concurrency: Setze den ConcurrencyStamp des geladenen Meeting-Entities
// auf den vom Frontend gelieferten Wert. So erkennt das EF/ABP-Framework,
// falls das Meeting zwischenzeitlich von jemand anderem geändert wurde.
//meeting.ConcurrencyStamp = input.ConcurrencyStamp;
// Alle folgenden DB-Änderungen laufen in einer Transaktion (ABP UnitOfWork),
// um Konsistenz sicherzustellen – entweder werden alle Änderungen gespeichert oder keine.
try
{
#region Globale Überschreibung der AllMoodTypes (nur Admin)
if (userMode == UserModeDto.Admin)
{
// 1. Lösche alle MoodTypes, die vom Administrator zum Entfernen markiert wurden
foreach (var moodTypeDto in input.AllMoodTypes.Where(m => m.Delete))
{
// Löschen des MoodType (falls bereits von anderem Admin gelöscht, wirft dies eine Exception)
await _moodTypeRepository.DeleteAsync(moodTypeDto.Id);
}
// 2. Lade die verbleibenden existierenden MoodTypes aus der DB (nach evtl. Löschungen)
var existingMoodTypes = await _moodTypeRepository.GetListAsync();
// 3. Füge neue MoodTypes hinzu oder aktualisiere bestehende anhand der Admin-Eingaben
foreach (var moodTypeDto in input.AllMoodTypes)
{
if (moodTypeDto.Delete)
{
// Überspringe MoodTypes, die bereits gelöscht wurden
continue;
}
var moodTypeEntity = existingMoodTypes.FirstOrDefault(mt => mt.Id == moodTypeDto.Id);
if (moodTypeEntity == null)
{
// MoodType existiert noch nicht -> neu anlegen
var newMoodType = new MoodType
{
Name = moodTypeDto.Name,
Description = moodTypeDto.Description,
Color = moodTypeDto.Color,
CreatedAt = DateTime.UtcNow
// Id (Key) wird bei Bedarf vom ORM/DB vergeben (z.B. Identity oder Guid über GuidGenerator)
};
await _moodTypeRepository.InsertAsync(newMoodType);
}
else
{
// MoodType existiert bereits -> aktualisieren
// Setze auch hier den ConcurrencyStamp, um parallele Änderungen an MoodTypes zu erkennen
//moodTypeEntity.ConcurrencyStamp = moodTypeDto.ConcurrencyStamp;
moodTypeEntity.Name = moodTypeDto.Name;
moodTypeEntity.Description = moodTypeDto.Description;
moodTypeEntity.Color = moodTypeDto.Color;
moodTypeEntity.UpdatedAt = DateTime.UtcNow;
await _moodTypeRepository.UpdateAsync(moodTypeEntity);
}
}
}
#endregion
#region Vorhandene Moods überschreiben bzw. hinzufügen (MoodVotes)
if (input.AllMoodTypes != null && input.AllMoodTypes.Count > 0)
{
// Entferne alle bisherigen MoodVotes des Teilnehmers, um sie durch die neuen zu ersetzen
await _moodVoteRepository.DeleteAsync(mv => mv.ParticipantId == participant.Id);
// Lege für jeden im Frontend ausgewählten MoodType einen neuen MoodVote an
foreach (var moodTypeDto in input.AllMoodTypes)
{
if (moodTypeDto.Selected)
{
var newMoodVote = new MoodVote
{
ParticipantId = participant.Id,
MoodTypeId = moodTypeDto.Id,
VoteTime = DateTime.UtcNow
};
await _moodVoteRepository.InsertAsync(newMoodVote);
}
}
}
#endregion
#region Hinzufügen neuer Nachrichten (UserMessages) für den Teilnehmer
// Speichere alle neuen Nachrichten, die vom Teilnehmer im Frontend hinzugefügt wurden
foreach (var messageDto in (input.UserMessages ?? new List<MessageDto>()))
{
var newMessage = new Message
{
ParticipantId = participant.Id,
CurrentMessage = messageDto.CurrentMessage,
CreatedAt = DateTime.UtcNow
};
await _messageRepository.InsertAsync(newMessage);
}
#endregion
#region Sonstige Eigenschaften aktualisieren
// Aktualisiere die Meeting-Eigenschaften
meeting.ScheduledTime = input.ScheduledTime;
meeting.UpdatedAt = DateTime.UtcNow;
#endregion
// Speichere die Änderungen am Meeting (ConcurrencyStamp wird vom Framework geprüft)
var updatedMeeting = await _meetingRepository.UpdateAsync(meeting);
#region DTO vorbereiten (Ergebnis für das Frontend)
// Mappe das aktualisierte Meeting-Entity zurück auf das MeetingDto
var meetingDto = ObjectMapper.Map<Meeting, MeetingDto>(updatedMeeting);
#region AllMoodTypes für das Ausgabe-DTO
// Hole die aktuelle Liste aller MoodTypes aus der Datenbank
var moodTypes = await _moodTypeRepository.GetListAsync();
// Markiere im MoodType-Listening diejenigen als 'Selected', die der Teilnehmer jetzt ausgewählt hat
if (participant.MoodVotes != null && participant.MoodVotes.Any())
{
// Falls die MoodVotes des Teilnehmers bereits im Kontext verfügbar sind, nutze sie
foreach (var vote in participant.MoodVotes)
{
var moodType = moodTypes.FirstOrDefault(m => m.Id == vote.MoodTypeId);
if (moodType != null)
{
moodType.Selected = true;
}
}
}
else
{
// Falls die MoodVotes nicht im Kontext geladen sind, verwende die aktuelle Auswahl aus dem Input
foreach (var moodTypeDto in input.AllMoodTypes)
{
var moodType = moodTypes.FirstOrDefault(m => m.Id == moodTypeDto.Id);
if (moodType != null)
{
moodType.Selected = moodTypeDto.Selected;
}
}
}
// Wandle die MoodType-Entitäten in DTOs um (immer eine Liste bereitstellen, auch wenn leer)
meetingDto.AllMoodTypes = moodTypes.Any()
? ObjectMapper.Map<List<MoodType>, List<MoodTypeDto>>(moodTypes)
: new List<MoodTypeDto>();
#endregion
#region UserMessages für das Ausgabe-DTO
// Hole alle Nachrichten für den Teilnehmer und mappe sie auf DTOs
var messages = await _messageRepository.GetListAsync(m => m.ParticipantId == participant.Id);
meetingDto.UserMessages = messages.Any()
? ObjectMapper.Map<List<Message>, List<MessageDto>>(messages)
: new List<MessageDto>();
#endregion
#endregion
// Gebe das aktualisierte Meeting als DTO zurück
return meetingDto;
}
catch (AbpDbConcurrencyException)
{
// Falls zwischen Laden und Speichern eine parallele Änderung entdeckt wurde (optimistische Sperre),
// wird eine verständliche Ausnahme geworfen, die z.B. im Frontend angezeigt werden kann.
throw new BusinessException("Das Meeting wurde in der Zwischenzeit von einem anderen Benutzer geändert. Bitte laden Sie die Seite neu und versuchen Sie es erneut.");
}
}"
Is there a pssebility to deactivate the Concurrency Check entirely?:
That I dont get: "The data you have submitted has already been changed by another user. Discard your changes and try again."
I chagned the classes, but I still get it (after time): " [Serializable] public class MeetingDto : EntityDto<Guid>//, IHasConcurrencyStamp { public string Title { get; set; } public DateTime UpdatedAt { get; set; }
public DateTime ScheduledTime { get; set; }
public List<ParticipantDto> Participants { get; set; }
public List<MoodTypeDto> AllMoodTypes { get; set; }
//public List<MoodVoteDto> UserMoodVotes { get; set; }
public List<MessageDto> UserMessages { get; set; }
//public string ConcurrencyStamp { get; set; } // muss vom Client mitgesendet werden
}
[Serializable] public class ParticipantDto : EntityDto<Guid> { public Guid UserId { get; set; } public Guid MeetingId { get; set; }
public UserModeDto eUserMode { get; set; }
public List<MoodVoteDto> MoodVotes { get; set; }
public List<MessageDto> Messages { get; set; }
public DateTime LastHeartbeat { get; set; }
public string UserAgent { get; set; }
public bool IsInactive { get; set; }
}
[Serializable] public class MessageDto : CreationAuditedEntityDto<Guid> { public Guid ParticipantId { get; set; } public string CurrentMessage { get; set; } public DateTime CreatedAt { get; set; } }
[Serializable] public class MoodVoteDto : EntityDto<Guid> { public bool Selected { get; set; } // Wird im FrontEnd gebraucht public Guid ParticipantId { get; set; }
public Guid MoodTypeId { get; set; }
public DateTime VoteTime { get; set; }
}
[Serializable]
public class MoodTypeDto : EntityDto<Guid>
{
public bool Selected { get; set; }
public string Name { get; set; }
public string Description { get; set; }
public string Color { get; set; }
public DateTime CreatedAt { get; set; }
public DateTime UpdatedAt { get; set; }
public bool Delete { get; set; } = false;
}
[Serializable] public class MeetingStatusDto : EntityDto<Guid> { public Guid MeetingId { get; set; } public int TotalParticipants { get; set; } public List<MoodSummaryDto> MoodSummary { get; set; } public List<MessageDto> Messages { get; set; } }
[Serializable] public class MoodSummaryDto : EntityDto<Guid> { public Guid MoodTypeId { get; set; } public int VoteCount { get; set; } }
[Serializable] public class UserAccessDto : EntityDto<Guid> { public Guid ParticipantId { get; set; } public string UserAgent { get; set; } public UserModeDto eUserMode { get; set; } public string LastSeen { get; set; } public string IsActive { get; set; }
}" and " public class Meeting :BasicAggregateRoot<Guid>//, IHasConcurrencyStamp { //public override string ConcurrencyStamp { get; set; } = null; public string Title { get; set; } public DateTime ScheduledTime { get; set; } public DateTime UpdatedAt { get; set; }
public List<Participant> Participants { get; set; }
public Meeting(Guid id, string title, DateTime scheduledTime)
: base(id)
{
Title = title;
ScheduledTime = scheduledTime;
Participants = new List<Participant>();
}
}
public class Participant : Entity<Guid> { public Guid UserId { get; set; } public Guid MeetingId { get; set; } public UserMode eUserMode { get; set; } public Meeting Meeting { get; set; } public List<MoodVote> MoodVotes { get; set; } public List<Message> Messages { get; set; } public DateTime LastHeartbeat { get; set; } public string UserAgent { get; set; } public bool IsInactive { get; set; } }
public class Message : Entity<Guid> {
public Guid ParticipantId { get; set; }
public Participant Participant { get; set; }
public string CurrentMessage { get; set; }
public DateTime CreatedAt { get; set; }
}
public class MoodVote : Entity<Guid> { public Guid ParticipantId { get; set; } public Participant Participant { get; set; } public Guid MoodTypeId { get; set; } public MoodType MoodType { get; set; } public DateTime VoteTime { get; set; } }
public class MoodType : Entity<Guid> { [NotMapped] public bool Selected { get; set; } // Wird im FrontEnd gebraucht
public string Name { get; set; }
public string Description { get; set; }
public string Color { get; set; }
public DateTime CreatedAt { get; set; }
public DateTime UpdatedAt { get; set; }
}
public enum UserMode { User = 0, Admin = 1, Verwalter = 2 }"
Hi,
please take a look at the code, I get (after some time) "Die von Ihnen übermittelten Daten wurden bereits von einem anderen Benutzer/Kunden geändert. Bitte verwerfen Sie die vorgenommenen Änderungen und versuchen Sie es von vorne" when the frontend sends request for the "UpdateAsync". Please give me the corrected code fragments!
Alright, but simply posting a link doesn’t really justify deducting a credit from my ticket budget—especially since we ended up finding a different solution.
Hi,
how to use ABP single layer https://easyupload.io/ven8mh without a database at all, that the frontend will just serve a plain angular website?
SQL Server Version 11.00.6567 Windows Server 2019 abp package version: 9.x
We are encountering the error: "Incorrect syntax near the 'WITH' keyword." However, upgrading SQL Server is not an acceptable solution.
Instead, we are looking for potential code adjustments or bug fixes within our existing version or any upgrade of your ABP software.
Environment Details:
"
Falsche Syntax in der Nähe des WITH-Schlüsselworts. Falls diese Anweisung ein allgemeiner Tabellenausdruck, eine XMLNAMESPACES-Klausel oder eine CHANGE TRACKING CONTEXT-Klausel ist, muss die vorherige Anweisung mit einem Semikolon abgeschlossen werden.
Microsoft.Data.SqlClient.SqlException (0x80131904): Falsche Syntax in der Nähe des WITH-Schlüsselworts.
Falsche Syntax in der Nähe des WITH-Schlüsselworts. Falls diese Anweisung ein allgemeiner Tabellenausdruck, eine XMLNAMESPACES-Klausel oder eine CHANGE TRACKING CONTEXT-Klausel ist, muss die vorherige Anweisung mit einem Semikolon abgeschlossen werden.
at System.Threading.Tasks.ContinuationResultTaskFromResultTask2.InnerInvoke() at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state) --- End of stack trace from previous location --- at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state) at System.Threading.Tasks.Task.ExecuteWithThreadLocal(Task& currentTaskSlot, Thread threadPoolThread) --- End of stack trace from previous location --- at Microsoft.EntityFrameworkCore.Storage.RelationalCommand.ExecuteReaderAsync(RelationalCommandParameterObject parameterObject, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Storage.RelationalCommand.ExecuteReaderAsync(RelationalCommandParameterObject parameterObject, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Query.Internal.SplitQueryingEnumerable1.AsyncEnumerator.InitializeReaderAsync(AsyncEnumerator enumerator, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.SqlServer.Storage.Internal.SqlServerExecutionStrategy.ExecuteAsync[TState,TResult](TState state, Func4 operation, Func4 verifySucceeded, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Query.Internal.SplitQueryingEnumerable1.AsyncEnumerator.MoveNextAsync() at Microsoft.EntityFrameworkCore.EntityFrameworkQueryableExtensions.ToListAsync[TSource](IQueryable1 source, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.EntityFrameworkQueryableExtensions.ToListAsync[TSource](IQueryable1 source, CancellationToken cancellationToken) at Volo.Abp.Domain.Repositories.EntityFrameworkCore.EfCoreRepository2.GetListAsync(Expression1 predicate, Boolean includeDetails, CancellationToken cancellationToken) at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo) at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapterWithReturnValue1.ProceedAsync()
at Volo.Abp.Uow.UnitOfWorkInterceptor.InterceptAsync(IAbpMethodInvocation invocation)
at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter1.InterceptAsync[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo, Func3 proceed)
at PapeCo.Services.VibeScan.MeetingAppService.GetMeetingStatusAsync(Guid meetingId) in xxx.Application_MyStructure\Services.cs:line 179
at lambda_method2273(Closure, Object)
at Microsoft.AspNetCore.Mvc.Infrastructure.ActionMethodExecutor.AwaitableObjectResultExecutor.Execute(ActionContext actionContext, IActionResultTypeMapper mapper, ObjectMethodExecutor executor, Object controller, Object[] arguments)
at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeActionMethodAsync>g__Awaited|12_0(ControllerActionInvoker invoker, ValueTask`1 actionResultValueTask)
at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.
Full: Error https://easyupload.io/aks3ki