增加赛果同步

server/models/GamesPs.js

@@ -11,6 +11,7 @@ const PS_IOR_KEYS = [
 ];
 
 const BASE_URL = 'https://api.isthe.me/api/p';
+const IS_DEV = process.env.NODE_ENV == 'development';
 
 const GAMES = {
   Leagues: {},
@@ -36,9 +37,12 @@ const getMarketType = (mk) => {
 }
 
 /**
- * 更新联赛列表
+ * 同步联赛列表
  */
 const syncLeaguesList = ({ mk, leagues }) => {
+  if (IS_DEV) {
+    return Logs.out('syncLeaguesList', { mk, leagues });
+  }
   axios.post(`${BASE_URL}/syncLeague`, { mk, leagues })
   .then(res => {
     Logs.out('syncLeaguesList', res.data);
@@ -47,6 +51,10 @@ const syncLeaguesList = ({ mk, leagues }) => {
     Logs.out('syncLeaguesList', err.message);
   });
 }
+
+/**
+ * 更新联赛列表
+ */
 const updateLeaguesList = ({ mk, leagues }) => {
   const leaguesList = GAMES.Leagues;
   if (JSON.stringify(leaguesList[mk]) != JSON.stringify(leagues)) {
@@ -74,6 +82,9 @@ const getFilteredLeagues = async (mk) => {
  * 同步比赛列表到服务器
  */
 const syncGamesList = ({ platform, mk, games }) => {
+  if (IS_DEV) {
+    return Logs.out('syncGamesList', { platform, mk, games });
+  }
   axios.post(`${BASE_URL}/syncGames`, { platform, mk, games })
   .then(res => {
     Logs.out('syncGamesList', { platform, mk, count: games.length }, res.data);
@@ -136,7 +147,9 @@ const updateGamesList = (({ platform, mk, games } = {}) => {
  * 提交盘口数据
  */
 const submitOdds = ({ platform, mk, games }) => {
-  // console.log('syncOdds', games);
+  if (IS_DEV) {
+    return Logs.out('syncOdds', { platform, mk, games });
+  }
   axios.post(`${BASE_URL}/syncOdds`, { platform, mk, games})
   .then(res => {
     Logs.out('syncOdds', { platform, mk, count: games.length }, res.data);
@@ -199,7 +212,7 @@ const syncBaseEvents = ({ mk, games, outrights }) => {
       }).filter(item => item.match.every(entry => entry.value !== 0));
       return { ...gameInfo, matches };
     });
-    // console.log('baseList', baseList[marketType]);
+    // Logs.out('baseList', baseList[marketType]);
     submitOdds({ platform: 'ps', mk, games: gamesList });
   }
 }
@@ -217,6 +230,8 @@ const updateGamesEvents = ({ platform, mk, games, outrights }) => {
       syncBaseEvents({ mk, games, outrights });
     }
 
+    Logs.out('updateGamesEvents', { platform, mk, games, outrights });
+
     resolve();
   });
 }
@@ -234,9 +249,33 @@ const getGamesRelation = async (mk) => {
   });
 }
 
+/**
+ * 同步比赛结果
+ */
+const syncGamesResult = async (result) => {
+  if (IS_DEV) {
+    return Logs.out('updateGamesResult', result);
+  }
+  axios.post(`${BASE_URL}/syncMatchResult`, result)
+  .then(res => {
+    Logs.out('syncMatchResult', res.data);
+  })
+  .catch(err => {
+    Logs.out('syncMatchResult', err.message);
+  });
+}
+
+/**
+ * 更新比赛结果
+ */
+const updateGamesResult = (result) => {
+  syncGamesResult(result);
+  return Promise.resolve();
+}
 
 module.exports = {
   updateLeaguesList, getFilteredLeagues,
   updateGamesList, updateGamesEvents,
   getGamesRelation,
+  updateGamesResult,
 }

server/routes/pstery.js

@@ -34,6 +34,18 @@ router.post('/update_leagues_list', (req, res) => {
   res.sendSuccess({ updateCount });
 });
 
+// 更新比赛结果
+router.post('/update_games_result', (req, res) => {
+  const { date, list } = req.body ?? {};
+  Games.updateGamesResult({ date, list })
+  .then(() => {
+    res.sendSuccess();
+  })
+  .catch(err => {
+    res.badRequest(err.message);
+  });
+});
+
 // 获取筛选过的联赛
 router.get('/get_filtered_leagues', (req, res) => {
   const { mk } = req.query;
@@ -48,8 +60,14 @@ router.get('/get_filtered_leagues', (req, res) => {
 
 // 获取关联列表
 router.get('/get_games_relation', (req, res) => {
-  const gamesRelation = Games.getGamesRelation();
-  res.sendSuccess(gamesRelation);
+  const { mk } = req.query;
+  Games.getGamesRelation(mk)
+  .then(gamesRelation => {
+    res.sendSuccess(gamesRelation);
+  })
+  .catch(err => {
+    res.badRequest(err.message);
+  });
 });
 
 module.exports = router;