package com.xzx.gc.order.service;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.lang.Snowflake;
|
import cn.hutool.core.map.MapUtil;
|
import cn.hutool.core.util.IdUtil;
|
import cn.hutool.core.util.NumberUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.xzx.gc.common.constant.*;
|
import com.xzx.gc.common.exception.RestException;
|
import com.xzx.gc.common.utils.*;
|
import com.xzx.gc.common.utils.ali.SmsUtil;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.JsonResult;
|
import com.xzx.gc.model.admin.*;
|
import com.xzx.gc.model.order.QueryRuleManageDetailDTO;
|
import com.xzx.gc.model.order.SettlePageDTO;
|
import com.xzx.gc.model.order.UpdateRoyaltyRuleDTO;
|
import com.xzx.gc.order.mapper.*;
|
import com.xzx.gc.util.DoubleUtil;
|
import com.xzx.gc.util.SessionUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
@Service
|
@Transactional
|
@Slf4j
|
public class WeightItemPriceService {
|
|
@Autowired
|
private WeightItemPriceMapper weightItemPriceMapper;
|
|
@Autowired
|
private OtherUserService otherUserService;
|
|
@Autowired
|
private SysMessageMapper sysMessageMapper;
|
|
@Autowired
|
private CityPartnerService cityPartnerService;
|
@Autowired
|
private PartnerAccountService partnerAccountService;
|
@Autowired
|
private AccountMapper accountMapper;
|
|
@Autowired
|
private AccountService accountService;
|
|
@Autowired
|
private CityPartnerMapper cityPartnerMapper;
|
|
@Autowired
|
private BusinessUtil businessUtil;
|
|
@Autowired
|
private WeightItemPriceLogMapper weightItemPriceLogMapper;
|
|
@Autowired
|
private RedPaperRuleMapper redPaperRuleMapper;
|
|
@Autowired
|
private PackageGoodsInfoService packageGoodsInfoService;
|
|
@Autowired
|
private RebateWeightPriceMapper rebateWeightPriceMapper;
|
|
@Autowired
|
private RebateWeightPriceLogMapper rebateWeightPriceLogMapper;
|
|
@Autowired
|
private RedPaperRuleService redPaperRuleService;
|
|
@Autowired
|
private IdUtils idUtils;
|
@Autowired
|
private PayInfoMapper payInfoMapper;
|
|
@Autowired
|
private OrderSettleDeductService orderSettleDeductService;
|
|
@Autowired
|
private OrderSettleService orderSettleService;
|
|
@Autowired
|
private SessionUtil sessionUtil;
|
|
|
public void addBatch(List<WeightItemPrice> list) {
|
String now = DateUtil.now();
|
for (WeightItemPrice weightItemPrice : list) {
|
weightItemPrice.setCreateTime(now);
|
//未审核
|
weightItemPrice.setStatus("1");
|
}
|
weightItemPriceMapper.insertList(list);
|
}
|
|
public void updateById(WeightItemPrice weightItemPrice) {
|
weightItemPriceMapper.updateByPrimaryKeySelective(weightItemPrice);
|
}
|
|
/**
|
* 明细列表 不包含异常的且金额>0
|
*
|
* @param dto
|
* @return
|
*/
|
public List<WeightItemPrice> queryRuleManageDetail(QueryRuleManageDetailDTO dto) {
|
//处理时间格式
|
dto.setStartTime(DateUtils.changeTimeBigin(dto.getStartTime()));
|
dto.setEndTime(DateUtils.changeTimeEnd(dto.getEndTime()));
|
List<WeightItemPrice> royaltyList = weightItemPriceMapper.queryWeightItemList(dto);
|
return royaltyList;
|
}
|
|
/**
|
* 结算提成
|
*
|
* @param model
|
*/
|
public void updateRoyaltyRule(UpdateRoyaltyRuleDTO model) {
|
//明细
|
List<WeightItemPrice> weightList = model.getRoyaltyList();
|
if (CollUtil.isEmpty(weightList)) {
|
throw new RestException("未选择任何明细");
|
}
|
|
//总金额
|
BigDecimal sumMoney = BigDecimal.ZERO;
|
//异常金额
|
BigDecimal expeptionMoney = BigDecimal.ZERO;
|
//实际金额
|
BigDecimal money;
|
|
String receiver = model.getReceiver();
|
OtherUserInfo receiverInfo = otherUserService.findById(receiver);
|
String partnerId = receiverInfo.getPartnerId();
|
CityPartner cityPartner = cityPartnerService.findById(Convert.toInt(partnerId));
|
|
RedPaperRule one = redPaperRuleService.findByPackageIdAndRuleType(UserEnum.提成规则.getValue(), weightList.get(0).getPackageId());
|
if (one == null) {
|
throw new RestException("当前打包站提成规则未开启");
|
}
|
for (WeightItemPrice itemModel : weightList) {
|
//更新状态
|
WeightItemPrice weightItemPrice = new WeightItemPrice();
|
weightItemPrice.setId(Convert.toLong(itemModel.getId()));
|
weightItemPrice.setUpdateTime(DateUtil.now());
|
weightItemPrice.setStatus(itemModel.getStatus());
|
updateById(weightItemPrice);
|
|
if (!OrderEnum.异常.getValue().equals(itemModel.getStatus())) {
|
sumMoney = sumMoney.add(new BigDecimal(itemModel.getSettleMoney()));
|
} else {
|
expeptionMoney = expeptionMoney.add(new BigDecimal(itemModel.getSettleMoney()));
|
}
|
}
|
|
//扣除项
|
OrderSettleDeduct orderSettleDeduct = model.getOrderSettleDeduct();
|
BigDecimal deductMoney = BigDecimal.ZERO;
|
if (orderSettleDeduct != null) {
|
deductMoney = NumberUtil.add(Convert.toBigDecimal(orderSettleDeduct.getFrockMoney(), BigDecimal.ZERO), Convert.toBigDecimal(orderSettleDeduct.getHouseMoney(), BigDecimal.ZERO)
|
, Convert.toBigDecimal(orderSettleDeduct.getInsuranceMoney(), BigDecimal.ZERO), Convert.toBigDecimal(orderSettleDeduct.getPowerMoney(), BigDecimal.ZERO),
|
Convert.toBigDecimal(orderSettleDeduct.getVehicleMoney(), BigDecimal.ZERO));
|
money = NumberUtil.sub(sumMoney, deductMoney);
|
} else {
|
money = sumMoney;
|
}
|
|
List<WeightItemPrice> collect = weightList.stream().filter(x -> !x.getStatus().equals(OrderEnum.异常.getValue())).collect(Collectors.toList());
|
if (CollUtil.isNotEmpty(collect)) {
|
|
String startTime = model.getStartTime();
|
String endTime = model.getEndTime();
|
|
|
//按入库时间升序
|
CollUtil.sort(collect, (o1, o2) -> {
|
if (DateUtil.compare(DateUtil.parse(o1.getStorageTime(), DateUtils.DATE_FORMAT_YMD), DateUtil.parse(o2.getStorageTime(), DateUtils.DATE_FORMAT_YMD)) > 0) {
|
return -1;
|
} else if (DateUtil.compare(DateUtil.parse(o1.getStorageTime(), DateUtils.DATE_FORMAT_YMD), DateUtil.parse(o2.getStorageTime(), DateUtils.DATE_FORMAT_YMD)) == 0) {
|
return 0;
|
} else {
|
return 1;
|
}
|
});
|
|
String status = collect.get(0).getStatus();
|
|
if (StrUtil.isBlank(startTime)) {
|
startTime = CollUtil.getFirst(collect).getStorageTime();
|
}
|
|
if (StrUtil.isBlank(endTime)) {
|
endTime = CollUtil.getLast(collect).getStorageTime();
|
}
|
|
startTime = DateUtil.parse(startTime).toString(DateUtils.DATE_FORMAT_YMD);
|
endTime = DateUtil.parse(endTime).toString(DateUtils.DATE_FORMAT_YMD);
|
//新增提成表
|
OrderSettle orderSettle = new OrderSettle();
|
String settleId = idUtils.generate("JS", 9);
|
orderSettle.setId(settleId);
|
orderSettle.setCreateUserId(sessionUtil.getCurrentUser().getId() + "");
|
orderSettle.setUserId(receiver);
|
orderSettle.setSumMoney(sumMoney.toString());
|
orderSettle.setDeductMoney(deductMoney.toString());
|
orderSettle.setMoney(money.toString());
|
orderSettle.setExceptionMoney(expeptionMoney.toString());
|
orderSettle.setTimeList(startTime + "~" + endTime);
|
orderSettle.setStatus(Convert.toShort(status));
|
orderSettleService.add(orderSettle);
|
|
//结算扣款
|
if (orderSettleDeduct != null) {
|
orderSettleDeduct.setSettleId(settleId);
|
orderSettleDeductService.add(orderSettleDeduct);
|
}
|
|
//需要操作环保比
|
if (OrderEnum.已结算并支付.getValue().equals(status)) {
|
|
//回收员加钱
|
AccountInfo accountInfo = accountService.findByUserId(receiver);
|
Map payMap = new HashMap();
|
String payOrderId = idUtils.generate("ZF", 0);
|
payMap.put("payOrderId", payOrderId);
|
payMap.put("createUserId", accountInfo.getUserId());
|
payMap.put("money", money);
|
payMap.put("accountId", accountInfo.getAccountId());
|
payMap.put("payType", PayEnum.提成.getValue());
|
payMap.put("status", PayEnum.已支付.getValue());
|
payMap.put("createTime", DateUtil.now());
|
payInfoMapper.payInfoAdd(payMap);
|
accountService.addOtherUserAccount(accountInfo, CommonEnum.提成.getValue(), payOrderId, money.toString());
|
|
//回收员消息
|
String message = "您已经结算：+" + money + "元，提成单号：" + settleId + ",请注意查收.";
|
sysMessageMapper.insertMessage(message, receiver, "", "1", "提成", DateUtil.now());
|
|
//合伙人扣钱
|
partnerAccountService.addPartnerAccountLog(money.toString(), cityPartner, settleId);
|
String message1 = "您已经结算：-" + money + "元，提成单号：" + settleId + ",请注意检查.";
|
sysMessageMapper.insertMessage(message1, cityPartner.getUserId(), "", "1", "提成", DateUtil.now());
|
}
|
|
//发送提成短信
|
Map<String, String> map = new HashMap<>();
|
map.put("name", receiverInfo.getName());
|
map.put("sumMoney", orderSettle.getSumMoney());
|
map.put("time", orderSettle.getTimeList());
|
map.put("money", orderSettle.getMoney());
|
map.put("insuranceMoney", "0");
|
map.put("vehicleMoney", "0");
|
map.put("frockMoney", "0");
|
map.put("houseMoney", "0");
|
map.put("powerMoney", "0");
|
if (orderSettleDeduct != null) {
|
map.put("insuranceMoney", orderSettleDeduct.getInsuranceMoney());
|
map.put("vehicleMoney", orderSettleDeduct.getVehicleMoney());
|
map.put("frockMoney", orderSettleDeduct.getFrockMoney());
|
map.put("houseMoney", orderSettleDeduct.getHouseMoney());
|
map.put("powerMoney", orderSettleDeduct.getPowerMoney());
|
}
|
String content = StrUtil.format("{name},辛苦了.结算周期:{time},应付款总额:{sumMoney},扣除费用:保险:{insuranceMoney},车辆管理费:{vehicleMoney},工装:{frockMoney},扣除杂项:仓库房租:{houseMoney}仓库电费:{powerMoney},实际付款:{money}", map);
|
SmsUtil.sendPoint(receiverInfo.getMobilePhone(), content);
|
}
|
|
}
|
|
|
/**
|
* 提成列表
|
*
|
* @param model
|
* @return
|
*/
|
public Map<String, Object> queryRoyaltyManage(SettlementModel model) {
|
Map<String, Object> map = new HashMap<>();
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
model.setPartnerIds(partnerIds);
|
model.setStartTime(DateUtils.changeTimeBigin(model.getStartTime()));
|
model.setEndTime(DateUtils.changeTimeEnd(model.getEndTime()));
|
|
PageHelper.startPage(model.getPage(), model.getLimit());
|
List<SettlementModel> list = weightItemPriceMapper.queryRoyaltyManage(model);
|
PageInfo<SettlementModel> pageInfo = new PageInfo<>(list);
|
|
|
//格式化金额
|
for (SettlementModel seModel : list) {
|
QueryRuleManageDetailDTO dto = new QueryRuleManageDetailDTO();
|
dto.setReceiver(seModel.getReceiver());
|
dto.setEndTime(model.getEndTime());
|
dto.setStartTime(model.getStartTime());
|
List<WeightItemPrice> allList = weightItemPriceMapper.queryWeightItemList(dto);
|
List<WeightItemPrice> royaltyList = allList.stream().filter(x -> x.getStatus().equals(OrderEnum.未结算.getValue())).collect(Collectors.toList());
|
seModel.setRoyaltyList(royaltyList);
|
|
|
//已结算
|
BigDecimal settlementMoney = BigDecimal.ZERO;
|
//未结算
|
BigDecimal royaltyMoney = BigDecimal.ZERO;
|
for (WeightItemPrice weightItemPrice : allList) {
|
String status = weightItemPrice.getStatus();
|
String settleMoney = weightItemPrice.getSettleMoney();
|
if (OrderEnum.未结算.getValue().equals(status)) {
|
royaltyMoney = NumberUtil.add(royaltyMoney, Convert.toBigDecimal(settleMoney, BigDecimal.ZERO));
|
} else {
|
settlementMoney = NumberUtil.add(settlementMoney, Convert.toBigDecimal(settleMoney, BigDecimal.ZERO));
|
}
|
|
}
|
|
seModel.setSettlementMoney(DoubleUtil.roundTwo(settlementMoney.toString()));
|
seModel.setRoyaltyMoney(DoubleUtil.roundTwo(royaltyMoney.toString()));
|
}
|
|
map.put("data", list);
|
map.put("count", pageInfo.getTotal());
|
map.put("code", 0);
|
return map;
|
}
|
|
|
/**
|
* 自动结算
|
*/
|
@Scheduled(cron = "${ruleTime}")
|
public void updateSettleMoneyForRule() {
|
if (!SpringUtil.isCloud()) {
|
log.debug("开始定时更新提成金额");
|
List<WeightItemPriceModel> wpList = weightItemPriceMapper.queryWpList();
|
for (WeightItemPriceModel modelWp : wpList) {
|
String packageId = modelWp.getPackageId();
|
RedPaperRule one = redPaperRuleService.findByPackageIdAndRuleType(UserEnum.提成规则.getValue(), packageId);
|
if (one != null) {
|
BigDecimal wpA = new BigDecimal(modelWp.getWeight());
|
BigDecimal rate = new BigDecimal(modelWp.getPackagePrice()).subtract(new BigDecimal(modelWp.getGoodsPrice()));
|
String settleMoney = DoubleUtil.roundTwo(wpA.multiply(rate).toString());
|
//更新未结算的金额
|
WeightItemPrice weightItemPrice = new WeightItemPrice();
|
weightItemPrice.setId(Convert.toLong(modelWp.getId()));
|
weightItemPrice.setSettleMoney(settleMoney);
|
updateById(weightItemPrice);
|
}
|
}
|
log.debug("开始定时更新提成金额完成");
|
}
|
|
}
|
|
|
/**
|
* 添加修改提成规则
|
*
|
* @param model
|
* @return
|
*/
|
public JsonResult addRoyaltyRule(XzxUserRebateRuleModel model) {
|
|
|
//修改
|
if (null != model.getId()) {
|
rebateWeightPriceMapper.deleteByRuleId(model.getId() + "");
|
RedPaperRule rule = new RedPaperRule();
|
rule.setId(model.getId());
|
rule.setDelFlag(Convert.toShort(Constants.DEL_FLAG));
|
redPaperRuleService.update(rule);
|
}else {
|
//新增
|
List<RedPaperRule> redPaperRules = redPaperRuleService.queryRoyalRuleList(model.getPartnerId() + "", model.getPackageId());
|
if(CollUtil.isNotEmpty(redPaperRules)){
|
throw new RestException("当前打包站已存在提成规则");
|
}
|
|
}
|
Integer ruleId = addRule(model);
|
return JsonResult.success(ruleId);
|
}
|
|
private Integer addRule(XzxUserRebateRuleModel model) {
|
//添加
|
RedPaperRule rule = new RedPaperRule();
|
rule.setStartTime(model.getStartTime());
|
rule.setEndTime(model.getEndTime());
|
rule.setRuleName(model.getRuleName());
|
rule.setCreateTime(cn.hutool.core.date.DateUtil.now());
|
rule.setDelFlag((short) 0);
|
rule.setRuleType(UserEnum.提成规则.getValue());
|
rule.setStatus(model.getStatus());
|
rule.setApplicableObject("1");
|
rule.setProductType(model.getProductType());
|
rule.setPackageId(model.getPackageId());
|
rule.setPartnerId(model.getPartnerId());
|
rule.setTiming(model.getTiming());
|
redPaperRuleService.save(rule);
|
List<RebateWeightPriceModel> royaltyRuleList = model.getRoyaltyRuleList();
|
for (RebateWeightPriceModel model1 : royaltyRuleList) {
|
model1.setRuleId(rule.getId() + "");
|
model1.setPackageId(model.getPackageId());
|
//设置分类价格
|
setMoney(model, model1);
|
rebateWeightPriceMapper.addRoyaltyRule(model1);
|
}
|
return rule.getId();
|
}
|
|
private void setMoney(XzxUserRebateRuleModel model, RebateWeightPriceModel model1) {
|
//设置分类价格
|
PackageGoodsInfo byPackageIdAndItemType = packageGoodsInfoService.findByPackageIdAndItemType(model.getPackageId(), model1.getProductType());
|
if (byPackageIdAndItemType == null) {
|
throw new RestException("打包站分类" + BusinessSimpleUtil.getItemTypeName(model1.getProductType()) + "不存在");
|
} else {
|
model1.setMoney(businessUtil.changeMoney(byPackageIdAndItemType.getPutStoragePrice()));
|
}
|
}
|
|
|
public List<OrderSettle> settlePage(SettlePageDTO settlePageDTO) {
|
List<OrderSettle> byUserId = orderSettleService.findByUserId(settlePageDTO.getReceiver());
|
for (OrderSettle orderSettle : byUserId) {
|
OrderSettleDeduct bySettleId = orderSettleDeductService.findBySettleId(orderSettle.getId());
|
orderSettle.setOrderSettleDeduct(bySettleId);
|
}
|
|
return byUserId;
|
}
|
}
|
