TRS.WCM.Developer/贵州项目/4_sp_city_appendix.sql

DROP PROCEDURE IF EXISTS sp_city_appendix;
DELIMITER $$
CREATE PROCEDURE sp_city_appendix(IN n INT,
                                   IN masIdOffset BIGINT(20))

  BEGIN

    # 每迁移一个wcm节点，@n 必须 +1
    SET @n = n;

    # 每个wcm节点，元数据表需要加上后缀，以区分同名元数据表
    SET @citySuffix = concat('_city', @n);

    #附件迁移
    # 迁移 MAS 视频，6个wcm节点的视频是在一起的。可重复执行。
    # 支持断点续传，上一次迁移的最后一个 xx ID
    SET @prevMaterialquoteId = ifnull((SELECT prev_id from data_migration_log where table_name = 'xwcmmaterial'), 0);
    SET @prevAppendixId = ifnull((SELECT prev_id from data_migration_log where table_name = 'wcmappendix'), 0);


    SET @wcmdocument_offset_num = ifnull((SELECT max(offset_num) FROM data_migration_offset WHERE table_name = 'wcmdocument'), 0);
    SET @docIdOffset = @wcmdocument_offset_num;
    #附件迁移
	  SET @maxAppendixId= IFNULL((SELECT MAX(appendixId) from trs_hycloud_iip.wcmappendix),0);
    SET @appendixIdOffset = @maxAppendixId - @prevAppendixId;
    call sp_data_migration_wcmappendix(@prevAppendixId, @appendixIdOffset, @docIdOffset);
    #处理素材表
    SET @maxNAppendixId= IFNULL((SELECT MAX(appendixId) from trs_hycloud_iip.wcmappendix),0);
    SET @nappendixIdOffset = @maxNAppendixId - @prevMaterialquoteId;
    call sp_data_migration_xwcmmaterial(@prevMaterialquoteId, @nappendixIdOffset, @docIdOffset, masIdOffset);

  END $$
DELIMITER ;