diff --git a/ems-admin/src/main/java/com/xzzn/web/controller/ems/EmsSiteMonitorController.java b/ems-admin/src/main/java/com/xzzn/web/controller/ems/EmsSiteMonitorController.java index c5ae4d6..53543df 100644 --- a/ems-admin/src/main/java/com/xzzn/web/controller/ems/EmsSiteMonitorController.java +++ b/ems-admin/src/main/java/com/xzzn/web/controller/ems/EmsSiteMonitorController.java @@ -30,9 +30,18 @@ public class EmsSiteMonitorController extends BaseController{ /** * 单站监控-设备监控-实时运行头部数据 */ - @GetMapping("/runingHeadInfo") - public AjaxResult getRuningHeadInfo(@RequestParam Long siteId) + @GetMapping("/runningHeadInfo") + public AjaxResult getRunningHeadInfo(@RequestParam Long siteId) { - return success(iSingleSiteService.getSiteRuningHeadInfo(siteId)); + return success(iSingleSiteService.getSiteRunningHeadInfo(siteId)); + } + + /** + * 单站监控-设备监控-实时运行曲线图数据 + */ + @GetMapping("/runningGraph") + public AjaxResult getRunningGraph(@RequestParam Long siteId) + { + return success(iSingleSiteService.getRunningGraph(siteId)); } } diff --git a/ems-system/src/main/java/com/xzzn/ems/domain/EmsSite.java b/ems-system/src/main/java/com/xzzn/ems/domain/EmsSite.java deleted file mode 100644 index b789a2b..0000000 --- a/ems-system/src/main/java/com/xzzn/ems/domain/EmsSite.java +++ /dev/null @@ -1,57 +0,0 @@ -package com.xzzn.ems.domain; - -import com.xzzn.common.core.domain.BaseEntity; -import org.apache.commons.lang3.builder.ToStringBuilder; -import org.apache.commons.lang3.builder.ToStringStyle; -import com.xzzn.common.annotation.Excel; - -/** - * 站点对象 site - * - * @author xzzn - * @date 2025-06-16 - */ -public class EmsSite extends BaseEntity -{ - private static final long serialVersionUID = 1L; - - /** 自增主键 */ - private Long id; - - /** 站点名称 */ - @Excel(name = "站点名称") - private String siteName; - - public void setId(Long id) - { - this.id = id; - } - - public Long getId() - { - return id; - } - - public void setSiteName(String siteName) - { - this.siteName = siteName; - } - - public String getSiteName() - { - return siteName; - } - - @Override - public String toString() { - return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) - .append("id", getId()) - .append("siteName", getSiteName()) - .append("remark", getRemark()) - .append("createBy", getCreateBy()) - .append("updateBy", getUpdateBy()) - .append("createTime", getCreateTime()) - .append("updateTime", getUpdateTime()) - .toString(); - } -} diff --git a/ems-system/src/main/java/com/xzzn/ems/domain/EmsSiteSetting.java b/ems-system/src/main/java/com/xzzn/ems/domain/EmsSiteSetting.java new file mode 100644 index 0000000..a251214 --- /dev/null +++ b/ems-system/src/main/java/com/xzzn/ems/domain/EmsSiteSetting.java @@ -0,0 +1,121 @@ +package com.xzzn.ems.domain; + +import java.math.BigDecimal; +import java.util.Date; +import com.fasterxml.jackson.annotation.JsonFormat; +import com.xzzn.common.core.domain.BaseEntity; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.xzzn.common.annotation.Excel; + +/** + * 站点对象 ems_site_setting + * + * @author xzzn + * @date 2025-06-20 + */ +public class EmsSiteSetting extends BaseEntity +{ + private static final long serialVersionUID = 1L; + + /** 自增主键 */ + private Long id; + + /** 站点名称 */ + @Excel(name = "站点名称") + private String siteName; + + /** 站点地址 */ + @Excel(name = "站点地址") + private String siteAddress; + + /** 运营时间 */ + @JsonFormat(pattern = "yyyy-MM-dd") + @Excel(name = "运营时间", width = 30, dateFormat = "yyyy-MM-dd") + private Date runningTime; + + /** 纬度 */ + @Excel(name = "纬度") + private BigDecimal latitude; + + /** 经度 */ + @Excel(name = "经度") + private BigDecimal longitude; + + public void setId(Long id) + { + this.id = id; + } + + public Long getId() + { + return id; + } + + public void setSiteName(String siteName) + { + this.siteName = siteName; + } + + public String getSiteName() + { + return siteName; + } + + public void setSiteAddress(String siteAddress) + { + this.siteAddress = siteAddress; + } + + public String getSiteAddress() + { + return siteAddress; + } + + public void setRunningTime(Date runningTime) + { + this.runningTime = runningTime; + } + + public Date getRunningTime() + { + return runningTime; + } + + public void setLatitude(BigDecimal latitude) + { + this.latitude = latitude; + } + + public BigDecimal getLatitude() + { + return latitude; + } + + public void setLongitude(BigDecimal longitude) + { + this.longitude = longitude; + } + + public BigDecimal getLongitude() + { + return longitude; + } + + @Override + public String toString() { + return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) + .append("id", getId()) + .append("siteName", getSiteName()) + .append("siteAddress", getSiteAddress()) + .append("runningTime", getRunningTime()) + .append("latitude", getLatitude()) + .append("longitude", getLongitude()) + .append("remark", getRemark()) + .append("createBy", getCreateBy()) + .append("updateBy", getUpdateBy()) + .append("createTime", getCreateTime()) + .append("updateTime", getUpdateTime()) + .toString(); + } +} diff --git a/ems-system/src/main/java/com/xzzn/ems/domain/vo/SingleSiteBaseInfo.java b/ems-system/src/main/java/com/xzzn/ems/domain/vo/SingleSiteBaseInfo.java index 3f095d8..2ed5d77 100644 --- a/ems-system/src/main/java/com/xzzn/ems/domain/vo/SingleSiteBaseInfo.java +++ b/ems-system/src/main/java/com/xzzn/ems/domain/vo/SingleSiteBaseInfo.java @@ -1,7 +1,6 @@ package com.xzzn.ems.domain.vo; import java.math.BigDecimal; -import java.util.Date; import java.util.List; /** @@ -9,6 +8,11 @@ import java.util.List; * */ public class SingleSiteBaseInfo { + /** + * 站点名称 + */ + private String siteName; + /** * 今日充电量 */ @@ -27,12 +31,17 @@ public class SingleSiteBaseInfo { /** * 总放电量 */ - private BigDecimal totalDischargedCap; + private BigDecimal totalDisChargedCap; + + /** + * 站点坐标 + */ + private String[] siteLocation; /** * 站点位置 */ - private String siteLocation; + private String siteAddress; /** * 投运时间 @@ -52,7 +61,15 @@ public class SingleSiteBaseInfo { /** * 七天放电统计 */ - private List SevenDayDischargeStats; + private List sevenDayDisChargeStats; + + public String getSiteName() { + return siteName; + } + + public void setSiteName(String siteName) { + this.siteName = siteName; + } public BigDecimal getDayChargedCap() { return dayChargedCap; @@ -62,14 +79,6 @@ public class SingleSiteBaseInfo { this.dayChargedCap = dayChargedCap; } - public List getSevenDayDischargeStats() { - return SevenDayDischargeStats; - } - - public void setSevenDayDischargeStats(List sevenDayDischargeStats) { - SevenDayDischargeStats = sevenDayDischargeStats; - } - public BigDecimal getInstalledCap() { return installedCap; } @@ -94,20 +103,28 @@ public class SingleSiteBaseInfo { this.runningTime = runningTime; } - public String getSiteLocation() { + public String[] getSiteLocation() { return siteLocation; } - public void setSiteLocation(String siteLocation) { + public void setSiteLocation(String[] siteLocation) { this.siteLocation = siteLocation; } - public BigDecimal getTotalDischargedCap() { - return totalDischargedCap; + public String getSiteAddress() { + return siteAddress; } - public void setTotalDischargedCap(BigDecimal totalDischargedCap) { - this.totalDischargedCap = totalDischargedCap; + public void setSiteAddress(String siteAddress) { + this.siteAddress = siteAddress; + } + + public BigDecimal getTotalDisChargedCap() { + return totalDisChargedCap; + } + + public void setTotalDisChargedCap(BigDecimal totalDisChargedCap) { + this.totalDisChargedCap = totalDisChargedCap; } public BigDecimal getTotalChargedCap() { @@ -125,4 +142,12 @@ public class SingleSiteBaseInfo { public void setDayDisChargedCap(BigDecimal dayDisChargedCap) { this.dayDisChargedCap = dayDisChargedCap; } + + public List getSevenDayDisChargeStats() { + return sevenDayDisChargeStats; + } + + public void setSevenDayDisChargeStats(List sevenDayDisChargeStats) { + this.sevenDayDisChargeStats = sevenDayDisChargeStats; + } } diff --git a/ems-system/src/main/java/com/xzzn/ems/domain/vo/SiteMonitorRuningInfoVo.java b/ems-system/src/main/java/com/xzzn/ems/domain/vo/SiteMonitorRuningInfoVo.java index 6a3928e..8b52473 100644 --- a/ems-system/src/main/java/com/xzzn/ems/domain/vo/SiteMonitorRuningInfoVo.java +++ b/ems-system/src/main/java/com/xzzn/ems/domain/vo/SiteMonitorRuningInfoVo.java @@ -1,6 +1,5 @@ package com.xzzn.ems.domain.vo; -import java.math.BigDecimal; import java.util.List; /** diff --git a/ems-system/src/main/java/com/xzzn/ems/mapper/EmsSiteMapper.java b/ems-system/src/main/java/com/xzzn/ems/mapper/EmsSiteSettingMapper.java similarity index 56% rename from ems-system/src/main/java/com/xzzn/ems/mapper/EmsSiteMapper.java rename to ems-system/src/main/java/com/xzzn/ems/mapper/EmsSiteSettingMapper.java index c9b96d9..807a767 100644 --- a/ems-system/src/main/java/com/xzzn/ems/mapper/EmsSiteMapper.java +++ b/ems-system/src/main/java/com/xzzn/ems/mapper/EmsSiteSettingMapper.java @@ -1,16 +1,16 @@ package com.xzzn.ems.mapper; import java.util.List; -import com.xzzn.ems.domain.EmsSite; +import com.xzzn.ems.domain.EmsSiteSetting; import com.xzzn.ems.domain.vo.SiteTotalInfoVo; /** * 站点Mapper接口 * * @author xzzn - * @date 2025-06-16 + * @date 2025-06-20 */ -public interface EmsSiteMapper +public interface EmsSiteSettingMapper { /** * 查询站点 @@ -18,30 +18,31 @@ public interface EmsSiteMapper * @param id 站点主键 * @return 站点 */ - public EmsSite selectSiteById(Long id); + public EmsSiteSetting selectEmsSiteSettingById(Long id); /** * 查询站点列表 * + * @param emsSiteSetting 站点 * @return 站点集合 */ - public List selectSiteList(); + public List selectEmsSiteSettingList(EmsSiteSetting emsSiteSetting); /** * 新增站点 * - * @param site 站点 + * @param emsSiteSetting 站点 * @return 结果 */ - public int insertSite(EmsSite site); + public int insertEmsSiteSetting(EmsSiteSetting emsSiteSetting); /** * 修改站点 * - * @param site 站点 + * @param emsSiteSetting 站点 * @return 结果 */ - public int updateSite(EmsSite site); + public int updateEmsSiteSetting(EmsSiteSetting emsSiteSetting); /** * 删除站点 @@ -49,7 +50,7 @@ public interface EmsSiteMapper * @param id 站点主键 * @return 结果 */ - public int deleteSiteById(Long id); + public int deleteEmsSiteSettingById(Long id); /** * 批量删除站点 @@ -57,7 +58,7 @@ public interface EmsSiteMapper * @param ids 需要删除的数据主键集合 * @return 结果 */ - public int deleteSiteByIds(Long[] ids); + public int deleteEmsSiteSettingByIds(Long[] ids); /** * 获取站点总信息 diff --git a/ems-system/src/main/java/com/xzzn/ems/service/IEmsSiteService.java b/ems-system/src/main/java/com/xzzn/ems/service/IEmsSiteService.java index c657629..4ac665c 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/IEmsSiteService.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/IEmsSiteService.java @@ -1,7 +1,6 @@ package com.xzzn.ems.service; - -import com.xzzn.ems.domain.EmsSite; +import com.xzzn.ems.domain.EmsSiteSetting; import com.xzzn.ems.domain.vo.SiteTotalInfoVo; import java.util.List; @@ -13,7 +12,7 @@ import java.util.List; public interface IEmsSiteService { - public List getAllSites(); + public List getAllSites(); public SiteTotalInfoVo getSiteTotalInfo(); diff --git a/ems-system/src/main/java/com/xzzn/ems/service/ISingleSiteService.java b/ems-system/src/main/java/com/xzzn/ems/service/ISingleSiteService.java index c857eb7..9516395 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/ISingleSiteService.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/ISingleSiteService.java @@ -2,6 +2,7 @@ package com.xzzn.ems.service; import com.xzzn.ems.domain.vo.SiteMonitorHomeVo; import com.xzzn.ems.domain.vo.SiteMonitorRuningHeadInfoVo; +import com.xzzn.ems.domain.vo.SiteMonitorRuningInfoVo; /** * 单点监控 服务层 @@ -13,5 +14,7 @@ public interface ISingleSiteService public SiteMonitorHomeVo getSiteMonitorDataVo(Long siteId); - public SiteMonitorRuningHeadInfoVo getSiteRuningHeadInfo(Long siteId); + public SiteMonitorRuningHeadInfoVo getSiteRunningHeadInfo(Long siteId); + + public SiteMonitorRuningInfoVo getRunningGraph(Long siteId); } diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsSiteServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsSiteServiceImpl.java index 358f919..4a9e166 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsSiteServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsSiteServiceImpl.java @@ -1,8 +1,8 @@ package com.xzzn.ems.service.impl; -import com.xzzn.ems.domain.EmsSite; +import com.xzzn.ems.domain.EmsSiteSetting; import com.xzzn.ems.domain.vo.SiteTotalInfoVo; -import com.xzzn.ems.mapper.EmsSiteMapper; +import com.xzzn.ems.mapper.EmsSiteSettingMapper; import com.xzzn.ems.service.IEmsSiteService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -18,11 +18,11 @@ public class EmsSiteServiceImpl implements IEmsSiteService { @Autowired - private EmsSiteMapper emsSiteMapper; + private EmsSiteSettingMapper emsSiteMapper; @Override - public List getAllSites() { - return emsSiteMapper.selectSiteList(); + public List getAllSites() { + return emsSiteMapper.selectEmsSiteSettingList(null); } @Override diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/HomePageServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/HomePageServiceImpl.java index 0955bf3..c6916b2 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/HomePageServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/HomePageServiceImpl.java @@ -2,12 +2,12 @@ package com.xzzn.ems.service.impl; import com.xzzn.common.utils.DateUtils; import com.xzzn.common.utils.StringUtils; -import com.xzzn.ems.domain.EmsSite; +import com.xzzn.ems.domain.EmsSiteSetting; import com.xzzn.ems.domain.vo.SingleSiteBaseInfo; import com.xzzn.ems.domain.vo.SiteMonitorDataVo; import com.xzzn.ems.domain.vo.SiteTotalInfoVo; import com.xzzn.ems.mapper.EmsPcsDataMapper; -import com.xzzn.ems.mapper.EmsSiteMapper; +import com.xzzn.ems.mapper.EmsSiteSettingMapper; import com.xzzn.ems.service.IEmsSiteService; import com.xzzn.ems.service.IHomePageService; import org.springframework.beans.factory.annotation.Autowired; @@ -15,7 +15,6 @@ import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.util.Calendar; -import java.util.Date; import java.util.List; /** @@ -31,7 +30,7 @@ public class HomePageServiceImpl implements IHomePageService @Autowired private EmsPcsDataMapper emsPcsDataMapper; @Autowired - private EmsSiteMapper emsSiteMapper; + private EmsSiteSettingMapper emsSiteMapper; @Override public SiteTotalInfoVo getSiteTotalInfo() { @@ -44,14 +43,19 @@ public class HomePageServiceImpl implements IHomePageService if (siteId != null) { // 站点基本信息 - EmsSite emsSite = emsSiteMapper.selectSiteById(siteId); + EmsSiteSetting emsSite = emsSiteMapper.selectEmsSiteSettingById(siteId); if (emsSite != null) { - singleSiteBaseInfo.setSiteLocation(emsSite.getRemark());//站点位置 - singleSiteBaseInfo.setRunningTime(DateUtils.parseDateToStr("yyyy-MM-dd",emsSite.getCreateTime()));//投运时间 + singleSiteBaseInfo.setSiteName(emsSite.getSiteName()); + String[] siteLocation = new String[2]; + siteLocation[0] = emsSite.getLongitude() == null ? "" : emsSite.getLongitude().toString(); + siteLocation[1] = emsSite.getLatitude() == null ? "" : emsSite.getLatitude().toString(); + singleSiteBaseInfo.setSiteLocation(siteLocation);//站点位置 + singleSiteBaseInfo.setSiteAddress(emsSite.getSiteAddress()); + singleSiteBaseInfo.setRunningTime(DateUtils.parseDateToStr("yyyy-MM-dd",emsSite.getRunningTime()));//投运时间 // 装机功率+装机容量 待定 // 七天放电数据统计 List siteMonitorDataVoList = emsPcsDataMapper.getPcsDataBySiteId(siteId); - singleSiteBaseInfo.setSevenDayDischargeStats(siteMonitorDataVoList); + singleSiteBaseInfo.setSevenDayDisChargeStats(siteMonitorDataVoList); // 充放电基本数据处理 dealSitePCSDate(singleSiteBaseInfo,siteMonitorDataVoList); } @@ -82,7 +86,7 @@ public class HomePageServiceImpl implements IHomePageService singleSiteBaseInfo.setDayChargedCap(dayChargeCap); singleSiteBaseInfo.setDayDisChargedCap(dayDisChargeCap); singleSiteBaseInfo.setTotalChargedCap(totalChargeCap); - singleSiteBaseInfo.setTotalDischargedCap(totalDisChargeCap); + singleSiteBaseInfo.setTotalDisChargedCap(totalDisChargeCap); } } diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/SingleSiteServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/SingleSiteServiceImpl.java index 301778a..a1cfb4b 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/SingleSiteServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/SingleSiteServiceImpl.java @@ -86,23 +86,38 @@ public class SingleSiteServiceImpl implements ISingleSiteService { return flag; } + // 获取单站监控实时运行头部数据 @Override - public SiteMonitorRuningHeadInfoVo getSiteRuningHeadInfo(Long siteId) { - SiteMonitorRuningHeadInfoVo siteMonitorRuningHeadInfoVo = new SiteMonitorRuningHeadInfoVo(); + public SiteMonitorRuningHeadInfoVo getSiteRunningHeadInfo(Long siteId) { + SiteMonitorRuningHeadInfoVo siteMonitorRunningHeadInfoVo = new SiteMonitorRuningHeadInfoVo(); if (siteId != null) { // 实时有功功率/实时无功功率/今日充电量/今日放电量 - siteMonitorRuningHeadInfoVo = emsPcsDataMapper.getSiteRunningHeadInfo(siteId); + siteMonitorRunningHeadInfoVo = emsPcsDataMapper.getSiteRunningHeadInfo(siteId); // 电池簇SOC // 电池堆SOH EmsBatteryData emsBatteryData = emsBatteryDataMapper.getBatteryDataBySiteId(siteId); if (emsBatteryData != null) { - siteMonitorRuningHeadInfoVo.setSoc(emsBatteryData.getSoc()); - siteMonitorRuningHeadInfoVo.setSoh(emsBatteryData.getSoh()); + siteMonitorRunningHeadInfoVo.setSoc(emsBatteryData.getSoc()); + siteMonitorRunningHeadInfoVo.setSoh(emsBatteryData.getSoh()); } } - return siteMonitorRuningHeadInfoVo; + return siteMonitorRunningHeadInfoVo; + } + + // 获取单站监控实时运行曲线图数据 + @Override + public SiteMonitorRuningInfoVo getRunningGraph(Long siteId) { + SiteMonitorRuningInfoVo siteMonitorRuningInfoVo = new SiteMonitorRuningInfoVo(); + if (siteId != null) { + //储能功率list + //pcs平均温度list + //电池平均soclist + //电池平均温度list + + } + return siteMonitorRuningInfoVo; } } diff --git a/ems-system/src/main/resources/mapper/ems/EmsSiteMapper.xml b/ems-system/src/main/resources/mapper/ems/EmsSiteSettingMapper.xml similarity index 56% rename from ems-system/src/main/resources/mapper/ems/EmsSiteMapper.xml rename to ems-system/src/main/resources/mapper/ems/EmsSiteSettingMapper.xml index 2127add..1dc780c 100644 --- a/ems-system/src/main/resources/mapper/ems/EmsSiteMapper.xml +++ b/ems-system/src/main/resources/mapper/ems/EmsSiteSettingMapper.xml @@ -2,11 +2,15 @@ - + - + + + + + @@ -14,26 +18,34 @@ - - select id, site_name, remark, create_by, update_by, create_time, update_time from ems_site_setting + + select id, site_name, site_address, running_time, latitude, longitude, remark, create_by, update_by, create_time, update_time from ems_site_setting - + and site_name like concat('%', #{siteName}, '%') + and site_address = #{siteAddress} + and running_time = #{runningTime} + and latitude = #{latitude} + and longitude = #{longitude} - + where id = #{id} - + insert into ems_site_setting site_name, + site_address, + running_time, + latitude, + longitude, remark, create_by, update_by, @@ -42,6 +54,10 @@ #{siteName}, + #{siteAddress}, + #{runningTime}, + #{latitude}, + #{longitude}, #{remark}, #{createBy}, #{updateBy}, @@ -50,10 +66,14 @@ - + update ems_site_setting site_name = #{siteName}, + site_address = #{siteAddress}, + running_time = #{runningTime}, + latitude = #{latitude}, + longitude = #{longitude}, remark = #{remark}, create_by = #{createBy}, update_by = #{updateBy}, @@ -63,11 +83,11 @@ where id = #{id} - + delete from ems_site_setting where id = #{id} - + delete from ems_site_setting where id in #{id}