123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205 |
- package com.tour.module.service.impl;
- import com.alibaba.fastjson.JSONArray;
- import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
- import com.google.common.collect.Lists;
- import com.tour.common.core.domain.entity.SysUser;
- import com.tour.common.enums.UserTypeEnums;
- import com.tour.common.exception.CustomException;
- import com.tour.common.utils.SnCodeUtils;
- import com.tour.module.domain.Agent;
- import com.tour.module.domain.Card;
- import com.tour.module.domain.Contacts;
- import com.tour.module.domain.dto.OmsOrderDto;
- import com.tour.module.domain.dto.SystemOrderDto;
- import com.tour.module.enums.StatusEnum;
- import com.tour.module.service.IAgentService;
- import com.tour.module.service.ICardService;
- import com.tour.module.service.IContactsService;
- import com.tour.module.vo.*;
- import org.springframework.beans.BeanUtils;
- import org.springframework.stereotype.Service;
- import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
- import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
- import com.baomidou.mybatisplus.core.toolkit.Wrappers;
- import org.apache.commons.lang3.StringUtils;
- import com.tour.module.mapper.OrderMapper;
- import com.tour.module.domain.Order;
- import com.tour.module.service.IOrderService;
- import org.springframework.util.CollectionUtils;
- import javax.annotation.Resource;
- import java.util.*;
- import java.util.stream.Collectors;
- /**
- * 订单Service业务层处理
- *
- * @author zoe
- * @date 2023-05-23
- */
- @Service
- public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {
- @Resource
- ICardService cardService;
- @Resource
- IContactsService contactsService;
- @Resource
- IAgentService agentService;
- @Resource
- IContactsService iContactsService;
- @Override
- public List<Order> queryList(Order order) {
- LambdaQueryWrapper<Order> lqw = Wrappers.lambdaQuery();
- if (order.getMemberId() != null) {
- lqw.eq(Order::getMemberId, order.getMemberId());
- }
- if (order.getAgentId() != null) {
- lqw.eq(Order::getAgentId, order.getAgentId());
- }
- if (StringUtils.isNotBlank(order.getCardKey())) {
- lqw.eq(Order::getCardKey, order.getCardKey());
- }
- if (order.getStatus() != null && order.getStatus() !=10) {
- lqw.eq(Order::getStatus, order.getStatus());
- }
- if (order.getStatus() != null && order.getStatus() ==10) {//完成和取消
- List<Integer> list = new ArrayList<>();
- list.add(3);
- list.add(-1);
- lqw.in(Order::getStatus,list);
- }
- List<Order> orders = this.list(lqw);
- return orders;
- }
- @Override
- public List<OmsOrderDto> queryPageList(SystemOrderDto order, SysUser user) {
- boolean result = this.handleListSearchCondition(order, user);
- if (!result) {
- return Lists.newArrayList();
- }
- List<OmsOrderDto> orderList = baseMapper.queryPageList(order);
- if (CollectionUtils.isEmpty(orderList)) {
- return Lists.newArrayList();
- }
- // 代理商名称
- List<Long> agentIds = orderList.stream().map(OmsOrderDto::getAgentId).collect(Collectors.toList());
- List<Agent> agentList = agentService.list(new QueryWrapper<Agent>().in("id", agentIds));
- Map<Long, Agent> agentMap = Optional.of(agentList).map(list -> list.stream().collect(Collectors.toMap(Agent::getId, v -> v, (v1, v2) -> v1))).orElse(new HashMap<>());
- for (OmsOrderDto o : orderList) {
- // 增加代理商名称
- Agent agent = agentMap.get(o.getAgentId());
- o.setAgentName(agent == null ? null : agent.getAgentName());
- }
- return orderList;
- }
- private boolean handleListSearchCondition(SystemOrderDto order, SysUser user) {
- boolean result = true;
- if(UserTypeEnums.AGENT.getCode().equals(user.getType()) && user.getAgentId() != null) {
- List<Long> agentIds = agentService.listAgent(user.getAgentId());
- if (com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty(agentIds)) {
- result = false;
- }
- order.setAgentIds(agentIds);
- }
- if (order.getAId() != null) {
- List<Long> aIds = agentService.listAgent(order.getAId());
- if (com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty(order.getAgentIds())) {
- order.setAgentIds(aIds);
- } else {
- order.getAgentIds().retainAll(aIds);
- }
- if (com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty(order.getAgentIds())) {
- result = false;
- }
- }
- return result;
- }
- @Override
- public Long addOrder(OrderCreateVo orderVo) {
- Card card = cardService.getOne(new QueryWrapper<Card>().eq("card_key", orderVo.getCardKey()).eq("status", 0));
- if(card==null){
- throw new CustomException("卡密无效");
- }
- //会员卡和旅游卡的区别 会员卡要判断是否在有效期内
- if("1".equals(card.getType()) &&card.getValidEndTime().getTime()<System.currentTimeMillis()){//会员卡
- throw new CustomException("会员卡已失效");
- }
- Order order = new Order();
- BeanUtils.copyProperties(orderVo,order);
- order.setAgentId(card.getAgentId());
- String orderSn = SnCodeUtils.createSn();
- order.setOrderNo(orderSn);
- order.setCardType(card.getType());
- boolean result =true;
- if("2".equals(card.getType())){//旅游卡
- card.setStatus(StatusEnum.SHOW.getStatus().toString());//激活
- result= cardService.updateById(card);
- }
- if(result){
- this.save(order);
- }
- return order.getOrderId();
- }
- @Override
- public Boolean addOrderContact(OrderMemberVo orderVo) {
- String travelers = orderVo.getTravelerList();
- List<Contacts> array = JSONArray.parseArray(travelers,Contacts.class);
- String travelName = "";
- String travelIds= "";
- for(Contacts item:array){
- Contacts contacts = new Contacts();
- contacts.setContactName(item.getContactName());
- contacts.setMemberId(orderVo.getMemberId());
- List<Contacts> list =contactsService.queryList(contacts);
- if(CollectionUtils.isEmpty(list)){
- contactsService.save(item);
- }else{
- item.setId(list.get(0).getId());
- contactsService.updateById(item);
- }
- travelName += item.getContactName()+",";
- travelIds += item.getId()+",";
- }
- Order order = this.getById(orderVo.getOrderId());
- order.setTravelers(travelName.substring(0,travelName.length()-1));
- order.setTravelerIds(travelIds.substring(0,travelIds.length()-1));
- boolean result = this.updateById(order);
- return result;
- }
- @Override
- public String getQrCode(Long orderId) {
- Order order = this.getById(orderId);
- Agent agent = agentService.getById(order.getAgentId());
- return agent.getQrCode();
- }
- @Override
- public Boolean subTrip(OrderTravelVo orderVo) {
- Order order = new Order();
- order.setOrderId(orderVo.getOrderId());
- order.setTravelDetail(orderVo.getTravelDetail());
- return this.updateById(order);
- }
- @Override
- public OrderDetailVo getOrderDetail(Long orderId) {
- OrderDetailVo vo =baseMapper.getOrderDetail(orderId);
- String travelerIds = vo.getTravelerIds();
- List<String> ids = Arrays.asList(travelerIds.split(","));
- List<Contacts> contactsList = iContactsService.list(new QueryWrapper<Contacts>().in("id", ids));
- vo.setContactsList(contactsList);
- return vo;
- }
- }
|