/**
 * MinIO 文件上传工具
 * 使用 AWS Signature V4 签名，通过 plus.net.XMLHttpRequest PUT 直传
 */

import sha256 from 'js-sha256'

// ====== MinIO 配置 ======
var CFG = {
  endpoint: 'shxy.image.yushutx.com',
  accessKey: 'minioadmin',
  secretKey: 'minioadmin',
  bucket: 'scan-book',
  region: 'us-east-1',
  protocol: 'https'
}

// ====== 工具函数 ======

function pad(n) { return n < 10 ? '0' + n : '' + n }

function hmacRaw(key, msg) {
  return hexToBytes(sha256.hmac(key, msg))
}

function hexToBytes(hex) {
  var bytes = []
  for (var i = 0; i < hex.length; i += 2) {
    bytes.push(parseInt(hex.substring(i, i + 2), 16))
  }
  return new Uint8Array(bytes)
}

function bytesToHex(bytes) {
  var s = ''
  for (var i = 0; i < bytes.length; i++) {
    var b = bytes[i]
    s += '0123456789abcdef'[(b >> 4) & 0xf]
    s += '0123456789abcdef'[b & 0xf]
  }
  return s
}

function sha256Hex(s) { return sha256(s) }

// ====== AWS V4 签名 ======

function buildAuthHeader(objectKey, date, contentType, contentSha256) {
  var dateStr = date.getUTCFullYear() + pad(date.getUTCMonth() + 1) + pad(date.getUTCDate())
  var amzDate = dateStr + 'T' + pad(date.getUTCHours()) + pad(date.getUTCMinutes()) + pad(date.getUTCSeconds()) + 'Z'

  var host = CFG.endpoint
  var canonicalUri = '/' + CFG.bucket + '/' + objectKey

  var signedHeadersList = ['content-type', 'host', 'x-amz-content-sha256', 'x-amz-date']
  var canonicalHeaders =
    'content-type:' + contentType + '\n' +
    'host:' + host + '\n' +
    'x-amz-content-sha256:' + contentSha256 + '\n' +
    'x-amz-date:' + amzDate + '\n'
  var signedHeadersStr = signedHeadersList.join(';')

  var canonicalRequest =
    'PUT\n' + canonicalUri + '\n\n' + canonicalHeaders + signedHeadersStr + '\n' + contentSha256

  var credentialScope = dateStr + '/' + CFG.region + '/s3/aws4_request'
  var stringToSign = 'AWS4-HMAC-SHA256\n' + amzDate + '\n' + credentialScope + '\n' + sha256Hex(canonicalRequest)

  var signingKey = hmacRaw('AWS4' + CFG.secretKey, dateStr)
  signingKey = hmacRaw(signingKey, CFG.region)
  signingKey = hmacRaw(signingKey, 's3')
  signingKey = hmacRaw(signingKey, 'aws4_request')
  var signature = bytesToHex(hmacRaw(signingKey, stringToSign))

  var authHeader = 'AWS4-HMAC-SHA256 Credential=' + CFG.accessKey + '/' + credentialScope +
    ', SignedHeaders=' + signedHeadersStr + ', Signature=' + signature

  return { authHeader: authHeader, amzDate: amzDate }
}

// ====== 文件读取 ======

function readFileAsBase64(filePath) {
  return new Promise(function (resolve, reject) {
    // 方式1: plus.io FileReader（HBuilder App 环境，最可靠）
    if (typeof plus !== 'undefined' && plus.io && plus.io.FileReader) {
      plus.io.resolveLocalFileSystemURL(filePath, function (entry) {
        entry.file(function (file) {
          var reader = new plus.io.FileReader()
          reader.onloadend = function (e) {
            var data = e.target.result
            if (data.indexOf(',') > -1) data = data.split(',')[1]
            resolve(data)
          }
          reader.onerror = function () { reject(new Error('FileReader失败')) }
          reader.readAsDataURL(file)
        }, function () { reject(new Error('获取文件对象失败')) })
      }, function (err) {
        console.warn('resolveLocalFileSystemURL失败:', JSON.stringify(err))
        // 回退到 getFileSystemManager
        tryFSManager(filePath, resolve, reject)
      })
      return
    }
    // 方式2: uni.getFileSystemManager（H5/小程序）
    tryFSManager(filePath, resolve, reject)
  })
}

function tryFSManager(filePath, resolve, reject) {
  try {
    var fs = uni.getFileSystemManager()
    if (fs && fs.readFile) {
      fs.readFile({ filePath: filePath, encoding: 'base64', success: function (res) { resolve(res.data) }, fail: function (e) { reject(new Error('readFile失败: ' + JSON.stringify(e))) } })
    } else {
      reject(new Error('不支持文件读取'))
    }
  } catch (e) {
    reject(new Error('不支持文件读取: ' + e.message))
  }
}

function base64ToBytes(base64) {
  var chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'
  base64 = base64.replace(/=+$/, '')
  var bytes = []
  for (var i = 0; i < base64.length; i += 4) {
    var a = chars.indexOf(base64[i])
    var b = chars.indexOf(base64[i + 1])
    var c = chars.indexOf(base64[i + 2])
    var d = chars.indexOf(base64[i + 3])
    if (a >= 0 && b >= 0) {
      bytes.push((a << 2) | (b >> 4))
      if (c >= 0) bytes.push(((b & 0xf) << 4) | (c >> 2))
      if (d >= 0) bytes.push(((c & 3) << 6) | d)
    }
  }
  return bytes
}

// ====== 时间同步（用 plus.net.XMLHttpRequest GET，直接读 Date 响应头） ======

var _cachedTimeOffset = null

function syncServerTime() {
  return new Promise(function (resolve) {
    console.log('【MinIO时间同步】开始...')

    // 尝试用 plus.net.XMLHttpRequest GET 根路径获取 Date 头
    if (typeof plus !== 'undefined' && plus.net && plus.net.XMLHttpRequest) {
      try {
        var xhr = new plus.net.XMLHttpRequest()
        var timer = setTimeout(function () {
          console.warn('【MinIO时间同步】超时')
          xhr.abort()
          resolve(new Date())
        }, 10000)

        xhr.onreadystatechange = function () {
          if (xhr.readyState === 4) {
            clearTimeout(timer)
            try {
              var dateStr = xhr.getResponseHeader('Date')
              console.log('【MinIO时间同步】readyState=4, status:', xhr.status, ', Date头:', dateStr)
              if (dateStr) {
                var serverMs = Date.parse(dateStr)
                if (!isNaN(serverMs)) {
                  _cachedTimeOffset = serverMs - Date.now()
                  console.log('【MinIO时间同步】成功! 服务器ms:', serverMs, '本地ms:', Date.now(), '偏移:', _cachedTimeOffset, 'ms')
                  resolve(new Date(Date.now() + _cachedTimeOffset))
                  return
                }
              }
            } catch (e) {
              console.warn('【MinIO时间同步】解析异常:', e)
            }
            resolve(new Date())
          }
        }
        xhr.open('GET', CFG.protocol + '://' + CFG.endpoint + '/')
        xhr.send()
        return
      } catch (e) {
        console.warn('【MinIO时间同步】创建XHR失败:', e)
      }
    }

    // 兜底
    resolve(new Date())
  })
}

function getServerDate() {
  if (_cachedTimeOffset !== null) {
    return new Date(Date.now() + _cachedTimeOffset)
  }
  return new Date()
}

// ====== 上传 ======

export function uploadImage(filePath, typeDir) {
  if (typeDir === undefined) typeDir = 'Isbn'
  return new Promise(function (resolve, reject) {
    syncServerTime().then(function () {
      readFileAsBase64(filePath).then(function (base64) {
        var fileBytes = base64ToBytes(base64)
        var fileByteArray = new Uint8Array(fileBytes)
        var fileSha256 = sha256(fileBytes)

        // 构建对象路径
        var now = getServerDate()
        var datePath = now.getFullYear() + '-' + pad(now.getMonth() + 1) + '-' + pad(now.getDate())
        var ext = (filePath.match(/\.(\w+)$/) || [])[1] || 'jpg'
        ext = ext.toLowerCase()
        var uuid = 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
          var r = Math.random() * 16 | 0
          return (c === 'x' ? r : (r & 0x3 | 0x8)).toString(16)
        })
        var objectKey = datePath + '/' + typeDir + '/' + uuid + '.' + ext
        var ct = { jpg: 'image/jpeg', jpeg: 'image/jpeg', png: 'image/png', gif: 'image/gif', webp: 'image/webp', bmp: 'image/bmp' }
        var contentType = ct[ext] || 'image/jpeg'

        var sig = buildAuthHeader(objectKey, now, contentType, fileSha256)
        var url = CFG.protocol + '://' + CFG.endpoint + '/' + CFG.bucket + '/' + objectKey

        console.log('【MinIO上传】URL:', url)
        console.log('【MinIO上传】amzDate:', sig.amzDate)
        console.log('【MinIO上传】authHeader:', sig.authHeader)
        console.log('【MinIO上传】contentType:', contentType)
        console.log('【MinIO上传】fileSha256:', fileSha256)
        console.log('【MinIO上传】本地时间:', new Date().toISOString(), '服务器时间:', now.toISOString())

        // ====== 使用 plus.net.XMLHttpRequest PUT ======
        if (typeof plus !== 'undefined' && plus.net && plus.net.XMLHttpRequest) {
          try {
            var xhr = new plus.net.XMLHttpRequest()
            xhr.onreadystatechange = function () {
              if (xhr.readyState === 4) {
                console.log('【MinIO上传】onreadystatechange status:', xhr.status)
                if (xhr.status === 200) {
                  console.log('【MinIO上传】成功:', url)
                  resolve(url)
                } else {
                  console.error('【MinIO上传】失败, HTTP:', xhr.status, xhr.responseText || xhr.response)
                  reject(new Error('上传失败: HTTP ' + xhr.status))
                }
              }
            }
            xhr.open('PUT', url)
            xhr.setRequestHeader('Content-Type', contentType)
            xhr.setRequestHeader('X-Amz-Content-Sha256', fileSha256)
            xhr.setRequestHeader('X-Amz-Date', sig.amzDate)
            xhr.setRequestHeader('Authorization', sig.authHeader)
            console.log('【MinIO上传】发送数据, 大小:', fileByteArray.length, '字节')
            xhr.send(fileByteArray.buffer)
            return
          } catch (e) {
            console.warn('【MinIO上传】plus XHR失败:', e)
          }
        }

        // 兜底：uni.request
        uni.request({
          url: url, method: 'PUT',
          header: {
            'Content-Type': contentType,
            'X-Amz-Content-Sha256': fileSha256,
            'X-Amz-Date': sig.amzDate,
            'Authorization': sig.authHeader
          },
          data: fileByteArray.buffer,
          success: function (res) {
            if (res.statusCode === 200) { resolve(url) }
            else { reject(new Error('上传失败: HTTP ' + res.statusCode)) }
          },
          fail: function (err) { reject(new Error('上传网络错误')) }
        })
      }).catch(function (err) { reject(err) })
    }).catch(function (err) { reject(err) })
  })
}

export function uploadImages(filePaths, typeDir) {
  if (typeDir === undefined) typeDir = 'Isbn'
  var tasks = []
  for (var i = 0; i < filePaths.length; i++) {
    tasks.push(uploadImage(filePaths[i], typeDir))
  }
  return Promise.all(tasks)
}

export default { uploadImage, uploadImages }