moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

日常任务

Browse Source 
金豆，任务

taskConstant
This commit is contained in:
hokli
2025-05-16 18:57:20 +08:00
parent 5f9cccd8a8
commit 7f74b75456
35 changed files with 1341 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
accompany-base/accompany-common/src/main/java/com/accompany/common/status/BusiStatus.java
View File

@@ -949,6 +949,14 @@ public enum BusiStatus {
USER_EVENT_BEGIN_SELECT(20513, "超过可选时间范围"),
USER_EVENT_EXIST(20513, "该房间已经申请[时间范围]举办活动了"),
USER_EVENT_GOLD_CONFIG_ERROR(20513, "GOLD_CONFIG_ERROR"),
DAILY_RECEIVE_EXPIRE(20514, "领取失效，请刷新页面"),
DAILY_RECEIVE_EXIST(20514, "已经领取过了"),
DAILY_TASK_UNCOMPLETED(20514, "任务未完成，请刷新重试3"),
DAILY_GOLDBEANNOTENOUGH(20514, "金豆餘額不足，请完成任务获取"),
;
private final int value;

1
accompany-base/accompany-core/src/main/java/com/accompany/common/redis/RedisKey.java
View File

@@ -1460,6 +1460,7 @@ public enum RedisKey {
//小游戏token
joy_token,
;
public String getKey() {

48
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/constant/dailytask/DailyTaskConstant.java Normal file
View File

@@ -0,0 +1,48 @@
package com.accompany.business.constant.dailytask;
import com.accompany.common.redis.BaseRedisKey;
public interface DailyTaskConstant {
enum ReceiveStatus {
UNCOMPLETED,
AVAILABLE,
RECEIVED,
}
enum RedisKey implements BaseRedisKey {
task_receive_status,//日常任务领取状态
task_status,// 日常任务完成状态
lock_user_gold_bean, // 用户金豆分布式锁
charge_gold,//日充值金币
play_game,//游戏种类
recv_gold_num,//收礼金币
;
@Override
public String getKey() {
return "Daily:" + name();
}
}
enum SignRedisKey implements BaseRedisKey {
sign_award_list, //签到奖励key
sign_index_seven_today_status,
sign_index_seven_sign_lock,
sign_christmas_sign_lock,
sign_index_seven_times,
sign_index_seven_repeat_device,
sign_device_limit,
sign_christmas_repeat_device,
sign_index_seven_repeat_ip,
sign_ip_limit,
;
@Override
public String getKey() {
return "Sign:" + name();
}
}
}

34
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/constant/dailytask/DailyTaskTypeEnum.java Normal file
View File

@@ -0,0 +1,34 @@
package com.accompany.business.constant.dailytask;
public enum DailyTaskTypeEnum {
DAILY_SIGN(1, 100), ////每日签到
UP_MIC(60, 1500),//"上麦聊天",
UP_MIC_120(120, 5000),//上麦聊天(0/120Mins)
PLAY_GAME(3, 6000),//参与小游戏(0/3)
CHARGE_GOLD_NUM(7000, 5000),//充值7000
CHARGE_GOLD_NUM_5(35000, 30000),//充值35000
CHARGE_GOLD_NUM_10(70000, 70000),//充值70000
ROOM_SEND_GIFT(1, 8000),//房间送礼
RECV_LUCKY_GIFT(1, 100),//收到Lucky/Bravo礼物
RECV_NOMAL_GIFT(1, 4000),//收到普通礼物
RECV_NOMAL_GIFT_GOLD(20000, 8000),//收到礼物(价值超过2w金币)
;
private final int reachNum;//达标数量
private final int reachGoldBean;//奖励金豆数
DailyTaskTypeEnum(int reachNum, int reachGoldBean) {
this.reachNum = reachNum;
this.reachGoldBean = reachGoldBean;
}
public int getReachNum() {
return reachNum;
}
public int getReachGoldBean() {
return reachGoldBean;
}
}

29
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/constant/dailytask/GoldBeanBillType.java Normal file
View File

@@ -0,0 +1,29 @@
package com.accompany.business.constant.dailytask;
public enum GoldBeanBillType {
TASK_GAIN(1, "任务获取", (byte)1),
MALL_PAY(2, "商城购买", (byte)1),
;
private final int type;
private final String desc;
private final byte billType;//账单类型1-支出， 2-收入
GoldBeanBillType(int type, String desc, byte billType) {
this.type = type;
this.desc = desc;
this.billType = billType;
}
public int getType() {
return type;
}
public String getDesc() {
return desc;
}
public byte getBillType() {
return billType;
}
}

34
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/model/UserGoldBean.java Normal file
View File

@@ -0,0 +1,34 @@
package com.accompany.business.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
/**
* 用户金豆表实体类
*
* @author
* @since 2025-05-19
*/
@Data
public class UserGoldBean implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 用户uid
*/
@TableId(value = "uid", type = IdType.NONE)
private Long uid;
/**
* 总金豆数量
*/
private BigDecimal goldBean;
private Date updateTime;
}

50
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/model/UserGoldBeanBill.java Normal file
View File

@@ -0,0 +1,50 @@
package com.accompany.business.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
/**
* 用户金豆账单表实体类
*
* @author
* @since 2025-05-19
*/
@Data
public class UserGoldBeanBill implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(value = "id", type = IdType.AUTO)
private Long id;
/**
* 用户uid
*/
private Long uid;
/**
* //账单类型1-支出， 2-收入
*/
private Byte billType;
/**
* 类型1-任务领取，2商城购买
*/
private Integer type;
/**
* objId
*/
private String objId;
private BigDecimal beforeBean;
private BigDecimal operateBean;
private BigDecimal afterBean;
/**
* 时间
*/
private Date createTime;
private Date updateTime;
}

29
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/vo/DailyTaskVo.java Normal file
View File

@@ -0,0 +1,29 @@
package com.accompany.business.vo;
import com.accompany.business.constant.dailytask.DailyTaskConstant;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
@AllArgsConstructor
@NoArgsConstructor
@Builder
@ApiModel
@Data
public class DailyTaskVo {
@ApiModelProperty("任务类型")
private DailyTaskTypeEnum taskType;
@ApiModelProperty("UNCOMPLETED-完成, AVAILABLE-可领取，RECEIVED-已领取")
private DailyTaskConstant.ReceiveStatus receiveStatus;
@ApiModelProperty("金豆数量")
private Integer goldBean;
@ApiModelProperty("到达数量")
private Long reachNum;
@ApiModelProperty("达标值")
private Integer standardValue;
private String todayDate;
}

25
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/vo/dailytask/DailyProgressContext.java Normal file
View File

@@ -0,0 +1,25 @@
package com.accompany.business.vo.dailytask;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Data
public class DailyProgressContext {
private Integer partitiionId;
private Long uid;
private Long recvUid;
private Long roomUid;
private String gameId;
private Long chargeGoldNum;
private Byte giftType;
private Long recvGoldNum;
private Date createTime;
}

17
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/vo/dailytask/DailyTaskContext.java Normal file
View File

@@ -0,0 +1,17 @@
package com.accompany.business.vo.dailytask;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import lombok.Data;
@Data
public class DailyTaskContext {
private final Long uid;
private final DailyTaskTypeEnum taskType;
private String todayDate;
private Integer partitionId;
public DailyTaskContext(Long uid, DailyTaskTypeEnum taskType) {
this.uid = uid;
this.taskType = taskType;
}
}

12
accompany-business/accompany-business-service/src/main/java/com/accompany/business/event/listener/CommonRecharge4ActListener.java
View File

@@ -1,6 +1,9 @@
package com.accompany.business.event.listener;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.service.activity.h5.ActivityOfChargeService;
import com.accompany.business.service.dailytask.DailyTaskService;
import com.accompany.business.service.invite.UserInviteFissionV2Service;
import com.accompany.business.vo.charge.CommonRecharge4ActVo;
import com.accompany.common.constant.Constant;
@@ -26,6 +29,8 @@ public class CommonRecharge4ActListener implements ApplicationListener<CommonRe
private ActivityOfChargeService activityOfChargeService;
@Autowired
private UserInviteFissionV2Service userInviteFissionV2Service;
@Autowired
private DailyTaskService dailyTaskService;
@Override
@Async
@@ -42,6 +47,13 @@ public class CommonRecharge4ActListener implements ApplicationListener<CommonRe
log.error("chargeSuccessMessage addTotalNum error is {}", JSONObject.toJSONString(commonRecharge4ActVo), e);
}
this.inviteFissionCharge(commonRecharge4ActVo);
DailyProgressContext dailyProgressContext = DailyProgressContext.builder()
.chargeGoldNum(commonRecharge4ActVo.getTotalGoldNum())
.uid(commonRecharge4ActVo.getUid())
.createTime(commonRecharge4ActVo.getCreateTime())
.build();
dailyTaskService.executeProgress(DailyTaskTypeEnum.CHARGE_GOLD_NUM, dailyProgressContext);
}
private void inviteFissionCharge(CommonRecharge4ActVo commonRecharge4ActVo) {

14
accompany-business/accompany-business-service/src/main/java/com/accompany/business/mybatismapper/UserGoldBeanBillMapper.java Normal file
View File

@@ -0,0 +1,14 @@
package com.accompany.business.mybatismapper;
import com.accompany.business.model.UserGoldBeanBill;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* 用户金豆账单表 Mapper 接口
*
* @author
* @since 2025-05-19
*/
public interface UserGoldBeanBillMapper extends BaseMapper<UserGoldBeanBill> {
}

20
accompany-business/accompany-business-service/src/main/java/com/accompany/business/mybatismapper/UserGoldBeanMapper.java Normal file
View File

@@ -0,0 +1,20 @@
package com.accompany.business.mybatismapper;
import com.accompany.business.model.UserGoldBean;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
import java.math.BigDecimal;
/**
* 用户金豆表 Mapper 接口
*
* @author
* @since 2025-05-19
*/
public interface UserGoldBeanMapper extends BaseMapper<UserGoldBean> {
int updateAddGoldBean(@Param("uid") Long uid, @Param("goldBean") BigDecimal goldBean);
int updateSubGoldBean(@Param("uid") Long uid, @Param("goldBean") BigDecimal goldBean);
}

133
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/AbstractDailyTaskHandler.java Normal file
View File

@@ -0,0 +1,133 @@
package com.accompany.business.service.dailytask;
import com.accompany.business.constant.dailytask.DailyTaskConstant;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.constant.dailytask.GoldBeanBillType;
import com.accompany.business.service.user.UsersService;
import com.accompany.business.service.usergoldbean.UserGoldBeanService;
import com.accompany.business.vo.DailyTaskVo;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.common.result.BusiResult;
import com.accompany.common.status.BusiStatus;
import com.accompany.common.utils.DateTimeUtil;
import com.accompany.core.enumeration.PartitionEnum;
import com.accompany.core.exception.ServiceException;
import com.accompany.core.model.Users;
import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.redisson.client.codec.IntegerCodec;
import org.springframework.beans.factory.annotation.Autowired;
import java.math.BigDecimal;
import java.time.Duration;
import java.time.ZonedDateTime;
import java.util.Date;
import static com.accompany.business.constant.dailytask.DailyTaskConstant.RedisKey.task_receive_status;
import static com.accompany.business.constant.dailytask.DailyTaskConstant.RedisKey.task_status;
public abstract class AbstractDailyTaskHandler implements DailyTaskHandler {
@Autowired
protected UsersService usersService;
@Autowired
protected RedissonClient redissonClient;
@Autowired
private UserGoldBeanService userGoldBeanService;
protected final int EXPIRE_DAY = 1;
@Override
public DailyTaskVo handle(DailyTaskContext context){
Users users = usersService.getUsersByUid(context.getUid());
context.setTodayDate(this.getTodayDate(context.getUid(), new Date()));
context.setPartitionId(users.getPartitionId());
return this.doHandle(context);
}
/**
* 进度逻辑
* @param progressContext
* @return
*/
@Override
public abstract void executeProgress(DailyProgressContext progressContext);
/**
* 业务逻辑
* @param context
* @return
*/
@Override
public abstract DailyTaskVo doHandle(DailyTaskContext context);
/**
* 领取任务奖励
* @param uid
* @param receiveDate
* @param dailyTaskTypeEnum
* @return
*/
@Override
public BusiResult receive(Long uid, String receiveDate, DailyTaskTypeEnum dailyTaskTypeEnum) {
DailyTaskContext dailyTaskContext = new DailyTaskContext(uid, dailyTaskTypeEnum);
DailyTaskVo dailyTaskVo = this.handle(dailyTaskContext);
if (!dailyTaskVo.getTodayDate().equals(receiveDate)) {
throw new ServiceException(BusiStatus.DAILY_RECEIVE_EXPIRE);
}
RBucket<Integer> taskStatus = taskStatus(uid, receiveDate, dailyTaskTypeEnum);
if (taskStatus.isExists()) {
throw new ServiceException(BusiStatus.DAILY_RECEIVE_EXIST);
}
Integer receiveStatus = receiveStatus(uid, receiveDate, dailyTaskTypeEnum)
.getAndSet(1, Duration.ofDays(EXPIRE_DAY));
if (receiveStatus != null) {
throw new ServiceException(BusiStatus.DAILY_RECEIVE_EXIST);
}
userGoldBeanService.addGoldBean(uid, BigDecimal.valueOf(dailyTaskTypeEnum.getReachGoldBean()),
GoldBeanBillType.TASK_GAIN, String.valueOf(dailyTaskTypeEnum.ordinal()));
return BusiResult.success();
}
@Override
public String getTodayDate(Long uid, Date date) {
Users users = usersService.getUsersByUid(uid);
PartitionEnum partitionEnum = PartitionEnum.getByPartitionId(users.getPartitionId());
ZonedDateTime zonedDateTime = DateTimeUtil.convertWithZoneId(date, partitionEnum.getZoneId());
return zonedDateTime.format(DateTimeUtil.dateFormatter);
}
/**
* 获取领取状态
* @param uid
* @param todayDate
* @param taskType
* @return
*/
protected DailyTaskConstant.ReceiveStatus computeReceiveStatus(Long uid, String todayDate, DailyTaskTypeEnum taskType) {
if (!this.taskStatus(uid, todayDate, taskType).isExists()) {
return DailyTaskConstant.ReceiveStatus.UNCOMPLETED;
}
return this.receiveStatus(uid, todayDate, taskType).isExists()
? DailyTaskConstant.ReceiveStatus.RECEIVED
: DailyTaskConstant.ReceiveStatus.AVAILABLE;
}
private RBucket<Integer> receiveStatus(Long uid, String todayDate, DailyTaskTypeEnum dailyTaskTypeEnum) {
return redissonClient.getBucket(task_receive_status.getKey(uid.toString(), dailyTaskTypeEnum.name(),
todayDate.replaceAll("-", "")), IntegerCodec.INSTANCE);
}
/**
* 任务完成状态
* @param uid
* @param todayDate
* @param dailyTaskTypeEnum
* @return
*/
protected RBucket<Integer> taskStatus(Long uid, String todayDate, DailyTaskTypeEnum dailyTaskTypeEnum) {
return redissonClient.getBucket(task_status.getKey(uid.toString(), dailyTaskTypeEnum.name(),
todayDate.replaceAll("-", "")), IntegerCodec.INSTANCE);
}
}

23
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/DailyTaskHandler.java Normal file
View File

@@ -0,0 +1,23 @@
package com.accompany.business.service.dailytask;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.vo.DailyTaskVo;
import com.accompany.common.result.BusiResult;
import java.util.Date;
public interface DailyTaskHandler {
void executeProgress(DailyProgressContext progressContext);
DailyTaskVo handle(DailyTaskContext context);
DailyTaskVo doHandle(DailyTaskContext context);
BusiResult receive(Long uid, String receiveDate, DailyTaskTypeEnum dailyTaskTypeEnum);
String getTodayDate(Long uid, Date date);
}

28
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/DailyTaskHandlerRegistry.java Normal file
View File

@@ -0,0 +1,28 @@
package com.accompany.business.service.dailytask;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Component
public class DailyTaskHandlerRegistry {
private final Map<DailyTaskTypeEnum, DailyTaskHandler> handlerMap = new HashMap<>();
public DailyTaskHandlerRegistry(List<DailyTaskHandler> handlers) {
for (DailyTaskHandler handler : handlers) {
DailyTaskHandlerType annotation = handler.getClass().getAnnotation(DailyTaskHandlerType.class);
if (annotation != null) {
handlerMap.put(annotation.value(), handler);
}
}
}
public DailyTaskHandler getHandler(DailyTaskTypeEnum taskType) {
return handlerMap.get(taskType);
}
}

92
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/DailyTaskService.java Normal file
View File

@@ -0,0 +1,92 @@
package com.accompany.business.service.dailytask;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.vo.DailyTaskVo;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.common.result.BusiResult;
import com.accompany.common.status.BusiStatus;
import com.accompany.common.utils.StringUtils;
import com.accompany.core.exception.ServiceException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import static com.accompany.business.constant.dailytask.DailyTaskTypeEnum.*;
@Service
public class DailyTaskService {
@Autowired
private DailyTaskHandlerRegistry taskHandlerRegistry;
public DailyTaskVo executeDailyTask(DailyTaskTypeEnum contextTaskType, DailyTaskTypeEnum handlerTaskType, Long uid) {
DailyTaskHandler handler = taskHandlerRegistry.getHandler(handlerTaskType);
DailyTaskContext dailyTaskContext = new DailyTaskContext(uid, contextTaskType);
return handler.handle(dailyTaskContext);
}
/**
* 刷新任务进度
*
* @param taskType
* @param dailyProgressContext
*/
public void executeProgress(DailyTaskTypeEnum taskType, DailyProgressContext dailyProgressContext) {
DailyTaskHandler handler = taskHandlerRegistry.getHandler(taskType);
handler.executeProgress(dailyProgressContext);
}
/**
* 领取积分
*
* @param taskType
* @param uid
* @param todayDate
* @return
*/
public BusiResult executeReceive(DailyTaskTypeEnum taskType, Long uid, String todayDate) {
DailyTaskHandler handler = taskHandlerRegistry.getHandler(taskType);
if (handler == null || StringUtils.isEmpty(todayDate) || uid == null) {
throw new ServiceException(BusiStatus.PARAMERROR);
}
return handler.receive(uid, todayDate, taskType);
}
/**
* 任务列表
*
* @param uid
* @return
*/
public BusiResult<List<DailyTaskVo>> tasks(Long uid) {
List<DailyTaskVo> result = new ArrayList<>();
result.add(this.executeDailyTask(DAILY_SIGN, DAILY_SIGN, uid));
result.add(this.executeDailyTask(UP_MIC, UP_MIC, uid));
result.add(this.executeDailyTask(UP_MIC_120, UP_MIC, uid));
result.add(this.executeDailyTask(PLAY_GAME, PLAY_GAME, uid));
result.add(this.executeDailyTask(CHARGE_GOLD_NUM, CHARGE_GOLD_NUM, uid));
result.add(this.executeDailyTask(CHARGE_GOLD_NUM_5, CHARGE_GOLD_NUM, uid));
result.add(this.executeDailyTask(CHARGE_GOLD_NUM_10, CHARGE_GOLD_NUM, uid));
result.add(this.executeDailyTask(ROOM_SEND_GIFT, ROOM_SEND_GIFT, uid));
result.add(this.executeDailyTask(RECV_LUCKY_GIFT, ROOM_SEND_GIFT, uid));
result.add(this.executeDailyTask(RECV_NOMAL_GIFT, ROOM_SEND_GIFT, uid));
result.add(this.executeDailyTask(RECV_NOMAL_GIFT_GOLD, ROOM_SEND_GIFT, uid));
return BusiResult.success(result);
}
}

14
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/annotation/DailyTaskHandlerType.java Normal file
View File

@@ -0,0 +1,14 @@
package com.accompany.business.service.dailytask.annotation;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface DailyTaskHandlerType {
DailyTaskTypeEnum value();
}

67
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/handler/ChargeGoldNumHandler.java Normal file
View File

@@ -0,0 +1,67 @@
package com.accompany.business.service.dailytask.handler;
import com.accompany.business.constant.dailytask.DailyTaskConstant;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.service.dailytask.AbstractDailyTaskHandler;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.vo.DailyTaskVo;
import com.accompany.core.model.Users;
import org.redisson.api.RBucket;
import org.redisson.api.RMap;
import org.redisson.api.RedissonClient;
import org.redisson.client.codec.IntegerCodec;
import org.redisson.client.codec.LongCodec;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.time.Duration;
import java.util.Date;
import static com.accompany.business.constant.dailytask.DailyTaskConstant.RedisKey.charge_gold;
@Component
@DailyTaskHandlerType(DailyTaskTypeEnum.CHARGE_GOLD_NUM)
public class ChargeGoldNumHandler extends AbstractDailyTaskHandler {
@Override
public void executeProgress(DailyProgressContext progressContext) {
Long uid = progressContext.getUid();
Integer partitionId = usersService.getUsersByUid(uid).getPartitionId();
String todayDate = getTodayDate(uid, progressContext.getCreateTime());
RMap<Long, Long> dailyChargeGold = dailyChargeGold(partitionId, todayDate);
Long chargeGold = dailyChargeGold.addAndGet(uid, progressContext.getChargeGoldNum());
dailyChargeGold.expire(Duration.ofDays(EXPIRE_DAY));
chargeGold = chargeGold == null ? 0L : chargeGold;
if (chargeGold > DailyTaskTypeEnum.CHARGE_GOLD_NUM.getReachNum()) {
taskStatus(uid, todayDate, DailyTaskTypeEnum.CHARGE_GOLD_NUM).set(1, Duration.ofDays(EXPIRE_DAY));
}
if (chargeGold > DailyTaskTypeEnum.CHARGE_GOLD_NUM_5.getReachNum()) {
taskStatus(uid, todayDate, DailyTaskTypeEnum.CHARGE_GOLD_NUM_5).set(1, Duration.ofDays(EXPIRE_DAY));
}
if (chargeGold > DailyTaskTypeEnum.CHARGE_GOLD_NUM_10.getReachNum()) {
taskStatus(uid, todayDate, DailyTaskTypeEnum.CHARGE_GOLD_NUM_10).set(1, Duration.ofDays(EXPIRE_DAY));
}
}
@Override
public DailyTaskVo doHandle(DailyTaskContext context) {
DailyTaskTypeEnum taskType = context.getTaskType();
Long uid = context.getUid();
String todayDate = context.getTodayDate();
Long chargeGold = dailyChargeGold(context.getPartitionId(), todayDate).getOrDefault(uid, 0L);
return DailyTaskVo.builder()
.todayDate(todayDate)
.standardValue(taskType.getReachNum())
.reachNum(chargeGold)
.taskType(taskType)
.goldBean(taskType.getReachGoldBean())
.receiveStatus(computeReceiveStatus(uid, todayDate, taskType))
.build();
}
private RMap<Long, Long> dailyChargeGold(Integer partitionId, String todayDate) {
return redissonClient.getMap(charge_gold.getKey(partitionId.toString(), todayDate), IntegerCodec.INSTANCE);
}
}

38
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/handler/DailySignHandler.java Normal file
View File

@@ -0,0 +1,38 @@
package com.accompany.business.service.dailytask.handler;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.service.dailytask.AbstractDailyTaskHandler;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.vo.DailyTaskVo;
import org.springframework.stereotype.Component;
import java.time.Duration;
import java.util.Date;
@Component
@DailyTaskHandlerType(DailyTaskTypeEnum.DAILY_SIGN)
public class DailySignHandler extends AbstractDailyTaskHandler {
@Override
public void executeProgress(DailyProgressContext progressContext) {
Long uid = progressContext.getUid();
String todayDate = getTodayDate(uid, progressContext.getCreateTime());
taskStatus(uid, todayDate, DailyTaskTypeEnum.DAILY_SIGN).set(1, Duration.ofDays(EXPIRE_DAY));
}
@Override
public DailyTaskVo doHandle(DailyTaskContext context) {
DailyTaskTypeEnum taskType = context.getTaskType();
Long uid = context.getUid();
String todayDate = context.getTodayDate();
return DailyTaskVo.builder()
.todayDate(todayDate)
.standardValue(taskType.getReachNum())
.taskType(taskType)
.goldBean(taskType.getReachGoldBean())
.receiveStatus(computeReceiveStatus(uid, todayDate, taskType))
.build();
}
}

58
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/handler/PlayGameHandler.java Normal file
View File

@@ -0,0 +1,58 @@
package com.accompany.business.service.dailytask.handler;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.service.dailytask.AbstractDailyTaskHandler;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.vo.DailyTaskVo;
import org.redisson.api.RBucket;
import org.redisson.api.RSet;
import org.springframework.stereotype.Component;
import java.time.Duration;
import java.util.Date;
import static com.accompany.business.constant.dailytask.DailyTaskConstant.RedisKey.play_game;
@Component
@DailyTaskHandlerType(DailyTaskTypeEnum.PLAY_GAME)
public class PlayGameHandler extends AbstractDailyTaskHandler {
@Override
public void executeProgress(DailyProgressContext progressContext) {
Long uid = progressContext.getUid();
String todayDate = getTodayDate(uid, progressContext.getCreateTime());
RSet<String> playGameCategory = playGameCategory(uid, todayDate);
String gameId = progressContext.getGameId();
if (playGameCategory.contains(gameId)) {
return;
}
playGameCategory.add(gameId);
playGameCategory.expire(Duration.ofDays(EXPIRE_DAY));
int size = playGameCategory.size();
RBucket<Integer> taskStatus = taskStatus(uid, todayDate, DailyTaskTypeEnum.PLAY_GAME);
if (size >= DailyTaskTypeEnum.PLAY_GAME.getReachNum()) {
taskStatus.set(1, Duration.ofDays(EXPIRE_DAY));
}
}
@Override
public DailyTaskVo doHandle(DailyTaskContext context) {
DailyTaskTypeEnum taskType = context.getTaskType();
Long uid = context.getUid();
String todayDate = context.getTodayDate();
return DailyTaskVo.builder()
.todayDate(todayDate)
.reachNum((long)playGameCategory(uid, todayDate).size())
.standardValue(taskType.getReachNum())
.taskType(taskType)
.goldBean(taskType.getReachGoldBean())
.receiveStatus(computeReceiveStatus(uid, todayDate, taskType))
.build();
}
private RSet<String> playGameCategory(Long uid, String todayDate) {
return redissonClient.getSet(play_game.getKey(uid.toString(), todayDate));
}
}

51
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/handler/RecvLuckyGiftHandler.java Normal file
View File

@@ -0,0 +1,51 @@
package com.accompany.business.service.dailytask.handler;
import com.accompany.business.service.gift.GiftSendService;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.service.dailytask.AbstractDailyTaskHandler;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.vo.DailyTaskVo;
import org.redisson.api.RBucket;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.time.Duration;
import java.util.Date;
@Component
@DailyTaskHandlerType(DailyTaskTypeEnum.RECV_LUCKY_GIFT)
public class RecvLuckyGiftHandler extends AbstractDailyTaskHandler {
@Autowired
private GiftSendService giftSendService;
@Override
public void executeProgress(DailyProgressContext progressContext) {
Long uid = progressContext.getUid();
String todayDate = getTodayDate(uid, progressContext.getCreateTime());
RBucket<Integer> taskStatus = taskStatus(uid, todayDate, DailyTaskTypeEnum.RECV_LUCKY_GIFT);
if (taskStatus.isExists()) {
return;
}
boolean luckyGift = giftSendService.isLuckyGift(progressContext.getGiftType());
if (luckyGift) {
taskStatus(uid, todayDate, DailyTaskTypeEnum.RECV_LUCKY_GIFT).set(1, Duration.ofDays(EXPIRE_DAY));
}
}
@Override
public DailyTaskVo doHandle(DailyTaskContext context) {
DailyTaskTypeEnum taskType = context.getTaskType();
Long uid = context.getUid();
String todayDate = context.getTodayDate();
return DailyTaskVo.builder()
.todayDate(todayDate)
.standardValue(taskType.getReachNum())
.taskType(taskType)
.goldBean(taskType.getReachGoldBean())
.receiveStatus(computeReceiveStatus(uid, todayDate, taskType))
.build();
}
}

57
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/handler/RecvNomalGiftGoldHandler.java Normal file
View File

@@ -0,0 +1,57 @@
package com.accompany.business.service.dailytask.handler;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.service.dailytask.AbstractDailyTaskHandler;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.vo.DailyTaskVo;
import org.redisson.api.RBucket;
import org.redisson.api.RMap;
import org.springframework.stereotype.Component;
import java.time.Duration;
import java.util.Date;
import static com.accompany.business.constant.dailytask.DailyTaskConstant.RedisKey.recv_gold_num;
import static com.accompany.business.constant.dailytask.DailyTaskTypeEnum.RECV_NOMAL_GIFT_GOLD;
@Component
@DailyTaskHandlerType(RECV_NOMAL_GIFT_GOLD)
public class RecvNomalGiftGoldHandler extends AbstractDailyTaskHandler {
@Override
public void executeProgress(DailyProgressContext progressContext) {
Long uid = progressContext.getUid();
String todayDate = getTodayDate(uid, progressContext.getCreateTime());
RMap<Long, Long> recvGoldNum = recvGoldNum(progressContext.getPartitiionId(), todayDate);
Long addAndGet = recvGoldNum.addAndGet(uid, progressContext.getRecvGoldNum());
RBucket<Integer> taskStatus = taskStatus(uid, todayDate, RECV_NOMAL_GIFT_GOLD);
if (taskStatus.isExists()) {
return;
}
if (addAndGet != null && addAndGet >= RECV_NOMAL_GIFT_GOLD.getReachNum()) {
taskStatus(uid, todayDate, DailyTaskTypeEnum.RECV_NOMAL_GIFT_GOLD).set(1, Duration.ofDays(EXPIRE_DAY));
}
}
@Override
public DailyTaskVo doHandle(DailyTaskContext context) {
DailyTaskTypeEnum taskType = context.getTaskType();
Long uid = context.getUid();
String todayDate = context.getTodayDate();
RMap<Long, Long> recvGoldNum = recvGoldNum(context.getPartitionId(), todayDate);
return DailyTaskVo.builder()
.todayDate(todayDate)
.reachNum(recvGoldNum.getOrDefault(uid, 0L))
.standardValue(taskType.getReachNum())
.taskType(taskType)
.goldBean(taskType.getReachGoldBean())
.receiveStatus(computeReceiveStatus(uid, todayDate, taskType))
.build();
}
private RMap<Long, Long> recvGoldNum(Integer partitionId, String todayDate) {
return redissonClient.getMap(recv_gold_num.getKey(partitionId.toString(), todayDate));
}
}

52
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/handler/RecvNomalGiftHandler.java Normal file
View File

@@ -0,0 +1,52 @@
package com.accompany.business.service.dailytask.handler;
import com.accompany.business.service.gift.GiftSendService;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.service.dailytask.AbstractDailyTaskHandler;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.vo.DailyTaskVo;
import org.redisson.api.RBucket;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.time.Duration;
import java.util.Date;
@Component
@DailyTaskHandlerType(DailyTaskTypeEnum.RECV_NOMAL_GIFT)
public class RecvNomalGiftHandler extends AbstractDailyTaskHandler {
@Autowired
private GiftSendService giftSendService;
@Override
public void executeProgress(DailyProgressContext progressContext) {
Long uid = progressContext.getUid();
String todayDate = getTodayDate(uid, progressContext.getCreateTime());
RBucket<Integer> taskStatus = taskStatus(uid, todayDate, DailyTaskTypeEnum.RECV_NOMAL_GIFT);
if (taskStatus.isExists()) {
return;
}
boolean luckyGift = giftSendService.isLuckyGift(progressContext.getGiftType());
if (luckyGift) {
return;
}
taskStatus(uid, todayDate, DailyTaskTypeEnum.RECV_NOMAL_GIFT).set(1, Duration.ofDays(EXPIRE_DAY));
}
@Override
public DailyTaskVo doHandle(DailyTaskContext context) {
DailyTaskTypeEnum taskType = context.getTaskType();
Long uid = context.getUid();
String todayDate = context.getTodayDate();
return DailyTaskVo.builder()
.todayDate(todayDate)
.standardValue(taskType.getReachNum())
.taskType(taskType)
.goldBean(taskType.getReachGoldBean())
.receiveStatus(computeReceiveStatus(uid, todayDate, taskType))
.build();
}
}

46
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/handler/RoomSendGiftHandler.java Normal file
View File

@@ -0,0 +1,46 @@
package com.accompany.business.service.dailytask.handler;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.service.dailytask.AbstractDailyTaskHandler;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.vo.DailyTaskVo;
import org.redisson.api.RBucket;
import org.springframework.stereotype.Component;
import java.time.Duration;
import java.util.Date;
@Component
@DailyTaskHandlerType(DailyTaskTypeEnum.ROOM_SEND_GIFT)
public class RoomSendGiftHandler extends AbstractDailyTaskHandler {
@Override
public void executeProgress(DailyProgressContext progressContext) {
Long uid = progressContext.getUid();
String todayDate = getTodayDate(uid, progressContext.getCreateTime());
RBucket<Integer> taskStatus = taskStatus(uid, todayDate, DailyTaskTypeEnum.ROOM_SEND_GIFT);
if (taskStatus.isExists()) {
return;
}
if (progressContext.getRoomUid() == null) {
return;
}
taskStatus(uid, todayDate, DailyTaskTypeEnum.ROOM_SEND_GIFT).set(1, Duration.ofDays(EXPIRE_DAY));
}
@Override
public DailyTaskVo doHandle(DailyTaskContext context) {
DailyTaskTypeEnum taskType = context.getTaskType();
Long uid = context.getUid();
String todayDate = context.getTodayDate();
return DailyTaskVo.builder()
.todayDate(todayDate)
.standardValue(taskType.getReachNum())
.taskType(taskType)
.goldBean(taskType.getReachGoldBean())
.receiveStatus(computeReceiveStatus(uid, todayDate, taskType))
.build();
}
}

25
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/handler/UpMicHandler.java Normal file
View File

@@ -0,0 +1,25 @@
package com.accompany.business.service.dailytask.handler;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.business.service.dailytask.AbstractDailyTaskHandler;
import com.accompany.business.vo.dailytask.DailyTaskContext;
import com.accompany.business.service.dailytask.annotation.DailyTaskHandlerType;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.vo.DailyTaskVo;
import org.springframework.stereotype.Component;
@Component
@DailyTaskHandlerType(DailyTaskTypeEnum.UP_MIC)
public class UpMicHandler extends AbstractDailyTaskHandler {
@Override
public void executeProgress(DailyProgressContext progressContext) {
Long uid = progressContext.getUid();
String todayDate = getTodayDate(uid, progressContext.getCreateTime());
}
@Override
public DailyTaskVo doHandle(DailyTaskContext context) {
// 实现上麦聊天任务逻辑
return null;
}
}

48
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/dailytask/listener/DailyTaskGiftListener.java Normal file
View File

@@ -0,0 +1,48 @@
package com.accompany.business.service.dailytask.listener;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.event.GiftMessageEvent;
import com.accompany.business.message.GiftMessage;
import com.accompany.business.service.dailytask.DailyTaskService;
import com.accompany.business.service.gift.GiftSendRecordService;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.common.constant.Constant;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import java.util.Date;
@Slf4j
@Component
public class DailyTaskGiftListener implements ApplicationListener<GiftMessageEvent> {
@Autowired
private DailyTaskService dailyTaskService;
@Async
@Override
public void onApplicationEvent(GiftMessageEvent event) {
try {
GiftMessage giftMessage = (GiftMessage) event.getSource();
DailyProgressContext dailyProgressContext = DailyProgressContext.builder()
.roomUid(giftMessage.getRoomUid())
.uid(giftMessage.getSendUid())
.recvUid(giftMessage.getRecvUid())
.giftType(giftMessage.getGiftType())
.recvGoldNum(giftMessage.getRealGoldNum())
.createTime(new Date(giftMessage.getMessTime()))
.partitiionId(giftMessage.getPartitionId())
.build();
dailyTaskService.executeProgress(DailyTaskTypeEnum.RECV_LUCKY_GIFT, dailyProgressContext);
dailyTaskService.executeProgress(DailyTaskTypeEnum.RECV_NOMAL_GIFT_GOLD, dailyProgressContext);
dailyTaskService.executeProgress(DailyTaskTypeEnum.RECV_NOMAL_GIFT, dailyProgressContext);
dailyTaskService.executeProgress(DailyTaskTypeEnum.ROOM_SEND_GIFT, dailyProgressContext);
} catch (Exception e) {
log.error("DailyTaskGiftListener:e.getMessage:{}", e.getMessage(), e);
}
}
}

20
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/usergoldbean/UserGoldBeanBillService.java Normal file
View File

@@ -0,0 +1,20 @@
package com.accompany.business.service.usergoldbean;
import com.accompany.business.constant.dailytask.GoldBeanBillType;
import com.accompany.business.model.UserGoldBean;
import com.accompany.business.model.UserGoldBeanBill;
import com.baomidou.mybatisplus.extension.service.IService;
import java.math.BigDecimal;
/**
* 用户金豆账单表 服务类
*
* @author
* @since 2025-05-19
*/
public interface UserGoldBeanBillService extends IService<UserGoldBeanBill> {
int insertBill(Long uid, GoldBeanBillType goldBeanBillType, BigDecimal goldBean, String objId, UserGoldBean afterGoldBean);
}

24
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/usergoldbean/UserGoldBeanService.java Normal file
View File

@@ -0,0 +1,24 @@
package com.accompany.business.service.usergoldbean;
import com.accompany.business.constant.dailytask.GoldBeanBillType;
import com.accompany.business.model.UserGoldBean;
import com.accompany.business.model.UserPurse;
import com.baomidou.mybatisplus.extension.service.IService;
import java.math.BigDecimal;
import java.util.function.Consumer;
/**
* 用户金豆表 服务类
*
* @author
* @since 2025-05-19
*/
public interface UserGoldBeanService extends IService<UserGoldBean> {
UserGoldBean queryUserGoldBean(Long uid);
UserGoldBean addGoldBean(Long uid, BigDecimal goldBean, GoldBeanBillType goldBeanBillType, String objId);
UserGoldBean subGoldBean(Long uid, BigDecimal goldBean, GoldBeanBillType goldBeanBillType, String objId);
}

42
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/usergoldbean/impl/UserGoldBeanBillServiceImpl.java Normal file
View File

@@ -0,0 +1,42 @@
package com.accompany.business.service.usergoldbean.impl;
import com.accompany.business.constant.dailytask.GoldBeanBillType;
import com.accompany.business.model.UserGoldBean;
import com.accompany.business.model.UserGoldBeanBill;
import com.accompany.business.mybatismapper.UserGoldBeanBillMapper;
import com.accompany.business.service.usergoldbean.UserGoldBeanBillService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
import java.util.Date;
/**
* 用户金豆账单表 服务实现类
*
* @author
* @since 2025-05-19
*/
@Service
public class UserGoldBeanBillServiceImpl extends ServiceImpl<UserGoldBeanBillMapper, UserGoldBeanBill> implements UserGoldBeanBillService {
@Override
public int insertBill(Long uid, GoldBeanBillType goldBeanBillType, BigDecimal goldBean, String objId, UserGoldBean afterGoldBean) {
UserGoldBeanBill beanBill = new UserGoldBeanBill();
beanBill.setBillType(goldBeanBillType.getBillType());
beanBill.setType(goldBeanBillType.getType());
beanBill.setUid(uid);
beanBill.setOperateBean(goldBean);
beanBill.setCreateTime(new Date());
beanBill.setUpdateTime(beanBill.getCreateTime());
beanBill.setObjId(objId);
if (goldBeanBillType.getBillType() == 1) {
beanBill.setBeforeBean(afterGoldBean.getGoldBean().add(goldBean));
} else if (goldBeanBillType.getBillType() == 2) {
beanBill.setBeforeBean(afterGoldBean.getGoldBean().subtract(goldBean));
}
beanBill.setAfterBean(afterGoldBean.getGoldBean());
return 0;
}
}

132
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/usergoldbean/impl/UserGoldBeanServiceImpl.java Normal file
View File

@@ -0,0 +1,132 @@
package com.accompany.business.service.usergoldbean.impl;
import com.accompany.business.constant.dailytask.DailyTaskConstant;
import com.accompany.business.constant.dailytask.GoldBeanBillType;
import com.accompany.business.model.UserGoldBean;
import com.accompany.business.mybatismapper.UserGoldBeanMapper;
import com.accompany.business.service.usergoldbean.UserGoldBeanBillService;
import com.accompany.business.service.usergoldbean.UserGoldBeanService;
import com.accompany.common.redis.RedisKey;
import com.accompany.common.status.BusiStatus;
import com.accompany.core.exception.ServiceException;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
import java.util.Date;
import java.util.function.Function;
import static com.accompany.business.constant.dailytask.DailyTaskConstant.RedisKey.lock_user_gold_bean;
import static com.accompany.common.status.BusiStatus.DAILY_GOLDBEANNOTENOUGH;
/**
* 用户金豆表 服务实现类
*
* @author
* @since 2025-05-19
*/
@Slf4j
@Service
public class UserGoldBeanServiceImpl extends ServiceImpl<UserGoldBeanMapper, UserGoldBean> implements UserGoldBeanService {
@Autowired
private RedissonClient redissonClient;
@Autowired
private UserGoldBeanBillService userGoldBeanBillService;
@Override
public UserGoldBean queryUserGoldBean(Long uid) {
UserGoldBean userGoldBean = this.baseMapper.selectById(uid);
if (userGoldBean == null) {
userGoldBean = createUserGoldBean(uid);
}
return userGoldBean;
}
@Override
public UserGoldBean addGoldBean(Long uid, BigDecimal goldBean, GoldBeanBillType goldBeanBillType, String objId) {
if (goldBean.doubleValue() < 0D) {
throw new ServiceException(BusiStatus.PARAMETERILLEGAL);
}
UserGoldBean after = withLock(uid, lock_user_gold_bean, userGoldBean -> {
log.info("addGoldBean 操作前,buss:{},userGoldBean:{}", goldBeanBillType.getDesc(), JSONObject.toJSONString(userGoldBean));
int ret = baseMapper.updateAddGoldBean(uid, goldBean);
boolean result = SqlHelper.retBool(ret);
if (!result) {
throw new ServiceException(BusiStatus.SERVERBUSY);
}
userGoldBean.setGoldBean(userGoldBean.getGoldBean().add(goldBean));
userGoldBean.setUpdateTime(new Date());
log.info("addGoldBean 操作后,buss:{},userGoldBean:{}", goldBeanBillType.getDesc(), JSONObject.toJSONString(userGoldBean));
return userGoldBean;
});
userGoldBeanBillService.insertBill(uid, goldBeanBillType, goldBean, objId, after);
return after;
}
@Override
public UserGoldBean subGoldBean(Long uid, BigDecimal goldBean, GoldBeanBillType goldBeanBillType, String objId) {
if (goldBean.doubleValue() <= 0d) {
throw new ServiceException(BusiStatus.PARAMETERILLEGAL);
}
String desc = goldBeanBillType.getDesc();
UserGoldBean after = withLock(uid, lock_user_gold_bean, userGoldBean -> {
BigDecimal restDiamond = userGoldBean.getGoldBean().subtract(goldBean);
if (restDiamond.doubleValue() < 0d) {
throw new ServiceException(DAILY_GOLDBEANNOTENOUGH);
}
log.info("subGoldBean 操作前,buss:{},userPurse:{}", desc, JSONObject.toJSONString(userGoldBean));
int ret = baseMapper.updateSubGoldBean(uid, goldBean);
boolean result = SqlHelper.retBool(ret);
if (!result) {
throw new ServiceException(BusiStatus.SERVERBUSY);
}
userGoldBean.setGoldBean(restDiamond);
userGoldBean.setUpdateTime(new Date());
log.info("subGoldBean 操作后,buss:{},userPurse:{}", desc, JSONObject.toJSONString(userGoldBean));
return userGoldBean;
});
userGoldBeanBillService.insertBill(uid, goldBeanBillType, goldBean, objId, after);
return after;
}
private UserGoldBean createUserGoldBean(Long uid) {
UserGoldBean userGoldBean = new UserGoldBean();
userGoldBean.setUid(uid);
userGoldBean.setGoldBean(BigDecimal.ZERO);
userGoldBean.setUpdateTime(new Date());
save(userGoldBean);
return userGoldBean;
}
private <R> R withLock(Long uid, DailyTaskConstant.RedisKey redisKey, Function<UserGoldBean, R> function) {
String lockKey = redisKey.getKey(String.valueOf(uid));
RLock lock = redissonClient.getLock(lockKey);
long startTime = System.currentTimeMillis();
try {
lock.lock();
long lockTime = System.currentTimeMillis() - startTime;
log.info("[金豆] uid {} starTime {} lockTime:{} ", uid, startTime, lockTime);
UserGoldBean userGoldBean = this.queryUserGoldBean(uid);
return function.apply(userGoldBean);
} finally {
long finishTime = System.currentTimeMillis() - startTime;
lock.unlock();
long unlockTime = System.currentTimeMillis() - startTime;
log.info("[金豆] uid:{}, starTime {} finishTime:{} unlockTime:{}, ", uid, startTime, finishTime, unlockTime);
}
}
}

5
accompany-business/accompany-business-service/src/main/resources/accompany/sqlmappers/UserGoldBeanBillMapper.xml Normal file
View File

@@ -0,0 +1,5 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.accompany.business.mybatismapper.UserGoldBeanBillMapper">
</mapper>

12
accompany-business/accompany-business-service/src/main/resources/accompany/sqlmappers/UserGoldBeanMapper.xml Normal file
View File

@@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.accompany.business.mybatismapper.UserGoldBeanMapper">
<update id="updateAddGoldBean">
update user_gold_bean set gold_bean = gold_bean + #{goldBean}, update_time=now() where uid=#{uid}
</update>
<update id="updateSubGoldBean">
update user_gold_bean set gold_bean = gold_bean - #{goldBean}, update_time=now() where uid=#{uid}
</update>
</mapper>

39
accompany-business/accompany-business-web/src/main/java/com/accompany/business/controller/activity/dailytask/DailyTaskController.java Normal file
View File

@@ -0,0 +1,39 @@
package com.accompany.business.controller.activity.dailytask;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.service.dailytask.DailyTaskService;
import com.accompany.business.vo.DailyTaskVo;
import com.accompany.common.result.BusiResult;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
import static com.accompany.common.constant.ApplicationConstant.PublicParameters.PUB_UID;
@RestController
@RequestMapping("/daily")
public class DailyTaskController {
@Autowired
private DailyTaskService dailyTaskService;
@ApiOperation(value = "任务列表", httpMethod = "GET")
@GetMapping("/tasks")
public BusiResult<List<DailyTaskVo>> tasks(@RequestHeader(PUB_UID) Long uid) {
return dailyTaskService.tasks(uid);
}
@ApiOperation(value = "领取", httpMethod = "POST")
@ApiImplicitParams({
@ApiImplicitParam(name = "todayDate", value = "列表有传对应字段", required = true, dataType = "string", paramType = "query"),
@ApiImplicitParam(name = "taskType", value = "列表有传对应字段", required = true, dataType = "string", paramType = "query"),
})
@PostMapping("/recv")
public BusiResult<List<DailyTaskVo>> recv(@RequestHeader(PUB_UID) Long uid, String todayDate, DailyTaskTypeEnum taskType) {
return dailyTaskService.executeReceive(taskType, uid, todayDate);
}
}

15
accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GameMsgPushMessageConsumer.java
View File

@@ -1,11 +1,14 @@
package com.accompany.mq.consumer;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.enums.resource.ResourceCodeEnum;
import com.accompany.business.event.miniGame.MiniGameChangeCurrencyEvent;
import com.accompany.business.message.BillMessage;
import com.accompany.business.message.GameMsgMessage;
import com.accompany.business.service.dailytask.DailyTaskService;
import com.accompany.business.service.game.BaseGameMessageService;
import com.accompany.business.service.gift.BillMessageService;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.common.constant.Constant;
import com.accompany.mq.constant.MqConstant;
import com.accompany.mq.listener.AbstractMessageListener;
@@ -26,15 +29,25 @@ public class GameMsgPushMessageConsumer extends AbstractMessageListener<GameMsgM
private BaseGameMessageService baseGameMessageService;
@Autowired
private ApplicationContext applicationContext;
@Autowired
private DailyTaskService dailyTaskService;
@Override
public void onMessage(GameMsgMessage gameMsgMessage) {
log.info("onMessage gameMsgMessage: {}", gameMsgMessage.toString());
String gameId = gameMsgMessage.getGameId();
Long uid = gameMsgMessage.getUid();
if (gameMsgMessage.getPushScreen()) {
baseGameMessageService.sendGameMessage(gameMsgMessage.getGameId(), gameMsgMessage.getRoomUid(), gameMsgMessage.getUid(), Math.abs(gameMsgMessage.getCoin()),
baseGameMessageService.sendGameMessage(gameId, gameMsgMessage.getRoomUid(), uid, Math.abs(gameMsgMessage.getCoin()),
gameMsgMessage.getResourceCodeEnum(), gameMsgMessage.getConfigId());
}
applicationContext.publishEvent(new MiniGameChangeCurrencyEvent(gameMsgMessage));
DailyProgressContext progressContext = DailyProgressContext.builder()
.gameId(gameMsgMessage.getResourceCodeEnum().name() + gameId)
.uid(uid)
.createTime(gameMsgMessage.getCreateTime())
.build();
dailyTaskService.executeProgress(DailyTaskTypeEnum.PLAY_GAME, progressContext);
}
}