import { getApiBaseUrl, getApiEndpoint, isApiConfigured } from '../config/api.uts'
import { getAccessToken } from './session.uts'
import { request, HttpError } from './http.uts'

export const createIdempotencyKey = (scope: string): string => scope + '-' + Date.now() + '-' + Math.floor(Math.random() * 1000000000)

export const sanitizeRichText = (html: string): string => {
	if (html == null) return ''
	const base = getApiBaseUrl().replace(/\/+$/, '')
	const content = ('' + html)
		.replace(/<script[\s\S]*?<\/script>/gi, '')
		.replace(/<style[\s\S]*?<\/style>/gi, '')
		.replace(/\son[a-z]+\s*=\s*(['"]).*?\1/gi, '')
		// 危险协议（javascript: 等）直接去掉属性。
		.replace(/\s(href|src)\s*=\s*(['"])\s*javascript:[^'"]*\2/gi, '')
	if (base == '') return content
	// 后台富文本里的图片/链接存的是相对路径（/uploads/xxx.png）。小程序加载不了相对路径，
	// 而原来这里会把所有非 https 的 src 整条删掉，图片就变成破图（只显示 alt 文字）。
	// 这里统一补成接口域名下的绝对地址，http(s) 绝对地址原样保留。
	return content
		// 小程序 rich-text 不认 <s>/<strike>/<u>，换成它支持的 <del>/<ins>，
		// 否则后台设的删除线/下划线在人才端看不见（看着像"样式没生效"）。
		.replace(/<\s*(\/?)\s*s(?=[\s>/])([^>]*)>/gi, '<$1del$2>')
		.replace(/<\s*(\/?)\s*strike(?=[\s>/])([^>]*)>/gi, '<$1del$2>')
		.replace(/<\s*(\/?)\s*u(?=[\s>/])([^>]*)>/gi, '<$1ins$2>')
		.replace(/(src|href)=(["'])\/\//gi, '$1=$2https://')
		.replace(/(\s(?:src|href)\s*=\s*(['"]))\/+/gi, '$1' + base + '/')
		.replace(/(\s(?:src|href)\s*=\s*(['"]))(?!https?:|\/\/|\/|data:|javascript:)/gi, '$1' + base + '/')
		// 小程序 rich-text 不继承页面样式：后台图片带的是原图尺寸，会撑出卡片。
		// 在图片标签上补内联样式，按容器宽度等比缩放并居中。
		.replace(/(<img\b[^>]*?\sstyle=(["']))([^"']*)(\2)/gi, '$1$3max-width:100%;height:auto;display:block;margin:10px auto;$4')
		.replace(/<img\b(?![^>]*\sstyle=)/gi, '<img style="max-width:100%;height:auto;display:block;margin:10px auto;"')
}

export const requestDynamicCode = (codeType: string, businessId: string, onSuccess: (data: any) => void, onError: (error: HttpError) => void) => {
	request<any>({ path: getApiEndpoint('dynamicCode'), method: 'POST', data: { codeType: codeType, businessId: businessId } }, onSuccess, onError)
}

export const claimCoupon = (couponId: string, onSuccess: (data: any) => void, onError: (error: HttpError) => void) => {
	request<any>({ path: getApiEndpoint('couponClaim'), method: 'POST', data: { couponId: couponId }, idempotencyKey: createIdempotencyKey('coupon') }, onSuccess, onError)
}

export const getCouponDetail = (userCouponId: string, onSuccess: (data: any) => void, onError: (error: HttpError) => void) => {
	request<any>({ path: getApiEndpoint('couponDetail'), method: 'GET', data: { userCouponId: userCouponId } }, onSuccess, onError)
}

export const getRecordDetail = (recordId: string, onSuccess: (data: any) => void, onError: (error: HttpError) => void) => {
	request<any>({ path: getApiEndpoint('recordDetail'), method: 'GET', data: { recordId: recordId } }, onSuccess, onError)
}

export const submitBusiness = (businessType: string, payload: any, onSuccess: (data: any) => void, onError: (error: HttpError) => void) => {
	request<any>({ path: getApiEndpoint('businessSubmit'), method: 'POST', data: { businessType: businessType, payload: payload }, idempotencyKey: createIdempotencyKey(businessType) }, onSuccess, onError)
}

export const payOrder = (orderId: string, onSuccess: (data: any) => void, onError: (error: HttpError) => void) => {
	request<any>({ path: getApiEndpoint('orderPayment'), method: 'POST', data: { orderId: orderId }, idempotencyKey: createIdempotencyKey('payment') }, (payment: any) => {
		if (payment == null || payment.timeStamp == null || payment.nonceStr == null || payment.package == null || payment.paySign == null) {
			onError({ code: 'INVALID_PAYMENT_RESPONSE', message: '支付参数不完整', statusCode: 200, traceId: '' })
			return
		}
		uni.requestPayment({
			provider: 'wxpay',
			timeStamp: payment.timeStamp,
			nonceStr: payment.nonceStr,
			package: payment.package,
			signType: payment.signType != null ? payment.signType : 'RSA',
			paySign: payment.paySign,
			success: () => request<any>({ path: getApiEndpoint('orderPaymentResult'), method: 'GET', data: { orderId: orderId } }, onSuccess, onError),
			fail: () => onError({ code: 'PAYMENT_CANCELLED', message: '支付未完成', statusCode: 0, traceId: '' })
		})
	}, onError)
}

export const uploadProofFile = (filePath: string, businessType: string, onSuccess: (data: any) => void, onError: (error: HttpError) => void, onProgress?: (progress: number) => void): (() => void) => {
	const endpoint = getApiEndpoint('fileUpload')
	if (!isApiConfigured() || endpoint.length == 0) {
		onError({ code: 'API_NOT_CONFIGURED', message: '上传服务尚未配置', statusCode: 0, traceId: '' })
		return () => {}
	}
	const lowerPath = filePath.toLowerCase()
	if (!(/\.(jpg|jpeg|png|webp|pdf)$/).test(lowerPath)) {
		onError({ code: 'UNSUPPORTED_FILE', message: '仅支持 JPG、PNG、WEBP 或 PDF 文件', statusCode: 0, traceId: '' })
		return () => {}
	}
	let task: any = null
	let cancelled = false
	uni.getFileInfo({
		filePath: filePath,
		success: (file: any) => {
			if (cancelled) return
			if (file.size != null && file.size > 10 * 1024 * 1024) {
				onError({ code: 'FILE_TOO_LARGE', message: '文件不能超过 10MB', statusCode: 0, traceId: '' })
				return
			}
			task = uni.uploadFile({
				url: getApiBaseUrl().replace(/\/$/, '') + '/' + endpoint.replace(/^\//, ''),
				filePath: filePath,
				name: 'file',
				formData: { businessType: businessType },
				header: { Authorization: 'Bearer ' + getAccessToken(), 'X-Idempotency-Key': createIdempotencyKey('upload') },
				success: (response: any) => {
					try {
						const payload: any = JSON.parse(response.data as string)
						if (response.statusCode >= 200 && response.statusCode < 300 && (payload.code == null || payload.code == 0 || payload.code == 200)) onSuccess(payload.data != null ? payload.data : payload)
						else onError({ code: payload.code != null ? '' + payload.code : 'UPLOAD_FAILED', message: payload.message != null ? payload.message as string : '上传失败', statusCode: response.statusCode, traceId: payload.traceId != null ? payload.traceId as string : '' })
					} catch (_) {
						onError({ code: 'INVALID_UPLOAD_RESPONSE', message: '上传响应格式错误', statusCode: response.statusCode, traceId: '' })
					}
				},
				fail: () => onError({ code: cancelled ? 'UPLOAD_CANCELLED' : 'UPLOAD_NETWORK_ERROR', message: cancelled ? '已取消上传' : '上传失败，请检查网络后重试', statusCode: 0, traceId: '' })
			})
			if (onProgress != null) task.onProgressUpdate((progress: any) => onProgress(progress.progress as number))
		},
		fail: () => onError({ code: 'FILE_READ_FAILED', message: '无法读取待上传文件', statusCode: 0, traceId: '' })
	})
	return () => { cancelled = true; if (task != null) task.abort() }
}