kjh2064/taxbaik
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

feat(ops): 배포 알림과 텔레그램 리포트 추가

Browse Source
This commit is contained in:
김재현
2026-06-28 18:39:28 +09:00
parent d2cfcd90f0
commit 033883aac5
10 changed files with 333 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.gitea/workflows/deploy.yml
+46 -1
View File
@@ -38,18 +38,29 @@ jobs:
JWT_SECRET_KEY="${{ secrets.TAXBAIK_JWT_SECRET_KEY }}"
TELEGRAM_BOT_TOKEN="${{ secrets.TAXBAIK_TELEGRAM_BOT_TOKEN }}"
TELEGRAM_CHAT_ID="${{ secrets.TAXBAIK_TELEGRAM_CHAT_ID }}"
TELEGRAM_INQUIRY_CHAT_ID="${{ secrets.TAXBAIK_TELEGRAM_INQUIRY_CHAT_ID }}"
TELEGRAM_SYSTEM_CHAT_ID="${{ secrets.TAXBAIK_TELEGRAM_SYSTEM_CHAT_ID }}"
[ -z "$JWT_SECRET_KEY" ] && { echo "Missing TAXBAIK_JWT_SECRET_KEY" >&2; exit 1; }
[ -z "$TELEGRAM_BOT_TOKEN" ] && { echo "Missing TAXBAIK_TELEGRAM_BOT_TOKEN" >&2; exit 1; }
[ -z "$TELEGRAM_CHAT_ID" ] && { echo "Missing TAXBAIK_TELEGRAM_CHAT_ID" >&2; exit 1; }
[ -z "$TELEGRAM_INQUIRY_CHAT_ID" ] && TELEGRAM_INQUIRY_CHAT_ID="$TELEGRAM_CHAT_ID"
[ -z "$TELEGRAM_SYSTEM_CHAT_ID" ] && TELEGRAM_SYSTEM_CHAT_ID="-5585148480"
JWT_SECRET_KEY="$JWT_SECRET_KEY" \
TELEGRAM_BOT_TOKEN="$TELEGRAM_BOT_TOKEN" \
TELEGRAM_CHAT_ID="$TELEGRAM_CHAT_ID" \
TELEGRAM_INQUIRY_CHAT_ID="$TELEGRAM_INQUIRY_CHAT_ID" \
TELEGRAM_SYSTEM_CHAT_ID="$TELEGRAM_SYSTEM_CHAT_ID" \
python3 -c '
import json, os, pathlib
pathlib.Path("./publish/appsettings.Production.json").write_text(
json.dumps({
"Jwt": {"SecretKey": os.environ["JWT_SECRET_KEY"]},
"Telegram": {"BotToken": os.environ["TELEGRAM_BOT_TOKEN"], "ChatId": os.environ["TELEGRAM_CHAT_ID"]}
"Telegram": {
"BotToken": os.environ["TELEGRAM_BOT_TOKEN"],
"ChatId": os.environ["TELEGRAM_CHAT_ID"],
"InquiryChatId": os.environ["TELEGRAM_INQUIRY_CHAT_ID"],
"SystemChatId": os.environ["TELEGRAM_SYSTEM_CHAT_ID"]
}
}, ensure_ascii=False, indent=2),
encoding="utf-8"
)'
@@ -98,6 +109,34 @@ jobs:
COMMIT=$(git rev-parse --short HEAD)
DEPLOY_HOST="${{ secrets.DEPLOY_HOST }}"
DEPLOY_USER="${{ secrets.DEPLOY_USER }}"
TELEGRAM_BOT_TOKEN="${{ secrets.TAXBAIK_TELEGRAM_BOT_TOKEN }}"
TELEGRAM_SYSTEM_CHAT_ID="${{ secrets.TAXBAIK_TELEGRAM_SYSTEM_CHAT_ID }}"
TELEGRAM_CHAT_ID="${TELEGRAM_SYSTEM_CHAT_ID:--5585148480}"
send_telegram() {
local text="$1"
if [ -z "$TELEGRAM_BOT_TOKEN" ]; then
echo "Skipping Telegram notification: missing TAXBAIK_TELEGRAM_BOT_TOKEN" >&2
return 0
fi
curl -fsS -X POST "https://api.telegram.org/bot${TELEGRAM_BOT_TOKEN}/sendMessage" \
-d "chat_id=${TELEGRAM_CHAT_ID}" \
--data-urlencode "text=${text}" \
-d "parse_mode=HTML" >/dev/null || true
}
notify_failure() {
local exit_code=$?
send_telegram "❌ <b>TaxBaik 배포 실패</b>
커밋: <code>${COMMIT}</code>
시간: <code>${TIMESTAMP}</code>
단계: CI/CD deploy"
exit "$exit_code"
}
trap notify_failure ERR
echo "=== Deploying TaxBaik $COMMIT ($TIMESTAMP) ==="
@@ -179,3 +218,9 @@ jobs:
REMOTE
echo "✓ 배포 완료: taxbaik_${TIMESTAMP} @ $DEPLOY_HOST"
send_telegram "✅ <b>TaxBaik 배포 완료</b>
커밋: <code>${COMMIT}</code>
시간: <code>${TIMESTAMP}</code>
대상: <code>${DEPLOY_HOST}</code>
채널: <code>${TELEGRAM_CHAT_ID}</code>"
TaxBaik.Application/DependencyInjection.cs
+2
View File
@@ -25,6 +25,8 @@ public static class DependencyInjection
services.AddScoped<ConsultingActivityService>();
services.AddScoped<ContractService>();
services.AddScoped<RevenueTrackingService>();
services.AddScoped<TelegramReportService>();
services.AddScoped<PortalUserService>();
return services;
}
}
TaxBaik.Application/Services/ClientService.cs
+9
View File
@@ -22,6 +22,15 @@ public class ClientService(IClientRepository repository)
public async Task<Client?> GetByIdAsync(int id, CancellationToken ct = default) =>
await repository.GetByIdAsync(id, ct);
public async Task<Client?> GetByEmailAsync(string email, CancellationToken ct = default) =>
await repository.GetByEmailAsync(email, ct);
public async Task<Client?> GetByPhoneAsync(string phone, CancellationToken ct = default) =>
await repository.GetByPhoneAsync(phone, ct);
public async Task<int> CountCreatedAtRangeAsync(DateTime startDateUtc, DateTime endDateUtc, CancellationToken ct = default) =>
await repository.CountByCreatedAtRangeAsync(startDateUtc, endDateUtc, ct);
public async Task<int> CreateAsync(CreateClientDto dto, CancellationToken ct = default)
{
if (string.IsNullOrWhiteSpace(dto.Name))
TaxBaik.Application/Services/TelegramReportService.cs
+74
View File
@@ -0,0 +1,74 @@
namespace TaxBaik.Application.Services;
public record TelegramDailyReport(
DateOnly Date,
int NewInquiries,
int PendingInquiries,
int NewClients,
int PendingTaxFilings,
int PendingPayments);
public record TelegramWeeklyReport(
DateOnly WeekStart,
DateOnly WeekEnd,
int NewInquiries,
int NewClients,
int UpcomingTaxFilings,
decimal RevenueThisWeek);
public class TelegramReportService(
InquiryService inquiryService,
ClientService clientService,
TaxFilingScheduleService taxFilingScheduleService,
RevenueTrackingService revenueTrackingService)
{
public async Task<TelegramDailyReport> BuildDailyReportAsync(DateOnly date, CancellationToken ct = default)
{
var start = date.ToDateTime(TimeOnly.MinValue, DateTimeKind.Utc);
var end = date.ToDateTime(TimeOnly.MaxValue, DateTimeKind.Utc);
return new TelegramDailyReport(
Date: date,
NewInquiries: await inquiryService.CountByDateRangeAsync(start, end, ct),
PendingInquiries: await inquiryService.CountByStatusAsync("new", ct),
NewClients: await clientService.CountCreatedAtRangeAsync(start, end, ct),
PendingTaxFilings: await taxFilingScheduleService.GetPendingCountAsync(ct),
PendingPayments: (await revenueTrackingService.GetPendingPaymentsAsync(ct)).Count());
}
public async Task<TelegramWeeklyReport> BuildWeeklyReportAsync(DateOnly weekStart, CancellationToken ct = default)
{
var weekEnd = weekStart.AddDays(6);
var start = weekStart.ToDateTime(TimeOnly.MinValue, DateTimeKind.Utc);
var end = weekEnd.ToDateTime(TimeOnly.MaxValue, DateTimeKind.Utc);
var upcomingEnd = weekEnd.AddDays(7).ToDateTime(TimeOnly.MaxValue, DateTimeKind.Utc);
var revenue = await revenueTrackingService.GetTotalRevenueAsync(start, end, ct);
return new TelegramWeeklyReport(
WeekStart: weekStart,
WeekEnd: weekEnd,
NewInquiries: await inquiryService.CountByDateRangeAsync(start, end, ct),
NewClients: await clientService.CountCreatedAtRangeAsync(start, end, ct),
UpcomingTaxFilings: (await taxFilingScheduleService.GetUpcomingDuesAsync(14, ct))
.Count(x => x.DueDate >= start && x.DueDate <= upcomingEnd),
RevenueThisWeek: revenue);
}
public static string FormatDailyMessage(TelegramDailyReport report) =>
$"<b>📊 일간 리포트</b>\n\n" +
$"기준일: <code>{report.Date:yyyy-MM-dd}</code>\n" +
$"신규 문의: <code>{report.NewInquiries}</code>\n" +
$"처리 대기 문의: <code>{report.PendingInquiries}</code>\n" +
$"신규 고객: <code>{report.NewClients}</code>\n" +
$"신고 대기: <code>{report.PendingTaxFilings}</code>\n" +
$"미수 청구: <code>{report.PendingPayments}</code>";
public static string FormatWeeklyMessage(TelegramWeeklyReport report) =>
$"<b>📈 주간 리포트</b>\n\n" +
$"기간: <code>{report.WeekStart:yyyy-MM-dd}</code> ~ <code>{report.WeekEnd:yyyy-MM-dd}</code>\n" +
$"신규 문의: <code>{report.NewInquiries}</code>\n" +
$"신규 고객: <code>{report.NewClients}</code>\n" +
$"다가오는 신고: <code>{report.UpcomingTaxFilings}</code>\n" +
$"주간 매출: <code>₩{report.RevenueThisWeek:N0}</code>";
}
TaxBaik.Domain/Interfaces/IClientRepository.cs
+3
View File
@@ -8,6 +8,9 @@ public interface IClientRepository
int page, int pageSize, string? status = null, string? search = null,
CancellationToken ct = default);
Task<Client?> GetByIdAsync(int id, CancellationToken ct = default);
Task<Client?> GetByEmailAsync(string email, CancellationToken ct = default);
Task<Client?> GetByPhoneAsync(string phone, CancellationToken ct = default);
Task<int> CountByCreatedAtRangeAsync(DateTime startDateUtc, DateTime endDateUtc, CancellationToken ct = default);
Task<int> CreateAsync(Client client, CancellationToken ct = default);
Task UpdateAsync(Client client, CancellationToken ct = default);
Task DeleteAsync(int id, CancellationToken ct = default);
TaxBaik.Infrastructure/DependencyInjection.cs
+1
View File
@@ -19,6 +19,7 @@ public static class DependencyInjection
services.AddScoped<IClientRepository, ClientRepository>();
services.AddScoped<IFaqRepository, FaqRepository>();
services.AddScoped<IConsultationRepository, ConsultationRepository>();
services.AddScoped<IPortalUserRepository, PortalUserRepository>();
services.AddScoped<ITaxFilingRepository, TaxFilingRepository>();
services.AddScoped<ICompanyRepository, CompanyRepository>();
services.AddScoped<ITaxProfileRepository, TaxProfileRepository>();
TaxBaik.Infrastructure/Repositories/ClientRepository.cs
+27
View File
@@ -40,6 +40,33 @@ public class ClientRepository(IDbConnectionFactory connectionFactory) : BaseRepo
new { Id = id });
}
public async Task<Client?> GetByEmailAsync(string email, CancellationToken ct = default)
{
using var conn = Conn();
return await conn.QueryFirstOrDefaultAsync<Client>(
$"SELECT {SelectColumns} FROM clients WHERE email = @Email",
new { Email = email });
}
public async Task<Client?> GetByPhoneAsync(string phone, CancellationToken ct = default)
{
using var conn = Conn();
return await conn.QueryFirstOrDefaultAsync<Client>(
$"SELECT {SelectColumns} FROM clients WHERE phone = @Phone",
new { Phone = phone });
}
public async Task<int> CountByCreatedAtRangeAsync(DateTime startDateUtc, DateTime endDateUtc, CancellationToken ct = default)
{
using var conn = Conn();
return await conn.ExecuteScalarAsync<int>(
@"SELECT COUNT(*)
FROM clients
WHERE created_at >= @StartDateUtc
AND created_at <= @EndDateUtc",
new { StartDateUtc = startDateUtc, EndDateUtc = endDateUtc });
}
public async Task<int> CreateAsync(Client client, CancellationToken ct = default)
{
using var conn = Conn();
TaxBaik.Web/Program.cs
+86
View File
@@ -3,6 +3,8 @@ using System.Text;
using System.Text.Encodings.Web;
using System.Text.Unicode;
using Microsoft.AspNetCore.Authentication.JwtBearer;
using Microsoft.AspNetCore.Authentication.Cookies;
using Microsoft.AspNetCore.Authentication.OAuth;
using Microsoft.AspNetCore.Components.Authorization;
using Microsoft.AspNetCore.HttpOverrides;
using Microsoft.AspNetCore.ResponseCompression;
@@ -80,6 +82,85 @@ builder.Services.AddAuthentication(opts =>
ValidateLifetime = true,
ClockSkew = TimeSpan.FromMinutes(1)
};
})
.AddCookie(PortalAuthDefaults.Scheme, opts =>
{
opts.Cookie.Name = PortalAuthDefaults.CookieName;
opts.Cookie.HttpOnly = true;
opts.Cookie.SameSite = SameSiteMode.Lax;
opts.Cookie.SecurePolicy = isProduction ? CookieSecurePolicy.Always : CookieSecurePolicy.SameAsRequest;
opts.LoginPath = "/taxbaik/portal/login";
opts.AccessDeniedPath = "/taxbaik/portal/login";
opts.SlidingExpiration = true;
opts.ExpireTimeSpan = TimeSpan.FromDays(7);
})
.AddCookie(PortalOAuthDefaults.ExternalScheme, opts =>
{
opts.Cookie.Name = "TaxBaik.Portal.External";
opts.Cookie.HttpOnly = true;
opts.Cookie.SameSite = SameSiteMode.Lax;
opts.Cookie.SecurePolicy = isProduction ? CookieSecurePolicy.Always : CookieSecurePolicy.SameAsRequest;
})
.AddGoogle(PortalOAuthDefaults.GoogleScheme, opts =>
{
opts.SignInScheme = PortalOAuthDefaults.ExternalScheme;
opts.ClientId = builder.Configuration["Authentication:Google:ClientId"] ?? "";
opts.ClientSecret = builder.Configuration["Authentication:Google:ClientSecret"] ?? "";
opts.CallbackPath = "/taxbaik/portal/signin-google";
})
.AddOAuth(PortalOAuthDefaults.NaverScheme, opts =>
{
opts.SignInScheme = PortalOAuthDefaults.ExternalScheme;
opts.ClientId = builder.Configuration["Authentication:Naver:ClientId"] ?? "";
opts.ClientSecret = builder.Configuration["Authentication:Naver:ClientSecret"] ?? "";
opts.CallbackPath = "/taxbaik/portal/signin-naver";
opts.AuthorizationEndpoint = "https://nid.naver.com/oauth2.0/authorize";
opts.TokenEndpoint = "https://nid.naver.com/oauth2.0/token";
opts.UserInformationEndpoint = "https://openapi.naver.com/v1/nid/me";
opts.SaveTokens = true;
opts.Events = new OAuthEvents
{
OnCreatingTicket = async context =>
{
var request = new HttpRequestMessage(HttpMethod.Get, opts.UserInformationEndpoint);
request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", context.AccessToken);
var response = await context.Backchannel.SendAsync(request, context.HttpContext.RequestAborted);
response.EnsureSuccessStatusCode();
using var payload = System.Text.Json.JsonDocument.Parse(await response.Content.ReadAsStringAsync(context.HttpContext.RequestAborted));
var responseRoot = payload.RootElement.GetProperty("response");
context.Identity?.AddClaim(new System.Security.Claims.Claim(System.Security.Claims.ClaimTypes.NameIdentifier, responseRoot.GetProperty("id").GetString() ?? ""));
context.Identity?.AddClaim(new System.Security.Claims.Claim(System.Security.Claims.ClaimTypes.Name, responseRoot.GetProperty("name").GetString() ?? ""));
context.Identity?.AddClaim(new System.Security.Claims.Claim(System.Security.Claims.ClaimTypes.Email, responseRoot.GetProperty("email").GetString() ?? ""));
}
};
})
.AddOAuth(PortalOAuthDefaults.KakaoScheme, opts =>
{
opts.SignInScheme = PortalOAuthDefaults.ExternalScheme;
opts.ClientId = builder.Configuration["Authentication:Kakao:ClientId"] ?? "";
opts.ClientSecret = builder.Configuration["Authentication:Kakao:ClientSecret"] ?? "";
opts.CallbackPath = "/taxbaik/portal/signin-kakao";
opts.AuthorizationEndpoint = "https://kauth.kakao.com/oauth/authorize";
opts.TokenEndpoint = "https://kauth.kakao.com/oauth/token";
opts.UserInformationEndpoint = "https://kapi.kakao.com/v2/user/me";
opts.SaveTokens = true;
opts.Events = new OAuthEvents
{
OnCreatingTicket = async context =>
{
var request = new HttpRequestMessage(HttpMethod.Get, opts.UserInformationEndpoint);
request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", context.AccessToken);
var response = await context.Backchannel.SendAsync(request, context.HttpContext.RequestAborted);
response.EnsureSuccessStatusCode();
using var payload = System.Text.Json.JsonDocument.Parse(await response.Content.ReadAsStringAsync(context.HttpContext.RequestAborted));
var kakaoAccount = payload.RootElement.GetProperty("kakao_account");
var profile = kakaoAccount.GetProperty("profile");
context.Identity?.AddClaim(new System.Security.Claims.Claim(System.Security.Claims.ClaimTypes.NameIdentifier, payload.RootElement.GetProperty("id").GetInt64().ToString()));
context.Identity?.AddClaim(new System.Security.Claims.Claim(System.Security.Claims.ClaimTypes.Name, profile.GetProperty("nickname").GetString() ?? ""));
if (kakaoAccount.TryGetProperty("email", out var emailProp))
context.Identity?.AddClaim(new System.Security.Claims.Claim(System.Security.Claims.ClaimTypes.Email, emailProp.GetString() ?? ""));
}
};
});
// Blazor 인증
@@ -178,6 +259,11 @@ builder.Services.AddResponseCompression(opts => {
opts.Providers.Add<GzipCompressionProvider>();
});
builder.Services.AddScoped<IInquiryNotificationService, TelegramInquiryNotificationService>();
builder.Services.AddHostedService<TelegramReportBackgroundService>();
builder.Services.AddHttpContextAccessor();
builder.Services.AddScoped<PortalAuthService>();
builder.Services.Configure<PortalAuthOptions>(builder.Configuration.GetSection("Authentication"));
// 한글 포함 다국어 문자를 유니코드 엔티티로 변환하지 않도록 설정
builder.Services.AddSingleton(HtmlEncoder.Create(UnicodeRanges.All));
TaxBaik.Web/Services/TelegramNotificationService.cs
+3 -3
View File
@@ -33,8 +33,8 @@ public class TelegramNotificationService : ITelegramNotificationService
_httpClient = httpClient;
_logger = logger;
_botToken = config["Telegram:BotToken"] ?? "";
_defaultChatId = config["Telegram:ChatId"] ?? "";
_inquiryChatId = config["Telegram:InquiryChatId"] ?? "-5434691215";
_defaultChatId = config["Telegram:ChatId"] ?? "-5434691215";
_inquiryChatId = config["Telegram:InquiryChatId"] ?? _defaultChatId;
_systemChatId = config["Telegram:SystemChatId"] ?? "-5585148480";
}
@@ -88,7 +88,7 @@ public class TelegramNotificationService : ITelegramNotificationService
public async Task SendErrorAsync(string title, string details, CancellationToken ct = default)
{
var message = $"<b>❌ {title}</b>\n\n{details}\n\n<i>{DateTime.UtcNow:yyyy-MM-dd HH:mm:ss} UTC</i>";
await SendMessageAsync(message, ct);
await SendToChat(_systemChatId, message, ct);
}
public async Task SendInfoAsync(string title, string message, CancellationToken ct = default)
TaxBaik.Web/Services/TelegramReportBackgroundService.cs
+82
View File
@@ -0,0 +1,82 @@
namespace TaxBaik.Web.Services;
using Microsoft.Extensions.Hosting;
using TaxBaik.Application.Services;
public class TelegramReportBackgroundService(
IServiceScopeFactory scopeFactory,
ILogger<TelegramReportBackgroundService> logger) : BackgroundService
{
private static readonly TimeZoneInfo KoreaTimeZone = GetKoreaTimeZone();
private DateOnly? _lastDailyReportDate;
private DateOnly? _lastWeeklyReportWeekStart;
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
using var timer = new PeriodicTimer(TimeSpan.FromMinutes(30));
while (await timer.WaitForNextTickAsync(stoppingToken))
{
try
{
var now = TimeZoneInfo.ConvertTime(DateTimeOffset.UtcNow, KoreaTimeZone);
await TrySendReportsAsync(now, stoppingToken);
}
catch (Exception ex)
{
logger.LogError(ex, "Telegram report background loop failed");
}
}
}
private async Task TrySendReportsAsync(DateTimeOffset nowKst, CancellationToken ct)
{
if (nowKst.Hour is 9 or 10)
await SendDailyIfNeededAsync(DateOnly.FromDateTime(nowKst.DateTime), ct);
if (nowKst.DayOfWeek == DayOfWeek.Monday && nowKst.Hour is 9 or 10)
await SendWeeklyIfNeededAsync(DateOnly.FromDateTime(nowKst.DateTime).AddDays(-7), ct);
}
private async Task SendDailyIfNeededAsync(DateOnly date, CancellationToken ct)
{
if (_lastDailyReportDate == date)
return;
using var scope = scopeFactory.CreateScope();
var reportService = scope.ServiceProvider.GetRequiredService<TelegramReportService>();
var telegram = scope.ServiceProvider.GetRequiredService<ITelegramNotificationService>();
var report = await reportService.BuildDailyReportAsync(date, ct);
await telegram.SendSystemNotificationAsync(TelegramReportService.FormatDailyMessage(report), ct);
_lastDailyReportDate = date;
logger.LogInformation("Daily telegram report sent for {Date}", date);
}
private async Task SendWeeklyIfNeededAsync(DateOnly weekStart, CancellationToken ct)
{
if (_lastWeeklyReportWeekStart == weekStart)
return;
using var scope = scopeFactory.CreateScope();
var reportService = scope.ServiceProvider.GetRequiredService<TelegramReportService>();
var telegram = scope.ServiceProvider.GetRequiredService<ITelegramNotificationService>();
var report = await reportService.BuildWeeklyReportAsync(weekStart, ct);
await telegram.SendSystemNotificationAsync(TelegramReportService.FormatWeeklyMessage(report), ct);
_lastWeeklyReportWeekStart = weekStart;
logger.LogInformation("Weekly telegram report sent for {WeekStart}", weekStart);
}
private static TimeZoneInfo GetKoreaTimeZone()
{
try
{
return TimeZoneInfo.FindSystemTimeZoneById("Korea Standard Time");
}
catch (TimeZoneNotFoundException)
{
return TimeZoneInfo.FindSystemTimeZoneById("Asia/Seoul");
}
}
}