新增 运营诊断接口

This commit is contained in:
Lemon
2026-04-01 14:13:29 +08:00
parent da17b5151d
commit 19c89db265
10 changed files with 671 additions and 0 deletions

View File

@@ -8,7 +8,9 @@ import com.jsowell.common.exception.BusinessException;
import com.jsowell.common.response.RestApiResponse;
import com.jsowell.pile.dto.MerchantOrderReportDTO;
import com.jsowell.pile.dto.ParkingCouponRecordQueryDTO;
import com.jsowell.pile.dto.business.BusinessOperationAnalysisQueryDTO;
import com.jsowell.pile.service.BusinessFinancialService;
import com.jsowell.pile.vo.uniapp.business.BusinessOperationAnalysisVO;
import com.jsowell.pile.vo.web.MerchantOrderReportVO;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -87,4 +89,43 @@ public class BusinessFinancialController extends BaseController {
}
return response;
}
/**
* 查询经营分析
*
* @param dto 查询参数
* @return 经营分析
*/
@PostMapping("/operationAnalysis")
public RestApiResponse<?> getBusinessOperationAnalysis(@RequestBody BusinessOperationAnalysisQueryDTO dto) {
logger.info("查询经营分析 params:{}", JSONObject.toJSONString(dto));
RestApiResponse<?> response;
try {
validateBusinessOperationQuery(dto);
BusinessOperationAnalysisVO result = businessFinancialService.getBusinessOperationAnalysis(dto);
response = new RestApiResponse<>(result);
logger.info("查询经营分析成功 startTime:{}, endTime:{}, selectedMetricCode:{}",
dto.getStartTime(), dto.getEndTime(), dto.getSelectedMetricCode());
} catch (BusinessException e) {
logger.warn("查询经营分析业务异常 code:{}, message:{}", e.getCode(), e.getMessage(), e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
} catch (Exception e) {
logger.error("查询经营分析系统异常 params:{}", JSONObject.toJSONString(dto), e);
response = new RestApiResponse<>(e);
}
return response;
}
/**
* 校验经营分析查询参数
*
* @param dto 查询参数
*/
private void validateBusinessOperationQuery(BusinessOperationAnalysisQueryDTO dto) {
if (dto == null
|| StringUtils.isBlank(dto.getStartTime())
|| StringUtils.isBlank(dto.getEndTime())) {
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
}
}
}

View File

@@ -0,0 +1,100 @@
package com.jsowell.common.util;
import java.math.BigDecimal;
import java.math.RoundingMode;
/**
* BigDecimal工具类
*
* @author Auto
* @Date 2026/4/1
*/
public class BigDecimalUtils {
/**
* 工具类不允许实例化
*/
private BigDecimalUtils() {
}
/**
* 空值转零
*
* @param value 原始值
* @return 非空数值
*/
public static BigDecimal nullToZero(BigDecimal value) {
return value == null ? BigDecimal.ZERO : value;
}
/**
* 安全除法
*
* @param dividend 被除数
* @param divisor 除数
* @param scale 保留小数位
* @return 计算结果
*/
public static BigDecimal safeDivide(BigDecimal dividend, BigDecimal divisor, int scale) {
BigDecimal safeDividend = nullToZero(dividend);
BigDecimal safeDivisor = nullToZero(divisor);
if (safeDivisor.compareTo(BigDecimal.ZERO) == 0) {
return BigDecimal.ZERO;
}
return safeDividend.divide(safeDivisor, scale, RoundingMode.HALF_UP);
}
/**
* 标准化数值显示
*
* @param value 原始值
* @return 标准化后的数值
*/
public static BigDecimal normalize(BigDecimal value) {
BigDecimal safeValue = nullToZero(value);
if (safeValue.compareTo(BigDecimal.ZERO) == 0) {
return BigDecimal.ZERO;
}
return safeValue.stripTrailingZeros();
}
/**
* 将字符串安全转换为BigDecimal
*
* @param value 原始字符串
* @return BigDecimal值
*/
public static BigDecimal parseOrZero(String value) {
if (StringUtils.isBlank(value)) {
return BigDecimal.ZERO;
}
try {
return new BigDecimal(value.trim());
} catch (Exception e) {
return BigDecimal.ZERO;
}
}
/**
* 计算环比百分比
*
* @param currentValue 当前周期值
* @param previousValue 上周期值
* @return 环比字符串
*/
public static String calculateRate(BigDecimal currentValue, BigDecimal previousValue) {
BigDecimal safeCurrentValue = nullToZero(currentValue);
BigDecimal safePreviousValue = nullToZero(previousValue);
if (safePreviousValue.compareTo(BigDecimal.ZERO) == 0) {
return "0%";
}
BigDecimal rate = safeCurrentValue.subtract(safePreviousValue)
.divide(safePreviousValue, 4, RoundingMode.HALF_UP)
.multiply(new BigDecimal("100"));
BigDecimal normalizedRate = normalize(rate);
if (normalizedRate.compareTo(BigDecimal.ZERO) > 0) {
return "+" + normalizedRate.toPlainString() + "%";
}
return normalizedRate.toPlainString() + "%";
}
}

View File

@@ -0,0 +1,41 @@
package com.jsowell.pile.dto.business;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* 经营状态/经营诊断查询DTO
*
* @author Auto
* @Date 2026/4/1
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class BusinessOperationAnalysisQueryDTO {
/**
* 开始时间格式yyyy-MM-dd
*/
private String startTime;
/**
* 结束时间格式yyyy-MM-dd
*/
private String endTime;
/**
* 站点id列表
*/
private List<String> stationIdList;
/**
* 当前选中的指标编码
*/
private String selectedMetricCode;
}

View File

@@ -0,0 +1,39 @@
package com.jsowell.pile.dto.business;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* 经营分析日期区间DTO
*
* @author Auto
* @Date 2026/4/1
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class BusinessOperationDateRangeDTO {
/**
* 当前周期开始时间
*/
private String currentStart;
/**
* 当前周期结束时间
*/
private String currentEnd;
/**
* 上周期开始时间
*/
private String previousStart;
/**
* 上周期结束时间
*/
private String previousEnd;
}

View File

@@ -0,0 +1,55 @@
package com.jsowell.pile.dto.business;
import lombok.Data;
import java.math.BigDecimal;
/**
* 经营分析汇总DTO
*
* @author Auto
* @Date 2026/4/1
*/
@Data
public class BusinessOperationSummaryDTO {
/**
* 订单总额
*/
private BigDecimal orderAmount = BigDecimal.ZERO;
/**
* 服务费总额
*/
private BigDecimal serviceAmount = BigDecimal.ZERO;
/**
* 总用电度数
*/
private BigDecimal useElectricity = BigDecimal.ZERO;
/**
* 订单量
*/
private BigDecimal orderCount = BigDecimal.ZERO;
/**
* 总充电时长
*/
private BigDecimal chargeTime = BigDecimal.ZERO;
/**
* 单均服务费
*/
private BigDecimal avgServiceFee = BigDecimal.ZERO;
/**
* 单均度数
*/
private BigDecimal avgElectricity = BigDecimal.ZERO;
/**
* 单均充电时长
*/
private BigDecimal avgChargeTime = BigDecimal.ZERO;
}

View File

@@ -3,6 +3,8 @@ package com.jsowell.pile.service;
import com.jsowell.common.core.page.PageResponse;
import com.jsowell.pile.dto.MerchantOrderReportDTO;
import com.jsowell.pile.dto.ParkingCouponRecordQueryDTO;
import com.jsowell.pile.dto.business.BusinessOperationAnalysisQueryDTO;
import com.jsowell.pile.vo.uniapp.business.BusinessOperationAnalysisVO;
import com.jsowell.pile.vo.web.MerchantOrderReportVO;
import com.jsowell.pile.vo.web.ParkingCouponRecordVO;
@@ -16,4 +18,12 @@ public interface BusinessFinancialService {
* @return 分页结果
*/
PageResponse queryParkingCouponRecords(ParkingCouponRecordQueryDTO dto);
/**
* 查询经营分析
*
* @param dto 查询条件
* @return 经营分析
*/
BusinessOperationAnalysisVO getBusinessOperationAnalysis(BusinessOperationAnalysisQueryDTO dto);
}

View File

@@ -5,23 +5,37 @@ import com.github.pagehelper.PageInfo;
import com.huifu.adapay.core.exception.BaseAdaPayException;
import com.jsowell.adapay.service.AdapayService;
import com.jsowell.adapay.vo.AdapayAccountBalanceVO;
import com.jsowell.common.util.BigDecimalUtils;
import com.jsowell.common.core.domain.vo.AuthorizedDeptVO;
import com.jsowell.common.core.page.PageResponse;
import com.jsowell.common.enums.ykc.ReturnCodeEnum;
import com.jsowell.common.exception.BusinessException;
import com.jsowell.pile.dto.MerchantOrderReportDTO;
import com.jsowell.pile.dto.ParkingCouponRecordQueryDTO;
import com.jsowell.pile.dto.business.BusinessOperationAnalysisQueryDTO;
import com.jsowell.pile.dto.business.BusinessOperationDateRangeDTO;
import com.jsowell.pile.dto.business.BusinessOperationSummaryDTO;
import com.jsowell.pile.domain.SettleOrderReport;
import com.jsowell.pile.service.BusinessFinancialService;
import com.jsowell.pile.service.CarCouponRecordService;
import com.jsowell.pile.service.ClearingWithdrawInfoService;
import com.jsowell.pile.service.PileStationInfoService;
import com.jsowell.pile.service.SettleOrderReportService;
import com.jsowell.pile.util.UserUtils;
import com.jsowell.pile.vo.uniapp.business.BusinessOperationAnalysisVO;
import com.jsowell.pile.vo.uniapp.business.BusinessOperationDiagnosisItemVO;
import com.jsowell.pile.vo.uniapp.business.BusinessOperationMetricVO;
import com.jsowell.pile.vo.web.MerchantOrderReportVO;
import com.jsowell.pile.vo.web.ParkingCouponRecordVO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.List;
/**
@@ -31,6 +45,13 @@ import java.util.List;
@Service
public class BusinessFinancialServiceImpl implements BusinessFinancialService {
private static final String METRIC_ORDER_AMOUNT = "ORDER_AMOUNT";
private static final String METRIC_AVG_SERVICE_FEE = "AVG_SERVICE_FEE";
private static final String METRIC_AVG_ELECTRICITY = "AVG_ELECTRICITY";
private static final String FACTOR_ORDER_COUNT = "ORDER_COUNT";
private static final String FACTOR_AVG_ELECTRICITY = "AVG_ELECTRICITY";
private static final String FACTOR_AVG_CHARGE_TIME = "AVG_CHARGE_TIME";
@Autowired
private SettleOrderReportService settleOrderReportService;
@@ -148,4 +169,205 @@ public class BusinessFinancialServiceImpl implements BusinessFinancialService {
.total(pageInfo.getTotal())
.build();
}
/**
* 查询经营分析
*
* @param dto 查询条件
* @return 经营分析
*/
@Override
public BusinessOperationAnalysisVO getBusinessOperationAnalysis(BusinessOperationAnalysisQueryDTO dto) {
BusinessOperationDateRangeDTO range = buildDateRange(dto);
List<String> stationIdList = resolveStationIds(dto.getStationIdList());
BusinessOperationSummaryDTO currentSummary = buildOperationSummary(
stationIdList, range.getCurrentStart(), range.getCurrentEnd());
BusinessOperationSummaryDTO previousSummary = buildOperationSummary(
stationIdList, range.getPreviousStart(), range.getPreviousEnd());
List<BusinessOperationMetricVO> metricList = new ArrayList<>();
metricList.add(buildMetric(METRIC_ORDER_AMOUNT, "订单总额",
currentSummary.getOrderAmount(), previousSummary.getOrderAmount()));
metricList.add(buildMetric(METRIC_AVG_SERVICE_FEE, "单均服务费",
currentSummary.getAvgServiceFee(), previousSummary.getAvgServiceFee()));
metricList.add(buildMetric(METRIC_AVG_ELECTRICITY, "单均度数",
currentSummary.getAvgElectricity(), previousSummary.getAvgElectricity()));
BusinessOperationDiagnosisItemVO diagnosisItem = buildSelectedDiagnosisItem(dto, currentSummary, previousSummary);
return BusinessOperationAnalysisVO.builder()
.currentStartTime(range.getCurrentStart())
.currentEndTime(range.getCurrentEnd())
.previousStartTime(range.getPreviousStart())
.previousEndTime(range.getPreviousEnd())
.metricList(metricList)
.diagnosisItem(diagnosisItem)
.build();
}
/**
* 构建当前选中指标对应的最大影响因素
*
* @param dto 查询条件
* @param currentSummary 当前周期汇总
* @param previousSummary 上周期汇总
* @return 经营诊断指标
*/
private BusinessOperationDiagnosisItemVO buildSelectedDiagnosisItem(BusinessOperationAnalysisQueryDTO dto,
BusinessOperationSummaryDTO currentSummary,
BusinessOperationSummaryDTO previousSummary) {
String selectedMetricCode = dto.getSelectedMetricCode();
if (METRIC_AVG_SERVICE_FEE.equals(selectedMetricCode)) {
return buildDiagnosis(METRIC_AVG_SERVICE_FEE, "单均服务费",
FACTOR_AVG_ELECTRICITY, "单均度数",
currentSummary.getAvgElectricity(), previousSummary.getAvgElectricity());
}
if (METRIC_AVG_ELECTRICITY.equals(selectedMetricCode)) {
return buildDiagnosis(METRIC_AVG_ELECTRICITY, "单均度数",
FACTOR_AVG_CHARGE_TIME, "单均充电时长",
currentSummary.getAvgChargeTime(), previousSummary.getAvgChargeTime());
}
return buildDiagnosis(METRIC_ORDER_AMOUNT, "订单总额",
FACTOR_ORDER_COUNT, "订单量",
currentSummary.getOrderCount(), previousSummary.getOrderCount());
}
/**
* 构建经营状态指标项
*
* @param metricCode 指标编码
* @param metricName 指标名称
* @param currentValue 当前周期值
* @param previousValue 上周期值
* @return 经营状态指标
*/
private BusinessOperationMetricVO buildMetric(String metricCode, String metricName,
BigDecimal currentValue, BigDecimal previousValue) {
BigDecimal safeCurrentValue = BigDecimalUtils.nullToZero(currentValue);
BigDecimal safePreviousValue = BigDecimalUtils.nullToZero(previousValue);
BigDecimal changeValue = BigDecimalUtils.normalize(safeCurrentValue.subtract(safePreviousValue));
return BusinessOperationMetricVO.builder()
.metricCode(metricCode)
.metricName(metricName)
.currentValue(BigDecimalUtils.normalize(safeCurrentValue))
.previousValue(BigDecimalUtils.normalize(safePreviousValue))
.changeValue(changeValue)
.changeRate(BigDecimalUtils.calculateRate(safeCurrentValue, safePreviousValue))
.build();
}
/**
* 构建经营诊断指标项
*
* @param metricCode 指标编码
* @param metricName 指标名称
* @param factorCode 影响因素编码
* @param factorName 影响因素名称
* @param currentValue 当前周期值
* @param previousValue 上周期值
* @return 经营诊断指标
*/
private BusinessOperationDiagnosisItemVO buildDiagnosis(String metricCode, String metricName,
String factorCode, String factorName,
BigDecimal currentValue, BigDecimal previousValue) {
BigDecimal safeCurrentValue = BigDecimalUtils.nullToZero(currentValue);
BigDecimal safePreviousValue = BigDecimalUtils.nullToZero(previousValue);
BigDecimal changeValue = BigDecimalUtils.normalize(safeCurrentValue.subtract(safePreviousValue));
return BusinessOperationDiagnosisItemVO.builder()
.metricCode(metricCode)
.metricName(metricName)
.factorCode(factorCode)
.factorName(factorName)
.currentValue(BigDecimalUtils.normalize(safeCurrentValue))
.previousValue(BigDecimalUtils.normalize(safePreviousValue))
.changeValue(changeValue)
.changeRate(BigDecimalUtils.calculateRate(safeCurrentValue, safePreviousValue))
.build();
}
/**
* 根据查询条件构建当前周期和上周期日期区间
*
* @param dto 查询条件
* @return 日期区间
*/
private BusinessOperationDateRangeDTO buildDateRange(BusinessOperationAnalysisQueryDTO dto) {
try {
LocalDate currentStart = LocalDate.parse(dto.getStartTime());
LocalDate currentEnd = LocalDate.parse(dto.getEndTime());
if (currentEnd.isBefore(currentStart)) {
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
}
long days = ChronoUnit.DAYS.between(currentStart, currentEnd) + 1;
LocalDate previousEnd = currentStart.minusDays(1);
LocalDate previousStart = previousEnd.minusDays(days - 1);
return BusinessOperationDateRangeDTO.builder()
.currentStart(currentStart.toString())
.currentEnd(currentEnd.toString())
.previousStart(previousStart.toString())
.previousEnd(previousEnd.toString())
.build();
} catch (BusinessException e) {
throw e;
} catch (Exception e) {
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
}
}
/**
* 解析本次查询可用的站点ID列表
*
* @param stationIdList 前端传入站点ID列表
* @return 实际查询站点ID列表
*/
private List<String> resolveStationIds(List<String> stationIdList) {
if (!CollectionUtils.isEmpty(stationIdList)) {
return stationIdList;
}
try {
AuthorizedDeptVO authorizedMap = UserUtils.getAuthorizedMap();
if (authorizedMap == null) {
return stationIdList;
}
if (!CollectionUtils.isEmpty(authorizedMap.getStationDeptIds())) {
return pileStationInfoService.queryByStationDeptIds(authorizedMap.getStationDeptIds());
}
if (!CollectionUtils.isEmpty(authorizedMap.getMerchantDeptIds())) {
return pileStationInfoService.getStationIdsByMerchantIds(authorizedMap.getMerchantDeptIds());
}
} catch (Exception e) {
log.warn("解析经营分析站点权限失败", e);
}
return stationIdList;
}
/**
* 汇总指定周期内的经营指标
*
* @param stationIdList 站点ID列表
* @param startTime 开始时间
* @param endTime 结束时间
* @return 汇总结果
*/
private BusinessOperationSummaryDTO buildOperationSummary(List<String> stationIdList,
String startTime,
String endTime) {
List<SettleOrderReport> reportList = settleOrderReportService.queryOrderReport(
stationIdList, startTime, endTime);
if (CollectionUtils.isEmpty(reportList)) {
return new BusinessOperationSummaryDTO();
}
BusinessOperationSummaryDTO summary = new BusinessOperationSummaryDTO();
for (SettleOrderReport report : reportList) {
summary.setOrderAmount(summary.getOrderAmount().add(BigDecimalUtils.nullToZero(report.getTotalAmount())));
summary.setServiceAmount(summary.getServiceAmount().add(BigDecimalUtils.nullToZero(report.getServiceAmount())));
summary.setUseElectricity(summary.getUseElectricity().add(BigDecimalUtils.nullToZero(report.getUseElectricity())));
summary.setOrderCount(summary.getOrderCount().add(BigDecimalUtils.parseOrZero(report.getChargeNum())));
summary.setChargeTime(summary.getChargeTime().add(BigDecimalUtils.parseOrZero(report.getChargeTime())));
}
summary.setAvgServiceFee(BigDecimalUtils.safeDivide(summary.getServiceAmount(), summary.getOrderCount(), 2));
summary.setAvgElectricity(BigDecimalUtils.safeDivide(summary.getUseElectricity(), summary.getOrderCount(), 2));
summary.setAvgChargeTime(BigDecimalUtils.safeDivide(summary.getChargeTime(), summary.getOrderCount(), 2));
return summary;
}
}

View File

@@ -0,0 +1,51 @@
package com.jsowell.pile.vo.uniapp.business;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* 经营分析VO
*
* @author Auto
* @Date 2026/4/1
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class BusinessOperationAnalysisVO {
/**
* 当前周期开始时间
*/
private String currentStartTime;
/**
* 当前周期结束时间
*/
private String currentEndTime;
/**
* 上周期开始时间
*/
private String previousStartTime;
/**
* 上周期结束时间
*/
private String previousEndTime;
/**
* 顶部指标列表
*/
private List<BusinessOperationMetricVO> metricList;
/**
* 当前选中指标对应的最大影响因素
*/
private BusinessOperationDiagnosisItemVO diagnosisItem;
}

View File

@@ -0,0 +1,61 @@
package com.jsowell.pile.vo.uniapp.business;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
/**
* 经营诊断项VO
*
* @author Auto
* @Date 2026/4/1
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class BusinessOperationDiagnosisItemVO {
/**
* 指标编码
*/
private String metricCode;
/**
* 指标名称
*/
private String metricName;
/**
* 最大影响因素编码
*/
private String factorCode;
/**
* 最大影响因素名称
*/
private String factorName;
/**
* 当前周期值
*/
private BigDecimal currentValue;
/**
* 上周期值
*/
private BigDecimal previousValue;
/**
* 变化值
*/
private BigDecimal changeValue;
/**
* 环比
*/
private String changeRate;
}

View File

@@ -0,0 +1,51 @@
package com.jsowell.pile.vo.uniapp.business;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
/**
* 经营指标VO
*
* @author Auto
* @Date 2026/4/1
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class BusinessOperationMetricVO {
/**
* 指标编码
*/
private String metricCode;
/**
* 指标名称
*/
private String metricName;
/**
* 当前周期值
*/
private BigDecimal currentValue;
/**
* 上周期值
*/
private BigDecimal previousValue;
/**
* 变化值
*/
private BigDecimal changeValue;
/**
* 环比
*/
private String changeRate;
}