| | |
| | | import com.ard.alarm.digitization.model.DataBridge; |
| | | import com.ard.alarm.digitization.service.DataBridgeService; |
| | | import com.ard.utils.jdbc.Query; |
| | | import com.ard.utils.mqtt.MqttConsumer; |
| | | import com.ard.utils.mqtt.MqttProducer; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | |
| | | data.setWellNo(elem[0]); |
| | | data.setAlarmType(elem[1]); |
| | | data.setAlarmTime(elem[2]); |
| | | MqttConsumer.publish(2, false, "digitization3", JSON.toJSONString(data)); |
| | | MqttProducer.publish(2, false, "digitization3", JSON.toJSONString(data)); |
| | | } |
| | | } |
| | | } catch (Exception ex) { |