服务端的TigerApi 框架,基于.NET6 2024 版本
Ben Lin
2024-05-08 34565b0920fb37cf02e1df02a6bbfb08ca51cdb6
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
using Autofac;
using Autofac.Configuration;
using Autofac.Extensions.DependencyInjection;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Configuration.Json;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.OpenApi.Models;
using Rhea.Common;
using Sundial;
using System;
using System.IO;
using System.Linq;
using System.Reflection;
using Tiger.IBusiness;
using Tiger.IBusiness.Utility;
 
namespace Tiger.Api
{
    public class Startup
    {
        public string version => $"V{(Assembly.GetExecutingAssembly().GetCustomAttributes(typeof(AssemblyFileVersionAttribute)).First() as AssemblyFileVersionAttribute).Version}";
        public readonly string anyAllowSpecificOrigins = "any";
 
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
            //初始化 ApiConfig
            ApiConfig.InitConfig(configuration);
 
            //测试代码
            //ConsoleExt.WriteLine("");
            //Console.Read();
            //var t = Biz.GetBackupWIP_SN("test");
            //var l = Biz.Language.GetJson("zh-CN");
            ;
 
            //删除一个月前的日志
            DeleteLogs();
        }
 
        /// <summary>
        ///
        /// </summary>
        public IConfiguration Configuration { get; }
 
        // This method gets called by the runtime. Use this method to add services to the container.
        /// <summary>
        ///
        /// </summary>
        /// <param name="services"></param>
        public void ConfigureServices(IServiceCollection services)
        {
            //services.RegisterAssembly("Tiger.Service");
            //services.AddTransient(typeof(IBaseService<>), typeof(BaseService<>));
            services.AddControllersWithViews().AddNewtonsoftJson(opt =>
            {
                opt.SerializerSettings.ContractResolver = new Newtonsoft.Json.Serialization.DefaultContractResolver();
                opt.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss";
            });
 
            //配置跨域处理cors
            services.AddCors(options =>
            {
                options.AddPolicy(anyAllowSpecificOrigins, corsbuilder =>
                {
                    var corsPath = Configuration.GetSection("CorsPaths").GetChildren().Select(p => p.Value).ToArray();
                    corsbuilder.WithOrigins(corsPath)
                    .AllowAnyMethod()
                    .AllowAnyHeader();
                    //.AllowCredentials();//指定处理cookie
                });
            });
            services.AddSwaggerGen(c =>
            {
                c.SwaggerDoc(version, new OpenApiInfo { Title = "Tiger API", Version = version });
                var basePath = AppDomain.CurrentDomain.BaseDirectory;
                var xmlPath = Path.Combine(basePath, "Tiger.Api.xml");
                c.IncludeXmlComments(xmlPath);
            });
            //注册定时任务服务
            services.AddSchedule();
            //services.AddTransient<IMaterialInfoBusiness, MaterialInfoBusiness>();
        }
 
        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
        /// <summary>
        ///
        /// </summary>
        /// <param name="app"></param>
        /// <param name="env"></param>
        public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }
 
            //初始化 BizConfig
            var bizConfig = (new ConfigurationBuilder().SetBasePath(AppDomain.CurrentDomain.BaseDirectory).AddJsonFile("BizSettings.json")).Build();
            //BizConfig.InitConfig(bizConfig);
            BizConfig.InitConfig(bizConfig, DI.Resolve<ILanguage>().GetDictionary());
 
            //加载配置文件
            NLog.LogManager.LoadConfiguration("nlog.config").GetCurrentClassLogger();
            app.UseMiddleware<LogMiddleware>();
 
            app.UseSwagger();
            app.UseSwaggerUI(c =>
            {
                c.SwaggerEndpoint($"/swagger/{version}/swagger.json", $"Tiger API {version}");
            });
 
            app.UseRouting();
            app.UseCors(anyAllowSpecificOrigins);//支持跨域:允许特定来源的主机访问
 
            //app.UseHttpsRedirection();
            app.UseStaticFiles();
 
            //app.UseAuthorization();
            app.UseEndpoints(endpoints =>
            {
                endpoints.MapControllerRoute(name: "default", pattern: "{controller=Home}/{action=Index}/{id?}").RequireCors(anyAllowSpecificOrigins);
                endpoints.MapControllers().RequireCors(anyAllowSpecificOrigins);
            });
 
            ConsoleExt.Write($"Api Run as{((ApiConfig.IsDevVersion || ApiConfig.IsTestVersion) ? ((ApiConfig.IsDevVersion ? " Dev" : "") + (ApiConfig.IsTestVersion ? " Test" : "")) : " Release")} Edition", ConsoleColor.Cyan);
            //连接至数据库
            if (BizConfig.Configuration["IsTestServer"].ToLower() == "true")
            {
                ConsoleExt.WriteLine($", Link to Test {BizConfig.Configuration["Databases:Test:DbType"]} Database, " +
                    BizConfig.Configuration[$"Databases:Test:ConnectionString"].Split(';').Where(q => q.Contains("server")).FirstOrDefault() +
                    (BizConfig.Configuration[$"Databases:Test:ConnectionString"].Split(';').Any(q => q.Contains("server")) ? "," : "") +
                    BizConfig.Configuration[$"Databases:Main:ConnectionString"].Split(';').Where(q => q.Contains("port")).FirstOrDefault() +
                    (BizConfig.Configuration[$"Databases:Main:ConnectionString"].Split(';').Any(q => q.Contains("port")) ? "," : "") +
                    BizConfig.Configuration[$"Databases:Test:ConnectionString"].Split(';').Where(q => q.Contains("Data Source") || q.Contains("DataSource") || q.Contains("database")).FirstOrDefault(), ConsoleColor.Cyan);
            }
            else
            {
                ConsoleExt.WriteLine($", Link to Formal {BizConfig.Configuration["Databases:Main:DbType"]} Database, " +
                    BizConfig.Configuration[$"Databases:Main:ConnectionString"].Split(';').Where(q => q.Contains("server")).FirstOrDefault() +
                    (BizConfig.Configuration[$"Databases:Main:ConnectionString"].Split(';').Any(q => q.Contains("server")) ? "," : "") +
                    BizConfig.Configuration[$"Databases:Main:ConnectionString"].Split(';').Where(q => q.Contains("port")).FirstOrDefault() +
                    (BizConfig.Configuration[$"Databases:Main:ConnectionString"].Split(';').Any(q => q.Contains("port")) ? "," : "") +
                    BizConfig.Configuration[$"Databases:Main:ConnectionString"].Split(';').Where(q => q.Contains("Data Source") || q.Contains("DataSource") || q.Contains("database")).FirstOrDefault(), ConsoleColor.Cyan);
            }
 
            //初始化Business的AutoFacContainer
            DI.Resolve<IBiz>().SetContainer(AutoFacContainer.Instance);
            //开启Api监控总线
            DI.Resolve<IMonitorBus>().StartMonitors();
            //开启服务总线
            DI.Resolve<IServicesBus>().StartServices(app.ApplicationServices.GetService<ISchedulerFactory>());
            //开启DB缓存自动更新
            DI.Resolve<IDbCacheBus>().StartAutoUpdate();
            //开启MQTT服务
            MQTTHelper.Start();
        }
 
        /// <summary>
        /// 删除一个月前的Log
        /// </summary>
        public void DeleteLogs()
        {
            DirectoryInfo di = new DirectoryInfo(AppDomain.CurrentDomain.BaseDirectory + "\\Logs");
            if(di.Exists) 
            {
                var logFiles = di.GetFiles("*.log", SearchOption.AllDirectories);
                foreach (var file in logFiles)
                {
                    if ((DateTime.Now - file.LastWriteTime).TotalDays > 30)
                    {
                        file.Delete();
                    }
                }
            }
            
        }
    }//endClass
}