Merge branch 'master' into dev

src/api_s2c/xstask/ApiOnekeyReceive.ts

@@ -14,7 +14,7 @@ export default async function (call: ApiCall<ReqOnekeyReceive, ResOnekeyReceive>
     if (args.length < 1 || _ids.isDuplication() || heroIds.isDuplication()) return call.error(globalThis.lng.kbzz_1);
 
     let event = await G.mongodb.cEvent('xstask').findOne({uid: call.uid, type: 'xstask'});
-    if (event.receiveNum >= 8) return call.error(globalThis.lng.xstask_11);
+    if (event?.receiveNum >= 8) return call.error(globalThis.lng.xstask_11);
 
     //所有的任务
     let taskList = await XstaskFun.getAllTask(call.uid);

src/api_s2c/xstask/ApiReceive.ts

@@ -9,7 +9,7 @@ export default async function (call: ApiCall<ReqReceive, ResReceive>) {
     if (call.req.heroIds.isDuplication()) return call.error(globalThis.lng.xstask_10);
 
     let event = await G.mongodb.cEvent('xstask').findOne({uid: call.uid, type: 'xstask'});
-    if (event.receiveNum >= 8) return call.error(globalThis.lng.xstask_11);
+    if (event?.receiveNum >= 8) return call.error(globalThis.lng.xstask_11);
 
     let task = await XstaskFun.getTask(call.uid, call.req._id);
     let taskConf = G.gc.xstask[task?.taskId];

src/api_s2c/xstask/ApiRefresh.ts

@@ -13,7 +13,7 @@ export default async function (call: ApiCall<ReqRefresh, ResRefresh>) {
     if (delNum < 1) return call.error(globalThis.lng.xstask_11);
 
     let event = await G.mongodb.cEvent('xstask').findOne({uid: call.uid, type: 'xstask'});
-    if (event.receiveNum >= 8) return call.error(globalThis.lng.xstask_11);
+    if (event?.receiveNum >= 8) return call.error(globalThis.lng.xstask_11);
 
     let change: ResRefresh = {};
     let needDel = taskList.filter(task => task.receiveData == undefined || task.receiveData.rec == true);

src/gameLog.ts

@@ -1,4 +1,5 @@
 import { Db, MongoClient } from "mongodb";
+import { Logger } from "tsrpc";
 
 let logDB:Db;
 let errorLogDB:Db;
@@ -28,13 +29,28 @@ async function connGameLogDB() {
     return logDB;
 }
 
+export let mylogger: Logger = {
+    debug(...args: any[]){
+        console.debug(...args);
+    },
+    log(...args: any[]){
+        console.log(...args);
+    },
+    warn(...args: any[]){
+        console.warn(...args);
+    },
+    error(...args: any[]){
+        addErrorLog( args );
+        console.error(...args);
+    }
+}
 
 process.on('uncaughtException',function(err:Error){
-    addErrorLog((err?.stack)?.toString());
+    addErrorLog( (err?.stack || err)?.toString() );
 })
 
 process.on('unhandledRejection', function (err:Error, promise) {
-    addErrorLog((err?.stack)?.toString());
+    addErrorLog( (err?.stack || err)?.toString() );
 })
 
 async function addErrorLog(errData:any){

src/setWs.ts

@@ -13,6 +13,7 @@ import {player} from './shared/protocols/user/type';
 import {unQueueByConn} from './api_s2c/user/ApiLogin';
 import {clusterPublish, setUidProcessId} from './clusterUtils';
 import {clearGud, getGud} from './public/gud';
+import { mylogger } from './gameLog';
 
 export async function createWs() {
 
@@ -25,8 +26,9 @@ export async function createWs() {
             json: true,
             //API超时时间5分钟，为登陆排队做准备
             apiTimeout: 300000,
-            logLevel: G.argv.logModel as LogLevel
-        });
+            logLevel: G.argv.logModel as LogLevel,
+            logger:mylogger
+        }); 
         setCrossWs(G.serverCross);
         await G.serverCross.autoImplementApi(resolve(__dirname, 'api_cross'), true);
         await G.serverCross.start();
@@ -37,6 +39,7 @@ export async function createWs() {
             wss: getWssFile(),
             //API超时时间5分钟，为登陆排队做准备，只针对游服
             apiTimeout: 300000,
+            logger:mylogger
         });
         setWs(G.server);
         await G.server.autoImplementApi(resolve(__dirname, 'api_s2c'), true);