package com.mzl.flower.service.payment;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.mzl.flower.config.PyamentV3Configurer;
|
import com.mzl.flower.config.exception.ValidationException;
|
import com.mzl.flower.config.security.SecurityUtils;
|
import com.mzl.flower.constant.Constants;
|
import com.mzl.flower.constant.LockConstants;
|
import com.mzl.flower.dto.request.payment.*;
|
import com.mzl.flower.dto.response.payment.OrderSettlementDTO;
|
import com.mzl.flower.dto.response.payment.OrderSettlementDetailDTO;
|
import com.mzl.flower.dto.response.payment.OrderSettlementListDTO;
|
import com.mzl.flower.entity.flower.FlowerSupplierSaleNum;
|
import com.mzl.flower.entity.partner.Partner;
|
import com.mzl.flower.entity.payment.*;
|
import com.mzl.flower.entity.supplier.Station;
|
import com.mzl.flower.entity.supplier.Supplier;
|
import com.mzl.flower.entity.system.UserWechat;
|
import com.mzl.flower.entity.wallet.WalletBillRecordDO;
|
import com.mzl.flower.entity.wallet.WalletDO;
|
import com.mzl.flower.mapper.flower.FlowerSupplierSaleNumMapper;
|
import com.mzl.flower.mapper.payment.*;
|
import com.mzl.flower.mapper.supplier.StationMapper;
|
import com.mzl.flower.mapper.system.UserWechatMapper;
|
import com.mzl.flower.mapper.wallet.WalletBillRecordDetailMapper;
|
import com.mzl.flower.mapper.wallet.WalletBillRecordMapper;
|
import com.mzl.flower.mapper.wallet.WalletMapper;
|
import com.mzl.flower.service.BaseService;
|
import com.mzl.flower.service.wallet.WalletService;
|
import com.mzl.flower.utils.ExcelExportUtil;
|
import com.mzl.flower.utils.UUIDGenerator;
|
import lombok.extern.slf4j.Slf4j;
|
import org.redisson.api.RLock;
|
import org.redisson.api.RedissonClient;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.ObjectUtils;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.net.URLEncoder;
|
import java.time.LocalDateTime;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
@Slf4j
|
@Service
|
@Transactional
|
public class OrderSettlementService extends BaseService {
|
|
@Autowired
|
private OrderSettlementMapper settlementMapper;
|
|
@Autowired
|
private OrderSettlementDetailMapper settlementDetailMapper;
|
|
@Autowired
|
private OrderMapper orderMapper;
|
|
@Autowired
|
private OrderItemMapper orderItemMapper;
|
|
@Autowired
|
private OrderItemCheckMapper orderItemCheckMapper;
|
|
@Autowired
|
private UserWechatMapper wechatMapper;
|
|
@Autowired
|
private FeeServiceMapper feeServiceMapper;
|
|
@Autowired
|
private OrderItemSalesMapper orderItemSalesMapper;
|
|
@Autowired
|
private StationMapper stationMapper;
|
|
@Autowired
|
private FlowerSupplierSaleNumMapper saleNumMapper;
|
|
@Autowired
|
private UserPaymentV3Service paymentV3Service;
|
|
@Autowired
|
private OrderItemSettlementMapper orderItemSettlementMapper;
|
|
@Autowired
|
private TransferMapper transferMapper;
|
|
@Autowired
|
private TransferDetailMapper transferDetailMapper;
|
|
@Autowired
|
private WalletBillRecordMapper walletBillRecordMapper;
|
|
@Autowired
|
private WalletMapper walletMapper;
|
|
@Autowired
|
private WalletBillRecordDetailMapper walletBillRecordDetailMapper;
|
|
@Autowired
|
private WalletService walletService;
|
|
@Autowired
|
RedissonClient redissonClient;
|
|
public Page<OrderSettlementListDTO> selectSettlementList(Page page, OrderSettlementQueryDTO dto){
|
dto.setStartDate(parseLocalDateTime(dto.getStartDateStr(), true));
|
dto.setEndDate(parseLocalDateTime(dto.getEndDateStr(), false));
|
|
List<OrderSettlementListDTO> ls = settlementMapper.selectSettlementList(page, dto);
|
|
page.setRecords(ls);
|
return page;
|
}
|
|
public OrderSettlementDTO getSettlement(String id){
|
OrderSettlementDTO dto = new OrderSettlementDTO();
|
OrderSettlement settlement = settlementMapper.selectById(id);
|
if(settlement == null){
|
throw new ValidationException("结算单不存在");
|
}
|
BeanUtils.copyProperties(settlement, dto);
|
|
String userName;
|
if(Constants.SETTLEMENT_TYPE.supplier.name().equals(dto.getType())){
|
Supplier s = supplierMapper.selectOne(new QueryWrapper<Supplier>()
|
.eq("user_id", settlement.getUserId()));
|
userName = s.getName();
|
} else {
|
Partner p = partnerMapper.selectOne(new QueryWrapper<Partner>()
|
.eq("user_id", settlement.getUserId()));
|
userName = p.getName();
|
}
|
dto.setUserName(userName);
|
|
List<OrderSettlementDetailDTO> details = settlementDetailMapper.selectSettlementDetailList(id);
|
dto.setDetails(details);
|
|
return dto;
|
}
|
|
public void doSettlementTransfer(String id){
|
OrderSettlement settlement = settlementMapper.selectById(id);
|
if(settlement == null){
|
throw new ValidationException("结算单不存在");
|
}
|
String type = settlement.getType();
|
|
//2024-10-23
|
//供应商新的结算逻辑不结算供应商的钱。
|
if (Constants.SETTLEMENT_TYPE.supplier.name().equals(type)) {
|
throw new ValidationException("供应商不需要手动结算");
|
}
|
String status = settlement.getStatus();
|
if(Constants.SETTLEMENT_STATUS.PROCESSING.name().equals(status)){
|
throw new ValidationException("结算中，不用重复结算");
|
}
|
if(Constants.SETTLEMENT_STATUS.COMPLETED.name().equals(status)){
|
throw new ValidationException("结算成功，不用重复结算");
|
}
|
|
String name = "";
|
if(Constants.SETTLEMENT_TYPE.supplier.name().equals(type)){
|
Supplier s = supplierMapper.selectOne(new QueryWrapper<Supplier>()
|
.eq("user_id", settlement.getUserId()));
|
name = "供应商" + s.getName();
|
} else {
|
Partner p = partnerMapper.selectOne(new QueryWrapper<Partner>()
|
.eq("user_id", settlement.getUserId()));
|
name = "合伙人" + p.getName();
|
}
|
|
UserWechat wechat = wechatMapper.selectOne(new QueryWrapper<UserWechat>()
|
.eq("user_id", settlement.getUserId()));
|
if(wechat == null){
|
String msg = name + "未绑定账号无法结算";
|
log.error(msg);
|
throw new ValidationException(msg);
|
}
|
settlement.setOpenId(wechat.getOpenId());
|
|
LocalDateTime now = LocalDateTime.now();
|
String day = format(now, "yyyy-MM-dd");
|
|
String remarks = name + "账单结算";
|
|
String appId = Constants.SETTLEMENT_TYPE.supplier.name().equals(type)
|
? PyamentV3Configurer.supplier_app_id : PyamentV3Configurer.partner_app_id;
|
|
TransferReqDTO transferReqDTO = new TransferReqDTO();
|
transferReqDTO.setId(UUIDGenerator.getUUID());
|
transferReqDTO.setAppId(appId);
|
transferReqDTO.setName(day + "日" + remarks);
|
transferReqDTO.setRemarks(remarks);
|
|
settlement.setTransferId(transferReqDTO.getId());
|
|
BigDecimal settlementAmount = settlement.getSettlementAmount();
|
if(settlementAmount.doubleValue() > 0) {//结算金额>0时才去转账
|
TransferDetailReqDTO dr = new TransferDetailReqDTO();
|
dr.setId(UUIDGenerator.getUUID());
|
dr.setAmount(settlementAmount.multiply(new BigDecimal(100)).longValue());
|
dr.setOpenId(settlement.getOpenId());
|
dr.setRemarks(remarks);
|
if (settlementAmount.doubleValue() >= 2000) {
|
dr.setUserName(wechat.getRealName());
|
}
|
|
List<TransferDetailReqDTO> details = new ArrayList<>();
|
details.add(dr);
|
|
settlement.setTransferDetailId(dr.getId());
|
|
log.info("发起转账");
|
transferReqDTO.setDetails(details);
|
paymentV3Service.doBatchTransfer(transferReqDTO, SecurityUtils.getUserId()); //发起转账
|
}
|
|
settlement.setTransferTime(LocalDateTime.now());
|
settlement.setStatus(Constants.SETTLEMENT_STATUS.PROCESSING.name());
|
settlement.update(SecurityUtils.getUserId());
|
|
settlementMapper.updateById(settlement);
|
}
|
|
public void updateSettlementStatus(String transferId){
|
Transfer t = transferMapper.selectById(transferId);
|
if("FINISHED".equals(t.getStatus())){
|
OrderSettlement settlement = settlementMapper.selectOne(new QueryWrapper<OrderSettlement>()
|
.eq("transfer_id", transferId));
|
if(settlement == null){
|
return;
|
}
|
String transferDetailId = settlement.getTransferDetailId();
|
TransferDetail td = transferDetailMapper.selectById(transferDetailId);
|
if(td == null){
|
log.warn("未找到对应明细");
|
return;
|
}
|
String dStatus = td.getStatus();
|
if("SUCCESS".equals(dStatus)){
|
settlement.setStatus(Constants.SETTLEMENT_STATUS.COMPLETED.name());
|
settlement.update("sys");
|
settlementMapper.updateById(settlement);
|
} else if ("FAIL".equals(dStatus)){
|
settlement.setStatus(Constants.SETTLEMENT_STATUS.FAILED.name());
|
settlement.update("sys");
|
settlementMapper.updateById(settlement);
|
}
|
}
|
}
|
|
public void doSettlement(){//弃用
|
//结算完成收货的订单
|
List<Order> ls = orderMapper.getOrderForSettlement();
|
if(ls == null || ls.size() == 0){
|
return;
|
}
|
|
List<Station> stations = stationMapper.selectList(null);
|
Map<Long, BigDecimal> stationMap = new HashMap<>();
|
for(Station s : stations){
|
BigDecimal freight = s.getFreight();
|
stationMap.put(s.getId(), freight == null ? new BigDecimal(0) : freight);
|
}
|
|
List<String> orderIdsAll = new ArrayList<>();
|
List<String> orderIdsPartner = new ArrayList<>();
|
Map<String, Order> orderMap = new HashMap<>();
|
Set<Long> partnerIds = new HashSet<>();
|
for(Order o : ls){
|
String orderId = o.getId();
|
orderIdsAll.add(orderId);
|
orderMap.put(orderId, o);
|
Long partnerId = o.getPartnerId();
|
if(partnerId != null){
|
orderIdsPartner.add(orderId);
|
partnerIds.add(partnerId);
|
}
|
}
|
|
Map<Long, Partner> partnerMap = new HashMap<>();
|
|
if(partnerIds.size() > 0){
|
List<Partner> pLs = partnerMapper.selectBatchIds(partnerIds);
|
for(Partner p : pLs){
|
partnerMap.put(p.getId(), p);
|
}
|
}
|
|
List<OrderItem> orderItems = orderItemMapper.selectList(new QueryWrapper<OrderItem>()
|
.in("order_id", orderIdsAll));
|
List<String> itemIdsAll = new ArrayList<>();
|
Map<String, OrderItem> orderItemMap = new HashMap<>();
|
Map<Long, List<String>> supplierItemMap = new HashMap<>();
|
Map<Long, List<String>> partnerItemMap = new HashMap<>();
|
Set<Long> supplierIds = new HashSet<>();
|
for(OrderItem oi : orderItems){
|
String id = oi.getId();
|
itemIdsAll.add(id);
|
orderItemMap.put(id, oi);
|
if(orderIdsPartner.contains(oi.getOrderId())){
|
Order o = orderMap.get(oi.getOrderId());
|
Long partnerId = o.getPartnerId();
|
List<String> piIds = partnerItemMap.computeIfAbsent(partnerId, k -> new ArrayList<>());
|
piIds.add(id);
|
}
|
Long supplierId = oi.getSupplierId();
|
List<String> siIds = supplierItemMap.computeIfAbsent(supplierId, k -> new ArrayList<>());
|
siIds.add(id);
|
supplierIds.add(supplierId);
|
}
|
|
List<OrderItemCheck> orderItemCheckList = orderItemCheckMapper.selectList(new QueryWrapper<OrderItemCheck>()
|
.in("order_id", orderIdsAll)
|
.eq("audit_status", Constants.CHECK_AUDIT_STATUS.AGREED.name())
|
);
|
Map<String, BigDecimal> replaceMap = new HashMap<>();
|
Map<String, BigDecimal> reduceMap = new HashMap<>();
|
Map<String, BigDecimal> lackSupplierMap = new HashMap<>();
|
Map<String, BigDecimal> lackPartnerMap = new HashMap<>();
|
if(orderItemCheckList != null && orderItemCheckList.size() > 0){
|
for(OrderItemCheck c : orderItemCheckList){
|
String orderItemId = c.getOrderItemId();
|
BigDecimal amount = c.getDeductAmount();
|
String type = c.getType();
|
if(Constants.CHECK_TYPE.reduce.name().equals(type)){
|
BigDecimal ra = reduceMap.get(orderItemId);
|
if(ra == null){
|
ra = new BigDecimal(0);
|
}
|
ra = ra.add(amount);
|
reduceMap.put(orderItemId, ra);
|
} else if(Constants.CHECK_TYPE.lack.name().equals(type)){
|
OrderItem oi = orderItemMap.get(orderItemId);
|
int lackNum = c.getNum() == null ? 0 : c.getNum();
|
BigDecimal lackFeeSupplier = oi.getSupplierPrice().multiply(new BigDecimal(lackNum));
|
BigDecimal ra = lackSupplierMap.get(orderItemId);
|
if(ra == null){
|
ra = new BigDecimal(0);
|
}
|
ra = ra.add(lackFeeSupplier);
|
lackSupplierMap.put(orderItemId, ra);
|
|
BigDecimal lackFeePartner = oi.getMarkupPartner().multiply(new BigDecimal(lackNum));
|
BigDecimal pa = lackPartnerMap.get(orderItemId);
|
if(pa == null){
|
pa = new BigDecimal(0);
|
}
|
pa = pa.add(lackFeePartner);
|
lackPartnerMap.put(orderItemId, pa);
|
} else if(Constants.CHECK_TYPE.replace.name().equals(type)){
|
BigDecimal ra = replaceMap.get(orderItemId);
|
if(ra == null){
|
ra = new BigDecimal(0);
|
}
|
ra = ra.add(amount);
|
replaceMap.put(orderItemId, ra);
|
}
|
}
|
}
|
|
List<Supplier> suppliers = supplierMapper.selectBatchIds(supplierIds);
|
Map<Long, Supplier> supplierMap = new HashMap<>();
|
for(Supplier s : suppliers){
|
supplierMap.put(s.getId(), s);
|
}
|
|
String yearMonth = format(LocalDateTime.now().plusMonths(-1), "yyyy-MM");
|
List<FlowerSupplierSaleNum> saleNumLs = saleNumMapper.selectList(new QueryWrapper<FlowerSupplierSaleNum>()
|
.eq("`year_month`", yearMonth).in("supplier_id", supplierIds));
|
Map<Long, Integer> preMonthNumMap = new HashMap<>();
|
if(saleNumLs != null && saleNumLs.size() > 0){
|
for (FlowerSupplierSaleNum ss : saleNumLs) {
|
preMonthNumMap.put(ss.getSupplierId(), ss.getSaleNum());
|
}
|
}
|
|
List<FeeService> fees = feeServiceMapper.selectList(new QueryWrapper<>());
|
|
//售后结算
|
List<OrderItemSales> sLs = orderItemSalesMapper.selectList(new QueryWrapper<OrderItemSales>()
|
.in("order_item_id", itemIdsAll));
|
Map<String, BigDecimal> supplierSalesMap = new HashMap<>();
|
Map<String, BigDecimal> partnerSalesMap = new HashMap<>();
|
if(sLs != null && sLs.size() > 0){
|
for(OrderItemSales s : sLs){//同一个订单的同一个商品可能会多次理赔
|
prepareSalesAmount(s, supplierSalesMap, partnerSalesMap, null);
|
}
|
}
|
|
LocalDateTime now = LocalDateTime.now();
|
|
for(Long supplierId : supplierItemMap.keySet()){
|
Supplier s = supplierMap.get(supplierId);
|
|
OrderSettlement settlement = new OrderSettlement();
|
settlement.setId(UUIDGenerator.getUUID());
|
settlement.setType(Constants.SETTLEMENT_TYPE.supplier.name());
|
settlement.setUserId(s.getUserId());
|
settlement.setStatus(Constants.SETTLEMENT_STATUS.PENDING.name());
|
|
Integer flowerNum = 0;//商品数量
|
BigDecimal totalAmount = new BigDecimal(0);//交易合计
|
BigDecimal checkFee = new BigDecimal(0);//降级扣款
|
BigDecimal lackFee = new BigDecimal(0);//缺货扣款
|
BigDecimal replaceFee = new BigDecimal(0);//补货扣款
|
BigDecimal stationFee = new BigDecimal(0);//集货站运费
|
BigDecimal salesFee = new BigDecimal(0);//售后理赔
|
|
Set<String> orderIds = new HashSet<>();
|
Set<String> customerIds = new HashSet<>();
|
List<String> itemIds = supplierItemMap.get(supplierId);
|
for(String itemId : itemIds){
|
OrderSettlementDetail detail = new OrderSettlementDetail();
|
detail.setId(UUIDGenerator.getUUID());
|
detail.setSettlementId(settlement.getId());
|
|
OrderItem oi = orderItemMap.get(itemId);
|
|
orderIds.add(oi.getOrderId());
|
customerIds.add(oi.getCreateBy());
|
|
detail.setOrderId(oi.getOrderId());
|
detail.setOrderItemId(itemId);
|
detail.setPrice(oi.getSupplierPrice());
|
detail.setNum(oi.getNum());
|
detail.setTotalAmount(detail.getPrice().multiply(new BigDecimal(detail.getNum())));
|
|
BigDecimal ra = reduceMap.get(itemId);
|
detail.setCheckFee(ra == null ? new BigDecimal(0) : ra);//降级扣款
|
|
BigDecimal la = lackSupplierMap.get(itemId);
|
detail.setLackFee(la == null ? new BigDecimal(0) : la);//缺货扣款
|
|
BigDecimal rpa = replaceMap.get(itemId);
|
detail.setReplaceFee(rpa == null ? new BigDecimal(0) : rpa);//补货扣款
|
|
detail.setStationFee(new BigDecimal(0));
|
Long stationId = oi.getStationId();
|
if(stationId != null) {//集货站运费按每扎算
|
BigDecimal sa = stationMap.get(stationId);
|
if(sa != null){
|
detail.setStationFee(sa.multiply(new BigDecimal(detail.getNum())));
|
}
|
}
|
|
BigDecimal sf = supplierSalesMap.get(itemId);
|
detail.setSalesFee(sf == null ? new BigDecimal(0) : sf);
|
detail.create();
|
settlementDetailMapper.insert(detail);
|
|
flowerNum += oi.getNum();
|
totalAmount = totalAmount.add(detail.getTotalAmount());
|
checkFee = checkFee.add(detail.getCheckFee());
|
lackFee = lackFee.add(detail.getLackFee());
|
replaceFee = replaceFee.add(detail.getReplaceFee());
|
stationFee = stationFee.add(detail.getStationFee());
|
salesFee = salesFee.add(detail.getSalesFee());
|
}
|
|
settlement.setFlowerNum(flowerNum);
|
settlement.setTotalAmount(totalAmount);
|
settlement.setCheckFee(checkFee);
|
settlement.setLackFee(lackFee);
|
settlement.setReplaceFee(replaceFee);
|
settlement.setStationFee(stationFee);
|
settlement.setSalesFee(salesFee);
|
|
Integer orderNum = orderIds.size();//订单数量
|
settlement.setOrderNum(orderNum);
|
|
Integer customerNum = customerIds.size();//买家数量
|
settlement.setCustomerNum(customerNum);
|
|
BigDecimal price = totalAmount.divide(new BigDecimal(flowerNum), 2, RoundingMode.HALF_UP);//结算单价/均价
|
settlement.setPrice(price);
|
|
Integer preNum = preMonthNumMap.get(supplierId);
|
double serviceFeeRate = getServiceFeeRate(fees, preNum);
|
settlement.setServiceFeeRate(serviceFeeRate);
|
|
BigDecimal serviceFee = totalAmount.multiply(new BigDecimal(serviceFeeRate))
|
.divide(new BigDecimal(100), 2, RoundingMode.HALF_UP);//服务费
|
settlement.setServiceFee(serviceFee);
|
|
//供应商结算：商品价格-扣款-理赔-运费-服务费 = 结算金额
|
//扣款包含：降级扣款、缺货扣款和补货扣款
|
BigDecimal settlementAmount = totalAmount.subtract(checkFee).subtract(lackFee).subtract(replaceFee)
|
.subtract(salesFee).subtract(stationFee).subtract(serviceFee);//结算金额
|
if(settlementAmount.doubleValue() < 0){
|
settlementAmount = new BigDecimal(0);
|
}
|
settlement.setSettlementAmount(settlementAmount);
|
settlement.create();
|
|
settlementMapper.insert(settlement);
|
}
|
|
/* ******************************************************************** */
|
for(Long partnerId : partnerItemMap.keySet()){
|
Partner p = partnerMap.get(partnerId);
|
|
OrderSettlement settlement = new OrderSettlement();
|
settlement.setId(UUIDGenerator.getUUID());
|
settlement.setType(Constants.SETTLEMENT_TYPE.partner.name());
|
settlement.setUserId(p.getUserId());
|
settlement.setStatus(Constants.SETTLEMENT_STATUS.PENDING.name());
|
|
Integer flowerNum = 0;//商品数量
|
BigDecimal totalAmount = new BigDecimal(0);//交易合计
|
BigDecimal checkFee = new BigDecimal(0);//降级扣款
|
BigDecimal lackFee = new BigDecimal(0);//缺货扣款
|
BigDecimal replaceFee = new BigDecimal(0);//补货扣款
|
BigDecimal stationFee = new BigDecimal(0);//集货站运费
|
BigDecimal salesFee = new BigDecimal(0);//售后理赔
|
|
Set<String> orderIds = new HashSet<>();
|
Set<String> customerIds = new HashSet<>();
|
List<String> itemIds = partnerItemMap.get(partnerId);
|
for(String itemId : itemIds){
|
OrderSettlementDetail detail = new OrderSettlementDetail();
|
detail.setId(UUIDGenerator.getUUID());
|
detail.setSettlementId(settlement.getId());
|
|
OrderItem oi = orderItemMap.get(itemId);
|
|
orderIds.add(oi.getOrderId());
|
customerIds.add(oi.getCreateBy());
|
|
detail.setOrderId(oi.getOrderId());
|
detail.setOrderItemId(itemId);
|
detail.setPrice(oi.getMarkupPartner());
|
detail.setNum(oi.getNum());
|
detail.setTotalAmount(detail.getPrice().multiply(new BigDecimal(detail.getNum())));
|
detail.setCheckFee(new BigDecimal(0));
|
|
BigDecimal la = lackPartnerMap.get(itemId);
|
detail.setLackFee(la == null ? new BigDecimal(0) : la);//缺货扣款
|
|
detail.setReplaceFee(new BigDecimal(0));
|
detail.setStationFee(new BigDecimal(0));
|
|
BigDecimal sf = partnerSalesMap.get(itemId);
|
detail.setSalesFee(sf == null ? new BigDecimal(0) : sf);
|
detail.create();
|
settlementDetailMapper.insert(detail);
|
|
flowerNum += oi.getNum();
|
totalAmount = totalAmount.add(detail.getTotalAmount());
|
salesFee = salesFee.add(detail.getSalesFee());
|
lackFee = lackFee.add(detail.getLackFee());
|
}
|
|
settlement.setFlowerNum(flowerNum);
|
settlement.setTotalAmount(totalAmount);
|
settlement.setCheckFee(checkFee);
|
settlement.setLackFee(lackFee);
|
settlement.setReplaceFee(replaceFee);
|
settlement.setStationFee(stationFee);
|
settlement.setSalesFee(salesFee);
|
|
Integer orderNum = orderIds.size();//订单数量
|
settlement.setOrderNum(orderNum);
|
|
Integer customerNum = customerIds.size();//买家数量
|
settlement.setCustomerNum(customerNum);
|
|
BigDecimal price = totalAmount.divide(new BigDecimal(flowerNum), 2, RoundingMode.HALF_UP);//结算单价/均价
|
settlement.setPrice(price);
|
|
settlement.setServiceFee(new BigDecimal(0));
|
|
//合伙人结算：合伙人加价-理赔-缺货扣款 = 结算金额
|
BigDecimal settlementAmount = totalAmount.subtract(salesFee).subtract(lackFee);//结算金额
|
if(settlementAmount.doubleValue() < 0){
|
settlementAmount = new BigDecimal(0);
|
}
|
settlement.setSettlementAmount(settlementAmount);
|
settlement.create();
|
|
settlementMapper.insert(settlement);
|
}
|
|
//更新订单状态
|
for(Order o : ls){
|
o.setStatus(Constants.ORDER_STATUS.COMPLETED.name());
|
o.setStatusBackend(Constants.ORDER_STATUS_BACKEND.COMPLETED.name());
|
o.setCompleteTime(now);
|
o.update("sys");
|
orderMapper.updateById(o);
|
}
|
}
|
|
//新的结算，每一笔订单的商品都会独立结算，结算单只是汇总
|
public List<Order> getOrders4Settlement(){
|
//结算完成收货的订单
|
return orderMapper.getOrderForSettlement();
|
}
|
//这2个方法中间需要调用一下 OrderItemSettlementService.saveItemSettlementInfo(List<String> orderIdsAll)，以保证订单结算的准确性
|
public void doSettlementNew(List<Order> ls){
|
if(ls == null || ls.size() == 0){
|
return;
|
}
|
|
List<String> orderIdsAll = new ArrayList<>();
|
List<String> orderIdsPartner = new ArrayList<>();
|
Map<String, Order> orderMap = new HashMap<>();
|
Set<Long> partnerIds = new HashSet<>();
|
for(Order o : ls){
|
String orderId = o.getId();
|
orderIdsAll.add(orderId);
|
orderMap.put(orderId, o);
|
Long partnerId = o.getPartnerId();
|
if(partnerId != null){
|
orderIdsPartner.add(orderId);
|
partnerIds.add(partnerId);
|
}
|
}
|
|
Map<Long, Partner> partnerMap = new HashMap<>();
|
if(partnerIds.size() > 0){
|
List<Partner> pLs = partnerMapper.selectBatchIds(partnerIds);
|
for(Partner p : pLs){
|
partnerMap.put(p.getId(), p);
|
}
|
}
|
|
List<OrderItem> orderItems = orderItemMapper.selectList(new QueryWrapper<OrderItem>()
|
.in("order_id", orderIdsAll));
|
Map<String, OrderItem> orderItemMap = new HashMap<>();
|
Map<Long, List<String>> supplierItemMap = new HashMap<>();
|
Map<Long, List<String>> partnerItemMap = new HashMap<>();
|
Set<Long> supplierIds = new HashSet<>();
|
for(OrderItem oi : orderItems){
|
String id = oi.getId();
|
orderItemMap.put(id, oi);
|
if(orderIdsPartner.contains(oi.getOrderId())){
|
Order o = orderMap.get(oi.getOrderId());
|
Long partnerId = o.getPartnerId();
|
List<String> piIds = partnerItemMap.computeIfAbsent(partnerId, k -> new ArrayList<>());
|
piIds.add(id);
|
}
|
Long supplierId = oi.getSupplierId();
|
List<String> siIds = supplierItemMap.computeIfAbsent(supplierId, k -> new ArrayList<>());
|
siIds.add(id);
|
supplierIds.add(supplierId);
|
}
|
|
List<OrderItemSettlement> orderItemSettlements = orderItemSettlementMapper.selectList(new QueryWrapper<OrderItemSettlement>()
|
.in("order_id", orderIdsAll));
|
Map<String, OrderItemSettlement> orderItemSettlementMap = new HashMap<>();
|
for(OrderItemSettlement ois : orderItemSettlements){
|
orderItemSettlementMap.put(ois.getOrderItemId(), ois);
|
}
|
|
List<Supplier> suppliers = supplierMapper.selectBatchIds(supplierIds);
|
Map<Long, Supplier> supplierMap = new HashMap<>();
|
for(Supplier s : suppliers){
|
supplierMap.put(s.getId(), s);
|
}
|
|
LocalDateTime now = LocalDateTime.now();
|
|
for(Long supplierId : supplierItemMap.keySet()){
|
Supplier s = supplierMap.get(supplierId);
|
|
OrderSettlement settlement = new OrderSettlement();
|
settlement.setId(UUIDGenerator.getUUID());
|
settlement.setType(Constants.SETTLEMENT_TYPE.supplier.name());
|
settlement.setUserId(s.getUserId());
|
settlement.setStatus(Constants.SETTLEMENT_STATUS.PENDING.name());
|
|
Integer flowerNum = 0;//商品数量
|
BigDecimal totalAmount = new BigDecimal(0);//交易合计
|
BigDecimal checkFee = new BigDecimal(0);//降级扣款
|
BigDecimal lackFee = new BigDecimal(0);//缺货扣款
|
BigDecimal replaceFee = new BigDecimal(0);//补货扣款
|
BigDecimal stationFee = new BigDecimal(0);//集货站运费
|
BigDecimal salesFee = new BigDecimal(0);//售后理赔
|
BigDecimal serviceFee = new BigDecimal(0);//服务费
|
double serviceFeeRate = 0d;
|
BigDecimal settlementAmount = new BigDecimal(0);//结算费用
|
|
Set<String> orderIds = new HashSet<>();
|
Set<String> customerIds = new HashSet<>();
|
List<String> itemIds = supplierItemMap.get(supplierId);
|
for(String itemId : itemIds){
|
OrderSettlementDetail detail = new OrderSettlementDetail();
|
detail.setId(UUIDGenerator.getUUID());
|
detail.setSettlementId(settlement.getId());
|
|
OrderItem oi = orderItemMap.get(itemId);
|
OrderItemSettlement ois = orderItemSettlementMap.get(itemId);
|
|
orderIds.add(oi.getOrderId());
|
customerIds.add(oi.getCreateBy());
|
|
detail.setOrderId(oi.getOrderId());
|
detail.setOrderItemId(itemId);
|
detail.setPrice(oi.getSupplierPrice());
|
detail.setNum(oi.getNum());
|
detail.setTotalAmount(detail.getPrice().multiply(new BigDecimal(detail.getNum())));
|
|
detail.setCheckFee(ois.getCheckFee());//降级扣款
|
detail.setLackFee(ois.getLackFeeSupplier());//缺货扣款
|
detail.setReplaceFee(ois.getReplaceFee());//补货扣款
|
|
detail.setStationFee(ois.getStationFee());
|
detail.setSalesFee(ois.getSalesFeeSupplier());
|
detail.create();
|
settlementDetailMapper.insert(detail);
|
|
//2024-10-23
|
//copy信息到t_wallet_bill_record_detail
|
// WalletBillRecordDetail walletBillRecordDetail = new WalletBillRecordDetail();
|
// BeanUtils.copyProperties(detail, walletBillRecordDetail, "id");
|
// walletBillRecordDetail.setBillRecordId(walletBillRecord.getId());
|
// walletBillRecordDetailMapper.insert(walletBillRecordDetail);
|
|
flowerNum += oi.getNum();
|
totalAmount = totalAmount.add(detail.getTotalAmount());
|
checkFee = checkFee.add(detail.getCheckFee());
|
lackFee = lackFee.add(detail.getLackFee());
|
replaceFee = replaceFee.add(detail.getReplaceFee());
|
stationFee = stationFee.add(detail.getStationFee());
|
salesFee = salesFee.add(detail.getSalesFee());
|
serviceFee = serviceFee.add(ois.getServiceFee());
|
serviceFeeRate = ois.getServiceFeeRate();
|
settlementAmount = settlementAmount.add(ois.getIncomeSupplier());
|
WalletDO walletDO = walletService.getOrCreateBySupplierId(supplierId);
|
RLock lock = redissonClient.getLock(String.format(LockConstants.WALLET_ID_KEY, walletDO.getId()));
|
try {
|
if (lock.tryLock(10, 30, TimeUnit.SECONDS)) {
|
try {
|
//2024-10-28 直接保存到walletBillRecord
|
//新增WalletBillRecordDO
|
if(ois.getIncomeSupplier().compareTo(BigDecimal.ZERO) > 0) {
|
WalletBillRecordDO walletBillRecord = new WalletBillRecordDO();
|
walletBillRecord.setId(UUIDGenerator.getUUID());
|
WalletDO walletDOInfo = walletService.getBySupplierId(supplierId);
|
//增加供应商结算金额保存到钱包
|
walletBillRecord.setSupplierId(supplierId);
|
walletBillRecord.setWalletId(walletDOInfo.getId());
|
walletBillRecord.setSettlementId(settlement.getId());
|
walletBillRecord.setOrderItemId(detail.getOrderItemId());
|
//变动金额等于供应商收入
|
walletBillRecord.setTotalAmount(ois.getIncomeSupplier());
|
walletBillRecord.setType(Constants.BILL_CHANGE_TYPE.settlement.name());
|
walletBillRecord.setMethod(Constants.BILL_CHANGE_METHOD.add.name());
|
walletBillRecord.setOriginalAmount(walletDOInfo.getTotalAmount());
|
walletBillRecord.setChangeAmount(ois.getIncomeSupplier());
|
walletBillRecord.setBalance(walletDOInfo.getWithdrawableAmount().add(ois.getIncomeSupplier()));
|
Order order = orderMapper.selectById(detail.getOrderId());
|
if (!ObjectUtils.isEmpty(order)) {
|
walletBillRecord.setRemark("订单完成(订单号" + order.getOrderNo() + ")" + ",获得收入");
|
walletBillRecord.setOrderNo(order.getOrderNo());
|
}
|
//更新钱包
|
//可提现金额=钱包余额=结算金额
|
walletDOInfo.setWithdrawableAmount(walletDOInfo.getWithdrawableAmount().add(ois.getIncomeSupplier()));
|
walletDOInfo.setTotalAmount(walletDOInfo.getWithdrawableAmount());
|
//已结算金额
|
walletDOInfo.setSettledAmount(walletDOInfo.getSettledAmount().add(ois.getIncomeSupplier()));
|
walletMapper.updateById(walletDOInfo);
|
walletBillRecord.create();
|
walletBillRecordMapper.insert(walletBillRecord);
|
}
|
} finally {
|
lock.unlock();
|
}
|
}
|
} catch (InterruptedException e) {
|
throw new RuntimeException(e);
|
}
|
}
|
|
settlement.setFlowerNum(flowerNum);
|
settlement.setTotalAmount(totalAmount);
|
settlement.setCheckFee(checkFee);
|
settlement.setLackFee(lackFee);
|
settlement.setReplaceFee(replaceFee);
|
settlement.setStationFee(stationFee);
|
settlement.setSalesFee(salesFee);
|
|
Integer orderNum = orderIds.size();//订单数量
|
settlement.setOrderNum(orderNum);
|
|
Integer customerNum = customerIds.size();//买家数量
|
settlement.setCustomerNum(customerNum);
|
|
BigDecimal price = totalAmount.divide(new BigDecimal(flowerNum), 2, RoundingMode.HALF_UP);//结算单价/均价
|
settlement.setPrice(price);
|
|
settlement.setServiceFeeRate(serviceFeeRate);
|
settlement.setServiceFee(serviceFee);
|
|
//供应商结算：商品价格-扣款-理赔-运费-服务费 = 结算金额
|
//扣款包含：降级扣款、缺货扣款和补货扣款
|
settlement.setSettlementAmount(settlementAmount);
|
settlement.create();
|
|
//2024-10-23
|
//计算到钱包后订单状态变成已结算
|
//旧逻辑转账的时候才会标记状态为结算中
|
//新逻辑不是立即转账。不走结算后转账逻辑。此时没有转账时间、openID、转账ID、转账明细ID，直接标记结算状态完成，存金额到钱包中
|
settlement.setStatus(Constants.SETTLEMENT_STATUS.COMPLETED.name());
|
settlementMapper.insert(settlement);
|
|
}
|
|
/* ******************************************************************** */
|
for(Long partnerId : partnerItemMap.keySet()){
|
Partner p = partnerMap.get(partnerId);
|
|
OrderSettlement settlement = new OrderSettlement();
|
settlement.setId(UUIDGenerator.getUUID());
|
settlement.setType(Constants.SETTLEMENT_TYPE.partner.name());
|
settlement.setUserId(p.getUserId());
|
settlement.setStatus(Constants.SETTLEMENT_STATUS.PENDING.name());
|
|
Integer flowerNum = 0;//商品数量
|
BigDecimal totalAmount = new BigDecimal(0);//交易合计
|
BigDecimal checkFee = new BigDecimal(0);//降级扣款
|
BigDecimal lackFee = new BigDecimal(0);//缺货扣款
|
BigDecimal replaceFee = new BigDecimal(0);//补货扣款
|
BigDecimal stationFee = new BigDecimal(0);//集货站运费
|
BigDecimal salesFee = new BigDecimal(0);//售后理赔
|
BigDecimal settlementAmount = new BigDecimal(0);//结算费用
|
|
Set<String> orderIds = new HashSet<>();
|
Set<String> customerIds = new HashSet<>();
|
List<String> itemIds = partnerItemMap.get(partnerId);
|
for(String itemId : itemIds){
|
OrderSettlementDetail detail = new OrderSettlementDetail();
|
detail.setId(UUIDGenerator.getUUID());
|
detail.setSettlementId(settlement.getId());
|
|
OrderItem oi = orderItemMap.get(itemId);
|
OrderItemSettlement ois = orderItemSettlementMap.get(itemId);
|
|
orderIds.add(oi.getOrderId());
|
customerIds.add(oi.getCreateBy());
|
|
detail.setOrderId(oi.getOrderId());
|
detail.setOrderItemId(itemId);
|
detail.setPrice(getAmount(oi.getMarkupPartner()));
|
detail.setNum(oi.getNum());
|
detail.setTotalAmount(detail.getPrice().multiply(new BigDecimal(detail.getNum())));
|
detail.setCheckFee(new BigDecimal(0));
|
|
detail.setLackFee(ois.getLackFeePartner());//缺货扣款
|
|
detail.setReplaceFee(new BigDecimal(0));
|
detail.setStationFee(new BigDecimal(0));
|
|
detail.setSalesFee(ois.getSalesFeePartner());
|
detail.create();
|
settlementDetailMapper.insert(detail);
|
|
flowerNum += oi.getNum();
|
totalAmount = totalAmount.add(detail.getTotalAmount());
|
salesFee = salesFee.add(detail.getSalesFee());
|
lackFee = lackFee.add(detail.getLackFee());
|
settlementAmount = settlementAmount.add(ois.getIncomePartner());
|
}
|
|
settlement.setFlowerNum(flowerNum);
|
settlement.setTotalAmount(totalAmount);
|
settlement.setCheckFee(checkFee);
|
settlement.setLackFee(lackFee);
|
settlement.setReplaceFee(replaceFee);
|
settlement.setStationFee(stationFee);
|
settlement.setSalesFee(salesFee);
|
|
Integer orderNum = orderIds.size();//订单数量
|
settlement.setOrderNum(orderNum);
|
|
Integer customerNum = customerIds.size();//买家数量
|
settlement.setCustomerNum(customerNum);
|
|
BigDecimal price = totalAmount.divide(new BigDecimal(flowerNum), 2, RoundingMode.HALF_UP);//结算单价/均价
|
settlement.setPrice(price);
|
|
settlement.setServiceFee(new BigDecimal(0));
|
|
//合伙人结算：合伙人加价-理赔-缺货扣款 = 结算金额
|
settlement.setSettlementAmount(settlementAmount);
|
settlement.create();
|
|
settlementMapper.insert(settlement);
|
}
|
|
//更新订单状态
|
for(Order o : ls){
|
o.setStatus(Constants.ORDER_STATUS.COMPLETED.name());
|
o.setStatusBackend(Constants.ORDER_STATUS_BACKEND.COMPLETED.name());
|
o.setCompleteTime(now);
|
o.update("sys");
|
orderMapper.updateById(o);
|
}
|
}
|
|
public void exportSettlementList(HttpServletResponse response, OrderSettlementQueryDTO dto) {
|
dto.setStartDate(parseLocalDateTime(dto.getStartDateStr(), true));
|
dto.setEndDate(parseLocalDateTime(dto.getEndDateStr(), false));
|
List<OrderSettlementListDTO> ls = settlementMapper.selectSettlementListInfo(null, dto);
|
|
String[] rowsName = new String[]{"序号","结算人", "结算金额(元)", "订单数量", "买家数量", "商品数量", "结算合计(元)", "结算均价(元)", "降级扣款(元)",
|
"缺货扣款(元)", "补货扣款(元)", "售后理赔(元)", "服务费(元)", "集货站运费(元)", "结算类型", "结算状态", "结算时间"};
|
List<Object[]> dataList = new ArrayList<>();
|
int sn = 1;
|
for (OrderSettlementListDTO o : ls) {
|
Object[] objs = new Object[rowsName.length];
|
int a = 0;
|
objs[a++] = sn;
|
objs[a++] = o.getUserName();
|
objs[a++] = o.getSettlementAmount();
|
objs[a++] = o.getOrderNum();
|
objs[a++] = o.getCustomerNum();
|
objs[a++] = o.getFlowerNum();
|
objs[a++] = o.getTotalAmount();
|
objs[a++] = o.getPrice();
|
objs[a++] = o.getCheckFee();
|
objs[a++] = o.getLackFee();
|
objs[a++] = o.getReplaceFee();
|
objs[a++] = o.getSalesFee();
|
objs[a++] = o.getServiceFee();
|
objs[a++] = o.getStationFee();
|
objs[a++] = o.getTypeStr();
|
objs[a++] = o.getStatusStr();
|
objs[a++] = o.getTransferTime();
|
dataList.add(objs);
|
|
sn++;
|
}
|
ExcelExportUtil excelExportUtil = new ExcelExportUtil("结算列表", rowsName, dataList, response);
|
try {
|
response.addHeader("filename", URLEncoder.encode("结算列表.xls", "UTF-8"));
|
response.addHeader("Access-Control-Expose-Headers", "filename");
|
excelExportUtil.export();
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
}
|
|
}
|
}
|
