[백한결] 판매금액 정산 배치

template/package/package.typeorm.json → package.json

@@ -24,6 +24,7 @@
     "@nestjs/config": "^3.1.1",
     "@nestjs/core": "^10.0.0",
     "@nestjs/platform-express": "^10.0.0",
+    "@nestjs/schedule": "^4.0.2",
     "@nestjs/swagger": "^7.1.13",
     "@nestjs/typeorm": "^10.0.0",
     "class-transformer": "^0.5.1",

src/orders/order.entity.ts

@@ -0,0 +1,30 @@
+import { Column, Entity, PrimaryGeneratedColumn } from "typeorm";
+
+export enum OrderStatus {
+    PaymentComplete = "결제완료",
+    Shipping = "배송중",
+    Delivered = "배송완료",
+    PurchaseConfirmed = "구매확정",
+    Cancelled = "취소"
+}
+
+@Entity()
+export class Order {
+    @PrimaryGeneratedColumn()
+    id: number;
+
+    @Column()
+    sellerId: number;
+
+    @Column('decimal')
+    amount: number;
+
+    @Column({
+        type: 'enum',
+        enum: OrderStatus,
+    })
+    status: OrderStatus;
+
+    @Column({ nullable: true, type: 'timestamp' })
+    confirmedAt?: Date;
+}

src/settlements/settlements.service.ts

@@ -0,0 +1,36 @@
+import { Injectable } from "@nestjs/common";
+import { InjectRepository } from "@nestjs/typeorm";
+import { Order, OrderStatus } from "src/orders/order.entity";
+import { Raw, Repository } from "typeorm";
+
+@Injectable()
+export class SettlementsService {
+    private readonly commissionRate = 0.05;
+
+    constructor(@InjectRepository(Order) private orderRepository: Repository<Order>) {}
+
+    async calculateSettlements(): Promise<{ [sellerId: number]: number }> {
+        const orders = await this.orderRepository.find({
+            where: [
+                { status: OrderStatus.PurchaseConfirmed },
+                { 
+                    status: OrderStatus.Delivered, 
+                    confirmedAt: Raw(alias => `DATE_ADD(${alias}, INTERVAL 5 DAY) <= NOW()`)
+                }
+            ]
+        });
+
+        const settlements = {};
+
+        orders.forEach(order => {
+            const netAmount = order.amount * (1 - this.commissionRate);
+            if (settlements[order.sellerId]) {
+                settlements[order.sellerId] += netAmount;
+            } else {
+                settlements[order.sellerId] = netAmount;
+            }
+        });
+
+        return settlements;
+    }
+}

src/settlements/settlements.task.ts

@@ -0,0 +1,16 @@
+import { Injectable } from "@nestjs/common";
+import { Cron, CronExpression } from '@nestjs/schedule';
+import { SettlementsService } from "./settlements.service";
+
+@Injectable()
+export class SettlementsTask {
+    constructor(private settlementsService: SettlementsService) { }
+
+    @Cron('0 0 0 * * *', {
+        timeZone: 'Asia/Seoul'
+    })
+    async handleCron() {
+        const settlements = await this.settlementsService.calculateSettlements();
+        console.log(settlements);
+    }
+}