调整任务查询，回调，奖励类型查询
This commit is contained in:
@ -556,6 +556,164 @@ func (s *sReward) OperateTaskReward(ctx context.Context, in *model.OperateTaskRe
|
||||
}
|
||||
|
||||
// CallBack 奖励回调
|
||||
//
|
||||
// func (s *sReward) CallBack(ctx context.Context, in *model.RewardCallbackIn) (out *model.RewardCallbackOut, err error) {
|
||||
// var reward *model.Reward
|
||||
// var res model.RewardCallbackOut
|
||||
// res.OrderId = in.OrderId
|
||||
// res.AppId = in.AppId
|
||||
//
|
||||
// // 查询奖励
|
||||
// err = dao.Rewards.Ctx(ctx).Where(do.Rewards{PrizeId: in.PrizeId}).Scan(&reward)
|
||||
// if err != nil {
|
||||
// res.Errcode = -1
|
||||
// res.Errmsg = "查询奖励异常"
|
||||
// res.Datas = nil
|
||||
// return &res, ecode.Fail.Sub("查询奖励异常")
|
||||
// }
|
||||
//
|
||||
// if reward == nil {
|
||||
// res.Errcode = -1
|
||||
// res.Errmsg = "查询奖励为空"
|
||||
// res.Datas = nil
|
||||
// return &res, ecode.Params.Sub("查询奖励为空")
|
||||
// }
|
||||
//
|
||||
// // 判断是否过期
|
||||
// if reward.ExpireType == 1 {
|
||||
// //时间段过期
|
||||
// if reward.ValidTo.Before(gtime.Now()) {
|
||||
// res.Errcode = consts.BatchOutDate
|
||||
// res.Errmsg = consts.BatchOutDateMSG
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// // 日
|
||||
// now := time.Now()
|
||||
// // 当天开始时间
|
||||
// start := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location())
|
||||
// // 当天结束时间
|
||||
// end := time.Date(now.Year(), now.Month(), now.Day(), 23, 59, 59, 0, now.Location())
|
||||
// // 查先询用户当日已领取
|
||||
// //dailyGetNum, err := dao.Rewards.Ctx(ctx).
|
||||
// // LeftJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id=%s.reward_id", dao.Rewards.Table(), dao.UserTaskRewards.Table())).
|
||||
// // Where(dao.Rewards.Columns().PrizeId, in.PrizeId).
|
||||
// // WhereBetween(dao.UserTaskRewards.Columns().UpdatedAt, start, end).
|
||||
// // Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).Count()
|
||||
// //
|
||||
// //// dailyGetNum, err := dao.Rewards.Ctx(ctx).
|
||||
// //// Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id=%s.reward_id", dao.Rewards.Table(),
|
||||
// //// dao.UserTaskRewards.Table())).InnerJoin(dao.RewardWaters.Table(), fmt.Sprintf("%s.external_order_id = %s.order_id", dao.UserTaskRewards.Table(), dao.RewardWaters.Table())).
|
||||
// //// Where(dao.RewardWaters.Columns().Recvuid, in.Uid).Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).
|
||||
// //// WhereBetween(dao.UserTaskRewards.Columns().UpdatedAt, start, end).Fields(fmt.Sprintf("%s.*,%s.*", dao.Rewards.Table(), dao.UserTaskRewards.Table())).Count()
|
||||
// //
|
||||
// //if err != nil {
|
||||
// // res.Errcode = -1
|
||||
// // res.Errmsg = "查询用户当日领取数量失败"
|
||||
// // res.Datas = nil
|
||||
// // return &res, ecode.Fail.Sub("查询用户当日领取数量失败")
|
||||
// //}
|
||||
// //
|
||||
// //// 判断是否达到用户日限制
|
||||
// //if int(reward.UserDailyLimit) <= dailyGetNum {
|
||||
// // res.Errcode = consts.UserDayLimit
|
||||
// // res.Errmsg = consts.UserDayLimitMSG
|
||||
// //}
|
||||
// //
|
||||
// //// 查先询用户总共已领取
|
||||
// //dailyTotalNum, err := dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id=%s.reward_id", dao.Rewards.Table(),
|
||||
// // dao.UserTaskRewards.Table())).InnerJoin(dao.RewardWaters.Table(), fmt.Sprintf("%s.external_order_id = %s.order_id", dao.UserTaskRewards.Table(), dao.RewardWaters.Table())).
|
||||
// // Where(dao.RewardWaters.Columns().Recvuid, in.Uid).Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).
|
||||
// // Fields(fmt.Sprintf("%s.*,%s.*", dao.Rewards.Table(), dao.UserTaskRewards.Table())).Count()
|
||||
// //
|
||||
// //if err != nil {
|
||||
// // res.Errcode = -1
|
||||
// // res.Errmsg = "查询用户当日总共领取数量失败"
|
||||
// // res.Datas = nil
|
||||
// // return &res, ecode.Fail.Sub("查询用户当日总共领取数量失败")
|
||||
// //}
|
||||
// //// 判断是否达到用户总限制
|
||||
// //if int(reward.UserTotalLimit) <= dailyTotalNum {
|
||||
// // res.Errcode = consts.UserTotalLimit
|
||||
// // res.Errmsg = consts.UserTotalLimitMSG
|
||||
// //}
|
||||
// //
|
||||
// //// 查先询该批次当日已领取
|
||||
// //batchDailyGetNum, err := dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id = %s.reward_id",
|
||||
// // dao.Rewards.Table(), dao.UserTaskRewards.Table())).Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).
|
||||
// // WhereBetween(dao.UserTaskRewards.Columns().UpdatedAt, start, end).Fields(fmt.Sprintf("%s.*,%s.*", dao.Rewards.Table(), dao.UserTaskRewards.Table())).Count()
|
||||
// //if err != nil {
|
||||
// // res.Errcode = -1
|
||||
// // res.Errmsg = "查询该批次当日总共领取数量失败"
|
||||
// // res.Datas = nil
|
||||
// // return &res, ecode.Fail.Sub("查询该批次当日总共领取数量失败")
|
||||
// //}
|
||||
// //// 判断是否达到该批次日限制
|
||||
// //if int(reward.DailyTotalLimit) <= batchDailyGetNum {
|
||||
// // res.Errcode = consts.BatchDayLimit
|
||||
// // res.Errmsg = consts.BatchDayLimitMSG
|
||||
// //}
|
||||
// //
|
||||
// //// 查先询该批次总共已领取
|
||||
// //batchTotalGetNum, err := dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id = %s.reward_id",
|
||||
// // dao.Rewards.Table(), dao.UserTaskRewards.Table())).Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).
|
||||
// // Fields(fmt.Sprintf("%s.*,%s.*", dao.Rewards.Table(), dao.UserTaskRewards.Table())).Count()
|
||||
// //
|
||||
// //if err != nil {
|
||||
// // res.Errcode = -1
|
||||
// // res.Errmsg = "查询该批次总共领取数量失败"
|
||||
// // res.Datas = nil
|
||||
// // return &res, ecode.Fail.Sub("查询该批次总共领取数量失败")
|
||||
// //}
|
||||
// //// 判断是否达到该批次总共限制
|
||||
// //if int(reward.TotalLimit) <= batchTotalGetNum {
|
||||
// // res.Errcode = consts.BatchTotalLimit
|
||||
// // res.Errmsg = consts.BatchTotalLimitMSG
|
||||
// //}
|
||||
//
|
||||
// _, err = dao.RewardCallback.Ctx(ctx).OmitEmptyData().Insert(do.RewardCallback{
|
||||
// OrderId: in.OrderId,
|
||||
// PrizeId: in.PrizeId,
|
||||
// PrizeType: in.PrizeType,
|
||||
// PrizeSubType: in.PrizeSubType,
|
||||
// Uid: in.Uid,
|
||||
// Num: in.Num,
|
||||
// CustomInfo: in.CustomInfo,
|
||||
// AppId: in.AppId,
|
||||
// })
|
||||
//
|
||||
// if err != nil {
|
||||
// res.Errcode = -1
|
||||
// res.Errmsg = "存储奖励回调数据异常"
|
||||
// res.Datas = nil
|
||||
// return &res, ecode.Fail.Sub("存储奖励回调数据异常")
|
||||
// }
|
||||
//
|
||||
// // 回调成功，组装响应参数
|
||||
// var userTaskReward []*model.UserTaskRewards
|
||||
// if err = dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.%s = %s.%s",
|
||||
// dao.Rewards.Table(), dao.Rewards.Columns().Id, dao.UserTaskRewards.Table(), dao.UserTaskRewards.Columns().RewardId)).Scan(&userTaskReward); err != nil {
|
||||
// return nil, ecode.Fail.Sub("获取用户奖励记录异常")
|
||||
// }
|
||||
//
|
||||
// if userTaskReward == nil {
|
||||
// res.Errcode = -1
|
||||
// res.Errmsg = "用户奖励记录为空"
|
||||
// res.Datas = nil
|
||||
// return &res, ecode.Fail.Sub("用户奖励记录为空")
|
||||
// }
|
||||
//
|
||||
// callbackData := make([]model.CallbackData, 0)
|
||||
// for _, v := range userTaskReward {
|
||||
// callbackData = append(callbackData, model.CallbackData{
|
||||
// PrizeCode: v.InnerOrderId,
|
||||
// })
|
||||
// }
|
||||
//
|
||||
// res.Datas = callbackData
|
||||
//
|
||||
// return &res, err
|
||||
// }
|
||||
func (s *sReward) CallBack(ctx context.Context, in *model.RewardCallbackIn) (out *model.RewardCallbackOut, err error) {
|
||||
var reward *model.Reward
|
||||
var res model.RewardCallbackOut
|
||||
@ -593,76 +751,70 @@ func (s *sReward) CallBack(ctx context.Context, in *model.RewardCallbackIn) (out
|
||||
start := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location())
|
||||
// 当天结束时间
|
||||
end := time.Date(now.Year(), now.Month(), now.Day(), 23, 59, 59, 0, now.Location())
|
||||
// 查先询用户当日已领取
|
||||
dailyGetNum, err := dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id=%s.reward_id", dao.Rewards.Table(),
|
||||
dao.UserTaskRewards.Table())).InnerJoin(dao.RewardWaters.Table(), fmt.Sprintf("%s.external_order_id = %s.order_id", dao.UserTaskRewards.Table(), dao.RewardWaters.Table())).
|
||||
Where(dao.RewardWaters.Columns().Recvuid, in.Uid).Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).
|
||||
WhereBetween(dao.UserTaskRewards.Columns().UpdatedAt, start, end).Fields(fmt.Sprintf("%s.*,%s.*", dao.Rewards.Table(), dao.UserTaskRewards.Table())).Count()
|
||||
|
||||
value, err := dao.Users.Ctx(ctx).Where(dao.Users.Columns().WxPopenId, fmt.Sprintf("WX_%s", in.Uid)).WhereOr(dao.Users.Columns().QqPopenId, fmt.Sprintf("QQ_%s", in.Uid)).Fields(dao.Users.Columns().Id).Value()
|
||||
if err != nil {
|
||||
res.Errcode = -1
|
||||
res.Errmsg = "查询用户当日领取数量失败"
|
||||
res.Errmsg = "查询用户ID异常"
|
||||
res.Datas = nil
|
||||
return &res, ecode.Fail.Sub("查询用户当日领取数量失败")
|
||||
return &res, ecode.Fail.Sub("查询用户ID异常")
|
||||
}
|
||||
userId := value.Int64()
|
||||
|
||||
// 判断是否达到用户日限制
|
||||
if int(reward.UserDailyLimit) <= dailyGetNum {
|
||||
// 查询当前用户当天领取总数
|
||||
userTodayNum, err := dao.UserTasks.Ctx(ctx).Where(do.UserTasks{UserId: userId}).LeftJoin(dao.UserTaskRewards.Table(), "utr", "utr.user_task_id = user_tasks.id").
|
||||
WhereIn("utr.status", []int{3, 6}).
|
||||
Where("utr.reward_id = ?", reward.Id).WhereBetween("utr.updated_at", start, end).Count()
|
||||
if err != nil {
|
||||
res.Errcode = -1
|
||||
res.Errmsg = "查询用户当天领取数量异常"
|
||||
res.Datas = nil
|
||||
return &res, ecode.Fail.Sub("查询用户当天领取数量异常")
|
||||
}
|
||||
if userTodayNum >= int(reward.UserDailyLimit) {
|
||||
res.Errcode = consts.UserDayLimit
|
||||
res.Errmsg = consts.UserDayLimitMSG
|
||||
}
|
||||
|
||||
// 查先询用户总共已领取
|
||||
dailyTotalNum, err := dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id=%s.reward_id", dao.Rewards.Table(),
|
||||
dao.UserTaskRewards.Table())).InnerJoin(dao.RewardWaters.Table(), fmt.Sprintf("%s.external_order_id = %s.order_id", dao.UserTaskRewards.Table(), dao.RewardWaters.Table())).
|
||||
Where(dao.RewardWaters.Columns().Recvuid, in.Uid).Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).
|
||||
Fields(fmt.Sprintf("%s.*,%s.*", dao.Rewards.Table(), dao.UserTaskRewards.Table())).Count()
|
||||
|
||||
// 查询当前用户该奖励领取总数
|
||||
userTotalNum, err := dao.UserTasks.Ctx(ctx).Where(do.UserTasks{UserId: userId}).LeftJoin(dao.UserTaskRewards.Table(), "utr", "utr.user_task_id = user_tasks.id").
|
||||
WhereIn("utr.status", []int{3, 6}).
|
||||
Where("utr.reward_id = ?", reward.Id).Count()
|
||||
if err != nil {
|
||||
res.Errcode = -1
|
||||
res.Errmsg = "查询用户当日总共领取数量失败"
|
||||
res.Errmsg = "查询用户领取数量异常"
|
||||
res.Datas = nil
|
||||
return &res, ecode.Fail.Sub("查询用户当日总共领取数量失败")
|
||||
return &res, ecode.Fail.Sub("查询用户领取数量异常")
|
||||
}
|
||||
// 判断是否达到用户总限制
|
||||
if int(reward.UserTotalLimit) <= dailyTotalNum {
|
||||
if userTotalNum >= int(reward.UserTotalLimit) {
|
||||
res.Errcode = consts.UserTotalLimit
|
||||
res.Errmsg = consts.UserTotalLimitMSG
|
||||
}
|
||||
|
||||
// 查先询该批次当日已领取
|
||||
batchDailyGetNum, err := dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id = %s.reward_id",
|
||||
dao.Rewards.Table(), dao.UserTaskRewards.Table())).Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).
|
||||
WhereBetween(dao.UserTaskRewards.Columns().UpdatedAt, start, end).Fields(fmt.Sprintf("%s.*,%s.*", dao.Rewards.Table(), dao.UserTaskRewards.Table())).Count()
|
||||
// 查询该奖励今天发放总数
|
||||
todayNum, err := dao.UserTaskRewards.Ctx(ctx).WhereBetween("updated_at", start, end).Where("reward_id = ?", reward.Id).WhereIn("status", []int{3, 6}).Count()
|
||||
if err != nil {
|
||||
res.Errcode = -1
|
||||
res.Errmsg = "查询该批次当日总共领取数量失败"
|
||||
res.Errmsg = "查询该批次今天领取数量异常"
|
||||
res.Datas = nil
|
||||
return &res, ecode.Fail.Sub("查询该批次当日总共领取数量失败")
|
||||
return &res, ecode.Fail.Sub("查询该批次今天领取数量异常")
|
||||
}
|
||||
// 判断是否达到该批次日限制
|
||||
if int(reward.DailyTotalLimit) <= batchDailyGetNum {
|
||||
if todayNum >= int(reward.DailyTotalLimit) {
|
||||
res.Errcode = consts.BatchDayLimit
|
||||
res.Errmsg = consts.BatchDayLimitMSG
|
||||
}
|
||||
|
||||
// 查先询该批次总共已领取
|
||||
batchTotalGetNum, err := dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.id = %s.reward_id",
|
||||
dao.Rewards.Table(), dao.UserTaskRewards.Table())).Where(dao.UserTaskRewards.Columns().Status, 3).WhereOr(dao.UserTaskRewards.Columns().Status, 6).
|
||||
Fields(fmt.Sprintf("%s.*,%s.*", dao.Rewards.Table(), dao.UserTaskRewards.Table())).Count()
|
||||
|
||||
// 查询该奖励所有领取总数
|
||||
totalNum, err := dao.UserTaskRewards.Ctx(ctx).Where("reward_id = ?", reward.Id).WhereIn("status", []int{3, 6}).Count()
|
||||
if err != nil {
|
||||
res.Errcode = -1
|
||||
res.Errmsg = "查询该批次总共领取数量失败"
|
||||
res.Errmsg = "查询该批次总共领取数量异常"
|
||||
res.Datas = nil
|
||||
return &res, ecode.Fail.Sub("查询该批次总共领取数量失败")
|
||||
return &res, ecode.Fail.Sub("查询该批次总共领取数量异常")
|
||||
}
|
||||
// 判断是否达到该批次总共限制
|
||||
if int(reward.TotalLimit) <= batchTotalGetNum {
|
||||
if totalNum >= int(reward.TotalLimit) {
|
||||
res.Errcode = consts.BatchTotalLimit
|
||||
res.Errmsg = consts.BatchTotalLimitMSG
|
||||
}
|
||||
|
||||
_, err = dao.RewardCallback.Ctx(ctx).OmitEmptyData().Insert(do.RewardCallback{
|
||||
OrderId: in.OrderId,
|
||||
PrizeId: in.PrizeId,
|
||||
@ -681,26 +833,26 @@ func (s *sReward) CallBack(ctx context.Context, in *model.RewardCallbackIn) (out
|
||||
return &res, ecode.Fail.Sub("存储奖励回调数据异常")
|
||||
}
|
||||
|
||||
// 回调成功，组装响应参数
|
||||
var userTaskReward []*model.UserTaskRewards
|
||||
if err = dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.%s = %s.%s",
|
||||
dao.Rewards.Table(), dao.Rewards.Columns().Id, dao.UserTaskRewards.Table(), dao.UserTaskRewards.Columns().RewardId)).Scan(&userTaskReward); err != nil {
|
||||
return nil, ecode.Fail.Sub("获取用户奖励记录异常")
|
||||
}
|
||||
|
||||
if userTaskReward == nil {
|
||||
res.Errcode = -1
|
||||
res.Errmsg = "用户奖励记录为空"
|
||||
res.Datas = nil
|
||||
return &res, ecode.Fail.Sub("用户奖励记录为空")
|
||||
}
|
||||
//// 回调成功，组装响应参数
|
||||
//var userTaskReward []*model.UserTaskRewards
|
||||
//if err = dao.Rewards.Ctx(ctx).Where(dao.Rewards.Columns().PrizeId, in.PrizeId).InnerJoin(dao.UserTaskRewards.Table(), fmt.Sprintf("%s.%s = %s.%s",
|
||||
// dao.Rewards.Table(), dao.Rewards.Columns().Id, dao.UserTaskRewards.Table(), dao.UserTaskRewards.Columns().RewardId)).Scan(&userTaskReward); err != nil {
|
||||
// return nil, ecode.Fail.Sub("获取用户奖励记录异常")
|
||||
//}
|
||||
//
|
||||
//if userTaskReward == nil {
|
||||
// res.Errcode = -1
|
||||
// res.Errmsg = "用户奖励记录为空"
|
||||
// res.Datas = nil
|
||||
// return &res, ecode.Fail.Sub("用户奖励记录为空")
|
||||
//}
|
||||
|
||||
callbackData := make([]model.CallbackData, 0)
|
||||
for _, v := range userTaskReward {
|
||||
callbackData = append(callbackData, model.CallbackData{
|
||||
PrizeCode: v.InnerOrderId,
|
||||
})
|
||||
}
|
||||
//for _, v := range userTaskReward {
|
||||
callbackData = append(callbackData, model.CallbackData{
|
||||
PrizeCode: "rewardlsseew0rt70db0lhtazmicw50082uudq",
|
||||
})
|
||||
//}
|
||||
|
||||
res.Datas = callbackData
|
||||
|
||||
|
||||
Reference in New Issue
Block a user