publicclassUser:BaseGuidEntity{[Required]publicstringAccount{get;set;}/// <summary>/// 名称/// </summary>publicstringNickName{get;set;}/// <summary>/// 真实名称/// </summary>publicstringRealName{get;set;}/// <summary>/// 年龄/// </summary>publicintAge{get;set;}/// <summary>/// 手机号/// </summary>publicstringTel{get;set;}/// <summary>/// 住址/// </summary>publicstringAddress{get;set;}/// <summary>/// 密码/// </summary>publicstringPassword{get;set;}/// <summary>/// 用户状态/// </summary>publicUserStatusEnumUserStatus{get;set;}}publicenumUserStatusEnum{Registered,//已注册Incompleted,// 未完善信息Completed,//完善信息Locked,// 锁定Deleted// 删除}

publicstaticclassUserCreatingExtension{publicstaticvoidConfigureUserStore(thisModelBuilderbuilder){Check.NotNull(builder,nameof(builder));builder.Entity<User>(option =>{option.ToTable("User");option.ConfigureByConvention();});}}

[ConnectionStringName("Default")]publicclassMyShopDbContext:AbpDbContext<MyShopDbContext>{publicMyShopDbContext(DbContextOptions<MyShopDbContext>options):base(options){}protectedoverridevoidOnModelCreating(ModelBuilderbuilder){builder.ConfigureProductStore();builder.ConfigureOrderStore();builder.ConfigureOrderItemStore();builder.ConfigureCategoryStore();builder.ConfigureBasketAndItemsStore();// 配置用户表builder.ConfigureUserStore();}publicDbSet<Product>Products{get;set;}publicDbSet<Order>Orders{get;set;}publicDbSet<OrderItem>OrderItems{get;set;}publicDbSet<Category>Categories{get;set;}publicDbSet<Basket>Basket{get;set;}publicDbSet<BasketItem>BasketItems{get;set;}//添加用户表publicDbSet<User>Users{get;set;}}

[ConnectionStringName("Default")]publicclassDbMigrationsContext:AbpDbContext<DbMigrationsContext>{publicDbMigrationsContext(DbContextOptions<DbMigrationsContext>options):base(options){}protectedoverridevoidOnModelCreating(ModelBuilderbuilder){base.OnModelCreating(builder);builder.ConfigureProductStore();builder.ConfigureOrderStore();builder.ConfigureOrderItemStore();builder.ConfigureCategoryStore();builder.ConfigureBasketAndItemsStore();// 用户配置builder.ConfigureUserStore();}}

"Jwt":{"SecurityKey":"1111111111111111111111111111111","Issuer":"MyShopIssuer","Audience":"MyShopAudience","Expires":30// 过期分钟}

namespaceMyShop.Application.Contract.User{publicinterfaceIUserApplicationService{Task<BaseResult<TokenInfo>>Register(UserRegisterDtoregisterInfo,CancellationTokencancellationToken);Task<BaseResult<TokenInfo>>Login(UserLoginDtologinInfo);}}

namespaceMyShop.Application.AutoMapper.Profiles{publicclassMyShopApplicationProfile:Profile{publicMyShopApplicationProfile(){CreateMap<Product,ProductItemDto>().ReverseMap();CreateMap<Order,OrderInfoDto>().ReverseMap();CreateMap<Basket,BasketDto>().ReverseMap();CreateMap<BasketItem,BasketItemDto>().ReverseMap();CreateMap<InsertBasketItemDto,BasketItem>().ReverseMap();// 用户注册信息映射CreateMap<UserRegisterDto,User>().ForMember(src=>src.UserStatus,opt=>opt.MapFrom(src=>UserStatusEnum.Registered)).ForMember(src=>src.Password, opt=>opt.MapFrom(src=>EncryptHelper.MD5Encrypt(src.Password,string.Empty)));}}}

namespaceMyShop.Application{/// <summary>/// 用户服务/// </summary>publicclassUserApplicationService:ApplicationService,IUserApplicationService{privatereadonlyIConfiguration_configuration;privatereadonlyIRepository<User,Guid>_userRepository;/// <summary>/// 构造/// </summary>/// <param name="userRepository">用户仓储</param>/// <param name="configuration">配置信息</param>publicUserApplicationService(IRepository<User,Guid>userRepository,IConfigurationconfiguration){_userRepository=userRepository;_configuration=configuration;}/// <summary>/// 登录/// </summary>/// <param name="loginInfo">登录信息</param>/// <returns></returns>publicasyncTask<BaseResult<TokenInfo>>Login(UserLoginDtologinInfo){if(string.IsNullOrEmpty(loginInfo.Account)||string.IsNullOrEmpty(loginInfo.Password))returnBaseResult<TokenInfo>.Failed("用户名密码不能为空!");varuser=awaitTask.FromResult(_userRepository.FirstOrDefault(p =>p.Account==loginInfo.Account));if(user==null){returnBaseResult<TokenInfo>.Failed("用户名密码错误!");}stringmd5Pwd=EncryptHelper.MD5Encrypt(loginInfo.Password);if(user.Password!=md5Pwd){returnBaseResult<TokenInfo>.Failed("用户名密码错误!");}varclaims=GetClaims(user);vartoken=GenerateToken(claims);returnBaseResult<TokenInfo>.Success(token);}/// <summary>/// 注册/// </summary>/// <param name="registerInfo">注册信息</param>/// <param name="cancellationToken">取消令牌</param>/// <returns></returns>publicasyncTask<BaseResult<TokenInfo>>Register(UserRegisterDtoregisterInfo,CancellationTokencancellationToken){varuser=ObjectMapper.Map<UserRegisterDto,User>(registerInfo);varregisteredUser=await_userRepository.InsertAsync(user,true,cancellationToken);varclaims=GetClaims(user);vartoken=GenerateToken(claims);returnBaseResult<TokenInfo>.Success(token);} #region Token生成 privateIEnumerable<Claim>GetClaims(Useruser){varclaims=new[]{newClaim(AbpClaimTypes.UserName,user.NickName),newClaim(AbpClaimTypes.UserId,user.Id.ToString()),newClaim(AbpClaimTypes.PhoneNumber,user.Tel),newClaim(AbpClaimTypes.SurName,user.UserStatus==UserStatusEnum.Completed?user.RealName:string.Empty)};returnclaims;}/// <summary>/// 生成token/// </summary>/// <param name="claims">声明</param>/// <returns></returns>privateTokenInfoGenerateToken(IEnumerable<Claim>claims){// 密钥varkey=newSymmetricSecurityKey(Encoding.UTF8.GetBytes(_configuration["Jwt:SecurityKey"]));varcreds=newSigningCredentials(key,SecurityAlgorithms.HmacSha256);// 过期时间intexpires=string.IsNullOrEmpty(_configuration["Expires"])?30:Convert.ToInt32(_configuration["Expires"]);//生成tokenvartoken=newJwtSecurityToken(issuer:_configuration["Jwt:Issuer"],audience:_configuration["Jwt:Audience"],claims:claims,expires:DateTime.Now.AddMinutes(expires),signingCredentials:creds);returnnewTokenInfo(){Expire=expires,Token=newJwtSecurityTokenHandler().WriteToken(token)};} #endregion }}

usingMicrosoft.AspNetCore.Authentication.JwtBearer;usingMicrosoft.AspNetCore.Builder;usingMicrosoft.AspNetCore.Mvc;usingMicrosoft.Extensions.DependencyInjection;usingMicrosoft.Extensions.Hosting;usingMicrosoft.Extensions.PlatformAbstractions;usingMicrosoft.IdentityModel.Tokens;usingMicrosoft.OpenApi.Models;usingMyShop.Admin.Application;usingMyShop.Admin.Application.Services;usingMyShop.Api.Middleware;usingMyShop.Application;usingMyShop.Application.Contract.Order;usingMyShop.Application.Contract.Product;usingMyShop.EntityFrameworkCore;usingSystem;usingSystem.Collections.Generic;usingSystem.IO;usingSystem.Linq;usingSystem.Text;usingSystem.Threading.Tasks;usingVolo.Abp;usingVolo.Abp.AspNetCore;usingVolo.Abp.AspNetCore.Mvc;usingVolo.Abp.AspNetCore.Mvc.Conventions;usingVolo.Abp.AspNetCore.Mvc.ExceptionHandling;usingVolo.Abp.Autofac;usingVolo.Abp.Modularity;namespaceMyShop.Api{// 注意是依赖于AspNetCoreMvc 而不是 AspNetCore[DependsOn(typeof(AbpAspNetCoreMvcModule),typeof(AbpAutofacModule))][DependsOn(typeof(MyShopApplicationModule),typeof(MyShopEntityFrameworkCoreModule),typeof(MyShopAdminApplicationModule))]publicclassMyShopApiModule:AbpModule{publicoverridevoidConfigureServices(ServiceConfigurationContextcontext){varservice=context.Services;// 配置jwtConfigureJwt(service);// 配置跨域ConfigureCors(service);// 配置swaggerConfigureSwagger(service);service.Configure((AbpAspNetCoreMvcOptionsoptions)=>{options.ConventionalControllers.Create(typeof(Application.ProductApplicationService).Assembly);options.ConventionalControllers.Create(typeof(Application.OrderApplicationService).Assembly);options.ConventionalControllers.Create(typeof(Application.UserApplicationService).Assembly);options.ConventionalControllers.Create(typeof(Application.BasketApplicationService).Assembly);options.ConventionalControllers.Create(typeof(Admin.Application.Services.ProductApplicationService).Assembly, options =>{options.RootPath="admin";});});}publicoverridevoidOnApplicationInitialization(ApplicationInitializationContextcontext){varenv=context.GetEnvironment();varapp=context.GetApplicationBuilder();if(env.IsDevelopment()){app.UseDeveloperExceptionPage();}// 跨域app.UseCors("AllowAll");// swaggerapp.UseSwagger();app.UseSwaggerUI(options =>{options.SwaggerEndpoint("/swagger/v1/swagger.json","MyShopApi");});app.UseRouting();//添加jwt验证 注意：必须先添加认证再添加授权中间件，且必须添加在UseRouting 和UseEndpoints之间app.UseAuthentication();app.UseAuthorization();app.UseConfiguredEndpoints();} #region ServicesConfigure privatevoidConfigureJwt(IServiceCollectionservices){varconfiguration=services.GetConfiguration();services.AddAuthentication(options=>{options.DefaultAuthenticateScheme=JwtBearerDefaults.AuthenticationScheme;options.DefaultChallengeScheme=JwtBearerDefaults.AuthenticationScheme;}).AddJwtBearer(options=>{options.RequireHttpsMetadata=false;// 开发环境为falseoptions.TokenValidationParameters=newMicrosoft.IdentityModel.Tokens.TokenValidationParameters(){ValidateIssuer=true,//是否验证IssuerValidateAudience=true,//是否验证AudienceValidateLifetime=true,//是否验证失效时间ClockSkew=TimeSpan.FromSeconds(30),// 偏移时间,所以实际过期时间 = 给定过期时间+偏移时间ValidateIssuerSigningKey=true,//是否验证SecurityKeyValidAudience=configuration["Jwt:Audience"],//AudienceValidIssuer=configuration["Jwt:Issuer"],//Issuer，这两项和前面签发jwt的设置一致IssuerSigningKey=newSymmetricSecurityKey(Encoding.UTF8.GetBytes(configuration["Jwt:SecurityKey"]))//拿到SecurityKey};// 事件options.Events=newJwtBearerEvents(){OnAuthenticationFailed= context =>{returnTask.CompletedTask;},OnChallenge= context =>{// 验证失败BaseResult<object>result=newBaseResult<object>(ResponseResultCode.Unauthorized,"未授权",null);context.HandleResponse();context.Response.ContentType="application/json;utf-8";context.Response.StatusCode=StatusCodes.Status401Unauthorized;awaitcontext.Response.WriteAsync(JsonConvert.SerializeObject(result),Encoding.UTF8);},OnForbidden= context =>{returnTask.CompletedTask;},OnMessageReceived= context =>{returnTask.CompletedTask;}};});}privatevoidConfigureCors(IServiceCollectionservices){services.AddCors(options =>{options.AddPolicy("AllowAll", builder =>{builder.AllowAnyOrigin().SetIsOriginAllowedToAllowWildcardSubdomains().AllowAnyHeader().AllowAnyMethod();});});}privatevoidConfigureSwagger(IServiceCollectionservices){services.AddSwaggerGen(options =>{options.SwaggerDoc("v1",newMicrosoft.OpenApi.Models.OpenApiInfo(){Title="MyShopApi",Version="v0.1"});options.DocInclusionPredicate((docName,predicate)=>true);options.CustomSchemaIds(type =>type.FullName);varbasePath=PlatformServices.Default.Application.ApplicationBasePath;options.IncludeXmlComments(Path.Combine(basePath,"MyShop.Application.xml"));options.IncludeXmlComments(Path.Combine(basePath,"MyShop.Application.Contract.xml")); #region 添加请求认证 //Bearer 的scheme定义varsecurityScheme=newOpenApiSecurityScheme(){Description="JWT Authorization header using the Bearer scheme. Example: \"Authorization: Bearer{token}\"",Name="Authorization",//参数添加在头部In=ParameterLocation.Header,//使用Authorize头部Type=SecuritySchemeType.Http,//内容为以 bearer开头Scheme="Bearer",BearerFormat="JWT"};//把所有方法配置为增加bearer头部信息varsecurityRequirement=newOpenApiSecurityRequirement{{newOpenApiSecurityScheme{Reference=newOpenApiReference{Type=ReferenceType.SecurityScheme,Id="MyShopApi"}},newstring[]{}}};options.AddSecurityDefinition("MyShopApi",securityScheme);options.AddSecurityRequirement(securityRequirement); #endregion });} #endregion }}

/// <summary>/// 基础响应信息/// </summary>/// <typeparam name="T">响应数据类型</typeparam>publicclassBaseResult<T>whereT:class{/// <summary>/// 响应码/// </summary>publicResponseResultCodeCode{get;set;}/// <summary>/// 响应消息/// </summary>publicstringMessage{get;set;}/// <summary>/// 响应数据/// </summary>publicvirtualTData{get;set;}/// <summary>/// 响应成功信息/// </summary>/// <param name="data">响应数据</param>/// <returns></returns>publicstaticBaseResult<T>Success(Tdata,stringmessage="请求成功")=>newBaseResult<T>(ResponseResultCode.Success,message,data);/// <summary>/// 响应失败信息/// </summary>/// <param name="message">响应信息</param>/// <returns></returns>publicstaticBaseResult<T>Failed(stringmessage="请求失败!")=>newBaseResult<T>(ResponseResultCode.Failed,message,null);/// <summary>/// 响应异常信息/// </summary>/// <param name="message">响应信息</param>/// <returns></returns>publicstaticBaseResult<T>Error(stringmessage="请求失败!")=>newBaseResult<T>(ResponseResultCode.Error,message,null);/// <summary>/// 构造响应信息/// </summary>/// <param name="code">响应码</param>/// <param name="message">响应消息</param>/// <param name="data">响应数据</param>publicBaseResult(ResponseResultCodecode,stringmessage,Tdata){this.Code=code;this.Message=message;this.Data=data;}}publicenumResponseResultCode{Success=200,Failed=400,Unauthorized=401,Error=500}

/// <summary>/// 列表响应/// </summary>/// <typeparam name="T"></typeparam>publicclassListResult<T>:BaseResult<IEnumerable<T>>whereT:class{publicListResult(ResponseResultCodecode,stringmessage,IEnumerable<T>data):base(code,message,data){}}

publicclassPagedResult<T>:BaseResult<PageData<T>>{publicPagedResult(ResponseResultCodecode,stringmessage,PageData<T>data):base(code,message,data){}/// <summary>/// 响应成功信息/// </summary>/// <param name="total">数据总条数</param>/// <param name="list">分页列表信息</param>/// <returns></returns>publicstaticPagedResult<T>Success(inttotal,IEnumerable<T>list,stringmessage="请求成功")=>newPagedResult<T>(ResponseResultCode.Success,message,newPageData<T>(total,list));}/// <summary>/// 分页数据/// </summary>/// <typeparam name="T">数据类型</typeparam>publicclassPageData<T>{/// <summary>/// 构造/// </summary>/// <param name="total">数据总条数</param>/// <param name="list">数据集合</param>publicPageData(inttotal,IEnumerable<T>list){this.Total=total;this.Data=list;}/// <summary>/// 数据总条数/// </summary>publicintTotal{get;set;}/// <summary>/// 数据集合/// </summary>publicIEnumerable<T>Data{get;set;}}

// 移除Abp异常过滤器Configure<MvcOptions>(options =>{varindex=options.Filters.ToList().FindIndex(filter =>filterisServiceFilterAttributeattr&&attr.ServiceType.Equals(typeof(AbpExceptionFilter)));if(index>-1)options.Filters.RemoveAt(index);});

/// <summary>/// MyShop异常中间件/// </summary>publicclassMyShopExceptionMiddleware{privatereadonlyRequestDelegate_next;publicMyShopExceptionMiddleware(RequestDelegatenext){_next=next;}publicasyncTaskInvokeAsync(HttpContextcontext){try{await_next(context);}catch(Exceptionex){awaitHandleException(context,ex);}finally{awaitHandleException(context);}}privateasyncTaskHandleException(HttpContextcontext,Exceptionex=null){BaseResult<object>result=null;;boolhandle=true;if(context.Response.StatusCode==(int)HttpStatusCode.Unauthorized){result=newBaseResult<object>(ResponseResultCode.Unauthorized,"未授权!",null);}elseif(context.Response.StatusCode==(int)HttpStatusCode.InternalServerError){result=newBaseResult<object>(ResponseResultCode.Error,"服务繁忙!",null);}else{handle=false;}if(handle)awaitcontext.Response.WriteAsync(JsonConvert.SerializeObject(result),Encoding.UTF8);}}

publicstaticclassMiddlewareExtensions{/// <summary>/// MyShop异常中间件/// </summary>/// <param name="app"></param>/// <returns></returns>publicstaticIApplicationBuilderUseMyShopExceptionMiddleware(thisIApplicationBuilderapp){app.UseMiddleware<MyShopExceptionMiddleware>();returnapp;}}

app.UseMyShopExceptionMiddleware();