package com.ruoyi.errand.service.impl;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.errand.constant.DelFlagConstant;
|
import com.ruoyi.errand.domain.AddressBook;
|
import com.ruoyi.errand.domain.AppUser;
|
import com.ruoyi.errand.domain.Community;
|
import com.ruoyi.errand.domain.Order;
|
import com.ruoyi.errand.mapper.AddressBookMapper;
|
import com.ruoyi.errand.mapper.AppUserMapper;
|
import com.ruoyi.errand.mapper.CommunityMapper;
|
import com.ruoyi.errand.mapper.OrderMapper;
|
import com.ruoyi.errand.object.dto.app.ConfirmOrderDTO;
|
import com.ruoyi.errand.object.dto.app.OrderStatsVO;
|
import com.ruoyi.errand.object.dto.app.SetConfirmOrderDTO;
|
import com.ruoyi.errand.object.dto.sys.FinanceStatisticsDTO;
|
import com.ruoyi.errand.object.dto.sys.OrderPageListDTO;
|
import com.ruoyi.errand.object.vo.app.AppUserOrderListVO;
|
import com.ruoyi.errand.object.vo.app.ConfirmOrderVO;
|
import com.ruoyi.errand.object.vo.app.OrderDetailVO;
|
import com.ruoyi.errand.object.vo.app.OrderTopInfoVO;
|
import com.ruoyi.errand.object.vo.sys.FinanceStatisticsVO;
|
import com.ruoyi.errand.object.vo.sys.OrderPageListVO;
|
import com.ruoyi.errand.object.vo.sys.OrderSysDetailVO;
|
import com.ruoyi.errand.object.vo.sys.UserStatsVO;
|
import com.ruoyi.errand.service.OrderService;
|
import com.ruoyi.errand.utils.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.security.core.context.SecurityContextHolder;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.text.SimpleDateFormat;
|
import java.time.*;
|
import java.time.format.DateTimeFormatter;
|
import java.time.temporal.ChronoUnit;
|
import java.time.temporal.TemporalUnit;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Service
|
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {
|
|
@Resource
|
private AddressBookMapper addressBookMapper;
|
|
@Resource
|
private CommunityMapper communityMapper;
|
@Autowired
|
private RedisTemplate redisTemplate;
|
@Autowired
|
private AppUserMapper appUserMapper;
|
@Resource
|
private DeliveryWebSocket deliveryWebSocket;
|
|
@Override
|
public ConfirmOrderVO confirmOrder(ConfirmOrderDTO confirmOrderDTO) {
|
|
ConfirmOrderVO confirmOrderVO = new ConfirmOrderVO();
|
BeanUtils.copyProperties(confirmOrderDTO, confirmOrderVO);
|
|
//小区是否存在
|
Community community = communityMapper.selectById(confirmOrderDTO.getCommodityId());
|
if (community==null||community.getDelFlag().equals(DelFlagConstant.DELETE)){
|
throw new ServiceException("小区不存在");
|
}
|
if (community.getStatus()==1){
|
throw new ServiceException("小区已被冻结");
|
}
|
//将地址簿信息查询出来
|
AddressBook addressBook = addressBookMapper.selectById(confirmOrderDTO.getAddressBookId());
|
confirmOrderVO.setRecipientName(addressBook.getRecipientName());
|
confirmOrderVO.setRecipientPhone(addressBook.getRecipientPhone());
|
confirmOrderVO.setAddressDetail(addressBook.getAddressDetail());
|
|
//查询用户信息，设置用户支付信息
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
confirmOrderVO.setCommunityId(confirmOrderDTO.getCommodityId());
|
confirmOrderVO.setCommunityName(community.getName());
|
//两种支付方式
|
if (confirmOrderDTO.getPayMethod()==0){
|
confirmOrderVO.setPayMethod(0);
|
//在线支付
|
confirmOrderVO.setOrderAmount(community.getFeeAmount());//订单金额
|
confirmOrderVO.setPaymentAmount(community.getFeeAmount());//支付金额
|
|
}else if (confirmOrderDTO.getPayMethod()==1){
|
confirmOrderVO.setPayMethod(1);
|
//会员支付
|
if (appuser.getEndTime().isAfter(LocalDateTime.now())) {
|
//过期了
|
throw new ServiceException("支付错误：会员已到期");
|
}
|
confirmOrderVO.setOrderAmount(community.getFeeAmount());
|
confirmOrderVO.setPaymentAmount(BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP));//支付金额
|
|
}else {
|
throw new ServiceException("支付方式错误");
|
}
|
|
return confirmOrderVO;
|
|
|
}
|
|
@Override
|
public R orderPayment(ConfirmOrderDTO confirmOrderDTO) {
|
Order order = new Order();
|
BeanUtils.copyProperties(confirmOrderDTO, order);
|
//小区是否存在
|
Community community = communityMapper.selectById(confirmOrderDTO.getCommodityId());
|
if (community==null||community.getDelFlag().equals(DelFlagConstant.DELETE)){
|
throw new ServiceException("小区不存在");
|
}
|
if (community.getStatus()==1){
|
throw new ServiceException("小区已被冻结");
|
}
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
|
order.setOrderNumber("QJS" + getNumber(3) + sdf.format(new Date()));
|
|
//将地址簿信息查询出来
|
AddressBook addressBook = addressBookMapper.selectById(confirmOrderDTO.getAddressBookId());
|
order.setRecipientName(addressBook.getRecipientName());
|
order.setRecipientPhone(addressBook.getRecipientPhone());
|
order.setAddressDetail(addressBook.getAddressDetail());
|
|
//查询用户信息，设置用户支付信息
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
if (appuser.getFirstOrder()==1){
|
appuser.setFirstOrder(0);
|
appUserMapper.updateById(appuser);
|
}
|
order.setAppUserId(appuser.getId());
|
order.setCommunityId(confirmOrderDTO.getCommodityId());
|
order.setCommunityName(community.getName());
|
|
order.setPayMethod(confirmOrderDTO.getPayMethod());//支付方式
|
order.setPayStatus(1);//待付款
|
|
//两种支付方式
|
if (confirmOrderDTO.getPayMethod()==0){
|
order.setPayMethod(0);
|
//在线支付
|
order.setOrderAmount(community.getFeeAmount());//订单金额
|
order.setPaymentAmount(community.getFeeAmount());//支付金额
|
|
}else if (confirmOrderDTO.getPayMethod()==1){
|
order.setPayMethod(1);
|
if (appuser.getEndTime().isBefore(LocalDateTime.now())) {
|
//过期了
|
throw new ServiceException("支付错误：会员已到期");
|
}
|
order.setOrderAmount(community.getFeeAmount());
|
order.setPaymentAmount(BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP));//支付金额
|
}else {
|
throw new ServiceException("支付方式错误");
|
}
|
this.save(order);//先保存订单
|
|
|
//判断需要支付的金额是否大于0
|
BigDecimal paymentMoney = order.getPaymentAmount();
|
if ( BigDecimal.ZERO.compareTo(paymentMoney) < 0){
|
//调起微信支付
|
String agencyMatters = order.getAgencyMatters();
|
UniPayResult uniPayResult = PaymentUtil.uniPay(order.getOrderNumber(), paymentMoney.doubleValue(), "代办事项",
|
agencyMatters, "", "/app/order/orderPaymentCallback", appuser.getWxOpenid(), null);
|
if(null == uniPayResult || !"100".equals(uniPayResult.getRa_Code())){
|
return R.fail(null == uniPayResult ? "支付失败" : uniPayResult.getRb_CodeMsg());
|
}
|
String rc_result = uniPayResult.getRc_Result();
|
JSONObject jsonObject = JSON.parseObject(rc_result);
|
jsonObject.put("orderId", order.getId().toString());
|
//将支付数据添加到redis队列中，便于定时任务去校验是否完成支付，没有完成支付支付，15分钟后关闭订单。
|
long second = LocalDateTime.now().plusMinutes(15).toEpochSecond(ZoneOffset.UTC);
|
redisTemplate.opsForZSet().add("OrderPayment", order.getOrderNumber(), second);
|
return R.ok(jsonObject.toJSONString());
|
}
|
|
//会员支付或支付金额为0直接支付成功
|
order.setOrderStatus(1);//待确认
|
order.setPayStatus(2);//已支付
|
order.setOrderTime(LocalDateTime.now());//下单时间
|
this.updateById(order);
|
Map<String,Object> courier= appUserMapper.getCourierByCommunityId(order.getCommunityId());
|
if (courier == null || courier.isEmpty()) {
|
log.warn("未找到社区ID={}对应的骑手", order.getCommunityId());
|
return R.ok();
|
}
|
//todo 短信通知
|
sendSmsNotificationToCourier(courier,order);
|
//小程序弹窗通知
|
notifyDeliveryPerson((Long) courier.get("id"), order,1);//1=新订单
|
|
//登录访问
|
return R.ok(order.getId().toString());
|
}
|
|
|
/**
|
* 发送短信通知给骑手
|
*/
|
private void sendSmsNotificationToCourier(Map<String, Object> courier, Order order) {
|
try {
|
String phoneNumber = (String) courier.get("phone");
|
if (StringUtils.isBlank(phoneNumber)) {
|
log.warn("骑手手机号为空，无法发送短信通知");
|
return;
|
}
|
// String content = String.format("您有新的跑腿订单(订单号:%s)，请及时处理!", order.getOrderNumber());
|
//todo 调用短信服务API
|
// SMSUtil.sendSms(order.getOrderNumber(),phoneNumber, "", "");
|
log.info("已发送短信通知给骑手: {}", phoneNumber);
|
} catch (Exception e) {
|
log.error("发送短信通知失败", e);
|
}
|
}
|
|
/**
|
* 发送弹窗通知
|
*/
|
private void notifyDeliveryPerson(Long deliveryPersonId, Order order,Integer type) {
|
JSONObject message = new JSONObject();
|
message.put("type",type==1?"new_order":"update_order");
|
message.put("orderId", order.getId());
|
message.put("orderTime", order.getOrderTime());
|
deliveryWebSocket.sendNotification(deliveryPersonId.toString(), message.toJSONString());
|
}
|
|
@Override
|
public R orderPaymentCallback(UniPayCallbackResult uniPayCallbackResult) {
|
Order order = this.getBaseMapper().selectOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNumber, uniPayCallbackResult.getR2_OrderNo()));
|
if(null == order || order.getPayStatus() == 2){
|
return R.ok();
|
}
|
order.setOrderStatus(1);//待确认
|
order.setPayStatus(2);//已支付
|
order.setOrderTime(LocalDateTime.now());//下单时间
|
String r7TrxNo = uniPayCallbackResult.getR9_BankTrxNo();
|
order.setSerialNumber(r7TrxNo);
|
this.updateById(order);
|
|
Map<String,Object> courier= appUserMapper.getCourierByCommunityId(order.getCommunityId());
|
if (courier == null || courier.isEmpty()) {
|
log.warn("未找到社区ID={}对应的骑手", order.getCommunityId());
|
return R.ok();
|
}
|
//todo 短信通知
|
sendSmsNotificationToCourier(courier,order);
|
//小程序弹窗通知
|
notifyDeliveryPerson((Long) courier.get("id"), order,1);//1=新订单
|
return R.ok();
|
}
|
|
/**
|
* 定时任务关闭订单
|
*/
|
@Override
|
public void closeOrder() {
|
//订单支付数据
|
long second = LocalDateTime.now().toEpochSecond(ZoneOffset.UTC);
|
Set<String> orderPayment = redisTemplate.opsForZSet().rangeByScore("OrderPayment", 0, second);
|
if(orderPayment.size() > 0){
|
List<Order> list = this.getBaseMapper().selectList(new LambdaQueryWrapper<Order>().in(Order::getOrderNumber, orderPayment));
|
for (Order order : list) {
|
if(null == order || order.getPayStatus() != 1){
|
//不在待支付中的，移除
|
redisTemplate.opsForZSet().remove("OrderPayment", order.getOrderNumber());
|
continue;
|
}
|
//开始执行关闭订单操作
|
CloseOrderResult closeOrderResult = PaymentUtil.closeOrder(order.getOrderNumber());
|
if((null == closeOrderResult || !closeOrderResult.getRa_Status().equals("100")) &&
|
Arrays.asList("0", "4", "101", "10080000", "10080002", "10083004", "10083005").contains(closeOrderResult.getRb_Code())){
|
redisTemplate.opsForZSet().add("OrderPayment", order.getOrderNumber(), 0);
|
log.error("关闭订单失败：{}---->{}", order.getOrderNumber(), JSON.toJSONString(closeOrderResult));
|
}
|
redisTemplate.opsForZSet().remove("OrderPayment", order.getOrderNumber());
|
//删除订单
|
order.setDelFlag(DelFlagConstant.DELETE);
|
this.updateById(order);
|
}
|
}
|
|
}
|
|
@Override
|
public IPage<AppUserOrderListVO> getAppUserOrderList(Integer pageNum, Integer pageSize, Integer orderStatus) {
|
IPage<Order> page = new Page<>(pageNum, pageSize);
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
return this.baseMapper.getAppUserOrderList(page,orderStatus,appuser.getId());
|
}
|
|
@Override
|
public OrderDetailVO getOrderDetail(Integer id) {
|
return this.baseMapper.getOrderDetail(id);
|
}
|
|
@Override
|
public void setOrderInfo(SetConfirmOrderDTO setConfirmOrderDTO) {
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
//判断订单是否存在
|
Order order = this.getById(setConfirmOrderDTO.getId());
|
if (order==null
|
||order.getDelFlag().equals(DelFlagConstant.DELETE)
|
||!Objects.equals(order.getAppUserId(), appuser.getId())){
|
throw new ServiceException("订单id错误");
|
}
|
if (order.getOrderStatus()!=1){
|
throw new ServiceException("订单状态错误");
|
}
|
//判断地址簿id是否存在
|
if (setConfirmOrderDTO.getAddressBookId()!=null){
|
AddressBook addressBook = addressBookMapper.selectById(setConfirmOrderDTO.getAddressBookId());
|
if (addressBook==null||addressBook.getDel_flag().equals(DelFlagConstant.DELETE)){
|
throw new ServiceException("该地址簿id不存在");
|
}
|
if (!Objects.equals(addressBook.getCommunityId(), order.getCommunityId())){
|
throw new ServiceException("不能更改为其他小区");
|
}
|
order.setRecipientPhone(addressBook.getRecipientPhone());
|
order.setRecipientName(addressBook.getRecipientName());
|
order.setAddressDetail(addressBook.getAddressDetail());
|
}
|
//代办事项等更改
|
if (setConfirmOrderDTO.getNum()!=null){
|
order.setNum(setConfirmOrderDTO.getNum());
|
}
|
if (setConfirmOrderDTO.getRemark()!=null){
|
order.setRemark(setConfirmOrderDTO.getRemark());
|
}
|
if (setConfirmOrderDTO.getAgencyMatters()!=null){
|
order.setAgencyMatters(setConfirmOrderDTO.getAgencyMatters());
|
}
|
if (setConfirmOrderDTO.getPics()!=null){
|
order.setPics(setConfirmOrderDTO.getPics());
|
}
|
//修改
|
this.updateById(order);
|
|
Map<String,Object> courier= appUserMapper.getCourierByCommunityId(order.getCommunityId());
|
if (courier == null || courier.isEmpty()) {
|
log.warn("未找到社区ID={}对应的骑手", order.getCommunityId());
|
return;
|
}
|
//小程序弹窗通知
|
notifyDeliveryPerson((Long) courier.get("id"), order,2);//2=修改订单
|
}
|
|
@Override
|
public void cancelOrder(Integer id) {
|
//判断订单
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
//判断订单是否存在
|
Order order = this.getById(id);
|
if (order==null
|
||order.getDelFlag().equals(DelFlagConstant.DELETE)
|
||!Objects.equals(order.getAppUserId(), appuser.getId())){
|
throw new ServiceException("订单id错误");
|
}
|
//判断状态
|
if (order.getOrderStatus()!=1){
|
throw new ServiceException("订单状态错误");
|
}
|
//判断支付类型
|
if ( order.getPayMethod()==0){
|
//在线支付 回退
|
order.setOrderStatus(3);//已取消
|
R r = refundPayMoney(order);//退款
|
if (200 == r.getCode()) {
|
this.updateById(order);
|
}
|
}else {
|
order.setOrderStatus(3);//已取消
|
this.updateById(order);
|
}
|
|
}
|
|
@Override
|
public R refundPayMoneyCallback(RefundCallbackResult refundCallbackResult) {
|
String code = refundCallbackResult.getR3_RefundOrderNo().substring(1);
|
Order order = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNumber, code));
|
if (null == order || order.getPayStatus() == 1 || order.getOrderStatus() == 6) {
|
return R.ok();
|
}
|
order.setRefundCode(refundCallbackResult.getR5_RefundTrxNo());
|
order.setRefundStatus(2);
|
order.setRefundTime(LocalDateTime.now());
|
this.updateById(order);
|
return R.ok();
|
}
|
|
@Override
|
public OrderTopInfoVO orderTopInfo(Integer communityId) {
|
|
OrderTopInfoVO orderTopInfoVO = new OrderTopInfoVO();
|
//总金额
|
Map<String, Object> total = this.baseMapper.getOrderTopInfoByDate(communityId,null,null);
|
orderTopInfoVO.setTodayOrderNum(Integer.valueOf(String.valueOf(total.get("num"))) );
|
orderTopInfoVO.setTotalOrderAmount(new BigDecimal(String.valueOf(total.get("amount"))));
|
|
//今日
|
LocalDateTime now = LocalDateTime.now();
|
LocalDateTime start = now.with(LocalTime.MIN);
|
LocalDateTime end = now.with(LocalTime.MAX);
|
Map<String, Object> today = this.baseMapper.getOrderTopInfoByDate(communityId,start,end);
|
orderTopInfoVO.setTodayOrderNum(Integer.valueOf(String.valueOf(today.get("num"))));
|
orderTopInfoVO.setTodayOrderAmount(new BigDecimal(String.valueOf(today.get("amount"))));
|
|
//当月
|
YearMonth currentMonth = YearMonth.now();
|
start = currentMonth.atDay(1).atStartOfDay();
|
end = currentMonth.atEndOfMonth().atTime(LocalTime.MAX);
|
Map<String, Object> mouth = this.baseMapper.getOrderTopInfoByDate(communityId,start,end);
|
orderTopInfoVO.setMouthOrderNum(Integer.valueOf(String.valueOf(mouth.get("num"))));
|
orderTopInfoVO.setMouthOrderAmount(new BigDecimal(String.valueOf(mouth.get("amount"))));
|
|
//本季度
|
YearMonth thisMonth = YearMonth.now();
|
YearMonth firstMonthOfQuarter = thisMonth.with(
|
Month.of(((thisMonth.getMonthValue() - 1) / 3) * 3 + 1));
|
YearMonth lastMonthOfQuarter = firstMonthOfQuarter.plusMonths(2);
|
start = firstMonthOfQuarter.atDay(1).atStartOfDay();
|
end = lastMonthOfQuarter.atEndOfMonth().atTime(LocalTime.MAX) ;
|
Map<String, Object> quarter = this.baseMapper.getOrderTopInfoByDate(communityId,start,end);
|
orderTopInfoVO.setQuarterOrderNum(Integer.valueOf(String.valueOf(quarter.get("num"))));
|
orderTopInfoVO.setQuarterOrderAmount(new BigDecimal(String.valueOf(quarter.get("amount"))));
|
|
//本年
|
int year = Year.now().getValue();
|
start = LocalDateTime.of(year, 1, 1, 0, 0); // 1月1日
|
end = LocalDateTime.of(year, 12, 31, 23, 59, 59); // 12月31日
|
Map<String, Object> currentYear = this.baseMapper.getOrderTopInfoByDate(communityId,start,end);
|
orderTopInfoVO.setYearOrderNum(Integer.valueOf(String.valueOf(currentYear.get("num"))));
|
orderTopInfoVO.setYearOrderAmount(new BigDecimal(String.valueOf(currentYear.get("amount"))));
|
return orderTopInfoVO;
|
}
|
|
@Override
|
public OrderStatsVO getOrderStats(LocalDateTime start, LocalDateTime end, String datePattern, Integer communityId) {
|
OrderStatsVO orderStatsVO = new OrderStatsVO();
|
// 1. 查询按时间分组的用户数
|
List<Map<String, Object>> stats = this.getBaseMapper().countGroupByDate(start, end, datePattern , communityId);
|
|
// 2. 生成完整的日期序列并填充数据
|
fillDateAndValue(orderStatsVO, start, end, datePattern, stats);
|
|
return orderStatsVO;
|
}
|
|
@Override
|
public IPage<FinanceStatisticsVO> financeStatistics(FinanceStatisticsDTO dto) {
|
//查询出总的数量
|
IPage<FinanceStatisticsVO> page = new Page<>();
|
page.setTotal(this.getBaseMapper().selectPageTotal(dto));
|
List<FinanceStatisticsVO> list=this.getBaseMapper().financeStatistics(dto);
|
page.setRecords(list);
|
page.setSize(dto.getPageSize());
|
page.setCurrent(dto.getPageNum());
|
return page;
|
}
|
|
@Override
|
public List<FinanceStatisticsVO> export(FinanceStatisticsDTO dto) {
|
return this.getBaseMapper().export(dto);
|
}
|
|
|
|
@Override
|
public IPage<OrderPageListVO> getOrderPageList(OrderPageListDTO dto) {
|
IPage<OrderPageListVO> page = new Page<>(dto.getPageNum(),dto.getPageSize());
|
return this.getBaseMapper().getOrderPageList(page,dto);
|
}
|
|
@Override
|
public OrderSysDetailVO detail(Integer id) {
|
return this.getBaseMapper().detail(id);
|
}
|
|
@Override
|
public List<OrderPageListVO> orderExport(OrderPageListDTO dto) {
|
|
return this.getBaseMapper().orderExport(dto);
|
}
|
|
/**
|
* 填充空余时间
|
*/
|
private void fillDateAndValue(OrderStatsVO vo, LocalDateTime start, LocalDateTime end,
|
String datePattern, List<Map<String, Object>> stats) {
|
List<String> allDates = generateDateRange(start, end, datePattern);
|
Map<String, Integer> numMap = convertNumsToMap(stats);
|
Map<String, BigDecimal> amountMap = convertAmountToMap(stats);
|
|
List<String> dates = new ArrayList<>();
|
List<Integer> nums = new ArrayList<>();
|
|
List<BigDecimal> amounts = new ArrayList<>();
|
|
for (String date : allDates) {
|
dates.add(date);
|
nums.add(numMap.getOrDefault(date, 0)); // 无数据的日期补0
|
amounts.add(amountMap.getOrDefault(date,BigDecimal.ZERO.setScale(2, BigDecimal.ROUND_HALF_UP)));
|
}
|
|
vo.setDate(dates);
|
vo.setNumList(nums);
|
vo.setAmountList(amounts);
|
}
|
private Map<String, Integer> convertNumsToMap(List<Map<String, Object>> stats) {
|
return stats.stream()
|
.collect(Collectors.toMap(
|
stat -> String.valueOf(stat.get("date")),
|
stat -> Integer.valueOf(String.valueOf(stat.get("num")))
|
));
|
}
|
|
private Map<String, BigDecimal> convertAmountToMap(List<Map<String, Object>> stats) {
|
return stats.stream()
|
.collect(Collectors.toMap(
|
stat -> String.valueOf(stat.get("date")),
|
stat -> new BigDecimal(String.valueOf(stat.get("amount")))
|
));
|
}
|
|
private List<String> generateDateRange(LocalDateTime start, LocalDateTime end, String datePattern) {
|
List<String> dates = new ArrayList<>();
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(datePattern);
|
|
TemporalUnit unit = getTemporalUnit(datePattern);
|
LocalDateTime current = getInitialDateTime(start, datePattern);
|
|
while (!current.isAfter(end)) {
|
dates.add(current.format(formatter));
|
current = incrementDateTime(current, unit);
|
}
|
|
return dates;
|
}
|
|
private TemporalUnit getTemporalUnit(String datePattern) {
|
switch (datePattern) {
|
case "HH时": return ChronoUnit.HOURS;
|
case "EEEE":
|
case "dd日":
|
case "yyyy-MM-dd": return ChronoUnit.DAYS;
|
case "MM月": return ChronoUnit.MONTHS;
|
default: return ChronoUnit.DAYS;
|
}
|
}
|
|
private LocalDateTime getInitialDateTime(LocalDateTime datetime, String datePattern) {
|
switch (datePattern) {
|
case "HH时": return datetime.withMinute(0).withSecond(0).withNano(0);
|
case "MM月": return datetime.withDayOfMonth(1);
|
default: return datetime;
|
}
|
}
|
|
private LocalDateTime incrementDateTime(LocalDateTime current, TemporalUnit unit) {
|
if (unit == ChronoUnit.HOURS) return current.plusHours(1);
|
if (unit == ChronoUnit.DAYS) return current.plusDays(1);
|
if (unit == ChronoUnit.MONTHS) return current.plusMonths(1);
|
return current.plusDays(1);
|
}
|
/**
|
* 返回订单支付金额
|
*/
|
public R refundPayMoney(Order order) {
|
//开始退款
|
BigDecimal paymentAmount = order.getPaymentAmount();
|
if (BigDecimal.ZERO.compareTo(order.getPaymentAmount()) < 0) {//支付的金额是否大于0
|
//微信退款
|
RefundResult refund = PaymentUtil.refund(order.getOrderNumber(), "R" + order.getOrderNumber(), paymentAmount.doubleValue(),
|
"/app/order/refundPayMoneyCallback");
|
if (!"100".equals(refund.getRa_Status())) {
|
return R.fail(refund.getRc_CodeMsg());//退款失败
|
}
|
}
|
return R.ok();
|
}
|
|
|
public String getNumber(Integer size){
|
StringBuilder str = new StringBuilder();
|
for (int i = 0; i < size; i++) {
|
str.append(Double.valueOf(Math.random() * 10).intValue());
|
}
|
return str.toString();
|
}
|
}
|
