package jnpf.limsService.support;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;

/**
 * 取样终止申请流程状态同步的静态回归检查。
 */
public class LimsSxtQuyangZhongzhiShenqingFlowStatusChecks {

    private static final Path REPOSITORY_ROOT = Paths.get("").toAbsolutePath().normalize();

    public static void main(String[] args) throws IOException {
        String service = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsService/impl/LimsSxtJihuaServiceImpl.java");
        String entity = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsSxtQuyangZhongzhiShenqingEntity.java");
        String mapper = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsMapper/LimsSxtQuyangZhongzhiShenqingMapper.java");
        String childEntity = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsSxtQuyangZhongzhiShenqingZixiangEntity.java");
        String childMapper = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsMapper/LimsSxtQuyangZhongzhiShenqingZixiangMapper.java");
        String bizStatus = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/BizStatus.java");
        String schema = read("docs/pg-migration-ddl/self_built_tables_pg.sql");
        String migration = read("docs/pg-migration-ddl/update_lims_sxt_quyang_zhongzhi_shenqing_biz_status_20260723.sql");
        String qingyandanLinkMigration = read("docs/pg-migration-ddl/update_lims_sxt_quyang_zhongzhi_shenqing_qingyandan_link_20260723.sql");

        require(entity, "@TableName(\"lims_sxt_quyang_zhongzhi_shenqing\")",
                "sampling termination entity must map the application table");
        require(entity, "private String bizStatus;", "entity must expose biz_status");
        require(entity, "private String fTenantId;", "entity must expose the composite primary-key tenant id");
        require(mapper, "SuperMapper<LimsSxtQuyangZhongzhiShenqingEntity>",
                "sampling termination mapper must support status updates");
        require(childEntity, "@TableName(\"lims_sxt_quyang_zhongzhi_shenqing_zixiang\")",
                "sampling termination child entity must map selected sampling tasks");
        require(childEntity, "@TableField(\"qingyandan_id\")",
                "sampling termination child must retain its selected qingyandan id");
        require(childMapper, "SuperMapper<LimsSxtQuyangZhongzhiShenqingZixiangEntity>",
                "sampling termination child mapper must load selected sampling tasks");
        require(bizStatus, "DELETED(\"deleted\", \"已废弃\")",
                "sampling termination must reuse the existing deleted status");
        requireAbsent(bizStatus, "TERMINATED(",
                "sampling termination must not introduce a separate terminated status");
        require(service, "findQuyangZhongzhiShenqingByFlow",
                "flow synchronization must locate sampling termination applications");
        require(service, "syncQuyangZhongzhiShenqingStarted",
                "start events must set sampling termination applications to processing");
        require(service, "syncQuyangZhongzhiShenqingEnded",
                "end events must set sampling termination applications to completed");
        require(service, "syncApprovedQuyangTerminationStatus",
                "approved termination events must synchronize linked sampling applications");
        require(service, "BizStatus.DELETED", "approved termination must set the sampling status to deleted");
        require(service, "BizStatus.PENDING_FETCH", "only pending sampling applications may be terminated");
        require(service, "terminatePendingQingyandan(LimsSxtQuyangZhongzhiShenqingZixiangEntity child)",
                "termination must update the qingyandan id saved by the selected child");
        require(service, "多个取样终止申请关联同一流程任务",
                "duplicate sampling termination flow bindings must be rejected");
        require(service, "getFTenantId", "sampling termination status updates must be tenant-scoped");
        require(schema, "biz_status varchar(50) DEFAULT 'pending'",
                "fresh PostgreSQL schema must default sampling termination applications to pending");
        require(schema, "qingyandan_id varchar(50)",
                "fresh PostgreSQL schema must retain selected qingyandan ids");
        require(migration, "ALTER TABLE lims_sxt_quyang_zhongzhi_shenqing",
                "existing PostgreSQL deployments must receive the status column migration");
        require(migration, "ADD COLUMN IF NOT EXISTS biz_status varchar(50);",
                "migration must add the status column without a default before historical backfill");
        require(migration, "SET biz_status = CASE", "migration must backfill existing application statuses");
        require(migration, "OR (biz_status = 'pending' AND f_flow_state IN (1, 2, 3, 4, 5, 6, 7, 8, 9))",
                "migration must correct pending defaults created while importing historical non-pending workflows");
        requireOrder(migration, "UPDATE lims_sxt_quyang_zhongzhi_shenqing",
                "ALTER COLUMN biz_status SET DEFAULT 'pending'",
                "migration must backfill historical statuses before applying the default");
        require(qingyandanLinkMigration, "ADD COLUMN IF NOT EXISTS qingyandan_id varchar(50)",
                "existing PostgreSQL deployments must receive the qingyandan link column");
    }

    private static String read(String relativePath) throws IOException {
        return new String(Files.readAllBytes(REPOSITORY_ROOT.resolve(relativePath)), StandardCharsets.UTF_8);
    }

    private static void require(String source, String expected, String message) {
        if (!source.contains(expected)) {
            throw new AssertionError(message);
        }
    }

    private static void requireAbsent(String source, String unexpected, String message) {
        if (source.contains(unexpected)) {
            throw new AssertionError(message);
        }
    }

    private static void requireOrder(String source, String first, String second, String message) {
        if (source.indexOf(first) >= source.indexOf(second)) {
            throw new AssertionError(message);
        }
    }
}