ianzeng123
策略源码
{"type":"n8n","content":"{\"workflowData\":{\"nodes\":[{\"parameters\":{\"operation\":\"sendMessage\",\"chatId\":{\"__rl\":true,\"value\":\"=8357264271\",\"mode\":\"id\"},\"text\":\"={{ $json.output }}\",\"parseMode\":\"HTML\"},\"type\":\"n8n-nodes-base.telegram\",\"typeVersion\":1.2,\"position\":[960,336],\"id\":\"2ab70ac8-51b0-44c5-b5ed-88ab8c48f028\",\"name\":\"Telegram Message Sender\",\"credentials\":{\"telegramApi\":{\"id\":\"64b40791-c845-4775-9d67-0efc4122d162\",\"name\":\"Telegram account\"}}},{\"parameters\":{\"model\":{\"__rl\":true,\"value\":\"deepseek/deepseek-chat-v3.1\",\"mode\":\"list\",\"cachedResultName\":\"deepseek/deepseek-chat-v3.1\"}},\"type\":\"n8n-nodes-base.lmOpenAi\",\"typeVersion\":1,\"position\":[592,560],\"id\":\"666b23db-40c2-445a-b00f-1f18c1bc7ac7\",\"name\":\"AI Model\",\"credentials\":{\"openAiApi\":{\"id\":\"54d0b567-b3fc-4c6a-b6be-546e0b9cd83f\",\"name\":\"openrouter\"}}},{\"parameters\":{\"text\":\"=Please use FMZ's MCP to perform the following operation: \\n{{JSON.stringify($json.messageText)}}\\nPlease proceed and return the answer in english\",\"options\":{}},\"type\":\"@n8n/n8n-nodes-langchain.agent\",\"typeVersion\":1,\"position\":[560,336],\"id\":\"594d81c5-44c6-4af7-b0c8-5b303a6ff2fb\",\"name\":\"MCP Operation Executor\"},{\"parameters\":{\"mode\":\"runOnceForAllItems\",\"language\":\"javaScript\",\"jsCode\":\"const messageText = $input.first().json.message.text;\\n\\n// json must be an object, wrapped with value or other key names\\nreturn [\\n {\\n json: {messageText}\\n }\\n];\",\"notice\":\"\"},\"type\":\"n8n-nodes-base.code\",\"typeVersion\":2,\"position\":[336,336],\"id\":\"a2ae7878-b666-477b-91d4-9cd3b3950a30\",\"name\":\"Telegram Message Processor\"},{\"parameters\":{\"endpointUrl\":\"https://www.fmz.com/api/mcp/338244b4b2c77edf39e705199a95a41c?token=759f04ab87553277c8fbcd97239453ae\",\"authentication\":\"bearerAuth\",\"credentials\":\"\",\"include\":\"all\"},\"type\":\"@n8n/n8n-nodes-langchain.mcpClientTool\",\"typeVersion\":1.1,\"position\":[720,560],\"id\":\"502a94fc-5b2f-45a6-b01d-08c8058c6edd\",\"name\":\"MCP Client\",\"credentials\":{\"httpBearerAuth\":{\"id\":\"636bfcb6-f73d-4487-80a6-574919e7dc15\",\"name\":\"fmzflowtest\"}}},{\"parameters\":{\"notice\":\"\",\"rule\":{\"interval\":[{\"field\":\"seconds\",\"secondsInterval\":30}]},\"updates\":[\"*\"],\"additionalFields\":{}},\"type\":\"n8n-nodes-base.telegramTrigger\",\"typeVersion\":1,\"position\":[112,336],\"id\":\"c026936f-1993-4798-b7e4-a027bc2f7493\",\"name\":\"Telegram Trigger\",\"credentials\":{\"telegramApi\":{\"id\":\"64b40791-c845-4775-9d67-0efc4122d162\",\"name\":\"Telegram account\"}}},{\"parameters\":{\"mode\":\"runOnceForAllItems\",\"language\":\"javaScript\",\"jsCode\":\"// ========== Initialization Check ==========\\nif (_G('invoketime') === null) {\\n _G('invoketime', 0);\\n _G('STARTTIME', Date.now());\\n \\n const initAccount = exchange.GetAccount();\\n const ticker = exchange.GetTicker();\\n const initBTCAmount = initAccount.Stocks || 0;\\n const initUSDTBalance = initAccount.Balance || 0;\\n const initPrice = ticker.Last;\\n const initBTCValue = initBTCAmount * initPrice;\\n const initTotalValue = initUSDTBalance + initBTCValue;\\n \\n _G('initBTC', initBTCAmount);\\n _G('initUSDT', initUSDTBalance);\\n _G('initPrice', initPrice);\\n _G('initBTCValue', initBTCValue);\\n _G('initTotalValue', initTotalValue);\\n _G('approveCount', 0);\\n _G('rejectCount', 0);\\n _G('totalDecisions', 0);\\n \\n Log(`📊 Account Initialization: BTC=${_N(initBTCAmount, 8)}, USDT=${_N(initUSDTBalance, 2)}, Initial Price=$${_N(initPrice, 2)}, Initial Total Value=$${_N(initTotalValue, 2)}`);\\n}\\n\\n_G('totalDecisions', _G('totalDecisions') + 1);\\n_G('rejectCount', _G('rejectCount') + 1);\\n\\nconst invoketime = _G('invoketime') + 1;\\n_G('invoketime', invoketime);\\n\\nconst duringtime = Math.floor((Date.now() - _G('STARTTIME')) / 60000);\\n\\nconst currentAccount = exchange.GetAccount();\\nconst currentTicker = exchange.GetTicker();\\nconst currentBTCAmount = currentAccount.Stocks || 0;\\nconst currentUSDTBalance = currentAccount.Balance || 0;\\nconst currentPrice = currentTicker.Last;\\nconst currentBTCValue = currentBTCAmount * currentPrice;\\nconst currentTotalValue = currentUSDTBalance + currentBTCValue;\\n\\nconst initBTC = _G('initBTC');\\nconst initUSDT = _G('initUSDT');\\nconst initPrice = _G('initPrice');\\nconst initBTCValue = _G('initBTCValue');\\nconst initTotalValue = _G('initTotalValue');\\n\\nconst totalProfit = currentTotalValue - initTotalValue;\\nconst totalProfitPercent = initTotalValue > 0 ? ((totalProfit / initTotalValue) * 100).toFixed(2) : '0.00';\\n\\nLogProfit(totalProfit, \\\"&\\\");\\n\\nconst approveCount = _G('approveCount');\\nconst rejectCount = _G('rejectCount');\\nconst totalDecisions = _G('totalDecisions');\\n\\n// ========== Configuration Parameters ==========\\nconst TRADE_SYMBOL = $vars.contract || 'BTC';\\nconst TRADING_PAIR = `${TRADE_SYMBOL}_USDT`;\\n\\n// ========== Utility Functions ==========\\n\\nfunction parseDecision(decision) {\\n try {\\n if (Array.isArray(decision) && decision.length > 0) {\\n return decision[0];\\n }\\n return decision;\\n } catch (e) {\\n Log(\\\"❌ Decision parsing failed:\\\", e.message);\\n return null;\\n }\\n}\\n\\nfunction parseDecisionType(decision) {\\n const text = decision.toLowerCase();\\n \\n const decisionMap = {\\n 'major increase': { action: 'buy', description: 'Major Position Increase', emoji: '🚀' },\\n 'moderate increase': { action: 'buy', description: 'Moderate Position Increase', emoji: '📈' },\\n 'minor increase': { action: 'buy', description: 'Minor Position Increase', emoji: '➕' },\\n 'standard investment': { action: 'buy', description: 'Standard Investment', emoji: '💰' },\\n 'hold position': { action: 'hold', description: 'Hold Position', emoji: '⏸️' },\\n 'pause and observe': { action: 'hold', description: 'Pause and Observe', emoji: '⏸️' },\\n 'no action': { action: 'hold', description: 'No Action', emoji: '⏸️' },\\n 'continue observing': { action: 'hold', description: 'Continue Observing', emoji: '⏸️' }\\n };\\n \\n for (const [key, value] of Object.entries(decisionMap)) {\\n if (text.includes(key)) {\\n return value;\\n }\\n }\\n \\n return { action: 'hold', description: 'Hold Position', emoji: '⏸️' };\\n}\\n\\n// ========== History Management ==========\\n\\nfunction saveRejectionRecord(decision, price) {\\n const history = _G('dca_history') || [];\\n \\n const now = new Date();\\n const year = now.getFullYear();\\n const month = String(now.getMonth() + 1).padStart(2, '0');\\n const day = String(now.getDate()).padStart(2, '0');\\n const hour = String(now.getHours()).padStart(2, '0');\\n const minute = String(now.getMinutes()).padStart(2, '0');\\n const second = String(now.getSeconds()).padStart(2, '0');\\n const formattedTime = `${year}-${month}-${day} ${hour}:${minute}:${second}`;\\n \\n const record = {\\n timestamp: now.toISOString(),\\n datetime: formattedTime,\\n symbol: TRADE_SYMBOL,\\n decision: decision.tradingDecision,\\n planned_amount_usd: decision.tradingAmount,\\n actual_amount_usd: 0,\\n quantity: 0,\\n price: price,\\n executed: false,\\n approved: false,\\n reason: decision.tradingRationale\\n };\\n \\n history.push(record);\\n _G('dca_history', history);\\n \\n return history;\\n}\\n\\nfunction getStrategyStats(history, currentPrice) {\\n if (!history || history.length === 0) {\\n return {\\n runtime: '-',\\n totalDecisions: 0,\\n executedCount: 0,\\n totalInvested: 0,\\n totalQuantity: 0,\\n avgPrice: 0,\\n currentValue: 0,\\n currentProfit: 0,\\n profitPercent: 0\\n };\\n }\\n \\n const symbolHistory = history.filter(r => r.symbol === TRADE_SYMBOL);\\n \\n if (symbolHistory.length === 0) {\\n return {\\n runtime: '-',\\n totalDecisions: 0,\\n executedCount: 0,\\n totalInvested: 0,\\n totalQuantity: 0,\\n avgPrice: 0,\\n currentValue: 0,\\n currentProfit: 0,\\n profitPercent: 0\\n };\\n }\\n \\n const startTime = new Date(symbolHistory[0].timestamp);\\n const now = new Date();\\n const runtimeHours = Math.floor((now - startTime) / (1000 * 60 * 60));\\n const runtimeDays = Math.floor(runtimeHours / 24);\\n \\n const executedRecords = symbolHistory.filter(r => r.executed);\\n const totalInvested = executedRecords.reduce((sum, r) => sum + (r.actual_amount_usd || 0), 0);\\n const totalQuantity = executedRecords.reduce((sum, r) => sum + (r.quantity || 0), 0);\\n const avgPrice = totalQuantity > 0 ? totalInvested / totalQuantity : 0;\\n const currentValue = totalQuantity * currentPrice;\\n const currentProfit = currentValue - totalInvested;\\n const profitPercent = totalInvested > 0 ? (currentProfit / totalInvested * 100) : 0;\\n \\n return {\\n runtime: runtimeDays > 0 ? `${runtimeDays}d${runtimeHours % 24}h` : `${runtimeHours}h`,\\n totalDecisions: symbolHistory.length,\\n executedCount: executedRecords.length,\\n totalInvested: totalInvested,\\n totalQuantity: totalQuantity,\\n avgPrice: avgPrice,\\n currentValue: currentValue,\\n currentProfit: currentProfit,\\n profitPercent: profitPercent\\n };\\n}\\n\\n// ========== Table Generation (Simplified) ==========\\n\\nfunction generateAccountTable(initUSDT, currentUSDTBalance, initBTC, currentBTCAmount, initTotalValue, currentTotalValue, totalProfit, totalProfitPercent) {\\n const profitEmoji = totalProfit >= 0 ? \\\"🟢\\\" : \\\"🔴\\\";\\n \\n return {\\n type: \\\"table\\\", \\n title: `💼 Account Overview (${TRADE_SYMBOL})`,\\n cols: [\\\"Type\\\", \\\"Initial\\\", \\\"Current\\\", \\\"Profit Amount\\\", \\\"Profit Rate\\\"],\\n rows: [\\n [\\n \\\"USDT Balance\\\",\\n `$${_N(initUSDT, 2)}`,\\n `$${_N(currentUSDTBalance, 2)}`,\\n \\\"-\\\",\\n \\\"-\\\"\\n ],\\n [\\n `${TRADE_SYMBOL} Holdings`,\\n `${_N(initBTC, 8)}`,\\n `${_N(currentBTCAmount, 8)}`,\\n \\\"-\\\",\\n \\\"-\\\"\\n ],\\n [\\n \\\"Total Account Value\\\",\\n `$${_N(initTotalValue, 2)}`,\\n `$${_N(currentTotalValue, 2)}`,\\n `${profitEmoji} $${_N(totalProfit, 2)}`,\\n `${profitEmoji} ${totalProfitPercent}%`\\n ]\\n ]\\n };\\n}\\n\\nfunction generateDCATable(history, stats) {\\n const table = {\\n type: \\\"table\\\",\\n title: `📊 DCA Information (${TRADE_SYMBOL})`,\\n cols: [\\\"Time\\\", \\\"Decision\\\", \\\"Plan\\\", \\\"Price\\\", \\\"Rationale\\\", \\\"Status\\\"],\\n rows: []\\n };\\n \\n const symbolHistory = history.filter(r => r.symbol === TRADE_SYMBOL);\\n const recentHistory = symbolHistory.slice(-10);\\n \\n recentHistory.forEach(record => {\\n const timeStr = record.datetime;\\n let statusStr;\\n if (record.approved !== undefined) {\\n statusStr = record.approved ? \\\"✅ Approved\\\" : \\\"🚫 Rejected\\\";\\n } else {\\n statusStr = record.executed ? \\\"✅ Executed\\\" : \\\"⏸️ Skipped\\\";\\n }\\n \\n const planStr = record.executed ? `$${_N(record.actual_amount_usd, 0)}` : `$${_N(record.planned_amount_usd, 0)}`;\\n const priceStr = `$${_N(record.price, 0)}`;\\n const reasonStr = (record.reason || '').substring(0, 50);\\n \\n table.rows.push([\\n timeStr,\\n record.decision,\\n planStr,\\n priceStr,\\n reasonStr,\\n statusStr\\n ]);\\n });\\n \\n table.rows.push([\\n `Runtime ${stats.runtime}`,\\n `Total ${stats.totalDecisions}`,\\n `Invested $${_N(stats.totalInvested, 0)}`,\\n `Avg Price $${_N(stats.avgPrice, 0)}`,\\n `${_N(stats.totalQuantity, 6)} ${TRADE_SYMBOL}`,\\n `Executed ${stats.executedCount}`\\n ]);\\n \\n return table;\\n}\\n\\n// ========== Main Logic - Manual Rejection ==========\\n\\nfunction main() {\\n const decision = parseDecision($node[\\\"AI Result Analysis\\\"].json);\\n \\n if (!decision) {\\n Log(\\\"❌ No valid decision obtained\\\");\\n return { json: { success: false, error: \\\"Invalid decision\\\" } };\\n }\\n \\n Log(\\\"=\\\".repeat(60));\\n Log(`🚫 ${TRADE_SYMBOL} AI DCA Decision Analysis - Manual Rejection`);\\n Log(\\\"=\\\".repeat(60));\\n Log(`💡 Decision: ${decision.tradingDecision}`);\\n Log(`💰 Amount: $${decision.tradingAmount}`);\\n Log(`📝 Rationale: ${decision.tradingRationale}...`);\\n Log(`🚫 Manual Decision: Rejected (No trade execution)`);\\n Log(\\\"=\\\".repeat(60));\\n \\n const actionInfo = parseDecisionType(decision.tradingDecision);\\n Log(`🎯 AI Recommendation: ${actionInfo.emoji} ${actionInfo.description}`);\\n \\n exchange.SetCurrency(TRADING_PAIR);\\n \\n const ticker = exchange.GetTicker();\\n if (!ticker) {\\n Log(\\\"❌ Failed to get price\\\");\\n return { json: { success: false, error: \\\"Failed to get price\\\" } };\\n }\\n \\n const currentPrice = ticker.Last;\\n Log(`💵 Current Price: $${currentPrice}`);\\n \\n Log(\\\"\\\\n🚫🚫🚫 Manually Rejected, No Trade Execution 🚫🚫🚫\\\\n\\\");\\n \\n saveRejectionRecord(decision, currentPrice);\\n \\n const rejectResult = {\\n success: true,\\n executed: false,\\n rejected: true,\\n action: 'rejected',\\n decision: decision.tradingDecision,\\n plannedAmount: decision.tradingAmount,\\n actualAmount: 0,\\n quantity: 0,\\n price: currentPrice\\n };\\n \\n const history = _G('dca_history') || [];\\n const stats = getStrategyStats(history, currentPrice);\\n \\n const accountTable = generateAccountTable(\\n initUSDT, currentUSDTBalance, initBTC, currentBTCAmount,\\n initTotalValue, currentTotalValue, totalProfit, totalProfitPercent\\n );\\n \\n const dcaTable = generateDCATable(history, stats);\\n \\n LogStatus(\\n '`' + JSON.stringify(accountTable) + '`\\\\n\\\\n' +\\n '`' + JSON.stringify(dcaTable) + '`'\\n );\\n \\n Log(\\\"\\\\n\\\" + \\\"=\\\".repeat(60));\\n Log(\\\"🚫 Manually rejected, no trade executed\\\");\\n Log(\\\"=\\\".repeat(60));\\n \\n return rejectResult;\\n}\\n\\nconst rejectResult = main();\\n\\nreturn [{\\n json: {\\n invoketime: invoketime,\\n duringtime: duringtime + ' minutes',\\n tradeSymbol: TRADE_SYMBOL,\\n \\n initUSDT: _N(initUSDT, 2),\\n currentUSDT: _N(currentUSDTBalance, 2),\\n initBTC: _N(initBTC, 8),\\n currentBTC: _N(currentBTCAmount, 8),\\n initPrice: _N(initPrice, 2),\\n currentPrice: _N(currentPrice, 2),\\n initTotalValue: _N(initTotalValue, 2),\\n currentTotalValue: _N(currentTotalValue, 2),\\n totalProfit: _N(totalProfit, 2),\\n totalProfitPercent: totalProfitPercent + '%',\\n \\n totalDecisions: totalDecisions,\\n approveCount: approveCount,\\n rejectCount: rejectCount,\\n currentDecision: '✗ Manual Rejection',\\n \\n rejected: true,\\n tradeExecuted: false,\\n tradeSuccess: true,\\n aiDecision: rejectResult.decision,\\n aiPlannedAmount: rejectResult.plannedAmount,\\n actualAmount: 0,\\n tradeQuantity: 0,\\n tradePrice: rejectResult.price\\n }\\n}];\\n\",\"notice\":\"\"},\"type\":\"n8n-nodes-base.code\",\"typeVersion\":2,\"position\":[2480,-496],\"id\":\"8564d51b-7200-4a2c-b78d-172686391bf6\",\"name\":\"Manual Trade Rejection\"},{\"parameters\":{\"mode\":\"runOnceForAllItems\",\"language\":\"javaScript\",\"jsCode\":\"// ========== Initialization Check ==========\\nif (_G('invoketime') === null) {\\n _G('invoketime', 0);\\n _G('STARTTIME', Date.now());\\n \\n const initAccount = exchange.GetAccount();\\n const ticker = exchange.GetTicker();\\n const initBTCAmount = initAccount.Stocks || 0;\\n const initUSDTBalance = initAccount.Balance || 0;\\n const initPrice = ticker.Last;\\n const initBTCValue = initBTCAmount * initPrice;\\n const initTotalValue = initUSDTBalance + initBTCValue;\\n \\n _G('initBTC', initBTCAmount);\\n _G('initUSDT', initUSDTBalance);\\n _G('initPrice', initPrice);\\n _G('initBTCValue', initBTCValue);\\n _G('initTotalValue', initTotalValue);\\n _G('approveCount', 0);\\n _G('rejectCount', 0);\\n _G('totalDecisions', 0);\\n \\n Log(`📊 Account Initialization: BTC=${_N(initBTCAmount, 8)}, USDT=${_N(initUSDTBalance, 2)}, Initial Price=$${_N(initPrice, 2)}, Initial Total Value=$${_N(initTotalValue, 2)}`);\\n}\\n\\n_G('totalDecisions', _G('totalDecisions') + 1);\\n_G('approveCount', _G('approveCount') + 1);\\n\\nconst invoketime = _G('invoketime') + 1;\\n_G('invoketime', invoketime);\\n\\nconst duringtime = Math.floor((Date.now() - _G('STARTTIME')) / 60000);\\n\\nconst currentAccount = exchange.GetAccount();\\nconst currentTicker = exchange.GetTicker();\\nconst currentBTCAmount = currentAccount.Stocks || 0;\\nconst currentUSDTBalance = currentAccount.Balance || 0;\\nconst currentPrice = currentTicker.Last;\\nconst currentBTCValue = currentBTCAmount * currentPrice;\\nconst currentTotalValue = currentUSDTBalance + currentBTCValue;\\n\\nconst initBTC = _G('initBTC');\\nconst initUSDT = _G('initUSDT');\\nconst initPrice = _G('initPrice');\\nconst initBTCValue = _G('initBTCValue');\\nconst initTotalValue = _G('initTotalValue');\\n\\nconst totalProfit = currentTotalValue - initTotalValue;\\nconst totalProfitPercent = initTotalValue > 0 ? ((totalProfit / initTotalValue) * 100).toFixed(2) : '0.00';\\n\\nLogProfit(totalProfit, \\\"&\\\");\\n\\nconst approveCount = _G('approveCount');\\nconst rejectCount = _G('rejectCount');\\nconst totalDecisions = _G('totalDecisions');\\n\\n// ========== Configuration Parameters ==========\\nconst TRADE_SYMBOL = $vars.contract || 'BTC';\\nconst TRADING_PAIR = `${TRADE_SYMBOL}_USDT`;\\n\\n// ========== Utility Functions ==========\\n\\nfunction parseDecision(decision) {\\n try {\\n if (Array.isArray(decision) && decision.length > 0) {\\n return decision[0];\\n }\\n return decision;\\n } catch (e) {\\n Log(\\\"❌ Decision parsing failed:\\\", e.message);\\n return null;\\n }\\n}\\n\\nfunction parseDecisionType(decision) {\\n const text = decision.toLowerCase();\\n \\n const decisionMap = {\\n 'major increase': { action: 'buy', description: 'Major Position Increase', emoji: '🚀' },\\n 'moderate increase': { action: 'buy', description: 'Moderate Position Increase', emoji: '📈' },\\n 'minor increase': { action: 'buy', description: 'Minor Position Increase', emoji: '➕' },\\n 'standard investment': { action: 'buy', description: 'Standard Investment', emoji: '💰' },\\n 'hold position': { action: 'hold', description: 'Hold Position', emoji: '⏸️' },\\n 'pause and observe': { action: 'hold', description: 'Pause and Observe', emoji: '⏸️' },\\n 'no action': { action: 'hold', description: 'No Action', emoji: '⏸️' },\\n 'continue observing': { action: 'hold', description: 'Continue Observing', emoji: '⏸️' }\\n };\\n \\n for (const [key, value] of Object.entries(decisionMap)) {\\n if (text.includes(key)) {\\n return value;\\n }\\n }\\n \\n return { action: 'hold', description: 'Hold Position', emoji: '⏸️' };\\n}\\n\\n// ========== History Management ==========\\n\\nfunction saveDecisionRecord(decision, tradeInfo, executed) {\\n const history = _G('dca_history') || [];\\n \\n const now = new Date();\\n const year = now.getFullYear();\\n const month = String(now.getMonth() + 1).padStart(2, '0');\\n const day = String(now.getDate()).padStart(2, '0');\\n const hour = String(now.getHours()).padStart(2, '0');\\n const minute = String(now.getMinutes()).padStart(2, '0');\\n const second = String(now.getSeconds()).padStart(2, '0');\\n const formattedTime = `${year}-${month}-${day} ${hour}:${minute}:${second}`;\\n \\n const record = {\\n timestamp: now.toISOString(),\\n datetime: formattedTime,\\n symbol: TRADE_SYMBOL,\\n decision: decision.tradingDecision,\\n planned_amount_usd: decision.tradingAmount,\\n actual_amount_usd: tradeInfo.actualAmount || 0,\\n quantity: tradeInfo.quantity || 0,\\n price: tradeInfo.price,\\n executed: executed,\\n approved: true,\\n reason: decision.tradingRationale\\n };\\n \\n history.push(record);\\n _G('dca_history', history);\\n \\n return history;\\n}\\n\\nfunction getStrategyStats(history, currentPrice) {\\n if (!history || history.length === 0) {\\n return {\\n runtime: '-',\\n totalDecisions: 0,\\n executedCount: 0,\\n totalInvested: 0,\\n totalQuantity: 0,\\n avgPrice: 0,\\n currentValue: 0,\\n currentProfit: 0,\\n profitPercent: 0\\n };\\n }\\n \\n const symbolHistory = history.filter(r => r.symbol === TRADE_SYMBOL);\\n \\n if (symbolHistory.length === 0) {\\n return {\\n runtime: '-',\\n totalDecisions: 0,\\n executedCount: 0,\\n totalInvested: 0,\\n totalQuantity: 0,\\n avgPrice: 0,\\n currentValue: 0,\\n currentProfit: 0,\\n profitPercent: 0\\n };\\n }\\n \\n const startTime = new Date(symbolHistory[0].timestamp);\\n const now = new Date();\\n const runtimeHours = Math.floor((now - startTime) / (1000 * 60 * 60));\\n const runtimeDays = Math.floor(runtimeHours / 24);\\n \\n const executedRecords = symbolHistory.filter(r => r.executed);\\n const totalInvested = executedRecords.reduce((sum, r) => sum + (r.actual_amount_usd || 0), 0);\\n const totalQuantity = executedRecords.reduce((sum, r) => sum + (r.quantity || 0), 0);\\n const avgPrice = totalQuantity > 0 ? totalInvested / totalQuantity : 0;\\n const currentValue = totalQuantity * currentPrice;\\n const currentProfit = currentValue - totalInvested;\\n const profitPercent = totalInvested > 0 ? (currentProfit / totalInvested * 100) : 0;\\n \\n return {\\n runtime: runtimeDays > 0 ? `${runtimeDays}d${runtimeHours % 24}h` : `${runtimeHours}h`,\\n totalDecisions: symbolHistory.length,\\n executedCount: executedRecords.length,\\n totalInvested: totalInvested,\\n totalQuantity: totalQuantity,\\n avgPrice: avgPrice,\\n currentValue: currentValue,\\n currentProfit: currentProfit,\\n profitPercent: profitPercent\\n };\\n}\\n\\n// ========== Spot Buy Function ==========\\n\\nfunction executeSpotBuy(symbol, usdAmount, currentPrice) {\\n try {\\n exchange.SetCurrency(symbol);\\n \\n Log(`💰 Spot Buy: $${usdAmount}`);\\n \\n const orderId = exchange.Buy(-1, usdAmount);\\n \\n if (orderId) {\\n Sleep(2000);\\n \\n const order = exchange.GetOrder(orderId);\\n if (order) {\\n const actualQty = order.DealAmount || 0;\\n const avgPrice = order.AvgPrice || currentPrice;\\n const actualCost = order.DealAmount * order.AvgPrice || usdAmount;\\n \\n Log(`✅ Buy Successful: ${_N(actualQty, 6)} ${TRADE_SYMBOL} @ $${_N(avgPrice, 2)} (Cost $${_N(actualCost, 2)})`);\\n \\n return { \\n success: true, \\n orderId: orderId,\\n quantity: actualQty,\\n avgPrice: avgPrice,\\n actualCost: actualCost\\n };\\n } else {\\n const estimatedQty = usdAmount / currentPrice;\\n Log(`✅ Buy Successful (Estimated ${_N(estimatedQty, 6)} ${TRADE_SYMBOL})`);\\n \\n return { \\n success: true, \\n orderId: orderId,\\n quantity: estimatedQty,\\n avgPrice: currentPrice,\\n actualCost: usdAmount\\n };\\n }\\n } else {\\n Log(`❌ Buy Failed`);\\n return { success: false, error: \\\"Order submission failed\\\" };\\n }\\n } catch (e) {\\n Log(`❌ Buy Exception: ${e.message}`);\\n return { success: false, error: e.message };\\n }\\n}\\n\\n// ========== Table Generation (Simplified) ==========\\n\\nfunction generateAccountTable(initUSDT, currentUSDTBalance, initBTC, currentBTCAmount, initTotalValue, currentTotalValue, totalProfit, totalProfitPercent) {\\n const profitEmoji = totalProfit >= 0 ? \\\"🟢\\\" : \\\"🔴\\\";\\n \\n return {\\n type: \\\"table\\\", \\n title: `💼 Account Overview (${TRADE_SYMBOL})`,\\n cols: [\\\"Type\\\", \\\"Initial\\\", \\\"Current\\\", \\\"Profit Amount\\\", \\\"Profit Rate\\\"],\\n rows: [\\n [\\n \\\"USDT Balance\\\",\\n `$${_N(initUSDT, 2)}`,\\n `$${_N(currentUSDTBalance, 2)}`,\\n \\\"-\\\",\\n \\\"-\\\"\\n ],\\n [\\n `${TRADE_SYMBOL} Holdings`,\\n `${_N(initBTC, 8)}`,\\n `${_N(currentBTCAmount, 8)}`,\\n \\\"-\\\",\\n \\\"-\\\"\\n ],\\n [\\n \\\"Total Account Value\\\",\\n `$${_N(initTotalValue, 2)}`,\\n `$${_N(currentTotalValue, 2)}`,\\n `${profitEmoji} $${_N(totalProfit, 2)}`,\\n `${profitEmoji} ${totalProfitPercent}%`\\n ]\\n ]\\n };\\n}\\n\\nfunction generateDCATable(history, stats) {\\n const table = {\\n type: \\\"table\\\",\\n title: `📊 DCA Information (${TRADE_SYMBOL})`,\\n cols: [\\\"Time\\\", \\\"Decision\\\", \\\"Plan\\\", \\\"Price\\\", \\\"Rationale\\\", \\\"Status\\\"],\\n rows: []\\n };\\n \\n const symbolHistory = history.filter(r => r.symbol === TRADE_SYMBOL);\\n const recentHistory = symbolHistory.slice(-10);\\n \\n recentHistory.forEach(record => {\\n const timeStr = record.datetime;\\n let statusStr;\\n if (record.approved !== undefined) {\\n statusStr = record.approved ? \\\"✅ Approved\\\" : \\\"🚫 Rejected\\\";\\n } else {\\n statusStr = record.executed ? \\\"✅ Executed\\\" : \\\"⏸️ Skipped\\\";\\n }\\n \\n const planStr = record.executed ? `$${_N(record.actual_amount_usd, 0)}` : `$${_N(record.planned_amount_usd, 0)}`;\\n const priceStr = `$${_N(record.price, 0)}`;\\n const reasonStr = (record.reason || '').substring(0, 50);\\n \\n \\n table.rows.push([\\n timeStr,\\n record.decision,\\n planStr,\\n priceStr,\\n reasonStr,\\n statusStr\\n ]);\\n });\\n \\n table.rows.push([\\n `Runtime ${stats.runtime}`,\\n `Total ${stats.totalDecisions}`,\\n `Invested $${_N(stats.totalInvested, 0)}`,\\n `Avg Price $${_N(stats.avgPrice, 0)}`,\\n `${_N(stats.totalQuantity, 6)} ${TRADE_SYMBOL}`,\\n `Executed ${stats.executedCount}`\\n ]);\\n \\n return table;\\n}\\n\\n// ========== Main Logic ==========\\n\\nfunction main() {\\n const decision = parseDecision($node[\\\"AI Result Analysis\\\"].json);\\n \\n if (!decision) {\\n Log(\\\"❌ No valid decision obtained\\\");\\n return { json: { success: false, error: \\\"Invalid decision\\\" } };\\n }\\n \\n Log(\\\"=\\\".repeat(60));\\n Log(`📊 ${TRADE_SYMBOL} AI DCA Decision Analysis - Manual Approval`);\\n Log(\\\"=\\\".repeat(60));\\n Log(`💡 Decision: ${decision.tradingDecision}`);\\n Log(`💰 Amount: $${decision.tradingAmount}`);\\n Log(`📝 Rationale: ${decision.tradingRationale}...`);\\n Log(\\\"=\\\".repeat(60));\\n \\n const actionInfo = parseDecisionType(decision.tradingDecision);\\n Log(`🎯 ${actionInfo.emoji} ${actionInfo.description}`);\\n \\n exchange.SetCurrency(TRADING_PAIR);\\n \\n const ticker = exchange.GetTicker();\\n if (!ticker) {\\n Log(\\\"❌ Failed to get price\\\");\\n return { json: { success: false, error: \\\"Failed to get price\\\" } };\\n }\\n \\n const currentPrice = ticker.Last;\\n Log(`💵 Current Price: $${currentPrice}`);\\n \\n let executeResult = {\\n success: false,\\n executed: false,\\n orderId: null,\\n error: null\\n };\\n \\n let tradeInfo = {\\n price: currentPrice,\\n quantity: 0,\\n actualAmount: 0,\\n avgPrice: currentPrice\\n };\\n \\n if (actionInfo.action === 'buy' && decision.tradingAmount > 0) {\\n Log(`\\\\n🚀 Preparing to execute spot buy`);\\n \\n const result = executeSpotBuy(TRADING_PAIR, decision.tradingAmount, currentPrice);\\n \\n executeResult = {\\n ...result,\\n executed: result.success\\n };\\n \\n if (result.success) {\\n tradeInfo.quantity = result.quantity;\\n tradeInfo.actualAmount = result.actualCost || decision.tradingAmount;\\n tradeInfo.avgPrice = result.avgPrice || currentPrice;\\n }\\n \\n saveDecisionRecord(decision, tradeInfo, executeResult.executed);\\n } else {\\n Log(\\\"⏸️ Hold Position\\\");\\n executeResult.executed = false;\\n executeResult.success = true;\\n \\n saveDecisionRecord(decision, tradeInfo, false);\\n }\\n \\n const history = _G('dca_history') || [];\\n const stats = getStrategyStats(history, currentPrice);\\n \\n const accountTable = generateAccountTable(\\n initUSDT, currentUSDTBalance, initBTC, currentBTCAmount,\\n initTotalValue, currentTotalValue, totalProfit, totalProfitPercent\\n );\\n \\n const dcaTable = generateDCATable(history, stats);\\n \\n LogStatus(\\n '`' + JSON.stringify(accountTable) + '`\\\\n\\\\n' +\\n '`' + JSON.stringify(dcaTable) + '`'\\n );\\n \\n Log(\\\"\\\\n\\\" + \\\"=\\\".repeat(60));\\n Log(executeResult.executed ? \\\"✅ Trade execution completed\\\" : \\\"⏸️ No trade operation needed\\\");\\n Log(\\\"=\\\".repeat(60));\\n \\n return {\\n success: executeResult.success,\\n executed: executeResult.executed,\\n action: actionInfo.action,\\n decision: decision.tradingDecision,\\n plannedAmount: decision.tradingAmount,\\n actualAmount: tradeInfo.actualAmount,\\n quantity: tradeInfo.quantity,\\n price: currentPrice,\\n orderId: executeResult.orderId\\n };\\n}\\n\\nconst tradeResult = main();\\n\\nreturn [{\\n json: {\\n invoketime: invoketime,\\n duringtime: duringtime + ' minutes',\\n tradeSymbol: TRADE_SYMBOL,\\n \\n initUSDT: _N(initUSDT, 2),\\n currentUSDT: _N(currentUSDTBalance, 2),\\n initBTC: _N(initBTC, 8),\\n currentBTC: _N(currentBTCAmount, 8),\\n initPrice: _N(initPrice, 2),\\n currentPrice: _N(currentPrice, 2),\\n initTotalValue: _N(initTotalValue, 2),\\n currentTotalValue: _N(currentTotalValue, 2),\\n totalProfit: _N(totalProfit, 2),\\n totalProfitPercent: totalProfitPercent + '%',\\n \\n totalDecisions: totalDecisions,\\n approveCount: approveCount,\\n rejectCount: rejectCount,\\n currentDecision: '✓ Manual Approval',\\n \\n tradeExecuted: tradeResult.executed,\\n tradeSuccess: tradeResult.success,\\n tradeAction: tradeResult.action,\\n aiDecision: tradeResult.decision,\\n aiPlannedAmount: tradeResult.plannedAmount,\\n actualAmount: tradeResult.actualAmount,\\n tradeQuantity: tradeResult.quantity,\\n tradePrice: tradeResult.price,\\n orderId: tradeResult.orderId || '-'\\n }\\n}];\\n\",\"notice\":\"\"},\"type\":\"n8n-nodes-base.code\",\"typeVersion\":2,\"position\":[2480,-688],\"id\":\"36846b5d-8c6b-4923-9327-511f266473ad\",\"name\":\"DCA Trade Execution\"},{\"parameters\":{\"mode\":\"rules\",\"rules\":{\"values\":[{\"conditions\":{\"options\":{\"caseSensitive\":true,\"leftValue\":\"\",\"typeValidation\":\"strict\",\"version\":2},\"conditions\":[{\"leftValue\":\"={{ $json['tradingDecisionConfirm'] }}\",\"rightValue\":\"Yes\",\"operator\":{\"type\":\"string\",\"operation\":\"equals\"},\"id\":\"9c0a7b2e-58c3-4a34-af76-93c8ba3a7100\"}],\"combinator\":\"and\"},\"renameOutput\":false},{\"conditions\":{\"options\":{\"caseSensitive\":true,\"leftValue\":\"\",\"typeValidation\":\"strict\",\"version\":2},\"conditions\":[{\"id\":\"f2e69ae0-0dea-4654-84e8-881119a47f8e\",\"leftValue\":\"={{ $json['tradingDecisionConfirm'] }}\",\"rightValue\":\"No\",\"operator\":{\"type\":\"string\",\"operation\":\"equals\",\"name\":\"filter.operator.equals\"}}],\"combinator\":\"and\"},\"renameOutput\":false}]},\"looseTypeValidation\":false,\"options\":{}},\"type\":\"n8n-nodes-base.switch\",\"typeVersion\":3.2,\"position\":[2256,-592],\"id\":\"9e9e344b-49b1-4753-aece-409f4f6669b0\",\"name\":\"Decision Branch\"},{\"parameters\":{\"resume\":\"form\",\"formTitle\":\"Trading Decision Confirmation\",\"formDescription\":\"\",\"formFields\":{\"values\":[{\"fieldLabel\":\"tradingDecisionConfirm\",\"fieldType\":\"dropdown\",\"fieldOptions\":{\"values\":[{\"option\":\"Yes\"},{\"option\":\"No\"}]},\"multiselect\":false,\"requiredField\":false}]},\"pushNotifications\":true,\"autoPopup\":true,\"limitWaitTime\":true,\"limitType\":\"afterTimeInterval\",\"resumeAmount\":1,\"resumeUnit\":\"minutes\"},\"type\":\"n8n-nodes-base.wait\",\"typeVersion\":1.1,\"position\":[2032,-592],\"id\":\"72613e10-950a-4a05-839e-0038cc7f2823\",\"name\":\"Manual Decision Confirmation\"},{\"parameters\":{\"mode\":\"runOnceForAllItems\",\"language\":\"javaScript\",\"jsCode\":\"function parseAIOutput(output) {\\n try {\\n const cleaned = output.replace(/```[a-z]*\\\\n?/gi, '').trim();\\n const start = cleaned.indexOf('{');\\n const end = cleaned.lastIndexOf('}');\\n return JSON.parse(cleaned.substring(start, end + 1));\\n } catch (e) {\\n return {};\\n }\\n}\\n\\n\\nconst signals = parseAIOutput($input.first().json.output);\\n\\nreturn signals\",\"notice\":\"\"},\"type\":\"n8n-nodes-base.code\",\"typeVersion\":2,\"position\":[1808,-592],\"id\":\"144bae9a-b44c-4211-bedd-287859a2caf3\",\"name\":\"AI Result Analysis\"},{\"parameters\":{\"model\":{\"__rl\":true,\"value\":\"deepseek/deepseek-chat-v3.1\",\"mode\":\"list\",\"cachedResultName\":\"deepseek/deepseek-chat-v3.1\"}},\"type\":\"n8n-nodes-base.lmOpenAi\",\"typeVersion\":1,\"position\":[1504,-368],\"id\":\"d4a7deb4-d22e-4911-b5e4-56a5b6f37d06\",\"name\":\"DCA Decision Model\",\"credentials\":{\"openAiApi\":{\"id\":\"54d0b567-b3fc-4c6a-b6be-546e0b9cd83f\",\"name\":\"openrouter\"}}},{\"parameters\":{\"text\":\"=You are an experienced cryptocurrency quantitative trading fund management analyst. Please conduct a multi-dimensional comprehensive analysis based on the following technical indicators and market data, and provide this week's DCA trading decision.\\n\\n【Market Data Overview】\\n- Base DCA Amount: {{$vars.dcamoney }} USD\\n- Adjustable Range: 0-{{ $vars.dcamoney * 2 }} USD (0 indicates pause DCA)\\n\\n【Technical Indicator Data】\\n**RSI Relative Strength Index:**\\n{{ $json.RSI }}\\n\\n**MACD Trend Indicator:**\\n{{ $json.MACD_HIST }}\\n\\n**ATR Volatility:**\\n{{ $json[\\\"ATR\\\"] }}\\n\\n**OBV Money Flow:**\\n{{ $json[\\\"OBV\\\"] }}\\n\\n**Market Sentiment Analysis:**\\n{{ JSON.stringify($json['sentimentAnalysis']) }}\\n\\n【Analysis Requirements】\\nPlease evaluate comprehensively from the following dimensions:\\n\\n1. **Trend Strength Analysis**\\n - Assess MACD long/short status and trend strength\\n - Determine if in a clear uptrend/downtrend\\n - Identify early signals of trend reversal\\n\\n2. **Overbought/Oversold Assessment**\\n - Judge if market is overheated or panicked based on RSI\\n - Consider contrarian investment opportunities (increase position during panic)\\n - Note: Crypto markets may experience sustained overbought or oversold conditions, need to combine with other indicators\\n\\n3. **Volatility Risk Assessment**\\n - Analyze ATR volatility level and trend changes\\n - Consider reducing single investment amount during high volatility to spread risk\\n - May moderately increase investment during low volatility\\n - Assess market uncertainty level\\n\\n4. **Capital Flow Health**\\n - Whether OBV capital flow supports current price movement\\n - Judge volume-price divergence risk\\n - Analyze sustainability and strength of capital inflow/outflow\\n\\n5. **Market Sentiment Balance**\\n - Short-term vs long-term sentiment divergence or resonance\\n - Extreme panic often presents best accumulation opportunities\\n - Extreme euphoria requires calm consideration of pause\\n - Neutral sentiment maintains standard investment\\n\\n6. **Risk-Reward Ratio Assessment**\\n - Comprehensively assess current position building risk-reward ratio\\n - Consider long-term nature and safety of DCA strategy\\n - Balance chip accumulation with risk control\\n - Identify asymmetric opportunities (limited downside risk, huge upside potential)\\n\\n【DCA Investment Decision Principles】\\n- ✅ **Be greedy during panic and oversold conditions (major increase)** - Market panic is the best time to accumulate chips\\n- ✅ **Be active during pullbacks and corrections (moderate increase)** - Seize periodic lows\\n- ✅ **Persist during consolidation and uncertainty (standard investment)** - Maintain DCA discipline\\n- ⚠️ **Stay calm during euphoria and overbought conditions (pause and observe)** - Pause at extreme highs, wait for pullback\\n- ⚠️ **Flexible adjustment during high volatility** - Dynamically balance according to market conditions\\n- ⚠️ **Stay cautious during sustained capital outflow** - Avoid blind bottom fishing\\n\\n【Important Notes】\\n- Core of DCA strategy is long-term holding and cost smoothing, this strategy does not involve selling operations\\n- Profit-taking and exit should be executed in independent bull market top judgment modules\\n- Crypto markets are highly volatile, need to combine multiple indicators for comprehensive judgment, avoid single indicator misleading\\n- Pay attention to structural market changes and macroeconomic environment impact\\n\\n【Output Format Requirements】\\nPlease output strictly according to the following JSON format, do not include markdown code block markers:\\n\\n{\\n \\\"tradingDecision\\\": \\\"Major Increase/Moderate Increase/Standard Investment/Pause and Observe\\\",\\n \\\"tradingAmount\\\": 150,\\n \\\"tradingRationale\\\": \\\"Detailed explanation of your analysis logic, including comprehensive judgment of various indicators and decision rationale\\\"\\n}\\n\\n【Decision Option Explanations】\\n- **Major Increase ({{ $vars.dcamoney * 1.5 }}-{{ $vars.dcamoney * 2 }} USD)**: Market shows extreme panic or deep pullback, multiple indicators show oversold with reversal signs, excellent risk-reward ratio\\n- **Moderate Increase ({{ $vars.dcamoney * 1.2 }}-{{ $vars.dcamoney * 1.49 }} USD)**: Market in pullback adjustment period, indicators show some downward pressure but long-term trend healthy, suitable for increased investment\\n- **Standard Investment ({{ $vars.dcamoney }} USD)**: Market in consolidation or unclear trend state, maintain DCA discipline, avoid being affected by short-term volatility\\n- **Pause and Observe (0 USD)**: Market shows extreme euphoria or serious overbought, multiple indicators show high-level risk, or market structure deterioration requires waiting for better timing\\n\\n【Output Requirements】\\n- Trading Decision: Must be one of the four options above\\n- Trading Amount: Must be 0 or integer between {{ Math.round($vars.dcamoney * 0.5) }} to {{ $vars.dcamoney * 2 }}\\n- Trading Rationale: At least 200 words, clearly explain indicator weights and logical reasoning process, including:\\n * Current status and trend analysis of various technical indicators\\n * Mutual verification, resonance, or divergence phenomena between indicators\\n * Judgment of market cycle stage (bear market/consolidation/early bull/mid bull/late bull, etc.)\\n * Balance of risks and opportunities, including potential downside risk and upside space\\n * Final decision logical reasoning and confidence level\\n * Particular attention to risk points or opportunity points\\n\\nNow begin analysis and provide decision.\",\"options\":{}},\"type\":\"@n8n/n8n-nodes-langchain.agent\",\"typeVersion\":1,\"position\":[1408,-592],\"id\":\"594fc237-f546-4e28-a83d-6ec69a0ffc55\",\"name\":\"DCA Decision Analysis\",\"retryOnFail\":true,\"waitBetweenTries\":5000},{\"parameters\":{\"mode\":\"runOnceForAllItems\",\"language\":\"javaScript\",\"jsCode\":\"// Initialize containers\\nlet macdHistData = null;\\nlet rsiData = null;\\nlet atrData = null;\\nlet obvData = null;\\nlet sentimentData = null;\\n\\n// Counter for sequential identification\\nlet resultIndex = 0;\\n\\n// Loop over items\\nfor (const item of items) {\\n \\n // Sentiment indicators (with output field)\\n if (item.json.output) {\\n try {\\n // Clean markdown code block markers from output\\n const cleanOutput = item.json.output.replace(/```json\\\\n?|\\\\n?```/g, '').trim();\\n sentimentData = JSON.parse(cleanOutput);\\n } catch (e) {\\n sentimentData = item.json.output;\\n }\\n continue;\\n }\\n \\n // Process data with result field\\n if (item.json.result && Array.isArray(item.json.result)) {\\n const result = item.json.result;\\n \\n if (resultIndex === 0) {\\n // 1st: MACD (3D array: [DIF, DEA, HIST])\\n if (Array.isArray(result[0]) && result.length === 3) {\\n // 3D array, take HIST (index 2), filter null and take recent 30\\n const histArray = result[2].filter(v => v !== null);\\n macdHistData = histArray.slice(-30);\\n } else {\\n // Single dimension array fallback\\n const filtered = result.filter(v => v !== null);\\n macdHistData = filtered.slice(-30);\\n }\\n } else if (resultIndex === 1) {\\n // 2nd: RSI, filter null and take recent 30\\n const filtered = result.filter(v => v !== null);\\n rsiData = filtered.slice(-30);\\n } else if (resultIndex === 2) {\\n // 3rd: ATR, filter null and take recent 30\\n const filtered = result.filter(v => v !== null);\\n atrData = filtered.slice(-30);\\n } else if (resultIndex === 3) {\\n // 4th: OBV, filter null and take recent 30\\n const filtered = result.filter(v => v !== null);\\n obvData = filtered.slice(-30);\\n }\\n \\n resultIndex++;\\n }\\n}\\n\\n// Return result\\nreturn [{\\n json: {\\n \\\"MACD_HIST\\\": macdHistData,\\n \\\"RSI\\\": rsiData,\\n \\\"ATR\\\": atrData,\\n \\\"OBV\\\": obvData,\\n \\\"sentimentAnalysis\\\": sentimentData\\n }\\n}];\",\"notice\":\"\"},\"type\":\"n8n-nodes-base.code\",\"typeVersion\":2,\"position\":[1184,-592],\"id\":\"b7e56d88-2ac4-4509-bbda-1cc7d9c4b39a\",\"name\":\"Data Integration\"},{\"parameters\":{\"model\":{\"__rl\":true,\"value\":\"anthropic/claude-sonnet-4\",\"mode\":\"list\",\"cachedResultName\":\"anthropic/claude-sonnet-4\"}},\"type\":\"n8n-nodes-base.lmOpenAi\",\"typeVersion\":1,\"position\":[656,16],\"id\":\"c2284296-dd86-4851-b9b7-2d45628bc30e\",\"name\":\"Sentiment Analysis Model\",\"credentials\":{\"openAiApi\":{\"id\":\"54d0b567-b3fc-4c6a-b6be-546e0b9cd83f\",\"name\":\"openrouter\"}}},{\"parameters\":{\"text\":\"=You are a highly intelligent sentiment analyzer specialized in analyzing **cryptocurrency market sentiment and market expectations**. Please conduct cryptocurrency sentiment analysis for coin {{$vars.contract}} using the following two-part method on the provided text:\\n\\n**Short-term Sentiment Analysis:**\\n\\n* Assess immediate market reactions, including price volatility, social media heat, news events, on-chain data, and technical indicator signals;\\n* Determine overall market tendency: \\\"Positive\\\", \\\"Neutral\\\", or \\\"Negative\\\";\\n* Calculate a numerical sentiment score between **-1 (extremely negative)** and **1 (extremely positive)**;\\n* Provide concise reasoning for short-term sentiment, focusing on **latest market movements, trader behavior, news events, or technical trends**.\\n\\n**Long-term Sentiment Analysis:**\\n\\n* Assess long-term prospects of the crypto asset, including fundamentals, development progress, market adoption, macroeconomic and regulatory environment;\\n* Determine overall sentiment category: \\\"Positive\\\", \\\"Neutral\\\", or \\\"Negative\\\";\\n* Calculate a long-term sentiment score between **-1 (extremely negative)** and **1 (extremely positive)**;\\n* Provide detailed reasoning for long-term sentiment, focusing on **project potential, market structure, policy trends, and institutional participation**.\\n\\nOutput must be a strictly formatted JSON object containing two keys: \\\"shortTermSentiment\\\" and \\\"longTermSentiment\\\".\\nEach key's value is an object containing the following three fields: \\\"category\\\", \\\"score\\\", \\\"rationale\\\".\\nDo not output any additional text.\\n\\n**Output Example:**\\n\\n```json\\n{\\n \\\"shortTermSentiment\\\": {\\n \\\"category\\\": \\\"Positive\\\",\\n \\\"score\\\": 0.7,\\n \\\"rationale\\\": \\\"...\\\"\\n },\\n \\\"longTermSentiment\\\": {\\n \\\"category\\\": \\\"Neutral\\\",\\n \\\"score\\\": 0.0,\\n \\\"rationale\\\": \\\"...\\\"\\n }\\n}\\n```\\n\\n**Now, please analyze the following cryptocurrency market-related text and generate JSON output conforming to the above format:**\\n{{ $json.text }}\\n\",\"options\":{}},\"type\":\"@n8n/n8n-nodes-langchain.agent\",\"typeVersion\":1,\"position\":[560,-208],\"id\":\"7f936565-162c-4131-8008-e49af06f2919\",\"name\":\"AI Sentiment Analysis\",\"retryOnFail\":true,\"waitBetweenTries\":5000},{\"parameters\":{\"endpointUrl\":\"https://mcp.alphavantage.co/mcp?apikey='HCTH32FPOI6UPF66'\",\"authentication\":\"none\",\"tool\":\"NEWS_SENTIMENT\",\"tickers\":\"=CRYPTO:{{$vars.contract}}\"},\"type\":\"@n8n/n8n-nodes-langchain.mcpClient\",\"typeVersion\":1.1,\"position\":[336,-112],\"id\":\"0c79252c-bc23-4603-9e8e-ddf5b65f4f67\",\"name\":\"Crypto News Retrieval\"},{\"parameters\":{\"operation\":\"OBV\",\"inReal\":\"={{ $json.result }}\",\"inPriceV\":\"[]\"},\"type\":\"n8n-nodes-base.ta\",\"typeVersion\":1,\"position\":[656,-400],\"id\":\"7a9cbd3e-a7f3-44db-90d7-75faf7d03645\",\"name\":\"OBV\"},{\"parameters\":{\"operation\":\"ATR\",\"inReal\":\"={{ $json.result }}\",\"optInTimePeriod\":14},\"type\":\"n8n-nodes-base.ta\",\"typeVersion\":1,\"position\":[656,-592],\"id\":\"d89b6aa5-095d-49c7-833b-1566c5a85f0e\",\"name\":\"ATR\"},{\"parameters\":{\"operation\":\"RSI\",\"inReal\":\"={{ $json.result }}\",\"optInTimePeriod\":14},\"type\":\"n8n-nodes-base.ta\",\"typeVersion\":1,\"position\":[656,-784],\"id\":\"9173f360-862c-4603-ad6b-678f088b218a\",\"name\":\"RSI\"},{\"parameters\":{\"operation\":\"MACD\",\"inReal\":\"={{ $json.result }}\",\"optInFastPeriod\":12,\"optInSlowPeriod\":26,\"optInSignalPeriod\":9},\"type\":\"n8n-nodes-base.ta\",\"typeVersion\":1,\"position\":[656,-976],\"id\":\"3e64f173-9ffd-489e-84bb-8d97e6b12c78\",\"name\":\"MACD\"},{\"parameters\":{\"mode\":\"append\",\"numberInputs\":5},\"type\":\"n8n-nodes-base.merge\",\"typeVersion\":3.2,\"position\":[960,-640],\"id\":\"2027a15d-bf95-4b96-b16d-1ef2e8cbb0ee\",\"name\":\"Merge\"},{\"parameters\":{\"operation\":\"getRecords\",\"exchange\":0,\"symbol\":{\"__rl\":true,\"value\":\"={{$vars.contract}}_USDT\",\"mode\":\"id\"},\"period\":86400,\"limit\":100},\"type\":\"n8n-nodes-base.marketInfo\",\"typeVersion\":1,\"position\":[336,-688],\"id\":\"2170f346-eb3a-4848-a725-f7521a559056\",\"name\":\"Market Information\"},{\"parameters\":{\"notice\":\"\",\"rule\":{\"interval\":[{\"field\":\"minutes\",\"minutesInterval\":5}]}},\"type\":\"n8n-nodes-base.scheduleTrigger\",\"typeVersion\":1.2,\"position\":[112,-448],\"id\":\"e0957a91-4232-46ea-8a2d-e1f39e3fb27d\",\"name\":\"Schedule Trigger\"}],\"pinData\":{},\"connections\":{\"AI Model\":{\"ai_languageModel\":[[{\"node\":\"MCP Operation Executor\",\"type\":\"ai_languageModel\",\"index\":0}]]},\"MCP Operation Executor\":{\"main\":[[{\"node\":\"Telegram Message Sender\",\"type\":\"main\",\"index\":0}]]},\"Telegram Message Processor\":{\"main\":[[{\"node\":\"MCP Operation Executor\",\"type\":\"main\",\"index\":0}]]},\"MCP Client\":{\"ai_tool\":[[{\"node\":\"MCP Operation Executor\",\"type\":\"ai_tool\",\"index\":0}]]},\"Telegram Trigger\":{\"main\":[[{\"node\":\"Telegram Message Processor\",\"type\":\"main\",\"index\":0}]]},\"Decision Branch\":{\"main\":[[{\"node\":\"DCA Trade Execution\",\"type\":\"main\",\"index\":0}],[{\"node\":\"Manual Trade Rejection\",\"type\":\"main\",\"index\":0}]]},\"Manual Decision Confirmation\":{\"main\":[[{\"node\":\"Decision Branch\",\"type\":\"main\",\"index\":0}]]},\"AI Result Analysis\":{\"main\":[[{\"node\":\"Manual Decision Confirmation\",\"type\":\"main\",\"index\":0}]]},\"DCA Decision Model\":{\"ai_languageModel\":[[{\"node\":\"DCA Decision Analysis\",\"type\":\"ai_languageModel\",\"index\":0}]]},\"DCA Decision Analysis\":{\"main\":[[{\"node\":\"AI Result Analysis\",\"type\":\"main\",\"index\":0}]]},\"Data Integration\":{\"main\":[[{\"node\":\"DCA Decision Analysis\",\"type\":\"main\",\"index\":0}]]},\"Sentiment Analysis Model\":{\"ai_languageModel\":[[{\"node\":\"AI Sentiment Analysis\",\"type\":\"ai_languageModel\",\"index\":0}]]},\"AI Sentiment Analysis\":{\"main\":[[{\"node\":\"Merge\",\"type\":\"main\",\"index\":4}]]},\"Crypto News Retrieval\":{\"main\":[[{\"node\":\"AI Sentiment Analysis\",\"type\":\"main\",\"index\":0}]]},\"OBV\":{\"main\":[[{\"node\":\"Merge\",\"type\":\"main\",\"index\":3}]]},\"ATR\":{\"main\":[[{\"node\":\"Merge\",\"type\":\"main\",\"index\":2}]]},\"RSI\":{\"main\":[[{\"node\":\"Merge\",\"type\":\"main\",\"index\":1}]]},\"MACD\":{\"main\":[[{\"node\":\"Merge\",\"type\":\"main\",\"index\":0}]]},\"Merge\":{\"main\":[[{\"node\":\"Data Integration\",\"type\":\"main\",\"index\":0}]]},\"Market Information\":{\"main\":[[{\"node\":\"OBV\",\"type\":\"main\",\"index\":0},{\"node\":\"ATR\",\"type\":\"main\",\"index\":0},{\"node\":\"RSI\",\"type\":\"main\",\"index\":0},{\"node\":\"MACD\",\"type\":\"main\",\"index\":0}]]},\"Schedule Trigger\":{\"main\":[[{\"node\":\"Crypto News Retrieval\",\"type\":\"main\",\"index\":0},{\"node\":\"Market Information\",\"type\":\"main\",\"index\":0}]]}},\"active\":false,\"settings\":{\"timezone\":\"Asia/Shanghai\",\"executionOrder\":\"v1\"},\"tags\":[],\"meta\":{\"templateCredsSetupCompleted\":true},\"credentials\":{},\"id\":\"a10fa198-f87f-4509-9a4a-9827a76a2371\",\"plugins\":{},\"mcpClients\":{\"NEWS_SENTIMENT\":{\"name\":\"NEWS_SENTIMENT\",\"description\":\"Returns live and historical market news & sentiment data from premier news outlets worldwide.\",\"properties\":[{\"displayName\":\"tickers\",\"name\":\"tickers\",\"type\":\"string\",\"description\":\"Stock/crypto/forex symbols to filter articles. Example: \\\"IBM\\\" or \\\"COIN,CRYPTO:BTC,FOREX:USD\\\".\",\"displayOptions\":{\"show\":{\"tool\":[\"NEWS_SENTIMENT\"]}},\"placeholder\":\"Enter tickers\"},{\"displayName\":\"topics\",\"name\":\"topics\",\"type\":\"string\",\"description\":\"News topics to filter by. Example: \\\"technology\\\" or \\\"technology,ipo\\\".\",\"displayOptions\":{\"show\":{\"tool\":[\"NEWS_SENTIMENT\"]}},\"placeholder\":\"Enter topics\"},{\"displayName\":\"time_from\",\"name\":\"time_from\",\"type\":\"string\",\"description\":\"Start time range in YYYYMMDDTHHMM format. Example: \\\"20220410T0130\\\".\",\"displayOptions\":{\"show\":{\"tool\":[\"NEWS_SENTIMENT\"]}},\"placeholder\":\"Enter time_from\"},{\"displayName\":\"time_to\",\"name\":\"time_to\",\"type\":\"string\",\"description\":\"End time range in YYYYMMDDTHHMM format. Defaults to current time if time_from specified.\",\"displayOptions\":{\"show\":{\"tool\":[\"NEWS_SENTIMENT\"]}},\"placeholder\":\"Enter time_to\"},{\"displayName\":\"sort\",\"name\":\"sort\",\"type\":\"string\",\"description\":\"Sort order - \\\"LATEST\\\" (default), \\\"EARLIEST\\\", or \\\"RELEVANCE\\\".\",\"displayOptions\":{\"show\":{\"tool\":[\"NEWS_SENTIMENT\"]}},\"placeholder\":\"Enter sort\"},{\"displayName\":\"limit\",\"name\":\"limit\",\"type\":\"number\",\"description\":\"Number of results to return. Default 50, max 1000.\",\"displayOptions\":{\"show\":{\"tool\":[\"NEWS_SENTIMENT\"]}}}]}}},\"startNodes\":[],\"triggerToStartFrom\":{\"name\":\"Telegram Trigger\"}}"}