package com.xzx.gc.order.service;
|
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.UserEnum;
|
import com.xzx.gc.common.utils.DateUtils;
|
import com.xzx.gc.common.utils.RedisUtil;
|
import com.xzx.gc.entity.CityPartner;
|
import com.xzx.gc.entity.PackageGoodsInfo;
|
import com.xzx.gc.entity.RebateRule;
|
import com.xzx.gc.entity.RedPaperRule;
|
import com.xzx.gc.model.admin.*;
|
import com.xzx.gc.model.query.XzxUserRedpaperRuleQuery;
|
import com.xzx.gc.order.mapper.*;
|
import com.xzx.gc.util.DoubleUtil;
|
import org.apache.commons.codec.binary.Base64;
|
import org.apache.commons.lang3.StringUtils;
|
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.*;
|
|
@Service
|
@Transactional
|
public class RedPaperRuleService {
|
|
|
@Autowired
|
private RedPaperRuleMapper redPaperRuleMapper;
|
|
@Autowired private RedPaperRuleMapper xzxUserRedpaperRuleDao;
|
|
@Autowired private ConfigMapper configMapper;
|
|
@Autowired
|
private CityPartnerService cityPartnerService;
|
|
@Autowired
|
private RebateRuleMapper rebateRuleMapper;
|
|
@Autowired
|
private PackageGoodsInfoService packageGoodsInfoService;
|
|
@Autowired
|
private RebateWeightPriceMapper rebateWeightPriceMapper;
|
|
|
/**
|
* 红包在规则时间范围内是否有效
|
* @param ruleId
|
* @return
|
*/
|
public boolean isvalid( Integer ruleId ){
|
//是否在规则的时间内
|
RedPaperRule redPaperRule = redPaperRuleMapper.selectByPrimaryKey(ruleId);
|
if(redPaperRule==null||Constants.DEL_FLAG==Convert.toInt(redPaperRule.getDelFlag(),1)||Constants.FAIL.equals(Convert.toStr(redPaperRule.getStatus(),"0"))){
|
return false;
|
}
|
Date startTime = DateUtil.parse(redPaperRule.getStartTime(),DateUtils.DATE_FORMAT_YMD);
|
Date endTime = DateUtil.parse(redPaperRule.getEndTime(),DateUtils.DATE_FORMAT_YMD);
|
boolean in = DateUtil.isIn(DateUtil.parse(DateUtil.today(),DateUtils.DATE_FORMAT_YMD), startTime, endTime);
|
return in;
|
}
|
|
|
/**
|
* 获取当前时间内符合条件的一条规则
|
* @return
|
*/
|
public RedPaperRule getOne(String ruleType,String partnerId){
|
if(StrUtil.isBlank(partnerId)){
|
return null;
|
}
|
return redPaperRuleMapper.getOne(DateUtil.format(new Date(),DateUtils.DATE_FORMAT_YMD),ruleType,partnerId);
|
}
|
|
|
/**
|
* 根据打包站和类型查找
|
* @param ruleType
|
* @param packageId
|
* @return
|
*/
|
public RedPaperRule findByPackageIdAndRuleType(String ruleType,String packageId){
|
RedPaperRule redPaperRule=new RedPaperRule();
|
redPaperRule.setStatus(Convert.toShort(Constants.OPEN_FLAG));
|
redPaperRule.setDelFlag(Convert.toShort(Constants.DEL_NOT_FLAG));
|
redPaperRule.setRuleType(ruleType);
|
redPaperRule.setPackageId(packageId);
|
return redPaperRuleMapper.selectOne(redPaperRule);
|
}
|
|
|
|
|
public Map<String,Object> queryByCondition(XzxUserRedpaperRuleQuery query, String ruleType){
|
PageHelper.startPage(query.getPage(),query.getLimit());
|
List<RedPaperRule> list = xzxUserRedpaperRuleDao.queryByCondition(query);
|
PageInfo<RedPaperRule> pageInfo=new PageInfo<>(list);
|
|
List<XzxUserRedpaperPriceModel> priceList = new ArrayList<>();
|
if(ruleType.equals("3")){
|
for (RedPaperRule rule:list) {
|
if(rule.getPartnerId().equals("-1")){
|
rule.setPartnerName("管理员");
|
|
}
|
XzxUserRedpaperPriceModel model = new XzxUserRedpaperPriceModel(rule);
|
List<RebateRule> rulePriceList =xzxUserRedpaperRuleDao.queryRebateRulePriceList(String.valueOf(rule.getId()));
|
model.setRulePriceList(rulePriceList);
|
model.setApplicableObject(rule.getApplicableObject());
|
//文案文字返回
|
String sharingProfitType = rule.getSharingProfitType();
|
if(sharingProfitType!=null){
|
String[] types = sharingProfitType.split(",");
|
StringBuffer typeDesc = new StringBuffer();
|
String aa="";
|
String demo="";
|
for (String type:types) {
|
String desc =configMapper.queryTypeDesc(type);
|
int a=1;
|
for (RebateRule p:rulePriceList) {
|
if(typeDesc.toString()!=null&&!"".equals(typeDesc.toString())){
|
if(type.equals("REBATE_TWO")){
|
if(a>=2){
|
typeDesc.append(";").append(a+"、"+demo).append(p.getWeight()).append("kg,").append(desc).append(p.getRate()).append("%");
|
}else{
|
typeDesc.append(desc).append(p.getRate()).append("%");
|
}
|
|
}else if(type.equals("REBATE_THREE")){
|
aa=desc;
|
}
|
a=a+1;
|
}else{
|
demo=desc;
|
typeDesc.append(a+"、"+desc).append(p.getWeight()).append("kg,");
|
}
|
|
//break;
|
}
|
|
}
|
|
typeDesc.append(",").append((rulePriceList.size()+1)+"、").append(aa).append(model.getConversionPerUnit()).append("kg");
|
model.setTypeDesc(typeDesc.toString());
|
|
}
|
priceList.add(model);
|
|
}
|
}else if(ruleType.equals("8")){
|
for (RedPaperRule rule:list) {
|
XzxUserRedpaperPriceModel model = new XzxUserRedpaperPriceModel(rule);
|
|
StringBuffer typeDesc = new StringBuffer();
|
BigDecimal radio = new BigDecimal(rule.getShareRatio());
|
BigDecimal showRadio = radio.multiply(new BigDecimal("100"));
|
typeDesc.append("城市合伙人每笔订单成交，总部收取每笔订单回收流水的").append(DoubleUtil.subZeroAndDot(showRadio.toString()));
|
typeDesc.append("%，做为平台服务费。");
|
model.setTypeDesc(typeDesc.toString());
|
model.setShareRatio(showRadio.toString());
|
|
//设置合伙人名字
|
String partnerId = model.getPartnerId();
|
if (StrUtil.isNotBlank(partnerId)) {
|
CityPartner byId = cityPartnerService.findById(Convert.toInt(partnerId));
|
if (byId != null) {
|
model.setPartnerName(byId.getPartnerName());
|
}
|
}
|
priceList.add(model);
|
|
}
|
}else{
|
for (RedPaperRule rule:list) {
|
XzxUserRedpaperPriceModel model = new XzxUserRedpaperPriceModel(rule);
|
//文案文字返回
|
String sharingProfitType = rule.getSharingProfitType();
|
model.setApplicableObject(rule.getApplicableObject());
|
if(ruleType.equals("2")){
|
if(sharingProfitType!=null){
|
String[] types = sharingProfitType.split(",");
|
StringBuffer typeDesc = new StringBuffer();
|
for (String type:types) {
|
String desc =configMapper.queryTypeDesc(type);
|
if(typeDesc.toString()!=null&&!"".equals(typeDesc.toString())){
|
typeDesc.append(",").append(desc);
|
}else{
|
if(type.equals("SHARE_RATIO")){
|
typeDesc.append(desc).append(model.getShareRatio()).append("%");
|
}else{
|
typeDesc.append(desc);
|
}
|
}
|
}
|
model.setTypeDesc(typeDesc.toString());
|
}
|
}else{
|
if(ruleType.equals("5")){
|
StringBuffer str = new StringBuffer();
|
List<RebateRule> wl = rebateRuleMapper.queryWtList(rule.getId()+"");
|
model.setProductType(rule.getProductType());
|
String[] types = rule.getProductType().split(",");
|
List<RebateRule> rulePriceList = new ArrayList<>();
|
for (int i=0;i<wl.size();i++) {
|
RebateRule ww = wl.get(i);
|
rulePriceList.add(ww);
|
str.append(i+1).append("、用户每次下单超过").append(ww.getWeight()).append("kg,返利").append(ww.getRate().split(",")[0]+"%;");
|
}
|
model.setRulePriceList(rulePriceList);
|
str.append((wl.size()+1));
|
str.append("、适用物品包括：");
|
for (String t:types) {
|
if(t.equals("1")){
|
str.append("废纸").append(",");
|
}else if(t.equals("2")){
|
str.append("杂纸").append(",");
|
}
|
}
|
model.setTypeDesc(str.toString());
|
}else if(ruleType.equals(UserEnum.提成规则.getValue())){
|
StringBuffer str = new StringBuffer();
|
String packageId = rule.getPackageId();
|
CityPartner partner =cityPartnerService.queryById(packageId);
|
str.append(partner.getPartnerName()).append("的发放规则");
|
str.append("1、回收员每次成交，合伙人给回收员发放提成，提成为");
|
List<RebateWeightPriceModel> itemList = rebateWeightPriceMapper.queryOldItemList(rule.getId()+"");
|
for (RebateWeightPriceModel mm:itemList) {
|
PackageGoodsInfo packageGoodsInfo = packageGoodsInfoService.findByPackageIdAndItemTypeForBidden(mm.getPackageId(), mm.getProductType());
|
String title = packageGoodsInfo.getTitle();
|
mm.setProductName(title);
|
str.append(title).append("：").append(mm.getMoney()).append("元/公斤，");
|
|
}
|
model.setRoyaltyRuleList(itemList);
|
String rType = rule.getProductType();
|
if(null!=rType){
|
String[] itemType = rType.split(",");
|
if(itemType[0].equals("3")){
|
str.append("2、可以人工结算提成；");
|
}
|
if(itemType[0].equals("4")){
|
String timming = rule.getTiming();
|
String[] trs = timming.split(",");
|
str.append("3、每周").append(trs[0]).append(" ").append(trs[1]).append("点系统自动结算提成");
|
}
|
}
|
model.setTypeDesc(str.toString());
|
}else{
|
StringBuffer str = new StringBuffer();
|
if(model.getIssuanceRules().equals("0")){
|
double totald = Double.parseDouble(model.getAmount())*100;
|
long total =new Double(totald).longValue();
|
int count = Integer.parseInt(model.getRedEnvelopesNum());
|
long average = total / count;
|
String[] pri = model.getRandomAmountAverage().split(",");
|
str.append("1、发放金额随机，金额范围为").append(model.getRandomAmountAverage()).append("元；平均为").append(average).append("元");
|
str.append("总额为").append(model.getAmount()).append("元,随机分配；最高").append(pri[1]).append("元/个");
|
}else{
|
str.append("发放固定金额，红包为").append(model.getRandomAmountAverage()).append(",总额为").append(model.getAmount());
|
}
|
model.setTypeDesc(str.toString());
|
}
|
|
}
|
priceList.add(model);
|
|
}
|
}
|
Map<String,Object> map = new HashMap<>();
|
map.put("data",priceList);
|
map.put("pageNumber",pageInfo.getPageNum());
|
map.put("pageSize",pageInfo.getPageSize());
|
map.put("totalPage",pageInfo.getPages());
|
map.put("count",pageInfo.getTotal());
|
//queryListAfter(priceList);
|
|
return map;
|
}
|
|
public void deleteByRuleId(Integer ruleId){
|
xzxUserRedpaperRuleDao.deleteByRuleId(ruleId);
|
}
|
public Map<String,Object> queryRebateList(XzxPlatformCapitalInfoModel model){
|
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
model.setPartnerIds(partnerIds);
|
Map<String,Object> map = new HashMap<>();
|
String mobilePhone = model.getMobilePhone();
|
if(!StringUtils.isEmpty(model.getMobilePhone())){
|
model.setMobilePhone(mobilePhone);
|
model.setNickName(new String(Base64.encodeBase64(mobilePhone.getBytes())));
|
|
}
|
PageHelper.startPage(model.getPage(),model.getLimit());
|
List<XzxPlatformCapitalInfoModel> list = xzxUserRedpaperRuleDao.queryRebateList(model);
|
|
for (XzxPlatformCapitalInfoModel info:list) {
|
if(info.getUserId()!=null&&!"".equals(info.getUserId())){
|
//转昵称
|
String nickName = info.getNickName();
|
if(nickName!=null&&!"".equals(nickName)){
|
nickName = cn.hutool.core.codec.Base64.decodeStr(nickName);
|
}
|
info.setNickName(nickName);
|
//查询用户此单之前的累计重量
|
String afterWeight = "0" ;
|
String userId = info.getUserId();
|
String completeTime = info.getCreateTime();
|
List<String> orderIds = xzxUserRedpaperRuleDao.queryUserOrderIds(completeTime,userId);
|
if(orderIds!=null&&orderIds.size()>0){
|
afterWeight = xzxUserRedpaperRuleDao.queryAfterWeightByOrderIds(orderIds);
|
}
|
info.setAfterWeight(DoubleUtil.roundThree(afterWeight));
|
info.setDesignatedWeight(DoubleUtil.roundThree(info.getDesignatedWeight()));
|
}
|
|
}
|
//如果没有用户Id，则不显示返利列表
|
if(list.size()==0){
|
list = new ArrayList<>();
|
}
|
|
PageInfo<XzxPlatformCapitalInfoModel> pageInfo=new PageInfo<>(list);
|
String totalAmount =xzxUserRedpaperRuleDao.queryTotalAmountByParam(model);
|
|
map.put("data",list);
|
map.put("count",pageInfo.getTotal());
|
map.put("code",0);
|
map.put("orderNum",pageInfo.getTotal());
|
if(null!=totalAmount&&!"".equals(totalAmount)){
|
map.put("totalAmount",DoubleUtil.roundTwo(totalAmount));
|
|
}else{
|
map.put("totalAmount","0");
|
}
|
return map;
|
}
|
|
public List<RedPaperRule> queryRedpaperListStartAndEnd(String startTime,String endTime,String partnerId,Integer id,String ruleType){
|
return xzxUserRedpaperRuleDao.queryRedpaperListStartAndEnd(startTime,endTime,partnerId,id,ruleType);
|
}
|
|
public Map<String,Object> queryAccountList(CommissionModel model){
|
Map<String,Object> map = new HashMap<>();
|
String partnerName = model.getPartnerName();
|
if(!StringUtils.isEmpty(partnerName)){
|
model.setPartnerName(partnerName);
|
model.setMobile(partnerName);
|
}
|
int count = 0;
|
PageHelper.startPage(model.getPage(),model.getLimit());
|
List<CommissionModel> list = xzxUserRedpaperRuleDao.queryAccountList(model);
|
for (CommissionModel cmodel:list) {
|
cmodel.setOrderMoney(DoubleUtil.roundTwo(cmodel.getOrderMoney()));
|
}
|
//已提佣次数
|
map.put("commissionNum",count);
|
//总提佣金额
|
String totalMoney =xzxUserRedpaperRuleDao.queryTotalCommissionMoney(model);
|
if(null!=totalMoney&&!"".equals(totalMoney)){
|
map.put("totalMoney",DoubleUtil.roundTwo(totalMoney));
|
}else{
|
map.put("totalMoney","0.00");
|
}
|
PageInfo<CommissionModel> pageInfo=new PageInfo<>(list);
|
map.put("code",0);
|
map.put("data",pageInfo.getList());
|
map.put("count",pageInfo.getTotal());
|
return map;
|
}
|
|
public List<RedPaperRule> queryRoyalRuleList(String partnerId,String packageId){
|
return xzxUserRedpaperRuleDao.queryRoyalRuleList(partnerId,packageId);
|
}
|
|
public RedPaperRule queryById(Integer id) {
|
return xzxUserRedpaperRuleDao.selectByPrimaryKey(id);
|
}
|
|
public boolean update(RedPaperRule ru) {
|
return xzxUserRedpaperRuleDao.updateByPrimaryKeySelective(ru)>0?true:false;
|
}
|
|
public boolean save(RedPaperRule rule) {
|
return xzxUserRedpaperRuleDao.insertUseGeneratedKeys(rule)>0?true:false;
|
}
|
|
}
|
