"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getOdds = void 0;
const table_1 = require("../table");
const _ = require("lodash");
const moment = require("moment");
const cache_1 = require("../../../cache");
let localOddsDbData = {};
//获取凯利列表
function getKellyList(AvgOdds, Odds) {
    let fm = getKelly(AvgOdds);
    if (Odds.length == 3)
        return [round(fm * Odds[0] / AvgOdds[0] / 100), round(fm * Odds[1] / AvgOdds[1] / 100), round(fm * Odds[2] / AvgOdds[2] / 100)];
    else
        return [round(fm * Odds[0] / AvgOdds[0] / 100), round(fm * Odds[1] / AvgOdds[1] / 100)];
}
//获取凯利指数
function getKelly(Odds) {
    return 100.0 / _.sumBy(Odds, (o) => { return 1 / o; });
}
function round(value) {
    return (Math.round(value * 100) / 100).toFixed(2);
}
//获取数据库数据，足球
async function getZqOddsDbData(match) {
    let oddsList = [];
    let oddsLetGoalList = []; //让球
    let oddsBigSmallList = []; //
    //吴广要求加入的
    //欧盘公司：1、百家平均，2、竞足官方，3、威廉希尔，4、立博，5、澳门，6、Bet365 ，7、Interwetten   8、SNAI ，9、皇冠，10、易胜博，
    //11、伟德， 12、Bwin，13、Gamebookers  14、Pinnacle平博 ， 15、10BET，16、18luck(新利)，17、Coral ，18、Eurobet ，19、金宝博  ，  20、利记，
    //21、Mansion88(明升) ，22,Centrebet(澳大利亚), 23、UEDBET(UED亚洲)，24、Unibe(优胜客)，  25、香港马会，26、Betshop
    //对应数据库的id（没有皇冠）： 1129, 115, 82, 80, 281, 104, 110,90,81,255,158,177,16,1028,88,71,499,474,1137,9,1023,16,432,535
    //1, 3, 4, 9, 12, 14, 16, 18, 60, 70, 71, 80, 81, 82, 88, 90, 97, 98, 104, 110, 115, 158, 173, 177, 182, 255, 266, 281, 370, 422, 432, 450, 474, 499, 517, 535, 538, 545, 574, 608, 615, 649, 659, 976, 658, 748, 799, 1038, 1039, 1040, 1041, 1042, 1044, 1129, 1183, 1137, 1028, 1023
    let where = `AND \`Type\`=1 
AND \`T_Company\`.\`Id\` IN (1,3,12,14,82,98,104,110,115,177,182,266,370,432,450,538,545,574,608,615,658,748,799,1038,1039,1040,1041,1042,1044,1129,281,255,976)
WHERE \`MatchId\`=${match.InfoId} and \`T_Company\`.\`Name\` is not null ORDER BY \`CompanyId\` `;
    oddsList = await table_1.db.db.query(`SELECT \`T_Company\`.\`Name\` as \`CompanyName\`,\`T_Company\`.\`OrderId\`,\`T_Odds100\`.* FROM \`T_Odds100\`
LEFT JOIN \`T_Company\` ON \`T_Company\`.\`Id\`= \`T_Odds100\`.\`CompanyId\` 

${where}
`);
    oddsLetGoalList = await table_1.db.db.query(`SELECT \`T_Company\`.\`Name\` as \`CompanyName\` ,\`T_Company\`.\`OrderId\`,\`T_OddsLetGoal\`.* FROM \`T_OddsLetGoal\` 
    LEFT JOIN \`T_Company\` ON \`T_Company\`.\`Id\`= \`T_OddsLetGoal\`.\`CompanyId\` ${where}`);
    oddsBigSmallList = await table_1.db.db.query(`SELECT \`T_Company\`.\`Name\` as \`CompanyName\` ,\`T_Company\`.\`OrderId\`,\`T_OddsBigSmall\`.* FROM \`T_OddsBigSmall\` 
    LEFT JOIN \`T_Company\` ON \`T_Company\`.\`Id\`= \`T_OddsBigSmall\`.\`CompanyId\` ${where}`);
    return checkOdds({ oddsList, oddsLetGoalList, oddsBigSmallList });
}
//检查数据
function checkOdds({ oddsList, oddsLetGoalList, oddsBigSmallList }) {
    oddsList = checkOddsList(oddsList);
    oddsLetGoalList = checkOddsList(oddsLetGoalList);
    oddsBigSmallList = checkOddsList(oddsBigSmallList);
    return { oddsList: oddsList, oddsLetGoalList: oddsLetGoalList, oddsBigSmallList: oddsBigSmallList };
}
function checkOddsList(list) {
    if (list && list.length > 0) {
        return list[0];
    }
    return [];
}
//获取数据库数据，篮球
async function getLqOddsDbData(match) {
    let oddsList = [];
    let oddsLetGoalList = []; //让球
    let oddsBigSmallList = []; //
    let where = `WHERE \`T_NBACompany\`.\`Type\`=1 
AND \`T_NBACompany\`.\`Id\` IN (3,6,9,26,43,82,77,83,214,265,272,317,368,369,431,458,360,422,446,366,339)
AND \`MatchId\`=${match.InfoId} and \`T_NBACompany\`.\`Name\` is not null 
ORDER BY \`CompanyId\``;
    let where2 = `WHERE \`T_NBACompany\`.\`Type\`=2 
AND \`MatchId\`=${match.InfoId} and \`T_NBACompany\`.\`Name\` is not null  ORDER BY \`CompanyId\` `;
    oddsList = await table_1.db.db.query(`SELECT \`T_NBACompany\`.\`Name\` as \`CompanyName\` ,\`T_NBAOdds100\`.* FROM \`T_NBAOdds100\` 
LEFT JOIN \`T_NBACompany\` ON \`T_NBACompany\`.\`Id\`= \`T_NBAOdds100\`.\`CompanyId\` 
${where}
`);
    oddsLetGoalList = await table_1.db.db.query(`SELECT \`T_NBACompany\`.\`Name\` as \`CompanyName\` ,\`T_NBAOddsLetGoal\`.* FROM \`T_NBAOddsLetGoal\` 
    LEFT JOIN \`T_NBACompany\` ON \`T_NBACompany\`.\`Id\`= \`T_NBAOddsLetGoal\`.\`CompanyId\` ${where2}`);
    oddsBigSmallList = await table_1.db.db.query(`SELECT \`T_NBACompany\`.\`Name\` as \`CompanyName\` ,\`T_NBAOddsBigSmall\`.* FROM \`T_NBAOddsBigSmall\` 
    LEFT JOIN \`T_NBACompany\` ON \`T_NBACompany\`.\`Id\`= \`T_NBAOddsBigSmall\`.\`CompanyId\` ${where2}`);
    return checkOdds({ oddsList, oddsLetGoalList, oddsBigSmallList });
}
//获取数据库数据
async function getOddsDbData(match) {
    let match_odds_key = `${config.CachePrefix}match:match_getOddsDbData:v3_${match.Id}`;
    let replyMatch = await cache_1.redis.get(match_odds_key);
    if (replyMatch && replyMatch.length > 0 && !match.isUpdateCache) {
        return JSON.parse(replyMatch);
    }
    else if (!match.isUpdateCache) {
        return {};
    }
    let result = { oddsList: [], oddsLetGoalList: [], oddsBigSmallList: [] };
    if (match.InfoId && match.LotteryId != 73) {
        result = await getZqOddsDbData(match);
    }
    else if (match.InfoId && match.LotteryId == 73) {
        result = await getLqOddsDbData(match);
    }
    await cache_1.redis.set(match_odds_key, JSON.stringify(result));
    cache_1.redis.expire(match_odds_key, 60 * 60 * 24);
    //标识此场比赛已经缓存
    cache_1.redis.set(`${config.CachePrefix}match:match_odds:${match.Id}`, match.Id);
    cache_1.redis.expire(`${config.CachePrefix}match:match_odds:${match.Id}`, 60 * 60 * 24);
    return result;
}
function getCheckField(tableName) {
    if (tableName == 'OddsLetGoal') {
        return { checkHomeField: 'HostOdds', checkGuestField: 'QuestOdds', valueHomeField: 'HostOdds', valueGuestField: 'QuestOdds' };
    }
    else if (tableName == 'OddsBigSmall') {
        return { checkHomeField: 'BigOdds', checkGuestField: 'SmallOdds', valueHomeField: 'BigOdds', valueGuestField: 'SmallOdds' };
    }
    return { checkHomeField: 'HomeWin', checkGuestField: 'GuestWin', valueHomeField: 'HomeWin', valueGuestField: 'GuestWin' };
}
async function getSameFirstOddsStat({ match, oddsItem, tableName }) {
    let Nba = match.LotteryId == 73 ? 'NBA' : '';
    let { checkHomeField, checkGuestField, valueHomeField, valueGuestField } = getCheckField(tableName);
    if (oddsItem[`First${valueHomeField}`] == null) {
        return {
            SameFirstOddsStat: '',
            SameFirstOddsList: '',
        };
    }
    let sameOddsList = await table_1.db.db.query(`SELECT t."BeginTime",t."HostTeamId",t."HostTeam",t."GuestTeamId",t."GuestTeam",t."HostScore",t."GuestScore",p."ShortName" 
FROM "T_${Nba}${tableName}" o
LEFT JOIN "T_${Nba}Match" t ON t."Id"= o."MatchId"
LEFT JOIN "T_${Nba}MatchType" p ON p."Id"=t."MatchTypeId" and p."ParentId"=0
WHERE "CompanyId"=${oddsItem.CompanyId}  
AND "First${checkHomeField}>=${round(oddsItem[`First${valueHomeField}`] - 0.025)} AND "First${checkHomeField}"<=${round(oddsItem[`First${valueHomeField}`] + 0.025)}
AND "First${checkGuestField}>=${round(oddsItem[`First${valueGuestField}`] - 0.025)} AND "First${checkGuestField}"<=${round(oddsItem[`First${valueGuestField}`] + 0.025)}
AND "Details"<>''
AND "${checkHomeField}"<>0
AND t."BeginTime">'${moment().add(-2, 'year').format("YYYY-MM-DD")}'
AND t."BeginTime" IS NOT NULL
AND t."HostScore" IS NOT NULL
${match.LotteryId == 73 ? 'AND t."HostScore"!=t."GuestScore"' : 'AND t."MatchTypeId" IN (8,11,31,34,36)'}
order by "BeginTime" desc
limit 100
`);
    sameOddsList = checkOddsList(sameOddsList);
    return {
        SameFirstOddsStat: JSON.stringify(statWonFlatLost(sameOddsList)),
        SameFirstOddsList: JSON.stringify(sameOddsList),
    };
}
async function getSameLastOddsStat({ match, oddsItem, tableName }) {
    let Nba = match.LotteryId == 73 ? 'NBA' : '';
    let { checkHomeField, checkGuestField, valueHomeField, valueGuestField } = getCheckField(tableName);
    if (oddsItem[`First${valueHomeField}`] == null) {
        return {
            SameLastOddsStat: '',
            SameLastOddsList: '',
        };
    }
    //只有初赔没有终盘,则使用初赔数据
    if (!oddsItem[`${valueHomeField}`]) {
        let result = await getSameFirstOddsStat({ match, oddsItem, tableName });
        return {
            SameLastOddsStat: result.SameFirstOddsStat,
            SameLastOddsList: result.SameFirstOddsList,
        };
    }
    let sameOddsList = await table_1.db.db.query(`SELECT t."BeginTime",t."HostTeamId",t."HostTeam",t."GuestTeamId",t."GuestTeam",t."HostScore",t."GuestScore",p."ShortName" 
FROM "T_${Nba}${tableName}" o
LEFT JOIN "T_${Nba}Match" t ON t."Id"= o."MatchId"
LEFT JOIN "T_${Nba}MatchType" p ON p."Id"=t."MatchTypeId" and p."ParentId"=0
WHERE "CompanyId"=${oddsItem.CompanyId}  
AND "${checkHomeField}">=${round(oddsItem[`${valueHomeField}`] - 0.025)} AND "${checkHomeField}"<=${round(oddsItem[`${valueHomeField}`] + 0.025)}
AND "${checkGuestField}">=${round(oddsItem[`${valueGuestField}`] - 0.025)} AND "${checkGuestField}"<=${round(oddsItem[`${valueGuestField}`] + 0.025)}
AND "Details"<>''
AND "${checkHomeField}"<>0
AND t."BeginTime">'${moment().add(-2, 'year').format("YYYY-MM-DD")}'
AND t."BeginTime" IS NOT NULL
AND t."HostScore" IS NOT NULL
${match.LotteryId == 73 ? 'AND t."HostScore"!=t."GuestScore"' : 'AND t."MatchTypeId" IN (8,11,31,34,36)'}
order by "BeginTime" desc
limit 100
`);
    sameOddsList = checkOddsList(sameOddsList);
    return {
        SameLastOddsStat: JSON.stringify(statWonFlatLost(sameOddsList)),
        SameLastOddsList: JSON.stringify(sameOddsList),
    };
}
async function getSameMatchTypeSameFirstOddsStat({ match, oddsItem, tableName }) {
    let Nba = match.LotteryId == 73 ? 'NBA' : '';
    let { checkHomeField, checkGuestField, valueHomeField, valueGuestField } = getCheckField(tableName);
    if (oddsItem[`First${valueHomeField}`] == null) {
        return {
            SameMatchTypeSameFirstOddsStat: '',
            SameMatchTypeSameFirstOddsList: '',
        };
    }
    let sameOddsList = await table_1.db.db.query(`
SELECT t."BeginTime",t."HostTeamId",t."HostTeam",t."GuestTeamId",t."GuestTeam",t."HostScore",t."GuestScore",p."ShortName" 
FROM "T_${Nba}${tableName}" o
LEFT JOIN "T_${Nba}Match" t ON t."Id"= o."MatchId"
LEFT JOIN "T_${Nba}MatchType" p ON p."Id"=t."MatchTypeId" and p."ParentId"=0
WHERE "CompanyId"=${oddsItem.CompanyId}  
AND "First${checkHomeField}>=${round(oddsItem[`First${valueHomeField}`] - 0.025)} AND "First${checkHomeField}"<=${round(oddsItem[`First${valueHomeField}`] + 0.025)}
AND "First${checkGuestField}>=${round(oddsItem[`First${valueGuestField}`] - 0.025)} AND "First${checkGuestField}"<=${round(oddsItem[`First${valueGuestField}`] + 0.025)}
AND "Details"<>''
AND "${checkHomeField}"<>0
AND t."BeginTime">'${moment().add(-2, 'year').format("YYYY-MM-DD")}'
AND t."BeginTime" IS NOT NULL
AND t."HostScore" IS NOT NULL
${match.LotteryId == 73 ? 'AND t."HostScore"!=t."GuestScore"' : ''}
AND t."MatchTypeId" IN (select "MatchTypeId" from "T_${Nba}Match" where "Id" =${match.InfoId} limit 1)
order by "BeginTime" desc
limit 100
`);
    sameOddsList = checkOddsList(sameOddsList);
    return {
        SameMatchTypeSameFirstOddsStat: JSON.stringify(statWonFlatLost(sameOddsList)),
        SameMatchTypeSameFirstOddsList: JSON.stringify(sameOddsList),
    };
}
//统计胜平负
function statWonFlatLost(sameOddsList) {
    let AllCount = 0;
    let WinCount = 0;
    let FlatCount = 0;
    let LostCount = 0;
    let WinRate = 0;
    let FlatRate = 0;
    let LostRate = 0;
    if (sameOddsList && sameOddsList.length > 0) {
        _.map(sameOddsList, (item) => {
            AllCount++;
            if (item.HostScore > item.GuestScore) {
                WinCount++;
            }
            else if (item.HostScore == item.GuestScore) {
                FlatCount++;
            }
            else {
                LostCount++;
            }
        });
        WinRate = round(1 - parseFloat(round(FlatCount / AllCount)) - parseFloat(round(LostCount / AllCount)));
        FlatRate = round(FlatCount / AllCount);
        LostRate = round(LostCount / AllCount);
    }
    return { AllCount: AllCount, WinCount: WinCount, FlatCount: FlatCount, LostCount: LostCount, WinRate: WinRate, FlatRate: FlatRate, LostRate: LostRate };
}
async function getSameMatchTypeSameLastOddsStat({ match, oddsItem, tableName }) {
    let Nba = match.LotteryId == 73 ? 'NBA' : '';
    let { checkHomeField, checkGuestField, valueHomeField, valueGuestField } = getCheckField(tableName);
    if (oddsItem[`First${valueHomeField}`] == null) {
        return {
            SameMatchTypeSameLastOddsStat: '',
            SameMatchTypeSameLastOddsList: '',
        };
    }
    //只有初赔没有终盘,则使用初赔数据
    if (!oddsItem[`${valueHomeField}`]) {
        let result = await getSameMatchTypeSameFirstOddsStat({ match, oddsItem, tableName });
        return {
            SameMatchTypeSameLastOddsStat: result.SameMatchTypeSameFirstOddsStat,
            SameMatchTypeSameLastOddsList: result.SameMatchTypeSameFirstOddsList,
        };
    }
    let sameOddsList = await table_1.db.db.query(`SELECT t."BeginTime",t."HostTeamId",t."HostTeam",t."GuestTeamId",t."GuestTeam",t."HostScore",t."GuestScore",p."ShortName" 
FROM "T_${Nba}${tableName}" o
LEFT JOIN "T_${Nba}Match" t ON t."Id"= o."MatchId"
LEFT JOIN "T_${Nba}MatchType" p ON p."Id"=t."MatchTypeId" and p."ParentId"=0
WHERE "CompanyId"=${oddsItem.CompanyId}  
AND "${checkHomeField}">=${round(oddsItem[`${valueHomeField}`] - 0.025)} AND "${checkHomeField}"<=${round(oddsItem[`${valueHomeField}`] + 0.025)}
AND "${checkGuestField}">=${round(oddsItem[`${valueGuestField}`] - 0.025)} AND "${checkGuestField}"<=${round(oddsItem[`${valueGuestField}`] + 0.025)}
AND "Details"<>''
AND "${checkHomeField}"<>0
AND t."BeginTime">'${moment().add(-2, 'year').format("YYYY-MM-DD")}'
AND t."BeginTime" IS NOT NULL
AND t."HostScore" IS NOT NULL
${match.LotteryId == 73 ? 'AND t."HostScore"!=t."GuestScore"' : ''}
AND t."MatchTypeId" IN (select "MatchTypeId" from "T_${Nba}Match" where "Id" =${match.InfoId} limit 1)
order by "BeginTime" desc
limit 100
`);
    sameOddsList = checkOddsList(sameOddsList);
    return {
        SameMatchTypeSameLastOddsStat: JSON.stringify(statWonFlatLost(sameOddsList)),
        SameMatchTypeSameLastOddsList: JSON.stringify(sameOddsList),
    };
}
async function staticOdds100({ match, oddsList, tableName }) {
    //计算平均指数
    let length = match.LotteryId == 73 ? 2 : 3;
    let AvgFirstOdds = _.take([0, 0, 0], length);
    let AvgSecondOdds = _.take([0, 0, 0], length);
    let AvgLastOdds = _.take([0, 0, 0], length);
    let AvgFirstKelly = _.take([0, 0, 0], length);
    let AvgLastKelly = _.take([0, 0, 0], length);
    let oddsListLength = oddsList.length;
    if (match.LotteryId == 73) {
        _.map(oddsList, (oddsItem) => {
            let FirstOdds = [round(oddsItem.FirstHomeWin), round(oddsItem.FirstGuestWin)];
            let historyodds = JSON.parse(oddsItem.Details);
            let SecondOdds = FirstOdds;
            let LastOdds = FirstOdds;
            if (historyodds && historyodds.length > 1) {
                SecondOdds = [historyodds[1][0], historyodds[1][1]];
                LastOdds = [historyodds[0][0], historyodds[0][1]];
            }
            AvgFirstOdds = [AvgFirstOdds[0] + FirstOdds[0] / oddsListLength, AvgFirstOdds[1] + FirstOdds[1] / oddsListLength];
            AvgSecondOdds = [AvgSecondOdds[0] + SecondOdds[0] / oddsListLength, AvgSecondOdds[1] + SecondOdds[1] / oddsListLength];
            AvgLastOdds = [AvgLastOdds[0] + LastOdds[0] / oddsListLength, AvgLastOdds[1] + LastOdds[1] / oddsListLength];
        });
    }
    else {
        _.map(oddsList, (oddsItem) => {
            let FirstOdds = [round(oddsItem.FirstHomeWin), round(oddsItem.FirstStandoff), round(oddsItem.FirstGuestWin)];
            let historyodds = JSON.parse(oddsItem.Details);
            let SecondOdds = FirstOdds;
            let LastOdds = FirstOdds;
            if (historyodds && historyodds.length > 1) {
                SecondOdds = [historyodds[1][0], historyodds[1][1], historyodds[1][2]];
                LastOdds = [historyodds[0][0], historyodds[0][1], historyodds[0][2]];
            }
            AvgFirstOdds = [AvgFirstOdds[0] + FirstOdds[0] / oddsListLength, AvgFirstOdds[1] + FirstOdds[1] / oddsListLength, AvgFirstOdds[2] + FirstOdds[2] / oddsListLength];
            AvgSecondOdds = [AvgSecondOdds[0] + SecondOdds[0] / oddsListLength, AvgSecondOdds[1] + SecondOdds[1] / oddsListLength, AvgSecondOdds[2] + SecondOdds[2] / oddsListLength];
            AvgLastOdds = [AvgLastOdds[0] + LastOdds[0] / oddsListLength, AvgLastOdds[1] + LastOdds[1] / oddsListLength, AvgLastOdds[2] + LastOdds[2] / oddsListLength];
        });
    }
    AvgFirstOdds = _.map(AvgFirstOdds, (o) => { return round(o); });
    AvgSecondOdds = _.map(AvgSecondOdds, (o) => { return round(o); });
    AvgLastOdds = _.map(AvgLastOdds, (o) => { return round(o); });
    let AvgReturnScale = getKelly(AvgLastOdds);
    AvgFirstKelly = getKellyList(AvgFirstOdds, AvgFirstOdds);
    AvgLastKelly = getKellyList(AvgLastOdds, AvgLastOdds);
    let odds100 = await _.map(oddsList, async (oddsItem) => {
        let match_odds_key = `${config.CachePrefix}match:match_odds100_v20_${match.Id}:${oddsItem.CompanyId}`;
        let replyMatch = await cache_1.redis.get(match_odds_key);
        if (replyMatch && replyMatch.length > 0 && !match.isUpdateCache) {
            return JSON.parse(replyMatch);
        }
        else if (!match.isUpdateCache) {
            return {};
        }
        let FirstOdds = _.take([round(oddsItem.FirstHomeWin), round(oddsItem.FirstStandoff), round(oddsItem.FirstGuestWin)], length);
        if (match.LotteryId == 73) {
            FirstOdds = [round(oddsItem.FirstHomeWin), round(oddsItem.FirstGuestWin)];
        }
        let historyodds = JSON.parse(oddsItem.Details);
        let SecondOdds = FirstOdds;
        let LastOdds = FirstOdds;
        if (match.LotteryId == 73) {
            if (historyodds && historyodds.length > 1) {
                LastOdds = [historyodds[0][0], historyodds[0][1]];
            }
            if (historyodds && historyodds.length > 2) {
                SecondOdds = [historyodds[1][0], historyodds[1][1]];
            }
        }
        else {
            if (historyodds && historyodds.length > 1) {
                LastOdds = [historyodds[0][0], historyodds[0][1], historyodds[0][2]];
            }
            if (historyodds && historyodds.length > 2) {
                SecondOdds = [historyodds[1][0], historyodds[1][1], historyodds[1][2]];
            }
        }
        //同陪历史初赔
        let { SameFirstOddsStat, SameFirstOddsList } = await getSameFirstOddsStat({ match: match, oddsItem: oddsItem, tableName: tableName });
        //同陪历史终赔
        let { SameLastOddsStat, SameLastOddsList } = await getSameLastOddsStat({ match: match, oddsItem: oddsItem, tableName: tableName });
        //同联赛同陪历史统计
        let { SameMatchTypeSameFirstOddsStat, SameMatchTypeSameFirstOddsList } = await getSameMatchTypeSameFirstOddsStat({ match: match, oddsItem: oddsItem, tableName: tableName });
        let { SameMatchTypeSameLastOddsStat, SameMatchTypeSameLastOddsList } = await getSameMatchTypeSameLastOddsStat({ match: match, oddsItem: oddsItem, tableName: tableName });
        let result = {
            CompanyId: oddsItem.CompanyId,
            CompanyName: oddsItem.CompanyName,
            FirstOdds: replaceList(FirstOdds),
            SecondOdds: replaceList(SecondOdds),
            LastOdds: replaceList(LastOdds),
            FirstKelly: getKellyList(AvgFirstOdds, FirstOdds),
            LastKelly: getKellyList(AvgLastOdds, LastOdds),
            ReturnScale: round(getKelly(LastOdds)),
            HistoryOdds: JSON.stringify(historyodds).replace(new RegExp(/(<\/span>)/g), ''),
            // 同陪历史初赔统计
            SameFirstOddsStat: SameFirstOddsStat,
            //# 同陪历史初赔列表,
            SameFirstOddsList: SameFirstOddsList,
            //# 同陪历史终赔统计
            SameLastOddsStat: SameLastOddsStat,
            //# 同陪历史终赔列表
            SameLastOddsList: SameLastOddsList,
            //# 同联赛同陪历史初赔统计
            SameMatchTypeSameFirstOddsStat: SameMatchTypeSameFirstOddsStat,
            //# 同联赛同陪历史初赔列表
            SameMatchTypeSameFirstOddsList: SameMatchTypeSameFirstOddsList,
            //# 同联赛同陪历史终赔统计
            SameMatchTypeSameLastOddsStat: SameMatchTypeSameLastOddsStat,
            //# 同联赛同陪历史终赔列表
            SameMatchTypeSameLastOddsList: SameMatchTypeSameLastOddsList,
        };
        await cache_1.redis.set(match_odds_key, JSON.stringify(result));
        cache_1.redis.expire(match_odds_key, 60 * 60 * 24);
        return result;
    });
    //平均赔率
    let AvgOdds = {
        CompanyId: 0,
        CompanyName: '百家赔率',
        FirstOdds: AvgFirstOdds,
        SecondOdds: AvgSecondOdds,
        LastOdds: AvgLastOdds,
        FirstKelly: AvgFirstKelly,
        LastKelly: AvgLastKelly,
        ReturnScale: round(AvgReturnScale),
        HistoryOdds: JSON.stringify([])
    };
    // //防止微服务挂掉
    // try {
    //   //添加一条平均赔率
    //   odds100.unshift(AvgOdds)
    //
    //   let sportdtOdds = await api_hemera.query('info', 'getsportdodds100', root, {
    //     Id: match.Id,
    //     AvgFirstOdds: AvgFirstOdds,
    //     AvgLastOdds: AvgLastOdds
    //   })
    //   if (sportdtOdds && sportdtOdds.length > 0)
    //     odds100 = _.concat(odds100, sportdtOdds)
    // }catch (e:any){}
    return { odds100: odds100,
        AvgOdds: AvgOdds,
    };
}
//计算概率
function staticProbability({ match, AvgOdds }) {
    let firstScale = round(getKelly(AvgOdds.FirstOdds));
    //# 概率, 主胜，平局 客胜
    let MaxProbabilityName = '主胜';
    if (AvgOdds.LastOdds[1] < AvgOdds.LastOdds[0] && AvgOdds.LastOdds[1] < AvgOdds.LastOdds[2]) {
        MaxProbabilityName = '平局';
    }
    else if (AvgOdds.LastOdds[2] < AvgOdds.LastOdds[0] && AvgOdds.LastOdds[2] < AvgOdds.LastOdds[1]) {
        MaxProbabilityName = '客胜';
    }
    let Probability;
    if (match.LotteryId == 73) {
        Probability = {
            HostProbability: 100 - Math.round(AvgOdds.ReturnScale / AvgOdds.LastOdds[1]),
            FlatProbability: null,
            GuestProbability: Math.round(AvgOdds.ReturnScale / AvgOdds.LastOdds[1]),
            MaxProbabilityName: MaxProbabilityName,
            FirstProbability: [round(firstScale / AvgOdds.FirstOdds[0]), round(firstScale / AvgOdds.FirstOdds[1])],
            LastProbability: [round(AvgOdds.ReturnScale / AvgOdds.LastOdds[0]), round(AvgOdds.ReturnScale / AvgOdds.LastOdds[1])],
        };
    }
    else {
        Probability = {
            HostProbability: 100 - Math.round(AvgOdds.ReturnScale / AvgOdds.LastOdds[1]) - Math.round(AvgOdds.ReturnScale / AvgOdds.LastOdds[2]),
            FlatProbability: Math.round(AvgOdds.ReturnScale / AvgOdds.LastOdds[1]),
            GuestProbability: Math.round(AvgOdds.ReturnScale / AvgOdds.LastOdds[2]),
            MaxProbabilityName: MaxProbabilityName,
            FirstProbability: [round(firstScale / AvgOdds.FirstOdds[0]), round(firstScale / AvgOdds.FirstOdds[1]), round(firstScale / AvgOdds.FirstOdds[2])],
            LastProbability: [round(AvgOdds.ReturnScale / AvgOdds.LastOdds[0]), round(AvgOdds.ReturnScale / AvgOdds.LastOdds[1]), round(AvgOdds.ReturnScale / AvgOdds.LastOdds[2])],
        };
    }
    return Probability;
}
//替换字符串列表的乱字符
function replaceList(list) {
    return _.map(list, (item) => {
        return item.replace(new RegExp(/(<\/span>)/g), '');
    });
}
//计算亚盘 让球 大小球
async function staticAsia({ match, oddsList, tableName }) {
    let length = match.LotteryId == 73 ? 2 : 3;
    let result = await _.map(oddsList, async (item) => {
        let match_odds_key = `${config.CachePrefix}match:match_${tableName}:v18_${match.Id}:${item.CompanyId}`;
        let replyMatch = await cache_1.redis.get(match_odds_key);
        if (replyMatch && replyMatch.length > 0 && !match.isUpdateCache) {
            return JSON.parse(replyMatch);
        }
        else if (!match.isUpdateCache) {
            return {};
        }
        let historyodds = item.Details ? JSON.parse(item.Details) : [];
        if (historyodds.length == 0)
            return {};
        let LastOdds = _.take(historyodds[0], length);
        let SecondOdds = LastOdds;
        let FirstOdds = LastOdds;
        if (historyodds && historyodds.length > 1) {
            FirstOdds = _.take(historyodds[historyodds.length - 1], length);
            SecondOdds = _.take(historyodds[1], length);
        }
        //同陪历史初赔
        let { SameFirstOddsStat, SameFirstOddsList } = await getSameFirstOddsStat({ match: match, oddsItem: item, tableName: tableName });
        //同陪历史终赔
        let { SameLastOddsStat, SameLastOddsList } = await getSameLastOddsStat({ match: match, oddsItem: item, tableName: tableName });
        //同联赛同陪历史统计
        let { SameMatchTypeSameFirstOddsStat, SameMatchTypeSameFirstOddsList } = await getSameMatchTypeSameFirstOddsStat({ match: match, oddsItem: item, tableName: tableName });
        let { SameMatchTypeSameLastOddsStat, SameMatchTypeSameLastOddsList } = await getSameMatchTypeSameLastOddsStat({ match: match, oddsItem: item, tableName: tableName });
        let result = {
            CompanyId: item.CompanyId,
            CompanyName: item.CompanyName,
            FirstOdds: replaceList(FirstOdds),
            SecondOdds: replaceList(SecondOdds),
            LastOdds: replaceList(LastOdds),
            HistoryOdds: JSON.stringify(historyodds).replace(new RegExp(/(<\/span>)/g), ''),
            // 同陪历史初赔统计
            SameFirstOddsStat: SameFirstOddsStat,
            //# 同陪历史初赔列表,
            SameFirstOddsList: SameFirstOddsList,
            //# 同陪历史终赔统计
            SameLastOddsStat: SameLastOddsStat,
            //# 同陪历史终赔列表
            SameLastOddsList: SameLastOddsList,
            //# 同联赛同陪历史初赔统计
            SameMatchTypeSameFirstOddsStat: SameMatchTypeSameFirstOddsStat,
            //# 同联赛同陪历史初赔列表
            SameMatchTypeSameFirstOddsList: SameMatchTypeSameFirstOddsList,
            //# 同联赛同陪历史终赔统计
            SameMatchTypeSameLastOddsStat: SameMatchTypeSameLastOddsStat,
            //# 同联赛同陪历史终赔列表
            SameMatchTypeSameLastOddsList: SameMatchTypeSameLastOddsList,
        };
        cache_1.redis.set(match_odds_key, JSON.stringify(result));
        if (match.MatchState == '未')
            cache_1.redis.expire(match_odds_key, 60 * 60 * 24);
        else
            cache_1.redis.expire(match_odds_key, 60 * 60 * 24);
        return result;
    });
    return result;
}
//计算同陪,改成实时计算，数据取缓存数据，当前赔率取实时
//将历史数据都存储在redis中
async function getHistorySameOdds(match) {
    //检查是否已经有数据
    let keyMatch = `${config.CachePrefix}match:matchgetHistorySameOdds_v1_${match.Id}`;
    let replyList;
    replyList = await cache_1.redis.get(keyMatch);
    if (replyList && replyList.length > 0 && !match.isUpdateCache) {
        return JSON.parse(replyList);
    }
    //检查是否已经有所有的记录
    let allMatchList = [];
    let keyAllMatch = `${config.CachePrefix}match:matchbylottery_${match.LotteryId}`;
    if (match.isUpdateLocalCache) {
        localOddsDbData[match.LotteryId] = null;
    }
    if (localOddsDbData[match.LotteryId]) {
        allMatchList = localOddsDbData[match.LotteryId];
    }
    else {
        allMatchList = await cache_1.redis.get(keyAllMatch);
        if (allMatchList != null) {
            allMatchList = JSON.parse(allMatchList);
        }
    }
    if (allMatchList == null || allMatchList.length == 0) {
        // allMatchList = await Core.sequelize.query(`
        //     SELECT "Id", "InfoId", "GuestName", "HostName", "GameName", "MatchTime", "HostId", "GuestId","Results","BetSps","QcBf","ResultSps" 
        //     FROM core_match WHERE "MatchTime">'${moment().add(-2,'year').format("YYYY-MM-DD")}' and "LotteryId"=${match.LotteryId} 
        //     AND "Results" IS NOT null
        // `)
        // allMatchList = checkOddsList(allMatchList)
        // if(match.isUpdateCache) {
        //   localOddsDbData[match.LotteryId] = null;
        //   localOddsDbData[match.LotteryId] = allMatchList
        // }else {
        //   await client.set(keyAllMatch, JSON.stringify(allMatchList))
        //   client.expire(keyAllMatch, 60 * 60 * 24)
        // }
    }
    let resultItem = _.split(match.ResultSps, ',');
    let lastEndBet = getLastEndBet(match);
    allMatchList = _.filter(allMatchList, (item) => {
        let checkItem;
        if (match.LotteryId == 72) {
            if (item.BetSps)
                checkItem = JSON.parse(item.BetSps)["7206"];
            if (resultItem == null || resultItem.length < 2)
                resultItem = JSON.parse(match.BetSps)["7206"];
        }
        else if (match.LotteryId == 73) {
            if (item.BetSps)
                checkItem = JSON.parse(item.BetSps)["7301"];
            if (resultItem == null || resultItem.length < 2)
                resultItem = JSON.parse(match.BetSps)["7301"];
            if (checkItem && resultItem && Math.abs(checkItem[0] - resultItem[0]) <= 0.025
                && Math.abs(checkItem[1] - resultItem[1]) <= 0.025) {
                return true;
            }
            return false;
        }
        else if (match.LotteryId == 45) {
            if (item.BetSps)
                checkItem = JSON.parse(item.BetSps)["4501"];
            if (resultItem == null || resultItem.length < 2)
                resultItem = JSON.parse(match.BetSps)["4501"];
        }
        else {
            if (item.BetSps)
                checkItem = _.takeRight(_.split(item.ResultSps, ','), 3);
        }
        //大的那个控制在0。05以内
        let itemsCheckValue = _.map(checkItem, item => {
            if (item == _.max(checkItem)) {
                return 0.055;
            }
            else {
                return 0.025;
            }
        });
        if (checkItem && resultItem && Math.abs(checkItem[0] - resultItem[0]) <= itemsCheckValue[0]
            && Math.abs(checkItem[1] - resultItem[1]) <= itemsCheckValue[1]
            && Math.abs(checkItem[2] - resultItem[2]) <= itemsCheckValue[2]) {
            return true;
        }
        return false;
    });
    let AllCount = 0;
    let WinCount = 0;
    let FlatCount = 0;
    let LostCount = 0;
    allMatchList = _.map(allMatchList, (item) => {
        let checkItem = {};
        let ResultSocre = '';
        let QcbfList = _.split(item.QcBf, '-');
        AllCount++;
        if (QcbfList && QcbfList.length == 2 && parseInt(QcbfList[0]) < parseInt(QcbfList[1])) {
            ResultSocre = '负';
            LostCount++;
        }
        else if (QcbfList && QcbfList.length == 2 && parseInt(QcbfList[0]) == parseInt(QcbfList[1])) {
            ResultSocre = '平';
            FlatCount++;
        }
        else if (QcbfList && QcbfList.length == 2 && parseInt(QcbfList[0]) > parseInt(QcbfList[1])) {
            ResultSocre = '胜';
            WinCount++;
        }
        if (match.LotteryId == 72) {
            if (item.BetSps)
                checkItem = JSON.parse(item.BetSps)["7206"];
        }
        else if (match.LotteryId == 73) {
            if (item.BetSps)
                checkItem = JSON.parse(item.BetSps)["7301"];
        }
        else if (match.LotteryId == 45) {
            if (item.BetSps)
                checkItem = JSON.parse(item.BetSps)["4501"];
        }
        else {
            if (item.BetSps)
                checkItem = JSON.parse(item.BetSps)["7206"];
        }
        return {
            GameName: item.GameName,
            MatchTime: item.MatchTime,
            HostName: item.HostName,
            GuestName: item.GuestName,
            Qcbf: item.QcBf,
            ResultOdds: checkItem,
            ResultSocre: ResultSocre,
        };
    });
    AllCount = WinCount + FlatCount + LostCount;
    let result = {
        ResultSps: match.ResultSps,
        BetSps: match.BetSps,
        LastEndBet: JSON.stringify(lastEndBet),
        AllCount: AllCount,
        WinCount: WinCount,
        FlatCount: FlatCount,
        LostCount: LostCount,
        WinRate: AllCount > 0 ? round(1 - parseFloat(round(FlatCount / AllCount)) - parseFloat(round(LostCount / AllCount))) : null,
        FlatRate: AllCount > 0 ? round(FlatCount / AllCount) : null,
        LostRate: AllCount > 0 ? round(LostCount / AllCount) : null,
        SameOddsList: JSON.stringify(allMatchList),
    };
    await cache_1.redis.set(keyMatch, JSON.stringify(result));
    cache_1.redis.expire(keyMatch, 60 * 60 * 24);
    return result;
}
function getLastEndBet(match) {
    let lastEndBet = [];
    if (match.LotteryId == 72) {
        if (match.BetSps)
            lastEndBet = JSON.parse(match.BetSps)["7206"];
    }
    else if (match.LotteryId == 73) {
        if (match.BetSps)
            lastEndBet = JSON.parse(match.BetSps)["7301"];
    }
    else if (match.LotteryId == 45) {
        if (match.BetSps)
            lastEndBet = JSON.parse(match.BetSps)["4501"];
    }
    else {
        if (match.BetSps)
            lastEndBet = _.takeRight(_.split(match.ResultSps, ','), 3);
    }
    lastEndBet = _.map(lastEndBet, t => round(t));
    return lastEndBet;
}
//只获取部分字段
function getOddShortInfo(odd) {
    return {
        CompanyId: odd.CompanyId,
        CompanyName: odd.CompanyName,
        FirstOdds: odd.FirstOdds,
        SecondOdds: odd.SecondOdds,
        LastOdds: odd.LastOdds,
    };
}
async function getOdds(match) {
    //获取数据库数据
    //match.isUpdateCache=true
    // if(!match.isUpdateCache){
    //   return {
    //     Odds100: [],
    //     OddsLetGoal: [],
    //     OddsBigSmall: [],
    //     HistorySameOdds: [],
    //     OddsInfo:'[]',
    //   }
    // }
    let { oddsList, oddsLetGoalList, oddsBigSmallList } = await getOddsDbData(match);
    if (!oddsList) {
        return {
            Odds100: [],
            OddsLetGoal: [],
            OddsBigSmall: [],
            HistorySameOdds: [],
            OddsInfo: '[]',
        };
    }
    //计算百家赔率，以及平均赔率
    let { odds100, AvgOdds } = await staticOdds100({ match: match, oddsList: oddsList, tableName: 'Odds100' });
    //计算预测
    let Probability = staticProbability({ match, AvgOdds });
    //计算大小球
    let OddsBigSmall = await staticAsia({ match: match, oddsList: oddsBigSmallList, tableName: 'OddsBigSmall' });
    //计算同陪
    //将历史数据都存储在redis中
    //let historyOdds Results BetSps Id LotteryId 7206 7301 4501 ResultSps QcBf
    //let HistorySameOdds=[]
    let HistorySameOdds = await getHistorySameOdds(match);
    //计算让球
    let OddsLetGoal = await staticAsia({ match: match, oddsList: oddsLetGoalList, tableName: 'OddsLetGoal' });
    let asiaOdds = {};
    if (OddsLetGoal.length > 0)
        asiaOdds = await OddsLetGoal[0];
    //赔率的情报数据
    let OddsInfo = [getOddShortInfo(asiaOdds), getOddShortInfo(AvgOdds)];
    return {
        Odds100: odds100,
        Probability: Probability,
        OddsLetGoal: OddsLetGoal,
        OddsBigSmall: OddsBigSmall,
        HistorySameOdds: HistorySameOdds,
        OddsInfo: JSON.stringify(OddsInfo),
    };
}
exports.getOdds = getOdds;
//# sourceMappingURL=odds.js.map