| | |
|---|
| | | user: str, |
|---|
| | | password: str, |
|---|
| | | queue: str, |
|---|
| | | device_manager: DeviceManager): |
|---|
| | | device_manager: DeviceManager, |
|---|
| | | save_folder: str): |
|---|
| | | threading.Thread.__init__(self) |
|---|
| | | self._device_manager = device_manager |
|---|
| | | self.save_folder = save_folder |
|---|
| | | self._def_routes() |
|---|
| | | self.message_received: int = 0 |
|---|
| | | |
|---|
| | |
|---|
| | | print( |
|---|
| | | f'send image sub command received, length={req.data1.length}') |
|---|
| | | if req.data1.length > 0: |
|---|
| | | device = self._device_manager.get_device(req.device_id) |
|---|
| | | device = self._device_manager.get_device(req.device_id, self.save_folder) |
|---|
| | | img_msg = pb.ImagesMessage() |
|---|
| | | img_msg.ParseFromString(req.data1.data) |
|---|
| | | # print(img_msg.image1) |
|---|
| | |
|---|
| | | print('micro wave command') |
|---|
| | | if pb.SubCommand.MICRO_WAVE_SUB_COMMAND == req.sub_command: |
|---|
| | | print('micro wave sub command received') |
|---|
| | | device = self._device_manager.get_device(req.device_id) |
|---|
| | | device = self._device_manager.get_device(req.device_id,self.save_folder) |
|---|
| | | micro_wave_msg = pb.MicroWaveMessage() |
|---|
| | | micro_wave_msg.ParseFromString(req.data1.data) |
|---|
| | | if (micro_wave_msg.length == len(micro_wave_msg.data)): |
|---|
