From 3a57a654bad65c79e536b3a627665c0466a6f93e Mon Sep 17 00:00:00 2001 From: yinq Date: Mon, 4 Aug 2025 15:25:54 +0800 Subject: [PATCH] =?UTF-8?q?add=20=E5=8E=8B=E7=BC=A9=E7=A9=BA=E6=B0=94?= =?UTF-8?q?=E3=80=81=E6=B0=AE=E6=B0=94=E5=AE=9E=E6=97=B6=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../EmsRecordAirInstantController.java | 106 +++++++++++ .../EmsRecordNitrogenInstantController.java | 106 +++++++++++ .../record/domain/EmsRecordAirInstant.java | 167 ++++++++++++++++++ .../domain/EmsRecordNitrogenInstant.java | 167 ++++++++++++++++++ .../mapper/EmsRecordAirInstantMapper.java | 61 +++++++ .../EmsRecordNitrogenInstantMapper.java | 61 +++++++ .../service/IEmsRecordAirInstantService.java | 61 +++++++ .../IEmsRecordNitrogenInstantService.java | 61 +++++++ .../impl/EmsRecordAirInstantServiceImpl.java | 93 ++++++++++ .../EmsRecordNitrogenInstantServiceImpl.java | 93 ++++++++++ .../ems/record/EmsRecordAirInstantMapper.xml | 96 ++++++++++ .../record/EmsRecordNitrogenInstantMapper.xml | 96 ++++++++++ 12 files changed, 1168 insertions(+) create mode 100644 os-ems/src/main/java/com/os/ems/record/controller/EmsRecordAirInstantController.java create mode 100644 os-ems/src/main/java/com/os/ems/record/controller/EmsRecordNitrogenInstantController.java create mode 100644 os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAirInstant.java create mode 100644 os-ems/src/main/java/com/os/ems/record/domain/EmsRecordNitrogenInstant.java create mode 100644 os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordAirInstantMapper.java create mode 100644 os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordNitrogenInstantMapper.java create mode 100644 os-ems/src/main/java/com/os/ems/record/service/IEmsRecordAirInstantService.java create mode 100644 os-ems/src/main/java/com/os/ems/record/service/IEmsRecordNitrogenInstantService.java create mode 100644 os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAirInstantServiceImpl.java create mode 100644 os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordNitrogenInstantServiceImpl.java create mode 100644 os-ems/src/main/resources/mapper/ems/record/EmsRecordAirInstantMapper.xml create mode 100644 os-ems/src/main/resources/mapper/ems/record/EmsRecordNitrogenInstantMapper.xml diff --git a/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordAirInstantController.java b/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordAirInstantController.java new file mode 100644 index 0000000..1652bbe --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordAirInstantController.java @@ -0,0 +1,106 @@ +package com.os.ems.record.controller; + +import java.util.List; +import javax.servlet.http.HttpServletResponse; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import com.os.common.annotation.Log; +import com.os.common.core.controller.BaseController; +import com.os.common.core.domain.AjaxResult; +import com.os.common.enums.BusinessType; +import com.os.ems.record.domain.EmsRecordAirInstant; +import com.os.ems.record.service.IEmsRecordAirInstantService; +import com.os.common.utils.poi.ExcelUtil; +import com.os.common.core.page.TableDataInfo; + +/** + * 压缩空气实时数据Controller + * + * @author Yinq + * @date 2025-08-01 + */ +@RestController +@RequestMapping("/ems/record/recordAirInstant") +public class EmsRecordAirInstantController extends BaseController +{ + @Autowired + private IEmsRecordAirInstantService emsRecordAirInstantService; + + /** + * 查询压缩空气实时数据列表 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordAirInstant:list')") + @GetMapping("/list") + public TableDataInfo list(EmsRecordAirInstant emsRecordAirInstant) + { + startPage(); + List list = emsRecordAirInstantService.selectEmsRecordAirInstantList(emsRecordAirInstant); + return getDataTable(list); + } + + /** + * 导出压缩空气实时数据列表 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordAirInstant:export')") + @Log(title = "压缩空气实时数据", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, EmsRecordAirInstant emsRecordAirInstant) + { + List list = emsRecordAirInstantService.selectEmsRecordAirInstantList(emsRecordAirInstant); + ExcelUtil util = new ExcelUtil(EmsRecordAirInstant.class); + util.exportExcel(response, list, "压缩空气实时数据数据"); + } + + /** + * 获取压缩空气实时数据详细信息 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordAirInstant:query')") + @GetMapping(value = "/{objId}") + public AjaxResult getInfo(@PathVariable("objId") Long objId) + { + return success(emsRecordAirInstantService.selectEmsRecordAirInstantByObjId(objId)); + } + + /** + * 新增压缩空气实时数据 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordAirInstant:add')") + @Log(title = "压缩空气实时数据", businessType = BusinessType.INSERT) + @PostMapping + public AjaxResult add(@RequestBody EmsRecordAirInstant emsRecordAirInstant) + { + emsRecordAirInstant.setCreateBy(getUsername()); + return toAjax(emsRecordAirInstantService.insertEmsRecordAirInstant(emsRecordAirInstant)); + } + + /** + * 修改压缩空气实时数据 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordAirInstant:edit')") + @Log(title = "压缩空气实时数据", businessType = BusinessType.UPDATE) + @PutMapping + public AjaxResult edit(@RequestBody EmsRecordAirInstant emsRecordAirInstant) + { + emsRecordAirInstant.setUpdateBy(getUsername()); + return toAjax(emsRecordAirInstantService.updateEmsRecordAirInstant(emsRecordAirInstant)); + } + + /** + * 删除压缩空气实时数据 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordAirInstant:remove')") + @Log(title = "压缩空气实时数据", businessType = BusinessType.DELETE) + @DeleteMapping("/{objIds}") + public AjaxResult remove(@PathVariable Long[] objIds) + { + return toAjax(emsRecordAirInstantService.deleteEmsRecordAirInstantByObjIds(objIds)); + } +} diff --git a/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordNitrogenInstantController.java b/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordNitrogenInstantController.java new file mode 100644 index 0000000..0bf4f66 --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/controller/EmsRecordNitrogenInstantController.java @@ -0,0 +1,106 @@ +package com.os.ems.record.controller; + +import java.util.List; +import javax.servlet.http.HttpServletResponse; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import com.os.common.annotation.Log; +import com.os.common.core.controller.BaseController; +import com.os.common.core.domain.AjaxResult; +import com.os.common.enums.BusinessType; +import com.os.ems.record.domain.EmsRecordNitrogenInstant; +import com.os.ems.record.service.IEmsRecordNitrogenInstantService; +import com.os.common.utils.poi.ExcelUtil; +import com.os.common.core.page.TableDataInfo; + +/** + * 氮气实时数据Controller + * + * @author Yinq + * @date 2025-08-01 + */ +@RestController +@RequestMapping("/ems/record/recordNitrogenInstant") +public class EmsRecordNitrogenInstantController extends BaseController +{ + @Autowired + private IEmsRecordNitrogenInstantService emsRecordNitrogenInstantService; + + /** + * 查询氮气实时数据列表 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordNitrogenInstant:list')") + @GetMapping("/list") + public TableDataInfo list(EmsRecordNitrogenInstant emsRecordNitrogenInstant) + { + startPage(); + List list = emsRecordNitrogenInstantService.selectEmsRecordNitrogenInstantList(emsRecordNitrogenInstant); + return getDataTable(list); + } + + /** + * 导出氮气实时数据列表 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordNitrogenInstant:export')") + @Log(title = "氮气实时数据", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, EmsRecordNitrogenInstant emsRecordNitrogenInstant) + { + List list = emsRecordNitrogenInstantService.selectEmsRecordNitrogenInstantList(emsRecordNitrogenInstant); + ExcelUtil util = new ExcelUtil(EmsRecordNitrogenInstant.class); + util.exportExcel(response, list, "氮气实时数据数据"); + } + + /** + * 获取氮气实时数据详细信息 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordNitrogenInstant:query')") + @GetMapping(value = "/{objId}") + public AjaxResult getInfo(@PathVariable("objId") Long objId) + { + return success(emsRecordNitrogenInstantService.selectEmsRecordNitrogenInstantByObjId(objId)); + } + + /** + * 新增氮气实时数据 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordNitrogenInstant:add')") + @Log(title = "氮气实时数据", businessType = BusinessType.INSERT) + @PostMapping + public AjaxResult add(@RequestBody EmsRecordNitrogenInstant emsRecordNitrogenInstant) + { + emsRecordNitrogenInstant.setCreateBy(getUsername()); + return toAjax(emsRecordNitrogenInstantService.insertEmsRecordNitrogenInstant(emsRecordNitrogenInstant)); + } + + /** + * 修改氮气实时数据 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordNitrogenInstant:edit')") + @Log(title = "氮气实时数据", businessType = BusinessType.UPDATE) + @PutMapping + public AjaxResult edit(@RequestBody EmsRecordNitrogenInstant emsRecordNitrogenInstant) + { + emsRecordNitrogenInstant.setUpdateBy(getUsername()); + return toAjax(emsRecordNitrogenInstantService.updateEmsRecordNitrogenInstant(emsRecordNitrogenInstant)); + } + + /** + * 删除氮气实时数据 + */ + @PreAuthorize("@ss.hasPermi('ems/record:recordNitrogenInstant:remove')") + @Log(title = "氮气实时数据", businessType = BusinessType.DELETE) + @DeleteMapping("/{objIds}") + public AjaxResult remove(@PathVariable Long[] objIds) + { + return toAjax(emsRecordNitrogenInstantService.deleteEmsRecordNitrogenInstantByObjIds(objIds)); + } +} diff --git a/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAirInstant.java b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAirInstant.java new file mode 100644 index 0000000..7a2719f --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordAirInstant.java @@ -0,0 +1,167 @@ +package com.os.ems.record.domain; + +import java.util.Date; +import com.fasterxml.jackson.annotation.JsonFormat; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.os.common.annotation.Excel; +import com.os.common.core.domain.BaseEntity; + +/** + * 压缩空气实时数据对象 ems_record_air_instant + * + * @author Yinq + * @date 2025-08-01 + */ +public class EmsRecordAirInstant extends BaseEntity +{ + private static final long serialVersionUID = 1L; + + /** 自增标识 */ + private Long objId; + + /** 计量设备编号 */ + @Excel(name = "计量设备编号") + private String monitorCode; + + /** 采集时间 */ + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "采集时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") + private Date collectTime; + + /** 瞬时流量 */ + @Excel(name = "瞬时流量") + private Long fluxFlow; + + /** 累计流量 */ + @Excel(name = "累计流量") + private Long steamFlow; + + /** 露点温度 */ + @Excel(name = "露点温度") + private Long temperature; + + /** 压力 */ + @Excel(name = "压力") + private Long press; + + /** 密度 */ + @Excel(name = "密度") + private Long density; + + /** 压力差值 */ + @Excel(name = "压力差值") + private Long differencePress; + + /** 记录时间 */ + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "记录时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") + private Date recordTime; + + public void setObjId(Long objId) + { + this.objId = objId; + } + + public Long getObjId() + { + return objId; + } + public void setMonitorCode(String monitorCode) + { + this.monitorCode = monitorCode; + } + + public String getMonitorCode() + { + return monitorCode; + } + public void setCollectTime(Date collectTime) + { + this.collectTime = collectTime; + } + + public Date getCollectTime() + { + return collectTime; + } + public void setFluxFlow(Long fluxFlow) + { + this.fluxFlow = fluxFlow; + } + + public Long getFluxFlow() + { + return fluxFlow; + } + public void setSteamFlow(Long steamFlow) + { + this.steamFlow = steamFlow; + } + + public Long getSteamFlow() + { + return steamFlow; + } + public void setTemperature(Long temperature) + { + this.temperature = temperature; + } + + public Long getTemperature() + { + return temperature; + } + public void setPress(Long press) + { + this.press = press; + } + + public Long getPress() + { + return press; + } + public void setDensity(Long density) + { + this.density = density; + } + + public Long getDensity() + { + return density; + } + public void setDifferencePress(Long differencePress) + { + this.differencePress = differencePress; + } + + public Long getDifferencePress() + { + return differencePress; + } + public void setRecordTime(Date recordTime) + { + this.recordTime = recordTime; + } + + public Date getRecordTime() + { + return recordTime; + } + + @Override + public String toString() { + return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) + .append("objId", getObjId()) + .append("monitorCode", getMonitorCode()) + .append("collectTime", getCollectTime()) + .append("fluxFlow", getFluxFlow()) + .append("steamFlow", getSteamFlow()) + .append("temperature", getTemperature()) + .append("press", getPress()) + .append("density", getDensity()) + .append("differencePress", getDifferencePress()) + .append("recordTime", getRecordTime()) + .toString(); + } +} diff --git a/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordNitrogenInstant.java b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordNitrogenInstant.java new file mode 100644 index 0000000..8e3f401 --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordNitrogenInstant.java @@ -0,0 +1,167 @@ +package com.os.ems.record.domain; + +import java.util.Date; +import com.fasterxml.jackson.annotation.JsonFormat; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.os.common.annotation.Excel; +import com.os.common.core.domain.BaseEntity; + +/** + * 氮气实时数据对象 ems_record_nitrogen_instant + * + * @author Yinq + * @date 2025-08-01 + */ +public class EmsRecordNitrogenInstant extends BaseEntity +{ + private static final long serialVersionUID = 1L; + + /** 自增标识 */ + private Long objId; + + /** 计量设备编号 */ + @Excel(name = "计量设备编号") + private String monitorCode; + + /** 采集时间 */ + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "采集时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") + private Date collectTime; + + /** 瞬时流量 */ + @Excel(name = "瞬时流量") + private Long fluxFlow; + + /** 累计流量 */ + @Excel(name = "累计流量") + private Long steamFlow; + + /** 露点温度 */ + @Excel(name = "露点温度") + private Long temperature; + + /** 压力 */ + @Excel(name = "压力") + private Long press; + + /** 纯度 */ + @Excel(name = "纯度") + private Long purity; + + /** 压力差值 */ + @Excel(name = "压力差值") + private Long differencePress; + + /** 记录时间 */ + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "记录时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") + private Date recordTime; + + public void setObjId(Long objId) + { + this.objId = objId; + } + + public Long getObjId() + { + return objId; + } + public void setMonitorCode(String monitorCode) + { + this.monitorCode = monitorCode; + } + + public String getMonitorCode() + { + return monitorCode; + } + public void setCollectTime(Date collectTime) + { + this.collectTime = collectTime; + } + + public Date getCollectTime() + { + return collectTime; + } + public void setFluxFlow(Long fluxFlow) + { + this.fluxFlow = fluxFlow; + } + + public Long getFluxFlow() + { + return fluxFlow; + } + public void setSteamFlow(Long steamFlow) + { + this.steamFlow = steamFlow; + } + + public Long getSteamFlow() + { + return steamFlow; + } + public void setTemperature(Long temperature) + { + this.temperature = temperature; + } + + public Long getTemperature() + { + return temperature; + } + public void setPress(Long press) + { + this.press = press; + } + + public Long getPress() + { + return press; + } + public void setPurity(Long purity) + { + this.purity = purity; + } + + public Long getPurity() + { + return purity; + } + public void setDifferencePress(Long differencePress) + { + this.differencePress = differencePress; + } + + public Long getDifferencePress() + { + return differencePress; + } + public void setRecordTime(Date recordTime) + { + this.recordTime = recordTime; + } + + public Date getRecordTime() + { + return recordTime; + } + + @Override + public String toString() { + return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) + .append("objId", getObjId()) + .append("monitorCode", getMonitorCode()) + .append("collectTime", getCollectTime()) + .append("fluxFlow", getFluxFlow()) + .append("steamFlow", getSteamFlow()) + .append("temperature", getTemperature()) + .append("press", getPress()) + .append("purity", getPurity()) + .append("differencePress", getDifferencePress()) + .append("recordTime", getRecordTime()) + .toString(); + } +} diff --git a/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordAirInstantMapper.java b/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordAirInstantMapper.java new file mode 100644 index 0000000..4656659 --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordAirInstantMapper.java @@ -0,0 +1,61 @@ +package com.os.ems.record.mapper; + +import java.util.List; +import com.os.ems.record.domain.EmsRecordAirInstant; + +/** + * 压缩空气实时数据Mapper接口 + * + * @author Yinq + * @date 2025-08-01 + */ +public interface EmsRecordAirInstantMapper +{ + /** + * 查询压缩空气实时数据 + * + * @param objId 压缩空气实时数据主键 + * @return 压缩空气实时数据 + */ + public EmsRecordAirInstant selectEmsRecordAirInstantByObjId(Long objId); + + /** + * 查询压缩空气实时数据列表 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 压缩空气实时数据集合 + */ + public List selectEmsRecordAirInstantList(EmsRecordAirInstant emsRecordAirInstant); + + /** + * 新增压缩空气实时数据 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 结果 + */ + public int insertEmsRecordAirInstant(EmsRecordAirInstant emsRecordAirInstant); + + /** + * 修改压缩空气实时数据 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 结果 + */ + public int updateEmsRecordAirInstant(EmsRecordAirInstant emsRecordAirInstant); + + /** + * 删除压缩空气实时数据 + * + * @param objId 压缩空气实时数据主键 + * @return 结果 + */ + public int deleteEmsRecordAirInstantByObjId(Long objId); + + /** + * 批量删除压缩空气实时数据 + * + * @param objIds 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteEmsRecordAirInstantByObjIds(Long[] objIds); +} diff --git a/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordNitrogenInstantMapper.java b/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordNitrogenInstantMapper.java new file mode 100644 index 0000000..5394629 --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/mapper/EmsRecordNitrogenInstantMapper.java @@ -0,0 +1,61 @@ +package com.os.ems.record.mapper; + +import java.util.List; +import com.os.ems.record.domain.EmsRecordNitrogenInstant; + +/** + * 氮气实时数据Mapper接口 + * + * @author Yinq + * @date 2025-08-01 + */ +public interface EmsRecordNitrogenInstantMapper +{ + /** + * 查询氮气实时数据 + * + * @param objId 氮气实时数据主键 + * @return 氮气实时数据 + */ + public EmsRecordNitrogenInstant selectEmsRecordNitrogenInstantByObjId(Long objId); + + /** + * 查询氮气实时数据列表 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 氮气实时数据集合 + */ + public List selectEmsRecordNitrogenInstantList(EmsRecordNitrogenInstant emsRecordNitrogenInstant); + + /** + * 新增氮气实时数据 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 结果 + */ + public int insertEmsRecordNitrogenInstant(EmsRecordNitrogenInstant emsRecordNitrogenInstant); + + /** + * 修改氮气实时数据 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 结果 + */ + public int updateEmsRecordNitrogenInstant(EmsRecordNitrogenInstant emsRecordNitrogenInstant); + + /** + * 删除氮气实时数据 + * + * @param objId 氮气实时数据主键 + * @return 结果 + */ + public int deleteEmsRecordNitrogenInstantByObjId(Long objId); + + /** + * 批量删除氮气实时数据 + * + * @param objIds 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteEmsRecordNitrogenInstantByObjIds(Long[] objIds); +} diff --git a/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordAirInstantService.java b/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordAirInstantService.java new file mode 100644 index 0000000..b106acc --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordAirInstantService.java @@ -0,0 +1,61 @@ +package com.os.ems.record.service; + +import java.util.List; +import com.os.ems.record.domain.EmsRecordAirInstant; + +/** + * 压缩空气实时数据Service接口 + * + * @author Yinq + * @date 2025-08-01 + */ +public interface IEmsRecordAirInstantService +{ + /** + * 查询压缩空气实时数据 + * + * @param objId 压缩空气实时数据主键 + * @return 压缩空气实时数据 + */ + public EmsRecordAirInstant selectEmsRecordAirInstantByObjId(Long objId); + + /** + * 查询压缩空气实时数据列表 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 压缩空气实时数据集合 + */ + public List selectEmsRecordAirInstantList(EmsRecordAirInstant emsRecordAirInstant); + + /** + * 新增压缩空气实时数据 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 结果 + */ + public int insertEmsRecordAirInstant(EmsRecordAirInstant emsRecordAirInstant); + + /** + * 修改压缩空气实时数据 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 结果 + */ + public int updateEmsRecordAirInstant(EmsRecordAirInstant emsRecordAirInstant); + + /** + * 批量删除压缩空气实时数据 + * + * @param objIds 需要删除的压缩空气实时数据主键集合 + * @return 结果 + */ + public int deleteEmsRecordAirInstantByObjIds(Long[] objIds); + + /** + * 删除压缩空气实时数据信息 + * + * @param objId 压缩空气实时数据主键 + * @return 结果 + */ + public int deleteEmsRecordAirInstantByObjId(Long objId); +} diff --git a/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordNitrogenInstantService.java b/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordNitrogenInstantService.java new file mode 100644 index 0000000..6dec7f4 --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/service/IEmsRecordNitrogenInstantService.java @@ -0,0 +1,61 @@ +package com.os.ems.record.service; + +import java.util.List; +import com.os.ems.record.domain.EmsRecordNitrogenInstant; + +/** + * 氮气实时数据Service接口 + * + * @author Yinq + * @date 2025-08-01 + */ +public interface IEmsRecordNitrogenInstantService +{ + /** + * 查询氮气实时数据 + * + * @param objId 氮气实时数据主键 + * @return 氮气实时数据 + */ + public EmsRecordNitrogenInstant selectEmsRecordNitrogenInstantByObjId(Long objId); + + /** + * 查询氮气实时数据列表 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 氮气实时数据集合 + */ + public List selectEmsRecordNitrogenInstantList(EmsRecordNitrogenInstant emsRecordNitrogenInstant); + + /** + * 新增氮气实时数据 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 结果 + */ + public int insertEmsRecordNitrogenInstant(EmsRecordNitrogenInstant emsRecordNitrogenInstant); + + /** + * 修改氮气实时数据 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 结果 + */ + public int updateEmsRecordNitrogenInstant(EmsRecordNitrogenInstant emsRecordNitrogenInstant); + + /** + * 批量删除氮气实时数据 + * + * @param objIds 需要删除的氮气实时数据主键集合 + * @return 结果 + */ + public int deleteEmsRecordNitrogenInstantByObjIds(Long[] objIds); + + /** + * 删除氮气实时数据信息 + * + * @param objId 氮气实时数据主键 + * @return 结果 + */ + public int deleteEmsRecordNitrogenInstantByObjId(Long objId); +} diff --git a/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAirInstantServiceImpl.java b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAirInstantServiceImpl.java new file mode 100644 index 0000000..478ac12 --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAirInstantServiceImpl.java @@ -0,0 +1,93 @@ +package com.os.ems.record.service.impl; + +import java.util.List; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import com.os.ems.record.mapper.EmsRecordAirInstantMapper; +import com.os.ems.record.domain.EmsRecordAirInstant; +import com.os.ems.record.service.IEmsRecordAirInstantService; + +/** + * 压缩空气实时数据Service业务层处理 + * + * @author Yinq + * @date 2025-08-01 + */ +@Service +public class EmsRecordAirInstantServiceImpl implements IEmsRecordAirInstantService +{ + @Autowired + private EmsRecordAirInstantMapper emsRecordAirInstantMapper; + + /** + * 查询压缩空气实时数据 + * + * @param objId 压缩空气实时数据主键 + * @return 压缩空气实时数据 + */ + @Override + public EmsRecordAirInstant selectEmsRecordAirInstantByObjId(Long objId) + { + return emsRecordAirInstantMapper.selectEmsRecordAirInstantByObjId(objId); + } + + /** + * 查询压缩空气实时数据列表 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 压缩空气实时数据 + */ + @Override + public List selectEmsRecordAirInstantList(EmsRecordAirInstant emsRecordAirInstant) + { + return emsRecordAirInstantMapper.selectEmsRecordAirInstantList(emsRecordAirInstant); + } + + /** + * 新增压缩空气实时数据 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 结果 + */ + @Override + public int insertEmsRecordAirInstant(EmsRecordAirInstant emsRecordAirInstant) + { + return emsRecordAirInstantMapper.insertEmsRecordAirInstant(emsRecordAirInstant); + } + + /** + * 修改压缩空气实时数据 + * + * @param emsRecordAirInstant 压缩空气实时数据 + * @return 结果 + */ + @Override + public int updateEmsRecordAirInstant(EmsRecordAirInstant emsRecordAirInstant) + { + return emsRecordAirInstantMapper.updateEmsRecordAirInstant(emsRecordAirInstant); + } + + /** + * 批量删除压缩空气实时数据 + * + * @param objIds 需要删除的压缩空气实时数据主键 + * @return 结果 + */ + @Override + public int deleteEmsRecordAirInstantByObjIds(Long[] objIds) + { + return emsRecordAirInstantMapper.deleteEmsRecordAirInstantByObjIds(objIds); + } + + /** + * 删除压缩空气实时数据信息 + * + * @param objId 压缩空气实时数据主键 + * @return 结果 + */ + @Override + public int deleteEmsRecordAirInstantByObjId(Long objId) + { + return emsRecordAirInstantMapper.deleteEmsRecordAirInstantByObjId(objId); + } +} diff --git a/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordNitrogenInstantServiceImpl.java b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordNitrogenInstantServiceImpl.java new file mode 100644 index 0000000..ead10d9 --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordNitrogenInstantServiceImpl.java @@ -0,0 +1,93 @@ +package com.os.ems.record.service.impl; + +import java.util.List; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import com.os.ems.record.mapper.EmsRecordNitrogenInstantMapper; +import com.os.ems.record.domain.EmsRecordNitrogenInstant; +import com.os.ems.record.service.IEmsRecordNitrogenInstantService; + +/** + * 氮气实时数据Service业务层处理 + * + * @author Yinq + * @date 2025-08-01 + */ +@Service +public class EmsRecordNitrogenInstantServiceImpl implements IEmsRecordNitrogenInstantService +{ + @Autowired + private EmsRecordNitrogenInstantMapper emsRecordNitrogenInstantMapper; + + /** + * 查询氮气实时数据 + * + * @param objId 氮气实时数据主键 + * @return 氮气实时数据 + */ + @Override + public EmsRecordNitrogenInstant selectEmsRecordNitrogenInstantByObjId(Long objId) + { + return emsRecordNitrogenInstantMapper.selectEmsRecordNitrogenInstantByObjId(objId); + } + + /** + * 查询氮气实时数据列表 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 氮气实时数据 + */ + @Override + public List selectEmsRecordNitrogenInstantList(EmsRecordNitrogenInstant emsRecordNitrogenInstant) + { + return emsRecordNitrogenInstantMapper.selectEmsRecordNitrogenInstantList(emsRecordNitrogenInstant); + } + + /** + * 新增氮气实时数据 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 结果 + */ + @Override + public int insertEmsRecordNitrogenInstant(EmsRecordNitrogenInstant emsRecordNitrogenInstant) + { + return emsRecordNitrogenInstantMapper.insertEmsRecordNitrogenInstant(emsRecordNitrogenInstant); + } + + /** + * 修改氮气实时数据 + * + * @param emsRecordNitrogenInstant 氮气实时数据 + * @return 结果 + */ + @Override + public int updateEmsRecordNitrogenInstant(EmsRecordNitrogenInstant emsRecordNitrogenInstant) + { + return emsRecordNitrogenInstantMapper.updateEmsRecordNitrogenInstant(emsRecordNitrogenInstant); + } + + /** + * 批量删除氮气实时数据 + * + * @param objIds 需要删除的氮气实时数据主键 + * @return 结果 + */ + @Override + public int deleteEmsRecordNitrogenInstantByObjIds(Long[] objIds) + { + return emsRecordNitrogenInstantMapper.deleteEmsRecordNitrogenInstantByObjIds(objIds); + } + + /** + * 删除氮气实时数据信息 + * + * @param objId 氮气实时数据主键 + * @return 结果 + */ + @Override + public int deleteEmsRecordNitrogenInstantByObjId(Long objId) + { + return emsRecordNitrogenInstantMapper.deleteEmsRecordNitrogenInstantByObjId(objId); + } +} diff --git a/os-ems/src/main/resources/mapper/ems/record/EmsRecordAirInstantMapper.xml b/os-ems/src/main/resources/mapper/ems/record/EmsRecordAirInstantMapper.xml new file mode 100644 index 0000000..49f8d93 --- /dev/null +++ b/os-ems/src/main/resources/mapper/ems/record/EmsRecordAirInstantMapper.xml @@ -0,0 +1,96 @@ + + + + + + + + + + + + + + + + + + + select obj_id, monitor_code, collect_time, flux_flow, steam_flow, temperature, press, density, difference_press, record_time from ems_record_air_instant + + + + + + + + insert into ems_record_air_instant + + monitor_code, + collect_time, + flux_flow, + steam_flow, + temperature, + press, + density, + difference_press, + record_time, + + + #{monitorCode}, + #{collectTime}, + #{fluxFlow}, + #{steamFlow}, + #{temperature}, + #{press}, + #{density}, + #{differencePress}, + #{recordTime}, + + + + + update ems_record_air_instant + + monitor_code = #{monitorCode}, + collect_time = #{collectTime}, + flux_flow = #{fluxFlow}, + steam_flow = #{steamFlow}, + temperature = #{temperature}, + press = #{press}, + density = #{density}, + difference_press = #{differencePress}, + record_time = #{recordTime}, + + where obj_id = #{objId} + + + + delete from ems_record_air_instant where obj_id = #{objId} + + + + delete from ems_record_air_instant where obj_id in + + #{objId} + + + \ No newline at end of file diff --git a/os-ems/src/main/resources/mapper/ems/record/EmsRecordNitrogenInstantMapper.xml b/os-ems/src/main/resources/mapper/ems/record/EmsRecordNitrogenInstantMapper.xml new file mode 100644 index 0000000..0ec477e --- /dev/null +++ b/os-ems/src/main/resources/mapper/ems/record/EmsRecordNitrogenInstantMapper.xml @@ -0,0 +1,96 @@ + + + + + + + + + + + + + + + + + + + select obj_id, monitor_code, collect_time, flux_flow, steam_flow, temperature, press, purity, difference_press, record_time from ems_record_nitrogen_instant + + + + + + + + insert into ems_record_nitrogen_instant + + monitor_code, + collect_time, + flux_flow, + steam_flow, + temperature, + press, + purity, + difference_press, + record_time, + + + #{monitorCode}, + #{collectTime}, + #{fluxFlow}, + #{steamFlow}, + #{temperature}, + #{press}, + #{purity}, + #{differencePress}, + #{recordTime}, + + + + + update ems_record_nitrogen_instant + + monitor_code = #{monitorCode}, + collect_time = #{collectTime}, + flux_flow = #{fluxFlow}, + steam_flow = #{steamFlow}, + temperature = #{temperature}, + press = #{press}, + purity = #{purity}, + difference_press = #{differencePress}, + record_time = #{recordTime}, + + where obj_id = #{objId} + + + + delete from ems_record_nitrogen_instant where obj_id = #{objId} + + + + delete from ems_record_nitrogen_instant where obj_id in + + #{objId} + + + \ No newline at end of file