import { postgrestGet, type PostgrestParams, postgrestPut, postgrestPost } from "../postgrest-client";
import {getDocument} from "~/api/files/documents";
import { formatDate } from "~/utils";
  
/**
 * 从不同格式的 API 响应中提取数据
 * @param responseData API 响应数据
 * @returns 提取后的数据或 null
 */
function extractApiData<T>(responseData: unknown): T | null {
if (!responseData) return null;

// 格式1: { code: number, msg: string, data: T }
if (typeof responseData === 'object' && responseData !== null && 
    'code' in responseData && 
    'data' in responseData && 
    (responseData as { data: unknown }).data) {
    return (responseData as { data: T }).data;
}

// 格式2: 直接是数据对象
return responseData as T;
}

// 定义评查结果类型
interface EvaluationResult {
  id: string | number;
  document_id: string | number;
  evaluation_point_id: string | number;
  evaluated_results?: {
    result?: boolean;
    message?: string;
    data?: string;
    [key: string]: unknown;
  };
  [key: string]: unknown;
}

// 定义评查点类型
interface EvaluationPoint {
  id: string | number;
  evaluation_point_groups_id: string | number;
  suggestion_message_type?: string;
  suggestion_message?: string;
  score?: number;
  updated_at?: string;
  [key: string]: unknown;
}

// 定义审核状态类型
interface AuditStatus {
  id: string | number;
  document_id: string | number;
  evaluation_point_id: string | number;
  edit_audit_status: number;
  [key: string]: unknown;
}

// 定义评查点组类型
interface EvaluationPointGroup {
  id: string | number;
  name?: string;
  [key: string]: unknown;
}

// 定义前端使用的评查点结果类型
interface ReviewPointResult {
  id: string | number;
  title: string;
  groupName: string;
  status: string;
  content: string;
  suggestion: string;
  result?: boolean;
  score: number;
  evaluatedPointResultsLog?: Array<Record<string, unknown>>;
}

// 定义统计数据类型
interface StatsData {
  total: number;
  success: number;
  warning: number;
  error: number;
  score: number;
}

// 在文件顶部添加的类型定义，在interface区块前添加
interface OcrDataResult {
  pages?: number[];
  [key: string]: unknown;
}

interface OcrData {
  ocr_result?: Record<string, OcrDataResult>;
  [key: string]: unknown;
}

/**
 * 获取当前评查文件的所有评查点结果
 * @param fileId 评查文件ID
 * @returns 评查点结果列表和统计数据
 */ 
export async function getReviewPoints(fileId: string) {
    // 首先先获取这个文档的数据
    const documentData = await getDocument(fileId);
    if (documentData.error) {
      console.error("获取文档数据错误:", documentData.error);
      return Response.json({ error: documentData.error }, { status: documentData.status || 500 });
    }

    // 步骤1：根据fileId查询evaluation_results表
    const evaluationResultsParams: PostgrestParams = {
        select: '*',
        filter: {
            'document_id': `eq.${fileId}`
        }
    };
    const evaluationResultsResponse = await postgrestGet('evaluation_results', evaluationResultsParams);

    if (evaluationResultsResponse.error) {
        return { error: evaluationResultsResponse.error, status: evaluationResultsResponse.status };
    }

    // 评查结果数据
    const evaluationResultsData = extractApiData<EvaluationResult[]>(evaluationResultsResponse.data) || [];
    
    if (Array.isArray(evaluationResultsData) && evaluationResultsData.length <= 0) {
        return { data: [], stats: { total: 0, success: 0, warning: 0, error: 0, score: 0 },error: '获取评查结果数据失败' };
    }

    // 收集所有评查点ID，用于查询评查点详情
    const evaluationPointIds = evaluationResultsData.map(item => item.evaluation_point_id).filter(Boolean);
    
    if (evaluationPointIds.length === 0) {
        return { data: [], stats: { total: 0, success: 0, warning: 0, error: 0, score: 0 },error: '获取评查点ID失败' };
    }

    // 步骤2：根据evaluation_point_id查询evaluation_points表
    const evaluationPointsParams: PostgrestParams = {
        select: '*',
        filter: {
            'id': `in.(${evaluationPointIds.join(',')})`
        }
    };
    const evaluationPointsResponse = await postgrestGet('evaluation_points', evaluationPointsParams);

    if (evaluationPointsResponse.error) {
        return { error: evaluationPointsResponse.error, status: evaluationPointsResponse.status };
    }

    const evaluationPointsData = extractApiData<EvaluationPoint[]>(evaluationPointsResponse.data);
    
    if (!evaluationPointsData || !Array.isArray(evaluationPointsData)) {
        return { data: [], stats: { total: 0, success: 0, warning: 0, error: 0, score: 0 } };
    }

    // 收集所有评查点组ID，用于查询评查点组详情
    const groupIds = evaluationPointsData.map(item => item.evaluation_point_groups_id).filter(Boolean);

    if (groupIds.length === 0) {
        return { data: [], stats: { total: 0, success: 0, warning: 0, error: 0, score: 0 } };
    }

    // 步骤3：查询评查点组
    const groupsParams: PostgrestParams = {
        select: '*',
        filter: {
            'id': `in.(${groupIds.join(',')})`
        }
    };
    const groupsResponse = await postgrestGet('evaluation_point_groups', groupsParams);

    if (groupsResponse.error) {
        return { error: groupsResponse.error, status: groupsResponse.status };
    }

    const groupsData = extractApiData<EvaluationPointGroup[]>(groupsResponse.data);
    
    if (!groupsData || !Array.isArray(groupsData)) {
        return { data: [], stats: { total: 0, success: 0, warning: 0, error: 0, score: 0 } };
    }

    // 步骤4：从audit_status表中 获取 需人工审核 的那些评查点的数据
    // console.log('evaluationPointsData1112------', evaluationPointsData.find(point => point.post_action === 'manual'));
    const manualReviewPoints = evaluationPointsData.filter(point => point.post_action === 'manual');
    const manualReviewPointsIds = manualReviewPoints.map(point => point.id);
    const manualReviewPointsParams: PostgrestParams = {
        select: '*',
        filter: {
            'document_id': `eq.${fileId}`,
            'evaluation_point_id': `in.(${manualReviewPointsIds.join(',')})`
        }
    };
    const manualReviewPointsResponse = await postgrestGet('audit_status', manualReviewPointsParams);
    if (manualReviewPointsResponse.error) {
        return { error: manualReviewPointsResponse.error, status: manualReviewPointsResponse.status };
    }
    const manualReviewPointsData = extractApiData<AuditStatus[]>(manualReviewPointsResponse.data);
    
    // 构建评查点ID到editAuditStatus的映射
    const editAuditStatusMap = new Map<string | number, {id: string | number, status: number}>();
    
    // 如果有查询结果，则根据evaluation_point_id索引到对应数据
    if (manualReviewPointsData && Array.isArray(manualReviewPointsData)) {
        manualReviewPointsData.forEach(auditStatus => {
            if (auditStatus.evaluation_point_id && auditStatus.edit_audit_status !== undefined) {
                editAuditStatusMap.set(auditStatus.evaluation_point_id, {id: auditStatus.id, status: auditStatus.edit_audit_status});
            }
        });
    }
    
    // 为没有对应audit_status记录的manual类型评查点设置默认值0
    if (manualReviewPointsIds.length > 0) {
        manualReviewPointsIds.forEach(pointId => {
            if (!editAuditStatusMap.has(pointId)) {
                editAuditStatusMap.set(pointId, {id: '', status: 0});
            }
        });
    }
    
    // console.log('manualReviewPoints-------', manualReviewPoints);


    // 创建映射关系以便快速查找
    const pointsMap = new Map<string | number, EvaluationPoint>();
    evaluationPointsData.forEach(point => {
        pointsMap.set(point.id, point);
    });

    // console.log('pointsMap-------', pointsMap);

    const groupsMap = new Map<string | number, EvaluationPointGroup>();
    groupsData.forEach(group => {
        groupsMap.set(group.id, group);
    });

    // console.log('groupsMap-------', groupsMap);

    // 构建前端所需的数据格式
    const resultData: ReviewPointResult[] = evaluationResultsData.map(result => {
        const point = pointsMap.get(result.evaluation_point_id) || {} as EvaluationPoint;
        const group = groupsMap.get(point.evaluation_point_groups_id || 0) || {} as EvaluationPointGroup;
        const editAuditStatus = editAuditStatusMap.get(result.evaluation_point_id) || {id: '', status: 0};

        // 评查结果内容改成由evaluated_point_results_log中获取
        // const evaluatedPointResultsLog = result.evaluated_point_results_log;
        // console.log('evaluatedPointResultsLog-------', evaluatedPointResultsLog);

        
        // 从 evaluated_results 中提取数据
        let message = '';
        let data = '';
        
        if (result.evaluated_results && typeof result.evaluated_results === 'object') {
            message = result.evaluated_results.message || '';
            data = result.evaluated_results.data || '';
        }

        // 提取页码数组
        let contentPage: Record<string, string> = {};
        // console.log('result-------', result.evaluated_results?.result);
        // console.log('datacontent-------', data);
        // console.log('documentData-------', documentData);
        if (data && typeof data === 'object') {
            // 4-22 更改数据结构：通过拿到的data数据（每一个key对应一个object），将object中的page提取出来
            try{
              const dataObj = data as Record<string, {page: number | string,value: string}>;
              for (const key in dataObj) {
                if (Object.prototype.hasOwnProperty.call(dataObj, key)) {
                  let newPage = dataObj[key].page.toString();
                  // 如果newPage里面有文本，则把文本去掉
                  if(newPage.match(/\d+/g)){
                    newPage = newPage.match(/^\d+/g)?.map(Number).join('') || '';
                  }
                  contentPage[key] = newPage;
                }

                // 如果contentPage[key]为空，则需要根据这个key去ocrResult中找到对应的key，然后根据ocrResult中的pages数组，找到对应的页码
                if(!contentPage[key]){
                  // 分割key获取数组的第一位
                  const keyArray = key.split('-');
                  const ocrResult = documentData?.data?.ocrResult as OcrData;
                  const pages = ocrResult?.ocr_result?.[keyArray[0]]?.pages;
                  contentPage[key] = pages?.[0]?.toString() || '';
                }
              }
            }
            catch (e) {
                console.error('解析评查点data失败:', e);
                contentPage = {};
            }
        }

        return {
            id: result.id,
            documentId: fileId,
            pointId: point.id,
            editAuditStatusId: editAuditStatus.id,
            editAuditStatus: editAuditStatus.status,
            title: message,
            pointName: point.name || '',
            groupName: group.name || '',

            status: point.suggestion_message_type || '',    //评查点的评查结果状态
            // status: 'error',    //评查点的评查结果状态

            content: data,

            contentPage: contentPage,

            suggestion: point.suggestion_message || '',
            // suggestion: '只是给建议的修改内容',

            result: result.evaluated_results?.result, // 记录评查结果，用于统计
            score: point.score || 0,

            postAction: point.post_action || '',
            // postAction: 'manual',

            actionContent: point.action_config || '',
            // actionContent: '用户提前在评查点输入过的修改内容',

            legalBasis: point.references_laws || {},
            // legalBasis: {
            //   name: '中华人民共和国食品安全法', 
            //   content: '中华人民共和国食品安全法',
            //   article: [
            //     {
            //       name: '中华人民共和国食品安全法',
            //       content: '中华人民共和国食品安全法'
            //     }
            //   ]
            // }

            // 评查配置: point.evaluation_config
            evaluationConfig: point.evaluation_config || {},

            // evaluatedPointResultsLog: evaluatedPointResultsLog || {}
            evaluatedPointResultsLog: [
              {
                  "id": "1",
                  "type": "consistency",
                  "config": {
                      "logic": "and",
                      "pairs": [
                          {
                              "sourceField": {"现场笔录-被检查人名称":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-营业执照-名称":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"现场笔录-法定代表人（负责人）":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-营业执照-法定代表人":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"现场笔录-烟草专卖许可证号码":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-烟草专卖零售许可证-许可证号":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"证据复制（提取）单-烟草专卖零售许可证-企业名称":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-营业执照-名称":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"证据复制（提取）单-烟草专卖零售许可证-负责人姓名":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-营业执照-法定代表人":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"立案报告表-当事人-单位-名称":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-营业执照-名称":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"立案报告表-当事人-单位-法定代表人（负责人）":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-营业执照-法定代表人":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"立案报告表-当事人-单位-地址":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-营业执照-住所":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          }
                      ],
                      "selectedFields": []
                  }
              },
              {
                  "id": "2",
                  "type": "consistency",
                  "config": {
                      "logic": "and",
                      "pairs": [
                          {
                              "sourceField": {"现场笔录-被检查人姓名":{page: 1,value: '张三'}},
                              "targetField": {"立案报告表-当事人-个人（个体工商户）-姓名":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"立案报告表-当事人-个人（个体工商户）-姓名":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-居民身份证-姓名":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"现场笔录-性别":{page: 1,value: '张三'}},
                              "targetField": {"立案报告表-当事人-个人（个体工商户）-性别":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"立案报告表-当事人-个人（个体工商户）-性别":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-居民身份证-性别":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"现场笔录-证件类型及号码":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-居民身份证-公民身份号码":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"现场笔录-地址":{page: 1,value: '张三'}},
                              "targetField": {"立案报告表-当事人-个人（个体工商户）-住址":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          },
                          {
                              "sourceField": {"立案报告表-当事人-个人（个体工商户）-住址":{page: 1,value: '张三'}},
                              "targetField": {"证据复制（提取）单-居民身份证-住址":{page: 1,value: '张三'}},
                              "compareMethod": "exact",
                              "result": true
                          }
                      ],
                      "selectedFields": []
                  }
              }
          ]
        };
    });

    // 统计数据
    const stats: StatsData = {
        total: evaluationResultsData.length,
        success: 0,
        warning: 0,
        error: 0,
        score: 0
    };

    // 计算统计数据
    resultData.forEach(item => {
        // 成功数量统计
        if (item.result === true) {
            stats.success += 1;
        } else if (item.result === false) {
            // 警告和错误数量统计
            if (item.status === 'warning') {
                stats.warning += 1;
            } else if (item.status === 'error') {
                stats.error += 1;
            }
        }
        
        // 分数统计
        stats.score += item.score || 0;
    });

    // 构建文件信息-评查信息的数据
    // 找出最新的评查时间
    let latestUpdatedAt = '';
    evaluationResultsData.forEach(result => {
      if (result.updated_at && (!latestUpdatedAt || result.updated_at > latestUpdatedAt)) {
        latestUpdatedAt = result.updated_at.toString();
      }
    });

    // 提取不重复的规则组名称
    const uniqueGroups = Array.from(new Set(resultData.map(item => item.groupName))).filter(Boolean);
    
    // 计算问题数量
    const issueCount = stats.warning + stats.error;
    
    // 构建评查信息对象
    const reviewInfo = {
      reviewTime: formatDate(latestUpdatedAt),
      reviewModel: 'DeepSeek',
      ruleGroup: uniqueGroups.join('、'),
      result: issueCount > 0 ? 'warning' : 'success',
      issueCount: issueCount
    };
    // console.log("reviewInfo-------",JSON.stringify(reviewInfo,null,2));
    // data->reviewPoints   stats->statistics   reviewInfo->reviewInfo   document->document
    return { data: resultData, stats, reviewInfo, document: documentData.data };
}

/**
 * 更新评查结果
 * @param resultId 评查结果ID
 * @param editAuditStatusId 审核状态ID
 * @param result 评查结果 (true/false)
 * @param message 评查意见
 * @returns 更新后的评查结果
 */
export async function updateReviewResult(resultId: string, editAuditStatusId: string | number, result: string, message: string): Promise<{
  data?: unknown;
  error?: string;
  status?: number;
}> {
  try {
    if (!resultId) {
      return { error: '评查结果ID不能为空', status: 400 };
    }
    
    // 首先获取当前评查结果数据
    const currentResultResponse = await postgrestGet('evaluation_results', {
      select: '*',
      filter: { id: `eq.${resultId}` }
    });
    
    if (currentResultResponse.error) {
      return { error: currentResultResponse.error, status: currentResultResponse.status };
    }
    
    const currentResultData = extractApiData<EvaluationResult[]>(currentResultResponse.data);
    
    if (!currentResultData || !Array.isArray(currentResultData) || currentResultData.length === 0) {
      return { error: '未找到评查结果数据', status: 404 };
    }
    
    const currentResult = currentResultData[0];
    const currentEvaluatedResults = currentResult.evaluated_results || {};
    
    // 判断是否是重新审核操作
    const isReview = result === 'review';
    console.log('isReview-------', result);
    
    // 构建要更新的数据，保留原有字段
    const updatedEvaluatedResults = {
      ...currentEvaluatedResults,
      // 如果是重新审核操作，不更新result，只更新message
      ...(isReview ? { message } : { result: result === 'true' ? true : false, message }),
    };
    
    const updatedData = {
      evaluated_results: updatedEvaluatedResults
    };
    
    // 调用 API 更新评查点结果数据
    const resultResponse = await postgrestPut<unknown, typeof updatedData>(
      'evaluation_results',
      updatedData,
      { id: resultId }
    );
    
    if (resultResponse.error) {
      return { error: resultResponse.error, status: resultResponse.status };
    }
    
    // 处理audit_status表的更新或新增
    // 确定edit_audit_status的值：
    // 如果是重新审核操作，值为0；否则值为1
    const editAuditStatusValue = isReview ? 0 : 1;
    console.log('editAuditStatusValue-------', editAuditStatusValue);
    console.log('editAuditStatusId-------', editAuditStatusId);
    if (editAuditStatusId && editAuditStatusId !== '') {
      // 更新现有审核状态记录
      const auditStatusResponse = await postgrestPut(
        'audit_status',
        { edit_audit_status: editAuditStatusValue },
        { id: editAuditStatusId }
      );
      
      if (auditStatusResponse.error) {
        return { error: auditStatusResponse.error, status: auditStatusResponse.status || 500 };
      }
    } else {
      // 如果没有editAuditStatusId，则创建新记录
      // 首先获取文档ID和评查点ID
      const documentId = currentResult.document_id;
      const evaluationPointId = currentResult.evaluation_point_id;
      
      // 创建新的审核状态记录
      const newAuditStatus = {
        document_id: documentId,
        evaluation_point_id: evaluationPointId,
        evaluation_result_id: resultId,
        edit_audit_status: editAuditStatusValue
      };
      
      // 使用postgrestPost创建新记录
      const postResponse = await postgrestPost('audit_status', newAuditStatus);
      
      if (postResponse.error) {
        return { error: postResponse.error, status: postResponse.status || 500 };
      }
    }
    
    const extractedData = extractApiData<unknown>(resultResponse.data);
    
    if (!extractedData) {
      return { error: '更新评查结果失败', status: 500 };
    }
    
    return { data: extractedData };
  } catch (error) {
    console.error('更新评查结果失败:', error);
    return {
      error: error instanceof Error ? error.message : '更新评查结果失败',
      status: 500
    };
  }
}

/**
 * 确认评查结果并更新文档审核状态 只更新文档的审核状态为通过
 * @param documentId 文档ID
 * @returns 更新结果
 */
export async function confirmReviewResults(documentId: string): Promise<{
  data?: { auditStatus: number; };
  error?: string;
  status?: number;
}> {
  try {
    if (!documentId) {
      return { error: '文档ID不能为空', status: 400 };
    }
    
    // 获取该文档的所有评查点结果
    // const reviewPointsResponse = await getReviewPoints(documentId);
    
    // if ('error' in reviewPointsResponse && reviewPointsResponse.error) {
    //   return { error: reviewPointsResponse.error, status: reviewPointsResponse.status };
    // }
    
    // if (!('data' in reviewPointsResponse) || !reviewPointsResponse.data || !Array.isArray(reviewPointsResponse.data)) {
    //   return { error: '获取评查点数据失败', status: 500 };
    // }
    
    // // 计算总分数
    // const totalScore = reviewPointsResponse.stats?.score || 0;
    
    // // 根据总分确定审核状态
    // // <80分：不通过（-1），>=80分：通过（1）
    // const auditStatus = totalScore < 80 ? -1 : 1;
    
    // 更新文档的审核状态
    const updateDocumentParams = {
      audit_status: 1
    };
    
    // 调用API更新文档审核状态
    const response = await postgrestPut<{ id: string }, typeof updateDocumentParams>(
      'documents',
      updateDocumentParams,
      { id: documentId }
    );
    
    if (response.error) {
      return { error: response.error, status: response.status };
    }
    
    return { data: { auditStatus: 1} };
  } catch (error) {
    console.error('确认评查结果失败:', error);
    return {
      error: error instanceof Error ? error.message : '确认评查结果失败',
      status: 500
    };
  }
}