提交 35c98023 authored 作者: wangjiahao's avatar wangjiahao

Merge remote-tracking branch 'origin/dev' into fix_panel_edit_attr-auto-save

# Conflicts: # frontend/src/components/canvas/components/RectangleAttr.vue # frontend/src/views/Tinymce/RectangleAttr.vue # frontend/src/views/system/task/TaskRecord.vue # frontend/src/views/system/task/dataset.vue
...@@ -16,6 +16,7 @@ ...@@ -16,6 +16,7 @@
SELECT dataset_table_task_log.*, dataset_table_task.name SELECT dataset_table_task_log.*, dataset_table_task.name
FROM dataset_table_task_log FROM dataset_table_task_log
LEFT JOIN dataset_table_task ON dataset_table_task_log.task_id = dataset_table_task.id LEFT JOIN dataset_table_task ON dataset_table_task_log.task_id = dataset_table_task.id
LEFT JOIN dataset_table ON dataset_table_task_log.table_id = dataset_table.id
<if test="_parameter != null"> <if test="_parameter != null">
<include refid="io.dataease.base.mapper.ext.query.GridSql.gridCondition" /> <include refid="io.dataease.base.mapper.ext.query.GridSql.gridCondition" />
</if> </if>
......
package io.dataease.commons.constants; package io.dataease.commons.constants;
public enum TaskStatus { public enum TaskStatus {
Underway, Stopped Underway, Stopped, Pending, Exec
} }
...@@ -11,9 +11,9 @@ public class MysqlConfigration extends JdbcDTO { ...@@ -11,9 +11,9 @@ public class MysqlConfigration extends JdbcDTO {
public String getJdbc() { public String getJdbc() {
// 连接参数先写死,后边要把编码、时区等参数放到数据源的设置中 // 连接参数先写死,后边要把编码、时区等参数放到数据源的设置中
return "jdbc:mysql://HOSTNAME:PORT/DATABASE?characterEncoding=UTF-8" return "jdbc:mysql://HOSTNAME:PORT/DATABASE?characterEncoding=UTF-8&connectTimeout=5000&socketTimeout=5000"
.replace("HOSTNAME", getHost()) .replace("HOSTNAME", getHost())
.replace("PORT", getPort().toString()) .replace("PORT", getPort().toString())
.replace("DATABASE", getDataBase()); .replace("DATABASE", getDataBase());
} }
} }
\ No newline at end of file
...@@ -401,6 +401,7 @@ public class JdbcProvider extends DatasourceProvider { ...@@ -401,6 +401,7 @@ public class JdbcProvider extends DatasourceProvider {
String driver = null; String driver = null;
String jdbcurl = null; String jdbcurl = null;
DatasourceTypes datasourceType = DatasourceTypes.valueOf(datasourceRequest.getDatasource().getType()); DatasourceTypes datasourceType = DatasourceTypes.valueOf(datasourceRequest.getDatasource().getType());
Properties props = new Properties();
switch (datasourceType) { switch (datasourceType) {
case mysql: case mysql:
MysqlConfigration mysqlConfigration = new Gson().fromJson(datasourceRequest.getDatasource().getConfiguration(), MysqlConfigration.class); MysqlConfigration mysqlConfigration = new Gson().fromJson(datasourceRequest.getDatasource().getConfiguration(), MysqlConfigration.class);
...@@ -429,13 +430,14 @@ public class JdbcProvider extends DatasourceProvider { ...@@ -429,13 +430,14 @@ public class JdbcProvider extends DatasourceProvider {
password = oracleConfigration.getPassword(); password = oracleConfigration.getPassword();
driver = oracleConfigration.getDriver(); driver = oracleConfigration.getDriver();
jdbcurl = oracleConfigration.getJdbc(); jdbcurl = oracleConfigration.getJdbc();
props.put( "oracle.net.CONNECT_TIMEOUT" , "5000") ;
props.put( "oracle.jdbc.ReadTimeout" , "5000" ) ;
break; break;
default: default:
break; break;
} }
Class.forName(driver); Class.forName(driver);
Properties props = new Properties();
props.setProperty("user", username); props.setProperty("user", username);
if (StringUtils.isNotBlank(password)) { if (StringUtils.isNotBlank(password)) {
props.setProperty("password", password); props.setProperty("password", password);
......
...@@ -120,6 +120,13 @@ public class DatasourceService { ...@@ -120,6 +120,13 @@ public class DatasourceService {
datasourceProvider.checkStatus(datasourceRequest); datasourceProvider.checkStatus(datasourceRequest);
} }
public void validate(String datasourceId) throws Exception {
if(StringUtils.isEmpty(datasourceId)){
return;
}
Datasource datasource = datasourceMapper.selectByPrimaryKey(datasourceId);
validate(datasource);
}
public List<String> getSchema(Datasource datasource) throws Exception { public List<String> getSchema(Datasource datasource) throws Exception {
DatasourceProvider datasourceProvider = ProviderFactory.getProvider(datasource.getType()); DatasourceProvider datasourceProvider = ProviderFactory.getProvider(datasource.getType());
DatasourceRequest datasourceRequest = new DatasourceRequest(); DatasourceRequest datasourceRequest = new DatasourceRequest();
...@@ -132,6 +139,7 @@ public class DatasourceService { ...@@ -132,6 +139,7 @@ public class DatasourceService {
DatasourceProvider datasourceProvider = ProviderFactory.getProvider(ds.getType()); DatasourceProvider datasourceProvider = ProviderFactory.getProvider(ds.getType());
DatasourceRequest datasourceRequest = new DatasourceRequest(); DatasourceRequest datasourceRequest = new DatasourceRequest();
datasourceRequest.setDatasource(ds); datasourceRequest.setDatasource(ds);
datasourceProvider.checkStatus(datasourceRequest);
List<String> tables = datasourceProvider.getTables(datasourceRequest); List<String> tables = datasourceProvider.getTables(datasourceRequest);
// 获取当前数据源下的db类型数据集 // 获取当前数据源下的db类型数据集
......
...@@ -15,4 +15,5 @@ public class DataSetTaskDTO extends DatasetTableTask { ...@@ -15,4 +15,5 @@ public class DataSetTaskDTO extends DatasetTableTask {
private String datasetName; private String datasetName;
private Long nextExecTime; private Long nextExecTime;
private String taskStatus; private String taskStatus;
private String msg;
} }
...@@ -180,10 +180,10 @@ public class ChartViewService { ...@@ -180,10 +180,10 @@ public class ChartViewService {
} }
} }
// 获取数据集 // 获取数据集,需校验权限
DatasetTable table = dataSetTableService.get(view.getTableId()); DatasetTable table = dataSetTableService.get(view.getTableId());
if (ObjectUtils.isEmpty(table)) { if (ObjectUtils.isEmpty(table)) {
throw new RuntimeException(Translator.get("i18n_dataset_delete")); throw new RuntimeException(Translator.get("i18n_dataset_delete_or_no_permission"));
} }
// 判断连接方式,直连或者定时抽取 table.mode // 判断连接方式,直连或者定时抽取 table.mode
DatasourceRequest datasourceRequest = new DatasourceRequest(); DatasourceRequest datasourceRequest = new DatasourceRequest();
......
...@@ -299,6 +299,12 @@ public class DataSetTableService { ...@@ -299,6 +299,12 @@ public class DataSetTableService {
datasetTableField.setTableId(dataSetTableRequest.getId()); datasetTableField.setTableId(dataSetTableRequest.getId());
datasetTableField.setChecked(Boolean.TRUE); datasetTableField.setChecked(Boolean.TRUE);
List<DatasetTableField> fields = dataSetTableFieldsService.list(datasetTableField); List<DatasetTableField> fields = dataSetTableFieldsService.list(datasetTableField);
if (CollectionUtils.isEmpty(fields)) {
map.put("fields", fields);
map.put("data", new ArrayList<>());
map.put("page", new DataSetPreviewPage());
return map;
}
String[] fieldArray = fields.stream().map(DatasetTableField::getDataeaseName).toArray(String[]::new); String[] fieldArray = fields.stream().map(DatasetTableField::getDataeaseName).toArray(String[]::new);
DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class); DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class);
...@@ -1392,9 +1398,8 @@ public class DataSetTableService { ...@@ -1392,9 +1398,8 @@ public class DataSetTableService {
List<String> taskIds = datasetTableTaskLogMapper.selectByExample(datasetTableTaskLogExample).stream().map(DatasetTableTaskLog::getTaskId).collect(Collectors.toList()); List<String> taskIds = datasetTableTaskLogMapper.selectByExample(datasetTableTaskLogExample).stream().map(DatasetTableTaskLog::getTaskId).collect(Collectors.toList());
datasetTableTaskLogMapper.updateByExampleSelective(datasetTableTaskLog, datasetTableTaskLogExample); datasetTableTaskLogMapper.updateByExampleSelective(datasetTableTaskLog, datasetTableTaskLogExample);
DatasetTableTask datasetTableTask = new DatasetTableTask(); dataSetTableTaskService.updateTaskStatus(taskIds, JobStatus.Error);
datasetTableTask.setLastExecStatus(JobStatus.Error.name()); //TODO check task status
dataSetTableTaskService.update(taskIds, datasetTableTask);
for (DatasetTable jobStoppeddDatasetTable : jobStoppeddDatasetTables) { for (DatasetTable jobStoppeddDatasetTable : jobStoppeddDatasetTables) {
extractDataService.deleteFile("all_scope", jobStoppeddDatasetTable.getId()); extractDataService.deleteFile("all_scope", jobStoppeddDatasetTable.getId());
......
...@@ -95,6 +95,7 @@ public class DataSetTableTaskLogService { ...@@ -95,6 +95,7 @@ public class DataSetTableTaskLogService {
if(CollectionUtils.isNotEmpty(datasetTableTaskLogs)){ if(CollectionUtils.isNotEmpty(datasetTableTaskLogs)){
dataSetTaskDTO.setLastExecStatus(datasetTableTaskLogs.get(0).getStatus()); dataSetTaskDTO.setLastExecStatus(datasetTableTaskLogs.get(0).getStatus());
dataSetTaskDTO.setLastExecTime(datasetTableTaskLogs.get(0).getCreateTime()); dataSetTaskDTO.setLastExecTime(datasetTableTaskLogs.get(0).getCreateTime());
dataSetTaskDTO.setMsg(datasetTableTaskLogs.get(0).getInfo());
} }
return dataSetTaskDTO; return dataSetTaskDTO;
} }
......
...@@ -5,6 +5,7 @@ import io.dataease.base.domain.*; ...@@ -5,6 +5,7 @@ import io.dataease.base.domain.*;
import io.dataease.base.mapper.DatasetTableMapper; import io.dataease.base.mapper.DatasetTableMapper;
import io.dataease.base.mapper.DatasetTableTaskMapper; import io.dataease.base.mapper.DatasetTableTaskMapper;
import io.dataease.base.mapper.ext.ExtDataSetTaskMapper; import io.dataease.base.mapper.ext.ExtDataSetTaskMapper;
import io.dataease.base.mapper.ext.UtilMapper;
import io.dataease.base.mapper.ext.query.GridExample; import io.dataease.base.mapper.ext.query.GridExample;
import io.dataease.commons.constants.JobStatus; import io.dataease.commons.constants.JobStatus;
import io.dataease.commons.constants.ScheduleType; import io.dataease.commons.constants.ScheduleType;
...@@ -48,12 +49,11 @@ public class DataSetTableTaskService { ...@@ -48,12 +49,11 @@ public class DataSetTableTaskService {
@Lazy @Lazy
private DataSetTableService dataSetTableService; private DataSetTableService dataSetTableService;
@Resource @Resource
private ExtractDataService extractDataService;
@Resource
private ExtDataSetTaskMapper extDataSetTaskMapper; private ExtDataSetTaskMapper extDataSetTaskMapper;
@Resource @Resource
private DatasetTableMapper datasetTableMapper; private DatasetTableMapper datasetTableMapper;
@Resource
private UtilMapper utilMapper;
public DatasetTableTask save(DataSetTaskRequest dataSetTaskRequest) throws Exception { public DatasetTableTask save(DataSetTaskRequest dataSetTaskRequest) throws Exception {
checkName(dataSetTaskRequest); checkName(dataSetTaskRequest);
...@@ -82,22 +82,21 @@ public class DataSetTableTaskService { ...@@ -82,22 +82,21 @@ public class DataSetTableTaskService {
if (StringUtils.isEmpty(datasetTableTask.getId())) { if (StringUtils.isEmpty(datasetTableTask.getId())) {
datasetTableTask.setId(UUID.randomUUID().toString()); datasetTableTask.setId(UUID.randomUUID().toString());
datasetTableTask.setCreateTime(System.currentTimeMillis()); datasetTableTask.setCreateTime(System.currentTimeMillis());
datasetTableTask.setStatus(TaskStatus.Underway.name()); if (StringUtils.equalsIgnoreCase(datasetTableTask.getRate(), ScheduleType.SIMPLE.toString())){
datasetTableTask.setStatus(TaskStatus.Exec.name());
}else {
datasetTableTask.setStatus(TaskStatus.Underway.name());
}
datasetTableTaskMapper.insert(datasetTableTask); datasetTableTaskMapper.insert(datasetTableTask);
} else { } else {
datasetTableTaskMapper.updateByPrimaryKeySelective(datasetTableTask); datasetTableTaskMapper.updateByPrimaryKeySelective(datasetTableTask);
} }
// simple // simple
if (datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.toString()) && datasetTableTask.getStatus().equalsIgnoreCase(TaskStatus.Underway.name())) { // SIMPLE 类型,提前占位 if (datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.toString())) { // SIMPLE 类型,提前占位
execNow(datasetTableTask); execNow(datasetTableTask);
scheduleService.addSchedule(datasetTableTask);
}
//cron、simple_cron
if(!datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.name())){
scheduleService.addSchedule(datasetTableTask);
} }
scheduleService.addSchedule(datasetTableTask);
return datasetTableTask; return datasetTableTask;
} }
...@@ -122,6 +121,7 @@ public class DataSetTableTaskService { ...@@ -122,6 +121,7 @@ public class DataSetTableTaskService {
if(!existSyncTask){ if(!existSyncTask){
datasetTableTask.setLastExecTime(System.currentTimeMillis()); datasetTableTask.setLastExecTime(System.currentTimeMillis());
datasetTableTask.setLastExecStatus(JobStatus.Underway.name()); datasetTableTask.setLastExecStatus(JobStatus.Underway.name());
datasetTableTask.setStatus(TaskStatus.Exec.name());
update(datasetTableTask); update(datasetTableTask);
DatasetTableTaskLog datasetTableTaskLog = new DatasetTableTaskLog(); DatasetTableTaskLog datasetTableTaskLog = new DatasetTableTaskLog();
datasetTableTaskLog.setTableId(datasetTableTask.getTableId()); datasetTableTaskLog.setTableId(datasetTableTask.getTableId());
...@@ -159,17 +159,36 @@ public class DataSetTableTaskService { ...@@ -159,17 +159,36 @@ public class DataSetTableTaskService {
return datasetTableTaskMapper.selectByPrimaryKey(id); return datasetTableTaskMapper.selectByPrimaryKey(id);
} }
public void update(DatasetTableTask datasetTableTask) { public void updateTaskStatus(List<String> taskIds, JobStatus lastExecStatus) {
datasetTableTaskMapper.updateByPrimaryKeySelective(datasetTableTask);
}
public void update(List<String> taskIds, DatasetTableTask datasetTableTask) {
if (CollectionUtils.isEmpty(taskIds)){ if (CollectionUtils.isEmpty(taskIds)){
return; return;
} }
DatasetTableTaskExample example = new DatasetTableTaskExample(); DatasetTableTaskExample example = new DatasetTableTaskExample();
example.createCriteria().andIdIn(taskIds); example.createCriteria().andIdIn(taskIds);
datasetTableTaskMapper.updateByExampleSelective(datasetTableTask, example); List<DatasetTableTask> datasetTableTasks = datasetTableTaskMapper.selectByExample(example);
for (DatasetTableTask tableTask : datasetTableTasks) {
updateTaskStatus(tableTask, lastExecStatus);
}
}
public void updateTaskStatus(DatasetTableTask datasetTableTask, JobStatus lastExecStatus){
datasetTableTask.setLastExecStatus(lastExecStatus.name());
if(datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.name())){
datasetTableTask.setStatus(TaskStatus.Stopped.name());
}else {
if(StringUtils.isNotEmpty(datasetTableTask.getEnd()) && datasetTableTask.getEnd().equalsIgnoreCase("1")){
if(utilMapper.currentTimestamp() > datasetTableTask.getEndTime()){
datasetTableTask.setStatus(TaskStatus.Stopped.name());
}
}else {
datasetTableTask.setStatus(TaskStatus.Underway.name());
}
}
update(datasetTableTask);
}
public void update(DatasetTableTask datasetTableTask) {
datasetTableTaskMapper.updateByPrimaryKeySelective(datasetTableTask);
} }
public List<DatasetTableTask> list(DatasetTableTask datasetTableTask) { public List<DatasetTableTask> list(DatasetTableTask datasetTableTask) {
...@@ -217,12 +236,11 @@ public class DataSetTableTaskService { ...@@ -217,12 +236,11 @@ public class DataSetTableTaskService {
public void execTask(DatasetTableTask datasetTableTask) throws Exception{ public void execTask(DatasetTableTask datasetTableTask) throws Exception{
execNow(datasetTableTask); execNow(datasetTableTask);
if(datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.CRON.toString())){ if(!datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.toString())){
scheduleService.fireNow(datasetTableTask); scheduleService.fireNow(datasetTableTask);
} }
if(datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.toString())){ // if(datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.toString())){
scheduleService.addSchedule(datasetTableTask); // scheduleService.addSchedule(datasetTableTask);
} // }
} }
} }
...@@ -56,9 +56,9 @@ BEGIN; ...@@ -56,9 +56,9 @@ BEGIN;
INSERT INTO `sys_msg_type` VALUES (1, 0, 'i18n_msg_type_panel_share', 'panel', 'to-msg-share'); INSERT INTO `sys_msg_type` VALUES (1, 0, 'i18n_msg_type_panel_share', 'panel', 'to-msg-share');
INSERT INTO `sys_msg_type` VALUES (2, 1, 'i18n_msg_type_panel_share', 'panel', 'to-msg-share'); INSERT INTO `sys_msg_type` VALUES (2, 1, 'i18n_msg_type_panel_share', 'panel', 'to-msg-share');
INSERT INTO `sys_msg_type` VALUES (3, 1, 'i18n_msg_type_panel_share_cacnel', 'panel', 'to-msg-share'); INSERT INTO `sys_msg_type` VALUES (3, 1, 'i18n_msg_type_panel_share_cacnel', 'panel', 'to-msg-share');
INSERT INTO `sys_msg_type` VALUES (4, 0, 'i18n_msg_type_dataset_sync', 'dataset', 'to-msg-dataset'); INSERT INTO `sys_msg_type` VALUES (4, 0, 'i18n_msg_type_dataset_sync', 'sys-task-dataset', 'to-msg-dataset');
INSERT INTO `sys_msg_type` VALUES (5, 4, 'i18n_msg_type_dataset_sync_success', 'dataset', 'to-msg-dataset'); INSERT INTO `sys_msg_type` VALUES (5, 4, 'i18n_msg_type_dataset_sync_success', 'sys-task-dataset', 'to-msg-dataset');
INSERT INTO `sys_msg_type` VALUES (6, 4, 'i18n_msg_type_dataset_sync_faild', 'dataset', 'to-msg-dataset'); INSERT INTO `sys_msg_type` VALUES (6, 4, 'i18n_msg_type_dataset_sync_faild', 'sys-task-dataset', 'to-msg-dataset');
COMMIT; COMMIT;
-- ---------------------------- -- ----------------------------
......
INSERT INTO `sys_menu` VALUES (57, 1, 3, 1, '任务管理', 'sys-task', 'system/task/index', 2000, 'task', 'system-task', b'0', b'0', b'0', NULL, NULL, NULL, NULL, NULL); INSERT INTO `sys_menu` VALUES (58, 1, 0, 1, 'i18n_timed_task', 'sys-task-dataset', 'system/task/dataset', 1001, 'task', 'dataset', b'0', b'0', b'0', NULL, NULL, NULL, NULL, NULL);
INSERT INTO `sys_menu` VALUES (58, 57, 0, 1, '数据集任务', 'sys-task-dataset', 'system/task/dataset', 1, 'task', 'dataset', b'0', b'0', b'0', NULL, NULL, NULL, NULL, NULL);
ALTER TABLE `dataset_table_task` ALTER TABLE `dataset_table_task`
ADD COLUMN `last_exec_time` BIGINT(13) NULL DEFAULT NULL COMMENT '上次执行时间' AFTER `create_time`, ADD COLUMN `last_exec_time` BIGINT(13) NULL DEFAULT NULL COMMENT '上次执行时间' AFTER `create_time`,
ADD COLUMN `status` VARCHAR(50) NULL DEFAULT NULL COMMENT '任务状态' AFTER `last_exec_time`, ADD COLUMN `status` VARCHAR(50) NULL DEFAULT NULL COMMENT '任务状态' AFTER `last_exec_time`,
ADD COLUMN `last_exec_status` VARCHAR(50) NULL DEFAULT NULL COMMENT '上次执行结果' AFTER `last_exec_time`; ADD COLUMN `last_exec_status` VARCHAR(50) NULL DEFAULT NULL COMMENT '上次执行结果' AFTER `last_exec_time`;
update dataset_table_task set status='Underway';
update dataset_table_task set rate='SIMPLE' where rate='SIMPLE_COMPLETE'; update dataset_table_task set rate='SIMPLE' where rate='SIMPLE_COMPLETE';
update dataset_table_task set status='Stopped' where rate='SIMPLE';
update dataset_table_task set status='Underway' where rate='CRON';
UPDATE dataset_table_task
SET dataset_table_task.last_exec_time = (SELECT dataset_table_task_log.start_time FROM dataset_table_task_log WHERE dataset_table_task_log.task_id = dataset_table_task.id limit 1);
UPDATE dataset_table_task
SET dataset_table_task.last_exec_status = (SELECT dataset_table_task_log.status FROM dataset_table_task_log WHERE dataset_table_task_log.task_id = dataset_table_task.id limit 1);
ALTER TABLE `dataset_table_task_log` ADD COLUMN `trigger_type` VARCHAR(45) NULL AFTER `create_time`; ALTER TABLE `dataset_table_task_log` ADD COLUMN `trigger_type` VARCHAR(45) NULL AFTER `create_time`;
ALTER TABLE `dataset_table_task` ADD COLUMN `extra_data` LONGTEXT NULL AFTER `last_exec_status`;
update dataset_table_task_log set trigger_type='Cron'; update dataset_table_task_log set trigger_type='Cron';
ALTER TABLE `dataset_table_task` ADD COLUMN `extra_data` LONGTEXT NULL AFTER `last_exec_status`;
...@@ -251,7 +251,7 @@ i18n_datasource_not_allow_delete_msg= datasets are using this data source and ca ...@@ -251,7 +251,7 @@ i18n_datasource_not_allow_delete_msg= datasets are using this data source and ca
i18n_task_name_repeat=Name is used in same data set i18n_task_name_repeat=Name is used in same data set
i18n_id_or_pwd_error=Invalid ID or password i18n_id_or_pwd_error=Invalid ID or password
i18n_datasource_delete=Data source is delete i18n_datasource_delete=Data source is delete
i18n_dataset_delete=Data set is delete i18n_dataset_delete_or_no_permission=Data set is delete or no permission
i18n_chart_delete=Chart is delete i18n_chart_delete=Chart is delete
i18n_not_exec_add_sync=There is no completed synchronization task. Incremental synchronization cannot be performed i18n_not_exec_add_sync=There is no completed synchronization task. Incremental synchronization cannot be performed
i18n_excel_header_empty=Excel first row can not empty i18n_excel_header_empty=Excel first row can not empty
...@@ -273,4 +273,5 @@ i18n_msg_type_dataset_sync=Data set synchronization ...@@ -273,4 +273,5 @@ i18n_msg_type_dataset_sync=Data set synchronization
i18n_msg_type_dataset_sync_success=Dataset synchronization successful i18n_msg_type_dataset_sync_success=Dataset synchronization successful
i18n_msg_type_dataset_sync_faild=Dataset synchronization failed i18n_msg_type_dataset_sync_faild=Dataset synchronization failed
i18n_data_not_sync=Please sync data first i18n_data_not_sync=Please sync data first
i18n_excel_colume_change=The column name of Excel is inconsistent with the original data set i18n_excel_colume_change=The column name of Excel is inconsistent with the original data set
\ No newline at end of file i18n_timed_task=Timed Task
\ No newline at end of file
...@@ -250,7 +250,7 @@ i18n_datasource_not_allow_delete_msg= 个数据集正在使用此数据源,无 ...@@ -250,7 +250,7 @@ i18n_datasource_not_allow_delete_msg= 个数据集正在使用此数据源,无
i18n_task_name_repeat=同一数据集下任务名称已被使用 i18n_task_name_repeat=同一数据集下任务名称已被使用
i18n_id_or_pwd_error=无效的ID或密码 i18n_id_or_pwd_error=无效的ID或密码
i18n_datasource_delete=当前用到的数据源已被删除 i18n_datasource_delete=当前用到的数据源已被删除
i18n_dataset_delete=当前用到的数据集已被删除 i18n_dataset_delete_or_no_permission=当前用到的数据集没有权限或已被删除
i18n_chart_delete=当前用到的视图已被删除 i18n_chart_delete=当前用到的视图已被删除
i18n_not_exec_add_sync=没有已完成的同步任务,无法进行增量同步 i18n_not_exec_add_sync=没有已完成的同步任务,无法进行增量同步
i18n_excel_header_empty=Excel第一行为空 i18n_excel_header_empty=Excel第一行为空
...@@ -273,3 +273,4 @@ i18n_msg_type_dataset_sync_success=数据集同步成功 ...@@ -273,3 +273,4 @@ i18n_msg_type_dataset_sync_success=数据集同步成功
i18n_msg_type_dataset_sync_faild=数据集同步失败 i18n_msg_type_dataset_sync_faild=数据集同步失败
i18n_data_not_sync=请先完成数据同步 i18n_data_not_sync=请先完成数据同步
i18n_excel_colume_change=Excel的列名与原数据集不一致 i18n_excel_colume_change=Excel的列名与原数据集不一致
i18n_timed_task=定时任务
\ No newline at end of file
...@@ -253,7 +253,7 @@ i18n_datasource_not_allow_delete_msg= 個數據集正在使用此數據源,無 ...@@ -253,7 +253,7 @@ i18n_datasource_not_allow_delete_msg= 個數據集正在使用此數據源,無
i18n_task_name_repeat=同一數據集下任務名稱已被使用 i18n_task_name_repeat=同一數據集下任務名稱已被使用
i18n_id_or_pwd_error=無效的ID或密碼 i18n_id_or_pwd_error=無效的ID或密碼
i18n_datasource_delete=當前用到的數據源已被刪除 i18n_datasource_delete=當前用到的數據源已被刪除
i18n_dataset_delete=當前用到的數據集已被刪除 i18n_dataset_delete_or_no_permission=當前用到的數據集沒有權限或已被刪除
i18n_chart_delete=當前用到的視圖已被刪除 i18n_chart_delete=當前用到的視圖已被刪除
i18n_not_exec_add_sync=沒有已經完成的同步任務,無法進行增量同步 i18n_not_exec_add_sync=沒有已經完成的同步任務,無法進行增量同步
i18n_excel_header_empty=Excel第一行為空 i18n_excel_header_empty=Excel第一行為空
...@@ -275,4 +275,5 @@ i18n_msg_type_dataset_sync=數據集同步 ...@@ -275,4 +275,5 @@ i18n_msg_type_dataset_sync=數據集同步
i18n_msg_type_dataset_sync_success=數據集同步成功 i18n_msg_type_dataset_sync_success=數據集同步成功
i18n_msg_type_dataset_sync_faild=數據集同步失敗 i18n_msg_type_dataset_sync_faild=數據集同步失敗
i18n_data_not_sync=請先完成數據同步 i18n_data_not_sync=請先完成數據同步
i18n_excel_colume_change=Excel的列名與原數據集不一致 i18n_excel_colume_change=Excel的列名與原數據集不一致
\ No newline at end of file i18n_timed_task=定時任務
\ No newline at end of file
...@@ -1448,6 +1448,7 @@ export default { ...@@ -1448,6 +1448,7 @@ export default {
}, },
// 记录当前样式 // 记录当前样式
recordCurStyle() { recordCurStyle() {
debugger
const style = { const style = {
...this.defaultStyle ...this.defaultStyle
} }
...@@ -1462,6 +1463,7 @@ export default { ...@@ -1462,6 +1463,7 @@ export default {
// 记录当前样式 矩阵处理 // 记录当前样式 矩阵处理
recordMatrixCurStyle() { recordMatrixCurStyle() {
debugger
const left = Math.round(this.left / this.curCanvasScale.matrixStyleWidth) * this.curCanvasScale.matrixStyleWidth const left = Math.round(this.left / this.curCanvasScale.matrixStyleWidth) * this.curCanvasScale.matrixStyleWidth
const top = Math.round(this.top / this.curCanvasScale.matrixStyleHeight) * this.curCanvasScale.matrixStyleHeight const top = Math.round(this.top / this.curCanvasScale.matrixStyleHeight) * this.curCanvasScale.matrixStyleHeight
const width = Math.round(this.width / this.curCanvasScale.matrixStyleWidth) * this.curCanvasScale.matrixStyleWidth const width = Math.round(this.width / this.curCanvasScale.matrixStyleWidth) * this.curCanvasScale.matrixStyleWidth
......
...@@ -122,7 +122,8 @@ const list = [ ...@@ -122,7 +122,8 @@ const list = [
borderStyle: 'solid', borderStyle: 'solid',
borderWidth: 1, borderWidth: 1,
borderColor: '#000000', borderColor: '#000000',
backgroundColor: '#ffffff' backgroundColor: '#ffffff',
borderRadius: 0
} }
}, },
{ {
......
...@@ -4,10 +4,10 @@ ...@@ -4,10 +4,10 @@
ref="dateRef" ref="dateRef"
v-model="options.value" v-model="options.value"
:type="options.attrs.type" :type="options.attrs.type"
:range-separator="options.attrs.rangeSeparator" :range-separator="$t(options.attrs.rangeSeparator)"
:start-placeholder="options.attrs.startPlaceholder" :start-placeholder="$t(options.attrs.startPlaceholder)"
:end-placeholder="options.attrs.endPlaceholder" :end-placeholder="$t(options.attrs.endPlaceholder)"
:placeholder="options.attrs.placeholder" :placeholder="$t(options.attrs.placeholder)"
style="min-height: 36px;" style="min-height: 36px;"
@change="dateChange" @change="dateChange"
/> />
......
...@@ -4,7 +4,7 @@ ...@@ -4,7 +4,7 @@
v-if="options!== null && options.attrs!==null" v-if="options!== null && options.attrs!==null"
v-model="values" v-model="values"
resize="vertical" resize="vertical"
:placeholder="options.attrs.placeholder" :placeholder="$t(options.attrs.placeholder)"
@keypress.enter.native="search" @keypress.enter.native="search"
@dblclick="setEdit" @dblclick="setEdit"
> >
......
...@@ -3,11 +3,11 @@ ...@@ -3,11 +3,11 @@
<el-form v-if="options!== null && options.attrs!==null" ref="form" :model="form" :rules="rules"> <el-form v-if="options!== null && options.attrs!==null" ref="form" :model="form" :rules="rules">
<div class="de-number-range-container"> <div class="de-number-range-container">
<el-form-item prop="min"> <el-form-item prop="min">
<el-input v-model="form.min" :placeholder="options.attrs.placeholder" @change="handleMinChange" /> <el-input v-model="form.min" :placeholder="$t(options.attrs.placeholder_min)" @change="handleMinChange" />
</el-form-item> </el-form-item>
<span>~</span> <span>{{ $t('denumberrange.split_placeholder') }}</span>
<el-form-item prop="max"> <el-form-item prop="max">
<el-input v-model="form.max" :placeholder="options.attrs.placeholder" @change="handleMaxChange" /> <el-input v-model="form.max" :placeholder="$t(options.attrs.placeholder_max)" @change="handleMaxChange" />
</el-form-item> </el-form-item>
</div> </div>
</el-form> </el-form>
...@@ -40,12 +40,12 @@ export default { ...@@ -40,12 +40,12 @@ export default {
form: { min: '', max: '' }, form: { min: '', max: '' },
rules: { rules: {
min: [ min: [
{ required: true, message: this.$t('denumberrange.please_key_min'), trigger: 'blur' }, // { required: true, message: this.$t('denumberrange.please_key_min'), trigger: 'blur' },
{ validator: this.validateCom, trigger: 'blur' }, { validator: this.validateCom, trigger: 'blur' },
{ validator: this.validateMin, trigger: 'blur' } { validator: this.validateMin, trigger: 'blur' }
], ],
max: [ max: [
{ required: true, message: this.$t('denumberrange.please_key_max'), trigger: 'blur' }, // { required: true, message: this.$t('denumberrange.please_key_max'), trigger: 'blur' },
{ validator: this.validateCom, trigger: 'blur' }, { validator: this.validateCom, trigger: 'blur' },
{ validator: this.validateMax, trigger: 'blur' } { validator: this.validateMax, trigger: 'blur' }
] ]
...@@ -98,6 +98,7 @@ export default { ...@@ -98,6 +98,7 @@ export default {
this.$refs.form.validateField('min') this.$refs.form.validateField('min')
}, },
validateCom(rule, value, callback) { validateCom(rule, value, callback) {
if (!value) return callback()
const one = Number(value) const one = Number(value)
if (Number.isInteger(one)) { if (Number.isInteger(one)) {
if (one < MIN_NUMBER) { if (one < MIN_NUMBER) {
...@@ -110,6 +111,7 @@ export default { ...@@ -110,6 +111,7 @@ export default {
return callback(new Error(this.$t('denumberrange.must_int'))) return callback(new Error(this.$t('denumberrange.must_int')))
}, },
validateMin(rule, value, callback) { validateMin(rule, value, callback) {
if (!value) return callback()
const one = Number(value) const one = Number(value)
const max = Number(this.form.max) const max = Number(this.form.max)
if (!max || one < max) { if (!max || one < max) {
...@@ -118,6 +120,7 @@ export default { ...@@ -118,6 +120,7 @@ export default {
return callback(new Error(this.$t('denumberrange.min_out_max'))) return callback(new Error(this.$t('denumberrange.min_out_max')))
}, },
validateMax(rule, value, callback) { validateMax(rule, value, callback) {
if (!value) return callback()
const one = Number(value) const one = Number(value)
const min = Number(this.form.min) const min = Number(this.form.min)
if (!min || one > min) { if (!min || one > min) {
...@@ -141,7 +144,27 @@ export default { ...@@ -141,7 +144,27 @@ export default {
value: [this.form.min, this.form.max], value: [this.form.min, this.form.max],
operator: this.operator operator: this.operator
} }
this.inDraw && this.$store.commit('addViewFilter', param) if (this.form.min && this.form.max) {
this.inDraw && this.$store.commit('addViewFilter', param)
return
}
if (!this.form.min && !this.form.max) {
param.value = []
this.inDraw && this.$store.commit('addViewFilter', param)
return
}
if (this.form.min) {
param.value = [this.form.min]
param.operator = 'ge'
this.inDraw && this.$store.commit('addViewFilter', param)
return
}
if (this.form.max) {
param.value = [this.form.max]
param.operator = 'le'
this.inDraw && this.$store.commit('addViewFilter', param)
return
}
} }
} }
} }
...@@ -151,7 +174,7 @@ export default { ...@@ -151,7 +174,7 @@ export default {
.de-number-range-container { .de-number-range-container {
display: inline; display: inline;
>>>div.el-form-item { >>>div.el-form-item {
width: calc(50% - 5px) !important; width: calc(50% - 10px) !important;
display: inline-block; display: inline-block;
padding: 0 5px; padding: 0 5px;
} }
......
...@@ -7,7 +7,7 @@ ...@@ -7,7 +7,7 @@
:collapse-tags="showNumber" :collapse-tags="showNumber"
:clearable="!options.attrs.multiple" :clearable="!options.attrs.multiple"
:multiple="options.attrs.multiple" :multiple="options.attrs.multiple"
:placeholder="options.attrs.placeholder" :placeholder="$t(options.attrs.placeholder)"
:popper-append-to-body="inScreen" :popper-append-to-body="inScreen"
@change="changeValue" @change="changeValue"
> >
......
...@@ -2,14 +2,15 @@ import { WidgetService } from '../service/WidgetService' ...@@ -2,14 +2,15 @@ import { WidgetService } from '../service/WidgetService'
const leftPanel = { const leftPanel = {
icon: 'iconfont icon-zuoce-qujian', icon: 'iconfont icon-zuoce-qujian',
label: '数值区间', label: 'denumberrange.label',
defaultClass: 'text-filter' defaultClass: 'text-filter'
} }
const dialogPanel = { const dialogPanel = {
options: { options: {
attrs: { attrs: {
placeholder: '请输入整数', placeholder_min: 'denumberrange.please_key_min',
placeholder_max: 'denumberrange.please_key_max',
viewIds: [] viewIds: []
}, },
value: '' value: ''
......
...@@ -3,7 +3,7 @@ import { WidgetService } from '../service/WidgetService' ...@@ -3,7 +3,7 @@ import { WidgetService } from '../service/WidgetService'
const leftPanel = { const leftPanel = {
icon: 'iconfont icon-xialakuang', icon: 'iconfont icon-xialakuang',
label: '数字下拉', label: 'denumberselect.label',
defaultClass: 'text-filter' defaultClass: 'text-filter'
} }
...@@ -11,7 +11,7 @@ const dialogPanel = { ...@@ -11,7 +11,7 @@ const dialogPanel = {
options: { options: {
attrs: { attrs: {
multiple: false, multiple: false,
placeholder: '请选择', placeholder: 'denumberselect.placeholder',
datas: [], datas: [],
key: 'id', key: 'id',
label: 'text', label: 'text',
......
...@@ -2,14 +2,14 @@ import { WidgetService } from '../service/WidgetService' ...@@ -2,14 +2,14 @@ import { WidgetService } from '../service/WidgetService'
const leftPanel = { const leftPanel = {
icon: 'iconfont icon-shuru', icon: 'iconfont icon-shuru',
label: '文本搜索', label: 'deinputsearch.label',
defaultClass: 'text-filter' defaultClass: 'text-filter'
} }
const dialogPanel = { const dialogPanel = {
options: { options: {
attrs: { attrs: {
placeholder: '请输入关键字', placeholder: 'deinputsearch.placeholder',
viewIds: [] viewIds: []
}, },
......
...@@ -3,7 +3,7 @@ import { WidgetService } from '../service/WidgetService' ...@@ -3,7 +3,7 @@ import { WidgetService } from '../service/WidgetService'
const leftPanel = { const leftPanel = {
icon: 'iconfont icon-xialakuang', icon: 'iconfont icon-xialakuang',
label: '文本下拉', label: 'detextselect.label',
defaultClass: 'text-filter' defaultClass: 'text-filter'
} }
...@@ -11,7 +11,7 @@ const dialogPanel = { ...@@ -11,7 +11,7 @@ const dialogPanel = {
options: { options: {
attrs: { attrs: {
multiple: false, multiple: false,
placeholder: '请选择', placeholder: 'detextselect.placeholder',
viewIds: [], viewIds: [],
datas: [], datas: [],
key: 'id', key: 'id',
......
...@@ -2,7 +2,7 @@ import { WidgetService } from '../service/WidgetService' ...@@ -2,7 +2,7 @@ import { WidgetService } from '../service/WidgetService'
const leftPanel = { const leftPanel = {
icon: 'iconfont icon-riqi', icon: 'iconfont icon-riqi',
label: '日期范围', label: 'dedaterange.label',
defaultClass: 'time-filter' defaultClass: 'time-filter'
} }
...@@ -10,9 +10,9 @@ const dialogPanel = { ...@@ -10,9 +10,9 @@ const dialogPanel = {
options: { options: {
attrs: { attrs: {
type: 'daterange', type: 'daterange',
rangeSeparator: '', rangeSeparator: 'dedaterange.split_placeholder',
startPlaceholder: '开始日期', startPlaceholder: 'dedaterange.to_placeholder',
endPlaceholder: '结束日期', endPlaceholder: 'dedaterange.from_placeholder',
viewIds: [] viewIds: []
}, },
value: '' value: ''
......
...@@ -2,7 +2,7 @@ import { WidgetService } from '../service/WidgetService' ...@@ -2,7 +2,7 @@ import { WidgetService } from '../service/WidgetService'
const leftPanel = { const leftPanel = {
icon: 'iconfont icon-ri', icon: 'iconfont icon-ri',
label: '日期', label: 'dedate.label',
defaultClass: 'time-filter' defaultClass: 'time-filter'
} }
...@@ -10,7 +10,7 @@ const dialogPanel = { ...@@ -10,7 +10,7 @@ const dialogPanel = {
options: { options: {
attrs: { attrs: {
type: 'date', type: 'date',
placeholder: '请选择日期', placeholder: 'dedate.placeholder',
viewIds: [] viewIds: []
}, },
value: '' value: ''
......
...@@ -2,7 +2,7 @@ import { WidgetService } from '../service/WidgetService' ...@@ -2,7 +2,7 @@ import { WidgetService } from '../service/WidgetService'
const leftPanel = { const leftPanel = {
icon: 'iconfont icon-yue', icon: 'iconfont icon-yue',
label: '年月', label: 'deyearmonth.label',
defaultClass: 'time-filter' defaultClass: 'time-filter'
} }
...@@ -10,7 +10,7 @@ const dialogPanel = { ...@@ -10,7 +10,7 @@ const dialogPanel = {
options: { options: {
attrs: { attrs: {
type: 'month', type: 'month',
placeholder: '请选择年月', placeholder: 'deyearmonth.placeholder',
viewIds: [] viewIds: []
}, },
value: '' value: ''
......
...@@ -2,7 +2,7 @@ import { WidgetService } from '../service/WidgetService' ...@@ -2,7 +2,7 @@ import { WidgetService } from '../service/WidgetService'
const leftPanel = { const leftPanel = {
icon: 'iconfont icon-nian', icon: 'iconfont icon-nian',
label: '年份', label: 'deyear.label',
defaultClass: 'time-filter' defaultClass: 'time-filter'
} }
...@@ -10,7 +10,7 @@ const dialogPanel = { ...@@ -10,7 +10,7 @@ const dialogPanel = {
options: { options: {
attrs: { attrs: {
type: 'year', type: 'year',
placeholder: '请选择年份', placeholder: 'deyear.placeholder',
viewIds: [] viewIds: []
}, },
value: '' value: ''
......
...@@ -827,6 +827,7 @@ export default { ...@@ -827,6 +827,7 @@ export default {
dataset: { dataset: {
sheet_warn: 'There are multiple sheet pages, and the first one is extracted by default', sheet_warn: 'There are multiple sheet pages, and the first one is extracted by default',
datalist: 'Data Set', datalist: 'Data Set',
name: 'DataSet Name',
add_group: 'Add Group', add_group: 'Add Group',
add_scene: 'Add Scene', add_scene: 'Add Scene',
group: 'Group', group: 'Group',
...@@ -961,9 +962,10 @@ export default { ...@@ -961,9 +962,10 @@ export default {
task_status: 'Task status', task_status: 'Task status',
dataset: 'Data set', dataset: 'Data set',
search_by_name: 'Search by name', search_by_name: 'Search by name',
underway: 'Running', underway: 'Waiting for execution',
stopped: 'Stopped', stopped: 'End',
exec: 'Execute', pending: 'Pause',
exec: 'Execute Once',
confirm_exec: 'Manual trigger execution?', confirm_exec: 'Manual trigger execution?',
change_success: 'State switch successful' change_success: 'State switch successful'
}, },
...@@ -1289,6 +1291,8 @@ export default { ...@@ -1289,6 +1291,8 @@ export default {
channel_inner_msg: 'On site news' channel_inner_msg: 'On site news'
}, },
denumberrange: { denumberrange: {
label: 'Number range',
split_placeholder: 'To',
please_key_min: 'Please key min value', please_key_min: 'Please key min value',
please_key_max: 'Please key max value', please_key_max: 'Please key max value',
out_of_min: 'The min value cannot be less than the min integer -2³²', out_of_min: 'The min value cannot be less than the min integer -2³²',
...@@ -1296,5 +1300,35 @@ export default { ...@@ -1296,5 +1300,35 @@ export default {
must_int: 'Please key interger', must_int: 'Please key interger',
min_out_max: 'The min value must be less than the max value', min_out_max: 'The min value must be less than the max value',
max_out_min: 'The max value must be more than the min value' max_out_min: 'The max value must be more than the min value'
},
denumberselect: {
label: 'Number selector',
placeholder: 'Please select'
},
deinputsearch: {
label: 'Text search',
placeholder: 'Please key keyword'
},
detextselect: {
label: 'Text selector',
placeholder: 'Please select'
},
dedaterange: {
label: 'Date range',
to_placeholder: 'End date',
from_placeholder: 'Start date',
split_placeholder: 'To'
},
dedate: {
label: 'Date',
placeholder: 'Please select date'
},
deyearmonth: {
label: 'Month',
placeholder: 'Please select month'
},
deyear: {
label: 'Year',
placeholder: 'Please select year'
} }
} }
...@@ -827,6 +827,7 @@ export default { ...@@ -827,6 +827,7 @@ export default {
dataset: { dataset: {
sheet_warn: '有多個sheet頁面,默認抽取第一個', sheet_warn: '有多個sheet頁面,默認抽取第一個',
datalist: '數據集', datalist: '數據集',
name: '數據集名稱',
add_group: '添加分組', add_group: '添加分組',
add_scene: '添加場景', add_scene: '添加場景',
group: '分組', group: '分組',
...@@ -961,9 +962,10 @@ export default { ...@@ -961,9 +962,10 @@ export default {
task_status: '任務狀態', task_status: '任務狀態',
dataset: '數據集', dataset: '數據集',
search_by_name: '根據名稱搜索', search_by_name: '根據名稱搜索',
underway: '運行中', underway: '等待執行',
stopped: '停止', stopped: '執行结束',
exec: '執行', pending: '暫停',
exec: '執行一次',
confirm_exec: '手動觸發執行?', confirm_exec: '手動觸發執行?',
change_success: '狀態切換成功' change_success: '狀態切換成功'
}, },
...@@ -1289,6 +1291,8 @@ export default { ...@@ -1289,6 +1291,8 @@ export default {
channel_inner_msg: '站內消息' channel_inner_msg: '站內消息'
}, },
denumberrange: { denumberrange: {
label: '數值區間',
split_placeholder: '至',
please_key_min: '請輸入最小值', please_key_min: '請輸入最小值',
please_key_max: '請輸入最大值', please_key_max: '請輸入最大值',
out_of_min: '最小值不能小于最小整數-2³²', out_of_min: '最小值不能小于最小整數-2³²',
...@@ -1296,5 +1300,35 @@ export default { ...@@ -1296,5 +1300,35 @@ export default {
must_int: '請輸入整數', must_int: '請輸入整數',
min_out_max: '最小值必須小于最大值', min_out_max: '最小值必須小于最大值',
max_out_min: '最大值必須大于最小值' max_out_min: '最大值必須大于最小值'
},
denumberselect: {
label: '數字下拉',
placeholder: '請選擇'
},
deinputsearch: {
label: '文本搜索',
placeholder: '請輸入關鍵字'
},
detextselect: {
label: '文本下拉',
placeholder: '請選擇'
},
dedaterange: {
label: '日期範圍',
to_placeholder: '結束日期',
from_placeholder: '開始日期',
split_placeholder: '至'
},
dedate: {
label: '日期',
placeholder: '請選擇日期'
},
deyearmonth: {
label: '年月',
placeholder: '請選擇年月'
},
deyear: {
label: '年份',
placeholder: '請選擇年份'
} }
} }
...@@ -827,6 +827,7 @@ export default { ...@@ -827,6 +827,7 @@ export default {
dataset: { dataset: {
sheet_warn: '有多个 Sheet 页,默认抽取第一个', sheet_warn: '有多个 Sheet 页,默认抽取第一个',
datalist: '数据集', datalist: '数据集',
name: '数据集名称',
add_group: '添加分组', add_group: '添加分组',
add_scene: '添加场景', add_scene: '添加场景',
group: '分组', group: '分组',
...@@ -961,9 +962,10 @@ export default { ...@@ -961,9 +962,10 @@ export default {
task_status: '任务状态', task_status: '任务状态',
dataset: '数据集', dataset: '数据集',
search_by_name: '根据名称搜索', search_by_name: '根据名称搜索',
underway: '运行中', underway: '等待执行',
stopped: '停止', stopped: '执行结束',
exec: '执行', pending: '暂停',
exec: '执行一次',
confirm_exec: '手动触发执行?', confirm_exec: '手动触发执行?',
change_success: '状态切换成功' change_success: '状态切换成功'
}, },
...@@ -1291,6 +1293,8 @@ export default { ...@@ -1291,6 +1293,8 @@ export default {
channel_inner_msg: '站内消息' channel_inner_msg: '站内消息'
}, },
denumberrange: { denumberrange: {
label: '数值区间',
split_placeholder: '至',
please_key_min: '请输入最小值', please_key_min: '请输入最小值',
please_key_max: '请输入最大值', please_key_max: '请输入最大值',
out_of_min: '最小值不能小于最小整数-2³²', out_of_min: '最小值不能小于最小整数-2³²',
...@@ -1298,5 +1302,35 @@ export default { ...@@ -1298,5 +1302,35 @@ export default {
must_int: '请输入整数', must_int: '请输入整数',
min_out_max: '最小值必须小于最大值', min_out_max: '最小值必须小于最大值',
max_out_min: '最大值必须大于最小值' max_out_min: '最大值必须大于最小值'
},
denumberselect: {
label: '数字下拉',
placeholder: '请选择'
},
deinputsearch: {
label: '文本搜索',
placeholder: '请输入关键字'
},
detextselect: {
label: '文本下拉',
placeholder: '请选择'
},
dedaterange: {
label: '日期范围',
to_placeholder: '结束日期',
from_placeholder: '开始日期',
split_placeholder: '至'
},
dedate: {
label: '日期',
placeholder: '请选择日期'
},
deyearmonth: {
label: '年月',
placeholder: '请选择年月'
},
deyear: {
label: '年份',
placeholder: '请选择年份'
} }
} }
...@@ -54,6 +54,18 @@ ...@@ -54,6 +54,18 @@
<div class="content unicode" style="display: block;"> <div class="content unicode" style="display: block;">
<ul class="icon_lists dib-box"> <ul class="icon_lists dib-box">
<li class="dib">
<span class="icon iconfont">&#xe603;</span>
<div class="name">弧形框</div>
<div class="code-name">&amp;#xe603;</div>
</li>
<li class="dib">
<span class="icon iconfont">&#xe602;</span>
<div class="name">弧形框</div>
<div class="code-name">&amp;#xe602;</div>
</li>
<li class="dib"> <li class="dib">
<span class="icon iconfont">&#xe642;</span> <span class="icon iconfont">&#xe642;</span>
<div class="name">透明</div> <div class="name">透明</div>
...@@ -294,9 +306,9 @@ ...@@ -294,9 +306,9 @@
<pre><code class="language-css" <pre><code class="language-css"
>@font-face { >@font-face {
font-family: 'iconfont'; font-family: 'iconfont';
src: url('iconfont.woff2?t=1626919869905') format('woff2'), src: url('iconfont.woff2?t=1626927148990') format('woff2'),
url('iconfont.woff?t=1626919869905') format('woff'), url('iconfont.woff?t=1626927148990') format('woff'),
url('iconfont.ttf?t=1626919869905') format('truetype'); url('iconfont.ttf?t=1626927148990') format('truetype');
} }
</code></pre> </code></pre>
<h3 id="-iconfont-">第二步:定义使用 iconfont 的样式</h3> <h3 id="-iconfont-">第二步:定义使用 iconfont 的样式</h3>
...@@ -322,6 +334,24 @@ ...@@ -322,6 +334,24 @@
<div class="content font-class"> <div class="content font-class">
<ul class="icon_lists dib-box"> <ul class="icon_lists dib-box">
<li class="dib">
<span class="icon iconfont icon-weibiaoti-1"></span>
<div class="name">
弧形框
</div>
<div class="code-name">.icon-weibiaoti-1
</div>
</li>
<li class="dib">
<span class="icon iconfont icon-weibiaoti-"></span>
<div class="name">
弧形框
</div>
<div class="code-name">.icon-weibiaoti-
</div>
</li>
<li class="dib"> <li class="dib">
<span class="icon iconfont icon-touming"></span> <span class="icon iconfont icon-touming"></span>
<div class="name"> <div class="name">
...@@ -682,6 +712,22 @@ ...@@ -682,6 +712,22 @@
<div class="content symbol"> <div class="content symbol">
<ul class="icon_lists dib-box"> <ul class="icon_lists dib-box">
<li class="dib">
<svg class="icon svg-icon" aria-hidden="true">
<use xlink:href="#icon-weibiaoti-1"></use>
</svg>
<div class="name">弧形框</div>
<div class="code-name">#icon-weibiaoti-1</div>
</li>
<li class="dib">
<svg class="icon svg-icon" aria-hidden="true">
<use xlink:href="#icon-weibiaoti-"></use>
</svg>
<div class="name">弧形框</div>
<div class="code-name">#icon-weibiaoti-</div>
</li>
<li class="dib"> <li class="dib">
<svg class="icon svg-icon" aria-hidden="true"> <svg class="icon svg-icon" aria-hidden="true">
<use xlink:href="#icon-touming"></use> <use xlink:href="#icon-touming"></use>
......
@font-face { @font-face {
font-family: "iconfont"; /* Project id 2459092 */ font-family: "iconfont"; /* Project id 2459092 */
src: url('iconfont.woff2?t=1626919869905') format('woff2'), src: url('iconfont.woff2?t=1626927148990') format('woff2'),
url('iconfont.woff?t=1626919869905') format('woff'), url('iconfont.woff?t=1626927148990') format('woff'),
url('iconfont.ttf?t=1626919869905') format('truetype'); url('iconfont.ttf?t=1626927148990') format('truetype');
} }
.iconfont { .iconfont {
...@@ -13,6 +13,14 @@ ...@@ -13,6 +13,14 @@
-moz-osx-font-smoothing: grayscale; -moz-osx-font-smoothing: grayscale;
} }
.icon-weibiaoti-1:before {
content: "\e603";
}
.icon-weibiaoti-:before {
content: "\e602";
}
.icon-touming:before { .icon-touming:before {
content: "\e642"; content: "\e642";
} }
......
...@@ -5,6 +5,20 @@ ...@@ -5,6 +5,20 @@
"css_prefix_text": "icon-", "css_prefix_text": "icon-",
"description": "", "description": "",
"glyphs": [ "glyphs": [
{
"icon_id": "12617190",
"name": "弧形框",
"font_class": "weibiaoti-1",
"unicode": "e603",
"unicode_decimal": 58883
},
{
"icon_id": "12617065",
"name": "弧形框",
"font_class": "weibiaoti-",
"unicode": "e602",
"unicode_decimal": 58882
},
{ {
"icon_id": "4454064", "icon_id": "4454064",
"name": "透明", "name": "透明",
......
...@@ -205,7 +205,31 @@ export const BASE_BAR = { ...@@ -205,7 +205,31 @@ export const BASE_BAR = {
series: [], series: [],
dataZoom: [ dataZoom: [
{ {
type: 'inside' type: 'slider',
show: false,
xAxisIndex: [0],
start: 1,
end: 100
},
{
type: 'slider',
show: false,
yAxisIndex: [0],
left: '93%',
start: 1,
end: 100
},
{
type: 'inside',
xAxisIndex: [0],
start: 1,
end: 100
},
{
type: 'inside',
yAxisIndex: [0],
start: 1,
end: 100
} }
] ]
} }
...@@ -237,7 +261,31 @@ export const HORIZONTAL_BAR = { ...@@ -237,7 +261,31 @@ export const HORIZONTAL_BAR = {
series: [], series: [],
dataZoom: [ dataZoom: [
{ {
type: 'inside' type: 'slider',
show: false,
xAxisIndex: [0],
start: 1,
end: 100
},
{
type: 'slider',
show: false,
yAxisIndex: [0],
left: '93%',
start: 1,
end: 100
},
{
type: 'inside',
xAxisIndex: [0],
start: 1,
end: 100
},
{
type: 'inside',
yAxisIndex: [0],
start: 1,
end: 100
} }
] ]
} }
...@@ -271,7 +319,31 @@ export const BASE_LINE = { ...@@ -271,7 +319,31 @@ export const BASE_LINE = {
series: [], series: [],
dataZoom: [ dataZoom: [
{ {
type: 'inside' type: 'slider',
show: false,
xAxisIndex: [0],
start: 1,
end: 100
},
{
type: 'slider',
show: false,
yAxisIndex: [0],
left: '93%',
start: 1,
end: 100
},
{
type: 'inside',
xAxisIndex: [0],
start: 1,
end: 100
},
{
type: 'inside',
yAxisIndex: [0],
start: 1,
end: 100
} }
] ]
} }
......
<template> <template>
<div> <div style="width: 100%">
<div style="width: 100%"> <el-col>
<el-popover <el-form ref="colorForm" :model="colorForm" label-width="80px" size="mini" :disabled="param && !hasDataPermission('manage',param.privileges)">
placement="right" <el-form-item :label="$t('chart.color')" class="form-item">
width="400" <el-color-picker v-model="colorForm.color" class="color-picker-style" @change="changeBackgroundStyle" />
trigger="click" </el-form-item>
> <el-form-item :label="$t('chart.not_alpha')" class="form-item form-item-slider">
<el-col> <el-slider v-model="colorForm.alpha" show-input :show-input-controls="false" input-size="mini" @change="changeBackgroundStyle" />
<el-form ref="colorForm" :model="colorForm" label-width="80px" size="mini"> </el-form-item>
<el-form-item :label="$t('chart.color')" class="form-item"> </el-form>
<colorPicker v-model="colorForm.color" style="margin-top: 6px;cursor: pointer;z-index: 1004;border: solid 1px black" @change="changeBackgroundStyle" /> </el-col>
</el-form-item> <!-- <div style="width: 100%">-->
<el-form-item :label="$t('chart.not_alpha')" class="form-item form-item-slider"> <!-- <el-popover-->
<el-slider v-model="colorForm.alpha" show-input :show-input-controls="false" input-size="mini" @change="changeBackgroundStyle" /> <!-- placement="right"-->
</el-form-item> <!-- width="400"-->
</el-form> <!-- trigger="click"-->
</el-col> <!-- >-->
<!-- <el-col>-->
<!-- <el-form ref="colorForm" :model="colorForm" label-width="80px" size="mini">-->
<!-- <el-form-item :label="$t('chart.color')" class="form-item">-->
<!-- <colorPicker v-model="colorForm.color" style="margin-top: 6px;cursor: pointer;z-index: 1004;border: solid 1px black" @change="changeBackgroundStyle" />-->
<!-- </el-form-item>-->
<!-- <el-form-item :label="$t('chart.not_alpha')" class="form-item form-item-slider">-->
<!-- <el-slider v-model="colorForm.alpha" show-input :show-input-controls="false" input-size="mini" @change="changeBackgroundStyle" />-->
<!-- </el-form-item>-->
<!-- </el-form>-->
<!-- </el-col>-->
<el-button slot="reference" :disabled="param && !hasDataPermission('manage',param.privileges)" size="mini" class="shape-item">{{ $t('chart.background') }}<i class="el-icon-setting el-icon--right" /></el-button> <!-- <el-button slot="reference" :disabled="param && !hasDataPermission('manage',param.privileges)" size="mini" class="shape-item">{{ $t('chart.background') }}<i class="el-icon-setting el-icon&#45;&#45;right" /></el-button>-->
</el-popover> <!-- </el-popover>-->
</div> <!-- </div>-->
</div> </div>
</template> </template>
...@@ -100,4 +110,8 @@ export default { ...@@ -100,4 +110,8 @@ export default {
.el-form-item{ .el-form-item{
margin-bottom: 6px; margin-bottom: 6px;
} }
.color-picker-style{
cursor: pointer;
z-index: 1003;
}
</style> </style>
...@@ -100,7 +100,7 @@ ...@@ -100,7 +100,7 @@
<svg-icon icon-class="ds-sql" class="ds-icon-sql" /> <svg-icon icon-class="ds-sql" class="ds-icon-sql" />
{{ $t('dataset.sql_data') }} {{ $t('dataset.sql_data') }}
</el-dropdown-item> </el-dropdown-item>
<el-dropdown-item :command="beforeClickAddData('excel',data)"> <el-dropdown-item :command="beforeClickAddData('excel',data)" :disabled="!kettleRunning">
<svg-icon icon-class="ds-excel" class="ds-icon-excel" /> <svg-icon icon-class="ds-excel" class="ds-icon-excel" />
{{ $t('dataset.excel_data') }} {{ $t('dataset.excel_data') }}
</el-dropdown-item> </el-dropdown-item>
...@@ -341,7 +341,7 @@ ...@@ -341,7 +341,7 @@
</template> </template>
<script> <script>
import { loadTable, getScene, addGroup, delGroup, addTable, delTable, post } from '@/api/dataset/dataset' import { loadTable, getScene, addGroup, delGroup, addTable, delTable, post , isKettleRunning} from '@/api/dataset/dataset'
import { authModel } from '@/api/system/sysAuth' import { authModel } from '@/api/system/sysAuth'
import GroupMoveSelector from './GroupMoveSelector' import GroupMoveSelector from './GroupMoveSelector'
import DsMoveSelector from './DsMoveSelector' import DsMoveSelector from './DsMoveSelector'
...@@ -415,7 +415,8 @@ export default { ...@@ -415,7 +415,8 @@ export default {
id: 'id', id: 'id',
parentId: 'pid' parentId: 'pid'
}, },
isTreeSearch: false isTreeSearch: false,
kettleRunning: false
} }
}, },
computed: { computed: {
...@@ -426,6 +427,9 @@ export default { ...@@ -426,6 +427,9 @@ export default {
// return this.$store.state.dataset.sceneData // return this.$store.state.dataset.sceneData
// } // }
}, },
created() {
this.kettleState()
},
watch: { watch: {
search(val) { search(val) {
// if (val && val !== '') { // if (val && val !== '') {
...@@ -467,7 +471,11 @@ export default { ...@@ -467,7 +471,11 @@ export default {
'node': node 'node': node
} }
}, },
kettleState() {
isKettleRunning().then(res => {
this.kettleRunning = res.data
})
},
clickMore(param) { clickMore(param) {
// console.log(param) // console.log(param)
switch (param.type) { switch (param.type) {
......
...@@ -12,7 +12,7 @@ ...@@ -12,7 +12,7 @@
<el-radio v-model="panel.backgroundType" label="color" @change="onChangeType">{{ $t('chart.color') }}</el-radio> <el-radio v-model="panel.backgroundType" label="color" @change="onChangeType">{{ $t('chart.color') }}</el-radio>
</el-col> </el-col>
<el-col :span="18"> <el-col :span="18">
<colorPicker v-model="panel.color" style="margin-top: 6px;cursor: pointer;z-index: 1004;border: solid 1px black" /> <el-color-picker v-model="panel.color" style="cursor: pointer;z-index: 1004;" />
</el-col> </el-col>
</el-row> </el-row>
<el-row style="height: 60px;margin-top:10px;overflow: hidden"> <el-row style="height: 60px;margin-top:10px;overflow: hidden">
......
...@@ -19,7 +19,7 @@ ...@@ -19,7 +19,7 @@
<div class="filter-widget-icon"> <div class="filter-widget-icon">
<i :class="(widget.icon || 'el-icon-setting') + ' widget-icon-i'" /> <i :class="(widget.icon || 'el-icon-setting') + ' widget-icon-i'" />
</div> </div>
<div class="filter-widget-text">{{ widget.label }}</div> <div class="filter-widget-text">{{ $t(widget.label) || widget.label }}</div>
</div> </div>
</div> </div>
</div> </div>
......
...@@ -2,7 +2,13 @@ ...@@ -2,7 +2,13 @@
<el-col> <el-col>
<el-row style="margin-top: 10px;"> <el-row style="margin-top: 10px;">
<complex-table :data="data" :columns="columns" local-key="datasetTaskRecord" :search-config="searchConfig" :pagination-config="paginationConfig" @select="select" @search="search" @sort-change="sortChange"> <complex-table :data="data" :columns="columns" local-key="datasetTaskRecord" :search-config="searchConfig" :pagination-config="paginationConfig" @select="select" @search="search" @sort-change="sortChange">
<el-table-column prop="name" :label="$t('dataset.task_name')" /> <el-table-column prop="name" :label="$t('dataset.task_name')">
<template slot-scope="scope">
<span>
<el-link style="font-size: 12px" @click="jumpTask(scope.row)">{{ scope.row.name }}</el-link>
</span>
</template>
</el-table-column>
<el-table-column prop="startTime" :label="$t('dataset.start_time')"> <el-table-column prop="startTime" :label="$t('dataset.start_time')">
<template slot-scope="scope"> <template slot-scope="scope">
<span>{{ scope.row.startTime | timestampFormatDate }}</span> <span>{{ scope.row.startTime | timestampFormatDate }}</span>
...@@ -56,6 +62,12 @@ import TableSelector from '@/views/chart/view/TableSelector' ...@@ -56,6 +62,12 @@ import TableSelector from '@/views/chart/view/TableSelector'
export default { export default {
name: 'TaskRecord', name: 'TaskRecord',
components: { ComplexTable, LayoutContent, cron, TableSelector }, components: { ComplexTable, LayoutContent, cron, TableSelector },
props: {
param: {
type: Object,
default: null
}
},
data() { data() {
return { return {
header: '', header: '',
...@@ -71,7 +83,8 @@ export default { ...@@ -71,7 +83,8 @@ export default {
useComplexSearch: true, useComplexSearch: true,
quickPlaceholder: this.$t('dataset.task.search_by_name'), quickPlaceholder: this.$t('dataset.task.search_by_name'),
components: [ components: [
{ field: 'dataset_table_task.name', label: this.$t('dataset.task.name'), component: 'DeComplexInput' }, { field: 'dataset_table_task.name', label: this.$t('dataset.task_name'), component: 'DeComplexInput' },
{ field: 'dataset_table.name', label: this.$t('dataset.name'), component: 'DeComplexInput' },
{ field: 'dataset_table_task_log.status', label: this.$t('commons.status'), component: 'FuComplexSelect', options: [{ label: this.$t('dataset.completed'), value: 'Completed' }, { label: this.$t('dataset.underway'), value: 'Underway' }, { label: this.$t('dataset.error'), value: 'Error' }], multiple: false } { field: 'dataset_table_task_log.status', label: this.$t('commons.status'), component: 'FuComplexSelect', options: [{ label: this.$t('dataset.completed'), value: 'Completed' }, { label: this.$t('dataset.underway'), value: 'Underway' }, { label: this.$t('dataset.error'), value: 'Error' }], multiple: false }
] ]
}, },
...@@ -105,15 +118,43 @@ export default { ...@@ -105,15 +118,43 @@ export default {
computed: { computed: {
}, },
created() { created() {
this.search() if (this.param == null) {
this.timer = setInterval(() => { this.last_condition = {}
this.search(this.last_condition, false) this.search()
}, 5000) } else {
this.last_condition = {
'dataset_table_task.name': {
field: 'dataset_table_task.name',
operator: 'eq',
value: this.param.name
}
}
this.search(this.last_condition)
}
// this.timer = setInterval(() => {
// this.search(this.last_condition, false)
// }, 5000)
this.createTimer()
}, },
beforeDestroy() { beforeDestroy() {
clearInterval(this.timer) // clearInterval(this.timer)
this.destroyTimer()
}, },
methods: { methods: {
createTimer() {
if (!this.timer) {
this.timer = setInterval(() => {
this.search(this.last_condition, false)
}, 5000)
}
},
destroyTimer() {
if (this.timer) {
clearInterval(this.timer)
this.timer = null
}
},
msg2Current(routerParam) { msg2Current(routerParam) {
if (!routerParam || !routerParam.taskId) return if (!routerParam || !routerParam.taskId) return
const taskId = routerParam.taskId const taskId = routerParam.taskId
...@@ -125,7 +166,13 @@ export default { ...@@ -125,7 +166,13 @@ export default {
value: taskId value: taskId
} }
} }
// 先把定时器干掉 否则会阻塞下面的search
this.destroyTimer()
this.search(current_condition) this.search(current_condition)
// 查询完再开启定时器
this.createTimer()
}, },
sortChange({ column, prop, order }) { sortChange({ column, prop, order }) {
this.orderConditions = [] this.orderConditions = []
...@@ -145,13 +192,13 @@ export default { ...@@ -145,13 +192,13 @@ export default {
}, },
select(selection) { select(selection) {
}, },
search(condition) { search(condition, showLoading = true) {
this.last_condition = condition this.last_condition = condition
condition = formatQuickCondition(condition, 'dataset_table_task.name') condition = formatQuickCondition(condition, 'dataset_table_task.name')
const temp = formatCondition(condition) const temp = formatCondition(condition)
const param = temp || {} const param = temp || {}
param['orders'] = formatOrders(this.orderConditions) param['orders'] = formatOrders(this.orderConditions)
post('/dataset/taskLog/list/' + this.paginationConfig.currentPage + '/' + this.paginationConfig.pageSize, param).then(response => { post('/dataset/taskLog/list/' + this.paginationConfig.currentPage + '/' + this.paginationConfig.pageSize, param, showLoading).then(response => {
this.data = response.data.listObject this.data = response.data.listObject
this.paginationConfig.total = response.data.itemCount this.paginationConfig.total = response.data.itemCount
}) })
...@@ -159,6 +206,9 @@ export default { ...@@ -159,6 +206,9 @@ export default {
showErrorMassage(massage) { showErrorMassage(massage) {
this.show_error_massage = true this.show_error_massage = true
this.error_massage = massage this.error_massage = massage
},
jumpTask(item) {
this.$emit('jumpTask', item)
} }
} }
} }
......
...@@ -2,12 +2,12 @@ ...@@ -2,12 +2,12 @@
<layout-content v-loading="$store.getters.loadingMap[$store.getters.currentPath]"> <layout-content v-loading="$store.getters.loadingMap[$store.getters.currentPath]">
<el-row style="height: 100%;overflow-y: hidden;width: 100%;"> <el-row style="height: 100%;overflow-y: hidden;width: 100%;">
<el-tabs v-model="tabActive"> <el-tabs v-model="tabActive" @tab-click="changeTab">
<el-tab-pane :label="$t('dataset.task.list')" name="DatasetTaskList"> <el-tab-pane :label="$t('dataset.task.list')" name="DatasetTaskList">
<dataset-task-list /> <dataset-task-list v-if="tabActive=='DatasetTaskList'" :param="task" @jumpTaskRecord="jumpTaskRecord" />
</el-tab-pane> </el-tab-pane>
<el-tab-pane :label="$t('dataset.task.record')" name="TaskRecord"> <el-tab-pane :label="$t('dataset.task.record')" name="TaskRecord">
<task-record ref="task_record" /> <task-record v-if="tabActive=='TaskRecord'" ref="task_record" :param="task" @jumpTask="jumpTask" />
</el-tab-pane> </el-tab-pane>
</el-tabs> </el-tabs>
</el-row> </el-row>
...@@ -30,6 +30,7 @@ export default { ...@@ -30,6 +30,7 @@ export default {
components: { DatasetTableData, LayoutContent, ComplexTable, UnionView, UpdateInfo, TabDataPreview, DatasetTaskList, TaskRecord }, components: { DatasetTableData, LayoutContent, ComplexTable, UnionView, UpdateInfo, TabDataPreview, DatasetTaskList, TaskRecord },
data() { data() {
return { return {
task: null,
tabActive: 'DatasetTaskList' tabActive: 'DatasetTaskList'
} }
}, },
...@@ -51,7 +52,18 @@ export default { ...@@ -51,7 +52,18 @@ export default {
}) })
}, },
methods: { methods: {
changeTab() {
this.task = null
console.log(this.tabActive)
},
jumpTaskRecord(task) {
this.task = task
this.tabActive = 'TaskRecord'
},
jumpTask(task) {
this.task = task
this.tabActive = 'DatasetTaskList'
},
toMsgShare(routerParam) { toMsgShare(routerParam) {
if (routerParam !== null && routerParam.msgNotification) { if (routerParam !== null && routerParam.msgNotification) {
const panelShareTypeIds = [4, 5, 6] const panelShareTypeIds = [4, 5, 6]
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论