[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_105":106,"_107":108},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","CGH2026","name","etf-monitor","path","new-file-899.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/CGH2026/etf-monitor/code/new-file-899.ts","extension","id","22c5b953-382b-433f-bec7-34e7b26303f1","fileId","756e25e6-a031-11f1-9e70-1607ee4eb77e","parentId","branchId","b636b57c-1589-4055-8218-6fbf99de3708","branchVersion",51,"latest",true,"createdAt",["D",1788616695021],"version",21,"fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/global.ts\";\n\n// ============================================================\n// ETF行情数据API v2.5 - 完全脱离飞书（ETF列表存SQLite云端）\n// 功能：动态ETF列表(SQLite etf_config表) + 实时行情 + 日K技术指标\n// + 分时线(腾讯) + 盘中资金流(外盘-内盘) + 全市场涨跌家数(东财)\n// + 支撑压力位(实时计算) + 消息面(新浪) + 多因子AI分析\n// + ETF管理接口(GET/POST/PUT/DELETE /etfs)\n// 部署文件：new-file-899.ts (val-town HTTP端点)\n// 更新日期：2026-09-05 v2.5 去飞书化\n// ============================================================\n\n// 大盘指数列表\nconst INDEX_LIST = [\n { code: \"000001\", name: \"上证指数\", pre: \"sh\" },\n { code: \"399001\", name: \"深证成指\", pre: \"sz\" },\n { code: \"399006\", name: \"创业板指\", pre: \"sz\" },\n { code: \"000688\", name: \"科创50\", pre: \"sh\" },\n];\n\n// 板块关键词（用于消息面筛选）\nconst SECTOR_KEYWORDS = {\n \"科技\": [\"芯片\", \"半导体\", \"人工智能\", \"AI\", \"算力\", \"机器人\", \"卫星\", \"通信\", \"电子\", \"5G\", \"数据中心\", \"软件\", \"半导体设备\", \"功率\"],\n \"新能源\": [\"电池\", \"储能\", \"锂电\", \"光伏\", \"新能源\", \"固态电池\", \"充电桩\"],\n \"周期\": [\"黄金\", \"有色\", \"稀土\", \"稀有金属\", \"大宗商品\", \"铜\", \"金价\", \"贵金属\"],\n \"医药\": [\"创新药\", \"医药\", \"生物医药\", \"CRO\", \"医疗\", \"药\"],\n \"金融\": [\"银行\", \"券商\", \"保险\", \"金融\"],\n \"宽基\": [\"沪深300\", \"上证50\", \"中证\", \"大盘\", \"A股\"],\n \"其他\": [\"电力\", \"公用事业\", \"能源\"],\n \"消费\": [\"消费\", \"白酒\", \"食品\", \"家电\"],\n \"港股\": [\"港股\", \"恒生\", \"中概\"],\n \"海外\": [\"美股\", \"纳斯达克\", \"标普\", \"海外\"],\n};\n\n// ============ v2.5: ETF配置表（云端SQLite，脱离飞书） ============\n// 初始化ETF配置表并写入种子数据（首次运行时）\nconst ETF_SEED_DATA = [\n { code: \"159562\", name: \"黄金股ETF华夏\", sector: \"周期\" },\n { code: \"159305\", name: \"储能电池ETF广发\", sector: \"新能源\" },\n { code: \"562800\", name: \"稀有金属ETF嘉实\", sector: \"周期\" },\n { code: \"159755\", name: \"电池ETF广发\", sector: \"新能源\" },\n { code: \"159206\", name: \"卫星ETF永赢\", sector: \"科技\" },\n { code: \"159819\", name: \"人工智能ETF\", sector: \"科技\" },\n { code: \"159326\", name: \"电网设备ETF华夏\", sector: \"科技\" },\n { code: \"159995\", name: \"芯片ETF华夏\", sector: \"科技\" },\n { code: \"159770\", name: \"机器人ETF天弘\", sector: \"科技\" },\n { code: \"159300\", name: \"富国沪深300ETF\", sector: \"宽基\" },\n { code: \"588000\", name: \"科创50ETF华夏\", sector: \"宽基\" },\n { code: \"516310\", name: \"银行ETF易方达\", sector: \"金融\" },\n { code: \"562590\", name: \"半导体设备ETF华夏\", sector: \"科技\" },\n { code: \"159611\", name: \"电力ETF广发\", sector: \"其他\" },\n { code: \"516080\", name: \"创新药ETF易方达\", sector: \"医药\" },\n];\n\nasync function ensureEtfConfigTable() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS etf_config (\n code TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n sector TEXT DEFAULT '其他',\n enabled TEXT DEFAULT '是',\n updated_at INTEGER\n )`);\n // 首次初始化：表为空时写入种子数据\n const r = await sqlite.execute(\"SELECT COUNT(*) as cnt FROM etf_config\");\n if (!r.rows || r.rows[0].cnt === 0) {\n for (const e of ETF_SEED_DATA) {\n await sqlite.execute(\"INSERT OR IGNORE INTO etf_config (code, name, sector, enabled, updated_at) VALUES (?,?,?,?,?)\", [e.code, e.name, e.sector, \"是\", Date.now()]);\n }\n console.log(\"[ETF配置] 已写入种子数据 \" + ETF_SEED_DATA.length + \" 只\");\n }\n return true;\n } catch (e) {\n console.error(\"[ETF配置] 初始化失败:\", e.message);\n return false;\n }\n}\n\n// 从云端SQLite读取启用状态的ETF列表\nasync function getEtfListFromSqlite() {\n try {\n await ensureEtfConfigTable();\n const r = await sqlite.execute(\"SELECT code, name, sector, enabled FROM etf_config\");\n const list = [];\n for (const row of (r.rows || [])) {\n if (row.enabled === \"否\") continue; // 跳过停用\n if (!row.code) continue;\n list.push({ code: row.code, name: row.name || row.code, sector: row.sector || \"其他\" });\n }\n return list;\n } catch (e) {\n console.error(\"读取SQLite ETF列表失败:\", e.message);\n return [];\n }\n}\n\n// 读取全部ETF配置（含停用，供管理接口）\nasync function getAllEtfConfig() {\n try {\n await ensureEtfConfigTable();\n const r = await sqlite.execute(\"SELECT code, name, sector, enabled, updated_at FROM etf_config ORDER BY code\");\n return (r.rows || []).map(row => ({ code: row.code, name: row.name, sector: row.sector, enabled: row.enabled, updated_at: row.updated_at }));\n } catch (e) {\n console.error(\"读取全部ETF配置失败:\", e.message);\n return [];\n }\n}\n\nfunction etfPrefix(code) {\n return code.startsWith(\"15\") ? \"sz\" : \"sh\";\n}\n\n// 腾讯行情（GBK解码，批量）\nasync function fetchTencent(symbols) {\n const url = \"https://qt.gtimg.cn/q=\" + symbols;\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\" } });\n const buf = await res.arrayBuffer();\n let text;\n try { text = new TextDecoder(\"gbk\").decode(buf); } catch (e) { text = new TextDecoder(\"utf-8\").decode(buf); }\n const map = {};\n for (const line of text.split(\";\")) {\n const m = line.match(/v_(?:sh|sz)(\\d+)=\"([^\"]+)\"/);\n if (!m) continue;\n const f = m[2].split(\"~\");\n map[m[1]] = {\n name: f[1] || \"\", price: parseFloat(f[3]) || 0, change: parseFloat(f[32]) || 0,\n open: parseFloat(f[5]) || 0, high: parseFloat(f[33]) || 0, low: parseFloat(f[34]) || 0,\n volume: (parseFloat(f[36]) || 0) / 10000, amount: (parseFloat(f[37]) || 0) / 10000,\n outer: parseFloat(f[7]) || 0, inner: parseFloat(f[8]) || 0, // 外盘/内盘(手)\n turnover: parseFloat(f[38]) || 0, // 量比\n };\n }\n return map;\n}\n\n// 获取日K线\nasync function getKLine(code, n) {\n const prefix = etfPrefix(code);\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=\" + prefix + code + \",day,,,\" + n + \",qfq\";\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n const obj = d.data?.[prefix + code];\n const day = obj?.day || obj?.qfqday || [];\n return day.map(k => ({\n date: k[0], open: parseFloat(k[1]) || 0, close: parseFloat(k[2]) || 0,\n high: parseFloat(k[3]) || 0, low: parseFloat(k[4]) || 0, volume: parseFloat(k[5]) || 0,\n }));\n}\n\n// 获取分时数据（腾讯）\nasync function getMinuteData(code) {\n try {\n const prefix = etfPrefix(code);\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=\" + prefix + code;\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n const obj = d.data?.[prefix + code];\n const dataArr = obj?.data?.data || [];\n const date = obj?.data?.date || \"\";\n const points = [];\n for (const line of dataArr) {\n const p = line.split(\" \");\n if (p.length < 4) continue;\n points.push({\n t: p[0], p: parseFloat(p[1]) || 0, v: parseFloat(p[2]) || 0, a: parseFloat(p[3]) || 0,\n });\n }\n if (points.length === 0) return null;\n // 分时统计\n const latest = points[points.length - 1];\n let high = -Infinity, low = Infinity, cumV = 0, cumA = 0;\n for (const pt of points) {\n if (pt.p > high) high = pt.p;\n if (pt.p < low) low = pt.p;\n cumV += pt.v; cumA += pt.a;\n }\n const avgPrice = cumV > 0 ? cumA / (cumV * 100) : latest.p; // 均价 = 金额/股数\n return {\n date, latest: latest.p, avgPrice: Number(avgPrice.toFixed(4)),\n high: Number(high.toFixed(4)), low: Number(low.toFixed(4)),\n points, // 完整分时点（时间/价/量/额）\n };\n } catch (e) {\n console.error(\"分时获取失败 \" + code + \":\", e.message);\n return null;\n }\n}\n\n// EMA\nfunction calcEMA(values, period) {\n if (values.length === 0) return [];\n const k = 2 / (period + 1);\n let ema = values[0];\n const result = [ema];\n for (let i = 1; i < values.length; i++) {\n ema = values[i] * k + ema * (1 - k);\n result.push(ema);\n }\n return result;\n}\n\n// MACD(10,20,7)\nfunction calcMACD(closes) {\n const ema10 = calcEMA(closes, 10);\n const ema20 = calcEMA(closes, 20);\n const dif = closes.map((_, i) => ema10[i] - ema20[i]);\n const dea = calcEMA(dif, 7);\n const macd = dif.map((d, i) => 2 * (d - dea[i]));\n const n = closes.length - 1;\n return { dif: dif[n], dea: dea[n], macd: macd[n], difPrev: dif[n-1], deaPrev: dea[n-1], macdPrev: macd[n-1] };\n}\n\n// MA均线\nfunction calcMA(closes, period) {\n if (closes.length < period) return null;\n return closes.slice(-period).reduce((a, b) => a + b, 0) / period;\n}\n\n// KDJ(9,3,3)\nfunction calcKDJ(klines) {\n const n = 9;\n let k = 50, d = 50, lastK = 50, lastD = 50;\n for (let i = 0; i < klines.length; i++) {\n const start = Math.max(0, i - n + 1);\n let highest = -Infinity, lowest = Infinity;\n for (let j = start; j <= i; j++) {\n highest = Math.max(highest, klines[j].high);\n lowest = Math.min(lowest, klines[j].low);\n }\n const rsv = highest === lowest ? 50 : ((klines[i].close - lowest) / (highest - lowest)) * 100;\n k = (2 / 3) * k + (1 / 3) * rsv;\n d = (2 / 3) * d + (1 / 3) * k;\n lastK = k; lastD = d;\n }\n return { k: lastK, d: lastD, j: 3 * lastK - 2 * lastD };\n}\n\n// 支撑压力位 + 布林带（实时计算，替代硬编码）\nfunction calcSupportResistance(klines, ma20, ma5) {\n const recent = klines.slice(-20);\n let hi20 = -Infinity, lo20 = Infinity;\n for (const k of recent) {\n if (k.high > hi20) hi20 = k.high;\n if (k.low < lo20) lo20 = k.low;\n }\n // 布林带（20日，2倍标准差）\n let std = 0;\n if (klines.length >= 20) {\n const closes = klines.slice(-20).map(k => k.close);\n const mean = closes.reduce((a, b) => a + b, 0) / 20;\n std = Math.sqrt(closes.reduce((a, b) => a + (b - mean) * (b - mean), 0) / 20);\n }\n const bollMid = ma20 || 0;\n const bollUpper = ma20 ? ma20 + 2 * std : 0;\n const bollLower = ma20 ? ma20 - 2 * std : 0;\n // 短期支撑/压力：MA20/布林下轨取较近者\n const support = ma20 && bollLower ? Math.min(ma20, bollLower) : (ma20 || bollLower || lo20);\n const resistance = ma5 && bollUpper ? Math.max(ma5, bollUpper) : (ma5 || bollUpper || hi20);\n return {\n support: Number(support.toFixed(4)),\n resistance: Number(resistance.toFixed(4)),\n hi20: Number(hi20.toFixed(4)),\n lo20: Number(lo20.toFixed(4)),\n bollUpper: Number(bollUpper.toFixed(4)),\n bollLower: Number(bollLower.toFixed(4)),\n bollMid: Number(bollMid.toFixed(4)),\n };\n}\n\n// 获取资金流（新浪，最近N日 - T-1数据）\nasync function getFundFlow(code, days) {\n try {\n const prefix = etfPrefix(code);\n const url = \"https://vip.stock.finance.sina.com.cn/quotes_service/api/json_v2.php/MoneyFlow.ssl_qsfx_zjlrqs?page=1&num=\" + days + \"&sort=opendate&asc=0&daima=\" + prefix + code;\n const res = await fetch(url, { headers: { \"Referer\": \"https://finance.sina.com.cn/\", \"User-Agent\": \"Mozilla/5.0\" } });\n const text = await res.text();\n const clean = text.replace(/^[^(]*\$/, \"\").replace(/\$\\s*;?\\s*$/, \"\");\n let data;\n try { data = JSON.parse(clean); } catch (e) { data = JSON.parse(text); }\n if (!Array.isArray(data) || data.length === 0) return null;\n const latest = data[0];\n return {\n date: String(latest.opendate || \"\"),\n netAmount: Math.round(Number(latest.netamount) || 0),\n ratio: Number(latest.ratioamount) || 0,\n mainNet: Math.round(Number(latest.r0_net) || 0),\n mainRatio: Number(latest.r0_ratio) || 0,\n };\n } catch (e) {\n console.error(\"资金流获取失败 \" + code + \":\", e.message);\n return null;\n }\n}\n\n// 全市场涨跌家数（东财）\nasync function getMarketBreadth() {\n try {\n const url = \"https://push2.eastmoney.com/api/qt/ulist.np/get?fltt=2&secids=1.000001,0.399001&fields=f104,f105,f106\";\n const res = await fetch(url, { headers: { \"Referer\": \"https://quote.eastmoney.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n const diff = d.data?.diff || [];\n if (diff.length < 2) return null;\n const sh = diff[0], sz = diff[1];\n return {\n up: (sh.f104 || 0) + (sz.f104 || 0),\n down: (sh.f105 || 0) + (sz.f105 || 0),\n flat: (sh.f106 || 0) + (sz.f106 || 0),\n source: \"eastmoney\",\n };\n } catch (e) {\n console.error(\"涨跌家数获取失败:\", e.message);\n return null;\n }\n}\n\n// 获取消息面（新浪财经要闻，按板块关键词筛选）\nlet _newsCache = { time: 0, data: [] };\nasync function getNews() {\n const now = Date.now();\n if (_newsCache.data.length > 0 && now - _newsCache.time < 10 * 60 * 1000) return _newsCache.data;\n try {\n const url = \"https://feed.mix.sina.com.cn/api/roll/get?pageid=153&lid=2516&k=&num=30&page=1&r=\" + Math.random();\n const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n const items = d.result?.data || [];\n const news = items.map(n => ({ title: String(n.title || \"\"), time: String(n.ctime || \"\") }));\n _newsCache = { time: now, data: news };\n return news;\n } catch (e) {\n console.error(\"消息面获取失败:\", e.message);\n return _newsCache.data;\n }\n}\n\n// 多因子技术分析引擎（升级版：含分时、盘中资金流、支撑压力）\nfunction generateAnalysis(e) {\n const parts = [];\n const price = e.price, ma5 = e.ma5, ma10 = e.ma10, ma20 = e.ma20;\n const dif = e.dif, dea = e.dea, macd = e.macd, macdPrev = e.macdPrev;\n const k = e.kdjK, d = e.kdjD, j = e.kdjJ;\n const volRatio = e.volRatio;\n\n // 1. 均线\n let maTxt;\n if (price >= ma5 && ma5 >= ma10 && ma10 >= ma20) maTxt = \"均线多头排列（价>MA5>MA10>MA20），趋势向上\";\n else if (price <= ma5 && ma5 <= ma10 && ma10 <= ma20) maTxt = \"均线空头排列（价 ma5 && price > ma10 && ma10 < ma20) maTxt = \"价格站上5/10日线但MA10 ma20) maTxt = \"价格跌破5/10日线但MA10>MA20，短弱中强\";\n else maTxt = \"均线交织缠绕，方向不明\";\n parts.push(\"【均线】MA5=\" + ma5.toFixed(3) + \" MA10=\" + ma10.toFixed(3) + \" MA20=\" + ma20.toFixed(3) + \"，\" + maTxt);\n\n // 2. MACD\n let macdTxt;\n if (dif > dea && dif > 0) macdTxt = \"MACD多头（DIF>DEA且零轴上方）\";\n else if (dif > dea && dif < 0) macdTxt = \"MACD低位金叉（零轴下方DIF上穿DEA）\";\n else if (dif < dea && dif > 0) macdTxt = \"MACD高位死叉（零轴上方DIF下穿DEA）\";\n else macdTxt = \"MACD空头（DIF= macdPrev) macdTxt += \"，柱体/动能放大\";\n else macdTxt += \"，柱体/动能收窄\";\n parts.push(\"【MACD】DIF=\" + dif.toFixed(4) + \" DEA=\" + dea.toFixed(4) + \" 柱=\" + macd.toFixed(4) + \"，\" + macdTxt);\n\n // 3. KDJ\n let kdjTxt;\n if (k > 80 || j > 100) kdjTxt = \"KDJ超买区（K=\" + k.toFixed(0) + \"）\";\n else if (k < 20 || j < 0) kdjTxt = \"KDJ超卖区（K=\" + k.toFixed(0) + \"）\";\n else if (k > d) kdjTxt = \"KDJ金叉向上（K>D）\";\n else kdjTxt = \"KDJ死叉向下（K 1.5) volTxt = \"放量（量比\" + volRatio.toFixed(1) + \"）\";\n else if (volRatio > 1.2) volTxt = \"温和放量（量比\" + volRatio.toFixed(1) + \"）\";\n else if (volRatio < 0.7) volTxt = \"明显缩量（量比\" + volRatio.toFixed(1) + \"）\";\n else if (volRatio < 0.9) volTxt = \"缩量（量比\" + volRatio.toFixed(1) + \"）\";\n else volTxt = \"量能平稳（量比\" + volRatio.toFixed(1) + \"）\";\n parts.push(\"【量能】今日量/5日均量=\" + volRatio.toFixed(2) + \"，\" + volTxt);\n\n // 5. 盘中资金流向（外盘-内盘，实时）\n if (e.activeFlow) {\n const netHand = e.activeFlow.netHand;\n const flowTxt = netHand >= 0\n ? \"主动买盘占优（外盘-内盘+\" + (netHand / 10000).toFixed(2) + \"万手）\"\n : \"主动卖盘占优（外盘-内盘-\" + (Math.abs(netHand) / 10000).toFixed(2) + \"万手）\";\n parts.push(\"【盘中资金】\" + flowTxt + \"，为实时主动买卖力量\");\n }\n\n // 6. 资金流（T-1，如有）\n if (e.fundFlow) {\n const ff = e.fundFlow;\n const mainTxt = ff.mainNet >= 0 ? \"主力净流入\" + (ff.mainNet / 100000000).toFixed(2) + \"亿\" : \"主力净流出\" + (Math.abs(ff.mainNet) / 100000000).toFixed(2) + \"亿\";\n parts.push(\"【昨日主力】\" + mainTxt + \"，净流入率\" + (ff.mainRatio * 100).toFixed(1) + \"%（T-1，\" + ff.date + \"）\");\n }\n\n // 7. 分时状态（如有）\n if (e.minute) {\n const mv = e.minute;\n const vsAvg = price >= mv.avgPrice ? \"运行于分时均价上方（多头）\" : \"运行于分时均价下方（空头）\";\n const half = Math.floor(mv.points.length / 2);\n const secondHalf = mv.points.slice(half);\n let later = 0;\n for (const pt of secondHalf) later += pt.v;\n const firstHalf = mv.points.slice(0, half);\n let early = 0;\n for (const pt of firstHalf) early += pt.v;\n const flowDir = later > early ? \"午后/尾盘量能放大\" : \"午后/尾盘量能萎缩\";\n parts.push(\"【分时】\" + vsAvg + \"，分时均价=\" + mv.avgPrice.toFixed(3) + \"，\" + flowDir);\n }\n\n // 8. 消息面（如有相关）\n if (e.news && e.news.length > 0) {\n const newsTxt = e.news.slice(0, 2).map(n => n.title).join(\"；\");\n parts.push(\"【消息】\" + newsTxt);\n }\n\n // 9. 综合评分（v2.3.1：技术面为主，实时因子降权平滑，避免单日盘中波动剧烈反转结论）\n let score = 50;\n // --- 技术面（权重高，占主导，随日K稳定） ---\n if (price >= ma5) score += 6; else score -= 6;\n if (price >= ma10) score += 5; else score -= 5;\n if (price >= ma20) score += 5; else score -= 5;\n if (ma5 >= ma10) score += 4; else score -= 4;\n if (ma10 >= ma20) score += 4; else score -= 4;\n if (dif >= dea) score += 7; else score -= 7;\n if (dif >= 0) score += 5; else score -= 5;\n if (macd >= macdPrev) score += 3; else score -= 3;\n if (k >= d) score += 3; else score -= 3;\n // --- 实时因子（低权重，仅微调，防剧烈跳变） ---\n // 当日涨跌幅：平滑映射，封顶±3（原±5）\n if (e.change > 0) score += Math.min(3, e.change * 1.5); else score -= Math.min(3, Math.abs(e.change) * 1.5);\n // 量价配合：封顶±2（原±4）\n if (e.change > 0 && volRatio >= 1.1) score += 2;\n if (e.change < 0 && volRatio >= 1.3) score -= 2;\n if (e.change < 0 && volRatio <= 0.8) score += 1;\n // 盘中资金流（外盘-内盘）：封顶±2（原±3）\n if (e.activeFlow) {\n if (e.activeFlow.netHand > 0) score += 2;\n if (e.activeFlow.netHand < 0 && Math.abs(e.activeFlow.netHand) > 50000) score -= 2;\n }\n // T-1主力资金\n if (e.fundFlow) {\n if (e.fundFlow.mainNet > 0) score += 2;\n if (e.fundFlow.mainNet < -1e8) score -= 2;\n }\n // 分时强弱：封顶±1（原±2）\n if (e.minute) {\n if (price >= e.minute.avgPrice) score += 1; else score -= 1;\n }\n score = Math.max(5, Math.min(95, score));\n\n // 10. 走势判断\n let trend;\n if (score >= 70) trend = \"偏多\";\n else if (score >= 60) trend = \"震荡偏多\";\n else if (score >= 45) trend = \"震荡\";\n else if (score >= 35) trend = \"震荡偏空\";\n else trend = \"偏空\";\n\n // 11. 操作建议（含支撑压力位）\n let action;\n if (score >= 70) action = \"加仓/持有：趋势向上，回踩MA5/支撑位可加仓，跌破MA10减仓\";\n else if (score >= 60) action = \"持有偏加：多头占优，逢低分批加仓，止损位MA20/布林下轨\";\n else if (score >= 50) action = \"持有观望：多空均衡，等待方向选择，轻仓参与\";\n else if (score >= 40) action = \"减仓/观望：偏弱格局，反弹至压力位减仓，不宜重仓\";\n else action = \"回避：弱势明显，等待企稳信号，勿盲目抄底\";\n\n const support = e.sr ? e.sr.support.toFixed(3) : (ma20 ? ma20.toFixed(3) : \"-\");\n const resist = e.sr ? e.sr.resistance.toFixed(3) : (ma5 ? ma5.toFixed(3) : \"-\");\n const summary = \"综合评分\" + score.toFixed(0) + \"分，短期走势【\" + trend + \"】。关键支撑位\" + support + \"，压力位\" + resist + \"。\" + action;\n\n return { score, trend, action, analysis: parts.join(\"。\") + \"。\" + summary };\n}\n\n// 计算ETF全指标+分析\nasync function calcEtfIndicators(quote, newsList) {\n const [klines, minuteData] = await Promise.all([getKLine(quote.code, 60), getMinuteData(quote.code)]);\n if (klines.length < 25) {\n return { code: quote.code, name: quote.name, sector: quote.sector, ...quote, minute: minuteData, klineError: \"K线不足\", score: 50, trend: \"震荡\", action: \"数据不足\", analysis: \"K线数据不足，无法计算完整技术指标\" };\n }\n const closes = klines.map(k => k.close);\n const vols = klines.map(k => k.volume);\n const ma5 = calcMA(closes, 5);\n const ma10 = calcMA(closes, 10);\n const ma20 = calcMA(closes, 20);\n const macd = calcMACD(closes);\n const kdj = calcKDJ(klines);\n const vol5 = vols.slice(-6, -1).reduce((a, b) => a + b, 0) / 5;\n const volRatio = vol5 > 0 ? vols[vols.length - 1] / vol5 : 0;\n const last = klines[klines.length - 1];\n const kline = { date: last.date, open: last.open, close: last.close, high: last.high, low: last.low, prevClose: klines[klines.length - 2].close };\n\n // 盘中资金流向（外盘-内盘，实时）\n const activeFlow = {\n netHand: (quote.outer || 0) - (quote.inner || 0),\n outer: quote.outer || 0,\n inner: quote.inner || 0,\n };\n\n // 支撑压力位（实时计算）\n const sr = calcSupportResistance(klines, ma20, ma5);\n\n // 资金流（T-1，异步）\n let fundFlow = null;\n try { fundFlow = await getFundFlow(quote.code, 3); } catch (e) { fundFlow = null; }\n\n // 消息面筛选（按板块）\n const keywords = SECTOR_KEYWORDS[quote.sector] || [];\n const sectorNews = keywords.length > 0\n ? newsList.filter(n => keywords.some(kw => n.title.includes(kw)))\n : [];\n\n const base = {\n code: quote.code, name: quote.name, sector: quote.sector,\n price: quote.price, change: quote.change, open: quote.open, high: quote.high, low: quote.low,\n volume: quote.volume, amount: quote.amount,\n ma5, ma10, ma20,\n dif: macd.dif, dea: macd.dea, macd: macd.macd,\n difPrev: macd.difPrev, deaPrev: macd.deaPrev, macdPrev: macd.macdPrev,\n kdjK: kdj.k, kdjD: kdj.d, kdjJ: kdj.j,\n volRatio, kline, fundFlow, news: sectorNews,\n activeFlow, sr, minute: minuteData,\n };\n return { ...base, ...generateAnalysis(base) };\n}\n\n// 大盘指数实时\nasync function getIndexRealTime() {\n try {\n const symbols = INDEX_LIST.map(i => i.pre + i.code).join(\",\");\n const map = await fetchTencent(symbols);\n return INDEX_LIST.map(i => ({\n code: i.code, name: i.name,\n ...(map[i.code] || { price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }),\n }));\n } catch (e) {\n console.error(\"指数获取失败:\", e.message);\n return INDEX_LIST.map(i => ({ code: i.code, name: i.name, price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }));\n }\n}\n\n// ETF实时行情\nasync function getEtfRealTime(etfList) {\n try {\n const symbols = etfList.map(e => etfPrefix(e.code) + e.code).join(\",\");\n const map = await fetchTencent(symbols);\n return etfList.map(e => ({\n code: e.code, name: e.name, sector: e.sector,\n ...(map[e.code] || { price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }),\n }));\n } catch (e) {\n console.error(\"ETF获取失败:\", e.message);\n return etfList.map(e => ({ code: e.code, name: e.name, sector: e.sector, price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }));\n }\n}\n\nfunction beijingTime() {\n const d = new Date(Date.now() + 8 * 3600 * 1000);\n return d.toISOString().replace(\"T\", \" \").substring(0, 19);\n}\n\n// ============ 深度分析（火山方舟LLM，手动触发，次数可控） ============\n// 常量：每日免费深度分析次数上限\nconst DEEP_ANALYSIS_DAILY_LIMIT = 10;\n// 火山方舟模型\nconst ARK_MODEL = \"doubao-seed-2-0-pro-260215\";\nconst ARK_BASE_URL = \"https://ark.cn-beijing.volces.com/api/v3/chat/completions\";\n\n// 记录深度分析调用（返回今日已用次数）\nasync function recordDeepAnalysisUsage() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS deep_analysis_usage (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n date TEXT NOT NULL,\n code TEXT,\n name TEXT,\n created_at INTEGER NOT NULL,\n prompt_tokens INTEGER DEFAULT 0,\n completion_tokens INTEGER DEFAULT 0,\n status TEXT DEFAULT 'ok'\n )`);\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n const dateStr = bjNow.toISOString().substring(0, 10);\n return dateStr;\n } catch (e) {\n console.error(\"深度分析用量表初始化失败:\", e.message);\n return null;\n }\n}\n\n// 查询某日已用深度分析次数\nasync function getDeepAnalysisUsedCount(dateStr) {\n try {\n const r = await sqlite.execute(\n \"SELECT COUNT(*) as c FROM deep_analysis_usage WHERE date = ?\",\n [dateStr]\n );\n return r.rows?.[0]?.c ?? 0;\n } catch (e) {\n console.error(\"查询深度分析次数失败:\", e.message);\n return 0;\n }\n}\n\n// 写一条深度分析用量记录\nasync function logDeepAnalysisUsage(dateStr, code, name, promptTokens, completionTokens, status) {\n try {\n await sqlite.execute(\n \"INSERT INTO deep_analysis_usage (date, code, name, created_at, prompt_tokens, completion_tokens, status) VALUES (?,?,?,?,?,?,?)\",\n [dateStr, code, name, Date.now(), promptTokens || 0, completionTokens || 0, status || 'ok']\n );\n } catch (e) {\n console.error(\"写深度分析用量失败:\", e.message);\n }\n}\n\n// ============ v2.3.1: 深度分析结果持久化（供复盘查看） ============\n// 新建 deep_analysis_log 表：完整保存每次深度分析结果，跨请求可查\nasync function initDeepAnalysisLog() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS deep_analysis_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n date TEXT NOT NULL,\n code TEXT NOT NULL,\n name TEXT,\n sector TEXT,\n analysis TEXT,\n price REAL,\n change REAL,\n created_at INTEGER NOT NULL\n )`);\n return true;\n } catch (e) {\n console.error(\"[深度分析] log表初始化失败:\", e.message);\n return false;\n }\n}\n\n// 保存一条深度分析结果\nasync function saveDeepAnalysisLog(etf, quote, analysis) {\n try {\n await initDeepAnalysisLog();\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n const dateStr = bjNow.toISOString().substring(0, 10);\n await sqlite.execute(\n \"INSERT INTO deep_analysis_log (date, code, name, sector, analysis, price, change, created_at) VALUES (?,?,?,?,?,?,?,?)\",\n [dateStr, etf.code, etf.name, etf.sector || \"\", analysis, quote.price || 0, quote.change || 0, Date.now()]\n );\n return true;\n } catch (e) {\n console.error(\"[深度分析] 保存失败:\", e.message);\n return false;\n }\n}\n\n// 读取某ETF的历史深度分析（默认最近10条；不传code则返回全部最近N条）\nasync function getDeepAnalysisHistory(code, limit) {\n try {\n await initDeepAnalysisLog();\n const n = Math.min(Math.max(parseInt(limit || \"10\", 10) || 10, 1), 50);\n let rows;\n if (code) {\n const r = await sqlite.execute(\n \"SELECT * FROM deep_analysis_log WHERE code = ? ORDER BY id DESC LIMIT ?\",\n [code, n]\n );\n rows = r.rows || [];\n } else {\n const r = await sqlite.execute(\n \"SELECT * FROM deep_analysis_log ORDER BY id DESC LIMIT ?\",\n [n]\n );\n rows = r.rows || [];\n }\n return rows.map(r => ({\n id: r.id, date: r.date, code: r.code, name: r.name, sector: r.sector,\n analysis: r.analysis, price: r.price, change: r.change, created_at: r.created_at,\n }));\n } catch (e) {\n console.error(\"[深度分析] 读取历史失败:\", e.message);\n return [];\n }\n}\n\n// ============ v2.4: 删除记录 ============\n// 删除单条深度分析记录（按id）\nasync function deleteDeepAnalysisById(id) {\n try {\n await initDeepAnalysisLog();\n const r = await sqlite.execute(\"DELETE FROM deep_analysis_log WHERE id = ?\", [Number(id)]);\n return { deleted: r.rowsAffected || 0 };\n } catch (e) {\n console.error(\"[深度分析] 删除失败:\", e.message);\n return { error: e.message };\n }\n}\n\n// 删除某ETF全部深度分析记录（按code）\nasync function deleteDeepAnalysisByCode(code) {\n try {\n await initDeepAnalysisLog();\n const r = await sqlite.execute(\"DELETE FROM deep_analysis_log WHERE code = ?\", [code]);\n return { deleted: r.rowsAffected || 0 };\n } catch (e) {\n console.error(\"[深度分析] 删除失败:\", e.message);\n return { error: e.message };\n }\n}\n\n// 删除历史时段分析记录（按date，可指定period；不传period删除整天）\nasync function deleteHistoryRecord(date, period) {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS analysis_history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n date TEXT NOT NULL,\n period TEXT NOT NULL,\n label TEXT,\n created_at INTEGER NOT NULL,\n summary TEXT,\n records TEXT\n )`);\n let r;\n if (period) {\n // v2.4.1: period 参数可能是代码(period字段)或时段名(label字段)，两者都匹配\n r = await sqlite.execute(\"DELETE FROM analysis_history WHERE date = ? AND (period = ? OR label = ?)\", [date, period, period]);\n } else {\n r = await sqlite.execute(\"DELETE FROM analysis_history WHERE date = ?\", [date]);\n }\n return { deleted: r.rowsAffected || 0 };\n } catch (e) {\n console.error(\"[历史] 删除失败:\", e.message);\n return { error: e.message };\n }\n}\n\n// 调用火山方舟LLM做深度分析\nasync function callArkDeepAnalysis(etf, quote) {\n const apiKey = Deno.env.get(\"ARK_API_KEY\");\n if (!apiKey) {\n return { error: \"未配置ARK_API_KEY，请先在val-town环境变量中添加\" };\n }\n // 构建分析prompt：把该ETF的技术面+资金面+消息面数据打包\n const prompt = `你是一位专业ETF短线投资者，请对以下ETF进行深度分析，输出结构化的投资分析报告。\n\n## 标的\n名称：${etf.name}（代码${etf.code}，板块：${etf.sector}）\n\n## 实时行情\n- 现价：${quote.price}\n- 当日涨跌幅：${quote.change}%\n- 成交量：${quote.volume}万手\n- 成交额：${quote.amount}亿元\n\n## 技术指标（基于日K）\n- MA5=${etf.ma5?.toFixed(3)} MA10=${etf.ma10?.toFixed(3)} MA20=${etf.ma20?.toFixed(3)}\n- MACD: DIF=${etf.dif?.toFixed(4)} DEA=${etf.dea?.toFixed(4)} 柱=${etf.macd?.toFixed(4)}\n- KDJ: K=${etf.kdjK?.toFixed(1)} D=${etf.kdjD?.toFixed(1)} J=${etf.kdjJ?.toFixed(1)}\n- 量比：${etf.volRatio?.toFixed(2)}\n- 支撑位：${etf.support} 压力位：${etf.resistance}\n\n## 资金面\n${etf.fundFlow ? `- 昨日主力净流入：${(etf.fundFlow.mainNet/100000000).toFixed(2)}亿（${etf.fundFlow.date}）` : \"- 昨日主力资金：暂无数据\"}\n${etf.activeFlow ? `- 盘中主动买卖：外盘-内盘=${(etf.activeFlow.netHand/10000).toFixed(2)}万手` : \"\"}\n\n## 相关消息\n${etf.news && etf.news.length ? etf.news.slice(0,3).map(n=>n.title).join(\"\\n\") : \"暂无相关消息\"}\n\n## 要求\n请从以下维度给出深度分析（不要复述数据，要有独立判断）：\n1. **技术面研判**：均线系统状态、MACD动能、KDJ位置、量价配合，给出技术形态判断\n2. **资金面研判**：主力资金流向含义、盘中买卖力量\n3. **消息面研判**：结合当前板块政策/行业动态，判断消息的利好利空方向及影响程度\n4. **综合判断**：给出明确的操作观点（偏多/震荡偏多/震荡/震荡偏空/偏空），以及1-3天走势预判\n5. **风险提示**：指出关键风险点、止损位\n\n请用中文回答，控制在400字以内，条理清晰，观点明确。`;\n\n try {\n const res = await fetch(ARK_BASE_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": \"Bearer \" + apiKey,\n },\n body: JSON.stringify({\n model: ARK_MODEL,\n messages: [\n { role: \"system\", content: \"你是一位资深的ETF短线交易分析师，擅长技术分析、资金流分析和板块轮动研判。\" },\n { role: \"user\", content: prompt },\n ],\n temperature: 0.3,\n max_tokens: 1200,\n }),\n });\n const d = await res.json();\n if (d.error) {\n return { error: \"LLM调用失败: \" + (d.error.message || JSON.stringify(d.error)) };\n }\n const content = d.choices?.[0]?.message?.content || \"\";\n const usage = d.usage || {};\n return {\n content,\n promptTokens: usage.prompt_tokens || 0,\n completionTokens: usage.completion_tokens || 0,\n model: ARK_MODEL,\n };\n } catch (e) {\n console.error(\"LLM调用异常:\", e.message);\n return { error: \"LLM调用异常: \" + e.message };\n }\n}\n\n// ============ 历史存档读取（SQLite global组织级库，跨val共享） ============\nasync function getHistory() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS analysis_history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n date TEXT NOT NULL,\n period TEXT NOT NULL,\n label TEXT,\n created_at INTEGER NOT NULL,\n summary TEXT,\n records TEXT\n )`);\n // 最近30天所有时段的分析记录\n const r = await sqlite.execute(\n `SELECT * FROM analysis_history WHERE created_at > ? ORDER BY created_at DESC LIMIT 2000`,\n [Date.now() - 30 * 24 * 3600 * 1000]\n );\n const rows = r.rows || [];\n // 解析每条ETF记录\n const history = [];\n for (const row of rows) {\n try {\n const etf = JSON.parse(row.records);\n history.push({\n date: row.date, period: row.period, label: row.label, created_at: row.created_at,\n code: etf.code, name: etf.name, sector: etf.sector,\n price: etf.price, change: etf.change, volume: etf.volume, amount: etf.amount,\n dif: etf.dif, dea: etf.dea, macd: etf.macd,\n ma5: etf.ma5, ma10: etf.ma10, ma20: etf.ma20,\n kdjK: etf.kdjK, kdjD: etf.kdjD, kdjJ: etf.kdjJ,\n volRatio: etf.volRatio, score: etf.score, trend: etf.trend, action: etf.action,\n analysis: etf.analysis, support: etf.support, resistance: etf.resistance,\n });\n } catch (e) {}\n }\n // 按日期+时段聚合摘要\n const groups = {};\n for (const row of rows) {\n const key = row.date;\n if (!groups[key]) groups[key] = [];\n if (!groups[key].find(g => g.label === row.label)) {\n let summary = {};\n try { summary = JSON.parse(row.summary || \"{}\"); } catch (e) {}\n groups[key].push({ label: row.label, count: summary.count, upCount: summary.upCount, downCount: summary.downCount, avgScore: summary.avgScore, best: summary.best, worst: summary.worst });\n }\n }\n return { history, groups, total: history.length, latestDate: rows[0]?.date || null };\n } catch (e) {\n console.error(\"读取历史失败:\", e.message);\n return { history: [], groups: {}, total: 0, error: e.message };\n }\n}\n\nexport default async function (req) {\n const url = new URL(req.url);\n const path = url.pathname;\n // ===== v2.4.1: CORS 预检处理（修复前端DELETE跨域被拦截） =====\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization, X-Requested-With\",\n \"Access-Control-Max-Age\": \"86400\",\n },\n });\n }\n // ===== v2.5: ETF管理接口（增删ETF，脱离飞书） =====\n if (path === \"/etfs\") {\n await ensureEtfConfigTable();\n if (req.method === \"GET\") {\n // ?enabled=1 只返回启用；否则返回全部（含停用）\n const onlyEnabled = url.searchParams.get(\"enabled\") === \"1\";\n const all = await getAllEtfConfig();\n const list = onlyEnabled ? all.filter(e => e.enabled !== \"否\") : all;\n return Response.json({ success: true, timestamp: beijingTime(), count: list.length, list }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n if (req.method === \"POST\") {\n // 新增ETF：body { code, name, sector }\n try {\n const body = await req.json();\n const code = String(body.code || \"\").trim();\n if (!code) return Response.json({ success: false, message: \"缺少ETF代码\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n const name = String(body.name || code).trim();\n const sector = String(body.sector || \"其他\").trim();\n const exist = await sqlite.execute(\"SELECT code FROM etf_config WHERE code = ?\", [code]);\n if (exist.rows && exist.rows.length > 0) {\n return Response.json({ success: false, message: \"ETF \" + code + \" 已存在，请用PUT更新\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n await sqlite.execute(\"INSERT INTO etf_config (code, name, sector, enabled, updated_at) VALUES (?,?,?,?,?)\", [code, name, sector, \"是\", Date.now()]);\n return Response.json({ success: true, message: \"已添加ETF \" + code + \" \" + name }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n } catch (e) {\n return Response.json({ success: false, message: \"添加失败: \" + e.message }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n }\n if (req.method === \"PUT\") {\n // 更新ETF：?code=XXX，body { name?, sector?, enabled? }\n try {\n const code = url.searchParams.get(\"code\");\n if (!code) return Response.json({ success: false, message: \"缺少code参数\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n const body = await req.json();\n const name = body.name != null ? String(body.name).trim() : null;\n const sector = body.sector != null ? String(body.sector).trim() : null;\n const enabled = body.enabled != null ? String(body.enabled).trim() : null;\n const exist = await sqlite.execute(\"SELECT code FROM etf_config WHERE code = ?\", [code]);\n if (!exist.rows || exist.rows.length === 0) return Response.json({ success: false, message: \"ETF \" + code + \" 不存在\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n const sets = [], vals = [];\n if (name !== null) { sets.push(\"name = ?\"); vals.push(name); }\n if (sector !== null) { sets.push(\"sector = ?\"); vals.push(sector); }\n if (enabled !== null) { sets.push(\"enabled = ?\"); vals.push(enabled); }\n if (sets.length === 0) return Response.json({ success: false, message: \"没有要更新的字段（name/sector/enabled）\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n sets.push(\"updated_at = ?\"); vals.push(Date.now());\n vals.push(code);\n await sqlite.execute(\"UPDATE etf_config SET \" + sets.join(\", \") + \" WHERE code = ?\", vals);\n return Response.json({ success: true, message: \"已更新ETF \" + code }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n } catch (e) {\n return Response.json({ success: false, message: \"更新失败: \" + e.message }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n }\n if (req.method === \"DELETE\") {\n // 删除ETF：?code=XXX（彻底删除）\n const code = url.searchParams.get(\"code\");\n if (!code) return Response.json({ success: false, message: \"缺少code参数\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n const r = await sqlite.execute(\"DELETE FROM etf_config WHERE code = ?\", [code]);\n return Response.json({ success: true, message: \"已删除ETF \" + code, deleted: r.rowsAffected || 0 }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n return Response.json({ success: false, message: \"不支持的方法: \" + req.method }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n // ===== v2.4: 删除记录接口 =====\n if (path === \"/deep-analysis/history\" && req.method === \"DELETE\") {\n const id = url.searchParams.get(\"id\");\n const code = url.searchParams.get(\"code\");\n if (id) {\n const r = await deleteDeepAnalysisById(id);\n return Response.json({ success: !r.error, timestamp: beijingTime(), ...r }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n if (code) {\n const r = await deleteDeepAnalysisByCode(code);\n return Response.json({ success: !r.error, timestamp: beijingTime(), ...r }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n return Response.json({ success: false, message: \"请指定要删除的记录：?id=单条ID 或 ?code=ETF代码\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n if (path === \"/history\" && req.method === \"DELETE\") {\n const date = url.searchParams.get(\"date\");\n if (!date) {\n return Response.json({ success: false, message: \"请指定要删除的日期：?date=YYYY-MM-DD&period=可选时段\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n const period = url.searchParams.get(\"period\") || \"\";\n const r = await deleteHistoryRecord(date, period || null);\n return Response.json({ success: !r.error, timestamp: beijingTime(), ...r }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n if (path === \"/history\" || url.searchParams.get(\"history\") === \"1\") {\n const h = await getHistory();\n return Response.json({ success: true, timestamp: beijingTime(), ...h }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n // ===== 深度分析（LLM，次数可控） =====\n if (path === \"/deep-analysis/quota\" || url.searchParams.get(\"quota\") === \"1\") {\n const dateStr = await recordDeepAnalysisUsage();\n const used = dateStr ? await getDeepAnalysisUsedCount(dateStr) : 0;\n return Response.json({ success: true, timestamp: beijingTime(), date: dateStr, used, limit: DEEP_ANALYSIS_DAILY_LIMIT, remaining: Math.max(0, DEEP_ANALYSIS_DAILY_LIMIT - used) }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n if (path === \"/deep-analysis/history\" || url.searchParams.get(\"dahistory\") === \"1\") {\n const code = url.searchParams.get(\"code\") || \"\";\n const limit = url.searchParams.get(\"limit\") || \"10\";\n const list = await getDeepAnalysisHistory(code || null, limit);\n return Response.json({ success: true, timestamp: beijingTime(), count: list.length, list }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n if (path === \"/deep-analysis\" && (req.method === \"GET\" || req.method === \"POST\")) {\n const code = url.searchParams.get(\"code\");\n if (!code) {\n return Response.json({ success: false, message: \"缺少code参数，请指定ETF代码如 /deep-analysis?code=159562\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n // 检查今日配额\n const dateStr = await recordDeepAnalysisUsage();\n if (!dateStr) {\n return Response.json({ success: false, message: \"深度分析配额系统初始化失败\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n const used = await getDeepAnalysisUsedCount(dateStr);\n if (used >= DEEP_ANALYSIS_DAILY_LIMIT) {\n return Response.json({ success: false, message: \"今日深度分析次数已用完（\" + DEEP_ANALYSIS_DAILY_LIMIT + \"次），请明日再试\", used, limit: DEEP_ANALYSIS_DAILY_LIMIT }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n // 从缓存或实时获取该ETF数据\n let etf = null;\n let quote = null;\n try {\n const etfList = await getEtfListFromSqlite();\n const etfMeta = etfList.find(e => e.code === code);\n if (!etfMeta) {\n return Response.json({ success: false, message: \"ETF代码\" + code + \"不在监控列表（请先在飞书基础信息库添加）\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n const quotes = await getEtfRealTime([etfMeta]);\n const q = quotes[0] || {};\n const newsList = await getNews();\n const analyzed = await calcEtfIndicators({ ...etfMeta, ...q }, newsList);\n if (analyzed.klineError) {\n return Response.json({ success: false, message: \"该ETF数据不足: \" + analyzed.klineError }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n etf = analyzed;\n quote = q;\n } catch (e) {\n return Response.json({ success: false, message: \"获取ETF数据失败: \" + e.message }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n // 调用LLM深度分析\n const result = await callArkDeepAnalysis(etf, quote);\n // 记录用量（无论成败都计数，防止刷接口）\n const promptTokens = result.promptTokens || 0;\n const completionTokens = result.completionTokens || 0;\n await logDeepAnalysisUsage(dateStr, code, etf.name, promptTokens, completionTokens, result.error ? 'error' : 'ok');\n if (result.error) {\n return Response.json({ success: false, message: result.error, code, name: etf.name }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n // v2.3.1: 保存分析结果到SQLite，供复盘查看\n try { await saveDeepAnalysisLog(etf, quote, result.content); } catch (e) { console.error(\"保存深度分析结果失败:\", e.message); }\n return Response.json({ success: true, timestamp: beijingTime(), code, name: etf.name, sector: etf.sector, analysis: result.content, promptTokens, completionTokens, remaining: Math.max(0, DEEP_ANALYSIS_DAILY_LIMIT - used - 1) }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n const refresh = url.searchParams.get(\"refresh\");\n if (refresh === \"1\" || !globalThis._cachedData || Date.now() - globalThis._cacheTime > 30 * 1000) {\n try {\n // 动态读取ETF列表\n const etfList = await getEtfListFromSqlite();\n if (etfList.length === 0) {\n return Response.json({ success: false, timestamp: beijingTime(), message: \"飞书ETF基础信息库为空或读取失败\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n // 获取指数、ETF行情、消息面、全市场涨跌家数\n const [indices, etfQuotes, newsList, breadth] = await Promise.all([getIndexRealTime(), getEtfRealTime(etfList), getNews(), getMarketBreadth()]);\n // 逐只计算指标+分析（K线与分时并行）\n const etfs = [];\n for (const q of etfQuotes) {\n etfs.push(await calcEtfIndicators(q, newsList));\n }\n // 大盘盘面统计\n const upCount = etfs.filter(e => e.change > 0).length;\n const downCount = etfs.filter(e => e.change < 0).length;\n const flatCount = etfs.filter(e => e.change === 0).length;\n const avgChange = etfs.reduce((a, e) => a + e.change, 0) / (etfs.length || 1);\n const market = {\n upCount, downCount, flatCount, avgChange: Number(avgChange.toFixed(2)),\n totalAmount: Number(((indices[0]?.amount || 0) + (indices[1]?.amount || 0)).toFixed(2)),\n etfCount: etfs.length,\n // 全市场涨跌家数（东财，可能为空则降级）\n hsUp: breadth?.up || null,\n hsDown: breadth?.down || null,\n hsFlat: breadth?.flat || null,\n breadthSource: breadth?.source || null,\n };\n globalThis._cachedData = { indices, etfs, market };\n globalThis._cacheTime = Date.now();\n globalThis._cacheError = null;\n } catch (e) {\n globalThis._cacheError = e.message;\n console.error(\"数据获取失败:\", e.message);\n }\n }\n const data = globalThis._cachedData || { indices: [], etfs: [], market: {} };\n return Response.json({\n success: true, timestamp: beijingTime(),\n indices: data.indices, etfs: data.etfs, market: data.market,\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n}\n","deleted",false,"label",[14],"4413457f-3b8d-4303-8e1e-de4426fea38b",["D",1787622199218],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","ETF行情自动监控：获取行情数据、计算MACD、写入飞书多维表格","imageUrl","userId","e466a24e-860d-46c8-8516-ebc08a35b30f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03692-bb2d-7479-ba40-7240e1b1f15b","tursoName","4413457f3b8d43038e1ede4426fea38b","tursoHostname","4413457f3b8d43038e1ede4426fea38b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789528852539],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_104":99},"org",{"_9":10,"_98":99,"_100":99,"_55":56,"_101":102,"_103":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",52,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_138":139,"_140":141,"_142":143,"_144":42,"_145":42,"_146":42,"_147":32,"_148":-5,"_149":-7,"_150":-7,"_151":62,"_152":42,"_153":42,"_154":-5,"_155":42,"_156":42,"_157":42,"_158":-5},"ENV",{"_109":110,"_111":112,"_113":89,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]