hxx 2 jaren geleden
bovenliggende
commit
f3ec19988f

+ 12 - 15
CAE_Solution/src/Rabbitmq/rabbitClient/rabbitclient.cpp

@@ -110,22 +110,19 @@ int rabbitClient::recvMsg()
         cout<<"str.c_str() = "<<str.c_str()<<endl;
         printf("------------recvClient recvMsg-------------------\n");
         if(str!=""){
+            str.erase(0,1);
+            str.erase(str.end()-1);
+            std::string t;
+            for (int var = 0; var < str.length(); ++var) {
+                if(str[var]=='\\'){
 
-            QJsonParseError jsonError;
-//            QByteArray array=QByteArray::fromStdString(str);
-//            qDebug()<<"array ="<<array;
-//            std::string str_ = array.toStdString();
-//            cout<<"str_ = "<<str_<<endl;
-//            QByteArray array2(str.c_str(),str.length());
-//            qDebug()<<"array2 = "<<array2;
-//            QByteArray array3;
-//            for(int i=0;i<str.length();i++){
-//                array3.append(str[i]);
-//            }
-//            qDebug()<<"array3 = "<<array3;
-            QJsonDocument doucment = QJsonDocument::fromJson(str.c_str(), &jsonError);  // 转化为 JSON 文档
-            qDebug()<<"error!"<<jsonError.errorString();
-            emit sendmsg_recvclientToRecvstate(str);//信号
+                }else{
+                    t+=str[var];
+                }
+            }
+            cout<<"t="<<t<<endl;
+            cout<<"t.c_str() = "<<t.c_str()<<endl;
+            emit sendmsg_recvclientToRecvstate(t);//信号
         }
         QThread::sleep(1);
     }

+ 6 - 1
CAE_Solution/src/main.cpp

@@ -21,7 +21,7 @@ VTK_MODULE_INIT(vtkRenderingFreeType)
 #include <QMutex>
 #include "widget.h"
 #include "threadPool_and_statemachine/dealWith/handlepool.h"
-
+#include "threadPool_and_statemachine/dealWith/vtkjsonobject.h"
 
 int main(int argc, char *argv[])
 {
@@ -59,4 +59,9 @@ int main(int argc, char *argv[])
     QObject::connect(handle,SIGNAL(sendWidget_handlePoolToWidget(QWidget*)),&w,SLOT(getWidget_handlePoolToWidget(QWidget*)));
 
     return a.exec();
+//    std::string recvmsg="{\"usrId\":\"20b49733a2934704ac338a7d27b8f23f\",\"solverConfigid\":\"ac21409a892047a68fe2beabc3f24f14\",\"proId\":\"13538bee645c49f599dd10a7f77665c4\",\"paramJson\":\"\",\"action\":\"init\"}";
+//    cout<<"recvmsg="<<recvmsg<<endl;
+//    cout<<"recvmsg.c_str() = "<<recvmsg.c_str()<<endl;
+//    vtkJsonObject* json_object = new vtkJsonObject();
+//    json_object->FromJSON(recvmsg);
 }

+ 1 - 1
CAE_Solution/src/threadPool_and_statemachine/dealWith/handlepool.cpp

@@ -1,5 +1,5 @@
 #include "handlepool.h"
-
+#include <iostream>
 /*
  * @brief:the constructor
  * @param:

+ 1 - 0
CAE_Solution/src/threadPool_and_statemachine/dealWith/vtkjsonobject.cpp

@@ -31,6 +31,7 @@ vtkJsonObject::~vtkJsonObject()
 void vtkJsonObject::FromJSON(std::string msg)
 {
     //QByteArray byteArray(msg.c_str(),msg.length());
+
     QJsonParseError jsonError;
     QJsonDocument doucment = QJsonDocument::fromJson(msg.c_str(), &jsonError);  // 转化为 JSON 文档
     if(jsonError.error!=QJsonParseError::NoError)qDebug()<<"error!"<<jsonError.errorString();