Merge branch 'jkbms_ble' into master

CHANGELOG.md

@@ -15,6 +15,7 @@
 * Added: Choose how battery temperature is assembled (mean temp 1 & 2, only temp 1 or only temp 2) by @mr-manuel
 * Added: Config file by @ppuetsch
 * Added: Create empty `config.ini` for easier user usage by @mr-manuel
+* Added: Cronjob to restart Bluetooth service every 12 hours by @mr-manuel
 * Added: Daly BMS - Read capacity https://github.com/Louisvdw/dbus-serialbattery/pull/594 by @transistorgit
 * Added: Daly BMS - Read production date and build unique identifier by @transistorgit
 * Added: Daly BMS - Set SoC by @transistorgit
@@ -24,8 +25,18 @@
 * Added: Fix for Venus OS >= v3.00~14 showing unused items https://github.com/Louisvdw/dbus-serialbattery/issues/469 by @mr-manuel
 * Added: HighInternalTemperature alarm (MOSFET) for JKBMS by @mr-manuel
 * Added: Improved maintainability (flake8, black lint), introduced code checks and automate release build https://github.com/Louisvdw/dbus-serialbattery/pull/386 by @ppuetsch
+* Added: Install needed Bluetooth components automatically after a Venus OS upgrade by @mr-manuel
 * Added: JKBMS - MOS temperature https://github.com/Louisvdw/dbus-serialbattery/pull/440 by @baphomett
 * Added: JKBMS - Uniqie identifier and show "User Private Data" field that can be set in the JKBMS App to identify the BMS in a multi battery environment by @mr-manuel
+* Added: JKBMS BLE - Balancing switch status by @mr-manuel
+* Added: JKBMS BLE - Capacity by @mr-manuel
+* Added: JKBMS BLE - Cell imbalance alert by @mr-manuel
+* Added: JKBMS BLE - Charging switch status by @mr-manuel
+* Added: JKBMS BLE - Discharging switch status by @mr-manuel
+* Added: JKBMS BLE - MOS temperature by @mr-manuel
+* Added: JKBMS BLE - Show if balancing is active and which cells are balancing by @mr-manuel
+* Added: JKBMS BLE - Show serial number and "User Private Data" field that can be set in the JKBMS App to identify the BMS in a multi battery environment by @mr-manuel
+* Added: JKBMS BLE driver by @baranator
 * Added: Possibility to add `config.ini` to the root of a USB flash drive on install via the USB method by @mr-manuel
 * Added: Post install notes by @mr-manuel
 * Added: Read charge/discharge limits from JKBMS by @mr-manuel
@@ -55,6 +66,7 @@
 * Changed: Default FLOAT_CELL_VOLTAGE from 3.350 V to 3.375 V by @mr-manuel
 * Changed: Default LINEAR_LIMITATION_ENABLE from False to True by @mr-manuel
 * Changed: Disabled ANT BMS by default https://github.com/Louisvdw/dbus-serialbattery/issues/479 by @mr-manuel
+* Changed: Driver can now also start without serial adapter attached for Bluetooth BMS by @seidler2547
 * Changed: Fix for https://github.com/Louisvdw/dbus-serialbattery/issues/239 by @mr-manuel
 * Changed: Fix for https://github.com/Louisvdw/dbus-serialbattery/issues/311 by @mr-manuel
 * Changed: Fix for https://github.com/Louisvdw/dbus-serialbattery/issues/351 by @mr-manuel
@@ -68,6 +80,7 @@
 * Changed: Improved JBD BMS soc calculation https://github.com/Louisvdw/dbus-serialbattery/pull/439 by @aaronreek
 * Changed: Logging to get relevant data by @mr-manuel
 * Changed: Many code improvements https://github.com/Louisvdw/dbus-serialbattery/pull/393 by @ppuetsch
+* Changed: Moved Bluetooth part to `reinstall-local.sh` by @mr-manuel
 * Changed: Moved BMS scripts to subfolder by @mr-manuel
 * Changed: Removed all wildcard imports and fixed black lint errors by @mr-manuel
 * Changed: Removed cell voltage penalty. Replaced by automatic voltage calculation. Max voltage is kept until cells are balanced and reset when cells are inbalanced by @mr-manuel
@@ -78,3 +91,4 @@
 * Changed: Temperature alarm changed in order to not trigger all in the same condition for JKBMS by @mr-manuel
 * Changed: Time-To-Soc repetition from cycles to seconds. Minimum value is every 5 seconds. This prevents CPU overload and ensures system stability. Renamed `TIME_TO_SOC_LOOP_CYCLES` to `TIME_TO_SOC_RECALCULATE_EVERY` by @mr-manuel
 * Changed: Time-To-Soc string from `days, HR:MN:SC` to `<days>d <hours>h <minutes>m <seconds>s` (same as Time-To-Go) by @mr-manuel
+* Changed: Uninstall also installed Bluetooth modules on uninstall by @mr-manuel

etc/dbus-serialbattery/bms/jkbms_ble.py

@@ -0,0 +1,255 @@
+# -*- coding: utf-8 -*-
+from battery import Battery, Cell
+from utils import logger
+from bms.jkbms_brn import Jkbms_Brn
+from bleak import BleakScanner, BleakError
+import asyncio
+import time
+import os
+
+
+class Jkbms_Ble(Battery):
+    BATTERYTYPE = "Jkbms_Ble"
+    resetting = False
+
+    def __init__(self, port, baud, address):
+        super(Jkbms_Ble, self).__init__(address.replace(":", "").lower(), baud, address)
+        self.type = self.BATTERYTYPE
+        self.jk = Jkbms_Brn(address)
+
+        logger.info("Init of Jkbms_Ble at " + address)
+
+    def connection_name(self) -> str:
+        return "BLE " + self.address
+
+    def test_connection(self):
+        # call a function that will connect to the battery, send a command and retrieve the result.
+        # The result or call should be unique to this BMS. Battery name or version, etc.
+        # Return True if success, False for failure
+
+        # check if device with given mac is found, otherwise abort
+
+        logger.info("Test of Jkbms_Ble at " + self.jk.address)
+        try:
+            loop = asyncio.get_event_loop()
+            t = loop.create_task(BleakScanner.discover())
+            devices = loop.run_until_complete(t)
+        except BleakError as err:
+            logger.error(str(err))
+            return False
+        except Exception as err:
+            logger.error(f"Unexpected {err=}, {type(err)=}")
+            return False
+
+        found = False
+        for d in devices:
+            if d.address == self.jk.address:
+                found = True
+        if not found:
+            logger.error("No Jkbms_Ble found at " + self.jk.address)
+            return False
+
+        """
+        # before indipended service, has to be checked
+
+        logger.info("test of jkbmsble")
+        tries = 0
+        while True:
+            try:
+                loop = asyncio.get_event_loop()
+                t = loop.create_task(
+                    BleakScanner.find_device_by_address(self.jk.address)
+                )
+                device = loop.run_until_complete(t)
+
+                if device is None:
+                    logger.info("jkbmsble not found")
+                    if tries > 2:
+                        return False
+                else:
+                    # device found, exit loop and continue test
+                    break
+            except BleakError as e:
+                if tries > 2:
+                    return False
+                # recover from error if tries left
+                logger.error(str(e))
+                self.reset_bluetooth()
+            tries += 1
+        """
+
+        # device was found, presumeably a jkbms so start scraping
+        self.jk.start_scraping()
+        tries = 1
+
+        while self.jk.get_status() is None and tries < 20:
+            time.sleep(0.5)
+            tries += 1
+
+        # load initial data, from here on get_status has valid values to be served to the dbus
+        status = self.jk.get_status()
+        if status is None:
+            self.jk.stop_scraping()
+            return False
+
+        if not status["device_info"]["vendor_id"].startswith(("JK-", "JK_")):
+            self.jk.stop_scraping()
+            return False
+
+        logger.info("Jkbms_Ble found!")
+
+        # get first data to show in startup log
+        self.get_settings()
+        self.refresh_data()
+
+        return True
+
+    def get_settings(self):
+        # After successful  connection get_settings will be call to set up the battery.
+        # Set the current limits, populate cell count, etc
+        # Return True if success, False for failure
+        st = self.jk.get_status()["settings"]
+        self.cell_count = st["cell_count"]
+        self.max_battery_charge_current = st["max_charge_current"]
+        self.max_battery_discharge_current = st["max_discharge_current"]
+        self.max_battery_voltage = st["cell_ovp"] * self.cell_count
+        self.min_battery_voltage = st["cell_uvp"] * self.cell_count
+
+        # "User Private Data" field in APP
+        tmp = self.jk.get_status()["device_info"]["production"]
+        self.custom_field = tmp if tmp != "Input Us" else None
+
+        tmp = self.jk.get_status()["device_info"]["manufacturing_date"]
+        self.production = "20" + tmp if tmp and tmp != "" else None
+
+        self.unique_identifier = self.jk.get_status()["device_info"]["serial_number"]
+
+        for c in range(self.cell_count):
+            self.cells.append(Cell(False))
+
+        self.capacity = self.jk.get_status()["cell_info"]["capacity_nominal"]
+
+        self.hardware_version = (
+            "JKBMS "
+            + self.jk.get_status()["device_info"]["hw_rev"]
+            + " "
+            + str(self.cell_count)
+            + " cells"
+            + (" (" + self.production + ")" if self.production else "")
+        )
+        logger.info("BAT: " + self.hardware_version)
+        return True
+
+    def refresh_data(self):
+        # call all functions that will refresh the battery data.
+        # This will be called for every iteration (1 second)
+        # Return True if success, False for failure
+
+        # result = self.read_soc_data()
+        # TODO: check for errors
+        st = self.jk.get_status()
+        if st is None:
+            return False
+        if time.time() - st["last_update"] > 30:
+            # if data not updated for more than 30s, sth is wrong, then fail
+            logger.info("Jkbms_Ble: Bluetooth died")
+
+            # if the thread is still alive but data too old there is sth
+            # wrong with the bt-connection; restart whole stack
+            if not self.resetting:
+                self.reset_bluetooth()
+                self.jk.start_scraping()
+                time.sleep(2)
+
+            return False
+        else:
+            self.resetting = False
+
+        for c in range(self.cell_count):
+            self.cells[c].voltage = st["cell_info"]["voltages"][c]
+
+        self.to_temp(0, st["cell_info"]["temperature_mos"])
+        self.to_temp(1, st["cell_info"]["temperature_sensor_1"])
+        self.to_temp(2, st["cell_info"]["temperature_sensor_2"])
+        self.current = round(st["cell_info"]["current"], 1)
+        self.voltage = round(st["cell_info"]["total_voltage"], 2)
+
+        self.soc = st["cell_info"]["battery_soc"]
+        self.cycles = st["cell_info"]["cycle_count"]
+
+        self.charge_fet = st["settings"]["charging_switch"]
+        self.discharge_fet = st["settings"]["discharging_switch"]
+        self.balance_fet = st["settings"]["balancing_switch"]
+
+        self.balancing = False if st["cell_info"]["balancing_action"] == 0.000 else True
+        self.balancing_current = (
+            st["cell_info"]["balancing_current"]
+            if st["cell_info"]["balancing_current"] < 32768
+            else (65536 / 1000 - st["cell_info"]["balancing_current"]) * -1
+        )
+        self.balancing_action = st["cell_info"]["balancing_action"]
+
+        # show wich cells are balancing
+        for c in range(self.cell_count):
+            if self.balancing and (
+                st["cell_info"]["min_voltage_cell"] == c
+                or st["cell_info"]["max_voltage_cell"] == c
+            ):
+                self.cells[c].balance = True
+            else:
+                self.cells[c].balance = False
+
+        # protection bits
+        # self.protection.soc_low = 2 if status["cell_info"]["battery_soc"] < 10.0 else 0
+
+        # trigger cell imbalance warning when delta is to great
+        if st["cell_info"]["delta_cell_voltage"] > min(
+            st["settings"]["cell_ovp"] * 0.05, 0.200
+        ):
+            self.protection.cell_imbalance = 2
+        elif st["cell_info"]["delta_cell_voltage"] > min(
+            st["settings"]["cell_ovp"] * 0.03, 0.120
+        ):
+            self.protection.cell_imbalance = 1
+        else:
+            self.protection.cell_imbalance = 0
+
+        self.protection.voltage_high = 2 if st["warnings"]["cell_overvoltage"] else 0
+        self.protection.voltage_low = 2 if st["warnings"]["cell_undervoltage"] else 0
+
+        self.protection.current_over = (
+            2
+            if (
+                st["warnings"]["charge_overcurrent"]
+                or st["warnings"]["discharge_overcurrent"]
+            )
+            else 0
+        )
+        self.protection.set_IC_inspection = (
+            2 if st["cell_info"]["temperature_mos"] > 80 else 0
+        )
+        self.protection.temp_high_charge = 2 if st["warnings"]["charge_overtemp"] else 0
+        self.protection.temp_low_charge = 2 if st["warnings"]["charge_undertemp"] else 0
+        self.protection.temp_high_discharge = (
+            2 if st["warnings"]["discharge_overtemp"] else 0
+        )
+        return True
+
+    def reset_bluetooth(self):
+        logger.info("Reset of Bluetooth triggered")
+        self.resetting = True
+        # if self.jk.is_running():
+        # self.jk.stop_scraping()
+        logger.info("Scraping ended, issuing sys-commands")
+        # process kill is needed, since the service/bluetooth driver is probably freezed
+        os.system('pkill -f "bluetoothd"')
+        # stop will not work, if service/bluetooth driver is stuck
+        # os.system("/etc/init.d/bluetooth stop")
+        time.sleep(2)
+        os.system("rfkill block bluetooth")
+        os.system("rfkill unblock bluetooth")
+        os.system("/etc/init.d/bluetooth start")
+        logger.info("Bluetooth should have been restarted")
+
+    def get_balancing(self):
+        return 1 if self.balancing else 0