Compare commits
11 Commits
9050c00297
...
eb1b249869
| Author | SHA1 | Date | |
|---|---|---|---|
| eb1b249869 | |||
| b9a72b4589 | |||
| 5c63dc6e38 | |||
| 52f6af2091 | |||
| e3fbd45739 | |||
| 0fe4db5e77 | |||
| 305b8d3fd8 | |||
| df976b7b80 | |||
| b90aa50fac | |||
| 58d419ced3 | |||
| e8e964f9a0 |
+12
@@ -88,6 +88,18 @@ public class ActivateClubMembershipCommandHandler : IRequestHandler<ActivateClub
|
||||
);
|
||||
}
|
||||
|
||||
// 3.5. بررسی وضعیت کیفپول جادویی — اگر در حالت Magic است، فعالسازی مجاز نیست
|
||||
if (wallet.WalletMode == WalletMode.Magic)
|
||||
{
|
||||
_logger.LogWarning(
|
||||
"User {UserId} cannot activate club while in Magic wallet mode",
|
||||
request.UserId
|
||||
);
|
||||
throw new BadRequestException(
|
||||
"ابتدا باید چرخه کیفپول جادویی تکمیل شود"
|
||||
);
|
||||
}
|
||||
|
||||
// 4. پیدا کردن UserOrder با PackageId
|
||||
var packageOrder = await _context.UserOrders
|
||||
.Include(o => o.Transaction)
|
||||
|
||||
+11
@@ -72,6 +72,17 @@ public class CheckAndProcessDayaLoansCommandHandler : IRequestHandler<CheckAndPr
|
||||
|
||||
result.UserId = user.Id;
|
||||
|
||||
// 2.5. بررسی محدودیت دایا — پس از اولین دور، فقط IPG مجاز است
|
||||
var hasPreviousCycle = await _context.ClubMembershipCycles
|
||||
.AnyAsync(c => c.UserId == user.Id, cancellationToken);
|
||||
|
||||
if (hasPreviousCycle)
|
||||
{
|
||||
result.Message = "کاربرانی که دور اول را تکمیل کردهاند فقط از طریق درگاه بانکی میتوانند پکیج خریداری کنند";
|
||||
results.Add(result);
|
||||
continue;
|
||||
}
|
||||
|
||||
// 3. ذخیره/بهروزرسانی DayaLoanContract
|
||||
var contract = await _context.DayaLoanContracts
|
||||
.FirstOrDefaultAsync(d => d.NationalCode == dayaResult.NationalCode, cancellationToken);
|
||||
|
||||
+5
-1
@@ -1,7 +1,7 @@
|
||||
namespace CMSMicroservice.Application.InventoryItemCQ.Commands.ReduceInventory;
|
||||
|
||||
/// <summary>
|
||||
/// Command برای کم کردن موجودی (فروش)
|
||||
/// Command برای کم کردن موجودی (فروش، خسارت، مفقودی و ...)
|
||||
/// </summary>
|
||||
public record ReduceInventoryCommand : IRequest<ReduceInventoryResponseDto>
|
||||
{
|
||||
@@ -19,4 +19,8 @@ public record ReduceInventoryCommand : IRequest<ReduceInventoryResponseDto>
|
||||
public long? PerformedByUserId { get; init; }
|
||||
/// <summary>آیا از موجودی رزرو شده کم شود؟</summary>
|
||||
public bool FromReserved { get; init; } = true;
|
||||
/// <summary>نوع حرکت انبار (پیشفرض: فروش)</summary>
|
||||
public Domain.Enums.StockMovementType MovementType { get; init; } = Domain.Enums.StockMovementType.Sale;
|
||||
/// <summary>توضیحات</summary>
|
||||
public string? Note { get; init; }
|
||||
}
|
||||
|
||||
+3
-3
@@ -53,11 +53,11 @@ public class ReduceInventoryCommandHandler : IRequestHandler<ReduceInventoryComm
|
||||
var stockMovement = new StockMovement
|
||||
{
|
||||
InventoryItemId = item.Id,
|
||||
MovementType = StockMovementType.Sale,
|
||||
Quantity = request.Quantity,
|
||||
MovementType = request.MovementType,
|
||||
Quantity = -request.Quantity, // منفی — CHECK constraint: QuantityAfter = QuantityBefore + Quantity
|
||||
QuantityBefore = previousQuantity,
|
||||
QuantityAfter = item.Quantity,
|
||||
Note = "Sale confirmed",
|
||||
Note = request.Note ?? request.MovementType.ToString(),
|
||||
ReferenceNumber = request.ReferenceNumber ?? $"SALE-{DateTime.UtcNow:yyyyMMddHHmmss}",
|
||||
OrderId = request.OrderId,
|
||||
DiscountOrderId = request.DiscountOrderId,
|
||||
|
||||
@@ -0,0 +1,126 @@
|
||||
using CMSMicroservice.Application.Common.Interfaces;
|
||||
using CMSMicroservice.Domain.Entities.Club;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Microsoft.Extensions.DependencyInjection;
|
||||
using Microsoft.Extensions.Hosting;
|
||||
using Microsoft.Extensions.Logging;
|
||||
|
||||
namespace CMSMicroservice.Infrastructure.BackgroundServices;
|
||||
|
||||
/// <summary>
|
||||
/// سرویس یکباره برای Seed کردن ClubMembershipCycle برای عضویتهای فعال موجود.
|
||||
/// عضویتهایی که قبل از اضافه شدن سیستم Cycle ایجاد شدهاند رکورد ندارند.
|
||||
/// این Worker در استارتاپ اجرا شده، برای آنها CycleNumber=1 میسازد و سپس متوقف میشود.
|
||||
///
|
||||
/// فعال/غیرفعال از appsettings:
|
||||
/// "SeedWorkers": { "MagicWalletCycleSeed": { "Enabled": true } }
|
||||
///
|
||||
/// بعد از اجرای موفق، Enabled را false کنید.
|
||||
/// </summary>
|
||||
public class MagicWalletCycleSeedService : BackgroundService
|
||||
{
|
||||
private readonly IServiceScopeFactory _scopeFactory;
|
||||
private readonly ILogger<MagicWalletCycleSeedService> _logger;
|
||||
|
||||
public MagicWalletCycleSeedService(
|
||||
IServiceScopeFactory scopeFactory,
|
||||
ILogger<MagicWalletCycleSeedService> logger)
|
||||
{
|
||||
_scopeFactory = scopeFactory;
|
||||
_logger = logger;
|
||||
}
|
||||
|
||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
// صبر کوتاه برای اطمینان از آماده شدن دیتابیس
|
||||
await Task.Delay(TimeSpan.FromSeconds(15), stoppingToken);
|
||||
|
||||
_logger.LogInformation("MagicWalletCycleSeedService started — scanning active memberships without cycles...");
|
||||
|
||||
try
|
||||
{
|
||||
using var scope = _scopeFactory.CreateScope();
|
||||
var context = scope.ServiceProvider.GetRequiredService<IApplicationDbContext>();
|
||||
|
||||
var seededCount = await SeedMissingCycles(context, stoppingToken);
|
||||
|
||||
_logger.LogInformation(
|
||||
"MagicWalletCycleSeedService completed — seeded {Count} ClubMembershipCycle records",
|
||||
seededCount);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogError(ex, "MagicWalletCycleSeedService encountered an error");
|
||||
}
|
||||
|
||||
_logger.LogInformation(
|
||||
"MagicWalletCycleSeedService finished — shutting down (one-time execution). " +
|
||||
"Set SeedWorkers:MagicWalletCycleSeed:Enabled to false in appsettings.");
|
||||
}
|
||||
|
||||
private async Task<int> SeedMissingCycles(IApplicationDbContext context, CancellationToken ct)
|
||||
{
|
||||
// پیدا کردن عضویتهای فعالی که هنوز Cycle ندارند
|
||||
var membershipIdsWithCycle = await context.ClubMembershipCycles
|
||||
.Where(c => !c.IsDeleted)
|
||||
.Select(c => c.ClubMembershipId)
|
||||
.Distinct()
|
||||
.ToListAsync(ct);
|
||||
|
||||
var membershipsWithoutCycle = await context.ClubMemberships
|
||||
.Where(cm => !cm.IsDeleted && cm.IsActive && !membershipIdsWithCycle.Contains(cm.Id))
|
||||
.Select(cm => new
|
||||
{
|
||||
cm.Id,
|
||||
cm.UserId,
|
||||
cm.ActivatedAt
|
||||
})
|
||||
.ToListAsync(ct);
|
||||
|
||||
if (membershipsWithoutCycle.Count == 0)
|
||||
{
|
||||
_logger.LogInformation("No active memberships without cycles found — nothing to seed");
|
||||
return 0;
|
||||
}
|
||||
|
||||
_logger.LogInformation("Found {Count} active memberships without ClubMembershipCycle — seeding...",
|
||||
membershipsWithoutCycle.Count);
|
||||
|
||||
var seeded = 0;
|
||||
foreach (var cm in membershipsWithoutCycle)
|
||||
{
|
||||
if (ct.IsCancellationRequested) break;
|
||||
|
||||
try
|
||||
{
|
||||
var cycle = new ClubMembershipCycle
|
||||
{
|
||||
UserId = cm.UserId,
|
||||
ClubMembershipId = cm.Id,
|
||||
CycleNumber = 1,
|
||||
PackagePurchasedAt = cm.ActivatedAt ?? DateTime.UtcNow,
|
||||
IsCurrentCycle = true,
|
||||
PurchaseMethod = 0,
|
||||
PackageAmount = 0
|
||||
};
|
||||
|
||||
context.ClubMembershipCycles.Add(cycle);
|
||||
seeded++;
|
||||
|
||||
_logger.LogDebug(
|
||||
"Seeded ClubMembershipCycle for UserId={UserId}, MembershipId={MembershipId}, ActivatedAt={ActivatedAt}",
|
||||
cm.UserId, cm.Id, cm.ActivatedAt);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogWarning(ex,
|
||||
"Failed to seed cycle for MembershipId={MembershipId}, UserId={UserId}",
|
||||
cm.Id, cm.UserId);
|
||||
}
|
||||
}
|
||||
|
||||
await context.SaveChangesAsync(ct);
|
||||
|
||||
return seeded;
|
||||
}
|
||||
}
|
||||
@@ -126,6 +126,10 @@ public static class ConfigureServices
|
||||
// One-time: Initialize inventory records for existing products
|
||||
services.AddHostedService<InventoryInitializerService>();
|
||||
|
||||
// One-time: Seed ClubMembershipCycle for existing active memberships
|
||||
if (configuration.GetValue<bool>("SeedWorkers:MagicWalletCycleSeed:Enabled"))
|
||||
services.AddHostedService<MagicWalletCycleSeedService>();
|
||||
|
||||
if (configuration.GetValue<bool>("UseInMemoryDatabase"))
|
||||
{
|
||||
services.AddDbContext<ApplicationDbContext>(options =>
|
||||
|
||||
+1
-2
@@ -26,8 +26,7 @@ public class DiscountProductConfiguration : IEntityTypeConfiguration<DiscountPro
|
||||
.HasMaxLength(500);
|
||||
|
||||
builder.Property(entity => entity.FullInformation)
|
||||
.IsRequired()
|
||||
.HasMaxLength(2000);
|
||||
.IsRequired();
|
||||
|
||||
builder.Property(entity => entity.Price)
|
||||
.IsRequired();
|
||||
|
||||
+4781
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,145 @@
|
||||
using System;
|
||||
using Microsoft.EntityFrameworkCore.Migrations;
|
||||
|
||||
#nullable disable
|
||||
|
||||
namespace CMSMicroservice.Infrastructure.Persistence.Migrations
|
||||
{
|
||||
/// <inheritdoc />
|
||||
public partial class u21 : Migration
|
||||
{
|
||||
/// <inheritdoc />
|
||||
protected override void Up(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.AddColumn<DateTime>(
|
||||
name: "MagicActivatedAt",
|
||||
schema: "CMS",
|
||||
table: "UserWallets",
|
||||
type: "datetime2",
|
||||
nullable: true);
|
||||
|
||||
migrationBuilder.AddColumn<DateTime>(
|
||||
name: "MagicCompletedAt",
|
||||
schema: "CMS",
|
||||
table: "UserWallets",
|
||||
type: "datetime2",
|
||||
nullable: true);
|
||||
|
||||
migrationBuilder.AddColumn<long>(
|
||||
name: "MagicTotalCredited",
|
||||
schema: "CMS",
|
||||
table: "UserWallets",
|
||||
type: "bigint",
|
||||
nullable: false,
|
||||
defaultValue: 0L);
|
||||
|
||||
migrationBuilder.AddColumn<long>(
|
||||
name: "MagicTotalDeposited",
|
||||
schema: "CMS",
|
||||
table: "UserWallets",
|
||||
type: "bigint",
|
||||
nullable: false,
|
||||
defaultValue: 0L);
|
||||
|
||||
migrationBuilder.AddColumn<int>(
|
||||
name: "WalletMode",
|
||||
schema: "CMS",
|
||||
table: "UserWallets",
|
||||
type: "int",
|
||||
nullable: false,
|
||||
defaultValue: 0);
|
||||
|
||||
migrationBuilder.CreateTable(
|
||||
name: "ClubMembershipCycles",
|
||||
schema: "CMS",
|
||||
columns: table => new
|
||||
{
|
||||
Id = table.Column<long>(type: "bigint", nullable: false)
|
||||
.Annotation("SqlServer:Identity", "1, 1"),
|
||||
UserId = table.Column<long>(type: "bigint", nullable: false),
|
||||
ClubMembershipId = table.Column<long>(type: "bigint", nullable: false),
|
||||
CycleNumber = table.Column<int>(type: "int", nullable: false),
|
||||
PackagePurchasedAt = table.Column<DateTime>(type: "datetime2", nullable: false),
|
||||
MagicStartedAt = table.Column<DateTime>(type: "datetime2", nullable: true),
|
||||
MagicCompletedAt = table.Column<DateTime>(type: "datetime2", nullable: true),
|
||||
PurchaseMethod = table.Column<int>(type: "int", nullable: false),
|
||||
PackageAmount = table.Column<long>(type: "bigint", nullable: false),
|
||||
IsCurrentCycle = table.Column<bool>(type: "bit", nullable: false, defaultValue: false),
|
||||
Created = table.Column<DateTime>(type: "datetime2", nullable: false),
|
||||
CreatedBy = table.Column<string>(type: "nvarchar(max)", nullable: true),
|
||||
LastModified = table.Column<DateTime>(type: "datetime2", nullable: true),
|
||||
LastModifiedBy = table.Column<string>(type: "nvarchar(max)", nullable: true),
|
||||
IsDeleted = table.Column<bool>(type: "bit", nullable: false)
|
||||
},
|
||||
constraints: table =>
|
||||
{
|
||||
table.PrimaryKey("PK_ClubMembershipCycles", x => x.Id);
|
||||
table.ForeignKey(
|
||||
name: "FK_ClubMembershipCycles_ClubMemberships_ClubMembershipId",
|
||||
column: x => x.ClubMembershipId,
|
||||
principalSchema: "CMS",
|
||||
principalTable: "ClubMemberships",
|
||||
principalColumn: "Id",
|
||||
onDelete: ReferentialAction.Restrict);
|
||||
table.ForeignKey(
|
||||
name: "FK_ClubMembershipCycles_Users_UserId",
|
||||
column: x => x.UserId,
|
||||
principalSchema: "CMS",
|
||||
principalTable: "Users",
|
||||
principalColumn: "Id",
|
||||
onDelete: ReferentialAction.Restrict);
|
||||
});
|
||||
|
||||
migrationBuilder.CreateIndex(
|
||||
name: "IX_ClubMembershipCycle_PackagePurchasedAt",
|
||||
schema: "CMS",
|
||||
table: "ClubMembershipCycles",
|
||||
column: "PackagePurchasedAt");
|
||||
|
||||
migrationBuilder.CreateIndex(
|
||||
name: "IX_ClubMembershipCycle_UserId_IsCurrentCycle",
|
||||
schema: "CMS",
|
||||
table: "ClubMembershipCycles",
|
||||
columns: new[] { "UserId", "IsCurrentCycle" });
|
||||
|
||||
migrationBuilder.CreateIndex(
|
||||
name: "IX_ClubMembershipCycles_ClubMembershipId",
|
||||
schema: "CMS",
|
||||
table: "ClubMembershipCycles",
|
||||
column: "ClubMembershipId");
|
||||
}
|
||||
|
||||
/// <inheritdoc />
|
||||
protected override void Down(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.DropTable(
|
||||
name: "ClubMembershipCycles",
|
||||
schema: "CMS");
|
||||
|
||||
migrationBuilder.DropColumn(
|
||||
name: "MagicActivatedAt",
|
||||
schema: "CMS",
|
||||
table: "UserWallets");
|
||||
|
||||
migrationBuilder.DropColumn(
|
||||
name: "MagicCompletedAt",
|
||||
schema: "CMS",
|
||||
table: "UserWallets");
|
||||
|
||||
migrationBuilder.DropColumn(
|
||||
name: "MagicTotalCredited",
|
||||
schema: "CMS",
|
||||
table: "UserWallets");
|
||||
|
||||
migrationBuilder.DropColumn(
|
||||
name: "MagicTotalDeposited",
|
||||
schema: "CMS",
|
||||
table: "UserWallets");
|
||||
|
||||
migrationBuilder.DropColumn(
|
||||
name: "WalletMode",
|
||||
schema: "CMS",
|
||||
table: "UserWallets");
|
||||
}
|
||||
}
|
||||
}
|
||||
+4780
File diff suppressed because it is too large
Load Diff
+38
@@ -0,0 +1,38 @@
|
||||
using Microsoft.EntityFrameworkCore.Migrations;
|
||||
|
||||
#nullable disable
|
||||
|
||||
namespace CMSMicroservice.Infrastructure.Persistence.Migrations
|
||||
{
|
||||
/// <inheritdoc />
|
||||
public partial class ExpandDiscountProductFullInformation : Migration
|
||||
{
|
||||
/// <inheritdoc />
|
||||
protected override void Up(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.AlterColumn<string>(
|
||||
name: "FullInformation",
|
||||
schema: "CMS",
|
||||
table: "DiscountProducts",
|
||||
type: "nvarchar(max)",
|
||||
nullable: false,
|
||||
oldClrType: typeof(string),
|
||||
oldType: "nvarchar(2000)",
|
||||
oldMaxLength: 2000);
|
||||
}
|
||||
|
||||
/// <inheritdoc />
|
||||
protected override void Down(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.AlterColumn<string>(
|
||||
name: "FullInformation",
|
||||
schema: "CMS",
|
||||
table: "DiscountProducts",
|
||||
type: "nvarchar(2000)",
|
||||
maxLength: 2000,
|
||||
nullable: false,
|
||||
oldClrType: typeof(string),
|
||||
oldType: "nvarchar(max)");
|
||||
}
|
||||
}
|
||||
}
|
||||
+108
-2
@@ -439,6 +439,71 @@ namespace CMSMicroservice.Infrastructure.Persistence.Migrations
|
||||
b.ToTable("ClubMemberships", "CMS");
|
||||
});
|
||||
|
||||
modelBuilder.Entity("CMSMicroservice.Domain.Entities.Club.ClubMembershipCycle", b =>
|
||||
{
|
||||
b.Property<long>("Id")
|
||||
.ValueGeneratedOnAdd()
|
||||
.HasColumnType("bigint");
|
||||
|
||||
SqlServerPropertyBuilderExtensions.UseIdentityColumn(b.Property<long>("Id"));
|
||||
|
||||
b.Property<long>("ClubMembershipId")
|
||||
.HasColumnType("bigint");
|
||||
|
||||
b.Property<DateTime>("Created")
|
||||
.HasColumnType("datetime2");
|
||||
|
||||
b.Property<string>("CreatedBy")
|
||||
.HasColumnType("nvarchar(max)");
|
||||
|
||||
b.Property<int>("CycleNumber")
|
||||
.HasColumnType("int");
|
||||
|
||||
b.Property<bool>("IsCurrentCycle")
|
||||
.ValueGeneratedOnAdd()
|
||||
.HasColumnType("bit")
|
||||
.HasDefaultValue(false);
|
||||
|
||||
b.Property<bool>("IsDeleted")
|
||||
.HasColumnType("bit");
|
||||
|
||||
b.Property<DateTime?>("LastModified")
|
||||
.HasColumnType("datetime2");
|
||||
|
||||
b.Property<string>("LastModifiedBy")
|
||||
.HasColumnType("nvarchar(max)");
|
||||
|
||||
b.Property<DateTime?>("MagicCompletedAt")
|
||||
.HasColumnType("datetime2");
|
||||
|
||||
b.Property<DateTime?>("MagicStartedAt")
|
||||
.HasColumnType("datetime2");
|
||||
|
||||
b.Property<long>("PackageAmount")
|
||||
.HasColumnType("bigint");
|
||||
|
||||
b.Property<DateTime>("PackagePurchasedAt")
|
||||
.HasColumnType("datetime2");
|
||||
|
||||
b.Property<int>("PurchaseMethod")
|
||||
.HasColumnType("int");
|
||||
|
||||
b.Property<long>("UserId")
|
||||
.HasColumnType("bigint");
|
||||
|
||||
b.HasKey("Id");
|
||||
|
||||
b.HasIndex("ClubMembershipId");
|
||||
|
||||
b.HasIndex("PackagePurchasedAt")
|
||||
.HasDatabaseName("IX_ClubMembershipCycle_PackagePurchasedAt");
|
||||
|
||||
b.HasIndex("UserId", "IsCurrentCycle")
|
||||
.HasDatabaseName("IX_ClubMembershipCycle_UserId_IsCurrentCycle");
|
||||
|
||||
b.ToTable("ClubMembershipCycles", "CMS");
|
||||
});
|
||||
|
||||
modelBuilder.Entity("CMSMicroservice.Domain.Entities.Club.UserClubFeature", b =>
|
||||
{
|
||||
b.Property<long>("Id")
|
||||
@@ -1339,8 +1404,7 @@ namespace CMSMicroservice.Infrastructure.Persistence.Migrations
|
||||
|
||||
b.Property<string>("FullInformation")
|
||||
.IsRequired()
|
||||
.HasMaxLength(2000)
|
||||
.HasColumnType("nvarchar(2000)");
|
||||
.HasColumnType("nvarchar(max)");
|
||||
|
||||
b.Property<string>("ImagePath")
|
||||
.IsRequired()
|
||||
@@ -3576,12 +3640,33 @@ namespace CMSMicroservice.Infrastructure.Persistence.Migrations
|
||||
b.Property<string>("LastModifiedBy")
|
||||
.HasColumnType("nvarchar(max)");
|
||||
|
||||
b.Property<DateTime?>("MagicActivatedAt")
|
||||
.HasColumnType("datetime2");
|
||||
|
||||
b.Property<DateTime?>("MagicCompletedAt")
|
||||
.HasColumnType("datetime2");
|
||||
|
||||
b.Property<long>("MagicTotalCredited")
|
||||
.ValueGeneratedOnAdd()
|
||||
.HasColumnType("bigint")
|
||||
.HasDefaultValue(0L);
|
||||
|
||||
b.Property<long>("MagicTotalDeposited")
|
||||
.ValueGeneratedOnAdd()
|
||||
.HasColumnType("bigint")
|
||||
.HasDefaultValue(0L);
|
||||
|
||||
b.Property<long>("NetworkBalance")
|
||||
.HasColumnType("bigint");
|
||||
|
||||
b.Property<long>("UserId")
|
||||
.HasColumnType("bigint");
|
||||
|
||||
b.Property<int>("WalletMode")
|
||||
.ValueGeneratedOnAdd()
|
||||
.HasColumnType("int")
|
||||
.HasDefaultValue(0);
|
||||
|
||||
b.HasKey("Id");
|
||||
|
||||
b.HasIndex("UserId");
|
||||
@@ -3871,6 +3956,25 @@ namespace CMSMicroservice.Infrastructure.Persistence.Migrations
|
||||
b.Navigation("User");
|
||||
});
|
||||
|
||||
modelBuilder.Entity("CMSMicroservice.Domain.Entities.Club.ClubMembershipCycle", b =>
|
||||
{
|
||||
b.HasOne("CMSMicroservice.Domain.Entities.Club.ClubMembership", "ClubMembership")
|
||||
.WithMany("Cycles")
|
||||
.HasForeignKey("ClubMembershipId")
|
||||
.OnDelete(DeleteBehavior.Restrict)
|
||||
.IsRequired();
|
||||
|
||||
b.HasOne("CMSMicroservice.Domain.Entities.User", "User")
|
||||
.WithMany()
|
||||
.HasForeignKey("UserId")
|
||||
.OnDelete(DeleteBehavior.Restrict)
|
||||
.IsRequired();
|
||||
|
||||
b.Navigation("ClubMembership");
|
||||
|
||||
b.Navigation("User");
|
||||
});
|
||||
|
||||
modelBuilder.Entity("CMSMicroservice.Domain.Entities.Club.UserClubFeature", b =>
|
||||
{
|
||||
b.HasOne("CMSMicroservice.Domain.Entities.Club.ClubFeature", "ClubFeature")
|
||||
@@ -4496,6 +4600,8 @@ namespace CMSMicroservice.Infrastructure.Persistence.Migrations
|
||||
{
|
||||
b.Navigation("ClubMembershipHistories");
|
||||
|
||||
b.Navigation("Cycles");
|
||||
|
||||
b.Navigation("UserClubFeatures");
|
||||
});
|
||||
|
||||
|
||||
@@ -3,7 +3,7 @@
|
||||
<TargetFramework>net9.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
<Version>0.0.181</Version>
|
||||
<Version>0.0.183</Version>
|
||||
<DebugType>None</DebugType>
|
||||
<DebugSymbols>False</DebugSymbols>
|
||||
<GeneratePackageOnBuild>False</GeneratePackageOnBuild>
|
||||
|
||||
@@ -88,6 +88,15 @@ service UserWalletContract
|
||||
get: "/Customer/GetMagicWalletStatus"
|
||||
};
|
||||
};
|
||||
|
||||
// ============= Discount Wallet Methods =============
|
||||
|
||||
rpc InitiateDiscountCharge(InitiateDiscountChargeRequest) returns (InitiateDiscountChargeResponse){
|
||||
option (google.api.http) = {
|
||||
post: "/Customer/InitiateDiscountCharge"
|
||||
body: "*"
|
||||
};
|
||||
};
|
||||
}
|
||||
message CreateNewUserWalletRequest
|
||||
{
|
||||
@@ -145,6 +154,7 @@ message GetAllUserWalletByFilterResponseModel
|
||||
int64 user_id = 2;
|
||||
int64 balance = 3;
|
||||
int64 network_balance = 4;
|
||||
string user_name = 5;
|
||||
}
|
||||
|
||||
// ============= Customer-specific Messages =============
|
||||
@@ -240,4 +250,19 @@ message GetMagicWalletStatusResponse
|
||||
int64 magic_remaining_deposit = 5;
|
||||
int64 balance = 6;
|
||||
google.protobuf.Timestamp magic_activated_at = 7;
|
||||
int32 purchase_cycle_count = 8; // تعداد دورهای خرید پکیج (0 = هنوز هیچ دوری تکمیل نشده)
|
||||
}
|
||||
|
||||
// ============= Discount Wallet Messages =============
|
||||
|
||||
message InitiateDiscountChargeRequest
|
||||
{
|
||||
int64 amount = 1; // مبلغ واریزی (ریال)
|
||||
}
|
||||
|
||||
message InitiateDiscountChargeResponse
|
||||
{
|
||||
bool is_success = 1;
|
||||
string gateway_url = 2;
|
||||
string error_message = 3;
|
||||
}
|
||||
@@ -1,5 +1,6 @@
|
||||
using CMSMicroservice.Application.Common.Interfaces;
|
||||
using CMSMicroservice.Application.DiscountShopCQ.Commands.CompleteOrderPayment;
|
||||
using CMSMicroservice.Application.WalletCQ.Commands.VerifyDiscountWalletCharge;
|
||||
using CMSMicroservice.Application.WalletCQ.Commands.VerifyMagicWalletCharge;
|
||||
using MediatR;
|
||||
using Microsoft.AspNetCore.Authorization;
|
||||
@@ -186,4 +187,63 @@ public class PaymentCallbackController : ControllerBase
|
||||
return Redirect($"{frontOfficeBaseUrl}/magic-wallet?payment=failed");
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Callback برای شارژ کیفپول تخفیفی — زرینپال بعد از پرداخت کاربر را اینجا برمیگرداند
|
||||
/// </summary>
|
||||
[HttpGet("/api/wallet/verify-discount-charge")]
|
||||
public async Task<IActionResult> DiscountChargeCallback(
|
||||
[FromQuery(Name = "Authority")] string? authority,
|
||||
[FromQuery(Name = "Status")] string? status,
|
||||
CancellationToken cancellationToken)
|
||||
{
|
||||
var frontOfficeBaseUrl = _configuration["FrontOfficeBaseUrl"] ?? "https://localhost:5268";
|
||||
|
||||
_logger.LogInformation(
|
||||
"Discount charge callback received: Authority={Authority}, Status={Status}",
|
||||
authority, status);
|
||||
|
||||
try
|
||||
{
|
||||
if (string.IsNullOrEmpty(authority))
|
||||
{
|
||||
_logger.LogError("Discount charge callback: Authority is missing");
|
||||
return Redirect($"{frontOfficeBaseUrl}/profile/charge-discount-wallet?payment=error&reason=no-authority");
|
||||
}
|
||||
|
||||
// پیدا کردن PaymentTransaction برای استخراج UserId و Amount
|
||||
var paymentTx = await _context.PaymentTransactions
|
||||
.FirstOrDefaultAsync(pt => pt.Authority == authority, cancellationToken);
|
||||
|
||||
if (paymentTx == null || !paymentTx.UserId.HasValue)
|
||||
{
|
||||
_logger.LogError("Discount charge callback: PaymentTransaction not found for Authority={Authority}", authority);
|
||||
return Redirect($"{frontOfficeBaseUrl}/profile/charge-discount-wallet?payment=error&reason=tx-not-found");
|
||||
}
|
||||
|
||||
if (!string.Equals(status, "OK", StringComparison.OrdinalIgnoreCase))
|
||||
{
|
||||
_logger.LogWarning("Discount charge cancelled by user. Authority={Authority}", authority);
|
||||
return Redirect($"{frontOfficeBaseUrl}/profile/charge-discount-wallet?payment=cancelled");
|
||||
}
|
||||
|
||||
var result = await _sender.Send(new VerifyDiscountWalletChargeCommand
|
||||
{
|
||||
UserId = paymentTx.UserId.Value,
|
||||
Amount = paymentTx.Amount,
|
||||
Authority = authority
|
||||
}, cancellationToken);
|
||||
|
||||
_logger.LogInformation(
|
||||
"Discount charge completed successfully. Authority={Authority}, UserId={UserId}",
|
||||
authority, paymentTx.UserId.Value);
|
||||
|
||||
return Redirect($"{frontOfficeBaseUrl}/profile/charge-discount-wallet?payment=success");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogError(ex, "Discount charge callback error. Authority={Authority}", authority);
|
||||
return Redirect($"{frontOfficeBaseUrl}/profile/charge-discount-wallet?payment=failed");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -181,7 +181,9 @@ public class InventoryService : InventoryContract.InventoryContractBase
|
||||
Id = inventoryItem.Id,
|
||||
Quantity = Math.Abs(difference),
|
||||
FromReserved = false,
|
||||
ReferenceNumber = request.ReferenceNumber
|
||||
ReferenceNumber = request.ReferenceNumber,
|
||||
MovementType = Domain.Enums.StockMovementType.AdjustmentMinus,
|
||||
Note = "Stock adjustment (decrease)"
|
||||
},
|
||||
context.CancellationToken);
|
||||
|
||||
@@ -332,7 +334,9 @@ public class InventoryService : InventoryContract.InventoryContractBase
|
||||
Id = inventoryItem.Id,
|
||||
Quantity = request.Quantity,
|
||||
FromReserved = false,
|
||||
ReferenceNumber = request.ReferenceNumber ?? $"LOSS-{DateTime.UtcNow:yyyyMMddHHmmss}"
|
||||
ReferenceNumber = request.ReferenceNumber ?? $"LOSS-{DateTime.UtcNow:yyyyMMddHHmmss}",
|
||||
MovementType = (Domain.Enums.StockMovementType)request.LossType,
|
||||
Note = string.IsNullOrWhiteSpace(request.Reason) ? null : request.Reason
|
||||
},
|
||||
context.CancellationToken);
|
||||
|
||||
|
||||
@@ -4,6 +4,7 @@ using CMSMicroservice.Application.UserWalletCQ.Commands.CreateNewUserWallet;
|
||||
using CMSMicroservice.Application.UserWalletCQ.Commands.UpdateUserWallet;
|
||||
using CMSMicroservice.Application.UserWalletCQ.Commands.DeleteUserWallet;
|
||||
using CMSMicroservice.Application.WalletCQ.Commands.ChargeMagicWallet;
|
||||
using CMSMicroservice.Application.WalletCQ.Commands.ChargeDiscountWallet;
|
||||
using CMSMicroservice.Application.UserWalletCQ.Queries.GetUserWallet;
|
||||
using CMSMicroservice.Application.UserWalletCQ.Queries.GetAllUserWalletByFilter;
|
||||
using CMSMicroservice.Application.UserWalletCQ.Queries.GetCustomerWalletChangeLog;
|
||||
@@ -54,7 +55,28 @@ public class UserWalletService : UserWalletContract.UserWalletContractBase
|
||||
}
|
||||
public override async Task<GetAllUserWalletByFilterResponse> GetAllUserWalletByFilter(GetAllUserWalletByFilterRequest request, ServerCallContext context)
|
||||
{
|
||||
return await _dispatchRequestToCQRS.Handle<GetAllUserWalletByFilterRequest, GetAllUserWalletByFilterQuery, GetAllUserWalletByFilterResponse>(request, context);
|
||||
var response = await _dispatchRequestToCQRS.Handle<GetAllUserWalletByFilterRequest, GetAllUserWalletByFilterQuery, GetAllUserWalletByFilterResponse>(request, context);
|
||||
|
||||
// Enrich response with user names
|
||||
if (response?.Models != null && response.Models.Any())
|
||||
{
|
||||
var userIds = response.Models.Select(m => m.UserId).Distinct().ToList();
|
||||
var users = await _context.Users
|
||||
.AsNoTracking()
|
||||
.Where(u => userIds.Contains(u.Id))
|
||||
.Select(u => new { u.Id, u.FirstName, u.LastName })
|
||||
.ToDictionaryAsync(u => u.Id, context.CancellationToken);
|
||||
|
||||
foreach (var model in response.Models)
|
||||
{
|
||||
if (users.TryGetValue(model.UserId, out var user))
|
||||
{
|
||||
model.UserName = $"{user.FirstName} {user.LastName}".Trim();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return response;
|
||||
}
|
||||
|
||||
// ============= Customer-specific Methods =============
|
||||
@@ -170,6 +192,27 @@ public class UserWalletService : UserWalletContract.UserWalletContractBase
|
||||
};
|
||||
}
|
||||
|
||||
// ============= Discount Wallet Methods =============
|
||||
|
||||
public override async Task<InitiateDiscountChargeResponse> InitiateDiscountCharge(
|
||||
InitiateDiscountChargeRequest request, ServerCallContext context)
|
||||
{
|
||||
var userId = GetCurrentUserId();
|
||||
|
||||
var result = await _sender.Send(new ChargeDiscountWalletCommand
|
||||
{
|
||||
UserId = userId,
|
||||
Amount = request.Amount
|
||||
}, context.CancellationToken);
|
||||
|
||||
return new InitiateDiscountChargeResponse
|
||||
{
|
||||
IsSuccess = result.IsSuccess,
|
||||
GatewayUrl = result.GatewayUrl ?? "",
|
||||
ErrorMessage = result.ErrorMessage ?? ""
|
||||
};
|
||||
}
|
||||
|
||||
public override async Task<GetMagicWalletStatusResponse> GetMagicWalletStatus(
|
||||
Google.Protobuf.WellKnownTypes.Empty request, ServerCallContext context)
|
||||
{
|
||||
@@ -181,6 +224,9 @@ public class UserWalletService : UserWalletContract.UserWalletContractBase
|
||||
if (wallet == null)
|
||||
throw new RpcException(new Status(StatusCode.NotFound, "کیف پول یافت نشد"));
|
||||
|
||||
var cycleCount = await _context.ClubMembershipCycles
|
||||
.CountAsync(c => c.UserId == userId, context.CancellationToken);
|
||||
|
||||
var response = new GetMagicWalletStatusResponse
|
||||
{
|
||||
WalletMode = (int)wallet.WalletMode,
|
||||
@@ -188,7 +234,8 @@ public class UserWalletService : UserWalletContract.UserWalletContractBase
|
||||
MagicTotalCredited = wallet.MagicTotalCredited,
|
||||
MagicMaxDeposit = SystemConstants.MagicWalletMaxDeposit,
|
||||
MagicRemainingDeposit = Math.Max(0, SystemConstants.MagicWalletMaxDeposit - wallet.MagicTotalDeposited),
|
||||
Balance = wallet.Balance
|
||||
Balance = wallet.Balance,
|
||||
PurchaseCycleCount = cycleCount
|
||||
};
|
||||
|
||||
if (wallet.MagicActivatedAt.HasValue)
|
||||
|
||||
@@ -1,12 +1,11 @@
|
||||
{
|
||||
"PaymentProvider": "zarinpal",
|
||||
"ZarinPal": {
|
||||
"MerchantId": "6b098fc8-f490-47a1-aac3-1de1a1b84404",
|
||||
"MerchantId": "4225d555-5fa9-4df0-9b61-1ce152cbbba8",
|
||||
"UseSandbox": false
|
||||
},
|
||||
"CmsBaseUrl": "https://cms.kbs1.ir",
|
||||
"FrontOfficeBaseUrl": "https://kbs1.ir",
|
||||
"UseRealPaymentGateway": false,
|
||||
"JwtSecurityKey": "TvlZVx5TJaHs8e9HgUdGzhGP2CIidoI444nAj+8+g7c=",
|
||||
"JwtIssuer": "https://localhost",
|
||||
"JwtAudience": "https://localhost",
|
||||
@@ -68,6 +67,11 @@
|
||||
"CronExpression": "5 0 * * 0"
|
||||
}
|
||||
},
|
||||
"SeedWorkers": {
|
||||
"MagicWalletCycleSeed": {
|
||||
"Enabled": true
|
||||
}
|
||||
},
|
||||
"AllowedHosts": "*",
|
||||
"Kestrel": {
|
||||
"EndpointDefaults": {
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
{
|
||||
"PaymentProvider": "zarinpal",
|
||||
"ZarinPal": {
|
||||
"MerchantId": "6b098fc8-f490-47a1-aac3-1de1a1b84404",
|
||||
"MerchantId": "4225d555-5fa9-4df0-9b61-1ce152cbbba8",
|
||||
"UseSandbox": true
|
||||
},
|
||||
"FMS": {
|
||||
@@ -68,6 +68,11 @@
|
||||
"CronExpression": "5 0 * * 0"
|
||||
}
|
||||
},
|
||||
"SeedWorkers": {
|
||||
"MagicWalletCycleSeed": {
|
||||
"Enabled": true
|
||||
}
|
||||
},
|
||||
"AllowedHosts": "*",
|
||||
"Kestrel": {
|
||||
"EndpointDefaults": {
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
{
|
||||
"PaymentProvider": "zarinpal",
|
||||
"ZarinPal": {
|
||||
"MerchantId": "6b098fc8-f490-47a1-aac3-1de1a1b84404",
|
||||
"MerchantId": "4225d555-5fa9-4df0-9b61-1ce152cbbba8",
|
||||
"UseSandbox": true
|
||||
},
|
||||
"CmsBaseUrl": "https://cms.kbs1.ir",
|
||||
@@ -75,6 +75,11 @@
|
||||
"CronExpression": "5 0 * * 0"
|
||||
}
|
||||
},
|
||||
"SeedWorkers": {
|
||||
"MagicWalletCycleSeed": {
|
||||
"Enabled": true
|
||||
}
|
||||
},
|
||||
"AllowedHosts": "*",
|
||||
"Authentication": {
|
||||
"Authority": "https://ids.domain.com/",
|
||||
|
||||
Reference in New Issue
Block a user