mirror of
https://github.com/1Panel-dev/1Panel.git
synced 2026-10-09 08:00:27 +00:00
Compare commits
4
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
16a35141dd | ||
|
|
f6c334bdad | ||
|
|
cbb119117b | ||
|
|
cae0a6118f |
@@ -17,15 +17,20 @@ import (
|
||||
|
||||
func (u *CronjobService) handleApp(cronjob model.Cronjob, startTime time.Time) error {
|
||||
var apps []model.AppInstall
|
||||
if cronjob.AppID == "all" {
|
||||
if strings.Contains(cronjob.AppID, "all") {
|
||||
apps, _ = appInstallRepo.ListBy()
|
||||
} else {
|
||||
itemID, _ := strconv.Atoi(cronjob.AppID)
|
||||
app, err := appInstallRepo.GetFirst(commonRepo.WithByID(uint(itemID)))
|
||||
appIds := strings.Split(cronjob.AppID, ",")
|
||||
var idItems []uint
|
||||
for i := 0; i < len(appIds); i++ {
|
||||
itemID, _ := strconv.Atoi(appIds[i])
|
||||
idItems = append(idItems, uint(itemID))
|
||||
}
|
||||
appItems, err := appInstallRepo.ListBy(commonRepo.WithIdsIn(idItems))
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
apps = append(apps, app)
|
||||
apps = appItems
|
||||
}
|
||||
accountMap, err := loadClientMap(cronjob.BackupAccounts)
|
||||
if err != nil {
|
||||
@@ -232,7 +237,7 @@ type databaseHelper struct {
|
||||
|
||||
func loadDbsForJob(cronjob model.Cronjob) []databaseHelper {
|
||||
var dbs []databaseHelper
|
||||
if cronjob.DBName == "all" {
|
||||
if strings.Contains(cronjob.DBName, "all") {
|
||||
if cronjob.DBType == "mysql" || cronjob.DBType == "mariadb" {
|
||||
mysqlItems, _ := mysqlRepo.List()
|
||||
for _, mysql := range mysqlItems {
|
||||
@@ -254,36 +259,42 @@ func loadDbsForJob(cronjob model.Cronjob) []databaseHelper {
|
||||
}
|
||||
return dbs
|
||||
}
|
||||
itemID, _ := strconv.Atoi(cronjob.DBName)
|
||||
if cronjob.DBType == "mysql" || cronjob.DBType == "mariadb" {
|
||||
mysqlItem, _ := mysqlRepo.Get(commonRepo.WithByID(uint(itemID)))
|
||||
dbs = append(dbs, databaseHelper{
|
||||
DBType: cronjob.DBType,
|
||||
Database: mysqlItem.MysqlName,
|
||||
Name: mysqlItem.Name,
|
||||
})
|
||||
} else {
|
||||
pgItem, _ := postgresqlRepo.Get(commonRepo.WithByID(uint(itemID)))
|
||||
dbs = append(dbs, databaseHelper{
|
||||
DBType: cronjob.DBType,
|
||||
Database: pgItem.PostgresqlName,
|
||||
Name: pgItem.Name,
|
||||
})
|
||||
|
||||
dbNames := strings.Split(cronjob.DBName, ",")
|
||||
for _, name := range dbNames {
|
||||
itemID, _ := strconv.Atoi(name)
|
||||
if cronjob.DBType == "mysql" || cronjob.DBType == "mariadb" {
|
||||
mysqlItem, _ := mysqlRepo.Get(commonRepo.WithByID(uint(itemID)))
|
||||
dbs = append(dbs, databaseHelper{
|
||||
DBType: cronjob.DBType,
|
||||
Database: mysqlItem.MysqlName,
|
||||
Name: mysqlItem.Name,
|
||||
})
|
||||
} else {
|
||||
pgItem, _ := postgresqlRepo.Get(commonRepo.WithByID(uint(itemID)))
|
||||
dbs = append(dbs, databaseHelper{
|
||||
DBType: cronjob.DBType,
|
||||
Database: pgItem.PostgresqlName,
|
||||
Name: pgItem.Name,
|
||||
})
|
||||
}
|
||||
}
|
||||
return dbs
|
||||
}
|
||||
|
||||
func loadWebsForJob(cronjob model.Cronjob) []model.Website {
|
||||
var weblist []model.Website
|
||||
if cronjob.Website == "all" {
|
||||
if strings.Contains(cronjob.Website, "all") {
|
||||
weblist, _ = websiteRepo.List()
|
||||
return weblist
|
||||
}
|
||||
itemID, _ := strconv.Atoi(cronjob.Website)
|
||||
webItem, _ := websiteRepo.GetFirst(commonRepo.WithByID(uint(itemID)))
|
||||
if webItem.ID != 0 {
|
||||
weblist = append(weblist, webItem)
|
||||
websites := strings.Split(cronjob.Website, ",")
|
||||
var idItems []uint
|
||||
for i := 0; i < len(websites); i++ {
|
||||
itemID, _ := strconv.Atoi(websites[i])
|
||||
idItems = append(idItems, uint(itemID))
|
||||
}
|
||||
weblist, _ = websiteRepo.List(commonRepo.WithIdsIn(idItems))
|
||||
return weblist
|
||||
}
|
||||
|
||||
|
||||
@@ -24,6 +24,9 @@ export namespace Cronjob {
|
||||
backupAccounts: string;
|
||||
defaultDownload: string;
|
||||
backupAccountList: Array<string>;
|
||||
appIdList: Array<string>;
|
||||
websiteList: Array<string>;
|
||||
dbNameList: Array<string>;
|
||||
retainCopies: number;
|
||||
status: string;
|
||||
secret: string;
|
||||
|
||||
@@ -69,6 +69,7 @@ const message = {
|
||||
createNewFolder: 'Create new folder',
|
||||
createNewFile: 'Create new file',
|
||||
helpDoc: 'Help Document',
|
||||
unbind: 'UnBind',
|
||||
},
|
||||
search: {
|
||||
timeStart: 'Time start',
|
||||
|
||||
@@ -68,6 +68,7 @@ const message = {
|
||||
createNewFolder: '新建資料夾',
|
||||
createNewFile: '新建檔案',
|
||||
helpDoc: '幫助文档',
|
||||
unbind: '解綁',
|
||||
},
|
||||
search: {
|
||||
timeStart: '開始時間',
|
||||
|
||||
@@ -68,6 +68,7 @@ const message = {
|
||||
createNewFolder: '新建文件夹',
|
||||
createNewFile: '新建文件',
|
||||
helpDoc: '帮助文档',
|
||||
unbind: '解绑',
|
||||
},
|
||||
search: {
|
||||
timeStart: '开始时间',
|
||||
|
||||
@@ -186,9 +186,9 @@
|
||||
<el-form-item
|
||||
v-if="dialogData.rowData!.type === 'website' || dialogData.rowData!.type === 'cutWebsiteLog'"
|
||||
:label="dialogData.rowData!.type === 'website' ? $t('cronjob.website'):$t('website.website')"
|
||||
prop="website"
|
||||
prop="websiteList"
|
||||
>
|
||||
<el-select class="selectClass" v-model="dialogData.rowData!.website">
|
||||
<el-select class="selectClass" multiple v-model="dialogData.rowData!.websiteList">
|
||||
<el-option
|
||||
:disabled="websiteOptions.length === 0"
|
||||
:label="$t('commons.table.all')"
|
||||
@@ -212,8 +212,8 @@
|
||||
</el-form-item>
|
||||
|
||||
<div v-if="dialogData.rowData!.type === 'app'">
|
||||
<el-form-item :label="$t('cronjob.app')" prop="appID">
|
||||
<el-select class="selectClass" clearable v-model="dialogData.rowData!.appID">
|
||||
<el-form-item :label="$t('cronjob.app')" prop="appIdList">
|
||||
<el-select class="selectClass" multiple clearable v-model="dialogData.rowData!.appIdList">
|
||||
<el-option
|
||||
:disabled="appOptions.length === 0"
|
||||
:label="$t('commons.table.all')"
|
||||
@@ -239,8 +239,8 @@
|
||||
<el-radio value="postgresql">PostgreSQL</el-radio>
|
||||
</el-radio-group>
|
||||
</el-form-item>
|
||||
<el-form-item :label="$t('cronjob.database')" prop="dbName">
|
||||
<el-select class="selectClass" clearable v-model="dialogData.rowData!.dbName">
|
||||
<el-form-item :label="$t('cronjob.database')" prop="dbNameList">
|
||||
<el-select class="selectClass" multiple clearable v-model="dialogData.rowData!.dbNameList">
|
||||
<el-option
|
||||
:disabled="dbInfo.dbs.length === 0"
|
||||
:label="$t('commons.table.all')"
|
||||
@@ -378,6 +378,7 @@ import { listContainer } from '@/api/modules/container';
|
||||
import { Database } from '@/api/interface/database';
|
||||
import { ListAppInstalled } from '@/api/modules/app';
|
||||
import { loadDefaultSpec, specOptions, transObjToSpec, transSpecToObj, weekOptions } from './../helper';
|
||||
|
||||
const router = useRouter();
|
||||
|
||||
interface DialogProps {
|
||||
@@ -385,6 +386,7 @@ interface DialogProps {
|
||||
rowData?: Cronjob.CronjobInfo;
|
||||
getTableList?: () => Promise<any>;
|
||||
}
|
||||
|
||||
const title = ref<string>('');
|
||||
const drawerVisible = ref(false);
|
||||
const dialogData = ref<DialogProps>({
|
||||
@@ -408,6 +410,15 @@ const acceptParams = (params: DialogProps): void => {
|
||||
if (dialogData.value.rowData.backupAccounts) {
|
||||
dialogData.value.rowData.backupAccountList = dialogData.value.rowData.backupAccounts.split(',');
|
||||
}
|
||||
if (dialogData.value.rowData.appID) {
|
||||
dialogData.value.rowData.appIdList = dialogData.value.rowData.appID.split(',');
|
||||
}
|
||||
if (dialogData.value.rowData.website) {
|
||||
dialogData.value.rowData.websiteList = dialogData.value.rowData.website.split(',');
|
||||
}
|
||||
if (dialogData.value.rowData.dbName) {
|
||||
dialogData.value.rowData.dbNameList = dialogData.value.rowData.dbName.split(',');
|
||||
}
|
||||
dialogData.value.rowData!.command = dialogData.value.rowData!.command || 'sh';
|
||||
dialogData.value.rowData!.isCustom =
|
||||
dialogData.value.rowData!.command !== 'sh' &&
|
||||
@@ -718,6 +729,17 @@ const onSubmit = async (formEl: FormInstance | undefined) => {
|
||||
specs.push(itemSpec);
|
||||
}
|
||||
dialogData.value.rowData.backupAccounts = dialogData.value.rowData.backupAccountList.join(',');
|
||||
|
||||
if (dialogData.value.rowData.appIdList) {
|
||||
dialogData.value.rowData.appID = dialogData.value.rowData.appIdList.join(',');
|
||||
}
|
||||
if (dialogData.value.rowData.websiteList) {
|
||||
dialogData.value.rowData.website = dialogData.value.rowData.websiteList.join(',');
|
||||
}
|
||||
if (dialogData.value.rowData.dbNameList) {
|
||||
dialogData.value.rowData.dbName = dialogData.value.rowData.dbNameList.join(',');
|
||||
}
|
||||
|
||||
dialogData.value.rowData.spec = specs.join(',');
|
||||
if (!formEl) return;
|
||||
formEl.validate(async (valid) => {
|
||||
@@ -750,40 +772,49 @@ defineExpose({
|
||||
.specClass {
|
||||
width: 20% !important;
|
||||
margin-left: 20px;
|
||||
|
||||
.append {
|
||||
width: 20px;
|
||||
}
|
||||
}
|
||||
|
||||
@media only screen and (max-width: 1000px) {
|
||||
.specClass {
|
||||
width: 100% !important;
|
||||
margin-top: 20px;
|
||||
margin-left: 0;
|
||||
|
||||
.append {
|
||||
width: 43px;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
.specTypeClass {
|
||||
width: 22% !important;
|
||||
}
|
||||
|
||||
@media only screen and (max-width: 1000px) {
|
||||
.specTypeClass {
|
||||
width: 100% !important;
|
||||
}
|
||||
}
|
||||
|
||||
.selectClass {
|
||||
width: 100%;
|
||||
}
|
||||
|
||||
.tagClass {
|
||||
float: right;
|
||||
margin-right: 10px;
|
||||
font-size: 12px;
|
||||
margin-top: 5px;
|
||||
}
|
||||
|
||||
.logText {
|
||||
line-height: 22px;
|
||||
font-size: 12px;
|
||||
|
||||
.link {
|
||||
font-size: 12px;
|
||||
margin-top: -3px;
|
||||
|
||||
@@ -74,7 +74,7 @@ const submit = async () => {
|
||||
.then(() => {
|
||||
loading.value = false;
|
||||
emit('search');
|
||||
MsgSuccess(i18n.global.t('commons.msg.deleteSuccess'));
|
||||
MsgSuccess(i18n.global.t('commons.msg.operationSuccess'));
|
||||
dialogVisible.value = false;
|
||||
})
|
||||
.catch(() => {
|
||||
|
||||
@@ -163,7 +163,7 @@ const buttons = [
|
||||
},
|
||||
},
|
||||
{
|
||||
label: i18n.global.t('commons.button.delete'),
|
||||
label: i18n.global.t('commons.button.unbind'),
|
||||
click: (row: Database.DatabaseInfo) => {
|
||||
onDelete(row);
|
||||
},
|
||||
|
||||
@@ -74,7 +74,7 @@ const submit = async () => {
|
||||
.then(() => {
|
||||
loading.value = false;
|
||||
emit('search');
|
||||
MsgSuccess(i18n.global.t('commons.msg.deleteSuccess'));
|
||||
MsgSuccess(i18n.global.t('commons.msg.operationSuccess'));
|
||||
dialogVisible.value = false;
|
||||
})
|
||||
.catch(() => {
|
||||
|
||||
@@ -163,7 +163,7 @@ const buttons = [
|
||||
},
|
||||
},
|
||||
{
|
||||
label: i18n.global.t('commons.button.delete'),
|
||||
label: i18n.global.t('commons.button.unbind'),
|
||||
click: (row: Database.DatabaseInfo) => {
|
||||
onDelete(row);
|
||||
},
|
||||
|
||||
@@ -74,7 +74,7 @@ const submit = async () => {
|
||||
.then(() => {
|
||||
loading.value = false;
|
||||
emit('search');
|
||||
MsgSuccess(i18n.global.t('commons.msg.deleteSuccess'));
|
||||
MsgSuccess(i18n.global.t('commons.msg.operationSuccess'));
|
||||
dialogVisible.value = false;
|
||||
})
|
||||
.catch(() => {
|
||||
|
||||
@@ -163,7 +163,7 @@ const buttons = [
|
||||
},
|
||||
},
|
||||
{
|
||||
label: i18n.global.t('commons.button.delete'),
|
||||
label: i18n.global.t('commons.button.unbind'),
|
||||
click: (row: Database.DatabaseInfo) => {
|
||||
onDelete(row);
|
||||
},
|
||||
|
||||
@@ -265,7 +265,7 @@
|
||||
link
|
||||
small
|
||||
@click="getDirSize(row, $index)"
|
||||
:loading="btnLoading == $index"
|
||||
:loading="btnLoading.includes($index)"
|
||||
>
|
||||
<span v-if="row.dirSize == undefined">
|
||||
{{ $t('file.calculate') }}
|
||||
@@ -387,7 +387,7 @@ const initData = () => ({
|
||||
});
|
||||
let req = reactive(initData());
|
||||
let loading = ref(false);
|
||||
let btnLoading = ref(-1);
|
||||
let btnLoading = ref([]);
|
||||
const paths = ref<FilePaths[]>([]);
|
||||
let pathWidth = ref(0);
|
||||
const history: string[] = [];
|
||||
@@ -638,7 +638,7 @@ const getDirSize = async (row: any, index: number) => {
|
||||
const req = {
|
||||
path: row.path,
|
||||
};
|
||||
btnLoading.value = index;
|
||||
btnLoading.value.push(index);
|
||||
await ComputeDirSize(req)
|
||||
.then(async (res) => {
|
||||
let newData = [...data.value];
|
||||
@@ -646,7 +646,7 @@ const getDirSize = async (row: any, index: number) => {
|
||||
data.value = newData;
|
||||
})
|
||||
.finally(() => {
|
||||
btnLoading.value = -1;
|
||||
btnLoading.value = btnLoading.value.filter((item) => item !== index);
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
@@ -202,7 +202,7 @@ const verifySpec = (rule: any, value: any, callback: any) => {
|
||||
!Number.isInteger(item.second) ||
|
||||
!Number.isInteger(item.week)
|
||||
) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
switch (item.specType) {
|
||||
@@ -215,7 +215,7 @@ const verifySpec = (rule: any, value: any, callback: any) => {
|
||||
item.minute < 0 ||
|
||||
item.minute > 59
|
||||
) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
break;
|
||||
@@ -228,7 +228,7 @@ const verifySpec = (rule: any, value: any, callback: any) => {
|
||||
item.minute < 0 ||
|
||||
item.minute > 59
|
||||
) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
break;
|
||||
@@ -241,36 +241,36 @@ const verifySpec = (rule: any, value: any, callback: any) => {
|
||||
item.minute < 0 ||
|
||||
item.minute > 59
|
||||
) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
break;
|
||||
case 'perDay':
|
||||
if (item.hour < 0 || item.hour > 23 || item.minute < 0 || item.minute > 59) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
break;
|
||||
case 'perNHour':
|
||||
if (item.hour < 0 || item.hour > 8784 || item.minute < 0 || item.minute > 59) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
break;
|
||||
case 'perHour':
|
||||
if (item.minute < 0 || item.minute > 59) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
case 'perNMinute':
|
||||
if (item.minute < 0 || item.minute > 527040) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
break;
|
||||
case 'perNSecond':
|
||||
if (item.second < 0 || item.second > 31622400) {
|
||||
callback(new Error(i18n.global.t('cronjob.specErr')));
|
||||
callback(new Error(i18n.global.t('toolbox.clam.specErr')));
|
||||
return;
|
||||
}
|
||||
break;
|
||||
|
||||
Reference in New Issue
Block a user