# -*- coding: utf-8 -*-

#!/usr/bin/python
# -*- coding: utf-8 -*

from mysqlhelper import MySqLHelper
import json

db = MySqLHelper()

def bt_dt_save(data):
    try:
        obj = data[-1]
        sql2 = 'insert into dt_radar_boat_df_msg (object_id,lng,lat,height,minOfYear,second,direction,deviceTime,fusDevID,fps,cellid,msgCnt,nofobjects,dataSource,msgdata,isInside,serverTime,create_time) VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,now(),now()) on duplicate key update msgdata=values(msgdata), lng=values(lng), lat=values(lat), direction=values(direction), height=values(height), isInside=values(isInside), update_time=now()'
        ret = db.insertone(sql2, (obj['object_id'],"{:.8f}".format(obj['lng']),"{:.8f}".format(obj['lat']),"{:.2f}".format(obj['height']),obj['minOfYear'],obj['second'],"{:.2f}".format(obj['direction']),obj['time'],obj['speed'],obj['fps'],obj['cellid'],obj['msgCnt'],obj['nofobjects'],obj['dataSource'],json.dumps(data),obj['isInside']))
        print(f"数据库保存成功 {ret}:！")
    except Exception as e:
        print(e)
        pass

def bt_old_dt_clean():
    try:
        sql2 = 'update dt_radar_boat_df_msg set isInside = -1 where isInside =1'
        ret = db.update(sql2)
        print(f"数据库保存成功 {ret}:！")
    except Exception as e:
        print(e)
        pass

def bt_cy_save(data):
    try:
        obj = data[-1]
        sql2 = 'insert into dt_radar_boat_cy_msg (object_id,lng,lat,height,minOfYear,second,direction,deviceTime,fusDevID,fps,cellid,msgCnt,nofobjects,dataSource,msgdata,isInside,serverTime,create_time) VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,now(),now()) on duplicate key update msgdata=values(msgdata), lng=values(lng), lat=values(lat), direction=values(direction), height=values(height), isInside=values(isInside), update_time=now()'
        ret = db.insertone(sql2, (obj['object_id'],"{:.8f}".format(obj['lng']),"{:.8f}".format(obj['lat']),"{:.2f}".format(obj['height']),obj['minOfYear'],obj['second'],"{:.2f}".format(obj['direction']),obj['time'],obj['speed'],obj['fps'],obj['cellid'],obj['msgCnt'],obj['nofobjects'],obj['dataSource'],json.dumps(data),obj['isInside']))
        print(f"数据库保存成功 {ret}:！")
    except Exception as e:
        print(e)
        pass

def bt_old_cy_clean():
    try:
        sql2 = 'update dt_radar_boat_cy_msg set isInside = -1 where isInside =1'
        ret = db.update(sql2)
        print(f"数据库保存成功 {ret}:！")
    except Exception as e:
        print(e)
        pass
   


def uav_zte_dt_save(data):
    try:
        obj = data[-1]
        sql2 = 'insert into dt_radar_uav_zte_msg (object_id,lng,lat,height,minOfYear,second,direction,deviceTime,fusDevID,fps,cellid,msgCnt,nofobjects,dataSource,msgdata,isInside,serverTime,create_time) VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,now(),now()) on duplicate key update msgdata=values(msgdata), lng=values(lng), lat=values(lat), direction=values(direction), height=values(height), isInside=values(isInside), update_time=now()'
        ret = db.insertone(sql2, (obj['object_id'],"{:.8f}".format(obj['lng']),"{:.8f}".format(obj['lat']),"{:.2f}".format(obj['height']),obj['minOfYear'],obj['second'],"{:.2f}".format(obj['direction']),obj['time'],obj['speed'],obj['fps'],obj['cellid'],obj['msgCnt'],obj['nofobjects'],obj['dataSource'],json.dumps(data),obj['isInside']))
        #print(sql2)
        #print(obj)
        print(f"数据库更新成功 {ret}:！")
    except Exception as e:
        print(e)
        pass

def uav_zte_old_dt_clean():
    try:
        sql2 = 'update dt_radar_uav_zte_msg set isInside = -1 where isInside =1'
        ret = db.update(sql2)
        print(f"数据库保存成功 {ret}:！")
    except Exception as e:
        print(e)
        pass

def uav_hw_dt_save(object_id, track):
    try:
        obj = track[-1]
        sql2 = 'insert into dt_radar_uav_hw_msg (object_id,lng,lat,isInside,msgCnt,height,fusDevID,direction,second,deviceTime,msgdata,serverTime,create_time) VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,now(),now()) on duplicate key update msgdata=values(msgdata), lng=values(lng), lat=values(lat), height=values(height), fusDevID=values(fusDevID),direction=values(direction), msgCnt=values(msgCnt),update_time=now()'
        ret = db.insertone(sql2, (object_id,"{:.8f}".format(obj['lng']),"{:.8f}".format(obj['lat']),obj['isInside'],obj['batchSerial'],"{:.2f}".format(obj['height']),"{:.2f}".format(obj['velocityH']),obj['headH'],obj['second'],obj['deviceTime'],json.dumps(track)))
        print(f"数据库保存成功 {ret}:！")
    except Exception as e:
        print(e)
        pass

def uav_hw_old_dt_clean():
    try:
        sql2 = 'update dt_radar_uav_hw_msg set isInside = -1 where isInside =1'
        ret = db.update(sql2)
        print(f"数据库保存成功 {ret}:！")
    except Exception as e:
        print(e)
        pass


def main():
    print()    

if __name__ == '__main__':
    #print(time.strftime("%Y-%m-%d %H:%M:%S",time.localtime(1712900732)))
    main()