12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697 |
- #ifndef WEBSOCKETSERVER_H
- #define WEBSOCKETSERVER_H
- #include <QObject>
- #include <QList>
- #include <QByteArray>
- #include <QDateTime>
- #include <QString>
- #include <QTimer>
- #include <QFile>
- #include <QtNetwork/QSslError>
- #include <QJsonDocument>
- #include <QJsonObject>
- #include <QJsonValue>
- #include <QJsonParseError>
- #include <QUuid>
- #include <QSqlDatabase>
- #include <QSqlQuery>
- QT_FORWARD_DECLARE_CLASS(QWebSocketServer)
- QT_FORWARD_DECLARE_CLASS(QWebSocket)
- typedef struct {
- QString DataTime;
- QString StationId;
- QString Values;
- } ReceivePatrolRecord;
- class WebSocketClient {
- public:
- explicit WebSocketClient(QString cmd="",QWebSocket *so=nullptr){
- Cmd = cmd;
- StationId = "";
- StationName = "";
- DeviceId="";
- BusAddr="";
- Count="";
- Start="";
- Limit="";
- Order="";
- Time="";
- m_client=so;
- }
- QString Cmd ;
- QString StationId;
- QString StationName;
- QString DeviceId;
- QString BusAddr;
- QString Count;
- QString Start;
- QString Limit;
- QString Order;
- QString Time;
- QWebSocket *m_client;
- };
- class WebSocketServer : public QObject
- {
- Q_OBJECT
- public:
- explicit WebSocketServer(QObject *parent = nullptr);
- ~WebSocketServer();
- void start();
- void appendData(QString data);
- void patrolrecord(QList<QStringList> PatrolList);
- void ercodeSent(QString phone);
- signals:
- void closed();
- void weblog(QString emitlog);
- public slots:
- void onNewConnection();
- void processTextMessage(QString message);
- void socketDisconnected();
- void timeout();
- void onSslErrors(const QList<QSslError> &errors);
- private:
- int counttemp;
- QWebSocketServer *m_pWebSocketServer;
- QList<WebSocketClient *> clientList;
- QTimer *timer;
- QTimer *timerdata;
- QStringList datalist;
- int count;
- QSqlDatabase db;
- QList<QStringList> PatrolList;
- QList<ReceivePatrolRecord> PatrolRecordList;
- };
- #endif // WEBSOCKETSERVER_H
|