--no commit message

Maria Jorba Brosa
1 parent 1cbe8c09
Showing 1 changed file with 112 additions and 4 deletions
Project/applications/smartcities/main2.c
@@ -84,6 +84,38 @@ void init_registry(void)
     {chThdSleepMilliseconds(500);}
  
 }
+
+void send_data()
+{
+    int j;
+    for(j=0;j<TOTAL_SENSORS;j++)
+    {
+        printf(" enviant buffer %d\r\n",j);
+        
+        // fem servir 085 de prova, però haurem de fer servir sensor_id[j]
+        int ok=send(buffers[j],&ind[j],&sizes[j], mod.ID, sensors[j]);
+
+        if(ok==JSON_COMM_ERROR)
+        {
+            printf("wismart is not connected\r\n");
+        }
+        else if( ok==JSON_OTHER_ERROR){
+            printf("some error ocurred\r\n");
+        }
+        else if(ok ==JSON_POST_OK){
+            printf(" send OK \r\n");
+        }
+    }
+}
+
+void put_buffers(char** buffers,uint32_t ind[],uint32_t sizes[],char* valueSensors[]){
+int i;
+    for(i=0;i<TOTAL_SENSORS;i++){
+        put_message(valueSensors[i], buffers[i] ,&ind[i],&sizes[i]);
+    }
+
+}
+
 int main(void)
 {
     initLibwismart();
@@ -96,10 +128,10 @@ int main(void)
  
     //Escanea los sensores -> retorna un vector con las direcciones en cada posición del vector, si la posición del vector retorna un cero -> no existe el sensor
     uint8_t sensors[TOTAL_SENSORS];
-    char valueSensors[TOTAL_SENSORS];
+    char* valueSensors[TOTAL_SENSORS];
     I2C_scan(sensors);
  
-    int i  = 1;
+    
     //unsigned int time = getNTPTime();
     unsigned int time = getSecsSince1900();
  
@@ -108,6 +140,24 @@ int main(void)
     unsigned int delay2 = 0;
     sleep_thread(SHORT_PERIOD - time%SHORT_PERIOD);
  
+    uint32_t ind[4]={0};
+    char** buffers[4];
+    uint32_t sizes[4]={0};
+
+    init_registry();
+    
+    if(timeout==1)
+    {
+        printf("Creating AP\r\n");
+        //corroborar los parametros del AP
+        configServer_start(1);
+        libwismart_WiFi_SoftAP_Start(NETWORK_SSID_AP,NETWORK_CHANNEL_AP,NULL,softapMode_apStartedCb, softapMode_clientIndicationCb);
+        for(;;)
+        {
+            chThdSleepMilliseconds(1000);
+        }
+    
+    int i  = 1;
     while(1){
         time += getElapsedTime(delay);
         printf("time (absolute):\t%d\r\ntime mod LONG_PERIOD:\t%d\r\ntime mod SHORT_PERIOD:\t%d\r\n",time,time%LONG_PERIOD,time%SHORT_PERIOD);
@@ -122,10 +172,12 @@ int main(void)
         printf("time (absolute):\t%d\r\ntime mod LONG_PERIOD:\t%d\r\ntime mod SHORT_PERIOD:\t%d\r\n",time,time%LONG_PERIOD,time%SHORT_PERIOD);
  
         delay = getSystemTime();
+        //cada mitja hora
         if (i == LONG_PERIOD/SHORT_PERIOD ){
             /* Wi-Fi connect */
             wifi_connect();
             /* Send data to server, empty the buffer */
+            send_data();
             //time = getNTPTime();
             time = getSecsSince1900();
             printf("time (absolute):\t%d\r\ntime mod LONG_PERIOD:\t%d\r\ntime mod SHORT_PERIOD:\t%d\r\n",time,time%LONG_PERIOD,time%SHORT_PERIOD);
@@ -138,8 +190,64 @@ int main(void)
         printf("timestamp (absolute):\t%d\r\ntimestamp mod LONG_PERIOD:\t%d\r\ntimestamp mod SHORT_PERIOD:\t%d\r\n",timestamp,timestamp%LONG_PERIOD,timestamp%SHORT_PERIOD);
  
         /* Add data to the buffer with timestamp*/
+        put_buffers(buffers,ind,sizes,valueSensors);
+        printf("mirant memoria\r\n");
+        int res=check_memory();
+        if(res==SOFT_REACHED){
+            printf("--------------soft limit-------------\r\n");
+            int j;
+            for(j=0;j<TOTAL_SENSORS;j++)
+            {
+                printf(" enviant buffer %d\r\n",j);
+                
+                // fem servir 085 de prova, però haurem de fer servir sensor_id[j]
+                int ok=send(buffers[j],&ind[j],&sizes[j], mod.ID, sensor_id[j]);
+
+                if(ok==JSON_COMM_ERROR)
+                {
+                    printf("wismart is not connected\r\n");
+                }
+                else if( ok==JSON_OTHER_ERROR){
+                    printf("some error ocurred\r\n");
+                }
+                else if(ok ==JSON_POST_OK){
+                    printf(" send OK \r\n");
+                }
+            }
+        }
+        else if(res==HARD_REACHED){
+            printf("--------------hard limit-------------\r\n");
+            
+            // fem servir 085 de prova, però haurem de fer servir sensor_id[0]
+            while( send(buffers[0],&ind[0],&sizes[0], mod.ID, sensors[j]) != JSON_POST_OK )
+            {
+                // El servidor no ens sap dir si tenim permisos o no sense registrar una mostra.
+                // Intentem enviar un buffer sencer, a veure si ja podem buidar.
+                // No podem enviar només una mostra perquè json és rígid en aquest sentit.
+            
+                printf("hard_reached and unable to sentd.\r\nLa biblia en vers: i Jesús digué: Aixeca't, Llàtzer!!\r\n");
+                chThdSleepMilliseconds(HARD_LIMIT_WAIT_TIME);
+            }
+            int j;
+            for(j=1;j<TOTAL_SENSORS;j++)
+            {
+                printf(" enviant buffer %d\r\n",j);
+                
+                // fem servir 085 de prova, però haurem de fer servir sensor_id[j]
+                int ok=send(buffers[j],&ind[j],&sizes[j], mod.ID, sensors[j]);
+                if(ok==JSON_COMM_ERROR)
+                {
+                    printf("wismart is not connected\r\n");
+                }
+                else if( ok==JSON_OTHER_ERROR){
+                    printf("some error ocurred\r\n");
+                }
+                else if(ok ==JSON_POST_OK){
+                    printf(" send OK \r\n");
+                }
+            }
+        }
         //a_cookedData = format_data(a_rawData, timestamp);
-        store_data(/* data */);
  
         time += getElapsedTime(delay);
         printf("time (absolute):\t%d\r\ntime mod LONG_PERIOD:\t%d\r\ntime mod SHORT_PERIOD:\t%d\r\n",time,time%LONG_PERIOD,time%SHORT_PERIOD);
@@ -160,7 +268,7 @@ int main(void)
     uint32_t sizes[4]={0};
 	char* sensor_id[4];
     int i;
-    int num_sensors;
+    
  
    init_registry();