时间戳

首页 > 解决方案 > 如何解决错误在前一个操作完成之前在此上下文上启动了第二个操作

c# - 如何解决错误在前一个操作完成之前在此上下文上启动了第二个操作

问题描述

我正在实施 asp.net 核心项目。在我的控制器类中，创建方法，首先我在表 APIApplicantHistory 中插入一条记录作为日志历史记录，然后我进行一些计算以获取一个值，然后我返回到 create 方法并创建一条新记录并插入它进入 APIApplicant 表。为此，我编写了如下代码：

 namespace CSDDashboard.Controllers
 {
   public class ApiapplicantsController : Controller
{
    private readonly CSSDDashboardContext _context;

    public ApiapplicantsController(CSSDDashboardContext context)
    {
        _context = context;
    }

   public async Task<IActionResult> Create([Bind("Id,ApiRequestDate,ApiRequestNo,Apiid,ApplicantId,GateId,LastRequestStatus,NocRequestDate,NocRequestNo,Url,Description,IsDeleted")] Apiapplicant apiapplicant)
    {
        ApiApplicantDto dto = new ApiApplicantDto();

        if (ModelState.IsValid)
        {
            //   Apiapplicant myapiapplicant = _context.Apiapplicant.LastOrDefault<Apiapplicant>();
            Apiapplicant myapiapplicant = _context.Apiapplicant.ToArray().Last();
            int temp = myapiapplicant.Id + 1;
            int calcApiApplicantHistoryId = APIApplicantHistoryLog(temp);


            var api = _context.Api.Single(p => p.Id == apiapplicant.Apiid);
            var gate = _context.Gate.Single(p => p.Id == apiapplicant.GateId);
            var applicant = _context.Applicant.Single(p => p.ApplicantId == apiapplicant.ApplicantId);
            //var apiapplicanthistory = _context.ApiApplicantHistory.Single(p => p.Id == apiapplicant.LastRequestStatus);


            dto.apiId = api.Id;
            dto.gateId = gate.Id;
            dto.applicantId = applicant.ApplicantId;

            using (var _context = new CSSDDashboardContext())
            {

                _context.Set<Apiapplicant>().Add(new Apiapplicant
                {

                    Apiid = dto.apiId,
                    GateId = dto.gateId,
                    ApplicantId = dto.applicantId,
                    LastRequestStatus = calcApiApplicantHistoryId,


                    ApiRequestDate = apiapplicant.ApiRequestDate,
                    ApiRequestNo = apiapplicant.ApiRequestNo,
                    NocRequestDate = apiapplicant.NocRequestDate,
                    NocRequestNo = apiapplicant.NocRequestNo,
                    Url = apiapplicant.Url,
                    Description = apiapplicant.Description,
                    IsDeleted = false
                });
                 await _context.SaveChangesAsync();
             };

            return RedirectToAction(nameof(Index));
        }
        ViewData["Apiid"] = new SelectList(_context.Api, "Id", "Name", apiapplicant.Apiid);
        ViewData["ApplicantId"] = new SelectList(_context.Applicant, "ApplicantId", "Name", apiapplicant.ApplicantId);
        ViewData["GateId"] = new SelectList(_context.Gate, "Id", "Name", apiapplicant.GateId);
        ViewData["sentResponseType"] = new SelectList(_context.EntityType.Where(g => g.EntityKey=="sentResponseType").ToList(), "ID", "name", apiapplicant.LastRequestStatusNavigation.SentResponseType);
        ViewData["unconfirmedReason"] = new SelectList(_context.EntityType.Where(g => g.EntityKey == "unconfirmedReason").ToList(), "Id", "name", apiapplicant.LastRequestStatusNavigation.UnconfirmedReason);
        ViewData["lastReqStatus"] = new SelectList(_context.EntityType.Where(g => g.EntityKey == "lastRequestStatus").ToList(), "Id", "name", apiapplicant.LastRequestStatusNavigation.LastReqStatus);
        return View(apiapplicant);
    }


   private  int APIApplicantHistoryLog(int myAPIApplicantId)
    {
        APIApplicantHistoryDto mydto = new APIApplicantHistoryDto();

      //  var apiapplicantt = _context.ApiApplicantHistory.Single(p => p.ApiApplicantId == myAPIApplicantId);
     //   mydto.APIApplicantHistoryId = apiapplicantt.Id;

        using (var _context = new CSSDDashboardContext())
        //     using (var transaction = _context.Database.BeginTransaction())
        {

            _context.Set<ApiApplicantHistory>().Add(new ApiApplicantHistory
            {

                //   ApiApplicantId = mydto.APIApplicantHistoryId,
                ApiApplicantId = myAPIApplicantId,
                Date = null,
                SentResponseType = 0,
                UnconfirmedReason = 0,
                LastReqStatus = 0,
                Description = "",
                IdDeleted = false   // This field should be totally omited from SQL server
            }) ;
             _context.SaveChangesAsync();


            var myArrayList = new List<int>();

            var result = from x in _context.ApiApplicantHistory where x.ApiApplicantId == myAPIApplicantId
                         select new { x.Id };

            foreach (var i in result)
                myArrayList.Add(i.Id);

            return myArrayList.Max(); ;

        }
    }
   }

我的问题是，在运行应用程序并在 APIApplicant 中创建新记录后，向我显示以下错误：

处理请求时发生未处理的异常。InvalidOperationException：在前一个操作完成之前在此上下文上启动了第二个操作。这通常是由使用相同 DbContext 实例的不同线程引起的。有关如何避免 DbContext 线程问题的更多信息，请参阅 https://go.microsoft.com/fwlink/?linkid=2097913。

如果有人告诉我我在哪里犯了错误，我将不胜感激？

标签： c#asp.net-core-mvcentity-framework-core

解决方案

如果您单击异常消息中的链接：https ://go.microsoft.com/fwlink/?linkid=2097913 ，这似乎很简单：

Entity Framework Core 不支持在同一DbContext实例上运行多个并行操作。这包括async查询的并行执行和来自多个线程的任何显式并发使用。因此，请始终立即等待异步调用，或者DbContext对并行执行的操作使用单独的实例。

如果你检查你的APIApplicantHistoryLog方法，你就不是awaiting你的_context.SaveChangesAsync();方法调用。

推荐阅读