File content as of revision 0:3b743e0d0126:

/* mbed Microcontroller Library
 * Copyright (c) 2019 ARM Limited
 * SPDX-License-Identifier: Apache-2.0
 */
#include "mbed.h"
//#include "platform/mbed_thread.h"
#include "Sht31.h"
#define MAXIMUM_BUFFER_SIZE
using namespace std;
//sda, scl
Sht31   temp_sensor(I2C_SDA, I2C_SCL);
    float t;
    float h;

Thread thread1;
Thread thread2;
DigitalOut led1(LED1);

UnbufferedSerial pc(USBTX, USBRX);
UnbufferedSerial  dev(D8, D2);


int dev_RxLen=0;
int pc_RxLen=0;
int hh,tt;
    
 char dev_RxBuf[64] = {0};
char pc_RxBuf[64] = {0};
  char buf4[64] = {0};
char buf_datchik[64] = {0};
  

// обработчики прерываний по приему байта с устройства и с компа- просто заполняют буферы свои- при достижении 64 байта в буфере -начинают заполнять снова с нуля
// нужны только для отладки - в рабочем режиме- тключить для экономии энергии
void dev_recv()
{
if (dev_RxLen<63){

    dev.read(&dev_RxBuf[dev_RxLen], sizeof(dev_RxBuf[dev_RxLen]));    //  Got 1 char
         
    dev_RxLen++;
}
else dev_RxLen=0;
    }


 
void pc_recv()
{
    if (pc_RxLen<63){
    pc.read(&pc_RxBuf[pc_RxLen], sizeof(pc_RxBuf[pc_RxLen]));  //  Got 1 char
    pc_RxLen++;
    }
else pc_RxLen=0;
}


void connect_to_server_lora_and_recieve_otvety()
{                   
  sprintf(buf4,"at+join\r\n"); 
  for (uint8_t i = 0; i < 9; i++) {  
    dev.write(&buf4[i], sizeof(buf4[i]));
//распечатать на консоль то что послано на  рак811
//    pc.write(&buf4[i], sizeof(buf4[i]));
        }  
         ThisThread::sleep_for(4s);  
     
        
    while (1) {    
    //нужно только для отладки -можно убрать
    //распечатать на консоль то что пришло  с рак811
//    for (uint8_t i = 0; i < dev_RxLen; i++) {  
//    pc.write(&dev_RxBuf[i], sizeof(dev_RxBuf[i]));}
 
     //распечатать на консоль то что пришло с компа    
 //   for (uint8_t i = 0; i < pc_RxLen; i++) {  
 //   pc.write(&pc_RxBuf[i], sizeof(pc_RxBuf[i]));}
    

        ThisThread::sleep_for(1s);
        }
   }
   

void read_datchik_and_send_to_server_lora()
{
     while (true) {
        t = temp_sensor.readTemperature();
        h = temp_sensor.readHumidity();
        int tt=round(t); //из-за того что %f не работает пришлось посылать округленные показания датчиков
        sprintf(buf_datchik,"temp= %d",tt); 
        for (uint8_t i = 0; i < 8; i++) {  
    pc.write(&buf_datchik[i], sizeof(buf_datchik[i]));}
     int hh=round(h);
        sprintf(buf_datchik,"himi= %d",hh); 
        for (uint8_t i = 0; i < 8; i++) {  
    pc.write(&buf_datchik[i], sizeof(buf_datchik[i]));}
    
    
    
          //послать округленные до целого данные с датчика темп-ры и без пробела с датчика влажности на  рак811
   //  sprintf(buf4,"at+send=lora:1:%d %d\r\n",tt,hh);
      sprintf(buf4,"at+send=lora:1:%d%d\r\n",tt,hh);    
    for (uint8_t i = 0; i < 21; i++) {  
    dev.write(&buf4[i], sizeof(buf4[i]));
    //продублировать это в консоль
    pc.write(&buf4[i], sizeof(buf4[i]));} 
     
          //послать округленные до целого данные с датчика влажности на  рак811 - попытка послать наканал 0 - так не работает 
          //это можно убрать
 //    sprintf(buf4,"at+send=lora:0:%d\r\n",hh);
//    for (uint8_t i = 0; i < 19; i++) {  
 //   dev.write(&buf4[i], sizeof(buf4[i]));
    //продублировать это в консоль
 //   pc.write(&buf4[i], sizeof(buf4[i]));} 
    
    
         
       ThisThread::sleep_for(20s);
}
}




int main()
{
    pc.attach(&pc_recv, UnbufferedSerial::RxIrq);
    dev.attach(&dev_recv, UnbufferedSerial::RxIrq);
        
    pc.baud(115200);
    dev.baud(115200);
    
//фориат передачи -по умолчанию - поэтому не нужно
  //     pc.format(8, BufferedSerial::None,  1    );
   //     dev.format(8, BufferedSerial::None, 1    );

    thread1.start(read_datchik_and_send_to_server_lora);
    thread2.start(connect_to_server_lora_and_recieve_otvety);
    
}