CmsOrderController.java 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520
  1. package com.cyksj.web.controller.manage;
  2. import cn.dev33.satoken.annotation.SaCheckPermission;
  3. import cn.dev33.satoken.stp.StpUtil;
  4. import cn.hutool.core.date.DateTime;
  5. import cn.hutool.core.util.StrUtil;
  6. import com.alibaba.excel.support.ExcelTypeEnum;
  7. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  8. import com.cyksj.common.annotation.Log;
  9. import com.cyksj.common.annotation.NoSubmit;
  10. import com.cyksj.common.constant.Constant;
  11. import com.cyksj.common.exception.BusinessRuntimeException;
  12. import com.cyksj.common.util.IoKit;
  13. import com.cyksj.common.util.Xmls;
  14. import com.cyksj.dto.Result;
  15. import com.cyksj.enums.BusinessType;
  16. import com.cyksj.enums.GatewayResponse;
  17. import com.cyksj.mapper.GoodsDonSkuMapper;
  18. import com.cyksj.mapper.OrderCommentMapper;
  19. import com.cyksj.mapper.RealGoodsInterestUserMapper;
  20. import com.cyksj.mapper.channel.ChannelPopularizeMapper;
  21. import com.cyksj.mapper.manage.RealGoodsOrderHandleMapper;
  22. import com.cyksj.mapper.manage.coupon.CouponMapper;
  23. import com.cyksj.model.entity.*;
  24. import com.cyksj.model.excel.ExcelOrderDonData;
  25. import com.cyksj.model.excel.ExcelRealGoodsOrderData;
  26. import com.cyksj.model.excel.ExcelRealGoodsUserInterestData;
  27. import com.cyksj.model.excel.ExcelRealGoodsUserInterestHasPaymentData;
  28. import com.cyksj.model.manage.request.ReqSetLogisticsPost;
  29. import com.cyksj.model.manage.views.AccountView;
  30. import com.cyksj.model.manage.views.OrderDonBackView;
  31. import com.cyksj.model.request.*;
  32. import com.cyksj.model.views.*;
  33. import com.cyksj.service.mange.CmsOrderDonService;
  34. import com.cyksj.service.user.UserService;
  35. import com.cyksj.web.util.EasyExcelUtils;
  36. import com.ejlchina.searcher.BeanSearcher;
  37. import com.ejlchina.searcher.SearchResult;
  38. import com.ejlchina.searcher.param.Operator;
  39. import com.ejlchina.searcher.util.MapBuilder;
  40. import com.ejlchina.searcher.util.MapUtils;
  41. import lombok.RequiredArgsConstructor;
  42. import lombok.extern.slf4j.Slf4j;
  43. import org.apache.commons.lang3.StringUtils;
  44. import org.springframework.validation.annotation.Validated;
  45. import org.springframework.web.bind.annotation.*;
  46. import javax.servlet.http.HttpServletRequest;
  47. import javax.servlet.http.HttpServletResponse;
  48. import java.io.OutputStream;
  49. import java.math.BigDecimal;
  50. import java.util.ArrayList;
  51. import java.util.List;
  52. import java.util.Map;
  53. import java.util.Optional;
  54. /**
  55. * @author chan
  56. * @date 2021/10/12 下午11:05
  57. */
  58. @Slf4j
  59. @RequestMapping("/manage/order")
  60. @RestController
  61. @RequiredArgsConstructor
  62. public class CmsOrderController {
  63. private final HttpServletRequest request;
  64. private final CmsOrderDonService cmsOrderDonService;
  65. private final UserService userService;
  66. private final BeanSearcher beanSearcher;
  67. private final RealGoodsInterestUserMapper realGoodsInterestUserMapper;
  68. private final RealGoodsOrderHandleMapper realGoodsOrderHandleMapper;
  69. private final CouponMapper couponMapper;
  70. private final OrderCommentMapper orderCommentMapper;
  71. private final GoodsDonSkuMapper skuMapper;
  72. private final ChannelPopularizeMapper channelPopularizeMapper;
  73. @GetMapping("/get")
  74. @SaCheckPermission("order:view")
  75. public Result<SearchResult<OrderDonBackView>> get(Long channelId) {
  76. MapBuilder builder = MapUtils.flatBuilder(request.getParameterMap());
  77. if (channelId != null) {
  78. List<Long> popularizeIds = channelPopularizeMapper.getPopularizeIdByChannelId(channelId);
  79. builder.field(OrderDonBackView::getPopularizeId, popularizeIds).op(Operator.InList);
  80. }
  81. SearchResult<OrderDonBackView> search = beanSearcher.search(OrderDonBackView.class, builder.build());
  82. search.getDataList().forEach(data -> {
  83. if (data.getPopularizeId() != null) {
  84. Optional.ofNullable(channelPopularizeMapper.selectChannelByPid(data.getPopularizeId()))
  85. .ifPresent(channelName -> data.setChannel(channelName));
  86. }
  87. if (data.getGoodsDonType() != null && Constant.realGoodsType.contains(data.getGoodsDonType())) {
  88. RealGoodsOrderHandle realGoodsOrderHandle = realGoodsOrderHandleMapper.selectOne(Wrappers.lambdaQuery(RealGoodsOrderHandle.class).eq(RealGoodsOrderHandle::getOrderId, data.getId()).last("limit 1"));
  89. if (realGoodsOrderHandle != null) {
  90. data.setBeforeServiceName(realGoodsOrderHandle.getBeforeServiceName());
  91. data.setAfterServiceName(realGoodsOrderHandle.getAfterServiceName());
  92. }
  93. }
  94. if (data.getCouponUserId() != 0) {
  95. data.setCouponName(couponMapper.getCouponNameByCouponUserId(data.getCouponUserId()));
  96. data.setCouponMoney(data.getCouponMoney() == null ? BigDecimal.ZERO : data.getCouponMoney());
  97. }
  98. Optional.ofNullable(data.getGroupsId()).ifPresent(groupsId -> {
  99. AccountView accountView = beanSearcher.searchFirst(AccountView.class, MapUtils.builder().field(AccountView::getGroupsId, groupsId).onlySelect(AccountView::getAccount).build());
  100. Optional.ofNullable(accountView).ifPresent(account -> data.setGtAccount(account.getAccount()));
  101. });
  102. });
  103. return GatewayResponse.SUCCESS.newBuilder().toResult(search);
  104. }
  105. /**
  106. * 用户退款订单列表
  107. */
  108. @GetMapping("/get/refund/list")
  109. public Result<SearchResult<RefundOrderDonView>> getRefundOrderDonView() {
  110. SearchResult<RefundOrderDonView> search = beanSearcher.search(RefundOrderDonView.class, MapUtils.flatBuilder(request.getParameterMap())
  111. .build());
  112. search.getDataList().forEach(data -> {
  113. Optional.ofNullable(userService.getById(data.getUserId()))
  114. .ifPresent(user -> data.setNickname(user.getNickname()));
  115. });
  116. return GatewayResponse.SUCCESS.newBuilder().toResult(search);
  117. }
  118. /**
  119. * 订单导出
  120. */
  121. @GetMapping("/export")
  122. @SaCheckPermission("order:export")
  123. @Log(module = "订单管理/导出订单", businessType = BusinessType.EXPORT, isSaveRequestData = true)
  124. public void exportOrders(HttpServletResponse response) {
  125. List<ExcelOrderDonData> list = beanSearcher.searchAll(ExcelOrderDonData.class, MapUtils.flatBuilder(request.getParameterMap()).build());
  126. list.forEach(data -> {
  127. data.setMoney(data.getMoney().divide(BigDecimal.valueOf(100)));
  128. OrderDon.Type type = data.getType();
  129. data.setTypeStr(type != null ? type.getDesc() : "");
  130. OrderDon.Status status = data.getStatus();
  131. data.setStatusStr(status != null ? status.getDesc() : "");
  132. if (data.getChannelId() == null) {
  133. data.setChannel("自然流量渠道");
  134. }
  135. if (data.getGoodsDonType() != null && Constant.realGoodsType.contains(data.getGoodsDonType())) {
  136. OrderDonTransportView transportView = beanSearcher.searchFirst(OrderDonTransportView.class, MapUtils.builder().field(OrderDonTransportView::getOrderId, data.getId()).build());
  137. if (transportView != null) {
  138. data.setTransportStr(String.format("%s%s%s%s", transportView.getProvince(), transportView.getCity(), transportView.getDistrict(), transportView.getAddress()));
  139. data.setPhone(transportView.getPhone());
  140. data.setReceiver(transportView.getReceiver());
  141. data.setCodeCn(transportView.getCodeCn());
  142. data.setTrackingNumber(transportView.getTrackingNumber());
  143. }
  144. RealGoodsOrderHandle realGoodsOrderHandle = realGoodsOrderHandleMapper.selectOne(Wrappers.lambdaQuery(RealGoodsOrderHandle.class).eq(RealGoodsOrderHandle::getOrderId, data.getId()).last("limit 1"));
  145. if (realGoodsOrderHandle != null) {
  146. data.setBeforeServiceName(realGoodsOrderHandle.getBeforeServiceName());
  147. data.setAfterServiceName(realGoodsOrderHandle.getAfterServiceName());
  148. }
  149. }
  150. if (data.getCouponUserId() != 0) {
  151. data.setCouponName(couponMapper.getCouponNameByCouponUserId(data.getCouponUserId()));
  152. data.setCouponMoney(data.getCouponMoney() == null ? BigDecimal.ZERO : data.getCouponMoney().divide(BigDecimal.valueOf(100)));
  153. }
  154. });
  155. EasyExcelUtils.createExcelStreamMutilByEasyExcel(response, ExcelOrderDonData.class, list, "订单列表", "订单列表", ExcelTypeEnum.XLSX, null);
  156. }
  157. /**
  158. * 导出实物模板 订单excel
  159. */
  160. @GetMapping("/export/realGoods")
  161. public void exportRealGoods(HttpServletResponse response) {
  162. List<ExcelRealGoodsOrderData> list = beanSearcher.searchAll(ExcelRealGoodsOrderData.class, MapUtils.flatBuilder(request.getParameterMap())
  163. .field(ExcelOrderDonData::getGoodsDonType, Constant.realGoodsType).op(Operator.InList)
  164. .build());
  165. list.forEach(data -> {
  166. data.setPayType("寄付现结");
  167. if (data.getGoodsDonType() == Constant.realGoodsType.get(0)) {
  168. data.setRealGoodName("路由器");
  169. } else if (data.getGoodsDonType() == Constant.realGoodsType.get(1)) {
  170. data.setRealGoodName("银河潮玩");
  171. }
  172. });
  173. EasyExcelUtils.createExcelStreamMutilByEasyExcel(response, ExcelRealGoodsOrderData.class, list, "实物订单列表", "实物订单列表", ExcelTypeEnum.XLSX, null);
  174. }
  175. @PutMapping("/update/status")
  176. public Result<String> upStatus(@RequestBody OrderDon orderDon){
  177. cmsOrderDonService.update(Wrappers.lambdaUpdate(OrderDon.class).eq(OrderDon::getId,orderDon.getId()).set(OrderDon::getStatus,orderDon.getStatus()));
  178. return GatewayResponse.SUCCESS.newBuilder().toResult();
  179. }
  180. /**
  181. * 编辑自定义订阅节点
  182. */
  183. @PutMapping("/update/subNode")
  184. public Result<String> updateSubNode(@RequestBody OrderDon orderDon) {
  185. OrderDon en = cmsOrderDonService.getById(orderDon.getId());
  186. if (en != null) {
  187. en.setSubNode(orderDon.getSubNode());
  188. cmsOrderDonService.updateById(en);
  189. }
  190. return GatewayResponse.SUCCESS.newBuilder().toResult();
  191. }
  192. @GetMapping("/get/transport/{orderId}")
  193. public Result<OrderDonTransportView> getTransport(@PathVariable Long orderId){
  194. // OrderDonTransport transport = cmsOrderDonService.getTransport(orderId);
  195. OrderDonTransportView transportView = beanSearcher.searchFirst(OrderDonTransportView.class, MapUtils.builder().field(OrderDonTransportView::getOrderId, orderId).build());
  196. return GatewayResponse.SUCCESS.newBuilder().toResult(transportView);
  197. }
  198. @PostMapping("/post/setWaybill")
  199. public Result<OrderDonWaybill> setWaybill(@RequestBody ReqSetLogisticsPost reqSetLogisticsPost){
  200. OrderDonWaybill orderDonWaybill = cmsOrderDonService.setWaybill(reqSetLogisticsPost);
  201. return GatewayResponse.SUCCESS.newBuilder().toResult(orderDonWaybill);
  202. }
  203. /**
  204. * 用户购买实物商品意愿列表
  205. */
  206. @GetMapping("/get/realGooods/interest/users")
  207. @SaCheckPermission("interest:view")
  208. public Result<SearchResult> getInterestUserList(RealGoodsInterestUser.Status interestStatus, HttpServletRequest request) {
  209. MapBuilder builder = MapUtils.flatBuilder(request.getParameterMap());
  210. SearchResult<RealGoodsInterestUserView> search;
  211. if (interestStatus == null) {
  212. builder.field(RealGoodsInterestUserView::getInterestStatus, "hasPayment").op(Operator.NotEqual);
  213. search = beanSearcher.search(RealGoodsInterestUserView.class, builder.build());
  214. } else if (interestStatus != RealGoodsInterestUser.Status.hasPayment) {
  215. builder.field(RealGoodsInterestUserView::getInterestStatus, interestStatus.name());
  216. search = beanSearcher.search(RealGoodsInterestUserView.class, builder.build());
  217. } else {
  218. search = new SearchResult<>();
  219. SearchResult<RealGoodsInterestUserHasPaymentView> search2 = beanSearcher.search(RealGoodsInterestUserHasPaymentView.class, builder.build());
  220. search.setTotalCount(search2.getTotalCount());
  221. List<RealGoodsInterestUserView> dataList = search.getDataList();
  222. dataList.addAll(search2.getDataList());
  223. }
  224. search.getDataList().forEach(data -> {
  225. Long goodsId = data.getGoodsId();
  226. OrderDon order = cmsOrderDonService.getOne(Wrappers.lambdaQuery(OrderDon.class).eq(OrderDon::getUserId, data.getUserId()).eq(OrderDon::getGoodsId, goodsId).ne(OrderDon::getId, data.getId()).gt(OrderDon::getMoney, data.getMoney()).eq(OrderDon::getStatus, "close").last("limit 1"));
  227. if (order != null) {
  228. data.setOrderId(order.getId());
  229. data.setSkuId(order.getSkuId());
  230. data.setMoney(order.getMoney());
  231. realGoodsInterestUserMapper.updateData(data.getId(), data.getSkuId(), data.getOrderCreatedTime(), data.getOrderId());
  232. }
  233. });
  234. return GatewayResponse.SUCCESS.newBuilder().toResult(search);
  235. }
  236. /**
  237. * 修改订单状态
  238. */
  239. @PutMapping("/put/status/{orderId}")
  240. public Result<String> updateOrderStatus(@PathVariable Long orderId) {
  241. OrderDon orderDon = cmsOrderDonService.getById(orderId);
  242. if (orderDon == null) {
  243. throw BusinessRuntimeException.getInstance("该订单不存在");
  244. }
  245. if (orderDon.getStatus() == OrderDon.Status.complete) {
  246. throw BusinessRuntimeException.getInstance("该订单已是已完成状态");
  247. }
  248. if (orderDon.getStatus() != OrderDon.Status.hasPayment) {
  249. throw BusinessRuntimeException.getInstance("该订单不是未支付状态");
  250. }
  251. orderDon.setStatus(OrderDon.Status.complete);
  252. cmsOrderDonService.updateById(orderDon);
  253. return GatewayResponse.SUCCESS.newBuilder().toResult("修改订单状态成功");
  254. }
  255. /**
  256. * 修改购买意愿记录
  257. */
  258. @PutMapping("/put/interest")
  259. public Result<String> updateInterest(@RequestBody @Validated UserRealGoodsInterestReq req) {
  260. RealGoodsInterestUser realGoodsInterestUser = realGoodsInterestUserMapper.selectById(req.getId());
  261. if (realGoodsInterestUser != null) {
  262. if (req.getStatus() != null) {
  263. realGoodsInterestUser.setInterestStatus(req.getStatus());
  264. }
  265. if (req.getRemark() != null) {
  266. realGoodsInterestUser.setRemark(req.getRemark());
  267. }
  268. realGoodsInterestUserMapper.updateById(realGoodsInterestUser);
  269. }
  270. return GatewayResponse.SUCCESS.newBuilder().toResult("修改成功");
  271. }
  272. /**
  273. * 导出用户意愿列表
  274. */
  275. @GetMapping("/export/interest")
  276. public void exportInterest(RealGoodsInterestUser.Status interestStatus, HttpServletRequest request, HttpServletResponse response) {
  277. MapBuilder builder = MapUtils.flatBuilder(request.getParameterMap());
  278. List<ExcelRealGoodsUserInterestData> excelRealGoodsUserInterestData;
  279. if (interestStatus == null) {
  280. builder.field(RealGoodsInterestUserView::getInterestStatus, "hasPayment").op(Operator.NotEqual);
  281. excelRealGoodsUserInterestData = beanSearcher.searchAll(ExcelRealGoodsUserInterestData.class, builder.build());
  282. } else {
  283. List<ExcelRealGoodsUserInterestHasPaymentData> excelRealGoodsUserInterestData2 = beanSearcher.searchAll(ExcelRealGoodsUserInterestHasPaymentData.class, builder.build());
  284. excelRealGoodsUserInterestData = new ArrayList<>(excelRealGoodsUserInterestData2);
  285. }
  286. excelRealGoodsUserInterestData.forEach(data -> {
  287. Long goodsId = data.getGoodsId();
  288. OrderDon order = cmsOrderDonService.getOne(Wrappers.lambdaQuery(OrderDon.class).eq(OrderDon::getUserId, data.getUserId()).eq(OrderDon::getGoodsId, goodsId).ne(OrderDon::getId, data.getId()).gt(OrderDon::getMoney, data.getMoney()).eq(OrderDon::getStatus, "close").last("limit 1"));
  289. if (order != null) {
  290. data.setOrderId(order.getId());
  291. data.setSkuId(order.getSkuId());
  292. data.setMoney(order.getMoney());
  293. realGoodsInterestUserMapper.updateData(data.getId(), data.getSkuId(), data.getOrderCreatedTime(), data.getOrderId());
  294. }
  295. data.setMoney(data.getMoney().divide(BigDecimal.valueOf(100)));
  296. });
  297. EasyExcelUtils.createExcelStreamMutilByEasyExcel(response, ExcelRealGoodsUserInterestHasPaymentData.class, excelRealGoodsUserInterestData, "用户意愿列表", "用户意愿列表", ExcelTypeEnum.XLSX, null);
  298. }
  299. /**
  300. * 实物订单配置售前售后客户
  301. */
  302. @PostMapping("/put/realGoods/service")
  303. @NoSubmit
  304. @Log(module = "订单管理/售前、售后客服", businessType = BusinessType.PUT, isSaveRequestData = true)
  305. public Result<String> putRealGoodsService(@RequestBody @Validated RealGoodsServiceReq request) {
  306. OrderDon orderDon = cmsOrderDonService.getById(request.getOrderId());
  307. if (orderDon == null || orderDon.getRelationId() != 0) {
  308. throw BusinessRuntimeException.getInstance("该订单不是实物订单");
  309. }
  310. Boolean isBefore = false;
  311. Boolean isAfter = false;
  312. RealGoodsOrderHandle realGoodsOrderHandle = Optional.ofNullable(realGoodsOrderHandleMapper.selectOne(Wrappers.lambdaQuery(RealGoodsOrderHandle.class).eq(RealGoodsOrderHandle::getOrderId, request.getOrderId()).last("limit 1"))).orElse(new RealGoodsOrderHandle());
  313. if (StringUtils.isNotBlank(request.getBeforeServiceName())) {
  314. realGoodsOrderHandle.setBeforeServiceName(request.getBeforeServiceName());
  315. isBefore = true;
  316. }
  317. if (StringUtils.isNotBlank(request.getAfterServiceName())) {
  318. realGoodsOrderHandle.setAfterServiceName(request.getAfterServiceName());
  319. isAfter = true;
  320. }
  321. if (realGoodsOrderHandle.getId() == null) {
  322. realGoodsOrderHandle.setOrderId(request.getOrderId());
  323. realGoodsOrderHandleMapper.insert(realGoodsOrderHandle);
  324. } else {
  325. if (realGoodsOrderHandle.getBeforeOpNum() > 2) {
  326. throw BusinessRuntimeException.getInstance("售前客服已两次修改");
  327. }
  328. if (realGoodsOrderHandle.getAfterOpNum() > 2) {
  329. throw BusinessRuntimeException.getInstance("售后客服已两次修改");
  330. }
  331. if (isBefore) {
  332. realGoodsOrderHandle.setBeforeOpNum(realGoodsOrderHandle.getBeforeOpNum() + 1);
  333. }
  334. if (isAfter) {
  335. realGoodsOrderHandle.setAfterOpNum(realGoodsOrderHandle.getAfterOpNum() + 1);
  336. }
  337. realGoodsOrderHandleMapper.updateById(realGoodsOrderHandle);
  338. }
  339. return GatewayResponse.SUCCESS.newBuilder().toResult("操作成功");
  340. }
  341. /**
  342. * 新增平台评论
  343. */
  344. @PostMapping("/post/orderComment")
  345. public Result<String> insertOrderComment(@RequestBody @Validated OrderComment orderComment) {
  346. if (StrUtil.isEmpty(orderComment.getHeadImgUrl())) {
  347. orderComment.setHeadImgUrl(Constant.DEFAULT_HEAD_IMG);
  348. }
  349. if (orderComment.getCommentTime() == null) {
  350. orderComment.setCommentTime(DateTime.now().toDateStr());
  351. }
  352. orderCommentMapper.insert(orderComment);
  353. return GatewayResponse.SUCCESS.newBuilder().toResult("新增成功");
  354. }
  355. /**
  356. * 编辑平台评论
  357. */
  358. @PutMapping("/put/orderComment")
  359. public Result<String> updateOrderComment(@RequestBody @Validated OrderComment orderComment) {
  360. orderCommentMapper.updateById(orderComment);
  361. if (orderComment.getCommentTime() == null) {
  362. orderComment.setCommentTime(DateTime.now().toDateStr());
  363. }
  364. return GatewayResponse.SUCCESS.newBuilder().toResult("编辑成功");
  365. }
  366. /**
  367. * 删除平台评论
  368. */
  369. @DeleteMapping("/delete/orderComment/{id}")
  370. public Result<String> deleteOrderCommentById(@PathVariable Long id) {
  371. orderCommentMapper.deleteById(id);
  372. return GatewayResponse.SUCCESS.newBuilder().toResult("删除成功");
  373. }
  374. /**
  375. * 平台评论列表
  376. */
  377. @GetMapping("/get/orderComment")
  378. public Result<SearchResult<OrderCommentView>> getOrderCommentView() {
  379. SearchResult<OrderCommentView> search = beanSearcher.search(OrderCommentView.class, MapUtils.flatBuilder(request.getParameterMap()).build());
  380. return GatewayResponse.SUCCESS.newBuilder().toResult(search);
  381. }
  382. /**
  383. * 踢出车队
  384. */
  385. @PutMapping("/kickOut")
  386. @NoSubmit
  387. public Result<String> kickOut(@RequestBody @Validated ClickOutReq req) {
  388. long adminId = StpUtil.getLoginIdAsLong();
  389. cmsOrderDonService.kickOutRelationId(adminId, req);
  390. return GatewayResponse.SUCCESS.newBuilder().toResult();
  391. }
  392. /**
  393. * 踢出车队列表
  394. */
  395. @GetMapping("/get/kickOut/list")
  396. public Result<SearchResult<UserKickOutView>> getKickOutList() {
  397. SearchResult<UserKickOutView> search = beanSearcher.search(UserKickOutView.class, MapUtils.flatBuilder(request.getParameterMap()).build());
  398. return GatewayResponse.SUCCESS.newBuilder().toResult(search);
  399. }
  400. /**
  401. * 客服修改订单来源
  402. */
  403. @PutMapping("/update/order/source")
  404. public Result<String> updateOrderSource(@RequestBody OrderDon orderDon) {
  405. Long id = orderDon.getId();
  406. String labelSource = orderDon.getLabelSource();
  407. if (labelSource == null) labelSource = StrUtil.EMPTY;
  408. cmsOrderDonService.update(null, Wrappers.lambdaUpdate(OrderDon.class)
  409. .set(OrderDon::getLabelSource, labelSource)
  410. .eq(OrderDon::getId, id));
  411. realGoodsOrderHandleMapper.update(null, Wrappers.lambdaUpdate(RealGoodsOrderHandle.class)
  412. .set(RealGoodsOrderHandle::getLabelSource, labelSource)
  413. .eq(RealGoodsOrderHandle::getOrderId, id));
  414. return GatewayResponse.SUCCESS.newBuilder().toResult();
  415. }
  416. /**
  417. * 订单统一退款
  418. */
  419. @PostMapping("/unified/refund")
  420. @Log(module = "订单管理/统一退款", businessType = BusinessType.PUT, isSaveRequestData = true)
  421. public Result<String> unifiedRefund(@RequestBody @Validated OrderRefundReq refundReq) throws Exception {
  422. cmsOrderDonService.unifiedRefund(refundReq);
  423. return GatewayResponse.SUCCESS.newBuilder().toResult("退款成功");
  424. }
  425. /**
  426. * 微信退款回调
  427. */
  428. @PostMapping("/wx/refund/notify")
  429. public void wxRefundNotify(HttpServletRequest request, HttpServletResponse response) throws Exception {
  430. String xml = IoKit.toString(request.getInputStream());
  431. log.info("=== 退款成功的回调: \n {}", xml);
  432. // 解析xml
  433. Map<String, String> map = Xmls.toMap(xml);
  434. // 退款失败
  435. if (!StrUtil.equals("SUCCESS", map.get("return_code"))) {
  436. throw BusinessRuntimeException.getInstance("退款失败.");
  437. }
  438. cmsOrderDonService.wxRefundNotify(map);
  439. String toWechatXmlResponse = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>";
  440. OutputStream out = null;
  441. try {
  442. out = response.getOutputStream();
  443. IoKit.write(toWechatXmlResponse, out);
  444. } catch (Throwable e) {
  445. throw BusinessRuntimeException.getInstance(e == null ? null : e.getMessage());
  446. } finally {
  447. IoKit.close(out);
  448. }
  449. }
  450. /**
  451. * 更换用户车票
  452. */
  453. @PutMapping("/put/sameSpec/empty/relation")
  454. public Result<String> changeRelation(@RequestBody @Validated ChangeRelationReq req) {
  455. cmsOrderDonService.changeRelation(req);
  456. return GatewayResponse.SUCCESS.newBuilder().toResult();
  457. }
  458. /**
  459. * 多余车位的空账号
  460. */
  461. @GetMapping("/get/sameSpec/empty/relation")
  462. public Result<SearchResult<EmptyGroupsRelationView>> getSameSpecEmptyRelation(Long skuId, Long groupsId) {
  463. MapBuilder builder = MapUtils.flatBuilder(request.getParameterMap())
  464. .field(EmptyGroupsRelationView::getGroupsId, groupsId).op(Operator.NotEqual)
  465. .field(EmptyGroupsRelationView::getStatus, GroupsTrips.Status.down.name()).op(Operator.NotEqual)
  466. .field(EmptyGroupsRelationView::getSkuId, skuId).orderBy(EmptyGroupsRelationView::getAvailableNum)
  467. .desc();
  468. GoodsDonSku sku = skuMapper.selectById(skuId);
  469. if (sku.getGoodsId() != 18) {
  470. builder.field(EmptyGroupsRelationView::getAvailableNum, 0).op(Operator.GreaterThan);
  471. }
  472. SearchResult<EmptyGroupsRelationView> search = beanSearcher.search(EmptyGroupsRelationView.class,
  473. builder.build());
  474. return GatewayResponse.SUCCESS.newBuilder().toResult(search);
  475. }
  476. }