hnhzServer/share/configCommon.js

/**
 * TL++整个文件
 * 此类是和配置文件相关的函数
*/
'use strict';
var quick = require('quick-pomelo');
var P = quick.Promise;
var uuid = require('node-uuid');
var C = require('./constant');
var _ = require('lodash');/////是一个一致性、模块化、高性能的 JavaScript 实用工具库。
// 构造方法
var configCommon = function (app) {
    this.app = app;
};

// 导出类
module.exports = configCommon;

// 原型对象
var proto = configCommon.prototype;

//////获得最新的配置文件
proto.getHallConfig = function (){
    // delete require.cache[require.resolve('../app/config/hallConfig')];
    let hallConfig = require('../app/config/hallConfig') || {};
    return hallConfig;
}

//////获得活动配置的open和开始结束时间
proto.getActiveOpenTime = function (activeType){
    let confActive = this.getHallConfig().active || {};
    let activeInfoList = confActive.list || [];
    let res = {};
    for (var i = 0; i < activeInfoList.length; i++) {
        if(activeInfoList[i].type == activeType){
            res = {
                "open": activeInfoList[i].open,                   
                "startTime": activeInfoList[i].startTime,     
                "endTime": activeInfoList[i].endTime,  
                "reachAndRewardInfo": activeInfoList[i].reachAndRewardInfo
            }
            break;
        }
    }
    // console.warn("getActiveOpenTime    res  "+JSON.stringify(res));
    
    return res;
};

//////获得判定为回归用户未登录的天数
proto.getHuiguiNoLoginDays = function (activeType){
    let confhuiguiRequest = this.getHallConfig().huiguiRequest || {};
    let res = confhuiguiRequest.noLoginDays || 0;    
    return res;
};

//TL++,得到今日0点的时间戳
proto.getTodaySJC = function (){
    var today = new Date();
    today.setHours(0);
    today.setMinutes(0);
    today.setSeconds(0);
    today.setMilliseconds(0);
    let jrsjc = today.getTime();
    // console.warn("111得到今日0点的时间戳   ",jrsjc, typeof jrsjc);
    return jrsjc;
};

//邀请新人按比例送钻这个活动的信息写入数据库
proto.yxActivityAsync = P.coroutine(function* (scorers,etime) {
    // console.warn("下面是记录邀请新人按比例送钻这个活动的数据  etime "+etime)
    // if(!this.lconfigCommon) {
    //     // console.warn("邀请新人按比例送钻  this.lconfigCommon 不存在 "+etime);
    //     this.lconfigCommon = new configCommon(this.app);
    // }
    let yxhdxx = this.getActiveOpenTime(6);//邀请新人按比例送钻活动是否开启和开始结束时间的信息
    let isKQ = false;//邀请新人送钻石活动是否开启
    if(yxhdxx && yxhdxx.open && yxhdxx.startTime && yxhdxx.endTime) isKQ = true;
    // console.warn("获取配置信息   yxhdxx "+JSON.stringify(yxhdxx));
    if(!(isKQ && etime >= yxhdxx.startTime && etime < yxhdxx.endTime)){
        return;//活动未开启
    }
    let xhList = [];
    for (let scorer of scorers) {
        let xhInfo = {
            _id: scorer.playerId,
            chairId:scorer.chairId,
            userId: scorer.userId,
            name: scorer.name,
            gameCost: scorer.gameCost,
            giftCost: scorer.giftCost,
        }
        xhList[xhList.length] = xhInfo;
        // console.warn("下面是记录邀请新人按比例送钻这个活动的数据  xhInfo  "+JSON.stringify(xhInfo));
    }
    let yqrList = [];//邀请人列表
    if(xhList[0]){
        var yqxx = yield this.app.models.Invite.findByIdAsync(xhList[0]._id, 'yId yuId');
        if (yqxx) {
            xhList[0].yId = yqxx.yId;
            xhList[0].yuId = yqxx.yuId;
            if(yqrList.indexOf(xhList[0].yId) == -1) yqrList[yqrList.length] = xhList[0].yId;
        }
    }
    if(xhList[1]){
        var yqxx = yield this.app.models.Invite.findByIdAsync(xhList[1]._id, 'yId yuId');
        if (yqxx) {
            xhList[1].yId = yqxx.yId;
            xhList[1].yuId = yqxx.yuId;
            if(yqrList.indexOf(xhList[1].yId) == -1) yqrList[yqrList.length] = xhList[1].yId;
        }
    }
    if(xhList[2]){
        var yqxx = yield this.app.models.Invite.findByIdAsync(xhList[2]._id, 'yId yuId');
        if (yqxx) {
            xhList[2].yId = yqxx.yId;
            xhList[2].yuId = yqxx.yuId;
            if(yqrList.indexOf(xhList[2].yId) == -1) yqrList[yqrList.length] = xhList[2].yId;
        }
    }
    if(xhList[3]){
        var yqxx = yield this.app.models.Invite.findByIdAsync(xhList[3]._id, 'yId yuId');
        if (yqxx) {
            xhList[3].yId = yqxx.yId;
            xhList[3].yuId = yqxx.yuId;
            if(yqrList.indexOf(xhList[3].yId) == -1) yqrList[yqrList.length] = xhList[3].yId;
        }
    }
    // console.warn("下面是记录邀请新人按比例送钻这个活动的数据  xhList  "+JSON.stringify(xhList));
    // console.warn("下面是记录邀请新人按比例送钻这个活动的数据  yqrList  "+JSON.stringify(yqrList));
    let addCostInfos = [];
    for (var i = 0; i < xhList.length; i++) {
        if(!xhList[i].yId) continue;
        let index = yqrList.indexOf(xhList[i].yId);
        let lc = xhList[i].gameCost + xhList[i].giftCost;
        let lc2 = Math.floor(lc * yxhdxx.reachAndRewardInfo[0].rewardCount)
        // console.warn("下面是记录邀请新人按比例送钻这个活动的数据  addCostInfos  "+JSON.stringify(addCostInfos)+"   index   "+index+"   i   "+i+"   lc2   "+lc2+"  xhList[i].yId  "+xhList[i].yId);
        if(index != -1){
            if(addCostInfos[index]){
                addCostInfos[index].all += lc2;
            }
            else{
                addCostInfos[addCostInfos.length] = {
                    yId: xhList[i].yId,
                    yuId: xhList[i].yuId,
                    all: lc2
                }
            }
        }
        else{
            //记录的yid无效（是错的）
        }
    }
    let jrStart = this.getTodaySJC()

    // console.warn("下面是记录邀请新人按比例送钻这个活动的数据   jrStart  "+jrStart+"  addCostInfos  "+JSON.stringify(addCostInfos));
    if(addCostInfos[0] && addCostInfos[0].yId){
        let opts0 = { 
            pId: addCostInfos[0].yId,
            dayTime: { $gte: jrStart, $lt: jrStart+86400000}
        };
        var jrxhList0 = yield this.app.models.InvitesCost.findMongoAsync(opts0, 'pId uId all');
        // console.warn("下面是记录邀请新人按比例送钻这个活动的数据   length   "+jrxhList0.length)
        if (jrxhList0.length == 0) {
            var invitesCostItem0 = new this.app.models.InvitesCost({
                _id: uuid.v1(),
                pId: addCostInfos[0].yId,        // 邀请人标识
                uId: addCostInfos[0].yuId,       // 邀请人用户id
                isSend: 0,                       //该天产生的奖励是否通过邮件已发送出去
                all: addCostInfos[0].all         //邀请人邀请的所有新人在该天的全部消耗
            });
            yield invitesCostItem0.saveAsync();
        }
        else if (jrxhList0.length == 1) {
            jrxhList0[0].all += addCostInfos[0].all;
            yield jrxhList0[0].saveAsync();
        }
    }
    if(addCostInfos[1] && addCostInfos[1].yId){
        let opts1 = { 
            pId: addCostInfos[1].yId,
            dayTime: { $gte: jrStart, $lt: jrStart+86400000}
        };
        var jrxhList1 = yield this.app.models.InvitesCost.findMongoAsync(opts1, 'pId uId all');
        if (jrxhList1.length == 0) {
            var invitesCostItem1 = new this.app.models.InvitesCost({
                _id: uuid.v1(),
                pId: addCostInfos[1].yId,        // 邀请人标识
                uId: addCostInfos[1].yuId,       // 邀请人用户id
                isSend: 0,                       //该天产生的奖励是否通过邮件已发送出去
                all: addCostInfos[1].all         //邀请人邀请的所有新人在该天的全部消耗
            });
            yield invitesCostItem1.saveAsync();
        }
        else if (jrxhList1.length == 1) {
            jrxhList1[0].all += addCostInfos[1].all;
            yield jrxhList1[0].saveAsync();
        }
    }
    if(addCostInfos[2] && addCostInfos[2].yId){
        let opts2 = { 
            pId: addCostInfos[2].yId,
            dayTime: { $gte: jrStart, $lt: jrStart+86400000}
        };
        var jrxhList2 = yield this.app.models.InvitesCost.findMongoAsync(opts2, 'pId uId all');
        if (jrxhList2.length == 0) {
            var invitesCostItem2 = new this.app.models.InvitesCost({
                _id: uuid.v1(),
                pId: addCostInfos[2].yId,        // 邀请人标识
                uId: addCostInfos[2].yuId,       // 邀请人用户id
                isSend: 0,                       //该天产生的奖励是否通过邮件已发送出去
                all: addCostInfos[2].all         //邀请人邀请的所有新人在该天的全部消耗
            });
            yield invitesCostItem2.saveAsync();
        }
        else if (jrxhList2.length == 1) {
            jrxhList2[0].all += addCostInfos[2].all;
            yield jrxhList2[0].saveAsync();
        }
    }
    if(addCostInfos[3] && addCostInfos[3].yId){
        let opts3 = { 
            pId: addCostInfos[3].yId,
            dayTime: { $gte: jrStart, $lt: jrStart+86400000}
        };
        var jrxhList3 = yield this.app.models.InvitesCost.findMongoAsync(opts3, 'pId uId all');
        if (jrxhList3.length == 0) {
            var invitesCostItem3 = new this.app.models.InvitesCost({
                _id: uuid.v1(),
                pId: addCostInfos[3].yId,        // 邀请人标识
                uId: addCostInfos[3].yuId,       // 邀请人用户id
                isSend: 0,                       //该天产生的奖励是否通过邮件已发送出去
                all: addCostInfos[3].all         //邀请人邀请的所有新人在该天的全部消耗
            });
            yield invitesCostItem3.saveAsync();
        }
        else if (jrxhList3.length == 1) {
            jrxhList3[0].all += addCostInfos[3].all;
            yield jrxhList3[0].saveAsync();
        }
    }
    // return;
});

// proto.backAsync = cor(function* (user) {
////给玩家发邮件
proto.senMailToPlayer = P.coroutine(function* (playerId,userId,tittleT,descT,_reward,_rewardT,_rewardC,form) {
//////获得活动配置的open和开始结束时间
// proto.senMailToPlayer = function (playerId,userId,tittleT,descT,_reward,_rewardT,_rewardC,form){
    // console.warn("给玩家发邮件   playerId  "+playerId+"  userId  "+userId);
    if (!playerId || !userId || !tittleT || !descT || !form) {
        return false;
    }
    var reward = Number(_reward) || 0;;
    var rewardT = Number(_rewardT) || 0;
    var rewardC = Number(_rewardC) || 0;
    if (reward) {
        if(!rewardT || !rewardC) return false;//fail: rewardT or rewardC error!
    }
    else{
        if(rewardT) return false;//fail: rewardT error!
        if(rewardC) return false;//fail: rewardC error!
    }
    
    let receive = 1;
    if(reward) receive = 0;
    var mail = yield this.app.models.Mails.findByIdAsync(playerId, 'mailInfos');
    if (mail) {
        let item = {
            _id: "",
            index: mail.mailInfos.length, // 邮件下标
            tittleT: tittleT,  // 邮件标题类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
            descT: descT,  // 邮件内容类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
            reward: reward,              // 有无奖励 0:无奖励 1:有奖励
            rewardT: rewardT,              // 奖励类型 0:未定义 1:钻石,
            rewardC: rewardC,              // 奖励数量
            receive: receive,              // 是否领取 0:未领取 1:已领取
            read: 0,              // 是否已读 0:未读 1:已读
            form:form,       //邮件来源
            sendTime: Date.now()    // 发送日期
        }
        let newItem = _.clone(mail.mailInfos);
        let newItem2 = [0].concat(newItem);
        newItem2[0] = item;
        if(newItem2.length > 60){
            newItem2 = newItem2.slice(0,60)
        }
        mail.mailInfos = [];
        mail.mailInfos = _.clone(newItem2);
        yield mail.saveAsync();
    }
    else{
        let item = {
            _id: "",
            index: 0, // 邮件下标
            tittleT: tittleT,  // 邮件标题类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
            descT: descT,  // 邮件内容类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
            reward: reward,              // 有无奖励 0:无奖励 1:有奖励
            rewardT: rewardT,              // 奖励类型 0:未定义 1:钻石,
            rewardC: rewardC,              // 奖励数量
            receive: receive,              // 是否领取 0:未领取 1:已领取
            read: 0,              // 是否已读 0:未读 1:已读
            form:form,       //邮件来源
            sendTime: Date.now()    // 发送日期
        }
        let newItem = [];
        newItem[0] = item;
        var newMail = new this.app.models.Mails({
            _id: playerId,                // 用户id（player表的主键）
            userId: userId,              // 用户的userId
            mailInfos: newItem // 该活动的达成条件和奖励信息列表
        });
        yield newMail.saveAsync();
    }
    
    return true;
});

////检查是否是系统创房
proto.checkIsSystemCreat = P.coroutine(function* (playerId) {
    if(playerId == "system_promote") return true;
    return false;
});
////检查链接是否可进去，非比赛时间比赛链接不可进去
proto.checkIsCanJoin = P.coroutine(function* (gameid,_agentId,type) {
    let agentId = _agentId || "";
    if(!agentId) return { code: C.OK};
    // type: 1:创建房间，2:加入房间，3:创建或加入房间
    let aidsub = agentId.substr(0, 9);
    // console.warn("检查链接是否可进去，type: 1:创建房间，2:加入房间，3:创建或加入房间  aidsub "+aidsub+"  agentId  "+agentId);
    let bsIndex = aidsub.indexOf("promote_");
    if(bsIndex == -1) return { code: C.OK};//非比赛链接可以进去
    let nowTime = Date.now();
    // nowTime = 1681977609000;
    var opts = { 
        stime: { $lte: nowTime },
        etime: { $gt: nowTime}
    };
    opts['aid'] = agentId;
    let timelist = yield this.app.models.RaceTimeInfos.findMongoAsync(opts, 'agentNo stime etime', { sort: { etime: 1 } });//
    let isBSQJ = false;//是否活动期间
    // console.warn("这查到的是结束时间在今日的记录  nowTime  "+nowTime+"  length  "+timelist.length+"  timelist  "+ JSON.stringify(timelist));
    if(timelist.length > 0){
        //这查到的是开始时间小于等于当前时间而且结束时间大于当前时间的记录
        for (var i = 0; i < timelist.length; i++) {
            if(timelist[i].stime <= nowTime && nowTime < timelist[i].etime){
                // console.warn("是比赛期间")
                isBSQJ = true;//是比赛期间
                break;
            }
        }
    }
    if(!isBSQJ) return { code: C.FAILD, msg: "非比赛时间,不可进入" };
    return { code: C.OK};
});


//ts++签名验证
function checkSign(sign) {
    var signKey = 'defe6d21422c8b770767f74fcea95';
    if (sign!=signKey) return false;
    return true;
};