sporttery/server/triangle/eventsMatch.js

const Logs = require('../libs/logs');
const { eventsCombination } = require('./trangleCalc');
const { getSetting, updateSetting } = require('./settings');

const Request = {
  callbacks: {},
  count: 0,
}

const GLOBAL_DATA = {
  relationLength: 0,
  loopStatus: -1,
};

const getDataFromParent = (type, callback) => {
  const id = ++Request.count;
  Request.callbacks[id] = callback;
  process.send({ method: 'get', id, type });
}

const postDataToParent = (type, data) => {
  process.send({ method: 'post', type, data });
}

process.on('message', (message) => {
  const { callbacks } = Request;
  const { method, id, type, data } = message;
  if (method == 'get' && id) {
    let responseData = null;
    // if (data == 'getSolution') {
    //   responseData = Solution.get();
    // }
    process.send({ type: 'response', id, data: responseData });
  }
  else if (method == 'post') {
    if (type == 'updateSetting') {
      updateSetting(data);
    }
  }
  else if (type == 'response' && id && callbacks[id]) {
    callbacks[id](data);
    delete callbacks[id];
  }
});

/**
 * 精确浮点数字
 * @param {number} number
 * @param {number} x
 * @returns {number}
 */
const fixFloat = (number, x=2) => {
  return parseFloat(number.toFixed(x));
}

const getGamesRelation = () => {
  const setting = getSetting();
  const status = +setting.runWorkerEnabled;
  if (GLOBAL_DATA.loopStatus !== status) {
    GLOBAL_DATA.loopStatus = status;
    Logs.out('loop status changed to', status);
  }

  if (!setting.runWorkerEnabled) {
    return Promise.resolve([]);
  }
  return new Promise(resolve => {
    getDataFromParent('getGamesRelation', (relations) => {
      resolve(relations);
    });
  });
}

const updateSolutions = (solutions, eventsLogsMap) => {
  postDataToParent('updateSolutions', { solutions, eventsLogsMap });
}

const extractOdds = ({ evtime, events, sptime, special, platform, timestamp }) => {
  const { subsidyTime, subsidyAmount } = getSetting();
  const nowTime = Date.now();
  const isSubsidy = platform == 'ps' && timestamp > nowTime && timestamp < nowTime + 1000*60*60*subsidyTime;
  const setting = getSetting();
  const expireTimeEv = Date.now() - setting.expireTimeEvents;
  const expireTimeSP = Date.now() - setting.expireTimeSpecial;
  const extractData = {
    odds: null,
    evExpire: false,
    spExpire: false,
    removeCount: 0,
  }
  let odds = {};
  if (evtime > expireTimeEv) {
    odds = { ...odds, ...events };
  }
  else if (events) {
    extractData.evExpire = true;
  }
  if (sptime > expireTimeSP) {
    odds = { ...odds, ...special };
  }
  else if (special) {
    extractData.spExpire = true;
  }
  Object.keys(odds).forEach(ior => {
    if (!odds[ior]?.v || odds[ior].v <= 0) {
      delete odds[ior];
      extractData.removeCount++;
    }
    else if (isSubsidy && ior.startsWith('ior_ot')) {
      const sourceOdds = odds[ior].v;
      odds[ior].v = fixFloat(sourceOdds + subsidyAmount, 3);
      odds[ior].s = sourceOdds
    }
  });
  extractData.odds = odds;
  return extractData;
}

const eventMatch = () => {
  getGamesRelation()
  .then(relations => {

    const relationLength = relations?.length;
    if (!relationLength) {
      if (GLOBAL_DATA.relationLength) {
        GLOBAL_DATA.relationLength = 0;
        Logs.out('relation list is empty');
      }
      return [];
    }

    GLOBAL_DATA.relationLength = relationLength;

    /** 日志 盘口信息 */
    const eventsLogsMap = {
      expireEvents: [],
      removeEvents: []
    };
    /** 日志 End */

    const passableEvents = relations.map(({ id, rel, mk }) => {
      const eventsMap = {};
      const oddsMap = {};

      Object.keys(rel).forEach(platform => {
        const { leagueName, teamHomeName, teamAwayName, timestamp, stage, score, evtime, events, sptime, special } = rel[platform];
        if (!events && !special) {
          return;
        }
        if (platform == 'ps') {
          eventsMap.info = { leagueName, teamHomeName, teamAwayName, id, timestamp, stage, score };
        }
        const { odds, evExpire, spExpire, removeCount } = extractOdds({ evtime, events, sptime, special, platform, timestamp });

        /** 日志 盘口过期 */
        if (evExpire || spExpire) {
          eventsLogsMap.expireEvents.push({
            mk, platform,
            info: rel[platform],
            evExpire, spExpire,
            evtime, sptime,
          });
        }
        /** 日志 盘口移除 */
        if (removeCount) {
          eventsLogsMap.removeEvents.push({
            mk, platform,
            info: rel[platform],
            removeCount,
          });
        }
        /** 日志 End */

        Object.keys(odds).forEach(ior => {
          if (!oddsMap[ior]) {
            oddsMap[ior] = {};
          }
          oddsMap[ior][platform] = odds[ior];
        });
      });
      eventsMap.odds = oddsMap;
      return eventsMap;
    })
    .filter(item => item?.info);

    const solutions = eventsCombination(passableEvents);

    // Logs.out('eventMatch solutions', solutions);
    if (solutions?.length) {
      updateSolutions(solutions, eventsLogsMap);
    }
  })
  .finally(() => {
    setTimeout(() => {
      eventMatch();
    }, 2000);
  });
};

const syncSetting = () => {
  getDataFromParent('getSetting', (setting) => {
    if (setting) {
      updateSetting(setting);
    }
    else {
      Logs.out('syncSetting setting is empty');
    }
  });
}

syncSetting();
eventMatch();