package com.ruoyi.system.service.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.ruoyi.common.utils.OrderNos;
|
import com.ruoyi.system.dto.CreateOrderDto;
|
import com.ruoyi.system.dto.CreateOrderRequest;
|
import com.ruoyi.system.dto.VisitPerson;
|
import com.ruoyi.system.model.TTicketOrder;
|
import com.ruoyi.system.mapper.TTicketOrderMapper;
|
import com.ruoyi.system.model.TTourist;
|
import com.ruoyi.system.query.AppletOrderListQuery;
|
import com.ruoyi.system.query.TTicketOrderQuery;
|
import com.ruoyi.system.service.TAppUserService;
|
import com.ruoyi.system.service.TTicketOrderService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.system.service.TTouristService;
|
import com.ruoyi.system.utils.ticketUtil.TicketUtil;
|
import com.ruoyi.system.vo.CreateOrderVo;
|
import com.ruoyi.system.vo.TTicketOrderVo;
|
import org.springframework.stereotype.Service;
|
|
import java.math.BigDecimal;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author L
|
* @since 2025-12-30
|
*/
|
@Service
|
public class TTicketOrderServiceImpl extends ServiceImpl<TTicketOrderMapper, TTicketOrder> implements TTicketOrderService {
|
|
|
private final TicketUtil ticketUtil;
|
private final TTouristService tTouristService;
|
|
|
|
|
public TTicketOrderServiceImpl(TicketUtil ticketUtil, TTouristService tTouristService) {
|
this.ticketUtil = ticketUtil;
|
this.tTouristService = tTouristService;
|
}
|
|
|
@Override
|
public Page<TTicketOrderVo> pageList(Page<TTicketOrderVo> page, TTicketOrderQuery query) {
|
List<TTicketOrderVo> list = this.baseMapper.pageList(page,query);
|
page.setRecords( list);
|
return page;
|
}
|
|
@Override
|
public Page<TTicketOrderVo> getOrderList(AppletOrderListQuery query, Integer userId) {
|
Page<TTicketOrderVo> page = new Page<>(query.getPageNum(), query.getPageSize());
|
List<TTicketOrderVo> list = this.baseMapper.getOrderList(page,query,userId);
|
page.setRecords(list);
|
return page;
|
}
|
|
@Override
|
public Page<TTicketOrderVo> refundPageList(Page<TTicketOrderVo> page, TTicketOrderQuery query) {
|
List<TTicketOrderVo> list = this.baseMapper.refundPageList(page,query);
|
page.setRecords( list);
|
return page;
|
}
|
|
@Override
|
public boolean addOrder(CreateOrderDto dto, Integer userId) throws Exception {
|
|
CreateOrderRequest request = new CreateOrderRequest();
|
String did = OrderNos.getDid();
|
request.setOrderId(did);
|
request.setTravelDate(dto.getTravelDate());
|
request.setQuantity(dto.getQuantity());
|
request.setProductId(dto.getProductId());
|
|
if (dto.getQuantity()!=dto.getVisitPersons().size()) {
|
throw new RuntimeException("人数不匹配");
|
}
|
|
List<TTourist> tTourists = tTouristService.listByIds(dto.getVisitPersons());
|
ArrayList<VisitPerson> visitPeople = new ArrayList<>();
|
for (TTourist tTourist : tTourists) {
|
VisitPerson visitPerson = new VisitPerson();
|
visitPerson.setName(tTourist.getName());
|
visitPerson.setMobile(tTourist.getPhone());
|
visitPerson.setIdCard(tTourist.getIdCard());
|
visitPeople.add(visitPerson);
|
}
|
request.setVisitPersons(visitPeople);
|
CreateOrderVo createOrderVo = ticketUtil.saveOrder(request);
|
|
TTicketOrder order = new TTicketOrder();
|
order.setAppUserId(userId);
|
order.setOrderNo(did);
|
order.setPartnerOrderId(createOrderVo.getPartnerOrderId());
|
order.setOrderPrice(new BigDecimal(createOrderVo.getOrderAmount()).setScale(2, BigDecimal.ROUND_HALF_UP));
|
|
// 获取票价
|
BigDecimal ticketPrice = order.getOrderPrice().divide(new BigDecimal(dto.getQuantity()), 2, BigDecimal.ROUND_HALF_UP);
|
order.setTicketPrice(ticketPrice);
|
|
|
String result = dto.getVisitPersons().stream()
|
.map(String::valueOf) // Integer 转 String
|
.collect(Collectors.joining(","));
|
order.setTourist(result);
|
order.setTicketNum(dto.getQuantity());
|
order.setStatus(0);
|
|
order.setTicketInfo(dto.getProductName());
|
boolean save = this.save(order);
|
|
|
return save;
|
}
|
|
@Override
|
public boolean refundOrder(TTicketOrder order) throws Exception {
|
String nowTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
|
// 查询未使用的票
|
String visitPersons = order.getVisitPersons();
|
JSONArray jsonArray = JSONArray.parseArray(visitPersons);
|
List<String> ticketIds = new ArrayList<>();
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
Integer status = jsonObject.getInteger("status");
|
if(status==null || status==0){
|
String ticketId = jsonObject.getString("ticketId");
|
ticketIds.add(ticketId);
|
}
|
}
|
if(ticketIds.isEmpty()){
|
throw new RuntimeException("无未使用的票");
|
}
|
boolean refund = ticketUtil.cannelTicket(order.getOrderNo(), order.getPartnerOrderId(), ticketIds);
|
if(refund){
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
Integer status = jsonObject.getInteger("status");
|
if(status==null || status==0){
|
jsonObject.put("status",2);
|
jsonObject.put("refundTime",System.currentTimeMillis());
|
}
|
}
|
|
// jsonArray 转换为字符串
|
String result = jsonArray.toJSONString();
|
order.setVisitPersons(result);
|
order.setStatus(4);
|
order.setRefundMoney(order.getTicketPrice().multiply(new BigDecimal(ticketIds.size())));
|
boolean update = this.updateById(order);
|
return update;
|
}
|
return false;
|
}
|
}
|
