huanghai
/
YunNanDsBase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

'commit'

Browse Source
main
黄海 7 months ago
parent bd7e971907
commit 250d693845
2 changed files with 42 additions and 178 deletions
Show Stats Download Patch File Download Diff File

100
src/main/java/com/dsideal/base/DataEase/Util/SyncCityScreen.java
Unescape View File

@ -53,7 +53,7 @@ public class SyncCityScreen {
public static DataEaseModel dm = new DataEaseModel();
public static void clear(String dataVisualizationName){
public static void clear(String dataVisualizationName) {
//一、先删除后插入保持健康:保留：【云南省教育决策支持系统【市州】】，删除掉云南省教育决策支持系统【市州】+昆明市，云南省教育决策支持系统【市州】+楚雄州等数据
String sql = "select * from data_visualization_info where name like '%" + dataVisualizationName + "%' and name <>'" + dataVisualizationName + "'";
List<Record> toDelList = Db.use(DataEaseModel.DB_NAME).find(sql);
@ -95,6 +95,7 @@ public class SyncCityScreen {
}
System.out.println("成功删除大屏数据" + toDelList.size() + "条~");
}
/**
* 同步【云南省教育决策支持系统【市州】】
*
@ -111,8 +112,8 @@ public class SyncCityScreen {
sql = "select * from core_chart_view where scene_id=?";
List<Record> motherChartList = Db.use(DataEaseModel.DB_NAME).find(sql, motherId);
//母屏共享链接
// sql = "select * from xpack_share where resource_id=?";
// Record motherShareRecord = Db.use(DataEaseModel.DB_NAME).findFirst(sql, motherId);
sql = "select * from xpack_share where resource_id=?";
Record motherShareRecord = Db.use(DataEaseModel.DB_NAME).findFirst(sql, motherId);
//母屏的可视化资源表
sql = "select * from core_opt_recent where resource_id=?";
Record motherOptRecord = Db.use(DataEaseModel.DB_NAME).findFirst(sql, motherId);
@ -121,17 +122,9 @@ public class SyncCityScreen {
sql = "select * from visualization_link_jump where source_dv_id=?";
List<Record> motherLinkJumpList = Db.use(DataEaseModel.DB_NAME).find(sql, motherId);
//母屏的linkJumpInfo
// sql = "select * from visualization_link_jump_info where target_dv_id=?";
// List<Record> motherLinkJumpInfoList = Db.use(DataEaseModel.DB_NAME).find(sql, motherId);
//母屏的外部参数关联关系表
// sql = "select * from visualization_outer_params where visualization_id=?";
// List<Record> motheRouterParamsList = Db.use(DataEaseModel.DB_NAME).find(sql, motherId);
sql = "select * from visualization_link_jump_info where target_dv_id=?";
List<Record> motherLinkJumpInfoList = Db.use(DataEaseModel.DB_NAME).find(sql, motherId);
//跳转目标仪表板图表字段配置表
// sql = "select * from visualization_link_jump_target_view_info where link_jump_info_id in (" +
// "select id from visualization_link_jump_info where target_dv_id=?)";
// List<Record> motherLinkJumpTargetViewInfo = Db.use(DataEaseModel.DB_NAME).find(sql, motherId);
//2、需要哪16个城市
for (String cityName : dm.getCityNameList()) {
//（1）复制16个大屏
@ -143,16 +136,36 @@ public class SyncCityScreen {
// (2) 复制16个大屏的细节表
List<Record> writeList = new ArrayList<>();
Map<Long, Long> mcMap = new HashMap<>();
for (Record rMotherChart : motherChartList) {
Record rCityChart = new Record().setColumns(rMotherChart);//克隆出来
//修改大屏ID
rCityChart.set("id", getSnowId());
rCityChart.set("scene_id", bigScreenId);
writeList.add(rCityChart);
//保存母屏的组件IDS 与复制品组件IDS之间的对应关系
long motherChartId = rMotherChart.getLong("id");
mcMap.put(motherChartId, rCityChart.getLong("id"));
}
//批量保存
Db.use(DataEaseModel.DB_NAME).batchSave("core_chart_view", writeList, 100);
//回头修改一下主表
sql = "select component_data from data_visualization_info where id=?";
Record rChild = Db.use(DataEaseModel.DB_NAME).findFirst(sql, bigScreenId);
String component_data = rChild.getStr("component_data");
//遍历map
for (Map.Entry<Long, Long> entry : mcMap.entrySet()) {
Long key = entry.getKey();
Long value = entry.getValue();
component_data = component_data.replace(key.toString(), value.toString());
}
// 更新回去
sql = "update data_visualization_info set component_data=? where id=?";
Db.use(DataEaseModel.DB_NAME).update(sql, component_data, bigScreenId);
// (3) 修改地图中城市
List<Record> list = dm.getMap(bigScreenId);
//core_chart_view表
@ -175,11 +188,11 @@ public class SyncCityScreen {
}
// (4) 发布共享链接
// Record shareRecord = new Record().setColumns(motherShareRecord);
// shareRecord.set("resource_id", bigScreenId);
// shareRecord.set("id", getSnowId());
// shareRecord.set("uuid", randomString(8));//大小写字母和数字组合，长度为8
// Db.use(DataEaseModel.DB_NAME).save("xpack_share", "id", shareRecord);
Record shareRecord = new Record().setColumns(motherShareRecord);
shareRecord.set("resource_id", bigScreenId);
shareRecord.set("id", getSnowId());
shareRecord.set("uuid", randomString(8));//大小写字母和数字组合，长度为8
Db.use(DataEaseModel.DB_NAME).save("xpack_share", "id", shareRecord);
// (5) 插入可视化资源表
Record optRecord = new Record().setColumns(motherOptRecord);
@ -195,48 +208,19 @@ public class SyncCityScreen {
rCityLinkJump.set("source_dv_id", bigScreenId);
Db.use(DataEaseModel.DB_NAME).save("visualization_link_jump", "id", rCityLinkJump);
}
// (7) 插入跳转配置信息表
// Map<Integer, Long> map = new HashMap<>();
// int idx = 0;
// for (Record rMotherLinkJumpInfo : motherLinkJumpInfoList) {
// idx++;
// Record rCityLinkJumpInfo = new Record().setColumns(rMotherLinkJumpInfo);//克隆出来
// rCityLinkJumpInfo.set("id", getSnowId());
// map.put(idx, rCityLinkJumpInfo.getLong("id"));
// rCityLinkJumpInfo.set("target_dv_id", bigScreenId);
// Db.use(DataEaseModel.DB_NAME).save("visualization_link_jump_info", "id", rCityLinkJumpInfo);
// }
//TODO 外部参数比较复杂
/*
select * from visualization_outer_params where visualization_id=1036286881547030528;
*/
//(8) 跳转目标仪表板图表字段配置表：visualization_link_jump_info
// idx = 0;
// for (Record record : motherLinkJumpTargetViewInfo) {
// idx++;
// Record rCityLinkJumpTargetViewInfo = new Record().setColumns(record);//克隆出来
// rCityLinkJumpTargetViewInfo.set("target_id", getSnowId());
// rCityLinkJumpTargetViewInfo.set("link_jump_info_id", map.get(idx));
// Db.use(DataEaseModel.DB_NAME).save(
// "visualization_link_jump_target_view_info", "target_id", rCityLinkJumpTargetViewInfo);
// }
System.out.println("完成" + cityName + "的数据填充~");
break;
}
// //查询出每个城市的共享链接
// for (String cityName : dm.getCityNameList()) {
// String screenName = dataVisualizationName + cityName;
// sql = "select * from data_visualization_info where name =?";
// Record record = Db.use(DataEaseModel.DB_NAME).findFirst(sql, screenName);
// long id = record.getLong("id");
// sql = "select * from xpack_share where resource_id=?";
// Record shareRecord = Db.use(DataEaseModel.DB_NAME).findFirst(sql, id);
// System.out.println(cityName + "的共享链接：" + shareRecord.getStr("uuid"));
// }
//查询出每个城市的共享链接
for (String cityName : dm.getCityNameList()) {
String screenName = dataVisualizationName + cityName;
sql = "select * from data_visualization_info where name =?";
Record record = Db.use(DataEaseModel.DB_NAME).findFirst(sql, screenName);
long id = record.getLong("id");
sql = "select * from xpack_share where resource_id=?";
Record shareRecord = Db.use(DataEaseModel.DB_NAME).findFirst(sql, id);
System.out.println(cityName + "的共享链接：" + shareRecord.getStr("uuid"));
}
System.out.println("生成完毕");
}
@ -245,6 +229,6 @@ public class SyncCityScreen {
//获取数据可视化名称
String dataVisualizationName = LocalMysqlConnectUtil.PropKit.get("dataEase.dataVisualizationName");
clear(dataVisualizationName);
//SyncCityScreen(dataVisualizationName);
SyncCityScreen(dataVisualizationName);
}
}

120
src/main/java/com/dsideal/base/DataEase/Util/SyncCityScreenNew.java
Unescape View File

@ -1,120 +0,0 @@
package com.dsideal.base.DataEase.Util;
import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
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.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class SyncCityScreenNew {
/*
开启数据库SQL执行日志
SHOW VARIABLES LIKE 'general_log%';
SET GLOBAL general_log = 'ON';
SET GLOBAL general_log = 'OFF';
*/
/**
* 利用雪花算法获取唯一ID
*
* @return
*/
public static long getSnowId() throws InterruptedException {
//雪花算法生成唯一ID
Snowflake snowflake = IdUtil.createSnowflake(1, 1);
Thread.sleep(2);
return snowflake.nextId();
}
public static DataEaseModel dm = new DataEaseModel();
/**
* @param dataVisualizationName
* @throws InterruptedException
*/
public static void SyncScreen(String dataVisualizationName) throws InterruptedException {
//1、获取母屏数据
String sql = "select * from data_visualization_info where name =?";
Record motherRecord = Db.use(DataEaseModel.DB_NAME).findFirst(sql, dataVisualizationName);
long motherId = motherRecord.getLong("id");
//母屏细节表
sql = "select * from core_chart_view where scene_id=?";
List<Record> motherChartList = Db.use(DataEaseModel.DB_NAME).find(sql, motherId);
//母屏的可视化资源表
sql = "select * from core_opt_recent where resource_id=?";
Record motherOptRecord = Db.use(DataEaseModel.DB_NAME).findFirst(sql, motherId);
//母屏的linkJump
sql = "select * from visualization_link_jump where source_dv_id=?";
List<Record> motherLinkJumpList = Db.use(DataEaseModel.DB_NAME).find(sql, motherId);
//（1）复制大屏
Record cityRecord = new Record().setColumns(motherRecord);//复制record对象
cityRecord.set("name", dataVisualizationName + "_copy");
long bigScreenId = getSnowId();
cityRecord.set("id", bigScreenId);
Db.use(DataEaseModel.DB_NAME).save("data_visualization_info", "id", cityRecord);
Map<Long, Long> mcMap = new HashMap<>();
// (2) 复制大屏的细节表
List<Record> writeList = new ArrayList<>();
for (Record rMotherChart : motherChartList) {
long motherChartId = rMotherChart.getLong("id");
Record rCityChart = new Record().setColumns(rMotherChart);//克隆出来
//修改大屏ID
rCityChart.set("id", getSnowId());
rCityChart.set("scene_id", bigScreenId);
writeList.add(rCityChart);
//保存母屏的组件IDS 与复制品组件IDS之间的对应关系
mcMap.put(motherChartId, rCityChart.getLong("id"));
}
//批量保存
Db.use(DataEaseModel.DB_NAME).batchSave("core_chart_view", writeList, 100);//需要修改
//回头修改一下主表
sql = "select component_data from data_visualization_info where id=?";
Record rChild = Db.use(DataEaseModel.DB_NAME).findFirst(sql, bigScreenId);
String component_data = rChild.getStr("component_data");
//遍历map
for (Map.Entry<Long, Long> entry : mcMap.entrySet()) {
Long key = entry.getKey();
Long value = entry.getValue();
component_data = component_data.replace(key.toString(), value.toString());
}
// 更新回去
sql = "update data_visualization_info set component_data=? where id=?";
Db.use(DataEaseModel.DB_NAME).update(sql, component_data, bigScreenId);
// (5) 插入可视化资源表
Record optRecord = new Record().setColumns(motherOptRecord);
optRecord.set("resource_id", bigScreenId);
optRecord.set("id", getSnowId());
Db.use(DataEaseModel.DB_NAME).save("core_opt_recent", "id", optRecord);
// (6) 插入跳转配置表
for (Record rMotherLinkJump : motherLinkJumpList) {
Record rCityLinkJump = new Record().setColumns(rMotherLinkJump);//克隆出来
rCityLinkJump.set("id", getSnowId());
rCityLinkJump.set("source_dv_id", bigScreenId);
Db.use(DataEaseModel.DB_NAME).save("visualization_link_jump", "id", rCityLinkJump);
}
System.out.println("生成完毕");
}
public static void main(String[] args) throws InterruptedException {
LocalMysqlConnectUtil.Init();
//获取数据可视化名称
String dataVisualizationName = "黄海测试的气泡地图";
SyncScreen(dataVisualizationName);
}
}
Write Preview
Loading…
Cancel
Save