diff --git a/Src/Dlhis.Middle/Services/Implements/BalanceRecordCheckBackgroundService.cs b/Src/Dlhis.Middle/Services/Implements/BalanceRecordCheckBackgroundService.cs index 70810c52..5acade41 100644 --- a/Src/Dlhis.Middle/Services/Implements/BalanceRecordCheckBackgroundService.cs +++ b/Src/Dlhis.Middle/Services/Implements/BalanceRecordCheckBackgroundService.cs @@ -67,19 +67,20 @@ public class BalanceRecordCheckBackgroundService : BackgroundService //设置为已同步 balanceRecord.IsSync = true; await db.UpdateAsync(balanceRecord); - var r = await UploadAsync(balanceRecord); - if (r.Code == ApiStateCode.Success) + if (r.Code != ApiStateCode.Success) { - var d = r.Data; - //更新本地余额表 - await db.Updateable() - .SetColumns(x => x.Balance == d.Balance) - .Where(x => x.UserCode == d.UserCode) - .ExecuteCommandAsync(stoppingToken); - - await db.Client.Ado.CommitTranAsync(); + 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); + + await db.Client.Ado.CommitTranAsync(); } catch (Exception e) {