344 lines
13 KiB
SQL
344 lines
13 KiB
SQL
-- OnboardX 公司、部门、岗位、合同模板及入职模板层级升级脚本
|
|
-- 适用数据库：MySQL 8.0+
|
|
-- 说明：
|
|
-- 1. 可重复执行，不会覆盖已经人工维护的归属数据。
|
|
-- 2. 仅对能够从现有岗位/入职模板关系中唯一确定的数据执行安全回填。
|
|
-- 3. 脚本末尾会输出仍需人工处理的数据，请先处理完再启用相关模板。
|
|
|
|
SET NAMES utf8mb4;
|
|
|
|
DROP PROCEDURE IF EXISTS `ob_scope_add_column_if_missing`;
|
|
DELIMITER $$
|
|
CREATE PROCEDURE `ob_scope_add_column_if_missing`(
|
|
IN p_table_name VARCHAR(128),
|
|
IN p_column_name VARCHAR(128),
|
|
IN p_column_definition VARCHAR(1000)
|
|
)
|
|
BEGIN
|
|
IF NOT EXISTS (
|
|
SELECT 1
|
|
FROM information_schema.COLUMNS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = p_table_name
|
|
AND COLUMN_NAME = p_column_name
|
|
) THEN
|
|
SET @ddl = CONCAT(
|
|
'ALTER TABLE `', p_table_name, '` ADD COLUMN `',
|
|
p_column_name, '` ', p_column_definition
|
|
);
|
|
PREPARE stmt FROM @ddl;
|
|
EXECUTE stmt;
|
|
DEALLOCATE PREPARE stmt;
|
|
END IF;
|
|
END$$
|
|
DELIMITER ;
|
|
|
|
DROP PROCEDURE IF EXISTS `ob_scope_add_index_if_missing`;
|
|
DELIMITER $$
|
|
CREATE PROCEDURE `ob_scope_add_index_if_missing`(
|
|
IN p_table_name VARCHAR(128),
|
|
IN p_index_name VARCHAR(128),
|
|
IN p_index_definition VARCHAR(1000)
|
|
)
|
|
BEGIN
|
|
IF NOT EXISTS (
|
|
SELECT 1
|
|
FROM information_schema.STATISTICS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = p_table_name
|
|
AND INDEX_NAME = p_index_name
|
|
) THEN
|
|
SET @ddl = CONCAT(
|
|
'ALTER TABLE `', p_table_name, '` ADD ', p_index_definition
|
|
);
|
|
PREPARE stmt FROM @ddl;
|
|
EXECUTE stmt;
|
|
DEALLOCATE PREPARE stmt;
|
|
END IF;
|
|
END$$
|
|
DELIMITER ;
|
|
|
|
DROP PROCEDURE IF EXISTS `ob_scope_add_unique_index_if_clean`;
|
|
DELIMITER $$
|
|
CREATE PROCEDURE `ob_scope_add_unique_index_if_clean`(
|
|
IN p_table_name VARCHAR(128),
|
|
IN p_column_name VARCHAR(128),
|
|
IN p_index_name VARCHAR(128)
|
|
)
|
|
BEGIN
|
|
IF NOT EXISTS (
|
|
SELECT 1
|
|
FROM information_schema.STATISTICS
|
|
WHERE TABLE_SCHEMA = DATABASE()
|
|
AND TABLE_NAME = p_table_name
|
|
AND INDEX_NAME = p_index_name
|
|
) THEN
|
|
SET @duplicate_count = 0;
|
|
SET @check_sql = CONCAT(
|
|
'SELECT COUNT(*) INTO @duplicate_count FROM (',
|
|
'SELECT `', p_column_name, '` FROM `', p_table_name, '` ',
|
|
'WHERE `', p_column_name, '` IS NOT NULL ',
|
|
'AND LENGTH(TRIM(`', p_column_name, '`)) > 0 ',
|
|
'GROUP BY `', p_column_name, '` HAVING COUNT(*) > 1',
|
|
') duplicated_values'
|
|
);
|
|
PREPARE stmt FROM @check_sql;
|
|
EXECUTE stmt;
|
|
DEALLOCATE PREPARE stmt;
|
|
|
|
IF @duplicate_count = 0 THEN
|
|
SET @ddl = CONCAT(
|
|
'ALTER TABLE `', p_table_name, '` ADD UNIQUE INDEX `',
|
|
p_index_name, '` (`', p_column_name, '`)'
|
|
);
|
|
PREPARE stmt FROM @ddl;
|
|
EXECUTE stmt;
|
|
DEALLOCATE PREPARE stmt;
|
|
END IF;
|
|
END IF;
|
|
END$$
|
|
DELIMITER ;
|
|
|
|
-- 入职模板增加所属部门。
|
|
CALL `ob_scope_add_column_if_missing`(
|
|
'ob_onboarding_template',
|
|
'DepartmentId',
|
|
'BIGINT NULL COMMENT ''所属部门Id'' AFTER `CompanyId`'
|
|
);
|
|
|
|
-- 合同模板增加所属公司和部门。暂时允许 NULL，以兼容待人工归类的历史模板。
|
|
CALL `ob_scope_add_column_if_missing`(
|
|
'ob_contract_template',
|
|
'CompanyId',
|
|
'BIGINT NULL COMMENT ''所属公司Id'' AFTER `Id`'
|
|
);
|
|
CALL `ob_scope_add_column_if_missing`(
|
|
'ob_contract_template',
|
|
'DepartmentId',
|
|
'BIGINT NULL COMMENT ''所属部门Id'' AFTER `CompanyId`'
|
|
);
|
|
|
|
-- 兼容尚未执行上一版部门迁移的数据库，重复调用不会新增重复字段。
|
|
CALL `ob_scope_add_column_if_missing`(
|
|
'ob_position',
|
|
'DepartmentId',
|
|
'BIGINT NULL COMMENT ''所属部门Id'' AFTER `CompanyId`'
|
|
);
|
|
CALL `ob_scope_add_column_if_missing`(
|
|
'ob_onboarding_task',
|
|
'DepartmentId',
|
|
'BIGINT NULL COMMENT ''所属部门Id'' AFTER `CompanyId`'
|
|
);
|
|
CALL `ob_scope_add_column_if_missing`(
|
|
'ob_employee',
|
|
'DepartmentId',
|
|
'BIGINT NULL COMMENT ''所属部门Id'' AFTER `CompanyId`'
|
|
);
|
|
|
|
-- 合同模板与岗位为多对多关系，一份通用合同可同时适用于多个岗位。
|
|
CREATE TABLE IF NOT EXISTS `ob_contract_template_position` (
|
|
`Id` BIGINT NOT NULL COMMENT '主键',
|
|
`ContractTemplateId` BIGINT NOT NULL COMMENT '合同模板Id',
|
|
`PositionId` BIGINT NOT NULL COMMENT '适用岗位Id',
|
|
`ExtJson` LONGTEXT NULL COMMENT '扩展信息',
|
|
`Status` VARCHAR(20) NULL DEFAULT 'enable' COMMENT '启用状态',
|
|
`CreateTime` DATETIME(3) NULL COMMENT '创建时间',
|
|
`UpdateTime` DATETIME(3) NULL COMMENT '更新时间',
|
|
`CreateUserId` BIGINT NULL COMMENT '创建者Id',
|
|
`UpdateUserId` BIGINT NULL COMMENT '修改者Id',
|
|
`CreateUser` VARCHAR(200) NULL COMMENT '创建人',
|
|
`UpdateUser` VARCHAR(200) NULL COMMENT '更新人',
|
|
`IsDelete` TINYINT(1) NULL DEFAULT 0 COMMENT '软删除',
|
|
PRIMARY KEY (`Id`),
|
|
UNIQUE KEY `uk_ob_contract_template_position` (`ContractTemplateId`, `PositionId`),
|
|
KEY `idx_ob_contract_template_position_position` (`PositionId`, `ContractTemplateId`)
|
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='合同模板适用岗位';
|
|
|
|
CALL `ob_scope_add_index_if_missing`(
|
|
'ob_position',
|
|
'idx_ob_position_department_status',
|
|
'INDEX `idx_ob_position_department_status` (`DepartmentId`, `Status`, `IsDelete`)'
|
|
);
|
|
CALL `ob_scope_add_index_if_missing`(
|
|
'ob_onboarding_template',
|
|
'idx_ob_onboarding_template_scope',
|
|
'INDEX `idx_ob_onboarding_template_scope` (`CompanyId`, `DepartmentId`, `Status`, `IsDelete`)'
|
|
);
|
|
CALL `ob_scope_add_index_if_missing`(
|
|
'ob_contract_template',
|
|
'idx_ob_contract_template_scope',
|
|
'INDEX `idx_ob_contract_template_scope` (`CompanyId`, `DepartmentId`, `Status`, `IsDelete`)'
|
|
);
|
|
CALL `ob_scope_add_index_if_missing`(
|
|
'ob_onboarding_task',
|
|
'idx_ob_onboarding_task_department',
|
|
'INDEX `idx_ob_onboarding_task_department` (`DepartmentId`, `TaskStatus`, `IsDelete`)'
|
|
);
|
|
CALL `ob_scope_add_index_if_missing`(
|
|
'ob_employee',
|
|
'idx_ob_employee_department',
|
|
'INDEX `idx_ob_employee_department` (`DepartmentId`, `IsDelete`)'
|
|
);
|
|
|
|
-- 身份证号和手机号是正式员工防重复的数据库最终防线。
|
|
-- 若历史数据已经重复，本次会安全跳过建索引，并由脚本末尾查询列出冲突数据。
|
|
CALL `ob_scope_add_unique_index_if_clean`(
|
|
'ob_employee',
|
|
'IdCardNumber',
|
|
'uk_ob_employee_id_card'
|
|
);
|
|
CALL `ob_scope_add_unique_index_if_clean`(
|
|
'ob_employee',
|
|
'Phone',
|
|
'uk_ob_employee_phone'
|
|
);
|
|
|
|
-- 安全回填入职模板部门：只有全部适用岗位均属于同一个非空部门时才回填。
|
|
UPDATE `ob_onboarding_template` template
|
|
INNER JOIN (
|
|
SELECT
|
|
relation.`OnboardingTemplateId`,
|
|
MIN(position.`DepartmentId`) AS `DepartmentId`
|
|
FROM `ob_onboarding_template_position` relation
|
|
INNER JOIN `ob_position` position ON position.`Id` = relation.`PositionId`
|
|
WHERE COALESCE(relation.`IsDelete`, 0) = 0
|
|
AND COALESCE(position.`IsDelete`, 0) = 0
|
|
GROUP BY relation.`OnboardingTemplateId`
|
|
HAVING COUNT(*) > 0
|
|
AND COUNT(DISTINCT position.`DepartmentId`) = 1
|
|
AND SUM(position.`DepartmentId` IS NULL) = 0
|
|
) source ON source.`OnboardingTemplateId` = template.`Id`
|
|
SET template.`DepartmentId` = source.`DepartmentId`
|
|
WHERE template.`DepartmentId` IS NULL;
|
|
|
|
-- 安全回填合同模板公司、部门：只有历史引用的入职模板归属完全一致时才回填。
|
|
UPDATE `ob_contract_template` contract_template
|
|
INNER JOIN (
|
|
SELECT
|
|
relation.`ContractTemplateId`,
|
|
MIN(template.`CompanyId`) AS `CompanyId`,
|
|
MIN(template.`DepartmentId`) AS `DepartmentId`
|
|
FROM `ob_onboarding_template_contract` relation
|
|
INNER JOIN `ob_onboarding_template` template
|
|
ON template.`Id` = relation.`OnboardingTemplateId`
|
|
WHERE COALESCE(relation.`IsDelete`, 0) = 0
|
|
AND COALESCE(template.`IsDelete`, 0) = 0
|
|
GROUP BY relation.`ContractTemplateId`
|
|
HAVING COUNT(DISTINCT template.`CompanyId`) = 1
|
|
AND COUNT(DISTINCT template.`DepartmentId`) = 1
|
|
AND SUM(template.`DepartmentId` IS NULL) = 0
|
|
) source ON source.`ContractTemplateId` = contract_template.`Id`
|
|
SET contract_template.`CompanyId` = COALESCE(contract_template.`CompanyId`, source.`CompanyId`),
|
|
contract_template.`DepartmentId` = COALESCE(contract_template.`DepartmentId`, source.`DepartmentId`)
|
|
WHERE contract_template.`CompanyId` IS NULL
|
|
OR contract_template.`DepartmentId` IS NULL;
|
|
|
|
-- 根据历史入职模板关系，回填合同模板已经实际使用过的岗位范围。
|
|
INSERT IGNORE INTO `ob_contract_template_position` (
|
|
`Id`,
|
|
`ContractTemplateId`,
|
|
`PositionId`,
|
|
`Status`,
|
|
`CreateTime`,
|
|
`IsDelete`
|
|
)
|
|
SELECT DISTINCT
|
|
CAST(CONV(SUBSTRING(MD5(CONCAT(
|
|
'obctp:', contract_relation.`ContractTemplateId`, ':', position_relation.`PositionId`
|
|
)), 1, 15), 16, 10) AS UNSIGNED) AS `Id`,
|
|
contract_relation.`ContractTemplateId`,
|
|
position_relation.`PositionId`,
|
|
'enable',
|
|
NOW(3),
|
|
0
|
|
FROM `ob_onboarding_template_contract` contract_relation
|
|
INNER JOIN `ob_onboarding_template_position` position_relation
|
|
ON position_relation.`OnboardingTemplateId` = contract_relation.`OnboardingTemplateId`
|
|
INNER JOIN `ob_contract_template` contract_template
|
|
ON contract_template.`Id` = contract_relation.`ContractTemplateId`
|
|
INNER JOIN `ob_position` position
|
|
ON position.`Id` = position_relation.`PositionId`
|
|
WHERE COALESCE(contract_relation.`IsDelete`, 0) = 0
|
|
AND COALESCE(position_relation.`IsDelete`, 0) = 0
|
|
AND contract_template.`CompanyId` = position.`CompanyId`
|
|
AND contract_template.`DepartmentId` = position.`DepartmentId`;
|
|
|
|
DROP PROCEDURE IF EXISTS `ob_scope_add_unique_index_if_clean`;
|
|
DROP PROCEDURE IF EXISTS `ob_scope_add_index_if_missing`;
|
|
DROP PROCEDURE IF EXISTS `ob_scope_add_column_if_missing`;
|
|
|
|
-- 结果 1：仍未明确部门归属的岗位。必须在岗位管理中补齐。
|
|
SELECT
|
|
position.`Id`,
|
|
position.`PositionCode`,
|
|
position.`PositionName`,
|
|
position.`CompanyId`
|
|
FROM `ob_position` position
|
|
WHERE position.`DepartmentId` IS NULL
|
|
AND COALESCE(position.`IsDelete`, 0) = 0;
|
|
|
|
-- 结果 2：仍未明确部门归属的入职模板。必须编辑并重新保存。
|
|
SELECT
|
|
template.`Id`,
|
|
template.`TemplateCode`,
|
|
template.`TemplateName`,
|
|
template.`CompanyId`
|
|
FROM `ob_onboarding_template` template
|
|
WHERE template.`DepartmentId` IS NULL
|
|
AND COALESCE(template.`IsDelete`, 0) = 0;
|
|
|
|
-- 结果 3：仍未明确公司/部门或没有适用岗位的合同模板。必须编辑并重新保存。
|
|
SELECT
|
|
contract_template.`Id`,
|
|
contract_template.`TemplateCode`,
|
|
contract_template.`TemplateName`,
|
|
contract_template.`CompanyId`,
|
|
contract_template.`DepartmentId`,
|
|
COUNT(position_relation.`Id`) AS `PositionCount`
|
|
FROM `ob_contract_template` contract_template
|
|
LEFT JOIN `ob_contract_template_position` position_relation
|
|
ON position_relation.`ContractTemplateId` = contract_template.`Id`
|
|
AND COALESCE(position_relation.`IsDelete`, 0) = 0
|
|
WHERE COALESCE(contract_template.`IsDelete`, 0) = 0
|
|
GROUP BY
|
|
contract_template.`Id`,
|
|
contract_template.`TemplateCode`,
|
|
contract_template.`TemplateName`,
|
|
contract_template.`CompanyId`,
|
|
contract_template.`DepartmentId`
|
|
HAVING contract_template.`CompanyId` IS NULL
|
|
OR contract_template.`DepartmentId` IS NULL
|
|
OR COUNT(position_relation.`Id`) = 0;
|
|
|
|
-- 结果 4：检查层级不一致的数据，正常情况下应返回 0 行。
|
|
SELECT
|
|
contract_template.`Id` AS `ContractTemplateId`,
|
|
contract_template.`TemplateName`,
|
|
position.`Id` AS `PositionId`,
|
|
position.`PositionName`
|
|
FROM `ob_contract_template` contract_template
|
|
INNER JOIN `ob_contract_template_position` relation
|
|
ON relation.`ContractTemplateId` = contract_template.`Id`
|
|
INNER JOIN `ob_position` position ON position.`Id` = relation.`PositionId`
|
|
WHERE contract_template.`CompanyId` <> position.`CompanyId`
|
|
OR contract_template.`DepartmentId` <> position.`DepartmentId`;
|
|
|
|
-- 结果 5：正式员工身份证号或手机号重复时，唯一索引会被安全跳过；请清理后重新运行脚本。
|
|
SELECT
|
|
'IdCardNumber' AS `ConflictField`,
|
|
employee.`IdCardNumber` AS `ConflictValue`,
|
|
COUNT(*) AS `ConflictCount`
|
|
FROM `ob_employee` employee
|
|
WHERE NULLIF(TRIM(employee.`IdCardNumber`), '') IS NOT NULL
|
|
GROUP BY employee.`IdCardNumber`
|
|
HAVING COUNT(*) > 1
|
|
UNION ALL
|
|
SELECT
|
|
'Phone' AS `ConflictField`,
|
|
employee.`Phone` AS `ConflictValue`,
|
|
COUNT(*) AS `ConflictCount`
|
|
FROM `ob_employee` employee
|
|
WHERE NULLIF(TRIM(employee.`Phone`), '') IS NOT NULL
|
|
GROUP BY employee.`Phone`
|
|
HAVING COUNT(*) > 1;
|