package com.xzx.gc.order.service;
|
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.NumberUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.xzx.gc.common.constant.*;
|
import com.xzx.gc.common.utils.BusinessUtil;
|
import com.xzx.gc.common.utils.IdUtils;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.comon.account.AllAcountParamDto;
|
import com.xzx.gc.order.mapper.AccountLogMapper;
|
import com.xzx.gc.order.mapper.OrderMapper;
|
import com.xzx.gc.order.mapper.PayInfoMapper;
|
import com.xzx.gc.order.mapper.SysMessageMapper;
|
import com.xzx.gc.service.BaseAccountService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import tk.mybatis.mapper.entity.Example;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
@Transactional
|
@Slf4j
|
public class ShareRebateService extends BaseAccountService {
|
@Autowired
|
private UserShareService userShareService;
|
@Autowired
|
private UserService userService;
|
@Autowired
|
private BlackWhiteService blackWhiteService;
|
@Autowired
|
private OrderMapper orderMapper;
|
@Autowired
|
private RedPaperRuleService redPaperRuleService;
|
@Autowired
|
private AccountService accountService;
|
@Autowired
|
private BusinessUtil businessUtil;
|
|
@Autowired
|
private PayInfoMapper payInfoMapper;
|
|
@Autowired
|
private PartnerAccountLogService partnerAccountLogService;
|
|
@Autowired
|
private PartnerAccountService partnerAccountService;
|
|
@Autowired
|
private SysMessageMapper sysMessageMapper;
|
|
@Autowired
|
private AccountLogMapper accountLogMapper;
|
|
@Autowired
|
private IdUtils idUtils;
|
|
|
@Override
|
public Object account(AllAcountParamDto allAcountParamDto) {
|
String now = DateUtil.now();
|
RedPaperRule one = redPaperRuleService.getOne(UserEnum.分享分利规则.getValue(), allAcountParamDto.getPartnerId());
|
if (one != null) {
|
BigDecimal moneyDecimal = NumberUtil.toBigDecimal(allAcountParamDto.getMoney());
|
//分享返利
|
UserShareInfo userShareInfo1 = userShareService.findByRegister(allAcountParamDto.getMobile());
|
if (userShareInfo1 != null) {
|
//邀请人手机号码
|
String mobilePhone = userShareInfo1.getMobilePhone();
|
UserInfo userInfo1 = userService.findByMobile(mobilePhone);
|
if (userInfo1 != null) {
|
//邀请人的Id otherUserId为被被邀请人ID
|
allAcountParamDto.setUserId(userInfo1.getUserId());
|
//邀请人是否在白名单 如果不是在白名单则只有被邀请的用户首单才可以分享分利
|
boolean whiteByMobile = blackWhiteService.isWhiteByMobile(OrderEnum.分享.getValue(), mobilePhone, OrderEnum.白名单.getValue());
|
boolean hasMul = false;
|
if (whiteByMobile) {
|
hasMul = true;
|
} else {
|
Example example = new Example(OrderInfo.class);
|
Example.Criteria criteria = example.createCriteria();
|
criteria.andEqualTo("createUserId", allAcountParamDto.getOtherUserId());
|
List<String> list = new ArrayList<>();
|
list.add(OrderEnum.待入库.getValue());
|
list.add(OrderEnum.入库中.getValue());
|
list.add(OrderEnum.完成.getValue());
|
criteria.andIn("orderStatus", list);
|
if (orderMapper.selectCountByExample(example) == 0) {
|
hasMul = true;
|
}
|
}
|
|
//存在返利 执行操作
|
if (hasMul) {
|
AccountInfo accountInfo1 = accountService.findByUserId(userInfo1.getUserId());
|
if (accountInfo1 != null) {
|
BigDecimal div = NumberUtil.div(Convert.toBigDecimal(one.getShareRatio(), new BigDecimal("0")), new BigDecimal("100"));
|
//获取返利金额
|
BigDecimal mul = NumberUtil.mul(moneyDecimal, div);
|
mul = Convert.toBigDecimal(businessUtil.changeMoney(Convert.toStr(mul, "0")));
|
if(mul.compareTo(BigDecimal.ZERO)==0){
|
return null;
|
}
|
BigDecimal rewardMoney = Convert.toBigDecimal(userShareInfo1.getRewardMoney(), Constants.MONEY_INIT);
|
userShareInfo1.setRewardMoney(Convert.toStr(NumberUtil.add(rewardMoney, mul)));
|
userShareService.updateById(userShareInfo1);
|
allAcountParamDto.setMoney(mul);
|
allAcountParamDto.setAccountId(accountInfo1.getAccountId());
|
allAcountParamDto.setMobile(accountInfo1.getAccountName());
|
|
|
log.debug("准备进行分享返利操作:{}", JSONUtil.toJsonPrettyStr(allAcountParamDto));
|
//分享返利 用户加钱 合伙人扣钱
|
PartnerAccountLog partnerAccountLog = new PartnerAccountLog();
|
partnerAccountLog.setPartnerId(allAcountParamDto.getPartnerId());
|
partnerAccountLog.setFlowNo(allAcountParamDto.getFlowNo());
|
partnerAccountLog.setType(OrderEnum.分享返利.getValue());
|
partnerAccountLog.setMoney("-" + allAcountParamDto.getMoney().toString());
|
partnerAccountLog.setRuleId(allAcountParamDto.getRuleId());
|
partnerAccountLogService.add(partnerAccountLog);
|
partnerAccountService.updateReduceMoneyByPartnerId(allAcountParamDto.getPartnerId(), allAcountParamDto.getMoney());
|
|
//消息 环保金明细
|
Map payMap = new HashMap();
|
String payOrderId = idUtils.generate("ZF", 0);
|
payMap.put("payOrderId", payOrderId);
|
payMap.put("orderId", allAcountParamDto.getFlowNo());
|
payMap.put("createUserId", allAcountParamDto.getUserId());
|
payMap.put("money", allAcountParamDto.getMoney());
|
payMap.put("accountId", allAcountParamDto.getAccountId());
|
payMap.put("payType", PayEnum.分享返利.getValue());
|
payMap.put("status", PayEnum.已支付.getValue());
|
payMap.put("createTime", now);
|
payInfoMapper.payInfoAdd(payMap);
|
|
SysMessage sysMessage = new SysMessage();
|
sysMessage.setCreateTime(now);
|
sysMessage.setCreateUserId(allAcountParamDto.getUserId());
|
sysMessage.setFlag(SysEnum.未读.getValue());
|
sysMessage.setMessage("您邀请的好友“" + allAcountParamDto.getMobile() + "”已下单完成,您收到返利" + allAcountParamDto.getMoney().toString() + "元");
|
sysMessage.setMessageSubTypeName("返利");
|
sysMessage.setMessageType(SysEnum.返利.getValue());
|
sysMessage.setUserId(allAcountParamDto.getUserId());
|
sysMessageMapper.insert(sysMessage);
|
|
//用户日志
|
accountService.updateMoneyByUserId(allAcountParamDto.getUserId(), allAcountParamDto.getMoney());
|
AccountLog accountLog = new AccountLog();
|
accountLog.setCreateTime(now);
|
accountLog.setAccountId(allAcountParamDto.getAccountId());
|
accountLog.setCreateUserId(allAcountParamDto.getUserId());
|
accountLog.setChannelType(Convert.toShort(CommonEnum.分享返利操作.getValue()));
|
accountLog.setOldMoney(allAcountParamDto.getMoney().toString());
|
accountLog.setNewMoney(Convert.toStr(NumberUtil.add(Convert.toBigDecimal(accountLog.getOldMoney()), allAcountParamDto.getMoney())));
|
accountLog.setOrderId(payOrderId);
|
accountLogMapper.insertSelective(accountLog);
|
log.debug("分享返利操作已完成：用户：{}，金额：{}",allAcountParamDto.getUserId(), allAcountParamDto.getMoney().toString());
|
}
|
}
|
}
|
}
|
}
|
return null;
|
}
|
}
|
