From 32f46816cddf03c99deb6c304d7d12036dd4ad8b Mon Sep 17 00:00:00 2001
From: cjy <tiankui_xing@163.com>
Date: Tue, 6 Aug 2024 09:53:07 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E7=A7=9F=E6=88=B7=E6=9B=B4=E6=96=B0?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E5=AE=9E=E4=BD=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../DS.WMS.Test/SaasDBUpdateTest.cs           | 85 +++++++++++++++++++
 1 file changed, 85 insertions(+)
 create mode 100644 ds-wms-service/DS.WMS.Test/SaasDBUpdateTest.cs

diff --git a/ds-wms-service/DS.WMS.Test/SaasDBUpdateTest.cs b/ds-wms-service/DS.WMS.Test/SaasDBUpdateTest.cs
new file mode 100644
index 00000000..ea63fdd0
--- /dev/null
+++ b/ds-wms-service/DS.WMS.Test/SaasDBUpdateTest.cs
@@ -0,0 +1,85 @@
+using System.Reflection;
+using DS.Module.Core;
+using DS.Module.Core.Extensions;
+using DS.Module.SqlSugar;
+using DS.WMS.Core.Check.Entity;
+using DS.WMS.Core.Code.Entity;
+using DS.WMS.Core.Info.Entity;
+using DS.WMS.Core.Op.Entity;
+using DS.WMS.Core.Op.Entity.BookingSlot;
+using DS.WMS.Core.Sys.Entity;
+using DS.WMS.Core.TaskPlat.Entity;
+using Mapster;
+using Masuit.Tools.Strings;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Owin.BuilderProperties;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Serialization;
+using Org.BouncyCastle.Ocsp;
+using SqlSugar;
+using SqlSugar.IOC;
+using Xunit;
+
+namespace Ds.WMS.Test;
+
+public class SaasDBUpdateTest
+{
+    private readonly IServiceProvider _serviceProvider;
+    private readonly SqlSugarScope db;
+    private readonly ISaasDbService saasService;
+    public SaasDBUpdateTest(IServiceProvider serviceProvider)
+    {
+        _serviceProvider = serviceProvider;
+        db = (SqlSugarScope)_serviceProvider.GetRequiredService<ISqlSugarClient>();
+        saasService = _serviceProvider.GetRequiredService<ISaasDbService>();
+    }
+
+     
+    /// <summary>
+    /// 主库初始化单表
+    /// </summary>
+    [Fact]
+    public void MasterInitTableTest()
+    { 
+        StaticConfig.CodeFirst_MySqlCollate = "utf8mb4_0900_ai_ci";//较高版本支持 
+        db.CodeFirst.InitTables(typeof(SysPrintTemplate)); 
+        Assert.True(true);
+    }
+    /// <summary>
+    /// 初始化单表 多表 
+    /// 注意 海运出口 SeaExport 得手动数据库更新
+    /// </summary>
+    [Fact]
+    public void InitSaasTableTestByCjy()
+    {
+        var tenantList = db.Queryable<DS.Module.SqlSugar.SysTenantLink>().ToList();
+        var ass = Assembly.Load("DS.WMS.Core");
+        //var types = ass.GetTypes().Where(it => it.FullName?.Contains("DS.WMS.Core.TaskPlat.Entity") == true).ToArray();
+        foreach (var item in tenantList)
+        {
+            var tenantDb = saasService.GetBizDbScopeById(item.TenantId).CopyNew();
+            StaticConfig.CodeFirst_MySqlCollate = "utf8mb4_0900_ai_ci"; //较高版本支持
+            //tenantDb.CodeFirst.InitTables(types); //指定表空间下的实体
+            tenantDb.CodeFirst.InitTables(typeof(OpLetterYard));//指定更新特定实体 
+        }
+         
+        Assert.True(true);
+    } 
+    /// <summary>
+    /// 初始化单表
+    /// </summary>
+    [Fact]
+    public void InitTableTestZXF()
+    {
+        var tenantDb = saasService.GetBizDbScopeById("1750335377144680448");
+        StaticConfig.CodeFirst_MySqlCollate = "utf8mb4_0900_ai_ci";//较高版本支持 
+
+        var ass = Assembly.Load("DS.WMS.Core");
+        var types = ass.GetTypes().Where(it => it.FullName?.Contains("DS.WMS.Core.TaskPlat.Entity") == true).ToArray();
+        tenantDb.CodeFirst.InitTables(types);
+
+        //tenantDb.CodeFirst.InitTables(typeof(TaskFlowLog));
+        //tenantDb.CodeFirst.InitTables(typeof(TaskFlowLogDetail));
+        Assert.True(true);
+    }
+}
\ No newline at end of file