捐献所：加锁

game-server/app/servers/guild/handler/donateHandler.ts

@@ -1,7 +1,7 @@
 import { Application, BackendSession, HandlerService, } from 'pinus';
 import { UserGuildModel } from '../../../db/UserGuild';
 import { resResult } from '../../../pubUtils/util';
-import { STATUS, TASK_TYPE } from '../../../consts';
+import { DATA_NAME, STATUS, TASK_TYPE } from '../../../consts';
 import { DonationModel } from '../../../db/Donation';
 import { nowSeconds } from '../../../pubUtils/timeUtil';
 import { getArmyDonateBaseByLv, getArmyDonateBoxBaseById } from '../../../pubUtils/data';
@@ -14,6 +14,8 @@ import { ARMY } from '../../../pubUtils/dicParam';
 import { addActive } from '../../../services/guildService'
 import { checkActivityTask, checkTask } from '../../../services/taskService';
 import { guildInter } from '../../../pubUtils/interface';
+import { lockData } from '../../../services/redLockService';
+
 export default function (app: Application) {
     new HandlerService(app, {});
     return new DonationHandler(app);
@@ -52,17 +54,30 @@ export class DonationHandler {
         const serverId: number = parseInt(session.get('serverId'));
         const sid: string = session.get('sid');
         
+        let res: any = await lockData(serverId, DATA_NAME.DONATE, roleId);// 玩家可能会快速做多次操作，加一下锁
+        try {
+            if (!res) {
+                return resResult(STATUS.REDLOCK_ERR);
+            }
+
             let userGuild = await refreshUserGuild(myUserGuild, roleId);
-        if (!userGuild) return resResult(STATUS.WRONG_PARMS);
+            if (!userGuild) {
+                res.releaseCallback();
+                return resResult(STATUS.WRONG_PARMS);
+            }
             const { guildCode: code, donateCnt: resdonateCnt } = userGuild;
-        if (resdonateCnt >= ARMY.ARMY_DONATE_TIMES)
+            if (resdonateCnt >= ARMY.ARMY_DONATE_TIMES) {
+                res.releaseCallback();
                 return resResult(STATUS.GUILD_DONATE_TIMES_NOT_ENOUGH);
+            }
             let { donationLv } = await getDonation(code, serverId);
             let { donateReward } = getArmyDonateBaseByLv(donationLv);
             let { rewardGood, rewardFund, cosume } = donateReward.get(id);
             let result = await handleCost(roleId, sid, [cosume]);
-        if (!result)
+            if (!result) {
+                res.releaseCallback();
                 return resResult(STATUS.ROLE_MATERIAL_NOT_ENOUGH);
+            }
             let { donateCnt } = await UserGuildModel.donateFund(roleId, 1);
 
             let { donateFund, reports } = await DonationModel.donation(code, rewardFund, { reports: { id, roleName, time: nowSeconds() } });
@@ -78,7 +93,12 @@ export class DonationHandler {
             //活动任务
             await checkActivityTask(serverId, sid, roleId, TASK_TYPE.GUILD_DONATE, 1);
 
+            res.releaseCallback();
             return resResult(STATUS.SUCCESS, { donateFund, reports, donateCnt, simpleGoods: goods });
+        } catch (e) {
+            res.releaseCallback();
+            throw e;
+        }
     }
     /**
      * 领取宝箱

shared/consts/dataName.ts

@@ -10,4 +10,5 @@ export enum DATA_NAME {
     WEEKLY_GUILD_SUM = 'WeeklyGuildSum',   // 每周结算活跃和奖励
     GAMEMAIL = 'Mail',
     AUCTION_LOT = 'LotCode',
+    DONATE = 'Donate',
 }