airoptserver/src/main/java/com/miniframe/tools/file/SurromdaoFileRead.java

package com.miniframe.tools.file;

import com.google.gson.Gson;
import com.miniframe.core.ext.UtilTools;
import com.miniframe.model.mdo.MdoProComval;
import com.miniframe.model.mdo.MdoProComvalSQLBuilder;
import com.miniframe.model.mdo.dao.MdoProComvalMapper;
import com.miniframe.websocket.WebsocketEndPoint;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.util.List;

public class SurromdaoFileRead {

    public static void readFile(File file, String pid) {
        String line1="";
        MdoProComvalMapper comvalDao = UtilTools.getBean(MdoProComvalMapper.class);
        MdoProComvalSQLBuilder sb =new MdoProComvalSQLBuilder();
        MdoProComvalSQLBuilder.Criteria sc = sb.createCriteria();
        sc.andPidEqualTo(pid);
        sc.andTypeEqualTo(1);
        sb.setOrderByClause("step asc");
        List<MdoProComval> comvals =comvalDao.selectByExample(sb);
        int con =0;
        if(comvals!=null||!comvals.isEmpty()){
            con=comvals.size();
        }
        int i= 0;

        // 使用try-with-resources语句确保资源被正确关闭
        try (BufferedReader br = new BufferedReader(new FileReader(file))) {
            String line;
            // 逐行读取，直到文件末尾
            while ((line = br.readLine()) != null) {
                if(i ==0){
                    line=line.trim().replaceAll("\\s+"," ");//替换多个空格为一个空格
                    line=line.replace(" / ","/");
                    line1=line.replace("阻力系数Cdconstraint","阻力系数Cd constraint");
                    // 处理每一行数据
                    System.out.println(line);
                }
//                if(!line.endsWith("\n")){
//
//                }
                if(i>con){
                    String tvals=line.trim().replaceAll("\\s+"," ");//替换多个空格为一个空格
                    MdoProComval comval =new MdoProComval();
                    comval.setId(UtilTools.getUUid());
                    comval.setPid(pid);
                    comval.setStep(i);
                    comval.setVars(line1);
                    comval.setVals(tvals);
                    comval.setType(1);
                    comvalDao.insert(comval);
                    WebsocketEndPoint webs =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
                    Gson gson = new Gson();
                    webs.sendMessageToUser(String.valueOf(pid),gson.toJson(comval));
                }
                i++;

            }
        } catch (IOException e) {
            // 异常处理
            e.printStackTrace();
        }
    }
}