周末礼包
This commit is contained in:
parent
afb925bc40
commit
6aadb030c5
@ -2,6 +2,7 @@ import {ApiCall} from "tsrpc";
|
|||||||
import {ReqOpen, ResOpen} from "../../../shared/protocols/event/zhoumolibao/PtlOpen";
|
import {ReqOpen, ResOpen} from "../../../shared/protocols/event/zhoumolibao/PtlOpen";
|
||||||
import {PayFun} from "../../../public/pay";
|
import {PayFun} from "../../../public/pay";
|
||||||
import {HuoDongFun} from "../../../public/huodongfun";
|
import {HuoDongFun} from "../../../public/huodongfun";
|
||||||
|
import {PublicShared} from "../../../shared/public/public";
|
||||||
|
|
||||||
|
|
||||||
export default async function (call: ApiCall<ReqOpen, ResOpen>) {
|
export default async function (call: ApiCall<ReqOpen, ResOpen>) {
|
||||||
@ -18,3 +19,25 @@ export default async function (call: ApiCall<ReqOpen, ResOpen>) {
|
|||||||
})
|
})
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export async function checkResetBuyLog(call: ApiCall) {
|
||||||
|
let zeroTime = PublicShared.getToDayZeroTime()
|
||||||
|
|
||||||
|
|
||||||
|
let data = await G.mongodb.cEvent('zhoumolibao').findOne({uid: call.uid, type: 'zhoumolibao'})
|
||||||
|
if (data.refreshTime && data.refreshTime > zeroTime) return
|
||||||
|
|
||||||
|
G.mongodb.cEvent(`zhoumolibao`).updateOne(
|
||||||
|
{uid: call.uid, type: `zhoumolibao`},
|
||||||
|
{$set: {record: {}}},
|
||||||
|
{upsert: true}
|
||||||
|
)
|
||||||
|
|
||||||
|
let _hd = (await HuoDongFun.gethdList(call, 9))[0]
|
||||||
|
let payIds = _hd?.data?.gift?.filter(i => i.payId)?.map(i => i.payId)
|
||||||
|
let payLogs = await PayFun.getPayLogs(call.uid, payIds)
|
||||||
|
let payLogLength = R.values(payLogs).filter(i => i.time < zeroTime).length
|
||||||
|
if (payLogLength) {
|
||||||
|
PayFun.delPayLog(call.uid, payIds.map(i => ({payId: i})))
|
||||||
|
}
|
||||||
|
}
|
@ -11,13 +11,13 @@ export default async function (call: ApiCall<ReqReceive, ResReceive>) {
|
|||||||
|
|
||||||
// 取奖励列表,判断是否有可领取奖励
|
// 取奖励列表,判断是否有可领取奖励
|
||||||
let data = await G.mongodb.cEvent('zhoumolibao').findOne({uid: call.uid, type: 'zhoumolibao'})
|
let data = await G.mongodb.cEvent('zhoumolibao').findOne({uid: call.uid, type: 'zhoumolibao'})
|
||||||
let rec = data.record[call.req.id]
|
let rec = data?.record?.[call.req.id]
|
||||||
if (rec && rec >= gift?.buyNum) return call.errorCode(-2)
|
// if (rec && rec >= gift?.buyNum) return call.errorCode(-2)
|
||||||
|
|
||||||
await PlayerFun.sendPrize(call, gift.prize);
|
await PlayerFun.sendPrize(call, gift.prize);
|
||||||
|
|
||||||
await G.mongodb.cEvent('zhoumolibao').updateOne({uid: call.uid, type: 'zhoumolibao'}, {
|
await G.mongodb.cEvent('zhoumolibao').updateOne({uid: call.uid, type: 'zhoumolibao'}, {
|
||||||
$inc: {[`record.${gift.id}`]: 1}
|
$inc: {[`record.${gift.id}`]: 1},
|
||||||
},{ upsert: true })
|
},{ upsert: true })
|
||||||
|
|
||||||
call.succ({})
|
call.succ({})
|
||||||
|
@ -47,7 +47,7 @@ export type eventType = {
|
|||||||
qirichongzhi: Omit<ResOpenQirichongzhi, 'finished'>;
|
qirichongzhi: Omit<ResOpenQirichongzhi, 'finished'>;
|
||||||
jierihuodong: Omit<ResOpenJierihuodong, 'taskFinish'> & { refreshTime: number; };
|
jierihuodong: Omit<ResOpenJierihuodong, 'taskFinish'> & { refreshTime: number; };
|
||||||
kaifujingsai: ResOpenKaifujingsai;
|
kaifujingsai: ResOpenKaifujingsai;
|
||||||
zhoumolibao: ResOpenZhoumolibao;
|
zhoumolibao: ResOpenZhoumolibao & { refreshTime: number; }
|
||||||
} & {
|
} & {
|
||||||
[k: `${number}jijin`]: ResOpenYuedujijin;
|
[k: `${number}jijin`]: ResOpenYuedujijin;
|
||||||
[k: `yangchengmubiao${number}`]: yangchengmubiao;
|
[k: `yangchengmubiao${number}`]: yangchengmubiao;
|
||||||
|
Loading…
Reference in New Issue
Block a user