DeXun/klp-oa
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(ems): 添加能源消耗记录管理功能

Browse Source 
- 创建 EmsEnergyRecord 实体类，定义能耗记录主键、表计ID、能源ID、消耗量等字段
- 实现 EmsEnergyRecordBo 业务对象，用于接收前端参数并进行数据验证
- 开发 EmsEnergyRecordController 控制器，提供查询、新增、修改、删除和导出功能
- 配置 EmsEnergyRecordMapper 数据访问接口，继承 BaseMapperPlus 进行数据库操作
- 编写 EmsEnergyRecordMapper.xml 映射文件，定义结果集映射关系
- 实现 EmsEnergyRecordServiceImpl 服务类，封装业务逻辑和数据处理方法
- 定义 EmsEnergyRecordVo 视图对象，配置Excel导出注解和字典转换功能
- 提供 IEmsEnergyRecordService 接口，规范服务层方法契约
This commit is contained in:
Joshi
2026-04-20 13:08:33 +08:00
parent af002b84d3
commit bd4d591934
8 changed files with 488 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

99
klp-ems/src/main/java/com/klp/ems/controller/EmsEnergyRecordController.java Normal file
View File

@@ -0,0 +1,99 @@
package com.klp.ems.controller;
import java.util.List;
import java.util.Arrays;
import lombok.RequiredArgsConstructor;
import javax.servlet.http.HttpServletResponse;
import javax.validation.constraints.*;
import org.springframework.web.bind.annotation.*;
import org.springframework.validation.annotation.Validated;
import com.klp.common.annotation.RepeatSubmit;
import com.klp.common.annotation.Log;
import com.klp.common.core.controller.BaseController;
import com.klp.common.core.domain.PageQuery;
import com.klp.common.core.domain.R;
import com.klp.common.core.validate.AddGroup;
import com.klp.common.core.validate.EditGroup;
import com.klp.common.enums.BusinessType;
import com.klp.common.utils.poi.ExcelUtil;
import com.klp.ems.domain.vo.EmsEnergyRecordVo;
import com.klp.ems.domain.bo.EmsEnergyRecordBo;
import com.klp.ems.service.IEmsEnergyRecordService;
import com.klp.common.core.page.TableDataInfo;
/**
* 能源消耗记录
*
* @author klp
* @date 2026-04-20
*/
@Validated
@RequiredArgsConstructor
@RestController
@RequestMapping("/ems/energyRecord")
public class EmsEnergyRecordController extends BaseController {
private final IEmsEnergyRecordService iEmsEnergyRecordService;
/**
* 查询能源消耗记录列表
*/
@GetMapping("/list")
public TableDataInfo<EmsEnergyRecordVo> list(EmsEnergyRecordBo bo, PageQuery pageQuery) {
return iEmsEnergyRecordService.queryPageList(bo, pageQuery);
}
/**
* 导出能源消耗记录列表
*/
@Log(title = "能源消耗记录", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(EmsEnergyRecordBo bo, HttpServletResponse response) {
List<EmsEnergyRecordVo> list = iEmsEnergyRecordService.queryList(bo);
ExcelUtil.exportExcel(list, "能源消耗记录", EmsEnergyRecordVo.class, response);
}
/**
* 获取能源消耗记录详细信息
*
* @param energyRecordId 主键
*/
@GetMapping("/{energyRecordId}")
public R<EmsEnergyRecordVo> getInfo(@NotNull(message = "主键不能为空")
@PathVariable Long energyRecordId) {
return R.ok(iEmsEnergyRecordService.queryById(energyRecordId));
}
/**
* 新增能源消耗记录
*/
@Log(title = "能源消耗记录", businessType = BusinessType.INSERT)
@RepeatSubmit()
@PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody EmsEnergyRecordBo bo) {
return toAjax(iEmsEnergyRecordService.insertByBo(bo));
}
/**
* 修改能源消耗记录
*/
@Log(title = "能源消耗记录", businessType = BusinessType.UPDATE)
@RepeatSubmit()
@PutMapping()
public R<Void> edit(@Validated(EditGroup.class) @RequestBody EmsEnergyRecordBo bo) {
return toAjax(iEmsEnergyRecordService.updateByBo(bo));
}
/**
* 删除能源消耗记录
*
* @param energyRecordIds 主键串
*/
@Log(title = "能源消耗记录", businessType = BusinessType.DELETE)
@DeleteMapping("/{energyRecordIds}")
public R<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] energyRecordIds) {
return toAjax(iEmsEnergyRecordService.deleteWithValidByIds(Arrays.asList(energyRecordIds), true));
}
}

60
klp-ems/src/main/java/com/klp/ems/domain/EmsEnergyRecord.java Normal file
View File

@@ -0,0 +1,60 @@
package com.klp.ems.domain;
import com.baomidou.mybatisplus.annotation.*;
import com.klp.common.core.domain.BaseEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.math.BigDecimal;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
/**
* 能源消耗记录对象 ems_energy_record
*
* @author klp
* @date 2026-04-20
*/
@Data
@EqualsAndHashCode(callSuper = true)
@TableName("ems_energy_record")
public class EmsEnergyRecord extends BaseEntity {
private static final long serialVersionUID=1L;
/**
* 能耗记录主键ID
*/
@TableId(value = "energy_record_id")
private Long energyRecordId;
/**
* 表计ID（关联计量设备表）
*/
private Long meterId;
/**
* 能源ID（关联能源类型表：电/水/气/暖等）
*/
private Long energyId;
/**
* 消耗量
*/
private BigDecimal consumption;
/**
* 统计日期（yyyy-MM-dd）
*/
private Date recordDate;
/**
* 记录人ID
*/
private Long recordedBy;
/**
* 删除标志（0=存在 2=删除）
*/
@TableLogic
private String delFlag;
/**
* 备注
*/
private String remark;
}

59
klp-ems/src/main/java/com/klp/ems/domain/bo/EmsEnergyRecordBo.java Normal file
View File

@@ -0,0 +1,59 @@
package com.klp.ems.domain.bo;
import com.klp.common.core.domain.BaseEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.*;
import java.math.BigDecimal;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
/**
* 能源消耗记录业务对象 ems_energy_record
*
* @author klp
* @date 2026-04-20
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class EmsEnergyRecordBo extends BaseEntity {
/**
* 能耗记录主键ID
*/
private Long energyRecordId;
/**
* 表计ID（关联计量设备表）
*/
private Long meterId;
/**
* 能源ID（关联能源类型表：电/水/气/暖等）
*/
private Long energyId;
/**
* 消耗量
*/
private BigDecimal consumption;
/**
* 统计日期（yyyy-MM-dd）
*/
private Date recordDate;
/**
* 记录人ID
*/
private Long recordedBy;
/**
* 备注
*/
private String remark;
}

71
klp-ems/src/main/java/com/klp/ems/domain/vo/EmsEnergyRecordVo.java Normal file
View File

@@ -0,0 +1,71 @@
package com.klp.ems.domain.vo;
import java.math.BigDecimal;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import com.klp.common.annotation.ExcelDictFormat;
import com.klp.common.convert.ExcelDictConvert;
import lombok.Data;
/**
* 能源消耗记录视图对象 ems_energy_record
*
* @author klp
* @date 2026-04-20
*/
@Data
@ExcelIgnoreUnannotated
public class EmsEnergyRecordVo {
private static final long serialVersionUID = 1L;
/**
* 能耗记录主键ID
*/
@ExcelProperty(value = "能耗记录主键ID")
private Long energyRecordId;
/**
* 表计ID（关联计量设备表）
*/
@ExcelProperty(value = "表计ID", converter = ExcelDictConvert.class)
@ExcelDictFormat(readConverterExp = "关=联计量设备表")
private Long meterId;
/**
* 能源ID（关联能源类型表：电/水/气/暖等）
*/
@ExcelProperty(value = "能源ID", converter = ExcelDictConvert.class)
@ExcelDictFormat(readConverterExp = "关=联能源类型表：电/水/气/暖等")
private Long energyId;
/**
* 消耗量
*/
@ExcelProperty(value = "消耗量")
private BigDecimal consumption;
/**
* 统计日期（yyyy-MM-dd）
*/
@ExcelProperty(value = "统计日期", converter = ExcelDictConvert.class)
@ExcelDictFormat(readConverterExp = "y=yyy-MM-dd")
private Date recordDate;
/**
* 记录人ID
*/
@ExcelProperty(value = "记录人ID")
private Long recordedBy;
/**
* 备注
*/
@ExcelProperty(value = "备注")
private String remark;
}

15
klp-ems/src/main/java/com/klp/ems/mapper/EmsEnergyRecordMapper.java Normal file
View File

@@ -0,0 +1,15 @@
package com.klp.ems.mapper;
import com.klp.ems.domain.EmsEnergyRecord;
import com.klp.ems.domain.vo.EmsEnergyRecordVo;
import com.klp.common.core.mapper.BaseMapperPlus;
/**
* 能源消耗记录Mapper接口
*
* @author klp
* @date 2026-04-20
*/
public interface EmsEnergyRecordMapper extends BaseMapperPlus<EmsEnergyRecordMapper, EmsEnergyRecord, EmsEnergyRecordVo> {
}

49
klp-ems/src/main/java/com/klp/ems/service/IEmsEnergyRecordService.java Normal file
View File

@@ -0,0 +1,49 @@
package com.klp.ems.service;
import com.klp.ems.domain.EmsEnergyRecord;
import com.klp.ems.domain.vo.EmsEnergyRecordVo;
import com.klp.ems.domain.bo.EmsEnergyRecordBo;
import com.klp.common.core.page.TableDataInfo;
import com.klp.common.core.domain.PageQuery;
import java.util.Collection;
import java.util.List;
/**
* 能源消耗记录Service接口
*
* @author klp
* @date 2026-04-20
*/
public interface IEmsEnergyRecordService {
/**
* 查询能源消耗记录
*/
EmsEnergyRecordVo queryById(Long energyRecordId);
/**
* 查询能源消耗记录列表
*/
TableDataInfo<EmsEnergyRecordVo> queryPageList(EmsEnergyRecordBo bo, PageQuery pageQuery);
/**
* 查询能源消耗记录列表
*/
List<EmsEnergyRecordVo> queryList(EmsEnergyRecordBo bo);
/**
* 新增能源消耗记录
*/
Boolean insertByBo(EmsEnergyRecordBo bo);
/**
* 修改能源消耗记录
*/
Boolean updateByBo(EmsEnergyRecordBo bo);
/**
* 校验并批量删除能源消耗记录信息
*/
Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
}

112
klp-ems/src/main/java/com/klp/ems/service/impl/EmsEnergyRecordServiceImpl.java Normal file
View File

@@ -0,0 +1,112 @@
package com.klp.ems.service.impl;
import cn.hutool.core.bean.BeanUtil;
import com.klp.common.core.page.TableDataInfo;
import com.klp.common.core.domain.PageQuery;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import com.klp.ems.domain.bo.EmsEnergyRecordBo;
import com.klp.ems.domain.vo.EmsEnergyRecordVo;
import com.klp.ems.domain.EmsEnergyRecord;
import com.klp.ems.mapper.EmsEnergyRecordMapper;
import com.klp.ems.service.IEmsEnergyRecordService;
import java.util.List;
import java.util.Map;
import java.util.Collection;
/**
* 能源消耗记录Service业务层处理
*
* @author klp
* @date 2026-04-20
*/
@RequiredArgsConstructor
@Service
public class EmsEnergyRecordServiceImpl implements IEmsEnergyRecordService {
private final EmsEnergyRecordMapper baseMapper;
/**
* 查询能源消耗记录
*/
@Override
public EmsEnergyRecordVo queryById(Long energyRecordId){
return baseMapper.selectVoById(energyRecordId);
}
/**
* 查询能源消耗记录列表
*/
@Override
public TableDataInfo<EmsEnergyRecordVo> queryPageList(EmsEnergyRecordBo bo, PageQuery pageQuery) {
LambdaQueryWrapper<EmsEnergyRecord> lqw = buildQueryWrapper(bo);
Page<EmsEnergyRecordVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result);
}
/**
* 查询能源消耗记录列表
*/
@Override
public List<EmsEnergyRecordVo> queryList(EmsEnergyRecordBo bo) {
LambdaQueryWrapper<EmsEnergyRecord> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw);
}
private LambdaQueryWrapper<EmsEnergyRecord> buildQueryWrapper(EmsEnergyRecordBo bo) {
Map<String, Object> params = bo.getParams();
LambdaQueryWrapper<EmsEnergyRecord> lqw = Wrappers.lambdaQuery();
lqw.eq(bo.getMeterId() != null, EmsEnergyRecord::getMeterId, bo.getMeterId());
lqw.eq(bo.getEnergyId() != null, EmsEnergyRecord::getEnergyId, bo.getEnergyId());
lqw.eq(bo.getConsumption() != null, EmsEnergyRecord::getConsumption, bo.getConsumption());
lqw.eq(bo.getRecordDate() != null, EmsEnergyRecord::getRecordDate, bo.getRecordDate());
lqw.eq(bo.getRecordedBy() != null, EmsEnergyRecord::getRecordedBy, bo.getRecordedBy());
return lqw;
}
/**
* 新增能源消耗记录
*/
@Override
public Boolean insertByBo(EmsEnergyRecordBo bo) {
EmsEnergyRecord add = BeanUtil.toBean(bo, EmsEnergyRecord.class);
validEntityBeforeSave(add);
boolean flag = baseMapper.insert(add) > 0;
if (flag) {
bo.setEnergyRecordId(add.getEnergyRecordId());
}
return flag;
}
/**
* 修改能源消耗记录
*/
@Override
public Boolean updateByBo(EmsEnergyRecordBo bo) {
EmsEnergyRecord update = BeanUtil.toBean(bo, EmsEnergyRecord.class);
validEntityBeforeSave(update);
return baseMapper.updateById(update) > 0;
}
/**
* 保存前的数据校验
*/
private void validEntityBeforeSave(EmsEnergyRecord entity){
//TODO 做一些数据校验,如唯一约束
}
/**
* 批量删除能源消耗记录
*/
@Override
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
if(isValid){
//TODO 做一些业务上的校验,判断是否需要校验
}
return baseMapper.deleteBatchIds(ids) > 0;
}
}

23
klp-ems/src/main/resources/mapper/EmsEnergyRecordMapper.xml Normal file
View File

@@ -0,0 +1,23 @@
<?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="com.klp.ems.mapper.EmsEnergyRecordMapper">
<resultMap type="com.klp.ems.domain.EmsEnergyRecord" id="EmsEnergyRecordResult">
<result property="energyRecordId" column="energy_record_id"/>
<result property="meterId" column="meter_id"/>
<result property="energyId" column="energy_id"/>
<result property="consumption" column="consumption"/>
<result property="recordDate" column="record_date"/>
<result property="recordedBy" column="recorded_by"/>
<result property="createBy" column="create_by"/>
<result property="updateBy" column="update_by"/>
<result property="createTime" column="create_time"/>
<result property="updateTime" column="update_time"/>
<result property="delFlag" column="del_flag"/>
<result property="remark" column="remark"/>
</resultMap>
</mapper>