main
黄海 7 months ago
parent 42e3fa840d
commit f8a445c3db

@ -160,7 +160,7 @@
type: "POST", type: "POST",
dataType: "json", dataType: "json",
async: false, async: false,
url: '/dsBase/dataease/saveDataSetByCity', url: '/dsBase/dataease/saveDataSet',
data: { data: {
"id": id, "id": id,
"data": JSON.stringify(cleanedData) "data": JSON.stringify(cleanedData)

@ -143,7 +143,7 @@
type: "POST", type: "POST",
dataType: "json", dataType: "json",
async: false, async: false,
url: '/dsBase/dataease/saveDataSetByProvince', url: '/dsBase/dataease/saveDataSet',
data: { data: {
"id": id, "id": id,
"data": JSON.stringify(cleanedData) "data": JSON.stringify(cleanedData)

@ -343,14 +343,14 @@ public class DataEaseController extends Controller {
/** /**
* *
* *
* @param dataset_id id * @param dataset_id id
* @param id id * @param id id
* @param field * @param field
* @param value * @param value
*/ */
@Before(POST.class) @Before(POST.class)
@IsLoginInterface({}) @IsLoginInterface({})
public void saveDataSet(int dataset_id, int id,String field,String value) { public void saveDataSet(int dataset_id, int id, String field, String value) {
dm.saveDataSet(dataset_id, id, field, value); dm.saveDataSet(dataset_id, id, field, value);
renderJson(CommonUtil.returnMessageJson(true, "保存成功")); renderJson(CommonUtil.returnMessageJson(true, "保存成功"));
} }
@ -385,12 +385,16 @@ public class DataEaseController extends Controller {
/** /**
* *
* *
* @param id id * @param id id
* @param pageNumber
* @param pageSize
*/ */
@Before(GET.class) @Before(GET.class)
@IsLoginInterface({}) @IsLoginInterface({})
@IsNumericInterface({"id"}) @IsNumericInterface({"id"})
public void getDataSetContentByCity(int id) { public void getDataSetContentByCity(int id, int pageNumber, int pageSize) {
if (pageNumber == 0) pageNumber = 1;
if (pageSize == 0) pageSize = 20;
//登录的人员 //登录的人员
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");
@ -400,52 +404,10 @@ public class DataEaseController extends Controller {
//根据区域码,获取区域名称 //根据区域码,获取区域名称
String area_name = rm.getAreaName(area_code); String area_name = rm.getAreaName(area_code);
List<Record> list = dm.getDataSetContentByCity(id, area_name); Page<Record> list = dm.getDataSetContentByCity(id, area_name, pageNumber, pageSize);
renderJson(CommonUtil.renderJsonForLayUI(list)); renderJson(CommonUtil.renderJsonForLayUI(list));
} }
/**
*
*
* @param id id
* @param data
*/
@Before(POST.class)
@IsLoginInterface({})
public void saveDataSetByCity(int id, String data) {
//登录的人员
int identity_id = Integer.parseInt(CookieUtil.getValue(getRequest(), "identity_id"));
String person_id = CookieUtil.getValue(getRequest(), "person_id");
//获取他是哪个城市或者县区的管理员
//行政区划码
String area_code = rm.getAreaCode(identity_id, person_id);
//根据区域码,获取区域名称
String area_name = rm.getAreaName(area_code);
//行政区划
Record rArea = rm.getAreaRecordByName(area_name);
String area_id = rArea.getStr("id");
//此市州下有哪些县区
List<Record> list = dm.getAreaList(area_id);
Set<String> set = new HashSet<>();
for (Record record : list) {
set.add(record.getStr("area_name"));
}
JSONArray jsonArray = JSONArray.fromObject(data);
for (Object o : jsonArray) {
JSONObject jo = (JSONObject) o;
if (!set.contains(jo.get("行政区划").toString())) {
renderJson(CommonUtil.returnMessageJson(false, jo.get("行政区划").toString() + "并不隶属于" + area_name + ",请检查后重新填报!"));
return;
}
jo.put("上级行政区划", area_name);
}
//保存
dm.saveDataSetByCity(id, area_name, jsonArray);
renderJson(CommonUtil.returnMessageJson(true, "保存成功"));
}
/** /**
* Excel * Excel
* *
@ -552,25 +514,13 @@ public class DataEaseController extends Controller {
@Before(GET.class) @Before(GET.class)
@IsLoginInterface({}) @IsLoginInterface({})
@IsNumericInterface({"id"}) @IsNumericInterface({"id"})
public void getDataSetContentByProvince(int id) { public void getDataSetContentByProvince(int id, int pageNumber, int pageSize) {
List<Record> list = dm.getDataSetContentByProvince(id); if (pageNumber == 0) pageNumber = 1;
if (pageSize == 0) pageSize = 20;
Page<Record> list = dm.getDataSetContentByProvince(id, pageNumber, pageSize);
renderJson(CommonUtil.renderJsonForLayUI(list)); renderJson(CommonUtil.renderJsonForLayUI(list));
} }
/**
*
*
* @param id id
* @param data
*/
@Before(POST.class)
@IsLoginInterface({})
public void saveDataSetByProvince(int id, String data) {
JSONArray jsonArray = JSONArray.fromObject(data);
//保存
dm.saveDataSetByCity(id, "云南省", jsonArray);
renderJson(CommonUtil.returnMessageJson(true, "保存成功"));
}
/** /**
* Excel * Excel

@ -606,12 +606,13 @@ public class DataEaseModel {
* @param area_name * @param area_name
* @return * @return
*/ */
public List<Record> getDataSetContentByCity(int id, String area_name) { public Page<Record> getDataSetContentByCity(int id, String area_name, int pageNumber, int pageSize) {
Record record = Db.findById("t_dp_dataset", "id", id); Record record = Db.findById("t_dp_dataset", "id", id);
String tableName = record.getStr("table_name"); String tableName = record.getStr("table_name");
String sql = "select * from `" + tableName + "` where `上级行政区划`='" + area_name + "'"; Page<Record> p = Db.paginate(pageNumber, pageSize,
return Db.use(DB_NAME).find(sql); "SELECT *", "from " + DB_NAME + ".`" + tableName + "` where `上级行政区划`='" + area_name + "'");
return p;
} }
/** /**
@ -620,12 +621,12 @@ public class DataEaseModel {
* @param id * @param id
* @return * @return
*/ */
public List<Record> getDataSetContentByProvince(int id) { public Page<Record> getDataSetContentByProvince(int id, int pageNumber, int pageSize) {
Record record = Db.findById("t_dp_dataset", "id", id); Record record = Db.findById("t_dp_dataset", "id", id);
String tableName = record.getStr("table_name"); String tableName = record.getStr("table_name");
String sql = "select * from `" + tableName + "`"; return Db.paginate(pageNumber, pageSize,
return Db.use(DB_NAME).find(sql); "SELECT *", "from " + DB_NAME + ".`" + tableName + "`");
} }
/** /**
@ -639,45 +640,6 @@ public class DataEaseModel {
} }
/**
*
*
* @param id id
* @param ja json
*/
public void saveDataSetByCity(int id, String area_name, JSONArray ja) {
Record record = Db.findById("t_dp_dataset", "id", id);
String tableName = record.getStr("table_name");
String sql = "select max(id) as id from " + tableName;
Record r = Db.use(DB_NAME).findFirst(sql);
int start = 0;
if (r == null) {
start = 1;
} else {
start = r.getInt("id") + 1;
}
sql = "delete from `" + tableName + "` where `上级行政区划`=?";
Db.use(DB_NAME).update(sql, area_name);
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;
if (value == null || value.equals("")) value = null;
record.set(key.toString(), value);
}
record.set("id", ++start);
list.add(record);
}
Db.use(DB_NAME).batchSave(tableName, list, 100);
}
/** /**
* Excel * Excel

Loading…
Cancel
Save