This commit is contained in:
van
2026-03-03 19:21:36 +08:00
parent 0b0b431e95
commit 26f6f6e058
2 changed files with 144 additions and 121 deletions

View File

@@ -1,6 +1,7 @@
package com.ruoyi.web.controller.jarvis;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.*;
import javax.servlet.http.HttpServletResponse;
import org.springframework.web.bind.annotation.RequestParam;
@@ -62,7 +63,28 @@ public class OrderRowsController extends BaseController
startPage();
List<OrderRows> list = orderRowsService.selectOrderRowsList(orderRows);
return getDataTable(list);
TableDataInfo dataTable = getDataTable(list);
Date beginTime = getDateFromParams(orderRows.getParams(), "beginTime");
Date endTime = getDateFromParams(orderRows.getParams(), "endTime");
dataTable.setStatistics(buildStatistics(orderRows, beginTime, endTime));
return dataTable;
}
private static Date getDateFromParams(Map<String, Object> params, String key) {
if (params == null) return null;
Object v = params.get(key);
if (v == null) return null;
if (v instanceof Date) return (Date) v;
if (v instanceof String) {
String s = ((String) v).trim();
if (s.isEmpty()) return null;
try {
return new SimpleDateFormat("yyyy-MM-dd").parse(s);
} catch (Exception e) {
return null;
}
}
return null;
}
/**
@@ -146,31 +168,30 @@ public class OrderRowsController extends BaseController
return AjaxResult.success(options);
}
/**
* 根据联盟ID或日期范围统计订单数据按validCode分组
* 根据联盟ID或日期范围统计订单数据按validCode分组(独立接口,与列表同条件时建议用 list 返回的 statistics
*/
@GetMapping("/statistics")
public AjaxResult getStatistics(OrderRows orderRows, Date beginTime, Date endTime) {
Map<String, Object> result = new HashMap<>();
public AjaxResult getStatistics(OrderRows orderRows, Date beginTime, Date endTime) {
return AjaxResult.success(buildStatistics(orderRows, beginTime, endTime));
}
// 获取superAdminList筛选出isCount = 0的unionId
/**
* 按列表相同条件构建统计数据(与 selectOrderRowsList 同条件日期、unionId 等,排除 isCount=0
*/
private Map<String, Object> buildStatistics(OrderRows orderRows, Date beginTime, Date endTime) {
Map<String, Object> result = new HashMap<>();
List<Long> excludeUnionIds = new ArrayList<>();
List<SuperAdmin> superAdminList = superAdminService.selectSuperAdminList(null);
logger.info("superAdminList.size: {}", superAdminList.size());
for (SuperAdmin superAdmin : superAdminList) {
if (superAdmin.getIsCount() != null && superAdmin.getIsCount() == 0 && superAdmin.getUnionId() != null) {
try {
excludeUnionIds.add(Long.parseLong(superAdmin.getUnionId()));
} catch (NumberFormatException e) {
// 忽略无法解析的unionId
}
}
}
logger.info("excludeUnionIds: {}", excludeUnionIds.size());
// 使用新的查询方法直接在SQL中完成日期过滤和unionId排除
List<OrderRows> filteredList = orderRowsService.selectOrderRowsListWithFilter(orderRows, beginTime, endTime, excludeUnionIds);
// 定义分组
Map<String, List<String>> groups = new HashMap<>();
groups.put("cancel", Arrays.asList("3"));
groups.put("invalid", Arrays.asList("2","4","5","6","7","8","9","10","11","14","19","20","21","22","23","29","30","31","32","33","34"));
@@ -180,7 +201,6 @@ public AjaxResult getStatistics(OrderRows orderRows, Date beginTime, Date endTim
groups.put("deposit", Arrays.asList("24"));
groups.put("illegal", Arrays.asList("25","26","27","28"));
// 初始化统计结果
Map<String, Map<String, Object>> groupStats = new HashMap<>();
groupStats.put("cancel", createGroupStat("取消", "cancel"));
groupStats.put("invalid", createGroupStat("无效", "invalid"));
@@ -190,44 +210,40 @@ public AjaxResult getStatistics(OrderRows orderRows, Date beginTime, Date endTim
groupStats.put("deposit", createGroupStat("已付定金", "deposit"));
groupStats.put("illegal", createGroupStat("违规", "illegal"));
// 总统计数据
int totalOrders = 0;
double totalCosPrice = 0;
double totalCommission = 0;
double totalActualFee = 0;
long totalSkuNum = 0;
// 违规订单统计
long violationOrders = 0;
double violationCommission = 0.0;
// 按分组统计
for (OrderRows row : filteredList) {
totalOrders++;
if (row.getEstimateCosPrice() != null) {
totalCosPrice += row.getEstimateCosPrice();
}
if (row.getSkuNum() != null) {
totalSkuNum += row.getSkuNum();
}
// 计算佣金金额(对于违规和取消订单使用特殊计算)
String validCode = row.getValidCode() != null ? String.valueOf(row.getValidCode()) : null;
boolean isCancel = "3".equals(validCode); // 取消订单
boolean isCancel = "3".equals(validCode);
boolean isIllegal = "25".equals(validCode) || "26".equals(validCode)
|| "27".equals(validCode) || "28".equals(validCode); // 违规订单
|| "27".equals(validCode) || "28".equals(validCode);
double commissionAmount = 0.0;
double actualFeeAmount = 0.0;
// 违规订单:始终使用 estimateCosPrice * commissionRate / 100 计算
if (isIllegal) {
if (row.getEstimateCosPrice() != null && row.getCommissionRate() != null) {
commissionAmount = row.getEstimateCosPrice() * row.getCommissionRate() * 0.01;
actualFeeAmount = commissionAmount; // 违规订单的实际费用等于计算的佣金
actualFeeAmount = commissionAmount;
} else if (row.getEstimateFee() != null) {
commissionAmount = row.getEstimateFee();
actualFeeAmount = commissionAmount;
}
}
// 取消订单如果actualFee为空或0则使用公式计算
else if (isCancel) {
} else if (isCancel) {
if (row.getActualFee() != null && row.getActualFee() > 0) {
actualFeeAmount = row.getActualFee();
commissionAmount = row.getEstimateFee() != null ? row.getEstimateFee() : 0;
@@ -238,9 +254,7 @@ public AjaxResult getStatistics(OrderRows orderRows, Date beginTime, Date endTim
commissionAmount = row.getEstimateFee() != null ? row.getEstimateFee() : 0;
actualFeeAmount = row.getActualFee() != null ? row.getActualFee() : 0;
}
}
// 其他订单:使用原有的字段值
else {
} else {
commissionAmount = row.getEstimateFee() != null ? row.getEstimateFee() : 0;
actualFeeAmount = row.getActualFee() != null ? row.getActualFee() : 0;
}
@@ -248,11 +262,9 @@ public AjaxResult getStatistics(OrderRows orderRows, Date beginTime, Date endTim
totalCommission += commissionAmount;
totalActualFee += actualFeeAmount;
// 按validCode分组统计
if (validCode != null) {
for (Map.Entry<String, List<String>> group : groups.entrySet()) {
List<String> codes = group.getValue();
if (codes.contains(validCode)) {
if (group.getValue().contains(validCode)) {
Map<String, Object> stat = groupStats.get(group.getKey());
stat.put("count", (Integer) stat.get("count") + 1);
stat.put("commission", (Double) stat.get("commission") + commissionAmount);
@@ -260,8 +272,6 @@ public AjaxResult getStatistics(OrderRows orderRows, Date beginTime, Date endTim
if (row.getSkuNum() != null) {
stat.put("skuNum", (Long) stat.get("skuNum") + row.getSkuNum());
}
// 统计违规订单
if ("illegal".equals(group.getKey())) {
violationOrders++;
violationCommission += commissionAmount;
@@ -273,15 +283,15 @@ public AjaxResult getStatistics(OrderRows orderRows, Date beginTime, Date endTim
}
result.put("totalOrders", totalOrders);
result.put("totalCosPrice", totalCosPrice);
result.put("totalCommission", totalCommission);
result.put("totalActualFee", totalActualFee);
result.put("totalSkuNum", totalSkuNum);
result.put("violationOrders", violationOrders);
result.put("violationCommission", violationCommission);
result.put("groupStats", groupStats);
return AjaxResult.success(result);
}
return result;
}
/**

View File

@@ -24,6 +24,9 @@ public class TableDataInfo implements Serializable
/** 消息内容 */
private String msg;
/** 扩展数据(如统计信息等,可选) */
private Object statistics;
/**
* 表格数据对象
*/
@@ -82,4 +85,14 @@ public class TableDataInfo implements Serializable
{
this.msg = msg;
}
public Object getStatistics()
{
return statistics;
}
public void setStatistics(Object statistics)
{
this.statistics = statistics;
}
}