package cn.lili.modules.distribution.serviceimpl;
|
|
import cn.hutool.json.JSONUtil;
|
import cn.lili.common.utils.CurrencyUtil;
|
import cn.lili.modules.distribution.entity.dos.Distribution;
|
import cn.lili.modules.distribution.entity.dos.DistributionOrder;
|
import cn.lili.modules.distribution.entity.enums.DistributionOrderStatusEnum;
|
import cn.lili.modules.distribution.entity.vos.DistributionOrderSearchParams;
|
import cn.lili.modules.distribution.mapper.DistributionOrderMapper;
|
import cn.lili.modules.distribution.service.DistributionOrderService;
|
import cn.lili.modules.distribution.service.DistributionService;
|
import cn.lili.modules.order.aftersale.entity.dos.AfterSale;
|
import cn.lili.modules.order.order.entity.dos.Order;
|
import cn.lili.modules.order.order.entity.dos.StoreFlow;
|
import cn.lili.modules.order.order.entity.dto.StoreFlowProfitSharingDTO;
|
import cn.lili.modules.order.order.entity.dto.StoreFlowQueryDTO;
|
import cn.lili.modules.order.order.entity.enums.FlowTypeEnum;
|
import cn.lili.modules.order.order.entity.enums.PayStatusEnum;
|
import cn.lili.modules.order.order.service.OrderService;
|
import cn.lili.modules.order.order.service.StoreFlowService;
|
import cn.lili.modules.system.service.SettingService;
|
import cn.lili.mybatis.util.PageUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
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.util.Date;
|
import java.util.List;
|
|
/**
|
* 分销订单接口实现
|
*
|
* @author pikachu
|
* @since 2020-03-14 23:04:56
|
*/
|
@Slf4j
|
@Service
|
public class DistributionOrderServiceImpl extends ServiceImpl<DistributionOrderMapper, DistributionOrder>
|
implements DistributionOrderService {
|
|
/**
|
* 订单
|
*/
|
@Autowired
|
private OrderService orderService;
|
/**
|
* 店铺流水
|
*/
|
@Autowired
|
private StoreFlowService storeFlowService;
|
/**
|
* 分销员
|
*/
|
@Autowired
|
private DistributionService distributionService;
|
|
@Override
|
public IPage<DistributionOrder> getDistributionOrderPage(
|
DistributionOrderSearchParams distributionOrderSearchParams) {
|
return this.page(PageUtil.initPage(distributionOrderSearchParams),
|
distributionOrderSearchParams.queryWrapper());
|
|
}
|
|
/**
|
* 1.查看订单是否为分销订单
|
* 2.查看店铺流水计算分销总佣金
|
* 3.修改分销员的分销总金额、冻结金额
|
*
|
* @param orderSn 订单编号
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void calculationDistribution(String orderSn) {
|
|
//根据订单编号获取订单数据
|
Order order = orderService.getBySn(orderSn);
|
|
//判断是否为分销订单，如果为分销订单则获取分销佣金
|
if (order.getDistributionId() != null) {
|
//根据订单编号获取有分销金额的店铺流水记录
|
List<StoreFlow> storeFlowList = storeFlowService.listStoreFlow(
|
StoreFlowQueryDTO.builder().justDistribution(true).orderSn(orderSn).build());
|
double rebate = 0.0;
|
//循环店铺流水记录判断是否包含分销商品
|
//包含分销商品则进行记录分销订单、计算分销总额
|
for (StoreFlow storeFlow : storeFlowList) {
|
if (storeFlow.getDistributionRebate() == null || storeFlow.getDistributionRebate() == 0) {
|
continue;
|
}
|
rebate = CurrencyUtil.add(rebate, storeFlow.getDistributionRebate());
|
DistributionOrder distributionOrder = new DistributionOrder(storeFlow);
|
distributionOrder.setDistributionId(order.getDistributionId());
|
//分销员信息
|
Distribution distribution = distributionService.getById(order.getDistributionId());
|
distributionOrder.setDistributionName(distribution.getMemberName());
|
|
//添加分销订单
|
this.save(distributionOrder);
|
|
//记录会员的分销总额
|
if (rebate != 0.0) {
|
distributionService.addRebate(rebate, order.getDistributionId(), storeFlow.getFinalPrice());
|
}
|
|
}
|
}
|
|
}
|
|
/**
|
* 1.获取订单判断是否为已付款的分销订单 2.查看店铺流水记录分销佣金 3.修改分销员的分销总金额、可提现金额
|
*
|
* @param orderSn 订单编号
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void cancelOrder(String orderSn) {
|
//根据订单编号获取订单数据
|
Order order = orderService.getBySn(orderSn);
|
|
//判断是否为已付款的分销订单，则获取分销佣金
|
if (order.getDistributionId() != null && order.getPayStatus().equals(PayStatusEnum.PAID.name())) {
|
|
//根据订单编号获取有分销金额的店铺流水记录
|
List<DistributionOrder> distributionOrderList =
|
this.list(new LambdaQueryWrapper<DistributionOrder>().eq(DistributionOrder::getOrderSn, orderSn));
|
|
//如果没有分销定单，则直接返回
|
if (distributionOrderList.isEmpty()) {
|
return;
|
}
|
|
//包含分销商品则进行记录分销订单、计算分销总额
|
for (DistributionOrder distributionOrder : distributionOrderList) {
|
distributionService.subRebate(distributionOrder.getRebate(), order.getDistributionId(), distributionOrder.getSellBackRebate());
|
}
|
}
|
|
//修改分销订单的状态
|
this.update(new LambdaUpdateWrapper<DistributionOrder>().eq(DistributionOrder::getOrderSn, orderSn)
|
.set(DistributionOrder::getDistributionOrderStatus, DistributionOrderStatusEnum.REFUND.name()));
|
|
}
|
@Override
|
public void refundOrder(AfterSale afterSale) {
|
//判断是否为分销订单
|
StoreFlow refundStoreFlow = storeFlowService.queryOne(
|
StoreFlowQueryDTO.builder().justDistribution(true).refundSn(afterSale.getSn()).build());
|
if (refundStoreFlow != null) {
|
//获取收款分销订单
|
DistributionOrder distributionOrder = this.getOne(
|
new LambdaQueryWrapper<DistributionOrder>().eq(DistributionOrder::getOrderItemSn,
|
afterSale.getOrderItemSn()));
|
//分销订单不存在，则直接返回
|
if (distributionOrder == null) {
|
return;
|
}
|
if (distributionOrder.getSellBackRebate() == null) {
|
distributionOrder.setSellBackRebate(refundStoreFlow.getDistributionRebate());
|
} else {
|
distributionOrder.setSellBackRebate(
|
CurrencyUtil.add(distributionOrder.getSellBackRebate(), refundStoreFlow.getDistributionRebate()));
|
}
|
|
distributionOrder.setRebate(CurrencyUtil.sub(distributionOrder.getRebate(), refundStoreFlow.getDistributionRebate()));
|
if (distributionOrder.getRebate() == 0) {
|
distributionOrder.setDistributionOrderStatus(DistributionOrderStatusEnum.REFUND.name());
|
}
|
distributionOrder.setRefundNum(distributionOrder.getRefundNum() + afterSale.getNum());
|
this.updateById(distributionOrder);
|
|
// 修改分销员提成金额
|
if (refundStoreFlow.getDistributionRebate() != 0.0) {
|
distributionService.subRebate(refundStoreFlow.getDistributionRebate(), distributionOrder.getDistributionId(), refundStoreFlow.getFinalPrice());
|
}
|
}
|
}
|
|
@Override
|
public void completeOrder(StoreFlow storeFlow) {
|
if (storeFlow.getFlowType().equals(FlowTypeEnum.PAY.name())
|
&&storeFlow.getDistributionRebate() != null
|
&& storeFlow.getDistributionRebate() != 0) {
|
//获取分账内容
|
StoreFlowProfitSharingDTO storeFlowProfitSharingDTO = JSONUtil.toBean(storeFlow.getProfitSharing(), StoreFlowProfitSharingDTO.class);
|
//获取分销订单
|
DistributionOrder distributionOrder = this.getOne(new LambdaQueryWrapper<DistributionOrder>().eq(DistributionOrder::getOrderItemSn, storeFlow.getOrderItemSn()));
|
//解冻分销金额
|
distributionService.addCanRebate(storeFlowProfitSharingDTO.getDistributionPrice(), distributionOrder.getDistributionId());
|
// 订单完成
|
this.update(new LambdaUpdateWrapper<DistributionOrder>()
|
.eq(DistributionOrder::getId, distributionOrder.getId())
|
.set(DistributionOrder::getDistributionOrderStatus, DistributionOrderStatusEnum.COMPLETE.name()));
|
}
|
}
|
|
|
}
|
