[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_162":163,"_164":165},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_87":70,"_88":81,"_68":-7,"_89":-5,"_13":90,"_91":92,"_11":93,"_94":95,"_96":97,"_98":-5,"_99":-5,"_100":-5,"_101":26,"_102":103,"_104":38,"_105":-5,"_106":-5,"_107":108},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":36,"_37":38,"_39":-5,"_40":-5,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":-5,"_52":53,"_54":53,"_55":56,"_57":56,"_58":56,"_59":53,"_60":53,"_61":62,"_63":64,"_65":66,"_67":26},"query","handle","CGH2026","id","4413457f-3b8d-4303-8e1e-de4426fea38b","name","etf-monitor","createdAt",["D",1787622199218],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","ETF行情自动监控：获取行情数据、计算MACD、写入飞书多维表格","imageUrl","userId","e466a24e-860d-46c8-8516-ebc08a35b30f","pinnedFileId","756e25e6-a031-11f1-9e70-1607ee4eb77e","pinPreview",true,"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",{"_16":17,"_86":81},"org",{"_16":17,"_80":81,"_82":81,"_33":34,"_83":84,"_85":26},"branch",{"_68":69,"_20":70,"_18":71,"_72":19,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":-5,"_78":21,"_79":17},"isOwned","version",52,"main","b636b57c-1589-4055-8218-6fbf99de3708","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_18":19,"_20":21,"_22":157,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":36,"_37":38,"_39":-5,"_40":-5,"_41":42,"_43":44,"_45":46,"_47":48,"_49":158,"_51":-5,"_52":53,"_54":53,"_55":56,"_57":56,"_58":56,"_59":53,"_60":53,"_61":159,"_63":160,"_65":161,"_67":26},"tree",[148,149],[148,149],"counts",{"_136":42,"_137":138,"_139":42,"_140":141,"_142":143},"contents",[109,110],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":128,"_20":129,"_113":130,"_114":-5,"_115":71,"_116":69,"_118":38,"_22":131,"_68":132,"_121":133,"_123":134,"_125":26,"_126":-5,"_88":135},{"_18":111,"_20":112,"_113":36,"_114":-5,"_115":71,"_116":117,"_118":38,"_22":119,"_68":120,"_121":122,"_123":124,"_125":26,"_126":-5,"_88":127},"22c5b953-382b-433f-bec7-34e7b26303f1","new-file-899.ts","fileId","parentId","branchId","branchVersion",51,"latest",["D",1788616695021],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","label",[112],"be1ac5d4-72bf-4220-b013-9ab5db1357f4","main.ts","594a9562-a026-11f1-acc2-1607ee4eb77e",["D",1788616763470],29,"interval","import { sqlite } from \"https://esm.town/v/std/sqlite/global.ts\";\n// ============================================================\n// ETF定时分析 CRON v2.5 - 完全脱离飞书（ETF列表存SQLite云端）\n// 功能：动态ETF列表(SQLite etf_config表) + 4时段分析(9:25盘前/12:55午盘/14:30尾盘/15:00收盘)\n// + MACD(10,20,7) + 分时/盘中资金流/支撑压力位\n// + 深度分析 + 分析结果写入val-town SQLite存档(应用集中展示)\n// + 盘前9:25未开盘时改为\"盘前预判\"(基于昨收K线+消息面，修复数据错误)\n// 部署文件：main.ts (val-town CRON, 每15分钟)\n// 更新日期：2026-09-05 v2.5 去飞书化\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\nconst SECTOR_KEYWORDS = {\n \"科技\": [\"芯片\", \"半导体\", \"人工智能\", \"AI\", \"算力\", \"机器人\", \"卫星\", \"通信\", \"电子\", \"5G\", \"数据中心\", \"软件\", \"半导体设备\", \"功率\"],\n \"新能源\": [\"电池\", \"储能\", \"锂电\", \"光伏\", \"新能源\", \"固态电池\", \"充电桩\"],\n \"周期\": [\"黄金\", \"有色\", \"稀土\", \"稀有金属\", \"大宗商品\", \"铜\", \"金价\", \"贵金属\"],\n \"医药\": [\"创新药\", \"医药\", \"生物医药\", \"CRO\", \"医疗\", \"药\"],\n \"金融\": [\"银行\", \"券商\", \"保险\", \"金融\"],\n \"宽基\": [\"沪深300\", \"上证50\", \"中证\", \"大盘\", \"A股\"],\n \"其他\": [\"电力\", \"公用事业\", \"能源\"],\n \"消费\": [\"消费\", \"白酒\", \"食品\", \"家电\"],\n \"港股\": [\"港股\", \"恒生\", \"中概\"],\n \"海外\": [\"美股\", \"纳斯达克\", \"标普\", \"海外\"],\n};\n\n// ============ P0-1: A股交易日历（法定节假日判断） ============\n// 2026年交易所休市安排（沪深北交易所公告，2025-12-22发布）\n// 节假日闭市日（含周末连休）；2026年无调休补班工作日\nconst HOLIDAYS_2026 = [\n \"2026-01-01\",\"2026-01-02\",\"2026-01-03\",\"2026-01-04\", // 元旦 1/1-1/3休市，1/4周日\n \"2026-02-14\",\"2026-02-15\",\"2026-02-16\",\"2026-02-17\",\"2026-02-18\",\"2026-02-19\",\"2026-02-20\",\"2026-02-21\",\"2026-02-22\",\"2026-02-23\",\"2026-02-28\", // 春节 2/14-2/23，2/28周六\n \"2026-04-04\",\"2026-04-05\",\"2026-04-06\", // 清明\n \"2026-05-01\",\"2026-05-02\",\"2026-05-03\",\"2026-05-04\",\"2026-05-05\",\"2026-05-09\", // 劳动节，5/9周六\n \"2026-06-19\",\"2026-06-20\",\"2026-06-21\", // 端午\n \"2026-09-25\",\"2026-09-26\",\"2026-09-27\", // 中秋\n \"2026-09-20\", // 国庆前周末休市\n \"2026-10-01\",\"2026-10-02\",\"2026-10-03\",\"2026-10-04\",\"2026-10-05\",\"2026-10-06\",\"2026-10-07\",\"2026-10-10\", // 国庆 10/1-10/7，10/10周六\n];\n\n// 判断今天是否为A股交易日（北京时间）\nfunction isTradingDay(bjDateStr) {\n // 先查节假日表\n if (HOLIDAYS_2026.includes(bjDateStr)) return false;\n // 再判周末（用UTC构造，避免本地时区干扰，任何环境都准确）\n const parts = bjDateStr.split(\"-\").map(Number);\n const day = new Date(Date.UTC(parts[0], parts[1] - 1, parts[2])).getUTCDay();\n if (day === 0 || day === 6) return false;\n return true;\n}\n\n// 判断当前时间属于哪个分析时段（北京时间，±10分钟）\nfunction getAnalysisType() {\n const now = new Date();\n const bjHour = (now.getUTCHours() + 8) % 24;\n const bjMinute = now.getUTCMinutes();\n const bjTime = bjHour * 60 + bjMinute;\n const day = now.getUTCDay();\n if (day === 0 || day === 6) return { type: \"skip\", reason: \"周末不执行\" };\n // P0-1: 法定节假日判断（A股交易日历）\n const bjDateStr = new Date(Date.now() + 8 * 3600 * 1000).toISOString().substring(0, 10);\n if (!isTradingDay(bjDateStr)) return { type: \"skip\", reason: \"法定节假日休市 \" + bjDateStr };\n const windows = [\n { target: 9 * 60 + 25, type: \"盘前分析\", label: \"盘前\" },\n { target: 12 * 60 + 55, type: \"午盘分析\", label: \"午盘\" },\n { target: 14 * 60 + 30, type: \"尾盘分析\", label: \"尾盘\" },\n { target: 15 * 60, type: \"收盘分析\", label: \"收盘\" },\n ];\n for (const w of windows) {\n if (Math.abs(bjTime - w.target) <= 10) {\n return { type: w.type, label: w.label, bjTime: bjTime };\n }\n }\n return { type: \"skip\", reason: \"非指定时段\", bjTime: bjTime };\n}\n\nfunction etfPrefix(code) {\n return code.startsWith(\"15\") ? \"sz\" : \"sh\";\n}\n\n// ============ v2.5: ETF配置表（云端SQLite，脱离飞书） ============\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 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// ============ P0-2: 分析失败告警（SQLite记录） ============\n// 告警写入 SQLite alert_log 表（应用端可读）\nasync function initAlertTable() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS alert_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n date TEXT NOT NULL,\n period TEXT,\n level TEXT DEFAULT 'error',\n title TEXT,\n content TEXT,\n created_at INTEGER NOT NULL\n )`);\n return true;\n } catch (e) {\n console.error(\"[告警] alert_log表初始化失败:\", e.message);\n return false;\n }\n}\n\nasync function writeAlert(dateStr, period, level, title, content) {\n try {\n await initAlertTable();\n await sqlite.execute(\n \"INSERT INTO alert_log (date, period, level, title, content, created_at) VALUES (?,?,?,?,?,?)\",\n [dateStr, period || \"\", level || \"error\", title, content, Date.now()]\n );\n console.log(\"[告警] 已记录:\", title);\n return true;\n } catch (e) {\n console.error(\"[告警] 记录异常:\", e.message);\n return false;\n }\n}\n\n// 腾讯行情（含外盘/内盘）\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 };\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 => ({ date: k[0], close: parseFloat(k[2]) || 0, high: parseFloat(k[3]) || 0, low: parseFloat(k[4]) || 0, volume: parseFloat(k[5]) || 0 }));\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 points = [];\n for (const line of dataArr) {\n const p = line.split(\" \");\n if (p.length < 4) continue;\n points.push({ p: parseFloat(p[1]) || 0, v: parseFloat(p[2]) || 0, a: parseFloat(p[3]) || 0 });\n }\n if (points.length === 0) return null;\n let cumV = 0, cumA = 0;\n for (const pt of points) { cumV += pt.v; cumA += pt.a; }\n const avgPrice = cumV > 0 ? cumA / (cumV * 100) : points[points.length - 1].p;\n return {\n avgPrice: Number(avgPrice.toFixed(4)),\n latest: points[points.length - 1].p,\n pointCount: points.length,\n };\n } catch (e) {\n return null;\n }\n}\n\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++) { ema = values[i] * k + ema * (1 - k); result.push(ema); }\n return result;\n}\n\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] };\n}\n\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\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 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 bollLower = ma20 ? ma20 - 2 * std : 0;\n const bollUpper = ma20 ? ma20 + 2 * std : 0;\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 { support: Number(support.toFixed(4)), resistance: Number(resistance.toFixed(4)) };\n}\n\n// ============ P1: ATR(14) 平均真实波幅（风险指标） ============\nfunction calcATR(klines, period = 14) {\n if (!klines || klines.length < period + 1) return null;\n const trs = [];\n for (let i = 1; i < klines.length; i++) {\n const h = klines[i].high, l = klines[i].low, pc = klines[i - 1].close;\n const tr = Math.max(h - l, Math.abs(h - pc), Math.abs(l - pc));\n trs.push(tr);\n }\n // Wilder平滑\n let atr = trs.slice(0, period).reduce((a, b) => a + b, 0) / period;\n for (let i = period; i < trs.length; i++) {\n atr = (atr * (period - 1) + trs[i]) / period;\n }\n return { atr: Number(atr.toFixed(4)), atrPct: atr && klines[klines.length - 1].close ? Number((atr / klines[klines.length - 1].close * 100).toFixed(2)) : 0 };\n}\n\n// ============ P1: 隔夜外围联动（美股+富时A50） ============\n// 新浪国际指数接口，返回隔夜美股/外围走势\nasync function getOvernightOverseas() {\n try {\n // 美股指数 + 富时A50期指 + 恒生指数（腾讯国际行情）\n const url = \"https://qt.gtimg.cn/q=usDJI,usIXIC,usINX,hkHSI\";\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 result = [];\n const map = {\n usDJI: { name: \"道琼斯\", key: \"dow\" },\n usIXIC: { name: \"纳斯达克\", key: \"nasdaq\" },\n usINX: { name: \"标普500\", key: \"spx\" },\n hkHSI: { name: \"恒生指数\", key: \"hsi\" },\n };\n for (const line of text.split(\";\")) {\n const m = line.match(/v_([a-zA-Z0-9]+)=\"([^\"]+)\"/);\n if (!m) continue;\n const meta = map[m[1]];\n if (!meta) continue;\n const f = m[2].split(\"~\");\n result.push({\n key: meta.key, name: meta.name,\n price: parseFloat(f[3]) || 0,\n change: parseFloat(f[32]) || 0,\n });\n }\n return result;\n } catch (e) {\n console.error(\"获取外围数据失败:\", e.message);\n return [];\n }\n}\n\n// 生成外围联动分析文本\nfunction analyzeOverseas(overseas, label) {\n if (!overseas || overseas.length === 0) return \"\";\n const parts = [];\n for (const o of overseas) {\n if (!o.price) continue;\n const dir = o.change >= 0 ? \"上涨\" : \"下跌\";\n parts.push(o.name + \"隔夜\" + dir + (o.change >= 0 ? \"+\" : \"\") + o.change.toFixed(2) + \"%\");\n }\n if (parts.length === 0) return \"\";\n // 综合判断外围环境对A股的联动影响\n const avgChg = overseas.filter(o => o.price).reduce((a, b) => a + (b.change || 0), 0) / overseas.filter(o => o.price).length || 0;\n let env;\n if (avgChg > 0.8) env = \"外围整体强势，对A股偏暖\";\n else if (avgChg > 0.2) env = \"外围温和偏强，对A股略偏暖\";\n else if (avgChg > -0.2) env = \"外围震荡，对A股影响中性\";\n else if (avgChg > -0.8) env = \"外围偏弱，对A股略偏空\";\n else env = \"外围明显走弱，对A股偏空压制\";\n return \"【外围联动】\" + parts.join(\"，\") + \"；\" + env + \"（\" + label + \"研判参考）\";\n}\n\n// 资金流（新浪，T-1）\nasync function getFundFlow(code) {\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=2&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 || \"\"), mainNet: Math.round(Number(latest.r0_net) || 0),\n mainRatio: Number(latest.r0_ratio) || 0,\n };\n } catch (e) { return null; }\n}\n\n// 消息面（新浪要闻）\nasync function getNews() {\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 return (d.result?.data || []).map(n => String(n.title || \"\"));\n } catch (e) { return []; }\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;\n const k = e.kdjK, d = e.kdjD;\n const volRatio = e.volRatio;\n\n let maTxt;\n if (price >= ma5 && ma5 >= ma10 && ma10 >= ma20) maTxt = \"均线多头排列，趋势向上\";\n else if (price <= ma5 && ma5 <= ma10 && ma10 <= ma20) maTxt = \"均线空头排列，趋势向下\";\n else if (price > ma5 && price > ma10) maTxt = \"站上5/10日线，短期偏强\";\n else if (price < ma5 && price < ma10) maTxt = \"跌破5/10日线，短期偏弱\";\n else maTxt = \"均线交织，方向不明\";\n parts.push(\"【均线】MA5=\" + ma5.toFixed(3) + \" MA10=\" + ma10.toFixed(3) + \" MA20=\" + ma20.toFixed(3) + \"，\" + maTxt);\n\n let macdTxt;\n if (dif > dea && dif > 0) macdTxt = \"MACD多头（零轴上方）\";\n else if (dif > dea) macdTxt = \"MACD低位金叉\";\n else if (dif < dea && dif > 0) macdTxt = \"MACD高位死叉\";\n else macdTxt = \"MACD空头（零轴下方）\";\n parts.push(\"【MACD】DIF=\" + dif.toFixed(4) + \" DEA=\" + dea.toFixed(4) + \" 柱=\" + macd.toFixed(4) + \"，\" + macdTxt);\n\n let kdjTxt;\n if (k > 80) kdjTxt = \"KDJ超买\";\n else if (k < 20) kdjTxt = \"KDJ超卖\";\n else if (k > d) kdjTxt = \"KDJ金叉\";\n else kdjTxt = \"KDJ死叉\";\n parts.push(\"【KDJ】K=\" + k.toFixed(1) + \" D=\" + d.toFixed(1) + \"，\" + kdjTxt);\n\n let volTxt;\n if (volRatio > 1.5) volTxt = \"放量\";\n else if (volRatio > 1.2) volTxt = \"温和放量\";\n else if (volRatio < 0.7) volTxt = \"明显缩量\";\n else if (volRatio < 0.9) volTxt = \"缩量\";\n else volTxt = \"量能平稳\";\n parts.push(\"【量能】量比\" + volRatio.toFixed(2) + \"，\" + volTxt);\n\n // P1: ATR 波动风险分析\n if (e.atr && e.atr.atr > 0) {\n let atrTxt;\n if (e.atr.atrPct >= 3) atrTxt = \"波动剧烈，风险偏高，注意控制仓位\";\n else if (e.atr.atrPct >= 1.8) atrTxt = \"波动较大，短线注意止损保护\";\n else if (e.atr.atrPct >= 0.9) atrTxt = \"波动适中，风险可控\";\n else atrTxt = \"波动较小，走势相对平稳\";\n parts.push(\"【波动】ATR=\" + e.atr.atr + \"（日振幅均值\" + e.atr.atrPct + \"%），\" + atrTxt);\n }\n\n // P1: 隔夜外围联动\n if (e.overseas && e.overseas.length > 0) {\n const ovTxt = analyzeOverseas(e.overseas, \"盘前/盘中\");\n if (ovTxt) parts.push(ovTxt);\n }\n\n // 盘中资金流向（外盘-内盘）\n if (e.activeFlow && e.activeFlow.netHand) {\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 // 分时状态\n if (e.minute) {\n const vsAvg = price >= e.minute.avgPrice ? \"运行于分时均价上方（多头）\" : \"运行于分时均价下方（空头）\";\n parts.push(\"【分时】\" + vsAvg + \"，分时均价=\" + e.minute.avgPrice.toFixed(3));\n }\n\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 + \"（T-1，\" + ff.date + \"）\");\n }\n if (e.news && e.news.length > 0) {\n parts.push(\"【消息】\" + e.news.slice(0, 2).join(\"；\"));\n }\n\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 (k >= d) score += 3; else score -= 3;\n // --- 实时因子（低权重，仅微调，防剧烈跳变） ---\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 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 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 if (e.minute) {\n if (price >= e.minute.avgPrice) score += 1; else score -= 1;\n }\n if (e.fundFlow) { if (e.fundFlow.mainNet > 0) score += 2; if (e.fundFlow.mainNet < -1e8) score -= 2; }\n score = Math.max(5, Math.min(95, score));\n\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 let action;\n if (score >= 70) action = \"加仓/持有\";\n else if (score >= 60) action = \"持有偏加\";\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\n return { score, trend, action, analysis: parts.join(\"。\") + \"。综合评分\" + score + \"分，走势【\" + trend + \"】，\" + action + \"。关键支撑\" + support + \"，压力\" + resist + \"。\" };\n}\n\n// 写入日报表（飞书）已移除 v2.5：完全脱离飞书，数据只存SQLite\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 => ({ code: i.code, name: i.name, ...(map[i.code] || { price: 0, change: 0, amount: 0 }) }));\n } catch (e) {\n return INDEX_LIST.map(i => ({ code: i.code, name: i.name, price: 0, change: 0, amount: 0 }));\n }\n}\n\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 => ({ code: e.code, name: e.name, sector: e.sector, ...(map[e.code] || { price: 0, change: 0, volume: 0, amount: 0 }) }));\n } catch (e) {\n return etfList.map(e => ({ code: e.code, name: e.name, sector: e.sector, price: 0, change: 0, volume: 0, amount: 0 }));\n }\n}\n\n// ============ SQLite 存档（应用集中展示入口） ============\nasync function initSqlite() {\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 // P2: 同时初始化告警表（若有旧版本未建）\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS alert_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n date TEXT NOT NULL,\n period TEXT,\n level TEXT DEFAULT 'error',\n title TEXT,\n content TEXT,\n created_at INTEGER NOT NULL\n )`);\n } catch (e) {}\n return true;\n } catch (e) {\n console.error(\"SQLite初始化失败:\", e.message);\n return false;\n }\n}\n\n// ============ P2: 旧记录清理机制 ============\n// 保留最近 retentionDays 天的分析记录，防止SQLite无限增长（免费版10MB上限）\n// 保留天数可通过环境变量 CLEAN_RETENTION_DAYS 配置，默认60天\nasync function cleanOldRecords() {\n try {\n const retentionDays = parseInt(Deno.env.get(\"CLEAN_RETENTION_DAYS\") || \"60\", 10);\n if (isNaN(retentionDays) || retentionDays < 7) {\n console.log(\"[清理] 保留天数配置无效，使用默认60天\");\n }\n const keep = isNaN(retentionDays) || retentionDays < 7 ? 60 : retentionDays;\n await initSqlite();\n // 基于北京时间的日期字符串比较（date 存的是 YYYY-MM-DD）\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n const cutoff = new Date(bjNow.getTime() - keep * 24 * 3600 * 1000);\n const cutoffStr = cutoff.toISOString().substring(0, 10);\n // 删除 cutoff 之前的记录\n const del = await sqlite.execute(\n \"DELETE FROM analysis_history WHERE date < ?\",\n [cutoffStr]\n );\n // 同时清理告警表（保留30天告警）\n const cutoffAlert = new Date(bjNow.getTime() - 30 * 24 * 3600 * 1000);\n const cutoffAlertStr = cutoffAlert.toISOString().substring(0, 10);\n let delAlert = 0;\n try {\n const da = await sqlite.execute(\"DELETE FROM alert_log WHERE date < ?\", [cutoffAlertStr]);\n delAlert = da.rowsAffected || 0;\n } catch (e) {}\n // 删除深度分析用量记录（保留30天，供费用统计）\n let delDeep = 0;\n try {\n const dd = await sqlite.execute(\"DELETE FROM deep_analysis_usage WHERE date < ?\", [cutoffAlertStr]);\n delDeep = dd.rowsAffected || 0;\n } catch (e) {}\n const delCount = del.rowsAffected || 0;\n if (delCount > 0 || delAlert > 0 || delDeep > 0) {\n console.log(`[清理] 已删除分析记录${delCount}条、告警${delAlert}条、深度分析用量${delDeep}条（保留${keep}天）`);\n } else {\n console.log(`[清理] 无需清理，保留${keep}天内的记录`);\n }\n return { deleted: delCount, alertDeleted: delAlert, deepDeleted: delDeep, keep };\n } catch (e) {\n console.error(\"[清理] 异常:\", e.message);\n return { error: e.message };\n }\n}\n\n// 保存一次分析到SQLite（每条ETF一行，或整批JSON）\nasync function saveAnalysisToSqlite(dateStr, label, records) {\n try {\n await initSqlite();\n // 汇总摘要\n const upCount = records.filter(r => r.change > 0).length;\n const downCount = records.filter(r => r.change < 0).length;\n const avgScore = records.length ? Math.round(records.reduce((a, r) => a + r.score, 0) / records.length) : 0;\n const summary = JSON.stringify({\n label, count: records.length, upCount, downCount, avgScore,\n best: records.slice().sort((a, b) => b.score - a.score)[0]?.name || \"\",\n worst: records.slice().sort((a, b) => a.score - b.score)[0]?.name || \"\",\n });\n // 每条ETF一行，便于应用按日期+时段查询\n for (const r of records) {\n const etfJson = JSON.stringify({\n code: r.code, name: r.name, sector: r.sector,\n price: r.price, change: r.change, volume: r.volume, amount: r.amount,\n dif: r.dif, dea: r.dea, macd: r.macd,\n ma5: r.ma5, ma10: r.ma10, ma20: r.ma20,\n kdjK: r.kdjK, kdjD: r.kdjD, kdjJ: r.kdjJ,\n volRatio: r.volRatio, score: r.score, trend: r.trend, action: r.action,\n analysis: r.analysis,\n support: r.sr ? r.sr.support : null, resistance: r.sr ? r.sr.resistance : null,\n });\n await sqlite.execute(\n \"INSERT INTO analysis_history (date, period, label, created_at, summary, records) VALUES (?, ?, ?, ?, ?, ?)\",\n [dateStr, r.code, label, Date.now(), summary, etfJson]\n );\n }\n console.log(\"SQLite存档成功:\", dateStr, label, records.length, \"条\");\n return records.length;\n } catch (e) {\n console.error(\"SQLite存档失败:\", e.message);\n return 0;\n }\n}\n\n// SQLite 自检（验证global组织级库可读写）\nasync function sqliteSelfTest() {\n try {\n await initSqlite();\n // 清理测试记录\n try { await sqlite.execute(\"DELETE FROM analysis_history WHERE label IN ('selftest','crosstest')\"); } catch (e) {}\n const r = await sqlite.execute(\"SELECT COUNT(*) as c FROM analysis_history\");\n console.log(\"SQLite连接正常，存档记录数:\", r.rows?.[0]?.c ?? \"?\");\n return true;\n } catch (e) {\n console.error(\"SQLite自检失败:\", e.message);\n return false;\n }\n}\n\n// 主逻辑\nexport default async function handler() {\n const startTime = Date.now();\n console.log(\"=== ETF行情自动监控v2.2开始 ===\", new Date().toLocaleString(\"zh-CN\"));\n\n const at = getAnalysisType();\n console.log(\"时段判断:\", at.type, at.reason || \"\", \"北京时间\", at.bjTime);\n\n // 每次运行都做一次 SQLite 自检（验证global库连接）\n try { await sqliteSelfTest(); } catch (e) { console.error(\"自检异常:\", e.message); }\n\n // P2: 旧记录清理（幂等，保留最近N天，默认60天可配）\n try { await cleanOldRecords(); } catch (e) { console.error(\"记录清理异常:\", e.message); }\n\n const etfList = await getEtfListFromSqlite();\n console.log(\"监控ETF数量:\", etfList.length);\n if (etfList.length === 0) {\n // P0-2: ETF列表为空 → 告警\n const bjD = new Date(Date.now() + 8 * 3600 * 1000).toISOString().substring(0, 10);\n await writeAlert(bjD, at.label || \"全天\", \"error\", \"ETF列表读取为空\", \"云端ETF配置表读取失败或全部ETF被停用，请通过应用/接口管理ETF配置\");\n }\n\n // 获取指数（v2.5：不再写飞书，仅用于日志）\n try {\n await getIndexRealTime();\n } catch (e) {\n console.error(\"指数获取失败:\", e.message);\n }\n\n // 非指定时段：跳过ETF分析\n if (at.type === \"skip\") {\n console.log(\"非分析时段，跳过ETF处理\");\n console.log(\"=== 结束(耗时\" + (Date.now() - startTime) + \"ms) ===\");\n return;\n }\n\n // 指定时段：完整分析+写入（含SQLite存档）\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n const dateStr = bjNow.toISOString().substring(0, 10);\n let analysisFailed = false;\n try {\n const quotes = await getEtfRealTime(etfList);\n const newsList = await getNews();\n // P1: 隔夜外围数据（每次分析取一次，供各ETF联动研判）\n let overseas = [];\n try { overseas = await getOvernightOverseas(); } catch (e) { console.error(\"外围数据获取失败:\", e.message); }\n const records = [];\n for (const q of quotes) {\n try {\n const [klines, minuteData] = await Promise.all([getKLine(q.code, 60), getMinuteData(q.code)]);\n if (klines.length < 25) continue;\n const closes = klines.map(k => k.close);\n const vols = klines.map(k => k.volume);\n const ma5 = calcMA(closes, 5), ma10 = calcMA(closes, 10), ma20 = calcMA(closes, 20);\n const macd = calcMACD(closes);\n const kdj = calcKDJ(klines);\n const atr = calcATR(klines); // P1: ATR波动风险指标\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 activeFlow = { netHand: (q.outer || 0) - (q.inner || 0) };\n const sr = calcSupportResistance(klines, ma20, ma5);\n let fundFlow = null;\n try { fundFlow = await getFundFlow(q.code); } catch (e) {}\n const keywords = SECTOR_KEYWORDS[q.sector] || [];\n const sectorNews = keywords.length > 0 ? newsList.filter(t => keywords.some(kw => t.includes(kw))) : [];\n const base = {\n ...q, ma5, ma10, ma20,\n dif: macd.dif, dea: macd.dea, macd: macd.macd,\n kdjK: kdj.k, kdjD: kdj.d, kdjJ: kdj.j,\n atr, volRatio, fundFlow, news: sectorNews,\n activeFlow, sr, minute: minuteData, overseas,\n };\n const analysis = generateAnalysis(base);\n records.push({ ...base, ...analysis });\n console.log(q.code, q.name, \"价格\" + q.price, \"涨跌\" + q.change + \"%\", \"评分\" + analysis.score, \"趋势\" + analysis.trend);\n } catch (e) {\n console.error(q.code, \"处理失败:\", e.message);\n analysisFailed = true;\n }\n await new Promise(r => setTimeout(r, 200));\n }\n\n if (records.length > 0) {\n // v2.5: 不再写飞书日报表，数据只存SQLite（应用集中展示）\n // 写SQLite存档\n try {\n const saved = await saveAnalysisToSqlite(dateStr, at.label, records);\n if (saved === 0) {\n analysisFailed = true;\n await writeAlert(dateStr, at.label, \"warning\", \"SQLite存档异常\", at.label + \"时段SQLite存档写入0条，应用端可能无法显示该时段分析\");\n }\n } catch (e) {\n console.error(\"SQLite存档异常:\", e.message);\n analysisFailed = true;\n await writeAlert(dateStr, at.label, \"error\", \"SQLite存档失败\", at.label + \"时段存档写入异常: \" + e.message);\n }\n } else {\n // P0-2: 所有ETF都失败 → 告警\n analysisFailed = true;\n await writeAlert(dateStr, at.label, \"error\", \"分析无有效结果\", at.label + \"时段所有ETF分析均失败或K线数据不足(不足25根)，请检查数据源\");\n }\n } catch (e) {\n console.error(\"分析处理失败:\", e.message);\n analysisFailed = true;\n await writeAlert(dateStr, at.label, \"error\", \"分析流程异常\", at.label + \"时段分析整体失败: \" + e.message);\n }\n\n console.log(\"=== 结束(耗时\" + (Date.now() - startTime) + \"ms)\" + (analysisFailed ? \" [有告警]\" : \"\") + \" ===\");\n}\n",[129],"pulls","branches",1,"forks","envVars",{"_144":146,"_147":42},"connections",{"_144":42,"_145":42},"count","unfilledCount",6,"emptyCount",{"_18":128,"_20":129,"_113":130,"_114":-5,"_115":71,"_116":69,"_118":38,"_22":154,"_68":132,"_121":133,"_123":134,"_125":26,"_126":-5,"_151":155,"_88":156},{"_18":111,"_20":112,"_113":36,"_114":-5,"_115":71,"_116":117,"_118":38,"_22":150,"_68":120,"_121":122,"_123":124,"_125":26,"_126":-5,"_151":152,"_88":153},["D",1788616695021],"children",[],[112],["D",1788616763470],[],[129],["D",1787622199218],["D",1789528852539],{"_16":17,"_86":81},{"_16":17,"_80":81,"_82":81,"_33":34,"_83":84,"_85":26},{"_68":69,"_20":70,"_18":71,"_72":19,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":-5,"_78":21,"_79":17},"ctx",{"_61":-5,"_106":195,"_196":197,"_198":199,"_200":26,"_201":26,"_202":26,"_203":38,"_204":-5,"_205":-7,"_206":-7,"_207":42,"_208":26,"_209":26,"_210":-5,"_211":26,"_212":26,"_213":26,"_214":-5},"ENV",{"_166":167,"_168":169,"_170":70,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Search