package com.jsowell.netty.handler; import com.alibaba.fastjson2.JSONObject; import com.google.common.primitives.Bytes; import com.jsowell.common.constant.Constants; import com.jsowell.common.core.domain.ykc.YKCDataProtocol; import com.jsowell.common.core.domain.ykc.YKCFrameTypeCode; import com.jsowell.common.enums.ykc.OrderStatusEnum; import com.jsowell.common.enums.ykc.PayModeEnum; import com.jsowell.common.enums.ykc.ReturnCodeEnum; import com.jsowell.common.enums.ykc.StartModeEnum; import com.jsowell.common.exception.BusinessException; import com.jsowell.common.util.BytesUtil; import com.jsowell.common.util.StringUtils; import com.jsowell.common.util.YKCUtils; import com.jsowell.common.util.id.IdUtils; import com.jsowell.netty.factory.YKCOperateFactory; import com.jsowell.pile.domain.OrderBasicInfo; import com.jsowell.pile.domain.OrderDetail; import com.jsowell.pile.domain.PileAuthCard; import com.jsowell.pile.domain.PileBasicInfo; import com.jsowell.pile.service.IPileAuthCardService; import com.jsowell.pile.service.IPileBasicInfoService; import com.jsowell.pile.service.IPileBillingTemplateService; import com.jsowell.pile.service.impl.MemberBasicInfoServiceImpl; import com.jsowell.pile.transaction.dto.OrderTransactionDTO; import com.jsowell.pile.transaction.service.TransactionService; import com.jsowell.pile.vo.uniapp.CurrentTimePriceDetails; import com.jsowell.pile.vo.uniapp.MemberVO; import com.jsowell.pile.vo.web.BillingTemplateVO; import io.netty.channel.Channel; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.math.BigDecimal; import java.util.Date; /** * 充电桩主动申请启动充电 0x31 * * 启动充电鉴权结果 * @author JS-ZZA * @date 2022/9/19 14:29 */ @Slf4j @Component public class ConfirmStartChargingRequestHandler extends AbstractHandler{ private final String type = YKCUtils.frameType2Str(YKCFrameTypeCode.REQUEST_START_CHARGING_CODE.getBytes()); @Autowired private MemberBasicInfoServiceImpl memberBasicInfoService; @Autowired private IPileAuthCardService pileAuthCardService; @Autowired private TransactionService pileTransactionService; @Autowired private IPileBasicInfoService pileBasicInfoService; @Autowired private IPileBillingTemplateService pileBillingTemplateService; @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 = 7; // 桩编码 byte[] pileSnByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String pileSn = BytesUtil.binary(pileSnByteArr, 16); // 保存时间 saveLastTime(pileSn); // 枪号 startIndex += length; length = 1; byte[] connectorNumByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String connectorCode = BytesUtil.bcd2Str(connectorNumByteArr); // 启动方式 // 0x01 表示通过刷卡启动充电 // 0x02 表求通过帐号启动充电 （暂不支持） // 0x03 表示vin码启动充电 startIndex += length; byte[] startModeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String startMode = BytesUtil.bcd2Str(startModeByteArr); // 是否需要密码 0x00 不需要 0x01 需要 startIndex += length; byte[] needPasswordFlagByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String needPasswordFlag = BytesUtil.bcd2Str(needPasswordFlagByteArr); // 物理卡号 不足 8 位补 0 startIndex += length; length = 8; byte[] cardNumByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String physicsCard = BytesUtil.binary(cardNumByteArr, 16); log.info("物理卡号：{}", physicsCard); // 输入密码 对用户输入的密码进行16 位MD5 加密，采用小写上传 startIndex += length; length = 16; byte[] inputPasswordByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); // VIN码 startIndex += length; length = 17; byte[] vinCodeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length); String logicCard = ""; byte[] authenticationFlagByteArr = Constants.zeroByteArray; byte[] accountBalanceByteArr = Constants.zeroByteArray; String transactionCode = ""; try { if (StringUtils.equals("01", startMode)) { // 刷卡启动充电 // 根据传过来的物理卡号查询数据库中此卡信息 PileAuthCard pileAuthCardInfo = pileAuthCardService.selectCardInfoByLogicCard(physicsCard); if (pileAuthCardInfo == null) { // 未查到此卡信息 throw new BusinessException(ReturnCodeEnum.CODE_THIS_CARD_HAS_NO_INFO); } if (StringUtils.isBlank(pileAuthCardInfo.getMemberId())) { // 卡未绑定用户 throw new BusinessException(ReturnCodeEnum.CODE_THIS_CARD_NOT_BIND_USER); } // 卡状态 String cardStatus = pileAuthCardInfo.getStatus(); // 逻辑卡号 logicCard = pileAuthCardInfo.getLogicCard(); // 通过memberId获取账户余额 MemberVO memberVO = memberBasicInfoService.queryMemberInfoByMemberId(pileAuthCardInfo.getMemberId()); BigDecimal principalBalance = memberVO.getPrincipalBalance(); // 本金金额 double accountBalance = principalBalance.add(memberVO.getGiftBalance()).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue(); accountBalanceByteArr = YKCUtils.getPriceByte(String.valueOf(accountBalance), 2); if (!StringUtils.equals("1", cardStatus)) { return null; } // 鉴权成功标识 0x00 失败 0x01 成功 authenticationFlagByteArr = Constants.oneByteArray; transactionCode = IdUtils.generateTransactionCode(pileSn, connectorCode); // 通过桩号查询所属站点 PileBasicInfo pileBasicInfo = pileBasicInfoService.selectPileBasicInfoBySN(pileSn); Long stationId = pileBasicInfo.getStationId(); // TODO 个人桩站点不计费 // 将此订单信息存入订单表 String orderCode = IdUtils.getOrderCode(); // 订单基本信息 OrderBasicInfo orderBasicInfo = OrderBasicInfo.builder() .orderCode(orderCode) .transactionCode(transactionCode) .orderStatus(OrderStatusEnum.NOT_START.getValue()) .memberId(memberVO.getMemberId()) .stationId(String.valueOf(stationId)) .pileSn(pileSn) .connectorCode(connectorCode) .pileConnectorCode(pileSn + connectorCode) .logicCard(logicCard) .startMode(StartModeEnum.CARD.getValue()) .payStatus(Constants.ZERO) .payAmount(new BigDecimal(String.valueOf(accountBalance))) .payTime(new Date()) .payMode(PayModeEnum.PAYMENT_OF_BALANCE.getValue()) .orderAmount(BigDecimal.ZERO) .build(); // 根据桩编码查询当前计费模板 BillingTemplateVO billingTemplateVO = pileBillingTemplateService.selectBillingTemplateDetailByPileSn(pileSn); // 订单详情 OrderDetail orderDetail = OrderDetail.builder() .orderCode(orderCode) .sharpElectricityPrice(billingTemplateVO.getSharpElectricityPrice()) .sharpServicePrice(billingTemplateVO.getSharpServicePrice()) .peakElectricityPrice(billingTemplateVO.getPeakElectricityPrice()) .peakServicePrice(billingTemplateVO.getPeakServicePrice()) .flatElectricityPrice(billingTemplateVO.getFlatElectricityPrice()) .flatServicePrice(billingTemplateVO.getFlatServicePrice()) .valleyElectricityPrice(billingTemplateVO.getValleyElectricityPrice()) .valleyServicePrice(billingTemplateVO.getValleyServicePrice()) .build(); OrderTransactionDTO createOrderTransactionDTO = OrderTransactionDTO.builder() .orderBasicInfo(orderBasicInfo) .orderDetail(orderDetail) .build(); pileTransactionService.doCreateOrder(createOrderTransactionDTO); // 将卡状态改为启动锁定 PileAuthCard pileAuthCard = PileAuthCard.builder() .id(pileAuthCardInfo.getId()) .logicCard(physicsCard) .status("2") .build(); pileAuthCardService.updatePileAuthCard(pileAuthCard); } } catch (BusinessException e){ log.error("刷卡启动充电鉴权 error:{}, {}", e.getCode(), e.getMessage()); }catch (Exception e){ log.error("刷卡启动充电鉴权 error", e); } // 应答 // 交易流水号 // String transactionCode = IdUtils.generateTransactionCode(pileSn, connectorCode); byte[] serialNumByteArr = BytesUtil.str2Bcd(transactionCode); // 逻辑卡号 // String logicCardNum = "00000000"; // 账户余额 保留两位小数 // MemberVO memberVO = memberBasicInfoService.selectInfoByPhysicsCard(physicsCard); // BigDecimal principalBalance = memberVO.getPrincipalBalance(); // 本金金额 // double accountBalance = principalBalance.add(memberVO.getGiftBalance()).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue(); // byte[] accountBalanceByteArr = BytesUtil.str2Bcd(String.valueOf(accountBalance)); // 鉴权成功标识 0x00 失败 0x01 成功 // byte[] authenticationFlagByteArr = Constants.oneByteArray; /** * 失败原因 * 0x01 账户不存在 * 0x02 账户冻结 * 0x03 账户余额不足 * 0x04 该卡存在未结账记录 * 0x05 桩停用 * 0x06 该账户不能在此桩上充电 * 0x07 密码错误 * 0x08 电站电容不足 * 0x09 系统中vin 码不存在 * 0x0A 该桩存在未结账记录 * 0x0B 该桩不支持刷卡 */ byte[] defeatReasonByteArr = Constants.zeroByteArray; // 拼装消息体 byte[] msgBodyByteArr = Bytes.concat(serialNumByteArr, pileSnByteArr, connectorNumByteArr, cardNumByteArr, accountBalanceByteArr, authenticationFlagByteArr, defeatReasonByteArr); return getResult(ykcDataProtocol, msgBodyByteArr); } }