保存OB联赛列表

server/models/GamesPs.js

@@ -13,7 +13,7 @@ const GamesCacheFile = path.join(__dirname, '../data/games.cache');
 const DevGameTastFile = path.join(__dirname, '../data/gameTast.json');
 
 const childOptions = process.env.NODE_ENV == 'development' ? {
-  execArgv: ['--inspect=9228'],
+  execArgv: ['--inspect=9230'],
   stdio: ['pipe', 'pipe', 'pipe', 'ipc']
 } : {};
 const { fork } = require('child_process');
@@ -122,8 +122,14 @@ const syncLeaguesList = ({ mk, leagues }) => {
 /**
  * 更新联赛列表
  */
-const updateLeaguesList = ({ mk, leagues }) => {
-  const leaguesMap = GAMES.Leagues;
+const updateLeaguesList = ({ mk, leagues, platform }) => {
+  Logs.out('updateLeaguesList', { mk, leagues, platform });
+  if (!GAMES.Leagues[platform]) {
+    GAMES.Leagues[platform] = {};
+  }
+
+  const leaguesMap = GAMES.Leagues[platform];
+
   const nowTime = Date.now();
   const expireTime = nowTime - 1000 * 60 * 5;
   if (!leaguesMap[mk]) {
@@ -137,9 +143,12 @@ const updateLeaguesList = ({ mk, leagues }) => {
     JSON.stringify(leaguesMap[mk].leagues) != JSON.stringify(leagues)) {
     leaguesMap[mk].leagues = leagues;
     leaguesMap[mk].timestamp = nowTime;
-    syncLeaguesList({ mk, leagues });
+    if (platform == 'ps') {
+      syncLeaguesList({ mk, leagues });
+    }
     return leagues.length;
   }
+
   return 0;
 }
 
@@ -727,6 +736,18 @@ const updateGamesResult = (result) => {
   return Promise.resolve();
 }
 
+/**
+ * 获取OB联赛列表
+ */
+const getObLeaguesList = async() => {
+  const { Leagues } = GAMES;
+  const { ob } = Leagues;
+  if (!ob) {
+    return Promise.reject(new Error('ob leagues list not found'));
+  }
+  return Promise.resolve(Object.values(ob)[0]);
+}
+
 /**
  * 同步中单方案
  */
@@ -1279,6 +1300,7 @@ module.exports = {
   updateGamesList, updateGamesEvents,
   getGamesRelation,
   updateGamesResult,
+  getObLeaguesList,
   getSolutions, getGamesSolutions, getSolution, getSolutionsByIds,
   getTotalProfitWithSid,
   getTotalProfitWithBetInfo,

server/routes/pstery.js

@@ -29,8 +29,8 @@ router.post('/update_games_events', (req, res) => {
 
 // 更新联赛列表
 router.post('/update_leagues_list', (req, res) => {
-  const { mk, leagues } = req.body ?? {};
-  const updateCount = Games.updateLeaguesList({ mk, leagues });
+  const { mk, leagues, platform } = req.body ?? {};
+  const updateCount = Games.updateLeaguesList({ mk, leagues, platform });
   res.sendSuccess({ updateCount });
 });
 
@@ -58,6 +58,17 @@ router.get('/get_filtered_leagues', (req, res) => {
   });
 });
 
+// 获取OB联赛列表
+router.get('/get_ob_leagues', (req, res) => {
+  Games.getObLeaguesList()
+  .then(obLeaguesList => {
+    res.sendSuccess(obLeaguesList);
+  })
+  .catch(err => {
+    res.badRequest(err.message);
+  });
+});
+
 // 获取关联列表
 router.get('/get_games_relation', (req, res) => {
   const { mk, id, le } = req.query;