package com.ruoyi.order.controller; import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.ruoyi.account.api.feignClient.AppUserClient; import com.ruoyi.account.api.feignClient.UserAddressClient; import com.ruoyi.account.api.model.AppUser; import com.ruoyi.account.api.model.UserAddress; import com.ruoyi.common.core.constant.ExpressCompanyMap; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.utils.StringUtils; import com.ruoyi.common.core.utils.poi.ExcelUtil; import com.ruoyi.common.core.web.controller.BaseController; import com.ruoyi.common.core.web.page.PageInfo; import com.ruoyi.common.core.web.page.TableDataInfo; import com.ruoyi.common.security.service.TokenService; import com.ruoyi.order.enums.OrderStatus; import com.ruoyi.order.mapper.OrderMapper; import com.ruoyi.order.model.Order; import com.ruoyi.order.model.RefundPass; import com.ruoyi.order.service.CommissionService; import com.ruoyi.order.service.OrderService; import com.ruoyi.order.service.RefundPassService; import com.ruoyi.order.util.payment.model.RefundCallbackResult; import com.ruoyi.order.util.vo.MapTrackKD100Vo; import com.ruoyi.order.vo.*; import com.ruoyi.other.api.domain.BaseSetting; import com.ruoyi.other.api.domain.Goods; import com.ruoyi.other.api.feignClient.BaseSettingClient; import com.ruoyi.system.api.domain.SysUser; import com.ruoyi.system.api.feignClient.SysUserClient; import com.ruoyi.system.api.model.LoginUser; import io.swagger.annotations.*; import org.springframework.util.CollectionUtils; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.PrintWriter; import java.math.BigDecimal; import java.text.ParseException; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.stream.Collectors; /** *

* 前端控制器 *

* * @author luodangjia * @since 2024-11-21 */ @Api(tags = "订单") @RestController @RequestMapping("/order") public class OrderController extends BaseController { @Resource private OrderService orderService; @Resource private TokenService tokenService; @Resource private UserAddressClient addressClient; @Resource private CommissionService commissionService; @Resource private BaseSettingClient baseSettingClient; @Resource private OrderMapper orderMapper; @Resource private SysUserClient sysUserClient; @Resource private RefundPassService refundPassService; @Resource private AppUserClient appUserClient; /** * 我的订单列表 */ @ApiOperation(value = "我的订单列表", tags = {"小程序-个人中心-我的订单"}) @ApiImplicitParams({ @ApiImplicitParam(value = "订单状态", name = "status", required = true, dataType = "int"), }) @GetMapping("/getMyOrderList") public TableDataInfo getMyOrderList(@ApiParam("订单状态") Integer status) { startPage(); LoginUser loginUserApplet = tokenService.getLoginUserApplet(); return getDataTable(orderService.selectOrderListByUserId(status, loginUserApplet.getUserid())); } /** * 通过订单ids获取订单列表 */ @PostMapping("/getOrderListByIds") public R> getOrderListByIds(@RequestBody List ids) { return R.ok(orderService.listByIds(ids)); } /** * 订单详情 */ @ApiOperation(value = "订单详情", tags = {"小程序-个人中心-我的订单-订单详情"}) @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "int"), }) @GetMapping("/detail/{orderId}") public R detail(@PathVariable("orderId") Long orderId) { return R.ok(orderService.getOrderDetail(orderId)); } /** * 扫码校验 */ @ApiOperation(value = "扫码校验", tags = {"小程序-个人中心-门店管理"}) @ApiImplicitParams({ @ApiImplicitParam(value = "分享id", name = "shareId", required = true, dataType = "int", paramType = "query"), }) @GetMapping("/check/{orderNumber}/{shopId}") public R check(@PathVariable("orderNumber") String orderNumber, @PathVariable("shopId") Integer shopId) { LoginUser loginUserApplet = tokenService.getLoginUserApplet(); Order order = orderService.getOne(new LambdaQueryWrapper() .eq(Order::getOrderNumber, orderNumber)); return R.ok(orderService.check(order, shopId, loginUserApplet.getUserid())); } /** * 订单核销 */ @ApiOperation(value = "订单核销", tags = {"小程序-个人中心-门店管理"}) @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "id", required = true, dataType = "String"), }) @GetMapping("/writeOff") public R writeOff(String code, Integer shopId, String technicianId) { orderService.writeOff(code, shopId, technicianId); return R.ok(); } /** * 取消订单 */ @ApiOperation(value = "取消订单", tags = {"小程序-个人中心-我的订单"}) @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "int"), }) @GetMapping("/cancel/{orderId}") public R cancel(@PathVariable("orderId") Long orderId) { return orderService.cancel(orderId); } /** * 确认收货 */ @ApiOperation(value = "确认收货", tags = {"小程序-个人中心-我的订单"}) @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "int"), }) @GetMapping("/confirm/{orderId}") public R confirm(@PathVariable("orderId") Long orderId) { R baseSettingR = baseSettingClient.getBaseSetting(5); if (R.isError(baseSettingR)) { return R.fail("售后设置获取失败"); } BaseSetting baseSetting = baseSettingR.getData(); if (baseSetting == null) { return R.fail("售后设置获取失败"); } String content = baseSetting.getContent(); JSONObject jsonObject = JSONObject.parseObject(content); Long days = jsonObject.getLong("days"); Order order = orderService.getById(orderId); order.setAfterSaleTime(LocalDateTime.now().plusDays(days)); order.setOrderStatus(OrderStatus.COMPLETED.getCode()); orderService.updateById(order); return R.ok(); } /** * 更换收货地址 */ @ApiOperation(value = "更换收货地址", tags = {"小程序-个人中心-我的订单"}) @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "int"), }) @GetMapping("/changeAddress") public R changeAddress(@RequestParam("orderId") Long orderId, @RequestParam("addressId") Long addressId) { R userAddressR = addressClient.getUserAddressById(addressId); if (R.isError(userAddressR)) { return R.fail("收货地址不存在"); } UserAddress userAddress = userAddressR.getData(); String addressJson = JSONObject.toJSONString(userAddress); orderService.update(new LambdaUpdateWrapper() .eq(Order::getId, orderId) .set(Order::getAddressJson, addressJson)); return R.ok(); } /** * 更新订单状态 */ @ApiOperation(value = "更新订单状态", tags = {"后台-订单管理"}) @ApiImplicitParams({ @ApiImplicitParam(value = "订单对象", name = "order", required = true, dataType = "Order"), }) @PostMapping("/updateOrderStatus") public R updateOrderStatus(@RequestBody Order order) { Order order1 = orderService.getById(order.getId()); order1.setOrderStatus(order.getOrderStatus()); order1.setOldOrderStatus(order.getOldOrderStatus()); orderService.updateById(order1); return R.ok(); } /** * 预约技师 */ @PostMapping("/subscribe") public R subscribe(@RequestParam(value = "id", required = false) Long id, @RequestParam(value = "technicianId", required = false) Integer technicianId) { Order order = orderService.getById(id); order.setTechnicianId(technicianId); orderService.updateById(order); return R.ok(); } @PostMapping("/getLastOrder") public R getLastOrder(@RequestParam("appUserId") Long appUserId) { Order one = orderService.lambdaQuery().eq(Order::getAppUserId, appUserId).orderByDesc(Order::getCreateTime).last("limit 1").one(); return R.ok(one); } @PostMapping("/byUserId") public R> byUserId(@RequestParam("appUserId") Long appUserId, @RequestParam("shopId") Integer shopId) { List list = orderService.lambdaQuery() .eq(Order::getAppUserId, appUserId) .eq(null != shopId && -1 != shopId, Order::getShopId, shopId) .eq(Order::getPayStatus, 2) .isNull(Order::getRefundStatus) .eq(Order::getDelFlag, 0) .notIn(Order::getOrderStatus, 5, 6).list(); return R.ok(list); } @PostMapping("/byShopId") public R> byShopId(@RequestParam("shopId") Integer shopId) { return R.ok(orderService.lambdaQuery().isNotNull(Order::getEndTime).eq(Order::getShopId, shopId).list()); } @PostMapping("/byShopIdAndUserId") public R> byShopIdAndUserId(@RequestParam("appUserId") Long appUserId, @RequestParam("shopId") Integer shopId) { List list = orderService.lambdaQuery().isNotNull(Order::getEndTime) .eq(null != shopId && -1 != shopId, Order::getShopId, shopId) .eq(Order::getAppUserId, appUserId) .eq(Order::getPayStatus, 2) .isNull(Order::getRefundStatus) .eq(Order::getDelFlag, 0) .notIn(Order::getOrderStatus, 5, 6).list(); return R.ok(list); } @PostMapping("/confirmDelivery") @ApiOperation(value = "已发货操作", tags = {"管理后台-订单管理"}) public R confirmDelivery(@RequestBody ConfirmDelivery confirmDelivery) { return orderService.confirmDelivery(confirmDelivery); } @PutMapping("/cancelOrder/{orderId}") @ApiOperation(value = "取消订单操作", tags = {"管理后台-订单管理"}) public R cancelOrder(@PathVariable("orderId") Long orderId) { return orderService.cancelOrder(orderId); } @PutMapping("/receivingOperation/{orderId}") @ApiOperation(value = "收货操作", tags = {"管理后台-订单管理"}) public R receivingOperation(@PathVariable("orderId") Long orderId) { return orderService.receivingOperation(orderId); } @GetMapping("/getOrderInfo/{orderId}") @ApiOperation(value = "查询订单详情", tags = {"管理后台-订单管理"}) public R getOrderInfo(@PathVariable("orderId") Long orderId) { OrderInfoVo orderInfo = orderService.getOrderInfo(orderId); RefundPass one = refundPassService.getOne(new LambdaQueryWrapper().eq(RefundPass::getOrderId, orderId) .eq(RefundPass::getDelFlag, 0).last(" order by create_time desc limit 0,1")); if (one != null) { orderInfo.setRefundPassId(one.getId().toString()); } return R.ok(orderInfo); } @GetMapping("/getOrderPageList") // @ApiOperation(value = "获取订单列表", tags = {"管理后台-订单管理", "门店后台-订单管理"}) public R> getOrderPageList(OrderPageList orderPageList) { return R.ok(orderService.getOrderPageList(orderPageList)); } /** * 订单统计 */ @GetMapping("/getOrderStatistics") @ApiOperation(value = "订单统计", tags = {"管理后台-首页统计"}) public R getOrderStatistics(@RequestParam("startTime") String startTime, @RequestParam("endTime") String endTime) { Long userid = tokenService.getLoginUser().getUserid(); SysUser sysUser = sysUserClient.getSysUser(userid).getData(); LambdaQueryWrapper wrapper = new LambdaQueryWrapper() .in(Order::getOrderStatus, Arrays.asList(1, 2, 3, 4, 7, 8)) .eq(Order::getPayStatus, 2) .eq(Order::getDelFlag, 0) .between(Order::getCreateTime, LocalDateTime.parse(startTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")), LocalDateTime.parse(endTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))) .orderByAsc(Order::getCreateTime); if(sysUser.getRoleType() == 2){ //门店只拥有服务订单和自提商品订单 wrapper.eq(Order::getShopId, sysUser.getObjectId()).eq(Order::getOrderType, 1).or().eq(Order::getOrderType, 2).eq(Order::getDistributionMode, 1); } List orderList = orderService.list(wrapper); Map> map = orderList.stream() .collect(Collectors.groupingBy( item -> item.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")), TreeMap::new, // 使用 TreeMap 按键排序 Collectors.toList() )); List orderStatisticsDetails = new ArrayList<>(); map.forEach((key, value) -> { int serviceTotal = 0; int singleTotal = 0; int total = 0; BigDecimal totalMoney = BigDecimal.ZERO; BigDecimal serviceTotalMoney = BigDecimal.ZERO; BigDecimal singleTotalMoney = BigDecimal.ZERO; OrderStatisticsDetail orderStatisticsDetail = new OrderStatisticsDetail(); for (Order order : value) { if (order.getOrderType().equals(1)) { serviceTotal++; serviceTotalMoney = serviceTotalMoney.add(order.getTotalAmount()); total++; totalMoney = totalMoney.add(order.getTotalAmount()); } else if (order.getOrderType().equals(2)) { singleTotal++; singleTotalMoney = singleTotalMoney.add(order.getTotalAmount()); total++; totalMoney = totalMoney.add(order.getTotalAmount()); } } orderStatisticsDetail.setDate(key); orderStatisticsDetail.setServiceTotal(serviceTotal); orderStatisticsDetail.setSingleTotal(singleTotal); orderStatisticsDetail.setTotal(total); orderStatisticsDetail.setServiceTotalMoney(serviceTotalMoney); orderStatisticsDetail.setSingleTotalMoney(singleTotalMoney); orderStatisticsDetail.setTotalMoney(totalMoney); orderStatisticsDetails.add(orderStatisticsDetail); }); Integer shopId = null; if (sysUser.getRoleType() == 2) { shopId = sysUser.getObjectId(); } OrderStatistics orderStatistics = orderMapper.getOrderStatistics(startTime, endTime, shopId); if (null != orderStatistics) { SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); List sortedDetails = orderStatisticsDetails.stream() .sorted(Comparator.comparing((OrderStatisticsDetail detail) -> { try { return dateFormat.parse(detail.getDate()); } catch (ParseException e) { throw new RuntimeException(e); } })) .collect(Collectors.toList()); orderStatistics.setOrderStatisticsDetailList(sortedDetails); } return R.ok(orderStatistics); } /** * 订单取消支付回退 * * @param refundCallbackResult * @param response * @return */ @ResponseBody @GetMapping("/refundPayMoneyCallback") public void refundPayMoneyCallback(RefundCallbackResult refundCallbackResult, HttpServletResponse response) { R callback = orderService.refundPayMoneyCallback(refundCallbackResult); if (callback.getCode() == 200) { response.setStatus(200); PrintWriter out = null; try { out = response.getWriter(); } catch (IOException e) { throw new RuntimeException(e); } out.println("success"); out.flush(); out.close(); } } /** * 取消订单快递费回退 * * @param refundCallbackResult * @param response */ @ResponseBody @GetMapping("/refundExpressPayMoneyCallback") public void refundExpressPayMoneyCallback(RefundCallbackResult refundCallbackResult, HttpServletResponse response) { R callback = orderService.refundExpressPayMoneyCallback(refundCallbackResult); if (callback.getCode() == 200) { response.setStatus(200); PrintWriter out = null; try { out = response.getWriter(); } catch (IOException e) { throw new RuntimeException(e); } out.println("success"); out.flush(); out.close(); } } /** * 获取商品销售数量 * * @param goodsId * @return */ @PostMapping("/getGoodsSaleNum") public R getGoodsSaleNum(@RequestParam("goodsId") Integer goodsId, @RequestParam("type") Integer type) { Integer goodsSaleNum = orderService.getGoodsSaleNum(goodsId, type, null); return R.ok(goodsSaleNum); } /** * 获取门店销售订单数量 * * @param shopId 门店id * @param type 1:服务订单,2:单品订单 * @return */ @PostMapping("/getShopSaleNum") public R getShopSaleNum(@RequestParam("shopId") Integer shopId, @RequestParam("type") Integer type) { Integer shopSaleNum = orderService.getShopSaleNum(shopId, type); return R.ok(shopSaleNum); } @PostMapping("/getShopSaleNumByShopIds") public R getShopSaleNumByShopIds(@RequestBody OrderSaleNum orderSaleNum) { Integer shopSaleNum = orderService.getShopSaleNumByShopIds(orderSaleNum.getShopIds(), orderSaleNum.getType()); return R.ok(shopSaleNum); } /** * 获取所有在指定门店消费的用户id * * @param shopId * @return */ @PostMapping("/getAppUserByShoppingShop") public R> getAppUserByShoppingShop(@RequestParam("shopId") Integer shopId) { List list = orderService.list(new LambdaQueryWrapper().eq(Order::getShopId, shopId).eq(Order::getDelFlag, 0) .eq(Order::getPayStatus, 2).in(Order::getOrderStatus, Arrays.asList(1, 2, 3, 4, 7, 8))); Set collect = list.stream().map(Order::getAppUserId).collect(Collectors.toSet()); return R.ok(collect); } /** * 获取指定门店的核销订单 */ @GetMapping("/getRedeemedOrdersByShop") public R> getRedeemedOrdersByShop(@RequestParam("shopId") Integer shopId) { return R.ok(orderService.list(new LambdaQueryWrapper() .isNotNull(Order::getEndTime) .eq(Order::getShopId, shopId))); } /** * 获取订单快递明细 * * @param id * @return */ @GetMapping("/getOrderExpress/{id}") @ApiOperation(value = "获取订单快递明细", tags = {"小程序-订单管理"}) public R getOrderExpress(@PathVariable("id") Long id) { Order order = orderService.getById(id); String expressResult = order.getExpressResult(); if (StringUtils.isNotEmpty(expressResult)) { MapTrackKD100Vo mapTrackKD100Vo = JSON.parseObject(expressResult, MapTrackKD100Vo.class); return R.ok(mapTrackKD100Vo); } return R.ok(); } /** * 根据id获取订单详情 * * @param id * @return */ @PostMapping("/getOrderById") public R getOrderById(@RequestParam("id") Long id) { Order order = orderService.getById(id); return R.ok(order); } /** * 修改订单 * * @param order * @return */ @PostMapping("/editOrder") public R editOrder(@RequestBody Order order) { orderService.updateById(order); return R.ok(); } /** * 导入物流信息 */ @PostMapping("/importExpress") public R importExpress(@RequestBody String url) { JSONObject jsonObject = JSONObject.parseObject(url); String url2 = jsonObject.getString("url"); orderService.importExpress(url2); return R.ok(); } /** * 导出订单信息 */ @GetMapping("/exportExpress") public void exportExpress(HttpServletResponse response, OrderPageList orderPage) { //搜索条件,用户姓名 if (StringUtils.isNotEmpty(orderPage.getUserName())) { List data = appUserClient.getAppUserByNameNoFilter(orderPage.getUserName()).getData(); List collect = data.stream().map(AppUser::getId).collect(Collectors.toList()); if (CollectionUtils.isEmpty(collect)) { return; } if (null != orderPage.getAppUserIds()) { List appUserIds = orderPage.getAppUserIds(); appUserIds.addAll(collect); orderPage.setAppUserIds(appUserIds); } else { orderPage.setAppUserIds(collect); } } //搜索条件,用户电话 if (StringUtils.isNotEmpty(orderPage.getPhone())) { List data = appUserClient.getAppUserByPhoneNoFilter(orderPage.getPhone()).getData(); List collect = data.stream().map(AppUser::getId).collect(Collectors.toList()); if (CollectionUtils.isEmpty(collect)) { return; } if (null != orderPage.getAppUserIds()) { List appUserIds = orderPage.getAppUserIds(); if (!containsAny(appUserIds, collect)) { return; } appUserIds.addAll(collect); orderPage.setAppUserIds(appUserIds); } else { orderPage.setAppUserIds(collect); } } if (null != orderPage.getAppUserIds()) { orderPage.setAppUserIds(orderPage.getAppUserIds().stream().distinct().collect(Collectors.toList())); } // UserAddress userAddress = JSON.parseObject(order.getAddressJson(), UserAddress.class); // orderInfo.setRecipient(userAddress.getRecieveName() + "-" + userAddress.getRecievePhone()); // userAddress.setRecieveAddress(userAddress.getProvince() + userAddress.getCity() + userAddress.getDistrict() + userAddress.getRecieveAddress()); // orderInfo.setAddress(userAddress.getRecieveAddress()); List orderExportList = orderMapper.getOrderExportList(orderPage); orderExportList.forEach(orderExport -> { Long appUserId = orderExport.getAppUserId(); AppUser appUserById = appUserClient.getAppUserById(appUserId); if (null != appUserById) { orderExport.setUserName(appUserById.getName()); orderExport.setPhone(appUserById.getPhone()); } String goodJson = orderExport.getGoodJson(); if (StringUtils.isNotEmpty(goodJson) && !"NULL".equals(goodJson)) { Goods goods = JSONObject.parseObject(goodJson, Goods.class); orderExport.setGoodsName(goods.getName()); orderExport.setCompanyCostPrice(goods.getOperatingCost()); orderExport.setSupplierCostPrice(goods.getShopCost()); } String expressJson = orderExport.getExpressJson(); if (StringUtils.isNotEmpty(expressJson) && !expressJson.equals("NULL")) { JSONObject jsonObject = JSONObject.parseObject(expressJson); orderExport.setExpressNum(jsonObject.getString("num")); orderExport.setExpressName(ExpressCompanyMap.getCompanyNameByCode(jsonObject.getString("com"))); } String addressJson = orderExport.getAddressJson(); if (StringUtils.isNotEmpty(addressJson)) { UserAddress userAddress = JSON.parseObject(addressJson, UserAddress.class); orderExport.setAddress( userAddress.getProvince() + userAddress.getCity() + userAddress.getDistrict() + userAddress.getRecieveAddress() ); } }); ExcelUtil util = new ExcelUtil(OrderExport.class); util.exportExcel(response, orderExportList, "订单数据"); } /** * 判断 list1 是否包含 list2 中的至少一个元素 * * @param list1 第一个列表 * @param list2 第二个列表 * @return 如果 list1 包含 list2 中的至少一个元素,返回 true;否则返回 false */ private boolean containsAny(List list1, List list2) { // 将 list1 转换为 HashSet 以提高查询效率 Set set1 = new HashSet<>(list1); // 遍历 list2,检查是否有元素存在于 set1 中 for (Long element : list2) { if (set1.contains(element)) { return true; } } // 如果没有找到共同元素,返回 false return false; } /** * 获取用户订单数量 * * @param appUserId * @return */ @PostMapping("/getOrderCountByAppUserId") public R getOrderCountByAppUserId(@RequestParam("id") Long appUserId) { long count = orderService.count(new LambdaQueryWrapper().eq(Order::getDelFlag, 0) .eq(Order::getAppUserId, appUserId).in(Order::getOrderStatus, Arrays.asList(1, 2, 3, 4, 7, 8)) .eq(Order::getPayStatus, 2)); return R.ok(count); } /** * 查询给定用户在给定门店核销的订单 * @param shopId * @param appUserId * @return */ @PostMapping("/getOrderByAppUserIdsAndWriteOffShop") public R> getOrderByAppUserIdsAndWriteOffShop(@RequestParam("shopId") Integer shopId, @RequestParam("appUserId") Set appUserId){ List list = orderService.getOrderByAppUserIdsAndWriteOffShop(shopId, appUserId); return R.ok(list); } }