Python 串口编程 AT指令控制短信

发布时间：2019-09-18 07:27:52编辑：auto阅读（2572）

#-*- encoding: gbk -*-
import time
import sys
import os
import locale
import string
import traceback
import datetime
import serial

reload(sys);
sys.setdefaultencoding('gbk');


def mysterious(ust):
    s="";
    for i in range(len(ust)/4):
        us=ust[i*4:i*4+4];
        s=s+unichr(int(us,16));
    #end for
    return s
#end 


def decodePDU(pdu):
    phonelen=int(pdu[20:22],16);
    b=pdu[24:25+phonelen];#38
    phone="";
    for i in range(1,phonelen+1,2):
        if(i!=phonelen):
            phone=phone+b[i]+b[i-1];
        else:
            phone=phone+b[i];
        #end if
    #end for
    afterphone=25+phonelen+4;
    c=pdu[afterphone:afterphone+12];
    mytime= c[1]+c[0]+'-'+c[3]+c[2]+'-'+c[5]+c[4]+' '+c[7]+c[6]+':'+c[9]+c[8]+':'+c[11]+c[10];
    #15-04-12 14:32:35
    datalength=int(pdu[afterphone+12+2:afterphone+12+4],16)*2;
    mydata=mysterious(pdu[afterphone+12+4:afterphone+12+4+datalength]);
    return (phone,mydata,mytime);
#end def


def getMailIndex():
    file = open('messageindex.txt',"r");
    lines = file.readlines();
    file.close();
    return time.strptime(lines[0], "%y-%m-%d %H:%M:%S");
#    


def setMailIndex(timestr):
    f = open('messageindex.txt', 'w');
    f.write(timestr);
    f.close();
#    


def _queryQuick(cu,sql,tuple):
    try:
        cu.execute(sql,tuple);
        rows = []
        for row in cu:
            rows.append(row)
        #
        return rows
    except:
        print(traceback.format_exc())
    #end 
#
#获取信息
def _queryRows(cu,sql):
    try:
        cu.execute(sql)
        rows = []
        for row in cu:
            rows.append(row)
        #
        return rows
    except:
        print(traceback.format_exc())
    #end 
#


def executeMessage(messagelist):
    for messagetuple in messagelist:
        article=messagetuple[1];
        origin=messagetuple[0];
        
        conn.commit();
        #判断用户是否是信任列表里的用户
        users=_queryQuick(cur,"select username from trusted_users where username=%s",(origin,));
        if(len(users)<1):
            print('the user %s is not trusted user,ignore the message: %s,continue search the message...'%(origin,article));
            time.sleep(5)
            continue;
        #end if
        #start send message'已收到短信');
        print 'start send message'
        ser.write("AT+CMGS=47\r");
        pdus3="";
        while(pdus3.find('> ')<0):
            mydata3=ser.read(12);
            pdus3=pdus3+mydata3;
            time.sleep(0.1);
        #end while
        PDUmsg='0891683108200005F011000D91683166607056F70008AA205DF26536523077ED4FE1FF0C4E2D697757FA91D1611F8C224E0E60A854084F5C';
        myphone=origin[1]+origin[0]+origin[3]+origin[2]+origin[5]+origin[4]+origin[7]+origin[6]+origin[9]+origin[8]+origin[11]+origin[10]+'F'+origin[12];
        PDUmsgAll=PDUmsg[0:26]+myphone+PDUmsg[40:];
        ser.write(PDUmsgAll+"\x1a");
        time.sleep(1);
        pdus4="";
        while(pdus4.find('OK\r\n')<0):
            mydata4=ser.read(65536);
            pdus4=pdus4+mydata4;
            time.sleep(0.1);
        #end while
        print 'end send message'
#end def


#全局已读的邮件数量
globalMailReaded=getMailIndex();
hasNewMail=True;
ser = serial.Serial('COM3', 9600);
print 'get new Message...'
while True:
    if(hasNewMail):
        globalMailReaded=getMailIndex();
    #end if
    ser.write("AT+CMGL=4\r");
    pdus="";
    hasMessage=True;
    while(pdus.find('\r\nOK\r\n')<=0):
        mydata2=ser.read(65536);
        pdus=pdus+mydata2;
        if(len(pdus)==6 and pdus=='\r\nOK\r\n'):
            hasMessage=False;
            break;
        #end if  
        time.sleep(1);
    #end while
    if(hasMessage==False):
        hasNewMail=False;
        time.sleep(5);
        continue;
    #end if
    while(pdus.find('\r\n\r\nOK\r\n')<0):
        mydata=ser.read(65536);
        pdus=pdus+mydata;
        time.sleep(1);
    #end while
    strlist=pdus.split('+CMGL:');
    messagelist=[];
    pduCount=0;
    for str in strlist:
        index = str.find('0891');
        pduStr=str[index-1:].replace("\n", "");
        if(len(pduStr)>30):
            print pduStr;
            pduCount=pduCount+1;
            (phone2,mydata2,mytime2)=decodePDU(pduStr);
            Sms_Time=time.strptime(mytime2, "%y-%m-%d %H:%M:%S");
            if(Sms_Time>globalMailReaded):
                messagelist.append((phone2,mydata2));
                setMailIndex(mytime2);
                hasNewMail=True;
            #end if
        #end if
    #end for
    #删除旧短信
    print messagelist;
    print 'delete old message'
    time.sleep(1);
    if(pduCount>0):
        for j in range(25,0,-1):
            ATStr="AT+CMGD=%d\r"%(j);
            ser.write(ATStr);
            ATReturn="";
            while(ATReturn.find('OK')<0):
                mydata=ser.read(65536);
                ATReturn=ATReturn+mydata;
                time.sleep(0.05);
            #end while
        #end for
        print('has deleted all messages');
    #end if    
    if(len(messagelist)>0):
        executeMessage(messagelist);
    else:
        hasNewMail=False;
    #end if
    time.sleep(1);
#end while

关键字：