import { NextRequest, NextResponse } from "next/server";
import sql from "mssql";
import { apiLogger, formatError } from "../../../server/logger";

const SLOW_QUERY_MS = 3000;

const dbConfig = {
  server: process.env.DB_SERVER!,
  port: 1433,
  database: process.env.DB_DATABASE!,
  user: process.env.DB_USER!,
  password: process.env.DB_PASSWORD!,
  requestTimeout: 60000,
  options: {
    trustServerCertificate: process.env.DB_TRUST_CERT === "true",
    encrypt: false,
  },
};

export async function GET(request: NextRequest) {
  const workshopNo = request.nextUrl.searchParams.get("workshopNo");

  if (!workshopNo) {
    return NextResponse.json(
      { error: "请提供车间号参数" },
      { status: 400 }
    );
  }

  let pool: sql.ConnectionPool | undefined;
  const t0 = Date.now();
  try {
    pool = await sql.connect(dbConfig);
    const result = await pool
      .request()
      .input("车间号", sql.NVarChar(50), workshopNo)
      .execute(
        "[productionContractData].[sp_压力表合同生产数据_按车间号]"
      );

    const recordset = result.recordset;
    if (!recordset || recordset.length === 0) {
      return NextResponse.json({ columns: [], data: [], total: 0 });
    }

    const columns = Object.keys(recordset[0]);
    const data = recordset.map((row: Record<string, unknown>) => {
      const serialized: Record<string, unknown> = {};
      for (const key of columns) {
        const val = row[key];
        if (val instanceof Date) {
          serialized[key] = val.toISOString().split("T")[0];
        } else {
          serialized[key] = val;
        }
      }
      return serialized;
    });

    const dur = Date.now() - t0;
    if (dur > SLOW_QUERY_MS) {
      apiLogger.warn(`slow query · workshopNo=${workshopNo} · dur=${dur}ms · rows=${data.length}`);
    }
    return NextResponse.json({ columns, data, total: data.length });
  } catch (err) {
    const dur = Date.now() - t0;
    const message = err instanceof Error ? err.message : "Unknown error";
    apiLogger.error(`query failed · workshopNo=${workshopNo} · dur=${dur}ms · ${formatError(err)}`);
    return NextResponse.json({ error: message }, { status: 500 });
  } finally {
    if (pool) {
      await pool.close();
    }
  }
}