package com.zy.acs.charge.impl; import com.ghgande.j2mod.modbus.ModbusException; import com.ghgande.j2mod.modbus.facade.ModbusTCPMaster; import com.ghgande.j2mod.modbus.procimg.Register; import com.ghgande.j2mod.modbus.procimg.SimpleRegister; import com.ghgande.j2mod.modbus.util.BitVector; import com.zy.acs.charge.ChargeCoreService; import com.zy.acs.charge.constant.AiPowerChargeCoilEnum; import com.zy.acs.charge.constant.AiPowerChargeRegisterEnum; import com.zy.acs.charge.constant.ChargerType; import com.zy.acs.charge.model.ChargerStatus; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; /** * 爱普拉AGV锂电智能充电机调度 */ @Service("aiPowerChargeService") @Slf4j public class AiPowerChargeServiceImpl implements ChargeCoreService { @Override public ChargerType supportedType() { return ChargerType.Modbus; } /** * 开始充电 * * @param client * @return */ @Override public boolean startCharging(ModbusTCPMaster client) { // AGV车报告到位 -> true try { if (!client.isConnected()) { client.connect(); } return client.writeCoil(AiPowerChargeCoilEnum.AGV_REPORTED_IN_POSITION.getAddr(), true); } catch (Exception e) { log.info("写入开始充电指令报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return false; } /** * 停止充电 * * @param client * @return */ @Override public boolean stopCharging(ModbusTCPMaster client) { try { if (!client.isConnected()) { client.connect(); } return client.writeCoil(AiPowerChargeCoilEnum.AGV_REPORTED_IN_POSITION.getAddr(), false); } catch (Exception e) { log.info("写入停止充电指令报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return false; } /** * 在线正继电器状态(前进到位) * * @param client * @return */ @Override public boolean checkForwardRelayOnline(ModbusTCPMaster client) { try { if (!client.isConnected()) { client.connect(); } return client.readCoils(AiPowerChargeCoilEnum.FORWARD_RELAY_ONLINE.getAddr(), 1).getBit(0); } catch (Exception e) { log.info("读取在线正继电器状态报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return false; } /** * 离线正继电器状态(后退到位) * * @param client * @return */ @Override public boolean checkBackwardRelayOffline(ModbusTCPMaster client) { try { if (!client.isConnected()) { client.connect(); } return client.readCoils(AiPowerChargeCoilEnum.BACKWARD_RELAY_OFFLINE.getAddr(), 1).getBit(0); } catch (Exception e) { log.info("读取离线正继电器状态报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return false; } /** * 获取充电机充电电压 * * @param client * @return */ @Override public double getVoltage(ModbusTCPMaster client) { try { if (!client.isConnected()) { client.connect(); } return client.readMultipleRegisters(AiPowerChargeRegisterEnum.CHARGE_VOLTAGE.getAddr(), 1)[0].getValue() * AiPowerChargeRegisterEnum.CHARGE_CURRENT.getRaw(); } catch (Exception e) { log.info("读取充电电压报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return 0; } /** * 获取充电机充电电流 * * @param client * @return */ @Override public double getCurrent(ModbusTCPMaster client) { try { if (!client.isConnected()) { client.connect(); } return client.readMultipleRegisters(AiPowerChargeRegisterEnum.CHARGE_CURRENT.getAddr(), 1)[0].getValue() * AiPowerChargeRegisterEnum.CHARGE_CURRENT.getRaw(); } catch (Exception e) { log.info("读取充电电流报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return 0; } /** * 获取充电机充电模式 * * @param client * @return */ @Override public int getChargeMode(ModbusTCPMaster client) { try { if (!client.isConnected()) { client.connect(); } return client.readMultipleRegisters(AiPowerChargeRegisterEnum.CHARGE_MODE.getAddr(), 1)[0].getValue(); } catch (Exception e) { e.printStackTrace(); log.info("读取充电模式报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return -1; } /** * 获取充电机编号 * * @param client * @return */ @Override public int getChargeId(ModbusTCPMaster client) { try { if (!client.isConnected()) { client.connect(); } return client.readMultipleRegisters(AiPowerChargeRegisterEnum.CHARGER_ID.getAddr(), 1)[0].getValue(); } catch (Exception e) { e.printStackTrace(); log.info("读取充电机编号报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return -1; } /** * 获取充电机状态 * * @param client * @return */ @Override public ChargerStatus getStatus(ModbusTCPMaster client) { ChargerStatus status = new ChargerStatus(); // ---------- 批量读取线圈（地址100~115共16个） ---------- BitVector coils = null; try { if (!client.isConnected()) { client.connect(); } coils = client.readCoils(AiPowerChargeCoilEnum.WORK_STATUS.getAddr(), AiPowerChargeCoilEnum.values().length); for (int i = 0; i < coils.size(); i++) { switch (i) { case 0: status.setWorking(coils.getBit(i)); break; case 1: status.setOverheat(coils.getBit(i)); break; case 2: status.setFault(coils.getBit(i)); break; case 3: status.setCvMode(coils.getBit(i)); break; case 4: status.setBatteryConnected(coils.getBit(i)); break; case 5: status.setFanAbnormal(coils.getBit(i)); break; case 6: status.setPlateOverheat(coils.getBit(i)); break; case 7: status.setBrushPressed(coils.getBit(i)); break; case 8: status.setAgvReportedInPosition(coils.getBit(i)); break; case 9: status.setChargerConfirmedAgvReady(coils.getBit(i)); break; case 10: status.setForwardRelayOnline(coils.getBit(i)); break; case 11: status.setBackwardRelayOffline(coils.getBit(i)); break; case 12: status.setBmsChargeEnable(coils.getBit(i)); break; case 13: status.setCommRs485Success(!coils.getBit(i)); break; case 14: status.setCommCanSuccess(!coils.getBit(i)); break; case 15: status.setCommBmsSuccess(!coils.getBit(i)); break; default: break; } } // ---------- 批量读取保持寄存器（地址100~116共17个） ---------- Register[] registers = client.readMultipleRegisters(AiPowerChargeRegisterEnum.CHARGE_VOLTAGE.getAddr(), AiPowerChargeRegisterEnum.values().length); for (int i = 0; i < registers.length; i++) { switch (i) { case 0: status.setVoltage(registers[i].getValue() * AiPowerChargeRegisterEnum.CHARGE_VOLTAGE.getRaw()); break; case 1: status.setCurrent(registers[i].getValue() * AiPowerChargeRegisterEnum.CHARGE_CURRENT.getRaw()); break; case 2: status.setChargingTime(registers[i].getValue()); break; case 3: status.setCapacity(registers[i].getValue() * AiPowerChargeRegisterEnum.CHARGE_CAPACITY.getRaw()); break; case 4: status.setEnergy(registers[i].getValue() * AiPowerChargeRegisterEnum.CHARGE_ENERGY.getRaw()); break; case 5: status.setCellMaxVoltage(registers[i].getValue()); break; case 6: status.setCellMinVoltage(registers[i].getValue()); break; case 7: status.setPackVoltage(registers[i].getValue() * AiPowerChargeRegisterEnum.BMS_PACK_VOLTAGE.getRaw()); break; case 8: status.setVoltageDemand(registers[i].getValue() * AiPowerChargeRegisterEnum.BMS_VOLTAGE_DEMAND.getRaw()); break; case 9: status.setCurrentDemand(registers[i].getValue() * AiPowerChargeRegisterEnum.BMS_CURRENT_DEMAND.getRaw()); break; case 10: status.setTemperature(registers[i].getValue()); break; case 11: status.setSoc(registers[i].getValue() * AiPowerChargeRegisterEnum.BMS_SOC.getRaw()); break; case 12: status.setEndFlag(registers[i].getValue()); break; case 13: status.setChargerId(registers[i].getValue()); break; case 14: status.setFaultCode(registers[i].getValue()); break; case 15: status.setChargeMode(registers[i].getValue()); break; case 16: status.setScheduleFlag(registers[i].getValue()); break; default: break; } } } catch (Exception e) { log.info("批量读取线圈报错:{} ", e.getMessage()); log.info("批量读取保持寄存器报错:{} ", e.getMessage()); }finally { //client.disconnect(); } return status; } /** * 清除故障 * * @param client * @return */ @Override public boolean clearFault(ModbusTCPMaster client) { try { client.writeSingleRegister(AiPowerChargeRegisterEnum.SCHEDULE_FLAG.getAddr(), new SimpleRegister(1)); } catch (ModbusException e) { log.error("充电器清除故障失败......"); } return true; } /** * 完成退回 * * @param client * @return */ @Override public boolean finishRetract(ModbusTCPMaster client) { try { client.writeSingleRegister(AiPowerChargeRegisterEnum.SCHEDULE_FLAG.getAddr(), new SimpleRegister(2)); } catch (ModbusException e) { log.error("充电器完成退回失败......"); } return true; } /** * 恢复待机 * * @param client * @return */ @Override public boolean restoreStandby(ModbusTCPMaster client) { try { client.writeSingleRegister(AiPowerChargeRegisterEnum.SCHEDULE_FLAG.getAddr(), new SimpleRegister(3)); } catch (ModbusException e) { log.error("充电器恢复待机失败......"); } return true; } }