OrderServiceImpl.java 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205
  1. package com.tour.module.service.impl;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  4. import com.google.common.collect.Lists;
  5. import com.tour.common.core.domain.entity.SysUser;
  6. import com.tour.common.enums.UserTypeEnums;
  7. import com.tour.common.exception.CustomException;
  8. import com.tour.common.utils.SnCodeUtils;
  9. import com.tour.module.domain.Agent;
  10. import com.tour.module.domain.Card;
  11. import com.tour.module.domain.Contacts;
  12. import com.tour.module.domain.dto.OmsOrderDto;
  13. import com.tour.module.domain.dto.SystemOrderDto;
  14. import com.tour.module.enums.StatusEnum;
  15. import com.tour.module.service.IAgentService;
  16. import com.tour.module.service.ICardService;
  17. import com.tour.module.service.IContactsService;
  18. import com.tour.module.vo.*;
  19. import org.springframework.beans.BeanUtils;
  20. import org.springframework.stereotype.Service;
  21. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  22. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  23. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  24. import org.apache.commons.lang3.StringUtils;
  25. import com.tour.module.mapper.OrderMapper;
  26. import com.tour.module.domain.Order;
  27. import com.tour.module.service.IOrderService;
  28. import org.springframework.util.CollectionUtils;
  29. import javax.annotation.Resource;
  30. import java.util.*;
  31. import java.util.stream.Collectors;
  32. /**
  33. * 订单Service业务层处理
  34. *
  35. * @author zoe
  36. * @date 2023-05-23
  37. */
  38. @Service
  39. public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {
  40. @Resource
  41. ICardService cardService;
  42. @Resource
  43. IContactsService contactsService;
  44. @Resource
  45. IAgentService agentService;
  46. @Resource
  47. IContactsService iContactsService;
  48. @Override
  49. public List<Order> queryList(Order order) {
  50. LambdaQueryWrapper<Order> lqw = Wrappers.lambdaQuery();
  51. if (order.getMemberId() != null) {
  52. lqw.eq(Order::getMemberId, order.getMemberId());
  53. }
  54. if (order.getAgentId() != null) {
  55. lqw.eq(Order::getAgentId, order.getAgentId());
  56. }
  57. if (StringUtils.isNotBlank(order.getCardKey())) {
  58. lqw.eq(Order::getCardKey, order.getCardKey());
  59. }
  60. if (order.getStatus() != null && order.getStatus() !=10) {
  61. lqw.eq(Order::getStatus, order.getStatus());
  62. }
  63. if (order.getStatus() != null && order.getStatus() ==10) {//完成和取消
  64. List<Integer> list = new ArrayList<>();
  65. list.add(3);
  66. list.add(-1);
  67. lqw.in(Order::getStatus,list);
  68. }
  69. List<Order> orders = this.list(lqw);
  70. return orders;
  71. }
  72. @Override
  73. public List<OmsOrderDto> queryPageList(SystemOrderDto order, SysUser user) {
  74. boolean result = this.handleListSearchCondition(order, user);
  75. if (!result) {
  76. return Lists.newArrayList();
  77. }
  78. List<OmsOrderDto> orderList = baseMapper.queryPageList(order);
  79. if (CollectionUtils.isEmpty(orderList)) {
  80. return Lists.newArrayList();
  81. }
  82. // 代理商名称
  83. List<Long> agentIds = orderList.stream().map(OmsOrderDto::getAgentId).collect(Collectors.toList());
  84. List<Agent> agentList = agentService.list(new QueryWrapper<Agent>().in("id", agentIds));
  85. Map<Long, Agent> agentMap = Optional.of(agentList).map(list -> list.stream().collect(Collectors.toMap(Agent::getId, v -> v, (v1, v2) -> v1))).orElse(new HashMap<>());
  86. for (OmsOrderDto o : orderList) {
  87. // 增加代理商名称
  88. Agent agent = agentMap.get(o.getAgentId());
  89. o.setAgentName(agent == null ? null : agent.getAgentName());
  90. }
  91. return orderList;
  92. }
  93. private boolean handleListSearchCondition(SystemOrderDto order, SysUser user) {
  94. boolean result = true;
  95. if(UserTypeEnums.AGENT.getCode().equals(user.getType()) && user.getAgentId() != null) {
  96. List<Long> agentIds = agentService.listAgent(user.getAgentId());
  97. if (com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty(agentIds)) {
  98. result = false;
  99. }
  100. order.setAgentIds(agentIds);
  101. }
  102. if (order.getAId() != null) {
  103. List<Long> aIds = agentService.listAgent(order.getAId());
  104. if (com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty(order.getAgentIds())) {
  105. order.setAgentIds(aIds);
  106. } else {
  107. order.getAgentIds().retainAll(aIds);
  108. }
  109. if (com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty(order.getAgentIds())) {
  110. result = false;
  111. }
  112. }
  113. return result;
  114. }
  115. @Override
  116. public Long addOrder(OrderCreateVo orderVo) {
  117. Card card = cardService.getOne(new QueryWrapper<Card>().eq("card_key", orderVo.getCardKey()).eq("status", 0));
  118. if(card==null){
  119. throw new CustomException("卡密无效");
  120. }
  121. //会员卡和旅游卡的区别 会员卡要判断是否在有效期内
  122. if("1".equals(card.getType()) &&card.getValidEndTime().getTime()<System.currentTimeMillis()){//会员卡
  123. throw new CustomException("会员卡已失效");
  124. }
  125. Order order = new Order();
  126. BeanUtils.copyProperties(orderVo,order);
  127. order.setAgentId(card.getAgentId());
  128. String orderSn = SnCodeUtils.createSn();
  129. order.setOrderNo(orderSn);
  130. order.setCardType(card.getType());
  131. boolean result =true;
  132. if("2".equals(card.getType())){//旅游卡
  133. card.setStatus(StatusEnum.SHOW.getStatus().toString());//激活
  134. result= cardService.updateById(card);
  135. }
  136. if(result){
  137. this.save(order);
  138. }
  139. return order.getOrderId();
  140. }
  141. @Override
  142. public Boolean addOrderContact(OrderMemberVo orderVo) {
  143. String travelers = orderVo.getTravelerList();
  144. List<Contacts> array = JSONArray.parseArray(travelers,Contacts.class);
  145. String travelName = "";
  146. String travelIds= "";
  147. for(Contacts item:array){
  148. Contacts contacts = new Contacts();
  149. contacts.setContactName(item.getContactName());
  150. contacts.setMemberId(orderVo.getMemberId());
  151. List<Contacts> list =contactsService.queryList(contacts);
  152. if(CollectionUtils.isEmpty(list)){
  153. contactsService.save(item);
  154. }else{
  155. item.setId(list.get(0).getId());
  156. contactsService.updateById(item);
  157. }
  158. travelName += item.getContactName()+",";
  159. travelIds += item.getId()+",";
  160. }
  161. Order order = this.getById(orderVo.getOrderId());
  162. order.setTravelers(travelName.substring(0,travelName.length()-1));
  163. order.setTravelerIds(travelIds.substring(0,travelIds.length()-1));
  164. boolean result = this.updateById(order);
  165. return result;
  166. }
  167. @Override
  168. public String getQrCode(Long orderId) {
  169. Order order = this.getById(orderId);
  170. Agent agent = agentService.getById(order.getAgentId());
  171. return agent.getQrCode();
  172. }
  173. @Override
  174. public Boolean subTrip(OrderTravelVo orderVo) {
  175. Order order = new Order();
  176. order.setOrderId(orderVo.getOrderId());
  177. order.setTravelDetail(orderVo.getTravelDetail());
  178. return this.updateById(order);
  179. }
  180. @Override
  181. public OrderDetailVo getOrderDetail(Long orderId) {
  182. OrderDetailVo vo =baseMapper.getOrderDetail(orderId);
  183. String travelerIds = vo.getTravelerIds();
  184. List<String> ids = Arrays.asList(travelerIds.split(","));
  185. List<Contacts> contactsList = iContactsService.list(new QueryWrapper<Contacts>().in("id", ids));
  186. vo.setContactsList(contactsList);
  187. return vo;
  188. }
  189. }