ゼロベースで設計する理想のアーキテクチャ

{
  "formatId": "MDMSHPFX",
  "description": "高圧確定検針データ",
  "encoding": "shift_jis",
  "recordLength": 138,
  "headerRules": [
    {
      "lineNumber": 3,
      "fields": [
        { "name": "shoriY", "position": 126, "length": 4, "type": "string" },
        { "name": "shoriM", "position": 131, "length": 2, "type": "string" },
        { "name": "shoriD", "position": 134, "length": 2, "type": "string" }
      ]
    },
    {
      "lineNumber": 5,
      "fields": [
        { "name": "jigyosha", "position": 8, "length": 4, "type": "string" },
        { "name": "kyoten", "position": 23, "length": 2, "type": "string" }
      ],
      "validations": [
        {
          "field": "jigyosha",
          "rule": "equals",
          "value": "2903",
          "errorMessage": "事業者コードが2903ではない"
        }
      ]
    }
  ],
  "dataStartLine": 11,
  "fields": [
    {
      "name": "tenno1",
      "position": 0,
      "length": 5,
      "type": "string",
      "inheritFromPrevious": true
    },
    {
      "name": "tenno2",
      "position": 5,
      "length": 5,
      "type": "string",
      "inheritFromPrevious": true
    },
    { "name": "tariff", "position": 12, "length": 2, "type": "string" },
    { "name": "kakou", "position": 21, "length": 1, "type": "string" },
    { "name": "ctlno", "position": 30, "length": 7, "type": "string" },
    { "name": "motik", "position": 39, "length": 5, "type": "string" },
    { "name": "factr", "position": 46, "length": 2, "type": "string" },
    { "name": "ukeir", "position": 55, "length": 2, "type": "string" },
    { "name": "kubun", "position": 60, "length": 4, "type": "string" },
    { "name": "efun2", "position": 73, "length": 5, "type": "string" },
    { "name": "efpid", "position": 82, "length": 1, "type": "string" },
    { "name": "prcid", "position": 88, "length": 1, "type": "string" },
    { "name": "price", "position": 91, "length": 12, "type": "decimal" },
    { "name": "efuno", "position": 103, "length": 5, "type": "string" },
    { "name": "efstry", "position": 114, "length": 4, "type": "string" },
    { "name": "efstrm", "position": 118, "length": 2, "type": "string" },
    { "name": "efstrd", "position": 120, "length": 2, "type": "string" },
    { "name": "efendy", "position": 125, "length": 4, "type": "string" },
    { "name": "efendm", "position": 129, "length": 2, "type": "string" },
    { "name": "efendd", "position": 131, "length": 2, "type": "string" }
  ],
  "computedFields": [
    {
      "name": "tenno",
      "expression": "{tenno1}-{tenno2}{tariff:ifNotBlank('-')}{tariff}"
    },
    {
      "name": "efstr",
      "expression": "{efstry}{efstrm}{efstrd}",
      "type": "long"
    }
  ],
  "targetTable": "HN050",
  "keyColumns": ["cstno", "tenno", "ctlno", "efstr"],
  "staticValues": {
    "cstno": "01  ",
    "chota": "1",
    "usrid": "VKNDD0B "
  },
  "branchField": "kubun",
  "branchRules": [
    { "value": "前回", "action": "DELETE" },
    { "value": "今回", "action": "UPSERT" }
  ]
}

// 共通インターフェース
public interface IEdiProcessor
{
    string FormatId { get; }           // "MDMSHPFX"
    Encoding FileEncoding { get; }     // Shift_JIS
    Task<ProcessResult> ProcessAsync(Stream file, CancellationToken ct);
}

// 高圧確定検針単価用の実装
public class MdmsHpfxProcessor : EdiProcessorBase, IEdiProcessor
{
    public string FormatId => "MDMSHPFX";
    public Encoding FileEncoding => Encoding.GetEncoding("shift_jis");

    protected override int RecordLength => 138;
    protected override int DataStartLine => 11;

    protected override void ParseHeader(int lineNo, string line)
    {
        if (lineNo == 3) ParseShori(line);
        if (lineNo == 5) ParseJigyosha(line);
    }

    protected override ParsedRecord ParseDataLine(string line)
    {
        return new ParsedRecord
        {
            ["tenno1"] = line.Substring(0, 5).Trim(),
            ["tenno2"] = line.Substring(5, 5).Trim(),
            ["tariff"]  = line.Substring(12, 2).Trim(),
            // ...
        };
    }

    protected override string GetTargetTable() => "HN050";
    protected override string[] GetKeyColumns()
        => new[] { "cstno", "tenno", "ctlno", "efstr" };
}

// DI（Dependency Injection）で自動登録
services.AddEdiProcessors(typeof(MdmsHpfxProcessor).Assembly);

// 実行時にFormatIdでルーティング
var processor = processorFactory.GetProcessor("MDMSHPFX");
await processor.ProcessAsync(fileStream, ct);

// JSON定義を読み込む汎用エンジン
public class ConfigDrivenEdiEngine
{
    public async Task<ProcessResult> ProcessAsync(
        string formatId, Stream file, CancellationToken ct)
    {
        var schema = _schemaStore.Load(formatId);

        // 1. 汎用パース
        var records = _parser.Parse(file, schema);

        // 2. カスタムハンドラがあれば実行（オプション）
        if (_customHandlers.TryGet(formatId, out var handler))
        {
            records = await handler.TransformAsync(records);
        }

        // 3. DB書込
        await _dbWriter.WriteAsync(schema.TargetTable, records, schema, ct);

        return result;
    }
}

// カスタムハンドラ（必要なフォーマットのみ実装）
public class MdmsHpfxCustomHandler : ICustomHandler
{
    public string FormatId => "MDMSHPFX";

    public Task<List<ParsedRecord>> TransformAsync(List<ParsedRecord> records)
    {
        // 供給地点番号の空白引き継ぎ、グループ化、KWH2設定などの業務ロジック
        return Task.FromResult(ApplyBusinessRules(records));
    }
}

power-app/
  src/
    Power.Core/                       # 共通ドメインモデル・インターフェース
      Domain/                         # Entity, ValueObject
      Abstractions/                   # IEdiProcessor, IJobQueue 等
    Power.EdiIntegration/             # モジュール1: EDI受信・変換
      Engine/                         # 汎用パーサーエンジン
      Schemas/                        # JSON定義ファイル（40+）
      CustomHandlers/                 # 連携先固有ロジック
      Receivers/                      # スマメ/EDI受信アダプタ
    Power.ContractManagement/         # モジュール2: 契約管理
      Features/
        ReceiveMeter/                 # 契約取込
        MergeContract/                # 契約統合（CRY819X相当）
        MonthlyReset/                 # 月初リセット（CRY413相当）
      Data/                           # KY110, KY130, KY400
    Power.GridExpansion/              # モジュール3: 系統展開
      Features/
        GridExpansion/                # 系統展開（CGR911/912相当）
        LoadAggregation/              # 需要集約計算（CJK120-140相当）
        PlanGeneration/               # 計画生成（CJK211-217相当）
      Data/                           # CH010, CH5D0
    Power.WorkManagement/             # モジュール4: 工事管理
      Features/
        DemandResponseCalc/           # 需給調整計算（CSBK系相当）
        WorkOrder/                    # 工事処理（CSB系相当）
      Data/                           # SB030, SB120
    Power.Reporting/                  # モジュール5: 帳票
      Reports/                        # QuestPDFテンプレート
    Power.MasterMaintenance/          # モジュール6: マスタメンテ
      Pages/                          # Blazor Server画面
    Power.Jobs/                       # バッチジョブオーケストレーション
      Chains/                         # BATファイル相当のジョブチェーン定義
    Power.Infrastructure/             # インフラ層
      Data/                           # EF Core DbContext, Migrations
      Odbc/                           # レガシーDB接続（移行期間用）
      FileSystem/                     # ファイル入出力
  tests/
    Power.EdiIntegration.Tests/       # サンプルデータ駆動テスト
    Power.ContractManagement.Tests/
    ...
  formats/                            # EDIフォーマット定義（JSON）
    mdms-lp30min.json
    mdms-hpfix.json
    ...

// 現行BATの置き換え: 低圧30分値データ処理チェーン
public class LowVoltMeterJobChain
{
    public string Setup(IBackgroundJobClient jobs)
    {
        var step1 = jobs.Enqueue<MeterSortJob>(j => j.Execute("lv-meter30"));
        var step2 = jobs.ContinueJobWith<MeterImportJob>(step1,
            j => j.Execute("lv-meter30", "MDMSLP30"));
        var step3 = jobs.ContinueJobWith<ContractMergeJob>(step2,
            j => j.Execute());
        var step4 = jobs.ContinueJobWith<MasterCheckJob>(step3,
            j => j.Execute());
        var step5 = jobs.ContinueJobWith<MonthlyResetJob>(step4,
            j => j.Execute());

        return step1; // ジョブチェーンのルートID
    }
}

// フォーマット定義をJSON/YAMLから読み込み、汎用的にパースするエンジン
public class FixedLengthParserEngine
{
    private readonly ISchemaStore _schemas;

    public async IAsyncEnumerable<ParsedRecord> ParseAsync(
        string formatId, Stream stream,
        [EnumeratorCancellation] CancellationToken ct = default)
    {
        var schema = _schemas.Load(formatId);
        var encoding = Encoding.GetEncoding(schema.Encoding);
        using var reader = new BinaryReader(stream, encoding, leaveOpen: true);

        int lineNo = 0;
        var headerData = new Dictionary<string, object>();
        string? prevItmno1 = null, prevItmno2 = null;

        while (stream.Position < stream.Length)
        {
            ct.ThrowIfCancellationRequested();
            var bytes = reader.ReadBytes(schema.RecordLength);
            if (bytes.Length < schema.RecordLength) yield break;

            lineNo++;
            var line = encoding.GetString(bytes);

            // ヘッダ行の処理
            var headerRule = schema.HeaderRules
                .FirstOrDefault(h => h.LineNumber == lineNo);
            if (headerRule != null)
            {
                foreach (var field in headerRule.Fields)
                    headerData[field.Name] = ExtractField(line, field);
                ValidateHeader(headerRule, headerData);
                continue;
            }

            // データ開始行より前はスキップ
            if (lineNo < schema.DataStartLine) continue;

            // データ行のパース
            var record = new ParsedRecord();
            foreach (var field in schema.Fields)
            {
                var value = ExtractField(line, field);

                // 空白時の前レコード引き継ぎ
                if (field.InheritFromPrevious
                    && string.IsNullOrWhiteSpace(value as string))
                {
                    value = record.GetPrevious(field.Name);
                }

                record[field.Name] = value;
            }

            // ヘッダ情報をレコードにマージ
            foreach (var (key, val) in headerData)
                record[key] = val;

            // 計算フィールド
            foreach (var computed in schema.ComputedFields)
                record[computed.Name] = EvaluateExpression(computed, record);

            yield return record;
        }
    }

    private object ExtractField(string line, FieldDefinition field)
    {
        if (field.Position >= line.Length) return field.DefaultValue;
        var length = Math.Min(field.Length, line.Length - field.Position);
        var raw = line.Substring(field.Position, length);

        return field.Type switch
        {
            "string"  => raw.Trim(),
            "decimal" => decimal.TryParse(raw.Trim(), out var d) ? d : 0m,
            "long"    => long.TryParse(raw.Trim(), out var l) ? l : 0L,
            "date"    => ParseDate(raw, field.Format),
            _         => raw.Trim()
        };
    }
}

// 現行: CHP03TPB.BAT（10本のプログラムを順次実行）
// 理想: Hangfireのジョブチェーンで型安全に定義

public static class LowVoltMeterChain
{
    // BATファイル1本 → C#メソッド1本
    public static string Register(IBackgroundJobClient jobs, string yearMonth)
    {
        // CRY125S → CRY125 → VRY811B → CRY819X → CRY301X
        // → CHN04A → CHN041 → CRY135 → CRY411X → CRY413
        var j1 = jobs.Enqueue<MeterSortJob>(
            j => j.Execute(yearMonth));
        var j2 = jobs.ContinueJobWith<MeterImportJob>(j1,
            j => j.Execute(yearMonth));
        var j3 = jobs.ContinueJobWith<MeterFileJob>(j2,
            j => j.Execute());
        var j4 = jobs.ContinueJobWith<ContractMergeJob>(j3,
            j => j.Execute());
        var j5 = jobs.ContinueJobWith<UnregisteredMasterCheckJob>(j4,
            j => j.Execute());
        var j6 = jobs.ContinueJobWith<ControlNumberWorkJob>(j5,
            j => j.Execute());
        var j7 = jobs.ContinueJobWith<ControlNumberRegisterJob>(j6,
            j => j.Execute());
        var j8 = jobs.ContinueJobWith<MeterDataListJob>(j7,
            j => j.Execute());
        var j9 = jobs.ContinueJobWith<MeterFileOutJob>(j8,
            j => j.Execute());
        var j10 = jobs.ContinueJobWith<MonthlyResetJob>(j9,
            j => j.Execute());

        return j1;
    }
}

// 現行: CGR911 + CGR912 + CJK120 + CJK130 + CJK140（5本のCOBOLプログラム）
// 理想: 1つのサービスクラス

public class GridLoadService
{
    private readonly AppDbContext _db;

    /// <summary>
    /// Low-Level Code法による系統展開。
    /// レベル0（完成品）から順に需要量を集約し、
    /// 同一設備が複数の親に使われる場合の二重計算を防ぐ。
    /// </summary>
    public async Task<ExpansionResult> ExpandAsync(
        string yearMonth, CancellationToken ct)
    {
        // 1. 系統ツリーからLow-Level Codeを事前計算
        //    (CGR911:ゼロクリア + CGR912:自動設定 に相当)
        var items = await _db.Sb020
            .OrderBy(b => b.LowLevelCode)
            .ToListAsync(ct);

        // 2. 契約データ（設備管理）からグロス需要量を算出
        //    (CJK120:アクティビティチェーン に相当)
        var grossRequirements = await CalculateGrossRequirements(yearMonth, ct);

        // 3. レベル順に展開
        //    (CJK130:需要LOAD + CJK140:需要集約 に相当)
        var netRequirements = new Dictionary<string, decimal>();

        foreach (var level in items.GroupBy(i => i.LowLevelCode)
                                    .OrderBy(g => g.Key))
        {
            foreach (var item in level)
            {
                var gross = grossRequirements.GetValueOrDefault(item.PointNo, 0m);
                var onHand = item.OnHandQty;
                var net = Math.Max(0, gross - onHand);

                netRequirements[item.PointNo] = net;

                // 下位設備に需要量を集約
                var children = await _db.Sb020
                    .Where(b => b.ParentPointNo == item.PointNo)
                    .ToListAsync(ct);

                foreach (var child in children)
                {
                    var childGross = net * child.RequiredQty;
                    grossRequirements[child.PointNo] =
                        grossRequirements.GetValueOrDefault(child.PointNo, 0m)
                        + childGross;
                }
            }
        }

        return new ExpansionResult(netRequirements);
    }
}

// 現行: VB6 Form × 30本
// 理想: Blazor Server + 汎用CRUDコンポーネント

// 177テーブル全てに専用画面を作るのではなく:
// ・主要20テーブル → カスタム画面
// ・残り157テーブル → 汎用DataGrid画面

@page "/master/sl050"
@inject AppDbContext Db

<PageTitle>HN050 料金単価マスタ</PageTitle>

<RadzenDataGrid @ref="grid" Data="@records" TItem="Hn050"
    AllowFiltering="true" AllowSorting="true" AllowPaging="true"
    PageSize="20" EditMode="DataGridEditMode.Single"
    RowCreate="OnCreate" RowUpdate="OnUpdate">

    <Columns>
        <RadzenDataGridColumn Property="Cstno" Title="連携先" Width="80px" />
        <RadzenDataGridColumn Property="Itmno" Title="供給地点番号" Width="160px" />
        <RadzenDataGridColumn Property="Ctlno" Title="管理番号" Width="120px" />
        <RadzenDataGridColumn Property="Efstr" Title="適用開始" Width="100px"
            FormatString="{0:yyyyMMdd}" />
        <RadzenDataGridColumn Property="Kwh1" Title="価格1" Width="100px"
            FormatString="{0:N2}" TextAlign="TextAlign.Right" />
        <RadzenDataGridColumn Property="Kwh2" Title="価格2" Width="100px"
            FormatString="{0:N2}" TextAlign="TextAlign.Right" />
    </Columns>
</RadzenDataGrid>

{
  "formatId": "NEW_API_FORMAT",
  "parserType": "json",
  "jsonPath": "$.records[*]",
  "fieldMappings": [
    { "source": "partNumber", "target": "tenno" },
    { "source": "quantity", "target": "qty" }
  ],
  "targetTable": "KY110"
}