import {db as Info} from '../table'
import _ = require('lodash');

import moment = require("moment");
import { cache,redis as client, redis, task_lock } from '../../../cache'

let localOddsDbData:any = {}

//获取凯利列表
function getKellyList(AvgOdds:any, Odds:any){
  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:any){
  return 100.0/_.sumBy(Odds, (o:any) => {return 1/o});
}

function round(value:any){
  return (Math.round(value*100)/100).toFixed(2)
}

//获取数据库数据，足球
async function getZqOddsDbData(match:any){
  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 Info.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 Info.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 Info.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}:any){
  oddsList=checkOddsList(oddsList)
  oddsLetGoalList=checkOddsList(oddsLetGoalList)
  oddsBigSmallList=checkOddsList(oddsBigSmallList)

  return {oddsList:oddsList, oddsLetGoalList:oddsLetGoalList, oddsBigSmallList:oddsBigSmallList}
}

function checkOddsList(list:any){
  if(list && list.length>0){
    return list[0]
  }
  return []
}

//获取数据库数据，篮球
async function getLqOddsDbData(match:any){
  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 Info.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 Info.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 Info.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:any){
  let match_odds_key = `${config.CachePrefix}match:match_getOddsDbData:v3_${match.Id}`
  let replyMatch = await client.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 client.set(match_odds_key, JSON.stringify(result))
  client.expire(match_odds_key, 60 * 60 * 24)
  //标识此场比赛已经缓存
  client.set(`${config.CachePrefix}match:match_odds:${match.Id}`, match.Id)
  client.expire(`${config.CachePrefix}match:match_odds:${match.Id}`, 60 * 60 * 24)
  return result;
}

function getCheckField(tableName:any){
  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}:any){
  let Nba = match.LotteryId ==73 ? 'NBA' : ''
  let {checkHomeField,checkGuestField,valueHomeField,valueGuestField} = getCheckField(tableName)

  if(oddsItem[`First${valueHomeField}`]==null){
    return {
      SameFirstOddsStat:'',
      SameFirstOddsList:'',
    }
  }

  let sameOddsList = await Info.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}:any){
  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 Info.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}:any){
  let Nba = match.LotteryId ==73 ? 'NBA' : ''
  let {checkHomeField,checkGuestField,valueHomeField,valueGuestField} = getCheckField(tableName)
  if(oddsItem[`First${valueHomeField}`]==null){
    return {
      SameMatchTypeSameFirstOddsStat:'',
      SameMatchTypeSameFirstOddsList:'',
    }
  }
  let sameOddsList = await Info.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:any){
  let AllCount = 0
  let WinCount = 0
  let FlatCount = 0
  let LostCount = 0
  let WinRate:any = 0
  let FlatRate:any = 0
  let LostRate:any = 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}:any){
  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 Info.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}:any){
  //计算平均指数
  let length = match.LotteryId == 73 ? 2 :3
  let AvgFirstOdds:any = _.take([0,0,0],length)
  let AvgSecondOdds:any = _.take([0,0,0],length)
  let AvgLastOdds:any = _.take([0,0,0],length)
  let AvgFirstKelly:any = _.take([0,0,0],length)
  let AvgLastKelly:any = _.take([0,0,0],length)
  let oddsListLength=oddsList.length

  if(match.LotteryId == 73){
    _.map(oddsList, (oddsItem) => {
      let FirstOdds:any = [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:any = [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 client.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 client.set(match_odds_key,JSON.stringify(result))
    client.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}:any){
  let firstScale:any=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:any){
  return _.map(list,(item) =>{
    return item.replace(new RegExp(/(<\/span>)/g),'')
  })
}

//计算亚盘 让球 大小球
async function staticAsia({match,oddsList,tableName}:any){
  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 client.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,
    }
    client.set(match_odds_key,JSON.stringify(result))
    if(match.MatchState == '未')
      client.expire(match_odds_key, 60*60*24)
    else
      client.expire(match_odds_key, 60*60*24)
    return result
  })
  return result
}

//计算同陪,改成实时计算，数据取缓存数据，当前赔率取实时
//将历史数据都存储在redis中
async function getHistorySameOdds(match:any){
  //检查是否已经有数据
  let keyMatch = `${config.CachePrefix}match:matchgetHistorySameOdds_v1_${match.Id}`
  let replyList
  replyList = await client.get(keyMatch);
  if(replyList && replyList.length>0 && !match.isUpdateCache){
    return JSON.parse(replyList)
  }

  //检查是否已经有所有的记录
  let allMatchList:any = []
  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 client.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:any = _.split(match.ResultSps,',')

  let lastEndBet =getLastEndBet(match)

  allMatchList = _.filter(allMatchList, (item) =>{
    let checkItem:any
    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 client.set(keyMatch,JSON.stringify(result))
  client.expire(keyMatch, 60*60*24)
  return result
}

function getLastEndBet(match:any) {
  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:any){
  return {
    CompanyId: odd.CompanyId,
    CompanyName: odd.CompanyName,
    FirstOdds:  odd.FirstOdds,
    SecondOdds: odd.SecondOdds,
    LastOdds: odd.LastOdds,
  }
}

export async function getOdds(match:any) {
  //获取数据库数据
  //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),
  }
}