From c0a8b48bc4dc828c2599daa2252130e74c5fd5a4 Mon Sep 17 00:00:00 2001
From: lxw <810412026@qq.com>
Date: 星期二, 13 九月 2022 12:13:29 +0800
Subject: [PATCH] 台站下添加文件将文件存入数据库
---
src/main/java/com/whyc/service/StationInfoService.java | 46 ++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 42 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/whyc/service/StationInfoService.java b/src/main/java/com/whyc/service/StationInfoService.java
index 98b9f38..ba9e8c2 100644
--- a/src/main/java/com/whyc/service/StationInfoService.java
+++ b/src/main/java/com/whyc/service/StationInfoService.java
@@ -5,10 +5,8 @@
import com.whyc.dto.FileOpreate;
import com.whyc.dto.Response;
import com.whyc.dto.XmlFileOpreate;
-import com.whyc.mapper.FileInfoMapper;
-import com.whyc.mapper.StationInfoMapper;
-import com.whyc.pojo.FileInfo;
-import com.whyc.pojo.StationInfo;
+import com.whyc.mapper.*;
+import com.whyc.pojo.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -23,6 +21,15 @@
@Autowired(required = false)
private FileInfoMapper infoMapper;
+
+ @Autowired(required = false)
+ private BattgroupInfoMapper groupInfoMapper;
+
+ @Autowired(required = false)
+ private BattgroupDataMapper dataMapper;
+
+ @Autowired(required = false)
+ private FileParamMapper paramMapper;
//娣诲姞鍙扮珯
public Response addStation(String stationName1, String stationName2, String stationName3) {
String stationName="";
@@ -106,6 +113,8 @@
private void insertFileInDataBase(String stationName,int stationIdMax,int fileIdMax, FileInfo fileInfo) {
int count=0;
int stationId=0;
+ //鏌ヨ鏈�澶х殑鐢垫睜缁勫彿
+ int battGroupId=groupInfoMapper.selectMaxId();
if(fileInfo!=null){
//鏌ヨ绔欑偣鐨勬満鎴挎槸鍚﹀瓨鍦╯tationId
QueryWrapper wrapper=new QueryWrapper();
@@ -117,6 +126,35 @@
}
fileInfo.setFileId(String.valueOf(fileIdMax+1));
count=infoMapper.insert(fileInfo);
+ //灏嗚В鏋愬嚭鏉ョ殑鏂囦欢淇℃伅鎻掑叆鏁版嵁搴�
+ FileParam fparam=fileInfo.getFileParam();
+ //鍘婚櫎groupinfo
+ List<BattgroupInfo> battgroupInfoList=fileInfo.getBattInfoList();
+ if(count>0&&fparam!=null){
+ fparam.setFileId(String.valueOf(fileIdMax+1));
+ paramMapper.insert(fparam);
+ //灏嗙數姹犵粍淇℃伅鎻掑叆鏁版嵁搴�
+ if(battgroupInfoList.size()>0){
+ for(int i=0;i<battgroupInfoList.size();i++){
+ BattgroupInfo battgroupInfo=battgroupInfoList.get(i);
+ battgroupInfo.setBattgroupId(String.valueOf(battGroupId+1+i));
+ battgroupInfo.setStationId(String.valueOf(stationIdMax+1));
+ battgroupInfo.setFileId(String.valueOf(fileIdMax+1));
+ battgroupInfo.setBattgroupNum(fparam.getGroupNum());
+ int groupCount=groupInfoMapper.insert(battgroupInfo);
+
+ List<BattgroupData> battgroupDataList=battgroupInfo.getBattDataList();
+ //鎻掑叆鏀剧數鏁版嵁
+ if(groupCount>0&&battgroupDataList.size()>0){
+ for (int j=0;j<battgroupDataList.size();j++){
+ BattgroupData battgroupData=battgroupDataList.get(j);
+ battgroupData.setBattgroupId(String.valueOf(battGroupId+1+i));
+ }
+ }
+ dataMapper.insertBatchSomeColumn(battgroupDataList);
+ }
+ }
+ }
}
if(count>0){
if(stationId==0){
--
Gitblit v1.9.1