From bf60848c0d97d3f440eee20719010e49bc2aae2d Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期二, 25 三月 2025 11:44:03 +0800
Subject: [PATCH] 站点关联
---
src/main/java/com/whyc/service/PowerInfService.java | 25 +++++++++++++++++++++++++
1 files changed, 25 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/whyc/service/PowerInfService.java b/src/main/java/com/whyc/service/PowerInfService.java
index 4ea3cf6..869dde9 100644
--- a/src/main/java/com/whyc/service/PowerInfService.java
+++ b/src/main/java/com/whyc/service/PowerInfService.java
@@ -7,10 +7,13 @@
import com.whyc.dto.Response;
import com.whyc.mapper.*;
import com.whyc.pojo.db_batt.PowerInf;
+import com.whyc.pojo.db_batt.StationInf;
+import com.whyc.pojo.db_batt.StationPowerRelation;
import com.whyc.pojo.db_power_alarm.PowerAlarm;
import com.whyc.pojo.db_real_batt.RtData;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import java.util.Date;
import java.util.HashMap;
@@ -36,6 +39,12 @@
@Autowired(required = false)
private PowerAlarmMapper pAlarmMapper;
+
+ @Autowired
+ private StationPowerRelationService stationPowerRelationService;
+
+ @Autowired
+ private StationInfService stationInfService;
//鏍规嵁id鑾峰彇鐢垫簮淇℃伅
public Map<String,Object> getInfById(int powerId) {
@@ -83,6 +92,7 @@
return list;
}
+ @Transactional
public Response add(PowerInf powerInf) {
powerInf.setCreateTime(new Date());
//瀵筽owerInf鐨� devType杩涜鍒ゆ柇
@@ -98,6 +108,21 @@
if(powerInf.getChannelCount() == null){
powerInf.setChannelCount(1);
}
+ //鐢垫簮id鏌ヨ鏈�澶у��
+ int powerId = mapper.getMaxPowerId();
+ powerInf.setPowerId(powerId);
+ //瀵圭珯鐐瑰悕绉拌繘琛屾煡璇�,濡傛灉瀛樺湪鍒欑洿鎺ョ粦瀹氬叧绯�
+ //濡傛灉涓嶅瓨鍦�,鍒欐柊澧炲悗,鍐嶇粦瀹氬叧绯�
+ StationInf stationInf = stationInfService.getByStationName(powerInf.getStationName());
+ if(stationInf == null){
+ StationInf stationNew = new StationInf();
+ stationNew.setSinfName(powerInf.getStationName());
+ int stationId = stationInfService.getMaxStationId();
+ stationNew.setSinfId(stationId+1);
+ stationInfService.add(stationNew);
+ //绔欑偣鍜岀數婧恑d鍏宠仈
+ stationPowerRelationService.add(stationId,powerId);
+ }
mapper.insert(powerInf);
return new Response().setII(1,"鏂板瀹屾垚");
}
--
Gitblit v1.9.1