p_transmit_disinfection
/
transmit_disinfection_public_code
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

update

master
zhaohe 1 year ago
parent
60c87ea8a1
commit
924cd2ef42
2 changed files with 152 additions and 0 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 100
      api/cmds/pipeline_disinfection_cmd_append.cpp
  2. 52
      api/cmds/pipeline_disinfection_cmd_append.hpp

100
api/cmds/pipeline_disinfection_cmd_append.cpp
View File

@ -0,0 +1,100 @@
#include "pipeline_disinfection_cmd_append.hpp"
using namespace iflytop;
#ifdef PROJECT_TYPE_PIPE_DISINFECTION
void PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_setState(json& cmd, json& receipt) {
m_deviceIoControlService->airCompressor_setState(cmd["params"][0]);
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_channelSelect(json& cmd, json& receipt) {
m_deviceIoControlService->airCompressor_channelSelect(cmd["params"][0]);
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_setValve1(json& cmd, json& receipt) {
m_deviceIoControlService->airCompressor_setValve1(cmd["params"][0]);
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_setValve2(json& cmd, json& receipt) {
m_deviceIoControlService->airCompressor_setValve2(cmd["params"][0]);
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_getPressureDirect(json& cmd, json& receipt) {
receipt["ack"][0] = m_deviceIoControlService->airCompressor_getPressureDirect();
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_getPressure(json& cmd, json& receipt) {
receipt["ack"][0] = m_deviceIoControlService->airCompressor_getPressure();
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_getValve1(json& cmd, json& receipt) {
receipt["ack"][0] = m_deviceIoControlService->airCompressor_getValve1();
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_getValve2(json& cmd, json& receipt) {
receipt["ack"][0] = m_deviceIoControlService->airCompressor_getValve2();
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__AirInletProportionalValve_setState(json& cmd, json& receipt) {
m_deviceIoControlService->AirInletProportionalValve_setState(cmd["params"][0]);
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__AirInletProportionalValve_getState(json& cmd, json& receipt) {
receipt["ack"][0] = m_deviceIoControlService->AirInletProportionalValve_getState();
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__AirOutletProportionalValve_getState(json& cmd, json& receipt) {
receipt["ack"][0] = m_deviceIoControlService->AirOutletProportionalValve_getState();
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__AirOutletProportionalValve_setState(json& cmd, json& receipt) {
m_deviceIoControlService->AirOutletProportionalValve_setState(cmd["params"][0]);
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__AirProportionalValve_setState(json& cmd, json& receipt) {
m_deviceIoControlService->AirProportionalValve_setState(cmd["params"][0], cmd["params"][1]);
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__AirProportionalValve_getState(json& cmd, json& receipt) {
int32_t ack0;
int32_t ack1;
receipt["ackcode"] = m_deviceIoControlService->AirProportionalValve_getState(&ack0, &ack1);
receipt["ack"][0] = ack0;
receipt["ack"][1] = ack1;
return;
}
void PipelineDisinfectionCmdAppend::DeviceIOControlService__AirProportionalValve_isBusy(json& cmd, json& receipt) {
int32_t ack0;
receipt["ackcode"] = m_deviceIoControlService->AirProportionalValve_isBusy(&ack0);
receipt["ack"][0] = ack0;
return;
}
void PipelineDisinfectionCmdAppend::initialize() {
GET_TO_SERVICE(m_msgProcesser);
GET_TO_SERVICE(m_zconfig);
GET_TO_SERVICE(m_iflytopwsService);
GET_TO_SERVICE(m_dbService);
GET_TO_SERVICE(m_deviceStateService);
GET_TO_SERVICE(m_disinfectionCtrlService);
GET_TO_SERVICE(m_deviceIoControlService);
GET_TO_SERVICE(m_disinfectionLogsManager);
GET_TO_SERVICE(m_zcanhost);
GET_TO_SERVICE(m_dataExportService);
GET_TO_SERVICE(m_frontMsgProcesser);
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.airCompressor_setState", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_setState));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.airCompressor_channelSelect", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_channelSelect));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.airCompressor_setValve1", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_setValve1));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.airCompressor_setValve2", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_setValve2));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.airCompressor_getPressureDirect", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_getPressureDirect));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.airCompressor_getPressure", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_getPressure));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.airCompressor_getValve1", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_getValve1));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.airCompressor_getValve2", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__airCompressor_getValve2));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.AirInletProportionalValve_setState", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__AirInletProportionalValve_setState));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.AirInletProportionalValve_getState", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__AirInletProportionalValve_getState));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.AirOutletProportionalValve_getState", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__AirOutletProportionalValve_getState));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.AirOutletProportionalValve_setState", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__AirOutletProportionalValve_setState));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.AirProportionalValve_setState", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__AirProportionalValve_setState));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.AirProportionalValve_getState", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__AirProportionalValve_getState));
m_msgProcesser->registerMsgProcesser("DeviceIOControlService.AirProportionalValve_isBusy", BIND(PipelineDisinfectionCmdAppend::DeviceIOControlService__AirProportionalValve_isBusy));
}
#endif

52
api/cmds/pipeline_disinfection_cmd_append.hpp
View File

@ -0,0 +1,52 @@
#include <fstream>
#include <iostream>
#include <list>
#include <map>
#include <memory>
#include <set>
#include <sstream>
#include <string>
#include <vector>
//
#include "api/front_msg_processer.hpp"
#include "configs/project_setting.hpp"
namespace iflytop {
class PipelineDisinfectionCmdAppend : public enable_shared_from_this<PipelineDisinfectionCmdAppend> {
ENABLE_LOGGER(PipelineDisinfectionCmdAppend);
shared_ptr<FrontMsgProcesser> m_msgProcesser;
shared_ptr<GConfig> m_zconfig;
shared_ptr<IflytopFrontEndService> m_iflytopwsService;
shared_ptr<DBService> m_dbService;
shared_ptr<DeviceStateService> m_deviceStateService;
shared_ptr<DisinfectionCtrlService> m_disinfectionCtrlService;
shared_ptr<IF_DeviceIoContrlService> m_deviceIoControlService;
shared_ptr<DisinfectionLogsManager> m_disinfectionLogsManager;
shared_ptr<ZCanHost> m_zcanhost;
shared_ptr<DataExportService> m_dataExportService;
shared_ptr<FrontMsgProcesser> m_frontMsgProcesser;
public:
PipelineDisinfectionCmdAppend(){};
void initialize();
private:
void DeviceIOControlService__airCompressor_setState(json& cmd, json& receipt);
void DeviceIOControlService__airCompressor_channelSelect(json& cmd, json& receipt);
void DeviceIOControlService__airCompressor_setValve1(json& cmd, json& receipt);
void DeviceIOControlService__airCompressor_setValve2(json& cmd, json& receipt);
void DeviceIOControlService__airCompressor_getPressureDirect(json& cmd, json& receipt);
void DeviceIOControlService__airCompressor_getPressure(json& cmd, json& receipt);
void DeviceIOControlService__airCompressor_getValve1(json& cmd, json& receipt);
void DeviceIOControlService__airCompressor_getValve2(json& cmd, json& receipt);
void DeviceIOControlService__AirInletProportionalValve_setState(json& cmd, json& receipt);
void DeviceIOControlService__AirInletProportionalValve_getState(json& cmd, json& receipt);
void DeviceIOControlService__AirOutletProportionalValve_getState(json& cmd, json& receipt);
void DeviceIOControlService__AirOutletProportionalValve_setState(json& cmd, json& receipt);
void DeviceIOControlService__AirProportionalValve_setState(json& cmd, json& receipt);
void DeviceIOControlService__AirProportionalValve_getState(json& cmd, json& receipt);
void DeviceIOControlService__AirProportionalValve_isBusy(json& cmd, json& receipt);
};
} // namespace iflytop
Write Preview
Loading…
Cancel
Save