From 2ef4c9581dfa56582e63566aadc112aa9bc6f4a1 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 09 Nov 2021 14:26:52 +0800
Subject: [PATCH] 20211108
---
gc-user/src/main/java/com/xzx/gc/user/service/DistribService.java | 196 +++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 190 insertions(+), 6 deletions(-)
diff --git a/gc-user/src/main/java/com/xzx/gc/user/service/DistribService.java b/gc-user/src/main/java/com/xzx/gc/user/service/DistribService.java
index b46eba3..e435b8d 100644
--- a/gc-user/src/main/java/com/xzx/gc/user/service/DistribService.java
+++ b/gc-user/src/main/java/com/xzx/gc/user/service/DistribService.java
@@ -6,7 +6,9 @@
import cn.hutool.core.date.DateUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
+import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.exception.RestException;
+import com.xzx.gc.common.utils.RedisUtil;
import com.xzx.gc.common.utils.StringUtils;
import com.xzx.gc.entity.*;
import com.xzx.gc.user.dto.*;
@@ -30,6 +32,7 @@
import javax.annotation.Resource;
import java.math.BigDecimal;
+import java.math.RoundingMode;
import java.util.HashMap;
import java.util.List;
@@ -55,6 +58,10 @@
private UserShareInfoMapper userShareInfoMapper;
@Autowired
private SysMessageMapper sysMessageMapper;
+ @Autowired
+ private RedisUtil redisUtil;
+ @Autowired
+ private ScoreDetailsMapper scoreDetailsMapper;
public ViewSettingVo viewSetting(String ruleStr) {
ViewSettingVo viewSettingVo = new ViewSettingVo();
@@ -233,8 +240,7 @@
return data;
}
- public void adddistrib(AdddistribDto model) {
- String id = model.getId();
+ public void adddistrib(String id) {
AccountInfo accountInfo = accountMapper.selectByPrimaryKey(id);
accountInfo.setIsHead(1);
accountMapper.updateByPrimaryKey(accountInfo);
@@ -305,6 +311,9 @@
if(CollUtil.isNotEmpty(orderItemsVos)){
for(OrderItemsVo orderItemsVo : orderItemsVos){
if(ObjectUtil.isNotEmpty(orderItemsVo)){
+ String nickname = orderItemsVo.getNickname();
+ String decode = StringUtils.decode(nickname);
+ orderItemsVo.setNickname(decode);
Long orderId = orderItemsVo.getOrderId();
List<JhyOrderItems> jhyOrderItems = accountMapper.selectOrderById(orderId);
if(CollUtil.isNotEmpty(jhyOrderItems)){
@@ -346,9 +355,9 @@
String decode = StringUtils.decode(nickname);
distribDataListVo.setNickname(decode);
String id = distribDataListVo.getId();
- String kg = accountMapper.selectOrderByHeadUserId(id);
+ String kg = accountMapper.selectOrderByHeadUserId(id,distribDataListDto);
distribDataListVo.setKg(kg);
- String jdsl = accountMapper.selectJDSLByHeadUserId(id);
+ String jdsl = accountMapper.selectJDSLByHeadUserId(id,distribDataListDto);
distribDataListVo.setJdsl(jdsl);
}
}
@@ -380,9 +389,9 @@
String decode = StringUtils.decode(nickname);
distribDataListVo.setNickname(decode);
String id = distribDataListVo.getId();
- String kg = accountMapper.selectOrderByHeadUserId(id);
+ String kg = accountMapper.selectOrderExportByHeadUserId(id,distribDataListDto);
distribDataListVo.setKg(kg);
- String jdsl = accountMapper.selectJDSLByHeadUserId(id);
+ String jdsl = accountMapper.selectJDSLExportByHeadUserId(id,distribDataListDto);
distribDataListVo.setJdsl(jdsl);
}
}
@@ -396,4 +405,179 @@
return data;
}
+ public ViewScoreSettingVo viewScoreSetting(String ruleStr) {
+ ViewScoreSettingVo viewScoreSettingVo = new ViewScoreSettingVo();
+ RedPaperRule redPaperRule = redPaperRuleMapper.selectByRuleName(ruleStr);
+ if(ObjectUtil.isEmpty(redPaperRule)){
+ viewScoreSettingVo.setRegisterScore(0);
+ viewScoreSettingVo.setShareScore(0);
+ viewScoreSettingVo.setShareScoreTime(0);
+ viewScoreSettingVo.setFirstScore(0);
+ viewScoreSettingVo.setStatus((short) 0);
+ }else{
+ String shareRatio = redPaperRule.getShareRatio();
+ if(StrUtil.isNotEmpty(shareRatio)){
+ List<String> shareRatios = StrUtil.split(shareRatio,',',false,false);
+ if(ObjectUtil.isNotEmpty(shareRatios)){
+ viewScoreSettingVo.setId(redPaperRule.getId());
+ viewScoreSettingVo.setRegisterScore(StrUtil.isEmpty(shareRatios.get(0))?0:Integer.parseInt(shareRatios.get(0)));
+ viewScoreSettingVo.setShareScore(StrUtil.isEmpty(shareRatios.get(1))?0:Integer.parseInt(shareRatios.get(1)));
+ viewScoreSettingVo.setShareScoreTime(StrUtil.isEmpty(shareRatios.get(2))?0:Integer.parseInt(shareRatios.get(2)));
+ viewScoreSettingVo.setFirstScore(StrUtil.isEmpty(shareRatios.get(3))?0:Integer.parseInt(shareRatios.get(3)));
+ viewScoreSettingVo.setStatus(redPaperRule.getStatus());
+ }
+ }else{
+ viewScoreSettingVo.setId(redPaperRule.getId());
+ viewScoreSettingVo.setRegisterScore(0);
+ viewScoreSettingVo.setShareScore(0);
+ viewScoreSettingVo.setShareScoreTime(0);
+ viewScoreSettingVo.setFirstScore(0);
+ viewScoreSettingVo.setStatus(redPaperRule.getStatus());
+ }
+ }
+ return viewScoreSettingVo;
+ }
+
+ public void addScoreSetting(UpdateScoreSetting model) {
+ RedPaperRule redPaperRule = new RedPaperRule();
+ StringBuffer stringBuffer = new StringBuffer();
+ int registerScore = ObjectUtil.isEmpty(model.getRegisterScore()) ? 0 : model.getRegisterScore();
+ stringBuffer.append(registerScore+",");
+ int shareScore = ObjectUtil.isEmpty(model.getShareScore()) ? 0 : model.getShareScore();
+ stringBuffer.append(shareScore+",");
+ int shareScoreTime = ObjectUtil.isEmpty(model.getShareScoreTime()) ? 0 : model.getShareScoreTime();
+ stringBuffer.append(shareScoreTime+",");
+ int firstScore = ObjectUtil.isEmpty(model.getFirstScore()) ? 0 : model.getFirstScore();
+ stringBuffer.append(firstScore);
+ redPaperRule.setStatus((short) 0);
+ redPaperRule.setRuleName("积分运行设置");
+ redPaperRule.setRuleType("10");
+ redPaperRule.setSharingProfitType("register_score,share_score,share_score_time,first_score");
+ redPaperRule.setShareRatio(stringBuffer.toString());
+ redPaperRuleMapper.insert(redPaperRule);
+ }
+
+ public void updateScoreSetting(UpdateScoreSetting model) {
+ RedPaperRule redPaperRule = redPaperRuleMapper.selectByPrimaryKey(model.getId());
+ if(ObjectUtil.isNotEmpty(redPaperRule)){
+ StringBuffer stringBuffer = new StringBuffer();
+ int registerScore = ObjectUtil.isEmpty(model.getRegisterScore()) ? 0 : model.getRegisterScore();
+ stringBuffer.append(registerScore+",");
+ int shareScore = ObjectUtil.isEmpty(model.getShareScore()) ? 0 : model.getShareScore();
+ stringBuffer.append(shareScore+",");
+ int shareScoreTime = ObjectUtil.isEmpty(model.getShareScoreTime()) ? 0 : model.getShareScoreTime();
+ stringBuffer.append(shareScoreTime+",");
+ int firstScore = ObjectUtil.isEmpty(model.getFirstScore()) ? 0 : model.getFirstScore();
+ stringBuffer.append(firstScore);
+ redPaperRule.setStatus(model.getStatus());
+ redPaperRule.setSharingProfitType("register_score,share_score,share_score_time,first_score");
+ redPaperRule.setShareRatio(stringBuffer.toString());
+ redPaperRuleMapper.updateByPrimaryKey(redPaperRule);
+ }
+ }
+
+ public void shareToMoments(String userId) {
+ List<RedPaperRule> redPaperRules = redPaperRuleMapper.selectByRuleType("10");
+ if (CollUtil.isEmpty(redPaperRules)) {
+ return;
+ }
+
+ RedPaperRule rule = redPaperRules.get(0);
+ if (rule.getStatus() == 0) {
+ log.info("规则被禁用, 不执行返利");
+ return;
+ }
+
+ String shareTimes = getRuleValue(rule, CommonEnum.朋友圈分享限次.getValue());
+
+ String shareScore = getRuleValue(rule, CommonEnum.朋友圈分享奖励.getValue());
+ String key = "moments:times:" + userId;
+ Integer times = redisUtil.getAsInt("moments:times:" + userId);
+ times = times == null ? 1 : times + 1;
+
+ if (StrUtil.isNotBlank(shareTimes)) {
+ if (times > Integer.parseInt(shareTimes)) {
+ throw new RestException("达到24小时内最大分享次数");
+ }
+
+ if (StrUtil.isBlank(shareScore)) {
+ return;
+ }
+
+ AccountInfo accountInfo = accountMapper.selectOneByUserId(userId);
+ BigDecimal returnScore = new BigDecimal(shareScore);
+ BigDecimal collectScore = StrUtil.isNotBlank(accountInfo.getCollectScore()) ? new BigDecimal(accountInfo.getCollectScore()) : BigDecimal.ZERO;
+ accountInfo.setCollectScore(collectScore.add(returnScore).setScale(0, RoundingMode.DOWN).toString());
+ accountMapper.updateByPrimaryKey(accountInfo);
+
+ ScoreDetails scoreDetails = new ScoreDetails();
+ scoreDetails.setCurrentScore(new BigDecimal(accountInfo.getCollectScore()));
+ scoreDetails.setOriginalScore(collectScore);
+ scoreDetails.setChangeScore(returnScore);
+ scoreDetails.setCreatedTime(new Date());
+ scoreDetails.setType(ScoreDetails.SCORE_TYPE_SHARE_MOMENTS);
+ scoreDetails.setUserId(accountInfo.getUserId());
+ scoreDetailsMapper.insert(scoreDetails);
+
+ SysMessage sysMessage = new SysMessage();
+ sysMessage.setCreateTime(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
+ sysMessage.setCreateUserId(accountInfo.getUserId());
+ sysMessage.setUserId(accountInfo.getUserId());
+ sysMessage.setMessageType("4");
+ sysMessage.setMessageSubTypeName("朋友圈分享");
+ sysMessage.setMessage("朋友圈分享, 积分:" + returnScore);
+ sysMessage.setFlag("2");
+ sysMessageMapper.insert(sysMessage);
+
+ redisUtil.setex(key, times.toString(), 84400);
+ }
+ }
+
+ public void inviteAward(String phone) {
+ AccountInfo accountInfo = accountMapper.selectAccountInfoByPhone(phone);
+
+ List<RedPaperRule> redPaperRules = redPaperRuleMapper.selectByRuleType("10");
+ if (CollUtil.isEmpty(redPaperRules)) {
+ return;
+ }
+
+ RedPaperRule rule = redPaperRules.get(0);
+ String invite = getRuleValue(rule, CommonEnum.邀请奖励.getValue());
+
+ if (StrUtil.isBlank(invite)) {
+ return;
+ }
+
+ BigDecimal returnScore = new BigDecimal(invite);
+ BigDecimal collectScore = StrUtil.isNotBlank(accountInfo.getCollectScore()) ? new BigDecimal(accountInfo.getCollectScore()) : BigDecimal.ZERO;
+ accountInfo.setCollectScore(collectScore.add(returnScore).setScale(0, RoundingMode.DOWN).toString());
+ accountMapper.updateByPrimaryKey(accountInfo);
+
+ ScoreDetails scoreDetails = new ScoreDetails();
+ scoreDetails.setCurrentScore(new BigDecimal(accountInfo.getCollectScore()));
+ scoreDetails.setOriginalScore(collectScore);
+ scoreDetails.setChangeScore(returnScore);
+ scoreDetails.setCreatedTime(new Date());
+ scoreDetails.setType(ScoreDetails.SCORE_TYPE_INVITE);
+ scoreDetails.setUserId(accountInfo.getUserId());
+ scoreDetailsMapper.insert(scoreDetails);
+
+ SysMessage sysMessage = new SysMessage();
+ sysMessage.setCreateTime(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
+ sysMessage.setCreateUserId(accountInfo.getUserId());
+ sysMessage.setUserId(accountInfo.getUserId());
+ sysMessage.setMessageType("4");
+ sysMessage.setMessageSubTypeName("邀请奖励");
+ sysMessage.setMessage("邀请奖励, 积分:" + returnScore);
+ sysMessage.setFlag("2");
+ sysMessageMapper.insert(sysMessage);
+ }
+
+ private String getRuleValue(RedPaperRule redPaperRule, String key) {
+ List<String> rules = StrUtil.split(redPaperRule.getSharingProfitType(), ',');
+ List<String> values = StrUtil.split(redPaperRule.getShareRatio(), ',');
+
+ int i = rules.indexOf(key);
+ return values.get(i);
+ }
}
--
Gitblit v1.9.1