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

幸运25-record-分表

Browse Source
This commit is contained in:
khalil
2025-05-05 21:14:06 +08:00
parent cac74af670
commit eb65f862ea
4 changed files with 35 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
accompany-base/accompany-sharding/accompany-sharding-sdk/src/main/java/com/accompany/sharding/model/Lucky25Record.java
View File

@@ -1,8 +1,31 @@
package com.accompany.sharding.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.util.Date;
@TableName(value = "lucky_25_record")
public class Lucky25Record extends Lucky24Record {
@Data
public class Lucky25Record {
@TableId(type = IdType.AUTO)
private Long id;
private Integer partitionId;
private Long uid;
private Long receiverUid;
private Long roomUid;
private Integer giftId;
private Long giftGoldPrice;
private Integer giftNum;
private Integer poolId;
private Boolean isSupplement;
private Integer drawMultiple;
private Integer afterMultiple;
private Long winGoldNum;
private Date createTime;
private String messId;
}

10
accompany-base/accompany-sharding/accompany-sharding-service/src/main/java/com/accompany/sharding/config/ShardingSphereConfig.java
View File

@@ -148,6 +148,9 @@ public class ShardingSphereConfig {
tableConfigs.add(getShardingTableRuleConfiguration("bravo_record",
"ds.bravo_record_$->{20250320..20250531}",
"create_time", "bravoRecordStrategy"));
tableConfigs.add(getShardingTableRuleConfiguration("lucky_25_record",
"ds.lucky_25_record_$->{20250504..20250531}",
"create_time", "lucky25RecordStrategy"));
Map<String, AlgorithmConfiguration> algorithmsConfigs = new HashMap<>();
@@ -184,6 +187,9 @@ public class ShardingSphereConfig {
//
AlgorithmConfiguration bravoRecordShardingAlgorithm = getBravoRecordShardingAlgorithmConfiguration();
algorithmsConfigs.put("bravoRecordStrategy", bravoRecordShardingAlgorithm);
//
AlgorithmConfiguration lucky25RecordShardingAlgorithm = getLucky25RecordShardingAlgorithmConfiguration();
algorithmsConfigs.put("lucky25RecordStrategy", lucky25RecordShardingAlgorithm);
ShardingRuleConfiguration config = new ShardingRuleConfiguration();
config.setTables(tableConfigs);
@@ -204,6 +210,10 @@ public class ShardingSphereConfig {
return getGiftSendRecordShardingAlgorithmConfiguration();
}
private AlgorithmConfiguration getLucky25RecordShardingAlgorithmConfiguration() {
return getGiftSendRecordShardingAlgorithmConfiguration();
}
private AlgorithmConfiguration getGiftSendRecordShardingAlgorithmConfiguration() {
Properties properties = new Properties();
properties.setProperty("datetime-pattern", DateTimeUtil.DEFAULT_DATETIME_PATTERN);

2
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/Lucky25MqService.java
View File

@@ -127,7 +127,7 @@ public class Lucky25MqService implements InitializingBean {
robotMsgService.pushFollowUser(record.getUid(), record.getReceiverUid(), record.getRoomUid());
}
lucky24SendWeekRankService.updateRank(record);
//lucky24SendWeekRankService.updateRank(record);
// 删除该标识，表示消息已经消费过
statusMap.fastRemove(giftMessage.getMessId());

2
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/lucky/Lucky25RecordService.java
View File

@@ -7,8 +7,6 @@ import com.accompany.common.utils.DateTimeUtil;
import com.accompany.core.exception.ServiceException;
import com.accompany.sharding.mapper.Lucky25RecordMapper;
import com.accompany.sharding.model.Lucky25Record;
import com.accompany.sharding.vo.Lucky24PersonalStat;
import com.accompany.sharding.vo.Lucky24PlatformStat;
import com.accompany.sharding.vo.Lucky25PersonalStat;
import com.accompany.sharding.vo.Lucky25PlatformStat;
import com.alibaba.fastjson.JSON;