| | |
|---|
| | | long CHARGING_PILE_STARTS_CHARGING = System.currentTimeMillis(); |
|---|
| | | |
|---|
| | | ChargingPileStartsChargingMessage chargingPileStartsChargingMessage = JSON.parseObject(content.toJSONString(),ChargingPileStartsChargingMessage.class); |
|---|
| | | // 幂等防护：IoT平台会对启动申请并发/重复推送（同桩同枪同启动方式同卡/VIN）， |
|---|
| | | // 重复申请直接忽略，防止重复建单及硬件收到一失败一成功多个应答（order侧枪锁tryLock(0)快速失败所致） |
|---|
| | | String startIdemAccount = chargingPileStartsChargingMessage.getStart_method() != null |
|---|
| | | && chargingPileStartsChargingMessage.getStart_method() == 3 |
|---|
| | | ? chargingPileStartsChargingMessage.getVin() |
|---|
| | | : chargingPileStartsChargingMessage.getAccount(); |
|---|
| | | String startIdemKey = "IOT_START_CHARGING_IDEM:" + chargingPileStartsChargingMessage.getCharging_pile_code() |
|---|
| | | + ":" + chargingPileStartsChargingMessage.getCharging_gun_code() |
|---|
| | | + ":" + chargingPileStartsChargingMessage.getStart_method() |
|---|
| | | + ":" + startIdemAccount; |
|---|
| | | Boolean startIdemFirst = redisTemplate.opsForValue().setIfAbsent(startIdemKey, System.currentTimeMillis(), 60, TimeUnit.SECONDS); |
|---|
| | | if (!Boolean.TRUE.equals(startIdemFirst)) { |
|---|
| | | log.warn("CHARGING_PILE_STARTS_CHARGING重复申请，幂等忽略 key={}", startIdemKey); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | chargingMessage.setChargingPileStartsChargingMessage(chargingPileStartsChargingMessage); |
|---|
| | | chargingMessageUtil.handleMessage(chargingMessage); |
|---|
| | | // 按启动方式执行真实业务鉴权建单（1=刷卡SD订单，2=账号暂不支持，3=VIN码VD订单） |
|---|
| | |
|---|
| | | platformConfirmationCharging.setFailure_cause(startVO == null ? null : startVO.getFailureCause()); |
|---|
| | | } |
|---|
| | | iotMessageProduce.sendMessage(platformConfirmationCharging.getCharging_pile_code(), ServiceIdMenu.PLATFORM_CONFIRMATION_CHARGING.getKey(),messageUtil.platformConfirmationCharging(platformConfirmationCharging)); |
|---|
| | | // 鉴权/建单失败时删除幂等键，放行设备重试（避免60秒内重新刷卡/VIN启动被误拦）；成功则保留键至TTL过期 |
|---|
| | | if (!Integer.valueOf(1).equals(platformConfirmationCharging.getAuthentication())) { |
|---|
| | | redisTemplate.delete(startIdemKey); |
|---|
| | | } |
|---|
| | | |
|---|
| | | log.warn("CHARGING_PILE_STARTS_CHARGING消息处理：{} 毫秒", System.currentTimeMillis() - CHARGING_PILE_STARTS_CHARGING); |
|---|
| | | break; |
|---|
