ylrz_his_scrm_companyUI/src/api/aiSipCall/softPhone.js

// softPhone.js - WebPhone核心逻辑与配置管理
import * as JsSIP from 'jssip';

export const RINGBACK_AUDIO_URL = '/assets/voice/ringback.wav';

export const IPCC_DEFAULTS = {
  SERVER_PROD: 'sip.ylrzcloud.com',
  CONNECT_TIMEOUT: 8000,
  RECONNECT_CONNECT_TIMEOUT: 3000,
  RECONNECT_DELAY_MS: 100,
  RECONNECT_DELAY_IN_CALL_MS: 150,
  HEARTBEAT_INTERVAL: 16,
  TOKEN_TTL_MS: 60 * 60 * 1000,
  GATEWAY_RELEASE_DELAY_MS: 200,
  SERVER_RELEASE_DELAY_MS: 300,
  DISCONNECT_WAIT_MS: 800,
  AGENT_READY_TIMEOUT_MS: 3000,
  SIP_REGISTER_TIMEOUT_MS: 8000,
  READY_RESTORE_INITIAL_MS: 50,
  READY_RESTORE_INTERVAL_MS: 120,
  READY_RESTORE_MAX_ATTEMPTS: 12,
  STATUS_BUSY_DELAY_MS: 150,
  POST_CALL_READY_DEADLINE_MS: 3000
};
const SESSION_CONFIRMED_STATUS = 9;
/** JsSIP RTCSession.STATUS_ANSWERED — 已发送 200，不可再次 answer */
const SESSION_ANSWERED_STATUS = 5;
/** JsSIP RTCSession.STATUS_WAITING_FOR_ACK */
const SESSION_WAITING_ACK_STATUS = 6;
/** JsSIP RTCSession.STATUS_1XX_RECEIVED — 可 answer 的状态含 2/3/4 */
const SESSION_ANSWERABLE_STATUSES = [2, 3, 4];

export const JS_SIP_DEFAULTS = {
  SERVER: 'wss://sip.ylrzcloud.com:8443',
  DOMAIN: 'sip.ylrzcloud.com',
  TRANSPORT: 'wss',
  USER_AGENT: 'JsSIP',
  SESSION_EXPIRES: 180,
  MIN_SESSION_EXPIRES: 90,
  SPEAKER_VOLUME: 0.8,
  MIC_VOLUME: 0.8,
  RECONNECT_INTERVAL: 3,
  RECONNECT_TOTAL_DURATION: 60000
};

const toBase64 = (str) => {
  const bytes = new TextEncoder().encode(str);
  return btoa(String.fromCharCode(...bytes));
};
const fromBase64 = (b64) => {
  const binary = atob(b64);
  const bytes = Uint8Array.from(binary, (c) => c.charCodeAt(0));
  return new TextDecoder().decode(bytes);
};
const encodePassword = (pwd) => {
  if (!pwd) return '';
  try {
    const timestamp = Date.now().toString(36);
    const pwdStr = String(pwd);
    const encoded = toBase64(pwdStr);
    return `${timestamp}:${encoded}`;
  } catch (e) {
    try { return btoa(String(pwd)); } catch (fallbackError) { return ''; }
  }
};
const decodePassword = (encoded) => {
  if (!encoded) return '';
  try {
    let base64Part = encoded;
    if (encoded.includes(':')) base64Part = encoded.split(':')[1];
    return fromBase64(base64Part);
  } catch (e) { return ''; }
};

/** 优先约束：开启回声消除等增强；失败后自动降级 */
const MIC_AUDIO_CONSTRAINTS_ENHANCED = {
  audio: { echoCancellation: true, noiseSuppression: true, autoGainControl: true },
  video: false
};
/** 兼容约束：部分浏览器/驱动对增强项会报 Requested device not found */
const MIC_AUDIO_CONSTRAINTS_BASIC = {
  audio: true,
  video: false
};
/** JsSIP answer/call 用的媒体约束（与 BASIC 对齐，避免二次失败） */
export const MIC_MEDIA_CONSTRAINTS = {
  audio: true,
  video: false
};

/** 兼容旧浏览器：补齐 mediaDevices.getUserMedia */
export function ensureMediaDevices() {
  if (typeof navigator === 'undefined') return false;
  if (!navigator.mediaDevices) {
    navigator.mediaDevices = {};
  }
  if (!navigator.mediaDevices.getUserMedia) {
    const legacy = navigator.getUserMedia || navigator.webkitGetUserMedia || navigator.mozGetUserMedia || navigator.msGetUserMedia;
    if (!legacy) return false;
    navigator.mediaDevices.getUserMedia = (constraints) => new Promise((resolve, reject) => {
      legacy.call(navigator, constraints, resolve, reject);
    });
  }
  return typeof navigator.mediaDevices.getUserMedia === 'function';
}

function formatMicError(err) {
  const name = err?.name || '';
  const msg = err?.message || String(err || '');
  if (name === 'NotFoundError' || /Requested device not found/i.test(msg)) {
    return '未检测到可用麦克风，请检查设备连接后重试';
  }
  if (name === 'NotAllowedError' || name === 'PermissionDeniedError' || /Permission|Denied|Access/i.test(msg)) {
    return '麦克风权限被拒绝，请在浏览器地址栏允许麦克风后刷新重试';
  }
  if (name === 'NotReadableError' || name === 'TrackStartError') {
    return '麦克风被其他程序占用，请关闭后重试';
  }
  if (name === 'OverconstrainedError' || name === 'ConstraintNotSatisfiedError') {
    return '当前麦克风不支持该音频参数，已尝试兼容模式';
  }
  if (/secure|HTTPS|getUserMedia/i.test(msg)) {
    return '当前环境无法访问麦克风（需 HTTPS 或 localhost）';
  }
  return msg || '麦克风初始化失败';
}

export function releaseMediaStream(stream) {
  if (!stream) return;
  stream.getTracks().forEach((track) => {
    try { track.stop(); } catch (e) {}
  });
}

/**
 * 申请麦克风：增强约束失败时自动降级为 audio:true，提升浏览器兼容性
 */
export async function requestMicrophoneAccess() {
  if (!ensureMediaDevices()) {
    throw new Error('浏览器不支持麦克风');
  }
  const attempts = [MIC_AUDIO_CONSTRAINTS_ENHANCED, MIC_AUDIO_CONSTRAINTS_BASIC];
  let lastError = null;
  for (let i = 0; i < attempts.length; i++) {
    try {
      const stream = await navigator.mediaDevices.getUserMedia(attempts[i]);
      if (stream?.getAudioTracks?.().length) {
        return stream;
      }
      releaseMediaStream(stream);
      lastError = new Error('未获取到麦克风音轨');
    } catch (err) {
      lastError = err;
      // 权限明确拒绝时不再降级重试
      const name = err?.name || '';
      if (name === 'NotAllowedError' || name === 'PermissionDeniedError') {
        break;
      }
    }
  }
  throw new Error(formatMicError(lastError));
}

export async function checkMicrophonePermission() {
  if (!ensureMediaDevices()) return false;
  try {
    if (navigator.permissions?.query) {
      const status = await navigator.permissions.query({ name: 'microphone' });
      return status.state !== 'denied';
    }
    return true;
  } catch (err) {
    return true;
  }
}

export class ProfileManager {
  constructor() { this.profile = null; this.load(); }
  load() {
    try {
      const json = localStorage.getItem('WebPhoneProfile');
      if (!json) this.reset();
      else {
        this.profile = JSON.parse(json);
        if (this.profile.users) {
          Object.keys(this.profile.users).forEach(uid => {
            const user = this.profile.users[uid];
            if (user.password && typeof user.password === 'string') user.password = decodePassword(user.password);
          });
        }
      }
    } catch (error) { this.reset(); }
  }
  save() {
    const toStore = JSON.parse(JSON.stringify(this.profile));
    if (toStore.users) {
      Object.keys(toStore.users).forEach(uid => {
        const user = toStore.users[uid];
        if (user.password && typeof user.password === 'string') user.password = encodePassword(user.password);
      });
    }
    localStorage.setItem('WebPhoneProfile', JSON.stringify(toStore));
  }
  reset() {
    this.profile = {
      users: {}, user: '', reconnect: true, reconnect_interval: JS_SIP_DEFAULTS.RECONNECT_INTERVAL,
      user_agent: JS_SIP_DEFAULTS.USER_AGENT, session_expires: JS_SIP_DEFAULTS.SESSION_EXPIRES,
      min_session_expires: JS_SIP_DEFAULTS.MIN_SESSION_EXPIRES, speaker_volume: JS_SIP_DEFAULTS.SPEAKER_VOLUME,
      mic_volume: JS_SIP_DEFAULTS.MIC_VOLUME, speaker_paused: false, mic_paused: false,
      auto_answer: true, stun: false, ice_server: ''
    };
    this.save();
  }
  getProfile() { return this.profile; }
  getSettings() {
    let reconnectInterval = this.profile.reconnect_interval || 15;
    if (reconnectInterval > 1000) {
      reconnectInterval = Math.floor(reconnectInterval / 1000);
      this.profile.reconnect_interval = reconnectInterval;
      this.save();
    }
    const currentUser = this.getCurrentUserProfile() || {};
    return {
      user_agent: this.profile.user_agent, session_expires: this.profile.session_expires,
      min_session_expires: this.profile.min_session_expires, stun: this.profile.stun,
      ice_server: this.profile.ice_server,
      auto_answer: currentUser.auto_answer !== undefined ? currentUser.auto_answer : this.profile.auto_answer,
      reconnect: this.profile.reconnect, reconnect_interval: reconnectInterval
    };
  }
  updateSettings(settings) { Object.assign(this.profile, settings); this.save(); }
  resetSettings() {
    this.profile.reconnect = true;
    this.profile.reconnect_interval = JS_SIP_DEFAULTS.RECONNECT_INTERVAL;
    this.profile.user_agent = JS_SIP_DEFAULTS.USER_AGENT;
    this.profile.session_expires = JS_SIP_DEFAULTS.SESSION_EXPIRES;
    this.profile.min_session_expires = JS_SIP_DEFAULTS.MIN_SESSION_EXPIRES;
    this.profile.auto_answer = false;
    this.profile.stun = false;
    this.profile.ice_server = '';
    this.save();
  }
  getCurrentUserProfile() { return this.profile.users?.[this.profile.user] || null; }
  addUser(profile) {
    if (!profile.user || !profile.domain || !profile.password) throw new Error('登录名、域名和密码为必填项');
    const userId = `${profile.user}@${profile.domain}`;
    if (this.profile.users[userId]) this.profile.users[userId] = { ...this.profile.users[userId], ...profile, user: profile.user, domain: profile.domain };
    else this.profile.users[userId] = profile;
    this.profile.user = userId;
    this.save();
  }
  updateUser(userId, updatedProfile) {
    if (this.profile.users[userId]) {
      const newUser = updatedProfile.user, newDomain = updatedProfile.domain;
      const newUserId = `${newUser}@${newDomain}`;
      if (newUserId !== userId) {
        const merged = { ...this.profile.users[userId], ...updatedProfile, user: newUser, domain: newDomain };
        delete this.profile.users[userId];
        this.profile.users[newUserId] = merged;
        if (this.profile.user === userId) this.profile.user = newUserId;
      } else this.profile.users[userId] = { ...this.profile.users[userId], ...updatedProfile, user: newUser, domain: newDomain };
      this.save();
    }
  }
  deleteCurrentUser() { if (this.profile.user) delete this.profile.users[this.profile.user]; const keys = Object.keys(this.profile.users); this.profile.user = keys.length > 0 ? keys[0] : ''; this.save(); }
  switchUser(userId) { if (this.profile.users[userId]) { this.profile.user = userId; this.save(); } }
}

export class WebPhone {
  constructor(profile, settings) {
    this.profile = profile; this.settings = settings; this.session = null; this.ua = null;
    this.call_id = this.randomUUID(); this.events = {}; this.callTimerId = null; this.dtfmTimerId = null; this.audioCtx = null; this.oscillatorLow = null;
    this.oscillatorHigh = null; this.gainNode = null; this.reconnectEnabled = settings.reconnect;
    this.reconnectAttempts = 0; this.reconnectStartTime = null;
    this.reconnectTotalDuration = JS_SIP_DEFAULTS.RECONNECT_TOTAL_DURATION;
    this.isReconnecting = false; this.reconnectTimerId = null; this._isHandlingDisconnect = false;
    this._deferredReconnectAfterCall = false;
    this._intentionalTerminate = false;
    this._intentionalTerminateUntil = 0;
    this.ringbackMedia = new Audio(RINGBACK_AUDIO_URL); this.ringbackMedia.loop = true;
    this.remoteMedia = new Audio(); this.remoteMedia.autoplay = true;
    this.remoteMedia.setAttribute('playsinline', 'true');
    this.localMedia = new Audio(); this.peerConnection = null;
    this._mountPlaybackElement(this.ringbackMedia, 'sip-ringback-audio');
    this._mountPlaybackElement(this.remoteMedia, 'sip-remote-audio');
    this.localStream = null;
    this._speakerPaused = false;
    this._speakerVolume = this.profile?.speaker_volume ?? JS_SIP_DEFAULTS.SPEAKER_VOLUME;
    this._answering = false;
    this._iceIssueTimer = null;
    this._remoteAudioSyncTimers = [];
    this._remotePlayRetryTimer = null;
    this.initUA();
  }
  _unmountPlaybackElement(id) {
    if (typeof document === 'undefined' || !id) return;
    const existing = document.getElementById(id);
    if (existing) {
      try {
        existing.pause();
        if (existing.srcObject) {
          existing.srcObject.getTracks().forEach((t) => { try { t.stop(); } catch (e) {} });
          existing.srcObject = null;
        }
      } catch (e) {}
      existing.remove();
    }
  }
  _mountPlaybackElement(el, id) {
    if (!el || typeof document === 'undefined') return;
    this._unmountPlaybackElement(id);
    el.id = id;
    el.setAttribute('playsinline', 'true');
    el.setAttribute('webkit-playsinline', 'true');
    el.preload = 'auto';
    if (!el.isConnected) {
      el.style.cssText = 'position:fixed;left:-9999px;width:1px;height:1px;opacity:0;pointer-events:none;';
      document.body.appendChild(el);
    }
  }
  _clearPeerConnection() {
    if (!this.peerConnection) return;
    this.peerConnection.ontrack = null;
    this.peerConnection.onaddstream = null;
    this.peerConnection.oniceconnectionstatechange = null;
    try { this.peerConnection.close(); } catch (err) {}
    this.peerConnection = null;
  }
  _clearRemotePlayback({ stopTracks = true } = {}) {
    this._clearRemoteAudioSyncTimers();
    if (this._remotePlayRetryTimer) {
      clearTimeout(this._remotePlayRetryTimer);
      this._remotePlayRetryTimer = null;
    }
    this.pauseRingback();
    if (this.remoteMedia) {
      try { this.remoteMedia.pause(); } catch (e) {}
      this.remoteMedia.muted = false;
      if (this.remoteMedia.srcObject) {
        if (stopTracks) {
          this.remoteMedia.srcObject.getTracks().forEach((t) => { try { t.stop(); } catch (e) {} });
        }
        this.remoteMedia.srcObject = null;
      }
      try { this.remoteMedia.load(); } catch (e) {}
    }
    this._clearPeerConnection();
  }
  /** 通话中远端无声时尝试恢复，不终止当前 SIP 会话 */
  async recoverRemotePlayback() {
    if (this.peerConnection) this.syncRemoteReceivers(this.peerConnection);
    if (this.remoteMedia?.srcObject) {
      this._pruneEndedRemoteTracks(this.remoteMedia.srcObject);
    }
    return this.resumeRemoteAudio();
  }
  /** 新外呼/来电前清理上一轮媒体，避免频繁通话后远端无声 */
  async prepareForNewCall() {
    this._answering = false;
    this.clearIceIssueTimer();
    this._clearRemotePlayback();
    if (this.session) {
      const status = this.session.status;
      if (status !== 7 && status !== 8) {
        try { this.session.terminate({ status_code: 486 }); } catch (e) {}
      } else {
        this.session = null;
      }
    }
    try {
      await this.ensureLocalStream();
    } catch (e) {
      console.warn('[音频] 新通话前麦克风初始化失败:', e.message || e);
      // 向上抛出，便于界面提示；兼容降级已在 requestMicrophoneAccess 内完成
      throw e;
    }
  }
  _pruneEndedRemoteTracks(stream) {
    if (!stream?.getAudioTracks) return stream;
    stream.getAudioTracks().forEach((track) => {
      if (track.readyState === 'ended') {
        try { stream.removeTrack(track); } catch (e) {}
      }
    });
    return stream;
  }
  _attachRemoteTrack(track) {
    if (!track || track.kind !== 'audio' || track.readyState === 'ended' || !this.remoteMedia) return false;
    let stream = this.remoteMedia.srcObject;
    if (!stream) {
      stream = new MediaStream();
      this.remoteMedia.srcObject = stream;
    } else {
      this._pruneEndedRemoteTracks(stream);
    }
    if (!stream.getTracks().some((t) => t.id === track.id)) {
      stream.addTrack(track);
    }
    track.enabled = true;
    this.remoteMedia.autoplay = true;
    this.remoteMedia.setAttribute('playsinline', 'true');
    this.remoteMedia.volume = this._getEffectiveSpeakerVolume();
    this.remoteMedia.muted = false;
    this.pauseRingback();
    this._scheduleRemotePlayRetry(0);
    return true;
  }
  _scheduleRemotePlayRetry(attempt = 0) {
    if (this._remotePlayRetryTimer) {
      clearTimeout(this._remotePlayRetryTimer);
      this._remotePlayRetryTimer = null;
    }
    const delays = [0, 120, 300, 600, 1200, 2500];
    const delay = delays[Math.min(attempt, delays.length - 1)];
    this._remotePlayRetryTimer = setTimeout(async () => {
      this._remotePlayRetryTimer = null;
      if (!this.hasActiveCall() && !this.hasSipSession()) return;
      const played = await this.resumeRemoteAudio();
      if (!played && attempt < delays.length - 1 && (this.hasActiveCall() || this.hasSipSession())) {
        if (this.peerConnection) this.syncRemoteReceivers(this.peerConnection);
        this._scheduleRemotePlayRetry(attempt + 1);
      }
    }, delay);
  }
  isRemotePlaybackPaused() {
    if (!this.remoteMedia) return true;
    if (this._speakerPaused) return false;
    if (this.remoteMedia.paused) return true;
    // MediaStream 播放时 readyState 可能长期为 0，不能作为暂停依据
    if (this.remoteMedia.srcObject) return false;
    return this.remoteMedia.readyState < 2;
  }
  isRemotePlaybackActive() {
    if (!this.remoteMedia || !this.hasRemoteAudioTrack()) return false;
    if (this._speakerPaused) return true;
    return !this.remoteMedia.paused;
  }
  _clearRemoteAudioSyncTimers() {
    this._remoteAudioSyncTimers.forEach((t) => clearTimeout(t));
    this._remoteAudioSyncTimers = [];
  }
  _scheduleRemoteAudioSync() {
    this._clearRemoteAudioSyncTimers();
    [300, 800, 1500, 3000, 5000, 8000, 12000].forEach((delay) => {
      const timerId = setTimeout(() => {
        if (this.hasActiveCall() || this.hasSipSession()) {
          if (this.peerConnection) this.syncRemoteReceivers(this.peerConnection);
          if (!this.isRemotePlaybackActive()) {
            this.refreshRemoteAudio();
          }
        }
      }, delay);
      this._remoteAudioSyncTimers.push(timerId);
    });
  }
  randomUUID() {
    if (typeof crypto !== 'undefined' && typeof crypto.randomUUID === 'function') return crypto.randomUUID().replace(/-/g, '');
    const arr = new Uint8Array(16);
    if (typeof crypto !== 'undefined' && typeof crypto.getRandomValues === 'function') crypto.getRandomValues(arr);
    else for (let i = 0; i < 16; i++) arr[i] = Math.floor(Math.random() * 256);
    arr[6] = (arr[6] & 0x0f) | 0x40; arr[8] = (arr[8] & 0x3f) | 0x80;
    return Array.from(arr, (b) => b.toString(16).padStart(2, '0')).join('');
  }
  initUA() {
    if (!this.profile.server || !this.profile.user || !this.profile.domain) {
      this.emit('OnStatusMessage', { type: 'error', text: '配置不完整' });
      return;
    }
    const socket = new JsSIP.WebSocketInterface(this.profile.server);
    if (String(this.profile.server || '').startsWith('wss://')) socket.via_transport = 'WS';
    const user = String(this.profile.user || '');
    const displayName = this.profile.display_name ? String(this.profile.display_name) : '';
    const password = this.profile.password ? String(this.profile.password) : '';
    const server = String(this.profile.server || '');
    const transport = 'ws';
    const domain = String(this.profile.domain || '');
    if (!user || !domain || !password) {
      this.emit('OnStatusMessage', { type: 'error', text: '账号配置不完整，请检查登录名、域名和密码' });
      return;
    }
    if (server.startsWith('wss://') && window.location.protocol === 'http:') {
      console.warn('[jsSip] 警告: 页面通过 HTTP 加载，但 SIP 服务器使用 WSS 协议。浏览器会阻止混合内容');
      this.emit('OnStatusMessage', { type: 'warn', text: 'HTTP页面使用WSS会被浏览器阻止' });
    }
    const uri = new JsSIP.URI('sip', user, domain);
    const contactUriStr = `sip:${user}@${domain};transport=${transport}`;
    this.configuration = {
      sockets: [socket], authorization_user: user, user_agent: this.settings.user_agent || JS_SIP_DEFAULTS.USER_AGENT,
      display_name: displayName || undefined, session_timers: false,
      session_timers_expires: this.settings.session_expires || JS_SIP_DEFAULTS.SESSION_EXPIRES,
      session_timers_min_se: this.settings.min_session_expires || JS_SIP_DEFAULTS.MIN_SESSION_EXPIRES,
      session_timers_force_refresher: false,
      no_answer_timeout: 60, register: true, uri: uri.toAor(), contact_uri: contactUriStr, password: password,
      log_level: 'error'
    };
  }
  getPcConfig() {
    if (!this.settings.stun) return undefined;
    const iceUrl = (this.settings.ice_server || 'stun:stun.l.google.com:19302').trim();
    if (!iceUrl) return undefined;
    return { iceServers: [{ urls: iceUrl }] };
  }
  hasActiveCall() {
    if (!this.session) return false;
    const status = this.session.status;
    return status === SESSION_CONFIRMED_STATUS || status === SESSION_WAITING_ACK_STATUS || status === SESSION_ANSWERED_STATUS;
  }
  hasSipSession() {
    if (!this.session) return false;
    const status = this.session.status;
    return status !== 7 && status !== 8 && status !== 0;
  }
  createUA() {
    this.ua = new JsSIP.UA(this.configuration);
    this.ua.set('display_name', this.profile.display_name);
    this.ua.on('connecting', this.connecting.bind(this));
    this.ua.on('connected', this.connected.bind(this));
    this.ua.on('disconnected', this.disconnected.bind(this));
    this.ua.on('registered', this.registered.bind(this));
    this.ua.on('unregistered', this.unregistered.bind(this));
    this.ua.on('registrationFailed', this.registrationFailed.bind(this));
    this.ua.on('registrationExpiring', this.registrationExpiring.bind(this));
    this.ua.on('newRTCSession', this.newRTCSession.bind(this));
    this.ua.on('transportError', this.transportError.bind(this));
  }
  On(event, callback) { this.events[event] = callback; }
  Off(event) { if (this.events[event]) delete this.events[event]; }
  emit(event, ...args) { if (this.events[event]) try { this.events[event](...args); } catch (e) { console.error(e); } }
  resetReconnectState() {
    if (this.reconnectTimerId) clearTimeout(this.reconnectTimerId);
    this.reconnectTimerId = null; this.isReconnecting = false; this.reconnectAttempts = 0; this.reconnectStartTime = null;
    this.emit('OnReconnectStatus', { isReconnecting: false, failed: false });
  }
  Start(reconnect, isReconnect = false) {
    console.log(`[jsSip] 启动 ${reconnect ? '正常连接' : '禁用重连'} ${isReconnect ? '(重连模式)' : ''}`);
    this.reconnectEnabled = reconnect;
    if (this.ua) { try { if (this.ua.isRegistered()) this.ua.unregister(); this.ua.stop(); } catch (e) {} this.ua = null; }
    if (!isReconnect) this.resetReconnectState();
    setTimeout(() => {
      this.createUA();
      if (this.ua.isRegistered()) { this.SetQueueIn(); return; }
      if (this.ua.isConnected()) { this.Register(); return; }
      try { this.ua.start(); } catch (error) {
        this.emit('OnStatusMessage', { type: 'error', text: '启动失败: ' + error.message });
        this.scheduleReconnect();
      }
    }, 50);
  }
  Register() { if (this.ua) this.ua.register(); }
  UnRegister() {
    this.reconnectEnabled = false; this.resetReconnectState();
    if (this.ua) { try { if (this.ua.isRegistered()) this.ua.unregister(); this.ua.stop(); } catch (e) {} this.ua = null; }
    if (this.reconnectTimerId) clearTimeout(this.reconnectTimerId);
    if (this.callTimerId) clearInterval(this.callTimerId);
    if (this.dtfmTimerId) clearTimeout(this.dtfmTimerId);
  }
  scheduleReconnect() {
    if (!this.reconnectEnabled || this.hasActiveCall() || this._isIntentionalHangupPhase()) return;
    if (this.reconnectTimerId) clearTimeout(this.reconnectTimerId);
    if (this.isReconnecting) return;
    const now = Date.now();
    if (this.reconnectStartTime === null) this.reconnectStartTime = now;
    const elapsed = now - this.reconnectStartTime;
    if (elapsed >= this.reconnectTotalDuration) {
      console.error('[jsSip] 重连超时（超过1分钟）');
      this.isReconnecting = false;
      this.emit('OnReconnectStatus', { isReconnecting: false, failed: true });
      this.emit('OnStatusMessage', { type: 'error', text: '重连超时' });
      return;
    }
    this.reconnectAttempts++;
    const configuredSec = this.settings.reconnect_interval ?? JS_SIP_DEFAULTS.RECONNECT_INTERVAL;
    let interval = this.reconnectAttempts <= 1 ? 400 : Math.min(configuredSec * 1000, 3000);
    if (this.reconnectAttempts > 5) interval = 2000;
    if (elapsed + interval > this.reconnectTotalDuration) {
      const remainingTime = this.reconnectTotalDuration - elapsed;
      if (remainingTime < 500) {
        this.emit('OnReconnectStatus', { isReconnecting: false, failed: true });
        this.emit('OnStatusMessage', { type: 'error', text: '重连超时' });
        return;
      }
      interval = Math.min(interval, remainingTime);
    }
    console.log(`[jsSip] ${Math.ceil(interval / 1000)}秒后重连 (第${this.reconnectAttempts}次)`);
    this.isReconnecting = true;
    this.emit('OnReconnectStatus', { isReconnecting: true, failed: false });
    this.reconnectTimerId = setTimeout(() => {
      this.isReconnecting = false;
      this.reconnectTimerId = null;
      this.Start(true, true);
    }, interval);
  }
  transportError(err) {
    const errorMessage = err?.message || err?.reason || '传输错误';
    if (this.hasActiveCall() || this.hasSipSession()) {
      console.debug('[SIP] 传输错误(通话中，保持会话):', errorMessage);
      return;
    }
    console.error('[SIP] WebSocket传输错误:', errorMessage);
    let errorText = 'WSS连接失败';
    if (errorMessage.includes('SecurityError') || errorMessage.includes('mixed content')) errorText = 'WSS连接被浏览器阻止';
    else if (err?.code === 1006) errorText = 'WSS连接异常关闭';
    else if (err?.code === 1005) errorText = 'WSS连接被拒绝';
    this.emit('OnStatusMessage', { type: 'error', text: errorText });
    if (!this.hasActiveCall() && !this.isReconnecting && this.reconnectEnabled) this.scheduleReconnect();
  }
  connecting() { this.emit('OnStatusMessage', { type: 'info', text: 'jsSip连接中...' }); }
  connected() { this.Register(); this.emit('OnStatusMessage', { type: 'success', text: 'jsSip开始注册' }); }
  disconnected(e) {
    if (this._isHandlingDisconnect) return;
    this._isHandlingDisconnect = true;
    const reason = e?.cause || e?.message || '未知原因';
    const inCall = this.hasActiveCall() || this.hasSipSession();
    if (this._isIntentionalHangupPhase()) {
      console.debug(`[SIP] 主动挂机后信令变化，保持注册不重连: ${reason}`);
      setTimeout(() => { this._isHandlingDisconnect = false; }, 400);
      return;
    }
    if (inCall) {
      console.debug(`[SIP] 信令连接断开(通话中，保持会话): ${reason}`);
      this._deferredReconnectAfterCall = true;
    } else {
      console.warn(`[SIP] 连接断开: ${reason}`);
      this.emit('OnRegister', { registered: false });
      if (!this.isReconnecting && this.reconnectEnabled) {
        this.scheduleReconnect();
      } else if (!this.reconnectEnabled && this.ua) {
        try { this.ua.stop(); } catch (err) {}
        this.ua = null;
      }
    }
    setTimeout(() => { this._isHandlingDisconnect = false; }, 400);
  }
  registered() {
    this._clearIntentionalHangupPhase();
    this.resetReconnectState();
    this.emit('OnRegister', { registered: true });
    this.emit('OnStatusMessage', { type: 'success', text: '已连接' });
    this.SetQueueIn();
  }
  unregistered() { this.emit('OnRegister', { registered: false }); this.emit('OnStatusMessage', { type: 'info', text: 'jsSip已注销' }); }
  registrationFailed(e) {
    const cause = e?.cause || e?.message || '未知原因';
    const statusCode = e?.response?.status_code || '';
    console.error('[jsSip] 注册失败:', cause);
    let errorText = '注册失败';
    if (cause === 'Connection Error') errorText = '注册失败: 无法连接服务器';
    else if (cause.includes('403') || cause.includes('Forbidden') || cause.includes('401')) errorText = '注册失败: 认证失败';
    else if (cause.includes('404')) errorText = '注册失败: 用户不存在';
    else if (cause.includes('408') || cause.includes('Timeout')) errorText = '注册失败: 请求超时';
    this.emit('OnRegister', { registered: false });
    this.emit('OnStatusMessage', { type: 'error', text: errorText });
    if (!this.hasActiveCall() && !this.isReconnecting && this.reconnectEnabled) this.scheduleReconnect();
  }
  registrationExpiring() { this.Register(); }
  releaseLocalStream() {
    if (this.localStream) {
      releaseMediaStream(this.localStream);
      this.localStream = null;
    }
    if (this.localMedia) this.localMedia.srcObject = null;
  }
  async ensureLocalStream() {
    if (this.localStream?.getAudioTracks().some(t => t.readyState === 'live')) {
      return this.localStream;
    }
    this.releaseLocalStream();
    const stream = await requestMicrophoneAccess();
    this.localStream = stream;
    this.localMedia.srcObject = stream;
    this.localMedia.muted = true;
    this.localMedia.volume = 0;
    return stream;
  }
  _getSpeakerVolume() {
    return this.profile?.speaker_volume ?? JS_SIP_DEFAULTS.SPEAKER_VOLUME;
  }
  _getEffectiveSpeakerVolume() {
    return this._speakerPaused ? 0 : (this._speakerVolume ?? this._getSpeakerVolume());
  }
  async Answer() {
    if (!this.session || this._answering) return;
    const status = this.session.status;
    if (status === SESSION_CONFIRMED_STATUS || status === SESSION_ANSWERED_STATUS || status === SESSION_WAITING_ACK_STATUS) return;
    if (!SESSION_ANSWERABLE_STATUSES.includes(status)) return;
    try {
      await this.ensureLocalStream();
    } catch (e) {
      console.warn('[SIP] 麦克风初始化失败:', e.message || e);
      // 本地流失败时仍尝试用兼容约束接听，避免 JsSIP 再次用增强约束失败
    }
    const options = {
      // 使用兼容约束，减少 Overconstrained / Requested device not found
      mediaConstraints: { ...MIC_MEDIA_CONSTRAINTS }
    };
    if (this.localStream) options.mediaStream = this.localStream;
    const pcConfig = this.getPcConfig();
    if (pcConfig) options.pcConfig = pcConfig;
    this._answering = true;
    try {
      this.session.answer(options);
    } catch (err) {
      console.warn('[SIP] answer 失败:', err.message || err);
    } finally {
      this._answering = false;
    }
  }
  _scheduleAutoAnswer(attempt = 0) {
    if (!this.session || attempt > 30) return;
    const status = this.session.status;
    if (status === SESSION_CONFIRMED_STATUS || status === SESSION_ANSWERED_STATUS || status === SESSION_WAITING_ACK_STATUS) return;
    if (SESSION_ANSWERABLE_STATUSES.includes(status)) {
      this.Answer();
      return;
    }
    setTimeout(() => this._scheduleAutoAnswer(attempt + 1), 100);
  }
  markIntentionalHangup() {
    this._intentionalTerminate = true;
    this._intentionalTerminateUntil = Date.now() + 8000;
    this._deferredReconnectAfterCall = false;
    if (this.reconnectTimerId) {
      clearTimeout(this.reconnectTimerId);
      this.reconnectTimerId = null;
    }
    this.isReconnecting = false;
    this.emit('OnReconnectStatus', { isReconnecting: false, failed: false });
  }
  _isIntentionalHangupPhase() {
    return this._intentionalTerminate || Date.now() < this._intentionalTerminateUntil;
  }
  _clearIntentionalHangupPhase() {
    this._intentionalTerminate = false;
    this._intentionalTerminateUntil = 0;
  }
  Terminate(code) {
    this.markIntentionalHangup();
    if (!this.session) return;
    if (code) this.session.terminate({ status_code: code });
    else this.session.terminate();
  }
  ToggleHold() { if (this.session && this.session.isEstablished()) { if (this.session.isOnHold().local) this.session.unhold(); else this.session.hold(); } }
  ToggleMicPhone() {
    if (!this.session) return;
    const muted = this.session.isMuted().audio;
    if (muted) this.session.unmute({ audio: true });
    else this.session.mute({ audio: true });
  }
  isMicMuted() { return this.session ? this.session.isMuted().audio : false; }
  SetSpeaker(paused, volume) {
    if (typeof paused === 'boolean') this._speakerPaused = paused;
    if (typeof volume === 'number' && !Number.isNaN(volume)) {
      this._speakerVolume = Math.min(1, Math.max(0, volume));
    }
    const vol = this._getEffectiveSpeakerVolume();
    if (this.remoteMedia) this.remoteMedia.volume = vol;
    if (this.ringbackMedia) this.ringbackMedia.volume = vol;
  }
  SetMicPhone(paused, volume) { this.localMedia.volume = paused ? 0 : volume; if (this.localStream) this.localStream.getAudioTracks().forEach((track) => { track.enabled = !paused; }); }
  SetQueueIn() { if (this.ua && this.ua.isRegistered()) this.ua.sendMessage('execute_available', `${this.profile.user}@${this.profile.domain}`, {}); }
  SendDTMF(tone) { if (this.session && this.session.isEstablished()) this.session.sendDTMF(tone); }
  PlayDtmfTone(key) {
    const DTMF_MAP = { '0': [697,1633],'1':[697,1209],'2':[697,1336],'3':[697,1477],'4':[770,1209],'5':[770,1336],'6':[770,1477],'7':[852,1209],'8':[852,1336],'9':[852,1477],'*':[697,1633],'#':[770,1633] };
    const [lowFreq, highFreq] = DTMF_MAP[key] || [697,1209];
    this.generateDtmfTone(lowFreq, highFreq, 0.2, this.remoteMedia.volume);
  }
  generateDtmfTone(lowFreq, highFreq, duration, volume) {
    if (this.dtfmTimerId) { clearTimeout(this.dtfmTimerId); if (this.oscillatorLow) try { this.oscillatorLow.stop(); } catch(e){} if (this.oscillatorHigh) try { this.oscillatorHigh.stop(); } catch(e){} }
    if (!this.audioCtx || this.audioCtx.state === 'closed') this.audioCtx = new (window.AudioContext || window.webkitAudioContext)();
    this.gainNode = this.audioCtx.createGain();
    this.oscillatorLow = this.audioCtx.createOscillator(); this.oscillatorLow.type = 'sine'; this.oscillatorLow.frequency.value = lowFreq;
    this.oscillatorHigh = this.audioCtx.createOscillator(); this.oscillatorHigh.type = 'sine'; this.oscillatorHigh.frequency.value = highFreq;
    this.oscillatorLow.connect(this.gainNode); this.oscillatorHigh.connect(this.gainNode);
    this.gainNode.connect(this.audioCtx.destination);
    this.gainNode.gain.setValueAtTime(volume, this.audioCtx.currentTime);
    this.gainNode.gain.linearRampToValueAtTime(0, this.audioCtx.currentTime + duration);
    this.oscillatorLow.start(); this.oscillatorHigh.start();
    this.dtfmTimerId = setTimeout(() => { if (this.oscillatorLow) try { this.oscillatorLow.stop(); } catch(e){} if (this.oscillatorHigh) try { this.oscillatorHigh.stop(); } catch(e){} this.dtfmTimerId = null; }, duration * 1000);
  }
  IsOnHold() { return this.session ? this.session.isOnHold().local : false; }
  pauseRingback() { if (this.ringbackMedia && !this.ringbackMedia.paused) this.ringbackMedia.pause(); }
  playRingback() { if (this.ringbackMedia && this.ringbackMedia.paused) { this.ringbackMedia.currentTime = 0; this.ringbackMedia.play().catch(e => console.warn('[音频] 回铃音播放失败')); } }
  newRTCSession(event) {
    const incoming = event.session;
    const outgoing = incoming.direction === 'outgoing';

    if (this.session && this.session !== incoming && this.hasActiveCall() && !outgoing) {
      try { incoming.terminate({ status_code: 486 }); } catch (e) {}
      return;
    }

    const stale = this.session && this.session !== incoming ? this.session : null;
    this._clearRemotePlayback();
    this._answering = false;
    this.session = incoming;
    this._bindSessionEvents(incoming);

    if (stale && stale.status !== 7 && stale.status !== 8) {
      try { stale.terminate({ status_code: 486 }); } catch (e) {}
    }

    this.emit('OnSessionCreated', { outgoing, callee: incoming.remote_identity?.uri?.user || '', province: event.request?.getHeader('X-Province') || '', city: event.request?.getHeader('X-City') || '' });
    if (!outgoing && this.settings.auto_answer !== false) {
      this._scheduleAutoAnswer();
    }
    if (outgoing) this.playRingback();
  }
  _bindSessionEvents(session) {
    session.on('progress', (e) => {
      this.emit('OnRing', {
        outgoing: session.direction === 'outgoing',
        province: e.response?.getHeader('X-Province') || '',
        city: e.response?.getHeader('X-City') || ''
      });
    });
    session.on('confirmed', () => {
      this.pauseRingback();
      this.emit('OnAnswered', session.direction === 'outgoing');
      // 外呼计时以客户真正接通为准，由 IPCC CALLEE_ANSWERED / 来电由 SIP confirmed 启动
      if (session.direction !== 'outgoing') {
        this.startCallTimer();
      }
      if (this.remoteMedia) {
        this.remoteMedia.volume = this._getEffectiveSpeakerVolume();
      }
      this.refreshRemoteAudio();
      this._scheduleRemoteAudioSync();
    });
    session.on('ended', () => {
      console.log('[SIP] session ended', session.direction);
      this.sessionClosed(true, '', session);
    });
    session.on('failed', (e) => {
      const cause = e?.cause || '';
      console.warn('[SIP] session failed:', cause, session.direction);
      this.sessionClosed(false, cause, session);
    });
    session.on('peerconnection', (data) => {
      const pc = data?.peerconnection || data;
      if (pc) this.registerRemoteMedia(pc);
    });
  }
  registerRemoteMedia(connection) {
    if (!connection) return;
    this.peerConnection = connection;
    const onRemoteTrack = (track) => this._attachRemoteTrack(track);
    connection.ontrack = (e) => {
      if (e.track) onRemoteTrack(e.track);
      else if (e.streams?.[0]) e.streams[0].getAudioTracks().forEach(onRemoteTrack);
    };
    if (typeof connection.addEventListener === 'function') {
      connection.addEventListener('track', (e) => {
        if (e.track) onRemoteTrack(e.track);
        else if (e.streams?.[0]) e.streams[0].getAudioTracks().forEach(onRemoteTrack);
      });
    }
    connection.onaddstream = (e) => {
      if (e.stream) e.stream.getAudioTracks().forEach(onRemoteTrack);
    };
    this.syncRemoteReceivers(connection);
    this.registerRemoteMediaIceHandlers(connection);
  }
  syncRemoteReceivers(connection) {
    if (!connection || !this.remoteMedia) return false;
    let attached = false;
    const attach = (track) => {
      if (this._attachRemoteTrack(track)) attached = true;
    };
    if (typeof connection.getTransceivers === 'function') {
      connection.getTransceivers().forEach((tr) => {
        if (tr.receiver?.track) attach(tr.receiver.track);
      });
    }
    if (typeof connection.getReceivers === 'function') {
      connection.getReceivers().forEach((receiver) => {
        if (receiver.track) attach(receiver.track);
      });
    }
    return attached;
  }
  hasRemoteAudioTrack() {
    const stream = this.remoteMedia?.srcObject;
    if (stream?.getAudioTracks?.().some((t) => t.readyState === 'live' && t.enabled)) return true;
    if (this.peerConnection) {
      this.syncRemoteReceivers(this.peerConnection);
      const refreshed = this.remoteMedia?.srcObject;
      return !!refreshed?.getAudioTracks?.().some((t) => t.readyState === 'live' && t.enabled);
    }
    return false;
  }
  registerRemoteMediaIceHandlers(connection) {
    if (!connection) return;
    connection.oniceconnectionstatechange = () => {
      const state = connection.iceConnectionState;
      if (state === 'failed') {
        console.warn('[SIP] ICE 状态: failed');
        this.emit('OnIceMediaIssue', { state, timedOut: true });
      } else if (state === 'disconnected') {
        console.warn('[SIP] ICE 状态: disconnected');
        if (this._iceIssueTimer) clearTimeout(this._iceIssueTimer);
        this.emit('OnIceMediaIssue', { state, timedOut: false });
        this._iceIssueTimer = setTimeout(() => {
          this._iceIssueTimer = null;
          const cur = connection.iceConnectionState;
          if (cur === 'disconnected' || cur === 'failed') {
            this.emit('OnIceMediaIssue', { state: cur, timedOut: true });
          }
        }, 12000);
      } else if (state === 'connected' || state === 'completed') {
        if (this._iceIssueTimer) {
          clearTimeout(this._iceIssueTimer);
          this._iceIssueTimer = null;
        }
        this.resumeRemoteAudio();
        this._scheduleRemotePlayRetry(0);
      }
    };
  }
  stopCallTimer() {
    if (this.callTimerId) {
      clearInterval(this.callTimerId);
      this.callTimerId = null;
    }
  }
  clearIceIssueTimer() {
    if (this._iceIssueTimer) {
      clearTimeout(this._iceIssueTimer);
      this._iceIssueTimer = null;
    }
  }
  sessionClosed(succeed, reason, closedSession) {
    if (!closedSession || this.session !== closedSession) return;
    const intentional = this._isIntentionalHangupPhase();
    const shouldReconnect = !intentional && this._deferredReconnectAfterCall;
    this._deferredReconnectAfterCall = false;
    this.clearIceIssueTimer();
    this.stopCallTimer();
    this._answering = false;
    this._clearRemotePlayback();
    this.session = null;
    if (!intentional) {
      this.releaseLocalStream();
    }
    this.emit('OnSessionClosed', { succeeded: succeed, reason, intentional });
    if (shouldReconnect && this.reconnectEnabled && !this.isReconnecting) {
      this.scheduleReconnect();
    }
  }
  refreshRemoteAudio() {
    if (this.peerConnection) this.syncRemoteReceivers(this.peerConnection);
    return this.resumeRemoteAudio();
  }
  async resumeRemoteAudio() {
    if (this.peerConnection) this.syncRemoteReceivers(this.peerConnection);
    if (this.audioCtx && this.audioCtx.state === 'suspended') {
      try { await this.audioCtx.resume(); } catch (e) {}
    }
    if (!this.remoteMedia || !this.hasRemoteAudioTrack()) return false;
    this.remoteMedia.volume = this._getEffectiveSpeakerVolume();
    this.remoteMedia.muted = false;
    try {
      await this.remoteMedia.play();
      return !this.remoteMedia.paused;
    } catch (e) {
      console.warn('[音频] 远端播放 resume 失败:', e.message || e);
      return false;
    }
  }
  startCallTimer() {
    if (this.callTimerId) clearInterval(this.callTimerId);
    let seconds = 0;
    this.callTimerId = setInterval(() => { seconds++; const mins = Math.floor(seconds / 60); const secs = seconds % 60; this.emit('OnCallTimer', `${mins.toString().padStart(2, '0')}:${secs.toString().padStart(2, '0')}`); }, 1000);
  }
  destroy() {
    this.reconnectEnabled = false;
    this.clearIceIssueTimer();
    this._clearRemotePlayback();
    if (this.reconnectTimerId) clearTimeout(this.reconnectTimerId);
    if (this.callTimerId) clearInterval(this.callTimerId);
    if (this.dtfmTimerId) clearTimeout(this.dtfmTimerId);
    if (this.session) {
      try { this.session.terminate(); } catch (e) {}
      this.session = null;
    }
    this.UnRegister();
    const cleanupAudio = (audio) => { if (!audio) return; try { audio.pause(); audio.src = ''; if (audio.srcObject) { audio.srcObject.getTracks().forEach(t => t.stop()); audio.srcObject = null; } audio.load(); } catch(e) {} };
    cleanupAudio(this.ringbackMedia); cleanupAudio(this.remoteMedia); cleanupAudio(this.localMedia);
    this._unmountPlaybackElement('sip-ringback-audio');
    this._unmountPlaybackElement('sip-remote-audio');
    this.releaseLocalStream();
    this.ringbackMedia = null; this.remoteMedia = null; this.localMedia = null;
    if (this.audioCtx) { try { if (this.audioCtx.state !== 'closed') this.audioCtx.close(); } catch(e) {} this.audioCtx = null; }
    this.oscillatorLow = null; this.oscillatorHigh = null; this.gainNode = null;
    this.events = {}; this.configuration = null; this.profile = null; this.settings = null; this.session = null; this.ua = null;
  }
}

export default {
  WebPhone, ProfileManager, checkMicrophonePermission, releaseMediaStream,
  RINGBACK_AUDIO_URL, IPCC_DEFAULTS, JS_SIP_DEFAULTS
};