|
@@ -1,6 +1,5 @@
|
|
|
package com.nokia.sms;
|
|
|
|
|
|
-import com.nokia.sms.task.SyncTask;
|
|
|
import de.siegmar.fastcsv.reader.CsvReader;
|
|
|
import de.siegmar.fastcsv.reader.CsvRow;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
@@ -23,11 +22,10 @@ import java.util.stream.Stream;
|
|
|
class SyncTest {
|
|
|
@Autowired
|
|
|
private JdbcTemplate jdbcTemplate;
|
|
|
- @Autowired
|
|
|
- private SyncTask syncTask;
|
|
|
|
|
|
@Test
|
|
|
- void test() {}
|
|
|
+ void test() {
|
|
|
+ }
|
|
|
|
|
|
/**
|
|
|
* 测试导入数据
|
|
@@ -36,7 +34,7 @@ class SyncTest {
|
|
|
void testImport() {
|
|
|
String path = "z:/data";
|
|
|
// 读取目标文件夹下的文件
|
|
|
- try(Stream<Path> stream = Files.list(Paths.get(path))) {
|
|
|
+ try (Stream<Path> stream = Files.list(Paths.get(path))) {
|
|
|
List<Path> pathList = stream.collect(Collectors.toList());
|
|
|
log.info("pathList: {}", pathList);
|
|
|
for (Path t : pathList) {
|
|
@@ -45,7 +43,7 @@ class SyncTest {
|
|
|
log.info("file: {}", t.getFileName().toString());
|
|
|
try (CsvReader csvReader = CsvReader.builder().build(t, StandardCharsets.UTF_8)) {
|
|
|
for (CsvRow row : csvReader) {
|
|
|
- Object[] o1 = new Object[]{
|
|
|
+ Object[] o1 = new Object[] {
|
|
|
row.getField(0),
|
|
|
Integer.valueOf(row.getField(1)),
|
|
|
row.getField(2),
|
|
@@ -55,7 +53,7 @@ class SyncTest {
|
|
|
Integer.valueOf(row.getField(6)),
|
|
|
};
|
|
|
l1.add(o1);
|
|
|
- Object[] o2 = new Object[]{
|
|
|
+ Object[] o2 = new Object[] {
|
|
|
row.getField(0),
|
|
|
Integer.valueOf(row.getField(1)),
|
|
|
row.getField(2),
|
|
@@ -66,7 +64,7 @@ class SyncTest {
|
|
|
t.getFileName().toString()
|
|
|
};
|
|
|
l2.add(o2);
|
|
|
-// log.info("{}: {}", row.getOriginalLineNumber(), o1);
|
|
|
+ // log.info("{}: {}", row.getOriginalLineNumber(), o1);
|
|
|
}
|
|
|
}
|
|
|
log.info("blacklist");
|