Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调整导出excel实体类

Browse Source
This commit is contained in:
wr
2025-04-28 14:27:50 +08:00
parent 5007dda683
commit bb061305db
2 changed files with 13 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/impl/MigrationServiceImpl.java
View File

@@ -12,12 +12,13 @@ import com.njcn.param.LineCountEvaluateParam;
import com.njcn.po.influx.DataV; import com.njcn.po.influx.DataV;
import com.njcn.migration.read.util.TimeUtil; import com.njcn.migration.read.util.TimeUtil;
import com.njcn.po.influx.PqsCommunicate; import com.njcn.po.influx.PqsCommunicate;
import com.njcn.po.mysql.DevTimeDto;
import com.njcn.po.mysql.LineTimeDto;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.io.File; import java.io.File;
import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
@@ -131,33 +132,31 @@ public class MigrationServiceImpl implements MigrationService {
public void initializeExcel() { public void initializeExcel() {
File file = new File("/usr/local/jar/sj.xlsx"); File file = new File("/usr/local/jar/sj.xlsx");
Map<String, String> map = TimeUtil.getLineMap(); Map<String, String> map = TimeUtil.getLineMap();
List<DataV> lineExcel = new ArrayList<>(); List<LineTimeDto> lineExcel = new ArrayList<>();
map.forEach((line,value)->{ map.forEach((line,value)->{
DataV data=new DataV(); LineTimeDto data=new LineTimeDto();
data.setLineId(line); data.setLineId(line);
data.setTimeId(value); data.setTimeData(value);
lineExcel.add(data); lineExcel.add(data);
}); });
Map<String, String> devmap = TimeUtil.getDevMap(); Map<String, String> devmap = TimeUtil.getDevMap();
List<PqsCommunicate> devExcel = new ArrayList<>(); List<DevTimeDto> devExcel = new ArrayList<>();
devmap.forEach((line,value)->{ devmap.forEach((line,value)->{
PqsCommunicate data=new PqsCommunicate(); DevTimeDto data=new DevTimeDto();
data.setDevId(line); data.setDevId(line);
data.setTimeId(value); data.setTimeData(value);
devExcel.add(data); devExcel.add(data);
}); });
ExcelWriter excelWriter = EasyExcel.write(file).build(); ExcelWriter excelWriter = EasyExcel.write(file).build();
//模板1 //模板1
WriteSheet writeSheet = EasyExcel.writerSheet(0, "line" ).head(DataV.class) WriteSheet writeSheet = EasyExcel.writerSheet(0, "line" ).head(LineTimeDto.class)
.includeColumnFiledNames(Arrays.asList("lineId","timeId"))
.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy())
.build(); .build();
excelWriter.write(lineExcel, writeSheet); excelWriter.write(lineExcel, writeSheet);
//模板2 //模板2
WriteSheet writeSheet2 = EasyExcel.writerSheet(1, "dev" ).head(PqsCommunicate.class) WriteSheet writeSheet2 = EasyExcel.writerSheet(1, "dev" ).head(DevTimeDto.class)
.includeColumnFiledNames(Arrays.asList("devId","timeId"))
.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy())
.build(); .build();
excelWriter.write(devExcel, writeSheet2); excelWriter.write(devExcel, writeSheet2);

8
migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/util/TimeUtil.java
View File

@@ -79,7 +79,7 @@ public class TimeUtil {
} }
@PostConstruct @PostConstruct
public void init() throws IOException { public void init() {
File file = new File("/usr/local/jar/sj.xlsx"); File file = new File("/usr/local/jar/sj.xlsx");
List<LineTimeDto> excelDataV = EasyExcel.read(file) List<LineTimeDto> excelDataV = EasyExcel.read(file)
.head(LineTimeDto.class) .head(LineTimeDto.class)
@@ -119,15 +119,13 @@ public class TimeUtil {
ExcelWriter excelWriter = EasyExcel.write(file).build(); ExcelWriter excelWriter = EasyExcel.write(file).build();
//模板1 //模板1
WriteSheet writeSheet = EasyExcel.writerSheet(0, "line").head(DataV.class) WriteSheet writeSheet = EasyExcel.writerSheet(0, "line").head(LineTimeDto.class)
.includeColumnFiledNames(Arrays.asList("lineId", "timeData"))
.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy())
.build(); .build();
excelWriter.write(excelDataV, writeSheet); excelWriter.write(excelDataV, writeSheet);
//模板2 //模板2
WriteSheet writeSheet2 = EasyExcel.writerSheet(1, "dev").head(PqsCommunicate.class) WriteSheet writeSheet2 = EasyExcel.writerSheet(1, "dev").head(DevTimeDto.class)
.includeColumnFiledNames(Arrays.asList("devId", "timeData"))
.registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy())
.build(); .build();
excelWriter.write(excelCommunicates, writeSheet2); excelWriter.write(excelCommunicates, writeSheet2);