All files model.js

94.79% Statements 91/96
80.48% Branches 33/41
100% Functions 15/15
94.31% Lines 83/88

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170        4x   4x 16x   16x 9x     7x 28x   7x 7x     7x 7x 7x   7x 2x     5x 5x 20x 5x   19x 5x       5x       4x         4x 4x 16x   16x 16x 16x 16x 16x 16x 16x 16x 16x   16x 9x     7x 18x 18x 18x   18x 18x   18x 7x 7x 2x 2x     2x     11x 11x   11x 11x     11x 3x 8x 8x     11x 9x 4x     9x         4x         29x   10x       19x                           4x   7x 4x     7x 4x 4x 6x     4x   1x     3x 5x 5x 8x   5x     3x 1x       2x 3x     2x        
// public/js/model.js
 
// 計算MA值
function calculateMA(allKlinesData, intervalsData) {
  const results = {};
 
  intervalsData.forEach((data, i) => {
    const timeInterval = data.time_interval;
 
    if (data.param_1 == null) {
      return;
    }
 
    const params = [data.param_1, data.param_2, data.param_3, data.param_4];
    const maxParam = Math.max(...params.filter((param) => param !== null));
 
    Eif (!results[timeInterval]) {
      results[timeInterval] = [];
    }
 
    allKlinesData[timeInterval].forEach((klineData) => {
      const symbol = Object.keys(klineData)[0];
      const closePrices = klineData[symbol]["closePrices"];
 
      if (closePrices.length < maxParam) {
        return;
      }
 
      const maData = {};
      params.forEach((param) => {
        if (param !== null) {
          const dataSlice = closePrices.slice(0, param);
          const ma =
            dataSlice.reduce((acc, val) => acc + val, 0) / dataSlice.length;
          maData[`MA_${param}`] = ma;
        }
      });
 
      results[timeInterval].push({ symbol, maData });
    });
  });
 
  return results;
}
 
// 根據MA值進行篩選
function compareMAValues(maData, intervalsData) {
  const results = {};
  for (let i = 0; i < 4; i++) {
    const interval = intervalsData[i];
 
    const timeInterval = interval["time_interval"];
    const param1 = interval["param_1"];
    const param2 = interval["param_2"];
    const param3 = interval["param_3"];
    const param4 = interval["param_4"];
    const comparisonOperator1 = interval["comparison_operator_1"];
    const comparisonOperator2 = interval["comparison_operator_2"];
    const logicalOperator = interval["logical_operator"];
    const allMaData = maData[timeInterval];
 
    if (param1 == null) {
      continue;
    }
 
    for (let j = 0; j < allMaData.length; j++) {
      const symbolMAData = allMaData[j];
      const symbol = symbolMAData["symbol"];
      const maData = symbolMAData["maData"];
 
      const ma1 = parseFloat(maData[`MA_${param1}`]);
      const ma2 = parseFloat(maData[`MA_${param2}`]);
 
      if (param3 === null || param4 === null) {
        const condition = compare(ma1, comparisonOperator1, ma2);
        if (Boolean(condition)) {
          Eif (!results[timeInterval]) {
            results[timeInterval] = [];
          }
 
          results[timeInterval].push({ symbol });
        }
      } else {
        const ma3 = parseFloat(maData[`MA_${param3}`]);
        const ma4 = parseFloat(maData[`MA_${param4}`]);
 
        const condition1 = compare(ma1, comparisonOperator1, ma2);
        const condition2 = compare(ma3, comparisonOperator2, ma4);
 
        let condition;
        if (logicalOperator === "and") {
          condition = condition1 && condition2;
        } else Eif (logicalOperator === "or") {
          condition = condition1 || condition2;
        }
 
        if (Boolean(condition)) {
          if (!results[timeInterval]) {
            results[timeInterval] = [];
          }
 
          results[timeInterval].push({ symbol });
        }
      }
    }
  }
  return results;
}
 
//判斷函式
function compare(ma1, operator, ma2) {
  switch (operator) {
    case "<":
      return ma1 < ma2;
    case "<=":
      return ma1 <= ma2;
    case ">":
      return ma1 > ma2;
    case ">=":
      return ma1 >= ma2;
    case "==":
      return ma1 == ma2;
    case "!=":
      return ma1 != ma2;
    default:
      throw new Error("Invalid comparison operator");
  }
}
 
// 取得標的的交集
function findIntersection(matchingData, intervalsData) {
  const symbolArrays = [];
  // 只考慮那些 param_1 不為 null 的時間週期
  const activeIntervals = intervalsData.filter((item) => item.param_1 !== null);
  const count = activeIntervals.length;
 
  // 檢查 matchingData 是否包含 activeIntervals 定義的所有時間週期
  const intervals = activeIntervals.map((interval) => interval.time_interval);
  const availableIntervals = Object.keys(matchingData);
  const isAllIntervalsAvailable = intervals.every((interval) =>
    availableIntervals.includes(interval)
  );
 
  if (!isAllIntervalsAvailable) {
    // 如果有時間週期沒資料,直接返回空陣列(因為一定不會有交集)
    return [];
  }
 
  for (let i = 0; i < count; i++) {
    const interval = intervalsData[i]["time_interval"];
    const symbolsForInterval = matchingData[interval].map(
      (item) => item["symbol"]
    );
    symbolArrays.push(symbolsForInterval);
  }
  // 如果只有一個陣列,則直接返回該陣列
  if (symbolArrays.length === 1) {
    return symbolArrays[0];
  }
 
  // 否則取得所有陣列的交集
  const intersection = symbolArrays.reduce((acc, currArray) => {
    return acc.filter((symbol) => currArray.includes(symbol));
  });
 
  return intersection;
}
 
export { calculateMA, compareMAValues, findIntersection };