diff --git a/Src/Dlhis.Middle/Services/Implements/BalanceRecordCheckBackgroundService.cs b/Src/Dlhis.Middle/Services/Implements/BalanceRecordCheckBackgroundService.cs index 99b71a3c..a117b24b 100644 --- a/Src/Dlhis.Middle/Services/Implements/BalanceRecordCheckBackgroundService.cs +++ b/Src/Dlhis.Middle/Services/Implements/BalanceRecordCheckBackgroundService.cs @@ -69,18 +69,18 @@ public class BalanceRecordCheckBackgroundService : BackgroundService { throw new Exception(r.Msg); } - + var d = r.Data; //更新本地余额表 await db.Updateable() .SetColumns(x => x.Balance == d.Balance) .Where(x => x.UserCode == d.UserCode) .ExecuteCommandAsync(stoppingToken); - + //eg:一定要在此处更新为已同步 balanceRecord.IsSync = true; await db.UpdateAsync(balanceRecord); - + await db.Client.Ado.CommitTranAsync(); } catch (Exception e) @@ -89,6 +89,12 @@ public class BalanceRecordCheckBackgroundService : BackgroundService await db.Client.Ado.RollbackTranAsync(); } } + + balanceRecords = await db.Queryable().Where(x => x.TenantId == factory).Where(x => !x.IsSync).ToListAsync(stoppingToken); + if (!balanceRecords.Any()) + { + _logger.LogInformation("上传离线订单完成"); + } } } catch (Exception e)