using System;
using System.Collections.Generic;
using System.ServiceModel;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Http.Features;
using Microsoft.AspNetCore.Rewrite;
using Microsoft.AspNetCore.StaticFiles;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.FileProviders;
using Microsoft.Extensions.Hosting;
using MySystem.PublicClass.GraphQL;
using System.Text;
using Microsoft.IdentityModel.Tokens;
using System.Linq;
namespace MySystem
{
public class Startup
{
public Startup(IConfiguration configuration)
{
Configuration = configuration;
}
public IConfiguration Configuration { get; }
// This method gets called by the runtime. Use this method to add services to the container.
public void ConfigureServices(IServiceCollection services)
{
services.AddControllersWithViews();
services.AddRouting(options =>
{
options.LowercaseUrls = true;
});
services.AddSingleton<IHttpContextAccessor, HttpContextAccessor>();
services.Configure<Setting>(Configuration.GetSection("Setting"));
services.AddCors(option => option.AddPolicy("cors", policy => policy.AllowAnyHeader().AllowAnyMethod().AllowCredentials().SetIsOriginAllowed(_ => true)));
services.AddMvc(options =>
{
options.EnableEndpointRouting = false;
options.Filters.Add(typeof(GlobalExceptions));
});
services.AddSession(options =>
{
// 设置 Session 过期时间
options.IdleTimeout = TimeSpan.FromHours(1);
options.Cookie.HttpOnly = true;
});
services.AddSingleton<IRepository, Repository>();
services.Configure<FormOptions>(x =>
{
x.MultipartBodyLengthLimit = 50 * 1024 * 1024;//不到300M
});
//生成密钥
var symmetricKeyAsBase64 = Configuration["Setting:JwtSecret"];
var keyByteArray = Encoding.ASCII.GetBytes(symmetricKeyAsBase64);
var signingKey = new SymmetricSecurityKey(keyByteArray);
//认证参数
services.AddAuthentication("Bearer").AddJwtBearer(o =>
{
o.TokenValidationParameters = new TokenValidationParameters
{
ValidateIssuerSigningKey = true,//是否验证签名,不验证的画可以篡改数据，不安全
IssuerSigningKey = signingKey,//解密的密钥
ValidateIssuer = true,//是否验证发行人，就是验证载荷中的Iss是否对应ValidIssuer参数
// ValidIssuer = Configuration["Setting:JwtIss"],//发行人
IssuerValidator = (m, n, z) =>
{
return n.Issuer;
},
ValidateAudience = true,//是否验证订阅人，就是验证载荷中的Aud是否对应ValidAudience参数
// ValidAudience = Configuration["Setting:JwtAud"],//订阅人
AudienceValidator = (m, n, z) =>
{
string check = RedisDbconn.Instance.Get<string>("utoken:" + n.Issuer);
return m != null && m.FirstOrDefault().Equals(check);
},
ValidateLifetime = true,//是否验证过期时间，过期了就拒绝访问
ClockSkew = TimeSpan.Zero,//这个是缓冲过期时间，也就是说，即使我们配置了过期时间，这里也要考虑进去，过期时间+缓冲，默认好像是7分钟，你可以直接设置为0
RequireExpirationTime = true,
};
});
string appkey = Configuration["Setting:AppKey"];
string appid = Configuration["Setting:AppId"];
string checkurl = Configuration["Setting:CheckUrl"];
string serviceurl = Configuration["Setting:WebServiceUrl"];
string schemeurl = Configuration["Setting:DbSchemeUrl"];
MySystemLib.SystemPublicFuction.appkey = appkey;
MySystemLib.SystemPublicFuction.appid = appid;
MySystemLib.SystemPublicFuction.checkurl = checkurl;
MySystemLib.SystemPublicFuction.appcheck = "success";
RedisDbconn.csredis = new CSRedis.CSRedisClient(Configuration["Setting:RedisConnStr"]);
}
// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
if (env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
// app.UseExceptionHandler("/Home/Error");
Library.ConfigurationManager.EnvironmentFlag = 1;
}
else
{
app.UseExceptionHandler("/Home/Error");
app.UseHsts();
Library.ConfigurationManager.EnvironmentFlag = 2;
}
// Library.ConfigurationManager.EnvironmentFlag = 1;
Library.function.WritePage("/", "WebRootPath.txt", env.WebRootPath);
// app.UseStatusCodePagesWithReExecute("/public/errpage/pc/{0}.html");
// RequestDelegate handler = async context =>
// {
// var response = context.Response;
// if (response.StatusCode < 500)
// {
// response.("/public/errpage/pc/{0}.html");
// }
// };
// app.UseStatusCodePages(builder => builder.Run(handler));
app.UseStaticFiles();
// app.UseStaticFiles(new StaticFileOptions
// {
// FileProvider = new PhysicalFileProvider(AppContext.BaseDirectory + "/static"),
// RequestPath = "/static"
// });
// app.UseStaticFiles(new StaticFileOptions
// {
// FileProvider = new PhysicalFileProvider(AppContext.BaseDirectory + "/" + Configuration["Setting:Database"]),
// RequestPath = "/" + Configuration["Setting:Database"]
// });
app.UseStaticFiles(new StaticFileOptions
{
ContentTypeProvider = new FileExtensionContentTypeProvider(new Dictionary<string, string>
{
{ ".apk", "application/vnd.android.package-archive" }
})
});
app.UseCors("cors");
app.UseAuthentication();
app.UseRouting();
app.UseAuthorization();
app.UseSession();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllerRoute(
name: "default",
pattern: "{controller=Home}/{action=Index}/{Id?}");
});
InitMain();
//必须打开的
// if(Library.ConfigurationManager.EnvironmentFlag == 1)
// {
// }
// if(Library.ConfigurationManager.EnvironmentFlag == 2)
// {
LeaderCompPrizeHelper.Instance.Start(); //领导人达标奖
RecommandKingHelper.Instance.Start(); //推荐王
AddSourcePosSnHelper.Instance.Start(); //补来源机具
// }
// LeaderCompPrizeHelper.Instance.StartTest();
}
private void InitMain()
{
string conn = Configuration["Setting:SqlConnStr"];
string dbName = "KxsMainServer";
if(Library.ConfigurationManager.EnvironmentFlag == 2)
{
dbName = "KxsProfitServer";
}
Dictionary<string, Dictionary<string, string>> tables = new Dictionary<string, Dictionary<string, string>>();
System.Data.DataTable tablecollection = Library.CustomerSqlConn.dtable("select DISTINCT TABLE_NAME from information_schema.columns where table_schema = '" + dbName + "'", conn);
foreach (System.Data.DataRow subtable in tablecollection.Rows)
{
Dictionary<string, string> Columns = new Dictionary<string, string>();
System.Data.DataTable columncollection = Library.CustomerSqlConn.dtable("select COLUMN_NAME,DATA_TYPE from information_schema.columns where table_schema = '" + dbName + "' and TABLE_NAME='" + subtable["TABLE_NAME"].ToString() + "'", conn);
foreach (System.Data.DataRow column in columncollection.Rows)
{
string datatype = column["DATA_TYPE"].ToString();
if (datatype == "decimal")
{
datatype = "numeric";
}
Columns.Add(column["COLUMN_NAME"].ToString(), datatype);
}
tables.Add(subtable["TABLE_NAME"].ToString(), Columns);
}
MySystemLib.SystemPublicFuction.dbtables = tables;
}
}
}