kgdxpr 9 months ago
commit c083061041

@ -1 +1 @@
[{"baseUrl":"","className":"DataEaseController","description":"DataEaseController","docFileName":"com_dsideal_base_DataEase_Controller_DataEaseController.html","generateDocs":true,"packageName":"com.dsideal.base.DataEase.Controller","requestNodes":[{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#route","deprecated":false,"description":"省级路由","header":[],"method":["GET","POST"],"methodName":"route","paramNodes":[{"description":"城市名称","jsonBody":false,"name":"city_name","required":false,"type":"string"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/route"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#routePage","deprecated":false,"description":"市级路由","header":[],"method":["GET","POST"],"methodName":"routePage","paramNodes":[{"description":"哪一个仪表盘","jsonBody":false,"name":"type_id","required":false,"type":"int"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/routePage"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSet","deprecated":false,"description":"根据当前登录人员的identity_id,获取此人员可以维护的数据集名称","header":[],"method":["GET","POST"],"methodName":"getDataSet","paramNodes":[],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/getDataSet"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#downloadExcel","deprecated":false,"description":"下载指定数据集的Excel文件","header":[],"method":["GET","POST"],"methodName":"downloadExcel","paramNodes":[{"description":"数据集id","jsonBody":false,"name":"id","required":false,"type":"int"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/downloadExcel"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#downSampleExcel","deprecated":false,"description":"下载模板Excel","header":[],"method":["GET","POST"],"methodName":"downSampleExcel","paramNodes":[{"description":"数据集id","jsonBody":false,"name":"id","required":false,"type":"int"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/downSampleExcel"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#uploadExcel","deprecated":false,"description":"上传Excel文件","header":[],"method":["GET","POST"],"methodName":"uploadExcel","paramNodes":[],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/uploadExcel"}],"srcFileName":"D:\\dsWork\\YunNanDsBase\\src\\main\\java\\com\\dsideal\\base\\DataEase\\Controller\\DataEaseController.java"}]
[{"baseUrl":"","className":"DataEaseController","description":"DataEaseController","docFileName":"com_dsideal_base_DataEase_Controller_DataEaseController.html","generateDocs":true,"packageName":"com.dsideal.base.DataEase.Controller","requestNodes":[{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#route","deprecated":false,"description":"省级路由","header":[],"method":["GET","POST"],"methodName":"route","paramNodes":[{"description":"城市名称","jsonBody":false,"name":"city_name","required":false,"type":"string"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/route"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#routePage","deprecated":false,"description":"routePage","header":[],"method":["GET","POST"],"methodName":"routePage","paramNodes":[],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/routePage"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSet","deprecated":false,"description":"根据当前登录人员的identity_id,获取此人员可以维护的数据集名称","header":[],"method":["GET","POST"],"methodName":"getDataSet","paramNodes":[],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/getDataSet"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#downloadExcel","deprecated":false,"description":"下载指定数据集的Excel文件","header":[],"method":["GET","POST"],"methodName":"downloadExcel","paramNodes":[{"description":"数据集id","jsonBody":false,"name":"id","required":false,"type":"int"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/downloadExcel"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#downSampleExcel","deprecated":false,"description":"下载模板Excel","header":[],"method":["GET","POST"],"methodName":"downSampleExcel","paramNodes":[{"description":"数据集id","jsonBody":false,"name":"id","required":false,"type":"int"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/downSampleExcel"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#uploadExcel","deprecated":false,"description":"上传Excel文件","header":[],"method":["GET","POST"],"methodName":"uploadExcel","paramNodes":[],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/uploadExcel"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSetContent","deprecated":false,"description":"获取数据集下的数据表","header":[],"method":["GET","POST"],"methodName":"getDataSetContent","paramNodes":[{"description":"数据集id","jsonBody":false,"name":"dataset_id","required":false,"type":"int"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/getDataSetContent"},{"changeFlag":0,"codeFileUrl":"com_dsideal_base_DataEase_Controller_DataEaseController.html#saveDataSet","deprecated":false,"description":"保存数据集下的数据表","header":[],"method":["GET","POST"],"methodName":"saveDataSet","paramNodes":[{"description":"数据集id","jsonBody":false,"name":"dataset_id","required":false,"type":"int"},{"description":"保存的数据","jsonBody":false,"name":"data","required":false,"type":"string"}],"responseNode":{"childNodes":[],"className":"","list":false,"showFieldNotNull":false},"url":"/dataease/saveDataSet"}],"srcFileName":"D:\\dsWork\\YunNanDsBase\\src\\main\\java\\com\\dsideal\\base\\DataEase\\Controller\\DataEaseController.java"}]

@ -20,17 +20,11 @@
"request": {
"method": "GET",
"url": {
"query": [
{
"description": "哪一个仪表盘",
"value": "",
"key": "type_id"
}
],
"query": [],
"raw": "{{domain}}/dataease/routePage"
}
},
"name": "市级路由"
"name": "routePage"
},
{
"request": {
@ -83,6 +77,43 @@
}
},
"name": "上传Excel文件"
},
{
"request": {
"method": "GET",
"url": {
"query": [
{
"description": "数据集id",
"value": "",
"key": "dataset_id"
}
],
"raw": "{{domain}}/dataease/getDataSetContent"
}
},
"name": "获取数据集下的数据表"
},
{
"request": {
"method": "POST",
"url": {
"query": [
{
"description": "数据集id",
"value": "",
"key": "dataset_id"
},
{
"description": "保存的数据",
"value": "",
"key": "data"
}
],
"raw": "{{domain}}/dataease/saveDataSet"
}
},
"name": "保存数据集下的数据表"
}
],
"name": "DataEaseController"

@ -46,7 +46,7 @@
省级路由
</a>
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#routePage">
市级路由
routePage
</a>
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSet">
根据当前登录人员的identity_id,获取此人员可以维护的数据集名称
@ -60,6 +60,12 @@
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#uploadExcel">
上传Excel文件
</a>
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSetContent">
获取数据集下的数据表
</a>
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#saveDataSet">
保存数据集下的数据表
</a>
</div>
</div>
</div> </div>
@ -102,28 +108,13 @@
</div>
<hr>
<div class="action-item">
<h2 id="routePage"><a href="#">市级路由 </a></h2>
<h2 id="routePage"><a href="#">routePage </a></h2>
<p><strong>请求URL</strong></p>
<p>
<code>/dataease/routePage</code>
<span class="label label-default">GET</span>
<span class="label label-default">POST</span>
</p>
<p><strong>请求参数</strong> <span class="badge">application/x-www-form-urlencoded</span></p>
<table class="table table-bordered">
<tr>
<th>参数名</th>
<th>类型</th>
<th>必须</th>
<th>描述</th>
</tr>
<tr>
<td>type_id</td>
<td>int</td>
<td></td>
<td>哪一个仪表盘</td>
</tr>
</table>
<p><strong>返回结果</strong></p>
<pre class="prettyprint lang-json">{}</pre>
</div>
@ -203,6 +194,66 @@
<span class="label label-default">POST</span>
</p>
<p><strong>返回结果</strong></p>
<pre class="prettyprint lang-json">{}</pre>
</div>
<hr>
<div class="action-item">
<h2 id="getDataSetContent"><a href="#">获取数据集下的数据表 </a></h2>
<p><strong>请求URL</strong></p>
<p>
<code>/dataease/getDataSetContent</code>
<span class="label label-default">GET</span>
<span class="label label-default">POST</span>
</p>
<p><strong>请求参数</strong> <span class="badge">application/x-www-form-urlencoded</span></p>
<table class="table table-bordered">
<tr>
<th>参数名</th>
<th>类型</th>
<th>必须</th>
<th>描述</th>
</tr>
<tr>
<td>dataset_id</td>
<td>int</td>
<td></td>
<td>数据集id</td>
</tr>
</table>
<p><strong>返回结果</strong></p>
<pre class="prettyprint lang-json">{}</pre>
</div>
<hr>
<div class="action-item">
<h2 id="saveDataSet"><a href="#">保存数据集下的数据表 </a></h2>
<p><strong>请求URL</strong></p>
<p>
<code>/dataease/saveDataSet</code>
<span class="label label-default">GET</span>
<span class="label label-default">POST</span>
</p>
<p><strong>请求参数</strong> <span class="badge">application/x-www-form-urlencoded</span></p>
<table class="table table-bordered">
<tr>
<th>参数名</th>
<th>类型</th>
<th>必须</th>
<th>描述</th>
</tr>
<tr>
<td>dataset_id</td>
<td>int</td>
<td></td>
<td>数据集id</td>
</tr>
<tr>
<td>data</td>
<td>string</td>
<td></td>
<td>保存的数据</td>
</tr>
</table>
<p><strong>返回结果</strong></p>
<pre class="prettyprint lang-json">{}</pre>
</div>
<hr>
@ -220,11 +271,13 @@
var search_source_data = [
{name: 'DataEaseController.省级路由', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#route'},
{name: 'DataEaseController.市级路由', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#routePage'},
{name: 'DataEaseController.routePage', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#routePage'},
{name: 'DataEaseController.根据当前登录人员的identity_id,获取此人员可以维护的数据集名称', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSet'},
{name: 'DataEaseController.下载指定数据集的Excel文件', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#downloadExcel'},
{name: 'DataEaseController.下载模板Excel', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#downSampleExcel'},
{name: 'DataEaseController.上传Excel文件', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#uploadExcel'},
{name: 'DataEaseController.获取数据集下的数据表', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSetContent'},
{name: 'DataEaseController.保存数据集下的数据表', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#saveDataSet'},
];

@ -46,7 +46,7 @@
省级路由
</a>
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#routePage">
市级路由
routePage
</a>
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSet">
根据当前登录人员的identity_id,获取此人员可以维护的数据集名称
@ -60,6 +60,12 @@
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#uploadExcel">
上传Excel文件
</a>
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSetContent">
获取数据集下的数据表
</a>
<a class="catalog-item" href="com_dsideal_base_DataEase_Controller_DataEaseController.html#saveDataSet">
保存数据集下的数据表
</a>
</div>
</div>
</div> </div>
@ -93,11 +99,13 @@
var search_source_data = [
{name: 'DataEaseController.省级路由', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#route'},
{name: 'DataEaseController.市级路由', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#routePage'},
{name: 'DataEaseController.routePage', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#routePage'},
{name: 'DataEaseController.根据当前登录人员的identity_id,获取此人员可以维护的数据集名称', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSet'},
{name: 'DataEaseController.下载指定数据集的Excel文件', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#downloadExcel'},
{name: 'DataEaseController.下载模板Excel', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#downSampleExcel'},
{name: 'DataEaseController.上传Excel文件', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#uploadExcel'},
{name: 'DataEaseController.获取数据集下的数据表', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#getDataSetContent'},
{name: 'DataEaseController.保存数据集下的数据表', url: 'com_dsideal_base_DataEase_Controller_DataEaseController.html#saveDataSet'},
];

@ -20,6 +20,7 @@ import com.jfinal.kit.StrKit;
import com.jfinal.plugin.activerecord.Record;
import com.jfinal.upload.UploadFile;
import io.github.yedaxia.apidocs.ApiDoc;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import java.io.File;
@ -124,7 +125,7 @@ public class DataEaseController extends Controller {
// identity_id=1 省
// identity_id=2 市
// identity_id=3 县
List<Record> list = dm.getDataSetByIdentityId(identity_id,area_name);
List<Record> list = dm.getDataSetByIdentityId(identity_id, area_name);
renderJson(CommonUtil.renderJsonForLayUI(list));
}
@ -253,4 +254,50 @@ public class DataEaseController extends Controller {
kv.set("message", "上传成功");
renderJson(kv);
}
/**
*
*
* @param dataset_id id
*/
@Before(GET.class)
@IsLoginInterface({})
@IsNumericInterface({"dataset_id"})
public void getDataSetContent(int dataset_id) {
List<Record> list = dm.getDataSetContent(dataset_id);
renderJson(CommonUtil.renderJsonForLayUI(list));
}
/**
*
*
* @param dataset_id id
* @param data
*/
@Before(POST.class)
@IsLoginInterface({})
public void saveDataSet(int dataset_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);
//父亲的区域名称
String parent_area_name = rm.getParentAreaName(area_name);
JSONArray jsonArray = JSONArray.fromObject(data);
for (Object o : jsonArray) {
JSONObject jo = (JSONObject) o;
jo.put("行政区划", area_name);
jo.put("上级行政区划", parent_area_name);
}
//保存
dm.saveDataSet(identity_id, dataset_id, area_name, jsonArray);
renderJson(CommonUtil.returnMessageJson(true, "保存成功"));
}
}

@ -7,6 +7,7 @@ import com.jfinal.kit.StrKit;
import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Record;
import com.jfinal.plugin.activerecord.SqlPara;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
@ -22,7 +23,7 @@ import java.util.stream.Collectors;
public class DataEaseModel {
//DataEase数据库名称
public static final String DB_NAME = "dataease";
public static String DB_NAME = "dataease";
/**
*
@ -37,7 +38,10 @@ public class DataEaseModel {
for (Record record : list) {
//这个数据集,当前的区域,已经填写了多少条数据
String table_name = record.getStr("table_name");
sql = "select count(1) as c from `" + table_name + "` where `行政区划`='" + area_name + "'";
sql = "select count(1) as c from `" + table_name + "`";
if (identity_id > 1) {
sql += " where `行政区划`='" + area_name + "'";
}
int cnt = Db.use(DB_NAME).queryInt(sql);
record.set("fill_count", cnt);
}
@ -364,6 +368,17 @@ public class DataEaseModel {
return Db.findFirst(sql, area_name);
}
/**
* id
*
* @param id
* @return
*/
public Record getAreaById(String id) {
String sql = "select * from t_dm_area where id=?";
return Db.findFirst(sql, id);
}
/**
* id
*
@ -534,4 +549,55 @@ public class DataEaseModel {
long rootId = getVisuallizationRoot().getLong("id");
return new HashSet<>(getChildren(rootId));
}
/**
*
*
* @param provinceName
* @return
*/
public List<Record> getProvinceArea(String provinceName) {
String provinceId = getAreaByName(provinceName).getStr("id");
String sql = "select * from ds_db.t_dm_area where province_id=? and level_id=5";
return Db.find(sql, provinceId);
}
/**
*
*
* @param dataset_id id
* @return
*/
public List<Record> getDataSetContent(int dataset_id) {
String tableName = getTableName(dataset_id);
String sql = "select * from `" + tableName + "`";
return Db.use(DB_NAME).find(sql);
}
/**
*
*
* @param dataset_id id
* @param ja json
*/
public void saveDataSet(int identity_id, int dataset_id, String area_name, JSONArray ja) {
String tableName = getTableName(dataset_id);
String sql = "delete from `" + tableName + "` where `行政区划`=?";
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 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);
}
}

@ -36,12 +36,21 @@ public class ExcelReader {
}
private String getCellValue(Cell cell) {
return switch (cell.getCellType()) {
case STRING -> cell.getStringCellValue();
case NUMERIC -> String.valueOf(cell.getNumericCellValue());
case BOOLEAN -> String.valueOf(cell.getBooleanCellValue());
case FORMULA -> cell.getCellFormula();
default -> "";
};
String res = "";
switch (cell.getCellType()) {
case STRING:
res = cell.getStringCellValue();
break;
case NUMERIC:
res = String.valueOf(cell.getNumericCellValue());
break;
case BOOLEAN:
res = String.valueOf(cell.getBooleanCellValue());
break;
case FORMULA:
res = cell.getCellFormula();
break;
}
return res;
}
}

@ -2,16 +2,13 @@ package com.dsideal.base.Tools;
import com.dsideal.base.DataEase.Model.DataEaseModel;
import com.dsideal.base.Tools.Util.LocalMysqlConnectUtil;
import com.dsideal.base.Tools.Util.SshMysqlConnectUtil;
import com.jcraft.jsch.JSchException;
import com.jfinal.plugin.activerecord.Record;
import java.io.IOException;
import java.util.List;
import com.jcraft.jsch.Session;
public class DataSetAddXzqh {
public class Step1_DataSetAddXzqh {
public static DataEaseModel dm = new DataEaseModel();

@ -5,7 +5,7 @@ import com.dsideal.base.Tools.Util.LocalMysqlConnectUtil;
import java.io.IOException;
public class DataSetInit {
public class Step2_DataSetInit {
public static DataEaseModel dm = new DataEaseModel();
public static void main(String[] args) throws IOException {

@ -0,0 +1,115 @@
package com.dsideal.base.Tools;
import com.dsideal.base.DataEase.Model.DataEaseModel;
import com.dsideal.base.Tools.Util.LocalMysqlConnectUtil;
import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Record;
import java.io.IOException;
import java.util.Arrays;
import java.util.List;
public class Step3_DataSetFakeData {
public static DataEaseModel dm = new DataEaseModel();
/**
*
*
* @param table_name
* @param area_name
*/
public static void CopyData(String table_name, String source_area_name, String area_name, String parent_name) {
String sql = "select * from `" + table_name + "` where `行政区划`='" + source_area_name + "'";
List<Record> list = Db.use(DataEaseModel.DB_NAME).find(sql);
for (Record r : list) {
r.set("行政区划", area_name);
r.set("上级行政区划", parent_name);
r.remove("id");
}
System.out.println(table_name);
Db.use(DataEaseModel.DB_NAME).batchSave(table_name, list, 100);
}
/**
*
*
* @param table_name
* @param area_name
*/
public static void deleteData(String table_name, String area_name) {
String sql = "delete from `" + table_name + "` where `行政区划`='" + area_name + "'";
Db.use(DataEaseModel.DB_NAME).update(sql);
}
public static void main(String[] args) throws IOException {
//切换至测试数据库
//DataEaseModel.DB_NAME = "dataease_huanghai";
//初始化数据库链接
LocalMysqlConnectUtil.Init();
DataEaseModel dm = new DataEaseModel();
//这几个是要保留的地名
List<String> keepArea = Arrays.asList("云南省", "昆明市", "楚雄州", "寻甸县");
//所有市州
Record rPrinvice = dm.getAreaByName("云南省");
String province_id = rPrinvice.getStr("id");
List<Record> listCity = dm.getAreaList(province_id);
int identity_id = 1;
//完善省级数据
List<Record> list = dm.getDataSetByIdentityId(identity_id, null);
for (Record record : list) {
String table_name = record.getStr("table_name");
System.out.println("正在处理数据集:" + table_name);
String sql = "update `" + table_name + "` set `行政区划`='云南省' where `行政区划` is null";
Db.use(DataEaseModel.DB_NAME).update(sql);
sql = "update `" + table_name + "` set `上级行政区划`='云南省' where `上级行政区划` is null";
Db.use(DataEaseModel.DB_NAME).update(sql);
}
//拷贝城市数据
for (Record rCity : listCity) {
//城市名称
String area_name = rCity.getStr("area_name");
//如果在保留名单中,则跳过
if (keepArea.contains(area_name)) {
continue;
}
//遍历所有市州数据集
identity_id = 2;
list = dm.getDataSetByIdentityId(identity_id, null);
for (Record record : list) {
String table_name = record.getStr("table_name");
System.out.println("正在处理数据集:" + table_name);
//检查这个行政区划,在本数据表中是不是存在过,判断办法是 列名: `行政区划`= area_name,如果存在则不作处理,否则拷贝昆明市的数据
deleteData(table_name, area_name);
CopyData(table_name, "昆明市", area_name, "云南省");
}
}
//获取所有县区
List<Record> listArea = dm.getProvinceArea("云南省");
for (Record rArea : listArea) {
//城市名称
String area_name = rArea.getStr("area_name");
String parent_id = rArea.getStr("parent_id");
//隶属哪个市州
Record parentRecord = dm.getAreaById(parent_id);
String parent_name = parentRecord.getStr("area_name");
//如果在保留名单中,则跳过
if (keepArea.contains(area_name)) {
continue;
}
//遍历所有县区数据集
identity_id = 3;
list = dm.getDataSetByIdentityId(identity_id, null);
for (Record record : list) {
String table_name = record.getStr("table_name");
System.out.println(area_name + "正在处理数据集:" + table_name);
//检查这个行政区划,在本数据表中是不是存在过,判断办法是 列名: `行政区划`= area_name,如果存在则不作处理,否则拷贝寻甸县的数据
deleteData(table_name, area_name);
CopyData(table_name, "寻甸县", area_name, parent_name);
}
}
}
}

@ -10,7 +10,7 @@ import com.jfinal.plugin.activerecord.Record;
import java.io.IOException;
import java.util.List;
public class ChangUrlLink {
public class Step4_ChangUrlLink {
public static DataEaseModel dm = new DataEaseModel();
@ -31,8 +31,8 @@ public class ChangUrlLink {
//只有http的不要
&& content.startsWith(prefix) && content.length() > prefix.length()) {
System.out.println(content);
//sql="update visualization_link_jump_info set content=? where id=?";
//Db.use(DataEaseModel.DB_NAME).update(sql, content.replace(sourceHost, targetHost), id);
sql="update visualization_link_jump_info set content=? where id=?";
Db.use(DataEaseModel.DB_NAME).update(sql, content.replace(sourceHost, targetHost), id);
}
}
}

@ -2,7 +2,7 @@ package com.dsideal.base.Tools.Util;
import com.dsideal.base.DataEase.Model.DataEaseModel;
import com.dsideal.base.Plugin.YamlProp;
import com.dsideal.base.Tools.DataSetInit;
import com.dsideal.base.Tools.Step2_DataSetInit;
import com.jfinal.kit.Prop;
import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
@ -20,7 +20,7 @@ public class LocalMysqlConnectUtil {
HikariCpPlugin masterPlugin = new HikariCpPlugin(PropKit.get("mysql.jdbcUrl"), PropKit.get("mysql.user"),
PropKit.get("mysql.password").trim(), PropKit.get("mysql.driverClassName"));
HikariCpPlugin dataEasePlugin = new HikariCpPlugin(PropKit.get("mysql.jdbcUrl").replace("ds_db", "dataease"), PropKit.get("mysql.user"),
HikariCpPlugin dataEasePlugin = new HikariCpPlugin(PropKit.get("mysql.jdbcUrl").replace("ds_db", DataEaseModel.DB_NAME), PropKit.get("mysql.user"),
PropKit.get("mysql.password").trim(), PropKit.get("mysql.driverClassName"));
masterPlugin.start();
@ -36,7 +36,7 @@ public class LocalMysqlConnectUtil {
//遍历sql目录下所有的sql文件
File sqlDir;
String basePath = DataSetInit.class.getResource("/").getPath();
String basePath = Step2_DataSetInit.class.getResource("/").getPath();
sqlDir = new File(basePath + "/Sql");
File[] sqlFiles = sqlDir.listFiles();
for (File sqlFile : sqlFiles != null ? sqlFiles : new File[0]) {

@ -1,7 +1,7 @@
package com.dsideal.base.Tools.Util;
import com.dsideal.base.DataEase.Model.DataEaseModel;
import com.dsideal.base.Tools.DataSetInit;
import com.dsideal.base.Tools.Step2_DataSetInit;
import com.dsideal.base.Util.SSHConnector;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
@ -45,7 +45,7 @@ public class SshMysqlConnectUtil {
//遍历sql目录下所有的sql文件
File sqlDir;
String basePath = DataSetInit.class.getResource("/").getPath();
String basePath = Step2_DataSetInit.class.getResource("/").getPath();
sqlDir = new File(basePath + "/Sql");
File[] sqlFiles = sqlDir.listFiles();
for (File sqlFile : sqlFiles != null ? sqlFiles : new File[0]) {

@ -34,6 +34,6 @@
<appender-ref ref="STDOUT" />
<appender-ref ref="FILE" />
</root>
<logger level="debug" additivity="false">
<logger level="debug" additivity="false" name="com.dsideal">
</logger>
</configuration>
Loading…
Cancel
Save