プールフィルコントロール

 def get_ph_reading（）：log（ "DEBUG"、 "get_ph_reading（）Started"）pool_pump_running =read_pool_sensor_status_values（ "pool_sensor_status"、 "led_status"、 "pump_run_led"）if pool_pump_running =="True ：if pooldb.temp_probe =="Yes"：pool_temp =float（read_pool_sensor_status_values（ "pool_sensor_status"、 "system_status"、 "pool_current_temp"））ph_value =float（get_ph.get_current_ph_with_temp（pool_temp））else：ph_value =float（get_ph （））debug（ "現在のpHは：{}"。format（ph_value））influx_data.write_data（ "pH"、ph_value）influx_data.write_data（ "pool_temp"、pool_temp）if pooldb.emoncms_server1 =="Yes"：res =requests.get（ "http：//" + pooldb.server1 + "/" + pooldb.emoncmspath1 + "/ input / post？＆node =" + str（pooldb.ph_node）+ "＆csv =" + ph_value + "＆apikey ="+ pooldb.apikey1）log（" DEBUG "、"現在のpH値{}をEmoncmsサーバー1に送信 ".format（ph_v alue））debug（ "{}の現在のpH値をEmoncmsサーバー1に送信" .format（ph_value））if pooldb.emoncms_server2 =="Yes"：res =requests.get（ "https：//" + pooldb.server2 + "/" + pooldb.emoncmspath2 + "/ input / post？＆node =" + str（pooldb.ph_node）+ "＆csv =" + ph_value + "＆apikey =" + pooldb.apikey2）log（ "DEBUG"、 "送信済み{}の現在のpH値をEmoncmsServer 2 ".format（ph_value））debug（"現在のpH値{}をEmoncmsServer2に送信 ".format（ph_value））update_pool_sensor_status_values（" pool_sensor_status "、" pool_chemicals "、" pool_current_ph "、ph_value）log（" DEBUG "、" get_ph_reading（）Completed "）else：log（" INFO "、"プールポンプが実行されていません。正確なpH測定値を取得できません！ "）debug（"プールポンプが実行されていません。正確なpH測定値を取得してください！ "）log（" DEBUG "、" get_ph_reading（）Completed "）

このコードは、次のような「get_ph.py」モジュールを呼び出します。

＃！/ usr / bin / python ##プールで使用する場合_control_master.py__author __ ='Richard J. Sears' VERSION ="V3.4（2018-03-16）"＃[メール保護]＃これはAtlas ScientificpHボードでのみ使用されます。importserialimportsysimporttimefromserial import SerialExceptionusbport ='/ dev / PH'try：ser =serial.Serial（usbport、38400、timeout =0）except serial.SerialException as e： print "Error、"、e sys.exit（0）def read_line（）：lsl =len（ '\ r'）line_buffer =[] while True：next_char =ser.read（1）if next_char ==''：break line_buffer.append（next_char）if（len（line_buffer）> =lsl and line_buffer [-lsl：] ==list（ '\ r'））：break return '' .join（line_buffer）def read_lines（）：lines =[ ] try：while True：line =read_line（）if not line：bre ak ser.flush_input（）lines.append（line）は、SerialExceptionを除く行をe：print "Error、"、e return Nonedef send_cmd（cmd）： "" "コマンドをアトラスセンサーに送信します。送信する前に、コマンドの最後にキャリッジリターンを追加します。 ：param cmd ：： return： "" "buf =cmd +" \ r "＃キャリッジリターンを追加try：ser.write（buf）return True（SerialException as eを除く）：print" Error、 "、e return Nonedef get_current_ph_with_temp（current_temp） ：＃send_cmd（ "RESPONSE、0"）send_cmd（ "C、0"）send_cmd（ "T、％d"％current_temp）send_cmd（ "R"）time.sleep（1.3）lines =read_line（）return linesdef get_current_ph_no_temp（ ）：＃send_cmd（ "RESPONSE、0"）send_cmd（ "C、0"）send_cmd（ "R"）time.sleep（1.3）lines =read_line（）return linesdef main（）：＃send_cmd（ "RESPONSE、0" ）send_cmd（ "C、0"）send_cmd（ "R"）time.sleep（1.3）lines =read_lines（）print（ "温度校正は実行されません："）for i in range（len（lines））：print lines [ i] if __name__ =='__ main __'：main（）

 def pool_pump_running_chemical（）：pool_pump_running_chemical =GPIO.input（pool_pump_running_pin）if pool_pump_running_chemical ==False：debug（ "Pool Pump Running via Chemical Sensor Chamber：TRUE-PUMP IS RUNNING"）else：debug（ 「化学センサーチャンバーを介して作動するプールポンプ：FALSE-ポンプがオフです」）

 {digitalWrite（ETAPE_POWER、HIGH）; // eTapeプールの電源をオンにします。resistance=analogRead（ETAPE）; //エタペ抵抗を読み取りますdigitalWrite（ETAPE_POWER、LOW）; // eTapeへの電源をオフにしますtake_battery_reading（）; //バッテリーの読み取りを行いますpower_spi_enable（）; rf12_sleep（RF12_WAKEUP）; rf12_sendNow（0、＆pool、sizeof pool）; rf12_sendWait（2）; rf12_sleep（RF12_SLEEP）; power_spi_disable（）; if（debug）{flash_led（50）; } //それだけです-次回まで待ちます：）sleep_until_next_reading（）; } 

 UPPER_Float =digitalRead（17）; LOWER_Float =digitalRead（3）; if（UPPER_Float ==LOW）{UPPER_Float_Position ="Closed"; } else {UPPER_Float_Position ="Open"; } if（LOWER_Float ==LOW）{LOWER_Float_Position ="Closed"; } else {LOWER_Float_Position ="Open"; } if（（UPPER_Float ==LOW）&&（LOWER_Float ==LOW））{pool_level.level =2; //両方が閉じている=プールがいっぱいです} else if（（UPPER_Float ==HIGH）&&（LOWER_Float ==LOW））{pool_level.level =1; //下部が閉じ、上部が開いている=プールMIDWAY} else {pool_level.level =0; //両方のフロートが開いている=プールLOW水を追加} 

 get_pool_level_value =read_emoncms_database（ "data"、pooldb.pool_level_table）

 if get_pool_level_value ==0：get_pool_level ="LOW" pool_fill_valve（ "OPEN"）

 def acid_level（）：acid_level_ok =GPIO.input（acid_level_sensor_pin）if acid_level_ok ==True：

 {％if system_error_led =="True"％}  {％elif system_run_led ==" True "％}  {％else％}  { ％endif％} 

 def get_ph_reading（）：log（ "DEBUG"、 "get_ph_reading（）Started"）pool_pump_running =read_pool_sensor_status_values（ "pool_sensor_status"、 "led_status"、 "pump_run_led"）if pool_pump_running =="True ：if pooldb.temp_probe =="Yes"：pool_temp =float（read_pool_sensor_status_values（ "pool_sensor_status"、 "system_status"、 "pool_current_temp"））ph_value =float（get_ph.get_current_ph_with_temp（pool_temp））else：ph_value =float（get_ph （））debug（ "現在のpHは：{}"。format（ph_value））influx_data.write_data（ "pH"、ph_value）influx_data.write_data（ "pool_temp"、pool_temp）if pooldb.emoncms_server1 =="Yes"：res =requests.get（ "http：//" + pooldb.server1 + "/" + pooldb.emoncmspath1 + "/ input / post？＆node =" + str（pooldb.ph_node）+ "＆csv =" + ph_value + "＆apikey ="+ pooldb.apikey1）log（" DEBUG "、"現在のpH値{}をEmoncmsサーバー1に送信 ".format（ph_v alue））debug（ "{}の現在のpH値をEmoncmsサーバー1に送信" .format（ph_value））if pooldb.emoncms_server2 =="Yes"：res =requests.get（ "https：//" + pooldb.server2 + "/" + pooldb.emoncmspath2 + "/ input / post？＆node =" + str（pooldb.ph_node）+ "＆csv =" + ph_value + "＆apikey =" + pooldb.apikey2）log（ "DEBUG"、 "送信済み{}の現在のpH値をEmoncmsServer 2 ".format（ph_value））debug（"現在のpH値{}をEmoncmsServer2に送信 ".format（ph_value））update_pool_sensor_status_values（" pool_sensor_status "、" pool_chemicals "、" pool_current_ph "、ph_value）log（" DEBUG "、" get_ph_reading（）Completed "）else：log（" INFO "、"プールポンプが実行されていません。正確なpH測定値を取得できません！ "）debug（"プールポンプが実行されていません。正確なpH測定値を取得してください！ "）log（" DEBUG "、" get_ph_reading（）Completed "）

 import syssys.path.append（ '../'）from influxdb import InfluxDBClientimport pooldbdef write_data（measurement、value）：client =InfluxDBClient（pooldb.influx_host、pooldb.influx_port、pooldb.influx_user、 pooldb.influx_password、pooldb.influx_dbname）json_body =[{"測定"：測定、 "フィールド"：{"値"：値}}] client.write_points（json_body）