#!/usr/bin/env python
# coding=gbk
from os.path import getsize
import sys
import re
import time
import datetime
import os
from re import compile,IGNORECASE
import smtplib
from email.MIMEText import MIMEText
import socket
reload(sys)
sys.setdefaultencoding('gbk')

##日誌檔案
log = r'tomcat.log'
##每次執行後的位置，保證不重複統計
 

last_position_logfile = r'pos.txt'

##獲取儲存的位置
def get_last_position(file):
    data = open(file,'r')
    last_position = data.readline()
    if last_position:
        last_position = int(last_position)
    else:
        last_position = 0
    data.close()
    return last_position

##儲存上次讀寫後的位置
def write_this_position
 
(file,last_position):
    data = open(file,'w')
    data.write(str(last_position))
    data.close()

##獲取主機ip
def getIpaddr():
    myname = socket.getfqdn(socket.gethostname())
    myaddr = socket.gethostbyname(myname)
    return myaddr

##解析日誌檔案
def anlysis_log(file):
    ##設定超時告警閾值
    timeout_count_threshold=5
 

    msg_result={}
    currentTime=time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
    ip = getIpaddr()
    data = open(file,'r')
    last_position = get_last_position(last_position_logfile)
    this_position = getsize(log)
    ##快速定位位置
    if this_position < last_position:
        data.seek(0)
    elif this_position == last_position:
        exit()
    elif this_position > last_position:
        data.seek(last_position)

    ##迴圈讀取日誌行
    for line in data.readlines():
        ##正則匹配
        match=re.search(r'(ASClient)(.*)(elapsed=\d{5})(.*)(method=.*)(.*)(servicename=.*),',line)
        if ( not match ):
            pass
        else:
            msg_method=match.group(5).split(',')[0].split('=')[1]
            msg_service=match.group(7).split(',')[0].split('=')[1]
            if msg_service not in msg_result:
                msg_result[msg_service]={'timeout_total':0}
            if msg_method not in msg_result[msg_service]:
                msg_result[msg_service][msg_method]={'timeout':0}
            msg_result[msg_service]['timeout_total']+=1
            msg_result[msg_service][msg_method]['timeout']+=1   
    for (k,v) in msg_result.items():
        if ( (k=='test') and v['timeout_total']>timeout_count_threshold ):
            msg_report=''
            for (x,y) in v.items():
                if(x != 'timeout_total'):
                    pp='  %s [超時次數:%s],'% (x,y['timeout'])
                    msg_report=msg_report+pp          
            content='%s超時次數為%s, IP:%s'%(k.upper(),v['timeout_total'],ip)

            sendmail('IP:%s, %s呼叫超時次數為:%s, 超時閥值為10秒, 具體的method如下:<br>%s'%(ip,k,v['timeout_total'],msg_report.replace(',','<br>')),'[報警]系統%s超時'%k.upper())

    ##把當前位置儲存到檔案
    write_this_position(last_position_logfile,data.tell())
    data.close()
    print time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))

def sendmail(content,subject):
    url = r"smtp.163.com"
    sender = '[email protected]'
    receivers = ['[email protected]']
    msg = MIMEText(content,'html','gbk')
    msg['Subject'] = subject
    msg['To'] = ",".join(receivers)
    conn = smtplib.SMTP(url,25)
    conn.sendmail(sender,receivers,msg.as_string())
    conn.close()

anlysis_log(log)