class testSmsSetIPManager(Abstract):#
def __init__(self):
self.timer = osTimer()
- self.newip = "8.134.110.49"
+ self.newip = "test.iot.socket.thisiot.com"
# "8.134.110.49"#默认大锤服务器 在大锤服务器更改要连接新的服务器地址
- self.newcom = 30346
+ self.newcom = 9999
# 31379
-
+
self.new_key = "3JyCjsw4ryXKzjzudayY"
self.new_pid = "qAELPTKmFanR4RHe"
self.server_sate = 0
def set_new_key_cb(self, event, msg):
self.new_key = msg
+ print("set_new_key_cb",msg,self.new_key)
EventMesh.publish("set_storage_config",["set_new_key",self.new_key])
def get_new_key_cb(self, event, msg):
def set_new_pid_cb(self, event, msg):
self.new_pid = msg
+ print("set_new_pid_cb",msg,self.new_pid)
EventMesh.publish("set_storage_config",["set_new_pid",self.new_pid])
def get_new_pid_cb(self, event, msg):
# md5_key = "bZld0ALsZTt15tKEZhOlLPgbsO75BLTP"
# PID = "SZKW"
elif server_type == 2:
-
- d_server_addr = "8.134.110.49"
- d_server_port = 30346
+ # test.iot.socket.thisiot.com:9999
+ d_server_addr = "test.iot.socket.thisiot.com"
+ d_server_port = 9999
d_md5_key = "3JyCjsw4ryXKzjzudayY"
d_PID = "qAELPTKmFanR4RHe"
elif server_type == 3:
self.reconnect_flag = 0
self.connect_tmp = 0
server_data = server_init()
- print("SockManager:server_data:{}".format(server_data))
+ # print("SockManager:server_data:{}".format(server_data))
self.server_addr = server_data[0]
self.server_port = server_data[1]
ip_infor = {}
print("sign_data:{} sonce_data:{}".format(md5_data,sign_data))
# sign_data = MD5_head
# http://8.134.110.49:31379/dev/device/check?imei=&bid=sonce=sign=
- url = "http://8.134.110.49:31379/dev/device/check?imei={}&bid={}&sonce={}&sign={}".format(imei,pid_data,sonce_data,sign_data)
+ url = "http://test.app.api.thisiot.com/dev/device/check?imei={}&bid={}&sonce={}&sign={}".format(imei,pid_data,sonce_data,sign_data)
response = request.get(url)
data_tmp ={}
# d_PID = "3G"
# response.content = {'protocolType': '', 'host': 'device.miwitracker.com', 'secretKey': '', 'port': 8505, 'bid': '3G', 'extJsonStr': ''}
# response.status_code=200
- # print("test-{}".format(response.status_code))
+ print("test-{}".format(response.status_code))
if response.status_code == 200:
content = response.content
c = next(content)
EventMesh.subscribe(self.TYPE + "_SEND", self.handler)
EventMesh.subscribe(self.TYPE + "_RECV", self.handler)
- def handler(self, event, msg):
+ def change_key_pid(self):
server_data = EventMesh.publish("get_new_key_pid")#获取pid和key
- # print("handler",server_data)
+ print("handler",server_data,type(server_data[0]),type(server_data[1]))
if server_data != None:
- if self.md5_key != server_data[0]:
- print("change md5key",self.md5_key,server_data[0])
+ if str(self.md5_key) != str(server_data[0]):
+ print("change md5key1",self.md5_key,server_data[0])
self.md5_key = server_data[0]
- if self.PID != server_data[1]:
- print("change md5PID",self.PID,server_data[1])
+ print("change md5key2",self.md5_key,server_data[0])
+ if str(self.PID) != str(server_data[1]):
+ print("change md5PID1",self.PID,server_data[1])
self.PID = server_data[1]
+ print("change md5PID2",self.PID,server_data[1])
+ pass
+
+ def handler(self, event, msg):
+ self.change_key_pid()
self.password = EventMesh.publish(constants.EVENT.GET_PASSWORD)
self.imei = EventMesh.publish(constants.EVENT.GET_IMEI)#"867387060319166"#EventMesh.publish(constants.EVENT.GET_IMEI)#"867387060319166" #EventMesh.publish(constants.EVENT.GET_IMEI)#"867387060319166"#EventMesh.publish(constants.EVENT.GET_IMEI) #"867387060319166"#EventMesh.publish(constants.EVENT.GET_IMEI) #"867387060319166"#"867387060319188"#"867387060319177"#"867387060319166"#"860132060004322"#"867387060319166"#"860132060004322"#EventMesh.publish(constants.EVENT.GET_IMEI)