package com.ruoyi.order.controller;
import cn.afterturn.easypoi.excel.ExcelExportUtil;
import cn.afterturn.easypoi.excel.entity.ExportParams;
import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import java.io.IOException;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.DecimalFormat;
import java.time.*;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ruoyi.account.api.feignClient.AppUserCarClient;
import com.ruoyi.account.api.feignClient.AppUserClient;
import com.ruoyi.account.api.feignClient.AppUserTagClient;
import com.ruoyi.account.api.model.TAppUser;
import com.ruoyi.account.api.model.TAppUserCar;
import com.ruoyi.account.api.model.TAppUserTag;
import com.ruoyi.chargingPile.api.domain.SiteMenu;
import com.ruoyi.chargingPile.api.dto.GetSiteListDTO;
import com.ruoyi.chargingPile.api.feignClient.*;
import com.ruoyi.chargingPile.api.model.Partner;
import com.ruoyi.chargingPile.api.model.Site;
import com.ruoyi.chargingPile.api.model.TChargingGun;
import com.ruoyi.chargingPile.api.model.TChargingPile;
import com.ruoyi.chargingPile.api.model.TParkingRecord;
import com.ruoyi.chargingPile.api.model.TPartnerAppUser;
import com.ruoyi.chargingPile.api.vo.GetChargingGunByChargingPileIdsVo;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.core.dto.ChargingOrderGroup;
import com.ruoyi.common.core.dto.ChargingPercentProvinceDto;
import com.ruoyi.common.core.utils.StringUtils;
import com.ruoyi.common.log.annotation.Log;
import com.ruoyi.common.log.enums.BusinessType;
import com.ruoyi.common.log.enums.OperatorType;
import com.ruoyi.common.redis.service.RedisService;
import com.ruoyi.common.security.annotation.Logical;
import com.ruoyi.common.security.annotation.RequiresPermissions;
import com.ruoyi.common.security.service.TokenService;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.common.core.web.page.PageInfo;
import com.ruoyi.order.api.dto.ChargingStatisticeDTO;
import com.ruoyi.order.api.model.*;
import com.ruoyi.order.api.query.ChargingOrderQuery;
import com.ruoyi.common.core.dto.MongoChargingOrderQuery;
import com.ruoyi.order.api.query.TChargingCountQuery;
import com.ruoyi.order.api.query.UploadRealTimeMonitoringDataQuery;
import com.ruoyi.order.api.vo.*;
import com.ruoyi.order.api.vo.ChargingOrderInfoVO;
import com.ruoyi.order.api.vo.GetChargingOrderByLicensePlate;
import com.ruoyi.order.api.vo.TCharingOrderVO;
import com.ruoyi.order.dto.GetMyChargingOrderList;
import com.ruoyi.order.dto.GetNoInvoicedOrder;
import com.ruoyi.order.dto.MyChargingOrderInfo;
import com.ruoyi.order.dto.MyChargingOrderList;
import com.ruoyi.order.dto.OrderEvaluateVo;
import com.ruoyi.order.dto.*;
import com.ruoyi.order.mapper.TChargingOrderMapper;
import com.ruoyi.order.export.PayOrderExport;
import com.ruoyi.order.export.EnterpriseChargingDetailExport;
import com.ruoyi.order.service.*;
import com.ruoyi.order.support.FranchiseeUserStatistics;
import com.ruoyi.order.util.PreviousSixMonths;
import com.ruoyi.order.util.mongodb.service.UploadRealTimeMonitoringDataService;
import com.ruoyi.order.vo.EndOfChargePageInfo;
import com.ruoyi.order.vo.ChargingSimulationVO;
import com.ruoyi.order.vo.IcbcAdminSubOrderVO;
import com.ruoyi.order.vo.StatisticsOfBatteryVO;
import com.ruoyi.order.vo.ReservationRecommendationVO;
import com.ruoyi.order.vo.UpdateOrderPaymentAmountDto;
import com.ruoyi.order.vo.WatchChargingOrderVo;
import com.ruoyi.other.api.feignClient.RoleSiteClient;
import com.ruoyi.other.api.feignClient.UserSiteClient;
import com.ruoyi.other.api.feignClient.UserTagClient;
import com.ruoyi.other.api.feignClient.VipClient;
import com.ruoyi.other.api.feignClient.OtherClient;
import com.ruoyi.other.api.domain.TCompany;
import com.ruoyi.other.api.domain.TVip;
import com.ruoyi.other.api.domain.TUserTag;
import com.ruoyi.payment.api.feignClient.AliPaymentClient;
import com.ruoyi.payment.api.feignClient.WxPaymentClient;
import com.ruoyi.payment.api.vo.IcbcPaymentResp;
import com.ruoyi.payment.api.vo.IcbcRefundResp;
import com.ruoyi.payment.api.vo.IcbcSubOrderRefundResp;
import com.ruoyi.system.api.domain.SysUser;
import com.ruoyi.system.api.feignClient.SysUserClient;
import com.ruoyi.system.api.feignClient.SysUserRoleClient;
import com.ruoyi.system.api.model.SysUserRoleVo;
import io.swagger.annotations.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.net.URLEncoder;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.stream.Collectors;
import com.ruoyi.common.core.utils.DateUtils;
import com.ruoyi.common.core.utils.WebUtils;
import org.apache.poi.ss.usermodel.Workbook;
/**
*
* 前端控制器
*
*
* @author xiaochen
* @since 2024-08-07
*/
@Api(tags = "充电订单")
@RestController
@RequestMapping("/t-charging-order")
public class TChargingOrderController {
private Logger log = LoggerFactory.getLogger(TChargingOrderController.class);
@Resource
private TChargingOrderService chargingOrderService;
@Autowired
private TokenService tokenService;
@Autowired
private TOrderEvaluateService orderEvaluateService;
@Autowired
private TGrantVipService tGrantVipService;
@Resource
private WxPaymentClient wxPaymentClient;
@Resource
private RedisService redisService;
@Resource
private AliPaymentClient aliPaymentClient;
@Resource
private TShoppingOrderService shoppingOrderService;
@Resource
private AppUserClient appUserClient;
@Resource
private TVipOrderService vipOrderService;
@Resource
private ParkingLotClient parkingLotClient;
@Resource
private TChargingOrderRefundService chargingOrderRefundService;
@Resource
private TShoppingOrderRefundService shoppingOrderRefundService;
@Resource
private TVipOrderRefundService vipOrderRefundService;
@Resource
private SiteClient siteClient;
@Resource
private ChargingPileClient chargingPileClient;
@Resource
private ChargingGunClient chargingGunClient;
@Resource
private AppUserCarClient appUserCarClient;
@Resource
private AppUserTagClient appUserTagClient;
@Resource
private UserTagClient userTagClient;
@Resource
private TChargingOrderAccountingStrategyService chargingOrderAccountingStrategyService;
@Resource
private TOrderInvoiceService invoiceService;
@Resource
private TOrderInvoiceDetailService orderInvoiceDetailService;
@Resource
private UploadRealTimeMonitoringDataService uploadRealTimeMonitoringDataService;
@Resource
private PartnerClient partnerClient;
@Resource
private SysUserClient sysUserClient;
@Resource
private UserSiteClient userSiteClient;
@Resource
private RoleSiteClient roleSiteClient;
@Resource
private VipClient vipClient;
@Resource
private OtherClient otherClient;
@Resource
private SysUserRoleClient sysUserRoleClient;
@Resource
private TChargingOrderMapper chargingOrderMapper;
/** 尖峰平谷反查分块 id 上限：MyCat/druid 对 IN 列表的解析路由成本随 id 数非线性增长
* （实测 500 个约 5s、5000 个 70s+ 触发读超时；100 个内约 0.2s/块，约 2ms/个）。 */
private static final int PHASE_ID_BATCH_SIZE = 100;
/** 尖峰平谷分块反查并发度：46k id 实测 ~20s，典型加盟商 <3s（串行 5000/块 >70s 读超时）。 */
private static final ExecutorService PHASE_QUERY_EXECUTOR = Executors.newFixedThreadPool(16);
@GetMapping("/reservationRecommendation")
@ApiOperation(value = "获取站点预约充电推荐时段", tags = {"管理后台-充电桩信息"})
public R getReservationRecommendation(@RequestParam Integer siteId) {
return R.ok(chargingOrderService.getReservationRecommendation(siteId));
}
/** 小程序加盟商看板：站点范围始终从登录账号绑定关系解析。聚合查询下推到分片，避免全量拉订单。 */
@PostMapping("/app/franchisee/charge-data")
public R> franchiseeChargeData(@RequestBody(required = false) Map params) {
List siteIds = franchiseeSiteIds(params);
LocalDateTime[] range = franchiseeRange(params);
List dayStats = franchiseeDayStats(siteIds, range);
Map summary = new LinkedHashMap<>();
summary.put("orderAmountWan", sum(dayStats, FranchiseeDayStat::getOrderAmount).divide(BigDecimal.valueOf(10000), 4, RoundingMode.HALF_UP));
summary.put("serviceFeeWan", sum(dayStats, FranchiseeDayStat::getServiceFee).divide(BigDecimal.valueOf(10000), 4, RoundingMode.HALF_UP));
summary.put("chargingPowerWan", sum(dayStats, FranchiseeDayStat::getCapacity).divide(BigDecimal.valueOf(10000), 4, RoundingMode.HALF_UP));
summary.put("chargingAmount", sum(dayStats, FranchiseeDayStat::getPaymentAmount));
summary.put("chargingOrderCount", dayStats.stream().mapToLong(stat -> numberValue(stat.getOrderCount())).sum());
summary.put("powerUtilizationRate", observedPowerUtilization(dayStats));
summary.put("demandPowerSatisfactionRate", demandPowerSatisfaction(dayStats));
Map result = new LinkedHashMap<>();
result.put("summary", summary);
result.put("keyDataLine", franchiseeDailyTrend(dayStats, range, "订单金额", FranchiseeDayStat::getOrderAmountEffective));
result.put("keyDataRing", franchiseePhaseRing(siteIds, range));
result.put("orderStats", franchiseeOrderTrend(dayStats, range));
result.put("efficiency", franchiseeEfficiencyTrend(dayStats, range));
result.put("powerDistribution", franchiseePowerDistribution(siteIds, range));
return R.ok(result);
}
@PostMapping("/app/franchisee/income")
public R> franchiseeIncome(@RequestBody(required = false) Map params) {
List siteIds = franchiseeSiteIds(params);
LocalDate firstMonth = YearMonth.now().minusMonths(5).atDay(1);
LocalDate nextMonth = YearMonth.now().plusMonths(1).atDay(1);
List dayStats = franchiseeDayStats(siteIds,
new LocalDateTime[]{firstMonth.atStartOfDay(), nextMonth.atStartOfDay()});
Map result = new LinkedHashMap<>();
result.put("totalIncome", sum(dayStats, FranchiseeDayStat::getPaymentAmount));
result.put("electricityFee", sum(dayStats, FranchiseeDayStat::getElectrovalence));
result.put("serviceFee", sum(dayStats, FranchiseeDayStat::getServiceFee));
result.put("incomeColumn", franchiseeIncomeTrend(dayStats, firstMonth, 6));
List> incomePie = new ArrayList<>();
Map electricityItem = new LinkedHashMap<>();
electricityItem.put("name", "充电费");
electricityItem.put("value", sum(dayStats, FranchiseeDayStat::getElectrovalence));
incomePie.add(electricityItem);
Map serviceItem = new LinkedHashMap<>();
serviceItem.put("name", "服务费");
serviceItem.put("value", sum(dayStats, FranchiseeDayStat::getServiceFee));
incomePie.add(serviceItem);
result.put("incomePie", incomePie);
return R.ok(result);
}
@PostMapping("/app/franchisee/user")
public R> franchiseeUser(@RequestBody(required = false) Map params) {
Partner partner = franchiseePartner();
List siteIds = partner == null ? Collections.emptyList() : franchiseeSiteIds(params, partner.getId());
LocalDateTime[] range = franchiseeRange(params);
List aggs = franchiseeUserAggs(siteIds, range);
Map> chargingUsersByDay = new LinkedHashMap<>();
for (FranchiseeUserAgg agg : aggs) {
if (agg == null || agg.getAppUserId() == null || agg.getStatDay() == null) {
continue;
}
chargingUsersByDay.computeIfAbsent(agg.getStatDay(), key -> new HashSet<>()).add(agg.getAppUserId());
}
List relations = Collections.emptyList();
if (partner != null && partner.getId() != null) {
R> relationResult = partnerClient.getBoundAppUserRelations(partner.getId());
if (relationResult != null && relationResult.getData() != null) {
relations = relationResult.getData();
}
}
FranchiseeUserStatistics.Result userStatistics = FranchiseeUserStatistics.calculateByUserDays(
chargingUsersByDay, relations, range[0], range[1]);
Set users = aggs.stream().map(FranchiseeUserAgg::getAppUserId).filter(Objects::nonNull).collect(Collectors.toSet());
List appUsers = Collections.emptyList();
if (!users.isEmpty()) {
R> userResult = appUserClient.getUserByIds(new ArrayList<>(users));
if (userResult != null && userResult.getData() != null) appUsers = userResult.getData();
}
Map userMap = appUsers.stream().filter(user -> user.getId() != null)
.collect(Collectors.toMap(TAppUser::getId, user -> user, (left, right) -> left));
List carIds = aggs.stream().map(FranchiseeUserAgg::getAppUserCarId).filter(Objects::nonNull).distinct().collect(Collectors.toList());
List cars = Collections.emptyList();
if (!carIds.isEmpty()) {
R> carResult = appUserCarClient.getCarByIds(carIds);
if (carResult != null && carResult.getData() != null) cars = carResult.getData();
}
Map evaluation = franchiseeEvaluation(siteIds);
Map result = new LinkedHashMap<>();
result.put("summary", userStatistics.getSummary());
result.put("userStats", userStatistics.getTrend());
result.put("userTags", franchiseeUserTags(aggs));
Map vipNames = new HashMap<>();
R> vipResult = vipClient.getAllVip();
if (vipResult != null && vipResult.getData() != null) vipResult.getData().forEach(vip -> vipNames.put(vip.getId(), vip.getName()));
result.put("memberType", franchiseeMemberTypes(appUsers, vipNames));
result.put("corpRank", franchiseeCompanyRank(aggs, userMap));
result.put("evaluation", evaluation.get("summary"));
result.put("goodTags", evaluation.get("goodTags"));
result.put("badTags", evaluation.get("badTags"));
result.put("traffic", franchiseeTraffic(siteIds, range));
result.put("vehicleClass", franchiseeOrderCarGroup(aggs, cars, TAppUserCar::getVehicleUse, "未知用途", 5));
result.put("vehicleBrand", franchiseeOrderCarGroup(aggs, cars, TAppUserCar::getVehicleBrand, "其他", 5));
return R.ok(result);
}
@PostMapping("/app/franchisee/operation")
public R> franchiseeOperation(@RequestBody(required = false) Map params) {
Map result = new LinkedHashMap<>();
List siteIds = franchiseeSiteIds(params);
List piles = Collections.emptyList();
if (!siteIds.isEmpty()) { R> pileResult = chargingPileClient.getChargingPileBySiteIds(siteIds); if (pileResult != null && pileResult.getData() != null) piles = pileResult.getData(); }
List guns = Collections.emptyList();
List pileIds = piles.stream().map(TChargingPile::getId).filter(Objects::nonNull).collect(Collectors.toList());
if (!pileIds.isEmpty()) {
GetChargingGunByChargingPileIdsVo query = new GetChargingGunByChargingPileIdsVo(); query.setChargingPileIds(pileIds);
R> gunResult = chargingGunClient.getChargingGunByChargingPileIds(query);
if (gunResult != null && gunResult.getData() != null) guns = gunResult.getData();
}
BigDecimal total = BigDecimal.valueOf(guns.size());
BigDecimal available = BigDecimal.valueOf(guns.stream().filter(this::isAvailableGun).count());
BigDecimal fault = countGuns(guns, 7), offline = countGuns(guns, 1);
LocalDateTime[] range = franchiseeRange(params);
List operationStats = franchiseeDayStats(siteIds, range);
BigDecimal powerSatisfaction = demandPowerSatisfaction(operationStats);
Map gunSatMap = Collections.emptyMap();
if (!siteIds.isEmpty() && range[0] != null && range[1] != null) {
gunSatMap = chargingOrderMapper.franchiseeGunSatisfaction(siteIds, range[0], range[1]).stream()
.filter(sat -> sat != null && sat.getChargingGunId() != null)
.collect(Collectors.toMap(FranchiseeGunSat::getChargingGunId, sat -> sat, (left, right) -> left));
}
Map summary = new LinkedHashMap<>(); summary.put("availableRate", rate(available, total)); summary.put("faultRate", rate(fault, total)); summary.put("offlineRate", rate(offline, total)); summary.put("powerSatisfactionRate", powerSatisfaction);
result.put("summary", summary); result.put("dcCharts", operationCharts(guns, gunSatMap, true)); result.put("acCharts", operationCharts(guns, gunSatMap, false));
return R.ok(result);
}
/** 加盟商看板按日聚合（siteIds 为空直接返回空，避免空 IN）。 */
private List franchiseeDayStats(List siteIds, LocalDateTime[] range) {
if (siteIds == null || siteIds.isEmpty() || range == null || range[0] == null || range[1] == null) {
return Collections.emptyList();
}
return chargingOrderMapper.franchiseeDayStats(siteIds, range[0], range[1]);
}
/** 加盟商看板用户维度聚合（仅已结束订单；siteIds 为空直接返回空）。 */
private List franchiseeUserAggs(List siteIds, LocalDateTime[] range) {
if (siteIds == null || siteIds.isEmpty() || range == null || range[0] == null || range[1] == null) {
return Collections.emptyList();
}
return chargingOrderMapper.franchiseeUserAggs(siteIds, range[0], range[1]);
}
private List franchiseeSiteIds(Map params) {
Partner partner = franchiseePartner();
if (partner == null || partner.getId() == null) return Collections.emptyList();
return franchiseeSiteIds(params, partner.getId());
}
private Partner franchiseePartner() {
if (tokenService.getLoginUserApplet() == null || tokenService.getLoginUserApplet().getUserId() == null) return null;
Long appUserId = tokenService.getLoginUserApplet().getUserId();
R partnerResult = partnerClient.getPartnerByAppUserId(appUserId);
return partnerResult == null ? null : partnerResult.getData();
}
private List franchiseeSiteIds(Map params, Integer partnerId) {
R> siteResult = siteClient.getSiteAll();
List sites = siteResult == null ? null : siteResult.getData();
List siteIds = sites == null ? new ArrayList<>() : sites.stream().filter(s -> Objects.equals(s.getPartnerId(), partnerId)).map(Site::getId).collect(Collectors.toList());
Object requestedSite = params == null ? null : params.get("siteId");
if (requestedSite != null && !String.valueOf(requestedSite).isEmpty()) {
Integer siteId = Integer.valueOf(String.valueOf(requestedSite)); siteIds = siteIds.contains(siteId) ? Collections.singletonList(siteId) : Collections.singletonList(-1);
}
return siteIds;
}
private List> franchiseeUserTags(List aggs) {
Set userIds = aggs.stream()
.map(FranchiseeUserAgg::getAppUserId)
.filter(Objects::nonNull)
.collect(Collectors.toSet());
if (userIds.isEmpty()) {
return Collections.emptyList();
}
R> tagResult = userTagClient.getAllUserTag();
List tags = tagResult == null || tagResult.getData() == null
? Collections.emptyList() : tagResult.getData();
// 单次批量拉取全部用户标签关系（t_app_user_tag 分片键 app_user_id 精确路由），
// 避免原先 标签×用户 双层循环逐个远程调用导致接口 40s+。
R> relationResult = appUserTagClient.listByUserIds(new ArrayList<>(userIds));
List relations = relationResult == null || relationResult.getData() == null
? Collections.emptyList() : relationResult.getData();
Map> usersByTag = relations.stream()
.filter(relation -> relation.getUserTagId() != null && relation.getAppUserId() != null)
.collect(Collectors.groupingBy(TAppUserTag::getUserTagId,
Collectors.mapping(TAppUserTag::getAppUserId, Collectors.toSet())));
Map counts = new LinkedHashMap<>();
for (TUserTag tag : tags) {
if (tag == null || tag.getId() == null || StringUtils.isBlank(tag.getName())) {
continue;
}
Set taggedUsers = usersByTag.get(tag.getId());
if (taggedUsers != null && !taggedUsers.isEmpty()) {
counts.put(tag.getName(), (long) taggedUsers.size());
}
}
return counts.entrySet().stream()
.map(entry -> namedCount(entry.getKey(), entry.getValue()))
.collect(Collectors.toList());
}
private List> franchiseeMemberTypes(List users, Map vipNames) {
long ordinary = users.stream().filter(user -> user.getVipId() == null || user.getVipId() == 0).count();
Map vipCounts = users.stream().filter(user -> user.getVipId() != null && user.getVipId() != 0)
.collect(Collectors.groupingBy(TAppUser::getVipId, Collectors.counting()));
List> result = new ArrayList<>();
if (ordinary > 0) result.add(namedCount("普通用户", ordinary));
vipCounts.forEach((vipId, count) -> result.add(namedCount(vipNames.getOrDefault(vipId, "会员" + vipId), count)));
return result;
}
private Map franchiseeCompanyRank(List aggs, Map userMap) {
Map totals = new HashMap<>();
aggs.forEach(agg -> {
TAppUser user = userMap.get(agg.getAppUserId());
if (user != null && user.getCompanyId() != null) {
totals.merge(user.getCompanyId(), value(agg.getCapacity()), BigDecimal::add);
}
});
List> sorted = totals.entrySet().stream()
.sorted(Map.Entry.comparingByValue().reversed()).limit(5).collect(Collectors.toList());
Map chart = new LinkedHashMap<>();
chart.put("categories", sorted.stream().map(entry -> {
R companyResult = otherClient.unitDetail(entry.getKey());
TCompany company = companyResult == null ? null : companyResult.getData();
return company == null || StringUtils.isBlank(company.getName()) ? "单位" + entry.getKey() : company.getName();
}).collect(Collectors.toList()));
Map series = new LinkedHashMap<>(); series.put("name", "充电量");
series.put("data", sorted.stream().map(Map.Entry::getValue).collect(Collectors.toList()));
chart.put("series", Collections.singletonList(series)); return chart;
}
private Map franchiseeEvaluation(List siteIds) {
if (siteIds == null || siteIds.isEmpty()) {
Map emptySummary = new LinkedHashMap<>();
emptySummary.put("score", 0D); emptySummary.put("goodCount", 0); emptySummary.put("mediumCount", 0); emptySummary.put("badCount", 0);
emptySummary.put("goodRate", BigDecimal.ZERO); emptySummary.put("mediumRate", BigDecimal.ZERO); emptySummary.put("badRate", BigDecimal.ZERO);
Map empty = new LinkedHashMap<>(); empty.put("summary", emptySummary); empty.put("goodTags", Collections.emptyList()); empty.put("badTags", Collections.emptyList()); return empty;
}
Double score = chargingOrderService.getAver(siteIds);
List> levels = chargingOrderService.getLevelEvaluate(siteIds);
long good = 0, medium = 0, bad = 0;
if (levels != null) for (Map level : levels) {
String range = String.valueOf(level.get("score_range")); long count = numberValue(level.get("count"));
if ("4-5".equals(range)) good += count; else if ("3".equals(range)) medium += count; else if ("1-2".equals(range)) bad += count;
}
long total = good + medium + bad;
Map summary = new LinkedHashMap<>(); summary.put("score", score == null ? 0D : score);
summary.put("goodCount", good); summary.put("mediumCount", medium); summary.put("badCount", bad);
summary.put("goodRate", ratePercent(good, total)); summary.put("mediumRate", ratePercent(medium, total)); summary.put("badRate", ratePercent(bad, total));
Map result = new LinkedHashMap<>(); result.put("summary", summary);
result.put("goodTags", safeList(orderEvaluateService.goodTop(siteIds))); result.put("badTags", safeList(orderEvaluateService.badTop(siteIds))); return result;
}
private List> franchiseeTraffic(List siteIds, LocalDateTime[] range) {
if (siteIds == null || siteIds.isEmpty() || range == null || range[0] == null || range[1] == null) {
return Collections.emptyList();
}
List> result = new ArrayList<>();
chargingOrderMapper.franchiseeTrafficStats(siteIds, range[0], range[1]).forEach(stat -> {
if (stat == null || stat.getOrderCount() == null || stat.getOrderCount() == 0) {
return;
}
String source = stat.getSource() == null || stat.getSource().isEmpty() ? "明星充电" : stat.getSource();
result.add(namedCount(source, stat.getOrderCount()));
});
return result;
}
private List> franchiseeOrderCarGroup(List aggs,
List cars,
java.util.function.Function getter,
String emptyName,
int limit) {
Map carsById = cars.stream()
.filter(car -> car.getId() != null)
.collect(Collectors.toMap(TAppUserCar::getId, car -> car, (left, right) -> left));
Map counts = new HashMap<>();
aggs.forEach(agg -> {
if (agg == null || agg.getOrderCount() == null) {
return;
}
TAppUserCar car = agg.getAppUserCarId() == null ? null : carsById.get(agg.getAppUserCarId());
String value = car == null ? null : getter.apply(car);
counts.merge(value == null || value.trim().isEmpty() ? emptyName : value, agg.getOrderCount(), Long::sum);
});
return counts.entrySet().stream().sorted(Map.Entry.comparingByValue().reversed()).limit(limit)
.map(entry -> namedCount(entry.getKey(), entry.getValue())).collect(Collectors.toList());
}
private List> namedCounts(String[] names, long[] values) {
List> result = new ArrayList<>();
for (int i = 0; i < names.length; i++) if (values[i] > 0) result.add(namedCount(names[i], values[i]));
return result;
}
private Map namedCount(String name, long value) { Map result = new LinkedHashMap<>(); result.put("name", name); result.put("value", value); return result; }
private long numberValue(Object value) { return value instanceof Number ? ((Number) value).longValue() : 0L; }
private BigDecimal ratePercent(long numerator, long denominator) { return denominator == 0 ? BigDecimal.ZERO : BigDecimal.valueOf(numerator * 100D / denominator).setScale(2, RoundingMode.HALF_UP); }
private List safeList(List values) { return values == null ? Collections.emptyList() : values; }
private BigDecimal countGuns(List guns, int status) { return BigDecimal.valueOf(guns.stream().filter(gun -> Objects.equals(gun.getStatus(), status)).count()); }
private boolean isAvailableGun(TChargingGun gun) { return gun.getStatus() != null && gun.getStatus() >= 2 && gun.getStatus() <= 6; }
private BigDecimal rate(BigDecimal numerator, BigDecimal denominator) { return denominator.signum() == 0 ? BigDecimal.ZERO : numerator.multiply(BigDecimal.valueOf(100)).divide(denominator, 2, RoundingMode.HALF_UP); }
private List> operationCharts(List guns, Map gunSatMap, boolean dc) {
List selected = guns.stream().filter(gun -> dc ? Objects.equals(gun.getType(), 4) : gun.getType() != null && gun.getType() >= 1 && gun.getType() <= 3).collect(Collectors.toList());
List> charts = new ArrayList<>();
String[] keys = {"availableRate", "faultRate", "offlineRate", "powerSatisfactionRate"}; int[] statuses = {0, 7, 1, 0};
String[] names = {"可用率", "故障率", "离网率", "电量满足率"};
for (int i = 0; i < keys.length; i++) {
final int status = statuses[i]; Map chart = new LinkedHashMap<>(); chart.put("key", keys[i]);
List categories = selected.stream().map(TChargingGun::getName).map(name -> name == null ? "未命名充电枪" : name).collect(Collectors.toList());
final int metricIndex = i;
List values = selected.stream().map(gun -> metricIndex == 3
? gunSatisfaction(gunSatMap, gun.getId())
: BigDecimal.valueOf(metricIndex == 0 ? (isAvailableGun(gun) ? 100 : 0) : (Objects.equals(gun.getStatus(), status) ? 100 : 0))).collect(Collectors.toList());
chart.put("categories", categories);
Map series = new LinkedHashMap<>(); series.put("name", names[i]); series.put("data", values); chart.put("series", Collections.singletonList(series)); charts.add(chart);
}
return charts;
}
private BigDecimal gunSatisfaction(Map gunSatMap, Integer gunId) {
FranchiseeGunSat sat = gunId == null ? null : gunSatMap.get(gunId);
if (sat == null || sat.getSatCount() == null || sat.getSatCount() == 0) {
return BigDecimal.ZERO;
}
return value(sat.getSatSum()).divide(BigDecimal.valueOf(sat.getSatCount()), 2, RoundingMode.HALF_UP);
}
private LocalDateTime[] franchiseeRange(Map params) {
LocalDate today = LocalDate.now();
if (params != null && params.get("startTime") != null && params.get("endTime") != null) {
String startText = String.valueOf(params.get("startTime"));
String endText = String.valueOf(params.get("endTime"));
if (!startText.isEmpty() && !endText.isEmpty()) {
try {
return new LocalDateTime[]{LocalDate.parse(startText).atStartOfDay(), LocalDate.parse(endText).plusDays(1).atStartOfDay()};
} catch (RuntimeException ignored) {
// 日期格式异常时回退到快捷日期范围。
}
}
}
String type = params == null ? "today" : String.valueOf(params.getOrDefault("dateType", "today"));
if ("year".equals(type)) return new LocalDateTime[]{today.withDayOfYear(1).atStartOfDay(), today.plusDays(1).atStartOfDay()};
if ("month".equals(type)) return new LocalDateTime[]{today.withDayOfMonth(1).atStartOfDay(), today.plusDays(1).atStartOfDay()};
if ("week".equals(type)) { LocalDate start = today.minusDays(today.getDayOfWeek().getValue() - 1); return new LocalDateTime[]{start.atStartOfDay(), today.plusDays(1).atStartOfDay()}; }
return new LocalDateTime[]{today.atStartOfDay(), today.plusDays(1).atStartOfDay()};
}
private BigDecimal sum(List items, java.util.function.Function getter) { return items.stream().map(getter).map(this::value).reduce(BigDecimal.ZERO, BigDecimal::add); }
private BigDecimal value(BigDecimal value) { return value == null ? BigDecimal.ZERO : value; }
private Map dayStatByDay(List stats) {
return stats.stream().filter(stat -> stat != null && stat.getStatDay() != null)
.collect(Collectors.toMap(FranchiseeDayStat::getStatDay, stat -> stat, (left, right) -> left));
}
private Map franchiseeDailyTrend(List stats, LocalDateTime[] range, String name, java.util.function.Function getter) {
Map byDay = dayStatByDay(stats);
List categories = new ArrayList<>(); List data = new ArrayList<>();
LocalDate start = range[0] == null ? LocalDate.now() : range[0].toLocalDate();
LocalDate end = range[1] == null ? start.plusDays(1) : range[1].toLocalDate();
for (LocalDate day = start; day.isBefore(end); day = day.plusDays(1)) {
categories.add(day.toString().substring(5));
FranchiseeDayStat stat = byDay.get(day);
data.add(stat == null ? BigDecimal.ZERO : value(getter.apply(stat)));
}
Map chart = new LinkedHashMap<>(); chart.put("categories", categories);
Map series = new LinkedHashMap<>(); series.put("name", name); series.put("data", data); chart.put("series", new ArrayList<>(Collections.singletonList(series))); return chart;
}
private Map franchiseeOrderTrend(List stats, LocalDateTime[] range) {
Map chart = franchiseeDailyTrend(stats, range, "充电金额", FranchiseeDayStat::getOrderAmountEffective);
((List>) chart.get("series")).get(0).put("type", "column");
Map byDay = dayStatByDay(stats);
List countData = new ArrayList<>(); List categories = (List) chart.get("categories");
LocalDate start = range[0] == null ? LocalDate.now() : range[0].toLocalDate();
for (int i = 0; i < categories.size(); i++) { LocalDate day = start.plusDays(i); FranchiseeDayStat stat = byDay.get(day); countData.add(BigDecimal.valueOf(stat == null ? 0L : numberValue(stat.getOrderCount()))); }
Map countSeries = new LinkedHashMap<>(); countSeries.put("name", "充电订单"); countSeries.put("data", countData); countSeries.put("type", "line"); countSeries.put("style", "curve"); countSeries.put("index", 1); ((List>) chart.get("series")).add(countSeries); return chart;
}
private Map franchiseePhaseRing(List siteIds, LocalDateTime[] range) {
Map phase = new LinkedHashMap<>(); phase.put(1, BigDecimal.ZERO); phase.put(2, BigDecimal.ZERO); phase.put(3, BigDecimal.ZERO); phase.put(4, BigDecimal.ZERO);
if (siteIds != null && !siteIds.isEmpty() && range != null && range[0] != null && range[1] != null) {
List ids = chargingOrderMapper.franchiseeOrderIds(siteIds, range[0], range[1]);
if (!ids.isEmpty()) {
// 分块并行反查 strategy 表（分片键 charging_order_id）：MyCat 按 id 路由成本约 2ms/个，
// 串行 5000/块在大范围下 70s+ 读超时；100/块 × 16 线程实测 46k id 约 20s（代理并发吞吐有限）。
List> futures = new ArrayList<>();
for (int from = 0; from < ids.size(); from += PHASE_ID_BATCH_SIZE) {
List chunk = ids.subList(from, Math.min(from + PHASE_ID_BATCH_SIZE, ids.size()));
futures.add(CompletableFuture.runAsync(() -> {
List items = chargingOrderMapper.franchiseePhaseStatsByOrderIds(chunk);
if (items != null) {
synchronized (phase) {
items.forEach(item -> {
if (item != null && item.getType() != null) {
phase.computeIfPresent(item.getType(), (key, total) -> total.add(value(item.getCapacity())));
}
});
}
}
}, PHASE_QUERY_EXECUTOR));
}
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
}
}
String[] names = {"尖", "峰", "平", "谷"}; List> data = new ArrayList<>();
for (int i = 1; i <= 4; i++) { Map item = new LinkedHashMap<>(); item.put("name", names[i - 1]); item.put("value", phase.get(i)); data.add(item); }
Map chart = new LinkedHashMap<>(); chart.put("series", Collections.singletonList(Collections.singletonMap("data", data))); return chart;
}
private Map franchiseeEfficiencyTrend(List stats, LocalDateTime[] range) {
Map byDay = dayStatByDay(stats);
List categories = new ArrayList<>();
List powerData = new ArrayList<>(), utilization = new ArrayList<>();
LocalDate start = range[0] == null ? LocalDate.now() : range[0].toLocalDate();
LocalDate end = range[1] == null ? start.plusDays(1) : range[1].toLocalDate();
for (LocalDate day = start; day.isBefore(end); day = day.plusDays(1)) {
categories.add(day.toString().substring(5));
FranchiseeDayStat stat = byDay.get(day);
powerData.add(stat == null ? BigDecimal.ZERO : averagePower(stat));
utilization.add(observedPowerUtilization(stat == null ? Collections.emptyList() : Collections.singletonList(stat)));
}
Map chart = new LinkedHashMap<>(); chart.put("categories", categories);
Map powerSeries = new LinkedHashMap<>(); powerSeries.put("name", "功率"); powerSeries.put("data", powerData);
Map utilizationSeries = new LinkedHashMap<>(); utilizationSeries.put("name", "功率利用率"); utilizationSeries.put("data", utilization);
chart.put("series", new ArrayList<>(Arrays.asList(powerSeries, utilizationSeries))); return chart;
}
private BigDecimal averagePower(FranchiseeDayStat stat) {
if (stat == null || stat.getPowerCount() == null || stat.getPowerCount() == 0 || stat.getTotalPower() == null) {
return BigDecimal.ZERO;
}
return stat.getTotalPower().divide(BigDecimal.valueOf(stat.getPowerCount()), 2, RoundingMode.HALF_UP);
}
private BigDecimal observedPowerUtilization(List stats) {
BigDecimal sum = stats.stream().map(FranchiseeDayStat::getUtilPowerSum).map(this::value).reduce(BigDecimal.ZERO, BigDecimal::add);
long count = stats.stream().mapToLong(stat -> numberValue(stat.getUtilPowerCount())).sum();
if (count == 0) return BigDecimal.ZERO;
BigDecimal maximum = stats.stream().map(FranchiseeDayStat::getMaxPower).filter(Objects::nonNull).max(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
if (maximum.signum() == 0) return BigDecimal.ZERO;
return sum.divide(BigDecimal.valueOf(count), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).divide(maximum, 2, RoundingMode.HALF_UP);
}
private BigDecimal demandPowerSatisfaction(List stats) {
BigDecimal total = stats.stream().map(FranchiseeDayStat::getElecSatSum).map(this::value).reduce(BigDecimal.ZERO, BigDecimal::add);
long count = stats.stream().mapToLong(stat -> numberValue(stat.getElecSatCount())).sum();
if (count == 0) return BigDecimal.ZERO;
return total.divide(BigDecimal.valueOf(count), 2, RoundingMode.HALF_UP);
}
private Map franchiseePowerDistribution(List siteIds, LocalDateTime[] range) {
String[] names = {"0-30kW", "30-60kW", "60-120kW", "120-300kW", "300kW以上"}; long[] counts = new long[5];
if (siteIds != null && !siteIds.isEmpty() && range != null && range[0] != null && range[1] != null) {
chargingOrderMapper.franchiseePowerBuckets(siteIds, range[0], range[1]).forEach(bucket -> {
if (bucket != null && bucket.getBucket() != null && bucket.getBucket() >= 0 && bucket.getBucket() < 5) {
counts[bucket.getBucket()] += numberValue(bucket.getOrderCount());
}
});
}
List> data = new ArrayList<>(); for (int i = 0; i < names.length; i++) { Map item = new LinkedHashMap<>(); item.put("name", names[i]); item.put("value", counts[i]); data.add(item); }
return Collections.singletonMap("series", Collections.singletonList(Collections.singletonMap("data", data)));
}
private Map franchiseeIncomeTrend(List stats, LocalDate firstMonth, int monthCount) {
List categories = new ArrayList<>();
List electricity = new ArrayList<>(), service = new ArrayList<>();
Map> byMonth = stats.stream().filter(stat -> stat != null && stat.getStatDay() != null)
.collect(Collectors.groupingBy(stat -> YearMonth.from(stat.getStatDay())));
for (int i = 0; i < monthCount; i++) {
YearMonth month = YearMonth.from(firstMonth).plusMonths(i);
categories.add(String.format("%02d月", month.getMonthValue()));
List monthStats = byMonth.getOrDefault(month, Collections.emptyList());
electricity.add(sum(monthStats, FranchiseeDayStat::getElectrovalence));
service.add(sum(monthStats, FranchiseeDayStat::getServiceFee));
}
Map chart = new LinkedHashMap<>(); chart.put("categories", categories);
Map electricitySeries = new LinkedHashMap<>(); electricitySeries.put("name", "充电费"); electricitySeries.put("data", electricity);
Map serviceSeries = new LinkedHashMap<>(); serviceSeries.put("name", "服务费"); serviceSeries.put("data", service);
chart.put("series", new ArrayList<>(Arrays.asList(electricitySeries, serviceSeries))); return chart;
}
/**
* 远程调用 监管平台查询前一天用能统计
* @return
*/
@ResponseBody
@PostMapping(value = "/getChargingStatistics")
public R> getChargingStatistics(@RequestBody ChargingStatisticeDTO dto) {
List collect = chargingOrderAccountingStrategyService.lambdaQuery().between(TChargingOrderAccountingStrategy::getCreateTime, dto.getStartTime(), dto.getEndTime())
.list().stream().map(TChargingOrderAccountingStrategy::getChargingOrderId).collect(Collectors.toList());
if (!collect.isEmpty()){
List list = chargingOrderService.lambdaQuery()
.in(TChargingOrder::getId,collect).list();
return R.ok(list);
}
return R.ok(new ArrayList());
}
/**
* 远程调用 增加管理后台赠送会员记录
* @return
*/
@ResponseBody
@PostMapping(value = "/management/give/vip")
public R managementGiveVip(@RequestBody TGrantVip grantVip) {
return R.ok(tGrantVipService.save(grantVip));
}
/**
* 远程调用根据枪id 查询最新的订单id 用户后台结束充电
* @param id
* @return
*/
@ResponseBody
@PostMapping(value = "/queryOrderByGunId/{id}")
public R queryOrderByGunId(@PathVariable("id") String id) {
List integers = new ArrayList<>();
integers.add(2);
integers.add(3);
integers.add(4);
TChargingOrder one = chargingOrderService.lambdaQuery()
.eq(TChargingOrder::getChargingGunId, id)
.in(TChargingOrder::getStatus, integers)
.one();
if (one!=null){
return R.ok(one.getId().toString());
}
return R.ok();
}
@RequiresPermissions(value = {"/chargingUserAnalysis"}, logical = Logical.OR)
@ResponseBody
@PostMapping(value = "/enterprise/charging/analysis")
@ApiOperation(value = "企业用户充电分析", tags = {"管理后台-数据分析-企业用户充电分析"})
public R> enterpriseChargingAnalysis(@RequestBody EnterpriseChargingAnalysisQuery query) {
return chargingOrderService.enterpriseChargingAnalysis(query);
}
@RequiresPermissions(value = {"/chargingUserAnalysis"}, logical = Logical.OR)
@ResponseBody
@PostMapping(value = "/enterprise/charging/detail")
@ApiOperation(value = "企业用户充电明细", tags = {"管理后台-数据分析-企业用户充电分析"})
public R> enterpriseChargingDetail(@RequestBody EnterpriseChargingAnalysisQuery query) {
return chargingOrderService.enterpriseChargingDetail(query);
}
@RequiresPermissions(value = {"/chargingUserAnalysis"}, logical = Logical.OR)
@ResponseBody
@PutMapping(value = "/enterprise/charging/detail/export")
@ApiOperation(value = "企业用户充电明细导出", tags = {"管理后台-数据分析-企业用户充电分析"})
public void exportEnterpriseChargingDetail(@RequestBody EnterpriseChargingAnalysisQuery query) {
List records = chargingOrderService.enterpriseChargingDetailExport(query);
List exports = records.stream().map(this::buildEnterpriseChargingDetailExport).collect(Collectors.toList());
Workbook workbook = ExcelExportUtil.exportExcel(new ExportParams(), EnterpriseChargingDetailExport.class, exports);
HttpServletResponse response = WebUtils.response();
response.setContentType("application/vnd.ms-excel;charset=UTF-8");
response.setCharacterEncoding("utf-8");
response.setHeader("Pragma", "no-cache");
response.setHeader("Cache-Control", "no-cache");
try {
response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode("企业用户充电明细.xls", "utf-8"));
try (ServletOutputStream outputStream = response.getOutputStream()) {
workbook.write(outputStream);
}
workbook.close();
} catch (IOException e) {
log.error("导出企业用户充电明细失败", e);
}
}
private EnterpriseChargingDetailExport buildEnterpriseChargingDetailExport(EnterpriseChargingDetailVO dto) {
EnterpriseChargingDetailExport export = new EnterpriseChargingDetailExport();
export.setCode(dto.getCode());
export.setOrderType(formatEnterpriseOrderType(dto.getOrderType()));
export.setOrderClassification(formatOrderClassification(dto.getOrderClassification()));
export.setSiteName(dto.getSiteName());
export.setTerminalName(dto.getTerminalName());
export.setStatus(formatPayOrderStatus(1, dto.getStatus()));
export.setChargingSecond(dto.getChargingSecond());
export.setTotalAmount(dto.getTotalAmount());
export.setCouponDiscountAmount(dto.getCouponDiscountAmount());
export.setVipDiscountAmount(dto.getVipDiscountAmount());
export.setPaymentAmount(dto.getPaymentAmount());
export.setRefundAmount(dto.getRefundAmount());
export.setPartnerName(dto.getPartnerName());
export.setPhone(dto.getPhone());
export.setOrderSource(formatOrderSource(dto.getOrderSource()));
export.setCreateTime(dto.getCreateTime() == null ? null : DateUtils.localDateTimeToString(dto.getCreateTime()));
export.setStartTime(dto.getStartTime() == null ? null : DateUtils.localDateTimeToString(dto.getStartTime()));
export.setEndTime(dto.getEndTime() == null ? null : DateUtils.localDateTimeToString(dto.getEndTime()));
export.setLicensePlate(dto.getLicensePlate());
export.setChargingCapacity(dto.getChargingCapacity());
export.setElectrovalence(dto.getElectrovalence());
export.setServiceCharge(dto.getServiceCharge());
export.setEndMode(formatChargingEndMode(dto.getEndMode()));
export.setPeriodCount(dto.getPeriodCount());
return export;
}
private String formatChargingEndMode(Integer endMode) {
if (endMode == null) {
return "-";
}
switch (endMode) {
case 0:
return "异常终止";
case 1:
return "主动终止";
case 2:
return "满电终止";
case 3:
return "费用不足终止";
default:
return "-";
}
}
private String formatEnterpriseOrderType(Integer type) {
if (type == null) {
return "-";
}
if (type == 1) {
return "充电订单（小程序）";
}
if (type == 2) {
return "充电订单（刷卡）";
}
return "充电订单";
}
private String formatOrderClassification(Integer type) {
if (type == null) {
return "-";
}
return type == 1 ? "线上订单" : "线下订单";
}
private String formatOrderSource(Integer source) {
if (source == null) {
return "-";
}
if (source == 0) {
return "自有平台";
}
if (source == 1) {
return "第三方平台";
}
if (source == 2) {
return "引流平台";
}
return "其他";
}
@RequiresPermissions(value = {"/invoiceManagement/select_order", "/paymentOrder/order"}, logical = Logical.OR)
@ResponseBody
@PostMapping(value = "/pay/order/list")
@ApiOperation(value = "列表", tags = {"管理后台-支付订单-订单信息"})
public R> payOrderList(@RequestBody PayOrderQueryDto payOrderQueryDto) {
resolveInvoiceOrderIds(payOrderQueryDto);
return chargingOrderService.payOrderQuery(payOrderQueryDto);
}
@RequiresPermissions(value = {"/invoiceManagement/select_order", "/invoiceManagement/export", "/paymentOrder/order"}, logical = Logical.OR)
@ResponseBody
@PutMapping(value = "/pay/order/export")
@ApiOperation(value = "导出查看订单列表", tags = {"管理后台-支付订单-订单信息"})
@Log(title = "发票管理查看订单导出", businessType = BusinessType.EXPORT)
public void exportPayOrder(@RequestBody PayOrderQueryDto payOrderQueryDto) {
resolveInvoiceOrderIds(payOrderQueryDto);
payOrderQueryDto.setPageCurr(1);
payOrderQueryDto.setPageSize(10000);
R> result = chargingOrderService.payOrderQuery(payOrderQueryDto);
List records = result.getData() == null || result.getData().getRecords() == null
? Collections.emptyList() : result.getData().getRecords();
List exports = records.stream().map(this::buildPayOrderExport).collect(Collectors.toList());
Workbook workbook = ExcelExportUtil.exportExcel(new ExportParams(), PayOrderExport.class, exports);
HttpServletResponse response = WebUtils.response();
response.setContentType("application/vnd.ms-excel;charset=UTF-8");
response.setCharacterEncoding("utf-8");
response.setHeader("Pragma", "no-cache");
response.setHeader("Cache-Control", "no-cache");
try {
response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode("订单列表.xls", "utf-8"));
try (ServletOutputStream outputStream = response.getOutputStream()) {
workbook.write(outputStream);
}
workbook.close();
} catch (IOException e) {
log.error("导出查看订单列表失败", e);
}
}
/**
* 查看开票订单时以数据库中的开票明细为准，避免前端遗漏或篡改订单 ID。
*/
private void resolveInvoiceOrderIds(PayOrderQueryDto query) {
if (query == null || query.getInvoiceId() == null) {
return;
}
LambdaQueryWrapper wrapper = new LambdaQueryWrapper()
.eq(TOrderInvoiceDetail::getOrderInvoiceId, query.getInvoiceId());
if (query.getType() != null) {
wrapper.eq(TOrderInvoiceDetail::getOrderType, query.getType());
}
List orderIds = orderInvoiceDetailService.list(wrapper).stream()
.map(TOrderInvoiceDetail::getOrderId)
.filter(Objects::nonNull)
.map(String::valueOf)
.collect(Collectors.toList());
query.setIds(orderIds);
}
private PayOrderExport buildPayOrderExport(PayOrderDto dto) {
PayOrderExport export = new PayOrderExport();
export.setCode(dto.getCode());
export.setType(formatPayOrderType(dto.getType()));
export.setTitle(dto.getTitle());
export.setPhone(dto.getPhone());
export.setOrderStatus(dto.getPayTime() != null ? "订单支付成功" : "订单完成");
export.setStatus(formatPayOrderStatus(dto.getType(), dto.getStatus()));
export.setRefundStatus(dto.getRefundStatus() != null && dto.getRefundStatus() > 0 ? "有退款" : "无退款");
export.setRechargeAmount(dto.getRechargeAmount());
export.setPaymentAmount(dto.getPaymentAmount());
export.setFinalAmount(dto.getFinalAmount());
export.setCreateTime(dto.getCreateTime() == null ? null : DateUtils.localDateTimeToString(dto.getCreateTime()));
export.setEndTime(dto.getEndTime() == null ? null : DateUtils.localDateTimeToString(dto.getEndTime()));
export.setPayTime(dto.getPayTime() == null ? null : DateUtils.localDateTimeToString(dto.getPayTime()));
return export;
}
private String formatPayOrderType(Integer type) {
if (type == null || type < 1 || type > 4) {
return "-";
}
return new String[]{"充电订单", "购物订单", "vip订单", "停车订单"}[type - 1];
}
private String formatPayOrderStatus(Integer type, Integer status) {
if (type == null) {
return "-";
}
if (type == 3) {
return "支付成功";
}
if (status == null) {
return "-";
}
if (type == 1 && status >= 0 && status <= 5) {
return new String[]{"未知", "等待中", "启动中", "充电中", "停止中", "已结束"}[status];
}
if (type == 2 && status >= 1 && status <= 4) {
return new String[]{"待发货", "待收货", "已完成", "已取消"}[status - 1];
}
if (type == 4 && status >= 1 && status <= 3) {
return new String[]{"已进场", "已出场", "已缴费出场"}[status - 1];
}
return "-";
}
public static List testing5(long total, long current, long size, List str){
List result = new ArrayList<>();
//获取初始化分页结构
com.ruoyi.order.util.Page page = new com.ruoyi.order.util.Page().getPage(total, size, current - 1);
//获取集合下标初始值
long startIndex = page.getStartIndex();
//获取集合下标结束值
long endInddex = 0;
if(startIndex + page.getCurrent() >= total || size > total){
endInddex = total;
}else {
endInddex = Math.min(startIndex + page.getSize(), total);
}
//如果输入的开始查询下标大于集合大小，则查询为空值
if(startIndex > total){
result = Collections.emptyList();
}else{
result = str.subList((int)startIndex,(int)endInddex);
}
return result;
}
@ResponseBody
@PostMapping(value = "/pay/order/refund")
@ApiOperation(value = "退款", tags = {"管理后台-支付订单-订单信息"})
public R refund(@RequestBody PayOrderRefundDto payOrderQueryDto) {
return chargingOrderService.payRefund(payOrderQueryDto);
}
@ResponseBody
@PostMapping(value = "/pay/order/special/refund/query")
@RequiresPermissions(value = {"/paymentOrder/specialRefund", "/paymentOrder/specialRefund/refund"}, logical = Logical.OR)
@ApiOperation(value = "特殊退款查询", tags = {"管理后台-支付订单-特殊退款处理"})
public R specialRefundQuery(@RequestBody PayOrderRefundDto payOrderQueryDto) {
return chargingOrderService.getSpecialRefundOrder(payOrderQueryDto);
}
@ResponseBody
@PostMapping(value = "/pay/order/special/refund")
@RequiresPermissions(value = {"/paymentOrder/specialRefund/refund"}, logical = Logical.OR)
@ApiOperation(value = "特殊退款", tags = {"管理后台-支付订单-特殊退款处理"})
public R specialRefund(@RequestBody PayOrderRefundDto payOrderQueryDto) {
return chargingOrderService.specialRefund(payOrderQueryDto);
}
@RequiresPermissions(value = {"/paymentOrder/order"}, logical = Logical.OR)
@ResponseBody
@GetMapping(value = "/pay/order/pay/detail")
@ApiOperation(value = "支付信息", tags = {"管理后台-支付订单-订单信息"})
public R payOrderList(Long orderId, Integer type) {
switch (type) {
case 1:
TChargingOrder byId = chargingOrderService.getById(orderId);
PayOrderInfoDto payOrderInfoDto = new PayOrderInfoDto();
payOrderInfoDto.setOrderId(byId.getId().toString());
payOrderInfoDto.setCode(byId.getCode());
payOrderInfoDto.setTradeNo(byId.getRechargeSerialNumber());
payOrderInfoDto.setPayType(byId.getRechargePaymentType());
payOrderInfoDto.setPayAmount(byId.getPaymentAmount());
payOrderInfoDto.setPayTime(byId.getCreateTime());
payOrderInfoDto.setRefundAmount(byId.getRefundAmount());
payOrderInfoDto.setRechargeAmount(byId.getRechargeAmount());
payOrderInfoDto.setFinalAmount(byId.getRechargeAmount().subtract(byId.getRefundAmount()));
payOrderInfoDto.setPayMethod(byId.getPayMethod());
payOrderInfoDto.setBalancePayAmount(byId.getBalancePayAmount());
payOrderInfoDto.setThirdPayAmount(byId.getThirdPayAmount());
payOrderInfoDto.setBalanceRefundAmount(byId.getBalanceRefundAmount());
payOrderInfoDto.setThirdRefundAmount(byId.getThirdRefundAmount());
payOrderInfoDto.setRefundableAmount(chargingOrderService.getManualRefundableAmount(byId.getId()));
return R.ok(payOrderInfoDto);
case 2:
TShoppingOrder byId1 = shoppingOrderService.getById(orderId);
PayOrderInfoDto payOrderInfoDto1 = new PayOrderInfoDto();
payOrderInfoDto1.setOrderId(byId1.getId().toString());
payOrderInfoDto1.setCode(byId1.getCode());
payOrderInfoDto1.setTradeNo(byId1.getSerialNumber());
payOrderInfoDto1.setPayType(byId1.getPaymentType());
payOrderInfoDto1.setPayAmount(byId1.getPaymentAmount());
payOrderInfoDto1.setPayTime(byId1.getCreateTime());
payOrderInfoDto1.setRefundAmount(byId1.getRefundAmount());
payOrderInfoDto1.setRechargeAmount(byId1.getPaymentAmount());
payOrderInfoDto1.setFinalAmount(byId1.getPaymentAmount().subtract(byId1.getRefundAmount()));
return R.ok(payOrderInfoDto1);
case 3:
TVipOrder byId2 = vipOrderService.getById(orderId);
PayOrderInfoDto payOrderInfoDto2 = new PayOrderInfoDto();
payOrderInfoDto2.setOrderId(byId2.getId().toString());
payOrderInfoDto2.setCode(byId2.getCode());
payOrderInfoDto2.setTradeNo(byId2.getSerialNumber());
payOrderInfoDto2.setPayType(byId2.getPaymentType());
payOrderInfoDto2.setPayAmount(byId2.getPaymentAmount());
payOrderInfoDto2.setPayTime(byId2.getCreateTime());
payOrderInfoDto2.setRefundAmount(byId2.getRefundAmount());
payOrderInfoDto2.setRechargeAmount(byId2.getPaymentAmount());
payOrderInfoDto2.setFinalAmount(byId2.getPaymentAmount().subtract(byId2.getRefundAmount()));
return R.ok(payOrderInfoDto2);
//todo luo 停车场订单
case 4:
R recordById = parkingLotClient.getRecordById(orderId);
TParkingRecord byId3 =recordById.getData();
PayOrderInfoDto payOrderInfoDto3 = new PayOrderInfoDto();
payOrderInfoDto3.setOrderId(byId3.getId().toString());
payOrderInfoDto3.setCode(byId3.getCode());
payOrderInfoDto3.setPayTime(byId3.getCreateTime());
payOrderInfoDto3.setRechargeAmount(byId3.getPayment());
return R.ok(payOrderInfoDto3);
}
return R.ok();
}
@ResponseBody
@GetMapping(value = "/pay/order/refund/detail")
@ApiOperation(value = "退款信息", tags = {"管理后台-支付订单-订单信息"})
public R refundDetail(Long orderId, Integer type) {
switch (type) {
case 1:
List byId = chargingOrderRefundService.lambdaQuery().eq(TChargingOrderRefund::getChargingOrderId, orderId).orderByDesc(TChargingOrderRefund::getRefundTime).list();
return R.ok(byId);
case 2:
List list = shoppingOrderRefundService.lambdaQuery().eq(TShoppingOrderRefund::getShoppingOrderId, orderId).orderByDesc(TShoppingOrderRefund::getRefundTime).list();
return R.ok(list);
case 3:
List list1 = vipOrderRefundService.lambdaQuery().eq(TVipOrderRefund::getVipOrderId, orderId).orderByDesc(TVipOrderRefund::getRefundTime).list();
return R.ok(list1);
}
return R.ok();
}
@ResponseBody
@GetMapping(value = "/pay/order/charging")
@ApiOperation(value = "充电信息", tags = {"管理后台-支付订单-订单信息"})
public R refundDetail(Long orderId) {
PayOrderChargingInfo payOrderChargingInfo = new PayOrderChargingInfo();
TChargingOrder byId = chargingOrderService.getById(orderId);
List data = siteClient.getSiteByIds(Collections.singletonList(byId.getSiteId())).getData();
payOrderChargingInfo.setSiteName(data.get(0).getName());
TChargingPile data1 = chargingPileClient.getChargingPileById(byId.getChargingPileId()).getData();
payOrderChargingInfo.setChargingName(data1.getName());
TChargingGun data2 = chargingGunClient.getChargingGunById(byId.getChargingGunId()).getData();
payOrderChargingInfo.setGunName(data2.getName());
payOrderChargingInfo.setCarNum(byId.getPlateNum());
payOrderChargingInfo.setTChargingOrder(byId);
Long count = chargingOrderAccountingStrategyService.lambdaQuery().eq(TChargingOrderAccountingStrategy::getChargingOrderId, orderId).count();
payOrderChargingInfo.setPeriodCount(count);
if (byId.getAppUserCarId()!=null && 0 != byId.getAppUserCarId()) {
List carid = new ArrayList<>();
carid.add(byId.getAppUserCarId());
R> carByIds = appUserCarClient.getCarByIds(carid);
payOrderChargingInfo.setCarNum(carByIds.getData().get(0).getLicensePlate());
}else{
payOrderChargingInfo.setCarNum(byId.getPlateNum());
}
payOrderChargingInfo.setStartTime(byId.getStartTime());
payOrderChargingInfo.setEndTime(byId.getEndTime());
payOrderChargingInfo.setTimeCount(payOrderChargingInfo.calculateDuration());
return R.ok(payOrderChargingInfo);
}
@ResponseBody
@GetMapping(value = "/pay/order/charging/details")
@ApiOperation(value = "充电明细", tags = {"管理后台-支付订单-订单信息"})
public R> chargingDetail(Long orderId) {
TChargingOrder chargingOrder = chargingOrderService.getById(orderId);
List list = chargingOrderAccountingStrategyService.lambdaQuery().eq(TChargingOrderAccountingStrategy::getChargingOrderId, orderId)
.orderByDesc(TChargingOrderAccountingStrategy::getStartTime).list();
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
for (TChargingOrderAccountingStrategy tChargingOrderAccountingStrategy : list) {
LocalDateTime createTime = chargingOrder.getStartTime();
String format = createTime.format(formatter);
String startTime = tChargingOrderAccountingStrategy.getStartTime();
if("00:00".equals(startTime)){
createTime = createTime.plusDays(1);
format = createTime.format(formatter);
}
tChargingOrderAccountingStrategy.setStartTime(format+" "+tChargingOrderAccountingStrategy.getStartTime());
tChargingOrderAccountingStrategy.setEndTime(format+" "+tChargingOrderAccountingStrategy.getEndTime());
}
//从新排序
list.sort(new Comparator() {
@Override
public int compare(TChargingOrderAccountingStrategy o1, TChargingOrderAccountingStrategy o2) {
String startTime = o1.getStartTime();
String startTime1 = o2.getStartTime();
LocalDateTime localDateTime = LocalDateTime.parse(startTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));
LocalDateTime localDateTime1 = LocalDateTime.parse(startTime1, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));
if(localDateTime.isBefore(localDateTime1)){
return -1;
}
if(localDateTime.isAfter(localDateTime1)){
return 1;
}
return 0;
}
});
return R.ok(list);
}
@RequiresPermissions(value = {"/paymentOrder/refund", "/paymentOrder/order", "/paymentOrder/specialRefund"}, logical = Logical.OR)
@ResponseBody
@PostMapping(value = "/pay/order/refund/list")
@ApiOperation(value = "列表", tags = {"管理后台-支付订单-退款订单"})
public R> refundList(@RequestBody ChargingRefundDto chargingRefundDto) {
Long userId = tokenService.getLoginUser().getUserid();
SysUser sysUser = sysUserClient.getSysUser(userId).getData();
if (sysUser != null && Integer.valueOf(2).equals(sysUser.getRoleType())) {
List siteIds = new ArrayList<>();
List sites = siteClient.getSiteListByUserId(userId).getData();
if (sites != null) {
for (GetSiteListDTO site : sites) {
siteIds.add(site.getId());
}
}
chargingRefundDto.setSiteIds(siteIds.isEmpty() ? Collections.singletonList(-1) : siteIds);
}
return chargingOrderService.getRefundList(chargingRefundDto);
}
public static List testing4(long total, long current, long size, List str){
List result = new ArrayList<>();
//获取初始化分页结构
com.ruoyi.order.util.Page page = new com.ruoyi.order.util.Page().getPage(total, size, current - 1);
//获取集合下标初始值
long startIndex = page.getStartIndex();
//获取集合下标结束值
long endInddex = 0;
if(startIndex + page.getCurrent() >= total || size > total){
endInddex = total;
}else {
endInddex = Math.min(startIndex + page.getSize(), total);
}
//如果输入的开始查询下标大于集合大小，则查询为空值
if(startIndex > total){
result = Collections.emptyList();
}else{
result = str.subList((int)startIndex,(int)endInddex);
}
return result;
}
@ResponseBody
@PostMapping(value = "/pay/order/refund/list1")
@ApiOperation(value = "列表1", tags = {"管理后台-支付订单-退款订单"})
public R> refundList1(@RequestBody ChargingRefundDto chargingRefundDto) {
return chargingOrderService.getRefundList(chargingRefundDto);
}
@RequiresPermissions(value = {"/chargingPileOrder"}, logical = Logical.OR)
@ResponseBody
@PostMapping(value = "/chargingOrder")
@ApiOperation(value = "充电桩订单列表", tags = {"管理后台-订单管理"})
public AjaxResult chargingOrder(@RequestBody ChargingOrderQuery dto) {
TCharingOrderVO res = chargingOrderService.chargingOrder(dto);
return AjaxResult.success(res);
}
@RequiresPermissions(value = {"/chargingPileOrder"}, logical = Logical.OR)
@ResponseBody
@PostMapping(value = "/chargingOrder/list")
@ApiOperation(value = "充电桩订单分页列表", tags = {"管理后台-订单管理"})
public AjaxResult> chargingOrderList(@RequestBody ChargingOrderQuery dto) {
PageInfo res = chargingOrderService.chargingOrderList(dto);
return AjaxResult.success(res);
}
@RequiresPermissions(value = {"/chargingPileOrder"}, logical = Logical.OR)
@ResponseBody
@PostMapping(value = "/chargingOrder/summary")
@ApiOperation(value = "充电桩订单汇总", tags = {"管理后台-订单管理"})
public AjaxResult chargingOrderSummary(@RequestBody ChargingOrderQuery dto) {
TCharingOrderVO res = chargingOrderService.chargingOrderSummary(dto);
return AjaxResult.success(res);
}
@RequiresPermissions(value = {"/chargingPileOrder"}, logical = Logical.OR)
@ResponseBody
@PostMapping(value = "/balanceIncomeDetail")
@ApiOperation(value = "充电桩订单余额收入明细", tags = {"管理后台-订单管理"})
public AjaxResult> balanceIncomeDetail(@RequestBody ChargingOrderQuery dto) {
List res = chargingOrderService.balanceIncomeDetail(dto);
return AjaxResult.success(res);
}
@RequiresPermissions(value = {"/chargingPileOrder/monitoring_record"}, logical = Logical.OR)
@ResponseBody
@GetMapping(value = "/chargingOrderInfo")
@ApiOperation(value = "充电桩订单列表查看详情", tags = {"管理后台-订单管理"})
public AjaxResult chargingOrderInfo(String strategyId) {
TChargingOrder byId = chargingOrderService.getById(strategyId);
ChargingOrderInfoVO chargingOrderInfoVO = new ChargingOrderInfoVO();
chargingOrderInfoVO.setCdElectronic(byId.getCurrent()!=null?byId.getCurrent().setScale(2, BigDecimal.ROUND_HALF_DOWN)+"":"");
chargingOrderInfoVO.setCdVoltage(byId.getVoltage()!=null?byId.getVoltage().setScale(2, BigDecimal.ROUND_HALF_DOWN)+"":"");
chargingOrderInfoVO.setSurplus(byId.getTotalElectricity()!=null?byId.getTotalElectricity().setScale(2, BigDecimal.ROUND_HALF_DOWN)+"":"");
chargingOrderInfoVO.setTotalPower(byId.getPower()!=null?byId.getPower().setScale(2, BigDecimal.ROUND_HALF_DOWN)+"":"");
if (byId.getAppUserCarId()!=null){
TAppUserCar data = appUserCarClient.getCarById(byId.getAppUserCarId()+"").getData();
if (data!=null){
chargingOrderInfoVO.setLicensePlate(data.getLicensePlate());
chargingOrderInfoVO.setVehicleBrand(data.getVehicleBrand());
chargingOrderInfoVO.setVehicleModel(data.getVehicleModel());
chargingOrderInfoVO.setVehicleUse(data.getVehicleUse());
}
}else{
chargingOrderInfoVO.setLicensePlate(byId.getPlateNum());
}
// 时段总服务费
List list = chargingOrderAccountingStrategyService.lambdaQuery().eq(TChargingOrderAccountingStrategy::getChargingOrderId, strategyId).orderByDesc(TChargingOrderAccountingStrategy::getStartTime).list();
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
for (TChargingOrderAccountingStrategy tChargingOrderAccountingStrategy : list) {
LocalDateTime createTime = byId.getStartTime();
String format = createTime.format(formatter);
String startTime = tChargingOrderAccountingStrategy.getStartTime();
if("00:00".equals(startTime)){
createTime = createTime.plusDays(1);
format = createTime.format(formatter);
}
tChargingOrderAccountingStrategy.setStartTime(format+" "+tChargingOrderAccountingStrategy.getStartTime());
tChargingOrderAccountingStrategy.setEndTime(format+" "+tChargingOrderAccountingStrategy.getEndTime());
// if (byId.getVipDiscountAmount()!=null && byId.getServiceCharge().compareTo(BigDecimal.ZERO) != 0){
// BigDecimal multiply = byId.getVipDiscountAmount().divide(byId.getServiceCharge(), 2)
// .multiply(tChargingOrderAccountingStrategy.getPeriodOriginalServicePrice());
// tChargingOrderAccountingStrategy.setVipDiscount(multiply);
// }
// if (byId.getCouponDiscountAmount()!=null && byId.getServiceCharge().compareTo(BigDecimal.ZERO) != 0){
// BigDecimal multiply = byId.getCouponDiscountAmount().divide(byId.getServiceCharge(), 2)
// .multiply(tChargingOrderAccountingStrategy.getPeriodOriginalServicePrice());
// tChargingOrderAccountingStrategy.setCouponDiscount(multiply);
// }
if(null == tChargingOrderAccountingStrategy.getCouponDiscount()){
tChargingOrderAccountingStrategy.setCouponDiscount(BigDecimal.ZERO);
}
}
//从新排序
list.sort(new Comparator() {
@Override
public int compare(TChargingOrderAccountingStrategy o1, TChargingOrderAccountingStrategy o2) {
String startTime = o1.getStartTime();
String startTime1 = o2.getStartTime();
LocalDateTime localDateTime = LocalDateTime.parse(startTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));
LocalDateTime localDateTime1 = LocalDateTime.parse(startTime1, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));
if(localDateTime.isBefore(localDateTime1)){
return -1;
}
if(localDateTime.isAfter(localDateTime1)){
return 1;
}
return 0;
}
});
chargingOrderInfoVO.setList(list);
return AjaxResult.success(chargingOrderInfoVO);
}
@Log(title = "【扫一扫】添加评价", businessType = BusinessType.INSERT,operatorType = OperatorType.MOBILE)
@ResponseBody
@PostMapping(value = "/addEvaluate")
@ApiOperation(value = "添加评价", tags = {"小程序-扫一扫"})
public AjaxResult getMyChargingOrderList(@RequestBody OrderEvaluateVo dto) {
dto.setAppUserId(tokenService.getLoginUserApplet().getUserId());
orderEvaluateService.addOrderEvaluate(dto);
return AjaxResult.success();
}
/**
* 查询用户最近一次充电记录使用的车辆
*
* @param
* @return
*/
@GetMapping(value = "/getCar/{id}")
public R getCar(@PathVariable("id")String id) {
List list = chargingOrderService.list(new LambdaQueryWrapper()
.eq(TChargingOrder::getAppUserId, id)
.isNotNull(TChargingOrder::getAppUserCarId));
if (!list.isEmpty()){
// 最近使用的车辆id
Long size = list.get(0).getAppUserCarId();
return R.ok(size);
}else{
return R.ok(-1L);
}
}
/**
* 查询会员在本月有多少次享受了充电折扣
* @param req
* @return
*/
@PostMapping(value = "/getChargingCount")
public R getChargingCount(@RequestBody TChargingCountQuery req) {
int size = chargingOrderService.list(new LambdaQueryWrapper()
.eq(TChargingOrder::getAppUserId, req.getUserId())
.eq(TChargingOrder::getRechargePaymentStatus, 2)
.between(TChargingOrder::getStartTime, req.getStartTime(), req.getEndTime())).size();
return R.ok(size);
}
//用户订单数量
@PostMapping(value = "/useOrderCount")
public R useOrderCount(@RequestParam("userId") Long userId) {
Long count = chargingOrderService.lambdaQuery().eq(TChargingOrder::getAppUserId, userId).count();
return R.ok(count);
}
/**
* 查询指定站点中实际发生过充电的用户ID
*/
@PostMapping(value = "/getAppUserIdsBySiteIds")
public R> getAppUserIdsBySiteIds(@RequestBody List siteIds) {
return R.ok(chargingOrderService.getAppUserIdsBySiteIds(siteIds));
}
//订单详情
@PostMapping(value = "/detail")
public R detail(@RequestParam("orderId") Long orderId) {
return R.ok(chargingOrderService.getById(orderId));
}
@PostMapping(value = "/getList")
public R> getList(@RequestParam("siteId") Integer siteId) {
List list = chargingOrderService.lambdaQuery().eq(TChargingOrder::getSiteId, siteId).list();
return R.ok(list);
}
@PostMapping(value = "/getBySiteIdAndTime")
public R> getBySiteIdAndTime(@RequestBody ChargingPercentProvinceDto chargingPercentProvinceDto) {
List groups = chargingOrderService.chargingOrderGroup(chargingPercentProvinceDto);
return R.ok(groups);
}
/**
* 根据站点id和时间区间查询订单数据
* @param chargingPercentProvinceDto
* @return
*/
@PostMapping(value = "/getOrderBySiteIdAndTime")
public R> getOrderBySiteIdAndTime(@RequestBody ChargingPercentProvinceDto chargingPercentProvinceDto){
LocalDate date1 = chargingPercentProvinceDto.getDate1();
LocalDate date2 = chargingPercentProvinceDto.getDate2();
String tripartitePlatformName = chargingPercentProvinceDto.getTripartitePlatformName();
List list = chargingOrderService.list(new LambdaQueryWrapper().in(TChargingOrder::getSiteId, chargingPercentProvinceDto.getSiteIds())
.between(null != date1 && null != date2, TChargingOrder::getPayTime, date1.atTime(0, 0, 0), date2.atTime(23, 59, 59))
.eq(TChargingOrder::getDelFlag, 0).eq(TChargingOrder::getStatus, 5)
.eq(StringUtils.isNotEmpty(tripartitePlatformName), TChargingOrder::getOrderSource, 2)
.eq(StringUtils.isNotEmpty(tripartitePlatformName), TChargingOrder::getTripartitePlatformName, tripartitePlatformName));
return R.ok(list);
}
/**
* 根据充电枪id获取正在进行中的订单
* @param chargingGunId 充电枪id
* @return
*/
@PostMapping(value = "/getOrderDetailByGunId")
public R getOrderDetailByGunId(@RequestParam("chargingGunId") Integer chargingGunId) {
TChargingOrder one = chargingOrderService.getOne(new LambdaQueryWrapper().eq(TChargingOrder::getChargingGunId, chargingGunId)
.eq(TChargingOrder::getDelFlag, 0).eq(TChargingOrder::getStatus, 3));
return R.ok(one);
}
@ResponseBody
@GetMapping(value = "/getMyChargingOrderList")
@ApiOperation(value = "获取充电记录列表", tags = {"小程序-充电记录"})
public AjaxResult> getMyChargingOrderList(GetMyChargingOrderList query) {
Map orderList = chargingOrderService.getMyChargingOrderList(query);
return AjaxResult.success(orderList);
}
@ResponseBody
@GetMapping(value = "/getMyChargingOrderInfo")
@ApiOperation(value = "获取充电记订单明细", tags = {"小程序-充电记录"})
public AjaxResult getMyChargingOrderInfo(String id) {
TChargingOrder tChargingOrder = chargingOrderService.getById(id);
Long userId = tokenService.getLoginUserApplet().getUserId();
if(!tChargingOrder.getAppUserId().equals(userId)){
return AjaxResult.error("权限不足");
}
MyChargingOrderInfo myChargingOrderInfo = chargingOrderService.getMyChargingOrderInfo(id);
return AjaxResult.success(myChargingOrderInfo);
}
@ResponseBody
@GetMapping(value = "/getNoInvoicedOrder")
@ApiOperation(value = "获取未开票的订单数据", tags = {"小程序-充电发票"})
public AjaxResult> getNoInvoicedOrder(GetNoInvoicedOrder query) {
List list = chargingOrderService.getNoInvoicedOrder(query);
return AjaxResult.success(list);
}
@Log(title = "【扫一扫】支付充电充值费用", businessType = BusinessType.UPDATE,operatorType = OperatorType.MOBILE)
@ResponseBody
@PostMapping(value = "/paymentChargingOrder")
@ApiOperation(value = "支付充电充值费用", tags = {"小程序-扫一扫"})
public AjaxResult paymentChargingOrder(@RequestBody AddChargingOrder addChargingOrder) {
return chargingOrderService.paymentChargingOrder(addChargingOrder);
}
@ResponseBody
@GetMapping(value = "/confirmIcbcPayment")
@ApiOperation(value = "主动确认工行充电支付结果", tags = {"小程序-扫一扫"})
public AjaxResult confirmIcbcPayment(@RequestParam("orderCode") String orderCode) {
return chargingOrderService.confirmIcbcPayment(orderCode);
}
@RequiresPermissions(value = {"/chargingPileOrder", "/paymentOrder/refund"}, logical = Logical.AND)
@PostMapping("/icbc/fund/payment-query")
@ApiOperation(value = "管理后台查询工行支付订单", tags = {"后台-充电桩订单"})
public AjaxResult queryIcbcAdminPayment(@RequestBody IcbcAdminFundOperationReq request) {
return AjaxResult.success(chargingOrderService.queryIcbcAdminPayment(request == null ? null : request.getOrderCode()));
}
@RequiresPermissions(value = {"/chargingPileOrder", "/paymentOrder/refund"}, logical = Logical.AND)
@PostMapping("/icbc/fund/refund")
@ApiOperation(value = "管理后台工行主订单退款", tags = {"后台-充电桩订单"})
public AjaxResult refundIcbcAdminPayment(@RequestBody IcbcAdminFundOperationReq request) {
return AjaxResult.success(chargingOrderService.refundIcbcAdminPayment(request));
}
@RequiresPermissions(value = {"/chargingPileOrder", "/paymentOrder/refund"}, logical = Logical.AND)
@PostMapping("/icbc/fund/sub-orders")
@ApiOperation(value = "管理后台查询工行分账子订单", tags = {"后台-充电桩订单"})
public AjaxResult> queryIcbcAdminSubOrders(@RequestBody IcbcAdminFundOperationReq request) {
return AjaxResult.success(chargingOrderService.queryIcbcAdminSubOrders(request == null ? null : request.getOrderCode()));
}
@RequiresPermissions(value = {"/chargingPileOrder", "/paymentOrder/refund"}, logical = Logical.AND)
@PostMapping("/icbc/fund/sub-order-refund")
@ApiOperation(value = "管理后台工行分账子订单退款", tags = {"后台-充电桩订单"})
public AjaxResult refundIcbcAdminSubOrder(@RequestBody IcbcAdminFundOperationReq request) {
return AjaxResult.success(chargingOrderService.refundIcbcAdminSubOrder(request));
}
@ResponseBody
@GetMapping("/simulation/current")
@ApiOperation(value = "查询当前枪可模拟结算的已支付订单", tags = {"小程序-模拟充电"})
public AjaxResult getCurrentSimulationOrder(@RequestParam("gunId") Integer gunId) {
return AjaxResult.success(chargingOrderService.getCurrentSimulationOrder(gunId));
}
@ResponseBody
@PostMapping("/simulation/complete")
@ApiOperation(value = "模拟完成充电并执行真实结算", tags = {"小程序-模拟充电"})
public AjaxResult