|
|
@@ -177,8 +177,14 @@ local function insertTargetMoZhuDB(targetDb)
|
|
|
LuaMongo.find(targetCollection, nil, MozhuQueryFiles)
|
|
|
local data = {}
|
|
|
if not LuaMongo.next(data) then
|
|
|
- initMoZhuDB(data)
|
|
|
+ return
|
|
|
end
|
|
|
+
|
|
|
+
|
|
|
+ if not data.ciyuanMoZhu then
|
|
|
+ data.ciyuanMoZhu = {}
|
|
|
+ initMoZhuDB(data.ciyuanMoZhu)
|
|
|
+ end
|
|
|
|
|
|
local targetMoZhuData = data.ciyuanMoZhu
|
|
|
local roleRankLen = #targetMoZhuData.roleRank
|
|
|
@@ -517,7 +523,7 @@ local function startMergeServer(dbList)
|
|
|
for _, coll in ipairs(MergeServerDefine.COLLECTIONS) do
|
|
|
if not MergeServerDefine.NO_INSERT_COLLECTIONS[coll] then
|
|
|
|
|
|
- print(string.format("========================开始处理集合: %s\n", coll))
|
|
|
+ print(string.format("========================开始处理集合: %s, %s\n", sourceDb, coll))
|
|
|
if coll == MergeServerDefine.COLLECTIONS[1] then
|
|
|
processCharColl(sourceDb, targetDb, coll)
|
|
|
elseif coll == MergeServerDefine.COLLECTIONS[3] then
|