技術選定調査レポート: モダンアーキテクチャによる再構築

// Hangfire でのバッチ処理例（CHP060TB.BAT の置換）
public class GridBatchOrchestrator
{
    // 日次バッチ: CRY125S → CRY125 → VRY811B → ... → CRY413
    public void ExecuteDailyBatch()
    {
        var batchId = BatchJob.StartNew(batch =>
        {
            var job1 = batch.Enqueue<ICro125SService>(s => s.ExecuteAsync());
            var job2 = batch.ContinueJobWith<ICro125Service>(job1, s => s.ExecuteAsync());
            var job3 = batch.ContinueJobWith<IVro811BService>(job2, s => s.ExecuteAsync());
            // ... 順次実行
            batch.ContinueJobWith<ICro413Service>(job3, s => s.ExecuteAsync());
        });
    }
}

// Azure Durable Functions でのパイプライン例
[FunctionName("GridBatchOrchestrator")]
public static async Task RunOrchestrator(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    await context.CallActivityAsync("CRY125S_Execute", null);
    await context.CallActivityAsync("CRY125_Execute", null);
    await context.CallActivityAsync("VRY811B_Execute", null);
    // ...順次実行、自動リトライ・チェックポイント付き
    await context.CallActivityAsync("CRY413_Execute", null);
}

// 再帰的系統展開 — 直感的だが深い系統構成でスタック問題の可能性
public class GridExpansionService
{
    private readonly IGridRepository _gridRepo;

    public async Task<List<MaterialRequirement>> ExplodeAsync(
        string pointCode, decimal requiredQty, DateTime dueDate)
    {
        var requirements = new List<MaterialRequirement>();
        await ExplodeRecursiveAsync(pointCode, requiredQty, dueDate, 0, requirements);
        return requirements;
    }

    private async Task ExplodeRecursiveAsync(
        string parentItem, decimal parentQty, DateTime dueDate,
        int level, List<MaterialRequirement> results)
    {
        var children = await _gridRepo.GetChildrenAsync(parentItem);

        foreach (var child in children)
        {
            var grossReq = parentQty * child.QuantityPer; // 構成数量を乗算
            var netReq = grossReq - await GetAvailableStockAsync(child.PointCode);

            results.Add(new MaterialRequirement
            {
                PointCode = child.PointCode,
                Level = level + 1,
                GrossRequirement = grossReq,
                NetRequirement = Math.Max(0, netReq),
                DueDate = dueDate.AddDays(-child.LeadTimeDays),
            });

            // 子が製造品（中間品）なら再帰展開
            if (child.FacilityType == FacilityType.Manufactured)
            {
                await ExplodeRecursiveAsync(
                    child.PointCode, Math.Max(0, netReq),
                    dueDate.AddDays(-child.LeadTimeDays),
                    level + 1, results);
            }
        }
    }
}

// Low-Level Code 法: 需要集約の標準アルゴリズム
// 同一設備が複数の親に使われる場合の二重計算を防ぐ
public class GridLoadService
{
    /// <summary>
    /// Low-Level Code 法による 需要集約 展開。
    /// 各設備の「最下位レベル」を事前計算し、レベル0から順に処理する。
    /// 同一設備が複数の親に使われる場合でも正確にNetRequirementを算出。
    /// </summary>
    public async Task<GridLoadResult> RunGridLoadAsync(
        IEnumerable<DemandRecord> demands)
    {
        // Step 1: Low-Level Code の計算
        // 設備が系統ツリーの中で出現する最も深いレベルを事前計算
        var lowLevelCodes = await ComputeLowLevelCodesAsync();
        var maxLevel = lowLevelCodes.Values.Max();

        // Step 2: 需要を設備別に集約
        var requirementsByFacility = new Dictionary<string, GrossNetRecord>();
        foreach (var demand in demands)
        {
            AccumulateDemand(requirementsByItem, demand.PointCode, demand.Quantity, demand.DueDate);
        }

        // Step 3: レベル0（完成品）から順に展開
        for (int level = 0; level <= maxLevel; level++)
        {
            var itemsAtLevel = lowLevelCodes
                .Where(kv => kv.Value == level)
                .Select(kv => kv.Key);

            foreach (var pointCode in itemsAtLevel)
            {
                if (!requirementsByItem.TryGetValue(pointCode, out var record))
                    continue;

                // Gross → Net 計算（在庫・工事予定残を差し引き）
                var netReq = ComputeNetRequirement(record);

                if (netReq <= 0) continue;

                // 系統構成 下位設備への展開
                var children = await _gridRepo.GetChildrenAsync(pointCode);
                foreach (var child in children)
                {
                    var childReq = netReq * child.QuantityPer;
                    AccumulateDemand(requirementsByItem,
                        child.PointCode, childReq,
                        record.DueDate.AddDays(-child.LeadTimeDays));
                }
            }
        }

        return new GridLoadResult(requirementsByItem);
    }
}

-- 系統構成をフラット化してDBに保持するパターン
-- 展開済みの構成をテーブルに持ち、JOINで一発取得
CREATE TABLE GRID_FLAT (
    ParentFacility   VARCHAR(20),
    ChildFacility    VARCHAR(20),
    Level        INT,
    CumulativeQty DECIMAL(18,6),  -- 累積構成数量（親からの乗算済み）
    LeadTimeDays INT,
    PRIMARY KEY (ParentItem, ChildItem, Level)
);

-- 系統展開がSQLの集計クエリに変換できる
SELECT ChildItem, SUM(DemandQty * CumulativeQty) AS TotalRequirement
FROM GRID_FLAT bf
JOIN Demand d ON bf.ParentFacility = d.PointCode
GROUP BY ChildItem;

// Pipeline パターン: EDI変換処理の汎用化
// パターンA（EDIデータ変換）に最適
public interface IPipelineStep<T>
{
    Task<T> ExecuteAsync(T input, CancellationToken ct);
}

// EDI処理パイプラインの例（VKNDD0B のモダン版）
public class EdiPipeline<TRecord>
{
    private readonly List<IPipelineStep<EdiContext<TRecord>>> _steps = [];

    public EdiPipeline<TRecord> AddStep(IPipelineStep<EdiContext<TRecord>> step)
    {
        _steps.Add(step);
        return this;
    }

    public async Task<EdiResult> ExecuteAsync(Stream inputFile, CancellationToken ct)
    {
        var context = new EdiContext<TRecord> { InputStream = inputFile };

        foreach (var step in _steps)
        {
            context = await step.ExecuteAsync(context, ct);
            if (context.HasError) break; // エラー時は中断
        }

        return context.ToResult();
    }
}

// 使用例: 料金単価データ処理パイプライン
var pipeline = new EdiPipeline<MeterDataRecord>()
    .AddStep(new ValidateControlTable())      // RN920 制御テーブル確認
    .AddStep(new ParseFixedLengthFile())       // 138byte 固定長解析
    .AddStep(new FilterTargetRecords())        // CTL="D", ID="1", JIGYOSHA="2903"
    .AddStep(new ClassifyPreviousCurrent())    // KUBUN による前回/今回分類
    .AddStep(new UpsertToDatabase())           // HN050 への INSERT/UPDATE/DELETE
    .AddStep(new UpdateControlStatus())        // RN920 ステータス更新
    .AddStep(new WriteProcessingLog());        // ログ出力

// 連携先ごとに異なるEDIフォーマットを Strategy で切り替え
public interface IEdiFormatParser
{
    string CustomerCode { get; }  // "01"=低圧需要家, etc.
    IEnumerable<ContractRecord> Parse(Stream input);
}

public class MdmsMeterParser : IEdiFormatParser
{
    public string CustomerCode => "01";

    public IEnumerable<ContractRecord> Parse(Stream input)
    {
        // MDMSLP30: 250byte 固定長レコード
        // バイト位置: 0-9=供給地点番号, 10-15=数量, ...
        using var reader = new StreamReader(input, Encoding.GetEncoding("Shift_JIS"));
        // ...
    }
}

public class SwitchingEdiParser : IEdiFormatParser
{
    public string CustomerCode => "SWITCHING";

    public IEnumerable<ContractRecord> Parse(Stream input)
    {
        // SWREQ21: 可変長レコード
        // ...
    }
}

// DI で全パーサーを登録、連携先コードで自動選択
services.AddTransient<IEdiFormatParser, MdmsMeterParser>();
services.AddTransient<IEdiFormatParser, SwitchingEdiParser>();
services.AddTransient<IEdiFormatParser, TakusoEdiParser>();
// ... 連携先追加時は新クラスを追加するだけ

// CQRS で契約コマンドと工事照会を分離
// 注意: MediatR は 2025年7月から商用ライセンス化

// Command: 契約データ登録
public record ProcessContractCommand(
    string CustomerCode,
    Stream EdiData) : IRequest<ContractResult>;

public class ProcessContractHandler : IRequestHandler<ProcessContractCommand, ContractResult>
{
    private readonly IEnumerable<IEdiFormatParser> _parsers;
    private readonly IContractRepository _contractRepo;

    public async Task<ContractResult> Handle(
        ProcessContractCommand request, CancellationToken ct)
    {
        var parser = _parsers.First(p => p.CustomerCode == request.CustomerCode);
        var contracts = parser.Parse(request.EdiData);
        await _contractRepo.BulkUpsertAsync(contracts, ct);
        return new ContractResult(contracts.Count());
    }
}

// Query: 契約照会
public record GetContractStatusQuery(string PointCode, DateRange Period)
    : IRequest<ContractStatusResult>;

// QuestPDF による需給計画表の例
Document.Create(container =>
{
    container.Page(page =>
    {
        page.Size(PageSizes.A4.Landscape());
        page.Margin(1, Unit.Centimetre);

        page.Header().Text("需給計画表")
            .FontSize(16).Bold().AlignCenter();

        page.Content().Table(table =>
        {
            table.ColumnsDefinition(cols =>
            {
                cols.ConstantColumn(80);  // 供給地点番号
                cols.ConstantColumn(120); // 設備名
                cols.RelativeColumn();    // 当月計画
                cols.RelativeColumn();    // 翌月計画
                cols.RelativeColumn();    // 翌々月計画
            });

            // ヘッダー行
            table.Header(header =>
            {
                header.Cell().Text("供給地点番号").Bold();
                header.Cell().Text("設備名").Bold();
                header.Cell().Text("N0(当月)").Bold();
                header.Cell().Text("N1(翌月)").Bold();
                header.Cell().Text("N2(翌々月)").Bold();
            });

            // データ行
            foreach (var item in supplyPlan)
            {
                table.Cell().Text(item.PointCode);
                table.Cell().Text(item.FacilityName);
                table.Cell().Text(item.N0Total.ToString("#,##0"));
                table.Cell().Text(item.N1Total.ToString("#,##0"));
                table.Cell().Text(item.N2Total.ToString("#,##0"));
            }
        });
    });
}).GeneratePdf("supply-plan.pdf");

// 汎用 CSV 出力サービス
public class ReportExportService
{
    // CsvHelper で型安全なCSV出力
    public async Task ExportCsvAsync<T>(
        IEnumerable<T> data, Stream output, CsvConfiguration? config = null)
    {
        config ??= new CsvConfiguration(CultureInfo.GetCultureInfo("ja-JP"))
        {
            HasHeaderRecord = true,
            Encoding = Encoding.UTF8, // Shift_JIS → UTF-8
        };

        await using var writer = new StreamWriter(output, config.Encoding);
        await using var csv = new CsvWriter(writer, config);
        await csv.WriteRecordsAsync(data);
    }

    // PDF出力が必要な場合は QuestPDF
    public void ExportPdf<T>(IEnumerable<T> data, string templateName, Stream output)
    {
        var template = _templateRegistry.Get(templateName);
        template.Render(data, output);
    }
}

// メタデータ駆動の汎用CRUD画面（Tier 2-3 向け）
// テーブル名を渡すだけで CRUD 画面を動的に生成
@page "/admin/table/{TableName}"

<h3>@TableName データ管理</h3>
<RadzenDataGrid Data="@data" TItem="Dictionary<string, object>"
    AllowFiltering="true" AllowSorting="true" AllowPaging="true">
    @foreach (var col in columns)
    {
        <RadzenDataGridColumn Property="@col.Name" Title="@col.DisplayName"
            Type="@col.DataType" />
    }
</RadzenDataGrid>

@code {
    [Parameter] public string TableName { get; set; } = "";

    // メタデータからカラム定義を動的取得
    private List<ColumnMetadata> columns = [];
    private IEnumerable<Dictionary<string, object>> data = [];

    protected override async Task OnParametersSetAsync()
    {
        columns = await _metadataService.GetColumnsAsync(TableName);
        data = await _dataService.GetAllAsync(TableName);
    }
}

Feature: 契約データ処理
    ProcessOrder.Command.cs
    ProcessOrder.Handler.cs
    ProcessOrder.Validator.cs
    ProcessOrder.Endpoint.cs

Feature: 設備データリセット
    ResetFacility.Command.cs
    ResetFacility.Handler.cs
    ResetFacility.Endpoint.cs

Feature: 設備マスタCRUD
    GetItems.Query.cs
    CreateItem.Command.cs
    UpdateItem.Command.cs
    Items.Endpoint.cs

Power.Web (Host)
    共通認証・認可
    共通ミドルウェア
    モジュール登録

Power.Cis (料金CIS)
    Contracts/
        LowVolt/
        HighVolt/
        Takuso/
    Charging/
    Masters/
    Reports/

Power.Grid (設備管理)
    DemandPlan/
        MonthlyReset/
        GridExpansion/
    WorkManagement/
        DemandResponsePlan/
    Reports/

Power.SharedKernel
    Domain/ (共通Entity, ValueObject)
    Infrastructure/ (DB, EDI共通)
    Common/ (ExeOdbc後継のDB接続層)

// 実用的なDDD: フルDDDのセレモニーを避け、必要な要素だけ使う

// Value Object: 供給地点番号（VB6の ITMNO1+ITMNO2+TARIFF に対応）
public record PointCode
{
    public string Prefix { get; }   // ITMNO1 (前半5桁)
    public string Suffix { get; }   // ITMNO2 (後半5桁)
    public string TariffCode { get; }  // TARIFF  (料金種別2桁)

    public PointCode(string prefix, string suffix, string tariffCode)
    {
        // バリデーション: 桁数チェック等
        Prefix = prefix;
        Suffix = suffix;
        TariffCode = tariffCode;
    }

    public override string ToString() => $"{Prefix}-{Suffix}-{TariffCode}";
}

// Entity: 設備マスタ (SB010 → わかりやすい名前に)
public class Facility  // ← "SB010Record" ではなく業務用語で
{
    public PointCode Code { get; private set; }
    public string Name { get; private set; }
    public FacilityType Type { get; private set; }  // 製品/中間品/購入品
    public int LeadTimeDays { get; private set; }
    // ... ビジネスロジックをここに集約
}