diff --git a/api/cmds/pipeline_disinfection_cmd_append.cpp b/api/cmds/pipeline_disinfection_cmd_append.cpp new file mode 100644 index 0000000..4da294a --- /dev/null +++ b/api/cmds/pipeline_disinfection_cmd_append.cpp @@ -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 \ No newline at end of file diff --git a/api/cmds/pipeline_disinfection_cmd_append.hpp b/api/cmds/pipeline_disinfection_cmd_append.hpp new file mode 100644 index 0000000..99ae34f --- /dev/null +++ b/api/cmds/pipeline_disinfection_cmd_append.hpp @@ -0,0 +1,52 @@ +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +#include "api/front_msg_processer.hpp" +#include "configs/project_setting.hpp" +namespace iflytop { + +class PipelineDisinfectionCmdAppend : public enable_shared_from_this { + ENABLE_LOGGER(PipelineDisinfectionCmdAppend); + + shared_ptr m_msgProcesser; + shared_ptr m_zconfig; + shared_ptr m_iflytopwsService; + shared_ptr m_dbService; + shared_ptr m_deviceStateService; + shared_ptr m_disinfectionCtrlService; + shared_ptr m_deviceIoControlService; + shared_ptr m_disinfectionLogsManager; + shared_ptr m_zcanhost; + shared_ptr m_dataExportService; + shared_ptr 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