app.js

var envConfig = { cloudEnvId: 'YOUR_CLOUD_ENV_ID' };
try { envConfig = require('./env.js'); } catch (e) {}

App({
  globalData: {
    funds: [],
    groups: [],
    groupMap: {},  // { fundCode: groupId }
    chickAssets: {}
  },

  onLaunch: function() {
    var self = this;
    if (wx.cloud) {
      wx.cloud.init({
        env: envConfig.cloudEnvId,
        traceUser: true
      });
    }
    this.getChickAssets().then(function(urls) {
      self.preloadNavAssets(urls);
    });
  },


  // ============ 小鸡插画（云存储） ============

  getChickAssets: function() {
    var self = this;
    var cache = {};
    try { cache = wx.getStorageSync('chick_assets_cache') || {}; } catch (e) {}
    var needKeys = ['empty', 'search', 'error', 'ai', 'navFund', 'navMarket', 'navDiscover'];
    var cacheReady = cache.fileIds && cache.v === 5 && cache.expireAt > Date.now();
    if (cacheReady) {
      for (var i = 0; i < needKeys.length; i++) {
        if (!cache.fileIds[needKeys[i]]) { cacheReady = false; break; }
      }
    }
    if (cacheReady) {
      self.globalData.chickAssets = cache.fileIds;
      return Promise.resolve(cache.fileIds);
    }

    var p = self.globalData._chickAssetsPromise;
    if (p) return p;

    p = wx.cloud.callFunction({ name: 'chickAssets' }).then(function(res) {
      var data = (res.result && res.result.assets) || {};
      if (Object.keys(data).length === 0) {
        data = (res.result && res.result.urls) || {};
      }
      var save = { fileIds: data, v: 5, expireAt: Date.now() + 90 * 60 * 1000 };
      try { wx.setStorageSync('chick_assets_cache', save); } catch (e) {}
      self.globalData.chickAssets = data;
      return data;
    }).catch(function() {
      return self.globalData.chickAssets || {};
    });

    self.globalData._chickAssetsPromise = p;
    p.then(function() { self.globalData._chickAssetsPromise = null; },
           function() { self.globalData._chickAssetsPromise = null; });
    return p;
  },

  preloadNavAssets: function(urls) {
    if (!urls) return;
    ['navFund', 'navMarket', 'navDiscover'].forEach(function(key) {
      var src = urls[key];
      if (!src) return;
      wx.getImageInfo({
        src: src,
        complete: function() {}
      });
    });
  },


  // ============ 云同步 ============

  _loadSyncMeta: function() {
    try { return wx.getStorageSync('_sync_meta') || {}; } catch (e) { return {}; }
  },

  _saveSyncMeta: function(meta) {
    wx.setStorageSync('_sync_meta', meta);
  },

  _touch: function(category) {
    var meta = this._loadSyncMeta();
    var now = Date.now();
    var last = meta._seq || 0;
    if (now <= last) now = last + 1;
    meta._seq = now;
    meta[category] = now;
    this._saveSyncMeta(meta);
    return now;
  },

  getLastSyncTime: function() {
    var meta = this._loadSyncMeta();
    return meta._lastSync || 0;
  },

  _markSynced: function() {
    var meta = this._loadSyncMeta();
    meta._lastSync = Date.now();
    this._saveSyncMeta(meta);
  },

  prepareSyncData: function() {
    var meta = this._loadSyncMeta();
    var now = Date.now();
    var codes = this.loadCodes();
    var types = this.loadFundTypes();
    var fundList = [];
    for (var i = 0; i < codes.length; i++) {
      var c = codes[i];
      fundList.push({ code: c, type: types[c] || 'watch', updatedAt: meta.fundTypes || meta.fundCodes || now });
    }
    var rawGroups = this.loadGroups();
    var groups = [];
    for (var j = 0; j < rawGroups.length; j++) {
      groups.push({ groupId: rawGroups[j].id, name: rawGroups[j].name, updatedAt: meta.groups || now });
    }
    var rawMap = this.loadGroupMap();
    var groupMap = [];
    var mk = Object.keys(rawMap);
    for (var k = 0; k < mk.length; k++) groupMap.push({ fundCode: mk[k], groupId: rawMap[mk[k]], updatedAt: meta.groupMap || now });
    var allTrades = {};
    try { allTrades = wx.getStorageSync('fund_trades') || {}; } catch (e) {}
    var trades = [];
    var tk = Object.keys(allTrades);
    for (var t = 0; t < tk.length; t++) {
      var list = allTrades[tk[t]] || [];
      for (var u = 0; u < list.length; u++) { var tr = list[u]; tr.tradeId = tr.id; delete tr.id; tr.fundCode = tk[t]; tr.updatedAt = meta.trades || now; trades.push(tr); }
    }
    var rawOv = this.loadPositionOverrides();
    var overrides = [];
    var ok = Object.keys(rawOv);
    for (var o = 0; o < ok.length; o++) {
      var ov = rawOv[ok[o]];
      if (ov) overrides.push({ fundCode: ok[o], marketValue: ov.marketValue, profit: ov.profit, holdingDays: ov.holdingDays, updatedAt: meta.overrides || now });
    }
    console.log('prepareSyncData groups sample:', groups.length > 0 ? JSON.stringify(groups[0]) : 'empty');
    return { fundList: fundList, groups: groups, groupMap: groupMap, trades: trades, overrides: overrides };
  },

  applySyncData: function(data) {
    var fl = data.fundList || [];
    var codes = [], types = {};
    for (var i = 0; i < fl.length; i++) { codes.push(fl[i].code); types[fl[i].code] = fl[i].type || 'watch'; }
    this.saveCodes(codes);
    this.saveFundTypes(types);
    var gl = data.groups || [];
    var cg = [];
    for (var j = 0; j < gl.length; j++) cg.push({ id: gl[j].groupId || gl[j].id, name: gl[j].name });
    this.saveGroups(cg);
    var gml = data.groupMap || [];
    var gm = {};
    for (var k = 0; k < gml.length; k++) gm[gml[k].fundCode] = gml[k].groupId;
    this.saveGroupMap(gm);
    var tl = data.trades || [];
    var tbc = {};
    for (var t = 0; t < tl.length; t++) {
      var tr = tl[t], fc = tr.fundCode;
      if (!tbc[fc]) tbc[fc] = [];
      tbc[fc].push({ id: tr.tradeId || tr.id, date: tr.date, type: tr.type, shares: tr.shares, amount: tr.amount, nav: tr.nav, isBefore3pm: tr.isBefore3pm });
    }
    wx.setStorageSync('fund_trades', tbc);
    var ol = data.overrides || [];
    var om = {};
    for (var o = 0; o < ol.length; o++) { var ov = ol[o]; om[ov.fundCode] = { marketValue: ov.marketValue, profit: ov.profit, holdingDays: ov.holdingDays }; }
    this.savePositionOverrides(om);
    this._markSynced();
  },

  _doSync: function(data, silent) {
    var self = this;
    var p = wx.cloud.callFunction({ name: 'sync', data: { data: data } }).then(function(res) {
      if (res.result && res.result.success) { self.applySyncData(res.result.data); return { ok: true, time: new Date() }; }
      var errs = (res.result && res.result.errors) || [];
      return { ok: false, error: errs.length > 0 ? errs.join('; ') : '同步返回异常' };
    }).catch(function(err) { return { ok: false, error: err.message || '网络错误' }; });
    return silent ? p.catch(function(){}) : p;
  },

  syncData: function() {
    var self = this;
    var data = self.prepareSyncData();
    return self._doSync(data);
  },

  // 数据变更后静默推送云端
  pushToCloud: function() {
    var data = this.prepareSyncData();
    return this._doSync(data, true);
  },


  // ============ 基金代码存储 ============

  loadCodes: function() {
    try { return wx.getStorageSync('fund_codes') || []; } catch (e) { return []; }
  },

  saveCodes: function(codes) {
    wx.setStorageSync('fund_codes', codes);
    this._touch('fundCodes');
  },

  // ============ 分组存储 ============

  loadGroups: function() {
    try {
      var groups = wx.getStorageSync('fund_groups') || [];
      var fixed = false;
      for (var i = 0; i < groups.length; i++) {
        if (!groups[i].id) {
          groups[i].id = 'g_' + Date.now() + '_' + i;
          fixed = true;
        }
      }
      if (fixed) { wx.setStorageSync('fund_groups', groups); }
      return groups;
    } catch (e) { return []; }
  },

  saveGroups: function(groups) {
    wx.setStorageSync('fund_groups', groups);
    this._touch('groups');
    this.globalData.groups = groups;
  },

  loadGroupMap: function() {
    try { return wx.getStorageSync('fund_group_map') || {}; } catch (e) { return {}; }
  },

  saveGroupMap: function(map) {
    wx.setStorageSync('fund_group_map', map);
    this._touch('groupMap');
    this.globalData.groupMap = map;
  },

  addGroup: function(name) {
    var groups = this.globalData.groups;
    var id = 'g_' + Date.now();
    groups.push({ id: id, name: name });
    this.saveGroups(groups);
    return id;
  },

  renameGroup: function(groupId, newName) {
    var groups = this.globalData.groups;
    for (var i = 0; i < groups.length; i++) {
      if (groups[i].id === groupId) { groups[i].name = newName; break; }
    }
    this.saveGroups(groups);
  },

  deleteGroup: function(groupId) {
    var groups = this.globalData.groups;
    var map = this.globalData.groupMap;
    Object.keys(map).forEach(function(code) {
      if (map[code] === groupId) delete map[code];
    });
    this.saveGroupMap(map);
    this.saveGroups(groups.filter(function(g) { return g.id !== groupId; }));
  },

  setFundGroup: function(fundCode, groupId) {
    var map = this.globalData.groupMap;
    if (groupId) {
      map[fundCode] = groupId;
    } else {
      delete map[fundCode];
    }
    this.saveGroupMap(map);
  },

  // ============ 基金类型 (持仓 position / 自选 watch) ============

  loadFundTypes: function() {
    try { return wx.getStorageSync('fund_types') || {}; } catch (e) { return {}; }
  },

  saveFundTypes: function(types) {
    wx.setStorageSync('fund_types', types);
    this._touch('fundTypes');
  },

  setFundType: function(fundCode, type) {
    var types = this.loadFundTypes();
    types[fundCode] = type;
    this.saveFundTypes(types);
  },

  getFundType: function(fundCode) {
    var types = this.loadFundTypes();
    return types[fundCode] || 'watch';
  },

  // ============ 交易记录 & 盈亏 ============

  loadTrades: function(code) {
    try {
      var all = wx.getStorageSync('fund_trades') || {};
      return all[code] || [];
    } catch (e) { return []; }
  },

  saveTrades: function(code, trades) {
    var all = {};
    try { all = wx.getStorageSync('fund_trades') || {}; } catch (e) {}
    all[code] = trades;
    wx.setStorageSync('fund_trades', all);
    this._touch('trades');
  },

  addTrade: function(code, trade) {
    var trades = this.loadTrades(code);
    trades.push(trade);
    this.saveTrades(code, trades);
    return trades;
  },

  deleteTrade: function(code, index) {
    var trades = this.loadTrades(code);
    trades.splice(index, 1);
    this.saveTrades(code, trades);
    return trades;
  },

  calcProfitLoss: function(code, nav) {
    var trades = this.loadTrades(code);
    var totalShares = 0;
    var totalCost = 0;
    for (var i = 0; i < trades.length; i++) {
      var t = trades[i];
      if (t.type === 'buy') {
        totalShares += t.shares;
        totalCost += t.amount;
      } else if (t.type === 'sell') {
        totalShares -= t.shares;
        totalCost -= t.amount;
      }
    }
    var avgCost = totalShares > 0 ? totalCost / totalShares : 0;
    var marketValue = totalShares * nav;
    var profit = marketValue - totalCost;
    var profitPct = totalCost > 0 ? (profit / totalCost) * 100 : 0;
    return {
      shares: totalShares, cost: totalCost, avgCost: avgCost,
      marketValue: marketValue, profit: profit, profitPct: profitPct,
      holdingDays: this.calcHoldingDays(code)
    };
  },

  calcHoldingDays: function(code) {
    var trades = this.loadTrades(code);
    if (trades.length === 0) return 0;
    var earliestEffective = null;
    for (var i = 0; i < trades.length; i++) {
      var t = trades[i];
      if (t.type !== 'buy') continue;
      var parts = t.date.split('-');
      var buyDate = new Date(parseInt(parts[0]), parseInt(parts[1]) - 1, parseInt(parts[2]));
      var offset = (t.isBefore3pm !== false) ? 1 : 2;
      var effective = new Date(buyDate.getTime() + offset * 86400000);
      if (!earliestEffective || effective < earliestEffective) {
        earliestEffective = effective;
      }
    }
    if (!earliestEffective) return 0;
    var today = new Date();
    today.setHours(0, 0, 0, 0);
    earliestEffective.setHours(0, 0, 0, 0);
    var diff = Math.floor((today.getTime() - earliestEffective.getTime()) / 86400000);
    return Math.max(0, diff);
  },

  // ============ 持仓金额/收益/天数 手动覆盖 ============

  loadPositionOverrides: function() {
    try { return wx.getStorageSync('position_overrides') || {}; } catch (e) { return {}; }
  },

  savePositionOverrides: function(overrides) {
    wx.setStorageSync('position_overrides', overrides);
    this._touch('overrides');
  },

  getPosOverride: function(code) {
    var all = this.loadPositionOverrides();
    return all[code] || null;
  },

  setPosOverride: function(code, override) {
    var all = this.loadPositionOverrides();
    if (!override) {
      delete all[code];
    } else {
      all[code] = override;
    }
    this.savePositionOverrides(all);
  },

  applyPosOverrides: function(code, nav, pl) {
    var ov = this.getPosOverride(code);
    if (!ov) return pl;
    var marketValue = ov.marketValue;
    var profit = ov.profit;
    var cost = marketValue - profit;
    var profitPct = cost > 0 ? (profit / cost) * 100 : 0;
    var avgCost = nav > 0 ? cost / (marketValue / nav) : 0;
    if (isNaN(avgCost) || !isFinite(avgCost)) avgCost = 0;
    return {
      shares: nav > 0 ? marketValue / nav : pl.shares,
      cost: cost,
      avgCost: avgCost,
      marketValue: marketValue,
      profit: profit,
      profitPct: profitPct,
      override: true,
      holdingDays: ov.holdingDays || 0
    };
  },

  // ============ 聚合全部持仓总览 ============

  calcPortfolio: function(funds) {
    var totalCost = 0;
    var totalMarket = 0;
    var totalDailyProfit = 0;
    var list = [];
    for (var i = 0; i < funds.length; i++) {
      var f = funds[i];
      var type = this.getFundType(f.code);
      if (type !== 'position') continue;
      var nav = parseFloat(f.nav) || 0;
      if (nav <= 0) continue;
      var pl = this.calcProfitLoss(f.code, nav);
      pl = this.applyPosOverrides(f.code, nav, pl);
      if (pl.shares <= 0) continue;
      totalCost += pl.cost;
      totalMarket += pl.marketValue;
      // 当日持仓收益：当日净值变动带来的持有收益变化
      var dailyPct = parseFloat(f.changePct) || 0;
      var dailyProfit = pl.marketValue * dailyPct / (100 + dailyPct);
      pl.dailyProfit = dailyProfit;
      totalDailyProfit += dailyProfit;
      list.push({ code: f.code, name: f.name, nav: nav, pl: pl });
    }
    var totalProfit = totalMarket - totalCost;
    var totalPct = totalCost > 0 ? (totalProfit / totalCost) * 100 : 0;
    return { totalCost: totalCost, totalMarket: totalMarket, totalProfit: totalProfit,
      totalPct: totalPct, totalDailyProfit: totalDailyProfit, items: list };
  },

  // ============ API ============

  callApi: function(type, code, params) {
    var data = { type: type, code: code };
    if (params) {
      Object.keys(params).forEach(function(k) { data[k] = params[k]; });
    }
    return wx.cloud.callFunction({
      name: 'fundApi',
      data: data
    }).then(function(res) { return res.result; });
  },

  searchFund: function(code) {
    return this.callApi('search', code).then(function(data) {
      var items = (data.QuotationCodeTable && data.QuotationCodeTable.Data) || [];
      var fundItems = [];
      for (var i = 0; i < items.length; i++) {
        if (items[i].Classify === 'OTCFUND' || items[i].SecurityTypeName === '基金') {
          fundItems.push(items[i]);
        }
      }
      if (fundItems.length > 0) {
        return { code: code, name: fundItems[0].Name, quoteId: fundItems[0].QuoteID };
      }
      return null;
    });
  },

  fetchNav: function(code) {
    return this.callApi('nav', code).then(function(data) {
      var list = (data.Data && data.Data.LSJZList) || [];
      if (list.length > 0) {
        return {
          nav: parseFloat(list[0].DWJZ),
          changePct: parseFloat(list[0].JZZZL),
          date: list[0].FSRQ
        };
      }
      return null;
    });
  },

  // 拉取历史净值 (多页)
  fetchHistory: function(code, days) {
    var self = this;
    var all = [];
    var pageSize = 20;
    var pages = Math.ceil(days / pageSize);
    var endDate = new Date();
    var startDate = new Date(endDate.getTime() - days * 86400000);
    var sd = startDate.getFullYear() + '-' +
      String(startDate.getMonth() + 1).padStart(2, '0') + '-' +
      String(startDate.getDate()).padStart(2, '0');
    var ed = endDate.getFullYear() + '-' +
      String(endDate.getMonth() + 1).padStart(2, '0') + '-' +
      String(endDate.getDate()).padStart(2, '0');

    function fetchPage(page) {
      return self.callApi('history', code, {
        pageIndex: page, pageSize: pageSize,
        startDate: sd, endDate: ed
      }).then(function(data) {
        if (data.list && data.list.length > 0) {
          all = all.concat(data.list);
        }
        if (page < pages && data.list && data.list.length === pageSize) {
          return fetchPage(page + 1);
        }
        return all;
      });
    }
    return fetchPage(1).then(function(list) {
      // 反转按日期升序，取最近 days 条
      list.reverse();
      if (list.length > days) list = list.slice(list.length - days);
      return list.map(function(item) {
        return {
          date: item.FSRQ,
          nav: parseFloat(item.DWJZ),
          changePct: parseFloat(item.JZZZL) || 0
        };
      });
    });
  },

  // 拉取沪深300基准
  fetchBenchmark: function(days) {
    var endDate = new Date();
    var startDate = new Date(endDate.getTime() - days * 86400000);
    var sd = startDate.getFullYear() + '-' +
      String(startDate.getMonth() + 1).padStart(2, '0') + '-' +
      String(startDate.getDate()).padStart(2, '0');
    var ed = endDate.getFullYear() + '-' +
      String(endDate.getMonth() + 1).padStart(2, '0') + '-' +
      String(endDate.getDate()).padStart(2, '0');
    return this.callApi('history', '160706', { pageIndex: 1, pageSize: 20, startDate: sd, endDate: ed })
      .then(function(data) {
        var list = (data.Data && data.Data.LSJZList) || (data.list || []);
        list.reverse();
        if (list.length > days) list = list.slice(list.length - days);
        return list.map(function(item) {
          return {
            date: item.FSRQ,
            nav: parseFloat(item.DWJZ)
          };
        });
      });
  },

  // ============ 市场行情（通过云函数代理） ============

  fetchIndices: function() {
    return wx.cloud.callFunction({
      name: 'fundApi',
      data: { type: 'indices' }
    }).then(function(res) {
      return (res.result && res.result.indices) || [];
    });
  },

  fetchSectors: function() {
    return wx.cloud.callFunction({
      name: 'fundApi',
      data: { type: 'sectors' }
    }).then(function(res) {
      return (res.result && res.result.sectors) || [];
    });
  },

  // ============ 持仓 & 新闻 & 分析 ============

  fetchHoldings: function(code) {
    return this.callApi('holdings', code).then(function(data) {
      return data;
    });
  },

  fetchStockNews: function(code, stockName) {
    var self = this;
    return wx.cloud.callFunction({
      name: 'fundApi',
      data: { type: 'stocknews', code: code, stockName: stockName || '' }
    }).then(function(res) {
      var data = res.result;
      return data.news || [];
    });
  },

  fetchSectorNews: function(keyword) {
    var self = this;
    return wx.cloud.callFunction({
      name: 'fundApi',
      data: { type: 'sectornews', code: keyword, keyword: keyword }
    }).then(function(res) {
      var data = res.result;
      return data.news || [];
    });
  },

 analyzeNews: function(stocks, newsMap, fundName) {
    var data = { stocks: stocks, newsMap: newsMap };
    if (fundName) data.fundName = fundName;
    if (arguments.length > 3 && arguments[3]) data.navTrend = arguments[3];
    if (arguments.length > 4 && arguments[4]) data.position = arguments[4];
    if (arguments.length > 5 && arguments[5] != null) data.dailyChangePct = arguments[5];
    if (arguments.length > 6 && arguments[6]) data.fundCode = arguments[6];
    return wx.cloud.callFunction({
      name: 'analyze',
      data: data
    }).then(function(res) { return res.result; });
  },

  fetchRecommendations: function(params) {
    var data = { type: 'daily' };
    if (params) {
      Object.keys(params).forEach(function(k) { data[k] = params[k]; });
    }
    return wx.cloud.callFunction({
      name: 'recommend',
      data: data
    }).then(function(res) { return res.result; });
  },

  // ============ 定投计划 ============

  loadPlans: function() {
    try { return wx.getStorageSync('fund_plans') || []; } catch (e) { return []; }
  },

  savePlans: function(plans) {
    wx.setStorageSync('fund_plans', plans);
    this._touch('plans');
  },

  getFundPlans: function(fundCode) {
    var all = this.loadPlans();
    return all.filter(function(p) { return p.fundCode === fundCode; });
  },

  addPlan: function(plan) {
    var all = this.loadPlans();
    all.push(plan);
    this.savePlans(all);
    this._checkPlanExecution(plan);
    return all;
  },

  updatePlan: function(planId, updates) {
    var all = this.loadPlans();
    for (var i = 0; i < all.length; i++) {
      if (all[i].id === planId) {
        Object.keys(updates).forEach(function(k) { all[i][k] = updates[k]; });
        break;
      }
    }
    this.savePlans(all);
    return all;
  },

  deletePlan: function(planId) {
    var all = this.loadPlans();
    all = all.filter(function(p) { return p.id !== planId; });
    this.savePlans(all);
    return all;
  },

  _shouldExecuteToday: function(plan) {
    if (plan._forceExec) { delete plan._forceExec; return true; }
    if (!plan.active) return false;
    var today = new Date();
    today.setHours(0, 0, 0, 0);
    if (plan.createdAt) {
      var parts = plan.createdAt.split('-');
      var created = new Date(parseInt(parts[0]), parseInt(parts[1]) - 1, parseInt(parts[2]));
      created.setHours(0, 0, 0, 0);
      if (created.getTime() === today.getTime()) return false;
    }
    if (plan.lastExecuted) {
      var leParts = plan.lastExecuted.split('-');
      var leDate = new Date(parseInt(leParts[0]), parseInt(leParts[1]) - 1, parseInt(leParts[2]));
      leDate.setHours(0, 0, 0, 0);
      if (leDate.getTime() === today.getTime()) return false;
    }
    var dayOfWeek = today.getDay();
    var dayOfMonth = today.getDate();
    switch (plan.period) {
      case 'daily': return true;
      case 'weekly': return plan.dayOfWeek === dayOfWeek;
      case 'biweekly': {
        if (plan.dayOfWeek !== dayOfWeek) return false;
        if (plan.lastExecuted) {
          var leParts2 = plan.lastExecuted.split('-');
          var leDate2 = new Date(parseInt(leParts2[0]), parseInt(leParts2[1]) - 1, parseInt(leParts2[2]));
          leDate2.setHours(0, 0, 0, 0);
          var diff = Math.floor((today.getTime() - leDate2.getTime()) / 86400000);
          return diff >= 13;
        }
        return true;
      }
      case 'monthly': {
        var lastDay = new Date(today.getFullYear(), today.getMonth() + 1, 0).getDate();
        var target = Math.min(plan.dayOfMonth, lastDay);
        return dayOfMonth === target;
      }
    }
    return false;
  },

  _executePlan: function(plan) {
    if (!this._shouldExecuteToday(plan)) return false;
    var today = new Date();
    var dateStr = today.getFullYear() + '-' +
      String(today.getMonth() + 1).padStart(2, '0') + '-' +
      String(today.getDate()).padStart(2, '0');
    var nav = 1.0;
    var funds = this.globalData.funds;
    for (var i = 0; i < funds.length; i++) {
      if (funds[i].code === plan.fundCode && funds[i].nav) {
        nav = parseFloat(funds[i].nav) || 1.0;
        break;
      }
    }
    var shares = plan.amount / nav;
    var trade = {
      id: 'dt_' + Date.now(),
      date: dateStr,
      type: 'buy',
      shares: parseFloat(shares.toFixed(2)),
      amount: plan.amount,
      nav: parseFloat(nav.toFixed(4)),
      isBefore3pm: true,
      autoInvest: true
    };
    this.addTrade(plan.fundCode, trade);
    var all = this.loadPlans();
    for (var j = 0; j < all.length; j++) {
      if (all[j].id === plan.id) {
        all[j].lastExecuted = dateStr;
        break;
      }
    }
    this.savePlans(all);
    return true;
  },

  _checkPlanExecution: function(plan) {
    var executed = this._executePlan(plan);
    if (executed) {
      var page = this._getCurrentPage();
      if (page && page.applyFilter) page.applyFilter();
      if (page && page.updatePortfolio) page.updatePortfolio();
    }
  },

  _getCurrentPage: function() {
    var pages = getCurrentPages();
    return pages.length > 0 ? pages[pages.length - 1] : null;
  },

  executeAllPlans: function() {
    var plans = this.loadPlans();
    var changed = false;
    for (var i = 0; i < plans.length; i++) {
      if (this._executePlan(plans[i])) changed = true;
    }
    if (changed) {
      var page = this._getCurrentPage();
      if (page && page.applyFilter) page.applyFilter();
      if (page && page.updatePortfolio) page.updatePortfolio();
    }
    return changed;
  }
});