Hi,
I called a function 'LikePost' from JS on some case, it will call a procedure which will insert a new entry in one table and update a field in another. After the above work is completed i want to send notification which I want to call asynchronously. When i am doing that it gives me the below error in audit log:
Microsoft.Data.SqlClient.SqlException (0x80131904): The transaction operation cannot be performed because there are pending requests working on this transaction. at Microsoft.Data.SqlClient.SqlConnection.OnError(SqlException exception, Boolean breakConnection, Action1 wrapCloseInAction) at Microsoft.Data.SqlClient.SqlInternalConnection.OnError(SqlException exception, Boolean breakConnection, Action1 wrapCloseInAction) at Microsoft.Data.SqlClient.TdsParser.ThrowExceptionAndWarning(TdsParserStateObject stateObj, Boolean callerHasConnectionLock, Boolean asyncClose) at Microsoft.Data.SqlClient.TdsParser.TryRun(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj, Boolean& dataReady) at Microsoft.Data.SqlClient.TdsParser.Run(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj) at Microsoft.Data.SqlClient.TdsParser.TdsExecuteTransactionManagerRequest(Byte[] buffer, TransactionManagerRequestType request, String transactionName, TransactionManagerIsolationLevel isoLevel, Int32 timeout, SqlInternalTransaction transaction, TdsParserStateObject stateObj, Boolean isDelegateControlRequest) at Microsoft.Data.SqlClient.SqlInternalConnectionTds.ExecuteTransactionYukon(TransactionRequest transactionRequest, String transactionName, IsolationLevel iso, SqlInternalTransaction internalTransaction, Boolean isDelegateControlRequest) at Microsoft.Data.SqlClient.SqlInternalTransaction.Commit() at Microsoft.Data.SqlClient.SqlTransaction.Commit() at Microsoft.EntityFrameworkCore.Storage.RelationalTransaction.Commit() at Abp.EntityFrameworkCore.Uow.DbContextEfCoreTransactionStrategy.Commit() at Abp.EntityFrameworkCore.Uow.EfCoreUnitOfWork.CommitTransaction() at Abp.EntityFrameworkCore.Uow.EfCoreUnitOfWork.CompleteUowAsync() at Abp.Domain.Uow.UnitOfWork...
Can you please help me out in resolving this.
I am pasting the code below: public async Task<int> LikePost(GetLikePostInput input) { var LikeCount = 0; Int64 FeedCreatorUserId = 0;
try
{
_storedProcedureCalling.EnsureConnectionOpen();
SqlParameter[] parameters = new SqlParameter[]
{
new SqlParameter(){ Direction=ParameterDirection.Input, SqlDbType =SqlDbType.UniqueIdentifier,ParameterName="@FeedId",Value= input.PostId}
,new SqlParameter(){ Direction=ParameterDirection.Input, SqlDbType =SqlDbType.BigInt,ParameterName="@UserId",Value= AbpSession.UserId}
,new SqlParameter(){ Direction=ParameterDirection.Input, SqlDbType =SqlDbType.Int,ParameterName="@TenantId",Value= AbpSession.TenantId}
,new SqlParameter(){ Direction=ParameterDirection.Input, SqlDbType =SqlDbType.Int,ParameterName="@PostReferenceType",Value= PostReferenceType.Like}
,new SqlParameter(){ Direction=ParameterDirection.Input, SqlDbType =SqlDbType.Bit,ParameterName="@IsLike",Value= input.IsLikeClick}
};
List<IDataRecord> outputUserOrderdsDataReader = new List<IDataRecord>();
var outputPOEmailDataReader = new List<IDataRecord>();
using (var command = _storedProcedureCalling.CreateCommand("LikePostOrComment", CommandType.StoredProcedure, parameters))
{
using (var dataReader = await command.ExecuteReaderAsync())
{
if (dataReader.HasRows)
{
DataTable dt = new DataTable();
dt.Load(dataReader);
if (dt != null && dt.Rows.Count > 0)
{
LikeCount = Convert.ToInt32(dt.Rows[0]["LikeCount"]);
FeedCreatorUserId = Convert.ToInt64(dt.Rows[0]["CreatorUserId"]);
}
}
}
}
if (input.IsLikeClick)
{
if ((long)AbpSession.UserId != FeedCreatorUserId)
{
await _customNotificationAppService.GenerateLikeNotification((Guid)input.PostId, (long)AbpSession.UserId, "postlike");
}
}
}
catch (Exception ex)
{
Logger.Info("LikePost error: " + ex.StackTrace);
return 0;
throw new UserFriendlyException(ex.Message + " " + ex.StackTrace);
}
return LikeCount;
}
public async Task GenerateLikeNotification(Guid FeedId, long UserId, string LikeType) { _storedProcedureCalling.EnsureConnectionOpen(); List<IDataRecord> outputDataReader = new List<IDataRecord>();
SqlParameter[] parameters = new SqlParameter[]
{
new SqlParameter(){ Direction=ParameterDirection.Input, SqlDbType =SqlDbType.UniqueIdentifier,ParameterName="@FeedId",Value= FeedId}
,new SqlParameter(){ Direction=ParameterDirection.Input, SqlDbType =SqlDbType.BigInt,ParameterName="@SenderUserId",Value= UserId}
,new SqlParameter(){ Direction=ParameterDirection.Input, SqlDbType =SqlDbType.NVarChar,ParameterName="@LikeType",Value= LikeType}
};
try
{
DataTable dt = new DataTable();
using (var command = _storedProcedureCalling.CreateCommand("GenerateLikeNotification", CommandType.StoredProcedure, parameters))
{
using (var dataReader = await command.ExecuteReaderAsync())
{
if (dataReader.HasRows)
{
dt.Load(dataReader);
}
}
}
/*real time notification in web*/
if (dt != null && dt.Rows.Count > 0)
{
var notificationData = new LocalizableMessageNotificationData(new LocalizableString(dt.Rows[0]["SendMsgType"].ToString(), CDPConsts.LocalizationSourceName));
notificationData["0"] = dt.Rows[0]["SenderName"].ToString();
var userNotifications = new List<UserNotification>();
userNotifications = dt.AsEnumerable().Select(dataRow => new UserNotification
{
Id = Guid.Parse(dataRow["UserNotificationsId"].ToString()),
TenantId = Convert.ToInt32(dataRow["TenantId"]),
UserId = Convert.ToInt64(dataRow["ReceiverID"]),
State = (UserNotificationState)Convert.ToInt32(dataRow["State"]),
Notification = new TenantNotification()
{
Id = Guid.Parse(dataRow["TenantNotificationId"].ToString()),
NotificationName = dataRow["NotificationName"].ToString(),
TenantId = Convert.ToInt32(dataRow["TenantId"]),
Severity = NotificationSeverity.Info,
Data = notificationData,
CreationTime = DateTime.UtcNow
}
}).ToList();
await _realTimeNotifier.SendNotificationsAsync(userNotifications.ToArray());
}
}
catch (Exception e)
{
Logger.Info("GenerateLikeNotification error: " + e.StackTrace);
}
}
