Russian Qt Forum

//+++++++функция обработки данных и получения с датчика

QString ReadWrite (QString serial,QString nms,QString nameFile,FT_HANDLE ftHandle1)
{
             FT_STATUS ftStatus1;
             DWORD BytesWritten1;
             //DWORD sizeMsg;
             QString TxBuffer1;
            QString lrc;
           // int msg;
            nms=QString::number( nms.toInt()+1);
            TxBuffer1="#TPO,TO:";
            TxBuffer1.append(serial);
            TxBuffer1.append(QString(",FROM:")).append( QString("000001,")).append("PAS:1111,NMS:");
            TxBuffer1.append(nms);
            TxBuffer1.append(",GET_DATA:DBG_DATA,LRC:");
            lrc="00";
            QString TxBuffer1NEW = TxBuffer1;
            TxBuffer1.append(lrc).append(",#TPE");
            QString a;
            a = TxBuffer1;
            QByteArray buffer1 = TxBuffer1.toAscii();
            char * p;
            p = buffer1.data();
           quint8 cSummator;
           int lrC =buffer1.length();

           for (int k=5;k<=(lrC-5);k++)
           {
               cSummator = cSummator+p[k];
           }
           //подсчет лрц
           int cFirst,cSecond;
           cFirst=cSummator/16;
           cSecond = cSummator % 16;
           if (cFirst>9)
           {cFirst=cFirst+55;} else cFirst=cFirst+48;
           if(cSecond>9) {cSecond=cSecond+55;} else cSecond=cSecond+48;
           lrc = QString(cFirst);
           lrc.append(cSecond);
         //  cSummator = lrc.toUInt()- 0xFF+1;
           //lrc = cSummator;
           TxBuffer1NEW.append(lrc).append(",#TPE");
            QByteArray TBuffer1= TxBuffer1NEW.toAscii();
             DWORD sizeMsg;
             int dlinaComand;
             dlinaComand =TxBuffer1.length();
             sizeMsg = TxBuffer1.length();




// отправка команды



             ftStatus1 = FT_Write(ftHandle1,
                                 TBuffer1.data(),
                                 sizeMsg,
                                 &BytesWritten1);


            if (ftStatus1 == FT_OK)
            {//если строчка прошла успешно
             //progres=progres+1;


            }
            else
            {                        QMessageBox::warning(0,"ОШИБКА",
                                     "ошибка при обмене сообщениями с датчиком топлива \n"
                                     "перезапустите программу и повторите попытку",
                                     QMessageBox::Ok,QMessageBox::Ok);


            }



//чтение ответa с прибора

                  DWORD BytesReceived;
                  DWORD RxBytes = 100;
                  char RxBuffer[255]= "0";
                 //  FT_SetTimeouts(ftHandle1,250,250);
                  ftStatus1 = FT_Read(ftHandle1,RxBuffer,RxBytes,&BytesReceived);
                 QString sbufRead;
                 int sum=0;
                 sum= sum+ BytesReceived;
                 sbufRead = QString(RxBuffer);
                 ftStatus1 = FT_Read(ftHandle1,RxBuffer,RxBytes,&BytesReceived);
                 sum= sum+ BytesReceived;
                 sbufRead.append(QString(RxBuffer));
                 QString otvet;

                 QFile fl(nameFile);
                 fl.open(QIODevice::Append | QIODevice::Text );
                 QTextStream out(&fl);
                 out << nms;
                 out <<  endl;
                 fl.close();

                 for(int cm = dlinaComand;cm <= sbufRead.length();cm++)
                 {   if (sbufRead[cm]=='#'&& sbufRead[cm+1]=='T' && sbufRead[cm+2]=='P' && sbufRead[cm+3] == 'E' )
                         {
                                 otvet = otvet.append(sbufRead[cm]);
                                 otvet = otvet.append(sbufRead[cm+1]);
                                 otvet = otvet.append(sbufRead[cm+2]);
                                 otvet = otvet.append(sbufRead[cm+3]);
                                 break;
                         }
                 otvet = otvet.append(sbufRead[cm]);
                 }

          int error=0;
          int dlinaOtvet=0;
          dlinaOtvet = otvet.length();
          if (ftStatus1 == FT_OK)
                 {
                         if (dlinaOtvet+dlinaComand ==sum )
                                 {


                                       // запись ответов датчика
                                            QString  sPokazateli;
                                            for(int datc1=1; datc1<dlinaOtvet;datc1++)
                                                   {
                                                    if (otvet[datc1]=='L'&& otvet[datc1+1]=='U' && otvet[datc1+2]=='E' && otvet[datc1+3]==':')
                                                         {
                                                          datc1 = datc1+4;
                                                          while ( otvet[datc1]!=',' && otvet[datc1+1]!='L' && otvet[datc1+2]!='R' && otvet[datc1+3]!='C' )
                                                          {
                                                 if ((otvet[datc1]!=';') )
                                                 {
                                                    sPokazateli.append(otvet[datc1]);
                                                     datc1++;
                                                     if (otvet[datc1] ==',')
                                                  {
                                                         QFile d1(nameFile);
                                                         d1.open(QIODevice::Append | QIODevice::Text );
                                                         QTextStream out(&d1);


                                                         out << sPokazateli;
                                                         out <<   endl;
                                                           d1.close();
                                                          sPokazateli.clear();
                                                         // break;
                                                      }}

                                                    else
                                                          {
                                                           QFile d1(nameFile);
                                                           d1.open(QIODevice::Append | QIODevice::Text );
                                                           QTextStream out(&d1);
                                                           out << sPokazateli;
                                                           out <<   endl;
                                                           d1.close();
                                                           sPokazateli.clear();
                                                           datc1++;
                                                           }
                                                           }
                                                }
                                                 }


                          }


else
     { error++;
       if (error <=3)
        {
         QMessageBox::warning(0,"ОШИБКА",
           "тест провален 3 подрят ошибки обмена с датчиком \n"
           "перезапустите программу и повторите попытку",
            QMessageBox::Ok,QMessageBox::Ok);
               }
   }
     }
      return nms;
      }

 if (chet_dat<=12)
       {    switch(chet_dat)
            {
            case 1:
               {

               QString name_file1 = "datchic1.txt";
               QFuture <void> future1a= QtConcurrent::run(tempiratura_datchika,tn1,name_file1,nms,ftHandle1,serial1);
               
               break;
                }
            case 2:
               {
               QString name_file2 = "datchic2.txt";

              QFuture <void> future2a = QtConcurrent::run(tempiratura_datchika,tn2,name_file2,nms,ftHandle1,serial2);
               break;
               }
            case 3:
               {
               QString name_file3 = "datchic3.txt";
               QFuture <void> future3a = QtConcurrent::run(tempiratura_datchika,tn3,name_file3,nms,ftHandle1,serial3);
               break;
               }
            case 4:
               {
               QString name_file4 = "datchic4.txt";
                QFuture <void> future4a = QtConcurrent::run( tempiratura_datchika,tn4,name_file4,nms,ftHandle1,serial4);

               break;
               }
            case 5:
               {
               QString name_file5 = "datchic5.txt";
               QFuture <void> future5a = QtConcurrent::run(  tempiratura_datchika,tn5,name_file5,nms,ftHandle1,serial5);

               break;
               }
            case 6:
               {
               QString name_file6 = "datchic6.txt";
               QFuture <void> future6a = QtConcurrent::run( tempiratura_datchika,tn6,name_file6,nms,ftHandle1,serial6);
               break;
               }
            case 7:
               {
               QString name_file7 = "datchic7.txt";
          
               QFuture <void> future7a = QtConcurrent::run( tempiratura_datchika,tn7,name_file7,nms,ftHandle1,serial7);

               break;
               }
            case 8:
               {
               QString name_file8 = "datchic8.txt";
            
               QFuture <void> future8a = QtConcurrent::run( tempiratura_datchika,tn8,name_file8,nms,ftHandle1,serial8);

               break;
               }
            case 9:
               {
               QString name_file9 = "datchic9.txt";
              
               QFuture <void> future9a = QtConcurrent::run(   tempiratura_datchika,tn9,name_file9,nms,ftHandle1,serial9);
               break;
               }
            case 10:
               {
               QString name_file10 = "datchic10.txt";
            
                QFuture <void> future10a = QtConcurrent::run(tempiratura_datchika,tn10,name_file10,nms,ftHandle1,serial10);

               break;
               }
            case 11:
               {
               QString name_file11 = "datchic11.txt";
          
               QFuture <void> future11a = QtConcurrent::run( tempiratura_datchika,tn11,name_file11,nms,ftHandle1,serial11);

               break;
               }
            case 12:
               {
                QString name_file12 = "datchic12.txt";
                QFuture <void> future12a = QtConcurrent::run(tempiratura_datchika,tn12,name_file12,nms,ftHandle1,serial12);

               break;
               }

 QFuture <void> future1a= QtConcurrent::run(tempiratura_datchika,tn1,name_file1,nms,ftHandle1,serial1,tk1);

 void someFunction(int arg1, double arg2);
 QFuture<void> future = QtConcurrent::run(boost::bind(someFunction, 1, 2.0));

QFuture <void> future1a= QtConcurrent::run(bind(tempiratura_datchika,tn1,name_file1,nms,ftHandle1,serial1,tk1));