from ctypes import *
from collections import OrderedDict
from dialin.dg.dialysate_generator import DG
from dialin.ui import crc
from time import sleep
import struct

if __name__ == "__main__":
    # Create an instance of the DG Class
    dg = DG(log_level='DEBUG')

    if dg.cmd_log_in_to_dg() == 0:
        exit(1)
    sleep(2)
    cal = dg.calibration_record

    f = open("DG_Calibration.log", "w")

    #print(cal.DG_CALIBRATION_RECORD)
    #exit(0)

    status = False

    cal.hd_calibration_record['pumps']['concentrate_1']['step_speed_2_flow_ratio'][1] = 34.2
    cal.hd_calibration_record['pumps']['drain']['cal_time'][1] = 96321
    cal.hd_calibration_record['pumps']['ro']['gain_3_ratio'][1] = 45.69
    cal.hd_calibration_record['volumes']['drain_line']['volume'][1] = 125.8
    cal.hd_calibration_record['volumes']['drain_line']['crc'][1] = 78
    cal.hd_calibration_record['volumes']['pre_ro_purge']['volume'][1] = 125.8
    cal.hd_calibration_record['volumes']['reservoir_1']['max_residual_fluid'][1] = 85.36
    cal.hd_calibration_record['bicarb_concentrates']['bicarb_conc_3']['reserved_space'][1] = 85.36
    cal.hd_calibration_record['fans']['fan_2']['reserved_space_2'][1] = 456.25

    print(cal.hd_calibration_record)

    try:
        if status:
            dara = []
            cal.get_hd_calibration_record()
            while True:
                sleep(0.2)
                #print(cal.current_message, cal.total_messages, cal.cal_data)

                if cal.cal_data != 0:
                    f.write(str(cal.cal_data) + '\r')
                    dara.append(cal.cal_data)

                    if cal.current_message == cal.total_messages:
                        f.close()
                        break
        else:
            cal.set_hd_calibration_record()

        print(cal.hd_calibration_record)

    except KeyboardInterrupt:
        f.close()