#!/usr/bin/env python
# _*_ coding: utf-8 _*_
'''
# @Time    : 2018/1/17 21:54
# @Author  : Soner
# @version : V1.0
# @license : Copyright(C), Your Company
# @實(shí)現(xiàn)的功能：
            1.單APK包的上下行及總流量監(jiān)測(cè)
            2.定時(shí)備份
            3.定時(shí)發(fā)送郵件提醒
'''
import time
import subprocess
import xlwt
import os
import shutil
import datetime
# ----------------- 獲取設(shè)備UID -----------------
def getUid(package_name):#獲取UID
    cmd = 'adb shell dumpsys package ' + package_name + ' | findstr userId'
    p1 = subprocess.Popen(cmd, shell = True,
    stdout=subprocess.PIPE, stderr = subprocess.PIPE)#用adb獲取信息
    uidLongString = str(p1.stdout.read().strip(), encoding="utf-8")
    uidLongList = uidLongString.split("=")
    uid = uidLongList[1]
    return uid[0:5]
# ----------------- 計(jì)算設(shè)備流量 -----------------
def getFlowFromUid(packagename, uid=None):
    '''
    # 通過(guò)應(yīng)用uid，獲取應(yīng)用當(dāng)前消耗的流量
    # 獲取PID adb shell ps | findstr 包名   如果是LINUx 系統(tǒng) findstr 換成 grep
    # 獲取網(wǎng)絡(luò)標(biāo)識(shí)及流量 “adb shell cat /proc/應(yīng)用PID碼/net/dev”
    # return (rcv,snd)
    '''
    if uid is None:
        uid = getUid(packagename)
    cmd = 'adb shell cat /proc/net/xt_qtaguid/stats | findstr %s' % uid
    std = os.popen(cmd)
    net_rcv_bck = []
    net_rcv_front = []
    net_snd_bck = []
    net_snd_front = []
    lo_rcv_bck = []
    lo_rcv_front = []
    lo_snd_bck = []
    lo_snd_front = []
    for line in std:        # if 判斷里的 “ccmni0”根據(jù)使用的SIM卡變換，具體的需要先去查詢(xún)改掉這里，不然會(huì)出錯(cuò)“adb shell cat /proc/應(yīng)用PID碼/net/dev”
        data = line.split()
        if 'ccmni0' in line:
            background_flow = int(data[4]) == 0
            if background_flow:
                net_rcv_bck.append(int(data[5]))
                net_snd_bck.append(int(data[7]))
            else:
                net_rcv_front.append(int(data[5]))
                net_snd_front.append(int(data[7]))
        elif 'lo' in line:
            background_flow = int(data[4]) == 0
            if background_flow:
                lo_rcv_bck.append(int(data[5]))
                lo_snd_bck.append(int(data[7]))
            else:
                lo_rcv_front.append(int(data[5]))
                lo_snd_front.append(int(data[7]))
    return sum(net_rcv_bck), sum(net_rcv_front), sum(net_snd_bck), sum(net_snd_front), \
            sum(lo_rcv_bck), sum(lo_rcv_front), sum(lo_snd_bck), sum(lo_snd_front)
# ----------------- 發(fā)送郵件 -----------------
''''' 
函數(shù)說(shuō)明：Send_email_text() 函數(shù)實(shí)現(xiàn)發(fā)送帶有附件的郵件，可以群發(fā)，附件格式包括：xlsx,pdf,txt,jpg,mp3等 
參數(shù)說(shuō)明： 
    1. subject：郵件主題 
    2. content：郵件正文 
    3. filepath：附件的地址, 輸入格式為["","",...] 
    4. receive_email：收件人地址, 輸入格式為["","",...] 
'''  
def Send_email_text(subject,content,filepath,receive_email):  
    import smtplib  
    from email.mime.multipart import MIMEMultipart   
    from email.mime.text import MIMEText   
    from email.mime.application import MIMEApplication  
    sender = "Youn Email"  # 發(fā)送人的賬號(hào)， 已配置為 163 郵箱服務(wù)，如果使用其它的郵箱，可在方法下面修改
    passwd = "PASSWORD"     # 發(fā)送人的密碼  
    receivers = receive_email   #收件人郵箱  
    msgRoot = MIMEMultipart()   
    msgRoot['Subject'] = subject  
    msgRoot['From'] = sender  
    if len(receivers)>1:  
        msgRoot['To'] = ','.join(receivers) #群發(fā)郵件  
    else:  
        msgRoot['To'] = receivers[0]  
    part = MIMEText(content)   
    msgRoot.attach(part)  
    ##添加附件部分--可以自己追加類(lèi)型，或者全部打開(kāi)自動(dòng)判斷  
    for path in filepath:
        # if ".jpg" in path:
        #     #jpg類(lèi)型附件
        #     jpg_name = path.split("\\")[-1]
        #     part = MIMEApplication(open(path,'rb').read())
        #     part.add_header('Content-Disposition', 'attachment', filename=jpg_name)
        #     msgRoot.attach(part)
        #
        # if ".pdf" in path:
        #     #pdf類(lèi)型附件
        #     pdf_name = path.split("\\")[-1]
        #     part = MIMEApplication(open(path,'rb').read())
        #     part.add_header('Content-Disposition', 'attachment', filename=pdf_name)
        #     msgRoot.attach(part)
        if ".xls" in path:  
            #xlsx類(lèi)型附件  
            xlsx_name = path.split("\\")[-1]  
            part = MIMEApplication(open(path,'rb').read())   
            part.add_header('Content-Disposition', 'attachment', filename=xlsx_name)  
            msgRoot.attach(part)  
        # if ".txt" in path:
        #     #txt類(lèi)型附件
        #     txt_name = path.split("\\")[-1]
        #     part = MIMEApplication(open(path,'rb').read())
        #     part.add_header('Content-Disposition', 'attachment', filename=txt_name)
        #     msgRoot.attach(part)
        #
        # if ".mp3" in path:
        #     #mp3類(lèi)型附件
        #     mp3_name = path.split("\\")[-1]
        #     part = MIMEApplication(open(path,'rb').read())
        #     part.add_header('Content-Disposition', 'attachment', filename=mp3_name)
        #     msgRoot.attach(part)
    try:
        global m
        m = smtplib.SMTP()  
        m.connect("smtp.163.com") #這里我使用的是163郵箱,也可以使用其它郵箱
        m.login(sender, passwd)  
        m.sendmail(sender, receivers, msgRoot.as_string())  
        print("郵件發(fā)送成功")  
    except smtplib.SMTPException as e:  
        print("Error, 發(fā)送失敗")  
    finally:  
        m.quit()
# ----------------- 創(chuàng)建EXCEL表格 -----------------
col =0
row =0
book_Mirror = xlwt.Workbook(encoding='utf-8', style_compression=0)  # 創(chuàng)建新的工作簿Mirror
sheet_load_Mirror = book_Mirror.add_sheet('流量', cell_overwrite_ok=True)  # 創(chuàng)建新的sheet，并命名為流量
sheet_load_Mirror.write(row, col, "時(shí)間")
sheet_load_Mirror.write(row, col + 1, "網(wǎng)絡(luò)下行(KB)")
sheet_load_Mirror.write(row, col + 2, "網(wǎng)絡(luò)上行(KB)")
sheet_load_Mirror.write(row, col + 3, "網(wǎng)絡(luò)總流量(KB)")
sheet_load_Mirror.write(row, col + 4, "本地下行(KB)")
sheet_load_Mirror.write(row, col + 5, "本地上行(KB)")
sheet_load_Mirror.write(row, col + 6, "本地總流量(KB)")
# ----------------- 需要監(jiān)測(cè)的包名 -----------------
time_end =0 # 監(jiān)測(cè)初始時(shí)間，單位秒
package_name_Mirror= "You 的APK名稱(chēng)"  # 改成自己需要測(cè)試的APk包名
uid = (getUid(package_name_Mirror))[0:5]
try:
    uid_sdk = getUid(package_name_Mirror)
    print(time.strftime('%Y-%m-%d   %H:%M:%S',time.localtime(time.time())) +'  uid =  '+str(uid_sdk))
except:
    print('獲取Mirror-uid失敗')
# ----------------- 定位文件目錄 -----------------
file_dir = "D:\\"   # 可改成自己的目錄，要與下邊對(duì)稱(chēng)
os.chdir(file_dir)
row =1
col =0
s = 1
net_bck_start_rx, net_front_start_rx, net_bck_start_tx, net_front_start_tx, \
lo_bck_start_rx, lo_front_start_rx, lo_bck_start_tx, lo_front_start_tx = getFlowFromUid(package_name_Mirror, uid)
net_start_rx = net_bck_start_rx + net_front_start_rx
net_start_tx = net_bck_start_tx + net_front_start_tx
lo_start_rx = lo_bck_start_rx + lo_front_start_rx
lo_start_tx = lo_bck_start_tx + lo_front_start_tx
i = 1
time_k,time_s = 0,0
while   time_end <= 259200:
    net_bck_end_rx, net_front_end_rx, net_bck_end_tx, net_front_end_tx, \
    lo_bck_end_rx, lo_front_end_rx, lo_bck_end_tx, lo_front_end_tx = getFlowFromUid(package_name_Mirror, uid)
    net_end_rx = net_bck_end_rx + net_front_end_rx
    net_end_tx = net_bck_end_tx + net_front_end_tx
    lo_end_rx = lo_bck_end_rx + lo_front_end_rx
    lo_end_tx = lo_bck_end_tx + lo_front_end_tx
    net_flow_rx, net_flow_tx = net_end_rx - net_start_rx, net_end_tx - net_start_tx
    lo_flow_rx, lo_flow_tx = lo_end_rx - lo_start_rx, lo_end_tx - lo_start_tx
    net_rx_kb, net_tx_kb = round(net_flow_rx / 1024, 3), round(net_flow_tx / 1024, 3)
    lo_rx_kb, lo_tx_kb = round(lo_flow_rx / 1024, 3), round(lo_flow_tx / 1024, 3)
    timeNow = time.strftime('%Y-%m-%d %H-%M-%S', time.localtime(time.time()))  # 獲取當(dāng)前時(shí)間用于輸出
    timenew = time.strftime('%Y-%m-%d %H-%M', time.localtime(time.time()))  # 獲取當(dāng)前時(shí)間用戶(hù)備份時(shí)的命名
    sheet_load_Mirror.write(row, col, timeNow)  # 寫(xiě)入時(shí)間
    sheet_load_Mirror.write(row, col + 1, net_rx_kb)  # 寫(xiě)入網(wǎng)絡(luò)下行(KB)
    sheet_load_Mirror.write(row, col + 2, net_tx_kb)  # 寫(xiě)入網(wǎng)絡(luò)上行(KB)
    sheet_load_Mirror.write(row, col + 3, round(net_rx_kb + net_tx_kb, 3))  # 寫(xiě)入網(wǎng)絡(luò)總流量(KB)
    sheet_load_Mirror.write(row, col + 4, lo_rx_kb)  # 寫(xiě)入本地上行(KB)
    sheet_load_Mirror.write(row, col + 5, lo_tx_kb)  # 寫(xiě)入本地下行(KB)
    sheet_load_Mirror.write(row, col + 6, round(lo_rx_kb + lo_tx_kb, 3))  # 寫(xiě)入本地總流量(KB)
    book_Mirror.save("d:\Mirror_Folw.xls")  # 保存EXCEL表
    print(" %s ---------- %s %s ----------" % (row, package_name_Mirror, timeNow))
    print(
          '網(wǎng)絡(luò)下行：', net_rx_kb, 'KB\t',
          '網(wǎng)絡(luò)上行：', net_tx_kb, 'KB\t',
          '網(wǎng)絡(luò)總流量', round(net_rx_kb + net_tx_kb, 3), 'KB\t\t',
          '本地下行：', lo_rx_kb, 'KB\t',
          '本地上行：', lo_tx_kb, 'KB\t',
          '本地總流量', round(lo_rx_kb + lo_tx_kb, 3), 'KB\t\n'
          )
    row = row + 1   # EXCEL表格追加下一行寫(xiě)入
    time.sleep(10)  # 控制監(jiān)測(cè)頻率
    time_end += 10  # 監(jiān)測(cè)計(jì)時(shí)器
    time_s += 10    # 備份計(jì)時(shí)器
    time_k += 10    # 郵件計(jì)時(shí)器
    # 定時(shí)備份
    if time_s == 300:
        shutil.copy("Mirror_Folw.xls", "d:\\test\\Mirror_Folw_%s.xls" % timenew)    # 改成自己需要復(fù)制的文件（此處的路徑為上面定位目錄），和復(fù)制后的文件路徑以及名稱(chēng)
        time_s = 0
        print('備份成功~！')
    try:
        # 定時(shí)發(fā)送郵件
        if time_end == (1800 * i):
            subject = "郵件標(biāo)題"
            content = "郵件正文"
            Mirror_path = "d:\\test\\Mirror_Folw_%s.xls" % timenew # 附件地址
            file_path = [Mirror_path]  # 可添加多個(gè)附件到郵箱
            receive_email = ["接收人的郵箱"]
            Send_email_text(subject,content,file_path,receive_email)
            i += 1
    except:
        continue
print("---------- END  統(tǒng)計(jì)時(shí)長(zhǎng)：%s----------" % str(time_k))

# add_header.py
def request(flow):
    flow.request.headers["X-Custom-Header"] = "Value"
    print(f"Modified headers for {flow.request.url}")

python3 r0capture.py -U -f com.example.app -v -p captured.pcap

from scapy.all import rdpcap, TCP, IP, Raw
packets = rdpcap('captured.pcap') # 加載 PCAP 文件
for pkt in packets:
    if IP in pkt and TCP in pkt and Raw in pkt:
        payload = pkt[Raw].load
        try:
            # 簡(jiǎn)單解碼 HTTP 請(qǐng)求行
            http_text = payload.decode('utf-8', errors='ignore')
            if http_text.startswith('GET') or http_text.startswith('POST'):
                print(f"發(fā)現(xiàn) HTTP 請(qǐng)求: {http_text.splitlines()[0]}")
        except:
            pass