showAbpEmail() {this.resetForm('emailForm')

      setting.GetEmailSettingsForApplication().then(data=>{if(data.result) {

          Object.assign(this.abpEmailForm, data.result)

        }this.isAbpEmail = true //编辑状态
})

    },

    /// <summary>
    ///重写默认的SmtpBuilder类/// </summary>
    public classMyMailKitSmtpBuilder : DefaultMailKitSmtpBuilder

    {private readonlyISmtpEmailSenderConfiguration _smtpEmailSenderConfiguration;private readonlyIAbpMailKitConfiguration _abpMailKitConfiguration;publicMyMailKitSmtpBuilder(ISmtpEmailSenderConfiguration smtpEmailSenderConfiguration, IAbpMailKitConfiguration abpMailKitConfiguration)

            :base(smtpEmailSenderConfiguration, abpMailKitConfiguration)

        {

            _smtpEmailSenderConfiguration=smtpEmailSenderConfiguration;

            _abpMailKitConfiguration=abpMailKitConfiguration;

        }/// <summary>
        ///配置发送处理/// </summary>
        /// <param name="client"></param>
        protected override voidConfigureClient(SmtpClient client)

        {

            client.CheckCertificateRevocation= false;

            client.ServerCertificateValidationCallback= (sender, certificate, chain, errors) => true;



            client.Connect(_smtpEmailSenderConfiguration.Host, _smtpEmailSenderConfiguration.Port, GetSecureSocketOption());if(_smtpEmailSenderConfiguration.UseDefaultCredentials)

            {return;

            }var username =_smtpEmailSenderConfiguration.UserName;var password =_smtpEmailSenderConfiguration.Password;//password = SimpleStringCipher.Instance.Decrypt(originalPass);//如果不重写自定义配置MySmtpEmailSenderConfiguration，那么密码需要解密
client.Authenticate(username, password);//base.ConfigureClient(client);
}

    }

    /// <summary>
    ///邮件发送参数配置类/// </summary>
    public classMySmtpEmailSenderConfiguration : SmtpEmailSenderConfiguration

    {public MySmtpEmailSenderConfiguration(ISettingManager settingManager) : base(settingManager)

        {



        }/// <summary>
        ///重写密码处理，需要解密密码/// </summary>
        public override string Password=>SimpleStringCipher.Instance.Decrypt(GetNotEmptySettingValue(EmailSettingNames.Smtp.Password));

    }

        /// <summary>
        ///发送校验的电子邮件/// </summary>
        /// <returns></returns>
        public asyncTask SendEmailValidate(SendEmailActivationLinkDto input)

        {var user = awaitGetUserByChecking(input.EmailAddress);//user.SetNewEmailConfirmationCode();

            #region 根据模板生成邮件正文

            //使用相对路径进行构造处理
            string template = string.Format("/UploadFiles/Email/EmailValidate.html");var helper = newNVelocityHelper(template);//${标题} ${内容} ${称呼} ${日期}
            var tilte = "邮箱验证通知";

            helper.AddKeyValue("title", tilte);

            helper.AddKeyValue("callname", "");

            helper.AddKeyValue("date", DateTime.Now.ToLongDateString());//邮箱校验码
            var callback =Guid.NewGuid().ToString();

            helper.AddKeyValue("callback", callback);var html =helper.ExecuteString();#endregion

            #region 构建邮件内容对象 发送邮件
            string toEmail = "wuhuacong@163.com";await _emailSender.SendAsync(newSystem.Net.Mail.MailMessage

            { 

                To={ toEmail },

                Subject=tilte,

                Body=html,

                IsBodyHtml= true});#endregionLogHelper.Logger.Info(string.Format("校验邮件发送给:{0}, {1}", toEmail, "发送邮件成功"));

        }

[DependsOn(typeof(WebCoreModule),typeof(AbpAspNetCoreSignalRModule))]public classWebHostModule: AbpModule

    {private readonlyIWebHostEnvironment _env;private readonlyIConfigurationRoot _appConfiguration;publicWebHostModule(IWebHostEnvironment env)

        {

            _env=env;

            _appConfiguration=env.GetAppConfiguration();

        }

public voidConfigure(IApplicationBuilder app, IWebHostEnvironment env, ILoggerFactory loggerFactory)

{

   ........................



    app.UseEndpoints(endpoints=>{

endpoints.MapHub<AbpCommonHub>("/signalr");

        endpoints.MapHub<ChatHub>("/signalr-chat");



        endpoints.MapControllerRoute("defaultWithArea", "{area}/{controller=Home}/{action=Index}/{id?}");

        endpoints.MapControllerRoute("default", "{controller=Home}/{action=Index}/{id?}");



    });

        /// <summary>
        ///发送SignalR消息/// </summary>
        /// <param name="input">发送的消息体</param>
        /// <returns></returns>
        public async Task<string>SendMessage(SendChatMessageInput input)

        {var sender =Context.ToUserIdentifier();var receiver = newUserIdentifier(input.TenantId, input.UserId);try{using(ChatAbpSession.Use(Context.GetTenantId(), Context.GetUserId()))

                {await_chatMessageManager.SendMessageAsync(sender, receiver, input.Message, input.TenancyName, input.UserName, input.ProfilePictureId);return string.Empty;

                }

            }catch(UserFriendlyException ex)

            {

                Logger.Warn("Could not send chat message to user:" +receiver);

                Logger.Warn(ex.ToString(), ex);returnex.Message;

            }catch(Exception ex)

            {

                Logger.Warn("Could not send chat message to user:" +receiver);

                Logger.Warn(ex.ToString(), ex);return _localizationManager.GetSource("AbpWeb").GetString("InternalServerError");

            }

        }

    /// <summary>
    ///发送的SignalR消息/// </summary>
    public classSendChatMessageInput

    {/// <summary>
        ///租户ID/// </summary>
        public int? TenantId { get; set; }/// <summary>
        ///用户ID/// </summary>
        public long UserId { get; set; }/// <summary>
        ///用户名/// </summary>
        public string UserName { get; set; }/// <summary>
        ///租户名/// </summary>
        public string TenancyName { get; set; }/// <summary>
        ///个人图片ID/// </summary>
        public Guid? ProfilePictureId { get; set; }/// <summary>
        ///发送的消息内容/// </summary>
        public string Message { get; set; }

    }

[AbpAuthorize]public classChatAppService : MyServiceBase, IChatAppService

    {private readonly IRepository<ChatMessage, long>_chatMessageRepository;private readonlyIUserFriendsCache _userFriendsCache;private readonly IOnlineClientManager<ChatChannel>_onlineClientManager;private readonly IChatCommunicator _chatCommunicator;

        private async void btnGetToken_Click(objectsender, EventArgs e)

        {if(this.txtUserName.Text.Length == 0)

            {

                MessageDxUtil.ShowTips("用户名不能为空");return;

            }else if (this.txtPassword.Text.Length == 0)

            {

                MessageDxUtil.ShowTips("用户密码不能为空"); return;

            }var data = newAuthenticateModel()

            {

                UserNameOrEmailAddress= this.txtUserName.Text,

                Password= this.txtPassword.Text

            }.ToJson();



            helper.ContentType= "application/json";//指定通讯的JSON方式
            helper.MaxTry = 2;var content = helper.GetHtml(TokenUrl, data, true);

            Console.WriteLine(content);var setting = new JsonSerializerSettings() { ContractResolver = newCamelCasePropertyNamesContractResolver() };var result = JsonConvert.DeserializeObject<AbpResponse<AuthenticateResultModel>>(content, setting);if (result != null && result.Success && !string.IsNullOrWhiteSpace(result.Result.AccessToken))

            {//获取当前用户
                Cache.Instance["AccessToken"] = result.Result.AccessToken;//设置缓存，方便ApiCaller调用设置Header
                currentUser = await UserApiCaller.Instance.GetAsync(new EntityDto<long>(result.Result.UserId));



                Console.WriteLine(result.Result.ToJson());

                Cache.Instance["token"] =  result.Result; //设置缓存后，APICaller不用手工指定RequestHeaders的令牌信息
EnableConnectState(false);

            }this.Text = string.Format("获取Token{0}", (result != null && result.Success) ? "成功" : "失败");//获取用户身份的朋友列表
GetUserFriends();

        }

        private voidGetUserFriends()

        {var result =ChatApiCaller.Instance.GetUserChatFriendsWithSettings();this.friendDict = new Dictionary<long, FriendDto>();foreach (var friend inresult.Friends)

            {this.friendDict.Add(friend.FriendUserId, friend);this.txtFriends.Properties.Items.Add(newCListItem(friend.FriendUserName, friend.FriendUserId.ToString()));

            }

        }

connection = newHubConnectionBuilder()

.WithUrl(ChatUrl, options=>{

    options.AccessTokenProvider= () =>Task.FromResult(token.AccessToken);

    options.UseDefaultCredentials= true;

})

.Build();

        private asyncTask StartConnection()

        {if (connection == null)

            {if (!Cache.Instance.ContainKey("token"))

                {

                    MessageDxUtil.ShowTips("没有登录，请先登录");return;

                }var token = Cache.Instance["token"] asAuthenticateResultModel;if (token != null)

                {

                    connection= newHubConnectionBuilder()

                    .WithUrl(ChatUrl, options=>{

                        options.AccessTokenProvider= () =>Task.FromResult(token.AccessToken);

                        options.UseDefaultCredentials= true;

                    })

                    .Build();//connection.HandshakeTimeout = new TimeSpan(8000);//握手过期时间//收到消息的处理
                    connection.On<string>("MessageReceived", (str) =>{

                        Console.WriteLine(str);this.richTextBox.AppendText(str);this.richTextBox.AppendText("\r\n");this.richTextBox.ScrollToCaret();

                    });awaitconnection.StartAsync();



                    EnableConnectState(true);

                }

            }awaitTask.CompletedTask;

        }

this.messages = new List<ChatMessageDto>();//清空数据

var result = awaitChatApiCaller.Instance.GetUserChatMessages(input);if (result != null && result.Items.Count > 0)

{this.messages = result.Items.Concat(this.messages);await ChatApiCaller.Instance.MarkAllUnreadMessagesOfUserAsRead(new MarkAllUnreadMessagesOfUserAsReadInput() { TenantId = 1, UserId =currentUser.Id });

}this.richTextBox.Clear();foreach (var item in this.messages)

{var message = string.Format("User[{0}]:{1}  -{2}", item.TargetUserId, item.Message, item.CreationTime);this.richTextBox.AppendText(message);this.richTextBox.AppendText("\r\n");

}this.richTextBox.ScrollToCaret();

//当前用户id为2，发送给id为8的
var data = newSendChatMessageInput()

{

    Message= this.txtMessage.Text,

    UserId=friend.FriendUserId,

    TenantId=friend.FriendTenantId,

    UserName=friend.FriendUserName,

    TenancyName=friend.FriendTenancyName,

    ProfilePictureId=Guid.NewGuid()

};try{//调用服务chathub接口进行发送消息
    var result = await connection.InvokeAsync<string>("SendMessage", data);

    Console.WriteLine(result);if (!string.IsNullOrWhiteSpace(result))

    {

        MessageDxUtil.ShowError(result);

    }else{await GetUserChatMessages(); //刷新消息
        this.txtMessage.Text = ""; //清空输入
        this.Text = string.Format("消息发送成功:{0}", DateTime.Now.ToString());

    }

}catch(Exception ex)

{

    MessageDxUtil.ShowTips(ex.Message);

}