去掉刚才加上的锁

This commit is contained in:
luying
2022-05-05 21:35:21 +08:00
parent 91052e6c71
commit b3700454e4

View File

@@ -15,8 +15,6 @@ import { RewardInter } from '../pubUtils/interface';
import { reportTAEvent } from './sdkService';
import { getAllServers } from './redisService';
import { sendMessageToGuildWithSuc, sendMessageToServer, sendMessageToServerWithSuc } from './pushService';
import { lockDataWithNoParam } from './redLockService';
import { DATA_NAME } from '../consts';
// ! 获取底价,假数据
export function getBasePrice(gid: number, count: number) {
@@ -292,8 +290,6 @@ export async function calculateDividend(dividend: DividendType) {
}
export async function startGuildAuction() {
let res: any = await lockDataWithNoParam(DATA_NAME.SEND_AUCTION);//加锁
if (!!res.err) return false;
try {
console.log('schedule startGuildAuction called:', new Date());
@@ -309,11 +305,9 @@ export async function startGuildAuction() {
}
await pushAuctionUpdate(lots, dividends);
res.releaseCallback();
return true;
} catch (e) {
console.error('startGuildAuction err: ', e);
res.releaseCallback();
return false;
}
}
@@ -336,8 +330,6 @@ export async function sendLotsRewardToMlail(lots: LotType[]) {
}
export async function startWorldAuction() {
let res: any = await lockDataWithNoParam(DATA_NAME.SEND_AUCTION);//加锁
if (!!res.err) return false;
try {
console.log('schedule startWorldAuction called:', new Date());
const begin = await todayGuildBegin();
@@ -353,18 +345,14 @@ export async function startWorldAuction() {
await pushCurrentTime(time);
}
await pushAuctionUpdate(lots, dividends);
res.releaseCallback();
return true;
} catch (e) {
console.error('startWorldAuction err: ', e);
res.releaseCallback();
return false;
}
}
export async function stopAuction() {
let res: any = await lockDataWithNoParam(DATA_NAME.SEND_AUCTION);//加锁
if (!!res.err) return false;
try {
console.log('schedule stopAuction called:', new Date());
const begin = await todayGuildBegin();
@@ -379,11 +367,9 @@ export async function stopAuction() {
await pushCurrentTime(time);
}
await pushAuctionUpdate(lots, []);
res.releaseCallback();
return true;
} catch (e) {
console.error('stopAuction err: ', e);
res.releaseCallback();
return false;
}
}