菜品统计

This commit is contained in:
zengtao01
2024-04-22 18:03:18 +08:00
parent 075656cbf4
commit 99fc189db4
15 changed files with 542 additions and 1 deletions

View File

@ -68,7 +68,7 @@ public interface ErrorCodeConstants {
ErrorCode STORE_COMPLAIN_NOT_EXISTS = new ErrorCode(1_004_013_009, "订单明细不存在");
ErrorCode CUSTOMER_TRAFFIC_NOT_EXISTS = new ErrorCode(1_004_013_010, "订单明细不存在");
ErrorCode DEVICE_WARN_NOT_EXISTS = new ErrorCode(1_004_013_011, "订单明细不存在");
ErrorCode DISH_STATISTICS_NOT_EXISTS = new ErrorCode(1_004_013_012, "订单明细不存在");
ErrorCode DINING_PLATES_NOT_EXISTS = new ErrorCode(1_004_099_000, "餐盘不存在");

View File

@ -0,0 +1,95 @@
package cn.iocoder.yudao.module.member.controller.admin.dishstatistics;
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.constraints.*;
import javax.validation.*;
import javax.servlet.http.*;
import java.util.*;
import java.io.IOException;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
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.*;
import cn.iocoder.yudao.module.member.controller.admin.dishstatistics.vo.*;
import cn.iocoder.yudao.module.member.dal.dataobject.dishstatistics.DishStatisticsDO;
import cn.iocoder.yudao.module.member.service.dishstatistics.DishStatisticsService;
@Tag(name = "管理后台 - 菜品统计")
@RestController
@RequestMapping("/member/dish-statistics")
@Validated
public class DishStatisticsController {
@Resource
private DishStatisticsService dishStatisticsService;
@PostMapping("/create")
@Operation(summary = "创建菜品统计")
@PreAuthorize("@ss.hasPermission('member:dish-statistics:create')")
public CommonResult<Long> createDishStatistics(@Valid @RequestBody DishStatisticsSaveReqVO createReqVO) {
return success(dishStatisticsService.createDishStatistics(createReqVO));
}
@PutMapping("/update")
@Operation(summary = "更新菜品统计")
@PreAuthorize("@ss.hasPermission('member:dish-statistics:update')")
public CommonResult<Boolean> updateDishStatistics(@Valid @RequestBody DishStatisticsSaveReqVO updateReqVO) {
dishStatisticsService.updateDishStatistics(updateReqVO);
return success(true);
}
@DeleteMapping("/delete")
@Operation(summary = "删除菜品统计")
@Parameter(name = "id", description = "编号", required = true)
@PreAuthorize("@ss.hasPermission('member:dish-statistics:delete')")
public CommonResult<Boolean> deleteDishStatistics(@RequestParam("id") Long id) {
dishStatisticsService.deleteDishStatistics(id);
return success(true);
}
@GetMapping("/get")
@Operation(summary = "获得菜品统计")
@Parameter(name = "id", description = "编号", required = true, example = "1024")
@PreAuthorize("@ss.hasPermission('member:dish-statistics:query')")
public CommonResult<DishStatisticsRespVO> getDishStatistics(@RequestParam("id") Long id) {
DishStatisticsDO dishStatistics = dishStatisticsService.getDishStatistics(id);
return success(BeanUtils.toBean(dishStatistics, DishStatisticsRespVO.class));
}
@GetMapping("/page")
@Operation(summary = "获得菜品统计分页")
@PreAuthorize("@ss.hasPermission('member:dish-statistics:query')")
public CommonResult<PageResult<DishStatisticsRespVO>> getDishStatisticsPage(@Valid DishStatisticsPageReqVO pageReqVO) {
PageResult<DishStatisticsDO> pageResult = dishStatisticsService.getDishStatisticsPage(pageReqVO);
return success(BeanUtils.toBean(pageResult, DishStatisticsRespVO.class));
}
@GetMapping("/export-excel")
@Operation(summary = "导出菜品统计 Excel")
@PreAuthorize("@ss.hasPermission('member:dish-statistics:export')")
@OperateLog(type = EXPORT)
public void exportDishStatisticsExcel(@Valid DishStatisticsPageReqVO pageReqVO,
HttpServletResponse response) throws IOException {
pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
List<DishStatisticsDO> list = dishStatisticsService.getDishStatisticsPage(pageReqVO).getList();
// 导出 Excel
ExcelUtils.write(response, "菜品统计.xls", "数据", DishStatisticsRespVO.class,
BeanUtils.toBean(list, DishStatisticsRespVO.class));
}
}

View File

@ -0,0 +1,38 @@
package cn.iocoder.yudao.module.member.controller.admin.dishstatistics.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 DishStatisticsPageReqVO extends PageParam {
@Schema(description = "设备Ip")
private String deviceSn;
@Schema(description = "门店id", example = "26370")
private Long storeId;
@Schema(description = "报警次数", example = "24451")
private Long dishId;
@Schema(description = "菜品", example = "张三")
private String dishesName;
@Schema(description = "重量")
private BigDecimal weight;
@Schema(description = "创建时间")
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
private LocalDateTime[] createTime;
}

View File

@ -0,0 +1,45 @@
package cn.iocoder.yudao.module.member.controller.admin.dishstatistics.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 DishStatisticsRespVO {
@Schema(description = "编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "7207")
@ExcelProperty("编号")
private Long id;
@Schema(description = "设备Ip")
@ExcelProperty("设备Ip")
private String deviceSn;
@Schema(description = "门店id", example = "26370")
@ExcelProperty("门店id")
private Long storeId;
@Schema(description = "报警次数", example = "24451")
@ExcelProperty("报警次数")
private Long dishId;
@Schema(description = "菜品", example = "张三")
@ExcelProperty("菜品")
private String dishesName;
@Schema(description = "重量")
@ExcelProperty("重量")
private BigDecimal weight;
@Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED)
@ExcelProperty("创建时间")
private LocalDateTime createTime;
}

View File

@ -0,0 +1,31 @@
package cn.iocoder.yudao.module.member.controller.admin.dishstatistics.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 DishStatisticsSaveReqVO {
@Schema(description = "编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "7207")
private Long id;
@Schema(description = "设备Ip")
private String deviceSn;
@Schema(description = "门店id", example = "26370")
private Long storeId;
@Schema(description = "报警次数", example = "24451")
private Long dishId;
@Schema(description = "菜品", example = "张三")
private String dishesName;
@Schema(description = "重量")
private BigDecimal weight;
}

View File

@ -0,0 +1,62 @@
package cn.iocoder.yudao.module.member.dal.dataobject.dishstatistics;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.ToString;
import java.math.BigDecimal;
/**
* 菜品统计 DO
*
* @author 开发账号
*/
@TableName("member_dish_statistics")
@KeySequence("member_dish_statistics_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class DishStatisticsDO extends BaseDO {
/**
* 编号
*/
@TableId
private Long id;
/**
* 设备Ip
*/
private String deviceSn;
/**
* 门店id
*/
private Long storeId;
/**
* 菜品Id
*/
private Long dishId;
/**
* 菜品
*/
private String dishesName;
/**
* 重量
*/
private BigDecimal weight;
/**
* 价钱
*/
private BigDecimal money;
}

View File

@ -0,0 +1,33 @@
package cn.iocoder.yudao.module.member.dal.mysql.dishstatistics;
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.dishstatistics.vo.DishStatisticsPageReqVO;
import cn.iocoder.yudao.module.member.dal.dataobject.dishstatistics.DishStatisticsDO;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* 菜品统计 Mapper
*
* @author 开发账号
*/
@Mapper
public interface DishStatisticsMapper extends BaseMapperX<DishStatisticsDO> {
default PageResult<DishStatisticsDO> selectPage(DishStatisticsPageReqVO reqVO) {
return selectPage(reqVO, new LambdaQueryWrapperX<DishStatisticsDO>()
.eqIfPresent(DishStatisticsDO::getDeviceSn, reqVO.getDeviceSn())
.eqIfPresent(DishStatisticsDO::getStoreId, reqVO.getStoreId())
.eqIfPresent(DishStatisticsDO::getDishId, reqVO.getDishId())
.likeIfPresent(DishStatisticsDO::getDishesName, reqVO.getDishesName())
.eqIfPresent(DishStatisticsDO::getWeight, reqVO.getWeight())
.betweenIfPresent(DishStatisticsDO::getCreateTime, reqVO.getCreateTime())
.orderByDesc(DishStatisticsDO::getId));
}
List<DishStatisticsDO> getSaleData(String time);
}

View File

@ -0,0 +1,32 @@
package cn.iocoder.yudao.module.member.job;
import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler;
import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore;
import cn.iocoder.yudao.module.member.service.dishstatistics.DishStatisticsService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
/**
* @author zt
* @description <description class purpose>
* @since 2024/4/22
*/
@Slf4j
@Component
public class StatisticsJob implements JobHandler {
@Resource
private DishStatisticsService service;
@Override
@TenantIgnore
public String execute(String param) {
Integer i = service.addData();
log.info("[execute][菜品统计任务生成数据 ({}) 个]",i );
return String.format("菜品统计定时任务生成数 %s 个", i);
}
}

View File

@ -0,0 +1,59 @@
package cn.iocoder.yudao.module.member.service.dishstatistics;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.member.controller.admin.dishstatistics.vo.DishStatisticsPageReqVO;
import cn.iocoder.yudao.module.member.controller.admin.dishstatistics.vo.DishStatisticsSaveReqVO;
import cn.iocoder.yudao.module.member.dal.dataobject.dishstatistics.DishStatisticsDO;
import javax.validation.Valid;
/**
* 菜品统计 Service 接口
*
* @author 开发账号
*/
public interface DishStatisticsService {
/**
* 创建菜品统计
*
* @param createReqVO 创建信息
* @return 编号
*/
Long createDishStatistics(@Valid DishStatisticsSaveReqVO createReqVO);
/**
* 更新菜品统计
*
* @param updateReqVO 更新信息
*/
void updateDishStatistics(@Valid DishStatisticsSaveReqVO updateReqVO);
/**
* 删除菜品统计
*
* @param id 编号
*/
void deleteDishStatistics(Long id);
/**
* 获得菜品统计
*
* @param id 编号
* @return 菜品统计
*/
DishStatisticsDO getDishStatistics(Long id);
/**
* 获得菜品统计分页
*
* @param pageReqVO 分页查询
* @return 菜品统计分页
*/
PageResult<DishStatisticsDO> getDishStatisticsPage(DishStatisticsPageReqVO pageReqVO);
/**
* 统计昨日数据
*/
Integer addData();
}

View File

@ -0,0 +1,96 @@
package cn.iocoder.yudao.module.member.service.dishstatistics;
import cn.hutool.core.collection.CollectionUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.member.controller.admin.dishstatistics.vo.DishStatisticsPageReqVO;
import cn.iocoder.yudao.module.member.controller.admin.dishstatistics.vo.DishStatisticsSaveReqVO;
import cn.iocoder.yudao.module.member.dal.dataobject.dishstatistics.DishStatisticsDO;
import cn.iocoder.yudao.module.member.dal.mysql.dishstatistics.DishStatisticsMapper;
import cn.iocoder.yudao.module.member.util.MemberConstants;
import cn.iocoder.yudao.module.system.api.dish.DishesApi;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
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.*;
/**
* 菜品统计 Service 实现类
*
* @author 开发账号
*/
@Service
@Validated
public class DishStatisticsServiceImpl implements DishStatisticsService {
@Resource
private DishStatisticsMapper dishStatisticsMapper;
@Resource
private DishesApi dishesApi;
@Override
public Long createDishStatistics(DishStatisticsSaveReqVO createReqVO) {
// 插入
DishStatisticsDO dishStatistics = BeanUtils.toBean(createReqVO, DishStatisticsDO.class);
dishStatisticsMapper.insert(dishStatistics);
// 返回
return dishStatistics.getId();
}
@Override
public void updateDishStatistics(DishStatisticsSaveReqVO updateReqVO) {
// 校验存在
validateDishStatisticsExists(updateReqVO.getId());
// 更新
DishStatisticsDO updateObj = BeanUtils.toBean(updateReqVO, DishStatisticsDO.class);
dishStatisticsMapper.updateById(updateObj);
}
@Override
public void deleteDishStatistics(Long id) {
// 校验存在
validateDishStatisticsExists(id);
// 删除
dishStatisticsMapper.deleteById(id);
}
private void validateDishStatisticsExists(Long id) {
if (dishStatisticsMapper.selectById(id) == null) {
throw exception(DISH_STATISTICS_NOT_EXISTS);
}
}
@Override
public DishStatisticsDO getDishStatistics(Long id) {
return dishStatisticsMapper.selectById(id);
}
@Override
public PageResult<DishStatisticsDO> getDishStatisticsPage(DishStatisticsPageReqVO pageReqVO) {
return dishStatisticsMapper.selectPage(pageReqVO);
}
@Override
public Integer addData() {
String time = LocalDateTime.now().format(DateTimeFormatter.ofPattern(MemberConstants.DATE_FORMAT));
List<DishStatisticsDO> saleData = dishStatisticsMapper.getSaleData(time);
if(CollectionUtil.isNotEmpty(saleData)){
List<Long> dishIds = saleData.stream().map(DishStatisticsDO::getDishId).collect(Collectors.toList());
Map<Long, String> dishName = dishesApi.getDishName(dishIds);
saleData.forEach(add ->{
add.setDishesName(dishName.get(add.getDishId()));
});
dishStatisticsMapper.insertBatch(saleData);
}
return saleData.size();
}
}

View File

@ -0,0 +1,20 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.iocoder.yudao.module.member.dal.mysql.dishstatistics.DishStatisticsMapper">
<!--
一般情况下,尽可能使用 Mapper 进行 CRUD 增删改查即可。
无法满足的场景,例如说多表关联查询,才使用 XML 编写 SQL。
代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。
文档可见https://www.iocoder.cn/MyBatis/x-plugins/
-->
<select id="getSaleData" resultType="cn.iocoder.yudao.module.member.dal.dataobject.dishstatistics.DishStatisticsDO">
select a.store_id as storeId, b.sn as deviceSn, b.dishes_id as dishId, sum(b.weight) as weight, sum(b.price) as money
from member_dish_order a
right join member_order_detail b on a.id = b.order_id
where date_format(b.create_time, '%Y-%m-%d') = #{time}
group by a.store_id, b.sn, b.dishes_id
</select>
</mapper>

View File

@ -2,6 +2,9 @@ package cn.iocoder.yudao.module.system.api.dish;
import cn.iocoder.yudao.module.system.api.dish.dto.DishesRespDto;
import java.util.List;
import java.util.Map;
/**
* @author zt
* @description <description class purpose>
@ -13,4 +16,9 @@ public interface DishesApi {
* @Description: 根据菜品id 获取菜品属性
*/
public DishesRespDto getDish(Long id);
/**
* @Description: 根据菜品id 获取菜品名称
*/
public Map<Long,String> getDishName(List<Long> ids);
}

View File

@ -8,6 +8,9 @@ import cn.iocoder.yudao.module.system.service.dishes.DishesService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
import java.util.Map;
/**
* 菜品营养 Service 接口
@ -25,4 +28,9 @@ public class DishesApiImpl implements DishesApi {
DishesDO dishes = dishesService.getDishes(id);
return BeanUtils.toBean(dishes,DishesRespDto.class);
}
@Override
public Map<Long, String> getDishName(List<Long> ids) {
return dishesService.getDishName(ids);
}
}

View File

@ -7,6 +7,8 @@ import cn.iocoder.yudao.module.system.controller.admin.dishes.vo.DishesSaveReqVO
import cn.iocoder.yudao.module.system.dal.dataobject.dishes.DishesDO;
import javax.validation.Valid;
import java.util.List;
import java.util.Map;
/**
* 菜品管理 Service 接口
@ -54,4 +56,7 @@ public interface DishesService {
*/
PageResult<DishesDO> getDishesPage(DishesPageReqVO pageReqVO);
Map<Long,String> getDishName(List<Long> ids);
}

View File

@ -19,6 +19,7 @@ import cn.iocoder.yudao.module.system.dal.mysql.dishes.DishesMapper;
import cn.iocoder.yudao.module.system.enums.ErrorCodeConstants;
import cn.iocoder.yudao.module.system.service.dishesnutrition.DishesNutritionService;
import cn.iocoder.yudao.module.system.service.dishesraw.DishesRawService;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.SneakyThrows;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
@ -26,6 +27,8 @@ import org.springframework.validation.annotation.Validated;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
@ -137,4 +140,10 @@ public class DishesServiceImpl implements DishesService {
return dishesMapper.selectPage(pageReqVO);
}
@Override
public Map<Long, String> getDishName(List<Long> ids) {
List<DishesDO> dishesDOS = dishesMapper.selectList(Wrappers.<DishesDO>lambdaQuery().in(DishesDO::getId, ids));
Map<Long, String> collect = dishesDOS.stream().collect(Collectors.toMap(DishesDO::getId, DishesDO::getDishesName));
return collect;
}
}