main
黄海 9 months ago
parent 48cc4a643b
commit 9fb685651f

@ -259,25 +259,24 @@ public class DataEaseController extends Controller {
/** /**
* *
* *
* @param dataset_id id * @param id id
*/ */
@Before(GET.class) @Before(GET.class)
@IsLoginInterface({}) @IsLoginInterface({})
@IsNumericInterface({"dataset_id"}) public void getDataSetContent(int id) {
public void getDataSetContent(int dataset_id) { List<Record> list = dm.getDataSetContent(id);
List<Record> list = dm.getDataSetContent(dataset_id);
renderJson(CommonUtil.renderJsonForLayUI(list)); renderJson(CommonUtil.renderJsonForLayUI(list));
} }
/** /**
* *
* *
* @param dataset_id id * @param id id
* @param data * @param data
*/ */
@Before(POST.class) @Before(POST.class)
@IsLoginInterface({}) @IsLoginInterface({})
public void saveDataSet(int dataset_id, String data) { public void saveDataSet(int id, String data) {
//登录的人员 //登录的人员
int identity_id = Integer.parseInt(CookieUtil.getValue(getRequest(), "identity_id")); int identity_id = Integer.parseInt(CookieUtil.getValue(getRequest(), "identity_id"));
String person_id = CookieUtil.getValue(getRequest(), "person_id"); String person_id = CookieUtil.getValue(getRequest(), "person_id");
@ -297,7 +296,7 @@ public class DataEaseController extends Controller {
jo.put("上级行政区划", parent_area_name); jo.put("上级行政区划", parent_area_name);
} }
//保存 //保存
dm.saveDataSet(dataset_id, area_name, jsonArray); dm.saveDataSet(id, area_name, jsonArray);
renderJson(CommonUtil.returnMessageJson(true, "保存成功")); renderJson(CommonUtil.returnMessageJson(true, "保存成功"));
} }
} }

@ -190,7 +190,7 @@ public class DataEaseModel {
* @param dataset_group_id id * @param dataset_group_id id
* @return * @return
*/ */
public String getTableName(long dataset_group_id) { public String getTableName(String dataset_group_id) {
Kv kv = Kv.by("dataset_group_id", dataset_group_id); Kv kv = Kv.by("dataset_group_id", dataset_group_id);
SqlPara sqlPara = Db.getSqlPara("DataEase.getTableName", kv); SqlPara sqlPara = Db.getSqlPara("DataEase.getTableName", kv);
return Db.findFirst(sqlPara).getStr("table_name"); return Db.findFirst(sqlPara).getStr("table_name");
@ -351,7 +351,7 @@ public class DataEaseModel {
//数据集名称 //数据集名称
String dataset_name = record.getStr("name"); String dataset_name = record.getStr("name");
//对应的表名 //对应的表名
String table_name = getTableName(dataease_id); String table_name = getTableName(String.valueOf(dataease_id));
//将这些数据集扫描到表中,然后标识这个数据集由谁来维护 //将这些数据集扫描到表中,然后标识这个数据集由谁来维护
collectDataSet(parent_name, table_name, dataset_name, dataease_id); collectDataSet(parent_name, table_name, dataset_name, dataease_id);
} }
@ -565,11 +565,12 @@ public class DataEaseModel {
/** /**
* *
* *
* @param dataset_id id * @param id id
* @return * @return
*/ */
public List<Record> getDataSetContent(int dataset_id) { public List<Record> getDataSetContent(int id) {
String tableName = getTableName(dataset_id); Record record = Db.findById("t_dp_dataset", "id", id);
String tableName = record.getStr("table_name");
String sql = "select * from `" + tableName + "`"; String sql = "select * from `" + tableName + "`";
return Db.use(DB_NAME).find(sql); return Db.use(DB_NAME).find(sql);
} }
@ -577,20 +578,22 @@ public class DataEaseModel {
/** /**
* *
* *
* @param dataset_id id * @param id id
* @param ja json * @param ja json
*/ */
public void saveDataSet( int dataset_id, String area_name, JSONArray ja) { public void saveDataSet(int id, String area_name, JSONArray ja) {
String tableName = getTableName(dataset_id); Record record = Db.findById("t_dp_dataset", "id", id);
String tableName = record.getStr("table_name");
String sql = "delete from `" + tableName + "` where `行政区划`=?"; String sql = "delete from `" + tableName + "` where `行政区划`=?";
Db.use(DB_NAME).update(sql,area_name); Db.use(DB_NAME).update(sql, area_name);
List<Record> list = new ArrayList<>(); List<Record> list = new ArrayList<>();
for (int i = 0; i < ja.size(); i++) { for (int i = 0; i < ja.size(); i++) {
JSONObject jsonObject = ja.getJSONObject(i); JSONObject jsonObject = ja.getJSONObject(i);
//遍历jo的每一个属性 //遍历jo的每一个属性
// 或者使用keySet和for-each循环遍历 // 或者使用keySet和for-each循环遍历
Record record = new Record(); record = new Record();
for (Object key : jsonObject.keySet()) { for (Object key : jsonObject.keySet()) {
Object value = jsonObject.get(key); Object value = jsonObject.get(key);
if (value.equals("null")) value = null; if (value.equals("null")) value = null;

Loading…
Cancel
Save