登录
注册
开源
企业版
高校版
搜索
帮助中心
使用条款
关于我们
开源
企业版
高校版
私有云
模力方舟
AI 队友
登录
注册
轻量养虾,开箱即用!低 Token + 稳定算力,Gitee & 模力方舟联合出品的 PocketClaw 正式开售!点击了解详情~
代码拉取完成,页面将自动刷新
开源项目
>
WEB应用开发
>
Web开发框架
&&
捐赠
捐赠前请先登录
取消
前往登录
扫描微信二维码支付
取消
支付完成
支付提示
将跳转至支付宝完成支付
确定
取消
Watch
不关注
关注所有动态
仅关注版本发行动态
关注但不提醒动态
9.9K
Star
14.5K
Fork
4.2K
GVP
dotNET China
/
Furion
代码
Issues
0
Pull Requests
0
统计
流水线
服务
质量分析
Jenkins for Gitee
腾讯云托管
腾讯云 Serverless
悬镜安全
阿里云 SAE
Codeblitz
SBOM
开发画像分析
我知道了,不再自动展开
更新失败,请稍后重试!
移除标识
内容风险标识
本任务被
标识为内容中包含有代码安全 Bug 、隐私泄露等敏感信息,仓库外成员不可访问
SpareTime.DoIt()中使用异步委托的问题
已完成
#I3XVZ0
taoran
创建于
2021-06-25 18:31
> 特别说明:如果 Issue 报告为问题且开发成员回复确认问题之后但**三天内**都不能得到反馈,则视为无效Issue。 ### Furion 版本号 2.10.1 ----------- ### Web 项目类型 - [x] WebApi ----------- ### 描述你的问题 **ef写入重复的数据后** 三种情况: 1. SpareTime.DoIt(async () =>{ await Scoped.Create(async (fac, scope) => { await ef写入重复的数据 }); }); 时,正常返回200,异常可以被全局异常处理截获并写日志,程序会终止。 2. 直接:ef写入重复的数据 时,返回500,不能在对象“dbo.Orders”中插入重复键,异常可以被全局异常处理截获并写日志 3. SpareTime.DoIt(() =>{ Scoped.Create(async (fac, scope) => { await ef写入重复的数据 }); }); 时,正常返回200,异常可以被全局异常处理截获并写日志,程序正常运行。 ----------- ### 异常堆栈信息 **第一种情况,程序退出前的异常信息** Error: An assembly specified in the application dependencies manifest (YLVIP.Web.Entry.deps.json) has already been found but with a different file extension: package: 'YLVIP.Web.Entry', version: '1.0.0' path: 'YLVIP.Web.Entry.dll' previously found assembly: '\YLVIP.Web.Entry\bin\Debug\net5.0\YLVIP.Web.Entry.exe' PS \YLVIP.Web.Entry\bin\Debug\net5.0> dotnet YLVIP.Web.Entry.dll Unhandled exception. Microsoft.EntityFrameworkCore.DbUpdateException: An error occurred while updating the entries. See the inner exception for details. ---> Microsoft.Data.SqlClient.SqlException (0x80131904): 违反了 PRIMARY KEY 约束“PK_Orders”。不能在对象“dbo.Orders”中插入重复键。重复键值为 (1122334455)。 语句已终止。 at Microsoft.Data.SqlClient.SqlCommand.<>c.<ExecuteDbDataReaderAsync>b__169_0(Task`1 result) at System.Threading.Tasks.ContinuationResultTaskFromResultTask`2.InnerInvoke() at System.Threading.Tasks.Task.<>c.<.cctor>b__277_0(Object obj) at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state) --- End of stack trace from previous location --- 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.Update.ReaderModificationCommandBatch.ExecuteAsync(IRelationalConnection connection, CancellationToken cancellationToken) ClientConnectionId:efd565e0-7b8c-492d-af1c-25029f3071c3 Error Number:2627,State:1,Class:14 --- End of inner exception stack trace --- at Microsoft.EntityFrameworkCore.Update.ReaderModificationCommandBatch.ExecuteAsync(IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(IList`1 entriesToSave, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(DbContext _, Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.SqlServer.Storage.Internal.SqlServerExecutionStrategy.ExecuteAsync[TState,TResult](TState state, Func`4 operation, Func`4 verifySucceeded, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Furion.DatabaseAccessor.PrivateRepository`1.InsertNowAsync(IEnumerable`1 entities, CancellationToken cancellationToken) at YLVIP.Application.OrderService.<>c__DisplayClass3_0.<<CreateOrders>b__1>d.MoveNext() in \YLVIP.Application\Orders\OrderService.cs:line 89 --- End of stack trace from previous location --- at Furion.DependencyInjection.Scoped.Create(Func`3 handler, IServiceScopeFactory scopeFactory) at YLVIP.Application.OrderService.<>c__DisplayClass3_0.<<CreateOrders>b__0>d.MoveNext() in \YLVIP.Application\Orders\OrderService.cs:line 67 --- End of stack trace from previous location --- at System.Threading.Tasks.Task.<>c.<ThrowAsync>b__140_1(Object state) at System.Threading.QueueUserWorkItemCallback.<>c.<.cctor>b__6_0(QueueUserWorkItemCallback quwi) at System.Threading.ExecutionContext.RunForThreadPoolUnsafe[TState](ExecutionContext executionContext, Action`1 callback, TState& state) at System.Threading.QueueUserWorkItemCallback.Execute() at System.Threading.ThreadPoolWorkQueue.Dispatch() 进程已结束,退出代码为 -532,462,766。 ----------- ### 代码或代码仓库 ``` public async Task<List<AddOrderOutput>> CreateOrders(VipOrderListInput orders) { var ydOrders = orders.Adapt<PostOrderToYunDa>(); var data = new YunDaData { method = "oms_create_order_elec_th", data = SecretUtil.EncodeBase64("UTF-8", JSON.Serialize(ydOrders)) }; // 快递接口 var responseMessage = await _yunDaApi.PostCreateOrderElecThAsync(data); if (!responseMessage.success) throw Oops.Oh(responseMessage.error_msg).StatusCode(400); // 后台记录快递数据 SpareTime.DoIt(async () => { await Scoped.Create(async (fac, scope) => { var services = scope.ServiceProvider; var orderRespository = Db.GetRepository<Orders>(services); // 插入重复数据 await orderRespository.InsertNowAsync(responseMessage.result_info); }); }); // 返回快递结果 return responseMessage.result_info.Adapt<List<AddOrderOutput>>(); } ``` ----------- ### 数据库信息 - [x] SqlServer ----------- ### 期待结果 SpareTime.DoIt中发送异常时,程序不要结束运行 第三种情况可以达到期望的效果, 请问: 第一种情况是框架bug么?亦或是我的 SpareTime.DoIt(async () =>{});用的不对,应该怎么用? -----------
> 特别说明:如果 Issue 报告为问题且开发成员回复确认问题之后但**三天内**都不能得到反馈,则视为无效Issue。 ### Furion 版本号 2.10.1 ----------- ### Web 项目类型 - [x] WebApi ----------- ### 描述你的问题 **ef写入重复的数据后** 三种情况: 1. SpareTime.DoIt(async () =>{ await Scoped.Create(async (fac, scope) => { await ef写入重复的数据 }); }); 时,正常返回200,异常可以被全局异常处理截获并写日志,程序会终止。 2. 直接:ef写入重复的数据 时,返回500,不能在对象“dbo.Orders”中插入重复键,异常可以被全局异常处理截获并写日志 3. SpareTime.DoIt(() =>{ Scoped.Create(async (fac, scope) => { await ef写入重复的数据 }); }); 时,正常返回200,异常可以被全局异常处理截获并写日志,程序正常运行。 ----------- ### 异常堆栈信息 **第一种情况,程序退出前的异常信息** Error: An assembly specified in the application dependencies manifest (YLVIP.Web.Entry.deps.json) has already been found but with a different file extension: package: 'YLVIP.Web.Entry', version: '1.0.0' path: 'YLVIP.Web.Entry.dll' previously found assembly: '\YLVIP.Web.Entry\bin\Debug\net5.0\YLVIP.Web.Entry.exe' PS \YLVIP.Web.Entry\bin\Debug\net5.0> dotnet YLVIP.Web.Entry.dll Unhandled exception. Microsoft.EntityFrameworkCore.DbUpdateException: An error occurred while updating the entries. See the inner exception for details. ---> Microsoft.Data.SqlClient.SqlException (0x80131904): 违反了 PRIMARY KEY 约束“PK_Orders”。不能在对象“dbo.Orders”中插入重复键。重复键值为 (1122334455)。 语句已终止。 at Microsoft.Data.SqlClient.SqlCommand.<>c.<ExecuteDbDataReaderAsync>b__169_0(Task`1 result) at System.Threading.Tasks.ContinuationResultTaskFromResultTask`2.InnerInvoke() at System.Threading.Tasks.Task.<>c.<.cctor>b__277_0(Object obj) at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state) --- End of stack trace from previous location --- 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.Update.ReaderModificationCommandBatch.ExecuteAsync(IRelationalConnection connection, CancellationToken cancellationToken) ClientConnectionId:efd565e0-7b8c-492d-af1c-25029f3071c3 Error Number:2627,State:1,Class:14 --- End of inner exception stack trace --- at Microsoft.EntityFrameworkCore.Update.ReaderModificationCommandBatch.ExecuteAsync(IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.Update.Internal.BatchExecutor.ExecuteAsync(IEnumerable`1 commandBatches, IRelationalConnection connection, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(IList`1 entriesToSave, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(DbContext _, Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.SqlServer.Storage.Internal.SqlServerExecutionStrategy.ExecuteAsync[TState,TResult](TState state, Func`4 operation, Func`4 verifySucceeded, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Furion.DatabaseAccessor.PrivateRepository`1.InsertNowAsync(IEnumerable`1 entities, CancellationToken cancellationToken) at YLVIP.Application.OrderService.<>c__DisplayClass3_0.<<CreateOrders>b__1>d.MoveNext() in \YLVIP.Application\Orders\OrderService.cs:line 89 --- End of stack trace from previous location --- at Furion.DependencyInjection.Scoped.Create(Func`3 handler, IServiceScopeFactory scopeFactory) at YLVIP.Application.OrderService.<>c__DisplayClass3_0.<<CreateOrders>b__0>d.MoveNext() in \YLVIP.Application\Orders\OrderService.cs:line 67 --- End of stack trace from previous location --- at System.Threading.Tasks.Task.<>c.<ThrowAsync>b__140_1(Object state) at System.Threading.QueueUserWorkItemCallback.<>c.<.cctor>b__6_0(QueueUserWorkItemCallback quwi) at System.Threading.ExecutionContext.RunForThreadPoolUnsafe[TState](ExecutionContext executionContext, Action`1 callback, TState& state) at System.Threading.QueueUserWorkItemCallback.Execute() at System.Threading.ThreadPoolWorkQueue.Dispatch() 进程已结束,退出代码为 -532,462,766。 ----------- ### 代码或代码仓库 ``` public async Task<List<AddOrderOutput>> CreateOrders(VipOrderListInput orders) { var ydOrders = orders.Adapt<PostOrderToYunDa>(); var data = new YunDaData { method = "oms_create_order_elec_th", data = SecretUtil.EncodeBase64("UTF-8", JSON.Serialize(ydOrders)) }; // 快递接口 var responseMessage = await _yunDaApi.PostCreateOrderElecThAsync(data); if (!responseMessage.success) throw Oops.Oh(responseMessage.error_msg).StatusCode(400); // 后台记录快递数据 SpareTime.DoIt(async () => { await Scoped.Create(async (fac, scope) => { var services = scope.ServiceProvider; var orderRespository = Db.GetRepository<Orders>(services); // 插入重复数据 await orderRespository.InsertNowAsync(responseMessage.result_info); }); }); // 返回快递结果 return responseMessage.result_info.Adapt<List<AddOrderOutput>>(); } ``` ----------- ### 数据库信息 - [x] SqlServer ----------- ### 期待结果 SpareTime.DoIt中发送异常时,程序不要结束运行 第三种情况可以达到期望的效果, 请问: 第一种情况是框架bug么?亦或是我的 SpareTime.DoIt(async () =>{});用的不对,应该怎么用? -----------
评论 (
3
)
登录
后才可以发表评论
状态
已完成
待办的
进行中
已完成
已关闭
负责人
未设置
百小僧
monksoul
负责人
协作者
+负责人
+协作者
标签
漏洞
疑问
未设置
标签管理
里程碑
Furion 2021
未关联里程碑
Pull Requests
未关联
未关联
关联的 Pull Requests 被合并后可能会关闭此 issue
分支
未关联
分支 (
-
)
标签 (
-
)
开始日期   -   截止日期
-
置顶选项
不置顶
置顶等级:高
置顶等级:中
置顶等级:低
优先级
不指定
严重
主要
次要
不重要
参与者(2)
C#
1
https://gitee.com/dotnetchina/Furion.git
git@gitee.com:dotnetchina/Furion.git
dotnetchina
Furion
Furion
点此查找更多帮助
搜索帮助
Git 命令在线学习
如何在 Gitee 导入 GitHub 仓库
Git 仓库基础操作
企业版和社区版功能对比
SSH 公钥设置
如何处理代码冲突
仓库体积过大,如何减小?
如何找回被删除的仓库数据
Gitee 产品配额说明
GitHub仓库快速导入Gitee及同步更新
什么是 Release(发行版)
将 PHP 项目自动发布到 packagist.org
仓库举报
回到顶部
登录提示
该操作需登录 Gitee 帐号,请先登录后再操作。
立即登录
没有帐号,去注册