import {ApiCall} from "tsrpc";
import {HuoDongFun} from "../../../public/huodongfun";
import {PayFun} from '../../../public/pay';
import {ReqOpen, ResOpen} from "../../../shared/protocols/event/leijichongzhi/PtlOpen";
import {PublicShared} from '../../../shared/public/public';

export default async function (call: ApiCall<ReqOpen, ResOpen>) {
    let _hdinfo = await HuoDongFun.getHdidInfo(call, call.req.hdid)
    if (!_hdinfo || Object.keys(_hdinfo).length <= 0) {
        // 无此活动
        return call.error('', {code: -1, message: globalThis.lng.huodong_open_1})
    }

    let _dbType: `leijichongzhi${number}` = `leijichongzhi${call.req.hdid}`
    let db = await G.mongodb.cEvent(_dbType).findOne({uid: call.uid, type: _dbType});
    let sTime = db?.sTime || PublicShared.getToDayZeroTime(G.time);

    if (!db) {
        G.mongodb.cEvent(_dbType).updateOne(
            {uid: call.uid, type: _dbType},
            {$set: {sTime: sTime, recIndex: []}},
            {upsert: true}
        );
    }
    let payNum = (await PayFun.getPayDaysAllPayNum(call.uid, _hdinfo.stime, _hdinfo.rtime)) * 10
    payNum = payNum - (db.round || 0) * R.compose(R.sum(), R.map(i => i.total))(_hdinfo.data.tasks)

    call.succ({
        sTime: sTime,
        recIndex: db?.recIndex || [],
        payNum: payNum,
        hdinfo: _hdinfo,
        round: db.round || 0
    });
}