import socket
import time
import pymysql


HOST='192.168.1.1'
GPSPORT=8888

db=pymysql.connect(host='localhost',port=8889,user='root',password='root'
                    ,database='gpsdata')



def insertposn(posn):
        #print("Posn Below passed to DB Loop for Insetingn")
        #print(posn)
        db=pymysql.connect(host='localhost',port=8889,user='root',password='root'
                    ,database='gpsdata')

        sql="INSERT INTO `position`(`latitude`, `latns`, `longitude`, `longew`, `course`, `speed`,`time`)VALUES ('%s','%s','%s','%s','%s','%s','%s')"% (posn['lat'],posn['latns'],posn['long'],posn['longew'],posn['course'],posn['speed'],posn['time'])
        #print(sql)
        cursor=db.cursor()
        cursor.execute(sql)
        db.commit()
        db.close()
        #print("Completed db insertn")
        posn={'lat': '', 'long': '', 'time':'', 'latns': '', 'longew': '','course':'','speed':'' }

def dataparse(rdata):
     ndata=rdata.decode()
     ldata=ndata.splitlines()
     #print(ldata)
     return ldata

def extractposn(ldata,posn):
    for line in ldata:
        if '$GPGLL' in line:
            nline=line.split(sep=',')
            posn['lat']=nline[1]
            posn['latns']=nline[2]
            posn['long']=nline[3]
            posn['longew']=nline[4]
            #print("After Extracting Posn from GPGLL Stringn")
            #print(posn)

        if '$GPVTG' in line:
            cline=line.split(sep=',')
            posn['course']=cline[1]
            posn['speed']=cline[5]

        if (posn['lat']!='' or posn['long']!='') :
                t=time.localtime()
                year=t.tm_year
                month=t.tm_mon
                day=t.tm_mday
                hour=t.tm_hour
                minute=t.tm_min
                second=t.tm_sec
                posn['time']=str(year)+'-'+str(month)+'-'+str(day)+' '+str(hour)+':'+str(minute)+':'+str(second)
                insertposn(posn)


mysock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)

mysock.connect((HOST,GPSPORT))

for i in range(0,1000):
    posn={'lat': '', 'long': '', 'time':'', 'latns': '', 'longew': '','course':'','speed':'' }
    rdata=mysock.recv(1000)
    #print("Raw Data receivedn")
    #print(rdata)
    ldata=dataparse(rdata)
    #print("After Splitting data into linesn")
    #print(ldata)
    extractposn(ldata,posn)
    #print(" Value of i=%d" % (i,) )
#time.sleep(0.25)

mysock.close()