From 441f4fd8652a5d51c386d19eb27a7dbb2140b10b Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期六, 17 五月 2025 14:03:17 +0800
Subject: [PATCH] 查询机房，电源，电池组信息
---
src/main/java/com/whyc/service/BattInfService.java | 97 ++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 84 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/whyc/service/BattInfService.java b/src/main/java/com/whyc/service/BattInfService.java
index da95a13..a4c0bd1 100644
--- a/src/main/java/com/whyc/service/BattInfService.java
+++ b/src/main/java/com/whyc/service/BattInfService.java
@@ -5,9 +5,12 @@
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.BattDto;
+import com.whyc.dto.InfoDto;
import com.whyc.dto.PowerDto;
import com.whyc.dto.Response;
import com.whyc.mapper.BattInfMapper;
+import com.whyc.mapper.PowerInfMapper;
+import com.whyc.mapper.StationInfMapper;
import com.whyc.pojo.db_station.BattInf;
import com.whyc.pojo.db_station.PowerInf;
import com.whyc.pojo.db_station.StationInf;
@@ -25,12 +28,18 @@
@Autowired(required = false)
private BattInfMapper mapper;
+ @Autowired(required = false)
+ private PowerInfMapper pinfMapper;
+
+ @Autowired(required = false)
+ private StationInfMapper sinfMapper;
+
/*鏂板缓鐢垫睜缁勶紙鏂扮殑璁惧鏂扮殑鐢垫睜缁勶級
* @param binf
* 1.鍦ㄧ數婧愪笅鏂板缓璁惧锛岃褰曡澶囩紪鍙凤紝devNum,璁惧鍚嶇О涓鸿澶囩被鍨�+devNum
*/
@Transactional
- public Response addDev(BattInf adddinf) {
+ public void addDev(BattInf adddinf) {
//妫�娴嬬數婧愪笅鏄惁瀛樺湪璁惧
int devNum=mapper.getMaxDevNum(adddinf.getPowerId());
if(devNum==0){
@@ -59,11 +68,10 @@
adddinf.setBattgroupNum(1);
adddinf.setCreateTime(new Date());
mapper.insert(adddinf);
- return new Response().set(1, true, "鏂板缓鐢垫睜缁勶紙鏂扮殑璁惧鏂扮殑鐢垫睜缁勶級");
}
//璁惧涓嬫坊鍔犵數姹犵粍
@Transactional
- public Response addBatt(BattInf addbinf) {
+ public void addBatt(BattInf addbinf) {
//鑾峰彇璁惧鐨勯�氱敤淇℃伅
QueryWrapper wrapper=new QueryWrapper();
wrapper.eq("dev_id",addbinf.getDevId());
@@ -95,20 +103,55 @@
addbinf.setBattgroupNum(battgroupNum);
addbinf.setCreateTime(new Date());
mapper.insert(addbinf);
- return new Response().set(1, true, "璁惧涓嬫坊鍔犵數姹犵粍");
}
- //鍒犻櫎鐢垫簮
- public Response delBatt(Integer bid) {
+ //鍒犻櫎鐢垫睜缁�
+ @Transactional
+ public Response delBatt(Integer stationId, Integer powerId,Integer battgroupId) {
UpdateWrapper wrapper=new UpdateWrapper();
- wrapper.eq("battgroup_id",bid);
+ wrapper.eq("battgroup_id",battgroupId);
mapper.delete(wrapper);
+ //妫�娴嬪鏋減owerId涓嬬數姹犵粍鍒犻櫎瀹屼簡,瑕佸皢鐢垫簮涔熷垹闄ゆ帀
+ QueryWrapper wrapper1=new QueryWrapper();
+ wrapper1.eq("power_id",powerId);
+ List<BattInf> binfList=mapper.selectList(wrapper1);
+ if(binfList==null){
+ UpdateWrapper wrapper2=new UpdateWrapper();
+ wrapper2.eq("power_id",powerId);
+ pinfMapper.delete(wrapper);
+ //鍐嶆娴嬪鏋滄満鎴夸笅鐢垫簮涔熷叏鍒犻櫎浜嗭紝瑕佸皢鏈烘埧涔熷垹闄�
+ QueryWrapper wrapper3=new QueryWrapper();
+ wrapper3.eq("station_id",stationId);
+ List<PowerInf> pinfList=pinfMapper.selectList(wrapper3);
+ if(pinfList==null){
+ UpdateWrapper wrapper4=new UpdateWrapper();
+ wrapper4.eq("station_id",stationId);
+ sinfMapper.delete(wrapper4);
+ }
+ }
return new Response().set(1,true);
}
- //淇敼鐢垫簮
+ //淇敼鐢垫睜缁�
public Response updateBatt(BattInf binf) {
+ UpdateWrapper wrapper1=new UpdateWrapper();
+ wrapper1.eq("dev_id",binf.getDevId());
+ if(binf.getDevIp()!=null){
+ wrapper1.set("dev_ip",binf.getDevIp());
+ }
+ if(binf.getDevName()!=null){
+ wrapper1.set("dev_name",binf.getDevName());
+ }
UpdateWrapper wrapper=new UpdateWrapper();
wrapper.eq("battgroup_id",binf.getBattgroupId());
if(binf.getBattgroupName()!=null){
+ //妫�娴嬭鏈烘埧涓嬭淇敼鐨勭數婧愬悕鏄惁绮楀湪
+ QueryWrapper queryWrapper=new QueryWrapper();
+ queryWrapper.eq("battgroup_name",binf.getBattgroupName());
+ queryWrapper.eq("dev_id",binf.getDevId());
+ queryWrapper.last("limit 1");
+ BattInf juegeb=mapper.selectOne(queryWrapper);
+ if(juegeb!=null){
+ return new Response().set(1,false,"璇ヨ澶囦笅宸插瓨鍦�"+binf.getBattgroupName()+"鐨勭數姹犵粍");
+ }
wrapper.set("battgroup_name",binf.getBattgroupName());
}
if(binf.getMonvolstd()!=null){
@@ -126,18 +169,18 @@
if(binf.getMoncount()!=null){
wrapper.set("moncount",binf.getMoncount());
}
- if(binf.getModel()!=null){
- wrapper.set("model",binf.getModel());
+ if(binf.getBattModel()!=null){
+ wrapper.set("batt_model",binf.getBattModel());
}
mapper.update((BattInf) ActionUtil.objeNull,wrapper);
return new Response().set(1,true);
}
- //鏌ヨ鐢垫睜
- public Response getBatt(BattDto dto) {
+ //鏌ヨ鏈烘埧锛岀數婧愶紝鐢垫睜缁勪俊鎭�
+ public Response getInfo(BattDto dto) {
User user= ActionUtil.getUser();
dto.setUid(user.getId());
PageHelper.startPage(dto.getPageNum(),dto.getPageSize());
- List<BattInf> list=mapper.getBatt(dto);
+ List<InfoDto> list=mapper.getInfo(dto);
PageInfo pageInfo=new PageInfo(list);
return new Response().setII(1,list!=null,pageInfo,"鏌ヨ鐢垫睜");
}
@@ -147,4 +190,32 @@
wrapper.eq("power_id",pid);
mapper.delete(wrapper);
}
+
+ //鑾峰彇鐢垫睜鍝佺墝(涓嬫媺)
+ public Response getProductByUid(Integer uid) {
+ List<String> list=mapper.getProductByUid(uid);
+ return new Response().setII(1,list.size()>0,list,"鑾峰彇鐢垫睜鍝佺墝(涓嬫媺)");
+ }
+ //鑾峰彇鏍囩О鍗曚綋鐢靛帇(涓嬫媺)
+ public Response getMonVolByUid(Integer uid) {
+ List<String> list=mapper.getMonVolByUid(uid);
+ return new Response().setII(1,list.size()>0,list,"鑾峰彇鏍囩О鍗曚綋鐢靛帇(涓嬫媺)");
+ }
+
+ //鑾峰彇鏍囩О瀹归噺(涓嬫媺)
+ public Response getMonCapByUid(Integer uid) {
+ List<String> list=mapper.getMonCapByUid(uid);
+ return new Response().setII(1,list.size()>0,list,"鑾峰彇鏍囩О瀹归噺(涓嬫媺)");
+ }
+
+ //鑾峰彇鏍囩О鍐呴樆(涓嬫媺)
+ public Response getMonResByUid(Integer uid) {
+ List<String> list=mapper.getMonResByUid(uid);
+ return new Response().setII(1,list.size()>0,list,"鑾峰彇鏍囩О鍐呴樆(涓嬫媺)");
+ }
+ //鑾峰彇璁惧鍨嬪彿(涓嬫媺)
+ public Response getDevTypeByUid(Integer uid) {
+ List<String> list=mapper.getDevTypeByUid(uid);
+ return new Response().setII(1,list.size()>0,list,"鑾峰彇璁惧鍨嬪彿(涓嬫媺)");
+ }
}
\ No newline at end of file
--
Gitblit v1.9.1