Merge remote-tracking branch 'origin/bugfix' into bugfix

src/api_s2c/jjc/ApiOpen.ts

@@ -30,6 +30,6 @@ export default async function (call: ApiCall<ReqOpen, ResOpen>) {
     });
 
     UserFun.activeHeadFrame(call.uid, 'jjc_rank', data["rank"] + 1);
-    JJCFun.checkUpdatePlayer()
+    //JJCFun.checkUpdatePlayer()
 
 }

src/fix_patch/patch_20240109-1.ts

@@ -0,0 +1,119 @@
+import { patchFun, patchInit } from "../patch";
+import { PublicShared } from "../shared/public/public";
+import { JJCFun } from "../public/jjc";
+
+function getRankPrize(rank: number, conf?: typeof G.gc.jjc_ph['']) {
+    if (!conf) {
+        conf = Object.values(G.gc.jjc_ph).filter(v => rank >= v.ph[0] && rank <= v.ph[1])[0];
+    }
+    if (conf) {
+        return [...conf.prize, { a: 'item', t: '11', n: typeof conf.rongyuprize == 'number' ? conf.rongyuprize : PublicShared.eval(conf.rongyuprize, { a: rank }) }];
+    } else {
+        return [];
+    }
+}
+
+class Path {
+
+    async addEmail(email, isCross = false) {
+        let { prize, uid, ...e } = email;
+        let lng = await G.redis.rawGet(`user:lng:${uid}`);
+        let sendEmail = {
+            _id: null,
+            uid: uid,
+            type: e.type,
+            title: e.lngTitle ? (e.lngTitle[lng] || e.lngTitle['ja']) : e.title,
+            content: e.lngContent ? (e.lngContent[lng] || e.lngContent['ja']) : e.content,
+            createTime: e.createTime || G.time,
+            contentInsertArr: e.contentInsertArr || []
+        } as any;
+
+        /**跨服邮件给sid标识*/
+        // if (isCross) {
+        //     sendEmail.sid = uid.split('_')[0];
+        // }
+        if ((prize === null || prize === void 0 ? void 0 : prize.length) > 0) {
+            sendEmail.prizeData = {
+                prize: email.prize,
+                isGet: false
+            };
+        }
+        if (email.g123log && Object.keys(email.g123log).length > 0)
+            sendEmail.g123log = email.g123log;
+
+        if (email.lngTitle) {
+            sendEmail.lngTitle = email.lngTitle;
+            sendEmail.lngContent = email.lngContent;
+        }
+        //太亏了！换其他清理机制，getAllEmail是性能消耗大户
+        //todo.. 换其他清理机制
+        // if (!isCross) {
+        //     let emailList = await this.getAllEmail(uid);
+        //     if (emailList.length >= 50) {
+        //         emailList.sort((a, b) => {
+        //             let noPrizeA = a.prizeData == undefined ? 0 : 1;
+        //             let noPrizeB = b.prizeData == undefined ? 0 : 1;
+        //             let getA = a.prizeData?.isGet == true ? 0 : 1;
+        //             let getB = b.prizeData?.isGet == true ? 0 : 1;
+        //             if (noPrizeA != noPrizeB) {
+        //                 return noPrizeA - noPrizeB;
+        //             } else if (getA != getB) {
+        //                 return getA - getB;
+        //             }
+        //             return a.createTime - b.createTime;
+        //         });
+        //         this.removeEmail(uid, emailList[0]._id);
+        //         G.server.sendMsgByUid(uid, 'msg_s2c/EmailDel', emailList[0]._id);
+        //     }
+        // }
+        //@ts-ignore
+        await G.mongodb.collection('email').insertOne({
+            ttl: new Date(), ...G.mongodb.conversionIdObj(sendEmail)
+        })
+    }
+
+    async sendEmail(uid: string, rank: number, prize: atn[]) {
+
+        if (uid.indexOf('npc_') != -1) return;
+
+        await this.addEmail({
+            uid: uid,
+            type: 'system',
+            title: G.gc.jjc_com.email.titel,
+            content: G.gc.jjc_com.email.content,
+            prize: prize,
+            contentInsertArr: [rank]
+        });
+    }
+    async fun1(a: any) {
+        for (let conf of Object.values(G.gc.jjc_ph)) {
+            let players = await JJCFun.getRankListUid(conf.ph[0] - 1, conf.ph[1]);
+
+            for (let index = 0; index < players.length; index++) {
+                let uid = players[index];
+                await this.sendEmail(uid, conf.ph[0] + index, getRankPrize(conf.ph[0] + index, conf));
+                console.log("sendEmail", uid, conf.ph[0] + index)
+            }
+        }
+
+        return "sucess!!!"
+    }
+
+
+
+    async run() {
+        await this.fun1(1);
+    }
+}
+
+async function main() {
+    await patchInit()
+    let patch = new Path();
+    await patch.run();
+    console.log("逻辑执行完成，等待退出");
+    setTimeout(function () {
+        console.log('结束程序');
+        process.exit();
+    }, 3000);
+}
+main();

src/fix_patch/patch_20240110.ts

@@ -0,0 +1,51 @@
+import { patchInit } from "../patch";
+
+
+class Path {
+
+    async fun1(a: any) {
+        let taskType = 2;
+        let users = await G.mongodb.collection('user').find({ loginTime: { $gte: 1704643200 } }).toArray();
+        for (let i = 0; i < users.length; i++) {
+            let user = users[i];
+            let unFinishTask = (await G.mongodb.collection('task').find({
+                uid: user.uid, type: taskType, finish: 0
+            }, { projection: { taskid: 1 } }).toArray()).map(i => i.taskid);
+
+            if (unFinishTask.length >= 2) {
+                for (let taskid of unFinishTask) {
+                    let con = G.gc.task[taskType][taskid];
+                    if (!con) {
+                        await G.mongodb.collection("task").deleteOne({
+                            uid: user.uid, taskid: taskid
+                        });
+                        console.log(`删除玩家${user.uid}任务:${taskid}`);
+                    }
+                    if (unFinishTask.includes(con.pretask)) {
+                        await G.mongodb.collection("task").deleteOne({
+                            uid: user.uid, taskid: taskid
+                        });
+                        console.log(`删除玩家${user.uid}任务:${taskid}`);
+                    }
+                }
+            }
+        }
+    }
+
+
+    async run() {
+        await this.fun1(1);
+    }
+}
+
+async function main() {
+    await patchInit()
+    let patch = new Path();
+    await patch.run();
+    console.log("逻辑执行完成，等待退出");
+    setTimeout(function () {
+        console.log('结束程序');
+        process.exit();
+    }, 3000);
+}
+main();

src/module/collection_fightLog.ts

@@ -1,4 +1,4 @@
 import {fightResult} from '../shared/fightControl/fightType';
 
 
-export type CollectionFightLog = fightResult & { uid: string, type: string };
+export type CollectionFightLog = fightResult & { uid: string, type: string, ttl: Date};

src/public/fight.ts

@@ -1,43 +1,43 @@
-import {ApiCall, TsrpcError} from 'tsrpc';
+import { ApiCall, TsrpcError } from 'tsrpc';
-import {FightControl} from '../shared/fightControl/fightCntrol';
+import { FightControl } from '../shared/fightControl/fightCntrol';
-import {formatNpcData} from '../shared/fightControl/fightFun';
+import { formatNpcData } from '../shared/fightControl/fightFun';
-import {fightResult, joinFightData, roleDataType} from '../shared/fightControl/fightType';
+import { fightResult, joinFightData, roleDataType } from '../shared/fightControl/fightType';
-import {rankInfo} from '../shared/protocols/type';
+import { rankInfo } from '../shared/protocols/type';
-import {HeroShared} from '../shared/public/hero';
+import { HeroShared } from '../shared/public/hero';
-import {PlayerShared} from '../shared/public/player';
+import { PlayerShared } from '../shared/public/player';
-import {HeroFun} from './hero';
+import { HeroFun } from './hero';
-import {UserFun} from './user';
+import { UserFun } from './user';
-import {re, string} from "mathjs";
+import { re, string } from "mathjs";
-import {getGud} from './gud';
+import { getGud } from './gud';
-import {PushGiftFun} from "./pushgift";
+import { PushGiftFun } from "./pushgift";
 
 type fightType = 'tanxian' | 'pata' | 'jjc' | 'gbtx' | 'qjzzd' | 'meirishilian' | 'wzrycross';
 
 
-let fights:{[key:string]:FightControl} = {
+let fights: { [key: string]: FightControl } = {
-    
+
 };
-function clearFights (){
+function clearFights() {
     //定时清理战斗
-    setInterval(()=>{
+    setInterval(() => {
         let now = Date.now();
-        for (let key in fights){
+        for (let key in fights) {
-            if (now - fights[key].startTime > 30000){
+            if (now - fights[key].startTime > 30000) {
-                console.log("清理战斗",key);
+                console.log("清理战斗", key);
-                try{
+                try {
                     fights[key].release();
-                }catch(e){
+                } catch (e) {
                     console.error(e);
                 }
                 delete fights[key];
             }
         }
-    },5000);
+    }, 5000);
 }
 clearFights();
 
 export class FightFun {
-    static fightIndex:number = 0;
+    static fightIndex: number = 0;
 
     static fight(data: joinFightData[], maxRoundNums = 30, fightType: "pvp" | "pve" = 'pvp') {
         this.fightIndex++;
@@ -80,16 +80,20 @@ export class FightFun {
         });
 
         return {
-            player: {...player, buff: PlayerShared.getBuff(player)},
+            player: { ...player, buff: PlayerShared.getBuff(player) },
             roles: roles
         };
     }
 
     /**挑战竞技场 */
     static async fightJJc(call: ApiCall, rankInfo: rankInfo) {
-        if (rankInfo.player.uid.indexOf('npc_') != -1) return await this.fightNpc(call, G.gc.jjc_npc[rankInfo.player.uid].npcId, 'jjc', await this.getPlayerFightData(call.conn.uid));
+        let result;
 
-        let result = this.fight([await this.getPlayerFightData(call.conn.uid), await this.getPlayerFightData(rankInfo.player.uid)]);
+        if (rankInfo.player.uid.indexOf('npc_') != -1) {
+            result = await this.fightNpc(call, G.gc.jjc_npc[rankInfo.player.uid].npcId, 'jjc', await this.getPlayerFightData(call.conn.uid));
+        } else {
+            result = this.fight([await this.getPlayerFightData(call.conn.uid), await this.getPlayerFightData(rankInfo.player.uid)]);
+        }
 
         // 竞技场 战败触发推送礼包
         if (result.winSide != 0) {
@@ -130,14 +134,14 @@ export class FightFun {
      * @param result
      */
     static async saveLog(uid: string, type: string, result: fightResult) {
-        let writeList = ['ganhai', 'jjc', 'hbzbJfs', 'hbzbZbs', 'slzd', 'clsl'] 
+        let writeList = ['ganhai', 'jjc', 'hbzbJfs', 'hbzbZbs', 'slzd', 'clsl']
         if (uid.indexOf('npc') != -1 || !writeList.includes(type)) return;
 
-        G.mongodb.collection('fightLog').insertOne({uid, type, ...result})
+        G.mongodb.collection('fightLog').insertOne({ uid, type, ...result, ttl: new Date() })
 
     }
 
     static async readLog(uid: string, type: string, len = 20) {
-        return await G.mongodb.collection('fightLog').find({uid, type}).limit(len).toArray() || []
+        return await G.mongodb.collection('fightLog').find({ uid, type }).limit(len).sort({ _id: -1 }).toArray() || []
     }
 }

src/public/jjc.ts

@@ -94,37 +94,37 @@ export class JJCFun {
      * @param uTimeOffset
      * @param isUpdate 是否更新数据
      */
-    static async checkUpdatePlayer(min: number = 0, max: number = 1000, uTimeOffset: number = 600, isUpdate: boolean = true) {
+    // static async checkUpdatePlayer(min: number = 0, max: number = 1000, uTimeOffset: number = 600, isUpdate: boolean = true) {
-        // 获取指定排名用户uid
+    //     // 获取指定排名用户uid
-        let sortInfo = await this.getRankListUid(min, max)
+    //     let sortInfo = await this.getRankListUid(min, max)
-        if (!sortInfo.length) return []
+    //     if (!sortInfo.length) return []
-        let updateArr = []
+    //     let updateArr = []
 
-        let users = await G.redis.hGetAll('rank:jjc:data')
+    //     let users = await G.redis.hGetAll('rank:jjc:data')
 
-        for (let i = 0; i < sortInfo.length; i++) {
+    //     for (let i = 0; i < sortInfo.length; i++) {
-            let uid = sortInfo[i]
+    //         let uid = sortInfo[i]
-            let rankInfo = users[uid]
+    //         let rankInfo = users[uid]
-            if (!rankInfo?.player) continue
+    //         if (!rankInfo?.player) continue
-            // 比对utime，判断是否更新数据
+    //         // 比对utime，判断是否更新数据
-            if (!rankInfo.player.isNpc) {
+    //         if (!rankInfo.player.isNpc) {
-                if (!rankInfo.utime || (rankInfo.utime && rankInfo.utime < (G.time - uTimeOffset))) {
+    //             if (!rankInfo.utime || (rankInfo.utime && rankInfo.utime < (G.time - uTimeOffset))) {
-                    updateArr.push(rankInfo)
+    //                 updateArr.push(rankInfo)
-                }
+    //             }
-            }
+    //         }
-        }
+    //     }
-        // 更新数据
+    //     // 更新数据
-        if (isUpdate && updateArr.length > 0) {
+    //     if (isUpdate && updateArr.length > 0) {
-            let playerArrInfo = await G.mongodb.collection("user").find({uid: {$in: updateArr.map(i => i.uid)}}).toArray()
+    //         let playerArrInfo = await G.mongodb.collection("user").find({uid: {$in: updateArr.map(i => i.uid)}}).toArray()
-            for (let i = 0; i < playerArrInfo.length; i++) {
+    //         for (let i = 0; i < playerArrInfo.length; i++) {
-                let playerInfo = playerArrInfo[i]
+    //             let playerInfo = playerArrInfo[i]
-                let index = updateArr.findIndex(x => x.player.uid == playerInfo.uid)
+    //             let index = updateArr.findIndex(x => x.player.uid == playerInfo.uid)
-                updateArr[index].player = playerInfo
+    //             updateArr[index].player = playerInfo
-                updateArr[index].utime = G.time
+    //             updateArr[index].utime = G.time
-                this.updatePlayerData(playerInfo.uid, updateArr[index]);
+    //             this.updatePlayerData(playerInfo.uid, updateArr[index]);
-            }
+    //         }
-        }
+    //     }
-    }
+    // }
 
     /**
      * 获取指定范围排名的用户，仅返回uid[]

src/public/pay.ts

@@ -260,7 +260,10 @@ export class PayFun {
             let selectPrize = await G.ioredis.get(`pay:${payId}:${player.uid}`);
             if (selectPrize) {
                 prize.push(...JSON.parse(selectPrize))
-                G.ioredis.del(`pay:${payId}:${player.uid}`)
+                //支付A check -> 玩家支付 -> 网络延迟
+                //支付B check -> 玩家支付 -> pay -> del
+                //支付A -> pay 时，这里可能被清了，导致给玩家发放了空的奖励，因此，这里不清除
+                //G.ioredis.del(`pay:${payId}:${player.uid}`)
             }
         }
 

src/public/player.ts

@@ -19,6 +19,8 @@ import {getGud, setGud} from './gud';
 import {addGameLog} from "../gameLog";
 import {PushGiftFun} from "./pushgift";
 import { ActionLog } from './actionLog/actionLog';
+import { roleDataType } from '../shared/fightControl/fightType';
+import { PlayerShared } from '../shared/public/player';
 
 
 export type call = {
@@ -41,6 +43,41 @@ export type call = {
 };
 
 export class PlayerFun {
+    /**
+     * 通过uid获取战斗数据
+     * @param uid 
+     * @returns 
+     */
+    static async getDefaultFightDataByUid(uid:string){
+        let gud = await getGud(uid);
+        let posObj = gud.heroPos;
+        let roles: k_v<roleDataType> = {};
+        if (gud.selectMatrix && gud.matrixPos) {
+            posObj = gud.matrixPos[gud.selectMatrix];
+        }
+        let heros = await HeroFun.getHeros({uid:uid}, Object.values(posObj).filter(_id => _id != '') as string[]);
+        let otherBuff = UserFun.getOtherBuff(gud)
+
+        Object.entries(posObj).forEach(obj => {
+            let pos = obj[0];
+            let _id = obj[1];
+            let hero = heros.filter(h => h._id == _id)[0];
+            
+            if (hero) {
+                roles[pos] = {
+                    ...hero,
+                    attr: {
+                        ...HeroShared.getHeroBasicAttr(hero, { ...otherBuff, allBuff: HeroShared.getAllBuff(heros) }, Number(pos))
+                    }
+                };
+            }
+        });
+    
+        return {
+            player: { ...gud, buff: PlayerShared.getBuff(gud) },
+            roles: roles
+        };
+    }
     /**
      * 获取玩家atn数量
      */