package com.jsowell.netty.handler; import com.jsowell.common.core.domain.ykc.YKCDataProtocol; import com.jsowell.common.core.domain.ykc.YKCFrameTypeCode; import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum; import com.jsowell.common.enums.ykc.OrderStatusEnum; import com.jsowell.common.util.BytesUtil; import com.jsowell.common.util.StringUtils; import com.jsowell.common.util.YKCUtils; import com.jsowell.netty.factory.YKCOperateFactory; import com.jsowell.pile.domain.OrderBasicInfo; import com.jsowell.pile.domain.ThirdPartyStationRelation; import com.jsowell.pile.service.IOrderBasicInfoService; import com.jsowell.pile.service.IThirdPartySettingInfoService; import com.jsowell.pile.service.IThirdPartyStationRelationService; import com.jsowell.pile.vo.base.ThirdPartyStationRelationVO; import com.jsowell.thirdparty.lianlian.service.LianLianService; import com.jsowell.thirdparty.yongchengboche.service.YCBCService; import io.netty.channel.Channel; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.Date; import java.util.Objects; /** * 充电结束Handler * 0x19 * GBT-27930 充电桩与 BMS 充电结束阶段报文 * @author JS-ZZA * @date 2022/9/19 13:27 */ @Slf4j @Component public class ChargeEndHandler extends AbstractHandler{ private final String type = YKCUtils.frameType2Str(YKCFrameTypeCode.CHARGE_END_CODE.getBytes()); @Autowired private IOrderBasicInfoService orderBasicInfoService; @Autowired private IThirdPartySettingInfoService thirdPartySettingInfoService; @Autowired private LianLianService lianLianService; @Autowired private YCBCService ycbcService; @Autowired private IThirdPartyStationRelationService thirdPartyStationRelationService; @Override public void afterPropertiesSet() throws Exception { YKCOperateFactory.register(type, this); } @Override public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, Channel channel) { // log.info("[===执行充电结束逻辑===] param:{}, channel:{}", JSONObject.toJSONString(ykcDataProtocol), channel.toString()); // 消息体 byte[] msgBody = ykcDataProtocol.getMsgBody(); int startIndex = 0; int length = 16; // 交易流水号 byte[] serialNumByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String transactionCode = BytesUtil.bcd2Str(serialNumByteArr); // 桩编码 startIndex += length; length = 7; byte[] pileSnByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String pileSn = BytesUtil.bcd2Str(pileSnByteArr); // 保存时间 saveLastTime(pileSn, channel); // 枪号 startIndex += length; length = 1; byte[] connectorCodeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String connectorCode = BytesUtil.bcd2Str(connectorCodeByteArr); // BMS中止荷电状态 SOC 1%/位， 0%偏移量； 数据范围： 0~100% startIndex += length; byte[] BMSStopChargingSOC = BytesUtil.copyBytes(msgBody, startIndex, length); String stopSoc = BytesUtil.binary(BMSStopChargingSOC, 10); // BMS 动力蓄电池单体最低电压 0.01 V/位， 0 V 偏移量；数据范围： 0 ~24 V startIndex += length; length = 2; byte[] BMSBatteryMinVoltageByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); // BMS 动力蓄电池单体最高电压 0.01 V/位， 0 V 偏移量；数据范围： 0 ~24 V startIndex += length; byte[] BMSBatteryMaxVoltageByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); // BMS 动力蓄电池最低温度 1ºC/位， -50 ºC 偏移量；数据范围： -50 ºC ~+200 ºC startIndex += length; length = 1; byte[] BMSBatteryMinTemperatureByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); // BMS 动力蓄电池最高温度 1ºC/位， -50 ºC 偏移量；数据范围： -50 ºC ~+200 ºC startIndex += length; byte[] BMSBatteryMaxTemperatureByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); // 电桩累计充电时间 1 min/位， 0 min 偏移量； 数据范围： 0~600 min startIndex += length; length = 2; byte[] pileSumChargingTimeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); // 电桩输出能量 0.1 kWh/位， 0 kWh 偏移量； 数据范围： 0~1000 kWh startIndex += length; byte[] pileOutputEnergyByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); // 电桩充电机编号 充电机编号， 1/位， 1偏移量 ，数据范围 ： 0 ～ 0xFFFFFFFF startIndex += length; length = 4; byte[] pileChargedCodeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); // 查询订单，改为待结算 将结束soc传入 // OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByOrderCode(transactionCode); OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode); if (Objects.nonNull(orderInfo)) { if (StringUtils.equals(OrderStatusEnum.IN_THE_CHARGING.getValue(), orderInfo.getOrderStatus())) { orderInfo.setOrderStatus(OrderStatusEnum.STAY_SETTLEMENT.getValue()); } orderInfo.setEndSOC(stopSoc); if (orderInfo.getChargeEndTime() == null) { orderInfo.setChargeEndTime(new Date()); // 结束充电时间 } orderBasicInfoService.updateOrderBasicInfo(orderInfo); try { // 查询该站点是否已对接互联互通平台，如果对接则发送充电结束 // 通过站点id查询相关配置信息 ThirdPartyStationRelation relation = new ThirdPartyStationRelation(); relation.setStationId(Long.parseLong(orderInfo.getStationId())); ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(relation); // ThirdPartySettingInfo info = thirdPartySettingInfoService.getInfoByStationId(Long.parseLong(orderInfo.getStationId())); if (Objects.isNull(relationInfo)) { return null; } // 联联平台 if (StringUtils.equals(ThirdPlatformTypeEnum.LIAN_LIAN_PLATFORM.getCode(), relationInfo.getThirdPartyType())) { // 推送停止充电结果 lianLianService.pushStopChargeResult(orderInfo.getOrderCode()); } // 甬城泊车平台 if (StringUtils.equals(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getCode(), relationInfo.getThirdPartyType())) { ycbcService.pushStopChargeResult(orderInfo.getOrderCode()); } } catch (Exception e) { log.error("联联平台推送停止充电结果异常", e); } } return null; } }