菜品与财务分析

This commit is contained in:
qjq
2024-04-02 15:06:27 +08:00
parent 12833c1b9f
commit 5bddb6e9f9
33 changed files with 1758 additions and 6 deletions

View File

@ -0,0 +1,96 @@
package cn.iocoder.yudao.module.member.controller.admin.carteenmoney;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo.CarteenMoneyPageReqVO;
import cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo.CarteenMoneyRespVO;
import cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo.CarteenMoneySaveReqVO;
import cn.iocoder.yudao.module.member.dal.dataobject.carteenmoney.CarteenMoneyDO;
import cn.iocoder.yudao.module.member.service.carteenmoney.CarteenMoneyService;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import org.springframework.validation.annotation.Validated;
import org.springframework.security.access.prepost.PreAuthorize;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Operation;
import javax.validation.*;
import javax.servlet.http.*;
import java.io.IOException;
import java.util.List;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils;
import cn.iocoder.yudao.framework.operatelog.core.annotations.OperateLog;
import static cn.iocoder.yudao.framework.operatelog.core.enums.OperateTypeEnum.*;
@Tag(name = "管理后台 - 门店流水")
@RestController
@RequestMapping("/t/carteen-money")
@Validated
public class CarteenMoneyController {
@Resource
private CarteenMoneyService carteenMoneyService;
// @PostMapping("/create")
// @Operation(summary = "创建门店流水")
// @PreAuthorize("@ss.hasPermission('t:carteen-money:create')")
// public CommonResult<Long> createCarteenMoney(@Valid @RequestBody CarteenMoneySaveReqVO createReqVO) {
// return success(carteenMoneyService.createCarteenMoney(createReqVO));
// }
//
// @PutMapping("/update")
// @Operation(summary = "更新门店流水")
// @PreAuthorize("@ss.hasPermission('t:carteen-money:update')")
// public CommonResult<Boolean> updateCarteenMoney(@Valid @RequestBody CarteenMoneySaveReqVO updateReqVO) {
// carteenMoneyService.updateCarteenMoney(updateReqVO);
// return success(true);
// }
//
// @DeleteMapping("/delete")
// @Operation(summary = "删除门店流水")
// @Parameter(name = "id", description = "编号", required = true)
// @PreAuthorize("@ss.hasPermission('t:carteen-money:delete')")
// public CommonResult<Boolean> deleteCarteenMoney(@RequestParam("id") Long id) {
// carteenMoneyService.deleteCarteenMoney(id);
// return success(true);
// }
@GetMapping("/get")
@Operation(summary = "获得门店流水")
@Parameter(name = "id", description = "编号", required = true, example = "1024")
@PreAuthorize("@ss.hasPermission('t:carteen-money:query')")
public CommonResult<CarteenMoneyRespVO> getCarteenMoney(@RequestParam("id") Long id) {
CarteenMoneyDO carteenMoney = carteenMoneyService.getCarteenMoney(id);
return success(BeanUtils.toBean(carteenMoney, CarteenMoneyRespVO.class));
}
@GetMapping("/page")
@Operation(summary = "获得门店流水分页")
@PreAuthorize("@ss.hasPermission('t:carteen-money:query')")
public CommonResult<PageResult<CarteenMoneyRespVO>> getCarteenMoneyPage(@Valid CarteenMoneyPageReqVO pageReqVO) {
PageResult<CarteenMoneyDO> pageResult = carteenMoneyService.getCarteenMoneyPage(pageReqVO);
return success(BeanUtils.toBean(pageResult, CarteenMoneyRespVO.class));
}
@GetMapping("/export-excel")
@Operation(summary = "导出门店流水 Excel")
@PreAuthorize("@ss.hasPermission('t:carteen-money:export')")
@OperateLog(type = EXPORT)
public void exportCarteenMoneyExcel(@Valid CarteenMoneyPageReqVO pageReqVO,
HttpServletResponse response) throws IOException {
pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
List<CarteenMoneyDO> list = carteenMoneyService.getCarteenMoneyPage(pageReqVO).getList();
// 导出 Excel
ExcelUtils.write(response, "门店流水.xls", "数据", CarteenMoneyRespVO.class,
BeanUtils.toBean(list, CarteenMoneyRespVO.class));
}
}

View File

@ -0,0 +1,47 @@
package cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo;
import lombok.*;
import java.util.*;
import io.swagger.v3.oas.annotations.media.Schema;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
@Schema(description = "管理后台 - 门店流水分页 Request VO")
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class CarteenMoneyPageReqVO extends PageParam {
@Schema(description = "门店id", example = "927")
private Long carteenId;
@Schema(description = "门店名称", example = "王五")
private String carteenName;
@Schema(description = "成交金额")
private BigDecimal successMoney;
@Schema(description = "退款金额")
private BigDecimal errorMoney;
@Schema(description = "平台预留金额")
private BigDecimal estimateMoney;
@Schema(description = "总收入")
private BigDecimal sumMoney;
@Schema(description = "总成本")
private BigDecimal totalCost;
@Schema(description = "总利润")
private BigDecimal totalProfit;
@Schema(description = "创建时间")
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
private LocalDateTime[] createTime;
}

View File

@ -0,0 +1,57 @@
package cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;
import java.util.*;
import java.util.*;
import java.math.BigDecimal;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDateTime;
import com.alibaba.excel.annotation.*;
@Schema(description = "管理后台 - 门店流水 Response VO")
@Data
@ExcelIgnoreUnannotated
public class CarteenMoneyRespVO {
@Schema(description = "主键id", requiredMode = Schema.RequiredMode.REQUIRED, example = "14879")
@ExcelProperty("主键id")
private Long id;
@Schema(description = "门店id", requiredMode = Schema.RequiredMode.REQUIRED, example = "927")
@ExcelProperty("门店id")
private Long carteenId;
@Schema(description = "门店名称", example = "王五")
@ExcelProperty("门店名称")
private String carteenName;
@Schema(description = "成交金额")
@ExcelProperty("成交金额")
private BigDecimal successMoney;
@Schema(description = "退款金额")
@ExcelProperty("退款金额")
private BigDecimal errorMoney;
@Schema(description = "平台预留金额")
@ExcelProperty("平台预留金额")
private BigDecimal estimateMoney;
@Schema(description = "总收入")
@ExcelProperty("总收入")
private BigDecimal sumMoney;
@Schema(description = "总成本")
@ExcelProperty("总成本")
private BigDecimal totalCost;
@Schema(description = "总利润")
@ExcelProperty("总利润")
private BigDecimal totalProfit;
@Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED)
@ExcelProperty("创建时间")
private LocalDateTime createTime;
}

View File

@ -0,0 +1,41 @@
package cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;
import java.util.*;
import javax.validation.constraints.*;
import java.math.BigDecimal;
@Schema(description = "管理后台 - 门店流水新增/修改 Request VO")
@Data
public class CarteenMoneySaveReqVO {
@Schema(description = "主键id", requiredMode = Schema.RequiredMode.REQUIRED, example = "14879")
private Long id;
@Schema(description = "门店id", requiredMode = Schema.RequiredMode.REQUIRED, example = "927")
@NotNull(message = "门店id不能为空")
private Long carteenId;
@Schema(description = "门店名称", example = "王五")
private String carteenName;
@Schema(description = "成交金额")
private BigDecimal successMoney;
@Schema(description = "退款金额")
private BigDecimal errorMoney;
@Schema(description = "平台预留金额")
private BigDecimal estimateMoney;
@Schema(description = "总收入")
private BigDecimal sumMoney;
@Schema(description = "总成本")
private BigDecimal totalCost;
@Schema(description = "总利润")
private BigDecimal totalProfit;
}

View File

@ -1,18 +1,30 @@
package cn.iocoder.yudao.module.member.controller.admin.order;
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.member.controller.admin.order.vo.OrderDetailsReqVO;
import cn.iocoder.yudao.module.member.controller.admin.order.vo.OrderDetailsRespVO;
import cn.iocoder.yudao.module.member.service.order.OrderService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.Map;
@Tag(name = "管理后台 - 会员订单")
@RestController
@RequestMapping("/member/order")
@Validated
public class OrderController {
//@Resource
//private OrderService orderService;
@Resource
private OrderService orderService;
//
//@PostMapping("/create")
//@Operation(summary = "创建会员订单")
@ -67,5 +79,18 @@ public class OrderController {
// ExcelUtils.write(response, "会员订单.xls", "数据", OrderRespVO.class,
// BeanUtils.toBean(list, OrderRespVO.class));
//}
/*================后台管理-订单管理========================*/
/**
* @Description:
* @Author: qjq
* @Date: 2024/4/1 9:13
* @return
*/
@GetMapping("/page")
@Operation(summary = "获得会员订单分页")
@PreAuthorize("@ss.hasPermission('member:order:query')")
public CommonResult<PageResult<OrderDetailsRespVO>> getPageResult(@Valid OrderDetailsReqVO reqVO){
return CommonResult.success(orderService.getPageOrderDetails(reqVO));
}
}

View File

@ -0,0 +1,45 @@
package cn.iocoder.yudao.module.member.controller.admin.order.vo;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.ToString;
import java.math.BigDecimal;
import java.time.LocalDateTime;
/**
* @Author:qjq
* @Date:2024/4/1 9:28
*/
@Schema(description = "管理后台 - 订单管理分页 Request VO")
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class OrderDetailsReqVO extends PageParam {
@Schema(description = "门店Id", example = "24217")
private String storeId;
@Schema(description = "开始时间", example = "2024-4-12 9:00:00")
private LocalDateTime startDate;
@Schema(description = "结束时间", example = "2024-4-12 18:00:00")
private LocalDateTime endDate;
@Schema(description = "订单号", example = "20240401085810236196705")
private String orderId;
@Schema(description = "用户名称", example = "张三")
private String userName;
@Schema(description = "用户账号", example = "13527409779")
private String userAccount;
@Schema(description = "卡号", example = "13527409779")
private String userJob;
@Schema(description = "最小金额", example = "0.00")
private BigDecimal minAmount;
@Schema(description = "最大金额", example = "999")
private BigDecimal maxAmount;
@Schema(description = "订单状态", example = "1")
private String orderStatus;
@Schema(description = "支付方式", example = "钱包")
private String payMethods;
@Schema(description = "时间段", example = "早餐")
private String timePeriod;
}

View File

@ -0,0 +1,66 @@
package cn.iocoder.yudao.module.member.controller.admin.order.vo;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import lombok.ToString;
import java.math.BigDecimal;
import java.time.LocalDateTime;
/**
* @Author:qjq
* @Date:2024/4/1 10:14
*/
@Schema(description = "管理后台 - 订单管理分页 Response VO")
@Data
@ToString(callSuper = true)
@ExcelIgnoreUnannotated
public class OrderDetailsRespVO {
@Schema(description = "门店名称", example = "真好")
@ExcelProperty("门店名称")
private String storeName;
@Schema(description = "订单编号", example = "20240401090630943547146")
@ExcelProperty("订单编号")
private Long id;
@Schema(description = "门店Id", example = "127")
private Long storeId;
@Schema(description = "用户名称", example = "张三")
@ExcelProperty("用户名称")
private String userName;
@Schema(description = "用户账号", example = "15111956918")
@ExcelProperty("用户账号")
private String userAccount;
@Schema(description = "工号", example = "15111956918")
@ExcelProperty("工号")
private String userJob;
@Schema(description = "订单交易时间", example = "2024-04-01 09:06:19")
@ExcelProperty("订单交易时间")
private LocalDateTime createTime;
@Schema(description = "金额", example = "123.11")
@ExcelProperty("金额")
private BigDecimal totalMoney;
@Schema(description = "支付方式", example = "钱包")
@ExcelProperty("钱包")
private String payMethods;
@Schema(description = "时间段", example = "早餐")
@ExcelProperty("时间段")
private String timePeriod;
@Schema(description = "订单状态", example = "交易完成")
@ExcelProperty("订单状态")
private String orderStatus ;
@Schema(description = "用户id", example = "1024")
private Long userId;
}

View File

@ -0,0 +1,69 @@
package cn.iocoder.yudao.module.member.dal.dataobject.carteenmoney;
import lombok.*;
import java.util.*;
import java.math.BigDecimal;
import java.math.BigDecimal;
import java.math.BigDecimal;
import java.math.BigDecimal;
import java.math.BigDecimal;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
/**
* 门店流水 DO
*
* @author 开发账号
*/
@TableName("t_carteen_money")
@KeySequence("t_carteen_money_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class CarteenMoneyDO extends BaseDO {
/**
* 主键id
*/
@TableId
private Long id;
/**
* 门店id
*/
private Long carteenId;
/**
* 门店名称
*/
private String carteenName;
/**
* 成交金额
*/
private BigDecimal successMoney;
/**
* 退款金额
*/
private BigDecimal errorMoney;
/**
* 平台预留金额
*/
private BigDecimal estimateMoney;
/**
* 总收入
*/
private BigDecimal sumMoney;
/**
* 总成本
*/
private BigDecimal totalCost;
/**
* 总利润
*/
private BigDecimal totalProfit;
}

View File

@ -54,4 +54,8 @@ public class DishOrderDO extends BaseDO {
* 用户
*/
private Long userId;
/**
* 支付方式
*/
private String payMethods;
}

View File

@ -0,0 +1,33 @@
package cn.iocoder.yudao.module.member.dal.mysql.carteenmoney;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo.CarteenMoneyPageReqVO;
import cn.iocoder.yudao.module.member.dal.dataobject.carteenmoney.CarteenMoneyDO;
import org.apache.ibatis.annotations.Mapper;
/**
* 门店流水 Mapper
*
* @author 开发账号
*/
@Mapper
public interface CarteenMoneyMapper extends BaseMapperX<CarteenMoneyDO> {
default PageResult<CarteenMoneyDO> selectPage(CarteenMoneyPageReqVO reqVO) {
return selectPage(reqVO, new LambdaQueryWrapperX<CarteenMoneyDO>()
.eqIfPresent(CarteenMoneyDO::getCarteenId, reqVO.getCarteenId())
.likeIfPresent(CarteenMoneyDO::getCarteenName, reqVO.getCarteenName())
.eqIfPresent(CarteenMoneyDO::getSuccessMoney, reqVO.getSuccessMoney())
.eqIfPresent(CarteenMoneyDO::getErrorMoney, reqVO.getErrorMoney())
.eqIfPresent(CarteenMoneyDO::getEstimateMoney, reqVO.getEstimateMoney())
.eqIfPresent(CarteenMoneyDO::getSumMoney, reqVO.getSumMoney())
.eqIfPresent(CarteenMoneyDO::getTotalCost, reqVO.getTotalCost())
.eqIfPresent(CarteenMoneyDO::getTotalProfit, reqVO.getTotalProfit())
.betweenIfPresent(CarteenMoneyDO::getCreateTime, reqVO.getCreateTime())
.orderByDesc(CarteenMoneyDO::getId));
}
}

View File

@ -3,10 +3,14 @@ package cn.iocoder.yudao.module.member.dal.mysql.order;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.member.controller.admin.order.vo.OrderDetailsReqVO;
import cn.iocoder.yudao.module.member.controller.app.order.vo.AppOrderPageReqVO;
import cn.iocoder.yudao.module.member.dal.dataobject.order.DishOrderDO;
import org.apache.ibatis.annotations.Mapper;
import java.time.LocalDateTime;
import java.util.List;
/**
* 会员订单 Mapper
*
@ -25,5 +29,17 @@ public interface DishOrderMapper extends BaseMapperX<DishOrderDO> {
.eqIfPresent(DishOrderDO::getUserId, reqVO.getUserId())
.orderByDesc(DishOrderDO::getId));
}
default PageResult<DishOrderDO> selectPageList(OrderDetailsReqVO reqVO, List<Long> userIds, LocalDateTime startTime, LocalDateTime endTime) {
return selectPage( reqVO, new LambdaQueryWrapperX<DishOrderDO>()
.eqIfPresent(DishOrderDO::getStoreId, reqVO.getStoreId())
.betweenIfPresent(DishOrderDO::getCreateTime, reqVO.getStartDate(), reqVO.getEndDate())
.eqIfPresent(DishOrderDO::getOrderStatus, reqVO.getOrderStatus())
.inIfPresent(DishOrderDO::getUserId, userIds)
.eqIfPresent(DishOrderDO::getId, reqVO.getOrderId())
.betweenIfPresent(DishOrderDO::getTotalMoney, reqVO.getMinAmount(), reqVO.getMaxAmount())
.betweenIfPresent(DishOrderDO::getCreateTime, startTime, endTime)
.eqIfPresent(DishOrderDO::getPayMethods, reqVO.getPayMethods())
.orderByDesc(DishOrderDO::getId));
}
}

View File

@ -0,0 +1,55 @@
package cn.iocoder.yudao.module.member.service.carteenmoney;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo.CarteenMoneyPageReqVO;
import cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo.CarteenMoneySaveReqVO;
import cn.iocoder.yudao.module.member.dal.dataobject.carteenmoney.CarteenMoneyDO;
import javax.validation.*;
/**
* 门店流水 Service 接口
*
* @author 开发账号
*/
public interface CarteenMoneyService {
/**
* 创建门店流水
*
* @param createReqVO 创建信息
* @return 编号
*/
Long createCarteenMoney(@Valid CarteenMoneySaveReqVO createReqVO);
/**
* 更新门店流水
*
* @param updateReqVO 更新信息
*/
void updateCarteenMoney(@Valid CarteenMoneySaveReqVO updateReqVO);
/**
* 删除门店流水
*
* @param id 编号
*/
void deleteCarteenMoney(Long id);
/**
* 获得门店流水
*
* @param id 编号
* @return 门店流水
*/
CarteenMoneyDO getCarteenMoney(Long id);
/**
* 获得门店流水分页
*
* @param pageReqVO 分页查询
* @return 门店流水分页
*/
PageResult<CarteenMoneyDO> getCarteenMoneyPage(CarteenMoneyPageReqVO pageReqVO);
}

View File

@ -0,0 +1,170 @@
package cn.iocoder.yudao.module.member.service.carteenmoney;
import cn.hutool.core.date.LocalDateTimeUtil;
import cn.hutool.core.util.ObjUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo.CarteenMoneyPageReqVO;
import cn.iocoder.yudao.module.member.controller.admin.carteenmoney.vo.CarteenMoneySaveReqVO;
import cn.iocoder.yudao.module.member.dal.dataobject.carteenmoney.CarteenMoneyDO;
import cn.iocoder.yudao.module.member.dal.dataobject.order.DishOrderDO;
import cn.iocoder.yudao.module.member.dal.mysql.carteenmoney.CarteenMoneyMapper;
import cn.iocoder.yudao.module.member.dal.mysql.order.DishOrderMapper;
import cn.iocoder.yudao.module.system.enums.ErrorCodeConstants;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import org.springframework.validation.annotation.Validated;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
/**
* 门店流水 Service 实现类
*
* @author 开发账号
*/
@Service
@Validated
public class CarteenMoneyServiceImpl implements CarteenMoneyService {
@Resource
private CarteenMoneyMapper carteenMoneyMapper;
@Resource
private DishOrderMapper dishOrderMapper;
@Override
public Long createCarteenMoney(CarteenMoneySaveReqVO createReqVO) {
// 插入
CarteenMoneyDO carteenMoney = BeanUtils.toBean(createReqVO, CarteenMoneyDO.class);
carteenMoneyMapper.insert(carteenMoney);
// 返回
return carteenMoney.getId();
}
@Override
public void updateCarteenMoney(CarteenMoneySaveReqVO updateReqVO) {
// 校验存在
validateCarteenMoneyExists(updateReqVO.getId());
// 更新
CarteenMoneyDO updateObj = BeanUtils.toBean(updateReqVO, CarteenMoneyDO.class);
carteenMoneyMapper.updateById(updateObj);
}
@Override
public void deleteCarteenMoney(Long id) {
// 校验存在
validateCarteenMoneyExists(id);
// 删除
carteenMoneyMapper.deleteById(id);
}
private void validateCarteenMoneyExists(Long id) {
if (carteenMoneyMapper.selectById(id) == null) {
throw exception(ErrorCodeConstants.CARTEEN_MONEY_NOT_EXISTS);
}
}
@Override
public CarteenMoneyDO getCarteenMoney(Long id) {
return carteenMoneyMapper.selectById(id);
}
@Override
public PageResult<CarteenMoneyDO> getCarteenMoneyPage(CarteenMoneyPageReqVO pageReqVO) {
List<CarteenMoneyDO> todayCarteenMoney = this.getTodayCarteenMoney(pageReqVO.getCreateTime()[1],pageReqVO.getCarteenId());
Long size= 0L;
//表示要进行处理
if(ObjUtil.isNotEmpty(todayCarteenMoney) && (pageReqVO.getPageNo()==1 || pageReqVO.getPageNo()==-1)){
todayCarteenMoney.forEach(c -> c.setCreateTime(LocalDateTime.now()));
LocalDateTime localDateTime = pageReqVO.getCreateTime()[1];
LocalDateTime localDateTime1 = pageReqVO.getCreateTime()[0];
//获取昨天
LocalDateTime offset = LocalDateTimeUtil.offset(localDateTime, -1, ChronoUnit.DAYS);
LocalDateTime end = LocalDateTimeUtil.endOfDay(offset);
pageReqVO.setCreateTime(new LocalDateTime[]{localDateTime1,end});
PageResult<CarteenMoneyDO> page = carteenMoneyMapper.selectPage(pageReqVO);
List<CarteenMoneyDO> list = page.getList();
list.addAll(todayCarteenMoney);
list.sort(Comparator.comparing(CarteenMoneyDO::getCreateTime).reversed());
page.setList(list);
page.setTotal(page.getTotal() + todayCarteenMoney.size());
return page;
}else if(ObjUtil.isNotEmpty(todayCarteenMoney)){
size= (long) todayCarteenMoney.size();
}
PageResult<CarteenMoneyDO> pageResult = carteenMoneyMapper.selectPage(pageReqVO);
pageResult.setTotal(pageResult.getTotal() + size);
return pageResult;
}
/**
* @Description: 获取今日门店流水
* @Author: qjq
* @Date: 2024/4/2 9:10
* @return
*/
public List<CarteenMoneyDO> getTodayCarteenMoney(LocalDateTime endTime,Long storeId){
//判断是否为同一天
if(LocalDateTimeUtil.isSameDay(endTime,LocalDateTime.now())){
//今日开始时间
LocalDateTime localDateTime = LocalDateTimeUtil.beginOfDay(endTime);
//今日流水明细
return this.getDishOrderDO(localDateTime, endTime,storeId);
}
return Collections.emptyList();
}
/**
* @Description: 定时计算门店流水信息
* @Author: qjq
* @Date: 2024/4/1 17:38
* @return
*/
public void insertCarteenMoney(){
//计算昨天的门店流水
LocalDateTime now = LocalDateTimeUtil.now();
//获取昨天
LocalDateTime offset = LocalDateTimeUtil.offset(now, -1, ChronoUnit.DAYS);
//昨天开始时间
LocalDateTime startDate = LocalDateTimeUtil.beginOfDay(offset);
//昨天结束时间
LocalDateTime endDate = LocalDateTimeUtil.endOfDay(offset);
carteenMoneyMapper.insertBatch(this.getDishOrderDO(startDate,endDate,null));
}
public List<CarteenMoneyDO> getDishOrderDO(LocalDateTime startDate, LocalDateTime endDate,Long storeId){
List<DishOrderDO> dishOrderDOS = dishOrderMapper.selectList(new LambdaQueryWrapperX<DishOrderDO>()
.betweenIfPresent(DishOrderDO::getCreateTime, startDate, endDate)
.eqIfPresent(DishOrderDO::getStoreId,storeId));
//根据门店id分组
Map<Long, List<DishOrderDO>> collect = dishOrderDOS.stream().collect(Collectors.groupingBy(DishOrderDO::getStoreId));
List<CarteenMoneyDO> list= new ArrayList<>();
for (Map.Entry<Long, List<DishOrderDO>> longListEntry : collect.entrySet()) {
//门店id
Long storeId1 = longListEntry.getKey();
List<DishOrderDO> value = longListEntry.getValue();
//获取昨天门店的成交金额
double sum = value.stream().map(DishOrderDO::getTotalMoney).mapToDouble(BigDecimal::doubleValue).sum();
BigDecimal bigDecimal1 = BigDecimal.valueOf(sum);
CarteenMoneyDO build = CarteenMoneyDO.builder()
.carteenName(value.get(0).getStoreName())
.carteenId(storeId1)
.successMoney(bigDecimal1)
.sumMoney(bigDecimal1).build();
list.add(build);
}
return list;
}
}

View File

@ -1,6 +1,8 @@
package cn.iocoder.yudao.module.member.service.order;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.member.controller.admin.order.vo.OrderDetailsReqVO;
import cn.iocoder.yudao.module.member.controller.admin.order.vo.OrderDetailsRespVO;
import cn.iocoder.yudao.module.member.controller.app.order.vo.AppOrderPageReqVO;
import cn.iocoder.yudao.module.member.controller.app.order.vo.AppOrderRespVO;
import cn.iocoder.yudao.module.member.controller.app.order.vo.AppOrderSaveReqVO;
@ -60,4 +62,5 @@ public interface OrderService {
*/
List<AppOrderRespVO> getOrderList();
PageResult<OrderDetailsRespVO> getPageOrderDetails(OrderDetailsReqVO reqVO);
}

View File

@ -1,14 +1,25 @@
package cn.iocoder.yudao.module.member.service.order;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.LocalDateTimeUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
import cn.iocoder.yudao.module.member.controller.admin.order.vo.OrderDetailsReqVO;
import cn.iocoder.yudao.module.member.controller.admin.order.vo.OrderDetailsRespVO;
import cn.iocoder.yudao.module.member.controller.app.order.vo.AppOrderPageReqVO;
import cn.iocoder.yudao.module.member.controller.app.order.vo.AppOrderRespVO;
import cn.iocoder.yudao.module.member.controller.app.order.vo.AppOrderSaveReqVO;
import cn.iocoder.yudao.module.member.controller.app.orderdetail.vo.AppOrderDetailRespVO;
import cn.iocoder.yudao.module.member.dal.dataobject.order.DishOrderDO;
import cn.iocoder.yudao.module.member.dal.dataobject.user.MemberUserDO;
import cn.iocoder.yudao.module.member.dal.mysql.order.DishOrderMapper;
import cn.iocoder.yudao.module.member.dal.mysql.user.MemberUserMapper;
import cn.iocoder.yudao.module.member.enums.CostTypeEnum;
import cn.iocoder.yudao.module.member.enums.TimePeriodEnum;
import cn.iocoder.yudao.module.member.service.orderdetail.OrderDetailService;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import org.springframework.stereotype.Service;
@ -16,8 +27,16 @@ import org.springframework.validation.annotation.Validated;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.time.temporal.ChronoUnit;
import java.time.temporal.TemporalUnit;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.member.enums.ErrorCodeConstants.ORDER_NOT_EXISTS;
@ -36,7 +55,8 @@ public class OrderServiceImpl implements OrderService {
@Resource
private OrderDetailService orderDetailService;
@Resource
private MemberUserMapper memberUserMapper;
@Override
public Long createOrder(AppOrderSaveReqVO createReqVO) {
// 插入
@ -103,6 +123,57 @@ public class OrderServiceImpl implements OrderService {
}
return vos;
}
@Override
public PageResult<OrderDetailsRespVO> getPageOrderDetails(OrderDetailsReqVO reqVO) {
List<Long> userIds=new ArrayList<>();
if(ObjUtil.isNotEmpty(reqVO.getUserName())
|| ObjUtil.isNotEmpty(reqVO.getUserAccount())
|| ObjUtil.isNotEmpty(reqVO.getUserJob())){
//根据用户属性获取ids
userIds = memberUserMapper.selectList(new LambdaQueryWrapperX<MemberUserDO>()
.likeIfPresent(MemberUserDO::getNickname, reqVO.getUserName())
.eqIfPresent(MemberUserDO::getMobile, reqVO.getUserAccount())
.eqIfPresent(MemberUserDO::getCardId, reqVO.getUserJob()))
.stream().map(MemberUserDO::getId).collect(Collectors.toList());
}
Map<String, LocalDateTime> timePeriod = this.getTimePeriod(reqVO.getTimePeriod());
LocalDateTime startTime =null;
LocalDateTime endTime =null;
if(ObjUtil.isNotEmpty(timePeriod)){
startTime=timePeriod.get("start");
endTime=timePeriod.get("end");
}
//进行分页查询
PageResult<DishOrderDO> pageResult = dishOrderMapper.selectPageList(reqVO, userIds, startTime, endTime);
List<OrderDetailsRespVO> list=new ArrayList<>();
for (DishOrderDO dishOrderDO : pageResult.getList()) {
OrderDetailsRespVO bean = BeanUtils.toBean(dishOrderDO, OrderDetailsRespVO.class);
MemberUserDO userDO = memberUserMapper.selectById(bean.getUserId());
bean.setUserName(userDO.getName());
bean.setUserJob(userDO.getMobile());
bean.setUserAccount(userDO.getMobile());
bean.setTimePeriod(TimePeriodEnum.MIDDAY.getTimePeriod(bean.getCreateTime()));
list.add(bean);
}
return new PageResult<>(list,pageResult.getTotal());
}
/**
* @Description: 数据类型对标 {@link CostTypeEnum}
* @Author: qjq
* @Date: 2024/4/1 11:18
* @return
*/
public Map<String,LocalDateTime> getTimePeriod(String type){
if(TimePeriodEnum.MORNING.getCode().equalsIgnoreCase(type)){
return TimePeriodEnum.MORNING.getStartToEnd();
}else if(TimePeriodEnum.MIDDAY.getCode().equalsIgnoreCase(type)){
return TimePeriodEnum.MIDDAY.getStartToEnd();
}else if(TimePeriodEnum.NIGHT.getCode().equalsIgnoreCase(type)){
return TimePeriodEnum.NIGHT.getStartToEnd();
}else {
return Collections.emptyMap();
}
}
}