Method group_csv

drg_group/qingdao_2023/GroupProxy.java:162–179

(Path filename,List<String> cols)

        System.out.println("group time "+(d2.getTime() - d1.getTime()));
    }
    public void group_csv(Path filename,List<String> cols){
        Date d1= new Date();
        List<String> result=read_csv(filename,cols)
            .parallel()
            .map(x->group_record(new MedicalRecord(x)).toCsv())
            // .filter(x->x.record.remark!=null&&!x.record.remark.isEmpty()&&!x.drg.equals(x.record.remark))
            .collect(Collectors.toList());
        Date d2= new Date();
        System.out.println("record count "+result.size());
        System.out.println("group time "+(d2.getTime() - d1.getTime()));
        result.add(0, "\uFEFF"+"Index,gender,age,ageDay,weight,dept,inHospitalTime,leavingType,zdList,ssList,remark,status,messages,mdc,adrg,drg");
        try{
            Files.write(Paths.get(filename.toString().replace(".csv", "_java_result.csv")),result,StandardCharsets.UTF_8,StandardOpenOption.CREATE_NEW);
        }catch(IOException e) {
            System.out.println(String.format("文件写入失败%s", Paths.get(filename.toString().replace(".csv", "_java_result.csv"))));
            e.printStackTrace();
        }
    }
    public static Stream<Object> read_csv(Path filename,List<String> cols){
        try {
            List<String> headers=Arrays.asList(Files.lines(filename).findFirst().get().replace( "\uFEFF", "").split(",",-1));