From 0c369f4d3dab390ab14332346b0fe6b86c999bd9 Mon Sep 17 00:00:00 2001 From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com> Date: 星期一, 23 六月 2025 09:46:29 +0800 Subject: [PATCH] 修复消息处理逻辑并增加地址检查在 `RequestInbound.cs` 中,更新了对 `content.Message` 的条件判断,增加了对 "无法获取目标地址" 消息的处理逻辑,并确保错误信息始终被记录。在 `Dt_TaskService.cs` 中,增加了对 `ToAddress` 变量的空值检查,确保在创建新任务实例之前,地址是有效的。 --- Code Management/WMS/WIDESEA_WMSServer/WIDESEA_Core/BaseRepository/IRepository.cs | 24 ++++++++++++++++++++++++ 1 files changed, 24 insertions(+), 0 deletions(-) diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_Core/BaseRepository/IRepository.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_Core/BaseRepository/IRepository.cs index b35fc98..4a5e263 100644 --- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_Core/BaseRepository/IRepository.cs +++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_Core/BaseRepository/IRepository.cs @@ -16,6 +16,7 @@ /// SqlsugarClient瀹炰綋 /// </summary> ISqlSugarClient Db { get; } + /// <summary> /// 閫氳繃涓婚敭鏌ヨ鏁版嵁 /// </summary> @@ -51,6 +52,13 @@ int AddData(TEntity entity); Task<int> AddDataAsync(TEntity entity); + + /// <summary> + /// 瀵艰埅鎻掑叆鏁版嵁(鍙敮鎸�2绾�) + /// </summary> + /// <param name="Entity"></param> + /// <returns></returns> + Task<bool> AddDataNavAsync(TEntity Entity); /// <summary> /// 娣诲姞澶氭潯鏁版嵁 @@ -116,6 +124,20 @@ Task<bool> UpdateDataAsync(List<TEntity> listEntity); /// <summary> + /// 瀵艰埅鏇存柊鏁版嵁(鍙敮鎸�2绾�) + /// </summary> + /// <param name="Entity"></param> + /// <returns></returns> + Task<bool> UpdateDataNavAsync(TEntity Entity); + + /// <summary> + /// 瀵艰埅鏇存柊鏁版嵁(鍙敮鎸�2绾�) + /// </summary> + /// <param name="Entity"></param> + /// <returns></returns> + bool UpdateDataNav(TEntity Entity); + + /// <summary> /// 鎸囧畾鍒楁洿鏂版暟鎹� /// </summary> /// <param name="entity"></param> @@ -156,6 +178,8 @@ Task<TEntity> QueryFirstAsync(Expression<Func<TEntity, bool>> whereExpression); + Task<TEntity> QueryFirstNavAsync(Expression<Func<TEntity, bool>> whereExpression); + TResult QueryFirst<TResult>(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, TResult>> expression); Task<TResult> QueryFirstAsync<TResult>(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, TResult>> expression); -- Gitblit v1.9.3