更新逻辑

pinnacle/libs/globalData.js

@@ -63,3 +63,21 @@ export const getEventsByIds = (ids) => {
 
   return normalizedIds.map(id => gamesMap[id]).filter(Boolean);
 }
+
+/**
+ * 获取盘口详情
+ * @param {*} ior
+ * @param {*} id
+ * @returns
+ */
+export const getIorInfo = async(ior, id) => {
+  if (!id || !ior) {
+    return Promise.reject({ cause: 400, message: 'id and ior are required', data: { id, ior } });
+  }
+  const { gamesMap } = GLOBAL_DATA;
+  const iorInfo = parseIorDetail(ior, id, gamesMap);
+  if (iorInfo.cause === 400) {
+    return Promise.reject({ cause: 400, message: iorInfo.message, data: { id, ior } });
+  }
+  return Promise.resolve(iorInfo);
+}

pinnacle/libs/syncData.js

@@ -763,21 +763,3 @@ export const startSyncMarketsData = () => {
     pinnacleDataLoop();
   });
 }
-
-/**
- * 获取盘口详情
- * @param {*} ior
- * @param {*} id
- * @returns
- */
-export const getIorInfo = async(ior, id) => {
-  if (!id || !ior) {
-    return Promise.reject({ cause: 400, message: 'id and ior are required', data: { id, ior } });
-  }
-  const { gamesMap } = GLOBAL_DATA;
-  const iorInfo = parseIorDetail(ior, id, gamesMap);
-  if (iorInfo.cause === 400) {
-    return Promise.reject({ cause: 400, message: iorInfo.message, data: { id, ior } });
-  }
-  return Promise.resolve(iorInfo);
-}

pinnacle/main.js

@@ -7,6 +7,8 @@ import requireInternalToken from './middleware/requireInternalToken.js';
 import pinnacleProxyRoutes from './routes/pinnacleProxy.js';
 import tradingRoutes from './routes/trading.js';
 
+import { startSyncMarketsData } from "./libs/syncData.js";
+
 const app = express();
 
 app.use((req, res, next) => {
@@ -73,3 +75,5 @@ app.use('/api/trading', requireInternalToken, tradingRoutes);
 // 启动服务
 const PORT = process.env.PORT || 9057;
 app.listen(PORT, () => Logs.out(`Pinnacle service running on port ${PORT}`));
+
+startSyncMarketsData();

pinnacle/routes/trading.js

@@ -1,6 +1,5 @@
 import express from 'express';
-
-import { startSyncMarketsData, getIorInfo } from "../libs/syncData.js";
+import { getIorInfo } from '../libs/globalData.js';
 
 const router = express.Router();
 
@@ -15,6 +14,4 @@ router.get('/get_ior_info/:id/:ior', (req, res) => {
   });
 });
 
-startSyncMarketsData();
-
 export default router;