|
|
|
@ -591,10 +591,10 @@ public class DataEaseModel {
|
|
|
|
|
Page<Record> p;
|
|
|
|
|
if (identity_id > 1) {
|
|
|
|
|
p = Db.paginate(pageNumber, pageSize,
|
|
|
|
|
"SELECT *", "from "+DB_NAME+".`" + tableName + "` where `行政区划`='" + area_name + "' or `上级行政区划`='" + area_name + "'");
|
|
|
|
|
"SELECT *", "from " + DB_NAME + ".`" + tableName + "` where `行政区划`='" + area_name + "' or `上级行政区划`='" + area_name + "'");
|
|
|
|
|
} else {
|
|
|
|
|
p = Db.paginate(pageNumber, pageSize,
|
|
|
|
|
"SELECT *", "from "+DB_NAME+".`" + tableName + "`");
|
|
|
|
|
"SELECT *", "from " + DB_NAME + ".`" + tableName + "`");
|
|
|
|
|
}
|
|
|
|
|
return p;
|
|
|
|
|
}
|
|
|
|
@ -630,36 +630,12 @@ public class DataEaseModel {
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 保存数据集对应的表
|
|
|
|
|
*
|
|
|
|
|
* @param id 数据集id
|
|
|
|
|
* @param ja json数组
|
|
|
|
|
*/
|
|
|
|
|
public void saveDataSet(int identity_id, int id, String area_name, JSONArray ja) {
|
|
|
|
|
Record record = Db.findById("t_dp_dataset", "id", id);
|
|
|
|
|
public void saveDataSet(int dataset_id, int id, String field, String value) {
|
|
|
|
|
Record record = Db.findById("t_dp_dataset", "id", dataset_id);
|
|
|
|
|
String tableName = record.getStr("table_name");
|
|
|
|
|
|
|
|
|
|
if (identity_id > 1) {
|
|
|
|
|
String sql = "delete from `" + tableName + "` where `行政区划`=?";
|
|
|
|
|
Db.use(DB_NAME).update(sql, area_name);
|
|
|
|
|
} else {
|
|
|
|
|
String sql = "delete from `" + tableName + "`";
|
|
|
|
|
Db.use(DB_NAME).update(sql);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
List<Record> list = new ArrayList<>();
|
|
|
|
|
for (int i = 0; i < ja.size(); i++) {
|
|
|
|
|
JSONObject jsonObject = ja.getJSONObject(i);
|
|
|
|
|
//遍历jo的每一个属性
|
|
|
|
|
// 或者使用keySet和for-each循环遍历
|
|
|
|
|
record = new Record();
|
|
|
|
|
for (Object key : jsonObject.keySet()) {
|
|
|
|
|
Object value = jsonObject.get(key);
|
|
|
|
|
if (value.equals("null")) value = null;
|
|
|
|
|
record.set(key.toString(), value);
|
|
|
|
|
}
|
|
|
|
|
list.add(record);
|
|
|
|
|
}
|
|
|
|
|
Db.use(DB_NAME).batchSave(tableName, list, 100);
|
|
|
|
|
String sql = "update `" + tableName + "` set `" + field + "`=? where id=?";
|
|
|
|
|
Db.use(DB_NAME).update(sql, value, id);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|