#!/usr/bin/env
# -*- coding: utf-8 -*-


import os
import subprocess


def main():
    # 给定的变量列表
    names = [
        "tagsystem", "game_model_luckpresent", "follow", "game_data",
        "cc_basegroup_web", "coreservice_datastore", "mobile_data_ai",
        "dividentv34", "audiotiev34", "tempv34", "beaconmonitorv34",
        "friendv34", "statisticslog", "appgames", "newactivity",
        "appstatistics", "importantactivity", "goodvoice",
        "gamecoperation_app", "riskctl_bigdata", "webcc_dirdata_plaform",
        "audio_social_ocean", "ccfrontend"
    ]
    
    print("开始检查MongoDB配置文件...")
    
    for name in names:
        # 构建配置文件路径
        config_path = "/home/cc/oceanmongos/conf/mongodb{}/mongors.conf".format(name)
        
        # 检查配置文件是否存在
        if os.path.exists(config_path):
            print("发现配置文件: {}".format(config_path))
            
            # 构建rsync命令
            rsync_cmd = "rsync -avzCL --port=8873 cc@ccadmin2.x.netease.com::mongos_output/mongors_{}.conf /home/cc/oceanmongos/conf/mongodb{}/mongors.conf".format(name, name)
            
            try:
                # 执行rsync命令
                print("正在同步: {}".format(name))
                result = subprocess.call(rsync_cmd, shell=True)
                
                if result == 0:
                    print("✓ 同步成功: {}".format(name))
                else:
                    print("✗ 同步失败: {} (返回码: {})".format(name, result))
                    
            except Exception as e:
                print("✗ 执行异常: {} - {}".format(name, str(e)))
        else:
            print("配置文件不存在，跳过: {}".format(config_path))


if __name__ == "__main__":
    main()