台站下添加文件将文件存入数据库

lxw

2022-09-13 c0a8b48bc4dc828c2599daa2252130e74c5fd5a4

台站下添加文件将文件存入数据库

 src/main/java/com/whyc/mapper/BattgroupDataMapper.java

New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;

import com.whyc.pojo.BattgroupData;

public interface BattgroupDataMapper extends CustomMapper<BattgroupData>{
}

 src/main/java/com/whyc/mapper/BattgroupInfoMapper.java

New file
@@ -0,0 +1,8 @@
package com.whyc.mapper;

import com.whyc.pojo.BattgroupInfo;

public interface BattgroupInfoMapper extends CustomMapper<BattgroupInfo>{
    ////查询最大的电池组号
    int selectMaxId();
}

 src/main/java/com/whyc/mapper/FileParamMapper.java

New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;

import com.whyc.pojo.FileParam;

public interface FileParamMapper extends CustomMapper<FileParam>{
}

 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){
            //查询站点的机房是否存在stationId
            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){

 src/main/resources/mapper/BattgroupDataMapper.xml

New file
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.BattgroupDataMapper">


</mapper>

 src/main/resources/mapper/BattgroupInfoMapper.xml

New file
@@ -0,0 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.BattgroupInfoMapper">


    <select id="selectMaxId" resultType="java.lang.Integer">
        select ifnull(max(battGroup_id),"100000001") from db_res_meter.tb_battgroup_info limit 1
    </select>
</mapper>

 src/main/resources/mapper/FileParamMapper.xml

New file
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.FileParamMapper">


</mapper>