Apple 指控 OpenAI 销毁关键证据 涉及 AI 硬件商业机密诉讼

import os
import json
import hashlib
import datetime
import requests
from typing import Dict, Any, Optional

class EnterpriseAIGateway:
    def __init__(self, api_key: str, base_url: str = "https://api.n1n.ai/v1"):
        self.api_key = api_key
        self.base_url = base_url
        self.audit_log_file = "enterprise_ai_audit_log.jsonl"

    def _create_request_hash(self, payload: Dict[str, Any]) -> str:
        """生成请求载荷的哈希指纹，用于合规审计与追溯"""
        raw_data = json.dumps(payload, sort_keys=True).encode('utf-8')
        return hashlib.sha256(raw_data).hexdigest()

    def _write_audit_log(self, model: str, req_hash: str, status_code: int, duration_ms: float):
        """记录本地不可篡改的日志条目"""
        log_entry = {
            "timestamp": datetime.datetime.utcnow().isoformat() + "Z",
            "model": model,
            "request_hash": req_hash,
            "status_code": status_code,
            "duration_ms": round(duration_ms, 2)
        }
        with open(self.audit_log_file, "a", encoding="utf-8") as f:
            f.write(json.dumps(log_entry, ensure_ascii=False) + "\n")

    def chat_completion(
        self, 
        model: str, 
        messages: list, 
        temperature: float = 0.7
    ) -> Optional[Dict[str, Any]]:
        headers = {
            "Authorization": f"Bearer {self.api_key}",
            "Content-Type": "application/json"
        }
        payload = {
            "model": model,
            "messages": messages,
            "temperature": temperature
        }
        
        req_hash = self._create_request_hash(payload)
        start_time = datetime.datetime.now()
        
        try:
            response = requests.post(
                f"{self.base_url}/chat/completions",
                headers=headers,
                json=payload,
                timeout=30
            )
            duration = (datetime.datetime.now() - start_time).total_seconds() * 1000
            self._write_audit_log(model, req_hash, response.status_code, duration)
            
            if response.status_code == 200:
                return response.json()
            else:
                print(f"API 调用异常 [{response.status_code}]: {response.text}")
                return None
        except Exception as err:
            print(f"网络或系统级错误: {str(err)}")
            return None

# 使用示例
if __name__ == "__main__":
    # 从环境变量中获取 n1n.ai 的 API 密钥
    API_KEY = os.getenv("N1N_API_KEY", "your-n1n-api-key-here")
    gateway = EnterpriseAIGateway(api_key=API_KEY)
    
    messages = [
        {"role": "system", "content": "你是一名企业级 AI 安全与合规顾问。"},
        {"role": "user", "content": "请简述企业在研发 AI 硬件时如何防范代码与商业机密泄露。"}
    ]
    
    # 通过 n1n.ai 极速 API 接口请求 OpenAI 模型
    res = gateway.chat_completion(model="gpt-4o", messages=messages)
    if res:
        print("成功获取大模型响应：")
        print(res["choices"][0]["message"]["content"][:150] + "...")