From dd049b44b12febe4e8ad9a231b70a0db2bb2ca19 Mon Sep 17 00:00:00 2001 From: liguoyang Date: Wed, 21 Aug 2024 14:53:30 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E9=94=99=E8=AF=AF=E6=8F=90=E9=86=92?= =?UTF-8?q?=E6=8A=9B=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../BalanceRecordCheckBackgroundService.cs | 21 ++++++++++--------- 1 file changed, 11 insertions(+), 10 deletions(-) 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) {