Commit 91d8c821 authored by gary's avatar gary

1、dataInit fix

parent 5b802508
...@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; ...@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.common.io.Files;
import org.apache.commons.io.FileUtils; import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.junit.Test; import org.junit.Test;
...@@ -22,6 +23,7 @@ import javax.annotation.Resource; ...@@ -22,6 +23,7 @@ import javax.annotation.Resource;
import java.io.File; import java.io.File;
import java.io.FileWriter; import java.io.FileWriter;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.*; import java.util.*;
...@@ -80,12 +82,11 @@ public class DataInitTest extends CommonIT { ...@@ -80,12 +82,11 @@ public class DataInitTest extends CommonIT {
public void importOrgJson(){ public void importOrgJson(){
String input = ""; String input = "";
try { try {
String filePath = "C:\\Users\\Gary J Li\\Documents\\PwcDoc\\DD2018\\admin文档\\初始化\\company_info.json"; File targetFile = new File("src/main/resources/orgImport/company_info.json");
input = FileUtils.readFileToString(new File(filePath), "UTF-8"); input = FileUtils.readFileToString(targetFile, "UTF-8");
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
JSONObject object = JSONObject.parseObject(input); JSONObject object = JSONObject.parseObject(input);
Map<String, Object> orgs = object.getInnerMap(); Map<String, Object> orgs = object.getInnerMap();
Map<String, Object> failList = new HashMap<>(); Map<String, Object> failList = new HashMap<>();
...@@ -171,9 +172,9 @@ public class DataInitTest extends CommonIT { ...@@ -171,9 +172,9 @@ public class DataInitTest extends CommonIT {
} }
equityInfos.forEach(ei -> { equityInfos.forEach(ei -> {
// 逐条insert 失败的记录 // 逐条insert 失败的记录
/*if (equityInformationMapper.insertSelective(ei) < 1) { if (equityInformationMapper.insertSelective(ei) < 1) {
failList.putIfAbsent(orgK, orgV); failList.putIfAbsent(orgK, orgV);
}*/ }
}); });
} }
} else if ("股东信息".equals(infoK) && equityInfos.isEmpty()) { } else if ("股东信息".equals(infoK) && equityInfos.isEmpty()) {
...@@ -243,9 +244,9 @@ public class DataInitTest extends CommonIT { ...@@ -243,9 +244,9 @@ public class DataInitTest extends CommonIT {
} }
equityInfos1.forEach(ei -> { equityInfos1.forEach(ei -> {
// 逐条insert 失败的记录 // 逐条insert 失败的记录
/* if (equityInformationMapper.insertSelective(ei) < 1) { if (equityInformationMapper.insertSelective(ei) < 1) {
failList.putIfAbsent(orgK, orgV); failList.putIfAbsent(orgK, orgV);
}*/ }
}); });
} }
} else if ("变更记录".equals(infoK)) { } else if ("变更记录".equals(infoK)) {
...@@ -271,9 +272,9 @@ public class DataInitTest extends CommonIT { ...@@ -271,9 +272,9 @@ public class DataInitTest extends CommonIT {
}); });
logs.forEach(l -> { logs.forEach(l -> {
// 逐条insert 失败的记录 // 逐条insert 失败的记录
/* if (operationLogEquityMapper.insertSelective(l) < 1) { if (operationLogEquityMapper.insertSelective(l) < 1) {
failList.putIfAbsent(orgK, orgV); failList.putIfAbsent(orgK, orgV);
}*/ }
}); });
} }
...@@ -344,7 +345,7 @@ public class DataInitTest extends CommonIT { ...@@ -344,7 +345,7 @@ public class DataInitTest extends CommonIT {
} }
} }
}); });
/* if (organizationMapper.insertSelective(org) < 0) { if (organizationMapper.insertSelective(org) < 0) {
failList.putIfAbsent(orgK, orgV); failList.putIfAbsent(orgK, orgV);
} }
if (organizationExtraMapper.insertSelective(orgEx) < 0) { if (organizationExtraMapper.insertSelective(orgEx) < 0) {
...@@ -352,7 +353,7 @@ public class DataInitTest extends CommonIT { ...@@ -352,7 +353,7 @@ public class DataInitTest extends CommonIT {
} }
if (organizationEmployeeMapper.insertSelective(orgEmp) < 0) { if (organizationEmployeeMapper.insertSelective(orgEmp) < 0) {
failList.putIfAbsent(orgK, orgV); failList.putIfAbsent(orgK, orgV);
}*/ }
insertExtraList(orgId); insertExtraList(orgId);
} }
}); });
...@@ -366,7 +367,7 @@ public class DataInitTest extends CommonIT { ...@@ -366,7 +367,7 @@ public class DataInitTest extends CommonIT {
FileWriter writer; FileWriter writer;
FileWriter writer1; FileWriter writer1;
try { try {
writer = new FileWriter("C:\\Users\\Gary J Li\\Documents\\PwcDoc\\DD2018\\admin文档\\初始化\\company_info_failed.json"); writer = new FileWriter("src/main/resources/orgImport/company_info_failed.json");
writer.write(failedStr); writer.write(failedStr);
writer.flush(); writer.flush();
writer.close(); writer.close();
...@@ -374,7 +375,7 @@ public class DataInitTest extends CommonIT { ...@@ -374,7 +375,7 @@ public class DataInitTest extends CommonIT {
e.printStackTrace(); e.printStackTrace();
} }
try { try {
writer1 = new FileWriter("C:\\Users\\Gary J Li\\Documents\\PwcDoc\\DD2018\\admin文档\\初始化\\company_info_msg.txt"); writer1 = new FileWriter("src/main/resources/orgImport/company_info_msg.txt");
writer1.write(failMsg.toString()); writer1.write(failMsg.toString());
writer1.flush(); writer1.flush();
writer1.close(); writer1.close();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment