Python 串口編程 AT指令控制簡訊
- 2020 年 1 月 6 日
- 筆記
#-*- 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=47r"); 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('OKrn')<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=4r"); pdus=""; hasMessage=True; while(pdus.find('rnOKrn')<=0): mydata2=ser.read(65536); pdus=pdus+mydata2; if(len(pdus)==6 and pdus=='rnOKrn'): hasMessage=False; break; #end if time.sleep(1); #end while if(hasMessage==False): hasNewMail=False; time.sleep(5); continue; #end if while(pdus.find('rnrnOKrn')<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=%dr"%(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
