package com.xzx.gc.order.service;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.text.StrBuilder;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.UserEnum;
|
import com.xzx.gc.common.utils.BusinessUtil;
|
import com.xzx.gc.common.utils.StringUtils;
|
import com.xzx.gc.entity.OtherUserInfo;
|
import com.xzx.gc.entity.RebateRule;
|
import com.xzx.gc.entity.RedPaperRule;
|
import com.xzx.gc.entity.UserInfo;
|
import com.xzx.gc.order.dto.RuleDto;
|
import com.xzx.gc.order.mapper.OrderMapper;
|
import com.xzx.gc.order.mapper.RebateRuleMapper;
|
import com.xzx.gc.order.mapper.UserMapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Comparator;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@Service
|
@Transactional
|
@Slf4j
|
public class RuleService {
|
|
@Autowired
|
private RedPaperRuleService redPaperRuleService;
|
|
@Autowired
|
private OrderService orderService;
|
|
@Autowired
|
private RebateRuleService rebateRuleService;
|
|
|
@Autowired
|
private OtherUserService otherUserService;
|
|
@Autowired
|
private UserService userService;
|
/**
|
* 查询用户重量返利
|
* @param userId
|
* @param checkFlag 检查参与用户是平台用户则弃掉
|
* @return
|
*/
|
public RuleDto findWeightRebate(String userId,boolean checkFlag,String partnerId){
|
RuleDto ruleDto = new RuleDto();
|
if(checkFlag){
|
UserInfo byId = userService.findById(userId);
|
if(byId!=null){
|
String mobilePhone = byId.getMobilePhone();
|
List<OtherUserInfo> byMobile = otherUserService.findByMobile(mobilePhone);
|
if(CollUtil.isNotEmpty(byMobile)) {
|
return ruleDto;
|
}
|
}
|
}
|
RedPaperRule one = redPaperRuleService.getOne(UserEnum.重量返利规则.getValue(),partnerId);
|
if (one != null) {
|
ruleDto.setRuleId(one.getId());
|
String s = changeProductType(one.getProductType());
|
ruleDto.setProductType(s);
|
List<RebateRule> rebateRules = rebateRuleService.findByRuleId(one.getId());
|
ruleDto.setRebateRules(rebateRules);
|
} else {
|
log.warn("重量返利规则不存在");
|
}
|
return ruleDto;
|
}
|
|
|
/**
|
* 查询用户阶梯返利
|
* @param userId
|
* @return
|
*/
|
public RuleDto findStepRebate(String userId,boolean checkFlag,String partnerId){
|
RuleDto ruleDto=new RuleDto();
|
ruleDto.setScale(UserEnum.无返利.getValue());
|
if(checkFlag){
|
UserInfo byId = userService.findById(userId);
|
if(byId!=null){
|
String mobilePhone = byId.getMobilePhone();
|
List<OtherUserInfo> byMobile = otherUserService.findByMobile(mobilePhone);
|
if(CollUtil.isNotEmpty(byMobile)) {
|
return ruleDto;
|
}
|
}
|
}
|
RedPaperRule one = redPaperRuleService.getOne(UserEnum.阶梯返利规则.getValue(),partnerId);
|
if(one!=null){
|
ruleDto.setRuleId(one.getId());
|
ruleDto.setConversionPerUnit(one.getConversionPerUnit());
|
List<RebateRule> rebateRules = rebateRuleService.findByRuleId(one.getId());
|
String rate=null;
|
String minWeight=null;
|
String minScale=null;
|
if(CollUtil.isNotEmpty(rebateRules)){
|
//sort升序
|
List<RebateRule> collect = rebateRules.stream().sorted(Comparator.comparing(RebateRule::getSort)).collect(Collectors.toList());
|
ruleDto.setRebateRules(collect);
|
ruleDto.setMinScale(collect.get(0).getRate());
|
ruleDto.setMinWeight(collect.get(0).getWeight());
|
//用户以前下单的总重量
|
BigDecimal sumWeight = orderService.findSumWeight(userId,one);
|
ruleDto.setSumWeight(sumWeight);
|
|
//从大到小
|
rebateRules = rebateRules.stream().sorted(Comparator.comparing(RebateRule::getSort).reversed()).collect(Collectors.toList());
|
for (RebateRule rebateRule : rebateRules) {
|
String weight = rebateRule.getWeight();
|
String rate1 = rebateRule.getRate();
|
if(sumWeight.compareTo(Convert.toBigDecimal(weight))>=0){
|
rate = rate1;
|
break;
|
}
|
}
|
}
|
|
if(rate!=null){
|
ruleDto.setScale(rate);
|
}else{
|
//无返利
|
ruleDto.setMinScale(minScale);
|
ruleDto.setMinWeight(minWeight);
|
}
|
}
|
return ruleDto;
|
}
|
|
/**
|
* 获取返利规则阶梯重量及返利
|
* @return
|
*/
|
public List<RebateRule> getRebateRules(RedPaperRule one){
|
List<RebateRule> rebateRules = rebateRuleService.findByRuleId(one.getId());
|
if(CollUtil.isEmpty(rebateRules)) {
|
rebateRules=new ArrayList<>();
|
}
|
return rebateRules;
|
}
|
|
/**
|
* 将类型转换成itemType
|
* @param productType
|
* @return
|
*/
|
public String changeProductType(String productType){
|
String[] split = productType.split(",");
|
StrBuilder strBuilder=StrBuilder.create();
|
for (String s : split) {
|
if("1".equals(s)){
|
strBuilder.append(Constants.PAPER_WASTE_ITEM_TYPE).append(",");
|
}else if("2".equals(s)){
|
strBuilder.append(Constants.PAPER_MIX_ITEM_TYPE).append(",");
|
}
|
}
|
return StringUtils.removeLast(strBuilder, ",");
|
}
|
}
|
