|
|
|
@ -115,54 +115,54 @@ public class Step3_DataSetFakeData {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//市州净注入与净流出的数据集
|
|
|
|
|
// String tableName = "excel_区域人口流动分布_193751804a";
|
|
|
|
|
// for (Record record : listCity) {
|
|
|
|
|
// String cityName = record.getStr("area_name");
|
|
|
|
|
// String sql = "delete from `" + tableName + "` where `行政区划`='" + cityName + "'";
|
|
|
|
|
// Db.use(DataEaseModel.DB_NAME).update(sql);
|
|
|
|
|
// System.out.println(cityName + "正在处理数据集:" + tableName);
|
|
|
|
|
// if (keepArea.contains(cityName)) continue;
|
|
|
|
|
// Record rCity = dm.getAreaByName(cityName);
|
|
|
|
|
// List<Record> lArea = dm.getAreaList(rCity.getStr("id"));
|
|
|
|
|
// List<Record> writeList = new ArrayList<>();
|
|
|
|
|
// int x = 0;
|
|
|
|
|
// for (Record r : lArea) {
|
|
|
|
|
// x++;
|
|
|
|
|
// Record rArea = new Record();
|
|
|
|
|
// rArea.set("行政区划", cityName);
|
|
|
|
|
// rArea.set("下级行政区划", r.getStr("area_name"));
|
|
|
|
|
// rArea.set("类型", x % 2 == 1 ? "净流出" : "净流入");
|
|
|
|
|
// rArea.set("数值", 900);
|
|
|
|
|
// writeList.add(rArea);
|
|
|
|
|
// }
|
|
|
|
|
// Db.use(DataEaseModel.DB_NAME).batchSave(tableName, writeList, 100);
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//县区净注入与净流出的数据集
|
|
|
|
|
String tableName = "excel_区域人口流动分布_374179b760";
|
|
|
|
|
int x=0;
|
|
|
|
|
String tableName = "excel_区域人口流动分布_193751804a";
|
|
|
|
|
for (Record record : listCity) {
|
|
|
|
|
x++;
|
|
|
|
|
String cityName = record.getStr("area_name");
|
|
|
|
|
if (keepArea.contains(cityName)) continue;
|
|
|
|
|
String sql = "delete from `" + tableName + "` where `上级行政区划`='" + cityName + "'";
|
|
|
|
|
String sql = "delete from `" + tableName + "` where `行政区划`='" + cityName + "'";
|
|
|
|
|
Db.use(DataEaseModel.DB_NAME).update(sql);
|
|
|
|
|
|
|
|
|
|
System.out.println(cityName + "正在处理数据集:" + tableName);
|
|
|
|
|
//if (keepArea.contains(cityName)) continue;
|
|
|
|
|
Record rCity = dm.getAreaByName(cityName);
|
|
|
|
|
List<Record> lArea = dm.getAreaList(rCity.getStr("id"));
|
|
|
|
|
List<Record> writeList = new ArrayList<>();
|
|
|
|
|
int x = 0;
|
|
|
|
|
for (Record r : lArea) {
|
|
|
|
|
x++;
|
|
|
|
|
Record rArea = new Record();
|
|
|
|
|
rArea.set("上级行政区划", cityName);
|
|
|
|
|
rArea.set("行政区划", r.getStr("area_name"));
|
|
|
|
|
rArea.set("类型", x % 2 == 1 ? "净流出" : "净流入");
|
|
|
|
|
rArea.set("数值(人)", 2313250);
|
|
|
|
|
rArea.set("行政区划", cityName);
|
|
|
|
|
rArea.set("下级行政区划", r.getStr("area_name"));
|
|
|
|
|
rArea.set("类型", x % 2 == 1 ? "净流出" : "净流入");
|
|
|
|
|
rArea.set("数值", 900);
|
|
|
|
|
writeList.add(rArea);
|
|
|
|
|
}
|
|
|
|
|
Db.use(DataEaseModel.DB_NAME).batchSave(tableName, writeList, 100);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// //县区净注入与净流出的数据集
|
|
|
|
|
// String tableName = "excel_区域人口流动分布_374179b760";
|
|
|
|
|
// int x=0;
|
|
|
|
|
// for (Record record : listCity) {
|
|
|
|
|
// x++;
|
|
|
|
|
// String cityName = record.getStr("area_name");
|
|
|
|
|
// if (keepArea.contains(cityName)) continue;
|
|
|
|
|
// String sql = "delete from `" + tableName + "` where `上级行政区划`='" + cityName + "'";
|
|
|
|
|
// Db.use(DataEaseModel.DB_NAME).update(sql);
|
|
|
|
|
//
|
|
|
|
|
// System.out.println(cityName + "正在处理数据集:" + tableName);
|
|
|
|
|
// Record rCity = dm.getAreaByName(cityName);
|
|
|
|
|
// List<Record> lArea = dm.getAreaList(rCity.getStr("id"));
|
|
|
|
|
// List<Record> writeList = new ArrayList<>();
|
|
|
|
|
// for (Record r : lArea) {
|
|
|
|
|
// Record rArea = new Record();
|
|
|
|
|
// rArea.set("上级行政区划", cityName);
|
|
|
|
|
// rArea.set("行政区划", r.getStr("area_name"));
|
|
|
|
|
// rArea.set("类型", x % 2 == 1 ? "净流出" : "净流入");
|
|
|
|
|
// rArea.set("数值(人)", 2313250);
|
|
|
|
|
// writeList.add(rArea);
|
|
|
|
|
// }
|
|
|
|
|
// Db.use(DataEaseModel.DB_NAME).batchSave(tableName, writeList, 100);
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|