update
This commit is contained in:
PaulVua
@@ -338,7 +338,7 @@ try:
|
||||
csv_string = ','.join(str(value) if value is not None else '' for value in payload_csv)
|
||||
size_of_string = len(csv_string)
|
||||
command = f'AT+UDWNFILE="sensordata_csv.json",{size_of_string}\r'
|
||||
ser_sara.write((command + '\r').encode('utf-8'))
|
||||
ser_sara.write(command.encode('utf-8'))
|
||||
response_SARA_1 = read_complete_response(ser_sara)
|
||||
#if need_to_log:
|
||||
#print("Open JSON:")
|
||||
@@ -353,113 +353,118 @@ try:
|
||||
print(response_SARA_2)
|
||||
|
||||
#3. Send to endpoint (with device ID)
|
||||
command= f'AT+UHTTPC=0,4,"/pro_4G/data.php?sensor_id={device_id}","server_response.txt","sensordata_csv.json",4\r'
|
||||
ser_sara.write((command + '\r').encode('utf-8'))
|
||||
response_SARA_3 = read_complete_response(ser_sara)
|
||||
|
||||
print("Send data:")
|
||||
print(response_SARA_3)
|
||||
|
||||
# Les types de réponse
|
||||
command= f'AT+UHTTPC=0,4,"/pro_4G/data.php?sensor_id={device_id}","server_response.txt","sensordata_csv.json",4\r'
|
||||
ser_sara.write(command.encode('utf-8'))
|
||||
|
||||
# 1.La commande n'a pas fonctionné
|
||||
# +CME ERROR: No connection to phone
|
||||
# +CME ERROR: Operation not allowed
|
||||
print("Waiting for +UUHTTPCR response...")
|
||||
response_received = False
|
||||
while not response_received:
|
||||
response_SARA_3 = read_complete_response(ser_sara, timeout=5)
|
||||
print(response_SARA_3)
|
||||
if "+UUHTTPCR" in response_SARA_3:
|
||||
response_received = True
|
||||
|
||||
# Les types de réponse
|
||||
|
||||
# 2.La commande fonctionne: elle renvoie un code
|
||||
# +UUHTTPCR: <profile_id>,<http_command>,<http_result>
|
||||
# <http_result>: 1 pour sucess et 0 pour fail
|
||||
# +UUHTTPCR: 0,4,1 -> OK
|
||||
# +UUHTTPCR: 0,4,0 -> error
|
||||
# 1.La commande n'a pas fonctionné
|
||||
# +CME ERROR: No connection to phone
|
||||
# +CME ERROR: Operation not allowed
|
||||
|
||||
# Split response into lines
|
||||
lines = response_SARA_3.strip().splitlines()
|
||||
# 2.La commande fonctionne: elle renvoie un code
|
||||
# +UUHTTPCR: <profile_id>,<http_command>,<http_result>
|
||||
# <http_result>: 1 pour sucess et 0 pour fail
|
||||
# +UUHTTPCR: 0,4,1 -> OK
|
||||
# +UUHTTPCR: 0,4,0 -> error
|
||||
|
||||
# 1.Vérifier si la réponse contient un message d'erreur CME
|
||||
if "+CME ERROR" in lines[-1]:
|
||||
print("*****")
|
||||
print('<span style="color: red;font-weight: bold;">ATTENTION: CME ERROR</span>')
|
||||
print("error:", lines[-1])
|
||||
print("*****")
|
||||
#update status
|
||||
update_json_key(config_file, "SARA_R4_network_status", "disconnected")
|
||||
# Split response into lines
|
||||
lines = response_SARA_3.strip().splitlines()
|
||||
|
||||
# Gestion de l'erreur spécifique
|
||||
if "No connection to phone" in lines[-1]:
|
||||
print("No connection to the phone. Retrying or reset may be required.")
|
||||
# Actions spécifiques pour ce type d'erreur (par exemple, réinitialiser ou tenter de reconnecter)
|
||||
# need to reconnect to network
|
||||
# and reset HTTP profile (AT+UHTTP=0) -> ne fonctionne pas..
|
||||
# tester un reset avec CFUN 15
|
||||
# 1.Reconnexion au réseau (AT+COPS)
|
||||
command = f'AT+COPS=1,2,"{selected_networkID}"\r'
|
||||
ser_sara.write((command + '\r').encode('utf-8'))
|
||||
responseReconnect = read_complete_response(ser_sara)
|
||||
print("Response reconnect:")
|
||||
print(responseReconnect)
|
||||
print("End response reconnect")
|
||||
# 1.Vérifier si la réponse contient un message d'erreur CME
|
||||
if "+CME ERROR" in lines[-1]:
|
||||
print("*****")
|
||||
print('<span style="color: red;font-weight: bold;">ATTENTION: CME ERROR</span>')
|
||||
print("error:", lines[-1])
|
||||
print("*****")
|
||||
#update status
|
||||
update_json_key(config_file, "SARA_R4_network_status", "disconnected")
|
||||
|
||||
elif "Operation not allowed" in lines[-1]:
|
||||
print("Operation not allowed. This may require a different configuration.")
|
||||
# Actions spécifiques pour ce type d'erreur
|
||||
# Gestion de l'erreur spécifique
|
||||
if "No connection to phone" in lines[-1]:
|
||||
print("No connection to the phone. Retrying or reset may be required.")
|
||||
# Actions spécifiques pour ce type d'erreur (par exemple, réinitialiser ou tenter de reconnecter)
|
||||
# need to reconnect to network
|
||||
# and reset HTTP profile (AT+UHTTP=0) -> ne fonctionne pas..
|
||||
# tester un reset avec CFUN 15
|
||||
# 1.Reconnexion au réseau (AT+COPS)
|
||||
command = f'AT+COPS=1,2,"{selected_networkID}"\r'
|
||||
ser_sara.write(command.encode('utf-8'))
|
||||
responseReconnect = read_complete_response(ser_sara)
|
||||
print("Response reconnect:")
|
||||
print(responseReconnect)
|
||||
print("End response reconnect")
|
||||
|
||||
# Clignotement LED en cas d'erreur
|
||||
GPIO.output(23, GPIO.LOW) # Éteindre la LED définitivement
|
||||
for _ in range(4):
|
||||
GPIO.output(23, GPIO.HIGH) # Allumer la LED
|
||||
time.sleep(0.1)
|
||||
GPIO.output(23, GPIO.LOW) # Éteindre la LED
|
||||
time.sleep(0.1)
|
||||
GPIO.output(23, GPIO.LOW) # Turn off the LED
|
||||
elif "Operation not allowed" in lines[-1]:
|
||||
print("Operation not allowed. This may require a different configuration.")
|
||||
# Actions spécifiques pour ce type d'erreur
|
||||
|
||||
else:
|
||||
# 2.Si la réponse contient une réponse HTTP valide
|
||||
# Extract HTTP response code from the last line
|
||||
# ATTENTION: lines[-1] renvoie l'avant dernière ligne et il peut y avoir un soucis avec le OK
|
||||
# rechercher plutot
|
||||
http_response = lines[-1] # "+UUHTTPCR: 0,4,0"
|
||||
parts = http_response.split(',')
|
||||
# Clignotement LED en cas d'erreur
|
||||
GPIO.output(23, GPIO.LOW) # Éteindre la LED définitivement
|
||||
for _ in range(4):
|
||||
GPIO.output(23, GPIO.HIGH) # Allumer la LED
|
||||
time.sleep(0.1)
|
||||
GPIO.output(23, GPIO.LOW) # Éteindre la LED
|
||||
time.sleep(0.1)
|
||||
GPIO.output(23, GPIO.LOW) # Turn off the LED
|
||||
|
||||
# 2.1 code 0 (HTTP failed)
|
||||
if len(parts) == 3 and parts[-1] == '0': # The third value indicates success
|
||||
print("*****")
|
||||
print('<span style="color: red;font-weight: bold;">ATTENTION: HTTP operation failed</span>')
|
||||
update_json_key(config_file, "SARA_R4_network_status", "disconnected")
|
||||
print("*****")
|
||||
print("resetting the URL (domain name):")
|
||||
print("Turning off the blue LED...")
|
||||
for _ in range(4): # Faire clignoter 4 fois
|
||||
GPIO.output(23, GPIO.HIGH) # Allumer la LED
|
||||
time.sleep(0.1) # Attendre 100 ms
|
||||
GPIO.output(23, GPIO.LOW) # Éteindre la LED
|
||||
time.sleep(0.1) # Attendre 100 ms
|
||||
GPIO.output(23, GPIO.LOW) # Turn off the LED
|
||||
command = f'AT+UHTTP=0,1,"{url_nebuleair}"\r'
|
||||
ser_sara.write((command + '\r').encode('utf-8'))
|
||||
response_SARA_31 = read_complete_response(ser_sara)
|
||||
if need_to_log:
|
||||
print(response_SARA_31)
|
||||
else:
|
||||
# 2.Si la réponse contient une réponse HTTP valide
|
||||
# Extract HTTP response code from the last line
|
||||
# ATTENTION: lines[-1] renvoie l'avant dernière ligne et il peut y avoir un soucis avec le OK
|
||||
# rechercher plutot
|
||||
http_response = lines[-1] # "+UUHTTPCR: 0,4,0"
|
||||
parts = http_response.split(',')
|
||||
|
||||
# 2.2 code 1 (HHTP succeded)
|
||||
else:
|
||||
# Si la commande HTTP a réussi
|
||||
print('<span class="badge text-bg-success">HTTP operation successful.</span>')
|
||||
update_json_key(config_file, "SARA_R4_network_status", "connected")
|
||||
print("Turning on the blue LED...")
|
||||
for _ in range(4): # Faire clignoter 4 fois
|
||||
GPIO.output(23, GPIO.HIGH) # Allumer la LED
|
||||
time.sleep(0.1) # Attendre 100 ms
|
||||
GPIO.output(23, GPIO.LOW) # Éteindre la LED
|
||||
time.sleep(0.1) # Attendre 100 ms
|
||||
GPIO.output(23, GPIO.HIGH) # Turn on the LED
|
||||
#4. Read reply from server
|
||||
ser_sara.write(b'AT+URDFILE="server_response.txt"\r')
|
||||
response_SARA_4 = read_complete_response(ser_sara)
|
||||
if need_to_log:
|
||||
print("Reply from server:")
|
||||
print('<p class="text-success">')
|
||||
print(response_SARA_4)
|
||||
print('</p>')
|
||||
# 2.1 code 0 (HTTP failed)
|
||||
if len(parts) == 3 and parts[-1] == '0': # The third value indicates success
|
||||
print("*****")
|
||||
print('<span style="color: red;font-weight: bold;">ATTENTION: HTTP operation failed</span>')
|
||||
update_json_key(config_file, "SARA_R4_network_status", "disconnected")
|
||||
print("*****")
|
||||
print("resetting the URL (domain name):")
|
||||
print("Turning off the blue LED...")
|
||||
for _ in range(4): # Faire clignoter 4 fois
|
||||
GPIO.output(23, GPIO.HIGH) # Allumer la LED
|
||||
time.sleep(0.1) # Attendre 100 ms
|
||||
GPIO.output(23, GPIO.LOW) # Éteindre la LED
|
||||
time.sleep(0.1) # Attendre 100 ms
|
||||
GPIO.output(23, GPIO.LOW) # Turn off the LED
|
||||
command = f'AT+UHTTP=0,1,"{url_nebuleair}"\r'
|
||||
ser_sara.write(command.encode('utf-8'))
|
||||
response_SARA_31 = read_complete_response(ser_sara)
|
||||
if need_to_log:
|
||||
print(response_SARA_31)
|
||||
|
||||
# 2.2 code 1 (HHTP succeded)
|
||||
else:
|
||||
# Si la commande HTTP a réussi
|
||||
print('<span class="badge text-bg-success">HTTP operation successful.</span>')
|
||||
update_json_key(config_file, "SARA_R4_network_status", "connected")
|
||||
print("Turning on the blue LED...")
|
||||
for _ in range(4): # Faire clignoter 4 fois
|
||||
GPIO.output(23, GPIO.HIGH) # Allumer la LED
|
||||
time.sleep(0.1) # Attendre 100 ms
|
||||
GPIO.output(23, GPIO.LOW) # Éteindre la LED
|
||||
time.sleep(0.1) # Attendre 100 ms
|
||||
GPIO.output(23, GPIO.HIGH) # Turn on the LED
|
||||
#4. Read reply from server
|
||||
ser_sara.write(b'AT+URDFILE="server_response.txt"\r')
|
||||
response_SARA_4 = read_complete_response(ser_sara)
|
||||
if need_to_log:
|
||||
print("Reply from server:")
|
||||
print('<p class="text-success">')
|
||||
print(response_SARA_4)
|
||||
print('</p>')
|
||||
|
||||
#5. empty json
|
||||
ser_sara.write(b'AT+UDELFILE="sensordata_csv.json"\r')
|
||||
@@ -489,8 +494,6 @@ try:
|
||||
time.sleep(1)
|
||||
|
||||
#2. Write to shell
|
||||
|
||||
|
||||
ser_sara.write(payload_string.encode())
|
||||
response_SARA_2 = read_complete_response(ser_sara)
|
||||
if need_to_log:
|
||||
|
||||
Reference in New Issue
Block a user