Merge branch 'master' of ssh://115.28.86.8:29418/~admin/昆仑_1025

congmu

2024-11-06 31037e4ce8e0f45d4058184d60b358b5eadb50e1

Merge branch 'master' of ssh://115.28.86.8:29418/~admin/昆仑_1025

 Client/Áõ×Óº½/log/ÈÕÖ¾_Áõ×Óº½_1106.doc

Binary files differ

 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/2024kunlun_project_permisson.pro.user

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE QtCreatorProject>
<!-- Written by QtCreator 4.5.0, 2024-10-31T16:02:45. -->
<!-- Written by QtCreator 4.5.0, 2024-11-04T20:34:52. -->
<qtcreator>
 <data>
  <variable>EnvironmentId</variable>

 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/PmsClientSocket.cpp

@@ -5,7 +5,7 @@
PmsClientSocket::PmsClientSocket(QWidget * parent):QWidget(parent)
{
    client = new QTcpSocket(this);

    connect(client,SIGNAL(connected()),this,SLOT(connected_Slot()));
    client->connectToHost(targetIp,port);
    if(!client->waitForConnected(3000)){

@@ -14,14 +14,12 @@
    }
    connectSuccess = true;
    qDebug()<< "QT网络通信成功已连接服务器！";
    connect(client,SIGNAL(connected()),this,SLOT(connected_Slot()));

}

void PmsClientSocket::queryAllUserAboutUser()
{
    if(connectSuccess){
        QueryPmsRequest req;
        QueryPmsReq req;
        client->write((char *)&req,req.head.len);
        qDebug() << "查询全部权限请求发送成功";
    }
@@ -30,10 +28,10 @@
void PmsClientSocket::queryPmsByParam(PmsParam param)
{
    if(connectSuccess){
        QueryPmsRequest req;
        strcpy(req.name,param.getName().c_str());
        strcpy(req.permissonType,param.getPermissonType().c_str());
        strcpy(req.userNo,param.getUserNo().c_str());
        QueryPmsReq req;
        strcpy(req.name,param.getName().toLocal8Bit().data());
        strcpy(req.permissonType,param.getPermissonType().toLocal8Bit().data());
        strcpy(req.userNo,param.getUserNo().toLocal8Bit().data());
        client->write((char *)&req,req.head.len);
        qDebug() << "条件查询权限请求发送成功";
    }
@@ -41,12 +39,23 @@

void PmsClientSocket::updatePmsByParam(PmsPlusParma param)
{
    UpdatePmsRequest upReq;
    upReq.devManage = param.getDevManage();
    upReq.loggerSearch = param.getLoggerSearch();
    upReq.mapMark = param.getMapMark();
    upReq.productPlan = param.getProductPlan();
    upReq.roleId = param.getRoleId();
    UpdatePmsReq upReq;

    upReq.id = param.getId();
    if(param.getPermissonType().isEmpty()){
        upReq.devManage = param.getDevManage();
        upReq.loggerSearch = param.getLoggerSearch();
        upReq.mapMark = param.getMapMark();
        upReq.productPlan = param.getProductPlan();
        upReq.warningManage = param.getWarninManage();
        upReq.versionManage = param.getVersionManage();
        upReq.admin = param.getAdmin();
        upReq.queryHistory = param.getQueryHistory();

        memset(upReq.permissonType,0,32);
    }else {
        strcpy(upReq.permissonType,param.getPermissonType().toLocal8Bit().data());
    }
    client->write((char *)&upReq,upReq.head.len);
    qDebug() << "更新权限请求发送成功";
}
@@ -59,40 +68,45 @@
void PmsClientSocket::readyRead_Slot()
{
    QByteArray buf = client->readAll();
    QString recvData = QString::fromLocal8Bit(buf);
    qDebug()<< "client收到的数据" << recvData;
    QueryPmsResponse * res;
    UpdatePmsResponse * upRes;
    int type = *(int *)buf.data();
    if(type == QUERY_PMS_REQ){
          res = (QueryPmsResponse *)buf.data();
    qDebug()<< "client收到了的数据";
    QueryPmsRes * res;
    UpdatePmsRes * upRes;
    Head head = *(Head *)buf.data();
    if(head.type == QUERY_PMS_RES){
        qDebug()<< "查询响应";
          res = (QueryPmsRes *)buf.data();
          if(res->success){
              vector<PmsQueryResult> vecs;
              int pmsLen = res->head.len-sizeof(QueryPmsResponse);
              for(int i =0;i<pmsLen;i+=sizeof(PmsRes)){
                  PmsRes structRes = *(PmsRes*)(res + sizeof(QueryPmsResponse) + i*sizeof(PmsRes));
                      PmsQueryResult res;
                      res.setName(string(structRes.name));
                      res.setUserNo(string(structRes.userNo));
                      res.setRoleId(structRes.roleId);
                      res.setStartDateTime(string(structRes.startDateTime));
                      res.setEndDateTime(string(structRes.endDateTime));
                      res.setLoggerSearch(structRes.loggerSearch);
                      res.setMapMark(structRes.mapMark);
                      res.setDevManage(structRes.devManage);
                      res.setProductPlan(structRes.productPlan);
                      res.setQueryHistory(structRes.queryHistory);
                      res.setPermissonType(string(structRes.permissonType));
                      vecs.push_back(res);
              int pmsLen = (res->head.len-sizeof(QueryPmsRes))/sizeof(PmsRes);
              for(int i =0;i<pmsLen;i++){
                  PmsRes structRes = res->pmsList[i];
                      PmsQueryResult qres;
                      qres.setName(QString::fromLocal8Bit(structRes.name));
                      qres.setUserNo(QString::fromLocal8Bit(structRes.userNo));
                      qres.setId(structRes.id);
                      qres.setLoginTime(string(structRes.loginTime));
                      qres.setRegisterTime(string(structRes.registerTime));
                      qres.setLoggerSearch(structRes.loggerSearch);
                      qres.setMapMark(structRes.mapMark);
                      qres.setDevManage(structRes.devManage);
                      qres.setProductPlan(structRes.productPlan);
                      qres.setQueryHistory(structRes.queryHistory);
                      qres.setPermissonType(QString::fromLocal8Bit(structRes.permissonType));
                      qres.setWarninManage(structRes.warningManage);
                      qres.setVersionManage(structRes.versionManage);
                      qres.setAdmin(structRes.admin);
                      vecs.push_back(qres);
              }
              if(!vecs.empty()){
                  emit notifyDateChange(vecs);
              }
              emit notifyDateChange(vecs);
          }else{
              // æŸ¥è¯¢å¤±è´¥æ•°æ®ä¸ºç©ºæ¸…除表格数据
              emit notifyDateChange(vector<PmsQueryResult>());
          }
    }
    if(type == UPDATE_PMS_REQ){
        res = (QueryPmsResponse *)buf.data();
        if(res->success){
    if(head.type == UPDATE_PMS_RES){
        upRes = (UpdatePmsRes *)buf.data();
        qDebug()<< "更新响应";
        if(upRes->success){
            QString dlgTitle = "更新结果";
            QString strInfo = "权限信息更新成功";
            QMessageBox::information(this,dlgTitle,strInfo,

 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/PmsClientSocket.h

@@ -16,7 +16,7 @@
};

enum option{
    QUERY_PMS_REQ,
    QUERY_PMS_REQ=6,
    UPDATE_PMS_REQ,
    QUERY_PMS_RES,
    UPDATE_PMS_RES,
@@ -24,73 +24,84 @@


// æŒ‰å‘˜å·¥ç¼–号、名字或职位查询人员权限信息请求
typedef struct QueryPmsRequest{
typedef struct QueryPmsReq{
    Head head;
    char userNo[32];
    char name[32];
    char permissonType[32];
    QueryPmsRequest(){
    QueryPmsReq(){
        head.type=QUERY_PMS_REQ;
        memset(userNo,0,32);
        memset(permissonType,0,32);
        memset(name,0,32);
        head.len = sizeof(QueryPmsRequest);
        head.len = sizeof(QueryPmsReq);
    }
} QueryPmsRequest;
} QueryPmsReq;

// æŒ‰è§’色id更新权限信息请求
typedef struct UpdatePmsRequest{
typedef struct UpdatePmsReq{
    Head head;
    int roleId;
    // äººå‘˜è¡¨ä¸»é”®id
    int id;
    int queryHistory;
    int loggerSearch;
    int mapMark;
    int devManage;
    int productPlan;
    UpdatePmsRequest(){
        head.type=QUERY_PMS_RES;
        head.len = sizeof(UpdatePmsRequest);
    }
} UpdatePmsRequest;
    int warningManage;
    int versionManage; //版本管理
    int admin; //系统管理员

// å•ä¸ªäººå‘˜æƒé™ç»“构体
typedef struct UserAboutPms{
    char permissonType[32];
    UpdatePmsReq(){
        head.type=UPDATE_PMS_REQ;
        head.len = sizeof(UpdatePmsReq);
    }
} UpdatePmsReq;

// å•ä¸ªäººå‘˜å’Œæƒé™è”合查询结构体
typedef struct PmsRes{
    int queryHistory;
    int loggerSearch;
    int mapMark;
    int devManage;
    int productPlan;
    int roleId;
    int versionManage; //版本管理
    int warningManage;
    int admin; //系统管理员

    int id;

    char userNo[32];
    char name[32];
    char permissonType[32];
    char startDateTime[32];
    char endDateTime[32];

    char permissonType[32];  // è§’色类型

    char department[32];
    char loginTime[32];
    char registerTime[32];
} PmsRes;

// æŸ¥è¯¢äººå‘˜å’Œè§’色信息的响应结构体
typedef struct UserAboutPmsResponse{
typedef struct QueryPmsRes{
    Head head;
    int success; // 1为成功 ,0为失败
    //PmsRes pmsList[100];
    char pmsList[0];
    UserAboutPmsResponse(){
    PmsRes pmsList[0];
    QueryPmsRes(){
        head.type=QUERY_PMS_RES;
//        memset(pmsList,0,sizeof(PmsRes));
//        head.len = sizeof(UserAboutPmsResponse);
    }
} QueryPmsResponse;
} QueryPmsRes;

// æƒé™æ›´æ–°ç»“果响应体
typedef struct UpdatePmsResponse{
typedef struct UpdatePmsRes{
    Head head;
    int success; // 1为成功 ,0为失败
    UpdatePmsResponse(){
    UpdatePmsRes(){
        head.type = UPDATE_PMS_RES;
        head.len = sizeof(UpdatePmsResponse);
        head.len = sizeof(UpdatePmsRes);
    }

} UpdatePmsResponse ;
} UpdatePmsRes ;


class PmsClientSocket : public QWidget
@@ -99,7 +110,7 @@

    QTcpSocket *client;

    int port=88888;
    int port=16888;
    QString targetIp = "127.0.0.1";

    bool connectSuccess= false;

 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/permissondialog.cpp

@@ -34,11 +34,29 @@
    map5[2]=ui->radioButton_15;


    map<int,QRadioButton *> warningMap;
    warningMap[0]=ui->radioButton_16;
    warningMap[1]=ui->radioButton_17;
    warningMap[2]=ui->radioButton_18;

    map<int,QRadioButton *> versionMap;
    versionMap[0]=ui->radioButton_19;
    versionMap[1]=ui->radioButton_20;
    versionMap[2]=ui->radioButton_21;

    map<int,QRadioButton *> superManager;
    // 1为超级管理员
    superManager[0]=ui->radioButton_23;
    superManager[1]=ui->radioButton_22;

    btnList.push_back(map1);
    btnList.push_back(map2);
    btnList.push_back(map3);
    btnList.push_back(map4);
    btnList.push_back(map5);
    btnList.push_back(warningMap);
    btnList.push_back(versionMap);
    btnList.push_back(superManager);

}

@@ -50,7 +68,7 @@
int PermissonDialog::findBoxCheck(map<int, QRadioButton *> map)
{
    for(int i =0;i<map.size();i++){
        if(btnList[0][i]->isChecked()){
        if(map[i]->isChecked()){
            return i;
        }
    }
@@ -65,6 +83,12 @@
    btnList[2][res.getMapMark()]->setChecked(true);
    btnList[3][res.getDevManage()]->setChecked(true);
    btnList[4][res.getProductPlan()]->setChecked(true);

    btnList[5][res.getWarninManage()]->setChecked(true);

    btnList[6][res.getVersionManage()]->setChecked(true);

    btnList[7][res.getAdmin()]->setChecked(true);

    curRes = res;

@@ -81,8 +105,11 @@
    param.setMapMark(findBoxCheck(btnList[2]));
    param.setDevManage(findBoxCheck(btnList[3]));
    param.setProductPlan(findBoxCheck(btnList[4]));
    param.setWarninManage(findBoxCheck(btnList[5]));
    param.setVersionManage(findBoxCheck(btnList[6]));
    param.setAdmin(findBoxCheck(btnList[7]));

    param.setRoleId(curRes.getRoleId());
    param.setId(curRes.getId());
    client->updatePmsByParam(param);

}

 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/permissondialog.ui

@@ -6,8 +6,8 @@
   <rect>
    <x>0</x>
    <y>0</y>
    <width>421</width>
    <height>361</height>
    <width>560</width>
    <height>492</height>
   </rect>
  </property>
  <property name="windowTitle">
@@ -16,54 +16,18 @@
  <layout class="QGridLayout" name="gridLayout_3">
   <item row="0" column="0">
    <layout class="QGridLayout" name="gridLayout_2">
     <item row="3" column="0">
      <widget class="QDialogButtonBox" name="buttonBox">
       <property name="orientation">
        <enum>Qt::Horizontal</enum>
       </property>
       <property name="standardButtons">
        <set>QDialogButtonBox::Cancel|QDialogButtonBox::Ok</set>
       </property>
      </widget>
     </item>
     <item row="0" column="0">
      <layout class="QGridLayout" name="gridLayout">
       <item row="0" column="0">
        <widget class="QGroupBox" name="groupBox">
         <property name="title">
          <string>历时查询</string>
         </property>
         <widget class="QRadioButton" name="radioButton">
          <property name="geometry">
           <rect>
            <x>20</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>无权限</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_2">
          <property name="geometry">
           <rect>
            <x>150</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>可查看</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_3">
          <property name="geometry">
           <rect>
            <x>280</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>可修改</string>
          </property>
         </widget>
        </widget>
       </item>
       <item row="1" column="0">
        <widget class="QGroupBox" name="groupBox_2">
         <property name="title">
@@ -96,6 +60,52 @@
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_6">
          <property name="geometry">
           <rect>
            <x>280</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>可修改</string>
          </property>
         </widget>
        </widget>
       </item>
       <item row="0" column="0">
        <widget class="QGroupBox" name="groupBox">
         <property name="title">
          <string>历时查询</string>
         </property>
         <widget class="QRadioButton" name="radioButton">
          <property name="geometry">
           <rect>
            <x>20</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>无权限</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_2">
          <property name="geometry">
           <rect>
            <x>150</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>可查看</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_3">
          <property name="geometry">
           <rect>
            <x>280</x>
@@ -248,17 +258,132 @@
         </widget>
        </widget>
       </item>
       <item row="5" column="0">
        <widget class="QGroupBox" name="groupBox_6">
         <property name="title">
          <string>警报管理</string>
         </property>
         <widget class="QRadioButton" name="radioButton_16">
          <property name="geometry">
           <rect>
            <x>20</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>无权限</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_17">
          <property name="geometry">
           <rect>
            <x>150</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>可查看</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_18">
          <property name="geometry">
           <rect>
            <x>280</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>可修改</string>
          </property>
         </widget>
        </widget>
       </item>
       <item row="6" column="0">
        <widget class="QGroupBox" name="groupBox_7">
         <property name="title">
          <string>版本管理</string>
         </property>
         <widget class="QRadioButton" name="radioButton_19">
          <property name="geometry">
           <rect>
            <x>20</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>无权限</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_20">
          <property name="geometry">
           <rect>
            <x>150</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>可查看</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_21">
          <property name="geometry">
           <rect>
            <x>280</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>可修改</string>
          </property>
         </widget>
        </widget>
       </item>
       <item row="7" column="0">
        <widget class="QGroupBox" name="groupBox_8">
         <property name="title">
          <string>超级管理员</string>
         </property>
         <widget class="QRadioButton" name="radioButton_22">
          <property name="geometry">
           <rect>
            <x>20</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>是</string>
          </property>
         </widget>
         <widget class="QRadioButton" name="radioButton_23">
          <property name="geometry">
           <rect>
            <x>150</x>
            <y>20</y>
            <width>115</width>
            <height>19</height>
           </rect>
          </property>
          <property name="text">
           <string>否</string>
          </property>
         </widget>
        </widget>
       </item>
      </layout>
     </item>
     <item row="1" column="0">
      <widget class="QDialogButtonBox" name="buttonBox">
       <property name="orientation">
        <enum>Qt::Horizontal</enum>
       </property>
       <property name="standardButtons">
        <set>QDialogButtonBox::Cancel|QDialogButtonBox::Ok</set>
       </property>
      </widget>
     </item>
    </layout>
   </item>

 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/permissonwindow.cpp

@@ -11,46 +11,20 @@
    ui(new Ui::PermissonWindow)
{
    ui->setupUi(this);
    clientSocket = new PmsClientSocket(this);

    dia = new PermissonDialog(this,clientSocket);



    connect(this,SIGNAL(sendUserNo(PmsQueryResult)),dia,SLOT(recvUserNo(PmsQueryResult)));
    connect(clientSocket,SIGNAL(notifyDateChange(vector<PmsQueryResult>)),this,SLOT(renderItemData(vector<PmsQueryResult>)));

    roleMap["普通采矿员工"] = 1;
    roleMap["技术维护人员"] = 2;
    roleMap["系统管理员"] = 3;
    roleMap["安全管理人员"] = 4;

    this->setWindowTitle("权限管理");
    vector<QString> lableList;
    lableList.push_back("员工编号");
    lableList.push_back("姓名");
    lableList.push_back("当天工作时间");
    lableList.push_back("当天结束时间");
    lableList.push_back("部门");
    lableList.push_back("登录时间");
    lableList.push_back("注册时间");

    lableList.push_back("职位");
    clientSocket = new PmsClientSocket(this);


    dia = new PermissonDialog(this,clientSocket);

    m_model = new QStandardItemModel(globalPms.size(),lableList.size(),this);

    ui->tableView->setModel(m_model);

    for(int i=0;i<m_model->rowCount();i++){
        PmsQueryResult curRes = globalPms[i];
        m_model->setItem(i,0,new QStandardItem(QString::fromStdString(curRes.getUserNo())));
        m_model->setItem(i,1,new QStandardItem(QString::fromLocal8Bit(curRes.getName().c_str())));
        m_model->setItem(i,2,new QStandardItem(QString::fromStdString(curRes.getStartDateTime())));
        m_model->setItem(i,3,new QStandardItem(QString::fromStdString(curRes.getEndDateTime())));
        m_model->setItem(i,4,new QStandardItem(QString::fromLocal8Bit(curRes.getPermissonType().c_str())));

    }

    ui->tableView->horizontalHeader()->setSectionResizeMode(QHeaderView::Stretch);
    ui->tableView->verticalHeader()->hide();


    QStringList lable;
@@ -60,11 +34,22 @@

    m_model->setHorizontalHeaderLabels(lable);

    ui->tableView->setModel(m_model);
    ui->tableView->verticalHeader()->hide();

    connect(this,SIGNAL(sendUserNo(PmsQueryResult)),dia,SLOT(recvUserNo(PmsQueryResult)));
    connect(clientSocket,SIGNAL(notifyDateChange(vector<PmsQueryResult>)),this,SLOT(renderItemData(vector<PmsQueryResult>)));
    connect(m_model,SIGNAL(itemChanged(QStandardItem*)),this,SLOT(listenItemChange(QStandardItem*)));


    // å‘一次查询全部数据请求
    clientSocket->queryAllUserAboutUser();




    QComBoxDelegate * qc = new QComBoxDelegate(this);



    ui->tableView->setItemDelegateForColumn(4,qc);
    ui->tableView->setItemDelegateForColumn(5,qc);


    m = new QMenu(this);
@@ -82,17 +67,13 @@
    connect(ac1,&QAction::triggered,[=]{
         int row = ui->tableView->currentIndex().row();
         qDebug() << "更新当前员工信息"
                  <<  QString::fromStdString( globalPms[row].getUserNo());
                  << globalPms[row].getUserNo();
         // å‘送员工编号信息
         emit sendUserNo(globalPms[row]);

         dia->setModal(true);
         dia->show();
    });


    connect(m_model,SIGNAL(itemChanged(QStandardItem*)),this,SLOT(listenItemChange(QStandardItem*)));


}

@@ -123,44 +104,50 @@

void PermissonWindow::on_pushButton_clicked()
{
    qDebug() << "发送查询请求";

    PmsParam pm;
    pm.setName(ui->lineEdit->text().toStdString());
    pm.setPermissonType(ui->lineEdit_2->text().toStdString());
    pm.setUserNo(ui->lineEdit_3->text().toStdString());
    pm.setName(ui->lineEdit->text());
    pm.setPermissonType(ui->lineEdit_2->text());
    pm.setUserNo(ui->lineEdit_3->text());

    clientSocket->queryPmsByParam(pm);
    qDebug() << "查询中";

}

void PermissonWindow::listenItemChange(QStandardItem *item)
{
    QString localText = item->text();
    if(roleMap.count(localText.toStdString())){
        qDebug() << "发起职位更新请求";
    if(item->column()==m_model->columnCount()-1){
        QString localText = item->text();

        PmsPlusParma pm;
        pm.setPermissonType(localText.toStdString());
        pm.setRoleId(roleMap[localText.toStdString()]);
        pm.setPermissonType(localText);

        int id = globalPms[item->row()].getId();
        pm.setId(id);
        clientSocket->updatePmsByParam(pm);
    }
}

void PermissonWindow::renderItemData(vector<PmsQueryResult> res)
{

    globalPms = res;
    m_model->setRowCount(globalPms.size());

    for(int i=0;i<m_model->rowCount();i++){
        PmsQueryResult curRes = globalPms[i];
        m_model->setItem(i,0,new QStandardItem(QString::fromStdString(curRes.getUserNo())));
        m_model->setItem(i,1,new QStandardItem(QString::fromLocal8Bit(curRes.getName().c_str())));
        m_model->setItem(i,2,new QStandardItem(QString::fromStdString(curRes.getStartDateTime())));
        m_model->setItem(i,3,new QStandardItem(QString::fromStdString(curRes.getEndDateTime())));
        m_model->setItem(i,4,new QStandardItem(QString::fromLocal8Bit(curRes.getPermissonType().c_str())));
        m_model->setItem(i,0,new QStandardItem(curRes.getUserNo()));
        m_model->setItem(i,1,new QStandardItem(curRes.getName()));
        m_model->setItem(i,2,new QStandardItem(QString::fromStdString(curRes.getDepartment())));
        m_model->setItem(i,3,new QStandardItem(QString::fromStdString(curRes.getLoginTime())));
        m_model->setItem(i,4,new QStandardItem(QString::fromStdString(curRes.getRegisterTime())));

        m_model->blockSignals(true);
        m_model->setItem(i,5,new QStandardItem(curRes.getPermissonType()));
        m_model->blockSignals(false);
    }
    ui->tableView->horizontalHeader()->setSectionResizeMode(QHeaderView::Stretch);

    qDebug() << "查询到的数量 " << globalPms.size();
}


 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/permissonwindow.h

@@ -46,11 +46,13 @@
    QMenu * m;
    PermissonDialog *dia;
    SyncDataToDB * dbInfo;
    map<string,int> roleMap;


    vector<PmsQueryResult> globalPms;
    PmsClientSocket * clientSocket;

    bool isRenderData;


};


 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/pmsparam.h

@@ -1,32 +1,33 @@
#ifndef PMSPARAM_H
#define PMSPARAM_H
#include <QString>
#include <string>
using namespace std;


class PmsParam {
protected:
    string userNo;
    string name;
    string permissonType;
    QString userNo;
    QString name;
    QString permissonType;
public:
    void setUserNo(string id){
    void setUserNo(QString id){
        this->userNo = id;
    }
    void setName(string name){
    void setName(QString name){
        this->name = name;
    }
    void setPermissonType(string permissonType){
    void setPermissonType(QString permissonType){
        this->permissonType = permissonType;
    }

    string getUserNo(){
    QString getUserNo(){
        return userNo;
    }
    string getName(){
    QString getName(){
        return name;
    }
    string getPermissonType(){
    QString getPermissonType(){
        return permissonType;
    }


 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/pmsplusparam.h

@@ -1,15 +1,19 @@
#ifndef PMSPLUSPARAM_H
#ifndef PMSPLUSPARAM_H
#define PMSPLUSPARAM_H
#include "pmsparam.h"

class PmsPlusParma : public PmsParam{
    int roleId;
    int id;

    int queryHistory;
    int loggerSearch;
    int mapMark;
    int devManage;
    int productPlan;

    int warninManage;
    int versionManage; //版本管理
    int admin; //系统管理员
public:
    void setQueryHistory(int val){
        this->queryHistory = val;
@@ -27,8 +31,8 @@
        this->productPlan = val;
    }

    void setRoleId(int val){
        this->roleId = val;
    void setId(int val){
        this->id = val;
    }

    int getQueryHistory(){
@@ -47,19 +51,51 @@
        return productPlan;
    }

    int getRoleId(){
        return roleId;
    int getId(){
        return id;
    }

    PmsPlusParma(){
        id = 0;
        queryHistory = 0;
        loggerSearch = 0;
        mapMark = 0;
        devManage = 0;
        productPlan = 0;
    }


    PmsPlusParma(){
        roleId = -1;
        queryHistory = -1;
        loggerSearch = -1;
        mapMark = -1;
        devManage = -1;
        productPlan = -1;
    int getVersionManage() const
    {
        return versionManage;
    }

    void setVersionManage(int value)
    {
        versionManage = value;
    }

    int getAdmin() const
    {
    return admin;
    }

    void setAdmin(int value)
    {
    admin = value;
    }

    int getWarninManage() const
    {
        return warninManage;
    }

    void setWarninManage(int value)
    {
        warninManage = value;
    }
};

#endif // PMSPLUSPARAM_H



 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/pmsqueryresult.h

@@ -1,10 +1,8 @@
#ifndef PMSQUERYRESULT_H
#ifndef PMSQUERYRESULT_H
#define PMSQUERYRESULT_H

#include "pmsparam.h"
class PmsQueryResult : public PmsParam{
    string startDateTime;
    string endDateTime;

    int queryHistory;
    int loggerSearch;
@@ -12,13 +10,22 @@
    int devManage;
    int productPlan;

    int warninManage;
    int versionManage; //版本管理
    int admin; //系统管理员

    int id;
    int roleId;

    string department;
    string loginTime;
    string registerTime;
public:
    void setStartDateTime(string time){
        this->startDateTime = time;
    void setLoginTime(string time){
        this->loginTime = time;
    }
    void setEndDateTime(string time){
        this->endDateTime = time;
    void setRegisterTime(string time){
        this->registerTime = time;
    }

    void setQueryHistory(int val){
@@ -36,16 +43,16 @@
    void setProductPlan(int val){
        this->productPlan = val;
    }
    void setRoleId(int val){
        this->roleId = val;
    void setId(int val){
        this->id = val;
    }


    string getStartDateTime(){
        return startDateTime;
    string getLoginTime(){
        return loginTime;
    }
    string getEndDateTime(){
        return endDateTime;
    string getRegisterTime(){
        return registerTime;
    }
    int getQueryHistory(){
        return queryHistory;
@@ -62,12 +69,58 @@
    int getProductPlan(){
        return productPlan;
    }
    int getRoleId(){
        return roleId;
    int getId(){
        return id;
    }




    int getVersionManage() const
    {
        return versionManage;
    }

    void setVersionManage(int value)
    {
        versionManage = value;
    }

    int getAdmin() const
    {
    return admin;
    }

    void setAdmin(int value)
    {
    admin = value;
    }

    int getWarninManage() const
    {
        return warninManage;
    }

    void setWarninManage(int value)
    {
        warninManage = value;
    }



    string getDepartment() const
    {
        return department;
    }

    void setDepartment(const string &value)
    {
        department = value;
    }

};


#endif // PMSQUERYRESULT_H



 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/qcomboxdelegate.cpp

@@ -16,7 +16,21 @@
{
    QComboBox * box = new QComboBox(parent);
    QStringList text;
    text << "普通采矿员工" << "技术维护人员" << "系统管理员"<< "安全管理人员";

    QString curText = qvariant_cast<QString>(index.data());

    vector<QString> vecq;
    vecq.push_back("技术维护人员");
    vecq.push_back("系统管理员");
    vecq.push_back("安全管理人员");
    vecq.push_back("普通采矿员工");

    text << curText;
    for(QString role : vecq){
        if(curText!=role){
            text << role;
        }
    }
    box->addItems(text);

    return box;

 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/qcomboxdelegate.h

@@ -1,12 +1,14 @@
#ifndef QCOMBOXDELEGATE_H
#ifndef QCOMBOXDELEGATE_H
#define QCOMBOXDELEGATE_H

#include <QItemDelegate>
#include <QComboBox>
#pragma execution_character_set("utf-8")
#include <vector>
using namespace std;

class QComBoxDelegate : public QItemDelegate
{

public:
    QComBoxDelegate();
    QComBoxDelegate(QObject * p=0);

 Client/½ª¿É¸ý/code/2024kunlun_project_permisson/syncdatatodb.cpp

@@ -23,17 +23,17 @@
{
    string sql = "SELECT * FROM user_info AS u, employee_permisson AS e WHERE u.role_id=e.id";

    if(!param.getUserNo().empty()){
        sql += " and u.user_no='" + param.getUserNo() + "'";
    }
//    if(!param.getUserNo().empty()){
//        sql += " and u.user_no='" + param.getUserNo() + "'";
//    }

    if(!param.getName().empty()){
        sql += " and u.name='" + param.getName()+ "'";
    }
//    if(!param.getName().empty()){
//        sql += " and u.name='" + param.getName()+ "'";
//    }

    if(!param.getPermissonType().empty()){
        sql += " and e.permission_type='" + param.getPermissonType()+ "'";
    }
//    if(!param.getPermissonType().empty()){
//        sql += " and e.permission_type='" + param.getPermissonType()+ "'";
//    }

    qDebug() << "sql语句" << QString::fromStdString(sql);

@@ -56,16 +56,16 @@
    string sql = "update employee_permisson";

    // åªæ›´æ”¹èŒä½
    if(!param.getPermissonType().empty()){
        sql.append(" set permission_type='" + param.getPermissonType())+ "'";
    }else{
        sql.append(" set query_history=") + to_string(param.getQueryHistory());
        sql.append(",logger_search=") + to_string(param.getLoggerSearch());
        sql.append(",map_mark=") + to_string(param.getMapMark());
        sql.append(",dev_manage=") + to_string(param.getDevManage());
        sql.append(",product_plan=") + to_string(param.getProductPlan());
    }
    sql.append(" where e.id=" + param.getRoleId());
//    if(!param.getPermissonType().empty()){
//        sql.append(" set permission_type='" + param.getPermissonType())+ "'";
//    }else{
//        sql.append(" set query_history=") + to_string(param.getQueryHistory());
//        sql.append(",logger_search=") + to_string(param.getLoggerSearch());
//        sql.append(",map_mark=") + to_string(param.getMapMark());
//        sql.append(",dev_manage=") + to_string(param.getDevManage());
//        sql.append(",product_plan=") + to_string(param.getProductPlan());
//    }
    //sql.append(" where e.id=" + param.getRoleId());

    mysql_real_query(&mysql, sql.c_str(), sql.size());
    mysql_store_result(&mysql);
@@ -76,13 +76,13 @@

void SyncDataToDB::setPmsResult(PmsQueryResult &res, char **row)
{
    res.setName(string(row[1]));
    res.setUserNo(string(row[5]));
    res.setStartDateTime(string(row[2]));
    res.setEndDateTime(string(row[3]));
    res.setRoleId(stoi(string(row[4])));
//    res.setName(string(row[1]));
//    res.setUserNo(string(row[5]));
//    res.setStartDateTime(string(row[2]));
//    res.setEndDateTime(string(row[3]));
//    res.setRoleId(stoi(string(row[4])));

    res.setPermissonType(string(row[8]));
   // res.setPermissonType(string(row[8]));
    res.setQueryHistory(stoi(string(row[9])));
    res.setLoggerSearch(stoi(string(row[10])));
    res.setMapMark(stoi(string(row[11])));
@@ -90,5 +90,5 @@
    res.setProductPlan(stoi(string(row[13])));


    qDebug() << QString::fromStdString(res.getUserNo());
    //qDebug() << QString::fromStdString(res.getUserNo());
}

 Client/½ª¿É¸ý/code/·þÎñ¶ËÒµÎñ´úÂë/PermissonManage.cpp

New file
@@ -0,0 +1,152 @@
#include "stdafx.h"
#include "PermissonManage.h"
#include <iostream>
#include "MysqlConn.h"
#include <string.h>
#include <vector>
using namespace std;


PermissonManage::PermissonManage()
{
}


PermissonManage::~PermissonManage()
{
}

bool PermissonManage::queryPmsByParam(SOCKET client, QueryPmsReq * req)
{
    // ç»„装SQL语句
    string sql = "SELECT * FROM user_info AS u, role_info AS e WHERE u.role_id=e.id";

    if (*(req->userNo)) {
        sql += " and u.user_no='" + string(req->userNo) + "'";
    }

    if (*(req->name)) {
        sql += " and u.name='" + string(req->name) + "'";
    }

    if (*(req->permissonType)) {
        sql += " and e.permission_type='" + string(req->permissonType) + "'";
    }

    cout << "sql:" << sql << endl;

    // è°ƒç”¨MySQL API æ‰§è¡ŒSQL语句，根据返回值组装响应结构体
    MysqlConn conn;
    conn.connect("127.0.0.1", "root", "root", "mydb");


    bool ret = conn.query (sql);

    vector<PmsRes> pmsTempList;
    while (conn.getResult()){
        PmsRes pmsRes;
        pmsRes.admin = stoi(conn.getField(22));
        strcpy_s(pmsRes.department, conn.getField(1).c_str());

        pmsRes.devManage = stoi(conn.getField(18));
        pmsRes.id = stoi(conn.getField(0));
        pmsRes.loggerSearch = stoi(conn.getField(16));
        strcpy_s(pmsRes.loginTime, conn.getField(11).c_str());
        pmsRes.mapMark = stoi(conn.getField(17));

        strcpy_s(pmsRes.name, conn.getField(2).c_str());
        strcpy_s(pmsRes.permissonType, conn.getField(14).c_str());
        pmsRes.productPlan = stoi(conn.getField(19));
        pmsRes.queryHistory = stoi(conn.getField(15));
        strcpy_s(pmsRes.registerTime, conn.getField(12).c_str());
        strcpy_s(pmsRes.userNo, conn.getField(4).c_str());
        pmsRes.versionManage = stoi(conn.getField(21));
        pmsRes.warningManage = stoi(conn.getField(20));
        pmsTempList.push_back(pmsRes);


        cout << "获取结果集2" <<  conn.getField(0) << conn.getField(1) << conn.getField(2);
    }
	
    QueryPmsRes  *res;
    int len = sizeof(QueryPmsRes) + pmsTempList.size() * sizeof(PmsRes);
    res = (QueryPmsRes *)malloc(len);

	
    PmsRes * pmArr = new PmsRes[pmsTempList.size()];
    for (int i = 0; i < pmsTempList.size();i++) {
        pmArr[i] = pmsTempList[i];	
    }

    memcpy(res->pmsList,pmArr, pmsTempList.size() * sizeof(PmsRes));


    res->head.type = QUERY_PMS_RES;
    res->head.len = len;

    if (ret > 0) {
        res->success = 1; // æˆåŠŸ
    }
    else {
        res->success = 0; // å¤±è´¥
    }
    cout <<  "id="<< res->pmsList[0].id << endl;
    // å‘送结构体给客户端
    cout << __FUNCTION__ << send(client, (char*)res, res->head.len, 0) << endl;

    delete[] pmArr;
    delete res;
    return true;
}

bool PermissonManage::updatePms(SOCKET client, UpdatePmsReq * req)
{
    // è°ƒç”¨MySQL API æ‰§è¡ŒSQL语句，根据返回值组装响应结构体
    MysqlConn conn;
    conn.connect("127.0.0.1", "root", "root", "mydb");

    char sql[512] = { 0 };

    UpdatePmsRes res;
    if (*(req->permissonType)) {

        // å…ˆç”¨è§’色类型查一遍角色表id
        sprintf(sql, "select id from role_info where permission_type='%s'", req->permissonType);
        bool ret = conn.query(sql);
        bool retRes = conn.getResult();
        if (!ret || !retRes) {
            res.success = 0;
        }
        else {
            int roleId = stoi(conn.getField(0));
            memset(sql, 0, 512);
            sprintf(sql, "update user_info set role_id=%d where id=%d", roleId, req->id);
            ret = conn.update(sql);
            res.success = ret;
        }
    }
    else {
        // å…ˆç”¨id查一遍角色id
        sprintf(sql,"select role_id from user_info where id=%d", req->id);

        bool ret = conn.query(sql);
        bool retRes = conn.getResult();
        if (!ret || !retRes) {
            res.success = 0;
        }else {
            int roleId = stoi(conn.getField(0));
            memset(sql, 0, 512);
            sprintf(sql, "update  role_info set query_history=%d,logger_search=%d,map_mark=%d,dev_manage=%d"
                            ",product_plan=%d,warning_manage=%d,version_manage=%d,role_info.admin=%d where id=%d",req->queryHistory,req->loggerSearch,
                                req->mapMark,req->devManage,req->productPlan,req->warningManage,req->versionManage,req->admin,roleId);

            cout << "更新权限sql:" << sql << endl;
            ret = conn.update(sql);
            res.success = ret;
        }
    }
    // å‘送结构体给客户端
    cout << __FUNCTION__ << send(client, (char*)&res, res.head.len, 0) << endl;

    return true;
}

 Client/½ª¿É¸ý/code/·þÎñ¶ËÒµÎñ´úÂë/PermissonManage.h

New file
@@ -0,0 +1,16 @@
#pragma once

#include "common.h"
#include <WinSock2.h>
#include <string>
using namespace std;

class PermissonManage
{
public:
    PermissonManage();
    ~PermissonManage();
    bool queryPmsByParam(SOCKET client, QueryPmsReq * req);
    bool updatePms(SOCKET client, UpdatePmsReq * req);
};


 Client/½ª¿É¸ý/code/·þÎñ¶ËÒµÎñ´úÂë/ServerSocket.cpp

New file
@@ -0,0 +1,166 @@
#include "stdafx.h"
#include "ServerSocket.h"
#include "common.h"
#include "DeviceManage.h"
#include "PermissonManage.h"

#define HEART_CHECK_TIMES 60  // å¿ƒè·³æ£€æµ‹çš„次数

struct TestData
{
    int type;
    int len;
    char data[32];
};

ServerSocket::ServerSocket(bool openHeartCheck):m_openHeartCheck(openHeartCheck)
{
    if (initSocket()) {
        cout << "init socket ok" << endl;
    }
    else {
        cout << "init socket fail" << endl;
    }
}


ServerSocket::~ServerSocket()
{
    closesocket(m_server); //  å…³é—­æœåŠ¡ç«¯å¥—接字
    WSACleanup(); // å…³é—­ç½‘络环境
}

bool ServerSocket::initSocket()
{
    WSAData wsa = { 0 };
    WSAStartup(MAKEWORD(2, 2), &wsa); // å¯åŠ¨ç½‘络环境
    // SOCK_STREAM:TCP协议
    // SOCK_DGRAM：UDP协议
    m_server = socket(AF_INET, SOCK_STREAM, 0);
    SOCKADDR_IN addr;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(16888);
    addr.sin_addr.S_un.S_addr = 0;
    int ret_bind = ::bind(m_server, (sockaddr*)&addr, sizeof(addr));
    if (ret_bind) {
        cout << "bind fail:" << WSAGetLastError() << endl;
        return false;
    }
    int ret_listen = listen(m_server, 5);
    if (ret_listen) {
        cout << "listen fail:" << WSAGetLastError() << endl;
        return false;
    }
    // æ­£å¸¸ï¼ŒæˆåŠŸåˆå§‹åŒ–
    // å¯åŠ¨accept线程
    thread accept_thread(&ServerSocket::acceptThread, this);
    accept_thread.detach(); // å‰¥ç¦»çº¿ç¨‹ï¼Œé˜²æ­¢å¼‚常结束
    // å¯åŠ¨å¿ƒè·³æ£€æµ‹çº¿ç¨‹
    thread heart_check_thread(&ServerSocket::heartCheckThread, this);
    heart_check_thread.detach();

    return true;
}

void ServerSocket::acceptThread()
{
    while (true)
    {
        SOCKADDR_IN addr;
        SOCKET client; // å½“前连接上的客户端套接字
        int len = sizeof(addr);

        cout << "wait for conn..." << endl;
        client = accept(m_server, (sockaddr*)&addr, &len);
        cout << "conn client:" << client << endl;

        if (client == SOCKET_ERROR) {
            cout << "socket error:" << WSAGetLastError() << endl;
            break;
        }
        else if (client == 0) {
            cout << "socket close:" << WSAGetLastError() << endl;
            break;
        }
        // æ­£å¸¸
            // å»ºç«‹æ–°çš„键值对
        m_clientsMap[client] = HEART_CHECK_TIMES;
        // åˆ›å»ºé•¿è¿žæŽ¥çš„线程
        thread recv_send_thread(&ServerSocket::recvAndSendThread, this, client);
        recv_send_thread.detach();
    }
}
void ServerSocket::recvAndSendThread(SOCKET client)
{
    while (true) {
        char buffer[1024] = { 0 };
        int len_recv = recv(client, buffer, sizeof(buffer), 0);
        cout << "len_recv:" << len_recv << " client:" << client << endl;
        if (len_recv <= 0) {
            cout << "client socket å·²å…³é—­æˆ–异常结束:" << WSAGetLastError() << endl;
            break;
        }
        // æ­£å¸¸
            // é‡ç½®å¿ƒè·³é˜ˆå€¼
        m_clientsMap[client] = HEART_CHECK_TIMES; 
        // è§£åŒ…处理
        cout << "buffer:" << buffer << endl;
		
        int type = *(int*)buffer;
        if (type == 100) {
            TestData* td = (TestData*)buffer;
            cout << "收到结构体:" << td->len << " " << td->data << endl;
        }
        else if (type == AD_REQ) {
            // æ·»åŠ è®¾å¤‡
            cout << "收到添加设备请求" << endl;
            ADReq *req = (ADReq*)buffer;
            cout << "设备名称" << req->devInfo[0].deviceName << endl;

            // è°ƒç”¨ æ·»åŠ è®¾å¤‡ ä¸šåŠ¡API
            DeviceManage devMan;
            devMan.addDeviceBusiness(client, req);
        }
        else if (type == QUERY_PMS_REQ) {
            cout << "查询权限请求" << endl;
            QueryPmsReq * req = (QueryPmsReq *)buffer;
            PermissonManage pmsManage;
            pmsManage.queryPmsByParam(client, req);
		
        }
        else if (type == UPDATE_PMS_REQ) {
            cout << "更新权限请求" << endl;
            UpdatePmsReq * req = (UpdatePmsReq *)buffer;
            PermissonManage pmsManage;
            pmsManage.updatePms(client, req);

        }

        // åŽŸå°ä¸åŠ¨çš„回收到的内容给对应客户端
        //send(client, buffer, len_recv, 0);
    }
    closesocket(client);
}

void ServerSocket::heartCheckThread()
{
    while (m_openHeartCheck)
    {
        // è½®è¯¢map
        for (auto iter = m_clientsMap.begin();iter != m_clientsMap.end();) {
            iter->second--; // é˜ˆå€¼é€’减
            cout << "client:" << iter->first << " é˜ˆå€¼:" << iter->second << endl;
            if (iter->second == 0) {
                // è¿žæŽ¥æ— æ•ˆäº†ï¼Œå…³é—­è¿žæŽ¥ï¼Œå†åˆ é™¤
                cout << "发现无效客户端连接:" << iter->first << endl;
                closesocket(iter->first);
                iter = m_clientsMap.erase(iter); // æŽ¥æ”¶è¿”回值，防止迭代器失效
            }
            else {
                ++iter;
            }
        }
        // é—´éš”5秒
        Sleep(5 * 1000); // ç¡çœ 5000毫秒，就是5秒
    }
}

 Client/½ª¿É¸ý/code/·þÎñ¶ËÒµÎñ´úÂë/common.h

New file
@@ -0,0 +1,1064 @@
#ifndef COMMON_H
#define COMMON_H

#include <string.h>

enum TypeInfo {

    //注册登录
    LOGIN_REQ, // ç™»å½•è¯·æ±‚
    LOGIN_RES, // ç™»å½•å“åº”
    REGISTER_REQ, //注册请求
    REGISTER_RES, //注册响应
    RESET_REQ, //重置密码请求
    RESET_RES, //重置密码响应


    //权限管理
    QUERY_PMS_REQ,      // æŒ‰å‘˜å·¥ç¼–号、名字或职位查询人员权限信息请求
    UPDATE_PMS_REQ,     // æŒ‰è§’色id更新权限信息请求
    QUERY_PMS_RES,      // æŸ¥è¯¢äººå‘˜å’Œè§’色信息的响应结构体
    UPDATE_PMS_RES,     // æƒé™æ›´æ–°ç»“果响应体

    //设备管理
    AD_REQ,//添加设备请求
    AD_RES,//添加设备响应
    MD_REQ,//修改设备请求
    MD_RES,//修改设备响应
    QD_REQ,//查询设备请求
    QD_RES,//查询设备响应

    //地图标注
    MML_REQ,//地图标注加载请求
    MML_RES,//地图标注加载响应	
    MMI_REQ,//地图标注插入请求
    MMI_RES,//地图标注插入响应	
    MMD_REQ,//地图标注删除请求
    MMD_RES,//地图标注删除响应

    //大屏显示
    ENVIRONMENT_REQ,//环境数据请求
    ENVIRONMENT_RES,//环境数据响应
    DEVICESTATUS_REQ,//设备状态请求
    DEVICESTATUS_RES,//设备状态响应
    MOVEMENTRECORD_REQ,//操作日志请求
    MOVEMENTRECORD_RES,//操作日志响应
    ALARMRECORD_REQ,//警报记录请求
    ALARMRECORD_RES,//警报记录响应
    YIELD_REQ,//煤矿产量请求
    YIELD_RES,//煤矿产量响应

    //警报管理
    WARNING_REQ, // è­¦æŠ¥è¯·æ±‚
    WARNING_RES, // è­¦æŠ¥å“åº”


    //生产计划管理
    ADD_PDPLAN_REQ,//添加一条生产计划的请求结构体
    ADD_PDPLAN_RES,//添加一条生产计划的响应结构体
    DEL_PDPLAN_REQ,//删除一条生产计划的请求结构体
    DEL_PDPLAN_RES,//删除一条生产计划的响应结构体
    UPDATE_PDPLAN_REQ,//更改一条生产计划的请求结构体
    UPDATE_PDPLAN_RES,//更改一条生产计划的响应结构体
    QUERY_PDPLAN_REQ,//查询一条生产计划的请求结构体
    QUERY_PDPLAN_RES,//查询一条生产计划的响应结构体


    ADD_MONOUTPUT_REQ,//添加月产量的请求结构体
    ADD_MONOUTPUT_RES,//添加月产量的响应结构体
    DEL_MONOUTPUT_REQ,//删除月产量的请求结构体
    DEL_MONOUTPUT_RES,//删除月产量的响应结构体
    UPDATE_MONOUTPUT_REQ,//更新月产量的请求结构体
    UPDATE_MONOUTPUT_RES,//更新月产量的响应结构体
    QUERY_MONOUTPUT_REQ,//查询月产量的请求结构体
    QUERY_MONOUTPUT_RES,//查询月产量的响应结构体


    //自动升级
    VERSION_NUM_REQ,  // ç‰ˆæœ¬å·è¯·æ±‚
    VERSION_NUM_RES,   // ç‰ˆæœ¬å·å“åº”
    UPLOAD_FILE_REQ, // ä¸Šä¼ æ–‡ä»¶çš„请求
    UPLOAD_FILE_RES, // ä¸Šä¼ æ–‡ä»¶çš„响应
    VERSION_INFOENTRY_REQ,       // ç‰ˆæœ¬ä¿¡æ¯å½•å…¥è¯·æ±‚
    VERSION_INFOENTRY_RES,       //版本信息录入响应
    VERSION_UPDATE_REQ, // ç‰ˆæœ¬æ›´æ–°è¯·æ±‚
    VERSION_UPDATE_RES, // ç‰ˆæœ¬æ›´æ–°å“åº”
    FILE_DOWNLOADS_REQ, // ç‰ˆæœ¬æ›´æ–°æ–‡ä»¶ä¸‹è½½è¯·æ±‚
    FILE_DOWNLOADS_RES, // ç‰ˆæœ¬æ›´æ–°æ–‡ä»¶ä¸‹è½½å“åº”
    DOWNLOAD_SUCCESSFULLY_RES,       // æ›´æ–°æ–‡ä»¶ä¸‹è½½æˆåŠŸçš„响应

    //日志
    LOGSEARCH_REQ,//日志查询请求
    LOGSEARCH_RES,//日志查询响应

};

struct Head {
    int type;
    int len;
};

//注册登录
//登录请求 
struct LoginReq
{
    Head head;
    char userName[32];
    char password[32];
    LoginReq() {
        head.type = LOGIN_REQ;
        head.len = sizeof(LoginReq);
    }
};

struct Permission
{
    int admin;//超级管理员
    int loggerSearch; //日志查询
    int queryHistory; //历史记录
    int mapMark;//地图
    int versionManage; // ç‰ˆæœ¬ç®¡ç†
    int warning; //警报
    int devManage; //设备管理
    int productPlan;//生产计划
    char roleName[32]; // è§’色名
};

//登录响应
struct LoginRes
{
    Head head;
    char userName[32];
    int status; // ç™»å½•çŠ¶æ€
    // ç™»å½•æˆåŠŸæ—¶ï¼Œè¯¥è´¦å·å¯¹åº”的权限组合
    Permission per;
    LoginRes()
    {
        head.type = LOGIN_RES;
        head.len = sizeof(LoginRes);
    }
};

//注册请求 
struct RegisterReq
{
    Head head;
    char userName[32];
    char password[32];
    char email[50];
    char capcha[10];//验证码
    char telephone[32];
    RegisterReq() {
        head.type = REGISTER_REQ;
        head.len = sizeof(RegisterReq);
    }
};

//注册响应
struct RegisterRes
{
    Head head;
    char userName[32];
    int status; // æ³¨å†ŒçŠ¶æ€
    RegisterRes()
    {
        head.type = REGISTER_RES;
        head.len = sizeof(RegisterRes);
    }
};

//重置密码请求 
struct ResetReq
{
    Head head;
    char email[50];
    char capcha[10];//验证码
    char password[32];//新密码
    char confirmPassword[32];//确认密码
    ResetReq() {
        head.type = RESET_REQ;
        head.len = sizeof(ResetReq);
    }
};

//重置密码响应
struct ResetRes
{
    Head head;
    char user_name[32];
    int status; // é‡ç½®å¯†ç çŠ¶æ€
    ResetRes()
    {
        head.type = RESET_RES;
        head.len = sizeof(ResetRes);
    }
};

//权限管理
// æŒ‰å‘˜å·¥ç¼–号、名字或职位查询人员权限信息请求
typedef struct QueryPmsReq {
    Head head;
    char userNo[32];
    char name[32];
    char permissonType[32];
    QueryPmsReq() {
        head.type = QUERY_PMS_REQ;
        memset(userNo, 0, 32);
        memset(permissonType, 0, 32);
        memset(name, 0, 32);
        head.len = sizeof(QueryPmsReq);
    }
} QueryPmsReq;

// æŒ‰è§’色id更新权限信息请求
typedef struct UpdatePmsReq {
    Head head;
    // äººå‘˜è¡¨ä¸»é”®id
    int id;
    int queryHistory;
    int loggerSearch;
    int mapMark;
    int devManage;
    int productPlan;
    int warningManage;
    int versionManage; //版本管理
    int admin; //系统管理员

    char permissonType[32];
    UpdatePmsReq() {
        head.type = QUERY_PMS_RES;
        head.len = sizeof(UpdatePmsReq);
    }
} UpdatePmsReq;

// å•ä¸ªäººå‘˜å’Œæƒé™è”合查询结构体
typedef struct PmsRes {
    int queryHistory;
    int loggerSearch;
    int mapMark;
    int devManage;
    int productPlan;
    int versionManage; //版本管理
    int warningManage;
    int admin; //系统管理员

    int id;

    char userNo[32];
    char name[32];

    char permissonType[32];  // è§’色类型

    char department[32];
    char loginTime[32];
    char registerTime[32];
} PmsRes;

// æŸ¥è¯¢äººå‘˜å’Œè§’色信息的响应结构体
typedef struct QueryPmsRes {
    Head head;
    int success; // 1为成功 ,0为失败
    PmsRes pmsList[0];
    QueryPmsRes() {
        head.type = QUERY_PMS_REQ;
    }
} QueryPmsRes;

// æƒé™æ›´æ–°ç»“果响应体
struct UpdatePmsRes {
    Head head;
    int success; // 1为成功 ,0为失败
    UpdatePmsRes() {
        head.type = UPDATE_PMS_RES;
        head.len = sizeof(UpdatePmsRes);
    }

};




//设备管理
struct DevicesInfo
{
    char deviceName[32];//设备名称
    char deviceStatus[32];//设备状态
    char area[32]; // åœ°åŒº
    double longitude;//经度
    double latitude;//纬度
    char purchasingTime[15];//购买时间
    char installTime[15];//安装时间
    char manufacturer[100];//厂家
    char devicesSerialNumber[32];//设备编码
    char devicesType[32];//设备类型
};
//添加设备
struct ADReq//添加请求
{
    Head head;
    DevicesInfo devInfo[0];

    ADReq() {
        head.type = AD_REQ;
        head.len = sizeof(ADReq);
    }

};

struct ADRes//添加响应
{
    Head head;
    int status;
    ADRes() {
        head.type = AD_RES;
        head.len = sizeof(ADRes);
    }

};
//修改设备
struct MDRes//修改响应
{
    Head head;
    DevicesInfo info;
    MDRes() {
        head.type = MD_RES;
        head.len = sizeof(MDRes);
    }
};
struct MDReq//修改请求
{
    Head head;
    int type;
    MDReq() {
        head.type = MD_REQ;
        head.len = sizeof(MDReq);
    }
};
//查询设备
struct QDReq//查询请求
{
    Head head;
    DevicesInfo info;
    QDReq() {
        head.type = QD_REQ;
        head.len = sizeof(QDReq);
    }
};
struct QDRes//查询响应
{
    Head head;
    int type;
    QDRes() {
        head.type = QD_RES;
        head.len = sizeof(QDRes);
    }
};


//地图标注
struct MarkInfo
{
    int markId;//标注点id
    double latitude;//纬度
    double longitude;//经度
    int deviceId;//设备ID
    int deviceStatus;//设备状态
    char deviceName[32];//设备名称
};
//地图标注加载请求
struct MMLReq//地图
{
    Head head;
    MMLReq() {
        head.type = MML_REQ;
        head.len = sizeof(MMLReq);
    }
};
//地图标注加载响应：
struct MMLRes
{
    Head head;
    int status;//操作状态
    MarkInfo info[0];
    MMLRes() {
        head.type = MML_RES;
        head.len = sizeof(MMLRes);
    }
};
//地图标注插入请求
struct MMIReq//地图
{
    Head head;
    MarkInfo info[0];
    MMIReq() {
        head.type = MMI_REQ;
        head.len = sizeof(MMIReq);
    }
};
//地图标注插入响应：
struct MMIRes
{
    Head head;
    int status;//操作状态
    MarkInfo info[0];
    MMIRes() {
        head.type = MMI_RES;
        head.len = sizeof(MMIRes);
    }
};

//地图标注删除请求
struct MMDReq//地图
{
    Head head;
    MarkInfo info[0];
    MMDReq() {
        head.type = MMD_REQ;
        head.len = sizeof(MMDReq);
    }
};
//地图标注删除响应：
struct MMDRes
{
    Head head;
    int status;//操作状态
    MarkInfo info[0];
    MMDRes() {
        head.type = MMD_RES;
        head.len = sizeof(MMDRes);
    }
};

//大屏显示
//环境数据请求
struct EnvironmentReq
{
    Head head;
    EnvironmentReq() {
        head.type = ENVIRONMENT_REQ;
        head.len = sizeof(EnvironmentReq);
    }
};
//环境数据响应
struct Environment
{
    double longitude;//经度
    double latitude;//纬度
    float temp;//温度
    float humidity;//湿度
    float oxygen;//氧气浓度
    float carbon;//一氧化碳浓度
};
struct EnvironmentRes
{
    Head head;
    int status;
    Environment environment[0];
    EnvironmentRes() {
        head.type = ENVIRONMENT_RES;
        head.len = sizeof(EnvironmentRes);
    }
};
//设备状态请求
struct DeviceStatusReq
{
    Head head;
    DeviceStatusReq() {
        head.type = DEVICESTATUS_REQ;
        head.len = sizeof(DeviceStatusReq);
    }
};
//设备状态响应
struct DeviceStatus
{
    double longitude;//经度
    double latitude;//纬度
    int deviceID;//设备编号
    char deviceName[32];//设备名称
    char deviceStatus[32];//设备状态
};
struct DeviceStatusRes
{
    Head head;
    int status;
    DeviceStatus deviceStatus[0];
    DeviceStatusRes() {
        head.type = DEVICESTATUS_RES;
        head.len = sizeof(DeviceStatusRes);
    }
};
//操作日志请求
struct MovementRecordReq
{
    Head head;
    MovementRecordReq() {
        head.type = MOVEMENTRECORD_REQ;
        head.len = sizeof(MovementRecordReq);
    }
};
//操作日志响应
struct MovementRecord
{
    double longitude;//经度
    double latitude;//纬度
    char userName;//操作用户名
    char operateTime[32];//操作时间
    char deviceName[32];//操作设备
    char movement[256];//操作描述
};
struct MovementRecordRes
{
    Head head;
    int status;
    MovementRecord movementRecord[0];
    MovementRecordRes() {
        head.type = MOVEMENTRECORD_RES;
        head.len = sizeof(MovementRecordRes);
    }
};
//警报记录请求
struct AlarmRecordReq
{
    Head head;
    AlarmRecordReq() {
        head.type = ALARMRECORD_REQ;
        head.len = sizeof(AlarmRecordReq);
    }
};
//警报记录响应
struct AlarmRecord
{
    double longitude;//经度
    double latitude;//纬度
    char alarmTime[32];//警报时间
    char alarmtype[32];//处理时间
    char alarmContent[256];//警报内容
};
struct AlarmRecordRes
{
    Head head;
    int status;
    AlarmRecord alarmRecord[0];
    AlarmRecordRes() {
        head.type = ALARMRECORD_RES;
        head.len = sizeof(AlarmRecordRes);
    }
};
//煤矿产量请求
struct YieldReq
{
    Head head;
    YieldReq() {
        head.type = YIELD_REQ;
        head.len = sizeof(YieldReq);
    }
};
//煤矿产量响应
struct Yield
{
    int month;//月份
    int output;//产量
};
struct YieldRes
{
    Head head;
    int status;
    Yield yield[0];
    YieldRes() {
        head.type = YIELD_RES;
        head.len = sizeof(YieldRes);
    }
};

//警报管理
// è­¦æŠ¥è¯·æ±‚结构体  
struct WarningReq {
    Head head;

    float oxygenWarning;
    float carbonWarning;
    float tempWarning;
    float humidityWarning;

    WarningReq() {
        head.type = WARNING_REQ;
        head.len = sizeof(WarningReq);
    }
};


struct DataThreshold {
    //阈值
    float oxygenThreshold;
    float carbonThreshold;
    float tempThreshold;
    float humidityThreshold;
};

struct Data {
    float oxygen;   // æ°§æ°”浓度  
    float carbon;   // ä¸€æ°§åŒ–碳浓度  
    float temp;     // æ¸©åº¦  
    float humidity; // æ¹¿åº¦ 
};

// è­¦æŠ¥å“åº”结构体  
struct WarningRes {
    Head head;
    int status;         // å“åº”状态（比如 0 è¡¨ç¤ºæˆåŠŸï¼Œ1 è¡¨ç¤ºå¤±è´¥ç­‰ï¼‰  
    const char* message; // å“åº”消息描述  

    WarningRes(int stat, const char* msg) {
        head.type = WARNING_RES;
        head.len = sizeof(WarningRes);
        status = stat;
        message = msg;
    }
};

//生产计划管理
struct PdplanInfo
{
    int planId;//订单编号
    char planName[32];//订单名字
    char startDate[32];//起始日期
    char closingDate[32];//交付日期
    char pdName[8];//产品名
    double plannedPd;//计划生产量
    double actualPd;//实际生产量
    double progress;//生产进度
    int finishOntime;//是否按期完成
};

struct MonoutputInfo
{
    int month;//月份
    double aOutput;//a产品月产量
    double bOutput;//b产品月产量
    double cOutput;//c产品月产量
};

//添加一条生产计划的请求结构体
struct AddPdplanReq
{
    Head head;
    PdplanInfo info[0];
    AddPdplanReq() {
        head.type = ADD_PDPLAN_REQ;
        head.len = sizeof(AddPdplanReq);
    }
};

//添加一条生产计划的响应结构体
struct AddPdplanRes
{
    Head head;
    int status;//表示是否添加成功，0否1是
    AddPdplanRes() {
        head.type = ADD_PDPLAN_RES;
        head.len = sizeof(AddPdplanRes);
    }
};

//删除一条生产计划的请求结构体
struct DelPdplanReq
{
    Head head;
    PdplanInfo info[0];
    DelPdplanReq() {
        head.type = DEL_PDPLAN_REQ;
        head.len = sizeof(DelPdplanReq);
    }
};

//删除一条生产计划的响应结构体
struct DelPdplanRes
{
    Head head;
    int status;//表示是否删除成功，0否1是
    DelPdplanRes() {
        head.type = DEL_PDPLAN_RES;
        head.len = sizeof(DelPdplanRes);
    }
};

//更改一条生产计划的请求结构体.
struct UpdatePdplanReq
{
    Head head;
    PdplanInfo info[0];
    UpdatePdplanReq() {
        head.type = UPDATE_PDPLAN_REQ;
        head.len = sizeof(UpdatePdplanReq);
    }
};

//更改一条生产计划的响应结构体
struct UpdatePdplanRes
{
    Head head;
    int status;//表示是否更新成功，0否1是
    PdplanInfo info[0];
    UpdatePdplanRes() {
        head.type = UPDATE_PDPLAN_RES;
        head.len = sizeof(UpdatePdplanRes);
    }
};

//查询一条生产计划的请求结构体
struct QueryPdplanReq
{
    Head head;
    int planId;//订单编号
    char planName[32];//订单划名字
    char startDate[32];//起始日期
    char closingDate[32];//交付日期
    char pdName[8];//产品名
    double plannedPd;//计划生产量
    double actualPd;//实际生产量
    double progress;//生产进度
    int finishOntime;//是否按期完成
    QueryPdplanReq() {
        head.type = QUERY_PDPLAN_REQ;
        head.len = sizeof(QueryPdplanReq);
    }
};

//查询一条生产计划的响应结构体
struct QueryPdplanRes
{
    Head head;
    int status;//表示是否添加成功，0否1是
    PdplanInfo info[0];
    QueryPdplanRes() {
        head.type = QUERY_PDPLAN_RES;
        head.len = sizeof(QueryPdplanRes);
    }
};


//添加月产量的请求结构体
struct AddMonoutputReq
{
    Head head;
    MonoutputInfo info[0];
    AddMonoutputReq() {
        head.type = ADD_MONOUTPUT_REQ;
        head.len = sizeof(AddMonoutputReq);
    }
};

//添加月产量的响应结构体
struct AddMonoutputRes
{
    Head head;
    int status;//表示是否添加成功，0否1是
    AddMonoutputRes() {
        head.type = ADD_MONOUTPUT_RES;
        head.len = sizeof(AddMonoutputRes);
    }
};

//删除月产量的请求结构体
struct DelMonoutputReq
{
    Head head;
    MonoutputInfo info[0];
    DelMonoutputReq() {
        head.type = DEL_MONOUTPUT_REQ;
        head.len = sizeof(DelMonoutputReq);
    }
};

//删除月产量的响应结构体
struct DelMonoutputRes
{
    Head head;
    int status;//表示是否删除成功，0否1是
    DelMonoutputRes() {
        head.type = DEL_MONOUTPUT_RES;
        head.len = sizeof(DelMonoutputRes);
    }
};

//更改月产量的请求结构体.
struct UpdateMonoutputReq
{
    Head head;
    MonoutputInfo info[0];
    UpdateMonoutputReq() {
        head.type = UPDATE_MONOUTPUT_REQ;
        head.len = sizeof(UpdateMonoutputReq);
    }
};

//更改月产量的响应结构体
struct UpdateMonoutputRes
{
    Head head;
    int status;//表示是否更新成功，0否1是
    MonoutputInfo info[0];
    UpdateMonoutputRes() {
        head.type = UPDATE_MONOUTPUT_RES;
        head.len = sizeof(UpdateMonoutputRes);
    }
};

//查询月产量的请求结构体
struct QueryMonoutputReq
{
    Head head;
    int month;//月份
    double aOutput;//a产品月产量
    double bOutput;//b产品月产量
    double cOutput;//c产品月产量
    QueryMonoutputReq() {
        head.type = QUERY_MONOUTPUT_REQ;
        head.len = sizeof(QueryMonoutputReq);
    }
};

//查询月产量的响应结构体
struct QueryMonoutputRes
{
    Head head;
    int status;//表示是否添加成功，0否1是
    MonoutputInfo info[0];
    QueryMonoutputRes() {
        head.type = QUERY_MONOUTPUT_RES;
        head.len = sizeof(QueryMonoutputRes);
    }
};



//历史查询分析
// åŽ†å²æŸ¥è¯¢è¯·æ±‚结构体
struct HistoryQueryReq {
    Head head;
    //根据时间范围查询
    char startTime[32];
    char endTime[32];
    //关键字查询
    char keyWord[32];
    HistoryQueryReq() {
        // åˆå§‹åŒ–数据头
        head.type = QUERY_MONOUTPUT_REQ;
        head.len = sizeof(HistoryQueryReq);
        // åˆå§‹åŒ–查询条件字段
        memset(startTime, 0, sizeof(startTime));
        memset(endTime, 0, sizeof(endTime));

    }
};

// åŽ†å²æŸ¥è¯¢å“åº”结构体

// ç³»ç»Ÿè¿è¡ŒçŠ¶æ€è¡¨ç›¸å…³ä¿¡æ¯
struct HistroyInfo {
    WarningRes warn;//警报查询
    QDRes dev;//设备查询
    QueryPdplanRes  pro;//生产计划查询
};
struct HistoryQueryRes {
    Head head;
    //HistroyInfo sys[0];
    HistoryQueryRes() {
        // åˆå§‹åŒ–数据头
        head.type = QUERY_MONOUTPUT_RES;
        head.len = sizeof(HistoryQueryRes);
    }
};


//自动升级
struct VersionNumReq        // ç‰ˆæœ¬å·è¯·æ±‚
{
    Head head;
    VersionNumReq() {
        head.type = VERSION_NUM_REQ;
        head.len = sizeof(VersionNumReq);
    }
};

struct VersionNumRes        // ç‰ˆæœ¬å·å“åº”
{
    Head head;
    char versionId[64]; // ç‰ˆæœ¬å·
    VersionNumRes() {
        head.type = VERSION_NUM_RES;
        head.len = sizeof(VersionNumRes);
    }
};

// æ–‡ä»¶ä¼ è¾“
struct FileInfo
{
    char fileName[256];
    long long fileSize;
    char s_filepath[128];
    char content[0];
};

struct UploadFileReq        // ä¸Šä¼ æ–‡ä»¶çš„请求
{
    Head head;
    FileInfo fileInfo;
    UploadFileReq() {
        head.type = UPLOAD_FILE_REQ;
        head.len = sizeof(UploadFileReq);
    }
};

struct UploadFileRes {      // ä¸Šä¼ æ–‡ä»¶çš„响应
    Head head;
    bool state = false;
    char fileName[256];
    long long file_size;
    UploadFileRes()
    {
        head.type = UPLOAD_FILE_RES;
        head.len = sizeof(UploadFileRes);
    }
};

// ç‰ˆæœ¬ä¿¡æ¯å½•å…¥
// è¯·æ±‚
struct VersionInfoEntryReq {
    Head head;
    char versionId[64]; // ç‰ˆæœ¬å·
    char versionIdOld[64]; // ä¸Šä¸€ä¸ªç‰ˆæœ¬å·
    int fileNum;
    char context[0];        //包含下载文件信息

    VersionInfoEntryReq()
    {
        head.type = VERSION_INFOENTRY_REQ;
        head.len = sizeof(VersionInfoEntryReq);
    }
};

// ç‰ˆæœ¬ä¿¡æ¯å½•å…¥å“åº”
struct VersionInfoEntryRes {
    Head head;
    bool state = false;
    VersionInfoEntryRes()
    {
        head.type = VERSION_INFOENTRY_RES;
        head.len = sizeof(VersionInfoEntryRes);
    }
};

// ç‰ˆæœ¬æ›´æ–°è¯·æ±‚
struct VersionUpdateReq {
    Head head;

    char curVersionId[64]; // ç‰ˆæœ¬å·
    VersionUpdateReq()
    {
        head.type = VERSION_UPDATE_REQ;
        head.len = sizeof(VersionUpdateReq);
    }
};

// ç‰ˆæœ¬æ›´æ–°å“åº”
struct VersionUpdateRes {
    Head head;
    bool state = false;
    char versionId[64]; // ç‰ˆæœ¬å·
    char updateDate[32]; // æ›´æ–°æ—¶é—´
    char versionDescription[1024]; //更新描述

    VersionUpdateRes()
    {
        head.type = VERSION_UPDATE_RES;
        head.len = sizeof(VersionUpdateRes);
    }
};

// ç‰ˆæœ¬æ›´æ–°æ–‡ä»¶ä¸‹è½½è¯·æ±‚
struct FileDownloadsReq {
    Head head;
    char versionId[64]; // ç‰ˆæœ¬å·
    FileDownloadsReq()
    {
        head.type = FILE_DOWNLOADS_REQ;
        head.len = sizeof(FileDownloadsReq);
    }
};

// ç‰ˆæœ¬æ›´æ–°æ–‡ä»¶ä¸‹è½½å“åº”
struct FileDownloadsRes {
    Head head;
    char versionId[64]; // ç‰ˆæœ¬å·
    char filename[128]; //文件名
    long long filesize; //文件大小
    char c_filepath[128];    //客户端放最新版本的本地路径
    int fileNum; // æ–‡ä»¶æ•°é‡
    long long allFileSize; // æ–‡ä»¶æ€»å¤§å°
    char content[0];
    FileDownloadsRes()
    {
        head.type = FILE_DOWNLOADS_RES;
        head.len = sizeof(FileDownloadsRes);
    }
};

// æ›´æ–°æ–‡ä»¶ä¸‹è½½æˆåŠŸçš„响应
struct DownloadSuccessfullyRes {
    Head head;
    bool state = false;
    char fileName[256];
    long long fileSize;
    DownloadSuccessfullyRes()
    {
        head.type = DOWNLOAD_SUCCESSFULLY_RES;
        head.len = sizeof(DownloadSuccessfullyRes);
    }
};


//日志
struct ParsedLog {
    char timeStamp[64]; // æ—¶é—´æˆ³
    char deviceId[64]; // è®¾å¤‡ID
    char level[16];    // æ—¥å¿—级别
    char content[256];  // æ—¥å¿—内容
    char userId[64];    // ç”¨æˆ·ID
    char fileName[32];   //文件名
    char functionName[32];  //函数名
    int problemLine;    //产生错误行号
};

// æ—¥å¿—查询请求结构体
// æ—¥å¿—查询请求结构体
struct LogQueryReq {
    Head head;                      // æ•°æ®å¤´
    char timeStamp[64];             // æ—¶é—´æˆ³
    char content[256];           // æ—¥å¿—内容
    char level[16];                 //日志级别
    char deviceId[64];             // è®¾å¤‡ID
    // æ— å‚构造函数
    LogQueryReq() {
        head.type = LOGSEARCH_REQ;
        head.len = sizeof(LogQueryReq);
    }
};

// æ—¥å¿—查询响应结构体
struct LogQueryRes {
    Head head;
    int status;                    // å“åº”状态 (如 0 è¡¨ç¤ºæˆåŠŸï¼Œéž 0 è¡¨ç¤ºå¤±è´¥)
    char errorMessage[256];        // é”™è¯¯ä¿¡æ¯ï¼ˆå¦‚果有）

    // æ— å‚构造函数
    LogQueryRes() {
        head.type = LOGSEARCH_RES;
        head.len = sizeof(LogQueryRes);
    }
};




#endif // COMMON_H

 Client/½ª¿É¸ý/document/ȨÏÞ¹ÜÀíÐèÇó·ÖÎö.docx

Binary files differ

 Client/½ª¿É¸ý/log/½ª¿É¸ý_1106.doc

Binary files differ

 Server/Àîתת/log/ÅäÖùÜÀí_Àîתת_1106.doc

Binary files differ

 common.h

@@ -90,6 +90,14 @@
    //日志
    LOGSEARCH_REQ,//日志查询请求
    LOGSEARCH_RES,//日志查询响应
	
    //历史查询分析
    HISTORY_DEV_REQ,        //历史查询硬件请求
    HISTORY_DEV_RES,        //历史查询硬件响应
    HISTORY_PRODUCE_REQ,    //历史查询生产请求
    HISTORY_PRODUCE_RES,    //历史查询生产响应
    HISTORY_ENV_REQ,    //历史查询环境请求
    HISTORY_ENV_RES,    //历史查询环境响应

};

@@ -276,22 +284,22 @@
//设备管理
struct DevicesInfo
{
    int deviceID;
    char deviceName[32];//设备名称
    char deviceStatus[32];//设备状态
    char area[32]; // åœ°åŒº
    double longitude;//经度
    double latitude;//纬度
    char purchasingTime[15];//购买时间
    char installTime[15];//安装时间
    char manufacturer[100];//厂家
    char devicesSerialNumber[32];//设备编码
    char devicesType[32];//设备类型
    double longitude;//经度
    double latitude;//纬度
    char purchasingTime[15];//购买时间
    char installTime[15];//安装时间
    char devicesSerialNumber[32];//设备编码
};
//添加设备
struct ADReq//添加请求
{
    Head head;
    char deviceName[32];
    DevicesInfo devInfo[0];
    ADReq() {
        head.type = AD_REQ;
        head.len = sizeof(ADReq);
@@ -302,7 +310,7 @@
struct ADRes//添加响应
{
    Head head;
    int type;
    int status;
    ADRes() {
        head.type = AD_RES;
        head.len = sizeof(ADRes);
@@ -310,22 +318,23 @@

};
//修改设备
struct MDRes//修改请求
struct MDReq//修改请求
{
    Head head;
    DevicesInfo info;
    MDRes() {
        head.type = MD_RES;
        head.len = sizeof(MDRes);
    }
};
struct MDReq//修改响应
{
    Head head;
    int type;
	
    MDReq() {
        head.type = MD_REQ;
        head.len = sizeof(MDReq);
    }
};
struct MDRes//修改响应
{
    Head head;
    DevicesInfo info;
    int status;
    MDRes() {
        head.type = MD_RES;
        head.len = sizeof(MDRes);
    }
};
//查询设备
@@ -341,7 +350,7 @@
struct QDRes//查询响应
{
    Head head;
    int type;
    int status;
    QDRes() {
        head.type = QD_RES;
        head.len = sizeof(QDRes);
@@ -827,40 +836,91 @@


//历史查询分析
// åŽ†å²æŸ¥è¯¢è¯·æ±‚结构体
struct HistoryQueryReq {

//历史查询分析

struct warningInfo {
    int device_id;
    char des[32];
    char time[32];
    float data;
    char type[16];
    char status[16];
};
// åŽ†å²æŸ¥è¯¢è®¾å¤‡ä¿¡æ¯è¯·æ±‚结构体
struct HistoryDevReq {
    Head head;
    //根据时间范围查询
    char startTime[32];
    char endTime[32];
    //关键字查询
    char keyWord[32];
    HistoryQueryReq() {
    HistoryDevReq() {
        // åˆå§‹åŒ–数据头
        head.type = QUERY_MONOUTPUT_REQ;
        head.len = sizeof(HistoryQueryReq);
        head.type = HISTORY_DEV_REQ;
        head.len = sizeof(HISTORY_DEV_REQ);
        // åˆå§‹åŒ–查询条件字段
        std::memset(startTime, 0, sizeof(startTime));
        std::memset(endTime, 0, sizeof(endTime));

    }
};
// åŽ†å²æŸ¥è¯¢ç”Ÿäº§è®¡åˆ’请求结构体
struct HistoryProReq {
    Head head;
    //根据时间范围查询
    char startTime[32];
    char endTime[32];
    //关键字查询
    char keyWord[32];
    HistoryProReq() {
        // åˆå§‹åŒ–数据头
        head.type = HISTORY_PRODUCE_REQ;
        head.len = sizeof(HistoryProReq);
        // åˆå§‹åŒ–查询条件字段
    }
};
// åŽ†å²æŸ¥è¯¢çŽ¯å¢ƒä¿¡æ¯è¯·æ±‚结构体
struct HistoryEnvReq {
    Head head;
    //根据时间范围查询
    char startTime[32];
    char endTime[32];
    //关键字查询
    char keyWord[32];
    HistoryEnvReq() {
        // åˆå§‹åŒ–数据头
        head.type = HISTORY_ENV_REQ;
        head.len = sizeof(HistoryEnvReq);
        // åˆå§‹åŒ–查询条件字段
    }
};

// åŽ†å²æŸ¥è¯¢å“åº”结构体

// ç³»ç»Ÿè¿è¡ŒçŠ¶æ€è¡¨ç›¸å…³ä¿¡æ¯
struct HistroyInfo {
    WarningRes warn;//警报查询
    QDRes dev;//设备查询
    QueryPdplanRes  pro;//生产计划查询
};
struct HistoryQueryRes {
//查询设备信息响应结构体
struct HistoryDevRes {
    Head head;
    HistroyInfo sys[0];
    HistoryQueryRes() {
    DevicesInfo dev[0];
    HistoryDevRes() {
        // åˆå§‹åŒ–数据头
        head.type = QUERY_MONOUTPUT_RES;
        head.len = sizeof(HistoryQueryRes);
        head.type = HISTORY_DEV_RES;
        head.len = sizeof(HistoryDevRes);
    }
};
//查询生产计划响应结构体
struct HistoryProRes {
    Head head;
    PdplanInfo pro[0];
    HistoryProRes() {
        // åˆå§‹åŒ–数据头
        head.type = HISTORY_PRODUCE_RES;
        head.len = sizeof(HistoryProRes);
    }
};
//查询环境信息响应结构体
struct HistoryEnvRes {
    Head head;
    warningInfo env[0];
    HistoryEnvRes() {
        // åˆå§‹åŒ–数据头
        head.type = HISTORY_ENV_RES;
        head.len = sizeof(HistoryEnvRes);
    }
};


 ±í.docx

Binary files differ