mytodattime = datetime.datetime.now()

myEID=(int)(E_status)

if myEID==1:

myaddstr="E"

else:

myaddstr = "A"

myfilename = str(mytodattime.year) + str(mytodattime.month) + str(mytodattime.day) + '-' + str(

mytodattime.hour) + '-' + str(mytodattime.minute) + '-' + str(mytodattime.second) + '-'+ str(mydtuadd2)+str(myaddstr)

print(myfilename)

myzsqid = 0

mystatus = 0

# mydata=bytes((0x01,0x2,0x03,0x4,0x05,0x06))

# print(mydata)

myls = ''

my_value = list(mydata)

myzsqid = my_value[0] + my_value[1] * 256+myEID*10

mytimer2 = my_value[2] + my_value[3] * 256

mygettime = str(my_value[10]) + '-' + str(my_value[9]) + '-' + str(my_value[8]) + '=' + str(

my_value[7]) + ':' + str(my_value[6]) + ':' + str(my_value[4])

myls=myls+str(mydtuadd2)+ '\n'

myls = myls + str(myzsqid) + '\n'

myls = myls + str(mytimer2) + '\n'

myls = myls + str(mygettime) + '\n'

ii = 0

while ii < len(my_value) - 2:

# 存储原始数据

if ii <= 10:

pass

# y = my_value[ii]

# myls = myls + str(y) + '\n'

ii = ii + 1

# print(ii)

else:

# 直接进行转换

y = (my_value[ii] + my_value[ii + 1] * 256) / 10.0

myls = myls + str(y) + '\n'

ii = ii + 2

# print(ii)

# print(myls)

myfilename = myfilename + ".bat"

myfile = open(myfilename, "wt")

myfile.write(myls)

myfile.close()

# myservertime2

sqlstr = 'insert into tb_filename VALUES (' + str(mydtuadd2) + ",\'" + str(myservertime2) + "\'" + ',\'' + str(myfilename) + "\'" + ",\'" + myls + "\')"

#print(sqlstr)

my_str_short = [0x10, 0x80, 0x01, 0x00, 0x81, 0x16]

my_str_short[2] = (int)(my_dtu_add_low)

my_str_short[3] = (int)(my_dtu_add_high)

s2 = my_101_com_genert_CRC(my_str_short)

s3 = bytes(s2)

conn.sendall(s3)

my_all_step = 3

print("send data:", end='')

i = datetime.datetime.now()

time_count = i.hour * 3600 + i.minute * 60 + i.second

time_count2 = time_count % 65535

y = time_count2 % 256

x = time_count2 // 256

# s2 = bytes(s, 'utf-8')

if s == None:

return

print(datetime.datetime.now(), ": ", end='')

s2 = s

for i in s2:

print(hex(i), end='')

if i != s2[-1]:

print('-', end='')

# s2=bytes(s0,'utf-8')

s2 = s0

status = 0

for i in s2:

if i == 0x10:

my_start = s2.index(i)

status = 0x10

elif i == 0x68:

my_start = s2.index(i)

status = 0x68

else:

my_start = 0

status = 0

if status == 0x10:

if len(s2) < 5:

break

x = s2[my_start + 5]

if x == 0x16:

s3 = s2[my_start:my_start + 6]

break

elif status == 0x68:

if len(s2) < 10:

break

x = s2[my_start + 3]

if x == 0x68:

lenth = int(s2[my_start + 1])

s3 = s2[my_start:my_start + lenth + 6]

break

else:

s3 = None;

# s = str(s3, encoding="utf-8")

s = s3

s = s2

if s3 != None:

# print("source data:", end='')

# my_str_to_hex_display(s)

print("get data:", end='')

my_str_to_hex_display(s)

else:

print("None get data")

if s0[0] == 0x10:

crc = s0[1] + s0[2] + s0[3]

s0[4] = crc % 256

s0[5] = 0x16

else:

my_lenth = s0[1]

count = 0

for ii in range(0, my_lenth):

count = count + s0[ii + 4]

crc = count % 256

ii = ii + 1

s0[ii + 4] = crc

s0[ii + 5] = 0X16

s1 = s0

def __init__(self, host, user, pwd, db): # 类的构造函数，初始化数据库连接ip或者域名，以及用户名，密码，要连接的数据库名称

self.host = host

self.user = user

self.pwd = pwd

self.db = db

def __GetConnect(self): # 得到数据库连接信息函数， 返回: conn.cursor()

if not self.db:

raise (NameError, "没有设置数据库信息")

self.conn = pymssql.connect(host=self.host, user=self.user, password=self.pwd, database=self.db, charset='utf8')

cur = self.conn.cursor() # 将数据库连接信息，赋值给cur。

if not cur:

raise (NameError, "连接数据库失败")

else:

return cur

# 执行查询语句,返回的是一个包含tuple的list，list的元素是记录行，tuple的元素是每行记录的字段

def ExecQuery(self, sql): # 执行Sql语句函数，返回结果

cur = self.__GetConnect() # 获得数据库连接信息

cur.execute(sql) # 执行Sql语句

resList = cur.fetchall() # 获得所有的查询结果

# 查询完毕后必须关闭连接

self.conn.close() # 返回查询结果

return resList

def ExecNonQuery(self, sql):

cur = self.__GetConnect()

cur.execute(sql)

self.conn.commit()

# ms=MSSQL(host="120.27.48.70:3538",user="saw",pwd="ncist1525",db="DTU_SERVER") #实例化类对象，连接数据对象

ms = MSSQL(host="106.14.41.25:3539", user="sa", pwd="NcisT.DKyT_123456", db="ZSQ_TEST") # 实例化类对象，连接数据对象[ZSQ_TEST]

# sqlstr = "insert into TB_cycdata (status,timer,temperature) VALUES (10,11,12)"

print(sqlstr)

def __init__(self):

self.duanlu = 0 # 短路

self.jiedi = 0 # 接地

self.A_all = 0.0 #

self.E_fild = 0.0

self.temperature = 0.0

self.Li_bat = 0.0

self.Sun_bat = 0.0

self.xian_V = 0.0

self.A_half = 0.0

self.Gan_bat = 0.0

self.timer = 0

self.alarmid = 0

def __init__(self):

self.duanlu = 0 # 短路

self.jiedi = 0 # 接地

self.A_all = 0.0 #

self.E_fild = 0.0

self.temperature = 0.0

self.Li_bat = 0.0

self.Sun_bat = 0.0

self.xian_V = 0.0

self.A_half = 0.0

self.Gan_bat = 0.0

self.timer = 0

self.alarmid = 0

self.RTCtime = ''

self.A_I = 0.0

self.A_E = 0.0

self.A_half_I = 0.0

self.B_I = 0.0

self.B_E = 0.0

self.B_half_I = 0.0

self.C_half_I = 0.0

self.C_I = 0.0

self.C_E = 0.0

def __init__(self):

self.temperature = 0.0

self.bat_v = 0.0

self.bat_sun = 0.0

def __init__(self):

self.T1_I = 0.0

self.T2_I = 0.0

self.T3_I = 0.0

self.T4_I = 0.0

self.T5_I = 0.0

self.T6_I = 0.0

self.T7_I = 0.0

self.T8_I = 0.0

self.T9_I = 0.0

self.T10_I = 0.0

self.T11_I = 0.0

self.T12_I = 0.0

self.T1_E = 0.0

self.T2_E = 0.0

self.T3_E = 0.0

self.T4_E = 0.0

self.T5_E = 0.0

self.T6_E = 0.0

self.T7_E = 0.0

self.T8_E = 0.0

self.T9_E = 0.0

self.T10_E = 0.0

self.T11_E = 0.0

dtu_add_Low = dtu_add_Low2

dtu_add_High = dtu_add_High2

my_all_step = my_all_step2

my_heart_time_count = my_heart_time_count2

file_count = file_count2

zsqA = zsqA2

zsqB = zsqB2

zsqC = zsqC2

zsqX = zsqX2

mydtu = mydtu2

ac12tA = ac12tA2

ac12tB = ac12tB2

ac12tC = ac12tC2

my_zsq_recdata_buf_I = my_zsq_recdata_buf_I2

my_zsq_recdata_buf_E = my_zsq_recdata_buf_E2

my_zsq_recdata_buf_pt = my_zsq_recdata_buf_pt2

my_get_file_e_status = my_get_file_e_status2

# zsqA.Li_bat=0.0

# zsqA.temperature=0.0

mydtuadd = 0

myservertime = datetime.datetime.now()

my_get_com_bytes = my_get_fram(buf)

if my_get_com_bytes == None:

return

if my_get_com_bytes[0] == 0x10:

dtu_add_Low = my_get_com_bytes[2]

dtu_add_High = my_get_com_bytes[3]

else:

dtu_add_Low = my_get_com_bytes[5]

dtu_add_High = my_get_com_bytes[6]

my_inf_add = my_inf_add_high = my_get_com_bytes[13]

my_inf_add_Low = my_get_com_bytes[12]

my_inf_add = my_inf_add * 256 + my_get_com_bytes[12]

mydtuadd = dtu_add_Low + dtu_add_High * 256

my_str2 = my_get_com_bytes

# 建立链路过程

if my_str2[0] == 0x10 and my_str2[1] == 0x49: # 建立链路0X10，0X49

my_str_short = [0x10, 0x8b, 0x10, 0x00, 0x8c, 0x16]

my_str_short[2] = dtu_add_Low

my_str_short[3] = dtu_add_High

s2 = my_101_com_genert_CRC(my_str_short)

s3 = bytes(s2)

conn.sendall(s3)

my_all_step = 1

print("send data:", end='')

my_str_to_hex_display(s3)

elif my_str2[0] == 0x10 and my_str2[1] == 0x40 and my_all_step == 1:

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

# 10 C9 01 00 CA 16

my_str_short = [0x10, 0xC9, 0x01, 0x00, 0x81, 0x16]

my_str_short[2] = dtu_add_Low

my_str_short[3] = dtu_add_High

s2 = my_101_com_genert_CRC(my_str_short)

s3 = bytes(s2)

conn.send(s3)

my_all_step = 2

print("send data:", end='')

my_str_to_hex_display(s3)

elif my_str2[0] == 0x10 and my_str2[1] == 0x0B and my_all_step == 2:

my_str_short = [0x10, 0xC0, 0x01, 0x00, 0x81, 0x16]

my_str_short[2] = dtu_add_Low

my_str_short[3] = dtu_add_High

s2 = my_101_com_genert_CRC(my_str_short)

s3 = bytes(s2)

conn.send(s3)

my_all_step = 3

print("send data:", end='')

my_str_to_hex_display(s3)

elif my_str2[0] == 0x10 and my_str2[1] == 0x00 and my_all_step == 3:

my_str_short = [0x68, 0x0B, 0x0B, 0x68, 0xF3, 0x01, 0x00, 0x46, 0x01, 0x04, 0x01, 0x00, 0x00, 0x00, 0x00, 0x40,

0x16]

my_str_short[5] = my_str_short[10] = dtu_add_Low

my_str_short[6] = my_str_short[11] = dtu_add_High

s2 = my_101_com_genert_CRC(my_str_short)

s3 = bytes(s2)

conn.send(s3)

my_all_step = 4

print("send data:", end='')

my_str_to_hex_display(s3)

elif my_str2[0] == 0x10 and my_str2[1] == 0x00 and my_all_step == 4:

print("link buid finish==")

# 发送计数同步帧

my_str_short = [0x68, 0x0C, 0x0C, 0x68, 0x73, 0x01, 0x00, 0xDC, 0x01, 0x65, 0x01, 0x00, 0x01, 0x4F, 0x01, 0x02,

0XFF, 0x16]

my_str_short[5] = my_str_short[10] = dtu_add_Low

my_str_short[6] = my_str_short[11] = dtu_add_High

x, y = get_time_count()

my_str_short[14] = int(x)

my_str_short[15] = int(y)

s2 = my_101_com_genert_CRC(my_str_short)

s3 = bytes(s2)

conn.send(s3)

my_all_step = 4

print("send data:", end='')

my_str_to_hex_display(s3)

# 计数同步帧应答

elif my_str2[0] == 0x68 and my_str2[4] == 0x80 and my_str2[7] == 0xDC and my_str2[9] == 0x66:

my_heart_time_count = my_heart_time_count + 1

print("time_count finish==%d" % my_heart_time_count)

# 心跳包

elif my_str2[0] == 0x10 and my_str2[1] == 0xD2:

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

print("heart time finish==")

# 计数同步值

my_str_short = [0x68, 0x0C, 0x0C, 0x68, 0x73, 0x01, 0x00, 0xDC, 0x01, 0x65, 0x01, 0x00, 0x01, 0x4F, 0x01, 0x02,

0XFF, 0x16]

my_str_short[5] = my_str_short[10] = dtu_add_Low

my_str_short[6] = my_str_short[11] = dtu_add_High

x, y = get_time_count()

my_str_short[14] = x

my_str_short[15] = y

s2 = my_101_com_genert_CRC(my_str_short)

s3 = bytes(s2)

conn.send(s3)

my_all_step = 4

print("send data:", end='')

my_str_to_hex_display(s3)

# 时钟同步应答

elif my_str2[0] == 0x10 and my_str2[1] == 0x00 and my_all_step == 5:

pass

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x67 and my_str2[

9] == 0x07 and my_all_step == 5:

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

print("RTC time finish==")

# 周期数据应答

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x68 and my_str2[

9] == 0x06:

# 密码验证

print('周期密码OK')

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x02 and my_str2[

9] == 0x14:

# 遥信数据

zsqA.duanlu = my_str2[14]

zsqA.jiedi = my_str2[15]

zsqB.duanlu = my_str2[16]

zsqB.jiedi = my_str2[17]

zsqC.duanlu = my_str2[18]

zsqC.jiedi = my_str2[19]

print('周期遥信')

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x09 and my_str2[

9] == 0x14:

# 遥测数据

if my_str2[12] == 0x01 and my_str2[13] == 0x40:

zsqA.A_all = (my_str2[14] + my_str2[15] * 256) / 10.0

zsqA.temperature = (my_str2[17] + my_str2[18] * 256) / 10.0

zsqA.E_fild = (my_str2[20] + my_str2[21] * 256) / 10.0

zsqA.Li_bat = (my_str2[23] + my_str2[24] * 256) / 10.0

zsqB.A_all = (my_str2[26] + my_str2[27] * 256) / 10.0

zsqB.temperature = (my_str2[29] + my_str2[30] * 256) / 10.0

zsqB.E_fild = (my_str2[32] + my_str2[33] * 256) / 10.0

zsqB.Li_bat = (my_str2[35] + my_str2[36] * 256) / 10.0

zsqC.A_all = (my_str2[38] + my_str2[39] * 256) / 10.0

zsqC.temperature = (my_str2[41] + my_str2[42] * 256) / 10.0

zsqC.E_fild = (my_str2[44] + my_str2[45] * 256) / 10.0

zsqC.Li_bat = (my_str2[47] + my_str2[48] * 256) / 10.0

print('周期遥测数据')

elif my_str2[12] == 0x00 and my_str2[13] == 0x41:

mydtu.bat_v = (my_str2[14] + my_str2[15] * 256) / 10.0

mydtu.bat_sun = (my_str2[16] + my_str2[17] * 256) / 10.0

mydtu.temperature = (my_str2[18] + my_str2[19] * 256) / 10.0

mydtu.shidu = (my_str2[20] + my_str2[21] * 256) / 10.0

print('周期遥测环境数据')

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x09 and (

my_str2[9] == 0x67 or my_str2[9] == 0x68 or my_str2[9] == 0x69):

# 遥测补充、遥测12T、计数同步值

if my_str2[9] == 0x67:

zsqA.Sun_bat = (my_str2[14] + my_str2[15] * 256) / 10.0

zsqA.xian_V = (my_str2[16] + my_str2[17] * 256) / 10.0

zsqA.Gan_bat = (my_str2[18] + my_str2[19] * 256) / 10.0

zsqA.A_half = (my_str2[20] + my_str2[21] * 256) / 10.0

zsqB.Sun_bat = (my_str2[22] + my_str2[23] * 256) / 10.0

zsqB.xian_V = (my_str2[24] + my_str2[25] * 256) / 10.0

zsqB.Gan_bat = (my_str2[26] + my_str2[27] * 256) / 10.0

zsqB.A_half = (my_str2[28] + my_str2[29] * 256) / 10.0

zsqC.Sun_bat = (my_str2[30] + my_str2[31] * 256) / 10.0

zsqC.xian_V = (my_str2[32] + my_str2[33] * 256) / 10.0

zsqC.Gan_bat = (my_str2[34] + my_str2[35] * 256) / 10.0

zsqC.A_half = (my_str2[36] + my_str2[37] * 256) / 10.0

print('周期遥测补充')

elif my_str2[9] == 0x68:

ac12tA.T1_I = (my_str2[14] + my_str2[15] * 256) / 10.0

ac12tA.T2_I = (my_str2[16] + my_str2[17] * 256) / 10.0

ac12tA.T3_I = (my_str2[18] + my_str2[19] * 256) / 10.0

ac12tA.T4_I = (my_str2[20] + my_str2[21] * 256) / 10.0

ac12tA.T5_I = (my_str2[22] + my_str2[23] * 256) / 10.0

ac12tA.T6_I = (my_str2[24] + my_str2[25] * 256) / 10.0

ac12tA.T7_I = (my_str2[26] + my_str2[27] * 256) / 10.0

ac12tA.T8_I = (my_str2[28] + my_str2[29] * 256) / 10.0

ac12tA.T9_I = (my_str2[30] + my_str2[31] * 256) / 10.0

ac12tA.T10_I = (my_str2[32] + my_str2[33] * 256) / 10.0

ac12tA.T11_I = (my_str2[34] + my_str2[35] * 256) / 10.0

ac12tA.T12_I = (my_str2[36] + my_str2[37] * 256) / 10.0

ac12tA.T1_E = (my_str2[38] + my_str2[39] * 256) / 10.0

ac12tA.T2_E = (my_str2[40] + my_str2[41] * 256) / 10.0

ac12tA.T3_E = (my_str2[42] + my_str2[43] * 256) / 10.0

ac12tA.T4_E = (my_str2[44] + my_str2[45] * 256) / 10.0

ac12tA.T5_E = (my_str2[46] + my_str2[47] * 256) / 10.0

ac12tA.T6_E = (my_str2[48] + my_str2[49] * 256) / 10.0

ac12tA.T7_E = (my_str2[50] + my_str2[51] * 256) / 10.0

ac12tA.T8_E = (my_str2[52] + my_str2[53] * 256) / 10.0

ac12tA.T9_E = (my_str2[54] + my_str2[55] * 256) / 10.0

ac12tA.T10_E = (my_str2[56] + my_str2[57] * 256) / 10.0

ac12tA.T11_E = (my_str2[58] + my_str2[59] * 256) / 10.0

ac12tA.T12_E = (my_str2[60] + my_str2[61] * 256) / 10.0

ac12tB.T1_I = (my_str2[62] + my_str2[63] * 256) / 10.0

ac12tB.T2_I = (my_str2[64] + my_str2[65] * 256) / 10.0

ac12tB.T3_I = (my_str2[66] + my_str2[67] * 256) / 10.0

ac12tB.T4_I = (my_str2[68] + my_str2[69] * 256) / 10.0

ac12tB.T5_I = (my_str2[70] + my_str2[71] * 256) / 10.0

ac12tB.T6_I = (my_str2[72] + my_str2[73] * 256) / 10.0

ac12tB.T7_I = (my_str2[74] + my_str2[75] * 256) / 10.0

ac12tB.T8_I = (my_str2[76] + my_str2[77] * 256) / 10.0

ac12tB.T9_I = (my_str2[78] + my_str2[79] * 256) / 10.0

ac12tB.T10_I = (my_str2[80] + my_str2[81] * 256) / 10.0

ac12tB.T11_I = (my_str2[82] + my_str2[83] * 256) / 10.0

ac12tB.T12_I = (my_str2[84] + my_str2[85] * 256) / 10.0

ac12tB.T1_E = (my_str2[86] + my_str2[87] * 256) / 10.0

ac12tB.T2_E = (my_str2[88] + my_str2[89] * 256) / 10.0

ac12tB.T3_E = (my_str2[90] + my_str2[91] * 256) / 10.0

ac12tB.T4_E = (my_str2[92] + my_str2[93] * 256) / 10.0

ac12tB.T5_E = (my_str2[94] + my_str2[95] * 256) / 10.0

ac12tB.T6_E = (my_str2[96] + my_str2[97] * 256) / 10.0

ac12tB.T7_E = (my_str2[98] + my_str2[99] * 256) / 10.0

ac12tB.T8_E = (my_str2[100] + my_str2[101] * 256) / 10.0

ac12tB.T9_E = (my_str2[102] + my_str2[103] * 256) / 10.0

ac12tB.T10_E = (my_str2[104] + my_str2[105] * 256) / 10.0

ac12tB.T11_E = (my_str2[106] + my_str2[107] * 256) / 10.0

ac12tB.T12_E = (my_str2[108] + my_str2[109] * 256) / 10.0

ac12tC.T1_I = (my_str2[110] + my_str2[111] * 256) / 10.0

ac12tC.T2_I = (my_str2[112] + my_str2[113] * 256) / 10.0

ac12tC.T3_I = (my_str2[114] + my_str2[115] * 256) / 10.0

ac12tC.T4_I = (my_str2[116] + my_str2[117] * 256) / 10.0

ac12tC.T5_I = (my_str2[118] + my_str2[119] * 256) / 10.0

ac12tC.T6_I = (my_str2[120] + my_str2[121] * 256) / 10.0

ac12tC.T7_I = (my_str2[122] + my_str2[123] * 256) / 10.0

ac12tC.T8_I = (my_str2[124] + my_str2[125] * 256) / 10.0

ac12tC.T9_I = (my_str2[126] + my_str2[127] * 256) / 10.0

ac12tC.T10_I = (my_str2[128] + my_str2[129] * 256) / 10.0

ac12tC.T11_I = (my_str2[130] + my_str2[131] * 256) / 10.0

ac12tC.T12_I = (my_str2[132] + my_str2[133] * 256) / 10.0

ac12tC.T1_E = (my_str2[134] + my_str2[135] * 256) / 10.0

ac12tC.T2_E = (my_str2[136] + my_str2[137] * 256) / 10.0

ac12tC.T3_E = (my_str2[138] + my_str2[139] * 256) / 10.0

ac12tC.T4_E = (my_str2[140] + my_str2[141] * 256) / 10.0

ac12tC.T5_E = (my_str2[142] + my_str2[143] * 256) / 10.0

ac12tC.T6_E = (my_str2[144] + my_str2[145] * 256) / 10.0

ac12tC.T7_E = (my_str2[146] + my_str2[147] * 256) / 10.0

ac12tC.T8_E = (my_str2[148] + my_str2[149] * 256) / 10.0

ac12tC.T9_E = (my_str2[150] + my_str2[151] * 256) / 10.0

ac12tC.T10_E = (my_str2[152] + my_str2[153] * 256) / 10.0

ac12tC.T11_E = (my_str2[154] + my_str2[155] * 256) / 10.0

ac12tC.T12_E = (my_str2[156] + my_str2[157] * 256) / 10.0

print('周期遥测12T')

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0xDC and my_str2[

9] == 0x69:

dtutimer = (my_str2[14] + my_str2[15] * 256)

RTCtime = str(my_str2[22]) + "-" + str(my_str2[21]) + "-" + str(my_str2[20]) + " " + str(

my_str2[19]) + ":" + str(my_str2[18]) + ":" + str(my_str2[16])

mytodattime = datetime.datetime.now()

myservertime = str(mytodattime)[:19]

print('周期计数同步值')

# 把收到的数据写入到数据库中

sqlstr = 'insert into TB_cycdata VALUES (1,' + "\'" + str(myservertime) + "\'" + ',' + str(

mydtuadd) + ',' + "\'" + str(RTCtime) + "\'" + ',' + str(dtutimer) + ',' + str(mydtu.bat_v) + ',' + str(

mydtu.bat_sun) + ',' + str(mydtu.temperature) + ',' + str(mydtu.shidu) + ',' + str(zsqA.duanlu) + ',' + str(

zsqA.jiedi) + ',' + str(zsqA.A_all) + ',' + str(zsqA.E_fild) + ',' + str(zsqA.Li_bat) + ',' + str(

zsqA.Sun_bat) + ',' + str(zsqA.xian_V) + ',' + str(zsqA.A_half) + ',' + str(zsqA.Gan_bat) + ',' + str(

zsqA.temperature) + ',' + str(zsqA.timer) + ',' + str(zsqB.duanlu) + ',' + str(zsqB.jiedi) + ',' + str(

zsqB.A_all) + ',' + str(zsqB.E_fild) + ',' + str(zsqB.Li_bat) + ',' + str(zsqB.Sun_bat) + ',' + str(

zsqB.xian_V) + ',' + str(zsqB.A_half) + ',' + str(zsqB.Gan_bat) + ',' + str(zsqB.temperature) + ',' + str(

zsqB.timer) + ',' + str(zsqC.duanlu) + ',' + str(zsqC.jiedi) + ',' + str(zsqC.A_all) + ',' + str(

zsqC.E_fild) + ',' + str(zsqC.Li_bat) + ',' + str(zsqC.Sun_bat) + ',' + str(zsqC.xian_V) + ',' + str(

zsqC.A_half) + ',' + str(zsqC.Gan_bat) + ',' + str(zsqC.temperature) + ',' + str(zsqC.timer) + ',0,0' + ')'

print(sqlstr)

my_fun_SQL_insertdata(sqlstr)

sqlstr = 'insert into TB_AC12T VALUES (' + str(mydtuadd) + ',1,11,' + "\'" + str(

myservertime) + "\'" + ',' + "\'" + str(

RTCtime) + "\'" + ',' + str(ac12tA.T1_I) + ',' + str(

ac12tA.T2_I) + ',' + str(ac12tA.T3_I) + ',' + str(ac12tA.T4_I) + ',' + str(ac12tA.T5_I) + ',' + str(

ac12tA.T6_I) + ',' + str(ac12tA.T7_I) + ',' + str(ac12tA.T8_I) + ',' + str(ac12tA.T9_I) + ',' + str(

ac12tA.T10_I) + ',' + str(ac12tA.T11_I) + ',' + str(ac12tA.T12_I) + ')'

print(sqlstr)

my_fun_SQL_insertdata(sqlstr)

sqlstr = 'insert into TB_AC12T VALUES (' + str(mydtuadd) + ',1,21,' + "\'" + str(

myservertime) + "\'" + ',' + "\'" + str(

RTCtime) + "\'" + ',' + str(ac12tB.T1_I) + ',' + str(

ac12tB.T2_I) + ',' + str(ac12tB.T3_I) + ',' + str(ac12tB.T4_I) + ',' + str(ac12tB.T5_I) + ',' + str(

ac12tB.T6_I) + ',' + str(ac12tB.T7_I) + ',' + str(ac12tB.T8_I) + ',' + str(ac12tB.T9_I) + ',' + str(

ac12tB.T10_I) + ',' + str(ac12tB.T11_I) + ',' + str(ac12tB.T12_I) + ')'

print(sqlstr)

my_fun_SQL_insertdata(sqlstr)

sqlstr = 'insert into TB_AC12T VALUES (' + str(mydtuadd) + ',1,31,' + "\'" + str(

myservertime) + "\'" + ',' + "\'" + str(

RTCtime) + "\'" + ',' + str(ac12tC.T1_I) + ',' + str(

ac12tC.T2_I) + ',' + str(ac12tC.T3_I) + ',' + str(ac12tC.T4_I) + ',' + str(ac12tC.T5_I) + ',' + str(

ac12tC.T6_I) + ',' + str(ac12tC.T7_I) + ',' + str(ac12tC.T8_I) + ',' + str(ac12tC.T9_I) + ',' + str(

ac12tC.T10_I) + ',' + str(ac12tC.T11_I) + ',' + str(ac12tC.T12_I) + ')'

print(sqlstr)

my_fun_SQL_insertdata(sqlstr)

sqlstr = 'insert into TB_AC12T VALUES (' + str(mydtuadd) + ',1,12,' + "\'" + str(

myservertime) + "\'" + ',' + "\'" + str(

RTCtime) + "\'" + ',' + str(ac12tA.T1_E) + ',' + str(

ac12tA.T2_E) + ',' + str(ac12tA.T3_E) + ',' + str(ac12tA.T4_E) + ',' + str(ac12tA.T5_E) + ',' + str(

ac12tA.T6_E) + ',' + str(ac12tA.T7_E) + ',' + str(ac12tA.T8_E) + ',' + str(ac12tA.T9_E) + ',' + str(

ac12tA.T10_E) + ',' + str(ac12tA.T11_E) + ',' + str(ac12tA.T12_E) + ')'

print(sqlstr)

my_fun_SQL_insertdata(sqlstr)

sqlstr = 'insert into TB_AC12T VALUES (' + str(mydtuadd) + ',1,22,' + "\'" + str(

myservertime) + "\'" + ',' + "\'" + str(

RTCtime) + "\'" + ',' + str(ac12tB.T1_E) + ',' + str(

ac12tB.T2_E) + ',' + str(ac12tB.T3_E) + ',' + str(ac12tB.T4_E) + ',' + str(ac12tB.T5_E) + ',' + str(

ac12tB.T6_E) + ',' + str(ac12tB.T7_E) + ',' + str(ac12tB.T8_E) + ',' + str(ac12tB.T9_E) + ',' + str(

ac12tB.T10_E) + ',' + str(ac12tB.T11_E) + ',' + str(ac12tB.T12_E) + ')'

print(sqlstr)

my_fun_SQL_insertdata(sqlstr)

sqlstr = 'insert into TB_AC12T VALUES (' + str(mydtuadd) + ',1,32,' + "\'" + str(

myservertime) + "\'" + ',' + "\'" + str(

RTCtime) + "\'" + ',' + str(ac12tC.T1_E) + ',' + str(

ac12tC.T2_E) + ',' + str(ac12tC.T3_E) + ',' + str(ac12tC.T4_E) + ',' + str(ac12tC.T5_E) + ',' + str(

ac12tC.T6_E) + ',' + str(ac12tC.T7_E) + ',' + str(ac12tC.T8_E) + ',' + str(ac12tC.T9_E) + ',' + str(

ac12tC.T10_E) + ',' + str(ac12tC.T11_E) + ',' + str(ac12tC.T12_E) + ')'

print(sqlstr)

my_fun_SQL_insertdata(sqlstr)

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

#######################################3

# 报警数据处理

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x01 and my_str2[

9] == 0x03:

zsqinf = ((my_str2[12]) // 2)

zsqX.alarmid = zsqinf + 1

if my_str2[12] % 2 == 0:

zsqX.duanlu = my_str2[14]

zsqX.jiedi = 0

else:

zsqX.jiedi = my_str2[14]

zsqX.duanlu = 0

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

print("报警-遥信无时标")

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x1E and my_str2[

9] == 0x03:

zsqX.RTCtime = str(

str(my_str2[21]) + "-" + str(my_str2[20]) + "-" + str(my_str2[19]) + " " + str(my_str2[18]) + ":" + str(

my_str2[17]) + ":" + str(my_str2[15]))

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

print("报警-遥信有时标")

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x09 and my_str2[

9] == 0x6A:

zsqX.A_I = (my_str2[14] + my_str2[15] * 256) / 10.0

zsqX.A_E = (my_str2[16] + my_str2[17] * 256) / 10.0

zsqX.A_half_I = (my_str2[18] + my_str2[19] * 256) / 10.0

zsqX.B_I = (my_str2[20] + my_str2[21] * 256) / 10.0

zsqX.B_E = (my_str2[22] + my_str2[23] * 256) / 10.0

zsqX.B_half_I = (my_str2[24] + my_str2[25] * 256) / 10.0

zsqX.C_I = (my_str2[26] + my_str2[27] * 256) / 10.0

zsqX.C_E = (my_str2[28] + my_str2[29] * 256) / 10.0

zsqX.C_half_I = (my_str2[30] + my_str2[31] * 256) / 10.0

my_fun_send_OK(conn, dtu_add_Low, dtu_add_High)

print("报警-遥测AC")

elif my_str2[0] == 0x68 and (my_str2[4] == 0x53 or my_str2[4] == 0x73) and my_str2[7] == 0x09 and my_str2[

9] == 0x6B:

ac12tA.T1_I = (my_str2[14] + my_str2[15] * 256) / 10.0

ac12tA.T2_I = (my_str2[16] + my_str2[17] * 256) / 10.0

ac12tA.T3_I = (my_str2[18] + my_str2[19] * 256) / 10.0

ac12tA.T4_I = (my_str2[20] + my_str2[21] * 256) / 10.0

ac12tA.T5_I = (my_str2[22] + my_str2[23] * 256) / 10.0

ac12tA.T6_I = (my_str2[24] + my_str2[25] * 256) / 10.0

ac12tA.T7_I = (my_str2[26] + my_str2[27] * 256) / 10.0

ac12tA.T8_I = (my_str2[28] + my_str2[29] * 256) / 10.0

ac12tA.T9_I = (my_str2[30] + my_str2[31] * 256) / 10.0

ac12tA.T10_I = (my_str2[32] + my_str2[33] * 256) / 10.0

ac12tA.T11_I = (my_str2[34] + my_str2[35] * 256) / 10.0