更具数采工程更新send TCP 文件

Cigarette/Thread/threadSendTCP.cpp

@@ -3,13 +3,25 @@
 #include <WS2tcpip.h>
 #include <stdio.h>
 #include <qtcpsocket.h>
+#include <PLCDevice.h>
 #pragma comment(lib, "ws2_32.lib")
 
+extern PLCDevice* m_PLCTCPDevice;
+extern PLCDevice* m_PLCDevice;
 void threadSendTCP::init(SyncQueue<_TCPSendInfo>* p_TCP_Info_queue, std::string ip_, int port_) {
     ip = QString::fromStdString(ip_);
     port = port_;
     qDebug() << "tcp ip:" << ip << "| tcp port:" << port;
     Local_TCP_Info_queue = p_TCP_Info_queue;
+
+#ifdef __TCPServer
+    tcpServer = new QTcpServer(this);
+	tcpServer->listen(QHostAddress::Any, port);// Equivalent to QHostAddress("127.0.0.1").
+    connect(tcpServer,SIGNAL(newConnection()),this,SLOT(onNewConnection()));
+	connect(mySocket, SIGNAL(connected()), this, SLOT(onClientConnected()));
+	connect(mySocket, SIGNAL(disconnected()), this, SLOT(onClientDisconnected()));
+#endif
+
 }
 void threadSendTCP::start_work()
 {
@@ -19,42 +31,195 @@ void threadSendTCP::start_work()
 
 void threadSendTCP::stop()
 {
+#ifdef __TCPServer
+	if (tcpServer->isListening())
+		tcpServer->close();
+	if(tcpServer) delete tcpServer;
+#endif
+#ifdef __TCPClient
+    mySocket->deleteLater();
+    if (mySocket) delete mySocket;
+#endif
     isLoop = false;
     // wait();
-    delete mySocket;
+
 }
 
+#ifdef __TCPClient
 bool threadSendTCP::connectTCP() {
     mySocket = new QTcpSocket();
     // 取消已有的连接
     mySocket->abort();
     // 连接服务器
     mySocket->connectToHost(ip, port);
-    if (!mySocket->waitForConnected(30000)) {
+    if (!mySocket->waitForConnected(100)) {
        qDebug() << "connect failed!";
        return false;
     }
     qDebug() << "connect successfully!";
     return true;
 }
+#endif
 
 void threadSendTCP::run()
 {
+    try {
+#ifdef __TCPClient
         if (!connectTCP())
+        {
             qDebug() << "TCP connect error!";
+        }
+#endif
         while (isLoop) {
             _TCPSendInfo TCPSendInfo;
             Local_TCP_Info_queue->take(TCPSendInfo);
             num++;
             sendData(&TCPSendInfo, num);
+#ifdef __TCPServer
+            if (ClientStatus == QAbstractSocket::ConnectedState)
+            {
+                sendData(&TCPSendInfo, num);
+            }
+#endif
+#ifdef __TCPClient
+            sendData(&TCPSendInfo, num);
+#endif
         //mySocket->write("Hello! here is tcp client!\n");
         //mySocket->flush();
         }
     }
+    catch (const std::exception& e) {
+        // 注意：std::exception通常不捕获由运行时错误引发的异常
+        // 但这里是为了演示catch块的结构
+        std::cerr << __FUNCTION__<<"捕获到异常: " << e.what() << std::endl;
+    }
+    catch (...) {
+        // 使用省略号（...）可以捕获所有类型的异常，这是一种通用的捕获方式
+        std::cerr << "捕获到未知类型的异常" << std::endl;
+    }
+}
+
 
 void threadSendTCP::sendData(_TCPSendInfo* TCPSendInfo, int Num) {
-    std::string fileName = TCPSendInfo->pics_name + ", " + QString::number(Num).toStdString();
+
+    std::string fileName = TCPSendInfo->pics_name;
+    QDateTime ts_start = QDateTime::currentDateTime();
+#if defined(__TCPServer) || defined(__TCPClient)
     mySocket->write(fileName.c_str());
+    char temp = num % 10;
+    mySocket->write((char*)&temp, sizeof(char));
     mySocket->write("\n");
     mySocket->flush();
+#endif
+
+#if defined(__ModebusServer) || defined(__ModebusClient)
+    std::vector<int> asciiVals = stringToAscii(fileName);
+    //mySocket->write(fileName.c_str());
+    /*int temp = num % 2;
+    if (temp == 1)
+    {
+        m_PLCDevice->write_bit_2_plc(10006, 1);
+
+    }
+    else
+    {
+        m_PLCDevice->write_bit_2_plc(10006, 0);
+    }*/
+
+    //mySocket->write((char*)&temp,sizeof(char));
+    //mySocket->write("\n");
+    //mySocket->flush();
+    // 
+    //遍历发送
+    int val_[32] = {};
+    uint8_t high[17] = {};
+    uint8_t low[17] = {};
+    uint16_t val[17] = {};
+    int h = 0;
+    int l = 0;
+    for (int i = 0; i < asciiVals.size(); i++)
+    {
+        if (i % 2 == 0)
+        {
+            high[h] = asciiVals[i];
+            h++;
+        }
+        else
+        {
+            low[l] = asciiVals[i];
+            l++;
+        }
+    }
+
+#endif
+
+#ifdef __ModebusServer
+    //m_PLCTCPDevice->write_2_plc(40000, 70, (uint16_t*)&val_);//小盒
+    m_PLCTCPDevice->write_2_plc(40070, 70, (uint16_t*)&val_);//条盒
+#endif
+
+#ifdef __ModebusClient
+
+    for (int i = 0; i < sizeof(val) / sizeof(short); i++)
+    {
+        val[i] = (static_cast<uint16_t>(high[i]) << 8) | low[i];//组合高低字节
+        m_PLCTCPDevice->mapping->tab_registers[i] = val[i];
+    }
+
+    /*uint16_t da, dat, data, data_, data__;
+    da = m_PLCTCPDevice->mapping->tab_registers[13];
+    dat = m_PLCTCPDevice->mapping->tab_registers[14];
+    data = m_PLCTCPDevice->mapping->tab_registers[15];
+    data_ = m_PLCTCPDevice->mapping->tab_registers[16];
+    data__ = m_PLCTCPDevice->mapping->tab_registers[17];
+    uint8_t da8[2], dat8[2], data8[2], data8_[2], data8__[2];
+    Ui16ToUin8_P(da, da8);
+    Ui16ToUin8_P(dat, dat8);
+    Ui16ToUin8_P(data, data8);
+    Ui16ToUin8_P(data_, data8_);
+    Ui16ToUin8_P(data__, data8__);
+    string str[8];
+    str[0] = std::to_string(data8[0]);
+    str[1] = std::to_string(data8[1]);
+    str[2] = std::to_string(data8_[0]);
+    str[3] = std::to_string(data8__[0]);
+    str[4] = std::to_string(dat8[0]);
+    str[7] = std::to_string(da8[1]);
+    cout << "tcp_send_times:" << num << endl;
+    cout << "data:" << str[7] << str[4] << "." << str[0] << str[1] << str[2] << "_" << str[3] << endl;*/
+
+#endif
+
+}
+//字符串转ASCII
+std::vector<int> threadSendTCP::stringToAscii(const std::string& str)
+{
+    std::vector<int> asciiValues;
+    for (char c : str) {
+        asciiValues.push_back(static_cast<int>(c));
+    }
+    return asciiValues;
+}
+
+#ifdef __TCPServer
+void threadSendTCP::onNewConnection()
+{
+    mySocket = tcpServer->nextPendingConnection(); //创建socket
+	qDebug() << "NewConnectionConnected";
+	ClientStatus = QAbstractSocket::ConnectedState;
+    
+}
+
+void threadSendTCP::onClientConnected()
+{
+    
+    qDebug() << "ClientConnected";
+}
+
+void threadSendTCP::onClientDisconnected()
+{
+    ClientStatus = QAbstractSocket::UnconnectedState;
+    qDebug() << "ClientDisconnected";
+	mySocket->deleteLater();
 }
+#endif

Cigarette/Thread/threadSendTCP.h

@@ -1,16 +1,20 @@
 #pragma once
+#include "common.h"
+#include <QWidget>
 #include <QDebug>
 #include <QDateTime>
 #include <iostream>
 #include <QThread>
 #include <qtcpsocket.h>
-#include "common.h"
 #include "SyncQueue.h"
+#include <QTcpServer>
 
 class _TCPSendInfo
 {
 public:
     std::string pics_name;
+    std::string result;
+    std::string num;
 
     _TCPSendInfo()
     {
@@ -38,8 +42,9 @@ public:
         wait();
     }
     void stop();
+#ifdef __TCPClient
     bool connectTCP();
-
+#endif
 protected:
     void run();
 
@@ -47,9 +52,21 @@ public:
     void init(SyncQueue<_TCPSendInfo>* p_TCP_Info_queue, std::string ip_, int port_);
     void start_work();
     void sendData(_TCPSendInfo* TCPSendInfo, int Num);
-
+    std::vector<int> stringToAscii(const std::string& str);
+#ifdef __TCPServer
+private slots:
+    void    onNewConnection();
+    void    onClientConnected();
+    void    onClientDisconnected();
+#endif
 public:
     SyncQueue<_TCPSendInfo>* Local_TCP_Info_queue;
     std::atomic_bool isLoop = { 0 };
-    QTcpSocket* mySocket;
+#if defined(__TCPServer) || defined(__TCPClient)
+    QTcpSocket* mySocket = NULL;
+#endif
+#ifdef __TCPServer
+    QTcpServer *tcpServer = NULL;
+    QAbstractSocket::SocketState ClientStatus;
+#endif
 };