脚本支持增量更新数据

TRS.WCM.Developer/贵州项目/3_sp_data_migration_wcmappendix.sql

@@ -67,8 +67,8 @@ CREATE PROCEDURE sp_data_migration_wcmappendix(IN prevAppendixId BIGINT(20),
       RELATEPHOTOIDS,
       APPDESC2,
       ATTRIBUTES,
-      AppFromType,
-      AppFromId
+      0,
+      0
     FROM trs_data_migration.wcmappendix
 		ORDER BY APPENDIXID asc;
 

TRS.WCM.Developer/贵州项目/3_sp_data_migration_wcmchannel.sql

@@ -110,12 +110,12 @@ CREATE PROCEDURE sp_data_migration_wcmchannel(IN prevChnlId BIGINT(20),
       VIEWPROPS,
       NEEDEDPROPS,
       INHERIT,
-      IsSubscribe,
-      ISPUSHABLE,
-      ISDISTRIBUTABLE,
-      CHANNELLOGO,
-      SEARCHWORDVALUE,
-      CHNLDESCPINYIN
+      0,
+      0,
+      0,
+      null,
+      null,
+      null
     FROM trs_data_migration.wcmchannel
 		ORDER BY channelid asc;
 

TRS.WCM.Developer/贵州项目/3_sp_data_migration_wcmchnldoc.sql

@@ -93,18 +93,19 @@ CREATE PROCEDURE sp_data_migration_wcmchnldoc(IN prevRecId BIGINT(20),
       DOCLEVEL,
       attachpic,
       POSCHNLID,
-      DocType,
-      ISTIMINGPUBLISH,
-      ACTIONTYPE,
-      PUBSTATUS,
-      GDORDER,
-      DOCAUTHOR,
-      ORIGINRECID,
-      DOCSOURCENAME,
-      TIMEDSTATUS,
-      CANCELPUBTIME
+      20,
+      0,
+      0,
+      0,
+      0,
+      null,
+      0,
+      null,
+      0,
+      null
     -- 迭代十五才有的字段 ACTIONUSER
     FROM trs_data_migration.wcmchnldoc
+    where CHNLID > 0 and SITEID > 0
     ORDER BY RECID ASC ;
 
 	DECLARE CONTINUE HANDLER FOR NOT FOUND SET isover = 1;
@@ -164,7 +165,7 @@ CREATE PROCEDURE sp_data_migration_wcmchnldoc(IN prevRecId BIGINT(20),
         THEN
           SET @RECID = f_RECID;
           SET f_RECID = f_RECID + recIdOffset;
-
+          set f_ORIGINRECID = f_RECID;
           SET @doc_offset_num = ifnull((SELECT offset_num FROM data_migration_offset WHERE table_name = doc_migr_table_name AND start_id < f_DOCID and  end_id >= f_DOCID), 0);
           SET f_DOCID = f_DOCID + @doc_offset_num;
           SET @channel_offset_num = ifnull((SELECT offset_num FROM data_migration_offset WHERE table_name = channel_migr_table_name AND start_id < f_CHNLID and  end_id >= f_CHNLID), 0);

TRS.WCM.Developer/贵州项目/3_sp_data_migration_wcmdocument.sql

@@ -172,14 +172,14 @@ CREATE PROCEDURE sp_data_migration_wcmdocument(IN prevDocId BIGINT(20),
       DOCFORM,
       DOCLEVEL,
       olddocpuburl,
-      AttachVideo,
-      AttachAudio,
-      ThumbFiles,
-      commentFlag,
-      readingMoodFlag,
-      FromType,
-      FromId,
-      OriginDocId
+      0,
+      0,
+      null,
+      null,
+      null,
+      0,
+      0,
+      0
 		FROM trs_data_migration.wcmdocument
 		ORDER BY docid asc;
 
@@ -287,6 +287,8 @@ CREATE PROCEDURE sp_data_migration_wcmdocument(IN prevDocId BIGINT(20),
           THEN
             SET @doc_offset_num = ifnull((SELECT offset_num FROM data_migration_offset WHERE table_name = migr_table_name AND start_id < f_OriginDocId and  end_id >= f_OriginDocId), docIdOffset);
             SET f_OriginDocId = f_OriginDocId + @doc_offset_num;
+          else
+            SET f_OriginDocId = f_DOCID;
           END IF;
           # 栏目ID
           SET @channel_offset_num = ifnull((SELECT offset_num FROM data_migration_offset WHERE table_name = channel_migr_table_name AND start_id < f_DOCCHANNEL and  end_id >= f_DOCCHANNEL), 0);

TRS.WCM.Developer/贵州项目/3_sp_data_migration_wcmmetatable.sql

@@ -61,7 +61,7 @@ CREATE PROCEDURE sp_data_migration_wcmmetatable(IN citySuffix VARCHAR(20),
             EXECUTE stmt;
             deallocate prepare stmt;
 
-            call sp_data_migration_wcmmetablexx(concat('wcmmetatable', f_TABLENAME), prevDocId, docIdOffset);
+            call sp_data_migration_wcmmetablexx(concat('wcmmetatable', f_TABLENAME), prevDocId, docIdOffset, channelIdOffset);
 
             select concat('完成更新 ', 'wcmmetatable', f_TABLENAME, '.MetaDataId & ChannelId') info;
         END IF ;

TRS.WCM.Developer/贵州项目/3_sp_data_migration_wcmwebsite.sql

@@ -96,12 +96,12 @@ CREATE PROCEDURE sp_data_migration_wcmwebsite(IN citySuffix VARCHAR(255), IN pre
       IsSubscribe,
       ISPUSHABLE,
       ISDISTRIBUTABLE,
-      OUTLINETEMPLATE,
-      CHNLOUTLINETEMP,
-      DETAILTEMPLATE,
-      SITEDESCPINYIN,
-      IDXPREFIX,
-      AUTOCHECK
+      0,
+      0,
+      0,
+      null,
+      null,
+      0
 		FROM trs_data_migration.wcmwebsite
 		ORDER BY siteid asc;
 

TRS.WCM.Developer/贵州项目/3_sp_data_migration_xwcmviewfieldinfo.sql

@@ -192,7 +192,7 @@ CREATE PROCEDURE sp_data_migration_xwcmviewfieldinfo(IN citySuffix VARCHAR(20),
             SET f_DBFIELD = f_DBFIELD + @db_offset_num;
 
             -- SET f_LIBFILEDID = f_LIBFILEDID + ;
-            SET f_FIELDGROUPID = null;
+            SET f_FIELDGROUPID = ifnull((SELECT METAVIEWFIELDGROUPID FROM trs_hycloud_iip.xwcmmetaviewfieldgroup WHERE METAVIEWID = f_VIEWID AND GROUPNAME = '基本属性'), 0);
 
             SET @ralation_offset_num = ifnull((SELECT offset_num FROM data_migration_offset WHERE table_name = view_migr_table_name AND start_id < f_RELATIONVIEWID and  end_id >= f_RELATIONVIEWID), 0);
             SET f_RELATIONVIEWID = f_RELATIONVIEWID + @ralation_offset_num;

TRS.WCM.Developer/贵州项目/3_sp_data_migration_xwcmviewinfo.sql

@@ -149,6 +149,28 @@ CREATE PROCEDURE sp_data_migration_xwcmviewinfo(IN citySuffix VARCHAR(20),
                   f_Attribute
                 );
 
+          SELECT ifnull(max(METAVIEWFIELDGROUPID), 0) into v_gpId from trs_hycloud_iip.xwcmmetaviewfieldgroup;
+          SET @savefieldgroup_sql =  concat('insert into ',
+                                             'trs_hycloud_iip.xwcmmetaviewfieldgroup (',
+                                                 'METAVIEWFIELDGROUPID,',
+                                                 'GROUPNAME,',
+                                                 'METAVIEWID,',
+                                                 'PARENTID,',
+                                                 'CRUSER,',
+                                                 'CRTIME,',
+                                                 'GROUPORDER',
+                                             ') ',
+                                             'values(',
+                                                (v_gpId + 1), ',',
+                                                '\'', '基本属性', '\',', f_VIEWINFOID, ',', 0,',',
+                                                '\'', 'admin', '\',',
+                                                '\'', now(), '\',',
+                                                '1',
+                                             ') ');
+          prepare stmt from @savefieldgroup_sql;
+          EXECUTE stmt;
+          deallocate prepare stmt;
+
           SET @log_sql = trs_data_migration.build_migration_log_sql(migr_table_name, @VIEWINFOID, now());
 
           prepare stmt from @log_sql;