HotelOrderServiceImpl.java 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564
  1. package com.chuanghai.ihotel.service.impl;
  2. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  3. import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
  4. import com.baomidou.mybatisplus.core.metadata.IPage;
  5. import com.baomidou.mybatisplus.core.toolkit.IdWorker;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.chuanghai.ihotel.aop.LoginCheckAspect;
  8. import com.chuanghai.ihotel.common.exception.BizCodeEnume;
  9. import com.chuanghai.ihotel.common.exception.RRException;
  10. import com.chuanghai.ihotel.common.utils.MyQuery;
  11. import com.chuanghai.ihotel.common.utils.PageParam;
  12. import com.chuanghai.ihotel.common.utils.PageUtils;
  13. import com.chuanghai.ihotel.component.PayComponent;
  14. import com.chuanghai.ihotel.config.JXNXSPayConfig;
  15. import com.chuanghai.ihotel.config.RabbitMQConfig;
  16. import com.chuanghai.ihotel.constant.TimeConstant;
  17. import com.chuanghai.ihotel.controller.request.ConfrimOrderRequest;
  18. import com.chuanghai.ihotel.controller.request.OrderQueryRequest;
  19. import com.chuanghai.ihotel.controller.request.SubmitOrderRequest;
  20. import com.chuanghai.ihotel.dao.HotelOrderDao;
  21. import com.chuanghai.ihotel.dto.BillHandleResultDTO;
  22. import com.chuanghai.ihotel.dto.EventMessageDTO;
  23. import com.chuanghai.ihotel.dto.LockRoomDTO;
  24. import com.chuanghai.ihotel.entity.HotelOrderBillEntity;
  25. import com.chuanghai.ihotel.entity.HotelOrderEntity;
  26. import com.chuanghai.ihotel.entity.HotelUserEntity;
  27. import com.chuanghai.ihotel.entity.RoomDoorLockDataEntity;
  28. import com.chuanghai.ihotel.entity.RoomEntity;
  29. import com.chuanghai.ihotel.entity.RoomTypeEntity;
  30. import com.chuanghai.ihotel.entity.SystemSettingEntity;
  31. import com.chuanghai.ihotel.enums.EventMessageTypeEnum;
  32. import com.chuanghai.ihotel.enums.OrderBillStatuEnum;
  33. import com.chuanghai.ihotel.enums.OrderStatuEnum;
  34. import com.chuanghai.ihotel.enums.UserIdentityTypeEnum;
  35. import com.chuanghai.ihotel.service.HotelOrderBillService;
  36. import com.chuanghai.ihotel.service.HotelOrderService;
  37. import com.chuanghai.ihotel.service.HotelUserService;
  38. import com.chuanghai.ihotel.service.RoomDoorLockDataService;
  39. import com.chuanghai.ihotel.service.RoomRealtimeStatuService;
  40. import com.chuanghai.ihotel.service.RoomService;
  41. import com.chuanghai.ihotel.service.RoomTypeService;
  42. import com.chuanghai.ihotel.service.SystemSettingService;
  43. import com.chuanghai.ihotel.util.CommonUtil;
  44. import com.chuanghai.ihotel.vo.ConfirmOrderVO;
  45. import com.chuanghai.ihotel.vo.LoginUserVO;
  46. import com.chuanghai.ihotel.vo.OrderBillHandleVO;
  47. import com.chuanghai.ihotel.vo.OrderSubmitVO;
  48. import com.chuanghai.ihotel.vo.UserOrderDetailVO;
  49. import com.chuanghai.ihotel.vo.UserOrderIndexVO;
  50. import lombok.extern.slf4j.Slf4j;
  51. import org.springframework.amqp.rabbit.core.RabbitTemplate;
  52. import org.springframework.beans.BeanUtils;
  53. import org.springframework.beans.factory.annotation.Autowired;
  54. import org.springframework.stereotype.Service;
  55. import org.springframework.transaction.annotation.Transactional;
  56. import org.springframework.util.StringUtils;
  57. import java.math.BigDecimal;
  58. import java.time.LocalDate;
  59. import java.time.LocalDateTime;
  60. import java.time.temporal.ChronoUnit;
  61. import java.util.List;
  62. import java.util.Map;
  63. import java.util.stream.Collectors;
  64. @Slf4j
  65. @Service("hotelOrderService")
  66. public class HotelOrderServiceImpl extends ServiceImpl<HotelOrderDao, HotelOrderEntity> implements HotelOrderService {
  67. @Autowired
  68. private SystemSettingService systemSettingService;
  69. @Autowired
  70. private RoomTypeService roomTypeService;
  71. @Autowired
  72. private RoomRealtimeStatuService roomRealtimeStatuService;
  73. @Autowired
  74. private HotelUserService hotelUserService;
  75. @Autowired
  76. private RoomService roomService;
  77. @Autowired
  78. private HotelOrderBillService orderBillService;
  79. @Autowired
  80. private RoomDoorLockDataService doorLockService;
  81. @Autowired
  82. private RoomDoorLockDataService roomDoorLockDataService;
  83. @Autowired
  84. private PayComponent payComponent;
  85. @Autowired
  86. private JXNXSPayConfig jxnxsPayConfig;
  87. @Autowired
  88. private RabbitTemplate rabbitTemplate;
  89. @Autowired
  90. private RabbitMQConfig rabbitMQConfig;
  91. @Override
  92. public PageUtils queryPage(PageParam pageParam, OrderQueryRequest request) {
  93. QueryWrapper<HotelOrderEntity> queryWrapper = new QueryWrapper<>();
  94. queryWrapper.eq(request.getOrderId() != null, "id", request.getOrderId());
  95. queryWrapper.eq(StringUtils.hasText(request.getDeleteFlag()), "delete_flag", request.getDeleteFlag());
  96. queryWrapper.eq(StringUtils.hasText(request.getOrderNo()), "order_no", request.getOrderNo());
  97. queryWrapper.eq(StringUtils.hasText(request.getUserFlag()), "user_flag", request.getUserFlag());
  98. queryWrapper.eq(StringUtils.hasText(request.getUserName()), "user_name", request.getUserName());
  99. queryWrapper.eq(StringUtils.hasText(request.getUserPhone()), "user_phone", request.getUserPhone());
  100. queryWrapper.eq(StringUtils.hasText(request.getRoomNo()), "room_no", request.getRoomNo());
  101. queryWrapper.eq(request.getRoomTypeId() != null, "room_type_id", request.getRoomTypeId());
  102. String statu = request.getStatu();
  103. if (StringUtils.hasText(statu)) {
  104. if (statu.contains("-")) {
  105. String[] split = statu.split("-");
  106. queryWrapper.eq("order_statu", split[0]);
  107. queryWrapper.eq("biz_statu", split[1]);
  108. } else {
  109. queryWrapper.eq("order_statu", statu);
  110. }
  111. }
  112. queryWrapper.ge(request.getEnableStartTime() != null, "enable_start_time", request.getEnableStartTime());
  113. queryWrapper.le(request.getEnableStartTime() != null, "enable_end_time", request.getEnableStartTime());
  114. IPage<HotelOrderEntity> page = this.page(
  115. new MyQuery<HotelOrderEntity>().getPage(pageParam),
  116. queryWrapper
  117. );
  118. return new PageUtils(page);
  119. }
  120. @Override
  121. public PageUtils userOrderPage(PageParam pageParam, OrderQueryRequest request) {
  122. pageParam.setOrderField("create_time");
  123. pageParam.setOrder("desc");
  124. LoginUserVO loginUserVO = LoginCheckAspect.threadLocal.get();
  125. request.setUserFlag(loginUserVO.getCardNumber());
  126. request.setDeleteFlag("1"); // 1未删除
  127. PageUtils pageUtils = this.queryPage(pageParam, request);
  128. List<HotelOrderEntity> list = pageUtils.getList();
  129. List<UserOrderIndexVO> collect = list.stream().map(e -> {
  130. UserOrderIndexVO vo = new UserOrderIndexVO();
  131. BeanUtils.copyProperties(e, vo);
  132. return vo;
  133. }).collect(Collectors.toList());
  134. pageUtils.setList(collect);
  135. return pageUtils;
  136. }
  137. @Override
  138. public HotelOrderEntity findByOrderNo(String orderNo) {
  139. QueryWrapper<HotelOrderEntity> queryWrapper = new QueryWrapper<>();
  140. queryWrapper.eq("order_no", orderNo);
  141. queryWrapper.last("limit 1");
  142. return this.getOne(queryWrapper);
  143. }
  144. @Override
  145. public ConfirmOrderVO confirmOrder(ConfrimOrderRequest request) {
  146. SystemSettingEntity systemSetting = systemSettingService.get();
  147. // 入住日期校验
  148. Integer preDay = systemSetting.getPreDay();
  149. if (Math.abs(ChronoUnit.DAYS.between(request.getStartTime(), LocalDate.now())) > preDay) {
  150. throw new RRException(BizCodeEnume.PARAMETER_ERROR, "只能预定" + preDay + "天之内的房源");
  151. }
  152. // 查询房源是否充足
  153. Long roomTypeId = request.getRoomTypeId();
  154. RoomTypeEntity roomType = roomTypeService.myGetById(roomTypeId);
  155. if (roomType == null) {
  156. throw new RRException(BizCodeEnume.PARAMETER_ERROR, "房型不存在");
  157. }
  158. LocalDateTime startTime = CommonUtil.localDateToTime(request.getStartTime(), TimeConstant.INTO_TIME);
  159. LocalDateTime endTime = CommonUtil.localDateToTime(request.getEndTime(), TimeConstant.OUT_TIME);
  160. long days = ChronoUnit.DAYS.between(request.getStartTime(), request.getEndTime());
  161. int busyNum = roomRealtimeStatuService.getBusyNum(roomTypeId, startTime, endTime);
  162. int enableNum = roomType.getRoomNum() - busyNum;
  163. // 查询房型价格
  164. BigDecimal discountPrice = roomType.getDiscountPrice();
  165. // 查询押金
  166. BigDecimal deposit = systemSetting.getDeposit();
  167. BigDecimal totalAmount = discountPrice.add(deposit).multiply(new BigDecimal(Long.toString(days)));
  168. // 封装确认订单vo
  169. ConfirmOrderVO vo = new ConfirmOrderVO();
  170. vo.setStartTime(startTime);
  171. vo.setEndTime(endTime);
  172. vo.setNums(Integer.valueOf((int)days));
  173. vo.setRoomTypeId(roomTypeId);
  174. vo.setRoomTypeName(roomType.getTypeName());
  175. vo.setFreeNum(enableNum >= 0 ? enableNum : 0);
  176. vo.setDiscountPrice(roomType.getDiscountPrice());
  177. vo.setDeposit(systemSetting.getDeposit());
  178. vo.setPriceOfWater(systemSetting.getPriceOfWater());
  179. vo.setPriceOfElectric(systemSetting.getPriceOfElectric());
  180. vo.setFreeQuotaOfElectric(systemSetting.getPriceOfElectric());
  181. vo.setFreeQuotaOfWater(systemSetting.getFreeQuotaOfWater());
  182. vo.setFreeQuotaOfElectric(systemSetting.getFreeQuotaOfElectric());
  183. vo.setFreeTotal(systemSetting.getFreeTotal());
  184. vo.setTotalAmount(totalAmount);
  185. return vo;
  186. }
  187. @Override
  188. public void orderPaySuccess(Long orderId, String orderNo, String realPayAmount, LocalDateTime payTime) {
  189. HotelOrderEntity order = null;
  190. if (orderId != null) {
  191. order = this.getById(orderId);
  192. } else {
  193. if (StringUtils.hasText(orderNo)) {
  194. order = this.findByOrderNo(orderNo);
  195. }
  196. }
  197. if (order == null) {
  198. log.warn("修改订单状态:订单【{}】不存在", orderId);
  199. return;
  200. }
  201. if (OrderStatuEnum.WAIT_PAY.getCode().equalsIgnoreCase(order.getOrderStatu())) {
  202. if (Math.abs(order.getPayAmount().subtract(new BigDecimal(realPayAmount)).doubleValue()) < 0.01) {
  203. // 订单最终支付金额验证成功
  204. if (payTime == null) {
  205. order.setPayTime(LocalDateTime.now());
  206. } else {
  207. order.setPayTime(payTime);
  208. }
  209. order.setOrderStatu(OrderStatuEnum.FINISH_PAY.getCode());
  210. this.updateById(order);
  211. }
  212. }
  213. }
  214. @Transactional
  215. @Override
  216. public OrderSubmitVO submitOrder(SubmitOrderRequest request) {
  217. LoginUserVO loginUserVO = LoginCheckAspect.threadLocal.get();
  218. String cardNumber = loginUserVO.getCardNumber();
  219. // 身份校验
  220. HotelUserEntity hotelUser = hotelUserService.findByCardNumber(cardNumber);
  221. if (hotelUser == null) {
  222. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "非法用户");
  223. }
  224. String identityType = hotelUser.getIdentityType();
  225. if (!UserIdentityTypeEnum.STAFF_OF_TEACHER.getCode().equals(identityType)) {
  226. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "非法用户-非教职工");
  227. }
  228. SystemSettingEntity systemSetting = systemSettingService.get();
  229. // 入住时间校验
  230. Integer preDay = systemSetting.getPreDay();
  231. if (Math.abs(ChronoUnit.DAYS.between(request.getEnableStartTime().toLocalDate(), LocalDate.now())) > preDay) {
  232. throw new RRException(BizCodeEnume.PARAMETER_ERROR, "只能预定" + preDay + "天之内的房源");
  233. }
  234. // 校验房型
  235. RoomTypeEntity roomType = roomTypeService.myGetById(request.getRoomTypeId());
  236. if (roomType == null) {
  237. throw new RRException(BizCodeEnume.PARAMETER_ERROR, "房型不存在");
  238. }
  239. // 金额校验
  240. BigDecimal discountPrice = roomType.getDiscountPrice();
  241. BigDecimal deposit = systemSetting.getDeposit();
  242. long days = ChronoUnit.DAYS.between(request.getEnableStartTime().toLocalDate(), request.getEnableEndTime().toLocalDate());
  243. BigDecimal totalAmount = discountPrice.add(deposit).multiply(new BigDecimal(Long.toString(days)));
  244. if (Math.abs(totalAmount.subtract(request.getPayAmount()).doubleValue()) > 0.01) {
  245. throw new RRException(BizCodeEnume.ORDER_SUBMIT_ERROR, "订单金额校验失败");
  246. }
  247. // 锁定房源
  248. long orderId = IdWorker.getId();
  249. LockRoomDTO lockRoomDTO = LockRoomDTO.builder()
  250. .roomTypeId(roomType.getId())
  251. .bizId(orderId)
  252. .startTime(request.getEnableStartTime())
  253. .endTime(request.getEnableEndTime())
  254. .build();
  255. Long roomId = roomRealtimeStatuService.lockRoomByRoomTypeId(lockRoomDTO);
  256. if (roomId == null) {
  257. throw new RRException(BizCodeEnume.ORDER_SUBMIT_ERROR, "【" + roomType.getTypeName() + "】房型房源不足,锁定房源失败");
  258. }
  259. RoomEntity room = roomService.getById(roomId);
  260. if (room == null) {
  261. throw new RRException(BizCodeEnume.UNKNOW_EXCEPTION, "系统异常,根据id查询房间失败");
  262. }
  263. // 订单落库
  264. HotelOrderEntity hotelOrder = new HotelOrderEntity();
  265. BeanUtils.copyProperties(request, hotelOrder);
  266. hotelOrder.setId(orderId);
  267. hotelOrder.setOrderNo(IdWorker.getTimeId());
  268. hotelOrder.setUserFlag(cardNumber);
  269. hotelOrder.setRoomId(roomId);
  270. hotelOrder.setRoomNo(room.getRoomNo());
  271. hotelOrder.setRoomTypeName(roomType.getTypeName());
  272. hotelOrder.setRoomTypeMasterImg(roomType.getTypeImage().split(",")[0]);
  273. hotelOrder.setCreateTime(LocalDateTime.now());
  274. hotelOrder.setOrderStatu(OrderStatuEnum.WAIT_PAY.getCode());
  275. hotelOrder.setBizStatu(OrderBillStatuEnum.WAIT_HANDLE.getCode());
  276. hotelOrder.setDeleteFlag("1"); // 0删除、1正常
  277. this.save(hotelOrder);
  278. // 发送延迟消息
  279. EventMessageDTO eventMessage = EventMessageDTO.builder()
  280. .eventMessageType(EventMessageTypeEnum.PRODUCT_ORDER_NEW.name())
  281. .accountNo(loginUserVO.getCardNumber())
  282. .bizId(orderId)
  283. .build();
  284. rabbitTemplate.convertAndSend(rabbitMQConfig.getOrderEventExchange(), rabbitMQConfig.getOrderCloseDelayRoutingKey(), eventMessage);
  285. // 返回支付参数
  286. String payUrl = String.format(jxnxsPayConfig.getPayUrl(), hotelOrder.getOrderNo(), request.getPayAmount());
  287. return OrderSubmitVO.builder().orderId(hotelOrder.getId()).payUrl(payUrl).build();
  288. }
  289. @Override
  290. public void handleOrderMessage(EventMessageDTO eventMessageDTO) {
  291. String messageType = eventMessageDTO.getEventMessageType();
  292. try {
  293. if(EventMessageTypeEnum.PRODUCT_ORDER_NEW.name().equalsIgnoreCase(messageType)) {
  294. // 关单消息
  295. this.closeOrder(eventMessageDTO);
  296. }
  297. } catch (Exception e) {
  298. log.error("订单消费者消费失败:{}", eventMessageDTO);
  299. throw new RRException(BizCodeEnume.MQ_CONSUME_EXCEPTION);
  300. }
  301. }
  302. @Override
  303. public void closeOrder(EventMessageDTO eventMessageDTO) {
  304. Long orderId = eventMessageDTO.getBizId();
  305. String cardNumber = eventMessageDTO.getAccountNo();
  306. HotelOrderEntity orderEntity = this.getById(orderId);
  307. if (orderEntity == null) {
  308. log.warn("关单:订单【{}】不存在", orderId);
  309. return;
  310. }
  311. // 判断订单状态
  312. if (!orderEntity.getOrderStatu().equalsIgnoreCase(OrderStatuEnum.WAIT_PAY.getCode())) {
  313. log.info("关单:订单不是初始状态待支付:{}", eventMessageDTO);
  314. return;
  315. }
  316. // 未支付,向第三方支付平台查询状态
  317. Map<String, String> map = payComponent.queryOrderStatus(orderEntity.getOrderNo());
  318. log.info("关单:订单支付状态查询结果,【{}】", map);
  319. String payStatus = map.get("status");
  320. if ("1".equalsIgnoreCase(payStatus)) { // 已经完成支付
  321. String amount = map.get("trade_amount");
  322. String payTimeStr = map.get("trade_pay_time");
  323. LocalDateTime payTime = LocalDateTime.parse(payTimeStr, TimeConstant.DEFAULT_DTF);
  324. String realPayAmount = new BigDecimal(amount).divide(new BigDecimal(100)).setScale(2, BigDecimal.ROUND_UP).toString(); // 分转成元
  325. this.orderPaySuccess(orderId, orderEntity.getOrderNo(), realPayAmount, payTime);
  326. } else { // 未支付,取消订单
  327. this.cancelOrder(cardNumber, orderId);
  328. }
  329. }
  330. @Override
  331. public boolean cancelOrder(String userFlag, Long orderId) {
  332. HotelOrderEntity orderEntity = this.getById(orderId);
  333. if (orderEntity == null) {
  334. log.warn("取消订单:订单【{}】不存在", orderId);
  335. return false;
  336. }
  337. if (!orderEntity.getUserFlag().equalsIgnoreCase(userFlag)) {
  338. log.warn("取消订单:操作越权,非法取消订单,订单原用户【】,操作用户【】", orderEntity.getUserFlag(), userFlag);
  339. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "不能取消非自己的订单");
  340. }
  341. orderEntity.setOrderStatu(OrderStatuEnum.CANCEL.getCode());
  342. this.updateById(orderEntity);
  343. // 释放库存
  344. roomRealtimeStatuService.releaseByBizId(orderEntity.getId());
  345. return true;
  346. }
  347. @Override
  348. public UserOrderDetailVO userOrderDetail(Long orderId) {
  349. HotelOrderEntity orderEntity = userGetOrderById(orderId);
  350. UserOrderDetailVO detailVO = new UserOrderDetailVO();
  351. BeanUtils.copyProperties(orderEntity, detailVO);
  352. RoomTypeEntity roomType = roomTypeService.myGetById(orderEntity.getRoomTypeId());
  353. detailVO.setRoomTypeUsualPrice(roomType.getUsualPrice());
  354. detailVO.setRoomTypeDiscountPrice(roomType.getDiscountPrice());
  355. // 订单状态为已入住之后,查询水电等相关信息
  356. String orderStatu = orderEntity.getOrderStatu();
  357. if (Integer.valueOf(orderStatu).intValue() >= Integer.valueOf(OrderStatuEnum.HOLD_ON.getCode()).intValue()) {
  358. HotelOrderBillEntity orderBill = orderBillService.findByOrderId(orderId);
  359. if (orderBill == null) {
  360. throw new RRException(BizCodeEnume.UNKNOW_EXCEPTION, "用户订单详情-订单状态错误");
  361. }
  362. BeanUtils.copyProperties(orderBill, detailVO);
  363. }
  364. // 订单状态为已入住,查询密码锁等相关信息
  365. if (OrderStatuEnum.HOLD_ON.getCode().equals(orderStatu)) {
  366. RoomDoorLockDataEntity lockData = roomDoorLockDataService.queryByOrderId(orderId);
  367. if (lockData == null) {
  368. throw new RRException(BizCodeEnume.UNKNOW_EXCEPTION, "用户订单详情-锁密码获取失败");
  369. }
  370. detailVO.setLockRealtimePassword(lockData.getLockRealtimePassword());
  371. detailVO.setPasswordStartTime(lockData.getStartTime());
  372. detailVO.setPasswordEndTime(lockData.getEndTime());
  373. }
  374. return detailVO;
  375. }
  376. @Override
  377. public OrderSubmitVO getOrderPayParam(Long orderId) {
  378. HotelOrderEntity orderEntity = userGetOrderById(orderId);
  379. if (!OrderStatuEnum.WAIT_PAY.getCode().equalsIgnoreCase(orderEntity.getOrderStatu())) {
  380. throw new RRException(BizCodeEnume.PARAMETER_ERROR, "当前订单状态为非待支付状态");
  381. }
  382. // 支付参数
  383. String payUrl = String.format(jxnxsPayConfig.getPayUrl(), orderEntity.getOrderNo(), orderEntity.getPayAmount());
  384. return OrderSubmitVO.builder().orderId(orderId).payUrl(payUrl).build();
  385. }
  386. @Override
  387. public void userDeleteOrder(Long orderId) {
  388. HotelOrderEntity order = userGetOrderById(orderId);
  389. String orderStatu = order.getOrderStatu();
  390. // 已取消、待支付、已完成订单才可以被删除
  391. if (!(OrderStatuEnum.CANCEL.getCode().equalsIgnoreCase(orderStatu)
  392. || OrderStatuEnum.WAIT_PAY.getCode().equalsIgnoreCase(orderStatu)
  393. || OrderStatuEnum.FINISH_PAY.getCode().equalsIgnoreCase(orderStatu))) {
  394. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "当前订单不可删除");
  395. }
  396. UpdateWrapper<HotelOrderEntity> updateWrapper = new UpdateWrapper<>();
  397. updateWrapper.eq("id", orderId);
  398. updateWrapper.set("delete_flag", "0"); // 0表示删除
  399. updateWrapper.last("limit 1");
  400. this.update(null, updateWrapper);
  401. }
  402. @Override
  403. public void userCancelOrder(Long orderId) {
  404. HotelOrderEntity order = userGetOrderById(orderId);
  405. // 已取消、待支付、已完成订单才可以被删除
  406. if (!OrderStatuEnum.WAIT_PAY.getCode().equalsIgnoreCase(order.getOrderStatu())) {
  407. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "当前订单不可取消");
  408. }
  409. UpdateWrapper<HotelOrderEntity> updateWrapper = new UpdateWrapper<>();
  410. updateWrapper.eq("id", orderId);
  411. updateWrapper.set("order_statu", OrderStatuEnum.WAIT_PAY.getCode());
  412. updateWrapper.last("limit 1");
  413. this.update(null, updateWrapper);
  414. }
  415. @Transactional
  416. @Override
  417. public void userHoldOrder(Long orderId) {
  418. HotelOrderEntity order = userGetOrderById(orderId);
  419. // 支付完成状态的订单才可以办理入住
  420. if (!OrderStatuEnum.FINISH_PAY.getCode().equalsIgnoreCase(order.getOrderStatu())) {
  421. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "订单状态异常");
  422. }
  423. // 订单有效时间校验
  424. LocalDateTime now = LocalDateTime.now();
  425. if (now.isAfter(order.getEnableEndTime())) {
  426. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "订单超过有效时间");
  427. }
  428. Long roomId = order.getRoomId();
  429. // 水电抄表 => 生成结账单
  430. orderBillService.generateBill(orderId, roomId);
  431. // 门锁密码
  432. doorLockService.generatePassword(order);
  433. // 更新订单状态
  434. UpdateWrapper<HotelOrderEntity> updateWrapper = new UpdateWrapper<>();
  435. updateWrapper.eq("id", orderId);
  436. updateWrapper.set("order_statu", OrderStatuEnum.HOLD_ON.getCode());
  437. updateWrapper.last("limit 1");
  438. this.update(null, updateWrapper);
  439. }
  440. @Override
  441. public OrderBillHandleVO userReturnOrder(Long orderId) {
  442. HotelOrderEntity order = userGetOrderById(orderId);
  443. // 入住状态的订单才可以办理退房
  444. if (!OrderStatuEnum.HOLD_ON.getCode().equalsIgnoreCase(order.getOrderStatu())) {
  445. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "订单状态异常");
  446. }
  447. // 结算订单
  448. BillHandleResultDTO billHandleResult = orderBillService.calcBill(orderId);
  449. if ("1".equals(billHandleResult.getResultFlag()) && billHandleResult.getReturnFee().doubleValue() > 0) {
  450. // TODO 发起退款
  451. }
  452. // 密码锁密码删除
  453. roomDoorLockDataService.deleteByOrderId(orderId);
  454. // 更新订单状态
  455. UpdateWrapper<HotelOrderEntity> updateWrapper = new UpdateWrapper<>();
  456. updateWrapper.eq("id", orderId);
  457. updateWrapper.set("order_statu", OrderStatuEnum.WAIT_BILL.getCode());
  458. updateWrapper.last("limit 1");
  459. this.update(null, updateWrapper);
  460. OrderBillHandleVO vo = new OrderBillHandleVO();
  461. vo.setOrderId(orderId);
  462. vo.setBillId(billHandleResult.getBillId());
  463. vo.setFlag(billHandleResult.getResultFlag());
  464. vo.setRefundFee(billHandleResult.getReturnFee());
  465. vo.setSupperFee(billHandleResult.getRealFee());
  466. return vo;
  467. }
  468. /**
  469. * 用户根据订单id获取订单
  470. * @param orderId
  471. * @return
  472. */
  473. private HotelOrderEntity userGetOrderById(Long orderId) {
  474. HotelOrderEntity orderEntity = this.getById(orderId);
  475. if ("0".equalsIgnoreCase(orderEntity.getDeleteFlag())) {
  476. throw new RRException(BizCodeEnume.PARAMETER_ERROR, "订单不存在,订单已删除");
  477. }
  478. if (orderEntity == null) {
  479. throw new RRException(BizCodeEnume.PARAMETER_ERROR, "订单不存在,无效的orderId");
  480. }
  481. LoginUserVO loginUserVO = LoginCheckAspect.threadLocal.get();
  482. String userFlag = loginUserVO.getCardNumber();
  483. if (!orderEntity.getUserFlag().equalsIgnoreCase(userFlag)) {
  484. throw new RRException(BizCodeEnume.PERMISSION_DENIED, "非自己的订单");
  485. }
  486. return orderEntity;
  487. }
  488. }