[{"_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",{"_100":99,"_32":45,"_108":90,"_27":102,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":59,"_125":-5,"_126":-5,"_127":128},"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":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",32,"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","main.ts","latestPath","fileId","594a9562-a026-11f1-acc2-1607ee4eb77e","name","fileType","interval","content","import { sqlite } from \"jsr:@valtown/sqlite\";\n\n// ============================================================\n// ETF定时分析 CRON v2.1 - 短线升级版\n// 功能：动态ETF列表(飞书) + 4时段分析(9:25/12:55/14:30/15:00)\n// + MACD(10,20,7) + 分时/盘中资金流/支撑压力位\n// + 深度分析 + 指数同步到飞书\n// 部署文件：main.ts (val-town CRON, 每15分钟)\n// 更新日期：2026-08-26\n// ============================================================\n\nconst ETF_INFO_TABLE_ID = \"tbl5K6lJm9aAjKdo\";\nconst INDEX_TABLE_ID = \"tblsDzjKrYZGHcXD\";\nconst DAILY_TABLE_ID = Deno.env.get(\"FEISHU_TABLE_ID\");\n\nconst INDEX_LIST = [\n { code: \"000001\", name: \"上证指数\", pre: \"sh\" },\n { code: \"399001\", name: \"深证成指\", pre: \"sz\" },\n { code: \"399006\", name: \"创业板指\", pre: \"sz\" },\n { code: \"000688\", name: \"科创50\", pre: \"sh\" },\n];\n\nconst SECTOR_KEYWORDS = {\n \"科技\": [\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 \"医药\": [\"创新药\", \"医药\", \"生物医药\", \"CRO\", \"医疗\", \"药\"],\n \"金融\": [\"银行\", \"券商\", \"保险\", \"金融\"],\n \"宽基\": [\"沪深300\", \"上证50\", \"中证\", \"大盘\", \"A股\"],\n \"其他\": [\"电力\", \"公用事业\", \"能源\"],\n \"消费\": [\"消费\", \"白酒\", \"食品\", \"家电\"],\n \"港股\": [\"港股\", \"恒生\", \"中概\"],\n \"海外\": [\"美股\", \"纳斯达克\", \"标普\", \"海外\"],\n};\n\nfunction getAnalysisType() {\n const now = new Date();\n const bjHour = (now.getUTCHours() + 8) % 24;\n const bjMinute = now.getUTCMinutes();\n const bjTime = bjHour * 60 + bjMinute;\n const day = now.getUTCDay();\n if (day === 0 || day === 6) return { type: \"skip\", reason: \"周末不执行\" };\n const windows = [\n { target: 9 * 60 + 25, type: \"盘前分析\", label: \"盘前\" },\n { target: 12 * 60 + 55, type: \"午盘分析\", label: \"午盘\" },\n { target: 14 * 60 + 30, type: \"尾盘分析\", label: \"尾盘\" },\n { target: 15 * 60, type: \"收盘分析\", label: \"收盘\" },\n ];\n for (const w of windows) {\n if (Math.abs(bjTime - w.target) <= 10) {\n return { type: w.type, label: w.label, bjTime: bjTime };\n }\n }\n return { type: \"skip\", reason: \"非指定时段\", bjTime: bjTime };\n}\n\nfunction etfPrefix(code) {\n return code.startsWith(\"15\") ? \"sz\" : \"sh\";\n}\n\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 headers: { \"Content-Type\": \"application/json\" },\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 const d = await res.json();\n if (!d.tenant_access_token) throw new Error(\"飞书token获取失败\");\n return d.tenant_access_token;\n}\n\nasync function getEtfListFromFeishu() {\n try {\n const token = await getFeishuToken();\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n const url = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt +\n \"/tables/\" + ETF_INFO_TABLE_ID + \"/records?page_size=100\";\n const res = await fetch(url, {\n headers: { \"Authorization\": \"Bearer \" + token },\n });\n const d = await res.json();\n if (d.code !== 0) return [];\n const items = d.data.items || [];\n const list = [];\n for (const r of items) {\n const f = r.fields;\n const enabled = Array.isArray(f[\"启用\"])\n ? (f[\"启用\"][0]?.text || \"\")\n : String(f[\"启用\"] || \"是\");\n if (enabled === \"否\") continue;\n const code = String(f[\"ETF代码\"] || \"\");\n if (!code) continue;\n const name = String(f[\"ETF名称\"] || code);\n const sector = Array.isArray(f[\"所属板块\"])\n ? (f[\"所属板块\"][0]?.text || \"其他\")\n : (String(f[\"所属板块\"] || \"其他\"));\n list.push({ code, name, sector });\n }\n return list;\n } catch (e) {\n console.error(\"读取ETF列表失败:\", e.message);\n return [];\n }\n}\n\nasync function fetchTencent(symbols) {\n const url = \"https://qt.gtimg.cn/q=\" + symbols;\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\" },\n });\n const buf = await res.arrayBuffer();\n let text;\n try {\n text = new TextDecoder(\"gbk\").decode(buf);\n } catch (e) {\n text = new TextDecoder(\"utf-8\").decode(buf);\n }\n const map = {};\n for (const line of text.split(\";\")) {\n const m = line.match(/v_(?:sh|sz)(\\d+)=\"([^\"]+)\"/);\n if (!m) continue;\n const f = m[2].split(\"~\");\n map[m[1]] = {\n name: f[1] || \"\",\n price: parseFloat(f[3]) || 0,\n change: parseFloat(f[32]) || 0,\n open: parseFloat(f[5]) || 0,\n high: parseFloat(f[33]) || 0,\n low: parseFloat(f[34]) || 0,\n volume: (parseFloat(f[36]) || 0) / 10000,\n amount: (parseFloat(f[37]) || 0) / 10000,\n outer: parseFloat(f[7]) || 0,\n inner: parseFloat(f[8]) || 0,\n };\n }\n return map;\n}\n\nasync function getKLine(code, n) {\n const prefix = etfPrefix(code);\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=\" +\n prefix + code + \",day,,,\" + n + \",qfq\";\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" },\n });\n const d = await res.json();\n const obj = d.data?.[prefix + code];\n const day = obj?.day || obj?.qfqday || [];\n return day.map((k) => ({\n date: k[0],\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\nasync function getMinuteData(code) {\n try {\n const prefix = etfPrefix(code);\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=\" +\n prefix + code;\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" },\n });\n const d = await res.json();\n const obj = d.data?.[prefix + code];\n const dataArr = obj?.data?.data || [];\n const points = [];\n for (const line of dataArr) {\n const p = line.split(\" \");\n if (p.length < 4) continue;\n points.push({\n p: parseFloat(p[1]) || 0,\n v: parseFloat(p[2]) || 0,\n a: parseFloat(p[3]) || 0,\n });\n }\n if (points.length === 0) return null;\n let cumV = 0, cumA = 0;\n for (const pt of points) {\n cumV += pt.v;\n cumA += pt.a;\n }\n const avgPrice = cumV > 0\n ? cumA / (cumV * 100)\n : points[points.length - 1].p;\n return {\n avgPrice: Number(avgPrice.toFixed(4)),\n latest: points[points.length - 1].p,\n pointCount: points.length,\n };\n } catch (e) {\n return null;\n }\n}\n\nfunction calcEMA(values, period) {\n if (values.length === 0) return [];\n const k = 2 / (period + 1);\n let ema = values[0];\n const result = [ema];\n for (let i = 1; i < values.length; i++) {\n ema = values[i] * k + ema * (1 - k);\n result.push(ema);\n }\n return result;\n}\n\nfunction calcMACD(closes) {\n const ema10 = calcEMA(closes, 10);\n const ema20 = calcEMA(closes, 20);\n const dif = closes.map((_, i) => ema10[i] - ema20[i]);\n const dea = calcEMA(dif, 7);\n const macd = dif.map((d, i) => 2 * (d - dea[i]));\n const n = closes.length - 1;\n return { dif: dif[n], dea: dea[n], macd: macd[n] };\n}\n\nfunction calcMA(closes, period) {\n if (closes.length < period) return null;\n return closes.slice(-period).reduce((a, b) => a + b, 0) / period;\n}\n\nfunction calcKDJ(klines) {\n const n = 9;\n let k = 50, d = 50, lastK = 50, lastD = 50;\n for (let i = 0; i < klines.length; i++) {\n const start = Math.max(0, i - n + 1);\n let highest = -Infinity, lowest = Infinity;\n for (let j = start; j <= i; j++) {\n highest = Math.max(highest, klines[j].high);\n lowest = Math.min(lowest, klines[j].low);\n }\n const rsv = highest === lowest\n ? 50\n : ((klines[i].close - lowest) / (highest - lowest)) * 100;\n k = (2 / 3) * k + (1 / 3) * rsv;\n d = (2 / 3) * d + (1 / 3) * k;\n lastK = k;\n lastD = d;\n }\n return { k: lastK, d: lastD, j: 3 * lastK - 2 * lastD };\n}\n\nfunction calcSupportResistance(klines, ma20, ma5) {\n const recent = klines.slice(-20);\n let hi20 = -Infinity, lo20 = Infinity;\n for (const k of recent) {\n if (k.high > hi20) hi20 = k.high;\n if (k.low < lo20) lo20 = k.low;\n }\n let std = 0;\n if (klines.length >= 20) {\n const closes = klines.slice(-20).map((k) => k.close);\n const mean = closes.reduce((a, b) => a + b, 0) / 20;\n std = Math.sqrt(\n closes.reduce((a, b) => a + (b - mean) * (b - mean), 0) / 20,\n );\n }\n const bollLower = ma20 ? ma20 - 2 * std : 0;\n const bollUpper = ma20 ? ma20 + 2 * std : 0;\n const support = ma20 && bollLower\n ? Math.min(ma20, bollLower)\n : (ma20 || bollLower || lo20);\n const resistance = ma5 && bollUpper\n ? Math.max(ma5, bollUpper)\n : (ma5 || bollUpper || hi20);\n return {\n support: Number(support.toFixed(4)),\n resistance: Number(resistance.toFixed(4)),\n };\n}\n\nasync function getFundFlow(code) {\n try {\n const prefix = etfPrefix(code);\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 const res = await fetch(url, {\n headers: {\n \"Referer\": \"https://finance.sina.com.cn/\",\n \"User-Agent\": \"Mozilla/5.0\",\n },\n });\n const text = await res.text();\n const clean = text.replace(/^[^(]*\$/, \"\").replace(/\$\\s*;?\\s*$/, \"\");\n let data;\n try {\n data = JSON.parse(clean);\n } catch (e) {\n data = JSON.parse(text);\n }\n if (!Array.isArray(data) || data.length === 0) return null;\n const latest = data[0];\n return {\n date: String(latest.opendate || \"\"),\n mainNet: Math.round(Number(latest.r0_net) || 0),\n mainRatio: Number(latest.r0_ratio) || 0,\n };\n } catch (e) {\n return null;\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 const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n return (d.result?.data || []).map((n) => String(n.title || \"\"));\n } catch (e) {\n return [];\n }\n}\n\nfunction generateAnalysis(e) {\n const parts = [];\n const price = e.price, ma5 = e.ma5, ma10 = e.ma10, ma20 = e.ma20;\n const dif = e.dif, dea = e.dea, macd = e.macd;\n const k = e.kdjK, d = e.kdjD;\n const volRatio = e.volRatio;\n\n let maTxt;\n if (price >= ma5 && ma5 >= ma10 && ma10 >= ma20) {\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 parts.push(\n \"【均线】MA5=\" + ma5.toFixed(3) + \" MA10=\" + ma10.toFixed(3) + \" MA20=\" +\n ma20.toFixed(3) + \"，\" + maTxt,\n );\n\n let macdTxt;\n if (dif > dea && dif > 0) macdTxt = \"MACD多头（零轴上方）\";\n else if (dif > dea) macdTxt = \"MACD低位金叉\";\n else if (dif < dea && dif > 0) macdTxt = \"MACD高位死叉\";\n else macdTxt = \"MACD空头（零轴下方）\";\n parts.push(\n \"【MACD】DIF=\" + dif.toFixed(4) + \" DEA=\" + dea.toFixed(4) + \" 柱=\" +\n macd.toFixed(4) + \"，\" + macdTxt,\n );\n\n let kdjTxt;\n if (k > 80) kdjTxt = \"KDJ超买\";\n else if (k < 20) kdjTxt = \"KDJ超卖\";\n else if (k > d) kdjTxt = \"KDJ金叉\";\n else kdjTxt = \"KDJ死叉\";\n parts.push(\"【KDJ】K=\" + k.toFixed(1) + \" D=\" + d.toFixed(1) + \"，\" + kdjTxt);\n\n let volTxt;\n if (volRatio > 1.5) volTxt = \"放量\";\n else if (volRatio > 1.2) volTxt = \"温和放量\";\n else if (volRatio < 0.7) volTxt = \"明显缩量\";\n else if (volRatio < 0.9) volTxt = \"缩量\";\n else volTxt = \"量能平稳\";\n parts.push(\"【量能】量比\" + volRatio.toFixed(2) + \"，\" + volTxt);\n\n if (e.activeFlow) {\n const netHand = e.activeFlow.netHand;\n const flowTxt = netHand >= 0\n ? \"主动买盘占优（+\" + (netHand / 10000).toFixed(2) + \"万手）\"\n : \"主动卖盘占优（-\" + (Math.abs(netHand) / 10000).toFixed(2) + \"万手）\";\n parts.push(\"【盘中资金】\" + flowTxt + \"（实时外盘-内盘）\");\n }\n\n if (e.minute) {\n const vsAvg = price >= e.minute.avgPrice\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 const mainTxt = ff.mainNet >= 0\n ? \"主力净流入\" + (ff.mainNet / 100000000).toFixed(2) + \"亿\"\n : \"主力净流出\" + (Math.abs(ff.mainNet) / 100000000).toFixed(2) + \"亿\";\n parts.push(\"【昨日主力】\" + mainTxt + \"（T-1，\" + ff.date + \"）\");\n }\n if (e.news && e.news.length > 0) {\n parts.push(\"【消息】\" + e.news.slice(0, 2).join(\"；\"));\n }\n\n let score = 50;\n if (price >= ma5) score += 5;\n else score -= 5;\n if (price >= ma10) score += 4;\n else score -= 4;\n if (price >= ma20) score += 4;\n else score -= 4;\n if (ma5 >= ma10) score += 3;\n else score -= 3;\n if (ma10 >= ma20) score += 3;\n else score -= 3;\n if (dif >= dea) score += 6;\n else score -= 6;\n if (dif >= 0) score += 4;\n else score -= 4;\n if (k >= d) score += 3;\n else score -= 3;\n if (e.change > 0) score += Math.min(5, e.change * 2);\n else score -= Math.min(5, Math.abs(e.change) * 2);\n if (e.change > 0 && volRatio >= 1.1) score += 3;\n if (e.change < 0 && volRatio >= 1.3) score -= 4;\n if (e.change < 0 && volRatio <= 0.8) score += 2;\n if (e.activeFlow) {\n if (e.activeFlow.netHand > 0) score += 3;\n if (e.activeFlow.netHand < 0 && Math.abs(e.activeFlow.netHand) > 50000) {\n score -= 3;\n }\n }\n if (e.minute) {\n if (price >= e.minute.avgPrice) score += 2;\n else score -= 2;\n }\n if (e.fundFlow) {\n if (e.fundFlow.mainNet > 0) score += 3;\n if (e.fundFlow.mainNet < -1e8) score -= 3;\n }\n score = Math.max(5, Math.min(95, score));\n\n let trend;\n if (score >= 70) trend = \"偏多\";\n else if (score >= 60) trend = \"震荡偏多\";\n else if (score >= 45) trend = \"震荡\";\n else if (score >= 35) trend = \"震荡偏空\";\n else trend = \"偏空\";\n\n let action;\n if (score >= 70) action = \"加仓/持有\";\n else if (score >= 60) action = \"持有偏加\";\n else if (score >= 50) action = \"持有观望\";\n else if (score >= 40) action = \"减仓/观望\";\n else action = \"回避\";\n\n const support = e.sr\n ? e.sr.support.toFixed(3)\n : (ma20 ? ma20.toFixed(3) : \"-\");\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\nasync function writeToFeishu(records, label) {\n const token = await getFeishuToken();\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n const nowMs = Date.now();\n const bjNow = new Date(nowMs + 8 * 3600 * 1000);\n const dateStr = bjNow.toISOString().substring(0, 10);\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 \"ETF名称\": r.name,\n \"ETF代码\": r.code,\n \"所属板块\": r.sector,\n \"收盘价\": Number(r.price.toFixed(3)),\n \"当日涨跌幅(%)\": Number(r.change.toFixed(2)),\n \"成交量(万手)\": Number((r.volume || 0).toFixed(2)),\n \"成交额(亿元)\": Number((r.amount || 0).toFixed(2)),\n \"MACD-DIF\": Number(r.dif.toFixed(4)),\n \"MACD-DEA\": Number(r.dea.toFixed(4)),\n \"MACD柱\": Number(r.macd.toFixed(4)),\n \"涨跌原因分析\": \"【\" + label + \"】\" + r.analysis,\n \"后续1-3天走势判断\": r.trend,\n \"判断依据\": \"综合评分\" + r.score + \"分，\" + r.action,\n \"数据来源\": \"腾讯/新浪API+val-town自动分析 \" + label,\n },\n })),\n };\n\n const batchSize = 100;\n let created = 0;\n for (let i = 0; i < body.records.length; i += batchSize) {\n const batch = { records: body.records.slice(i, i + batchSize) };\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 headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(batch),\n },\n );\n const d = await res.json();\n if (d.code === 0) created += (d.data?.records || []).length;\n else console.error(\"写入飞书失败:\", d.msg);\n if (i + batchSize < body.records.length) {\n await new Promise((r) => setTimeout(r, 300));\n }\n }\n return created;\n}\n\nasync function syncIndicesToFeishu(indices) {\n try {\n const token = await getFeishuToken();\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n const nowMs = Date.now();\n const listUrl = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt +\n \"/tables/\" + INDEX_TABLE_ID + \"/records?page_size=100\";\n const listRes = await fetch(listUrl, {\n headers: { \"Authorization\": \"Bearer \" + token },\n });\n const ld = await listRes.json();\n const existing = ld.data?.items || [];\n const existingMap = {};\n for (const r of existing) {\n const code = String(r.fields[\"指数代码\"] || \"\");\n if (code) existingMap[code] = r.record_id;\n }\n const toCreate = [];\n const toUpdate = [];\n for (const idx of indices) {\n const fields = {\n \"指数代码\": idx.code,\n \"指数名称\": idx.name,\n \"最新价\": Number(idx.price.toFixed(2)),\n \"涨跌幅\": Number(idx.change.toFixed(2)),\n \"更新时间\": nowMs,\n };\n if (existingMap[idx.code]) {\n toUpdate.push({ record_id: existingMap[idx.code], fields });\n } else toCreate.push({ fields });\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 headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ records: toUpdate }),\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 headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ records: toCreate }),\n },\n );\n }\n console.log(\"指数同步完成:\", indices.length, \"条\");\n } catch (e) {\n console.error(\"指数同步失败:\", e.message);\n }\n}\n\nasync function getIndexRealTime() {\n try {\n const symbols = INDEX_LIST.map((i) => i.pre + i.code).join(\",\");\n const map = await fetchTencent(symbols);\n return INDEX_LIST.map((i) => ({\n code: i.code,\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 const map = await fetchTencent(symbols);\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\nexport default async function handler() {\n const startTime = Date.now();\n console.log(\n \"=== ETF行情自动监控v2.1开始 ===\",\n new Date().toLocaleString(\"zh-CN\"),\n );\n\n const at = getAnalysisType();\n console.log(\"时段判断:\", at.type, at.reason || \"\", \"北京时间\", at.bjTime);\n\n const etfList = await getEtfListFromFeishu();\n console.log(\"监控ETF数量:\", etfList.length);\n\n try {\n const indices = await getIndexRealTime();\n await syncIndicesToFeishu(indices);\n } catch (e) {\n console.error(\"指数处理失败:\", e.message);\n }\n\n if (at.type === \"skip\") {\n console.log(\"非分析时段，跳过ETF处理\");\n console.log(\"=== 结束(耗时\" + (Date.now() - startTime) + \"ms) ===\");\n return;\n }\n\n try {\n const quotes = await getEtfRealTime(etfList);\n const newsList = await getNews();\n const records = [];\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 if (klines.length < 25) continue;\n const closes = klines.map((k) => k.close);\n const vols = klines.map((k) => k.volume);\n const ma5 = calcMA(closes, 5),\n ma10 = calcMA(closes, 10),\n ma20 = calcMA(closes, 20);\n const macd = calcMACD(closes);\n const kdj = calcKDJ(klines);\n const vol5 = vols.slice(-6, -1).reduce((a, b) => a + b, 0) / 5;\n const volRatio = vol5 > 0 ? vols[vols.length - 1] / vol5 : 0;\n const activeFlow = { netHand: (q.outer || 0) - (q.inner || 0) };\n const sr = calcSupportResistance(klines, ma20, ma5);\n let fundFlow = null;\n try {\n fundFlow = await getFundFlow(q.code);\n } catch (e) {}\n const keywords = SECTOR_KEYWORDS[q.sector] || [];\n const sectorNews = keywords.length > 0\n ? newsList.filter((t) => keywords.some((kw) => t.includes(kw)))\n : [];\n const base = {\n ...q,\n ma5,\n ma10,\n ma20,\n dif: macd.dif,\n dea: macd.dea,\n macd: macd.macd,\n kdjK: kdj.k,\n kdjD: kdj.d,\n kdjJ: kdj.j,\n volRatio,\n fundFlow,\n news: sectorNews,\n activeFlow,\n sr,\n minute: minuteData,\n };\n const analysis = generateAnalysis(base);\n records.push({ ...base, ...analysis });\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 await new Promise((r) => setTimeout(r, 200));\n }\n\n if (records.length > 0) {\n const created = await writeToFeishu(records, at.label);\n console.log(at.label + \"写入飞书:\", created, \"条\");\n }\n } catch (e) {\n console.error(\"分析处理失败:\", e.message);\n }\n\n console.log(\"=== 结束(耗时\" + (Date.now() - startTime) + \"ms) ===\");\n}","import { sqlite } from \"https://esm.town/v/std/sqlite?v=4\";\n\n// ============================================================\n// ETF定时分析 CRON v2.1 - 短线升级版\n// 功能：动态ETF列表(飞书) + 4时段分析(9:25/12:55/14:30/15:00)\n// + MACD(10,20,7) + 分时/盘中资金流/支撑压力位\n// + 深度分析 + 指数同步到飞书\n// 部署文件：main.ts (val-town CRON, 每15分钟)\n// 更新日期：2026-08-26\n// ============================================================\n\nconst ETF_INFO_TABLE_ID = \"tbl5K6lJm9aAjKdo\";\nconst INDEX_TABLE_ID = \"tblsDzjKrYZGHcXD\";\nconst DAILY_TABLE_ID = Deno.env.get(\"FEISHU_TABLE_ID\");\n\nconst INDEX_LIST = [\n { code: \"000001\", name: \"上证指数\", pre: \"sh\" },\n { code: \"399001\", name: \"深证成指\", pre: \"sz\" },\n { code: \"399006\", name: \"创业板指\", pre: \"sz\" },\n { code: \"000688\", name: \"科创50\", pre: \"sh\" },\n];\n\nconst SECTOR_KEYWORDS = {\n \"科技\": [\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 \"医药\": [\"创新药\", \"医药\", \"生物医药\", \"CRO\", \"医疗\", \"药\"],\n \"金融\": [\"银行\", \"券商\", \"保险\", \"金融\"],\n \"宽基\": [\"沪深300\", \"上证50\", \"中证\", \"大盘\", \"A股\"],\n \"其他\": [\"电力\", \"公用事业\", \"能源\"],\n \"消费\": [\"消费\", \"白酒\", \"食品\", \"家电\"],\n \"港股\": [\"港股\", \"恒生\", \"中概\"],\n \"海外\": [\"美股\", \"纳斯达克\", \"标普\", \"海外\"],\n};\n\nfunction getAnalysisType() {\n const now = new Date();\n const bjHour = (now.getUTCHours() + 8) % 24;\n const bjMinute = now.getUTCMinutes();\n const bjTime = bjHour * 60 + bjMinute;\n const day = now.getUTCDay();\n if (day === 0 || day === 6) return { type: \"skip\", reason: \"周末不执行\" };\n const windows = [\n { target: 9 * 60 + 25, type: \"盘前分析\", label: \"盘前\" },\n { target: 12 * 60 + 55, type: \"午盘分析\", label: \"午盘\" },\n { target: 14 * 60 + 30, type: \"尾盘分析\", label: \"尾盘\" },\n { target: 15 * 60, type: \"收盘分析\", label: \"收盘\" },\n ];\n for (const w of windows) {\n if (Math.abs(bjTime - w.target) <= 10) {\n return { type: w.type, label: w.label, bjTime: bjTime };\n }\n }\n return { type: \"skip\", reason: \"非指定时段\", bjTime: bjTime };\n}\n\nfunction etfPrefix(code) {\n return code.startsWith(\"15\") ? \"sz\" : \"sh\";\n}\n\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 headers: { \"Content-Type\": \"application/json\" },\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 const d = await res.json();\n if (!d.tenant_access_token) throw new Error(\"飞书token获取失败\");\n return d.tenant_access_token;\n}\n\nasync function getEtfListFromFeishu() {\n try {\n const token = await getFeishuToken();\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n const url = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt +\n \"/tables/\" + ETF_INFO_TABLE_ID + \"/records?page_size=100\";\n const res = await fetch(url, {\n headers: { \"Authorization\": \"Bearer \" + token },\n });\n const d = await res.json();\n if (d.code !== 0) return [];\n const items = d.data.items || [];\n const list = [];\n for (const r of items) {\n const f = r.fields;\n const enabled = Array.isArray(f[\"启用\"])\n ? (f[\"启用\"][0]?.text || \"\")\n : String(f[\"启用\"] || \"是\");\n if (enabled === \"否\") continue;\n const code = String(f[\"ETF代码\"] || \"\");\n if (!code) continue;\n const name = String(f[\"ETF名称\"] || code);\n const sector = Array.isArray(f[\"所属板块\"])\n ? (f[\"所属板块\"][0]?.text || \"其他\")\n : (String(f[\"所属板块\"] || \"其他\"));\n list.push({ code, name, sector });\n }\n return list;\n } catch (e) {\n console.error(\"读取ETF列表失败:\", e.message);\n return [];\n }\n}\n\nasync function fetchTencent(symbols) {\n const url = \"https://qt.gtimg.cn/q=\" + symbols;\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\" },\n });\n const buf = await res.arrayBuffer();\n let text;\n try {\n text = new TextDecoder(\"gbk\").decode(buf);\n } catch (e) {\n text = new TextDecoder(\"utf-8\").decode(buf);\n }\n const map = {};\n for (const line of text.split(\";\")) {\n const m = line.match(/v_(?:sh|sz)(\\d+)=\"([^\"]+)\"/);\n if (!m) continue;\n const f = m[2].split(\"~\");\n map[m[1]] = {\n name: f[1] || \"\",\n price: parseFloat(f[3]) || 0,\n change: parseFloat(f[32]) || 0,\n open: parseFloat(f[5]) || 0,\n high: parseFloat(f[33]) || 0,\n low: parseFloat(f[34]) || 0,\n volume: (parseFloat(f[36]) || 0) / 10000,\n amount: (parseFloat(f[37]) || 0) / 10000,\n outer: parseFloat(f[7]) || 0,\n inner: parseFloat(f[8]) || 0,\n };\n }\n return map;\n}\n\nasync function getKLine(code, n) {\n const prefix = etfPrefix(code);\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=\" +\n prefix + code + \",day,,,\" + n + \",qfq\";\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" },\n });\n const d = await res.json();\n const obj = d.data?.[prefix + code];\n const day = obj?.day || obj?.qfqday || [];\n return day.map((k) => ({\n date: k[0],\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\nasync function getMinuteData(code) {\n try {\n const prefix = etfPrefix(code);\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=\" +\n prefix + code;\n const res = await fetch(url, {\n headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" },\n });\n const d = await res.json();\n const obj = d.data?.[prefix + code];\n const dataArr = obj?.data?.data || [];\n const points = [];\n for (const line of dataArr) {\n const p = line.split(\" \");\n if (p.length < 4) continue;\n points.push({\n p: parseFloat(p[1]) || 0,\n v: parseFloat(p[2]) || 0,\n a: parseFloat(p[3]) || 0,\n });\n }\n if (points.length === 0) return null;\n let cumV = 0, cumA = 0;\n for (const pt of points) {\n cumV += pt.v;\n cumA += pt.a;\n }\n const avgPrice = cumV > 0\n ? cumA / (cumV * 100)\n : points[points.length - 1].p;\n return {\n avgPrice: Number(avgPrice.toFixed(4)),\n latest: points[points.length - 1].p,\n pointCount: points.length,\n };\n } catch (e) {\n return null;\n }\n}\n\nfunction calcEMA(values, period) {\n if (values.length === 0) return [];\n const k = 2 / (period + 1);\n let ema = values[0];\n const result = [ema];\n for (let i = 1; i < values.length; i++) {\n ema = values[i] * k + ema * (1 - k);\n result.push(ema);\n }\n return result;\n}\n\nfunction calcMACD(closes) {\n const ema10 = calcEMA(closes, 10);\n const ema20 = calcEMA(closes, 20);\n const dif = closes.map((_, i) => ema10[i] - ema20[i]);\n const dea = calcEMA(dif, 7);\n const macd = dif.map((d, i) => 2 * (d - dea[i]));\n const n = closes.length - 1;\n return { dif: dif[n], dea: dea[n], macd: macd[n] };\n}\n\nfunction calcMA(closes, period) {\n if (closes.length < period) return null;\n return closes.slice(-period).reduce((a, b) => a + b, 0) / period;\n}\n\nfunction calcKDJ(klines) {\n const n = 9;\n let k = 50, d = 50, lastK = 50, lastD = 50;\n for (let i = 0; i < klines.length; i++) {\n const start = Math.max(0, i - n + 1);\n let highest = -Infinity, lowest = Infinity;\n for (let j = start; j <= i; j++) {\n highest = Math.max(highest, klines[j].high);\n lowest = Math.min(lowest, klines[j].low);\n }\n const rsv = highest === lowest\n ? 50\n : ((klines[i].close - lowest) / (highest - lowest)) * 100;\n k = (2 / 3) * k + (1 / 3) * rsv;\n d = (2 / 3) * d + (1 / 3) * k;\n lastK = k;\n lastD = d;\n }\n return { k: lastK, d: lastD, j: 3 * lastK - 2 * lastD };\n}\n\nfunction calcSupportResistance(klines, ma20, ma5) {\n const recent = klines.slice(-20);\n let hi20 = -Infinity, lo20 = Infinity;\n for (const k of recent) {\n if (k.high > hi20) hi20 = k.high;\n if (k.low < lo20) lo20 = k.low;\n }\n let std = 0;\n if (klines.length >= 20) {\n const closes = klines.slice(-20).map((k) => k.close);\n const mean = closes.reduce((a, b) => a + b, 0) / 20;\n std = Math.sqrt(\n closes.reduce((a, b) => a + (b - mean) * (b - mean), 0) / 20,\n );\n }\n const bollLower = ma20 ? ma20 - 2 * std : 0;\n const bollUpper = ma20 ? ma20 + 2 * std : 0;\n const support = ma20 && bollLower\n ? Math.min(ma20, bollLower)\n : (ma20 || bollLower || lo20);\n const resistance = ma5 && bollUpper\n ? Math.max(ma5, bollUpper)\n : (ma5 || bollUpper || hi20);\n return {\n support: Number(support.toFixed(4)),\n resistance: Number(resistance.toFixed(4)),\n };\n}\n\nasync function getFundFlow(code) {\n try {\n const prefix = etfPrefix(code);\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 const res = await fetch(url, {\n headers: {\n \"Referer\": \"https://finance.sina.com.cn/\",\n \"User-Agent\": \"Mozilla/5.0\",\n },\n });\n const text = await res.text();\n const clean = text.replace(/^[^(]*\$/, \"\").replace(/\$\\s*;?\\s*$/, \"\");\n let data;\n try {\n data = JSON.parse(clean);\n } catch (e) {\n data = JSON.parse(text);\n }\n if (!Array.isArray(data) || data.length === 0) return null;\n const latest = data[0];\n return {\n date: String(latest.opendate || \"\"),\n mainNet: Math.round(Number(latest.r0_net) || 0),\n mainRatio: Number(latest.r0_ratio) || 0,\n };\n } catch (e) {\n return null;\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 const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n return (d.result?.data || []).map((n) => String(n.title || \"\"));\n } catch (e) {\n return [];\n }\n}\n\nfunction generateAnalysis(e) {\n const parts = [];\n const price = e.price, ma5 = e.ma5, ma10 = e.ma10, ma20 = e.ma20;\n const dif = e.dif, dea = e.dea, macd = e.macd;\n const k = e.kdjK, d = e.kdjD;\n const volRatio = e.volRatio;\n\n let maTxt;\n if (price >= ma5 && ma5 >= ma10 && ma10 >= ma20) {\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 parts.push(\n \"【均线】MA5=\" + ma5.toFixed(3) + \" MA10=\" + ma10.toFixed(3) + \" MA20=\" +\n ma20.toFixed(3) + \"，\" + maTxt,\n );\n\n let macdTxt;\n if (dif > dea && dif > 0) macdTxt = \"MACD多头（零轴上方）\";\n else if (dif > dea) macdTxt = \"MACD低位金叉\";\n else if (dif < dea && dif > 0) macdTxt = \"MACD高位死叉\";\n else macdTxt = \"MACD空头（零轴下方）\";\n parts.push(\n \"【MACD】DIF=\" + dif.toFixed(4) + \" DEA=\" + dea.toFixed(4) + \" 柱=\" +\n macd.toFixed(4) + \"，\" + macdTxt,\n );\n\n let kdjTxt;\n if (k > 80) kdjTxt = \"KDJ超买\";\n else if (k < 20) kdjTxt = \"KDJ超卖\";\n else if (k > d) kdjTxt = \"KDJ金叉\";\n else kdjTxt = \"KDJ死叉\";\n parts.push(\"【KDJ】K=\" + k.toFixed(1) + \" D=\" + d.toFixed(1) + \"，\" + kdjTxt);\n\n let volTxt;\n if (volRatio > 1.5) volTxt = \"放量\";\n else if (volRatio > 1.2) volTxt = \"温和放量\";\n else if (volRatio < 0.7) volTxt = \"明显缩量\";\n else if (volRatio < 0.9) volTxt = \"缩量\";\n else volTxt = \"量能平稳\";\n parts.push(\"【量能】量比\" + volRatio.toFixed(2) + \"，\" + volTxt);\n\n if (e.activeFlow) {\n const netHand = e.activeFlow.netHand;\n const flowTxt = netHand >= 0\n ? \"主动买盘占优（+\" + (netHand / 10000).toFixed(2) + \"万手）\"\n : \"主动卖盘占优（-\" + (Math.abs(netHand) / 10000).toFixed(2) + \"万手）\";\n parts.push(\"【盘中资金】\" + flowTxt + \"（实时外盘-内盘）\");\n }\n\n if (e.minute) {\n const vsAvg = price >= e.minute.avgPrice\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 const mainTxt = ff.mainNet >= 0\n ? \"主力净流入\" + (ff.mainNet / 100000000).toFixed(2) + \"亿\"\n : \"主力净流出\" + (Math.abs(ff.mainNet) / 100000000).toFixed(2) + \"亿\";\n parts.push(\"【昨日主力】\" + mainTxt + \"（T-1，\" + ff.date + \"）\");\n }\n if (e.news && e.news.length > 0) {\n parts.push(\"【消息】\" + e.news.slice(0, 2).join(\"；\"));\n }\n\n let score = 50;\n if (price >= ma5) score += 5;\n else score -= 5;\n if (price >= ma10) score += 4;\n else score -= 4;\n if (price >= ma20) score += 4;\n else score -= 4;\n if (ma5 >= ma10) score += 3;\n else score -= 3;\n if (ma10 >= ma20) score += 3;\n else score -= 3;\n if (dif >= dea) score += 6;\n else score -= 6;\n if (dif >= 0) score += 4;\n else score -= 4;\n if (k >= d) score += 3;\n else score -= 3;\n if (e.change > 0) score += Math.min(5, e.change * 2);\n else score -= Math.min(5, Math.abs(e.change) * 2);\n if (e.change > 0 && volRatio >= 1.1) score += 3;\n if (e.change < 0 && volRatio >= 1.3) score -= 4;\n if (e.change < 0 && volRatio <= 0.8) score += 2;\n if (e.activeFlow) {\n if (e.activeFlow.netHand > 0) score += 3;\n if (e.activeFlow.netHand < 0 && Math.abs(e.activeFlow.netHand) > 50000) {\n score -= 3;\n }\n }\n if (e.minute) {\n if (price >= e.minute.avgPrice) score += 2;\n else score -= 2;\n }\n if (e.fundFlow) {\n if (e.fundFlow.mainNet > 0) score += 3;\n if (e.fundFlow.mainNet < -1e8) score -= 3;\n }\n score = Math.max(5, Math.min(95, score));\n\n let trend;\n if (score >= 70) trend = \"偏多\";\n else if (score >= 60) trend = \"震荡偏多\";\n else if (score >= 45) trend = \"震荡\";\n else if (score >= 35) trend = \"震荡偏空\";\n else trend = \"偏空\";\n\n let action;\n if (score >= 70) action = \"加仓/持有\";\n else if (score >= 60) action = \"持有偏加\";\n else if (score >= 50) action = \"持有观望\";\n else if (score >= 40) action = \"减仓/观望\";\n else action = \"回避\";\n\n const support = e.sr\n ? e.sr.support.toFixed(3)\n : (ma20 ? ma20.toFixed(3) : \"-\");\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\nasync function writeToFeishu(records, label) {\n const token = await getFeishuToken();\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n const nowMs = Date.now();\n const bjNow = new Date(nowMs + 8 * 3600 * 1000);\n const dateStr = bjNow.toISOString().substring(0, 10);\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 \"ETF名称\": r.name,\n \"ETF代码\": r.code,\n \"所属板块\": r.sector,\n \"收盘价\": Number(r.price.toFixed(3)),\n \"当日涨跌幅(%)\": Number(r.change.toFixed(2)),\n \"成交量(万手)\": Number((r.volume || 0).toFixed(2)),\n \"成交额(亿元)\": Number((r.amount || 0).toFixed(2)),\n \"MACD-DIF\": Number(r.dif.toFixed(4)),\n \"MACD-DEA\": Number(r.dea.toFixed(4)),\n \"MACD柱\": Number(r.macd.toFixed(4)),\n \"涨跌原因分析\": \"【\" + label + \"】\" + r.analysis,\n \"后续1-3天走势判断\": r.trend,\n \"判断依据\": \"综合评分\" + r.score + \"分，\" + r.action,\n \"数据来源\": \"腾讯/新浪API+val-town自动分析 \" + label,\n },\n })),\n };\n\n const batchSize = 100;\n let created = 0;\n for (let i = 0; i < body.records.length; i += batchSize) {\n const batch = { records: body.records.slice(i, i + batchSize) };\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 headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(batch),\n },\n );\n const d = await res.json();\n if (d.code === 0) created += (d.data?.records || []).length;\n else console.error(\"写入飞书失败:\", d.msg);\n if (i + batchSize < body.records.length) {\n await new Promise((r) => setTimeout(r, 300));\n }\n }\n return created;\n}\n\nasync function syncIndicesToFeishu(indices) {\n try {\n const token = await getFeishuToken();\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n const nowMs = Date.now();\n const listUrl = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt +\n \"/tables/\" + INDEX_TABLE_ID + \"/records?page_size=100\";\n const listRes = await fetch(listUrl, {\n headers: { \"Authorization\": \"Bearer \" + token },\n });\n const ld = await listRes.json();\n const existing = ld.data?.items || [];\n const existingMap = {};\n for (const r of existing) {\n const code = String(r.fields[\"指数代码\"] || \"\");\n if (code) existingMap[code] = r.record_id;\n }\n const toCreate = [];\n const toUpdate = [];\n for (const idx of indices) {\n const fields = {\n \"指数代码\": idx.code,\n \"指数名称\": idx.name,\n \"最新价\": Number(idx.price.toFixed(2)),\n \"涨跌幅\": Number(idx.change.toFixed(2)),\n \"更新时间\": nowMs,\n };\n if (existingMap[idx.code]) {\n toUpdate.push({ record_id: existingMap[idx.code], fields });\n } else toCreate.push({ fields });\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 headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ records: toUpdate }),\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 headers: {\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ records: toCreate }),\n },\n );\n }\n console.log(\"指数同步完成:\", indices.length, \"条\");\n } catch (e) {\n console.error(\"指数同步失败:\", e.message);\n }\n}\n\nasync function getIndexRealTime() {\n try {\n const symbols = INDEX_LIST.map((i) => i.pre + i.code).join(\",\");\n const map = await fetchTencent(symbols);\n return INDEX_LIST.map((i) => ({\n code: i.code,\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 const map = await fetchTencent(symbols);\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\nexport default async function handler() {\n const startTime = Date.now();\n console.log(\n \"=== ETF行情自动监控v2.1开始 ===\",\n new Date().toLocaleString(\"zh-CN\"),\n );\n\n const at = getAnalysisType();\n console.log(\"时段判断:\", at.type, at.reason || \"\", \"北京时间\", at.bjTime);\n\n const etfList = await getEtfListFromFeishu();\n console.log(\"监控ETF数量:\", etfList.length);\n\n try {\n const indices = await getIndexRealTime();\n await syncIndicesToFeishu(indices);\n } catch (e) {\n console.error(\"指数处理失败:\", e.message);\n }\n\n if (at.type === \"skip\") {\n console.log(\"非分析时段，跳过ETF处理\");\n console.log(\"=== 结束(耗时\" + (Date.now() - startTime) + \"ms) ===\");\n return;\n }\n\n try {\n const quotes = await getEtfRealTime(etfList);\n const newsList = await getNews();\n const records = [];\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 if (klines.length < 25) continue;\n const closes = klines.map((k) => k.close);\n const vols = klines.map((k) => k.volume);\n const ma5 = calcMA(closes, 5),\n ma10 = calcMA(closes, 10),\n ma20 = calcMA(closes, 20);\n const macd = calcMACD(closes);\n const kdj = calcKDJ(klines);\n const vol5 = vols.slice(-6, -1).reduce((a, b) => a + b, 0) / 5;\n const volRatio = vol5 > 0 ? vols[vols.length - 1] / vol5 : 0;\n const activeFlow = { netHand: (q.outer || 0) - (q.inner || 0) };\n const sr = calcSupportResistance(klines, ma20, ma5);\n let fundFlow = null;\n try {\n fundFlow = await getFundFlow(q.code);\n } catch (e) {}\n const keywords = SECTOR_KEYWORDS[q.sector] || [];\n const sectorNews = keywords.length > 0\n ? newsList.filter((t) => keywords.some((kw) => t.includes(kw)))\n : [];\n const base = {\n ...q,\n ma5,\n ma10,\n ma20,\n dif: macd.dif,\n dea: macd.dea,\n macd: macd.macd,\n kdjK: kdj.k,\n kdjD: kdj.d,\n kdjJ: kdj.j,\n volRatio,\n fundFlow,\n news: sectorNews,\n activeFlow,\n sr,\n minute: minuteData,\n };\n const analysis = generateAnalysis(base);\n records.push({ ...base, ...analysis });\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 await new Promise((r) => setTimeout(r, 200));\n }\n\n if (records.length > 0) {\n const created = await writeToFeishu(records, at.label);\n console.log(at.label + \"写入飞书:\", created, \"条\");\n }\n } catch (e) {\n console.error(\"分析处理失败:\", e.message);\n }\n\n console.log(\"=== 结束(耗时\" + (Date.now() - startTime) + \"ms) ===\");\n}","createdAt",["D",1787789570999],"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","756e25e6-a031-11f1-9e70-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03692-bb2d-7479-ba40-7240e1b1f15b","tursoName","4413457f3b8d43038e1ede4426fea38b","tursoHostname","4413457f3b8d43038e1ede4426fea38b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789528852539],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":102},"org",{"_100":99,"_101":102,"_103":102,"_18":55,"_104":105,"_106":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"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":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":168,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":169,"_84":170,"_86":171,"_88":25},"tree",[158,159],"files",[158,159],"counts",{"_146":63,"_147":148,"_149":63,"_150":151,"_152":153},"contents",[129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":142,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":25,"_38":143,"_13":144,"_33":34,"_35":37,"_24":25,"_140":-5,"_27":145},{"_43":131,"_32":132,"_30":57,"_133":-5,"_41":42,"_40":134,"_135":25,"_38":136,"_13":137,"_33":138,"_35":139,"_24":25,"_140":-5,"_27":141},"ace8b1db-d417-4254-955a-7fc2f180ef6d","new-file-899.ts","parentId",28,"latest",["D",1787710327539],12,"http","// ============================================================\n// ETF行情数据API v2.1 - 短线升级版\n// 功能：动态ETF列表 + 实时行情 + 日K技术指标 + 分时线(腾讯)\n// + 盘中资金流(外盘-内盘) + 全市场涨跌家数(东财)\n// + 支撑压力位(实时计算) + 消息面(新浪) + 多因子AI分析\n// 部署文件：new-file-899.ts (val-town HTTP端点)\n// 更新日期：2026-08-26\n// ============================================================\n\nconst ETF_INFO_TABLE_ID = \"tbl5K6lJm9aAjKdo\";\n\nconst INDEX_LIST = [\n { code: \"000001\", name: \"上证指数\", pre: \"sh\" },\n { code: \"399001\", name: \"深证成指\", pre: \"sz\" },\n { code: \"399006\", name: \"创业板指\", pre: \"sz\" },\n { code: \"000688\", name: \"科创50\", pre: \"sh\" },\n];\n\nconst SECTOR_KEYWORDS = {\n \"科技\": [\"芯片\", \"半导体\", \"人工智能\", \"AI\", \"算力\", \"机器人\", \"卫星\", \"通信\", \"电子\", \"5G\", \"数据中心\", \"软件\", \"半导体设备\", \"功率\"],\n \"新能源\": [\"电池\", \"储能\", \"锂电\", \"光伏\", \"新能源\", \"固态电池\", \"充电桩\"],\n \"周期\": [\"黄金\", \"有色\", \"稀土\", \"稀有金属\", \"大宗商品\", \"铜\", \"金价\", \"贵金属\"],\n \"医药\": [\"创新药\", \"医药\", \"生物医药\", \"CRO\", \"医疗\", \"药\"],\n \"金融\": [\"银行\", \"券商\", \"保险\", \"金融\"],\n \"宽基\": [\"沪深300\", \"上证50\", \"中证\", \"大盘\", \"A股\"],\n \"其他\": [\"电力\", \"公用事业\", \"能源\"],\n \"消费\": [\"消费\", \"白酒\", \"食品\", \"家电\"],\n \"港股\": [\"港股\", \"恒生\", \"中概\"],\n \"海外\": [\"美股\", \"纳斯达克\", \"标普\", \"海外\"],\n};\n\nasync function getFeishuToken() {\n const res = await fetch(\"https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ app_id: Deno.env.get(\"FEISHU_APP_ID\"), app_secret: Deno.env.get(\"FEISHU_APP_SECRET\") }),\n });\n const d = await res.json();\n if (!d.tenant_access_token) throw new Error(\"飞书token获取失败: \" + JSON.stringify(d));\n return d.tenant_access_token;\n}\n\nasync function getEtfListFromFeishu() {\n try {\n const token = await getFeishuToken();\n const bt = Deno.env.get(\"FEISHU_BASE_TOKEN\");\n const url = \"https://open.feishu.cn/open-apis/bitable/v1/apps/\" + bt + \"/tables/\" + ETF_INFO_TABLE_ID + \"/records?page_size=100\";\n const res = await fetch(url, { headers: { \"Authorization\": \"Bearer \" + token } });\n const d = await res.json();\n if (d.code !== 0) throw new Error(\"读取ETF信息库失败: \" + d.msg);\n const items = d.data.items || [];\n const list = [];\n for (const r of items) {\n const f = r.fields;\n const enabled = Array.isArray(f[\"启用\"]) ? (f[\"启用\"][0]?.text || \"\") : String(f[\"启用\"] || \"是\");\n if (enabled === \"否\") continue;\n const code = String(f[\"ETF代码\"] || \"\");\n if (!code) continue;\n const name = String(f[\"ETF名称\"] || code);\n const sector = Array.isArray(f[\"所属板块\"]) ? (f[\"所属板块\"][0]?.text || \"其他\") : (String(f[\"所属板块\"] || \"其他\"));\n list.push({ code, name, sector });\n }\n return list;\n } catch (e) {\n console.error(\"读取飞书ETF列表失败:\", e.message);\n return [];\n }\n}\n\nfunction etfPrefix(code) {\n return code.startsWith(\"15\") ? \"sz\" : \"sh\";\n}\n\nasync function fetchTencent(symbols) {\n const url = \"https://qt.gtimg.cn/q=\" + symbols;\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\" } });\n const buf = await res.arrayBuffer();\n let text;\n try { text = new TextDecoder(\"gbk\").decode(buf); } catch (e) { text = new TextDecoder(\"utf-8\").decode(buf); }\n const map = {};\n for (const line of text.split(\";\")) {\n const m = line.match(/v_(?:sh|sz)(\\d+)=\"([^\"]+)\"/);\n if (!m) continue;\n const f = m[2].split(\"~\");\n map[m[1]] = {\n name: f[1] || \"\", price: parseFloat(f[3]) || 0, change: parseFloat(f[32]) || 0,\n open: parseFloat(f[5]) || 0, high: parseFloat(f[33]) || 0, low: parseFloat(f[34]) || 0,\n volume: (parseFloat(f[36]) || 0) / 10000, amount: (parseFloat(f[37]) || 0) / 10000,\n outer: parseFloat(f[7]) || 0, inner: parseFloat(f[8]) || 0,\n turnover: parseFloat(f[38]) || 0,\n };\n }\n return map;\n}\n\nasync function getKLine(code, n) {\n const prefix = etfPrefix(code);\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=\" + prefix + code + \",day,,,\" + n + \",qfq\";\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n const obj = d.data?.[prefix + code];\n const day = obj?.day || obj?.qfqday || [];\n return day.map(k => ({\n date: k[0], open: parseFloat(k[1]) || 0, close: parseFloat(k[2]) || 0,\n high: parseFloat(k[3]) || 0, low: parseFloat(k[4]) || 0, volume: parseFloat(k[5]) || 0,\n }));\n}\n\nasync function getMinuteData(code) {\n try {\n const prefix = etfPrefix(code);\n const url = \"https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=\" + prefix + code;\n const res = await fetch(url, { headers: { \"Referer\": \"https://gu.qq.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n const obj = d.data?.[prefix + code];\n const dataArr = obj?.data?.data || [];\n const date = obj?.data?.date || \"\";\n const points = [];\n for (const line of dataArr) {\n const p = line.split(\" \");\n if (p.length < 4) continue;\n points.push({ t: p[0], p: parseFloat(p[1]) || 0, v: parseFloat(p[2]) || 0, a: parseFloat(p[3]) || 0 });\n }\n if (points.length === 0) return null;\n const latest = points[points.length - 1];\n let high = -Infinity, low = Infinity, cumV = 0, cumA = 0;\n for (const pt of points) {\n if (pt.p > high) high = pt.p;\n if (pt.p < low) low = pt.p;\n cumV += pt.v; cumA += pt.a;\n }\n const avgPrice = cumV > 0 ? cumA / (cumV * 100) : latest.p;\n return {\n date, latest: latest.p, avgPrice: Number(avgPrice.toFixed(4)),\n high: Number(high.toFixed(4)), low: Number(low.toFixed(4)),\n points,\n };\n } catch (e) {\n console.error(\"分时获取失败 \" + code + \":\", e.message);\n return null;\n }\n}\n\nfunction calcEMA(values, period) {\n if (values.length === 0) return [];\n const k = 2 / (period + 1);\n let ema = values[0];\n const result = [ema];\n for (let i = 1; i < values.length; i++) {\n ema = values[i] * k + ema * (1 - k);\n result.push(ema);\n }\n return result;\n}\n\nfunction calcMACD(closes) {\n const ema10 = calcEMA(closes, 10);\n const ema20 = calcEMA(closes, 20);\n const dif = closes.map((_, i) => ema10[i] - ema20[i]);\n const dea = calcEMA(dif, 7);\n const macd = dif.map((d, i) => 2 * (d - dea[i]));\n const n = closes.length - 1;\n return { dif: dif[n], dea: dea[n], macd: macd[n], difPrev: dif[n-1], deaPrev: dea[n-1], macdPrev: macd[n-1] };\n}\n\nfunction calcMA(closes, period) {\n if (closes.length < period) return null;\n return closes.slice(-period).reduce((a, b) => a + b, 0) / period;\n}\n\nfunction calcKDJ(klines) {\n const n = 9;\n let k = 50, d = 50, lastK = 50, lastD = 50;\n for (let i = 0; i < klines.length; i++) {\n const start = Math.max(0, i - n + 1);\n let highest = -Infinity, lowest = Infinity;\n for (let j = start; j <= i; j++) {\n highest = Math.max(highest, klines[j].high);\n lowest = Math.min(lowest, klines[j].low);\n }\n const rsv = highest === lowest ? 50 : ((klines[i].close - lowest) / (highest - lowest)) * 100;\n k = (2 / 3) * k + (1 / 3) * rsv;\n d = (2 / 3) * d + (1 / 3) * k;\n lastK = k; lastD = d;\n }\n return { k: lastK, d: lastD, j: 3 * lastK - 2 * lastD };\n}\n\nfunction calcSupportResistance(klines, ma20, ma5) {\n const recent = klines.slice(-20);\n let hi20 = -Infinity, lo20 = Infinity;\n for (const k of recent) {\n if (k.high > hi20) hi20 = k.high;\n if (k.low < lo20) lo20 = k.low;\n }\n let std = 0;\n if (klines.length >= 20) {\n const closes = klines.slice(-20).map(k => k.close);\n const mean = closes.reduce((a, b) => a + b, 0) / 20;\n std = Math.sqrt(closes.reduce((a, b) => a + (b - mean) * (b - mean), 0) / 20);\n }\n const bollMid = ma20 || 0;\n const bollUpper = ma20 ? ma20 + 2 * std : 0;\n const bollLower = ma20 ? ma20 - 2 * std : 0;\n const support = ma20 && bollLower ? Math.min(ma20, bollLower) : (ma20 || bollLower || lo20);\n const resistance = ma5 && bollUpper ? Math.max(ma5, bollUpper) : (ma5 || bollUpper || hi20);\n return {\n support: Number(support.toFixed(4)),\n resistance: Number(resistance.toFixed(4)),\n hi20: Number(hi20.toFixed(4)),\n lo20: Number(lo20.toFixed(4)),\n bollUpper: Number(bollUpper.toFixed(4)),\n bollLower: Number(bollLower.toFixed(4)),\n bollMid: Number(bollMid.toFixed(4)),\n };\n}\n\nasync function getFundFlow(code, days) {\n try {\n const prefix = etfPrefix(code);\n const url = \"https://vip.stock.finance.sina.com.cn/quotes_service/api/json_v2.php/MoneyFlow.ssl_qsfx_zjlrqs?page=1&num=\" + days + \"&sort=opendate&asc=0&daima=\" + prefix + code;\n const res = await fetch(url, { headers: { \"Referer\": \"https://finance.sina.com.cn/\", \"User-Agent\": \"Mozilla/5.0\" } });\n const text = await res.text();\n const clean = text.replace(/^[^(]*\$/, \"\").replace(/\$\\s*;?\\s*$/, \"\");\n let data;\n try { data = JSON.parse(clean); } catch (e) { data = JSON.parse(text); }\n if (!Array.isArray(data) || data.length === 0) return null;\n const latest = data[0];\n return {\n date: String(latest.opendate || \"\"),\n netAmount: Math.round(Number(latest.netamount) || 0),\n ratio: Number(latest.ratioamount) || 0,\n mainNet: Math.round(Number(latest.r0_net) || 0),\n mainRatio: Number(latest.r0_ratio) || 0,\n };\n } catch (e) {\n console.error(\"资金流获取失败 \" + code + \":\", e.message);\n return null;\n }\n}\n\nasync function getMarketBreadth() {\n try {\n const url = \"https://push2.eastmoney.com/api/qt/ulist.np/get?fltt=2&secids=1.000001,0.399001&fields=f104,f105,f106\";\n const res = await fetch(url, { headers: { \"Referer\": \"https://quote.eastmoney.com/\", \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n const diff = d.data?.diff || [];\n if (diff.length < 2) return null;\n const sh = diff[0], sz = diff[1];\n return {\n up: (sh.f104 || 0) + (sz.f104 || 0),\n down: (sh.f105 || 0) + (sz.f105 || 0),\n flat: (sh.f106 || 0) + (sz.f106 || 0),\n source: \"eastmoney\",\n };\n } catch (e) {\n console.error(\"涨跌家数获取失败:\", e.message);\n return null;\n }\n}\n\nlet _newsCache = { time: 0, data: [] };\nasync function getNews() {\n const now = Date.now();\n if (_newsCache.data.length > 0 && now - _newsCache.time < 10 * 60 * 1000) return _newsCache.data;\n try {\n const url = \"https://feed.mix.sina.com.cn/api/roll/get?pageid=153&lid=2516&k=&num=30&page=1&r=\" + Math.random();\n const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await res.json();\n const items = d.result?.data || [];\n const news = items.map(n => ({ title: String(n.title || \"\"), time: String(n.ctime || \"\") }));\n _newsCache = { time: now, data: news };\n return news;\n } catch (e) {\n console.error(\"消息面获取失败:\", e.message);\n return _newsCache.data;\n }\n}\n\nfunction generateAnalysis(e) {\n const parts = [];\n const price = e.price, ma5 = e.ma5, ma10 = e.ma10, ma20 = e.ma20;\n const dif = e.dif, dea = e.dea, macd = e.macd, macdPrev = e.macdPrev;\n const k = e.kdjK, d = e.kdjD, j = e.kdjJ;\n const volRatio = e.volRatio;\n\n let maTxt;\n if (price >= ma5 && ma5 >= ma10 && ma10 >= ma20) maTxt = \"均线多头排列（价>MA5>MA10>MA20），趋势向上\";\n else if (price <= ma5 && ma5 <= ma10 && ma10 <= ma20) maTxt = \"均线空头排列（价 ma5 && price > ma10 && ma10 < ma20) maTxt = \"价格站上5/10日线但MA10 ma20) maTxt = \"价格跌破5/10日线但MA10>MA20，短弱中强\";\n else maTxt = \"均线交织缠绕，方向不明\";\n parts.push(\"【均线】MA5=\" + ma5.toFixed(3) + \" MA10=\" + ma10.toFixed(3) + \" MA20=\" + ma20.toFixed(3) + \"，\" + maTxt);\n\n let macdTxt;\n if (dif > dea && dif > 0) macdTxt = \"MACD多头（DIF>DEA且零轴上方）\";\n else if (dif > dea && dif < 0) macdTxt = \"MACD低位金叉（零轴下方DIF上穿DEA）\";\n else if (dif < dea && dif > 0) macdTxt = \"MACD高位死叉（零轴上方DIF下穿DEA）\";\n else macdTxt = \"MACD空头（DIF= macdPrev) macdTxt += \"，柱体/动能放大\";\n else macdTxt += \"，柱体/动能收窄\";\n parts.push(\"【MACD】DIF=\" + dif.toFixed(4) + \" DEA=\" + dea.toFixed(4) + \" 柱=\" + macd.toFixed(4) + \"，\" + macdTxt);\n\n let kdjTxt;\n if (k > 80 || j > 100) kdjTxt = \"KDJ超买区（K=\" + k.toFixed(0) + \"）\";\n else if (k < 20 || j < 0) kdjTxt = \"KDJ超卖区（K=\" + k.toFixed(0) + \"）\";\n else if (k > d) kdjTxt = \"KDJ金叉向上（K>D）\";\n else kdjTxt = \"KDJ死叉向下（K 1.5) volTxt = \"放量（量比\" + volRatio.toFixed(1) + \"）\";\n else if (volRatio > 1.2) volTxt = \"温和放量（量比\" + volRatio.toFixed(1) + \"）\";\n else if (volRatio < 0.7) volTxt = \"明显缩量（量比\" + volRatio.toFixed(1) + \"）\";\n else if (volRatio < 0.9) volTxt = \"缩量（量比\" + volRatio.toFixed(1) + \"）\";\n else volTxt = \"量能平稳（量比\" + volRatio.toFixed(1) + \"）\";\n parts.push(\"【量能】今日量/5日均量=\" + volRatio.toFixed(2) + \"，\" + volTxt);\n\n if (e.activeFlow) {\n const netHand = e.activeFlow.netHand;\n const flowTxt = netHand >= 0\n ? \"主动买盘占优（外盘-内盘+\" + (netHand / 10000).toFixed(2) + \"万手）\"\n : \"主动卖盘占优（外盘-内盘-\" + (Math.abs(netHand) / 10000).toFixed(2) + \"万手）\";\n parts.push(\"【盘中资金】\" + flowTxt + \"，为实时主动买卖力量\");\n }\n\n if (e.fundFlow) {\n const ff = e.fundFlow;\n const mainTxt = ff.mainNet >= 0 ? \"主力净流入\" + (ff.mainNet / 100000000).toFixed(2) + \"亿\" : \"主力净流出\" + (Math.abs(ff.mainNet) / 100000000).toFixed(2) + \"亿\";\n parts.push(\"【昨日主力】\" + mainTxt + \"，净流入率\" + (ff.mainRatio * 100).toFixed(1) + \"%（T-1，\" + ff.date + \"）\");\n }\n\n if (e.minute) {\n const mv = e.minute;\n const vsAvg = price >= mv.avgPrice ? \"运行于分时均价上方（多头）\" : \"运行于分时均价下方（空头）\";\n const half = Math.floor(mv.points.length / 2);\n let later = 0, early = 0;\n for (const pt of mv.points.slice(half)) later += pt.v;\n for (const pt of mv.points.slice(0, half)) early += pt.v;\n const flowDir = later > early ? \"午后/尾盘量能放大\" : \"午后/尾盘量能萎缩\";\n parts.push(\"【分时】\" + vsAvg + \"，分时均价=\" + mv.avgPrice.toFixed(3) + \"，\" + flowDir);\n }\n\n if (e.news && e.news.length > 0) {\n const newsTxt = e.news.slice(0, 2).map(n => n.title).join(\"；\");\n parts.push(\"【消息】\" + newsTxt);\n }\n\n let score = 50;\n if (price >= ma5) score += 5; else score -= 5;\n if (price >= ma10) score += 4; else score -= 4;\n if (price >= ma20) score += 4; else score -= 4;\n if (ma5 >= ma10) score += 3; else score -= 3;\n if (ma10 >= ma20) score += 3; else score -= 3;\n if (dif >= dea) score += 6; else score -= 6;\n if (dif >= 0) score += 4; else score -= 4;\n if (macd >= macdPrev) score += 3; else score -= 3;\n if (k >= d) score += 3; else score -= 3;\n if (e.change > 0) score += Math.min(5, e.change * 2); else score -= Math.min(5, Math.abs(e.change) * 2);\n if (e.change > 0 && volRatio >= 1.1) score += 3;\n if (e.change < 0 && volRatio >= 1.3) score -= 4;\n if (e.change < 0 && volRatio <= 0.8) score += 2;\n if (e.activeFlow) {\n if (e.activeFlow.netHand > 0) score += 3;\n if (e.activeFlow.netHand < 0 && Math.abs(e.activeFlow.netHand) > 50000) score -= 3;\n }\n if (e.fundFlow) {\n if (e.fundFlow.mainNet > 0) score += 3;\n if (e.fundFlow.mainNet < -1e8) score -= 3;\n }\n if (e.minute) {\n if (price >= e.minute.avgPrice) score += 2; else score -= 2;\n }\n score = Math.max(5, Math.min(95, score));\n\n let trend;\n if (score >= 70) trend = \"偏多\";\n else if (score >= 60) trend = \"震荡偏多\";\n else if (score >= 45) trend = \"震荡\";\n else if (score >= 35) trend = \"震荡偏空\";\n else trend = \"偏空\";\n\n let action;\n if (score >= 70) action = \"加仓/持有：趋势向上，回踩MA5/支撑位可加仓，跌破MA10减仓\";\n else if (score >= 60) action = \"持有偏加：多头占优，逢低分批加仓，止损位MA20/布林下轨\";\n else if (score >= 50) action = \"持有观望：多空均衡，等待方向选择，轻仓参与\";\n else if (score >= 40) action = \"减仓/观望：偏弱格局，反弹至压力位减仓，不宜重仓\";\n else action = \"回避：弱势明显，等待企稳信号，勿盲目抄底\";\n\n const support = e.sr ? e.sr.support.toFixed(3) : (ma20 ? ma20.toFixed(3) : \"-\");\n const resist = e.sr ? e.sr.resistance.toFixed(3) : (ma5 ? ma5.toFixed(3) : \"-\");\n const summary = \"综合评分\" + score.toFixed(0) + \"分，短期走势【\" + trend + \"】。关键支撑位\" + support + \"，压力位\" + resist + \"。\" + action;\n\n return { score, trend, action, analysis: parts.join(\"。\") + \"。\" + summary };\n}\n\nasync function calcEtfIndicators(quote, newsList) {\n const [klines, minuteData] = await Promise.all([getKLine(quote.code, 60), getMinuteData(quote.code)]);\n if (klines.length < 25) {\n return { code: quote.code, name: quote.name, sector: quote.sector, ...quote, minute: minuteData, klineError: \"K线不足\", score: 50, trend: \"震荡\", action: \"数据不足\", analysis: \"K线数据不足，无法计算完整技术指标\" };\n }\n const closes = klines.map(k => k.close);\n const vols = klines.map(k => k.volume);\n const ma5 = calcMA(closes, 5);\n const ma10 = calcMA(closes, 10);\n const ma20 = calcMA(closes, 20);\n const macd = calcMACD(closes);\n const kdj = calcKDJ(klines);\n const vol5 = vols.slice(-6, -1).reduce((a, b) => a + b, 0) / 5;\n const volRatio = vol5 > 0 ? vols[vols.length - 1] / vol5 : 0;\n const last = klines[klines.length - 1];\n const kline = { date: last.date, open: last.open, close: last.close, high: last.high, low: last.low, prevClose: klines[klines.length - 2].close };\n\n const activeFlow = {\n netHand: (quote.outer || 0) - (quote.inner || 0),\n outer: quote.outer || 0,\n inner: quote.inner || 0,\n };\n const sr = calcSupportResistance(klines, ma20, ma5);\n\n let fundFlow = null;\n try { fundFlow = await getFundFlow(quote.code, 3); } catch (e) { fundFlow = null; }\n\n const keywords = SECTOR_KEYWORDS[quote.sector] || [];\n const sectorNews = keywords.length > 0\n ? newsList.filter(n => keywords.some(kw => n.title.includes(kw)))\n : [];\n\n const base = {\n code: quote.code, name: quote.name, sector: quote.sector,\n price: quote.price, change: quote.change, open: quote.open, high: quote.high, low: quote.low,\n volume: quote.volume, amount: quote.amount,\n ma5, ma10, ma20,\n dif: macd.dif, dea: macd.dea, macd: macd.macd,\n difPrev: macd.difPrev, deaPrev: macd.deaPrev, macdPrev: macd.macdPrev,\n kdjK: kdj.k, kdjD: kdj.d, kdjJ: kdj.j,\n volRatio, kline, fundFlow, news: sectorNews,\n activeFlow, sr, minute: minuteData,\n };\n return { ...base, ...generateAnalysis(base) };\n}\n\nasync function getIndexRealTime() {\n try {\n const symbols = INDEX_LIST.map(i => i.pre + i.code).join(\",\");\n const map = await fetchTencent(symbols);\n return INDEX_LIST.map(i => ({\n code: i.code, name: i.name,\n ...(map[i.code] || { price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }),\n }));\n } catch (e) {\n console.error(\"指数获取失败:\", e.message);\n return INDEX_LIST.map(i => ({ code: i.code, name: i.name, price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }));\n }\n}\n\nasync function getEtfRealTime(etfList) {\n try {\n const symbols = etfList.map(e => etfPrefix(e.code) + e.code).join(\",\");\n const map = await fetchTencent(symbols);\n return etfList.map(e => ({\n code: e.code, name: e.name, sector: e.sector,\n ...(map[e.code] || { price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }),\n }));\n } catch (e) {\n console.error(\"ETF获取失败:\", e.message);\n return etfList.map(e => ({ code: e.code, name: e.name, sector: e.sector, price: 0, change: 0, open: 0, high: 0, low: 0, volume: 0, amount: 0 }));\n }\n}\n\nfunction beijingTime() {\n const d = new Date(Date.now() + 8 * 3600 * 1000);\n return d.toISOString().replace(\"T\", \" \").substring(0, 19);\n}\n\nexport default async function (req) {\n const url = new URL(req.url);\n const refresh = url.searchParams.get(\"refresh\");\n if (refresh === \"1\" || !globalThis._cachedData || Date.now() - globalThis._cacheTime > 30 * 1000) {\n try {\n const etfList = await getEtfListFromFeishu();\n if (etfList.length === 0) {\n return Response.json({ success: false, timestamp: beijingTime(), message: \"飞书ETF基础信息库为空或读取失败\" }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n }\n const [indices, etfQuotes, newsList, breadth] = await Promise.all([getIndexRealTime(), getEtfRealTime(etfList), getNews(), getMarketBreadth()]);\n const etfs = [];\n for (const q of etfQuotes) {\n etfs.push(await calcEtfIndicators(q, newsList));\n }\n const upCount = etfs.filter(e => e.change > 0).length;\n const downCount = etfs.filter(e => e.change < 0).length;\n const flatCount = etfs.filter(e => e.change === 0).length;\n const avgChange = etfs.reduce((a, e) => a + e.change, 0) / (etfs.length || 1);\n const market = {\n upCount, downCount, flatCount, avgChange: Number(avgChange.toFixed(2)),\n totalAmount: Number(((indices[0]?.amount || 0) + (indices[1]?.amount || 0)).toFixed(2)),\n etfCount: etfs.length,\n hsUp: breadth?.up ?? null,\n hsDown: breadth?.down ?? null,\n hsFlat: breadth?.flat ?? null,\n breadthSource: breadth?.source ?? null,\n };\n globalThis._cachedData = { indices, etfs, market };\n globalThis._cacheTime = Date.now();\n globalThis._cacheError = null;\n } catch (e) {\n globalThis._cacheError = e.message;\n console.error(\"数据获取失败:\", e.message);\n }\n }\n const data = globalThis._cachedData || { indices: [], etfs: [], market: {} };\n return Response.json({\n success: true, timestamp: beijingTime(),\n indices: data.indices, etfs: data.etfs, market: data.market,\n }, { headers: { \"Access-Control-Allow-Origin\": \"*\" } });\n}","label",[132],"ca87347a-b2da-4a63-8c45-cf070a319f96",["D",1787789570999],18,[28],"pulls","branches",1,"forks","envVars",{"_154":156,"_157":63},"connections",{"_154":63,"_155":63},"count","unfilledCount",6,"emptyCount",{"_43":142,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":25,"_38":164,"_13":144,"_33":34,"_35":37,"_24":25,"_140":-5,"_161":165,"_27":166},{"_43":131,"_32":132,"_30":57,"_133":-5,"_41":42,"_40":134,"_135":25,"_38":160,"_13":137,"_33":138,"_35":139,"_24":25,"_140":-5,"_161":162,"_27":163},["D",1787710327539],"children",[],[132],["D",1787789570999],[],[28],["D",1787622199218],["D",1789528852539],{"_100":99,"_107":102},{"_100":99,"_101":102,"_103":102,"_18":55,"_104":105,"_106":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_126":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":59,"_214":-5,"_215":-7,"_216":-7,"_217":63,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":90,"_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 · v32