autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-07-04 22:18:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

交易分账 重构

Browse Source
This commit is contained in:
autumn.g@foxmail.com
2023-08-28 19:48:46 +08:00
parent 5ff4336830
commit 2a5651a42e
2 changed files with 115 additions and 115 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jsowell-pile/src/main/java/com/jsowell/pile/service/IOrderBasicInfoService.java
View File

@@ -303,7 +303,7 @@ public interface IOrderBasicInfoService {
/** /**
* 生成订单日报 * 生成订单日报
*/ */
void generateDailyOrderReports(String stationId, String tradeDate); // void generateDailyOrderReports(String stationId, String tradeDate);
/** /**
* 获取运营商订单列表 * 获取运营商订单列表

228
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java
View File

@@ -2563,120 +2563,120 @@ public class OrderBasicInfoServiceImpl implements IOrderBasicInfoService {
* @param stationId 站点id * @param stationId 站点id
* @param tradeDate 交易日期 * @param tradeDate 交易日期
*/ */
@Override // @Override
public void generateDailyOrderReports(String stationId, String tradeDate) { // public void generateDailyOrderReports(String stationId, String tradeDate) {
// logger.info("线程名===={}", Thread.currentThread().getName()); // // logger.info("线程名===={}", Thread.currentThread().getName());
if (StringUtils.isBlank(stationId)) { // if (StringUtils.isBlank(stationId)) {
return; // return;
} // }
if (StringUtils.isBlank(tradeDate)) { // if (StringUtils.isBlank(tradeDate)) {
// 日期为空默认昨天 // // 日期为空默认昨天
tradeDate = LocalDate.now().plusDays(-1).toString(); // tradeDate = LocalDate.now().plusDays(-1).toString();
} // }
PileStationVO stationInfo = pileStationInfoService.getStationInfo(stationId); // PileStationVO stationInfo = pileStationInfoService.getStationInfo(stationId);
// 查询站点前一天结算完成的订单 // // 查询站点前一天结算完成的订单
QueryOrderDTO dto = new QueryOrderDTO(); // QueryOrderDTO dto = new QueryOrderDTO();
dto.setStationId(stationId); // dto.setStationId(stationId);
LocalDate parse = LocalDate.parse(tradeDate, DateTimeFormatter.ofPattern("yyyy-MM-dd")); // LocalDate parse = LocalDate.parse(tradeDate, DateTimeFormatter.ofPattern("yyyy-MM-dd"));
String startTime = DateUtils.formatDateTime(LocalDateTime.of(parse, LocalTime.MIN)); // String startTime = DateUtils.formatDateTime(LocalDateTime.of(parse, LocalTime.MIN));
String endTime = DateUtils.formatDateTime(LocalDateTime.of(parse, LocalTime.MAX)); // String endTime = DateUtils.formatDateTime(LocalDateTime.of(parse, LocalTime.MAX));
dto.setStartSettleTime(startTime); // dto.setStartSettleTime(startTime);
dto.setEndSettleTime(endTime); // dto.setEndSettleTime(endTime);
// 查询结算完成的订单 // // 查询结算完成的订单
List<OrderListVO> orderListVOS = orderBasicInfoMapper.selectOrderBasicInfoList(dto); // List<OrderListVO> orderListVOS = orderBasicInfoMapper.selectOrderBasicInfoList(dto);
// if (CollectionUtils.isEmpty(orderListVOS)) { // // if (CollectionUtils.isEmpty(orderListVOS)) {
// logger.info("站点:{}, 在{}-{}没有查询到订单数据", stationInfo.getStationName(), startTime, endTime); // // logger.info("站点:{}, 在{}-{}没有查询到订单数据", stationInfo.getStationName(), startTime, endTime);
// return; // // return;
// } // // }
List<String> collect = orderListVOS.stream().map(OrderListVO::getOrderCode).collect(Collectors.toList()); // List<String> collect = orderListVOS.stream().map(OrderListVO::getOrderCode).collect(Collectors.toList());
logger.info("站点:{}, 在{}-{}查询到订单数据{}条，订单编号:{}", stationInfo.getStationName(), startTime, endTime, orderListVOS.size(), collect); // logger.info("站点:{}, 在{}-{}查询到订单数据{}条，订单编号:{}", stationInfo.getStationName(), startTime, endTime, orderListVOS.size(), collect);
// 统计出日报信息 // // 统计出日报信息
BigDecimal useElectricity = BigDecimal.ZERO; // BigDecimal useElectricity = BigDecimal.ZERO;
int chargeNum = 0; // int chargeNum = 0;
long chargeTime = 0L; // long chargeTime = 0L;
BigDecimal totalElectricityAmount = BigDecimal.ZERO; // BigDecimal totalElectricityAmount = BigDecimal.ZERO;
BigDecimal totalServiceAmount = BigDecimal.ZERO; // BigDecimal totalServiceAmount = BigDecimal.ZERO;
BigDecimal totalOrderAmount = BigDecimal.ZERO; // BigDecimal totalOrderAmount = BigDecimal.ZERO;
BigDecimal totalVirtualAmount = BigDecimal.ZERO; // BigDecimal totalVirtualAmount = BigDecimal.ZERO;
BigDecimal totalSettleAmount = BigDecimal.ZERO; // BigDecimal totalSettleAmount = BigDecimal.ZERO;
List<String> orderCodeList = Lists.newArrayList(); // List<String> orderCodeList = Lists.newArrayList();
for (OrderListVO vo : orderListVOS) { // for (OrderListVO vo : orderListVOS) {
// 统计结算金额大于0的 // // 统计结算金额大于0的
BigDecimal settleAmount = StringUtils.isBlank(vo.getSettleAmount()) // BigDecimal settleAmount = StringUtils.isBlank(vo.getSettleAmount())
? BigDecimal.ZERO // ? BigDecimal.ZERO
: new BigDecimal(vo.getSettleAmount()); // : new BigDecimal(vo.getSettleAmount());
if (settleAmount.compareTo(BigDecimal.ZERO) <= 0) { // if (settleAmount.compareTo(BigDecimal.ZERO) <= 0) {
// 只统计用电量大于0的 // // 只统计用电量大于0的
continue; // continue;
} // }
//
// 订单消费金额 // // 订单消费金额
String orderAmount = vo.getOrderAmount(); // String orderAmount = vo.getOrderAmount();
//
// 用电度数 // // 用电度数
BigDecimal chargingDegree = StringUtils.isBlank(vo.getChargingDegree()) // BigDecimal chargingDegree = StringUtils.isBlank(vo.getChargingDegree())
? BigDecimal.ZERO // ? BigDecimal.ZERO
: new BigDecimal(vo.getChargingDegree()); // : new BigDecimal(vo.getChargingDegree());
//
// 充电度数累计 // // 充电度数累计
useElectricity = useElectricity.add(chargingDegree); // useElectricity = useElectricity.add(chargingDegree);
//
// 充电次数 // // 充电次数
chargeNum += 1; // chargeNum += 1;
orderCodeList.add(vo.getOrderCode()); // orderCodeList.add(vo.getOrderCode());
//
// 充电时间累计 // // 充电时间累计
if (StringUtils.isNotBlank(vo.getChargeStartTime()) && StringUtils.isNotBlank(vo.getChargeEndTime())) { // if (StringUtils.isNotBlank(vo.getChargeStartTime()) && StringUtils.isNotBlank(vo.getChargeEndTime())) {
long l = DateUtils.intervalTime(vo.getChargeStartTime(), vo.getChargeEndTime()); // long l = DateUtils.intervalTime(vo.getChargeStartTime(), vo.getChargeEndTime());
chargeTime += l; // chargeTime += l;
} // }
//
// 电费金额 // // 电费金额
BigDecimal e = vo.getTotalElectricityAmount() != null ? vo.getTotalElectricityAmount() : BigDecimal.ZERO; // BigDecimal e = vo.getTotalElectricityAmount() != null ? vo.getTotalElectricityAmount() : BigDecimal.ZERO;
totalElectricityAmount = totalElectricityAmount.add(e); // totalElectricityAmount = totalElectricityAmount.add(e);
//
// 服务费金额 // // 服务费金额
BigDecimal serviceAmount = vo.getTotalServiceAmount() != null ? vo.getTotalServiceAmount() : BigDecimal.ZERO; // BigDecimal serviceAmount = vo.getTotalServiceAmount() != null ? vo.getTotalServiceAmount() : BigDecimal.ZERO;
totalServiceAmount = totalServiceAmount.add(serviceAmount); // totalServiceAmount = totalServiceAmount.add(serviceAmount);
//
// 订单金额 // // 订单金额
totalOrderAmount = totalOrderAmount.add(new BigDecimal(orderAmount)); // totalOrderAmount = totalOrderAmount.add(new BigDecimal(orderAmount));
//
// 虚拟金额 // // 虚拟金额
String virtualAmount = StringUtils.isNotBlank(vo.getVirtualAmount()) ? vo.getVirtualAmount() : Constants.ZERO; // String virtualAmount = StringUtils.isNotBlank(vo.getVirtualAmount()) ? vo.getVirtualAmount() : Constants.ZERO;
totalVirtualAmount = totalVirtualAmount.add(new BigDecimal(virtualAmount)); // totalVirtualAmount = totalVirtualAmount.add(new BigDecimal(virtualAmount));
//
// 结算金额 // // 结算金额
totalSettleAmount = totalSettleAmount.add(settleAmount); // totalSettleAmount = totalSettleAmount.add(settleAmount);
} // }
//
// 计算报表 // // 计算报表
SettleOrderReport settleOrderReport = new SettleOrderReport(); // SettleOrderReport settleOrderReport = new SettleOrderReport();
String settleCode = "SETTLE_" + IdUtils.getOrderCode(); // String settleCode = "SETTLE_" + IdUtils.getOrderCode();
settleOrderReport.setSettleCode(settleCode); // settleOrderReport.setSettleCode(settleCode);
settleOrderReport.setMerchantId(stationInfo.getMerchantId()); // settleOrderReport.setMerchantId(stationInfo.getMerchantId());
settleOrderReport.setStationId(stationId); // settleOrderReport.setStationId(stationId);
settleOrderReport.setUseElectricity(useElectricity); // settleOrderReport.setUseElectricity(useElectricity);
settleOrderReport.setChargeNum(chargeNum + ""); // settleOrderReport.setChargeNum(chargeNum + "");
settleOrderReport.setChargeTime(chargeTime + ""); // settleOrderReport.setChargeTime(chargeTime + "");
settleOrderReport.setElectricityAmount(totalElectricityAmount); // settleOrderReport.setElectricityAmount(totalElectricityAmount);
settleOrderReport.setServiceAmount(totalServiceAmount); // settleOrderReport.setServiceAmount(totalServiceAmount);
settleOrderReport.setTotalAmount(totalOrderAmount); // settleOrderReport.setTotalAmount(totalOrderAmount);
settleOrderReport.setVirtualAmount(totalVirtualAmount); // settleOrderReport.setVirtualAmount(totalVirtualAmount);
settleOrderReport.setTradeDate(tradeDate); // settleOrderReport.setTradeDate(tradeDate);
settleOrderReport.setOrderCodes(Joiner.on(",").join(orderCodeList)); // settleOrderReport.setOrderCodes(Joiner.on(",").join(orderCodeList));
// 计算手续费 = 结算金额 * 0.55% // // 计算手续费 = 结算金额 * 0.55%
SplitSettleAmountVO splitSettleAmountVO = splitSettleAmount(totalSettleAmount); // SplitSettleAmountVO splitSettleAmountVO = splitSettleAmount(totalSettleAmount);
settleOrderReport.setTradeFee(splitSettleAmountVO.getFeeAmount()); // settleOrderReport.setTradeFee(splitSettleAmountVO.getFeeAmount());
settleOrderReport.setTradeAmount(splitSettleAmountVO.getTradeAmount()); // settleOrderReport.setTradeAmount(splitSettleAmountVO.getTradeAmount());
// 根据站点id和交易日期查询 // // 根据站点id和交易日期查询
SettleOrderReport selectResult = settleOrderReportService.selectByStationIdAndDate(stationId, tradeDate); // SettleOrderReport selectResult = settleOrderReportService.selectByStationIdAndDate(stationId, tradeDate);
if (selectResult != null) { // if (selectResult != null) {
settleOrderReport.setId(selectResult.getId()); // settleOrderReport.setId(selectResult.getId());
} // }
// 订单日报 新增或更新 // // 订单日报 新增或更新
settleOrderReportService.insertOrUpdate(settleOrderReport); // settleOrderReportService.insertOrUpdate(settleOrderReport);
} // }
/** /**
* 通过结算金额，计算客户到账金额和手续费 * 通过结算金额，计算客户到账金额和手续费