Browse Source

代码提交

master
si@aidatagov.com 2 weeks ago
parent
commit
7a3223845b
  1. 5
      vue-fastapi-backend/module_admin/dao/datasec_config_dao.py
  2. 56
      vue-fastapi-frontend/src/views/meta/metatask/index.vue
  3. 47
      vue-fastapi-frontend/src/views/meta/metatask/secConfig.vue
  4. 71
      vue-fastapi-frontend/src/views/metadataConfig/taskBizConfig/index.vue

5
vue-fastapi-backend/module_admin/dao/datasec_config_dao.py

@ -1,6 +1,6 @@
from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.ext.asyncio import AsyncSession
from sqlalchemy.future import select from sqlalchemy.future import select
from sqlalchemy import update, delete from sqlalchemy import update, delete,desc
from datetime import datetime, time from datetime import datetime, time
from typing import List from typing import List
@ -33,7 +33,8 @@ class DatasecConfigDao:
datetime.combine(datetime.strptime(query_object.begin_time, '%Y-%m-%d'), time(0, 0, 0)), datetime.combine(datetime.strptime(query_object.begin_time, '%Y-%m-%d'), time(0, 0, 0)),
datetime.combine(datetime.strptime(query_object.end_time, '%Y-%m-%d'), time(23, 59, 59)), datetime.combine(datetime.strptime(query_object.end_time, '%Y-%m-%d'), time(23, 59, 59)),
) if query_object.begin_time and query_object.end_time else True ) if query_object.begin_time and query_object.end_time else True
).order_by(DatasecConfig.onum) ) .order_by(desc(DatasecConfig.create_time))
return await PageUtil.paginate(db, query, query_object.page_num, query_object.page_size, is_page) return await PageUtil.paginate(db, query, query_object.page_num, query_object.page_size, is_page)

56
vue-fastapi-frontend/src/views/meta/metatask/index.vue

@ -117,7 +117,7 @@
plain plain
icon="edit" icon="edit"
:disabled="singleOne" :disabled="multiple"
@click="handleUpdate" @click="handleUpdate"
v-hasPermi="['meta:metatask:edit']" v-hasPermi="['meta:metatask:edit']"
>修改</el-button >修改</el-button
@ -338,7 +338,6 @@
<el-button <el-button
link link
type="primary" type="primary"
:disabled="row.status === 'ONLINE'"
icon="Edit" icon="Edit"
@click="handleUpdate(row)" @click="handleUpdate(row)"
v-hasPermi="['meta:metatask:edit']" v-hasPermi="['meta:metatask:edit']"
@ -482,7 +481,7 @@
</el-form-item> </el-form-item>
</el-col> </el-col>
</el-row> </el-row>
<el-row> <!-- <el-row>
<el-col :span="24"> <el-col :span="24">
<el-form-item label="数据库" prop="dbCode"> <el-form-item label="数据库" prop="dbCode">
<el-input <el-input
@ -494,7 +493,7 @@
/> />
</el-form-item> </el-form-item>
</el-col> </el-col>
</el-row> </el-row> -->
<el-row> <el-row>
<el-col :span="24"> <el-col :span="24">
<div style="color: #909399; font-size: 13px; margin-bottom: 4px;margin-left: 20px;"> <div style="color: #909399; font-size: 13px; margin-bottom: 4px;margin-left: 20px;">
@ -899,28 +898,57 @@ const handleLogRow = (row) => {
}; };
const submitForm = async () => { const submitForm = async () => {
proxy.$refs["taskForm"].validate(async (valid) => { proxy.$refs["taskForm"].validate(async (valid) => {
if (valid) { if (!valid) return;
const submitForm = { ...form.value };
submitForm.dbCode = clickNode.value.type;
submitForm.dbRName = clickNode.value.name;
if (submitForm.metataskId !== undefined) {
await updatemetatask(submitForm); const submitData = { ...form.value };
proxy.$modal.msgSuccess("修改成功");
const isOnline = submitData.status === 'ONLINE';
const metataskId = submitData.metataskId;
// ONLINE 线
if (isOnline) {
try {
await proxy.$modal.confirm(
"该任务当前为【上线状态】,提交修改将导致任务下线,是否确认继续?"
);
// 1 线
await downOrUpmetatask(String(metataskId), "OFFLINE");
submitData.status='OFFLINE'
// 2
await updatemetatask(submitData);
proxy.$modal.msgSuccess("修改成功,任务已下线");
open.value = false; open.value = false;
getList(); getList();
} catch (e) {
//
return;
}
}
// ONLINE
else {
if (metataskId !== undefined) {
await updatemetatask(submitData);
proxy.$modal.msgSuccess("修改成功");
} else { } else {
await addmetatask(submitForm); submitData.dbRName = clickNode.value.name;
submitData.dbCode = clickNode.value.type;
await addmetatask(submitData);
proxy.$modal.msgSuccess("新增成功"); proxy.$modal.msgSuccess("新增成功");
}
open.value = false; open.value = false;
getList(); getList();
} }
}
}); });
}; };
const handleDelete = async (row) => { const handleDelete = async (row) => {
let isDelete = true; let isDelete = true;
if(row.metataskId!=null){ if(row.metataskId!=null){

47
vue-fastapi-frontend/src/views/meta/metatask/secConfig.vue

@ -61,8 +61,7 @@
type="success" type="success"
plain plain
icon="edit" icon="edit"
:disabled="single"
:disabled="singleOne"
@click="handleUpdate" @click="handleUpdate"
v-hasPermi="['meta:metatask:edit']" v-hasPermi="['meta:metatask:edit']"
>修改</el-button >修改</el-button
@ -252,7 +251,6 @@
<el-button <el-button
link link
type="primary" type="primary"
:disabled="row.status === 'ONLINE'"
icon="Edit" icon="Edit"
@click="handleUpdate(row)" @click="handleUpdate(row)"
v-hasPermi="['meta:metatask:edit']" v-hasPermi="['meta:metatask:edit']"
@ -665,27 +663,50 @@ const handleLogRow = (row) => {
}; };
const submitForm = async () => { const submitForm = async () => {
proxy.$refs["taskForm"].validate(async (valid) => { proxy.$refs["taskForm"].validate(async (valid) => {
if (valid) { if (!valid) return;
const submitForm = { ...form.value };
const submitData = { ...form.value };
const isEdit = submitData.onum !== undefined;
const isOnline = submitData.status === 'ONLINE';
try {
// + ONLINE 线
if (isEdit && isOnline) {
await proxy.$modal.confirm(
"该任务当前为【上线状态】,提交修改将导致任务下线,是否确认继续?"
);
// 1 线
await downOrUpmetatask(String(submitData.onum), "OFFLINE");
if (submitForm.onum !== undefined) { // 2
submitData.status = 'OFFLINE';
await editDatasecConfig(submitData);
await editDatasecConfig(submitForm); proxy.$modal.msgSuccess("修改成功,任务已下线");
}
// + ONLINE
else if (isEdit) {
await editDatasecConfig(submitData);
proxy.$modal.msgSuccess("修改成功"); proxy.$modal.msgSuccess("修改成功");
open.value = false; }
getList(); //
} else { else {
await addDatasecConfig(submitForm); await addDatasecConfig(submitData);
proxy.$modal.msgSuccess("新增成功"); proxy.$modal.msgSuccess("新增成功");
}
open.value = false; open.value = false;
getList(); getList();
} } catch (e) {
// /
return;
} }
}); });
}; };
const handleDelete = async (row) => { const handleDelete = async (row) => {
let isDelete = true; let isDelete = true;
if(row.onum!=null){ if(row.onum!=null){

71
vue-fastapi-frontend/src/views/metadataConfig/taskBizConfig/index.vue

@ -618,10 +618,7 @@ function openEditDialog(row) {
ElMessage.warning('请选择一条记录进行编辑') ElMessage.warning('请选择一条记录进行编辑')
return return
} }
if (row.status !== 'OFFLINE') {
ElMessage.warning('仅支持下线状态的任务进行修改')
return
}
title.value = '编辑标签任务' title.value = '编辑标签任务'
Object.assign(form, row) Object.assign(form, row)
loadRightTable(row.onum) loadRightTable(row.onum)
@ -648,30 +645,56 @@ function handleRowDelete(row) {
.catch(() => {}) .catch(() => {})
} }
function submitForm() { const submitForm = async () => {
bizFormRef.value.validate(async valid => { bizFormRef.value.validate(async (valid) => {
if (!valid) return if (!valid) return;
let tabonums=[]
rightTableData.value.forEach(item=>{ //
tabonums.push(item.onum) const tabonums = rightTableData.value.map(item => item.onum);
const submitData = {
...form,
tabOnumList: tabonums
};
const isEdit = !!submitData.onum;
const isOnline = submitData.status === 'ONLINE';
})
console.log( rightTableData.value,"sss")
const submitData = { ...form,tabOnumList:tabonums }
try { try {
if (title.value.includes('新增')) { // + ONLINE 线
await addTaskBizConfig(submitData) if (isEdit && isOnline) {
ElMessage.success('新增成功') await proxy.$modal.confirm(
} else { '该任务当前为【上线状态】,保存修改将导致任务下线,是否确认继续?'
await updateTaskBizConfig(submitData) );
ElMessage.success('编辑成功')
// 1 线
await downOrUpmetatask(submitData.onum, 'OFFLINE');
// 2 OFFLINE
submitData.status = 'OFFLINE';
await updateTaskBizConfig(submitData);
proxy.$modal.msgSuccess('修改成功,任务已下线');
} }
open.value = false // + ONLINE
getList() else if (isEdit) {
} catch { await updateTaskBizConfig(submitData);
proxy.$modal.msgSuccess('修改成功');
} }
}) //
} else {
await addTaskBizConfig(submitData);
proxy.$modal.msgSuccess('新增成功');
}
open.value = false;
getList();
} catch (e) {
// or
return;
}
});
};
function handleClose(done) { function handleClose(done) {
bizFormRef.value.resetFields() bizFormRef.value.resetFields()

Loading…
Cancel
Save