/**
 * Tencent is pleased to support the open source community by making Tars available.
 *
 * Copyright (C) 2016THL A29 Limited, a Tencent company. All rights reserved.
 *
 * Licensed under the BSD 3-Clause License (the "License"); you may not use this file except 
 * in compliance with the License. You may obtain a copy of the License at
 *
 * https://opensource.org/licenses/BSD-3-Clause
 *
 * Unless required by applicable law or agreed to in writing, software distributed 
 * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR 
 * CONDITIONS OF ANY KIND, either express or implied. See the License for the 
 * specific language governing permissions and limitations under the License.
 */

#ifndef NOTIFY_I_H
#define NOTIFY_I_H

#include "NotifyF.h"
#include "util/tc_common.h"
#include "util/tc_config.h"
#include "util/tc_mysql.h"
#include "servant/TarsLogger.h"
#include "LoadDbThread.h"

using namespace tars;

class NotifyImp : public Notify
{
public:
    /**
     * 初始化
     *
     * @return int
     */
    virtual void initialize();

    /**
     * 退出
     */
    virtual void destroy() {};

    /**
     * report
     * @param sServerName
     * @param sThreadId
     * @param sResult
     * @param current
     */
    virtual void reportServer(const string& sServerName, const string& sThreadId, const string& sResult, tars::TarsCurrentPtr current);

    /**
     * notify
     * @param sServerName
     * @param sThreadId
     * @param sCommand
     * @param sResult
     * @param current
     */
    virtual void notifyServer(const string& sServerName, NOTIFYLEVEL level, const string& sMessage, tars::TarsCurrentPtr current);

    /**
     * get notify info
     */
    virtual tars::Int32 getNotifyInfo(const tars::NotifyKey & stKey,tars::NotifyInfo &stInfo,tars::TarsCurrentPtr current);

    /*
     *reportNotifyInfo
     *@param info
     */
    virtual void reportNotifyInfo(const tars::ReportInfo & info, tars::TarsCurrentPtr current);

protected:

    void loadconf();

private:

    bool IsdbTableExist(const string& sTbName);

    void creatTb(const string &sTbName);

    bool IsNeedFilte(const string& sServerName,const string& sResult);

protected:
    TC_Mysql _mysqlConfig;
    string     _sql;                //创建表
    size_t   _maxPageSize;
    size_t   _maxPageNum;
   /*
     * 按模块配置过滤规则
     * key=default 表示全局规则
     * key=app.server具体模块规则
     * 模块规则匹配失败才匹配全局规则
       <tars>
         <filter>
            default=r1|r2
            MTT.HelloServer=r3|r4
         </filter> 
       </tars>
     */
   map<string,set<string> > _setFilter;
};

#endif