Skip to content
  • MySensors
  • OpenHardware.io
  • Categories
  • Recent
  • Tags
  • Popular
Skins
  • Light
  • Brite
  • Cerulean
  • Cosmo
  • Flatly
  • Journal
  • Litera
  • Lumen
  • Lux
  • Materia
  • Minty
  • Morph
  • Pulse
  • Sandstone
  • Simplex
  • Sketchy
  • Spacelab
  • United
  • Yeti
  • Zephyr
  • Dark
  • Cyborg
  • Darkly
  • Quartz
  • Slate
  • Solar
  • Superhero
  • Vapor

  • Default (No Skin)
  • No Skin
Collapse
Brand Logo
  1. Home
  2. Announcements
  3. 💬 Water Meter Pulse Sensor

💬 Water Meter Pulse Sensor

Scheduled Pinned Locked Moved Announcements
109 Posts 37 Posters 30.9k Views 35 Watching
  • Oldest to Newest
  • Newest to Oldest
  • Most Votes
Reply
  • Reply as topic
Log in to reply
This topic has been deleted. Only users with topic management privileges can see it.
  • E Offline
    E Offline
    executivul
    wrote on last edited by
    #87

    Sorry to hijack the thread a bit,
    I'm using a TCRT5000 sensor to read a water meter (Zenner), it works ok until it stops detecting pulses, I have to increase the sensitivity (clockwise turn the trimpot) and it works ok for another few days/weeks, then again it needs an increase in sensitivity, like somehow it's loosing it's sensitivity .
    I'm already with my second sensor, the first one got to the end of the trimpot and couldn't adjust anymore.

    Has this happened to anyone else? It's powered by 5V, it's the LED losing power or the photosensor losing sensitivity? Any ideas?
    Thanks.

    1 Reply Last reply
    0
    • gohanG Offline
      gohanG Offline
      gohan
      Mod
      wrote on last edited by
      #88

      Don't you have another sensor to try?

      1 Reply Last reply
      0
      • A Offline
        A Offline
        Alehandro06
        wrote on last edited by
        #89

        @flopp which box did you buy for m-bus readings? did you work it out?
        ''I was so lucky that my water company change the meter to a meter with wireless m-bus.
        So I bought a box for this and now I have 100% correct readings.''

        1 Reply Last reply
        0
        • B Offline
          B Offline
          bereska
          wrote on last edited by
          #90

          Water Meter shows up in mysensors.json and homeassistant logs but fails to appear in Homeassistant GUI.
          I have a dozen Nodes already successfully operating
          I used the default sketch on this page. Just added Node 6
          Looks like values are not getting through
          Thank you for your help

          1 Reply Last reply
          0
          • B Offline
            B Offline
            bereska
            wrote on last edited by
            #91

            this is HA log:

            2019-07-04 23:24:05 DEBUG (MainThread) [homeassistant.components.mqtt] Received message on mygateway1-out/6/255/3/0/11: b'Water Meter',
            2019-07-04 23:24:05 DEBUG (MainThread) [mysensors.gateway_mqtt] Receiving 6;255;3;0;11;Water Meter,
            2019-07-04 23:24:23 DEBUG (MainThread) [homeassistant.components.mqtt] Received message on mygateway1-out/6/255/3/0/11: b'Water Meter',
            2019-07-04 23:24:23 DEBUG (MainThread) [mysensors.gateway_mqtt] Receiving 6;255;3;0;11;Water Meter

            B 1 Reply Last reply
            0
            • B bereska

              this is HA log:

              2019-07-04 23:24:05 DEBUG (MainThread) [homeassistant.components.mqtt] Received message on mygateway1-out/6/255/3/0/11: b'Water Meter',
              2019-07-04 23:24:05 DEBUG (MainThread) [mysensors.gateway_mqtt] Receiving 6;255;3;0;11;Water Meter,
              2019-07-04 23:24:23 DEBUG (MainThread) [homeassistant.components.mqtt] Received message on mygateway1-out/6/255/3/0/11: b'Water Meter',
              2019-07-04 23:24:23 DEBUG (MainThread) [mysensors.gateway_mqtt] Receiving 6;255;3;0;11;Water Meter

              B Offline
              B Offline
              bereska
              wrote on last edited by
              #92

              here is the sketch:

              // Enable debug prints to serial monitor
              #define MY_DEBUG
              
              // Enable and select radio type attached
              #define MY_RADIO_RF24
              #define MY_NODE_ID 6
              //#define MY_RADIO_NRF5_ESB
              //#define MY_RADIO_RFM69
              //#define MY_RADIO_RFM95
              
              #include <MySensors.h>
              
              #define DIGITAL_INPUT_SENSOR 3                  // The digital input you attached your sensor.  (Only 2 and 3 generates interrupt!)
              
              #define PULSE_FACTOR 1000                       // Number of blinks per m3 of your meter (One rotation/liter)
              
              #define SLEEP_MODE false                        // flowvalue can only be reported when sleep mode is false.
              
              #define MAX_FLOW 40                             // Max flow (l/min) value to report. This filters outliers.
              
              #define CHILD_ID 1                              // Id of the sensor child
              
              uint32_t SEND_FREQUENCY =
                  30000;           // Minimum time between send (in milliseconds). We don't want to spam the gateway.
              
              MyMessage flowMsg(CHILD_ID,V_FLOW);
              MyMessage volumeMsg(CHILD_ID,V_VOLUME);
              MyMessage lastCounterMsg(CHILD_ID,V_VAR1);
              
              double ppl = ((double)PULSE_FACTOR)/1000;        // Pulses per liter
              
              volatile uint32_t pulseCount = 0;
              volatile uint32_t lastBlink = 0;
              volatile double flow = 0;
              bool pcReceived = false;
              uint32_t oldPulseCount = 0;
              uint32_t newBlink = 0;
              double oldflow = 0;
              double volume =0;
              double oldvolume =0;
              uint32_t lastSend =0;
              uint32_t lastPulse =0;
              
              void setup()
              {
                // initialize our digital pins internal pullup resistor so one pulse switches from high to low (less distortion)
                pinMode(DIGITAL_INPUT_SENSOR, INPUT_PULLUP);
              
                pulseCount = oldPulseCount = 0;
              
                // Fetch last known pulse count value from gw
                request(CHILD_ID, V_VAR1);
              
                lastSend = lastPulse = millis();
              
                attachInterrupt(digitalPinToInterrupt(DIGITAL_INPUT_SENSOR), onPulse, FALLING);
              }
              
              void presentation()
              {
                // Send the sketch version information to the gateway and Controller
                sendSketchInfo("Water Meter", "1.1");
              
                // Register this device as Water flow sensor
                present(CHILD_ID, S_WATER);
              }
              
              void loop()
              {
                uint32_t currentTime = millis();
              
                // Only send values at a maximum frequency or woken up from sleep
                if (SLEEP_MODE || (currentTime - lastSend > SEND_FREQUENCY)) {
                  lastSend=currentTime;
              
                  if (!pcReceived) {
                    //Last Pulsecount not yet received from controller, request it again
                    request(CHILD_ID, V_VAR1);
                    return;
                  }
              
                  if (!SLEEP_MODE && flow != oldflow) {
                    oldflow = flow;
              
                    Serial.print("l/min:");
                    Serial.println(flow);
              
                    // Check that we don't get unreasonable large flow value.
                    // could happen when long wraps or false interrupt triggered
                    if (flow<((uint32_t)MAX_FLOW)) {
                      send(flowMsg.set(flow, 2));                   // Send flow value to gw
                    }
                  }
              
                  // No Pulse count received in 2min
                  if(currentTime - lastPulse > 120000) {
                    flow = 0;
                  }
              
                  // Pulse count has changed
                  if ((pulseCount != oldPulseCount)||(!SLEEP_MODE)) {
                    oldPulseCount = pulseCount;
              
                    Serial.print("pulsecount:");
                    Serial.println(pulseCount);
              
                    send(lastCounterMsg.set(pulseCount));                  // Send  pulsecount value to gw in VAR1
              
                    double volume = ((double)pulseCount/((double)PULSE_FACTOR));
                    if ((volume != oldvolume)||(!SLEEP_MODE)) {
                      oldvolume = volume;
              
                      Serial.print("volume:");
                      Serial.println(volume, 3);
              
                      send(volumeMsg.set(volume, 3));               // Send volume value to gw
                    }
                  }
                }
                if (SLEEP_MODE) {
                  sleep(SEND_FREQUENCY);
                }
              }
              
              void receive(const MyMessage &message)
              {
                if (message.type==V_VAR1) {
                  uint32_t gwPulseCount=message.getULong();
                  pulseCount += gwPulseCount;
                  flow=oldflow=0;
                  Serial.print("Received last pulse count from gw:");
                  Serial.println(pulseCount);
                  pcReceived = true;
                }
              }
              
              void onPulse()
              {
                if (!SLEEP_MODE) {
                  uint32_t newBlink = micros();
                  uint32_t interval = newBlink-lastBlink;
              
                  if (interval!=0) {
                    lastPulse = millis();
                    if (interval<500000L) {
                      // Sometimes we get interrupt on RISING,  500000 = 0.5 second debounce ( max 120 l/min)
                      return;
                    }
                    flow = (60000000.0 /interval) / ppl;
                  }
                  lastBlink = newBlink;
                }
                pulseCount++;
              }```
              1 Reply Last reply
              0
              • B Offline
                B Offline
                bereska
                wrote on last edited by
                #93

                looks like the problem is the node is NOT sending initial value to gw
                need your help modifying the sketch accordingly
                thank you

                1 Reply Last reply
                0
                • B Offline
                  B Offline
                  bereska
                  wrote on last edited by
                  #94

                  Is it possible to get any help on this page or not?

                  rejoe2R 1 Reply Last reply
                  0
                  • B bereska

                    Is it possible to get any help on this page or not?

                    rejoe2R Offline
                    rejoe2R Offline
                    rejoe2
                    wrote on last edited by
                    #95

                    @bereska said in 💬 Water Meter Pulse Sensor:

                    Is it possible to get any help on this page or not?

                    Crying out loud most likely will not help...
                    Seems your setup is a little special, so just some assumptions from one using a serial GW and not MyS-MQTT:
                    Your controller is asked for sending an initial value, but has none yet. So no answer is sent out. Triggering the counter on Node side could help to send one (after waiting time has passed). Then have a look at your controller, if there's a value available. If, you might set the correct value, restart your node afterwards and see, if everything now works as expected?

                    Controller: FHEM; MySensors: 2.3.1, RS485,nRF24,RFM69, serial Gateways

                    B 1 Reply Last reply
                    1
                    • rejoe2R rejoe2

                      @bereska said in 💬 Water Meter Pulse Sensor:

                      Is it possible to get any help on this page or not?

                      Crying out loud most likely will not help...
                      Seems your setup is a little special, so just some assumptions from one using a serial GW and not MyS-MQTT:
                      Your controller is asked for sending an initial value, but has none yet. So no answer is sent out. Triggering the counter on Node side could help to send one (after waiting time has passed). Then have a look at your controller, if there's a value available. If, you might set the correct value, restart your node afterwards and see, if everything now works as expected?

                      B Offline
                      B Offline
                      bereska
                      wrote on last edited by
                      #96

                      @rejoe2 thank you. How do i trigger "the counter on Node side"?

                      1 Reply Last reply
                      0
                      • rejoe2R Offline
                        rejoe2R Offline
                        rejoe2
                        wrote on last edited by
                        #97

                        ...just let the node count some pulses (your code states: FALLING). So just pull the counter PIN (here: D3) to ground several times.

                        Controller: FHEM; MySensors: 2.3.1, RS485,nRF24,RFM69, serial Gateways

                        B 1 Reply Last reply
                        0
                        • rejoe2R rejoe2

                          ...just let the node count some pulses (your code states: FALLING). So just pull the counter PIN (here: D3) to ground several times.

                          B Offline
                          B Offline
                          bereska
                          wrote on last edited by
                          #98

                          @rejoe2 i did like you said, still no show in HA
                          here is the serial log:

                           __  __       ____
                          |  \/  |_   _/ ___|  ___ _ __  ___  ___  _ __ ___
                          | |\/| | | | \___ \ / _ \ `_ \/ __|/ _ \| `__/ __|
                          | |  | | |_| |___| |  __/ | | \__ \  _  | |  \__ \
                          |_|  |_|\__, |____/ \___|_| |_|___/\___/|_|  |___/
                                  |___/                      2.3.0
                          
                          16 MCO:BGN:INIT NODE,CP=RNNNA---,VER=2.3.0
                          26 TSM:INIT
                          28 TSF:WUR:MS=0
                          34 !TSM:INIT:TSP FAIL
                          36 TSM:FAIL:CNT=1
                          38 TSM:FAIL:DIS
                          40 TSF:TDI:TSL
                           
                           __  __       ____
                          |  \/  |_   _/ ___|  ___ _ __  ___  ___  _ __ ___
                          | |\/| | | | \___ \ / _ \ `_ \/ __|/ _ \| `__/ __|
                          | |  | | |_| |___| |  __/ | | \__ \  _  | |  \__ \
                          |_|  |_|\__, |____/ \___|_| |_|___/\___/|_|  |___/
                                  |___/                      2.3.0
                          
                          16 MCO:BGN:INIT NODE,CP=RNNNA---,VER=2.3.0
                          26 TSM:INIT
                          28 TSF:WUR:MS=0
                          34 TSM:INIT:TSP OK
                          36 TSM:INIT:STATID=6
                          38 TSF:SID:OK,ID=6
                          40 TSM:FPAR
                          77 TSF:MSG:SEND,6-6-255-255,s=255,c=3,t=7,pt=0,l=0,sg=0,ft=0,st=OK:
                          532 TSF:MSG:READ,0-0-6,s=255,c=3,t=8,pt=1,l=1,sg=0:0
                          538 TSF:MSG:FPAR OK,ID=0,D=1
                          624 TSF:MSG:READ,31-31-6,s=255,c=3,t=8,pt=1,l=1,sg=0:1
                          1267 TSF:MSG:READ,21-21-6,s=255,c=3,t=8,pt=1,l=1,sg=0:1
                          1546 TSF:MSG:READ,41-41-6,s=255,c=3,t=8,pt=1,l=1,sg=0:1
                          2088 TSM:FPAR:OK
                          2088 TSM:ID
                          2091 TSM:ID:OK
                          2093 TSM:UPL
                          2097 TSF:MSG:SEND,6-6-0-0,s=255,c=3,t=24,pt=1,l=1,sg=0,ft=0,st=OK:1
                          2103 TSF:MSG:READ,0-0-6,s=255,c=3,t=25,pt=1,l=1,sg=0:1
                          2109 TSF:MSG:PONG RECV,HP=1
                          2113 TSM:UPL:OK
                          2115 TSM:READY:ID=6,PAR=0,DIS=1
                          2119 TSF:MSG:SEND,6-6-0-0,s=255,c=3,t=15,pt=6,l=2,sg=0,ft=0,st=OK:0100
                          2127 TSF:MSG:READ,0-0-6,s=255,c=3,t=15,pt=6,l=2,sg=0:0100
                          2138 TSF:MSG:SEND,6-6-0-0,s=255,c=0,t=17,pt=0,l=5,sg=0,ft=0,st=OK:2.3.0
                          2148 TSF:MSG:SEND,6-6-0-0,s=255,c=3,t=6,pt=1,l=1,sg=0,ft=0,st=OK:0
                          2242 TSF:MSG:READ,0-0-6,s=255,c=3,t=6,pt=0,l=1,sg=0:M
                          2250 TSF:MSG:SEND,6-6-0-0,s=255,c=3,t=11,pt=0,l=11,sg=0,ft=0,st=OK:Water Meter
                          2260 TSF:MSG:SEND,6-6-0-0,s=255,c=3,t=12,pt=0,l=3,sg=0,ft=0,st=OK:1.1
                          2273 TSF:MSG:SEND,6-6-0-0,s=1,c=0,t=21,pt=0,l=0,sg=0,ft=0,st=OK:
                          2281 MCO:REG:REQ
                          2289 TSF:MSG:SEND,6-6-0-0,s=255,c=3,t=26,pt=1,l=1,sg=0,ft=0,st=OK:2
                          2297 TSF:MSG:READ,0-0-6,s=255,c=3,t=27,pt=1,l=1,sg=0:1
                          2304 MCO:PIM:NODE REG=1
                          2306 MCO:BGN:STP
                          2310 TSF:MSG:SEND,6-6-0-0,s=1,c=2,t=24,pt=0,l=0,sg=0,ft=0,st=OK:
                          2318 MCO:BGN:INIT OK,TSP=1
                          32319 TSF:MSG:SEND,6-6-0-0,s=1,c=2,t=24,pt=0,l=0,sg=0,ft=0,st=OK:
                          
                          1 Reply Last reply
                          0
                          • rejoe2R Offline
                            rejoe2R Offline
                            rejoe2
                            wrote on last edited by rejoe2
                            #99

                            @bereska said in 💬 Water Meter Pulse Sensor:

                            32319 TSF:MSG:SEND,6-6-0-0,s=1,c=2,t=24,pt=0,l=0,sg=0,ft=0,st=OK:

                            Logparser states: there was nothing counted (empty payload). So make sure, there really was counted anything.
                            (I didn't check your sketch, just assuming, it's the default one and everything is wired correctly; if that's the case, you should be able to see a different payload than nothing or "0", that your controller might treat as non existent).

                            Controller: FHEM; MySensors: 2.3.1, RS485,nRF24,RFM69, serial Gateways

                            1 Reply Last reply
                            1
                            • mfalkviddM mfalkvidd

                              Great work @bart59 !
                              Do you have any indication on how long battery life you will get with this setup?

                              S Offline
                              S Offline
                              stevefury
                              wrote on last edited by
                              #100

                              @mfalkvidd how looks the sensor now with the modifications? and how to wire this?

                              mfalkviddM 1 Reply Last reply
                              0
                              • S stevefury

                                @mfalkvidd how looks the sensor now with the modifications? and how to wire this?

                                mfalkviddM Offline
                                mfalkviddM Offline
                                mfalkvidd
                                Mod
                                wrote on last edited by mfalkvidd
                                #101

                                @stevefury sorry, I don't understand. Which modifications are you referring to?

                                1 Reply Last reply
                                0
                                • I Offline
                                  I Offline
                                  ibibiuooui
                                  wrote on last edited by
                                  #102

                                  I'm just getting this....

                                  16:57:15.660 -> 10091 TSM:FAIL:RE-INIT
                                  16:57:15.660 -> 10093 TSM:INIT
                                  16:57:15.660 -> 10101 !TSM:INIT:TSP FAIL
                                  16:57:15.660 -> 10103 TSM:FAIL:CNT=2
                                  16:57:15.660 -> 10107 TSM:FAIL:DIS
                                  16:57:15.713 -> 10111 TSF:TDI:TSL

                                  1 Reply Last reply
                                  0
                                  • rejoe2R Offline
                                    rejoe2R Offline
                                    rejoe2
                                    wrote on last edited by
                                    #103

                                    @ibibiuooui said in 💬 Water Meter Pulse Sensor:

                                    !TSM:INIT:TSP FAIL

                                    See https://www.mysensors.org/build/parser: There's a problem in the initialisation of your transceiver (whatever it may be). So first check wiring, see https://forum.mysensors.org/topic/666/read-this-first-it-could-save-you-a-lot-of-time for further details. If that doesn't help, imo you should open up a seperate thread.

                                    Controller: FHEM; MySensors: 2.3.1, RS485,nRF24,RFM69, serial Gateways

                                    1 Reply Last reply
                                    1
                                    • CrankyCoderC Offline
                                      CrankyCoderC Offline
                                      CrankyCoder
                                      wrote on last edited by CrankyCoder
                                      #104

                                      I am finally getting around to trying this out. I was playing with just trying to see if i can get the pulses. First thing i did was take an old compass and put it beside the meter and had someone turn on the water. I could definitely see the compass needle pull a little as the water was flowing. So I assumed that pull was enough to be detectable with my hall effect sensor. I have tried a couple, and just can't seem to get it to pick up.

                                      If i use a magnet, simple code will detect the pulse and the green led on the sensor lights up.

                                      But no matter where I put that sensor near the meter it just doesn't seem to detect it. Not quite sure what's happening.

                                      The meter i have is this one.
                                      https://www.badgermeter.com/resources/add29b88-1ffb-49c9-80ab-bb8697bd6d1a/absolute digital encoder product data sheet ade-ds-00183-en.pdf/

                                      Not sure if anyone has any recommendation on which hall effect sensor would be the best for this but ill take suggestions lol

                                      My sensor I am testing with is
                                      3144E Hall Effect Sensor

                                      Doesn't have a sensitivity dial but the recommended one on this build page didn't either.

                                      Home Automation Tinkerer
                                      www.CrankyCoder.net

                                      Controller: HomeAssistant in Kubernetes
                                      Gateway: MQTTClientGateway
                                      MySensors: 2.3

                                      1 Reply Last reply
                                      0
                                      • bart59B bart59

                                        I wanted to operate my water pulse meter on batteries and also get the water flow. The original design had the following issues with that:

                                        • Incorrect flow calc: micros() was used to calculate the flow, however micros() wraps every 70 minutes which looks like a huge flow (which is then discarded in code)
                                        • Volume calc: millis() wraps every 50 days which is not handled correctly either
                                        • Too much current for battery use: The IR LED of the TCRT5000 is always on and the LM393 comparator is also taking a few mA's
                                        • Could not report flow in sleep mode because millis() does not increment on sleep - need to do this based on calculation of total sleep time. We now simply calculate the number of pulses per minute and deduct the flow
                                        • I also had issued with the data transport reliability, so I added error counters (which show up on the Gateway as distance sensors)
                                        • I also wanted to provide a measurement counter to the gateway (that counts up each time a message is sent)
                                        • The sensor will reboot itself when too many errors occur

                                        So I modified the circuit of the IR sensor:

                                        • Assumption that the wheel of the water meter turns slowly (takes at least a few seconds to turn around)
                                        • We will wake up every 500 millisecond to turn on the IR LED connected to PIN 8. Pin 8 also powers the photo transistor that measures the reflection
                                        • I removed the power from the opamp circuit that is linked to the photo transistor
                                        • The voltage from the photo transistor is then read using an analog read on A1. Based on a threshold value we will deduct if the mirror on the water meter is in view
                                        • Pin 7 is connected to a learning switch which will turn the device in a specific mode and the min/max values on A1 are used to calculate the value of the threshold (which is then stored in the EEPROM)
                                        • After 30 seconds in learning mode, the new threshold is established and the LED on Pin 6 will show the actual on/off mirror signals, so you can see the pulses are correctly counted
                                        • switch back the DIP switch on Pin 7 to bring back normal mode
                                        • The circuit also contains the battery voltage sensor circuit (I am using a 1.5V battery and step up circuit). So the resistors used are 470k from + pole of battery to the A0 input and 1 M ohm from A0 to ground
                                        
                                        /**
                                        
                                         * Created by Henrik Ekblad <henrik.ekblad@mysensors.org>
                                         * Copyright (C) 2013-2015 Sensnology AB
                                         * Full contributor list: https://github.com/mysensors/Arduino/graphs/contributors
                                         *
                                         * Documentation: http://www.mysensors.org
                                         * Support Forum: http://forum.mysensors.org
                                         *
                                         * This program is free software; you can redistribute it and/or
                                         * modify it under the terms of the GNU General Public License
                                         * version 2 as published by the Free Software Foundation.
                                         *
                                         *******************************
                                         *
                                         * REVISION HISTORY
                                         * Version 1.0 - Henrik Ekblad
                                         * Version 1.1 - GizMoCuz
                                         * Version 1.2 - changed BM: using low power separate circuit for infra red on pin 8 + analog A1
                                         * 
                                         * ISSUES WITH ORIGINAL CODE
                                         * Incorrect flow calc: micros() was used to calculate the flow, however micros() is wraps every 70 minutes which looks like a huge flow (which is discarded)
                                         * Volume calc: millis() wraps every 50 days which is not handled correctly
                                         * Too much current for battery use: The IR LED of the TCRT5000 is always on and the LM393 comparator is also taking a few mA's
                                         * Could not report flow in sleep mode because millis() does not increment on sleep - need to do this based on calculation of total sleep time
                                         * 
                                         * MODIFIED CIRCUIT IR SENSOR
                                         * Assumption that the wheel of the water meter turns slowly (takes at least a few seconds to turn around)
                                         * We will wake up every second to turn on the IR LED (connected to PIN 8). Pin 8 also powers the photo transistor that measures the reflection
                                         * The voltage from the photo transistor is then read using an analog read on A1. Based on a treshold value we will deduct if the mirror is in view
                                         * Pin 7 is connected to a learning switch which will turn the device in continous mode and the min/max values on A1 are used to recalc the treshold
                                         * during a 30 second period. After this period the new treshold is established and the LED on Pin 6 will show the actual on/off mirror signals
                                         *
                                         * http://www.mysensors.org/build/pulse_water
                                         */
                                        
                                        // BOARD: PRO MINI 3.3V/ 8Mhz ATMEGA328 8Mhz
                                        
                                        // Enable debug prints to serial monitor
                                        #define MY_DEBUG 
                                        
                                        // Enable and select radio type attached
                                        #define MY_RADIO_NRF24
                                        //#define MY_RADIO_RFM69
                                        
                                        #define MY_NODE_ID 10                 // hard code the node number
                                        #include <SPI.h>
                                        #include <MySensors.h>  
                                        
                                        #define SENSOR_POWER 8                // pin that will provide power to IR LED + sense circuit
                                        #define IR_SENSE_PIN  A1              // input for IR voltage
                                        #define BATTERY_SENSE_PIN  A0         // select the input pin for the battery sense point
                                        #define LEARN_SWITCH_PIN 7            // switch (SW1 on battery module) to turn on learning mode (low==on)
                                        #define LEARN_LED_PIN 6               // LED feedback during learning mode (LED on battery module)
                                        #define LEARN_TIME 30                 // number of seconds we will keep learn loop
                                        
                                        #define PULSE_FACTOR 1000             // Nummber of blinks per m3 of your meter (One rotation/1 liter)
                                        #define MAX_FLOW 80                   // Max flow (l/min) value to report. This filters outliers.
                                        #define CHILD_ID 1                    // Id of the sensor child (contains 3 subs: V_FLOW, V_VOLUME, VAR1)
                                        #define CHILD_PINGID 2                // ID of ping counter
                                        #define CHILD_ERRID 3                 // ID of error counter
                                        
                                        #define CHECK_FREQUENCY 500           // time in milliseconds between loop (where we check the sensor) - 500ms   
                                        #define MIN_SEND_FREQ 60              // Minimum time between send (in multiplies of CHECK_FREQUENCY). We don't want to spam the gateway (30 seconds)
                                        #define MAX_SEND_FREQ 1200            // Maximum time between send (in multiplies of CHECK_FREQUENCY). We need to show we are alive (600 sec/10 min)
                                        #define IR_ON_SETTLE 2                // number of milliseconds after we turned on the IR LED and we assume the receive signal is stable (in ms)
                                        #define EE_TRESHOLD 10                // config addresses 0 + 1 used for treshold from learning (loadState() returns only uint8 value)
                                        #define TRESHOLD_MARGIN 3             // additional margin before we actually see a one or zero
                                        #define RESETMIN 5                    // number of cycle times (either 30 sec of 10 min) we consistently need to have transmission errors before we perform hard reset
                                        
                                        MyMessage volumeMsg(CHILD_ID,V_VOLUME); // display volume and flow on the same CHILD_ID
                                        MyMessage flowMsg(CHILD_ID,V_FLOW); // flow
                                        MyMessage lastCounterMsg(CHILD_ID,V_VAR1);
                                        MyMessage pingMsg(CHILD_PINGID,V_DISTANCE); // use distance to keep track of changing value
                                        MyMessage errMsg(CHILD_ERRID,V_DISTANCE); // use distance to keep track of changing value
                                        
                                        
                                        double ppl = ((double)PULSE_FACTOR / 1000.0);    // Pulses per liter
                                        unsigned int oldBatteryPcnt = 0;          // check if changed
                                        unsigned int minsendcnt = MIN_SEND_FREQ;  // counter for keeping minimum intervals between sending
                                        unsigned int maxsendcnt = MAX_SEND_FREQ;  // counter for keeping maximum intervals between sending 
                                        unsigned int treshold = 512;              // threshold value when to swap on/off for pulse
                                        unsigned long pulseCount = 0;             // total volume of this pulse meter (value stored/received on gateway on pcReceived)
                                        unsigned long oldPulseCount = 0;          // to see if we have received something
                                        boolean pcReceived = false;               // received volume from prior reboot
                                        boolean onoff = false;                    // sensor value above/below treshold 
                                        unsigned int intervalcnt = 0;             // number of cycles between last period (for flow calculation)
                                        double flow = 0;                          // maintain flow
                                        double oldflow = 0;                       // keep prior flow (only send on change)
                                        unsigned int learntime=LEARN_TIME*2;      // timer for learning period
                                        unsigned int learnlow = 1023;             // lowest value found during learning
                                        unsigned int learnhigh = 0;               // highest value found during learning
                                        boolean learnsaved = false;               // have saved learned value
                                        unsigned long pingcnt = 0;
                                        unsigned long errcnt = 0;                 // error count
                                        unsigned int errcnt2 = 0;                 // error counter set to 0 when sending is ok
                                        
                                        void(* resetFunc) (void) = 0;//declare reset function at address 0 (for rebooting the Arduino)
                                        
                                        void setup() {    
                                          // make sure a few vars have the right init value after software reboot
                                          pingcnt = 0;
                                          pcReceived = false;
                                          pulseCount = oldPulseCount = 0;
                                          // setup hardware
                                          pinMode(SENSOR_POWER, OUTPUT); 
                                          digitalWrite(SENSOR_POWER, LOW);
                                          pinMode(LEARN_SWITCH_PIN, INPUT_PULLUP);
                                          pinMode(LEARN_LED_PIN, INPUT);      // default is input because this pin also has SW2 of battery block
                                        
                                          // Fetch last known pulse count value from gateway
                                          request(CHILD_ID, V_VAR1);
                                        
                                          // Fetch threshold value from EE prom
                                          treshold = readEeprom(EE_TRESHOLD);
                                          if (treshold<30 || treshold>1000) treshold = 512;   // wrong value in EEprom, take default
                                          Serial.print("Treshold: ");
                                          Serial.println(treshold);
                                                
                                          // use the 1.1 V internal reference for the battery and IR sensor
                                        #if defined(__AVR_ATmega2560__)
                                           analogReference(INTERNAL1V1);
                                        #else
                                           analogReference(INTERNAL);
                                        #endif
                                          analogRead(IR_SENSE_PIN); // settle analogreference value
                                          wait(CHECK_FREQUENCY); // wait a bit
                                        }
                                        
                                        void presentation()  {
                                          // Send the sketch version information to the gateway and Controller
                                          sendSketchInfo("Water Meter", "1.2");
                                        
                                          // Register this device as Waterflow sensor
                                          present(CHILD_ID, S_WATER);      
                                          present(CHILD_PINGID, S_DISTANCE); 
                                          present(CHILD_ERRID, S_DISTANCE);
                                        }
                                        
                                        void loop() {
                                          if (digitalRead(LEARN_SWITCH_PIN)==LOW) {
                                            pinMode(LEARN_LED_PIN, OUTPUT);
                                            digitalWrite(SENSOR_POWER, HIGH);
                                            intervalcnt = 0;
                                            learn_loop();
                                          } else {
                                            learntime=LEARN_TIME*2;
                                            learnlow = 1023;
                                            learnhigh = 0;
                                            pinMode(LEARN_LED_PIN, INPUT);
                                            normal_loop();
                                          }
                                        }
                                        
                                        void learn_loop() {
                                          // will run into this loop as long as we are learning
                                          wait(500);
                                          unsigned int sensorValue = analogRead(IR_SENSE_PIN);
                                          Serial.print("IR: ");
                                          Serial.print(sensorValue);
                                          if (learntime>0) {
                                            // still learning
                                            learntime--;
                                            learnsaved = false;    
                                            digitalWrite(LEARN_LED_PIN, !digitalRead(LEARN_LED_PIN));  // blink led
                                            if (sensorValue < learnlow) {
                                              learnlow = sensorValue;
                                              Serial.println(" Lowest");
                                            } else if (sensorValue > learnhigh) {
                                              learnhigh = sensorValue;
                                              Serial.println(" Highest");
                                            } else Serial.println();
                                          } else {
                                            if (!learnsaved) {
                                              treshold = (learnhigh + learnlow)/2;
                                              Serial.print("Treshold: ");
                                              Serial.println(treshold);
                                              storeEeprom(EE_TRESHOLD, treshold);
                                            }
                                            learnsaved = true;
                                            // just display using LED
                                            digitalWrite(LEARN_LED_PIN, sensorValue>treshold);
                                            Serial.println((sensorValue>treshold ? " on" : " off"));
                                          }
                                        }
                                        
                                        void normal_loop() { 
                                          unsigned long start_loop = millis();    // to allow adjusting wait time
                                          intervalcnt++;
                                          // we start doing a measurement
                                          digitalWrite(SENSOR_POWER, HIGH);
                                          wait(IR_ON_SETTLE); 
                                          unsigned int sensorValue = analogRead(IR_SENSE_PIN);
                                          digitalWrite(SENSOR_POWER, LOW); 
                                          #ifdef MY_DEBUG_DETAIL
                                          Serial.print("IR: ");
                                          Serial.println(sensorValue);
                                          #endif
                                          boolean nowvalue = onoff;
                                          if (onoff && (sensorValue<treshold-TRESHOLD_MARGIN)) nowvalue = false;
                                          if (!onoff && (sensorValue>treshold+TRESHOLD_MARGIN)) nowvalue = true;
                                          if (nowvalue != onoff) {
                                            // we have a pulse, only count on upwards pulse
                                            onoff = nowvalue;
                                            if (onoff) {
                                              pulseCount++;
                                              #ifdef MY_DEBUG
                                              Serial.print("p: ");
                                              Serial.println(pulseCount);
                                              #endif
                                            }
                                          }
                                        
                                        // Only send values at a maximum frequency or woken up from sleep
                                          if (minsendcnt>0) minsendcnt--;
                                          if (maxsendcnt>0) maxsendcnt--;
                                          // send minimum interval when we have pulse changes or if we had some flow the prior time or send on timeout
                                          if ((minsendcnt==0 && (pulseCount != oldPulseCount)) || (minsendcnt==0 && oldflow != 0) || maxsendcnt==0) {
                                            if (!pcReceived) {   //Last Pulsecount not yet received from controller, request it again
                                              Serial.print("Re-request var1 ..");
                                              request(CHILD_ID, V_VAR1);
                                        // Prevent flooding the gateway with re-requests,,, wait at least 1000 ms for gateway (cannot be sleep or smartSleep
                                              wait(2*CHECK_FREQUENCY); 
                                              return;
                                            }
                                            minsendcnt = MIN_SEND_FREQ;
                                            maxsendcnt = MAX_SEND_FREQ;
                                            pingcnt++;
                                        
                                            sensorValue = analogRead(BATTERY_SENSE_PIN);
                                            int batteryPcnt = sensorValue / 10;
                                            // 1M, 470K divider across battery and using internal ADC ref of 1.1V
                                            // Sense point is bypassed with 0.1 uF cap to reduce noise at that point
                                            // ((1e6+470e3)/1e6)*1.1 = Vmax = 1.67 Volts
                                            // 1.67/1023 = Volts per bit = 0.00158065
                                        
                                            Serial.print("Battery %: ");
                                            Serial.println(batteryPcnt);
                                        
                                            if (oldBatteryPcnt != batteryPcnt) {
                                              sendBatteryLevel(batteryPcnt);
                                              oldBatteryPcnt = batteryPcnt;
                                            }
                                            double volume = ((double)pulseCount/((double)PULSE_FACTOR));      
                                            flow = ((double) (pulseCount-oldPulseCount)) * (60000.0 / ((double) intervalcnt*(double) CHECK_FREQUENCY)) / ppl;  // flow in liter/min
                                        
                                            #ifdef MY_DEBUG
                                            Serial.print("pulsecount:");
                                            Serial.println(pulseCount);
                                            Serial.print("volume:");
                                            Serial.println(volume, 3);
                                            Serial.print("l/min:");
                                            Serial.println(flow);
                                            #endif
                                               
                                            bool b = send(lastCounterMsg.set(pulseCount));  // Send  pulsecount value to gw in VAR1
                                            if (b) errcnt2=0; else { errcnt++; errcnt2++; }
                                            b = send(volumeMsg.set(volume, 3));               // Send volume (set function 2nd argument is resolution)
                                            if (b) errcnt2=0; else { errcnt++; errcnt2++; }
                                            b = send(flowMsg.set(flow, 2));                   // Send flow value to gw
                                            if (b) errcnt2=0; else { errcnt++; errcnt2++; }
                                            b = send(pingMsg.set(pingcnt));                   // ensure at least this var has a different value
                                            if (b) errcnt2=0; else { errcnt++; errcnt2++; }
                                            b = send(errMsg.set(errcnt2+((float) errcnt2/100),2));    // ensure we always send error count
                                            if (b) errcnt2=0; else { errcnt++; errcnt2++; }
                                            oldPulseCount = pulseCount;
                                            intervalcnt = 0;
                                            oldflow = flow; 
                                            if (errcnt2>= (5*RESETMIN)) {
                                              Serial.println("Reset");
                                              wait(300);
                                              resetFunc(); //call reset to reboot the Arduino
                                            }
                                          }
                                        // calculate how long it took to process all of this. then go to sleep for the remaining period
                                          unsigned long end_loop = millis();
                                          if (end_loop - start_loop < CHECK_FREQUENCY)
                                            sleep(CHECK_FREQUENCY - (end_loop > start_loop ? end_loop - start_loop : 0));
                                        }
                                        
                                        void receive(const MyMessage &message) {
                                          if (message.type==V_VAR1) {
                                            unsigned long gwPulseCount=message.getULong();
                                            pulseCount += gwPulseCount;
                                            oldPulseCount += gwPulseCount;
                                            flow=oldflow=0;
                                            Serial.print("Received last pulse count from gw:");
                                            Serial.println(pulseCount);
                                            pcReceived = true;
                                          }
                                        }
                                        
                                        
                                        void storeEeprom(int pos, int value) {
                                            // function for saving the values to the internal EEPROM
                                            // value = the value to be stored (as int)
                                            // pos = the first byte position to store the value in
                                            // only two bytes can be stored with this function (max 32.767)
                                            saveState(pos, ((unsigned int)value >> 8 ));
                                            pos++;
                                            saveState(pos, (value & 0xff));
                                        }
                                        
                                        int readEeprom(int pos) {
                                            // function for reading the values from the internal EEPROM
                                            // pos = the first byte position to read the value from 
                                            int hiByte;
                                            int loByte;
                                            hiByte = loadState(pos) << 8;
                                            pos++;
                                            loByte = loadState(pos);
                                            return (hiByte | loByte);
                                        }
                                        
                                        Emmanuel AbrahamE Offline
                                        Emmanuel AbrahamE Offline
                                        Emmanuel Abraham
                                        wrote on last edited by
                                        #105

                                        @bart59 Can you post full circuit diagram for the modified code you made?

                                        1 Reply Last reply
                                        0
                                        • Paolo RendanoP Offline
                                          Paolo RendanoP Offline
                                          Paolo Rendano
                                          wrote on last edited by
                                          #106

                                          I made some improvements on this sketch. Please review them here: https://github.com/mysensors/MySensors/pull/1540

                                          with these changes you will have:
                                          1 - factory reset
                                          2 - automatic home assistant entities creation
                                          3 - counter correction from home assistant using service notify.mysensors
                                          4 - fixed counter automatically incremented by 1 at each device restart (due to arduino library interrupt bug)
                                          5- other tiny improvements

                                          1 Reply Last reply
                                          0
                                          Reply
                                          • Reply as topic
                                          Log in to reply
                                          • Oldest to Newest
                                          • Newest to Oldest
                                          • Most Votes


                                          14

                                          Online

                                          11.7k

                                          Users

                                          11.2k

                                          Topics

                                          113.0k

                                          Posts


                                          Copyright 2019 TBD   |   Forum Guidelines   |   Privacy Policy   |   Terms of Service
                                          • Login

                                          • Don't have an account? Register

                                          • Login or register to search.
                                          • First post
                                            Last post
                                          0
                                          • MySensors
                                          • OpenHardware.io
                                          • Categories
                                          • Recent
                                          • Tags
                                          • Popular