风扇开启执行逻辑

执行流程

public static void businessExecutionWork(){//以下为业务逻辑部分System.out.println("1、根据电池包控制风扇服务执行 开始!");//1、获取电池包电压、电流、环境温度//获取电池包电压、电流、环境温度ObtainBatteryDataService obtainBatteryDataService = new ObtainBatteryDataServiceImpl();List<ObtainBatteryBean> sendObtainBatteryData= obtainBatteryDataService.obtainBatteryDataList(BATTERY_ID);//2、通过CAN总线发送 CAN信号到总控制系统CanChannelUtil canChannelUtil = new CanChannelUtil();canChannelUtil.sendObtainBattery(sendObtainBatteryData);System.out.println("2、通过CAN总线发送 CAN信号到总控制系统!");//3、总控制系统接收CAN信号MainCenterBussinessService mainCenterBussinessService = new MainCenterBussinessServiceImpl();List<ObtainBatteryBean> receiveObtainBatteryData= canChannelUtil.receiveObtainBattery();//4、对电池包电压、电流、环境温度监测System.out.println("4、对电池包电压、电流、环境温度监测!");boolean status = mainCenterBussinessService.checkBatterystatus(receiveObtainBatteryData);//5、根据电池包电压、电流、环境温度控制风扇System.out.println("5、根据电池包控制风扇服务执行!");if(status){//控制风扇打开 打开时间为1分钟!mainCenterBussinessService.fanHeatExchanger(true);}else{mainCenterBussinessService.fanHeatExchanger(false);}//6、根据电池包控制风扇服务执行 结束System.out.println("6、根据电池包控制风扇服务执行 结束!");}

监测风扇

public boolean checkBatterystatus(List<ObtainBatteryBean> obtainBatteryBeanList) {System.out.println("4.1、检测开始");if (obtainBatteryBeanList.size() == 0) {return false;}int i = 0;System.out.println("4.1、判断温度、电流、环境温度是否达到临界阀值");for (ObtainBatteryBean obtainBatteryBean : obtainBatteryBeanList) {if (obtainBatteryBean.getCurrent() > Constants.CURRENT) {i++;continue;}if (obtainBatteryBean.getTemperature() > Constants.TEMPERATURE) {i++;continue;}if (obtainBatteryBean.getVoltage() > Constants.VOLTAGE) {i++;continue;}}System.out.println("4.2、估算soc");if(i>obtainBatteryBeanList.size()/2){System.out.println("4.3、需要预警保护");return true;}System.out.println("4.3、不需要预警保护");return false;}

临界值配置 配置

/*** @desc: 临界值配置 配置* @author: langjf* @date: 2024/5/6*/
public class Constants {/*** 电流阈值*/public static final Double CURRENT = 10D;/*** 电压阈值*/public static final Double VOLTAGE = 220D;/***温度阀值*/public static final Double TEMPERATURE = 80D;/*** 扇热时间 60秒*/public static final int  HEAT_DISSIPATION_TIME = 60000;/*** 是否开启扇热*/public static AtomicInteger fanHeatExchanger = new AtomicInteger(0);/*** 监测周期 5秒*/public static final int MONITORING_CYCLE=5000;/*** 开启扇热*/public static void fanHeatStart(){fanHeatExchanger.addAndGet(1);System.out.println("开启扇热");}/*** 关闭扇热*/public static void fanHeatStop(){fanHeatExchanger.addAndGet(-1);System.out.println("关闭扇热");}/*** 查看开启状态* @return*/public static boolean getFanHeatStatus(){if(fanHeatExchanger.get()>0){System.out.println("当前开启状态为：开启");return true;}System.out.println("当前开启状态为：关闭");return false;}
}

发送CAN信号

/*** @desc:发送CAN信号* @author: langjf* @date: 2024/5/6*/
public class CanChannelUtil {List<ObtainBatteryBean> beanList=new ArrayList<>();/*** 发送CAN信号 实际信号值为0101 类型二进制数据流 此处为数据模拟 暂不做处理* @param beanList*/public void sendObtainBattery(List<ObtainBatteryBean> beanList){this.beanList=beanList;}/*** 接收CAN信号 实际信号值为0101 类型二进制数据流 此处为数据模拟 暂不做处理* @return*/public List<ObtainBatteryBean> receiveObtainBattery(){return beanList;}}

获取电池包的单体电压 电流 环境温度

/*** @desc: 获取电池包的单体电压 电流 环境温度* @author: langjf* @date: 2024/5/6*/
public class ObtainBatteryUtil {/*** 获取电池电流* @param batteryId* @return*/public static Double getCurrent(String batteryId){//system get current 模拟值Double current =Math.random()*100;return current;}/*** 获取电池电压* @param batteryId* @return*/public static Double getVoltage(String batteryId){//system get voltage 模拟值Double voltage =Math.random()*220;return voltage;}/*** 获取电池温度* @param batteryId* @return*/public static Double getTemperature(String batteryId){//system get temperature 模拟值Double temperature =Math.random()*100;return temperature;}/*** 获取电池包中所有电池编码集合 模拟值* @return*/public static List<String> getBatteryIdList(){//system get batteryIdList 模拟值List<String> batteryIdList =new ArrayList<>();while (batteryIdList.size()<=10){String code="设备"+Math.random()*100;if(!batteryIdList.contains(code)){batteryIdList.add(code);}}return batteryIdList;}}

电池数据封装

/*** @desc: 电池数据封装* @author: langjf* @date: 2024/5/6*/
@Data
public class ObtainBatteryBean {/*** 电池包ID*/private String batteryId;/*** 电流*/private Double current;/*** 电压*/private Double voltage;/*** 温度*/private Double temperature;
}

得到电池包含的数据 包括电流 电压 温度

/*** @desc: 得到电池包含的数据 包括电流 电压 温度* @author: langjf* @date: 2024/5/6*/
public class ObtainBatteryDataServiceImpl implements ObtainBatteryDataService {@Overridepublic ObtainBatteryBean obtainBatteryData(String batteryId) {ObtainBatteryBean obtainBatteryBean=new ObtainBatteryBean();obtainBatteryBean.setBatteryId(batteryId);obtainBatteryBean.setTemperature(ObtainBatteryUtil.getTemperature(batteryId));obtainBatteryBean.setCurrent(ObtainBatteryUtil.getCurrent(batteryId));obtainBatteryBean.setVoltage(ObtainBatteryUtil.getVoltage(batteryId));return obtainBatteryBean;}@Overridepublic List<ObtainBatteryBean> obtainBatteryDataList(String equipment) {List<String> batteryIdList=ObtainBatteryUtil.getBatteryIdList();List<ObtainBatteryBean> obtainBatteryBeanList=new ArrayList<>();batteryIdList.stream().forEach(batteryId -> {obtainBatteryBeanList.add(obtainBatteryData(batteryId));});return obtainBatteryBeanList;}}

执行

public class Main {/*** 设备ID*/private  static final String BATTERY_ID = "Battery";public static void main(String[] args) {try {while (true){//判断风扇是否开启System.out.println("判断风扇是否开启");Boolean fanHeatStatus = Constants.getFanHeatStatus();if(!fanHeatStatus){//未开启 执行电池包检测 业务逻辑businessExecutionWork();//判断是否开启fanHeatStatus = Constants.getFanHeatStatus();if(fanHeatStatus){//风扇开启后60秒后在进行 电池包检测System.out.println("风扇已开启 等待风扇开启60秒 进行扇热");Thread.sleep(Constants.HEAT_DISSIPATION_TIME);System.out.println("风扇已开启60秒，执行关闭风扇;");Constants.fanHeatStop();}}System.out.println("5秒后继续检测电池包");Thread.sleep(Constants.MONITORING_CYCLE);}} catch (InterruptedException e) {e.printStackTrace();System.out.println("异常中断!");}}
}

main方法执行效果