qixin/HJ_Server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge branch 'bugfix' into dev

Browse Source
This commit is contained in:
xichaoyin 2024-01-04 21:37:11 +08:00
commit 77087741a7
1 changed files with 75 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
src/api_s2c/event/pobinglibao/ApiReceive.ts
View File

@ -1,42 +1,88 @@
import {ApiCall} from "tsrpc"; import { ApiCall } from "tsrpc";
import {ReqReceive, ResReceive} from "../../../shared/protocols/event/pobinglibao/PtlReceive"; import { ReqReceive, ResReceive } from "../../../shared/protocols/event/pobinglibao/PtlReceive";
import {HuoDongFun} from "../../../public/huodongfun"; import { HuoDongFun } from "../../../public/huodongfun";
import {PlayerFun} from "../../../public/player"; import { PlayerFun } from "../../../public/player";
import {HongDianChange} from "../../hongdian/fun"; import { HongDianChange } from "../../hongdian/fun";
import {PayFun} from "../../../public/pay"; import { PayFun } from "../../../public/pay";
import {PublicShared} from "../../../shared/public/public"; import { PublicShared } from "../../../shared/public/public";
export default async function (call: ApiCall<ReqReceive, ResReceive>) { export default async function (call: ApiCall<ReqReceive, ResReceive>) {
// 查询活动是否是可领取状态 // 查询活动是否是可领取状态
let _hd = (await HuoDongFun.gethdList(call, 10))[0] let _hd = (await HuoDongFun.gethdList(call, 10))[0]
let gift = _hd?.data?.gift?.find(i => i.id == call.req.id)
if (!gift || !call.req.recId) return call.errorCode(-1)
// 查询购买状态 let prize = [];
let payLog = await PayFun.getPayLog(call.uid, gift.payId) let update = {};
payLog = payLog?.filter(i => i.time >= _hd.stime && i.time <= _hd.etime) || [] // 判断活动是否是最后一天
if (!payLog || !payLog.length) return call.errorCode(-2) if (PublicShared.chkSameDate(G.time, _hd.etime)) {
let data = await G.mongodb.cEvent(`pobinglibao${_hd.hdid}`).findOne(
{ uid: call.uid, type: `pobinglibao${_hd.hdid}` }
);
/** for (let gift of _hd.data.gift) {
* 取奖励列表，判断是否有可领取奖励 // 查询购买状态
* 购买日起，每种礼包每天可领一次礼包，每种类型独立 let push = [];
* 活动结束前的最后一天，可领取所有奖励 let payLog = await PayFun.getPayLog(call.uid, gift.payId)
*/ payLog = payLog?.filter(i => i.time >= _hd.stime && i.time <= _hd.etime) || []
let data = await G.mongodb.cEvent(`pobinglibao${_hd.hdid}`).findOne({uid: call.uid, type: `pobinglibao${_hd.hdid}`}) if (!payLog || !payLog.length) continue;
let rec = data?.record?.[call.req.id]?.length
let _payDiff = PublicShared.getDiff(payLog[0].time)
_payDiff = _payDiff > 3 ? 3 : _payDiff
let _endDiff = PublicShared.getDiff(_hd.etime)
if ((rec >= _payDiff && _endDiff < 1) || data?.record?.[gift.id] == call.req.recId) return call.errorCode(-3)
await PlayerFun.sendPrize(call, gift[call.req.recId]); for (let key of ["prize", "recPrize1", "recPrize2"]) {
if (data.record[gift.id] && data.record[gift.id].includes(key)) {
push.concat(key);
prize.concat(gift[key]);
}
}
if (push.length > 0) {
if (update["$push"]) {
update["$push"]["record." + gift.id] = { $each: push }
} else {
update["$push"] = { ["record." + gift.id]: { $each: push } }
}
}
}
await G.mongodb.cEvent(`pobinglibao${_hd.hdid}`).updateOne({uid: call.uid, type: `pobinglibao${_hd.hdid}`}, { if (!prize.length) {
$push: {[`record.${gift.id}`]: call.req.recId}, return call.errorCode(-3)
}, {upsert: true}) }
} else {
let gift = _hd?.data?.gift?.find(i => i.id == call.req.id);
if (!gift || !call.req.recId) return call.errorCode(-1);
call.succ({prize: gift[call.req.recId]}) // 查询购买状态
let payLog = await PayFun.getPayLog(call.uid, gift.payId)
payLog = payLog?.filter(i => i.time >= _hd.stime && i.time <= _hd.etime) || []
if (!payLog || !payLog.length) return call.errorCode(-2);
/**
* 取奖励列表，判断是否有可领取奖励
* 购买日起，每种礼包每天可领一次礼包，每种类型独立
* 活动结束前的最后一天，可领取所有奖励
*/
let data = await G.mongodb.cEvent(`pobinglibao${_hd.hdid}`).findOne(
{ uid: call.uid, type: `pobinglibao${_hd.hdid}` }
)
let rec = data?.record?.[call.req.id]?.length
let _payDiff = PublicShared.getDiff(payLog[0].time)
_payDiff = _payDiff > 3 ? 3 : _payDiff
if (rec >= _payDiff || data?.record?.[gift.id] == call.req.recId) return call.errorCode(-3)
prize.concat(gift[call.req.recId]);
update = {
$push: { [`record.${gift.id}`]: call.req.recId },
}
}
await PlayerFun.sendPrize(call, prize);
await G.mongodb.cEvent(`pobinglibao${_hd.hdid}`).updateOne(
{ uid: call.uid, type: `pobinglibao${_hd.hdid}` }, update, { upsert: true }
);
call.succ({ prize: prize });
HongDianChange.sendChangeKey(call.uid, ['huodonghd']); HongDianChange.sendChangeKey(call.uid, ['huodonghd']);
} }