[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_172":173,"_174":175},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_107":89,"_27":101,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":58,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_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":25},"version",46,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","new-file-899.ts","latestPath","fileId","756e25e6-a031-11f1-9e70-1607ee4eb77e","name","fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/global.ts\";\n\n\n\n// ============================================================\n\n// ETF行情数据API v2.3 - 含深度分析LLM接口(次数可控)\n\n// 功能：动态ETF列表(飞书基础信息库) + 实时行情 + 日K技术指标\n\n// + 分时线(腾讯) + 盘中资金流(外盘-内盘) + 全市场涨跌家数(东财)\n\n// + 支撑压力位(实时计算) + 消息面(新浪) + 多因子AI分析\n\n// 部署文件：new-file-899.ts (val-town HTTP端点)\n\n// 更新日期：2026-08-27 v2.3\n\n// ============================================================\n\n\n\n// 飞书ETF基础信息库 table_id（增删ETF在此表操作）\n\nconst ETF_INFO_TABLE_ID = \"tbl5K6lJm9aAjKdo\";\n\n\n\n// 大盘指数列表\n\nconst INDEX_LIST = [\n\n { code: \"000001\", name: \"上证指数\", pre: \"sh\" },\n\n { code: \"399001\", name: \"深证成指\", pre: \"sz\" },\n\n { code: \"399006\", name: \"创业板指\", pre: \"sz\" },\n\n { code: \"000688\", name: \"科创50\", pre: \"sh\" },\n\n];\n\n\n\n// 板块关键词（用于消息面筛选）\n\nconst SECTOR_KEYWORDS = {\n\n \"科技\": [\"芯片\", \"半导体\", \"人工智能\", \"AI\", \"算力\", \"机器人\", \"卫星\", \"通信\", \"电子\", \"5G\", \"数据中心\", \"软件\", \"半导体设备\", \"功率\"],\n\n \"新能源\": [\"电池\", \"储能\", \"锂电\", \"光伏\", \"新能源\", \"固态电池\", \"充电桩\"],\n\n \"周期\": [\"黄金\", \"有色\", \"稀土\", \"稀有金属\", \"大宗商品\", \"铜\", \"金价\", \"贵金属\"],\n\n \"医药\": [\"创新药\", \"医药\", \"生物医药\", \"CRO\", \"医疗\", \"药\"],\n\n \"金融\": [\"银行\", \"券商\", \"保险\", \"金融\"],\n\n \"宽基\": [\"沪深300\", \"上证50\", \"中证\", \"大盘\", \"A股\"],\n\n \"其他\": [\"电力\", \"公用事业\", \"能源\"],\n\n \"消费\": [\"消费\", \"白酒\", \"食品\", \"家电\"],\n\n \"港股\": [\"港股\", \"恒生\", \"中概\"],\n\n \"海外\": [\"美股\", \"纳斯达克\", \"标普\", \"海外\"],\n\n};\n\n\n\n// 获取飞书token\n\nasync function getFeishuToken() {\n\n const res = await fetch(\"https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal\", {\n\n method: \"POST\",\n\n headers: { \"Content-Type\": \"application/json\" },\n\n body: JSON.stringify({ app_id: Deno.env.get(\"FEISHU_APP_ID\"), app_secret: Deno.env.get(\"FEISHU_APP_SECRET\") }),\n\n });\n\n const d = await res.json();\n\n if (!d.tenant_access_token) throw new Error(\"飞书token获取失败: \" + JSON.stringify(d));\n\n return d.tenant_access_token;\n\n}\n\n\n\n// 从飞书ETF基础信息库读取启用状态的ETF列表\n\nasync function getEtfListFromFeishu() {\n\n try {\n\n const token = await getFeishuToken();\n\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n\n const url = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt + \"/tables/\" + ETF_INFO_TABLE_ID + \"/records?page_size=100\";\n\n const res = await fetch(url, { headers: { \"Authorization\": \"Bearer \" + token } });\n\n const d = await res.json();\n\n if (d.code !== 0) throw new Error(\"读取ETF信息库失败: \" + d.msg);\n\n const items = d.data.items || [];\n\n const list = [];\n\n for (const r of items) {\n\n const f = r.fields;\n\n const enabled = Array.isArray(f[\"启用\"]) ? (f[\"启用\"][0]?.text || \"\") : String(f[\"启用\"] || \"是\");\n\n if (enabled === \"否\") continue; // 跳过停用\n\n const code = String(f[\"ETF代码\"] || \"\");\n\n if (!code) continue;\n\n const name = String(f[\"ETF名称\"] || code);\n\n const sector = Array.isArray(f[\"所属板块\"]) ? (f[\"所属板块\"][0]?.text || \"其他\") : (String(f[\"所属板块\"] || \"其他\"));\n\n list.push({ code, name, sector });\n\n }\n\n return list;\n\n } catch (e) {\n\n console.error(\"读取飞书ETF列表失败:\", e.message);\n\n return [];\n\n }\n\n}\n\n\n\nfunction etfPrefix(code) {\n\n return code.startsWith(\"15\") ? \"sz\" : \"sh\";\n\n}\n\n\n\n// 腾讯行情（GBK解码，批量）\n\nasync function fetchTencent(symbols) {\n\n const url = \"https://qt.gtimg.cn/q=\" + symbols;\n\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\" } });\n\n const buf = await res.arrayBuffer();\n\n let text;\n\n try { text = new TextDecoder(\"gbk\").decode(buf); } catch (e) { text = new TextDecoder(\"utf-8\").decode(buf); }\n\n const map = {};\n\n for (const line of text.split(\";\")) {\n\n const m = line.match(/v_(?:sh|sz)(\\d+)=\"([^\"]+)\"/);\n\n if (!m) continue;\n\n const f = m[2].split(\"~\");\n\n map[m[1]] = {\n\n name: f[1] || \"\", price: parseFloat(f[3]) || 0, change: parseFloat(f[32]) || 0,\n\n open: parseFloat(f[5]) || 0, high: parseFloat(f[33]) || 0, low: parseFloat(f[34]) || 0,\n\n volume: (parseFloat(f[36]) || 0) / 10000, amount: (parseFloat(f[37]) || 0) / 10000,\n\n outer: parseFloat(f[7]) || 0, inner: parseFloat(f[8]) || 0, // 外盘/内盘(手)\n\n turnover: parseFloat(f[38]) || 0, // 量比\n\n };\n\n }\n\n return map;\n\n}\n\n\n\n// 获取日K线\n\nasync function getKLine(code, n) {\n\n const prefix = etfPrefix(code);\n\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=\" + prefix + code + \",day,,,\" + n + \",qfq\";\n\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n\n const d = await res.json();\n\n const obj = d.data?.[prefix + code];\n\n const day = obj?.day || obj?.qfqday || [];\n\n return day.map(k => ({\n\n date: k[0], open: parseFloat(k[1]) || 0, close: parseFloat(k[2]) || 0,\n\n high: parseFloat(k[3]) || 0, low: parseFloat(k[4]) || 0, volume: parseFloat(k[5]) || 0,\n\n }));\n\n}\n\n\n\n// 获取分时数据（腾讯）\n\nasync function getMinuteData(code) {\n\n try {\n\n const prefix = etfPrefix(code);\n\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=\" + prefix + code;\n\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n\n const d = await res.json();\n\n const obj = d.data?.[prefix + code];\n\n const dataArr = obj?.data?.data || [];\n\n const date = obj?.data?.date || \"\";\n\n const points = [];\n\n for (const line of dataArr) {\n\n const p = line.split(\" \");\n\n if (p.length < 4) continue;\n\n points.push({\n\n t: p[0], p: parseFloat(p[1]) || 0, v: parseFloat(p[2]) || 0, a: parseFloat(p[3]) || 0,\n\n });\n\n }\n\n if (points.length === 0) return null;\n\n // 分时统计\n\n const latest = points[points.length - 1];\n\n let high = -Infinity, low = Infinity, cumV = 0, cumA = 0;\n\n for (const pt of points) {\n\n if (pt.p > high) high = pt.p;\n\n if (pt.p < low) low = pt.p;\n\n cumV += pt.v; cumA += pt.a;\n\n }\n\n const avgPrice = cumV > 0 ? cumA / (cumV * 100) : latest.p; // 均价 = 金额/股数\n\n return {\n\n date, latest: latest.p, avgPrice: Number(avgPrice.toFixed(4)),\n\n high: Number(high.toFixed(4)), low: Number(low.toFixed(4)),\n\n points, // 完整分时点（时间/价/量/额）\n\n };\n\n } catch (e) {\n\n console.error(\"分时获取失败 \" + code + \":\", e.message);\n\n return null;\n\n }\n\n}\n\n\n\n// EMA\n\nfunction calcEMA(values, period) {\n\n if (values.length === 0) return [];\n\n const k = 2 / (period + 1);\n\n let ema = values[0];\n\n const result = [ema];\n\n for (let i = 1; i < values.length; i++) {\n\n ema = values[i] * k + ema * (1 - k);\n\n result.push(ema);\n\n }\n\n return result;\n\n}\n\n\n\n// MACD(10,20,7)\n\nfunction calcMACD(closes) {\n\n const ema10 = calcEMA(closes, 10);\n\n const ema20 = calcEMA(closes, 20);\n\n const dif = closes.map((_, i) => ema10[i] - ema20[i]);\n\n const dea = calcEMA(dif, 7);\n\n const macd = dif.map((d, i) => 2 * (d - dea[i]));\n\n const n = closes.length - 1;\n\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\n\n\n// MA均线\n\nfunction calcMA(closes, period) {\n\n if (closes.length < period) return null;\n\n return closes.slice(-period).reduce((a, b) => a + b, 0) / period;\n\n}\n\n\n\n// KDJ(9,3,3)\n\nfunction calcKDJ(klines) {\n\n const n = 9;\n\n let k = 50, d = 50, lastK = 50, lastD = 50;\n\n for (let i = 0; i < klines.length; i++) {\n\n const start = Math.max(0, i - n + 1);\n\n let highest = -Infinity, lowest = Infinity;\n\n for (let j = start; j <= i; j++) {\n\n highest = Math.max(highest, klines[j].high);\n\n lowest = Math.min(lowest, klines[j].low);\n\n }\n\n const rsv = highest === lowest ? 50 : ((klines[i].close - lowest) / (highest - lowest)) * 100;\n\n k = (2 / 3) * k + (1 / 3) * rsv;\n\n d = (2 / 3) * d + (1 / 3) * k;\n\n lastK = k; lastD = d;\n\n }\n\n return { k: lastK, d: lastD, j: 3 * lastK - 2 * lastD };\n\n}\n\n\n\n// 支撑压力位 + 布林带（实时计算，替代硬编码）\n\nfunction calcSupportResistance(klines, ma20, ma5) {\n\n const recent = klines.slice(-20);\n\n let hi20 = -Infinity, lo20 = Infinity;\n\n for (const k of recent) {\n\n if (k.high > hi20) hi20 = k.high;\n\n if (k.low < lo20) lo20 = k.low;\n\n }\n\n // 布林带（20日，2倍标准差）\n\n let std = 0;\n\n if (klines.length >= 20) {\n\n const closes = klines.slice(-20).map(k => k.close);\n\n const mean = closes.reduce((a, b) => a + b, 0) / 20;\n\n std = Math.sqrt(closes.reduce((a, b) => a + (b - mean) * (b - mean), 0) / 20);\n\n }\n\n const bollMid = ma20 || 0;\n\n const bollUpper = ma20 ? ma20 + 2 * std : 0;\n\n const bollLower = ma20 ? ma20 - 2 * std : 0;\n\n // 短期支撑/压力：MA20/布林下轨取较近者\n\n const support = ma20 && bollLower ? Math.min(ma20, bollLower) : (ma20 || bollLower || lo20);\n\n const resistance = ma5 && bollUpper ? Math.max(ma5, bollUpper) : (ma5 || bollUpper || hi20);\n\n return {\n\n support: Number(support.toFixed(4)),\n\n resistance: Number(resistance.toFixed(4)),\n\n hi20: Number(hi20.toFixed(4)),\n\n lo20: Number(lo20.toFixed(4)),\n\n bollUpper: Number(bollUpper.toFixed(4)),\n\n bollLower: Number(bollLower.toFixed(4)),\n\n bollMid: Number(bollMid.toFixed(4)),\n\n };\n\n}\n\n\n\n// 获取资金流（新浪，最近N日 - T-1数据）\n\nasync function getFundFlow(code, days) {\n\n try {\n\n const prefix = etfPrefix(code);\n\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\n const res = await fetch(url, { headers: { \"Referer\": \"https://finance.sina.com.cn/\", \"User-Agent\": \"Mozilla/5.0\" } });\n\n const text = await res.text();\n\n const clean = text.replace(/^[^(]*\$/, \"\").replace(/\$\\s*;?\\s*$/, \"\");\n\n let data;\n\n try { data = JSON.parse(clean); } catch (e) { data = JSON.parse(text); }\n\n if (!Array.isArray(data) || data.length === 0) return null;\n\n const latest = data[0];\n\n return {\n\n date: String(latest.opendate || \"\"),\n\n netAmount: Math.round(Number(latest.netamount) || 0),\n\n ratio: Number(latest.ratioamount) || 0,\n\n mainNet: Math.round(Number(latest.r0_net) || 0),\n\n mainRatio: Number(latest.r0_ratio) || 0,\n\n };\n\n } catch (e) {\n\n console.error(\"资金流获取失败 \" + code + \":\", e.message);\n\n return null;\n\n }\n\n}\n\n\n\n// 全市场涨跌家数（东财）\n\nasync function getMarketBreadth() {\n\n try {\n\n const url = \"https://push2.eastmoney.com/api/qt/ulist.np/get?fltt=2&secids=1.000001,0.399001&fields=f104,f105,f106\";\n\n const res = await fetch(url, { headers: { \"Referer\": \"https://quote.eastmoney.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n\n const d = await res.json();\n\n const diff = d.data?.diff || [];\n\n if (diff.length < 2) return null;\n\n const sh = diff[0], sz = diff[1];\n\n return {\n\n up: (sh.f104 || 0) + (sz.f104 || 0),\n\n down: (sh.f105 || 0) + (sz.f105 || 0),\n\n flat: (sh.f106 || 0) + (sz.f106 || 0),\n\n source: \"eastmoney\",\n\n };\n\n } catch (e) {\n\n console.error(\"涨跌家数获取失败:\", e.message);\n\n return null;\n\n }\n\n}\n\n\n\n// 获取消息面（新浪财经要闻，按板块关键词筛选）\n\nlet _newsCache = { time: 0, data: [] };\n\nasync function getNews() {\n\n const now = Date.now();\n\n if (_newsCache.data.length > 0 && now - _newsCache.time < 10 * 60 * 1000) return _newsCache.data;\n\n try {\n\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\n const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n\n const d = await res.json();\n\n const items = d.result?.data || [];\n\n const news = items.map(n => ({ title: String(n.title || \"\"), time: String(n.ctime || \"\") }));\n\n _newsCache = { time: now, data: news };\n\n return news;\n\n } catch (e) {\n\n console.error(\"消息面获取失败:\", e.message);\n\n return _newsCache.data;\n\n }\n\n}\n\n\n\n// 多因子技术分析引擎（升级版：含分时、盘中资金流、支撑压力）\n\nfunction generateAnalysis(e) {\n\n const parts = [];\n\n const price = e.price, ma5 = e.ma5, ma10 = e.ma10, ma20 = e.ma20;\n\n const dif = e.dif, dea = e.dea, macd = e.macd, macdPrev = e.macdPrev;\n\n const k = e.kdjK, d = e.kdjD, j = e.kdjJ;\n\n const volRatio = e.volRatio;\n\n\n\n // 1. 均线\n\n let maTxt;\n\n if (price >= ma5 && ma5 >= ma10 && ma10 >= ma20) maTxt = \"均线多头排列（价>MA5>MA10>MA20），趋势向上\";\n\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\n else maTxt = \"均线交织缠绕，方向不明\";\n\n parts.push(\"【均线】MA5=\" + ma5.toFixed(3) + \" MA10=\" + ma10.toFixed(3) + \" MA20=\" + ma20.toFixed(3) + \"，\" + maTxt);\n\n\n\n // 2. MACD\n\n let macdTxt;\n\n if (dif > dea && dif > 0) macdTxt = \"MACD多头（DIF>DEA且零轴上方）\";\n\n else if (dif > dea && dif < 0) macdTxt = \"MACD低位金叉（零轴下方DIF上穿DEA）\";\n\n else if (dif < dea && dif > 0) macdTxt = \"MACD高位死叉（零轴上方DIF下穿DEA）\";\n\n else macdTxt = \"MACD空头（DIF= macdPrev) macdTxt += \"，柱体/动能放大\";\n\n else macdTxt += \"，柱体/动能收窄\";\n\n parts.push(\"【MACD】DIF=\" + dif.toFixed(4) + \" DEA=\" + dea.toFixed(4) + \" 柱=\" + macd.toFixed(4) + \"，\" + macdTxt);\n\n\n\n // 3. KDJ\n\n let kdjTxt;\n\n if (k > 80 || j > 100) kdjTxt = \"KDJ超买区（K=\" + k.toFixed(0) + \"）\";\n\n else if (k < 20 || j < 0) kdjTxt = \"KDJ超卖区（K=\" + k.toFixed(0) + \"）\";\n\n else if (k > d) kdjTxt = \"KDJ金叉向上（K>D）\";\n\n else kdjTxt = \"KDJ死叉向下（K 1.5) volTxt = \"放量（量比\" + volRatio.toFixed(1) + \"）\";\n\n else if (volRatio > 1.2) volTxt = \"温和放量（量比\" + volRatio.toFixed(1) + \"）\";\n\n else if (volRatio < 0.7) volTxt = \"明显缩量（量比\" + volRatio.toFixed(1) + \"）\";\n\n else if (volRatio < 0.9) volTxt = \"缩量（量比\" + volRatio.toFixed(1) + \"）\";\n\n else volTxt = \"量能平稳（量比\" + volRatio.toFixed(1) + \"）\";\n\n parts.push(\"【量能】今日量/5日均量=\" + volRatio.toFixed(2) + \"，\" + volTxt);\n\n\n\n // 5. 盘中资金流向（外盘-内盘，实时）\n\n if (e.activeFlow) {\n\n const netHand = e.activeFlow.netHand;\n\n const flowTxt = netHand >= 0\n\n ? \"主动买盘占优（外盘-内盘+\" + (netHand / 10000).toFixed(2) + \"万手）\"\n\n : \"主动卖盘占优（外盘-内盘-\" + (Math.abs(netHand) / 10000).toFixed(2) + \"万手）\";\n\n parts.push(\"【盘中资金】\" + flowTxt + \"，为实时主动买卖力量\");\n\n }\n\n\n\n // 6. 资金流（T-1，如有）\n\n if (e.fundFlow) {\n\n const ff = e.fundFlow;\n\n const mainTxt = ff.mainNet >= 0 ? \"主力净流入\" + (ff.mainNet / 100000000).toFixed(2) + \"亿\" : \"主力净流出\" + (Math.abs(ff.mainNet) / 100000000).toFixed(2) + \"亿\";\n\n parts.push(\"【昨日主力】\" + mainTxt + \"，净流入率\" + (ff.mainRatio * 100).toFixed(1) + \"%（T-1，\" + ff.date + \"）\");\n\n }\n\n\n\n // 7. 分时状态（如有）\n\n if (e.minute) {\n\n const mv = e.minute;\n\n const vsAvg = price >= mv.avgPrice ? \"运行于分时均价上方（多头）\" : \"运行于分时均价下方（空头）\";\n\n const half = Math.floor(mv.points.length / 2);\n\n const secondHalf = mv.points.slice(half);\n\n let later = 0;\n\n for (const pt of secondHalf) later += pt.v;\n\n const firstHalf = mv.points.slice(0, half);\n\n let early = 0;\n\n for (const pt of firstHalf) early += pt.v;\n\n const flowDir = later > early ? \"午后/尾盘量能放大\" : \"午后/尾盘量能萎缩\";\n\n parts.push(\"【分时】\" + vsAvg + \"，分时均价=\" + mv.avgPrice.toFixed(3) + \"，\" + flowDir);\n\n }\n\n\n\n // 8. 消息面（如有相关）\n\n if (e.news && e.news.length > 0) {\n\n const newsTxt = e.news.slice(0, 2).map(n => n.title).join(\"；\");\n\n parts.push(\"【消息】\" + newsTxt);\n\n }\n\n\n\n // 9. 综合评分\n\n let score = 50;\n\n if (price >= ma5) score += 5; else score -= 5;\n\n if (price >= ma10) score += 4; else score -= 4;\n\n if (price >= ma20) score += 4; else score -= 4;\n\n if (ma5 >= ma10) score += 3; else score -= 3;\n\n if (ma10 >= ma20) score += 3; else score -= 3;\n\n if (dif >= dea) score += 6; else score -= 6;\n\n if (dif >= 0) score += 4; else score -= 4;\n\n if (macd >= macdPrev) score += 3; else score -= 3;\n\n if (k >= d) score += 3; else score -= 3;\n\n if (e.change > 0) score += Math.min(5, e.change * 2); else score -= Math.min(5, Math.abs(e.change) * 2);\n\n if (e.change > 0 && volRatio >= 1.1) score += 3;\n\n if (e.change < 0 && volRatio >= 1.3) score -= 4;\n\n if (e.change < 0 && volRatio <= 0.8) score += 2;\n\n // 盘中资金流（外盘-内盘）\n\n if (e.activeFlow) {\n\n if (e.activeFlow.netHand > 0) score += 3;\n\n if (e.activeFlow.netHand < 0 && Math.abs(e.activeFlow.netHand) > 50000) score -= 3;\n\n }\n\n // T-1主力资金\n\n if (e.fundFlow) {\n\n if (e.fundFlow.mainNet > 0) score += 3;\n\n if (e.fundFlow.mainNet < -1e8) score -= 3;\n\n }\n\n // 分时强弱\n\n if (e.minute) {\n\n if (price >= e.minute.avgPrice) score += 2; else score -= 2;\n\n }\n\n score = Math.max(5, Math.min(95, score));\n\n\n\n // 10. 走势判断\n\n let trend;\n\n if (score >= 70) trend = \"偏多\";\n\n else if (score >= 60) trend = \"震荡偏多\";\n\n else if (score >= 45) trend = \"震荡\";\n\n else if (score >= 35) trend = \"震荡偏空\";\n\n else trend = \"偏空\";\n\n\n\n // 11. 操作建议（含支撑压力位）\n\n let action;\n\n if (score >= 70) action = \"加仓/持有：趋势向上，回踩MA5/支撑位可加仓，跌破MA10减仓\";\n\n else if (score >= 60) action = \"持有偏加：多头占优，逢低分批加仓，止损位MA20/布林下轨\";\n\n else if (score >= 50) action = \"持有观望：多空均衡，等待方向选择，轻仓参与\";\n\n else if (score >= 40) action = \"减仓/观望：偏弱格局，反弹至压力位减仓，不宜重仓\";\n\n else action = \"回避：弱势明显，等待企稳信号，勿盲目抄底\";\n\n\n\n const support = e.sr ? e.sr.support.toFixed(3) : (ma20 ? ma20.toFixed(3) : \"-\");\n\n const resist = e.sr ? e.sr.resistance.toFixed(3) : (ma5 ? ma5.toFixed(3) : \"-\");\n\n const summary = \"综合评分\" + score.toFixed(0) + \"分，短期走势【\" + trend + \"】。关键支撑位\" + support + \"，压力位\" + resist + \"。\" + action;\n\n\n\n return { score, trend, action, analysis: parts.join(\"。\") + \"。\" + summary };\n\n}\n\n\n\n// 计算ETF全指标+分析\n\nasync function calcEtfIndicators(quote, newsList) {\n\n const [klines, minuteData] = await Promise.all([getKLine(quote.code, 60), getMinuteData(quote.code)]);\n\n if (klines.length < 25) {\n\n return { code: quote.code, name: quote.name, sector: quote.sector, ...quote, minute: minuteData, klineError: \"K线不足\", score: 50, trend: \"震荡\", action: \"数据不足\", analysis: \"K线数据不足，无法计算完整技术指标\" };\n\n }\n\n const closes = klines.map(k => k.close);\n\n const vols = klines.map(k => k.volume);\n\n const ma5 = calcMA(closes, 5);\n\n const ma10 = calcMA(closes, 10);\n\n const ma20 = calcMA(closes, 20);\n\n const macd = calcMACD(closes);\n\n const kdj = calcKDJ(klines);\n\n const vol5 = vols.slice(-6, -1).reduce((a, b) => a + b, 0) / 5;\n\n const volRatio = vol5 > 0 ? vols[vols.length - 1] / vol5 : 0;\n\n const last = klines[klines.length - 1];\n\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\n // 盘中资金流向（外盘-内盘，实时）\n\n const activeFlow = {\n\n netHand: (quote.outer || 0) - (quote.inner || 0),\n\n outer: quote.outer || 0,\n\n inner: quote.inner || 0,\n\n };\n\n\n\n // 支撑压力位（实时计算）\n\n const sr = calcSupportResistance(klines, ma20, ma5);\n\n\n\n // 资金流（T-1，异步）\n\n let fundFlow = null;\n\n try { fundFlow = await getFundFlow(quote.code, 3); } catch (e) { fundFlow = null; }\n\n\n\n // 消息面筛选（按板块）\n\n const keywords = SECTOR_KEYWORDS[quote.sector] || [];\n\n const sectorNews = keywords.length > 0\n\n ? newsList.filter(n => keywords.some(kw => n.title.includes(kw)))\n\n : [];\n\n\n\n const base = {\n\n code: quote.code, name: quote.name, sector: quote.sector,\n\n price: quote.price, change: quote.change, open: quote.open, high: quote.high, low: quote.low,\n\n volume: quote.volume, amount: quote.amount,\n\n ma5, ma10, ma20,\n\n dif: macd.dif, dea: macd.dea, macd: macd.macd,\n\n difPrev: macd.difPrev, deaPrev: macd.deaPrev, macdPrev: macd.macdPrev,\n\n kdjK: kdj.k, kdjD: kdj.d, kdjJ: kdj.j,\n\n volRatio, kline, fundFlow, news: sectorNews,\n\n activeFlow, sr, minute: minuteData,\n\n };\n\n return { ...base, ...generateAnalysis(base) };\n\n}\n\n\n\n// 大盘指数实时\n\nasync function getIndexRealTime() {\n\n try {\n\n const symbols = INDEX_LIST.map(i => i.pre + i.code).join(\",\");\n\n const map = await fetchTencent(symbols);\n\n return INDEX_LIST.map(i => ({\n\n code: i.code, name: i.name,\n\n ...(map[i.code] || { price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }),\n\n }));\n\n } catch (e) {\n\n console.error(\"指数获取失败:\", e.message);\n\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}\n\n\n\n// ETF实时行情\n\nasync function getEtfRealTime(etfList) {\n\n try {\n\n const symbols = etfList.map(e => etfPrefix(e.code) + e.code).join(\",\");\n\n const map = await fetchTencent(symbols);\n\n return etfList.map(e => ({\n\n code: e.code, name: e.name, sector: e.sector,\n\n ...(map[e.code] || { price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }),\n\n }));\n\n } catch (e) {\n\n console.error(\"ETF获取失败:\", e.message);\n\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\n}\n\n\n\nfunction beijingTime() {\n\n const d = new Date(Date.now() + 8 * 3600 * 1000);\n\n return d.toISOString().replace(\"T\", \" \").substring(0, 19);\n\n}\n\n\n\n// ============ 深度分析（火山方舟LLM，手动触发，次数可控） ============\n\n// 常量：每日免费深度分析次数上限\n\nconst DEEP_ANALYSIS_DAILY_LIMIT = 10;\n\n// 火山方舟模型\n\nconst ARK_MODEL = \"doubao-seed-2-0-pro-260215\";\n\nconst ARK_BASE_URL = \"https://ark.cn-beijing.volces.com/api/v3/chat/completions\";\n\n\n\n// 记录深度分析调用（返回今日已用次数）\n\nasync function recordDeepAnalysisUsage() {\n\n try {\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS deep_analysis_usage (\n\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n date TEXT NOT NULL,\n\n code TEXT,\n\n name TEXT,\n\n created_at INTEGER NOT NULL,\n\n prompt_tokens INTEGER DEFAULT 0,\n\n completion_tokens INTEGER DEFAULT 0,\n\n status TEXT DEFAULT 'ok'\n\n )`);\n\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n\n const dateStr = bjNow.toISOString().substring(0, 10);\n\n return dateStr;\n\n } catch (e) {\n\n console.error(\"深度分析用量表初始化失败:\", e.message);\n\n return null;\n\n }\n\n}\n\n\n\n// 查询某日已用深度分析次数\n\nasync function getDeepAnalysisUsedCount(dateStr) {\n\n try {\n\n const r = await sqlite.execute(\n\n \"SELECT COUNT(*) as c FROM deep_analysis_usage WHERE date = ?\",\n\n [dateStr]\n\n );\n\n return r.rows?.[0]?.c ?? 0;\n\n } catch (e) {\n\n console.error(\"查询深度分析次数失败:\", e.message);\n\n return 0;\n\n }\n\n}\n\n\n\n// 写一条深度分析用量记录\n\nasync function logDeepAnalysisUsage(dateStr, code, name, promptTokens, completionTokens, status) {\n\n try {\n\n await sqlite.execute(\n\n \"INSERT INTO deep_analysis_usage (date, code, name, created_at, prompt_tokens, completion_tokens, status) VALUES (?,?,?,?,?,?,?)\",\n\n [dateStr, code, name, Date.now(), promptTokens || 0, completionTokens || 0, status || 'ok']\n\n );\n\n } catch (e) {\n\n console.error(\"写深度分析用量失败:\", e.message);\n\n }\n\n}\n\n\n\n// 调用火山方舟LLM做深度分析\n\nasync function callArkDeepAnalysis(etf, quote) {\n\n const apiKey = Deno.env.get(\"ARK_API_KEY\");\n\n if (!apiKey) {\n\n return { error: \"未配置ARK_API_KEY，请先在val-town环境变量中添加\" };\n\n }\n\n // 构建分析prompt：把该ETF的技术面+资金面+消息面数据打包\n\n const prompt = `你是一位专业ETF短线投资者，请对以下ETF进行深度分析，输出结构化的投资分析报告。\n\n\n\n## 标的\n\n名称：${etf.name}（代码${etf.code}，板块：${etf.sector}）\n\n\n\n## 实时行情\n\n- 现价：${quote.price}\n\n- 当日涨跌幅：${quote.change}%\n\n- 成交量：${quote.volume}万手\n\n- 成交额：${quote.amount}亿元\n\n\n\n## 技术指标（基于日K）\n\n- MA5=${etf.ma5?.toFixed(3)} MA10=${etf.ma10?.toFixed(3)} MA20=${etf.ma20?.toFixed(3)}\n\n- MACD: DIF=${etf.dif?.toFixed(4)} DEA=${etf.dea?.toFixed(4)} 柱=${etf.macd?.toFixed(4)}\n\n- KDJ: K=${etf.kdjK?.toFixed(1)} D=${etf.kdjD?.toFixed(1)} J=${etf.kdjJ?.toFixed(1)}\n\n- 量比：${etf.volRatio?.toFixed(2)}\n\n- 支撑位：${etf.support} 压力位：${etf.resistance}\n\n\n\n## 资金面\n\n${etf.fundFlow ? `- 昨日主力净流入：${(etf.fundFlow.mainNet/100000000).toFixed(2)}亿（${etf.fundFlow.date}）` : \"- 昨日主力资金：暂无数据\"}\n\n${etf.activeFlow ? `- 盘中主动买卖：外盘-内盘=${(etf.activeFlow.netHand/10000).toFixed(2)}万手` : \"\"}\n\n\n\n## 相关消息\n\n${etf.news && etf.news.length ? etf.news.slice(0,3).map(n=>n.title).join(\"\\n\") : \"暂无相关消息\"}\n\n\n\n## 要求\n\n请从以下维度给出深度分析（不要复述数据，要有独立判断）：\n\n1. **技术面研判**：均线系统状态、MACD动能、KDJ位置、量价配合，给出技术形态判断\n\n2. **资金面研判**：主力资金流向含义、盘中买卖力量\n\n3. **消息面研判**：结合当前板块政策/行业动态，判断消息的利好利空方向及影响程度\n\n4. **综合判断**：给出明确的操作观点（偏多/震荡偏多/震荡/震荡偏空/偏空），以及1-3天走势预判\n\n5. **风险提示**：指出关键风险点、止损位\n\n\n\n请用中文回答，控制在400字以内，条理清晰，观点明确。`;\n\n\n\n try {\n\n const res = await fetch(ARK_BASE_URL, {\n\n method: \"POST\",\n\n headers: {\n\n \"Content-Type\": \"application/json\",\n\n \"Authorization\": \"Bearer \" + apiKey,\n\n },\n\n body: JSON.stringify({\n\n model: ARK_MODEL,\n\n messages: [\n\n { role: \"system\", content: \"你是一位资深的ETF短线交易分析师，擅长技术分析、资金流分析和板块轮动研判。\" },\n\n { role: \"user\", content: prompt },\n\n ],\n\n temperature: 0.3,\n\n max_tokens: 1200,\n\n }),\n\n });\n\n const d = await res.json();\n\n if (d.error) {\n\n return { error: \"LLM调用失败: \" + (d.error.message || JSON.stringify(d.error)) };\n\n }\n\n const content = d.choices?.[0]?.message?.content || \"\";\n\n const usage = d.usage || {};\n\n return {\n\n content,\n\n promptTokens: usage.prompt_tokens || 0,\n\n completionTokens: usage.completion_tokens || 0,\n\n model: ARK_MODEL,\n\n };\n\n } catch (e) {\n\n console.error(\"LLM调用异常:\", e.message);\n\n return { error: \"LLM调用异常: \" + e.message };\n\n }\n\n}\n\n\n\n// ============ 历史存档读取（SQLite global组织级库，跨val共享） ============\n\nasync function getHistory() {\n\n try {\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS analysis_history (\n\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n date TEXT NOT NULL,\n\n period TEXT NOT NULL,\n\n label TEXT,\n\n created_at INTEGER NOT NULL,\n\n summary TEXT,\n\n records TEXT\n\n )`);\n\n // 最近30天所有时段的分析记录\n\n const r = await sqlite.execute(\n\n `SELECT * FROM analysis_history WHERE created_at > ? ORDER BY created_at DESC LIMIT 2000`,\n\n [Date.now() - 30 * 24 * 3600 * 1000]\n\n );\n\n const rows = r.rows || [];\n\n // 解析每条ETF记录\n\n const history = [];\n\n for (const row of rows) {\n\n try {\n\n const etf = JSON.parse(row.records);\n\n history.push({\n\n date: row.date, period: row.period, label: row.label, created_at: row.created_at,\n\n code: etf.code, name: etf.name, sector: etf.sector,\n\n price: etf.price, change: etf.change, volume: etf.volume, amount: etf.amount,\n\n dif: etf.dif, dea: etf.dea, macd: etf.macd,\n\n ma5: etf.ma5, ma10: etf.ma10, ma20: etf.ma20,\n\n kdjK: etf.kdjK, kdjD: etf.kdjD, kdjJ: etf.kdjJ,\n\n volRatio: etf.volRatio, score: etf.score, trend: etf.trend, action: etf.action,\n\n analysis: etf.analysis, support: etf.support, resistance: etf.resistance,\n\n });\n\n } catch (e) {}\n\n }\n\n // 按日期+时段聚合摘要\n\n const groups = {};\n\n for (const row of rows) {\n\n const key = row.date;\n\n if (!groups[key]) groups[key] = [];\n\n if (!groups[key].find(g => g.label === row.label)) {\n\n let summary = {};\n\n try { summary = JSON.parse(row.summary || \"{}\"); } catch (e) {}\n\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\n }\n\n return { history, groups, total: history.length, latestDate: rows[0]?.date || null };\n\n } catch (e) {\n\n console.error(\"读取历史失败:\", e.message);\n\n return { history: [], groups: {}, total: 0, error: e.message };\n\n }\n\n}\n\n\n\nexport default async function (req) {\n\n const url = new URL(req.url);\n\n const path = url.pathname;\n\n if (path === \"/history\" || url.searchParams.get(\"history\") === \"1\") {\n\n const h = await getHistory();\n\n return Response.json({ success: true, timestamp: beijingTime(), ...h }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\n // ===== 深度分析（LLM，次数可控） =====\n\n if (path === \"/deep-analysis/quota\" || url.searchParams.get(\"quota\") === \"1\") {\n\n const dateStr = await recordDeepAnalysisUsage();\n\n const used = dateStr ? await getDeepAnalysisUsedCount(dateStr) : 0;\n\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 }\n\n if (path === \"/deep-analysis\" && (req.method === \"GET\" || req.method === \"POST\")) {\n\n const code = url.searchParams.get(\"code\");\n\n if (!code) {\n\n return Response.json({ success: false, message: \"缺少code参数，请指定ETF代码如 /deep-analysis?code=159562\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\n // 检查今日配额\n\n const dateStr = await recordDeepAnalysisUsage();\n\n if (!dateStr) {\n\n return Response.json({ success: false, message: \"深度分析配额系统初始化失败\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\n const used = await getDeepAnalysisUsedCount(dateStr);\n\n if (used >= DEEP_ANALYSIS_DAILY_LIMIT) {\n\n return Response.json({ success: false, message: \"今日深度分析次数已用完（\" + DEEP_ANALYSIS_DAILY_LIMIT + \"次），请明日再试\", used, limit: DEEP_ANALYSIS_DAILY_LIMIT }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\n // 从缓存或实时获取该ETF数据\n\n let etf = null;\n\n let quote = null;\n\n try {\n\n const etfList = await getEtfListFromFeishu();\n\n const etfMeta = etfList.find(e => e.code === code);\n\n if (!etfMeta) {\n\n return Response.json({ success: false, message: \"ETF代码\" + code + \"不在监控列表（请先在飞书基础信息库添加）\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\n const quotes = await getEtfRealTime([etfMeta]);\n\n const q = quotes[0] || {};\n\n const newsList = await getNews();\n\n const analyzed = await calcEtfIndicators({ ...etfMeta, ...q }, newsList);\n\n if (analyzed.klineError) {\n\n return Response.json({ success: false, message: \"该ETF数据不足: \" + analyzed.klineError }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\n etf = analyzed;\n\n quote = q;\n\n } catch (e) {\n\n return Response.json({ success: false, message: \"获取ETF数据失败: \" + e.message }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\n // 调用LLM深度分析\n\n const result = await callArkDeepAnalysis(etf, quote);\n\n // 记录用量（无论成败都计数，防止刷接口）\n\n const promptTokens = result.promptTokens || 0;\n\n const completionTokens = result.completionTokens || 0;\n\n await logDeepAnalysisUsage(dateStr, code, etf.name, promptTokens, completionTokens, result.error ? 'error' : 'ok');\n\n if (result.error) {\n\n return Response.json({ success: false, message: result.error, code, name: etf.name }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\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 }\n\n const refresh = url.searchParams.get(\"refresh\");\n\n if (refresh === \"1\" || !globalThis._cachedData || Date.now() - globalThis._cacheTime > 30 * 1000) {\n\n try {\n\n // 动态读取ETF列表\n\n const etfList = await getEtfListFromFeishu();\n\n if (etfList.length === 0) {\n\n return Response.json({ success: false, timestamp: beijingTime(), message: \"飞书ETF基础信息库为空或读取失败\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n }\n\n // 获取指数、ETF行情、消息面、全市场涨跌家数\n\n const [indices, etfQuotes, newsList, breadth] = await Promise.all([getIndexRealTime(), getEtfRealTime(etfList), getNews(), getMarketBreadth()]);\n\n // 逐只计算指标+分析（K线与分时并行）\n\n const etfs = [];\n\n for (const q of etfQuotes) {\n\n etfs.push(await calcEtfIndicators(q, newsList));\n\n }\n\n // 大盘盘面统计\n\n const upCount = etfs.filter(e => e.change > 0).length;\n\n const downCount = etfs.filter(e => e.change < 0).length;\n\n const flatCount = etfs.filter(e => e.change === 0).length;\n\n const avgChange = etfs.reduce((a, e) => a + e.change, 0) / (etfs.length || 1);\n\n const market = {\n\n upCount, downCount, flatCount, avgChange: Number(avgChange.toFixed(2)),\n\n totalAmount: Number(((indices[0]?.amount || 0) + (indices[1]?.amount || 0)).toFixed(2)),\n\n etfCount: etfs.length,\n\n // 全市场涨跌家数（东财，可能为空则降级）\n\n hsUp: breadth?.up || null,\n\n hsDown: breadth?.down || null,\n\n hsFlat: breadth?.flat || null,\n\n breadthSource: breadth?.source || null,\n\n };\n\n globalThis._cachedData = { indices, etfs, market };\n\n globalThis._cacheTime = Date.now();\n\n globalThis._cacheError = null;\n\n } catch (e) {\n\n globalThis._cacheError = e.message;\n\n console.error(\"数据获取失败:\", e.message);\n\n }\n\n }\n\n const data = globalThis._cachedData || { indices: [], etfs: [], market: {} };\n\n return Response.json({\n\n success: true, timestamp: beijingTime(),\n\n indices: data.indices, etfs: data.etfs, market: data.market,\n\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n\n}","import { sqlite } from \"https://esm.town/v/std/sqlite/global.ts\";\n\n// ============================================================\n\n// ETF行情数据API v2.3 - 含深度分析LLM接口(次数可控)\n\n// 功能：动态ETF列表(飞书基础信息库) + 实时行情 + 日K技术指标\n\n// + 分时线(腾讯) + 盘中资金流(外盘-内盘) + 全市场涨跌家数(东财)\n\n// + 支撑压力位(实时计算) + 消息面(新浪) + 多因子AI分析\n\n// 部署文件：new-file-899.ts (val-town HTTP端点)\n\n// 更新日期：2026-08-27 v2.3\n\n// ============================================================\n\n// 飞书ETF基础信息库 table_id（增删ETF在此表操作）\n\nconst ETF_INFO_TABLE_ID = \"tbl5K6lJm9aAjKdo\";\n\n// 大盘指数列表\n\nconst INDEX_LIST = [\n { code: \"000001\", name: \"上证指数\", pre: \"sh\" },\n\n { code: \"399001\", name: \"深证成指\", pre: \"sz\" },\n\n { code: \"399006\", name: \"创业板指\", pre: \"sz\" },\n\n { code: \"000688\", name: \"科创50\", pre: \"sh\" },\n];\n\n// 板块关键词（用于消息面筛选）\n\nconst SECTOR_KEYWORDS = {\n \"科技\": [\n \"芯片\",\n \"半导体\",\n \"人工智能\",\n \"AI\",\n \"算力\",\n \"机器人\",\n \"卫星\",\n \"通信\",\n \"电子\",\n \"5G\",\n \"数据中心\",\n \"软件\",\n \"半导体设备\",\n \"功率\",\n ],\n\n \"新能源\": [\"电池\", \"储能\", \"锂电\", \"光伏\", \"新能源\", \"固态电池\", \"充电桩\"],\n\n \"周期\": [\n \"黄金\",\n \"有色\",\n \"稀土\",\n \"稀有金属\",\n \"大宗商品\",\n \"铜\",\n \"金价\",\n \"贵金属\",\n ],\n\n \"医药\": [\"创新药\", \"医药\", \"生物医药\", \"CRO\", \"医疗\", \"药\"],\n\n \"金融\": [\"银行\", \"券商\", \"保险\", \"金融\"],\n\n \"宽基\": [\"沪深300\", \"上证50\", \"中证\", \"大盘\", \"A股\"],\n\n \"其他\": [\"电力\", \"公用事业\", \"能源\"],\n\n \"消费\": [\"消费\", \"白酒\", \"食品\", \"家电\"],\n\n \"港股\": [\"港股\", \"恒生\", \"中概\"],\n\n \"海外\": [\"美股\", \"纳斯达克\", \"标普\", \"海外\"],\n};\n\n// 获取飞书token\n\nasync function getFeishuToken() {\n const res = await fetch(\n \"https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal\",\n {\n method: \"POST\",\n\n headers: { \"Content-Type\": \"application/json\" },\n\n body: JSON.stringify({\n app_id: Deno.env.get(\"FEISHU_APP_ID\"),\n app_secret: Deno.env.get(\"FEISHU_APP_SECRET\"),\n }),\n },\n );\n\n const d = await res.json();\n\n if (!d.tenant_access_token) {\n throw new Error(\"飞书token获取失败: \" + JSON.stringify(d));\n }\n\n return d.tenant_access_token;\n}\n\n// 从飞书ETF基础信息库读取启用状态的ETF列表\n\nasync function getEtfListFromFeishu() {\n try {\n const token = await getFeishuToken();\n\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n\n const url = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt +\n \"/tables/\" + ETF_INFO_TABLE_ID + \"/records?page_size=100\";\n\n const res = await fetch(url, {\n headers: { \"Authorization\": \"Bearer \" + token },\n });\n\n const d = await res.json();\n\n if (d.code !== 0) throw new Error(\"读取ETF信息库失败: \" + d.msg);\n\n const items = d.data.items || [];\n\n const list = [];\n\n for (const r of items) {\n const f = r.fields;\n\n const enabled = Array.isArray(f[\"启用\"])\n ? (f[\"启用\"][0]?.text || \"\")\n : String(f[\"启用\"] || \"是\");\n\n if (enabled === \"否\") continue; // 跳过停用\n\n const code = String(f[\"ETF代码\"] || \"\");\n\n if (!code) continue;\n\n const name = String(f[\"ETF名称\"] || code);\n\n const sector = Array.isArray(f[\"所属板块\"])\n ? (f[\"所属板块\"][0]?.text || \"其他\")\n : (String(f[\"所属板块\"] || \"其他\"));\n\n list.push({ code, name, sector });\n }\n\n return list;\n } catch (e) {\n console.error(\"读取飞书ETF列表失败:\", e.message);\n\n return [];\n }\n}\n\nfunction etfPrefix(code) {\n return code.startsWith(\"15\") ? \"sz\" : \"sh\";\n}\n\n// 腾讯行情（GBK解码，批量）\n\nasync function fetchTencent(symbols) {\n const url = \"https://qt.gtimg.cn/q=\" + symbols;\n\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\" },\n });\n\n const buf = await res.arrayBuffer();\n\n let text;\n\n try {\n text = new TextDecoder(\"gbk\").decode(buf);\n } catch (e) {\n text = new TextDecoder(\"utf-8\").decode(buf);\n }\n\n const map = {};\n\n for (const line of text.split(\";\")) {\n const m = line.match(/v_(?:sh|sz)(\\d+)=\"([^\"]+)\"/);\n\n if (!m) continue;\n\n const f = m[2].split(\"~\");\n\n map[m[1]] = {\n name: f[1] || \"\",\n price: parseFloat(f[3]) || 0,\n change: parseFloat(f[32]) || 0,\n\n open: parseFloat(f[5]) || 0,\n high: parseFloat(f[33]) || 0,\n low: parseFloat(f[34]) || 0,\n\n volume: (parseFloat(f[36]) || 0) / 10000,\n amount: (parseFloat(f[37]) || 0) / 10000,\n\n outer: parseFloat(f[7]) || 0,\n inner: parseFloat(f[8]) || 0, // 外盘/内盘(手)\n\n turnover: parseFloat(f[38]) || 0, // 量比\n };\n }\n\n return map;\n}\n\n// 获取日K线\n\nasync function getKLine(code, n) {\n const prefix = etfPrefix(code);\n\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=\" +\n prefix + code + \",day,,,\" + n + \",qfq\";\n\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" },\n });\n\n const d = await res.json();\n\n const obj = d.data?.[prefix + code];\n\n const day = obj?.day || obj?.qfqday || [];\n\n return day.map((k) => ({\n date: k[0],\n open: parseFloat(k[1]) || 0,\n close: parseFloat(k[2]) || 0,\n\n high: parseFloat(k[3]) || 0,\n low: parseFloat(k[4]) || 0,\n volume: parseFloat(k[5]) || 0,\n }));\n}\n\n// 获取分时数据（腾讯）\n\nasync function getMinuteData(code) {\n try {\n const prefix = etfPrefix(code);\n\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=\" +\n prefix + code;\n\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" },\n });\n\n const d = await res.json();\n\n const obj = d.data?.[prefix + code];\n\n const dataArr = obj?.data?.data || [];\n\n const date = obj?.data?.date || \"\";\n\n const points = [];\n\n for (const line of dataArr) {\n const p = line.split(\" \");\n\n if (p.length < 4) continue;\n\n points.push({\n t: p[0],\n p: parseFloat(p[1]) || 0,\n v: parseFloat(p[2]) || 0,\n a: parseFloat(p[3]) || 0,\n });\n }\n\n if (points.length === 0) return null;\n\n // 分时统计\n\n const latest = points[points.length - 1];\n\n let high = -Infinity, low = Infinity, cumV = 0, cumA = 0;\n\n for (const pt of points) {\n if (pt.p > high) high = pt.p;\n\n if (pt.p < low) low = pt.p;\n\n cumV += pt.v;\n cumA += pt.a;\n }\n\n const avgPrice = cumV > 0 ? cumA / (cumV * 100) : latest.p; // 均价 = 金额/股数\n\n return {\n date,\n latest: latest.p,\n avgPrice: Number(avgPrice.toFixed(4)),\n\n high: Number(high.toFixed(4)),\n low: Number(low.toFixed(4)),\n\n points, // 完整分时点（时间/价/量/额）\n };\n } catch (e) {\n console.error(\"分时获取失败 \" + code + \":\", e.message);\n\n return null;\n }\n}\n\n// EMA\n\nfunction calcEMA(values, period) {\n if (values.length === 0) return [];\n\n const k = 2 / (period + 1);\n\n let ema = values[0];\n\n const result = [ema];\n\n for (let i = 1; i < values.length; i++) {\n ema = values[i] * k + ema * (1 - k);\n\n result.push(ema);\n }\n\n return result;\n}\n\n// MACD(10,20,7)\n\nfunction calcMACD(closes) {\n const ema10 = calcEMA(closes, 10);\n\n const ema20 = calcEMA(closes, 20);\n\n const dif = closes.map((_, i) => ema10[i] - ema20[i]);\n\n const dea = calcEMA(dif, 7);\n\n const macd = dif.map((d, i) => 2 * (d - dea[i]));\n\n const n = closes.length - 1;\n\n return {\n dif: dif[n],\n dea: dea[n],\n macd: macd[n],\n difPrev: dif[n - 1],\n deaPrev: dea[n - 1],\n macdPrev: macd[n - 1],\n };\n}\n\n// MA均线\n\nfunction calcMA(closes, period) {\n if (closes.length < period) return null;\n\n return closes.slice(-period).reduce((a, b) => a + b, 0) / period;\n}\n\n// KDJ(9,3,3)\n\nfunction calcKDJ(klines) {\n const n = 9;\n\n let k = 50, d = 50, lastK = 50, lastD = 50;\n\n for (let i = 0; i < klines.length; i++) {\n const start = Math.max(0, i - n + 1);\n\n let highest = -Infinity, lowest = Infinity;\n\n for (let j = start; j <= i; j++) {\n highest = Math.max(highest, klines[j].high);\n\n lowest = Math.min(lowest, klines[j].low);\n }\n\n const rsv = highest === lowest\n ? 50\n : ((klines[i].close - lowest) / (highest - lowest)) * 100;\n\n k = (2 / 3) * k + (1 / 3) * rsv;\n\n d = (2 / 3) * d + (1 / 3) * k;\n\n lastK = k;\n lastD = d;\n }\n\n return { k: lastK, d: lastD, j: 3 * lastK - 2 * lastD };\n}\n\n// 支撑压力位 + 布林带（实时计算，替代硬编码）\n\nfunction calcSupportResistance(klines, ma20, ma5) {\n const recent = klines.slice(-20);\n\n let hi20 = -Infinity, lo20 = Infinity;\n\n for (const k of recent) {\n if (k.high > hi20) hi20 = k.high;\n\n if (k.low < lo20) lo20 = k.low;\n }\n\n // 布林带（20日，2倍标准差）\n\n let std = 0;\n\n if (klines.length >= 20) {\n const closes = klines.slice(-20).map((k) => k.close);\n\n const mean = closes.reduce((a, b) => a + b, 0) / 20;\n\n std = Math.sqrt(\n closes.reduce((a, b) => a + (b - mean) * (b - mean), 0) / 20,\n );\n }\n\n const bollMid = ma20 || 0;\n\n const bollUpper = ma20 ? ma20 + 2 * std : 0;\n\n const bollLower = ma20 ? ma20 - 2 * std : 0;\n\n // 短期支撑/压力：MA20/布林下轨取较近者\n\n const support = ma20 && bollLower\n ? Math.min(ma20, bollLower)\n : (ma20 || bollLower || lo20);\n\n const resistance = ma5 && bollUpper\n ? Math.max(ma5, bollUpper)\n : (ma5 || bollUpper || hi20);\n\n return {\n support: Number(support.toFixed(4)),\n\n resistance: Number(resistance.toFixed(4)),\n\n hi20: Number(hi20.toFixed(4)),\n\n lo20: Number(lo20.toFixed(4)),\n\n bollUpper: Number(bollUpper.toFixed(4)),\n\n bollLower: Number(bollLower.toFixed(4)),\n\n bollMid: Number(bollMid.toFixed(4)),\n };\n}\n\n// 获取资金流（新浪，最近N日 - T-1数据）\n\nasync function getFundFlow(code, days) {\n try {\n const prefix = etfPrefix(code);\n\n const url =\n \"https://vip.stock.finance.sina.com.cn/quotes_service/api/json_v2.php/MoneyFlow.ssl_qsfx_zjlrqs?page=1&num=\" +\n days + \"&sort=opendate&asc=0&daima=\" + prefix + code;\n\n const res = await fetch(url, {\n headers: {\n \"Referer\": \"https://finance.sina.com.cn/\",\n \"User-Agent\": \"Mozilla/5.0\",\n },\n });\n\n const text = await res.text();\n\n const clean = text.replace(/^[^(]*\$/, \"\").replace(/\$\\s*;?\\s*$/, \"\");\n\n let data;\n\n try {\n data = JSON.parse(clean);\n } catch (e) {\n data = JSON.parse(text);\n }\n\n if (!Array.isArray(data) || data.length === 0) return null;\n\n const latest = data[0];\n\n return {\n date: String(latest.opendate || \"\"),\n\n netAmount: Math.round(Number(latest.netamount) || 0),\n\n ratio: Number(latest.ratioamount) || 0,\n\n mainNet: Math.round(Number(latest.r0_net) || 0),\n\n mainRatio: Number(latest.r0_ratio) || 0,\n };\n } catch (e) {\n console.error(\"资金流获取失败 \" + code + \":\", e.message);\n\n return null;\n }\n}\n\n// 全市场涨跌家数（东财）\n\nasync function getMarketBreadth() {\n try {\n const url =\n \"https://push2.eastmoney.com/api/qt/ulist.np/get?fltt=2&secids=1.000001,0.399001&fields=f104,f105,f106\";\n\n const res = await fetch(url, {\n headers: {\n \"Referer\": \"https://quote.eastmoney.com/\",\n \"User-Agent\": \"Mozilla/5.0\",\n },\n });\n\n const d = await res.json();\n\n const diff = d.data?.diff || [];\n\n if (diff.length < 2) return null;\n\n const sh = diff[0], sz = diff[1];\n\n return {\n up: (sh.f104 || 0) + (sz.f104 || 0),\n\n down: (sh.f105 || 0) + (sz.f105 || 0),\n\n flat: (sh.f106 || 0) + (sz.f106 || 0),\n\n source: \"eastmoney\",\n };\n } catch (e) {\n console.error(\"涨跌家数获取失败:\", e.message);\n\n return null;\n }\n}\n\n// 获取消息面（新浪财经要闻，按板块关键词筛选）\n\nlet _newsCache = { time: 0, data: [] };\n\nasync function getNews() {\n const now = Date.now();\n\n if (_newsCache.data.length > 0 && now - _newsCache.time < 10 * 60 * 1000) {\n return _newsCache.data;\n }\n\n try {\n const url =\n \"https://feed.mix.sina.com.cn/api/roll/get?pageid=153&lid=2516&k=&num=30&page=1&r=\" +\n Math.random();\n\n const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n\n const d = await res.json();\n\n const items = d.result?.data || [];\n\n const news = items.map((n) => ({\n title: String(n.title || \"\"),\n time: String(n.ctime || \"\"),\n }));\n\n _newsCache = { time: now, data: news };\n\n return news;\n } catch (e) {\n console.error(\"消息面获取失败:\", e.message);\n\n return _newsCache.data;\n }\n}\n\n// 多因子技术分析引擎（升级版：含分时、盘中资金流、支撑压力）\n\nfunction generateAnalysis(e) {\n const parts = [];\n\n const price = e.price, ma5 = e.ma5, ma10 = e.ma10, ma20 = e.ma20;\n\n const dif = e.dif, dea = e.dea, macd = e.macd, macdPrev = e.macdPrev;\n\n const k = e.kdjK, d = e.kdjD, j = e.kdjJ;\n\n const volRatio = e.volRatio;\n\n // 1. 均线\n\n let maTxt;\n\n if (price >= ma5 && ma5 >= ma10 && ma10 >= ma20) {\n maTxt = \"均线多头排列（价>MA5>MA10>MA20），趋势向上\";\n } else if (price <= ma5 && ma5 <= ma10 && ma10 <= ma20) {\n maTxt = \"均线空头排列（价 ma5 && price > ma10 && ma10 < ma20) {\n maTxt = \"价格站上5/10日线但MA10 ma20) {\n maTxt = \"价格跌破5/10日线但MA10>MA20，短弱中强\";\n } else maTxt = \"均线交织缠绕，方向不明\";\n\n parts.push(\n \"【均线】MA5=\" + ma5.toFixed(3) + \" MA10=\" + ma10.toFixed(3) + \" MA20=\" +\n ma20.toFixed(3) + \"，\" + maTxt,\n );\n\n // 2. MACD\n\n let macdTxt;\n\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\n parts.push(\n \"【MACD】DIF=\" + dif.toFixed(4) + \" DEA=\" + dea.toFixed(4) + \" 柱=\" +\n macd.toFixed(4) + \"，\" + macdTxt,\n );\n\n // 3. KDJ\n\n let kdjTxt;\n\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) {\n volTxt = \"温和放量（量比\" + volRatio.toFixed(1) + \"）\";\n } else if (volRatio < 0.7) {\n volTxt = \"明显缩量（量比\" + volRatio.toFixed(1) + \"）\";\n } else if (volRatio < 0.9) volTxt = \"缩量（量比\" + volRatio.toFixed(1) + \"）\";\n else volTxt = \"量能平稳（量比\" + volRatio.toFixed(1) + \"）\";\n\n parts.push(\"【量能】今日量/5日均量=\" + volRatio.toFixed(2) + \"，\" + volTxt);\n\n // 5. 盘中资金流向（外盘-内盘，实时）\n\n if (e.activeFlow) {\n const netHand = e.activeFlow.netHand;\n\n const flowTxt = netHand >= 0\n ? \"主动买盘占优（外盘-内盘+\" + (netHand / 10000).toFixed(2) + \"万手）\"\n : \"主动卖盘占优（外盘-内盘-\" + (Math.abs(netHand) / 10000).toFixed(2) +\n \"万手）\";\n\n parts.push(\"【盘中资金】\" + flowTxt + \"，为实时主动买卖力量\");\n }\n\n // 6. 资金流（T-1，如有）\n\n if (e.fundFlow) {\n const ff = e.fundFlow;\n\n const mainTxt = ff.mainNet >= 0\n ? \"主力净流入\" + (ff.mainNet / 100000000).toFixed(2) + \"亿\"\n : \"主力净流出\" + (Math.abs(ff.mainNet) / 100000000).toFixed(2) + \"亿\";\n\n parts.push(\n \"【昨日主力】\" + mainTxt + \"，净流入率\" +\n (ff.mainRatio * 100).toFixed(1) + \"%（T-1，\" + ff.date + \"）\",\n );\n }\n\n // 7. 分时状态（如有）\n\n if (e.minute) {\n const mv = e.minute;\n\n const vsAvg = price >= mv.avgPrice\n ? \"运行于分时均价上方（多头）\"\n : \"运行于分时均价下方（空头）\";\n\n const half = Math.floor(mv.points.length / 2);\n\n const secondHalf = mv.points.slice(half);\n\n let later = 0;\n\n for (const pt of secondHalf) later += pt.v;\n\n const firstHalf = mv.points.slice(0, half);\n\n let early = 0;\n\n for (const pt of firstHalf) early += pt.v;\n\n const flowDir = later > early ? \"午后/尾盘量能放大\" : \"午后/尾盘量能萎缩\";\n\n parts.push(\n \"【分时】\" + vsAvg + \"，分时均价=\" + mv.avgPrice.toFixed(3) + \"，\" +\n flowDir,\n );\n }\n\n // 8. 消息面（如有相关）\n\n if (e.news && e.news.length > 0) {\n const newsTxt = e.news.slice(0, 2).map((n) => n.title).join(\"；\");\n\n parts.push(\"【消息】\" + newsTxt);\n }\n\n // 9. 综合评分（v2.3.1：技术面为主，实时因子降权平滑，避免单日盘中波动剧烈反转结论）\n\n let score = 50;\n\n // --- 技术面（权重高，占主导，随日K稳定） ---\n\n if (price >= ma5) score += 6;\n else score -= 6;\n\n if (price >= ma10) score += 5;\n else score -= 5;\n\n if (price >= ma20) score += 5;\n else score -= 5;\n\n if (ma5 >= ma10) score += 4;\n else score -= 4;\n\n if (ma10 >= ma20) score += 4;\n else score -= 4;\n\n if (dif >= dea) score += 7;\n else score -= 7;\n\n if (dif >= 0) score += 5;\n else score -= 5;\n\n if (macd >= macdPrev) score += 3;\n else score -= 3;\n\n if (k >= d) score += 3;\n else score -= 3;\n\n // --- 实时因子（低权重，仅微调，防剧烈跳变） ---\n\n // 当日涨跌幅：平滑映射，封顶±3（原±5）\n\n if (e.change > 0) score += Math.min(3, e.change * 1.5);\n else score -= Math.min(3, Math.abs(e.change) * 1.5);\n\n // 量价配合：封顶±2（原±4）\n\n if (e.change > 0 && volRatio >= 1.1) score += 2;\n\n if (e.change < 0 && volRatio >= 1.3) score -= 2;\n\n if (e.change < 0 && volRatio <= 0.8) score += 1;\n\n // 盘中资金流（外盘-内盘）：封顶±2（原±3）\n\n if (e.activeFlow) {\n if (e.activeFlow.netHand > 0) score += 2;\n\n if (e.activeFlow.netHand < 0 && Math.abs(e.activeFlow.netHand) > 50000) {\n score -= 2;\n }\n }\n\n // T-1主力资金\n\n if (e.fundFlow) {\n if (e.fundFlow.mainNet > 0) score += 2;\n\n if (e.fundFlow.mainNet < -1e8) score -= 2;\n }\n\n // 分时强弱：封顶±1（原±2）\n\n if (e.minute) {\n if (price >= e.minute.avgPrice) score += 1;\n else score -= 1;\n }\n\n score = Math.max(5, Math.min(95, score));\n\n // 10. 走势判断\n\n let trend;\n\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\n let action;\n\n if (score >= 70) {\n action = \"加仓/持有：趋势向上，回踩MA5/支撑位可加仓，跌破MA10减仓\";\n } else if (score >= 60) {\n action = \"持有偏加：多头占优，逢低分批加仓，止损位MA20/布林下轨\";\n } else if (score >= 50) action = \"持有观望：多空均衡，等待方向选择，轻仓参与\";\n else if (score >= 40) {\n action = \"减仓/观望：偏弱格局，反弹至压力位减仓，不宜重仓\";\n } else action = \"回避：弱势明显，等待企稳信号，勿盲目抄底\";\n\n const support = e.sr\n ? e.sr.support.toFixed(3)\n : (ma20 ? ma20.toFixed(3) : \"-\");\n\n const resist = e.sr\n ? e.sr.resistance.toFixed(3)\n : (ma5 ? ma5.toFixed(3) : \"-\");\n\n const summary = \"综合评分\" + score.toFixed(0) + \"分，短期走势【\" + trend +\n \"】。关键支撑位\" + support + \"，压力位\" + resist + \"。\" + action;\n\n return { score, trend, action, analysis: parts.join(\"。\") + \"。\" + summary };\n}\n\n// 计算ETF全指标+分析\n\nasync function calcEtfIndicators(quote, newsList) {\n const [klines, minuteData] = await Promise.all([\n getKLine(quote.code, 60),\n getMinuteData(quote.code),\n ]);\n\n if (klines.length < 25) {\n return {\n code: quote.code,\n name: quote.name,\n sector: quote.sector,\n ...quote,\n minute: minuteData,\n klineError: \"K线不足\",\n score: 50,\n trend: \"震荡\",\n action: \"数据不足\",\n analysis: \"K线数据不足，无法计算完整技术指标\",\n };\n }\n\n const closes = klines.map((k) => k.close);\n\n const vols = klines.map((k) => k.volume);\n\n const ma5 = calcMA(closes, 5);\n\n const ma10 = calcMA(closes, 10);\n\n const ma20 = calcMA(closes, 20);\n\n const macd = calcMACD(closes);\n\n const kdj = calcKDJ(klines);\n\n const vol5 = vols.slice(-6, -1).reduce((a, b) => a + b, 0) / 5;\n\n const volRatio = vol5 > 0 ? vols[vols.length - 1] / vol5 : 0;\n\n const last = klines[klines.length - 1];\n\n const kline = {\n date: last.date,\n open: last.open,\n close: last.close,\n high: last.high,\n low: last.low,\n prevClose: klines[klines.length - 2].close,\n };\n\n // 盘中资金流向（外盘-内盘，实时）\n\n const activeFlow = {\n netHand: (quote.outer || 0) - (quote.inner || 0),\n\n outer: quote.outer || 0,\n\n inner: quote.inner || 0,\n };\n\n // 支撑压力位（实时计算）\n\n const sr = calcSupportResistance(klines, ma20, ma5);\n\n // 资金流（T-1，异步）\n\n let fundFlow = null;\n\n try {\n fundFlow = await getFundFlow(quote.code, 3);\n } catch (e) {\n fundFlow = null;\n }\n\n // 消息面筛选（按板块）\n\n const keywords = SECTOR_KEYWORDS[quote.sector] || [];\n\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,\n name: quote.name,\n sector: quote.sector,\n\n price: quote.price,\n change: quote.change,\n open: quote.open,\n high: quote.high,\n low: quote.low,\n\n volume: quote.volume,\n amount: quote.amount,\n\n ma5,\n ma10,\n ma20,\n\n dif: macd.dif,\n dea: macd.dea,\n macd: macd.macd,\n\n difPrev: macd.difPrev,\n deaPrev: macd.deaPrev,\n macdPrev: macd.macdPrev,\n\n kdjK: kdj.k,\n kdjD: kdj.d,\n kdjJ: kdj.j,\n\n volRatio,\n kline,\n fundFlow,\n news: sectorNews,\n\n activeFlow,\n sr,\n minute: minuteData,\n };\n\n return { ...base, ...generateAnalysis(base) };\n}\n\n// 大盘指数实时\n\nasync function getIndexRealTime() {\n try {\n const symbols = INDEX_LIST.map((i) => i.pre + i.code).join(\",\");\n\n const map = await fetchTencent(symbols);\n\n return INDEX_LIST.map((i) => ({\n code: i.code,\n name: i.name,\n\n ...(map[i.code] ||\n {\n price: 0,\n change: 0,\n open: 0,\n high: 0,\n low: 0,\n volume: 0,\n amount: 0,\n }),\n }));\n } catch (e) {\n console.error(\"指数获取失败:\", e.message);\n\n return INDEX_LIST.map((i) => ({\n code: i.code,\n name: i.name,\n price: 0,\n change: 0,\n open: 0,\n high: 0,\n low: 0,\n volume: 0,\n amount: 0,\n }));\n }\n}\n\n// ETF实时行情\n\nasync function getEtfRealTime(etfList) {\n try {\n const symbols = etfList.map((e) => etfPrefix(e.code) + e.code).join(\",\");\n\n const map = await fetchTencent(symbols);\n\n return etfList.map((e) => ({\n code: e.code,\n name: e.name,\n sector: e.sector,\n\n ...(map[e.code] ||\n {\n price: 0,\n change: 0,\n open: 0,\n high: 0,\n low: 0,\n volume: 0,\n amount: 0,\n }),\n }));\n } catch (e) {\n console.error(\"ETF获取失败:\", e.message);\n\n return etfList.map((e) => ({\n code: e.code,\n name: e.name,\n sector: e.sector,\n price: 0,\n change: 0,\n open: 0,\n high: 0,\n low: 0,\n volume: 0,\n amount: 0,\n }));\n }\n}\n\nfunction beijingTime() {\n const d = new Date(Date.now() + 8 * 3600 * 1000);\n\n return d.toISOString().replace(\"T\", \" \").substring(0, 19);\n}\n\n// ============ 深度分析（火山方舟LLM，手动触发，次数可控） ============\n\n// 常量：每日免费深度分析次数上限\n\nconst DEEP_ANALYSIS_DAILY_LIMIT = 10;\n\n// 火山方舟模型\n\nconst ARK_MODEL = \"doubao-seed-2-0-pro-260215\";\n\nconst ARK_BASE_URL =\n \"https://ark.cn-beijing.volces.com/api/v3/chat/completions\";\n\n// 记录深度分析调用（返回今日已用次数）\n\nasync function recordDeepAnalysisUsage() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS deep_analysis_usage (\n\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n date TEXT NOT NULL,\n\n code TEXT,\n\n name TEXT,\n\n created_at INTEGER NOT NULL,\n\n prompt_tokens INTEGER DEFAULT 0,\n\n completion_tokens INTEGER DEFAULT 0,\n\n status TEXT DEFAULT 'ok'\n\n )`);\n\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n\n const dateStr = bjNow.toISOString().substring(0, 10);\n\n return dateStr;\n } catch (e) {\n console.error(\"深度分析用量表初始化失败:\", e.message);\n\n return null;\n }\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\n return r.rows?.[0]?.c ?? 0;\n } catch (e) {\n console.error(\"查询深度分析次数失败:\", e.message);\n\n return 0;\n }\n}\n\n// 写一条深度分析用量记录\n\nasync function logDeepAnalysisUsage(\n dateStr,\n code,\n name,\n promptTokens,\n completionTokens,\n status,\n) {\n try {\n await sqlite.execute(\n \"INSERT INTO deep_analysis_usage (date, code, name, created_at, prompt_tokens, completion_tokens, status) VALUES (?,?,?,?,?,?,?)\",\n [\n dateStr,\n code,\n name,\n Date.now(),\n promptTokens || 0,\n completionTokens || 0,\n status || \"ok\",\n ],\n );\n } catch (e) {\n console.error(\"写深度分析用量失败:\", e.message);\n }\n}\n\n// ============ v2.3.1: 深度分析结果持久化（供复盘查看） ============\n\n// 新建 deep_analysis_log 表：完整保存每次深度分析结果，跨请求可查\n\nasync function initDeepAnalysisLog() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS deep_analysis_log (\n\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n date TEXT NOT NULL,\n\n code TEXT NOT NULL,\n\n name TEXT,\n\n sector TEXT,\n\n analysis TEXT,\n\n price REAL,\n\n change REAL,\n\n created_at INTEGER NOT NULL\n\n )`);\n\n return true;\n } catch (e) {\n console.error(\"[深度分析] log表初始化失败:\", e.message);\n\n return false;\n }\n}\n\n// 保存一条深度分析结果\n\nasync function saveDeepAnalysisLog(etf, quote, analysis) {\n try {\n await initDeepAnalysisLog();\n\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n\n const dateStr = bjNow.toISOString().substring(0, 10);\n\n await sqlite.execute(\n \"INSERT INTO deep_analysis_log (date, code, name, sector, analysis, price, change, created_at) VALUES (?,?,?,?,?,?,?,?)\",\n [\n dateStr,\n etf.code,\n etf.name,\n etf.sector || \"\",\n analysis,\n quote.price || 0,\n quote.change || 0,\n Date.now(),\n ],\n );\n\n return true;\n } catch (e) {\n console.error(\"[深度分析] 保存失败:\", e.message);\n\n return false;\n }\n}\n\n// 读取某ETF的历史深度分析（默认最近10条；不传code则返回全部最近N条）\n\nasync function getDeepAnalysisHistory(code, limit) {\n try {\n await initDeepAnalysisLog();\n\n const n = Math.min(Math.max(parseInt(limit || \"10\", 10) || 10, 1), 50);\n\n let rows;\n\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\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\n rows = r.rows || [];\n }\n\n return rows.map((r) => ({\n id: r.id,\n date: r.date,\n code: r.code,\n name: r.name,\n sector: r.sector,\n\n analysis: r.analysis,\n price: r.price,\n change: r.change,\n created_at: r.created_at,\n }));\n } catch (e) {\n console.error(\"[深度分析] 读取历史失败:\", e.message);\n\n return [];\n }\n}\n\n// 调用火山方舟LLM做深度分析\n\nasync function callArkDeepAnalysis(etf, quote) {\n const apiKey = Deno.env.get(\"ARK_API_KEY\");\n\n if (!apiKey) {\n return { error: \"未配置ARK_API_KEY，请先在val-town环境变量中添加\" };\n }\n\n // 构建分析prompt：把该ETF的技术面+资金面+消息面数据打包\n\n const prompt =\n `你是一位专业ETF短线投资者，请对以下ETF进行深度分析，输出结构化的投资分析报告。\n\n\n\n## 标的\n\n名称：${etf.name}（代码${etf.code}，板块：${etf.sector}）\n\n\n\n## 实时行情\n\n- 现价：${quote.price}\n\n- 当日涨跌幅：${quote.change}%\n\n- 成交量：${quote.volume}万手\n\n- 成交额：${quote.amount}亿元\n\n\n\n## 技术指标（基于日K）\n\n- MA5=${etf.ma5?.toFixed(3)} MA10=${etf.ma10?.toFixed(3)} MA20=${\n etf.ma20?.toFixed(3)\n }\n\n- MACD: DIF=${etf.dif?.toFixed(4)} DEA=${etf.dea?.toFixed(4)} 柱=${\n etf.macd?.toFixed(4)\n }\n\n- KDJ: K=${etf.kdjK?.toFixed(1)} D=${etf.kdjD?.toFixed(1)} J=${\n etf.kdjJ?.toFixed(1)\n }\n\n- 量比：${etf.volRatio?.toFixed(2)}\n\n- 支撑位：${etf.support} 压力位：${etf.resistance}\n\n\n\n## 资金面\n\n${\n etf.fundFlow\n ? `- 昨日主力净流入：${\n (etf.fundFlow.mainNet / 100000000).toFixed(2)\n }亿（${etf.fundFlow.date}）`\n : \"- 昨日主力资金：暂无数据\"\n }\n\n${\n etf.activeFlow\n ? `- 盘中主动买卖：外盘-内盘=${\n (etf.activeFlow.netHand / 10000).toFixed(2)\n }万手`\n : \"\"\n }\n\n\n\n## 相关消息\n\n${\n etf.news && etf.news.length\n ? etf.news.slice(0, 3).map((n) => n.title).join(\"\\n\")\n : \"暂无相关消息\"\n }\n\n\n\n## 要求\n\n请从以下维度给出深度分析（不要复述数据，要有独立判断）：\n\n1. **技术面研判**：均线系统状态、MACD动能、KDJ位置、量价配合，给出技术形态判断\n\n2. **资金面研判**：主力资金流向含义、盘中买卖力量\n\n3. **消息面研判**：结合当前板块政策/行业动态，判断消息的利好利空方向及影响程度\n\n4. **综合判断**：给出明确的操作观点（偏多/震荡偏多/震荡/震荡偏空/偏空），以及1-3天走势预判\n\n5. **风险提示**：指出关键风险点、止损位\n\n\n\n请用中文回答，控制在400字以内，条理清晰，观点明确。`;\n\n try {\n const res = await fetch(ARK_BASE_URL, {\n method: \"POST\",\n\n headers: {\n \"Content-Type\": \"application/json\",\n\n \"Authorization\": \"Bearer \" + apiKey,\n },\n\n body: JSON.stringify({\n model: ARK_MODEL,\n\n messages: [\n {\n role: \"system\",\n content:\n \"你是一位资深的ETF短线交易分析师，擅长技术分析、资金流分析和板块轮动研判。\",\n },\n\n { role: \"user\", content: prompt },\n ],\n\n temperature: 0.3,\n\n max_tokens: 1200,\n }),\n });\n\n const d = await res.json();\n\n if (d.error) {\n return {\n error: \"LLM调用失败: \" + (d.error.message || JSON.stringify(d.error)),\n };\n }\n\n const content = d.choices?.[0]?.message?.content || \"\";\n\n const usage = d.usage || {};\n\n return {\n content,\n\n promptTokens: usage.prompt_tokens || 0,\n\n completionTokens: usage.completion_tokens || 0,\n\n model: ARK_MODEL,\n };\n } catch (e) {\n console.error(\"LLM调用异常:\", e.message);\n\n return { error: \"LLM调用异常: \" + e.message };\n }\n}\n\n// ============ 历史存档读取（SQLite global组织级库，跨val共享） ============\n\nasync function getHistory() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS analysis_history (\n\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n date TEXT NOT NULL,\n\n period TEXT NOT NULL,\n\n label TEXT,\n\n created_at INTEGER NOT NULL,\n\n summary TEXT,\n\n records TEXT\n\n )`);\n\n // 最近30天所有时段的分析记录\n\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\n const rows = r.rows || [];\n\n // 解析每条ETF记录\n\n const history = [];\n\n for (const row of rows) {\n try {\n const etf = JSON.parse(row.records);\n\n history.push({\n date: row.date,\n period: row.period,\n label: row.label,\n created_at: row.created_at,\n\n code: etf.code,\n name: etf.name,\n sector: etf.sector,\n\n price: etf.price,\n change: etf.change,\n volume: etf.volume,\n amount: etf.amount,\n\n dif: etf.dif,\n dea: etf.dea,\n macd: etf.macd,\n\n ma5: etf.ma5,\n ma10: etf.ma10,\n ma20: etf.ma20,\n\n kdjK: etf.kdjK,\n kdjD: etf.kdjD,\n kdjJ: etf.kdjJ,\n\n volRatio: etf.volRatio,\n score: etf.score,\n trend: etf.trend,\n action: etf.action,\n\n analysis: etf.analysis,\n support: etf.support,\n resistance: etf.resistance,\n });\n } catch (e) {}\n }\n\n // 按日期+时段聚合摘要\n\n const groups = {};\n\n for (const row of rows) {\n const key = row.date;\n\n if (!groups[key]) groups[key] = [];\n\n if (!groups[key].find((g) => g.label === row.label)) {\n let summary = {};\n\n try {\n summary = JSON.parse(row.summary || \"{}\");\n } catch (e) {}\n\n groups[key].push({\n label: row.label,\n count: summary.count,\n upCount: summary.upCount,\n downCount: summary.downCount,\n avgScore: summary.avgScore,\n best: summary.best,\n worst: summary.worst,\n });\n }\n }\n\n return {\n history,\n groups,\n total: history.length,\n latestDate: rows[0]?.date || null,\n };\n } catch (e) {\n console.error(\"读取历史失败:\", e.message);\n\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\n const path = url.pathname;\n\n if (path === \"/history\" || url.searchParams.get(\"history\") === \"1\") {\n const h = await getHistory();\n\n return Response.json({ success: true, timestamp: beijingTime(), ...h }, {\n headers: { \"Access-Control-Allow-Origin\": \"*\" },\n });\n }\n\n // ===== 深度分析（LLM，次数可控） =====\n\n if (\n path === \"/deep-analysis/quota\" || url.searchParams.get(\"quota\") === \"1\"\n ) {\n const dateStr = await recordDeepAnalysisUsage();\n\n const used = dateStr ? await getDeepAnalysisUsedCount(dateStr) : 0;\n\n return Response.json({\n success: true,\n timestamp: beijingTime(),\n date: dateStr,\n used,\n limit: DEEP_ANALYSIS_DAILY_LIMIT,\n remaining: Math.max(0, DEEP_ANALYSIS_DAILY_LIMIT - used),\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n if (\n path === \"/deep-analysis/history\" ||\n url.searchParams.get(\"dahistory\") === \"1\"\n ) {\n const code = url.searchParams.get(\"code\") || \"\";\n\n const limit = url.searchParams.get(\"limit\") || \"10\";\n\n const list = await getDeepAnalysisHistory(code || null, limit);\n\n return Response.json({\n success: true,\n timestamp: beijingTime(),\n count: list.length,\n list,\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n if (\n path === \"/deep-analysis\" && (req.method === \"GET\" || req.method === \"POST\")\n ) {\n const code = url.searchParams.get(\"code\");\n\n if (!code) {\n return Response.json({\n success: false,\n message: \"缺少code参数，请指定ETF代码如 /deep-analysis?code=159562\",\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n // 检查今日配额\n\n const dateStr = await recordDeepAnalysisUsage();\n\n if (!dateStr) {\n return Response.json({\n success: false,\n message: \"深度分析配额系统初始化失败\",\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n const used = await getDeepAnalysisUsedCount(dateStr);\n\n if (used >= DEEP_ANALYSIS_DAILY_LIMIT) {\n return Response.json({\n success: false,\n message: \"今日深度分析次数已用完（\" + DEEP_ANALYSIS_DAILY_LIMIT +\n \"次），请明日再试\",\n used,\n limit: DEEP_ANALYSIS_DAILY_LIMIT,\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n // 从缓存或实时获取该ETF数据\n\n let etf = null;\n\n let quote = null;\n\n try {\n const etfList = await getEtfListFromFeishu();\n\n const etfMeta = etfList.find((e) => e.code === code);\n\n if (!etfMeta) {\n return Response.json({\n success: false,\n message: \"ETF代码\" + code +\n \"不在监控列表（请先在飞书基础信息库添加）\",\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n const quotes = await getEtfRealTime([etfMeta]);\n\n const q = quotes[0] || {};\n\n const newsList = await getNews();\n\n const analyzed = await calcEtfIndicators({ ...etfMeta, ...q }, newsList);\n\n if (analyzed.klineError) {\n return Response.json({\n success: false,\n message: \"该ETF数据不足: \" + analyzed.klineError,\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n etf = analyzed;\n\n quote = q;\n } catch (e) {\n return Response.json({\n success: false,\n message: \"获取ETF数据失败: \" + e.message,\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n // 调用LLM深度分析\n\n const result = await callArkDeepAnalysis(etf, quote);\n\n // 记录用量（无论成败都计数，防止刷接口）\n\n const promptTokens = result.promptTokens || 0;\n\n const completionTokens = result.completionTokens || 0;\n\n await logDeepAnalysisUsage(\n dateStr,\n code,\n etf.name,\n promptTokens,\n completionTokens,\n result.error ? \"error\" : \"ok\",\n );\n\n if (result.error) {\n return Response.json({\n success: false,\n message: result.error,\n code,\n name: etf.name,\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n // v2.3.1: 保存分析结果到SQLite，供复盘查看\n\n try {\n await saveDeepAnalysisLog(etf, quote, result.content);\n } catch (e) {\n console.error(\"保存深度分析结果失败:\", e.message);\n }\n\n return Response.json({\n success: true,\n timestamp: beijingTime(),\n code,\n name: etf.name,\n sector: etf.sector,\n analysis: result.content,\n promptTokens,\n completionTokens,\n remaining: Math.max(0, DEEP_ANALYSIS_DAILY_LIMIT - used - 1),\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n const refresh = url.searchParams.get(\"refresh\");\n\n if (\n refresh === \"1\" || !globalThis._cachedData ||\n Date.now() - globalThis._cacheTime > 30 * 1000\n ) {\n try {\n // 动态读取ETF列表\n\n const etfList = await getEtfListFromFeishu();\n\n if (etfList.length === 0) {\n return Response.json({\n success: false,\n timestamp: beijingTime(),\n message: \"飞书ETF基础信息库为空或读取失败\",\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n\n // 获取指数、ETF行情、消息面、全市场涨跌家数\n\n const [indices, etfQuotes, newsList, breadth] = await Promise.all([\n getIndexRealTime(),\n getEtfRealTime(etfList),\n getNews(),\n getMarketBreadth(),\n ]);\n\n // 逐只计算指标+分析（K线与分时并行）\n\n const etfs = [];\n\n for (const q of etfQuotes) {\n etfs.push(await calcEtfIndicators(q, newsList));\n }\n\n // 大盘盘面统计\n\n const upCount = etfs.filter((e) => e.change > 0).length;\n\n const downCount = etfs.filter((e) => e.change < 0).length;\n\n const flatCount = etfs.filter((e) => e.change === 0).length;\n\n const avgChange = etfs.reduce((a, e) => a + e.change, 0) /\n (etfs.length || 1);\n\n const market = {\n upCount,\n downCount,\n flatCount,\n avgChange: Number(avgChange.toFixed(2)),\n\n totalAmount: Number(\n ((indices[0]?.amount || 0) + (indices[1]?.amount || 0)).toFixed(2),\n ),\n\n etfCount: etfs.length,\n\n // 全市场涨跌家数（东财，可能为空则降级）\n\n hsUp: breadth?.up || null,\n\n hsDown: breadth?.down || null,\n\n hsFlat: breadth?.flat || null,\n\n breadthSource: breadth?.source || null,\n };\n\n globalThis._cachedData = { indices, etfs, market };\n\n globalThis._cacheTime = Date.now();\n\n globalThis._cacheError = null;\n } catch (e) {\n globalThis._cacheError = e.message;\n\n console.error(\"数据获取失败:\", e.message);\n }\n }\n\n const data = globalThis._cachedData || { indices: [], etfs: [], market: {} };\n\n return Response.json({\n success: true,\n timestamp: beijingTime(),\n\n indices: data.indices,\n etfs: data.etfs,\n market: data.market,\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n}","createdAt",["D",1787798222736],"branchVersion","branchId","b636b57c-1589-4055-8218-6fbf99de3708","id","4413457f-3b8d-4303-8e1e-de4426fea38b","etf-monitor",["D",1787622199218],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","ETF行情自动监控：获取行情数据、计算MACD、写入飞书多维表格","imageUrl","e466a24e-860d-46c8-8516-ebc08a35b30f","pinnedFileId","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",{"_99":98,"_106":101},"org",{"_99":98,"_100":101,"_102":101,"_18":55,"_103":104,"_105":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",52,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","CGH2026","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":167,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":168,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":169,"_83":170,"_85":171,"_87":25},"tree",[158,159],"files",[158,159],"counts",{"_146":62,"_147":148,"_149":62,"_150":151,"_152":153},"contents",[128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":137,"_32":138,"_30":139,"_131":-5,"_41":42,"_40":140,"_132":25,"_38":141,"_13":142,"_33":143,"_35":144,"_24":25,"_135":-5,"_27":145},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":133,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_27":136},"1661a679-9403-48e4-b7b0-fbad4aaec3c0","parentId","latest",["D",1787798222736],17,"label",[28],"16466c61-45a1-4798-bd9a-a91da8a7627f","main.ts","594a9562-a026-11f1-acc2-1607ee4eb77e",45,["D",1787794884517],27,"interval","import { sqlite } from \"https://esm.town/v/std/sqlite/global.ts\";\n\n// ============================================================\n\n// ETF定时分析 CRON v2.2 - 存档集中到应用版\n\n// 功能：动态ETF列表(飞书) + 4时段分析(9:25盘前/12:55午盘/14:30尾盘/15:00收盘)\n\n// + MACD(10,20,7) + 分时/盘中资金流/支撑压力位\n\n// + 深度分析 + 分析结果写入val-town SQLite存档(应用集中展示)\n\n// + 盘前9:25未开盘时改为\"盘前预判\"(基于昨收K线+消息面，修复数据错误)\n\n// 部署文件：main.ts (val-town CRON, 每15分钟)\n\n// 更新日期：2026-08-27\n\n// ============================================================\n\nconst ETF_INFO_TABLE_ID = \"tbl5K6lJm9aAjKdo\"; // ETF基础信息库\n\nconst INDEX_TABLE_ID = \"tblsDzjKrYZGHcXD\"; // 大盘指数表\n\nconst DAILY_TABLE_ID = Deno.env.get(\"FEISHU_TABLE_ID\"); // 日报表\n\nconst INDEX_LIST = [\n { code: \"000001\", name: \"上证指数\", pre: \"sh\" },\n\n { code: \"399001\", name: \"深证成指\", pre: \"sz\" },\n\n { code: \"399006\", name: \"创业板指\", pre: \"sz\" },\n\n { code: \"000688\", name: \"科创50\", pre: \"sh\" },\n];\n\nconst SECTOR_KEYWORDS = {\n \"科技\": [\n \"芯片\",\n \"半导体\",\n \"人工智能\",\n \"AI\",\n \"算力\",\n \"机器人\",\n \"卫星\",\n \"通信\",\n \"电子\",\n \"5G\",\n \"数据中心\",\n \"软件\",\n \"半导体设备\",\n \"功率\",\n ],\n\n \"新能源\": [\"电池\", \"储能\", \"锂电\", \"光伏\", \"新能源\", \"固态电池\", \"充电桩\"],\n\n \"周期\": [\n \"黄金\",\n \"有色\",\n \"稀土\",\n \"稀有金属\",\n \"大宗商品\",\n \"铜\",\n \"金价\",\n \"贵金属\",\n ],\n\n \"医药\": [\"创新药\", \"医药\", \"生物医药\", \"CRO\", \"医疗\", \"药\"],\n\n \"金融\": [\"银行\", \"券商\", \"保险\", \"金融\"],\n\n \"宽基\": [\"沪深300\", \"上证50\", \"中证\", \"大盘\", \"A股\"],\n\n \"其他\": [\"电力\", \"公用事业\", \"能源\"],\n\n \"消费\": [\"消费\", \"白酒\", \"食品\", \"家电\"],\n\n \"港股\": [\"港股\", \"恒生\", \"中概\"],\n\n \"海外\": [\"美股\", \"纳斯达克\", \"标普\", \"海外\"],\n};\n\n// ============ P0-1: A股交易日历（法定节假日判断） ============\n\n// 2026年交易所休市安排（沪深北交易所公告，2025-12-22发布）\n\n// 节假日闭市日（含周末连休）；2026年无调休补班工作日\n\nconst HOLIDAYS_2026 = [\n \"2026-01-01\",\n \"2026-01-02\",\n \"2026-01-03\",\n \"2026-01-04\", // 元旦 1/1-1/3休市，1/4周日\n\n \"2026-02-14\",\n \"2026-02-15\",\n \"2026-02-16\",\n \"2026-02-17\",\n \"2026-02-18\",\n \"2026-02-19\",\n \"2026-02-20\",\n \"2026-02-21\",\n \"2026-02-22\",\n \"2026-02-23\",\n \"2026-02-28\", // 春节 2/14-2/23，2/28周六\n\n \"2026-04-04\",\n \"2026-04-05\",\n \"2026-04-06\", // 清明\n\n \"2026-05-01\",\n \"2026-05-02\",\n \"2026-05-03\",\n \"2026-05-04\",\n \"2026-05-05\",\n \"2026-05-09\", // 劳动节，5/9周六\n\n \"2026-06-19\",\n \"2026-06-20\",\n \"2026-06-21\", // 端午\n\n \"2026-09-25\",\n \"2026-09-26\",\n \"2026-09-27\", // 中秋\n\n \"2026-09-20\", // 国庆前周末休市\n\n \"2026-10-01\",\n \"2026-10-02\",\n \"2026-10-03\",\n \"2026-10-04\",\n \"2026-10-05\",\n \"2026-10-06\",\n \"2026-10-07\",\n \"2026-10-10\", // 国庆 10/1-10/7，10/10周六\n];\n\n// 判断今天是否为A股交易日（北京时间）\n\nfunction isTradingDay(bjDateStr) {\n // 先查节假日表\n\n if (HOLIDAYS_2026.includes(bjDateStr)) return false;\n\n // 再判周末（用UTC构造，避免本地时区干扰，任何环境都准确）\n\n const parts = bjDateStr.split(\"-\").map(Number);\n\n const day = new Date(Date.UTC(parts[0], parts[1] - 1, parts[2])).getUTCDay();\n\n if (day === 0 || day === 6) return false;\n\n return true;\n}\n\n// 判断当前时间属于哪个分析时段（北京时间，±10分钟）\n\nfunction getAnalysisType() {\n const now = new Date();\n\n const bjHour = (now.getUTCHours() + 8) % 24;\n\n const bjMinute = now.getUTCMinutes();\n\n const bjTime = bjHour * 60 + bjMinute;\n\n const day = now.getUTCDay();\n\n if (day === 0 || day === 6) return { type: \"skip\", reason: \"周末不执行\" };\n\n // P0-1: 法定节假日判断（A股交易日历）\n\n const bjDateStr = new Date(Date.now() + 8 * 3600 * 1000).toISOString()\n .substring(0, 10);\n\n if (!isTradingDay(bjDateStr)) {\n return { type: \"skip\", reason: \"法定节假日休市 \" + bjDateStr };\n }\n\n const windows = [\n { target: 9 * 60 + 25, type: \"盘前分析\", label: \"盘前\" },\n\n { target: 12 * 60 + 55, type: \"午盘分析\", label: \"午盘\" },\n\n { target: 14 * 60 + 30, type: \"尾盘分析\", label: \"尾盘\" },\n\n { target: 15 * 60, type: \"收盘分析\", label: \"收盘\" },\n ];\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\n return { type: \"skip\", reason: \"非指定时段\", bjTime: bjTime };\n}\n\nfunction etfPrefix(code) {\n return code.startsWith(\"15\") ? \"sz\" : \"sh\";\n}\n\nasync function getFeishuToken() {\n const res = await fetch(\n \"https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal\",\n {\n method: \"POST\",\n\n headers: { \"Content-Type\": \"application/json\" },\n\n body: JSON.stringify({\n app_id: Deno.env.get(\"FEISHU_APP_ID\"),\n app_secret: Deno.env.get(\"FEISHU_APP_SECRET\"),\n }),\n },\n );\n\n const d = await res.json();\n\n if (!d.tenant_access_token) throw new Error(\"飞书token获取失败\");\n\n return d.tenant_access_token;\n}\n\n// ============ P0-2: 分析失败告警（SQLite记录 + 飞书推送可选） ============\n\n// 告警写入 SQLite alert_log 表（应用端可读），若配置了 FEISHU_OPEN_ID 则同时推飞书\n\nasync function initAlertTable() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS alert_log (\n\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n date TEXT NOT NULL,\n\n period TEXT,\n\n level TEXT DEFAULT 'error',\n\n title TEXT,\n\n content TEXT,\n\n created_at INTEGER NOT NULL\n\n )`);\n\n return true;\n } catch (e) {\n console.error(\"[告警] alert_log表初始化失败:\", e.message);\n\n return false;\n }\n}\n\nasync function writeAlert(dateStr, period, level, title, content) {\n try {\n await initAlertTable();\n\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\n console.log(\"[告警] 已记录:\", title);\n\n // 可选：推飞书（需配置FEISHU_OPEN_ID）\n\n const openId = Deno.env.get(\"FEISHU_OPEN_ID\");\n\n if (openId) {\n try {\n const token = await getFeishuToken();\n\n const url =\n \"https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=open_id\";\n\n const body = {\n receive_id: openId,\n\n msg_type: \"text\",\n\n content: JSON.stringify({\n text: \"⚠️ ETF监控[\" + period + \"] \" + title + \"\\n\" + content,\n }),\n };\n\n await fetch(url, {\n method: \"POST\",\n\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": \"Bearer \" + token,\n },\n\n body: JSON.stringify(body),\n });\n\n console.log(\"[告警] 已推飞书\");\n } catch (e) {\n console.error(\"[告警] 飞书推送异常:\", e.message);\n }\n }\n\n return true;\n } catch (e) {\n console.error(\"[告警] 记录异常:\", e.message);\n\n return false;\n }\n}\n\n// 从飞书基础信息库读取启用ETF列表\n\nasync function getEtfListFromFeishu() {\n try {\n const token = await getFeishuToken();\n\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n\n const url = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt +\n \"/tables/\" + ETF_INFO_TABLE_ID + \"/records?page_size=100\";\n\n const res = await fetch(url, {\n headers: { \"Authorization\": \"Bearer \" + token },\n });\n\n const d = await res.json();\n\n if (d.code !== 0) return [];\n\n const items = d.data.items || [];\n\n const list = [];\n\n for (const r of items) {\n const f = r.fields;\n\n const enabled = Array.isArray(f[\"启用\"])\n ? (f[\"启用\"][0]?.text || \"\")\n : String(f[\"启用\"] || \"是\");\n\n if (enabled === \"否\") continue;\n\n const code = String(f[\"ETF代码\"] || \"\");\n\n if (!code) continue;\n\n const name = String(f[\"ETF名称\"] || code);\n\n const sector = Array.isArray(f[\"所属板块\"])\n ? (f[\"所属板块\"][0]?.text || \"其他\")\n : (String(f[\"所属板块\"] || \"其他\"));\n\n list.push({ code, name, sector });\n }\n\n return list;\n } catch (e) {\n console.error(\"读取ETF列表失败:\", e.message);\n\n return [];\n }\n}\n\n// 腾讯行情（含外盘/内盘）\n\nasync function fetchTencent(symbols) {\n const url = \"https://qt.gtimg.cn/q=\" + symbols;\n\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\" },\n });\n\n const buf = await res.arrayBuffer();\n\n let text;\n\n try {\n text = new TextDecoder(\"gbk\").decode(buf);\n } catch (e) {\n text = new TextDecoder(\"utf-8\").decode(buf);\n }\n\n const map = {};\n\n for (const line of text.split(\";\")) {\n const m = line.match(/v_(?:sh|sz)(\\d+)=\"([^\"]+)\"/);\n\n if (!m) continue;\n\n const f = m[2].split(\"~\");\n\n map[m[1]] = {\n name: f[1] || \"\",\n price: parseFloat(f[3]) || 0,\n change: parseFloat(f[32]) || 0,\n\n open: parseFloat(f[5]) || 0,\n high: parseFloat(f[33]) || 0,\n low: parseFloat(f[34]) || 0,\n\n volume: (parseFloat(f[36]) || 0) / 10000,\n amount: (parseFloat(f[37]) || 0) / 10000,\n\n outer: parseFloat(f[7]) || 0,\n inner: parseFloat(f[8]) || 0,\n };\n }\n\n return map;\n}\n\n// 日K线\n\nasync function getKLine(code, n) {\n const prefix = etfPrefix(code);\n\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=\" +\n prefix + code + \",day,,,\" + n + \",qfq\";\n\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" },\n });\n\n const d = await res.json();\n\n const obj = d.data?.[prefix + code];\n\n const day = obj?.day || obj?.qfqday || [];\n\n return day.map((k) => ({\n date: k[0],\n close: parseFloat(k[2]) || 0,\n high: parseFloat(k[3]) || 0,\n low: parseFloat(k[4]) || 0,\n volume: parseFloat(k[5]) || 0,\n }));\n}\n\n// 分时数据（腾讯）\n\nasync function getMinuteData(code) {\n try {\n const prefix = etfPrefix(code);\n\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=\" +\n prefix + code;\n\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" },\n });\n\n const d = await res.json();\n\n const obj = d.data?.[prefix + code];\n\n const dataArr = obj?.data?.data || [];\n\n const points = [];\n\n for (const line of dataArr) {\n const p = line.split(\" \");\n\n if (p.length < 4) continue;\n\n points.push({\n p: parseFloat(p[1]) || 0,\n v: parseFloat(p[2]) || 0,\n a: parseFloat(p[3]) || 0,\n });\n }\n\n if (points.length === 0) return null;\n\n let cumV = 0, cumA = 0;\n\n for (const pt of points) {\n cumV += pt.v;\n cumA += pt.a;\n }\n\n const avgPrice = cumV > 0\n ? cumA / (cumV * 100)\n : points[points.length - 1].p;\n\n return {\n avgPrice: Number(avgPrice.toFixed(4)),\n\n latest: points[points.length - 1].p,\n\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\n const k = 2 / (period + 1);\n\n let ema = values[0];\n\n const result = [ema];\n\n for (let i = 1; i < values.length; i++) {\n ema = values[i] * k + ema * (1 - k);\n result.push(ema);\n }\n\n return result;\n}\n\nfunction calcMACD(closes) {\n const ema10 = calcEMA(closes, 10);\n\n const ema20 = calcEMA(closes, 20);\n\n const dif = closes.map((_, i) => ema10[i] - ema20[i]);\n\n const dea = calcEMA(dif, 7);\n\n const macd = dif.map((d, i) => 2 * (d - dea[i]));\n\n const n = closes.length - 1;\n\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\n return closes.slice(-period).reduce((a, b) => a + b, 0) / period;\n}\n\nfunction calcKDJ(klines) {\n const n = 9;\n\n let k = 50, d = 50, lastK = 50, lastD = 50;\n\n for (let i = 0; i < klines.length; i++) {\n const start = Math.max(0, i - n + 1);\n\n let highest = -Infinity, lowest = Infinity;\n\n for (let j = start; j <= i; j++) {\n highest = Math.max(highest, klines[j].high);\n\n lowest = Math.min(lowest, klines[j].low);\n }\n\n const rsv = highest === lowest\n ? 50\n : ((klines[i].close - lowest) / (highest - lowest)) * 100;\n\n k = (2 / 3) * k + (1 / 3) * rsv;\n\n d = (2 / 3) * d + (1 / 3) * k;\n\n lastK = k;\n lastD = d;\n }\n\n return { k: lastK, d: lastD, j: 3 * lastK - 2 * lastD };\n}\n\n// 支撑压力位（实时计算）\n\nfunction calcSupportResistance(klines, ma20, ma5) {\n const recent = klines.slice(-20);\n\n let hi20 = -Infinity, lo20 = Infinity;\n\n for (const k of recent) {\n if (k.high > hi20) hi20 = k.high;\n\n if (k.low < lo20) lo20 = k.low;\n }\n\n let std = 0;\n\n if (klines.length >= 20) {\n const closes = klines.slice(-20).map((k) => k.close);\n\n const mean = closes.reduce((a, b) => a + b, 0) / 20;\n\n std = Math.sqrt(\n closes.reduce((a, b) => a + (b - mean) * (b - mean), 0) / 20,\n );\n }\n\n const bollLower = ma20 ? ma20 - 2 * std : 0;\n\n const bollUpper = ma20 ? ma20 + 2 * std : 0;\n\n const support = ma20 && bollLower\n ? Math.min(ma20, bollLower)\n : (ma20 || bollLower || lo20);\n\n const resistance = ma5 && bollUpper\n ? Math.max(ma5, bollUpper)\n : (ma5 || bollUpper || hi20);\n\n return {\n support: Number(support.toFixed(4)),\n resistance: Number(resistance.toFixed(4)),\n };\n}\n\n// ============ P1: ATR(14) 平均真实波幅（风险指标） ============\n\nfunction calcATR(klines, period = 14) {\n if (!klines || klines.length < period + 1) return null;\n\n const trs = [];\n\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\n const tr = Math.max(h - l, Math.abs(h - pc), Math.abs(l - pc));\n\n trs.push(tr);\n }\n\n // Wilder平滑\n\n let atr = trs.slice(0, period).reduce((a, b) => a + b, 0) / period;\n\n for (let i = period; i < trs.length; i++) {\n atr = (atr * (period - 1) + trs[i]) / period;\n }\n\n return {\n atr: Number(atr.toFixed(4)),\n atrPct: atr && klines[klines.length - 1].close\n ? Number((atr / klines[klines.length - 1].close * 100).toFixed(2))\n : 0,\n };\n}\n\n// ============ P1: 隔夜外围联动（美股+富时A50） ============\n\n// 新浪国际指数接口，返回隔夜美股/外围走势\n\nasync function getOvernightOverseas() {\n try {\n // 美股指数 + 富时A50期指 + 恒生指数（腾讯国际行情）\n\n const url = \"https://qt.gtimg.cn/q=usDJI,usIXIC,usINX,hkHSI\";\n\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\" },\n });\n\n const buf = await res.arrayBuffer();\n\n let text;\n\n try {\n text = new TextDecoder(\"gbk\").decode(buf);\n } catch (e) {\n text = new TextDecoder(\"utf-8\").decode(buf);\n }\n\n const result = [];\n\n const map = {\n usDJI: { name: \"道琼斯\", key: \"dow\" },\n\n usIXIC: { name: \"纳斯达克\", key: \"nasdaq\" },\n\n usINX: { name: \"标普500\", key: \"spx\" },\n\n hkHSI: { name: \"恒生指数\", key: \"hsi\" },\n };\n\n for (const line of text.split(\";\")) {\n const m = line.match(/v_([a-zA-Z0-9]+)=\"([^\"]+)\"/);\n\n if (!m) continue;\n\n const meta = map[m[1]];\n\n if (!meta) continue;\n\n const f = m[2].split(\"~\");\n\n result.push({\n key: meta.key,\n name: meta.name,\n\n price: parseFloat(f[3]) || 0,\n\n change: parseFloat(f[32]) || 0,\n });\n }\n\n return result;\n } catch (e) {\n console.error(\"获取外围数据失败:\", e.message);\n\n return [];\n }\n}\n\n// 生成外围联动分析文本\n\nfunction analyzeOverseas(overseas, label) {\n if (!overseas || overseas.length === 0) return \"\";\n\n const parts = [];\n\n for (const o of overseas) {\n if (!o.price) continue;\n\n const dir = o.change >= 0 ? \"上涨\" : \"下跌\";\n\n parts.push(\n o.name + \"隔夜\" + dir + (o.change >= 0 ? \"+\" : \"\") + o.change.toFixed(2) +\n \"%\",\n );\n }\n\n if (parts.length === 0) return \"\";\n\n // 综合判断外围环境对A股的联动影响\n\n const avgChg =\n overseas.filter((o) => o.price).reduce((a, b) => a + (b.change || 0), 0) /\n overseas.filter((o) => o.price).length || 0;\n\n let env;\n\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\n return \"【外围联动】\" + parts.join(\"，\") + \"；\" + env + \"（\" + label +\n \"研判参考）\";\n}\n\n// 资金流（新浪，T-1）\n\nasync function getFundFlow(code) {\n try {\n const prefix = etfPrefix(code);\n\n const url =\n \"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=\" +\n prefix + code;\n\n const res = await fetch(url, {\n headers: {\n \"Referer\": \"https://finance.sina.com.cn/\",\n \"User-Agent\": \"Mozilla/5.0\",\n },\n });\n\n const text = await res.text();\n\n const clean = text.replace(/^[^(]*\$/, \"\").replace(/\$\\s*;?\\s*$/, \"\");\n\n let data;\n\n try {\n data = JSON.parse(clean);\n } catch (e) {\n data = JSON.parse(text);\n }\n\n if (!Array.isArray(data) || data.length === 0) return null;\n\n const latest = data[0];\n\n return {\n date: String(latest.opendate || \"\"),\n mainNet: Math.round(Number(latest.r0_net) || 0),\n\n mainRatio: Number(latest.r0_ratio) || 0,\n };\n } catch (e) {\n return null;\n }\n}\n\n// 消息面（新浪要闻）\n\nasync function getNews() {\n try {\n const url =\n \"https://feed.mix.sina.com.cn/api/roll/get?pageid=153&lid=2516&k=&num=30&page=1&r=\" +\n Math.random();\n\n const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n\n const d = await res.json();\n\n return (d.result?.data || []).map((n) => String(n.title || \"\"));\n } catch (e) {\n return [];\n }\n}\n\n// 深度分析（升级版：分时+盘中资金流+支撑压力）\n\nfunction generateAnalysis(e) {\n const parts = [];\n\n const price = e.price, ma5 = e.ma5, ma10 = e.ma10, ma20 = e.ma20;\n\n const dif = e.dif, dea = e.dea, macd = e.macd;\n\n const k = e.kdjK, d = e.kdjD;\n\n const volRatio = e.volRatio;\n\n let maTxt;\n\n if (price >= ma5 && ma5 >= ma10 && ma10 >= ma20) {\n maTxt = \"均线多头排列，趋势向上\";\n } else if (price <= ma5 && ma5 <= ma10 && ma10 <= ma20) {\n 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\n parts.push(\n \"【均线】MA5=\" + ma5.toFixed(3) + \" MA10=\" + ma10.toFixed(3) + \" MA20=\" +\n ma20.toFixed(3) + \"，\" + maTxt,\n );\n\n let macdTxt;\n\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\n parts.push(\n \"【MACD】DIF=\" + dif.toFixed(4) + \" DEA=\" + dea.toFixed(4) + \" 柱=\" +\n macd.toFixed(4) + \"，\" + macdTxt,\n );\n\n let kdjTxt;\n\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\n parts.push(\"【KDJ】K=\" + k.toFixed(1) + \" D=\" + d.toFixed(1) + \"，\" + kdjTxt);\n\n let volTxt;\n\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\n parts.push(\"【量能】量比\" + volRatio.toFixed(2) + \"，\" + volTxt);\n\n // P1: ATR 波动风险分析\n\n if (e.atr && e.atr.atr > 0) {\n let atrTxt;\n\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\n parts.push(\n \"【波动】ATR=\" + e.atr.atr + \"（日振幅均值\" + e.atr.atrPct + \"%），\" +\n atrTxt,\n );\n }\n\n // P1: 隔夜外围联动\n\n if (e.overseas && e.overseas.length > 0) {\n const ovTxt = analyzeOverseas(e.overseas, \"盘前/盘中\");\n\n if (ovTxt) parts.push(ovTxt);\n }\n\n // 盘中资金流向（外盘-内盘）\n\n if (e.activeFlow && e.activeFlow.netHand) {\n const netHand = e.activeFlow.netHand;\n\n const flowTxt = netHand >= 0\n ? \"主动买盘占优（+\" + (netHand / 10000).toFixed(2) + \"万手）\"\n : \"主动卖盘占优（-\" + (Math.abs(netHand) / 10000).toFixed(2) + \"万手）\";\n\n parts.push(\"【盘中资金】\" + flowTxt + \"（实时外盘-内盘）\");\n }\n\n // 分时状态\n\n if (e.minute) {\n const vsAvg = price >= e.minute.avgPrice\n ? \"运行于分时均价上方（多头）\"\n : \"运行于分时均价下方（空头）\";\n\n parts.push(\n \"【分时】\" + vsAvg + \"，分时均价=\" + e.minute.avgPrice.toFixed(3),\n );\n }\n\n if (e.fundFlow) {\n const ff = e.fundFlow;\n\n const mainTxt = ff.mainNet >= 0\n ? \"主力净流入\" + (ff.mainNet / 100000000).toFixed(2) + \"亿\"\n : \"主力净流出\" + (Math.abs(ff.mainNet) / 100000000).toFixed(2) + \"亿\";\n\n parts.push(\"【昨日主力】\" + mainTxt + \"（T-1，\" + ff.date + \"）\");\n }\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\n if (price >= ma5) score += 5;\n else score -= 5;\n\n if (price >= ma10) score += 4;\n else score -= 4;\n\n if (price >= ma20) score += 4;\n else score -= 4;\n\n if (ma5 >= ma10) score += 3;\n else score -= 3;\n\n if (ma10 >= ma20) score += 3;\n else score -= 3;\n\n if (dif >= dea) score += 6;\n else score -= 6;\n\n if (dif >= 0) score += 4;\n else score -= 4;\n\n if (k >= d) score += 3;\n else score -= 3;\n\n if (e.change > 0) score += Math.min(5, e.change * 2);\n else score -= Math.min(5, Math.abs(e.change) * 2);\n\n if (e.change > 0 && volRatio >= 1.1) score += 3;\n\n if (e.change < 0 && volRatio >= 1.3) score -= 4;\n\n if (e.change < 0 && volRatio <= 0.8) score += 2;\n\n if (e.activeFlow) {\n if (e.activeFlow.netHand > 0) score += 3;\n\n if (e.activeFlow.netHand < 0 && Math.abs(e.activeFlow.netHand) > 50000) {\n score -= 3;\n }\n }\n\n if (e.minute) {\n if (price >= e.minute.avgPrice) score += 2;\n else score -= 2;\n }\n\n if (e.fundFlow) {\n if (e.fundFlow.mainNet > 0) score += 3;\n if (e.fundFlow.mainNet < -1e8) score -= 3;\n }\n\n score = Math.max(5, Math.min(95, score));\n\n let trend;\n\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\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\n ? e.sr.support.toFixed(3)\n : (ma20 ? ma20.toFixed(3) : \"-\");\n\n const resist = e.sr\n ? e.sr.resistance.toFixed(3)\n : (ma5 ? ma5.toFixed(3) : \"-\");\n\n return {\n score,\n trend,\n action,\n analysis: parts.join(\"。\") + \"。综合评分\" + score + \"分，走势【\" + trend +\n \"】，\" + action + \"。关键支撑\" + support + \"，压力\" + resist + \"。\",\n };\n}\n\n// 写入日报表（飞书）\n\nasync function writeToFeishu(records, label) {\n const token = await getFeishuToken();\n\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n\n const nowMs = Date.now();\n\n const bjNow = new Date(nowMs + 8 * 3600 * 1000);\n\n const dateStr = bjNow.toISOString().substring(0, 10);\n\n const dayStart = new Date(dateStr + \"T00:00:00+08:00\").getTime();\n\n const body = {\n records: records.map((r) => ({\n fields: {\n \"记录日期\": dayStart,\n\n \"ETF名称\": r.name,\n\n \"ETF代码\": r.code,\n\n \"所属板块\": r.sector,\n\n \"收盘价\": Number(r.price.toFixed(3)),\n\n \"当日涨跌幅(%)\": Number(r.change.toFixed(2)),\n\n \"成交量(万手)\": Number((r.volume || 0).toFixed(2)),\n\n \"成交额(亿元)\": Number((r.amount || 0).toFixed(2)),\n\n \"MACD-DIF\": Number(r.dif.toFixed(4)),\n\n \"MACD-DEA\": Number(r.dea.toFixed(4)),\n\n \"MACD柱\": Number(r.macd.toFixed(4)),\n\n \"涨跌原因分析\": \"【\" + label + \"】\" + r.analysis,\n\n \"后续1-3天走势判断\": r.trend,\n\n \"判断依据\": \"综合评分\" + r.score + \"分，\" + r.action,\n\n \"数据来源\": \"腾讯/新浪API+val-town自动分析 \" + label,\n },\n })),\n };\n\n const batchSize = 100;\n\n let created = 0;\n\n for (let i = 0; i < body.records.length; i += batchSize) {\n const batch = { records: body.records.slice(i, i + batchSize) };\n\n const res = await fetch(\n \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt + \"/tables/\" +\n DAILY_TABLE_ID + \"/records/batch_create\",\n {\n method: \"POST\",\n\n headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n\n body: JSON.stringify(batch),\n },\n );\n\n const d = await res.json();\n\n if (d.code === 0) created += (d.data?.records || []).length;\n else console.error(\"写入飞书失败:\", d.msg);\n\n if (i + batchSize < body.records.length) {\n await new Promise((r) => setTimeout(r, 300));\n }\n }\n\n return created;\n}\n\n// 同步指数到指数表（覆盖式更新）\n\nasync function syncIndicesToFeishu(indices) {\n try {\n const token = await getFeishuToken();\n\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n\n const nowMs = Date.now();\n\n const listUrl = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt +\n \"/tables/\" + INDEX_TABLE_ID + \"/records?page_size=100\";\n\n const listRes = await fetch(listUrl, {\n headers: { \"Authorization\": \"Bearer \" + token },\n });\n\n const ld = await listRes.json();\n\n const existing = ld.data?.items || [];\n\n const existingMap = {};\n\n for (const r of existing) {\n const code = String(r.fields[\"指数代码\"] || \"\");\n\n if (code) existingMap[code] = r.record_id;\n }\n\n const toCreate = [];\n\n const toUpdate = [];\n\n for (const idx of indices) {\n const fields = {\n \"指数代码\": idx.code,\n\n \"指数名称\": idx.name,\n\n \"最新价\": Number(idx.price.toFixed(2)),\n\n \"涨跌幅\": Number(idx.change.toFixed(2)),\n\n \"更新时间\": nowMs,\n };\n\n if (existingMap[idx.code]) {\n toUpdate.push({ record_id: existingMap[idx.code], fields });\n } else toCreate.push({ fields });\n }\n\n if (toUpdate.length > 0) {\n await fetch(\n \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt + \"/tables/\" +\n INDEX_TABLE_ID + \"/records/batch_update\",\n {\n method: \"POST\",\n\n headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n\n body: JSON.stringify({ records: toUpdate }),\n },\n );\n }\n\n if (toCreate.length > 0) {\n await fetch(\n \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt + \"/tables/\" +\n INDEX_TABLE_ID + \"/records/batch_create\",\n {\n method: \"POST\",\n\n headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n\n body: JSON.stringify({ records: toCreate }),\n },\n );\n }\n\n console.log(\"指数同步完成:\", indices.length, \"条\");\n } catch (e) {\n console.error(\"指数同步失败:\", e.message);\n }\n}\n\n// 获取指数\n\nasync function getIndexRealTime() {\n try {\n const symbols = INDEX_LIST.map((i) => i.pre + i.code).join(\",\");\n\n const map = await fetchTencent(symbols);\n\n return INDEX_LIST.map((i) => ({\n code: i.code,\n name: i.name,\n ...(map[i.code] || { price: 0, change: 0, amount: 0 }),\n }));\n } catch (e) {\n return INDEX_LIST.map((i) => ({\n code: i.code,\n name: i.name,\n price: 0,\n change: 0,\n amount: 0,\n }));\n }\n}\n\nasync function getEtfRealTime(etfList) {\n try {\n const symbols = etfList.map((e) => etfPrefix(e.code) + e.code).join(\",\");\n\n const map = await fetchTencent(symbols);\n\n return etfList.map((e) => ({\n code: e.code,\n name: e.name,\n sector: e.sector,\n ...(map[e.code] || { price: 0, change: 0, volume: 0, amount: 0 }),\n }));\n } catch (e) {\n return etfList.map((e) => ({\n code: e.code,\n name: e.name,\n sector: e.sector,\n price: 0,\n change: 0,\n volume: 0,\n amount: 0,\n }));\n }\n}\n\n// ============ SQLite 存档（应用集中展示入口） ============\n\nasync function initSqlite() {\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS analysis_history (\n\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n date TEXT NOT NULL,\n\n period TEXT NOT NULL,\n\n label TEXT,\n\n created_at INTEGER NOT NULL,\n\n summary TEXT,\n\n records TEXT\n\n )`);\n\n // P2: 同时初始化告警表（若有旧版本未建）\n\n try {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS alert_log (\n\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n date TEXT NOT NULL,\n\n period TEXT,\n\n level TEXT DEFAULT 'error',\n\n title TEXT,\n\n content TEXT,\n\n created_at INTEGER NOT NULL\n\n )`);\n } catch (e) {}\n\n return true;\n } catch (e) {\n console.error(\"SQLite初始化失败:\", e.message);\n\n return false;\n }\n}\n\n// ============ P2: 旧记录清理机制 ============\n\n// 保留最近 retentionDays 天的分析记录，防止SQLite无限增长（免费版10MB上限）\n\n// 保留天数可通过环境变量 CLEAN_RETENTION_DAYS 配置，默认60天\n\nasync function cleanOldRecords() {\n try {\n const retentionDays = parseInt(\n Deno.env.get(\"CLEAN_RETENTION_DAYS\") || \"60\",\n 10,\n );\n\n if (isNaN(retentionDays) || retentionDays < 7) {\n console.log(\"[清理] 保留天数配置无效，使用默认60天\");\n }\n\n const keep = isNaN(retentionDays) || retentionDays < 7 ? 60 : retentionDays;\n\n await initSqlite();\n\n // 基于北京时间的日期字符串比较（date 存的是 YYYY-MM-DD）\n\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n\n const cutoff = new Date(bjNow.getTime() - keep * 24 * 3600 * 1000);\n\n const cutoffStr = cutoff.toISOString().substring(0, 10);\n\n // 删除 cutoff 之前的记录\n\n const del = await sqlite.execute(\n \"DELETE FROM analysis_history WHERE date < ?\",\n [cutoffStr],\n );\n\n // 同时清理告警表（保留30天告警）\n\n const cutoffAlert = new Date(bjNow.getTime() - 30 * 24 * 3600 * 1000);\n\n const cutoffAlertStr = cutoffAlert.toISOString().substring(0, 10);\n\n let delAlert = 0;\n\n try {\n const da = await sqlite.execute(\"DELETE FROM alert_log WHERE date < ?\", [\n cutoffAlertStr,\n ]);\n\n delAlert = da.rowsAffected || 0;\n } catch (e) {}\n\n // 删除深度分析用量记录（保留30天，供费用统计）\n\n let delDeep = 0;\n\n try {\n const dd = await sqlite.execute(\n \"DELETE FROM deep_analysis_usage WHERE date < ?\",\n [cutoffAlertStr],\n );\n\n delDeep = dd.rowsAffected || 0;\n } catch (e) {}\n\n const delCount = del.rowsAffected || 0;\n\n if (delCount > 0 || delAlert > 0 || delDeep > 0) {\n console.log(\n `[清理] 已删除分析记录${delCount}条、告警${delAlert}条、深度分析用量${delDeep}条（保留${keep}天）`,\n );\n } else {\n console.log(`[清理] 无需清理，保留${keep}天内的记录`);\n }\n\n return {\n deleted: delCount,\n alertDeleted: delAlert,\n deepDeleted: delDeep,\n keep,\n };\n } catch (e) {\n console.error(\"[清理] 异常:\", e.message);\n\n return { error: e.message };\n }\n}\n\n// 保存一次分析到SQLite（每条ETF一行，或整批JSON）\n\nasync function saveAnalysisToSqlite(dateStr, label, records) {\n try {\n await initSqlite();\n\n // 汇总摘要\n\n const upCount = records.filter((r) => r.change > 0).length;\n\n const downCount = records.filter((r) => r.change < 0).length;\n\n const avgScore = records.length\n ? Math.round(records.reduce((a, r) => a + r.score, 0) / records.length)\n : 0;\n\n const summary = JSON.stringify({\n label,\n count: records.length,\n upCount,\n downCount,\n avgScore,\n\n best: records.slice().sort((a, b) => b.score - a.score)[0]?.name || \"\",\n\n worst: records.slice().sort((a, b) => a.score - b.score)[0]?.name || \"\",\n });\n\n // 每条ETF一行，便于应用按日期+时段查询\n\n for (const r of records) {\n const etfJson = JSON.stringify({\n code: r.code,\n name: r.name,\n sector: r.sector,\n\n price: r.price,\n change: r.change,\n volume: r.volume,\n amount: r.amount,\n\n dif: r.dif,\n dea: r.dea,\n macd: r.macd,\n\n ma5: r.ma5,\n ma10: r.ma10,\n ma20: r.ma20,\n\n kdjK: r.kdjK,\n kdjD: r.kdjD,\n kdjJ: r.kdjJ,\n\n volRatio: r.volRatio,\n score: r.score,\n trend: r.trend,\n action: r.action,\n\n analysis: r.analysis,\n\n support: r.sr ? r.sr.support : null,\n resistance: r.sr ? r.sr.resistance : null,\n });\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\n console.log(\"SQLite存档成功:\", dateStr, label, records.length, \"条\");\n\n return records.length;\n } catch (e) {\n console.error(\"SQLite存档失败:\", e.message);\n\n return 0;\n }\n}\n\n// SQLite 自检（验证global组织级库可读写）\n\nasync function sqliteSelfTest() {\n try {\n await initSqlite();\n\n // 清理测试记录\n\n try {\n await sqlite.execute(\n \"DELETE FROM analysis_history WHERE label IN ('selftest','crosstest')\",\n );\n } catch (e) {}\n\n const r = await sqlite.execute(\n \"SELECT COUNT(*) as c FROM analysis_history\",\n );\n\n console.log(\"SQLite连接正常，存档记录数:\", r.rows?.[0]?.c ?? \"?\");\n\n return true;\n } catch (e) {\n console.error(\"SQLite自检失败:\", e.message);\n\n return false;\n }\n}\n\n// 主逻辑\n\nexport default async function handler() {\n const startTime = Date.now();\n\n console.log(\n \"=== ETF行情自动监控v2.2开始 ===\",\n new Date().toLocaleString(\"zh-CN\"),\n );\n\n const at = getAnalysisType();\n\n console.log(\"时段判断:\", at.type, at.reason || \"\", \"北京时间\", at.bjTime);\n\n // 每次运行都做一次 SQLite 自检（验证global库连接）\n\n try {\n await sqliteSelfTest();\n } catch (e) {\n console.error(\"自检异常:\", e.message);\n }\n\n // P2: 旧记录清理（幂等，保留最近N天，默认60天可配）\n\n try {\n await cleanOldRecords();\n } catch (e) {\n console.error(\"记录清理异常:\", e.message);\n }\n\n const etfList = await getEtfListFromFeishu();\n\n console.log(\"监控ETF数量:\", etfList.length);\n\n if (etfList.length === 0) {\n // P0-2: ETF列表为空 → 告警\n\n const bjD = new Date(Date.now() + 8 * 3600 * 1000).toISOString().substring(\n 0,\n 10,\n );\n\n await writeAlert(\n bjD,\n at.label || \"全天\",\n \"error\",\n \"ETF列表读取为空\",\n \"飞书基础信息库读取失败或全部ETF被停用，请检查飞书连接和FEISHU_APP_ID/SECRET/BASE_TOKEN配置\",\n );\n }\n\n // 同步指数（每次都做）\n\n try {\n const indices = await getIndexRealTime();\n\n await syncIndicesToFeishu(indices);\n } catch (e) {\n console.error(\"指数处理失败:\", e.message);\n\n // P0-2: 指数同步失败 → 告警\n\n const bjD2 = new Date(Date.now() + 8 * 3600 * 1000).toISOString().substring(\n 0,\n 10,\n );\n\n await writeAlert(\n bjD2,\n at.label || \"全天\",\n \"warning\",\n \"指数同步失败\",\n \"上证/深成/创业板/科创50指数获取或写入失败: \" + e.message,\n );\n }\n\n // 非指定时段：跳过ETF分析\n\n if (at.type === \"skip\") {\n console.log(\"非分析时段，跳过ETF处理\");\n\n console.log(\"=== 结束(耗时\" + (Date.now() - startTime) + \"ms) ===\");\n\n return;\n }\n\n // 指定时段：完整分析+写入（含SQLite存档）\n\n const bjNow = new Date(Date.now() + 8 * 3600 * 1000);\n\n const dateStr = bjNow.toISOString().substring(0, 10);\n\n let analysisFailed = false;\n\n try {\n const quotes = await getEtfRealTime(etfList);\n\n const newsList = await getNews();\n\n // P1: 隔夜外围数据（每次分析取一次，供各ETF联动研判）\n\n let overseas = [];\n\n try {\n overseas = await getOvernightOverseas();\n } catch (e) {\n console.error(\"外围数据获取失败:\", e.message);\n }\n\n const records = [];\n\n for (const q of quotes) {\n try {\n const [klines, minuteData] = await Promise.all([\n getKLine(q.code, 60),\n getMinuteData(q.code),\n ]);\n\n if (klines.length < 25) continue;\n\n const closes = klines.map((k) => k.close);\n\n const vols = klines.map((k) => k.volume);\n\n const ma5 = calcMA(closes, 5),\n ma10 = calcMA(closes, 10),\n ma20 = calcMA(closes, 20);\n\n const macd = calcMACD(closes);\n\n const kdj = calcKDJ(klines);\n\n const atr = calcATR(klines); // P1: ATR波动风险指标\n\n const vol5 = vols.slice(-6, -1).reduce((a, b) => a + b, 0) / 5;\n\n const volRatio = vol5 > 0 ? vols[vols.length - 1] / vol5 : 0;\n\n const activeFlow = { netHand: (q.outer || 0) - (q.inner || 0) };\n\n const sr = calcSupportResistance(klines, ma20, ma5);\n\n let fundFlow = null;\n\n try {\n fundFlow = await getFundFlow(q.code);\n } catch (e) {}\n\n const keywords = SECTOR_KEYWORDS[q.sector] || [];\n\n const sectorNews = keywords.length > 0\n ? newsList.filter((t) => keywords.some((kw) => t.includes(kw)))\n : [];\n\n const base = {\n ...q,\n ma5,\n ma10,\n ma20,\n\n dif: macd.dif,\n dea: macd.dea,\n macd: macd.macd,\n\n kdjK: kdj.k,\n kdjD: kdj.d,\n kdjJ: kdj.j,\n\n atr,\n volRatio,\n fundFlow,\n news: sectorNews,\n\n activeFlow,\n sr,\n minute: minuteData,\n overseas,\n };\n\n const analysis = generateAnalysis(base);\n\n records.push({ ...base, ...analysis });\n\n console.log(\n q.code,\n q.name,\n \"价格\" + q.price,\n \"涨跌\" + q.change + \"%\",\n \"评分\" + analysis.score,\n \"趋势\" + analysis.trend,\n );\n } catch (e) {\n console.error(q.code, \"处理失败:\", e.message);\n\n analysisFailed = true;\n }\n\n await new Promise((r) => setTimeout(r, 200));\n }\n\n if (records.length > 0) {\n // 写飞书日报表（保留）\n\n try {\n const created = await writeToFeishu(records, at.label);\n\n console.log(at.label + \"写入飞书:\", created, \"条\");\n\n if (created === 0) {\n analysisFailed = true;\n\n await writeAlert(\n dateStr,\n at.label,\n \"warning\",\n \"飞书写入0条\",\n at.label +\n \"时段分析完成但飞书日报表写入0条，请检查FEISHU_TABLE_ID是否有效\",\n );\n }\n } catch (e) {\n console.error(\"写飞书失败:\", e.message);\n\n analysisFailed = true;\n\n await writeAlert(\n dateStr,\n at.label,\n \"error\",\n \"飞书写入失败\",\n at.label + \"时段写入飞书日报表失败: \" + e.message,\n );\n }\n\n // 写SQLite存档（应用集中展示）\n\n try {\n const saved = await saveAnalysisToSqlite(dateStr, at.label, records);\n\n if (saved === 0) {\n analysisFailed = true;\n\n await writeAlert(\n dateStr,\n at.label,\n \"warning\",\n \"SQLite存档异常\",\n at.label + \"时段SQLite存档写入0条，应用端可能无法显示该时段分析\",\n );\n }\n } catch (e) {\n console.error(\"SQLite存档异常:\", e.message);\n\n analysisFailed = true;\n\n await writeAlert(\n dateStr,\n at.label,\n \"error\",\n \"SQLite存档失败\",\n at.label + \"时段存档写入异常: \" + e.message,\n );\n }\n } else {\n // P0-2: 所有ETF都失败 → 告警\n\n analysisFailed = true;\n\n await writeAlert(\n dateStr,\n at.label,\n \"error\",\n \"分析无有效结果\",\n at.label + \"时段所有ETF分析均失败或K线数据不足(不足25根)，请检查数据源\",\n );\n }\n } catch (e) {\n console.error(\"分析处理失败:\", e.message);\n\n analysisFailed = true;\n\n await writeAlert(\n dateStr,\n at.label,\n \"error\",\n \"分析流程异常\",\n at.label + \"时段分析整体失败: \" + e.message,\n );\n }\n\n console.log(\n \"=== 结束(耗时\" + (Date.now() - startTime) + \"ms)\" +\n (analysisFailed ? \" [有告警]\" : \"\") + \" ===\",\n );\n}",[138],"pulls","branches",1,"forks","envVars",{"_154":156,"_157":62},"connections",{"_154":62,"_155":62},"count","unfilledCount",6,"emptyCount",{"_43":137,"_32":138,"_30":139,"_131":-5,"_41":42,"_40":140,"_132":25,"_38":164,"_13":142,"_33":143,"_35":144,"_24":25,"_135":-5,"_161":165,"_27":166},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":160,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_161":162,"_27":163},["D",1787798222736],"children",[],[28],["D",1787794884517],[],[138],["D",1787622199218],["D",1789528852539],{"_99":98,"_106":101},{"_99":98,"_100":101,"_102":101,"_18":55,"_103":104,"_105":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_125":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":58,"_214":-5,"_215":-7,"_216":-7,"_217":62,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":89,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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"]

Diff · v46