Skip to content

Commit

Permalink
feat(frontend): mysql工具箱支持格子内选择集群/实例/IP TencentBlueKing#6997
Browse files Browse the repository at this point in the history
# Reviewed, transaction id: 19102
  • Loading branch information
jinquantianxia committed Sep 23, 2024
1 parent 9e19abc commit a5bb050
Show file tree
Hide file tree
Showing 9 changed files with 178 additions and 53 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,6 @@ export async function generateRedisScaleUpdownCloneData(ticketData: TicketModel<
groupNum: clusterListMap[item.cluster_id].machine_pair_cnt,
version: item.db_version,
clusterType: clusters[item.cluster_id].cluster_type as RedisClusterTypes,
clusterTypeName: clusters[item.cluster_id].cluster_type_name,
currentCapacity: {
used: 1,
total: clusterListMap[item.cluster_id].cluster_capacity,
Expand Down
1 change: 0 additions & 1 deletion dbm-ui/frontend/src/locales/zh-cn.json
Original file line number Diff line number Diff line change
Expand Up @@ -3524,7 +3524,6 @@
"DB名称支持通配符_如Data_区分大小写_多个使用英文逗号_分号或换行分隔": "DB名称支持通配符_如Data_区分大小写_多个使用英文逗号_分号或换行分隔",
"统计视图": "统计视图",
"主机列表": "主机列表",
"DB名称支持通配符_如Data_区分大小写_多个使用英文逗号_分号或换行分隔": "DB名称支持通配符_如Data_区分大小写_多个使用英文逗号_分号或换行分隔",
"不允许输入系统库和特殊库,如mysql、sys 等": "不允许输入系统库和特殊库,如mysql、sys 等",
"DB名、表名不允许为空,忽略DB名、忽略表名不允许为 *": "DB名、表名不允许为空,忽略DB名、忽略表名不允许为 *",
"支持 %(指代任意长度字符串), ?(指代单个字符串), *(指代全部)三个通配符": "支持 %(指代任意长度字符串), ?(指代单个字符串), *(指代全部)三个通配符",
Expand Down
1 change: 0 additions & 1 deletion dbm-ui/frontend/src/types/auto-imports.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
// @ts-nocheck
// noinspection JSUnusedGlobalSymbols
// Generated by unplugin-auto-import
// biome-ignore lint: disable
export {}
declare global {
const EffectScope: (typeof import('vue'))['EffectScope'];
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -124,6 +124,7 @@
id: 0,
},
version: '',
is_stand_by: false,
});

export type IDataRowBatchKey = keyof Pick<IDataRow, 'dbPatterns' | 'ignoreDbs' | 'tablePatterns' | 'ignoreTables'>;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,20 +49,22 @@
@change="handleInstancesChange" />
</template>
<script lang="ts">
type InstanceInfo = ServiceReturnType<typeof checkMysqlInstances>[number];

const instanceWithSelectorMemo: { [key: string]: Record<string, boolean> } = {};
</script>
<script setup lang="ts">
import _ from 'lodash';
import { useI18n } from 'vue-i18n';

import TendbhaInstanceModel from '@services/model/mysql/tendbha-instance';
import { checkMysqlInstances } from '@services/source/instances';

import { ClusterTypes } from '@common/const';
import { ipPort, ipv4 } from '@common/regex';

import InstanceSelector, {
type InstanceSelectorValues,
type IValue,
type PanelListType,
} from '@components/instance-selector/Index.vue';
import TableEditInput from '@components/render-table/columns/input/index.vue';
Expand All @@ -81,6 +83,11 @@
db_module_name?: string;
master_domain?: string;
cluster_type?: string;
related_clusters?: InstanceInfo['related_clusters'];
related_instances?: {
cluster_id: number;
instance_address: string;
}[];
}

interface Props {
Expand All @@ -97,7 +104,7 @@
}

interface Exposes {
getValue: () => Promise<InstanceBasicInfo>;
getValue: () => Promise<Required<InstanceBasicInfo>>;
focus: () => void;
}

Expand All @@ -119,9 +126,10 @@
const isFocused = ref(false);
const isShowInstanceSelecotr = ref(false);
const localValue = ref('');
const selectedIntances = shallowRef<InstanceSelectorValues<TendbhaInstanceModel>>({ [ClusterTypes.TENDBHA]: [] });
const selectedIntances = shallowRef<InstanceSelectorValues<IValue>>({ [ClusterTypes.TENDBHA]: [] });

const instanceKey = `instance_${random()}`;
let modelValueLocal: InstanceBasicInfo;
instanceWithSelectorMemo[instanceKey] = {};

const rules = [
Expand Down Expand Up @@ -155,10 +163,17 @@
instanceWithSelectorMemo[instanceKey][instanceData.instance_address] = true;
if (
!modelValue.value?.instance_address ||
modelValue.value.instance_address !== instanceData.instance_address
modelValueLocal?.instance_address !== instanceData.instance_address
) {
modelValue.value = instanceData;
emits('instanceChange', instanceData);
modelValueLocal = _.cloneDeep({
...instanceData,
related_instances: data.map((item) => ({
cluster_id: item.cluster_id,
instance_address: item.instance_address,
})),
});
modelValue.value = modelValueLocal;
emits('instanceChange', modelValueLocal as Required<InstanceBasicInfo>);
}
return true;
}),
Expand Down Expand Up @@ -207,6 +222,11 @@
} else {
localValue.value = `${modelValue.value.bk_cloud_id}:${modelValue.value.ip}:${modelValue.value.port}`;
}
if (modelValueLocal?.ip !== modelValue.value?.ip) {
setTimeout(() => {
inputRef.value.getValue();
});
}
},
{
immediate: true,
Expand All @@ -218,9 +238,9 @@
};

// 批量选择
const handleInstancesChange = (selected: InstanceSelectorValues<TendbhaInstanceModel>) => {
const handleInstancesChange = (selected: InstanceSelectorValues<IValue>) => {
selectedIntances.value = selected;
const list = selected[ClusterTypes.TENDBHA];
const list = _.flatMap(Object.values(selected));
if (props.type === 'instance') {
localValue.value = list[0].instance_address;
} else if (props.type === 'ip') {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -127,17 +127,18 @@

const handleSubmit = () => {
isSubmitting.value = true;
tableRef.value!.getValue().then((infos: MySQLProxySwitchDetails['infos']) => {
createTicket({
bk_biz_id: window.PROJECT_CONFIG.BIZ_ID,
ticket_type: TicketTypes.MYSQL_PROXY_SWITCH,
remark: '',
details: {
infos,
is_safe: isSafe.value,
},
})
.then((data) => {
tableRef
.value!.getValue()
.then((infos: MySQLProxySwitchDetails['infos']) =>
createTicket({
bk_biz_id: window.PROJECT_CONFIG.BIZ_ID,
ticket_type: TicketTypes.MYSQL_PROXY_SWITCH,
remark: '',
details: {
infos,
is_safe: isSafe.value,
},
}).then((data) => {
window.changeConfirm = false;
router.push({
name: 'MySQLProxyReplace',
Expand All @@ -148,11 +149,11 @@
ticketId: data.id,
},
});
})
.finally(() => {
isSubmitting.value = false;
});
});
}),
)
.finally(() => {
isSubmitting.value = false;
});
};

const handleReset = () => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,11 @@
<FixedColumn fixed="left">
<RenderOriginalProxyHost
ref="originRef"
v-model="localIp"
@input-finish="handleOriginProxyInputFinish" />
:cluster-types="['TendbhaHost']"
:model-value="data.originProxy"
:tab-list-config="tabListConfig"
type="ip"
@instance-change="handleOriginProxyInputFinish" />
</FixedColumn>
<td style="padding: 0">
<RenderRelatedInstances
Expand Down Expand Up @@ -45,7 +48,7 @@
rowKey: string;
originProxy: {
ip: string;
bk_cloud_id: number | null;
bk_cloud_id: number;
bk_host_id: number;
bk_biz_id: number;
port: number;
Expand All @@ -55,7 +58,7 @@
instance: string;
}[];
targetProxy: {
bk_cloud_id: number | null;
bk_cloud_id: number;
bk_host_id: number;
bk_biz_id: number;
cluster_id: number;
Expand All @@ -79,14 +82,14 @@
cluster_ids: number[];
origin_proxy: {
ip: string;
bk_cloud_id: number | null;
bk_cloud_id: number;
bk_host_id: number;
bk_biz_id: number;
port?: number;
};
target_proxy: {
ip: string;
bk_cloud_id: number | null;
bk_cloud_id: number;
bk_host_id: number;
bk_biz_id: number;
port?: number;
Expand All @@ -101,7 +104,7 @@
data.originProxy ||
({
ip: '',
bk_cloud_id: null,
bk_cloud_id: 0,
bk_host_id: 0,
bk_biz_id: 0,
port: 0,
Expand All @@ -111,7 +114,7 @@
data.targetProxy ||
({
ip: '',
bk_cloud_id: null,
bk_cloud_id: 0,
bk_host_id: 0,
bk_biz_id: 0,
port: 0,
Expand All @@ -120,25 +123,58 @@
</script>
<script setup lang="ts">
import { ref } from 'vue';
import { useI18n } from 'vue-i18n';

import FixedColumn from '@components/render-table/columns/fixed-column/index.vue';
import OperateColumn from '@components/render-table/columns/operate-column/index.vue';

import RenderOriginalProxyHost from '@views/db-manage/mysql/common/edit-field/InstanceWithSelector.vue';

import RenderTargetProxy from '../../../common/RenderTargetProxy.vue';
import RenderOriginalProxyHost from '../RenderOriginalProxyHost.vue';
import RenderRelatedInstances from '../RenderRelatedInstances.vue';

const props = defineProps<Props>();

const emits = defineEmits<Emits>();

const { t } = useI18n();

const originRef = ref<InstanceType<typeof RenderOriginalProxyHost>>();
const relatedInstancesRef = ref<InstanceType<typeof RenderRelatedInstances>>();
const targetRef = ref<InstanceType<typeof RenderTargetProxy>>();

const localIp = ref('');
const localRelatedInstances = ref<IDataRow['relatedInstances']>([]);

const tabListConfig = {
TendbhaHost: [
{
id: 'TendbhaHost',
name: t('目标Proxy主机'),
tableConfig: {
firsrColumn: {
label: t('Proxy 主机'),
field: 'ip',
role: 'proxy',
},
multiple: false,
},
},
{
id: 'manualInput',
name: t('手动输入'),
tableConfig: {
firsrColumn: {
label: t('Proxy 主机'),
field: 'ip',
role: 'proxy',
},
multiple: false,
},
},
],
} as any;

watch(
() => props.data,
() => {
Expand All @@ -149,8 +185,18 @@
},
);

const handleOriginProxyInputFinish = (value: IDataRow['relatedInstances']) => {
localRelatedInstances.value = value;
const handleOriginProxyInputFinish = (info: {
ip: string;
related_instances: {
cluster_id: number;
instance_address: string;
}[];
}) => {
localIp.value = info.ip;
localRelatedInstances.value = info.related_instances.map((item) => ({
cluster_id: item.cluster_id,
instance: item.instance_address,
}));
};

const handleAppend = () => {
Expand All @@ -171,7 +217,13 @@
relatedInstancesRef.value!.getValue(),
targetRef.value!.getValue(),
]).then(([originData, relatedInstancesData, targetData]) => ({
...originData,
origin_proxy: {
ip: originData.ip,
bk_cloud_id: originData.bk_cloud_id,
bk_host_id: originData.bk_host_id,
bk_biz_id: window.PROJECT_CONFIG.BIZ_ID,
port: originData.port,
},
...relatedInstancesData,
...targetData,
}));
Expand Down
Loading

0 comments on commit a5bb050

Please sign in to comment.