fix 多钱包调整

2024-11-08 16:36:10 +08:00
parent 36bfd2e8f6
commit 1a0ba28249
36 changed files with 418 additions and 434 deletions
--- a/Src/Dlhis.Middle/BackgroundServices/BalanceRecordUploadBackgroundService.cs
+++ b/Src/Dlhis.Middle/BackgroundServices/BalanceRecordUploadBackgroundService.cs
@@ -0,0 +1,128 @@
+using System.Net.Http.Headers;
+using System.Text;
+using Dlhis.Middle.Apis;
+using Dlhis.Middle.Entities;
+using Dlhis.Middle.Response;
+using Dlhis.Middle.Services;
+using Kurisu.AspNetCore.DataAccess.SqlSugar.Services;
+using Kurisu.AspNetCore.UnifyResultAndValidation;
+using Kurisu.AspNetCore.Utils.Extensions;
+
+namespace Dlhis.Middle.BackgroundServices;
+
+public class BalanceRecordUploadBackgroundService : BackgroundService
+{
+    private readonly IServiceProvider _serviceProvider;
+    private readonly ILogger<BalanceRecordUploadBackgroundService> _logger;
+    private readonly IWebHostEnvironment _environment;
+    private readonly ISettingService _settingService;
+    private readonly ICanteenApi _canteenApi;
+
+    private readonly IHealthCheckService _healthCheckService;
+
+    public BalanceRecordUploadBackgroundService(IServiceProvider serviceProvider,
+        ILogger<BalanceRecordUploadBackgroundService> logger,
+        IWebHostEnvironment environment,
+        ISettingService settingService,
+        ICanteenApi canteenApi,
+        IHealthCheckService healthCheckService)
+    {
+        _serviceProvider = serviceProvider;
+        _logger = logger;
+        _environment = environment;
+        _settingService = settingService;
+        _canteenApi = canteenApi;
+        _healthCheckService = healthCheckService;
+    }
+
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+    {
+        while (!stoppingToken.IsCancellationRequested && _environment.IsProduction())
+        {
+            if (!_healthCheckService.GetIsOffline())
+            {
+                var now = DateTime.Now;
+
+                using var scope = _serviceProvider.CreateScope();
+                var db = scope.ServiceProvider.GetService<IDbContext>();
+                var ds = scope.ServiceProvider.GetService<IDataDownloadService>();
+
+                var factories = _settingService.GetFactories();
+                foreach (var factory in factories)
+                {
+                    try
+                    {
+                        var balanceRecords = await db.Queryable<LocalBalanceRecordEntity>().Where(x => x.TenantId == factory).Where(x => !x.IsSync).ToListAsync(stoppingToken);
+                        if (balanceRecords.Any())
+                        {
+                            _logger.LogInformation("上传离线订单");
+                            foreach (var balanceRecord in balanceRecords)
+                            {
+                                //事务
+                                await db.Client.Ado.BeginTranAsync();
+                                try
+                                {
+                                    var r = await _canteenApi.UploadAsync(balanceRecord);
+                                    if (r.Code != ApiStateCode.Success)
+                                    {
+                                        throw new Exception(r.Msg);
+                                    }
+
+                                    var d = r.Data;
+                                    //更新本地余额表
+                                    await db.Updateable<LocalGainfoMealEntity>()
+                                        .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)
+                                {
+                                    _logger.LogError(e, "{factory}上传离线消费失败:{message}", factory, e.Message);
+                                    await db.Client.Ado.RollbackTranAsync();
+                                }
+                            }
+
+                            balanceRecords = await db.Queryable<LocalBalanceRecordEntity>().Where(x => x.TenantId == factory).Where(x => !x.IsSync).ToListAsync(stoppingToken);
+                            if (!balanceRecords.Any())
+                            {
+                                _logger.LogInformation("上传离线订单完成");
+                            }
+                        }
+                    }
+                    catch (Exception e)
+                    {
+                        _logger.LogError(e, "{factory}同步离线数据失败:{message}", factory, e.Message);
+                    }
+                }
+
+
+                if (now is { Hour: 4, Minute: 1 }
+                    && !_healthCheckService.GetIsOffline()
+                    && !await db.Queryable<LocalBalanceRecordEntity>().Where(x => !x.IsSync).AnyAsync())
+                {
+                    await ds.InitAsync(factories);
+                }
+                else if (now is { Hour: 15, Minute: 1 }
+                         && !_healthCheckService.GetIsOffline()
+                         && !await db.Queryable<LocalBalanceRecordEntity>().Where(x => !x.IsSync).AnyAsync())
+                {
+                    await ds.InitAsync(factories);
+                }
+                else if (now is { Hour: 20, Minute: 1 }
+                         && !_healthCheckService.GetIsOffline()
+                         && !await db.Queryable<LocalBalanceRecordEntity>().Where(x => !x.IsSync).AnyAsync())
+                {
+                    await ds.InitAsync(factories);
+                }
+            }
+
+            await Task.Delay(60 * 1000, stoppingToken);
+        }
+    }
+}