462 lines
15 KiB
Python
462 lines
15 KiB
Python
from fastapi import APIRouter, HTTPException
|
||
from app.core.database import get_connection
|
||
from pydantic import BaseModel
|
||
from typing import List, Optional
|
||
from decimal import Decimal
|
||
from datetime import date
|
||
|
||
router = APIRouter(prefix="/journal-entries", tags=["仕訳"])
|
||
|
||
|
||
class JournalLine(BaseModel):
|
||
account_id: int
|
||
debit: Decimal = Decimal("0")
|
||
credit: Decimal = Decimal("0")
|
||
tax_rate: Optional[int] = None # 10 or 8 or None
|
||
tax_direction: Optional[str] = None # "paid" or "received" or None
|
||
|
||
|
||
class JournalEntryRequest(BaseModel):
|
||
entry_date: date
|
||
description: str
|
||
lines: List[JournalLine]
|
||
tax_paid_account_id: Optional[int] = None # 仮払消費税等 勘定
|
||
tax_received_account_id: Optional[int] = None # 仮受消費税等 勘定
|
||
rounding_mode: str = "round" # "round", "floor", or "ceil"
|
||
|
||
class JournalEntryUpdateRequest(BaseModel):
|
||
description: str
|
||
lines: List[JournalLine]
|
||
updated_reason: str
|
||
|
||
|
||
class JournalEntryDeleteRequest(BaseModel):
|
||
deleted_reason: str
|
||
|
||
|
||
@router.get("", summary="仕訳一覧取得")
|
||
def get_journal_entries(
|
||
from_date: date = None,
|
||
to_date: date = None,
|
||
keyword: str = None,
|
||
account_id: int = None
|
||
):
|
||
"""
|
||
仕訳一覧を検索して取得
|
||
"""
|
||
with get_connection() as conn:
|
||
with conn.cursor() as cur:
|
||
# クエリ構築
|
||
sql = """
|
||
SELECT
|
||
je.journal_entry_id,
|
||
je.entry_date,
|
||
je.description,
|
||
je.fiscal_year,
|
||
COALESCE(SUM(jl.debit), 0) as debit_total,
|
||
COALESCE(SUM(jl.credit), 0) as credit_total
|
||
FROM journal_entries je
|
||
LEFT JOIN journal_lines jl ON je.journal_entry_id = jl.journal_entry_id
|
||
WHERE je.is_deleted = false
|
||
"""
|
||
|
||
params = []
|
||
|
||
if from_date:
|
||
sql += " AND je.entry_date >= %s"
|
||
params.append(from_date)
|
||
|
||
if to_date:
|
||
sql += " AND je.entry_date <= %s"
|
||
params.append(to_date)
|
||
|
||
if keyword:
|
||
sql += " AND je.description LIKE %s"
|
||
params.append(f"%{keyword}%")
|
||
|
||
if account_id:
|
||
sql += """ AND je.journal_entry_id IN (
|
||
SELECT DISTINCT journal_entry_id
|
||
FROM journal_lines
|
||
WHERE account_id = %s
|
||
)"""
|
||
params.append(account_id)
|
||
|
||
sql += """
|
||
GROUP BY je.journal_entry_id, je.entry_date, je.description, je.fiscal_year
|
||
ORDER BY je.entry_date DESC, je.journal_entry_id DESC
|
||
"""
|
||
|
||
cur.execute(sql, params)
|
||
rows = cur.fetchall()
|
||
|
||
return [dict(row) for row in rows]
|
||
|
||
|
||
@router.get("/{journal_id}", summary="仕訳詳細取得")
|
||
def get_journal_entry(journal_id: int):
|
||
"""
|
||
指定された仕訳の詳細を取得
|
||
"""
|
||
with get_connection() as conn:
|
||
with conn.cursor() as cur:
|
||
# ヘッダー取得
|
||
cur.execute("""
|
||
SELECT
|
||
journal_entry_id,
|
||
entry_date,
|
||
description,
|
||
fiscal_year,
|
||
version,
|
||
is_deleted
|
||
FROM journal_entries
|
||
WHERE journal_entry_id = %s
|
||
""", (journal_id,))
|
||
|
||
header = cur.fetchone()
|
||
if not header:
|
||
raise HTTPException(status_code=404, detail="仕訳が存在しません")
|
||
|
||
# 明細取得
|
||
cur.execute("""
|
||
SELECT
|
||
jl.journal_line_id,
|
||
jl.account_id,
|
||
a.account_code,
|
||
a.account_name,
|
||
jl.debit,
|
||
jl.credit,
|
||
jl.tax_rate,
|
||
jl.tax_direction
|
||
FROM journal_lines jl
|
||
JOIN accounts a ON jl.account_id = a.account_id
|
||
WHERE jl.journal_entry_id = %s
|
||
ORDER BY jl.journal_line_id
|
||
""", (journal_id,))
|
||
|
||
lines = cur.fetchall()
|
||
|
||
return {
|
||
**dict(header),
|
||
"lines": [dict(line) for line in lines]
|
||
}
|
||
|
||
|
||
@router.post("/{journal_id}/reverse", summary="逆仕訳作成")
|
||
def create_reverse_entry(journal_id: int):
|
||
"""
|
||
指定された仕訳の逆仕訳を作成
|
||
"""
|
||
with get_connection() as conn:
|
||
with conn.cursor() as cur:
|
||
# 元仕訳取得
|
||
cur.execute("""
|
||
SELECT entry_date, description, fiscal_year
|
||
FROM journal_entries
|
||
WHERE journal_entry_id = %s AND is_deleted = false
|
||
""", (journal_id,))
|
||
|
||
header = cur.fetchone()
|
||
if not header:
|
||
raise HTTPException(status_code=404, detail="仕訳が存在しません")
|
||
|
||
# 元仕訳の明細取得
|
||
cur.execute("""
|
||
SELECT account_id, debit, credit
|
||
FROM journal_lines
|
||
WHERE journal_entry_id = %s
|
||
""", (journal_id,))
|
||
|
||
lines = cur.fetchall()
|
||
|
||
# 逆仕訳ヘッダー作成
|
||
cur.execute("""
|
||
INSERT INTO journal_entries (
|
||
entry_date,
|
||
description,
|
||
fiscal_year,
|
||
version,
|
||
is_deleted,
|
||
created_by
|
||
)
|
||
VALUES (%s, %s, %s, 1, false, %s)
|
||
RETURNING journal_entry_id
|
||
""", (
|
||
header["entry_date"],
|
||
f"[逆仕訳] {header['description']}",
|
||
header["fiscal_year"],
|
||
"system"
|
||
))
|
||
|
||
new_entry_id = cur.fetchone()["journal_entry_id"]
|
||
|
||
# 逆仕訳明細作成（借方と貸方を入れ替え）
|
||
for line in lines:
|
||
cur.execute("""
|
||
INSERT INTO journal_lines (
|
||
journal_entry_id,
|
||
account_id,
|
||
debit,
|
||
credit
|
||
)
|
||
VALUES (%s, %s, %s, %s)
|
||
""", (
|
||
new_entry_id,
|
||
line["account_id"],
|
||
line["credit"], # 借方と貸方を入れ替え
|
||
line["debit"]
|
||
))
|
||
|
||
conn.commit()
|
||
|
||
return {
|
||
"status": "ok",
|
||
"reversed_journal_entry_id": new_entry_id,
|
||
"original_journal_entry_id": journal_id
|
||
}
|
||
|
||
|
||
@router.post("", summary="仕訳登録")
|
||
def create_journal_entry(req: JournalEntryRequest):
|
||
|
||
from app.utils.month_lock import is_month_locked
|
||
from decimal import Decimal, ROUND_HALF_UP, ROUND_DOWN, ROUND_UP
|
||
|
||
if is_month_locked(req.entry_date):
|
||
raise HTTPException(
|
||
status_code=400,
|
||
detail="该月份已锁定，不能新增仕訳"
|
||
)
|
||
|
||
if not req.lines:
|
||
raise HTTPException(status_code=400, detail="仕訳明細不能为空")
|
||
|
||
# 税額計算と税行生成
|
||
all_lines = []
|
||
tax_aggregation = {} # {"paid": Decimal, "received": Decimal}
|
||
|
||
# 端数処理モード設定
|
||
rounding_map = {
|
||
"round": ROUND_HALF_UP,
|
||
"floor": ROUND_DOWN,
|
||
"ceil": ROUND_UP
|
||
}
|
||
rounding = rounding_map.get(req.rounding_mode, ROUND_HALF_UP)
|
||
|
||
for line in req.lines:
|
||
all_lines.append(line)
|
||
|
||
# 税対象行の場合、税額を計算
|
||
if line.tax_rate and line.tax_direction:
|
||
amount = line.debit if line.debit > 0 else line.credit
|
||
rate = Decimal(str(line.tax_rate)) / Decimal("100") # 10% -> 0.10
|
||
|
||
# 入力額は税抜額として、税額 = 税抜額 × 税率
|
||
raw_tax = amount * rate
|
||
tax_amount = raw_tax.quantize(Decimal("1"), rounding=rounding)
|
||
|
||
# 税方向ごとに集計
|
||
if line.tax_direction not in tax_aggregation:
|
||
tax_aggregation[line.tax_direction] = Decimal("0")
|
||
tax_aggregation[line.tax_direction] += tax_amount
|
||
|
||
# 集計した税額で税行を追加
|
||
if "paid" in tax_aggregation and tax_aggregation["paid"] > 0:
|
||
if not req.tax_paid_account_id:
|
||
raise HTTPException(status_code=400, detail="仮払消費税等 勘定を選択してください")
|
||
all_lines.append(JournalLine(
|
||
account_id=req.tax_paid_account_id,
|
||
debit=tax_aggregation["paid"],
|
||
credit=Decimal("0")
|
||
))
|
||
|
||
if "received" in tax_aggregation and tax_aggregation["received"] > 0:
|
||
if not req.tax_received_account_id:
|
||
raise HTTPException(status_code=400, detail="仮受消費税等 勘定を選択してください")
|
||
all_lines.append(JournalLine(
|
||
account_id=req.tax_received_account_id,
|
||
debit=Decimal("0"),
|
||
credit=tax_aggregation["received"]
|
||
))
|
||
|
||
# 借貸平衡校験
|
||
total_debit = sum(l.debit for l in all_lines)
|
||
total_credit = sum(l.credit for l in all_lines)
|
||
if total_debit != total_credit:
|
||
raise HTTPException(status_code=400, detail="借方和贷方不平衡")
|
||
|
||
fiscal_year = req.entry_date.year
|
||
|
||
with get_connection() as conn:
|
||
with conn.cursor() as cur:
|
||
# 仕訳ヘッダ
|
||
cur.execute("""
|
||
INSERT INTO journal_entries (
|
||
entry_date,
|
||
description,
|
||
fiscal_year,
|
||
version,
|
||
is_deleted,
|
||
created_by
|
||
)
|
||
VALUES (%s, %s, %s, 1, false, %s)
|
||
RETURNING journal_entry_id
|
||
""", (
|
||
req.entry_date,
|
||
req.description,
|
||
fiscal_year,
|
||
"system"
|
||
))
|
||
|
||
entry_id = cur.fetchone()["journal_entry_id"]
|
||
|
||
# 明細（税行を含む）
|
||
for line in all_lines:
|
||
# tax_directionの値を変換: paid->INPUT, received->OUTPUT, none->NONE
|
||
tax_dir_db = None
|
||
if line.tax_direction:
|
||
if line.tax_direction == 'paid':
|
||
tax_dir_db = 'INPUT'
|
||
elif line.tax_direction == 'received':
|
||
tax_dir_db = 'OUTPUT'
|
||
elif line.tax_direction == 'none':
|
||
tax_dir_db = 'NONE'
|
||
else:
|
||
tax_dir_db = line.tax_direction.upper()
|
||
|
||
cur.execute("""
|
||
INSERT INTO journal_lines (
|
||
journal_entry_id,
|
||
account_id,
|
||
debit,
|
||
credit,
|
||
tax_rate,
|
||
tax_direction
|
||
)
|
||
VALUES (%s, %s, %s, %s, %s, %s)
|
||
""", (
|
||
entry_id,
|
||
line.account_id,
|
||
line.debit,
|
||
line.credit,
|
||
line.tax_rate,
|
||
tax_dir_db
|
||
))
|
||
|
||
conn.commit()
|
||
|
||
return {
|
||
"status": "ok",
|
||
"journal_entry_id": entry_id
|
||
}
|
||
|
||
|
||
@router.put("/{journal_id}")
|
||
def update_journal_entry(journal_id: int, req: JournalEntryUpdateRequest):
|
||
from app.utils.month_lock import is_month_locked
|
||
|
||
with get_connection() as conn:
|
||
with conn.cursor() as cur:
|
||
|
||
# ① 取得现有仕訳
|
||
cur.execute("""
|
||
SELECT journal_date, is_deleted, version
|
||
FROM journal_entries
|
||
WHERE journal_id = %s
|
||
""", (journal_id,))
|
||
row = cur.fetchone()
|
||
|
||
if not row:
|
||
raise HTTPException(status_code=404, detail="仕訳が存在しません")
|
||
|
||
if row["is_deleted"]:
|
||
raise HTTPException(status_code=400, detail="削除済み仕訳は更新できません")
|
||
|
||
journal_date = row["journal_date"]
|
||
|
||
# 借贷平衡校验（update）
|
||
total_debit = sum(l.debit for l in req.lines)
|
||
total_credit = sum(l.credit for l in req.lines)
|
||
|
||
if total_debit != total_credit:
|
||
raise HTTPException(status_code=400, detail="借方和贷方不平衡")
|
||
|
||
|
||
# ② 月次锁定检查
|
||
if is_month_locked(journal_date):
|
||
raise HTTPException(status_code=400, detail="该月份已锁定，不能修改仕訳")
|
||
|
||
# ③ 更新 header
|
||
cur.execute("""
|
||
UPDATE journal_entries
|
||
SET description = %s,
|
||
version = version + 1,
|
||
updated_at = NOW(),
|
||
updated_reason = %s
|
||
WHERE journal_id = %s
|
||
""", (
|
||
req.description,
|
||
req.updated_reason,
|
||
journal_id
|
||
))
|
||
|
||
# ④ 删除原有明细（物理删除，OK）
|
||
cur.execute("""
|
||
DELETE FROM journal_lines
|
||
WHERE journal_id = %s
|
||
""", (journal_id,))
|
||
|
||
# ⑤ 插入新明细
|
||
for line in req.lines:
|
||
cur.execute("""
|
||
INSERT INTO journal_lines (
|
||
journal_id,
|
||
account_id,
|
||
debit,
|
||
credit
|
||
) VALUES (%s, %s, %s, %s)
|
||
""", (
|
||
journal_id,
|
||
line.account_id,
|
||
line.debit,
|
||
line.credit
|
||
))
|
||
|
||
conn.commit()
|
||
|
||
return {
|
||
"status": "ok",
|
||
"journal_id": journal_id,
|
||
"message": "仕訳を更新しました"
|
||
}
|
||
|
||
|
||
|
||
@router.delete("/{journal_id}", summary="仕訳削除（ソフト削除）")
|
||
def delete_journal_entry(journal_id: int, req: JournalEntryDeleteRequest):
|
||
|
||
with get_connection() as conn:
|
||
with conn.cursor() as cur:
|
||
cur.execute("""
|
||
UPDATE journal_entries
|
||
SET is_deleted = true,
|
||
updated_at = NOW()
|
||
WHERE journal_entry_id = %s
|
||
AND is_deleted = false
|
||
RETURNING journal_entry_id
|
||
""", (journal_id,))
|
||
|
||
row = cur.fetchone()
|
||
if not row:
|
||
raise HTTPException(
|
||
status_code=404,
|
||
detail="仕訳が存在しないか、既に削除されています"
|
||
)
|
||
|
||
conn.commit()
|
||
|
||
return {
|
||
"status": "deleted",
|
||
"journal_entry_id": journal_id
|
||
}
|