pstery.js 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125
  1. const express = require('express');
  2. const router = express.Router();
  3. const Games = require('../models/GamesPs');
  4. // 更新比赛列表
  5. router.post('/update_games_list', (req, res) => {
  6. const { platform, mk, games } = req.body ?? {};
  7. Games.updateGamesList({ platform, mk, games })
  8. .then(() => {
  9. res.sendSuccess();
  10. })
  11. .catch(err => {
  12. res.badRequest(err.message);
  13. })
  14. });
  15. // 更新比赛盘口
  16. router.post('/update_games_events', (req, res) => {
  17. const { platform, mk, games, outrights } = req.body ?? {};
  18. Games.updateGamesEvents({ platform, mk, games, outrights })
  19. .then(updateCount => {
  20. res.sendSuccess({ updateCount });
  21. })
  22. .catch(err => {
  23. res.badRequest(err.message);
  24. })
  25. });
  26. // 更新联赛列表
  27. router.post('/update_leagues_list', (req, res) => {
  28. const { mk, leagues } = req.body ?? {};
  29. const updateCount = Games.updateLeaguesList({ mk, leagues });
  30. res.sendSuccess({ updateCount });
  31. });
  32. // 更新比赛结果
  33. router.post('/update_games_result', (req, res) => {
  34. const { date, list } = req.body ?? {};
  35. Games.updateGamesResult({ date, list })
  36. .then(() => {
  37. res.sendSuccess();
  38. })
  39. .catch(err => {
  40. res.badRequest(err.message);
  41. });
  42. });
  43. // 获取筛选过的联赛
  44. router.get('/get_filtered_leagues', (req, res) => {
  45. const { mk } = req.query;
  46. Games.getFilteredLeagues(mk)
  47. .then(filteredLeagues => {
  48. res.sendSuccess(filteredLeagues);
  49. })
  50. .catch(err => {
  51. res.badRequest(err.message);
  52. });
  53. });
  54. // 获取关联列表
  55. router.get('/get_games_relation', (req, res) => {
  56. const { mk, id, le } = req.query;
  57. const ids = id?.split(',').map(item => +item.trim()).filter(item => !!item) ?? [];
  58. const listEvents = le === 'true';
  59. const gamesRelation = Games.getGamesRelation({ mk, ids, listEvents });
  60. res.sendSuccess(gamesRelation);
  61. });
  62. // 获取中单方案
  63. router.get('/get_solutions', (req, res) => {
  64. const { win_min, no_events } = req.query;
  65. Games.getSolutions({ win_min: win_min ? +win_min : undefined, no_events: no_events === 'true' })
  66. .then(({ solutions, gamesEvents }) => {
  67. res.sendSuccess({ solutions, gamesEvents });
  68. })
  69. .catch(err => {
  70. res.badRequest(err.message);
  71. });
  72. });
  73. // 获取单个中单方案
  74. router.get('/get_solution', (req, res) => {
  75. const { sid } = req.query;
  76. Games.getSolution(sid)
  77. .then(solution => {
  78. res.sendSuccess(solution);
  79. })
  80. .catch(err => {
  81. res.badRequest(err.message);
  82. });
  83. });
  84. // 获取综合利润方案
  85. router.post('/calc_total_profit', (req, res) => {
  86. const [sid1, sid2, inner_base, inner_rebate] = req.body;
  87. Games.getTotalProfitWithSid(sid1, sid2, inner_base, inner_rebate)
  88. .then(totalProfit => {
  89. res.sendSuccess(totalProfit);
  90. })
  91. .catch(err => {
  92. res.badRequest(err.message);
  93. });
  94. });
  95. // 获取自定义综合利润
  96. router.post('/calc_custom_total_profit', (req, res) => {
  97. const [betInfo1, betInfo2, fixed, inner_base, inner_rebate] = req.body;
  98. Games.getTotalProfitWithBetInfo(betInfo1, betInfo2, fixed, inner_base, inner_rebate)
  99. .then(totalProfit => {
  100. res.sendSuccess(totalProfit);
  101. })
  102. .catch(err => {
  103. res.badRequest(err.message);
  104. });
  105. });
  106. // 异常通知
  107. router.post('/notify_exception', (req, res) => {
  108. const { message } = req.body;
  109. Games.notifyException(message);
  110. res.sendSuccess();
  111. });
  112. module.exports = router;