#!/usr/bin/env python 
    #encoding=utf-8 
    import os, sys 
     
    def chk_err(log_file,tmp_file,type,print_list,port=""): 
        cur_num = int(os.popen("sudo grep '' %s | wc -l" % log_file).read().strip()) 
        old_num = 0 
        if os.path.exists(tmp_file): 
            old_num = int(open(tmp_file).read().strip()) 
            if cur_num < old_num: 
                os.popen("echo 0 > %s" % tmp_file) 
                old_num = 0 
        else: 
            os.popen("echo 0 > %s" % tmp_file) 
        err_log = os.popen("sudo grep -ni 'error' %s" % log_file).readlines() 
        if err_log: 
            err_list = [] 
            for err in err_log: 
                if int(err.split(":")[0]) > old_num: 
                    err_list.append(err[len(err.split(":")[0])+1:]) 
            if err_list: 
                os.popen("echo %s > %s" % (err_log[-1].split(":")[0], tmp_file)) 
                if type == "syslog": 
                    print "0" 
                elif type == "mysqllog": 
                    print_list.append(port) 
        elif not err_log and type == "syslog": 
            print "0" 
     
    def chk_err_log(type): 
        try: 
            print_list = [] 
            homedir = "/home/zabbix" 
            if not os.path.exists(homedir): 
                os.mkdir(homedir) 
            if type == "syslog": 
                log_file = "/var/log/messages" 
                tmp_file = "%s/.syslog_num"%homedir 
                chk_err(log_file,tmp_file,type,print_list) 
            elif type == "mysqllog": 
                psinfo = os.popen("ps -auxww|grep mysqld|grep -v root|grep -v grep").readlines() 
                if not psinfo: 
                    print "0" 
                for i in psinfo: 
                    for j in i.split("--"): 
                        if j.find("datadir") != -1: 
                            datadir = j.split("=")[1].strip() 
                        elif j.find("port") != -1: 
                            port = j.split("=")[1].strip() 
                    if port == "3306": 
                        log_file = "%s/$(hostname).err" % datadir 
                    else: 
                        log_file = "%s/mysql.err" % datadir 
                    tmp_file = "%s/.mysqllog_%s" % (homedir,port) 
                    chk_err(log_file,tmp_file,type,print_list,port) 
                if len(print_list)==0: 
                    print "0" 
                else: 
                    if type == "syslog": 
                        print "0" 
                    elif type == "mysqllog": 
                        print print_list 
        except Exception, e: 
            print e 
     
    if __name__ == "__main__": 
        chk_err_log(sys.argv[1])