"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.CompetitionResult = exports.ZqSpPercent = exports.statProbability = exports.liveScore = exports.get_core_match = exports.gp_liveScore = exports.start_realtime_message_task = void 0;
const Model = require("../model");
const sequelize = require("sequelize");
const moment = require("moment");
const _ = require("lodash");
const api_hemera = require("../../../api_hemera");
const ms_schedule = require("./ms_schedule");
const nami_data = require("../../../nami/nami_data");
const cache_1 = require("../../../cache");
const config = require("../../../../config");
const Core = require("../table");
const info_db = require("../table");
const md5 = require("md5");
const zlib = require("zlib");
const matchlock = { flag: false };
async function start_realtime_message_task() {
}
exports.start_realtime_message_task = start_realtime_message_task;
async function gp_liveScore(root, args, context) {
    //return await matchImp.liveScore(root, args, context, null);
    let result = await liveScore({}, args, {}, null);
    // let result = await cache(async (args: any) => {
    //   return await liveScore({}, args, {}, null)
    // }, args, 3, 'liveScore:v1')
    // let result = await cache(async (args: any) => {
    //   let result = await liveScore({}, args, {}, null);
    //   let buffer = await zlib.gzipSync(JSON.stringify(result))
    //   let z_result = buffer.toString("base64");
    //   return z_result
    // }, args, 3, 'liveScore:v2')
    // if(result){
    //   const buffer = Buffer.from(result, 'base64');
    //   let str_json_result = (await zlib.unzipSync(buffer)).toString();
    //   result = JSON.parse(str_json_result)
    // }
    //弥补ios客户端错误，将count=0的强制为null
    if (result == null || result.count == 0) {
        return {
            count: 0,
            matchs: null,
        };
    }
    //
    //获取nami的足球实时比分数据
    try {
        if (args.matchState == '未' && [72, 45].includes(args.lottery_id)) {
            result.matchs = await this.addNamiScoreLiveData(result.matchs);
        }
    }
    catch (e) {
        console.info(e);
    }
    return result;
}
exports.gp_liveScore = gp_liveScore;
const liveScore = async (root, args, context, isUpdateCache) => {
    let md5Result = md5(JSON.stringify(args)).toUpperCase();
    //add test 
    let key = `${config.CachePrefix}match:match_liveScore:v11_t_${md5Result}`;
    let keyCount = `${config.CachePrefix}match:match_liveScoreCount:v11_t_${md5Result}`;
    let reply = null;
    //isUpdateCache = true;
    if (!isUpdateCache)
        reply = await get10SecondsCache(key, keyCount);
    if (reply != null && !isUpdateCache) {
        return reply;
    }
    //数据库出现问题的话，则使用24小时的缓存
    if (matchlock.flag && !isUpdateCache) {
        reply = await get24HoursCache(key, keyCount);
        return reply;
    }
    else {
        reply = await get24HoursCache(key, keyCount);
        if (reply && args.coreIds == null) {
            doGetLiveScore(root, args, context, isUpdateCache, key, keyCount);
            return reply;
        }
        else {
            return await doGetLiveScore(root, args, context, isUpdateCache, key, keyCount);
        }
    }
    return await doGetLiveScore(root, args, context, isUpdateCache, key, keyCount);
};
exports.liveScore = liveScore;
async function doGetLiveScore(root, args, context, isUpdateCache, key, keyCount) {
    try {
        matchlock.flag = true;
        //检查参数
        let where = await getWheres(args);
        //检查分页
        let { limit, offset, order } = checkPages(args);
        //从数据库中获取数据
        let { t, count } = await queryMatchsFromDb(limit, where, offset, order, args);
        let counts = count[0] || 0;
        //记录查询锁
        matchlock.flag = false;
        //实时整理初始的数据，足球与篮球通用，不需要查询微服务的部分
        t = initBaseMatchsData(t);
        //获取7M sportsdt的数据,足球与篮球通用
        try {
            t = await initSportsdtBaseData(t);
        }
        catch (e) {
            console.info(e);
        }
        //获取7M的足球实时比分数据
        try {
            t = await addSportsdtScoreLiveData(t);
        }
        catch (e) {
            console.info(e);
        }
        //获取nami的足球实时比分数据
        try {
            t = await addNamiScoreLiveData(t);
        }
        catch (e) {
            console.info(e);
        }
        //获取7M的篮球实时比分数据
        try {
            t = await addSportsdtBasketballLiveData(t);
        }
        catch (e) {
            console.info(e);
        }
        //计算情报数据
        t = getSportsInfoCount(t);
        //测试数据，此部分的代码只是为了测试使用
        if (args.isTest != null && args.isTest == 1) {
            addTestData(t);
        }
        //重新排序
        //t= JSON.parse( JSON.stringify(t))
        if (args.order == null) {
            t = _.concat(_.filter(t, (o) => o.MatchState != "未" && o.Sportsdt && o.Sportsdt.SportsdtMatchId), _.filter(t, (o) => o.MatchState == "未" && o.Sportsdt && o.Sportsdt.SportsdtMatchId));
        }
        if (args.infoId && t.length > 1) {
            //优先使用竞足的数据
            t = _.concat(_.orderBy(_.filter(t, (o) => o.LotteryId == 72), ['MatchTime'], ['desc']), _.orderBy(_.filter(t, (o) => o.LotteryId == 45), ['MatchTime'], ['desc']), _.orderBy(_.filter(t, (o) => o.LotteryId != 72 && o.LotteryId != 45), ['MatchTime'], ['desc']));
            //t=_.orderBy(t,['MatchTime'],['desc'])
            t = _.take(t, 1);
        }
        if (args.lotId == 45 || args.lotId == 74) {
            t = _.orderBy(t, (o) => {
                return parseInt(o.IssueName) * 1000 + parseInt(o.MatchNumber);
            });
        }
        let result = { matchs: t, count: counts.dataValues ? counts.dataValues.count || 0 : 0 };
        //防止恶意进攻，超过查询范围内的不进入到缓存
        if (t.length > 0) {
            setMatchs(key, keyCount, result, args);
        }
        return result;
    }
    catch (e) {
        console.info(e);
        matchlock.flag = false;
        let result = await get24HoursCache(key, keyCount);
        if (result) {
            setMatchs(key, keyCount, result, args);
            return result;
        }
        else {
            throw e;
        }
    }
    //基础数据查询数据库，篮球实时比分的数据查询老的core数据库
    async function queryMatchsFromDb(limit, where, offset, order, args) {
        if (args.lotId == 73) {
            // let t =  getMatchListFromOldDb(limit, where, offset, order);
            // //从数据库中获取总记录数
            // let count =  getMatchCountFromOldDb(where);
            let t = getMatchListFromDb(limit, where, offset, order);
            //从数据库中获取总记录数
            let count = getMatchCountFromDb(where);
            let result = await Promise.all([t, count]);
            let matchs = _.map(result[0], (match) => {
                //match.MatchTime = moment(match.MatchTime).valueOf();
                return match;
            });
            return { t: matchs, count: result[1] };
        }
        else {
            let t = getMatchListFromDb(limit, where, offset, order);
            //从数据库中获取总记录数
            let count = getMatchCountFromDb(where);
            let result = await Promise.all([t, count]);
            let matchs = _.map(result[0], (match) => {
                //match.MatchTime = moment(match.MatchTime).valueOf();
                return match;
            });
            return { t: matchs, count: result[1] };
        }
    }
    //足球实时比分
    async function addSportsdtScoreLiveData(t) {
        try {
            if (args.infoId != null || args.matchState == '未' || args.matchState == '进行中' || (t.length == 1)) {
                let livedata = await api_hemera.query('sport', 'getlivedata_from_db', root, {}, 1);
                if (livedata == null) {
                    livedata = await api_hemera.queryWithRealtimeFirst('sport', 'getlivedata', root, {});
                }
                livedata = livedata.LiveData;
                t = _.map(t, (o) => {
                    if (o.Sportsdt.SportsdtMatchId && livedata[o.Sportsdt.SportsdtMatchId]) {
                        let sportsdtLiveData = livedata[o.Sportsdt.SportsdtMatchId];
                        let timediff = moment().diff(moment(sportsdtLiveData.TStartTime), "minutes");
                        let isUseSportsdt = true;
                        // try{
                        //   if(parseInt(o.MatchState)>timediff){
                        //     isUseSportsdt = false;
                        //   }
                        // }catch (e:any){}
                        if (isUseSportsdt) {
                            if (o.Sportsdt.SportsdtIsah == 1) {
                                o.BcBf = "";
                                if (sportsdtLiveData.Half.length > 0) {
                                    let bcbfs = sportsdtLiveData.Half.split("-");
                                    o.BcBf = `${bcbfs[1]}-${bcbfs[0]}`;
                                }
                                if (sportsdtLiveData.Score.length == 2)
                                    o.QcBf = `${sportsdtLiveData.Score[1]}-${sportsdtLiveData.Score[0]}`;
                                o.HostRed = sportsdtLiveData.RedCard[1];
                                o.GuestRed = sportsdtLiveData.RedCard[0];
                                o.HostYellow = sportsdtLiveData.YellowCard[1];
                                o.GuestYellow = sportsdtLiveData.YellowCard[0];
                            }
                            else {
                                o.BcBf = sportsdtLiveData.Half;
                                if (sportsdtLiveData.Score.length == 2)
                                    o.QcBf = `${sportsdtLiveData.Score[0]}-${sportsdtLiveData.Score[1]}`;
                                o.HostRed = sportsdtLiveData.RedCard[0];
                                o.GuestRed = sportsdtLiveData.RedCard[1];
                                o.HostYellow = sportsdtLiveData.YellowCard[0];
                                o.GuestYellow = sportsdtLiveData.YellowCard[1];
                            }
                            switch (sportsdtLiveData.Status) {
                                case 1:
                                    o.MatchState = timediff <= 45 ? `${timediff}` : "45+";
                                    break;
                                case 2:
                                    o.MatchState = "中场";
                                    break;
                                case 3:
                                    o.MatchState = timediff <= 45 ? `${45 + timediff}` : "90+";
                                    break;
                                case 4:
                                    o.MatchState = "完";
                                    break;
                            }
                            //             比赛状态值，表示如下
                            // 0 ：未开始
                            // 1：上半场
                            // 2：中场
                            // 3：下半场
                            // 4：完场
                            // 5：中断
                            // 6：取消
                            // 7：加时
                            // 8：加时
                            // 9：加时
                            // 10：完场
                            // 11：点球大战
                            // 12：全场结束
                            // 13：延期
                            // 14: 腰斩
                            // 15: 待定
                            // 16：金球
                            // 17：未开始
                            // *0、17同为未开始，7、8、9为加时，4、10、12完场
                            //篮球状态
                            // 0 ：未开始
                            // 1：第一节
                            // 2：第一节完
                            // 3：第二节
                            // 4：第二节完
                            // 5：第三节
                            // 6：第三节完
                            // 7：第四节
                            // 8：第四节完
                            // 9：完场
                            // 10：加时
                            // 11：完场(加)
                            // 12：中断
                            // 13：取消
                            // 14: 延期
                            // 15: 腰斩
                            // 16待定
                        }
                    }
                    return o;
                });
            }
        }
        catch (e) {
            console.info(e);
        }
        return t;
    }
    //纳米数据的实时比分
    async function addNamiScoreLiveData(t) {
        try {
            if ((args.matchState == '未' || args.matchState == '进行中') && (t.length >= 1)) {
                // console.info(`begin addNamiScoreLiveData`);
                let nami_score_list_obj = await nami_data.get_local_nami_realtime_score();
                let sportsdt_id_list = _.map(nami_score_list_obj.id_list, "sportsdt_match_id");
                t = _.map(t, (o) => {
                    if (o.Sportsdt.SportsdtMatchId && sportsdt_id_list.includes(o.Sportsdt.SportsdtMatchId)) {
                        let leisu_id = _.find(nami_score_list_obj.id_list, (id_obj) => {
                            return id_obj.sportsdt_match_id == o.Sportsdt.SportsdtMatchId;
                        }).leisu_match_id;
                        let livedata = _.find(nami_score_list_obj.list, (name_obj) => { return name_obj.id == leisu_id; });
                        // let livedata = _.find(nami_score_list_obj.list,(name_obj)=>{return name_obj.score[1]>1});//测试
                        // console.info(JSON.stringify(livedata),moment(livedata.score[4]*1000).format("YYYY-MM-DD HH:mm:ss"));
                        if (livedata == null) {
                            return o;
                        }
                        // console.info(`找到的雷速数据`)
                        let score_list = livedata.score;
                        // livedata.score字段格式：[2783605,8,[1, 0, 0, 0, -1, 0, 0],[1, 0, 0, 0, -1, 0, 0],0,""]
                        // 0:"纳米比赛id - int"
                        // 1:"比赛状态，详见状态码->比赛状态 - int"
                        // 2:Array[7]
                        // 0:"主队比分(常规时间) - int"
                        // 1:"主队半场比分 - int"
                        // 2:"主队红牌 - int"
                        // 3:"主队黄牌 - int"
                        // 4:"主队角球，-1表示没有角球数据 - int"
                        // 5:"主队加时比分(120分钟，即包括常规时间比分)，加时赛才有 - int"
                        // 6:"主队点球大战比分(不包含常规时间及加时赛比分)，点球大战才有 - int"
                        // 3:Array[7]
                        // 0:"客队比分(常规时间) - int"
                        // 1:"客队半场比分 - int"
                        // 2:"客队红牌 - int"
                        // 3:"客队黄牌 - int"
                        // 4:"客队角球，-1表示没有角球数据 - int"
                        // 5:"客队加时比分(120分钟，即包括常规时间比分)，加时赛才有 - int"
                        // 6:"客队点球大战比分(不包含常规时间及加时赛比分)，点球大战才有 - int"
                        // 4:"开球时间戳，上/下半场开球时间(根据比赛状态判断) - int"
                        // 5:"备注信息，可忽略 - string"
                        let timediff = moment().add(4, 'second').diff(moment(score_list[4] * 1000), "minutes");
                        if (o.Sportsdt.SportsdtIsah != 1) {
                            o.QcBf = `${score_list[2][0]}-${score_list[3][0]}`;
                            o.BcBf = `${score_list[2][1]}-${score_list[3][1]}`;
                            o.HostRed = score_list[2][2];
                            o.GuestRed = score_list[3][2];
                            o.HostYellow = score_list[2][4];
                            o.GuestYellow = score_list[3][4];
                        }
                        else {
                            o.QcBf = `${score_list[3][0]}-${score_list[2][0]}`;
                            o.BcBf = `${score_list[3][1]}-${score_list[2][1]}`;
                            o.HostRed = score_list[3][2];
                            o.GuestRed = score_list[2][2];
                            o.HostYellow = score_list[3][4];
                            o.GuestYellow = score_list[2][4];
                        }
                        // 状态码score_list[1]	描述
                        // 0	比赛异常，说明：暂未判断具体原因的异常比赛，可能但不限于：腰斩、取消等等，建议隐藏处理
                        // 1	未开赛
                        // 2	上半场
                        // 3	中场
                        // 4	下半场
                        // 5	加时赛
                        // 6	加时赛(弃用)
                        // 7	点球决战
                        // 8	完场
                        // 9	推迟
                        // 10	中断
                        // 11	腰斩
                        // 12	取消
                        // 13	待定
                        switch (score_list[1]) {
                            case 2:
                                o.MatchState = timediff <= 45 ? `${timediff}` : "45+";
                                break;
                            case 3:
                                o.MatchState = "中场";
                                break;
                            case 4:
                                o.MatchState = timediff <= 45 ? `${45 + timediff}` : "90+";
                                break;
                            case 5:
                                o.MatchState = "加时";
                                break;
                            case 7:
                                o.MatchState = "点球";
                                break;
                            case 8:
                                o.MatchState = "完";
                                break;
                            case 9:
                                o.MatchState = "推迟";
                                break;
                            case 10:
                                o.MatchState = "中断";
                                break;
                            case 11:
                                o.MatchState = "腰斩";
                                break;
                            case 12:
                                o.MatchState = "取消";
                                break;
                        }
                    }
                    return o;
                });
            }
        }
        catch (e) {
            console.info(e);
        }
        return t;
    }
    //篮球实时比分
    async function addSportsdtBasketballLiveData(t) {
        try {
        }
        catch (e) {
            console.info(e);
        }
        return t;
    }
    async function initSportsdtBaseData(t) {
        // let [ms_schedules,livegame] = await Promise.all([
        //   api_hemera.query('info', 'getmsschedulesbycoreids', root, { coreIds: _.map(t, o => o.Id) }),
        //   api_hemera.query('sport', 'getlivegame', root, {})
        // ]);
        //let ms_schedules = await api_hemera.query('info', 'getmsschedulesbycoreids', root, { coreIds: _.map(t, o => o.Id) },200);
        let ms_schedules = await ms_schedule.getMsSchedulesByCoreIds({ CoreIds: _.map(t, o => o.Id) });
        t = t.map((o) => {
            o = JSON.parse(JSON.stringify(o));
            let schedule = _.find(ms_schedules, s => {
                return s.core_match_id == o.Id;
            });
            o.Sportsdt = {};
            try {
                o.YiqiuMatchId = schedule.yiqiu_match_id;
                if (schedule != null) {
                    o.Sportsdt.SportsdtMatchId = schedule.sportsdt_match_id;
                    o.Sportsdt.N = schedule.sportsdt_n;
                    o.Sportsdt.SportsdtIsah = schedule.sportsdt_isah;
                    if (o.InfoId == null && schedule.info_match_id != null) {
                        o.InfoId = schedule.info_match_id;
                    }
                    if (schedule.sportsdt_isah == 1) {
                        o.Sportsdt.SportsdtHostTeamId = schedule.sportsdt_guest_team_id;
                        o.Sportsdt.SportsdtGuestTeamId = schedule.sportsdt_host_team_id;
                    }
                    else {
                        o.Sportsdt.SportsdtHostTeamId = schedule.sportsdt_host_team_id;
                        o.Sportsdt.SportsdtGuestTeamId = schedule.sportsdt_guest_team_id;
                    }
                    o.Sportsdt.SportsdtCompetitionId = schedule.sportsdt_competition_id;
                    o.Sportsdt.SportsdtType = schedule.sportsdt_type;
                    o.Sportsdt.SportsdtDegree = schedule.sportsdt_degree;
                    o.Sportsdt.SportsdtNum = schedule.sportsdt_num;
                    o.Sportsdt.SportsdtStarttime = schedule.sportsdt_starttime;
                    o.Sportsdt.LotteryId = o.LotteryId;
                }
                //`http://data.7m.com.cn/team_data/${params.teamid}/logo_img/club_logo.jpg`
                // if(livegame&&livegame.Competition&&livegame.Competition[schedule.sportsdt_competition_id]){
                //   o.GameName = livegame.Competition[schedule.sportsdt_competition_id].ShortName
                // }
            }
            catch (e) { }
            o.Odds = {};
            try {
                if (schedule != null) {
                    o.Odds.CoreId = o.Id;
                    o.Odds.CoreLotteryId = o.LotteryId;
                    o.Odds.SportsdtId = schedule.sportsdt_match_id;
                    o.Odds.MatchState = o.MatchState;
                    o.Odds.BetSps = o.BetSps;
                    o.Odds.SportsdtIsah = o.Sportsdt.SportsdtIsah;
                }
            }
            catch (e) {
                console.info(e);
            }
            return o;
        });
        return t;
    }
    function addTestData(t) {
        if (args.matchState == '未' && t.length > 0 && args.lotId == 72) {
            t[0].MatchState = moment().format("mm");
            //t[0].QcBf = `0-${Math.round(parseInt(moment().format("ss")) / 20)}`;
            t[0].QcBf = `0-${Math.round(moment().minute() % 2)}`;
        }
        if (args.matchState == '未' && t.length > 1 && args.lotId == 72) {
            t[1].MatchState = moment().format("mm");
            //t[0].QcBf = `0-${Math.round(parseInt(moment().format("ss")) / 20)}`;
            t[1].QcBf = `0-${Math.round(moment().add(14, 'second').minute() % 3)}`;
        }
    }
    function initBaseMatchsData(t) {
        t = t.map((item) => {
            item.Issue = item.T_Issue;
            item.Lottery = item.T_Lottery;
            item.Odds100 = item.T_Odds100;
            if (!item.GameName) {
                item.GameName = '';
            }
            //应对易求页面显示，当未知天气时，天气与温度一起显示出来，天气不显示
            if (!item.Weather || item.Weather == '未知') {
                item.Weather = '';
            }
            try {
                item.MatchTime = moment(item.MatchTime).utc();
            }
            catch (e) {
                console.info(e);
            }
            try {
                if (item.Temperature && item.Temperature.indexOf('℃') < 0 && item.Temperature.length > 0) {
                    item.Temperature = item.Temperature.split('&')[0];
                    item.Temperature = `${item.Temperature}℃`;
                }
            }
            catch (e) {
                console.info(e);
            }
            //item.MatchTime = moment(item.MatchTime).add(-8, "hour");
            item.MatchState = item.MatchState.replace('节', '节 ');
            return item;
        });
        let list = [];
        for (let p of t) {
            list.push(p);
        }
        t = _.filter(list, item => {
            if (item)
                return true;
            else
                return false;
        });
        return t;
    }
    async function getMatchCountFromDb(where) {
        return await Model.Match.findAll({
            attributes: [[sequelize.fn('COUNT', sequelize.col('Id')), 'count']],
            where: where,
        });
    }
    async function getMatchListFromDb(limit, where, offset, order) {
        return await Model.Match.findAll({
            limit: limit || 20,
            // include: [
            //   { model: Model.Issue, },
            //   { model: Model.Lottery, },
            // ],
            where: where,
            offset: offset,
            order: order,
        });
    }
    async function getMatchCountFromOldDb(where) {
        // return await OldModel.Match.findAll({
        //   attributes: [[sequelize.fn('COUNT', sequelize.col('Id')), 'count']],
        //   where: where,
        // });
    }
    async function getMatchListFromOldDb(limit, where, offset, order) {
        // return await OldModel.Match.findAll({
        //   limit: limit || 20,
        //   include: [
        //     { model: OldModel.Issue, },
        //     { model: OldModel.Lottery, },
        //   ],
        //   where: where,
        //   offset: offset,
        //   order: order,
        // });
    }
    function checkPages(args) {
        // console.info(args,`check pages args`);
        let offset = 0;
        if (args.offset) {
            offset = args.offset;
        }
        let limit = 20;
        if (args.limit && args.limit <= 500 && args.limit > 0) {
            limit = args.limit;
        }
        let order = [["MatchTime", "asc"], ["Id", "asc"]];
        //let order = [['Id', 'DESC']];
        // ("LotteryId", "IssueName", "MatchNumber");
        //let order = [["LotteryId","ASC"],["IssueName","ASC"],["MatchNumber","ASC"]]
        if ((args.lotId == 45 || args.lotId == 74) && args.matchState == '未') {
            order = [["MatchTime", "asc"]];
            //[sequelize.fn('max', sequelize.col('age')), 'DESC'],
        }
        if ((args.lotId == 45 || args.lotId == 74) && args.matchState == '完') {
            order = [["IssueName", "asc"]];
        }
        if (args.lotId == 72 && args.matchState == '未') {
            order = [["MatchTime", "asc"], ["MatchNumber", "asc"]];
        }
        if (args.lotId == 72 && args.matchState == '完') {
            order = [["IssueName", "asc"], ["MatchNumber", "asc"]];
        }
        if (args.infoId) {
            limit = 10;
            order = [["MatchTime", "desc"]];
        }
        if (args.order && args.order[0]?.length == 2) {
            order = args.order;
        }
        return { limit, offset, order };
    }
}
function getSportsInfoCount(list) {
    return _.map(list, (item) => {
        if (item == null) {
            return item;
        }
        //情报
        item.SportsInfoCount = 0;
        if (item.SportsInfo) {
            if (!item.SportsInfo.HostBad)
                item.SportsInfo = JSON.parse(item.SportsInfo);
            item.SportsInfoCount = item.SportsInfoCount + item.SportsInfo.HostBad.length;
            item.SportsInfoCount = item.SportsInfoCount + item.SportsInfo.GuestBad.length;
            item.SportsInfoCount = item.SportsInfoCount + item.SportsInfo.HostGood.length;
            item.SportsInfoCount = item.SportsInfoCount + item.SportsInfo.GuestGood.length;
            if (item.SportsInfo.PredictionDesc) {
                item.SportsInfoCount = item.SportsInfoCount + 1;
            }
        }
        else {
            item.SportsInfo = {
                GuestBad: [],
                GuestGood: [],
                HostBad: [],
                HostGood: [],
                PredictionDesc: ''
            };
        }
        if (item.JcInfo) {
            try {
                let jcInfo = item.JcInfo;
                if (!item.JcInfo.HostBad)
                    jcInfo = JSON.parse(item.JcInfo);
                item.SportsInfoCount = item.SportsInfoCount + jcInfo.HostBad.length;
                item.SportsInfoCount = item.SportsInfoCount + jcInfo.GuestBad.length;
                item.SportsInfoCount = item.SportsInfoCount + jcInfo.HostGood.length;
                item.SportsInfoCount = item.SportsInfoCount + jcInfo.GuestGood.length;
                if (jcInfo.PredictionDesc) {
                    item.SportsInfoCount = item.SportsInfoCount + 1;
                }
            }
            catch (e) {
                console.info(e);
            }
        }
        //情报价格
        item.JcInfoPrice = 500;
        return item;
    });
}
async function getWheres(args) {
    let where = {};
    where.MatchTime = {
        $gt: moment().subtract(120, 'day').format('YYYY-MM-DD')
    };
    if (args.sportsdtId) {
        //let ms_schedules = await ms_schedule.getMsSchedulesByCoreIds({CoreIds:_.map(t, o => o.Id)});
        let ms_schedules_item = await info_db.ms_schedule.findOne({
            where: { sportsdt_match_id: args.sportsdtId }
        });
        if (ms_schedules_item != null) {
            where.InfoId = args.info_match_id;
            where.LotteryId = { $in: [72, 45, 73, 74] };
        }
    }
    if (args.matchIds) {
        where.Id = { $in: args.matchIds };
    }
    if (args.lotId) {
        where.LotteryId = args.lotId;
    }
    else {
        where.LotteryId = { $in: [72, 45, 73, 74] };
    }
    if (args.lotIds) {
        where.LotteryId = { $in: args.lotIds };
    }
    if (args.issueId) {
        where.IssueId = args.issueId;
    }
    if (args.infoId) {
        where.InfoId = args.infoId;
        where.LotteryId = { $in: [72, 45, 73, 74] };
    }
    if (args.matchDay) {
        try {
            where.MatchTime = {
                $between: [moment(args.matchDay).format('YYYY-MM-DD'),
                    moment(args.matchDay).add(1, 'day').format('YYYY-MM-DD')]
            };
        }
        catch (e) { }
    }
    if (args.matchState) {
        if (args.matchState == '完') {
            where.MatchState = { $in: ['完', '取消', '中断', '推迟', '改期'] };
        }
        else if (args.matchState == '未') {
            where.MatchTime = {
                $gt: moment().add(-150, 'minute').format('YYYY-MM-DD HH:mm')
            };
            where.MatchState = { $notIn: ['取消', '中断', '推迟', '腰斩', '改期'] };
        }
        else if (args.matchState == '进行中')
            where.MatchState = { $notIn: ['完', '取消', '中断', '推迟', '腰斩', '改期'] };
        else
            where.MatchState = args.matchState;
    }
    else {
        where.MatchState = { $notIn: ['腰斩'] };
    }
    if (args.type) {
    }
    if (args.userId) {
    }
    if (args.issueName && args.issueName != null) {
        //where.IssueName = {$in:[args.issueName]}
        where.IssueName = args.issueName;
    }
    if (args.isContainSportsInfo == 1) {
        where.SportsInfo = { $not: null };
    }
    if (args.isContainSportsInfo == 0) {
        where.SportsInfo = null;
    }
    return where;
}
async function get10SecondsCache(key, keyCount) {
    let reply = await cache_1.redis.get(`${key}_${moment().format('YYYYMMDDHH')}`);
    if (reply && reply.length > 0) {
        let replyCount = await cache_1.redis.get(`${keyCount}_${moment().format('YYYYMMDDHH')}`);
        const buffer = Buffer.from(reply, 'base64');
        let str_json_result = (await zlib.unzipSync(buffer)).toString();
        reply = JSON.parse(str_json_result);
        reply = getSportsInfoCount(reply);
        let result = { matchs: reply, count: JSON.parse(replyCount) };
        return result;
    }
    return null;
}
async function get24HoursCache(key, keyCount) {
    let time24 = 'time24';
    key = key + time24;
    let reply = await cache_1.redis.get(`${key}`);
    if (reply && reply.length > 0) {
        let replyCount = await cache_1.redis.get(`${keyCount}`);
        const buffer = Buffer.from(reply, 'base64');
        let str_json_result = (await zlib.unzipSync(buffer)).toString();
        reply = JSON.parse(str_json_result);
        reply = getSportsInfoCount(reply);
        let result = { matchs: reply, count: JSON.parse(replyCount) };
        return result;
    }
    return null;
}
async function setMatchs(key, keyCount, result, args) {
    let buffer = await zlib.gzipSync(JSON.stringify(result.matchs));
    let z_result = buffer.toString("base64");
    await cache_1.redis.setex(`${key}_${moment().format('YYYYMMDDHH')}`, 20, z_result);
    //更新为5秒
    cache_1.redis.expire(`${key}_${moment().format('YYYYMMDDHH')}`, 20);
    await cache_1.redis.setex(`${keyCount}_${moment().format('YYYYMMDDHH')}`, 20, JSON.stringify(result.count));
    //更新为5秒
    cache_1.redis.expire(`${keyCount}_${moment().format('YYYYMMDDHH')}`, 20);
    let time24 = 'time24';
    await cache_1.redis.setex(key + time24, 60 * 60 * 24 * 7, z_result);
    cache_1.redis.expire(key + time24, 60 * 60 * 24 * 7);
    await cache_1.redis.setex(keyCount + time24, 60 * 60 * 24 * 7, JSON.stringify(result.count));
    cache_1.redis.expire(keyCount + time24, 60 * 60 * 24 * 7);
}
//计算概率
const statProbability = async (match) => {
    let oddsList = [];
    if (match.InfoId && match.LotteryId != 73) {
        oddsList = await Model.Odds100.findAll({ where: { MatchId: match.InfoId } });
    }
    else if (match.InfoId && match.LotteryId == 73) {
        //oddsList = await Model.NBAOdds100.findAll({where: { MatchId: match.InfoId }})
    }
    return {
        HostProbability: String,
        FlatProbability: String,
        GuestProbability: String,
        MaxProbabilityName: String,
        FirstProbability: String,
        LastProbability: String,
    };
};
exports.statProbability = statProbability;
// 获取足球概率战力值
function ZqSpPercent(match) {
    try {
        let sp = JSON.parse(match.BetSps)["7206"];
        if (!sp || sp.length < 0) {
            return [0, 0];
        }
        let pavg = sp[1] / 2;
        let v1 = [sp[0] + pavg, sp[2] + pavg];
        let sum = v1[0] + v1[1];
        let r = [Math.round(v1[0] / sum * 100), Math.round(v1[1] / sum * 100)];
        let sy = 100 - _.sum(r);
        if (r[0] > r[1]) {
            r[1] += sy;
        }
        else {
            r[0] += sy;
        }
        return r;
    }
    catch (e) {
        return [0, 0];
    }
}
exports.ZqSpPercent = ZqSpPercent;
const CompetitionResult = async () => {
    let sql = `SELECT * FROM core_match WHERE \`InfoState\`=true ORDER BY \`LotteryId\` DESC`;
    let result = await Core.sequelize.query(sql);
    return result;
};
exports.CompetitionResult = CompetitionResult;
async function get_core_match({ lotteryId }) {
    try {
        if (!_.includes([72, 74, 75, 45], lotteryId)) {
            return null;
        }
        let where = {
            MatchState: '未',
            LotteryId: lotteryId,
            MatchTime: { $gte: moment().add(-1, 'day').format("YYYY-MM-DD") }
        };
        if (lotteryId == 74) {
            where = {
                // MatchState: [null,'未'],
                LotteryId: lotteryId,
                MatchTime: { $gte: moment().add(-1, 'day').format("YYYY-MM-DD") }
            };
        }
        let result = await Core.core_match.findAll({
            where: where,
            order: [["MatchTime", "asc"], ["MatchNumber", "asc"]],
            limit: 500,
            attributes: [`Id`, `updateflag`, `LotteryId`, `IssueId`, `IssueName`, `BdGameType`,
                `BdGameTypeColor`, `GameName`, `GameColor`, `BdMatchDay`, `MatchNumber`,
                `MatchRound`, `MatchTime`, `StopSellTime`, `PrintEndTime`,
                `InfoId`, `HostId`, `HostName`, `HostRank`, `HostRed`, `HostYellow`,
                `LetScore`, `PreTotalScore`, `GuestId`, `GuestName`, `GuestRank`,
                `GuestRed`, `GuestYellow`, `MatchState`, `ResultState`, `Results`,
                `BetSps`, `Commends`, `AvgOdds`, `GgStopPlayIds`, `DgStopPlayIds`,
                `IsAutoUpdate`, `BcBf`, `QcBf`, `ResultSps`,
                //`OkoooId`, `BetradarId`, 
                //`IsTextLive`, `PlayerData`, `TimeData`, `LiveData`, `TechnicalStatistics`, 
                `Stoppage`, `Weather`, `Temperature`, `SportsInfo`, `SportsLive`,
                // `SportsLineup`, `SportsStatistics`, `SportsInjury`, `SportteryMatchId`, `JcInfo`, 
                `DfcpImgUrl`,
                `VideoUrl`,
                // `CreatedAt`, `UpdatedAt`, 
                `InfoState`, `WinLoseRate`, `WinLoseCount`,
                `RangQiuWinLoseRate`, `RangQiuWinLoseCount`, `SportteryTempId`, `SportteryHostId`,
                //`SportteryGuestId`, `SportteryHostName`, `SportteryGuestName`, `TempId`, `GuessRate`, 
                //`GuessTotal`, `GuessJoinTotal`, `GuessWinTotal`, `GuessEquelTotal`, `GuessLoseTotal`
            ]
        });
        let ms_schedule_data_list = await Core.ms_schedule.findAll({
            where: {
                core_match_time: { $gte: moment().format("YYYY-MM-DD") }
            }
        });
        result = JSON.parse(JSON.stringify(result));
        result = _.map(result, (o) => {
            if (o.InfoId == null || o.InfoId == 0) {
                o.InfoId = (_.find(ms_schedule_data_list, (m) => {
                    return m.core_match_id == o.Id;
                }) || {}).info_match_id;
            }
            let ms_item = _.find(ms_schedule_data_list, (m) => {
                return m.core_match_id == o.Id;
            });
            if (ms_item) {
                // console.info(`ms_item.yiqiu_match_id`,ms_item.yiqiu_match_id)
                o.YiqiuMatchId = ms_item.yiqiu_match_id;
            }
            if (o) {
                delete o.JcInfo;
                delete o.SportsInfo;
                delete o.CreatedAt;
                delete o.UpdatedAt;
                delete o.updateflag;
                delete o.IssueId;
                delete o.SportsLive;
                delete o.SportsLineup;
                delete o.SportsStatistics;
                delete o.SportsInjury;
                delete o.GuessRate;
                delete o.GuessTotal;
                delete o.GuessJoinTotal;
                delete o.GuessWinTotal;
                delete o.GuessEquelTotal;
                delete o.GuessLoseTotal;
                delete o.OkoooId;
                delete o.BetradarId;
                delete o.IsTextLive;
                delete o.PlayerData;
                delete o.TimeData;
                delete o.TechnicalStatistics;
            }
            return o;
        });
        // console.info(`result`,result);
        if (lotteryId == 74) {
            let game_list = (await info_db.ms_soccer_game.findAll({
                limit: 100,
                // `id`, `match_time`,`zucai_issue_name`, `zucai_number`, info_match_id, status, odds 
                attributes: [`id`, `match_time`, `zucai_issue_name`, `zucai_number`, `info_match_id`, `status`, `odds`],
                where: {
                    is_zucai: 1,
                    match_time: { $gte: moment().format("YYYY-MM-DD") },
                }
            }))?.map((a) => a.dataValues) ?? [];
            // 通过zucai_issue_name与zucai_number找到对应比赛
            result = _.map(result, (o) => {
                let game = _.find(game_list, (g) => {
                    return g.zucai_issue_name == o.IssueName && g.zucai_number == o.MatchNumber;
                });
                if (game) {
                    o.odds = game.odds;
                    o.YiqiuMatchId = o.YiqiuMatchId || game.id;
                    o.MatchState = o.MatchState || '未';
                    if (moment(o.MatchTime) < moment() && o.MatchState == "未") {
                        o.MatchState = "";
                    }
                    if (o.odds?.['3000181']?.eu) {
                        o.AvgOdds = o.AvgOdds || _.map(o.odds?.['3000181'].eu, (n) => Number(n).toFixed(2)).join(",");
                    }
                    else {
                        o.AvgOdds = '--,--,--';
                    }
                    //测试的时候可以留下odds
                    delete o.odds;
                }
                return o;
            });
        }
        result = _.filter(result, (o) => {
            if (o.MatchState != "未") {
                return false;
            }
            return o.BetSps != "{\"7201\":[0.0,0.0,0.0],\"7202\":[0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0],\"7203\":[0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0],\"7204\":[0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0,0.0],\"7206\":[0.0,0.0,0.0]}";
        });
        return result;
    }
    catch (e) {
        console.info(`lottery_get_matchs 获取比赛数据异常:${e.message}`);
    }
}
exports.get_core_match = get_core_match;
//# sourceMappingURL=match.js.map