hrms-bangkok/hrms-api-backend
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 7 Wiki Activity Actions

no message
Some checks failed
release-dev / release-dev (push) Failing after 11s
Details

Browse source
This commit is contained in:
kittapath 2024-12-24 23:41:01 +07:00
parent 00e8424329
commit d88394984b
1 changed files with 117 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

139
BMA.EHR.Application/Repositories/MessageQueue/NotificationRepository.cs
View file

@ -223,7 +223,22 @@ namespace BMA.EHR.Application.Repositories.MessageQueue
} }
if (IsSendMail == true) if (IsSendMail == true)
{ {
_emailSenderService.SendMail(Subject, Body, "kittapath@frappet.com"); var apiUrl = $"{_configuration["API"]}/org/dotnet/email/{ReceiverUserId}";
using (var client = new HttpClient())
{
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken.Replace("Bearer ", ""));
client.DefaultRequestHeaders.Add("api_key", _configuration["API_KEY"]);
var _req = new HttpRequestMessage(HttpMethod.Get, apiUrl);
var _res = await client.SendAsync(_req);
var _result = await _res.Content.ReadAsStringAsync();
if (_res.IsSuccessStatusCode)
{
var org = JsonConvert.DeserializeObject<ResultRequest>(_result);
if (org != null && org.result != null)
_emailSenderService.SendMail(Subject, Body, org.result);
}
}
} }
await _dbContext.SaveChangesAsync(); await _dbContext.SaveChangesAsync();
//} //}
@ -250,25 +265,40 @@ namespace BMA.EHR.Application.Repositories.MessageQueue
LastUpdateUserId = UserId ?? "", LastUpdateUserId = UserId ?? "",
LastUpdatedAt = DateTime.Now, LastUpdatedAt = DateTime.Now,
}); });
/* if (IsSendInbox == true) /* if (IsSendInbox == true)
{ {
_dbContext.Set<Inbox>().Add(new Inbox _dbContext.Set<Inbox>().Add(new Inbox
{ {
Subject = Subject, Subject = Subject,
Body = Body, Body = Body,
ReceiverUserId = ReceiverUserId, ReceiverUserId = ReceiverUserId,
Payload = Payload, Payload = Payload,
CreatedFullName = FullName ?? "System Administrator", CreatedFullName = FullName ?? "System Administrator",
CreatedUserId = UserId ?? "", CreatedUserId = UserId ?? "",
CreatedAt = DateTime.Now, CreatedAt = DateTime.Now,
LastUpdateFullName = FullName ?? "System Administrator", LastUpdateFullName = FullName ?? "System Administrator",
LastUpdateUserId = UserId ?? "", LastUpdateUserId = UserId ?? "",
LastUpdatedAt = DateTime.Now, LastUpdatedAt = DateTime.Now,
}); });
}*/ }*/
if (IsSendMail == true) if (IsSendMail == true)
{ {
_emailSenderService.SendMail(Subject, Body, "kittapath@frappet.com"); var apiUrl = $"{_configuration["API"]}/org/dotnet/email/{ReceiverUserId}";
using (var client = new HttpClient())
{
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken.Replace("Bearer ", ""));
client.DefaultRequestHeaders.Add("api_key", _configuration["API_KEY"]);
var _req = new HttpRequestMessage(HttpMethod.Get, apiUrl);
var _res = await client.SendAsync(_req);
var _result = await _res.Content.ReadAsStringAsync();
if (_res.IsSuccessStatusCode)
{
var org = JsonConvert.DeserializeObject<ResultRequest>(_result);
if (org != null && org.result != null)
_emailSenderService.SendMail(Subject, Body, org.result);
}
}
} }
await _dbContext.SaveChangesAsync(); await _dbContext.SaveChangesAsync();
} }
@ -327,7 +357,22 @@ namespace BMA.EHR.Application.Repositories.MessageQueue
} }
if (IsSendMail == true) if (IsSendMail == true)
{ {
_emailSenderService.SendMail(Subject, Body, "kittapath@frappet.com"); var apiUrl = $"{_configuration["API"]}/org/dotnet/email/{ReceiverUserId}";
using (var client = new HttpClient())
{
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken.Replace("Bearer ", ""));
client.DefaultRequestHeaders.Add("api_key", _configuration["API_KEY"]);
var _req = new HttpRequestMessage(HttpMethod.Get, apiUrl);
var _res = await client.SendAsync(_req);
var _result = await _res.Content.ReadAsStringAsync();
if (_res.IsSuccessStatusCode)
{
var org = JsonConvert.DeserializeObject<ResultRequest>(_result);
if (org != null && org.result != null)
_emailSenderService.SendMail(Subject, Body, org.result);
}
}
} }
} }
await _dbContext.SaveChangesAsync(); await _dbContext.SaveChangesAsync();
@ -343,6 +388,11 @@ namespace BMA.EHR.Application.Repositories.MessageQueue
public Guid ReceiverUserId { get; set; } public Guid ReceiverUserId { get; set; }
public string NotiLink { get; set; } public string NotiLink { get; set; }
} }
public class ResultRequest
{
public string result { get; set; }
}
public async Task PushNotificationsLinkAsync(NotisLinkRequest[] ReceiverUserIds, string Subject, string Body, string Payload = "", bool IsSendInbox = false, bool IsSendMail = false) public async Task PushNotificationsLinkAsync(NotisLinkRequest[] ReceiverUserIds, string Subject, string Body, string Payload = "", bool IsSendInbox = false, bool IsSendMail = false)
{ {
try try
@ -380,7 +430,22 @@ namespace BMA.EHR.Application.Repositories.MessageQueue
} }
if (IsSendMail == true) if (IsSendMail == true)
{ {
_emailSenderService.SendMail(Subject, Body, "kittapath@frappet.com"); var apiUrl = $"{_configuration["API"]}/org/dotnet/email/{ReceiverUserId.ReceiverUserId}";
using (var client = new HttpClient())
{
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken.Replace("Bearer ", ""));
client.DefaultRequestHeaders.Add("api_key", _configuration["API_KEY"]);
var _req = new HttpRequestMessage(HttpMethod.Get, apiUrl);
var _res = await client.SendAsync(_req);
var _result = await _res.Content.ReadAsStringAsync();
if (_res.IsSuccessStatusCode)
{
var org = JsonConvert.DeserializeObject<ResultRequest>(_result);
if (org != null && org.result != null)
_emailSenderService.SendMail(Subject, Body, org.result);
}
}
} }
} }
await _dbContext.SaveChangesAsync(); await _dbContext.SaveChangesAsync();
@ -435,7 +500,22 @@ namespace BMA.EHR.Application.Repositories.MessageQueue
} }
if (data.IsSendMail == true) if (data.IsSendMail == true)
{ {
_emailSenderService.SendMail(Subject, Body, "kittapath@frappet.com"); var apiUrl = $"{_configuration["API"]}/org/dotnet/email/{data.ReceiverUserId}";
using (var client = new HttpClient())
{
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken.Replace("Bearer ", ""));
client.DefaultRequestHeaders.Add("api_key", _configuration["API_KEY"]);
var _req = new HttpRequestMessage(HttpMethod.Get, apiUrl);
var _res = await client.SendAsync(_req);
var _result = await _res.Content.ReadAsStringAsync();
if (_res.IsSuccessStatusCode)
{
var org = JsonConvert.DeserializeObject<ResultRequest>(_result);
if (org != null && org.result != null)
_emailSenderService.SendMail(Subject, Body, org.result);
}
}
} }
} }
await _dbContext.SaveChangesAsync(); await _dbContext.SaveChangesAsync();
@ -482,7 +562,22 @@ namespace BMA.EHR.Application.Repositories.MessageQueue
} }
if (IsSendMail == true) if (IsSendMail == true)
{ {
_emailSenderService.SendMail(Subject, Body, "kittapath@frappet.com"); var apiUrl = $"{_configuration["API"]}/org/dotnet/email/{ReceiverUserId}";
using (var client = new HttpClient())
{
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken.Replace("Bearer ", ""));
client.DefaultRequestHeaders.Add("api_key", _configuration["API_KEY"]);
var _req = new HttpRequestMessage(HttpMethod.Get, apiUrl);
var _res = await client.SendAsync(_req);
var _result = await _res.Content.ReadAsStringAsync();
if (_res.IsSuccessStatusCode)
{
var org = JsonConvert.DeserializeObject<ResultRequest>(_result);
if (org != null && org.result != null)
_emailSenderService.SendMail(Subject, Body, org.result);
}
}
} }
await _dbContext.SaveChangesAsync(); await _dbContext.SaveChangesAsync();
} }